您的位置:首页 > 编程语言 > Java开发

Java之品优购课程讲义_day19(9)

2018-11-02 16:57 609 查看

前端代码
调用查询的方法,参见 pinyougou-cart-web 工程。
[AppleScript] 纯文本查看 复制代码
?
1
queryPayStatus(response.out_trade_no);//查询支付状态

订单超时处理
当用户下单后 5 分钟尚未付款应该释放订单,增加库存
5.4.1 删除缓存中的订单
(1)修改 pinyougou-seckill-interface 的 SeckillOrderService.java

/**
* 从缓存中删除订单
* @param userId
* @param orderId
*/
public void deleteOrderFromRedis(String userId,Long orderId);

(2)修改 pinyougou-seckill-service 的 SeckillOrderServiceImpl.java

@Override
public void deleteOrderFromRedis(String userId, Long orderId) {
//根据用户 ID 查询日志
TbSeckillOrder seckillOrder = (TbSeckillOrder)
redisTemplate.boundHashOps("seckillOrder").get(userId);
if(seckillOrder!=null &&
seckillOrder.getId().longValue()== orderId.longValue() ){
redisTemplate.boundHashOps("seckillOrder").delete(userId);//删除缓存中
的订单
//恢复库存
//1.从缓存中提取秒杀商品
TbSeckillGoods
seckillGoods=(TbSeckillGoods)redisTemplate.boundHashOps("seckillGoods").get(seckill
Order.getSeckillId());
if(seckillGoods!=null){
seckillGoods.setStockCount(seckillGoods.getStockCount()+1);
redisTemplate.boundHashOps("seckillGoods").put(seckillOrder
5b4
.getSeckillId(),
seckillGoods);//存入缓存
}
}
}

关闭微信订单
(1)修改 pinyougou-pay-interface 的 WeixinPayService 接口

/**
* 关闭支付
* @param out_trade_no
* @return
*/
public Map closePay(String out_trade_no);

(2)修改 pinyougou-pay-service 的 WeixinPayServiceImpl

@Override
public Map closePay(String out_trade_no) {
Map param=new HashMap();
param.put("appid", appid);//公众账号 ID
param.put("mch_id", partner);//商户号
param.put("out_trade_no", out_trade_no);//订单号
param.put("nonce_str", WXPayUtil.generateNonceStr());//随机字符串
String url="https://api.mch.weixin.qq.com/pay/closeorder";
try {
String xmlParam = WXPayUtil.generateSignedXml(param, partnerkey);
HttpClient client=new HttpClient(url);
client.setHttps(true);
client.setXmlParam(xmlParam);
client.post();
String result = client.getContent();
Map<String, String> map = WXPayUtil.xmlToMap(result);
System.out.println(map);
return map;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}

3 超时调用服务
修改 pinyougou-seckill-web 的 PayController.java

/**
* 查询支付状态
* @param out_trade_no
* @return
*/
@RequestMapping("/queryPayStatus")
public Result queryPayStatus(String out_trade_no){
//获取当前用户
String
userId=SecurityContextHolder.getContext().getAuthentication().getName();
Res
b60
ult result=null;
int x=0;
while(true){
........
try {
Thread.sleep(3000);//间隔三秒
} catch (InterruptedException e) {
e.printStackTrace();
}
//不让循环无休止地运行定义变量,如果超过了这个值则退出循环,设置时间为 1 分钟
x++;
if(x>20){
result=new  Result(false, "二维码超时");
//1.调用微信的关闭订单接口(学员实现)
Map<String,String> payresult =
weixinPayService.closePay(out_trade_no);
if( !"SUCCESS".equals(payresult.get("result_code")) ){//如果返回结果
是正常关闭
if("ORDERPAID".equals(payresult.get("err_code"))){
result=new Result(true, "支付成功");
seckillOrderService.saveOrderFromRedisToDb(userId,
Long.valueOf(out_trade_no), map.get("transaction_id"));
}
}
if(result.isSuccess()==false){
System.out.println("超时,取消订单");
//2.调用删除
seckillOrderService.deleteOrderFromRedis(userId,
Long.valueOf(out_trade_no));
}
break;
}
}
return result;
}

前端代码
pinyougou-seckill-web 的 payController.js

//查询支付状态
queryPayStatus=function(out_trade_no){
payService.queryPayStatus(out_trade_no).success(
function(response){
if(response.success){
location.href="paysuccess.html#?money="+$scope.money;
}else{
if(response.message=='二维码超时'){
location.href="payTimeOut.html";
}else{
location.href="payfail.html";
}
}
}
);
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  Java