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

提交推送任务

Browse Source
This commit is contained in:
Guava
2023-06-26 10:13:17 +08:00
parent 59671cced7
commit 961487071f
4 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
servers/boe-server-task/src/main/java/com/xboe/module/cases/entity/CasesRecommend.java
View File

@@ -41,8 +41,8 @@ public class CasesRecommend extends BaseEntity {
@Column(name = "user_count",length = 11)
private Integer userCount;
/**推送进度*/
@Column(name = "push_progress", length = 255)
private String pushProgress;
@Column(name = "push_progress")
private Integer pushProgress;
/**查看率*/
@Column(name = "view_rate", length = 255)
private String viewRate;

2
servers/boe-server-task/src/main/java/com/xboe/module/cases/service/ICasesRecommendService.java
View File

@@ -12,7 +12,7 @@ public interface ICasesRecommendService {
* @param pushProgress
* @return
*/
List<CasesRecommend> queryByPushProgress(String pushProgress);
List<CasesRecommend> queryByPushProgress(Integer pushProgress);
/**
* 修改

4
servers/boe-server-task/src/main/java/com/xboe/module/cases/service/impl/CasesRecommendServiceImpl.java
View File

@@ -16,8 +16,8 @@ public class CasesRecommendServiceImpl implements ICasesRecommendService {
private CasesRecommendDao casesRecommendDao;
@Override
public List<CasesRecommend> queryByPushProgress(String pushProgress) {
return casesRecommendDao.getGenericDao().findList(CasesRecommend.class, FieldFilters.eq("push_progress", pushProgress));
public List<CasesRecommend> queryByPushProgress(Integer pushProgress) {
return casesRecommendDao.getGenericDao().findList(CasesRecommend.class, FieldFilters.eq("pushProgress", pushProgress));
}

8
servers/boe-server-task/src/main/java/com/xboe/task/CasesRecommendPushSchedule.java
View File

@@ -46,7 +46,7 @@ public class CasesRecommendPushSchedule {
@Scheduled(cron = "0 */1 * * * ?")
public void execute() {
log.info("启动案例推荐定时任务");
List<CasesRecommend> casesRecommends = casesRecommendService.queryByPushProgress(CasesPushStatusEnum.WAIT_PUSH.name());
List<CasesRecommend> casesRecommends = casesRecommendService.queryByPushProgress(CasesPushStatusEnum.WAIT_PUSH.getStatus());
if (CollectionUtils.isEmpty(casesRecommends)) {
log.warn("没有推送纪录，无需推送");
return;
@@ -60,14 +60,14 @@ public class CasesRecommendPushSchedule {
//修改为推送完成 --- 无数据 无需推送
CasesRecommend tempUpdate = new CasesRecommend();
tempUpdate.setId(casesRecommend.getId());
tempUpdate.setPushProgress(CasesPushStatusEnum.PUSH_SUCCESS.name());
tempUpdate.setPushProgress(CasesPushStatusEnum.PUSH_SUCCESS.getStatus());
casesRecommendService.update(tempUpdate);
continue;
}
//修改为推送中
CasesRecommend tempUpdate = new CasesRecommend();
tempUpdate.setId(casesRecommend.getId());
tempUpdate.setPushProgress(CasesPushStatusEnum.PUSH_ING.name());
tempUpdate.setPushProgress(CasesPushStatusEnum.PUSH_ING.getStatus());
casesRecommendService.update(tempUpdate);
for (CasesRecommendPushRecord casesRecommendPushRecord : casesRecommendPushRecords) {
@@ -92,7 +92,7 @@ public class CasesRecommendPushSchedule {
//修改为推送完成 --- 无数据 无需推送
CasesRecommend finishTemp = new CasesRecommend();
finishTemp.setId(casesRecommend.getId());
finishTemp.setPushProgress(CasesPushStatusEnum.PUSH_SUCCESS.name());
finishTemp.setPushProgress(CasesPushStatusEnum.PUSH_SUCCESS.getStatus());
casesRecommendService.update(finishTemp);
log.info("启动案例推荐定时任务----结束");
}