From 179c4d64313c9b7572778da4aaaf6c6584fe457d Mon Sep 17 00:00:00 2001
From: mitao <2763622819@qq.com>
Date: 星期二, 20 五月 2025 23:48:08 +0800
Subject: [PATCH] 修改文件上传类型限制
---
springcloud_k8s_panzhihuazhihuishequ/timejob/src/main/java/com/panzhihua/timejob/jobhandler/PartyBuildingJobHandler.java | 70 ++++++++++++++++++++++++++--------
1 files changed, 53 insertions(+), 17 deletions(-)
diff --git a/springcloud_k8s_panzhihuazhihuishequ/timejob/src/main/java/com/panzhihua/timejob/jobhandler/PartyBuildingJobHandler.java b/springcloud_k8s_panzhihuazhihuishequ/timejob/src/main/java/com/panzhihua/timejob/jobhandler/PartyBuildingJobHandler.java
index 6265902..a7d0f94 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/timejob/src/main/java/com/panzhihua/timejob/jobhandler/PartyBuildingJobHandler.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/timejob/src/main/java/com/panzhihua/timejob/jobhandler/PartyBuildingJobHandler.java
@@ -1,21 +1,27 @@
package com.panzhihua.timejob.jobhandler;
+import java.util.Date;
+import java.util.List;
+
+import javax.annotation.Resource;
+
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
+import com.panzhihua.common.model.dtos.community.integral.admin.AddComActIntegralUserDTO;
import com.panzhihua.common.model.vos.R;
+import com.panzhihua.common.model.vos.community.integral.admin.ComActActivityPeopleVO;
import com.panzhihua.common.model.vos.partybuilding.PartyBuildingActivityVO;
import com.panzhihua.common.model.vos.user.SysUserNoticeVO;
+import com.panzhihua.common.service.community.CommunityService;
import com.panzhihua.common.service.partybuilding.PartyBuildingService;
import com.panzhihua.common.service.user.UserService;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-import org.springframework.util.ObjectUtils;
-import javax.annotation.Resource;
-import java.util.Date;
-import java.util.List;
+import lombok.extern.slf4j.Slf4j;
/**
* @program: springcloud_k8s_panzhihuazhihuishequ
@@ -31,33 +37,40 @@
private PartyBuildingService partyBuildingService;
@Resource
private UserService userService;
+ @Resource
+ private CommunityService communityService;
/**
* 定时任务刷新党建动态发布状态
+ *
* @return 刷新个数
- * @throws Exception 出现的异常
+ * @throws Exception
+ * 出现的异常
*/
@XxlJob("timedtaskpartybuildingstatusJobHandler")
public ReturnT<String> timedtaskpartybuildingstatusJobHandler(String param) throws Exception {
log.info("定时任务刷新党建动态发布状态");
- R r=partyBuildingService.timedTaskPartyBuildingStatus();
- log.info("执行结果【{}】",r.toString());
+ R r = partyBuildingService.timedTaskPartyBuildingStatus();
+ log.info("执行结果【{}】", r.toString());
return ReturnT.SUCCESS;
}
/**
* 定时任务取消党建活动
+ *
* @return 取消个数
- * @throws Exception 出现的异常
+ * @throws Exception
+ * 出现的异常
*/
@XxlJob("timedTaskPartyBuildingActivityJobHandler")
public ReturnT<String> timedTaskPartyBuildingActivityJobHandler(String param) throws Exception {
log.info("定时任务取消党建活动");
- R r=partyBuildingService.timedTaskPartyBuildingActivity();
+ R r = partyBuildingService.timedTaskPartyBuildingActivity();
if (R.isOk(r)) {
Object data = r.getData();
if (!ObjectUtils.isEmpty(data)) {
- List<PartyBuildingActivityVO> partyBuildingActivityVOS= JSONArray.parseArray(JSONArray.toJSONString(data),PartyBuildingActivityVO.class);
+ List<PartyBuildingActivityVO> partyBuildingActivityVOS =
+ JSONArray.parseArray(JSONArray.toJSONString(data), PartyBuildingActivityVO.class);
if (!ObjectUtils.isEmpty(partyBuildingActivityVOS)) {
partyBuildingActivityVOS.forEach(partyBuildingActivityVO -> {
List<Long> userIds = partyBuildingActivityVO.getUserIds();
@@ -83,22 +96,45 @@
});
}
}
- }
+ }
- log.info("执行结果【{}】",r.toString());
+ log.info("执行结果【{}】", r.toString());
return ReturnT.SUCCESS;
}
/**
* 定时任务刷新党建活动的各个状态 除取消外
+ *
* @return 刷新个数
- * @throws Exception 出现的异常
+ * @throws Exception
+ * 出现的异常
*/
@XxlJob("timedTaskPartyBuildingActivityAllJobHandler")
public ReturnT<String> timedTaskPartyBuildingActivityAllJobHandler(String param) throws Exception {
log.info("定时任务刷新党建活动的各个状态 除取消外");
- R r=partyBuildingService.timedTaskPartyBuildingActivityAll();
- log.info("执行结果【{}】",r.toString());
+ R r = partyBuildingService.timedTaskPartyBuildingActivityAll();
+ if (R.isOk(r)) {
+ // 获取待结束的活动列表
+ List<Long> activityList = JSONArray.parseArray(JSONArray.toJSONString(r.getData()), Long.class);
+ if (!activityList.isEmpty()) {
+ log.info("党员活动结束计算积分");
+ activityList.forEach(activityId -> {
+ R r1 = partyBuildingService.getTaskPbActivityPeopleList(activityId);
+ if (R.isOk(r1)) {
+ List<ComActActivityPeopleVO> peopleList =
+ JSONArray.parseArray(JSONArray.toJSONString(r1.getData()), ComActActivityPeopleVO.class);
+ if (!peopleList.isEmpty()) {
+ peopleList.forEach(people -> {
+ communityService.addIntegralTradeAdmin(new AddComActIntegralUserDTO(
+ people.getActivityId(), AddComActIntegralUserDTO.integralType.cydyhd,
+ people.getCommunityId(), people.getUserId()));
+ });
+ }
+ }
+ });
+ }
+ }
+ log.info("执行结果【{}】", r.toString());
return ReturnT.SUCCESS;
}
}
--
Gitblit v1.7.1