diff --git a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesRecommendPushRecordServiceImpl.java b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesRecommendPushRecordServiceImpl.java
index 900c493d..d7990b8d 100644
--- a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesRecommendPushRecordServiceImpl.java
+++ b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesRecommendPushRecordServiceImpl.java
@@ -21,10 +21,11 @@ import com.xboe.module.boecase.entity.CasesRecommendLaunchImportData;
 import com.xboe.module.boecase.entity.CasesRecommendPushRecord;
 import com.xboe.module.boecase.service.ICasesRecommendPushRecordService;
 import com.xboe.module.boecase.vo.CasesRecommendLaunchVo;
+import com.xboe.system.user.dao.MessageDao;
 import com.xboe.system.user.dao.UserDao;
+import com.xboe.system.user.entity.Message;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
-import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -61,6 +62,9 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
     @Resource
     private CasesRecommendPushRecordDao casesRecommendPushRecordDao;
 
+    @Resource
+    private MessageDao messageDao;
+
 
     @Autowired(required = false)
     private IEventDataSender eventDataSender;
@@ -184,9 +188,25 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
             Integer pushStatus;
             try {
 
-                eventDataSender.send("案例推荐", "recommendCases", "案例推荐【" + casesRecommendPushRecord.getCaseTitle() + "】",
-                        casesRecommendPushRecord.getCaseId(), "99", casesRecommendPushRecord.getCaseTitle(),
-                        casesRecommendPushRecord.getSysCreateAid(), casesRecommendPushRecord.getSysCreateBy(), "");
+                Message message = new Message();
+                message.setMsgType(1);
+                message.setAcceptId(casesRecommendPushRecord.getPushUserId());
+                message.setAcceptName(casesRecommendPushRecord.getPushUserName());
+                message.setContent("案例推荐【" + casesRecommendPushRecord.getCaseTitle() + "】");
+                message.setIsRead(false);
+                message.setMsgTime(LocalDateTime.now());
+                message.setRefId(casesRecommendPushRecord.getCaseId());
+                message.setRefType("99");
+                message.setSendName(casesRecommendPushRecord.getSysCreateBy());
+                message.setSendType(1);
+                message.setTitle("案例推荐【" + casesRecommendPushRecord.getCaseTitle() + "】");
+                message.setSendAid(casesRecommendPushRecord.getSysCreateAid());
+                message.setSource(1);
+
+                messageDao.save(message);
+//                eventDataSender.send("案例推荐", "recommendCases", "案例推荐【" + casesRecommendPushRecord.getCaseTitle() + "】",
+//                        casesRecommendPushRecord.getCaseId(), "99", casesRecommendPushRecord.getCaseTitle(),
+//                        casesRecommendPushRecord.getSysCreateAid(), casesRecommendPushRecord.getSysCreateBy(), "");
 
                 pushStatus = CasesPushStatusEnum.PUSH_SUCCESS.getStatus();
             } catch (Exception e) {