|  |  |  | 
|---|
|  |  |  | 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)) { | 
|---|
|  |  |  | //这里为空,直接离线 | 
|---|