微信支付

CODE/smart-community/app-api/src/main/java/com/community/huiju/common/wxpay/WXPay.java

@@ -40,12 +40,12 @@ public class WXPay {
         this.notifyUrl = notifyUrl;
         this.autoReport = autoReport;
         this.useSandbox = useSandbox;
-        if (useSandbox) {
-            this.signType = SignType.MD5; // 沙箱环境unifiedOrder
-        }
-        else {
-            this.signType = SignType.HMACSHA256;
-        }
+        //if (useSandbox) {
+            this.signType = SignType.MD5;
+        //}
+        //else {
+        //    this.signType = SignType.HMACSHA256;
+        //}
         this.wxPayRequest = new WXPayRequest(config);
     }
 

CODE/smart-community/app-api/src/main/java/com/community/huiju/controller/WxPayController.java

@@ -1,11 +1,17 @@
 package com.community.huiju.controller;
 
 import com.community.commom.mode.ResponseBean;
+import com.community.commom.redis.RedisTemplate;
 import com.community.huiju.common.wxpay.HfWxConfig;
 import com.community.huiju.common.wxpay.WXPay;
+import com.community.huiju.service.TaVistorServiceI;
+import com.community.huiju.service.WxPayServiceI;
 import com.google.common.collect.Maps;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -24,29 +30,55 @@ import java.util.Map;
 @RequestMapping("/")
 @Api(value = "微信支付 API", description = "微信支付 API")
 public class WxPayController {
+	private Logger log = LoggerFactory.getLogger(WxPayController.class);
+	
+	@Autowired
+	private WxPayServiceI wxPayService;
 	
 	@ApiOperation(value = "统一下单", notes = "统一下单")
 	@RequestMapping(value = "/wxUnifiedOrder",method = RequestMethod.GET)
 	public ResponseBean wxUnifiedOrder(){
 		ResponseBean responseBean = new ResponseBean();
-		HfWxConfig config = new HfWxConfig();
+		
+		Map<String, String> resp = Maps.newHashMap();
+		try {
+			resp = wxPayService.wxUnifiedOrder();
+		} catch (Exception e) {
+			e.printStackTrace();
+			responseBean.addError("下单失败");
+			return responseBean;
+		}
+		log.info("下单成功: {}",resp);
+		responseBean.addSuccess(resp);
+		return responseBean;
+	}
+	
+	@ApiOperation(value = "下载对账单", notes = "下载对账单")
+	@RequestMapping(value = "/wxDownloadBill",method = RequestMethod.GET)
+	public ResponseBean wxDownloadBill(){
+		ResponseBean responseBean = new ResponseBean();
+		
+		Map<String, String> resp = Maps.newHashMap();
+		try {
+			resp = wxPayService.wxDownloadBill();
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+		responseBean.addSuccess(resp);
+		return responseBean;
+	}
+	
+	@ApiOperation(value = "订单查询", notes = "订单查询")
+	@RequestMapping(value = "/wxOrderQuery",method = RequestMethod.GET)
+	public ResponseBean wxOrderQuery(){
+		ResponseBean responseBean = new ResponseBean();
 		Map<String, String> resp = Maps.newHashMap();
 		try {
-			WXPay wxpay = new WXPay(config);
-			
-			Map<String, String> data = new HashMap<String, String>();
-			data.put("body", "支付测试");
-			data.put("out_trade_no", "2019021910595900000012");
-			data.put("device_info", "");
-			data.put("fee_type", "CNY");
-			data.put("total_fee", "1");
-			data.put("spbill_create_ip", "123.12.12.123");
-			data.put("notify_url", "http://www.example.com/wxpay/notify");
-			// 此处指定为APP支付
-			data.put("trade_type", "APP");
-			resp = wxpay.unifiedOrder(data);
+			resp = wxPayService.wxOrderQuery();
 		} catch (Exception e) {
 			e.printStackTrace();
+			responseBean.addError("查询失败");
+			return responseBean;
 		}
 		responseBean.addSuccess(resp);
 		return responseBean;

CODE/smart-community/app-api/src/main/java/com/community/huiju/service/WxPayServiceI.java

@@ -0,0 +1,23 @@
+package com.community.huiju.service;
+
+import java.util.Map;
+
+public interface WxPayServiceI {
+	/**
+	 * 微信支付统一下单
+	 * @return
+	 */
+	Map<String, String> wxUnifiedOrder() throws Exception;
+	
+	/**
+	 * 下载对账单
+	 * @return
+	 */
+	Map<String, String> wxDownloadBill() throws Exception;
+	
+	/**
+	 * 订单查询
+	 * @return
+	 */
+	Map<String, String> wxOrderQuery() throws Exception;
+}

CODE/smart-community/app-api/src/main/java/com/community/huiju/service/impl/WxPayServiceImpl.java

@@ -0,0 +1,96 @@
+package com.community.huiju.service.impl;
+
+import com.community.huiju.common.wxpay.HfWxConfig;
+import com.community.huiju.common.wxpay.WXPay;
+import com.community.huiju.common.wxpay.WXPayConstants;
+import com.community.huiju.common.wxpay.WXPayUtil;
+import com.community.huiju.dao.TpBillInvoiceMapper;
+import com.community.huiju.service.BillServiceI;
+import com.community.huiju.service.WxPayServiceI;
+import com.github.pagehelper.Page;
+import com.github.pagehelper.PageHelper;
+import com.google.common.collect.Maps;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.time.Instant;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author FXF
+ * @date 2018-10-25
+ */
+@Service("wxPayService")
+public class WxPayServiceImpl implements WxPayServiceI {
+	/**
+	 * 微信支付统一下单
+	 *
+	 * @return
+	 */
+	@Override
+	public Map<String, String> wxUnifiedOrder() throws Exception {
+		HfWxConfig config = new HfWxConfig();
+		WXPay wxpay = new WXPay(config);
+		
+		Map<String, String> data = new HashMap<String, String>();
+		data.put("body", "支付测试");
+		//商品号唯一
+		data.put("out_trade_no", "2019021910595900001116");
+		data.put("device_info", "");
+		data.put("fee_type", "CNY");
+		//金额 后台计算
+		data.put("total_fee", "1");
+		//终端IP
+		data.put("spbill_create_ip", "123.12.12.123");
+		//回调地址
+		data.put("notify_url", "http://106.14.20.193:8086/app-api/wxDownloadBill");
+		// 此处指定为APP支付
+		data.put("trade_type", "APP");
+		Map<String, String> resp = wxpay.unifiedOrder(data);
+		
+		//第二次重新生成签名
+		Map<String, String> secondSignData = new HashMap<String, String>();
+		long timestamp = Instant.now().getEpochSecond();
+		secondSignData.put("appid", config.getAppID());
+		secondSignData.put("partnerid", config.getMchID());
+		secondSignData.put("prepayid", resp.get("prepay_id"));
+		secondSignData.put("noncestr", resp.get("nonce_str"));
+		secondSignData.put("timestamp", String.valueOf(timestamp));
+		secondSignData.put("package", "Sign=WXPay");
+		secondSignData.put("sign", WXPayUtil.generateSignature(secondSignData, config.getKey(), WXPayConstants.SignType.MD5));
+		return secondSignData;
+	}
+	
+	/**
+	 * 下载对账单
+	 *
+	 * @return
+	 */
+	@Override
+	public Map<String, String> wxDownloadBill() throws Exception {
+		HfWxConfig config = new HfWxConfig();
+		WXPay wxpay = new WXPay(config);
+		
+		Map<String, String> data = new HashMap<String, String>();
+		data.put("bill_date", "20190219");
+		data.put("bill_type", "ALL");
+		return wxpay.downloadBill(data);
+	}
+	
+	/**
+	 * 订单查询
+	 *
+	 * @return
+	 */
+	@Override
+	public Map<String, String> wxOrderQuery() throws Exception {
+		HfWxConfig config = new HfWxConfig();
+		WXPay wxpay = new WXPay(config);
+		
+		Map<String, String> data = new HashMap<String, String>();
+		data.put("out_trade_no", "2019021910595900000012");
+		return wxpay.orderQuery(data);
+	}
+}