From c78e10f059efc9f91609cd92933b3a419309bee3 Mon Sep 17 00:00:00 2001
From: lvleigang <957075182@qq.com>
Date: Mon, 9 Sep 2024 14:20:48 +0800
Subject: [PATCH] =?UTF-8?q?esb=E6=B7=BB=E5=8A=A0=E6=B6=88=E6=81=AF?=
 =?UTF-8?q?=E6=8E=A8=E9=80=81=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/SysApplicationServiceImpl.java       | 20 +++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/service/src/main/java/com/hzya/frame/sysnew/application/service/impl/SysApplicationServiceImpl.java b/service/src/main/java/com/hzya/frame/sysnew/application/service/impl/SysApplicationServiceImpl.java
index 77a1dd3f..e2674a56 100644
--- a/service/src/main/java/com/hzya/frame/sysnew/application/service/impl/SysApplicationServiceImpl.java
+++ b/service/src/main/java/com/hzya/frame/sysnew/application/service/impl/SysApplicationServiceImpl.java
@@ -46,6 +46,8 @@ import com.hzya.frame.sysnew.messageManageDetail.entity.SysMessageManageDetailEn
 import com.hzya.frame.sysnew.messageManageLog.dao.ISysMessageManageLogDao;
 import com.hzya.frame.sysnew.messageManageLog.entity.SysMessageManageLogEntity;
 import com.hzya.frame.sysnew.messageManageLog.entity.SysMessageManageLogPageVo;
+import com.hzya.frame.sysnew.pushMessage.entity.SysPushMessageEntity;
+import com.hzya.frame.sysnew.sendMessageLog.service.ISysSendMessageLogService;
 import com.hzya.frame.util.AESUtil;
 import com.hzya.frame.util.IPHelper;
 import com.hzya.frame.uuid.UUIDUtils;
@@ -90,6 +92,8 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
     @Resource
     private ISysApplicationApiDao sysApplicationApiDao;
     @Resource
+    private ISysSendMessageLogService sysSendMessageLogService;
+    @Resource
     private ISysMessageManageLogDao sysMessageManageLogDao;
     @Resource
     private DsDataSourceUtil dsDataSourceUtil;
@@ -2638,9 +2642,21 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
         sysMessageManageLogEntity.setModify_time(new Date());
         sysMessageManageLogEntity.setSts("Y");
         taskExecutor.execute(() -> doEsbTask(sysMessageManageLogEntity));
+        SysPushMessageEntity sysPushMessageEntity = new SysPushMessageEntity();
+        sysPushMessageEntity.setSendAppName(sendApp.getName());
+        sysPushMessageEntity.setReceiveAppName(receiveApp.getName());
+        sysPushMessageEntity.setReceiveApiName(receiveApi.getApiName());
+        sysPushMessageEntity.setReceiveApiCode(receiveApi.getApiCode());
+        sysPushMessageEntity.setReturnData(sysMessageManageLogEntity.getReturnData());
+        sysPushMessageEntity.setStatus(sysMessageManageLogEntity.getStatus());
+        taskExecutor.execute(() -> sendMssage(sysPushMessageEntity));
         return sysMessageManageLogEntity;
     }
 
+    private void sendMssage(SysPushMessageEntity sysPushMessageEntity) {
+        sysSendMessageLogService.sendMessage(sysPushMessageEntity);
+    }
+
     private SysMessageManageLogEntity updateLog(SysApplicationEntity sendApp, SysApplicationEntity receiveApp, SysApplicationApiEntity receiveApi,
                                               String oldbodys,String bodys,
                                               Map<String, String> oldheaderMap,Map<String, String> headerMap,
@@ -2793,6 +2809,9 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
         sysMessageManageLogEntity.setModify_time(new Date());
         sysMessageManageLogEntity.setSts("Y");
         taskExecutor.execute(() -> doEsbTaskNew(sysMessageManageLogEntity));
+
+
+
         return sysMessageManageLogEntity;
     }
 
@@ -2805,6 +2824,7 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
      **/
     private void doEsbTask(SysMessageManageLogEntity manageLogEntities) {
         sysMessageManageLogDao.save(manageLogEntities);
+
     }
     private void doEsbTaskNew(SysMessageManageLogEntity manageLogEntities) {
         sysMessageManageLogDao.update(manageLogEntities);