日志格式化

onemap-modules/onemap-analyse/src/main/java/com/onemap/analyse/service/ILogService.java

@@ -1,7 +1,5 @@
 package com.onemap.analyse.service;
 
-import com.onemap.common.datasource.annotation.Slave;
-
 /**
  * 规划，合规分析日志
  */

onemap-modules/onemap-analyse/src/main/java/com/onemap/analyse/service/impl/FzssServiceImpl.java

@@ -145,6 +145,18 @@ public class FzssServiceImpl implements IFzssService {
         return fzxzCalc;
     }
 
+    /**
+     * 更新辅助选任务状态
+     *
+     * @param bsm
+     * @param rwzt
+     */
+    private void updateFzxzStatus(String bsm, Integer rwzt) {
+        UpdateWrapper<FzxzDTO> wrapper = new UpdateWrapper<>();
+        wrapper.eq("bsm", bsm).set("rwzt", Rwzt.getRun());
+        fzxzMapper.update(null, wrapper);
+    }
+
     /**
      * 规划选址逻辑在这里
      *
@@ -154,10 +166,8 @@ public class FzssServiceImpl implements IFzssService {
     @Override
     public RequestResult startSchedule(FzxzCalc fzxzCalc) {
         FzxzDTO fzxzDTO = fzxzCalc.getFzxzDTO();
-        // 0.开始规划
-        UpdateWrapper<FzxzDTO> wrapper = new UpdateWrapper<>();
-        wrapper.eq("bsm", fzxzDTO.getBsm()).set("rwzt", Rwzt.getRun());
-        fzxzMapper.update(null, wrapper);
+        // 0.开始规划,更新任务状态
+        updateFzxzStatus(fzxzDTO.getBsm(), Rwzt.getRun());
 
         // TODO 数据源
         String sjyName = "";
@@ -227,7 +237,10 @@ public class FzssServiceImpl implements IFzssService {
         iLogService.saveLog(fzxzDTO.getBsm(), "辅助选址", "计算完成", "info");
 
         // 5.生成报告,生成world文件
-        iReportService.createReport(fzxzDTO.getBsm(), null);
+        FzxzReport fzxzReport = iReportService.createReport(fzxzDTO.getBsm(), null);
+
+        // 6.开始规划,更新任务状态
+        updateFzxzStatus(fzxzDTO.getBsm(), Rwzt.getComplete());
 
         Map<String, Object> resMap = new HashMap<>();
         resMap.put("rwbsm", fzxzDTO.getBsm());
@@ -287,7 +300,7 @@ public class FzssServiceImpl implements IFzssService {
             return RequestResult.error("标识码参数未传递！", null);
         }
         // 查询辅助选址基本信息
-        QueryWrapper<FzxzDTO> fzxzwrapper = new QueryWrapper<FzxzDTO>();
+        QueryWrapper<FzxzDTO> fzxzwrapper = new QueryWrapper<>();
         fzxzwrapper.eq("bsm", bsm);
         FzxzDTO fzxzinfo = fzxzMapper.selectOne(fzxzwrapper);
         if (fzxzinfo == null) {
@@ -304,7 +317,6 @@ public class FzssServiceImpl implements IFzssService {
         xzyzWrapper.eq("rwbsm", result.getBsm());
         List<FzxzXzyzDTO> fzxzXzyzDTOS = fzxzXzyzMapper.selectList(xzyzWrapper);
         result.setXzyz(fzxzXzyzDTOS);
-
         return RequestResult.success("查询成功！", result);
     }
 

onemap-modules/onemap-analyse/src/main/java/com/onemap/analyse/service/impl/LogServiceImpl.java

@@ -4,7 +4,6 @@ import com.onemap.analyse.domain.FxrwrzDTO;
 import com.onemap.analyse.mapper.FxrwrzMapper;
 import com.onemap.analyse.service.ILogService;
 import com.onemap.common.core.utils.StringUtils;
-import com.onemap.common.datasource.annotation.Slave;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;