货权转移记录新增导出

转移数量变动日志 新增    (总计 , 备注模糊查询 )
货权转移管理列表新增删除
货权转移编辑弹窗,客户不清空,备注清空

src/main/java/com/th/demo/controller/maint/CargoController.java

@@ -66,7 +66,7 @@ public class CargoController {
 
     @RequestMapping(value = "/queryRecord.do")
     public String queryRecord(int page, int rows,String uperCustomer, String Customer,
-            String RecordDateBegin,String RecordDateEnd,String subStr,String changeFrom,
+            String RecordDateBegin,String RecordDateEnd,String subStr,String changeFrom,String remark,
                               HttpServletRequest request) {
 
         try {
@@ -81,7 +81,7 @@ public class CargoController {
 
             String userId = (String) request.getAttribute("userId");
             String belongId = (String) request.getAttribute("belongId");
-            result = cargoService.queryRecord(page,rows,uperCustomer,Customer,fromDate2,toDate2,subStr,changeFrom,userId,belongId);
+            result = cargoService.queryRecord(page,rows,uperCustomer,Customer,fromDate2,toDate2,subStr,changeFrom,userId,belongId,remark);
         } catch (Exception ex) {
             ex.printStackTrace();
             result = JSONTools.toString(ResponseCodeMsg.CODE_EX, ex.getMessage());

src/main/java/com/th/demo/controller/ware/ChangeRecordController.java

@@ -5,14 +5,20 @@ import com.th.demo.model.system.Type;
 import com.th.demo.service.ware.ChangeRecordService;
 import com.th.demo.service.ware.ChangeService;
 import com.th.demo.tools.DateTools;
+import com.th.demo.tools.ExportExcelTools;
 import com.th.demo.tools.JSONTools;
+import com.th.demo.tools.Tools;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.OutputStream;
+import java.text.SimpleDateFormat;
 import java.util.Date;
+import java.util.List;
 
 @RestController
 @RequestMapping(value = "/WareChangeRecord")
@@ -76,4 +82,99 @@ public class ChangeRecordController {
         }
     }
 
+    /**
+     * 导出转移记录Excel - 分批查询流式导出
+     */
+    @RequestMapping(value = "/exportExcel.do")
+    public void exportExcel(
+            String wareName,
+            String stackName,
+            String model,
+            String materialName,
+            String standard,
+            String customerName,
+            String plateNo,
+            String pFromDate,
+            String pToDate,
+            String userId,
+            String belongId,
+            HttpServletRequest request,
+            HttpServletResponse response) {
+        try {
+            // 设置超时时间，单位毫秒（10分钟）
+            response.setHeader("timeout", "600000");
+
+            Date fromDate = DateTools.StrToDate(pFromDate, "yyyy-MM-dd HH:mm:ss");
+            Date toDate = DateTools.StrToDate(pToDate, "yyyy-MM-dd HH:mm:ss");
+
+            // 设置表头
+            String[] headers = {"仓库名称", "垛位", "层号", "品名", "规格型号", "钢种", "数量", "重量",
+                    "钢板号", "类型", "客户名称(旧)", "收货地址(旧)", "客户名称(新)", "收货地址(新)",
+                    "计量方式", "切边类型", "产地", "备注", "操作人", "操作时间"};
+
+            // 设置字段名
+            String[] columns = {"wareName", "stackName", "layer", "materialName", "model", "standard",
+                    "count", "weight", "plateNo", "recordType", "customerNameOld", "receiveAddressOld",
+                    "customerNameNew", "receiveAddressNew", "wgtDcnMtcCd", "edgeTy", "productionPlace",
+                    "remark", "addUserUserDesc", "addTime"};
+
+            // 设置列宽
+            int[] arrWidth = {80, 50, 50, 50, 80, 50, 50, 50, 100, 60,
+                    100, 150, 100, 150, 60, 60, 100, 80, 60, 120};
+
+            // 生成文件名
+            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+            String filename = "转移记录_" + sdf.format(new Date()) + ".xlsx";
+
+            // 分批查询，每批5000条
+            final int batchSize = 5000;
+            int offset = 0;
+
+            // 使用try-with-resources自动关闭流
+            try (OutputStream out = Tools.getExportOutStream(filename, response)) {
+                // 创建流式工作簿
+                ExportExcelTools<List<java.util.Map<String, Object>>> exportExcel = new ExportExcelTools<>();
+
+                // 写入表头
+                exportExcel.writeHeaders("转移记录", headers, columns, arrWidth, out, "yyyy/MM/dd HH:mm:ss");
+
+                // 分批查询并写入
+                while (true) {
+                    List<java.util.Map<String, Object>> batchData = changeRecordService.exportForExcelBatch(
+                            wareName, stackName, model, materialName, standard, customerName,
+                            plateNo, fromDate, toDate, userId, belongId, offset, batchSize);
+
+                    if (batchData == null || batchData.isEmpty()) {
+                        break;
+                    }
+
+                    // 写入数据
+                    exportExcel.appendData(columns, batchData, "yyyy/MM/dd HH:mm:ss");
+
+                    // 如果数据少于批次大小，说明是最后一批
+                    if (batchData.size() < batchSize) {
+                        break;
+                    }
+
+                    offset += batchSize;
+
+                    // 手动触发GC回收内存
+                    System.gc();
+                }
+
+                // 完成写入
+                exportExcel.finishWrite(out);
+                out.flush();
+            } catch (Exception e) {
+                e.printStackTrace();
+                response.reset();
+                response.setContentType("text/html;charset=utf-8");
+                response.getWriter().write("导出失败：" + e.getMessage());
+            }
+
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
 }

src/main/java/com/th/demo/mapping/ware/CargoChangeRecordMapper.java

@@ -16,7 +16,7 @@ public interface CargoChangeRecordMapper {
     CargoChangeRecord selectByCustomer(String uperCustomer, String Customer);
 
     List<CargoChangeRecord> selectRecord(String uperCustomer, String Customer,
-                                         Date RecordDateBegin,Date RecordDateEnd,String subStr,String changeFrom);
+                                         Date RecordDateBegin,Date RecordDateEnd,String subStr,String changeFrom,String remark);
 
 
 

src/main/java/com/th/demo/mapping/ware/ChangeRecordMapper.java

@@ -5,6 +5,7 @@ import com.th.demo.model.ware.MoveRecord;
 
 import java.util.Date;
 import java.util.List;
+import java.util.Map;
 
 public interface ChangeRecordMapper {
     int deleteByPrimaryKey(String id);
@@ -24,4 +25,11 @@ public interface ChangeRecordMapper {
     List<ChangeRecord> select(String wareName, String stackName, String model, String materialName, String standard, String customerName, String plateNo, Date fromDate, Date toDate, String userId, String belongId);
 
     List<ChangeRecord> selectTotal(String wareName, String stackName, String model, String materialName, String standard, String customerName, String plateNo, Date date, Date fromDate, String userId, String belongId);
+
+    List<Map<String, Object>> selectForExport(String wareName, String stackName, String model, String materialName, String standard, String customerName, String plateNo, Date fromDate, Date toDate, String userId, String belongId);
+
+    /**
+     * 分批查询导出数据
+     */
+    List<Map<String, Object>> selectForExportBatch(String wareName, String stackName, String model, String materialName, String standard, String customerName, String plateNo, Date fromDate, Date toDate, String userId, String belongId, int offset, int limit);
 }

src/main/java/com/th/demo/service/impl/maint/CargoServiceImpl.java

@@ -126,9 +126,9 @@ public class CargoServiceImpl implements CargoService {
     @Override
     public String queryRecord(int page, int rows, String uperCustomer, String Customer ,
                               Date RecordDateBegin,Date RecordDateEnd,String subStr,String changeFrom,
-                              String userId, String belongId) {
+                              String userId, String belongId,String remark) {
         PageHelper.startPage(page, rows);
-        List<CargoChangeRecord> list   = cargoChangeRecordMapper.selectRecord(uperCustomer, Customer,RecordDateBegin,RecordDateEnd,subStr,changeFrom);
+        List<CargoChangeRecord> list   = cargoChangeRecordMapper.selectRecord(uperCustomer, Customer,RecordDateBegin,RecordDateEnd,subStr,changeFrom,remark);
         PageInfo<CargoChangeRecord> pageInfo = new PageInfo<>(list);
         result = JSONTools.toStringyyyyMMddHHmmss(pageInfo);
         return result;

src/main/java/com/th/demo/service/impl/ware/ChangeRecordServiceImpl.java

@@ -12,6 +12,7 @@ import org.springframework.stereotype.Service;
 
 import java.util.Date;
 import java.util.List;
+import java.util.Map;
 
 @Service("ChangeRecordService")
 public class ChangeRecordServiceImpl implements ChangeRecordService {
@@ -39,4 +40,31 @@ public class ChangeRecordServiceImpl implements ChangeRecordService {
         result = JSONTools.toStringyyyyMMddHHmmss(list);
         return result;
     }
+
+    @Override
+    public List<Map<String, Object>> exportForExcel(String wareName, String stackName, String model, String materialName, String standard, String customerName, String plateNo, Date fromDate, Date toDate, String userId, String belongId) {
+        // 调用 Mapper 获取数据，返回已转换为 Map 的列表
+        return changeRecordMapper.selectForExport(wareName, stackName, model, materialName, standard, customerName, plateNo, fromDate, toDate, userId, belongId);
+    }
+
+    /**
+     * 分批导出转移记录Excel（解决大数据量内存溢出问题）
+     */
+    @Override
+    public List<Map<String, Object>> exportForExcelBatch(String wareName, String stackName, String model, String materialName, String standard, String customerName, String plateNo, Date fromDate, Date toDate, String userId, String belongId, int offset, int limit) {
+        // ========== 入参空值处理 ==========
+        wareName = wareName == null ? "" : wareName;
+        stackName = stackName == null ? "" : stackName;
+        model = model == null ? "" : model;
+        materialName = materialName == null ? "" : materialName;
+        standard = standard == null ? "" : standard;
+        customerName = customerName == null ? "" : customerName;
+        plateNo = plateNo == null ? "" : plateNo;
+        userId = userId == null ? "" : userId;
+        belongId = belongId == null ? "" : belongId;
+
+        // 调用分批查询 Mapper
+        return changeRecordMapper.selectForExportBatch(wareName, stackName, model, materialName, standard,
+                customerName, plateNo, fromDate, toDate, userId, belongId, offset, limit);
+    }
 }

src/main/java/com/th/demo/service/maint/CargoService.java

@@ -10,5 +10,5 @@ public interface CargoService {
 
     String queryRecord(int page, int rows, String uperCustomer, String Customer ,
                        Date RecordDateBegin,Date RecordDateEnd,String subStr,String changeFrom,
-                       String userId, String belongId);
+                       String userId, String belongId,String remark);
 }

src/main/java/com/th/demo/service/ware/ChangeRecordService.java

@@ -1,9 +1,18 @@
 package com.th.demo.service.ware;
 
 import java.util.Date;
+import java.util.List;
+import java.util.Map;
 
 public interface ChangeRecordService {
     String query(int page, int rows, String wareName, String stackName, String model, String materialName, String standard, String customerName, String plateNo, Date fromDate, Date toDate, String userId, String belongId);
 
     String queryTotal(int page, int rows, String wareName, String stackName, String model, String materialName, String standard, String customerName, String plateNo, Date fromDate, Date toDate, String userId, String belongId);
+
+    List<Map<String, Object>> exportForExcel(String wareName, String stackName, String model, String materialName, String standard, String customerName, String plateNo, Date fromDate, Date toDate, String userId, String belongId);
+
+    /**
+     * 分批导出转移记录Excel（解决大数据量内存溢出问题）
+     */
+    List<Map<String, Object>> exportForExcelBatch(String wareName, String stackName, String model, String materialName, String standard, String customerName, String plateNo, Date fromDate, Date toDate, String userId, String belongId, int offset, int limit);
 }

src/main/resource/mapper/ware/CargoChangeRecordMapper.xml

@@ -68,6 +68,9 @@
     <if test="param6 != null and param6 != ''" >
       and change_from like concat('%',#{param6,jdbcType=VARCHAR},'%')
     </if>
+      <if test="param7 != null and param7 != ''" >
+          and remark like concat('%',#{param7,jdbcType=VARCHAR},'%')
+      </if>
     order by modify_time desc
   </select>
 

src/main/resource/mapper/ware/ChangeRecordMapper.xml

@@ -424,5 +424,139 @@
     order by t.add_time desc
   </select>
 
+  <!-- 导出转移记录查询，返回Map列表 -->
+  <select id="selectForExport" resultType="java.util.Map">
+    select
+      t.ware_name as wareName,
+      t.stack_name as stackName,
+      t.layer as layer,
+      t.material_name as materialName,
+      t.model as model,
+      t.standard as standard,
+      t.count as count,
+      t.weight as weight,
+      t.plate_no as plateNo,
+      (case t.record_type when '0' then '入库取消' when '1' then '入库' else t.record_type end) as recordType,
+      t.customer_name_old as customerNameOld,
+      t.receive_address_old as receiveAddressOld,
+      t.customer_name_new as customerNameNew,
+      t.receive_address_new as receiveAddressNew,
+      t.wgt_dcn_mtc_cd as wgtDcnMtcCd,
+      t.edge_ty as edgeTy,
+      t.production_place as productionPlace,
+      t.remark as remark,
+      u.user_desc as addUserUserDesc,
+      t.add_time as addTime
+    from t_ware_change_record t
+    left join sys_user u on t.add_id = u.id
+    where 1=1
+    <if test="param1 != null and param1 != ''">
+      and t.ware_name like concat('%', #{param1,jdbcType=VARCHAR}, '%')
+    </if>
+    <if test="param2 != null and param2 != ''">
+      and t.stack_name like concat('%', #{param2,jdbcType=VARCHAR}, '%')
+    </if>
+    <if test="param3 != null and param3 != ''">
+      and t.model like concat('%', #{param3,jdbcType=VARCHAR}, '%')
+    </if>
+    <if test="param4 != null and param4 != ''">
+      and t.material_name like concat('%', #{param4,jdbcType=VARCHAR}, '%')
+    </if>
+    <if test="param5 != null and param5 != ''">
+      and t.standard like concat('%', #{param5,jdbcType=VARCHAR}, '%')
+    </if>
+    <if test="param6 != null and param6 != ''">
+      and (t.customer_name_old like concat('%', #{param6,jdbcType=VARCHAR}, '%')
+           or t.customer_name_new like concat('%', #{param6,jdbcType=VARCHAR}, '%'))
+    </if>
+    <if test="param7 != null and param7 != ''">
+      and t.plate_no like concat('%', #{param7,jdbcType=VARCHAR}, '%')
+    </if>
+    <if test="param8 != null">
+      and t.add_time &gt;= #{param8,jdbcType=TIMESTAMP}
+    </if>
+    <if test="param9 != null">
+      and t.add_time &lt;= #{param9,jdbcType=TIMESTAMP}
+    </if>
+    <if test="param10 != null and param10 != ''">
+      and t.ware_name in (
+        select b.name from t_maint_userware a, t_maint_ware b
+        where a.ware_id = b.id and a.user_id = #{param10,jdbcType=VARCHAR}
+      )
+    </if>
+    <if test="param11 != null and param11 != ''">
+      and t.belong_id = #{param11,jdbcType=VARCHAR}
+    </if>
+    and t.cancel_flag = '0'
+    order by t.add_time desc
+  </select>
+
+  <!-- 分批导出转移记录查询，支持分页 -->
+  <select id="selectForExportBatch" resultType="java.util.Map">
+    select
+      t.ware_name as wareName,
+      t.stack_name as stackName,
+      t.layer as layer,
+      t.material_name as materialName,
+      t.model as model,
+      t.standard as standard,
+      t.count as count,
+      t.weight as weight,
+      t.plate_no as plateNo,
+      (case t.record_type when '0' then '入库取消' when '1' then '入库' else t.record_type end) as recordType,
+      t.customer_name_old as customerNameOld,
+      t.receive_address_old as receiveAddressOld,
+      t.customer_name_new as customerNameNew,
+      t.receive_address_new as receiveAddressNew,
+      t.wgt_dcn_mtc_cd as wgtDcnMtcCd,
+      t.edge_ty as edgeTy,
+      t.production_place as productionPlace,
+      t.remark as remark,
+      u.user_desc as addUserUserDesc,
+      t.add_time as addTime
+    from t_ware_change_record t
+    left join sys_user u on t.add_id = u.id
+    where 1=1
+    <if test="param1 != null and param1 != ''">
+      and t.ware_name like concat('%', #{param1,jdbcType=VARCHAR}, '%')
+    </if>
+    <if test="param2 != null and param2 != ''">
+      and t.stack_name like concat('%', #{param2,jdbcType=VARCHAR}, '%')
+    </if>
+    <if test="param3 != null and param3 != ''">
+      and t.model like concat('%', #{param3,jdbcType=INTEGER}, '%')
+    </if>
+    <if test="param4 != null and param4 != ''">
+      and t.material_name like concat('%', #{param4,jdbcType=VARCHAR}, '%')
+    </if>
+    <if test="param5 != null and param5 != ''">
+      and t.standard like concat('%', #{param5,jdbcType=VARCHAR}, '%')
+    </if>
+    <if test="param6 != null and param6 != ''">
+      and (t.customer_name_old like concat('%', #{param6,jdbcType=VARCHAR}, '%')
+           or t.customer_name_new like concat('%', #{param6,jdbcType=VARCHAR}, '%'))
+    </if>
+    <if test="param7 != null and param7 != ''">
+      and t.plate_no like concat('%', #{param7,jdbcType=VARCHAR}, '%')
+    </if>
+    <if test="param8 != null and param9 != null">
+      and t.add_time between #{param8,jdbcType=TIMESTAMP} and #{param9,jdbcType=TIMESTAMP}
+    </if>
+    <if test="param10 != null and param10 != ''">
+      and t.ware_name in (
+        select b.name from t_maint_userware a, t_maint_ware b
+        where a.ware_id = b.id and a.user_id = #{param10,jdbcType=VARCHAR}
+      )
+    </if>
+    <if test="param11 != null and param11 != ''">
+      and t.belong_id = #{param11,jdbcType=VARCHAR}
+    </if>
+    and t.cancel_flag = '0'
+    order by t.add_time desc
+    <if test="param12 != null and param12 >= 0">
+      LIMIT #{param13,jdbcType=INTEGER} OFFSET #{param12,jdbcType=INTEGER}
+    </if>
+  </select>
+
 
 </mapper>