angelo
/
java-store-retail-app
forked from angelo/java-retail-app
3
0
Fork 0
Code Pull Requests Activity

## 提货中心相关流程；

This commit is contained in:
cabbage 2025-08-05 09:23:01 +08:00
parent 884b8665c7
commit 71e42c3311
32 changed files with 515 additions and 509 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
bd-api/bd-api-sale/src/main/java/com/hzs/sale/postage/IPostageServiceApi.java
View File

@ -1,29 +0,0 @@
package com.hzs.sale.postage;
import com.hzs.common.core.domain.R;
import com.hzs.sale.postage.dto.PostageProductDTO;
import java.math.BigDecimal;
import java.util.List;
/**
* @Description: 邮费服务API
* @Author: jiang chao
* @Time: 2023/4/25 14:40
* @Classname: IPostageServiceApi
* @PackageName: com.hzs.sale.postage
*/
public interface IPostageServiceApi {
/**
* 查询邮费
*
* @param pkId 邮费模板ID
* @param productList 产品列表
* @param province 省
* @param recCity 市
* @return
*/
R<BigDecimal> queryPostage(Integer pkId, List<PostageProductDTO> productList, Integer province, Integer recCity);
}

6
bd-api/bd-api-sale/src/main/java/com/hzs/sale/postage/dto/PostageProductDTO.java
View File

@ -8,11 +8,7 @@ import lombok.NoArgsConstructor;
import java.io.Serializable; import java.io.Serializable;
/** /**
* @Description: 邮费产品DOT * 邮费产品DOT
* @Author: jiang chao
* @Time: 2023/4/25 16:05
* @Classname: PostageProductDTO
* @PackageName: com.hzs.sale.postage.dto
*/ */
@NoArgsConstructor @NoArgsConstructor
@AllArgsConstructor @AllArgsConstructor

27
bd-business/bd-business-common/src/main/java/com/hzs/common/util/TransactionUtils.java
View File

@ -1,26 +1,16 @@
package com.hzs.common.util; package com.hzs.common.util;
import com.hzs.common.core.constant.CacheConstants;
import com.hzs.common.core.enums.ELanguages;
import com.hzs.common.core.service.RedisService;
import com.hzs.common.core.utils.SpringUtils;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.InitializingBean; import org.springframework.beans.factory.InitializingBean;
import org.springframework.context.i18n.LocaleContextHolder;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
/** /**
* 国际化翻译工具 * 国际化翻译工具
*
* @author hzs
*/ */
@Component @Component
@Slf4j @Slf4j
public class TransactionUtils implements InitializingBean { public class TransactionUtils implements InitializingBean {
// private static RedisService redisService;
/** /**
* 获取国际化翻译内容 * 获取国际化翻译内容
* *
@ -29,22 +19,6 @@ public class TransactionUtils implements InitializingBean {
* @return * @return
*/ */
public static String getContent(String key, Object... args) { public static String getContent(String key, Object... args) {
// try {
// // 获取对应语言
// ELanguages language = ELanguages.getLanguagesByLocal(LocaleContextHolder.getLocale().toLanguageTag());
// if (null != language) {
// String str = redisService.getCacheMapValue(CacheConstants.LANGUAGE_KEY + language.getLocal(), key);
// if (StringUtils.isNotEmpty(str)) {
// if (args.length != 0) {
// str = String.format(str, args);
// }
// return str;
// }
// }
// log.warn("国际化翻译工具: 翻译键不存在或缓存不存在! key: {}", key);
// } catch (Exception e) {
// log.error("国际化翻译工具异常! key: {}", key, e);
// }
if (args.length != 0) { if (args.length != 0) {
return String.format(key, args); return String.format(key, args);
} }
@ -53,7 +27,6 @@ public class TransactionUtils implements InitializingBean {
@Override @Override
public void afterPropertiesSet() { public void afterPropertiesSet() {
// redisService = SpringUtils.getBean(RedisService.class);
} }
} }

333
bd-business/bd-business-sale/src/main/java/com/hzs/activity/pick/controller/api/ApiPickController.java
View File

@ -9,33 +9,43 @@ import com.hzs.activity.pick.vo.ApiPickDetailVO;
import com.hzs.activity.pick.vo.ApiPickVO; import com.hzs.activity.pick.vo.ApiPickVO;
import com.hzs.activity.wares.service.IAcGiftConfigService; import com.hzs.activity.wares.service.IAcGiftConfigService;
import com.hzs.common.core.annotation.RepeatSubmitSimple; import com.hzs.common.core.annotation.RepeatSubmitSimple;
import com.hzs.common.core.constant.CacheConstants;
import com.hzs.common.core.constant.msg.ActivityMsgConstants; import com.hzs.common.core.constant.msg.ActivityMsgConstants;
import com.hzs.common.core.constant.msg.CommonMsgConstants; import com.hzs.common.core.constant.msg.CommonMsgConstants;
import com.hzs.common.core.enums.*; import com.hzs.common.core.enums.*;
import com.hzs.common.core.service.RedisService;
import com.hzs.common.core.utils.CommonUtil;
import com.hzs.common.core.utils.StringUtils; import com.hzs.common.core.utils.StringUtils;
import com.hzs.common.core.web.controller.BaseController; import com.hzs.common.core.web.controller.BaseController;
import com.hzs.common.core.web.domain.AjaxResult; import com.hzs.common.core.web.domain.AjaxResult;
import com.hzs.common.core.web.page.TableDataInfo; import com.hzs.common.core.web.page.TableDataInfo;
import com.hzs.common.domain.activity.base.ext.AcGiftConfigExt; import com.hzs.common.domain.activity.base.ext.AcGiftConfigExt;
import com.hzs.common.domain.activity.pick.AcPick; import com.hzs.common.domain.activity.pick.AcPick;
import com.hzs.common.domain.activity.pick.AcPickMemberLog;
import com.hzs.common.domain.member.base.CuMember;
import com.hzs.common.domain.sale.ext.SaOrderExt;
import com.hzs.common.domain.sale.order.SaOrderItems;
import com.hzs.common.domain.system.base.BdStorehouse;
import com.hzs.common.security.utils.SecurityUtils; import com.hzs.common.security.utils.SecurityUtils;
import com.hzs.common.util.TransactionUtils; import com.hzs.common.util.TransactionUtils;
import com.hzs.member.base.IMemberServiceApi;
import com.hzs.retail.sale.param.RetailOrderOtherParam;
import com.hzs.sale.product.IProductServiceApi; import com.hzs.sale.product.IProductServiceApi;
import com.hzs.sale.product.dto.ProductDTO; import com.hzs.sale.product.dto.ProductDTO;
import com.hzs.system.base.ICurrencyServiceApi;
import com.hzs.system.base.dto.CurrencyDTO;
import org.apache.dubbo.config.annotation.DubboReference; import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date;
import java.util.List; import java.util.List;
import java.util.concurrent.TimeUnit;
/** /**
* @Description: 会员端提货处理控制器 * 会员端提货处理控制器
* @Author: jiang chao
* @Time: 2023/4/24 13:55
* @Classname: ApiPickController
* @PackageName: com.hzs.activity.pick.controller.api
*/ */
@RequestMapping("/api/pick") @RequestMapping("/api/pick")
@RestController @RestController
@ -47,9 +57,15 @@ public class ApiPickController extends BaseController {
private IAcPickMemberLogService iAcPickMemberLogService; private IAcPickMemberLogService iAcPickMemberLogService;
@Autowired @Autowired
private IAcGiftConfigService iAcGiftConfigService; private IAcGiftConfigService iAcGiftConfigService;
@Autowired
private RedisService redisService;
@DubboReference @DubboReference
IProductServiceApi iProductServiceApi; IProductServiceApi iProductServiceApi;
@DubboReference
IMemberServiceApi iMemberServiceApi;
@DubboReference
ICurrencyServiceApi iCurrencyServiceApi;
/** /**
* 查询提货列表 * 查询提货列表
@ -86,6 +102,9 @@ public class ApiPickController extends BaseController {
// 会员提货商品数量不足 // 会员提货商品数量不足
return AjaxResult.error(TransactionUtils.getContent(ActivityMsgConstants.PICK_QUANTITY_NOT_ENOUGH)); return AjaxResult.error(TransactionUtils.getContent(ActivityMsgConstants.PICK_QUANTITY_NOT_ENOUGH));
} }
if (quantity % acPick.getBaseQuantity() != 0) {
return AjaxResult.error(TransactionUtils.getContent(ActivityMsgConstants.PICK_QUANTITY_BASE, acPick.getBaseQuantity()));
}
// 提货详情VO // 提货详情VO
ApiPickVO apiPickVO = new ApiPickVO(); ApiPickVO apiPickVO = new ApiPickVO();
@ -96,7 +115,8 @@ public class ApiPickController extends BaseController {
switch (EPickType.getEnumByValue(acPick.getPickType())) { switch (EPickType.getEnumByValue(acPick.getPickType())) {
case PICK_PRODUCT: case PICK_PRODUCT:
case PRIZE: case PRIZE:
// 提货产品处理、迁移抽奖处理 case COMPANY_PRODUCT:
// 提货产品处理、迁移抽奖处理、分公司产品
// 查询产品 // 查询产品
ProductDTO productDTO = iProductServiceApi.getProduct(acPick.getPkDataId().intValue()).getData(); ProductDTO productDTO = iProductServiceApi.getProduct(acPick.getPkDataId().intValue()).getData();
// 处理提货产品明细 // 处理提货产品明细
@ -175,154 +195,159 @@ public class ApiPickController extends BaseController {
@RepeatSubmitSimple @RepeatSubmitSimple
@PostMapping("/order") @PostMapping("/order")
public AjaxResult order(@RequestBody PickOrderParam param) { public AjaxResult order(@RequestBody PickOrderParam param) {
// if (null == param.getPkId() || null == param.getQuantity() || null == param.getRecProvince() || null == param.getRecCity() if (null == param.getPkId() || null == param.getQuantity() || null == param.getRecProvince() || null == param.getRecCity()
// || StringUtils.isAnyEmpty(param.getRecName(), param.getRecPhone(), param.getRecAddress())) { || StringUtils.isAnyEmpty(param.getRecName(), param.getRecPhone(), param.getRecAddress())) {
// // 缺少参数 // 缺少参数
// return AjaxResult.error(TransactionUtils.getContent(CommonMsgConstants.MISSING_PARAM)); return AjaxResult.error(TransactionUtils.getContent(CommonMsgConstants.MISSING_PARAM));
// } }
//
// // 所属国家 // 所属国家
// Integer pkCountry = SecurityUtils.getPkCountry(); Integer pkCountry = SecurityUtils.getPkCountry();
// // 当前用户 // 当前用户
// Long userId = SecurityUtils.getUserId(); Long userId = SecurityUtils.getUserId();
// // 当前时间 // 当前时间
// Date nowDate = new Date(); Date nowDate = new Date();
//
// QueryWrapper<AcPick> pickQueryWrapper = new QueryWrapper<>(); LambdaQueryWrapper<AcPick> pickQueryWrapper = new LambdaQueryWrapper<>();
// pickQueryWrapper.eq(SystemFieldConstants.PK_ID, param.getPkId()); pickQueryWrapper.eq(AcPick::getPkId, param.getPkId());
// pickQueryWrapper.eq("PK_MEMBER", userId); pickQueryWrapper.eq(AcPick::getPkMember, userId);
// pickQueryWrapper.eq(SystemFieldConstants.PK_COUNTRY, pkCountry); pickQueryWrapper.eq(AcPick::getPkCountry, pkCountry);
// AcPick acPick = iAcPickService.getOne(pickQueryWrapper); AcPick acPick = iAcPickService.getOne(pickQueryWrapper);
// if (null == acPick) { if (null == acPick) {
// // 会员提货商品不存在 // 会员提货商品不存在
// return AjaxResult.error(TransactionUtils.getContent(ActivityMsgConstants.PICK_PRODUCT_NOT_EXIST)); return AjaxResult.error(TransactionUtils.getContent(ActivityMsgConstants.PICK_PRODUCT_NOT_EXIST));
// } }
// if (!acPick.getUsableQuantity().equals(param.getQuantity()) && param.getQuantity() % acPick.getBaseQuantity() != 0) { if (!acPick.getUsableQuantity().equals(param.getQuantity()) && param.getQuantity() % acPick.getBaseQuantity() != 0) {
// // 提货数量等于可提数量 或 提货数量是提货基数的倍数才能进行处理 // 提货数量等于可提数量 或 提货数量是提货基数的倍数才能进行处理
// return AjaxResult.error(TransactionUtils.getContent(ActivityMsgConstants.PICK_QUANTITY_BASE, acPick.getBaseQuantity())); return AjaxResult.error(TransactionUtils.getContent(ActivityMsgConstants.PICK_QUANTITY_BASE, acPick.getBaseQuantity()));
// } }
//
// // 邮费 // 邮费
// BigDecimal postage = iAcPickService.postageHandle(acPick, param.getQuantity(), param.getRecProvince(), param.getRecCity(), pkCountry); BigDecimal postage = iAcPickService.postageHandle(acPick, param.getQuantity(), param.getRecProvince(), param.getRecCity(), pkCountry);
// if (null == postage) { if (null == postage) {
// // 提货邮费计算错误 // 提货邮费计算错误
// return AjaxResult.error(TransactionUtils.getContent(ActivityMsgConstants.PICK_POSTAGE_ERROR)); return AjaxResult.error(TransactionUtils.getContent(ActivityMsgConstants.PICK_POSTAGE_ERROR));
// } }
//
// // 查询会员信息 // 查询会员信息
// CuMember cuMember = iMemberServiceApi.getMember(userId).getData(); CuMember cuMember = iMemberServiceApi.getMember(userId).getData();
// // 查询汇率 // 查询汇率
// CurrencyDTO currencyDTO = iCurrencyServiceApi.getCurrency(pkCountry).getData(); CurrencyDTO currencyDTO = iCurrencyServiceApi.getCurrency(pkCountry).getData();
// // 生成订单编号 // 生成订单编号
// String orderCode = CommonUtil.createSerialNumber(EOrderPrefix.ORDER_CODE); String orderCode = CommonUtil.createSerialNumber(EOrderPrefix.ORDER_CODE);
//
// // 根据收货省获取仓库 // 根据收货省获取仓库
// BdStorehouse storehouse = iCurrencyServiceApi.queryBdStorehouseByProvince(param.getRecProvince()).getData(); BdStorehouse storehouse = iCurrencyServiceApi.queryBdStorehouseByProvince(param.getRecProvince()).getData();
//
// // 生成订单信息 // 生成订单信息
// SaOrderExt saOrder = new SaOrderExt(); SaOrderExt saOrder = new SaOrderExt();
// saOrder.setOrderCode(orderCode); saOrder.setOrderCode(orderCode);
// saOrder.setOrderType(EOrderType.PICK_ORDER.getValue()); saOrder.setOrderType(EOrderType.PICK_ORDER.getValue());
// saOrder.setPkRate(currencyDTO.getPkId()); saOrder.setPkRate(currencyDTO.getPkId());
// saOrder.setOrderAmount(BigDecimal.ZERO); saOrder.setOrderAmount(BigDecimal.ZERO);
// saOrder.setPostage(postage); saOrder.setPostage(postage);
// saOrder.setRecName(param.getRecName()); saOrder.setRecName(param.getRecName());
// saOrder.setRecPhone(param.getRecPhone()); saOrder.setRecPhone(param.getRecPhone());
// saOrder.setRecProvince(param.getRecProvince()); saOrder.setRecProvince(param.getRecProvince());
// saOrder.setRecCity(param.getRecCity()); saOrder.setRecCity(param.getRecCity());
// saOrder.setRecCounty(param.getRecCounty()); saOrder.setRecCounty(param.getRecCounty());
// saOrder.setRecAddress(param.getRecAddress()); saOrder.setRecAddress(param.getRecAddress());
// saOrder.setRemark(param.getRemark()); saOrder.setRemark(param.getRemark());
// saOrder.setPkMember(userId); saOrder.setPkMember(userId);
// saOrder.setPkReference(cuMember.getPkParent()); saOrder.setPkReference(cuMember.getPkParent());
// saOrder.setTranType(ETransportType.LAND.getValue()); saOrder.setTranType(ETransportType.LAND.getValue());
// saOrder.setPkVertex(cuMember.getPkVertex()); saOrder.setDeliveryWay(EDelivery.FAST_MAIL.getValue());
// if (null != storehouse) { saOrder.setPkVertex(cuMember.getPkVertex());
// saOrder.setPkStorehouse(storehouse.getPkId()); if (null != storehouse) {
// } saOrder.setPkStorehouse(storehouse.getPkId());
// saOrder.setPkCreator(userId); }
// saOrder.setCreationTime(nowDate); saOrder.setPkCreator(userId);
// saOrder.setPkCountry(pkCountry); saOrder.setCreationTime(nowDate);
// saOrder.setPkCountry(pkCountry);
// // 生成订单明细信息
// List<SaOrderItems> orderItemsList = new ArrayList<>(); // 生成订单明细信息
// List<SaOrderItems> orderItemsList = new ArrayList<>();
// // 根据各种提货不同进行处理
// switch (EPickType.getEnumByValue(acPick.getPickType())) { // 根据各种提货不同进行处理
// case PICK_PRODUCT: switch (EPickType.getEnumByValue(acPick.getPickType())) {
// case PRIZE: case PICK_PRODUCT:
// // 提货产品处理、迁移抽奖处理 case PRIZE:
// // 查询产品信息 case COMPANY_PRODUCT:
// ProductDTO productDTO = iProductServiceApi.getProduct(acPick.getPkDataId().intValue()).getData(); // 提货产品处理、迁移抽奖处理、分公司产品
// // 查询产品信息
// // 处理提货产品明细 ProductDTO productDTO = iProductServiceApi.getProduct(acPick.getPkDataId().intValue()).getData();
// SaOrderItems productOrderItems = new SaOrderItems(); // 处理提货产品明细
// productOrderItems.setPkProduct(acPick.getPkDataId().intValue()); SaOrderItems productOrderItems = new SaOrderItems();
// productOrderItems.setPkRate(currencyDTO.getPkId()); productOrderItems.setPkProduct(acPick.getPkDataId().intValue());
// productOrderItems.setQuantity(param.getQuantity()); productOrderItems.setQuantity(param.getQuantity());
// productOrderItems.setPkGrade(cuMember.getPkSettleGrade()); productOrderItems.setPkRate(currencyDTO.getPkId());
// productOrderItems.setPkAwards(cuMember.getPkAwards()); productOrderItems.setPkWares(0);
// productOrderItems.setOrderStatus(EOrderStatus.PAY.getValue()); productOrderItems.setWaresQuantity(param.getQuantity());
// productOrderItems.setPkCreator(userId); productOrderItems.setPkGrade(cuMember.getPkSettleGrade());
// productOrderItems.setCreationTime(nowDate); productOrderItems.setPkAwards(cuMember.getPkAwards());
// productOrderItems.setSpecsName(acPick.getSpecsName()); productOrderItems.setOrderStatus(EOrderStatus.PAY.getValue());
// productOrderItems.setSpecsNameId(acPick.getSpecsNameId()); productOrderItems.setPkCreator(userId);
// productOrderItems.setPkCountry(pkCountry); productOrderItems.setCreationTime(nowDate);
// productOrderItems.setWaresQuantity(param.getQuantity()); productOrderItems.setSpecsName(acPick.getSpecsName());
// productOrderItems.setSkuCode(CommonUtil.createSkuCode(productDTO.getProductCode(), acPick.getSpecsNameId())); productOrderItems.setSpecsNameId(acPick.getSpecsNameId());
// productOrderItems.setPkStorehouse(saOrder.getPkStorehouse()); productOrderItems.setPkCountry(pkCountry);
// orderItemsList.add(productOrderItems); productOrderItems.setSkuCode(CommonUtil.createSkuCode(productDTO.getProductCode(), acPick.getSpecsNameId()));
// break; productOrderItems.setPkStorehouse(saOrder.getPkStorehouse());
// case LOTTERY_DRAW: orderItemsList.add(productOrderItems);
// case CONSUMPTION_GIFT: break;
// case DIRECT_PUSH_GIFT: case LOTTERY_DRAW:
// // 抽奖活动、商品赠品活动、消费赠送活动、直推赠送活动 case CONSUMPTION_GIFT:
// case DIRECT_PUSH_GIFT:
// // 处理提货产品明细 // 抽奖活动、商品赠品活动、消费赠送活动、直推赠送活动
// List<AcGiftConfigExt> giftConfigList = iAcGiftConfigService.queryListByRuleIdList(acPick.getPkDataId(), pkCountry); // 处理提货产品明细
// for (AcGiftConfigExt acGiftConfigExt : giftConfigList) { List<AcGiftConfigExt> giftConfigList = iAcGiftConfigService.queryListByRuleIdList(acPick.getPkDataId(), pkCountry);
// // 查询产品信息 for (AcGiftConfigExt acGiftConfigExt : giftConfigList) {
// ProductDTO giftProductDTO = iProductServiceApi.getProduct(acGiftConfigExt.getPkProduct()).getData(); // 查询产品信息
// if (null == giftProductDTO) { ProductDTO giftProductDTO = iProductServiceApi.getProduct(acGiftConfigExt.getPkProduct()).getData();
// return AjaxResult.error("提货产品不存在，请联系客服处理"); if (null == giftProductDTO) {
// } return AjaxResult.error("提货产品不存在，请联系客服处理");
// }
// SaOrderItems giftOrderItems = new SaOrderItems(); SaOrderItems giftOrderItems = new SaOrderItems();
// giftOrderItems.setPkProduct(acGiftConfigExt.getPkProduct()); giftOrderItems.setPkProduct(acGiftConfigExt.getPkProduct());
// giftOrderItems.setPkRate(currencyDTO.getPkId()); giftOrderItems.setPkRate(currencyDTO.getPkId());
// giftOrderItems.setQuantity(param.getQuantity() * acGiftConfigExt.getQuantity()); giftOrderItems.setQuantity(param.getQuantity() * acGiftConfigExt.getQuantity());
// giftOrderItems.setPkGrade(cuMember.getPkSettleGrade()); giftOrderItems.setPkGrade(cuMember.getPkSettleGrade());
// giftOrderItems.setPkAwards(cuMember.getPkAwards()); giftOrderItems.setPkAwards(cuMember.getPkAwards());
// giftOrderItems.setOrderStatus(EOrderStatus.PAY.getValue()); giftOrderItems.setOrderStatus(EOrderStatus.PAY.getValue());
// giftOrderItems.setPkCreator(userId); giftOrderItems.setPkCreator(userId);
// giftOrderItems.setCreationTime(nowDate); giftOrderItems.setCreationTime(nowDate);
// giftOrderItems.setSpecsName(acPick.getSpecsName()); giftOrderItems.setSpecsName(acPick.getSpecsName());
// giftOrderItems.setSpecsNameId(acPick.getSpecsNameId()); giftOrderItems.setSpecsNameId(acPick.getSpecsNameId());
// giftOrderItems.setPkCountry(pkCountry); giftOrderItems.setPkCountry(pkCountry);
// giftOrderItems.setWaresQuantity(param.getQuantity()); giftOrderItems.setWaresQuantity(param.getQuantity());
// giftOrderItems.setSkuCode(CommonUtil.createSkuCode(giftProductDTO.getProductCode(), acPick.getSpecsNameId())); giftOrderItems.setSkuCode(CommonUtil.createSkuCode(giftProductDTO.getProductCode(), acPick.getSpecsNameId()));
// orderItemsList.add(giftOrderItems); orderItemsList.add(giftOrderItems);
// } }
// break; break;
// default: default:
// } }
// saOrder.setOrderItemsList(orderItemsList); saOrder.setOrderItemsList(orderItemsList);
//
// // 添加提货日志 // 添加提货日志
// AcPickMemberLog acPickMemberLog = new AcPickMemberLog(); AcPickMemberLog acPickMemberLog = new AcPickMemberLog();
// acPickMemberLog.setPkMember(userId); acPickMemberLog.setPkMember(userId);
// acPickMemberLog.setPkPick(acPick.getPkId()); acPickMemberLog.setPkPick(acPick.getPkId());
// acPickMemberLog.setPickQuantity(param.getQuantity()); acPickMemberLog.setPickQuantity(param.getQuantity());
// acPickMemberLog.setPickTime(nowDate); acPickMemberLog.setPickTime(nowDate);
// acPickMemberLog.setPickOrder(orderCode); acPickMemberLog.setPickOrder(orderCode);
// acPickMemberLog.setPkCountry(pkCountry); acPickMemberLog.setPkCountry(pkCountry);
// iAcPickMemberLogService.save(acPickMemberLog); iAcPickMemberLogService.save(acPickMemberLog);
//
// // 临时订单直接放入缓存 RetailOrderOtherParam orderParam = new RetailOrderOtherParam();
// redisService.setCacheObject(CacheConstants.TEMP_ORDER + userId + orderCode, saOrder, CacheConstants.MEMBER_REFRESH_TIME, TimeUnit.MINUTES); orderParam.setBuyMemberCode(cuMember.getMemberCode());
// orderParam.setSpecialArea(ESpecialArea.PICK_AREA.getValue());
// return AjaxResult.success("", orderCode);
return AjaxResult.error(); // 订单缓存（60分钟有效，防止在线支付回调慢）
redisService.setCacheObject(CacheConstants.RETAIL_TEMP_ORDER + userId + orderCode, saOrder, CacheConstants.RETAIL_ORDER_EXPIRE_TIME * 2, TimeUnit.MINUTES);
// 缓存订单参数（30分钟有效）
redisService.setCacheObject(CacheConstants.RETAIL_TEMP_OTHER_PARAM + userId + orderCode, orderParam, CacheConstants.RETAIL_ORDER_EXPIRE_TIME * 2, TimeUnit.MINUTES);
return AjaxResult.success("", orderCode);
} }
/** /**

18
bd-business/bd-business-sale/src/main/java/com/hzs/activity/pick/mapper/AcPickMapper.java
View File

@ -64,11 +64,7 @@ public interface AcPickMapper extends BaseMapper<AcPick> {
int updatePickByPkId(@Param("acPick") AcPick acPick); int updatePickByPkId(@Param("acPick") AcPick acPick);
/** /**
* @description: 删除充值提货卡 * 删除充值提货卡
* @author: zhang jing
* @date: 2023/10/26 13:45
* @param: [acPick]
* @return: boolean
**/ **/
boolean removePickByPkId(@Param("acPick") AcPick acPick); boolean removePickByPkId(@Param("acPick") AcPick acPick);
@ -107,4 +103,16 @@ public interface AcPickMapper extends BaseMapper<AcPick> {
*/ */
int batchSaveOrUpdatePick(@Param("pickList") List<AcPick> pickList); int batchSaveOrUpdatePick(@Param("pickList") List<AcPick> pickList);
/**
* 根据ID更新会员提货数据
*
* @param pkId
* @param quantity
* @param pkMember 会员ID，可为null
* @return
*/
int updateMemberPickById(@Param("pkId") Long pkId,
@Param("quantity") Integer quantity,
@Param("pkMember") Long pkMember);
} }

12
bd-business/bd-business-sale/src/main/java/com/hzs/activity/pick/mapper/AcPickMemberLogMapper.java
View File

@ -13,6 +13,18 @@ import java.util.List;
*/ */
public interface AcPickMemberLogMapper extends BaseMapper<AcPickMemberLog> { public interface AcPickMemberLogMapper extends BaseMapper<AcPickMemberLog> {
/**
* 查询会员订单数据
*
* @param pkMember
* @param orderCode
* @param delFlag
* @return
*/
List<AcPickMemberLog> listPickMemberLog(@Param("pkMember") Long pkMember,
@Param("orderCode") String orderCode,
@Param("delFlag") Integer delFlag);
/** /**
* 查询提货日志 * 查询提货日志
* *

10
bd-business/bd-business-sale/src/main/java/com/hzs/activity/pick/service/IAcPickMemberLogService.java
View File

@ -12,6 +12,16 @@ import java.util.List;
*/ */
public interface IAcPickMemberLogService extends IService<AcPickMemberLog> { public interface IAcPickMemberLogService extends IService<AcPickMemberLog> {
/**
* 查询会员订单数据
*
* @param pkMember
* @param orderCode
* @param delFlag
* @return
*/
List<AcPickMemberLog> listPickMemberLog(Long pkMember, String orderCode, Integer delFlag);
/** /**
* 查询提货日志 * 查询提货日志
* *

11
bd-business/bd-business-sale/src/main/java/com/hzs/activity/pick/service/IAcPickService.java
View File

@ -135,4 +135,15 @@ public interface IAcPickService extends IService<AcPick> {
*/ */
int batchSaveOrUpdatePick(List<AcPick> pickList); int batchSaveOrUpdatePick(List<AcPick> pickList);
/**
* 根据ID更新会员提货数据
*
* @param pkId
* @param quantity
* @param pkMember 会员ID，可为null
* @return
*/
int updateMemberPickById(Long pkId, Integer quantity, Long pkMember);
} }

5
bd-business/bd-business-sale/src/main/java/com/hzs/activity/pick/service/impl/AcPickMemberLogServiceImpl.java
View File

@ -16,6 +16,11 @@ import java.util.*;
@Service @Service
public class AcPickMemberLogServiceImpl extends ServiceImpl<AcPickMemberLogMapper, AcPickMemberLog> implements IAcPickMemberLogService { public class AcPickMemberLogServiceImpl extends ServiceImpl<AcPickMemberLogMapper, AcPickMemberLog> implements IAcPickMemberLogService {
@Override
public List<AcPickMemberLog> listPickMemberLog(Long pkMember, String orderCode, Integer delFlag) {
return baseMapper.listPickMemberLog(pkMember, orderCode, delFlag);
}
@Override @Override
public List<AcPickMemberLogVO> queryMemberLog(Long pkMember) { public List<AcPickMemberLogVO> queryMemberLog(Long pkMember) {
return baseMapper.queryMemberLog(pkMember); return baseMapper.queryMemberLog(pkMember);

20
bd-business/bd-business-sale/src/main/java/com/hzs/activity/pick/service/impl/AcPickServiceImpl.java
View File

@ -18,7 +18,6 @@ import com.hzs.common.core.constant.msg.CommonMsgConstants;
import com.hzs.common.core.constant.msg.DocumentMsgConstants; import com.hzs.common.core.constant.msg.DocumentMsgConstants;
import com.hzs.common.core.domain.R; import com.hzs.common.core.domain.R;
import com.hzs.common.core.enums.*; import com.hzs.common.core.enums.*;
import com.hzs.common.core.exception.ServiceException;
import com.hzs.common.core.exception.base.BaseException; import com.hzs.common.core.exception.base.BaseException;
import com.hzs.common.core.utils.CommonUtil; import com.hzs.common.core.utils.CommonUtil;
import com.hzs.common.core.utils.DateUtils; import com.hzs.common.core.utils.DateUtils;
@ -32,8 +31,8 @@ import com.hzs.common.domain.member.base.CuMember;
import com.hzs.common.domain.sale.product.BdProduct; import com.hzs.common.domain.sale.product.BdProduct;
import com.hzs.common.util.TransactionUtils; import com.hzs.common.util.TransactionUtils;
import com.hzs.member.base.IMemberServiceApi; import com.hzs.member.base.IMemberServiceApi;
import com.hzs.sale.postage.IPostageServiceApi;
import com.hzs.sale.postage.dto.PostageProductDTO; import com.hzs.sale.postage.dto.PostageProductDTO;
import com.hzs.sale.postage.service.IPostageBusinessService;
import com.hzs.sale.product.service.IBdProductService; import com.hzs.sale.product.service.IBdProductService;
import com.hzs.system.sys.IApprovalServiceApi; import com.hzs.system.sys.IApprovalServiceApi;
import com.hzs.system.sys.dto.ApprovalBusinessResultDTO; import com.hzs.system.sys.dto.ApprovalBusinessResultDTO;
@ -70,13 +69,13 @@ public class AcPickServiceImpl extends ServiceImpl<AcPickMapper, AcPick> impleme
private RabbitTemplate rabbitTemplate; private RabbitTemplate rabbitTemplate;
@Autowired @Autowired
private IBdProductService iBdProductService; private IBdProductService iBdProductService;
@Autowired
private IPostageBusinessService iPostageBusinessService;
@DubboReference @DubboReference
IApprovalServiceApi iApprovalServiceApi; IApprovalServiceApi iApprovalServiceApi;
@DubboReference @DubboReference
IMemberServiceApi iMemberServiceApi; IMemberServiceApi iMemberServiceApi;
@DubboReference
IPostageServiceApi iPostageServiceApi;
@Override @Override
public boolean addPickByActivity(Long pkMember, Integer pickType, Long pkBaseConfig, Long pkDataId, public boolean addPickByActivity(Long pkMember, Integer pickType, Long pkBaseConfig, Long pkDataId,
@ -571,6 +570,7 @@ public class AcPickServiceImpl extends ServiceImpl<AcPickMapper, AcPick> impleme
switch (EPickType.getEnumByValue(acPick.getPickType())) { switch (EPickType.getEnumByValue(acPick.getPickType())) {
case PICK_PRODUCT: case PICK_PRODUCT:
case PRIZE: case PRIZE:
case COMPANY_PRODUCT:
// 提货产品处理、迁移抽奖处理 // 提货产品处理、迁移抽奖处理
// 封装邮费查询产品数据列表 // 封装邮费查询产品数据列表
productList.add(PostageProductDTO.builder() productList.add(PostageProductDTO.builder()
@ -594,15 +594,17 @@ public class AcPickServiceImpl extends ServiceImpl<AcPickMapper, AcPick> impleme
default: default:
} }
R<BigDecimal> postageR = iPostageServiceApi.queryPostage(acPick.getPkPostage(), productList, recProvince, recCity); return iPostageBusinessService.queryPostage(acPick.getPkPostage(), productList, recProvince, recCity);
if (postageR.isSuccess()) {
return postageR.getData();
}
throw new ServiceException(postageR.getMsg());
} }
@Override @Override
public int batchSaveOrUpdatePick(List<AcPick> pickList) { public int batchSaveOrUpdatePick(List<AcPick> pickList) {
return baseMapper.batchSaveOrUpdatePick(pickList); return baseMapper.batchSaveOrUpdatePick(pickList);
} }
@Override
public int updateMemberPickById(Long pkId, Integer quantity, Long pkMember) {
return baseMapper.updateMemberPickById(pkId, quantity, pkMember);
}
} }

6
bd-business/bd-business-sale/src/main/java/com/hzs/activity/pick/vo/ApiPickListVO.java
View File

@ -6,11 +6,7 @@ import lombok.Data;
import java.util.Date; import java.util.Date;
/** /**
* @Description: 会员提货列表VO * 会员提货列表VO
* @Author: jiang chao
* @Time: 2023/4/24 16:15
* @Classname: ApiPickVO
* @PackageName: com.hzs.activity.pick.vo
*/ */
@Data @Data
public class ApiPickListVO { public class ApiPickListVO {

13
bd-business/bd-business-sale/src/main/java/com/hzs/retail/sale/controller/api/ApiRetailOrderController.java
View File

@ -485,7 +485,7 @@ public class ApiRetailOrderController {
* @param payParam 支付订单入参 * @param payParam 支付订单入参
* @return * @return
*/ */
@RepeatSubmit // @RepeatSubmit
@PostMapping("/pay-other-order") @PostMapping("/pay-other-order")
public AjaxResult payOtherOrder(@Valid @RequestBody RetailOrderPayParam payParam) { public AjaxResult payOtherOrder(@Valid @RequestBody RetailOrderPayParam payParam) {
// 当前会员ID // 当前会员ID
@ -505,7 +505,16 @@ public class ApiRetailOrderController {
} }
// 封装订单信息 // 封装订单信息
SaOrderExt saOrderExt = iRetailOrderService.createSaOrder(otherParam, null, buyMember); SaOrderExt saOrderExt;
if (ESpecialArea.PICK_AREA.getValue() == otherParam.getSpecialArea()) {
// 提货专区，获取缓存订单
saOrderExt = redisService.getCacheObject(CacheConstants.RETAIL_TEMP_ORDER + pkMember + payParam.getOrderCode());
if (null == saOrderExt) {
return AjaxResult.error("订单已不存在");
}
} else {
saOrderExt = iRetailOrderService.createSaOrder(otherParam, null, buyMember);
}
// 校验会员账户状态等 // 校验会员账户状态等
R<CuMemberAccountExt> accountResult = iRetailOrderService.validMemberAccount(pkMember, payParam.getPayPwd()); R<CuMemberAccountExt> accountResult = iRetailOrderService.validMemberAccount(pkMember, payParam.getPayPwd());

75
bd-business/bd-business-sale/src/main/java/com/hzs/retail/sale/controller/service/impl/RetailOrderServiceImpl.java
View File

@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.lang.Validator; import cn.hutool.core.lang.Validator;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.hzs.activity.pick.service.IAcPickMemberLogService;
import com.hzs.activity.pick.service.IAcPickService; import com.hzs.activity.pick.service.IAcPickService;
import com.hzs.common.core.constant.*; import com.hzs.common.core.constant.*;
import com.hzs.common.core.domain.R; import com.hzs.common.core.domain.R;
@ -13,6 +14,7 @@ import com.hzs.common.core.exception.ServiceException;
import com.hzs.common.core.service.RedisService; import com.hzs.common.core.service.RedisService;
import com.hzs.common.core.utils.*; import com.hzs.common.core.utils.*;
import com.hzs.common.domain.activity.pick.AcPick; import com.hzs.common.domain.activity.pick.AcPick;
import com.hzs.common.domain.activity.pick.AcPickMemberLog;
import com.hzs.common.domain.member.account.CuMemberAccount; import com.hzs.common.domain.member.account.CuMemberAccount;
import com.hzs.common.domain.member.base.CuMember; import com.hzs.common.domain.member.base.CuMember;
import com.hzs.common.domain.member.ext.CuMemberAccountExt; import com.hzs.common.domain.member.ext.CuMemberAccountExt;
@ -33,7 +35,6 @@ import com.hzs.retail.sale.param.RetailOrderParam;
import com.hzs.retail.sale.param.RetailOrderRegisterParam; import com.hzs.retail.sale.param.RetailOrderRegisterParam;
import com.hzs.retail.sale.param.RetailOrderUpgradeParam; import com.hzs.retail.sale.param.RetailOrderUpgradeParam;
import com.hzs.sale.order.param.OrderItemsParam; import com.hzs.sale.order.param.OrderItemsParam;
import com.hzs.sale.order.param.WaresNumberParam;
import com.hzs.sale.order.service.*; import com.hzs.sale.order.service.*;
import com.hzs.sale.order.service.impl.SaOrderHandle; import com.hzs.sale.order.service.impl.SaOrderHandle;
import com.hzs.sale.wares.service.IBdWaresDetailService; import com.hzs.sale.wares.service.IBdWaresDetailService;
@ -83,6 +84,8 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
private ISaOrderWaresLimitService iSaOrderWaresLimitService; private ISaOrderWaresLimitService iSaOrderWaresLimitService;
@Autowired @Autowired
private IAcPickService iAcPickService; private IAcPickService iAcPickService;
@Autowired
private IAcPickMemberLogService iAcPickMemberLogService;
@Autowired @Autowired
private RedisService redisService; private RedisService redisService;
@ -661,15 +664,14 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
List<SaOrderWares> orderWaresList = new ArrayList<>(); List<SaOrderWares> orderWaresList = new ArrayList<>();
// 订单商品map（key：商品主键-商品价格，value：商品数量） // 订单商品map（key：商品主键-商品价格，value：商品数量）
Map<String, Integer> orderWaresMap = new HashMap<>(); Map<String, Integer> orderWaresMap = new HashMap<>();
// 商品销量数据 // // 商品销量数据
List<WaresNumberParam> waresNumberList = new ArrayList<>(); // List<WaresNumberParam> waresNumberList = new ArrayList<>();
// 商品销量map（key：商品主键，value：商品数量） // // 商品销量map（key：商品主键，value：商品数量）
Map<Integer, Integer> waresNumberMap = new HashMap<>(); // Map<Integer, Integer> waresNumberMap = new HashMap<>();
// 商品限购列表 // 商品限购列表
List<SaOrderWaresLimit> waresLimitList = new ArrayList<>(); List<SaOrderWaresLimit> waresLimitList = new ArrayList<>();
// 商品限购map（key：商品主键，value：商品数量） // 商品限购map（key：商品主键，value：商品数量）
Map<Integer, Integer> waresLimitMap = new HashMap<>(); Map<Integer, Integer> waresLimitMap = new HashMap<>();
// 盒数商品 // 盒数商品
List<String> boxWaresList = BoxProductUtil.getBoxProductListBySystemType(saOrderExt.getSystemType()); List<String> boxWaresList = BoxProductUtil.getBoxProductListBySystemType(saOrderExt.getSystemType());
@ -678,10 +680,6 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
saOrderItems.setOrderStatus(EOrderStatus.PAY.getValue()); saOrderItems.setOrderStatus(EOrderStatus.PAY.getValue());
saOrderItems.setPkCreator(saOrderExt.getPkCreator()); saOrderItems.setPkCreator(saOrderExt.getPkCreator());
saOrderItems.setCreationTime(saOrderExt.getCreationTime()); saOrderItems.setCreationTime(saOrderExt.getCreationTime());
if (EDelivery.PICK.getValue() == saOrderExt.getDeliveryWay()) {
// 主订单是提货中心，明细状态也是提货中心
saOrderItems.setOrderStatus(EOrderStatus.PICK.getValue());
}
// 指定商品拆分 并且 非赠品 // 指定商品拆分 并且 非赠品
if (boxWaresList.contains(saOrderItems.getWareCode()) if (boxWaresList.contains(saOrderItems.getWareCode())
@ -692,11 +690,35 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
waresLimitMap.merge(saOrderItems.getPkWares(), saOrderItems.getWaresQuantity(), Integer::sum); waresLimitMap.merge(saOrderItems.getPkWares(), saOrderItems.getWaresQuantity(), Integer::sum);
} }
// 商品销量累计 // // 商品销量累计
waresNumberMap.merge(saOrderItems.getPkWares(), saOrderItems.getWaresQuantity(), Integer::sum); // waresNumberMap.merge(saOrderItems.getPkWares(), saOrderItems.getWaresQuantity(), Integer::sum);
if (null != saOrderExt.getDeliveryWay()
&& EDelivery.PICK.getValue() == saOrderExt.getDeliveryWay()) {
// 主订单发货方式是提货中心，明细状态也是提货中心
saOrderItems.setOrderStatus(EOrderStatus.PICK.getValue());
}
} }
iSaOrderItemsService.saveBatch(saOrderExt.getOrderItemsList()); iSaOrderItemsService.saveBatch(saOrderExt.getOrderItemsList());
if (EOrderType.PICK_ORDER.getValue() == saOrderExt.getOrderType()) {
// 提货订单处理
// 提货日志列表
List<AcPickMemberLog> pickMemberLogList = iAcPickMemberLogService.listPickMemberLog(saOrderExt.getPkMember(), saOrderExt.getOrderCode(), EDelFlag.DELETE.getValue());
if (CollectionUtil.isNotEmpty(pickMemberLogList)) {
for (AcPickMemberLog acPickMemberLog : pickMemberLogList) {
// 更新会员提货表
iAcPickService.updateMemberPickById(acPickMemberLog.getPkPick(), acPickMemberLog.getPickQuantity() * -1, acPickMemberLog.getPkMember());
// 更新会员提货日志表
iAcPickMemberLogService.update(Wrappers.<AcPickMemberLog>lambdaUpdate()
.eq(AcPickMemberLog::getPkId, acPickMemberLog.getPkId())
.eq(AcPickMemberLog::getDelFlag, EDelFlag.DELETE.getValue())
.set(AcPickMemberLog::getDelFlag, EDelFlag.UN_DELETE.getValue())
);
}
}
}
if (orderWaresMap.size() > 0) { if (orderWaresMap.size() > 0) {
// 处理订单商品拆分数据 // 处理订单商品拆分数据
for (String key : orderWaresMap.keySet()) { for (String key : orderWaresMap.keySet()) {
@ -711,15 +733,15 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
orderWaresList.add(saOrderWares); orderWaresList.add(saOrderWares);
} }
} }
if (waresNumberMap.size() > 0) { // if (waresNumberMap.size() > 0) {
// 处理订单商品销量、会员商品限购 // // 处理订单商品销量、会员商品限购
for (Integer key : waresNumberMap.keySet()) { // for (Integer key : waresNumberMap.keySet()) {
waresNumberList.add(WaresNumberParam.builder() // waresNumberList.add(WaresNumberParam.builder()
.pkWares(key) // .pkWares(key)
.number(waresNumberMap.get(key)) // .number(waresNumberMap.get(key))
.build()); // .build());
} // }
} // }
if (ESpecialArea.RETAIL_REGISTER.getValue() == saOrderExt.getOrderType() if (ESpecialArea.RETAIL_REGISTER.getValue() == saOrderExt.getOrderType()
|| ESpecialArea.RETAIL_UPGRADE.getValue() == saOrderExt.getOrderType()) { || ESpecialArea.RETAIL_UPGRADE.getValue() == saOrderExt.getOrderType()) {
// 注册、升级 // 注册、升级
@ -766,10 +788,10 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
// 订单商品拆分表 // 订单商品拆分表
iSaOrderWaresService.saveBatch(orderWaresList); iSaOrderWaresService.saveBatch(orderWaresList);
} }
if (waresNumberList.size() > 0) { // if (waresNumberList.size() > 0) {
// 更新商品销量表 // // 更新商品销量表
iBdWaresExtendService.updateWaresSalesAccrual(waresNumberList); // iBdWaresExtendService.updateWaresSalesAccrual(waresNumberList);
} // }
if (waresLimitList.size() > 0) { if (waresLimitList.size() > 0) {
// 更新会员商品限购 // 更新会员商品限购
iSaOrderWaresLimitService.saveBatchLimit(waresLimitList); iSaOrderWaresLimitService.saveBatchLimit(waresLimitList);
@ -820,7 +842,8 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
*/ */
private Boolean handleMemberActivate(CuMember cuMember, SaOrderExt saOrder) { private Boolean handleMemberActivate(CuMember cuMember, SaOrderExt saOrder) {
if ((null == cuMember.getIsActivate() || EYesNo.YES.getIntValue() != cuMember.getIsActivate()) if ((null == cuMember.getIsActivate() || EYesNo.YES.getIntValue() != cuMember.getIsActivate())
&& (EOrderType.RETAIL_REGISTER.getValue() == saOrder.getOrderType() || EOrderType.RETAIL_UPGRADE.getValue() == saOrder.getOrderType()) && (EOrderType.RETAIL_REGISTER.getValue() == saOrder.getOrderType()
|| EOrderType.RETAIL_UPGRADE.getValue() == saOrder.getOrderType())
) { ) {
// 会员激活状态为空 或 未激活，并且是 注册、升级 订单，判断会员是否激活 // 会员激活状态为空 或 未激活，并且是 注册、升级 订单，判断会员是否激活
if (saOrder.getBoxNum() > 0) { if (saOrder.getBoxNum() > 0) {

3
bd-business/bd-business-sale/src/main/java/com/hzs/retail/sale/param/RetailOrderOtherParam.java
View File

@ -1,8 +1,7 @@
package com.hzs.retail.sale.param; package com.hzs.retail.sale.param;
import com.hzs.common.domain.member.base.CuMember; import com.hzs.common.domain.member.base.CuMember;
import lombok.Data; import lombok.*;
import lombok.EqualsAndHashCode;
import javax.validation.constraints.NotEmpty; import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.Size; import javax.validation.constraints.Size;

8
bd-business/bd-business-sale/src/main/java/com/hzs/sale/order/param/WaresNumberParam.java
View File

@ -5,14 +5,6 @@ import lombok.Builder;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
/**
* @BelongsProject: hzs_cloud
* @BelongsPackage: com.hzs.sale.order.param
* @Author: yh
* @CreateTime: 2023-05-05 17:33
* @Description: TODO
* @Version: 1.0
*/
@Data @Data
@Builder @Builder
@AllArgsConstructor @AllArgsConstructor

271
bd-business/bd-business-sale/src/main/java/com/hzs/sale/order/service/impl/SaOrderServiceImpl.java
View File

@ -7,7 +7,9 @@ import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hzs.activity.pick.service.IAcPickMemberLogService;
import com.hzs.activity.pick.service.IAcPickService; import com.hzs.activity.pick.service.IAcPickService;
import com.hzs.activity.pick.service.IAcRetailPickService; import com.hzs.activity.pick.service.IAcRetailPickService;
import com.hzs.common.core.constant.*; import com.hzs.common.core.constant.*;
@ -19,6 +21,7 @@ import com.hzs.common.core.exception.ServiceException;
import com.hzs.common.core.service.RedisService; import com.hzs.common.core.service.RedisService;
import com.hzs.common.core.utils.*; import com.hzs.common.core.utils.*;
import com.hzs.common.core.utils.reflect.ReflectUtils; import com.hzs.common.core.utils.reflect.ReflectUtils;
import com.hzs.common.domain.activity.pick.AcPickMemberLog;
import com.hzs.common.domain.member.account.CuMemberAccount; import com.hzs.common.domain.member.account.CuMemberAccount;
import com.hzs.common.domain.member.base.CuMember; import com.hzs.common.domain.member.base.CuMember;
import com.hzs.common.domain.member.base.CuMemberRegister; import com.hzs.common.domain.member.base.CuMemberRegister;
@ -93,65 +96,65 @@ import java.util.stream.Collectors;
public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> implements ISaOrderService { public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> implements ISaOrderService {
@DubboReference @DubboReference
IMemberServiceApi memberServiceApi; IMemberServiceApi iMemberServiceApi;
@DubboReference
IGradeServiceApi gradeServiceApi;
@DubboReference
IAwardsServiceApi awardsServiceApi;
@DubboReference
IAreaServiceApi areaServiceApi;
@DubboReference
IMemberBankServiceApi memberBankServiceApi;
@DubboReference
IMemberAccountServiceApi memberAccountServiceApi;
@DubboReference
IAreaCurrencyServiceApi areaCurrencyServiceApi;
@DubboReference
ICountryServiceApi countryServiceApi;
@DubboReference
ICurrencyServiceApi currencyServiceApi;
@DubboReference
IApprovalServiceApi approvalServiceApi;
@DubboReference
IMemberAchieveServiceApi memberAchieveServiceApi;
@DubboReference
ISystemConfigServiceApi systemConfigServiceApi;
@DubboReference
ICuMemberServiceLogServiceApi cuMemberServiceLogServiceApi;
@DubboReference
IMemberTradeServiceApi memberTradeServiceApi;
@DubboReference
ICuMemberDetailServiceApi iCuMemberDetailServiceApi;
@DubboReference @DubboReference
IGradeServiceApi iGradeServiceApi; IGradeServiceApi iGradeServiceApi;
@DubboReference
IAwardsServiceApi iAwardsServiceApi;
@DubboReference
IAreaServiceApi iAreaServiceApi;
@DubboReference
IMemberBankServiceApi iMemberBankServiceApi;
@DubboReference
IMemberAccountServiceApi iMemberAccountServiceApi;
@DubboReference
IAreaCurrencyServiceApi iAreaCurrencyServiceApi;
@DubboReference
ICountryServiceApi iCountryServiceApi;
@DubboReference
ICurrencyServiceApi iCurrencyServiceApi;
@DubboReference
IApprovalServiceApi iApprovalServiceApi;
@DubboReference
IMemberAchieveServiceApi iMemberAchieveServiceApi;
@DubboReference
ISystemConfigServiceApi iSystemConfigServiceApi;
@DubboReference
ICuMemberServiceLogServiceApi iCuMemberServiceLogServiceApi;
@DubboReference
IMemberTradeServiceApi iMemberTradeServiceApi;
@DubboReference
ICuMemberDetailServiceApi iCuMemberDetailServiceApi;
@Autowired
private IBdWaresService waresService;
@Autowired
private IBdWaresExtendService waresExtendService;
@Autowired
private SaOrderHandle saOrderHandle;
@Autowired
private ISaOrderItemsService saOrderItemsService;
@Autowired @Autowired
private UserTokenService userTokenService; private UserTokenService userTokenService;
@Autowired @Autowired
private SaOrderHandle saOrderHandle;
@Autowired
private IBdWaresService iBdWaresService;
@Autowired
private IBdWaresExtendService iBdWaresExtendService;
@Autowired
private IBdProductExtendService iBdProductExtendService; private IBdProductExtendService iBdProductExtendService;
@Autowired @Autowired
private IBdWaresSpecsRelationService waresSpecsRelationService; private IBdWaresSpecsRelationService iBdWaresSpecsRelationService;
@Autowired @Autowired
private ISaDeliverItemsService saDeliverItemsService; private ISaOrderItemsService iSaOrderItemsService;
@Autowired
private IAcRetailPickService iAcRetailPickService;
@Autowired @Autowired
private ISaOrderWaresLimitService iSaOrderWaresLimitService; private ISaOrderWaresLimitService iSaOrderWaresLimitService;
@Autowired @Autowired
private IAcPickService iAcPickService; private ISaDeliverItemsService iSaDeliverItemsService;
@Autowired
private ISaOrderChargeLogService iSaOrderChargeLogService;
@Autowired @Autowired
private IOrderBusinessService iOrderBusinessService; private IOrderBusinessService iOrderBusinessService;
@Autowired @Autowired
private ISaOrderChargeLogService iSaOrderChargeLogService; private IAcPickService iAcPickService;
@Autowired
private IAcRetailPickService iAcRetailPickService;
@Autowired
private IAcPickMemberLogService iAcPickMemberLogService;
@Autowired @Autowired
private RedisService redisService; private RedisService redisService;
@Autowired @Autowired
@ -159,27 +162,27 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
@Override @Override
public List<CuMemberExt> queryMemberExtByCondition(CuMember cuMember) { public List<CuMemberExt> queryMemberExtByCondition(CuMember cuMember) {
return memberServiceApi.getMemberInfo(cuMember).getData(); return iMemberServiceApi.getMemberInfo(cuMember).getData();
} }
@Override @Override
public List<CuMemberExt> querySponsorOnUmbrella(Long placeParentId, String phone) { public List<CuMemberExt> querySponsorOnUmbrella(Long placeParentId, String phone) {
return memberServiceApi.querySponsorOnUmbrella(placeParentId, null, phone).getData(); return iMemberServiceApi.querySponsorOnUmbrella(placeParentId, null, phone).getData();
} }
@Override @Override
public List<CuMemberExt> selectPlaceSponsorUnderUmbrellaByCondition(Long memberId, List<CuMemberExt> cuMemberExtList) { public List<CuMemberExt> selectPlaceSponsorUnderUmbrellaByCondition(Long memberId, List<CuMemberExt> cuMemberExtList) {
return memberServiceApi.selectPlaceSponsorUnderUmbrellaByCondition(memberId, cuMemberExtList).getData(); return iMemberServiceApi.selectPlaceSponsorUnderUmbrellaByCondition(memberId, cuMemberExtList).getData();
} }
@Override @Override
public List<CuMemberExt> queryPlaceSponsorUnderUmbrella(Long memberId, String placeParent) { public List<CuMemberExt> queryPlaceSponsorUnderUmbrella(Long memberId, String placeParent) {
return memberServiceApi.queryPlaceSponsorUnderUmbrella(memberId, placeParent).getData(); return iMemberServiceApi.queryPlaceSponsorUnderUmbrella(memberId, placeParent).getData();
} }
@Override @Override
public CuMemberExt queryPlaceSponsorLastLeft(Long memberId, Integer placeDept) { public CuMemberExt queryPlaceSponsorLastLeft(Long memberId, Integer placeDept) {
return memberServiceApi.queryPlaceSponsorLastLeft(memberId, placeDept).getData(); return iMemberServiceApi.queryPlaceSponsorLastLeft(memberId, placeDept).getData();
} }
@Override @Override
@ -208,7 +211,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
if (CollectionUtil.isNotEmpty(itemIdList)) { if (CollectionUtil.isNotEmpty(itemIdList)) {
orderItemsQueryWrapper.in(SaOrderItems::getPkId, itemIdList); orderItemsQueryWrapper.in(SaOrderItems::getPkId, itemIdList);
} }
saOrderExt.setOrderItemsList(saOrderItemsService.list(orderItemsQueryWrapper)); saOrderExt.setOrderItemsList(iSaOrderItemsService.list(orderItemsQueryWrapper));
return saOrderExt; return saOrderExt;
} }
@ -243,7 +246,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
@Override @Override
public Integer queryCuMemberByPkMember(Long pkReference) { public Integer queryCuMemberByPkMember(Long pkReference) {
return memberServiceApi.queryCuMemberByPkMember(pkReference).getData(); return iMemberServiceApi.queryCuMemberByPkMember(pkReference).getData();
} }
@Override @Override
@ -258,12 +261,12 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
@Override @Override
public CuMember getCuMemberByKey(Long pkId) { public CuMember getCuMemberByKey(Long pkId) {
return memberServiceApi.getMemberById(pkId).getData(); return iMemberServiceApi.getMemberById(pkId).getData();
} }
@Override @Override
public CuMember getCuMemberByCode(String code) { public CuMember getCuMemberByCode(String code) {
return memberServiceApi.getMemberByCode(code).getData(); return iMemberServiceApi.getMemberByCode(code).getData();
} }
@Override @Override
@ -273,7 +276,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
@Override @Override
public List<CuMemberAccountExt> queryMemberAccountByCondition(CuMemberAccount cuMemberAccount) { public List<CuMemberAccountExt> queryMemberAccountByCondition(CuMemberAccount cuMemberAccount) {
return memberAccountServiceApi.queryMemberAccountByCondition(cuMemberAccount).getData(); return iMemberAccountServiceApi.queryMemberAccountByCondition(cuMemberAccount).getData();
} }
@Override @Override
@ -301,7 +304,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
cuMemberAccount.setMemberCode(creator.getMemberCode()); cuMemberAccount.setMemberCode(creator.getMemberCode());
// 查询专区所属币种 // 查询专区所属币种
List<AreaCurrencyDTO> areaCurrencyDTOList = areaCurrencyServiceApi.queryAreaCurrencyByCondition(saOrder.getOrderType(), cuMemberAccount.getPkCountry()).getData(); List<AreaCurrencyDTO> areaCurrencyDTOList = iAreaCurrencyServiceApi.queryAreaCurrencyByCondition(saOrder.getOrderType(), cuMemberAccount.getPkCountry()).getData();
BigDecimal postage = saOrder.getPostage(); BigDecimal postage = saOrder.getPostage();
@ -311,7 +314,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
if (saOrderItems.getPkSpecialCurrency() != null) { if (saOrderItems.getPkSpecialCurrency() != null) {
BigDecimal orderItemPayMoney = ComputeUtil.computeMultiply(saOrderItems.getPrice(), saOrderItems.getQuantity()); BigDecimal orderItemPayMoney = ComputeUtil.computeMultiply(saOrderItems.getPrice(), saOrderItems.getQuantity());
payMoney = ComputeUtil.computeSubtract(payMoney, orderItemPayMoney); payMoney = ComputeUtil.computeSubtract(payMoney, orderItemPayMoney);
List<AreaCurrencyDTO> areaCurrencyDtoList = areaCurrencyServiceApi.queryAreaCurrencyByCondition(saOrderItems.getPkSpecialCurrency()).getData(); List<AreaCurrencyDTO> areaCurrencyDtoList = iAreaCurrencyServiceApi.queryAreaCurrencyByCondition(saOrderItems.getPkSpecialCurrency()).getData();
if (!handleSaOrderAmount(saOrder, orderItemList, cuMemberAccount, orderItemPayMoney, BigDecimal.ZERO, areaCurrencyDtoList)) { if (!handleSaOrderAmount(saOrder, orderItemList, cuMemberAccount, orderItemPayMoney, BigDecimal.ZERO, areaCurrencyDtoList)) {
return null; return null;
} }
@ -348,7 +351,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
|| EOrderType.UPGRADE_ORDER.getValue() == saOrder.getOrderType()) { || EOrderType.UPGRADE_ORDER.getValue() == saOrder.getOrderType()) {
if (cuMemberAccount.getPayAccount3Flag()) { if (cuMemberAccount.getPayAccount3Flag()) {
// 验证是否有政策币权限 // 验证是否有政策币权限
List<CuMemberServiceLog> cuMemberServiceLogs = cuMemberServiceLogServiceApi.queryMaxCuMemberServiceLog(cuMemberAccount.getPkMember(), Collections.singletonList(EApprovalBusiness.POLICY_CURRENCY_YES_NO.getValue())); List<CuMemberServiceLog> cuMemberServiceLogs = iCuMemberServiceLogServiceApi.queryMaxCuMemberServiceLog(cuMemberAccount.getPkMember(), Collections.singletonList(EApprovalBusiness.POLICY_CURRENCY_YES_NO.getValue()));
if (CollectionUtil.isNotEmpty(cuMemberServiceLogs)) { if (CollectionUtil.isNotEmpty(cuMemberServiceLogs)) {
Map<Integer, CuMemberServiceLog> cuMemberServiceLogMap = new HashMap<>(ComputeUtil.mapInitCapacity(cuMemberServiceLogs.size())); Map<Integer, CuMemberServiceLog> cuMemberServiceLogMap = new HashMap<>(ComputeUtil.mapInitCapacity(cuMemberServiceLogs.size()));
cuMemberServiceLogs.forEach(serviceLog -> cuMemberServiceLogMap.put(serviceLog.getEditType(), serviceLog)); cuMemberServiceLogs.forEach(serviceLog -> cuMemberServiceLogMap.put(serviceLog.getEditType(), serviceLog));
@ -454,13 +457,13 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public Boolean confirmRegSaOrderByOrderParam(OrderParam orderParam) { public Boolean confirmRegSaOrderByOrderParam(OrderParam orderParam) {
boolean isToBePay = getIsToBePayByOrderType(orderParam.getPkSettleCountry(), orderParam.getSpecialArea()); boolean isToBePay = getIsToBePayByOrderType(orderParam.getPkSettleCountry(), orderParam.getSpecialArea());
CuMember cuMember = saOrderHandle.packageSaveUser(orderParam, memberServiceApi.queryMember(orderParam.getCenterCodeId()).getData()); CuMember cuMember = saOrderHandle.packageSaveUser(orderParam, iMemberServiceApi.queryMember(orderParam.getCenterCodeId()).getData());
// 获取会员编号、会员主键 // 获取会员编号、会员主键
if (isToBePay) { if (isToBePay) {
cuMember = memberServiceApi.createMemberIdAndCode(cuMember).getData(); cuMember = iMemberServiceApi.createMemberIdAndCode(cuMember).getData();
} else if (EOrderType.REGISTER_ORDER.getValue() == orderParam.getSpecialArea()) { } else if (EOrderType.REGISTER_ORDER.getValue() == orderParam.getSpecialArea()) {
// 2023.10.16按最新需求，注册订单需要在支付前需要显示会员编号 // 2023.10.16按最新需求，注册订单需要在支付前需要显示会员编号
cuMember = memberServiceApi.createRegisterMemberCode(cuMember).getData(); cuMember = iMemberServiceApi.createRegisterMemberCode(cuMember).getData();
} }
SaOrderExt saOrderExt = packageWholeSaOrder(orderParam, cuMember); SaOrderExt saOrderExt = packageWholeSaOrder(orderParam, cuMember);
@ -472,7 +475,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
if (isToBePay && !orderParam.getIsHaiFun()) { if (isToBePay && !orderParam.getIsHaiFun()) {
processOrder(saOrderExt); processOrder(saOrderExt);
// 调用其他服务保存会员信息、会员注册信息 // 调用其他服务保存会员信息、会员注册信息
R<Boolean> saveResult = memberServiceApi.saveMember(cuMember); R<Boolean> saveResult = iMemberServiceApi.saveMember(cuMember);
if (saveResult.isSuccess()) { if (saveResult.isSuccess()) {
if (!saveResult.getData()) { if (!saveResult.getData()) {
log.error("confirmRegSaOrderByOrderParam 保存会员失败."); log.error("confirmRegSaOrderByOrderParam 保存会员失败.");
@ -535,9 +538,9 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
orderParam.setPlaceParentId(placeMember.getPkId()); orderParam.setPlaceParentId(placeMember.getPkId());
} }
} }
CuMember cuMember = saOrderHandle.packageSaveUser(orderParam, memberServiceApi.queryMember(orderParam.getCenterCodeId()).getData()); CuMember cuMember = saOrderHandle.packageSaveUser(orderParam, iMemberServiceApi.queryMember(orderParam.getCenterCodeId()).getData());
// 获取会员编号、会员主键 // 获取会员编号、会员主键
cuMember = memberServiceApi.createMemberIdAndCode(cuMember).getData(); cuMember = iMemberServiceApi.createMemberIdAndCode(cuMember).getData();
return cuMember; return cuMember;
} }
@ -579,8 +582,8 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
cuMember.setPkSettleGradeValue(gradeDTO.getGradeValue()); cuMember.setPkSettleGradeValue(gradeDTO.getGradeValue());
// 判断奖衔，原会员有奖衔的话判断哪个大，使用大的 // 判断奖衔，原会员有奖衔的话判断哪个大，使用大的
if (pkAwards != null && gradeDTO.getGradeValue() != null) { if (pkAwards != null && gradeDTO.getGradeValue() != null) {
BdAwards bdAwards = awardsServiceApi.getAwardsOne(pkAwards).getData(); BdAwards bdAwards = iAwardsServiceApi.getAwardsOne(pkAwards).getData();
BdAwards newAwards = awardsServiceApi.getAwardsOne(gradeDTO.getPkAwards()).getData(); BdAwards newAwards = iAwardsServiceApi.getAwardsOne(gradeDTO.getPkAwards()).getData();
if (bdAwards.getAwardsValue() < newAwards.getAwardsValue()) { if (bdAwards.getAwardsValue() < newAwards.getAwardsValue()) {
cuMember.setPkAwards(gradeDTO.getPkAwards()); cuMember.setPkAwards(gradeDTO.getPkAwards());
} }
@ -621,7 +624,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
List<WaresNumberParam> waresNumberList = waresNumberParamList.stream().filter(DeduplicationUtil.distinctByKey(WaresNumberParam::getPkWares)).collect(Collectors.toList()); List<WaresNumberParam> waresNumberList = waresNumberParamList.stream().filter(DeduplicationUtil.distinctByKey(WaresNumberParam::getPkWares)).collect(Collectors.toList());
waresSalesAccrual(waresNumberList); waresSalesAccrual(waresNumberList);
// 保存订单明细 // 保存订单明细
saOrderItemsService.saveBatch(saOrderExt.getOrderItemsList()); iSaOrderItemsService.saveBatch(saOrderExt.getOrderItemsList());
} }
@Override @Override
@ -744,7 +747,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
newCuMember.setStopDate(DateUtils.addMonths(newCuMember.getExpireDate(), 6)); newCuMember.setStopDate(DateUtils.addMonths(newCuMember.getExpireDate(), 6));
// 调用其他服务保存会员信息、会员注册信息 // 调用其他服务保存会员信息、会员注册信息
R<Boolean> saveResult = memberServiceApi.saveMember(newCuMember, saOrderExt, isToBePay, cuMemberAccountExt); R<Boolean> saveResult = iMemberServiceApi.saveMember(newCuMember, saOrderExt, isToBePay, cuMemberAccountExt);
if (saveResult.isSuccess()) { if (saveResult.isSuccess()) {
if (!saveResult.getData()) { if (!saveResult.getData()) {
log.error("payRegSaOrder 保存会员失败!."); log.error("payRegSaOrder 保存会员失败!.");
@ -790,7 +793,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
redisService.lockKeyMany(CacheConstants.MEMBER_ORDER + saOrderExt.getOrderCode()); redisService.lockKeyMany(CacheConstants.MEMBER_ORDER + saOrderExt.getOrderCode());
try { try {
updateById(saOrderExt); updateById(saOrderExt);
saOrderItemsService.updateBatchById(saOrderExt.getOrderItemsList()); iSaOrderItemsService.updateBatchById(saOrderExt.getOrderItemsList());
} finally { } finally {
redisService.unlock(CacheConstants.MEMBER_ORDER + saOrderExt.getOrderCode()); redisService.unlock(CacheConstants.MEMBER_ORDER + saOrderExt.getOrderCode());
} }
@ -817,7 +820,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public Boolean payUpgradeSaOrder(SaOrderExt saOrderExt, CuMemberAccountExt cuMemberAccountExt) { public Boolean payUpgradeSaOrder(SaOrderExt saOrderExt, CuMemberAccountExt cuMemberAccountExt) {
CuMember cuMember = getCuMemberByKey(saOrderExt.getPkMember()); CuMember cuMember = getCuMemberByKey(saOrderExt.getPkMember());
GradeDTO oldGradeDTO = gradeServiceApi.getGrade(cuMember.getPkSettleGrade()).getData(); GradeDTO oldGradeDTO = iGradeServiceApi.getGrade(cuMember.getPkSettleGrade()).getData();
// 封装等级,重新计算会员等级 // 封装等级,重新计算会员等级
if (setLastCuMemberGrade(cuMember, saOrderExt)) { if (setLastCuMemberGrade(cuMember, saOrderExt)) {
return false; return false;
@ -833,7 +836,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
// 更新订单信息 // 更新订单信息
updateSaOrder(saOrderExt); updateSaOrder(saOrderExt);
// 处理会员信息，更新会员等级,扣款 // 处理会员信息，更新会员等级,扣款
R<Boolean> saveResult = memberServiceApi.saveMember(cuMember, saOrderExt, cuMemberAccountExt); R<Boolean> saveResult = iMemberServiceApi.saveMember(cuMember, saOrderExt, cuMemberAccountExt);
if (saveResult.isSuccess()) { if (saveResult.isSuccess()) {
if (!saveResult.getData()) { if (!saveResult.getData()) {
log.error("payUpgradeSaOrder 保存会员失败!!!"); log.error("payUpgradeSaOrder 保存会员失败!!!");
@ -907,7 +910,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
CuMember member = getCuMemberByKey(saOrderExt.getPkMember()); CuMember member = getCuMemberByKey(saOrderExt.getPkMember());
CuMember cuMember = calculateHaFunMemberGrade(saOrderExt, member); CuMember cuMember = calculateHaFunMemberGrade(saOrderExt, member);
R<Boolean> saveResult = memberServiceApi.saveMember(cuMember, saOrderExt, cuMemberAccountExt); R<Boolean> saveResult = iMemberServiceApi.saveMember(cuMember, saOrderExt, cuMemberAccountExt);
if (saveResult.isSuccess()) { if (saveResult.isSuccess()) {
if (!saveResult.getData()) { if (!saveResult.getData()) {
log.error("payRepurchaseSaOrder 保存订单失败!"); log.error("payRepurchaseSaOrder 保存订单失败!");
@ -959,7 +962,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
if (productIdList.size() > 0 && saOrderExt.getRecProvince() != null) { if (productIdList.size() > 0 && saOrderExt.getRecProvince() != null) {
// 根据产品，先查看是否由仓库，有仓库的话修改仓库 // 根据产品，先查看是否由仓库，有仓库的话修改仓库
List<BdProductStorehouseExt> bdProductStorehouseList = areaServiceApi.queryBdProductStorehouseByCondition(productIdList, saOrderExt.getRecProvince()).getData(); List<BdProductStorehouseExt> bdProductStorehouseList = iAreaServiceApi.queryBdProductStorehouseByCondition(productIdList, saOrderExt.getRecProvince()).getData();
Map<Integer, BdProductStorehouseExt> bdProductStorehouseMap = new HashMap<>(); Map<Integer, BdProductStorehouseExt> bdProductStorehouseMap = new HashMap<>();
if (CollectionUtil.isNotEmpty(bdProductStorehouseList)) { if (CollectionUtil.isNotEmpty(bdProductStorehouseList)) {
bdProductStorehouseList.forEach(bdProductStorehouse -> bdProductStorehouseMap.put(bdProductStorehouse.getPkProduct(), bdProductStorehouse)); bdProductStorehouseList.forEach(bdProductStorehouse -> bdProductStorehouseMap.put(bdProductStorehouse.getPkProduct(), bdProductStorehouse));
@ -997,7 +1000,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
if (orderParam.getIsEnough() != null && orderParam.getIsEnough()) { if (orderParam.getIsEnough() != null && orderParam.getIsEnough()) {
orderReturn.setIsEnough(Boolean.TRUE); orderReturn.setIsEnough(Boolean.TRUE);
CuMember member = getCuMemberByKey(orderParam.getCenterCodeId()); CuMember member = getCuMemberByKey(orderParam.getCenterCodeId());
GradeDTO grade = gradeServiceApi.getGrade(member.getPkSettleGrade()).getData(); GradeDTO grade = iGradeServiceApi.getGrade(member.getPkSettleGrade()).getData();
orderReturn.setPkGrade(grade.getPkTransaction()); orderReturn.setPkGrade(grade.getPkTransaction());
return orderReturn; return orderReturn;
} }
@ -1009,7 +1012,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
} else { } else {
member = getCuMemberByKey(orderParam.getCenterCodeId()); member = getCuMemberByKey(orderParam.getCenterCodeId());
} }
GradeDTO grade = gradeServiceApi.getGrade(member.getPkSettleGrade()).getData(); GradeDTO grade = iGradeServiceApi.getGrade(member.getPkSettleGrade()).getData();
if (grade.getGradeValue() < gradeDTO.getGradeValue()) { if (grade.getGradeValue() < gradeDTO.getGradeValue()) {
orderReturn.setIsEnough(Boolean.TRUE); orderReturn.setIsEnough(Boolean.TRUE);
} else { } else {
@ -1069,12 +1072,12 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
|| orderBlankRegParams.getProcessType() == EProcessType.DOUBLEAVOID.getValue()) { || orderBlankRegParams.getProcessType() == EProcessType.DOUBLEAVOID.getValue()) {
//添加修改记录表数据 //添加修改记录表数据
memberLog.setApproveStatus(EApproveStatus.FINISH.getValue()); memberLog.setApproveStatus(EApproveStatus.FINISH.getValue());
cuMemberServiceLogServiceApi.insert(memberLog); iCuMemberServiceLogServiceApi.insert(memberLog);
// 主要业务 // 主要业务
//创建用户 //创建用户
CuMemberExt memberExt = createMember(orderBlankRegParams); CuMemberExt memberExt = createMember(orderBlankRegParams);
R<CuMember> member = memberServiceApi.createEmptyOrderMember(memberExt); R<CuMember> member = iMemberServiceApi.createEmptyOrderMember(memberExt);
if (member.getData() == null) { if (member.getData() == null) {
throw new ServiceException("保存会员失败"); throw new ServiceException("保存会员失败");
} }
@ -1090,12 +1093,12 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
Set<Long> memberSet = new HashSet<>(); Set<Long> memberSet = new HashSet<>();
memberSet.add(loginUser.getUserId()); memberSet.add(loginUser.getUserId());
memberLog.setApproveStatus(EApproveStatus.ALREADY_SUBMIT.getValue()); memberLog.setApproveStatus(EApproveStatus.ALREADY_SUBMIT.getValue());
cuMemberServiceLogServiceApi.insert(memberLog); iCuMemberServiceLogServiceApi.insert(memberLog);
ApprovalSubmitDTO approvalSubmitDTO = ApprovalSubmitDTO.builder().eApprovalBusiness(EApprovalBusiness.EMPTY_ORDER) ApprovalSubmitDTO approvalSubmitDTO = ApprovalSubmitDTO.builder().eApprovalBusiness(EApprovalBusiness.EMPTY_ORDER)
.businessCode(code) .businessCode(code)
.signType(ESignType.getEnumByValue(orderBlankRegParams.getSignType())) .signType(ESignType.getEnumByValue(orderBlankRegParams.getSignType()))
.remark(orderBlankRegParams.getRemark()).pkMemberList(memberSet).build(); .remark(orderBlankRegParams.getRemark()).pkMemberList(memberSet).build();
R<String> submit = approvalServiceApi.submit(approvalSubmitDTO, loginUser); R<String> submit = iApprovalServiceApi.submit(approvalSubmitDTO, loginUser);
if (!submit.isSuccess()) { if (!submit.isSuccess()) {
log.error("====" + submit.getData()); log.error("====" + submit.getData());
throw new ServiceException(TransactionUtils.getContent(ConfigMsgConstants.MEMBER_UPDATE_PETITION)); throw new ServiceException(TransactionUtils.getContent(ConfigMsgConstants.MEMBER_UPDATE_PETITION));
@ -1108,7 +1111,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
businessCommissionDTO.setPkCountry(pkCountry); businessCommissionDTO.setPkCountry(pkCountry);
businessCommissionDTO.setMemberAmountDTOList(orderBlankRegParams.getMemberAmountDTOList()); businessCommissionDTO.setMemberAmountDTOList(orderBlankRegParams.getMemberAmountDTOList());
businessCommissionDTO.setTradeType(EApprovalBusiness.EMPTY_ORDER.getValue()); businessCommissionDTO.setTradeType(EApprovalBusiness.EMPTY_ORDER.getValue());
R<Boolean> b = memberTradeServiceApi.businessCommissionSubmit(businessCommissionDTO); R<Boolean> b = iMemberTradeServiceApi.businessCommissionSubmit(businessCommissionDTO);
if (!b.getData()) { if (!b.getData()) {
throw new ServiceException(TransactionUtils.getContent(ConfigMsgConstants.MEMBER_UPDATE_CODE_MONEY)); throw new ServiceException(TransactionUtils.getContent(ConfigMsgConstants.MEMBER_UPDATE_CODE_MONEY));
} }
@ -1128,7 +1131,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
saOrder.setOrderCode(orderCode); saOrder.setOrderCode(orderCode);
// 虚拟订单 // 虚拟订单
saOrder.setOrderType(EOrderType.FICTITIOUS_ORDER.getValue()); saOrder.setOrderType(EOrderType.FICTITIOUS_ORDER.getValue());
R<CurrencyDTO> currency = currencyServiceApi.getCurrency(orderBlankRegParams.getPkSettleCountry()); R<CurrencyDTO> currency = iCurrencyServiceApi.getCurrency(orderBlankRegParams.getPkSettleCountry());
saOrder.setPkRate(currency.getData().getPkId()); saOrder.setPkRate(currency.getData().getPkId());
saOrder.setOrderAmount(orderBlankRegParams.getRegisterPrice()); saOrder.setOrderAmount(orderBlankRegParams.getRegisterPrice());
saOrder.setOrderAchieve(orderBlankRegParams.getRegisterPv()); saOrder.setOrderAchieve(orderBlankRegParams.getRegisterPv());
@ -1160,7 +1163,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
List<SaOrderItems> orderItems = orderBlankRegParams.getOrderItems(); List<SaOrderItems> orderItems = orderBlankRegParams.getOrderItems();
for (SaOrderItems orderItem : orderItems) { for (SaOrderItems orderItem : orderItems) {
orderItem.setPkOrder(saOrder.getPkId()); orderItem.setPkOrder(saOrder.getPkId());
BdWares wares = waresService.getWares(orderItem.getPkWares()); BdWares wares = iBdWaresService.getWares(orderItem.getPkWares());
BdProductExtendExt productExtend = iBdProductExtendService.queryExtendAndProduct(orderItem.getPkProduct()); BdProductExtendExt productExtend = iBdProductExtendService.queryExtendAndProduct(orderItem.getPkProduct());
orderItem.setPkWares(wares.getPkId()); orderItem.setPkWares(wares.getPkId());
orderItem.setPrice(wares.getWaresPrice().multiply(new BigDecimal(orderItem.getQuantity()))); orderItem.setPrice(wares.getWaresPrice().multiply(new BigDecimal(orderItem.getQuantity())));
@ -1172,7 +1175,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
orderItem.setOrderStatus(EOrderStatus.PAY.getValue()); orderItem.setOrderStatus(EOrderStatus.PAY.getValue());
orderItem.setCreationTime(DateUtils.currentDateTime()); orderItem.setCreationTime(DateUtils.currentDateTime());
// 填充冗余产品规格 // 填充冗余产品规格
List<BdWaresSpecsRelationExt> waresSpecsRelationList = waresSpecsRelationService.selectByWaresSpecsSku(orderItem.getPkWaresSpecsSku()); List<BdWaresSpecsRelationExt> waresSpecsRelationList = iBdWaresSpecsRelationService.selectByWaresSpecsSku(orderItem.getPkWaresSpecsSku());
// 规格名称 // 规格名称
List<String> specsNames = new ArrayList<>(); List<String> specsNames = new ArrayList<>();
// 规格id // 规格id
@ -1187,7 +1190,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
orderItem.setPkCreator(SecurityUtils.getUserId()); orderItem.setPkCreator(SecurityUtils.getUserId());
orderItem.setSkuCode(CommonUtil.createSkuCode(productExtend.getProductCode(), orderItem.getSpecsNameId())); orderItem.setSkuCode(CommonUtil.createSkuCode(productExtend.getProductCode(), orderItem.getSpecsNameId()));
} }
saOrderItemsService.saveBatch(orderItems); iSaOrderItemsService.saveBatch(orderItems);
// 设置用户银行卡信息 国内页面隐藏 // 设置用户银行卡信息 国内页面隐藏
if (loginUser.getDataCountry() != 1) { if (loginUser.getDataCountry() != 1) {
CuMemberBankParam memberBank = new CuMemberBankParam(); CuMemberBankParam memberBank = new CuMemberBankParam();
@ -1200,7 +1203,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
memberBank.setPhone(orderBlankRegParams.getReservedPhone()); memberBank.setPhone(orderBlankRegParams.getReservedPhone());
memberBank.setIdCard(orderBlankRegParams.getIdCard()); memberBank.setIdCard(orderBlankRegParams.getIdCard());
memberBank.setPkMember(member.getPkId()); memberBank.setPkMember(member.getPkId());
memberBankServiceApi.addBankInfo(memberBank); iMemberBankServiceApi.addBankInfo(memberBank);
} }
return saOrder; return saOrder;
} }
@ -1324,13 +1327,13 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
// // 修改订单 // // 修改订单
// Date currentDateTime = DateUtils.currentDateTime(); // Date currentDateTime = DateUtils.currentDateTime();
// // 删除发货单 // // 删除发货单
// saDeliverItemsService.deleteSaDeliverItems(saOrderExt.getPkId(), pkOrderItemList); // iSaDeliverItemsService.deleteSaDeliverItems(saOrderExt.getPkId(), pkOrderItemList);
// updateSaOrder(pkApprove, saOrderExt, currentDateTime); // updateSaOrder(pkApprove, saOrderExt, currentDateTime);
// // 删除订单明细 // // 删除订单明细
// if (!saOrderItemsService.updateOrderItemsById(pkOrderItemList, pkApprove, currentDateTime)) { // if (!iSaOrderItemsService.updateOrderItemsById(pkOrderItemList, pkApprove, currentDateTime)) {
// throw new ServiceException("更新订单失败"); // throw new ServiceException("更新订单失败");
// } // }
// if (!memberServiceApi.normalRevokeOrder(pkApprove, saOrderExt, null, businessCommissionDTO).getData()) { // if (!iMemberServiceApi.normalRevokeOrder(pkApprove, saOrderExt, null, businessCommissionDTO).getData()) {
// throw new ServiceException("撤单失败"); // throw new ServiceException("撤单失败");
// } // }
// } else { // } else {
@ -1338,11 +1341,11 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
saOrderExt.setDelFlag(EDelFlag.DELETE.getValue()); saOrderExt.setDelFlag(EDelFlag.DELETE.getValue());
Date currentDate = DateUtils.currentDateTime(); Date currentDate = DateUtils.currentDateTime();
// 删除发货单 // 删除发货单
saDeliverItemsService.deleteSaDeliverItems(saOrderExt.getPkId(), null); iSaDeliverItemsService.deleteSaDeliverItems(saOrderExt.getPkId(), null);
// 修改订单 // 修改订单
updateSaOrder(pkApprove, saOrderExt, currentDate); updateSaOrder(pkApprove, saOrderExt, currentDate);
// 删除订单明细 // 删除订单明细
if (!saOrderItemsService.updateOrderItems(saOrderExt)) { if (!iSaOrderItemsService.updateOrderItems(saOrderExt)) {
throw new ServiceException("更新订单失败"); throw new ServiceException("更新订单失败");
} }
@ -1352,7 +1355,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
// 撤销注册订单 单点撤单 // 撤销注册订单 单点撤单
if (ECancelOrderType.SINGLE_CANCEL_ORDER.getValue() == orderCancelParam.getCancelType()) { if (ECancelOrderType.SINGLE_CANCEL_ORDER.getValue() == orderCancelParam.getCancelType()) {
// 单点撤单，变死点 // 单点撤单，变死点
R<Boolean> tmpR = memberServiceApi.singleRevokeMemberByRegisterOrder(pkApprove, saOrderExt, businessCommissionDTO); R<Boolean> tmpR = iMemberServiceApi.singleRevokeMemberByRegisterOrder(pkApprove, saOrderExt, businessCommissionDTO);
if (!tmpR.isSuccess()) { if (!tmpR.isSuccess()) {
throw new ServiceException("撤单失败 " + tmpR.getMsg()); throw new ServiceException("撤单失败 " + tmpR.getMsg());
} }
@ -1361,12 +1364,12 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
List<Long> memberList = validateCancelOrderVO.getMemberList().stream().map(OrderCancelRegisterMemberVO::getPkMember).collect(Collectors.toList()); List<Long> memberList = validateCancelOrderVO.getMemberList().stream().map(OrderCancelRegisterMemberVO::getPkMember).collect(Collectors.toList());
if (CollectionUtil.isNotEmpty(memberList)) { if (CollectionUtil.isNotEmpty(memberList)) {
// 撤销所有订单明细表 // 撤销所有订单明细表
saOrderItemsService.updateOrderItemsByMemberList(memberList, pkApprove, currentDate); iSaOrderItemsService.updateOrderItemsByMemberList(memberList, pkApprove, currentDate);
// 撤销所有订单主表 // 撤销所有订单主表
baseMapper.updateSaOrderByMember(memberList, pkApprove, currentDate); baseMapper.updateSaOrderByMember(memberList, pkApprove, currentDate);
} }
R<Boolean> tmpR = memberServiceApi.mergeRevokeMemberByRegisterOrder(pkApprove, memberList, validateCancelOrderVO.getSaOrderMap(), businessCommissionDTO); R<Boolean> tmpR = iMemberServiceApi.mergeRevokeMemberByRegisterOrder(pkApprove, memberList, validateCancelOrderVO.getSaOrderMap(), businessCommissionDTO);
if (!tmpR.isSuccess()) { if (!tmpR.isSuccess()) {
throw new ServiceException("撤单失败 " + tmpR.getMsg()); throw new ServiceException("撤单失败 " + tmpR.getMsg());
} }
@ -1426,7 +1429,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
if (isFirst == null) { if (isFirst == null) {
isFirst = validateFirstOrder(cuMember.getPkParent(), cuMember.getPkSettleCountry()); isFirst = validateFirstOrder(cuMember.getPkParent(), cuMember.getPkSettleCountry());
} }
cuMember = memberAchieveServiceApi.queryCuMemberAchieveByPkMember(cuMember, isFirst, isFirstAchieve).getData(); cuMember = iMemberAchieveServiceApi.queryCuMemberAchieveByPkMember(cuMember, isFirst, isFirstAchieve).getData();
// 验证是否推荐过人，没有推荐只能放入极左极下 // 验证是否推荐过人，没有推荐只能放入极左极下
return cuMember; return cuMember;
} }
@ -1475,7 +1478,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
@Override @Override
public String querySystemConfigByKey(Integer pkCountry, String key) { public String querySystemConfigByKey(Integer pkCountry, String key) {
return systemConfigServiceApi.getBonusSystemConfig(pkCountry, key).getData(); return iSystemConfigServiceApi.getBonusSystemConfig(pkCountry, key).getData();
} }
@Override @Override
@ -1547,7 +1550,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
updateWrapper.set(SaOrderItems::getOrderStatus, EOrderStatus.RECEIVED.getValue()); updateWrapper.set(SaOrderItems::getOrderStatus, EOrderStatus.RECEIVED.getValue());
updateWrapper.set(SaOrderItems::getPkModified, memberId); updateWrapper.set(SaOrderItems::getPkModified, memberId);
updateWrapper.set(SaOrderItems::getModifiedTime, new Date()); updateWrapper.set(SaOrderItems::getModifiedTime, new Date());
return saOrderItemsService.update(updateWrapper); return iSaOrderItemsService.update(updateWrapper);
} }
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
@ -1558,7 +1561,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
// 如果是注册订单，需要校验下面是否有会员 // 如果是注册订单，需要校验下面是否有会员
if (EOrderType.REGISTER_ORDER.getValue() == saOrder.getOrderType()) { if (EOrderType.REGISTER_ORDER.getValue() == saOrder.getOrderType()) {
// 注册类订单，需要校验是否推荐过人或者安置过人，如果有则不允许进行取消 // 注册类订单，需要校验是否推荐过人或者安置过人，如果有则不允许进行取消
if (memberServiceApi.checkLowerMember(saOrder.getPkMember()).getData()) { if (iMemberServiceApi.checkLowerMember(saOrder.getPkMember()).getData()) {
// 订单所属会员下存在用户不能取消 // 订单所属会员下存在用户不能取消
return TransactionUtils.getContent(MemberMsgConstants.EXIST_MEMBER_NOT_CANCEL); return TransactionUtils.getContent(MemberMsgConstants.EXIST_MEMBER_NOT_CANCEL);
} }
@ -1572,7 +1575,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
updateItemsWrapper.set(SaOrderItems::getDelFlag, EDelFlag.DELETE.getValue()); updateItemsWrapper.set(SaOrderItems::getDelFlag, EDelFlag.DELETE.getValue());
updateItemsWrapper.set(SaOrderItems::getPkModified, memberId); updateItemsWrapper.set(SaOrderItems::getPkModified, memberId);
updateItemsWrapper.set(SaOrderItems::getModifiedTime, nowDate); updateItemsWrapper.set(SaOrderItems::getModifiedTime, nowDate);
saOrderItemsService.update(updateItemsWrapper); iSaOrderItemsService.update(updateItemsWrapper);
// 删除订单 // 删除订单
LambdaUpdateWrapper<SaOrder> updateOrderWrapper = new LambdaUpdateWrapper<>(); LambdaUpdateWrapper<SaOrder> updateOrderWrapper = new LambdaUpdateWrapper<>();
@ -1584,7 +1587,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
// 如果是注册订单，需要取消点位 // 如果是注册订单，需要取消点位
if (EOrderType.REGISTER_ORDER.getValue() == saOrder.getOrderType()) { if (EOrderType.REGISTER_ORDER.getValue() == saOrder.getOrderType()) {
if (!memberServiceApi.cancelMember(saOrder.getPkMember()).getData()) { if (!iMemberServiceApi.cancelMember(saOrder.getPkMember()).getData()) {
throw new ServiceException("取消订单失败"); throw new ServiceException("取消订单失败");
} }
} }
@ -1621,7 +1624,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
orderItemsUpdateWrapper.set(SaOrderItems::getDelFlag, EDelFlag.DELETE.getValue()); orderItemsUpdateWrapper.set(SaOrderItems::getDelFlag, EDelFlag.DELETE.getValue());
orderItemsUpdateWrapper.set(SaOrderItems::getPkModified, userId); orderItemsUpdateWrapper.set(SaOrderItems::getPkModified, userId);
orderItemsUpdateWrapper.set(SaOrderItems::getModifiedTime, nowDate); orderItemsUpdateWrapper.set(SaOrderItems::getModifiedTime, nowDate);
saOrderItemsService.update(orderItemsUpdateWrapper); iSaOrderItemsService.update(orderItemsUpdateWrapper);
} }
@Override @Override
@ -1661,7 +1664,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
@Override @Override
public Boolean regEmptyOrderApproved(ApprovalBusinessResultDTO approvalBusinessResultDTO) { public Boolean regEmptyOrderApproved(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
R<CuMemberServiceLog> cuMemberServiceLogR = cuMemberServiceLogServiceApi.selectByBusinessNo(approvalBusinessResultDTO.getBusinessCode()); R<CuMemberServiceLog> cuMemberServiceLogR = iCuMemberServiceLogServiceApi.selectByBusinessNo(approvalBusinessResultDTO.getBusinessCode());
OrderBlankRegParams orderBlankRegParams = JSONUtil.toBean(cuMemberServiceLogR.getData().getNewValue(), OrderBlankRegParams.class); OrderBlankRegParams orderBlankRegParams = JSONUtil.toBean(cuMemberServiceLogR.getData().getNewValue(), OrderBlankRegParams.class);
// 调用空单注册方法 // 调用空单注册方法
this.registerEmptyOrder(orderBlankRegParams); this.registerEmptyOrder(orderBlankRegParams);
@ -1670,14 +1673,14 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
@Override @Override
public Boolean regEmptyOrderReject(ApprovalBusinessResultDTO approvalBusinessResultDTO) { public Boolean regEmptyOrderReject(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
R<CuMemberServiceLog> cuMemberServiceLogR = cuMemberServiceLogServiceApi.selectByBusinessNo(approvalBusinessResultDTO.getBusinessCode()); R<CuMemberServiceLog> cuMemberServiceLogR = iCuMemberServiceLogServiceApi.selectByBusinessNo(approvalBusinessResultDTO.getBusinessCode());
OrderBlankRegParams orderBlankRegParams = JSONUtil.toBean(cuMemberServiceLogR.getData().getNewValue(), OrderBlankRegParams.class); OrderBlankRegParams orderBlankRegParams = JSONUtil.toBean(cuMemberServiceLogR.getData().getNewValue(), OrderBlankRegParams.class);
CuMemberServiceLog memberLog = new CuMemberServiceLog(); CuMemberServiceLog memberLog = new CuMemberServiceLog();
memberLog.setBusinessNo(approvalBusinessResultDTO.getBusinessCode()); memberLog.setBusinessNo(approvalBusinessResultDTO.getBusinessCode());
memberLog.setPkModified(approvalBusinessResultDTO.getLoginUser().getUserId()); memberLog.setPkModified(approvalBusinessResultDTO.getLoginUser().getUserId());
memberLog.setModifiedTime(DateUtils.currentDateTime()); memberLog.setModifiedTime(DateUtils.currentDateTime());
memberLog.setApproveStatus(EApproveStatus.REJECTED.getValue()); memberLog.setApproveStatus(EApproveStatus.REJECTED.getValue());
cuMemberServiceLogServiceApi.updateByBusinessNo(memberLog); iCuMemberServiceLogServiceApi.updateByBusinessNo(memberLog);
List<MemberAmountDTO> memberAmountDTOList = new ArrayList<>(); List<MemberAmountDTO> memberAmountDTOList = new ArrayList<>();
MemberAmountDTO memberAmountDTO = new MemberAmountDTO(); MemberAmountDTO memberAmountDTO = new MemberAmountDTO();
memberAmountDTO.setPkMember(approvalBusinessResultDTO.getLoginUser().getUserId()); memberAmountDTO.setPkMember(approvalBusinessResultDTO.getLoginUser().getUserId());
@ -1692,7 +1695,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
businessCommissionDTO.setPkCountry(orderBlankRegParams.getPkCountry()); businessCommissionDTO.setPkCountry(orderBlankRegParams.getPkCountry());
businessCommissionDTO.setMemberAmountDTOList(memberAmountDTOList); businessCommissionDTO.setMemberAmountDTOList(memberAmountDTOList);
businessCommissionDTO.setTradeType(EApprovalBusiness.UPDATE_SETTLE_COUNTRY.getValue()); businessCommissionDTO.setTradeType(EApprovalBusiness.UPDATE_SETTLE_COUNTRY.getValue());
R<Boolean> b = memberTradeServiceApi.businessCommissionSubmit(businessCommissionDTO); R<Boolean> b = iMemberTradeServiceApi.businessCommissionSubmit(businessCommissionDTO);
if (!b.getData()) { if (!b.getData()) {
throw new ServiceException(ConfigMsgConstants.MEMBER_UPDATE_CODE_MONEY); throw new ServiceException(ConfigMsgConstants.MEMBER_UPDATE_CODE_MONEY);
} }
@ -1701,9 +1704,9 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
@Override @Override
public void closeOrder() { public void closeOrder() {
R<Map<String, String>> configMap = systemConfigServiceApi.getSystemConfig(); R<Map<String, String>> configMap = iSystemConfigServiceApi.getSystemConfig();
Map<String, String> configDate = configMap.getData(); Map<String, String> configDate = configMap.getData();
R<Map<Integer, BdCountry>> all = countryServiceApi.getAllCountryMap(); R<Map<Integer, BdCountry>> all = iCountryServiceApi.getAllCountryMap();
Set<Map.Entry<Integer, BdCountry>> entries = all.getData().entrySet(); Set<Map.Entry<Integer, BdCountry>> entries = all.getData().entrySet();
for (Map.Entry<Integer, BdCountry> entry : entries) { for (Map.Entry<Integer, BdCountry> entry : entries) {
@ -1727,7 +1730,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
ESpecialAreaTime specialAreaTime = ESpecialAreaTime.getSpecialAreaTime(date); ESpecialAreaTime specialAreaTime = ESpecialAreaTime.getSpecialAreaTime(date);
if (orderType != null && specialAreaTime != null) { if (orderType != null && specialAreaTime != null) {
if (baseMapper.closeOrder(country.getPkId(), specialAreaTime.getAttributeValue(), orderType) > 0) { if (baseMapper.closeOrder(country.getPkId(), specialAreaTime.getAttributeValue(), orderType) > 0) {
saOrderItemsService.closeOrder(country.getPkId(), specialAreaTime.getAttributeValue(), orderType); iSaOrderItemsService.closeOrder(country.getPkId(), specialAreaTime.getAttributeValue(), orderType);
} }
} }
} }
@ -1756,7 +1759,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
@Override @Override
public void waresSalesAccrual(List<WaresNumberParam> waresNumberParamList) { public void waresSalesAccrual(List<WaresNumberParam> waresNumberParamList) {
try { try {
waresExtendService.updateWaresSalesAccrual(waresNumberParamList); iBdWaresExtendService.updateWaresSalesAccrual(waresNumberParamList);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
@ -1772,7 +1775,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
public int insertBach(List<SaOrder> orderList, List<SaOrderItems> orderItemsList) { public int insertBach(List<SaOrder> orderList, List<SaOrderItems> orderItemsList) {
int i = baseMapper.insertBach(orderList); int i = baseMapper.insertBach(orderList);
if (i > 0 && CollectionUtil.isNotEmpty(orderItemsList)) { if (i > 0 && CollectionUtil.isNotEmpty(orderItemsList)) {
saOrderItemsService.insertBach(orderItemsList); iSaOrderItemsService.insertBach(orderItemsList);
} }
return i; return i;
} }
@ -1784,7 +1787,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
for (SaOrderItems saOrderItems : saOrderExt.getOrderItemsList()) { for (SaOrderItems saOrderItems : saOrderExt.getOrderItemsList()) {
saOrderItems.setPkOrder(saOrderExt.getPkId()); saOrderItems.setPkOrder(saOrderExt.getPkId());
} }
saOrderItemsService.saveBatch(saOrderExt.getOrderItemsList()); iSaOrderItemsService.saveBatch(saOrderExt.getOrderItemsList());
} }
@Override @Override
@ -1802,11 +1805,11 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
saOrderExt.setDelFlag(EDelFlag.DELETE.getValue()); saOrderExt.setDelFlag(EDelFlag.DELETE.getValue());
Date currentDate = DateUtils.currentDateTime(); Date currentDate = DateUtils.currentDateTime();
// 删除发货单 // 删除发货单
saDeliverItemsService.deleteSaDeliverItems(saOrderExt.getPkId(), null); iSaDeliverItemsService.deleteSaDeliverItems(saOrderExt.getPkId(), null);
// 修改订单 // 修改订单
updateSaOrder(pkApprove, saOrderExt, currentDate); updateSaOrder(pkApprove, saOrderExt, currentDate);
// 删除订单明细 // 删除订单明细
if (!saOrderItemsService.updateOrderItems(saOrderExt)) { if (!iSaOrderItemsService.updateOrderItems(saOrderExt)) {
throw new ServiceException("更新订单失败"); throw new ServiceException("更新订单失败");
} }
@ -1828,7 +1831,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
// 撤销注册订单 // 撤销注册订单
if (myOrderVO.getOrderType() == EOrderType.RETAIL_REGISTER.getValue()) { if (myOrderVO.getOrderType() == EOrderType.RETAIL_REGISTER.getValue()) {
// 逻辑删除会员 // 逻辑删除会员
if (!memberServiceApi.singleRevokeMemberBySelfRevokeOrder(pkApprove, saOrderExt, businessCommissionDTO).getData()) { if (!iMemberServiceApi.singleRevokeMemberBySelfRevokeOrder(pkApprove, saOrderExt, businessCommissionDTO).getData()) {
throw new ServiceException("撤单失败"); throw new ServiceException("撤单失败");
} }
} else { } else {
@ -1877,15 +1880,21 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
// 订单邮费 // 订单邮费
BigDecimal postage = saOrder.getPostage(); BigDecimal postage = saOrder.getPostage();
if (payMoney.add(postage).compareTo(BigDecimal.ZERO) == 0) {
// 订单金额 + 邮费 = 0，直接返回跑
cuMemberAccount.setIsPayment(Boolean.TRUE);
return cuMemberAccount;
}
// 订单创建人 // 订单创建人
CuMember creator = getCuMemberByKey(saOrder.getPkCreator()); CuMember creator = getCuMemberByKey(saOrder.getPkCreator());
cuMemberAccount.setMemberCode(creator.getMemberCode()); cuMemberAccount.setMemberCode(creator.getMemberCode());
// 查询专区所属币种 // 查询专区所属币种
List<AreaCurrencyDTO> areaCurrencyDTOList = areaCurrencyServiceApi.queryAreaCurrencyByCondition(ESpecialArea.getRetailSpecialAreaValue(saOrder.getOrderType()), cuMemberAccount.getPkCountry()).getData(); List<AreaCurrencyDTO> areaCurrencyDTOList = iAreaCurrencyServiceApi.queryAreaCurrencyByCondition(ESpecialArea.getRetailSpecialAreaValue(saOrder.getOrderType()), cuMemberAccount.getPkCountry()).getData();
// 验证会员是否存在特殊消费配置 // 验证会员是否存在特殊消费配置
List<AreaCurrencyDTO> memberCurrencyDTOList = areaCurrencyServiceApi.queryMemberCurrency(ESpecialArea.getRetailSpecialAreaValue(saOrder.getOrderType()), cuMemberAccount.getPkMember()).getData(); List<AreaCurrencyDTO> memberCurrencyDTOList = iAreaCurrencyServiceApi.queryMemberCurrency(ESpecialArea.getRetailSpecialAreaValue(saOrder.getOrderType()), cuMemberAccount.getPkMember()).getData();
if (CollectionUtil.isNotEmpty(memberCurrencyDTOList)) { if (CollectionUtil.isNotEmpty(memberCurrencyDTOList)) {
areaCurrencyDTOList = memberCurrencyDTOList; areaCurrencyDTOList = memberCurrencyDTOList;
} else { } else {
@ -1895,7 +1904,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
if (saOrderItems.getPkSpecialCurrency() != null) { if (saOrderItems.getPkSpecialCurrency() != null) {
BigDecimal orderItemPayMoney = ComputeUtil.computeMultiply(saOrderItems.getPrice(), saOrderItems.getQuantity()); BigDecimal orderItemPayMoney = ComputeUtil.computeMultiply(saOrderItems.getPrice(), saOrderItems.getQuantity());
payMoney = ComputeUtil.computeSubtract(payMoney, orderItemPayMoney); payMoney = ComputeUtil.computeSubtract(payMoney, orderItemPayMoney);
List<AreaCurrencyDTO> areaCurrencyDtoList = areaCurrencyServiceApi.queryAreaCurrencyByCondition(saOrderItems.getPkSpecialCurrency()).getData(); List<AreaCurrencyDTO> areaCurrencyDtoList = iAreaCurrencyServiceApi.queryAreaCurrencyByCondition(saOrderItems.getPkSpecialCurrency()).getData();
if (!handleRetailSaOrderAmount(saOrder, cuMemberAccount, orderItemPayMoney, BigDecimal.ZERO, areaCurrencyDtoList)) { if (!handleRetailSaOrderAmount(saOrder, cuMemberAccount, orderItemPayMoney, BigDecimal.ZERO, areaCurrencyDtoList)) {
return null; return null;
@ -1943,7 +1952,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
|| EOrderType.RETAIL_UPGRADE.getValue() == saOrder.getOrderType()) { || EOrderType.RETAIL_UPGRADE.getValue() == saOrder.getOrderType()) {
if (cuMemberAccount.getPayAccount3Flag()) { if (cuMemberAccount.getPayAccount3Flag()) {
// 验证是否有政策币权限 // 验证是否有政策币权限
List<CuMemberServiceLog> cuMemberServiceLogs = cuMemberServiceLogServiceApi.queryMaxCuMemberServiceLog(cuMemberAccount.getPkMember(), Collections.singletonList(EApprovalBusiness.POLICY_CURRENCY_YES_NO.getValue())); List<CuMemberServiceLog> cuMemberServiceLogs = iCuMemberServiceLogServiceApi.queryMaxCuMemberServiceLog(cuMemberAccount.getPkMember(), Collections.singletonList(EApprovalBusiness.POLICY_CURRENCY_YES_NO.getValue()));
if (CollectionUtil.isNotEmpty(cuMemberServiceLogs)) { if (CollectionUtil.isNotEmpty(cuMemberServiceLogs)) {
Map<Integer, CuMemberServiceLog> cuMemberServiceLogMap = new HashMap<>(ComputeUtil.mapInitCapacity(cuMemberServiceLogs.size())); Map<Integer, CuMemberServiceLog> cuMemberServiceLogMap = new HashMap<>(ComputeUtil.mapInitCapacity(cuMemberServiceLogs.size()));
cuMemberServiceLogs.forEach(serviceLog -> cuMemberServiceLogMap.put(serviceLog.getEditType(), serviceLog)); cuMemberServiceLogs.forEach(serviceLog -> cuMemberServiceLogMap.put(serviceLog.getEditType(), serviceLog));
@ -2048,7 +2057,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
// 查询会员最新升级记录 // 查询会员最新升级记录
CuMemberLevel cuMemberLevel = iCuMemberDetailServiceApi.getLastUpgrade(cuMember.getPkId(), saOrder.getPkId()).getData(); CuMemberLevel cuMemberLevel = iCuMemberDetailServiceApi.getLastUpgrade(cuMember.getPkId(), saOrder.getPkId()).getData();
if (null != cuMemberLevel) { if (null != cuMemberLevel) {
return gradeServiceApi.getGrade(cuMemberLevel.getNewLevel()).getData(); return iGradeServiceApi.getGrade(cuMemberLevel.getNewLevel()).getData();
} }
// 没有升级记录，直接查会员注册信息表 // 没有升级记录，直接查会员注册信息表
@ -2056,11 +2065,11 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
if (null == cuMemberRegister) { if (null == cuMemberRegister) {
throw new ServiceException("没有会员注册信息"); throw new ServiceException("没有会员注册信息");
} }
return gradeServiceApi.getGrade(cuMemberRegister.getPkRegisterGrade()).getData(); return iGradeServiceApi.getGrade(cuMemberRegister.getPkRegisterGrade()).getData();
} }
/** /**
* 处理撤销升级订单 * 处理撤销订单
* *
* @param saOrderExt 订单信息 * @param saOrderExt 订单信息
* @param updSaOrder 升级订单 * @param updSaOrder 升级订单
@ -2074,7 +2083,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
// 计算等级 // 计算等级
// 空单注册，从cu_member_register中获取 // 空单注册，从cu_member_register中获取
if (updSaOrder == null) { if (updSaOrder == null) {
CuMemberRegister cuMemberRegister = memberServiceApi.queryCuMemberRegister(saOrderExt.getPkMember()).getData(); CuMemberRegister cuMemberRegister = iMemberServiceApi.queryCuMemberRegister(saOrderExt.getPkMember()).getData();
cuMember.setPkRegisterGrade(cuMemberRegister.getPkRegisterGrade()); cuMember.setPkRegisterGrade(cuMemberRegister.getPkRegisterGrade());
cuMember.setPkSettleGrade(cuMemberRegister.getPkRegisterGrade()); cuMember.setPkSettleGrade(cuMemberRegister.getPkRegisterGrade());
cuMember.setConsumeMoney(BigDecimal.ZERO); cuMember.setConsumeMoney(BigDecimal.ZERO);
@ -2099,6 +2108,22 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
cuMember.setIsActivate(EYesNo.NO.getIntValue()); cuMember.setIsActivate(EYesNo.NO.getIntValue());
} }
saOrderExt.setUpdateFlag(EYesNo.YES.getIntValue()); saOrderExt.setUpdateFlag(EYesNo.YES.getIntValue());
} else if (EOrderType.PICK_ORDER.getValue() == saOrderExt.getOrderType()) {
// 提货订单
// 提货日志列表
List<AcPickMemberLog> pickMemberLogList = iAcPickMemberLogService.listPickMemberLog(saOrderExt.getPkMember(), saOrderExt.getOrderCode(), EDelFlag.UN_DELETE.getValue());
if (CollectionUtil.isNotEmpty(pickMemberLogList)) {
for (AcPickMemberLog acPickMemberLog : pickMemberLogList) {
// 更新会员提货表
iAcPickService.updateMemberPickById(acPickMemberLog.getPkPick(), acPickMemberLog.getPickQuantity(), acPickMemberLog.getPkMember());
// 更新会员提货日志表
iAcPickMemberLogService.update(Wrappers.<AcPickMemberLog>lambdaUpdate()
.eq(AcPickMemberLog::getPkId, acPickMemberLog.getPkId())
.eq(AcPickMemberLog::getDelFlag, EDelFlag.UN_DELETE.getValue())
.set(AcPickMemberLog::getDelFlag, EDelFlag.DELETE.getValue())
);
}
}
} else if (EOrderType.RETAIL_PICK.getValue() == saOrderExt.getOrderType()) { } else if (EOrderType.RETAIL_PICK.getValue() == saOrderExt.getOrderType()) {
// 新提货订单 // 新提货订单
if (!iAcRetailPickService.cancelRetailPickOrder(saOrderExt.getPkId(), pkApprove)) { if (!iAcRetailPickService.cancelRetailPickOrder(saOrderExt.getPkId(), pkApprove)) {
@ -2114,7 +2139,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
// iSaOrderWaresLimitService.updateCancelOrder(saOrderExt.getPkId(), saOrderExt.getPkMember(), saOrderExt.getModifiedTime(), boxProductList); // iSaOrderWaresLimitService.updateCancelOrder(saOrderExt.getPkId(), saOrderExt.getPkMember(), saOrderExt.getModifiedTime(), boxProductList);
// } // }
if (!memberServiceApi.normalRevokeOrder(pkApprove, saOrderExt, cuMember, businessCommissionDTO).getData()) { if (!iMemberServiceApi.normalRevokeOrder(pkApprove, saOrderExt, cuMember, businessCommissionDTO).getData()) {
throw new ServiceException("撤单处理会员失败"); throw new ServiceException("撤单处理会员失败");
} }
} }
@ -2239,10 +2264,10 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
BdGrade lastUpdateGrade = gradeList.stream().filter(tmpGrade -> tmpGrade.getPkId().equals(lastMemberLevel.getNewLevel())).findFirst().get(); BdGrade lastUpdateGrade = gradeList.stream().filter(tmpGrade -> tmpGrade.getPkId().equals(lastMemberLevel.getNewLevel())).findFirst().get();
// 盒数基数 = 手动升级盒数 + 手动升级之后的升级订单盒数 // 盒数基数 = 手动升级盒数 + 手动升级之后的升级订单盒数
baseBoxNum = lastUpdateGrade.getBoxNumber() baseBoxNum = lastUpdateGrade.getBoxNumber()
+ saOrderItemsService.getRetailWaresQuantityNew(cuMember.getPkId(), boxWaresList, lastMemberLevel.getUpgradeTime(), Collections.singletonList(EOrderType.RETAIL_UPGRADE.getValue()), systemType); + iSaOrderItemsService.getRetailWaresQuantityNew(cuMember.getPkId(), boxWaresList, lastMemberLevel.getUpgradeTime(), Collections.singletonList(EOrderType.RETAIL_UPGRADE.getValue()), systemType);
} else { } else {
// 没有手动升级记录 // 没有手动升级记录
baseBoxNum = saOrderItemsService.getRetailWaresQuantityNew(cuMember.getPkId(), boxWaresList, null, Arrays.asList(EOrderType.RETAIL_REGISTER.getValue(), EOrderType.RETAIL_UPGRADE.getValue()), systemType); baseBoxNum = iSaOrderItemsService.getRetailWaresQuantityNew(cuMember.getPkId(), boxWaresList, null, Arrays.asList(EOrderType.RETAIL_REGISTER.getValue(), EOrderType.RETAIL_UPGRADE.getValue()), systemType);
} }
} }
return baseBoxNum; return baseBoxNum;

7
bd-business/bd-business-sale/src/main/java/com/hzs/sale/postage/mapper/BdPostageMapper.java
View File

@ -8,16 +8,13 @@ import org.apache.ibatis.annotations.Param;
import java.util.List; import java.util.List;
/** /**
* <p>
* 邮费设置 Mapper 接口 * 邮费设置 Mapper 接口
* </p>
*
* @author hzs
* @since 2022-08-27
*/ */
public interface BdPostageMapper extends BaseMapper<BdPostage> { public interface BdPostageMapper extends BaseMapper<BdPostage> {
/** /**
* 查询邮费列表 * 查询邮费列表
*
* @return * @return
*/ */
List<PostageVo> selectByList(@Param("pkCountry") Integer pkCountry); List<PostageVo> selectByList(@Param("pkCountry") Integer pkCountry);

42
bd-business/bd-business-sale/src/main/java/com/hzs/sale/postage/provider/IPostageServiceProvider.java
View File

@ -1,42 +0,0 @@
package com.hzs.sale.postage.provider;
import com.hzs.common.core.domain.R;
import com.hzs.common.core.exception.ServiceException;
import com.hzs.sale.postage.IPostageServiceApi;
import com.hzs.sale.postage.dto.PostageProductDTO;
import com.hzs.sale.postage.service.IPostageBusinessService;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.factory.annotation.Autowired;
import java.math.BigDecimal;
import java.util.List;
/**
* @Description: 邮费服务API
* @Author: jiang chao
* @Time: 2023/4/25 14:41
* @Classname: IPostageServiceProvider
* @PackageName: com.hzs.sale.postage.provider
*/
@Slf4j
@DubboService
public class IPostageServiceProvider implements IPostageServiceApi {
@Autowired
private IPostageBusinessService iPostageBusinessService;
@Override
public R<BigDecimal> queryPostage(Integer pkId, List<PostageProductDTO> productList, Integer province, Integer recCity) {
try {
return R.ok(iPostageBusinessService.queryPostage(pkId, productList, province, recCity));
} catch (ServiceException se) {
log.error("查询邮费模板数据异常， 模板ID： {}", pkId, se);
return R.fail(se.getMessage());
} catch (Exception e) {
log.error("查询邮费模板异常， 模板ID： {}", pkId, e);
}
return R.fail();
}
}

3
bd-business/bd-business-sale/src/main/java/com/hzs/sale/postage/service/IBdPostageService.java
View File

@ -9,9 +9,6 @@ import java.util.List;
/** /**
* 邮费设置 服务类 * 邮费设置 服务类
*
* @author hzs
* @since 2022-08-27
*/ */
public interface IBdPostageService extends IService<BdPostage> { public interface IBdPostageService extends IService<BdPostage> {

6
bd-business/bd-business-sale/src/main/java/com/hzs/sale/postage/service/IPostageBusinessService.java
View File

@ -6,11 +6,7 @@ import java.math.BigDecimal;
import java.util.List; import java.util.List;
/** /**
* @Description: 邮费业务服务 * 邮费业务服务
* @Author: jiang chao
* @Time: 2023/4/25 16:20
* @Classname: IPostageBusinessService
* @PackageName: com.hzs.sale.postage.service
*/ */
public interface IPostageBusinessService { public interface IPostageBusinessService {

3
bd-business/bd-business-sale/src/main/java/com/hzs/sale/postage/service/impl/BdPostageServiceImpl.java
View File

@ -35,9 +35,6 @@ import java.util.List;
/** /**
* 邮费设置 服务实现类 * 邮费设置 服务实现类
*
* @author hzs
* @since 2022-08-27
*/ */
@Service @Service
public class BdPostageServiceImpl extends ServiceImpl<BdPostageMapper, BdPostage> implements IBdPostageService { public class BdPostageServiceImpl extends ServiceImpl<BdPostageMapper, BdPostage> implements IBdPostageService {

6
bd-business/bd-business-sale/src/main/java/com/hzs/sale/postage/service/impl/PostageBusinessServiceImpl.java
View File

@ -25,11 +25,7 @@ import java.util.Map;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
* @Description: 邮费业务服务 * 邮费业务服务
* @Author: jiang chao
* @Time: 2023/4/25 16:20
* @Classname: PostageBusinessServiceImpl
* @PackageName: com.hzs.sale.postage.service.impl
*/ */
@Service @Service
public class PostageBusinessServiceImpl implements IPostageBusinessService { public class PostageBusinessServiceImpl implements IPostageBusinessService {

3
bd-business/bd-business-sale/src/main/java/com/hzs/sale/wares/service/impl/BdWaresExtendServiceImpl.java
View File

@ -15,9 +15,6 @@ import java.util.List;
/** /**
* 商品发布扩展表 服务实现类 * 商品发布扩展表 服务实现类
*
* @author hzs
* @since 2022-09-09
*/ */
@Service @Service
public class BdWaresExtendServiceImpl extends ServiceImpl<BdWaresExtendMapper, BdWaresExtend> implements IBdWaresExtendService { public class BdWaresExtendServiceImpl extends ServiceImpl<BdWaresExtendMapper, BdWaresExtend> implements IBdWaresExtendService {

18
bd-business/bd-business-sale/src/main/resources/mapper/activity/pick/AcPickMapper.xml
View File

@ -149,7 +149,7 @@
<!-- 会员提货列表 --> <!-- 会员提货列表 -->
<select id="pickList" resultType="com.hzs.activity.pick.vo.ApiPickListVO"> <select id="pickList" resultType="com.hzs.activity.pick.vo.ApiPickListVO">
<!-- 提货产品 --> <!-- 提货产品、分公司产品 -->
select ap.pk_id, select ap.pk_id,
ap.pick_type, ap.pick_type,
case case
@ -170,7 +170,7 @@
where ap.del_flag = 0 where ap.del_flag = 0
and ap.pk_country = #{pkCountry} and ap.pk_country = #{pkCountry}
and ap.pk_member = #{pkMember} and ap.pk_member = #{pkMember}
and ap.pick_type = 0 and ap.pick_type in (0, 20)
and ap.usable_quantity > 0 and ap.usable_quantity > 0
and (ap.receive_time is null or to_char(ap.receive_time, 'yyyy-mm-dd') >= to_char(sysdate, 'yyyy-mm-dd')) and (ap.receive_time is null or to_char(ap.receive_time, 'yyyy-mm-dd') >= to_char(sysdate, 'yyyy-mm-dd'))
<!-- 迁移抽奖、新抽奖 --> <!-- 迁移抽奖、新抽奖 -->
@ -263,4 +263,18 @@
update set ap.usable_quantity = ap.usable_quantity + tmp.usable_quantity update set ap.usable_quantity = ap.usable_quantity + tmp.usable_quantity
</update> </update>
<!-- 根据ID更新会员提货数据 -->
<update id="updateMemberPickById">
update ac_pick ap
set ap.usable_quantity = ap.usable_quantity + #{quantity},
ap.used_quantity = ap.used_quantity - #{quantity},
ap.modified_time = sysdate
where ap.del_flag = 0
<if test="pkMember != null">
and ap.pk_member = #{pkMember}
</if>
and ap.pk_id = #{pkId}
and ap.usable_quantity + #{quantity} > 0
</update>
</mapper> </mapper>

20
bd-business/bd-business-sale/src/main/resources/mapper/activity/pick/AcPickMemberLogMapper.xml
View File

@ -2,18 +2,14 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.hzs.activity.pick.mapper.AcPickMemberLogMapper"> <mapper namespace="com.hzs.activity.pick.mapper.AcPickMemberLogMapper">
<!-- 通用查询映射结果 --> <!-- 查询会员订单数据 -->
<resultMap id="BaseResultMap" type="com.hzs.common.domain.activity.pick.AcPickMemberLog"> <select id="listPickMemberLog" resultType="com.hzs.common.domain.activity.pick.AcPickMemberLog">
<id column="PK_ID" property="pkId"/> select *
<result column="PK_MEMBER" property="pkMember"/> from AC_PICK_MEMBER_LOG t
<result column="PK_PICK" property="pkPick"/> where t.pk_member = #{pkMember}
<result column="PICK_QUANTITY" property="pickQuantity"/> and t.pick_order = #{orderCode}
<result column="PICK_TIME" property="pickTime"/> and t.del_flag = #{delFlag}
<result column="PICK_ORDER" property="pickOrder"/> </select>
<result column="PK_COUNTRY" property="pkCountry"/>
<result column="DEL_FLAG" property="delFlag"/>
<result column="SOURCE" property="source"/>
</resultMap>
<!-- 查询提货日志 --> <!-- 查询提货日志 -->
<select id="queryMemberLog" resultType="com.hzs.activity.pick.vo.AcPickMemberLogVO"> <select id="queryMemberLog" resultType="com.hzs.activity.pick.vo.AcPickMemberLogVO">

27
bd-business/bd-business-system/src/main/java/com/hzs/system/config/provider/AreaCurrencyServiceProvider.java
View File

@ -23,25 +23,21 @@ import java.util.List;
import java.util.Set; import java.util.Set;
/** /**
* @Description: 专区币种配置提供的公共api服务 * 专区币种配置提供的公共api服务
* @Author: sui q
* @Time: 2022/9/6 10:41
* @Classname: AreaCurrencyServiceProvider
* @PackageName: com.hzs.system.config.provider
*/ */
@DubboService @DubboService
public class AreaCurrencyServiceProvider implements IAreaCurrencyServiceApi { public class AreaCurrencyServiceProvider implements IAreaCurrencyServiceApi {
@Autowired @Autowired
private IBdAccountService bdAccountService; private IBdAccountService iBdAccountService;
@Autowired @Autowired
private IBdSpecialCurrencyService specialCurrencyService; private IBdSpecialCurrencyService iBdSpecialCurrencyService;
@Autowired @Autowired
private IBdMemberSpecialCurrencyService iBdMemberSpecialCurrencyService; private IBdMemberSpecialCurrencyService iBdMemberSpecialCurrencyService;
@Override @Override
public R<List<AreaCurrencyDTO>> queryAreaCurrencyByPkCountry(Integer pkCountry) { public R<List<AreaCurrencyDTO>> queryAreaCurrencyByPkCountry(Integer pkCountry) {
List<BdAccount> bdAccountList = bdAccountService.queryBdAccount(pkCountry); List<BdAccount> bdAccountList = iBdAccountService.queryBdAccount(pkCountry);
List<AreaCurrencyDTO> areaCurrencyDTOList = new ArrayList<>(); List<AreaCurrencyDTO> areaCurrencyDTOList = new ArrayList<>();
for (BdAccount bdAccount : bdAccountList) { for (BdAccount bdAccount : bdAccountList) {
AreaCurrencyDTO areaCurrencyDTO = new AreaCurrencyDTO(); AreaCurrencyDTO areaCurrencyDTO = new AreaCurrencyDTO();
@ -52,18 +48,9 @@ public class AreaCurrencyServiceProvider implements IAreaCurrencyServiceApi {
return R.ok(areaCurrencyDTOList); return R.ok(areaCurrencyDTOList);
} }
/**
* 根据条件查找对应的币种配置
*
* @param specialArea 所属专区
* @param pkCountry 国家
* @return: R<List < AreaCurrencyDTO>>
* @Author: sui q
* @Date: 2022/9/6 10:37
*/
@Override @Override
public R<List<AreaCurrencyDTO>> queryAreaCurrencyByCondition(Integer specialArea, Integer pkCountry) { public R<List<AreaCurrencyDTO>> queryAreaCurrencyByCondition(Integer specialArea, Integer pkCountry) {
List<AreaCurrencyExt> areaCurrencyExtList = bdAccountService.queryAreaCurrencyByCondition(specialArea, pkCountry); List<AreaCurrencyExt> areaCurrencyExtList = iBdAccountService.queryAreaCurrencyByCondition(specialArea, pkCountry);
List<AreaCurrencyDTO> areaCurrencyDTOList = new ArrayList<>(); List<AreaCurrencyDTO> areaCurrencyDTOList = new ArrayList<>();
areaCurrencyExtList.forEach(areaCurrencyExt -> areaCurrencyDTOList.add(BeanUtil.copyProperties(areaCurrencyExt, AreaCurrencyDTO.class))); areaCurrencyExtList.forEach(areaCurrencyExt -> areaCurrencyDTOList.add(BeanUtil.copyProperties(areaCurrencyExt, AreaCurrencyDTO.class)));
return R.ok(areaCurrencyDTOList); return R.ok(areaCurrencyDTOList);
@ -82,7 +69,7 @@ public class AreaCurrencyServiceProvider implements IAreaCurrencyServiceApi {
public R<List<AreaCurrencyDTO>> queryAreaCurrencyByCondition(Integer pkSpecialAccount) { public R<List<AreaCurrencyDTO>> queryAreaCurrencyByCondition(Integer pkSpecialAccount) {
SpecialCurrencyParam specialCurrencyParam = new SpecialCurrencyParam(); SpecialCurrencyParam specialCurrencyParam = new SpecialCurrencyParam();
specialCurrencyParam.setPkId(pkSpecialAccount); specialCurrencyParam.setPkId(pkSpecialAccount);
List<BdSpecialCurrencyExt> bdSpecialCurrencyExtList = specialCurrencyService.querySpecialCurrencyList(specialCurrencyParam); List<BdSpecialCurrencyExt> bdSpecialCurrencyExtList = iBdSpecialCurrencyService.querySpecialCurrencyList(specialCurrencyParam);
if (CollectionUtil.isNotEmpty(bdSpecialCurrencyExtList) && CollectionUtil.isNotEmpty(bdSpecialCurrencyExtList.get(0).getSpecialCurrencyDetailList())) { if (CollectionUtil.isNotEmpty(bdSpecialCurrencyExtList) && CollectionUtil.isNotEmpty(bdSpecialCurrencyExtList.get(0).getSpecialCurrencyDetailList())) {
List<AreaCurrencyDTO> resultList = BeanUtil.copyToList(bdSpecialCurrencyExtList.get(0).getSpecialCurrencyDetailList(), AreaCurrencyDTO.class); List<AreaCurrencyDTO> resultList = BeanUtil.copyToList(bdSpecialCurrencyExtList.get(0).getSpecialCurrencyDetailList(), AreaCurrencyDTO.class);
// 2023.11.17 需求添加，记录模板名称，用于后续写死判断逻辑使用 // 2023.11.17 需求添加，记录模板名称，用于后续写死判断逻辑使用
@ -103,7 +90,7 @@ public class AreaCurrencyServiceProvider implements IAreaCurrencyServiceApi {
public List<AreaCurrencyDTO> queryAreaCurrencyBySpecialArea(Set<Integer> pkCurrencySet, Integer account) { public List<AreaCurrencyDTO> queryAreaCurrencyBySpecialArea(Set<Integer> pkCurrencySet, Integer account) {
List<AreaCurrencyDTO> resultList = new ArrayList<>(); List<AreaCurrencyDTO> resultList = new ArrayList<>();
List<BdSpecialCurrencyDetailExt> bdSpecialCurrencyDetailListList = specialCurrencyService.queryAreaCurrencyBySpecialArea(pkCurrencySet, account); List<BdSpecialCurrencyDetailExt> bdSpecialCurrencyDetailListList = iBdSpecialCurrencyService.queryAreaCurrencyBySpecialArea(pkCurrencySet, account);
if (CollectionUtil.isNotEmpty(bdSpecialCurrencyDetailListList)) { if (CollectionUtil.isNotEmpty(bdSpecialCurrencyDetailListList)) {
for (BdSpecialCurrencyDetailExt bdSpecialCurrencyDetail : bdSpecialCurrencyDetailListList) { for (BdSpecialCurrencyDetailExt bdSpecialCurrencyDetail : bdSpecialCurrencyDetailListList) {
resultList.add(AreaCurrencyDTO.builder() resultList.add(AreaCurrencyDTO.builder()

21
bd-common/bd-common-core/src/main/java/com/hzs/common/core/constant/msg/ActivityMsgConstants.java
View File

@ -8,40 +8,45 @@ public class ActivityMsgConstants {
/** /**
* 会员点击抽奖按钮，验证抽奖次数 -- 抽奖次数不足！ * 会员点击抽奖按钮，验证抽奖次数 -- 抽奖次数不足！
*/ */
public static final String DRAW_AVAILABLE_NUMBER = "抽奖次数不足！"; public static final String DRAW_AVAILABLE_NUMBER = "抽奖次数不足！";
/** /**
* 会员点击抽奖按钮，验证抽奖次数 -- 抽奖活动已经结束，不能抽奖！ * 会员点击抽奖按钮，验证抽奖次数 -- 抽奖活动已经结束，不能抽奖！
*/ */
public static final String DRAW_OVER = "抽奖活动已经结束，不能抽奖！"; public static final String DRAW_OVER = "抽奖活动已经结束，不能抽奖！";
/** /**
* 修改或者提货时，提货相关数据已经不存在 -- 会员提货商品不存在 * 修改或者提货时，提货相关数据已经不存在 -- 会员提货商品不存在
*/ */
public static final String PICK_PRODUCT_NOT_EXIST = "会员提货商品不存在"; public static final String PICK_PRODUCT_NOT_EXIST = "提货商品不存在";
/** /**
* 会员提货时，提货数量不足 -- 会员提货商品数量不足 * 会员提货时，提货数量不足 -- 会员提货商品数量不足
*/ */
public static final String PICK_QUANTITY_NOT_ENOUGH = "会员提货商品数量不足"; public static final String PICK_QUANTITY_NOT_ENOUGH = "提货商品数量不足";
/** /**
* 会员提货时，不包邮但是邮费模板配置有错误或者缺失 -- 提货邮费计算错误 * 会员提货时，不包邮但是邮费模板配置有错误或者缺失 -- 提货邮费计算错误
*/ */
public static final String PICK_POSTAGE_ERROR = "提货邮费计算错误"; public static final String PICK_POSTAGE_ERROR = "提货邮费计算错误";
/** /**
* 签呈处理，提货充值记录已经没有了 -- 签呈处理失败：提货充值记录不存在 * 签呈处理，提货充值记录已经没有了 -- 签呈处理失败：提货充值记录不存在
*/ */
public static final String PICK_NOT_EXIST = "签呈处理失败：提货充值记录不存在"; public static final String PICK_NOT_EXIST = "签呈处理失败：提货充值记录不存在";
/** /**
* 签呈处理，提货充值记录已经处理过了 -- 签呈处理失败：提货充值记录已处理 * 签呈处理，提货充值记录已经处理过了 -- 签呈处理失败：提货充值记录已处理
*/ */
public static final String PICK_PROCESSED = "签呈处理失败：提货充值记录已处理"; public static final String PICK_PROCESSED = "签呈处理失败：提货充值记录已处理";
/** /**
* 奖品信息填写不完整 -- 奖品规则信息填写不完整 * 奖品信息填写不完整 -- 奖品规则信息填写不完整
*/ */
public static final String DRAW_RULE_COMPLETE_INFO = "奖品规则信息填写不完整"; public static final String DRAW_RULE_COMPLETE_INFO = "奖品规则信息填写不完整";
/**
* 会员提货时，提货数量只能为配置基数的倍数（比如：沙棘果汁一次只能提3箱） -- 提货数量只能为%s的倍数
*/
public static final String PICK_QUANTITY_BASE = "提货数量只能为%s的倍数";
} }

1
bd-common/bd-common-core/src/main/java/com/hzs/common/core/enums/EActType.java
View File

@ -1,6 +1,5 @@
package com.hzs.common.core.enums; package com.hzs.common.core.enums;
import com.hzs.common.core.constant.EnumsPrefixConstants;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Getter; import lombok.Getter;

2
bd-common/bd-common-core/src/main/java/com/hzs/common/core/enums/EDelFlag.java
View File

@ -6,8 +6,6 @@ import lombok.Getter;
/** /**
* 删除标记枚举类 * 删除标记枚举类
*
* @author hzs
*/ */
@AllArgsConstructor @AllArgsConstructor
@Getter @Getter

7
bd-common/bd-common-core/src/main/java/com/hzs/common/core/enums/EOrderType.java
View File

@ -29,6 +29,11 @@ public enum EOrderType {
*/ */
REPURCHASE_ORDER(3, "旧复购订单", 1, EnumsPrefixConstants.ORDER_TYPE + 3), REPURCHASE_ORDER(3, "旧复购订单", 1, EnumsPrefixConstants.ORDER_TYPE + 3),
/**
* 提货订单
*/
PICK_ORDER(8, "提货订单", 0, EnumsPrefixConstants.ORDER_TYPE + 8),
/** /**
* 重消订单 * 重消订单
*/ */
@ -63,7 +68,7 @@ public enum EOrderType {
RETAIL_TICKET(45, "自助购票", 0, EnumsPrefixConstants.ORDER_TYPE + 45), RETAIL_TICKET(45, "自助购票", 0, EnumsPrefixConstants.ORDER_TYPE + 45),
RETAIL_PICK(46, "提货订单", 0, EnumsPrefixConstants.ORDER_TYPE + 46), RETAIL_PICK(46, "活动提货订单", 0, EnumsPrefixConstants.ORDER_TYPE + 46),
; ;

5
bd-common/bd-common-core/src/main/java/com/hzs/common/core/enums/ESpecialArea.java
View File

@ -26,6 +26,11 @@ public enum ESpecialArea {
*/ */
REPURCHASE_AREA(3, "旧复购自营", 1, EnumsPrefixConstants.SPECIAL_AREA + "3", 5, EMenuDetail.REPURCHASE.getValue()), REPURCHASE_AREA(3, "旧复购自营", 1, EnumsPrefixConstants.SPECIAL_AREA + "3", 5, EMenuDetail.REPURCHASE.getValue()),
/**
* 提货专区
*/
PICK_AREA(8, "提货专区", 0, EnumsPrefixConstants.SPECIAL_AREA + "8", 5, EMenuDetail.PICK.getValue()),
/** /**
* 重消专区 * 重消专区
*/ */

6
bd-common/bd-common-domain/src/main/java/com/hzs/common/domain/activity/pick/AcPickMemberLog.java
View File

@ -10,13 +10,15 @@ import com.baomidou.mybatisplus.annotation.TableField;
import java.io.Serializable; import java.io.Serializable;
import lombok.Data; import lombok.*;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;
/** /**
* 会员提货记录 * 会员提货记录
*/ */
@Builder
@AllArgsConstructor
@NoArgsConstructor
@Data @Data
@EqualsAndHashCode(callSuper = false) @EqualsAndHashCode(callSuper = false)
@Accessors(chain = true) @Accessors(chain = true)