新增

couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/controller/IncidentController.java

@@ -22,26 +22,10 @@ import java.util.List;
 @RequestMapping("/incident")
 public class IncidentController extends BaseController {
 
-    /**
-     * 事件列表
-     */
-    static List<String> list=new ArrayList<>(){
-        {
-            add("breakdown");
-            add("electronic-fence");
-            add("real-time-data");
-            add("stored-event");
-        }
-    };
     /**
      * 事件服务
      */
     @Autowired
     private IncidentService incidentService;
 
-
-
-
-
-
 }

couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/mapper/IncidentMapper.java

@@ -10,5 +10,9 @@ import org.apache.ibatis.annotations.Mapper;
  */
 @Mapper
 public interface IncidentMapper {
+    /**
+     * 新增存储事件
+     * @param coupletMsgData
+     */
     public void reportMapper(CoupletMsgData coupletMsgData);
 }

couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/BreakdownServiceImpl.java

@@ -2,6 +2,8 @@ package com.couplet.analyze.msg.service.impl;
 
 import com.couplet.analyze.msg.domain.CoupletMsgData;
 import com.couplet.analyze.msg.service.IncidentService;
+import com.couplet.common.log.annotation.Log;
+import lombok.extern.log4j.Log4j2;
 import org.springframework.stereotype.Service;
 
 /**
@@ -10,6 +12,7 @@ import org.springframework.stereotype.Service;
  * @Description: 故障事件
  */
 @Service("breakdown")
+@Log4j2
 public class BreakdownServiceImpl implements IncidentService {
     /**
      * 故障事件
@@ -19,6 +22,10 @@ public class BreakdownServiceImpl implements IncidentService {
     @Override
     public void incident(CoupletMsgData coupletMsgData) {
 
+        log.info("故障事件开始.....");
+        log.info("故障事件结束.....");
+
+
     }
 
     /**