| | |
|---|
| | | import com.mes.opctask.entity.LoadGlassDeviceTaskHistory; |
|---|
| | | import com.mes.opctask.service.LoadGlassDeviceTaskHistoryService; |
|---|
| | | import com.mes.opctask.service.LoadGlassDeviceTaskService; |
|---|
| | | import com.mes.pp.entity.OptimizeProject; |
|---|
| | | import com.mes.pp.service.OptimizeProjectService; |
|---|
| | | import com.mes.rawglassdetails.entity.RawGlassStorageDetails; |
|---|
| | | import com.mes.rawglassdetails.service.RawGlassStorageDetailsService; |
|---|
| | | import com.mes.uppattenusage.entity.UpPattenUsage; |
|---|
| | |
|---|
| | | private LoadGlassDeviceTaskHistoryService loadGlassDeviceTaskHistoryService; |
|---|
| | | @Resource |
|---|
| | | private UpPattenUsageMapper upPattenUsageMapper; |
|---|
| | | @Resource |
|---|
| | | private OptimizeProjectService optimizeProjectService; |
|---|
| | | |
|---|
| | | private static final List<Integer> LOAD_STATION_01 = Arrays.asList(101, 102); |
|---|
| | | private static final List<Integer> LOAD_STATION_02 = Arrays.asList(103, 104); |
|---|
| | |
|---|
| | | private static final String LOAD_GLASS_DEVICE_ONE_TASK = "load_glass_device_one_task"; |
|---|
| | | |
|---|
| | | private static final String LOAD_GLASS_DEVICE_TWO_TASK = "load_glass_device_two_task"; |
|---|
| | | |
|---|
| | | |
|---|
| | | //设备id 上片位信息 任务表不一致 历史任务表公用一张 新增任务/任务结束，后会在历史表中新增一条记录并在结束后更新任务 一个任务即可 |
|---|
| | | //定时任务扫描上片位有没有原片 |
|---|
| | |
|---|
| | | @Scheduled(fixedDelay = 300) |
|---|
| | | public void opcLoadGlassTwoFinish() { |
|---|
| | | opcLoadGlassFinishChid(LOAD_GLASS_DEVICE_TWO_TASK, LOAD_GLASS_TWO_DEVICE); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 定时任务扫码已完成上片的工程，将工程状态改为已完成，同步pp表的工程表，状态改为300 |
|---|
| | | */ |
|---|
| | | @Scheduled(fixedDelay = 3000) |
|---|
| | | public void updateEngineerState() { |
|---|
| | | log.info("修改已完成工程状态任务开始执行"); |
|---|
| | | List<Engineering> engineerings = engineeringMapper.selectList(new LambdaQueryWrapper<Engineering>().eq(Engineering::getState, Const.ENGINEERING_RUNNING)); |
|---|
| | | for (Engineering engineering : engineerings) { |
|---|
| | | Integer count = upPattenUsageMapper.selectCount(new LambdaQueryWrapper<UpPattenUsage>() |
|---|
| | | .eq(UpPattenUsage::getEngineeringId, engineering.getEngineerId()).ne(UpPattenUsage::getState, Const.LOAD_RAW_GLASS_SUCCESS)); |
|---|
| | | if (count == 0) { |
|---|
| | | engineeringMapper.update(null, new LambdaUpdateWrapper<Engineering>().set(Engineering::getState, Const.ENGINEERING_SUCCESS) |
|---|
| | | .eq(Engineering::getEngineerId, engineering.getEngineerId())); |
|---|
| | | optimizeProjectService.update(null, new LambdaUpdateWrapper<OptimizeProject>().set(OptimizeProject::getState, 300) |
|---|
| | | .eq(OptimizeProject::getProjectNo, engineering.getEngineerId())); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | private void opcLoadGlassChild(String tableName, Integer deviceId) { |
|---|
| | |
|---|
| | | List<Integer> loadStation = LOAD_GLASS_DEVICE_ONE_TASK.equals(tableName) ? LOAD_STATION_01 : LOAD_STATION_02; |
|---|
| | | List<RawGlassStorageDetails> loadStationList = rawGlassStorageDetailsService.list(new LambdaQueryWrapper<RawGlassStorageDetails>() |
|---|
| | | .inSql(RawGlassStorageDetails::getSlot, "select slot from raw_glass_storage_station where enable_state = 1") |
|---|
| | | .eq(RawGlassStorageDetails::getState, Const.RAW_GLASS_STATE_IN) |
|---|
| | | .in(RawGlassStorageDetails::getState, Const.RAW_GLASS_STATE_IN_ALL) |
|---|
| | | .eq(RawGlassStorageDetails::getDeviceId, deviceId)); |
|---|
| | | if (CollectionUtils.isEmpty(loadStationList)) { |
|---|
| | | log.info("当前上片线路两个上片位都没有原片信息，结束本次上片任务，等待仓储调度任务"); |
|---|
