|
@@ -6,9 +6,9 @@ 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.manager.ChuanYunManager;
|
|
|
+import com.galaxis.manatee.service.DataArcherService;
|
|
|
import com.galaxis.manatee.service.LogStandardService;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.data.domain.PageRequest;
|
|
@@ -39,8 +39,9 @@ public class WorkHourStatisticsRecently {
|
|
|
private final ChuanyunSelfCostDao chuanyunSelfCostDao;
|
|
|
private final ChuanyunUserDepartmentNameDao chuanyunUserDepartmentNameDao;
|
|
|
private final LogStandardService logStandardService;
|
|
|
+ private final DataArcherService dataArcherService;
|
|
|
|
|
|
- public WorkHourStatisticsRecently(ChuanYunManager chuanYunManager, ChuanyunLogDao chuanyunLogDao, ChuanyunGroupProjectDao chuanyunGroupProjectDao, ChuanyunUserCompanyDao chuanyunUserCompanyDao, ChuanyunSelfWorkHourDao chuanyunSelfWorkHourDao, ChuanyunWeekMemberHourDao chuanyunWeekMemberHourDao, ChuanyunSelfCostDao chuanyunSelfCostDao, ChuanyunUserDepartmentNameDao chuanyunUserDepartmentNameDao, LogStandardService logStandardService) {
|
|
|
+ public WorkHourStatisticsRecently(DataArcherService dataArcherService,ChuanYunManager chuanYunManager, ChuanyunLogDao chuanyunLogDao, ChuanyunGroupProjectDao chuanyunGroupProjectDao, ChuanyunUserCompanyDao chuanyunUserCompanyDao, ChuanyunSelfWorkHourDao chuanyunSelfWorkHourDao, ChuanyunWeekMemberHourDao chuanyunWeekMemberHourDao, ChuanyunSelfCostDao chuanyunSelfCostDao, ChuanyunUserDepartmentNameDao chuanyunUserDepartmentNameDao, LogStandardService logStandardService) {
|
|
|
this.chuanYunManager = chuanYunManager;
|
|
|
this.chuanyunLogDao = chuanyunLogDao;
|
|
|
this.chuanyunGroupProjectDao = chuanyunGroupProjectDao;
|
|
@@ -50,6 +51,7 @@ public class WorkHourStatisticsRecently {
|
|
|
this.chuanyunSelfCostDao = chuanyunSelfCostDao;
|
|
|
this.chuanyunUserDepartmentNameDao = chuanyunUserDepartmentNameDao;
|
|
|
this.logStandardService = logStandardService;
|
|
|
+ this.dataArcherService=dataArcherService;
|
|
|
}
|
|
|
|
|
|
@Scheduled(fixedDelay = 3600000L)
|
|
@@ -202,7 +204,7 @@ public class WorkHourStatisticsRecently {
|
|
|
if (processWeekHour == null){
|
|
|
chuanyunWeekMemberHourDao.deleteByProjectIdAndUserIdAndYearAndWeekAndStatusAndProjectType(chuanyunWeekMemberHourDO.getProjectId(),chuanyunWeekMemberHourDO.getUserId(),chuanyunWeekMemberHourDO.getYear(),chuanyunWeekMemberHourDO.getWeek(),"2",chuanyunWeekMemberHourDO.getProjectType());
|
|
|
//同时删除氚云钟数据
|
|
|
- deleteExamineStatus(ChuanyunProjectMemberWeekHourDO.SCHEMA_CODE,"F0000007","F0000001",chuanyunWeekMemberHourDO.getProjectId(),"F0000002",chuanyunWeekMemberHourDO.getUserId(),"F0000008",chuanyunWeekMemberHourDO.getYear(),"","","F0000006",chuanyunWeekMemberHourDO.getWeek(),"F0000003",chuanyunWeekMemberHourDO.getProjectType());
|
|
|
+ dataArcherService.deleteExamineStatus(ChuanyunProjectMemberWeekHourDO.SCHEMA_CODE,"F0000007","F0000001",chuanyunWeekMemberHourDO.getProjectId(),"F0000002",chuanyunWeekMemberHourDO.getUserId(),"F0000008",chuanyunWeekMemberHourDO.getYear(),"","","F0000006",chuanyunWeekMemberHourDO.getWeek(),"F0000003",chuanyunWeekMemberHourDO.getProjectType());
|
|
|
}
|
|
|
}
|
|
|
}catch (Exception e){
|
|
@@ -307,45 +309,6 @@ public class WorkHourStatisticsRecently {
|
|
|
});
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 删除状态为审核中数据
|
|
|
- */
|
|
|
- public void deleteExamineStatus(String schemaCode,String statusCode,String projectCode,String projectId,String userCode,String userId,String yearCode,String year,String monthCode,String month,String weekCode,String week,String typeCode,String projectType) {
|
|
|
- try {
|
|
|
- List<String> matchers = new ArrayList<>();
|
|
|
- matchers.add(statusCode+"_2,"+"2");
|
|
|
- matchers.add(projectCode+"_2,"+projectId);
|
|
|
- if (!StringUtils.isEmpty(userId)){
|
|
|
- matchers.add(userCode+"_2,"+userId);
|
|
|
- }
|
|
|
- if (!StringUtils.isEmpty(year)){
|
|
|
- matchers.add(yearCode+"_2,"+year);
|
|
|
- }
|
|
|
- if (!StringUtils.isEmpty(month)){
|
|
|
- matchers.add(monthCode+"_2,"+month);
|
|
|
- }
|
|
|
- if (!StringUtils.isEmpty(week)){
|
|
|
- matchers.add(weekCode+"_2,"+week);
|
|
|
- }
|
|
|
- if (!StringUtils.isEmpty(projectType)){
|
|
|
- matchers.add(typeCode+"_2,"+projectType);
|
|
|
- }
|
|
|
- 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.warn("删除状态为审核中数据失败");
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
- }catch (Exception e) {
|
|
|
- e.printStackTrace();
|
|
|
- log.error(e.getMessage());
|
|
|
- }
|
|
|
- }
|
|
|
|
|
|
private String getCharacters(String str){
|
|
|
String reg = "[^\u4e00-\u9fa5]";
|