diff --git a/op-modules/op-device/src/main/java/com/op/device/controller/EquRepairOrderController.java b/op-modules/op-device/src/main/java/com/op/device/controller/EquRepairOrderController.java index 082f86cc1..096cf19bd 100644 --- a/op-modules/op-device/src/main/java/com/op/device/controller/EquRepairOrderController.java +++ b/op-modules/op-device/src/main/java/com/op/device/controller/EquRepairOrderController.java @@ -1,6 +1,8 @@ package com.op.device.controller; +import java.util.HashMap; import java.util.List; +import java.util.Map; import javax.servlet.http.HttpServletResponse; import com.op.device.domain.EquEquipment; @@ -48,6 +50,8 @@ public class EquRepairOrderController extends BaseController { return getDataTable(list); } + + /** * 导出故障报修列表 */ @@ -152,4 +156,15 @@ public class EquRepairOrderController extends BaseController { return getDataTable(list); } + /** + * 黑蚊香车间生产监控看板设备故障信息 + */ + + + @GetMapping("/getCsRepairlist") + public List getCsRepairlist(EquRepairOrder equRepairOrder) { + //查询未维修完成的设备 + List equRepairOrderList= equRepairOrderService.selectRepairEquList(equRepairOrder); + return equRepairOrderList; + } } diff --git a/op-modules/op-device/src/main/java/com/op/device/mapper/EquRepairOrderMapper.java b/op-modules/op-device/src/main/java/com/op/device/mapper/EquRepairOrderMapper.java index 65b4a288e..268e11adc 100644 --- a/op-modules/op-device/src/main/java/com/op/device/mapper/EquRepairOrderMapper.java +++ b/op-modules/op-device/src/main/java/com/op/device/mapper/EquRepairOrderMapper.java @@ -113,4 +113,6 @@ public interface EquRepairOrderMapper { List getNoticesGroup(SysNoticeGroup noticeQo); Map selectEquInfoByequCode(String equipmentCode); + + List selectRepairEquList(EquRepairOrder equRepairOrder); } diff --git a/op-modules/op-device/src/main/java/com/op/device/schedul/MyWebSocketHandler.java b/op-modules/op-device/src/main/java/com/op/device/schedul/MyWebSocketHandler.java index 371df11aa..9f8f922ec 100644 --- a/op-modules/op-device/src/main/java/com/op/device/schedul/MyWebSocketHandler.java +++ b/op-modules/op-device/src/main/java/com/op/device/schedul/MyWebSocketHandler.java @@ -27,19 +27,5 @@ public class MyWebSocketHandler extends TextWebSocketHandler { private EquRepairOrderMapper equRepairOrderMapper; - @Scheduled(fixedRate = 5000) // 每60秒执行一次 - @DS("ds_1000") - public void sendPeriodicMessages() { - EquRepairOrder equRepairOrder=new EquRepairOrder(); - equRepairOrder.setOrderStatus("2"); - List equRepairOrderList=equRepairOrderMapper.selectEquRepairOrderList(equRepairOrder); - for (int i = 0; i < equRepairOrderList.size(); i++) { - Map map=new HashMap(); - map=equRepairOrderMapper.selectEquInfoByequCode(equRepairOrderList.get(i).getEquipmentCode()); - equRepairOrderList.get(i).setParams(map); - } - String jsonResult = JSON.toJSONString(equRepairOrderList); - WebSocketUsers.sendMessageToUsersByText(jsonResult); - } } diff --git a/op-modules/op-device/src/main/java/com/op/device/service/IEquRepairOrderService.java b/op-modules/op-device/src/main/java/com/op/device/service/IEquRepairOrderService.java index 7723522fc..48cbdf1e2 100644 --- a/op-modules/op-device/src/main/java/com/op/device/service/IEquRepairOrderService.java +++ b/op-modules/op-device/src/main/java/com/op/device/service/IEquRepairOrderService.java @@ -1,6 +1,7 @@ package com.op.device.service; import java.util.List; +import java.util.Map; import com.op.common.core.web.domain.AjaxResult; import com.op.device.domain.*; @@ -80,4 +81,7 @@ public interface IEquRepairOrderService { //查询组线 public List selectGroupLineList(); + Map selectEquInfoByequCode(String equipmentCode); + + List selectRepairEquList(EquRepairOrder equRepairOrder); } diff --git a/op-modules/op-device/src/main/java/com/op/device/service/impl/EquRepairOrderServiceImpl.java b/op-modules/op-device/src/main/java/com/op/device/service/impl/EquRepairOrderServiceImpl.java index 50b64e9fc..296c383ae 100644 --- a/op-modules/op-device/src/main/java/com/op/device/service/impl/EquRepairOrderServiceImpl.java +++ b/op-modules/op-device/src/main/java/com/op/device/service/impl/EquRepairOrderServiceImpl.java @@ -4,6 +4,7 @@ import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; +import java.util.Map; import java.util.regex.Matcher; import java.util.regex.Pattern; import java.util.stream.Collectors; @@ -604,4 +605,16 @@ public class EquRepairOrderServiceImpl implements IEquRepairOrderService { return equEquipmentMapper.selectEquipmentGroupLine(); } + @Override + @DS("#header.poolName") + public Map selectEquInfoByequCode(String equipmentCode) { + return equRepairOrderMapper.selectEquInfoByequCode(equipmentCode); + } + + @Override + @DS("#header.poolName") + public List selectRepairEquList(EquRepairOrder equRepairOrder) { + return equRepairOrderMapper.selectRepairEquList(equRepairOrder); + } + } diff --git a/op-modules/op-device/src/main/resources/mapper/device/DeviceInterfaceMapper.xml b/op-modules/op-device/src/main/resources/mapper/device/DeviceInterfaceMapper.xml index 1f1b294ee..eae96455d 100644 --- a/op-modules/op-device/src/main/resources/mapper/device/DeviceInterfaceMapper.xml +++ b/op-modules/op-device/src/main/resources/mapper/device/DeviceInterfaceMapper.xml @@ -15,8 +15,9 @@ from equ_repair_work_order wo left join base_equipment be on wo.equipment_code = be.equipment_code left join equ_team et on wo.work_team = et.team_code - where wo.work_status = '0' - and wo.del_flag = '0' + where +-- wo.work_status = '0' AND + wo.del_flag = '0' +