package com.matrix.system.shopXcx.api.action; import com.matrix.component.rabbitmq.RabiitMqTemplate; import com.matrix.component.redis.RedisUserLoginUtils; import com.matrix.component.wechat.externalInterface.protocol.paramProtocol.BrandWCPayRequestData; import com.matrix.config.RabbitMqConfig; import com.matrix.core.constance.SystemErrorCode; import com.matrix.core.exception.GlobleException; import com.matrix.core.pojo.AjaxResult; import com.matrix.core.tools.LogUtil; import com.matrix.system.common.constance.AppConstance; import com.matrix.system.hive.bean.MoneyCardUse; import com.matrix.system.hive.bean.MoneyCardUseFlow; import com.matrix.system.hive.bean.SysVipInfo; import com.matrix.system.hive.dao.MoneyCardUseDao; import com.matrix.system.hive.dao.MoneyCardUseFlowDao; import com.matrix.system.hive.dao.ShoppingGoodsDao; import com.matrix.system.hive.dao.SysVipInfoDao; import com.matrix.system.score.dao.ScoreVipDetailDao; import com.matrix.system.shopXcx.api.pojo.OrderInfoQueryPOJO; import com.matrix.system.shopXcx.api.pojo.ShopOrderDto; import com.matrix.system.shopXcx.api.service.OrderCouponGroupService; 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.bean.ShopActivitiesGroupJoin; import com.matrix.system.shopXcx.bean.ShopActivitiesGroupJoinUser; import com.matrix.system.shopXcx.bean.ShopOrder; import com.matrix.system.shopXcx.bean.ShopPayLog; import com.matrix.system.shopXcx.dao.*; import com.matrix.system.shopXcx.mqTask.MQTaskRouting; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Controller; import org.springframework.transaction.annotation.Transactional; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import java.math.BigDecimal; import java.util.*; /** * @author jyy * @description 订单控制器 * @date 2019-06-10 10:58 */ @Controller @RequestMapping(value = "wxapi/shopOrder") public class WXShopOrderAction { @Autowired private WXShopOrderService shopOrderService; @Autowired WxShopCouponService wxShopCouponService; @Autowired ShoppingCartService shoppingCartService; @Autowired private RedisUserLoginUtils redisUserLoginUtils; @Autowired ShopCouponRecordDao shopCouponRecordDao; @Autowired ShopSkuDao shopSkuDao; @Autowired ShopProductDao shopProductDao; @Autowired OrderCouponGroupService orderCouponGroupService; @Autowired private ShopPayLogDao shopPayLogDao; @Autowired ShopOrderDao shopOrderDao; @Autowired SysVipInfoDao sysVipInfoDao; @Autowired private ShopActivitiesGroupJoinUserDao shopActivitiesGroupJoinUserDao; @Autowired private ShopActivitiesGroupJoinDao shopActivitiesGroupJoinDao; @Autowired private RabiitMqTemplate rabiitMqTemplate; @Autowired ShoppingGoodsDao shoppingGoodsDao; @Autowired MoneyCardUseFlowDao moneyCardUseFlowDao; @Autowired MoneyCardUseDao moneyCardUseDao; @Value("${evn}") private String evn; /** * 计算购物车订单价格 * * @param shopOrderDto * @return * @throws Exception */ @PostMapping(value = "/calculationCartOrder") public @ResponseBody AjaxResult calculationCartOrder(@RequestBody ShopOrderDto shopOrderDto) throws Exception { return shopOrderService.buildDiscountExplain(shopOrderDto); } @Autowired private ScoreVipDetailDao scoreVipDetailDao; /** * 新增微信支付订单 * * @param shopOrderDto * @return */ @PostMapping(value = "/addShopOrder") public @ResponseBody AjaxResult addShopOrder(@RequestBody @Validated ShopOrderDto shopOrderDto) throws Exception { ShopOrder shopOrder = shopOrderService.createShopOrder(shopOrderDto); AjaxResult result = AjaxResult.buildSuccessInstance("订单创建成功"); result.putInMap("orderId", shopOrder.getId()); if (shopOrderDto.getPayMethod().equals(ShopOrder.SHOP_ORDER_PAY_METHOD_WX)) { BrandWCPayRequestData payData = shopOrderService.startPayment(shopOrder); result.setRows(Arrays.asList(payData)); } return result; } /** * 余额支付确认 * * @param orderId * @return * @throws Exception */ @GetMapping(value = "/moneyCardPay/{orderId}") @ResponseBody @Transactional public AjaxResult moneyCardPay(@PathVariable Integer orderId) throws Exception { ShopOrder order = shopOrderDao.selectById(orderId); if (order != null && ShopOrder.SHOP_ORDER_PAY_METHOD_VIPCARD == order.getPayMethod() && ShopOrder.ORDER_PAY_STATUS_WAIT == order.getPayStatus()) { MoneyCardUse moneyCardUse = moneyCardUseDao.selectVipCard(order.getUserId()); Double balance=moneyCardUse.getGiftMoney() + moneyCardUse.getRealMoney(); if(balance>=order.getOrderMoney().doubleValue()){ //扣减会员卡余额 if(moneyCardUse.getRealMoney()>=order.getOrderMoney().doubleValue()){ moneyCardUse.setRealMoney(moneyCardUse.getRealMoney()-order.getOrderMoney().doubleValue()); }else{ moneyCardUse.setGiftMoney(moneyCardUse.getGiftMoney()-(order.getOrderMoney().doubleValue()- moneyCardUse.getRealMoney() )); moneyCardUse.setRealMoney(0D); } moneyCardUseDao.update(moneyCardUse); //插入扣减记录 MoneyCardUseFlow moneyCardUseFlow=new MoneyCardUseFlow(); moneyCardUseFlow.setTotal(order.getOrderMoney().doubleValue()); moneyCardUseFlow.setCarUseId(moneyCardUse.getId()); moneyCardUseFlow.setVipId(order.getUserId()); moneyCardUseFlow.setType(MoneyCardUseFlow.USE_TYPE_CONSUMER); moneyCardUseFlow.setOrderNo(order.getOrderNo()); moneyCardUseFlow.setCreateTime(new Date()); moneyCardUseFlow.setBalance(moneyCardUse.getGiftMoney()+moneyCardUse.getRealMoney()); moneyCardUseFlow.setCardName(moneyCardUse.getCardName()); moneyCardUseFlowDao.insert(moneyCardUseFlow); //构建需要修改订单信息Map Map modifyMap = new HashMap<>(); modifyMap.put("id", order.getId()); //设置微信支付状态为已支付 modifyMap.put("payResult", ShopOrder.ORDER_WX_STATUS_PAY_SUCCESS); //设置支付状态为支付成功 modifyMap.put("payStatus", ShopOrder.ORDER_PAY_STATUS_SUCCESS); //如果是商品订单则进入待发货 modifyMap.put("orderStatus", ShopOrder.ORDER_STATUS_WAIT_SEND); shopOrderDao.updateByMap(modifyMap); // 判断该订单是否为拼团产生的订单 ShopActivitiesGroupJoinUser joinUser = shopActivitiesGroupJoinUserDao.selectGroupJoinUserByOrderId(order.getId().longValue()); if (joinUser != null) { joinUser.setIsHasPay(ShopActivitiesGroupJoinUser.IS_HAS_PAY_Y); shopActivitiesGroupJoinUserDao.updateByModel(joinUser); ShopActivitiesGroupJoin groupJoin = shopActivitiesGroupJoinDao.selectGroupAndPriceById(joinUser.getGjId()); List joinUserList = shopActivitiesGroupJoinUserDao.selectGroupJoinUserListByGjId(joinUser.getGjId()); LogUtil.info("#当前已支付完成:{}#", joinUserList.size()); // 若拼团中已支付的数量等于几人团预设值，则更新拼团状态为拼团成功 if (groupJoin.getGroupPrice().getGpCount() == joinUserList.size()) { groupJoin.setGjStatus(ShopActivitiesGroupJoin.ACTIVITIES_JOIN_SUCCESS); } else { if (joinUser.getUserId().equals(groupJoin.getGjHeadId())) { groupJoin.setGjStatus(ShopActivitiesGroupJoin.ACTIVITIES_JOIN_ING); } } shopActivitiesGroupJoinDao.updateByModel(groupJoin); SysVipInfo sysVipInfo = sysVipInfoDao.selectByPhone(order.getUserTel(),order.getCompanyId()); if (sysVipInfo != null) { sysVipInfo.setIsDeal(SysVipInfo.DEAL_VIP); sysVipInfoDao.update(sysVipInfo); } } // 根据订单类型创建不同的处理任务 rabiitMqTemplate.sendTopicMsg(RabbitMqConfig.MQ_EXCHANGE_TOPIC + evn, MQTaskRouting.CREATE_ORDER + evn, orderId + ""); //支付记录 recordPayLog(Integer.valueOf(orderId), 1, order.getOrderNo(), order.getOrderMoney(), "会员卡余额支付成功", ShopOrder.ORDER_PAY_STATUS_SUCCESS); return AjaxResult.buildSuccessInstance("支付成功"); }else{ return AjaxResult.buildFailInstance("会员卡余额不足"); } } else { LogUtil.info("订单状态不为待付款，order status=", order.getOrderStatus()); return AjaxResult.buildFailInstance("订单不支持本次结算"); } } private void recordPayLog(Integer orderId, Integer type, String orderNo, BigDecimal payMoney, String payRemark, int payStatus) { //设置支付类型为收款 ShopPayLog payLog = new ShopPayLog(); payLog.setPayType(type); payLog.setJoinId(orderId); payLog.setPayMoney(payMoney); payLog.setPayOrderNo(orderNo); payLog.setPayRemark(payRemark); payLog.setPayStatus(payStatus); payLog.setCreateBy(AppConstance.SYSTEM_USER); payLog.setUpdateBy(AppConstance.SYSTEM_USER); shopPayLogDao.insert(payLog); } /** * 订单结算 * * @param orderId 订单ID * @return */ @GetMapping(value = "orderSettlement/{orderId}") public @ResponseBody AjaxResult orderSettlement(@PathVariable("orderId") int orderId) { try { return shopOrderService.orderSettlement(orderId); } catch (Exception e) { throw new GlobleException(SystemErrorCode.DATA_ADD_FAIL); } } /** * 查询订单支付结果 * * @param orderId * @return * @throws InterruptedException * @author JIANGYOUYAO * @email 935090232@qq.com * @date 2018年9月8日 */ @GetMapping(value = "/findOrderPayStatus/{orderId}") public @ResponseBody AjaxResult findOrderPayStatus(@PathVariable Integer orderId) throws InterruptedException { AjaxResult ajaxResult = shopOrderService.findOrderPayStatus(orderId); return ajaxResult; } /** * 获取我的订单信息 * * @return */ @PostMapping(value = "getMyOrderInfo") @ResponseBody public AjaxResult getMyOrderInfo(@RequestBody OrderInfoQueryPOJO orderInfoQueryPOJO) { AjaxResult ajaxResult = shopOrderService.getMyOrderInfo(orderInfoQueryPOJO); return ajaxResult; } /** * 通过订单ID获取订单信息 * * @return */ @GetMapping(value = "getOrderInfoById/{orderId}") @ResponseBody public AjaxResult getOrderInfoById(@PathVariable Integer orderId) { AjaxResult ajaxResult = shopOrderService.getOrderInfoById(orderId); return ajaxResult; } /** * 取消订单 * * @param * @return */ @GetMapping(value = "cancelOrderWhenWaitPay/{orderId}") @ResponseBody public AjaxResult cancelOrderWhenWaitPay(@PathVariable("orderId") Integer orderId) { return shopOrderService.cancelOrderWhenWaitPay(orderId); } /** * 删除订单 * * @param * @return */ @GetMapping(value = "delOrder/{orderId}") @ResponseBody public AjaxResult delOrderById(@PathVariable("orderId") Integer orderId) { return shopOrderService.delOrderById(orderId); } /** * 确认收货 * * @param * @return */ @GetMapping(value = "confirmPackageById/{orderId}") @ResponseBody public AjaxResult confirmPackageById(@PathVariable("orderId") Integer orderId) { return shopOrderService.confirmPackageById(orderId); } @GetMapping(value = "/getOrderStatusCount") @ResponseBody public AjaxResult getOrderStatusCount() { SysVipInfo sysVipInfo = redisUserLoginUtils.getLoginUser(SysVipInfo.class); AjaxResult result = AjaxResult.buildSuccessInstance( shopOrderDao.selectOrderStatusCount(sysVipInfo.getId())); return result; } }