Commit b791829c by 周晓航

上报数据处理

Signed-off-by: 周晓航 <xiaohang.zhou@freemud.com>
parent 40cc98bf
...@@ -60,7 +60,7 @@ public class WeChatLiveMsgHandle { ...@@ -60,7 +60,7 @@ public class WeChatLiveMsgHandle {
/** /**
* @param orderBean * @param orderBean
* @param flag 0 支付成功 * @param flag 1:支付成功,2:支付失败,3:用户取消,4:超时未支付;5:商家取消;10:其他原因取消
*/ */
public void reportOrderStatus(OrderBeanV1 orderBean, int flag) { public void reportOrderStatus(OrderBeanV1 orderBean, int flag) {
if (Objects.nonNull(orderBean) if (Objects.nonNull(orderBean)
...@@ -78,7 +78,7 @@ public class WeChatLiveMsgHandle { ...@@ -78,7 +78,7 @@ public class WeChatLiveMsgHandle {
// 需要拿到 openid // 需要拿到 openid
Object openid = jsonObject.get("openid"); Object openid = jsonObject.get("openid");
request.setOpenid(Objects.isNull(openid) ? "" : openid.toString()); request.setOpenid(Objects.isNull(openid) ? "" : openid.toString());
if (flag == 0) { if (flag == 1) {
// Object payTransId = jsonObject.get("payTransId"); // Object payTransId = jsonObject.get("payTransId");
// request.setTransaction_id(Objects.isNull(payTransId) ? "" : payTransId.toString()); // request.setTransaction_id(Objects.isNull(payTransId) ? "" : payTransId.toString());
...@@ -87,6 +87,7 @@ public class WeChatLiveMsgHandle { ...@@ -87,6 +87,7 @@ public class WeChatLiveMsgHandle {
Object payDate = jsonObject.get("payDate"); Object payDate = jsonObject.get("payDate");
request.setPay_time(Objects.isNull(payDate) ? "" : payDate.toString()); request.setPay_time(Objects.isNull(payDate) ? "" : payDate.toString());
} }
request.setAction_type(flag);
// 获取 session // 获取 session
String accessToken = this.getAccessToken(orderBean.getAppId(), orderBean.getParentCode()); String accessToken = this.getAccessToken(orderBean.getAppId(), orderBean.getParentCode());
......
...@@ -1806,7 +1806,7 @@ public class OrderServiceImpl implements Orderservice { ...@@ -1806,7 +1806,7 @@ public class OrderServiceImpl implements Orderservice {
// TODO: 2019/9/10 删除订单通知 // TODO: 2019/9/10 删除订单通知
orderQueueService.backOrdersStatusChange(orderBean.getOid(), orderBean.getStatus()); orderQueueService.backOrdersStatusChange(orderBean.getOid(), orderBean.getStatus());
weChatLiveMsgHandle.reportOrderStatus(orderBean,0); weChatLiveMsgHandle.reportOrderStatus(orderBean,3);
return ResponseUtil.success(); return ResponseUtil.success();
} }
......
...@@ -1028,7 +1028,7 @@ public class SellCouponOrderServiceImpl implements OrderFactoryService { ...@@ -1028,7 +1028,7 @@ public class SellCouponOrderServiceImpl implements OrderFactoryService {
// fisherman 直播卖券-> 需要额外上报 时间来不及 有时间 这一块需要移到 异步调用 // fisherman 直播卖券-> 需要额外上报 时间来不及 有时间 这一块需要移到 异步调用
try { try {
weChatLiveMsgHandle.reportOrderStatus(orderBean, 0); weChatLiveMsgHandle.reportOrderStatus(orderBean, 1);
}catch (Exception e){ }catch (Exception e){
// 不要影响主流程 // 不要影响主流程
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment