From 164454c61e83423b911133e7b8976c5681e353d2 Mon Sep 17 00:00:00 2001
From: chenlong <vip_chenlong@163.com>
Date: Mon, 11 Mar 2024 17:53:36 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84=E5=BA=93=E5=AD=98=E5=93=81?=
 =?UTF-8?q?=E6=98=8E=E7=BB=86=E7=BB=9F=E8=AE=A1=EF=BC=8C=E5=AF=BC=E5=87=BA?=
 =?UTF-8?q?=E5=BE=85=E5=AE=9A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/StockOutDetailController.java  | 13 ++-
 .../report/mapper/StockOutDetailMapper.java   |  5 ++
 .../report/mapper/StockOutDetailMapper.xml    | 20 +++++
 .../report/service/StockOutDetailService.java |  4 +-
 .../impl/StockOutDetailServiceImp.java        | 90 +++++++++++++++++--
 5 files changed, 120 insertions(+), 12 deletions(-)

diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/controller/StockOutDetailController.java b/blade-service/logpm-report/src/main/java/com/logpm/report/controller/StockOutDetailController.java
index cea6f79a1..e4c7c9442 100644
--- a/blade-service/logpm-report/src/main/java/com/logpm/report/controller/StockOutDetailController.java
+++ b/blade-service/logpm-report/src/main/java/com/logpm/report/controller/StockOutDetailController.java
@@ -29,11 +29,20 @@ public class StockOutDetailController extends BladeController {
 	 * @param size    每页数据量
      */
 	@GetMapping("/report")
-	public R<List<Map<String, Object>>> report(
+	public R<Map<String, Object>> report(
 		@RequestParam Map<String, Object> query,
 		@RequestParam Integer current,
 		@RequestParam Integer size){
-		List<Map<String, Object>> data = test.report(current, size, query);
+		Map<String, Object> data = test.report(current, size, query);
 		return data(data);
 	}
+
+	/**
+	 * 报表数据导出
+	 * @param query 所有请求参数
+	 */
+	@GetMapping("/export")
+	public void export(@RequestParam Map<String, Object> query) {
+		test.reportExport(query);
+	}
 }
diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/StockOutDetailMapper.java b/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/StockOutDetailMapper.java
index b585848a4..ba4849ee5 100644
--- a/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/StockOutDetailMapper.java
+++ b/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/StockOutDetailMapper.java
@@ -1,6 +1,8 @@
 package com.logpm.report.mapper;
 
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Options;
+import org.apache.ibatis.cursor.Cursor;
 
 import java.util.List;
 import java.util.Map;
@@ -13,5 +15,8 @@ public interface StockOutDetailMapper {
 
 	List<Map<String, Object>> getList(Map<String, Object> where);
 
+	@Options(fetchSize = Integer.MIN_VALUE)
+	Cursor<Map<String, Object>> getListCursor(Map<String, Object> where);
+
 	Integer getCount(Map<String, Object> where);
 }
diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/StockOutDetailMapper.xml b/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/StockOutDetailMapper.xml
index 0a281a4d2..f1b80a818 100644
--- a/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/StockOutDetailMapper.xml
+++ b/blade-service/logpm-report/src/main/java/com/logpm/report/mapper/StockOutDetailMapper.xml
@@ -29,6 +29,26 @@
 
             LIMIT #{offset}, #{size}
     </select>
+    <select id="getListCursor" resultType="java.util.Map">
+        SELECT b.goods_allocation_name        -- 货位
+             , a.stock_quantity               -- 数量
+             , a.coding                       -- 包条码
+             , w.name       as warehouse_name -- 仓库
+             , c.market_name                  -- 商场
+             , c.cargo_number                 -- 物料编码
+             , m.name       as material_name  -- 物料名称
+             , a.create_time                  -- 时间
+             , a.conditions as out_type       -- 出库类型
+             , e.note_number                  -- 配送单号
+             , e.train_number                 -- 车次号
+             , a.reservation_code             -- 预约单号
+             , r.consignee  as client_name    -- 收货人（客户名称）
+             , a.id
+
+            <include refid="tables" />
+
+            <include refid="wheres" />
+    </select>
 
     <select id="getCount" resultType="java.lang.Integer">
         SELECT count(*)
diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/service/StockOutDetailService.java b/blade-service/logpm-report/src/main/java/com/logpm/report/service/StockOutDetailService.java
index bbfcc9c31..e5b968cca 100644
--- a/blade-service/logpm-report/src/main/java/com/logpm/report/service/StockOutDetailService.java
+++ b/blade-service/logpm-report/src/main/java/com/logpm/report/service/StockOutDetailService.java
@@ -5,5 +5,7 @@ import java.util.Map;
 
 public interface StockOutDetailService {
 
-	List<Map<String, Object>> report(Integer current, Integer size, Map<String, Object> where);
+	Map<String, Object> report(Integer current, Integer size, Map<String, Object> where);
+
+	void reportExport(Map<String, Object> where);
 }
diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/StockOutDetailServiceImp.java b/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/StockOutDetailServiceImp.java
index 01edf7b54..700c4510c 100644
--- a/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/StockOutDetailServiceImp.java
+++ b/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/StockOutDetailServiceImp.java
@@ -3,12 +3,16 @@ package com.logpm.report.service.impl;
 import com.logpm.report.mapper.StockOutDetailMapper;
 import com.logpm.report.service.StockOutDetailService;
 import lombok.AllArgsConstructor;
+import org.apache.ibatis.cursor.Cursor;
+import org.apache.ibatis.session.SqlSession;
+import org.apache.ibatis.session.SqlSessionFactory;
+import org.jetbrains.annotations.Nullable;
+import org.springblade.core.redis.cache.BladeRedis;
 import org.springframework.stereotype.Service;
 
-import java.util.Collection;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.stream.Collectors;
 
 /**
  * 库存品出口明细报表
@@ -19,6 +23,10 @@ public class StockOutDetailServiceImp implements StockOutDetailService {
 
 	private StockOutDetailMapper testMapper;
 
+	private BladeRedis redis;
+
+	private SqlSessionFactory sqlSessionFactory;
+
 	/**
 	 * 报表统计信息
 	 *
@@ -28,8 +36,66 @@ public class StockOutDetailServiceImp implements StockOutDetailService {
 	 * @return 查询结果
 	 */
 	@Override
-	public List<Map<String, Object>> report(Integer current, Integer size, Map<String, Object> query) {
+	public Map<String, Object> report(Integer current, Integer size, Map<String, Object> query) {
+
+		HashMap<String, Object> res = new HashMap<>();
+
+		res.put("records", getList(current, size, query));
+		res.put("total", getCount(query));
+		res.put("current", current);
+		res.put("size", size);
+		res.put("pages", (int) Math.ceil((double) (int) res.get("total") / size));
+
+		return res;
+	}
+
+	/**
+	 * 报表导出
+	 *
+	 * @param where 条件
+	 */
+	@Override
+	public void reportExport(Map<String, Object> where) {
+		try (
+			SqlSession sqlSession = sqlSessionFactory.openSession();
+			Cursor<Map<String, Object>> listCursor = sqlSession.getMapper(StockOutDetailMapper.class).getListCursor(where)
+		) {
+
+			listCursor.forEach(stringObjectMap -> {
+				// 写入 excel
+				System.out.println(stringObjectMap.get("id"));
+			});
+
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+	}
+
+	/**
+	 * 获取当前查询的数据
+	 *
+	 * @param current 当前页数
+	 * @param size    数据量
+	 * @param query   查询条件集合
+	 * @return 数据列表
+	 */
+	private List<Map<String, Object>> getList(Integer current, Integer size, Map<String, Object> query) {
 		Integer offset = (current - 1) * size;
+		query.put("offset", offset);
+		query.put("size", size);
+
+		return testMapper.getList(query);
+	}
+
+	/**
+	 * 获取当前查询的总数据量
+	 *
+	 * @param query 请求的参数集合
+	 * @return 数量
+	 */
+	@Nullable
+	private Integer getCount(Map<String, Object> query) {
+		// 是否需要获取缓存的数据，如果没有查询条件时才获取缓存数据
 		boolean getCacheCount = true;
 		long whereCount = query.entrySet().stream().filter((entry) -> entry.getValue() != null)
 			.filter(entry -> !entry.getKey().equals("current") && !entry.getKey().equals("size"))
@@ -38,12 +104,18 @@ public class StockOutDetailServiceImp implements StockOutDetailService {
 			getCacheCount = false;
 		}
 
-		query.put("offset", offset);
-		query.put("size", size);
-
-		List<Map<String, Object>> List = testMapper.getList(query);
-		Integer count = testMapper.getCount(query);
+		Integer count;
+		if (getCacheCount) {
+			// 这里的key需要调整为租户模式
+			String key = "test-st";
+			if (!redis.exists(key)) {
+				redis.setEx(key, testMapper.getCount(query), 600L);
+			}
+			count = redis.get(key);
+		} else {
+			count = testMapper.getCount(query);
+		}
 
-		return List;
+		return count;
 	}
 }