|
@@ -0,0 +1,601 @@
|
|
|
+package com.galaxis.manatee.task;
|
|
|
+
|
|
|
+import com.fasterxml.jackson.annotation.JsonProperty;
|
|
|
+import com.fasterxml.jackson.core.JsonProcessingException;
|
|
|
+import com.fasterxml.jackson.core.type.TypeReference;
|
|
|
+import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
|
|
|
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
|
|
|
+import com.galaxis.manatee.constant.ChuanYunConstant;
|
|
|
+import com.galaxis.manatee.dao.*;
|
|
|
+import com.galaxis.manatee.entity.chuanyun.data.object.*;
|
|
|
+import com.galaxis.manatee.entity.chuanyun.dto.ChuanyunFindAllBizDTO;
|
|
|
+import com.galaxis.manatee.entity.chuanyun.dto.ChuanyunSaveDTO;
|
|
|
+import com.galaxis.manatee.entity.chuanyun.dto.Filter;
|
|
|
+import com.galaxis.manatee.exception.BigSizeException;
|
|
|
+import com.galaxis.manatee.manager.ChuanYunManager;
|
|
|
+import com.galaxis.manatee.util.ChuanyunLocalDateTimeDeserializer;
|
|
|
+import com.galaxis.manatee.util.ChuanyunLocalDateTimeSerializer;
|
|
|
+import lombok.Data;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.springframework.beans.BeanUtils;
|
|
|
+import org.springframework.data.domain.PageRequest;
|
|
|
+import org.springframework.scheduling.annotation.Scheduled;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+
|
|
|
+import java.math.BigDecimal;
|
|
|
+import java.math.RoundingMode;
|
|
|
+import java.time.Instant;
|
|
|
+import java.time.LocalDateTime;
|
|
|
+import java.time.format.DateTimeFormatter;
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.List;
|
|
|
+
|
|
|
+/**
|
|
|
+ * @author zcj
|
|
|
+ * @version 0.1
|
|
|
+ * @date 2020/8/9 11:02 下午
|
|
|
+ */
|
|
|
+@Service
|
|
|
+@Slf4j
|
|
|
+public class WorkHourStatistics {
|
|
|
+ private final ObjectMapper objectMapper=new ObjectMapper();
|
|
|
+ private final ChuanYunManager chuanYunManager;
|
|
|
+ private final ChuanyunUserCompanyDao chuanyunUserCompanyDao;
|
|
|
+ private final ChuanyunWorkHourDao chuanyunWorkHourDao;
|
|
|
+ private final ChuanyunSelfWorkHourDao chuanyunSelfWorkHourDao;
|
|
|
+ private final ChuanyunSelfCostDao chuanyunSelfCostDao;
|
|
|
+ private final ChuanyunWeekMemberHourDao chuanyunWeekMemberHourDao;
|
|
|
+
|
|
|
+ public WorkHourStatistics(ChuanYunManager chuanYunManager, ChuanyunUserCompanyDao chuanyunUserCompanyDao, ChuanyunWorkHourDao chuanyunWorkHourDao, ChuanyunSelfWorkHourDao chuanyunSelfWorkHourDao, ChuanyunSelfCostDao chuanyunSelfCostDao, ChuanyunWeekMemberHourDao chuanyunWeekMemberHourDao) {
|
|
|
+ this.chuanYunManager = chuanYunManager;
|
|
|
+ this.chuanyunUserCompanyDao = chuanyunUserCompanyDao;
|
|
|
+ this.chuanyunWorkHourDao = chuanyunWorkHourDao;
|
|
|
+ this.chuanyunSelfWorkHourDao = chuanyunSelfWorkHourDao;
|
|
|
+ this.chuanyunSelfCostDao = chuanyunSelfCostDao;
|
|
|
+ this.chuanyunWeekMemberHourDao = chuanyunWeekMemberHourDao;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 人力成本
|
|
|
+ */
|
|
|
+ @Scheduled(fixedDelay = 3600000L)
|
|
|
+ private void standardWorkHour() {
|
|
|
+ var flag = true;
|
|
|
+ var pageSize = 20;
|
|
|
+ var page = 0;
|
|
|
+ long startTime=Instant.now().getEpochSecond();
|
|
|
+ while(flag) {
|
|
|
+ var pageable= PageRequest.of(page,pageSize);
|
|
|
+ var chuanyunUserCompanyList = chuanyunUserCompanyDao.findAllByStatus(1,pageable);
|
|
|
+ if (page<=chuanyunUserCompanyList.getTotalPages()){
|
|
|
+ page += 1;
|
|
|
+ //逐个将员工每天工时进行统计汇总
|
|
|
+ List<ChuanyunUserCompanyDO> userCompanyDOList = chuanyunUserCompanyList.getContent();
|
|
|
+ userCompanyDOList.forEach(chuanyunUserCompanyDO -> {
|
|
|
+ long start= Instant.now().getEpochSecond();
|
|
|
+ //工时标准化
|
|
|
+ standardHour(chuanyunUserCompanyDO);
|
|
|
+ log.info("每日工时标准化"+chuanyunUserCompanyDO.getUserName()+(Instant.now().getEpochSecond()-start)+"秒");
|
|
|
+ });
|
|
|
+ }else {
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ log.info("每日工时标准化"+(Instant.now().getEpochSecond()-startTime)+"秒");
|
|
|
+ updateChuanyunStandardWorkHour();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 员工单日、各个项目工时标准化,并保存
|
|
|
+ * @param chuanyunUserCompanyDO 员工信息
|
|
|
+ */
|
|
|
+ private void standardHour(ChuanyunUserCompanyDO chuanyunUserCompanyDO) {
|
|
|
+ BigDecimal standard = new BigDecimal(8);
|
|
|
+ //每人每个项目每天工时
|
|
|
+ List<ChuanyunWorkHourDO> selfList = chuanyunWorkHourDao.getSelfWorkHour(chuanyunUserCompanyDO.getUserId());
|
|
|
+ selfList.forEach(self->{
|
|
|
+ try{
|
|
|
+ ChuanyunSelfWorkHourDO chuanyunSelfWorkHourDO = new ChuanyunSelfWorkHourDO();
|
|
|
+ chuanyunSelfWorkHourDO.setStatus(self.getStatus());
|
|
|
+ chuanyunSelfWorkHourDO.setUserId(chuanyunUserCompanyDO.getUserId());
|
|
|
+ chuanyunSelfWorkHourDO.setProjectType(self.getProjectType());
|
|
|
+ if(ChuanYunConstant.PRODUCTION_PROJECT.equals(self.getProjectType())){
|
|
|
+ chuanyunSelfWorkHourDO.setProjectId(ChuanYunConstant.PRODUCTION_PROJECT_ID);
|
|
|
+ }else{
|
|
|
+ chuanyunSelfWorkHourDO.setProjectId(self.getProjectId());
|
|
|
+ }
|
|
|
+ chuanyunSelfWorkHourDO.setDayLogDate(self.getDayLogDate());
|
|
|
+ //每人每天工时
|
|
|
+ ChuanyunWorkHourDO chuanyunWorkHourDO = chuanyunWorkHourDao.getDayWorkHour(chuanyunUserCompanyDO.getUserId(),self.getDayLogDate());
|
|
|
+ //工时标准化
|
|
|
+ if (chuanyunWorkHourDO != null) {
|
|
|
+ if (chuanyunWorkHourDO.getHoursWorked().compareTo(standard)<0) {
|
|
|
+ chuanyunSelfWorkHourDO.setStandardWorkHour(self.getHoursWorked());
|
|
|
+ }else {
|
|
|
+ BigDecimal personDays = (self.getHoursWorked().divide(chuanyunWorkHourDO.getHoursWorked(), 2, RoundingMode.HALF_UP)).multiply(standard);
|
|
|
+ chuanyunSelfWorkHourDO.setStandardWorkHour(personDays);
|
|
|
+ }
|
|
|
+ ChuanyunSelfWorkHourDO chuanyunSelfWorkHourDO1 = chuanyunSelfWorkHourDao.findByUserIdAndAndProjectIdAndAndDayLogDate(chuanyunUserCompanyDO.getUserId(),ChuanYunConstant.PRODUCTION_PROJECT.equals(self.getProjectType())?ChuanYunConstant.PRODUCTION_PROJECT_ID:self.getProjectId(),self.getDayLogDate());
|
|
|
+ if (chuanyunSelfWorkHourDO1!=null) {
|
|
|
+ chuanyunSelfWorkHourDao.delete(chuanyunSelfWorkHourDO1);
|
|
|
+ }
|
|
|
+ chuanyunSelfWorkHourDao.save(chuanyunSelfWorkHourDO);
|
|
|
+ }
|
|
|
+ }catch (Exception e){
|
|
|
+ log.error(e.getMessage());
|
|
|
+ log.error(""+self);
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 人员-项目-周度工时汇总
|
|
|
+ */
|
|
|
+ @Scheduled(fixedDelay = 3600000L)
|
|
|
+ private void standardWeeklyWorkHour() {
|
|
|
+ long start=Instant.now().getEpochSecond();
|
|
|
+ //删除数据库中审批中的数据,防止重复记录工时
|
|
|
+// chuanyunWeekMemberHourDao.deleteAllByStatus("2");
|
|
|
+ //更新数据库
|
|
|
+ log.info("开始周工时标准化");
|
|
|
+ List<ChuanyunWeekMemberHourDO> list = chuanyunWeekMemberHourDao.getWeekMemberHour();
|
|
|
+ list.forEach(chuanyunWeekMemberHourDO -> {
|
|
|
+ if (chuanyunWeekMemberHourDO!=null){
|
|
|
+ ChuanyunWeekMemberHourDO weekMemberHourDO = new ChuanyunWeekMemberHourDO();
|
|
|
+ weekMemberHourDO.setProjectId(chuanyunWeekMemberHourDO.getProjectId());
|
|
|
+ weekMemberHourDO.setProjectType(chuanyunWeekMemberHourDO.getProjectType());
|
|
|
+ weekMemberHourDO.setStandardWorkHour(chuanyunWeekMemberHourDO.getStandardWorkHour());
|
|
|
+ weekMemberHourDO.setStatus(chuanyunWeekMemberHourDO.getStatus());
|
|
|
+ weekMemberHourDO.setUserId(chuanyunWeekMemberHourDO.getUserId());
|
|
|
+ weekMemberHourDO.setYear(chuanyunWeekMemberHourDO.getYear());
|
|
|
+ weekMemberHourDO.setWeek(chuanyunWeekMemberHourDO.getWeek());
|
|
|
+ ChuanyunWeekMemberHourDO oldWeekHour = chuanyunWeekMemberHourDao.findByProjectIdAndUserIdAndWeekAndStatusAndProjectTypeAndYear(chuanyunWeekMemberHourDO.getProjectId(),chuanyunWeekMemberHourDO.getUserId(),chuanyunWeekMemberHourDO.getWeek(),chuanyunWeekMemberHourDO.getStatus(),chuanyunWeekMemberHourDO.getProjectType(),chuanyunWeekMemberHourDO.getYear());
|
|
|
+ if (oldWeekHour != null) {
|
|
|
+ chuanyunWeekMemberHourDao.delete(oldWeekHour);
|
|
|
+ }
|
|
|
+ chuanyunWeekMemberHourDao.save(weekMemberHourDO);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ log.info("周工时标准化"+(Instant.now().getEpochSecond()-start)+"秒");
|
|
|
+ updateChuanyunWeekHour();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 单月工时汇总
|
|
|
+ */
|
|
|
+ @Scheduled(fixedDelay = 3600000L)
|
|
|
+ private void standardMonthlyWorkHour() {
|
|
|
+ var flag = true;
|
|
|
+ var pageSize = 20;
|
|
|
+ var page = 0;
|
|
|
+ while(flag) {
|
|
|
+ var pageable= PageRequest.of(page,pageSize);
|
|
|
+ var chuanyunUserCompanyList = chuanyunUserCompanyDao.findAllByStatus(1,pageable);
|
|
|
+ if (page<=chuanyunUserCompanyList.getTotalPages()){
|
|
|
+ page += 1;
|
|
|
+ List<ChuanyunUserCompanyDO> userCompanyDOList = chuanyunUserCompanyList.getContent();
|
|
|
+ //单项目单人单月成本
|
|
|
+ userCompanyDOList.forEach(this::standardMonthlyHour);
|
|
|
+ }else {
|
|
|
+ flag = false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ updateChuanyunMonthHour();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 员工每月、各个项目标准工时会职工
|
|
|
+ * @param chuanyunUserCompanyDO 员工信息
|
|
|
+ */
|
|
|
+ private void standardMonthlyHour(ChuanyunUserCompanyDO chuanyunUserCompanyDO) {
|
|
|
+ //删除上一次状态为审核中,但本次已经审核通过的数据
|
|
|
+ chuanyunSelfCostDao.findAllByStatusAndUserId(ChuanYunConstant.IN_PROCESS,chuanyunUserCompanyDO.getUserId()).forEach(chuanyunSelfCostDO -> {
|
|
|
+ List<ChuanyunSelfWorkHourDO> chuanyunSelfWorkHourList=chuanyunSelfWorkHourDao.findAllByUserIdAndProjectIdAndStatusAndDayLogDateBetween(
|
|
|
+ chuanyunSelfCostDO.getUserId(),
|
|
|
+ chuanyunSelfCostDO.getProjectId(),
|
|
|
+ ChuanYunConstant.IN_PROCESS,
|
|
|
+ chuanyunSelfCostDO.getDayLogDate(),
|
|
|
+ chuanyunSelfCostDO.getDayLogDate().plusMonths(1L));
|
|
|
+ //如果没有仍在审批中的每日工时,则将该月、该项目的审核中的月工时统计删除,manatee数据库与氚云
|
|
|
+ if(chuanyunSelfWorkHourList.size()==0){
|
|
|
+ //删除manatee中的在审核工时
|
|
|
+ chuanyunSelfCostDao.delete(chuanyunSelfCostDO);
|
|
|
+ //删除氚云中的在审核工时
|
|
|
+ List<String> matchers = new ArrayList<>();
|
|
|
+ matchers.add("F0000003_2,"+chuanyunSelfCostDO.getProjectId());
|
|
|
+ matchers.add("F0000009_2,"+ChuanYunConstant.IN_PROCESS);
|
|
|
+ matchers.add("F0000002_2,"+chuanyunSelfCostDO.getUserId());
|
|
|
+ matchers.add("F0000004_2,"+chuanyunSelfCostDO.getDayLogDate());
|
|
|
+ var filter= Filter.instance(0,1,true,"And",matchers);
|
|
|
+ try {
|
|
|
+ ChuanyunFindAllBizDTO<Object> chuanyunFindAllResponse = chuanYunManager.findAll(ChuanyunMemberMonthCostDO.SCHEMA_CODE,filter);
|
|
|
+ if (chuanyunFindAllResponse.getReturnData()!=null){
|
|
|
+ List<ChuanyunMemberMonthCostDO> result=objectMapper.convertValue(chuanyunFindAllResponse.getReturnData().getBizObjectArray(), new TypeReference<>(){});
|
|
|
+ result.forEach(chuanyunMemberMonthCostDO -> {
|
|
|
+ try{
|
|
|
+ chuanYunManager.delete(ChuanyunMemberMonthCostDO.SCHEMA_CODE,chuanyunMemberMonthCostDO.getObjectId());
|
|
|
+ }catch (Exception e){
|
|
|
+ log.error("逐条删除失败"+e.getMessage());
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ log.error("删除已审核通过的月度数据汇总失败");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ });
|
|
|
+ //每月每项目工时,按月-项目-用户分组统计标准工时
|
|
|
+ List<ChuanyunSelfWorkHourDO> list = chuanyunSelfWorkHourDao.getMonthProjectHour(chuanyunUserCompanyDO.getUserId());
|
|
|
+ DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
|
|
+ list.forEach(projectMonth->{
|
|
|
+ //获取人员-月度-相同工时状态标准工时汇总
|
|
|
+ ChuanyunSelfWorkHourDO monthHour = chuanyunSelfWorkHourDao.getMonthHour(projectMonth.getUserId(),df.format(projectMonth.getDayLogDate()),projectMonth.getStatus());
|
|
|
+
|
|
|
+ ChuanyunSelfCostDO chuanyunSelfCostDO = new ChuanyunSelfCostDO();
|
|
|
+ chuanyunSelfCostDO.setStatus(projectMonth.getStatus());
|
|
|
+ chuanyunSelfCostDO.setMonthlyTotalHour(monthHour.getStandardWorkHour());
|
|
|
+ chuanyunSelfCostDO.setProjectId(projectMonth.getProjectId());
|
|
|
+ chuanyunSelfCostDO.setProjectType(projectMonth.getProjectType());
|
|
|
+ chuanyunSelfCostDO.setUserId(projectMonth.getUserId());
|
|
|
+ chuanyunSelfCostDO.setDayLogDate(projectMonth.getDayLogDate().withDayOfMonth(1));
|
|
|
+ chuanyunSelfCostDO.setTotalHour(projectMonth.getStandardWorkHour());
|
|
|
+ chuanyunSelfCostDO.setDepartmentId(chuanyunUserCompanyDO.getDepartmentId());
|
|
|
+ ChuanyunSelfCostDO oldSelfDO = chuanyunSelfCostDao.getOldSelfDO(chuanyunSelfCostDO.getUserId(),
|
|
|
+ chuanyunSelfCostDO.getProjectId(),
|
|
|
+ df.format(chuanyunSelfCostDO.getDayLogDate()),
|
|
|
+ projectMonth.getStatus());
|
|
|
+ if (oldSelfDO !=null) {
|
|
|
+ chuanyunSelfCostDao.delete(oldSelfDO);
|
|
|
+ }
|
|
|
+ chuanyunSelfCostDao.save(chuanyunSelfCostDO);
|
|
|
+ });
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 定时更新氚云数据
|
|
|
+ */
|
|
|
+ private void updateChuanyunStandardWorkHour(){
|
|
|
+ var flag = true;
|
|
|
+ var pageSize = 20;
|
|
|
+ var page = 0;
|
|
|
+ log.info("开始更新日工时汇总");
|
|
|
+ long startTime=Instant.now().getEpochSecond();
|
|
|
+ while(flag) {
|
|
|
+ var pageable= PageRequest.of(page,pageSize);
|
|
|
+ var updateList=chuanyunSelfWorkHourDao.findAll(pageable);
|
|
|
+ if (page<=updateList.getTotalPages()){
|
|
|
+ page += 1;
|
|
|
+ updateList.forEach(chuanyunSelfWorkHourDO -> {
|
|
|
+ try{
|
|
|
+ String departmentId=chuanyunUserCompanyDao.findAllByUserId(chuanyunSelfWorkHourDO.getUserId()).get(0).getDepartmentId();
|
|
|
+ ChuanyunSelfWorkHourDTO chuanyunSelfWorkHourDTO = new ChuanyunSelfWorkHourDTO();
|
|
|
+ BeanUtils.copyProperties(chuanyunSelfWorkHourDO,chuanyunSelfWorkHourDTO);
|
|
|
+ chuanyunSelfWorkHourDTO.setDepartmentId(departmentId);
|
|
|
+ List<String> matchers = new ArrayList<>();
|
|
|
+ matchers.add("F0000001_2,"+chuanyunSelfWorkHourDO.getProjectId());
|
|
|
+ matchers.add("F0000002_2,"+chuanyunSelfWorkHourDO.getUserId());
|
|
|
+ matchers.add("F0000003_2,"+chuanyunSelfWorkHourDO.getDayLogDate());
|
|
|
+ matchers.add("F0000005_2,"+chuanyunSelfWorkHourDO.getProjectType());
|
|
|
+// matchers.add("F0000006_2,"+self.getStatus());
|
|
|
+ var filter= Filter.instance(0,1,true,"And",matchers);
|
|
|
+ var chuanyunFindAllResponse=chuanYunManager.findAll(ChuanyunMemberHourDO.SCHEMA_CODE,filter);
|
|
|
+ var selfMonthString=objectMapper.writeValueAsString(chuanyunSelfWorkHourDTO);
|
|
|
+ ChuanyunSaveDTO chuanyunSaveDTO;
|
|
|
+ if (chuanyunFindAllResponse.getReturnData()!=null){
|
|
|
+ List<ChuanyunMemberHourDO> result=objectMapper.convertValue(chuanyunFindAllResponse.getReturnData().getBizObjectArray(), new TypeReference<>(){});
|
|
|
+ ChuanyunMemberHourDO firstResult = result.get(0);
|
|
|
+ chuanyunSaveDTO =chuanYunManager.update(ChuanyunMemberHourDO.SCHEMA_CODE,firstResult.getObjectId(),selfMonthString);
|
|
|
+ }else {
|
|
|
+ chuanyunSaveDTO =chuanYunManager.save(ChuanyunMemberHourDO.SCHEMA_CODE,selfMonthString,true);
|
|
|
+ }
|
|
|
+ if(!chuanyunSaveDTO.getSuccessful()){
|
|
|
+ log.warn("新增工时标准化失败");
|
|
|
+ }
|
|
|
+ }catch (Exception e){
|
|
|
+ e.printStackTrace();
|
|
|
+ log.warn("更新标准工时异常");
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }else {
|
|
|
+ //流程执行完
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ log.info("日工时更新花费"+(Instant.now().getEpochSecond()-startTime));
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 人员-项目-周度工时汇总,更新氚云数据
|
|
|
+ */
|
|
|
+ private void updateChuanyunWeekHour(){
|
|
|
+ var flag = true;
|
|
|
+ var pageSize = 20;
|
|
|
+ var page = 0;
|
|
|
+ log.info("开始更新周工时汇总");
|
|
|
+// deleteExamineStatus(ChuanyunProjectMemberWeekHourDO.SCHEMA_CODE,"F0000007");
|
|
|
+ long startTime=Instant.now().getEpochSecond();
|
|
|
+ while(flag) {
|
|
|
+ var pageable = PageRequest.of(page, pageSize);
|
|
|
+ var updateList = chuanyunWeekMemberHourDao.findAll(pageable);
|
|
|
+ if (page<=updateList.getTotalPages()){
|
|
|
+ page += 1;
|
|
|
+ updateList.getContent().forEach(chuanyunWeekMemberHourDO -> {
|
|
|
+ //更新氚云
|
|
|
+ try {
|
|
|
+ String departmentId=chuanyunUserCompanyDao.findAllByUserId(chuanyunWeekMemberHourDO.getUserId()).get(0).getDepartmentId();
|
|
|
+ BigDecimal standard = new BigDecimal(8);
|
|
|
+ ChuanyunProjectMemberWeekHourDTO chuanyunProjectMemberWeekHourDTO = new ChuanyunProjectMemberWeekHourDTO();
|
|
|
+ chuanyunProjectMemberWeekHourDTO.setProjectId(chuanyunWeekMemberHourDO.getProjectId());
|
|
|
+ chuanyunProjectMemberWeekHourDTO.setUserId(chuanyunWeekMemberHourDO.getUserId());
|
|
|
+ chuanyunProjectMemberWeekHourDTO.setWeek(chuanyunWeekMemberHourDO.getWeek());
|
|
|
+ chuanyunProjectMemberWeekHourDTO.setProjectType(chuanyunWeekMemberHourDO.getProjectType());
|
|
|
+ chuanyunProjectMemberWeekHourDTO.setTotalHour(chuanyunWeekMemberHourDO.getStandardWorkHour());
|
|
|
+ chuanyunProjectMemberWeekHourDTO.setPersonDays(chuanyunWeekMemberHourDO.getStandardWorkHour().divide(standard,2,RoundingMode.HALF_UP));
|
|
|
+ chuanyunProjectMemberWeekHourDTO.setHourStatus(chuanyunWeekMemberHourDO.getStatus());
|
|
|
+ chuanyunProjectMemberWeekHourDTO.setYear(chuanyunWeekMemberHourDO.getYear());
|
|
|
+ chuanyunProjectMemberWeekHourDTO.setDepartmentId(departmentId);
|
|
|
+
|
|
|
+ List<String> matchers = new ArrayList<>();
|
|
|
+ matchers.add("F0000001_2,"+chuanyunWeekMemberHourDO.getProjectId());
|
|
|
+ matchers.add("F0000002_2,"+chuanyunWeekMemberHourDO.getUserId());
|
|
|
+ matchers.add("F0000006_2,"+chuanyunWeekMemberHourDO.getWeek());
|
|
|
+ matchers.add("F0000008_2,"+chuanyunWeekMemberHourDO.getYear());
|
|
|
+ matchers.add("F0000003_2,"+chuanyunWeekMemberHourDO.getProjectType());
|
|
|
+ matchers.add("F0000007_2,"+chuanyunWeekMemberHourDO.getStatus());
|
|
|
+ var filter= Filter.instance(0,1,true,"And",matchers);
|
|
|
+ var chuanyunFindAllResponse=chuanYunManager.findAll(ChuanyunProjectMemberWeekHourDO.SCHEMA_CODE,filter);
|
|
|
+ var selfMonthString=objectMapper.writeValueAsString(chuanyunProjectMemberWeekHourDTO);
|
|
|
+ ChuanyunSaveDTO chuanyunSaveDTO;
|
|
|
+ if (chuanyunFindAllResponse.getReturnData()!=null) {
|
|
|
+ List<ChuanyunProjectMemberWeekHourDO> result=objectMapper.convertValue(chuanyunFindAllResponse.getReturnData().getBizObjectArray(), new TypeReference<>(){});
|
|
|
+ ChuanyunProjectMemberWeekHourDO firstResult = result.get(0);
|
|
|
+ chuanyunSaveDTO = chuanYunManager.update(ChuanyunProjectMemberWeekHourDO.SCHEMA_CODE,firstResult.getObjectId(),selfMonthString);
|
|
|
+ }else {
|
|
|
+ chuanyunSaveDTO = chuanYunManager.save(ChuanyunProjectMemberWeekHourDO.SCHEMA_CODE,selfMonthString,true);
|
|
|
+ }
|
|
|
+ if(!chuanyunSaveDTO.getSuccessful()){
|
|
|
+ log.warn("新增人员项目周度工时失败");
|
|
|
+ }
|
|
|
+ } catch (JsonProcessingException | BigSizeException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }else {
|
|
|
+ //流程执行完
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ log.info("周工时更新花费"+(Instant.now().getEpochSecond()-startTime));
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 人员-项目-月度工时汇总,更新氚云数据
|
|
|
+ */
|
|
|
+ private void updateChuanyunMonthHour(){
|
|
|
+ var flag = true;
|
|
|
+ var pageSize = 20;
|
|
|
+ var page = 0;
|
|
|
+ log.info("开始更新月工时汇总");
|
|
|
+ //删除氚云表单审核中数据
|
|
|
+// deleteExamineStatus(ChuanyunMemberMonthCostDO.SCHEMA_CODE,"F0000009");
|
|
|
+ long startTime=Instant.now().getEpochSecond();
|
|
|
+ while(flag) {
|
|
|
+ var pageable = PageRequest.of(page, pageSize);
|
|
|
+ var updateList = chuanyunSelfCostDao.findAll(pageable);
|
|
|
+ if (page<=updateList.getTotalPages()){
|
|
|
+ page += 1;
|
|
|
+ updateList.getContent().forEach(chuanyunSelfCostDO -> {
|
|
|
+ ChuanyunMemberMonthCostDTO chuanyunMemberMonthCostDTO = new ChuanyunMemberMonthCostDTO();
|
|
|
+
|
|
|
+ //更新氚云数据
|
|
|
+ chuanyunMemberMonthCostDTO.setCost(chuanyunSelfCostDO.getCost());
|
|
|
+ chuanyunMemberMonthCostDTO.setProjectId(chuanyunSelfCostDO.getProjectId());
|
|
|
+ chuanyunMemberMonthCostDTO.setProjectType(chuanyunSelfCostDO.getProjectType());
|
|
|
+ chuanyunMemberMonthCostDTO.setStatus(chuanyunSelfCostDO.getStatus());
|
|
|
+ chuanyunMemberMonthCostDTO.setUserId(chuanyunSelfCostDO.getUserId());
|
|
|
+ chuanyunMemberMonthCostDTO.setMonthWorkHour(chuanyunSelfCostDO.getMonthlyTotalHour());
|
|
|
+ chuanyunMemberMonthCostDTO.setDayLogDate(chuanyunSelfCostDO.getDayLogDate());
|
|
|
+ chuanyunMemberMonthCostDTO.setWorkHour(chuanyunSelfCostDO.getTotalHour());
|
|
|
+ chuanyunMemberMonthCostDTO.setDepartmentId(chuanyunSelfCostDO.getDepartmentId());
|
|
|
+ try {
|
|
|
+ List<String> matchers = new ArrayList<>();
|
|
|
+ matchers.add("F0000003_2,"+chuanyunSelfCostDO.getProjectId());
|
|
|
+ matchers.add("F0000009_2,"+chuanyunSelfCostDO.getStatus());
|
|
|
+ matchers.add("F0000002_2,"+chuanyunSelfCostDO.getUserId());
|
|
|
+ matchers.add("F0000004_2,"+chuanyunSelfCostDO.getDayLogDate());
|
|
|
+ var filter= Filter.instance(0,1,true,"And",matchers);
|
|
|
+ var chuanyunFindAllResponse=chuanYunManager.findAll(ChuanyunMemberMonthCostDO.SCHEMA_CODE,filter);
|
|
|
+ var memberMonthString=objectMapper.writeValueAsString(chuanyunMemberMonthCostDTO);
|
|
|
+ ChuanyunSaveDTO chuanyunSaveDTO;
|
|
|
+ if (chuanyunFindAllResponse.getReturnData()!=null){
|
|
|
+ List<ChuanyunMemberMonthCostDO> result=objectMapper.convertValue(chuanyunFindAllResponse.getReturnData().getBizObjectArray(), new TypeReference<>(){});
|
|
|
+ ChuanyunMemberMonthCostDO firstResult = result.get(0);
|
|
|
+ chuanyunSaveDTO =chuanYunManager.update(ChuanyunMemberMonthCostDO.SCHEMA_CODE,firstResult.getObjectId(),memberMonthString);
|
|
|
+ }else {
|
|
|
+ chuanyunSaveDTO =chuanYunManager.save(ChuanyunMemberMonthCostDO.SCHEMA_CODE,memberMonthString,true);
|
|
|
+ }
|
|
|
+ if(!chuanyunSaveDTO.getSuccessful()){
|
|
|
+ log.warn("新增项目成员月度成本汇总失败");
|
|
|
+ }
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ log.warn("########"+chuanyunSelfCostDO+"");
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }else {
|
|
|
+ //流程执行完
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ log.info("月工时更新花费"+(Instant.now().getEpochSecond()-startTime));
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 删除状态为审核中数据
|
|
|
+ * @param schemaCode
|
|
|
+ * @param buttonCode
|
|
|
+ */
|
|
|
+ public void deleteExamineStatus(String schemaCode,String buttonCode) {
|
|
|
+ try {
|
|
|
+ List<String> matchers = new ArrayList<>();
|
|
|
+ matchers.add(buttonCode+"_2,"+"2");
|
|
|
+ var filter= Filter.instance(0,Integer.MAX_VALUE,true,"And",matchers);
|
|
|
+ var chuanyunFindAllResponse=chuanYunManager.findAll(schemaCode,filter);
|
|
|
+ if (chuanyunFindAllResponse.getReturnData()!=null){
|
|
|
+ List<ChuanyunCommonDO> result=objectMapper.convertValue(chuanyunFindAllResponse.getReturnData().getBizObjectArray(), new TypeReference<>(){});
|
|
|
+ result.forEach(basicDO -> {
|
|
|
+ ChuanyunSaveDTO chuanyunSaveDTO = chuanYunManager.delete(schemaCode,basicDO.getObjectId());
|
|
|
+ if(chuanyunSaveDTO.getSuccessful()){
|
|
|
+ log.info("删除状态为审核中数据成功");
|
|
|
+ }else{
|
|
|
+ log.warn("删除状态为审核中数据失败");
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
+ }catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ log.error(e.getMessage());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 人员项目周度工时
|
|
|
+ */
|
|
|
+ @Data
|
|
|
+ static
|
|
|
+ class ChuanyunProjectMemberWeekHourDTO{
|
|
|
+
|
|
|
+ @JsonProperty("F0000001")
|
|
|
+ private String projectId;
|
|
|
+
|
|
|
+ @JsonProperty("F0000002")
|
|
|
+ private String userId;
|
|
|
+
|
|
|
+ @JsonProperty("F0000003")
|
|
|
+ private String projectType;
|
|
|
+
|
|
|
+ @JsonProperty("F0000004")
|
|
|
+ private BigDecimal totalHour;
|
|
|
+
|
|
|
+ @JsonProperty("F0000005")
|
|
|
+ private BigDecimal personDays;
|
|
|
+
|
|
|
+ @JsonProperty("F0000008")
|
|
|
+ private String year;
|
|
|
+
|
|
|
+ @JsonProperty("F0000006")
|
|
|
+ private String week;
|
|
|
+
|
|
|
+ @JsonProperty("F0000007")
|
|
|
+ private String hourStatus;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 部门信息
|
|
|
+ */
|
|
|
+ @JsonProperty("F0000009")
|
|
|
+ private String departmentId;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 工时标准化更新数据
|
|
|
+ */
|
|
|
+ @Data
|
|
|
+ static
|
|
|
+ class ChuanyunSelfWorkHourDTO {
|
|
|
+
|
|
|
+ @JsonProperty("F0000002")
|
|
|
+ private String userId;
|
|
|
+
|
|
|
+ @JsonProperty("F0000001")
|
|
|
+ private String projectId;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 项目类型
|
|
|
+ */
|
|
|
+ @JsonProperty("F0000005")
|
|
|
+ private String projectType;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 流程状态
|
|
|
+ */
|
|
|
+ @JsonProperty("F0000006")
|
|
|
+ private String status;
|
|
|
+
|
|
|
+ @JsonProperty("F0000003")
|
|
|
+ @JsonSerialize(using = ChuanyunLocalDateTimeSerializer.class)
|
|
|
+ @JsonDeserialize(using = ChuanyunLocalDateTimeDeserializer.class)
|
|
|
+ private LocalDateTime dayLogDate;
|
|
|
+
|
|
|
+ @JsonProperty("F0000004")
|
|
|
+ private BigDecimal standardWorkHour;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 部门Id
|
|
|
+ */
|
|
|
+ @JsonProperty("F0000007")
|
|
|
+ private String departmentId;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Data
|
|
|
+ static
|
|
|
+ class ChuanyunMemberMonthCostDTO{
|
|
|
+ /**
|
|
|
+ * 项目ID
|
|
|
+ */
|
|
|
+ @JsonProperty("F0000003")
|
|
|
+ private String projectId;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 项目类型
|
|
|
+ */
|
|
|
+ @JsonProperty("F0000008")
|
|
|
+ private String projectType;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 日志流程状态
|
|
|
+ */
|
|
|
+ @JsonProperty("F0000009")
|
|
|
+ private String status;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 用户ID
|
|
|
+ */
|
|
|
+ @JsonProperty("F0000002")
|
|
|
+ private String userId;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 日期
|
|
|
+ */
|
|
|
+ @JsonProperty("F0000004")
|
|
|
+ @JsonSerialize(using = ChuanyunLocalDateTimeSerializer.class)
|
|
|
+ @JsonDeserialize(using = ChuanyunLocalDateTimeDeserializer.class)
|
|
|
+ private LocalDateTime dayLogDate;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 工时
|
|
|
+ */
|
|
|
+ @JsonProperty("F0000005")
|
|
|
+ private BigDecimal workHour;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 成本
|
|
|
+ */
|
|
|
+ @JsonProperty("F0000006")
|
|
|
+ private BigDecimal cost;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 月度工时汇总
|
|
|
+ */
|
|
|
+ @JsonProperty("F0000007")
|
|
|
+ private BigDecimal monthWorkHour;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 部门Id
|
|
|
+ */
|
|
|
+ @JsonProperty("F0000010")
|
|
|
+ private String departmentId;
|
|
|
+ }
|
|
|
+}
|