Compare commits
19 Commits
b117705508
...
b498fc9924
| Author | SHA1 | Date |
|---|---|---|
|
|
b498fc9924 | |
|
|
0df18cfe1d | |
|
|
bd0371f8fd | |
|
|
4d78bfaed5 | |
|
|
aa12deaa62 | |
|
|
4225f92413 | |
|
|
42e9883029 | |
|
|
d2afea78f8 | |
|
|
7e4085378b | |
|
|
b440079fa0 | |
|
|
162ccfb6bb | |
|
|
a108c27708 | |
|
|
06cf3ce2a9 | |
|
|
a10a5182cf | |
|
|
9d0fcd7605 | |
|
|
4b3a1f6041 | |
|
|
410fa5e60d | |
|
|
e98fa16f49 | |
|
|
d8c3683ddd |
|
|
@ -1,7 +1,6 @@
|
||||||
package com.hzs.member.account.controller.api;
|
package com.hzs.member.account.controller.api;
|
||||||
|
|
||||||
import com.hzs.common.core.constant.EnumsPrefixConstants;
|
import cn.hutool.core.collection.CollectionUtil;
|
||||||
import com.hzs.common.core.enums.EOrderType;
|
|
||||||
import com.hzs.common.core.enums.ETradeType;
|
import com.hzs.common.core.enums.ETradeType;
|
||||||
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;
|
||||||
|
|
@ -10,34 +9,24 @@ import com.hzs.common.core.web.page.TableDataInfo;
|
||||||
import com.hzs.common.security.utils.SecurityUtils;
|
import com.hzs.common.security.utils.SecurityUtils;
|
||||||
import com.hzs.member.account.service.ICuMemberAccountService;
|
import com.hzs.member.account.service.ICuMemberAccountService;
|
||||||
import com.hzs.member.account.service.ICuMemberTradeService;
|
import com.hzs.member.account.service.ICuMemberTradeService;
|
||||||
import com.hzs.member.account.vo.CuMemberAccountVO;
|
|
||||||
import com.hzs.member.account.vo.CuMemberTradeVO;
|
import com.hzs.member.account.vo.CuMemberTradeVO;
|
||||||
import com.hzs.member.account.vo.CuMemberWalletBalanceVO;
|
|
||||||
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.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 我的钱包
|
* 我的钱包
|
||||||
*
|
|
||||||
* @Description:
|
|
||||||
* @Author: ljc
|
|
||||||
* @Time: 2023/2/8 11:19
|
|
||||||
* @Classname: CuMemberWalletControllerApi
|
|
||||||
* @Package_name: com.hzs.member.account.controller.api
|
|
||||||
*/
|
*/
|
||||||
@RestController
|
@RestController
|
||||||
@RequestMapping("/api/wallet")
|
@RequestMapping("/api/wallet")
|
||||||
public class ApiCuMemberWalletController extends BaseController {
|
public class ApiCuMemberWalletController extends BaseController {
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
ICuMemberAccountService memberAccountService;
|
private ICuMemberAccountService iCuMemberAccountService;
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
ICuMemberTradeService memberTradeService;
|
private ICuMemberTradeService iCuMemberTradeService;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
@ -49,7 +38,7 @@ public class ApiCuMemberWalletController extends BaseController {
|
||||||
public AjaxResult getWalletBalance() {
|
public AjaxResult getWalletBalance() {
|
||||||
Long pkMember = SecurityUtils.getUserId();
|
Long pkMember = SecurityUtils.getUserId();
|
||||||
Integer pkCountry = SecurityUtils.getPkCountry();
|
Integer pkCountry = SecurityUtils.getPkCountry();
|
||||||
return AjaxResult.success(memberAccountService.queryWalletBalanceByPkMember(pkMember, pkCountry));
|
return AjaxResult.success(iCuMemberAccountService.queryWalletBalanceByPkMember(pkMember, pkCountry));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
@ -61,11 +50,11 @@ public class ApiCuMemberWalletController extends BaseController {
|
||||||
@GetMapping("/trade-type")
|
@GetMapping("/trade-type")
|
||||||
public AjaxResult tradeType() {
|
public AjaxResult tradeType() {
|
||||||
// 查询交易类型
|
// 查询交易类型
|
||||||
List<Integer> tradeTypes = memberTradeService.selectTradeType(SecurityUtils.getUserId(), SecurityUtils.getPkCountry());
|
List<Integer> tradeTypes = iCuMemberTradeService.selectTradeType(SecurityUtils.getUserId(), SecurityUtils.getPkCountry());
|
||||||
List<EnumEntity> enumEntityList = new ArrayList<>();
|
List<EnumEntity> enumEntityList = new ArrayList<>();
|
||||||
for (ETradeType value : ETradeType.values()) {
|
for (ETradeType value : ETradeType.values()) {
|
||||||
if (tradeTypes.contains(value.getValue())) {
|
if (tradeTypes.contains(value.getValue())) {
|
||||||
enumEntityList.add(new EnumEntity(value.getValue(), value.getLabel(), EnumsPrefixConstants.TRADE_TYPE));
|
enumEntityList.add(new EnumEntity(value.getValue(), value.getLabel()));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return AjaxResult.success(enumEntityList);
|
return AjaxResult.success(enumEntityList);
|
||||||
|
|
@ -83,7 +72,12 @@ public class ApiCuMemberWalletController extends BaseController {
|
||||||
cuMemberTradeVO.setPkCountry(SecurityUtils.getPkCountry());
|
cuMemberTradeVO.setPkCountry(SecurityUtils.getPkCountry());
|
||||||
cuMemberTradeVO.setPkMember(SecurityUtils.getUserId());
|
cuMemberTradeVO.setPkMember(SecurityUtils.getUserId());
|
||||||
startPage();
|
startPage();
|
||||||
List<CuMemberTradeVO> cuMemberTradeVOList = memberTradeService.selectWattleDetail(cuMemberTradeVO);
|
List<CuMemberTradeVO> cuMemberTradeVOList = iCuMemberTradeService.selectWattleDetail(cuMemberTradeVO);
|
||||||
|
if (CollectionUtil.isNotEmpty(cuMemberTradeVOList)) {
|
||||||
|
for (CuMemberTradeVO memberTradeVO : cuMemberTradeVOList) {
|
||||||
|
memberTradeVO.setTradeTypeVal(ETradeType.getTradeLabel(memberTradeVO.getTradeType()));
|
||||||
|
}
|
||||||
|
}
|
||||||
return getDataTable(cuMemberTradeVOList);
|
return getDataTable(cuMemberTradeVOList);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -49,6 +49,7 @@ import com.hzs.system.config.IAreaCurrencyServiceApi;
|
||||||
import com.hzs.system.config.IAwardsServiceApi;
|
import com.hzs.system.config.IAwardsServiceApi;
|
||||||
import com.hzs.system.config.dto.AreaCurrencyDTO;
|
import com.hzs.system.config.dto.AreaCurrencyDTO;
|
||||||
import com.hzs.third.pay.ITOnlinePaymentServiceApi;
|
import com.hzs.third.pay.ITOnlinePaymentServiceApi;
|
||||||
|
import com.hzs.third.sms.ISmsServiceApi;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
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;
|
||||||
|
|
@ -76,6 +77,8 @@ public class CuMemberBusinessServiceImpl implements ICuMemberBusinessService {
|
||||||
ICurrencyServiceApi iCurrencyServiceApi;
|
ICurrencyServiceApi iCurrencyServiceApi;
|
||||||
@DubboReference
|
@DubboReference
|
||||||
ISaOrderServiceApi iSaOrderServiceApi;
|
ISaOrderServiceApi iSaOrderServiceApi;
|
||||||
|
@DubboReference
|
||||||
|
ISmsServiceApi iSmsServiceApi;
|
||||||
|
|
||||||
@DubboReference
|
@DubboReference
|
||||||
ITOnlinePaymentServiceApi itOnlinePaymentServiceApi;
|
ITOnlinePaymentServiceApi itOnlinePaymentServiceApi;
|
||||||
|
|
@ -1232,6 +1235,14 @@ public class CuMemberBusinessServiceImpl implements ICuMemberBusinessService {
|
||||||
saveLevelUpgrade(cuMember, EUpgradeType.BUY_UPGRADE.getValue(), saOrder, 0);
|
saveLevelUpgrade(cuMember, EUpgradeType.BUY_UPGRADE.getValue(), saOrder, 0);
|
||||||
|
|
||||||
this.handleRetailMemberAccount(saOrder, cuMemberAccountExt);
|
this.handleRetailMemberAccount(saOrder, cuMemberAccountExt);
|
||||||
|
|
||||||
|
try {
|
||||||
|
// 发送会员注册成功短信
|
||||||
|
iSmsServiceApi.sendMemberRegister(cuMember.getPhone(), EAliSmsTemplate.MEMBER_REGISTER,
|
||||||
|
cuMember.getMemberCode(), cuMember.getLoginPassword(), cuMember.getPayPassword());
|
||||||
|
} catch (Exception e) {
|
||||||
|
log.error("发送注册短信失败");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
@Transactional(rollbackFor = Exception.class)
|
||||||
|
|
|
||||||
|
|
@ -6,15 +6,14 @@ import cn.hutool.core.util.ObjectUtil;
|
||||||
import com.hzs.common.core.annotation.RepeatSubmit;
|
import com.hzs.common.core.annotation.RepeatSubmit;
|
||||||
import com.hzs.common.core.config.BdConfig;
|
import com.hzs.common.core.config.BdConfig;
|
||||||
import com.hzs.common.core.constant.CacheConstants;
|
import com.hzs.common.core.constant.CacheConstants;
|
||||||
|
import com.hzs.common.core.constant.CountryConstants;
|
||||||
import com.hzs.common.core.constant.RetailConstants;
|
import com.hzs.common.core.constant.RetailConstants;
|
||||||
import com.hzs.common.core.domain.R;
|
import com.hzs.common.core.domain.R;
|
||||||
import com.hzs.common.core.enums.EGrade;
|
import com.hzs.common.core.enums.EGrade;
|
||||||
import com.hzs.common.core.enums.EOrderPrefix;
|
|
||||||
import com.hzs.common.core.enums.ESpecialArea;
|
import com.hzs.common.core.enums.ESpecialArea;
|
||||||
import com.hzs.common.core.enums.EYesNo;
|
import com.hzs.common.core.enums.EYesNo;
|
||||||
import com.hzs.common.core.exception.ServiceException;
|
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.CommonUtil;
|
|
||||||
import com.hzs.common.core.utils.StringUtils;
|
import com.hzs.common.core.utils.StringUtils;
|
||||||
import com.hzs.common.core.web.domain.AjaxResult;
|
import com.hzs.common.core.web.domain.AjaxResult;
|
||||||
import com.hzs.common.domain.member.base.CuMember;
|
import com.hzs.common.domain.member.base.CuMember;
|
||||||
|
|
@ -23,7 +22,6 @@ import com.hzs.common.domain.member.ext.CuMemberAccountExt;
|
||||||
import com.hzs.common.domain.sale.ext.BdWaresSpecsSkuExt;
|
import com.hzs.common.domain.sale.ext.BdWaresSpecsSkuExt;
|
||||||
import com.hzs.common.domain.sale.ext.SaOrderExt;
|
import com.hzs.common.domain.sale.ext.SaOrderExt;
|
||||||
import com.hzs.common.domain.sale.wares.BdWares;
|
import com.hzs.common.domain.sale.wares.BdWares;
|
||||||
import com.hzs.common.domain.system.config.BdAwards;
|
|
||||||
import com.hzs.common.domain.system.config.BdGrade;
|
import com.hzs.common.domain.system.config.BdGrade;
|
||||||
import com.hzs.common.security.service.MemberTokenService;
|
import com.hzs.common.security.service.MemberTokenService;
|
||||||
import com.hzs.common.security.utils.SecurityUtils;
|
import com.hzs.common.security.utils.SecurityUtils;
|
||||||
|
|
@ -33,7 +31,6 @@ import com.hzs.retail.sale.param.*;
|
||||||
import com.hzs.retail.sale.vo.*;
|
import com.hzs.retail.sale.vo.*;
|
||||||
import com.hzs.sale.order.param.*;
|
import com.hzs.sale.order.param.*;
|
||||||
import com.hzs.sale.order.service.ISaOrderService;
|
import com.hzs.sale.order.service.ISaOrderService;
|
||||||
import com.hzs.sale.order.service.ISaOrderShareTmpService;
|
|
||||||
import com.hzs.sale.shopping.service.IShoppingCartService;
|
import com.hzs.sale.shopping.service.IShoppingCartService;
|
||||||
import com.hzs.sale.shopping.vo.ProductGroup;
|
import com.hzs.sale.shopping.vo.ProductGroup;
|
||||||
import com.hzs.sale.shopping.vo.ShoppingCartRedis;
|
import com.hzs.sale.shopping.vo.ShoppingCartRedis;
|
||||||
|
|
@ -41,7 +38,6 @@ import com.hzs.sale.shopping.vo.ShoppingCartVO;
|
||||||
import com.hzs.sale.wares.service.IBdWaresService;
|
import com.hzs.sale.wares.service.IBdWaresService;
|
||||||
import com.hzs.sale.wares.service.IBdWaresSpecsSkuService;
|
import com.hzs.sale.wares.service.IBdWaresSpecsSkuService;
|
||||||
import com.hzs.system.base.IAreaServiceApi;
|
import com.hzs.system.base.IAreaServiceApi;
|
||||||
import com.hzs.system.config.IAwardsServiceApi;
|
|
||||||
import com.hzs.system.config.IGradeServiceApi;
|
import com.hzs.system.config.IGradeServiceApi;
|
||||||
import com.hzs.system.config.dto.GradeDTO;
|
import com.hzs.system.config.dto.GradeDTO;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
|
@ -77,8 +73,6 @@ public class ApiRetailOrderController {
|
||||||
private IBdWaresService iBdWaresService;
|
private IBdWaresService iBdWaresService;
|
||||||
@Autowired
|
@Autowired
|
||||||
private IBdWaresSpecsSkuService iBdWaresSpecsSkuService;
|
private IBdWaresSpecsSkuService iBdWaresSpecsSkuService;
|
||||||
@Autowired
|
|
||||||
private ISaOrderShareTmpService iSaOrderShareTmpService;
|
|
||||||
|
|
||||||
@DubboReference
|
@DubboReference
|
||||||
IMemberServiceApi iMemberServiceApi;
|
IMemberServiceApi iMemberServiceApi;
|
||||||
|
|
@ -86,8 +80,6 @@ public class ApiRetailOrderController {
|
||||||
IGradeServiceApi iGradeServiceApi;
|
IGradeServiceApi iGradeServiceApi;
|
||||||
@DubboReference
|
@DubboReference
|
||||||
IAreaServiceApi iAreaServiceApi;
|
IAreaServiceApi iAreaServiceApi;
|
||||||
@DubboReference
|
|
||||||
IAwardsServiceApi iAwardsServiceApi;
|
|
||||||
@Autowired
|
@Autowired
|
||||||
private MemberTokenService memberTokenService;
|
private MemberTokenService memberTokenService;
|
||||||
|
|
||||||
|
|
@ -281,11 +273,10 @@ public class ApiRetailOrderController {
|
||||||
}
|
}
|
||||||
if (ObjectUtil.isEmpty(buyMember)) {
|
if (ObjectUtil.isEmpty(buyMember)) {
|
||||||
buyMember = new CuMember();
|
buyMember = new CuMember();
|
||||||
List<BdGrade> gradeList = iGradeServiceApi.getRetailGradeList().getData();
|
GradeDTO gradeDTO = iGradeServiceApi.getGradeByGradeValue(EGrade.MEMBER.getValue(), CountryConstants.CHINA_COUNTRY).getData();
|
||||||
// Map<String, BdAwards> awardsMap = iAwardsServiceApi.getAwards().getData();
|
buyMember.setPkSettleGrade(gradeDTO.getPkId());
|
||||||
buyMember.setPkSettleGrade(gradeList.get(0).getPkId());
|
buyMember.setPkAwards(gradeDTO.getPkAwards());
|
||||||
buyMember.setPkSettleCountry(1);
|
buyMember.setPkSettleCountry(CountryConstants.CHINA_COUNTRY);
|
||||||
buyMember.setPkAwards(1);
|
|
||||||
}
|
}
|
||||||
orderParam.setOrderItemsParams(orderItemsParams);
|
orderParam.setOrderItemsParams(orderItemsParams);
|
||||||
iRetailOrderService.createSaOrderItems(orderParam, null, buyMember, null, null);
|
iRetailOrderService.createSaOrderItems(orderParam, null, buyMember, null, null);
|
||||||
|
|
@ -772,17 +763,10 @@ public class ApiRetailOrderController {
|
||||||
// registerParam.setOrderItemsParams(convertShoppingCarToSku(registerParam.getPkCreator(), registerParam.getShopList()));
|
// registerParam.setOrderItemsParams(convertShoppingCarToSku(registerParam.getPkCreator(), registerParam.getShopList()));
|
||||||
|
|
||||||
// 遍历商品,封装订单明细
|
// 遍历商品,封装订单明细
|
||||||
// 订单金额
|
|
||||||
BigDecimal orderAmount = BigDecimal.ZERO;
|
|
||||||
|
|
||||||
// 生成订单编号
|
// 生成订单编号
|
||||||
String orderCode = CommonUtil.createSerialNumber(EOrderPrefix.ORDER_CODE);
|
|
||||||
List<OrderItemsParam> orderItemsParams = new ArrayList<>();
|
List<OrderItemsParam> orderItemsParams = new ArrayList<>();
|
||||||
for (FansConfirmOrderWaresParam waresParam : registerParam.getWaresList()) {
|
for (FansConfirmOrderWaresParam waresParam : registerParam.getWaresList()) {
|
||||||
// 遍历sku
|
// 遍历sku
|
||||||
// 产品价格等map
|
|
||||||
Map<Long, BdWaresSpecsSkuExt> skuMap = iBdWaresSpecsSkuService.queryWaresSpecsSkuList(waresParam.getSkuList().stream().map(FansConfirmOrderSkuParam::getPkWaresSku).collect(Collectors.toList()));
|
|
||||||
|
|
||||||
// 查询商品
|
// 查询商品
|
||||||
BdWares bdWares = iBdWaresService.getWares(waresParam.getPkWares());
|
BdWares bdWares = iBdWaresService.getWares(waresParam.getPkWares());
|
||||||
|
|
||||||
|
|
@ -790,9 +774,6 @@ public class ApiRetailOrderController {
|
||||||
List<WaresItemsParam> itemsParamList = new ArrayList<>(waresParam.getSkuList().size());
|
List<WaresItemsParam> itemsParamList = new ArrayList<>(waresParam.getSkuList().size());
|
||||||
// 遍历产品信息
|
// 遍历产品信息
|
||||||
for (FansConfirmOrderSkuParam skuParam : waresParam.getSkuList()) {
|
for (FansConfirmOrderSkuParam skuParam : waresParam.getSkuList()) {
|
||||||
BdWaresSpecsSkuExt specsSku = skuMap.get(skuParam.getPkWaresSku());
|
|
||||||
orderAmount = orderAmount.add(specsSku.getPrice().multiply(new BigDecimal(skuParam.getQuantity() * waresParam.getQuantity())));
|
|
||||||
|
|
||||||
itemsParamList.add(WaresItemsParam.builder()
|
itemsParamList.add(WaresItemsParam.builder()
|
||||||
.pkWaresSpecsSku(skuParam.getPkWaresSku().intValue())
|
.pkWaresSpecsSku(skuParam.getPkWaresSku().intValue())
|
||||||
.quantity(skuParam.getQuantity())
|
.quantity(skuParam.getQuantity())
|
||||||
|
|
|
||||||
|
|
@ -61,7 +61,7 @@ public class RetailOrderPostageServiceImpl implements IRetailOrderPostageService
|
||||||
public String calculatePostage(BigDecimal freePostage, Map<Integer, List<SaOrderItems>> postageMap, RetailOrderParam orderParam) {
|
public String calculatePostage(BigDecimal freePostage, Map<Integer, List<SaOrderItems>> postageMap, RetailOrderParam orderParam) {
|
||||||
// 处理邮费
|
// 处理邮费
|
||||||
if (ESpecialArea.RETAIL_REGISTER.getValue() == orderParam.getSpecialArea()) {
|
if (ESpecialArea.RETAIL_REGISTER.getValue() == orderParam.getSpecialArea()) {
|
||||||
// 会员专区(注册、升级)免邮费
|
// 精品专区免邮费
|
||||||
orderParam.setPostage(BigDecimal.ZERO);
|
orderParam.setPostage(BigDecimal.ZERO);
|
||||||
} else {
|
} else {
|
||||||
// 其它专区计算邮费
|
// 其它专区计算邮费
|
||||||
|
|
|
||||||
|
|
@ -26,6 +26,7 @@ import com.hzs.common.domain.sale.order.*;
|
||||||
import com.hzs.common.domain.sale.product.BdProduct;
|
import com.hzs.common.domain.sale.product.BdProduct;
|
||||||
import com.hzs.common.domain.sale.wares.BdWaresRange;
|
import com.hzs.common.domain.sale.wares.BdWaresRange;
|
||||||
import com.hzs.common.domain.system.base.BdStorehouse;
|
import com.hzs.common.domain.system.base.BdStorehouse;
|
||||||
|
import com.hzs.common.domain.system.config.BdAwards;
|
||||||
import com.hzs.common.domain.system.config.BdGrade;
|
import com.hzs.common.domain.system.config.BdGrade;
|
||||||
import com.hzs.common.security.utils.SecurityUtils;
|
import com.hzs.common.security.utils.SecurityUtils;
|
||||||
import com.hzs.member.account.IMemberAccountServiceApi;
|
import com.hzs.member.account.IMemberAccountServiceApi;
|
||||||
|
|
@ -39,7 +40,6 @@ import com.hzs.sale.order.param.OrderItemsParam;
|
||||||
import com.hzs.sale.order.param.WaresNumberParam;
|
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.order.service.impl.SaOrderServiceImpl;
|
|
||||||
import com.hzs.sale.product.service.IBdProductService;
|
import com.hzs.sale.product.service.IBdProductService;
|
||||||
import com.hzs.sale.wares.service.IBdWaresDetailService;
|
import com.hzs.sale.wares.service.IBdWaresDetailService;
|
||||||
import com.hzs.sale.wares.service.IBdWaresExtendService;
|
import com.hzs.sale.wares.service.IBdWaresExtendService;
|
||||||
|
|
@ -49,7 +49,6 @@ import com.hzs.system.base.dto.CurrencyDTO;
|
||||||
import com.hzs.system.config.IAwardsServiceApi;
|
import com.hzs.system.config.IAwardsServiceApi;
|
||||||
import com.hzs.system.config.IGradeServiceApi;
|
import com.hzs.system.config.IGradeServiceApi;
|
||||||
import com.hzs.system.config.dto.GradeDTO;
|
import com.hzs.system.config.dto.GradeDTO;
|
||||||
import com.hzs.third.sms.ISmsServiceApi;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.apache.dubbo.config.annotation.DubboReference;
|
import org.apache.dubbo.config.annotation.DubboReference;
|
||||||
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
||||||
|
|
@ -106,8 +105,6 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
|
||||||
IMemberServiceApi iMemberServiceApi;
|
IMemberServiceApi iMemberServiceApi;
|
||||||
@DubboReference
|
@DubboReference
|
||||||
IMemberAccountServiceApi iMemberAccountServiceApi;
|
IMemberAccountServiceApi iMemberAccountServiceApi;
|
||||||
@DubboReference
|
|
||||||
ISmsServiceApi iSmsServiceApi;
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String confirmRegOrder(RetailOrderRegisterParam registerParam, List<BdGrade> gradeList) {
|
public String confirmRegOrder(RetailOrderRegisterParam registerParam, List<BdGrade> gradeList) {
|
||||||
|
|
@ -115,9 +112,9 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
|
||||||
CuMember newMember = new CuMember();
|
CuMember newMember = new CuMember();
|
||||||
newMember.setMemberName(registerParam.getMemberName());
|
newMember.setMemberName(registerParam.getMemberName());
|
||||||
newMember.setPhone(registerParam.getPhone());
|
newMember.setPhone(registerParam.getPhone());
|
||||||
newMember.setPkSettleGrade(gradeList.get(0).getPkId());
|
newMember.setPkSettleCountry(CountryConstants.CHINA_COUNTRY);
|
||||||
newMember.setPkSettleCountry(1);
|
// newMember.setPkSettleGrade(gradeList.get(0).getPkId());
|
||||||
newMember.setPkAwards(1);
|
// newMember.setPkAwards(gradeList.get(0).getPkAwards());
|
||||||
// 封装订单信息
|
// 封装订单信息
|
||||||
SaOrderExt saOrderExt = this.createSaOrder(registerParam, gradeList, newMember);
|
SaOrderExt saOrderExt = this.createSaOrder(registerParam, gradeList, newMember);
|
||||||
|
|
||||||
|
|
@ -213,21 +210,39 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
|
||||||
if (null != cuMember) {
|
if (null != cuMember) {
|
||||||
cuMember.setPkSettleGrade(newGrade.getPkId());
|
cuMember.setPkSettleGrade(newGrade.getPkId());
|
||||||
cuMember.setPkAwards(newGrade.getPkAwards());
|
cuMember.setPkAwards(newGrade.getPkAwards());
|
||||||
// if (null == cuMember.getPkAwards()) {
|
if (null == cuMember.getPkAwards()) {
|
||||||
// // 新会员没有奖衔,则进行赋值
|
// 新会员没有奖衔,则进行赋值
|
||||||
// cuMember.setPkAwards(newGrade.getPkAwards());
|
cuMember.setPkAwards(newGrade.getPkAwards());
|
||||||
// } else {
|
} else {
|
||||||
// // 老会员奖衔如果为无,也进行赋值
|
// 老会员奖衔如果为无,也进行赋值
|
||||||
// BdAwards bdAwards = iAwardsServiceApi.getAwardsOne(cuMember.getPkAwards()).getData();
|
BdAwards bdAwards = iAwardsServiceApi.getAwardsOne(cuMember.getPkAwards()).getData();
|
||||||
// if (EAwards.MEMBER.getValue() == bdAwards.getAwardsValue()
|
if (EAwards.MEMBER.getValue() == bdAwards.getAwardsValue()
|
||||||
// && EAwards.MEMBER.getValue() != newGrade.getPkAwards()) {
|
&& EAwards.MEMBER.getValue() != newGrade.getPkAwards()) {
|
||||||
// cuMember.setPkAwards(newGrade.getPkAwards());
|
cuMember.setPkAwards(newGrade.getPkAwards());
|
||||||
// }
|
}
|
||||||
// }
|
}
|
||||||
}
|
}
|
||||||
} else if (ESpecialArea.RETAIL_REPURCHASE.getValue() == orderParam.getSpecialArea()) {
|
} else if (ESpecialArea.RETAIL_REPURCHASE.getValue() == orderParam.getSpecialArea()) {
|
||||||
// saOrderExt.setOrderAmount(saOrderExt.getOrderAmount().add(orderParam.getPostage()));
|
// saOrderExt.setOrderAmount(saOrderExt.getOrderAmount().add(orderParam.getPostage()));
|
||||||
saOrderExt.setPostage(orderParam.getPostage());
|
saOrderExt.setPostage(orderParam.getPostage());
|
||||||
|
// 会员信息
|
||||||
|
if (null != cuMember) {
|
||||||
|
if (null == cuMember.getPkSettleGrade()) {
|
||||||
|
// 注册、升级订单,计算会员等级
|
||||||
|
BdGrade newGrade = this.calculateGrade(orderParam.getSpecialArea(), orderParam.getOrderItemsParams(),
|
||||||
|
gradeList, cuMember, orderAchieve);
|
||||||
|
if (null == newGrade) {
|
||||||
|
throw new ServiceException("会员不满足升级条件");
|
||||||
|
}
|
||||||
|
saOrderExt.setPkGrade(newGrade.getPkId());
|
||||||
|
cuMember.setPkSettleGrade(newGrade.getPkId());
|
||||||
|
|
||||||
|
if (null == cuMember.getPkAwards()) {
|
||||||
|
// 会员没有奖衔,则进行赋值
|
||||||
|
cuMember.setPkAwards(newGrade.getPkAwards());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
} else if (ESpecialArea.RETAIL_UPGRADE.getValue() == orderParam.getSpecialArea()) {
|
} else if (ESpecialArea.RETAIL_UPGRADE.getValue() == orderParam.getSpecialArea()) {
|
||||||
saOrderExt.setSpecialArea(ESpecialArea.RETAIL_UPGRADE.getValue());
|
saOrderExt.setSpecialArea(ESpecialArea.RETAIL_UPGRADE.getValue());
|
||||||
saOrderExt.setOrderType(ESpecialArea.RETAIL_UPGRADE.getValue());
|
saOrderExt.setOrderType(ESpecialArea.RETAIL_UPGRADE.getValue());
|
||||||
|
|
@ -257,14 +272,10 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
|
||||||
// 邮费模板map(key:邮费模板ID,value:邮费订单明细)
|
// 邮费模板map(key:邮费模板ID,value:邮费订单明细)
|
||||||
Map<Integer, List<SaOrderItems>> postageMap = new HashMap<>(ComputeUtil.mapInitCapacity(waresDetailExtList.size()));
|
Map<Integer, List<SaOrderItems>> postageMap = new HashMap<>(ComputeUtil.mapInitCapacity(waresDetailExtList.size()));
|
||||||
|
|
||||||
// 当前盒数
|
|
||||||
BigDecimal boxNum = BigDecimal.ZERO;
|
|
||||||
|
|
||||||
// 遍历生成订单明细数据
|
// 遍历生成订单明细数据
|
||||||
for (BdWaresDetailExt waresDetailExt : waresDetailExtList) {
|
for (BdWaresDetailExt waresDetailExt : waresDetailExtList) {
|
||||||
// 订单明细
|
// 订单明细
|
||||||
SaOrderItems orderItems = saOrderHandle.getSaOrderItems(cuMember, saOrderExt, currency, orderItemsList, waresDetailExt);
|
SaOrderItems orderItems = saOrderHandle.getSaOrderItems(cuMember, saOrderExt, currency, orderItemsList, waresDetailExt);
|
||||||
orderItems.setWaresBoxNum(null != waresDetailExt.getBoxNum() ? waresDetailExt.getBoxNum() : BigDecimal.ZERO);
|
|
||||||
|
|
||||||
// 不是赠品,需要累积包邮邮费
|
// 不是赠品,需要累积包邮邮费
|
||||||
if (EYesNo.NO.getIntValue() == waresDetailExt.getIsGift()) {
|
if (EYesNo.NO.getIntValue() == waresDetailExt.getIsGift()) {
|
||||||
|
|
@ -285,8 +296,7 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
|
||||||
if (null != saOrderExt) {
|
if (null != saOrderExt) {
|
||||||
// 订单邮费
|
// 订单邮费
|
||||||
saOrderExt.setPostage(orderParam.getPostage());
|
saOrderExt.setPostage(orderParam.getPostage());
|
||||||
// 订单指定商品盒数
|
saOrderExt.setBoxNum(BigDecimal.ZERO);
|
||||||
saOrderExt.setBoxNum(boxNum);
|
|
||||||
if (isCopy41List) {
|
if (isCopy41List) {
|
||||||
saOrderExt.setOrderType(ESpecialArea.RETAIL_UPGRADE.getValue());
|
saOrderExt.setOrderType(ESpecialArea.RETAIL_UPGRADE.getValue());
|
||||||
}
|
}
|
||||||
|
|
@ -350,7 +360,8 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
|
||||||
if (CollectionUtil.isNotEmpty(orderItemsParams)) {
|
if (CollectionUtil.isNotEmpty(orderItemsParams)) {
|
||||||
List<BdWaresDetailExt> waresDetailExtList = iBdWaresDetailService.queryWaresDetailByCondition(specialArea, ETransportType.LAND.getValue(), orderItemsParams, systemType);
|
List<BdWaresDetailExt> waresDetailExtList = iBdWaresDetailService.queryWaresDetailByCondition(specialArea, ETransportType.LAND.getValue(), orderItemsParams, systemType);
|
||||||
// 复购处理极差
|
// 复购处理极差
|
||||||
setWaresRange(specialArea, waresDetailExtList, cuMember);
|
// 2025.10.29 去掉级差处理,目前没有级差价格
|
||||||
|
// setWaresRange(specialArea, waresDetailExtList, cuMember);
|
||||||
if (waresDetailExtList.size() > 0) {
|
if (waresDetailExtList.size() > 0) {
|
||||||
bdWaresDetailExtList.addAll(waresDetailExtList);
|
bdWaresDetailExtList.addAll(waresDetailExtList);
|
||||||
}
|
}
|
||||||
|
|
@ -565,13 +576,6 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
|
||||||
throw new RuntimeException("会员注册失败");
|
throw new RuntimeException("会员注册失败");
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
|
||||||
// 发送会员注册成功短信
|
|
||||||
iSmsServiceApi.sendMemberRegister(newMember.getPhone(), EAliSmsTemplate.MEMBER_REGISTER,
|
|
||||||
newMember.getMemberCode(), newMember.getLoginPassword(), newMember.getPayPassword());
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.error("发送注册短信失败");
|
|
||||||
}
|
|
||||||
this.pushOrderMq(saOrderExt);
|
this.pushOrderMq(saOrderExt);
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
@ -839,17 +843,15 @@ public class RetailOrderServiceImpl implements IRetailOrderService {
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
private Boolean handleMemberActivate(CuMember cuMember, SaOrderExt saOrder) {
|
private Boolean handleMemberActivate(CuMember cuMember, SaOrderExt saOrder) {
|
||||||
if ((null == cuMember.getIsActivate() || EYesNo.YES.getIntValue() != cuMember.getIsActivate())
|
if (EOrderType.RETAIL_REGISTER.getValue() == saOrder.getOrderType()
|
||||||
&& (EOrderType.RETAIL_REGISTER.getValue() == saOrder.getOrderType() || EOrderType.RETAIL_REPURCHASE.getValue() == saOrder.getOrderType())
|
|| EOrderType.RETAIL_UPGRADE.getValue() == saOrder.getOrderType()
|
||||||
) {
|
|| EOrderType.RETAIL_REPURCHASE.getValue() == saOrder.getOrderType()) {
|
||||||
// 会员激活状态为空 或 未激活,并且是 注册、升级 订单,判断会员是否激活
|
|
||||||
// 存在指定盒数商品
|
|
||||||
cuMember.setIsActivate(EYesNo.YES.getIntValue());
|
cuMember.setIsActivate(EYesNo.YES.getIntValue());
|
||||||
if (EPayStatus.UNPAID.getValue() == cuMember.getPayStatus()) {
|
if (EPayStatus.UNPAID.getValue() == cuMember.getPayStatus()) {
|
||||||
cuMember.setPayTime(saOrder.getPayTime());
|
cuMember.setPayTime(saOrder.getPayTime());
|
||||||
cuMember.setPayStatus(EPayStatus.PAID.getValue());
|
cuMember.setPayStatus(EPayStatus.PAID.getValue());
|
||||||
|
return true;
|
||||||
}
|
}
|
||||||
return true;
|
|
||||||
}
|
}
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -9,28 +9,22 @@ 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.CommonUtil;
|
import com.hzs.common.core.utils.CommonUtil;
|
||||||
import com.hzs.common.core.utils.ComputeUtil;
|
import com.hzs.common.core.utils.ComputeUtil;
|
||||||
import com.hzs.common.core.utils.DateUtils;
|
|
||||||
import com.hzs.common.core.utils.StringUtils;
|
import com.hzs.common.core.utils.StringUtils;
|
||||||
import com.hzs.common.core.utils.reflect.ReflectUtils;
|
import com.hzs.common.core.utils.reflect.ReflectUtils;
|
||||||
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;
|
||||||
import com.hzs.common.domain.member.ext.CuMemberTeamExt;
|
|
||||||
import com.hzs.common.domain.sale.ext.BdPostageFailAreaExt;
|
import com.hzs.common.domain.sale.ext.BdPostageFailAreaExt;
|
||||||
import com.hzs.common.domain.sale.ext.BdWaresDetailExt;
|
import com.hzs.common.domain.sale.ext.BdWaresDetailExt;
|
||||||
import com.hzs.common.domain.sale.ext.SaOrderExt;
|
import com.hzs.common.domain.sale.ext.SaOrderExt;
|
||||||
import com.hzs.common.domain.sale.order.SaOrder;
|
|
||||||
import com.hzs.common.domain.sale.order.SaOrderItems;
|
import com.hzs.common.domain.sale.order.SaOrderItems;
|
||||||
import com.hzs.common.domain.sale.postage.BdPostage;
|
import com.hzs.common.domain.sale.postage.BdPostage;
|
||||||
import com.hzs.common.domain.sale.postage.BdPostageArea;
|
import com.hzs.common.domain.sale.postage.BdPostageArea;
|
||||||
import com.hzs.common.domain.sale.postage.BdPostageDetail;
|
import com.hzs.common.domain.sale.postage.BdPostageDetail;
|
||||||
import com.hzs.common.domain.sale.product.BdProduct;
|
import com.hzs.common.domain.sale.product.BdProduct;
|
||||||
import com.hzs.common.domain.sale.wares.BdWaresRange;
|
import com.hzs.common.domain.sale.wares.BdWaresRange;
|
||||||
import com.hzs.common.domain.system.base.BdStorehouse;
|
|
||||||
import com.hzs.common.domain.system.config.BdAreaFreePostage;
|
import com.hzs.common.domain.system.config.BdAreaFreePostage;
|
||||||
import com.hzs.common.domain.system.config.BdAwards;
|
import com.hzs.common.domain.system.config.BdAwards;
|
||||||
import com.hzs.common.security.utils.SecurityUtils;
|
|
||||||
import com.hzs.common.util.TransactionUtils;
|
import com.hzs.common.util.TransactionUtils;
|
||||||
import com.hzs.member.base.IMemberTeamServiceApi;
|
|
||||||
import com.hzs.sale.order.param.OrderParam;
|
import com.hzs.sale.order.param.OrderParam;
|
||||||
import com.hzs.sale.order.vo.SaOrderVO;
|
import com.hzs.sale.order.vo.SaOrderVO;
|
||||||
import com.hzs.sale.postage.service.IBdPostageAreaService;
|
import com.hzs.sale.postage.service.IBdPostageAreaService;
|
||||||
|
|
@ -46,9 +40,7 @@ import com.hzs.system.base.ISystemConfigServiceApi;
|
||||||
import com.hzs.system.base.dto.CurrencyDTO;
|
import com.hzs.system.base.dto.CurrencyDTO;
|
||||||
import com.hzs.system.config.IAreaFreePostageServiceApi;
|
import com.hzs.system.config.IAreaFreePostageServiceApi;
|
||||||
import com.hzs.system.config.IAwardsServiceApi;
|
import com.hzs.system.config.IAwardsServiceApi;
|
||||||
import com.hzs.system.config.IGradeServiceApi;
|
|
||||||
import com.hzs.system.config.dto.AreaCurrencyDTO;
|
import com.hzs.system.config.dto.AreaCurrencyDTO;
|
||||||
import com.hzs.system.config.dto.GradeDTO;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
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;
|
||||||
|
|
@ -581,6 +573,7 @@ public class SaOrderHandle {
|
||||||
.pkSupplier(waresDetailExt.getPkSupplier())
|
.pkSupplier(waresDetailExt.getPkSupplier())
|
||||||
.skuCode(CommonUtil.createSkuCode(waresDetailExt.getProductCode(), waresDetailExt.getSpecsNameId()))
|
.skuCode(CommonUtil.createSkuCode(waresDetailExt.getProductCode(), waresDetailExt.getSpecsNameId()))
|
||||||
.wareCode(waresDetailExt.getWaresCode())
|
.wareCode(waresDetailExt.getWaresCode())
|
||||||
|
.waresBoxNum(BigDecimal.ZERO)
|
||||||
.build();
|
.build();
|
||||||
if (saOrderItems.getIsGift() != null && EYesNo.YES.getIntValue() == saOrderItems.getIsGift()) {
|
if (saOrderItems.getIsGift() != null && EYesNo.YES.getIntValue() == saOrderItems.getIsGift()) {
|
||||||
// 赠品不计算金额、业绩等
|
// 赠品不计算金额、业绩等
|
||||||
|
|
|
||||||
|
|
@ -87,23 +87,23 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
|
||||||
@DubboReference
|
@DubboReference
|
||||||
IMemberServiceApi iMemberServiceApi;
|
IMemberServiceApi iMemberServiceApi;
|
||||||
@DubboReference
|
@DubboReference
|
||||||
IMemberBankServiceApi memberBankServiceApi;
|
IMemberBankServiceApi iMemberBankServiceApi;
|
||||||
@DubboReference
|
@DubboReference
|
||||||
IMemberAccountServiceApi memberAccountServiceApi;
|
IMemberAccountServiceApi iMemberAccountServiceApi;
|
||||||
@DubboReference
|
@DubboReference
|
||||||
IAreaCurrencyServiceApi areaCurrencyServiceApi;
|
IAreaCurrencyServiceApi iAreaCurrencyServiceApi;
|
||||||
@DubboReference
|
@DubboReference
|
||||||
ICountryServiceApi countryServiceApi;
|
ICountryServiceApi iCountryServiceApi;
|
||||||
@DubboReference
|
@DubboReference
|
||||||
ICurrencyServiceApi currencyServiceApi;
|
ICurrencyServiceApi iCurrencyServiceApi;
|
||||||
@DubboReference
|
@DubboReference
|
||||||
IApprovalServiceApi approvalServiceApi;
|
IApprovalServiceApi iApprovalServiceApi;
|
||||||
@DubboReference
|
@DubboReference
|
||||||
ISystemConfigServiceApi systemConfigServiceApi;
|
ISystemConfigServiceApi iSystemConfigServiceApi;
|
||||||
@DubboReference
|
@DubboReference
|
||||||
ICuMemberServiceLogServiceApi cuMemberServiceLogServiceApi;
|
ICuMemberServiceLogServiceApi iCuMemberServiceLogServiceApi;
|
||||||
@DubboReference
|
@DubboReference
|
||||||
IMemberTradeServiceApi memberTradeServiceApi;
|
IMemberTradeServiceApi iMemberTradeServiceApi;
|
||||||
@DubboReference
|
@DubboReference
|
||||||
IGradeServiceApi iGradeServiceApi;
|
IGradeServiceApi iGradeServiceApi;
|
||||||
|
|
||||||
|
|
@ -207,7 +207,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
|
||||||
|
|
@ -232,13 +232,13 @@ 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();
|
||||||
|
|
||||||
// 验证是否是跨国保单,登录结算国!=结算国,跨国报单修改支付金额
|
// 验证是否是跨国保单,登录结算国!=结算国,跨国报单修改支付金额
|
||||||
if (!Objects.equals(cuMemberAccount.getPkCountry(), saOrder.getPkCountry())) {
|
if (!Objects.equals(cuMemberAccount.getPkCountry(), saOrder.getPkCountry())) {
|
||||||
// 结算国当地币 转美金 美金登录当地币
|
// 结算国当地币 转美金 美金登录当地币
|
||||||
CurrencyDTO loginCountryCurrency = currencyServiceApi.getCurrency(cuMemberAccount.getPkCountry()).getData();
|
CurrencyDTO loginCountryCurrency = iCurrencyServiceApi.getCurrency(cuMemberAccount.getPkCountry()).getData();
|
||||||
CurrencyDTO settleCountryCurrency = currencyServiceApi.getCurrency(saOrder.getPkCountry()).getData();
|
CurrencyDTO settleCountryCurrency = iCurrencyServiceApi.getCurrency(saOrder.getPkCountry()).getData();
|
||||||
if (settleCountryCurrency.getInExchangeRate().compareTo(loginCountryCurrency.getInExchangeRate()) != 0) {
|
if (settleCountryCurrency.getInExchangeRate().compareTo(loginCountryCurrency.getInExchangeRate()) != 0) {
|
||||||
// 订单结算国与登录结算国汇率不相同才进行处理
|
// 订单结算国与登录结算国汇率不相同才进行处理
|
||||||
payMoney = ComputeUtil.computeMultiply(ComputeUtil.computeDivide(payMoney, settleCountryCurrency.getInExchangeRate()), loginCountryCurrency.getInExchangeRate());
|
payMoney = ComputeUtil.computeMultiply(ComputeUtil.computeDivide(payMoney, settleCountryCurrency.getInExchangeRate()), loginCountryCurrency.getInExchangeRate());
|
||||||
|
|
@ -252,7 +252,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;
|
||||||
}
|
}
|
||||||
|
|
@ -287,7 +287,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
|
||||||
if (EOrderType.REGISTER_ORDER.getValue() == saOrder.getOrderType()) {
|
if (EOrderType.REGISTER_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));
|
||||||
|
|
@ -474,7 +474,7 @@ 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);
|
||||||
|
|
@ -495,12 +495,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));
|
||||||
|
|
@ -513,7 +513,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));
|
||||||
}
|
}
|
||||||
|
|
@ -533,7 +533,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());
|
||||||
|
|
@ -605,7 +605,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;
|
||||||
}
|
}
|
||||||
|
|
@ -823,7 +823,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
|
||||||
|
|
@ -995,7 +995,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);
|
||||||
|
|
@ -1004,14 +1004,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());
|
||||||
|
|
@ -1026,7 +1026,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);
|
||||||
}
|
}
|
||||||
|
|
@ -1035,9 +1035,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) {
|
||||||
|
|
@ -1088,7 +1088,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
|
||||||
public CuMemberMyMarketVO selectMyMarket(Long pkMember, Integer pkCountry) {
|
public CuMemberMyMarketVO selectMyMarket(Long pkMember, Integer pkCountry) {
|
||||||
//查询全国市场
|
//查询全国市场
|
||||||
CuMemberMyMarketVO cuMemberMyMarketVO = baseMapper.selectMyMarket(null, pkCountry);
|
CuMemberMyMarketVO cuMemberMyMarketVO = baseMapper.selectMyMarket(null, pkCountry);
|
||||||
CountryDTO country = countryServiceApi.getCountry(pkCountry).getData();
|
CountryDTO country = iCountryServiceApi.getCountry(pkCountry).getData();
|
||||||
//查询市场分布
|
//查询市场分布
|
||||||
List<CuMemberMyMarketDetailVO> cuMemberMyMarketDetailVOList = baseMapper.selectMyMarketDetail(pkMember, pkCountry);
|
List<CuMemberMyMarketDetailVO> cuMemberMyMarketDetailVOList = baseMapper.selectMyMarketDetail(pkMember, pkCountry);
|
||||||
cuMemberMyMarketVO.setMyMarketDetailVOList(cuMemberMyMarketDetailVOList);
|
cuMemberMyMarketVO.setMyMarketDetailVOList(cuMemberMyMarketDetailVOList);
|
||||||
|
|
@ -1221,10 +1221,10 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
|
||||||
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 {
|
||||||
|
|
@ -1234,7 +1234,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;
|
||||||
|
|
@ -1281,7 +1281,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
|
||||||
if (EOrderType.RETAIL_REGISTER.getValue() == saOrder.getOrderType()) {
|
if (EOrderType.RETAIL_REGISTER.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));
|
||||||
|
|
@ -1408,6 +1408,23 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (EOrderType.RETAIL_REGISTER.getValue() == saOrderExt.getOrderType()
|
||||||
|
|| EOrderType.RETAIL_UPGRADE.getValue() == saOrderExt.getOrderType()
|
||||||
|
|| EOrderType.RETAIL_REPURCHASE.getValue() == saOrderExt.getOrderType()) {
|
||||||
|
// 判断处理支付状态和时间
|
||||||
|
Date firstPayTime = baseMapper.getFirstPayTime(saOrderExt.getPkMember());
|
||||||
|
if (null == firstPayTime) {
|
||||||
|
cuMember.setPayTime(null);
|
||||||
|
cuMember.setPayStatus(EPayStatus.UNPAID.getValue());
|
||||||
|
saOrderExt.setUpdateFlag(EYesNo.YES.getIntValue());
|
||||||
|
} else {
|
||||||
|
if (firstPayTime.compareTo(cuMember.getPayTime()) < 0) {
|
||||||
|
cuMember.setPayTime(firstPayTime);
|
||||||
|
saOrderExt.setUpdateFlag(EYesNo.YES.getIntValue());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if (!iMemberServiceApi.normalRevokeOrder(pkApprove, saOrderExt, cuMember, businessCommissionDTO).getData()) {
|
if (!iMemberServiceApi.normalRevokeOrder(pkApprove, saOrderExt, cuMember, businessCommissionDTO).getData()) {
|
||||||
throw new ServiceException("撤单处理会员失败");
|
throw new ServiceException("撤单处理会员失败");
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -422,23 +422,24 @@ public class BdWaresSpecsSkuServiceImpl extends ServiceImpl<BdWaresSpecsSkuMappe
|
||||||
waresItemWaresInfo.setSkuInfo(StringUtils.join(specsNames, ","));
|
waresItemWaresInfo.setSkuInfo(StringUtils.join(specsNames, ","));
|
||||||
});
|
});
|
||||||
|
|
||||||
if (EOrderType.RETAIL_REPURCHASE.getValue() == specialArea
|
// 2025.10.29 去掉级差处理,目前没有级差价格
|
||||||
|| EOrderType.RETAIL_CONSUME.getValue() == specialArea) {
|
// if (EOrderType.RETAIL_REPURCHASE.getValue() == specialArea
|
||||||
// 2024.12.30 添加需求,复消也需要处理级差
|
// || EOrderType.RETAIL_CONSUME.getValue() == specialArea) {
|
||||||
CuMember cuMember = iSaOrderService.getCuMemberByKey(pkMember);
|
// // 2024.12.30 添加需求,复消也需要处理级差
|
||||||
int level = cuMember.getPkSettleGrade();
|
// CuMember cuMember = iSaOrderService.getCuMemberByKey(pkMember);
|
||||||
int rangeType = ERangeType.GRADE.getValue();
|
// int level = cuMember.getPkSettleGrade();
|
||||||
List<Integer> pkWaresSpecsSku = productGroup.stream().map(ProductGroup::getPkSkuId).collect(Collectors.toList());
|
// int rangeType = ERangeType.GRADE.getValue();
|
||||||
List<BdWaresRange> bdWaresRangeList = iBdWaresRangeService.querySkuWaresRangeByCondition(cuMember.getPkSettleCountry(), rangeType, level, pkWaresSpecsSku);
|
// List<Integer> pkWaresSpecsSku = productGroup.stream().map(ProductGroup::getPkSkuId).collect(Collectors.toList());
|
||||||
bdWaresRangeList.forEach(bdWaresRange -> {
|
// List<BdWaresRange> bdWaresRangeList = iBdWaresRangeService.querySkuWaresRangeByCondition(cuMember.getPkSettleCountry(), rangeType, level, pkWaresSpecsSku);
|
||||||
String key = bdWaresRange.getPkWaresDetail().toString() + bdWaresRange.getPkWaresSpecsSku();
|
// bdWaresRangeList.forEach(bdWaresRange -> {
|
||||||
if (waresDetailExtMap.containsKey(key)) {
|
// String key = bdWaresRange.getPkWaresDetail().toString() + bdWaresRange.getPkWaresSpecsSku();
|
||||||
waresDetailExtMap.get(key).setPrice(bdWaresRange.getPrice());
|
// if (waresDetailExtMap.containsKey(key)) {
|
||||||
waresDetailExtMap.get(key).setAchieve(bdWaresRange.getAchieve());
|
// waresDetailExtMap.get(key).setPrice(bdWaresRange.getPrice());
|
||||||
waresDetailExtMap.get(key).setAssAchieve(bdWaresRange.getAssAchieve());
|
// waresDetailExtMap.get(key).setAchieve(bdWaresRange.getAchieve());
|
||||||
}
|
// waresDetailExtMap.get(key).setAssAchieve(bdWaresRange.getAssAchieve());
|
||||||
});
|
// }
|
||||||
}
|
// });
|
||||||
|
// }
|
||||||
|
|
||||||
for (WaresItemWaresInfo waresItemWaresInfo : waresItemVo.getWaresItemsParamList()) {
|
for (WaresItemWaresInfo waresItemWaresInfo : waresItemVo.getWaresItemsParamList()) {
|
||||||
waresItemVo.setPrice(ComputeUtil.computeAdd(waresItemVo.getPrice(), ComputeUtil.computeMultiply(waresItemWaresInfo.getPrice(), waresItemWaresInfo.getQuantity())));
|
waresItemVo.setPrice(ComputeUtil.computeAdd(waresItemVo.getPrice(), ComputeUtil.computeMultiply(waresItemWaresInfo.getPrice(), waresItemWaresInfo.getQuantity())));
|
||||||
|
|
|
||||||
|
|
@ -1308,8 +1308,7 @@
|
||||||
where so.del_flag = 0
|
where so.del_flag = 0
|
||||||
and so.order_status = 1
|
and so.order_status = 1
|
||||||
and so.pk_member = #{pkMember}
|
and so.pk_member = #{pkMember}
|
||||||
and so.order_type in (41, 42)
|
and so.order_type in (41, 42, 43)
|
||||||
and so.box_num != 0
|
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
<select id="queryRefundList" resultType="com.hzs.common.domain.third.pay.ext.TOnlineRefundExt">
|
<select id="queryRefundList" resultType="com.hzs.common.domain.third.pay.ext.TOnlineRefundExt">
|
||||||
|
|
|
||||||
|
|
@ -365,7 +365,8 @@
|
||||||
bwss.pk_wares_detail,
|
bwss.pk_wares_detail,
|
||||||
bwss.price,
|
bwss.price,
|
||||||
bwss.achieve,
|
bwss.achieve,
|
||||||
bwss.ass_achieve
|
bwss.ass_achieve,
|
||||||
|
bwd.is_gift
|
||||||
from bd_wares_specs_sku bwss
|
from bd_wares_specs_sku bwss
|
||||||
left join BD_WARES_DETAIL bwd
|
left join BD_WARES_DETAIL bwd
|
||||||
on bwd.del_flag = 0
|
on bwd.del_flag = 0
|
||||||
|
|
|
||||||
|
|
@ -460,12 +460,6 @@ public class EnumsInitController {
|
||||||
for (EPayBusinessType value : EPayBusinessType.values()) {
|
for (EPayBusinessType value : EPayBusinessType.values()) {
|
||||||
initList.add(this.createData(value.getKey(), value.getLabel()));
|
initList.add(this.createData(value.getKey(), value.getLabel()));
|
||||||
}
|
}
|
||||||
/**
|
|
||||||
* 支付状态
|
|
||||||
*/
|
|
||||||
for (EPayStatus value : EPayStatus.values()) {
|
|
||||||
initList.add(this.createData(value.getKey(), value.getLabel()));
|
|
||||||
}
|
|
||||||
/**
|
/**
|
||||||
* 支付渠道
|
* 支付渠道
|
||||||
*/
|
*/
|
||||||
|
|
|
||||||
|
|
@ -5,42 +5,52 @@
|
||||||
|
|
||||||
<!-- 查询会员汇总数据 -->
|
<!-- 查询会员汇总数据 -->
|
||||||
<select id="getMemberBoard" resultType="com.hzs.system.board.vo.BoardMemberVO">
|
<select id="getMemberBoard" resultType="com.hzs.system.board.vo.BoardMemberVO">
|
||||||
select *
|
SELECT
|
||||||
from (select count(1) member_total
|
*
|
||||||
from cu_member cm
|
FROM
|
||||||
where cm.del_flag = 0
|
(
|
||||||
and cm.pay_status = 1
|
SELECT
|
||||||
and cm.category = 0
|
count(1) member_total
|
||||||
and cm.customer_type != 1) a
|
FROM
|
||||||
left join (
|
cu_member cm
|
||||||
select count(1) member_today
|
WHERE
|
||||||
from cu_member cm
|
cm.del_flag = 0
|
||||||
where cm.del_flag = 0
|
AND cm.category = 0
|
||||||
and cm.pay_status = 1
|
AND cm.PAY_TIME IS NOT NULL
|
||||||
and cm.category = 0
|
) a
|
||||||
and to_char(cm.pay_time, 'yyyy-mm-dd') =
|
LEFT JOIN (
|
||||||
to_char(sysdate, 'yyyy-mm-dd')
|
SELECT
|
||||||
and cm.customer_type != 1
|
count(1) member_today
|
||||||
) b on 1 = 1
|
FROM
|
||||||
left join (select count(1) member_yesterday
|
cu_member cm
|
||||||
from cu_member cm
|
WHERE
|
||||||
where cm.del_flag = 0
|
cm.del_flag = 0
|
||||||
and cm.pay_status = 1
|
AND cm.category = 0
|
||||||
and cm.category = 0
|
AND cm.PAY_TIME IS NOT NULL
|
||||||
and to_char(cm.pay_time, 'yyyy-mm-dd') =
|
AND to_char(cm.pay_time, 'yyyy-mm-dd') = to_char(SYSDATE, 'yyyy-mm-dd')
|
||||||
to_char(sysdate - 1, 'yyyy-mm-dd')
|
) b ON 1 = 1
|
||||||
and cm.customer_type != 1
|
LEFT JOIN (
|
||||||
) c
|
SELECT
|
||||||
on 1 = 1
|
count(1) member_yesterday
|
||||||
left join (select count(1) member_month
|
FROM
|
||||||
from cu_member cm
|
cu_member cm
|
||||||
where cm.del_flag = 0
|
WHERE
|
||||||
and cm.pay_status = 1
|
cm.del_flag = 0
|
||||||
and cm.category = 0
|
AND cm.category = 0
|
||||||
and to_char(cm.pay_time, 'yyyy-mm') =
|
AND cm.PAY_TIME IS NOT NULL
|
||||||
to_char(sysdate, 'yyyy-mm')
|
AND to_char(cm.pay_time, 'yyyy-mm-dd') = to_char(SYSDATE - 1, 'yyyy-mm-dd')
|
||||||
and cm.customer_type != 1
|
) c ON 1 = 1
|
||||||
) d on 1 = 1
|
LEFT JOIN (
|
||||||
|
SELECT
|
||||||
|
count(1) member_month
|
||||||
|
FROM
|
||||||
|
cu_member cm
|
||||||
|
WHERE
|
||||||
|
cm.del_flag = 0
|
||||||
|
AND cm.category = 0
|
||||||
|
AND cm.PAY_TIME IS NOT NULL
|
||||||
|
AND to_char(cm.pay_time, 'yyyy-mm') = to_char(SYSDATE, 'yyyy-mm')
|
||||||
|
) d ON 1 = 1
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
<!-- 会员各等级数据 -->
|
<!-- 会员各等级数据 -->
|
||||||
|
|
@ -49,53 +59,48 @@
|
||||||
bg.grade_value,
|
bg.grade_value,
|
||||||
nvl(a.member_total, 0) member_total,
|
nvl(a.member_total, 0) member_total,
|
||||||
0 sort
|
0 sort
|
||||||
from (select cm.PK_REGISTER_GRADE, count(1) member_total
|
from (select cm.PK_SETTLE_GRADE, count(1) member_total
|
||||||
from cu_member cm
|
from cu_member cm
|
||||||
where cm.del_flag = 0
|
WHERE cm.del_flag = 0
|
||||||
and cm.pay_status = 1
|
AND cm.category = 0
|
||||||
and cm.category = 0
|
AND cm.PAY_TIME IS NOT NULL
|
||||||
and to_char(cm.pay_time, 'yyyy-mm-dd') =
|
AND to_char(cm.PAY_TIME, 'yyyy-mm-dd') = to_char(SYSDATE, 'yyyy-mm-dd')
|
||||||
to_char(sysdate, 'yyyy-mm-dd')
|
group by cm.PK_SETTLE_GRADE
|
||||||
and cm.customer_type != 1
|
order by cm.PK_SETTLE_GRADE) a
|
||||||
group by cm.PK_REGISTER_GRADE
|
|
||||||
order by cm.PK_REGISTER_GRADE) a
|
|
||||||
right join bd_grade bg
|
right join bd_grade bg
|
||||||
on bg.pk_id = a.PK_REGISTER_GRADE
|
on bg.pk_id = a.PK_SETTLE_GRADE
|
||||||
where bg.del_flag = 0
|
where bg.del_flag = 0
|
||||||
union all
|
union all
|
||||||
select bg.grade_name,
|
select bg.grade_name,
|
||||||
bg.grade_value,
|
bg.grade_value,
|
||||||
nvl(a.member_total, 0) member_total,
|
nvl(a.member_total, 0) member_total,
|
||||||
1 sort
|
1 sort
|
||||||
from (select cm.PK_REGISTER_GRADE, count(1) member_total
|
from (select cm.PK_SETTLE_GRADE, count(1) member_total
|
||||||
from cu_member cm
|
from cu_member cm
|
||||||
where cm.del_flag = 0
|
WHERE cm.del_flag = 0
|
||||||
and cm.pay_status = 1
|
AND cm.category = 0
|
||||||
and cm.category = 0
|
AND cm.PAY_TIME IS NOT NULL
|
||||||
and to_char(cm.pay_time, 'yyyy-mm-dd') =
|
AND to_char(cm.PAY_TIME, 'yyyy-mm-dd') = to_char(SYSDATE - 1, 'yyyy-mm-dd')
|
||||||
to_char(sysdate - 1, 'yyyy-mm-dd')
|
group by cm.PK_SETTLE_GRADE
|
||||||
and cm.customer_type != 1
|
order by cm.PK_SETTLE_GRADE) a
|
||||||
group by cm.PK_REGISTER_GRADE
|
|
||||||
order by cm.PK_REGISTER_GRADE) a
|
|
||||||
right join bd_grade bg
|
right join bd_grade bg
|
||||||
on bg.pk_id = a.PK_REGISTER_GRADE
|
on bg.pk_id = a.PK_SETTLE_GRADE
|
||||||
where bg.del_flag = 0
|
where bg.del_flag = 0
|
||||||
union all
|
union all
|
||||||
select bg.grade_name,
|
select bg.grade_name,
|
||||||
bg.grade_value,
|
bg.grade_value,
|
||||||
nvl(a.member_total, 0) member_total,
|
nvl(a.member_total, 0) member_total,
|
||||||
2 sort
|
2 sort
|
||||||
from (select cm.PK_REGISTER_GRADE, count(1) member_total
|
from (select cm.PK_SETTLE_GRADE, count(1) member_total
|
||||||
from cu_member cm
|
from cu_member cm
|
||||||
where cm.del_flag = 0
|
WHERE cm.del_flag = 0
|
||||||
and cm.pay_status = 1
|
AND cm.category = 0
|
||||||
and cm.category = 0
|
AND cm.PAY_TIME IS NOT NULL
|
||||||
and to_char(cm.pay_time, 'yyyy-mm') = to_char(sysdate, 'yyyy-mm')
|
AND to_char(cm.PAY_TIME, 'yyyy-mm') = to_char(SYSDATE, 'yyyy-mm')
|
||||||
and cm.customer_type != 1
|
group by cm.PK_SETTLE_GRADE
|
||||||
group by cm.PK_REGISTER_GRADE
|
order by cm.PK_SETTLE_GRADE) a
|
||||||
order by cm.PK_REGISTER_GRADE) a
|
|
||||||
right join bd_grade bg
|
right join bd_grade bg
|
||||||
on bg.pk_id = a.PK_REGISTER_GRADE
|
on bg.pk_id = a.PK_SETTLE_GRADE
|
||||||
where bg.del_flag = 0
|
where bg.del_flag = 0
|
||||||
order by sort, grade_value
|
order by sort, grade_value
|
||||||
</select>
|
</select>
|
||||||
|
|
@ -103,48 +108,40 @@
|
||||||
<!-- 查询日业绩汇总数据 -->
|
<!-- 查询日业绩汇总数据 -->
|
||||||
<select id="getDayAchieve" resultType="com.hzs.system.board.vo.BoardAchieveVO">
|
<select id="getDayAchieve" resultType="com.hzs.system.board.vo.BoardAchieveVO">
|
||||||
select a.*, b.*, 0 sort
|
select a.*, b.*, 0 sort
|
||||||
from (
|
from (select nvl(sum(so.order_achieve), 0) first_achieve,
|
||||||
select nvl(sum(so.order_achieve), 0) first_achieve,
|
nvl(sum(so.order_amount), 0) first_amount
|
||||||
nvl(sum(so.order_amount), 0) first_amount
|
from sa_order so
|
||||||
from sa_order so
|
where so.del_flag = 0
|
||||||
where so.del_flag = 0
|
and so.order_status = 1
|
||||||
and so.order_status = 1
|
and so.order_type in (41, 42)
|
||||||
and so.order_type in (41, 42)
|
and to_char(so.pay_time, 'yyyy-mm-dd') =
|
||||||
and to_char(so.pay_time, 'yyyy-mm-dd') =
|
to_char(sysdate, 'yyyy-mm-dd')) a
|
||||||
to_char(sysdate, 'yyyy-mm-dd')
|
left join (select nvl(sum(so.order_achieve), 0) rep_achieve,
|
||||||
) a
|
nvl(sum(so.order_amount), 0) rep_amount
|
||||||
left join (
|
from sa_order so
|
||||||
select nvl(sum(so.order_achieve), 0) rep_achieve,
|
where so.del_flag = 0
|
||||||
nvl(sum(so.order_amount), 0) rep_amount
|
and so.order_status = 1
|
||||||
from sa_order so
|
and so.order_type in (43, 44, 47)
|
||||||
where so.del_flag = 0
|
and to_char(so.pay_time, 'yyyy-mm-dd') =
|
||||||
and so.order_status = 1
|
to_char(sysdate, 'yyyy-mm-dd')) b on 1 = 1
|
||||||
and so.order_type in (43, 44, 47)
|
|
||||||
and to_char(so.pay_time, 'yyyy-mm-dd') =
|
|
||||||
to_char(sysdate, 'yyyy-mm-dd')
|
|
||||||
) b on 1 = 1
|
|
||||||
union all
|
union all
|
||||||
select a.*, b.*, 1 sort
|
select a.*, b.*, 1 sort
|
||||||
from (
|
from (select nvl(sum(so.order_achieve), 0) first_achieve,
|
||||||
select nvl(sum(so.order_achieve), 0) first_achieve,
|
nvl(sum(so.order_amount), 0) first_amount
|
||||||
nvl(sum(so.order_amount), 0) first_amount
|
from sa_order so
|
||||||
from sa_order so
|
where so.del_flag = 0
|
||||||
where so.del_flag = 0
|
and so.order_status = 1
|
||||||
and so.order_status = 1
|
and so.order_type in (41, 42)
|
||||||
and so.order_type in (41, 42)
|
and to_char(so.pay_time, 'yyyy-mm-dd') =
|
||||||
and to_char(so.pay_time, 'yyyy-mm-dd') =
|
to_char(sysdate - 1, 'yyyy-mm-dd')) a
|
||||||
to_char(sysdate - 1, 'yyyy-mm-dd')
|
left join (select nvl(sum(so.order_achieve), 0) rep_achieve,
|
||||||
) a
|
nvl(sum(so.order_amount), 0) rep_amount
|
||||||
left join (
|
from sa_order so
|
||||||
select nvl(sum(so.order_achieve), 0) rep_achieve,
|
where so.del_flag = 0
|
||||||
nvl(sum(so.order_amount), 0) rep_amount
|
and so.order_status = 1
|
||||||
from sa_order so
|
and so.order_type in (43, 44, 47)
|
||||||
where so.del_flag = 0
|
and to_char(so.pay_time, 'yyyy-mm-dd') =
|
||||||
and so.order_status = 1
|
to_char(sysdate - 1, 'yyyy-mm-dd')) b on 1 = 1
|
||||||
and so.order_type in (43, 44, 47)
|
|
||||||
and to_char(so.pay_time, 'yyyy-mm-dd') =
|
|
||||||
to_char(sysdate - 1, 'yyyy-mm-dd')
|
|
||||||
) b on 1 = 1
|
|
||||||
order by sort
|
order by sort
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
|
|
@ -157,18 +154,15 @@
|
||||||
where so.del_flag = 0
|
where so.del_flag = 0
|
||||||
and so.order_status = 1
|
and so.order_status = 1
|
||||||
and so.order_type in (41, 42)
|
and so.order_type in (41, 42)
|
||||||
and to_char(so.pay_time, 'yyyy-mm') = to_char(sysdate, 'yyyy-mm')
|
and to_char(so.pay_time, 'yyyy-mm') = to_char(sysdate, 'yyyy-mm')) a
|
||||||
) a
|
left join (select nvl(sum(so.order_achieve), 0) rep_achieve,
|
||||||
left join (
|
nvl(sum(so.order_amount - nvl(so.CONSUME_AMOUNT, 0)), 0) rep_amount
|
||||||
select nvl(sum(so.order_achieve), 0) rep_achieve,
|
from sa_order so
|
||||||
nvl(sum(so.order_amount - nvl(so.CONSUME_AMOUNT, 0)), 0) rep_amount
|
where so.del_flag = 0
|
||||||
from sa_order so
|
and so.order_status = 1
|
||||||
where so.del_flag = 0
|
and so.order_type in (43, 44, 47)
|
||||||
and so.order_status = 1
|
and to_char(so.pay_time, 'yyyy-mm') =
|
||||||
and so.order_type in (43, 44, 47)
|
to_char(sysdate, 'yyyy-mm')) b on 1 = 1
|
||||||
and to_char(so.pay_time, 'yyyy-mm') =
|
|
||||||
to_char(sysdate, 'yyyy-mm')
|
|
||||||
) b on 1 = 1
|
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
<!-- 各币种充值数据 -->
|
<!-- 各币种充值数据 -->
|
||||||
|
|
|
||||||
|
|
@ -1,27 +1,23 @@
|
||||||
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;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 支付状态
|
* 支付状态
|
||||||
*
|
|
||||||
* @author: hzs
|
|
||||||
*/
|
*/
|
||||||
@AllArgsConstructor
|
@AllArgsConstructor
|
||||||
@Getter
|
@Getter
|
||||||
public enum EPayStatus {
|
public enum EPayStatus {
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 未支付
|
* 未支付
|
||||||
*/
|
*/
|
||||||
UNPAID(0, "未支付", EnumsPrefixConstants.PAY_STATUS + "0"),
|
UNPAID(0, "未支付"),
|
||||||
/**
|
/**
|
||||||
* 已支付
|
* 已支付
|
||||||
*/
|
*/
|
||||||
PAID(1, "已支付", EnumsPrefixConstants.PAY_STATUS + "1"),
|
PAID(1, "已支付"),
|
||||||
|
|
||||||
;
|
;
|
||||||
|
|
||||||
|
|
@ -33,9 +29,5 @@ public enum EPayStatus {
|
||||||
* 显示标签
|
* 显示标签
|
||||||
*/
|
*/
|
||||||
private final String label;
|
private final String label;
|
||||||
/**
|
|
||||||
* 国际化翻译key值
|
|
||||||
*/
|
|
||||||
private final String key;
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -19,10 +19,10 @@ public enum ETradeType {
|
||||||
MALL_ORDER(114, 0, "商城订单", 0, EnumsPrefixConstants.TRADE_TYPE + 114, EOrderType.MALL_ORDER.getValue()),
|
MALL_ORDER(114, 0, "商城订单", 0, EnumsPrefixConstants.TRADE_TYPE + 114, EOrderType.MALL_ORDER.getValue()),
|
||||||
FICTITIOUS_ORDER(120, 0, "虚拟订单", 0, EnumsPrefixConstants.TRADE_TYPE + 120, EOrderType.FICTITIOUS_ORDER.getValue()),
|
FICTITIOUS_ORDER(120, 0, "虚拟订单", 0, EnumsPrefixConstants.TRADE_TYPE + 120, EOrderType.FICTITIOUS_ORDER.getValue()),
|
||||||
|
|
||||||
RETAIL_REGISTER_ORDER(141, 0, "注册订单", 0, EnumsPrefixConstants.TRADE_TYPE + 141, EOrderType.RETAIL_REGISTER.getValue()),
|
RETAIL_REGISTER_ORDER(141, 0, "精品专区订单", 0, EnumsPrefixConstants.TRADE_TYPE + 141, EOrderType.RETAIL_REGISTER.getValue()),
|
||||||
RETAIL_UPGRADE_ORDER(142, 0, "甄选订单", 0, EnumsPrefixConstants.TRADE_TYPE + 142, EOrderType.RETAIL_UPGRADE.getValue()),
|
RETAIL_UPGRADE_ORDER(142, 0, "复购专区订单", 0, EnumsPrefixConstants.TRADE_TYPE + 142, EOrderType.RETAIL_UPGRADE.getValue()),
|
||||||
RETAIL_REPURCHASE_ORDER(143, 0, "复购订单", 0, EnumsPrefixConstants.TRADE_TYPE + 143, EOrderType.RETAIL_REPURCHASE.getValue()),
|
RETAIL_REPURCHASE_ORDER(143, 0, "北大甄选订单", 0, EnumsPrefixConstants.TRADE_TYPE + 143, EOrderType.RETAIL_REPURCHASE.getValue()),
|
||||||
RETAIL_CONSUME_ORDER(144, 0, "赠品订单", 0, EnumsPrefixConstants.TRADE_TYPE + 144, EOrderType.RETAIL_CONSUME.getValue()),
|
RETAIL_CONSUME_ORDER(144, 0, "赠品专区订单", 0, EnumsPrefixConstants.TRADE_TYPE + 144, EOrderType.RETAIL_CONSUME.getValue()),
|
||||||
RETAIL_TICKET_ORDER(145, 0, "自主购票", 0, EnumsPrefixConstants.TRADE_TYPE + 145, EOrderType.RETAIL_TICKET.getValue()),
|
RETAIL_TICKET_ORDER(145, 0, "自主购票", 0, EnumsPrefixConstants.TRADE_TYPE + 145, EOrderType.RETAIL_TICKET.getValue()),
|
||||||
RETAIL_DISCOUNT_ORDER(147, 0, "五折订单", 0, EnumsPrefixConstants.TRADE_TYPE + 147, EOrderType.DISCOUNT_ORDER.getValue()),
|
RETAIL_DISCOUNT_ORDER(147, 0, "五折订单", 0, EnumsPrefixConstants.TRADE_TYPE + 147, EOrderType.DISCOUNT_ORDER.getValue()),
|
||||||
|
|
||||||
|
|
@ -69,14 +69,12 @@ public enum ETradeType {
|
||||||
REVOKE_MALL_ORDER(615, 0, "商城订单撤单返钱", 0, EnumsPrefixConstants.TRADE_TYPE + 615, -EOrderType.MALL_ORDER.getValue()),
|
REVOKE_MALL_ORDER(615, 0, "商城订单撤单返钱", 0, EnumsPrefixConstants.TRADE_TYPE + 615, -EOrderType.MALL_ORDER.getValue()),
|
||||||
REVOKE_FICTITIOUS_ORDER(618, 0, "虚拟订单撤单返钱", 0, EnumsPrefixConstants.TRADE_TYPE + 618, -EOrderType.FICTITIOUS_ORDER.getValue()),
|
REVOKE_FICTITIOUS_ORDER(618, 0, "虚拟订单撤单返钱", 0, EnumsPrefixConstants.TRADE_TYPE + 618, -EOrderType.FICTITIOUS_ORDER.getValue()),
|
||||||
|
|
||||||
REVOKE_RETAIL_REGISTER_ORDER(641, 0, "注册订单撤单", 0, EnumsPrefixConstants.TRADE_TYPE + 641, -EOrderType.RETAIL_REGISTER.getValue()),
|
REVOKE_RETAIL_REGISTER_ORDER(641, 0, "精品专区订单撤单", 0, EnumsPrefixConstants.TRADE_TYPE + 641, -EOrderType.RETAIL_REGISTER.getValue()),
|
||||||
REVOKE_RETAIL_REPURCHASE_ORDER(643, 0, "复购订单撤单", 0, EnumsPrefixConstants.TRADE_TYPE + 643, -EOrderType.RETAIL_REPURCHASE.getValue()),
|
REVOKE_RETAIL_UPGRADE(642, 0, "复购专区订单撤单", 0, EnumsPrefixConstants.TRADE_TYPE + 642, -EOrderType.RETAIL_UPGRADE.getValue()),
|
||||||
REVOKE_RETAIL_CONSUME_ORDER(644, 0, "赠品订单撤单", 0, EnumsPrefixConstants.TRADE_TYPE + 644, -EOrderType.RETAIL_CONSUME.getValue()),
|
REVOKE_RETAIL_REPURCHASE_ORDER(643, 0, "北大甄选订单撤单", 0, EnumsPrefixConstants.TRADE_TYPE + 643, -EOrderType.RETAIL_REPURCHASE.getValue()),
|
||||||
|
REVOKE_RETAIL_CONSUME_ORDER(644, 0, "赠品专区订单撤单", 0, EnumsPrefixConstants.TRADE_TYPE + 644, -EOrderType.RETAIL_CONSUME.getValue()),
|
||||||
REVOKE_RETAIL_TICKET_ORDER(645, 0, "自主购票撤单", 0, EnumsPrefixConstants.TRADE_TYPE + 645, -EOrderType.RETAIL_TICKET.getValue()),
|
REVOKE_RETAIL_TICKET_ORDER(645, 0, "自主购票撤单", 0, EnumsPrefixConstants.TRADE_TYPE + 645, -EOrderType.RETAIL_TICKET.getValue()),
|
||||||
|
REVOKE_DISCOUNT_ORDER(647, 0, "五折专区订单撤单", 0, EnumsPrefixConstants.TRADE_TYPE + 647, -EOrderType.DISCOUNT_ORDER.getValue()),
|
||||||
REVOKE_RETAIL_UPGRADE(642, 0, "甄选订单撤单", 0, EnumsPrefixConstants.TRADE_TYPE + 642, -EOrderType.RETAIL_UPGRADE.getValue()),
|
|
||||||
REVOKE_DISCOUNT_ORDER(647, 0, "五折订单撤单", 0, EnumsPrefixConstants.TRADE_TYPE + 647, -EOrderType.DISCOUNT_ORDER.getValue()),
|
|
||||||
|
|
||||||
ORDER_SELF_DELIVER(680, 0, "自提返还邮费", 0, EnumsPrefixConstants.TRADE_TYPE + 680, -99),
|
ORDER_SELF_DELIVER(680, 0, "自提返还邮费", 0, EnumsPrefixConstants.TRADE_TYPE + 680, -99),
|
||||||
|
|
||||||
ORDER_REFUND_ADJUST(690, 0, "退单金额补差", 0, EnumsPrefixConstants.TRADE_TYPE + 690, -99),
|
ORDER_REFUND_ADJUST(690, 0, "退单金额补差", 0, EnumsPrefixConstants.TRADE_TYPE + 690, -99),
|
||||||
|
|
@ -177,7 +175,10 @@ public enum ETradeType {
|
||||||
* @param value
|
* @param value
|
||||||
* @return String
|
* @return String
|
||||||
*/
|
*/
|
||||||
public static String getTradeLabel(int value) {
|
public static String getTradeLabel(Integer value) {
|
||||||
|
if (null == value) {
|
||||||
|
return "";
|
||||||
|
}
|
||||||
for (ETradeType type : ETradeType.values()) {
|
for (ETradeType type : ETradeType.values()) {
|
||||||
if (type.getValue() == value) {
|
if (type.getValue() == value) {
|
||||||
return type.getLabel();
|
return type.getLabel();
|
||||||
|
|
|
||||||
|
|
@ -8,11 +8,7 @@ import java.math.BigDecimal;
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @Description: sku扩展表
|
* sku扩展表
|
||||||
* @Author: sui q
|
|
||||||
* @Time: 2022/9/19 11:06
|
|
||||||
* @Classname: BdWaresSpecsSkuExt
|
|
||||||
* @PackageName: com.hzs.common.domain.sale.ext
|
|
||||||
*/
|
*/
|
||||||
@EqualsAndHashCode(callSuper = true)
|
@EqualsAndHashCode(callSuper = true)
|
||||||
@Data
|
@Data
|
||||||
|
|
@ -31,7 +27,6 @@ public class BdWaresSpecsSkuExt extends BdWaresSpecsSku {
|
||||||
private BigDecimal waresAchieve;
|
private BigDecimal waresAchieve;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 商品编号
|
* 商品编号
|
||||||
*/
|
*/
|
||||||
|
|
|
||||||
|
|
@ -1,5 +1,6 @@
|
||||||
package com.hzs.third.pay.controller.notify;
|
package com.hzs.third.pay.controller.notify;
|
||||||
|
|
||||||
|
import cn.hutool.core.util.StrUtil;
|
||||||
import cn.hutool.json.JSONUtil;
|
import cn.hutool.json.JSONUtil;
|
||||||
import com.hzs.common.core.enums.EPayChannel;
|
import com.hzs.common.core.enums.EPayChannel;
|
||||||
import com.hzs.common.core.enums.EPayType;
|
import com.hzs.common.core.enums.EPayType;
|
||||||
|
|
@ -153,6 +154,9 @@ public class JdPayNotifyController extends JdBaseController {
|
||||||
return ERROR;
|
return ERROR;
|
||||||
}
|
}
|
||||||
private Integer convertPayType(String payName){
|
private Integer convertPayType(String payName){
|
||||||
|
if(StrUtil.isEmpty(payName)){
|
||||||
|
payName = "";
|
||||||
|
}
|
||||||
Integer result = EPayType.WECHAT.getValue();
|
Integer result = EPayType.WECHAT.getValue();
|
||||||
switch (payName){
|
switch (payName){
|
||||||
case "XJK":
|
case "XJK":
|
||||||
|
|
|
||||||
|
|
@ -3,3 +3,4 @@ mybatis 配置的 configuration 属性下添加:
|
||||||
default-fetch-size: 100
|
default-fetch-size: 100
|
||||||
说明: 修改mybatis默认提取数据大小(默认为10),修改后每次查询数据提取一次100条,大批量查询数数据时,减少与oracle数据库交互提高加载数据速度,但是数据库每次查询使用内存増大,需要谨慎使用,防止OOM
|
说明: 修改mybatis默认提取数据大小(默认为10),修改后每次查询数据提取一次100条,大批量查询数数据时,减少与oracle数据库交互提高加载数据速度,但是数据库每次查询使用内存増大,需要谨慎使用,防止OOM
|
||||||
|
|
||||||
|
1
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue