[update] 下发相位参数优化

signal-control-service/src/main/java/net/wanji/web/service/impl/PlanSendServiceImpl.java

@@ -80,8 +80,8 @@ public class PlanSendServiceImpl implements PlanSendService {
      * @param crossId
      * @return
      */
-    public JsonViewObject phaseLaneSend(String crossId) {
-        PhaseTimingSendVO phaseTimingSendVO = buiPhaseTimingSendVO(crossId);
+    public JsonViewObject phaseLaneSend(String crossId, Integer schemeId) {
+        PhaseTimingSendVO phaseTimingSendVO = buiPhaseTimingSendVO(crossId, schemeId);
         JsonViewObject jsonViewObject = feignProxyService.phaseTimingSend(phaseTimingSendVO);
         return jsonViewObject;
     }
@@ -92,12 +92,13 @@ public class PlanSendServiceImpl implements PlanSendService {
      * @param crossId
      * @return
      */
-    private PhaseTimingSendVO buiPhaseTimingSendVO(String crossId) {
+    private PhaseTimingSendVO buiPhaseTimingSendVO(String crossId, Integer schemeId) {
         PhaseTimingSendVO phaseTimingSendVO = new PhaseTimingSendVO();
         phaseTimingSendVO.setCrossCode(crossId);
         List<PhaseTimingSendVO.Phase> phaseList = new ArrayList<>();
         CrossPhasePO crossPhasePO = new CrossPhasePO();
         crossPhasePO.setCrossId(crossId);
+        crossPhasePO.setPlanId(schemeId);
         List<CrossPhasePO> crossPhasePOS = crossPhaseMapper.listCrossPhasePO(crossPhasePO);
         CrossPhaseLightsPO crossPhaseLightsPO = new CrossPhaseLightsPO();
         crossPhaseLightsPO.setCrossId(crossId);
@@ -160,8 +161,6 @@ public class PlanSendServiceImpl implements PlanSendService {
         if (Objects.isNull(planSendResult) || planSendResult.getCode() != 200) {
             return jsonViewObject.fail("信号机方案下发-日计划下发UTC服务调用异常");
         }
-        // 下发车道相位
-        phaseLaneSend(crossId);
 
         // 更新时间表状态为已执行
         crossSchedulesMapper.resetStatus(crossId);
@@ -197,6 +196,9 @@ public class PlanSendServiceImpl implements PlanSendService {
             schemeIdDTO.setCrossId(crossId);
             schemeIdDTO.setSchemeId(schemeId);
             schemeSend(schemeIdDTO);
+
+            // 下发车道相位
+            phaseLaneSend(crossId, schemeId);
         }
 
         PlanSendVO planSendVO = new PlanSendVO();
@@ -218,13 +220,18 @@ public class PlanSendServiceImpl implements PlanSendService {
         Integer schemeId = schemeIdDTO.getSchemeId();
         List<SchemeSendVO.Pattern> patternList = buildPatternList(crossId, schemeId);
         schemeSendVO.setPatternList(patternList);
+
+        // 下发车道相位
+        phaseLaneSend(crossId, schemeId);
+
         // 发送请求
         JsonViewObject jsonViewObject = utcFeignClients.schemeSend(schemeSendVO);
         if (Objects.isNull(jsonViewObject) || jsonViewObject.getCode() != 200) {
             return jsonViewObject.fail("信号机方案下发-基础方案下发UTC服务调用异常");
         }
-        // 下发车道相位
-        phaseLaneSend(crossId);
+
+
+
         // 更新方案表状态为已执行
         crossSchemeMapper.resetStatus(crossId);
         crossSchemeMapper.updateStatus(schemeId);

signal-control-service/src/main/resources/mapper/scheme/CrossPhaseMapper.xml

@@ -36,7 +36,10 @@
         from t_base_cross_phase
         <where>
             <if test="entity.crossId != null and entity.crossId !=''">
-                cross_id = #{entity.crossId}
+                and cross_id = #{entity.crossId}
+            </if>
+            <if test="entity.planId != null and entity.planId !=''">
+                and plan_id = #{entity.planId}
             </if>
         </where>
     </select>

signal-utc-service/src/main/java/net/wanji/utc/common/typeenum/CrossLightsDirEnum.java

@@ -7,10 +7,10 @@ import java.util.Objects;
  * @date 2023/04/03 16:26
  */
 public enum CrossLightsDirEnum {
-    ONE(1, 1),// 由南向北
-    TWO(3, 4), // 由西向东
-    THREE(5, 2),// 由北向南
-    FOUR(7, 3);// 由东向西
+    ONE(5, 1),// 灯组放行方向（车道方向） 由南向北
+    TWO(7, 4), // 由西向东
+    THREE(1, 2),// 由北向南
+    FOUR(3, 3);// 由东向西
 
     private final Integer lightsCode;
     private final Integer hkLightsCode;