[add] 神思策略接口

signal-optimize-service/src/main/java/net/wanji/opt/dao/mapper/StrategyControlInfoMapper.java

+package net.wanji.opt.dao.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import net.wanji.opt.po.StrategyControlDataEntity;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * @author duanruiming
+ * @date 2024/11/04 10:57
+ */
+public interface StrategyControlInfoMapper extends BaseMapper<StrategyControlDataEntity> {
+    int insertBatch(@Param("list") List<StrategyControlDataEntity> list);
+}

signal-optimize-service/src/main/java/net/wanji/opt/po/StrategyControlDataEntity.java

+package net.wanji.opt.po;
+
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * @author duanruiming
+ * @date 2024/11/04 10:53
+ */
+@Data
+public class StrategyControlDataEntity {
+    /** value = 路口干线Id */ 
+    private String bizId;
+    /** value = 类型 0-路口 1-干线 */ 
+    private Integer bizType;
+    /** value = 策略类型 0-绿波带 1-失衡 2-溢出 3-空放 */ 
+    private Integer strategy;
+    /** value = 开始时间日期 */ 
+    private Date scheduleStart;
+    /** value = 结束时间日期 */ 
+    private Date scheduleEnd;
+    /** value = 日计划表 */ 
+    private String time;
+    /** value = 调控频率（秒），策略下发的频率（只针对失衡和绿波带有效） */ 
+    private Integer frequency;
+    /** value = 状态（1=开启，0=停止） */ 
+    private Integer status;
+}

signal-optimize-service/src/main/java/net/wanji/opt/synthesis/pojo/StrategyControlDataVO.java

@@ -28,7 +28,7 @@ public class StrategyControlDataVO {
     @ApiModelProperty(value = "日计划表")
     private List<StrategyControlDataVO.TimeTable> time;
     @ApiModelProperty(value = "调控频率（秒），策略下发的频率（只针对失衡和绿波带有效）")
-    private Integer freq;
+    private Integer frequency;
     @ApiModelProperty(value = "状态（1=开启，0=停止）")
     private Integer status;
     @ApiModelProperty(value = "操作（insert=新增,update=更新，delete=删除）")

signal-optimize-service/src/main/java/net/wanji/opt/synthesis/service/impl/StrategyControlServiceImpl.java

@@ -7,13 +7,16 @@ import net.wanji.common.enums.DateStyle;
 import net.wanji.common.framework.Constants;
 import net.wanji.common.framework.rest.JsonViewObject;
 import net.wanji.common.utils.tool.JacksonUtils;
+import net.wanji.opt.dao.mapper.StrategyControlInfoMapper;
+import net.wanji.opt.po.StrategyControlDataEntity;
 import net.wanji.opt.synthesis.pojo.*;
 import net.wanji.opt.synthesis.service.PushStrategyControlService;
 import net.wanji.opt.synthesis.service.StrategyControlService;
-import org.springframework.beans.factory.annotation.Autowired;
+import org.apache.commons.beanutils.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
+import javax.annotation.Resource;
 import java.util.*;
 
 /**
@@ -24,34 +27,26 @@ import java.util.*;
 @Service
 public class StrategyControlServiceImpl implements StrategyControlService {
 
-    @Autowired
+    @Resource
     private PushStrategyControlService pushStrategyControlService;
+    @Resource
+    private StrategyControlInfoMapper strategyControlInfoMapper;
 
     @Override
     public JsonViewObject strategyInfoOperation(StrategyControlVO strategyControlVO) throws Exception {
 
         try {
-            StrategyControlReq req = convertReq(strategyControlVO);
             // 存库
-            // 调用推送
-            //StrategyControlDataReq detailData = new StrategyControlDataReq();
-            //detailData.setBiz_id("241940");
-            //detailData.setBiz_type(0);
-            //detailData.setStrategy(3);
-            //Date date = new Date();
-            //detailData.setSchedule_end(DateUtil.format(date, DateStyle.YYYY_MM_DD_HH_MM_SS.getValue()));
-            //detailData.setSchedule_end(DateUtil.format(date, DateStyle.YYYY_MM_DD_HH_MM_SS.getValue()));
-            //StrategyControlDataReq.Time_table timeTable = new StrategyControlDataReq.Time_table();
-            //timeTable.setWeek(1);
-            //timeTable.setTime_list(new String[]{"00:00-01:00", "01:00-02:00"});
-            //StrategyControlDataReq.Time_table timeTable1 = new StrategyControlDataReq.Time_table();
-            //timeTable1.setWeek(1);
-            //timeTable1.setTime_list(new String[]{"02:00-03:00", "03:00-04:00"});
-            //detailData.setTime(Arrays.asList(timeTable1, timeTable));
-            //detailData.setFreq(1000 * 60);
-            //detailData.setStrategy(1);
-            //detailData.setAction("insert");
+            List<StrategyControlDataEntity> entities = new ArrayList<>();
+            List<StrategyControlDataVO> dataList = strategyControlVO.getDataList();
+            for (StrategyControlDataVO dataVO : dataList) {
+                StrategyControlDataEntity entity = new StrategyControlDataEntity();
+                BeanUtils.copyProperties(entity, dataVO);
+                entity.setTime(JacksonUtils.getInstance().writeValueAsString(dataVO.getTime()));
+            }
+            strategyControlInfoMapper.insertBatch(entities);
 
+            StrategyControlReq req = convertReq(strategyControlVO);
             // todo 测试数据
             //req.setData(Arrays.asList(detailData));
             Result result = pushStrategyControlService.push(req);
@@ -93,7 +88,7 @@ public class StrategyControlServiceImpl implements StrategyControlService {
                         timeTables.add(timeTable);
                     });
                     detailData.setTime(timeTables);
-                    detailData.setFreq(dataVO.getFreq());
+                    detailData.setFreq(dataVO.getFrequency());
                     detailData.setStatus(dataVO.getStatus());
                     detailData.setAction(dataVO.getAction());
                     dataReqList.add(detailData);

signal-optimize-service/src/main/resources/mapper/StrategyControlInfoMapper.xml

+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="net.wanji.opt.dao.mapper.StrategyControlInfoMapper">
+
+    <insert id="insertBatch" parameterType="net.wanji.opt.po.StrategyControlDataEntity">
+        INSERT INTO t_strategy_control_info (
+        bizId,
+        bizType,
+        strategy,
+        schedule_start,
+        schedule_end,
+        `time`,
+        frequency,
+        status,
+        create_time,
+        gmt_modified
+        ) VALUES
+        <foreach collection="list" item="entity" separator=",">
+            #{entity.bizId},
+            #{entity.bizType},
+            #{entity.strategy},
+            #{entity.scheduleStart},
+            #{entity.scheduleEnd},
+            #{entity.time},
+            #{entity.frequency},
+            #{entity.status},
+            #{createTime, jdbcType=TIMESTAMP, default=CURRENT_TIMESTAMP},
+            #{gmtModified, jdbcType=TIMESTAMP, default=CURRENT_TIMESTAMP, update="CURRENT_TIMESTAMP"}
+        </foreach>
+    </insert>
+</mapper>
\ No newline at end of file