| | |
|---|
| | | |
|---|
| | | import cn.hutool.json.JSONObject; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
|---|
| | | import com.mes.common.config.Const; |
|---|
| | | import com.mes.damage.entity.Damage; |
|---|
| | | import com.mes.damage.service.DamageService; |
|---|
| | | import com.mes.engineering.entity.Engineering; |
|---|
| | | import com.mes.temperingglass.service.TemperingGlassInfoService; |
|---|
| | | import com.mes.temperingglass.entity.TemperingGlassInfo; |
|---|
| | | import com.mes.tools.WebSocketServer; |
|---|
| | |
|---|
| | | if (outGlass != null) { |
|---|
| | | jsonObject.append("overGlass", overGlass); |
|---|
| | | } |
|---|
| | | //当前钢化工程的拿走数据 |
|---|
| | | LambdaQueryWrapper<TemperingGlassInfo> queryWrapper = new LambdaQueryWrapper<>(); |
|---|
| | | queryWrapper.select(TemperingGlassInfo::getEngineerId) |
|---|
| | | .lt(TemperingGlassInfo::getState, Const.TEMPERING_END) |
|---|
| | | .groupBy(TemperingGlassInfo::getEngineerId); |
|---|
| | | |
|---|
| | | List<String> engineerIds = temperingAgoService.list(queryWrapper) |
|---|
| | | .stream() |
|---|
| | | .map(TemperingGlassInfo::getEngineerId) |
|---|
| | | .distinct() |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | |
|---|
| | | List<Damage> temperingTakeGlassInfos = damageService.list( |
|---|
| | | new LambdaQueryWrapper<Damage>() |
|---|
| | | .in(Damage::getEngineerId, engineerIds) |
|---|
| | | .eq(Damage::getType, Const.GLASS_STATE_TAKE) |
|---|
| | | .orderByAsc(Damage::getId) |
|---|
| | | ); |
|---|
| | | |
|---|
| | | |
|---|
| | | jsonObject.append("temperingTakeGlassInfos", temperingTakeGlassInfos); |
|---|
| | | |
|---|
| | | ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("temperingGlass"); |
|---|
| | | if (sendwServer != null) { |
|---|
| | |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Scheduled(fixedDelay = 1000) |
|---|
| | | public void largenScreen() { |
|---|
| | | JSONObject jsonObject = new JSONObject(); |
|---|
| | | //大屏钢化信息 |
|---|
| | | Integer putGlass = temperingAgoService.count( |
|---|
| | | new LambdaUpdateWrapper<TemperingGlassInfo>() |
|---|
| | | .eq(TemperingGlassInfo::getState, Const.TEMPERING_NEW) |
|---|
| | | ); |
|---|
| | | jsonObject.append("temperingTaskType", putGlass); |
|---|
| | | //大屏钢化信息 |
|---|
| | | Integer temperingGlass = temperingAgoService.count( |
|---|
| | | new LambdaUpdateWrapper<TemperingGlassInfo>() |
|---|
| | | .eq(TemperingGlassInfo::getState, Const.TEMPERING_START) |
|---|
| | | .groupBy(TemperingGlassInfo::getEngineerId, |
|---|
| | | TemperingGlassInfo::getTemperingLayoutId) |
|---|
| | | ); |
|---|
| | | jsonObject.append("temperingGlass", temperingGlass); |
|---|
| | | ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("largenScreen"); |
|---|
| | | if (sendwServer != null) { |
|---|
| | | for (WebSocketServer webserver : sendwServer) { |
|---|
| | | if (webserver != null) { |
|---|
| | | webserver.sendMessage(jsonObject.toString()); |
|---|
| | | List<String> messages = webserver.getMessages(); |
|---|
| | | if (!messages.isEmpty()) { |
|---|
| | | // // 将最后一个消息转换为整数类型的列表 |
|---|
| | | webserver.clearMessages(); |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | log.info("largenScreen is closed"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
