批量审核

foodnexus-module-mall/foodnexus-module-product/src/main/java/cn/iocoder/foodnexus/module/product/controller/admin/spu/ProductSpuController.java

@@ -82,8 +82,8 @@ public class ProductSpuController {
     @PutMapping("/pass-all")
     @Operation(summary = "审核通过所有产品")
     @PreAuthorize("@ss.hasPermission('product:spu:update')")
-    public CommonResult<Boolean> passAll() {
-        productSpuService.passAll();
+    public CommonResult<Boolean> passAll(@RequestBody ProductSpuUpdateStatusBatchReqVO updateReqVO) {
+        productSpuService.passAll(updateReqVO);
         return success(Boolean.TRUE);
     }
 

foodnexus-module-mall/foodnexus-module-product/src/main/java/cn/iocoder/foodnexus/module/product/controller/admin/spu/vo/ProductSpuUpdateStatusBatchReqVO.java

+package cn.iocoder.foodnexus.module.product.controller.admin.spu.vo;
+
+import cn.iocoder.foodnexus.framework.common.validation.InEnum;
+import cn.iocoder.foodnexus.module.product.enums.spu.ProductSpuStatusEnum;
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+
+import java.util.List;
+
+@Schema(description = "管理后台 - 商品 SPU Status 更新 Request VO")
+@Data
+public class ProductSpuUpdateStatusBatchReqVO {
+
+    @Schema(description = "商品id集合（不传默认所有数据）", requiredMode = Schema.RequiredMode.REQUIRED, example = "1")
+    private List<Long> ids;
+
+    @Schema(description = "商品状态", requiredMode = Schema.RequiredMode.REQUIRED, example = "1")
+    @NotNull(message = "商品状态不能为空")
+    @InEnum(ProductSpuStatusEnum.class)
+    private Integer status;
+
+}

foodnexus-module-mall/foodnexus-module-product/src/main/java/cn/iocoder/foodnexus/module/product/service/spu/ProductSpuService.java

@@ -6,6 +6,7 @@ import cn.iocoder.foodnexus.framework.common.util.collection.CollectionUtils;
 import cn.iocoder.foodnexus.module.customerpermission.core.annotation.CustomerVisible;
 import cn.iocoder.foodnexus.module.product.controller.admin.spu.vo.ProductSpuPageReqVO;
 import cn.iocoder.foodnexus.module.product.controller.admin.spu.vo.ProductSpuSaveReqVO;
+import cn.iocoder.foodnexus.module.product.controller.admin.spu.vo.ProductSpuUpdateStatusBatchReqVO;
 import cn.iocoder.foodnexus.module.product.controller.admin.spu.vo.ProductSpuUpdateStatusReqVO;
 import cn.iocoder.foodnexus.module.product.controller.app.spu.vo.AppProductSpuPageReqVO;
 import cn.iocoder.foodnexus.module.product.controller.app.spu.vo.AppProductSpuStatusRespVO;
@@ -155,7 +156,7 @@ public interface ProductSpuService {
 
     void audit(AuditCommonReqVO auditReqVO);
 
-    void passAll();
+    void passAll(ProductSpuUpdateStatusBatchReqVO updateReqVO);
 
     default Map<Long, ProductSpuDO> getProductVOMap(Set<Long> longs) {
         return this.getSpuMap(longs);

foodnexus-module-mall/foodnexus-module-product/src/main/java/cn/iocoder/foodnexus/module/product/service/spu/ProductSpuServiceImpl.java

@@ -13,6 +13,7 @@ import cn.iocoder.foodnexus.module.erp.api.enums.ErpAuditStatus;
 import cn.iocoder.foodnexus.module.product.controller.admin.category.vo.ProductCategoryListReqVO;
 import cn.iocoder.foodnexus.module.product.controller.admin.spu.vo.ProductSpuPageReqVO;
 import cn.iocoder.foodnexus.module.product.controller.admin.spu.vo.ProductSpuSaveReqVO;
+import cn.iocoder.foodnexus.module.product.controller.admin.spu.vo.ProductSpuUpdateStatusBatchReqVO;
 import cn.iocoder.foodnexus.module.product.controller.admin.spu.vo.ProductSpuUpdateStatusReqVO;
 import cn.iocoder.foodnexus.module.product.controller.app.spu.vo.AppProductSpuPageReqVO;
 import cn.iocoder.foodnexus.module.product.controller.app.spu.vo.AppProductSpuStatusRespVO;
@@ -145,14 +146,15 @@ public class ProductSpuServiceImpl implements ProductSpuService {
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void passAll() {
+    public void passAll(ProductSpuUpdateStatusBatchReqVO updateReqVO) {
         List<ProductSpuDO> productSpuDOS = productSpuMapper.selectList(Wrappers.<ProductSpuDO>lambdaQuery()
+                .in(CommonUtil.isNotEmpty(updateReqVO.getIds()), ProductSpuDO::getId, updateReqVO.getIds())
                 .eq(ProductSpuDO::getAuditStatus, ErpAuditStatus.PROCESS.getStatus()));
 
         if (CommonUtil.isNotEmpty(productSpuDOS)) {
             AuditCommonReqVO auditCommonReqVO = new AuditCommonReqVO();
-            auditCommonReqVO.setAuditReason("批量审核通过");
-            auditCommonReqVO.setAuditStatus(ErpAuditStatus.APPROVE.getStatus().toString());
+            auditCommonReqVO.setAuditReason("批量审核");
+            auditCommonReqVO.setAuditStatus(updateReqVO.getStatus().toString());
             for (ProductSpuDO item : productSpuDOS) {
                 auditCommonReqVO.setId(item.getId());
                 this.audit(auditCommonReqVO);