岐济生
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Pu Zhibing
2025-03-18 eb428cb6839049970e67264f4eafc612e5bcaa38 
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java


@@ -1,5 +1,8 @@


package com.ruoyi.order.service.impl;




import cn.hutool.http.HttpRequest;


import cn.hutool.http.HttpUtil;


import cn.hutool.json.JSONUtil;


import com.alibaba.fastjson2.JSON;


import com.alibaba.fastjson2.JSONObject;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


@@ -9,11 +12,13 @@


import com.ruoyi.common.core.constant.ExpressCompanyMap;


import com.ruoyi.common.core.domain.R;


import com.ruoyi.common.core.exception.ServiceException;


import com.ruoyi.common.core.utils.HttpUtils;


import com.ruoyi.common.core.utils.StringUtils;


import com.ruoyi.common.core.utils.uuid.QRCodeGenerator;


import com.ruoyi.common.core.web.page.PageInfo;


import com.ruoyi.common.security.service.TokenService;


import com.ruoyi.order.enums.OrderStatus;


import com.ruoyi.order.event.ConfirmDeliveryEvent;


import com.ruoyi.order.mapper.OrderGoodMapper;


import com.ruoyi.order.mapper.OrderMapper;


import com.ruoyi.order.model.Order;


@@ -44,6 +49,7 @@


import org.apache.poi.xssf.streaming.SXSSFWorkbook;


import org.apache.poi.xssf.usermodel.XSSFWorkbook;


import org.jetbrains.annotations.Nullable;


import org.springframework.context.ApplicationEventPublisher;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


@@ -58,6 +64,7 @@


import java.net.MalformedURLException;


import java.net.URL;


import java.time.LocalDateTime;


import java.time.OffsetDateTime;


import java.time.ZoneOffset;


import java.time.format.DateTimeFormatter;


import java.util.*;


@@ -137,6 +144,8 @@


    private AppUserGiveawayTemporaryClient appUserGiveawayTemporaryClient;


    @Resource


    private ShopGiveawayTemporaryClient shopGiveawayTemporaryClient;


    @Resource


    private ApplicationEventPublisher applicationEventPublisher;






    @Override


@@ -183,9 +192,9 @@


        }


        // 优惠券


        String couponJson = order.getCouponJson();


        CouponInfo couponInfo = new CouponInfo();


        JSONObject jsonObject = new JSONObject();


        if (StringUtils.isNotEmpty(couponJson)) {


            couponInfo = JSONObject.parseObject(couponJson, CouponInfo.class);


            jsonObject = JSONObject.parseObject(couponJson);


        }




        // 参与活动


@@ -208,7 +217,7 @@


        orderDetailVO.setOrderNumber(order.getOrderNumber());


        orderDetailVO.setCreateTime(order.getCreateTime());


        orderDetailVO.setTotalAmount(order.getTotalAmount());


        orderDetailVO.setCouponName(couponInfo.getCouponName());


        orderDetailVO.setCouponName(jsonObject.getString("couponName"));


        orderDetailVO.setActivityName(orderActivityInfo.getActivityName());


        orderDetailVO.setCouponAmount(order.getDiscountTotalAmount());


        orderDetailVO.setExpressAmount(order.getExpressAmount());


@@ -246,6 +255,7 @@


        }


        return orderDetailVO;


    }






    @Override


    public boolean check(Order order, Integer shopId, Long userId) {


@@ -499,7 +509,8 @@


    public R refundPayMoney(Order order) {


        //开始退款


        Integer payMethod = order.getPayMethod();


        BigDecimal paymentAmount = order.getPaymentAmount();


        BigDecimal expressAmount = order.getExpressAmount() == null ? BigDecimal.ZERO : order.getExpressAmount();


        BigDecimal paymentAmount = order.getPaymentAmount().add(expressAmount);


        AppUser appUser = appUserClient.getAppUserById(order.getAppUserId());


        if (1 == payMethod) {


            //微信退款


@@ -594,7 +605,6 @@


        if (3 == payMethod) {


            //开始运费退款，积分支付，运费是单独进行支付的，所以需要单独退款


            if (null != order.getExpressAmount() && BigDecimal.ZERO.compareTo(order.getExpressAmount()) < 0) {


                BigDecimal expressAmount = order.getExpressAmount();


                if (1 == order.getExpressPayMethod()) {


                    //微信退款


                    RefundResult refund = PaymentUtil.refund(order.getOrderNumber(), "R" + order.getOrderNumber(), expressAmount.doubleValue(), "/order/order/refundExpressPayMoneyCallback");


@@ -663,6 +673,7 @@


        order.setRefundTime(LocalDateTime.now());




        shopPointClient.deleteShopPointCopy(order.getId(), Arrays.asList(1,2,3));


        shopBalanceStatementClient.deleteShopBalanceStatementCopy(order.getId(), Arrays.asList(1,2,3));


        appUserGiveawayTemporaryClient.delAppUserGiveawayTemporary(order.getId());


        shopGiveawayTemporaryClient.delShopGiveawayTemporary(order.getId());


        return R.ok();


@@ -811,6 +822,7 @@


        Long days = jsonObject.getLong("days");


        order.setAfterSaleTime(LocalDateTime.now().plusDays(days));


        this.updateById(order);


        commissionService.calculationCommissionShop(order.getId());


        return R.ok();


    }




@@ -985,18 +997,33 @@


            for (int i = 1; i <= lastRowNum; i++) {


                Row row = sheet.getRow(i);


                // 订单编号


                if (row.getCell(0) == null){


                    throw new ServiceException("第" + i + "行订单编号为空", 500);


                }


                row.getCell(0).setCellType(CellType.STRING);


                String orderNum = row.getCell(0).getStringCellValue();


                // 快递单号


                if (row.getCell(1) == null){


                    throw new ServiceException("第" + i + "行快递单号为空", 500);


                }


                row.getCell(1).setCellType(CellType.STRING);


                String expressNum = row.getCell(1).getStringCellValue();


                // 快递公司名称


                if (row.getCell(2) == null){


                    throw new ServiceException("第" + i + "行快递公司为空", 500);


                }


                row.getCell(2).setCellType(CellType.STRING);


                String expressName = row.getCell(2).getStringCellValue();


                // 省区划代码


                if (row.getCell(3) == null){


                    throw new ServiceException("第" + i + "行省区划代码为空", 500);


                }


                row.getCell(3).setCellType(CellType.STRING);


                String provinceCode = row.getCell(3).getStringCellValue();


                // 市区划代码


                if (row.getCell(4) == null){


                    throw new ServiceException("第" + i + "行市区划代码为空", 500);


                }


                row.getCell(4).setCellType(CellType.STRING);


                String cityCode = row.getCell(4).getStringCellValue();


                Order order = this.getOne(new LambdaQueryWrapper<Order>()


@@ -1096,10 +1123,14 @@


                userAddress.getProvince() + userAddress.getCity());


        order.setExpressResult(JSON.toJSONString(mapTrackKD100Vo));


        this.updateById(order);




        // 发布事件


        applicationEventPublisher.publishEvent(new ConfirmDeliveryEvent(order.getId()));


        return R.ok();


    }








    public static void importExpress2(String filePath) throws MalformedURLException {


        // 从网络地址读取


        URL url = new URL(filePath);