| | |
|---|
| | | import com.mes.bigstoragecagetask.entity.BigStorageCageTask; |
|---|
| | | import com.mes.bigstoragecagetask.service.BigStorageCageTaskService; |
|---|
| | | import com.mes.common.config.Const; |
|---|
| | | import com.mes.hollow.entity.HollowBigStorageCage; |
|---|
| | | import com.mes.hollow.entity.HollowGlassOutRelationInfo; |
|---|
| | | import com.mes.hollow.service.HollowBigStorageCageDetailsService; |
|---|
| | | import com.mes.hollow.service.HollowBigStorageCageService; |
|---|
| | | import com.mes.hollow.service.HollowGlassOutRelationInfoService; |
|---|
| | | import com.mes.hollowqueue.entity.HollowGlassQueueInfo; |
|---|
| | | import com.mes.hollowqueue.service.HollowGlassQueueInfoService; |
|---|
| | | import com.mes.temperingglass.entity.TemperingGlassInfo; |
|---|
| | | import com.mes.tools.WebSocketServer; |
|---|
| | | import com.mes.utils.RedisUtil; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | |
|---|
| | | public class PushMessageToIndex { |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | HollowGlassQueueInfoService hollowGlassQueueInfoService; |
|---|
| | | HollowGlassQueueInfoService hollowGlassQueueInfoService; |
|---|
| | | @Resource |
|---|
| | | HollowGlassOutRelationInfoService hollowGlassOutRelationInfoService; |
|---|
| | | @Resource |
|---|
| | | HollowBigStorageCageService hollowBigStorageCageService; |
|---|
| | | @Resource |
|---|
| | | HollowBigStorageCageDetailsService hollowBigStorageCageDetailsService; |
|---|
| | | @Resource |
|---|
| | | BigStorageCageTaskService bigStorageCageTaskService; |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | RedisUtil redisUtil; |
|---|
| | | |
|---|
| | | @Scheduled(fixedDelay = 1000) |
|---|
| | | public void hollowGlassTask() { |
|---|
| | | List<HollowGlassOutRelationInfo> taskList = hollowGlassOutRelationInfoService.list(new LambdaQueryWrapper<HollowGlassOutRelationInfo>() |
|---|
| | | .in(HollowGlassOutRelationInfo::getState, Const.HOLLOW_FLOW_CARD_START, Const.HOLLOW_FLOW_CARD_PAUSE)); |
|---|
| | | .in(HollowGlassOutRelationInfo::getState, Const.HOLLOW_FLOW_CARD_START)); |
|---|
| | | if (CollectionUtil.isEmpty(taskList)) { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | JSONObject jsonObject = new JSONObject(); |
|---|
| | | List<String> flowCardIdList = taskList.stream().map(HollowGlassOutRelationInfo::getFlowCardId).collect(Collectors.toList()); |
|---|
| | | List<HollowGlassQueueInfo> list = hollowGlassQueueInfoService.list(new LambdaQueryWrapper<HollowGlassQueueInfo>().in(HollowGlassQueueInfo::getFlowCardId, flowCardIdList)); |
|---|
| | | List<Long> taskIdList = taskList.stream().map(HollowGlassOutRelationInfo::getId).collect(Collectors.toList()); |
|---|
| | | List<HollowGlassQueueInfo> list = hollowGlassQueueInfoService.list(new LambdaQueryWrapper<HollowGlassQueueInfo>().in(HollowGlassQueueInfo::getRelationId, taskIdList)); |
|---|
| | | Map<Integer, List<HollowGlassQueueInfo>> listMap = list.stream().collect(Collectors.groupingBy(HollowGlassQueueInfo::getCell)); |
|---|
| | | jsonObject.append("930", listMap.get(930)); |
|---|
| | | jsonObject.append("931", listMap.get(931)); |
|---|
| | |
|---|
| | | carPostion.add(0.5); |
|---|
| | | jsonObject.append("carPostion", carPostion); |
|---|
| | | //界面展示笼子信息 |
|---|
| | | jsonObject.append("bigStorageCageInfos", hollowBigStorageCageService.queryHollowbigStorageCageDetail()); |
|---|
| | | jsonObject.append("bigStorageCageInfos", hollowBigStorageCageDetailsService.queryHollowbigStorageCageDetail()); |
|---|
| | | |
|---|
| | | try{ |
|---|
| | | //进片任务数据 |
|---|
