| | |
| | | private ComBatteryTradeOrderService tradeOrderService; |
| | | @Value("${min.app.isTest}") |
| | | private Boolean isTest; |
| | | @Value("${min.app.isRefundTest}") |
| | | private Boolean isRefundTest; |
| | | @Value("${min.app.appid}") |
| | | private String appid; |
| | | @Value("${min.app.payKey}") |
| | | private String payKey; |
| | | @Value("${min.app.mchId}") |
| | | private String mchId; |
| | | @Value("${min.app.currencyNotifyUrl}") |
| | | private String currencyNotifyUrl; |
| | | // @Value("${min.app.currencyNotifyUrl}") |
| | | // private String currencyNotifyUrl; |
| | | @Resource |
| | | private ComBatteryCommodityOrderCollageTeamMapper orderCollageTeamMapper; |
| | | @Resource |
| | |
| | | return R.fail("未查询到用户收货地址"); |
| | | } |
| | | //查询用户信息 |
| | | SysUser user = userMapper.selectById(createOrderDto.getUserId()); |
| | | SysUser user = userMapper.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getUserId,createOrderDto.getUserId())); |
| | | if (user == null) { |
| | | return R.fail("未查询到用户信息"); |
| | | } |
| | |
| | | money = BigDecimal.valueOf(0.01); |
| | | } |
| | | // 调用wx支付 |
| | | result = WxPayUtils.getUnifiedorder(appid, mchId, payKey, currencyNotifyUrl + PayCpmstant.BATTERY_STORE_PAY_NOTIFY_URL |
| | | , remark, openId, orderNo, money,null); |
| | | // result = WxPayUtils.getUnifiedorder(appid, mchId, payKey, currencyNotifyUrl + PayCpmstant.BATTERY_STORE_PAY_NOTIFY_URL |
| | | // , remark, openId, orderNo, money,null); |
| | | log.info("用户购买商品微信支付返回参数:" + result); |
| | | return result; |
| | | } |
| | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public R syncCloseOrder() { |
| | | log.info("定时器定时关闭超过30分钟未支付订单,并返回商品库存"); |
| | | log.info("定时器定时关闭超过5分钟未支付订单,并返回商品库存"); |
| | | Date nowDate = new Date(); |
| | | //获取当前时间减30分钟时间 |
| | | Date oldDate = DateUtils.addMinutes(nowDate, -5); |
| | |
| | | return R.fail("该商品库存不足,无法下单"); |
| | | } |
| | | //查询用户信息 |
| | | SysUser user = userMapper.selectById(orderDto.getUserId()); |
| | | SysUser user = userMapper.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getUserId,orderDto.getUserId())); |
| | | if(user == null){ |
| | | return R.fail("未查询到用户信息"); |
| | | } |