feat(jg): 添加设备报废相关事件处理器

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/handler/SBBFCXEventHandler.java

+package com.yeejoin.amos.boot.module.jg.biz.handler;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.yeejoin.amos.boot.module.jg.api.event.SafetyProblemEvent;
+import com.yeejoin.amos.boot.module.jg.api.event.handler.SafetyProblemEventHandler;
+import com.yeejoin.amos.boot.module.jg.biz.service.impl.SafetyProblemTracingServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * SBBFCXEventHandler 类实现了 SafetyProblemEventHandler 接口，
+ * 用于处理设备报废撤销问题事件。
+ */
+@Component
+public class SBBFCXEventHandler implements SafetyProblemEventHandler {
+
+    private SafetyProblemTracingServiceImpl safetyProblemTracingService;
+
+    @Autowired
+    public SBBFCXEventHandler(SafetyProblemTracingServiceImpl safetyProblemTracingService) {
+        this.safetyProblemTracingService = safetyProblemTracingService;
+    }
+
+    /**
+     * 处理安全问题事件。
+     *
+     * @param event 安全问题事件对象，包含事件的详细信息。
+     *              该参数用于描述发生的安全问题事件。
+     */
+    @Override
+    public void handle(SafetyProblemEvent event) {
+        // 此处为处理安全问题事件的逻辑代码
+        JSONArray jsonArray = JSONObject.parseArray(event.getMessage().toString());
+        handleProblem(jsonArray);
+    }
+
+    private void handleProblem(JSONArray jsonArray) {
+        // TODO 后续增加设备报废撤销问题处理逻辑
+//        safetyProblemTracingService.recoverProblemBySourceId(jsonArray);
+    }
+}
+

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/handler/SBBFEventHandler.java

+package com.yeejoin.amos.boot.module.jg.biz.handler;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.yeejoin.amos.boot.module.jg.api.enums.SafetyProblemTypeEnum;
+import com.yeejoin.amos.boot.module.jg.api.event.SafetyProblemEvent;
+import com.yeejoin.amos.boot.module.jg.api.event.handler.SafetyProblemEventHandler;
+import com.yeejoin.amos.boot.module.jg.biz.service.impl.SafetyProblemTracingServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * SBBFEventHandler 类实现了 SafetyProblemEventHandler 接口，
+ * 用于处理设备报废问题事件。
+ */
+@Component
+public class SBBFEventHandler implements SafetyProblemEventHandler {
+
+    private SafetyProblemTracingServiceImpl safetyProblemTracingService;
+
+    @Autowired
+    public SBBFEventHandler(SafetyProblemTracingServiceImpl safetyProblemTracingService) {
+        this.safetyProblemTracingService = safetyProblemTracingService;
+    }
+
+    /**
+     * 处理安全问题事件。
+     *
+     * @param event 安全问题事件对象，包含事件的详细信息。
+     *              该参数用于描述发生的安全问题事件。
+     */
+    @Override
+    public void handle(SafetyProblemEvent event) {
+        // 此处为处理安全问题事件的逻辑代码
+        JSONArray jsonArray = JSONObject.parseArray(event.getMessage().toString());
+        handleProblem(jsonArray);
+    }
+
+    private void handleProblem(JSONArray jsonArray) {
+        List<String> records = new ArrayList<>();
+        for (int i = 0; i < jsonArray.size() && !ValidationUtil.isEmpty(jsonArray.get(i)); i++) {
+            records.add(jsonArray.get(i).toString());
+        }
+
+        safetyProblemTracingService.deleteBySourceId(records, SafetyProblemTypeEnum.SBBF.getName());
+    }
+}
+