修改人员资质问题生成

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/SafetyProblemTracingGenServiceImpl.java

 package com.yeejoin.amos.boot.module.jg.biz.service.impl;
 
+import cn.hutool.core.collection.CollectionUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -187,11 +188,13 @@ public class SafetyProblemTracingGenServiceImpl{
      */
     private void sendSafetyProblemMessage(List<Map<String, Object>> mapList, SafetyProblemTypeEnum safetyProblemTypeEnum) {
         JSONArray jsonArray = JSON.parseArray(JSON.toJSONString(mapList));
-        try {
-            emqKeeper.getMqttClient().publish(safetyProblemTypeEnum.getTopic(), jsonArray.toString().getBytes(StandardCharsets.UTF_8), 2, false);
-        } catch (MqttException e) {
-            logger.error("发送安全追溯问题设备信息消息失败---->{}", e.getMessage());
-            throw new RuntimeException(e);
+        if (CollectionUtil.isNotEmpty(jsonArray)){
+            try {
+                emqKeeper.getMqttClient().publish(safetyProblemTypeEnum.getTopic(), jsonArray.toString().getBytes(StandardCharsets.UTF_8), 2, false);
+            } catch (MqttException e) {
+                logger.error("发送安全追溯问题设备信息消息失败---->{}", e.getMessage());
+                throw new RuntimeException(e);
+            }
         }
     }
 }
\ No newline at end of file