| | |
|---|
| | | |
|---|
| | | import cn.hutool.core.date.DatePattern; |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; |
|---|
| | | import com.baomidou.mybatisplus.core.toolkit.StringPool; |
|---|
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|---|
| | | import org.apache.commons.compress.utils.Lists; |
|---|
| | |
|---|
| | | import org.jeecg.modules.mdc.util.DateUtils; |
|---|
| | | import org.jeecg.modules.mdc.vo.AndonOrderWebSocketVo; |
|---|
| | | import org.jeecg.modules.message.websocket.WebSocket; |
|---|
| | | import org.jeecg.modules.system.entity.SysUser; |
|---|
| | | import org.jeecg.modules.system.service.ISysDictService; |
|---|
| | | import org.jeecg.modules.system.service.ISysUserService; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | |
|---|
| | | } |
|---|
| | | return result; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<AndonOrderWebSocketVo> untreatedAndonList() { |
|---|
| | | List<AndonOrderWebSocketVo> result = new ArrayList<>(); |
|---|
| | | List<AndonOrder> andonOrderList = this.baseMapper.untreatedAndonList(); |
|---|
| | | if (andonOrderList != null && !andonOrderList.isEmpty()) { |
|---|
| | | |
|---|
| | | List<String> equipmentIds = andonOrderList.stream().map(AndonOrder::getEquipmentId).collect(Collectors.toList()); |
|---|
| | | List<MdcEquProDto> equipmentList = mdcEquipmentService.findEquProList(equipmentIds); |
|---|
| | | Map<String, MdcEquProDto> equipmentIdToProductionIdMap = CollectionUtils.isNotEmpty(equipmentList) ? equipmentList.stream().collect(Collectors.toMap(MdcEquProDto::getEquipmentId, comRateDto -> comRateDto)) : new HashMap<>(); |
|---|
| | | |
|---|
| | | andonOrderList.forEach(andonOrder -> { |
|---|
| | | AndonOrderWebSocketVo andonOrderWebSocketVo = new AndonOrderWebSocketVo(); |
|---|
| | | andonOrderWebSocketVo.setEquipmentId(andonOrder.getEquipmentId()); |
|---|
| | | andonOrderWebSocketVo.setCallPersonnel(userService.getById(andonOrder.getOperator()).getRealname()); |
|---|
| | | andonOrderWebSocketVo.setCallTime(DateUtils.format(andonOrder.getOperateTime(), DatePattern.NORM_DATE_PATTERN)); |
|---|
| | | andonOrderWebSocketVo.setCallReason(andonOrder.getCallReason()); |
|---|
| | | andonOrderWebSocketVo.setAndonType("程序呼叫"); |
|---|
| | | andonOrderWebSocketVo.setPersonResponsible(userService.getById(andonOrder.getResponder()).getRealname()); |
|---|
| | | andonOrderWebSocketVo.setRepairTime(StringPool.EMPTY); |
|---|
| | | andonOrderWebSocketVo.setFaultInfo(StringPool.EMPTY); |
|---|
| | | andonOrderWebSocketVo.setType("open"); |
|---|
| | | andonOrderWebSocketVo.setPlantName(equipmentIdToProductionIdMap != null && equipmentIdToProductionIdMap.containsKey(andonOrder.getEquipmentId()) ? equipmentIdToProductionIdMap.get(andonOrder.getEquipmentId()).getProductionName() : null); |
|---|
| | | result.add(andonOrderWebSocketVo); |
|---|
| | | |
|---|
| | | }); |
|---|
| | | } |
|---|
| | | return result; |
|---|
| | | } |
|---|
| | | } |
|---|
