装备报废消息发送至中心级

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/EquipmentSpecificSerivceImpl.java

@@ -1979,6 +1979,16 @@ public class EquipmentSpecificSerivceImpl extends ServiceImpl<EquipmentSpecificM
                             log.info(String.format("发送eqm转kafka消息失败：%s", exp.getMessage()));
                         }
 //                        idxFeign.handleEquipNotScrapWhenExpired(String.valueOf(e.get("id")), String.valueOf(e.get("bizOrgCode")), String.valueOf(e.get("bizOrgName")));
+
+                        // 发送消息，message监听，转发给中心级
+                        Map<String, Object> mapZxj = new HashMap<>();
+                        mapZxj.put("topic", "equip/scrap/put");
+                        mapZxj.put("data", map);
+                        try {
+                            emqKeeper.getMqttClient().publish("equip/scrap/put/zxj", JSON.toJSONString(mapZxj).getBytes(), 1, false);
+                        } catch (MqttException exp) {
+                            log.info(String.format("发送eqm消息，message根据该消息转发为kafka消息,失败信息：%s", exp.getMessage()));
+                        }
                     }
                 }