package com.yeshi.fanli.service.impl.shop;
|
|
import java.math.BigDecimal;
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.support.DefaultTransactionDefinition;
|
import org.yeshi.utils.exception.WXOrderException;
|
|
import com.aliyun.openservices.ons.api.Message;
|
import com.aliyun.openservices.ons.api.Producer;
|
import com.aliyun.openservices.ons.api.SendResult;
|
import com.aliyun.openservices.ons.api.transaction.LocalTransactionExecuter;
|
import com.aliyun.openservices.ons.api.transaction.TransactionProducer;
|
import com.aliyun.openservices.ons.api.transaction.TransactionStatus;
|
import com.google.gson.Gson;
|
import com.yeshi.fanli.dao.mybatis.shop.BanLiShopOrderGoodsMapper;
|
import com.yeshi.fanli.dao.mybatis.shop.BanLiShopOrderMapper;
|
import com.yeshi.fanli.dto.mq.order.OrderTopicTagEnum;
|
import com.yeshi.fanli.dto.mq.order.body.BanLiShopOrderMQMsg;
|
import com.yeshi.fanli.dto.msg.MsgRedPackUseContentDTO;
|
import com.yeshi.fanli.entity.bus.msg.MsgMoneyDetail.MsgTypeMoneyTypeEnum;
|
import com.yeshi.fanli.entity.mq.MQUnSendInfo;
|
import com.yeshi.fanli.entity.redpack.RedPackDetail;
|
import com.yeshi.fanli.entity.shop.BanLiShopGoods;
|
import com.yeshi.fanli.entity.shop.BanLiShopGoodsClass;
|
import com.yeshi.fanli.entity.shop.BanLiShopGoodsSets;
|
import com.yeshi.fanli.entity.shop.BanLiShopGoodsSetsPay;
|
import com.yeshi.fanli.entity.shop.BanLiShopOrder;
|
import com.yeshi.fanli.entity.shop.BanLiShopOrderGoods;
|
import com.yeshi.fanli.exception.mq.MQUnSendInfoException;
|
import com.yeshi.fanli.exception.redpack.RedPackBalanceException;
|
import com.yeshi.fanli.exception.redpack.RedPackDetailException;
|
import com.yeshi.fanli.exception.shop.BanLiShopOrderException;
|
import com.yeshi.fanli.service.inter.money.msg.UserMoneyMsgNotificationService;
|
import com.yeshi.fanli.service.inter.mq.MQUnSendInfoService;
|
import com.yeshi.fanli.service.inter.redpack.RedPackBalanceService;
|
import com.yeshi.fanli.service.inter.redpack.RedPackForbidService;
|
import com.yeshi.fanli.service.inter.shop.BanLiShopGoodsClassService;
|
import com.yeshi.fanli.service.inter.shop.BanLiShopGoodsService;
|
import com.yeshi.fanli.service.inter.shop.BanLiShopGoodsSetPayService;
|
import com.yeshi.fanli.service.inter.shop.BanLiShopGoodsSetService;
|
import com.yeshi.fanli.service.inter.shop.BanLiShopOrderService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.factory.RedPackDetailFactory;
|
import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
|
import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
import com.yeshi.fanli.util.shop.BanLiShopOrderUtil;
|
import com.yeshi.fanli.util.wx.BanLiShopWXPayUtil;
|
|
@Service
|
public class BanLiShopOrderServiceImpl implements BanLiShopOrderService {
|
|
@Resource
|
private BanLiShopOrderMapper banLiShopOrderMapper;
|
|
@Resource
|
private BanLiShopGoodsSetService banLiShopGoodsSetService;
|
|
@Resource
|
private BanLiShopGoodsSetPayService banLiShopGoodsSetPayService;
|
|
@Resource
|
private BanLiShopGoodsService banLiShopGoodsService;
|
|
@Resource
|
private BanLiShopGoodsClassService banLiShopGoodsClassService;
|
|
@Resource
|
private RedPackBalanceService redPackBalanceService;
|
|
@Resource(name = "producer")
|
private Producer producer;
|
|
@Resource
|
private MQUnSendInfoService mqUnSendInfoService;
|
|
@Resource
|
private BanLiShopOrderGoodsMapper banLiShopOrderGoodsMapper;
|
|
@Resource(name = "orderTransactionProducer")
|
private TransactionProducer orderTransactionProducer;
|
|
@Resource(name = "transactionManager")
|
private DataSourceTransactionManager transactionManager;
|
|
@Resource
|
private UserMoneyMsgNotificationService userMoneyMsgNotificationService;
|
|
@Resource
|
private RedPackForbidService redPackForbidService;
|
|
|
@Transactional(rollbackFor=Exception.class)
|
@Override
|
public void addOrder(BanLiShopOrder order) throws BanLiShopOrderException {
|
// 查询必要的参数是否添加
|
if (order.getGoodsSet() == null || order.getGoodsSet().getId() == null || order.getGoods() == null
|
|| order.getGoods().getId() == null)
|
throw new BanLiShopOrderException(1, "未选择商品");
|
|
if (order.getUid() == null)
|
throw new BanLiShopOrderException(1, "缺少用户ID");
|
|
if (order.getHongBaoPayment() == null && order.getBalancePayment() == null && order.getMoneyPayment() == null) {
|
throw new BanLiShopOrderException(1, "未选择支付方式");
|
}
|
|
if (order.getHongBaoPayment() != null) {
|
order.setHongBaoPaymentState(BanLiShopOrder.PAY_STATE_NOPAY);
|
}
|
|
if (order.getBalancePayment() != null) {
|
order.setBalancePaymentState(BanLiShopOrder.PAY_STATE_NOPAY);
|
}
|
|
if (order.getMoneyPayment() != null) {
|
order.setMoneyPaymentState(BanLiShopOrder.PAY_STATE_NOPAY);
|
}
|
|
order.setState(BanLiShopOrder.STATE_NO_PAY);
|
// 判断商品套餐是否存在
|
BanLiShopGoodsSets set = banLiShopGoodsSetService.selectByPrimaryKey(order.getGoodsSet().getId());
|
if (set == null) {
|
throw new BanLiShopOrderException(1, "商品套餐不存在");
|
}
|
|
BanLiShopGoods goods = banLiShopGoodsService.selectByPrimaryKey(order.getGoods().getId());
|
if (goods == null) {
|
throw new BanLiShopOrderException(1, "商品已下线");
|
}
|
|
if (goods.getCreateTime() == null)
|
goods.setCreateTime(new Date());
|
|
// 插入商品
|
BanLiShopOrderGoods orderGoods = getOrderGoods(goods, set);
|
order.setOrderGoods(orderGoods);
|
banLiShopOrderMapper.insertSelective(order);
|
|
// 添加订单号
|
String orderNo = BanLiShopOrderUtil.createOrderNo(order.getId());
|
// 更新订单号
|
BanLiShopOrder update = new BanLiShopOrder();
|
update.setId(order.getId());
|
update.setOrderNo(orderNo);
|
order.setOrderNo(orderNo);
|
banLiShopOrderMapper.updateByPrimaryKeySelective(update);
|
|
// 增加销量
|
banLiShopGoodsSetService.addSalesCount(order.getGoodsSet().getId(), 1);
|
banLiShopGoodsService.addSalesCount(order.getGoods().getId(), 1);
|
|
// 订单添加成功 ,延时通知后续
|
sendPlaceOrderMsg(order.getId(), order.getUid());
|
}
|
|
private BanLiShopOrderGoods getOrderGoods(BanLiShopGoods goods, BanLiShopGoodsSets set) {
|
BanLiShopOrderGoods orderGoods = new BanLiShopOrderGoods();
|
orderGoods.setCreateTime(new Date());
|
orderGoods.setGoodsId(goods.getId());
|
orderGoods.setGoodsName(goods.getTitle());
|
orderGoods.setGoodsSetId(set.getId());
|
orderGoods.setSetName(set.getName());
|
orderGoods.setState(set.getState());
|
orderGoods.setZkPrice(set.getZkPrice());
|
orderGoods.setPicture(goods.getSquarePicture());
|
banLiShopOrderGoodsMapper.insertSelective(orderGoods);
|
return orderGoods;
|
}
|
|
private void sendPlaceOrderMsg(Long orderId, Long uid) {
|
|
Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.banLiShopOrderDelay,
|
new BanLiShopOrderMQMsg(orderId, uid));
|
msg.setKey(orderId + "");
|
long delayTime = System.currentTimeMillis() + (Constant.IS_TEST ? 1000 * 30L : 1000 * 60 * 10);// 10分钟后通知
|
msg.setStartDeliverTime(delayTime);
|
SendResult sendResult = producer.send(msg);
|
if (sendResult == null) {
|
MQUnSendInfo info = new MQUnSendInfo();
|
info.setBody(new String(msg.getBody()));
|
if (msg.getStartDeliverTime() > 0)
|
info.setDeliverTime(new Date(msg.getStartDeliverTime()));
|
info.setKey(msg.getKey());
|
info.setTag(msg.getTag());
|
info.setTopic(msg.getTopic());
|
try {
|
mqUnSendInfoService.addMQUnSendInfo(info);
|
} catch (MQUnSendInfoException e) {
|
e.printStackTrace();
|
}
|
}
|
|
}
|
|
@Override
|
public List<BanLiShopOrder> listByUid(Long uid, int page, int pageSize) {
|
|
return banLiShopOrderMapper.listByUidAndState(null, uid, (page - 1) * pageSize, pageSize);
|
}
|
|
@Override
|
public long countByUid(Long uid) {
|
return banLiShopOrderMapper.countByUidAndState(null, uid);
|
}
|
|
@Override
|
public BanLiShopOrder selectByPrimaryKey(Long id) {
|
return banLiShopOrderMapper.selectByPrimaryKey(id);
|
}
|
|
@Override
|
public void udpateSelectiveByPrimaryKey(BanLiShopOrder order) {
|
if (order == null || order.getId() == null)
|
return;
|
if (order.getUpdateTime() == null)
|
order.setUpdateTime(new Date());
|
banLiShopOrderMapper.updateByPrimaryKeySelective(order);
|
}
|
|
@Transactional(rollbackFor=Exception.class)
|
@Override
|
public void payOrderByHongBao(Long orderId) throws BanLiShopOrderException, RedPackBalanceException {
|
BanLiShopOrder order = banLiShopOrderMapper.selectByPrimaryKeyForUpdate(orderId);
|
if (order == null) {
|
throw new BanLiShopOrderException(1, "订单不存在");
|
}
|
if (order.getHongBaoPayment() == null)
|
throw new BanLiShopOrderException(2, "不需要采用红包支付");
|
|
if (order.getHongBaoPaymentState() != null && order.getHongBaoPaymentState() == BanLiShopOrder.PAY_STATE_PAID) {
|
throw new BanLiShopOrderException(3, "重复支付");
|
}
|
|
BanLiShopGoods goods = banLiShopGoodsService.selectByPrimaryKey(order.getGoods().getId());
|
BanLiShopGoodsClass goodsClass = banLiShopGoodsClassService.selectByPrimaryKey(goods.getGoodsClass().getId());
|
BanLiShopGoodsSets set = banLiShopGoodsSetService.selectByPrimaryKey(order.getGoodsSet().getId());
|
RedPackDetail detail = null;
|
try {
|
detail = RedPackDetailFactory.createUseByShopOrder(orderId, order.getUid(), goodsClass.getName(),
|
set.getName(), order.getHongBaoPayment());
|
} catch (RedPackDetailException e) {
|
e.printStackTrace();
|
}
|
|
if (detail == null)
|
throw new RedPackBalanceException(4, "红包详情失败");
|
redPackBalanceService.subRedPack(order.getUid(), order.getHongBaoPayment(), detail);
|
|
BanLiShopOrder update = new BanLiShopOrder();
|
update.setHongBaoPaymentState(BanLiShopOrder.PAY_STATE_PAID);
|
// 判断其他待支付项是否已经支付
|
update.setUpdateTime(new Date());
|
order.setHongBaoPaymentState(update.getHongBaoPaymentState());
|
update.setState(getOrderPayState(order));
|
banLiShopOrderMapper.updateByPrimaryKeySelective(update);
|
}
|
|
private int getOrderPayState(BanLiShopOrder order) {
|
int needPayCount = 0;
|
int paidCount = 0;
|
// 获取订单付款状态
|
if (order.getHongBaoPayment() != null) {
|
needPayCount++;
|
if (order.getHongBaoPaymentState() != null
|
&& order.getHongBaoPaymentState() == BanLiShopOrder.PAY_STATE_PAID)
|
paidCount++;
|
}
|
|
if (order.getBalancePayment() != null) {
|
needPayCount++;
|
if (order.getBalancePaymentState() != null
|
&& order.getBalancePaymentState() == BanLiShopOrder.PAY_STATE_PAID)
|
paidCount++;
|
}
|
|
if (order.getMoneyPayment() != null) {
|
needPayCount++;
|
if (order.getMoneyPaymentState() != null && order.getMoneyPaymentState() == BanLiShopOrder.PAY_STATE_PAID)
|
paidCount++;
|
}
|
|
if (needPayCount == paidCount)
|
return BanLiShopOrder.STATE_PAID;
|
else {
|
if (paidCount == 0)
|
return BanLiShopOrder.STATE_NO_PAY;
|
else
|
return BanLiShopOrder.STATE_PART_PAY;
|
}
|
}
|
|
@Override
|
public void payOrderByMoney(Long orderId, BigDecimal money) throws BanLiShopOrderException {
|
BanLiShopOrder order = banLiShopOrderMapper.selectByPrimaryKeyForUpdate(orderId);
|
if (order == null) {
|
throw new BanLiShopOrderException(1, "订单不存在");
|
}
|
if (order.getMoneyPayment() == null)
|
throw new BanLiShopOrderException(2, "不需要采用现金支付");
|
|
if (order.getMoneyPaymentState() != null && order.getMoneyPaymentState() == BanLiShopOrder.PAY_STATE_PAID) {
|
throw new BanLiShopOrderException(3, "重复支付");
|
}
|
|
if (order.getMoneyPayment().compareTo(money) > 0) {
|
throw new BanLiShopOrderException(4, "支付金额不够");
|
}
|
|
// 支付成功
|
BanLiShopOrder update = new BanLiShopOrder();
|
update.setId(orderId);
|
update.setMoneyPaymentState(BanLiShopOrder.PAY_STATE_PAID);
|
// 判断其他待支付项是否已经支付
|
update.setUpdateTime(new Date());
|
order.setMoneyPaymentState(update.getMoneyPaymentState());
|
update.setState(getOrderPayState(order));
|
banLiShopOrderMapper.updateByPrimaryKeySelective(update);
|
}
|
|
@Override
|
public BanLiShopOrder selectByPrimaryKeyForUpdate(Long id) {
|
return banLiShopOrderMapper.selectByPrimaryKeyForUpdate(id);
|
}
|
|
@Override
|
public void invalidOrderByOrderId(Long id, String desc) {
|
// 判断订单是否存在
|
BanLiShopOrder order = banLiShopOrderMapper.selectByPrimaryKeyForUpdate(id);
|
if (order == null)
|
return;
|
|
// 判断是否处于未付款
|
if (order.getState() == BanLiShopOrder.STATE_NO_PAY) {
|
/**
|
* 查询是否已经微信支付
|
*/
|
if (order.getMoneyPayment() != null) {
|
try {
|
boolean isS = BanLiShopWXPayUtil.isPaySuccess(order.getOrderNo());
|
if (isS)// 支付成功，重新发送支付成功消息
|
{
|
BanLiShopOrderMQMsg msg = new BanLiShopOrderMQMsg(order.getId(), order.getUid());
|
Message message =MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER,
|
OrderTopicTagEnum.banLiShopOrderPaid,msg);
|
producer.send(message);
|
return;
|
}
|
|
} catch (WXOrderException e) {
|
e.printStackTrace();
|
} catch (Exception e) {
|
|
}
|
}
|
|
BanLiShopOrder update = new BanLiShopOrder();
|
update.setId(id);
|
update.setStateDesc(desc);
|
update.setState(BanLiShopOrder.STATE_INVALID);
|
update.setUpdateTime(new Date());
|
banLiShopOrderMapper.updateByPrimaryKeySelective(update);
|
}
|
}
|
|
@Override
|
public void rejectOrder(Long id, String msg) throws BanLiShopOrderException {
|
// 判断订单是否处于付款状态
|
BanLiShopOrder order = banLiShopOrderMapper.selectByPrimaryKey(id);
|
if (order == null)
|
throw new BanLiShopOrderException(1, "订单不存在");
|
|
if (order.getState() != BanLiShopOrder.STATE_PAID)
|
throw new BanLiShopOrderException(1, "订单未处于待审核状态");
|
|
Message message =MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.banLiShopOrderRefund,
|
new BanLiShopOrderMQMsg(order.getId(), order.getUid()));
|
try {
|
orderTransactionProducer.send(message, new LocalTransactionExecuter() {
|
@Override
|
public TransactionStatus execute(Message arg0, Object arg1) {
|
rejectOrderLocal(id, msg);
|
return TransactionStatus.CommitTransaction;
|
}
|
}, null);
|
} catch (Exception e) {// 消息发送失败
|
throw new BanLiShopOrderException(2, "MQ发送失败");
|
}
|
}
|
|
private void rejectOrderLocal(Long id, String msg) {
|
// 手动开启事务
|
org.springframework.transaction.TransactionStatus transactionStatus = transactionManager
|
.getTransaction(new DefaultTransactionDefinition());
|
try {
|
BanLiShopOrder order = banLiShopOrderMapper.selectByPrimaryKeyForUpdate(id);
|
BanLiShopOrder update = new BanLiShopOrder();
|
update.setId(order.getId());
|
update.setState(BanLiShopOrder.STATE_REJECT);
|
update.setStateDesc(msg);
|
update.setUpdateTime(new Date());
|
update.setRejectTime(new Date());
|
banLiShopOrderMapper.updateByPrimaryKeySelective(update);
|
// 消息发送
|
MsgRedPackUseContentDTO dto = new MsgRedPackUseContentDTO();
|
dto.setGoodsSetName(order.getOrderGoods().getSetName());
|
dto.setHongBao(order.getHongBaoPayment());
|
dto.setMoney(order.getMoneyPayment());
|
dto.setReason(msg);
|
dto.setTime(new Date());
|
userMoneyMsgNotificationService.redPackMsg(order.getUid(), MsgTypeMoneyTypeEnum.redPackUseFail,
|
new Gson().toJson(dto), null);
|
transactionManager.commit(transactionStatus);
|
} catch (Exception e) {
|
transactionManager.rollback(transactionStatus);
|
}
|
}
|
|
@Override
|
public BanLiShopOrder createOrder(Long goodsSetPayId, String chargeAccount, Long uid)
|
throws BanLiShopOrderException {
|
BanLiShopGoodsSetsPay pay = banLiShopGoodsSetPayService.selectByPrimaryKey(goodsSetPayId);
|
if (pay == null || pay.getGoodsSet() == null) {
|
throw new BanLiShopOrderException(21, "支付方式已下线");
|
}
|
|
BanLiShopGoodsSets set = banLiShopGoodsSetService.selectByPrimaryKey(pay.getGoodsSet().getId());
|
if (set == null || set.getState() == BanLiShopGoodsSets.STATE_OFFLINE) {
|
throw new BanLiShopOrderException(21, "商品已下线");
|
}
|
|
BanLiShopGoods goods = banLiShopGoodsService.selectByPrimaryKey(set.getGoods().getId());
|
if (goods == null || goods.getState() == BanLiShopGoods.STATE_OFFLINE) {
|
throw new BanLiShopOrderException(22, "商品已下线");
|
}
|
|
if(redPackForbidService.verifyForbid(uid))
|
throw new BanLiShopOrderException(25, "红包功能已被封禁");
|
|
if (pay.getHongBaoPrice() != null && pay.getHongBaoPrice().compareTo(new BigDecimal(0)) > 0) {
|
BigDecimal money = redPackBalanceService.getBalance(uid);
|
if (money.compareTo(pay.getHongBaoPrice()) < 0) {
|
throw new BanLiShopOrderException(24, "红包余额不足");
|
}
|
}
|
|
if (set.getStock() <= 0)
|
throw new BanLiShopOrderException(23, "商品库存不足");
|
|
BanLiShopOrder order = new BanLiShopOrder();
|
order.setChargeAccount(chargeAccount);
|
order.setChargeAccountType(goods.getChargeType());
|
order.setCreateTime(new Date());
|
order.setGoods(goods);
|
order.setGoodsSet(set);
|
if (pay.getHongBaoPrice() != null && pay.getHongBaoPrice().compareTo(new BigDecimal(0)) > 0) {
|
order.setHongBaoPayment(pay.getHongBaoPrice());
|
order.setHongBaoPaymentState(BanLiShopOrder.STATE_NO_PAY);
|
}
|
|
if (pay.getMoneyPrice() != null && pay.getMoneyPrice().compareTo(new BigDecimal(0)) > 0) {
|
order.setMoneyPayment(pay.getMoneyPrice());
|
order.setMoneyPaymentState(BanLiShopOrder.STATE_NO_PAY);
|
}
|
|
order.setState(BanLiShopOrder.STATE_NO_PAY);
|
order.setStateDesc("未付款");
|
order.setUid(uid);
|
|
return order;
|
}
|
|
@Override
|
public BanLiShopOrder selectByOrderNo(String orderNo) {
|
return banLiShopOrderMapper.selectByOrderNo(orderNo);
|
}
|
|
@Override
|
public List<BanLiShopOrder> listByUidAndState(Long uid, List<Integer> stateList, int page, int pageSize) {
|
return banLiShopOrderMapper.listByUidAndState(stateList, uid, (page - 1) * pageSize, pageSize);
|
}
|
|
@Override
|
public long countByUidAndState(Long uid, List<Integer> stateList) {
|
return banLiShopOrderMapper.countByUidAndState(stateList, uid);
|
}
|
|
}
|
