## 购票列表语句调整;调整部分代码格式;

This commit is contained in:
cabbage 2025-05-28 14:21:14 +08:00
parent e580c8bd74
commit 63b03bb38b
23 changed files with 146 additions and 353 deletions

View File

@ -11,9 +11,6 @@ import java.util.List;
/**
* 发货单明细表 Mapper 接口
*
* @author hzs
* @since 2022-08-31
*/
public interface SaDeliverItemsMapper extends BaseMapper<SaDeliverItems> {
@ -26,7 +23,6 @@ public interface SaDeliverItemsMapper extends BaseMapper<SaDeliverItems> {
*/
List<DeliverHandledVO> queryDeliverHandledList(@Param("param") DeliverHandledParam param, @Param("pkCountry") Integer pkCountry);
/**
* 批量插入
*
@ -64,10 +60,7 @@ public interface SaDeliverItemsMapper extends BaseMapper<SaDeliverItems> {
@Param("pkCountry") Integer pkCountry);
/*
* @description: 查询订单是否绑定追溯码
* @author: sui q
* @date: 2023/7/21 17:02
* @param: null null
* 查询订单是否绑定追溯码
**/
List<SaDeliverItems> querySaDeliverItemByOrder(@Param("orderCode") String orderCode, @Param("itemIdList") List<Long> itemIdList);

View File

@ -9,9 +9,6 @@ import java.util.List;
/**
* 发货单明细表 服务类
*
* @author hzs
* @since 2022-08-31
*/
public interface ISaDeliverItemsService extends IService<SaDeliverItems> {
@ -48,20 +45,14 @@ public interface ISaDeliverItemsService extends IService<SaDeliverItems> {
List<Integer> orderStatusList,
Integer pkCountry);
/*
* @description: 查询订单是否绑定追溯码
* @author: sui q
* @date: 2023/7/21 17:02
* @param: null null
**/
/**
* 查询订单是否绑定追溯码
*/
Boolean validateOrderBindBarCode(String orderCode, List<Long> itemIdList);
/*
* @description: 删除发货单
* @author: sui q
* @date: 2023/9/14 15:47
* @param: null null
**/
/**
* 删除发货单
*/
void deleteSaDeliverItems(Long pkOrder, List<Long> pkOrderItemsList);
}

View File

@ -15,9 +15,6 @@ import java.util.List;
/**
* 发货单明细表 服务实现类
*
* @author hzs
* @since 2022-08-31
*/
@Service
public class SaDeliverItemsServiceImpl extends ServiceImpl<SaDeliverItemsMapper, SaDeliverItems> implements ISaDeliverItemsService {

View File

@ -2,7 +2,7 @@ package com.hzs.sale.order.controller.api;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.hzs.common.core.constant.*;
import com.hzs.common.core.constant.msg.SaOrderMsgConstants;
import com.hzs.common.core.domain.R;
@ -142,8 +142,6 @@ public class ApiOrderController extends BaseController {
List<MyOrderItemsVO> myOrderItemsList = null;
// 是否处理
boolean isHandle = false;
// 汇率目前只有中国需要由美金转人民币显示其它国家显示就是美金不需要转换
BigDecimal baseExchangeRate = saOrder.getInExchangeRate();
// 遍历订单明细转换成前台显示内容
for (SaOrderItemsExt saOrderItems : orderItemsList) {
@ -183,18 +181,8 @@ public class ApiOrderController extends BaseController {
myOrder.setOrderStatus(saOrderItems.getOrderStatus());
// 订单显示金额 = 订单金额 + 运费
myOrder.setOrderAmount(myOrder.getOrderAmount().add(myOrder.getPostage()));
if (pkCountry.equals(CountryConstants.CHINA_COUNTRY)) {
// 登录会员如果是中国会员订单显示人民币业绩
myOrder.setOrderAchieve(myOrder.getOrderAchieve().multiply(currencyDTO.getInExchangeRate()));
}
if (!saOrder.getPkCountry().equals(pkCountry)) {
// 订单结算国与登录结算国不相同需要处理金额转换订单金额 订单结算国汇率 登录结算国汇率
if (baseExchangeRate.compareTo(currencyDTO.getInExchangeRate()) != 0) {
// 订单结算国与登录结算国汇率不相同才进行处理
myOrder.setOrderAmount(myOrder.getOrderAmount().multiply(currencyDTO.getInExchangeRate()).divide(baseExchangeRate, 6, BigDecimal.ROUND_HALF_UP).setScale(6, BigDecimal.ROUND_HALF_UP));
}
}
// 登录会员如果是中国会员订单显示人民币业绩
myOrder.setOrderAchieve(myOrder.getOrderAchieve().multiply(currencyDTO.getInExchangeRate()));
String recProvince = areaMap.get(saOrder.getRecProvince());
if (StringUtils.isNotEmpty(recProvince)) {
@ -292,13 +280,12 @@ public class ApiOrderController extends BaseController {
// 当前用户
Long userId = SecurityUtils.getUserId();
QueryWrapper<SaOrder> orderQueryWrapper = new QueryWrapper<>();
orderQueryWrapper.eq("ORDER_CODE", orderCode).and(wrapper -> wrapper.eq("PK_MEMBER", userId).or().eq(SystemFieldConstants.PK_CREATOR, userId));
LambdaQueryWrapper<SaOrder> orderQueryWrapper = new LambdaQueryWrapper<>();
orderQueryWrapper.eq(SaOrder::getOrderCode, orderCode).and(wrapper -> wrapper.eq(SaOrder::getPkMember, userId).or().eq(SaOrder::getPkCreator, userId));
SaOrder saOrder = iSaOrderService.getOne(orderQueryWrapper);
if (null != saOrder) {
// 查询订单
List<SaOrderItems> deliverList = iSaOrderItemsService.queryDeliverByOrder(saOrder.getPkId());
// List<SaDeliver> saDeliverList = iSaDeliverService.queryDeliverByOrder(saOrder.getPkId());
if (CollectionUtil.isNotEmpty(deliverList)) {
for (SaOrderItems orderItems : deliverList) {
if (null != orderItems && StringUtils.isNotEmpty(orderItems.getLogisticsCode())) {
@ -343,9 +330,8 @@ public class ApiOrderController extends BaseController {
public AjaxResult confirm(@PathVariable("orderCode") String orderCode) {
Long userId = SecurityUtils.getUserId();
QueryWrapper<SaOrder> orderQueryWrapper = new QueryWrapper<>();
orderQueryWrapper.eq("ORDER_CODE", orderCode).and(wrapper -> wrapper.eq("PK_MEMBER", userId).or().eq(SystemFieldConstants.PK_CREATOR, userId));
// orderQueryWrapper.eq("PK_MEMBER", userId);
LambdaQueryWrapper<SaOrder> orderQueryWrapper = new LambdaQueryWrapper<>();
orderQueryWrapper.eq(SaOrder::getOrderCode, orderCode).and(wrapper -> wrapper.eq(SaOrder::getPkMember, userId).or().eq(SaOrder::getPkCreator, userId));
SaOrder saOrder = iSaOrderService.getOne(orderQueryWrapper);
if (null != saOrder) {
if (EOrderStatus.DELIVERED.getValue() != saOrder.getOrderStatus()) {
@ -367,8 +353,8 @@ public class ApiOrderController extends BaseController {
public AjaxResult cancel(@PathVariable("orderCode") String orderCode) {
Long userId = SecurityUtils.getUserId();
QueryWrapper<SaOrder> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("ORDER_CODE", orderCode).and(wrapper -> wrapper.eq("PK_MEMBER", userId).or().eq(SystemFieldConstants.PK_CREATOR, userId));
LambdaQueryWrapper<SaOrder> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(SaOrder::getOrderCode, orderCode).and(wrapper -> wrapper.eq(SaOrder::getPkMember, userId).or().eq(SaOrder::getPkCreator, userId));
SaOrder saOrder = iSaOrderService.getOne(queryWrapper);
if (null != saOrder) {
if (EOrderStatus.WAIT_PAY.getValue() != saOrder.getOrderStatus()) {
@ -484,11 +470,6 @@ public class ApiOrderController extends BaseController {
/**
* 自助业务-订单自提订单列表
*
* @author: zhang jing
* @date: 2023/5/29 9:10
* @param: [selfPickUpParam]
* @return: com.hzs.common.core.web.page.TableDataInfo
**/
@GetMapping("/self-list")
public TableDataInfo selfOrderList(MyOrderParam param) {
@ -522,8 +503,6 @@ public class ApiOrderController extends BaseController {
saOrder.setMemberCode(CommonUtil.getMemberCode(saOrder.getMemberCode(), saOrder.getMemberServiceCode()));
saOrder.setMemberName(CommonUtil.getMemberName(saOrder.getMemberPkVertex(), saOrder.getMemberName(), saOrder.getMemberNickName()));
}
// 汇率目前只有中国需要由美金转人民币显示其它国家显示就是美金不需要转换
// BigDecimal baseExchangeRate = saOrder.getInExchangeRate();
//处理订单收货地址
String recProvince = areaMap.get(saOrder.getRecProvince());
@ -612,16 +591,13 @@ public class ApiOrderController extends BaseController {
myOrder.setAddress(saOrder.getRecAddress());
// 直销订单处理
if (saOrder.getPkCountry().equals(CountryConstants.CHINA_COUNTRY)) {
// 中国需要处理PV显示问题
// 汇率目前只有中国需要由美金转人民币显示其它国家显示就是美金不需要转换
BigDecimal baseExchangeRate = saOrder.getInExchangeRate();
if (null != baseExchangeRate) {
// 基础汇率不为空则进行转换
myOrder.setOrderAchieve(myOrder.getOrderAchieve().multiply(baseExchangeRate));
for (MyOrderItemsVO myOrderItemsVO : myOrder.getItemList()) {
myOrderItemsVO.setAchievement(myOrderItemsVO.getAchievement().multiply(baseExchangeRate));
}
// 汇率目前只有中国需要由美金转人民币显示其它国家显示就是美金不需要转换
BigDecimal baseExchangeRate = saOrder.getInExchangeRate();
if (null != baseExchangeRate) {
// 基础汇率不为空则进行转换
myOrder.setOrderAchieve(myOrder.getOrderAchieve().multiply(baseExchangeRate));
for (MyOrderItemsVO myOrderItemsVO : myOrder.getItemList()) {
myOrderItemsVO.setAchievement(myOrderItemsVO.getAchievement().multiply(baseExchangeRate));
}
}
@ -644,11 +620,6 @@ public class ApiOrderController extends BaseController {
/**
* 自助撤单列表(24点内)
*
* @author: zhang jing
* @date: 2023/11/21 10:33
* @param: [param]
* @return: com.hzs.common.core.web.page.TableDataInfo
**/
@GetMapping("/selfRevokeList")
public TableDataInfo selfRevokeList(MyOrderParam param) {
@ -671,9 +642,6 @@ public class ApiOrderController extends BaseController {
// 获取订单ID列表
List<Long> orderIdList = new ArrayList<>();
// 当前国家汇率
CurrencyDTO currencyDTO = iCurrencyServiceApi.getCurrency(pkCountry).getData();
for (SaOrderExt saOrderExt : orderList) {
// 默认为直销订单
orderIdList.add(saOrderExt.getPkId());
@ -727,15 +695,8 @@ public class ApiOrderController extends BaseController {
myOrder.setOrderStatus(saOrderItems.getOrderStatus());
// 订单显示金额 = 订单金额 + 运费
myOrder.setOrderAmount(myOrder.getOrderAmount().add(myOrder.getPostage()));
if (saOrder.getPkCountry().equals(CountryConstants.CHINA_COUNTRY)) {
// 如果是中国订单
myOrder.setOrderAchieve(myOrder.getOrderAchieve().multiply(baseExchangeRate));
}
if (!saOrder.getPkCountry().equals(pkCountry)) {
// 订单结算国与登录结算国不相同需要处理金额转换订单金额 订单结算国汇率 登录结算国汇率
myOrder.setOrderAmount(myOrder.getOrderAmount().multiply(currencyDTO.getInExchangeRate()).divide(baseExchangeRate, 2, BigDecimal.ROUND_HALF_UP));
}
// 如果是中国订单
myOrder.setOrderAchieve(myOrder.getOrderAchieve().multiply(baseExchangeRate));
String recProvince = areaMap.get(saOrder.getRecProvince());
if (StringUtils.isNotEmpty(recProvince)) {
@ -781,15 +742,9 @@ public class ApiOrderController extends BaseController {
/**
* 自动撤单参数校验
*
* @author: zhang jing
* @date: 2023/11/21 14:49
* @param: [orderQueryParam]
* @return: com.hzs.common.core.web.domain.AjaxResult
**/
@PostMapping("/check-self-revoke-order")
public AjaxResult checkSelfRevokeOrder(@RequestBody MyOrderVO myOrderVO) {
log.info(myOrderVO.getOrderCode());
// 验证订单编号订单类型是否存在
if (StringUtils.isEmpty(myOrderVO.getOrderCode())) {
return AjaxResult.error(TransactionUtils.getContent(SaOrderMsgConstants.ORDER_CODE_EMPTY));
@ -808,11 +763,6 @@ public class ApiOrderController extends BaseController {
/**
* 自助撤单
*
* @author: zhang jing
* @date: 2023/11/21 15:19
* @param: [orderCancelParam]
* @return: com.hzs.common.core.web.domain.AjaxResult
**/
@PostMapping("/self-revoke-order")
public AjaxResult selfRevokeOrder(@RequestBody MyOrderVO myOrderVO, HttpServletRequest request) {

View File

@ -1,7 +1,7 @@
package com.hzs.sale.order.controller.api;
import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.hzs.common.core.constant.msg.MemberMsgConstants;
import com.hzs.common.core.constant.msg.SaOrderMsgConstants;
import com.hzs.common.core.enums.*;
@ -24,30 +24,20 @@ import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* @Description: 订单自助业务
* @Author: sui q
* @Time: 2022/10/25 11:38
* @Classname: ApiFanSaOrderController
* @PackageName: com.hzs.sale.order.controller.api
* 订单自助业务
*/
@RestController
@RequestMapping("/api/order")
@Slf4j
public class ApiSaOrderBusinessController extends ParentOrderController {
private ISaOrderSelfLogService saOrderSelfLogService;
@Autowired
public void setSaOrderSelfLogService(ISaOrderSelfLogService saOrderSelfLogService) {
this.saOrderSelfLogService = saOrderSelfLogService;
}
private ISaOrderSelfLogService iSaOrderSelfLogService;
/**
* 订单申请自提
*
* @param selfPickUpParam 订单参数
* @Description: 订单申请自提
* @return: AjaxResult
* @Author: sui q
* @Date: 2022/8/27 16:47
*/
@PostMapping("/self-pick-up")
public AjaxResult selfPickUpSaOrder(@RequestBody SelfPickUpParam selfPickUpParam) throws Exception {
@ -61,9 +51,9 @@ public class ApiSaOrderBusinessController extends ParentOrderController {
selfPickUpParam.setCenterCodeId(SecurityUtils.getUserId());
selfPickUpParam.setPkSettleCountry(SecurityUtils.getPkCountry());
SaOrder saOrder = getOrderService().querySaleOrderByOrderCode(SaOrder.builder().orderStatus(EOrderStatus.PAY.getValue()).orderCode(selfPickUpParam.getOrderCode()).build());
QueryWrapper<SaOrderSelfLog> queryWrapper = new QueryWrapper();
queryWrapper.eq("PK_ORDER", saOrder.getPkId());
List<SaOrderSelfLog> list = saOrderSelfLogService.list(queryWrapper);
LambdaQueryWrapper<SaOrderSelfLog> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(SaOrderSelfLog::getPkOrder, saOrder.getPkId());
List<SaOrderSelfLog> list = iSaOrderSelfLogService.list(queryWrapper);
if (CollectionUtil.isNotEmpty(list)) {
return AjaxResult.error(TransactionUtils.getContent(MemberMsgConstants.SELF_PICKUP_ORDER_REPEAT));
}
@ -72,7 +62,7 @@ public class ApiSaOrderBusinessController extends ParentOrderController {
return AjaxResult.error(TransactionUtils.getContent(SaOrderMsgConstants.ORDER_CURRENT_DATE));
}
selfPickUpParam.setPkCreator(SecurityUtils.getUserId());
saOrderSelfLogService.applySelfPickUpSaOrder(saOrder, selfPickUpParam);
iSaOrderSelfLogService.applySelfPickUpSaOrder(saOrder, selfPickUpParam);
return AjaxResult.success(selfPickUpParam);
}
@ -88,7 +78,8 @@ public class ApiSaOrderBusinessController extends ParentOrderController {
if (selfPickUpParam.getApproveStatus() == null) {
selfPickUpParam.setApproveStatus(EApproveRechargeStatus.SUBMIT.getValue());
}
List<SaOrderSelfLogExt> orderSelfLogList = saOrderSelfLogService.queryMemberSaOrderSelfLog(selfPickUpParam);
List<SaOrderSelfLogExt> orderSelfLogList = iSaOrderSelfLogService.queryMemberSaOrderSelfLog(selfPickUpParam);
return getDataTable(orderSelfLogList);
}
}

View File

@ -8,28 +8,17 @@ import com.hzs.sale.order.param.SelfPickUpParam;
import java.util.List;
/**
* <p>
* 订单自提申请记录 Mapper 接口
* </p>
*
* @author hzs
* @since 2023-04-19
*/
public interface SaOrderSelfLogMapper extends BaseMapper<SaOrderSelfLog> {
/*
* @description: 查询自提订单
* @author: sui q
* @date: 2023/4/19 19:24
* @param: null null
**/
/**
* 查询自提订单
*/
List<SaOrderSelfLogExt> querySaOrderSelfLog(SelfPickUpParam selfPickUpVO);
/*
* @description: 查询自提订单
* @author: sui q
* @date: 2023/4/19 19:24
* @param: null null
**/
/**
* 查询自提订单
*/
List<SaOrderSelfLogExt> queryMemberSaOrderSelfLog(SelfPickUpParam selfPickUpVO);
}

View File

@ -9,53 +9,33 @@ import com.hzs.sale.order.param.SelfPickUpParam;
import java.util.List;
/**
* <p>
* 订单自提申请记录 服务类
* </p>
*
* @author hzs
* @since 2023-04-19
*/
public interface ISaOrderSelfLogService extends IService<SaOrderSelfLog> {
/*
* @description: 会员端自提记录日志,申请记录
* @author: sui q
* @date: 2023/4/19 17:37
* @param: null null
**/
/**
* 会员端自提记录日志,申请记录
*/
void applySelfPickUpSaOrder(SaOrder saOrder, SelfPickUpParam selfPickUpVO);
/*
* @description: 查询自提订单
* @author: sui q
* @date: 2023/4/19 19:24
* @param: null null
**/
/**
* 查询自提订单
*/
List<SaOrderSelfLogExt> querySaOrderSelfLog(SelfPickUpParam selfPickUpVO);
/*
* @description: 查询自提订单
* @author: sui q
* @date: 2023/4/20 15:30
* @param: null null
**/
/**
* 查询自提订单
*/
SaOrderSelfLog querySaOrderSelfLogById(Long pkId);
/*
* @description: 查询自提订单
* @author: sui q
* @date: 2023/4/19 19:24
* @param: null null
**/
/**
* 查询自提订单
*/
List<SaOrderSelfLogExt> queryMemberSaOrderSelfLog(SelfPickUpParam selfPickUpVO);
/*
* @description: 更新自提订单状态
* @author: sui q
* @date: 2023/4/20 15:38
* @param: null null
**/
/**
* 更新自提订单状态
*/
void updateSaOrderSelfLog(SelfPickUpParam selfPickUpVO, Long pkId);
}

View File

@ -434,7 +434,6 @@ public interface ISaOrderService extends IService<SaOrder> {
**/
List<SaOrderExt> selfAddressOrderList(MyOrderParam param, Long memberId, Integer pkCountry);
/**
* 我的订单数量
*

View File

@ -2399,8 +2399,8 @@ public class OrderBusinessServiceImpl implements IOrderBusinessService {
return myOrderVO;
}
//注册订单撤单验证
if (myOrderVO.getOrderType() == EOrderType.REGISTER_ORDER.getValue() ||
myOrderVO.getOrderType() == EOrderType.SPECIAL_REGISTER_ORDER.getValue()) {
if (myOrderVO.getOrderType() == EOrderType.REGISTER_ORDER.getValue()
|| myOrderVO.getOrderType() == EOrderType.SPECIAL_REGISTER_ORDER.getValue()) {
//校验会员是否存在推荐或安置
if (iMemberServiceApi.checkLowerMember(myOrderVO.getPkMember()).getData()) {
myOrderVO.setMsg(TransactionUtils.getContent(SaOrderMsgConstants.CHECK_MEMBER_LOWER_EXIST));

View File

@ -1,9 +1,7 @@
package com.hzs.sale.order.service.impl;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hzs.common.core.constant.SaOrderFieldConstants;
import com.hzs.common.core.constant.SystemFieldConstants;
import com.hzs.common.core.enums.EApproveRechargeStatus;
import com.hzs.common.core.utils.CommonUtil;
import com.hzs.common.core.utils.DateUtils;
@ -19,12 +17,7 @@ import org.springframework.stereotype.Service;
import java.util.List;
/**
* <p>
* 订单自提申请记录 服务实现类
* </p>
*
* @author hzs
* @since 2023-04-19
*/
@Service
public class SaOrderSelfLogServiceImpl extends ServiceImpl<SaOrderSelfLogMapper, SaOrderSelfLog> implements ISaOrderSelfLogService {
@ -64,14 +57,14 @@ public class SaOrderSelfLogServiceImpl extends ServiceImpl<SaOrderSelfLogMapper,
@Override
public void updateSaOrderSelfLog(SelfPickUpParam selfPickUpVO, Long pkId) {
UpdateWrapper<SaOrderSelfLog> updateWrapper = new UpdateWrapper<>();
updateWrapper.set(SystemFieldConstants.MODIFIED_TIME, DateUtils.currentDate());
updateWrapper.set(SystemFieldConstants.PK_MODIFIED, selfPickUpVO.getPkCreator());
updateWrapper.set(SystemFieldConstants.APPROVE_STATUS, selfPickUpVO.getApproveStatus());
if(StringUtils.isNotEmpty(selfPickUpVO.getRejectMsg())){
updateWrapper.set("REJECT_MSG", selfPickUpVO.getRejectMsg());
LambdaUpdateWrapper<SaOrderSelfLog> updateWrapper = new LambdaUpdateWrapper<>();
updateWrapper.set(SaOrderSelfLog::getModifiedTime, DateUtils.currentDate());
updateWrapper.set(SaOrderSelfLog::getPkModified, selfPickUpVO.getPkCreator());
updateWrapper.set(SaOrderSelfLog::getApproveStatus, selfPickUpVO.getApproveStatus());
if (StringUtils.isNotEmpty(selfPickUpVO.getRejectMsg())) {
updateWrapper.set(SaOrderSelfLog::getRejectMsg, selfPickUpVO.getRejectMsg());
}
updateWrapper.eq(SystemFieldConstants.PK_ID, pkId);
updateWrapper.eq(SaOrderSelfLog::getPkId, pkId);
update(updateWrapper);
}
}

View File

@ -105,9 +105,9 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
@DubboReference
IMemberServiceApi memberServiceApi;
@DubboReference
IGradeServiceApi gradeServiceApi;
IGradeServiceApi iGradeServiceApi;
@DubboReference
IAwardsServiceApi awardsServiceApi;
IAwardsServiceApi iAwardsServiceApi;
@DubboReference
IAreaServiceApi areaServiceApi;
@DubboReference
@ -702,8 +702,8 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
cuMember.setPkSettleGradeValue(gradeDTO.getGradeValue());
// 判断奖衔原会员有奖衔的话判断哪个大使用大的
if (pkAwards != null && gradeDTO.getGradeValue() != null) {
BdAwards bdAwards = awardsServiceApi.getAwardsOne(pkAwards).getData();
BdAwards newAwards = awardsServiceApi.getAwardsOne(gradeDTO.getPkAwards()).getData();
BdAwards bdAwards = iAwardsServiceApi.getAwardsOne(pkAwards).getData();
BdAwards newAwards = iAwardsServiceApi.getAwardsOne(gradeDTO.getPkAwards()).getData();
if (bdAwards.getAwardsValue() < newAwards.getAwardsValue()) {
cuMember.setPkAwards(gradeDTO.getPkAwards());
}
@ -976,7 +976,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
@Transactional(rollbackFor = Exception.class)
public Boolean payUpgradeSaOrder(SaOrderExt saOrderExt, CuMemberAccountExt cuMemberAccountExt) {
CuMember cuMember = getCuMemberByKey(saOrderExt.getPkMember());
GradeDTO oldGradeDTO = gradeServiceApi.getGrade(cuMember.getPkSettleGrade()).getData();
GradeDTO oldGradeDTO = iGradeServiceApi.getGrade(cuMember.getPkSettleGrade()).getData();
// 封装等级,重新计算会员等级
if (setLastCuMemberGrade(cuMember, saOrderExt)) {
return false;
@ -1209,7 +1209,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
if (orderParam.getIsEnough() != null && orderParam.getIsEnough()) {
orderReturn.setIsEnough(Boolean.TRUE);
CuMember member = getCuMemberByKey(orderParam.getCenterCodeId());
GradeDTO grade = gradeServiceApi.getGrade(member.getPkSettleGrade()).getData();
GradeDTO grade = iGradeServiceApi.getGrade(member.getPkSettleGrade()).getData();
orderReturn.setPkGradeVal(grade.getGradeName());
return orderReturn;
}
@ -1222,7 +1222,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
} else {
member = getCuMemberByKey(orderParam.getCenterCodeId());
}
GradeDTO grade = gradeServiceApi.getGrade(member.getPkSettleGrade()).getData();
GradeDTO grade = iGradeServiceApi.getGrade(member.getPkSettleGrade()).getData();
if (grade.getGradeValue() < gradeDTO.getGradeValue()) {
orderReturn.setIsEnough(Boolean.TRUE);
} else {
@ -1802,10 +1802,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
/**
* @param pkParent 推荐人
* @param pkCountry 国家
* 验证第二部门是否需要验证首单
* @return: boolean
* @Author: sui q
* @Date: 2022/9/7 9:29
* @Description: 验证第二部门是否需要验证首单
*/
@Override
public boolean validateFirstOrder(Long pkParent, Integer pkCountry) {
@ -1820,10 +1817,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
/**
* @param pkPlaceParent 安置位置
* @param pkCountry 国家
* 验证第二部门是否需要验证首单
* @return: boolean
* @Author: sui q
* @Date: 2022/9/7 9:29
* @Description: 验证第二部门是否需要验证首单
*/
@Override
public boolean validateLeftExistMember(Long pkPlaceParent, Integer pkCountry) {
@ -1908,10 +1902,6 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
/**
* @description: 自助撤单列表
* @author: zhang jing
* @date: 2023/11/21 11:24
* @param: [param, memberId, pkCountry]
* @return: java.util.List<com.hzs.common.domain.sale.ext.SaOrderExt>
**/
@Override
public List<SaOrderExt> selfRevokeOrderList(MyOrderParam param, Long memberId, Integer pkCountry) {
@ -1919,38 +1909,16 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
}
/**
* @description: 自助服务-可申请订单列表
* @author: zhang jing
* @date: 2023/4/19 11:29
* @param: [param, memberId, pkCountry]
* @return: java.util.List<com.hzs.common.domain.sale.ext.SaOrderExt>
**/
@Override
public List<SaOrderExt> selfOrderList(MyOrderParam param, Long memberId, Integer pkCountry) {
return baseMapper.selfOrderList(param, memberId, pkCountry);
}
/**
* @description: 查询最新待发货订单
* @author: zhang jing
* @date: 2023/11/22 16:28
* @param: [memberId, pkCountry]
* @return: java.util.List<com.hzs.common.domain.sale.ext.SaOrderExt>
**/
@Override
public String lastOrderList(Long memberId, Integer pkCountry) {
return baseMapper.lastOrderList(memberId, pkCountry);
}
/**
* @description: 自助服务- 修改收货地址订单列表
* @author: zhang jing
* @date: 2023/5/11 14:17
* @param: [param, memberId, pkCountry]
* @return: java.util.List<com.hzs.common.domain.sale.ext.SaOrderExt>
**/
@Override
public List<SaOrderExt> selfAddressOrderList(MyOrderParam param, Long memberId, Integer pkCountry) {
return baseMapper.selfAddressOrderList(param, memberId, pkCountry);
@ -2187,9 +2155,6 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
* 支付分享订单
*
* @param saOrderExt 订单
* @return: Boolean
* @Author: sui q
* @Date: 2023/3/15 17:27
*/
@Override
@Transactional(rollbackFor = Exception.class)
@ -2358,13 +2323,6 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
}
}
/**
* @description: 查询当天已支付订单信息
* @author: zhang jing
* @date: 2023/5/17 14:37
* @param: [orderType]
* @return: java.util.List<com.hzs.common.domain.sale.order.SaOrder>
**/
@Override
public List<SaOrder> querySaOrderByOrderType(String payTime) {
return baseMapper.querySaOrderByOrderType(payTime);
@ -2447,20 +2405,11 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
return i;
}
/**
* 根据编号查询会员首单
*
* @param memberCodeList
* @return
*/
@Override
public List<MemberFirstOrderVo> checkMemberIsFirstOrder(List<String> memberCodeList) {
return baseMapper.checkMemberIsFirstOrder(memberCodeList);
}
/**
* @description: 自助撤单
**/
@Override
@Transactional(rollbackFor = Exception.class)
public void selfRevokeOrder(Long pkApprove, MyOrderVO myOrderVO) {
@ -2479,7 +2428,7 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
throw new RuntimeException("更新订单失败");
}
//添加订单日志表
// 添加订单日志表
// 本批订单修改记录编号
String businessCode = CommonUtil.createSerialNumber(EOrderPrefix.DEFAULT);
SaOrderChargeLog saOrderChargeLog = this.packageSaOrderChargeLog(currentDate, pkApprove,
@ -2493,8 +2442,8 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
saOrderChargeLogService.save(saOrderChargeLog);
// 撤销注册订单(注册订单,海粉订单,特殊注册订单)
if (myOrderVO.getOrderType() == EOrderType.REGISTER_ORDER.getValue() ||
myOrderVO.getOrderType() == EOrderType.SPECIAL_REGISTER_ORDER.getValue()) {
if (myOrderVO.getOrderType() == EOrderType.REGISTER_ORDER.getValue()
|| myOrderVO.getOrderType() == EOrderType.SPECIAL_REGISTER_ORDER.getValue()) {
// 逻辑删除会员
if (!memberServiceApi.singleRevokeMemberBySelfRevokeOrder(pkApprove, saOrderExt, businessCommissionDTO).getData()) {
throw new RuntimeException("撤单失败");
@ -2525,8 +2474,8 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
// 记录原奖衔与新奖衔
BdAwards tmpAwards;
// 判断奖衔原奖衔>新奖衔 不进行变奖衔
BdAwards oldAwards = awardsServiceApi.getAwardsOne(cuMember.getPkAwards()).getData();
BdAwards newAwards = awardsServiceApi.getAwardsOne(gradeDTO.getPkAwards()).getData();
BdAwards oldAwards = iAwardsServiceApi.getAwardsOne(cuMember.getPkAwards()).getData();
BdAwards newAwards = iAwardsServiceApi.getAwardsOne(gradeDTO.getPkAwards()).getData();
if (oldAwards.getAwardsValue() > newAwards.getAwardsValue()) {
cuMember.setPkAwards(gradeDTO.getPkAwards());
tmpAwards = newAwards;
@ -2640,9 +2589,6 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
}
}
/**
* @description:
**/
private SaOrderChargeLog packageSaOrderChargeLog(Date nowDate, Long userId, Integer chargeType, String businessCode,
MyOrderVO saOrder, Integer approvalStatus) {
SaOrderChargeLog saOrderChargeLog = new SaOrderChargeLog();
@ -2663,11 +2609,6 @@ public class SaOrderServiceImpl extends ServiceImpl<SaOrderMapper, SaOrder> impl
return baseMapper.queryByPkIdOrCode(pkOrder, orderCode, pkCountry);
}
/**
* 查询订单单品统计
*
* @return
*/
@Override
public List<SingleItemStatVo> singleItemStat(SingleItemStatParam singleItemStatParam) {
return baseMapper.singleItemStat(singleItemStatParam);

View File

@ -254,8 +254,9 @@ public class ApiSaTicketController extends ParentOrderController {
/**
* 验证字段是否必输
*
* @param fieldList 需要验证的字段
* 验证字段是否必输
*/
private boolean validateFieldNotNull(BuyTicketParam buyTicketParam, List<String> fieldList) {
return fieldList.stream().anyMatch(field -> {

View File

@ -8,7 +8,7 @@
from ac_ticket at
where at.del_flag = 0
and to_char(#{queryDate}, 'yyyy-mm-dd') >= to_char(at.dis_start_date, 'yyyy-mm-dd')
and to_char(at.dis_end_date, 'yyyy-mm-dd') >= to_char((#{queryDate}, 'yyyy-mm-dd')
and to_char(at.dis_end_date, 'yyyy-mm-dd') >= to_char(#{queryDate}, 'yyyy-mm-dd')
and (at.pk_vertex is null or at.pk_vertex = '' or at.pk_vertex like ',' || #{pkVertex} || ',')
and at.pk_country = #{pkCountry}
</select>

View File

@ -543,10 +543,10 @@
<select id="querySaDeliverItemByOrder" resultType="com.hzs.common.domain.sale.deliver.SaDeliverItems">
select sdi.pk_id from sa_order so
inner join sa_deliver_items sdi
on so.pk_id =sdi.pk_order
on so.pk_id = sdi.pk_order
inner join sa_deliver_bar_code sdc
on sdi.pk_id=sdc.pk_deliver_items
where sdi.del_flag=0 and sdc.del_flag=0
on sdi.pk_id= sdc.pk_deliver_items
where sdi.del_flag = 0 and sdc.del_flag = 0
and so.order_code = #{orderCode}
<if test="itemIdList != null and itemIdList.size >0">
and sdi.pk_order_items in

View File

@ -1606,6 +1606,7 @@
#{item.pkId}
</foreach>
</select>
<!-- 查询最新待发货订单-->
<select id="lastOrderList" resultType="java.lang.String">
SELECT *

View File

@ -4,68 +4,68 @@
<!-- 通用查询映射结果 -->
<resultMap id="SaOrderSelfLogExt" type="com.hzs.common.domain.sale.ext.SaOrderSelfLogExt">
<id column="PK_ID" property="pkId" />
<result column="PK_MEMBER" property="pkMember" />
<result column="DEL_FLAG" property="delFlag" />
<result column="CREATION_TIME" property="creationTime" />
<result column="PK_CREATOR" property="pkCreator" />
<result column="MODIFIED_TIME" property="modifiedTime" />
<result column="PK_MODIFIED" property="pkModified" />
<result column="PK_COUNTRY" property="pkCountry" />
<result column="PK_ORDER" property="pkOrder" />
<result column="SELF_CODE" property="selfCode" />
<result column="PHONE" property="phone" />
<result column="REMARK" property="remark" />
<result column="APPROVE_STATUS" property="approveStatus" />
<result column="MEMBER_NAME" property="memberName" />
<result column="MEMBER_CODE" property="memberCode" />
<result column="ORDER_CODE" property="orderCode" />
<result column="ORDER_TYPE" property="orderType" />
<result column="APPLY_NAME" property="applyName" />
<result column="CREATOR" property="creator" />
<id column="PK_ID" property="pkId"/>
<result column="PK_MEMBER" property="pkMember"/>
<result column="DEL_FLAG" property="delFlag"/>
<result column="CREATION_TIME" property="creationTime"/>
<result column="PK_CREATOR" property="pkCreator"/>
<result column="MODIFIED_TIME" property="modifiedTime"/>
<result column="PK_MODIFIED" property="pkModified"/>
<result column="PK_COUNTRY" property="pkCountry"/>
<result column="PK_ORDER" property="pkOrder"/>
<result column="SELF_CODE" property="selfCode"/>
<result column="PHONE" property="phone"/>
<result column="REMARK" property="remark"/>
<result column="APPROVE_STATUS" property="approveStatus"/>
<result column="MEMBER_NAME" property="memberName"/>
<result column="MEMBER_CODE" property="memberCode"/>
<result column="ORDER_CODE" property="orderCode"/>
<result column="ORDER_TYPE" property="orderType"/>
<result column="APPLY_NAME" property="applyName"/>
<result column="CREATOR" property="creator"/>
<result column="COVER" property="cover"/>
<result column="PRODUCT_NAME" property="productName"/>
<result column="SPECS_NAME" property="specsName"/>
<result column="CLASSIFY_TYPE" property="classifyType" />
<result column="CLASSIFY_TYPE" property="classifyType"/>
<result column="IS_GIFT" property="isGift"/>
<result column="QUANTITY" property="quantity"/>
<result column="ORDER_ITEMS_ID" property="orderItemsId" />
<result column="REJECT_MSG" property="rejectMsg" />
<result column="PRODUCT_ID" property="productId" />
<result column="ORDER_ITEMS_ID" property="orderItemsId"/>
<result column="REJECT_MSG" property="rejectMsg"/>
<result column="PRODUCT_ID" property="productId"/>
</resultMap>
<select id="querySaOrderSelfLog" resultMap="SaOrderSelfLogExt">
select sl.pk_id,sl.self_code,sl.phone,sl.remark,sl.approve_status,sl.REJECT_MSG,cmb.member_name applyName,
sl.creation_time,cm.member_code,cmr.member_name creator,
cm.member_name,
so.order_code,
so.order_type,
bp.cover,
bp.product_name,
soi.pk_id order_items_id,
soi.is_gift,
soi.QUANTITY,
soi.specs_name,
bc.name classify_type,
soi.pk_product PRODUCT_ID
sl.creation_time,cm.member_code,cmr.member_name creator,
cm.member_name,
so.order_code,
so.order_type,
bp.cover,
bp.product_name,
soi.pk_id order_items_id,
soi.is_gift,
soi.QUANTITY,
soi.specs_name,
bc.name classify_type,
soi.pk_product PRODUCT_ID
from sa_order_self_log sl
inner join sa_order so
on sl.pk_order = so.pk_id
inner join cu_member cm
on cm.pk_id = so.pk_member
inner join sa_order so
on sl.pk_order = so.pk_id
inner join cu_member cm
on cm.pk_id = so.pk_member
left join cu_member cmb
on sl.pk_creator = cmb.pk_id
left join sa_order_items soi
on soi.pk_order = so.pk_id
and soi.del_flag = 0
inner join BD_PRODUCT bp
on bp.pk_id = soi.pk_product
inner join bd_classify bc
on bp.pk_classify = bc.pk_id
left join cu_member cmr
on sl.pk_creator = cmr.pk_id
on sl.pk_creator = cmb.pk_id
left join sa_order_items soi
on soi.pk_order = so.pk_id
and soi.del_flag = 0
inner join BD_PRODUCT bp
on bp.pk_id = soi.pk_product
inner join bd_classify bc
on bp.pk_classify = bc.pk_id
left join cu_member cmr
on sl.pk_creator = cmr.pk_id
where so.del_flag = 0 and sl.del_flag=0 and cm.del_flag=0 and soi.del_flag=0
and so.pk_country = #{pkSettleCountry}
and so.pk_country = #{pkSettleCountry}
<if test="memberCode != null and memberCode != ''">
and cm.member_code=#{memberCode}
</if>
@ -99,6 +99,7 @@
</if>
order by so.order_code desc
</select>
<select id="queryMemberSaOrderSelfLog" resultMap="SaOrderSelfLogExt">
select so.order_code,so.pay_time,sl.self_code,sl.approve_status,sl.creation_time,sl.remark,
bp.cover,bp.product_name,

View File

@ -11,12 +11,7 @@ import lombok.*;
import lombok.experimental.Accessors;
/**
* <p>
* 订单自提申请记录
* </p>
*
* @author hzs
* @since 2023-04-19
*/
@Data
@EqualsAndHashCode(callSuper = true)

View File

@ -2,9 +2,12 @@ package com.hzs.common.domain.sale.order;
import com.baomidou.mybatisplus.annotation.KeySequence;
import com.baomidou.mybatisplus.annotation.TableName;
import java.util.Date;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableField;
import java.io.Serializable;
import lombok.*;
@ -12,9 +15,6 @@ import lombok.experimental.Accessors;
/**
* 分享注册会员订单数据
*
* @author hzs
* @since 2023-09-08
*/
@NoArgsConstructor
@AllArgsConstructor

View File

@ -13,9 +13,6 @@ import lombok.experimental.Accessors;
/**
* 退款表
*
* @author hzs
* @since 2023-08-25
*/
@Data
@EqualsAndHashCode(callSuper = true)

View File

@ -13,9 +13,6 @@ import lombok.experimental.Accessors;
/**
* 退款明细表
*
* @author hzs
* @since 2023-08-25
*/
@Data
@EqualsAndHashCode(callSuper = true)

View File

@ -8,16 +8,9 @@ import lombok.NoArgsConstructor;
import java.io.Serializable;
import java.util.List;
/**
* 快递100 DTO
*
* @Description:
* @Author: ljc
* @Date: 2022/8/24 11:02
* @Version1.0
*/
@NoArgsConstructor
@AllArgsConstructor
@Builder

View File

@ -6,11 +6,6 @@ import java.io.Serializable;
/**
* 快递详情
*
* @Description:
* @Author: ljc
* @Date: 2022/8/24 11:02
* @Version1.0
*/
@Data
public class ExpressDetail implements Serializable {

View File

@ -19,13 +19,6 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @Description: 快递100
* @Author: ljc
* @Date: 2022/8/24 14:38
* @Version1.0
*/
@Service
@Slf4j
public class ExpressServiceImpl implements IExpressService {
@ -33,7 +26,6 @@ public class ExpressServiceImpl implements IExpressService {
@Autowired
private ExpressConfig expressConfig;
@Override
public R<ExpressDTO> expressTrackInfo(String trackingNumber, String mobile) {
String customer = expressConfig.getCustomer();
@ -41,8 +33,6 @@ public class ExpressServiceImpl implements IExpressService {
String url = expressConfig.getUrl();
QueryTrackParam queryTrackParam = new QueryTrackParam();
// TODO: 2022/4/18 快递公司的编码现在暂不传后期根据需求而定
// queryTrackParam.setCom("JD");
queryTrackParam.setNum(trackingNumber);
queryTrackParam.setPhone(mobile);
String param = new Gson().toJson(queryTrackParam);
@ -120,10 +110,9 @@ public class ExpressServiceImpl implements IExpressService {
* @return String
*/
private String querySign(String param, String key, String customer) {
StringBuilder sb = new StringBuilder();
sb.append(param);
sb.append(key);
sb.append(customer);
return sign(sb.toString());
String sb = param +
key +
customer;
return sign(sb);
}
}