|
@@ -291,11 +291,11 @@ public class DataCollectTask {
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
- @Scheduled(cron = "0 30 1 * * ?")
|
|
|
|
-//@Scheduled(cron = "0 42 16 * * ?")
|
|
|
|
|
|
+// @Scheduled(cron = "0 30 1 * * ?")
|
|
|
|
+@Scheduled(cron = "50 24 11 * * ?")
|
|
public void workDayTask(){
|
|
public void workDayTask(){
|
|
- if(isDev){return;}
|
|
|
|
- if(isPrivateDeploy) return;
|
|
|
|
|
|
+// if(isDev){return;}
|
|
|
|
+// if(isPrivateDeploy) return;
|
|
RestTemplate restTemplate = new RestTemplate();
|
|
RestTemplate restTemplate = new RestTemplate();
|
|
String sumUrl = PREFIX_URL+"/dataCollect/getWorkDayDataSum";
|
|
String sumUrl = PREFIX_URL+"/dataCollect/getWorkDayDataSum";
|
|
String listUrl = PREFIX_URL+"/dataCollect/getWorkDayDataList";
|
|
String listUrl = PREFIX_URL+"/dataCollect/getWorkDayDataList";
|
|
@@ -470,7 +470,7 @@ public class DataCollectTask {
|
|
if (owner.getIsActive() == 0) {
|
|
if (owner.getIsActive() == 0) {
|
|
continue;
|
|
continue;
|
|
}
|
|
}
|
|
- Project project = projectMapper.selectOne(new QueryWrapper<Project>().eq("project_code", "HH-GG-0000001").eq("company_id", specialCompanyId));
|
|
|
|
|
|
+ Project project = projectMapper.selectOne(new QueryWrapper<Project>().eq("project_code", "HH-QJ-0000001").eq("company_id", specialCompanyId));
|
|
TaskGroup leaveGroup = taskGroupMapper.selectOne(new LambdaQueryWrapper<TaskGroup>().eq(TaskGroup::getProjectId, project.getId()).eq(TaskGroup::getName, "请假工时"));
|
|
TaskGroup leaveGroup = taskGroupMapper.selectOne(new LambdaQueryWrapper<TaskGroup>().eq(TaskGroup::getProjectId, project.getId()).eq(TaskGroup::getName, "请假工时"));
|
|
for (LocalDate date = tmp.getStartDate(); date.compareTo(tmp.getEndDate()) <= 0; date = date.plusDays(1)) {
|
|
for (LocalDate date = tmp.getStartDate(); date.compareTo(tmp.getEndDate()) <= 0; date = date.plusDays(1)) {
|
|
//先计算每一天的请假工时数合计
|
|
//先计算每一天的请假工时数合计
|
|
@@ -733,12 +733,12 @@ public class DataCollectTask {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- @Scheduled(cron = "0 0 3 * * ?")
|
|
|
|
-//@Scheduled(cron = "0 57 9 * * ?")
|
|
|
|
|
|
+// @Scheduled(cron = "0 0 3 * * ?")
|
|
|
|
+@Scheduled(cron = "30 47 11 * * ?")
|
|
@Async
|
|
@Async
|
|
public void businessTripTask(){
|
|
public void businessTripTask(){
|
|
- if(isDev){return;}
|
|
|
|
- if(isPrivateDeploy) return;
|
|
|
|
|
|
+// if(isDev){return;}
|
|
|
|
+// if(isPrivateDeploy) return;
|
|
RestTemplate restTemplate = new RestTemplate();
|
|
RestTemplate restTemplate = new RestTemplate();
|
|
String sumUrl = PREFIX_URL+"/dataCollect/getBusinessTripDataSum";
|
|
String sumUrl = PREFIX_URL+"/dataCollect/getBusinessTripDataSum";
|
|
String listUrl = PREFIX_URL+"/dataCollect/getBusinessTripDataList";
|
|
String listUrl = PREFIX_URL+"/dataCollect/getBusinessTripDataList";
|
|
@@ -799,14 +799,7 @@ public class DataCollectTask {
|
|
toAddList.add(businessTrip);
|
|
toAddList.add(businessTrip);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
-// if(existBTripList.size() > 0){
|
|
|
|
-// toUpdateList.addAll(realDataList.stream().filter(t -> existIds.contains(t.getProcinstId())).collect(Collectors.toList()));
|
|
|
|
-// toAddList.addAll(realDataList.stream().filter(t -> !existIds.contains(t.getProcinstId())).collect(Collectors.toList()));
|
|
|
|
-// }else{
|
|
|
|
-// toAddList.addAll(realDataList);
|
|
|
|
-// }
|
|
|
|
if(!CollectionUtils.isEmpty(toAddList)){
|
|
if(!CollectionUtils.isEmpty(toAddList)){
|
|
-// businessTripMapper.batchInsert(toAddList);
|
|
|
|
for (BusinessTrip businessTrip : toAddList) {
|
|
for (BusinessTrip businessTrip : toAddList) {
|
|
businessTripMapper.insert(businessTrip);
|
|
businessTripMapper.insert(businessTrip);
|
|
if (!StringUtils.isEmpty(businessTrip.getCCcxmNo())) {
|
|
if (!StringUtils.isEmpty(businessTrip.getCCcxmNo())) {
|
|
@@ -850,6 +843,28 @@ public class DataCollectTask {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ //自动生成考勤数据
|
|
|
|
+ for (BusinessTrip trip : realDataList) {
|
|
|
|
+ LocalDate startDate = trip.getStartDate();
|
|
|
|
+ LocalDate endDate = trip.getEndDate();
|
|
|
|
+ while (!startDate.isAfter(endDate)) {
|
|
|
|
+ //检查是否已经有当天的考勤
|
|
|
|
+ int cnt = userFvTimeMapper.selectCount(new QueryWrapper<UserFvTime>().eq("work_date", startDate).eq("user_id", trip.getOwnerId()));
|
|
|
|
+ if (cnt == 0) {
|
|
|
|
+ UserFvTime time = new UserFvTime();
|
|
|
|
+ time.setUserId(trip.getOwnerId());
|
|
|
|
+ time.setWorkDate(startDate);
|
|
|
|
+ time.setStartTime("9:00");
|
|
|
|
+ time.setEndTime("18:00");
|
|
|
|
+ time.setWorkHours(8.0f);
|
|
|
|
+ time.setCompanyId(trip.getCompanyId());
|
|
|
|
+ time.setProcinstId("bustrip_"+UUID.randomUUID().toString().replace("-",""));
|
|
|
|
+ userFvTimeMapper.insert(time);
|
|
|
|
+ }
|
|
|
|
+ startDate = startDate.plusDays(1);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|
|
toUpdateList.clear();
|
|
toUpdateList.clear();
|