feat:关键字拉取

local.env

@@ -0,0 +1,4 @@
+MYSQL_HOST=123.157.250.162
+MYSQL_PORT=2881
+MYSQL_USER=root@sys
+MYSQL_PWD=bsd.1799

pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/controller/spu/HardSpuController.java

@@ -97,8 +97,8 @@ public class HardSpuController {
 
     @Operation(summary = "拉取旷世商品", description = "拉取旷世商品")
     @GetMapping("/async-all")
-    public R asyncAll() {
-        hardSpuService.asyncAll();
+    public R asyncAll(@ParameterObject HardSpuDto dto) {
+        hardSpuService.asyncAll(dto);
         return R.ok();
     }
 

pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/HardSpuService.java

@@ -76,7 +76,7 @@ public interface HardSpuService extends IService<HardSpuEntity> {
     /**
      * 拉取旷世商品
      */
-    void asyncAll();
+    void asyncAll(HardSpuDto dto);
 
     /**
      * 检验商品

pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/impl/spu/HardSpuServiceImpl.java

@@ -297,9 +297,12 @@ public class HardSpuServiceImpl extends ServiceImpl<HardSpuMapper, HardSpuEntity
      * 拉取旷世商品
      */
     @Override
-    public void asyncAll() {
+    public void asyncAll(HardSpuDto dto) {
         int pageNum = 1;
         KsBarcodeLikeDto likeDto = new KsBarcodeLikeDto();
+        if (ObjectUtil.isNotEmpty(dto.getName())) {
+            likeDto.setSearch(dto.getName());
+        }
         likeDto.setPage_num(pageNum);
         while (true) {
             boolean hasnext = asyncAllGroup(likeDto);

pjcloud-hardware/pjcloud-hardware-biz/src/main/resources/mapper/spu/HardSpuMapper.xml

@@ -71,7 +71,7 @@
         <if test="dto.name != null ">
             and a.name like concat('%', #{dto.name}, '%')
         </if>
-        <if test="dto.skuType != null ">
+        <if test="dto.skuType != null and dto.skuType != '' ">
             and a.sku_type = #{dto.skuType}
         </if>
         <if test="dto.spuCategoryId != null ">