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

修改消息发布重推送

Browse Source
This commit is contained in:
Guava
2023-07-05 12:03:10 +08:00
parent e4875d545b
commit b9de25d91a
2 changed files with 1 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -52,8 +52,7 @@ public class AsyncSendCasesRecommendService {
public void sendCasesRecommend(CasesRecommend casesRecommend) { public void sendCasesRecommend(CasesRecommend casesRecommend) {
List<Integer> pushStatusList = new ArrayList<>(); List<Integer> pushStatusList = new ArrayList<>();
pushStatusList.add(CasesPushStatusEnum.WAIT_PUSH.getStatus()); pushStatusList.add(CasesPushStatusEnum.WAIT_PUSH.getStatus());
List<CasesRecommendPushRecord> casesRecommendPushRecords = casesRecommendPushRecordDao.getGenericDao() List<CasesRecommendPushRecord> casesRecommendPushRecords = casesRecommendPushRecordDao.findList(FieldFilters.in("pushStatus", pushStatusList), FieldFilters.eqField("recommendId", casesRecommend.getId()));
.findList(CasesRecommendPushRecord.class, FieldFilters.in("pushStatus", pushStatusList), FieldFilters.eqField("recommendId", casesRecommend.getId()));
if (CollectionUtils.isEmpty(casesRecommendPushRecords)) { if (CollectionUtils.isEmpty(casesRecommendPushRecords)) {
//修改为推送完成 --- 无数据 无需推送 //修改为推送完成 --- 无数据 无需推送
updateProcessStatus(casesRecommend.getId(), CasesPushStatusEnum.PUSH_SUCCESS.getStatus()); updateProcessStatus(casesRecommend.getId(), CasesPushStatusEnum.PUSH_SUCCESS.getStatus());

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

@@ -179,11 +179,6 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
} }
} else { } else {
try { try {
casesRecommendDao.update(UpdateBuilder.from(CasesRecommend.class)
.addUpdateField("pushProgress", CasesPushStatusEnum.PUSH_ING.getStatus())
.addFilter(FieldFilters.eq("id", casesRecommend.getId()))
.builder());
casesRecommendPushRecordDao.update(UpdateBuilder.from(CasesRecommendPushRecord.class) casesRecommendPushRecordDao.update(UpdateBuilder.from(CasesRecommendPushRecord.class)
.addUpdateField("pushStatus", CasesPushStatusEnum.WAIT_PUSH.getStatus()) .addUpdateField("pushStatus", CasesPushStatusEnum.WAIT_PUSH.getStatus())
.addFilter(FieldFilters.eq("recommendId", casesRecommend.getId())) .addFilter(FieldFilters.eq("recommendId", casesRecommend.getId()))