PayController.java 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591
  1. package com.platform.yijia.controller;
  2. import com.alibaba.fastjson.JSON;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.alibaba.fastjson.parser.Feature;
  5. import com.google.gson.Gson;
  6. import com.platform.yijia.param.request.*;
  7. import com.platform.yijia.pojo.AppUserInfo;
  8. import com.platform.yijia.pojo.PayOrder;
  9. import com.platform.yijia.service.AppUserInfoService;
  10. import com.platform.yijia.service.PayOrderService;
  11. import com.platform.yijia.service.StationOilGunService;
  12. import com.platform.yijia.utils.*;
  13. import org.apache.commons.lang3.StringUtils;
  14. import org.slf4j.Logger;
  15. import org.slf4j.LoggerFactory;
  16. import org.springframework.stereotype.Controller;
  17. import org.springframework.web.bind.annotation.*;
  18. import javax.annotation.Resource;
  19. import java.text.SimpleDateFormat;
  20. import java.util.*;
  21. @Controller
  22. @RequestMapping("/api")
  23. public class PayController {
  24. private static Logger logger =(Logger) LoggerFactory.getLogger(PayController.class);
  25. @Resource
  26. private PayOrderService payOrderService;
  27. @Resource
  28. private AppUserInfoService appUserInfoService;
  29. @Resource
  30. private StationOilGunService stationOilGunService;
  31. /***
  32. * 微信子商户支付接口
  33. * @param weChatPaySetRequest
  34. * @return
  35. */
  36. @RequestMapping(value = "/weChatPaySet", consumes = "application/json", method = RequestMethod.POST)
  37. @ResponseBody
  38. public String weChatPaySet(@RequestBody WeChatPaySetRequest weChatPaySetRequest){
  39. Gson gson = new Gson();
  40. ResultData resultData = null; //返回结果
  41. try {
  42. String type = weChatPaySetRequest.getType(); //获取配置类型
  43. JSONObject reqData = new JSONObject(); //微信子商户支付参数配置
  44. reqData.put("mno", weChatPaySetRequest.getMno()); //商编
  45. reqData.put("subMchIdsubMchId", weChatPaySetRequest.getSubMchIdsubMchId()); //获取微信子商号
  46. if(type != null && type !=""){
  47. reqData.put("type", type);
  48. //根据类型设置必传参数
  49. switch (type){
  50. case "01": //支付Appid
  51. reqData.put("accountType", weChatPaySetRequest.getAccountType()); // 支付Appid类型 配置类型为01时必传
  52. reqData.put("subAppid", weChatPaySetRequest.getSubAppid()); // 支付Appid 配置类型为01,02时必传
  53. break;
  54. case "02": //关注Appid
  55. reqData.put("subAppid", weChatPaySetRequest.getSubAppid()); // 支付Appid 配置类型为01,02时必传
  56. reqData.put("subscribeAppid", weChatPaySetRequest.getSubscribeAppid()); // 推荐关注公众号Appid 配置类型为02时与推荐关注 小程序Appid二选一
  57. reqData.put("receiptAppid", weChatPaySetRequest.getReceiptAppid()); // 推荐关注小程序Appid 配置类型为02时与推荐关注 公众号Appid二选一
  58. break;
  59. case "03": //jsapi授权目录
  60. reqData.put("jsapiPath", weChatPaySetRequest.getJsapiPath()); // jsapi授权目录 配置类型为03时必传
  61. break;
  62. }
  63. }
  64. String sxfPay = SXFPaySign.getSXFPay(reqData); //封装传参信息,增加公共信息,增加业务信息
  65. logger.debug("参数信息:"+ sxfPay);
  66. System.out.println("req:" + sxfPay);
  67. //此处不要改变reqData里面值的顺序用LinkedHashMap
  68. HashMap reqMap = JSON.parseObject(sxfPay, LinkedHashMap.class, Feature.OrderedField);
  69. //组装加密串
  70. String signContent = RSASignature.getOrderContent(reqMap);
  71. System.out.println("拼接后的参数:" + signContent);
  72. logger.debug("拼接后的参数:"+signContent);
  73. //sign
  74. String sign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
  75. reqMap.put("sign", sign);
  76. String reqStr = JSON.toJSONString(reqMap);
  77. System.out.println("请求参数:" + reqMap);
  78. System.out.println("请求参数:" + reqStr);
  79. //String url = "https://openapi-test.tianquetech.com/merchant/weChatPaySet/addConf"; //测试环境
  80. String url = "https://openapi.tianquetech.com/merchant/weChatPaySet/addConf"; //生产环境
  81. //访问第三方接口
  82. String resultJson = HttpUtils.connectPostUrl(url, reqStr);
  83. System.out.println("返回信息:" + resultJson);
  84. // logger.debug("返回信息:"+resultJson);
  85. //不要对reqData排序 所以用LinkedHashMap
  86. HashMap<String, Object> result = JSON.parseObject(resultJson, LinkedHashMap.class, Feature.OrderedField);
  87. if ("0000".equals(result.get("code"))) {
  88. //验签
  89. String signResult = result.get("sign").toString();
  90. result.remove("sign");
  91. String resultStr = RSASignature.getOrderContent(result);
  92. System.out.println(resultStr);
  93. //sign
  94. String resultSign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
  95. System.out.println("resultSign:" + resultSign);
  96. //组装加密串
  97. if (RSASignature.doCheck(resultStr, signResult, SXFPaySign.sxfPublic)) {
  98. System.out.println("===================验签成功==============");
  99. }
  100. }
  101. resultData=ResultData.success(result);
  102. } catch (Exception e) {
  103. resultData=ResultData.error(CodeMsg.YEWU_FAIL,"支付失败");
  104. e.printStackTrace();
  105. }
  106. return gson.toJson(resultData);
  107. }
  108. /**
  109. * 支付接口,前台上传支付信息,支付数据落地生产订单,调用随行付支付接口
  110. * @param
  111. * @return
  112. */
  113. @RequestMapping(value = "/getJhPayInfo", consumes = "application/json", method = RequestMethod.POST)
  114. @ResponseBody
  115. public String getJhPayInfo(@RequestBody PayInfoRequest payInfoRequest){
  116. Gson gson =new Gson();
  117. ResultData resultData =null;
  118. //String token=payInfoRequest.getToken();//token
  119. String openId = payInfoRequest.getOpenId(); //用户openId
  120. String userType=payInfoRequest.getUserType();//用户登录类型 1 公众号。2 小程序
  121. String mno=payInfoRequest.getMno();//获取商户号
  122. Integer orderId =payInfoRequest.getOrderId();
  123. //根据token 和登录类型 身份验证
  124. AppUserInfo appUserInfo =new AppUserInfo();
  125. //订单类型 是小程序还是公众号
  126. appUserInfo.setUserType(userType);
  127. if(userType.equals("1")){
  128. //1 是公众号
  129. appUserInfo.setBlogOpenid(openId);
  130. }else if(userType.equals("2")){
  131. //2是小程序
  132. appUserInfo.setMinaOpenid(openId);
  133. }
  134. List<AppUserInfo> appUserInfoList =appUserInfoService.Authentication(appUserInfo);
  135. if(appUserInfoList!=null&&appUserInfoList.size()==1){
  136. //调用聚合支付
  137. try{
  138. //根据订单号查询订单信息
  139. PayOrder payOrder=payOrderService.searchPayOrder(orderId);
  140. if(payOrder!=null){
  141. //将业务参数存放在 JSON 对象中
  142. JSONObject reqData = new JSONObject();
  143. reqData.put("ordNo", payOrder.getOrderNo()); //商户订单号
  144. reqData.put("mno", mno); //商户编号
  145. //reqData.put("subMechId", ""); //子商户号
  146. //reqData.put("amt", payOrder.getAmt()); //订单总金额
  147. reqData.put("amt", "0.01");
  148. //reqData.put("discountAmt", ""); //参与优惠金额
  149. //reqData.put("unDiscountAmt", ""); //不参与优惠金额
  150. reqData.put("payType", "WECHAT"); //支付渠道
  151. if(userType.equals("1")){
  152. //1 是公众号
  153. reqData.put("payWay", "02"); //支付方式 02 公众号/服 务窗/js支付 03 小程序
  154. reqData.put("userId", appUserInfoList.get(0).getBlogOpenid()); //用户号 微信:openid; 支付宝:userid;银联:userid;微信&支付宝必传,银联js为非必传
  155. }else if(userType.equals("2")){
  156. //2是小程序
  157. reqData.put("payWay", "03"); //支付方式 02 公众号/服 务窗/js支付 03 小程序
  158. reqData.put("userId", appUserInfoList.get(0).getMinaOpenid()); //用户号 微信:openid; 支付宝:userid;银联:userid;微信&支付宝必传,银联js为非必传
  159. }
  160. //reqData.put("timeExpire", "10"); //订单失效时间, 以分钟为单位
  161. //reqData.put("limitPay", "00"); //限制卡类型: 00-全部 01-限定不能使 用信用卡支付 默认值 00
  162. reqData.put("subject", "聚合支付测试"); //订单标题
  163. //reqData.put("hbFqNum", "6"); //花呗分期数,仅可上送 6 或 12
  164. reqData.put("tradeSource", "01"); //交易来源 01服务商,02收银台,03硬件
  165. reqData.put("trmIp", "172.16.2.1");//商家ip地址
  166. // reqData.put("customerIp", ""); //持卡人ip地址,银联js支付时必传
  167. //reqData.put("subAppid", "wx24210004370ec43b"); //微信子公众号
  168. //reqData.put("outFrontUrl", ""); //js 支付,前台 成功通知地址
  169. //reqData.put("outFrontFailUrl", ""); //js 支付,前台 事变通知地址
  170. reqData.put("notifyUrl", "https://www.huijy.net/api/getCallback"); //回调地址
  171. //reqData.put("needReceipt", "00"); //电子发票功能 微信开具电子 发票使用
  172. //reqData.put("ledgerAccountFlag", "00"); //是否做分账 分账交易使 用;00:做; 01:不做;不传默认为不做分账
  173. //reqData.put("ledgerAccountEffectTime", "00"); //分账有效时间 单位为天;是 否做分账选择 00 时该字段必传
  174. // reqData.put("ruleId", "00"); //同 步 分 账 规 则 id
  175. // reqData.put("fusruleId", "00"); //同步分账规则
  176. //reqData.put("ylTrmNo", ""); //银联终端号
  177. //reqData.put("terminalId", ""); //TQ机具编号
  178. //reqData.put("deviceNo ", "1111"); //设备号
  179. // reqData.put("identityFlag", ""); //是否是实名支付
  180. // reqData.put("buyerIdType", "IDCARD"); //证件类型
  181. // reqData.put("buyerIdNo", "410523198701054018"); //证件号
  182. // reqData.put("buyerName", "张三"); //买家姓名
  183. // reqData.put("mobileNum", ""); //手机号
  184. // reqData.put("extend", ""); //备用
  185. String req= SXFPaySign.getSXFPay(reqData);
  186. logger.debug("参数信息:"+req);
  187. System.out.println("req:" + req);
  188. //此处不要改变reqData里面值的顺序用LinkedHashMap
  189. HashMap reqMap = JSON.parseObject(req, LinkedHashMap.class, Feature.OrderedField);
  190. //组装加密串
  191. String signContent = RSASignature.getOrderContent(reqMap);
  192. System.out.println("拼接后的参数:" + signContent);
  193. logger.debug("拼接后的参数:"+signContent);
  194. //sign
  195. String sign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
  196. System.out.println("============签名:" + sign);
  197. reqMap.put("sign", sign);
  198. String reqStr = JSON.toJSONString(reqMap);
  199. System.out.println("请求参数:" + reqMap);
  200. System.out.println("请求参数:" + reqStr);
  201. //调用第三方接口地址
  202. //String url = "https://openapi-test.tianquetech.com/order/jsapiScan";//测试地址
  203. String url = "https://openapi.suixingpay.com/order/jsapiScan";//生产地址
  204. String resultJson = HttpUtils.connectPostUrl(url, reqStr);
  205. System.out.println("返回信息:" + resultJson);
  206. // logger.debug("返回信息:"+resultJson);
  207. //不要对reqData排序 所以用LinkedHashMap
  208. HashMap<String, Object> result = JSON.parseObject(resultJson, LinkedHashMap.class, Feature.OrderedField);
  209. if ("0000".equals(result.get("code"))) {
  210. //验签
  211. String signResult = result.get("sign").toString();
  212. result.remove("sign");
  213. String resultStr = RSASignature.getOrderContent(result);
  214. System.out.println(resultStr);
  215. //sign
  216. String resultSign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
  217. System.out.println("resultSign:" + resultSign);
  218. //组装加密串
  219. if (RSASignature.doCheck(resultStr, signResult, SXFPaySign.sxfPublic)) {
  220. System.out.println("===================验签成功==============");
  221. }
  222. }
  223. resultData=ResultData.success(result);
  224. }else {
  225. resultData=ResultData.error(CodeMsg.YEWU_FAIL,"未查询到订单");
  226. }
  227. }catch (Exception e){
  228. resultData=ResultData.error(CodeMsg.YEWU_FAIL,"订单支付失败");
  229. e.printStackTrace();
  230. }
  231. }else{
  232. //返回失败支付失败信息
  233. resultData=ResultData.error(CodeMsg.USER_NOT_EXSIST);
  234. }
  235. return gson.toJson(resultData);
  236. }
  237. /**
  238. * 验证商户信息查询
  239. */
  240. @RequestMapping(value = "/getJhPayMnoInfo", method = RequestMethod.GET)
  241. @ResponseBody
  242. public String getJhPayMnoInfo(@RequestParam String mno){
  243. try {
  244. JSONObject reqData = new JSONObject();
  245. reqData.put("mno", mno); //商户编号
  246. String req = SXFPaySign.getSXFPay(reqData);
  247. logger.debug("参数信息:" + req);
  248. System.out.println("req:" + req);
  249. //此处不要改变reqData里面值的顺序用LinkedHashMap
  250. HashMap reqMap = JSON.parseObject(req, LinkedHashMap.class, Feature.OrderedField);
  251. //组装加密串
  252. String signContent = RSASignature.getOrderContent(reqMap);
  253. System.out.println("拼接后的参数:" + signContent);
  254. logger.debug("拼接后的参数:" + signContent);
  255. //sign
  256. String sign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
  257. System.out.println("============签名:" + sign);
  258. reqMap.put("sign", sign);
  259. String reqStr = JSON.toJSONString(reqMap);
  260. System.out.println("请求参数:" + reqMap);
  261. System.out.println("请求参数:" + reqStr);
  262. //调用第三方接口地址
  263. //String url = "https://openapi-test.tianquetech.com/merchant/merchantInfoQuery";//测试地址
  264. String url = "https://openapi.tianquetech.com/merchant/merchantInfoQuery";//生产地址
  265. String resultJson = HttpUtils.connectPostUrl(url, reqStr);
  266. HashMap<String, Object> result = JSON.parseObject(resultJson, LinkedHashMap.class, Feature.OrderedField);
  267. if ("0000".equals(result.get("code"))) {
  268. // //验签
  269. // String signResult = result.get("sign").toString();
  270. // result.remove("sign");
  271. // String resultStr = RSASignature.getOrderContent(result);
  272. // System.out.println(resultStr);
  273. // //sign
  274. // String resultSign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
  275. // System.out.println("resultSign:" + resultSign);
  276. // //组装加密串
  277. // if (RSASignature.doCheck(resultStr, signResult, SXFPaySign.sxfPublic)) {
  278. // System.out.println("===================验签成功==============");
  279. // }
  280. }
  281. }catch (Exception e){
  282. e.printStackTrace();
  283. }
  284. return "";
  285. }
  286. /**
  287. * 关单接口
  288. */
  289. @RequestMapping(value = "/getPayOrderClose", consumes = "application/json", method = RequestMethod.POST)
  290. @ResponseBody
  291. public String getPayOrderClose(@RequestBody PayCloseRequestParamter payCloseRequestParamter) {
  292. String results="";
  293. Gson gson =new Gson();
  294. String mno=payCloseRequestParamter.getMno();
  295. String origOrderNo=payCloseRequestParamter.getOrigOrderNo();
  296. String origUuid=payCloseRequestParamter.getOrigUuid();
  297. String token=payCloseRequestParamter.getToken();
  298. String userType=payCloseRequestParamter.getUserType();
  299. boolean flag =appUserInfoService.selectAppUserInfo(token,userType);
  300. ResultData resultData =null;
  301. if(flag){
  302. try {
  303. JSONObject reqData = new JSONObject();
  304. reqData.put("mno",mno); //商户编号
  305. reqData.put("origOrderNo",origOrderNo);//系统商户订单号
  306. reqData.put("origUuid", origUuid);//随行付订单号
  307. String req= SXFPaySign.getSXFPay(reqData);
  308. //此处不要改变reqData里面值的顺序用LinkedHashMap
  309. HashMap reqMap = JSON.parseObject(req, LinkedHashMap.class, Feature.OrderedField);
  310. //组装加密串
  311. String signContent = RSASignature.getOrderContent(reqMap);
  312. System.out.println("拼接后的参数:" + signContent);
  313. //sign
  314. String sign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
  315. System.out.println("============签名:" + sign);
  316. reqMap.put("sign", sign);
  317. String reqStr = JSON.toJSONString(reqMap);
  318. System.out.println("请求参数:" + reqMap);
  319. System.out.println("请求参数:" + reqStr);
  320. //调用第三方接口地址
  321. // String url = "https://openapi-test.tianquetech.com/query/close";//测试地址
  322. String url = "https://openapi.tianquetech.com/query/close";//生产地址
  323. String resultJson = HttpUtils.connectPostUrl(url, reqStr);
  324. System.out.println("返回信息:" + resultJson);
  325. //不要对reqData排序 所以用LinkedHashMap
  326. HashMap<String, Object> result = JSON.parseObject(resultJson, LinkedHashMap.class, Feature.OrderedField);
  327. if ("0000".equals(result.get("code"))) {
  328. //验签
  329. String signResult = result.get("sign").toString();
  330. result.remove("sign");
  331. String resultStr = RSASignature.getOrderContent(result);
  332. System.out.println(resultStr);
  333. //sign
  334. String resultSign = RSASignature.encryptBASE64(RSASignature.sign(signContent,SXFPaySign.privateKey));
  335. System.out.println("resultSign:" + resultSign);
  336. //组装加密串
  337. if (RSASignature.doCheck(resultStr, signResult, SXFPaySign.sxfPublic)) {
  338. System.out.println("===================验签成功==============");
  339. }
  340. }
  341. resultData=ResultData.success(result);
  342. }catch (Exception e){
  343. resultData=ResultData.error(CodeMsg.YEWU_FAIL,"关闭订单失败");
  344. e.printStackTrace();
  345. }
  346. }else{
  347. resultData=ResultData.error(CodeMsg.USER_NOT_EXSIST);
  348. }
  349. return gson.toJson(resultData);
  350. }
  351. /**
  352. * 异步回调通知
  353. */
  354. @RequestMapping(value = "/getCallback", consumes = "application/json", method = RequestMethod.POST)
  355. @ResponseBody
  356. public void getCallback(@RequestBody JSONObject request){
  357. logger.info("-------------------------------回调开始----------------------------------------------");
  358. logger.info("回调返回过来的参数"+request);
  359. logger.info("ordNo信息:" + request.get("ordNo").toString());
  360. logger.info("sign信息:" + request.get("sign").toString());
  361. Gson gson =new Gson();
  362. String sxfUuid=request.get("sxfUuid").toString(); //随行付落单号
  363. String payWay=request.get("payWay").toString(); //随行付交易方式
  364. String payTime=request.get("payTime").toString(); //随行付交易时间
  365. String uuid=request.get("uuid").toString(); //随行付交易流水号
  366. String mno=request.get("mno").toString();//发起交易的商户编号
  367. String ordNo=request.get("ordNo").toString();//商户生成的订单号
  368. String amt=request.get("amt").toString();//金额
  369. String buyerId=request.get("buyerId").toString();//用户登录
  370. String transactionId=request.get("transactionId").toString();//用户登录
  371. String drType=request.get("drType").toString();//借贷记标识 1-借,2-贷,3-其他
  372. String payType=request.get("payType").toString();//对订单的描述,取值范围:WECHAT:微信,ALIPAY:支付宝,UNIONPAY:
  373. String payBank=request.get("payBank").toString();//付款银行银行编码,例如 ICBC
  374. String pointAmount=request.get("pointAmount").toString();//代金券金额
  375. String totalOffstAmt=request.get("totalOffstAmt").toString();//消 费 者 付 款金额
  376. String settleAmt=request.get("settleAmt").toString();//商家入账金额
  377. String timeStamp=request.get("timeStamp").toString();//响应时间
  378. String sign=request.get("sign").toString();//签名
  379. String bizCode=request.get("bizCode").toString();//业务返回码
  380. String bizMsg=request.get("bizMsg").toString();//业 务 返 回 信息
  381. String openid=request.get("openid").toString();//微 信 或 支 付宝身份id()opendid userid
  382. String channelId=request.get("channelId").toString();//渠道商户号
  383. String subMechId=request.get("subMechId").toString();//子商户号
  384. String finishTime=request.get("finishTime").toString();//交易完成时间
  385. String clearDt=request.get("clearDt").toString();
  386. String settlementBatchNo=request.get("settlementBatchNo").toString();
  387. //String origOrdNo=request.get("origOrdNo").toString();//反交易退款异步通知
  388. //String origUuid=request.get("origUuid").toString();//token
  389. //String scene=request.get("scene").toString();//用户登录
  390. //String buyerAccount=request.get("buyerAccount").toString();//
  391. //String realRefundAmount=request.get("realRefundAmount").toString();//商家出账金额
  392. //String recFeeAmt=request.get("recFeeAmt").toString();//交易手续费
  393. //String recFeeRate=request.get("recFeeRate").toString();//交易手续费率
  394. //String refBuyerAmt=request.get("refBuyerAmt").toString();//消 费 者 到 账金额
  395. //String extend = extend=request.get("extend").toString();//备用
  396. //将业务参数存放在 JSON 对象中
  397. JSONObject reqData = new JSONObject();
  398. reqData.put("sxfUuid",sxfUuid);
  399. reqData.put("payWay",payWay);
  400. reqData.put("payTime",payTime);
  401. reqData.put("uuid",uuid);
  402. reqData.put("mno",mno);
  403. reqData.put("ordNo",ordNo);
  404. reqData.put("amt",amt);
  405. reqData.put("buyerId",buyerId);
  406. reqData.put("transactionId",transactionId);
  407. reqData.put("drType",drType);
  408. reqData.put("payType",payType);
  409. reqData.put("payBank",payBank);
  410. reqData.put("pointAmount",pointAmount);
  411. reqData.put("totalOffstAmt",totalOffstAmt);
  412. reqData.put("settleAmt",settleAmt);
  413. reqData.put("timeStamp",timeStamp);
  414. reqData.put("bizCode",bizCode);
  415. reqData.put("bizMsg",bizMsg);
  416. reqData.put("openid",openid);
  417. reqData.put("channelId",channelId);
  418. reqData.put("subMechId",subMechId);
  419. reqData.put("finishTime",finishTime);
  420. reqData.put("clearDt",clearDt);
  421. reqData.put("settlementBatchNo",settlementBatchNo);
  422. //reqData.put("realRefundAmount",realRefundAmount);
  423. //reqData.put("recFeeAmt",recFeeAmt);
  424. //reqData.put("recFeeRate",recFeeRate);
  425. //reqData.put("buyerAccount",buyerAccount);
  426. //reqData.put("origOrdNo",origOrdNo);
  427. //reqData.put("origUuid",origUuid);
  428. //reqData.put("scene",scene);
  429. //reqData.put("refBuyerAmt",refBuyerAmt);
  430. //reqData.put("extend",extend);
  431. //根据回调信息,先进行验签,验签后修改状态
  432. logger.info("打印参数信息"+gson.toJson(reqData));
  433. //不要对reqData排序 所以用LinkedHashMap
  434. HashMap<String, Object> result = JSON.parseObject(gson.toJson(reqData), LinkedHashMap.class, Feature.OrderedField);
  435. //验签
  436. String resultStr = RSASignature.getOrderContent(result);
  437. JSONObject req = new JSONObject();
  438. System.out.println(resultStr);
  439. if (RSASignature.doCheck(resultStr, sign, SXFPaySign.sxfPublic)) {
  440. logger.info("验签成功");
  441. //验签成功,修改订单状态
  442. List<PayOrder> list = payOrderService.getPayOrderList(ordNo);
  443. logger.info("根据订单号,查询订单"+gson.toJson(list));
  444. if (list != null && list.size() == 1) {
  445. String status = list.get(0).getStatus();
  446. //状态为未支付 0 修改状态为1已支付
  447. if (status.equals("0")) {
  448. PayOrder payOrder = new PayOrder();
  449. payOrder.setOrderNo(ordNo);
  450. payOrder.setStatus("1");
  451. payOrder.setPayDate(new Date()); //支付时间
  452. payOrder.setReceivedAmt(Double.valueOf(settleAmt)); //settleAmt商家入账金额
  453. //修改订单状态
  454. int count = payOrderService.getUpdatePayOrder(payOrder);
  455. if(count == 1){
  456. req.put("code","success");
  457. req.put("msg","修改订单状态成功");
  458. logger.info(req.toString());
  459. //开始打印
  460. List<PayOrder> listUp = payOrderService.getPayOrderList(ordNo);
  461. String content1;
  462. String content2;
  463. String orderNoP = "";
  464. String createdDateP ="";
  465. String stationNameP ="";
  466. String oilNameP ="";
  467. String orderLitersP ="";
  468. String oilPirceP ="";
  469. String receivableAmtP = "";
  470. String discountAmtP = "";
  471. String amtP = "";
  472. String sn; //打印机编号
  473. if(listUp != null && listUp.size() == 1){
  474. logger.info("要打印小票的订单信息: "+ listUp);
  475. if(StringUtils.isNotBlank(listUp.get(0).getOrderNo())){
  476. orderNoP =listUp.get(0).getOrderNo();
  477. }
  478. if(listUp.get(0).getCreatedDate() !=null && listUp.get(0).getCreatedDate().toString() !=""){
  479. //格式化日期
  480. SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  481. createdDateP =sdf.format(listUp.get(0).getCreatedDate());
  482. }
  483. if(StringUtils.isNotBlank(listUp.get(0).getStationName())){
  484. stationNameP =listUp.get(0).getStationName();
  485. }
  486. if(StringUtils.isNotBlank(listUp.get(0).getOilName())){
  487. oilNameP =listUp.get(0).getOilName();
  488. }
  489. //油价
  490. if(listUp.get(0).getOrderLiters() !=null && listUp.get(0).getOrderLiters() !=""){
  491. orderLitersP =listUp.get(0).getOrderLiters();
  492. }
  493. if(listUp.get(0).getOilPirce() !=null && listUp.get(0).getOilPirce() != "" ){
  494. oilPirceP =listUp.get(0).getOilPirce();
  495. }
  496. if(listUp.get(0).getReceivableAmt() !=null && listUp.get(0).getReceivableAmt().toString() !=""){
  497. receivableAmtP =listUp.get(0).getReceivableAmt().toString();
  498. }
  499. if(listUp.get(0).getDiscountAmt() != null && listUp.get(0).getDiscountAmt().toString() !=""){
  500. discountAmtP =listUp.get(0).getDiscountAmt().toString();
  501. }
  502. if(listUp.get(0).getAmt() !=null && listUp.get(0).getAmt().toString() !=""){
  503. amtP =listUp.get(0).getAmt().toString();
  504. }
  505. content1 = "<CB>支付小票--商户联</CB><BR>";
  506. content1 += "订单号:"+orderNoP+" <BR>";
  507. content1 += "时间:"+createdDateP+" <BR>";
  508. content1 += "油站:"+stationNameP+" <BR>";
  509. content1 += "油品: "+oilNameP+" <BR>";
  510. content1 += "油量: "+orderLitersP+" 升<BR>";
  511. content1 += "单价: "+oilPirceP+" L/元<BR>";
  512. content1 += "金额: "+receivableAmtP+" 元<BR>";
  513. content1 += "优惠: "+discountAmtP+" 元<BR>";
  514. content1 += "支付: "+amtP+" 元<BR>";
  515. content1 += "<BR>";
  516. content1 += "--------------------------------<BR>";
  517. content1 += "<BR>";
  518. content2 = "<CB>支付小票--顾客联</CB><BR>";
  519. content2 += "订单号:"+orderNoP+" <BR>";
  520. content2 += "时间:"+createdDateP+"<BR>";
  521. content2 += "油站:"+stationNameP+" <BR>";
  522. content2 += "油品: "+oilNameP+" <BR>";
  523. content2 += "油量: "+orderLitersP+" 升<BR>";
  524. content2 += "单价: "+oilPirceP+" L/元<BR>";
  525. content2 += "金额: "+receivableAmtP+" 元<BR>";
  526. content2 += "优惠: "+discountAmtP+" 元<BR>";
  527. content2 += "支付: "+amtP+" 元<BR>";
  528. content2 += "<BR>";
  529. //获取打印机编号
  530. //sn = "921611605"; //测试打印机 sn:921611605 key:72338zma
  531. Map params =new HashMap();
  532. params.put("stationId", listUp.get(0).getStationId());
  533. params.put("oilGunNo", listUp.get(0).getOilGun());
  534. Map m = stationOilGunService.getPrinterSnByStationIdAndOilGunNo(params);
  535. if(m.containsKey("printerSn") && m.get("printerSn").toString()!= null && m.get("printerSn").toString()!=""){
  536. sn = m.get("printerSn").toString();
  537. // //查询打印机的状态
  538. // JSONObject jsonPrintStatus = JSONObject.parseObject(FeiEPrinterUtil.queryPrinterStatus(sn));
  539. // if(jsonPrintStatus.getString("data").equals("\\u5728\u7ebf\\uff0c\\u5de5\\u4f5c\\u72b6\u6001\\u6b63\\u5e38\\u3002")){
  540. // logger.info("打印机在线,工作状态正常:" + jsonPrintStatus.toString());
  541. //开始打印
  542. String printInfo = FeiEPrinterUtil.printReceipt(sn, content1 + content2);
  543. JSONObject jsonObject = JSONObject.parseObject(printInfo);
  544. if(jsonObject.getString("msg").equals("ok")){
  545. logger.info("打印成功:" + jsonObject.toString());
  546. //如果打印成功 添加小票数量
  547. PayOrder p = new PayOrder();
  548. p.setPrintCount(1);
  549. p.setOrderNo(ordNo);
  550. payOrderService.getUpdatePayOrder(p);
  551. }
  552. // }else if(jsonPrintStatus.getString("data").equals("\\u79bb\\u7ebf\\u3002")){
  553. // logger.info("打印机离线:" + jsonPrintStatus.toString());
  554. // }else if(jsonPrintStatus.getString("data").equals("\\u5728\\u7ebf\\uff0c\\u5de5\\u4f5c\\u72b6\\u6001\\u4e0d\\u6b63\\u5e38\\u3002")){
  555. // logger.info("打印机在线,纸异常: "+jsonPrintStatus.toString());
  556. // }
  557. }else {
  558. logger.info("请正确配置打印机");
  559. }
  560. }
  561. }
  562. }
  563. }
  564. }else {
  565. logger.info("验签失败");
  566. req.put("code","fail");
  567. req.put("msg","失败");
  568. }
  569. }
  570. }