香港商品来源

README.md

@@ -18,7 +18,7 @@
 2,批量查询日统计
 ~~~~
 
-###**v2.0.1** 
+###**v2.0.0** 
 ~~~~
 1.h5获取店鋪列表根据分類Id    /api/getShopByCategory
     添加参数deptId  不传默认澳门  
@@ -29,4 +29,27 @@
 5页面统计 /api/point
     添加参数 deptId
 
+~~~~
+
+###**v2.0.1** 
+~~~~
+
+1.新增接口
+     添加热点时商品来源下拉框   GET  无参   /back/product/productSourceHK 
+     
+     h5获取商品详情_hk   GET 其他参数与澳门一致，新增参数  productSourceId         /api/hk/getProductInfo  
+     h5加入购物车_hk      GET 其他参数与澳门一致，新增参数  productSourceId        /api/hk/inCat
+     h5获取购物商品数量_hk  GET 其他参数与澳门一致，新增参数  productSourceId       /api/hk/getCatNum
+     
+2.添加参数 
+    保存热点    /service/scene/edit/tag/save
+    hotDataList 中添加参数 productSourceId  商品来源Id
+3.hot.json文件内容新增
+    productSource obj
+        id              商品来源Id
+        cdfName         来源名称
+        cdfMchId        店铺Id
+        cdfHost         来源域名
+        mchType         0，远程来源，1本地来源
+详见文档http://120.25.146.52:3090/project/81/interface/api/9452
 ~~~~

src/main/java/com/cdf/controller/api/CdfHkProductApiController.java

@@ -0,0 +1,74 @@
+package com.cdf.controller.api;
+
+import com.alibaba.fastjson.JSONObject;
+import com.cdf.common.ResultCode;
+import com.cdf.common.ResultData;
+import com.cdf.entity.ProductSource;
+import com.cdf.exception.BusinessException;
+import com.cdf.httpClient.client.CdfClient;
+import com.cdf.httpClient.client.CdfHKClient;
+import com.cdf.httpClient.request.CdfInCatRequest;
+import com.cdf.httpClient.response.cdf.CdfProductVo;
+import com.cdf.service.IProductSourceService;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+
+@RestController
+@RequestMapping("/api")
+public class CdfHkProductApiController {
+
+    @Resource
+    private CdfHKClient cdfHKClient;
+    @Autowired
+    private IProductSourceService productSourceService;
+
+    @GetMapping("/getCatNum")
+    public ResultData getCatNum(@RequestParam(required = false) String AccessToken,
+                                @RequestParam(required = false,defaultValue = "1")Integer productSourceId){
+        ProductSource productSource = productSourceService.getById(productSourceId);
+        if(productSource == null|| productSource.getMchType() == 1){
+            throw new BusinessException(ResultCode.PARAM_MISS);
+        }
+        JSONObject catNum = cdfHKClient.getCatNum(productSource.getCdfHost(),productSource.getCdfMchId(),AccessToken);
+        return  ResultData.ok(catNum);
+    }
+
+    @GetMapping("/inCat")
+    public ResultData inCat(@RequestParam(required = false) String AccessToken,
+                            @RequestParam(required = false) String skuId,
+                            @RequestParam(required = false) Integer num,
+                            @RequestParam(required = false,defaultValue = "1")Integer productSourceId){
+        ProductSource productSource = productSourceService.getById(productSourceId);
+        if(productSource == null|| productSource.getMchType() == 1){
+            throw new BusinessException(ResultCode.PARAM_MISS);
+        }
+        JSONObject jsonObject = cdfHKClient.inCat(productSource.getCdfHost(),productSource.getCdfMchId(),AccessToken, new CdfInCatRequest(skuId, num));
+        if(jsonObject.get("success")!=null && !jsonObject.getBoolean("success")){
+            return ResultData.error(jsonObject.getString("msg"));
+        }
+        if(jsonObject.get("status")!=null ){
+            return ResultData.error(401,jsonObject.getString("msg"));
+        }
+        return ResultData.ok(jsonObject);
+    }
+
+    @GetMapping("/getProductInfo")
+    public ResultData getProductInfo(@RequestParam(required = false) String productId,
+                                     @RequestParam(required = false,defaultValue = "1")Integer productSourceId){
+        if(StringUtils.isBlank(productId)){
+            return ResultData.ok();
+        }
+        ProductSource productSource = productSourceService.getById(productSourceId);
+        if(productSource == null || productSource.getMchType() == 1){
+            throw new BusinessException(ResultCode.PARAM_MISS);
+        }
+        CdfProductVo productById = cdfHKClient.getProductById(productSource.getCdfHost(),productSource.getCdfMchId(),productId);
+        return ResultData.ok(productById);
+    }
+}

src/main/java/com/cdf/controller/api/CdfProductApiController.java

@@ -1,48 +1,48 @@
-package com.cdf.controller.api;
-
-import com.alibaba.fastjson.JSONObject;
-import com.cdf.common.ResultData;
-import com.cdf.httpClient.client.CdfClient;
-import com.cdf.httpClient.request.CdfInCatRequest;
-import com.cdf.httpClient.response.cdf.CdfProductVo;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.web.bind.annotation.*;
-
-import javax.annotation.Resource;
-
-@RestController
-@RequestMapping("/api")
-public class CdfProductApiController {
-
-    @Resource
-    private CdfClient cdfClient;
-
-    @GetMapping("/getCatNum")
-    public ResultData getCatNum(@RequestParam(required = false) String AccessToken){
-        JSONObject catNum = cdfClient.getCatNum(AccessToken);
-        return  ResultData.ok(catNum);
-    }
-
-    @GetMapping("/inCat")
-    public ResultData inCat(@RequestParam(required = false) String AccessToken,
-                            @RequestParam(required = false) String skuId,
-                            @RequestParam(required = false) Integer num){
-        JSONObject jsonObject = cdfClient.inCat(AccessToken, new CdfInCatRequest(skuId, num));
-        if(jsonObject.get("success")!=null && !jsonObject.getBoolean("success")){
-            return ResultData.error(jsonObject.getString("msg"));
-        }
-        if(jsonObject.get("status")!=null ){
-            return ResultData.error(401,jsonObject.getString("msg"));
-        }
-        return ResultData.ok(jsonObject);
-    }
-
-    @GetMapping("/getProductInfo")
-    public ResultData getProductInfo(@RequestParam(required = false) String productId){
-        if(StringUtils.isBlank(productId)){
-            return ResultData.ok();
-        }
-        CdfProductVo productById = cdfClient.getProductById(productId);
-        return ResultData.ok(productById);
-    }
-}
+//package com.cdf.controller.api;
+//
+//import com.alibaba.fastjson.JSONObject;
+//import com.cdf.common.ResultData;
+//import com.cdf.httpClient.client.CdfClient;
+//import com.cdf.httpClient.request.CdfInCatRequest;
+//import com.cdf.httpClient.response.cdf.CdfProductVo;
+//import org.apache.commons.lang3.StringUtils;
+//import org.springframework.web.bind.annotation.*;
+//
+//import javax.annotation.Resource;
+//
+//@RestController
+//@RequestMapping("/api")
+//public class CdfProductApiController {
+//
+//    @Resource
+//    private CdfClient cdfClient;
+//
+//    @GetMapping("/getCatNum")
+//    public ResultData getCatNum(@RequestParam(required = false) String AccessToken){
+//        JSONObject catNum = cdfClient.getCatNum(AccessToken);
+//        return  ResultData.ok(catNum);
+//    }
+//
+//    @GetMapping("/inCat")
+//    public ResultData inCat(@RequestParam(required = false) String AccessToken,
+//                            @RequestParam(required = false) String skuId,
+//                            @RequestParam(required = false) Integer num){
+//        JSONObject jsonObject = cdfClient.inCat(AccessToken, new CdfInCatRequest(skuId, num));
+//        if(jsonObject.get("success")!=null && !jsonObject.getBoolean("success")){
+//            return ResultData.error(jsonObject.getString("msg"));
+//        }
+//        if(jsonObject.get("status")!=null ){
+//            return ResultData.error(401,jsonObject.getString("msg"));
+//        }
+//        return ResultData.ok(jsonObject);
+//    }
+//
+//    @GetMapping("/getProductInfo")
+//    public ResultData getProductInfo(@RequestParam(required = false) String productId){
+//        if(StringUtils.isBlank(productId)){
+//            return ResultData.ok();
+//        }
+//        CdfProductVo productById = cdfClient.getProductById(productId);
+//        return ResultData.ok(productById);
+//    }
+//}

src/main/java/com/cdf/controller/back/CdfProductController.java

@@ -8,9 +8,7 @@ import com.cdf.exception.BusinessException;
 import com.cdf.httpClient.client.CdfClient;
 import com.cdf.httpClient.response.cdf.*;
 import org.apache.commons.lang3.StringUtils;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 import java.util.ArrayList;
@@ -24,7 +22,7 @@ public class CdfProductController {
     @Resource
     private CdfClient cdfClient;
 
-    @RequestMapping("/list")
+    @PostMapping("/list")
     public ResultData getProductList(@RequestBody CdfProductListRequest param){
         if(StringUtils.isNotBlank(param.getKeyword()) && param.getKeyword().contains(",")){
             if(param.getPageNum() >1){

src/main/java/com/cdf/controller/back/HkProductController.java

@@ -3,14 +3,15 @@ package com.cdf.controller.back;
 import com.alibaba.fastjson.JSONArray;
 import com.cdf.common.PageInfo;
 import com.cdf.common.ResultData;
+import com.cdf.entity.ProductSource;
 import com.cdf.exception.BusinessException;
 import com.cdf.httpClient.client.CdfClient;
 import com.cdf.httpClient.response.cdf.*;
 import com.cdf.service.IProductHkService;
+import com.cdf.service.IProductSourceService;
 import org.apache.commons.lang3.StringUtils;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 import java.util.ArrayList;
@@ -21,10 +22,13 @@ import java.util.List;
 @RequestMapping("/back/product")
 public class HkProductController {
 
-    @Resource
+    @Autowired
     IProductHkService productHkService;
+    @Autowired
+    IProductSourceService productSourceService;
 
-    @RequestMapping("/HKList")
+
+    @PostMapping("/HKList")
     public ResultData getProductList(@RequestBody CdfProductListRequest param){
         if(StringUtils.isNotBlank(param.getKeyword()) && param.getKeyword().contains(",")){
             List<String> strings = Arrays.asList(param.getKeyword().split(","));
@@ -32,4 +36,10 @@ public class HkProductController {
         }
         return ResultData.ok(productHkService.pageList(param));
     }
+
+    @GetMapping("/productSourceHK")
+    public ResultData productSourceHK(){
+        List<ProductSource> list = productSourceService.getProductHk("HK");
+        return ResultData.ok(list);
+    }
 }

src/main/java/com/cdf/controller/back/TestController.java

@@ -11,6 +11,7 @@ import com.cdf.common.ResultData;
 import com.cdf.entity.ProductHk;
 import com.cdf.entity.Shop;
 import com.cdf.httpClient.client.CdfClient;
+import com.cdf.httpClient.client.CdfHKClient;
 import com.cdf.httpClient.client.FdkkClient;
 import com.cdf.httpClient.request.FdkkAllSceneRequest;
 import com.cdf.httpClient.response.FdkkResponse;
@@ -46,6 +47,8 @@ public class TestController {
     IShopService shopService;
     @Resource
     CdfClient cdfClient;
+    @Resource
+    CdfHKClient cdfHKClient;
     @Autowired
     private ScheduleTask scheduleTask;
     @Resource
@@ -59,7 +62,7 @@ public class TestController {
 
     @RequestMapping("/test/getProductById")
     public ResultData getProductById(@RequestParam(required = false) String productId){
-        return ResultData.ok(cdfClient.getProductById(productId));
+        return ResultData.ok(cdfHKClient.getProductById("https://hk.cdfmembers.com","604163145",productId));
     }
 
     @RequestMapping("/test/getProductList")

src/main/java/com/cdf/entity/HotRelation.java

@@ -40,6 +40,9 @@ public class HotRelation implements Serializable {
     @TableField("content")
     private String content;
 
+    @TableField("product_source_id")
+    private Integer productSourceId;
+
     @TableField("tb_status")
     @TableLogic
     private Boolean tbStatus;

src/main/java/com/cdf/entity/ProductSource.java

@@ -0,0 +1,75 @@
+package com.cdf.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author 
+ * @since 2023-01-31
+ */
+@Getter
+@Setter
+@TableName("t_product_source")
+public class ProductSource implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * cdf店铺表
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 店铺名称
+     */
+    @TableField("cdf_name")
+    private String cdfName;
+
+    /**
+     * cdf店铺Id
+     */
+    @TableField("cdf_mch_id")
+    private String cdfMchId;
+
+    /**
+     * cdf店铺访问域名
+     */
+    @TableField("cdf_host")
+    private String cdfHost;
+
+    /**
+     * 0远程店铺，1本地店铺
+     */
+    @TableField("mch_type")
+    private Integer mchType;
+
+    /**
+     * 所在地区
+     */
+    @TableField("region")
+    private String region;
+
+    @TableField("tb_status")
+    @TableLogic
+    private Integer tbStatus;
+
+    @TableField("create_time")
+    private LocalDateTime createTime;
+
+    @TableField("update_time")
+    private LocalDateTime updateTime;
+
+
+}

src/main/java/com/cdf/generate/AutoGenerate.java

@@ -20,7 +20,7 @@ public class AutoGenerate {
         String path =System.getProperty("user.dir") ;
 
         generate(path,"", getTables(new String[]{
-                "t_total_data_hk"
+                "t_product_source"
         }));
 
 //        generate(path,"goods", getTables(new String[]{
@@ -48,8 +48,8 @@ public class AutoGenerate {
 
 
     public static void  generate(String path,String moduleName,  List<String> tables){
-        FastAutoGenerator.create("jdbc:mysql://127.0.0.1:3306/cdf_gm",
-                "root","123456")
+        FastAutoGenerator.create("jdbc:mysql://18.156.200.112:3306/cdf_gm_test",
+                "root","4Dage@zhongmian#@168")
                 .globalConfig(builder -> {
                     builder.author("")               //作者
                             .outputDir(path+"\\src\\main\\java")    //输出路径(写到java目录)

src/main/java/com/cdf/httpClient/client/CdfHKClient.java

@@ -0,0 +1,81 @@
+package com.cdf.httpClient.client;
+
+import com.alibaba.fastjson.JSONObject;
+import com.cdf.httpClient.request.CdfChannelclick;
+import com.cdf.httpClient.request.CdfInCatRequest;
+import com.cdf.httpClient.response.cdf.*;
+import com.dtflys.forest.annotation.Get;
+import com.dtflys.forest.annotation.JSONBody;
+import com.dtflys.forest.annotation.Post;
+import com.dtflys.forest.annotation.Var;
+
+public interface CdfHKClient {
+
+    /**
+     * 获取商品详情
+     * @Var("host")String host,@Var("mchId") String mchId,
+     */
+    @Get(url = "{host}/api/prod/sqdetail?productId=${productId}",
+        headers = {
+                "app-key: h5sqBuyer_{mchId}",
+                "app-version: 6.6.88",
+                "ymt-pars: appid=71&mchId={mchId}&language=zh_CN&format=json"
+        })
+    CdfProductVo getProductById(@Var("host")String host,@Var("mchId") String mchId,@Var("productId") String productId);
+    /**
+     * 根据关键字搜索商品列表
+     */
+    @Post(url = "{host}/api/nodesearch/sqsearch",
+        headers = {
+                "app-key: h5sqBuyer_{mchId}",
+                "app-version: 6.6.88",
+                "ymt-pars: appid=71&mchId={mchId}&language=zh_CN&format=json"
+
+        })
+    CdfProductListResponse getProductList(@Var("host")String host,@Var("mchId") String mchId,@JSONBody CdfProductListRequest param);
+    /**
+     * 批量查询商品详情
+     */
+    @Post(url = "{host}/api/prod/getsqproductcardlistbyids",
+        headers = {
+                "app-key: h5sqBuyer_{mchId}",
+                "app-version: 6.6.88",
+                "ymt-pars: appid=71&mchId={mchId}&language=zh_CN&format=json"
+
+        })
+    CdfProductListByIdsVo getProductListByIds(@Var("host")String host,@Var("mchId") String mchId,@JSONBody CdfProductListByIdsRequest param);
+    /**
+     * 查询购物车数量
+     */
+    @Get(url = "{host}/api/trading/sqscartprodnum",
+        headers = {
+                "app-key: h5sqBuyer_{mchId}",
+                "app-version: 6.6.88",
+                "ymt-pars: appid=71&accesstoken={accessToken}&mchId={mchId}&language=zh_CN&format=json",
+        })
+    JSONObject getCatNum(@Var("host")String host,@Var("mchId") String mchId,@Var("accessToken") String accessToken);
+    /**
+     * 加入购物车
+     */
+    @Post(url = "{host}/api/trading/sqscartprod",
+        headers = {
+                "app-key: h5sqBuyer_{mchId}",
+                "app-version: 6.6.88",
+                "ymt-pars: appid=71&accesstoken={accessToken}&mchId={mchId}&language=zh_CN&format=json",
+        })
+    JSONObject inCat(@Var("host")String host,@Var("mchId") String mchId,@Var("accessToken") String accessToken, @JSONBody CdfInCatRequest request);
+    /**
+     * 上报商品来源
+     * 1，用戶点击进入商品详情时
+     * 2，用戶点击加入购物车时
+     * 3，用戶点击加入收藏时
+     */
+    @Post(url = "{host}/api/prodextra/channelclick",
+        headers = {
+                "app-key: h5sqBuyer_{mchId}",
+                "app-version: 6.6.88",
+                "cookieid: {cookieId}",
+                "ymt-pars: appid=71&accesstoken={accessToken}&userid={userId}&mchId={mchId}&language=zh_CN&format=json",
+        })
+    JSONObject channelclick(@Var("host")String host,@Var("mchId") String mchId,@Var("cookieId") String cookieId, @Var("accessToken") String accessToken, @Var("userId")String userId, @JSONBody CdfChannelclick request);
+}

src/main/java/com/cdf/httpClient/request/FdkkHotData.java

@@ -1,5 +1,6 @@
 package com.cdf.httpClient.request;
 
+import com.cdf.entity.ProductSource;
 import lombok.Data;
 
 import java.util.List;
@@ -12,4 +13,6 @@ public class FdkkHotData {
     private Integer hotType;
     private List<String> relationIds;
     private String hotContent;
+
+    private Integer productSourceId;
 }

src/main/java/com/cdf/mapper/IProductSourceMapper.java

@@ -0,0 +1,18 @@
+package com.cdf.mapper;
+
+import com.cdf.entity.ProductSource;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author 
+ * @since 2023-01-31
+ */
+@Mapper
+public interface IProductSourceMapper extends BaseMapper<ProductSource> {
+
+}

src/main/java/com/cdf/service/IProductSourceService.java

@@ -0,0 +1,19 @@
+package com.cdf.service;
+
+import com.cdf.entity.ProductSource;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+import java.util.List;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author 
+ * @since 2023-01-31
+ */
+public interface IProductSourceService extends IService<ProductSource> {
+
+    List<ProductSource> getProductHk(String type);
+}

src/main/java/com/cdf/service/impl/FdkkSceneEditService.java

@@ -8,6 +8,7 @@ import com.cdf.common.ResultCode;
 import com.cdf.entity.HotRelation;
 import com.cdf.entity.NumRegion;
 import com.cdf.entity.ProductHk;
+import com.cdf.entity.ProductSource;
 import com.cdf.exception.BusinessException;
 import com.cdf.httpClient.client.CdfClient;
 import com.cdf.httpClient.client.FdkkClient;
@@ -20,6 +21,7 @@ import com.cdf.httpClient.response.cdf.*;
 import com.cdf.service.IFdkkUserService;
 import com.cdf.service.IHotRelationService;
 import com.cdf.service.IProductHkService;
+import com.cdf.service.IProductSourceService;
 import com.cdf.util.*;
 import com.google.zxing.client.j2se.MatrixToImageWriter;
 import com.google.zxing.common.BitMatrix;
@@ -37,6 +39,7 @@ import javax.servlet.http.HttpServletResponse;
 import java.io.File;
 import java.io.IOException;
 import java.util.*;
+import java.util.stream.Collectors;
 
 @Service
 @Slf4j
@@ -69,6 +72,8 @@ public class FdkkSceneEditService {
     IProductHkService productHkService;
     @Autowired
     IFdkkUserService fdkkUserService;
+    @Autowired
+    IProductSourceService productSourceService;
 
 
     public JSONObject getAuth(String num, String token) {
@@ -269,6 +274,7 @@ public class FdkkSceneEditService {
 
         List<String> sidsList = new ArrayList<>();
         HashMap<String,HotRelation> hotRelationMap = new HashMap<>();
+        HashMap<Integer,ProductSource> productSourceMap = new HashMap<>();
         for (Object obj : tags) {
             JSONObject tag = (JSONObject) obj;
             String sid = tag.getString("sid");
@@ -278,6 +284,12 @@ public class FdkkSceneEditService {
         for (HotRelation hotRelation : hotRelations) {
             hotRelationMap.put(hotRelation.getHotId(),hotRelation);
         }
+        Set<Integer> productIds = hotRelations.stream().map(HotRelation::getProductSourceId).collect(Collectors.toSet());
+        List<ProductSource> productSources = productSourceService.listByIds(productIds);
+        for (ProductSource productSource : productSources) {
+            productSourceMap.put(productSource.getId(),productSource);
+        }
+
         for (Object obj : tags) {
             JSONObject tag = (JSONObject) obj;
             String sid = tag.getString("sid");
@@ -302,6 +314,9 @@ public class FdkkSceneEditService {
             if(jsonArray == null || jsonArray.size() <=0){
                 continue;
             }
+            if(hotRelation.getProductSourceId() != null){
+                tag.put("productSource",productSourceMap.get(hotRelation.getProductSourceId()));
+            }
             resultMap.put(sid,jsonArray);
             requestArray.addAll(jsonArray);
         }

src/main/java/com/cdf/service/impl/ProductSourceServiceImpl.java

@@ -0,0 +1,29 @@
+package com.cdf.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.cdf.entity.ProductSource;
+import com.cdf.mapper.IProductSourceMapper;
+import com.cdf.service.IProductSourceService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author 
+ * @since 2023-01-31
+ */
+@Service
+public class ProductSourceServiceImpl extends ServiceImpl<IProductSourceMapper, ProductSource> implements IProductSourceService {
+
+    @Override
+    public List<ProductSource> getProductHk(String type) {
+        LambdaQueryWrapper<ProductSource> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(ProductSource::getRegion,"HK");
+        return this.list(wrapper);
+    }
+}

src/main/resources/mapper/ProductSourceMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.cdf.mapper.IProductSourceMapper">
+
+</mapper>