|
|
@ -3456,7 +3456,12 @@ public class FinBillApplicationService extends MybatisBaseService<FinBillApplica |
|
|
|
List<String> orgPathList = Arrays.asList(finBillApplication1.getOrgSidPath().split("/")); |
|
|
|
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(orgPathList.get(orgPathList.size() - 1)).getData(); |
|
|
|
String nextNodeUserSids_ = sysOrganization.getManagerSid(); |
|
|
|
bv.setNextNodeUserSids(nextNodeUserSids_); |
|
|
|
if(StringUtils.isBlank(nextNodeUserSids_)){//若主管人员为空,则默认为管理员
|
|
|
|
bv.setNextNodeUserSids(ProcDefEnum.DEFAUL_TADMIN_SID.getProDefId()); |
|
|
|
}else{ |
|
|
|
bv.setNextNodeUserSids(nextNodeUserSids_); |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
//=======================================
|
|
|
|
if (r == 1) { |
|
|
@ -3529,7 +3534,12 @@ public class FinBillApplicationService extends MybatisBaseService<FinBillApplica |
|
|
|
List<String> orgPathList = Arrays.asList(finBillApplication.getOrgSidPath().split("/")); |
|
|
|
SysOrganizationVo sysOrganization = sysOrganizationFeign.fetchBySid(orgPathList.get(orgPathList.size() - 1)).getData(); |
|
|
|
String nextNodeUserSids_ = sysOrganization.getManagerSid(); |
|
|
|
bv.setNextNodeUserSids(nextNodeUserSids_); |
|
|
|
if(StringUtils.isBlank(nextNodeUserSids_)){ |
|
|
|
bv.setNextNodeUserSids(ProcDefEnum.DEFAUL_TADMIN_SID.getProDefId()); |
|
|
|
}else{ |
|
|
|
bv.setNextNodeUserSids(nextNodeUserSids_); |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
//=======================================
|
|
|
|
if (bv.getTaskId().equals(finBillApplication.getTaskId())) { |
|
|
@ -3702,6 +3712,32 @@ public class FinBillApplicationService extends MybatisBaseService<FinBillApplica |
|
|
|
//极光推送
|
|
|
|
UpdateFlowFieldVo ufVo = resultBean1.getData(); |
|
|
|
finBillApplication = fetchBySid(bv.getBusinessSid()); |
|
|
|
//============================================================================修改车辆的持久状态组装数据
|
|
|
|
try { |
|
|
|
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder() |
|
|
|
.setNameFormat("demo-pool-%d").build(); |
|
|
|
ExecutorService pool = new ThreadPoolExecutor(2, 100, |
|
|
|
0L, TimeUnit.MILLISECONDS, |
|
|
|
new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy()); |
|
|
|
Future future1 = pool.submit(() -> { |
|
|
|
List<BaseVehicleStateDto> dtoList = new ArrayList<>(); |
|
|
|
List<String> vehicleList = baseMapper.getSelectBySid(bv.getBusinessSid()); |
|
|
|
// List<BusSalesOrderVehicle> vehicleList = busSalesOrderVehicleService.selectListByOrderSid(bv.getBusinessSid());
|
|
|
|
vehicleList.removeAll(Collections.singleton(null)); |
|
|
|
if (!vehicleList.isEmpty()) { |
|
|
|
vehicleList.stream().forEach(v -> { |
|
|
|
BaseVehicleStateDto baseVehicleStateDto = new BaseVehicleStateDto(); |
|
|
|
baseVehicleStateDto.setOperateType(BaseVehicleStateEnum.OperateTypeEnum.LPSQTG.getTypeKey()); |
|
|
|
baseVehicleStateDto.setBusSid(v); |
|
|
|
dtoList.add(baseVehicleStateDto); |
|
|
|
}); |
|
|
|
ResultBean busVehicleStateResultBean = baseVehicleStateFeign.saveOrUpdate(dtoList); |
|
|
|
} |
|
|
|
}); |
|
|
|
} catch (Exception e) { |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
//============================================================================
|
|
|
|
try { |
|
|
|
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder() |
|
|
|
.setNameFormat("demo-pool-%d").build(); |
|
|
|