From 8d5fb4ee9d27fd6a61b210eaee74af265f76aa7c Mon Sep 17 00:00:00 2001
From: manailin <261030956@qq.com>
Date: 星期五, 08 四月 2022 14:55:18 +0800
Subject: [PATCH] [修改]修改配置
---
springcloud_k8s_panzhihuazhihuishequ/timejob/src/main/java/com/panzhihua/timejob/jobhandler/CommunityJobHandler.java | 86 +++++++++++++++++++++++++++++++++++++------
1 files changed, 74 insertions(+), 12 deletions(-)
diff --git a/springcloud_k8s_panzhihuazhihuishequ/timejob/src/main/java/com/panzhihua/timejob/jobhandler/CommunityJobHandler.java b/springcloud_k8s_panzhihuazhihuishequ/timejob/src/main/java/com/panzhihua/timejob/jobhandler/CommunityJobHandler.java
index 937f83b..b4855de 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/timejob/src/main/java/com/panzhihua/timejob/jobhandler/CommunityJobHandler.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/timejob/src/main/java/com/panzhihua/timejob/jobhandler/CommunityJobHandler.java
@@ -130,7 +130,7 @@
// 获取待结束的活动列表
List<Long> activityList = JSONArray.parseArray(JSONArray.toJSONString(r.getData()), Long.class);
if (!activityList.isEmpty()) {
- log.info("社区活动结束时计算积分");
+ log.info("社区活动结束时扣减未参与用户积分");
activityList.forEach(activityId -> {
R r1 = communityService.getTaskActivityPeopleList(activityId);
if (R.isOk(r1)) {
@@ -138,15 +138,14 @@
JSONArray.parseArray(JSONArray.toJSONString(r1.getData()), ComActActivityPeopleVO.class);
if (!peopleList.isEmpty()) {
peopleList.forEach(people -> {
- if (people.getIsVolunteer().equals(1)) {
- communityService.addIntegralTradeAdmin(new AddComActIntegralUserDTO(
- people.getActivityId(), AddComActIntegralUserDTO.integralType.cyzyzhd,
- people.getCommunityId(), people.getUserId()));
- } else {
- communityService.addIntegralTradeAdmin(new AddComActIntegralUserDTO(
- people.getActivityId(), AddComActIntegralUserDTO.integralType.cysqhd,
- people.getCommunityId(), people.getUserId()));
- }
+ AddComActIntegralUserDTO addComActIntegralUserDTO = new AddComActIntegralUserDTO();
+ addComActIntegralUserDTO.setUserId(people.getUserId());
+ addComActIntegralUserDTO.setIntegralType(AddComActIntegralUserDTO.integralType.qxhd);
+ addComActIntegralUserDTO.setActivityType(1);
+ addComActIntegralUserDTO.setIsVolunteer(people.getIsVolunteer());
+ addComActIntegralUserDTO.setCommunityId(people.getCommunityId());
+ addComActIntegralUserDTO.setServiceId(activityId);
+ communityService.addIntegralTradeAdmin(addComActIntegralUserDTO);
});
}
}
@@ -218,11 +217,18 @@
@XxlJob("timedTaskEldersAuthJobHandler")
public ReturnT<String> timedTaskEldersAuthJobHandler(String param) throws Exception {
- log.info("定时任务扫描上月高龄认证使用视频认证的用户添加成功记录");
+ log.info("定时任务扫描老人库的老人是否已加入到统计表中");
R r = communityService.timedTaskEldersAuthRecordJobHandler();
log.info("执行结果【{}】", r.toString());
+ log.info("定时任务扫描老人认证成功记录加入到统计表中");
+ R r1 = communityService.timedTaskElderAuthStatisticsJobHandler();
+ log.info("执行结果【{}】", r1.toString());
+ return ReturnT.SUCCESS;
+ }
- log.info("定时任务扫描高龄认证记录统计信息");
+ @XxlJob("timedTaskEldersAuthJobMonthHandler")
+ public ReturnT<String> timedTaskEldersAuthJobMonthHandler(String param) throws Exception {
+ log.info("定时任务扫描高龄认证记录重置任务");
R r1 = communityService.timedTaskEldersAuthJobHandler();
log.info("执行结果【{}】", r1.toString());
return ReturnT.SUCCESS;
@@ -249,4 +255,60 @@
log.info("执行结果【{}】", r.toString());
return ReturnT.SUCCESS;
}
+
+ /**
+ * 定时任务每隔半小时将商家浏览量和咨询量总值计入指定商家数据中
+ */
+ @XxlJob("timedTaskWriteDataToMerchantJobHandler")
+ public ReturnT<String> timedTaskWriteDataToMerchantJobHandler(String param) {
+ log.info("定时任务每隔半小时将商家浏览量和咨询量总值计入指定商家数据中");
+ R r = communityService.timedTaskWriteDataToMerchantJobHandler();
+ log.info("执行结果【{}】", r.toString());
+ return ReturnT.SUCCESS;
+ }
+
+ @XxlJob("timedTaskHouseJobHandler")
+ public ReturnT<String> timedTaskHouseJobHandler(String param) {
+ log.info("实有房屋定时任务修复数据");
+ R r = communityService.timedTaskHouseJobHandler();
+ log.info("执行结果【{}】", r.toString());
+ return ReturnT.SUCCESS;
+ }
+
+ /**
+ * 定时任务-每隔5分钟执行一次，将已到期的微商业街商家旗下所有的游戏/资讯全部下架
+ * @param param
+ * @return
+ */
+ @XxlJob("offResourceForMcsMerchantJobHandler")
+ public ReturnT<String> offResourceForMcsMerchantJobHandler(String param) {
+ log.info("定时任务将已到期的微商业街商家旗下所有的游戏/资讯全部下架");
+ R r = communityService.offResourceForMcsMerchant();
+ log.info("执行结果【{}】", r.toString());
+ return ReturnT.SUCCESS;
+ }
+
+ /**
+ * 定时任务-每隔5分钟执行一次，将已到期的微商业街游戏结束
+ * @param param
+ * @return
+ */
+ @XxlJob("endStatusForMcsGameJobHandler")
+ public ReturnT<String> endStatusForMcsGameJobHandler(String param) {
+ log.info("定时任务，将已到期的微商业街游戏结束");
+ R r = communityService.endStatusForMcsGame();
+ log.info("执行结果【{}】", r.toString());
+ return ReturnT.SUCCESS;
+ }
+
+ /**
+ * 定时任务针对服务结束后3天还未评价的用户默认好评
+ */
+ @XxlJob("timedTaskFmsServiceDefaultPraiseJobHandler")
+ public ReturnT<String> timedTaskFmsServiceDefaultPraiseJobHandler(String param) throws Exception {
+ log.info("定时任务针对服务结束后3天还未评价的用户默认好评");
+ R r = communityService.timedTaskFmsServiceDefaultPraise();
+ log.info("执行结果【{}】", r.toString());
+ return ReturnT.SUCCESS;
+ }
}
--
Gitblit v1.7.1