hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-11 03:46:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

提交推送

Browse Source
This commit is contained in:
Guava
2023-06-28 21:21:30 +08:00
parent a0a0a75689
commit aafa678b5b
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/CasesRecommendPushRecordServiceImpl.java
View File

@@ -1,6 +1,7 @@
package com.xboe.module.boecase.service.impl; package com.xboe.module.boecase.service.impl;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.json.JSONUtil;
import com.xboe.core.CurrentUser; import com.xboe.core.CurrentUser;
import com.xboe.core.event.IEventDataSender; import com.xboe.core.event.IEventDataSender;
import com.xboe.core.orm.FieldFilters; import com.xboe.core.orm.FieldFilters;
@@ -74,6 +75,7 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
casesRecommend.setRecommendOrgName(casesRecommendLaunch.getRecommendOrgName()); casesRecommend.setRecommendOrgName(casesRecommendLaunch.getRecommendOrgName());
casesRecommend.setPushProgress(CasesPushStatusEnum.WAIT_PUSH.getStatus()); casesRecommend.setPushProgress(CasesPushStatusEnum.WAIT_PUSH.getStatus());
casesRecommendDao.save(casesRecommend); casesRecommendDao.save(casesRecommend);
log.info("案例推送对象 {}", JSONUtil.toJsonStr(casesRecommend));
List<String> caseIds = new ArrayList<>(); List<String> caseIds = new ArrayList<>();
if (casesRecommendLaunch.getLaunchType() == 1) { if (casesRecommendLaunch.getLaunchType() == 1) {
@@ -104,8 +106,12 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
casesRecommendPushRecordDao.saveList(pushRecords); casesRecommendPushRecordDao.saveList(pushRecords);
} }
} }
//发送推送案例消息 try {
sendCasesRecommend(casesRecommend); //发送推送案例消息
sendCasesRecommend(casesRecommend);
} catch (Exception e) {
log.error("推送失败", e);
}
return true; return true;
} }