From 76a0a2249b2b11e44b5f4434d05b3e4b3b790341 Mon Sep 17 00:00:00 2001
From: zhangheng <test@test.test>
Date: Thu, 18 Sep 2025 09:36:35 +0800
Subject: [PATCH] =?UTF-8?q?##=20=E5=85=85=E5=80=BC=E5=B7=B2=E8=B4=AD?=
 =?UTF-8?q?=E4=B9=B0=E6=AC=A1=E6=95=B0,=E5=85=85=E5=80=BC=E6=9C=AA?=
 =?UTF-8?q?=E8=B4=AD=E4=B9=B0=E6=AC=A1=E6=95=B0=E5=8F=96=E6=B6=88=E7=AD=BE?=
 =?UTF-8?q?=E5=91=88?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/AcDrawRewardNumServiceImpl.java      | 60 ++++++++++++++++---
 1 file changed, 52 insertions(+), 8 deletions(-)

diff --git a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/draw/service/impl/AcDrawRewardNumServiceImpl.java b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/draw/service/impl/AcDrawRewardNumServiceImpl.java
index dcd3acb7..1d250921 100644
--- a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/draw/service/impl/AcDrawRewardNumServiceImpl.java
+++ b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/draw/service/impl/AcDrawRewardNumServiceImpl.java
@@ -39,6 +39,7 @@ import com.hzs.member.detail.ICuMemberServiceLogServiceApi;
 import com.hzs.system.sys.IApprovalServiceApi;
 import com.hzs.system.sys.dto.ApprovalBusinessResultDTO;
 import com.hzs.system.sys.dto.ApprovalSubmitDTO;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.dubbo.config.annotation.DubboReference;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -55,6 +56,7 @@ import java.util.concurrent.TimeUnit;
  * @since 2023-04-21
  */
 @Service
+@Slf4j
 public class AcDrawRewardNumServiceImpl extends ServiceImpl<AcDrawRewardNumMapper, AcDrawRewardNum> implements IAcDrawRewardNumService {
 
     @Autowired
@@ -239,10 +241,32 @@ public class AcDrawRewardNumServiceImpl extends ServiceImpl<AcDrawRewardNumMappe
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void purchasedTimes(PurchasedTimesParam purchasedTimesParam) {
-        purchasedTimesParam.setControlType(EControlType.MODIFY.getValue());
-        //业务单号
-        EApprovalBusiness approvalBusiness = EApprovalBusiness.PUR_CHASED_TIMES;
-        submitApproval(purchasedTimesParam, approvalBusiness);
+        log.info("修改已购买次数入参{}",JSONUtil.toJsonStr(purchasedTimesParam));
+        String memberCode = purchasedTimesParam.getMemberCode();
+        Integer num = purchasedTimesParam.getNum();
+        Long pkBaseId = purchasedTimesParam.getPkBaseId();
+        R<CuMember> memberDto = memberServiceApi.getMember(memberCode);
+        Long pkMember = memberDto.getData().getPkId();
+
+        LambdaQueryWrapper<AcDrawRewardNum> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(AcDrawRewardNum::getPkBaseId, pkBaseId);
+        queryWrapper.eq(AcDrawRewardNum::getPkMember, pkMember);
+        AcDrawRewardNum drawRewardNum = this.getOne(queryWrapper);
+        if (drawRewardNum != null) {
+            baseMapper.updatePurchasedTimesByBaseId(pkMember, num, pkBaseId);
+        } else {
+            drawRewardNum = new AcDrawRewardNum();
+            drawRewardNum.setPkBaseId(pkBaseId);
+            drawRewardNum.setPkMember(pkMember);
+            drawRewardNum.setTotalUsedNum(num);
+            drawRewardNum.setAvailableNum(num);
+            drawRewardNum.setTotalNum(num);
+            drawRewardNum.setAvailableSurplusNum(num);
+            drawRewardNum.setCreationTime(DateUtils.currentDateTime());
+            drawRewardNum.setPkCreator(memberDto.getData().getPkCreator());
+            drawRewardNum.setPkCountry(memberDto.getData().getPkCountry());
+            this.save(drawRewardNum);
+        }
     }
 
     /**
@@ -364,10 +388,30 @@ public class AcDrawRewardNumServiceImpl extends ServiceImpl<AcDrawRewardNumMappe
      */
     @Override
     public void unpurchasedTimes(PurchasedTimesParam purchasedTimesParam) {
-        purchasedTimesParam.setControlType(EControlType.MODIFY.getValue());
-        //业务单号
-        EApprovalBusiness approvalBusiness = EApprovalBusiness.UN_PUR_CHASED_TIMES;
-        submitApproval(purchasedTimesParam, approvalBusiness);
+        log.info("修改未购买次数入参{}",JSONUtil.toJsonStr(purchasedTimesParam));
+        String memberCode = purchasedTimesParam.getMemberCode();
+        Integer num = purchasedTimesParam.getNum();
+        Long pkBaseId = purchasedTimesParam.getPkBaseId();
+        R<CuMember> memberDto = memberServiceApi.getMember(memberCode);
+        Long pkMember = memberDto.getData().getPkId();
+
+        LambdaQueryWrapper<AcDrawRewardNum> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(AcDrawRewardNum::getPkBaseId, pkBaseId);
+        queryWrapper.eq(AcDrawRewardNum::getPkMember, pkMember);
+        AcDrawRewardNum drawRewardNum = this.getOne(queryWrapper);
+        if (drawRewardNum != null) {
+            baseMapper.updateUnpurchasedTimesByPkbaseId(pkMember, num, pkBaseId);
+        } else {
+            drawRewardNum = new AcDrawRewardNum();
+            drawRewardNum.setPkBaseId(pkBaseId);
+            drawRewardNum.setPkMember(pkMember);
+            drawRewardNum.setTotalNum(num);
+            drawRewardNum.setTotalSurplusNum(num);
+            drawRewardNum.setCreationTime(DateUtils.currentDateTime());
+            drawRewardNum.setPkCreator(memberDto.getData().getPkCreator());
+            drawRewardNum.setPkCountry(memberDto.getData().getPkCountry());
+            this.save(drawRewardNum);
+        }
     }
 
     /**