| | |
| | | import javax.annotation.Resource; |
| | | |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.data.redis.core.RedisTemplate; |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | |
| | | |
| | | @Resource |
| | | RedisTemplate<String, String> redisTemplate; |
| | | |
| | | private Logger logger = LoggerFactory.getLogger(StopStateCheck.class); |
| | | |
| | | private int waits = 10000; |
| | | |
| | |
| | | |
| | | String key = "state_" + orgId + "_" + areaCode + "_" + monitorpointId + "_" + mac; |
| | | String state_json = RedisUtil.get(redisTemplate, key); |
| | | |
| | | System.out.println("++++++++++++++++++++"); |
| | | System.out.println(key + " => " + state_json); |
| | | logger.error(key + " => " + state_json); |
| | | |
| | | //设备实时state为null,说明未收到该设备的数据,直接离线 |
| | | if(StringUtils.isEmpty(state_json)) { |
| | | //这里为空,直接离线 |