From 7bee39f076f6a29e6c93497060363e61cb6a634e Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Mon, 25 Aug 2025 09:11:50 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E6=8B=9B=E9=80=BB=E8=BE=91=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9=EF=BC=8C=E6=89=8B=E5=8A=A8=E8=A1=A5=E6=8B=9B=E5=92=8C?=
 =?UTF-8?q?=E5=89=8D=E7=AB=AF=E9=87=87=E7=94=A8websokcet=E9=80=9A=E8=AE=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../njcn/dataProcess/controller/DataRecallController.java    | 4 ++--
 .../njcn/dataProcess/websocket/RecallWebSocketServer.java    | 5 +++--
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataRecallController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataRecallController.java
index e1ea177..67fa509 100644
--- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataRecallController.java
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataRecallController.java
@@ -114,7 +114,7 @@ public class DataRecallController extends BaseController {
                 if(collect1.containsKey(temp)&&collect1.get(temp).containsKey(curDateString)){
                     DataIntegrityDto dto = collect1.get(temp).get(curDateString).get(0);
                     if( dto.getDueTime()!=0){
-                        int i = (dto.getRealTime()) / dto.getDueTime();
+                        double i =(double)dto.getRealTime() / dto.getDueTime();
                         if( i>=0.98){
                             recallType=3;
                         } else if(i<0.98&&i>0.8){
@@ -332,7 +332,7 @@ public class DataRecallController extends BaseController {
                     if(collect1.containsKey(temp)&&collect1.get(temp).containsKey(curDateString)){
                         DataIntegrityDto dto = collect1.get(temp).get(curDateString).get(0);
                         if( dto.getDueTime()!=0){
-                            int i = (dto.getRealTime()) / dto.getDueTime();
+                            double i = (double)dto.getRealTime() / dto.getDueTime();
                             if( i>=0.98){
                                 recallType=3;
                             } else if(i<0.98&&i>0.8){
diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/websocket/RecallWebSocketServer.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/websocket/RecallWebSocketServer.java
index b978dde..424543e 100644
--- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/websocket/RecallWebSocketServer.java
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/websocket/RecallWebSocketServer.java
@@ -210,7 +210,7 @@ public class RecallWebSocketServer {
                     if(collect1.containsKey(temp)&&collect1.get(temp).containsKey(curDateString)){
                         DataIntegrityDto dto = collect1.get(temp).get(curDateString).get(0);
                         if( dto.getDueTime()!=0){
-                            int i = (dto.getRealTime()) / dto.getDueTime();
+                            double i = (double)dto.getRealTime() / dto.getDueTime();
                             if( i>=0.98){
                                 recallType=3;
                             } else if(i<0.98&&i>0.8){
@@ -255,7 +255,7 @@ public class RecallWebSocketServer {
                                     String jsonString =redisUtil.getStringByKey(key);
                                     if(Objects.nonNull(jsonString)){
                                         TopicReplyDTO bean = JSONUtil.toBean(jsonString, TopicReplyDTO.class, true);
-
+                                        redisUtil.delete(key);
                                         flag =false;
                                         sendInfo(bean.getResult());
                                         BaseParam baseParam = new BaseParam();
@@ -314,6 +314,7 @@ public class RecallWebSocketServer {
                                 String jsonString =redisUtil.getStringByKey(key);
                                 if(Objects.nonNull(jsonString)){
                                     TopicReplyDTO bean = JSONUtil.toBean(jsonString, TopicReplyDTO.class, true);
+                                    redisUtil.delete(key);
 
                                     flag =false;
                                     sendInfo(bean.getResult());