From 32c13616300f182704a4844fddb8ff7901d51678 Mon Sep 17 00:00:00 2001
From: huanghongfa <18228131219@163.com>
Date: 星期五, 15 一月 2021 12:09:03 +0800
Subject: [PATCH] 定时任务修改
---
springcloud_k8s_panzhihuazhihuishequ/timejob/src/main/java/com/panzhihua/timejob/jobhandler/CommunityJobHandler.java | 64 +++++++++++++++++--------------
1 files changed, 35 insertions(+), 29 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 4e0be18..401522f 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
@@ -42,7 +42,8 @@
public ReturnT<String> timedTaskDynIstoppingJobHandler(String param) throws Exception {
log.info("定时任务刷新社区动态置顶状态");
R r=communityService.timedTaskDynIstopping();
- return new ReturnT(r.getData().toString());
+ log.info("执行结果【{}】",r.toString());
+ return ReturnT.SUCCESS;
}
/**
@@ -54,7 +55,8 @@
public ReturnT<String> timedTaskDynStatusJobHandler(String param) throws Exception {
log.info("定时任务刷新社区动态发布状态");
R r=communityService.timedTaskDynStatus();
- return new ReturnT(r.getData().toString());
+ log.info("执行结果【{}】",r.toString());
+ return ReturnT.SUCCESS;
}
/**
@@ -68,34 +70,37 @@
R r=communityService.timedTaskActActivity();
if (R.isOk(r)) {
Object data = r.getData();
- List<ComActActivityVO> comActActivityVOS= JSONArray.parseArray(JSONArray.toJSONString(data),ComActActivityVO.class);
- if (!ObjectUtils.isEmpty(comActActivityVOS)) {
- comActActivityVOS.forEach(comActActivityVO -> {
- List<ActivitySignVO> activitySignVOList = comActActivityVO.getActivitySignVOList();
- if (!ObjectUtils.isEmpty(activitySignVOList)) {
- activitySignVOList.forEach(activitySignVO -> {
- SysUserNoticeVO sysUserNoticeVO = new SysUserNoticeVO();
- sysUserNoticeVO.setUserId(activitySignVO.getUserId());
- sysUserNoticeVO.setType(1);
- sysUserNoticeVO.setBusinessType(2);
- sysUserNoticeVO.setBusinessTitle(comActActivityVO.getActivityName());
- sysUserNoticeVO.setBusinessTime(new Date());
- sysUserNoticeVO.setBusinessId(comActActivityVO.getId());
- sysUserNoticeVO.setStatus(0);
- sysUserNoticeVO.setTitle("活动因故取消");
- sysUserNoticeVO.setBusinessContent("报名人数不足活动自动取消");
- sysUserNoticeVO.setBusinessStatus(1);
- sysUserNoticeVO.setActivityType(activitySignVO.getIsVolunteer().intValue()==1?1:2);
- R r2 = userService.addNotice(sysUserNoticeVO);
- if (R.isOk(r2)) {
- log.info("新增社区活动取消通知成功【{}】", JSONObject.toJSONString(sysUserNoticeVO));
- }
- });
- }
- });
+ if (!ObjectUtils.isEmpty(data)) {
+ List<ComActActivityVO> comActActivityVOS= JSONArray.parseArray(JSONArray.toJSONString(data),ComActActivityVO.class);
+ if (!ObjectUtils.isEmpty(comActActivityVOS)) {
+ comActActivityVOS.forEach(comActActivityVO -> {
+ List<ActivitySignVO> activitySignVOList = comActActivityVO.getActivitySignVOList();
+ if (!ObjectUtils.isEmpty(activitySignVOList)) {
+ activitySignVOList.forEach(activitySignVO -> {
+ SysUserNoticeVO sysUserNoticeVO = new SysUserNoticeVO();
+ sysUserNoticeVO.setUserId(activitySignVO.getUserId());
+ sysUserNoticeVO.setType(1);
+ sysUserNoticeVO.setBusinessType(2);
+ sysUserNoticeVO.setBusinessTitle(comActActivityVO.getActivityName());
+ sysUserNoticeVO.setBusinessTime(new Date());
+ sysUserNoticeVO.setBusinessId(comActActivityVO.getId());
+ sysUserNoticeVO.setStatus(0);
+ sysUserNoticeVO.setTitle("活动因故取消");
+ sysUserNoticeVO.setBusinessContent("报名人数不足活动自动取消");
+ sysUserNoticeVO.setBusinessStatus(1);
+ sysUserNoticeVO.setActivityType(activitySignVO.getIsVolunteer().intValue()==1?1:2);
+ R r2 = userService.addNotice(sysUserNoticeVO);
+ if (R.isOk(r2)) {
+ log.info("新增社区活动取消通知成功【{}】", JSONObject.toJSONString(sysUserNoticeVO));
+ }
+ });
+ }
+ });
+ }
}
}
- return new ReturnT(r.getData().toString());
+ log.info("执行结果【{}】",r.toString());
+ return ReturnT.SUCCESS;
}
/**
@@ -107,6 +112,7 @@
public ReturnT<String> timedTaskActActivityAllJobHandler(String param) throws Exception {
log.info("定时任务刷新社区活动的各个状态 除取消外");
R r=communityService.timedTaskActActivityAll();
- return new ReturnT(r.getData().toString().toString());
+ log.info("执行结果【{}】",r.toString());
+ return ReturnT.SUCCESS;
}
}
--
Gitblit v1.7.1