修改 创建 方法

13693261870

2024-10-30 fe487bbf0cd12e1f424afc99c461f6c1907e62f5

 src/main/java/com/se/simu/service/SimuService.java

@@ -24,6 +24,8 @@

import javax.annotation.Resource;
import java.io.File;
import java.sql.Timestamp;
import java.util.Date;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@@ -49,6 +51,9 @@

    @Resource
    UwService uwService;

    @Resource
    ResultService resultService;

    /**
     * 获取
@@ -131,11 +136,18 @@
    }

    public boolean create(CreateSimuVo vo) {
        Date now = new Date();
        String date = StringHelper.YMDHMS2_FORMAT.format(now);
        if (StringHelper.isEmpty(vo.getName())) {
            vo.setName(date);
        }

        DataPo data = BeanUtil.copyProperties(vo, DataPo.class);
        data.setPath(vo.getName(), vo.getName());
        data.setPath(date, date);
        initPath(data);

        SimuPo simu = new SimuPo(vo.getNum(), vo.getPid(), vo.getName(), JSONUtil.toJsonStr(data), 0, vo.getBak());
        simu.setCreateTime(new Timestamp(now.getTime()));

        int rows = simuMapper.insert(simu);
        if (rows > 0) {
@@ -164,16 +176,19 @@
            @Override
            @SneakyThrows
            public void run() {
                scope(simu);
                cope(simu);
            }
        });
        executor.shutdown();
    }

    /**
     * 处理，状态：0-创建仿真，1-连接GEDB库，2-下载空间数据，3-下载高程数据，4-模拟内涝仿真，5-处理仿真数据，10-完成，-10-出错
     * 处理数据，状态标识：
     * 0-创建仿真任务，1-连接GEDB库，2-下载空间数据，3-下载高程数据，
     * 4-生成降雨文件，5-生成配置文件，6-模拟内涝仿真，7-处理水位文件，
     * 8-处理排水文件，9-处理仿真结果，10-完成，-10-出错
     */
    private void scope(SimuPo simu) {
    private void cope(SimuPo simu) {
        try {
            DataPo data = JSONUtil.toBean(simu.getData(), DataPo.class);

@@ -189,16 +204,27 @@
            gedbService.copeDem(token, data);

            update(simu, 4, null);
            uwService.createConfig();
            uwService.callExe();
            uwService.createRainFile(data);

            //update(simu, 5, null);
            // 处理仿真数据
            update(simu, 5, null);
            uwService.createConfig(data);

            //update(simu, 10, "完成");
            update(simu, 6, null);
            uwService.callExe(data);

            update(simu, 7, null);
            //uwService.copeWaterFiles();

            update(simu, 8, null);
            uwService.copeDrainFiles(data);

            update(simu, 9, null);
            resultService.process(data);

            update(simu, 10, "完成");
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
            update(simu, -10, ex.getMessage());
            update(simu, -simu.getStatus(), ex.getMessage());
        }
    }