[update] 添加分区字段

wj-datacenter-service/src/main/java/net/wanji/datacenter/pojo/entity/CrossStrategyResultEntity.java

@@ -59,4 +59,6 @@ public class CrossStrategyResultEntity {
     private String emptyDir;
     @TableField("empty_turn")
     private String emptyTurn;
+    @TableField("dt")
+    private Integer dt;
 }

wj-datacenter-service/src/main/java/net/wanji/datacenter/service/impl/CrossStrategyOptServiceImpl.java

 package net.wanji.datacenter.service.impl;
 
+import cn.hutool.core.date.DateUtil;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.extern.slf4j.Slf4j;
 import net.wanji.common.utils.tool.JacksonUtils;
@@ -73,6 +74,14 @@ public class CrossStrategyOptServiceImpl implements CrossStrategyOptService {
                 entity.setEmptyDir(PhaseEmptyEnum.getDir(rtnType));
                 entity.setEmptyTurn(PhaseEmptyEnum.getTurn(rtnType));
                 entity.setResponseContent(idx.getResponseContent());
+                if (Objects.nonNull(date)) {
+                    String parse = DateUtil.format(date, "yyyyMMdd");
+                    entity.setDt(Integer.valueOf(parse));
+                } else {
+                    Date current = new Date();
+                    String parse = DateUtil.format(current, "yyyyMMdd");
+                    entity.setDt(Integer.valueOf(parse));
+                }
                 crossStrategyResultMapper.insert(entity);
             }
         } catch (Exception e) {
@@ -92,6 +101,7 @@ public class CrossStrategyOptServiceImpl implements CrossStrategyOptService {
             crossStrategyResultEntity.setCrossName(dto.getCrossName());
             crossStrategyResultEntity.setCurrentAlgo(dto.getCurrentAlgo());
             crossStrategyResultEntity.setRequestTime(dto.getRequestTime());
+            Date issueTime = dto.getIssueTime();
             crossStrategyResultEntity.setIssueTime(dto.getIssueTime());
             crossStrategyResultEntity.setResponseCode(dto.getResponseCode());
             crossStrategyResultEntity.setTimingPlan(mapper.writeValueAsString(dto.getTimingPlan()));
@@ -106,6 +116,14 @@ public class CrossStrategyOptServiceImpl implements CrossStrategyOptService {
             crossStrategyResultEntity.setControlDir(dto.getControlDir());
             crossStrategyResultEntity.setData(mapper.writeValueAsString(dto.getData()));
             crossStrategyResultEntity.setResponseContent(dto.getResponseContent());
+            if (Objects.nonNull(issueTime)) {
+                String parse = DateUtil.format(issueTime, "yyyyMMdd");
+                crossStrategyResultEntity.setDt(Integer.valueOf(parse));
+            } else {
+                Date date = new Date();
+                String parse = DateUtil.format(date, "yyyyMMdd");
+                crossStrategyResultEntity.setDt(Integer.valueOf(parse));
+            }
             crossStrategyResultMapper.insert(crossStrategyResultEntity);
         } catch (Exception e) {
             throw new RuntimeException(e);