package com.panzhihua.timejob.jobhandler;
|
|
import com.panzhihua.common.model.vos.R;
|
import com.panzhihua.common.service.partybuilding.NewStriveForFeign;
|
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 javax.annotation.Resource;
|
|
/**
|
* 金汇社区任务定时器
|
* @author lyq
|
*/
|
@Slf4j
|
@Component
|
public class NewFightHandler {
|
|
@Resource
|
private NewStriveForFeign communityService;
|
|
|
//定时任务 清空每日
|
@XxlJob("timedNewStriveIntegratingTaskHandler")
|
public ReturnT<String> timedNewStriveIntegratingTaskHandler(String param) throws Exception
|
{
|
log.info("定时任务 每天检测一次 清空每日签到 积分任务记录");
|
R r = communityService.truncateData();
|
log.info("执行结果【{}】", r.toString());
|
return ReturnT.SUCCESS;
|
}
|
|
|
|
|
//定时任务 新双争双评需求问题清单 任务认领 开始 结束 定时任务
|
@XxlJob("timedNewFightNeedProblemInventoryHandler")
|
public ReturnT<String> timedNewFightNeedProblemInventoryHandler(String param) throws Exception
|
{
|
log.info("定时任务 新双争双评需求问题清单 任务认领 开始 结束");
|
R r = communityService.timedNewFightNeedProblemInventoryHandler();
|
log.info("执行结果【{}】", r.toString());
|
ReturnT rt= new ReturnT<String>();
|
rt.setCode(ReturnT.SUCCESS_CODE);
|
rt.setContent("执行结果【{"+r.toString()+"}】");
|
|
return rt;
|
}
|
|
|
|
//定时任务 社区组织共建 定时更新项目进度
|
@XxlJob("taskTimedGetListTimeHandler")
|
public ReturnT<String> taskTimedGetListTimeHandler(String param) throws Exception
|
{
|
log.info("定时任务 社区组织共建 定时更新项目进度 ");
|
R r = communityService.taskTimedGetListTime();
|
log.info("执行结果【{}】", r.toString());
|
ReturnT rt= new ReturnT<String>();
|
rt.setCode(ReturnT.SUCCESS_CODE);
|
rt.setContent("执行结果【{"+r.toString()+"}】");
|
|
return rt;
|
}
|
}
|