Commit d6e896bb by qwmqiuwenmin

fix

parent a40949f8
...@@ -536,26 +536,6 @@ public class WxEnterpriseController extends WebBaseController{ ...@@ -536,26 +536,6 @@ public class WxEnterpriseController extends WebBaseController{
if(StringUtils.isEmpty(taskId)){ if(StringUtils.isEmpty(taskId)){
return resultResponse(HaoBanErrCode.ERR_100021); return resultResponse(HaoBanErrCode.ERR_100021);
} }
QuartzTaskDTO taskDTO = buildQuartzTaskDTO("hb-fresh-wx-friend");
JSONObject json = new JSONObject();
json.put("taskId", taskId);
json.put("wxEnterpriseId", wxEnterpriseId);
taskDTO.setTaskParam(json.toJSONString());
taskDTO.setTaskStatus(1);
Date now = new Date();
Date exeDate = DateUtil.addDay(now, 1);
Calendar ca = Calendar.getInstance();
ca.setTime(exeDate);
// int hour = ca.get(Calendar.HOUR);
int day = ca.get(Calendar.DAY_OF_MONTH);//第几天
int month = ca.get(Calendar.MONTH);//第几个月
int year = ca.get(Calendar.YEAR);//年份数值
int hour = 4;//
int minute = ca.get(Calendar.MINUTE);//
int second = ca.get(Calendar.SECOND);//
String con = second + " " + minute + " " + hour + " " + day + " " + month +" " + year;
taskDTO.setTaskTimeInfo(con);
quartzService.addOrUpdateQuartzTask(taskDTO);
// dealSyncOperationApiService.dealWxFriendClerk(taskId, wxEnterpriseId); // dealSyncOperationApiService.dealWxFriendClerk(taskId, wxEnterpriseId);
RedisUtil.setCache(dayKey, dayCount+1); RedisUtil.setCache(dayKey, dayCount+1);
RedisUtil.setCache(monthKey, monthCount+1); RedisUtil.setCache(monthKey, monthCount+1);
......
package com.gic.haoban.manage.web.init; package com.gic.haoban.manage.web.init;
import com.alibaba.fastjson.JSONObject;
import com.gic.commons.util.DateUtil;
import com.gic.quartz.api.dto.QuartzTaskDTO; import com.gic.quartz.api.dto.QuartzTaskDTO;
import com.gic.quartz.api.service.QuartzService; import com.gic.quartz.api.service.QuartzService;
import java.util.Calendar;
import java.util.Date;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.springframework.beans.BeansException; import org.springframework.beans.BeansException;
...@@ -35,6 +40,13 @@ public class MyApplicationContextAware implements ApplicationContextAware { ...@@ -35,6 +40,13 @@ public class MyApplicationContextAware implements ApplicationContextAware {
memberExportTask.setTaskStatus(1); memberExportTask.setTaskStatus(1);
memberExportTask.setTaskTimeInfo("0 0/15 * * * *"); memberExportTask.setTaskTimeInfo("0 0/15 * * * *");
quartzService.addOrUpdateQuartzTask(memberExportTask); quartzService.addOrUpdateQuartzTask(memberExportTask);
QuartzTaskDTO taskDTO = buildQuartzTaskDTO("hb-fresh-wx-friend");
taskDTO.setTaskParam("-1");
taskDTO.setTaskStatus(1);
taskDTO.setTaskTimeInfo("0 0 10 * * *");
quartzService.addOrUpdateQuartzTask(taskDTO);
} }
// private QuartzTaskDTO buildQuartzMessageDTO(String id) { // private QuartzTaskDTO buildQuartzMessageDTO(String id) {
...@@ -44,9 +56,17 @@ public class MyApplicationContextAware implements ApplicationContextAware { ...@@ -44,9 +56,17 @@ public class MyApplicationContextAware implements ApplicationContextAware {
// taskDTO.setTaskService("com.gic.haoban.app.customer.service.api.service.MessageLogApiService"); // taskDTO.setTaskService("com.gic.haoban.app.customer.service.api.service.MessageLogApiService");
// return taskDTO; // return taskDTO;
// } // }
private QuartzTaskDTO buildQuartzTaskDTO(String id) {
QuartzTaskDTO taskDTO = new QuartzTaskDTO();
taskDTO.setReferId(id);
taskDTO.setTaskMethod("quartWxFriendClerk");
taskDTO.setTaskService("com.gic.haoban.manage.api.service.DealSyncOperationApiService");
return taskDTO;
}
private QuartzTaskDTO buildMemberExportQuartzTaskDTO(String id) { private QuartzTaskDTO buildMemberExportQuartzTaskDTO(String id) {
QuartzTaskDTO taskDTO = new QuartzTaskDTO(); QuartzTaskDTO taskDTO = new QuartzTaskDTO();
taskDTO.setReferId(id); taskDTO.setReferId(id);
taskDTO.setTaskMethod("quartzMemberExport"); taskDTO.setTaskMethod("quartzMemberExport");
taskDTO.setTaskService("com.gic.haoban.app.customer.service.api.service.MemberExportApiService"); taskDTO.setTaskService("com.gic.haoban.app.customer.service.api.service.MemberExportApiService");
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment