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 |  265 ++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 253 insertions(+), 12 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 4611954..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;
@@ -37,9 +39,12 @@
 import com.github.binarywang.wxpay.bean.request.BaseWxPayRequest;
 import com.github.binarywang.wxpay.bean.request.WxPayUnifiedOrderRequest;
 import com.github.binarywang.wxpay.bean.result.WxPayRefundResult;
+import com.github.binarywang.wxpay.bean.result.WxPayRefundV3Result;
 import com.github.binarywang.wxpay.exception.WxPayException;
 import com.github.xiaoymin.knife4j.core.util.CollectionUtils;
 import com.github.yulichang.wrapper.MPJLambdaWrapper;
+import io.swagger.models.auth.In;
+import okhttp3.Address;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.shiro.SecurityUtils;
 import org.checkerframework.checker.units.qual.C;
@@ -80,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;
@@ -95,6 +106,9 @@
 
     @Autowired
     private ShopMapper shopMapper;
+
+    @Autowired
+    private LabelsMapper labelsMapper;
 
     @Autowired
     private ShopGoodsRelationMapper relationMapper;
@@ -137,6 +151,9 @@
 
     @Autowired
     private AreasService areasService;
+
+    @Autowired
+    private AreasMapper areasMapper;
 
     @Autowired
     private GoodsorderDetailJoinMapper goodsorderDetailJoinMapper;
@@ -194,7 +211,7 @@
         goodsorderMapper.updateById(goodsorder);
     }
 
-    @Override
+    /*@Override
     public IPage<Shop> getShopPage(PageWrap<Shop> pageWrap) {
         IPage<Shop> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
         Shop model = pageWrap.getModel();
@@ -213,7 +230,7 @@
                         .like(StringUtils.isNotBlank(model.getName()),Shop::getName,model.getName())
                 .orderByAsc(" distance ")
         );
-    }
+    }*/
 
 
     /**
@@ -429,7 +446,6 @@
         queryWrapper.eq(pageWrap.getModel().getPayOrderId()!=null,Goodsorder::getPayOrderId,pageWrap.getModel().getPayOrderId());
         queryWrapper.eq(pageWrap.getModel().getStatus()!=null,Goodsorder::getStatus,pageWrap.getModel().getStatus());
         queryWrapper.eq(pageWrap.getModel().getIsdeleted()==null,Goodsorder::getIsdeleted,Constants.ZERO);
-        queryWrapper.eq(pageWrap.getModel().getIsdeleted()!=null,Goodsorder::getIsdeleted,pageWrap.getModel().getIsdeleted());
         queryWrapper.orderByDesc(Goodsorder::getCreateDate);
 
         IPage<Goodsorder> result = goodsorderJoinMapper.selectJoinPage(page, Goodsorder.class, queryWrapper);
@@ -485,6 +501,82 @@
            model.setGoodsorderDetailList(goodsorderDetailList);
         }
         return PageData.from(result);
+    }
+    @Override
+    public PageData<Goodsorder> findPageShop(PageWrap<Goodsorder> pageWrap) {
+        IPage<Goodsorder> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
+        MPJLambdaWrapper<Goodsorder> queryWrapper = new MPJLambdaWrapper<>();
+        Utils.MP.blankToNull(pageWrap.getModel());
+
+        queryWrapper.selectAll(Goodsorder.class)
+         .eq(pageWrap.getModel().getDistributionShopId()!=null,Goodsorder::getDistributionShopId,pageWrap.getModel().getDistributionShopId())
+         .eq(pageWrap.getModel().getStatus()!=null,Goodsorder::getStatus,pageWrap.getModel().getStatus())
+         .eq(pageWrap.getModel().getCode()!=null,Goodsorder::getCode,pageWrap.getModel().getCode())
+         .ge(pageWrap.getModel().getStarttime()!=null,Goodsorder::getCreateDate,pageWrap.getModel().getStarttime())
+         .le(pageWrap.getModel().getEndtime()!=null,Goodsorder::getCreateDate, pageWrap.getModel().getEndtime())
+         .eq(Goodsorder::getIsdeleted,Constants.ZERO)
+         .exists(StringUtils.isNotBlank(pageWrap.getModel().getGoodsName()),
+                "select d.id from goodsorder_detail d where d.isdeleted=0 and d.order_id=t.id and (d.goods_sku_id ='"+pageWrap.getModel().getGoodsName()+"' or d.name like '%"+pageWrap.getModel().getGoodsName()+"%')")
+         .orderByDesc(Goodsorder::getCreateDate);
+        IPage<Goodsorder> result = goodsorderJoinMapper.selectJoinPage(page, Goodsorder.class, queryWrapper);
+        PageData<Goodsorder> rr = PageData.from(result);
+        if(result!=null && result.getRecords().size()>0) {
+            List<Integer> idList = new ArrayList<>();
+            for(Goodsorder model:result.getRecords()){
+                idList.add(model.getId());
+            }
+            MPJLambdaWrapper<GoodsorderDetail> queryGoods = new MPJLambdaWrapper<>();
+            queryGoods.selectAll(GoodsorderDetail.class);
+            queryGoods.in(GoodsorderDetail::getOrderId,idList);
+            queryGoods.eq(GoodsorderDetail::getIsdeleted,Constants.ZERO);
+            queryGoods.and( StringUtils.isNotBlank(pageWrap.getModel().getGoodsName()),w ->{
+                w.like(GoodsorderDetail::getName,pageWrap.getModel().getGoodsName() ).or().eq(GoodsorderDetail::getGoodsSkuId,pageWrap.getModel().getGoodsName());
+            } );
+            List<GoodsorderDetail> goodsorderDetailList=goodsorderDetailJoinMapper.selectList(queryGoods);
+            for(Goodsorder model:result.getRecords()){
+                model.setGoodsorderDetailList(getDetailListById(goodsorderDetailList,model.getId()));
+            }
+            if(pageWrap.getPage() == 1 && pageWrap.getModel().getDistributionShopId()!=null){
+                //濡傛灉鏌ヨ绗竴椤碉紝鍋氱粡閿�鍟嗛攢鍞俊鎭粺璁′笟鍔℃煡璇�
+                Goodsorder count = new Goodsorder();
+                count.setOrderCount(rr.getTotal());
+                List<GoodsorderDetail> list =  goodsorderDetailJoinMapper.selectJoinList(GoodsorderDetail.class,new MPJLambdaWrapper<GoodsorderDetail>()
+                        .selectAll(GoodsorderDetail.class)
+                        .leftJoin(Goodsorder.class,Goodsorder::getId,GoodsorderDetail::getOrderId)
+                        .eq(pageWrap.getModel().getDistributionShopId()!=null,Goodsorder::getDistributionShopId,pageWrap.getModel().getDistributionShopId())
+                        .eq(pageWrap.getModel().getStatus()!=null,Goodsorder::getStatus,pageWrap.getModel().getStatus())
+                        .and( StringUtils.isNotBlank(pageWrap.getModel().getGoodsName()),w ->{
+                            w.like(GoodsorderDetail::getName,pageWrap.getModel().getGoodsName() ).or().eq(GoodsorderDetail::getGoodsSkuId,pageWrap.getModel().getGoodsName());
+                        } )
+                        .eq(pageWrap.getModel().getCode()!=null,Goodsorder::getCode,pageWrap.getModel().getCode())
+                        .ge(pageWrap.getModel().getStarttime()!=null,Goodsorder::getCreateDate,pageWrap.getModel().getStarttime())
+                        .le(pageWrap.getModel().getEndtime()!=null,Goodsorder::getCreateDate, pageWrap.getModel().getEndtime())
+                        .eq(Goodsorder::getIsdeleted,Constants.ZERO));
+                if(list!=null && list.size()>0){
+                    //鍟嗗搧鎬婚噺
+                    for (GoodsorderDetail d : list){
+                        count.setGoodsNum(Constants.formatIntegerNum(count.getGoodsNum()) + Constants.formatIntegerNum(d.getGoodsNum()));
+                        count.setOrderMoneyCount(Constants.formatBigdecimal(count.getOrderMoneyCount())
+                                .add(Constants.formatBigdecimal(d.getPrice()).multiply(new BigDecimal(Constants.formatIntegerNum(d.getGoodsNum())))));
+                    }
+                }
+                rr.setCountData(count);
+            }
+        }
+
+
+
+        return rr;
+    }
+
+    private List<GoodsorderDetail> getDetailListById(List<GoodsorderDetail> goodsorderDetailList, Integer id) {
+        List<GoodsorderDetail> list = new ArrayList<>();
+        for(GoodsorderDetail d : goodsorderDetailList){
+            if(Constants.equalsInteger(id,d.getOrderId())){
+                list.add(d);
+            }
+        }
+        return list;
     }
 
 
@@ -770,6 +862,7 @@
             goodsorder.setDistributionShopId(shop.getId());
             if(Objects.isNull(member.getBindShopId())){
                 member.setBindShopId(shop.getId());
+                member.setBindShopDate(new Date());
             }
         }
 
@@ -793,8 +886,7 @@
         goodsorder.setPrice(orderPayConfirmResponse.getPayAmount());
         goodsorder.setTotalPrice(orderPayConfirmResponse.getAmount());
         goodsorder.setUseIntegral(orderPayConfirmResponse.getDeductIntegral());
-        goodsorder.setIntegral(goodsorder.getUseIntegral());
-        goodsorder.setIntegralPrice(orderPayConfirmResponse.getIntegralAmount());
+        goodsorder.setIntegral(orderPayConfirmResponse.getIntegralAmount());
         goodsorder.setMailPrice(orderPayConfirmResponse.getMailAmount());
         goodsorder.setPayMethod(goodsorder.getPrice().compareTo(BigDecimal.ZERO)>Constants.ZERO?Constants.ZERO:Constants.ONE);
         if(Objects.nonNull(orderPayConfirmResponse.getMemberCoupon())){
@@ -807,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)){
@@ -1055,6 +1149,13 @@
         memberOrderResponse.setMemberOrderDetailResponseList(memberOrderDetailResponseList);
         if(Constants.equalsInteger(memberOrderResponse.getReceiveType(),Constants.ONE)){
             memberOrderResponse.setShopInfo(shopMapper.selectById(memberOrderResponse.getShopId()));
+        }
+        Member member = memberMapper.selectById(memberOrderResponse.getMemberId());
+        if(Objects.nonNull(member)){
+            String memberfullUrl = systemDictDataBiz.queryByCode(Constants.OSS,Constants.RESOURCE_PATH).getCode()+
+                    systemDictDataBiz.queryByCode(Constants.OSS,Constants.MEMBER_FILE).getCode();
+            member.setImgFullUrl(memberfullUrl + member.getImgurl());
+            memberOrderResponse.setMember(member);
         }
         return memberOrderResponse;
     }
@@ -1375,14 +1476,44 @@
         //閭垂閲戦
         if(Objects.nonNull(request.getReceiveType())){
             if(Constants.equalsInteger(request.getReceiveType(),Constants.ZERO)){
-                //TODO  鏍规嵁鏀惰揣鍦板潃 鏌ヨ杩愯垂閰嶇疆
+                MailConfigResponse mailConfigResponse = systemDictDataBiz.getMailConfig();
+                if(Objects.nonNull(request.getAddressId())){
+                    Addr addr = addrMapper.selectById(request.getAddressId());
+                    if(Objects.isNull(addr)){
+                        throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌鏀惰揣鍦板潃淇℃伅");
+                    }
+                    Areas areas = areasMapper.selectOne(new QueryWrapper<Areas>().lambda()
+                            .eq(Areas::getIsdeleted,Constants.ZERO)
+                            .eq(Areas::getId,StringUtils.leftPad(addr.getAreaId().toString().substring(0,2),6,"0"))
+                            .isNotNull(Areas::getYunFeeId)
+                            .last(" limit 1 ")
+                    );
+                    if(Objects.nonNull(areas)){
+                        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);
+                        }
+                    }
+                }
+                //鏍规嵁鏀惰揣鍦板潃 鏌ヨ杩愯垂閰嶇疆
                 //璁$畻鍟嗗搧淇℃伅鎬婚噸閲�
                 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);
             }
         }
@@ -1557,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);
+            }
+        }
+    }
+
+
+
 
     /**
      * 璁㈠崟鏍搁攢
@@ -1596,6 +1782,8 @@
         if(Constants.equalsInteger(goodsorder.getPayMethod(),Constants.ZERO)){
             //璧犻�佹秷璐硅�呯Н鍒�
             this.orderAddMemberIntegral(goodsorder);
+            //涓嬪崟瀹屾垚 鏍规嵁淇℃伅纭鏄惁闇�瑕佽禒閫侀個璇疯�呬紭鎯犲埜
+            this.orderDoneRewardInviteCoupon(goodsorder);
             //缁忛攢鍟� 娣诲姞璧犻�佺Н鍒�
             this.orderAddShopIntegral(goodsorder);
             //缁忛攢鍟� 缁撶畻閲戦
@@ -1786,10 +1974,12 @@
         RedisUtil.addObject(redisTemplate,Constants.RedisKeys.GOODSORDER_KEY,0);
         //鍔犲叆redis缂撳瓨锛屽埛鏂颁粖澶╁敭鍚庣紪鍙�0寮�濮�
         RedisUtil.addObject(redisTemplate,Constants.RedisKeys.AFTERSALE_KEY,0);
+        //鍔犲叆redis缂撳瓨锛屽埛鏂颁粖澶╁敭鍚庣紪鍙�0寮�濮�
+        RedisUtil.addObject(redisTemplate,Constants.RedisKeys.WITHDRAW_KEY,0);
     }
     @Override
     public  void refreshOrderCodes(){
-        long countOrder = 0,countSign=0,countSale=0;
+        long countOrder = 0,countSign=0,countSale=0,countWithdraw=0;
 
         QueryWrapper<Goodsorder> order = new QueryWrapper<>();
         order.apply(true, "TO_DAYS(NOW())=TO_DAYS(create_date)");
@@ -1818,6 +2008,22 @@
         }
         //鍔犲叆redis缂撳瓨锛屽埛鏂颁粖澶╁敭鍚庣紪鍙�0寮�濮�
         RedisUtil.addObject(redisTemplate,Constants.RedisKeys.AFTERSALE_KEY,countSale);
+
+
+
+        QueryWrapper<WithdrawRecord> withdraw = new QueryWrapper<>();
+        withdraw.apply(true, "TO_DAYS(NOW())=TO_DAYS(create_date)");
+        withdraw.orderByDesc(" CODE ");
+        withdraw.last(" limit 1 ");
+        Aftersale maxWithdrawOrder =  aftersaleMapper.selectOne(sale);
+        if(!Objects.isNull(maxWithdrawOrder)){
+            countWithdraw = Integer.valueOf(maxOrder.getCode().toString().substring(8,12));
+        }
+        //鍔犲叆redis缂撳瓨锛屽埛鏂颁粖澶╁敭鍚庣紪鍙�0寮�濮�
+        RedisUtil.addObject(redisTemplate,Constants.RedisKeys.WITHDRAW_KEY,countWithdraw);
+
+
+
     }
 
 
@@ -1899,11 +2105,13 @@
                         .eq(Goodsorder::getMemberId,member.getId())
                         .eq(Goodsorder::getStatus,Constants.OrderStatus.WAIT_RECEIVE.getKey()))
         );
+
         homeInfoResponse.setWaitPayNum(
                 goodsorderMapper.selectCount(new QueryWrapper<Goodsorder>().lambda().eq(Goodsorder::getIsdeleted,Constants.ZERO)
                         .eq(Goodsorder::getMemberId,member.getId())
                         .eq(Goodsorder::getStatus,Constants.OrderStatus.WAIT_PAY.getKey()))
         );
+
         homeInfoResponse.setCartTypeNum(
                 shopcartMapper.selectCount(new QueryWrapper<Shopcart>().lambda()
                         .eq(Shopcart::getIsdeleted,Constants.ZERO)
@@ -1925,11 +2133,44 @@
         );
 
         return homeInfoResponse;
-
-
     }
 
 
+    @Override
+    public PageData<Goodsorder> shopOrderPage(PageWrap<ShopOrderRequest> pageWrap) {
+        Integer shopId = null;
+        Integer status = null;
+        IPage<Goodsorder> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
+        MPJLambdaWrapper<Goodsorder> queryWrapper = new MPJLambdaWrapper<>();
+        Utils.MP.blankToNull(pageWrap.getModel());
+        ShopOrderRequest model = pageWrap.getModel();
+        queryWrapper.selectAll(Goodsorder.class);
+//        queryWrapper.selectAs(Member::getNickname,Goodsorder::getNickName);
+//        queryWrapper.selectAs(Member::getPhone,Goodsorder::getPhone);
+//        queryWrapper.selectAs(Member::getImgurl,Goodsorder::getImgurl);
+        queryWrapper.eq(Goodsorder::getIsdeleted,Constants.ZERO);
+        queryWrapper.eq(Objects.nonNull(model.getStatus()),Goodsorder::getStatus,model.getStatus());
+        queryWrapper.eq(Objects.nonNull(model.getShopId()),Goodsorder::getDistributionShopId,model.getShopId());
+        queryWrapper.orderByDesc(Goodsorder::getCreateDate);
+
+        IPage<Goodsorder> result = goodsorderJoinMapper.selectJoinPage(page, Goodsorder.class, queryWrapper);
+
+        String path = systemDictDataBiz.queryByCode(Constants.OSS, Constants.RESOURCE_PATH).getCode() +
+                systemDictDataBiz.queryByCode(Constants.OSS, Constants.GOODS_FILE).getCode();
+
+        for(Goodsorder goodsorder:result.getRecords()){
+
+            List<GoodsorderDetail> goodsorderDetailList=goodsorderDetailJoinMapper.selectList(new QueryWrapper<GoodsorderDetail>().lambda()
+                    .eq(GoodsorderDetail::getOrderId,goodsorder.getId()));
+            goodsorderDetailList.stream().forEach(s ->{
+                if(StringUtils.isBlank(s.getImgurl())){
+                    s.setImgurl(path + s.getGoodsImgurl());
+                }
+            });
+            goodsorder.setGoodsorderDetailList(goodsorderDetailList);
+        }
+        return PageData.from(result);
+    }
 
 
 

--
Gitblit v1.9.3