From cf77e6b94c5a2e2d4d992b9222c857bafde0111e Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期二, 08 十月 2024 09:46:51 +0800
Subject: [PATCH] 最新版本

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java |  108 +++++++++++++++++++++++++++++-------------------------
 1 files changed, 58 insertions(+), 50 deletions(-)

diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java
index 8189e92..c98d012 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java
@@ -5,6 +5,7 @@
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.doumee.biz.system.SystemDictDataBiz;
 import com.doumee.config.DataSyncConfig;
+import com.doumee.core.haikang.model.HKConstants;
 import com.doumee.core.haikang.model.param.BaseResponse;
 import com.doumee.core.haikang.model.param.request.*;
 import com.doumee.core.haikang.model.param.request.event.acs.EventAcsInfoRequest;
@@ -1056,25 +1057,7 @@
             }
             if(Constants.equalsInteger(device.getType(),Constants.ZERO)){
                 //濡傛灉鏄疞ED
-                PlatformBroadcastLog log = new PlatformBroadcastLog();
-                log.setCreateDate(new Date());
-                log.setBizType(Constants.ONE);
-                log.setHkDate(new Date());
-                log.setObjType(Constants.ONE);
-                log.setIds(device.getHkNo());
-                log.setRemark(device.getName());
-                log.setInfo(content);
-                log.setNum(Constants.ONE);
-                BaseResponse response = dealLedContentBiz(device.getHkNo(),content,speed,1);
-                if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
-                    log.setHkInfo("璇锋眰澶辫触锛�"+JSONObject.toJSONString(response));
-                    log.setHkStatus(Constants.THREE);
-                }else{
-                    log.setHkInfo("璇锋眰鎴愬姛");
-                    log.setHkStatus(Constants.TWO);
-                }
-                log.setDeviceType(Constants.ONE);
-                log.setName("璁剧疆LED灞忔樉鍐呭");
+                PlatformBroadcastLog log = dealLedContentBiz(device.getHkNo(),device.getName(),content,speed,1);
                 logList.add(log);
                 ledList.add(device.getHkId());
             }else  if(Constants.equalsInteger(device.getType(),Constants.ZERO)){
@@ -1083,36 +1066,8 @@
                 broadcastList.add(device.getHkId());
             }
         }
-
         if(broadcastList.size()>0){
-            String content1 =Constants.PlatformBroadcastContent.WRONG_IN.getInfo();
-            content1 = content1.replace("${param}",model.getCarCodeFront());
-            PlatformBroadcastLog log = new PlatformBroadcastLog();
-            log.setCreateDate(new Date());
-            log.setBizType(Constants.ONE);
-            log.setHkDate(new Date());
-            log.setObjType(Constants.ONE);
-            log.setInfo(content1);
-            log.setRemark(bNames);
-            log.setNum(Constants.ONE);
-            log.setIds(String.join(",",broadcastList));
-            CustomBroadcastRequest request = new CustomBroadcastRequest();
-            request.setAudioPointIndexCode(broadcastList);
-            request.setPlayDuration(15);//鍗曚綅绉�
-            request.setBroadCastMode("tts");
-            request.setPriority(1);
-            request.setState(1);//鎾斁/鍋滄鏍囪瘑 1-鎾斁锛�0-鍋滄
-            request.setPlayTtsContent(content1);
-            BaseResponse response =  HKService.customBroadcast(request);
-            if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
-                log.setHkInfo("璇锋眰澶辫触锛�"+JSONObject.toJSONString(response));
-                log.setHkStatus(Constants.THREE);
-            }else{
-                log.setHkInfo("璇锋眰鎴愬姛");
-                log.setHkStatus(Constants.TWO);
-            }
-            log.setDeviceType(Constants.ONE);
-            log.setName("鍙戦�佸箍鎾挱鎶ュ唴瀹�");
+            PlatformBroadcastLog log = dealBroadcastBiz(model,broadcastList,bNames);
             logList.add(log);
         }
         if(logList.size()>0){
@@ -1120,7 +1075,50 @@
         }
     }
 
-    public static BaseResponse dealLedContentBiz(String hkNo, String content,int speed,int color) {
+    private PlatformBroadcastLog dealBroadcastBiz(PlatformJob model, List<String> broadcastList,String bNames) {
+        PlatformBroadcastLog log = new PlatformBroadcastLog();
+        String content1 =Constants.PlatformBroadcastContent.WRONG_IN.getInfo();
+        content1 = content1.replace("${param}",model.getCarCodeFront());
+
+        log.setCreateDate(new Date());
+        log.setBizType(Constants.ONE);
+        log.setHkDate(new Date());
+        log.setObjType(Constants.ONE);
+        log.setInfo(content1);
+        log.setRemark(bNames);
+        log.setNum(Constants.ONE);
+        log.setIds(String.join(",",broadcastList));
+        CustomBroadcastRequest request = new CustomBroadcastRequest();
+        request.setAudioPointIndexCode(broadcastList);
+        request.setPlayDuration(15);//鍗曚綅绉�
+        request.setBroadCastMode("tts");
+        request.setPriority(1);
+        request.setState(1);//鎾斁/鍋滄鏍囪瘑 1-鎾斁锛�0-鍋滄
+        request.setPlayTtsContent(content1);
+        BaseResponse response =  HKService.customBroadcast(request);
+        if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
+            log.setHkInfo("璇锋眰澶辫触锛�"+JSONObject.toJSONString(response));
+            log.setHkStatus(Constants.THREE);
+        }else{
+            log.setHkInfo("璇锋眰鎴愬姛");
+            log.setHkStatus(Constants.TWO);
+        }
+        log.setDeviceType(Constants.ONE);
+        log.setName("鍙戦�佸箍鎾挱鎶ュ唴瀹�");
+        return  log;
+    }
+
+    public static PlatformBroadcastLog dealLedContentBiz(String hkNo,String hkName, String content,int speed,int color) {
+        PlatformBroadcastLog log = new PlatformBroadcastLog();
+        log.setCreateDate(new Date());
+        log.setBizType(Constants.ONE);
+        log.setHkDate(new Date());
+        log.setObjType(Constants.ONE);
+        log.setIds(hkNo);
+        log.setRemark(hkName);
+        log.setInfo(content);
+        log.setNum(Constants.ONE);
+
         TransparentChannelBodyRequest body = new TransparentChannelBodyRequest();
         TransparentChannelHeadRequest head = new TransparentChannelHeadRequest();
         TransparentChannelBodyParamRequest request = new TransparentChannelBodyParamRequest();
@@ -1147,6 +1145,16 @@
         request.getRegions().add(regions);
         regions.setSpeed(speed>0?speed:13);
         body.setParams(request);
-       return HKService.transparentchannel(head,body);
+        BaseResponse response =  HKService.transparentchannel(head,body);
+        if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
+            log.setHkInfo("璇锋眰澶辫触锛�"+JSONObject.toJSONString(response));
+            log.setHkStatus(Constants.THREE);
+        }else{
+            log.setHkInfo("璇锋眰鎴愬姛");
+            log.setHkStatus(Constants.TWO);
+        }
+        log.setDeviceType(Constants.ONE);
+        log.setName("璁剧疆LED灞忔樉鍐呭");
+        return log;
     }
 }

--
Gitblit v1.9.3