| | |
| | | import lombok.AllArgsConstructor; |
| | | import org.apache.poi.hssf.usermodel.*; |
| | | import org.springblade.core.boot.ctrl.BladeController; |
| | | 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.modules.mountain.vo.MountainVO; |
| | | import org.springblade.modules.mountainrain.entity.Mountainrain; |
| | | import org.springblade.modules.mountainrain.entity.Yucpptn; |
| | | import org.springblade.modules.mountainrain.excel.BgrExcel; |
| | | import org.springblade.modules.mountainrain.excel.BgrImporter; |
| | | import org.springblade.modules.mountainrain.excel.MgrExcel; |
| | | import org.springblade.modules.mountainrain.excel.MgrImporter; |
| | | import org.springblade.modules.mountainrain.service.IMountainrainService; |
| | | import org.springblade.modules.mountainrain.vo.*; |
| | | import org.springblade.modules.mountainrain.wrapper.MountainrainWrapper; |
| | | import org.springblade.modules.regionWeight.service.IRegionWeightService; |
| | | import org.springblade.modules.system.excel.UserExcel; |
| | | import org.springblade.modules.system.excel.UserImporter; |
| | | import org.springframework.stereotype.Component; |
| | | import org.springframework.web.bind.annotation.*; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | |
| | | import java.io.*; |
| | | import java.math.BigDecimal; |
| | | import java.net.URLEncoder; |
| | | import java.sql.Timestamp; |
| | | import java.text.DateFormat; |
| | | import java.text.ParseException; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.*; |
| | |
| | | e.printStackTrace(); |
| | | } |
| | | Process proc; |
| | | Timestamp timestamp = new Timestamp(System.currentTimeMillis()); |
| | | long url = timestamp.getTime(); |
| | | Map m = new HashMap(); |
| | | m.put("url", url + ".png"); |
| | | String[] args1 = new String[]{"python", "D:\\fz\\mou.py", String.valueOf(url)}; |
| | | try { |
| | | proc = Runtime.getRuntime().exec("python D:\\fz\\mou.py"); |
| | | proc = Runtime.getRuntime().exec(args1); |
| | | BufferedReader in = new BufferedReader(new InputStreamReader(proc.getInputStream())); |
| | | String line = null; |
| | | while ((line = in.readLine()) != null) { |
| | |
| | | } catch (InterruptedException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | lists.add(m); |
| | | return R.data(lists); |
| | | |
| | | } |
| | |
| | | e.printStackTrace(); |
| | | } |
| | | Process proc; |
| | | Timestamp timestamp = new Timestamp(System.currentTimeMillis()); |
| | | long url = timestamp.getTime(); |
| | | Map m = new HashMap(); |
| | | m.put("url", url + ".png"); |
| | | String[] args1 = new String[]{"python", "D:\\fz\\moup.py", String.valueOf(url)}; |
| | | try { |
| | | proc = Runtime.getRuntime().exec("python D:\\fz\\moup.py"); |
| | | proc = Runtime.getRuntime().exec(args1); |
| | | BufferedReader in = new BufferedReader(new InputStreamReader(proc.getInputStream())); |
| | | String line = null; |
| | | while ((line = in.readLine()) != null) { |
| | |
| | | } catch (InterruptedException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | lists.add(m); |
| | | return R.data(lists); |
| | | } |
| | | |
| | |
| | | * @return |
| | | */ |
| | | @GetMapping("/soleval") |
| | | public R soleval() { |
| | | mountainrainService.soildel(); |
| | | int intervals = 31; |
| | | public R soleval(String time, int b) { |
| | | //SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | | //String dateNow = sdf.format(new Date()); |
| | | String dateNow = time; |
| | | //mountainrainService.soildel(); |
| | | int intervals = 32 + b; |
| | | ArrayList passDaysList = new ArrayList<>(); |
| | | for (int i = 0; i < intervals; i++) { |
| | | for (int i = 1 + b; i < intervals; i++) { |
| | | passDaysList.add(getDays(i, false)); |
| | | } |
| | | Collections.sort(passDaysList); |
| | |
| | | String s = regionWeightService.selectCode(); |
| | | String[] split = s.split(","); |
| | | String strArrays = ""; |
| | | System.out.println("长度:"+split.length); |
| | | for (int i = 0; i < split.length; i++) { |
| | | strArrays += "'" + split[i] + "',"; |
| | | } |
| | | String code = strArrays.substring(0, strArrays.length() - 1); |
| | | // for (int i = 0; i < split.length; i++) { |
| | | // Integer num = 30; |
| | | // double v1 = 0; |
| | | // String stcd = null; |
| | | // for (int j = 0; j < passDaysList.size() - 2; j++) { |
| | | // List<Map<String, Object>> map = mountainrainService.selectMtwo(passDaysList.get(j).toString(), passDaysList.get(j + 1).toString(), code); |
| | | // if (map.size() == 0 || i > map.size() - 1) { |
| | | // break; |
| | | // } |
| | | // BigDecimal w = (BigDecimal) map.get(i).get("drp"); |
| | | // double drp = w.doubleValue(); |
| | | // stcd = map.get(i).get("STCD").toString(); |
| | | // //计算湿度 |
| | | // if (j == 0) { |
| | | // v1 = formatDouble1((num + drp) * 0.85); |
| | | // if (v1 > 60) { |
| | | // v1 = 60; |
| | | // } |
| | | // } else { |
| | | // v1 += drp; |
| | | // v1 = formatDouble1(v1 * 0.85); |
| | | // if (v1 > 60) { |
| | | // v1 = 60; |
| | | // } |
| | | // } |
| | | // } |
| | | // if (v1 > 60) { |
| | | // mountainrainService.soleInster(stcd, "60"); |
| | | // } else { |
| | | // String a = String.valueOf(v1); |
| | | // mountainrainService.soleInster(stcd, a); |
| | | // } |
| | | // } |
| | | for (int i = 0; i < split.length; i++) { |
| | | Integer num = 30; |
| | | double v1 = 0; |
| | | String stcd = null; |
| | | for (int j = 0; j < passDaysList.size() - 2; j++) { |
| | | List<Map<String, Object>> map = mountainrainService.selectMtwo(passDaysList.get(j).toString(), passDaysList.get(j + 1).toString(), code); |
| | | if (map.size() == 0 || i > map.size() - 1) { |
| | | //stcd=split[i]; |
| | | break; |
| | | } |
| | | BigDecimal w = (BigDecimal) map.get(i).get("drp"); |
| | | double drp = w.doubleValue(); |
| | | stcd = map.get(i).get("STCD").toString(); |
| | | //计算湿度 |
| | | if (j == 0) { |
| | | v1 = formatDouble1((num + drp) * 0.85); |
| | | if (v1 > 60) { |
| | | v1 = 60; |
| | | } |
| | | } else { |
| | | v1 += drp; |
| | | v1 = formatDouble1(v1 * 0.85); |
| | | if (v1 > 60) { |
| | | v1 = 60; |
| | | } |
| | | } |
| | | } |
| | | if (stcd != null) { |
| | | if (v1 > 60) { |
| | | mountainrainService.soleInster(stcd, "60", dateNow); |
| | | } else { |
| | | String a = String.valueOf(v1); |
| | | mountainrainService.soleInster(stcd, a, dateNow); |
| | | } |
| | | } |
| | | |
| | | } |
| | | |
| | | return R.success("成功"); |
| | | } |
| | |
| | | * @return |
| | | */ |
| | | @GetMapping("/selectsmriver") |
| | | public R selectsmriver(String time) { |
| | | public R selectsmriver(String time) throws ParseException { |
| | | Date date = null; |
| | | // 把Date按照格式转换成字符串 |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | |
| | | e.printStackTrace(); |
| | | } |
| | | String dateEnd = sdf.format(date); |
| | | List<Map<String, Object>> selctsmriver = mountainrainService.selctsmriver(time, dateEnd); |
| | | DateFormat sdfc = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | Date datess = sdfc.parse(time); |
| | | String now = sdfc.format(datess); |
| | | //当前时间的前24小时 |
| | | Date beforeHour1 = beforeHourToNowDate(now, 24); |
| | | String begintime24 = sdf.format(beforeHour1); |
| | | List<Map<String, Object>> selctsmriver = mountainrainService.selctsmriver(time, dateEnd, begintime24); |
| | | //预警数据 |
| | | List listyj = new ArrayList(); |
| | | //无预警数据 |
| | |
| | | * @return |
| | | */ |
| | | @GetMapping("/selectbgriver") |
| | | public R selectbgriver(String time) { |
| | | public R selectbgriver(String time) throws ParseException { |
| | | Date date = null; |
| | | // 把Date按照格式转换成字符串 |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | |
| | | e.printStackTrace(); |
| | | } |
| | | String dateEnd = sdf.format(date); |
| | | List<Map<String, Object>> selctsmriver = mountainrainService.selctbgriver(time, dateEnd); |
| | | DateFormat sdfc = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | Date datess = sdfc.parse(time); |
| | | String now = sdfc.format(datess); |
| | | //当前时间的前24小时 |
| | | Date beforeHour1 = beforeHourToNowDate(now, 24); |
| | | String begintime24 = sdf.format(beforeHour1); |
| | | List<Map<String, Object>> selctsmriver = mountainrainService.selctbgriver(time, dateEnd, begintime24); |
| | | //预警数据 |
| | | List listyj = new ArrayList(); |
| | | //无预警数据 |
| | |
| | | String times = time; |
| | | |
| | | String dateEnd1 = dateEnds1; |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | | Date date = null; |
| | | try { |
| | | date = sdf.parse(time); |
| | | } catch (ParseException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | String stime = sdf.format(date); |
| | | //对应雨量站 |
| | | String s = mountainrainService.selectCode(); |
| | | String[] split = s.split(","); |
| | |
| | | strArrays += "'" + split[i] + "',"; |
| | | } |
| | | String code = strArrays.substring(0, strArrays.length() - 1); |
| | | List<MountainrainsCVO> mountainrainsCVOS = mountainrainService.MountainYi(times, dateEnd1, code); |
| | | List<MountainrainsCVO> mountainrainsCVOS = mountainrainService.MountainYi(times, dateEnd1, code, stime); |
| | | List<Map<String, Object>> lists = new ArrayList<>(); |
| | | for (int i = 0; i < mountainrainsCVOS.size(); i++) { |
| | | if (mountainrainsCVOS.get(i).getCenconding() == null) { |
| | |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGohours()) { |
| | | int drp1 = mountainrainsCVOS.get(i).getDrp1(); |
| | | Integer gohours = mountainrainsCVOS.get(i).getGohours(); |
| | | int i1 = drp1 - gohours; |
| | | float i1 = (float) drp1 - gohours; |
| | | float v = (float) (Math.round(i1 * 10)) / 10; |
| | | String a = String.valueOf(v); |
| | | map.put("List", mountainrainsCVOS.get(i)); |
| | | map.put("flage1", "true"); |
| | | map.put("status", 2); |
| | | map.put("num", i1); |
| | | map.put("num", a); |
| | | lists.add(map); |
| | | } else { |
| | | map.put("List", mountainrainsCVOS.get(i)); |
| | |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGohour()) { |
| | | int drp1 = mountainrainsCVOS.get(i).getDrp1(); |
| | | Integer gohour = mountainrainsCVOS.get(i).getGohour(); |
| | | int i1 = drp1 - gohour; |
| | | float i1 = (float) drp1 - gohour; |
| | | float v = (float) (Math.round(i1 * 10)) / 10; |
| | | String a = String.valueOf(v); |
| | | map.put("List", mountainrainsCVOS.get(i)); |
| | | map.put("flage1", "true"); |
| | | map.put("status", 1); |
| | | map.put("num", i1); |
| | | map.put("num", a); |
| | | lists.add(map); |
| | | } else { |
| | | map.put("List", mountainrainsCVOS.get(i)); |
| | |
| | | } |
| | | |
| | | } |
| | | //色斑图 |
| | | String file = ""; |
| | | // 第一步,创建一个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 < mountainrainsCVOS.size(); i++) { |
| | | row = sheet.createRow((int) i + 1); |
| | | HSSFCell celli = row.createCell((short) 0); |
| | | row.createCell((short) 0).setCellValue(mountainrainsCVOS.get(i).getDj()); |
| | | row.createCell((short) 1).setCellValue(mountainrainsCVOS.get(i).getBw()); |
| | | if (mountainrainsCVOS.get(i).getCenconding() == null) { |
| | | continue; |
| | | } |
| | | if (mountainrainsCVOS.get(i).getSoilval() > 30) { |
| | | //0.8雨量湿度 |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGohours()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | Timestamp timestamp = new Timestamp(System.currentTimeMillis()); |
| | | long url = timestamp.getTime(); |
| | | Map m = new HashMap(); |
| | | m.put("url", url + ".png"); |
| | | lists.add(m); |
| | | Thread thread = new Thread(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | //色斑图 |
| | | String file = ""; |
| | | // 第一步,创建一个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 < mountainrainsCVOS.size(); i++) { |
| | | row = sheet.createRow((int) i + 1); |
| | | HSSFCell celli = row.createCell((short) 0); |
| | | row.createCell((short) 0).setCellValue(mountainrainsCVOS.get(i).getDj()); |
| | | row.createCell((short) 1).setCellValue(mountainrainsCVOS.get(i).getBw()); |
| | | if (mountainrainsCVOS.get(i).getCenconding() == null) { |
| | | continue; |
| | | } |
| | | if (mountainrainsCVOS.get(i).getSoilval() > 30) { |
| | | //0.8雨量湿度 |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGohours()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | } |
| | | } else { |
| | | //0.5雨量湿度 |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGohour()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | } |
| | | } |
| | | } |
| | | } else { |
| | | //0.5雨量湿度 |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGohour()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | try { |
| | | file = "D:/mou.xlsx"; |
| | | FileOutputStream fout = new FileOutputStream(file); |
| | | wb.write(fout); |
| | | fout.close(); |
| | | wb.close(); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | Process proc; |
| | | String[] args1 = new String[]{"python", "D:\\fz\\mou.py", String.valueOf(url)}; |
| | | try { |
| | | proc = Runtime.getRuntime().exec(args1); |
| | | 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(); |
| | | } |
| | | } |
| | | } |
| | | try { |
| | | file = "D:/mou.xlsx"; |
| | | FileOutputStream fout = new FileOutputStream(file); |
| | | wb.write(fout); |
| | | fout.close(); |
| | | wb.close(); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | Process proc; |
| | | try { |
| | | proc = Runtime.getRuntime().exec("python D:\\fz\\mou.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(); |
| | | } |
| | | }); |
| | | thread.start(); |
| | | return R.data(lists); |
| | | |
| | | } |
| | |
| | | double drp1 = w1.doubleValue(); |
| | | if (drp1 > 30) { |
| | | double v = drp1 - 30; |
| | | double v1 = (double) Math.round(v * 100) / 100; |
| | | String a = String.valueOf(v1); |
| | | map.put("flage1", "true"); |
| | | map.put("num", v); |
| | | map.put("num", a); |
| | | } else { |
| | | map.put("flage1", "false"); |
| | | } |
| | | map.put("List", list.get(i)); |
| | | 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(new HSSFRichTextString("lon")); |
| | | cell = row.createCell((short) 1); |
| | | cell.setCellValue(new HSSFRichTextString("lat")); |
| | | cell = row.createCell((short) 2); |
| | | cell.setCellValue(new HSSFRichTextString("rain")); |
| | | for (int i = 0; i < list.size(); i++) { |
| | | // 第四步,创建单元格,并设置值 |
| | | row = sheet.createRow((int) i + 1); |
| | | HSSFCell celli = row.createCell((short) 0); |
| | | BigDecimal w1 = (BigDecimal) list.get(i).get("drp1"); |
| | | double drp1 = w1.doubleValue(); |
| | | row.createCell((short) 0).setCellValue(list.get(i).get("LGTD").toString()); |
| | | row.createCell((short) 1).setCellValue(list.get(i).get("LTTD").toString()); |
| | | if (drp1 > 30) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | Timestamp timestamp = new Timestamp(System.currentTimeMillis()); |
| | | long url = timestamp.getTime(); |
| | | Map m = new HashMap(); |
| | | m.put("url", url + ".png"); |
| | | lists.add(m); |
| | | Thread thread = new Thread(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | 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(new HSSFRichTextString("lon")); |
| | | cell = row.createCell((short) 1); |
| | | cell.setCellValue(new HSSFRichTextString("lat")); |
| | | cell = row.createCell((short) 2); |
| | | cell.setCellValue(new HSSFRichTextString("rain")); |
| | | for (int i = 0; i < list.size(); i++) { |
| | | // 第四步,创建单元格,并设置值 |
| | | row = sheet.createRow((int) i + 1); |
| | | HSSFCell celli = row.createCell((short) 0); |
| | | BigDecimal w1 = (BigDecimal) list.get(i).get("drp1"); |
| | | double drp1 = w1.doubleValue(); |
| | | row.createCell((short) 0).setCellValue(list.get(i).get("LGTD").toString()); |
| | | row.createCell((short) 1).setCellValue(list.get(i).get("LTTD").toString()); |
| | | if (drp1 > 30) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | } |
| | | } |
| | | // 第六步,将文件存到指定位置 |
| | | try { |
| | | fileName = "D:/moup.xlsx"; |
| | | FileOutputStream fout = new FileOutputStream(fileName); |
| | | wb.write(fout); |
| | | fout.close(); |
| | | wb.close(); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | Process proc; |
| | | String[] args1 = new String[]{"python", "D:\\fz\\moup.py", String.valueOf(url)}; |
| | | try { |
| | | proc = Runtime.getRuntime().exec(args1); |
| | | 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(); |
| | | } |
| | | } |
| | | } |
| | | // 第六步,将文件存到指定位置 |
| | | try { |
| | | fileName = "D:/moup.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\\moup.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(); |
| | | } |
| | | }); |
| | | thread.start(); |
| | | return R.data(lists); |
| | | } |
| | | |
| | |
| | | |
| | | //2个小时前的时间 |
| | | String dateEnd2 = dateEnds2; |
| | | |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | | Date date = null; |
| | | try { |
| | | date = sdf.parse(time); |
| | | } catch (ParseException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | String stime = sdf.format(date); |
| | | //对应雨量站 |
| | | String s = mountainrainService.selectCode(); |
| | | String[] split = s.split(","); |
| | |
| | | strArrays += "'" + split[i] + "',"; |
| | | } |
| | | String code = strArrays.substring(0, strArrays.length() - 1); |
| | | List<MountainrainsCVO> mountainrainsCVOS = mountainrainService.MountainYi(times, dateEnd2, code); |
| | | List<MountainrainsCVO> mountainrainsCVOS = mountainrainService.MountainTw(times, dateEnd2, code, stime); |
| | | List<Map<String, Object>> lists = new ArrayList<>(); |
| | | for (int i = 0; i < mountainrainsCVOS.size(); i++) { |
| | | if (mountainrainsCVOS.get(i).getCenconding() == null) { |
| | |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGohours()) { |
| | | int drp1 = mountainrainsCVOS.get(i).getDrp1(); |
| | | Integer gohours = mountainrainsCVOS.get(i).getGohours(); |
| | | int i1 = drp1 - gohours; |
| | | float i1 = (float) drp1 - gohours; |
| | | float v = (float) (Math.round(i1 * 10)) / 10; |
| | | String a = String.valueOf(v); |
| | | map.put("List", mountainrainsCVOS.get(i)); |
| | | map.put("flage1", "true"); |
| | | map.put("flage3", "false"); |
| | | map.put("status", 2); |
| | | map.put("num", i1); |
| | | map.put("num", a); |
| | | lists.add(map); |
| | | } else if (mountainrainsCVOS.get(i).getDrp3() > mountainrainsCVOS.get(i).getGthours()) { |
| | | map.put("List", mountainrainsCVOS.get(i)); |
| | |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGohour()) { |
| | | int drp1 = mountainrainsCVOS.get(i).getDrp1(); |
| | | Integer gohour = mountainrainsCVOS.get(i).getGohour(); |
| | | int i1 = drp1 - gohour; |
| | | float i1 = (float) drp1 - gohour; |
| | | float v = (float) (Math.round(i1 * 10)) / 10; |
| | | String a = String.valueOf(v); |
| | | map.put("List", mountainrainsCVOS.get(i)); |
| | | map.put("flage1", "true"); |
| | | map.put("flage3", "false"); |
| | | map.put("status", 1); |
| | | map.put("num", i1); |
| | | map.put("num", a); |
| | | lists.add(map); |
| | | } else if (mountainrainsCVOS.get(i).getDrp3() > mountainrainsCVOS.get(i).getGthour()) { |
| | | map.put("List", mountainrainsCVOS.get(i)); |
| | |
| | | } |
| | | |
| | | } |
| | | //色斑图 |
| | | String file = ""; |
| | | // 第一步,创建一个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 < mountainrainsCVOS.size(); i++) { |
| | | row = sheet.createRow((int) i + 1); |
| | | HSSFCell celli = row.createCell((short) 0); |
| | | row.createCell((short) 0).setCellValue(mountainrainsCVOS.get(i).getDj()); |
| | | row.createCell((short) 1).setCellValue(mountainrainsCVOS.get(i).getBw()); |
| | | if (mountainrainsCVOS.get(i).getCenconding() == null) { |
| | | continue; |
| | | } |
| | | if (mountainrainsCVOS.get(i).getSoilval() > 30) { |
| | | //0.8雨量湿度 |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGohours()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else if (mountainrainsCVOS.get(i).getDrp3() > mountainrainsCVOS.get(i).getGthours()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | Timestamp timestamp = new Timestamp(System.currentTimeMillis()); |
| | | long url = timestamp.getTime(); |
| | | Map m = new HashMap(); |
| | | m.put("url", url + ".png"); |
| | | lists.add(m); |
| | | Thread thread = new Thread(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | //色斑图 |
| | | String file = ""; |
| | | // 第一步,创建一个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 < mountainrainsCVOS.size(); i++) { |
| | | row = sheet.createRow((int) i + 1); |
| | | HSSFCell celli = row.createCell((short) 0); |
| | | row.createCell((short) 0).setCellValue(mountainrainsCVOS.get(i).getDj()); |
| | | row.createCell((short) 1).setCellValue(mountainrainsCVOS.get(i).getBw()); |
| | | if (mountainrainsCVOS.get(i).getCenconding() == null) { |
| | | continue; |
| | | } |
| | | if (mountainrainsCVOS.get(i).getSoilval() > 30) { |
| | | //0.8雨量湿度 |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGohours()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else if (mountainrainsCVOS.get(i).getDrp3() > mountainrainsCVOS.get(i).getGthours()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | } |
| | | } else { |
| | | //0.5雨量湿度 |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGohour()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else if (mountainrainsCVOS.get(i).getDrp3() > mountainrainsCVOS.get(i).getGthour()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | } |
| | | } |
| | | } |
| | | } else { |
| | | //0.5雨量湿度 |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGohour()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else if (mountainrainsCVOS.get(i).getDrp3() > mountainrainsCVOS.get(i).getGthour()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | try { |
| | | file = "D:/mou.xlsx"; |
| | | FileOutputStream fout = new FileOutputStream(file); |
| | | wb.write(fout); |
| | | fout.close(); |
| | | wb.close(); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | Process proc; |
| | | String[] args1 = new String[]{"python", "D:\\fz\\mou.py", String.valueOf(url)}; |
| | | try { |
| | | proc = Runtime.getRuntime().exec(args1); |
| | | 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(); |
| | | } |
| | | } |
| | | } |
| | | try { |
| | | file = "D:/mou.xlsx"; |
| | | FileOutputStream fout = new FileOutputStream(file); |
| | | wb.write(fout); |
| | | fout.close(); |
| | | wb.close(); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | Process proc; |
| | | try { |
| | | proc = Runtime.getRuntime().exec("python D:\\fz\\mou.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(); |
| | | } |
| | | }); |
| | | thread.start(); |
| | | return R.data(lists); |
| | | |
| | | } |
| | |
| | | double drp1 = w1.doubleValue(); |
| | | if (drp1 > 50) { |
| | | double v = drp1 - 50; |
| | | double v1 = (double) Math.round(v * 10) / 10; |
| | | map.put("flage2", "true"); |
| | | map.put("num", v); |
| | | map.put("num", v1); |
| | | } else { |
| | | map.put("flage2", "false"); |
| | | } |
| | | map.put("List", list.get(i)); |
| | | 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(new HSSFRichTextString("lon")); |
| | | cell = row.createCell((short) 1); |
| | | cell.setCellValue(new HSSFRichTextString("lat")); |
| | | cell = row.createCell((short) 2); |
| | | cell.setCellValue(new HSSFRichTextString("rain")); |
| | | for (int i = 0; i < list.size(); i++) { |
| | | // 第四步,创建单元格,并设置值 |
| | | row = sheet.createRow((int) i + 1); |
| | | HSSFCell celli = row.createCell((short) 0); |
| | | BigDecimal w1 = (BigDecimal) list.get(i).get("drp1"); |
| | | double drp1 = w1.doubleValue(); |
| | | row.createCell((short) 0).setCellValue(list.get(i).get("LGTD").toString()); |
| | | row.createCell((short) 1).setCellValue(list.get(i).get("LTTD").toString()); |
| | | if (drp1 > 50) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | Timestamp timestamp = new Timestamp(System.currentTimeMillis()); |
| | | long url = timestamp.getTime(); |
| | | Map m = new HashMap(); |
| | | m.put("url", url + ".png"); |
| | | lists.add(m); |
| | | Thread thread = new Thread(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | 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(new HSSFRichTextString("lon")); |
| | | cell = row.createCell((short) 1); |
| | | cell.setCellValue(new HSSFRichTextString("lat")); |
| | | cell = row.createCell((short) 2); |
| | | cell.setCellValue(new HSSFRichTextString("rain")); |
| | | for (int i = 0; i < list.size(); i++) { |
| | | // 第四步,创建单元格,并设置值 |
| | | row = sheet.createRow((int) i + 1); |
| | | HSSFCell celli = row.createCell((short) 0); |
| | | BigDecimal w1 = (BigDecimal) list.get(i).get("drp1"); |
| | | double drp1 = w1.doubleValue(); |
| | | row.createCell((short) 0).setCellValue(list.get(i).get("LGTD").toString()); |
| | | row.createCell((short) 1).setCellValue(list.get(i).get("LTTD").toString()); |
| | | if (drp1 > 50) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | } |
| | | } |
| | | // 第六步,将文件存到指定位置 |
| | | try { |
| | | fileName = "D:/moup.xlsx"; |
| | | FileOutputStream fout = new FileOutputStream(fileName); |
| | | wb.write(fout); |
| | | fout.close(); |
| | | wb.close(); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | Process proc; |
| | | Timestamp timestamp = new Timestamp(System.currentTimeMillis()); |
| | | long url = timestamp.getTime(); |
| | | Map m = new HashMap(); |
| | | m.put("url", url + ".png"); |
| | | String[] args1 = new String[]{"python", "D:\\fz\\moup.py", String.valueOf(url)}; |
| | | try { |
| | | proc = Runtime.getRuntime().exec(args1); |
| | | 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(); |
| | | } |
| | | } |
| | | } |
| | | // 第六步,将文件存到指定位置 |
| | | try { |
| | | fileName = "D:/moup.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\\moup.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(); |
| | | } |
| | | }); |
| | | thread.start(); |
| | | return R.data(lists); |
| | | } |
| | | |
| | |
| | | |
| | | //2个小时前的时间 |
| | | String dateEnd3 = dateEnds3; |
| | | |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); |
| | | Date date = null; |
| | | try { |
| | | date = sdf.parse(time); |
| | | } catch (ParseException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | String stime = sdf.format(date); |
| | | //对应雨量站 |
| | | String s = mountainrainService.selectCode(); |
| | | String[] split = s.split(","); |
| | |
| | | strArrays += "'" + split[i] + "',"; |
| | | } |
| | | String code = strArrays.substring(0, strArrays.length() - 1); |
| | | List<MountainrainsCVO> mountainrainsCVOS = mountainrainService.MountainTr(times, dateEnd3, code); |
| | | List<MountainrainsCVO> mountainrainsCVOS = mountainrainService.MountainTr(times, dateEnd3, code, stime); |
| | | List<Map<String, Object>> lists = new ArrayList<>(); |
| | | for (int i = 0; i < mountainrainsCVOS.size(); i++) { |
| | | if (mountainrainsCVOS.get(i).getCenconding() == null) { |
| | |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGthours()) { |
| | | int drp1 = mountainrainsCVOS.get(i).getDrp1(); |
| | | Integer gohours = mountainrainsCVOS.get(i).getGohours(); |
| | | int i1 = drp1 - gohours; |
| | | float i1 = (float) drp1 - gohours; |
| | | float v = (float) (Math.round(i1 * 10)) / 10; |
| | | String a = String.valueOf(v); |
| | | map.put("List", mountainrainsCVOS.get(i)); |
| | | map.put("flage3", "true"); |
| | | map.put("status", 2); |
| | | map.put("num", i1); |
| | | map.put("num", a); |
| | | lists.add(map); |
| | | } else { |
| | | map.put("List", mountainrainsCVOS.get(i)); |
| | |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGthour()) { |
| | | int drp1 = mountainrainsCVOS.get(i).getDrp1(); |
| | | Integer gohour = mountainrainsCVOS.get(i).getGohour(); |
| | | int i1 = drp1 - gohour; |
| | | float i1 = (float) drp1 - gohour; |
| | | float v = (float) (Math.round(i1 * 10)) / 10; |
| | | String a = String.valueOf(v); |
| | | map.put("List", mountainrainsCVOS.get(i)); |
| | | map.put("flage3", "true"); |
| | | map.put("status", 1); |
| | | map.put("num", i1); |
| | | map.put("num", a); |
| | | lists.add(map); |
| | | } else { |
| | | map.put("List", mountainrainsCVOS.get(i)); |
| | |
| | | } |
| | | |
| | | } |
| | | //色斑图 |
| | | String file = ""; |
| | | // 第一步,创建一个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 < mountainrainsCVOS.size(); i++) { |
| | | row = sheet.createRow((int) i + 1); |
| | | HSSFCell celli = row.createCell((short) 0); |
| | | row.createCell((short) 0).setCellValue(mountainrainsCVOS.get(i).getDj()); |
| | | row.createCell((short) 1).setCellValue(mountainrainsCVOS.get(i).getBw()); |
| | | if (mountainrainsCVOS.get(i).getCenconding() == null) { |
| | | continue; |
| | | } |
| | | if (mountainrainsCVOS.get(i).getSoilval() > 30) { |
| | | //0.8雨量湿度 |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGthours()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | Timestamp timestamp = new Timestamp(System.currentTimeMillis()); |
| | | long url = timestamp.getTime(); |
| | | Map m = new HashMap(); |
| | | m.put("url", url + ".png"); |
| | | lists.add(m); |
| | | Thread thread = new Thread(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | //色斑图 |
| | | String file = ""; |
| | | // 第一步,创建一个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 < mountainrainsCVOS.size(); i++) { |
| | | row = sheet.createRow((int) i + 1); |
| | | HSSFCell celli = row.createCell((short) 0); |
| | | row.createCell((short) 0).setCellValue(mountainrainsCVOS.get(i).getDj()); |
| | | row.createCell((short) 1).setCellValue(mountainrainsCVOS.get(i).getBw()); |
| | | if (mountainrainsCVOS.get(i).getCenconding() == null) { |
| | | continue; |
| | | } |
| | | if (mountainrainsCVOS.get(i).getSoilval() > 30) { |
| | | //0.8雨量湿度 |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGthours()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | } |
| | | } else { |
| | | //0.5雨量湿度 |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGthour()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | } |
| | | } |
| | | } |
| | | } else { |
| | | //0.5雨量湿度 |
| | | if (mountainrainsCVOS.get(i).getDrp1() > mountainrainsCVOS.get(i).getGthour()) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | try { |
| | | file = "D:/mou.xlsx"; |
| | | FileOutputStream fout = new FileOutputStream(file); |
| | | wb.write(fout); |
| | | fout.close(); |
| | | wb.close(); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | Process proc; |
| | | String[] args1 = new String[]{"python", "D:\\fz\\mou.py", String.valueOf(url)}; |
| | | try { |
| | | proc = Runtime.getRuntime().exec(args1); |
| | | 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(); |
| | | } |
| | | } |
| | | } |
| | | try { |
| | | file = "D:/mou.xlsx"; |
| | | FileOutputStream fout = new FileOutputStream(file); |
| | | wb.write(fout); |
| | | fout.close(); |
| | | wb.close(); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | Process proc; |
| | | try { |
| | | proc = Runtime.getRuntime().exec("python D:\\fz\\mou.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(); |
| | | } |
| | | }); |
| | | thread.start(); |
| | | return R.data(lists); |
| | | |
| | | } |
| | |
| | | double drp1 = w1.doubleValue(); |
| | | if (drp1 > 80) { |
| | | double v = drp1 - 80; |
| | | double v1 = (double) Math.round(v * 10) / 10; |
| | | map.put("flage3", "true"); |
| | | map.put("num", v); |
| | | map.put("num", v1); |
| | | } else { |
| | | map.put("flage3", "false"); |
| | | } |
| | | map.put("List", list.get(i)); |
| | | 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(new HSSFRichTextString("lon")); |
| | | cell = row.createCell((short) 1); |
| | | cell.setCellValue(new HSSFRichTextString("lat")); |
| | | cell = row.createCell((short) 2); |
| | | cell.setCellValue(new HSSFRichTextString("rain")); |
| | | for (int i = 0; i < list.size(); i++) { |
| | | // 第四步,创建单元格,并设置值 |
| | | row = sheet.createRow((int) i + 1); |
| | | HSSFCell celli = row.createCell((short) 0); |
| | | BigDecimal w1 = (BigDecimal) list.get(i).get("drp1"); |
| | | double drp1 = w1.doubleValue(); |
| | | row.createCell((short) 0).setCellValue(list.get(i).get("LGTD").toString()); |
| | | row.createCell((short) 1).setCellValue(list.get(i).get("LTTD").toString()); |
| | | if (drp1 > 80) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | Timestamp timestamp = new Timestamp(System.currentTimeMillis()); |
| | | long url = timestamp.getTime(); |
| | | Map m = new HashMap(); |
| | | m.put("url", url + ".png"); |
| | | lists.add(m); |
| | | Thread thread = new Thread(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | 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(new HSSFRichTextString("lon")); |
| | | cell = row.createCell((short) 1); |
| | | cell.setCellValue(new HSSFRichTextString("lat")); |
| | | cell = row.createCell((short) 2); |
| | | cell.setCellValue(new HSSFRichTextString("rain")); |
| | | for (int i = 0; i < list.size(); i++) { |
| | | // 第四步,创建单元格,并设置值 |
| | | row = sheet.createRow((int) i + 1); |
| | | HSSFCell celli = row.createCell((short) 0); |
| | | BigDecimal w1 = (BigDecimal) list.get(i).get("drp1"); |
| | | double drp1 = w1.doubleValue(); |
| | | row.createCell((short) 0).setCellValue(list.get(i).get("LGTD").toString()); |
| | | row.createCell((short) 1).setCellValue(list.get(i).get("LTTD").toString()); |
| | | if (drp1 > 80) { |
| | | row.createCell((short) 2).setCellValue(2); |
| | | continue; |
| | | |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | } else { |
| | | row.createCell((short) 2).setCellValue(1); |
| | | continue; |
| | | } |
| | | } |
| | | // 第六步,将文件存到指定位置 |
| | | try { |
| | | fileName = "D:/moup.xlsx"; |
| | | FileOutputStream fout = new FileOutputStream(fileName); |
| | | wb.write(fout); |
| | | fout.close(); |
| | | wb.close(); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | Process proc; |
| | | String[] args1 = new String[]{"python", "D:\\fz\\moup.py", String.valueOf(url)}; |
| | | try { |
| | | proc = Runtime.getRuntime().exec(args1); |
| | | 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(); |
| | | } |
| | | } |
| | | } |
| | | // 第六步,将文件存到指定位置 |
| | | try { |
| | | fileName = "D:/moup.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\\moup.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(); |
| | | } |
| | | }); |
| | | thread.start(); |
| | | return R.data(lists); |
| | | } |
| | | |
| | |
| | | * 土壤色斑图 |
| | | */ |
| | | @GetMapping("/selectS") |
| | | public void selectS(){ |
| | | List<Map<String, Object>> list = mountainrainService.selectS(); |
| | | public R selectS(String time) { |
| | | List<Map<String, Object>> list = mountainrainService.selectS(time); |
| | | String fileName = ""; |
| | | // 第一步,创建一个webbook,对应一个Excel文件 |
| | | HSSFWorkbook wb = new HSSFWorkbook(); |
| | |
| | | row.createCell((short) 0).setCellValue(list.get(i).get("LGTD").toString()); |
| | | row.createCell((short) 1).setCellValue(list.get(i).get("LTTD").toString()); |
| | | row.createCell((short) 2).setCellValue(list.get(i).get("soilval").toString()); |
| | | if (stcd.equals("62455350")){ |
| | | if (stcd.equals("62455350")) { |
| | | row.createCell((short) 0).setCellValue("117.344876"); |
| | | row.createCell((short) 1).setCellValue("27.827067"); |
| | | row.createCell((short) 2).setCellValue(list.get(i).get("soilval").toString()); |
| | | } |
| | | if (stcd.equals("62334845")){ |
| | | if (stcd.equals("62334845")) { |
| | | row.createCell((short) 0).setCellValue("115.625720"); |
| | | row.createCell((short) 1).setCellValue("27.152794"); |
| | | row.createCell((short) 2).setCellValue(list.get(i).get("soilval").toString()); |
| | | } |
| | | if (stcd.equals("62433800")){ |
| | | if (stcd.equals("62433800")) { |
| | | row.createCell((short) 0).setCellValue("115.618546"); |
| | | row.createCell((short) 1).setCellValue("27.683604"); |
| | | row.createCell((short) 2).setCellValue(list.get(i).get("soilval").toString()); |
| | | } |
| | | if (stcd.equals("62436760")){ |
| | | if (stcd.equals("62436760")) { |
| | | row.createCell((short) 0).setCellValue("116.060889"); |
| | | row.createCell((short) 1).setCellValue("28.216806"); |
| | | row.createCell((short) 2).setCellValue(list.get(i).get("soilval").toString()); |
| | | } |
| | | if (stcd.equals("62437250")){ |
| | | if (stcd.equals("62437250")) { |
| | | row.createCell((short) 0).setCellValue("116.622783"); |
| | | row.createCell((short) 1).setCellValue("28.489384"); |
| | | row.createCell((short) 2).setCellValue(list.get(i).get("soilval").toString()); |
| | | } |
| | | if (stcd.equals("62433700")){ |
| | | if (stcd.equals("62433700")) { |
| | | row.createCell((short) 0).setCellValue("115.558771"); |
| | | row.createCell((short) 1).setCellValue("27.518623"); |
| | | row.createCell((short) 2).setCellValue(list.get(i).get("soilval").toString()); |
| | | } |
| | | if (stcd.equals("62425740")){ |
| | | if (stcd.equals("62425740")) { |
| | | row.createCell((short) 0).setCellValue("117.208587"); |
| | | row.createCell((short) 1).setCellValue("27.298647"); |
| | | row.createCell((short) 2).setCellValue(list.get(i).get("soilval").toString()); |
| | | } |
| | | if (stcd.equals("62437235")){ |
| | | if (stcd.equals("62437235")) { |
| | | row.createCell((short) 0).setCellValue("116.780591"); |
| | | row.createCell((short) 1).setCellValue("28.391352"); |
| | | row.createCell((short) 2).setCellValue(list.get(i).get("soilval").toString()); |
| | | } |
| | | if (stcd.equals("62437250")){ |
| | | if (stcd.equals("62437250")) { |
| | | row.createCell((short) 0).setCellValue("116.555834"); |
| | | row.createCell((short) 1).setCellValue("28.518077"); |
| | | row.createCell((short) 2).setCellValue(list.get(i).get("soilval").toString()); |
| | |
| | | e.printStackTrace(); |
| | | } |
| | | Process proc; |
| | | Timestamp timestamp = new Timestamp(System.currentTimeMillis()); |
| | | long url = timestamp.getTime(); |
| | | Map m = new HashMap(); |
| | | m.put("url", url + ".png"); |
| | | String[] args1 = new String[]{"python", "D:\\fz\\tur.py", String.valueOf(url)}; |
| | | try { |
| | | proc = Runtime.getRuntime().exec("python D:\\fz\\tur.py"); |
| | | proc = Runtime.getRuntime().exec(args1); |
| | | BufferedReader in = new BufferedReader(new InputStreamReader(proc.getInputStream())); |
| | | String line = null; |
| | | while ((line = in.readLine()) != null) { |
| | |
| | | } catch (InterruptedException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | return R.data(m); |
| | | } |
| | | |
| | | } |
| | | public static Date beforeHourToNowDate(String date, int hours) { |
| | | Calendar c = Calendar.getInstance(); |
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | try { |
| | | c.setTime(sdf.parse(date)); |
| | | c.set(Calendar.HOUR_OF_DAY, c.get(Calendar.HOUR_OF_DAY) - hours); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | return c.getTime(); |
| | | } |
| | | } |
| | | |