fix: 增加出入库流量数据综合导出

backend/src/main/java/com/yfd/platform/qgc_export/processor/QiProcessor.java

@@ -0,0 +1,25 @@
+package com.yfd.platform.qgc_export.processor;
+
+import org.springframework.stereotype.Component;
+
+/**
+ * 入库流量(QI) 处理器
+ */
+@Component
+public class QiProcessor extends HydropwIndicatorProcessor {
+
+    @Override
+    public String getFieldName() {
+        return "QI";
+    }
+
+    @Override
+    public String getSheetName() {
+        return "入库流量";
+    }
+
+    @Override
+    public int getOrder() {
+        return 5;
+    }
+}

backend/src/main/java/com/yfd/platform/qgc_export/processor/QoProcessor.java

@@ -0,0 +1,25 @@
+package com.yfd.platform.qgc_export.processor;
+
+import org.springframework.stereotype.Component;
+
+/**
+ * 出库流量(QO) 处理器
+ */
+@Component
+public class QoProcessor extends HydropwIndicatorProcessor {
+
+    @Override
+    public String getFieldName() {
+        return "QO";
+    }
+
+    @Override
+    public String getSheetName() {
+        return "出库流量";
+    }
+
+    @Override
+    public int getOrder() {
+        return 6;
+    }
+}

backend/src/main/java/com/yfd/platform/qgc_export/service/impl/QgcExportServiceImpl.java

@@ -120,6 +120,12 @@ public class QgcExportServiceImpl implements IQgcExportService {
     @Resource
     private DzVariationProcessor dzVariationProcessor;
 
+    // QI/QO 出入库流量相关（STTP=ENG）
+    @Resource
+    private QiProcessor qiProcessor;
+    @Resource
+    private QoProcessor qoProcessor;
+
     private static final SimpleDateFormat SDF_TIME = new SimpleDateFormat("dd日 HH时");
 
     /** 基础汇总指标（7个） */
@@ -299,6 +305,9 @@ public class QgcExportServiceImpl implements IQgcExportService {
         processorMap.put("v", vProcessor);
         processorMap.put("q", qProcessor);
         processorMap.put("z", zProcessor);
+        // 出入库流量（STTP=ENG，仅标准格式无日变幅）
+        processorMap.put("qi", qiProcessor);
+        processorMap.put("qo", qoProcessor);
 
         // WQ 别名：展开为全部水质指标
         List<String> expanded = new ArrayList<>();
@@ -321,6 +330,19 @@ public class QgcExportServiceImpl implements IQgcExportService {
                 result.add(dwtVariationProcessor);
                 continue;
             }
+
+//            // RZ 坝上水位 → 展开为标准格式 + 日变幅两个 Sheet
+//            if ("qi".equals(field)) {
+//                qiProcessor.setMappers(sdHydropwRMapper, sdHydropwdaySMapper);
+//                result.add(qiProcessor);
+//                continue;
+//            }
+//            // DZ 坝下水位 → 展开为标准格式 + 日变幅两个 Sheet
+//            if ("qo".equals(field)) {
+//                qoProcessor.setMappers(sdHydropwRMapper, sdHydropwdaySMapper);
+//                result.add(qoProcessor);
+//                continue;
+//            }
             // RZ 坝上水位 → 展开为标准格式 + 日变幅两个 Sheet
             if ("rz".equals(field)) {
                 rzProcessor.setMappers(sdHydropwRMapper, sdHydropwdaySMapper);
@@ -344,6 +366,8 @@ public class QgcExportServiceImpl implements IQgcExportService {
                     ((RiverIndicatorProcessor) p).setMappers(sdRiverRMapper, sdRiverdaySMapper);
                 } else if (p instanceof WqIndicatorProcessor) {
                     ((WqIndicatorProcessor) p).setMappers(sdWqRMapper, sdWqdaySMapper);
+                } else if (p instanceof HydropwIndicatorProcessor) {
+                    ((HydropwIndicatorProcessor) p).setMappers(sdHydropwRMapper, sdHydropwdaySMapper);
                 }
                 result.add(p);
             }