|
@@ -317,15 +317,22 @@ public class TimingTask {
|
|
|
|
|
|
//每天1:00 同步昨天的微信请假信息
|
|
|
@Scheduled(cron = "0 0 1 ? * *")
|
|
|
+// @Scheduled(cron = "0 59 13 ? * *")
|
|
|
public void synWxLeave() throws Exception {
|
|
|
if (isDev) return;
|
|
|
System.out.println("+++++++++++++++++++微信请假同步开始+++++++++++++++++++");
|
|
|
String startTime = Long.toString(System.currentTimeMillis()/1000L-86400);
|
|
|
String endTime = Long.toString(System.currentTimeMillis()/1000L);
|
|
|
+ //查询开启了微信请假同步的公司
|
|
|
+ List<TimeType> needSynLeave = timeTypeMapper.selectList(new QueryWrapper<TimeType>().eq("wx_leave", 1));
|
|
|
+ ArrayList<Integer> companyId = new ArrayList<>();
|
|
|
+ needSynLeave.forEach(item->{
|
|
|
+ companyId.add(item.getCompanyId());
|
|
|
+ });
|
|
|
//查询更新审批中的请假单
|
|
|
List<LeaveSheet> approvalLeave = leaveSheetMapper.selectApprovalList();
|
|
|
//插入请假单并更新审核中的请假单
|
|
|
- List<WxCorpInfo> wxCorpInfos = wxCorpInfoMapper.selectList(null);
|
|
|
+ List<WxCorpInfo> wxCorpInfos = wxCorpInfoMapper.selectList(new QueryWrapper<WxCorpInfo>().in("company_id",companyId));
|
|
|
List<LeaveSheet> leaveSheets = wxCorpInfoService.wxLeaveNumber(startTime,endTime, wxCorpInfos,approvalLeave);
|
|
|
for (LeaveSheet leaveSheet : leaveSheets) {
|
|
|
leaveSheetMapper.insert(leaveSheet);
|