[update] 调度计划更新

signal-utc-hisense-service/src/main/java/net/wanji/utc/hisense/service/impl/StaticInfoServiceImpl.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import net.wanji.common.utils.tool.ScheduleUtil;
 import net.wanji.common.utils.tool.StringUtils;
 import net.wanji.databus.dao.entity.CrossSchedulesPO;
 import net.wanji.databus.dao.mapper.CrossInfoMapper;
@@ -76,7 +77,7 @@ public class StaticInfoServiceImpl implements StaticInfoService {
                 crossInfoPO.setCode(cIntsID);
                 crossInfoPO.setName(vIntersectionEntity.getCIntsName());
                 crossInfoPO.setIp(vIntersectionEntity.getCCONTROLLERIP());
-                String [] array = {String.valueOf(vIntersectionEntity.getLongitude()), String.valueOf(vIntersectionEntity.getLatitude())};
+                String[] array = {String.valueOf(vIntersectionEntity.getLongitude()), String.valueOf(vIntersectionEntity.getLatitude())};
                 crossInfoPO.setLocation(StringUtils.join(array, ","));
                 crossInfoPO.setVersion(vIntersectionEntity.getCControllerModel());
                 crossInfoPO.setManufacturerId(22);
@@ -99,33 +100,80 @@ public class StaticInfoServiceImpl implements StaticInfoService {
     @Override
     public List<CrossSchedulesPO> crossSchedules(CrossSchedulesDTO crossSchedulesDTO) throws Exception {
 
-        String manufacturerCode = crossSchedulesDTO.getManufacturerCode();
+        Map<String, String> codeCrossIdMap = getCodeCrossIdMap(crossSchedulesDTO);
+
+        // 路口编号列表
         List<String> crossIdList = crossSchedulesDTO.getCrossIdList();
-        if (!CollectionUtils.isEmpty(crossIdList)) {
-            List<CrossSchedulesPO> result = new ArrayList<>(crossIdList.size());
-            for (String crossId : crossIdList) {
+        // 信号机编号
+        List<String> crossCodeList = crossInfoMapper.selectCrossCodesByIds(crossIdList);
+        List<CrossSchedulesPO> results = new ArrayList<>(crossCodeList.size());
+        if (!CollectionUtils.isEmpty(crossCodeList)) {
+            for (String code : crossCodeList) {
                 LambdaQueryWrapper<VNtcipTimeBaseSchedule> queryWrapper = new LambdaQueryWrapper<>();
-                queryWrapper.eq(VNtcipTimeBaseSchedule::getCIntsID, crossId);
+                queryWrapper.eq(VNtcipTimeBaseSchedule::getCIntsID, code);
                 List<VNtcipTimeBaseSchedule> vNtcipTimeBaseSchedules = vNtcipTimeBaseScheduleMapper.selectList(queryWrapper);
                 if (!CollectionUtils.isEmpty(vNtcipTimeBaseSchedules)) {
                     for (VNtcipTimeBaseSchedule vNtcipTimeBaseSchedule : vNtcipTimeBaseSchedules) {
                         if (Objects.nonNull(vNtcipTimeBaseSchedule)) {
                             CrossSchedulesPO crossSchedulesPO = new CrossSchedulesPO();
-                            crossSchedulesPO.setCrossId(crossId);
+                            crossSchedulesPO.setCrossId(codeCrossIdMap.get(code));
                             crossSchedulesPO.setScheduleNo(vNtcipTimeBaseSchedule.getNTimeBaseScheduleNumber());
                             crossSchedulesPO.setName("海信调度" + vNtcipTimeBaseSchedule.getNTimeBaseScheduleNumber());
-                            if (8190 == vNtcipTimeBaseSchedule.getNTimeBaseScheduleMonth()) {
-                                Integer nTimeBaseScheduleDay = vNtcipTimeBaseSchedule.getNTimeBaseScheduleDay();
-                                //crossSchedulesPO.setWeek();
+                            // 海信月份
+                            Integer hisenseMonth = vNtcipTimeBaseSchedule.getNTimeBaseScheduleMonth();
+                            // 星期
+                            Integer hisenseWeek = vNtcipTimeBaseSchedule.getNTimeBaseScheduleDay();
+                            // 日期 2147483647
+                            Integer hisenseDays = vNtcipTimeBaseSchedule.getNTimeBaseScheduleDate();
+                            String monthsStr = ScheduleUtil.getSchedule(hisenseMonth.longValue(), 1);
+                            String daysStr = ScheduleUtil.getSchedule(hisenseDays.longValue(), 2);
+                            String weekStr = ScheduleUtil.getSchedule(hisenseWeek.longValue(), 3);
+                            if (StringUtils.isNotBlank(weekStr)) {
+                                String[] weekSplit = weekStr.split(",");
+                                for (String oneWeek : weekSplit) {
+                                    CrossSchedulesPO crossSchedulesPOWeek = new CrossSchedulesPO();
+                                    crossSchedulesPOWeek.setCrossId(codeCrossIdMap.get(code));
+                                    crossSchedulesPOWeek.setScheduleNo(vNtcipTimeBaseSchedule.getNTimeBaseScheduleNumber());
+                                    crossSchedulesPOWeek.setName("海信调度" + vNtcipTimeBaseSchedule.getNTimeBaseScheduleNumber());
+                                    crossSchedulesPOWeek.setWeek(Integer.valueOf(oneWeek));
+                                    crossSchedulesPOWeek.setMonths(monthsStr);
+                                    crossSchedulesPOWeek.setDays(daysStr);
+                                    crossSchedulesPOWeek.setPlanId(0);
+                                    results.add(crossSchedulesPOWeek);
+                                }
+                            } else {
+                                // 不执行周调度
+                                CrossSchedulesPO crossSchedulesPOMonthDays = new CrossSchedulesPO();
+                                crossSchedulesPOMonthDays.setCrossId(codeCrossIdMap.get(code));
+                                crossSchedulesPOMonthDays.setScheduleNo(vNtcipTimeBaseSchedule.getNTimeBaseScheduleNumber());
+                                crossSchedulesPOMonthDays.setName("海信调度" + vNtcipTimeBaseSchedule.getNTimeBaseScheduleNumber());
+                                crossSchedulesPOMonthDays.setWeek(null);
+                                crossSchedulesPOMonthDays.setMonths(monthsStr);
+                                crossSchedulesPOMonthDays.setDays(daysStr);
+                                crossSchedulesPOMonthDays.setPlanId(0);
+                                results.add(crossSchedulesPOMonthDays);
                             }
-
-
                         }
                     }
                 }
             }
         }
-        return null;
+        return results;
+    }
+
+    /**
+     * 通过厂商编码，获取map<code 信号机编码, crossId 路口编号></>
+     *
+     * @param crossSchedulesDTO
+     * @return
+     */
+    private Map<String, String> getCodeCrossIdMap(CrossSchedulesDTO crossSchedulesDTO) {
+        String manufacturerCode = crossSchedulesDTO.getManufacturerCode();
+        Integer id = manufacturerInfoMapper.selectIdByCode(manufacturerCode);
+        List<CrossInfoPO> crossInfoPOList = crossInfoMapper.selectByManufacturerId(id);
+        List<String> codeList = crossInfoPOList.stream().map(CrossInfoPO::getCode).collect(Collectors.toList());
+        Map<String, String> codeCrossIdMap = crossInfoPOList.stream().collect(Collectors.toMap(CrossInfoPO::getCode, CrossInfoPO::getId));
+        return codeCrossIdMap;
     }
 
     @Override
@@ -140,13 +188,13 @@ public class StaticInfoServiceImpl implements StaticInfoService {
 
         //给海信发送http请求
         String post = OkHttpClientUtil.xmlPost(hisenseUrl, document.asXML());
-        if (StringUtils.isBlank(post)){
+        if (StringUtils.isBlank(post)) {
             log.error("请求 5.7. 协调状态 失败");
             return null;
         }
         Document postResult = DocumentHelper.parseText(post);
         String result = postResult.selectSingleNode(HttpConstants.SYSTEMSCRIPTION_RESULT).getText();
-        if (HttpConstants.RESULT_1.equals(result)){
+        if (HttpConstants.RESULT_1.equals(result)) {
             //成功
             String spot = postResult.selectSingleNode(HttpConstants.SYSTEMSCRIPTION_MESSAGECONTENT).valueOf("Spot");
             String CoordPatternStatus = postResult.selectSingleNode(HttpConstants.SYSTEMSCRIPTION_MESSAGECONTENT).valueOf("CoordPatternStatus");
@@ -160,7 +208,7 @@ public class StaticInfoServiceImpl implements StaticInfoService {
                     .build();
             return coordinationStatus;
 
-        }else {
+        } else {
             //失败
             log.error("请求 5.7. 协调状态 失败");
         }
@@ -180,13 +228,13 @@ public class StaticInfoServiceImpl implements StaticInfoService {
         messageContent.addElement(HttpConstants.PATTERN).setText(crossSchemeRingsDTO.getPattern());
         //给海信发送http请求
         String post = OkHttpClientUtil.xmlPost(hisenseUrl, document.asXML());
-        if (StringUtils.isBlank(post)){
+        if (StringUtils.isBlank(post)) {
             log.error("请求 5.15.根据方案号获取配时方案环图 失败");
             return null;
         }
         Document postResult = DocumentHelper.parseText(post);
         String result = postResult.selectSingleNode(HttpConstants.SYSTEMSCRIPTION_RESULT).getText();
-        if (HttpConstants.RESULT_1.equals(result)){
+        if (HttpConstants.RESULT_1.equals(result)) {
             //成功
             String patternRest = postResult.selectSingleNode(HttpConstants.SYSTEMSCRIPTION_MESSAGECONTENT).valueOf("Pattern");
             String cycleLen = postResult.selectSingleNode(HttpConstants.SYSTEMSCRIPTION_MESSAGECONTENT).valueOf("CycleLen");
@@ -226,7 +274,7 @@ public class StaticInfoServiceImpl implements StaticInfoService {
             crossSchemeRings.setPhaseList(phaseList);
             return crossSchemeRings;
 
-        }else {
+        } else {
             //失败
             log.error("请求 5.15. 方案环图请求 失败");
         }