Index: ssts-basedata/src/main/java/com/forgon/disinfectsystem/basedatamanager/urgent/notification/service/UrgentNotificationManagerImpl.java =================================================================== diff -u -r40308 -r40962 --- ssts-basedata/src/main/java/com/forgon/disinfectsystem/basedatamanager/urgent/notification/service/UrgentNotificationManagerImpl.java (.../UrgentNotificationManagerImpl.java) (revision 40308) +++ ssts-basedata/src/main/java/com/forgon/disinfectsystem/basedatamanager/urgent/notification/service/UrgentNotificationManagerImpl.java (.../UrgentNotificationManagerImpl.java) (revision 40962) @@ -140,6 +140,10 @@ newUrgentNotification.setUrgentAmount(tousseItem.getUrgentAmount()); objectDao.save(newUrgentNotification); + if(DatabaseUtil.isPoIdValid(newUrgentNotification.getId())){ + newUrgentNotification = (UrgentNotificationRecord) objectDao.getById(UrgentNotificationRecord.class.getSimpleName(), newUrgentNotification.getId()); + } + //websocket广播消息 websocketServerBroadcast(newUrgentNotification); } @@ -156,6 +160,10 @@ return; } + if(urgentNotification == null){ + return; + } + UrgentLevel urgentLevel = urgentLevelManager.get(urgentNotification.getUrgentLevelId()); if(urgentLevel == null || StringUtils.equals(urgentLevel.getNotification(), Constants.STR_NO)){ return; @@ -663,6 +671,10 @@ newUrgentNotification.setUrgentAmount(tousseItem.getUrgentAmount()); objectDao.save(newUrgentNotification); + if(DatabaseUtil.isPoIdValid(newUrgentNotification.getId())){ + newUrgentNotification = (UrgentNotificationRecord) objectDao.getById(UrgentNotificationRecord.class.getSimpleName(), newUrgentNotification.getId()); + } + //websocket广播消息 websocketServerBroadcast(newUrgentNotification); }