From 56fcde8c93a1a10bc50fac775e370a2db57f520e Mon Sep 17 00:00:00 2001
From: rk <94314517@qq.com>
Date: 星期二, 20 一月 2026 17:08:30 +0800
Subject: [PATCH] 小程序   接口开发

---
 server/dmmall_service/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java |   98 +++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 83 insertions(+), 15 deletions(-)

diff --git a/server/dmmall_service/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java b/server/dmmall_service/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java
index c9de79c..80590c6 100644
--- a/server/dmmall_service/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java
+++ b/server/dmmall_service/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java
@@ -1,5 +1,6 @@
 package com.doumee.service.business.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.Wrapper;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.doumee.biz.system.SystemDictDataBiz;
@@ -24,6 +25,7 @@
 import com.doumee.dao.web.request.*;
 import com.doumee.dao.web.request.goods.*;
 import com.doumee.dao.web.response.HomeInfoResponse;
+import com.doumee.dao.web.response.MailConfigResponse;
 import com.doumee.dao.web.response.MyPageResponse;
 import com.doumee.dao.web.response.goods.*;
 import com.doumee.service.business.AreasService;
@@ -83,6 +85,12 @@
     private ShopGoodsRelationMapper shopGoodsRelationMapper;
     @Autowired
     private MemberMapper memberMapper;
+    @Autowired
+    private CouponMapper couponMapper;
+    @Autowired
+    private MemberCouponJoinMapper memberCouponJoinMapper;
+    @Autowired
+    private InviteRecordMapper inviteRecordMapper;
 
     @Autowired
     private GoodsorderDetailMapper goodsorderDetailMapper;
@@ -891,6 +899,8 @@
                     .eq(MemberCoupon::getId,orderPayConfirmResponse.getMemberCoupon().getId())
             );
         }
+        goodsorder.setReturnCustomerIntegral(getBackIntegral(goodsorder.getPrice(),Constants.ONE));
+        goodsorder.setReturnMemberIntegral(getBackIntegral(goodsorder.getPrice(),Constants.ZERO));
         goodsorderMapper.insert(goodsorder);
         List<OrderGoodsCalculateResponse> goodsCalculateList  = orderPayConfirmResponse.getGoodsCalculateList();
         if(CollectionUtils.isEmpty(goodsCalculateList)){
@@ -1466,6 +1476,7 @@
         //閭垂閲戦
         if(Objects.nonNull(request.getReceiveType())){
             if(Constants.equalsInteger(request.getReceiveType(),Constants.ZERO)){
+                MailConfigResponse mailConfigResponse = systemDictDataBiz.getMailConfig();
                 if(Objects.nonNull(request.getAddressId())){
                     Addr addr = addrMapper.selectById(request.getAddressId());
                     if(Objects.isNull(addr)){
@@ -1481,28 +1492,28 @@
                         Labels  labels = labelsMapper.selectById(areas.getYunFeeId());
                         if(Objects.nonNull(labels)&&StringUtils.isNotBlank(labels.getParam())){
                             //{weight0:10,fee0:10,weight1:10,fee1:10},{棣栭噸:10,棣栭噸杩愯垂锛�10,缁噸锛�10,缁噸璐癸細10}
-
+                            mailConfigResponse = JSONObject.parseObject(labels.getParam(),MailConfigResponse.class);
                         }
-
                     }
-
-
-
                 }
-
-
-
-                //TODO  鏍规嵁鏀惰揣鍦板潃 鏌ヨ杩愯垂閰嶇疆
-
-
-
+                //鏍规嵁鏀惰揣鍦板潃 鏌ヨ杩愯垂閰嶇疆
                 //璁$畻鍟嗗搧淇℃伅鎬婚噸閲�
                 BigDecimal totalWeight = goodsCalculateList.stream().map(i->
                         i.getWeight().multiply(new BigDecimal(i.getGoodsNum().toString()))
                 ).reduce(BigDecimal.ZERO,BigDecimal::add);
-                //TODO 鏆傛椂鏃犺繍璐归噾棰�
-                mailAmount = BigDecimal.ZERO;
-
+                if(totalWeight.compareTo(mailConfigResponse.getWeight0())>=Constants.ZERO){
+                    mailAmount = mailConfigResponse.getFee0();
+                }else{
+                    //瓒呴噸閲嶉噺
+                    BigDecimal overWeight = totalWeight.subtract(mailConfigResponse.getWeight0());
+                    if (overWeight.compareTo(mailConfigResponse.getWeight1()) >= Constants.ZERO) {
+                        mailAmount = mailConfigResponse.getFee0().add(
+                                mailConfigResponse.getFee1()
+                                .multiply(overWeight.divide(mailConfigResponse.getWeight1(),2,RoundingMode.HALF_UP)));
+                    }else{
+                        mailAmount = mailConfigResponse.getFee0().add(mailConfigResponse.getFee1());
+                    }
+                }
                 amount = amount.add(mailAmount);
             }
         }
@@ -1677,11 +1688,66 @@
         //鏍规嵁璁㈠崟绫诲瀷杩涜绉垎璧犻��
         //涓嬪崟纭鏀惰揣 锛岃禒閫佺粡閿�鍟嗙Н鍒�
         this.orderAddShopIntegral(goodsorder);
+        //涓嬪崟瀹屾垚 鏍规嵁淇℃伅纭鏄惁闇�瑕佽禒閫侀個璇疯�呬紭鎯犲埜
+        this.orderDoneRewardInviteCoupon(goodsorder);
         //娑堣垂鑰呯‘璁ゆ敹璐�
         this.orderAddMemberIntegral(goodsorder);
         //缁忛攢鍟� 缁撶畻閲戦
         this.orderAddShopCash(goodsorder);
     }
+
+
+    /**
+     * 璁㈠崟纭鏀惰揣锛岃禒閫侀個璇疯�呬紭鎯犲埜
+     * @param
+     */
+    public void orderDoneRewardInviteCoupon(Goodsorder goodsorder){
+        PlatformConfigDTO platformConfigDTO = systemDictDataService.getPlatformConfigDTO();
+        if (platformConfigDTO.getShareCouponRewardStatus().equals(Constants.ONE)) {
+            return;
+        }
+        Member member = memberMapper.selectById(goodsorder.getMemberId());
+        if(Objects.isNull(member)||member.getIsdeleted().equals(Constants.ONE)){
+            return;
+        }
+        InviteRecord inviteRecord = inviteRecordMapper.selectOne(new QueryWrapper<InviteRecord>().lambda()
+                .eq(InviteRecord::getMemberId,member.getId())
+                .eq(InviteRecord::getIsdeleted,Constants.ZERO)
+                .eq(InviteRecord::getFirstOrderStatus,Constants.ZERO)
+                .last("limit 1")
+        );
+        if(Objects.isNull(inviteRecord)){
+            return;
+        }
+        Member inviteMember = memberMapper.selectById(inviteRecord.getInviteId());
+        if(Objects.isNull(inviteMember)||inviteMember.getIsdeleted().equals(Constants.ONE)){
+            return;
+        }
+
+        List<JSONObject> shareCouponRewardList = platformConfigDTO.getShareCouponRewardList();
+        //[{"num":"2","couponId":6},{"num":"3","couponId":5}]
+        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(shareCouponRewardList)){
+            List<MemberCoupon> memberCouponList = new ArrayList<>();
+            for (JSONObject jsonObject:shareCouponRewardList) {
+                Integer couponId = jsonObject.getInteger("couponId");
+                Integer num = jsonObject.getInteger("num");
+                Coupon coupon =  couponMapper.selectById(couponId);
+                if(Objects.isNull(coupon)||Constants.equalsInteger(coupon.getIsdeleted(),Constants.ONE)&&num>Constants.ZERO){
+                    continue;
+                }
+                MemberCoupon memberCoupon = MemberCoupon.couponToBean(coupon,inviteMember,new Date(),Constants.ONE,null);
+                for (int i = 0; i < num; i++) {
+                    memberCouponList.add(memberCoupon);
+                }
+            }
+            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(memberCouponList)){
+                memberCouponJoinMapper.insert(memberCouponList);
+            }
+        }
+    }
+
+
+
 
     /**
      * 璁㈠崟鏍搁攢
@@ -1716,6 +1782,8 @@
         if(Constants.equalsInteger(goodsorder.getPayMethod(),Constants.ZERO)){
             //璧犻�佹秷璐硅�呯Н鍒�
             this.orderAddMemberIntegral(goodsorder);
+            //涓嬪崟瀹屾垚 鏍规嵁淇℃伅纭鏄惁闇�瑕佽禒閫侀個璇疯�呬紭鎯犲埜
+            this.orderDoneRewardInviteCoupon(goodsorder);
             //缁忛攢鍟� 娣诲姞璧犻�佺Н鍒�
             this.orderAddShopIntegral(goodsorder);
             //缁忛攢鍟� 缁撶畻閲戦

--
Gitblit v1.9.3