123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670 |
- package com.platform.yijia.controller;
- import com.alibaba.fastjson.JSON;
- import com.alibaba.fastjson.JSONObject;
- import com.alibaba.fastjson.parser.Feature;
- import com.google.gson.Gson;
- import com.platform.yijia.param.request.*;
- import com.platform.yijia.pojo.AppUserInfo;
- import com.platform.yijia.pojo.CustomerManage;
- import com.platform.yijia.pojo.PayOrder;
- import com.platform.yijia.service.AppUserInfoService;
- import com.platform.yijia.service.PayOrderService;
- import com.platform.yijia.service.StationOilGunService;
- import com.platform.yijia.utils.*;
- import org.apache.commons.lang3.StringUtils;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- import org.springframework.stereotype.Controller;
- import org.springframework.web.bind.annotation.*;
- import javax.annotation.Resource;
- import java.math.BigDecimal;
- import java.text.ParseException;
- import java.text.SimpleDateFormat;
- import java.util.*;
- @Controller
- @RequestMapping("/api")
- public class PayController {
- private static Logger logger =(Logger) LoggerFactory.getLogger(PayController.class);
- @Resource
- private PayOrderService payOrderService;
- @Resource
- private AppUserInfoService appUserInfoService;
- @Resource
- private StationOilGunService stationOilGunService;
- /***
- * 微信子商户支付接口
- * @param weChatPaySetRequest
- * @return
- */
- @RequestMapping(value = "/weChatPaySet", consumes = "application/json", method = RequestMethod.POST)
- @ResponseBody
- public String weChatPaySet(@RequestBody WeChatPaySetRequest weChatPaySetRequest){
- Gson gson = new Gson();
- ResultData resultData = null; //返回结果
- try {
- String type = weChatPaySetRequest.getType(); //获取配置类型
- JSONObject reqData = new JSONObject(); //微信子商户支付参数配置
- reqData.put("mno", weChatPaySetRequest.getMno()); //商编
- reqData.put("subMchIdsubMchId", weChatPaySetRequest.getSubMchIdsubMchId()); //获取微信子商号
- if(type != null && type !=""){
- reqData.put("type", type);
- //根据类型设置必传参数
- switch (type){
- case "01": //支付Appid
- reqData.put("accountType", weChatPaySetRequest.getAccountType()); // 支付Appid类型 配置类型为01时必传
- reqData.put("subAppid", weChatPaySetRequest.getSubAppid()); // 支付Appid 配置类型为01,02时必传
- break;
- case "02": //关注Appid
- reqData.put("subAppid", weChatPaySetRequest.getSubAppid()); // 支付Appid 配置类型为01,02时必传
- reqData.put("subscribeAppid", weChatPaySetRequest.getSubscribeAppid()); // 推荐关注公众号Appid 配置类型为02时与推荐关注 小程序Appid二选一
- reqData.put("receiptAppid", weChatPaySetRequest.getReceiptAppid()); // 推荐关注小程序Appid 配置类型为02时与推荐关注 公众号Appid二选一
- break;
- case "03": //jsapi授权目录
- reqData.put("jsapiPath", weChatPaySetRequest.getJsapiPath()); // jsapi授权目录 配置类型为03时必传
- break;
- }
- }
- String sxfPay = SXFPaySign.getSXFPay(reqData); //封装传参信息,增加公共信息,增加业务信息
- logger.debug("参数信息:"+ sxfPay);
- System.out.println("req:" + sxfPay);
- //此处不要改变reqData里面值的顺序用LinkedHashMap
- HashMap reqMap = JSON.parseObject(sxfPay, LinkedHashMap.class, Feature.OrderedField);
- //组装加密串
- String signContent = RSASignature.getOrderContent(reqMap);
- System.out.println("拼接后的参数:" + signContent);
- logger.debug("拼接后的参数:"+signContent);
- //sign
- String sign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
- reqMap.put("sign", sign);
- String reqStr = JSON.toJSONString(reqMap);
- System.out.println("请求参数:" + reqMap);
- System.out.println("请求参数:" + reqStr);
- //String url = "https://openapi-test.tianquetech.com/merchant/weChatPaySet/addConf"; //测试环境
- String url = "https://openapi.tianquetech.com/merchant/weChatPaySet/addConf"; //生产环境
- //访问第三方接口
- String resultJson = HttpUtils.connectPostUrl(url, reqStr);
- System.out.println("返回信息:" + resultJson);
- // logger.debug("返回信息:"+resultJson);
- //不要对reqData排序 所以用LinkedHashMap
- HashMap<String, Object> result = JSON.parseObject(resultJson, LinkedHashMap.class, Feature.OrderedField);
- if ("0000".equals(result.get("code"))) {
- //验签
- String signResult = result.get("sign").toString();
- result.remove("sign");
- String resultStr = RSASignature.getOrderContent(result);
- System.out.println(resultStr);
- //sign
- String resultSign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
- System.out.println("resultSign:" + resultSign);
- //组装加密串
- if (RSASignature.doCheck(resultStr, signResult, SXFPaySign.sxfPublic)) {
- System.out.println("===================验签成功==============");
- }
- }
- resultData=ResultData.success(result);
- } catch (Exception e) {
- resultData=ResultData.error(CodeMsg.YEWU_FAIL,"支付失败");
- e.printStackTrace();
- }
- return gson.toJson(resultData);
- }
- /**
- * 支付接口,前台上传支付信息,支付数据落地生产订单,调用随行付支付接口
- * @param
- * @return
- */
- @RequestMapping(value = "/getJhPayInfo", consumes = "application/json", method = RequestMethod.POST)
- @ResponseBody
- public String getJhPayInfo(@RequestBody PayInfoRequest payInfoRequest){
- Gson gson =new Gson();
- ResultData resultData =null;
- //String token=payInfoRequest.getToken();//token
- String openId = payInfoRequest.getOpenId(); //用户openId
- String userType=payInfoRequest.getUserType();//用户登录类型 1 公众号。2 小程序
- String mno=payInfoRequest.getMno();//获取商户号
- Integer orderId =payInfoRequest.getOrderId();
- //根据token 和登录类型 身份验证
- AppUserInfo appUserInfo =new AppUserInfo();
- //订单类型 是小程序还是公众号
- appUserInfo.setUserType(userType);
- if(userType.equals("1")){
- //1 是公众号
- appUserInfo.setBlogOpenid(openId);
- }else if(userType.equals("2")){
- //2是小程序
- appUserInfo.setMinaOpenid(openId);
- }
- List<AppUserInfo> appUserInfoList =appUserInfoService.Authentication(appUserInfo);
- if(appUserInfoList!=null&&appUserInfoList.size()==1){
- //调用聚合支付
- try{
- //根据订单号查询订单信息
- PayOrder payOrder=payOrderService.searchPayOrder(orderId);
- if(payOrder!=null){
- //将业务参数存放在 JSON 对象中
- JSONObject reqData = new JSONObject();
- reqData.put("ordNo", payOrder.getOrderNo()); //商户订单号
- reqData.put("mno", mno); //商户编号
- //reqData.put("subMechId", ""); //子商户号
- //reqData.put("amt", payOrder.getAmt()); //订单总金额
- reqData.put("amt", "0.01");
- //reqData.put("discountAmt", ""); //参与优惠金额
- //reqData.put("unDiscountAmt", ""); //不参与优惠金额
- reqData.put("payType", "WECHAT"); //支付渠道
- if(userType.equals("1")){
- //1 是公众号
- reqData.put("payWay", "02"); //支付方式 02 公众号/服 务窗/js支付 03 小程序
- reqData.put("userId", appUserInfoList.get(0).getBlogOpenid()); //用户号 微信:openid; 支付宝:userid;银联:userid;微信&支付宝必传,银联js为非必传
- }else if(userType.equals("2")){
- //2是小程序
- reqData.put("payWay", "03"); //支付方式 02 公众号/服 务窗/js支付 03 小程序
- reqData.put("userId", appUserInfoList.get(0).getMinaOpenid()); //用户号 微信:openid; 支付宝:userid;银联:userid;微信&支付宝必传,银联js为非必传
- }
- //reqData.put("timeExpire", "10"); //订单失效时间, 以分钟为单位
- //reqData.put("limitPay", "00"); //限制卡类型: 00-全部 01-限定不能使 用信用卡支付 默认值 00
- reqData.put("subject", "聚合支付测试"); //订单标题
- //reqData.put("hbFqNum", "6"); //花呗分期数,仅可上送 6 或 12
- reqData.put("tradeSource", "01"); //交易来源 01服务商,02收银台,03硬件
- reqData.put("trmIp", "172.16.2.1");//商家ip地址
- // reqData.put("customerIp", ""); //持卡人ip地址,银联js支付时必传
- //reqData.put("subAppid", "wx24210004370ec43b"); //微信子公众号
- //reqData.put("outFrontUrl", ""); //js 支付,前台 成功通知地址
- //reqData.put("outFrontFailUrl", ""); //js 支付,前台 事变通知地址
- reqData.put("notifyUrl", "https://www.huijy.net/api/getCallback"); //回调地址
- //reqData.put("needReceipt", "00"); //电子发票功能 微信开具电子 发票使用
- //reqData.put("ledgerAccountFlag", "00"); //是否做分账 分账交易使 用;00:做; 01:不做;不传默认为不做分账
- //reqData.put("ledgerAccountEffectTime", "00"); //分账有效时间 单位为天;是 否做分账选择 00 时该字段必传
- // reqData.put("ruleId", "00"); //同 步 分 账 规 则 id
- // reqData.put("fusruleId", "00"); //同步分账规则
- //reqData.put("ylTrmNo", ""); //银联终端号
- //reqData.put("terminalId", ""); //TQ机具编号
- //reqData.put("deviceNo ", "1111"); //设备号
- // reqData.put("identityFlag", ""); //是否是实名支付
- // reqData.put("buyerIdType", "IDCARD"); //证件类型
- // reqData.put("buyerIdNo", "410523198701054018"); //证件号
- // reqData.put("buyerName", "张三"); //买家姓名
- // reqData.put("mobileNum", ""); //手机号
- // reqData.put("extend", ""); //备用
- String req= SXFPaySign.getSXFPay(reqData);
- logger.debug("参数信息:"+req);
- System.out.println("req:" + req);
- //此处不要改变reqData里面值的顺序用LinkedHashMap
- HashMap reqMap = JSON.parseObject(req, LinkedHashMap.class, Feature.OrderedField);
- //组装加密串
- String signContent = RSASignature.getOrderContent(reqMap);
- System.out.println("拼接后的参数:" + signContent);
- logger.debug("拼接后的参数:"+signContent);
- //sign
- String sign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
- System.out.println("============签名:" + sign);
- reqMap.put("sign", sign);
- String reqStr = JSON.toJSONString(reqMap);
- System.out.println("请求参数:" + reqMap);
- System.out.println("请求参数:" + reqStr);
- //调用第三方接口地址
- //String url = "https://openapi-test.tianquetech.com/order/jsapiScan";//测试地址
- String url = "https://openapi.suixingpay.com/order/jsapiScan";//生产地址
- String resultJson = HttpUtils.connectPostUrl(url, reqStr);
- System.out.println("返回信息:" + resultJson);
- // logger.debug("返回信息:"+resultJson);
- //不要对reqData排序 所以用LinkedHashMap
- HashMap<String, Object> result = JSON.parseObject(resultJson, LinkedHashMap.class, Feature.OrderedField);
- if ("0000".equals(result.get("code"))) {
- //验签
- String signResult = result.get("sign").toString();
- result.remove("sign");
- String resultStr = RSASignature.getOrderContent(result);
- System.out.println(resultStr);
- //sign
- String resultSign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
- System.out.println("resultSign:" + resultSign);
- //组装加密串
- if (RSASignature.doCheck(resultStr, signResult, SXFPaySign.sxfPublic)) {
- System.out.println("===================验签成功==============");
- }
- }
- resultData=ResultData.success(result);
- }else {
- resultData=ResultData.error(CodeMsg.YEWU_FAIL,"未查询到订单");
- }
- }catch (Exception e){
- resultData=ResultData.error(CodeMsg.YEWU_FAIL,"订单支付失败");
- e.printStackTrace();
- }
- }else{
- //返回失败支付失败信息
- resultData=ResultData.error(CodeMsg.USER_NOT_EXSIST);
- }
- return gson.toJson(resultData);
- }
- /**
- * 验证商户信息查询
- */
- @RequestMapping(value = "/getJhPayMnoInfo", method = RequestMethod.GET)
- @ResponseBody
- public String getJhPayMnoInfo(@RequestParam String mno){
- try {
- JSONObject reqData = new JSONObject();
- reqData.put("mno", mno); //商户编号
- String req = SXFPaySign.getSXFPay(reqData);
- logger.debug("参数信息:" + req);
- System.out.println("req:" + req);
- //此处不要改变reqData里面值的顺序用LinkedHashMap
- HashMap reqMap = JSON.parseObject(req, LinkedHashMap.class, Feature.OrderedField);
- //组装加密串
- String signContent = RSASignature.getOrderContent(reqMap);
- System.out.println("拼接后的参数:" + signContent);
- logger.debug("拼接后的参数:" + signContent);
- //sign
- String sign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
- System.out.println("============签名:" + sign);
- reqMap.put("sign", sign);
- String reqStr = JSON.toJSONString(reqMap);
- System.out.println("请求参数:" + reqMap);
- System.out.println("请求参数:" + reqStr);
- //调用第三方接口地址
- //String url = "https://openapi-test.tianquetech.com/merchant/merchantInfoQuery";//测试地址
- String url = "https://openapi.tianquetech.com/merchant/merchantInfoQuery";//生产地址
- String resultJson = HttpUtils.connectPostUrl(url, reqStr);
- HashMap<String, Object> result = JSON.parseObject(resultJson, LinkedHashMap.class, Feature.OrderedField);
- if ("0000".equals(result.get("code"))) {
- // //验签
- // String signResult = result.get("sign").toString();
- // result.remove("sign");
- // String resultStr = RSASignature.getOrderContent(result);
- // System.out.println(resultStr);
- // //sign
- // String resultSign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
- // System.out.println("resultSign:" + resultSign);
- // //组装加密串
- // if (RSASignature.doCheck(resultStr, signResult, SXFPaySign.sxfPublic)) {
- // System.out.println("===================验签成功==============");
- // }
- }
- }catch (Exception e){
- e.printStackTrace();
- }
- return "";
- }
- /**
- * 关单接口
- */
- @RequestMapping(value = "/getPayOrderClose", consumes = "application/json", method = RequestMethod.POST)
- @ResponseBody
- public String getPayOrderClose(@RequestBody PayCloseRequestParamter payCloseRequestParamter) {
- String results="";
- Gson gson =new Gson();
- String mno=payCloseRequestParamter.getMno();
- String origOrderNo=payCloseRequestParamter.getOrigOrderNo();
- String origUuid=payCloseRequestParamter.getOrigUuid();
- String token=payCloseRequestParamter.getToken();
- String userType=payCloseRequestParamter.getUserType();
- boolean flag =appUserInfoService.selectAppUserInfo(token,userType);
- ResultData resultData =null;
- if(flag){
- try {
- JSONObject reqData = new JSONObject();
- reqData.put("mno",mno); //商户编号
- reqData.put("origOrderNo",origOrderNo);//系统商户订单号
- reqData.put("origUuid", origUuid);//随行付订单号
- String req= SXFPaySign.getSXFPay(reqData);
- //此处不要改变reqData里面值的顺序用LinkedHashMap
- HashMap reqMap = JSON.parseObject(req, LinkedHashMap.class, Feature.OrderedField);
- //组装加密串
- String signContent = RSASignature.getOrderContent(reqMap);
- System.out.println("拼接后的参数:" + signContent);
- //sign
- String sign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
- System.out.println("============签名:" + sign);
- reqMap.put("sign", sign);
- String reqStr = JSON.toJSONString(reqMap);
- System.out.println("请求参数:" + reqMap);
- System.out.println("请求参数:" + reqStr);
- //调用第三方接口地址
- // String url = "https://openapi-test.tianquetech.com/query/close";//测试地址
- String url = "https://openapi.tianquetech.com/query/close";//生产地址
- String resultJson = HttpUtils.connectPostUrl(url, reqStr);
- System.out.println("返回信息:" + resultJson);
- //不要对reqData排序 所以用LinkedHashMap
- HashMap<String, Object> result = JSON.parseObject(resultJson, LinkedHashMap.class, Feature.OrderedField);
- if ("0000".equals(result.get("code"))) {
- //验签
- String signResult = result.get("sign").toString();
- result.remove("sign");
- String resultStr = RSASignature.getOrderContent(result);
- System.out.println(resultStr);
- //sign
- String resultSign = RSASignature.encryptBASE64(RSASignature.sign(signContent,SXFPaySign.privateKey));
- System.out.println("resultSign:" + resultSign);
- //组装加密串
- if (RSASignature.doCheck(resultStr, signResult, SXFPaySign.sxfPublic)) {
- System.out.println("===================验签成功==============");
- }
- }
- resultData=ResultData.success(result);
- }catch (Exception e){
- resultData=ResultData.error(CodeMsg.YEWU_FAIL,"关闭订单失败");
- e.printStackTrace();
- }
- }else{
- resultData=ResultData.error(CodeMsg.USER_NOT_EXSIST);
- }
- return gson.toJson(resultData);
- }
- /**
- * 异步回调通知
- */
- @RequestMapping(value = "/getCallback", consumes = "application/json", method = RequestMethod.POST)
- @ResponseBody
- public void getCallback(@RequestBody JSONObject request){
- logger.info("-------------------------------回调开始----------------------------------------------");
- logger.info("回调返回过来的参数"+request);
- logger.info("ordNo信息:" + request.get("ordNo").toString());
- logger.info("sign信息:" + request.get("sign").toString());
- Gson gson =new Gson();
- String sxfUuid=request.get("sxfUuid").toString(); //随行付落单号
- String payWay=request.get("payWay").toString(); //随行付交易方式
- String payTime=request.get("payTime").toString(); //随行付交易时间
- String uuid=request.get("uuid").toString(); //随行付交易流水号
- String mno=request.get("mno").toString();//发起交易的商户编号
- String ordNo=request.get("ordNo").toString();//商户生成的订单号
- String amt=request.get("amt").toString();//金额
- String buyerId=request.get("buyerId").toString();//用户登录
- String transactionId=request.get("transactionId").toString();//用户登录
- String drType=request.get("drType").toString();//借贷记标识 1-借,2-贷,3-其他
- String payType=request.get("payType").toString();//对订单的描述,取值范围:WECHAT:微信,ALIPAY:支付宝,UNIONPAY:
- String payBank=request.get("payBank").toString();//付款银行银行编码,例如 ICBC
- String pointAmount=request.get("pointAmount").toString();//代金券金额
- String totalOffstAmt=request.get("totalOffstAmt").toString();//消 费 者 付 款金额
- String settleAmt=request.get("settleAmt").toString();//商家入账金额
- String timeStamp=request.get("timeStamp").toString();//响应时间
- String sign=request.get("sign").toString();//签名
- String bizCode=request.get("bizCode").toString();//业务返回码
- String bizMsg=request.get("bizMsg").toString();//业 务 返 回 信息
- String openid=request.get("openid").toString();//微 信 或 支 付宝身份id()opendid userid
- String channelId=request.get("channelId").toString();//渠道商户号
- String subMechId=request.get("subMechId").toString();//子商户号
- String finishTime=request.get("finishTime").toString();//交易完成时间
- String clearDt=request.get("clearDt").toString();
- String settlementBatchNo=request.get("settlementBatchNo").toString();
- //String origOrdNo=request.get("origOrdNo").toString();//反交易退款异步通知
- //String origUuid=request.get("origUuid").toString();//token
- //String scene=request.get("scene").toString();//用户登录
- //String buyerAccount=request.get("buyerAccount").toString();//
- //String realRefundAmount=request.get("realRefundAmount").toString();//商家出账金额
- //String recFeeAmt=request.get("recFeeAmt").toString();//交易手续费
- //String recFeeRate=request.get("recFeeRate").toString();//交易手续费率
- //String refBuyerAmt=request.get("refBuyerAmt").toString();//消 费 者 到 账金额
- //String extend = extend=request.get("extend").toString();//备用
- //将业务参数存放在 JSON 对象中
- JSONObject reqData = new JSONObject();
- reqData.put("sxfUuid",sxfUuid);
- reqData.put("payWay",payWay);
- reqData.put("payTime",payTime);
- reqData.put("uuid",uuid);
- reqData.put("mno",mno);
- reqData.put("ordNo",ordNo);
- reqData.put("amt",amt);
- reqData.put("buyerId",buyerId);
- reqData.put("transactionId",transactionId);
- reqData.put("drType",drType);
- reqData.put("payType",payType);
- reqData.put("payBank",payBank);
- reqData.put("pointAmount",pointAmount);
- reqData.put("totalOffstAmt",totalOffstAmt);
- reqData.put("settleAmt",settleAmt);
- reqData.put("timeStamp",timeStamp);
- reqData.put("bizCode",bizCode);
- reqData.put("bizMsg",bizMsg);
- reqData.put("openid",openid);
- reqData.put("channelId",channelId);
- reqData.put("subMechId",subMechId);
- reqData.put("finishTime",finishTime);
- reqData.put("clearDt",clearDt);
- reqData.put("settlementBatchNo",settlementBatchNo);
- //reqData.put("realRefundAmount",realRefundAmount);
- //reqData.put("recFeeAmt",recFeeAmt);
- //reqData.put("recFeeRate",recFeeRate);
- //reqData.put("buyerAccount",buyerAccount);
- //reqData.put("origOrdNo",origOrdNo);
- //reqData.put("origUuid",origUuid);
- //reqData.put("scene",scene);
- //reqData.put("refBuyerAmt",refBuyerAmt);
- //reqData.put("extend",extend);
- //根据回调信息,先进行验签,验签后修改状态
- logger.info("打印参数信息"+gson.toJson(reqData));
- //不要对reqData排序 所以用LinkedHashMap
- HashMap<String, Object> result = JSON.parseObject(gson.toJson(reqData), LinkedHashMap.class, Feature.OrderedField);
- //验签
- String resultStr = RSASignature.getOrderContent(result);
- JSONObject req = new JSONObject();
- System.out.println(resultStr);
- if (RSASignature.doCheck(resultStr, sign, SXFPaySign.sxfPublic)) {
- logger.info("验签成功");
- //验签成功,修改订单状态
- List<PayOrder> list = payOrderService.getPayOrderList(ordNo);
- logger.info("根据订单号,查询订单"+gson.toJson(list));
- if (list != null && list.size() == 1) {
- String status = list.get(0).getStatus();
- //状态为未支付 0 修改状态为1已支付
- if (status.equals("0")) {
- PayOrder payOrder = new PayOrder();
- payOrder.setOrderNo(ordNo);
- payOrder.setStatus("1");
- payOrder.setPayDate(new Date()); //支付时间
- payOrder.setReceivedAmt(Double.valueOf(settleAmt)); //settleAmt商家入账金额
- //修改订单状态
- int count = payOrderService.getUpdatePayOrder(payOrder);
- if(count == 1){
- req.put("code","success");
- req.put("msg","修改订单状态成功");
- logger.info(req.toString());
- //将用户消费的信息插入顾客表
- Map<String, Object> infoMap = payOrderService.getOrderInfoAndUserInfoByOrderNo(payOrder);
- //手机号必须有
- if(infoMap != null && infoMap.containsKey("mobilePhone") && infoMap.get("mobilePhone") !=null ){
- //存放客户信息
- CustomerManage customerManage = new CustomerManage();
- String userType = infoMap.get("userType").toString();
- Date blogRegTime = null; //公众号注册时间
- Date minaRegTime = null; //小程序注册时间
- switch (userType){
- case "1":
- customerManage.setBlogOpenid(infoMap.get("blogOpenid").toString());
- customerManage.setBlogUserId((Integer) infoMap.get("userId"));
- customerManage.setPhoneNumber(infoMap.get("mobilePhone").toString());
- blogRegTime = (Date) infoMap.get("registeDate");
- break;
- case "2":
- customerManage.setMinaOpenid(infoMap.get("minaOpenid").toString());
- customerManage.setMinaUserId((Integer) infoMap.get("userId"));
- customerManage.setPhoneNumber(infoMap.get("mobilePhone").toString());
- minaRegTime = (Date) infoMap.get("registeDate");
- break;
- }
- //判断公众号和小程序时间取最早的时间
- if(blogRegTime !=null && minaRegTime != null){
- if(blogRegTime.compareTo(minaRegTime) >0){
- customerManage.setRegtime(minaRegTime);
- }else if(blogRegTime.compareTo(minaRegTime) <0){
- customerManage.setRegtime(blogRegTime);
- }else if(blogRegTime.compareTo(minaRegTime) ==0){
- //相等时随便取一个
- customerManage.setRegtime(minaRegTime);
- }
- }else if(blogRegTime == null){
- customerManage.setRegtime(minaRegTime);
- }else if(minaRegTime == null){
- customerManage.setRegtime(blogRegTime);
- }
- customerManage.setStationId(Integer.valueOf(infoMap.get("stationId").toString())); //油站ID
- customerManage.setOilName(infoMap.get("oilName").toString()); //油品名称
- customerManage.setStationName(infoMap.get("stationName").toString()); //存入油站名称
- //已存在用户信息 existCustomer
- CustomerManage existCustomer = payOrderService.isExistCustomer(customerManage);
- logger.info("查询出客户是否存在数据 null 表示没有" + existCustomer);
- //判断该用户是否已存在
- if(existCustomer != null){ //存在该用户时更新
- //此处if放null处理
- if(existCustomer.getAmt() !=null){
- //存入金额 累加原来金额
- customerManage.setAmt(existCustomer.getAmt().add(BigDecimal.valueOf((Double) infoMap.get("amt"))));
- }else {
- customerManage.setAmt(BigDecimal.valueOf((Double) infoMap.get("amt")));
- }
- if(existCustomer.getLiters() !=null){
- //存入升数 累加原来升数
- customerManage.setLiters(existCustomer.getLiters().add(BigDecimal.valueOf((Double) infoMap.get("orderLiters"))));
- }else {
- customerManage.setLiters(BigDecimal.valueOf((Double) infoMap.get("orderLiters")));
- }
- logger.info("存在客户 更新时参数: " + customerManage.getPhoneNumber());
- //存在 更新
- payOrderService.updateCustomer(customerManage);
- }else{
- customerManage.setAmt(BigDecimal.valueOf((Double) infoMap.get("amt"))); //存入金额
- customerManage.setLiters(BigDecimal.valueOf((Double) infoMap.get("orderLiters"))); //存入升数
- //不存在 新增
- logger.info("不存在客户 新增时参数: " + customerManage.toString());
- payOrderService.insertCustomer(customerManage);
- }
- }else{
- logger.info("该用户无手机号!");
- }
- //开始打印
- List<PayOrder> listUp = payOrderService.getPayOrderList(ordNo);
- String content1;
- String content2;
- String orderNoP = "";
- String createdDateP ="";
- String stationNameP ="";
- String oilNameP ="";
- String orderLitersP ="";
- String oilPirceP ="";
- String receivableAmtP = "";
- String discountAmtP = "";
- String amtP = "";
- String sn; //打印机编号
- if(listUp != null && listUp.size() == 1){
- logger.info("要打印小票的订单信息: "+ listUp);
- if(StringUtils.isNotBlank(listUp.get(0).getOrderNo())){
- orderNoP =listUp.get(0).getOrderNo();
- }
- if(listUp.get(0).getCreatedDate() !=null && listUp.get(0).getCreatedDate().toString() !=""){
- //格式化日期
- SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- createdDateP =sdf.format(listUp.get(0).getCreatedDate());
- }
- if(StringUtils.isNotBlank(listUp.get(0).getStationName())){
- stationNameP =listUp.get(0).getStationName();
- }
- if(StringUtils.isNotBlank(listUp.get(0).getOilName())){
- oilNameP =listUp.get(0).getOilName();
- }
- //油价
- if(listUp.get(0).getOrderLiters() !=null && listUp.get(0).getOrderLiters() !=""){
- orderLitersP =listUp.get(0).getOrderLiters()+"";
- }
- if(listUp.get(0).getOilPirce() !=null && listUp.get(0).getOilPirce() != "" ){
- oilPirceP =listUp.get(0).getOilPirce()+"";
- }
- if(listUp.get(0).getReceivableAmt() !=null && listUp.get(0).getReceivableAmt().toString() !=""){
- receivableAmtP =listUp.get(0).getReceivableAmt()+"";
- }
- if(listUp.get(0).getDiscountAmt() != null && listUp.get(0).getDiscountAmt().toString() !=""){
- discountAmtP =listUp.get(0).getDiscountAmt()+"";
- }
- if(listUp.get(0).getAmt() !=null && listUp.get(0).getAmt().toString() !=""){
- amtP =listUp.get(0).getAmt().toString()+"";
- }
- content1 = "<CB>支付小票--商户联</CB><BR>";
- content1 += "订单号:"+orderNoP+" <BR>";
- content1 += "时间:"+createdDateP+" <BR>";
- content1 += "油站:"+stationNameP+" <BR>";
- content1 += "油品: "+oilNameP+" <BR>";
- content1 += "油量: "+orderLitersP+" 升<BR>";
- content1 += "单价: "+oilPirceP+" L/元<BR>";
- content1 += "金额: "+receivableAmtP+" 元<BR>";
- content1 += "优惠: "+discountAmtP+" 元<BR>";
- content1 += "支付: "+amtP+" 元<BR>";
- content1 += "<BR>";
- content1 += "--------------------------------<BR>";
- content1 += "<BR>";
- content2 = "<CB>支付小票--顾客联</CB><BR>";
- content2 += "订单号:"+orderNoP+" <BR>";
- content2 += "时间:"+createdDateP+"<BR>";
- content2 += "油站:"+stationNameP+" <BR>";
- content2 += "油品: "+oilNameP+" <BR>";
- content2 += "油量: "+orderLitersP+" 升<BR>";
- content2 += "单价: "+oilPirceP+" L/元<BR>";
- content2 += "金额: "+receivableAmtP+" 元<BR>";
- content2 += "优惠: "+discountAmtP+" 元<BR>";
- content2 += "支付: "+amtP+" 元<BR>";
- content2 += "<BR>";
- //获取打印机编号
- //sn = "921611605"; //测试打印机 sn:921611605 key:72338zma
- Map params =new HashMap();
- params.put("stationId", listUp.get(0).getStationId());
- params.put("oilGunNo", listUp.get(0).getOilGun());
- Map m = stationOilGunService.getPrinterSnByStationIdAndOilGunNo(params);
- if(m.containsKey("printerSn") && m.get("printerSn").toString()!= null && m.get("printerSn").toString()!=""){
- sn = m.get("printerSn").toString();
- // //查询打印机的状态
- // JSONObject jsonPrintStatus = JSONObject.parseObject(FeiEPrinterUtil.queryPrinterStatus(sn));
- // if(jsonPrintStatus.getString("data").equals("\\u5728\u7ebf\\uff0c\\u5de5\\u4f5c\\u72b6\u6001\\u6b63\\u5e38\\u3002")){
- // logger.info("打印机在线,工作状态正常:" + jsonPrintStatus.toString());
- //开始打印
- String printInfo = FeiEPrinterUtil.printReceipt(sn, content1 + content2);
- JSONObject jsonObject = JSONObject.parseObject(printInfo);
- if(jsonObject.getString("msg").equals("ok")){
- logger.info("打印成功:" + jsonObject.toString());
- //如果打印成功 添加小票数量
- PayOrder p = new PayOrder();
- p.setPrintCount(1);
- p.setOrderNo(ordNo);
- payOrderService.getUpdatePayOrder(p);
- }
- // }else if(jsonPrintStatus.getString("data").equals("\\u79bb\\u7ebf\\u3002")){
- // logger.info("打印机离线:" + jsonPrintStatus.toString());
- // }else if(jsonPrintStatus.getString("data").equals("\\u5728\\u7ebf\\uff0c\\u5de5\\u4f5c\\u72b6\\u6001\\u4e0d\\u6b63\\u5e38\\u3002")){
- // logger.info("打印机在线,纸异常: "+jsonPrintStatus.toString());
- // }
- }else {
- logger.info("请正确配置打印机");
- }
- }
- }
- }
- }
- }else {
- logger.info("验签失败");
- req.put("code","fail");
- req.put("msg","失败");
- }
- }
- }
|