上传商品sku

ch-core/src/main/java/com/wwdz/ch/core/consts/DistributionEnum.java

@@ -59,6 +59,7 @@ public class DistributionEnum {
         GROUP_PURCHASE(6, "团购"),
         EXCHANGE(7, "交换"),
         BLACK(8, "盲盒"),
+        BLACK_COLLECTION(10, "盲袋集合，一个商品对应有多个sku"),
         ;
 
         private int code;

ch-dao/src/main/java/com/wwdz/ch/db/dao/distribution/ItemSkuDao.java

 package com.wwdz.ch.db.dao.distribution;
 
 import com.wwdz.ch.db.domain.distribution.ItemSku;
+import com.wwdz.ch.db.dto.request.distribution.ItemSkuRequestDto;
 
 import java.util.List;
 
@@ -10,5 +11,9 @@ public interface ItemSkuDao {
 
     List<ItemSku> findByItemId(long itemId);
 
+    ItemSku findBySkuCode(String code);
+
+    List<ItemSku> findByPage(ItemSkuRequestDto dto);
+
     boolean update(ItemSku itemSku);
 }

ch-dao/src/main/java/com/wwdz/ch/db/impl/distribution/ItemSkuDaoImpl.java

 package com.wwdz.ch.db.impl.distribution;
 
+import com.github.pagehelper.PageHelper;
 import com.wwdz.ch.db.dao.distribution.ItemSkuDao;
 import com.wwdz.ch.db.domain.distribution.ItemSku;
 import com.wwdz.ch.db.domain.distribution.ItemSkuExample;
+import com.wwdz.ch.db.dto.request.distribution.ItemSkuRequestDto;
 import com.wwdz.ch.db.mapper.distribution.ItemSkuMapper;
 import com.xxdxxs.db.component.JdbcHelper;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -26,7 +28,25 @@ public class ItemSkuDaoImpl implements ItemSkuDao {
         ItemSkuExample.Criteria criteria = example.createCriteria();
         criteria.andItemIdEqualTo(itemId);
         example.setOrderByClause("create_time desc");
-        return itemSkuMapper.selectByExample(example);
+        return itemSkuMapper.selectByExampleWithBLOBs(example);
+    }
+
+    @Override
+    public ItemSku findBySkuCode(String code) {
+        ItemSkuExample example = new ItemSkuExample();
+        ItemSkuExample.Criteria criteria = example.createCriteria();
+        criteria.andSkuCodeEqualTo(code);
+        return itemSkuMapper.selectOneByExampleWithBLOBs(example);
+    }
+
+    @Override
+    public List<ItemSku> findByPage(ItemSkuRequestDto dto) {
+        ItemSkuExample example = new ItemSkuExample();
+        ItemSkuExample.Criteria criteria = example.createCriteria();
+        JdbcHelper.ifPresent(dto.getItemId(), criteria::andItemIdEqualTo);
+        example.setOrderByClause("create_time desc");
+        PageHelper.startPage(dto.getPage(), dto.getLimit());
+        return itemSkuMapper.selectByExampleWithBLOBs(example);
     }
 
     @Override

ch-dao/src/main/resources/generatorConfig_new.xml

@@ -63,16 +63,16 @@
 
 
         <!--生成Model类存放位置-->
-        <javaModelGenerator targetPackage="com.wwdz.ch.db.domain" targetProject="ch-dao/src/main/java">
+        <javaModelGenerator targetPackage="com.wwdz.ch.db.domain.distribution" targetProject="ch-dao/src/main/java">
             <property name="enableSubPackages" value="true"/>
             <property name="trimStrings" value="true"/>
         </javaModelGenerator>
 
-        <sqlMapGenerator targetPackage="com.wwdz.ch.db.mapper" targetProject="ch-dao/src/main/resources"/>
-        <javaClientGenerator type="XMLMAPPER" targetPackage="com.wwdz.ch.db.mapper"
+        <sqlMapGenerator targetPackage="com.wwdz.ch.db.mapper.distribution" targetProject="ch-dao/src/main/resources"/>
+        <javaClientGenerator type="XMLMAPPER" targetPackage="com.wwdz.ch.db.mapper.distribution"
                              targetProject="ch-dao/src/main/java"/>
 
-        <table tableName="user_signin" enableCountByExample="true" enableUpdateByExample="true" enableDeleteByExample="true" enableSelectByExample="true" selectByExampleQueryId="true">
+        <table tableName="item_sku" enableCountByExample="true" enableUpdateByExample="true" enableDeleteByExample="true" enableSelectByExample="true" selectByExampleQueryId="true">
             <generatedKey column="id" sqlStatement="Mysql" identity="true" />
         </table>
 

ch-wx-api/src/main/java/com/wwdz/ch/wx/entity/vo/distribution/BlindBoxVo.java

+package com.wwdz.ch.wx.entity.vo.distribution;
+
+import com.xxdxxs.entity.Entity;
+import lombok.Data;
+import java.util.List;
+
+@Data
+public class BlindBoxVo implements Entity {
+
+    /**
+     * 优惠活动
+     */
+    private String sellActivity;
+
+    /**
+     * 盲袋商品列表
+     */
+    private List<List<String>> itemList;
+}

ch-wx-api/src/main/java/com/wwdz/ch/wx/impl/distribution/BlindBoxServiceImpl.java

+package com.wwdz.ch.wx.impl.distribution;
+
+import com.wwdz.ch.core.consts.DistributionEnum;
+import com.wwdz.ch.core.type.Result;
+import com.wwdz.ch.db.dao.distribution.ItemSkuDao;
+import com.wwdz.ch.db.dao.distribution.SupplierItemDao;
+import com.wwdz.ch.db.domain.distribution.ItemSku;
+import com.wwdz.ch.db.domain.distribution.SupplierItem;
+import com.wwdz.ch.db.dto.request.distribution.ItemSkuRequestDto;
+import com.wwdz.ch.db.dto.request.distribution.SupplierItemRequestDto;
+import com.wwdz.ch.wx.entity.vo.distribution.BlindBoxVo;
+import com.wwdz.ch.wx.service.distribution.BlindBoxService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Service
+public class BlindBoxServiceImpl implements BlindBoxService {
+
+    private static final Logger logger = LoggerFactory.getLogger(BlindBoxServiceImpl.class);
+
+    @Autowired
+    SupplierItemDao supplierItemDao;
+
+    @Autowired
+    ItemSkuDao itemSkuDao;
+
+    @Override
+    public Result findForHomePage(SupplierItemRequestDto dto) {
+        try {
+            List<List<String>> itemList = new ArrayList<>();
+            dto.setType(DistributionEnum.DistributionTypeEnum.BLACK_COLLECTION.getCode());
+            dto.setStock(0);
+            dto.setIsDeleted(false);
+            dto.setLimit(3);
+            List<SupplierItem> supplierItemList = supplierItemDao.findList(dto);
+            for (SupplierItem supplierItem : supplierItemList) {
+                long itemId = supplierItem.getId();
+                ItemSkuRequestDto itemSkuRequestDto = new ItemSkuRequestDto();
+                itemSkuRequestDto.setItemId(itemId);
+                itemSkuRequestDto.setLimit(3);
+                List<ItemSku> itemSkuList = itemSkuDao.findByPage(itemSkuRequestDto);
+                List<String> imageList = new ArrayList<>();
+                for (ItemSku itemSku : itemSkuList) {
+                    imageList.add(itemSku.getDefaultImage());
+                }
+                itemList.add(imageList);
+            }
+            BlindBoxVo blindBoxVo = new BlindBoxVo();
+            blindBoxVo.setSellActivity("全场限时立减五元");
+            blindBoxVo.setItemList(itemList);
+            return Result.success(blindBoxVo);
+        } catch (Exception e) {
+            logger.error("查询首页福袋 error : {}", e);
+        }
+        return Result.failed();
+    }
+
+
+    @Override
+    public Result findList(SupplierItemRequestDto dto) {
+        try {
+
+        } catch (Exception e) {
+            logger.error("查询盲袋商品列表 error : {}", e);
+        }
+        return Result.failed();
+    }
+
+    @Override
+    public Result findDetail(SupplierItemRequestDto dto) {
+        try {
+            List<List<String>> itemList = new ArrayList<>();
+            dto.setType(DistributionEnum.DistributionTypeEnum.BLACK_COLLECTION.getCode());
+            dto.setStock(0);
+            dto.setIsDeleted(false);
+            dto.setLimit(3);
+            List<SupplierItem> supplierItemList = supplierItemDao.findList(dto);
+            for (SupplierItem supplierItem : supplierItemList) {
+                long itemId = supplierItem.getId();
+                ItemSkuRequestDto itemSkuRequestDto = new ItemSkuRequestDto();
+                itemSkuRequestDto.setItemId(itemId);
+                itemSkuRequestDto.setLimit(3);
+                List<ItemSku> itemSkuList = itemSkuDao.findByPage(itemSkuRequestDto);
+                List<String> imageList = new ArrayList<>();
+                for (ItemSku itemSku : itemSkuList) {
+                    imageList.add(itemSku.getDefaultImage());
+                }
+                itemList.add(imageList);
+            }
+            BlindBoxVo blindBoxVo = new BlindBoxVo();
+            blindBoxVo.setSellActivity("全场限时立减五元");
+            blindBoxVo.setItemList(itemList);
+            return Result.success(blindBoxVo);
+        } catch (Exception e) {
+            logger.error("查询盲袋商品列表 error : {}", e);
+        }
+        return Result.failed();
+    }
+}

ch-wx-api/src/main/java/com/wwdz/ch/wx/service/distribution/BlindBoxService.java

+package com.wwdz.ch.wx.service.distribution;
+
+import com.wwdz.ch.core.type.Result;
+import com.wwdz.ch.db.dto.request.distribution.SupplierItemRequestDto;
+
+/**
+ * 盲袋
+ */
+public interface BlindBoxService {
+
+    /**
+     * 查询首页福袋
+     * @param dto
+     * @return
+     */
+    Result findForHomePage(SupplierItemRequestDto dto);
+
+
+    /**
+     * 查询盲袋商品列表
+     * @param dto
+     * @return
+     */
+    Result findList(SupplierItemRequestDto dto);
+
+
+    /**
+     * 查询盲袋商品详情
+     * @param dto
+     * @return
+     */
+    Result findDetail(SupplierItemRequestDto dto);
+
+}