亲宝软件园·资讯

展开

详解APP微信支付(java后台_统一下单和回调)

人气:0

1.微信配置信息 global.properties

2.方法wxpay用于生成预支付订单信息

方法notifyWeiXinPay用于微信支付成功后的回调, 注意: 在手机端使用微信支付成功后,微信服务器会根据提供的回调地址进行回调, parameterMap.put("notify_url", wxnotify); (见下面代码) 

在局域网是无法进行回调的,必须将你的服务端放在公网上进行测试, 回调函数会被多次调用,如果第一次成功后,你可以将业务数据状态标志为已处理, 对于相同订单的其它回调就不需要再次处理了;

package com.main.controller;
 
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.math.BigDecimal;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.SortedMap;
import java.util.TreeMap;
 
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
import org.jdom.JDOMException;
import org.springframework.http.MediaType;
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.main.model.WeiXinPrePay;
import com.main.util.ConfigManager;
import com.main.util.DateUtil;
import com.main.util.GeneralConstant;
import com.main.util.PayCommonUtil;
import com.main.util.Result;
import com.main.util.StringUtil;
 
@Controller
@RequestMapping("/pay")
public class PayController {
	
	
  String randomString = PayCommonUtil.getRandomString(32);
  //支付成功后的回调函数
  public static String wxnotify = "http://com.zhuohuicalss/pay/notifyWeiXinPay";
	
	public PayController() {
		System.out.println("MainController构造函数");
	}
	
	
	/**
   * @param totalAmount  支付金额
   * @param description  描述
   * @param request
   * @return
   */
  @RequestMapping(value = "/wxpay", produces = MediaType.APPLICATION_JSON_VALUE)
  @ResponseBody  
  public Result wxpay(HttpServletRequest request) {
  	Result result = new Result();
    Long userId = new Long(1);//baseController.getUserId();
    
    BigDecimal totalAmount = new BigDecimal(request.getParameter("totalPrice"));
    String trade_no = "";
    String description="";
		try {
			trade_no = new String(request.getParameter("orderNum").getBytes("ISO-8859-1"),"UTF-8");
			description = request.getParameter("description");
		} catch (UnsupportedEncodingException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
    String openId = "";
    
    Map<String, String> map = weixinPrePay(trade_no,totalAmount,description,openId,request); 
    SortedMap<String, Object> finalpackage = new TreeMap<String, Object>();
    //应用ID
    finalpackage.put("appid", ConfigManager.getInstance().getConfigItem("WXAppID")/*PayCommonUtil.APPID*/);
    //商户号
    finalpackage.put("partnerid", ConfigManager.getInstance().getConfigItem("MCH_ID"));
    Long time = (System.currentTimeMillis() / 1000);
    //时间戳
    finalpackage.put("timestamp", time.toString());
    //随机字符串
    finalpackage.put("noncestr", map.get("nonce_str"));
    //预支付交易会话ID
    finalpackage.put("prepayid", map.get("prepay_id"));
    //扩展字段
    finalpackage.put("package", "Sign=WXPay");
    
    WeiXinPrePay prePay = new WeiXinPrePay();
    prePay.setAppId(ConfigManager.getInstance().getConfigItem("WXAppID"));
    prePay.setMchId(ConfigManager.getInstance().getConfigItem("MCH_ID"));
    prePay.setTimeStamp(time.toString());
    prePay.setNonceStr(map.get("nonce_str"));
    prePay.setPrepayId(map.get("prepay_id"));
    prePay.setSignType("MD5");
    prePay.setPaySign(sign);
    result.setData(prePay);
    result.setStateCode(GeneralConstant.SUCCESS);
    result.setDesc("微信支付加载成功");
    
    return result;
  } 
 
	
	/**
   * 统一下单 
   * 应用场景:商户系统先调用该接口在微信支付服务后台生成预支付交易单,返回正确的预支付交易回话标识后再在APP里面调起支付。
   * @param trade_no
   * @param totalAmount
   * @param description
   * @param openid
   * @param sym
   * @param request
   * @return
   */
  @SuppressWarnings("unchecked")
  public Map<String, String> weixinPrePay(String trade_no,BigDecimal totalAmount, 
      String description, String openid, HttpServletRequest request) { 
    SortedMap<String, Object> parameterMap = new TreeMap<String, Object>(); 
    parameterMap.put("appid", ConfigManager.getInstance().getConfigItem("WXAppID")); //应用appid 
    parameterMap.put("mch_id", ConfigManager.getInstance().getConfigItem("MCH_ID")/*PayCommonUtil.MCH_ID*/); //商户号
    //parameterMap.put("device_info", "WEB");
    parameterMap.put("nonce_str", randomString); 
    parameterMap.put("body", description);
    parameterMap.put("out_trade_no", trade_no);
    parameterMap.put("fee_type", "CNY"); 
    System.out.println("jiner"); 
    BigDecimal total = totalAmount.multiply(new BigDecimal(100)); //接口中参数支付金额单位为【分】,参数值不能带小数,所以乘以100
    java.text.DecimalFormat df=new java.text.DecimalFormat("0"); 
    parameterMap.put("total_fee", df.format(total)); 
    System.out.println("jiner2"); 
    parameterMap.put("spbill_create_ip", PayCommonUtil.getRemoteHost(request)); 
    parameterMap.put("notify_url", wxnotify);
    parameterMap.put("trade_type", "APP");//"JSAPI"
    //trade_type为JSAPI是 openid为必填项
    //parameterMap.put("openid", openid);
    System.out.println(""); 
    String sign = PayCommonUtil.createSign("UTF-8", parameterMap); 
    System.out.println("jiner2"); 
    parameterMap.put("sign", sign); 
    String requestXML = PayCommonUtil.getRequestXml(parameterMap); 
    System.out.println(requestXML); 
    String result = PayCommonUtil.httpsRequest( 
        "https://api.mch.weixin.qq.com/pay/unifiedorder", "POST", 
        requestXML); 
    System.out.println(result); 
    Map<String, String> map = null; 
    try { 
      map = PayCommonUtil.doXMLParse(result); 
    } catch (JDOMException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
    } catch (IOException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
    } 
    return map;    
  }
  
  
 
  /**
   * 此函数会被执行多次,如果支付状态已经修改为已支付,则下次再调的时候判断是否已经支付,如果已经支付了,则什么也执行
   * @param request
   * @param response
   * @return
   * @throws IOException
   * @throws JDOMException
   */
  @RequestMapping(value = "notifyWeiXinPay", produces = MediaType.APPLICATION_JSON_VALUE)
  // @RequestDescription("支付回调地址")
  @ResponseBody
  public String notifyWeiXinPay(HttpServletRequest request, HttpServletResponse response) throws IOException, JDOMException {
    System.out.println("微信支付回调");
    InputStream inStream = request.getInputStream();
    ByteArrayOutputStream outSteam = new ByteArrayOutputStream();
    byte[] buffer = new byte[1024];
    int len = 0;
    while ((len = inStream.read(buffer)) != -1) {
      outSteam.write(buffer, 0, len);
    }
    String resultxml = new String(outSteam.toByteArray(), "utf-8");
    Map<String, String> params = PayCommonUtil.doXMLParse(resultxml);
    outSteam.close();
    inStream.close();
    
    
    Map<String,String> return_data = new HashMap<String,String>(); 
    if (!PayCommonUtil.isTenpaySign(params)) {
      // 支付失败
    	return_data.put("return_code", "FAIL"); 
      return_data.put("return_msg", "return_code不正确");
    	return StringUtil.GetMapToXML(return_data);
    } else {
      System.out.println("===============付款成功==============");
      // ------------------------------
      // 处理业务开始
      // ------------------------------
      // 此处处理订单状态,结合自己的订单数据完成订单状态的更新
      // ------------------------------
 
      String total_fee = params.get("total_fee");
      double v = Double.valueOf(total_fee) / 100;
      String out_trade_no = String.valueOf(Long.parseLong(params.get("out_trade_no").split("O")[0]));
			Date accountTime = DateUtil.stringtoDate(params.get("time_end"), "yyyyMMddHHmmss");
			String ordertime = DateUtil.dateToString(new Date(), "yyyy-MM-dd HH:mm:ss");
			String totalAmount = String.valueOf(v);
			String appId = params.get("appid");
			String tradeNo = params.get("transaction_id");
		
			return_data.put("return_code", "SUCCESS"); 
      return_data.put("return_msg", "OK"); 
			return StringUtil.GetMapToXML(return_data);
    }
  }
 
}

3.用到的一些工具类

import java.io.InputStream;
import java.util.*;
 
/**
 * 读取配置文件的类 单例类
 * @author Administrator
 *
 */
public class ConfigManager {
	// 属性文件命名
	private Properties m_props = null;
	private static Map<String,String> configMap;
	private static ConfigManager m_instance = null;
	private static  Properties props = null; 
	private ConfigManager() {
		m_props = new Properties();
		configMap = new HashMap<String,String>();
		try {
			props = System.getProperties(); //获取系统属性
			m_props.load(getInputStream());
			getSysConfigMsg();
			
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	public synchronized static ConfigManager getInstance() {
		if(m_instance == null){
			m_instance = new ConfigManager();
		}
		return m_instance;
	}
 
	public InputStream getInputStream() {
		InputStream is = null;
		try {
			is = getClass().getClassLoader().getResourceAsStream("global.properties");
		} catch (Exception e) {
			e.printStackTrace();
		}
		return is;
	}
  
	public Map<String,String> getSysConfigMsg(){
		Set<Object> keyset = m_props.keySet();
		Iterator<Object> it = keyset.iterator();
		while(it.hasNext()){
			String nextkey = it.next().toString();
			configMap.put(nextkey,getConfigItem(nextkey));
		}
		return configMap;
	}
	
	public String getConfigItem(String name) {
		String val = m_props.getProperty(name).trim();
		if("fileSavePath".equals(name)){
			if(props.getProperty("os.name").startsWith("Windows")){
				val = val.split("#")[0].toString().trim();
			}else{
				val = val.split("#")[1].toString().trim();
			}
		}
		
		return val;
		
	}
	public Map<String,String> getConfigMap(){
		return configMap;
	}
 
}
import java.text.DateFormat;
import java.text.ParsePosition;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.regex.Pattern;
 
 
public class DateUtil {
 
	// 格式:年-月-日 小时:分钟:秒
  public static final String FORMAT_ONE = "yyyy-MM-dd HH:mm:ss";
 
  // 格式:年-月-日 小时:分钟
  public static final String FORMAT_TWO = "yyyy-MM-dd HH:mm";
 
  // 格式:年月日 小时分钟秒
  public static final String FORMAT_THREE = "yyyyMMdd-HHmmss";
  
  // 格式:年月日
  public static final String FORMAT_FOUR = "yyyyMMdd";
  
  // 格式:年-月-日
  public static final String LONG_DATE_FORMAT = "yyyy-MM-dd";
 
  // 格式:月-日
  public static final String SHORT_DATE_FORMAT = "MM-dd";
 
  // 格式:小时:分钟:秒
  public static final String LONG_TIME_FORMAT = "HH:mm:ss";
 
  //格式:年-月
  public static final String MONTG_DATE_FORMAT = "yyyy-MM";
 
  // 年的加减
  public static final int SUB_YEAR = Calendar.YEAR;
 
  // 月加减
  public static final int SUB_MONTH = Calendar.MONTH;
 
  // 天的加减
  public static final int SUB_DAY = Calendar.DATE;
 
  // 小时的加减
  public static final int SUB_HOUR = Calendar.HOUR;
 
  // 分钟的加减
  public static final int SUB_MINUTE = Calendar.MINUTE;
 
  // 秒的加减
  public static final int SUB_SECOND = Calendar.SECOND;
 
  static final String dayNames[] = { "星期日", "星期一", "星期二", "星期三", "星期四",
      "星期五", "星期六" };
 
  public DateUtil() {
  }
 
  /**
   * 把符合日期格式的字符串转换为日期类型
   */
  public static Date stringtoDate(String dateStr, String format) {
    Date d = null;
    SimpleDateFormat formater = new SimpleDateFormat(format);
    try {
      formater.setLenient(false);
      d = formater.parse(dateStr);
    } catch (Exception e) {
      // log.error(e);
      d = null;
    }
    return d;
  }
  
  /**
   * 把符合日期格式的字符串转换为日期类型
   */
  public static Date stringtoDate(String dateStr, String format,
      ParsePosition pos) {
    Date d = null;
    SimpleDateFormat formater = new SimpleDateFormat(format);
    try {
      formater.setLenient(false);
      d = formater.parse(dateStr, pos);
    } catch (Exception e) {
      d = null;
    }
    return d;
  }
 
  /**
   * 把日期转换为字符串
   */
  public static String dateToString(Date date, String format) {
    String result = "";
    SimpleDateFormat formater = new SimpleDateFormat(format);
    try {
      result = formater.format(date);
    } catch (Exception e) {
      // log.error(e);
    }
    return result;
  }
 
  /**
   * 获取当前时间的指定格式
   */
  public static String getCurrDate(String format) {
    return dateToString(new Date(), format);
  }
 
  /**
   * 
   * @Title:    dateSub
   * @Date     2014-1-9 上午10:44:02
   * @Description: 得到指定日期前(后)的日期
   * @param:    @param dateKind 例:Calendar.DAY_OF_MONTH
   * @param:    @param dateStr 指定日期
   * @param:    @param amount  增加(减去)的时间量
   * @param:    @return  
   * @return:    String  
   * @throws
   * @author    mtf
   */
  public static String dateSub(int dateKind, String dateStr, int amount) {
    Date date = stringtoDate(dateStr, MONTG_DATE_FORMAT);
    Calendar calendar = Calendar.getInstance();
    calendar.setTime(date);
    calendar.add(dateKind, amount);
    return dateToString(calendar.getTime(), FORMAT_ONE);
  }
 
  /**
   * 昨日日期
   * @return
   */
  public static String yearthDate(String dateStr){
  	Date date = stringtoDate(dateStr, LONG_DATE_FORMAT);//取时间 
    Calendar calendar = Calendar.getInstance();
    calendar.setTime(date); 
    calendar.add(calendar.DATE,-1);//把日期往后增加一天.整数往后推,负数往前移动 
    //date=calendar.getTime();  //这个时间就是日期往后推一天的结果 
    return dateToString(calendar.getTime(), LONG_DATE_FORMAT);
  }
  
  /**
   * 两个日期相减
   * @return 相减得到的秒数
   */
  public static long timeSub(String firstTime, String secTime) {
    long first = stringtoDate(firstTime, FORMAT_ONE).getTime();
    long second = stringtoDate(secTime, FORMAT_ONE).getTime();
    return (second - first) / 1000;
  }
  /**
   * 两个日期相减
   * 参数地DATE
   * second 两个日期相差的秒
   * @return 相减得到的秒数 
   * 后面时间减去前面时间 再减去 相差秒数  如果大于0 返回 FASLE
   */
  public static boolean timeSub(Date firstTime, Date secTime,long secs) {
    long first = firstTime.getTime();
    long second = secTime.getTime();
    // 判断两个时间 是否间隔那么长 secs。
    return (second - first - secs) > 0 ? false:true;
  }
  /**
   * 两个日期相减
   * 参数地DATE
   * @return 相减得到的秒数 
   * 后面时间减去前面时间 如果大于0 返回 false
   */
  public static boolean timeSub(Date firstTime, Date secTime) {
    long first = firstTime.getTime();
    long second = secTime.getTime();
    return (second - first)>0?false:true;
  }
  /**
   * 获得某月的天数
   */
  public static int getDaysOfMonth(String year, String month) {
    int days = 0;
    if (month.equals("1") || month.equals("3") || month.equals("5")
        || month.equals("7") || month.equals("8") || month.equals("10")
        || month.equals("12")) {
      days = 31;
    } else if (month.equals("4") || month.equals("6") || month.equals("9")
        || month.equals("11")) {
      days = 30;
    } else {
      if ((Integer.parseInt(year) % 4 == 0 && Integer.parseInt(year) % 100 != 0)
          || Integer.parseInt(year) % 400 == 0) {
        days = 29;
      } else {
        days = 28;
      }
    }
 
    return days;
  }
 
  /**
   * 获取某年某月的天数
   */
  public static int getDaysOfMonth(int year, int month) {
    Calendar calendar = Calendar.getInstance();
    calendar.set(year, month - 1, 1);
    return calendar.getActualMaximum(Calendar.DAY_OF_MONTH);
  }
 
  /**
   * 获得当前日期
   */
  public static int getToday() {
    Calendar calendar = Calendar.getInstance();
    return calendar.get(Calendar.DATE);
  }
 
  /**
   * 获得当前月份
   */
  public static int getToMonth() {
    Calendar calendar = Calendar.getInstance();
    return calendar.get(Calendar.MONTH) + 1;
  }
 
  /**
   * 获得当前年份
   */
  public static int getToYear() {
    Calendar calendar = Calendar.getInstance();
    return calendar.get(Calendar.YEAR);
  }
 
  /**
   * 返回日期的天
   */
  public static int getDay(Date date) {
    Calendar calendar = Calendar.getInstance();
    calendar.setTime(date);
    return calendar.get(Calendar.DATE);
  }
  
  /**
   * 返回日期的年
   */
  public static int getYear(Date date) {
    Calendar calendar = Calendar.getInstance();
    calendar.setTime(date);
    return calendar.get(Calendar.YEAR);
  }
 
  /**
   * 返回日期的月份,1-12
   */
  public static int getMonth(Date date) {
    Calendar calendar = Calendar.getInstance();
    calendar.setTime(date);
    return calendar.get(Calendar.MONTH) + 1;
  }
 
  /**
   * 计算两个日期相差的天数,如果date2 > date1 返回正数,否则返回负数
   */
  public static long dayDiff(Date date1, Date date2) {
    return (date2.getTime() - date1.getTime()) / 86400000;
  }
 
  /**
   * 比较两个日期的年差
   */
  public static int yearDiff(String before, String after) {
    Date beforeDay = stringtoDate(before, LONG_DATE_FORMAT);
    Date afterDay = stringtoDate(after, LONG_DATE_FORMAT);
    return getYear(afterDay) - getYear(beforeDay);
  }
 
  /**
   * 比较指定日期与当前日期的差
   */
  public static int yearDiffCurr(String after) {
    Date beforeDay = new Date();
    Date afterDay = stringtoDate(after, LONG_DATE_FORMAT);
    return getYear(beforeDay) - getYear(afterDay);
  }
 
  /**
   * 获取每月的第一周
   */
  public static int getFirstWeekdayOfMonth(int year, int month) {
    Calendar c = Calendar.getInstance();
    c.setFirstDayOfWeek(Calendar.SATURDAY); // 星期天为第一天
    c.set(year, month - 1, 1);
    return c.get(Calendar.DAY_OF_WEEK);
  }
  
  /**
   * 获取每月的最后一周
   */
  public static int getLastWeekdayOfMonth(int year, int month) {
    Calendar c = Calendar.getInstance();
    c.setFirstDayOfWeek(Calendar.SATURDAY); // 星期天为第一天
    c.set(year, month - 1, getDaysOfMonth(year, month));
    return c.get(Calendar.DAY_OF_WEEK);
  }
 
  /**
   * 获得当前日期字符串,格式"yyyy-MM-dd HH:mm:ss"
   * 
   * @return
   */
  public static String getNow() {
    Calendar today = Calendar.getInstance();
    return dateToString(today.getTime(), FORMAT_ONE);
  }
 
  
 
  /**
   * 判断日期是否有效,包括闰年的情况
   * 
   * @param date
   *     YYYY-mm-dd
   * @return
   */
  public static boolean isDate(String date) {
    StringBuffer reg = new StringBuffer(
        "^((\\d{2}(([02468][048])|([13579][26]))-?((((0?");
    reg.append("[13578])|(1[02]))-?((0?[1-9])|([1-2][0-9])|(3[01])))");
    reg.append("|(((0?[469])|(11))-?((0?[1-9])|([1-2][0-9])|(30)))|");
    reg.append("(0?2-?((0?[1-9])|([1-2][0-9])))))|(\\d{2}(([02468][12");
    reg.append("35679])|([13579][01345789]))-?((((0?[13578])|(1[02]))");
    reg.append("-?((0?[1-9])|([1-2][0-9])|(3[01])))|(((0?[469])|(11))");
    reg.append("-?((0?[1-9])|([1-2][0-9])|(30)))|(0?2-?((0?[");
    reg.append("1-9])|(1[0-9])|(2[0-8]))))))");
    Pattern p = Pattern.compile(reg.toString());
    return p.matcher(date).matches();
  }
  
  
  /*****
   * 时间 增加、减少 n个小时以后时间
   * @param date
   *     YYYY-mm-dd HH:mm:ss
   * @param num>0 小时     
   * @param type 增加和减少标志 
   * **/
  public static Date adjustDateByHour(Date d ,Integer num, int type) {
  	Calendar Cal= Calendar.getInstance();
  	 	DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
	  Cal.setTime(d); 
  	if(type==0){
  	  Cal.add(Calendar.MINUTE,-num);
  	  // System.out.println("date:"+df.format(Cal.getTime()));
  		
  	}else
  	{
  		Cal.add(Calendar.MINUTE,num);
  	  //System.out.println("date:"+df.format(Cal.getTime()));
  	}
  	return Cal.getTime();
  }
  /*****
   * 时间 增加、减少 n个分钟以后时间
   * @param date
   *     YYYY-mm-dd HH:mm:ss
   * @param num>0 分钟    
   * @param type 增加和减少标志 
   * **/
  public static Date adjustDateByMinutes(Date d ,Integer num, int type) {
  	Calendar Cal= Calendar.getInstance();
  	 	DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
	  Cal.setTime(d); 
  	if(type==0){
  	  Cal.add(Calendar.MINUTE,-num);
  	 // System.out.println("date:"+df.format(Cal.getTime()));
  		
  	}else
  	{
  		Cal.add(Calendar.MINUTE,num);
  	 //  System.out.println("date:"+df.format(Cal.getTime()));
  	}
  	return Cal.getTime();
  }
  
  public static void main(String[] args){
//  	String dateStr = DateUtil.yearthDate("2017-05-30");
//  	System.out.println(dateStr);
//  	long min = DateUtil.timeSub("2017-04-12 00:00:00", "2017-04-13 00:00:00")/60;
//  	System.out.println(min);
  	String settlementDate = DateUtil.dateToString(new Date(), "yyyy-MM-dd");
  	long day = DateUtil.dayDiff(DateUtil.stringtoDate("2017-06-22", "yyyy-MM-dd"),DateUtil.stringtoDate(settlementDate, "yyyy-MM-dd"));
  	if(day >= 0){
  		System.out.println(day);
  	}
  	
  	String goodsArriveTime = "2017-04-02 17:00-18:00";
  	int space_index = goodsArriveTime.indexOf(" ");
  	String arrive_date = goodsArriveTime.substring(0, space_index);
		String arrive_time = goodsArriveTime.substring(space_index+1, goodsArriveTime.length());
		
		System.out.println(arrive_date);
		System.out.println(arrive_time);
		String arrive_start_time = arrive_time.substring(0, 2);
		String arrive_end_time = arrive_time.substring(6,8);
  	
		System.out.println(arrive_start_time);
		System.out.println(arrive_end_time);
		
		String Time = DateUtil.getCurrDate("HH");
		System.out.println(Time);
		
		String Time2 = DateUtil.getCurrDate("mm");
		System.out.println(Time2);
  }
  
}
import java.security.MessageDigest;
 
public class MD5Util {
	private static String byteArrayToHexString(byte b[]) {
    StringBuffer resultSb = new StringBuffer();
    for (int i = 0; i < b.length; i++)
      resultSb.append(byteToHexString(b[i]));
 
    return resultSb.toString();
  }
 
  private static String byteToHexString(byte b) {
    int n = b;
    if (n < 0)
      n += 256;
    int d1 = n / 16;
    int d2 = n % 16;
    return hexDigits[d1] + hexDigits[d2];
  }
 
  public static String MD5Encode(String origin, String charsetname) {
    String resultString = null;
    try {
      resultString = new String(origin);
      MessageDigest md = MessageDigest.getInstance("MD5");
      if (charsetname == null || "".equals(charsetname))
        resultString = byteArrayToHexString(md.digest(resultString
            .getBytes()));
      else
        resultString = byteArrayToHexString(md.digest(resultString
            .getBytes(charsetname)));
    } catch (Exception exception) {
    }
    return resultString;
  }
 
  private static final String hexDigits[] = { "0", "1", "2", "3", "4", "5",
      "6", "7", "8", "9", "a", "b", "c", "d", "e", "f" };
 
}
import org.apache.http.Consts;
import org.apache.http.HttpEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.ssl.SSLContexts;
import org.apache.http.util.EntityUtils;
import org.jdom.Document;
import org.jdom.Element;
import org.jdom.JDOMException;
import org.jdom.input.SAXBuilder;
 
import javax.net.ssl.SSLContext;
import javax.servlet.http.HttpServletRequest;
import java.io.*;
import java.net.ConnectException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.security.KeyStore;
import java.util.*;
 
public class PayCommonUtil {
	 //微信参数配置 
  public static String API_KEY = ConfigManager.getInstance().getConfigItem("API_KEY");
   
  //随机字符串生成 
  public static String getRandomString(int length) { //length表示生成字符串的长度   
     String base = "abcdefghijklmnopqrstuvwxyz0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ";     
     Random random = new Random();     
     StringBuffer sb = new StringBuffer();     
     for (int i = 0; i < length; i++) {     
       int number = random.nextInt(base.length());     
       sb.append(base.charAt(number));     
     }     
     return sb.toString();     
  }  
  
  //请求xml组装 
  public static String getRequestXml(SortedMap<String,Object> parameters){ 
     StringBuffer sb = new StringBuffer(); 
     sb.append("<xml>"); 
     Set es = parameters.entrySet(); 
     Iterator it = es.iterator(); 
     while(it.hasNext()) { 
       Map.Entry entry = (Map.Entry)it.next(); 
       String key = (String)entry.getKey(); 
       String value = (String)entry.getValue(); 
       if ("attach".equalsIgnoreCase(key)||"body".equalsIgnoreCase(key)||"sign".equalsIgnoreCase(key)) { 
         sb.append("<"+key+">"+"<![CDATA["+value+"]]></"+key+">"); 
       }else { 
         sb.append("<"+key+">"+value+"</"+key+">"); 
       } 
     } 
     sb.append("</xml>"); 
     return sb.toString(); 
  } 
  
  //生成签名 
  public static String createSign(String characterEncoding,SortedMap<String,Object> parameters){ 
     StringBuffer sb = new StringBuffer(); 
     Set es = parameters.entrySet(); 
     Iterator it = es.iterator(); 
     while(it.hasNext()) { 
       Map.Entry entry = (Map.Entry)it.next(); 
       String k = (String)entry.getKey(); 
       Object v = entry.getValue(); 
       if(null != v && !"".equals(v) 
           && !"sign".equals(k) && !"key".equals(k)) { 
         sb.append(k + "=" + v + "&"); 
       } 
     } 
     sb.append("key=" + API_KEY); 
     System.out.println(sb.toString());
     String sign = MD5Util.MD5Encode(sb.toString(), characterEncoding).toUpperCase(); 
     return sign; 
  }
  
  /**
   * 验证回调签名
   * @return
   */
  public static boolean isTenpaySign(Map<String, String> map) {
  	String characterEncoding="utf-8";
    String charset = "utf-8";
    String signFromAPIResponse = map.get("sign");
    if (signFromAPIResponse == null || signFromAPIResponse.equals("")) {
  	  System.out.println("API返回的数据签名数据不存在,有可能被第三方篡改!!!"); 
  	  return false;
    }
    System.out.println("服务器回包里面的签名是:" + signFromAPIResponse);
   //过滤空 设置 TreeMap
    SortedMap<String,String> packageParams = new TreeMap();
    
    for (String parameter : map.keySet()) {
  	  String parameterValue = map.get(parameter);
  	  String v = "";
  	  if (null != parameterValue) {
  		  v = parameterValue.trim();
  	  }
  	  packageParams.put(parameter, v);
    }
    
    StringBuffer sb = new StringBuffer();
    Set es = packageParams.entrySet();
    Iterator it = es.iterator();
    
    while(it.hasNext()) {
  	  Map.Entry entry = (Map.Entry)it.next();
  	  String k = (String)entry.getKey();
  	  String v = (String)entry.getValue();
  	  if(!"sign".equals(k) && null != v && !"".equals(v)) {
  		  sb.append(k + "=" + v + "&");
  	  }
    }
    sb.append("key=" + API_KEY);
    
   //将API返回的数据根据用签名算法进行计算新的签名,用来跟API返回的签名进行比较
   //算出签名
    String resultSign = "";
    String tobesign = sb.toString();
    
    if (null == charset || "".equals(charset)) {
  	  resultSign = MD5Util.MD5Encode(tobesign, characterEncoding).toUpperCase();
    }else{
  	  try{
  		  resultSign = MD5Util.MD5Encode(tobesign, characterEncoding).toUpperCase();
  	  }catch (Exception e) {
  		  resultSign = MD5Util.MD5Encode(tobesign, characterEncoding).toUpperCase();
  	  }
    }
    
    String tenpaySign = ((String)packageParams.get("sign")).toUpperCase();
    return tenpaySign.equals(resultSign);
  }
 
  //请求方法 
  public static String httpsRequest(String requestUrl, String requestMethod, String outputStr) { 
     try { 
        
       URL url = new URL(requestUrl); 
       HttpURLConnection conn = (HttpURLConnection) url.openConnection(); 
       
       conn.setDoOutput(true); 
       conn.setDoInput(true); 
       conn.setUseCaches(false); 
       // 设置请求方式(GET/POST) 
       conn.setRequestMethod(requestMethod); 
       conn.setRequestProperty("content-type", "application/x-www-form-urlencoded"); 
       // 当outputStr不为null时向输出流写数据 
       if (null != outputStr) { 
         OutputStream outputStream = conn.getOutputStream(); 
         // 注意编码格式 
         outputStream.write(outputStr.getBytes("UTF-8")); 
         outputStream.close(); 
       } 
       // 从输入流读取返回内容 
       InputStream inputStream = conn.getInputStream(); 
       InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8"); 
       BufferedReader bufferedReader = new BufferedReader(inputStreamReader); 
       String str = null; 
       StringBuffer buffer = new StringBuffer(); 
       while ((str = bufferedReader.readLine()) != null) { 
         buffer.append(str); 
       } 
       // 释放资源 
       bufferedReader.close(); 
       inputStreamReader.close(); 
       inputStream.close(); 
       inputStream = null; 
       conn.disconnect(); 
       return buffer.toString(); 
     } catch (ConnectException ce) { 
       System.out.println("连接超时:{}"+ ce); 
     } catch (Exception e) { 
       System.out.println("https请求异常:{}"+ e); 
     } 
     return null; 
  } 
   
  //退款的请求方法 
  public static String httpsRequest2(String requestUrl, String requestMethod, String outputStr) throws Exception { 
     KeyStore keyStore = KeyStore.getInstance("PKCS12"); 
     StringBuilder res = new StringBuilder(""); 
     FileInputStream instream = new FileInputStream(new File("/home/apiclient_cert.p12")); 
     try { 
       keyStore.load(instream, "".toCharArray()); 
     } finally { 
       instream.close(); 
     } 
 
     // Trust own CA and all self-signed certs 
     SSLContext sslcontext = SSLContexts.custom()
         .loadKeyMaterial(keyStore, "1313329201".toCharArray()) 
         .build(); 
     // Allow TLSv1 protocol only 
     SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(
         sslcontext, 
         new String[] { "TLSv1" }, 
         null, 
         SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);
     CloseableHttpClient httpclient = HttpClients.custom()
         .setSSLSocketFactory(sslsf) 
         .build(); 
     try { 
 
       HttpPost httpost = new HttpPost("https://api.mch.weixin.qq.com/secapi/pay/refund");
       httpost.addHeader("Connection", "keep-alive"); 
       httpost.addHeader("Accept", "*/*"); 
       httpost.addHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8"); 
       httpost.addHeader("Host", "api.mch.weixin.qq.com"); 
       httpost.addHeader("X-Requested-With", "XMLHttpRequest"); 
       httpost.addHeader("Cache-Control", "max-age=0"); 
       httpost.addHeader("User-Agent", "Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0) "); 
        StringEntity entity2 = new StringEntity(outputStr , Consts.UTF_8);
        httpost.setEntity(entity2); 
       System.out.println("executing request" + httpost.getRequestLine()); 
 
       CloseableHttpResponse response = httpclient.execute(httpost);
        
       try { 
         HttpEntity entity = response.getEntity();
          
         System.out.println("----------------------------------------"); 
         System.out.println(response.getStatusLine()); 
         if (entity != null) { 
           System.out.println("Response content length: " + entity.getContentLength()); 
           BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(entity.getContent())); 
           String text = "";
           res.append(text); 
           while ((text = bufferedReader.readLine()) != null) { 
             res.append(text); 
             System.out.println(text); 
           } 
            
         } 
         EntityUtils.consume(entity);
       } finally { 
         response.close(); 
       } 
     } finally { 
       httpclient.close(); 
     } 
     return res.toString(); 
  }
  
 //xml解析 
  public static Map doXMLParse(String strxml) throws JDOMException, IOException {
     strxml = strxml.replaceFirst("encoding=\".*\"", "encoding=\"UTF-8\""); 
 
     if(null == strxml || "".equals(strxml)) { 
       return null; 
     } 
      
     Map m = new HashMap(); 
      
     InputStream in = new ByteArrayInputStream(strxml.getBytes("UTF-8")); 
     SAXBuilder builder = new SAXBuilder();
     Document doc = builder.build(in);
     Element root = doc.getRootElement();
     List list = root.getChildren(); 
     Iterator it = list.iterator(); 
     while(it.hasNext()) { 
       Element e = (Element) it.next();
       String k = e.getName(); 
       String v = ""; 
       List children = e.getChildren(); 
       if(children.isEmpty()) { 
         v = e.getTextNormalize(); 
       } else { 
         v = getChildrenText(children); 
       } 
        
       m.put(k, v); 
     } 
      
     //关闭流 
     in.close(); 
      
     return m; 
  } 
  
  public static String getChildrenText(List children) { 
    StringBuffer sb = new StringBuffer(); 
    if(!children.isEmpty()) { 
      Iterator it = children.iterator(); 
      while(it.hasNext()) { 
        Element e = (Element) it.next();
        String name = e.getName(); 
        String value = e.getTextNormalize(); 
        List list = e.getChildren(); 
        sb.append("<" + name + ">"); 
        if(!list.isEmpty()) { 
          sb.append(getChildrenText(list)); 
        } 
        sb.append(value); 
        sb.append("</" + name + ">"); 
      } 
    } 
     
    return sb.toString(); 
 }
  
  
  public static String getRemoteHost(HttpServletRequest request){
    String ip = request.getHeader("x-forwarded-for");
    if(ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)){
      ip = request.getHeader("Proxy-Client-IP");
    }
    if(ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)){
      ip = request.getHeader("WL-Proxy-Client-IP");
    }
    if(ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)){
      ip = request.getRemoteAddr();
    }
    return ip.equals("0:0:0:0:0:0:0:1")?"127.0.0.1":ip;
  }
}
package com.lemonjr.api.utils;
 
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
 
public class StringUtil {
	
	/**
	 * 数值类型前面补零(共13位)
	 * @param num
	 * @return
	 */
	public static String supplementZeroGenerateThirteen(int num){
		String str = String.format("%013d", num); 
		
		return str;
	}
	
	/**
	 * 数值类型前面补零(共16位)
	 * @param num
	 * @return
	 */
	public static String supplementZeroGenerateSixteen(int num){
		String str = String.format("%016d", num); 
		
		return str;
	}
	/**
	 * 数值类型前面补零(共3位)
	 * @param num
	 * @return
	 */
	public static String supplementZeroGenerateThree(int num){
		String str = String.format("%03d", num); 
		
		return str;
	}
	
	/**
	 * 判断字符串是不是double型
	 * @param str
	 * @return
	 */
	public static boolean isNumeric(String str){ 
		 Pattern pattern = Pattern.compile("[0-9]+[.]{0,1}[0-9]*[dD]{0,1}"); 
		 Matcher isNum = pattern.matcher(str);
	   if( !isNum.matches() ){
		  return false; 
		 } 
		  return true; 
	}
	
	 public static String trim(String str, boolean nullFlag){
 	  String tempStr = null;
 
     if (str != null)
     {
       tempStr = str.trim();
     }
 
     if (nullFlag)
     {
       if ("".equals(tempStr) || "null".equals(tempStr))
       {
         tempStr = null;
       }
     }
     else
     {
       if (tempStr == null)
       {
         tempStr = "";
       }
     }
 
     return tempStr;
  }
	 public static String replace(String strSource, String strFrom, String strTo) {
			if(strSource==null){
				return null;
			}
			int i = 0;
			if ((i = strSource.indexOf(strFrom, i)) >= 0) {
				char[] cSrc = strSource.toCharArray();
				char[] cTo = strTo.toCharArray();
				int len = strFrom.length();
				StringBuffer buf = new StringBuffer(cSrc.length);
				buf.append(cSrc, 0, i).append(cTo);
				i += len;
				int j = i;
				while ((i = strSource.indexOf(strFrom, i)) > 0) {
					buf.append(cSrc, j, i - j).append(cTo);
					i += len;
					j = i;
				}
				buf.append(cSrc, j, cSrc.length - j);
				return buf.toString();
			}
			return strSource;
		}
 
	
	 public static String deal(String str) {
			str = replace(str, "\\", "\\\\");
			str = replace(str, "'", "\\'");
			str = replace(str, "\r", "\\r");
			str = replace(str, "\n", "\\n");
			str = replace(str, "\"", "\\\"");
			return str;
		}
	 
	 public static String GetMapToXML(Map<String,String> param){ 
     StringBuffer sb = new StringBuffer(); 
     sb.append("<xml>"); 
     for (Map.Entry<String,String> entry : param.entrySet()) {  
        sb.append("<"+ entry.getKey() +">"); 
        sb.append(entry.getValue()); 
        sb.append("</"+ entry.getKey() +">"); 
    }  
     sb.append("</xml>"); 
     return sb.toString(); 
   } 
	 
	public static void main(String[] args){
		//String a = StringUtil.supplementZeroGenerateThirteen(1000);
		double a = 32.;
		System.out.println(StringUtil.isNumeric("32."));
		System.out.println(a);
	}
 
}

4.用到的jar包

<!--微信 -->
    <dependency>
      <groupId>com.github.liyiorg</groupId>
      <artifactId>weixin-popular</artifactId>
      <version>2.8.5</version>
    </dependency>
<!--httpclient-->
    <dependency>
      <groupId>commons-httpclient</groupId>
      <artifactId>commons-httpclient</artifactId>
      <version>3.1</version>
    </dependency>
    <dependency>
      <groupId>org.jdom</groupId>
      <artifactId>jdom2</artifactId>
      <version>2.0.6</version>
    </dependency>

以上所述是小编给大家介绍的APP微信支付(java后台_统一下单和回调)详解整合,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!

您可能感兴趣的文章:

加载全部内容

相关教程
猜你喜欢
用户评论