Ver código fonte

add im即时通信

18339543638 3 anos atrás
pai
commit
847090fb85

+ 6 - 6
nb-service/web-service/src/main/java/com/nb/web/service/bus/utils/WsPublishUtils.java

@@ -45,7 +45,7 @@ public class WsPublishUtils implements Serializable{
      * @param tenantId
      * @return void
      */
-    @Async
+//    @Async
     public void publishPatientMonitor(String patientId,String tenantId){
         Assert.hasText(tenantId,"医院id不能为空");
         log.info("推送病号数据【{}】", JSONUtil.toJsonStr(patientId));
@@ -68,7 +68,7 @@ public class WsPublishUtils implements Serializable{
      * @param
      * @return void
      */
-    @Async
+//    @Async
     public void publishMonitorStateCount(String tenantId){
         Assert.hasText(tenantId,"医院id不能为空");
         MonitorStatusStatsCountResult message = patientService.statusStats(tenantId);
@@ -84,7 +84,7 @@ public class WsPublishUtils implements Serializable{
      * @param
      * @return void
      */
-    @Async
+//    @Async
     public void publishPatientUpdate(String tenantId){
         Assert.hasText(tenantId,"医院id不能为空");
         JSONObject message = new JSONObject().putOpt("result", 1);
@@ -98,7 +98,7 @@ public class WsPublishUtils implements Serializable{
      * @param
      * @return void
      */
-    @Async
+//    @Async
     public void publishDeviceRepeat(String tenantId){
         Assert.hasText(tenantId,"医院id不能为空");
         JSONObject message = new JSONObject().putOpt("count", patientService.patientAlarmCount(tenantId,PatientAlarmEnum.DEVICE_REPEAT));
@@ -114,7 +114,7 @@ public class WsPublishUtils implements Serializable{
      * @param
      * @return void
      */
-    @Async
+//    @Async
     public void publishDeviceNone(String tenantId){
         Assert.hasText(tenantId,"医院id不能为空");
         JSONObject message = new JSONObject().putOpt("count",patientService.patientAlarmCount(tenantId,PatientAlarmEnum.DEVICE_NONE));
@@ -131,7 +131,7 @@ public class WsPublishUtils implements Serializable{
      * @param
      * @return void
      */
-    @Async
+//    @Async
     public void publishMonitorTotalCount(String tenantId){
         Assert.hasText(tenantId,"医院id不能为空");
         JSONObject message = new JSONObject().putOpt("count",