diff --git a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/base/service/IActivityService.java b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/base/service/IActivityService.java index d40d489c..fc0bbc0c 100644 --- a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/base/service/IActivityService.java +++ b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/base/service/IActivityService.java @@ -109,7 +109,7 @@ public interface IActivityService { * @param recommendParam * @return */ - Boolean onLinePetition(AcRecommendParam recommendParam); + String onLinePetition(AcRecommendParam recommendParam); /** * 活动签呈审核通过 diff --git a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/base/service/impl/ActivityServiceImpl.java b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/base/service/impl/ActivityServiceImpl.java index 56746b95..ec0d661f 100644 --- a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/base/service/impl/ActivityServiceImpl.java +++ b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/base/service/impl/ActivityServiceImpl.java @@ -631,7 +631,8 @@ public class ActivityServiceImpl implements IActivityService { * @return */ @Override - public Boolean onLinePetition(AcRecommendParam recommendParam) { + public String onLinePetition(AcRecommendParam recommendParam) { + log.info("旅游活动新增参数{}",JSONUtil.toJsonStr(recommendParam)); //业务单号 String code = CommonUtil.createSerialNumber(EOrderPrefix.ACTIVITY_CODE.getValue()); EApprovalBusiness approvalBusiness = null; @@ -643,7 +644,40 @@ public class ActivityServiceImpl implements IActivityService { approvalBusiness = EApprovalBusiness.TOURISM_DELETE; } recommendParam.getActivityParam().setBusinessCode(code); - Boolean b = submitApproval(recommendParam, approvalBusiness); + Integer controlType = recommendParam.getControlType(); + if (controlType.equals(EControlType.SAVE.getValue())) { + ActivityParam activityParam = recommendParam.getActivityParam(); + activityParam.setPkCountry(recommendParam.getPkCountry()); + activityParam.setPkCreator(recommendParam.getPkMember()); + activityParam.setActType(EActType.TOURISM.getValue()); + + // 增加基础配置 + AcBaseConfig baseConfig = saveBaseConfig(activityParam); + // 目标群体配置 + saveGoalMemberConfig(activityParam, baseConfig); + } else if (controlType.equals(EControlType.MODIFY.getValue())) { + ActivityParam activityParam = recommendParam.getActivityParam(); + activityParam.setActType(EActType.TOURISM.getValue()); + activityParam.setPkCountry(recommendParam.getPkCountry()); + activityParam.setPkCreator(recommendParam.getPkMember()); + //目标用户群删除 + LambdaQueryWrapper qe = new LambdaQueryWrapper<>(); + qe.eq(AcGoalMemberConfig::getPkBaseId, activityParam.getPkId()); + goalMemberConfigService.remove(qe); + // 增加基础配置 + AcBaseConfig baseConfig = BeanUtil.copyProperties(activityParam, AcBaseConfig.class); + baseConfigService.updateById(baseConfig); + // 目标群体配置 + saveGoalMemberConfig(activityParam, baseConfig); + } else if (controlType.equals(EControlType.DELETE.getValue())) { + ActivityParam activityParam = recommendParam.getActivityParam(); + //目标用户群删除 + LambdaQueryWrapper qe = new LambdaQueryWrapper<>(); + qe.eq(AcGoalMemberConfig::getPkBaseId, activityParam.getPkId()); + goalMemberConfigService.remove(qe); + baseConfigService.removeById(activityParam.getPkId()); + drawGiftConfigService.removeDrawGiftConfig(activityParam.getPkId().intValue()); + } //日志 ActivityParam activityParam = recommendParam.getActivityParam(); activityParam.setPkCountry(SecurityUtils.getPkCountry()); @@ -651,7 +685,7 @@ public class ActivityServiceImpl implements IActivityService { activityParam.setActType(EActType.TOURISM.getValue()); activityParam.setBusinessCode(recommendParam.getActivityParam().getBusinessCode()); this.createBaseConfigLog(activityParam, new StringBuffer(), null, approvalBusiness.getValue(), false); - return b; + return null; } /** diff --git a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/consume/controller/manage/AcConsumeRuleConfigController.java b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/consume/controller/manage/AcConsumeRuleConfigController.java index 389f40d1..4552ac5b 100644 --- a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/consume/controller/manage/AcConsumeRuleConfigController.java +++ b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/consume/controller/manage/AcConsumeRuleConfigController.java @@ -172,13 +172,16 @@ public class AcConsumeRuleConfigController extends BaseController { * @param recommendParam 消费赠送参数 * @return AjaxResult */ - @Log(module = EOperationModule.CONSUME_GIVE, business = EOperationBusiness.CONSUME_GIVE, method = EOperationMethod.INSERT, remark = "在线签呈") - @PostMapping("/online-petition") + @Log(module = EOperationModule.CONSUME_GIVE, business = EOperationBusiness.CONSUME_GIVE, method = EOperationMethod.INSERT, remark = "消费赠送") + @PostMapping("/submit") public AjaxResult onLinePetition(@RequestBody AcRecommendParam recommendParam) { recommendParam.setPkCountry(SecurityUtils.getPkCountry()); recommendParam.setPkMember(SecurityUtils.getUserId()); recommendParam.setLoginUser(userTokenService.getLoginUser()); - consumeRuleConfigService.onLinePetition(recommendParam); + String str = consumeRuleConfigService.onLinePetition(recommendParam); + if (str != null) { + return AjaxResult.error(str); + } return AjaxResult.success(); } diff --git a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/consume/controller/manage/AcMemberConsumeRuleController.java b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/consume/controller/manage/AcMemberConsumeRuleController.java index d5a1638d..3a36d6f9 100644 --- a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/consume/controller/manage/AcMemberConsumeRuleController.java +++ b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/consume/controller/manage/AcMemberConsumeRuleController.java @@ -111,11 +111,14 @@ public class AcMemberConsumeRuleController extends BaseController { * @param memberConsumeRuleVo 会员消费赠送参数 * @return AjaxResult */ - @Log(module = EOperationModule.CONSUME_GIVE, business = EOperationBusiness.CONSUME_GIVE, method = EOperationMethod.INSERT, remark = "在线签呈") - @PostMapping("/online-petition") + @Log(module = EOperationModule.CONSUME_GIVE, business = EOperationBusiness.CONSUME_GIVE, method = EOperationMethod.INSERT, remark = "会员消费赠送") + @PostMapping("/submit") public AjaxResult onLinePetition(@RequestBody AcMemberConsumeRuleVo memberConsumeRuleVo) { memberConsumeRuleVo.setLoginUser(userTokenService.getLoginUser()); - iAcMemberConsumeRuleService.onLinePetition(memberConsumeRuleVo); + String str = iAcMemberConsumeRuleService.onLinePetition(memberConsumeRuleVo); + if (str != null) { + return AjaxResult.error(str); + } return AjaxResult.success(); } diff --git a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/consume/service/IAcConsumeRuleConfigService.java b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/consume/service/IAcConsumeRuleConfigService.java index 707de3bd..28cf19c9 100644 --- a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/consume/service/IAcConsumeRuleConfigService.java +++ b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/consume/service/IAcConsumeRuleConfigService.java @@ -38,7 +38,7 @@ public interface IAcConsumeRuleConfigService extends IService implements IAcConsumeRuleConfigService { @Autowired @@ -106,7 +108,9 @@ public class AcConsumeRuleConfigServiceImpl extends ServiceImpl implements IAcMemberConsumeRuleService { @Autowired @@ -80,7 +82,9 @@ public class AcMemberConsumeRuleServiceImpl extends ServiceImpl implements IAcDrawGiftRuleConfigService { @Autowired @@ -181,7 +184,9 @@ public class AcDrawGiftRuleConfigServiceImpl extends ServiceImpl implements IAcDrawRewardNumService { @Autowired @@ -239,10 +241,32 @@ public class AcDrawRewardNumServiceImpl extends ServiceImpl memberDto = memberServiceApi.getMember(memberCode); + Long pkMember = memberDto.getData().getPkId(); + + LambdaQueryWrapper 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 memberDto = memberServiceApi.getMember(memberCode); + Long pkMember = memberDto.getData().getPkId(); + + LambdaQueryWrapper 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); + } } /** diff --git a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/recommend/controller/AcRecommendConfigController.java b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/recommend/controller/AcRecommendConfigController.java index 10e92824..311ff9b9 100644 --- a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/recommend/controller/AcRecommendConfigController.java +++ b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/recommend/controller/AcRecommendConfigController.java @@ -44,12 +44,16 @@ public class AcRecommendConfigController extends BaseController { * @return AjaxResult */ @Log(module = EOperationModule.AC_RECOMMEEND_CONFIG, business = EOperationBusiness.AC_RECOMMEEND_CONFIG, method = EOperationMethod.INSERT, remark = "在线签呈") - @PostMapping("/online-petition") + @PostMapping("/submit") public AjaxResult onLinePetition(@RequestBody AcRecommendParam recommendParam) { recommendParam.setPkCountry(SecurityUtils.getPkCountry()); recommendParam.setPkMember(SecurityUtils.getUserId()); recommendParam.setLoginUser(userTokenService.getLoginUser()); - return toAjax(acRepurCouponsRuleConfigService.onLinePetition(recommendParam)); + String str = acRepurCouponsRuleConfigService.onLinePetition(recommendParam); + if (str != null) { + return AjaxResult.error(str); + } + return AjaxResult.success(); } diff --git a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/recommend/service/IAcRepurCouponsRuleConfigService.java b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/recommend/service/IAcRepurCouponsRuleConfigService.java index ef6629c6..3d9822d2 100644 --- a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/recommend/service/IAcRepurCouponsRuleConfigService.java +++ b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/recommend/service/IAcRepurCouponsRuleConfigService.java @@ -21,7 +21,7 @@ public interface IAcRepurCouponsRuleConfigService extends IService recommendUpgradeList = recommendParam.getRecommendUpgradeList(); @@ -113,12 +114,20 @@ public class AcRepurCouponsRuleConfigServiceImpl extends ServiceImpl { * * @param recommendParam */ - Boolean onLinePetition(AcRecommendParam recommendParam); + String onLinePetition(AcRecommendParam recommendParam); /** * 商品赠送 审核规则 diff --git a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/wares/service/impl/AcWaresRuleConfigServiceImpl.java b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/wares/service/impl/AcWaresRuleConfigServiceImpl.java index f7d1e9b1..0f75c255 100644 --- a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/wares/service/impl/AcWaresRuleConfigServiceImpl.java +++ b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/wares/service/impl/AcWaresRuleConfigServiceImpl.java @@ -30,9 +30,11 @@ import com.hzs.system.sys.IApprovalServiceApi; import com.hzs.system.sys.dto.ApprovalBusinessResultDTO; import com.hzs.system.sys.dto.ApprovalSubmitDTO; import com.hzs.system.sys.dto.LoginUser; +import lombok.extern.slf4j.Slf4j; import org.apache.dubbo.config.annotation.DubboReference; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import java.util.List; @@ -43,6 +45,7 @@ import java.util.List; * @since 2023-04-20 */ @Service +@Slf4j public class AcWaresRuleConfigServiceImpl extends ServiceImpl implements IAcWaresRuleConfigService { @Autowired @@ -108,7 +111,9 @@ public class AcWaresRuleConfigServiceImpl extends ServiceImpl