Ver código fonte

边缘端新增更多的打印日志

易涛 3 anos atrás
pai
commit
9787bc5ba3

+ 1 - 0
src/main/java/com/persagy/netty/client/CenterClientHandler.java

@@ -93,6 +93,7 @@ public class CenterClientHandler extends SimpleChannelInboundHandler<NettyMessag
 
     private void handlerMsg(ChannelHandlerContext channelHandlerContext, NettyMessage msg) throws Exception {
         if (msg.getOpCode() == 7) {
+            log.info("--报警定义新增或更新--{}",msg);
             NettyMessage<AlarmDefine> AlarmDefineMessage = JSONObject.parseObject(msg.toString(), new TypeReference<NettyMessage<AlarmDefine>>() {
             });
             List<AlarmDefine> definesList = AlarmDefineMessage.getContent();

+ 3 - 0
src/main/java/com/persagy/service/impl/AlarmDefineServiceImpl.java

@@ -9,6 +9,7 @@ import com.persagy.entity.AlarmState;
 import com.persagy.entity.ZktAlarmRecordDO;
 import com.persagy.repository.AlarmRecordRepository;
 import com.persagy.service.AlarmDefineService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -22,6 +23,7 @@ import java.util.concurrent.ConcurrentHashMap;
  * @since:2020/10/15 11:24
  * @version:V1.0
  **/
+@Slf4j
 @Service
 public class AlarmDefineServiceImpl implements AlarmDefineService {
     @Autowired
@@ -84,6 +86,7 @@ public class AlarmDefineServiceImpl implements AlarmDefineService {
         for (AlarmDefine alarmDefine : alarmDefineList) {
             alarmInfoCache.putAlarmDefinitionById(alarmDefine);
         }
+        log.info(String.valueOf(alarmInfoCache));
         return alarmDefineList;
     }