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-07-05 11:51:49 +08:00
parent 2aa0d5b2c0
commit e4875d545b
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -183,12 +183,13 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
.addUpdateField("pushProgress", CasesPushStatusEnum.PUSH_ING.getStatus()) .addUpdateField("pushProgress", CasesPushStatusEnum.PUSH_ING.getStatus())
.addFilter(FieldFilters.eq("id", casesRecommend.getId())) .addFilter(FieldFilters.eq("id", casesRecommend.getId()))
.builder()); .builder());
casesRecommendPushRecordDao.update(UpdateBuilder.from(CasesRecommendPushRecord.class)
.addUpdateField("pushStatus", CasesPushStatusEnum.WAIT_PUSH.getStatus())
.addFilter(FieldFilters.eq("recommendId", casesRecommend.getId()))
.builder());
//发送推送案例消息 //发送推送案例消息
asyncSendCasesRecommendService.sendCasesRecommend(casesRecommend); asyncSendCasesRecommendService.sendCasesRecommend(casesRecommend);
casesRecommendDao.update(UpdateBuilder.from(CasesRecommend.class)
.addUpdateField("pushProgress", CasesPushStatusEnum.PUSH_SUCCESS.getStatus())
.addFilter(FieldFilters.eq("id", casesRecommend.getId()))
.builder());
} catch (Exception e) { } catch (Exception e) {
log.error("推送失败", e); log.error("推送失败", e);
casesRecommendDao.update(UpdateBuilder.from(CasesRecommend.class) casesRecommendDao.update(UpdateBuilder.from(CasesRecommend.class)