ufo / yohoufo-fore · Commits

Go to a project

Authored by qinchao
Commit 3bc8de7a02709db93ff97874fbf2402400c9848f 1 parent c233e29e

卖家发货前，买家取消订单，重新上架

Inline Side-by-side
Showing 2 changed files with 32 additions and 11 deletions
... ... @@ -33,6 +33,7 @@ import com.yohoufo.order.service.proxy.CouponProxyService;
import com.yohoufo.order.service.proxy.InBoxFacade;
import com.yohoufo.order.service.proxy.OrderStatusFlowService;
import com.yohoufo.order.utils.LoggerUtils;
import com.yohoufo.order.utils.OrderAssist;
import com.yohoufo.order.utils.PaymentHelper;
import lombok.Setter;
import org.slf4j.Logger;
... ... @@ -122,17 +123,27 @@ public class BuyerOrderCancelService {
//退还优惠券
refundCouponIfNeed(buyerUid, orderCode);
int skup = bsdEvent.getSkup();
SellerOrderGoods psog = sellerOrderGoodsMapper.selectByPrimaryKey(skup);
int targetGoodsStatus = SkupStatus.BUYER_CANCEL_BEFORE_SELLER_DELIVER.getCode();
int targetSellerOrderStatus = SellerOrderStatus.BUYER_CANCEL_BEFORE_SELLER_DELIVER.getCode();
//重新上架标志
boolean reSellAfterCancel=(OrderAssist.skupIsCommonInStock(psog.getAttributes())||OrderAssist.skupIsAdvance(psog.getAttributes()))?true:false;
if(reSellAfterCancel){
targetGoodsStatus = SkupStatus.CAN_SELL.getCode();
targetSellerOrderStatus = SellerOrderStatus.HAS_PAYED.getCode();
}
SellerOrderGoods targetGoods = new SellerOrderGoods();
targetGoods.setId(skup);
targetGoods.setStatus(SkupStatus.BUYER_CANCEL_BEFORE_SELLER_DELIVER.getCode());
targetGoods.setStatus(targetGoodsStatus);
targetGoods.setExceptStatus(SkupStatus.SELL_OUT.getCode());
sellerOrderGoodsMapper.updateStatusBySkpu(targetGoods);
SellerOrder soc = new SellerOrder();
soc.setStatus(SellerOrderStatus.BUYER_CANCEL_BEFORE_SELLER_DELIVER.getCode());
soc.setStatus(targetSellerOrderStatus);
soc.setUpdateTime(DateUtil.getCurrentTimeSecond());
sellerOrderMapper.updateBySkups(soc, Arrays.asList(skup));
SellerOrderGoods psog = sellerOrderGoodsMapper.selectByPrimaryKey(skup);
if (noResponsibility){
inBoxFacade.noticeSellerWhenBuyerCancelNoResponsibility(psog, orderCode);
}else {
... ... @@ -145,7 +156,7 @@ public class BuyerOrderCancelService {
TransferCase transferCase = TransferCase.PART_GOODS_MONEY_TO_SELLER;
//（退费）扣除赔偿款，计算剩余的货款，退给买家
BuyerCancelAfterProcessTask bcapt = new BuyerCancelAfterProcessTask(buyerOrder, skup,
bpcr, transferCase);
bpcr, transferCase,reSellAfterCancel);
bcapt.targetOrderStatus = targetOrderStatus;
bcapt.setSwdType(SellerWalletDetail.Type.BUYER_CANCEL_NO_DELIVERY);
Future<PayRefundBo> future = ThreadPoolFactory.getBuyerCancelThreadPool().submit(bcapt);
... ... @@ -262,7 +273,7 @@ public class BuyerOrderCancelService {
//（退费）扣除赔偿款，计算剩余的货款，退给买家
TransferCase transferCase = TransferCase.PART_GOODS_MONEY_TO_SELLER;
BuyerCancelAfterProcessTask bcapt = new BuyerCancelAfterProcessTask(buyerOrder, skup,
bpcr, transferCase);
bpcr, transferCase,false);
bcapt.targetOrderStatus = targetOrderStatus;
bcapt.setSwdType(SellerWalletDetail.Type.BUYER_CANCEL_DELIVERY);
Future<PayRefundBo> future = ThreadPoolFactory.getBuyerCancelThreadPool().submit(bcapt);
... ... @@ -293,17 +304,19 @@ public class BuyerOrderCancelService {
BuyerOrder buyerOrder;
TransferCase transferCase;
OrderStatus targetOrderStatus;
boolean reSellFlag;//重新上架标志，重新上架则不退保证金了
@Setter
SellerWalletDetail.Type swdType;
public BuyerCancelAfterProcessTask(BuyerOrder buyerOrder, int skup, BuyerPenaltyCalResult bpcr, TransferCase transferCase) {
public BuyerCancelAfterProcessTask(BuyerOrder buyerOrder, int skup, BuyerPenaltyCalResult bpcr, TransferCase transferCase,boolean reSellFlag) {
this.buyerUid = buyerOrder.getUid();
this.orderCode = buyerOrder.getOrderCode();
this.skup = skup;
this.bpcr = bpcr;
this.transferCase = transferCase;
this.buyerOrder = buyerOrder;
this.reSellFlag = reSellFlag;
}
private PayRefundBo refundSellerEarnestMoney(SellerOrder sellerOrder){
... ... @@ -421,14 +434,17 @@ public class BuyerOrderCancelService {
public PayRefundBo call() throws Exception {
// 整个过程异步去执行（考虑退费依赖订单状态）
//（退费）退保证金给卖家
logger.info("in BuyerCancelAfterProcessTask call buyerUid {}, orderCode {}, skup {}, transferCase {}, compensate {}",
buyerUid, orderCode, skup, transferCase, bpcr);
logger.info("in BuyerCancelAfterProcessTask call buyerUid {}, orderCode {}, skup {}, transferCase {}, compensate {},reSellFlag {}",
buyerUid, orderCode, skup, transferCase, bpcr,reSellFlag);
PayRefundBo prb = null;
try {
SellerOrder sellerOrder = sellerOrderMapper.selectBySkup(skup);
logger.info("in BuyerCancelAfterProcessTask call sellerOrderMapper.selectBySkup, buyerUid {}, orderCode {}, skup {}",
buyerUid, orderCode, skup );
prb = refundSellerEarnestMoney(sellerOrder);
logger.info("in BuyerCancelAfterProcessTask call sellerOrderMapper.selectBySkup, buyerUid {}, orderCode {}, skup {},reSellFlag {}",
buyerUid, orderCode, skup,reSellFlag );
if(!reSellFlag){
//只有不重新上架，才退保证金
prb = refundSellerEarnestMoney(sellerOrder);
}
//（转账）瓜分指定赔偿款给卖家和平台
transferPenalty(bpcr);
... ...
... ... @@ -22,6 +22,11 @@ public class OrderAssist {
return new StringBuilder().append(storageId).append("_").append(salePrice).toString();
}
//普通现货
public static boolean skupIsCommonInStock(Integer attribute){
return Objects.nonNull(attribute) && SkupType.IN_STOCK.getCode() == attribute;
}
public static boolean skupIsAdvance(Integer attribute){
return Objects.nonNull(attribute) && SkupType.ADVANCE.getCode() == attribute;
}
... ...