package com.matrix.system.shopXcx.api.service.impl; import com.google.gson.Gson; import com.google.gson.GsonBuilder; import com.matrix.biz.bean.BizUser; import com.matrix.component.rabbitmq.RabiitMqTemplate; import com.matrix.component.redis.RedisUserLoginUtils; import com.matrix.component.tools.WxUtils; import com.matrix.component.wechat.externalInterface.protocol.paramProtocol.BrandWCPayRequestData; import com.matrix.component.wechat.externalInterface.weixinUtil.WeixinServiceUtil; import com.matrix.core.exception.GlobleException; import com.matrix.core.pojo.AjaxResult; import com.matrix.core.tools.LogUtil; import com.matrix.core.tools.StringUtils; import com.matrix.system.common.bean.BusParameterSettings; import com.matrix.system.common.constance.AppConstance; import com.matrix.system.common.dao.BusParameterSettingsDao; import com.matrix.system.common.dao.CustomerDataDictionaryDao; import com.matrix.system.common.interceptor.HostInterceptor; import com.matrix.system.constance.Dictionary; import com.matrix.system.hive.bean.ShoppingGoods; import com.matrix.system.hive.dao.ShoppingGoodsDao; import com.matrix.system.shopXcx.api.action.PayThreadPool; import com.matrix.system.shopXcx.api.pojo.AddShopOrderPOJO; import com.matrix.system.shopXcx.api.pojo.OrderInfoQueryPOJO; import com.matrix.system.shopXcx.api.service.ShoppingCartService; import com.matrix.system.shopXcx.api.service.WXShopOrderService; import com.matrix.system.shopXcx.api.service.WxShopCouponService; import com.matrix.system.shopXcx.api.tools.WxShopCouponUtil; import com.matrix.system.shopXcx.api.tools.WxShopOrderUtil; import com.matrix.system.shopXcx.api.vo.CouponReceiveInfoVO; import com.matrix.system.shopXcx.api.vo.ShopCartBillVo; import com.matrix.system.shopXcx.api.vo.ShopCartVo; import com.matrix.system.shopXcx.bean.*; import com.matrix.system.shopXcx.dao.*; import com.matrix.system.shopXcx.dto.DiscountExplain; import org.apache.commons.collections.CollectionUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; import java.util.*; /** * @author jyy * @description 订单服务层 * @date 2019-06-10 10:58 */ @Service public class WXShopOrderServiceImpl implements WXShopOrderService { @Autowired private WxShopOrderUtil wxShopOrderUtil; @Autowired private WxShopCouponUtil wxShopCouponUtil; @Autowired private RedisUserLoginUtils redisUserLoginUtils; @Autowired private WeixinServiceUtil weixinServiceUtil; @Autowired private ShopSkuDao shopSkuDao; @Autowired private ShopReceiveAddressDao shopReceiveAddressDao; @Autowired private ShopOrderDao shopOrderDao; @Autowired private ShopOrderDetailsDao shopOrderDetailsDao; @Autowired private ShopCouponDao shopCouponDao; @Autowired private ShopProductDao shopProductDao; @Autowired private ShopCouponRecordDao shopCouponRecordDao; @Autowired ShoppingGoodsDao shoppingGoodsDao; @Autowired ShoppingCartService shoppingCartService; @Autowired WxShopCouponService wxShopCouponService; @Autowired private ShopActivitiesGroupJoinDao shopActivitiesGroupJoinDao; @Autowired private ShopShoppingCartDao shoppingCartDao; @Autowired private ShopActivitiesGroupJoinUserDao shopActivitiesGroupJoinUserDao; @Autowired CustomerDataDictionaryDao dataDictionaryDao; @Value("${wx_pay_debug_onoff}") private boolean isDebug; @Autowired private BusParameterSettingsDao busParameterSettingsDao; @Override public BigDecimal calculationPostage(BigDecimal payPrice,Long companyId) { BigDecimal postage = BigDecimal.ZERO; BusParameterSettings yf = busParameterSettingsDao.selectCompanyParamByCode(AppConstance.PACKAGE_PRICE, companyId); BusParameterSettings myje = busParameterSettingsDao.selectCompanyParamByCode(AppConstance.FREE_PACKAGE_PRICE, companyId); if(yf!=null&&myje!=null){ if (Double.parseDouble(myje.getParamValue()) > payPrice.doubleValue()) { postage = new BigDecimal(yf.getParamValue()); } } return postage; } /** * 创建订单 * * @param addShopOrderPOJO * @return * @throws Exception */ @Transactional(rollbackFor = Exception.class) @Override public AjaxResult createShopOrder(AddShopOrderPOJO addShopOrderPOJO) throws Exception { BizUser bizUser = redisUserLoginUtils.getLoginUser(BizUser.class); //校验收货地址 ShopReceiveAddress shopReceiveAddress = shopReceiveAddressDao.selectById(addShopOrderPOJO.getReceiveAddrId()); if (shopReceiveAddress == null) { return new AjaxResult(AjaxResult.STATUS_FAIL, "请选择正确的收获地址"); } List cartList = shoppingCartService.findUserCartList(addShopOrderPOJO.getShopId()); //购物车不能为空 if (CollectionUtils.isEmpty(cartList)) { return new AjaxResult(AjaxResult.STATUS_FAIL, "请选择您需要购买的产品"); } //取出购物车中选中的产品 List buyCart = new ArrayList<>(); //取出购物车中没有参加店铺活动的产品，和参加了店铺活动但是活动没有达到标准的产品，用来计算是否可以使用优惠券 List notCouponuyCart = new ArrayList<>(); for (ShopCartVo shopCartVo : cartList) { for (ShopShoppingCart shopShoppingCart : shopCartVo.getCartList()) { if (shopShoppingCart.getIsSelected() == 1) { buyCart.add(shopShoppingCart); if (shopCartVo.getCoupon() == null || !shopCartVo.isSatisfactionCoupon()) { notCouponuyCart.add(shopShoppingCart); } } } } //计算订单优惠信息 DiscountExplain discountExplain = buildDiscountExplain(cartList, addShopOrderPOJO.getCouponReceiveId(), bizUser.getCompanyId()); ShopOrder shopOrder = new ShopOrder(); shopOrder.setCompanyId(bizUser.getCompanyId()); shopOrder.setStoreId(Integer.parseInt(addShopOrderPOJO.getShopId().toString())); //默认设置为产品类型 shopOrder.setOrderType(ShopOrder.ORDER_TYPE_GOODS); List details = new ArrayList<>(); Integer cartCount = 0; for (ShopShoppingCart shopShoppingCart : buyCart) { ShopOrderDetails shopOrderDetails = new ShopOrderDetails(); shopOrderDetails.setCreateBy(AppConstance.SYSTEM_USER); shopOrderDetails.setUpdateBy(AppConstance.SYSTEM_USER); shopOrderDetails.setpId(shopShoppingCart.getCartProductId()); shopOrderDetails.setsId(shopShoppingCart.getCartSkuId()); shopOrderDetails.setPrice(shopShoppingCart.getPrice()); shopOrderDetails.setCount(shopShoppingCart.getCartNumber()); shopOrderDetails.setsTitle(shopShoppingCart.getTitle() + shopShoppingCart.getName()); shopOrderDetails.setDiscountAmount(BigDecimal.ZERO); shopOrderDetails.setTotalPrice(shopOrderDetails.getPrice().multiply(BigDecimal.valueOf(shopOrderDetails.getCount()))); details.add(shopOrderDetails); cartCount += shopOrderDetails.getCount(); //查询绑定的产品是否为家居产品,如果已经含家具产品则不再比较 if (ShopOrder.ORDER_TYPE_GOODS != shopOrder.getOrderType()) { ShopSku shopSku = shopSkuDao.selectById(shopShoppingCart.getCartSkuId()); String stokCode = shopSku.getStockCode(); if (StringUtils.isNotBlank(stokCode)) { ShoppingGoods shoppingGoods = shoppingGoodsDao.selectById(Long.parseLong(stokCode)); if (shoppingGoods != null) { //根据购买的产品设置订单类型 if (Dictionary.SHOPPING_GOODS_TYPE_JJCP.equals(shoppingGoods.getGoodType())) { shopOrder.setOrderType(ShopOrder.ORDER_TYPE_GOODS); } else { } } else { shopOrder.setOrderType(ShopOrder.ORDER_TYPE_GOODS); } } } } //校验商品是否限购 wxShopOrderUtil.verifyProductLimitInfo(details, bizUser.getOpenId()); //TODO 更新库存和销量 更新库存和销量[考虑和erp库存联动] wxShopOrderUtil.updateProductAndSkuInfo(details); //用户openId shopOrder.setUserId(bizUser.getOpenId()); shopOrder.setCreateBy("微信小程序生成"); shopOrder.setUpdateBy("微信小程序生成"); shopOrder.setCommodityPrice(discountExplain.getBillPrice()); shopOrder.setPurchaseQuantity(cartCount); //购买方式 shopOrder.setShippingMethod(addShopOrderPOJO.getDeliverySelect()); //生成订单号 shopOrder.setOrderNo(WxUtils.getOrderNum()); //设置支付状态 shopOrder.setPayStatus(ShopOrder.ORDER_STATUS_WAIT_PAY); //设置订单状态 shopOrder.setOrderStatus(ShopOrder.ORDER_PAY_STATUS_WAIT); //设置退款费用(注：下次优化从数据字典表获取) shopOrder.setRefundCharge(BigDecimal.ZERO); //客户电话 shopOrder.setUserTel(shopReceiveAddress.getAddrTelephone()); //客户姓名 shopOrder.setUserName(shopReceiveAddress.getAddrLiaisonman()); //备注 shopOrder.setRemarks(addShopOrderPOJO.getRemarks()); //删除标识 shopOrder.setDelFlag(AppConstance.DATA_USEABLE); //微信订单号 shopOrder.setWxOrderNo(""); //微信支付结果 shopOrder.setPayResult(ShopOrder.ORDER_WX_STATUS_WAIT_PAY); //如果没有提交购买方式或配送方式不是物流 //获取邮费 shopOrder.setPostage(discountExplain.getPostage()); shopOrder.setOrderMoney(discountExplain.getPayPrice()); Gson g = new GsonBuilder().create(); shopOrder.setDiscountExplain(g.toJson(discountExplain)); shopOrder.setDiscountAmount(discountExplain.getActivity().add(discountExplain.getCoupon())); shopOrder.setCompanyId(HostInterceptor.getCompanyId()); shopOrderDao.insert(shopOrder); wxShopOrderUtil.insertSendPackageInfo(shopOrder, addShopOrderPOJO.getDeliverySelect(), shopReceiveAddress); //给订单详情表添加订单ID for (ShopOrderDetails shopOrderDetails : details) { shopOrderDetails.setOrderId(shopOrder.getId()); } if (CollectionUtils.isNotEmpty(details)) { shopOrderDetailsDao.batchInsert(details); } //更新使用的优惠券状态 if (addShopOrderPOJO.getCouponReceiveId() != null) { ShopCouponRecord record = new ShopCouponRecord(); record.setIsUsing(AppConstance.MY_COUPON_USE); record.setOrderId(shopOrder.getId()); record.setId(addShopOrderPOJO.getCouponReceiveId()); shopCouponRecordDao.updateByModel(record); } //删除用户购物车选中的产品 shoppingCartDao.deleteUserSelectCart(bizUser.getOpenId()); BrandWCPayRequestData payData = startPayment(shopOrder); AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, Arrays.asList(payData)); result.putInMap("orderId", shopOrder.getId()); return result; } @Override public DiscountExplain buildDiscountExplain(List cartList, Integer receiveId, Long companyId) { ShopCartBillVo shopCartBill = shoppingCartService.buildShopCartBillVo(cartList); DiscountExplain discountExplain = new DiscountExplain(); discountExplain.setActivity(shopCartBill.getBillCouponTotal()); discountExplain.setBillPrice(shopCartBill.getSrcTotal()); discountExplain.setPayPrice(shopCartBill.getBillTotal()); //计算优惠券 if (receiveId != null) { CouponReceiveInfoVO couponReceiveInfoVO = shopCouponRecordDao.selectMyCouponByReceiveId(receiveId); if (couponReceiveInfoVO != null) { BigDecimal payPrice = discountExplain.getPayPrice().subtract(couponReceiveInfoVO.getOffsetAmount()); payPrice = payPrice.compareTo(BigDecimal.ZERO) < 0 ? BigDecimal.ZERO : payPrice; discountExplain.setPayPrice(payPrice); discountExplain.setCoupon(couponReceiveInfoVO.getOffsetAmount()); } } discountExplain.setPostage(calculationPostage(discountExplain.getPayPrice(),companyId)); //计算实际支付 discountExplain.setPayPrice(discountExplain.getPayPrice().add(discountExplain.getPostage())); return discountExplain; } /** * 根据订单ID结算订单 * * @param orderId * @return * @throws Exception */ @Override public AjaxResult orderSettlement(int orderId) throws Exception { ShopOrder shopOrder = shopOrderDao.selectById(orderId); if (shopOrder == null) { throw new GlobleException("订单不存在！"); } if (!shopOrder.getPayResult().equals(ShopOrder.ORDER_PAY_STATUS_WAIT)) { throw new GlobleException("该订单不是待支付状态！"); } BrandWCPayRequestData payData = startPayment(shopOrder); AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, Arrays.asList(payData)); result.putInMap("orderId", shopOrder.getId()); return result; } /** * 开始付款 * * @param shopOrder * @return * @throws Exception */ @Override public BrandWCPayRequestData startPayment(ShopOrder shopOrder) throws Exception { BigDecimal unit = new BigDecimal("100"); BigDecimal money = new BigDecimal(shopOrder.getOrderMoney().toString()); BrandWCPayRequestData payData; String productNames = wxShopOrderUtil.getProductNames(shopOrder.getUserId(), shopOrder.getId()); LogUtil.debug(String.valueOf(isDebug)); if (isDebug) { payData = weixinServiceUtil.createOrder("[测试]" + productNames, shopOrder.getOrderNo(), 1, shopOrder.getUserId(), String.valueOf(shopOrder.getId())); } else { payData = weixinServiceUtil.createOrder(productNames, shopOrder.getOrderNo(), unit.multiply(money).intValue(), shopOrder.getUserId(), String.valueOf(shopOrder.getId())); } ShopOrder updateParam = new ShopOrder(); updateParam.setId(shopOrder.getId()); updateParam.setWxOrderNo(payData.getPrepay_id()); shopOrderDao.updateByModel(updateParam); return payData; } /** * 根据订单状态等条件获取我的订单列表 * * @param orderInfoQueryPOJO * @return */ @Override public AjaxResult getMyOrderInfo(OrderInfoQueryPOJO orderInfoQueryPOJO) { BizUser bizUser = redisUserLoginUtils.getLoginUser(BizUser.class); orderInfoQueryPOJO.setSort("update_time"); if (orderInfoQueryPOJO.getOffset() >= 1) { orderInfoQueryPOJO.setOffset((orderInfoQueryPOJO.getOffset() - 1) * orderInfoQueryPOJO.getLimit()); } List result = shopOrderDao.selectMyOrderByStatus(bizUser.getOpenId(), orderInfoQueryPOJO); return new AjaxResult(AjaxResult.STATUS_SUCCESS, result); } /** * 根据订单ID查询订单详情 * * @param orderId * @return */ @Override public AjaxResult getOrderInfoById(Integer orderId) { BizUser bizUser = redisUserLoginUtils.getLoginUser(BizUser.class); ShopOrder shopOrder = shopOrderDao.selectOrderInfoById(bizUser.getOpenId(), orderId); return new AjaxResult(AjaxResult.STATUS_SUCCESS, Arrays.asList(shopOrder)); } /** * 取消待付款订单 * * @param orderId * @return */ @Transactional(rollbackFor = Exception.class) @Override public AjaxResult cancelOrderWhenWaitPay(Integer orderId) { updateStockAndVolumeById(orderId); ShopOrder shopOrder = shopOrderDao.selectById(orderId); //如果订单不是待付款状态 if (ShopOrder.ORDER_PAY_STATUS_WAIT != shopOrder.getOrderStatus()) { throw new GlobleException("该订单不是待付款状态！"); } if (shopOrder.getDiscountAmount() != null && shopOrder.getDiscountAmount().compareTo(BigDecimal.ZERO) > 0) { ShopCouponRecord shopCouponRecord = new ShopCouponRecord(); BizUser bizUser = redisUserLoginUtils.getLoginUser(BizUser.class); shopCouponRecord.setUserId(bizUser.getOpenId()); shopCouponRecord.setOrderId(orderId); List recordList = shopCouponRecordDao.selectByModel(shopCouponRecord); if (CollectionUtils.isNotEmpty(recordList)) { for (ShopCouponRecord record : recordList) { Map modifyMap = new HashMap<>(); modifyMap.put("id", record.getId()); modifyMap.put("orderId", 0); modifyMap.put("isUsing", AppConstance.MY_COUPON_NOT_USE); shopCouponRecordDao.updateByMap(modifyMap); } } } ShopActivitiesGroupJoinUser joinUser = shopActivitiesGroupJoinUserDao.selectGroupJoinUserByOrderId(orderId.longValue()); if (joinUser != null) { joinUser.setIsHasCancel(ShopActivitiesGroupJoinUser.IS_HAS_CANCEL_Y); shopActivitiesGroupJoinUserDao.updateByModel(joinUser); if (joinUser.getIsHead() == ShopActivitiesGroupJoinUser.USER_IS_HEAD_Y) { ShopActivitiesGroupJoin groupJoin = new ShopActivitiesGroupJoin(); groupJoin.setId(joinUser.getGjId()); groupJoin.setGjStatus(ShopActivitiesGroupJoin.ACTIVITIES_JOIN_FAIL); shopActivitiesGroupJoinDao.updateByModel(groupJoin); } } //构建需要修改订单信息Map Map modifyMap = new HashMap<>(); modifyMap.put("id", orderId); modifyMap.put("orderStatus", ShopOrder.ORDER_STATUS_CANCEL); shopOrderDao.updateByMap(modifyMap); return new AjaxResult(AjaxResult.STATUS_SUCCESS, "订单取消成功！"); } /** * 删除已取消订单 * * @param orderId * @return */ @Override public AjaxResult delOrderById(Integer orderId) { ShopOrder order = shopOrderDao.selectById(orderId); if (order == null) { throw new GlobleException("没有找到该订单！"); } if (!order.getOrderStatus().equals(ShopOrder.ORDER_STATUS_CANCEL)) { throw new GlobleException("该订单不是取消状态，不能删除！"); } //构建需要修改订单信息Map Map modifyMap = new HashMap<>(); modifyMap.put("id", order.getId()); modifyMap.put("delFlag", AppConstance.DATA_DISABLE); shopOrderDao.updateByMap(modifyMap); return new AjaxResult(AjaxResult.STATUS_SUCCESS, "删除成功！"); } /** * 订单确认收货 * * @param orderId * @return */ @Override public AjaxResult confirmPackageById(Integer orderId) { ShopOrder shopOrder = shopOrderDao.selectById(orderId); //如果不是待收货状态 if (ShopOrder.ORDER_STATUS_WAIT_RECEIVE != shopOrder.getOrderStatus()) { throw new GlobleException("该订单不是待收货状态！"); } shopOrder.setOrderStatus(ShopOrder.ORDER_STATUS_WAIT_REMARK); shopOrderDao.updateByModel(shopOrder); return new AjaxResult(AjaxResult.STATUS_SUCCESS, "订单收货成功！"); } /** * 加库存减销量 * * @param orderId * @return wlz */ @Override public AjaxResult updateStockAndVolumeById(Integer orderId) { //通过订单ID查询订单详情 List shopOrderDetails = shopOrderDetailsDao.selectByOrderId(orderId); if (CollectionUtils.isNotEmpty(shopOrderDetails)) { for (ShopOrderDetails orderDetails : shopOrderDetails) { Integer count = orderDetails.getCount(); Integer pId = orderDetails.getpId(); Integer sId = orderDetails.getsId(); ShopProduct shopProduct = shopProductDao.selectById(pId); //获取此产品的总展示销量和真实销量 Integer dsVolume = shopProduct.getDsVolume(); Integer rsVolume = shopProduct.getRsVolume(); //退货减销量 Integer updateDs = dsVolume - count; Integer updateRs = rsVolume - count; Map modifyMap = new HashMap<>(); modifyMap.put("id", pId); modifyMap.put("dsVolume", updateDs); modifyMap.put("rsVolume", updateRs); shopProductDao.updateByMap(modifyMap); //加库存 ShopSku shopSku = shopSkuDao.selectById(sId); Integer stock = shopSku.getStock(); Integer updateStock = stock + count; Map modifyStock = new HashMap<>(); modifyStock.put("id", sId); modifyStock.put("stock", updateStock); shopSkuDao.updateByMap(modifyStock); } } return new AjaxResult(AjaxResult.STATUS_SUCCESS, "加库存减销量修改成功！"); } /** * 查询订单支付状态 * * @param orderId * @return */ @Autowired RabiitMqTemplate rabiitMqTemplate; @Override public AjaxResult findOrderPayStatus(Integer orderId) { AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, ""); result.putInMap("status", "err"); result.putInMap("msg", "查询支付信息失败，请联系客服或者刷新支付信息（错误码:005）"); ShopOrder order = shopOrderDao.selectById(orderId); if (order.getPayStatus().equals(ShopOrder.ORDER_PAY_STATUS_SUCCESS)) { result.putInMap("status", "success"); result.putInMap("msg", "支付成功"); } else if (order.getPayStatus().equals(ShopOrder.ORDER_PAY_STATUS_FAIL)) { result.putInMap("status", "err"); result.putInMap("msg", "查询支付信息失败，请联系客服或者刷新支付信息"); } else { LogUtil.debug("订单等待支付中={}。。。", orderId); PayThreadPool.waitThread(orderId, new Object()); result = PayThreadPool.getThreadResult(orderId); LogUtil.debug("订单支付完成={}。。。", orderId); } ShopActivitiesGroupJoin groupBuyStatus = shopActivitiesGroupJoinDao.selectGroupBuyByOrderId(orderId); if (groupBuyStatus != null) { result.putInMap("groupBuyStatus", groupBuyStatus.getGjStatus()); result.putInMap("gjId", groupBuyStatus.getId()); } return result; } }