maintenance

src/main/java/com/its/pis/process/DbmsDataProcess.java

@@ -99,15 +99,37 @@ public class DbmsDataProcess {
                     if (pis != null) {
                         String DATA_COLCT_TIME = SysUtils.getSysTime();
                         C2FMessage<PrkPlceRlTimeResponseInfo> rlTimeInfo = (C2FMessage<PrkPlceRlTimeResponseInfo>) data.getData();
+
                         if (rlTimeInfo != null) {
                             PrkPlceRlTimeResponseInfo info = rlTimeInfo.getData().getPayload();
                             TbPrkPlceRt rt = TbPrkPlceRt.toEntity(pis.getPIS_NMBR(), DATA_COLCT_TIME, info);
 
-                            this.prkPlceMapper.updatePrkPlceRlTime(rt);
-                            this.prkPlceDao.updateRlTimeFlr(pis.getPIS_NMBR(), DATA_COLCT_TIME, info.getFlr_info());
-                            this.prkPlceDao.updateRlTimeAr(pis.getPIS_NMBR(), info.getAr_info());
-                            this.prkPlceDao.updateRlTimePrv(pis.getPIS_NMBR(), info.getPrvuse_prkar_info());
-                            this.prkPlceDao.updateRlTimeDev(pis.getPIS_NMBR(), info.getPrk_colct_device_info());
+                            try {
+                                rt.setPartclrMatter("없음");
+                                this.prkPlceMapper.updatePrkPlceRlTime(rt);
+                            } catch (Exception e) {
+                                log.error("updatePrkPlceRlTime: {}", rt);
+                            }
+                            try {
+                                this.prkPlceDao.updateRlTimeFlr(pis.getPIS_NMBR(), DATA_COLCT_TIME, info.getFlr_info());
+                            } catch (Exception e) {
+                                log.error("updateRlTimeFlr: {}", info.getFlr_info());
+                            }
+                            try {
+                                this.prkPlceDao.updateRlTimeAr(pis.getPIS_NMBR(), info.getAr_info());
+                            } catch (Exception e) {
+                                log.error("updateRlTimeAr: {}", info.getAr_info());
+                            }
+                            try {
+                                this.prkPlceDao.updateRlTimePrv(pis.getPIS_NMBR(), info.getPrvuse_prkar_info());
+                            } catch (Exception e) {
+                                log.error("updateRlTimePrv: {}", info.getPrvuse_prkar_info());
+                            }
+                            try {
+                                this.prkPlceDao.updateRlTimeDev(pis.getPIS_NMBR(), info.getPrk_colct_device_info());
+                            } catch (Exception e) {
+                                log.error("updateRlTimeDev: {}", info.getPrk_colct_device_info());
+                            }
                         }
                         else {
                             log.error("RL TIME Data NULL...............");

src/main/java/com/its/pis/websocket/PisWebSocketHandlerC2F.java

@@ -121,6 +121,7 @@ public class PisWebSocketHandlerC2F extends PisWebSocketHandler {
             } else if (C2FConstants.prk_plce_rl_time_info.equals(eventName) || C2FConstants.prk_plce_rl_time_info_cycle.equals(eventName)) {
                 C2FMessage<PrkPlceRlTimeResponseInfo> rlTimeInfo = this.mapper.readValue(payloadMessage, new TypeReference<C2FMessage<PrkPlceRlTimeResponseInfo>>(){});
                 pis.setRlTimeInfo(rlTimeInfo);
+                //log.info("{}, C2F: RX] prk_plce_rl_time_info, {}", pis.getPIS_ID(), rlTimeInfo);
                 dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_RL_TIME, false, rlTimeInfo, pis));
                 log.info("{}, C2F: RX] prk_plce_rl_time_info", pis.getPIS_ID());
                 //log.info("RX] {}", this.mapper.writeValueAsString(rlTimeInfo));