fengxiang
2018-04-25 4f708def438b40d2a55c4bb479eb67acf8076a95
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
package com.moral.service.impl;
 
import java.time.LocalDateTime;
import java.util.*;
 
import javax.annotation.Resource;
 
import org.springframework.stereotype.Service;
 
import com.moral.common.util.ValidateUtil;
import com.moral.entity.Sensor;
import com.moral.mapper.DeviceMapper;
import com.moral.mapper.HistoryMapper;
import com.moral.mapper.SensorMapper;
import com.moral.service.AccountService;
import com.moral.service.HistoryService;
 
@Service
public class HistoryServiceImpl implements HistoryService {
 
    @Resource
    private AccountService accountService;
 
    @Resource
    private HistoryMapper historyMapper;
 
    @Resource
    private DeviceMapper deviceMapper;
 
    @Resource
    private SensorMapper sensorMapper;
 
    @Override
    public Map<String, Object> getAllSensorAverageByDevice(Map<String, Object> parameters) throws Exception {
        ValidateUtil.notNull(parameters.get("areaCode"), "param.is.null");
        ValidateUtil.notNull(parameters.get("accountId"), "param.is.null");
        Map<String,Object> resultMap = new LinkedHashMap<String, Object>();
        accountService.setOrgIdsByAccount(parameters);
        LocalDateTime time = LocalDateTime.now();
        // 当前时间 -10分钟
        parameters.put("start", time.minusMinutes(10));
        // 当前时间 -5分钟
        parameters.put("end", time.minusMinutes(5));
        List<Sensor> Sensors = sensorMapper.getSensorsByCriteria(parameters);
        List<String> sensorKeys = new ArrayList<String>();
        for (Sensor sensor : Sensors) {
            sensorKeys.add(sensor.getSensorKey());
        }
        parameters.put("sensorKeys", sensorKeys);
        List<Map<String, Object>> list = historyMapper.getAreaAllDataByAccount(parameters);
        resultMap.putAll(list.get(0));
        return resultMap;
    }
 
    @Override
    public Map<String, Object> getDeviceRankingBySensorAverage(Map<String, Object> parameters) {
        ValidateUtil.notNull(parameters.get("areaCode"), "param.is.null");
        ValidateUtil.notNull(parameters.get("accountId"), "param.is.null");
        Object macKey = parameters.get("macKey");
        ValidateUtil.notNull(macKey, "param.is.null");
 
        Map<String, Object> result = new LinkedHashMap<String, Object>();
        accountService.setOrgIdsByAccount(parameters);
        LocalDateTime time = LocalDateTime.now();
        // 当前时间 -1小时
        parameters.put("start", time.minusHours(1));
        parameters.put("end", time);
        List<String> sensorKeys = new ArrayList<String>();
        sensorKeys.add(macKey.toString());
        parameters.put("sensorKeys", sensorKeys);
        List<Map<String, Object>> list = historyMapper.getAreaAllDataByAccount(parameters);
 
        for (Map<String, Object> map : list) {
            result.put((String) map.get("name"), map.get(macKey.toString()));
        }
        return result;
    }
    @Override
    public String queryValueByMacAndTime(String mac, Date time){
        return  historyMapper.selectValueByMacAndTime(mac, time);
    }
}