Commit 29478fe8 by 李小惠

修改业务管理中审核未看到单据bug

parent ac350801
This source diff could not be displayed because it is too large. You can view the blob instead.
...@@ -85,6 +85,9 @@ public class BusFormServiceImpl extends ServiceImpl<BusFormMapper, BusForm> impl ...@@ -85,6 +85,9 @@ public class BusFormServiceImpl extends ServiceImpl<BusFormMapper, BusForm> impl
@Resource @Resource
private BusFormMapper busFormMapper; private BusFormMapper busFormMapper;
@Resource
private PolicemanService policemanService;
public Object addEs() { public Object addEs() {
List<BusForm> esDto=this.list(); List<BusForm> esDto=this.list();
return busFormRepository.saveAll(esDto); return busFormRepository.saveAll(esDto);
...@@ -167,6 +170,11 @@ public class BusFormServiceImpl extends ServiceImpl<BusFormMapper, BusForm> impl ...@@ -167,6 +170,11 @@ public class BusFormServiceImpl extends ServiceImpl<BusFormMapper, BusForm> impl
updateById(busForm); updateById(busForm);
} else { } else {
//保存 //保存
//将创建人员添加(为的是将审核员创建的单子,审核员能看见)
//将该组织机构下的所有审核人员进行查询,并添加到historyAssign中
String userIds=policemanService.searchUserByRoleId(req.getOrgId());
String userId=LoginContext.getContext().getLoginUser().getUserId().toString()+","+userIds;
busForm.setHistoryAssign(userId);
this.save(busForm); this.save(busForm);
} }
Task currentTask = taskService.createTaskQuery().processInstanceId(substring).singleResult(); Task currentTask = taskService.createTaskQuery().processInstanceId(substring).singleResult();
...@@ -182,6 +190,11 @@ public class BusFormServiceImpl extends ServiceImpl<BusFormMapper, BusForm> impl ...@@ -182,6 +190,11 @@ public class BusFormServiceImpl extends ServiceImpl<BusFormMapper, BusForm> impl
updateById(busForm); updateById(busForm);
} else { } else {
//保存 //保存
//将创建人员添加(为的是将审核员创建的单子,审核员能看见)
//将该组织机构下的所有审核人员进行查询,并添加到historyAssign中
String userIds=policemanService.searchUserByRoleId(req.getOrgId());
String userId=LoginContext.getContext().getLoginUser().getUserId().toString()+","+userIds;
busForm.setHistoryAssign(userId);
this.save(busForm); this.save(busForm);
} }
}else { }else {
...@@ -190,6 +203,11 @@ public class BusFormServiceImpl extends ServiceImpl<BusFormMapper, BusForm> impl ...@@ -190,6 +203,11 @@ public class BusFormServiceImpl extends ServiceImpl<BusFormMapper, BusForm> impl
updateById(busForm); updateById(busForm);
} else { } else {
//保存 //保存
//将创建人员添加(为的是将审核员创建的单子,审核员能看见)
//将该组织机构下的所有审核人员进行查询,并添加到historyAssign中
String userIds=policemanService.searchUserByRoleId(req.getOrgId());
String userId=LoginContext.getContext().getLoginUser().getUserId().toString()+","+userIds;
busForm.setHistoryAssign(userId);
this.save(busForm); this.save(busForm);
} }
} }
......
...@@ -163,6 +163,9 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -163,6 +163,9 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
@Resource @Resource
private IStoredEncryptApi iStoredEncryptApi; private IStoredEncryptApi iStoredEncryptApi;
@Resource
private PolicemanService policemanService;
private static final String REDIS_POLICE = "Policeman_"; private static final String REDIS_POLICE = "Policeman_";
private static final String REDIS_ORG = "Organization_"; private static final String REDIS_ORG = "Organization_";
...@@ -1728,6 +1731,9 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman ...@@ -1728,6 +1731,9 @@ public class PolicemanServiceImpl extends ServiceImpl<PolicemanMapper, Policeman
reassignment.setOrderCode(orderNum.getBussinessType()+orderNum.getYear()+ reassignment.setOrderCode(orderNum.getBussinessType()+orderNum.getYear()+
String.format("%02d", LocalDateTime.now().getMonth().getValue())+ String.format("%02d", LocalDateTime.now().getMonth().getValue())+
String.format("%02d",LocalDateTime.now().getDayOfMonth())+codeValue); String.format("%02d",LocalDateTime.now().getDayOfMonth())+codeValue);
String userIds=policemanService.searchUserByRoleId(req.getOrgId());
String userId=LoginContext.getContext().getLoginUser().getUserId().toString()+","+userIds;
reassignment.setHistoryAssign(userId);
reassignmentService.save(reassignment); reassignmentService.save(reassignment);
} }
//执行工作流(如果点击提交接入审核流) //执行工作流(如果点击提交接入审核流)
......
...@@ -719,7 +719,6 @@ public class TjServiceImpl implements TjService { ...@@ -719,7 +719,6 @@ public class TjServiceImpl implements TjService {
PubOrg pubOrg = pubOrgService.PubOrgExist(req.getOrgId()); PubOrg pubOrg = pubOrgService.PubOrgExist(req.getOrgId());
List<String> orgList= inventorySummaryMapper.getTotalData(String.valueOf(req.getOrgId())); List<String> orgList= inventorySummaryMapper.getTotalData(String.valueOf(req.getOrgId()));
List<TjOrgCountDto> tjOrgCountList=new ArrayList<>(); List<TjOrgCountDto> tjOrgCountList=new ArrayList<>();
String[] splitStart = req.getStartTime().split("-"); String[] splitStart = req.getStartTime().split("-");
String[] splitEnd =req.getEndTime().split("-"); String[] splitEnd =req.getEndTime().split("-");
Integer year=Integer.parseInt(splitStart[0] ); Integer year=Integer.parseInt(splitStart[0] );
...@@ -728,6 +727,7 @@ public class TjServiceImpl implements TjService { ...@@ -728,6 +727,7 @@ public class TjServiceImpl implements TjService {
for (int i = Integer.parseInt(splitStart[1]) ; i <= Integer.parseInt(splitEnd[1]); i++) { for (int i = Integer.parseInt(splitStart[1]) ; i <= Integer.parseInt(splitEnd[1]); i++) {
monthList.add(i); monthList.add(i);
} }
req.setMonthList(monthList);
List<CompletableFuture<TjOrgCountDto>> futures = orgList.stream() List<CompletableFuture<TjOrgCountDto>> futures = orgList.stream()
.map(orgId -> CompletableFuture.supplyAsync(() -> .map(orgId -> CompletableFuture.supplyAsync(() ->
equipmentCountSummaryMapper.TjOrgCount(orgId, equipmentCountSummaryMapper.TjOrgCount(orgId,
...@@ -736,9 +736,8 @@ public class TjServiceImpl implements TjService { ...@@ -736,9 +736,8 @@ public class TjServiceImpl implements TjService {
) )
.collect(Collectors.toList()); .collect(Collectors.toList());
// 等待所有 CompletableFuture 完成 // 等待所有 CompletableFuture 完成
CompletableFuture<Void> allOf = CompletableFuture.allOf( CompletableFuture<Void> allOf = CompletableFuture.allOf( futures.toArray(new CompletableFuture[0]));
futures.toArray(new CompletableFuture[0])
);
allOf.join(); allOf.join();
tjOrgCountList = futures.stream() tjOrgCountList = futures.stream()
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论