| | |
|---|
| | | WriteExtractUtil.append("已有任务在运行跳过此次运行！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！:::" + uuid); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | //凌晨1点10分开始进入此方法的休眠到1点20分 |
|---|
| | | Calendar calendar = Calendar.getInstance(); |
|---|
| | | int hour = calendar.get(Calendar.HOUR_OF_DAY); |
|---|
| | | int minute = calendar.get(Calendar.MINUTE); |
|---|
| | | if (hour == 1 && (minute >= 10 || minute <= 20)) { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | WriteExtractUtil.append("开始提取！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！:::" + uuid); |
|---|
| | | TimeInterval tempTestTimer = DateUtil.timer(); |
|---|
| | | WriteExtractUtil.append("提取-等待耗时：" + tempTestTimer.intervalMs() + ",:::" + uuid); |
|---|
| | |
|---|
| | | 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); |
|---|
| | | } |
|---|
| | | } |
|---|
