[add] 实时监控-路口优化方案下发

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

@@ -9,6 +9,7 @@ import net.wanji.common.framework.Constants;
 import net.wanji.common.utils.tool.DateUtil;
 import net.wanji.common.utils.tool.StringUtils;
 import net.wanji.feign.pojo.result.JsonViewObject;
+import net.wanji.feign.pojo.vo.SchemeSendVO;
 import net.wanji.feign.pojo.vo.SignalStatusVO;
 import net.wanji.feign.service.UtcFeignClients;
 import net.wanji.opt.dto.*;
@@ -108,6 +109,7 @@ public class CrossOptimizeServiceImpl implements CrossOptimizeService {
             } else {
                 phaseTimeOptResultMap = getPhaseTimeOptMap(timeOffsetPhaseMap);
             }
+
             // 相位优化总的可加可减时间，
             /**
              *
@@ -115,6 +117,21 @@ public class CrossOptimizeServiceImpl implements CrossOptimizeService {
              * 路口编号、计划号、方案号、相位号、原相位时长、优化后相位时长、调整时长
              */
             // 方案优化下发
+            String key = String.join(Constants.SystemParam.SEPARATOR_UNDER_LINE, "1", "s");
+            CrossPhaseDTO crossPhaseDTO = phaseMap.get(key);
+            String planNo = crossPhaseDTO.getPlanNo();
+
+            SchemeSendVO schemeSendVO = new SchemeSendVO();
+            List<SchemeSendVO.Pattern> patternList = new ArrayList<>();
+            SchemeSendVO.Pattern pattern = new SchemeSendVO.Pattern();
+
+            schemeSendVO.setCrossCode(crossId);
+            schemeSendVO.setPatternList(patternList);
+            JsonViewObject jsonViewObject = utcFeignClients.schemeSend(schemeSendVO);
+            if (Objects.isNull(jsonViewObject) || jsonViewObject.getCode() != 200) {
+                log.error("实时监控路口优化方案下发异常！");
+                throw new Exception();
+            }
 
             // 记录已优化的路口
             CROSS_OPT.add(crossId);