forked from moral

blame | history | patch | commit | commitdiff | ignore whitespace
kaiyu
2021-10-18 5586964c3e63f95c9e460a6a3d85d7dca408e096 
 screen-job/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java


@@ -2,6 +2,8 @@




import com.alibaba.fastjson.JSONObject;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.moral.api.config.mybatis.MybatisPlusConfig;


import com.moral.api.entity.HistoryHourly;


import com.moral.api.entity.Sensor;


import com.moral.api.mapper.HistoryHourlyMapper;


import com.moral.api.mapper.HistoryMinutelyMapper;


@@ -9,9 +11,11 @@


import com.moral.api.service.SensorService;


import com.moral.constant.Constants;


import com.moral.constant.RedisConstants;


import com.moral.constant.SeparateTableType;


import com.moral.util.AmendUtils;


import com.moral.util.DateUtils;




import com.moral.util.MybatisPLUSUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Service;


@@ -223,4 +227,39 @@


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


        return historyHourlyMapper.selectDailyData(params);


    }




    /**


     * @Description: 查询一段时间内某一mac的数据


     * @Param: [mac, startDate, endDate]


     * @return: java.util.List<com.moral.api.entity.HistoryHourly>


     * @Author: 陈凯裕


     * @Date: 2021/9/23


     */


    @Override


    public List<HistoryHourly> getValueByMacAndTime(String mac, Date startDate, Date endDate){


        QueryWrapper<HistoryHourly> wrapper = new QueryWrapper<>();


        wrapper.eq("mac",mac);


        wrapper.between("time",startDate,endDate);


        List<String> tableNames = MybatisPLUSUtils.getTableNamesByWrapper(startDate, endDate, SeparateTableType.MONTH);


        List<HistoryHourly> datas = multiTableQuery(wrapper, tableNames);


        return datas;


    }




    /**


     * @Description: 多表查询，传入表名集合，以及条件wrapper，返回数据


     * @Param: [wrapper, tableNames]


     * @return: java.util.List<com.moral.api.entity.HistoryHourly>


     * @Author: 陈凯裕


     * @Date: 2021/9/23


     */


    private List<HistoryHourly> multiTableQuery(QueryWrapper<HistoryHourly> wrapper,List<String> tableNames){


        List<HistoryHourly> result = new ArrayList<>();


        for (String tableName : tableNames) {


            MybatisPlusConfig.tableName.set(tableName);


            List<HistoryHourly> datas = historyHourlyMapper.selectList(wrapper);


            result.addAll(datas);


        }


        MybatisPlusConfig.tableName.remove();


        return result;


    }


}