添加消息

zoniot-water/zoniot-water-xxl-client/src/main/java/com/bz/zoneiot/water/xxl/jobs/WorkOrderManageJob.java

@@ -48,7 +48,9 @@ public class WorkOrderManageJob extends BaseJob {
     **/
     @XxlJob("workOrderManageJob")
     public ReturnT<String> execute(String string) {
+        log.info("【工单处理】开始");
         saveWorkOrderManageInfo();
+        log.info("【工单处理】结束");
         return ReturnT.SUCCESS;
     }
 
@@ -60,6 +62,7 @@ public class WorkOrderManageJob extends BaseJob {
     **/
     public void saveWorkOrderManageInfo(){
         List<DeviceAlarmInfoForOrderVo> deviceAlarmInfoForOrders = alarmDetailMapper.getAlarmInfoForWorkOrderManage();
+        log.info("【工单处理】报警信息数量：{}", deviceAlarmInfoForOrders != null? deviceAlarmInfoForOrders.size() : 0);
         if (CollectionUtils.isEmpty(deviceAlarmInfoForOrders)){
             return;
         }
@@ -93,6 +96,7 @@ public class WorkOrderManageJob extends BaseJob {
             workOrderManageByAlarm.setTaskDesc(deviceAlarmInfoForOrder.getTaskDesc());
             // 推送消息
             sendMessage(deviceAlarmInfoForOrder, workOrderManageByAlarm, errData);
+            log.info("【工单处理】消息推送完成.");
             workOrderManageByAlarms.add(workOrderManageByAlarm);
         }
         // 去掉推送失败的数据
@@ -100,14 +104,16 @@ public class WorkOrderManageJob extends BaseJob {
             deviceAlarmInfoForOrders.removeAll(errData);
         }
         // 保存工单
-        if (workOrderManageByAlarms.size()>0){
+        if (workOrderManageByAlarms.size() > 0){
             operationManagerClient.saveByAlarms(workOrderManageByAlarms);
+            log.info("【工单处理】保存工单数量：{}", workOrderManageByAlarms.size());
         }
         if (updates.size()>0){
             operationManagerClient.updateByAlarms(updates);
+            log.info("【工单处理】更新工单数量：{}", updates.size());
         }
         if (deviceAlarmInfoForOrders.size()>0){
-            //标记报警已生成工单
+            // 标记报警已生成工单
             alarmDetailMapper.updateAlarmSendMessageState(deviceAlarmInfoForOrders);
         }
     }