| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public Boolean innerAddWorkOrder(List<WorkOrder> workOrderList) { |
|---|
| | | public synchronized Boolean innerAddWorkOrder(List<WorkOrder> workOrderList) { |
|---|
| | | int total = workOrderList.size(); |
|---|
| | | workOrderList.stream().filter(item -> { |
|---|
| | | return StringUtils.hasText(item.getSerialNumber()) && Objects.nonNull(item.getStatus()) && !CollectionUtils.isEmpty(item.getErrorTypeList()); |
|---|
| | |
|---|
| | | |
|---|
| | | Date now = new Date(); |
|---|
| | | if (Objects.nonNull(beforeRecord)) { |
|---|
| | | if (beforeRecord.getStartCreateTime().after(now)) { |
|---|
| | | if (now.before(beforeRecord.getBeginCreateTime())) { |
|---|
| | | process.setBeforeReportMsg("事前报备已失效"); |
|---|
| | | } else if (beforeRecord.getEndCreateTime().before(now)){ |
|---|
| | | } else if (now.after(beforeRecord.getEndCreateTime())){ |
|---|
| | | process.setBeforeReportMsg("事前报备未生效"); |
|---|
| | | } else { |
|---|
| | | process.setBeforeReportMsg("已事前报备"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (Objects.nonNull(afterRecord)) { |
|---|
| | | if (afterRecord.getStartCreateTime().after(now)) { |
|---|
| | | if (now.before(afterRecord.getBeginCreateTime())) { |
|---|
| | | process.setAfterReportMsg("事后报备已失效"); |
|---|
| | | } else if (afterRecord.getEndCreateTime().before(now)){ |
|---|
| | | } else if (now.after(afterRecord.getEndCreateTime())){ |
|---|
| | | process.setAfterReportMsg("事后报备未生效"); |
|---|
| | | } else { |
|---|
| | | process.setAfterReportMsg("已事后报备"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return Result.ok().data(process); |
|---|
