| | |
| | | |
| | | maybeUpdate.getData().sort((o1, o2) -> DateUtil.compare(o1.getDate(extractUpdateTimeField), o2.getDate(extractUpdateTimeField))); |
| | | |
| | | batchResultEntity = targetNewDao.updateBatch(maybeUpdate, updateFilterEntity, false); |
| | | batchResultEntity = targetNewDao.updateBatch(maybeUpdate, updateFilterEntity, true); |
| | | |
| | | WriteExtractUtil.append("更新提取过滤后数据:" + extractTargetTable + ",需要更新的条数:" + maybeUpdate.getRows() + ",耗时:" + tempTestTimer2.intervalMs()); |
| | | targetNewDao.closeConnection(); |
| | |
| | | if (DataTableEntity.isEmpty(dt) || !"T_PM_MO_BASE".equalsIgnoreCase(targetTable)) { |
| | | return; |
| | | } |
| | | StringBuilder b=new StringBuilder(); |
| | | b.append("select * from T_PM_PROJECT_BASE where project_id in( "); |
| | | Map<String, FieldSetEntity> map = new HashMap<>(); |
| | | List<Object> moNumberList = new ArrayList<>(); |
| | | for (int i = 0; i < dt.getRows(); i++) { |
| | |
| | | continue; |
| | | } |
| | | moNumberList.add(moNumber); |
| | | |
| | | if(i>0)b.append(","); |
| | | b.append(moNumber); |
| | | |
| | | map.put(moNumber, dt.getFieldSetEntity(i)); |
| | | } |
| | | b.append(" ) "); |
| | | //查询制令单关联的工单数据 |
| | | DataTableEntity projectBaseDt = targetDao.getList("T_PM_PROJECT_BASE", new String[]{"PROJECT_ID,PROJECT_BASE_ID"}, |
| | | BaseUtil.buildQuestionMarkFilter("project_id", moNumberList.size(), true), moNumberList.toArray(), null, 1, dt.getRows()); |
| | |
| | | } |
| | | } |
| | | if (!map.isEmpty()) { |
| | | b.append("\r\n未找到工单:"); |
| | | map.forEach((key, value) -> { |
| | | b.append(key).append(","); |
| | | }); |
| | | SpringMVCContextHolder.getSystemLogger().error(b.toString()); |
| | | throw new BaseException(ErrorCode.MO_NUMBER_MASTER_PROJECT_BASE_EMPTY); |
| | | } |
| | | } |