Merge remote-tracking branch 'origin/develop_tzs_register' into develop_tzs_register

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

@@ -194,7 +194,9 @@ public class SafetyProblemTracingGenServiceImpl{
         JSONArray jsonArray = JSON.parseArray(JSON.toJSONString(mapList));
         if (CollectionUtil.isNotEmpty(jsonArray)){
             try {
+                logger.info("发送安全追溯问题主题---->{}", safetyProblemTypeEnum.getTopic());
                 emqKeeper.getMqttClient().publish(safetyProblemTypeEnum.getTopic(), jsonArray.toString().getBytes(StandardCharsets.UTF_8), 2, false);
+                logger.info("发送安全追溯问题消息成功---->");
             } catch (MqttException e) {
                 logger.error("发送安全追溯问题设备信息消息失败---->{}", e.getMessage());
                 throw new RuntimeException(e);