diff --git a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/AsyncSendCasesRecommendService.java b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/AsyncSendCasesRecommendService.java index c6852a82..6047a6de 100644 --- a/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/AsyncSendCasesRecommendService.java +++ b/servers/boe-server-all/src/main/java/com/xboe/module/boecase/service/impl/AsyncSendCasesRecommendService.java @@ -52,8 +52,7 @@ public class AsyncSendCasesRecommendService { public void sendCasesRecommend(CasesRecommend casesRecommend) { List pushStatusList = new ArrayList<>(); pushStatusList.add(CasesPushStatusEnum.WAIT_PUSH.getStatus()); - List casesRecommendPushRecords = casesRecommendPushRecordDao.getGenericDao() - .findList(CasesRecommendPushRecord.class, FieldFilters.in("pushStatus", pushStatusList), FieldFilters.eqField("recommendId", casesRecommend.getId())); + List casesRecommendPushRecords = casesRecommendPushRecordDao.findList(FieldFilters.in("pushStatus", pushStatusList), FieldFilters.eqField("recommendId", casesRecommend.getId())); if (CollectionUtils.isEmpty(casesRecommendPushRecords)) { //修改为推送完成 --- 无数据 无需推送 updateProcessStatus(casesRecommend.getId(), CasesPushStatusEnum.PUSH_SUCCESS.getStatus()); 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 2b69dc61..748a7748 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 @@ -179,11 +179,6 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR } } else { 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) .addUpdateField("pushStatus", CasesPushStatusEnum.WAIT_PUSH.getStatus()) .addFilter(FieldFilters.eq("recommendId", casesRecommend.getId()))