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

package com.platform.yijia.controller;
import com.alibaba.fastjson.JSONObject;
import com.google.gson.Gson;
import com.platform.yijia.dao.PayOrderMapper;
import com.platform.yijia.param.request.PayOrderRequest;
import com.platform.yijia.pojo.*;
import com.platform.yijia.service.*;
import com.platform.yijia.utils.CodeMsg;
import com.platform.yijia.utils.ResultData;
import com.platform.yijia.utils.weixinapp.WxPushUtil;
import me.chanjar.weixin.mp.bean.template.WxMpTemplateData;
import org.apache.commons.lang3.StringUtils;
import org.apache.ibatis.javassist.util.HotSwapAgent;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.naming.ldap.HasControls;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.*;

@Controller
@RequestMapping("/demo")
public class PayOrderController {
    private static Logger logger =(Logger) LoggerFactory.getLogger(PayOrderController.class);
    @Resource
    private PayOrderService payOrderService;
    @Resource
    private AppUserInfoService appUserInfoService;
    @Resource
    private StationService stationService;
    @Resource
    private CustomerGradeServices customerGradeServices;
    @Resource
    private PayOrderMapper payOrderMapper;
    @Resource
    private ElectronicMembershipCardService electronicMembershipCardService;
    @Resource
    private WxPushUtil wxPushUtil;
    @Resource
    private IntegralRuleService integralRuleService;
    @Resource
    private CustomerPointsService customerPointsService;
    @Resource
    private CustomerPointsRecordService customerPointsRecordService;
    @Resource
    private GzhNewsTemplateService gzhNewsTemplateService;
    @Resource
    private CustomerManagerService customerManagerService;

    //一键支付，生成订单
    @RequestMapping(value = "/AddPayOrderInfo", consumes = "application/json", method = RequestMethod.POST)
    @ResponseBody
    public String  AddPayOrderInfo(@RequestBody PayOrderRequest payOrderRequest){
        logger.info("获取订单前端传来参数openID："+ payOrderRequest.getOpenId());
        logger.info("获取订单前端传来参数userType："+ payOrderRequest.getUserType());
        Gson gson =new Gson();
        ResultData resultData =null;
        //根据token 和登录类型 身份验证
        AppUserInfo appUserInfo =new AppUserInfo();
        //订单类型 是小程序还是公众号
        appUserInfo.setUserType(payOrderRequest.getUserType());
        if(payOrderRequest.getUserType().equals("1")){
            //1 是公众号
            appUserInfo.setBlogOpenid(payOrderRequest.getOpenId());
        }else if(payOrderRequest.getUserType().equals("2")){
            //2是小程序
            appUserInfo.setMinaOpenid(payOrderRequest.getOpenId());
        }
        List<AppUserInfo> appUserInfoList =appUserInfoService.Authentication(appUserInfo);
        //判断登录人员是否验证成功
        if(appUserInfoList!=null&&appUserInfoList.size()>0){
            PayOrder payOrder=new PayOrder();
            payOrder.setConsumer(appUserInfoList.get(0).getBlogNickName()); //昵称
            payOrder.setConsumerId(appUserInfoList.get(0).getUserId()); //用户id
            //添加订单信息，返回订单号
            String ordNo =payOrderService.AddPayOrderInfo(payOrderRequest, payOrder);
            if(ordNo.equals("0")){
                resultData=ResultData.error(CodeMsg.CHECK_DATA);
            }else if(ordNo.equals("1")){
                resultData=ResultData.error(CodeMsg.PARAMS_NUll);
            }else {
                resultData=ResultData.success(ordNo);
            }
        }else{
            //登录人验证失败
            resultData=ResultData.error(CodeMsg.USER_NOT_EXSIST);
        }
        return gson.toJson(resultData);
    }


    //小程序支付生成订单
    @RequestMapping(value = "/AddPayOrderInfoNew", consumes = "application/json", method = RequestMethod.POST)
    @ResponseBody
    @Transactional
    public String  AddPayOrderInfoNew(@RequestBody PayOrderRequest payOrderRequest){
        logger.info("获取订单前端传来参数openId："+ payOrderRequest.getOpenId());
        logger.info("获取订单前端传来参数userType："+ payOrderRequest.getUserType());
        Gson gson =new Gson();
        ResultData resultData =null;
        AppUserInfo appUserInfo =new AppUserInfo();
        appUserInfo.setUserType(payOrderRequest.getUserType());         //订单类型 是小程序还是公众号
        if(payOrderRequest.getUserType().equals("1")){
            appUserInfo.setBlogOpenid(payOrderRequest.getOpenId());     //1 是公众号
        }else if(payOrderRequest.getUserType().equals("2")){
            appUserInfo.setMinaOpenid(payOrderRequest.getOpenId());   //2是小程序
        }
        List<AppUserInfo> appUserInfoList =appUserInfoService.Authentication(appUserInfo);
        Map<String ,Object> resultMap = new HashMap<>();            //返回结果集
        //判断登录人员是否验证成功
        if(appUserInfoList!=null && appUserInfoList.size()>0){
            PayOrder payOrder = new PayOrder();
            payOrder.setConsumer(appUserInfoList.get(0).getBlogNickName());             //昵称
            payOrder.setConsumerId(appUserInfoList.get(0).getUserId());                 //用户id
            Random random = new Random();
            String result="";
            for(int i=0;i<6;i++){
                result+=random.nextInt(10);
            }
            String ordNo=System.nanoTime()+result;
            payOrder.setOrderNo(ordNo);                                             //订单号
            logger.info("生成的订单号：" + ordNo);
            payOrder.setDiscountCouponAmt(payOrderRequest.getDiscountCouponAmt());  //优惠劵金额
            payOrder.setDiscountCoupon(payOrderRequest.getDiscountCoupon());        //优惠券
            payOrder.setCarNo(payOrderRequest.getCarNo());                          //车牌号、
            payOrder.setCustomerGrade(payOrderRequest.getCustomerGrade());          //客户电话
            payOrder.setMemberNo(payOrderRequest.getMemberNo());                    //会员卡号
            payOrder.setMemberAmt(payOrderRequest.getMemberAmt());                  //会员支付金额
            //payOrder.setPrintCount(payOrderRequest.getPrintCount());              //小票数量
            payOrder.setScore(payOrderRequest.getScore());                          //积分
            payOrder.setStationId(payOrderRequest.getStationId());                  //油站id
            payOrder.setStatus("0");                                                //创建订单 未支付状态 0
            if(StringUtils.isNotBlank(payOrderRequest.getUserType())){
                String userType = payOrderRequest.getUserType();            //支付方式：02公众号，03小程序',
                switch (userType){
                    case "1":
                        payOrder.setPayWay("02");
                        break;
                    case "2":
                        payOrder.setPayWay("03");
                        break;
                }
            }
            payOrder.setCreatedDate(new Date());                    //创建时间
            payOrder.setOrderType(payOrderRequest.getOrderType());  //订单类型
            payOrder.setOilGun(payOrderRequest.getOilGun());        //油枪号
            //根据油站和油枪获取加油员和油品价格 油站名称
            HashMap<String, Object> params = new HashMap<>();
            params.put("oliGunNo", payOrderRequest.getOilGun());
            params.put("stationId", payOrderRequest.getStationId());
            String oilPersonnel = "";
            //使用list原因：一个枪号对应多个加油员场景
            List<Map> mapResultList = payOrderMapper.selectPersonelName(params);
            if(mapResultList != null && mapResultList.size() > 0){
                for (Map per : mapResultList){
                    if(per.containsKey("personelName") && per.get("personelName").toString() !=null && per.get("personelName").toString() !=""){
                        oilPersonnel += per.get("personelName").toString() +",";
                    }
                }
                if(oilPersonnel !=""){
                    payOrder.setOilPersonnel(oilPersonnel.substring(0, oilPersonnel.length()-1));   //加油员
                }
                if(mapResultList.get(0).containsKey("stationName") && mapResultList.get(0).get("stationName").toString() !="" && mapResultList.get(0).get("stationName").toString() !=null ){
                    payOrder.setStationName(mapResultList.get(0).get("stationName").toString());        //油站名称
                }
            }
            String orderType = payOrderRequest.getOrderType();                          //获取订单类型
            if(orderType.equals("1")){                                                  //订单类型是油品时计算
                resultMap = this.calculateAmt(payOrderRequest);                         //计算油价 加油升数 优惠金额 实收金额 优惠价格
                payOrder.setOilPirce(resultMap.get("oilPrice").toString());
                payOrder.setOrderLiters(resultMap.get("oilLiters").toString());
                payOrder.setDiscountAmt(Double.valueOf(resultMap.get("discountAmt").toString()));
                payOrder.setAmt(Double.valueOf(resultMap.get("amt").toString()));
            }
            payOrder.setReceivableAmt(payOrderRequest.getReceivableAmt());                //订单应收金额
            String oilName =payOrderRequest.getOilName();
            payOrder.setOilName(oilName);                   //油品名称
            switch (oilName){                               //根据油品名称存储油品类型 1.柴油 2 汽油
                case "92#":
                    payOrder.setOilType("1");
                    break;
                case "95#":
                    payOrder.setOilType("1");
                    break;
                case "97#":
                    payOrder.setOilType("1");
                    break;
                case "0#":
                    payOrder.setOilType("2");
                    break;
                case "-10#":
                    payOrder.setOilType("2");
                    break;
                case "-20#":
                    payOrder.setOilType("2");
                    break;
            }
            payOrder.setOilType(orderType);
            String stationCardEnabledFlag = electronicMembershipCardService.getStationCardEnabledFlag(payOrderRequest.getStationId());
            //查询油站是否开启电子会员卡功能
            if(stationCardEnabledFlag.equals("1")){
                String balance = this.selectCardBalance(payOrderRequest.getStationId(), oilName, appUserInfoList.get(0).getUnionId());
                resultMap.put("balance", balance);
            }
            StationInfo stationInfo = new StationInfo();
            stationInfo.setStationId(payOrderRequest.getStationId());
            StationInfo stationInfos = stationService.selectStationInfo(stationInfo);
            if(stationInfos !=null){
                //获取油站图片和名称
                resultMap.put("stationPic", stationInfos.getStationPic());
                resultMap.put("stationName", stationInfos.getStationName());
            }
            //payOrder.setPayType("wx");                          //支付类型
            switch (orderType){
                case "1":       //油品
                    payOrderMapper.insertSelective(payOrder);
                    resultMap.put("ordNo", ordNo);
                    break;
                case "2":       //非油品
                    Map<String, String> m = stationService.getStationAppIdAndAppSecret(payOrderRequest.getStationId());
                    if(m.containsKey("stationName") && m.get("stationName") !=null){
                        payOrder.setStationName(m.get("stationName"));
                    }
                    payOrder.setAmt(Double.valueOf(payOrderRequest.getReceivableAmt()));        //非油品金额
                    payOrder.setDiscountAmt(Double.valueOf(0));                                 //优惠金额
                    payOrder.setOilPirce(payOrderRequest.getReceivableAmt().toString());        //非油品价格
                    payOrder.setOrderLiters("0");
                    resultMap.put("discountAmt", "0");                                          //优惠价格
                    resultMap.put("amt", payOrderRequest.getReceivableAmt());                   //实收价格
                    resultMap.put("receivableAmt", payOrderRequest.getReceivableAmt());         //应收价格
                    resultMap.put("oilLiters", "0");
                    resultMap.put("discountPrice", "0");
                    payOrderMapper.insertSelective(payOrder);
                    resultMap.put("ordNo", ordNo);
                    break;
            }
            resultData = ResultData.success(resultMap);
        }else{
            //登录人验证失败
            resultData=ResultData.error(CodeMsg.USER_NOT_EXSIST);
        }
        return gson.toJson(resultData);
    }

    //查询用户电子会员卡余额
    public String  selectCardBalance(Integer stationId, String oilName, String unionId) {
        String cardOilsType ="";
        switch (oilName){                               //根据油品名称存储电子卡油品类型 1.柴油 2 汽油
            case "92#":
                cardOilsType ="1";
                break;
            case "95#":
                cardOilsType ="1";
                break;
            case "97#":
                cardOilsType ="1";
                break;
            case "0#":
                cardOilsType ="2";
                break;
            case "-10#":
                cardOilsType ="2";
                break;
            case "-20#":
                cardOilsType ="2";
                break;
        }
        CustomerElectronicCard customerElectronicCard = new CustomerElectronicCard();
        customerElectronicCard.setCardOilsType(cardOilsType);
        customerElectronicCard.setStationId(stationId);
        customerElectronicCard.setUnionId(unionId);
        CustomerElectronicCard electronicCardInfo = electronicMembershipCardService.getElectronicCardInfoByUnionId(customerElectronicCard);
        BigDecimal balance = null;
        if(electronicCardInfo !=null){
            balance = electronicCardInfo.getAmt();
        }
        return balance.toString();
    }

    /***
     * 计算订单金额
     * @return
     */
    public Map<String ,Object> calculateAmt(PayOrderRequest payOrderRequest){
        Map<String ,Object> resultMap = new HashMap<>();
        if(payOrderRequest.getReceivableAmt() !=null){  //应收金额
            Double receivableAmt = payOrderRequest.getReceivableAmt();  //应收金额 用户输入的金额
            Integer stationId = payOrderRequest.getStationId();         //油站ID
            //String oilGun = payOrderRequest.getOilGun();                //油枪号
            String oilName = payOrderRequest.getOilName();          //油品名称
            String openId = payOrderRequest.getOpenId();        //用户的openId
            String mobilePhone = payOrderRequest.getCustomerPhone();        //客户手机号
            //获取油品价格
            StationOilPrice stationOilPrice = new StationOilPrice();
            stationOilPrice.setStationId(stationId);
            stationOilPrice.setOilName(oilName);
            StationOilPrice oilPriceInfo = stationService.getStationOilPrice(stationOilPrice);
            String oilPrice = oilPriceInfo.getOilPrice();
            String stationNanme = oilPriceInfo.getStationNanme();
            BigDecimal oilLiters = null;
            BigDecimal discountAmt =null;
            BigDecimal discountPrice = null;
            BigDecimal amt = null;

            //resultMap.put("stationName", stationNanme);
            resultMap.put("oilPrice", oilPrice);        //油品价格
            resultMap.put("receivableAmt", receivableAmt);        //应收价格
            //该油站的优惠方式
            String stationDiscountWay = stationService.getStationDiscountWay(stationId.toString());
            Map<String ,Object> params = new HashMap<String, Object>();
            params.put("stationId", stationId);
            params.put("oilName", oilName);
            BigDecimal receivableAmt_b = new BigDecimal(receivableAmt); //传入的应收金额
            switch (stationDiscountWay){
                case "1":       //1.等级直降
                    //查询等级直降的优惠方式
                    params.put("mobilePhone", mobilePhone);
                    params.put("minaOpenid", openId);
                    //查询客户等级信息
                    List<Map<String, Object>> customerGradeInfo = customerGradeServices.getCustomerGradeInfo(params);
                    if(customerGradeInfo != null && customerGradeInfo.size() >0){   //已存在客户等级信息
                        //使用客户已存在的等级计算优惠
                        oilLiters = receivableAmt_b.divide(new BigDecimal(oilPrice),2, BigDecimal.ROUND_HALF_UP);
                        discountAmt = oilLiters.multiply(new BigDecimal(customerGradeInfo.get(0).get("gasoilDiscountLitre").toString()));
                        discountAmt = discountAmt.setScale(2, BigDecimal.ROUND_HALF_UP);
                        amt = receivableAmt_b.subtract(discountAmt);
                        discountPrice = amt.divide(oilLiters, 2, BigDecimal.ROUND_HALF_UP);
                        resultMap.put("discountAmt", discountAmt.doubleValue());
                        resultMap.put("amt", amt.doubleValue());
                        resultMap.put("oilLiters", oilLiters.doubleValue());
                        resultMap.put("discountPrice", discountPrice.doubleValue());
                    }else {
                        //不存在客户等级信息时，查询油站的客户等级直降优惠（查询结果根据会员成长值条件做升序查询）
                        List<Map> customerGradeList = customerGradeServices.getCustomerGradeList(params);
                        //如果存在
                        if(customerGradeList !=null && customerGradeList.size() >0){
                            //用户第一次购买 取等级最低初始会员的优惠条件计算
                            oilLiters = receivableAmt_b.divide(new BigDecimal(oilPrice), 2, BigDecimal.ROUND_HALF_UP);   //加油升数
                            discountAmt = oilLiters.multiply(new BigDecimal(customerGradeList.get(0).get("gasoilDiscountLitre").toString()));
                            discountAmt = discountAmt.setScale(2, BigDecimal.ROUND_HALF_UP);
                            amt = receivableAmt_b.subtract(discountAmt);
                            discountPrice = amt.divide(oilLiters, 2, BigDecimal.ROUND_HALF_UP);
                            resultMap.put("discountAmt", discountAmt.doubleValue());
                            resultMap.put("amt", amt.doubleValue());
                            resultMap.put("oilLiters", oilLiters.doubleValue());
                            resultMap.put("discountPrice", discountPrice.doubleValue());
                        }else {
                            //不存在
                            resultMap.put("discountAmt", 0);
                            resultMap.put("amt", receivableAmt.doubleValue());
                            oilLiters = new BigDecimal(receivableAmt).divide(new BigDecimal(oilPrice), 2, BigDecimal.ROUND_HALF_UP);
                            resultMap.put("oilLiters", oilLiters.doubleValue());
                            resultMap.put("discountPrice", oilPrice);
                        }
                    }
                    break;
                case "2":       //2.满减
                    params.put("discountPlanType", "1");
                    //营销方案
                    List<Map> customerMarkertPlanList_1 = customerGradeServices.getCustomerMarkertPlanList(params);
                    //有优惠规则
                    if(customerMarkertPlanList_1 !=null && customerMarkertPlanList_1.size() >0){
                        boolean flag = true;
                        for (Map m : customerMarkertPlanList_1){
                            //如果当前应收金额大于条件金额
                            BigDecimal discountAmt_b = new BigDecimal(m.get("discountAmt").toString());   //条件金额
                            if(receivableAmt_b.compareTo(discountAmt_b) ==1 || receivableAmt_b.compareTo(discountAmt_b) ==0){
                                BigDecimal gasoilDiscountAmt_b = new BigDecimal(m.get("gasoilDiscountAmt").toString());   //每满多少优惠多少的金额
                                discountAmt = receivableAmt_b.divide(discountAmt_b, 2, BigDecimal.ROUND_HALF_UP).multiply(gasoilDiscountAmt_b);  //优惠金额
                                discountAmt = discountAmt.setScale(2, BigDecimal.ROUND_HALF_UP);
                                amt = receivableAmt_b.subtract(discountAmt);   //实收金额
                                oilLiters = receivableAmt_b.divide(new BigDecimal(oilPrice),2, BigDecimal.ROUND_HALF_UP);   //加油升数
                                discountPrice = amt.divide(oilLiters);        //优惠价格
                                resultMap.put("discountAmt", discountAmt.doubleValue());
                                resultMap.put("amt", amt.doubleValue());
                                resultMap.put("oilLiters", oilLiters.doubleValue());
                                resultMap.put("discountPrice", discountPrice.doubleValue());
                                flag = false;
                                break;
                            }
                        }
                        if(flag){
                            resultMap.put("discountAmt", 0);
                            resultMap.put("amt", receivableAmt.doubleValue());
                            oilLiters = new BigDecimal(receivableAmt).divide(new BigDecimal(oilPrice),2, BigDecimal.ROUND_HALF_UP);
                            resultMap.put("oilLiters", oilLiters.doubleValue());
                            resultMap.put("discountPrice", oilPrice);
                        }
                    }else {
                        //没有优惠规则
                        resultMap.put("discountAmt", 0);
                        resultMap.put("amt", receivableAmt.doubleValue());
                        oilLiters = new BigDecimal(receivableAmt).divide(new BigDecimal(oilPrice), 2, BigDecimal.ROUND_HALF_UP);
                        resultMap.put("oilLiters", oilLiters.doubleValue());
                        resultMap.put("discountPrice", oilPrice);
                    }
                    break;
                case "3":       //3.立减
                    params.put("discountPlanType", "2");
                    //营销方案
                    List<Map> customerMarkertPlanList_2 = customerGradeServices.getCustomerMarkertPlanList(params);
                    if(customerMarkertPlanList_2 !=null && customerMarkertPlanList_2.size() >0){
                        boolean flag = true;
                        for (Map m : customerMarkertPlanList_2){
                            //如果当前应收金额大于条件金额
                            BigDecimal discountAmt_b = new BigDecimal(m.get("discountAmt").toString());   //条件金额
                            if(receivableAmt_b.compareTo(discountAmt_b) ==1 || receivableAmt_b.compareTo(discountAmt_b) ==0){
                                BigDecimal gasoilDiscountAmt_b = new BigDecimal(m.get("gasoilDiscountAmt").toString());   //每满多少优惠多少的金额
                                discountAmt = gasoilDiscountAmt_b;  //优惠金额
                                amt = receivableAmt_b.subtract(gasoilDiscountAmt_b);   //实收金额
                                oilLiters = receivableAmt_b.divide(new BigDecimal(oilPrice), 2, BigDecimal.ROUND_HALF_UP);   //加油升数
                                discountPrice = amt.divide(oilLiters);        //优惠价格
                                resultMap.put("discountAmt", discountAmt.doubleValue());
                                resultMap.put("amt", amt.doubleValue());
                                resultMap.put("oilLiters", oilLiters.doubleValue());
                                resultMap.put("discountPrice", discountPrice.doubleValue());
                                flag = false;
                                break;
                            }
                        }
                        if(flag){   //用户加油金额不符合优惠条件
                            resultMap.put("discountAmt", 0);
                            resultMap.put("amt", receivableAmt.doubleValue());
                            oilLiters = new BigDecimal(receivableAmt).divide(new BigDecimal(oilPrice), 2, BigDecimal.ROUND_HALF_UP);
                            resultMap.put("oilLiters", oilLiters.doubleValue());
                            resultMap.put("discountPrice", oilPrice);
                        }
                    }else {
                        //没有优惠规则
                        resultMap.put("discountAmt", 0);
                        resultMap.put("amt", receivableAmt.doubleValue());
                        oilLiters = new BigDecimal(receivableAmt).divide(new BigDecimal(oilPrice), 2, BigDecimal.ROUND_HALF_UP);
                        resultMap.put("oilLiters", oilLiters.doubleValue());
                        resultMap.put("discountPrice", oilPrice);
                    }
                    break;
                case "4":       //4.独立直降
                    params.put("discountPlanType", "3");
                    //营销方案
                    List<Map> customerMarkertPlanList_3 = customerGradeServices.getCustomerMarkertPlanList(params);
                    if(customerMarkertPlanList_3 !=null && customerMarkertPlanList_3.size() >0){
                        boolean flag= true;
                        for(Map m : customerMarkertPlanList_3){
                            BigDecimal discountAmt_b = new BigDecimal(m.get("discountAmt").toString());   //条件金额
                            BigDecimal gasoilDiscountAmt_b = new BigDecimal(m.get("gasoilDiscountAmt").toString());
                            oilLiters = receivableAmt_b.divide(new BigDecimal(oilPrice), 2, BigDecimal.ROUND_HALF_UP);   //加油升数
                            if(m.get("discountTerm").toString().equals("1")){   //按升数优惠
                                if(oilLiters.compareTo(discountAmt_b) ==1 || oilLiters.compareTo(discountAmt_b) ==0){
                                    //计算
                                    discountAmt = oilLiters.multiply(gasoilDiscountAmt_b);
                                    discountAmt = discountAmt.setScale(2, BigDecimal.ROUND_HALF_UP);
                                    amt = receivableAmt_b.subtract(discountAmt);
                                    discountPrice = amt.divide(oilLiters, 2, BigDecimal.ROUND_HALF_UP);        //优惠价格
                                    resultMap.put("discountAmt", discountAmt.doubleValue());
                                    resultMap.put("amt", amt.doubleValue());
                                    resultMap.put("oilLiters", oilLiters.doubleValue());
                                    resultMap.put("discountPrice", discountPrice.doubleValue());
                                    flag =false;
                                    break;
                                }
                            }else if(m.get("discountTerm").toString().equals("2")){     //按金额优惠
                                if(receivableAmt_b.compareTo(discountAmt_b) ==1 || receivableAmt_b.compareTo(discountAmt_b) ==0){
                                    discountAmt = oilLiters.multiply(gasoilDiscountAmt_b);
                                    discountAmt = discountAmt.setScale(2, BigDecimal.ROUND_HALF_UP);
                                    amt = receivableAmt_b.subtract(discountAmt);
                                    discountPrice = amt.divide(oilLiters, 2, BigDecimal.ROUND_HALF_UP);        //优惠价格
                                    resultMap.put("discountAmt", discountAmt.doubleValue());
                                    resultMap.put("amt", amt.doubleValue());
                                    resultMap.put("oilLiters", oilLiters.doubleValue());
                                    resultMap.put("discountPrice", discountPrice.doubleValue());
                                    flag =false;
                                    break;
                                }
                            }
                        }
                        if(flag){
                            resultMap.put("discountAmt", 0);
                            resultMap.put("amt", receivableAmt.doubleValue());
                            oilLiters = new BigDecimal(receivableAmt).divide(new BigDecimal(oilPrice), 2, BigDecimal.ROUND_HALF_UP);
                            resultMap.put("oilLiters", oilLiters.doubleValue());
                            resultMap.put("discountPrice", oilPrice);
                        }
                    }else {
                        //没有优惠规则
                        resultMap.put("discountAmt", 0);
                        resultMap.put("amt", receivableAmt.doubleValue());
                        oilLiters = receivableAmt_b.divide(new BigDecimal(oilPrice), 2, BigDecimal.ROUND_HALF_UP);
                        resultMap.put("oilLiters", oilLiters.doubleValue());
                        resultMap.put("discountPrice", oilPrice);
                    }
                    break;
            }

            //resultData = ResultData.success(resultMap);
        }
        return resultMap;
    }

    /**
     * 计算消费生成积分
     */
    public void calculateIntegralAndPushIntegral(CalculateIntegral calculateIntegral, CustomerManage customerManage){
        int integral =0;
        //获取该油站的优惠方式
        String discountPlanType = stationService.getStationDiscountWay(calculateIntegral.getStationId().toString());
        IntegralRule integralRule = new IntegralRule();
        integralRule.setStationId(calculateIntegral.getStationId());
        integralRule.setEmptyDate(new Date());
        integralRule.setOilName(calculateIntegral.getOilName());
        integralRule.setOilType(calculateIntegral.getOilType());
        //获取该油站的积分规则
        List<IntegralRule> integralRuleList = integralRuleService.getIntegralRule(integralRule);
        if(integralRuleList !=null && integralRuleList.size() >0){
            List<IntegralRuleDetail> integralRuleDetailList = integralRuleList.get(0).getIntegralRuleDetailList();
            String currentTime = null;
            String datePickerTime=null;         //活动时间
            String[] datePickerTimeArray ={};
            String integralActivity = integralRuleList.get(0).getIntegralActivity();
            String integralProportion =null;
            if(integralActivity.equals("1")){
                datePickerTime = integralRuleList.get(0).getDatePickerTime();
                integralProportion = integralRuleList.get(0).getIntegralProportion();
                if(datePickerTime.contains(",")){
                    datePickerTimeArray = datePickerTime.split(",");
                }else {
                    datePickerTimeArray= new String[1];
                    datePickerTimeArray[0] = datePickerTime;
                }
            }
            if(integralRuleDetailList !=null && integralRuleDetailList.size() >0){
                Calendar calendar = Calendar.getInstance();
                calendar.setTime(new Date());   //获取当前时间
                for (IntegralRuleDetail integralRuleDetail : integralRuleDetailList){
                    if(integralRuleDetail.getOilType().equals("1")){    //油品
                        if (integralRuleDetail.getRuleType().equals("1")){  //按照实收金额
                            if(calculateIntegral.getAmt().compareTo(integralRuleDetail.getRuleTerms()) == 1 || calculateIntegral.getAmt().compareTo(integralRuleDetail.getRuleTerms()) == 0){
                                BigDecimal divide = null;
                                BigDecimal multiply = null;
                                //判断油站配置的优惠类型
                                if(discountPlanType.equals("1") && integralRuleDetail.getGread() !=null && customerManage.getGrade().equals(integralRuleDetail.getGread())){   //等级直降
                                    divide = calculateIntegral.getAmt().divide(integralRuleDetail.getSaleAmt(), 0, BigDecimal.ROUND_HALF_DOWN);
                                    multiply = divide.multiply(integralRuleDetail.getIntegral());
                                }else {
                                    divide = calculateIntegral.getAmt().divide(integralRuleDetail.getSaleAmt(), 0, BigDecimal.ROUND_HALF_DOWN);
                                    multiply = divide.multiply(integralRuleDetail.getIntegral());
                                }
                                if(integralActivity.equals("1") &&  datePickerTimeArray !=null && integralProportion !=null){
                                    String datePicker = integralRuleList.get(0).getDatePicker();
                                    switch (datePicker){
                                        case "1":   //  1.按周来
                                            int day_Week = calendar.get(Calendar.DAY_OF_WEEK);
                                            day_Week= day_Week-1;     //减一原因：数据库存的下标从零开始
                                            currentTime = String.valueOf(day_Week);
                                            break;
                                        case "2":   //  2.每月的多少号
                                            int day_month = calendar.get(Calendar.DAY_OF_MONTH);
                                            day_month = day_month-1;        //减一原因：数据库存的下标从零开始
                                            currentTime = String.valueOf(day_month); //当前时间
                                            break;
                                        case "3":   //  3.固定日期
                                            currentTime =new SimpleDateFormat("yyyy-MM-dd").format(new Date()); //当前时间
                                            break;
                                    }
                                    for (String s : datePickerTimeArray){
                                        if(s.equals(currentTime)){
                                            multiply = multiply.multiply(new BigDecimal(integralProportion));
                                            break;
                                        }
                                    }
                                }
                                integral =multiply.intValue();
                                break;
                            }
                        }else if (integralRuleDetail.getRuleType().equals("2")){    //按应收金额
                            if(calculateIntegral.getReceivableAmt().compareTo(integralRuleDetail.getRuleTerms()) ==1 || calculateIntegral.getReceivableAmt().compareTo(integralRuleDetail.getRuleTerms()) ==0){
                                BigDecimal divide = null;
                                BigDecimal multiply = null;
                                //判断油站配置的优惠类型
                                if(discountPlanType.equals("1") && integralRuleDetail.getGread() !=null && customerManage.getGrade().equals(integralRuleDetail.getGread())){   //等级直降
                                    divide = calculateIntegral.getReceivableAmt().divide(integralRuleDetail.getSaleAmt(), 0, BigDecimal.ROUND_HALF_DOWN);
                                    multiply = divide.multiply(integralRuleDetail.getIntegral());
                                }else {
                                    divide = calculateIntegral.getReceivableAmt().divide(integralRuleDetail.getSaleAmt(), 0, BigDecimal.ROUND_HALF_DOWN);
                                    multiply = divide.multiply(integralRuleDetail.getIntegral());
                                }
                                if(integralActivity.equals("1") &&  datePickerTimeArray !=null && integralProportion !=null){
                                    String datePicker = integralRuleList.get(0).getDatePicker();
                                    switch (datePicker){
                                        case "1":   //  1.按周来
                                            int day_Week = calendar.get(Calendar.DAY_OF_WEEK);
                                            day_Week= day_Week-1;     //减一原因：数据库存的下标从零开始
                                            currentTime = String.valueOf(day_Week);
                                            break;
                                        case "2":   //  2.每月的多少号
                                            int day_month = calendar.get(Calendar.DAY_OF_MONTH);
                                            day_month = day_month-1;        //减一原因：数据库存的下标从零开始
                                            currentTime = String.valueOf(day_month); //当前时间
                                            break;
                                        case "3":   //  3.固定日期
                                            currentTime =new SimpleDateFormat("yyyy-MM-dd").format(new Date()); //当前时间
                                            break;
                                    }
                                    for (String s : datePickerTimeArray){
                                        if(s.equals(currentTime)){
                                            multiply = multiply.multiply(new BigDecimal(integralProportion));
                                            break;
                                        }
                                    }
                                }
                                integral = multiply.intValue();
                                break;
                            }
                        }else if (integralRuleDetail.getRuleType().equals("3")){    //按照加油升数
                            if(calculateIntegral.getOilLiters().compareTo(integralRuleDetail.getRuleTerms()) ==1 || calculateIntegral.getOilLiters().compareTo(integralRuleDetail.getRuleTerms()) ==0){
                                BigDecimal divide = null;
                                BigDecimal multiply = null;
                                //判断油站配置的优惠类型
                                if(discountPlanType.equals("1") && integralRuleDetail.getGread() !=null && customerManage.getGrade().equals(integralRuleDetail.getGread())){   //等级直降
                                    divide = calculateIntegral.getOilLiters().divide(integralRuleDetail.getSaleAmt(), 0, BigDecimal.ROUND_HALF_DOWN);
                                    multiply = divide.multiply(integralRuleDetail.getIntegral());
                                }else {
                                    divide = calculateIntegral.getOilLiters().divide(integralRuleDetail.getSaleAmt(), 0, BigDecimal.ROUND_HALF_DOWN);
                                    multiply = divide.multiply(integralRuleDetail.getIntegral());
                                }
                                if(integralActivity.equals("1") &&  datePickerTimeArray !=null && integralProportion !=null){
                                    String datePicker = integralRuleList.get(0).getDatePicker();
                                    switch (datePicker){
                                        case "1":   //  1.按周来
                                            int day_Week = calendar.get(Calendar.DAY_OF_WEEK);
                                            day_Week= day_Week-1;     //减一原因：数据库存的下标从零开始
                                            currentTime = String.valueOf(day_Week);
                                            break;
                                        case "2":   //  2.每月的多少号
                                            int day_month = calendar.get(Calendar.DAY_OF_MONTH);
                                            day_month = day_month-1;        //减一原因：数据库存的下标从零开始
                                            currentTime = String.valueOf(day_month); //当前时间
                                            break;
                                        case "3":   //  3.固定日期
                                            currentTime =new SimpleDateFormat("yyyy-MM-dd").format(new Date()); //当前时间
                                            break;
                                    }
                                    for (String s : datePickerTimeArray){
                                        if(s.equals(currentTime)){
                                            multiply = multiply.multiply(new BigDecimal(integralProportion));
                                            break;
                                        }
                                    }
                                }
                                integral =multiply.intValue();
                                break;
                            }
                        }
                    }else if (integralRuleDetail.getOilType().equals("2")){     //非油品
                        if (calculateIntegral.getReceivableAmt().compareTo(integralRuleDetail.getRuleTerms()) ==1 || calculateIntegral.getReceivableAmt().compareTo(integralRuleDetail.getRuleTerms()) ==0){
                            BigDecimal divide = null;
                            BigDecimal multiply = null;
                            //判断油站配置的优惠类型
                            if(discountPlanType.equals("1") && integralRuleDetail.getGread() !=null && customerManage.getGrade().equals(integralRuleDetail.getGread())){   //等级直降
                                divide = calculateIntegral.getReceivableAmt().divide(integralRuleDetail.getSaleAmt(), 0, BigDecimal.ROUND_HALF_DOWN);
                                multiply = divide.multiply(integralRuleDetail.getIntegral());
                            }else {
                                divide = calculateIntegral.getReceivableAmt().divide(integralRuleDetail.getSaleAmt(), 0, BigDecimal.ROUND_HALF_DOWN);
                                multiply = divide.multiply(integralRuleDetail.getIntegral());
                            }
                            if(integralActivity.equals("1") &&  datePickerTimeArray !=null && integralProportion !=null){
                                String datePicker = integralRuleList.get(0).getDatePicker();
                                switch (datePicker){
                                    case "1":   //  1.按周来
                                        int day_Week = calendar.get(Calendar.DAY_OF_WEEK);
                                        day_Week= day_Week-1;     //减一原因：数据库存的下标从零开始
                                        currentTime = String.valueOf(day_Week);
                                        break;
                                    case "2":   //  2.每月的多少号
                                        int day_month = calendar.get(Calendar.DAY_OF_MONTH);
                                        day_month = day_month-1;        //减一原因：数据库存的下标从零开始
                                        currentTime = String.valueOf(day_month); //当前时间
                                        break;
                                    case "3":   //  3.固定日期
                                        currentTime =new SimpleDateFormat("yyyy-MM-dd").format(new Date()); //当前时间
                                        break;
                                }
                                for (String s : datePickerTimeArray){
                                    if(s.equals(currentTime)){
                                        multiply = multiply.multiply(new BigDecimal(integralProportion));
                                        break;
                                    }
                                }
                            }
                            integral = multiply.intValue();
                            break;
                        }
                    }
                }
            }
            calculateIntegral.setIntegral(integral);
            this.pushIntegral(calculateIntegral);
        }
    }

    /*
     * 公众号推送积分
     * @param stationId 油站ID
     * @param integral  本次所得积分
     * @param openId    小程序用户openID
     */
    public void pushIntegral(CalculateIntegral calculateIntegral){
        Integer stationId = calculateIntegral.getStationId();
        int integral = calculateIntegral.getIntegral();
        String openId = calculateIntegral.getOpenId();
        String unionId = calculateIntegral.getUnionId();
        String gzhAppId ="";
        String gzhAppSecret ="";
        String stationName = "";        //油站名称
        BigDecimal surplusIntegral=null;
        String customerName =null;
        if(StringUtils.isNotBlank(openId)){
            Map<String, String> m = stationService.getStationAppIdAndAppSecret(stationId);
            if(m !=null && m.containsKey("stationName") && m.containsKey("gzhAppId") && m.containsKey("gzhAppSecret")){
                stationName = m.get("stationName");
                gzhAppId = m.get("gzhAppId");
                gzhAppSecret = m.get("gzhAppSecret");
            }
            CustomerPoints customerPoints = new CustomerPoints();
            customerPoints.setStationId(stationId);
            customerPoints.setMinaOpenId(openId);
            customerPoints.setUnionId(unionId);
            CustomerPoints customerPointsInfo = customerPointsService.getCustomerPointsInfoByUnionId(customerPoints);
            if(customerPointsInfo !=null){
                customerName =customerPointsInfo.getCustomerName();
                surplusIntegral =new BigDecimal(customerPointsInfo.getPoints()).add(new BigDecimal(integral));
                CustomerPointsRecord customerPointsRecord = new CustomerPointsRecord();
                customerPointsRecord.setCreateTime(new Date());
                customerPointsRecord.setCustomerName(customerName);
                customerPointsRecord.setStationName(stationName);
                customerPointsRecord.setStationId(stationId);
                customerPointsRecord.setRecordType("+");
                customerPointsRecord.setUnionId(customerPointsInfo.getUnionId());
                customerPointsRecord.setIntegral(integral);
                customerPointsRecordService.insertCustomerPointsRecordInfo(customerPointsRecord);
                customerPoints.setUnionId(customerPointsInfo.getUnionId());
                customerPoints.setPoints(surplusIntegral.intValue());
                //更新客户积分
                customerPointsService.updateCustomerPointsInfo(customerPoints);
                String blogOpenId = customerPointsInfo.getBlogOpenId();     //公众号openId
                if(blogOpenId !=null){
                    //推送模板
                    List<WxMpTemplateData> wxMpTemplate = new ArrayList<>();
                    wxMpTemplate.add(new WxMpTemplateData("first","尊敬的"+customerName+"，您好：\n" + "您在"+stationName+"的积分最新交易信息如下"));
                    wxMpTemplate.add(new WxMpTemplateData("time", new SimpleDateFormat("yyyy年MM月dd日HH时mm分").format(new Date())));
                    wxMpTemplate.add(new WxMpTemplateData("type", "增加"));
                    wxMpTemplate.add(new WxMpTemplateData("Point", String.valueOf(integral)));
                    wxMpTemplate.add(new WxMpTemplateData("From", stationName));
                    wxMpTemplate.add(new WxMpTemplateData("remark",
                            "截止至" + new SimpleDateFormat(" yyyy年MM月dd日HH时mm分").format(new Date())+"，您在"+stationName+"的可用积分为 "+surplusIntegral.toString()+" 分"));
                    GzhNewsTemplate gzhNewsTemplate = new GzhNewsTemplate();
                    gzhNewsTemplate.setStationId(stationId);
                    gzhNewsTemplate.setTemplateType("1");
                    GzhNewsTemplate gzhNewsTemplateInfo = gzhNewsTemplateService.getGzhNewsTemplate(gzhNewsTemplate);
                    if(gzhNewsTemplateInfo !=null && gzhNewsTemplateInfo.getTemplateId() !=null){
                        wxPushUtil.push(gzhAppId, gzhAppSecret, gzhNewsTemplateInfo.getTemplateId(), blogOpenId, wxMpTemplate);
                    }
                }

            }

        }
    }

    /**
     * 根据订单号获取订单信息
     * produces="application/json;charset=UTF-8",consumes = "application/json",
     * @RequestBody String orderno
     * @param
     * @return
     */
    @RequestMapping(value = "/getPayOrderList", method = RequestMethod.GET)
    @ResponseBody
    public String getPayOrderList(@RequestParam String orderNo,String openId,String userType){
        Gson gson =new Gson();
        ResultData resultData =null;
        //根据token 和 usertype来判断用户是否存在
        boolean flag = appUserInfoService.selectAppUserInfo(openId,userType);
        if(flag){
            if(StringUtils.isNotBlank(orderNo)){
                PayOrderRequest payOrderRequest =new PayOrderRequest();
                payOrderRequest.setOrderNo(orderNo);
                List<PayOrder> payOrderList = payOrderService.getPayOrderList(payOrderRequest.getOrderNo());
                resultData=ResultData.success(payOrderList);
            }else {
                resultData=ResultData.error(CodeMsg.SEARCH_FAIL);
            }
        }else{
            resultData=ResultData.error(CodeMsg.USER_NOT_EXSIST);
        }
        return gson.toJson(resultData);
    }

    /*
     * 根据用户openId和用户类型userType查询用户订单
     * @param openId
     * @param userType
     * @return
     */
    @RequestMapping(value = "/getOrderListByOpenIdAndUserType", method = RequestMethod.GET)
    @ResponseBody
    public String getOrderListByOpenIdAndUserType(@RequestParam("openId") String openId, @RequestParam("userType") String userType){
        Gson gson =new Gson();
        ResultData resultData =null;
            if(StringUtils.isNotBlank(openId) && StringUtils.isNotBlank(userType)){
                AppUserInfo appUserInfo = new AppUserInfo();
                switch (userType){
                    case "1":
                        appUserInfo.setBlogOpenid(openId);
                        break;
                    case "2":
                        appUserInfo.setMinaOpenid(openId);
                        break;
                }
                List<PayOrder> payOrderList = payOrderService.getOrderListByOpenIdAndUserType(appUserInfo);
                resultData=ResultData.success(payOrderList);
            }else {
                resultData=ResultData.error(CodeMsg.SEARCH_FAIL);
            }

        return gson.toJson(resultData);
    }
}