月球大数据地理空间分析展示平台-【后端】-月球后台服务
13693261870
2023-09-12 235032f6f941ea94595014570925196e7357b7cf
修改栅格发布的文件组成形式
已添加1个文件
已修改3个文件
166 ■■■■ 文件已修改
src/main/java/com/moon/server/controller/data/PublishController.java 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/moon/server/entity/shujian/CreateLayerEntity.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/moon/server/entity/shujian/TaskResultEntity.java 115 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/moon/server/service/data/ShuJianService.java 44 ●●●●● 补丁 | 查看 | 原始文档 | 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();
    }
}