package com.nq.controller;
|
|
import com.nq.common.ServerResponse;
|
|
import com.nq.dao.UserRechargeMapper;
|
import com.nq.pay.PayUtil;
|
import com.nq.pojo.UserRecharge;
|
import com.nq.service.IPayService;
|
|
import java.io.IOException;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import javax.servlet.http.HttpServletResponse;
|
|
import com.nq.service.IUserRechargeService;
|
import com.nq.service.IUserService;
|
import net.sf.json.JSONObject;
|
import org.apache.commons.collections.map.LinkedMap;
|
import org.apache.commons.lang3.StringUtils;
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Controller;
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
@Controller
|
@RequestMapping({"/api/pay/"})
|
public class PayApiController {
|
private static final Logger log = LoggerFactory.getLogger(PayApiController.class);
|
|
@Autowired
|
IPayService iPayService;
|
|
@Autowired
|
IUserService iUserService;
|
|
@Autowired
|
IUserRechargeService iUserRechargeService;
|
|
@Autowired
|
UserRechargeMapper userRechargeMapper;
|
|
@RequestMapping({"juhe1Notify.do"})
|
@ResponseBody
|
public void juhe1Notify(HttpServletRequest request, HttpServletResponse response) throws IOException {
|
ServerResponse serverResponse = this.iPayService.juhe1Notify(request);
|
if (serverResponse.isSuccess()) {
|
response.getWriter().write("ok");
|
log.info("第一个支付渠道的通知 返回 ok 成功");
|
} else {
|
log.error("juhe1Notify error Msg = {}", serverResponse.getMsg());
|
}
|
}
|
|
@RequestMapping({"juhenewpayNotify.do"})
|
@ResponseBody
|
public JSONObject juhenewpayNotify(HttpServletRequest request, HttpServletResponse response) throws IOException {
|
System.out.println("============开始回调===============");
|
LinkedMap map = new LinkedMap();
|
String orderno = (String) request.getParameter("orderno");
|
String amount = (String) request.getParameter("payamount");
|
String[] arr = orderno.split("_");
|
map.put("payamount", request.getParameter("payamount"));
|
map.put("orderno", orderno);
|
map.put("status", (String) request.getParameter("status"));
|
log.info("回调创建订单前map==="+map.toString());
|
|
JSONObject jsonObj = new JSONObject();
|
Map<String,Object> json = new HashMap<String,Object>();
|
|
|
if ("1".equals((String) request.getParameter("status"))) {
|
// 这里编写用户业务逻辑代码，如存储订单状态，自动发货等
|
//TODO
|
if (amount != null & !StringUtils.isEmpty(amount)) {
|
System.out.println("============更新用户金额===============");
|
Double aDouble = Double.valueOf(amount);
|
Integer integer = aDouble.intValue();
|
//判断是否回调成功
|
UserRecharge userRecharge = this.userRechargeMapper.findUserRechargeByOrderSn(orderno);
|
if(userRecharge == null){
|
System.out.println("============ 充值完成===============");
|
iUserRechargeService.createOrder(Integer.valueOf(arr[0]), 1, aDouble.intValue(), orderno);
|
jsonObj.put("reason", "success");
|
} else {
|
System.out.println("============充值失败，已回调成功无需重复回调===============");
|
jsonObj.put("reason", "error");
|
}
|
} else{
|
jsonObj.put("reason", "error");
|
}
|
System.out.println("============回调成功并结束===============");
|
//jsonObj.putAll(map);
|
return jsonObj;
|
} else {
|
System.out.println("============回调失败并结束===============");
|
jsonObj.put("reason", "error");
|
return jsonObj;
|
}
|
|
}
|
|
@RequestMapping({"juheh5payNotify.do"})
|
@ResponseBody
|
public void juheh5payNotify(HttpServletRequest request, HttpServletResponse response) throws IOException {
|
System.out.println("============开始回调===============");
|
LinkedMap map = new LinkedMap();
|
String orderno = (String) request.getParameter("name");
|
String amount = (String) request.getParameter("money");
|
String[] arr = orderno.split("_");
|
map.put("money", request.getParameter("money"));
|
map.put("name", orderno);
|
log.info("回调创建订单前map==="+map.toString());
|
|
JSONObject jsonObj = new JSONObject();
|
Map<String,Object> json = new HashMap<String,Object>();
|
|
|
//if ("200".equals((String) request.getParameter("status"))) {
|
// 这里编写用户业务逻辑代码，如存储订单状态，自动发货等
|
//TODO
|
if (amount != null & !StringUtils.isEmpty(amount)) {
|
System.out.println("============更新用户金额===============");
|
Double aDouble = Double.valueOf(amount);
|
Integer integer = aDouble.intValue();
|
//判断是否回调成功
|
UserRecharge userRecharge = this.userRechargeMapper.findUserRechargeByOrderSn(orderno);
|
if(userRecharge == null){
|
System.out.println("============充值完成===============");
|
iUserRechargeService.createOrder(Integer.valueOf(arr[0]), 1, aDouble.intValue(), orderno);
|
} else {
|
System.out.println("============充值失败，已回调成功无需重复回调===============");
|
}
|
} else{
|
}
|
System.out.println("============回调成功并结束===============");
|
//jsonObj.putAll(map);
|
response.getWriter().write("success");
|
/*} else {
|
System.out.println("============回调失败并结束===============");
|
response.getWriter().write("error");
|
}*/
|
|
}
|
|
@RequestMapping({"flyNotify.do"})
|
@ResponseBody
|
public void flyNotify(HttpServletRequest request, HttpServletResponse response) throws IOException {
|
ServerResponse serverResponse = this.iPayService.flyNotify(request);
|
if (serverResponse.isSuccess()) {
|
response.getWriter().write("success");
|
}
|
}
|
|
|
@RequestMapping({"flyNotify2.do"})
|
@ResponseBody
|
public void flyNotify2(HttpServletRequest request, HttpServletResponse response) throws IOException {
|
ServerResponse serverResponse = this.iPayService.flyNotify(request, PayUtil.DOWN_TOKEN_TPO2);
|
if (serverResponse.isSuccess()) {
|
response.getWriter().write("success");
|
}
|
}
|
|
@RequestMapping({"flyNotify3.do"})
|
@ResponseBody
|
public void flyNotify3(HttpServletRequest request, HttpServletResponse response) throws IOException {
|
ServerResponse serverResponse = this.iPayService.flyNotify(request, PayUtil.DOWN_TOKEN_TPO3);
|
if (serverResponse.isSuccess()) {
|
response.getWriter().write("success");
|
}
|
}
|
|
|
|
@RequestMapping({"withdrawNotify.do"})
|
@ResponseBody
|
public void withdrawNotify(HttpServletRequest request, HttpServletResponse response) throws IOException {
|
ServerResponse serverResponse = this.iPayService.withdrawNotify(request,PayUtil.DF_TOKEN_TOP1);
|
if (serverResponse.isSuccess()) {
|
response.getWriter().write("{\"reason\":\"success\"}");
|
log.info("fly 支付渠道的通知 返回 success 成功");
|
} else {
|
log.error("fly notify error Msg = {}", serverResponse.getMsg());
|
}
|
}
|
|
@RequestMapping({"withdrawNotify2.do"})
|
@ResponseBody
|
public void withdrawNotify2(HttpServletRequest request, HttpServletResponse response) throws IOException {
|
ServerResponse serverResponse = this.iPayService.withdrawNotify(request,PayUtil.DF_TOKEN_TOP2);
|
if (serverResponse.isSuccess()) {
|
response.getWriter().write("{\"reason\":\"success\"}");
|
log.info("fly 支付渠道的通知 返回 success 成功");
|
} else {
|
log.error("fly notify error Msg = {}", serverResponse.getMsg());
|
}
|
}
|
|
@RequestMapping({"withdrawNotify3.do"})
|
@ResponseBody
|
public void withdrawNotify3(HttpServletRequest request, HttpServletResponse response) throws IOException {
|
ServerResponse serverResponse = this.iPayService.withdrawNotify(request,PayUtil.DF_TOKEN_TOP3);
|
if (serverResponse.isSuccess()) {
|
response.getWriter().write("{\"reason\":\"success\"}");
|
log.info("fly 支付渠道的通知 返回 success 成功");
|
} else {
|
log.error("fly notify error Msg = {}", serverResponse.getMsg());
|
}
|
}
|
|
@RequestMapping({"withdrawNotify4.do"})
|
@ResponseBody
|
public void withdrawNotify4(HttpServletRequest request, HttpServletResponse response) throws IOException {
|
ServerResponse serverResponse = this.iPayService.withdrawNotify(request,PayUtil.DF_TOKEN_TOP4);
|
if (serverResponse.isSuccess()) {
|
response.getWriter().write("{\"reason\":\"success\"}");
|
log.info("fly 支付渠道的通知 返回 success 成功");
|
} else {
|
log.error("fly notify error Msg = {}", serverResponse.getMsg());
|
}
|
}
|
}
|
