식별장치 drone에 대한 식별 정보만 이력관리

src/main/java/com/palnet/process/message/consumer/MessageConsumer.java

@@ -33,12 +33,16 @@ public class MessageConsumer {
     @RabbitListener(queues = {"websocket.drone.queue"}, concurrency = "8")
     public void receiveDroneMessage(final String message) throws JsonProcessingException {
 		log.info("websocket message : {}", message);
+
 		GPModel model = objectMapper.readValue(message, GPModel.class);
 
-		CtrCntrlModel history = this.convertModel(model); // 웹 표출 model로 변환
+		CtrCntrlModel history = this.convertModel(model);
 
+		// DRON의 대한 식별정보만 이력 관리
+		if (history.getObjectId().indexOf("PALDRON") > -1) {
 			gpHistoryShareModel.putHistory(model.getObjectId(), history);
 		}
+    }
 
     public CtrCntrlModel convertModel(final GPModel dataInfo) {
 		CtrCntrlModel model = new CtrCntrlModel();
@@ -73,23 +77,23 @@ public class MessageConsumer {
 		// 비정상 상황 식별코드 추가
 		model.setControlWarnCd(dataInfo.isControlWarnCd());
 
-		if(prevModel == null) {
+//		if(prevModel == null) {
-			if(model.isControlWarnCd()) {
+//			if(model.isControlWarnCd()) {
-				model.setControlWarnNotyCd(true); // 최초 비정상 발생
+//				model.setControlWarnNotyCd(true); // 최초 비정상 발생
-			}
+//			}
-		} else {
+//		} else {
-			if(prevModel.isControlWarnCd() && model.isControlWarnCd()) {
+//			if(prevModel.isControlWarnCd() && model.isControlWarnCd()) {
-				model.setControlWarnNotyCd(false); // 비정상 -> 비정상
+//				model.setControlWarnNotyCd(false); // 비정상 -> 비정상
-			}
+//			}
-			if(prevModel.isControlWarnCd() && !model.isControlWarnCd()) {
+//			if(prevModel.isControlWarnCd() && !model.isControlWarnCd()) {
-				model.setControlWarnNotyCd(false); // 비정상 -> 정상
+//				model.setControlWarnNotyCd(false); // 비정상 -> 정상
-			}
+//			}
-			if(!prevModel.isControlWarnCd() && model.isControlWarnCd()) {
+//			if(!prevModel.isControlWarnCd() && model.isControlWarnCd()) {
-				model.setControlWarnNotyCd(true); // 정상 -> 비정상상
+//				model.setControlWarnNotyCd(true); // 정상 -> 비정상상
-			}
+//			}
-		}
+//		}
-
+//
-		model.setControlCacheCount(1);
+//		model.setControlCacheCount(1);
 
 		return model;
 	}