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

开启异步发送消息

Browse Source
This commit is contained in:
Guava
2023-07-04 18:37:12 +08:00
parent cbaf4c945c
commit d4befa9f37
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -80,7 +80,7 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
@Override
public boolean launchPush(CasesRecommendLaunchVo casesRecommendLaunch, CurrentUser currentUser, String token) {
long t1 = System.currentTimeMillis();
List<String> caseIds = new ArrayList<>();
if (casesRecommendLaunch.getLaunchType() == 1) {
caseIds.addAll(casesRecommendLaunch.getCasesIdList());
@@ -123,6 +123,8 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
throw new RuntimeException("推荐人不能为空");
}
log.info("查询用户消耗时长为 {}秒", System.currentTimeMillis() - t1 / 1000);
CasesRecommend casesRecommend = new CasesRecommend();
casesRecommend.setRecommendId(currentUser.getAccountId());
casesRecommend.setRecommendBy(currentUser.getName());
@@ -135,9 +137,9 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
log.info("案例推送对象 {}", JSONUtil.toJsonStr(casesRecommend));
List<CasesRecommendPushRecord> pushRecords = new ArrayList<>();
for (String caseId : caseIds) {
Cases cases = casesDao.get(caseId);
List<CasesRecommendPushRecord> pushRecords = new ArrayList<>();
Map<String, Object> userMap = userDao.findMap("id", "name", FieldFilters.in("id", userIds));
for (String userId : userIds) {
CasesRecommendPushRecord casesRecommendPushRecord = new CasesRecommendPushRecord();
@@ -151,9 +153,9 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
casesRecommendPushRecord.setReadFlag(0);
pushRecords.add(casesRecommendPushRecord);
}
if (CollectionUtil.isNotEmpty(pushRecords)) {
casesRecommendPushRecordDao.saveList(pushRecords);
}
}
if (CollectionUtil.isNotEmpty(pushRecords)) {
casesRecommendPushRecordDao.saveList(pushRecords);
}
try {
//发送推送案例消息