| | |
|---|
| | | @Autowired |
|---|
| | | private MqttUtil mqttUtil; |
|---|
| | | |
|---|
| | | @Value(value = "${jeecg.mqtt.enable}") |
|---|
| | | private boolean mqttEnable; |
|---|
| | | |
|---|
| | | public String getTemporaryToken() { |
|---|
| | | if (token == null) { |
|---|
| | | RedisUtil redisUtil = SpringContextUtils.getBean(RedisUtil.class); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Result<?> fitFultRecord(RealTimeDataVo vo) { |
|---|
| | | public Result<?> fitFaultRecord(RealTimeDataVo vo) { |
|---|
| | | TenantContext.setTenant(vo.getTenantid()+""); |
|---|
| | | ThreadUtil.execute(() -> { |
|---|
| | | try { |
|---|
| | |
|---|
| | | |
|---|
| | | //处理结束后，将redis中实时数据发送至云服务器 |
|---|
| | | Map<Object, Object> toCloudFaultMap = redisUtil.hmget(MqttConstant.MQTT_REAL_FAULT); |
|---|
| | | if(!toCloudFaultMap.isEmpty()){ |
|---|
| | | if(mqttEnable && !toCloudFaultMap.isEmpty()){ |
|---|
| | | MqMessage< Map<Object, Object>> message = new MqMessage<>(); |
|---|
| | | message.setData(toCloudFaultMap); |
|---|
| | | message.setTentId(vo.getTenantid()+""); |
|---|
| | |
|---|
| | | */ |
|---|
| | | private List<DryFaultRecord> fitFault(String fault, String orderId,Integer tenantId,String machineId,Integer faultType){ |
|---|
| | | List<DryFaultRecord> result = new ArrayList<>(); |
|---|
| | | if(StringUtils.isEmpty(fault))return result; |
|---|
| | | //数据样本："eqp_fault": "滚筒降超时-报警,风机过流报警,滚筒升超时-报警,风箱升报警", |
|---|
| | | System.err.println((faultType == 1 ? "类型：故障" : "类型：报警") + DateUtils.formatDateTime()+"--"+fault); |
|---|
| | | //redis中的故障 |
|---|
