小店审核成功同步分销管理同平台提成比例

netflix-dao/src/main/java/com/cyksj/mapper/shop/YhShopUserPlatDistributeRateMapper.java

@@ -10,4 +10,5 @@ import com.cyksj.model.entity.YhShopUserPlatDistributeRate;
  *创建时间:2023/9/18 14:26
  */
 public interface YhShopUserPlatDistributeRateMapper extends BaseMapper<YhShopUserPlatDistributeRate> {
+	void batchInsertGoodsRate(Long userId);
 }

netflix-dao/src/main/resources/mapper/YhShopUserPlatDistributeRateMapper.xml

@@ -0,0 +1,14 @@
+<?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.cyksj.mapper.shop.YhShopUserPlatDistributeRateMapper">
+
+    <insert id="batchInsertGoodsRate">
+        insert
+        ignore into yh_shop_user_plat_distribute_rate(`user_id`,`goods_id`,`rate`,`second_rate`,`created_time`,`update_time`)
+        select user_id, goods_id, rate, second_rate, now(), now()
+        from user_distribute ud
+                 inner join user_plat_distribute_rate ur
+                            on ur.distribute_id = ud.id and ud.deleted is true and ud.user_id = #{userId}
+    </insert>
+</mapper>

netflix-service/src/main/java/com/cyksj/service/mange/goods/CmsYhShopCommonServiceImpl.java

@@ -8,6 +8,7 @@ import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.cyksj.common.exception.BusinessRuntimeException;
 import com.cyksj.mapper.GoodsDonMapper;
+import com.cyksj.mapper.manage.distribute.UserDistributeMapper;
 import com.cyksj.mapper.shop.*;
 import com.cyksj.model.entity.*;
 import com.cyksj.model.request.DistributeApplyMoneyReq;
@@ -65,6 +66,9 @@ public class CmsYhShopCommonServiceImpl implements CmsYhShopCommonService {
 
 	private final YhShopUserBusinessDefaultRateConfigMapper defaultRateConfigMapper;
 
+	private final UserDistributeMapper userDistributeMapper;
+
+	private final YhShopUserPlatDistributeRateMapper yhShopUserPlatDistributeRateMapper;
 	@Override
 	public void setGeneralGoodsRate(List<YhShopGeneralGoodsRate> rates) {
 		List<YhShopGeneralGoodsRate> saveShopGoodsRate = new ArrayList<>(rates.size());
@@ -121,6 +125,14 @@ public class CmsYhShopCommonServiceImpl implements CmsYhShopCommonService {
 			yhShop.setReason(null);
 			if (yhShop.getVerifyStatus() == YhShop.Status.verify) {
 				yhShop.setVerifyStatus(YhShop.Status.success);
+				//审核成功 同步分销管理 设置的平台提成比例
+				UserDistribute userDistribute = userDistributeMapper.selectOne(Wrappers.lambdaQuery(UserDistribute.class)
+						.eq(UserDistribute::getUserId, yhShop.getUserId())
+						.eq(UserDistribute::getDeleted, true).last("limit 1"));
+				if (userDistribute != null) {
+					yhShop.setBusinessId(userDistribute.getBusinessId());
+					yhShopUserPlatDistributeRateMapper.batchInsertGoodsRate(yhShop.getUserId());
+				}
 			}
 		}
 		yhShopApplyRecord.setVerifyTime(DateTime.now());

netflix-web/src/main/java/com/cyksj/web/controller/manage/goods/shop/YhShopGoodsController.java

@@ -20,6 +20,7 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.*;
 
+import javax.servlet.http.HttpServletRequest;
 import java.util.List;
 
 /*
@@ -41,6 +42,8 @@ public class YhShopGoodsController {
 
 	private final YhShopMapper yhShopMapper;
 
+	private final HttpServletRequest request;
+
 	/**
 	 * 新增平台
 	 */
@@ -107,7 +110,7 @@ public class YhShopGoodsController {
 	@GetMapping("/get/available/goods")
 	public Result<SearchResult<YhShopAvailableGoodsView>> getAvailableGoods(){
 		long userId = StpYhShopManageUser.getLoginIdAsLong();
-		SearchResult<YhShopAvailableGoodsView> search = beanSearcher.search(YhShopAvailableGoodsView.class, MapUtils.builder()
+		SearchResult<YhShopAvailableGoodsView> search = beanSearcher.search(YhShopAvailableGoodsView.class, MapUtils.flatBuilder(request.getParameterMap())
 				.put("condition", String.format("and (select count(*) from yh_shop_goods_sku where user_id = %s and goods_id = yr.goods_id and deleted is true) = 0", userId))
 				.build());
 		return GatewayResponse.SUCCESS.newBuilder().toResult(search);