src/main/java/com/moon/server/controller/data/PublishController.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/moon/server/entity/shujian/CreateLayerEntity.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/moon/server/entity/shujian/TaskResultEntity.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/moon/server/service/data/ShuJianService.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
src/main/java/com/moon/server/controller/data/PublishController.java
@@ -167,16 +167,15 @@ @SysLog() @ApiOperation(value = "å页æ¥è¯¢æ°ç®çé¢è²è¡¨") @ApiImplicitParams({ @ApiImplicitParam(name = "port", value = "端å£", dataType = "int", paramType = "query", example = "50001"), @ApiImplicitParam(name = "pageSize", value = "æ¯é¡µæ¡æ°", dataType = "int", paramType = "query", example = "10"), @ApiImplicitParam(name = "pageIndex", value = "å页æ°ï¼ä»1å¼å§ï¼", dataType = "int", paramType = "query", example = "1") }) @GetMapping(value = "/selectSjColorTables") public void selectSjColorTables(Integer port, int pageSize, int pageIndex, HttpServletRequest req, HttpServletResponse res) { public void selectSjColorTables(int pageSize, int pageIndex, HttpServletRequest req, HttpServletResponse res) { pageIndex = Math.max(pageIndex, 1); pageSize = Math.max(pageSize, 5); shuJianService.selectSjColorTables(port, pageSize, pageIndex, req, res); shuJianService.selectSjColorTables(pageSize, pageIndex, req, res); } @SysLog() src/main/java/com/moon/server/entity/shujian/CreateLayerEntity.java
@@ -311,7 +311,7 @@ public ImagePathList() { datasource = "Local"; recursion = 1; recursion = 0; filter = new ArrayList<>(); } src/main/java/com/moon/server/entity/shujian/TaskResultEntity.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,115 @@ package com.moon.server.entity.shujian; import java.io.Serializable; import java.util.ArrayList; import java.util.List; /** * æ°ç®.ä»»å¡ç»æå®ä½ç±» * * @author WWW * @date 2023-09-12 */ @SuppressWarnings("AlibabaLowerCamelCaseVariableNaming") public class TaskResultEntity implements Serializable { private static final long serialVersionUID = -6420150955559673365L; public TaskResultEntity() { result = new ArrayList<>(); } private String command; private String status; private List<Result> result; public String getCommand() { return command; } public void setCommand(String command) { this.command = command; } public String getStatus() { return status; } public void setStatus(String status) { this.status = status; } public List<Result> getResult() { return result; } public void setResult(List<Result> result) { this.result = result; } public class Result { public Result() { } private String name; private Integer status; private Integer data_id; private String description; private Double process; private Integer command; public String getName() { return name; } public void setName(String name) { this.name = name; } public Integer getStatus() { return status; } public void setStatus(Integer status) { this.status = status; } public Integer getData_id() { return data_id; } public void setData_id(Integer data_id) { this.data_id = data_id; } public String getDescription() { return description; } public void setDescription(String description) { this.description = description; } public Double getProcess() { return process; } public void setProcess(Double process) { this.process = process; } public Integer getCommand() { return command; } public void setCommand(Integer command) { this.command = command; } } } src/main/java/com/moon/server/service/data/ShuJianService.java
@@ -78,9 +78,9 @@ /** * å页æ¥è¯¢æ°ç®çé¢è²è¡¨ */ public void selectSjColorTables(Integer port, Integer pageSize, Integer pageIndex, HttpServletRequest req, HttpServletResponse res) { public void selectSjColorTables(Integer pageSize, Integer pageIndex, HttpServletRequest req, HttpServletResponse res) { try { String url = String.format(COLOR_TABLE, null == port || 50001 == port ? sjUrl1 : sjUrl5, ak, pageSize, pageIndex); String url = String.format(COLOR_TABLE, sjUrl5, ak, pageSize, pageIndex); HttpHelper httpHelper = new HttpHelper(); httpHelper.service(req, res, null, url); @@ -108,18 +108,18 @@ */ public Integer insertSjService(PubEntity pub) { CreateLayerEntity layerEntity = createLayerEntity(pub); Integer layerId = postLayerEntity(layerEntity); if (null == layerId) { LayerResultEntity.Result layerResult = postLayerEntity(layerEntity); if (null == layerResult) { return 0; } CreateServiceEntity serviceEntity = createServiceEntity(pub, layerId); CreateServiceEntity serviceEntity = createServiceEntity(pub, layerResult.getLayer_id()); Integer serviceId = postServiceEntity(serviceEntity); if (null == serviceId) { return 0; } PublishEntity publishEntity = createPublishEntity(pub, layerId, serviceId); PublishEntity publishEntity = createPublishEntity(pub, layerResult.getLayer_id(), serviceId); int rows = publishService.insert(publishEntity); if (0 == rows) { return 0; @@ -131,7 +131,7 @@ insertMetaPub(pub, publishEntity.getId()); // layerService.insert(createLayerEntity(resEntity, StaticData.I3)) return rows; return layerResult.getMission_id(); } /** @@ -221,14 +221,14 @@ /** * åéå¾å±å®ä½ç±» */ public Integer postLayerEntity(CreateLayerEntity layerEntity) { public LayerResultEntity.Result postLayerEntity(CreateLayerEntity layerEntity) { Map<String, Object> map = getMapData(layerEntity); String url = String.format("%s/sj_raster/v6/api/layer?op=create_ex&%s", sjUrl5, ak); LayerResultEntity rs = postForRest(url, map, LayerResultEntity.class); boolean flag = null == rs || !StaticData.SUCCESS.equals(rs.getStatus()) || null == rs.getResult().getLayer_id(); boolean flag = null == rs || !StaticData.SUCCESS.equals(rs.getStatus()); return flag ? null : rs.getResult().getLayer_id(); return flag ? null : rs.getResult(); } /** @@ -418,18 +418,18 @@ setPubEntity(pub, entity); CreateLayerEntity layerEntity = createLayerEntity(pub); Integer layerId = postLayerEntity(layerEntity); if (null == layerId) { LayerResultEntity.Result layerResult = postLayerEntity(layerEntity); if (null == layerResult) { return 0; } CreateServiceEntity serviceEntity = createServiceEntity(pub, layerId); CreateServiceEntity serviceEntity = createServiceEntity(pub, layerResult.getLayer_id()); Integer serviceId = postServiceEntity(serviceEntity); if (null == serviceId) { return 0; } entity.setLayerid(layerId); entity.setLayerid(layerResult.getLayer_id()); entity.setServiceid(serviceId); entity.setEventid(pub.getUuid()); entity.setUpdateUser(pub.getUserId()); @@ -461,7 +461,7 @@ layerService.update(lyrEntity); } return entity.getId(); return layerResult.getMission_id(); } /** @@ -595,4 +595,18 @@ return map; } /** * è·åä»»å¡ç¶æ */ public List<TaskResultEntity.Result> getTaskStatus(List<Integer> list) { String url = String.format("%s/sj_raster/v6/api/mission?op=bulk_get_mission_status&%s", sjUrl5, ak); Map<String, Object> map = new HashMap<>(); map.put("cmd_list", list); TaskResultEntity rs = postForRest(url, map, TaskResultEntity.class); boolean flag = null == rs || !StaticData.SUCCESS.equals(rs.getStatus()); return flag ? null : rs.getResult(); } }