oyingServer.git

			@@ -1,7 +1,24 @@
			package com.oying.modules.sh.service.impl;

			import com.alibaba.fastjson2.JSONObject;
			import com.oying.exception.BadRequestException;
			import com.oying.modules.hwc.service.SwiftPassService;
			import com.oying.modules.pc.product.domain.Product;
			import com.oying.modules.pc.product.domain.enums.ProductStatusEnum;
			import com.oying.modules.pc.product.service.ProductService;
			import com.oying.modules.sh.domain.Order;
			import com.oying.utils.FileUtil;
			import com.oying.modules.sh.domain.OrderProductSnapshot;
			import com.oying.modules.sh.domain.request.GeneratorOrder;
			import com.oying.modules.sh.domain.request.ProductOrder;
			import com.oying.modules.sh.domain.request.SubmitOrder;
			import com.oying.modules.sh.domain.vo.OrderInfo;
			import com.oying.modules.sh.domain.vo.ProductInfo;
			import com.oying.modules.sh.service.OrderProductSnapshotService;
			import com.oying.modules.sh.service.UserAddressService;
			import com.oying.utils.*;
			import com.oying.utils.enums.GenerateEnum;
			import com.oying.utils.enums.PayStateEnum;
			import com.oying.utils.enums.PayTypeEnum;
			import lombok.RequiredArgsConstructor;
			import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			@@ -10,34 +27,122 @@
			import com.oying.modules.sh.mapper.OrderMapper;
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.annotation.Transactional;
			import com.oying.utils.PageUtil;
			import java.util.List;
			import java.util.Map;

			import java.math.BigDecimal;
			import java.sql.Timestamp;
			import java.util.*;
			import java.io.IOException;
			import javax.servlet.http.HttpServletRequest;
			import javax.servlet.http.HttpServletResponse;
			import java.util.ArrayList;
			import java.util.LinkedHashMap;
			import com.oying.utils.PageResult;

			/**
			* @description 服务实现
			* @author lixin
			* @date 2025-06-11
			**/
			* @author lixin
			* @description 服务实现
			* @date 2025-06-11
			**/
			@Service
			@RequiredArgsConstructor
			public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> implements OrderService {

			private final OrderMapper orderMapper;
			private final UserAddressService userAddressService;
			private final ProductService productService;
			private final SwiftPassService swiftPassService;
			private final OrderProductSnapshotService productSnapshotService;
			private final RedisUtils redisUtils;

			@Override
			public PageResult<Order> queryAll(OrderQueryCriteria criteria, Page<Object> page){
			public PageResult<Order> queryAll(OrderQueryCriteria criteria, Page<Object> page) {
			return PageUtil.toPage(orderMapper.findAll(criteria, page));
			}

			@Override
			public List<Order> queryAll(OrderQueryCriteria criteria){
			public List<Order> queryAll(OrderQueryCriteria criteria) {
			return orderMapper.findAll(criteria);
			}

			@Override
			@Transactional(rollbackFor = Exception.class)
			public synchronized Order submitOrder(SubmitOrder submit, HttpServletRequest request) {
			if (!submit.getPayType().equals(PayTypeEnum.HWC)) {
			throw new BadRequestException("支付类型暂未开放");
			}
			String orderNum = redisUtils.generateOrderSn(GenerateEnum.ORDER.getKey());
			// 总金额
			BigDecimal amount = BigDecimal.ZERO;
			GeneratorOrder generator = new GeneratorOrder();
			generator.setProducts(submit.getProducts());
			generator.setStoreId(submit.getStoreId());
			OrderInfo info = generatorOrder(generator);
			// 商品快照
			List<OrderProductSnapshot> snapshots = new ArrayList<>();

			for (ProductInfo productInfo : info.getProducts()) {
			Product product = productInfo.getProduct();
			OrderProductSnapshot snapshot = new OrderProductSnapshot();
			snapshot.setOrderNum(orderNum);
			snapshot.setStoreId(submit.getStoreId());
			snapshot.setProductId(product.getProductId());
			snapshot.setProductBarcode(product.getBarcode());
			snapshot.setProductName(product.getName());
			snapshot.setProductTitle(product.getTitle());
			snapshot.setProductMainImage(product.getMainImageUrl());
			snapshot.setParamData(JSONObject.toJSONString(productInfo.getProductLabels()));
			snapshot.setUnitPrice(product.getPrice());
			snapshot.setDetailCount(productInfo.getCount());
			snapshot.setOriginalPrice(product.getPrice());
			snapshot.setPaidPrice(product.getPrice());
			BigDecimal decimal = BigDecimalUtils.multiply(product.getPrice(), productInfo.getCount());
			amount = BigDecimalUtils.add(amount, decimal);
			snapshot.setActuallyPayPrice(decimal);
			snapshot.setPayState(PayStateEnum.NOTPAY.getKey());
			snapshots.add(snapshot);
			}
			// 下单后30分钟失效
			Timestamp time = DateUtil.addMinute(DateUtil.getTimeStamp(), 30);
			String expire = DateUtil.localDateTimeFormat(time.toLocalDateTime(), DateUtil.SDF_YMDHMS);
			swiftPassService.pay(StringUtils.getIp(request), BigDecimalUtils.yuanToCents(amount).toString(), expire,SecurityUtils.getCurrentUserId());
			productSnapshotService.saveBatch(snapshots);
			return null;
			}

			@Override
			@Transactional(rollbackFor = Exception.class)
			public synchronized OrderInfo generatorOrder(GeneratorOrder criteria) {
			List<ProductInfo> products = new ArrayList<>();
			BigDecimal amount = BigDecimal.ZERO;
			for (ProductOrder productOrder : criteria.getProducts()) {
			Product product = productService.getById(productOrder.getProductId());
			if (product == null) {
			throw new BadRequestException("商品不存在");
			}
			if (product.getStoreId().equals(criteria.getStoreId())) {
			throw new BadRequestException("不支持跨门店下单");
			}
			if (!product.getStatus().equals(ProductStatusEnum.AVAILABLE.getValue())) {
			ProductStatusEnum statusEnum = ProductStatusEnum.get(product.getStatus());
			throw new BadRequestException(product.getName() + "：" + (statusEnum != null ? statusEnum.getReasonPhrase() : "状态"));
			}
			if (productOrder.getCount() > product.getStockQuantity()) {
			throw new BadRequestException("商品库存不足");
			}
			if (productOrder.getCount() < product.getMinPurchaseQuantity()) {
			throw new BadRequestException("起售数量不足");
			}
			ProductInfo info = new ProductInfo();
			info.setProduct(product);
			info.setProductLabels(product.getLabels());
			info.setCount(productOrder.getCount());
			products.add(info);
			amount = BigDecimalUtils.add(amount, BigDecimalUtils.multiply(product.getPrice(), productOrder.getCount()));
			}
			OrderInfo info = new OrderInfo();
			info.setProducts(products);
			info.setAmount(amount);
			info.setPayAmount(amount);
			info.setPromotionAmount(BigDecimal.ZERO);
			info.setUserAddresses(userAddressService.queryUserAddress());
			return info;
			}

			@Override
			@@ -68,6 +173,7 @@
			map.put("订单号", order.getOrderNum());
			map.put("用户id", order.getUserId());
			map.put("门店ID", order.getStoreId());
			map.put("门店", order.getStoreName());
			map.put("描述", order.getOrderDescribe());
			map.put("原金额", order.getOriginalPrice());
			map.put("折扣价", order.getPaidPrice());
			@@ -79,11 +185,6 @@
			map.put("订单失效时间RFC3339", order.getExpireTime());
			map.put("openid", order.getOpenid());
			map.put("APPID", order.getAppId());
			map.put("时间戳", order.getTimestamp());
			map.put(" nonceStr", order.getNonceStr());
			map.put(" packageVal", order.getPackageVal());
			map.put(" signType", order.getSignType());
			map.put("签名", order.getPaySign());
			map.put("创建人", order.getCreateBy());
			map.put("创建时间", order.getCreateTime());
			map.put("修改者", order.getUpdateBy());