JDD-PAY-NEW/YijiaRestful/src/main/java/com/platform/yijia/controller/PayController.java

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.CustomerGradeServices;
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;
    @Resource
    private CustomerGradeServices customerGradeServices;

    /***
     * 微信子商户支付接口
     * @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());

                        //将用户消费的信息插入顾客表： 以手机号 油品名称 油站id为条件插入且存入 加油升数、实收金额、油站名称  根据订单号查询用户手机号
                        Map<String, Object> infoMap = payOrderService.getOrderInfoAndUserInfoByOrderNo(payOrder);   //获取该订单手机号、加油升数、实收金额、油站名称
                        //手机号必须有
                        if(infoMap != null && infoMap.containsKey("mobilePhone") && infoMap.get("mobilePhone") !=null ){
                            //存放客户信息
                            CustomerManage customerManage = new CustomerManage();
                            //存放查询用户信息
                            AppUserInfo appUserInfo = new AppUserInfo();
                            appUserInfo.setMobilePhone(infoMap.get("mobilePhone").toString());
                            //从客户信息表查询数据用于插入客户表 使用List原因：app_user_info存在小程序和公众号两种信息
                            List<AppUserInfo> appUserInfoList = payOrderService.getUserInfoByOpenId(appUserInfo);
                            Date blogRegTime = null;    //公众号注册时间
                            Date minaRegTime = null;    //小程序注册时间
                            if(appUserInfoList != null && appUserInfoList.size() >0){
                                for(AppUserInfo u : appUserInfoList){
                                    //向客户表插入小程序和公众号的openId 用户表ID 用户手机号 注册时间
                                    switch (u.getUserType()){
                                        case "1":
                                            customerManage.setBlogOpenid(u.getBlogOpenid());
                                            customerManage.setBlogUserId(u.getUserId());
                                            customerManage.setPhoneNumber(u.getMobilePhone());
                                            customerManage.setCustomerName(u.getBlogNickName());
                                            blogRegTime =u.getRegisteDate();
                                            break;
                                        case "2":
                                            customerManage.setMinaOpenid(u.getMinaOpenid());
                                            customerManage.setMinaUserId(u.getUserId());
                                            customerManage.setPhoneNumber(u.getMobilePhone());
                                            customerManage.setCustomerName(u.getBlogNickName());
                                            minaRegTime = u.getRegisteDate();
                                            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());

                                //用户等级设置 说明：每个油站只存在一种优惠方案。 立减满减在另一张表故作次条件判断，如果该油站没有设置优惠方案则不去存会员等级
                                List<Map> customerGradeInfo = customerGradeServices.getCustomerGradeList(infoMap);  //直降
                                if(customerGradeInfo != null && customerGradeInfo.size() >0){
                                    for (Map m: customerGradeInfo){
                                        if(Double.valueOf(customerManage.getAmt().toString()) >= Double.valueOf(m.get("memberConditStart").toString()) && Double.valueOf(customerManage.getAmt().toString()) < Double.valueOf(m.get("memberConditEnd").toString())){
                                            customerManage.setGrade(m.get("grade").toString());     //存入等级名称
                                            customerManage.setMemberId(m.get("id").toString());     //存入等级ID
                                        }
                                        break;
                                    }
                                }else {
                                    //立减满减
                                    List<Map> customerMarkertPlanList = customerGradeServices.getCustomerMarkertPlanList(infoMap);
                                    if(customerMarkertPlanList !=null && customerMarkertPlanList.size() >0){
                                        for(Map m: customerMarkertPlanList){
                                            if(Double.valueOf(customerManage.getAmt().toString()) >= Double.valueOf(m.get("discountAmt").toString())){
                                                customerManage.setGrade(m.get("grade").toString());     //存入等级名称
                                                customerManage.setMemberId(m.get("id").toString());     //存入等级ID
                                            }
                                            break;
                                        }
                                    }

                                }
                                //存在 更新
                                payOrderService.updateCustomer(customerManage);
                            }else{          //该客户不存在时插入
                                //用户等级设置 说明：每个油站只存在一种优惠方案。立减满减在另一张表故作此条件判断，如果该油站没有设置优惠方案则不去存会员等级
                                List<Map> customerGradeInfo = customerGradeServices.getCustomerGradeList(infoMap);  //直降
                                if(customerGradeInfo != null && customerGradeInfo.size() >0){
                                    for (Map m: customerGradeInfo){
                                        if(Double.valueOf(infoMap.get("amt").toString()) >= Double.valueOf(m.get("memberConditStart").toString()) && Double.valueOf(infoMap.get("amt").toString()) < Double.valueOf(m.get("memberConditEnd").toString())){
                                            customerManage.setGrade(m.get("grade").toString());     //存入等级名称
                                            customerManage.setMemberId(m.get("id").toString());     //存入等级ID
                                        }
                                        break;
                                    }
                                }else {
                                    //立减满减
                                    List<Map> customerMarkertPlanList = customerGradeServices.getCustomerMarkertPlanList(infoMap);
                                    if(customerMarkertPlanList !=null && customerMarkertPlanList.size() >0){
                                        for(Map m: customerMarkertPlanList){
                                            if(Double.valueOf(infoMap.get("amt").toString()) >= Double.valueOf(m.get("discountAmt").toString())){
                                                customerManage.setGrade(m.get("grade").toString());     //存入等级名称
                                                customerManage.setMemberId(m.get("id").toString());     //存入等级ID
                                            }
                                            break;
                                        }
                                    }
                                }
                                customerManage.setAmt(BigDecimal.valueOf((Double) infoMap.get("amt")));    //存入金额
                                customerManage.setLiters(BigDecimal.valueOf((Double) infoMap.get("orderLiters")));    //存入升数
                                //不存在 新增
                                logger.info("不存在客户 新增时参数: " + customerManage.toString());
                                payOrderService.insertCustomer(customerManage);
                            }

                            //打印机打印小票
                            String content1;
                            String content2;
                            String orderNoP = "";
                            String createdDateP ="";
                            String stationNameP ="";
                            String oilNameP ="";
                            String orderLitersP ="";
                            String oilPirceP ="";
                            String receivableAmtP = "";
                            String discountAmtP = "";
                            String amtP = "";
                            String mobilePhoneP = "";
                            String payWayP = "";
                            String sn;  //打印机编号
                                //logger.info("要打印小票的订单信息: "+ listUp);

                            if(StringUtils.isNotBlank(infoMap.get("orderNo").toString())){
                                orderNoP =infoMap.get("orderNo").toString();
                            }
                            if(infoMap.containsKey("createdDate") && infoMap.get("createdDate") !=null ){
                                //格式化日期
                                SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                                createdDateP =sdf.format(infoMap.get("createdDate"));
                            }
                            if(infoMap.containsKey("stationName") && infoMap.get("stationName") !=null ){
                                stationNameP =infoMap.get("stationName").toString();
                            }
                            if(infoMap.containsKey("oilName") && infoMap.get("oilName") !=null ){
                                oilNameP =infoMap.get("oilName").toString();
                            }
                            //加油升数
                            if(infoMap.containsKey("orderLiters") && infoMap.get("orderLiters") !=null ){
                                orderLitersP =infoMap.get("orderLiters")+"";
                            }
                            //油价
                            if(infoMap.containsKey("oilPirce") && infoMap.get("oilPirce") !=null ){
                                oilPirceP =infoMap.get("oilPirce")+"";
                            }
                            if(infoMap.containsKey("receivableAmt") && infoMap.get("receivableAmt") !=null ){
                                receivableAmtP =infoMap.get("receivableAmt")+"";
                            }
                            if(infoMap.containsKey("discountAmt") && infoMap.get("discountAmt") !=null ){
                                discountAmtP =infoMap.get("discountAmt")+"";
                            }
                            if(infoMap.containsKey("amt") && infoMap.get("amt") !=null ){
                                amtP =infoMap.get("amt")+"";
                            }
                            if(infoMap.containsKey("mobilePhone") && infoMap.get("mobilePhone") !=null ){
                                String phone =infoMap.get("mobilePhone")+"";
                                //手机号中间四位****代替
                                mobilePhoneP = phone.substring(0, 3) + "****" + phone.substring(7, phone.length());
                            }
                            if(infoMap.containsKey("payWay") && infoMap.get("payWay") !=null ){
                                if(infoMap.get("payWay").equals("02") || infoMap.get("payWay").equals("03")){
                                    payWayP ="微信";
                                }
                            }

                            content1 = "<CB>支付小票--顾客联</CB><BR>";
                            content1 += "订单号："+orderNoP+"  <BR>";
                            content1 += "时间："+createdDateP+" <BR>";
                            content1 += "油站："+stationNameP+"  <BR>";
                            content1 += "油品： "+oilNameP+"  <BR>";
                            content1 += "油量： "+orderLitersP+"  升<BR>";
                            content1 += "单价： "+oilPirceP+" L/元<BR>";
                            content1 += "<BOLD><B>原价： "+receivableAmtP+" 元</B></BOLD><BR>";
                            content1 += "优惠： "+discountAmtP+" 元<BR>";
                            content1 += "支付： "+amtP+" 元<BR>";
                            content1 += "支付方式： "+payWayP+" <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 += "<BOLD><B>原价： "+receivableAmtP+" 元</B></BOLD><BR>";
                            content2 += "优惠： "+discountAmtP+" 元<BR>";
                            content2 += "支付： "+amtP+" 元<BR>";
                            content2 += "手机号： "+mobilePhoneP+" <BR>";
                            content2 += "支付方式： "+payWayP+" <BR>";
                            content2 += "<BR>";
                            //获取打印机编号
                            //sn = "921611605";     //测试打印机 sn：921611605 key：72338zma
                            Map params  =new HashMap();
                            params.put("stationId", infoMap.get("stationId").toString());
                            params.put("oilGunNo", infoMap.get("oilGun").toString());
                            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="";    //打印信息
                                if(m.containsKey("printSetting") && m.get("printSetting").toString()!= null && m.get("printSetting").toString()!=""){
                                    switch (m.get("printSetting").toString()){
                                        case "1":   //1 客户联
                                            printInfo = FeiEPrinterUtil.printReceipt(sn, content1);
                                            break;
                                        case "2":   //2 商户联
                                            printInfo = FeiEPrinterUtil.printReceipt(sn, content2);
                                            break;
                                        case "3":   //3商户联和客户联
                                            printInfo = FeiEPrinterUtil.printReceipt(sn, content1 + content2);
                                            break;
                                    }
                                }
                                JSONObject jsonObject = JSONObject.parseObject(printInfo);
                                if(jsonObject != null && 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("该用户无手机号！");
                        }
                    }
                }
            }
        }else {
            logger.info("验签失败");
            req.put("code","fail");
            req.put("msg","失败");
        }
    }
}