报表

xufenglei

2018-02-05 48bfa4e57cd2195b86bd8c0debe2e241db0ba80d

 src/main/java/com/moral/service/impl/MonitorPointServiceImpl.java

@@ -9,20 +9,21 @@
import com.github.pagehelper.PageHelper;

import com.moral.common.bean.Constants;

import com.moral.common.bean.PageBean;

import com.moral.common.util.ExampleUtil;

import com.moral.common.util.MyBatisBaseMapUtil;

import com.moral.common.util.*;

import org.springframework.stereotype.Service;



import com.moral.common.util.ValidateUtil;

import com.moral.entity.MonitorPoint;

import com.moral.mapper.MonitorPointMapper;

import com.moral.service.MonitorPointService;

import tk.mybatis.mapper.entity.Example;

import tk.mybatis.mapper.entity.Example.Criteria;



@Service

public class MonitorPointServiceImpl implements MonitorPointService {

    @Resource

    private MonitorPointMapper monitorPointMapper;

    @Resource

    RedisUtils redisUtils;

    private static Class ENTITY_CLASS = MonitorPoint.class;

    @Override

    public List<MonitorPoint> getMonitorPointsByAreaName(Map<String, Object> parameters) {

@@ -31,7 +32,25 @@
    }

    @Override

    public List<MonitorPoint> queryWithStateByMap(Map<String, Object> params){

        return monitorPointMapper.selectWithStateByMap(params);

        List<MonitorPoint> monitorPointList = monitorPointMapper.selectByMap(params);

        for(MonitorPoint monitorPoint:monitorPointList){

            loadStateFromRedis(monitorPoint);

        }

        return monitorPointList;

    }

    private void loadStateFromRedis(MonitorPoint monitorPoint){

        StringBuilder key = new StringBuilder();

        key.append("*_").append(monitorPoint.getId()).append("_*");

        List<Map> stateList = redisUtils.getList(key.toString(),Map.class);

        int state = -1;

        if(stateList!=null){

            for (Map deviceState:stateList){

                int s =  Integer.parseInt(deviceState.get("state").toString());

                state = s>state&&s<4?s:state;

            }

        }

        state = state==-1?4:state;

        monitorPoint.setState(state);

    }

    @Override

    public PageBean queryByPageBean(PageBean pageBean) {

@@ -87,4 +106,15 @@
        }

    }



   @Override

   public List<MonitorPoint> getMonitorPointsByName(String name) {

      Example example = new Example(MonitorPoint.class);

      Criteria criteria = example.createCriteria();



      criteria.andEqualTo("isDelete", Constants.IS_DELETE_FALSE).andLike("name", "%" + name + "%");

      example.or().andEqualTo("isDelete", Constants.IS_DELETE_FALSE).andCondition("getPY(name) like ", "%" + name + "%");



      List<MonitorPoint> monitorPoints = monitorPointMapper.selectByExample(example);

      return monitorPoints;

   }

}