|
@@ -32,10 +32,10 @@ public class FileParseTask {
|
|
|
private FileParse2ServiceImpl fileParseService;
|
|
private FileParse2ServiceImpl fileParseService;
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private TableCreator tableCreator;
|
|
private TableCreator tableCreator;
|
|
|
- @Scheduled(fixedRate = 300000)
|
|
|
|
|
|
|
+ //@Scheduled(fixedRate = 300000)
|
|
|
public void dataDeal(){
|
|
public void dataDeal(){
|
|
|
logger.info("开始解析文件");
|
|
logger.info("开始解析文件");
|
|
|
- List<DataChipTestLog> dataChipTestLogs = baseDao.getJdbcTemplate().query("select wafer_id,SUBSTR(WAFER_ID,0, INSTR(WAFER_ID, '#') -1) lot_id,status,data_path,counter_path,dbid_ from (select wafer_id,SUBSTR(WAFER_ID,0, INSTR(WAFER_ID, '#') -1) lot_id,status,data_path,counter_path,dbid_ from " +
|
|
|
|
|
|
|
+ List<DataChipTestLog> dataChipTestLogs = baseDao.getJdbcTemplate().query("select wafer_id,lot_id,status,data_path,counter_path,dbid_ from (select wafer_id,SUBSTR(WAFER_ID,0, INSTR(WAFER_ID, '#') -1) lot_id,status,data_path,counter_path,dbid_ from " +
|
|
|
" DATACENTER$MESFILE WHERE DEALSTATE_=0 ORDER BY DBID_ ASC ) where " +
|
|
" DATACENTER$MESFILE WHERE DEALSTATE_=0 ORDER BY DBID_ ASC ) where " +
|
|
|
" rownum<=100", new BeanPropertyRowMapper<>(DataChipTestLog.class));
|
|
" rownum<=100", new BeanPropertyRowMapper<>(DataChipTestLog.class));
|
|
|
List<String> distinctLotIds = dataChipTestLogs.stream().map(DataChipTestLog::getLot_id).distinct()
|
|
List<String> distinctLotIds = dataChipTestLogs.stream().map(DataChipTestLog::getLot_id).distinct()
|