添加消息发送

refined-manager/src/main/java/com/mortals/xhx/daemon/task/SyncAppointWaitAndFinTaskImpl.java

@@ -3,6 +3,7 @@ package com.mortals.xhx.daemon.task;
 import cn.hutool.core.date.DateTime;
 import cn.hutool.core.date.DateUnit;
 import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.NumberUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.http.HttpUtil;
 import com.alibaba.fastjson.JSON;
@@ -208,15 +209,19 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService {
                         FinPersonInfo finPersonInfo = waitMap.get(item.getWaitId());
                         item.setProcessStatus(ProcessStatusEnum.接件结束.getValue());
                         item.setCallTime(finPersonInfo.getCalltime());
-                        Long diff = DateUtil.between(item.getTakeTime(), finPersonInfo.getCalltime(), DateUnit.MINUTE);
+                        Long diff = DateUtil.between(item.getTakeTime(), finPersonInfo.getCalltime(), DateUnit.SECOND);
                         if (!ObjectUtils.isEmpty(finPersonInfo.getAvgWaitTime())) {
-                            int avgWait = finPersonInfo.getAvgWaitTime() / 60;
+                            int avgWait = finPersonInfo.getAvgWaitTime();
                             if (avgWait > 0
-                                    && diff >= avgWait) {
+                                    && diff > avgWait) {
                                 //todo 构造发送消息。
                                 AlarmRecordsEntity recordsEntity = new AlarmRecordsEntity();
                                 recordsEntity.initAttrValue();
-                                String alarmContent = String.format("排队编号:%s:,%s业务叫号等待时间为%d分钟，超过了平均等待时长%d分钟!", item.getQueueNo(), item.getBussinessName(),diff,diff - avgWait+1);
+                                double doTime = NumberUtil.div(Double.parseDouble((diff)+""), 60, 1); // 保留1位小数，四舍五入
+                                double upTime = NumberUtil.div(Double.parseDouble((diff-avgWait)+""), 60, 1); // 保留1位小数，四舍五入
+
+                                String alarmContent = String.format("排队编号:%s:,%s业务叫号等待时间为%d分钟，超过了平均等待时长%d分钟!",
+                                        item.getQueueNo(), item.getBussinessName(),doTime,upTime);
                                 recordsEntity.setAlarmContent(alarmContent);
                                 recordsEntity.setAlarmTime(new Date());
                                 recordsEntity.setCreateTime(new Date());
@@ -253,13 +258,17 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService {
                         Long diff = DateUtil.between(item.getCallTime(), endPersonInfo.getEndtime(), DateUnit.MINUTE);
 
                         if (!ObjectUtils.isEmpty(endPersonInfo.getAvgHandleTime())) {
-                            int avgWait = endPersonInfo.getAvgHandleTime() / 60;
+                            int avgWait = endPersonInfo.getAvgHandleTime();
                             if (avgWait > 0
-                                    && diff >= avgWait) {
+                                    && diff > avgWait) {
                                 //todo 构造发送消息。
                                 AlarmRecordsEntity recordsEntity = new AlarmRecordsEntity();
                                 recordsEntity.initAttrValue();
-                                String alarmContent = String.format("编号:%s:,%s业务办理时间为%d分钟，超过了平均办理时长%d分钟!",  item.getBussinessName(),diff,diff - avgWait+1);
+
+                                double doTime = NumberUtil.div(Double.parseDouble((diff)+""), 60, 1); // 保留1位小数，四舍五入
+                                double upTime = NumberUtil.div(Double.parseDouble((diff-avgWait)+""), 60, 1); // 保留1位小数，四舍五入
+
+                                String alarmContent = String.format("编号:%s:,%s业务办理时间为%d分钟，超过了平均办理时长%d分钟!",  item.getBussinessName(),doTime,upTime);
                                 recordsEntity.setAlarmContent(alarmContent);
                                 recordsEntity.setAlarmTime(new Date());
                                 recordsEntity.setCreateTime(new Date());
@@ -492,6 +501,10 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService {
 
 
 
+        double result = NumberUtil.div(Double.parseDouble((63-53)+""), 60, 1); // 保留1位小数，四舍五入
+
+        System.out.println(result);
+
     }