抚州水文后端
parent: ec5c0176 | patch | commit | ignore whitespace
tangzy
2021-09-08 31cac151ee472f29ad6e6c57f6039c42ea863ded 
1.单位
1 files modified
117 ■■■■■ changed files
src/main/java/org/springblade/modules/rsvr/controller/RsvrRController.java 117 ●●●●● patch | view | raw | blame | history 
 src/main/java/org/springblade/modules/rsvr/controller/RsvrRController.java


@@ -181,7 +181,7 @@


            strArrays += "'" + split[i] + "',";


        }


        String code = strArrays.substring(0, strArrays.length() - 1);


        List<Map<String, Object>> sel = rsvrRService.sel(egmd, edmd,code);


        List<Map<String, Object>> sel = rsvrRService.sel(egmd, edmd, code);


        map.addAll(sel);


        //用来判断是否重复统计超警信息


        Map mnum = new HashMap();


@@ -228,7 +228,7 @@


                                BigDecimal inq = (BigDecimal) map.get(i).get("INQ");


                                double INQ = inq.doubleValue();


                                //DecimalFormat df = new DecimalFormat("#0.000");


                                texta += "入库流量" +INQ+ "(立方米每秒)、";


                                texta += "入库流量" + INQ + "(立方米每秒)、";


                            }


                            if (map.get(i).get("W") == null) {


                                texta += "蓄水量暂无数据、";


@@ -243,10 +243,10 @@


                                BigDecimal otq = (BigDecimal) map.get(i).get("OTQ");


                                double OTQ = otq.doubleValue();


                                //DecimalFormat df = new DecimalFormat("#0.000");


                                texta += "出库流量" +OTQ + "(立方米每秒);";


                                texta += "出库流量" + OTQ + "(立方米每秒);";


                            }


                        }


                        if(stnm.equals("廖坊")) {


                        if (stnm.equals("廖坊")) {


                            texth += "$$$$$" + stnm.replaceAll(" ", "") + "水库&&&&&:";


                            if (RZ == 0) {


                                texth += "库水位暂无数据、";


@@ -275,7 +275,7 @@


                                BigDecimal otq = (BigDecimal) map.get(i).get("OTQ");


                                double OTQ = otq.doubleValue();


                                //DecimalFormat df = new DecimalFormat("#0.000");


                                texth += "出库流量" +  OTQ + "(立方米每秒)。";


                                texth += "出库流量" + OTQ + "(立方米每秒)。";


                            }


                        }


                        alist.add(map.get(i));


@@ -313,7 +313,7 @@


                                texta += "出库流量" + OTQ + "(立方米每秒);";


                            }


                        }


                        if ( stnm.equals("廖坊")) {


                        if (stnm.equals("廖坊")) {


                            texth += "$$$$$" + stnm.replaceAll(" ", "") + "水库&&&&&:" + "库水位" + RZ + "m、";


                            if (map.get(i).get("INQ") == null) {


                                texth += "入库流量暂无数据、";


@@ -412,9 +412,9 @@




            }


            if (number == 0) {


                text += texta+texth;


                text += texta + texth;


            } else {


                text += "有" + number + "个水库站预警;" + texta+texth;


                text += "有" + number + "个水库站预警;" + texta + texth;


            }


            //水库涨幅,跌幅信息


            List<Map<String, Object>> selecthds = rsvrRService.selectsk(beginTime, endTime);


@@ -464,14 +464,18 @@


                    c.put(stcd, v3);


                }


            }


            //获取涨幅最大的信息


            Object maxKey = getMaxKey(m1);


            String s1 = m1.get(maxKey).toString();


            text += " 涨幅最大的是：" + s1 + "(涨" + maxKey + "米)。";


            //获取跌幅最大的信息


            Object maxKey2 = getMaxKey(m2);


            String s2 = m2.get(maxKey2).toString();


            text += " 跌幅最大的是：" + s2 + "(跌" + maxKey + "米)。";


            if (m1.size()!=0) {


                //获取涨幅最大的信息


                Object maxKey = getMaxKey(m1);


                String s1 = m1.get(maxKey).toString();


                text += " 涨幅最大的是：" + s1 + "(涨" + maxKey + "米)。";


            }


            if (m2.size()!=0) {


                //获取跌幅最大的信息


                Object maxKey2 = getMaxKey(m2);


                String s2 = m2.get(maxKey2).toString();


                text += " 跌幅最大的是：" + s2 + "(跌" + maxKey2 + "米)。";


            }


            m.put("text", text);


            m.put("number", number);


            m.put("Yjlist", ylist);


@@ -516,7 +520,7 @@


        //日


        String day = strs[2].toString();


        //定义短信内容头


        String text = year + "月" + day + "日"+hs+"时";


        String text = year + "月" + day + "日" + hs + "时";


        String texta = "";


        String texth = "";


        //定义统计数量


@@ -552,7 +556,7 @@


            }


        }


        //水库水情预警信息


        List<Map<String, Object>> map = rsvrRService.selectyjcks(egmd, edmd,timec,timez);


        List<Map<String, Object>> map = rsvrRService.selectyjcks(egmd, edmd, timec, timez);


        //用来判断是否重复统计超警信息


        Map mnum = new HashMap();


        //定义list保存预警信息


@@ -583,7 +587,7 @@


                    //站点名称


                    String stnm = map.get(i).get("STNM").toString();


                    //实时水库水位值


                    if (stnm.equals("洪门") ) {


                    if (stnm.equals("洪门")) {


                        texta += "$$$$$" + stnm.replaceAll(" ", "") + "水库&&&&&";


                        if (RZ == 0) {


                            texta += "库水位暂无数据、";


@@ -617,8 +621,7 @@


                            texta += "出库流量" + OTQ + "(立方米每秒);";


                        }


//                        texta += "汛限水位暂无数据;";


                    }


                    else if ( stnm.equals("廖坊")){


                    } else if (stnm.equals("廖坊")) {


                        texth += "$$$$$" + stnm.replaceAll(" ", "") + "水库&&&&&";


                        if (RZ == 0) {


                            texth += "库水位暂无数据、";


@@ -663,7 +666,7 @@


                    //站点名称


                    String stnm = map.get(i).get("STNM").toString();


                    //站点名称


                    if (stnm.equals("洪门") ) {


                    if (stnm.equals("洪门")) {


                        texta += "$$$$$" + stnm.replaceAll(" ", "") + "水库&&&&&";


                        if (RZ == 0) {


                            texta += "库水位暂无数据、";


@@ -697,8 +700,7 @@


                            texta += "出库流量" + OTQ + "(立方米每秒);";


                        }


//                        texta += "汛限水位暂无数据;";


                    }


                    else if ( stnm.equals("廖坊")){


                    } else if (stnm.equals("廖坊")) {


                        texth += "$$$$$" + stnm.replaceAll(" ", "") + "水库&&&&&";


                        if (RZ == 0) {


                            texth += "库水位暂无数据、";


@@ -748,7 +750,7 @@


                        String addvcd5 = map.get(i).get("ADDVNM").toString();


                        //站点名称


                        String stnm = map.get(i).get("STNM").toString();


                        if (stnm.equals("洪门") ) {


                        if (stnm.equals("洪门")) {


                            texta += "$$$$$" + stnm.replaceAll(" ", "") + "水库&&&&&";


                            if (RZ == 0) {


                                texta += "库水位暂无数据、";


@@ -782,8 +784,7 @@


                                texta += "出库流量" + OTQ + "(立方米每秒);";


                            }


//                        texta += "汛限水位暂无数据;";


                        }


                        else if ( stnm.equals("廖坊")){


                        } else if (stnm.equals("廖坊")) {


                            texth += "$$$$$" + stnm.replaceAll(" ", "") + "水库&&&&&";


                            if (RZ == 0) {


                                texth += "库水位暂无数据、";


@@ -821,9 +822,9 @@


                }


            }


            if (number == 0) {


                text += texta+texth;


                text += texta + texth;


            } else {


                text += "有" + number + "个水库站超汛限;" + texta+texth;


                text += "有" + number + "个水库站超汛限;" + texta + texth;


            }


        }


        Map m = new HashMap();


@@ -894,17 +895,17 @@


    public R selList(String stcd) {


        List<Map<String, Object>> newList = rsvrRService.selList(stcd);


        Map<String, List<Map>> mm = new HashMap();


        for(Map temp: newList){


            if(mm.containsKey(temp.get("LNNM")))


        for (Map temp : newList) {


            if (mm.containsKey(temp.get("LNNM")))


                mm.get(temp.get("LNNM")).add(temp);


            else{


            else {


                List<Map> ll = new ArrayList<>();


                ll.add(temp);


                mm.put((String) temp.get("LNNM"), ll);


            }


        }


        List<List<Map>> res = new ArrayList();


        for(Map.Entry<String, List<Map>> et: mm.entrySet()){


        for (Map.Entry<String, List<Map>> et : mm.entrySet()) {


            res.add(et.getValue());


        }


        return R.data(res);


@@ -947,8 +948,8 @@


     */


    @ApiLog("水库实时预警")


    @PostMapping("/selectyj")


    @ApiOperation(value = "水库实时预警",notes = "")


    public R selectyj(String times,int mou,int k){


    @ApiOperation(value = "水库实时预警", notes = "")


    public R selectyj(String times, int mou, int k) {


        Date date = null;


        // 把Date按照格式转换成字符串


        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");


@@ -959,8 +960,8 @@


        }


        String dateEnd = sdf.format(date);




        String egmd="";


        String edmd="";


        String egmd = "";


        String edmd = "";


        List<Map<String, Object>> selectfx = rsvrRService.selectfx();


        String b = (String) selectfx.get(0).get("BGMD");


        String e = (String) selectfx.get(0).get("EDMD");


@@ -970,35 +971,31 @@


        int es = Integer.parseInt(e.trim());


        int b2s = Integer.parseInt(b2.trim());


        int e2s = Integer.parseInt(e2.trim());


        if(mou>=bs&&mou<=es){


            egmd=b;


            edmd=e;


        }


        else if(mou>=b2s&&mou<=e2s) {


            egmd=b2;


            edmd=e2;


        }


        else {


            String mous="0901";


        if (mou >= bs && mou <= es) {


            egmd = b;


            edmd = e;


        } else if (mou >= b2s && mou <= e2s) {


            egmd = b2;


            edmd = e2;


        } else {


            String mous = "0901";


            int m = Integer.parseInt(mous);


            if(m>=bs&&m<=es){


                egmd=b;


                edmd=e;


            }


            else if(m>=b2s&&m<=e2s) {


                egmd=b2;


                edmd=e2;


            if (m >= bs && m <= es) {


                egmd = b;


                edmd = e;


            } else if (m >= b2s && m <= e2s) {


                egmd = b2;


                edmd = e2;


            }


        }


        List<Map<String, Object>> map;


        if(k==13){


            map = rsvrRService.selectyj(egmd,edmd,times,dateEnd);


        }


        else {


            map = rsvrRService.selectyj(egmd,edmd,times,dateEnd);


        if (k == 13) {


            map = rsvrRService.selectyj(egmd, edmd, times, dateEnd);


        } else {


            map = rsvrRService.selectyj(egmd, edmd, times, dateEnd);


        }


        List<Map<String, Object>> lists = new ArrayList<>();


        for(int i=0;i<map.size();i++) {


        for (int i = 0; i < map.size(); i++) {


            Map<String, Object> maps = new HashMap<String, Object>();


            BigDecimal bigDecimaldz = (BigDecimal) map.get(i).get("FSLTDZ");//汛限水位


            BigDecimal bigDecimalrz = (BigDecimal) map.get(i).get("RZ");//当前水位