fetch: add assemble receipt export api eairps#245

Author: Jzow

core/api/src/main/java/com/wansenai/api/warehouse/AssembleController.java

@@ -19,14 +19,8 @@
 import com.wansenai.utils.response.Response;
 import com.wansenai.vo.warehouse.AssembleReceiptDetailVO;
 import com.wansenai.vo.warehouse.AssembleReceiptVO;
-import org.springframework.web.bind.annotation.RestController;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.PutMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.PostMapping;
+import jakarta.servlet.http.HttpServletResponse;
+import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
 
@@ -64,4 +58,9 @@ public Response<String> deleteAssembleReceiptByIds(@RequestParam("ids") List<Lon
     public Response<String> updateAssembleReceiptStatusByIds(@RequestParam("ids") List<Long> ids, @RequestParam("status") Integer status) {
         return assembleService.updateAssembleReceiptStatus(ids, status);
     }
+
+    @GetMapping("export")
+    public void exportAssembleReceipt(@ModelAttribute QueryAssembleReceiptDTO queryAssembleReceiptDTO, HttpServletResponse response) throws Exception {
+        assembleService.exportAssembleReceipt(queryAssembleReceiptDTO, response);
+    }
 }

core/domain/src/main/java/com/wansenai/vo/warehouse/AssembleReceiptVO.java

@@ -15,6 +15,7 @@
 import com.fasterxml.jackson.annotation.JsonFormat;
 import com.fasterxml.jackson.databind.annotation.JsonSerialize;
 import com.wansenai.bo.BigDecimalSerializerBO;
+import com.wansenai.utils.excel.ExcelExport;
 import lombok.Builder;
 import lombok.Data;
 
@@ -28,19 +29,26 @@ public class AssembleReceiptVO {
     @JsonFormat(shape = JsonFormat.Shape.STRING)
     private Long id;
 
+    @ExcelExport(value = "单据编号")
     private String receiptNumber;
 
+    @ExcelExport(value = "商品信息")
     private String productInfo;
 
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    @ExcelExport(value = "单据日期")
     private LocalDateTime receiptDate;
 
-    private String operator;
-
+    @ExcelExport(value = "商品数量")
     private Integer productNumber;
 
     @JsonSerialize(using = BigDecimalSerializerBO.class)
+    @ExcelExport(value = "金额合计")
     private BigDecimal totalAmount;
 
+    @ExcelExport(value = "操作员")
+    private String operator;
+
+    @ExcelExport(value = "状态", kv = "0-未审核;1-已审核")
     private Integer status;
 }

core/service/src/main/java/com/wansenai/service/warehouse/AssembleReceiptService.java

@@ -20,6 +20,7 @@
 import com.wansenai.utils.response.Response;
 import com.wansenai.vo.warehouse.AssembleReceiptDetailVO;
 import com.wansenai.vo.warehouse.AssembleReceiptVO;
+import jakarta.servlet.http.HttpServletResponse;
 
 import java.util.List;
 
@@ -34,4 +35,6 @@ public interface AssembleReceiptService extends IService<WarehouseReceiptMain> {
     Response<String> deleteBatchAssembleReceipt(List<Long> ids);
 
     Response<String> updateAssembleReceiptStatus(List<Long> ids, Integer status);
+
+    void exportAssembleReceipt(QueryAssembleReceiptDTO queryAssembleReceiptDTO, HttpServletResponse response) throws Exception;
 }

core/service/src/main/java/com/wansenai/service/warehouse/impl/AssembleReceiptServiceImpl.java

@@ -37,9 +37,11 @@
 import com.wansenai.utils.constants.CommonConstants;
 import com.wansenai.utils.enums.AssembleReceiptCodeEnum;
 import com.wansenai.utils.enums.BaseCodeEnum;
+import com.wansenai.utils.excel.ExcelUtils;
 import com.wansenai.utils.response.Response;
 import com.wansenai.vo.warehouse.AssembleReceiptDetailVO;
 import com.wansenai.vo.warehouse.AssembleReceiptVO;
+import jakarta.servlet.http.HttpServletResponse;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StringUtils;
@@ -178,7 +180,46 @@ public Response<Page<AssembleReceiptVO>> getAssembleReceiptPageList(QueryAssembl
         return Response.responseData(result);
     }
 
-    @Override
+    private List<AssembleReceiptVO> getAssembleReceiptList(QueryAssembleReceiptDTO queryAssembleReceiptDTO) {
+        var wrapperMainMapper = lambdaQuery()
+                .eq(queryAssembleReceiptDTO.getOperatorId() != null, WarehouseReceiptMain::getCreateBy, queryAssembleReceiptDTO.getOperatorId())
+                .eq(queryAssembleReceiptDTO.getStatus() != null, WarehouseReceiptMain::getStatus, queryAssembleReceiptDTO.getStatus())
+                .eq(StringUtils.hasLength(queryAssembleReceiptDTO.getReceiptNumber()), WarehouseReceiptMain::getReceiptNumber, queryAssembleReceiptDTO.getReceiptNumber())
+                .like(StringUtils.hasLength(queryAssembleReceiptDTO.getRemark()), WarehouseReceiptMain::getRemark, queryAssembleReceiptDTO.getRemark())
+                .ge(StringUtils.hasLength(queryAssembleReceiptDTO.getStartDate()), WarehouseReceiptMain::getCreateTime, queryAssembleReceiptDTO.getStartDate())
+                .le(StringUtils.hasLength(queryAssembleReceiptDTO.getEndDate()), WarehouseReceiptMain::getCreateTime, queryAssembleReceiptDTO.getEndDate())
+                .eq(WarehouseReceiptMain::getType, "组装单")
+                .eq(WarehouseReceiptMain::getDeleteFlag, CommonConstants.NOT_DELETED)
+                .list();
+
+        var assembleReceiptVOList = new ArrayList<AssembleReceiptVO>(wrapperMainMapper.size() + 1);
+        wrapperMainMapper.forEach(item -> {
+
+            var product = productService.getById(item.getProductId());
+            var productInfo = "";
+            if(product != null) {
+                productInfo = product.getProductName() + "|" + product.getProductStandard() + "|" + product.getProductModel() + "|" + product.getProductUnit();
+            }
+
+            var operator = userService.getById(item.getCreateBy());
+            var assembleReceiptVO = AssembleReceiptVO.builder()
+                    .id(item.getId())
+                    .receiptNumber(item.getReceiptNumber())
+                    .productInfo(productInfo)
+                    .receiptDate(item.getReceiptDate())
+                    .operator(Optional.ofNullable(operator).map(SysUser::getName).orElse(""))
+                    .productNumber(item.getTotalProductNumber())
+                    .totalAmount(item.getTotalAmount())
+                    .status(item.getStatus())
+                    .build();
+
+            assembleReceiptVOList.add(assembleReceiptVO);
+        });
+        return assembleReceiptVOList;
+    }
+
+
+        @Override
     public Response<AssembleReceiptDetailVO> getAssembleReceiptDetail(Long id) {
         if (id == null) {
             return Response.responseMsg(BaseCodeEnum.PARAMETER_NULL);
@@ -428,4 +469,13 @@ public Response<String> updateAssembleReceiptStatus(List<Long> ids, Integer stat
         }
         return Response.responseMsg(AssembleReceiptCodeEnum.UPDATE_ASSEMBLE_RECEIPT_SUCCESS);
     }
+
+    @Override
+    public void exportAssembleReceipt(QueryAssembleReceiptDTO queryAssembleReceiptDTO, HttpServletResponse response) throws Exception {
+        var data = getAssembleReceiptList(queryAssembleReceiptDTO);
+        if (!data.isEmpty()) {
+            var file = ExcelUtils.exportFile(ExcelUtils.DEFAULT_FILE_PATH, "组装单", data);
+            ExcelUtils.downloadExcel(file, "组装单", response);
+        }
+    }
 }

web/src/api/warehouse/assemble.ts

@@ -14,6 +14,7 @@ enum API {
     DeleteBatch = '/warehouse/assemble/deleteByIds',
     UpdateStatus = '/warehouse/assemble/updateStatusByIds',
     GetDetail = '/warehouse/assemble/getDetailById',
+    Export = '/warehouse/assemble/export',
 }
 
 export function getAssemblePageList(params: QueryAssembleReq) {
@@ -65,4 +66,14 @@ export function getAssembleDetailById(id: number) {
             url: `${API.GetDetail}/${id}`
         },
     );
+}
+
+export function exportAssemble(params: QueryAssembleReq) {
+    return defHttp.get<BaseDataResp<Blob>>(
+        {
+            url: `${API.Export}`,
+            params,
+            responseType: "blob"
+        }
+    );
 }

web/src/views/warehouse/assemble/index.vue

@@ -52,9 +52,8 @@ import {defineComponent, ref} from "vue";
 import {BasicTable, TableAction, useTable} from "@/components/Table";
 import {useMessage} from "@/hooks/web/useMessage";
 import {columns, searchFormSchema} from "@/views//warehouse/assemble/assemble.data";
-import {exportXlsx} from "@/api/basic/common";
 import {useI18n} from "vue-i18n";
-import {getAssemblePageList, deleteBatchAssemble, updateAssembleStatus} from "@/api/warehouse/assemble";
+import {getAssemblePageList, deleteBatchAssemble, updateAssembleStatus, exportAssemble} from "@/api/warehouse/assemble";
 import AddEditAssembleModal from "@/views/warehouse/assemble/components/AddEditAssembleModal.vue"
 import ViewAssembleModal from "@/views/warehouse/assemble/components/ViewAssembleModal.vue";
 import {Tag} from "ant-design-vue";
@@ -67,7 +66,7 @@ export default defineComponent({
     const { createMessage } = useMessage();
     const addEditModalRef = ref(null);
     const [receiptViewModal, {openModal: openReceiptViewModal}] = useModal();
-    const [registerTable, { reload, getSelectRows }] = useTable({
+    const [registerTable, { reload, getSelectRows, getForm }] = useTable({
       title: '组装单列表',
       rowKey: 'id',
       api: getAssemblePageList,
@@ -170,14 +169,17 @@ export default defineComponent({
     }
 
     async function handleExport() {
-      const file = await exportXlsx("组装单列表")
-      const blob = new Blob([file]);
-      const link = document.createElement("a");
-      link.href = URL.createObjectURL(blob);
-      const timestamp = getTimestamp(new Date());
-      link.download = "组装单数据" + timestamp + ".xlsx";
-      link.target = "_blank";
-      link.click();
+      const data = getForm().getFieldsValue();
+      const file: any = await exportAssemble(data)
+      if (file.size > 0) {
+        const blob = new Blob([file]);
+        const link = document.createElement("a");
+        link.href = URL.createObjectURL(blob);
+        const timestamp = getTimestamp(new Date());
+        link.download = "组装单数据" + timestamp + ".xlsx";
+        link.target = "_blank";
+        link.click();
+      }
     }