package com.java110.job.task.oa;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.core.factory.GenerateCodeFactory;
|
import com.java110.dto.classes.ScheduleClassesStaffDto;
|
import com.java110.dto.community.CommunityDto;
|
import com.java110.dto.task.TaskDto;
|
import com.java110.dto.work.*;
|
import com.java110.intf.oa.*;
|
import com.java110.intf.store.IScheduleClassesStaffV1InnerServiceSMO;
|
import com.java110.job.quartz.TaskSystemQuartz;
|
import com.java110.po.workPool.WorkCopyPo;
|
import com.java110.po.workPool.WorkPoolFilePo;
|
import com.java110.po.workPool.WorkTaskItemPo;
|
import com.java110.po.workPool.WorkTaskPo;
|
import com.java110.utils.exception.CmdException;
|
import com.java110.utils.util.DateUtil;
|
import com.java110.utils.util.ListUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Arrays;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
|
@Component
|
public class CycleWorkTaskGeneratorTemplate extends TaskSystemQuartz {
|
|
@Autowired
|
private IWorkCycleV1InnerServiceSMO workCycleV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IScheduleClassesStaffV1InnerServiceSMO scheduleClassesStaffV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IWorkTaskV1InnerServiceSMO workTaskV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IWorkPoolV1InnerServiceSMO workPoolV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IWorkPoolFileV1InnerServiceSMO workPoolFileV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IWorkPoolContentV1InnerServiceSMO workPoolContentV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IWorkTaskItemV1InnerServiceSMO workTaskItemV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IWorkCopyV1InnerServiceSMO workCopyV1InnerServiceSMOImpl;
|
|
@Override
|
protected void process(TaskDto taskDto) throws Exception {
|
logger.debug("开始执行周期性工作单任务生成" + taskDto.toString());
|
|
// 获取小区
|
List<CommunityDto> communityDtos = getAllCommunity();
|
|
for (CommunityDto communityDto : communityDtos) {
|
try {
|
generatorTask(taskDto, communityDto);
|
} catch (Exception e) {
|
logger.error("推送消息失败", e);
|
}
|
}
|
}
|
|
private void generatorTask(TaskDto taskDto, CommunityDto communityDto) {
|
|
WorkCycleDto workCycleDto = new WorkCycleDto();
|
workCycleDto.setCommunityId(communityDto.getCommunityId());
|
workCycleDto.setWorkCycle(WorkPoolDto.WORK_CYCLE_CYCLE);
|
workCycleDto.setCurTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
|
List<WorkCycleDto> workCycleDtos = workCycleV1InnerServiceSMOImpl.queryWorkCycles(workCycleDto);
|
|
if(workCycleDtos == null){
|
return ;
|
}
|
|
for(WorkCycleDto tmpWorkCycleDto : workCycleDtos){
|
|
try{
|
doGeneratorTask(tmpWorkCycleDto,taskDto,communityDto);
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
}
|
|
private void doGeneratorTask(WorkCycleDto tmpWorkCycleDto,TaskDto taskDto, CommunityDto communityDto) {
|
|
WorkPoolDto workPoolDto = new WorkPoolDto();
|
workPoolDto.setWorkId(tmpWorkCycleDto.getWorkId());
|
List<WorkPoolDto> workPoolDtos = workPoolV1InnerServiceSMOImpl.queryWorkPools(workPoolDto);
|
|
if(ListUtil.isNull(workPoolDtos)){
|
return;
|
}
|
|
Date startTime = DateUtil.getDateFromStringA(workPoolDtos.get(0).getStartTime());
|
Calendar startTimeCal = Calendar.getInstance();
|
startTimeCal.setTime(startTime);
|
|
Calendar nowCal = Calendar.getInstance();
|
nowCal.set(Calendar.HOUR_OF_DAY,startTimeCal.get(Calendar.HOUR_OF_DAY));
|
nowCal.set(Calendar.MINUTE,startTimeCal.get(Calendar.MINUTE));
|
nowCal.set(Calendar.SECOND,startTimeCal.get(Calendar.SECOND));
|
|
Date nowTime = nowCal.getTime();
|
|
boolean hasCondition = false;
|
switch (tmpWorkCycleDto.getPeriod()) {
|
case WorkCycleDto.PERIOD_MONTH_DAY:
|
hasCondition = hasGeneratorTaskConditionByDay(tmpWorkCycleDto, taskDto, communityDto,nowTime);
|
break;
|
case WorkCycleDto.PERIOD_MONTH_WORKDAY:
|
hasCondition = hasGeneratorTaskConditionByWeek(tmpWorkCycleDto, taskDto, communityDto,nowTime);
|
break;
|
}
|
if (!hasCondition) {
|
return;
|
}
|
|
|
|
|
WorkTaskPo workTaskPo = new WorkTaskPo();
|
workTaskPo.setWorkId(tmpWorkCycleDto.getWorkId());
|
workTaskPo.setState(WorkTaskDto.STATE_WAIT);
|
workTaskPo.setTaskId(GenerateCodeFactory.getGeneratorId("11"));
|
workTaskPo.setStoreId(tmpWorkCycleDto.getStoreId());
|
workTaskPo.setCommunityId(tmpWorkCycleDto.getCommunityId());
|
workTaskPo.setStartTime(DateUtil.getFormatTimeStringA(nowTime));
|
workTaskPo.setEndTime(DateUtil.getAddHoursStringA(nowTime,Integer.parseInt(tmpWorkCycleDto.getHours())));
|
workTaskPo.setStaffId(tmpWorkCycleDto.getStaffId());
|
workTaskPo.setStaffName(tmpWorkCycleDto.getStaffName());
|
workTaskPo.setOrgStaffId(tmpWorkCycleDto.getStaffId());
|
workTaskPo.setOrgStaffName(tmpWorkCycleDto.getStaffName());
|
|
int flag = workTaskV1InnerServiceSMOImpl.saveWorkTask(workTaskPo);
|
|
if (flag < 1) {
|
throw new CmdException("保存数据失败");
|
}
|
|
WorkPoolContentDto workPoolContentDto = new WorkPoolContentDto();
|
workPoolContentDto.setWorkId(tmpWorkCycleDto.getWorkId());
|
List<WorkPoolContentDto> workPoolContentDtos
|
= workPoolContentV1InnerServiceSMOImpl.queryWorkPoolContents(workPoolContentDto);
|
|
for (WorkPoolContentDto tWorkPoolContentDto:workPoolContentDtos) {
|
WorkTaskItemPo workTaskItemPo = new WorkTaskItemPo();
|
workTaskItemPo.setDeductionMoney("0");
|
workTaskItemPo.setContentId(tWorkPoolContentDto.getContentId());
|
workTaskItemPo.setStoreId(tWorkPoolContentDto.getStoreId());
|
workTaskItemPo.setWorkId(tWorkPoolContentDto.getWorkId());
|
workTaskItemPo.setItemId(GenerateCodeFactory.getGeneratorId("11"));
|
workTaskItemPo.setState(WorkTaskDto.STATE_WAIT);
|
workTaskItemPo.setCommunityId(tWorkPoolContentDto.getCommunityId());
|
workTaskItemPo.setTaskId(workTaskPo.getTaskId());
|
workTaskItemV1InnerServiceSMOImpl.saveWorkTaskItem(workTaskItemPo);
|
}
|
|
// 将抄送状态修改为待处理
|
WorkCopyDto workCopyDto = new WorkCopyDto();
|
workCopyDto.setWorkId(tmpWorkCycleDto.getWorkId());
|
List<WorkCopyDto> workCopyDtos = workCopyV1InnerServiceSMOImpl.queryWorkCopys(workCopyDto);
|
|
if(!ListUtil.isNull(workCopyDtos)){
|
WorkCopyPo workCopyPo = new WorkCopyPo();
|
workCopyPo.setCopyId(workCopyDtos.get(0).getCopyId());
|
workCopyPo.setState(WorkCopyDto.STATE_DOING);
|
workCopyPo.setRemark("待处理");
|
workCopyV1InnerServiceSMOImpl.updateWorkCopy(workCopyPo);
|
}
|
|
|
WorkPoolFileDto workPoolFileDto = new WorkPoolFileDto();
|
workPoolFileDto.setWorkId(tmpWorkCycleDto.getWorkId());
|
workPoolFileDto.setFileType(WorkPoolFileDto.FILE_TYPE_START);
|
List<WorkPoolFileDto> workPoolFileDtos = workPoolFileV1InnerServiceSMOImpl.queryWorkPoolFiles(workPoolFileDto);
|
|
if(ListUtil.isNull(workPoolFileDtos)){
|
return;
|
}
|
WorkPoolFilePo workPoolFilePo = null;
|
for(WorkPoolFileDto tmpWorkPoolFileDto : workPoolFileDtos){
|
workPoolFilePo = new WorkPoolFilePo();
|
workPoolFilePo.setCommunityId(workTaskPo.getCommunityId());
|
workPoolFilePo.setFileType(WorkPoolFileDto.FILE_TYPE_START);
|
workPoolFilePo.setFileId(GenerateCodeFactory.getGeneratorId("11"));
|
workPoolFilePo.setWorkId(workTaskPo.getWorkId());
|
workPoolFilePo.setTaskId(workTaskPo.getTaskId());
|
workPoolFilePo.setPathUrl(tmpWorkPoolFileDto.getPathUrl());
|
workPoolFilePo.setStoreId(workTaskPo.getStoreId());
|
workPoolFileV1InnerServiceSMOImpl.saveWorkPoolFile(workPoolFilePo);
|
}
|
|
|
|
|
|
}
|
|
private boolean hasGeneratorTaskConditionByWeek(WorkCycleDto tmpWorkCycleDto, TaskDto taskDto, CommunityDto communityDto,Date nowTime) {
|
|
// 检查 今日是否 需要 生成巡检任务
|
// 检查 今日是否 需要 生成巡检任务
|
String[] workday = tmpWorkCycleDto.getPeriodWorkday().split(",");
|
|
Calendar today = Calendar.getInstance();
|
int day = today.get(Calendar.DAY_OF_WEEK);
|
|
//一周第一天是否为星期天
|
boolean isFirstSunday = (today.getFirstDayOfWeek() == Calendar.SUNDAY);
|
//获取周几
|
//若一周第一天为星期天，则-1
|
if (isFirstSunday) {
|
day = day - 1;
|
if (day == 0) {
|
day = 7;
|
}
|
}
|
if(!Arrays.asList(workday).contains(day+"")){
|
return false;
|
}
|
|
//当前时间是否 到了 巡检任务前30分钟
|
int beforeTime = Integer.parseInt(tmpWorkCycleDto.getBeforeTime());
|
|
String planTime = DateUtil.getFormatTimeStringA(nowTime);
|
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(DateUtil.getDateFromStringA(planTime));
|
calendar.add(Calendar.MINUTE,beforeTime*(-1));
|
if(DateUtil.getCurrentDate().before(calendar.getTime())){ // 还没到生成任务时间
|
return false;
|
}
|
|
|
ScheduleClassesStaffDto scheduleClassesStaffDto = new ScheduleClassesStaffDto();
|
scheduleClassesStaffDto.setStaffId(tmpWorkCycleDto.getStaffId());
|
scheduleClassesStaffDto.setToday(DateUtil.getDateFromStringA(planTime));
|
scheduleClassesStaffDto = scheduleClassesStaffV1InnerServiceSMOImpl.staffIsWork(scheduleClassesStaffDto);
|
|
if(!scheduleClassesStaffDto.isWork()){//根据排班员工 休息
|
return false;
|
|
}
|
|
WorkTaskDto workTaskDto = new WorkTaskDto();
|
workTaskDto.setCommunityId(tmpWorkCycleDto.getCommunityId());
|
workTaskDto.setWorkId(tmpWorkCycleDto.getWorkId());
|
workTaskDto.setTaskInsTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B));
|
workTaskDto.setOrgStaffId(tmpWorkCycleDto.getStaffId());
|
|
//目前逻辑修改 一个巡检 计划 对于一个员工只能生成一次巡检任务，所以 传 员工 巡检计划ID 时间即可
|
List<WorkTaskDto> workTasksDtos = workTaskV1InnerServiceSMOImpl.queryWorkTasks(workTaskDto);
|
if (workTasksDtos != null && !workTasksDtos.isEmpty()) { // 已经生成过
|
return false;
|
}
|
|
return true;
|
|
}
|
|
private boolean hasGeneratorTaskConditionByDay(WorkCycleDto tmpWorkCycleDto, TaskDto taskDto, CommunityDto communityDto,Date nowTime) {
|
|
// 检查 今日是否 需要 生成巡检任务
|
String[] months = tmpWorkCycleDto.getPeriodMonth().split(",");
|
|
Calendar today = Calendar.getInstance();
|
int month = today.get(Calendar.MONTH) + 1;
|
if (!Arrays.asList(months).contains(month + "")) {
|
return false;
|
}
|
String[] days = tmpWorkCycleDto.getPeriodDay().split(",");
|
int day = today.get(Calendar.DAY_OF_MONTH);
|
if (!Arrays.asList(days).contains(day + "")) {
|
return false;
|
}
|
|
//当前时间是否 到了 巡检任务前30分钟
|
|
int beforeTime = Integer.parseInt(tmpWorkCycleDto.getBeforeTime());
|
|
String planTime = DateUtil.getFormatTimeStringA(nowTime);
|
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(DateUtil.getDateFromStringA(planTime));
|
calendar.add(Calendar.MINUTE, beforeTime * (-1));
|
if (DateUtil.getCurrentDate().before(calendar.getTime())) { // 还没到生成任务时间
|
return false;
|
}
|
|
// 判断 员工是否上班
|
|
ScheduleClassesStaffDto scheduleClassesStaffDto = new ScheduleClassesStaffDto();
|
scheduleClassesStaffDto.setStaffId(tmpWorkCycleDto.getStaffId());
|
scheduleClassesStaffDto.setToday(DateUtil.getDateFromStringA(planTime));
|
scheduleClassesStaffDto = scheduleClassesStaffV1InnerServiceSMOImpl.staffIsWork(scheduleClassesStaffDto);
|
|
if (!scheduleClassesStaffDto.isWork()) {//根据排班员工 休息
|
return false;
|
|
}
|
|
WorkTaskDto workTaskDto = new WorkTaskDto();
|
workTaskDto.setCommunityId(tmpWorkCycleDto.getCommunityId());
|
workTaskDto.setWorkId(tmpWorkCycleDto.getWorkId());
|
workTaskDto.setTaskInsTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B));
|
workTaskDto.setOrgStaffId(tmpWorkCycleDto.getStaffId());
|
|
//目前逻辑修改 一个巡检 计划 对于一个员工只能生成一次巡检任务，所以 传 员工 巡检计划ID 时间即可
|
List<WorkTaskDto> workTasksDtos = workTaskV1InnerServiceSMOImpl.queryWorkTasks(workTaskDto);
|
if (workTasksDtos != null && !workTasksDtos.isEmpty()) { // 已经生成过
|
return false;
|
}
|
|
return true;
|
}
|
}
|
