支付宝支付(网站支付,APP支付,扫码支付) Java服务端代码

布满荆棘的人生 2022-06-12 13:40 318阅读 0赞

# AlipayController #

import java.util.Calendar;
    import java.util.HashMap;
    import java.util.Map;
    import java.util.Set;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.ResponseBody;
    import com.alibaba.fastjson.JSON;
    import com.alibaba.fastjson.JSONArray;
    import com.alibaba.fastjson.JSONObject;
    import com.alipay.api.AlipayApiException;
    import com.alipay.api.AlipayClient;
    import com.alipay.api.domain.AlipayTradeAppPayModel;
    import com.alipay.api.internal.util.AlipaySignature;
    import com.alipay.api.request.AlipayTradeAppPayRequest;
    import com.alipay.api.request.AlipayTradePagePayRequest;
    import com.alipay.api.request.AlipayTradeWapPayRequest;
    import com.alipay.api.response.AlipayTradeAppPayResponse;
    import com.message.AlipayPayRequest;
    import com.redis.utils.RedisUtil;
    import com.utils.AlipayConfig;
    import com.utils.HttpClientUtils;
    
    @Controller
    @RequestMapping(value = "/alipay")
    public class AlipayController {
    
    	//公众号支付(网站支付)
    	@RequestMapping(value = "/wapPay", produces = "text/html;charset=UTF-8", method = RequestMethod.POST)
    	public void wapPay(AlipayPayRequest request, HttpServletResponse httpResponse) {
    		if (request.getUid() != 0 && request.getItemId() != null) {
    			int money = 0 ;//充值金额
    			String querywolfurl = AlipayConfig.diamond_url;//公众号充值钻石表
    			String string = HttpClientUtils.executePost(querywolfurl, null, "utf-8");//充值表,使用了一个自定义的post请求
    			JSONArray jsona = JSONArray.parseArray(string);
    			if (jsona.size() > 0) {
    				for (int i = 0; i < jsona.size(); i++) {
    					JSONObject job = jsona.getJSONObject(i);
    					if ((job.getString("recharge_price_id")).equals(request.getItemId())) {
    						money = Integer.parseInt(job.getString("amount").substring(0, job.getString("amount").indexOf(".")));
    						break;
    					}
    				}
    			}
    			long timeStart = Calendar.getInstance().getTimeInMillis();
    			String out_trade_no = request.getUid() + "_" + timeStart;// 订单号
    
    			AlipayClient alipayClient = AlipayConfig.getAlipayClient(); // 获得初始化的AlipayClient
    			AlipayTradeWapPayRequest alipayRequest = new AlipayTradeWapPayRequest();// 创建API对应的request
    			alipayRequest.setReturnUrl(AlipayConfig.return_url);// 付款成功后,页面重定向通知
    			alipayRequest.setNotifyUrl(AlipayConfig.notify_url);// 服务器通知
    
    			Map<String, Object> map = new HashMap<String, Object>();
    			map.put("out_trade_no", out_trade_no);// 订单号
    			map.put("total_amount", money);// 交易金额,单位:元
    			map.put("subject", request.getSubject());// 订单标题
    			map.put("product_code", "QUICK_WAP_PAY");// 销售产品码
    			map.put("timeout_express", "90m");// 该笔订单允许的最晚付款时间，逾期将关闭交易
    			alipayRequest.setBizContent(JSON.toJSONString(map));
    
    			try {
    				String form = alipayClient.pageExecute(alipayRequest).getBody(); // 调用SDK生成表单
    				System.err.println(form);
    				httpResponse.setContentType("text/html;charset=" + AlipayConfig.CHARSET);
    				httpResponse.getWriter().write(form);// 直接将完整的表单html输出到页面
    				httpResponse.getWriter().flush();
    				RedisUtil.setValueTime(out_trade_no, "1", 2 * 24 * 60 * 60);//创建订单保存2天有限期
    			} catch (Exception e) {
    				e.printStackTrace();
    			}
    		}
    	}
    	
    	// APP支付
    	@ResponseBody
    	@RequestMapping(value = "/appPay", method = RequestMethod.POST)
    	public String appPay(AlipayPayRequest request) {
    		if (request.getUid() != 0 && request.getItemId() != null) {
    			//app端的充值表放在redis中
    			JSONArray json = JSONArray.parseArray(RedisUtil.getByKey("RechargeMeter"));
    			String money = "" ;//充值金额
    			if (json.size() > 0) {
    				for (int i = 0; i < json.size(); i++) {
    					JSONObject job = json.getJSONObject(i);
    					if ((job.getString("itemId")).equals(request.getItemId())){
    						money = (String) job.get("money");
    						break;
    					}
    				}
    			}
    			if(money.equals("")){
    				//支付的商品id不存在,返回异常信息
    				return JSON.toJSONString("error");
    			}
    			long timeStart = Calendar.getInstance().getTimeInMillis();
    			String out_trade_no = request.getUid() + "_" + timeStart;// 订单号
    			// 实例化客户端
    			AlipayClient alipayClient = AlipayConfig.getAlipayClient(); // 获得初始化的AlipayClient
    			// 实例化具体API对应的request类,类名称和接口名称对应,当前调用接口名称：alipay.trade.app.pay
    			AlipayTradeAppPayRequest alipayRequest = new AlipayTradeAppPayRequest();
    			// SDK已经封装掉了公共参数，这里只需要传入业务参数。以下方法为sdk的model入参方式(model和biz_content同时存在的情况下取biz_content)。
    			AlipayTradeAppPayModel model = new AlipayTradeAppPayModel();
    			model.setSubject(request.getSubject());
    			model.setOutTradeNo(out_trade_no);
    			model.setTimeoutExpress("30m");
    			model.setTotalAmount(money);
    			model.setProductCode("QUICK_MSECURITY_PAY");
    			alipayRequest.setBizModel(model);
    			alipayRequest.setNotifyUrl(AlipayConfig.APPnotify);
    			try {
    				// 这里和普通的接口调用不同，使用的是sdkExecute
    				AlipayTradeAppPayResponse alipayResponse = alipayClient.sdkExecute(alipayRequest);
    				System.out.println(alipayResponse.getBody());// 就是orderString可以直接给客户端请求，无需再做处理。
    				RedisUtil.setValueTime(out_trade_no, "1", 2 * 24 * 60 * 60);//创建订单保存2天有限期
    				return alipayResponse.getBody();
    			} catch (AlipayApiException e) {
    				e.printStackTrace();
    			}
    		}
    		return null;
    	}
    
    	// 扫码支付
    	@ResponseBody
    	@RequestMapping(value = "/pagePay", produces = "text/html;charset=UTF-8", method = RequestMethod.POST)
    	public String pagePay(AlipayPayRequest request) {
    		if (request.getUid() != 0 && request.getItemId() != null) {
    			int money = 0 ;//充值金额
    			String querywolfurl = AlipayConfig.diamond_url;//公众号充值钻石表
    			String string = HttpClientUtils.executePost(querywolfurl, null, "utf-8");//充值表
    			JSONArray jsona = JSONArray.parseArray(string);
    			if (jsona.size() > 0) {
    				for (int i = 0; i < jsona.size(); i++) {
    					JSONObject job = jsona.getJSONObject(i);
    					if ((job.getString("recharge_price_id")).equals(request.getItemId())) {
    						money = Integer.parseInt(job.getString("amount").substring(0, job.getString("amount").indexOf(".")));
    						break;
    					}
    				}
    			}
    			long timeStart = Calendar.getInstance().getTimeInMillis();
    			String out_trade_no = request.getUid() + "_" + timeStart;// 订单号
    			AlipayClient alipayClient = AlipayConfig.getAlipayClient(); // 获得初始化的AlipayClient
    			AlipayTradePagePayRequest alipayRequest = new AlipayTradePagePayRequest();// 创建API对应的request
    			alipayRequest.setReturnUrl(AlipayConfig.OWreturn_url);// 回跳地址
    			alipayRequest.setNotifyUrl(AlipayConfig.OWnotify_url);// 通知地址
    			Map<String, Object> map = new HashMap<String, Object>();
    			map.put("out_trade_no", out_trade_no);// 订单号
    			map.put("product_code", "FAST_INSTANT_TRADE_PAY");// 销售产品码
    			map.put("total_amount", money);// 交易金额,单位:元
    			map.put("subject", "钻石");// 订单标题
    			alipayRequest.setBizContent(JSON.toJSONString(map));
    			try {
    				String form = alipayClient.pageExecute(alipayRequest).getBody(); // 调用SDK生成表单
    				System.out.println("---------支付宝扫码---------> " + form);// 就是orderString可以直接给客户端请求，无需再做处理。
    				RedisUtil.setValueTime(out_trade_no, "1", 2 * 24 * 60 * 60);//创建订单保存2天有限期
    				return form;
    				
    			} catch (AlipayApiException e) {
    				e.printStackTrace();
    			}
    		}
    		return null;
    	}
    	
    	// 公众号(网站)--支付成功后回调方法
    	@RequestMapping(value = "/notify", method = RequestMethod.POST)
    	public void notify(HttpServletRequest request, HttpServletResponse httpResponse) {
    		// 获取支付宝POST过来反馈信息
    		Map<String, String> params = new HashMap<String, String>();
    		Map<String, String[]> requestParams = request.getParameterMap();
    		Set<String> keySet = requestParams.keySet();
    		String out_trade_no = "";
    		String trade_status = "";
    		String total_amount = "";
    		for (String key : keySet) {
    			StringBuffer buffer = new StringBuffer();
    			for (String string : requestParams.get(key)) {
    				buffer.append(string);
    			}
    			params.put(key, buffer.toString());
    			if (key.equals("out_trade_no")) {
    				out_trade_no = buffer.toString();// 商户订单号
    				System.out.println(key + " : " + buffer.toString());
    			} else if (key.equals("trade_status")) {
    				trade_status = buffer.toString();// 交易状态
    				System.out.println(key + " : " + buffer.toString());
    			} else if (key.equals("total_amount")) {
    				total_amount = buffer.toString().substring(0,buffer.toString().length()-3) + "";// 充值金额
    				System.out.println(key + " : " + total_amount);
    			}
    		}
    		try {
    			// 计算得出通知验证结果
    			boolean verify_result = AlipaySignature.rsaCheckV1(params, AlipayConfig.ALIPAY_PUBLIC_KEY,
    					AlipayConfig.CHARSET, AlipayConfig.SIGNTYPE);
    			
    			if (verify_result) {// 验证成功
    				if (trade_status.equals("TRADE_SUCCESS")) { // 交易支付成功
    					boolean contains = RedisUtil.getAllkeys().contains(out_trade_no);
    					if((contains && !RedisUtil.getByKey(out_trade_no).equals("3")) || !contains){
    						RedisUtil.setValue(out_trade_no, "2");// 支付成功,未加钻石
    						
    						//获取订单信息,传到业务层,修改数据库
    						String uid = out_trade_no.substring(0, out_trade_no.indexOf("_"));
    						int diamond = 0;// 钻石
    						String querywolfurl = AlipayConfig.diamond_url;//公众号充值钻石表
    						String string = HttpClientUtils.executePost(querywolfurl, null, "utf-8");//充值表
    						JSONArray jsona = JSONArray.parseArray(string);
    						if (jsona.size() > 0) {
    							for (int i = 0; i < jsona.size(); i++) {
    								JSONObject job = jsona.getJSONObject(i);
    								if (job.getString("amount").substring(0, job.getString("amount").indexOf(".")).equals(total_amount)) {
    									diamond = Integer.parseInt(job.getString("jewel_amount"));// 钻石
    									break;
    								}
    							}
    						}
    						System.out.println("diamond : "+ diamond);
    						
    						//........
    						if(修改数据库失败){
    							System.out.println("增加钻石失败--网络异常");
    						}else{
    							RedisUtil.setValue(out_trade_no, "3");// 增加钻石成功
    							System.out.println("增加钻石成功");
    							httpResponse.getWriter().println("success");
    						}
    						
    					}
    				}
    			} else {// 验证失败
    				httpResponse.getWriter().println("fail");
    			}
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	
    	// APP--支付成功后回调方法
    	@RequestMapping(value = "/APPnotify", method = RequestMethod.POST)
    	public void APPnotify(HttpServletRequest request, HttpServletResponse httpResponse) {
    		// 获取支付宝POST过来反馈信息
    		Map<String, String> params = new HashMap<String, String>();
    		Map<String, String[]> requestParams = request.getParameterMap();
    		Set<String> keySet = requestParams.keySet();
    		String out_trade_no = "";
    		String trade_status = "";
    		String total_amount = "";
    		for (String key : keySet) {
    			StringBuffer buffer = new StringBuffer();
    			for (String string : requestParams.get(key)) {
    				buffer.append(string);
    			}
    			params.put(key, buffer.toString());
    			if (key.equals("out_trade_no")) {
    				out_trade_no = buffer.toString();// 商户订单号
    				System.out.println(key + " : " + buffer.toString());
    			} else if (key.equals("trade_status")) {
    				trade_status = buffer.toString();// 交易状态
    				System.out.println(key + " : " + buffer.toString());
    			} else if (key.equals("total_amount")) {
    				total_amount = buffer.toString().substring(0,buffer.toString().length()-3) + "";// 充值金额
    				System.out.println(key + " : " + total_amount);
    			}
    		}
    		try {
    			// 计算得出通知验证结果
    			boolean verify_result = AlipaySignature.rsaCheckV1(params, AlipayConfig.ALIPAY_PUBLIC_KEY,
    					AlipayConfig.CHARSET, AlipayConfig.SIGNTYPE);
    
    			if (verify_result) {// 验证成功
    				if (trade_status.equals("TRADE_SUCCESS")) { // 交易支付成功
    					boolean contains = RedisUtil.getAllkeys().contains(out_trade_no);
    					if((contains && !RedisUtil.getByKey(out_trade_no).equals("3")) || !contains){
    						RedisUtil.setValue(out_trade_no, "2");// 支付成功,未加钻石
    						
    						//获取订单信息,传到业务层,修改数据库
    						String uid = out_trade_no.substring(0, out_trade_no.indexOf("_"));
    						
    						JSONArray json = JSONArray.parseArray(RedisUtil.getByKey("RechargeMeter"));
    						int diamond = 0;
    						if (json.size() > 0) {
    							for (int i = 0; i < json.size(); i++) {
    								JSONObject job = json.getJSONObject(i);
    								if (job.get("money").equals(total_amount)) {
    									diamond = Integer.parseInt((String) job.get("ADiamonds"));
    									break;
    								}
    							}
    						}
    						System.out.println("diamond : "+ diamond);
    
    						//........
    						if(修改数据库失败){
    							System.out.println("增加钻石失败--网络异常");
    						}else{
    							RedisUtil.setValue(out_trade_no, "3");// 增加钻石成功
    							System.out.println("增加钻石成功");
    							httpResponse.getWriter().println("success");
    						}
    					}
    				}
    			} else {// 验证失败
    				httpResponse.getWriter().println("fail");
    			}
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	
    	// 扫码--支付成功后回调方法
    	@RequestMapping(value = "/OWnotify", method = RequestMethod.POST)
    	public void OWnotify(HttpServletRequest request, HttpServletResponse httpResponse) {
    		// 获取支付宝POST过来反馈信息
    		Map<String, String> params = new HashMap<String, String>();
    		Map<String, String[]> requestParams = request.getParameterMap();
    		Set<String> keySet = requestParams.keySet();
    		String out_trade_no = "";
    		String trade_status = "";
    		String total_amount = "";
    		for (String key : keySet) {
    			StringBuffer buffer = new StringBuffer();
    			for (String string : requestParams.get(key)) {
    				buffer.append(string);
    			}
    			params.put(key, buffer.toString());
    			if (key.equals("out_trade_no")) {
    				out_trade_no = buffer.toString();// 商户订单号
    				System.out.println(key + " : " + buffer.toString());
    			} else if (key.equals("trade_status")) {
    				trade_status = buffer.toString();// 交易状态
    				System.out.println(key + " : " + buffer.toString());
    			} else if (key.equals("total_amount")) {
    				total_amount = buffer.toString().substring(0,buffer.toString().length()-3) + "";// 充值金额
    				System.out.println(key + " : " + total_amount);
    			}
    		}
    		try {
    			// 计算得出通知验证结果
    			boolean verify_result = AlipaySignature.rsaCheckV1(params, AlipayConfig.ALIPAY_PUBLIC_KEY,
    					AlipayConfig.CHARSET, AlipayConfig.SIGNTYPE);
    			if (verify_result) {// 验证成功
    				if (trade_status.equals("TRADE_SUCCESS")) { // 交易支付成功
    					boolean contains = RedisUtil.getAllkeys().contains(out_trade_no);
    					if((contains && !RedisUtil.getByKey(out_trade_no).equals("3")) || !contains){
    						RedisUtil.setValue(out_trade_no, "2");// 支付成功,未加钻石
    						
    						//获取订单信息,传到业务层,修改数据库
    						String uid = out_trade_no.substring(0, out_trade_no.indexOf("_"));
    						
    						int diamond = 0;// 钻石
    						String querywolfurl = AlipayConfig.diamond_url;//公众号充值钻石表
    						String string = HttpClientUtils.executePost(querywolfurl, null, "utf-8");//充值表
    						JSONArray jsona = JSONArray.parseArray(string);
    						if (jsona.size() > 0) {
    							for (int i = 0; i < jsona.size(); i++) {
    								JSONObject job = jsona.getJSONObject(i);
    								if (job.getString("amount").substring(0, job.getString("amount").indexOf(".")).equals(total_amount)) {
    									diamond = Integer.parseInt(job.getString("jewel_amount"));// 钻石
    									break;
    								}
    							}
    						}
    						System.out.println("diamond : "+ diamond);
    
    						//........
    						if(修改数据库失败){
    							System.out.println("增加钻石失败--网络异常");
    						}else{
    							RedisUtil.setValue(out_trade_no, "3");// 增加钻石成功
    							System.out.println("增加钻石成功");
    							httpResponse.getWriter().println("success");
    						}
    					}
    				}
    			} else {// 验证失败
    				httpResponse.getWriter().println("fail");
    			}
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	
    }

# AlipayPayRequest 支付请求的参数 #

public class AlipayPayRequest {
    	private long uid;//用户的uid
    	private String itemId;// 充值商品id
    	private String subject;// 订单标题
    //并提供get/set方法

#  #

# AlipayConfig  #

import com.alipay.api.AlipayClient;
    import com.alipay.api.DefaultAlipayClient;
    
    /**
     * 获取初始化的AlipayClient
     * 包括沙箱及正式版(网关地址,APPID,私钥,公钥均不同)
    */
    public class AlipayConfig {
    	//网关地址
    	//public static final String URL = "https://openapi.alipay.com/gateway.do"; //(正式环境)
    	public static final String URL = "https://openapi.alipaydev.com/gateway.do"; //沙箱(测试环境)
    	
    	//APPID
            public static final String ALIPAY_APPID = "<公司应用的APPID>"; 
    
            //私钥
    	public static String APP_PRIVATE_KEY = "<使用开放平台提供的工具生成>";
    	//支付宝公钥
    	public static String ALIPAY_PUBLIC_KEY = "<使用开放平台提供的工具生成>";
    	
    	//签名算法类型(根据生成私钥的算法,RSA2或RSA)
    	public static final String SIGNTYPE = "RSA";
    	
    	public static final String FORMAT = "json";//请求数据格式
    	public static final String CHARSET = "utf-8";//编码集
    	
    	// 服务器异步通知页面路径 需http://或者https://格式的完整路径，不能加?id=123这类自定义参数，必须外网可以正常访问
    	public static final String notify_url = "http://....../alipay/notify";//公众号
    	public static final String APPnotify = "http://....../alipay/APPnotify";//APP
    	public static final String OWnotify_url = "http://....../alipay/OWnotify";//网站扫码
    	// 页面跳转同步通知页面路径 需http://或者https://格式的完整路径，不能加?id=123这类自定义参数，必须外网可以正常访问 商户可以自定义同步跳转地址
    	public static final String return_url = "https://www.xxx.com/";
    	public static final String OWreturn_url = "https://www.xxx.com/";//网站扫码
    	
    	public static final String diamond_url = "http://www.xxx.com/GetRechergePrice";//公众号充值钻石表(这里是从另一个服务器获取的,也可以存在redis或数据库中)
    	
        // 统一收单交易创建接口
        private static AlipayClient alipayClient = null;
    
        /**获得初始化的AlipayClient
         * @return 支付宝客户端
         */
        public static AlipayClient getAlipayClient() {
            if (alipayClient == null) {
                synchronized (AlipayConfig.class) {
                    if (null == alipayClient) {
                        alipayClient = new DefaultAlipayClient(URL, ALIPAY_APPID, APP_PRIVATE_KEY, FORMAT, CHARSET,ALIPAY_PUBLIC_KEY,SIGNTYPE);
                    }
                }
            }
            return alipayClient;
        }
    }