From e8dd7cfa6bbfd8be4a52f24e03c74f853cc6ac4f Mon Sep 17 00:00:00 2001
From: doum <doum>
Date: 星期一, 26 一月 2026 18:34:25 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 server/dmmall_service/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java |  350 +++++++++++++++++++---------------------------------------
 1 files changed, 115 insertions(+), 235 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 0fa21e1..0d71799 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
@@ -36,6 +36,7 @@
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.doumee.service.business.IntegralService;
+import com.doumee.service.business.NoticeService;
 import com.doumee.service.system.SystemDictDataService;
 import com.github.binarywang.wxpay.bean.request.BaseWxPayRequest;
 import com.github.binarywang.wxpay.bean.request.WxPayUnifiedOrderRequest;
@@ -90,6 +91,10 @@
     private MemberMapper memberMapper;
     @Autowired
     private CouponMapper couponMapper;
+    @Autowired
+    private NoticeService noticeService;
+    @Autowired
+    private NoticeMapper noticeMapper;
     @Autowired
     private MemberCouponJoinMapper memberCouponJoinMapper;
     @Autowired
@@ -388,7 +393,7 @@
             throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),ResponseStatus.DATA_EMPTY.getMessage());
         }
 
-        cancelOrder( query.getId(),  user.getId(),goodsorder.getCancelInfo() );
+        cancelOrderNew( query.getId(),  user.getId(),goodsorder.getCancelInfo() );
 
     }
 
@@ -411,17 +416,27 @@
                 .selectAs(Member::getNickname,Goodsorder::getNickName)
                 .selectAs(Member::getPhone,Goodsorder::getPhone)
                 .selectAs(Member::getName,Goodsorder::getMemberName)
-                .selectAs(SystemUser::getRealname,Goodsorder::getKdUserName)
+                .selectAs(MemberCoupon::getName,Goodsorder::getCouponName)
+                .select("t4.realname",Goodsorder::getKdUserName)
+                .select("t5.realname",Goodsorder::getCancelUserName)
+                .select("t6.realname",Goodsorder::getRefundUserName)
                 .selectAs(Shop::getName,Goodsorder::getShopName)
+                .leftJoin(MemberCoupon.class,MemberCoupon::getId,Goodsorder::getCouponId)
                 .leftJoin(Shop.class,Shop::getId,Goodsorder::getDistributionShopId)
                 .leftJoin(Member.class,Member::getId,Goodsorder::getMemberId)
                 .leftJoin(SystemUser.class,SystemUser::getId,Goodsorder::getKdUser)
+                .leftJoin(SystemUser.class,SystemUser::getId,Goodsorder::getCancelUser)
+                .leftJoin(SystemUser.class,SystemUser::getId,Goodsorder::getRefundUserId)
                 .eq(Goodsorder::getId,id);
         Goodsorder result=goodsorderJoinMapper.selectJoinOne(Goodsorder.class,q);
         if(Objects.nonNull(result)){
             MPJLambdaWrapper<GoodsorderDetail> queryWrapper = new MPJLambdaWrapper<>();
             queryWrapper.selectAll(GoodsorderDetail.class)
+                    .selectAs(Labels::getName,GoodsorderDetail::getCategoryName)
                     .eq(GoodsorderDetail::getIsdeleted,Constants.ZERO)
+                    .leftJoin(GoodsSku.class,GoodsSku::getId,GoodsorderDetail::getGoodsSkuId)
+                    .leftJoin(Goods.class,Goods::getId,GoodsSku::getGoodsId)
+                    .leftJoin(Labels.class,Labels::getId,Goods::getCategoryId)
                     .eq(GoodsorderDetail::getOrderId,result.getId()) ;
             List<GoodsorderDetail> goodsorderDetailList=goodsorderDetailMapper.selectList(queryWrapper);
             String path = systemDictDataBiz.queryByCode(Constants.OSS, Constants.RESOURCE_PATH).getCode()
@@ -430,6 +445,8 @@
                 if(StringUtils.isNotBlank(model.getImgurl())){
                    model.setImgurl(path+ model.getImgurl());
                 }
+                //灏忚
+                model.setTotalPrice(Constants.formatBigdecimal(model.getPrice()).multiply(new BigDecimal(Constants.formatIntegerNum(model.getGoodsNum()))));
             }
             result.setGoodsorderDetailList(goodsorderDetailList);
         }
@@ -456,6 +473,8 @@
         queryWrapper.selectAll(Goodsorder.class);
         queryWrapper.selectAs(Shop::getName,Goodsorder::getShopName);
         initPageQueryWrapper(queryWrapper,pageWrap);
+        queryWrapper.selectAs(MemberCoupon::getName,Goodsorder::getCouponName);
+        queryWrapper.leftJoin(MemberCoupon.class,MemberCoupon::getId,Goodsorder::getCouponId);
         queryWrapper.eq(pageWrap.getModel().getStatus()!=null,Goodsorder::getStatus,pageWrap.getModel().getStatus());
         queryWrapper.orderByDesc(Goodsorder::getCreateDate);
 
@@ -469,7 +488,7 @@
             dealOrderDetailsBiz(idList,result);//鏌ヨ璁㈠崟鏄庣粏
         }
         PageData<Goodsorder> rr =  PageData.from(result);
-        if(pageWrap.getPage() == 1){
+        if(pageWrap.getPage() == 1  && pageWrap.getModel().getNeedCount()!=null&& pageWrap.getModel().getNeedCount()){
             //濡傛灉鏌ヨ绗竴椤碉紝鍋氭暟鎹粺璁�
             rr.setCountData(dealCountOrderNum(pageWrap));
         }
@@ -646,41 +665,42 @@
 
 
     @Override
-    public List<Goodsorder> exportExcel(Goodsorder pageWrap) {
-
-        MPJLambdaWrapper<Goodsorder> queryWrapper = new MPJLambdaWrapper<>();
-
-
-        queryWrapper.selectAll(Goodsorder.class);
-        queryWrapper.selectAs(GoodsorderDetail::getName,Goodsorder::getGoodsName);
-        queryWrapper.selectAs(GoodsorderDetail::getSkuName,Goodsorder::getSkuName);
-        queryWrapper.selectAs(GoodsorderDetail::getGoodsNum,Goodsorder::getGoodsNum);
-        queryWrapper.selectAs(GoodsorderDetail::getPrice,Goodsorder::getGoodsPrice);
-        queryWrapper.selectAs(Member::getNickname,Goodsorder::getNickName);
-        queryWrapper.selectAs(Member::getPhone,Goodsorder::getPhone);
-        queryWrapper.selectAs(Addr::getAddr,Goodsorder::getAddr);
-        queryWrapper.select("(select CREATE_DATE  from order_urge where ORDER_ID=t.id and ISDELETED=0 ORDER BY CREATE_DATE desc limit 1) as urgeCreateDate ");
-        queryWrapper.leftJoin(Member.class,Member::getId,Goodsorder::getMemberId);
-        queryWrapper.leftJoin(Addr.class,Addr::getMemberId,Member::getId);
-        queryWrapper.leftJoin(GoodsorderDetail.class,GoodsorderDetail::getOrderId,Goodsorder::getId);
-        queryWrapper.eq(GoodsorderDetail::getIsdeleted,Constants.ZERO);
-        queryWrapper.eq(Addr::getIsDefault,Constants.ONE);
-
-        queryWrapper.eq(pageWrap.getCode()!=null,Goodsorder::getCode,pageWrap.getCode());
-        queryWrapper.and(StringUtils.isNotBlank(pageWrap.getNickName()),ms->ms.like(Goodsorder::getLinkname,pageWrap.getNickName())
-                .or().like(Goodsorder::getLinkphone,pageWrap.getNickName())
-        );
-        queryWrapper.ge(pageWrap.getStarttime()!=null,Goodsorder::getCreateDate,pageWrap.getStarttime());
-        queryWrapper.le(pageWrap.getEndtime()!=null,Goodsorder::getCreateDate, pageWrap.getEndtime());
-
-        queryWrapper.eq(pageWrap.getStatus()!=null,Goodsorder::getStatus,pageWrap.getStatus());
-        queryWrapper.eq(pageWrap.getIsdeleted()==null,Goodsorder::getIsdeleted,Constants.ZERO);
-        queryWrapper.eq(pageWrap.getIsdeleted()!=null,Goodsorder::getIsdeleted,pageWrap.getIsdeleted());
-        queryWrapper.orderByDesc(Goodsorder::getCreateDate);
-
-        List<Goodsorder> result = goodsorderJoinMapper.selectJoinList(Goodsorder.class, queryWrapper);
-
-
+    public List<GoodsorderExport> exportExcel(PageWrap<Goodsorder> pageWrap) {
+        pageWrap.getModel().setNeedCount(false);
+        PageData<Goodsorder> list = findPage(pageWrap);
+        List<GoodsorderExport> result = new ArrayList<>();
+        if(list!=null && list.getRecords()!=null){
+            for(Goodsorder order: list.getRecords()){
+                GoodsorderExport param = new GoodsorderExport();
+                param.setCode(order.getCode());
+                String goodsInfo = "";
+                int goodsNum= 0;
+                if(order.getGoodsorderDetailList()!=null && order.getGoodsorderDetailList().size()>0){
+                    for(GoodsorderDetail detail:order.getGoodsorderDetailList()){
+                        goodsNum += Constants.formatIntegerNum(detail.getGoodsNum());
+                        goodsInfo+= StringUtils.defaultString(detail.getName(),"")+"/"+Constants.formatBigdecimal(detail.getGoodsWeight())+"kg"
+                                +"("+Constants.formatBigdecimal(detail.getPrice())+"  x  "+Constants.formatIntegerNum(detail.getGoodsNum())+")锛沑n";
+                    }
+                }
+                param.setTotalNum(goodsNum);
+                param.setGoodsName(goodsInfo);
+                param.setTotalPrice(order.getTotalPrice());
+                param.setIntegralPrice(order.getIntegral());
+                param.setCouponPrice(order.getCouponPrice());
+                param.setMailPrice(order.getMailPrice());
+                param.setPrice(order.getPrice());
+                param.setShopName(order.getShopName());
+                param.setShopSettlement(order.getShopSettlement());
+                param.setReceiveType(order.getReceiveType());
+                param.setLinkname(order.getLinkname());
+                param.setLinkphone(order.getLinkphone());
+                param.setAddr(order.getLinkaddr());
+                param.setKdInfo(StringUtils.defaultString(order.getKdName(),"")+StringUtils.defaultString(order.getKdCode(),""));
+                param.setStatus(order.getStatus());
+                param.setCreateDate(order.getCreateDate());
+                result.add(param);
+            }
+        }
         return result;
     }
 
@@ -692,187 +712,6 @@
 
 
     /****************************************绉诲姩绔帴鍙e紑濮�********************************************************************/
-
-
-    @Transactional(rollbackFor = {Exception.class,BusinessException.class})
-    public PayResponse orderPay(OrderPayRequest orderPayRequest){
-        Member member = memberMapper.selectById(orderPayRequest.getMemberId());
-        //鏌ヨ鏀惰揣鍦板潃
-        Addr addr = addrMapper.selectById(orderPayRequest.getAddressId());
-        if(Objects.isNull(addr)){
-            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌鏀惰揣鍦板潃淇℃伅锛�");
-        }
-        Areas area = areasService.findById(addr.getAreaId(), Constants.TWO);
-        if(Objects.isNull(area)){
-            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏀惰揣鍦板潃鍖哄垝淇℃伅鍙戠敓鍙樺寲锛岃鏇存柊鍚庝笅鍗曪紒");
-        }
-        Goodsorder goodsorder = new Goodsorder();
-        goodsorder.setCreator(orderPayRequest.getMemberId());
-        goodsorder.setIntegral(BigDecimal.ZERO);
-        goodsorder.setCreateDate(new Date());
-        goodsorder.setIsdeleted(Constants.ZERO);
-        goodsorder.setMemberInfo(orderPayRequest.getRemark());
-        goodsorder.setAddrId(addr.getId());
-        goodsorder.setLinkaddr(area.getProvinceName()+area.getCityName() + area.getName() + addr.getAddr());
-        goodsorder.setLinkphone(addr.getPhone());
-        goodsorder.setLinkname(addr.getName());
-        goodsorder.setMemberId(member.getId());
-        goodsorder.setType(orderPayRequest.getOrderType());
-        //鍗曟嵁缂栧彿 鑷
-        goodsorder.setCode(getNextInCode());
-        //璁$畻璁㈠崟鎬婚噾棰�
-        BigDecimal sumPrice = BigDecimal.ZERO;
-        //瀛樺偍璁板綍鏄庣粏
-        List<PayDetailRequest> payDetailRequestList = orderPayRequest.getPayDetailRequestList();
-        if(Objects.isNull(payDetailRequestList)||payDetailRequestList.size()==Constants.ZERO){
-            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏃犳槑缁嗘暟鎹�,璇锋鏌ラ�夋嫨鏁版嵁锛�");
-        }
-        List<GoodsorderDetail> goodsOrderDetailList = new ArrayList<>();
-        for (PayDetailRequest payDetailRequest:payDetailRequestList) {
-            //鏌ヨ鍟嗗搧
-            GoodsSku goodsSku = goodsSkuMapper.selectById(payDetailRequest.getGoodsSkuId());
-            if(Objects.isNull(goodsSku)){
-                throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌鍟嗗搧SKU淇℃伅锛�");
-            }
-            Goods goods = goodsMapper.selectById(goodsSku.getGoodsId());
-            if(Objects.isNull(goods)){
-                throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌鍟嗗搧淇℃伅锛�");
-            }
-            if(goods.getStatus().equals(Constants.ONE)){
-                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀛樺湪鍟嗗搧宸插垹闄ゆ垨宸蹭笅鏋讹紝鏃犳硶涓嬪崟");
-            }
-            if(goodsSku.getStock().compareTo(new BigDecimal(Constants.formatIntegerNum(payDetailRequest.getGoodsNum())))<Constants.ZERO){
-                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"瀛樺湪鍟嗗搧搴撳瓨涓嶈冻锛屾棤娉曚笅鍗曪紒");
-            }
-            //鍟嗗搧搴撳瓨鎵i櫎
-            goodsSku.setStock(goodsSku.getStock().subtract(new BigDecimal(Constants.formatIntegerNum(payDetailRequest.getGoodsNum()))));
-            goodsSkuMapper.updateById(goodsSku);
-            GoodsorderDetail goodsOrderDetail = new GoodsorderDetail();
-            goodsOrderDetail.setCreator(member.getId());
-            goodsOrderDetail.setCreateDate(new Date());
-            goodsOrderDetail.setImgurl(StringUtils.isBlank(goodsSku.getImgurl())?goods.getImgurl():goodsSku.getImgurl());
-            goodsOrderDetail.setName(goods.getName());
-            goodsOrderDetail.setGoodsSkuId(goodsSku.getId().toString());
-            goodsOrderDetail.setSkuName(goodsSku.getName());
-            goodsOrderDetail.setPrice(goodsSku.getPrice());
-            goodsOrderDetail.setGoodsNum(payDetailRequest.getGoodsNum());
-            goodsOrderDetailList.add(goodsOrderDetail);
-            sumPrice = sumPrice.add(goodsSku.getPrice().multiply(new BigDecimal(payDetailRequest.getGoodsNum())));
-            //璐墿杞︽敮浠� 鍒犻櫎璐墿杞﹀晢鍝�
-            if(orderPayRequest.getIsShopChart().equals(Constants.ONE)){
-                shopcartMapper.deleteById(payDetailRequest.getShopCartId());
-            }
-        }
-
-        //璁㈠崟鏀粯鐜伴噾閲戦
-        goodsorder.setPrice((sumPrice.subtract(orderPayRequest.getDeductionBalance())));
-        MemberCoupon memberCoupon = new MemberCoupon();
-        if(!Objects.isNull(orderPayRequest.getCouponId())){
-            memberCoupon = memberCouponMapper.selectById(orderPayRequest.getCouponId());
-            if(Objects.isNull(memberCoupon)){
-                throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌浼樻儬鍒镐俊鎭紒");
-            }
-            if(sumPrice.compareTo(memberCoupon.getLimitPrice())<Constants.ZERO){
-                throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"璁㈠崟閲戦灏忎簬浼樻儬鍒告�婚噾棰濓紝鏃犳硶浣跨敤锛�");
-            }
-            if(memberCoupon.getStatus().equals(Constants.ONE)){
-                throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"浼樻儬鍒稿凡浣跨敤锛�");
-            }
-            sumPrice = sumPrice.subtract(memberCoupon.getPrice());
-            goodsorder.setCouponId(orderPayRequest.getCouponId());
-            goodsorder.setCouponPrice(memberCoupon.getPrice());
-        }
-
-        goodsorder.setCode(getNextInCode());
-        if(!Objects.isNull(memberCoupon)){
-            memberCoupon.setStatus(Constants.ONE);
-            memberCouponMapper.updateById(memberCoupon);
-        }
-        //鍜栬眴鍟嗗煄璁㈠崟 鍗曠嫭澶勭悊 鎵e噺绉垎 娣诲姞绉垎鍙樺姩璁板綍
-        if(orderPayRequest.getOrderType().equals(Constants.ONE)){
-            if(member.getIntegral().compareTo(sumPrice)<=Constants.ZERO){
-                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "鍜栬眴涓嶈冻,鏃犳硶鍏戞崲锛�");
-            }
-            goodsorder.setStatus(Constants.OrderStatus.PAY_DONE.getKey());
-            goodsorder.setPayStatus(Constants.ZERO);
-            goodsorder.setPayDate(new Date());
-            goodsorderMapper.insert(goodsorder);
-            //鏇存柊鐢ㄦ埛绉垎
-            memberMapper.subtractIntegral(member.getId(),sumPrice);
-            PayResponse payResponse = new PayResponse();
-            payResponse.setOrderId(goodsorder.getId());
-            return payResponse;
-        }
-        goodsorder.setIntegral(orderPayRequest.getDeductionBalance());
-        goodsorderMapper.insert(goodsorder);
-        //鏁版嵁瀛樺偍
-        BigDecimal total = Constants.formatBigdecimal(goodsorder.getPrice()).add(Constants.formatBigdecimal(goodsorder.getIntegral())).add(Constants.formatBigdecimal(goodsorder.getCouponPrice()));
-        BigDecimal rate =Constants.formatBigdecimal(goodsorder.getCouponPrice()).divide(total,4,BigDecimal.ROUND_HALF_UP);
-        BigDecimal totalWxMoney = new BigDecimal(0);
-        BigDecimal totalIntegral = new BigDecimal(0);
-        for (int i =0;i< goodsOrderDetailList.size();i++) {
-            GoodsorderDetail goodsOrderDetail= goodsOrderDetailList.get(i);
-            goodsOrderDetail.setOrderId(goodsorder.getId());
-            BigDecimal wxMoney ;
-            BigDecimal integral;
-            if(i!=0 && i == goodsOrderDetailList.size() -1){
-                //澶勭悊鍥犱负鍥涜垗浜斿叆閫犳垚鐨勫彲閫�閲戦鎹熷け
-                wxMoney = Constants.formatBigdecimal(goodsorder.getPrice()).subtract(totalWxMoney);
-                integral = Constants.formatBigdecimal(goodsorder.getIntegral()).subtract(totalIntegral);;
-            }else{
-                //褰撳墠鏄庣粏瀹為檯浠锋牸
-                BigDecimal detialTotal = Constants.formatBigdecimal(goodsOrderDetail.getPrice()).multiply(new BigDecimal(Constants.formatIntegerNum(goodsOrderDetail.getGoodsNum())));
-                //鎶樼畻浼樻儬鍒稿悗鏀粯浠锋牸锛堝寘鍚幇閲戝拰浣欓閮ㄥ垎锛�
-                BigDecimal  actDetialTotal = detialTotal.subtract(detialTotal.multiply(rate));
-                //鎸夌幇閲戝拰绉垎鏀粯姣斾緥锛屾姌绠楁瘡涓槑缁嗙幇閲戝拰绉垎鏀粯鐨勬暟閲�
-                BigDecimal rate1 = detialTotal .divide(total,4,BigDecimal.ROUND_HALF_UP);
-                //鍙��鐜伴噾閲戦
-                wxMoney = Constants.formatBigdecimal(goodsorder.getPrice()).multiply(rate1);
-                //鍓╀笅鐨勬槸浣欓鎶垫墸
-                integral =actDetialTotal.subtract(wxMoney);
-                totalWxMoney = totalWxMoney.add(wxMoney);//绱
-                totalIntegral= totalIntegral.add(integral);//绱
-            }
-            goodsOrderDetail.setMoney(wxMoney);
-            goodsOrderDetail.setIntegral(integral);
-            goodsorderDetailMapper.insert(goodsOrderDetail);
-        }
-        //濡傛灉鎶垫墸閲戦澶т簬 0 鍒欒繘琛屼綑棰濅笟鍔″鐞�
-        if(orderPayRequest.getDeductionBalance().compareTo(BigDecimal.ZERO)>Constants.ZERO){
-            //鎶垫墸閲戦灏忎簬浼氬憳鍓╀綑浣欓
-            if(orderPayRequest.getDeductionBalance().compareTo(member.getIntegral())<=Constants.ZERO){
-                //鏇存柊浣欓淇℃伅 娣诲姞绉垎鍙樺姩璁板綍
-                DealIntegralRequest dealIntegralRequest = new DealIntegralRequest();
-                dealIntegralRequest.setIntegralNum(orderPayRequest.getDeductionBalance());
-                dealIntegralRequest.setDealType(Constants.ONE);
-                dealIntegralRequest.setMemberId(member.getId());
-                dealIntegralRequest.setObjId(goodsorder.getId());
-                dealIntegralRequest.setOrderCode(goodsorder.getCode().toString());
-                dealIntegralRequest.setIntegralObjType(Constants.IntegralObjType.SHOP_ORDER);
-                integralService.dealIntegral(dealIntegralRequest);
-                //鍙戦�佸井淇″皬绋嬪簭璁㈤槄娑堟伅
-                SendWxMessage.integralChangeNotice(member,orderPayRequest.getDeductionBalance());
-                //浣欓鍏ㄩ儴鎶垫墸
-                if(goodsorder.getPrice().compareTo(BigDecimal.ZERO)==Constants.ZERO){
-                    goodsorder.setStatus(Constants.OrderStatus.PAY_DONE.getKey());
-                    goodsorder.setPayStatus(Constants.ONE);
-                    goodsorder.setPayDate(new Date());
-                    goodsorderMapper.updateById(goodsorder);
-                    PayResponse payResponse = new PayResponse();
-                    payResponse.setOrderId(goodsorder.getId());
-                    return payResponse;
-                }
-            }else{
-                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"浣欓涓嶈冻锛屾棤娉曡繘琛屾敮浠橈紝褰撳墠鍓╀綑浣欓锛氥��"+member.getIntegral()+"銆戯紒");
-            }
-        }
-        if(goodsorder.getPrice().compareTo(orderPayRequest.getTitlePrice())!=Constants.ZERO){
-            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鍟嗗搧浠锋牸鍙戠敓鍙樺寲锛岃鍒锋柊鍚庨噸鏂版敮浠橈紒");
-        }
-        return this.wxPay(goodsorder,member);
-    }
-
-
 
     @Override
     @Transactional(rollbackFor = {Exception.class,BusinessException.class})
@@ -1053,7 +892,7 @@
             dealIntegralRequest.setMemberId(member.getId());
             dealIntegralRequest.setObjId(goodsorder.getId());
             dealIntegralRequest.setOrderCode(goodsorder.getCode().toString());
-            dealIntegralRequest.setIntegralObjType(Constants.IntegralObjType.SHOP_ORDER);
+            dealIntegralRequest.setIntegralObjType(Constants.IntegralObjType.MEMBER_ORDER);
             integralService.dealIntegral(dealIntegralRequest);
         }
 
@@ -1074,6 +913,13 @@
         PayResponse payResponse = new PayResponse();
         payResponse.setOrderId(goodsorder.getId());
         payResponse.setPayType(Constants.ONE);
+        //鍙戦�侀�氱煡
+        if(Objects.nonNull(goodsorder.getPickUpShopId())){
+            //鍙戦�佺珯鍐呬俊 - 缁忛攢鍟�
+            noticeService.orderPayNotice(goodsorder.getPickUpShopId(),goodsorder.getId(),goodsorder.getReceiveType());
+        }
+
+
         return payResponse;
     }
 
@@ -1301,7 +1147,7 @@
             dealIntegralRequest.setMemberId(goodsorder.getMemberId());
             dealIntegralRequest.setObjId(goodsorder.getId());
             dealIntegralRequest.setOrderCode(goodsorder.getCode().toString());
-            dealIntegralRequest.setIntegralObjType(Constants.IntegralObjType.SHOP_ORDER_CANCEL);
+            dealIntegralRequest.setIntegralObjType(Constants.IntegralObjType.MEMBER_ORDER_CANCEL);
             integralService.dealIntegral(dealIntegralRequest);
         }
         //璁㈠崟淇℃伅鍙栨秷
@@ -1328,8 +1174,6 @@
 
         SendWxMessage.orderCancel(goodsorder,memberMapper.selectById(goodsorder.getMemberId()),goodsName);
 
-
-
         //鏌ヨ浼樻儬鍒镐俊鎭褰�
         if(!Objects.isNull(goodsorder.getCouponId())){
             MemberCoupon memberCoupon = memberCouponMapper.selectById(goodsorder.getCouponId());
@@ -1352,11 +1196,11 @@
             throw new BusinessException(ResponseStatus.DATA_EMPTY);
         }
         if(!(Constants.equalsInteger(goodsorder.getStatus(),Constants.OrderStatus.WAIT_PAY.getKey())
-        || Constants.equalsInteger(goodsorder.getStatus(),Constants.OrderStatus.PAY_DONE.getKey()) 
-        || Constants.equalsInteger(goodsorder.getStatus(),Constants.OrderStatus.WAIT_RECEIVE.getKey()) )){
+            || Constants.equalsInteger(goodsorder.getStatus(),Constants.OrderStatus.PAY_DONE.getKey()) )){
             throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"璁㈠崟鍙栨秷澶辫触锛氳鍗曠姸鎬佸凡娴佽浆锛�");
         }
-        if(goodsorder.getPrice().compareTo(BigDecimal.ZERO)>Constants.ZERO){
+        if(Constants.formatBigdecimal(goodsorder.getPrice()).compareTo(BigDecimal.ZERO)>Constants.ZERO
+                && Constants.equalsObject(goodsorder.getPayStatus(),Constants.ONE) ){
             //寰俊鐜伴噾閫�娆�
             String refundCode = WxMiniUtilService.wxRefund(goodsorder.getCode().toString(), goodsorder.getPrice(), goodsorder.getPrice());
             Fund fund = new Fund();
@@ -1373,7 +1217,9 @@
             fund.setNum(goodsorder.getPrice());
             fundMapper.insert(fund);
         }
-        if(goodsorder.getIntegral().compareTo(BigDecimal.ZERO)>Constants.ZERO){
+        //璁㈠崟宸叉敮浠樼姸鎬� 锛� 浣跨敤浜嗙Н鍒� 涓旂Н鍒嗕娇鐢ㄥぇ浜�0
+        if(goodsorder.getIntegral().compareTo(BigDecimal.ZERO)>Constants.ZERO
+                &&Constants.equalsInteger(goodsorder.getStatus(),Constants.OrderStatus.PAY_DONE.getKey())){
             //鏇存柊浣欓淇℃伅 娣诲姞绉垎鍙樺姩璁板綍
             DealIntegralRequest dealIntegralRequest = new DealIntegralRequest();
             dealIntegralRequest.setIntegralNum(goodsorder.getIntegral());
@@ -1381,7 +1227,7 @@
             dealIntegralRequest.setMemberId(goodsorder.getMemberId());
             dealIntegralRequest.setObjId(goodsorder.getId());
             dealIntegralRequest.setOrderCode(goodsorder.getCode().toString());
-            dealIntegralRequest.setIntegralObjType(Constants.IntegralObjType.SHOP_ORDER_CANCEL);
+            dealIntegralRequest.setIntegralObjType(Constants.IntegralObjType.MEMBER_ORDER_CANCEL);
             integralService.dealIntegral(dealIntegralRequest);
         }
         //璁㈠崟淇℃伅鍙栨秷
@@ -1406,7 +1252,10 @@
             }
         }
 
-        //SendWxMessage.orderCancel(goodsorder,memberMapper.selectById(goodsorder.getMemberId()),goodsName);
+        // 鐢ㄦ埛涓诲姩鍙栨秷 鍙戦�佺粡閿�鍟嗙珯鍐呮秷鎭�
+        if(Objects.nonNull(goodsorder.getPickUpShopId())&&StringUtils.isBlank(cancelInfo)){
+            noticeService.orderCancelNotice(goodsorder.getPickUpShopId(),goodsorder.getId(),goodsorder.getCode().toString());
+        }
 
         //鏌ヨ浼樻儬鍒镐俊鎭褰�
         if(!Objects.isNull(goodsorder.getCouponId())){
@@ -1417,10 +1266,6 @@
             }
         }
     }
-
-
-
-
 
     public BigDecimal getDeductAmount(List<PayDetailRequest> requestList){
         List<MemberCoupon> memberCouponList = new ArrayList<>();
@@ -1795,6 +1640,7 @@
         String couponNames = "";
         if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(shareCouponRewardList)){
             List<MemberCoupon> memberCouponList = new ArrayList<>();
+            List<CouponNoticeRequest> requestList = new ArrayList<>();
             for (JSONObject jsonObject:shareCouponRewardList) {
                 Integer couponId = jsonObject.getInteger("couponId");
                 Integer num = jsonObject.getInteger("num");
@@ -1808,9 +1654,19 @@
                 }
                 couponIds = couponIds + (StringUtils.isBlank(couponIds)? ",":"" )+ couponId ;
                 couponNames = couponNames + (StringUtils.isBlank(couponNames)? ",":"" )+ coupon.getName() ;
+
+
+                CouponNoticeRequest couponNoticeRequest = new CouponNoticeRequest();
+                couponNoticeRequest.setMemberCoupon(memberCoupon);
+                couponNoticeRequest.setNum(num);
+                requestList.add(couponNoticeRequest);
             }
             if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(memberCouponList)){
                 memberCouponJoinMapper.insert(memberCouponList);
+            }
+            if(CollectionUtils.isNotEmpty(requestList)){
+                //鍙戦�佺珯鍐呬俊
+                noticeService.couponNotice(inviteMember.getId(),requestList);
             }
         }
         inviteRecordMapper.update(new UpdateWrapper<InviteRecord>().lambda()
@@ -1885,7 +1741,11 @@
             dealIntegralRequest.setMemberId(goodsorder.getDistributionShopId());
             dealIntegralRequest.setObjId(goodsorder.getId());
             dealIntegralRequest.setOrderCode(goodsorder.getCode().toString());
-            dealIntegralRequest.setIntegralObjType(Constants.IntegralObjType.ORDER_DONATE);
+            dealIntegralRequest.setIntegralObjType(Constants.IntegralObjType.SHOP_ORDER);
+            Member member = memberMapper.selectById(goodsorder.getMemberId());
+            if(Objects.nonNull(member)){
+                dealIntegralRequest.setParam1(member.getNickname());
+            }
             integralService.dealShopIntegral(dealIntegralRequest);
         }
     }
@@ -1906,6 +1766,7 @@
             dealIntegralRequest.setObjId(goodsorder.getId());
             dealIntegralRequest.setOrderCode(goodsorder.getCode().toString());
             dealIntegralRequest.setIntegralObjType(Constants.IntegralObjType.ORDER_DONE_AMOUNT);
+            dealIntegralRequest.setParam1(goodsorder.getCode().toString());
             integralService.dealShopAmount(dealIntegralRequest);
         }
     }
@@ -1973,6 +1834,18 @@
         goodsorder.setIsComment(Constants.ONE);
         goodsorderMapper.updateById(goodsorder);
     }
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public  void orderRefund(Goodsorder param){
+        Goodsorder goodsorder = goodsorderMapper.selectById(param.getId());
+        if(!goodsorder.getMemberId().equals(goodsorder.getMemberId())){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鎿嶄綔澶辫触锛氱敤鎴蜂俊鎭尮閰嶅け璐ワ紒");
+        }
+        if(!goodsorder.getStatus().equals(Constants.OrderStatus.DONE.getKey())){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鎿嶄綔澶辫触锛氳鍗曟湭瀹屾垚锛屾棤娉曢��娆撅紒");
+        }
+
+    }
 
 
     @Override
@@ -1997,7 +1870,7 @@
         ));
         myPageResponse.setAfterOrders(aftersaleMapper.selectCount(new QueryWrapper<Aftersale>()
                 .apply(" ID in ( select g.id from goodsorder g where g.MEMBER_ID = '"+memberId+"'  ) ")
-                .notIn("STATUS",Constants.AftersaleStatus.DONE,Constants.AftersaleStatus.SHOP_REFUSE,Constants.AftersaleStatus.CANCEL)
+                .notIn("STATUS",Constants.AftersaleStatus.DONE.getKey(),Constants.AftersaleStatus.SHOP_REFUSE.getKey(),Constants.AftersaleStatus.CANCEL.getKey())
         ));
 
 
@@ -2207,6 +2080,13 @@
                         .eq(Collect::getMemberId,member.getId())
                 )
         );
+        homeInfoResponse.setUnRead(
+                noticeMapper.selectCount(new QueryWrapper<Notice>().lambda()
+                        .eq(Notice::getIsdeleted,Constants.ZERO)
+                        .eq(Notice::getMemberId,member.getId())
+                        .eq(Notice::getStatus,Constants.ZERO)
+                )>=Constants.ZERO?Constants.ZERO:Constants.ONE
+        );
 
         return homeInfoResponse;
     }

--
Gitblit v1.9.3