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 4ca4aba5..2b69dc61 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 @@ -183,12 +183,13 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR .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())) + .builder()); //发送推送案例消息 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) { log.error("推送失败", e); casesRecommendDao.update(UpdateBuilder.from(CasesRecommend.class)