diff --git a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/controller/IncidentController.java b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/controller/IncidentController.java index 94bc850..44b71db 100644 --- a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/controller/IncidentController.java +++ b/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 list=new ArrayList<>(){ - { - add("breakdown"); - add("electronic-fence"); - add("real-time-data"); - add("stored-event"); - } - }; /** * 事件服务 */ @Autowired private IncidentService incidentService; - - - - - } diff --git a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/mapper/IncidentMapper.java b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/mapper/IncidentMapper.java index 5826340..e45bbfe 100644 --- a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/mapper/IncidentMapper.java +++ b/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); } diff --git a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/BreakdownServiceImpl.java b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/BreakdownServiceImpl.java index 051d95c..3a5ca25 100644 --- a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/BreakdownServiceImpl.java +++ b/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("故障事件结束....."); + + } /**