mybatis配置更新

services/load-transfer-mq/src/main/java/com/hdkj/lt/mq/mapper/plan/PlanAwaitTransferAreaResultMapper.java

@@ -23,13 +23,13 @@ public interface PlanAwaitTransferAreaResultMapper extends BaseMapper<PlanAwaitT
 
     List<SwitchInfoDTO> getSwitchSectionInfo(String lineId, String startSwitchId, String linkSwitchId, List<String> endSwitchIds, List<String> switchTypes);
 
-    List<FhzgDistTransformerCustomer> getTransformerCustomerInfo(List<String> trans, List<String> customers, LocalDateTime planStartTime, LocalDateTime planEndTime);
+    List<FhzgDistTransformerCustomer> getTransformerCustomerInfo(@Param("trans") List<String> trans, @Param("customers") List<String> customers, @Param("planStartTime") LocalDateTime planStartTime, @Param("planEndTime") LocalDateTime planEndTime);
 
-    PlanPowerCutVO selectPlanAndPlanTime(Long planId);
+    PlanPowerCutVO selectPlanAndPlanTime(@Param("planId") Long planId);
 
-    void saveBreakerSvgAfterBatch(List<FhzgInfoBreakerSvgAfter> breakerSvgAfterList);
+    void saveBreakerSvgAfterBatch(@Param("breakerSvgAfterList") List<FhzgInfoBreakerSvgAfter> breakerSvgAfterList);
 
-    List<SwitchTreeNode> getBreakerSvgAfter(String feeder, Long planId, List<String> deviceTypes);
+    List<SwitchTreeNode> getBreakerSvgAfter(@Param("feeder") String feeder, @Param("planId") Long planId, @Param("deviceTypes") List<String> deviceTypes);
 }
 
 

services/load-transfer-mq/src/main/java/com/hdkj/lt/mq/service/plan/impl/AnalysisTransferResultServiceImpl.java

@@ -181,7 +181,7 @@ public class AnalysisTransferResultServiceImpl implements IAnalysisTransferResul
                     List<FhzgPlanTransferSchemeUsers> transferSchemeUsers = Lists.newArrayList();
                     // 转供方案可转用户
                     List<FhzgPlanTransferableSchemeUsers> transferableSchemeUsers = Lists.newArrayList();
-                    Snowflake snowflake = IdUtil.getSnowflake(1,1);
+                    Snowflake snowflake = IdUtil.getSnowflake(1, 1);
                     //转供前开关信息
                     LambdaQueryWrapper<FhzgPlanSwitchInfoList> lambdaQueryWrapper = new LambdaQueryWrapper<>();
                     lambdaQueryWrapper.eq(FhzgPlanSwitchInfoList::getPlanId, planId);
@@ -337,7 +337,7 @@ public class AnalysisTransferResultServiceImpl implements IAnalysisTransferResul
                 BigDecimal rateCapacity = StringToBigDecimal(powerTransformerInfo.getRateCapacity());
                 powerTransferInfo.setRateCapacity(rateCapacity);
                 powerTransferInfo.setVoltLevel(getVolLevelByEnum(powerTransformerInfo.getVoltLevel()));
-                if (powerTransformerPAfter != null && rateCapacity != null&& rateCapacity.compareTo(BigDecimal.valueOf(0))!=0) {
+                if (powerTransformerPAfter != null && rateCapacity != null && rateCapacity.compareTo(BigDecimal.valueOf(0)) != 0) {
                     powerTransferInfo.setLoadRate(powerTransformerPAfter.divide(rateCapacity, 5, RoundingMode.HALF_UP).multiply(new BigDecimal("100")));
                 }
                 powerTransferInfoList.add(powerTransferInfo);
@@ -480,7 +480,12 @@ public class AnalysisTransferResultServiceImpl implements IAnalysisTransferResul
         // 获取最大电流信息负载计算等信息
         stateEstimationEquip.setPsrIds(dataList.stream().map(e -> e.getLineId()).collect(Collectors.toList()));
         // 调用实时量测接口获取七天最大电流值，判断接口返回情况，错误时防止解析中断
-        ApiResponse<Map<String, BigDecimal>> lineIResp = IMeasurementApiClient.queryPeriodByCommonQuery(stateEstimationEquip);
+        ApiResponse<Map<String, BigDecimal>> lineIResp = new ApiResponse<>();
+        try {
+            lineIResp = IMeasurementApiClient.queryPeriodByCommonQuery(stateEstimationEquip);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
 //        HashMap hashMap = new HashMap();
 //        hashMap.put("15DKX-5837", new BigDecimal("160"));
 //        lineIResp.setData(hashMap);
@@ -609,7 +614,7 @@ public class AnalysisTransferResultServiceImpl implements IAnalysisTransferResul
                                                       List<XferSupplyAreaDTO> supplyAreaList, Long schemeId, AtomicReference<Integer> powerOnSuccess
             , Map<String, FeederCheckRuleDTO> feederCheckRuleDTOMap) {
         LoginUser loginUser = SecurityUtils.getLoginUser();
-        Snowflake snowflake = IdUtil.getSnowflake(1,1);
+        Snowflake snowflake = IdUtil.getSnowflake(1, 1);
         supplyAreaList.forEach(e -> {
             if (Integer.compare(powerOnSuccess.get(), 0) == 0) {
                 powerOnSuccess.set(Objects.equals(e.getPowerOnSuccess(), Boolean.TRUE) ? 1 : 0);
@@ -832,7 +837,7 @@ public class AnalysisTransferResultServiceImpl implements IAnalysisTransferResul
                             .tag("1")
                             .body(message).build();
                     com.aliyun.openservices.ons.api.Message message1 = buildMessage(messageEntity);
-                   // log.info("计划停电消息推送：{}", JSON.toJSONString(message1));
+                    // log.info("计划停电消息推送：{}", JSON.toJSONString(message1));
                     message1.setTag("1");
                     message1.setTopic(RocketMQConstants.TOPIC_ID_SOLUTION_OPERATION_TICKET);
                     producerBean.sendAsync(message1, messageEntity.getSendCallback());

services/pom.xml

@@ -221,6 +221,9 @@
                     <source>${java.version}</source>
                     <target>${java.version}</target>
                     <encoding>${project.build.sourceEncoding}</encoding>
+                    <compilerArgs>
+                        <arg>-parameters</arg>
+                    </compilerArgs>
                 </configuration>
             </plugin>
         </plugins>