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 d8c004a3..ae2fec8a 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 @@ -185,6 +185,12 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR .addUpdateField("pushStatus", CasesPushStatusEnum.WAIT_PUSH.getStatus()) .addFilter(FieldFilters.eq("recommendId", casesRecommend.getId())) .builder()); + + casesRecommendDao.update(UpdateBuilder.from(CasesRecommend.class) + .addUpdateField("pushProgress", CasesPushStatusEnum.WAIT_PUSH.getStatus()) + .addFilter(FieldFilters.eq("id", casesRecommend.getId())) + .builder()); + //发送推送案例消息 asyncSendCasesRecommendService.sendCasesRecommend(casesRecommend); } catch (Exception e) {