| | |
|---|
| | | package com.moral.controller;
|
|---|
| | |
|
|---|
| | | import java.math.BigDecimal;
|
|---|
| | | import java.text.SimpleDateFormat;
|
|---|
| | | import java.time.LocalDate;
|
|---|
| | | import java.time.LocalDateTime;
|
|---|
| | | import java.time.temporal.ChronoUnit;
|
|---|
| | | import java.time.temporal.TemporalAdjusters;
|
|---|
| | | import java.util.ArrayList;
|
|---|
| | | import java.util.Arrays;
|
|---|
| | | import java.util.Collections;
|
|---|
| | | import java.util.Comparator;
|
|---|
| | | import java.util.Date;
|
|---|
| | | import java.util.HashMap;
|
|---|
| | | import java.util.List;
|
|---|
| | | import java.util.Map;
|
|---|
| | |
|
|---|
| | | import javax.annotation.Resource;
|
|---|
| | | import javax.servlet.http.HttpServletRequest;
|
|---|
| | |
|
|---|
| | | import org.apache.commons.lang3.time.DateUtils;
|
|---|
| | | import org.springframework.util.ObjectUtils;
|
|---|
| | | import org.springframework.web.bind.annotation.GetMapping;
|
|---|
| | | import org.springframework.web.bind.annotation.RequestMapping;
|
|---|
| | | import org.springframework.web.bind.annotation.RestController;
|
|---|
| | |
|
|---|
| | | import com.alibaba.fastjson.JSON;
|
|---|
| | | import com.alibaba.fastjson.JSONObject;
|
|---|
| | | import com.moral.common.util.WebUtils;
|
|---|
| | | import com.moral.mapper.AlarmDailyMapper;
|
|---|
| | | import com.moral.mapper.DemoMapper;
|
|---|
| | | import com.moral.mapper.HistoryMapper;
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | @RestController
|
|---|
| | | @RequestMapping("demo")
|
|---|
| | | public class DemoConreoller {
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private DemoMapper demoMapper;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private AlarmDailyMapper alarmDailyMapper;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private HistoryMapper historyMapper;
|
|---|
| | |
|
|---|
| | | @GetMapping("list")
|
|---|
| | | public List<Map<String, Object>> getDatas(HttpServletRequest request){
|
|---|
| | | Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);
|
|---|
| | | parameters.put("size", Integer.valueOf(parameters.get("size").toString()));
|
|---|
| | | List<Map<String, Object>> list = demoMapper.getDatas(parameters);
|
|---|
| | | Collections.sort(list, new Comparator<Map<String, Object>>() {
|
|---|
| | | @Override
|
|---|
| | | public int compare(Map<String, Object> o1, Map<String, Object> o2) {
|
|---|
| | | return ((Date)o1.get("time")).compareTo((Date)o2.get("time"));
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | return list;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @GetMapping("pollution")
|
|---|
| | | public List<Map<String, Object>> getPollutionDatas(HttpServletRequest request){
|
|---|
| | | Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);
|
|---|
| | | Object sensorKey = parameters.get("sensorKey");
|
|---|
| | | parameters.put("sensorKeys", Arrays.asList(sensorKey));
|
|---|
| | | parameters.put("start", LocalDate.now().with(TemporalAdjusters.firstDayOfMonth()));
|
|---|
| | | parameters.put("end", LocalDate.now().with(TemporalAdjusters.firstDayOfNextMonth()));
|
|---|
| | | List<Map<String, Object>> alarmData = alarmDailyMapper.getAlarmData(parameters);
|
|---|
| | | Collections.sort(alarmData, new Comparator<Map<String, Object>>() {
|
|---|
| | | @Override
|
|---|
| | | public int compare(Map<String, Object> o1, Map<String, Object> o2) {
|
|---|
| | | return ((BigDecimal) o2.get(sensorKey)).compareTo((BigDecimal) o1.get(sensorKey));
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | return alarmData;
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | @GetMapping("compare")
|
|---|
| | | public List<Map<String, Object>> getCompareDatas(HttpServletRequest request){
|
|---|
| | | List<Map<String, Object>> thisMonth = getDatas(request);
|
|---|
| | | List<Date> timeList = new ArrayList<Date>();
|
|---|
| | | SimpleDateFormat simpleDateFormat = new SimpleDateFormat("dd日HH时");
|
|---|
| | | for (Map<String, Object> map : thisMonth) {
|
|---|
| | | timeList.add(DateUtils.addMonths((Date)map.get("time"), -1));
|
|---|
| | | JSONObject json = JSON.parseObject(map.remove("aqi_json").toString());
|
|---|
| | | map.put("this_month_PM2_5",json.get("PM2_5"));
|
|---|
| | | map.put("this_month_PM10",json.get("PM10"));
|
|---|
| | | map.put("format_time", simpleDateFormat.format((Date)map.get("time")));
|
|---|
| | | }
|
|---|
| | | Map<String, Object> parameters = new HashMap<String, Object>();
|
|---|
| | | parameters.put("timeList", timeList);
|
|---|
| | | List<Map<String, Object>> lastMonth = demoMapper.getDatas(parameters);
|
|---|
| | | for (Map<String, Object> map : thisMonth) {
|
|---|
| | | String formatTime = map.get("format_time").toString();
|
|---|
| | | for (Map<String, Object> last : lastMonth) {
|
|---|
| | | if (formatTime.equals(simpleDateFormat.format((Date)last.get("time")))) {
|
|---|
| | | JSONObject json = JSON.parseObject(last.remove("aqi_json").toString());
|
|---|
| | | map.put("last_month_PM2_5",json.get("PM2_5"));
|
|---|
| | | map.put("last_month_PM10",json.get("PM10"));
|
|---|
| | | lastMonth.remove(last);
|
|---|
| | | break;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | return thisMonth;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | *
|
|---|
| | | * 功能描述: |
|---|
| | | *
|
|---|
| | | * @param: startTime 开始时间
|
|---|
| | | * @param: endTime 结束时间
|
|---|
| | | * @return:
|
|---|
| | | * @author: fengxiang
|
|---|
| | | * @date: 2018/7/30 11:27
|
|---|
| | | */
|
|---|
| | | @GetMapping("get-dayaqis")
|
|---|
| | | public List<Map<String, Object>> getDayAqis(Date startTime,Date endTime) {
|
|---|
| | | return demoMapper.selectByTimeZones(startTime,endTime);
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | @GetMapping("avg")
|
|---|
| | | public Map<String, Object> getAvgDatas(HttpServletRequest request){
|
|---|
| | | Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);
|
|---|
| | | parameters.put("sensorKeys", Arrays.asList("e1", "e2", "e3", "e13"));
|
|---|
| | | LocalDateTime now = LocalDateTime.now();
|
|---|
| | | parameters.put("start", now.minusHours(1).truncatedTo(ChronoUnit.HOURS));
|
|---|
| | | parameters.put("end", now.truncatedTo(ChronoUnit.HOURS));
|
|---|
| | | List<Map<String, Object>> avgs = historyMapper.getAreaAllDataByAccount(parameters);
|
|---|
| | | if (ObjectUtils.isEmpty(avgs)) {
|
|---|
| | | return new HashMap<String, Object>();
|
|---|
| | | } else {
|
|---|
| | | return avgs.get(0);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
