Commit 6e13534c authored by 钱坤's avatar 钱坤

定时任务默认关闭,部署到prod环境准备跑数据

parent 81c0a5be
...@@ -21,6 +21,7 @@ import me.chanjar.weixin.cp.bean.Gender; ...@@ -21,6 +21,7 @@ import me.chanjar.weixin.cp.bean.Gender;
import me.chanjar.weixin.cp.bean.WxCpDepart; import me.chanjar.weixin.cp.bean.WxCpDepart;
import me.chanjar.weixin.cp.bean.WxCpUser; import me.chanjar.weixin.cp.bean.WxCpUser;
import me.chanjar.weixin.cp.config.impl.WxCpDefaultConfigImpl; import me.chanjar.weixin.cp.config.impl.WxCpDefaultConfigImpl;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled; import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
...@@ -58,12 +59,16 @@ public class OrgSyncByWxcpJob { ...@@ -58,12 +59,16 @@ public class OrgSyncByWxcpJob {
private RoleService roleService; private RoleService roleService;
@Resource @Resource
private OrgSyncService orgSyncService; private OrgSyncService orgSyncService;
@Value("${tanpu.sync.job.skipped:true}")
private boolean jobSkipped;
@Scheduled(cron="0 30 2 * * ?") //每日凌晨2点30执行 @Scheduled(cron="0 30 6 * * ?") //每日凌晨6点30执行
public void execute(){ public void execute(){
log.info("====== 开始执行OrgSyncByWxcpJob ======"); log.info("====== 开始执行OrgSyncByWxcpJob ======");
try { try {
orgSyncByWxcp("Y"); if (!jobSkipped) {
orgSyncByWxcp("Y");
}
} catch (Exception e) { } catch (Exception e) {
log.error("====== 异常结束执行OrgSyncByWxcpJob,错误:{}=======", e.getMessage()); log.error("====== 异常结束执行OrgSyncByWxcpJob,错误:{}=======", e.getMessage());
} }
...@@ -126,8 +131,8 @@ public class OrgSyncByWxcpJob { ...@@ -126,8 +131,8 @@ public class OrgSyncByWxcpJob {
} }
/** /**
* @description: 整理 员工与角色关联关系 数据 * @description: 整理 员工与角色关联关系 数据
* @Author: zejia zj wu * @Author: zejia zj wu
* @date: 2021/5/27 3:08 下午 * @date: 2021/5/27 3:08 下午
*/ */
...@@ -181,8 +186,8 @@ public class OrgSyncByWxcpJob { ...@@ -181,8 +186,8 @@ public class OrgSyncByWxcpJob {
} }
/** /**
* @description: 整理 部门与员工关联关系 数据 * @description: 整理 部门与员工关联关系 数据
* @Author: zejia zj wu * @Author: zejia zj wu
* @date: 2021/5/27 3:08 下午 * @date: 2021/5/27 3:08 下午
*/ */
...@@ -240,8 +245,8 @@ public class OrgSyncByWxcpJob { ...@@ -240,8 +245,8 @@ public class OrgSyncByWxcpJob {
return workDataDto; return workDataDto;
} }
/** /**
* @description: 整理 部门机构 数据 * @description: 整理 部门机构 数据
* @Author: zejia zj wu * @Author: zejia zj wu
* @date: 2021/5/27 3:09 下午 * @date: 2021/5/27 3:09 下午
*/ */
...@@ -301,8 +306,8 @@ public class OrgSyncByWxcpJob { ...@@ -301,8 +306,8 @@ public class OrgSyncByWxcpJob {
return workDataDto; return workDataDto;
} }
/** /**
* @description: 获取部门等级 * @description: 获取部门等级
* @Author: zejia zj wu * @Author: zejia zj wu
* @date: 2021/5/27 3:09 下午 * @date: 2021/5/27 3:09 下午
*/ */
...@@ -314,8 +319,8 @@ public class OrgSyncByWxcpJob { ...@@ -314,8 +319,8 @@ public class OrgSyncByWxcpJob {
return 1 + getLevel(hashMap2, parentId); return 1 + getLevel(hashMap2, parentId);
} }
/** /**
* @description: 整理 员工 数据 * @description: 整理 员工 数据
* @Author: zejia zj wu * @Author: zejia zj wu
* @date: 2021/5/27 3:09 下午 * @date: 2021/5/27 3:09 下午
*/ */
...@@ -379,8 +384,8 @@ public class OrgSyncByWxcpJob { ...@@ -379,8 +384,8 @@ public class OrgSyncByWxcpJob {
return workDataDto; return workDataDto;
} }
/** /**
* @description: 整理 用户表 数据 * @description: 整理 用户表 数据
* @Author: zejia zj wu * @Author: zejia zj wu
* @date: 2021/5/27 3:10 下午 * @date: 2021/5/27 3:10 下午
*/ */
...@@ -464,8 +469,8 @@ public class OrgSyncByWxcpJob { ...@@ -464,8 +469,8 @@ public class OrgSyncByWxcpJob {
/** /**
* @description: 判断是否需要执行 并返回数据MD5 * @description: 判断是否需要执行 并返回数据MD5
* @Author: zejia zj wu * @Author: zejia zj wu
* @date: 2021/5/27 3:10 下午 * @date: 2021/5/27 3:10 下午
*/ */
...@@ -480,8 +485,8 @@ public class OrgSyncByWxcpJob { ...@@ -480,8 +485,8 @@ public class OrgSyncByWxcpJob {
return digestHex; return digestHex;
} }
/** /**
* @description: 获取 企业微信 用户列表信息 * @description: 获取 企业微信 用户列表信息
* @Author: zejia zj wu * @Author: zejia zj wu
* @date: 2021/5/27 3:11 下午 * @date: 2021/5/27 3:11 下午
*/ */
...@@ -505,8 +510,8 @@ public class OrgSyncByWxcpJob { ...@@ -505,8 +510,8 @@ public class OrgSyncByWxcpJob {
return wxCpDepartDtoArrayList; return wxCpDepartDtoArrayList;
} }
/** /**
* @description: 获取 企业微信 部门聊表信息 * @description: 获取 企业微信 部门聊表信息
* @Author: zejia zj wu * @Author: zejia zj wu
* @date: 2021/5/27 3:11 下午 * @date: 2021/5/27 3:11 下午
*/ */
......
...@@ -4,6 +4,7 @@ apollo: ...@@ -4,6 +4,7 @@ apollo:
enabled: true # 启用apollo配置中心 enabled: true # 启用apollo配置中心
namespaces: application.yml # 监听namespaces namespaces: application.yml # 监听namespaces
cacheDir: ./apollocache/ # 配置中心缓存路径 cacheDir: ./apollocache/ # 配置中心缓存路径
meta: http://apollo.caixiaoquan.com:8080
# apollo appid # apollo appid
app.id: feo-jobs app.id: feo-jobs
......
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