|
|
@ -4825,23 +4825,6 @@ public class BusSalesOrderService extends MybatisBaseService<BusSalesOrderMapper |
|
|
|
} catch (Exception e) { |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
/* //==============================
|
|
|
|
//如果创建人与部门主管一样,则自动到下一环节。
|
|
|
|
if (busSalesOrder.get().getCreateBySid().equals(nextNodeUserSids_)) { |
|
|
|
busSalesOrderOne = fetchBySid(businessSid); |
|
|
|
bv = new BusinessVariables(); |
|
|
|
bv.setModelId(busSalesOrderOne.getProcDefId()); |
|
|
|
bv.setInstanceId(busSalesOrderOne.getProcInstId()); |
|
|
|
bv.setTaskId(busSalesOrderOne.getTaskId()); |
|
|
|
bv.setUserSid(busSalesOrderOne.getCreateBySid()); |
|
|
|
bv.setBusinessSid(busSalesOrderOne.getSid()); |
|
|
|
bv.setTaskDefKey(busSalesOrderOne.getNodeId()); |
|
|
|
Map<String, Object> variabless = getOrderMap(busSalesOrderOne); |
|
|
|
bv.setFormVariables(variabless); |
|
|
|
bv.setOrgSidPath(busSalesOrderOne.getOrgSidPath()); |
|
|
|
bv.setComment("因与申请人相同,系统自动处理,需以下一级审批人审批意见为准!"); |
|
|
|
return complete(bv); |
|
|
|
}*/ |
|
|
|
try { |
|
|
|
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder() |
|
|
|
.setNameFormat("demo-pool-%d").build(); |
|
|
@ -5206,6 +5189,34 @@ public class BusSalesOrderService extends MybatisBaseService<BusSalesOrderMapper |
|
|
|
//推送车款
|
|
|
|
createCarFin(vo, busSalesOrder); |
|
|
|
} |
|
|
|
//==============================修改车辆的持久状态组装数据
|
|
|
|
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<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.DDBA_PASS.getTypeKey()); |
|
|
|
if (StringUtils.isNotBlank(v.getLinkSid())) { |
|
|
|
baseVehicleStateDto.setVinSid(v.getLinkSid()); |
|
|
|
baseVehicleStateDto.setVinNo(v.getLinkNo()); |
|
|
|
} |
|
|
|
baseVehicleStateDto.setBusSid(v.getSid()); |
|
|
|
dtoList.add(baseVehicleStateDto); |
|
|
|
}); |
|
|
|
ResultBean busVehicleStateResultBean = baseVehicleStateFeign.saveOrUpdate(dtoList); |
|
|
|
} |
|
|
|
}); |
|
|
|
} catch (Exception e) { |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
//-----------------推送车款款项结束
|
|
|
|
//推送采购渠道待选择
|
|
|
|
BusPurchaseChannelDto busPurchaseChannelDto = new BusPurchaseChannelDto(); |
|
|
|