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,18 +843,16 @@ 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') |                     to_char(sysdate, 'yyyy-mm-dd')) a | ||||||
|              ) a |                  left join (select nvl(sum(so.order_achieve), 0) rep_achieve, | ||||||
|                  left join ( |  | ||||||
|             select nvl(sum(so.order_achieve), 0) rep_achieve, |  | ||||||
|                                    nvl(sum(so.order_amount), 0)  rep_amount |                                    nvl(sum(so.order_amount), 0)  rep_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 (43, 44, 47) |                               and so.order_type in (43, 44, 47) | ||||||
|                               and to_char(so.pay_time, 'yyyy-mm-dd') = |                               and to_char(so.pay_time, 'yyyy-mm-dd') = | ||||||
|                   to_char(sysdate, 'yyyy-mm-dd') |                                   to_char(sysdate, 'yyyy-mm-dd')) b on 1 = 1 | ||||||
|         ) 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') |                     to_char(sysdate - 1, 'yyyy-mm-dd')) a | ||||||
|              ) a |                  left join (select nvl(sum(so.order_achieve), 0) rep_achieve, | ||||||
|                  left join ( |  | ||||||
|             select nvl(sum(so.order_achieve), 0) rep_achieve, |  | ||||||
|                                    nvl(sum(so.order_amount), 0)  rep_amount |                                    nvl(sum(so.order_amount), 0)  rep_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 (43, 44, 47) |                               and so.order_type in (43, 44, 47) | ||||||
|                               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') |                                   to_char(sysdate - 1, 'yyyy-mm-dd')) b on 1 = 1 | ||||||
|         ) 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 ( |  | ||||||
|             select nvl(sum(so.order_achieve), 0)                            rep_achieve, |  | ||||||
|                                    nvl(sum(so.order_amount - nvl(so.CONSUME_AMOUNT, 0)), 0) rep_amount |                                    nvl(sum(so.order_amount - nvl(so.CONSUME_AMOUNT, 0)), 0) rep_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 (43, 44, 47) |                               and so.order_type in (43, 44, 47) | ||||||
|                               and to_char(so.pay_time, 'yyyy-mm') = |                               and to_char(so.pay_time, 'yyyy-mm') = | ||||||
|                   to_char(sysdate, 'yyyy-mm') |                                   to_char(sysdate, 'yyyy-mm')) b on 1 = 1 | ||||||
|         ) 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