| | |
| | | OutputQueue.SCALE.offer(jsonObject); |
| | | } |
| | | } catch (Exception e){ |
| | | log.error("称重模块异常"+e.getMessage()); |
| | | log.error("称重模块异常"+e .getMessage()); |
| | | } |
| | | // BasDevpService basDevpService = SpringUtils.getBean(BasDevpService.class); |
| | | // BasDevp basDevp = basDevpService.selectById(slave.getStaNo()); |
| | |
| | | dataOutputStream = new DataOutputStream(socket.getOutputStream()); |
| | | dataInputStream = new DataInputStream(socket.getInputStream()); |
| | | // log.info("条码扫描仪连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); |
| | | // DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class); |
| | | // deviceErrorService.deleteDeviceError("scale", slave.getId()); |
| | | try{ |
| | | DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class); |
| | | deviceErrorService.deleteDeviceError("devp", slave.getId()); |
| | | } catch (Exception e){ |
| | | log.error("e:"+e.getMessage()); |
| | | } |
| | | } catch (Exception e) { |
| | | socket = null; |
| | | log.error("磅秤连接失败!!! ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); |
| | | // DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class); |
| | | // deviceErrorService.addDeviceError("scale", slave.getId(), "磅秤连接失败"); |
| | | try{ |
| | | DeviceErrorService deviceErrorService = SpringUtils.getBean(DeviceErrorService.class); |
| | | deviceErrorService.deleteDeviceError("devp", slave.getId()); |
| | | } catch (Exception e1){ |
| | | log.error("e:"+e1.getMessage()); |
| | | } |
| | | return false; |
| | | } |
| | | return true; |