Commit 6dc072e7 by qwmqiuwenmin

fix

parent cfdb6129
......@@ -150,6 +150,9 @@ public interface DealSyncOperationApiService {
* @param wxEnterpriseId
*/
public void dealWxFriendClerkSingle(String taskId, String wxUserId, String staffId,String wxEnterpriseId);
/**
* 定时
* @param res
*/
public void quartWxFriendClerk(String res);
}
package com.gic.haoban.manage.service.service.out.impl;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.gic.api.base.commons.Page;
import com.gic.clerk.api.dto.ClerkDTO;
......@@ -688,4 +689,16 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
HashSet<String> hashSet = (HashSet<String>) dealLogList.stream().map(TabHaobanPreDealLog::getDataId).collect(Collectors.toSet());
dealDepartmentToMq(taskId, hashSet, SyncTaskStatusEnum.friend_clerk_sync);
}
@Override
public void quartWxFriendClerk(String res) {
if(StringUtils.isNotBlank(res)){
JSONObject json = JSON.parseObject(res);
String taskId = json.getString("taskId");
String wxEnterpriseId = json.getString("wxEnterpriseId");
dealWxFriendClerk(taskId, wxEnterpriseId);
}
}
}
......@@ -3,6 +3,7 @@ package com.gic.haoban.manage.web.controller;
import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.druid.util.StringUtils;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.gic.api.base.commons.Page;
import com.gic.commons.util.DateUtil;
import com.gic.enterprise.api.dto.EnterpriseAndUserDTO;
......@@ -535,23 +536,26 @@ public class WxEnterpriseController extends WebBaseController{
if(StringUtils.isEmpty(taskId)){
return resultResponse(HaoBanErrCode.ERR_100021);
}
// QuartzTaskDTO taskDTO = buildQuartzTaskDTO("haoban-enterprise-fresh-wx-friend");
// taskDTO.setTaskParam("");
// taskDTO.setTaskStatus(1);
// Date now = new Date();
// Date exeDate = DateUtil.addDay(now, 1);
// Calendar ca = Calendar.getInstance();
// ca.setTime(exeDate);
// int day = ca.get(Calendar.DAY_OF_MONTH);//第几天
// int month = ca.get(Calendar.MONTH);//第几个月
// int year = ca.get(Calendar.YEAR);//年份数值
// int hour = ca.get(Calendar.HOUR);//
// 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);
QuartzTaskDTO taskDTO = buildQuartzTaskDTO("haoban-enterprise-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(now);
int day = ca.get(Calendar.DAY_OF_MONTH);//第几天
int month = ca.get(Calendar.MONTH);//第几个月
int year = ca.get(Calendar.YEAR);//年份数值
int hour = ca.get(Calendar.HOUR);//
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);
RedisUtil.setCache(dayKey, dayCount+1);
RedisUtil.setCache(monthKey, monthCount+1);
RedisUtil.setCache(dateKey, DateUtil.dateToStr(new Date(),DateUtil.FORMAT_DATETIME_19));
......@@ -561,7 +565,7 @@ public class WxEnterpriseController extends WebBaseController{
private QuartzTaskDTO buildQuartzTaskDTO(String id) {
QuartzTaskDTO taskDTO = new QuartzTaskDTO();
taskDTO.setReferId(id);
taskDTO.setTaskMethod("dealWxFriendClerk");
taskDTO.setTaskMethod("quartWxFriendClerk");
taskDTO.setTaskService("com.gic.haoban.manage.api.service.DealSyncOperationApiService");
return taskDTO;
}
......
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