package com.panzhihua.service_community.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.panzhihua.common.constants.PayCpmstant;
|
import com.panzhihua.common.model.dtos.shop.WxPayNotifyOrderDTO;
|
import com.panzhihua.common.model.vos.common.ComBatteryCommodityOrderVo;
|
import com.panzhihua.common.model.vos.common.ComBatteryCommoditySpecsVo;
|
import com.panzhihua.common.model.vos.common.ComBatteryCommodityVo;
|
import com.panzhihua.common.model.vos.common.ComBatteryUserAddressVo;
|
import com.panzhihua.common.utlis.DateUtils;
|
import com.panzhihua.common.utlis.Snowflake;
|
import com.panzhihua.common.utlis.WxPayUtils;
|
import com.panzhihua.service_community.dao.*;
|
import com.panzhihua.service_community.entity.*;
|
import com.panzhihua.service_community.service.ComBatteryCommodityOrderService;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.panzhihua.service_community.service.ComBatteryTradeOrderService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.BeanUtils;
|
import com.panzhihua.common.model.dtos.common.*;
|
import com.panzhihua.common.model.vos.R;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* title: 电动车商城-订单表表服务实现类
|
* <p>
|
* projectName 成都呐喊信息技术有限公司-智慧社区项目
|
* <p>
|
* description: 电动车商城-订单表表服务实现类
|
*
|
* @author lyq
|
* @date 2022-03-29 16:05:48
|
*/
|
@Slf4j
|
@Service("comBatteryCommodityOrderService")
|
public class ComBatteryCommodityOrderServiceImpl extends ServiceImpl<ComBatteryCommodityOrderMapper, ComBatteryCommodityOrder> implements ComBatteryCommodityOrderService {
|
|
@Resource
|
private ComBatteryCommodityMapper commodityMapper;
|
@Resource
|
private ComBatteryCommoditySpecsMapper commoditySpecsMapper;
|
@Resource
|
private ComBatteryUserAddressMapper userAddressMapper;
|
@Resource
|
private SysUserMapper userMapper;
|
@Resource
|
private ComBatteryTradeOrderService tradeOrderService;
|
@Value("${min.app.isTest}")
|
private Boolean isTest;
|
@Value("${min.app.isRefundTest}")
|
private Boolean isRefundTest;
|
@Value("${min.app.appid}")
|
private String appid;
|
@Value("${min.app.payKey}")
|
private String payKey;
|
@Value("${min.app.mchId}")
|
private String mchId;
|
@Value("${min.app.currencyNotifyUrl}")
|
private String currencyNotifyUrl;
|
|
/**
|
* description queryByPage 分页查询
|
*
|
* @param comBatteryCommodityOrder 请求参数
|
* @return 分页查询列表数据
|
* @author lyq
|
* @date 2022-03-29 16:05:48
|
*/
|
@Override
|
public R queryByPage(PageComBatteryCommodityOrderDto comBatteryCommodityOrder) {
|
return R.ok(this.baseMapper.queryAllByLimit(comBatteryCommodityOrder, new Page(comBatteryCommodityOrder.getPageNum(), comBatteryCommodityOrder.getPageSize())));
|
}
|
|
/**
|
* description insert 新增数据
|
*
|
* @param comBatteryCommodityOrder 请求参数
|
* @return 新增结果
|
* @author lyq
|
* @date 2022-03-29 16:05:48
|
*/
|
@Override
|
public R insert(AddComBatteryCommodityOrderDto comBatteryCommodityOrder) {
|
ComBatteryCommodityOrder entity = new ComBatteryCommodityOrder();
|
BeanUtils.copyProperties(comBatteryCommodityOrder, entity);
|
if (this.baseMapper.insert(entity) > 0) {
|
return R.ok();
|
}
|
return R.fail("添加失败");
|
}
|
|
/**
|
* description update 修改数据
|
*
|
* @param editDto 请求参数
|
* @return 修改结果
|
* @author lyq
|
* @date 2022-03-29 16:05:48
|
*/
|
@Override
|
public R update(EditComBatteryCommodityOrderDto editDto) {
|
ComBatteryCommodityOrder entity = this.baseMapper.selectById(editDto.getId());
|
if (entity == null) {
|
return R.fail("未查询到该记录");
|
}
|
BeanUtils.copyProperties(editDto, entity);
|
if (this.baseMapper.updateById(entity) > 0) {
|
return R.ok();
|
}
|
return R.fail("修改失败");
|
}
|
|
/**
|
* description deleteById 通过主键删除数据
|
*
|
* @param id 主键id
|
* @return 删除结果
|
* @author lyq
|
* @date 2022-03-29 16:05:48
|
*/
|
@Override
|
public R deleteById(Long id) {
|
ComBatteryCommodityOrder entity = new ComBatteryCommodityOrder();
|
entity.setId(id);
|
entity.setIsDel(ComBatteryCommodityOrder.IsDel.YES);
|
if (this.baseMapper.updateById(entity) > 0) {
|
return R.ok();
|
}
|
return R.fail("删除失败");
|
}
|
|
/**
|
* description detailById 查询详情
|
*
|
* @param id 主键id
|
* @return 详情数据
|
* @author lyq
|
* @date 2022-03-29 16:05:48
|
*/
|
@Override
|
public R detailById(Long id) {
|
ComBatteryCommodityOrderVo commodityOrderVo = this.baseMapper.queryById(id);
|
if(commodityOrderVo != null){
|
//查询商品信息
|
ComBatteryCommodityVo commodityVo = commodityMapper.queryById(commodityOrderVo.getCommodityId());
|
commodityOrderVo.setCommodityVo(commodityVo);
|
//查询商品规格信息
|
ComBatteryCommoditySpecsVo commoditySpecsVo = commoditySpecsMapper.queryById(commodityOrderVo.getSpecsId());
|
commodityOrderVo.setCommoditySpecsVo(commoditySpecsVo);
|
//查询用户收货地址
|
ComBatteryUserAddressVo userAddressVo = userAddressMapper.queryById(commodityOrderVo.getAddressId());
|
commodityOrderVo.setUserAddressVo(userAddressVo);
|
}
|
return R.ok(commodityOrderVo);
|
}
|
|
/**
|
* description queryByPage 查询列表
|
*
|
* @param comBatteryCommodityOrder 请求参数
|
* @return 列表数据
|
* @author lyq
|
* @date 2022-03-29 16:05:48
|
*/
|
@Override
|
public R queryByList(PageComBatteryCommodityOrderDto comBatteryCommodityOrder) {
|
return R.ok(this.baseMapper.queryAllByList(comBatteryCommodityOrder));
|
}
|
|
/**
|
* 修改订单收货地址
|
* @param editOrderAddressDto 请求参数
|
* @return 修改结果
|
*/
|
@Override
|
public R updateOrderAddress(EditOrderAddressDto editOrderAddressDto) {
|
ComBatteryCommodityOrder entity = new ComBatteryCommodityOrder();
|
BeanUtils.copyProperties(editOrderAddressDto, entity);
|
if (this.baseMapper.updateById(entity) > 0) {
|
return R.ok();
|
}
|
return R.fail("修改失败");
|
}
|
|
/**
|
* 修改订单物流信息
|
* @param editOrderLogisticsDto 请求参数
|
* @return 修改结果
|
*/
|
@Override
|
public R updateOrderLogistics(EditOrderLogisticsDto editOrderLogisticsDto) {
|
ComBatteryCommodityOrder entity = new ComBatteryCommodityOrder();
|
BeanUtils.copyProperties(editOrderLogisticsDto, entity);
|
if (this.baseMapper.updateById(entity) > 0) {
|
return R.ok();
|
}
|
return R.fail("修改失败");
|
}
|
|
/**
|
* 电动车商城购买商品支付回调
|
* @param notifyOrderDTO 请求参数
|
* @return 购买商品支付回调
|
*/
|
@Override
|
public R batteryPayNotify(WxPayNotifyOrderDTO notifyOrderDTO) {
|
Date payTime = DateUtils.stringToDate(notifyOrderDTO.getPayTime(), new SimpleDateFormat("yyyyMMddHHmmss"));
|
Date nowDate = new Date();
|
String orderNo = notifyOrderDTO.getOrderTradeNo();
|
String payNo = notifyOrderDTO.getWxTradeNo();
|
BigDecimal cashFee = new BigDecimal(notifyOrderDTO.getCashFee());
|
ComBatteryCommodityOrder commodityOrder = this.baseMapper.selectOne(new QueryWrapper<ComBatteryCommodityOrder>().lambda()
|
.eq(ComBatteryCommodityOrder::getOrderNo,orderNo));
|
if (commodityOrder == null) {
|
log.error("用户购买商品订单微信支付回调错误，未查询到支付订单记录，支付订单号：" + orderNo);
|
return R.fail("未查询到用户购买商品支付订单记录");
|
}
|
if (!commodityOrder.getPayStatus().equals(ComBatteryCommodityOrder.PayStatus.WZF)) {
|
log.error("用户购买商品订单微信支付回调错误,错误原因：支付订单状态已发生改变，不可重复回调,订单号：" + orderNo);
|
return R.fail("支付订单状态已发生改变，不可重复回调");
|
}
|
//更新订单
|
commodityOrder.setStatus(ComBatteryCommodityOrder.Status.DFH);
|
commodityOrder.setPayStatus(ComBatteryCommodityOrder.PayStatus.YZF);
|
commodityOrder.setPayNo(payNo);
|
commodityOrder.setPayAmount(cashFee);
|
commodityOrder.setUpdateAt(nowDate);
|
commodityOrder.setPayTime(payTime);
|
this.baseMapper.updateById(commodityOrder);
|
|
// 更新微信支付流水记录
|
tradeOrderService.renewPayTrade(commodityOrder.getId(), cashFee, notifyOrderDTO.getWxTradeNo(), payTime, nowDate);
|
return R.ok();
|
}
|
|
/**
|
* 小程序用户创建订单
|
* @param createOrderDto 请求参数
|
* @return 创建结果
|
*/
|
@Override
|
public R appletsOrderCreate(UserCreateOrderDto createOrderDto) {
|
//查询商品
|
ComBatteryCommodity commodity = commodityMapper.selectById(createOrderDto.getCommodityId());
|
if(commodity == null){
|
return R.fail("未查询到商品信息");
|
}
|
//查询商品规格信息
|
ComBatteryCommoditySpecs commoditySpecs = commoditySpecsMapper.selectById(createOrderDto.getSpecsId());
|
if(commoditySpecs == null){
|
return R.fail("未查询到商品规格信息");
|
}
|
//判断商品库存
|
if(commoditySpecs.getStock() < createOrderDto.getCount()){
|
return R.fail("您购买的商品库存不足");
|
}
|
//查询用户收货地址
|
ComBatteryUserAddress userAddress = userAddressMapper.selectById(createOrderDto.getAddressId());
|
if(userAddress == null){
|
return R.fail("未查询到用户收货地址");
|
}
|
//查询用户信息
|
SysUser user = userMapper.selectById(createOrderDto.getUserId());
|
if(user == null){
|
return R.fail("未查询到用户信息");
|
}
|
Date nowDate = new Date();
|
//初始化订单信息
|
ComBatteryCommodityOrder commodityOrder = getCreateOrder(commodity,userAddress,user,commoditySpecs,createOrderDto,nowDate);
|
Map<String,Object> resultMap = new HashMap<>(2);
|
if(this.baseMapper.insert(commodityOrder) > 0){
|
//更新商品库存
|
commoditySpecs.setStock(commoditySpecs.getStock() - createOrderDto.getCount());
|
commoditySpecsMapper.updateById(commoditySpecs);
|
|
//微信支付需要调取小程序微信支付
|
String result = getWxPayResult(commodityOrder.getFinalAmount(),commodityOrder.getOpenId(),commodityOrder.getOrderNo(),"购买商品");
|
resultMap.put("payResult",result);
|
resultMap.put("orderId",commodityOrder.getId());
|
|
// 添加微信支付交易流水
|
String wxTradeOrderNo = "wx" + Snowflake.getId();
|
tradeOrderService.addOrderTradeRecord(user.getUserId(), user.getOpenid(), wxTradeOrderNo, ComBatteryTradeOrder.PayType.WX,
|
commodityOrder.getFinalAmount(), ComBatteryTradeOrder.TradeType.DDC_SHOP, commodityOrder.getId(),
|
commodityOrder.getOrderNo(), user.getUserId(), nowDate);
|
}
|
return R.ok(resultMap);
|
}
|
|
/**
|
* 初始化订单数据
|
* @param commodity 商品数据
|
* @param userAddress 用户收货地址信息
|
* @param user 用户数据
|
* @param commoditySpecs 商品规格数据
|
* @param createOrderDto 用户请求参数
|
* @param nowDate 操作时间
|
* @return 初始化订单数据
|
*/
|
private ComBatteryCommodityOrder getCreateOrder(ComBatteryCommodity commodity, ComBatteryUserAddress userAddress
|
, SysUser user, ComBatteryCommoditySpecs commoditySpecs, UserCreateOrderDto createOrderDto, Date nowDate){
|
ComBatteryCommodityOrder commodityOrder = new ComBatteryCommodityOrder();
|
commodityOrder.setUserId(user.getUserId());
|
commodityOrder.setOpenId(user.getOpenid());
|
commodityOrder.setStoreId(commodity.getStoreId());
|
commodityOrder.setCommodityId(commodity.getId());
|
commodityOrder.setSpecsId(commoditySpecs.getId());
|
commodityOrder.setOrderNo("BS" + Snowflake.getId());
|
commodityOrder.setStatus(ComBatteryCommodityOrder.Status.DFK);
|
commodityOrder.setPayStatus(ComBatteryCommodityOrder.PayStatus.WZF);
|
commodityOrder.setIsDel(ComBatteryCommodityOrder.IsDel.NO);
|
commodityOrder.setPayType(ComBatteryCommodityOrder.PayType.WX);
|
commodityOrder.setCount(createOrderDto.getCount());
|
commodityOrder.setPrice(commoditySpecs.getPrice());
|
commodityOrder.setAmount(commoditySpecs.getPrice().multiply(BigDecimal.valueOf(createOrderDto.getCount())));
|
commodityOrder.setFreight(commodity.getPostage());
|
commodityOrder.setFinalAmount(commodityOrder.getAmount().add(commodityOrder.getFreight()));
|
commodityOrder.setCreateAt(nowDate);
|
commodityOrder.setCreateBy(user.getUserId());
|
commodityOrder.setRemark(createOrderDto.getRemark());
|
//收货地址
|
commodityOrder.setAddressId(userAddress.getId());
|
commodityOrder.setReceivingName(userAddress.getName());
|
commodityOrder.setReceivingPhone(userAddress.getPhone());
|
commodityOrder.setReceivingRegion(userAddress.getProvinceName() + userAddress.getCityName() + userAddress.getCityName());
|
commodityOrder.setReceivingAddress(userAddress.getAddress());
|
return commodityOrder;
|
}
|
|
/**
|
* 小程序唤起微信支付
|
*
|
* @param money
|
* 需要支付的金额
|
* @param openId
|
* 用户唤起微信支付的openid
|
* @param orderNo
|
* 业务订单号
|
* @param remark
|
* 交易备注
|
* @return 小程序支付参数
|
*/
|
private String getWxPayResult(BigDecimal money, String openId, String orderNo, String remark) {
|
String result = "";
|
// 将剩余金额调起微信支付
|
if (isTest) {
|
money = BigDecimal.valueOf(0.01);
|
}
|
// 调用wx支付
|
result = WxPayUtils.getUnifiedorder(appid, mchId, payKey, currencyNotifyUrl + PayCpmstant.BATTERY_STORE_PAY_NOTIFY_URL, remark, openId, orderNo, money);
|
log.info("用户购买商品微信支付返回参数:" + result);
|
return result;
|
}
|
|
/**
|
* 定时关闭5分钟未支付订单
|
* @return 操作结果
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public R syncCloseOrder() {
|
log.info("定时器定时关闭超过30分钟未支付订单，并返回商品库存");
|
Date nowDate = new Date();
|
//获取当前时间减30分钟时间
|
Date oldDate = DateUtils.addMinutes(nowDate,-5);
|
List<ComBatteryCommodityOrder> commodityOrderList = this.baseMapper.selectList(new QueryWrapper<ComBatteryCommodityOrder>()
|
.lambda().eq(ComBatteryCommodityOrder::getStatus,ComBatteryCommodityOrder.Status.DFK)
|
.eq(ComBatteryCommodityOrder::getPayStatus,ComBatteryCommodityOrder.PayStatus.WZF)
|
.eq(ComBatteryCommodityOrder::getIsDel,ComBatteryCommodityOrder.IsDel.NO)
|
.lt(ComBatteryCommodityOrder::getCreateAt,oldDate));
|
commodityOrderList.forEach(commodityOrder -> {
|
commodityOrder.setStatus(ComBatteryCommodityOrder.Status.YGB);
|
commodityOrder.setUpdateAt(nowDate);
|
this.baseMapper.updateById(commodityOrder);
|
//归还库存
|
ComBatteryCommoditySpecs commoditySpecs = commoditySpecsMapper.selectById(commodityOrder.getSpecsId());
|
if(commoditySpecs != null){
|
commoditySpecs.setStock(commoditySpecs.getStock() + commodityOrder.getCount());
|
commoditySpecs.setUpdateAt(nowDate);
|
commoditySpecsMapper.updateById(commoditySpecs);
|
}
|
});
|
return R.ok();
|
}
|
|
/**
|
* 电动车商城用户确认收货
|
* @param id 订单id
|
* @param userId 用户id
|
* @return 确认结果
|
*/
|
@Override
|
public R appletsOrderReceiving(Long id, Long userId) {
|
ComBatteryCommodityOrder commodityOrder = this.baseMapper.selectById(id);
|
if(commodityOrder == null){
|
return R.fail("未查询到订单信息");
|
}
|
//确认收货
|
commodityOrder.setStatus(ComBatteryCommodityOrder.Status.YWC);
|
commodityOrder.setReceivingTime(new Date());
|
commodityOrder.setUpdateAt(new Date());
|
commodityOrder.setUpdateBy(userId);
|
if(this.baseMapper.updateById(commodityOrder) > 0){
|
return R.ok();
|
}
|
return R.fail();
|
}
|
|
/**
|
* 后台订单发货
|
* @param deliverAdminDto 请求参数
|
* @return 发货结果
|
*/
|
@Override
|
public R orderDeliver(OrderDeliverAdminDto deliverAdminDto) {
|
//查询订单
|
ComBatteryCommodityOrder commodityOrder = this.baseMapper.selectById(deliverAdminDto.getId());
|
if(commodityOrder == null){
|
return R.fail("未查询到订单信息");
|
}
|
Date nowDate = new Date();
|
//判断操作类型
|
if(deliverAdminDto.getType().equals(OrderDeliverAdminDto.Type.FH)){
|
commodityOrder.setLogisticsCompany(deliverAdminDto.getLogisticsCompany());
|
commodityOrder.setLogisticsNo(deliverAdminDto.getLogisticsNo());
|
commodityOrder.setUpdateBy(deliverAdminDto.getUserId());
|
commodityOrder.setUpdateAt(nowDate);
|
commodityOrder.setDeliveryTime(nowDate);
|
commodityOrder.setStatus(ComBatteryCommodityOrder.Status.DSH);
|
}else if(deliverAdminDto.getType().equals(OrderDeliverAdminDto.Type.XGWL)){
|
commodityOrder.setLogisticsCompany(deliverAdminDto.getLogisticsCompany());
|
commodityOrder.setLogisticsNo(deliverAdminDto.getLogisticsNo());
|
commodityOrder.setUpdateBy(deliverAdminDto.getUserId());
|
commodityOrder.setUpdateAt(nowDate);
|
}
|
if(this.baseMapper.updateById(commodityOrder) > 0){
|
return R.ok();
|
}
|
return R.fail();
|
}
|
}
|
