test

沈斌

2017-11-15 a93eae62e20f3c8c94166021581161379e8c1947

 src/main/java/com/moral/monitor/listener/quartz/StopStateCheck.java

@@ -7,6 +7,8 @@
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;
@@ -23,6 +25,8 @@
    @Resource
    RedisTemplate<String, String> redisTemplate;

    private Logger logger = LoggerFactory.getLogger(StopStateCheck.class);

    private int waits = 10000;

    public void check() {
@@ -34,10 +38,10 @@
            String static_equ_json = RedisUtil.get(redisTemplate, "static_equ_" + mac);
            //设备资料为null，说明未收到该设备的数据，直接离线
            if(StringUtils.isEmpty(static_equ_json)) {
            //这里为空，直接离线
               jobDao.updateStateByMac(mac, 4);
               return;
           }
                //这里为空，直接离线
                  jobDao.updateStateByMac(mac, 4);
                  return;
            }
            Map<String,String> seJSON = JSON.parseObject(static_equ_json,new TypeReference<Map<String,String>>() {});
            if(!seJSON.isEmpty()) {
                String orgId = seJSON.get("orgId");
@@ -46,12 +50,17 @@

                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)) {
                      //这里为空，直接离线
                      jobDao.updateStateByMac(mac, 4);
                      return;
                 }
                }
                Map<String,String> stateJSON = JSON.parseObject(state_json,new TypeReference<Map<String,String>>() {});
                if(!stateJSON.isEmpty()) {
                    Long time = Long.parseLong(stateJSON.get("time"));