parent
28e5a386ba
commit
a0f8008517
File diff suppressed because one or more lines are too long
@ -0,0 +1,333 @@ |
|||||||
|
package com.web.controller.notify; |
||||||
|
|
||||||
|
import com.alibaba.fastjson.JSONObject; |
||||||
|
import com.hai.config.WxMsgConfig; |
||||||
|
import com.hai.entity.*; |
||||||
|
import com.hai.enum_type.OrderStatusEnum; |
||||||
|
import com.hai.enum_type.RechargePayType; |
||||||
|
import com.hai.order.service.OrderService; |
||||||
|
import com.hai.order.type.OrderChildStatus; |
||||||
|
import com.hai.service.*; |
||||||
|
import com.hai.service.impl.OutRechargeOrderServiceImpl; |
||||||
|
import io.swagger.annotations.Api; |
||||||
|
import io.swagger.annotations.ApiOperation; |
||||||
|
import org.slf4j.Logger; |
||||||
|
import org.slf4j.LoggerFactory; |
||||||
|
import org.springframework.stereotype.Controller; |
||||||
|
import org.springframework.web.bind.annotation.*; |
||||||
|
|
||||||
|
import javax.annotation.Resource; |
||||||
|
import javax.servlet.http.HttpServletRequest; |
||||||
|
import javax.servlet.http.HttpServletResponse; |
||||||
|
import java.io.PrintWriter; |
||||||
|
import java.util.Date; |
||||||
|
import java.util.HashMap; |
||||||
|
import java.util.Map; |
||||||
|
import java.util.Objects; |
||||||
|
|
||||||
|
@Controller |
||||||
|
@RequestMapping(value = "/mobileRechargeNotify") |
||||||
|
@Api(value = "通知") |
||||||
|
public class MobileRechargeNotifyController { |
||||||
|
|
||||||
|
private static Logger log = LoggerFactory.getLogger(OutRechargeOrderServiceImpl.class); |
||||||
|
|
||||||
|
@Resource |
||||||
|
private OutRechargeOrderService outRechargeOrderService; |
||||||
|
|
||||||
|
@Resource |
||||||
|
private OutRechargeChildOrderService outRechargeChildOrderService; |
||||||
|
|
||||||
|
@Resource |
||||||
|
private HighUserService highUserService; |
||||||
|
|
||||||
|
@Resource |
||||||
|
private ApiOrderRecordService apiOrderRecordService; |
||||||
|
|
||||||
|
@Resource |
||||||
|
private HighOrderService highOrderService; |
||||||
|
|
||||||
|
@Resource |
||||||
|
private OrderService orderService; |
||||||
|
|
||||||
|
@RequestMapping(value = "/rechargeCallbackByJj", method = RequestMethod.POST) |
||||||
|
@ApiOperation(value = "尖椒充值回调") |
||||||
|
@ResponseBody |
||||||
|
public void rechargeCallbackByJj(@RequestBody String reqBodyStr, HttpServletRequest request, HttpServletResponse response) { |
||||||
|
try { |
||||||
|
|
||||||
|
JSONObject dataObject = JSONObject.parseObject(reqBodyStr, JSONObject.class); |
||||||
|
|
||||||
|
log.info("============回调任务Start============="); |
||||||
|
log.info("尖椒订单充值-回调参数: " + dataObject); |
||||||
|
log.info("============回调任务End============="); |
||||||
|
|
||||||
|
// 1 尖椒 2 龙阅
|
||||||
|
dataObject.put("orderNo" , dataObject.getString("out_order_id")); |
||||||
|
|
||||||
|
// 查询充值记录订单
|
||||||
|
OutRechargeChildOrder childOrder = outRechargeChildOrderService.findByOrderNo(dataObject.getString("out_order_id")); |
||||||
|
|
||||||
|
// 查询充值订单
|
||||||
|
OutRechargeOrder rechargeOrder = outRechargeOrderService.findByOrderId(childOrder.getParentOrderId()); |
||||||
|
|
||||||
|
// 判断是否充值成功 并发送微信小程序服务通知
|
||||||
|
if (dataObject.getInteger("status") == 3) { |
||||||
|
if (rechargeOrder.getRechargeStatus() ==201) { |
||||||
|
new Thread(() -> { |
||||||
|
HighUser highUser = highUserService.findByUserId(rechargeOrder.getUserId()); |
||||||
|
WxMsgConfig.rechargedSuccess( |
||||||
|
rechargeOrder.getRechargeContent() + "充值成功", |
||||||
|
String.valueOf(rechargeOrder.getPayRealPrice()), |
||||||
|
rechargeOrder.getOrderNo(), |
||||||
|
rechargeOrder.getFinishTime(), |
||||||
|
RechargePayType.getNameByType(rechargeOrder.getPayType()), |
||||||
|
highUser.getOpenId()); |
||||||
|
}).start(); |
||||||
|
} |
||||||
|
|
||||||
|
childOrder.setStatus(101); |
||||||
|
rechargeOrder.setRechargeStatus(202); |
||||||
|
rechargeOrder.setPayStatus(100); |
||||||
|
|
||||||
|
outRechargeOrderService.updateOrder(rechargeOrder); |
||||||
|
outRechargeChildOrderService.updateOrder(childOrder); |
||||||
|
orderFinish(rechargeOrder); |
||||||
|
|
||||||
|
// api商户订单
|
||||||
|
if (rechargeOrder.getPayType() == 6) { |
||||||
|
apiOrderRecord(rechargeOrder); |
||||||
|
} |
||||||
|
|
||||||
|
} else { |
||||||
|
// 充值失败操作
|
||||||
|
callbackResult(childOrder , rechargeOrder); |
||||||
|
} |
||||||
|
|
||||||
|
response.setCharacterEncoding("UTF-8"); |
||||||
|
response.setContentType("text/html;charset=utf-8"); |
||||||
|
PrintWriter writer= response.getWriter(); |
||||||
|
writer.write("SUCCESS"); |
||||||
|
|
||||||
|
|
||||||
|
} catch (Exception e) { |
||||||
|
log.error("WechatPayController --> wechatNotify() error!", e); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
|
||||||
|
@RequestMapping(value = "/rechargeCallbackByLy", method = RequestMethod.POST) |
||||||
|
@ApiOperation(value = "龙阅充值回调") |
||||||
|
@ResponseBody |
||||||
|
public void rechargeCallbackByLy( |
||||||
|
@RequestParam(name = "out_trade_num", required = true) String out_trade_num, |
||||||
|
@RequestParam(name = "userid", required = true) Long userid, |
||||||
|
@RequestParam(name = "state", required = true) Long state, |
||||||
|
@RequestBody String reqBodyStr , |
||||||
|
HttpServletRequest request, HttpServletResponse response) { |
||||||
|
try { |
||||||
|
|
||||||
|
log.info("============回调任务Start============="); |
||||||
|
log.info("龙阅订单充值-回调参数: " + reqBodyStr); |
||||||
|
log.info("============回调任务End============="); |
||||||
|
|
||||||
|
OutRechargeChildOrder childOrder = outRechargeChildOrderService.findByOrderNo(out_trade_num); |
||||||
|
|
||||||
|
OutRechargeOrder rechargeOrder = outRechargeOrderService.findByOrderId(childOrder.getParentOrderId()); |
||||||
|
|
||||||
|
// 判断是否充值成功 并发送微信小程序服务通知
|
||||||
|
if (state == 1) { |
||||||
|
if (rechargeOrder.getRechargeStatus() ==201) { |
||||||
|
new Thread(() -> { |
||||||
|
HighUser highUser = highUserService.findByUserId(rechargeOrder.getUserId()); |
||||||
|
WxMsgConfig.rechargedSuccess( |
||||||
|
rechargeOrder.getRechargeContent() + "充值成功", |
||||||
|
String.valueOf(rechargeOrder.getPayRealPrice()), |
||||||
|
rechargeOrder.getOrderNo(), |
||||||
|
rechargeOrder.getFinishTime(), |
||||||
|
RechargePayType.getNameByType(rechargeOrder.getPayType()), |
||||||
|
highUser.getOpenId()); |
||||||
|
}).start(); |
||||||
|
} |
||||||
|
childOrder.setStatus(101); |
||||||
|
rechargeOrder.setRechargeStatus(202); |
||||||
|
rechargeOrder.setPayStatus(100); |
||||||
|
rechargeOrder.setFinishTime(new Date()); |
||||||
|
|
||||||
|
outRechargeOrderService.updateOrder(rechargeOrder); |
||||||
|
outRechargeChildOrderService.updateOrder(childOrder); |
||||||
|
orderFinish(rechargeOrder); |
||||||
|
if (rechargeOrder.getPayType() == 6) { |
||||||
|
apiOrderRecord(rechargeOrder); |
||||||
|
} |
||||||
|
} else { |
||||||
|
callbackResult(childOrder , rechargeOrder); |
||||||
|
} |
||||||
|
|
||||||
|
response.setCharacterEncoding("UTF-8"); |
||||||
|
response.setContentType("text/html;charset=utf-8"); |
||||||
|
PrintWriter writer= response.getWriter(); |
||||||
|
writer.write("SUCCESS"); |
||||||
|
|
||||||
|
|
||||||
|
} catch (Exception e) { |
||||||
|
log.error("WechatPayController --> wechatNotify() error!", e); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
@RequestMapping(value = "/rechargeCallbackByHg", method = RequestMethod.POST) |
||||||
|
@ApiOperation(value = "嗨购充值回调") |
||||||
|
@ResponseBody |
||||||
|
public void rechargeCallbackByHg( |
||||||
|
@RequestParam(name = "mchid", required = false) String mchid, |
||||||
|
@RequestParam(name = "out_order_id", required = false) String out_order_id, |
||||||
|
@RequestParam(name = "orderid", required = true) String orderid, |
||||||
|
@RequestParam(name = "return_time", required = false) String return_time, |
||||||
|
@RequestParam(name = "return_price", required = false) String return_price, |
||||||
|
@RequestParam(name = "recharge_price", required = false) String recharge_price, |
||||||
|
@RequestParam(name = "price", required = false) String price, |
||||||
|
@RequestParam(name = "status", required = true) String status, |
||||||
|
@RequestParam(name = "phone", required = false) String phone, |
||||||
|
@RequestParam(name = "secret_key", required = false) String secret_key, |
||||||
|
HttpServletResponse response) { |
||||||
|
try { |
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
JSONObject dataObject = new JSONObject(); |
||||||
|
|
||||||
|
dataObject.put("mchid" , mchid); |
||||||
|
dataObject.put("out_order_id" , out_order_id); |
||||||
|
dataObject.put("orderid" , orderid); |
||||||
|
dataObject.put("return_time" , return_time); |
||||||
|
dataObject.put("return_price" , mchid); |
||||||
|
dataObject.put("recharge_price" , recharge_price); |
||||||
|
dataObject.put("price" , price); |
||||||
|
dataObject.put("status" , status); |
||||||
|
dataObject.put("phone" , phone); |
||||||
|
dataObject.put("secret_key" , secret_key); |
||||||
|
|
||||||
|
log.info("============回调任务Start============="); |
||||||
|
log.info("嗨购订单充值-回调参数: " + dataObject); |
||||||
|
log.info("============回调任务End============="); |
||||||
|
|
||||||
|
// 1 尖椒 2 龙阅
|
||||||
|
|
||||||
|
// 查询充值记录订单
|
||||||
|
OutRechargeChildOrder childOrder = outRechargeChildOrderService.findByOrderNo(orderid); |
||||||
|
|
||||||
|
// 查询充值订单
|
||||||
|
OutRechargeOrder rechargeOrder = outRechargeOrderService.findByOrderId(childOrder.getParentOrderId()); |
||||||
|
|
||||||
|
// 判断是否充值成功 并发送微信小程序服务通知
|
||||||
|
if (Objects.equals(status, "1")) { |
||||||
|
if (rechargeOrder.getRechargeStatus() ==201) { |
||||||
|
new Thread(() -> { |
||||||
|
HighUser highUser = highUserService.findByUserId(rechargeOrder.getUserId()); |
||||||
|
WxMsgConfig.rechargedSuccess( |
||||||
|
rechargeOrder.getRechargeContent() + "充值成功", |
||||||
|
String.valueOf(rechargeOrder.getPayRealPrice()), |
||||||
|
rechargeOrder.getOrderNo(), |
||||||
|
rechargeOrder.getFinishTime(), |
||||||
|
RechargePayType.getNameByType(rechargeOrder.getPayType()), |
||||||
|
highUser.getOpenId()); |
||||||
|
}).start(); |
||||||
|
} |
||||||
|
|
||||||
|
childOrder.setStatus(101); |
||||||
|
rechargeOrder.setRechargeStatus(202); |
||||||
|
rechargeOrder.setPayStatus(100); |
||||||
|
|
||||||
|
outRechargeOrderService.updateOrder(rechargeOrder); |
||||||
|
outRechargeChildOrderService.updateOrder(childOrder); |
||||||
|
orderFinish(rechargeOrder); |
||||||
|
|
||||||
|
// api商户订单
|
||||||
|
if (rechargeOrder.getPayType() == 6) { |
||||||
|
apiOrderRecord(rechargeOrder); |
||||||
|
} |
||||||
|
|
||||||
|
} else { |
||||||
|
// 充值失败操作
|
||||||
|
callbackResult(childOrder , rechargeOrder); |
||||||
|
} |
||||||
|
|
||||||
|
response.setCharacterEncoding("UTF-8"); |
||||||
|
response.setContentType("text/html;charset=utf-8"); |
||||||
|
PrintWriter writer= response.getWriter(); |
||||||
|
writer.write("SUCCESS"); |
||||||
|
|
||||||
|
|
||||||
|
} catch (Exception e) { |
||||||
|
log.error("WechatPayController --> wechatNotify() error!", e); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
|
||||||
|
// 充值回调结果处理
|
||||||
|
private void callbackResult(OutRechargeChildOrder childOrder , OutRechargeOrder rechargeOrder) throws Exception { |
||||||
|
|
||||||
|
// 101:充值成功 102: 充值中 103：充值失败 104 未充值
|
||||||
|
// 订单支付状态 ： 101.待支付 102.已支付 100.已完成 104.已取消 105.已退款
|
||||||
|
if (childOrder.getStatus() == 102 && rechargeOrder.getPayStatus() == 102) { |
||||||
|
|
||||||
|
Date rechargeTime = rechargeOrder.getCreateTimed(); |
||||||
|
Date currentTime = new Date(); |
||||||
|
// 当前时间减去充值时间
|
||||||
|
int hours = (int) ((currentTime.getTime() - rechargeTime.getTime()) / (1000 * 60 * 60)); |
||||||
|
|
||||||
|
// // 判断快充 并且 充值时间小于6
|
||||||
|
// if (rechargeOrder.getRechargeType() == 1 && hours < 6) {
|
||||||
|
// outRechargeOrderService.pollRequest(rechargeOrder);
|
||||||
|
// return;
|
||||||
|
// }
|
||||||
|
// 判断慢充 并且 充值时间小于72
|
||||||
|
if (hours < 72) { |
||||||
|
outRechargeOrderService.pollRequest(rechargeOrder); |
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
outRechargeOrderService.refundOrder(rechargeOrder.getId() , childOrder); |
||||||
|
|
||||||
|
// 发送充值失败 微信小程序服务通知
|
||||||
|
new Thread(() -> { |
||||||
|
HighUser highUser = highUserService.findByUserId(rechargeOrder.getUserId()); |
||||||
|
WxMsgConfig.rechargedFail( |
||||||
|
rechargeOrder.getRechargeContent() + "充值失败", |
||||||
|
String.valueOf(rechargeOrder.getPayRealPrice()), |
||||||
|
highUser.getOpenId()); |
||||||
|
}).start(); |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
// 订单完成操作
|
||||||
|
private void orderFinish(OutRechargeOrder rechargeOrder) { |
||||||
|
HighOrder highOrder = highOrderService.getOrderByOrderNo(rechargeOrder.getOrderNo()); |
||||||
|
if (highOrder != null) { |
||||||
|
highOrder.setOrderStatus(OrderStatusEnum.type3.getType()); |
||||||
|
highOrder.setFinishTime(new Date()); |
||||||
|
for (HighChildOrder highChildOrder : highOrder.getHighChildOrderList()) { |
||||||
|
highChildOrder.setChildOrderStatus(OrderChildStatus.STATUS3.getNumber()); |
||||||
|
highChildOrder.setFinishTime(new Date()); |
||||||
|
} |
||||||
|
orderService.updateOrderData(highOrder); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
private void apiOrderRecord(OutRechargeOrder rechargeOrder) { |
||||||
|
Map<String, Object> orderMap = new HashMap<>(); |
||||||
|
orderMap.put("orderId" , rechargeOrder.getId()); |
||||||
|
|
||||||
|
// 查询是否用重复订单
|
||||||
|
ApiOrderRecord apiOrderRecord = apiOrderRecordService.queryOrderResult(orderMap); |
||||||
|
|
||||||
|
apiOrderRecord.setStatus(100); |
||||||
|
apiOrderRecord.setRequestTime(new Date()); |
||||||
|
apiOrderRecordService.updateOrderRecord(apiOrderRecord); |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
Loading…
Reference in new issue