[update] 静态数据和下发数据优化

signal-utc-service/src/main/java/net/wanji/utc/common/constant/Constants.java

@@ -10,6 +10,7 @@ import java.util.List;
 import java.util.concurrent.ConcurrentHashMap;
 
 @Component
+@SuppressWarnings("all")
 public class Constants {
     /**
      * 厂商接口地址

signal-utc-service/src/main/java/net/wanji/utc/controller/ControlCommandController.java

@@ -4,7 +4,6 @@ import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
-import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import net.wanji.utc.entity.JsonViewObject;
 import net.wanji.utc.service.control.ControlCommandStrategyService;
@@ -12,6 +11,8 @@ import net.wanji.utc.vo.*;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
+import javax.annotation.Resource;
+
 import static net.wanji.utc.common.constant.Constants.*;
 
 /**
@@ -23,12 +24,11 @@ import static net.wanji.utc.common.constant.Constants.*;
 @Slf4j
 @RestController
 @RequestMapping("/controlCommand")
-@RequiredArgsConstructor
 @Api(value = "控制指令接口", description = "控制指令接口")
 public class ControlCommandController {
 
-    private final ControlCommandStrategyService controlCommandStrategyService;
-
+    @Resource
+    private ControlCommandStrategyService controlCommandStrategyService;
 
     /**
      * 信号机方案下发

signal-utc-service/src/main/java/net/wanji/utc/controller/StaticInfoController.java

 package net.wanji.utc.controller;
 
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiResponse;
 import io.swagger.annotations.ApiResponses;
-import net.wanji.utc.entity.JsonViewObject;
-import net.wanji.utc.po.*;
-import net.wanji.utc.service.staticinfo.StaticInfoService;
 import net.wanji.utc.dto.CrossInfoDTO;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
 import net.wanji.utc.dto.CrossSchedulesDTO;
 import net.wanji.utc.dto.PlanSectionDTO;
 import net.wanji.utc.dto.SchemePhaseLightsDTO;
+import net.wanji.utc.entity.JsonViewObject;
+import net.wanji.utc.po.CrossInfoPO;
+import net.wanji.utc.po.CrossSchedulesPO;
+import net.wanji.utc.service.staticinfo.StaticInfoService;
 import net.wanji.utc.vo.PlanSectionVO;
 import net.wanji.utc.vo.SchemePhaseLightsVO;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
 
 import javax.ws.rs.core.MediaType;
 import java.util.List;
+import java.util.Objects;
 
 /**
  * 静态信息接口
@@ -77,7 +82,7 @@ public class StaticInfoController {
         String crossId = planSectionDTO.getCrossId();
         Integer planNo = planSectionDTO.getPlanNo();
         PlanSectionVO planSectionVO = new PlanSectionVO();
-        if (planNo == -1) {
+        if (Objects.isNull(planNo) || planNo == -1) {
             // 返回所有
             planSectionVO = staticInfoService.buildPlanSectionResponse(crossId);
         } else {

signal-utc-service/src/main/java/net/wanji/utc/mapper/CrossSectionMapper.java

@@ -11,7 +11,8 @@ import java.util.List;
  */
 public interface CrossSectionMapper {
     void deleteOne(@Param("crossId") String crossId,
-                   @Param("timeSecNo") Integer timeSecNo);
+                   @Param("timeSecNo") Integer timeSecNo,
+                   @Param("planId") Integer planId);
 
     void insertOne(CrossSectionPO crossSectionPO);
 

signal-utc-service/src/main/java/net/wanji/utc/po/hk/request/PlanSectionInfoQueryPO.java

+package net.wanji.utc.po.hk.request;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author duanruiming
+ * @date 2023/02/16 15:28
+ */
+@Data
+public class PlanSectionInfoQueryPO {
+    private List<PlanSectionQueryPO> data;
+
+    @Data
+    public static class PlanSectionQueryPO {
+        private String crossCode;
+        private Integer planNo;
+    }
+}

signal-utc-service/src/main/java/net/wanji/utc/po/hk/response/PlanPO.java

+package net.wanji.utc.po.hk.response;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author duanruiming
+ * @date 2023/02/16 15:56
+ */
+@Data
+public class PlanPO {
+    private Integer planNo;
+    private String planName;
+    private List<SectionPO> sectionList;
+}

signal-utc-service/src/main/java/net/wanji/utc/po/hk/response/PlanSectionResponseListPO.java

+package net.wanji.utc.po.hk.response;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author duanruiming
+ * @date 2023/02/16 15:38
+ */
+@Data
+public class PlanSectionResponseListPO {
+    private String crossCode;
+    private List<PlanPO> planList;
+}

signal-utc-service/src/main/java/net/wanji/utc/po/hk/response/SectionPO.java

+package net.wanji.utc.po.hk.response;
+
+import lombok.Data;
+
+/**
+ * @author duanruiming
+ * @date 2023/02/16 15:56
+ */
+@Data
+public class SectionPO {
+    private Integer timeSecNo;
+    private String beginTime;
+    private Integer patternNo;
+    private Integer controlType;
+}

signal-utc-service/src/main/java/net/wanji/utc/service/control/impl/ControlCommandStrategyServiceImpl.java

@@ -6,8 +6,8 @@ import net.wanji.utc.common.typeenum.DateStyle;
 import net.wanji.utc.entity.JsonViewObject;
 import net.wanji.utc.mapper.*;
 import net.wanji.utc.po.*;
-import net.wanji.utc.service.control.ControlCommandStrategyService;
 import net.wanji.utc.service.control.ControlCommandService;
+import net.wanji.utc.service.control.ControlCommandStrategyService;
 import net.wanji.utc.util.StringUtils;
 import net.wanji.utc.vo.*;
 import org.springframework.stereotype.Service;
@@ -40,29 +40,24 @@ public class ControlCommandStrategyServiceImpl implements ControlCommandStrategy
     private final CrossPlanMapper crossPlanMapper;
     private final CrossSchedulesMapper crossSchedulesMapper;
 
-
     /**
      * 通过路口编号获取厂商编码
      *
      * @param crossId
      * @return
      */
-    public String getManufacturerCodeByCrossId(String crossId) throws Exception{
-        // 获取厂商ID和信号机ID
+    public String getManufacturerCodeByCrossId(String crossId) throws Exception {
         CrossInfoPO crossInfoPO = crossInfoMapper.selectByPrimaryKey(crossId);
         if (Objects.isNull(crossInfoPO)) {
-            throw new Exception("当前路口编号不存在!");
+            throw new Exception("当前路口信息不存在!");
         }
-        String signalId = crossInfoPO.getCode();
         Integer manufacturerId = crossInfoPO.getManufacturerId();
-        // 获取厂商代码
         ManufacturerInfoPO manufacturerInfoPO = manufacturerInfoMapper.selectById(manufacturerId);
         return manufacturerInfoPO.getCode();
     }
 
-
-    @Transactional(rollbackFor = Exception.class)
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public JsonViewObject schemeSendStrategy(SchemeSendVO schemeSendVO) throws Exception {
         JsonViewObject jsonViewObject;
         String manufacturerIdCode = getManufacturerCodeByCrossId(schemeSendVO.getCrossCode());
@@ -120,9 +115,30 @@ public class ControlCommandStrategyServiceImpl implements ControlCommandStrategy
         crossSchemeMapper.insertBatch(crossSchemePOList);
     }
 
-    @Transactional(rollbackFor = Exception.class)
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public JsonViewObject planSendStrategy(PlanSendVO planSendVO) throws Exception {
+        PlanSendVO.Plan plan = new PlanSendVO.Plan();
+        plan.setPlanNo("1");
+        plan.setPlanDescribe("date1111");
+
+        List<PlanSendVO.Plan.Section> sectionList = new ArrayList<>();
+        PlanSendVO.Plan.Section section = new PlanSendVO.Plan.Section();
+        section.setPatternNo("1");
+        section.setSectionNo("1");
+        section.setControlMode("4"); // runMode
+        section.setBeginTime("7:00");
+        section.setEndTime("18:00");
+        sectionList.add(section);
+        plan.setSectionList(sectionList);
+
+        List<PlanSendVO.Plan> plans = new ArrayList<>();
+        plans.add(plan);
+
+        planSendVO.setPlanList(plans);
+        planSendVO.setCrossCode("14Q1409IRF0");
+
+
         JsonViewObject jsonViewObject;
         String manufacturerIdCode = getManufacturerCodeByCrossId(planSendVO.getCrossCode());
         if (StringUtils.equals(BasicEnum.ManufacturerEnum.HK.getCode(), manufacturerIdCode)) {
@@ -161,8 +177,8 @@ public class ControlCommandStrategyServiceImpl implements ControlCommandStrategy
         crossPlanMapper.insertBatch(crossPlanPOList);
     }
 
-    @Transactional(rollbackFor = Exception.class)
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public JsonViewObject scheduleSendStrategy(ScheduleSendVO scheduleSendVO) throws Exception {
         JsonViewObject jsonViewObject;
         String manufacturerIdCode = getManufacturerCodeByCrossId(scheduleSendVO.getCrossCode());

signal-utc-service/src/main/java/net/wanji/utc/service/staticinfo/impl/HkCrossSchedulesServiceImpl.java

@@ -50,8 +50,7 @@ public class HkCrossSchedulesServiceImpl implements HkCrossSchedulesService {
         if (Objects.nonNull(hkResponse) && Objects.equals(Constants.HK_SUCCESS_CODE, hkResponse.getCode())) {
             String dataStr = String.valueOf(hkResponse.getData());
             if (StringUtils.isNotBlank(dataStr)) {
-                List<ScheduleResponseListPO> scheduleResponseListPOS = JSONObject.parseObject(dataStr, new TypeReference<List<ScheduleResponseListPO>>() {
-                });
+                List<ScheduleResponseListPO> scheduleResponseListPOS = JSONObject.parseObject(dataStr, new TypeReference<List<ScheduleResponseListPO>>() {});
                 for (ScheduleResponseListPO scheduleResponseListPO : scheduleResponseListPOS) {
                     String crossCode = scheduleResponseListPO.getCrossCode();
                     List<ScheduleResponsePO> schedules = scheduleResponseListPO.getSchedules();

signal-utc-service/src/main/java/net/wanji/utc/service/staticinfo/impl/HkPlanSectionServiceImpl.java

 package net.wanji.utc.service.staticinfo.impl;
 
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.TypeReference;
 import com.hikvision.artemis.sdk.ArtemisHttpUtil;
 import com.hikvision.artemis.sdk.config.ArtemisConfig;
 import lombok.RequiredArgsConstructor;
@@ -14,12 +13,20 @@ import net.wanji.utc.mapper.CrossSectionMapper;
 import net.wanji.utc.po.CrossPlanPO;
 import net.wanji.utc.po.CrossSchemePO;
 import net.wanji.utc.po.CrossSectionPO;
+import net.wanji.utc.po.hk.request.PlanSectionInfoQueryPO;
+import net.wanji.utc.po.hk.response.HKResponse;
+import net.wanji.utc.po.hk.response.PlanPO;
+import net.wanji.utc.po.hk.response.PlanSectionResponseListPO;
+import net.wanji.utc.po.hk.response.SectionPO;
 import net.wanji.utc.service.staticinfo.HkPlanSectionService;
 import net.wanji.utc.util.PathUtil;
 import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
 
-import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 
 /**
  * @author Kent HAN
@@ -37,63 +44,76 @@ public class HkPlanSectionServiceImpl implements HkPlanSectionService {
     public void planSection(String crossCode, Integer planNo, String crossId) throws Exception {
         // 请求3.1.6接口，获取信号机计划
         Map<String, String> path = PathUtil.getPathMapByApiCode("uploadPlan");
-        JSONObject dataEle = new JSONObject();
-        dataEle.put("crossCode", crossCode);
-        dataEle.put("planNo", planNo);
-        ArrayList<JSONObject> data = new ArrayList<>();
-        data.add(dataEle);
-        JSONObject requestContent = new JSONObject();
-        requestContent.put("data", data);
-        String body = requestContent.toJSONString();
-        String responseStr = ArtemisHttpUtil.doPostStringArtemis(artemisConfig, path, body, null,
+        PlanSectionInfoQueryPO planSectionInfoQueryPO = new PlanSectionInfoQueryPO();
+        PlanSectionInfoQueryPO.PlanSectionQueryPO planSectionQueryPO = new PlanSectionInfoQueryPO.PlanSectionQueryPO();
+        planSectionQueryPO.setCrossCode(crossCode);
+        planSectionQueryPO.setPlanNo(planNo);
+        planSectionInfoQueryPO.setData(Arrays.asList(planSectionQueryPO));
+        String requestBody = JSONObject.toJSONString(planSectionInfoQueryPO);
+        // 调用海康平台获取结果
+        String responseStr = ArtemisHttpUtil.doPostStringArtemis(artemisConfig, path, requestBody, null,
                 null, "application/json", null);
-        JSONObject responseObj = JSON.parseObject(responseStr);
-        if(Constants.HK_SUCCESS_CODE.equals(responseObj.getInteger(Constants.HK_CODE_KEY))) {
-            JSONArray responsedata = responseObj.getJSONArray("data");
-            for (int n = 0; n < responsedata.size(); n++) {
-                JSONObject responseDataEle = responsedata.getJSONObject(n);
-                JSONArray planList = responseDataEle.getJSONArray("planList");
-                for (int i = 0; i < planList.size(); i++) {
+        HKResponse hkResponse = JSONObject.parseObject(responseStr, HKResponse.class);
+        // 数据处理
+        insertPlanSection(crossId, hkResponse);
+    }
+
+    /**
+     * 解析数据，将数据保存到本地数据库
+     *
+     * @param crossId
+     * @param hkResponse
+     */
+    private void insertPlanSection(String crossId, HKResponse hkResponse) {
+        if (Objects.nonNull(hkResponse) && Objects.equals(hkResponse.getCode(), Constants.HK_SUCCESS_CODE)) {
+            String dataStr = String.valueOf(hkResponse.getData());
+            List<PlanSectionResponseListPO> planSectionResponseListPOS = JSONObject.parseObject(dataStr, new TypeReference<List<PlanSectionResponseListPO>>() {});
+            for (PlanSectionResponseListPO planSectionResponseListPO : planSectionResponseListPOS) {
+                String crossCodeRes = planSectionResponseListPO.getCrossCode();
+                List<PlanPO> planList = planSectionResponseListPO.getPlanList();
+                for (PlanPO planPO : planList) {
                     CrossPlanPO crossPlanPO = new CrossPlanPO();
-                    JSONObject plan = planList.getJSONObject(i);
-                    String responsePlanNo = plan.getString("planNo");
-                    crossPlanPO.setPlanNo(responsePlanNo);
-                    String name = plan.getString("planName");
-                    crossPlanPO.setName(name);
+                    crossPlanPO.setPlanNo(String.valueOf(planPO.getPlanNo()));
+                    crossPlanPO.setName(planPO.getPlanName());
                     crossPlanPO.setCrossId(crossId);
+                    // 插入之前的计划id，时段删除时使用
+                    List<CrossPlanPO> crossPlanPOS = crossPlanMapper.selectByCrossIdAndPlanNo(crossId, planPO.getPlanNo());
+                    Integer planId = null;
+                    if (!CollectionUtils.isEmpty(crossPlanPOS)) {
+                        planId = crossPlanPOS.get(0).getId();
+                    }
                     // 写入数据库
-                    crossPlanMapper.deleteOne(crossId, Integer.parseInt(responsePlanNo));
+                    crossPlanMapper.deleteOne(crossId, planPO.getPlanNo());
                     crossPlanMapper.insertOne(crossPlanPO);
                     Integer crossPlanPOId = crossPlanPO.getId();
                     // 构造时段数据
-                    JSONArray sectionList = plan.getJSONArray("sectionList");
-                    for (int j = 0; j < sectionList.size(); j++) {
-                        JSONObject section = sectionList.getJSONObject(j);
+                    List<SectionPO> sectionList = planPO.getSectionList();
+                    for (int i = 0; i < sectionList.size(); i++) {
+                        SectionPO sectionPO = sectionList.get(i);
                         CrossSectionPO crossSectionPO = new CrossSectionPO();
-                        String timeSecNo = section.getString("timeSecNo");
-                        crossSectionPO.setSectionNo(timeSecNo);
-                        String beginTime = section.getString("beginTime");
+                        crossSectionPO.setSectionNo(String.valueOf(sectionPO.getTimeSecNo()));
+                        String beginTime = sectionPO.getBeginTime();
                         crossSectionPO.setStartTime(beginTime);
                         // 计算结束时间
-                        if (j < sectionList.size() - 1) {
-                            JSONObject nextSection = sectionList.getJSONObject(j + 1);
-                            String endTime = nextSection.getString("beginTime");
+                        if (i < sectionList.size() - 1) {
+                            SectionPO nextSection = sectionList.get(i + 1);
+                            String endTime = nextSection.getBeginTime();
                             crossSectionPO.setEndTime(endTime);
                         } else {
                             crossSectionPO.setEndTime("24:00");
                         }
                         crossSectionPO.setCrossId(crossId);
                         crossSectionPO.setPlanId(crossPlanPOId);
-                        Integer controlType = section.getInteger("controlType");
+                        Integer controlType = sectionPO.getControlType();
                         controlType = HkPlanSectionControlTypeEnum.getCodeByHkCode(controlType);
                         crossSectionPO.setControlMode(controlType);
                         // 获取方案ID
-                        Integer schemeNo = section.getInteger("patternNo");
+                        Integer schemeNo = sectionPO.getPatternNo();
                         CrossSchemePO crossSchemePO = crossSchemeMapper.selectByCrossIdAndSchemeNo(crossId, schemeNo);
                         Integer schemePOId = crossSchemePO.getId();
                         crossSectionPO.setScemeId(schemePOId);
                         // 写入数据库
-                        crossSectionMapper.deleteOne(crossId, Integer.parseInt(timeSecNo));
+                        crossSectionMapper.deleteOne(crossId, sectionPO.getTimeSecNo(), planId);
                         crossSectionMapper.insertOne(crossSectionPO);
                     }
                 }

signal-utc-service/src/main/java/net/wanji/utc/service/staticinfo/impl/HkSchemePhaseLightsServiceImpl.java

@@ -48,6 +48,7 @@ public class HkSchemePhaseLightsServiceImpl implements HkSchemePhaseLightsServic
         JSONObject object = JSON.parseObject(Result);
         if(Constants.HK_SUCCESS_CODE.equals(object.getInteger(Constants.HK_CODE_KEY))) {
             JSONArray data = object.getJSONArray("data");
+            // 轮询获取方案详细信息
             for (int i = 0; i < data.size(); i++) {
                 JSONObject obj =  data.getJSONObject(i);
                 Integer patternNo = obj.getInteger("patternNo");

signal-utc-service/src/main/java/net/wanji/utc/service/staticinfo/impl/WanJiCommonStaticInfoServiceImpl.java

@@ -90,7 +90,7 @@ public class WanJiCommonStaticInfoServiceImpl implements WanJiCommonStaticInfoSe
 
                 List<CrossSectionPO> crossSectionPOList = content.getCrossSectionPOList();
                 crossSectionPOList.forEach(crossSectionPO -> {
-                    crossSectionMapper.deleteOne(crossId, Integer.parseInt(crossSectionPO.getSectionNo()));
+                    crossSectionMapper.deleteOne(crossId, Integer.parseInt(crossSectionPO.getSectionNo()), null);
                     crossSectionMapper.insertOne(crossSectionPO);
                 });
             }

signal-utc-service/src/main/resources/mapper/CrossSchedulesMapper.xml

@@ -29,7 +29,7 @@
 
     <select id="selectByCrossIds" resultMap="BaseResultMap">
         select
-            id,scheduleNo,name,cross_id,plan_id,week,special_date,gmt_create,gmt_modified
+            id,schedule_no,name,cross_id,plan_id,week,special_date,gmt_create,gmt_modified
         from t_cross_schedules
         where cross_id in
         <foreach collection="crossIds" item="crossId" separator="," open="(" close=")">

signal-utc-service/src/main/resources/mapper/CrossSectionMapper.xml

@@ -15,8 +15,8 @@
     </resultMap>
 
     <insert id="insertOne" keyProperty="id" useGeneratedKeys="true">
-        insert into t_cross_section(section_no,start_time,end_time,cross_id,plan_id,control_mode,sceme_id)
-        values (#{sectionNo},#{startTime},#{endTime},#{crossId},#{planId},#{controlMode},#{scemeId})
+        insert into t_cross_section(section_no, start_time, end_time, cross_id, plan_id, control_mode, sceme_id)
+        values (#{sectionNo}, #{startTime}, #{endTime}, #{crossId}, #{planId}, #{controlMode}, #{scemeId})
     </insert>
 
     <insert id="insertBatch" keyProperty="id" useGeneratedKeys="true">
@@ -29,21 +29,48 @@
 
     <delete id="deleteOne">
         delete from t_cross_section
-        where cross_id = #{crossId} and section_no = #{timeSecNo}
+        <where>
+            <if test="crossId != null and crossId != ''">
+                and cross_id = #{crossId}
+            </if>
+            <if test="timeSecNo != null and timeSecNo != ''">
+                and section_no = #{timeSecNo}
+            </if>
+            <if test="planId != null and planId != ''">
+                and plan_id = #{planId}
+            </if>
+        </where>
     </delete>
 
     <select id="selectByCrossId" resultMap="BaseResultMap">
-        select
-            id,section_no,start_time,end_time,cross_id,plan_id,control_mode,sceme_id,gmt_create,gmt_modified
+        select id,
+               section_no,
+               start_time,
+               end_time,
+               cross_id,
+               plan_id,
+               control_mode,
+               sceme_id,
+               gmt_create,
+               gmt_modified
         from t_cross_section
         where cross_id = #{crossId}
     </select>
 
     <select id="selectByCrossIdAndPlanId" resultMap="BaseResultMap">
-        select
-            id,section_no,start_time,end_time,cross_id,plan_id,control_mode,sceme_id,gmt_create,gmt_modified
+        select id,
+               section_no,
+               start_time,
+               end_time,
+               cross_id,
+               plan_id,
+               control_mode,
+               sceme_id,
+               gmt_create,
+               gmt_modified
         from t_cross_section
-        where cross_id = #{crossId} and plan_id = #{planId}
+        where cross_id = #{crossId}
+          and plan_id = #{planId}
     </select>