Merge branch 'shop_opt'

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());