| | |
|---|
| | | import com.moral.service.HistoryService;
|
|---|
| | | import com.moral.service.ProfessionService;
|
|---|
| | | import com.moral.util.AQICalculation;
|
|---|
| | |
|
|---|
| | | import com.moral.util.DatesUtil;
|
|---|
| | |
|
|---|
| | | import org.apache.commons.collections.CollectionUtils;
|
|---|
| | | import org.springframework.stereotype.Service;
|
|---|
| | | import org.springframework.util.ObjectUtils;
|
|---|
| | |
|---|
| | | }
|
|---|
| | | returnMap = AQICalculation.hourlyAQI(AQIMap);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | long aqi = Math.round(Double.valueOf(returnMap.get("AQI").toString()));
|
|---|
| | | returnMap.put("AQI",aqi);
|
|---|
| | | return returnMap;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|---|
| | | for (Map.Entry<String, Object> entry : map.entrySet()) {
|
|---|
| | | for (Sensor sensor : sensors) {
|
|---|
| | | if (sensor.getSensorKey().equals(entry.getKey())) {
|
|---|
| | | mapAvg.put(entry.getKey(), new BigDecimal(entry.getValue().toString().replace("\"", "")).stripTrailingZeros().toPlainString() + sensor.getUnit());
|
|---|
| | | if (entry.getValue() != null) {
|
|---|
| | | mapAvg.put(entry.getKey(), new BigDecimal(entry.getValue().toString().replace("\"", "")).stripTrailingZeros().toPlainString() + sensor.getUnit());
|
|---|
| | | }
|
|---|
| | | } else if (("min" + sensor.getSensorKey()).equals(entry.getKey())) {
|
|---|
| | | mapMin.put(entry.getKey().substring(3), new BigDecimal(entry.getValue().toString().replace("\"", "")).stripTrailingZeros().toPlainString());
|
|---|
| | | } else if (("max" + sensor.getSensorKey()).equals(entry.getKey())) {
|
|---|
| | |
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public List<Map<String,Object>> getO3AVG(Map<String, Object> parameters) {
|
|---|
| | | String mac= (String) parameters.get("mac");
|
|---|
| | | String stime= (String) parameters.get("time");
|
|---|
| | | SimpleDateFormat format=new SimpleDateFormat("yyyy-MM");
|
|---|
| | | public List<Map<String, Object>> getUavSensorData(Map<String, Object> parameters) {
|
|---|
| | | List<Sensor> sensors = sensorMapper.getSensorsByMac(parameters);
|
|---|
| | | List<String> sensorKeys = new ArrayList<>();
|
|---|
| | | for (Sensor sensor : sensors) {
|
|---|
| | | sensorKeys.add(sensor.getSensorKey());
|
|---|
| | | }
|
|---|
| | | parameters.put("sensorKeys", sensorKeys);
|
|---|
| | | List<Map<String, Object>> uavSensorData = historyMapper.getUavSensorData(parameters);
|
|---|
| | | for (Map<String, Object> dataMap : uavSensorData) {
|
|---|
| | | for (Map.Entry<String, Object> entry : dataMap.entrySet()) {
|
|---|
| | | for (Sensor sensor : sensors) {
|
|---|
| | | if (sensor.getSensorKey().equals(entry.getKey())) {
|
|---|
| | | if (entry.getValue() != null) {
|
|---|
| | | dataMap.put(entry.getKey(), new BigDecimal(entry.getValue().toString().replace("\"", "")).stripTrailingZeros().toPlainString() + sensor.getUnit());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | Map<String, Object> map = sensorMapper.getSensorBySensorKey(parameters.get("sensorKey").toString());
|
|---|
| | | parameters.put("unit", map.get("unit"));
|
|---|
| | | parameters.put("description", map.get("description"));
|
|---|
| | | return uavSensorData;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public List<Map<String, Object>> getO3AVG(Map<String, Object> parameters) {
|
|---|
| | | String mac = (String) parameters.get("mac");
|
|---|
| | | String stime = (String) parameters.get("time");
|
|---|
| | | SimpleDateFormat format = new SimpleDateFormat("yyyy-MM");
|
|---|
| | | Date time = null;
|
|---|
| | | try {
|
|---|
| | | time = format.parse(stime);
|
|---|
| | |
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | List<String> stringListDate = DatesUtil.getAllTheDateOftheMonth(time);
|
|---|
| | | List<Map<String,Object>> maxList=new ArrayList<Map<String,Object>>();
|
|---|
| | | List<Map<String, Object>> maxList = new ArrayList<Map<String, Object>>();
|
|---|
| | | for (String date : stringListDate) {
|
|---|
| | | System.out.println("------------------------------------------------");
|
|---|
| | | Map<String, Object> parm = new HashMap<String, Object>();
|
|---|
| | | DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
|---|
| | | LocalDateTime time1 = LocalDateTime.parse(date + " 00:00:00", df);
|
|---|
| | | LocalDateTime time2 = time1.plusDays(1);
|
|---|
| | | String time3 = time2.toString().substring(0, 10);
|
|---|
| | | String nextDate = time3 + " 07:00:00";
|
|---|
| | | System.out.println("-----"+date);
|
|---|
| | | System.out.println(nextDate);
|
|---|
| | | parm.put("date", date);
|
|---|
| | | parm.put("nextDate", nextDate);
|
|---|
| | | parm.put("mac", mac);
|
|---|
| | | List<Map<String, Object>> listMap = historyMapper.getO3AVG(parm);
|
|---|
| | | System.out.println("size="+listMap.size());
|
|---|
| | | List list=new ArrayList();
|
|---|
| | | DatesUtil.getList(listMap,list);
|
|---|
| | | List list1=new ArrayList();
|
|---|
| | | String maxO3="";
|
|---|
| | | for (int i = 0; i <list.size() ; i++) {
|
|---|
| | | List elist=new ArrayList();
|
|---|
| | | List tlist=new ArrayList();
|
|---|
| | | Double sum=0.0;
|
|---|
| | | Double avg=0.0;
|
|---|
| | | for (Object o : (List)list.get(i)) {
|
|---|
| | | Iterator<Map.Entry> iterator= ((Map)o).entrySet().iterator();
|
|---|
| | | while(iterator.hasNext()) {
|
|---|
| | | List list = new ArrayList();
|
|---|
| | | DatesUtil.getList(listMap, list);
|
|---|
| | | List list1 = new ArrayList();
|
|---|
| | | String maxO3 = "";
|
|---|
| | | for (int i = 0; i < list.size(); i++) {
|
|---|
| | | List elist = new ArrayList();
|
|---|
| | | Double sum = 0.0;
|
|---|
| | | Double avg = 0.0;
|
|---|
| | | for (Object o : (List) list.get(i)) {
|
|---|
| | | Iterator<Map.Entry> iterator = ((Map) o).entrySet().iterator();
|
|---|
| | | while (iterator.hasNext()) {
|
|---|
| | | Map.Entry entry = iterator.next();
|
|---|
| | | if (entry.getKey().equals("e15")){
|
|---|
| | | if (entry.getKey().equals("e15")) {
|
|---|
| | | elist.add(entry.getValue());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | for (int j = 0; j <elist.size(); j++) {
|
|---|
| | | sum+=Double.parseDouble((String) elist.get(j));
|
|---|
| | | if (listMap.size()<=8 && listMap.size()>0){
|
|---|
| | | avg=sum/listMap.size();
|
|---|
| | | }else {
|
|---|
| | | avg=sum/8;
|
|---|
| | | for (int j = 0; j < elist.size(); j++) {
|
|---|
| | | sum += Double.parseDouble((String) elist.get(j));
|
|---|
| | | if (listMap.size() <= 8 && listMap.size() > 0) {
|
|---|
| | | avg = sum / listMap.size();
|
|---|
| | | } else {
|
|---|
| | | avg = sum / 8;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | if (avg==0.0){
|
|---|
| | | if (avg == 0.0) {
|
|---|
| | | list1.add("");
|
|---|
| | | }else {
|
|---|
| | | } else {
|
|---|
| | | BigDecimal b = new BigDecimal(avg);
|
|---|
| | | double avg1 = b.setScale(4,BigDecimal.ROUND_HALF_UP).doubleValue();
|
|---|
| | | double avg1 = b.setScale(4, BigDecimal.ROUND_HALF_UP).doubleValue();
|
|---|
| | | list1.add(avg1);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | System.out.println(list1);
|
|---|
| | |
|
|---|
| | | String timef=date+" 00:00:00";
|
|---|
| | | String timea=date+" 23:59:59";
|
|---|
| | | int num=historyMapper.getNum(timef,timea);
|
|---|
| | | if (num==0) {
|
|---|
| | | String timef = date + " 00:00:00";
|
|---|
| | | String timea = date + " 23:59:59";
|
|---|
| | | int num = historyMapper.getNum(timef, timea);
|
|---|
| | | if (num == 0) {
|
|---|
| | | maxO3 = "";
|
|---|
| | | }else {
|
|---|
| | | if (list1.size()!=0){
|
|---|
| | | maxO3= ""+ Collections.max(list1);
|
|---|
| | | }else {
|
|---|
| | | maxO3="";
|
|---|
| | | }}
|
|---|
| | | Map<String,Object> avgMap=new HashMap<String,Object>();
|
|---|
| | | avgMap.put("time",date);
|
|---|
| | | avgMap.put("e15",maxO3);
|
|---|
| | | } else {
|
|---|
| | | if (list1.size() != 0) {
|
|---|
| | | maxO3 = "" + Collections.max(list1);
|
|---|
| | | } else {
|
|---|
| | | maxO3 = "";
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | Map<String, Object> avgMap = new HashMap<String, Object>();
|
|---|
| | | avgMap.put("time", date);
|
|---|
| | | avgMap.put("e15", maxO3);
|
|---|
| | | maxList.add(avgMap);
|
|---|
| | | }
|
|---|
| | | return maxList;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public String getJsonData(String mac, String time,String table) {
|
|---|
| | | return historyMapper.getJsonData(mac,time,table);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
