|
@@ -324,7 +324,7 @@ public class ReportServiceImpl implements IReportService {
|
|
|
}
|
|
|
jo.remove("DFD10_GZSC");
|
|
|
jo.remove("DFD10_FZL");
|
|
|
- Map<String,String> str = this.getXlgzzTjByParam(DDYZLFXBList,key);
|
|
|
+ Map<String,String> str = AuxiliaryTools.getXlgzzTjByParam(DDYZLFXBList,key);
|
|
|
jo.put("sum",str.get("sc"));
|
|
|
jo.put("avg",ArithUtils.div(str.get("pjfzl"),str.get("xlts")));
|
|
|
ja.add(jo);
|
|
@@ -357,7 +357,7 @@ public class ReportServiceImpl implements IReportService {
|
|
|
}
|
|
|
jo2.remove("DFD10_GZSC");
|
|
|
jo2.remove("DFD10_FZL");
|
|
|
- Map<String,String> str = this.getXlgzzTjByParam(DDYZLFXBList,key);
|
|
|
+ Map<String,String> str = AuxiliaryTools.getXlgzzTjByParam(DDYZLFXBList,key);
|
|
|
jo2.put("sum",str.get("sc"));
|
|
|
jo2.put("avg",ArithUtils.div(str.get("pjfzl"),str.get("xlts")));
|
|
|
ja2.add(jo2);
|
|
@@ -385,7 +385,7 @@ public class ReportServiceImpl implements IReportService {
|
|
|
}else{
|
|
|
jo3 = JSONObject.fromObject(temp);
|
|
|
pbTemp.put(key,"1");
|
|
|
- Map<String,String> str = this.getXlPbgzzTjByParam(pbgzzList,key,"1");
|
|
|
+ Map<String,String> str = AuxiliaryTools.getXlPbgzzTjByParam(pbgzzList,key,"1");
|
|
|
jo3.put("sum",str.get("sc"));
|
|
|
jo3.put("avg",ArithUtils.div(str.get("pjfzl"),str.get("xlts")));
|
|
|
ja3.add(jo3);
|
|
@@ -396,7 +396,7 @@ public class ReportServiceImpl implements IReportService {
|
|
|
}else{
|
|
|
jo4 = JSONObject.fromObject(temp);
|
|
|
pbTemp2.put(key,"1");
|
|
|
- Map<String,String> str = this.getXlPbgzzTjByParam(pbgzzList,key,"2");
|
|
|
+ Map<String,String> str = AuxiliaryTools.getXlPbgzzTjByParam(pbgzzList,key,"2");
|
|
|
jo4.put("sum",str.get("sc"));
|
|
|
jo4.put("avg",ArithUtils.div(str.get("pjfzl"),str.get("xlts")));
|
|
|
ja4.add(jo4);
|
|
@@ -408,19 +408,18 @@ public class ReportServiceImpl implements IReportService {
|
|
|
List<Map<String, String>> qxlgdbbbList = db.getMybatisMapper(IReportBatchMapper.class).selectQxlgdbbData(map);
|
|
|
JSONArray jagd = new JSONArray();
|
|
|
if (qxlgdbbbList != null && !qxlgdbbbList.isEmpty()){
|
|
|
- int size = qxlgdbbbList.size();
|
|
|
Map<String,Object> gdTemp = new HashMap<String,Object>();
|
|
|
Map<String,String> temp = null;
|
|
|
String unit = "";
|
|
|
- for (int i = 0; i < size; i++) {
|
|
|
+ for (int i = 0; i < qxlgdbbbList.size(); i++) {
|
|
|
temp = qxlgdbbbList.get(i);
|
|
|
unit = temp.get("DFD11_GDDW");//单位
|
|
|
- if (unit ==null || "".equals(unit) ||gdTemp.containsKey(unit)){
|
|
|
+ if (unit ==null || "".equals(unit) || gdTemp.containsKey(unit)){
|
|
|
continue;
|
|
|
} else {
|
|
|
gdTemp.put(unit,"1");
|
|
|
JSONObject tempjo = JSONObject.fromObject(temp);
|
|
|
- this.getQxgdByParam(qxlgdbbbList,unit,tempjo);
|
|
|
+ AuxiliaryTools.getQxgdByParam(qxlgdbbbList,unit,tempjo);
|
|
|
jagd.add(tempjo);
|
|
|
}
|
|
|
}
|
|
@@ -441,12 +440,12 @@ public class ReportServiceImpl implements IReportService {
|
|
|
temp2.put("GZLS-D","");
|
|
|
for (int i = 0; i < jagd.size(); i++) {
|
|
|
temp1 = jagd.getJSONObject(i);
|
|
|
- temp2.put("KHZS",ArithUtils.add(temp2.getString("KHZS"),temp1.getString("KHZS")));
|
|
|
+ temp2.put("KHZS",ArithUtils.addToInt(temp2.getString("KHZS"),temp1.getString("KHZS")));
|
|
|
temp2.put("DDXCSJ",ArithUtils.add(temp2.getString("DDXCSJ"),temp1.getString("DDXCSJ")));
|
|
|
- temp2.put("GDCLSJ",ArithUtils.add(temp2.getString("KHZS"),temp1.getString("KHZS")));
|
|
|
- temp2.put("DDXCCSS",ArithUtils.add(temp2.getString("DDXCCSS"),temp1.getString("DDXCCSS")));
|
|
|
+ temp2.put("GDCLSJ",ArithUtils.add(temp2.getString("GDCLSJ"),temp1.getString("GDCLSJ")));
|
|
|
+ temp2.put("DDXCCSS",ArithUtils.addToInt(temp2.getString("DDXCCSS"),temp1.getString("DDXCCSS")));
|
|
|
temp2.put("GDCSZS",ArithUtils.add(temp2.getString("GDCSZS"),temp1.getString("GDCSZS")));
|
|
|
- temp2.put("GDZS",ArithUtils.add(temp2.getString("GDZS"),temp1.getString("GDZS")));
|
|
|
+ temp2.put("GDZS",ArithUtils.addToInt(temp2.getString("GDZS"),temp1.getString("GDZS")));
|
|
|
temp2.put("YSXJHD",ArithUtils.add(temp2.getString("YSXJHD"),temp1.getString("YSXJHD")));
|
|
|
temp2.put("GZLS-A",ArithUtils.add(temp2.getString("GZLS-A"),temp1.getString("GZLS-A")));
|
|
|
temp2.put("GZLS-B",ArithUtils.add(temp2.getString("GZLS-B"),temp1.getString("GZLS-B")));
|
|
@@ -464,401 +463,25 @@ public class ReportServiceImpl implements IReportService {
|
|
|
rstMap.put("result2",ja2);//线路过载
|
|
|
rstMap.put("result3",ja3);//配变过载
|
|
|
rstMap.put("result4",ja4);//配变重载
|
|
|
- rstMap.put("result5",jagd);//配变重载
|
|
|
+ rstMap.put("result5",jagd);//抢修工单
|
|
|
|
|
|
Map<String,Object> param = new HashMap<String,Object>();
|
|
|
param.put("maxZzsc",maxZzsc);
|
|
|
param.put("maxXlName",maxXlName);
|
|
|
-
|
|
|
param.put("maxZzsc2",maxZzsc2);
|
|
|
param.put("maxXlName2",maxXlName2);
|
|
|
//获取配变过载数据最大值
|
|
|
- this.getMaxPbByParam(pbgzzList,param);
|
|
|
+ AuxiliaryTools.getMaxPbByParam(pbgzzList,param);
|
|
|
//获取配变重载数据最大值
|
|
|
- rstMap.put("descStr",this.getXlgzzDesc(ja,ja2,param));
|
|
|
- rstMap.put("descStr2",this.getXlPbgzzDesc(ja3,ja4,param));
|
|
|
- }
|
|
|
- return rstMap;
|
|
|
- }
|
|
|
-
|
|
|
- private Map<String, String> getQxgdByParam(List<Map<String, String>> list, String unit, JSONObject tempjo) {
|
|
|
- String id = "";
|
|
|
- try {
|
|
|
- id = tempjo.getString("DFD11_ID");
|
|
|
- } catch (Exception e){
|
|
|
- id = "";
|
|
|
- }
|
|
|
- if(list != null && !list.isEmpty()){
|
|
|
- int size = list.size();
|
|
|
- JSONObject temp;
|
|
|
- String tempId = "",tempUnit = "",gzlx = "";
|
|
|
- JSONObject ddd , ddd2;
|
|
|
- for (int i = 0; i < size; i++) {
|
|
|
- temp = JSONObject.fromObject(list.get(i));
|
|
|
- tempUnit = temp.getString("DFD11_GDDW");
|
|
|
- if(unit.equals(tempUnit)){
|
|
|
- gzlx = temp.getString("GZLX");
|
|
|
- switch (gzlx){
|
|
|
- case "A":
|
|
|
- tempjo.put("GZLS-A",ArithUtils.add(tempjo.getString("GZLS-A"),String.valueOf(1)));
|
|
|
- break;
|
|
|
- case "B":
|
|
|
- tempjo.put("GZLS-B",ArithUtils.add(tempjo.getString("GZLS-B"),String.valueOf(1)));
|
|
|
- break;
|
|
|
- case "C":
|
|
|
- tempjo.put("GZLS-C",ArithUtils.add(tempjo.getString("GZLS-C"),String.valueOf(1)));
|
|
|
- break;
|
|
|
- case "D":
|
|
|
- tempjo.put("GZLS-D",ArithUtils.add(tempjo.getString("GZLS-D"),String.valueOf(1)));
|
|
|
- break;
|
|
|
- default:
|
|
|
- break;
|
|
|
- }
|
|
|
- tempjo.put("GDZS",ArithUtils.add(tempjo.getString("GDZS"),String.valueOf(1)));//工单总数 累加
|
|
|
- tempjo.put("DFD11_QXZSC",ArithUtils.add(tempjo.getString("DFD11_QXZSC"),temp.getString("DFD11_QXZSC")));//抢修总时长累加
|
|
|
- ddd = JSONObject.fromObject(temp.get("DFD11_TJSHSJ"));
|
|
|
- ddd2 = JSONObject.fromObject(temp.get("DFD11_GDSJ"));
|
|
|
- tempjo.put("GDCLSJ",ArithUtils.add(tempjo.getString("GDCLSJ"),StringUtil.ObjectToString(StringUtil.dateCalculate2((Long)ddd.get("time"),(Long)ddd2.get("time")))));
|
|
|
- ddd = JSONObject.fromObject(temp.get("DFD11_SCPFQXDSJ"));
|
|
|
- ddd2 = JSONObject.fromObject(temp.get("DFD11_DWXCSJ"));
|
|
|
- tempjo.put("DDXCSJ",ArithUtils.add(tempjo.getString("DDXCSJ"),StringUtil.ObjectToString(StringUtil.dateCalculate2((Long)ddd.get("time"),(Long)ddd2.get("time")))));
|
|
|
- tempjo.remove("DFD11_TJSHSJ");
|
|
|
- tempjo.remove("DFD11_GDSJ");
|
|
|
- tempjo.remove("DFD11_SCPFQXDSJ");
|
|
|
- tempjo.remove("DFD11_DWXCSJ");
|
|
|
- }
|
|
|
-// }
|
|
|
- }
|
|
|
- }
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 获取配变描述信息
|
|
|
- * @param ja3 过载
|
|
|
- * @param ja4 重载
|
|
|
- * @param param
|
|
|
- * @return
|
|
|
- */
|
|
|
- private List<String> getXlPbgzzDesc(JSONArray ja3, JSONArray ja4, Map<String, Object> param) {
|
|
|
- List<String> list = new ArrayList<String>();
|
|
|
- StringBuffer descStr = new StringBuffer();
|
|
|
- //过载
|
|
|
- String maxGb = StringUtil.ObjectToString(param.get("maxPbName1"));
|
|
|
- String avg = "";
|
|
|
- if(ja3 != null && !ja3.isEmpty()){
|
|
|
- descStr.append("监测发现公变过载")
|
|
|
- .append(ja3.size())
|
|
|
- .append("个,");
|
|
|
- int size = ja3.size();
|
|
|
- Map<String,Object> temp = new HashMap<String,Object>();
|
|
|
- for (int i = 0; i < size; i++) {
|
|
|
- JSONObject jo = ja3.getJSONObject(i);
|
|
|
- String key = jo.getString("KEYSS");
|
|
|
- if(key.equals(maxGb)){
|
|
|
- avg = jo.getString("avg");
|
|
|
- maxGb = jo.getString("DFD9_GBMC");
|
|
|
- }
|
|
|
- String unit = jo.getString("DFD9_UNIT");
|
|
|
- if(temp.containsKey(unit)){
|
|
|
- temp.put(unit,Integer.valueOf(String.valueOf(temp.get(unit))) + 1);
|
|
|
- }else{
|
|
|
- temp.put(unit,1);
|
|
|
- }
|
|
|
- }
|
|
|
- if(!temp.isEmpty()){
|
|
|
- descStr.append("分别为");
|
|
|
- }
|
|
|
- for (Map.Entry<String, Object> entry : temp.entrySet()) {
|
|
|
- descStr.append(entry.getKey())
|
|
|
- .append(entry.getValue())
|
|
|
- .append("个,");
|
|
|
- }
|
|
|
- descStr.append("其中").append(maxGb).append(",");
|
|
|
- descStr.append("过载时长最长" + StringUtil.ObjToFloat(param.get("maxPb1")) + "小时,平均负载率为" + avg + "%。")
|
|
|
- .append("原因为:")
|
|
|
- .append(param.get("reason1"))
|
|
|
- .append("。")
|
|
|
- .append("措施为:")
|
|
|
- .append(param.get("cs1"))
|
|
|
- .append("。");
|
|
|
- descStr.append("不涉及电采暖线路。");
|
|
|
- }else{
|
|
|
- descStr.append("监测发现公变过载。");
|
|
|
- }
|
|
|
- //重载
|
|
|
- StringBuffer descStr2 = new StringBuffer();
|
|
|
- String maxGb2 = StringUtil.ObjectToString(param.get("maxPbName2"));
|
|
|
- String avg2 = "";
|
|
|
- if(ja4 != null && !ja4.isEmpty()){
|
|
|
- descStr2.append("监测发现公变重载")
|
|
|
- .append(ja4.size())
|
|
|
- .append("个,");
|
|
|
- int size = ja4.size();
|
|
|
- Map<String,Object> temp = new HashMap<String,Object>();
|
|
|
- for (int i = 0; i < size; i++) {
|
|
|
- JSONObject jo = ja4.getJSONObject(i);
|
|
|
- String key = jo.getString("KEYSS");
|
|
|
- if(key.equals(maxGb2)){
|
|
|
- avg2 = jo.getString("avg");
|
|
|
- maxGb2 = jo.getString("DFD9_GBMC");
|
|
|
- }
|
|
|
- String unit = jo.getString("DFD9_UNIT");
|
|
|
- if(temp.containsKey(unit)){
|
|
|
- temp.put(unit,Integer.valueOf(String.valueOf(temp.get(unit))) + 1);
|
|
|
- }else{
|
|
|
- temp.put(unit,1);
|
|
|
- }
|
|
|
- }
|
|
|
- if(!temp.isEmpty()){
|
|
|
- descStr2.append("分别为");
|
|
|
- for (Map.Entry<String, Object> entry : temp.entrySet()) {
|
|
|
- descStr2.append(entry.getKey())
|
|
|
- .append(entry.getValue())
|
|
|
- .append("个,");
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- descStr2.append("其中").append(maxGb2).append(",");
|
|
|
- descStr2.append("重载时长最长" + StringUtil.ObjToFloat(param.get("maxPb2")) + "小时,平均负载率为" + avg2 + "%。")
|
|
|
- .append("原因为:")
|
|
|
- .append(param.get("reason1"))
|
|
|
- .append("。")
|
|
|
- .append("措施为:")
|
|
|
- .append(param.get("cs1"))
|
|
|
- .append("。");
|
|
|
- descStr2.append("不涉及电采暖线路。");
|
|
|
- }else{
|
|
|
- descStr2.append("监测发现公变过载。");
|
|
|
- }
|
|
|
- list.add(descStr.toString());
|
|
|
- list.add(descStr2.toString());
|
|
|
- return list;
|
|
|
- }
|
|
|
+ rstMap.put("descStr",AuxiliaryTools.getXlgzzDesc(ja,ja2,param));
|
|
|
+ rstMap.put("descStr2",AuxiliaryTools.getXlPbgzzDesc(ja3,ja4,param));
|
|
|
+ rstMap.put("descStr3",AuxiliaryTools.getQxgdDesc(jagd,param));
|
|
|
|
|
|
- /**
|
|
|
- * 查找最大值详情
|
|
|
- * @param list
|
|
|
- * @param param
|
|
|
- */
|
|
|
- private void getMaxPbByParam(List<Map<String, String>> list, Map<String, Object> param) {
|
|
|
- List<Map<String, String>> tempList1 = new ArrayList<Map<String, String>>();
|
|
|
- List<Map<String, String>> tempList2 = new ArrayList<Map<String, String>>();
|
|
|
- if(list != null && !list.isEmpty()){
|
|
|
- for (int i = 0; i < list.size(); i++) {
|
|
|
- Map<String, String> temp = list.get(i);
|
|
|
- Object fzl = temp.get("DFD9_FZL");
|
|
|
- if(StringUtil.ObjToFloat(fzl) > 100){
|
|
|
- tempList1.add(temp);
|
|
|
- }else if(StringUtil.ObjToFloat(fzl) <= 100 && StringUtil.ObjToFloat(fzl) >= 80){
|
|
|
- tempList2.add(temp);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- //获取配变数据最大值
|
|
|
- float maxPb1 = 0f;
|
|
|
- float maxPb2 = 0f;
|
|
|
- //过载
|
|
|
- if(tempList1 != null && !tempList1.isEmpty()){
|
|
|
- int size = tempList1.size();
|
|
|
- for (int i = 0; i < size; i++) {
|
|
|
- Map<String, String> temp = tempList1.get(i);
|
|
|
- float fzl = StringUtil.ObjToFloat(temp.get("DFD9_GZSC"));
|
|
|
- if(maxPb1 < fzl){
|
|
|
- maxPb1 = fzl;
|
|
|
- param.put("gbmc1",temp.get("DFD9_GBMC"));//公变名称
|
|
|
- param.put("reason1",temp.get("DFD9_JTYY"));//具体原因
|
|
|
- param.put("cs1",temp.get("DFD9_JTJJCS"));//具体解决措施
|
|
|
- param.put("maxPbName1",temp.get("KEYSS"));
|
|
|
- }
|
|
|
- }
|
|
|
- param.put("maxPb1",maxPb1);
|
|
|
- }
|
|
|
- //重载
|
|
|
- if(tempList2 != null && !tempList2.isEmpty()){
|
|
|
- int size = tempList2.size();
|
|
|
- for (int i = 0; i < size; i++) {
|
|
|
- Map<String, String> temp = tempList2.get(i);
|
|
|
- float fzl = StringUtil.ObjToFloat(temp.get("DFD9_ZZSC"));
|
|
|
- if(maxPb2 < fzl){
|
|
|
- maxPb2 = fzl;
|
|
|
- param.put("gbmc2",temp.get("DFD9_GBMC"));//公变名称
|
|
|
- param.put("reason2",temp.get("DFD9_JTYY"));//具体原因
|
|
|
- param.put("cs2",temp.get("DFD9_JTJJCS"));//具体解决措施
|
|
|
- param.put("maxPbName2",temp.get("KEYSS"));
|
|
|
- }
|
|
|
- }
|
|
|
- param.put("maxPb2",maxPb2);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 获取线路配变重过载数据
|
|
|
- * @param pbgzzList
|
|
|
- * @param key
|
|
|
- * @return
|
|
|
- */
|
|
|
- private Map<String, String> getXlPbgzzTjByParam(List<Map<String, String>> pbgzzList, String key,String type) {
|
|
|
- Map<String,String> rstMap = new HashMap<String,String>();
|
|
|
- rstMap.put("sc","");
|
|
|
- rstMap.put("pjfzl","");
|
|
|
- rstMap.put("xlts","");
|
|
|
- if(pbgzzList == null || pbgzzList.isEmpty()){
|
|
|
- return rstMap;
|
|
|
- }else{
|
|
|
- int size = pbgzzList.size();
|
|
|
- float sum = 0f;
|
|
|
- float avg = 0f;
|
|
|
- int index = 0;
|
|
|
- for (int i = 0; i < size; i++) {
|
|
|
- Map<String,String> temp = pbgzzList.get(i);
|
|
|
- Object fzl = temp.get("DFD9_FZL");
|
|
|
- if("1".equals(type) && StringUtil.ObjToFloat(fzl) > 100){//过载
|
|
|
- String tempkey = temp.get("KEYSS");//单位
|
|
|
- if(tempkey.equals(key)){
|
|
|
- sum = ArithUtils.add(String.valueOf(sum),String.valueOf(temp.get("DFD9_GZSC")));
|
|
|
- avg = ArithUtils.add(String.valueOf(avg),String.valueOf(temp.get("DFD9_FZL")));
|
|
|
- index ++;
|
|
|
- }
|
|
|
- }else if("2".equals(type) && StringUtil.ObjToFloat(fzl) <= 100 && StringUtil.ObjToFloat(fzl) >= 80) {//重载
|
|
|
- String tempkey = temp.get("KEYSS");//单位
|
|
|
- if(tempkey.equals(key)){
|
|
|
- sum = ArithUtils.add(String.valueOf(sum),String.valueOf(temp.get("DFD9_ZZSC")));
|
|
|
- avg = ArithUtils.add(String.valueOf(avg),String.valueOf(temp.get("DFD9_FZL")));
|
|
|
- index ++;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
- rstMap.put("sc",StringUtil.ObjectToString(sum));
|
|
|
- rstMap.put("pjfzl",StringUtil.ObjectToString(avg));
|
|
|
- rstMap.put("xlts",StringUtil.ObjectToString(index));
|
|
|
}
|
|
|
return rstMap;
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 获取线路描述信息
|
|
|
- * @param ja 重载
|
|
|
- * @param ja2 过载
|
|
|
- * @param param 附加参数
|
|
|
- * @return
|
|
|
- */
|
|
|
- private List<String> getXlgzzDesc(JSONArray ja,JSONArray ja2,Map<String,Object> param) {
|
|
|
- String maxXlName = StringUtil.ObjectToString(param.get("maxXlName"));
|
|
|
- List<String> list = new ArrayList<String>();
|
|
|
- StringBuffer rst = new StringBuffer();
|
|
|
- if(ja == null || ja.size() <= 0){
|
|
|
- rst.append("监测未发现线路重载。");
|
|
|
- }else{
|
|
|
- rst.append("监测发现线路重载")
|
|
|
- .append(ja.size() )
|
|
|
- .append("条。");
|
|
|
- Map<String,Object> map = new HashMap<String,Object>();
|
|
|
- String xlmc = "";
|
|
|
- for (int i = 0; i < ja.size(); i++) {
|
|
|
- JSONObject jo = ja.getJSONObject(i);
|
|
|
- String key = StringUtil.ObjectToString(jo.get("DFD10_XGSMC"));//县公司名称
|
|
|
- String keys = StringUtil.ObjectToString(jo.get("KEYSS"));
|
|
|
- if(maxXlName.equals(keys)){
|
|
|
- maxXlName = jo.getString("avg");
|
|
|
- xlmc = jo.getString("DFD10_XLMC");
|
|
|
- }
|
|
|
- if(map.containsKey(key)){
|
|
|
- map.put(key,Integer.valueOf(String.valueOf(map.get(key))) + 1);
|
|
|
- }else{
|
|
|
- map.put(key,1);
|
|
|
- }
|
|
|
- }
|
|
|
- if(!map.isEmpty()){
|
|
|
- rst.append("分别为");
|
|
|
- }
|
|
|
- for (Map.Entry<String, Object> entry : map.entrySet()) {
|
|
|
- rst.append(entry.getKey())
|
|
|
- .append(entry.getValue())
|
|
|
- .append("条,");
|
|
|
- }
|
|
|
- rst.append("其中").append(xlmc).append(",");
|
|
|
- rst.append("重载时长最长" + StringUtil.ObjToFloat(param.get("maxZzsc")) + "小时,平均负载率为" + maxXlName + "%。");
|
|
|
- rst.append("不涉及电采暖线路。");
|
|
|
- }
|
|
|
-
|
|
|
- //******************************过载***************************************//
|
|
|
- StringBuffer rst2 = new StringBuffer();
|
|
|
- maxXlName = StringUtil.ObjectToString(param.get("maxXlName2"));
|
|
|
- if(ja2 == null || ja2.size() <= 0){
|
|
|
- rst2.append("监测未发现线路过载。");
|
|
|
- }else{
|
|
|
- rst2.append("监测发现线路过载");
|
|
|
- rst2.append(ja2.size() )
|
|
|
- .append("条。");
|
|
|
- Map<String,Object> map = new HashMap<String,Object>();
|
|
|
- String xlmc = "";
|
|
|
- for (int i = 0; i < ja2.size(); i++) {
|
|
|
- JSONObject jo = ja2.getJSONObject(i);
|
|
|
- String key = StringUtil.ObjectToString(jo.get("DFD10_XGSMC"));//县公司名称
|
|
|
- String keys = StringUtil.ObjectToString(jo.get("KEYSS"));
|
|
|
-
|
|
|
- if(maxXlName.equals(keys)){
|
|
|
- maxXlName = jo.getString("avg");
|
|
|
- xlmc = jo.getString("DFD10_XLMC");
|
|
|
- }
|
|
|
- if(map.containsKey(key)){
|
|
|
- map.put(key,Integer.valueOf(String.valueOf(map.get(key))) + 1);
|
|
|
- }else{
|
|
|
- map.put(key,1);
|
|
|
- }
|
|
|
- }
|
|
|
- if(!map.isEmpty()){
|
|
|
- rst2.append("分别为");
|
|
|
- }
|
|
|
- for (Map.Entry<String, Object> entry : map.entrySet()) {
|
|
|
- rst2.append(entry.getKey())
|
|
|
- .append(entry.getValue())
|
|
|
- .append("条,");
|
|
|
- }
|
|
|
- rst2.append("其中").append(xlmc).append(",");
|
|
|
- rst2.append("过载时长最长" + StringUtil.ObjToFloat(param.get("maxZzsc")) + "小时,平均负载率为" + maxXlName + "%。");
|
|
|
- rst2.append("不涉及电采暖线路。");
|
|
|
- }
|
|
|
- list.add(rst.toString());
|
|
|
- list.add(rst2.toString());
|
|
|
- return list;
|
|
|
- }
|
|
|
|
|
|
- /**
|
|
|
- * 获取线路统计信息
|
|
|
- * @param ddyzlfxbList
|
|
|
- * @param key
|
|
|
- * @return
|
|
|
- */
|
|
|
- private Map<String, String> getXlgzzTjByParam(List<Map<String, String>> ddyzlfxbList,String key) {
|
|
|
- Map<String,String> map = new HashMap<String,String>();
|
|
|
- if(ddyzlfxbList == null || ddyzlfxbList.isEmpty()){
|
|
|
- map.put("sc","");
|
|
|
- map.put("pjfzl","");
|
|
|
- map.put("xlts","");
|
|
|
- return map;
|
|
|
- }else{
|
|
|
- Map<String,String> temp = new HashMap<String,String>();
|
|
|
- float sum = 0f;
|
|
|
- int index = 0;
|
|
|
- float avg = 0f;
|
|
|
- for (int i = 0; i < ddyzlfxbList.size(); i++) {
|
|
|
- temp = ddyzlfxbList.get(i);
|
|
|
- String tempkey = temp.get("KEYSS");//单位
|
|
|
- if(key.equals(tempkey)){
|
|
|
- sum = ArithUtils.add(String.valueOf(sum),String.valueOf(temp.get("DFD10_GZSC")));
|
|
|
- avg = ArithUtils.add(String.valueOf(avg),String.valueOf(temp.get("DFD10_FZL")));
|
|
|
- index ++;
|
|
|
- }
|
|
|
- }
|
|
|
- map.put("sc",sum + "");
|
|
|
- map.put("pjfzl",avg + "");
|
|
|
- map.put("xlts",index + "");
|
|
|
- }
|
|
|
- return map;
|
|
|
- }
|
|
|
|
|
|
/**
|
|
|
* 台区停电日报
|