/*
|
* Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
|
*
|
* Redistribution and use in source and binary forms, with or without
|
* modification, are permitted provided that the following conditions are met:
|
*
|
* Redistributions of source code must retain the above copyright notice,
|
* this list of conditions and the following disclaimer.
|
* Redistributions in binary form must reproduce the above copyright
|
* notice, this list of conditions and the following disclaimer in the
|
* documentation and/or other materials provided with the distribution.
|
* Neither the name of the dreamlu.net developer nor the names of its
|
* contributors may be used to endorse or promote products derived from
|
* this software without specific prior written permission.
|
* Author: Chill 庄骞 (smallchill@163.com)
|
*/
|
package org.springblade.modules.regionWeight.controller;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import io.reactivex.Observable;
|
import io.swagger.annotations.*;
|
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
|
import lombok.AllArgsConstructor;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import javax.validation.Valid;
|
import java.io.*;
|
import java.text.SimpleDateFormat;
|
import java.util.Map.Entry;
|
|
import org.apache.poi.hssf.usermodel.*;
|
import org.apache.poi.ss.usermodel.Row;
|
import org.apache.poi.ss.usermodel.Sheet;
|
import org.apache.poi.ss.usermodel.Workbook;
|
import org.python.util.PythonInterpreter;
|
import org.springblade.core.excel.util.ExcelUtil;
|
import org.springblade.core.log.annotation.ApiLog;
|
import org.springblade.core.mp.support.Condition;
|
import org.springblade.core.mp.support.Query;
|
import org.springblade.core.secure.BladeUser;
|
import org.springblade.core.secure.utils.AuthUtil;
|
import org.springblade.core.tool.api.R;
|
import org.springblade.core.tool.constant.BladeConstant;
|
import org.springblade.core.tool.utils.DateUtil;
|
import org.springblade.core.tool.utils.Func;
|
import org.springblade.modules.regionWeight.excel.regionExcel;
|
import org.springblade.modules.system.entity.User;
|
import org.springblade.modules.system.excel.UserExcel;
|
import org.springframework.aop.support.JdkRegexpMethodPointcut;
|
import org.springframework.web.bind.annotation.*;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import org.springblade.modules.regionWeight.entity.RegionWeight;
|
import org.springblade.modules.regionWeight.vo.RegionWeightVO;
|
import org.springblade.modules.regionWeight.service.IRegionWeightService;
|
import org.springblade.core.boot.ctrl.BladeController;
|
import springfox.documentation.annotations.ApiIgnore;
|
|
import java.math.BigDecimal;
|
import java.util.*;
|
|
/**
|
* 控制器
|
*
|
* @author BladeX
|
* @since 2021-05-12
|
*/
|
@RestController
|
@AllArgsConstructor
|
@RequestMapping("regionWeight/regionweight")
|
@Api(value = "", tags = "接口")
|
public class RegionWeightController extends BladeController {
|
|
private final IRegionWeightService regionWeightService;
|
|
/**
|
* 详情
|
*/
|
@GetMapping("/detail")
|
@ApiOperationSupport(order = 1)
|
@ApiOperation(value = "详情", notes = "传入regionWeight")
|
public R<RegionWeight> detail(RegionWeight regionWeight) {
|
RegionWeight detail = regionWeightService.getOne(Condition.getQueryWrapper(regionWeight));
|
return R.data(detail);
|
}
|
|
/**
|
* 分页
|
*/
|
@GetMapping("/list")
|
@ApiOperationSupport(order = 2)
|
@ApiOperation(value = "分页", notes = "传入regionWeight")
|
public R<IPage<RegionWeight>> list(RegionWeight regionWeight, Query query) {
|
IPage<RegionWeight> pages = regionWeightService.page(Condition.getPage(query), Condition.getQueryWrapper(regionWeight));
|
return R.data(pages);
|
}
|
|
/**
|
* 自定义分页
|
*/
|
@GetMapping("/page")
|
@ApiOperationSupport(order = 3)
|
@ApiOperation(value = "分页", notes = "传入regionWeight")
|
public R<IPage<RegionWeightVO>> page(RegionWeightVO regionWeight, Query query, Long deptId) {
|
IPage<RegionWeightVO> pages = null;
|
if (deptId == null || deptId == 361000) {
|
deptId = null;
|
pages = regionWeightService.selectRegionWeightPage(Condition.getPage(query), regionWeight, deptId);
|
} else {
|
int length = deptId.toString().length();
|
if (length == 6) {
|
pages = regionWeightService.selectRegionWeights(Condition.getPage(query), regionWeight, deptId);
|
} else {
|
pages = regionWeightService.selectRegionWeightPage(Condition.getPage(query), regionWeight, deptId);
|
}
|
}
|
|
return R.data(pages);
|
}
|
|
/**
|
* 新增
|
*/
|
@PostMapping("/save")
|
@ApiOperationSupport(order = 4)
|
@ApiOperation(value = "新增", notes = "传入regionWeight")
|
public R save(@Valid @RequestBody RegionWeight regionWeight) {
|
return R.status(regionWeightService.save(regionWeight));
|
}
|
|
/**
|
* 修改
|
*/
|
@PostMapping("/update")
|
@ApiOperationSupport(order = 5)
|
@ApiOperation(value = "修改", notes = "传入regionWeight")
|
public R update(@Valid @RequestBody RegionWeight regionWeight) {
|
return R.status(regionWeightService.updateById(regionWeight));
|
}
|
|
/**
|
* 新增或修改
|
*/
|
@PostMapping("/submit")
|
@ApiOperationSupport(order = 6)
|
@ApiOperation(value = "新增或修改", notes = "传入regionWeight")
|
public R submit(@Valid @RequestBody RegionWeight regionWeight) {
|
return R.status(regionWeightService.saveOrUpdate(regionWeight));
|
}
|
|
|
/**
|
* 删除
|
*/
|
@PostMapping("/remove")
|
@ApiOperationSupport(order = 8)
|
@ApiOperation(value = "删除", notes = "传入ids")
|
public R remove(@ApiParam(value = "主键集合", required = true) @RequestParam String ids) {
|
return R.status(regionWeightService.removeByIds(Func.toLongList(ids)));
|
}
|
|
/**
|
* 懒加载树形结构
|
*/
|
@GetMapping("/lazy-tree")
|
public R<List<RegionWeightVO>> lazyTree(String code) {
|
List<RegionWeightVO> tree = regionWeightService.lazyTree(code);
|
return R.data(tree);
|
}
|
|
/**
|
* 面降雨量
|
*/
|
@GetMapping("/selectReM")
|
public R selectReM(String beginTime, String endTime) {
|
String substring = beginTime.substring(0, 10);
|
String r = beginTime.substring(11, 13);
|
//截取月日
|
String[] strs = substring.split("-");
|
//月
|
String year = strs[1].toString();
|
//日
|
String day = strs[2].toString();
|
String substrings = endTime.substring(0, 10);
|
String rs = endTime.substring(11, 13);
|
//截取月日
|
String[] strss = substrings.split("-");
|
//月
|
String years = strss[1].toString();
|
//日
|
String days = strss[2].toString();
|
String yday = year + "月" + day + "日" + r + "时-" + years + "月" + days + "日" + rs + "时。";
|
//最新雨量值
|
List<Map<String, Object>> map = regionWeightService.selectReM(beginTime, endTime);
|
List<Map<String, Object>> mapAll = regionWeightService.selectAll();
|
//权重值
|
List<Map<String, Object>> list = regionWeightService.selectWeight();
|
Map map1 = new HashMap();
|
Map mapc = new HashMap();
|
List<Map<String, Object>> list1 = new ArrayList<Map<String, Object>>();
|
List<Map<String, Object>> lists = new ArrayList<Map<String, Object>>();
|
List<Map<String, Object>> listc = new ArrayList<Map<String, Object>>();
|
double v = 0;
|
//统计抚州市雨量
|
Double num = 0.0;
|
String region_code = null;
|
if (map.size() == 0) {
|
List<Map<String, Object>> l = new ArrayList<Map<String, Object>>();
|
List<Map<String, Object>> m = new ArrayList<Map<String, Object>>();
|
mapc.put("List", l);
|
mapc.put("Num", m);
|
mapc.put("text", yday + "暂无降雨信息。");
|
lists.add(mapc);
|
} else {
|
for (int i = 0; i < map.size(); i++) {
|
region_code = map.get(i).get("REGION_CODE").toString();
|
//获取行政区编码
|
if (i != 0) {
|
String region_code1 = map.get(i - 1).get("REGION_CODE").toString();
|
if (!region_code.equals(region_code1)) {
|
map1.put("id", region_code1);
|
map1.put("value", v);
|
list1.add(map1);
|
v = 0;
|
map1 = new HashMap();
|
for (int j = 0; j < list.size(); j++) {
|
if (region_code.equals(list.get(j).get("STATION_CODE").toString())) {
|
BigDecimal bigDecimaldrp = (BigDecimal) map.get(i).get("DRP");
|
double drp = bigDecimaldrp.floatValue();
|
String weight1 = map.get(i).get("WEIGHT").toString();
|
float weight = Float.parseFloat(weight1);
|
v += drp * weight;
|
break;
|
}
|
}
|
} else {
|
for (int j = 0; j < list.size(); j++) {
|
if (region_code.equals(list.get(j).get("STATION_CODE").toString())) {
|
BigDecimal bigDecimaldrp = (BigDecimal) map.get(i).get("DRP");
|
double drp = bigDecimaldrp.floatValue();
|
String weight1 = map.get(i).get("WEIGHT").toString();
|
float weight = Float.parseFloat(weight1);
|
System.out.println(Math.round(drp));
|
v += drp * weight;
|
break;
|
}
|
}
|
}
|
} else {
|
for (int j = 0; j < list.size(); j++) {
|
if (region_code.equals(list.get(j).get("STATION_CODE").toString())) {
|
BigDecimal bigDecimaldrp = (BigDecimal) map.get(i).get("DRP");
|
double drp = bigDecimaldrp.floatValue();
|
String weight1 = map.get(i).get("WEIGHT").toString();
|
float weight = Float.parseFloat(weight1);
|
System.out.println(Math.round(drp));
|
v += drp * weight;
|
break;
|
}
|
}
|
}
|
}
|
map1.put("id", region_code);
|
map1.put("value", v);
|
list1.add(map1);
|
Map<String, Object> result1 = new HashMap<String, Object>();
|
//县/区面雨量值
|
for (Map<String, Object> maps : list1) {
|
String id = maps.get("id").toString();
|
Double value = Double.parseDouble(maps.get("value").toString());
|
if (result1.containsKey(id)) {
|
Double temp = Double.parseDouble(result1.get(id).toString());
|
value += temp;
|
}
|
result1.put(id, value);
|
}
|
//计算市的面雨量
|
for (String k : result1.keySet()) {
|
for (int c = 0; c < list.size(); c++) {
|
if (k.equals(list.get(c).get("STATION_CODE").toString())) {
|
String s = result1.get(k).toString();
|
Double w = Double.parseDouble(s);
|
String weight = list.get(c).get("WEIGHT").toString();
|
Double weights = Double.parseDouble(weight);
|
double v1 = w * weights;
|
num += v1;
|
} else {
|
continue;
|
}
|
|
}
|
}
|
// 排序
|
List<Map.Entry<String, Object>> entryList2 = new ArrayList<Map.Entry<String, Object>>(result1.entrySet());
|
Collections.sort(entryList2, new Comparator<Map.Entry<String, Object>>() {
|
@Override
|
public int compare(Entry<String, Object> me1, Entry<String, Object> me2) {
|
return me2.getValue().toString().compareTo(me1.getValue().toString()); // 升序排序
|
}
|
});
|
//拼接前3位降雨最大的区域
|
double v3 = (double) Math.round(num * 10) / 10;
|
String text = "抚州市降雨:" + v3 + "(毫米)。 ";
|
String text1 = "前三降雨量的是: ";
|
String tx = "";
|
for (int i = 0; i < entryList2.size(); i++) {
|
Map mapa = new HashMap();
|
String codes = entryList2.get(i).getKey();
|
String values = entryList2.get(i).getValue().toString();
|
Double a = Double.parseDouble(values);
|
double as = (double) Math.round(a * 10) / 10;
|
for (int j = 0; j < list.size(); j++) {
|
if (codes.equals(list.get(j).get("STATION_CODE").toString())) {
|
String station_name = list.get(j).get("STATION_NAME").toString();
|
mapa.put("region", station_name);
|
mapa.put("dyp", as);
|
listc.add(mapa);
|
if (i < 3) {
|
tx += station_name + "降雨量为：" + as + "(毫米),";
|
}
|
}
|
|
}
|
}
|
mapc.put("List", listc);
|
mapc.put("Num", mapAll);
|
mapc.put("text", yday + text);
|
lists.add(mapc);
|
}
|
return R.data(lists);
|
}
|
|
|
/**
|
* 点降雨量(时段降雨,自定义降雨)
|
*
|
* @param beginTime
|
* @param endTime
|
* @return
|
*/
|
@GetMapping("/selectReD")
|
public R selectReD(String beginTime, String endTime) {
|
String substring = beginTime.substring(0, 10);
|
String r = beginTime.substring(11, 13);
|
//截取月日
|
String[] strs = substring.split("-");
|
//月
|
String year = strs[1].toString();
|
//日
|
String day = strs[2].toString();
|
String substrings = endTime.substring(0, 10);
|
String rs = endTime.substring(11, 13);
|
//截取月日
|
String[] strss = substrings.split("-");
|
//月
|
String years = strss[1].toString();
|
//日
|
String days = strss[2].toString();
|
List<Map<String, Object>> maps = regionWeightService.selectYjs(beginTime, endTime);
|
List<Map<String, Object>> lists = new ArrayList<>();
|
Map<String, Object> map = new HashMap<String, Object>();
|
String text = "";
|
String yday = year + "月" + day + "日" + r + "时-" + years + "月" + days + "日" + rs + "时。";
|
//0-10降雨量范围
|
List lista = new ArrayList<>();
|
//10-25降雨量范围
|
List listb = new ArrayList<>();
|
//25-50降雨量范围
|
List listc = new ArrayList<>();
|
//50-100降雨量范围
|
List listd = new ArrayList<>();
|
//100-250降雨量范围
|
List liste = new ArrayList<>();
|
//250降雨量范围
|
List listf = new ArrayList<>();
|
for (int i = 0; i < maps.size(); i++) {
|
if (i < 3) {
|
String addvnm = maps.get(i).get("ADDVNM").toString();
|
String stnm = maps.get(i).get("STNM").toString();
|
BigDecimal bigDecimaldyp = (BigDecimal) maps.get(i).get("dyp");//日雨量
|
double dyp = bigDecimaldyp.doubleValue();
|
if (dyp > 0 && dyp <= 10) {
|
lista.add(maps.get(i));
|
} else if (dyp > 10 && dyp <= 25) {
|
listb.add(maps.get(i));
|
} else if (dyp > 25 && dyp <= 50) {
|
listc.add(maps.get(i));
|
} else if (dyp > 50 && dyp <= 100) {
|
listd.add(maps.get(i));
|
} else if (dyp > 100 && dyp <= 250) {
|
liste.add(maps.get(i));
|
} else if (dyp > 250) {
|
listf.add(maps.get(i));
|
}
|
text += stnm + "站" + dyp + "毫米,";
|
} else {
|
BigDecimal bigDecimaldyp = (BigDecimal) maps.get(i).get("dyp");//日雨量
|
double dyp = bigDecimaldyp.doubleValue();
|
if (dyp > 0 && dyp <= 10) {
|
lista.add(maps.get(i));
|
} else if (dyp > 10 && dyp <= 25) {
|
listb.add(maps.get(i));
|
} else if (dyp > 25 && dyp <= 50) {
|
listc.add(maps.get(i));
|
} else if (dyp > 50 && dyp <= 100) {
|
listd.add(maps.get(i));
|
} else if (dyp > 100 && dyp <= 250) {
|
liste.add(maps.get(i));
|
} else if (dyp > 250) {
|
listf.add(maps.get(i));
|
}
|
}
|
}
|
//0-10
|
map.put("one", lista);
|
//10-25
|
map.put("two", listb);
|
//25-50
|
map.put("three", listc);
|
//50-100
|
map.put("four", listd);
|
//100-250
|
map.put("five", liste);
|
//250
|
map.put("six", listf);
|
String a = "";
|
if (maps.size() == 0) {
|
a = yday + "暂无降雨信息。";
|
} else {
|
a = yday + "点降雨量前三为:" + text.substring(0, text.length() - 1) + "。";
|
}
|
map.put("text", a);
|
lists.add(map);
|
String fileName = "";
|
// 第一步，创建一个webbook，对应一个Excel文件
|
HSSFWorkbook wb = new HSSFWorkbook();
|
// 第二步，在webbook中添加一个sheet,对应Excel文件中的sheet
|
HSSFSheet sheet = wb.createSheet("雨量表");
|
// 第三步，在sheet中添加表头第0行,注意老版本poi对Excel的行数列数有限制short
|
HSSFRow row = sheet.createRow((int) 0);
|
// 第四步，创建单元格，并设置值表头 设置表头居中
|
HSSFCellStyle style = wb.createCellStyle();
|
//style.setAlignment(HSSFCellStyle.ALIGN_CENTER); // 创建一个居中格式
|
HSSFCell cell = row.createCell((short) 0);
|
cell.setCellValue("lon");
|
cell = row.createCell((short) 1);
|
cell.setCellValue("lat");
|
cell = row.createCell((short) 2);
|
cell.setCellValue("rain");
|
for (int i = 0; i < maps.size(); i++) {
|
// 第四步，创建单元格，并设置值
|
row = sheet.createRow((int) i + 1);
|
HSSFCell celli = row.createCell((short) 0);
|
row.createCell((short) 0).setCellValue(maps.get(i).get("LGTD").toString());
|
row.createCell((short) 1).setCellValue(maps.get(i).get("LTTD").toString());
|
row.createCell((short) 2).setCellValue(maps.get(i).get("dyp").toString());
|
}
|
// 第六步，将文件存到指定位置
|
try {
|
fileName = "D:/pptnd.xlsx";
|
FileOutputStream fout = new FileOutputStream(fileName);
|
wb.write(fout);
|
fout.close();
|
wb.close();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
Process proc;
|
try {
|
proc = Runtime.getRuntime().exec("python D:\\fz\\fz.py");
|
BufferedReader in = new BufferedReader(new InputStreamReader(proc.getInputStream()));
|
String line = null;
|
while ((line = in.readLine()) != null) {
|
System.out.println(line);
|
}
|
in.close();
|
proc.waitFor();
|
} catch (IOException e) {
|
e.printStackTrace();
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
return R.data(lists);
|
}
|
|
|
/**
|
* 流域
|
*/
|
@GetMapping("/selectReL")
|
public R selectReL(String beginTime, String endTime) {
|
String substring = beginTime.substring(0, 10);
|
String r = beginTime.substring(11, 13);
|
//截取月日
|
String[] strs = substring.split("-");
|
//月
|
String year = strs[1].toString();
|
//日
|
String day = strs[2].toString();
|
String substrings = endTime.substring(0, 10);
|
String rs = endTime.substring(11, 13);
|
//截取月日
|
String[] strss = substrings.split("-");
|
//月
|
String years = strss[1].toString();
|
//日
|
String days = strss[2].toString();
|
String yday = year + "月" + day + "日" + r + "时-" + years + "月" + days + "日" + rs + "时。";
|
String text = "";
|
//最新雨量值
|
List<Map<String, Object>> map = regionWeightService.selectReL(beginTime, endTime);
|
//权重值
|
List<Map<String, Object>> list = regionWeightService.selectWeights();
|
List<Map<String, Object>> list2 = regionWeightService.selectLALL();
|
List<Map<String, Object>> list3 = regionWeightService.selectLNam();
|
Map mc = new HashMap();
|
for (int a = 0; a < list2.size(); a++) {
|
for (int b = 0; b < list3.size(); b++) {
|
String code = list2.get(a).get("code").toString();
|
String num = list2.get(a).get("num").toString();
|
String code1 = list3.get(b).get("code").toString();
|
if (code.equals(code1)) {
|
mc.put(list3.get(b).get("cname").toString(), num);
|
}
|
}
|
}
|
Map map1 = new HashMap();
|
Map mapc = new HashMap();
|
List<Map<String, Object>> list1 = new ArrayList<Map<String, Object>>();
|
List<Map<String, Object>> lists = new ArrayList<Map<String, Object>>();
|
List<Map<String, Object>> listc = new ArrayList<Map<String, Object>>();
|
double v = 0;
|
//统计抚州市雨量
|
Double num = 0.0;
|
String region_code = null;
|
if (map.size() == 0) {
|
List<Map<String, Object>> l = new ArrayList<Map<String, Object>>();
|
List<Map<String, Object>> m = new ArrayList<Map<String, Object>>();
|
mapc.put("List", l);
|
mapc.put("Num", m);
|
mapc.put("text", yday + "暂无流域信息。");
|
lists.add(mapc);
|
} else {
|
for (int i = 0; i < map.size(); i++) {
|
region_code = map.get(i).get("REGION_CODE").toString();
|
//获取行政区编码
|
if (i != 0) {
|
String region_code1 = map.get(i - 1).get("REGION_CODE").toString();
|
if (!region_code.equals(region_code1)) {
|
map1.put("id", region_code1);
|
map1.put("value", v);
|
list1.add(map1);
|
v = 0;
|
map1 = new HashMap();
|
for (int j = 0; j < list.size(); j++) {
|
if (region_code.equals(list.get(j).get("STATION_CODE").toString())) {
|
BigDecimal bigDecimaldrp = (BigDecimal) map.get(i).get("DRP");
|
double drp = bigDecimaldrp.floatValue();
|
String weight1 = map.get(i).get("WEIGHT").toString();
|
float weight = Float.parseFloat(weight1);
|
v += drp * weight;
|
break;
|
}
|
}
|
} else {
|
for (int j = 0; j < list.size(); j++) {
|
if (region_code.equals(list.get(j).get("STATION_CODE").toString())) {
|
BigDecimal bigDecimaldrp = (BigDecimal) map.get(i).get("DRP");
|
double drp = bigDecimaldrp.floatValue();
|
String weight1 = map.get(i).get("WEIGHT").toString();
|
float weight = Float.parseFloat(weight1);
|
v += drp * weight;
|
break;
|
}
|
}
|
}
|
} else {
|
for (int j = 0; j < list.size(); j++) {
|
if (region_code.equals(list.get(j).get("STATION_CODE").toString())) {
|
BigDecimal bigDecimaldrp = (BigDecimal) map.get(i).get("DRP");
|
double drp = bigDecimaldrp.floatValue();
|
String weight1 = map.get(i).get("WEIGHT").toString();
|
float weight = Float.parseFloat(weight1);
|
v += drp * weight;
|
break;
|
}
|
}
|
}
|
}
|
map1.put("id", region_code);
|
map1.put("value", v);
|
list1.add(map1);
|
Map<String, Object> result1 = new HashMap<String, Object>();
|
//县/区面雨量值
|
for (Map<String, Object> maps : list1) {
|
String id = maps.get("id").toString();
|
Double value = Double.parseDouble(maps.get("value").toString());
|
if (result1.containsKey(id)) {
|
Double temp = Double.parseDouble(result1.get(id).toString());
|
value += temp;
|
}
|
result1.put(id, value);
|
}
|
// 排序
|
List<Map.Entry<String, Object>> entryList2 = new ArrayList<Map.Entry<String, Object>>(result1.entrySet());
|
Collections.sort(entryList2, new Comparator<Map.Entry<String, Object>>() {
|
@Override
|
public int compare(Entry<String, Object> me1, Entry<String, Object> me2) {
|
return me2.getValue().toString().compareTo(me1.getValue().toString()); // 升序排序
|
}
|
});
|
for (int i = 0; i < entryList2.size(); i++) {
|
Map mapa = new HashMap();
|
String codes = entryList2.get(i).getKey();
|
String values = entryList2.get(i).getValue().toString();
|
Double a = Double.parseDouble(values);
|
double as = (double) Math.round(a * 10) / 10;
|
for (int j = 0; j < list.size(); j++) {
|
if (codes.equals(list.get(j).get("STATION_CODE").toString())) {
|
String station_name = list.get(j).get("STATION_NAME").toString();
|
mapa.put("region", station_name);
|
mapa.put("dyp", as);
|
listc.add(mapa);
|
}
|
|
}
|
}
|
Collections.sort(listc, new Comparator<Map<String, Object>>() {
|
public int compare(Map<String, Object> o1, Map<String, Object> o2) {
|
return (Double) o1.get("dyp") < (Double) o2.get("dyp") ? 1 : ((Double) o1.get("dyp") == (Double) o2.get("dyp") ? 0 : -1);
|
}
|
});
|
for (int c = 0; c < listc.size(); c++) {
|
if (c < 3) {
|
text += listc.get(c).get("region").toString() + ":" + listc.get(c).get("dyp") + "(毫米),";
|
}
|
}
|
String a = "流域前三的为：" + text.substring(0, text.length() - 1) + "。";
|
mapc.put("List", listc);
|
mapc.put("Num", mc);
|
mapc.put("text", yday + a);
|
lists.add(mapc);
|
}
|
return R.data(lists);
|
}
|
|
/**
|
* @param type 类型 0：实时 1 历史
|
* @param timez 当前时间 yyyy-MM-dd HH:00:00
|
* @param dateBegins1 前一小时
|
* @param dateBegins3 前三小时
|
* @param dateBegins6 前六小时
|
* @param timet 当天的8点 yyyy-MM-dd 08:00:00
|
* @return
|
*/
|
@ApiLog("雨量预警")
|
@GetMapping("/pptnYj")
|
public R selectcInfos(int type, String timez, String dateBegins1, String dateBegins3, String dateBegins6, String timet, int k) {
|
if (type == 0 && k == 13) {
|
//当前时间
|
String time = timez;
|
|
//当天的8点
|
String times = timet;
|
|
//查询前一小时数据
|
String dateBegin1 = dateBegins1;
|
|
//三个小时前的时间
|
String dateBegin3 = dateBegins3;
|
|
//六个小时前的时间
|
String dateBegin6 = dateBegins6;
|
|
List<Map<String, Object>> maps = regionWeightService.selectppyj(time, dateBegin1, dateBegin3, dateBegin6, times);
|
List<Map<String, Object>> lists = new ArrayList<>();
|
for (int i = 0; i < maps.size(); i++) {
|
Map<String, Object> map = new HashMap<String, Object>();
|
BigDecimal bigDecimaldrp1 = (BigDecimal) maps.get(i).get("drp1");//1小时
|
BigDecimal bigDecimaldrp3 = (BigDecimal) maps.get(i).get("drp3");//3小时
|
BigDecimal bigDecimaldrp6 = (BigDecimal) maps.get(i).get("drp6");//6小时
|
BigDecimal bigDecimaldyp = (BigDecimal) maps.get(i).get("dyp");//日雨量
|
double drp1 = bigDecimaldrp1.doubleValue();
|
double drp3 = bigDecimaldrp3.doubleValue();
|
double drp6 = bigDecimaldrp6.doubleValue();
|
double dyp = bigDecimaldyp.doubleValue();
|
if (drp1 >= 30 || drp3 >= 50 || drp6 >= 80 || dyp >= 80) {
|
maps.get(i).put("YJ", "一级预警");
|
} else if (drp1 >= 50 || drp3 >= 80 || drp6 >= 100 || dyp >= 100) {
|
maps.get(i).put("YJ", "二级预警");
|
} else if (drp1 >= 80 || drp3 >= 100 || drp6 >= 120 || dyp >= 120) {
|
maps.get(i).put("YJ", "三级预警");
|
} else {
|
maps.get(i).put("YJ", "无预警");
|
}
|
map.put("YjList", maps.get(i));
|
lists.add(map);
|
}
|
return R.data(lists);
|
} else {
|
//当前时间
|
String time = timez;
|
|
//当天的8点
|
String times = timet;
|
|
//查询前一小时数据
|
String dateBegin1 = dateBegins1;
|
|
//三个小时前的时间
|
String dateBegin3 = dateBegins3;
|
|
//六个小时前的时间
|
String dateBegin6 = dateBegins6;
|
|
List<Map<String, Object>> maps = regionWeightService.selectppyj(time, dateBegin1, dateBegin3, dateBegin6, times);
|
List<Map<String, Object>> lists = new ArrayList<>();
|
for (int i = 0; i < maps.size(); i++) {
|
Map<String, Object> map = new HashMap<String, Object>();
|
BigDecimal bigDecimaldrp1 = (BigDecimal) maps.get(i).get("drp1");//1小时
|
BigDecimal bigDecimaldrp3 = (BigDecimal) maps.get(i).get("drp3");//3小时
|
BigDecimal bigDecimaldrp6 = (BigDecimal) maps.get(i).get("drp6");//6小时
|
BigDecimal bigDecimaldyp = (BigDecimal) maps.get(i).get("dyp");//日雨量
|
double drp1 = bigDecimaldrp1.doubleValue();
|
double drp3 = bigDecimaldrp3.doubleValue();
|
double drp6 = bigDecimaldrp6.doubleValue();
|
double dyp = bigDecimaldyp.doubleValue();
|
if (drp1 >= 30 || drp3 >= 50 || drp6 >= 80 || dyp >= 80) {
|
maps.get(i).put("YJ", "一级预警");
|
} else if (drp1 >= 50 || drp3 >= 80 || drp6 >= 100 || dyp >= 100) {
|
maps.get(i).put("YJ", "二级预警");
|
} else if (drp1 >= 80 || drp3 >= 100 || drp6 >= 120 || dyp >= 120) {
|
maps.get(i).put("YJ", "三级预警");
|
} else {
|
maps.get(i).put("YJ", "无预警");
|
}
|
map.put("YjList", maps.get(i));
|
lists.add(map);
|
}
|
return R.data(lists);
|
}
|
|
|
}
|
|
@GetMapping("/selectReDc")
|
public R selectReDc(String beginTime, String endTime) {
|
String substring = beginTime.substring(0, 10);
|
String r = beginTime.substring(11, 13);
|
//截取月日
|
String[] strs = substring.split("-");
|
//月
|
String year = strs[1].toString();
|
//日
|
String day = strs[2].toString();
|
String substrings = endTime.substring(0, 10);
|
String rs = endTime.substring(11, 13);
|
//截取月日
|
String[] strss = substrings.split("-");
|
//月
|
String years = strss[1].toString();
|
//日
|
String days = strss[2].toString();
|
//List<Map<String, Object>> maps = regionWeightService.selectYjs(beginTime, endTime);
|
String s = regionWeightService.selectCode();
|
String[] split = s.split(",");
|
String strArrays = "";
|
for (int i = 0; i < split.length; i++) {
|
strArrays += "'" + split[i] + "',";
|
}
|
String code = strArrays.substring(0, strArrays.length() - 1);
|
List<Map<String, Object>> maps = regionWeightService.ss(beginTime, endTime, code);
|
List<Map<String, Object>> lists = new ArrayList<>();
|
Map<String, Object> map = new HashMap<String, Object>();
|
String text = "";
|
String yday = year + "月" + day + "日" + r + "时-" + years + "月" + days + "日" + rs + "时。";
|
//0-10降雨量范围
|
List lista = new ArrayList<>();
|
//10-25降雨量范围
|
List listb = new ArrayList<>();
|
//25-50降雨量范围
|
List listc = new ArrayList<>();
|
//50-100降雨量范围
|
List listd = new ArrayList<>();
|
//100-250降雨量范围
|
List liste = new ArrayList<>();
|
//250降雨量范围
|
List listf = new ArrayList<>();
|
for (int i = 0; i < maps.size(); i++) {
|
if (i < 3) {
|
String addvnm = maps.get(i).get("ADDVNM").toString();
|
String stnm = maps.get(i).get("STNM").toString();
|
BigDecimal bigDecimaldyp = (BigDecimal) maps.get(i).get("dyp");//日雨量
|
double dyp = bigDecimaldyp.doubleValue();
|
if (dyp > 0 && dyp <= 10) {
|
lista.add(maps.get(i));
|
} else if (dyp > 10 && dyp <= 25) {
|
listb.add(maps.get(i));
|
} else if (dyp > 25 && dyp <= 50) {
|
listc.add(maps.get(i));
|
} else if (dyp > 50 && dyp <= 100) {
|
listd.add(maps.get(i));
|
} else if (dyp > 100 && dyp <= 250) {
|
liste.add(maps.get(i));
|
} else if (dyp > 250) {
|
listf.add(maps.get(i));
|
}
|
text += stnm + "站" + dyp + "毫米,";
|
} else {
|
BigDecimal bigDecimaldyp = (BigDecimal) maps.get(i).get("dyp");//日雨量
|
double dyp = bigDecimaldyp.doubleValue();
|
if (dyp > 0 && dyp <= 10) {
|
lista.add(maps.get(i));
|
} else if (dyp > 10 && dyp <= 25) {
|
listb.add(maps.get(i));
|
} else if (dyp > 25 && dyp <= 50) {
|
listc.add(maps.get(i));
|
} else if (dyp > 50 && dyp <= 100) {
|
listd.add(maps.get(i));
|
} else if (dyp > 100 && dyp <= 250) {
|
liste.add(maps.get(i));
|
} else if (dyp > 250) {
|
listf.add(maps.get(i));
|
}
|
}
|
}
|
//0-10
|
map.put("one", lista);
|
//10-25
|
map.put("two", listb);
|
//25-50
|
map.put("three", listc);
|
//50-100
|
map.put("four", listd);
|
//100-250
|
map.put("five", liste);
|
//250
|
map.put("six", listf);
|
String a = "";
|
if (maps.size() == 0) {
|
a = yday + "暂无降雨信息。";
|
} else {
|
a = yday + "点降雨量前三为:" + text.substring(0, text.length() - 1) + "。";
|
}
|
map.put("text", a);
|
lists.add(map);
|
String fileName = "";
|
// 第一步，创建一个webbook，对应一个Excel文件
|
HSSFWorkbook wb = new HSSFWorkbook();
|
// 第二步，在webbook中添加一个sheet,对应Excel文件中的sheet
|
HSSFSheet sheet = wb.createSheet("雨量表");
|
// 第三步，在sheet中添加表头第0行,注意老版本poi对Excel的行数列数有限制short
|
HSSFRow row = sheet.createRow((int) 0);
|
// 第四步，创建单元格，并设置值表头 设置表头居中
|
HSSFCellStyle style = wb.createCellStyle();
|
//style.setAlignment(HSSFCellStyle.ALIGN_CENTER); // 创建一个居中格式
|
HSSFCell cell = row.createCell((short) 0);
|
cell.setCellValue("lon");
|
cell = row.createCell((short) 1);
|
cell.setCellValue("lat");
|
cell = row.createCell((short) 2);
|
cell.setCellValue("rain");
|
for (int i = 0; i < maps.size(); i++) {
|
// 第四步，创建单元格，并设置值
|
row = sheet.createRow((int) i + 1);
|
HSSFCell celli = row.createCell((short) 0);
|
row.createCell((short) 0).setCellValue(maps.get(i).get("LGTD").toString());
|
row.createCell((short) 1).setCellValue(maps.get(i).get("LTTD").toString());
|
row.createCell((short) 2).setCellValue(maps.get(i).get("dyp").toString());
|
}
|
// 第六步，将文件存到指定位置
|
try {
|
fileName = "D:/pptnd.xlsx";
|
FileOutputStream fout = new FileOutputStream(fileName);
|
wb.write(fout);
|
fout.close();
|
wb.close();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
Process proc;
|
try {
|
proc = Runtime.getRuntime().exec("python D:\\fz\\fz.py");
|
BufferedReader in = new BufferedReader(new InputStreamReader(proc.getInputStream()));
|
String line = null;
|
while ((line = in.readLine()) != null) {
|
System.out.println(line);
|
}
|
in.close();
|
proc.waitFor();
|
} catch (IOException e) {
|
e.printStackTrace();
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
return R.data(lists);
|
}
|
|
|
}
|
