加入日志

yn-bftl-byx / thirdparty

Browse code 加入日志 master
1 parent d2f841b commit 768a94c64562e425f7e0055a681754211d7ccb38 steven authored on 18 Dec

Patch

Showing 3 changed files

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/common/util/IPUtils.java
package com.yn.bftl.thirdparty.common.util; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.ServletRequestAttributes; import javax.servlet.http.HttpServletRequest; import java.net.InetAddress; import java.net.UnknownHostException; /** * IP工具类 * / @Slf4j public class IPUtils { public static void checkWhileIp(String whiteIp) { if (StringUtils.isEmpty(whiteIp)) { throw new YnceErrorException("参数不能为空"); } ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes(); String ip = IPUtils.getClientIpAddress(requestAttributes.getRequest()); log.info("==========================u8 IP地址：" + ip); if (StringUtils.isEmpty(ip)) { throw new YnceErrorException("非法IP"); } if (!whiteIp.equals(ip)) { throw new YnceErrorException("非法访问"); } } /* * 获取IP地址 / public static String getClientIpAddress(HttpServletRequest request) { String ip = null; try { ip = request.getHeader("x-forwarded-for"); if (StringUtils.isEmpty(ip) \|\| "unknown".equalsIgnoreCase(ip)) { ip = request.getHeader("Proxy-Client-IP"); } if (StringUtils.isEmpty(ip) \|\| ip.length() == 0 \|\| "unknown".equalsIgnoreCase(ip)) { ip = request.getHeader("WL-Proxy-Client-IP"); } if (StringUtils.isEmpty(ip) \|\| "unknown".equalsIgnoreCase(ip)) { ip = request.getHeader("HTTP_CLIENT_IP"); } if (StringUtils.isEmpty(ip) \|\| "unknown".equalsIgnoreCase(ip)) { ip = request.getHeader("HTTP_X_FORWARDED_FOR"); } if (StringUtils.isEmpty(ip) \|\| "unknown".equalsIgnoreCase(ip)) { ip = request.getRemoteAddr(); } } catch (Exception e) { log.error("IPUtils ERROR ", e); } return ip; } public static String getServerIpAddress() { try { InetAddress localhost = InetAddress.getLocalHost(); return localhost.getHostAddress(); } catch (UnknownHostException e) { log.error(e.getMessage()); return null; } } public static void main(String[] args) { try { InetAddress localhost = InetAddress.getLocalHost(); String ip = localhost.getHostAddress(); System.out.println("服务端IP地址：" + ip); } catch (UnknownHostException e) { e.printStackTrace(); } } } package com.yn.bftl.thirdparty.common.util; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.ServletRequestAttributes; import javax.servlet.http.HttpServletRequest; import java.net.InetAddress; import java.net.UnknownHostException; /* * IP工具类 * / @Slf4j public class IPUtils { public static void checkWhileIp(String whiteIp) { if (StringUtils.isEmpty(whiteIp)) { throw new YnceErrorException("参数不能为空"); } ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes(); String ip = IPUtils.getClientIpAddress(requestAttributes.getRequest()); if (StringUtils.isEmpty(ip)) { throw new YnceErrorException("非法IP"); } if (!whiteIp.equals(ip)) { throw new YnceErrorException("非法访问"); } } /* * 获取IP地址 */ public static String getClientIpAddress(HttpServletRequest request) { String ip = null; try { ip = request.getHeader("x-forwarded-for"); if (StringUtils.isEmpty(ip) \|\| "unknown".equalsIgnoreCase(ip)) { ip = request.getHeader("Proxy-Client-IP"); } if (StringUtils.isEmpty(ip) \|\| ip.length() == 0 \|\| "unknown".equalsIgnoreCase(ip)) { ip = request.getHeader("WL-Proxy-Client-IP"); } if (StringUtils.isEmpty(ip) \|\| "unknown".equalsIgnoreCase(ip)) { ip = request.getHeader("HTTP_CLIENT_IP"); } if (StringUtils.isEmpty(ip) \|\| "unknown".equalsIgnoreCase(ip)) { ip = request.getHeader("HTTP_X_FORWARDED_FOR"); } if (StringUtils.isEmpty(ip) \|\| "unknown".equalsIgnoreCase(ip)) { ip = request.getRemoteAddr(); } } catch (Exception e) { log.error("IPUtils ERROR ", e); } return ip; } public static String getServerIpAddress() { try { InetAddress localhost = InetAddress.getLocalHost(); return localhost.getHostAddress(); } catch (UnknownHostException e) { log.error(e.getMessage()); return null; } } public static void main(String[] args) { try { InetAddress localhost = InetAddress.getLocalHost(); String ip = localhost.getHostAddress(); System.out.println("服务端IP地址：" + ip); } catch (UnknownHostException e) { e.printStackTrace(); } } }

Ignore Space Show notes View

src/main/java/com/yn/bftl/thirdparty/common/util/IPUtils.java

package com.yn.bftl.thirdparty.common.util;

import com.yn.bftl.thirdparty.common.exception.YnceErrorException;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;

import javax.servlet.http.HttpServletRequest;
import java.net.InetAddress;
import java.net.UnknownHostException;

/**
 * IP工具类
 *
 */
@Slf4j
public class IPUtils {

public static void checkWhileIp(String whiteIp) {
        if (StringUtils.isEmpty(whiteIp)) {
            throw new YnceErrorException("参数不能为空");
        }
        ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
        String ip = IPUtils.getClientIpAddress(requestAttributes.getRequest());
        log.info("==========================u8 IP地址：" + ip);
        if (StringUtils.isEmpty(ip)) {
            throw new YnceErrorException("非法IP");
        }
        if (!whiteIp.equals(ip)) {
            throw new YnceErrorException("非法访问");
        }
    }

/**
	 * 获取IP地址
	 */
	public static String getClientIpAddress(HttpServletRequest request) {
    	String ip = null;
        try {
            ip = request.getHeader("x-forwarded-for");
            if (StringUtils.isEmpty(ip) || "unknown".equalsIgnoreCase(ip)) {
                ip = request.getHeader("Proxy-Client-IP");
            }
            if (StringUtils.isEmpty(ip) || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
                ip = request.getHeader("WL-Proxy-Client-IP");
            }
            if (StringUtils.isEmpty(ip) || "unknown".equalsIgnoreCase(ip)) {
                ip = request.getHeader("HTTP_CLIENT_IP");
            }
            if (StringUtils.isEmpty(ip) || "unknown".equalsIgnoreCase(ip)) {
                ip = request.getHeader("HTTP_X_FORWARDED_FOR");
            }
            if (StringUtils.isEmpty(ip) || "unknown".equalsIgnoreCase(ip)) {
                ip = request.getRemoteAddr();
            }
        } catch (Exception e) {
        	log.error("IPUtils ERROR ", e);
        }

return ip;
    }

public static String getServerIpAddress() {
        try {
            InetAddress localhost = InetAddress.getLocalHost();
            return localhost.getHostAddress();
        } catch (UnknownHostException e) {
            log.error(e.getMessage());
            return null;
        }
    }

public static void main(String[] args) {
        try {
            InetAddress localhost = InetAddress.getLocalHost();
            String ip = localhost.getHostAddress();
            System.out.println("服务端IP地址：" + ip);
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
    }

}

package com.yn.bftl.thirdparty.common.util;

import javax.servlet.http.HttpServletRequest;
import java.net.InetAddress;
import java.net.UnknownHostException;

/**
 * IP工具类
 *
 */
@Slf4j
public class IPUtils {

public static void checkWhileIp(String whiteIp) {
        if (StringUtils.isEmpty(whiteIp)) {
            throw new YnceErrorException("参数不能为空");
        }
        ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
        String ip = IPUtils.getClientIpAddress(requestAttributes.getRequest());
        if (StringUtils.isEmpty(ip)) {
            throw new YnceErrorException("非法IP");
        }
        if (!whiteIp.equals(ip)) {
            throw new YnceErrorException("非法访问");
        }
    }

return ip;
    }

}

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/u8/controller/U8ShippingController.java
package com.yn.bftl.thirdparty.modules.u8.controller; import com.alibaba.fastjson.JSON; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import com.yn.bftl.thirdparty.common.util.IPUtils; import com.yn.bftl.thirdparty.config.U8Properties; import com.yn.bftl.thirdparty.modules.business.dto.U8ShippingDTO; import com.yn.bftl.thirdparty.modules.u8.service.U8ShippingService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.util.CollectionUtils; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; @Slf4j @RestController @RequestMapping("/u8") public class U8ShippingController { @Autowired private U8Properties u8Properties; @Autowired private U8ShippingService u8ShippingService; @RequestMapping(value = "/shipping", method = RequestMethod.POST) public void shipping(@RequestBody U8ShippingDTO shippingSynDataDTO) { log.info("=======================================u8请求参数" + JSON.toJSONString(shippingSynDataDTO)); IPUtils.checkWhileIp(u8Properties.getWhiteIp()); if (CollectionUtils.isEmpty(shippingSynDataDTO.getDetailList())) { log.error("订单项数据不能为空"); throw new YnceErrorException("订单项数据不能为空"); } u8ShippingService.saveU8SynData(shippingSynDataDTO); } } package com.yn.bftl.thirdparty.modules.u8.controller; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import com.yn.bftl.thirdparty.common.util.IPUtils; import com.yn.bftl.thirdparty.config.U8Properties; import com.yn.bftl.thirdparty.modules.business.dto.U8ShippingDTO; import com.yn.bftl.thirdparty.modules.u8.service.U8ShippingService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.util.CollectionUtils; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; @RestController @RequestMapping("/u8") public class U8ShippingController { @Autowired private U8Properties u8Properties; @Autowired private U8ShippingService u8ShippingService; @RequestMapping(value = "/shipping", method = RequestMethod.POST) public void shipping(@RequestBody U8ShippingDTO shippingSynDataDTO) { IPUtils.checkWhileIp(u8Properties.getWhiteIp()); if (CollectionUtils.isEmpty(shippingSynDataDTO.getDetailList())) { throw new YnceErrorException("订单项数据不能为空"); } u8ShippingService.saveU8SynData(shippingSynDataDTO); } }

Ignore Space Show notes View

src/main/java/com/yn/bftl/thirdparty/modules/u8/controller/U8ShippingController.java

package com.yn.bftl.thirdparty.modules.u8.controller;

import com.alibaba.fastjson.JSON;
import com.yn.bftl.thirdparty.common.exception.YnceErrorException;
import com.yn.bftl.thirdparty.common.util.IPUtils;
import com.yn.bftl.thirdparty.config.U8Properties;
import com.yn.bftl.thirdparty.modules.business.dto.U8ShippingDTO;
import com.yn.bftl.thirdparty.modules.u8.service.U8ShippingService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

@Slf4j
@RestController
@RequestMapping("/u8")
public class U8ShippingController {

@Autowired
    private U8Properties u8Properties;

@Autowired
    private U8ShippingService u8ShippingService;

@RequestMapping(value = "/shipping", method = RequestMethod.POST)
    public void shipping(@RequestBody U8ShippingDTO shippingSynDataDTO) {
        log.info("=======================================u8请求参数" + JSON.toJSONString(shippingSynDataDTO));
        IPUtils.checkWhileIp(u8Properties.getWhiteIp());
        if (CollectionUtils.isEmpty(shippingSynDataDTO.getDetailList())) {
            log.error("订单项数据不能为空");
            throw new YnceErrorException("订单项数据不能为空");
        }

u8ShippingService.saveU8SynData(shippingSynDataDTO);
    }

}

package com.yn.bftl.thirdparty.modules.u8.controller;

import com.yn.bftl.thirdparty.common.exception.YnceErrorException;
import com.yn.bftl.thirdparty.common.util.IPUtils;
import com.yn.bftl.thirdparty.config.U8Properties;
import com.yn.bftl.thirdparty.modules.business.dto.U8ShippingDTO;
import com.yn.bftl.thirdparty.modules.u8.service.U8ShippingService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/u8")
public class U8ShippingController {

@Autowired
    private U8Properties u8Properties;

@Autowired
    private U8ShippingService u8ShippingService;

@RequestMapping(value = "/shipping", method = RequestMethod.POST)
    public void shipping(@RequestBody U8ShippingDTO shippingSynDataDTO) {
        IPUtils.checkWhileIp(u8Properties.getWhiteIp());
        if (CollectionUtils.isEmpty(shippingSynDataDTO.getDetailList())) {
            throw new YnceErrorException("订单项数据不能为空");
        }

u8ShippingService.saveU8SynData(shippingSynDataDTO);
    }

}

Ignore Space Show notes View src/main/java/com/yn/bftl/thirdparty/modules/u8/service/impl/U8ShippingServiceImpl.java
package com.yn.bftl.thirdparty.modules.u8.service.impl; import com.yn.bftl.common.modules.inventory.entity.Warehouse; import com.yn.bftl.common.modules.order.entity.Order; import com.yn.bftl.common.modules.order.entity.OrderItem; import com.yn.bftl.common.modules.order.entity.Shipping; import com.yn.bftl.common.modules.order.entity.ShippingItem; import com.yn.bftl.common.modules.order.enums.ShippingStatus; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import com.yn.bftl.thirdparty.common.repository.; import com.yn.bftl.thirdparty.modules.business.dto.U8ShippingDTO; import com.yn.bftl.thirdparty.modules.business.dto.U8ShippingDetailDTO; import com.yn.bftl.thirdparty.modules.u8.service.U8ShippingService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.ArrayList; import java.util.List; @Service @Slf4j public class U8ShippingServiceImpl implements U8ShippingService { @Autowired private OrderRepository orderRepository; @Autowired private OrderItemRepository orderItemRepository; @Autowired private WarehouseRepository warehouseRepository; @Autowired private ShippingRepository shippingRepository; @Transactional public void saveU8SynData(U8ShippingDTO shippingSynDataDTO) { Order order = orderRepository.findFirstBySn(shippingSynDataDTO.getSn()); if (order == null) { log.error("订单号不存在"); throw new YnceErrorException("订单号不存在"); } Shipping shipping = new Shipping(); BeanUtils.copyProperties(shippingSynDataDTO, shipping); shipping.setOrders(order); List<ShippingItem> shippingItemList = new ArrayList<>(); for (U8ShippingDetailDTO u8ShippingDetailDTO: shippingSynDataDTO.getDetailList()) { OrderItem orderItem = orderItemRepository.findById(Long.parseLong(u8ShippingDetailDTO.getOrderItemId())).orElse(null); if (orderItem == null) { log.error("订单项不存在"); throw new YnceErrorException("订单项不存在"); } ShippingItem shippingItem = new ShippingItem(); BeanUtils.copyProperties(u8ShippingDetailDTO, shippingItem); Warehouse warehouse = warehouseRepository.findByCode(u8ShippingDetailDTO.getCode()); if (warehouse == null) { log.error("仓库不存在"); throw new YnceErrorException("仓库不存在"); } shippingItem.setOutWarehouse(warehouse); shippingItem.setShipping(shipping); shippingItemList.add(shippingItem); } shipping.setShippingItem(shippingItemList); shippingRepository.save(shipping); // 更新订单状态 order.setShippingStatus(ShippingStatus.SHIPPED); orderRepository.saveAndFlush(order); } } package com.yn.bftl.thirdparty.modules.u8.service.impl; import com.yn.bftl.common.modules.inventory.entity.Warehouse; import com.yn.bftl.common.modules.order.entity.Order; import com.yn.bftl.common.modules.order.entity.OrderItem; import com.yn.bftl.common.modules.order.entity.Shipping; import com.yn.bftl.common.modules.order.entity.ShippingItem; import com.yn.bftl.common.modules.order.enums.ShippingStatus; import com.yn.bftl.thirdparty.common.exception.YnceErrorException; import com.yn.bftl.thirdparty.common.repository.; import com.yn.bftl.thirdparty.modules.business.dto.U8ShippingDTO; import com.yn.bftl.thirdparty.modules.business.dto.U8ShippingDetailDTO; import com.yn.bftl.thirdparty.modules.u8.service.U8ShippingService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.ArrayList; import java.util.List; @Service @Slf4j public class U8ShippingServiceImpl implements U8ShippingService { @Autowired private OrderRepository orderRepository; @Autowired private OrderItemRepository orderItemRepository; @Autowired private WarehouseRepository warehouseRepository; @Autowired private ShippingRepository shippingRepository; @Transactional public void saveU8SynData(U8ShippingDTO shippingSynDataDTO) { Order order = orderRepository.findFirstBySn(shippingSynDataDTO.getSn()); if (order == null) { throw new YnceErrorException("订单号不存在"); } Shipping shipping = new Shipping(); BeanUtils.copyProperties(shippingSynDataDTO, shipping); shipping.setOrders(order); List<ShippingItem> shippingItemList = new ArrayList<>(); for (U8ShippingDetailDTO u8ShippingDetailDTO: shippingSynDataDTO.getDetailList()) { OrderItem orderItem = orderItemRepository.findById(Long.parseLong(u8ShippingDetailDTO.getOrderItemId())).orElse(null); if (orderItem == null) { throw new YnceErrorException("订单项不存在"); } ShippingItem shippingItem = new ShippingItem(); BeanUtils.copyProperties(u8ShippingDetailDTO, shippingItem); Warehouse warehouse = warehouseRepository.findByCode(u8ShippingDetailDTO.getCode()); if (warehouse == null) { throw new YnceErrorException("仓库不存在"); } shippingItem.setOutWarehouse(warehouse); shippingItem.setShipping(shipping); shippingItemList.add(shippingItem); } shipping.setShippingItem(shippingItemList); shippingRepository.save(shipping); // 更新订单状态 order.setShippingStatus(ShippingStatus.SHIPPED); orderRepository.saveAndFlush(order); } }

Ignore Space Show notes View

src/main/java/com/yn/bftl/thirdparty/modules/u8/service/impl/U8ShippingServiceImpl.java

package com.yn.bftl.thirdparty.modules.u8.service.impl;

import com.yn.bftl.common.modules.inventory.entity.Warehouse;
import com.yn.bftl.common.modules.order.entity.Order;
import com.yn.bftl.common.modules.order.entity.OrderItem;
import com.yn.bftl.common.modules.order.entity.Shipping;
import com.yn.bftl.common.modules.order.entity.ShippingItem;
import com.yn.bftl.common.modules.order.enums.ShippingStatus;
import com.yn.bftl.thirdparty.common.exception.YnceErrorException;
import com.yn.bftl.thirdparty.common.repository.*;
import com.yn.bftl.thirdparty.modules.business.dto.U8ShippingDTO;
import com.yn.bftl.thirdparty.modules.business.dto.U8ShippingDetailDTO;
import com.yn.bftl.thirdparty.modules.u8.service.U8ShippingService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.List;

@Service
@Slf4j
public class U8ShippingServiceImpl implements U8ShippingService {

@Autowired
    private OrderRepository orderRepository;

@Autowired
    private OrderItemRepository orderItemRepository;

@Autowired
    private WarehouseRepository warehouseRepository;

@Autowired
    private ShippingRepository shippingRepository;

@Transactional
    public void saveU8SynData(U8ShippingDTO shippingSynDataDTO) {
        Order order = orderRepository.findFirstBySn(shippingSynDataDTO.getSn());
        if (order == null) {
            log.error("订单号不存在");
            throw new YnceErrorException("订单号不存在");
        }
        Shipping shipping = new Shipping();
        BeanUtils.copyProperties(shippingSynDataDTO, shipping);
        shipping.setOrders(order);
        List<ShippingItem> shippingItemList = new ArrayList<>();
        for (U8ShippingDetailDTO u8ShippingDetailDTO: shippingSynDataDTO.getDetailList()) {
            OrderItem orderItem = orderItemRepository.findById(Long.parseLong(u8ShippingDetailDTO.getOrderItemId())).orElse(null);
            if (orderItem == null) {
                log.error("订单项不存在");
                throw new YnceErrorException("订单项不存在");
            }
            ShippingItem shippingItem = new ShippingItem();
            BeanUtils.copyProperties(u8ShippingDetailDTO, shippingItem);
            Warehouse warehouse = warehouseRepository.findByCode(u8ShippingDetailDTO.getCode());
            if (warehouse == null) {
                log.error("仓库不存在");
                throw new YnceErrorException("仓库不存在");
            }
            shippingItem.setOutWarehouse(warehouse);
            shippingItem.setShipping(shipping);
            shippingItemList.add(shippingItem);
        }
        shipping.setShippingItem(shippingItemList);
        shippingRepository.save(shipping);
        // 更新订单状态
        order.setShippingStatus(ShippingStatus.SHIPPED);
        orderRepository.saveAndFlush(order);
    }
}

package com.yn.bftl.thirdparty.modules.u8.service.impl;

import java.util.ArrayList;
import java.util.List;

@Service
@Slf4j
public class U8ShippingServiceImpl implements U8ShippingService {

@Autowired
    private OrderRepository orderRepository;

@Autowired
    private OrderItemRepository orderItemRepository;

@Autowired
    private WarehouseRepository warehouseRepository;

@Autowired
    private ShippingRepository shippingRepository;

@Transactional
    public void saveU8SynData(U8ShippingDTO shippingSynDataDTO) {
        Order order = orderRepository.findFirstBySn(shippingSynDataDTO.getSn());
        if (order == null) {
            throw new YnceErrorException("订单号不存在");
        }
        Shipping shipping = new Shipping();
        BeanUtils.copyProperties(shippingSynDataDTO, shipping);
        shipping.setOrders(order);
        List<ShippingItem> shippingItemList = new ArrayList<>();
        for (U8ShippingDetailDTO u8ShippingDetailDTO: shippingSynDataDTO.getDetailList()) {
            OrderItem orderItem = orderItemRepository.findById(Long.parseLong(u8ShippingDetailDTO.getOrderItemId())).orElse(null);
            if (orderItem == null) {
                throw new YnceErrorException("订单项不存在");
            }
            ShippingItem shippingItem = new ShippingItem();
            BeanUtils.copyProperties(u8ShippingDetailDTO, shippingItem);
            Warehouse warehouse = warehouseRepository.findByCode(u8ShippingDetailDTO.getCode());
            if (warehouse == null) {
                throw new YnceErrorException("仓库不存在");
            }
            shippingItem.setOutWarehouse(warehouse);
            shippingItem.setShipping(shipping);
            shippingItemList.add(shippingItem);
        }
        shipping.setShippingItem(shippingItemList);
        shippingRepository.save(shipping);
        // 更新订单状态
        order.setShippingStatus(ShippingStatus.SHIPPED);
        orderRepository.saveAndFlush(order);
    }
}

Show line notes below