Browse Source

MQTT uuid修改

gao.qiang 1 year ago
parent
commit
94f5605447

+ 1 - 1
business-service/src/main/java/com/ozs/service/utils/PublishCallback.java

@@ -85,7 +85,7 @@ public class PublishCallback implements MqttCallback {
             if (sign.startsWith("rate")&&code==400){
                 CallbackUtil.callback(deviceSn,code,"帧率升级失败");
             }
-            if (sign.startsWith("cient")&&code==400){
+            if (sign.startsWith("cien")&&code==400){
                 CallbackUtil.callback(deviceSn,code,"置信度升级失败");
             }
             CallbackUtil.callback(deviceSn,code,"");

+ 4 - 3
business-service/src/main/java/com/ozs/service/utils/PublishClient.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
 import com.ozs.common.utils.sign.Md5Utils;
 import com.ozs.common.utils.stateSecrets.SM4Utils;
+import com.ozs.common.utils.uuid.IdUtils;
 import com.ozs.service.entity.vo.BaseCameraVersionVo;
 import com.ozs.service.entity.vo.Codec;
 import com.ozs.service.entity.vo.Data;
@@ -167,7 +168,7 @@ public class PublishClient {
                 updateDeviceSn.setName("UpdateRequest");
                 updateDeviceSn.setType(Integer.valueOf(baseCameraVersionVo.getUpgradeType()));
                 updateDeviceSn.setMd5(baseCameraVersionVo.getMd5());
-                updateDeviceSn.setSign(UUID.randomUUID().toString());
+                updateDeviceSn.setSign(IdUtils.fastSimpleUUID());
                 updateDeviceSn.setUrl(baseCameraVersionVo.getVersionAddress());
                 String s = JSON.toJSONString(updateDeviceSn);
                 server.message = new MqttMessage();
@@ -209,7 +210,7 @@ public class PublishClient {
                 Map<String, Object> map = new HashMap<>();
                 map.put("svp", svp);
                 res.put("data", map);
-                res.put("sign", "cient"+UUID.randomUUID().toString());
+                res.put("sign", "cien"+IdUtils.fastSimpleUUID());
                 String s = JSONObject.toJSONString(res);
 
                 server.message = new MqttMessage();
@@ -251,7 +252,7 @@ public class PublishClient {
                 Map<String, Object> map = new HashMap<>();
                 map.put("codec", codec);
                 res.put("data", map);
-                res.put("sign", "rate"+UUID.randomUUID().toString());
+                res.put("sign", "rate"+IdUtils.fastSimpleUUID());
                 String s = JSONObject.toJSONString(res);
 
                 server.message = new MqttMessage();