| | |
|---|
| | | |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | import com.moral.api.entity.Device; |
|---|
| | | import com.moral.api.entity.Sensor; |
|---|
| | | import com.moral.api.mapper.DeviceMapper; |
|---|
| | | import com.moral.api.service.DeviceService; |
|---|
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|---|
| | | import com.moral.api.service.HistoryHourlyService; |
|---|
| | | import com.moral.constant.Constants; |
|---|
| | | import com.moral.constant.RedisConstants; |
|---|
| | | import com.moral.util.DateUtils; |
|---|
| | | |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.data.redis.core.RedisTemplate; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * <p> |
|---|
| | |
|---|
| | | @Autowired |
|---|
| | | DeviceMapper deviceMapper; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private RedisTemplate redisTemplate; |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<Device> getDevicesByMonitorPointId(Integer monitorPointId) { |
|---|
| | | QueryWrapper<Device> wrapper = new QueryWrapper(); |
|---|
| | | wrapper.eq("is_delete", Constants.NOT_DELETE); |
|---|
| | | wrapper.eq("monitor_point_id",monitorPointId); |
|---|
| | | wrapper.eq("is_delete", Constants.NOT_DELETE); |
|---|
| | | List<Device> devices = deviceMapper.selectList(wrapper); |
|---|
| | | return devices; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Map<String, Object> getSensorsByMac(String mac) { |
|---|
| | | //从redis中获取设备因子信息 |
|---|
| | | Device device = (Device) redisTemplate.opsForHash().get(RedisConstants.DEVICE_INFO, mac); |
|---|
| | | List<Sensor> sensors = device.getVersion().getSensors(); |
|---|
| | | Map<String, Object> result = new HashMap<>(); |
|---|
| | | for (Sensor sensor : sensors) { |
|---|
| | | String sensorCode = sensor.getCode(); |
|---|
| | | String name = sensor.getName(); |
|---|
| | | result.put(sensorCode, name); |
|---|
| | | } |
|---|
| | | return result; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<Map<String, Object>> getTrendChartData(Map<String, Object> params) { |
|---|
| | | Object type = params.get("type"); |
|---|
| | | String start = params.remove("time").toString(); |
|---|
| | | String end; |
|---|
| | | String timeUnits; |
|---|
| | | String dateFormat; |
|---|
| | | if ("day".equals(type)) { |
|---|
| | | end = DateUtils.getDateAddDay(start, 1); |
|---|
| | | timeUnits = "hourly"; |
|---|
| | | dateFormat = "%H"; |
|---|
| | | } else if ("month".equals(type)) { |
|---|
| | | end = DateUtils.getDateAddMonth(start, 1); |
|---|
| | | timeUnits = "daily"; |
|---|
| | | dateFormat = "%d"; |
|---|
| | | } else { |
|---|
| | | end = DateUtils.getDateAddYear(start, 1); |
|---|
| | | timeUnits = "monthly"; |
|---|
| | | dateFormat = "%m"; |
|---|
| | | } |
|---|
| | | params.put("dateFormat", dateFormat); |
|---|
| | | params.put("timeUnits", timeUnits); |
|---|
| | | params.put("start", start); |
|---|
| | | params.put("end", end); |
|---|
| | | return deviceMapper.getTrendChartData(params); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
