微信支付服务端自动对账

2024-01-21 11:18
文章标签 微信 服务端 自动 支付 对账

本文主要是介绍微信支付服务端自动对账，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

微信支付服务端自动对账

支付及对账流程链接

自动对账说明

微信支付后每天的商户系统的自动对账还是比较繁琐的，所谓自动对账实际上就是将商户某天交易成功的订单信息与微信某天的账单进行逐一匹配的过程。其涉及到三个专业名词短款、长款和金额不一致，以下对其进行解释：
**短款：**平台资金流有，而支付公司没有的差异，可能是因为支付公司日切早于平台的账务，一旦出现，会出现短款的现象，银行日切导致段差异，会在下一天与银行的勾对中，将此笔差异勾对上，如果是非日切导致的原因，就需要深入追查或让支付公司补款了
**长款：**平台资金流没有，而第三方支付有的差异。可能原因如下：
1）第三方支付日切晚于平台订单账务；
2）平台处理订单时的掉单。一旦出现，则会出现长款（即银行不应该结算而实际结算）的现象，对于因日切导致的差异，在第二天的对账中系统会自动解决，其他原因的，需要技术排查。
**金额不一致：**本地已支付，支付渠道已支付，但是金额不同，这个需要人工来逐一核查。
注意：微信后台是每天九点会生成前一天的账单，故商户后台处理对账下载账单逻辑时建议定时任务定在每天十天再去处理

本人所写自动对账JAVA代码

public void downloadWechatBill() throws Exception {cachedThreadPool.execute(() -> {try{Calendar ca = Calendar.getInstance();ca.setTime(new Date());ca.add(Calendar.DATE, -1);SimpleDateFormat dateFormat= new SimpleDateFormat("yyyyMMdd");SimpleDateFormat dateFormatStr= new SimpleDateFormat("yyyy-MM-dd");SimpleDateFormat dateFormatTime= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");Map<Object, Object> map = new HashMap<>();map.put("appid", APPID);map.put("mch_id", MCHID);map.put("nonce_str", RandomUtil.getRandomStringByLength(32));map.put("bill_date", dateFormat.format(ca.getTime()));map.put("bill_type", "ALL");map.put("tar_type", "GZIP");//根据算法生成签名String sign = Md5EncryptUtil.getWechatSign(map, KEY_APPSECRET);map.put("sign", sign);//将参数转换成xmlString paramXML = XMLParser.converterPayPalm(map);// 下载文件LOG.info("【微信对账业务】-开始下载账单");Boolean downloadSuccess = downloadFile(DOWNLOADB_BILL_URL, FileCatalogEnum.WECHAT_DOWNLOAD_BILL_FILE.getType()+dateFormat.format(ca.getTime())+".gzip",paramXML);if(downloadSuccess){LOG.info("【微信对账业务】-下载账单成功");//如所传日期有账单并下载成功，刚将其上传至ftp服务器做备份FileInputStream in=new FileInputStream(new File(FileCatalogEnum.WECHAT_DOWNLOAD_BILL_FILE.getType()+dateFormat.format(ca.getTime())+".gzip"));uploadFile(FILE_FTP_HOST, Integer.valueOf(FILE_FTP_PORT), FILE_FTP_USERNAME, FILE_FTP_PASSWORD, FileCatalogEnum.WECHAT_DOWNLOAD_BILL_FILE.getType(), dateFormat.format(ca.getTime())+".gzip", in);//从服务器所存储账单的路径下读取账单信息并开始对账服务List<String[]> billInfoArr = this.readGzipBillInfo(FileCatalogEnum.WECHAT_DOWNLOAD_BILL_FILE.getType()+dateFormat.format(ca.getTime())+".gzip");List<Map<String, Object>> saveDiffShortList = new ArrayList<>();List<Map<String, Object>> saveDiffLongList = new ArrayList<>();if(billInfoArr == null){LOG.info("【微信对账业务】-总金额相等无须逐一对账");//无须对账将服务器中的文件删除this.deleteServerFile(FileCatalogEnum.WECHAT_DOWNLOAD_BILL_FILE.getType()+dateFormat.format(ca.getTime())+".gzip");return;}if(billInfoArr.size()>0){//此处为对账业务逻辑处理//获取下载账单日期的商户后台的当日订单List<PaymentTradePO> paymentTradePOList = iWechatPayDao.getOrderByBillDate(dateFormatStr.format(ca.getTime()));LOG.info("【微信对账业务】-开始对账");//首先以商户后台的订单为主去比对微信的订单，如商户有订单而微信没有则标记为短款，如两者都有但金额不一致则标记为金额不一致for(PaymentTradePO tradePO : paymentTradePOList){int count = 1;String tradeId = tradePO.getTradeId();String account = tradePO.getPrice().setScale(2, BigDecimal.ROUND_HALF_UP).toString();for(String[] strArr : billInfoArr){Date tradeTime = dateFormatTime.parse(strArr[0]);String appid = strArr[1];String mchid = strArr[2];String wechatOrderId = strArr[5];String wechatTradeId = strArr[6];String wechatAccount = strArr[12];if(tradeId.equals(wechatTradeId) && account.equals(wechatAccount)){billInfoArr.remove(count-1);break;}//出现金额不一致的情况else if(tradeId.equals(wechatTradeId) && !account.equals(wechatAccount)){WechatCheckAccountOrderDiffPO diffPO = new WechatCheckAccountOrderDiffPO(appid,mchid);diffPO.setOrderDiffId(LogicIdUtil.bussinessId());diffPO.setBussinessOrderNum(wechatTradeId);diffPO.setWechatOrderNum(wechatOrderId);diffPO.setOrderTime(tradePO.getCreateTime());diffPO.setTradeSuccessTime(tradeTime);diffPO.setWechatTradeAmount(new BigDecimal(wechatAccount));diffPO.setBussinessTradeAmount(tradePO.getPrice());diffPO.setDiffType(WechatCheckBilDiffTypeEnum.INCONSISTENT_AMOUNT.getType());diffPO.setDiffOrderStatus(WechatCheckBilDiffStatusEnum.NOT_FLAT_ACCOUNT.getType());diffPO.setStatus(DataStatusEnum.NORMAL.getType());diffPO.setCreateTime(new Date());saveDiffShortList.add(SqlUtil.durableData(diffPO, PlatformConstants.TABLE_SAVE));break;}if(count==billInfoArr.size()){//此时就出现短款if(!tradeId.equals(wechatTradeId)){WechatCheckAccountOrderDiffPO diffPO = new WechatCheckAccountOrderDiffPO(appid,mchid);diffPO.setOrderDiffId(LogicIdUtil.bussinessId());diffPO.setBussinessOrderNum(tradeId);diffPO.setWechatOrderNum(tradePO.getTransactionId());diffPO.setOrderTime(tradePO.getCreateTime());diffPO.setTradeSuccessTime(tradePO.getUpdateTime());diffPO.setBussinessTradeAmount(tradePO.getPrice());diffPO.setDiffType(WechatCheckBilDiffTypeEnum.SHORT_PARAGRAPH.getType());diffPO.setDiffOrderStatus(WechatCheckBilDiffStatusEnum.NOT_FLAT_ACCOUNT.getType());diffPO.setStatus(DataStatusEnum.NORMAL.getType());diffPO.setCreateTime(new Date());saveDiffShortList.add(SqlUtil.durableData(diffPO, PlatformConstants.TABLE_SAVE));}}count++;}}LOG.info("【微信对账业务】-短款对账完毕");if (!saveDiffShortList.isEmpty()) {   //将对账有出入的数据批量保存iWechatPayDao.batchSave(saveDiffShortList);}//再以微信订单为主比对商户后台订单，如微信订单有，商户后台没有则有可能是因为银行日切日早于商户的所以造成的数据出入，故先在日期中的短款数据中匹配，如有则平账，否则保存为长款//从服务器所存储账单的路径下读取账单信息并开始对账服务billInfoArr = this.readGzipBillInfo(FileCatalogEnum.WECHAT_DOWNLOAD_BILL_FILE.getType()+dateFormat.format(ca.getTime())+".gzip");for(String[] strArr : billInfoArr){int count = 1;Date tradeTime = dateFormatTime.parse(strArr[0]);String appid = strArr[1];String mchid = strArr[2];String wechatOrderId = strArr[5];String wechatTradeId = strArr[6];String wechatAccount = strArr[12];for(PaymentTradePO tradePO : paymentTradePOList){String tradeId = tradePO.getTradeId();String account = tradePO.getPrice().setScale(2, BigDecimal.ROUND_HALF_UP).toString();if(wechatTradeId.equals(tradeId) && wechatAccount.equals(account)){paymentTradePOList.remove(count-1);break;}//出现金额不一致的情况else if(tradeId.equals(wechatTradeId) && !account.equals(wechatAccount)){WechatCheckAccountOrderDiffPO diffPO = new WechatCheckAccountOrderDiffPO(appid,mchid);diffPO.setOrderDiffId(LogicIdUtil.bussinessId());diffPO.setBussinessOrderNum(wechatTradeId);diffPO.setWechatOrderNum(wechatOrderId);diffPO.setOrderTime(tradePO.getCreateTime());diffPO.setTradeSuccessTime(tradeTime);diffPO.setWechatTradeAmount(new BigDecimal(wechatAccount));diffPO.setBussinessTradeAmount(tradePO.getPrice());diffPO.setDiffType(WechatCheckBilDiffTypeEnum.INCONSISTENT_AMOUNT.getType());diffPO.setDiffOrderStatus(WechatCheckBilDiffStatusEnum.NOT_FLAT_ACCOUNT.getType());diffPO.setStatus(DataStatusEnum.NORMAL.getType());diffPO.setCreateTime(new Date());if(iWechatPayDao.getInconsistentAmountByTradeId(wechatTradeId)==0){saveDiffLongList.add(SqlUtil.durableData(diffPO, PlatformConstants.TABLE_SAVE));}break;}if(count==paymentTradePOList.size()){//此时就出现长款if(!wechatTradeId.equals(tradeId)){//先排除因微信日切日早于商户平台的，故先在日期中的短款数据中匹配，如有则平账，否则保存为长款Integer infoCount = iWechatPayDao.getIsCheckDiffBillByTradeId(wechatTradeId,wechatAccount);if(infoCount>0){iWechatPayDao.updateDiffOrderStatus(wechatTradeId);}else{WechatCheckAccountOrderDiffPO diffPO = new WechatCheckAccountOrderDiffPO(appid,mchid);diffPO.setOrderDiffId(LogicIdUtil.bussinessId());diffPO.setBussinessOrderNum(wechatTradeId);diffPO.setWechatOrderNum(wechatOrderId);diffPO.setTradeSuccessTime(tradeTime);diffPO.setWechatTradeAmount(new BigDecimal(wechatAccount));diffPO.setDiffType(WechatCheckBilDiffTypeEnum.LONG_SECTION.getType());diffPO.setDiffOrderStatus(WechatCheckBilDiffStatusEnum.NOT_FLAT_ACCOUNT.getType());diffPO.setStatus(DataStatusEnum.NORMAL.getType());diffPO.setCreateTime(new Date());saveDiffLongList.add(SqlUtil.durableData(diffPO, PlatformConstants.TABLE_SAVE));}}}count++;}}LOG.info("【微信对账业务】-长款对账完毕");if (!saveDiffLongList.isEmpty()) {   //将对账有出入的数据批量保存iWechatPayDao.batchSave(saveDiffLongList);}}//对账逻辑处理完毕，将服务器中的文件删除this.deleteServerFile(FileCatalogEnum.WECHAT_DOWNLOAD_BILL_FILE.getType()+dateFormat.format(ca.getTime())+".gzip");}}catch (Exception e){e.printStackTrace();}});}

自动对账中所涉及的工具类

生成签名的工具类（key为商户调置的密钥）

public static String getWechatSign(Map<Object,Object> map,String key){ArrayList<String> list = new ArrayList<String>();for(Map.Entry<Object,Object> entry:map.entrySet()){if(entry.getValue()!=""){list.add(entry.getKey() + "=" + entry.getValue() + "&");}}int size = list.size();String [] arrayToSort = list.toArray(new String[size]);Arrays.sort(arrayToSort, String.CASE_INSENSITIVE_ORDER);StringBuilder sb = new StringBuilder();for(int i = 0; i < size; i ++) {sb.append(arrayToSort[i]);}String result = sb.toString();result += "key=" + key;LOG.error("sign Before MD5:" + result);result = md5(result).toUpperCase();LOG.error("sign Result:" + result);return result;}

将参数MAP转成XML

public static String converterPayPalm(Map<Object, Object> dataMap) {StringBuilder strBuilder = new StringBuilder();try {strBuilder.append("<xml>");Set<Object> objSet = dataMap.keySet();for (Object key : objSet) {if (key == null) {continue;}//strBuilder.append("\n");strBuilder.append("<").append(key.toString()).append(">");Object value = dataMap.get(key);strBuilder.append(coverter(value).trim());strBuilder.append("</").append(key.toString()).append(">");}strBuilder.append("</xml>");} catch (Exception e) {LOG.error("MAP转换XML异常：" + e);}return strBuilder.toString();}

下载微信对账单

urlPath：微信提供的下载URL
saveDir：下载后的保存路径
content：请求参数

public static Boolean downloadFile(String urlPath, String saveDir,String content) throws Exception {URL url = new URL(urlPath);// 连接类的父类，抽象类URLConnection urlConnection = url.openConnection();// http的连接类HttpURLConnection httpURLConnection = (HttpURLConnection) urlConnection;// 设定请求的方法，默认是GET（对于知识库的附件服务器必须是GET，如果是POST会返回405。流程附件迁移功能里面必须是POST，有所区分。）httpURLConnection.setRequestMethod("POST");httpURLConnection.setDoOutput(true);httpURLConnection.setRequestProperty("Accept", "application/json;");httpURLConnection.setRequestProperty("Content-Type", "application/json;charset=utf-8");BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(httpURLConnection.getOutputStream(),PlatformConstants.DEFAULT_CHARSET));writer.write(content.toString());writer.flush();writer.close();// 设置字符编码// 打开到此 URL 引用的资源的通信链接（如果尚未建立这样的连接）。int code = httpURLConnection.getResponseCode();InputStream inputStream = httpURLConnection.getInputStream();if(inputStream.available()!=149){System.out.println("结果："+inputStream.available());File file = new File(saveDir);if (!file.getParentFile().exists()) {boolean result = file.getParentFile().mkdirs();if (!result) {System.out.println("创建失败");}}OutputStream out = new FileOutputStream(file);int size = 0;int lent = 0;byte[] buf = new byte[1024];while ((size = inputStream.read(buf)) != -1) {lent += size;out.write(buf, 0, size);}inputStream.close();out.close();return true;}LOG.info("【微信对账业务】-T日无账单");return false;}

读取压缩文件中的账单信息的方法

参数path：路径+文件名

public List<String[]> readGzipBillInfo(String path){Calendar ca = Calendar.getInstance();ca.setTime(new Date());ca.add(Calendar.DATE, -1);SimpleDateFormat dateFormat= new SimpleDateFormat("yyyyMMdd");SimpleDateFormat dateFormatStr= new SimpleDateFormat("yyyy-MM-dd");SimpleDateFormat dateFormatTime= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");try {File file=new File(path);if(!file.exists()){return null;}BufferedReader reader = new BufferedReader(new InputStreamReader(new GZIPInputStream(new FileInputStream(path)), "utf-8"));String line = null;StringBuilder result = new StringBuilder();while ((line = reader.readLine()) != null) {result.append(line);}String tradeMsg =  result.substring(result.indexOf("`"));//首先比较微信对账中的总金额和商户后台订单总金额是否相等，如相等则不进行逐一比对String totalAmount = iWechatPayDao.getTradeTotal(dateFormatStr.format(ca.getTime()));String listStr = "";String objStr = "";if(tradeMsg.indexOf("总交易单数")>=0){listStr =  tradeMsg.substring(0, tradeMsg.indexOf("总交易单数"));objStr =  tradeMsg.substring(tradeMsg.indexOf("总交易单数"));String[] i = objStr.replaceAll("`","").split("手续费总金额");String[] acount = i[1].split(",");if(acount[1].equals(totalAmount)){return null;}}String tradeInfo =  tradeMsg.substring(0,tradeMsg.indexOf("总")).replace("`", "");// 去掉汇总数据，并且去掉'`'//用spilt方法拿出每一天数据放进数组里。之后再用spilt方法把数据放进二维数组里。String[] tradeArray = tradeInfo.split("%");  // 根据%来区分List<String[]> tradeList = new ArrayList<>();String[] tradeDetailArray = null;for (String tradeDetailInfo : tradeArray) {tradeDetailArray = tradeDetailInfo.split(",");tradeList.add(tradeDetailArray);}String tradeTotalMsg =tradeMsg.substring(tradeMsg.indexOf("总"));String tradeTotalInfo =tradeTotalMsg.substring(tradeTotalMsg.indexOf("`"));return tradeList;} catch (IOException e) {e.printStackTrace();}return null;}

向FTP服务器上传文件

 /*** Description: 向FTP服务器上传文件* @param url FTP服务器hostname* @param port FTP服务器端口* @param username FTP登录账号* @param password FTP登录密码* @param path FTP服务器保存目录* @param filename 上传到FTP服务器上的文件名* @param input 输入流* @return 成功返回true，否则返回false*/public static void uploadFile(String url, int port, String username, String password, String path, String filename, InputStream input) {boolean success = false;Map<String, Object> map = new HashMap<String,Object>();String filepath="";FTPClient ftp = new FTPClient();try {int reply;ftp.connect(url, port);//连接FTP服务器//如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器ftp.login(username, password);//登录reply = ftp.getReplyCode();//判断reply的code是否正常，一般正常为2开头的codeif (!FTPReply.isPositiveCompletion(reply)) {ftp.disconnect();map.put("status", success);map.put("filepath", filepath);}boolean a = ftp.changeWorkingDirectory("/");System.out.println("转换目录结果1:"+a);if(StringUtils.isBlank(path) || path.equals("/")){//如果输入的路径为空或者为根路径，则不转换操作目录}else{//否则创建想要上传文件的目录，并且将操作目录转为新创建的目录ftp.makeDirectory(path);boolean b = ftp.changeWorkingDirectory(path);System.out.println("转换目录结果2:"+b);}//ftp上传文件是以文本形式传输的，所以多媒体文件会失真，需要转为二进制形式传输ftp.setFileType(FTP.BINARY_FILE_TYPE);//转码后可以文件名可以为中文ftp.storeFile(new String(filename.getBytes("GBK"), "iso-8859-1"), input);input.close();ftp.logout();LOG.info("【微信对账业务】-账单成功上传至FTP服务器");
/*            success = true;filepath = "ftp://"+url+":"+port+"/"+path+"/"+filename;map.put("status", success);map.put("filepath", filepath);*/} catch (Exception e) {e.printStackTrace();} finally {if (ftp.isConnected()) {try {ftp.disconnect();} catch (Exception ioe) {}}}}

删除服务器的文件

/*** 删除服务上的文件* @date 2018/08/29* @param filePath 路径* @return*/public static boolean deleteServerFile(String filePath){boolean delete_flag = false;File file = new File(filePath);if (file.exists() && file.isFile() && file.delete())delete_flag = true;elsedelete_flag = false;return delete_flag;}

这篇关于微信支付服务端自动对账的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/629339。

相关文章

Java中实现订单超时自动取消功能(最新推荐)

Java中实现订单超时自动取消功能(最新推荐)

《Java中实现订单超时自动取消功能(最新推荐)》本文介绍了Java中实现订单超时自动取消功能的几种方法,包括定时任务、JDK延迟队列、Redis过期监听、Redisson分布式延迟队列、Rocket... 目录1、定时任务2、JDK延迟队列 DelayQueue（1）定义实现Delayed接口的实体类 （
阅读更多...
shell脚本自动删除30天以前的文件(最新推荐)

shell脚本自动删除30天以前的文件(最新推荐)

《shell脚本自动删除30天以前的文件(最新推荐)》该文章介绍了如何使用Shell脚本自动删除指定目录下30天以前的文件,并通过crontab设置定时任务,此外,还提供了如何使用Shell脚本删除E... 目录shell脚本自动删除30天以前的文件linux按照日期定时删除elasticsearch索引s
阅读更多...
Go Mongox轻松实现MongoDB的时间字段自动填充

Go Mongox轻松实现MongoDB的时间字段自动填充

《GoMongox轻松实现MongoDB的时间字段自动填充》这篇文章主要为大家详细介绍了Go语言如何使用mongox库,在插入和更新数据时自动填充时间字段,从而提升开发效率并减少重复代码,需要的可以... 目录前言时间字段填充规则Mongox 的安装使用 Mongox 进行插入操作使用 Mongox 进行更
阅读更多...
C语言中自动与强制转换全解析

C语言中自动与强制转换全解析

《C语言中自动与强制转换全解析》在编写C程序时,类型转换是确保数据正确性和一致性的关键环节,无论是隐式转换还是显式转换,都各有特点和应用场景,本文将详细探讨C语言中的类型转换机制,帮助您更好地理解并在... 目录类型转换的重要性自动类型转换（隐式转换）强制类型转换（显式转换）常见错误与注意事项总结与建议类型
阅读更多...
IDEA如何让控制台自动换行

IDEA如何让控制台自动换行

《IDEA如何让控制台自动换行》本文介绍了如何在IDEA中设置控制台自动换行,具体步骤为：File-Settings-Editor-General-Console,然后勾选Usesoftwrapsin... 目录IDEA如何让控制台自http://www.chinasem.cn动换行操作流http://www
阅读更多...
vscode保存代码时自动eslint格式化图文教程

vscode保存代码时自动eslint格式化图文教程

《vscode保存代码时自动eslint格式化图文教程》：本文主要介绍vscode保存代码时自动eslint格式化的相关资料,包括打开设置文件并复制特定内容,文中通过代码介绍的非常详细,需要的朋友... 目录1、点击设置2、选择远程--->点击右上角打开设置3、会弹出settings.json文件，将以下内
阅读更多...
Python脚本实现自动删除C盘临时文件夹

Python脚本实现自动删除C盘临时文件夹

《Python脚本实现自动删除C盘临时文件夹》在日常使用电脑的过程中,临时文件夹往往会积累大量的无用数据,占用宝贵的磁盘空间,下面我们就来看看Python如何通过脚本实现自动删除C盘临时文件夹吧... 目录一、准备工作二、python脚本编写三、脚本解析四、运行脚本五、案例演示六、注意事项七、总结在日常使用
阅读更多...
SpringBoot项目启动后自动加载系统配置的多种实现方式

SpringBoot项目启动后自动加载系统配置的多种实现方式

《SpringBoot项目启动后自动加载系统配置的多种实现方式》：本文主要介绍SpringBoot项目启动后自动加载系统配置的多种实现方式,并通过代码示例讲解的非常详细,对大家的学习或工作有一定的... 目录1. 使用 CommandLineRunner实现方式：2. 使用 ApplicationRunne
阅读更多...
Springboot的ThreadPoolTaskScheduler线程池轻松搞定15分钟不操作自动取消订单

Springboot的ThreadPoolTaskScheduler线程池轻松搞定15分钟不操作自动取消订单

《Springboot的ThreadPoolTaskScheduler线程池轻松搞定15分钟不操作自动取消订单》：本文主要介绍Springboot的ThreadPoolTaskScheduler线... 目录ThreadPoolTaskScheduler线程池实现15分钟不操作自动取消订单概要1，创建订单后
阅读更多...
python实现自动登录12306自动抢票功能

python实现自动登录12306自动抢票功能

《python实现自动登录12306自动抢票功能》随着互联网技术的发展,越来越多的人选择通过网络平台购票,特别是在中国,12306作为官方火车票预订平台,承担了巨大的访问量,对于热门线路或者节假日出行... 目录一、遇到的问题？二、改进三、进阶–展望总结一、遇到的问题？1.url-正确的表头：就是首先ur
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2