From 1a3cb3d15f1c159d12f7569c9058e6fbc114969a Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Mon, 19 Dec 2022 11:01:22 +0800
Subject: [PATCH] 20221219 1、生成物流单号 2、支付后订单状态自动成为待收货状态 3、新增编辑商品后,会自动计算补贴金额和商品星级,并显示在后台商品列表中

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java |  259 ++++++++++++++++++++++++++++++++++++---------------
 1 files changed, 184 insertions(+), 75 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java
index d9bad98..c05d958 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java
@@ -14,6 +14,7 @@
 import cc.mrbird.febs.mall.entity.*;
 import cc.mrbird.febs.mall.mapper.*;
 import cc.mrbird.febs.mall.service.*;
+import cc.mrbird.febs.mall.vo.ApiShopApplyVo;
 import cc.mrbird.febs.mall.vo.OrderDetailVo;
 import cc.mrbird.febs.mall.vo.OrderListVo;
 import cc.mrbird.febs.mall.vo.OrderRefundVo;
@@ -73,15 +74,19 @@
     private final IMallAchieveService mallAchieveService;
     private final UnipayService unipayService;
 
+    private final MallMemberBankSignMapper mallMemberBankSignMapper;
+    private final MallMemberBankMapper mallMemberBankMapper;
+    private final MallShopApplyMapper mallShopApplyMapper;
+
     @Override
     @Transactional(rollbackFor = Exception.class)
     public Long createOrder(AddOrderDto addOrderDto) {
         MallMember member = LoginUserUtil.getLoginUser();
 
-        MallAddressInfo address = mallAddressInfoMapper.selectAddressInfoByMemberIdAndId(member.getId(), addOrderDto.getAddressId());
-        if (address == null) {
-            throw new FebsException("地址不存在");
-        }
+//        MallAddressInfo address = mallAddressInfoMapper.selectAddressInfoByMemberIdAndId(member.getId(), addOrderDto.getAddressId());
+//        if (address == null) {
+//            throw new FebsException("地址不存在");
+//        }
 
         String orderNo = MallUtils.getOrderNum();
         MallOrderInfo orderInfo = new MallOrderInfo();
@@ -89,17 +94,33 @@
         orderInfo.setOrderTime(new Date());
         orderInfo.setMemberId(member.getId());
         orderInfo.setStatus(OrderStatusEnum.WAIT_PAY.getValue());
-        orderInfo.setName(address.getName());
-        orderInfo.setAddress(address.getArea() + address.getAddress());
-        orderInfo.setPhone(address.getPhone());
-        orderInfo.setLatitude(address.getLatitude());
-        orderInfo.setLongitude(address.getLongitude());
+//        orderInfo.setName(address.getName());
+//        orderInfo.setAddress(address.getArea() + address.getAddress());
+//        orderInfo.setPhone(address.getPhone());
+//        orderInfo.setLatitude(address.getLatitude());
+//        orderInfo.setLongitude(address.getLongitude());
         orderInfo.setRemark(addOrderDto.getRemark());
         orderInfo.setOrderType(addOrderDto.getOrderType());
 
         if (CollUtil.isEmpty(addOrderDto.getItems())) {
             throw new FebsException("参数错误");
         }
+
+//        int deliverType = ObjectUtil.isEmpty(addOrderDto.getDeliverType()) ? 1 : addOrderDto.getDeliverType();
+//        if(2 == deliverType){
+//            if(ObjectUtil.isEmpty(addOrderDto.getShopId())){
+//                throw new FebsException("请选择门店");
+//            }
+//            Long shopId = addOrderDto.getShopId();
+//            MallShopApply mallShopApply = mallShopApplyMapper.selectById(shopId);
+//            if(ObjectUtil.isEmpty(mallShopApply)){
+//                throw new FebsException("请选择门店");
+//            }
+//            if(MallShopApply.APPLY_AGREE != mallShopApply.getStatus()){
+//                throw new FebsException("请选择门店");
+//            }
+//            orderInfo.setShopId(shopId);
+//        }
 
         this.baseMapper.insert(orderInfo);
         BigDecimal total = BigDecimal.ZERO;
@@ -183,7 +204,13 @@
         }
 
         orderInfo.setAmount(total);
-        orderInfo.setCarriage(carriage);
+//        if(2 == deliverType){
+//            orderInfo.setDeliverType(2);
+//            orderInfo.setCarriage(BigDecimal.ZERO);
+//        }else{
+//            orderInfo.setDeliverType(1);
+//            orderInfo.setCarriage(carriage);
+//        }
         this.baseMapper.updateById(orderInfo);
 
         agentProducer.sendOrderCancelDelayMsg(orderInfo.getId(), 15 * 60 * 1000L);
@@ -209,12 +236,12 @@
         this.baseMapper.updateById(orderInfo);
     }
 
-    public static void main(String[] args) {
-        String unipayStr = "{\"r1_MerchantNo\":\"888118000001971\",\"rd_Pic\":\"\",\"r6_FrpCode\":\"ALIPAY_H5\",\"r7_TrxNo\":\"100222082332490699\",\"r0_Version\":\"1.0\",\"r3_Amount\":\"0.01\",\"r4_Cur\":\"1\",\"r2_OrderNo\":\"2022082212510288174\",\"rb_CodeMsg\":\"\",\"hmac\":\"1659BB77DEDDF9956EA4D6DF227C3B14\",\"ra_Code\":100,\"rc_Result\":\"<html><head><meta http-equiv='Content-Type' content='text/html; charset=UTF-8'><title></title></head><body><script type='text/javascript'>location.href='https://qr.alipay.com/bax019737vbdwoisxcdp00a2';</script></body></html>\"}";
-        JSONObject jsonObject = JSONUtil.parseObj(unipayStr);
-        String r7_trxNo = (String) jsonObject.get("r7_TrxNo");
-        System.out.println(r7_trxNo);
-    }
+//    public static void main(String[] args) {
+//        String unipayStr = "{\"r1_MerchantNo\":\"888118000001971\",\"rd_Pic\":\"\",\"r6_FrpCode\":\"ALIPAY_H5\",\"r7_TrxNo\":\"100222082332490699\",\"r0_Version\":\"1.0\",\"r3_Amount\":\"0.01\",\"r4_Cur\":\"1\",\"r2_OrderNo\":\"2022082212510288174\",\"rb_CodeMsg\":\"\",\"hmac\":\"1659BB77DEDDF9956EA4D6DF227C3B14\",\"ra_Code\":100,\"rc_Result\":\"<html><head><meta http-equiv='Content-Type' content='text/html; charset=UTF-8'><title></title></head><body><script type='text/javascript'>location.href='https://qr.alipay.com/bax019737vbdwoisxcdp00a2';</script></body></html>\"}";
+//        JSONObject jsonObject = JSONUtil.parseObj(unipayStr);
+//        String r7_trxNo = (String) jsonObject.get("r7_TrxNo");
+//        System.out.println(r7_trxNo);
+//    }
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -233,10 +260,31 @@
         String rcResult = "";
         switch (payOrderDto.getType()) {
             case "1":
+                UnipayDto unipayDtoWx = new UnipayDto();
+//                unipayDto.setAmount(new BigDecimal("0.01"));
+                unipayDtoWx.setAmount(orderInfo.getAmount());
+                unipayDtoWx.setFrpCode("WEIXIN_APP3");
+                unipayDtoWx.setTradeMerchantNo("777180800385820");
+                unipayDtoWx.setOrderNo(orderInfo.getOrderNo());
+                List<MallOrderItem> itemsWx = orderInfo.getItems();
+                if(CollUtil.isEmpty(itemsWx)){
+                    unipayDtoWx.setProductName("商品");
+                }else{
+                    unipayDtoWx.setProductName(itemsWx.get(0).getGoodsName());
+                }
+                String unipayStrWx = unipayService.unipay(unipayDtoWx);
+                if("fail" == unipayStrWx){
+                    throw new FebsException("支付失败");
+                }else{
+//                    JSONUtil.parseObj(unipayStr);
+                    JSONObject jsonObject = JSONUtil.parseObj(unipayStrWx);
+                    payResultStr = (String) jsonObject.get("r7_TrxNo");
+                    rcResult = (String) jsonObject.get("rc_Result");
+                }
+                orderInfo.setPayOrderNo(payResultStr);
 //                orderInfo.setPayOrderNo(payOrderDto.getPayOrderNo());
 //                orderInfo.setPayImage(payOrderDto.getPayImage());
                 orderInfo.setPayMethod("微信支付");
-                agentProducer.sendOrderReturn(orderInfo.getId());
                 break;
             case "2":
 //                if (StrUtil.isNotBlank(orderInfo.getPayOrderNo())) {
@@ -248,7 +296,7 @@
 //                unipayDto.setAmount(new BigDecimal("0.01"));
                 unipayDto.setAmount(orderInfo.getAmount());
                 unipayDto.setFrpCode("ALIPAY_H5");
-                unipayDto.setTradeMerchantNo("777180800385820");
+                unipayDto.setTradeMerchantNo("777184100385821");
                 unipayDto.setOrderNo(orderInfo.getOrderNo());
                 List<MallOrderItem> items = orderInfo.getItems();
                 if(CollUtil.isEmpty(items)){
@@ -274,50 +322,55 @@
 
                 orderInfo.setPayOrderNo(orderInfo.getOrderNo());
                 orderInfo.setPayMethod("余额支付");
-                orderInfo.setStatus(OrderStatusEnum.WAIT_SHIPPING.getValue());
+//                orderInfo.setStatus(OrderStatusEnum.WAIT_SHIPPING.getValue());
+                //订单支付成功后,订单直接变成待收货
+                orderInfo.setStatus(OrderStatusEnum.WAIT_FINISH.getValue());
+                //生成物流编号
+                String logisticsNo = MallUtils.getLogisticsNum(StrUtil.subSuf(payResultStr, payResultStr.length() - 2));
+                orderInfo.setPayTradeNo(logisticsNo);
                 orderInfo.setPayTime(new Date());
                 orderInfo.setPayResult("1");
 
-                boolean hasTc = false;
+//                boolean hasTc = false;
                 // 静态倍数
-                List<MallOrderItem> orderItems = this.baseMapper.getMallOrderItemByOrderId(orderInfo.getId());
-                if (CollUtil.isNotEmpty(orderItems)) {
-                    for (MallOrderItem orderItem : orderItems) {
-                        MallGoods mallGoods = mallGoodsMapper.selectById(orderItem.getGoodsId());
-                        BigDecimal score = BigDecimal.ZERO;
-                        MallGoodsSku sku = mallGoodsSkuMapper.selectById(orderItem.getSkuId());
-                        if (mallGoods.getIsNormal() == 2) {
-                            hasTc = true;
-                            score = sku.getPresentPrice().multiply(mallGoods.getStaticMulti()).multiply(new BigDecimal(orderItem.getCnt()));
-//                            BigDecimal staticMulti = mallGoods.getStaticMulti() == null ? BigDecimal.ZERO : mallGoods.getStaticMulti();
-//                            score = sku.getPresentPrice().multiply(staticMulti);
-                            // 普通商品也及时结算,不再10天结算
-                        } else {
-                            score = sku.getPresentPrice();
-                        }
-
-                        if (score.compareTo(BigDecimal.ZERO) > 0) {
-                            memberWalletService.add(score, member.getId(), "score");
-                            mallMoneyFlowService.addMoneyFlow(member.getId(), score, MoneyFlowTypeEnum.STATIC_BONUS.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.SCORE.getValue());
-
-                            // 添加业绩
-                            mallAchieveService.add(orderItem.getId());
-                        }
-                    }
-                }
+//                List<MallOrderItem> orderItems = this.baseMapper.getMallOrderItemByOrderId(orderInfo.getId());
+//                if (CollUtil.isNotEmpty(orderItems)) {
+//                    for (MallOrderItem orderItem : orderItems) {
+//                        MallGoods mallGoods = mallGoodsMapper.selectById(orderItem.getGoodsId());
+//                        BigDecimal score = BigDecimal.ZERO;
+//                        MallGoodsSku sku = mallGoodsSkuMapper.selectById(orderItem.getSkuId());
+//                        if (mallGoods.getIsNormal() == 2) {
+//                            hasTc = true;
+//                            score = sku.getPresentPrice().multiply(mallGoods.getStaticMulti()).multiply(new BigDecimal(orderItem.getCnt()));
+////                            BigDecimal staticMulti = mallGoods.getStaticMulti() == null ? BigDecimal.ZERO : mallGoods.getStaticMulti();
+////                            score = sku.getPresentPrice().multiply(staticMulti);
+//                            // 普通商品也及时结算,不再10天结算
+//                        } else {
+//                            score = sku.getPresentPrice();
+//                        }
+//
+//                        if (score.compareTo(BigDecimal.ZERO) > 0) {
+//                            memberWalletService.add(score, member.getId(), "score");
+//                            mallMoneyFlowService.addMoneyFlow(member.getId(), score, MoneyFlowTypeEnum.STATIC_BONUS.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.SCORE.getValue());
+//
+//                            // 添加业绩
+//                            mallAchieveService.add(orderItem.getId());
+//                        }
+//                    }
+//                }
 
                 // 购买套餐后,升级为普通会员
-                if (hasTc) {
-                    MallMember mallMember = memberMapper.selectById(member.getId());
-                    if (AgentLevelEnum.ZERO_LEVEL.name().equals(mallMember.getLevel())) {
-                        mallMember.setLevel(AgentLevelEnum.FIRST_LEVEL.name());
-                        memberMapper.updateById(mallMember);
-                    }
-                }
+//                if (hasTc) {
+//                    MallMember mallMember = memberMapper.selectById(member.getId());
+//                    if (AgentLevelEnum.ZERO_LEVEL.name().equals(mallMember.getLevel())) {
+//                        mallMember.setLevel(AgentLevelEnum.FIRST_LEVEL.name());
+//                        memberMapper.updateById(mallMember);
+//                    }
+//                }
 
                 mallMoneyFlowService.addMoneyFlow(member.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue());
-                agentProducer.sendAutoLevelUpMsg(member.getId());
-                agentProducer.sendOrderReturn(orderInfo.getId());
+//                agentProducer.sendAutoLevelUpMsg(member.getId());
+//                agentProducer.sendOrderReturn(orderInfo.getId());
                 break;
             case "4":
                 if (orderInfo.getOrderType() != 2) {
@@ -334,24 +387,27 @@
                 mallMoneyFlowService.addMoneyFlow(member.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(),  FlowTypeEnum.PRIZE_SCORE.getValue());
                 break;
             case "5":
-                AgreementSignDto agreementSignDto = new AgreementSignDto();
-                agreementSignDto.setOrderNo(orderInfo.getOrderNo());
-                agreementSignDto.setSmsCode(payOrderDto.getSmsCode());
-                String agreementSignStr = unipayService.agreementSign(agreementSignDto);
-                if("fail".equals(agreementSignStr)){
-                    throw new FebsException("支付失败");
-                }else{
-                    JSONObject jsonObject = JSONUtil.parseObj(agreementSignStr);
-                    payResultStr = (String) jsonObject.get("biz_code");
-                    String signBizMsg = (String) jsonObject.get("biz_msg");
-                    String err_msg = (String) jsonObject.get("err_msg");
-                    if(!"JS000000".equals(payResultStr)){
-                        throw new FebsException(signBizMsg);
-                    }
-                    if(ObjectUtil.isNotNull(jsonObject.get("err_code"))){
-                        throw new FebsException(err_msg);
-                    }
-                }
+//                AgreementSignDto agreementSignDto = new AgreementSignDto();
+//                agreementSignDto.setOrderNo(orderInfo.getOrderNo());
+//                agreementSignDto.setSmsCode(payOrderDto.getSmsCode());
+//                String agreementSignStr = unipayService.agreementSign(agreementSignDto);
+//                if("fail".equals(agreementSignStr)){
+//                    throw new FebsException("支付失败");
+//                }else{
+//                    JSONObject jsonObject = JSONUtil.parseObj(agreementSignStr);
+//                    payResultStr = (String) jsonObject.get("biz_code");
+//                    String signData = (String) jsonObject.get("data");
+//                    String signBizMsg = (String) jsonObject.get("biz_msg");
+//
+//                    JSONObject signDatajsonObject = JSONUtil.parseObj(signData);
+//                    String err_msg = (String) signDatajsonObject.get("err_msg");
+//                    if(!"JS000000".equals(payResultStr)){
+//                        throw new FebsException(signBizMsg);
+//                    }
+//                    if(ObjectUtil.isNotNull(signDatajsonObject.get("err_code"))){
+//                        throw new FebsException(err_msg);
+//                    }
+//                }
                 
                 AgreementPayDto agreementPayDto = new AgreementPayDto();
                 agreementPayDto.setOrderNo(orderInfo.getOrderNo());
@@ -367,10 +423,20 @@
                 }else{
                     agreementPayDto.setOrderDesc(itemsGoods.get(0).getGoodsName());
                 }
-                agreementPayDto.setBankNo(payOrderDto.getBankNo());
+                Long bankId = payOrderDto.getBankId() == null ? 0L : payOrderDto.getBankId();
+                MallMemberBank mallMemberBank = mallMemberBankMapper.selectById(bankId);
+                if(ObjectUtil.isEmpty(mallMemberBank)){
+                    throw new FebsException("银行卡未添加");
+                }
+                String bankNo = mallMemberBank.getBankNo();
+                MallMemberBankSign mallMemberBankSign = mallMemberBankSignMapper.selectOneByMemberIdAndBankCardNo(member.getId(), bankNo);
+                if(ObjectUtil.isEmpty(mallMemberBankSign)){
+                    throw new FebsException("银行卡未签约");
+                }
+                agreementPayDto.setBankNo(bankNo);
                 String agreementPayStr = unipayService.agreementPay(agreementPayDto);
 
-                if("fail".equals(agreementSignStr)){
+                if("fail".equals(agreementPayStr)){
                     throw new FebsException("支付失败");
                 }else{
                     JSONObject jsonObject = JSONUtil.parseObj(agreementPayStr);
@@ -394,6 +460,21 @@
         map.put("rcResult", rcResult);
 
         return map;
+    }
+
+    public static void main(String[] args) {
+        String str = "{\"biz_code\":\"JS000000\",\"biz_msg\":\"成功\",\"data\":\"{\\\"order_status\\\":\\\"P2000\\\",\\\"jp_order_no\\\":\\\"100120220826446740396081496064\\\",\\\"err_msg\\\":\\\"短信验证码不符\\\",\\\"err_code\\\":\\\"CP110026\\\",\\\"sign_no\\\":\\\"\\\",\\\"mch_order_no\\\":\\\"NO_2022082618263952399\\\"}\",\"mch_no\":\"888118000001971\",\"rand_str\":\"an2w7ulf5ru6upkk5bdg441kdi3gnpvu\",\"resp_code\":\"SUCCESS\",\"sec_key\":\"\",\"sign\":\"NiJXRTSIZ9xZMUOwEHiEHdZXmgL2cHUU5WUa1NbMRRzui0DIiuZSW4e31LjnBxwVwmy3uuPMP+tqhY8VLyC8uCFOdGdZI7e72VuRvyvaiW7/sqCrsfgPOBEjiGE/CmSMRoEXv9HmqCyNBF6iHSEhQJql5Yge30dQdyB6xFfqjk0=\",\"sign_type\":\"2\"}";
+
+        JSONObject jsonObject = JSONUtil.parseObj(str);
+        String payResultStr = (String) jsonObject.get("biz_code");
+        String signBizMsg = (String) jsonObject.get("biz_msg");
+        String signData = (String) jsonObject.get("data");
+
+        JSONObject signDatajsonObject = JSONUtil.parseObj(signData);
+        String err_msg = (String) signDatajsonObject.get("err_msg");
+        if(ObjectUtil.isNotNull(signDatajsonObject.get("err_code"))){
+            System.out.println(err_msg);
+        }
     }
 
     private String balancePay(MallOrderInfo orderInfo, String tradePwd, String field) {
@@ -437,7 +518,8 @@
 
         OrderDetailVo orderDetailVo = MallOrderInfoConversion.INSTANCE.entityToDetailVo(orderInfo);
 
-        if (orderInfo.getStatus() == OrderStatusEnum.WAIT_FINISH.getValue()) {
+        Integer deliverType = (ObjectUtil.isEmpty(orderInfo.getDeliverType()) ? new Integer(0):orderInfo.getDeliverType());
+        if (orderInfo.getStatus() == OrderStatusEnum.WAIT_FINISH.getValue() && 2 != deliverType) {
             MallExpressInfo expressInfo = expressInfoMapper.selectByOrderId(orderInfo.getId());
             orderDetailVo.setExpressNo(expressInfo.getExpressNo());
             orderDetailVo.setExpressCom(expressInfo.getExpressCom());
@@ -454,6 +536,20 @@
 
             long remainTime = DateUtil.between(new Date(), endTime, DateUnit.SECOND, false);
             orderDetailVo.setRemainTime(remainTime);
+        }
+        if(2 == deliverType){
+            MallShopApply mallShopApply = mallShopApplyMapper.selectById(orderInfo.getShopId());
+            if(ObjectUtil.isNotEmpty(mallShopApply)){
+                ApiShopApplyVo apiShopApplyVo = new ApiShopApplyVo();
+                apiShopApplyVo.setName(mallShopApply.getName());
+                apiShopApplyVo.setPhone(mallShopApply.getPhone());
+                apiShopApplyVo.setSaleArea(mallShopApply.getSaleArea());
+                apiShopApplyVo.setLatitude(mallShopApply.getLatitude());
+                apiShopApplyVo.setLongitude(mallShopApply.getLongitude());
+                apiShopApplyVo.setShopName(mallShopApply.getShopName());
+                apiShopApplyVo.setAddress(mallShopApply.getAddress());
+                orderDetailVo.setApiShopApplyVo(apiShopApplyVo);
+            }
         }
         return orderDetailVo;
     }
@@ -627,4 +723,17 @@
         }
     }
 
+    @Override
+    public FebsResponse bangCardSign(BangCardSignDto bangCardSignDto) {
+        MallMember member = LoginUserUtil.getLoginUser();
+        Long memberId = member.getId();
+        String bankCard = bangCardSignDto.getBankCard();
+        MallMemberBankSign mallMemberBankSign = mallMemberBankSignMapper.selectOneByMemberIdAndBankCardNo(memberId,bankCard);
+        if(ObjectUtil.isNotEmpty(mallMemberBankSign)){
+            return new FebsResponse().success().data(mallMemberBankSign);
+        }else{
+            return new FebsResponse().success();
+        }
+    }
+
 }

--
Gitblit v1.9.1