|
@@ -7672,19 +7672,19 @@ public class ReportServiceImpl extends ServiceImpl<ReportMapper, Report> impleme
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public HttpRespMsg pushProjectReportToSap(String pushDate) {
|
|
|
|
|
|
+ public HttpRespMsg pushProjectReportToSap(String pushDate,Integer reportId) {
|
|
HttpRespMsg httpRespMsg =new HttpRespMsg();
|
|
HttpRespMsg httpRespMsg =new HttpRespMsg();
|
|
LocalDateTime localDateTime=LocalDateTime.now();
|
|
LocalDateTime localDateTime=LocalDateTime.now();
|
|
User user = userMapper.selectById(request.getHeader("token"));
|
|
User user = userMapper.selectById(request.getHeader("token"));
|
|
Integer companyId = user.getCompanyId();
|
|
Integer companyId = user.getCompanyId();
|
|
- List<Map<String,Object>> resultList=reportMapper.getPushProjectReportToSap(companyId,pushDate,pushDate,null);
|
|
|
|
|
|
+ List<Map<String,Object>> resultList=reportMapper.getPushProjectReportToSap(companyId,pushDate,pushDate,null,reportId);
|
|
//过滤服务code为空的数据
|
|
//过滤服务code为空的数据
|
|
resultList=resultList.stream().filter(r->r.get("ProjectElementID")!=null && !StringUtils.isEmpty(String.valueOf(r.get("ProjectElementID")))).collect(Collectors.toList());
|
|
resultList=resultList.stream().filter(r->r.get("ProjectElementID")!=null && !StringUtils.isEmpty(String.valueOf(r.get("ProjectElementID")))).collect(Collectors.toList());
|
|
- List<Integer> projectIds = resultList.stream().map(r -> Integer.valueOf(String.valueOf(r.get("ProjectId")))).distinct().collect(Collectors.toList());
|
|
|
|
- projectIds.add(-1);
|
|
|
|
|
|
+ List<Integer> taskIds = resultList.stream().map(r -> Integer.valueOf(String.valueOf(r.get("TaskId")))).distinct().collect(Collectors.toList());
|
|
|
|
+ taskIds.add(-1);
|
|
//提前推送项目工时(工时管家相关项目任务分组阶段下任务作为SAP服务 预算工时数据推送到SAP)
|
|
//提前推送项目工时(工时管家相关项目任务分组阶段下任务作为SAP服务 预算工时数据推送到SAP)
|
|
//只推送需要推送日报参与的部分就可以了
|
|
//只推送需要推送日报参与的部分就可以了
|
|
- List<Map<String, Object>> pushProjectPlanHour = reportMapper.getProjectPlanData(companyId,projectIds,null,null);
|
|
|
|
|
|
+ List<Map<String, Object>> pushProjectPlanHour = reportMapper.getProjectPlanData(companyId,taskIds,null,null);
|
|
ExecutorService executor = Executors.newFixedThreadPool(1);
|
|
ExecutorService executor = Executors.newFixedThreadPool(1);
|
|
/*execute()让线程池中的线程来执行业务,每次调用都会将一个线程加入到就绪队列*/
|
|
/*execute()让线程池中的线程来执行业务,每次调用都会将一个线程加入到就绪队列*/
|
|
List<Map<String, Object>> finalResultList = resultList;
|
|
List<Map<String, Object>> finalResultList = resultList;
|