fix: 增加sheet页排序和化学需氧量指标

This commit is contained in:
tangwei 2026-08-05 17:43:06 +08:00
parent bc1910b8d2
commit d5549e1541
17 changed files with 101 additions and 39 deletions

View File

@ -0,0 +1,30 @@
package com.yfd.platform.qgc_export.processor;
import org.springframework.stereotype.Component;
/**
* 电导率(COND) 指标处理器
*/
@Component
public class CodcrProcessor extends WqIndicatorProcessor {
@Override
public String getFieldName() {
return "CODCR";
}
@Override
public String getSheetName() {
return "水质(化学需氧量)";
}
@Override
public int getDecimalPlaces() {
return 2;
}
@Override
public int getOrder() {
return 12;
}
}

View File

@ -24,7 +24,7 @@ public class CondProcessor extends WqIndicatorProcessor {
} }
@Override @Override
public String getSttpType() { public int getOrder() {
return "WQ"; return 13;
} }
} }

View File

@ -24,7 +24,7 @@ public class DoxProcessor extends WqIndicatorProcessor {
} }
@Override @Override
public String getSttpType() { public int getOrder() {
return "WQ"; return 11;
} }
} }

View File

@ -19,4 +19,9 @@ public class DwtProcessor extends WtrvIndicatorProcessor {
public String getSheetName() { public String getSheetName() {
return "出库水温"; return "出库水温";
} }
@Override
public int getOrder() {
return 8;
}
} }

View File

@ -24,4 +24,9 @@ public class DwtVariationProcessor extends WtrvIndicatorProcessor {
public boolean isVariation() { public boolean isVariation() {
return true; return true;
} }
@Override
public int getOrder() {
return 9;
}
} }

View File

@ -17,4 +17,9 @@ public class DzProcessor extends HydropwIndicatorProcessor {
public String getSheetName() { public String getSheetName() {
return "坝下水位"; return "坝下水位";
} }
@Override
public int getOrder() {
return 3;
}
} }

View File

@ -22,4 +22,9 @@ public class DzVariationProcessor extends HydropwIndicatorProcessor {
public boolean isVariation() { public boolean isVariation() {
return true; return true;
} }
@Override
public int getOrder() {
return 4;
}
} }

View File

@ -56,6 +56,14 @@ public interface ExportIndicatorProcessor {
return false; return false;
} }
/**
* Sheet 排序号升序排列
* 数值越小越靠前同组指标标准格式应排在日变幅格式之前
*/
default int getOrder() {
return 100;
}
/** /**
* 查询原始数据 * 查询原始数据
* *

View File

@ -24,7 +24,7 @@ public class PhProcessor extends WqIndicatorProcessor {
} }
@Override @Override
public String getSttpType() { public int getOrder() {
return "WQ"; return 15;
} }
} }

View File

@ -9,17 +9,14 @@ import org.springframework.stereotype.Component;
public class QProcessor extends RiverIndicatorProcessor { public class QProcessor extends RiverIndicatorProcessor {
@Override @Override
public String getFieldName() { public String getFieldName() { return "Q"; }
return "Q";
}
@Override @Override
public String getSheetName() { public String getSheetName() { return "流量(m³/s)"; }
return "流量(m³/s)";
}
@Override @Override
public String getSttpType() { public String getSttpType() { return "ZQ"; }
return "ZQ";
} @Override
public int getOrder() { return 32; }
} }

View File

@ -17,4 +17,9 @@ public class RzProcessor extends HydropwIndicatorProcessor {
public String getSheetName() { public String getSheetName() {
return "坝上水位"; return "坝上水位";
} }
@Override
public int getOrder() {
return 1;
}
} }

View File

@ -22,4 +22,9 @@ public class RzVariationProcessor extends HydropwIndicatorProcessor {
public boolean isVariation() { public boolean isVariation() {
return true; return true;
} }
@Override
public int getOrder() {
return 2;
}
} }

View File

@ -24,7 +24,7 @@ public class TuProcessor extends WqIndicatorProcessor {
} }
@Override @Override
public String getSttpType() { public int getOrder() {
return "WQ"; return 14;
} }
} }

View File

@ -9,17 +9,14 @@ import org.springframework.stereotype.Component;
public class VProcessor extends RiverIndicatorProcessor { public class VProcessor extends RiverIndicatorProcessor {
@Override @Override
public String getFieldName() { public String getFieldName() { return "V"; }
return "V";
}
@Override @Override
public String getSheetName() { public String getSheetName() { return "流速(m/s)"; }
return "流速(m/s)";
}
@Override @Override
public String getSttpType() { public String getSttpType() { return "ZQ"; }
return "ZQ";
} @Override
public int getOrder() { return 33; }
} }

View File

@ -24,8 +24,7 @@ public class WtmpProcessor extends WqIndicatorProcessor {
} }
@Override @Override
public String getSttpType() { public int getOrder() {
return "WQ"; return 10;
} }
} }

View File

@ -9,17 +9,14 @@ import org.springframework.stereotype.Component;
public class ZProcessor extends RiverIndicatorProcessor { public class ZProcessor extends RiverIndicatorProcessor {
@Override @Override
public String getFieldName() { public String getFieldName() { return "Z"; }
return "Z";
}
@Override @Override
public String getSheetName() { public String getSheetName() { return "水位(m)"; }
return "水位(m)";
}
@Override @Override
public String getSttpType() { public String getSttpType() { return "ZQ"; }
return "ZQ";
} @Override
public int getOrder() { return 31; }
} }

View File

@ -86,6 +86,8 @@ public class QgcExportServiceImpl implements IQgcExportService {
@Resource @Resource
private WtmpProcessor wtmpProcessor; private WtmpProcessor wtmpProcessor;
@Resource @Resource
private CodcrProcessor codcrProcessor;
@Resource
private PhProcessor phProcessor; private PhProcessor phProcessor;
@Resource @Resource
private DoxProcessor doxProcessor; private DoxProcessor doxProcessor;
@ -288,6 +290,7 @@ public class QgcExportServiceImpl implements IQgcExportService {
Map<String, ExportIndicatorProcessor> processorMap = new LinkedHashMap<>(); Map<String, ExportIndicatorProcessor> processorMap = new LinkedHashMap<>();
// WQ 在前 // WQ 在前
processorMap.put("wtmp", wtmpProcessor); processorMap.put("wtmp", wtmpProcessor);
processorMap.put("codcr", codcrProcessor);
processorMap.put("ph", phProcessor); processorMap.put("ph", phProcessor);
processorMap.put("dox", doxProcessor); processorMap.put("dox", doxProcessor);
processorMap.put("cond", condProcessor); processorMap.put("cond", condProcessor);
@ -302,7 +305,7 @@ public class QgcExportServiceImpl implements IQgcExportService {
for (String field : dataFields) { for (String field : dataFields) {
String lower = field.trim().toLowerCase(); String lower = field.trim().toLowerCase();
if ("wq".equals(lower)) { if ("wq".equals(lower)) {
expanded.addAll(List.of("wtmp", "ph", "dox", "cond", "tu")); expanded.addAll(List.of("wtmp","codcr", "ph", "dox", "cond", "tu"));
} else { } else {
expanded.add(lower); expanded.add(lower);
} }
@ -345,6 +348,7 @@ public class QgcExportServiceImpl implements IQgcExportService {
result.add(p); result.add(p);
} }
} }
result.sort(Comparator.comparingInt(ExportIndicatorProcessor::getOrder));
return result; return result;
} }