| | |
| | | CompletableFuture<List<Map<String,Object>>> tbAttResWaterBlock = getTbInfo("tb_att_res_water_block",resGuid,executor); |
| | | CompletableFuture<List<Map<String,Object>>> tbAttResWaterDelivery = getTbInfo("tb_att_res_water_delivery",resGuid,executor); |
| | | CompletableFuture<List<Map<String,Object>>> tbFileStorageLocation = getTbInfo("tb_file_storage_location",resGuid,executor); |
| | | CompletableFuture<List<Map<String,Object>>> tbResStagCapDisc = getTbInfo("tb_res_stag_cap_disc",resGuid,executor); |
| | | //等待所有任务执行完成 |
| | | try { |
| | | CompletableFuture.allOf( |
| | |
| | | tbAttResSafetyMonitor, |
| | | tbAttResStagChar, |
| | | tbAttResWaterBlock, |
| | | tbAttResWaterDelivery, |
| | | tbResStagCapDisc |
| | | tbAttResWaterDelivery |
| | | ).get(); |
| | | // 数据处理 |
| | | list.addAll(tbAttResBaseInfo.get()); |
| | |
| | | list.addAll(tbAttResWaterBlock.get()); |
| | | list.addAll(tbAttResWaterDelivery.get()); |
| | | list.addAll(tbFileStorageLocation.get()); |
| | | list.addAll(tbResStagCapDisc.get()); |
| | | } catch (InterruptedException e) { |
| | | e.printStackTrace(); |
| | | } catch (ExecutionException e) { |
| | |
| | | Date now = DateUtil.now(); |
| | | //更新数据 |
| | | tbResStagCapDisc.setUpdateTime(now); |
| | | b = updateById(tbResStagCapDisc); |
| | | updateById(tbResStagCapDisc); |
| | | } |
| | | |
| | | if (b){ |
| | | if (!edit) { |
| | | tbAttResBaseService.updateFinalState(list.get(0).getResGuid(), list.get(0).getCheckState()); |
| | | } |
| | | return true; |
| | | } |
| | | // if (b){ |
| | | // if (!edit) { |
| | | // tbAttResBaseService.updateFinalState(list.get(0).getResGuid(), list.get(0).getCheckState()); |
| | | // } |
| | | // return true; |
| | | // } |
| | | |
| | | return true; |
| | | } |