shicf
6 天以前 5d2411baa5ae84890430a2d7e360fc6777054797
product-server-data-center/src/main/java/com/product/data/center/service/DataExtractService.java
@@ -599,6 +599,8 @@
      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++) {
@@ -607,8 +609,13 @@
            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());
@@ -625,6 +632,11 @@
         }
      }
      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);
      }
   }