@xingjs@20250220@添加处理sww相关接口类

xingjinshuang

2025-02-20 0890b7861feae74bdcfd1851e577db6b9f31d484

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

@@ -20,7 +20,6 @@
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

import javax.annotation.Resource;
import java.io.File;
@@ -30,12 +29,6 @@
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * 仿真服务类
 *
 * @author WWW
 * @date   2024-09-18
 */
@Slf4j
@Service
@SuppressWarnings("ALL")
@@ -55,9 +48,6 @@
    @Resource
    ResultService resultService;

    /**
     * 获取
     */
    public IPage<SimuPo> get(SimuVo vo) {
        QueryWrapper<SimuPo> wrapper = getPageWrapper(vo);

@@ -80,7 +70,7 @@
        if (null != vo.getNum()) {
            wrapper.eq("num", vo.getNum());
        }
        if (!StringUtils.isEmpty(vo.getName())) {
        if (!StringHelper.isEmpty(vo.getName())) {
            wrapper.like("lower(name)", vo.getName().trim().toLowerCase());
        }
        if (!CollUtil.isEmpty(vo.getStatus())) {
@@ -90,9 +80,6 @@
        return wrapper;
    }

    /**
     * 删除
     */
    public int del(List<Integer> ids) {
        List<SimuPo> list = simuMapper.selectBatchIds(ids);
        if (null != list && list.size() > 0) {
@@ -134,6 +121,9 @@
        wrapper.last("limit 1");

        return simuMapper.selectOne(wrapper);
    }
    public SimuPo getSimuById(Integer id) {
        return simuMapper.selectById(id);
    }

    public SimuPo getSimuByServiceName(String serviceName) {
@@ -196,12 +186,6 @@
        executor.shutdown();
    }

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