diff --git a/hai-bweb/src/main/java/com/bweb/controller/Etc/EtcCustomerController.java b/hai-bweb/src/main/java/com/bweb/controller/Etc/EtcCustomerController.java
index a275e244..4006a157 100644
--- a/hai-bweb/src/main/java/com/bweb/controller/Etc/EtcCustomerController.java
+++ b/hai-bweb/src/main/java/com/bweb/controller/Etc/EtcCustomerController.java
@@ -488,6 +488,69 @@ public class EtcCustomerController {
         }
     }
 
+    @RequestMapping(value = "/getEtcContractOrderList", method = RequestMethod.GET)
+    @ResponseBody
+    @ApiOperation(value = "更新合同状态")
+    public ResponseData getEtcContractOrderList() {
+        try {
+
+            Map<String , Object> map = new HashMap<>();
+            map.put("vehStatus" , 15);
+
+            List<EtcContractOrder> list = etcCarMsgService.getEtcContractOrderList(map);
+
+            for(EtcContractOrder contractOrder : list ) {
+                if (contractOrder == null) {
+                    throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "未查询到合同！");
+                }
+
+                // 查询车辆信息
+                Map<String , Object> mapCar = new HashMap<>();
+                mapCar.put("vehId" , contractOrder.getVehId());
+                mapCar.put("custId" , contractOrder.getCustId());
+
+                EtcCarMsg carMsg = etcCarMsgService.findEtcCarByMap(mapCar);
+
+                if (carMsg == null) {
+                    throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "未查询到信息！");
+                }
+
+                // 查询车辆状态
+                JSONObject car = EtcService.getVehStatus(carMsg);
+                if (car.getString("errCode").equals("0")) {
+                    carMsg.setVehStatus(car.getJSONObject("result").getInteger("vehStatus"));
+                    carMsg.setPayStatus(car.getJSONObject("result").getInteger("payStatus"));
+                    carMsg.setSignStatus(car.getJSONObject("result").getInteger("signStatus"));
+                    contractOrder.setVehStatus(carMsg.getVehStatus());
+                    etcCarMsgService.updateEtcCar(carMsg);
+                }
+
+                // 查询微信签约代扣信息
+                JSONObject object = EtcService.checkNeedSignWechatWithhold( contractOrder.getProductId() , contractOrder.getCardVarietyId() , contractOrder.getVehId());
+                if (object.getString("errCode").equals("0")) {
+                    contractOrder.setWechatSign(object.getJSONObject("result").getBoolean("alreadySignFlag")? 1:0);
+                    contractOrder.setNeedSignWechat(object.getJSONObject("result").getBoolean("needSignFlag")? 1:0);
+                    contractOrder.setAppid(object.getJSONObject("result").getString("appId"));
+                    contractOrder.setJumpPath(object.getJSONObject("result").getString("path"));
+                }
+
+                // 查询银行签约代扣
+                JSONObject objectBank = EtcService.checkSignWithhold( contractOrder.getCustId());
+                if (objectBank.getString("errCode").equals("0")) {
+                    contractOrder.setBankSign(objectBank.getJSONObject("result").getBoolean("isSign")? 1:0);
+                }
+
+                etcCarMsgService.updateContractOrder(contractOrder);
+            }
+
+
+            return ResponseMsgUtil.success("成功");
+
+        } catch (Exception e) {
+            log.error("BsMsgController --> getMsgByList() error!", e);
+            return ResponseMsgUtil.exception(e);
+        }
+    }
 
 
 }
diff --git a/hai-bweb/src/main/java/com/bweb/controller/HighDiscountPackageController.java b/hai-bweb/src/main/java/com/bweb/controller/HighDiscountPackageController.java
index b1ed1c8d..cafbf858 100644
--- a/hai-bweb/src/main/java/com/bweb/controller/HighDiscountPackageController.java
+++ b/hai-bweb/src/main/java/com/bweb/controller/HighDiscountPackageController.java
@@ -257,13 +257,13 @@ public class HighDiscountPackageController {
                 }
             }
 
-            if (highDiscountPackage.getUsingAttribution() != null) {
-                HighDiscountPackage highDiscountPackage1 = highDiscountPackageService.getCallExclusive(highDiscountPackage.getUsingAttribution() , userInfoModel.getBsCompany().getId().intValue());
-                if (highDiscountPackage1 != null && highDiscountPackage1.getId() != highDiscountPackage.getId()) {
-                    log.error("highCouponPackage -> updateCouponPackageInfo() error!","专属优惠券已存在");
-                    throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "专属优惠券已存在");
-                }
-            }
+//            if (highDiscountPackage.getUsingAttribution() != null) {
+//                HighDiscountPackage highDiscountPackage1 = highDiscountPackageService.getCallExclusive(highDiscountPackage.getUsingAttribution() , userInfoModel.getBsCompany().getId().intValue());
+//                if (highDiscountPackage1 != null && highDiscountPackage1.getId() != highDiscountPackage.getId()) {
+//                    log.error("highCouponPackage -> updateCouponPackageInfo() error!","专属优惠券已存在");
+//                    throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "专属优惠券已存在");
+//                }
+//            }
 
             highDiscountPackage.setStatus(3);
             highDiscountPackage.setUpdatedTime(new Date());
diff --git a/hai-bweb/src/main/java/com/bweb/controller/HighTestController.java b/hai-bweb/src/main/java/com/bweb/controller/HighTestController.java
index a230ddb1..4f15e8f9 100644
--- a/hai-bweb/src/main/java/com/bweb/controller/HighTestController.java
+++ b/hai-bweb/src/main/java/com/bweb/controller/HighTestController.java
@@ -1 +1 @@
-
package com.bweb.controller;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.hai.common.exception.ErrorCode;
import com.hai.common.exception.ErrorHelp;
import com.hai.common.exception.SysCode;
import com.hai.common.pay.util.sdk.WXPayConstants;
import com.hai.common.utils.*;
import com.hai.config.*;
import com.hai.entity.*;
import com.hai.enum_type.GasOilPriceStatusEnum;
import com.hai.model.HighMerchantModel;
import com.hai.model.HighMerchantStoreModel;
import com.hai.model.ResponseData;

import com.hai.openApi.config.BlxConfig;
import com.hai.openApi.config.PriceComputeConfig;
import com.hai.openApi.service.ApiOrderService;
import com.hai.order.service.OrderPaySuccessService;
import com.hai.order.service.OrderService;
import com.hai.order.service.impl.OrderPaySuccessServiceImpl;
import com.hai.order.type.OrderPayType;
import com.hai.order.type.OrderProductType;
import com.hai.order.type.OrderRefundOpUserType;
import com.hai.order.type.OrderStatus;
import com.hai.order.utils.OrderUtil;
import com.hai.pay.channel.huipay.config.HuiConfig;
import com.hai.service.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.collections4.MapUtils;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.nio.charset.StandardCharsets;
import java.util.*;

/**
 * @Auther: 胡锐
 * @Description:
 * @Date: 2021/3/26 23:08
 */
@Controller
@RequestMapping(value = "/test")
@Api(value = "订单接口")
public class HighTestController {

    private static Logger log = LoggerFactory.getLogger(HighTestController.class);

    @Resource
    private BsOrderRebateService bsOrderRebateService;



    @Resource
    private PetroConfig petroConfig;


    @Resource
    private HighGoldRecService highGoldRecService;

    @Resource
    private OrderService orderService;
    @Resource
    private HighUserCardService highUserCardService;

    @Resource
    private HighOrderService highOrderService;

    @Resource
    private HighUserService highUserService;

    @Resource
    private HighGasService gasService;

    @Resource
    private HighMerchantService highMerchantService;

    @Resource
    private HighMerchantStoreService highMerchantStoreService;

    @Resource
    private HighGasOilPriceService highGasOilPriceService;

    @Resource
    private OutRechargeOrderService outRechargeOrderService;

    @Resource
    private HuiConfig huiConfig;

    @Resource
    private CommonService commonService;

    @Resource
    private HighOilCardOrderService highOilCardOrderService;

    @Resource
    private HighGasOrderService gasOrderService;
    @Resource
    private ShellGroupService shellGroupService;
    @Resource
    private HighMerchantStoreService merchantStoreService;

    @Resource
    private ApiOrderService apiOrderService;

    @Resource
    private ApiMerchantsService apiMerchantsService;

    @Resource
    private BlxConfig blxConfig;

    @Resource
    private HighGasOilGunNoService gasOilGunNoService;

    @Autowired
    private RedisTemplate redisTemplate;

    @Resource
    private PriceComputeConfig priceComputeConfig;

    @Resource
    private OrderPaySuccessServiceImpl orderPaySuccessService = new OrderPaySuccessServiceImpl();
    @RequestMapping(value = "/orderBusHandle", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "")
    public ResponseData orderBusHandle(@RequestParam(name = "orderNo", required = true) String orderNo) {
        try {
            orderPaySuccessService.orderBusHandle(orderService.getOrderDetailByNo(orderNo));
       /* HighOrder order = orderService.getOrderDetailByNo(orderNo);
        if (order != null) {
            // orderService.refundOrder(orderNo, DateUtil.date2String(new Date(), "yyyy-MM-dd HH:mm:ss"));
            // order.setRefundTime(new Date());
            // orderService.updateOrderData(order);
            return ResponseMsgUtil.success("修改成功");
        }*/
            return ResponseMsgUtil.success(null);

        } catch (Exception e) {
            log.error("HighUserCardController --> rocketMq() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/gasSyncPayment", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "重庆壳牌推送")
    public ResponseData gasSyncPayment(@RequestParam(name = "orderNo", required = true) String orderNo) {
        try {

            HighGasOrder order = gasOrderService.getDetailByOrderNo(orderNo);
            if (order != null) {
                // 查询油站
                HighMerchantStore store = merchantStoreService.getDetailById(order.getStoreId());
                if (store == null) {
                    throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "未找到门店");
                }

                return ResponseMsgUtil.success(
                        // 推送加好油
                        shellGroupService.gasSyncPayment(order.getOrderNo(),
                                store.getStoreKey(),
                                order.getPayTime(),
                                order.getGasRefuelPrice(),
                                order.getGasOilNo(),
                                order.getGasGunNo(),
                                order.getPayPrice(),
                                order.getTotalDeductionPrice()
                        )
                );
            }

            return ResponseMsgUtil.success(null);

        } catch (Exception e) {
            log.error("HighOrderController --> gasSyncPayment() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value="/resolveResponse",method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "解析")
    public ResponseData resolveResponse(
            @RequestParam(name = "data", required = false) String data
    ) {
        try {
            JSONObject cardInfoObject = HuiLianTongUnionCardConfig.resolveResponse(data);
            return ResponseMsgUtil.success(cardInfoObject);

        } catch (Exception e) {
            log.error("getUserByTelephone",e);
            return ResponseMsgUtil.exception(e);
        }
    }



    @RequestMapping(value = "/getHuiLianTongCardConsume", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询汇联通工会卡消费记录")
    public ResponseData getHuiLianTongCardConsume(@RequestParam(name = "businessType", required = true) String businessType,
                                                  @RequestParam(name = "cardNo", required = true) String cardNo,
                                                  @RequestParam(name = "sdate", required = true) Long sdate,
                                                  @RequestParam(name = "edate", required = true) Long edate,
                                                  @RequestParam(name = "pageNum", required = true) Integer pageNum,
                                                  @RequestParam(name = "pageSize", required = true) Integer pageSize,
                                                  HttpServletRequest request) {
        try {


            JSONObject consumptionRecord = HuiLianTongUnionCardConfig.queryConsumptionRecordByBusiness(businessType, cardNo, sdate, edate, pageNum, pageSize);
            if (StringUtils.isBlank(consumptionRecord.getString("data"))) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.REQUEST_ERROR, "");
            }

            JSONArray array = HuiLianTongUnionCardConfig.resolveResponse(consumptionRecord.getString("data")).getJSONArray(
                    "records");

            return ResponseMsgUtil.success(array);

        } catch (Exception e) {
            log.error("HighUserCardController --> getHuiLianTongCardConsume() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }



    @RequestMapping(value = "/createOrder", method = RequestMethod.POST)
    @ResponseBody
    @ApiOperation(value = "创建订单")
    public ResponseData createOrder(@RequestBody JSONObject object) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20230258302");
            mapPost.put("timetable" , new Date().getTime());
            mapPost.put("orderNo" , OrderUtil.generateOrderNo());
            mapPost.put("productType" , object.getString("productType"));
            mapPost.put("content" , object.getString("content"));

            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "0C7897EA3BD96156A5881618FF2FF645", WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("http://localhost:9902/v1/order/createOrder" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/payOrder", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "支付订单")
    public ResponseData payOrder(@RequestParam(name = "mchOrderNo", required = true) String mchOrderNo) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("apiKey" , "B94B5E62807FA56A7260AB581D8A1B48");
            mapPost.put("merchId" , "20230394901");
            mapPost.put("mchOrderNo" , mchOrderNo);


            Map<String , Object> map = new HashMap<>();
            map.put("apiKey" , "B94B5E62807FA56A7260AB581D8A1B48");
            map.put("merchId" , "20230394901");
            map.put("mchOrderNo" , mchOrderNo);

            System.out.println(map);

            mapPost.put("sign" , WxUtils.generateSignApi(map, MapUtils.getString(map, "apiKey"), WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("https://hsg.dctpay.com/v1/order/orderPay" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/queryOrderDetail", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询订单详情")
    public ResponseData queryOrderDetail(@RequestParam(name = "mchOrderNo", required = true) String mchOrderNo) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("apiKey" , "0C7897EA3BD96156A5881618FF2FF645");
            mapPost.put("merchId" , "20230258302");
            mapPost.put("mchOrderNo" , mchOrderNo);


            Map<String , Object> map = new HashMap<>();
            map.put("apiKey" , "0C7897EA3BD96156A5881618FF2FF645");
            map.put("merchId" , "20230258302");
            map.put("mchOrderNo" , mchOrderNo);

            System.out.println(map);

            mapPost.put("sign" , WxUtils.generateSignApi(map, MapUtils.getString(map, "apiKey"), WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("http://localhost:9902/v1/order/queryOrderDetail" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/deposit", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "工会卡充值")
    public ResponseData deposit(@RequestParam(name = "orderNo", required = true) String orderNo) {
        try {

            HighOrder order = highOrderService.getOrderByOrderNo(orderNo);
            HighChildOrder highChildOrder = order.getHighChildOrderList().get(0);

            if (order.getOrderStatus() != 2) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "订单状态错误");
            }

            // 汇联通充值
            String goodsDesc = "汇联通充值"+order.getPayPrice()+"元";
            String tranDesc = "";
            String businessType = "ghk_deposit";

            String orderNoAgain = OrderUtil.generateOrderNo();

            order.setOrderStatus(Integer.valueOf(3));
            order.setRemarks("工会卡再次充值订单号" + orderNoAgain);

            highOrderService.updateOrder(order);

            // 汇联通卡充值
            JSONObject deposit = HuiLianTongUnionCardConfig.deposit(orderNoAgain, highChildOrder.getGoodsSpecName(), order.getPayPrice(), businessType, order.getPaySerialNo(), goodsDesc);

            return ResponseMsgUtil.success( HuiLianTongUnionCardConfig.resolveResponse(deposit.getString("data")));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/getHuiLianTongCardByCardNo", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "根据卡号查询汇联通工会卡详情")
    public ResponseData getHuiLianTongCardByCardNo(@RequestParam(name = "cardNo", required = true) String cardNo) {
        try {
            // 查询工会卡
            JSONObject cardInfo = HuiLianTongUnionCardConfig.queryBalance(cardNo);
            JSONObject resolveResponse = HuiLianTongUnionCardConfig.resolveResponse(cardInfo.getString("data"));
            return ResponseMsgUtil.success(resolveResponse);

        } catch (Exception e) {
            log.error("HighUserCardController --> getHuiLianTongCardByCardNo() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/consumption", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "工会卡支付")
    public ResponseData consumption(@RequestParam(name = "payRealPrice", required = true) BigDecimal payRealPrice,
                                    @RequestParam(name = "cardNo", required = true) String cardNo) {
        try {


            String goodsDesc = "";
            String tranDesc = "";
            String instCode = "11101652";
            String businessType = "hisen_consume";


            // 工会卡支付
            JSONObject consumption = HuiLianTongUnionCardConfig.consumption(OrderUtil.generateOrderNo(), cardNo, payRealPrice, businessType, instCode, goodsDesc, tranDesc);
            if (!consumption.getString("respCode").equals("0000")) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, consumption.getString("respMessage"));
            }
            // 响应参数
            JSONObject consumptionResult = HuiLianTongUnionCardConfig.resolveResponse(consumption.getString("data"));
            if (consumptionResult.getBoolean("success") != true) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, consumptionResult.getString("message"));
            }
            return ResponseMsgUtil.success(consumptionResult);

        } catch (Exception e) {
            log.error("HighUserCardController --> getHuiLianTongCardByCardNo() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/refundOrder", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "工会卡退款")
    public ResponseData refundOrder(@RequestParam(name = "orderNo", required = true) String orderNo) {
        try {

            HighOrder order = highOrderService.getOrderByOrderNo(orderNo);

            if (order.getOrderStatus() != 2) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "订单状态错误");
            }

            orderService.refundOrder(order, OrderProductType.getDataByType(order.getProductType()).getName() + "退款",OrderRefundOpUserType.TYPE1,
                    null,
                    "系统自动退款");

            if (order.getProductType().equals(4)) {
                HighUser user = highUserService.findByUserId(order.getMemId());

                // 获取应退款积分
                int integralNum = order.getTotalPrice().multiply(new BigDecimal(100)).intValue();

                if ( integralNum> user.getGold()) {
                    throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "积分数量不足");
                }

                String remark = "订单" + order.getOrderNo() + "退还积分：" + integralNum;
                // 积分退款
                highUserService.goldHandle(user.getId(), integralNum,2, 3, order.getId() , remark , order.getOrderNo());
            }


            return ResponseMsgUtil.success("退款成功");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/externalOrderRefund", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "对外订单退款")
    public ResponseData externalOrderRefund(@RequestParam(name = "paySerialNo", required = true) String paySerialNo,
                                            @RequestParam(name = "WxMchId", required = true) String WxMchId,
                                            @RequestParam(name = "payRealPrice", required = true) String payRealPrice) {
        try {


            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("apiKey" , "B94B5E62807FA56A7260AB581D8A1B48");
            mapPost.put("merchId" , "20230394901");
            mapPost.put("paySerialNo" , paySerialNo);
            mapPost.put("wxMchId" , WxMchId);
            mapPost.put("payRealPrice" , payRealPrice);
            mapPost.put("refundPrice" , payRealPrice);

            Map<String , Object> map = new HashMap<>();
            map.put("apiKey" , "B94B5E62807FA56A7260AB581D8A1B48");
            map.put("merchId" , "20230394901");
            map.put("paySerialNo" , paySerialNo);
            map.put("wxMchId" , WxMchId);
            map.put("payRealPrice" , payRealPrice);
            map.put("refundPrice" , payRealPrice);

            System.out.println(map);

            mapPost.put("sign" , WxUtils.generateSignApi(map, MapUtils.getString(map, "apiKey"), WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("https://hsg.dctpay.com/v1/order/externalOrderRefund" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getBlxCouponBalance", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询停车券")
    public ResponseData getBlxCouponBalance(@RequestParam(name = "phone", required = true) String phone) {
        try {


            highUserCardService.getBlxCouponBalance(phone);

            return ResponseMsgUtil.success("object");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/queryJsParking", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询捷顺停车场")
    public ResponseData queryJsParking(@RequestParam(name = "gps", required = true) String gps) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20230258302");
            mapPost.put("gps" , gps);
            mapPost.put("range" , "1000");


            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "0C7897EA3BD96156A5881618FF2FF645", WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("http://localhost:9902/v1/blxCoupon/queryJsParking" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getUserCouponPage", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询捷顺停车场")
    public ResponseData getUserCouponPage(@RequestParam(name = "phone", required = true) String phone) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20230258302");
            mapPost.put("phone" , phone);


            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "0C7897EA3BD96156A5881618FF2FF645", WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("http://localhost:9902/v1/blxCoupon/getUserCouponPage" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/queryJsOrderList", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询车牌订单列表信息")
    public ResponseData queryJsOrderList(@RequestParam(name = "carNo", required = true) String carNo,
                                         @RequestParam(name = "orderStatus", required = true) String orderStatus) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20230258302");
            mapPost.put("orderStatus" , orderStatus);
            mapPost.put("carNo" , carNo);
            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "0C7897EA3BD96156A5881618FF2FF645", WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("http://localhost:9902/v1/blxCoupon/queryJsOrderList" , mapPost , new HashMap<>()));

        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }



    @RequestMapping(value = "/sendCoupon", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "发放券")
    public ResponseData sendCoupon(@RequestParam(name = "couponCode", required = true) String couponCode,
                                   @RequestParam(name = "receiverCount", required = true) Integer receiverCount,
                                   @RequestParam(name = "orderNo", required = true) String orderNo,
                                      @RequestParam(name = "receiverPhone", required = true) String receiverPhone) {
        try {


            // 下单请求
            JSONObject rechargeObject = HuiLianTongConfig.recharge(orderNo,
                    receiverCount,
                    couponCode,
                    receiverPhone);
            if (!rechargeObject.getString("respCode").equals("0000")) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "下单失败");
            }
            JSONObject response = HuiLianTongUnionCardConfig.resolveResponse(rechargeObject.getString("data"));

            // 购买卡券
            JSONObject returnParam = HuiLianTongConfig.costRechargeOrder(response.getJSONObject("data").getString("rechargeOrderId"));

            if (returnParam != null && returnParam.getString("respCode").equals("0000")) {
                // 解密
                JSONObject jsonObject = HuiLianTongUnionCardConfig.resolveResponse(returnParam.getString("data"));
                JSONArray dataArray = JSONObject.parseObject(jsonObject.getString("data"), JSONArray.class);

                return ResponseMsgUtil.success(dataArray);
            } else {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "下单失败");
            }

        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/preorder", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "发起支付")
    public ResponseData preorder() {
        try {


            JSONObject object = new JSONObject();
            object.put("outTradeNo" , "HUI" + OrderUtil.generateOrderNo());
            object.put("transType" , "JSAPI");
            object.put("payMode" , "WECHAT");
            object.put("totalAmount" , "0.01");
            object.put("profitSharing" , 0);
            object.put("subject" , "测试");
            object.put("userId" , "oUGn_4unIjp90MY-oEXluY4laDrQ");

            return ResponseMsgUtil.success(huiConfig.preorder(object));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/queryGasInfoListByPage", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询团油门店")
    public ResponseData queryGasInfoListByPage() {
        try {


            HighMerchantModel merchant = highMerchantService.getMerchantById(39L);
            if (merchant == null) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "未找到商户");
            }
            JSONObject jsonObjectP = TuanYouConfig.queryGasInfoListByPage(1, 1000);
            JSONObject resultObjectP = jsonObjectP.getObject("result", JSONObject.class);

            for (int i = 1; i <= resultObjectP.getInteger("totalPageNum").intValue();i++) {
                JSONObject jsonObject = TuanYouConfig.queryGasInfoListByPage(i, 1000);
                JSONObject resultObject = jsonObject.getObject("result", JSONObject.class);
                JSONArray jsonArray = resultObject.getJSONArray("gasInfoList");
                HighMerchantStore highMerchantStore;
                HighGasOilPrice highGasOilPrice;
                for (Object gasObject : jsonArray) {
                    JSONObject object = JSONObject.parseObject(JSONObject.toJSONString(gasObject));
                    HighMerchantStoreModel store = highMerchantStoreService.getMerchantStoreByKey(object.getString("gasId"));
                    JSONArray gasGunList = object.getJSONArray("gasGunList");
                    if (store != null) {
                        store.setType(1);
                        store.setSourceType(2);
                        store.setMerchantId(merchant.getId());
                        store.setCompanyId(merchant.getCompanyId());
                        store.setStoreKey(object.getString("gasId"));
                        store.setStoreName(object.getString("gasName"));
                        store.setStoreLogo(object.getString("gasLogoSmall"));
                        store.setRegionId(object.getLong("provinceCode"));
                        store.setRegionName(object.getString("provinceName"));
                        store.setAddress(object.getString("gasAddress"));
                        store.setLongitude(object.getString("gasAddressLongitude"));
                        store.setLatitude(object.getString("gasAddressLatitude"));
                        store.setStatus(object.getInteger("gasStatus"));
                        store.setPrestoreType(0);
                        store.setOperatorId(0L);
                        store.setOperatorName("系统创建");
                        store.setUpdateTime(new Date());
                        store.setExt1(object.getString("gasSourceId"));
                        highMerchantStoreService.updateMerchantStoreDetail(store);

                        JSONArray oilPriceList = object.getJSONArray("oilPriceList");
                        for (Object oilPrice : oilPriceList) {
                            JSONObject oilPriceObject = JSONObject.parseObject(JSONObject.toJSONString(oilPrice));
                            // 查询门店油号
                            highGasOilPrice = highGasOilPriceService.getGasOilPriceByStoreAndOilNo(store.getId(), oilPriceObject.getString("oilNo"));
                            if (highGasOilPrice == null) {
                                highGasOilPrice = new HighGasOilPrice();
                                highGasOilPrice.setMerchantStoreId(store.getId());
                                highGasOilPrice.setOilNo(oilPriceObject.getString("oilNo"));
                                highGasOilPrice.setOilNoName(oilPriceObject.getString("oilNoName"));
                                highGasOilPrice.setPriceCost(oilPriceObject.getBigDecimal("priceVip"));
                                highGasOilPrice.setPriceVip(oilPriceObject.getBigDecimal("priceGun"));
                                highGasOilPrice.setPriceGun(oilPriceObject.getBigDecimal("priceGun"));
                                highGasOilPrice.setPriceOfficial(oilPriceObject.getBigDecimal("priceOfficial"));
                                highGasOilPrice.setOilType(oilPriceObject.getInteger("oilType"));
                                highGasOilPrice.setOilTypeName(oilPriceObject.getString("oilTypeName"));
                                highGasOilPrice.setStatus(GasOilPriceStatusEnum.status1.getStatus());
                            } else {
                                highGasOilPrice.setMerchantStoreId(store.getId());
                                highGasOilPrice.setOilNo(oilPriceObject.getString("oilNo"));
                                highGasOilPrice.setOilNoName(oilPriceObject.getString("oilNoName"));
                                highGasOilPrice.setPriceCost(oilPriceObject.getBigDecimal("priceVip"));
                                highGasOilPrice.setPriceVip(oilPriceObject.getBigDecimal("priceGun"));
                                highGasOilPrice.setPriceGun(oilPriceObject.getBigDecimal("priceGun"));
                                highGasOilPrice.setPriceOfficial(oilPriceObject.getBigDecimal("priceOfficial"));
                                highGasOilPrice.setOilType(oilPriceObject.getInteger("oilType"));
                                highGasOilPrice.setOilTypeName(oilPriceObject.getString("oilTypeName"));
                                highGasOilPrice.setStatus(GasOilPriceStatusEnum.status1.getStatus());
                            }
                            highGasOilPriceService.editGasOilPrice(highGasOilPrice);

                            for (Object o : gasGunList) {
                                JSONObject gunNoObject = (JSONObject) o;
                                HighGasOilGunNo gasOilGunNo = gasOilGunNoService.getDetailByStoreAndGunNo(highGasOilPrice.getMerchantStoreId(), gunNoObject.getString("gunNo"));
                                if (gasOilGunNo == null) {
                                    gasOilGunNo = new HighGasOilGunNo();
                                    gasOilGunNo.setGasOilPriceId(highGasOilPrice.getId());
                                    gasOilGunNo.setStoreId(highGasOilPrice.getMerchantStoreId());
                                    gasOilGunNo.setOilNo(highGasOilPrice.getOilNo());
                                    gasOilGunNo.setOilNoName(highGasOilPrice.getOilNoName());
                                    gasOilGunNo.setOilType(highGasOilPrice.getOilType());
                                    gasOilGunNo.setOilTypeName(highGasOilPrice.getOilTypeName());
                                    gasOilGunNo.setGunNo(gunNoObject.getString("gunNo"));
                                    gasOilGunNo.setStatus(1);
                                    gasOilGunNoService.editGunNo(gasOilGunNo);
                                }
                            }
                        }
                    } else {
                        highMerchantStore = new HighMerchantStore();
                        highMerchantStore.setType(1);
                        highMerchantStore.setSourceType(2);
                        highMerchantStore.setMerchantId(merchant.getId());
                        highMerchantStore.setCompanyId(merchant.getCompanyId());
                        highMerchantStore.setStoreKey(object.getString("gasId"));
                        highMerchantStore.setStoreName(object.getString("gasName"));
                        highMerchantStore.setStoreLogo(object.getString("gasLogoSmall"));
                        highMerchantStore.setRegionId(object.getLong("provinceCode"));
                        highMerchantStore.setRegionName(object.getString("provinceName"));
                        highMerchantStore.setAddress(object.getString("gasAddress"));
                        highMerchantStore.setLongitude(object.getString("gasAddressLongitude"));
                        highMerchantStore.setLatitude(object.getString("gasAddressLatitude"));
                        highMerchantStore.setStatus(1);
                        highMerchantStore.setPrestoreType(0);
                        highMerchantStore.setOperatorId(0L);
                        highMerchantStore.setOperatorName("系统创建");
                        highMerchantStore.setCreateTime(new Date());
                        highMerchantStore.setUpdateTime(new Date());
                        highMerchantStore.setExt1(object.getString("gasSourceId"));
                        HighMerchantStoreModel merchantStoreModel = new HighMerchantStoreModel();
                        BeanUtils.copyProperties(highMerchantStore, merchantStoreModel);
                        highMerchantStoreService.insertMerchantStore(merchantStoreModel);

                        JSONArray oilPriceList = object.getJSONArray("oilPriceList");
                        for (Object oilPrice : oilPriceList) {
                            JSONObject oilPriceObject = JSONObject.parseObject(JSONObject.toJSONString(oilPrice));
                            highGasOilPrice = new HighGasOilPrice();
                            highGasOilPrice.setMerchantStoreId(merchantStoreModel.getId());
                            highGasOilPrice.setOilNo(oilPriceObject.getString("oilNo"));
                            highGasOilPrice.setOilNoName(oilPriceObject.getString("oilNoName"));
                            highGasOilPrice.setPriceCost(oilPriceObject.getBigDecimal("priceVip"));
                            highGasOilPrice.setPriceVip(oilPriceObject.getBigDecimal("priceGun"));
                            highGasOilPrice.setPriceGun(oilPriceObject.getBigDecimal("priceGun"));
                            highGasOilPrice.setPriceOfficial(oilPriceObject.getBigDecimal("priceOfficial"));
                            highGasOilPrice.setOilType(oilPriceObject.getInteger("oilType"));
                            highGasOilPrice.setOilTypeName(oilPriceObject.getString("oilTypeName"));
                            highGasOilPrice.setStatus(GasOilPriceStatusEnum.status1.getStatus());
                            highGasOilPriceService.editGasOilPrice(highGasOilPrice);

                            for (Object o : gasGunList) {
                                JSONObject gunNoObject = (JSONObject) o;
                                HighGasOilGunNo gasOilGunNo = gasOilGunNoService.getDetailByStoreAndGunNo(highGasOilPrice.getMerchantStoreId(), gunNoObject.getString("gunNo"));
                                if (gasOilGunNo == null) {
                                    gasOilGunNo = new HighGasOilGunNo();
                                    gasOilGunNo.setGasOilPriceId(highGasOilPrice.getId());
                                    gasOilGunNo.setStoreId(highGasOilPrice.getMerchantStoreId());
                                    gasOilGunNo.setOilNo(highGasOilPrice.getOilNo());
                                    gasOilGunNo.setOilNoName(highGasOilPrice.getOilNoName());
                                    gasOilGunNo.setOilType(highGasOilPrice.getOilType());
                                    gasOilGunNo.setOilTypeName(highGasOilPrice.getOilTypeName());
                                    gasOilGunNo.setGunNo(gunNoObject.getString("gunNo"));
                                    gasOilGunNo.setStatus(1);
                                    gasOilGunNoService.editGunNo(gasOilGunNo);
                                }
                            }
                        }
                    }
                }
            }

            return ResponseMsgUtil.success("完成");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/test", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "测试")
    public ResponseData test(@RequestParam(name = "no", required = true) String no) {
        try {

            JSONObject jsonObject = DianConfig.getGasInfoByGasId(no);

            return ResponseMsgUtil.success(jsonObject);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getGasInfoAll", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "获取全量油站")
    public ResponseData getGasInfoAll() {
        try {
            HighMerchantModel merchant = highMerchantService.getMerchantById(39L);
            JSONObject jsonObject = DianConfig.getGasInfoAll();

            JSONArray resultObject = jsonObject.getObject("result", JSONArray.class);

            for (int i = 0; i < resultObject.size();i++) {
                Object objectData =  resultObject.get(i);
                JSONObject object = JSONObject.parseObject(JSONObject.toJSONString(objectData));
                HighMerchantStore highMerchantStore;
                HighGasOilPrice highGasOilPrice;
                HighMerchantStoreModel store = highMerchantStoreService.getMerchantStoreByKey(object.getString("jyzid"));
                SecRegion region = commonService.getRegionsByName(object.getString("province"));
                if (store != null) {
                    store.setType(1);
                    store.setSourceType(6);
                    store.setMerchantId(merchant.getId());
                    store.setCompanyId(merchant.getCompanyId());
                    store.setStoreKey(object.getString("jyzid"));
                    store.setStoreName(object.getString("mingcheng"));
                    store.setStoreLogo(object.getString("tupian"));
                    store.setRegionId(region.getRegionId());
                    store.setRegionName(object.getString("province"));
                    store.setAddress(object.getString("dizhi"));
                    store.setLongitude(object.getString("lng"));
                    store.setLatitude(object.getString("lat"));
                    store.setStatus(object.getInteger("zhuangtai"));
                    store.setPrestoreType(0);
                    store.setOperatorId(0L);
                    store.setOperatorName("系统创建");
                    store.setUpdateTime(new Date());
                    store.setExt1(object.getString("gasSourceId"));
                    highMerchantStoreService.updateMerchantStoreDetail(store);

                    JSONArray oilPriceList = object.getJSONArray("oilPriceList");
                    for (Object oilPrice : oilPriceList) {
                        JSONObject oilPriceObject = JSONObject.parseObject(JSONObject.toJSONString(oilPrice));
                        // 查询门店油号
                        highGasOilPrice = highGasOilPriceService.getGasOilPriceByStoreAndOilNo(store.getId(), oilPriceObject.getString("youhao"));
                        if (highGasOilPrice == null) {
                            highGasOilPrice = new HighGasOilPrice();
                            highGasOilPrice.setMerchantStoreId(store.getId());
                            highGasOilPrice.setOilNo(oilPriceObject.getString("youhao"));
                            highGasOilPrice.setOilNoName(oilPriceObject.getString("youhao") + "#");
                            highGasOilPrice.setPriceVip(oilPriceObject.getBigDecimal("priceVip"));
                            highGasOilPrice.setPriceGun(oilPriceObject.getBigDecimal("priceGun"));
                            highGasOilPrice.setPriceOfficial(oilPriceObject.getBigDecimal("priceGun"));
                            highGasOilPrice.setOilType(oilPriceObject.getInteger("oiltype"));
                            highGasOilPrice.setOilTypeName(oilPriceObject.getString("oiltype").equals("1") ? "汽油": "柴油");
                            highGasOilPrice.setStatus(GasOilPriceStatusEnum.status1.getStatus());
                        } else {
                            highGasOilPrice.setMerchantStoreId(store.getId());
                            highGasOilPrice.setOilNo(oilPriceObject.getString("youhao"));
                            highGasOilPrice.setOilNoName( oilPriceObject.getString("youhao") + "#");
                            highGasOilPrice.setPriceVip(oilPriceObject.getBigDecimal("priceVip"));
                            highGasOilPrice.setPriceGun(oilPriceObject.getBigDecimal("priceGun"));
                            highGasOilPrice.setPriceOfficial(oilPriceObject.getBigDecimal("priceGun"));
                            highGasOilPrice.setOilType(oilPriceObject.getInteger("oiltype"));
                            highGasOilPrice.setOilTypeName(oilPriceObject.getString("oiltype").equals("1") ? "汽油": "柴油");
                        }
                        highGasOilPriceService.editGasOilPrice(highGasOilPrice);
                    }
                } else {
                    highMerchantStore = new HighMerchantStore();
                    highMerchantStore.setType(1);
                    highMerchantStore.setSourceType(6);
                    highMerchantStore.setMerchantId(merchant.getId());
                    highMerchantStore.setCompanyId(merchant.getCompanyId());
                    highMerchantStore.setStoreKey(object.getString("jyzid"));
                    highMerchantStore.setStoreName(object.getString("mingcheng"));
                    highMerchantStore.setStoreLogo(object.getString("tupian"));
                    highMerchantStore.setRegionId(region.getRegionId());
                    highMerchantStore.setRegionName(object.getString("province"));
                    highMerchantStore.setAddress(object.getString("dizhi"));
                    highMerchantStore.setLongitude(object.getString("lng"));
                    highMerchantStore.setLatitude(object.getString("lat"));
                    highMerchantStore.setStatus(1);
                    highMerchantStore.setPrestoreType(0);
                    highMerchantStore.setOperatorId(0L);
                    highMerchantStore.setOperatorName("系统创建");
                    highMerchantStore.setCreateTime(new Date());
                    highMerchantStore.setUpdateTime(new Date());
                    highMerchantStore.setExt1(object.getString("gasSourceId"));
                    HighMerchantStoreModel merchantStoreModel = new HighMerchantStoreModel();
                    BeanUtils.copyProperties(highMerchantStore, merchantStoreModel);
                    highMerchantStoreService.insertMerchantStore(merchantStoreModel);

                    JSONArray oilPriceList = object.getJSONArray("oilPriceList");
                    for (Object oilPrice : oilPriceList) {
                        JSONObject oilPriceObject = JSONObject.parseObject(JSONObject.toJSONString(oilPrice));
                        highGasOilPrice = new HighGasOilPrice();
                        highGasOilPrice.setMerchantStoreId(merchantStoreModel.getId());
                        highGasOilPrice.setOilNo(oilPriceObject.getString("youhao"));
                        highGasOilPrice.setOilNoName(oilPriceObject.getString("youhao") + "#");
                        highGasOilPrice.setPriceVip(oilPriceObject.getBigDecimal("priceVip"));
                        highGasOilPrice.setPriceGun(oilPriceObject.getBigDecimal("priceGun"));
                        highGasOilPrice.setPriceOfficial(oilPriceObject.getBigDecimal("priceGun"));
                        highGasOilPrice.setOilType(oilPriceObject.getInteger("oiltype"));
                        highGasOilPrice.setOilTypeName(oilPriceObject.getString("oiltype").equals("1") ? "汽油": "柴油");
                        highGasOilPriceService.editGasOilPrice(highGasOilPrice);
                    }
                }

            }

            return ResponseMsgUtil.success(jsonObject);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getOrderPay", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "getOrderPay")
    public ResponseData getOrderPay(@RequestParam(name = "orderNo", required = true) String orderNo) {
        try {


            HighOilCardOrder highOilCardOrder = highOilCardOrderService.findOrder(orderNo);

            highOilCardOrder.setStatus(2);

            JSONObject object = KytcService.getOrderPay(highOilCardOrder.getThirdOrderNo()  , highOilCardOrder.getPrice() , highOilCardOrder.getCardNo());

            highOilCardOrder.setExt1(object.toJSONString());

            highOilCardOrderService.updateOilCardOrder(highOilCardOrder);

            return ResponseMsgUtil.success("成功");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getOrderInfo", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "getOrderInfo")
    public ResponseData getOrderInfo(@RequestParam(name = "orderNo", required = true) String orderNo) {
        try {


            HighOilCardOrder highOilCardOrder = highOilCardOrderService.findOrder(orderNo);

            JSONObject object = KytcService.getOrderInfo(highOilCardOrder.getThirdOrderNo());

            highOilCardOrder.setExt2(object.toJSONString());

            if (object.getBoolean("State") == true) {
                JSONObject jsonObject = object.getJSONObject("Data");
                if (jsonObject.getInteger("OilOrderState") == 2) {
                    highOilCardOrder.setStatus(3);

                    HighOrder highOrder = highOrderService.getOrderByOrderNo(highOilCardOrder.getOrderNo());
                    highOrder.setOrderStatus(3);
                    highOrder.getHighChildOrderList().get(0).setChildOrderStatus(3);

                    highOrderService.updateOrder(highOrder);

                }
            }

            highOilCardOrderService.updateOilCardOrder(highOilCardOrder);

            return ResponseMsgUtil.success("成功");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getLogisticsMsg", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "获取物流")
    public ResponseData getLogisticsMsg(@RequestParam(name = "no", required = true) String no) {
        try {
            JSONObject jsonObjects = CommonConfig.getLogisticsMsg(no);
            return ResponseMsgUtil.success(jsonObjects);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

//    @RequestMapping(value = "/synCouponRule", method = RequestMethod.GET)
//    @ResponseBody
//    @ApiOperation(value = "获取卡券")
//    public ResponseData synCouponRule() {
//        try {
//            return ResponseMsgUtil.success(PetroConfig.synCouponRule());
//        } catch (Exception e) {
//            log.error("HighOrderController --> getBackendToken() error!", e);
//            return ResponseMsgUtil.exception(e);
//        }
//    }

//    @RequestMapping(value = "/getCoupon", method = RequestMethod.GET)
//    @ResponseBody
//    @ApiOperation(value = "卡券下单")
//    public ResponseData getCoupon() {
//        try {
//
//            JSONObject jsonObject = PetroConfig.getCoupon("16000443991501" , "18090580471" , OrderUtil.generateOrderNo());
//            String data = PetroConfig.decrypt(jsonObject.getString("biz_content"));
//            JSONObject object = JSONObject.parseObject(data);
//
//            return ResponseMsgUtil.success(object);
//        } catch (Exception e) {
//            log.error("HighOrderController --> getBackendToken() error!", e);
//            return ResponseMsgUtil.exception(e);
//        }
//    }


    @RequestMapping(value = "/deleteOilNo", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "删除油品")
    public ResponseData deleteOilNo() {
        try {

            gasService.deleteOilNo();
            return ResponseMsgUtil.success("1231243");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }
    @RequestMapping(value = "/getJiaHaoYouAllStation", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "加好油油站刷新")
    public ResponseData getJiaHaoYouAllStation() {
        try {
            gasService.getJiaHaoYouAllStation();
            return ResponseMsgUtil.success("1231243");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }
    @RequestMapping(value = "/getDianAllStation", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "点点网络")
    public ResponseData getDianAllStation() {
        try {

            gasService.getDianAllStation();
            return ResponseMsgUtil.success("1231243");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() err1or!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/integralRebateOrder", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "积分返利")
    public ResponseData integralRebateOrder() {
        try {

            // 查询满足初步返利条件订单
            List<HighOrder> order = highOrderService.integralRebateOrder();
            for (HighOrder highOrder : order) {

                // 查询是否存在积分记录
                Map<String, Object> map = new HashMap<>();
                map.put("goldType", 1);
                map.put("resType", 4);
                map.put("userId", highOrder.getMemId());
                map.put("resId", highOrder.getId());

                List<HighGoldRec> goldRecs = highGoldRecService.getGoldRec(map);

                // 判断是否重复赠送积分
                if (goldRecs.size() == 0) {
                    bsOrderRebateService.insertOrderRebate(highOrder);
                }

                highOrder.setWhetherRebate(true);
                highOrderService.updateOrderDetail(highOrder);

            }
            return ResponseMsgUtil.success("1231243");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() err1or!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/getApiCoupon", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "获取卡券")
    public ResponseData getApiCoupon() {
        try {

            // 查询满足初步返利条件订单
            List<HighOrder> order = highOrderService.integralRebateOrder();
            for (HighOrder highOrder : order) {

                // 查询是否存在积分记录
                Map<String, Object> map = new HashMap<>();
                map.put("goldType", 1);
                map.put("resType", 4);
                map.put("userId", highOrder.getMemId());
                map.put("resId", highOrder.getId());

                List<HighGoldRec> goldRecs = highGoldRecService.getGoldRec(map);

                // 判断是否重复赠送积分
                if (goldRecs.size() == 0) {
                    bsOrderRebateService.insertOrderRebate(highOrder);
                }

                highOrder.setWhetherRebate(true);
                highOrderService.updateOrderDetail(highOrder);

            }
            return ResponseMsgUtil.success("1231243");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() err1or!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/couponDetail", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "根据订单号查询中石油卡券详情")
    public ResponseData couponDetail(@RequestParam(name = "mchOrderNo", required = true) String mchOrderNo) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20230258302");
            mapPost.put("mchOrderNo" , mchOrderNo);
            mapPost.put("timetable" , new Date().getTime());
            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "0C7897EA3BD96156A5881618FF2FF645", WXPayConstants.SignType.MD5));

            return ResponseMsgUtil.success(HttpsUtils.doPost("http://localhost:9902/v1/apiCoupon/getCheckCode" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getCouponList", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "获取卡券")
    public ResponseData getCouponList() {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20230394901");
            mapPost.put("timetable" , new Date().getTime());
            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "B94B5E62807FA56A7260AB581D8A1B48", WXPayConstants.SignType.MD5));

            return ResponseMsgUtil.success(HttpsUtils.doPost("https://hsg.dctpay.com/v1/apiCoupon/getCouponList" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/refundApi", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "支付退款")
    public ResponseData refundApi(@RequestParam(name = "mchOrderNo", required = true) String mchOrderNo) {
        try {

            ApiOrder apiOrder = apiOrderService.findByOrderNo(mchOrderNo , null);
            // 查询APi
            HighOrder order = highOrderService.getOrderByOrderNo(apiOrder.getOrderNo());

            orderService.refundOrder(order, "商户退款退款", OrderRefundOpUserType.TYPE1,
                    null,
                    "系统自动退款");

            return ResponseMsgUtil.success("退款成功");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/checkAccountBalance", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询余额")
    public ResponseData checkAccountBalance() {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20240133101");
//            mapPost.put("mchOrderNo" , mchOrderNo);
            mapPost.put("timetable" , new Date().getTime());
            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "1F43EEC88D0F99FC201D81143F9EED85", WXPayConstants.SignType.MD5));

            return ResponseMsgUtil.success(HttpsUtils.doPost("https://hsg.dctpay.com/v1/apiMerchants/checkAccountBalance" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getStationStore", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询油站")
    public ResponseData getStationStore() {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20240587402");
//            mapPost.put("mchOrderNo" , mchOrderNo);
//            mapPost.put("timetable" , new Date().getTime());
            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "1A566F46B57830C45A06AD0AA387435C", WXPayConstants.SignType.MD5));

            return ResponseMsgUtil.success(HttpsUtils.doPost("https://hsg.dctpay.com/v1/refuelOnline/getStationStore" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }




    @RequestMapping(value = "/decryptPetroConfig", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "解码")
    public ResponseData decryptPetroConfig(@RequestParam(name = "content", required = true) String content) {
        try {

            PetroConfig.init(1);

            String data = PetroConfig.decrypt(content);
            JSONObject object = JSONObject.parseObject(data);
            return ResponseMsgUtil.success(object);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }



    @RequestMapping(value = "/synCouponRule", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "synCouponRule")
    public ResponseData synCouponRule() {
        try {

            PetroConfig.init(2);

            JSONObject jsonObject = petroConfig.synCouponRule();
            String data = PetroConfig.decrypt(jsonObject.getString("jsonResult"));
            JSONArray jsonArray = JSONArray.parseArray(data);

            return ResponseMsgUtil.success(jsonArray);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getCoupon", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "getCoupon")
    public ResponseData getCoupon(@RequestParam(name = "code", required = true) String code) {
        try {

            PetroConfig.init(2);

            // 发放卡券
            JSONObject jsonObject = petroConfig.getCoupon(code ,"18090580471");
            String data = PetroConfig.decrypt(jsonObject.getString("jsonResult"));
            JSONObject object = JSONObject.parseObject(data);
            return ResponseMsgUtil.success(object);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/decrypt", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "decrypt")
    public ResponseData decrypt(@RequestParam(name = "jsonResult", required = true) String jsonResult) {
        try {

            PetroConfig.init(2);
            String data = PetroConfig.decrypt(jsonResult);
            JSONObject object = JSONObject.parseObject(data);
            return ResponseMsgUtil.success(object);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/jNiuGoodsList", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "jNiuGoodsList")
    public ResponseData jNiuGoodsList() {
        try {

            JSONObject object = RechargeConfig.jNiuGoodsList();
            JSONArray array = object.getJSONArray("data");
            List<JSONObject> list = new ArrayList<>();
            for (int i = 0; i < array.size(); i++) {
                JSONObject jsonObject = array.getJSONObject(i);
                JSONArray jsonArray = jsonObject.getJSONArray("goodsOption");
                for (int j = 0; j < jsonArray.size(); j++) {
                    JSONObject goodsOption = jsonArray.getJSONObject(j);
                    JSONArray childArray = goodsOption.getJSONArray("child");
                    for (int t = 0; t < childArray.size(); t++) {
                        JSONObject child = childArray.getJSONObject(j);
                        JSONObject data = new JSONObject();
                        data.put("title" , jsonObject.getString("sort_title") + goodsOption.getString("name"));
                        data.put("goodsId" ,  child.getString("goods_id"));
                        data.put("goodsOptionId" ,  child.getString("goods_option_id"));
                        data.put("platPrice" ,  child.getString("plat_price"));
                        data.put("officialPrice" ,  child.getString("official_price"));
                        list.add(data);
                    }

                }

            }
            return ResponseMsgUtil.success(list);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/rechargeOrderByJn", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "rechargeOrderByJn")
    public ResponseData rechargeOrderByJn() {
        try {

            JSONObject object = new JSONObject();

            object.put("orderNo", OrderUtil.generateOrderNo());
            object.put("option_id", "632");
            object.put("phone", "18090580471");
            JSONObject returnObject = RechargeConfig.rechargeOrderByJn(object);

            return ResponseMsgUtil.success(returnObject);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/checkOrderByJn", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "checkOrderByJn")
    public ResponseData checkOrderByJn(@RequestParam(name = "order_no", required = true) String order_no) {
        try {

            JSONObject object = new JSONObject();

            object.put("orderNo" , order_no);
            int status = 0;
            JSONObject jsonObject = RechargeConfig.checkOrderByJn(object);
            if (jsonObject.getJSONObject("data") != null) {
                JSONObject  objectData= jsonObject.getJSONObject("data");
                // // 10充值中 20充值完成 -10 充值失败
                // -1取消，0充值中 ，1充值成功，2充值失败，3部分成功
                if (objectData.getInteger("status") == 10) {
                    status = 0;
                } else if (objectData.getInteger("status") == 20) {
                    status =  1;
                } else if (objectData.getInteger("status") == -10) {
                    status = 2;
                }
            }

            return ResponseMsgUtil.success(status);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/getListRechargeOrder", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "getListRechargeOrder")
    public ResponseData getListRechargeOrder(@RequestParam(name = "order_no", required = true) String order_no) {
        try {

            log.info("处理话费订单定时任务开始");
            Map<String, Object> map = new HashMap<>();
            map.put("payStatus", String.valueOf(102));
            map.put("rechargeStatus", String.valueOf(201));
            List<OutRechargeOrder> orderList = outRechargeOrderService.getListRechargeOrder(map);
            log.info("处理话费订单条数:" + orderList.size());
            if (orderList.size() > 0) {
                for (OutRechargeOrder order : orderList) {
                    try {
                        outRechargeOrderService.prepaidRechargeHandle(order);
                    } catch (Exception e) {
                        log.info("话费定时任务订单业务出现异常", e);
                    }
                }
            }
            return ResponseMsgUtil.success("");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/etcOrder", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "etcOrder")
    public ResponseData etcOrder() {
        try {
            String mobile = "18090580471";
            Map<String, Object> map = new TreeMap<>();
            map.put("requestId" , System.nanoTime());
            map.put("channelCode" , CommonSysConst.getSysConfig().getEtcChannelCode());
            map.put("timestamp" , new Date().getTime() / 1000);
            map.put("productNo" , "GZETCFXQD_GZETCCSCP");
            map.put("mobile" , RSAUtil.encryptBASE64(RSAUtil.encryptByPublicKey(mobile.getBytes(StandardCharsets.UTF_8), CommonSysConst.getSysConfig().getEtcPublicKey())));
            map.put("num" , 1);
            map.put("thirdOrderId" , OrderUtil.generateOrderNo());
            String s = StringUtils.join(map.values(), "");
            String sign = RSAUtil.sign(s.getBytes(), CommonSysConst.getSysConfig().getEtcPrivateKey());
            map.put("sign", sign);

            return ResponseMsgUtil.success(petroConfig.etcOrder(map));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/couJointDist", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "商户派发电子券")
    public ResponseData couJointDist(@RequestParam(name = "order_no", required = true) String order_no) {
        try {

            // 购买卡券
            JSONObject returnParam = HuiLianTongConfig.costRechargeOrder(order_no);
            // 解密
            JSONObject jsonObject = HuiLianTongUnionCardConfig.resolveResponse(returnParam.getString("data"));
            JSONArray dataArray = JSONObject.parseObject(jsonObject.getString("data"), JSONArray.class);

            return ResponseMsgUtil.success(dataArray);

        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getCarNo", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询车牌订单号")
    public ResponseData getCarNo(@RequestParam(name = "carNo", required = true) String carNo) {
        try {

            JSONObject jsonObject = new JSONObject();
            jsonObject.put("carNo" , carNo);
            jsonObject.put("orderStatus" , "03");

            JSONObject data = blxConfig.queryJsOrderList(jsonObject);

            return ResponseMsgUtil.success(data);

        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value="/getGasDetailByStoreKey",method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "根据门店key 查询")
    public ResponseData getGasDetailByStoreKey(@RequestParam(name = "storeKey", required = true) String storeKey) {
        try {

            JSONObject jsonObject = TuanYouConfig.queryGasInfoByGasId(storeKey);
            return ResponseMsgUtil.success(jsonObject.get("result"));
        } catch (Exception e) {
            log.error("HighGasController -> getGasDetailByStoreKey() error!",e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value="/getSphCoupon",method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "获取卡券")
    public ResponseData getSphCoupon() {
        try {

            JSONObject jsonObject = PetroCouponConfig.getCouponList();
            return ResponseMsgUtil.success(jsonObject);
        } catch (Exception e) {
            log.error("HighGasController -> getGasDetailByStoreKey() error!",e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value="/mchBalance",method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "处理扣款")
    public ResponseData mchBalance(@RequestParam(name = "merchId", required = true) String merchId,
                                   @RequestParam(name = "mchOrderNo", required = true) String mchOrderNo) {
        try {

            ApiMerchants apiMerchants = apiMerchantsService.findByMchId(merchId);

            ApiOrder apiOrder = apiOrderService.findByOrderNo(mchOrderNo , null);

            String key = "apiMerchant" + apiMerchants.getMchId();

            // 分布式锁占坑
            Boolean lock = redisTemplate.opsForValue().setIfAbsent(key, apiOrder.getOrderNo());

            HighOrder order = highOrderService.getOrderByOrderNo(apiOrder.getOrderNo());

            if(!order.getOrderStatus().equals(OrderStatus.STATUS1.getNumber())) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.ORDER_NO_STAY_PAY, "");
            }

            if(Boolean.TRUE.equals(lock)) {

                // 判断金额是否充足
                if (!priceComputeConfig.mchBalance(apiMerchants , apiOrder.getCostPrice() , apiOrder.getMchOrderNo())) {
                    throw ErrorHelp.genException(SysCode.System, ErrorCode.INSUFFICIENT_BALANCE);
                }

            } else {
                // 加锁失败，重试
                Thread.sleep(100);
                mchBalance(merchId , mchOrderNo);
            }
            return null;
        } catch (Exception e) {
            log.error("HighGasController -> getGasDetailByStoreKey() error!",e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getMerchantStoreList", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "下架团油")
    public ResponseData getMerchantStoreList() {
        try {

            // 客户端
            Map<String, Object> param = new HashMap<>();
            param.put("sourceType", 2);
//        param.put("regionId", "500000");
//        param.put("storeName", "壳牌");
            param.put("status", 1);
            List<HighMerchantStore> merchantStoreList = merchantStoreService.getMerchantStoreList(param);

            for (HighMerchantStore merchantStore : merchantStoreList) {
                merchantStore.setUpdateTime(new Date());
                merchantStore.setStatus(0);
                merchantStoreService.updateMerchantStoreDetail(merchantStore);
            }
            return ResponseMsgUtil.success("成功");

        } catch (Exception e) {
            return ResponseMsgUtil.exception(e);
        }
    }

}


\ No newline at end of file
+
package com.bweb.controller;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.hai.common.exception.ErrorCode;
import com.hai.common.exception.ErrorHelp;
import com.hai.common.exception.SysCode;
import com.hai.common.pay.util.sdk.WXPayConstants;
import com.hai.common.utils.*;
import com.hai.config.*;
import com.hai.entity.*;
import com.hai.enum_type.GasOilPriceStatusEnum;
import com.hai.model.HighMerchantModel;
import com.hai.model.HighMerchantStoreModel;
import com.hai.model.ResponseData;

import com.hai.openApi.config.BlxConfig;
import com.hai.openApi.config.PriceComputeConfig;
import com.hai.openApi.service.ApiOrderService;
import com.hai.order.service.OrderPaySuccessService;
import com.hai.order.service.OrderService;
import com.hai.order.service.impl.OrderPaySuccessServiceImpl;
import com.hai.order.type.OrderPayType;
import com.hai.order.type.OrderProductType;
import com.hai.order.type.OrderRefundOpUserType;
import com.hai.order.type.OrderStatus;
import com.hai.order.utils.OrderUtil;
import com.hai.pay.channel.huipay.config.HuiConfig;
import com.hai.service.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.collections4.MapUtils;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.nio.charset.StandardCharsets;
import java.util.*;

/**
 * @Auther: 胡锐
 * @Description:
 * @Date: 2021/3/26 23:08
 */
@Controller
@RequestMapping(value = "/test")
@Api(value = "订单接口")
public class HighTestController {

    private static Logger log = LoggerFactory.getLogger(HighTestController.class);

    @Resource
    private BsOrderRebateService bsOrderRebateService;



    @Resource
    private PetroConfig petroConfig;


    @Resource
    private HighGoldRecService highGoldRecService;

    @Resource
    private OrderService orderService;
    @Resource
    private HighUserCardService highUserCardService;

    @Resource
    private HighOrderService highOrderService;

    @Resource
    private HighUserService highUserService;

    @Resource
    private HighGasService gasService;

    @Resource
    private HighMerchantService highMerchantService;

    @Resource
    private HighMerchantStoreService highMerchantStoreService;

    @Resource
    private HighGasOilPriceService highGasOilPriceService;

    @Resource
    private OutRechargeOrderService outRechargeOrderService;

    @Resource
    private HuiConfig huiConfig;

    @Resource
    private CommonService commonService;

    @Resource
    private HighOilCardOrderService highOilCardOrderService;

    @Resource
    private HighGasOrderService gasOrderService;
    @Resource
    private ShellGroupService shellGroupService;
    @Resource
    private HighMerchantStoreService merchantStoreService;

    @Resource
    private ApiOrderService apiOrderService;

    @Resource
    private ApiMerchantsService apiMerchantsService;

    @Resource
    private BlxConfig blxConfig;

    @Resource
    private HighGasOilGunNoService gasOilGunNoService;

    @Autowired
    private RedisTemplate redisTemplate;

    @Resource
    private PriceComputeConfig priceComputeConfig;

    @Resource
    private OrderPaySuccessServiceImpl orderPaySuccessService = new OrderPaySuccessServiceImpl();
    @RequestMapping(value = "/orderBusHandle", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "")
    public ResponseData orderBusHandle(@RequestParam(name = "orderNo", required = true) String orderNo) {
        try {
            orderPaySuccessService.orderBusHandle(orderService.getOrderDetailByNo(orderNo));
       /* HighOrder order = orderService.getOrderDetailByNo(orderNo);
        if (order != null) {
            // orderService.refundOrder(orderNo, DateUtil.date2String(new Date(), "yyyy-MM-dd HH:mm:ss"));
            // order.setRefundTime(new Date());
            // orderService.updateOrderData(order);
            return ResponseMsgUtil.success("修改成功");
        }*/
            return ResponseMsgUtil.success(null);

        } catch (Exception e) {
            log.error("HighUserCardController --> rocketMq() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/gasSyncPayment", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "重庆壳牌推送")
    public ResponseData gasSyncPayment(@RequestParam(name = "orderNo", required = true) String orderNo) {
        try {

            HighGasOrder order = gasOrderService.getDetailByOrderNo(orderNo);
            if (order != null) {
                // 查询油站
                HighMerchantStore store = merchantStoreService.getDetailById(order.getStoreId());
                if (store == null) {
                    throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "未找到门店");
                }

                return ResponseMsgUtil.success(
                        // 推送加好油
                        shellGroupService.gasSyncPayment(order.getOrderNo(),
                                store.getStoreKey(),
                                order.getPayTime(),
                                order.getGasRefuelPrice(),
                                order.getGasOilNo(),
                                order.getGasGunNo(),
                                order.getPayPrice(),
                                order.getTotalDeductionPrice()
                        )
                );
            }

            return ResponseMsgUtil.success(null);

        } catch (Exception e) {
            log.error("HighOrderController --> gasSyncPayment() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value="/resolveResponse",method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "解析")
    public ResponseData resolveResponse(
            @RequestParam(name = "data", required = false) String data
    ) {
        try {
            JSONObject cardInfoObject = HuiLianTongUnionCardConfig.resolveResponse(data);
            return ResponseMsgUtil.success(cardInfoObject);

        } catch (Exception e) {
            log.error("getUserByTelephone",e);
            return ResponseMsgUtil.exception(e);
        }
    }



    @RequestMapping(value = "/getHuiLianTongCardConsume", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询汇联通工会卡消费记录")
    public ResponseData getHuiLianTongCardConsume(@RequestParam(name = "businessType", required = true) String businessType,
                                                  @RequestParam(name = "cardNo", required = true) String cardNo,
                                                  @RequestParam(name = "sdate", required = true) Long sdate,
                                                  @RequestParam(name = "edate", required = true) Long edate,
                                                  @RequestParam(name = "pageNum", required = true) Integer pageNum,
                                                  @RequestParam(name = "pageSize", required = true) Integer pageSize,
                                                  HttpServletRequest request) {
        try {


            JSONObject consumptionRecord = HuiLianTongUnionCardConfig.queryConsumptionRecordByBusiness(businessType, cardNo, sdate, edate, pageNum, pageSize);
            if (StringUtils.isBlank(consumptionRecord.getString("data"))) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.REQUEST_ERROR, "");
            }

            JSONArray array = HuiLianTongUnionCardConfig.resolveResponse(consumptionRecord.getString("data")).getJSONArray(
                    "records");

            return ResponseMsgUtil.success(array);

        } catch (Exception e) {
            log.error("HighUserCardController --> getHuiLianTongCardConsume() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }



    @RequestMapping(value = "/createOrder", method = RequestMethod.POST)
    @ResponseBody
    @ApiOperation(value = "创建订单")
    public ResponseData createOrder(@RequestBody JSONObject object) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20230258302");
            mapPost.put("timetable" , new Date().getTime());
            mapPost.put("orderNo" , OrderUtil.generateOrderNo());
            mapPost.put("productType" , object.getString("productType"));
            mapPost.put("content" , object.getString("content"));

            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "0C7897EA3BD96156A5881618FF2FF645", WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("http://localhost:9902/v1/order/createOrder" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/payOrder", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "支付订单")
    public ResponseData payOrder(@RequestParam(name = "mchOrderNo", required = true) String mchOrderNo) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("apiKey" , "B94B5E62807FA56A7260AB581D8A1B48");
            mapPost.put("merchId" , "20230394901");
            mapPost.put("mchOrderNo" , mchOrderNo);


            Map<String , Object> map = new HashMap<>();
            map.put("apiKey" , "B94B5E62807FA56A7260AB581D8A1B48");
            map.put("merchId" , "20230394901");
            map.put("mchOrderNo" , mchOrderNo);

            System.out.println(map);

            mapPost.put("sign" , WxUtils.generateSignApi(map, MapUtils.getString(map, "apiKey"), WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("https://hsg.dctpay.com/v1/order/orderPay" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/queryOrderDetail", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询订单详情")
    public ResponseData queryOrderDetail(@RequestParam(name = "mchOrderNo", required = true) String mchOrderNo) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("apiKey" , "0C7897EA3BD96156A5881618FF2FF645");
            mapPost.put("merchId" , "20230258302");
            mapPost.put("mchOrderNo" , mchOrderNo);


            Map<String , Object> map = new HashMap<>();
            map.put("apiKey" , "0C7897EA3BD96156A5881618FF2FF645");
            map.put("merchId" , "20230258302");
            map.put("mchOrderNo" , mchOrderNo);

            System.out.println(map);

            mapPost.put("sign" , WxUtils.generateSignApi(map, MapUtils.getString(map, "apiKey"), WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("http://localhost:9902/v1/order/queryOrderDetail" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/deposit", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "工会卡充值")
    public ResponseData deposit(@RequestParam(name = "orderNo", required = true) String orderNo) {
        try {

            HighOrder order = highOrderService.getOrderByOrderNo(orderNo);
            HighChildOrder highChildOrder = order.getHighChildOrderList().get(0);

            if (order.getOrderStatus() != 2) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "订单状态错误");
            }

            // 汇联通充值
            String goodsDesc = "汇联通充值"+order.getPayPrice()+"元";
            String tranDesc = "";
            String businessType = "ghk_deposit";

            String orderNoAgain = OrderUtil.generateOrderNo();

            order.setOrderStatus(Integer.valueOf(3));
            order.setRemarks("工会卡再次充值订单号" + orderNoAgain);

            highOrderService.updateOrder(order);

            // 汇联通卡充值
            JSONObject deposit = HuiLianTongUnionCardConfig.deposit(orderNoAgain, highChildOrder.getGoodsSpecName(), order.getPayPrice(), businessType, order.getPaySerialNo(), goodsDesc);

            return ResponseMsgUtil.success( HuiLianTongUnionCardConfig.resolveResponse(deposit.getString("data")));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/getHuiLianTongCardByCardNo", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "根据卡号查询汇联通工会卡详情")
    public ResponseData getHuiLianTongCardByCardNo(@RequestParam(name = "cardNo", required = true) String cardNo) {
        try {
            // 查询工会卡
            JSONObject cardInfo = HuiLianTongUnionCardConfig.queryBalance(cardNo);
            JSONObject resolveResponse = HuiLianTongUnionCardConfig.resolveResponse(cardInfo.getString("data"));
            return ResponseMsgUtil.success(resolveResponse);

        } catch (Exception e) {
            log.error("HighUserCardController --> getHuiLianTongCardByCardNo() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/consumption", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "工会卡支付")
    public ResponseData consumption(@RequestParam(name = "payRealPrice", required = true) BigDecimal payRealPrice,
                                    @RequestParam(name = "cardNo", required = true) String cardNo) {
        try {


            String goodsDesc = "";
            String tranDesc = "";
            String instCode = "11101652";
            String businessType = "hisen_consume";


            // 工会卡支付
            JSONObject consumption = HuiLianTongUnionCardConfig.consumption(OrderUtil.generateOrderNo(), cardNo, payRealPrice, businessType, instCode, goodsDesc, tranDesc);
            if (!consumption.getString("respCode").equals("0000")) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, consumption.getString("respMessage"));
            }
            // 响应参数
            JSONObject consumptionResult = HuiLianTongUnionCardConfig.resolveResponse(consumption.getString("data"));
            if (consumptionResult.getBoolean("success") != true) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, consumptionResult.getString("message"));
            }
            return ResponseMsgUtil.success(consumptionResult);

        } catch (Exception e) {
            log.error("HighUserCardController --> getHuiLianTongCardByCardNo() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/refundOrder", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "工会卡退款")
    public ResponseData refundOrder(@RequestParam(name = "orderNo", required = true) String orderNo) {
        try {

            HighOrder order = highOrderService.getOrderByOrderNo(orderNo);

            if (order.getOrderStatus() != 2) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "订单状态错误");
            }

            orderService.refundOrder(order, OrderProductType.getDataByType(order.getProductType()).getName() + "退款",OrderRefundOpUserType.TYPE1,
                    null,
                    "系统自动退款");

            if (order.getProductType().equals(4)) {
                HighUser user = highUserService.findByUserId(order.getMemId());

                // 获取应退款积分
                int integralNum = order.getTotalPrice().multiply(new BigDecimal(100)).intValue();

                if ( integralNum> user.getGold()) {
                    throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "积分数量不足");
                }

                String remark = "订单" + order.getOrderNo() + "退还积分：" + integralNum;
                // 积分退款
                highUserService.goldHandle(user.getId(), integralNum,2, 3, order.getId() , remark , order.getOrderNo());
            }


            return ResponseMsgUtil.success("退款成功");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/externalOrderRefund", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "对外订单退款")
    public ResponseData externalOrderRefund(@RequestParam(name = "paySerialNo", required = true) String paySerialNo,
                                            @RequestParam(name = "WxMchId", required = true) String WxMchId,
                                            @RequestParam(name = "payRealPrice", required = true) String payRealPrice) {
        try {


            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("apiKey" , "B94B5E62807FA56A7260AB581D8A1B48");
            mapPost.put("merchId" , "20230394901");
            mapPost.put("paySerialNo" , paySerialNo);
            mapPost.put("wxMchId" , WxMchId);
            mapPost.put("payRealPrice" , payRealPrice);
            mapPost.put("refundPrice" , payRealPrice);

            Map<String , Object> map = new HashMap<>();
            map.put("apiKey" , "B94B5E62807FA56A7260AB581D8A1B48");
            map.put("merchId" , "20230394901");
            map.put("paySerialNo" , paySerialNo);
            map.put("wxMchId" , WxMchId);
            map.put("payRealPrice" , payRealPrice);
            map.put("refundPrice" , payRealPrice);

            System.out.println(map);

            mapPost.put("sign" , WxUtils.generateSignApi(map, MapUtils.getString(map, "apiKey"), WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("https://hsg.dctpay.com/v1/order/externalOrderRefund" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getBlxCouponBalance", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询停车券")
    public ResponseData getBlxCouponBalance(@RequestParam(name = "phone", required = true) String phone) {
        try {


            highUserCardService.getBlxCouponBalance(phone);

            return ResponseMsgUtil.success("object");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/queryJsParking", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询捷顺停车场")
    public ResponseData queryJsParking(@RequestParam(name = "packageId", required = true) String packageId ,@RequestParam(name = "phone", required = true) String phone ) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20240694600");
            mapPost.put("packageId" , packageId);
            mapPost.put("phone" , phone);


            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "B1C8316D09969BD7F6534AC1676B4EFB", WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("https://hsg.dctpay.com/v1/discount/presentDiscount" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getUserCouponPage", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询捷顺停车场")
    public ResponseData getUserCouponPage(@RequestParam(name = "phone", required = true) String phone) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20230258302");
            mapPost.put("phone" , phone);


            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "0C7897EA3BD96156A5881618FF2FF645", WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("http://localhost:9902/v1/blxCoupon/getUserCouponPage" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/queryJsOrderList", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询车牌订单列表信息")
    public ResponseData queryJsOrderList(@RequestParam(name = "carNo", required = true) String carNo,
                                         @RequestParam(name = "orderStatus", required = true) String orderStatus) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20230258302");
            mapPost.put("orderStatus" , orderStatus);
            mapPost.put("carNo" , carNo);
            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "0C7897EA3BD96156A5881618FF2FF645", WXPayConstants.SignType.MD5));
            return ResponseMsgUtil.success(HttpsUtils.doPost("http://localhost:9902/v1/blxCoupon/queryJsOrderList" , mapPost , new HashMap<>()));

        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }



    @RequestMapping(value = "/sendCoupon", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "发放券")
    public ResponseData sendCoupon(@RequestParam(name = "couponCode", required = true) String couponCode,
                                   @RequestParam(name = "receiverCount", required = true) Integer receiverCount,
                                   @RequestParam(name = "orderNo", required = true) String orderNo,
                                      @RequestParam(name = "receiverPhone", required = true) String receiverPhone) {
        try {


            // 下单请求
            JSONObject rechargeObject = HuiLianTongConfig.recharge(orderNo,
                    receiverCount,
                    couponCode,
                    receiverPhone);
            if (!rechargeObject.getString("respCode").equals("0000")) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "下单失败");
            }
            JSONObject response = HuiLianTongUnionCardConfig.resolveResponse(rechargeObject.getString("data"));

            // 购买卡券
            JSONObject returnParam = HuiLianTongConfig.costRechargeOrder(response.getJSONObject("data").getString("rechargeOrderId"));

            if (returnParam != null && returnParam.getString("respCode").equals("0000")) {
                // 解密
                JSONObject jsonObject = HuiLianTongUnionCardConfig.resolveResponse(returnParam.getString("data"));
                JSONArray dataArray = JSONObject.parseObject(jsonObject.getString("data"), JSONArray.class);

                return ResponseMsgUtil.success(dataArray);
            } else {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "下单失败");
            }

        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/preorder", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "发起支付")
    public ResponseData preorder() {
        try {


            JSONObject object = new JSONObject();
            object.put("outTradeNo" , "HUI" + OrderUtil.generateOrderNo());
            object.put("transType" , "JSAPI");
            object.put("payMode" , "WECHAT");
            object.put("totalAmount" , "0.01");
            object.put("profitSharing" , 0);
            object.put("subject" , "测试");
            object.put("userId" , "oUGn_4unIjp90MY-oEXluY4laDrQ");

            return ResponseMsgUtil.success(huiConfig.preorder(object));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/queryGasInfoListByPage", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询团油门店")
    public ResponseData queryGasInfoListByPage() {
        try {


            HighMerchantModel merchant = highMerchantService.getMerchantById(39L);
            if (merchant == null) {
                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "未找到商户");
            }
            JSONObject jsonObjectP = TuanYouConfig.queryGasInfoListByPage(1, 1000);
            JSONObject resultObjectP = jsonObjectP.getObject("result", JSONObject.class);

            for (int i = 1; i <= resultObjectP.getInteger("totalPageNum").intValue();i++) {
                JSONObject jsonObject = TuanYouConfig.queryGasInfoListByPage(i, 1000);
                JSONObject resultObject = jsonObject.getObject("result", JSONObject.class);
                JSONArray jsonArray = resultObject.getJSONArray("gasInfoList");
                HighMerchantStore highMerchantStore;
                HighGasOilPrice highGasOilPrice;
                for (Object gasObject : jsonArray) {
                    JSONObject object = JSONObject.parseObject(JSONObject.toJSONString(gasObject));
                    HighMerchantStoreModel store = highMerchantStoreService.getMerchantStoreByKey(object.getString("gasId"));
                    JSONArray gasGunList = object.getJSONArray("gasGunList");
                    if (store != null) {
                        store.setType(1);
                        store.setSourceType(2);
                        store.setMerchantId(merchant.getId());
                        store.setCompanyId(merchant.getCompanyId());
                        store.setStoreKey(object.getString("gasId"));
                        store.setStoreName(object.getString("gasName"));
                        store.setStoreLogo(object.getString("gasLogoSmall"));
                        store.setRegionId(object.getLong("provinceCode"));
                        store.setRegionName(object.getString("provinceName"));
                        store.setAddress(object.getString("gasAddress"));
                        store.setLongitude(object.getString("gasAddressLongitude"));
                        store.setLatitude(object.getString("gasAddressLatitude"));
                        store.setStatus(object.getInteger("gasStatus"));
                        store.setPrestoreType(0);
                        store.setOperatorId(0L);
                        store.setOperatorName("系统创建");
                        store.setUpdateTime(new Date());
                        store.setExt1(object.getString("gasSourceId"));
                        highMerchantStoreService.updateMerchantStoreDetail(store);

                        JSONArray oilPriceList = object.getJSONArray("oilPriceList");
                        for (Object oilPrice : oilPriceList) {
                            JSONObject oilPriceObject = JSONObject.parseObject(JSONObject.toJSONString(oilPrice));
                            // 查询门店油号
                            highGasOilPrice = highGasOilPriceService.getGasOilPriceByStoreAndOilNo(store.getId(), oilPriceObject.getString("oilNo"));
                            if (highGasOilPrice == null) {
                                highGasOilPrice = new HighGasOilPrice();
                                highGasOilPrice.setMerchantStoreId(store.getId());
                                highGasOilPrice.setOilNo(oilPriceObject.getString("oilNo"));
                                highGasOilPrice.setOilNoName(oilPriceObject.getString("oilNoName"));
                                highGasOilPrice.setPriceCost(oilPriceObject.getBigDecimal("priceVip"));
                                highGasOilPrice.setPriceVip(oilPriceObject.getBigDecimal("priceGun"));
                                highGasOilPrice.setPriceGun(oilPriceObject.getBigDecimal("priceGun"));
                                highGasOilPrice.setPriceOfficial(oilPriceObject.getBigDecimal("priceOfficial"));
                                highGasOilPrice.setOilType(oilPriceObject.getInteger("oilType"));
                                highGasOilPrice.setOilTypeName(oilPriceObject.getString("oilTypeName"));
                                highGasOilPrice.setStatus(GasOilPriceStatusEnum.status1.getStatus());
                            } else {
                                highGasOilPrice.setMerchantStoreId(store.getId());
                                highGasOilPrice.setOilNo(oilPriceObject.getString("oilNo"));
                                highGasOilPrice.setOilNoName(oilPriceObject.getString("oilNoName"));
                                highGasOilPrice.setPriceCost(oilPriceObject.getBigDecimal("priceVip"));
                                highGasOilPrice.setPriceVip(oilPriceObject.getBigDecimal("priceGun"));
                                highGasOilPrice.setPriceGun(oilPriceObject.getBigDecimal("priceGun"));
                                highGasOilPrice.setPriceOfficial(oilPriceObject.getBigDecimal("priceOfficial"));
                                highGasOilPrice.setOilType(oilPriceObject.getInteger("oilType"));
                                highGasOilPrice.setOilTypeName(oilPriceObject.getString("oilTypeName"));
                                highGasOilPrice.setStatus(GasOilPriceStatusEnum.status1.getStatus());
                            }
                            highGasOilPriceService.editGasOilPrice(highGasOilPrice);

                            for (Object o : gasGunList) {
                                JSONObject gunNoObject = (JSONObject) o;
                                HighGasOilGunNo gasOilGunNo = gasOilGunNoService.getDetailByStoreAndGunNo(highGasOilPrice.getMerchantStoreId(), gunNoObject.getString("gunNo"));
                                if (gasOilGunNo == null) {
                                    gasOilGunNo = new HighGasOilGunNo();
                                    gasOilGunNo.setGasOilPriceId(highGasOilPrice.getId());
                                    gasOilGunNo.setStoreId(highGasOilPrice.getMerchantStoreId());
                                    gasOilGunNo.setOilNo(highGasOilPrice.getOilNo());
                                    gasOilGunNo.setOilNoName(highGasOilPrice.getOilNoName());
                                    gasOilGunNo.setOilType(highGasOilPrice.getOilType());
                                    gasOilGunNo.setOilTypeName(highGasOilPrice.getOilTypeName());
                                    gasOilGunNo.setGunNo(gunNoObject.getString("gunNo"));
                                    gasOilGunNo.setStatus(1);
                                    gasOilGunNoService.editGunNo(gasOilGunNo);
                                }
                            }
                        }
                    } else {
                        highMerchantStore = new HighMerchantStore();
                        highMerchantStore.setType(1);
                        highMerchantStore.setSourceType(2);
                        highMerchantStore.setMerchantId(merchant.getId());
                        highMerchantStore.setCompanyId(merchant.getCompanyId());
                        highMerchantStore.setStoreKey(object.getString("gasId"));
                        highMerchantStore.setStoreName(object.getString("gasName"));
                        highMerchantStore.setStoreLogo(object.getString("gasLogoSmall"));
                        highMerchantStore.setRegionId(object.getLong("provinceCode"));
                        highMerchantStore.setRegionName(object.getString("provinceName"));
                        highMerchantStore.setAddress(object.getString("gasAddress"));
                        highMerchantStore.setLongitude(object.getString("gasAddressLongitude"));
                        highMerchantStore.setLatitude(object.getString("gasAddressLatitude"));
                        highMerchantStore.setStatus(1);
                        highMerchantStore.setPrestoreType(0);
                        highMerchantStore.setOperatorId(0L);
                        highMerchantStore.setOperatorName("系统创建");
                        highMerchantStore.setCreateTime(new Date());
                        highMerchantStore.setUpdateTime(new Date());
                        highMerchantStore.setExt1(object.getString("gasSourceId"));
                        HighMerchantStoreModel merchantStoreModel = new HighMerchantStoreModel();
                        BeanUtils.copyProperties(highMerchantStore, merchantStoreModel);
                        highMerchantStoreService.insertMerchantStore(merchantStoreModel);

                        JSONArray oilPriceList = object.getJSONArray("oilPriceList");
                        for (Object oilPrice : oilPriceList) {
                            JSONObject oilPriceObject = JSONObject.parseObject(JSONObject.toJSONString(oilPrice));
                            highGasOilPrice = new HighGasOilPrice();
                            highGasOilPrice.setMerchantStoreId(merchantStoreModel.getId());
                            highGasOilPrice.setOilNo(oilPriceObject.getString("oilNo"));
                            highGasOilPrice.setOilNoName(oilPriceObject.getString("oilNoName"));
                            highGasOilPrice.setPriceCost(oilPriceObject.getBigDecimal("priceVip"));
                            highGasOilPrice.setPriceVip(oilPriceObject.getBigDecimal("priceGun"));
                            highGasOilPrice.setPriceGun(oilPriceObject.getBigDecimal("priceGun"));
                            highGasOilPrice.setPriceOfficial(oilPriceObject.getBigDecimal("priceOfficial"));
                            highGasOilPrice.setOilType(oilPriceObject.getInteger("oilType"));
                            highGasOilPrice.setOilTypeName(oilPriceObject.getString("oilTypeName"));
                            highGasOilPrice.setStatus(GasOilPriceStatusEnum.status1.getStatus());
                            highGasOilPriceService.editGasOilPrice(highGasOilPrice);

                            for (Object o : gasGunList) {
                                JSONObject gunNoObject = (JSONObject) o;
                                HighGasOilGunNo gasOilGunNo = gasOilGunNoService.getDetailByStoreAndGunNo(highGasOilPrice.getMerchantStoreId(), gunNoObject.getString("gunNo"));
                                if (gasOilGunNo == null) {
                                    gasOilGunNo = new HighGasOilGunNo();
                                    gasOilGunNo.setGasOilPriceId(highGasOilPrice.getId());
                                    gasOilGunNo.setStoreId(highGasOilPrice.getMerchantStoreId());
                                    gasOilGunNo.setOilNo(highGasOilPrice.getOilNo());
                                    gasOilGunNo.setOilNoName(highGasOilPrice.getOilNoName());
                                    gasOilGunNo.setOilType(highGasOilPrice.getOilType());
                                    gasOilGunNo.setOilTypeName(highGasOilPrice.getOilTypeName());
                                    gasOilGunNo.setGunNo(gunNoObject.getString("gunNo"));
                                    gasOilGunNo.setStatus(1);
                                    gasOilGunNoService.editGunNo(gasOilGunNo);
                                }
                            }
                        }
                    }
                }
            }

            return ResponseMsgUtil.success("完成");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/test", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "测试")
    public ResponseData test(@RequestParam(name = "no", required = true) String no) {
        try {

            JSONObject jsonObject = DianConfig.getGasInfoByGasId(no);

            return ResponseMsgUtil.success(jsonObject);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getGasInfoAll", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "获取全量油站")
    public ResponseData getGasInfoAll() {
        try {
            HighMerchantModel merchant = highMerchantService.getMerchantById(39L);
            JSONObject jsonObject = DianConfig.getGasInfoAll();

            JSONArray resultObject = jsonObject.getObject("result", JSONArray.class);

            for (int i = 0; i < resultObject.size();i++) {
                Object objectData =  resultObject.get(i);
                JSONObject object = JSONObject.parseObject(JSONObject.toJSONString(objectData));
                HighMerchantStore highMerchantStore;
                HighGasOilPrice highGasOilPrice;
                HighMerchantStoreModel store = highMerchantStoreService.getMerchantStoreByKey(object.getString("jyzid"));
                SecRegion region = commonService.getRegionsByName(object.getString("province"));
                if (store != null) {
                    store.setType(1);
                    store.setSourceType(6);
                    store.setMerchantId(merchant.getId());
                    store.setCompanyId(merchant.getCompanyId());
                    store.setStoreKey(object.getString("jyzid"));
                    store.setStoreName(object.getString("mingcheng"));
                    store.setStoreLogo(object.getString("tupian"));
                    store.setRegionId(region.getRegionId());
                    store.setRegionName(object.getString("province"));
                    store.setAddress(object.getString("dizhi"));
                    store.setLongitude(object.getString("lng"));
                    store.setLatitude(object.getString("lat"));
                    store.setStatus(object.getInteger("zhuangtai"));
                    store.setPrestoreType(0);
                    store.setOperatorId(0L);
                    store.setOperatorName("系统创建");
                    store.setUpdateTime(new Date());
                    store.setExt1(object.getString("gasSourceId"));
                    highMerchantStoreService.updateMerchantStoreDetail(store);

                    JSONArray oilPriceList = object.getJSONArray("oilPriceList");
                    for (Object oilPrice : oilPriceList) {
                        JSONObject oilPriceObject = JSONObject.parseObject(JSONObject.toJSONString(oilPrice));
                        // 查询门店油号
                        highGasOilPrice = highGasOilPriceService.getGasOilPriceByStoreAndOilNo(store.getId(), oilPriceObject.getString("youhao"));
                        if (highGasOilPrice == null) {
                            highGasOilPrice = new HighGasOilPrice();
                            highGasOilPrice.setMerchantStoreId(store.getId());
                            highGasOilPrice.setOilNo(oilPriceObject.getString("youhao"));
                            highGasOilPrice.setOilNoName(oilPriceObject.getString("youhao") + "#");
                            highGasOilPrice.setPriceVip(oilPriceObject.getBigDecimal("priceVip"));
                            highGasOilPrice.setPriceGun(oilPriceObject.getBigDecimal("priceGun"));
                            highGasOilPrice.setPriceOfficial(oilPriceObject.getBigDecimal("priceGun"));
                            highGasOilPrice.setOilType(oilPriceObject.getInteger("oiltype"));
                            highGasOilPrice.setOilTypeName(oilPriceObject.getString("oiltype").equals("1") ? "汽油": "柴油");
                            highGasOilPrice.setStatus(GasOilPriceStatusEnum.status1.getStatus());
                        } else {
                            highGasOilPrice.setMerchantStoreId(store.getId());
                            highGasOilPrice.setOilNo(oilPriceObject.getString("youhao"));
                            highGasOilPrice.setOilNoName( oilPriceObject.getString("youhao") + "#");
                            highGasOilPrice.setPriceVip(oilPriceObject.getBigDecimal("priceVip"));
                            highGasOilPrice.setPriceGun(oilPriceObject.getBigDecimal("priceGun"));
                            highGasOilPrice.setPriceOfficial(oilPriceObject.getBigDecimal("priceGun"));
                            highGasOilPrice.setOilType(oilPriceObject.getInteger("oiltype"));
                            highGasOilPrice.setOilTypeName(oilPriceObject.getString("oiltype").equals("1") ? "汽油": "柴油");
                        }
                        highGasOilPriceService.editGasOilPrice(highGasOilPrice);
                    }
                } else {
                    highMerchantStore = new HighMerchantStore();
                    highMerchantStore.setType(1);
                    highMerchantStore.setSourceType(6);
                    highMerchantStore.setMerchantId(merchant.getId());
                    highMerchantStore.setCompanyId(merchant.getCompanyId());
                    highMerchantStore.setStoreKey(object.getString("jyzid"));
                    highMerchantStore.setStoreName(object.getString("mingcheng"));
                    highMerchantStore.setStoreLogo(object.getString("tupian"));
                    highMerchantStore.setRegionId(region.getRegionId());
                    highMerchantStore.setRegionName(object.getString("province"));
                    highMerchantStore.setAddress(object.getString("dizhi"));
                    highMerchantStore.setLongitude(object.getString("lng"));
                    highMerchantStore.setLatitude(object.getString("lat"));
                    highMerchantStore.setStatus(1);
                    highMerchantStore.setPrestoreType(0);
                    highMerchantStore.setOperatorId(0L);
                    highMerchantStore.setOperatorName("系统创建");
                    highMerchantStore.setCreateTime(new Date());
                    highMerchantStore.setUpdateTime(new Date());
                    highMerchantStore.setExt1(object.getString("gasSourceId"));
                    HighMerchantStoreModel merchantStoreModel = new HighMerchantStoreModel();
                    BeanUtils.copyProperties(highMerchantStore, merchantStoreModel);
                    highMerchantStoreService.insertMerchantStore(merchantStoreModel);

                    JSONArray oilPriceList = object.getJSONArray("oilPriceList");
                    for (Object oilPrice : oilPriceList) {
                        JSONObject oilPriceObject = JSONObject.parseObject(JSONObject.toJSONString(oilPrice));
                        highGasOilPrice = new HighGasOilPrice();
                        highGasOilPrice.setMerchantStoreId(merchantStoreModel.getId());
                        highGasOilPrice.setOilNo(oilPriceObject.getString("youhao"));
                        highGasOilPrice.setOilNoName(oilPriceObject.getString("youhao") + "#");
                        highGasOilPrice.setPriceVip(oilPriceObject.getBigDecimal("priceVip"));
                        highGasOilPrice.setPriceGun(oilPriceObject.getBigDecimal("priceGun"));
                        highGasOilPrice.setPriceOfficial(oilPriceObject.getBigDecimal("priceGun"));
                        highGasOilPrice.setOilType(oilPriceObject.getInteger("oiltype"));
                        highGasOilPrice.setOilTypeName(oilPriceObject.getString("oiltype").equals("1") ? "汽油": "柴油");
                        highGasOilPriceService.editGasOilPrice(highGasOilPrice);
                    }
                }

            }

            return ResponseMsgUtil.success(jsonObject);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getOrderPay", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "getOrderPay")
    public ResponseData getOrderPay(@RequestParam(name = "orderNo", required = true) String orderNo) {
        try {


            HighOilCardOrder highOilCardOrder = highOilCardOrderService.findOrder(orderNo);

            highOilCardOrder.setStatus(2);

            JSONObject object = KytcService.getOrderPay(highOilCardOrder.getThirdOrderNo()  , highOilCardOrder.getPrice() , highOilCardOrder.getCardNo());

            highOilCardOrder.setExt1(object.toJSONString());

            highOilCardOrderService.updateOilCardOrder(highOilCardOrder);

            return ResponseMsgUtil.success("成功");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getOrderInfo", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "getOrderInfo")
    public ResponseData getOrderInfo(@RequestParam(name = "orderNo", required = true) String orderNo) {
        try {


            HighOilCardOrder highOilCardOrder = highOilCardOrderService.findOrder(orderNo);

            JSONObject object = KytcService.getOrderInfo(highOilCardOrder.getThirdOrderNo());

            highOilCardOrder.setExt2(object.toJSONString());

            if (object.getBoolean("State") == true) {
                JSONObject jsonObject = object.getJSONObject("Data");
                if (jsonObject.getInteger("OilOrderState") == 2) {
                    highOilCardOrder.setStatus(3);

                    HighOrder highOrder = highOrderService.getOrderByOrderNo(highOilCardOrder.getOrderNo());
                    highOrder.setOrderStatus(3);
                    highOrder.getHighChildOrderList().get(0).setChildOrderStatus(3);

                    highOrderService.updateOrder(highOrder);

                }
            }

            highOilCardOrderService.updateOilCardOrder(highOilCardOrder);

            return ResponseMsgUtil.success("成功");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getLogisticsMsg", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "获取物流")
    public ResponseData getLogisticsMsg(@RequestParam(name = "no", required = true) String no) {
        try {
            JSONObject jsonObjects = CommonConfig.getLogisticsMsg(no);
            return ResponseMsgUtil.success(jsonObjects);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

//    @RequestMapping(value = "/synCouponRule", method = RequestMethod.GET)
//    @ResponseBody
//    @ApiOperation(value = "获取卡券")
//    public ResponseData synCouponRule() {
//        try {
//            return ResponseMsgUtil.success(PetroConfig.synCouponRule());
//        } catch (Exception e) {
//            log.error("HighOrderController --> getBackendToken() error!", e);
//            return ResponseMsgUtil.exception(e);
//        }
//    }

//    @RequestMapping(value = "/getCoupon", method = RequestMethod.GET)
//    @ResponseBody
//    @ApiOperation(value = "卡券下单")
//    public ResponseData getCoupon() {
//        try {
//
//            JSONObject jsonObject = PetroConfig.getCoupon("16000443991501" , "18090580471" , OrderUtil.generateOrderNo());
//            String data = PetroConfig.decrypt(jsonObject.getString("biz_content"));
//            JSONObject object = JSONObject.parseObject(data);
//
//            return ResponseMsgUtil.success(object);
//        } catch (Exception e) {
//            log.error("HighOrderController --> getBackendToken() error!", e);
//            return ResponseMsgUtil.exception(e);
//        }
//    }


    @RequestMapping(value = "/deleteOilNo", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "删除油品")
    public ResponseData deleteOilNo() {
        try {

            gasService.deleteOilNo();
            return ResponseMsgUtil.success("1231243");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }
    @RequestMapping(value = "/getJiaHaoYouAllStation", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "加好油油站刷新")
    public ResponseData getJiaHaoYouAllStation() {
        try {
            gasService.getJiaHaoYouAllStation();
            return ResponseMsgUtil.success("1231243");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }
    @RequestMapping(value = "/getDianAllStation", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "点点网络")
    public ResponseData getDianAllStation() {
        try {

            gasService.getDianAllStation();
            return ResponseMsgUtil.success("1231243");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() err1or!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/integralRebateOrder", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "积分返利")
    public ResponseData integralRebateOrder() {
        try {

            // 查询满足初步返利条件订单
            List<HighOrder> order = highOrderService.integralRebateOrder();
            for (HighOrder highOrder : order) {

                // 查询是否存在积分记录
                Map<String, Object> map = new HashMap<>();
                map.put("goldType", 1);
                map.put("resType", 4);
                map.put("userId", highOrder.getMemId());
                map.put("resId", highOrder.getId());

                List<HighGoldRec> goldRecs = highGoldRecService.getGoldRec(map);

                // 判断是否重复赠送积分
                if (goldRecs.size() == 0) {
                    bsOrderRebateService.insertOrderRebate(highOrder);
                }

                highOrder.setWhetherRebate(true);
                highOrderService.updateOrderDetail(highOrder);

            }
            return ResponseMsgUtil.success("1231243");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() err1or!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/getApiCoupon", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "获取卡券")
    public ResponseData getApiCoupon() {
        try {

            // 查询满足初步返利条件订单
            List<HighOrder> order = highOrderService.integralRebateOrder();
            for (HighOrder highOrder : order) {

                // 查询是否存在积分记录
                Map<String, Object> map = new HashMap<>();
                map.put("goldType", 1);
                map.put("resType", 4);
                map.put("userId", highOrder.getMemId());
                map.put("resId", highOrder.getId());

                List<HighGoldRec> goldRecs = highGoldRecService.getGoldRec(map);

                // 判断是否重复赠送积分
                if (goldRecs.size() == 0) {
                    bsOrderRebateService.insertOrderRebate(highOrder);
                }

                highOrder.setWhetherRebate(true);
                highOrderService.updateOrderDetail(highOrder);

            }
            return ResponseMsgUtil.success("1231243");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() err1or!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/couponDetail", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "根据订单号查询中石油卡券详情")
    public ResponseData couponDetail(@RequestParam(name = "mchOrderNo", required = true) String mchOrderNo) {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20230258302");
            mapPost.put("mchOrderNo" , mchOrderNo);
            mapPost.put("timetable" , new Date().getTime());
            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "0C7897EA3BD96156A5881618FF2FF645", WXPayConstants.SignType.MD5));

            return ResponseMsgUtil.success(HttpsUtils.doPost("http://localhost:9902/v1/apiCoupon/getCheckCode" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getCouponList", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "获取卡券")
    public ResponseData getCouponList() {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20230394901");
            mapPost.put("timetable" , new Date().getTime());
            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "B94B5E62807FA56A7260AB581D8A1B48", WXPayConstants.SignType.MD5));

            return ResponseMsgUtil.success(HttpsUtils.doPost("https://hsg.dctpay.com/v1/apiCoupon/getCouponList" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/refundApi", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "支付退款")
    public ResponseData refundApi(@RequestParam(name = "mchOrderNo", required = true) String mchOrderNo) {
        try {

            ApiOrder apiOrder = apiOrderService.findByOrderNo(mchOrderNo , null);
            // 查询APi
            HighOrder order = highOrderService.getOrderByOrderNo(apiOrder.getOrderNo());

            orderService.refundOrder(order, "商户退款退款", OrderRefundOpUserType.TYPE1,
                    null,
                    "系统自动退款");

            return ResponseMsgUtil.success("退款成功");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/checkAccountBalance", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询余额")
    public ResponseData checkAccountBalance() {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20240133101");
//            mapPost.put("mchOrderNo" , mchOrderNo);
            mapPost.put("timetable" , new Date().getTime());
            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "1F43EEC88D0F99FC201D81143F9EED85", WXPayConstants.SignType.MD5));

            return ResponseMsgUtil.success(HttpsUtils.doPost("https://hsg.dctpay.com/v1/apiMerchants/checkAccountBalance" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getStationStore", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询油站")
    public ResponseData getStationStore() {
        try {

            Map<String , Object> mapPost = new HashMap<>();
            mapPost.put("merchId" , "20240587402");
//            mapPost.put("mchOrderNo" , mchOrderNo);
//            mapPost.put("timetable" , new Date().getTime());
            mapPost.put("sign" , WxUtils.generateSignApi(mapPost, "1A566F46B57830C45A06AD0AA387435C", WXPayConstants.SignType.MD5));

            return ResponseMsgUtil.success(HttpsUtils.doPost("https://hsg.dctpay.com/v1/refuelOnline/getStationStore" , mapPost , new HashMap<>()));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }




    @RequestMapping(value = "/decryptPetroConfig", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "解码")
    public ResponseData decryptPetroConfig(@RequestParam(name = "content", required = true) String content) {
        try {

            PetroConfig.init(1);

            String data = PetroConfig.decrypt(content);
            JSONObject object = JSONObject.parseObject(data);
            return ResponseMsgUtil.success(object);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }



    @RequestMapping(value = "/synCouponRule", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "synCouponRule")
    public ResponseData synCouponRule() {
        try {

            PetroConfig.init(2);

            JSONObject jsonObject = petroConfig.synCouponRule();
            String data = PetroConfig.decrypt(jsonObject.getString("jsonResult"));
            JSONArray jsonArray = JSONArray.parseArray(data);

            return ResponseMsgUtil.success(jsonArray);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getCoupon", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "getCoupon")
    public ResponseData getCoupon(@RequestParam(name = "code", required = true) String code) {
        try {

            PetroConfig.init(2);

            // 发放卡券
            JSONObject jsonObject = petroConfig.getCoupon(code ,"18090580471");
            String data = PetroConfig.decrypt(jsonObject.getString("jsonResult"));
            JSONObject object = JSONObject.parseObject(data);
            return ResponseMsgUtil.success(object);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/decrypt", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "decrypt")
    public ResponseData decrypt(@RequestParam(name = "jsonResult", required = true) String jsonResult) {
        try {

            PetroConfig.init(2);
            String data = PetroConfig.decrypt(jsonResult);
            JSONObject object = JSONObject.parseObject(data);
            return ResponseMsgUtil.success(object);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/jNiuGoodsList", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "jNiuGoodsList")
    public ResponseData jNiuGoodsList() {
        try {

            JSONObject object = RechargeConfig.jNiuGoodsList();
            JSONArray array = object.getJSONArray("data");
            List<JSONObject> list = new ArrayList<>();
            for (int i = 0; i < array.size(); i++) {
                JSONObject jsonObject = array.getJSONObject(i);
                JSONArray jsonArray = jsonObject.getJSONArray("goodsOption");
                for (int j = 0; j < jsonArray.size(); j++) {
                    JSONObject goodsOption = jsonArray.getJSONObject(j);
                    JSONArray childArray = goodsOption.getJSONArray("child");
                    for (int t = 0; t < childArray.size(); t++) {
                        JSONObject child = childArray.getJSONObject(j);
                        JSONObject data = new JSONObject();
                        data.put("title" , jsonObject.getString("sort_title") + goodsOption.getString("name"));
                        data.put("goodsId" ,  child.getString("goods_id"));
                        data.put("goodsOptionId" ,  child.getString("goods_option_id"));
                        data.put("platPrice" ,  child.getString("plat_price"));
                        data.put("officialPrice" ,  child.getString("official_price"));
                        list.add(data);
                    }

                }

            }
            return ResponseMsgUtil.success(list);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/rechargeOrderByJn", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "rechargeOrderByJn")
    public ResponseData rechargeOrderByJn() {
        try {

            JSONObject object = new JSONObject();

            object.put("orderNo", OrderUtil.generateOrderNo());
            object.put("option_id", "632");
            object.put("phone", "18090580471");
            JSONObject returnObject = RechargeConfig.rechargeOrderByJn(object);

            return ResponseMsgUtil.success(returnObject);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/checkOrderByJn", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "checkOrderByJn")
    public ResponseData checkOrderByJn(@RequestParam(name = "order_no", required = true) String order_no) {
        try {

            JSONObject object = new JSONObject();

            object.put("orderNo" , order_no);
            int status = 0;
            JSONObject jsonObject = RechargeConfig.checkOrderByJn(object);
            if (jsonObject.getJSONObject("data") != null) {
                JSONObject  objectData= jsonObject.getJSONObject("data");
                // // 10充值中 20充值完成 -10 充值失败
                // -1取消，0充值中 ，1充值成功，2充值失败，3部分成功
                if (objectData.getInteger("status") == 10) {
                    status = 0;
                } else if (objectData.getInteger("status") == 20) {
                    status =  1;
                } else if (objectData.getInteger("status") == -10) {
                    status = 2;
                }
            }

            return ResponseMsgUtil.success(status);
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value = "/getListRechargeOrder", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "getListRechargeOrder")
    public ResponseData getListRechargeOrder(@RequestParam(name = "order_no", required = true) String order_no) {
        try {

            log.info("处理话费订单定时任务开始");
            Map<String, Object> map = new HashMap<>();
            map.put("payStatus", String.valueOf(102));
            map.put("rechargeStatus", String.valueOf(201));
            List<OutRechargeOrder> orderList = outRechargeOrderService.getListRechargeOrder(map);
            log.info("处理话费订单条数:" + orderList.size());
            if (orderList.size() > 0) {
                for (OutRechargeOrder order : orderList) {
                    try {
                        outRechargeOrderService.prepaidRechargeHandle(order);
                    } catch (Exception e) {
                        log.info("话费定时任务订单业务出现异常", e);
                    }
                }
            }
            return ResponseMsgUtil.success("");
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/etcOrder", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "etcOrder")
    public ResponseData etcOrder() {
        try {
            String mobile = "18090580471";
            Map<String, Object> map = new TreeMap<>();
            map.put("requestId" , System.nanoTime());
            map.put("channelCode" , CommonSysConst.getSysConfig().getEtcChannelCode());
            map.put("timestamp" , new Date().getTime() / 1000);
            map.put("productNo" , "GZETCFXQD_GZETCCSCP");
            map.put("mobile" , RSAUtil.encryptBASE64(RSAUtil.encryptByPublicKey(mobile.getBytes(StandardCharsets.UTF_8), CommonSysConst.getSysConfig().getEtcPublicKey())));
            map.put("num" , 1);
            map.put("thirdOrderId" , OrderUtil.generateOrderNo());
            String s = StringUtils.join(map.values(), "");
            String sign = RSAUtil.sign(s.getBytes(), CommonSysConst.getSysConfig().getEtcPrivateKey());
            map.put("sign", sign);

            return ResponseMsgUtil.success(petroConfig.etcOrder(map));
        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/couJointDist", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "商户派发电子券")
    public ResponseData couJointDist(@RequestParam(name = "order_no", required = true) String order_no) {
        try {

            // 购买卡券
            JSONObject returnParam = HuiLianTongConfig.costRechargeOrder(order_no);
            // 解密
            JSONObject jsonObject = HuiLianTongUnionCardConfig.resolveResponse(returnParam.getString("data"));
            JSONArray dataArray = JSONObject.parseObject(jsonObject.getString("data"), JSONArray.class);

            return ResponseMsgUtil.success(dataArray);

        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value = "/getCarNo", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "查询车牌订单号")
    public ResponseData getCarNo(@RequestParam(name = "carNo", required = true) String carNo) {
        try {

            JSONObject jsonObject = new JSONObject();
            jsonObject.put("carNo" , carNo);
            jsonObject.put("orderStatus" , "03");

            JSONObject data = blxConfig.queryJsOrderList(jsonObject);

            return ResponseMsgUtil.success(data);

        } catch (Exception e) {
            log.error("HighOrderController --> getBackendToken() error!", e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value="/getGasDetailByStoreKey",method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "根据门店key 查询")
    public ResponseData getGasDetailByStoreKey(@RequestParam(name = "storeKey", required = true) String storeKey) {
        try {

            JSONObject jsonObject = TuanYouConfig.queryGasInfoByGasId(storeKey);
            return ResponseMsgUtil.success(jsonObject.get("result"));
        } catch (Exception e) {
            log.error("HighGasController -> getGasDetailByStoreKey() error!",e);
            return ResponseMsgUtil.exception(e);
        }
    }


    @RequestMapping(value="/getSphCoupon",method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "获取卡券")
    public ResponseData getSphCoupon() {
        try {

            JSONObject jsonObject = PetroCouponConfig.getCouponList();
            return ResponseMsgUtil.success(jsonObject);
        } catch (Exception e) {
            log.error("HighGasController -> getGasDetailByStoreKey() error!",e);
            return ResponseMsgUtil.exception(e);
        }
    }

    @RequestMapping(value="/mchBalance",method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "处理扣款")
    public ResponseData mchBalance(@RequestParam(name = "merchId", required = true) String merchId,
                                   @RequestParam(name = "mchOrderNo", required = true) String mchOrderNo) {
        ApiMerchants apiMerchants = apiMerchantsService.findByMchId(merchId);

        ApiOrder apiOrder = apiOrderService.findByOrderNo(mchOrderNo , null);

        String key = "apiMerchant" + apiMerchants.getMchId();
        try {

            // 分布式锁占坑
            Boolean lock = redisTemplate.opsForValue().setIfAbsent(key, apiOrder.getOrderNo());

            HighOrder order = highOrderService.getOrderByOrderNo(apiOrder.getOrderNo());

            if(Boolean.TRUE.equals(lock)) {

                // 判断金额是否充足
                if (!priceComputeConfig.mchBalance(apiMerchants , apiOrder.getCostPrice() , apiOrder.getMchOrderNo())) {
                    throw ErrorHelp.genException(SysCode.System, ErrorCode.INSUFFICIENT_BALANCE);
                }

                apiOrder.setStatus(3);
                apiOrderService.updateOrder(apiOrder);

                order.setOrderStatus(3);
                order.getHighChildOrderList().get(0).setChildOrderStatus(3);

                highOrderService.updateOrder(order);

            } else {
                // 加锁失败，重试
                Thread.sleep(100);
                mchBalance(merchId , mchOrderNo);
            }
            return null;
        } catch (Exception e) {
            log.error("HighGasController -> getGasDetailByStoreKey() error!",e);
            return ResponseMsgUtil.exception(e);
        } finally {
            // 删除key，释放锁
            redisTemplate.delete(key);
        }
    }

    @RequestMapping(value = "/getMerchantStoreList", method = RequestMethod.GET)
    @ResponseBody
    @ApiOperation(value = "下架团油")
    public ResponseData getMerchantStoreList() {
        try {

            // 客户端
            Map<String, Object> param = new HashMap<>();
            param.put("sourceType", 2);
//        param.put("regionId", "500000");
//        param.put("storeName", "壳牌");
            param.put("status", 1);
            List<HighMerchantStore> merchantStoreList = merchantStoreService.getMerchantStoreList(param);

            for (HighMerchantStore merchantStore : merchantStoreList) {
                merchantStore.setUpdateTime(new Date());
                merchantStore.setStatus(0);
                merchantStoreService.updateMerchantStoreDetail(merchantStore);
            }
            return ResponseMsgUtil.success("成功");

        } catch (Exception e) {
            return ResponseMsgUtil.exception(e);
        }
    }

}


\ No newline at end of file
diff --git a/hai-cweb/src/main/java/com/cweb/controller/Etc/EtcCustomerController.java b/hai-cweb/src/main/java/com/cweb/controller/Etc/EtcCustomerController.java
index 0bed5ac7..105bb736 100644
--- a/hai-cweb/src/main/java/com/cweb/controller/Etc/EtcCustomerController.java
+++ b/hai-cweb/src/main/java/com/cweb/controller/Etc/EtcCustomerController.java
@@ -186,6 +186,8 @@ public class EtcCustomerController {
         }
     }
 
+
+
     @RequestMapping(value = "/sendSignVerifyCode", method = RequestMethod.GET)
     @ResponseBody
     @ApiOperation(value = "签约验证码发送接口")
diff --git a/hai-service/src/main/java/com/hai/etc/impl/EtcCarMsgServiceImpl.java b/hai-service/src/main/java/com/hai/etc/impl/EtcCarMsgServiceImpl.java
index 60d9ed67..f765d095 100644
--- a/hai-service/src/main/java/com/hai/etc/impl/EtcCarMsgServiceImpl.java
+++ b/hai-service/src/main/java/com/hai/etc/impl/EtcCarMsgServiceImpl.java
@@ -186,6 +186,9 @@ public class EtcCarMsgServiceImpl implements EtcCarMsgService {
         if (MapUtils.getString(map , "custId") != null) {
             criteria.andCustIdEqualTo(MapUtils.getString(map , "custId"));
         }
+        if (MapUtils.getInteger(map , "vehStatus") != null) {
+            criteria.andVehStatusEqualTo(MapUtils.getInteger(map , "vehStatus"));
+        }
 
         return etcContractOrderMapper.selectByExample(example);
     }
diff --git a/hai-service/src/main/java/com/hai/etc/impl/EtcCustMsgServiceImpl.java b/hai-service/src/main/java/com/hai/etc/impl/EtcCustMsgServiceImpl.java
index 402004b4..1a9f5c14 100644
--- a/hai-service/src/main/java/com/hai/etc/impl/EtcCustMsgServiceImpl.java
+++ b/hai-service/src/main/java/com/hai/etc/impl/EtcCustMsgServiceImpl.java
@@ -62,7 +62,6 @@ public class EtcCustMsgServiceImpl implements EtcCustMsgService {
         if (MapUtils.getString(map , "phone") != null) {
             criteria.andPhoneEqualTo(MapUtils.getString(map , "phone"));
         }
-        criteria.andStatusNotEqualTo(0);
 
         example.setOrderByClause("create_time desc");
 
diff --git a/hai-service/src/main/java/com/hai/openApi/config/PriceComputeConfig.java b/hai-service/src/main/java/com/hai/openApi/config/PriceComputeConfig.java
index f5a96639..c0f15218 100644
--- a/hai-service/src/main/java/com/hai/openApi/config/PriceComputeConfig.java
+++ b/hai-service/src/main/java/com/hai/openApi/config/PriceComputeConfig.java
@@ -69,6 +69,7 @@ public class PriceComputeConfig {
         apiAmountRecordService.insertAmountRecord(apiAmountRecord);
 
 
+
         return true;
     }
 
diff --git a/hai-service/src/main/java/com/hai/openApi/service/ApiOrderService.java b/hai-service/src/main/java/com/hai/openApi/service/ApiOrderService.java
index c8be22ba..4a65e205 100644
--- a/hai-service/src/main/java/com/hai/openApi/service/ApiOrderService.java
+++ b/hai-service/src/main/java/com/hai/openApi/service/ApiOrderService.java
@@ -58,6 +58,17 @@ public interface ApiOrderService {
      */
     ApiOrder findByOrderNo(String mchOrderNo , String orderNo);
 
+    /**
+     * @Author Sum1Dream
+     * @Name createOrder
+     * @Description // 创建订单
+     * @Date 17:44 2023/2/28
+     * @Param [object]
+     * @Return void
+     */
+    void updateOrder(ApiOrder apiOrder) throws Exception;
+
+
     /**
      * @Author Sum1Dream
      * @Name refund
diff --git a/hai-service/src/main/java/com/hai/openApi/service/impl/ApiOrderServiceImpl.java b/hai-service/src/main/java/com/hai/openApi/service/impl/ApiOrderServiceImpl.java
index e9afbc1a..d0462862 100644
--- a/hai-service/src/main/java/com/hai/openApi/service/impl/ApiOrderServiceImpl.java
+++ b/hai-service/src/main/java/com/hai/openApi/service/impl/ApiOrderServiceImpl.java
@@ -419,6 +419,11 @@ public class ApiOrderServiceImpl implements ApiOrderService {
         return null;
     }
 
+    @Override
+    public void updateOrder(ApiOrder apiOrder) throws Exception {
+         apiOrderMapper.updateByPrimaryKey(apiOrder);
+    }
+
     @Override
     @Transactional(propagation = Propagation.REQUIRES_NEW)
     public void refund(String orderNo) {
diff --git a/hai-service/src/main/java/com/hai/service/impl/HighGasServiceImpl.java b/hai-service/src/main/java/com/hai/service/impl/HighGasServiceImpl.java
index 5016b818..cef7c97e 100644
--- a/hai-service/src/main/java/com/hai/service/impl/HighGasServiceImpl.java
+++ b/hai-service/src/main/java/com/hai/service/impl/HighGasServiceImpl.java
@@ -825,6 +825,7 @@ public class HighGasServiceImpl implements HighGasService {
         Map<String, Object> param = new HashMap<>();
         param.put("sourceType", 2);
         param.put("regionId", "500000");
+        param.put("storeName", "壳牌");
         param.put("status", 1);
         List<HighMerchantStore> merchantStoreList = merchantStoreService.getMerchantStoreList(param);
 
diff --git a/hai-service/src/main/java/com/hai/service/impl/OutRechargeOrderServiceImpl.java b/hai-service/src/main/java/com/hai/service/impl/OutRechargeOrderServiceImpl.java
index 81ae82a9..42e24d03 100644
--- a/hai-service/src/main/java/com/hai/service/impl/OutRechargeOrderServiceImpl.java
+++ b/hai-service/src/main/java/com/hai/service/impl/OutRechargeOrderServiceImpl.java
@@ -791,7 +791,7 @@ public class OutRechargeOrderServiceImpl implements OutRechargeOrderService {
                 object.put("orderNo" , childOrder.getOrderNo());
 
                 JSONObject jsonObject = RechargeConfig.checkOrderByJn(object);
-                childOrder.setExt3("畅停查询"+ jsonObject);
+                childOrder.setExt3("简牛查询"+ jsonObject);
                 if (jsonObject.getJSONObject("data") != null) {
                     JSONObject  objectData= jsonObject.getJSONObject("data");
                     // // 10充值中 20充值完成 -10 充值失败
diff --git a/v1/src/main/java/com/v1/controller/business/DiscountController.java b/v1/src/main/java/com/v1/controller/business/DiscountController.java
index 33818b67..3c502e8f 100644
--- a/v1/src/main/java/com/v1/controller/business/DiscountController.java
+++ b/v1/src/main/java/com/v1/controller/business/DiscountController.java
@@ -1,12 +1,15 @@
 package com.v1.controller.business;
 
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
 import com.hai.common.exception.ErrorCode;
 import com.hai.common.exception.ErrorHelp;
 import com.hai.common.exception.SysCode;
 import com.hai.common.utils.ResponseMsgUtil;
-import com.hai.entity.ApiKfcStores;
-import com.hai.entity.ApiMerchants;
+import com.hai.config.QianZhuConfig;
+import com.hai.entity.*;
 import com.hai.model.ResponseData;
 import com.hai.openApi.config.PriceComputeConfig;
 import com.hai.openApi.service.ApiMchProductService;
@@ -18,13 +21,11 @@ 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.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -48,6 +49,12 @@ public class DiscountController {
     @Resource
     private HighDiscountPackageService highDiscountPackageService;
 
+    @Resource
+    private HighUserService highUserService;
+
+    @Resource
+    private HighDiscountUserRelService highDiscountUserRelService;
+
     @RequestMapping(value = "/presentDiscount", method = RequestMethod.POST)
     @ResponseBody
     @ApiOperation(value = "赠送优惠券")
@@ -69,8 +76,8 @@ public class DiscountController {
 
             if (
                     StringUtils.isBlank(object.getString("merchId")) ||
-                    StringUtils.isBlank(object.getString("packageId")) ||
-                    StringUtils.isBlank(object.getString("phone")) ||
+                            StringUtils.isBlank(object.getString("packageId")) ||
+                            StringUtils.isBlank(object.getString("phone")) ||
                             StringUtils.isBlank(object.getString("sign"))
             ) {
                 log.error("getRechargeProduct error!", "请求参数校验失败！");
@@ -84,11 +91,6 @@ public class DiscountController {
                 throw ErrorHelp.genException(SysCode.System, ErrorCode.ACCOUNT_NOT_EXIST);
             }
 
-            if (!secConfigService.isConfig(OrderProductType.PRODUCT_TYPE2.getApiCode(), object.getString("merchId"))) {
-                log.error("getAllCities error!", "当前帐户无权限查询！");
-                throw ErrorHelp.genException(SysCode.System, ErrorCode.MERCHANT_NOT_AUTHORIZED, "");
-            }
-
             Map<String , Object> map = new HashMap<>();
             map.put("apiKey" , apiMerchants.getApiKey());
             map.put("packageId" , object.getString("packageId"));
@@ -111,4 +113,56 @@ public class DiscountController {
         }
     }
 
+    @RequestMapping(value = "/getDiscountPackage", method = RequestMethod.GET)
+    @ResponseBody
+    @ApiOperation(value = "查询可用优惠券包")
+    public ResponseData getDiscountPackage(@RequestParam(name = "type", required = true) Integer type , HttpServletRequest request) {
+        try {
+
+            Map<String, Object> map = new HashMap<>();
+            map.put("usingAttribution", type);
+            map.put("status" , 1);
+
+            List<JSONObject> list = new ArrayList<>();
+
+            List<HighDiscountPackage> discountPackages = highDiscountPackageService.getDiscountPackageList(map);
+
+            for (HighDiscountPackage discountPackage : discountPackages) {
+                JSONObject object = new JSONObject();
+                object.put("packageDetail" , highDiscountPackageService.findDiscountPackageById(discountPackage.getId()));
+                object.put("discountPackage" , discountPackage);
+                list.add(object);
+            }
+
+            return ResponseMsgUtil.success(list);
+
+        } catch (Exception e) {
+            log.error("HighUserCardController --> oilCardRefund() error!", e);
+            return ResponseMsgUtil.exception(e);
+        }
+    }
+
+    @RequestMapping(value = "/getUserDiscountList", method = RequestMethod.GET)
+    @ResponseBody
+    @ApiOperation(value = "查询用户优惠券")
+    public ResponseData getUserDiscountList(@RequestParam(name = "phone", required = true) String phone , HttpServletRequest request) {
+        try {
+
+            HighUser user = highUserService.findByPhone(phone);
+
+            if (user == null) {
+                throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR , "用户不存在！");
+            }
+
+            Map<String,Object> map = new HashMap<>();
+            map.put("userId", user.getId());
+
+            return ResponseMsgUtil.success(highDiscountUserRelService.getDiscountList(map));
+
+        } catch (Exception e) {
+            log.error("HighUserCardController --> oilCardRefund() error!", e);
+            return ResponseMsgUtil.exception(e);
+        }
+    }
+
 }
diff --git a/v1/src/main/java/com/v1/controller/orderController.java b/v1/src/main/java/com/v1/controller/orderController.java
index 49e0bbf4..b8a65d7a 100644
--- a/v1/src/main/java/com/v1/controller/orderController.java
+++ b/v1/src/main/java/com/v1/controller/orderController.java
@@ -1,10 +1,12 @@
 package com.v1.controller;
 
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.hai.common.exception.ErrorCode;
 import com.hai.common.exception.ErrorHelp;
 import com.hai.common.exception.SysCode;
 import com.hai.common.utils.ResponseMsgUtil;
+import com.hai.config.QianZhuConfig;
 import com.hai.config.WxOrderConfig;
 import com.hai.entity.ApiMerchants;
 import com.hai.entity.ApiOrder;
@@ -12,6 +14,7 @@ import com.hai.entity.ApiProductConfig;
 import com.hai.entity.HighOrder;
 import com.hai.model.OrderRefundModel;
 import com.hai.model.ResponseData;
+import com.hai.model.ThirdPartyModel;
 import com.hai.openApi.service.ApiOrderService;
 import com.hai.order.model.RefundPriceModel;
 import com.hai.order.service.OrderService;
@@ -27,15 +30,15 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import javax.sound.midi.Soundbank;
+import java.math.BigDecimal;
+import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 
 @Controller
@@ -83,11 +86,11 @@ public class orderController {
             }  else  {
                 ip = request.getHeader("x-forwarded-for");
             }
-
-            if (!apiIpAddressService.validationIpAddressLegal(object.getString("merchId") , ip)) {
-                log.error("getRechargeProduct error!", "非法ip地址，请联系管理人员！");
-                throw ErrorHelp.genException(SysCode.System, ErrorCode.IP_ERROR, "非法ip地址，请联系管理人员！");
-            }
+//
+//            if (!apiIpAddressService.validationIpAddressLegal(object.getString("merchId") , ip)) {
+//                log.error("getRechargeProduct error!", "非法ip地址，请联系管理人员！");
+//                throw ErrorHelp.genException(SysCode.System, ErrorCode.IP_ERROR, "非法ip地址，请联系管理人员！");
+//            }
 
             if (
                     StringUtils.isBlank(object.getString("productType")) ||
@@ -210,10 +213,10 @@ public class orderController {
                 ip = request.getHeader("x-forwarded-for");
             }
 
-            if (!apiIpAddressService.validationIpAddressLegal(object.getString("merchId") , ip)) {
-                log.error("getRechargeProduct error!", "非法ip地址，请联系管理人员！");
-                throw ErrorHelp.genException(SysCode.System, ErrorCode.IP_ERROR, "非法ip地址，请联系管理人员！");
-            }
+//            if (!apiIpAddressService.validationIpAddressLegal(object.getString("merchId") , ip)) {
+//                log.error("getRechargeProduct error!", "非法ip地址，请联系管理人员！");
+//                throw ErrorHelp.genException(SysCode.System, ErrorCode.IP_ERROR, "非法ip地址，请联系管理人员！");
+//            }
 
             if (
                             StringUtils.isBlank(object.getString("mchOrderNo")) ||
@@ -276,11 +279,11 @@ public class orderController {
             }  else  {
                 ip = request.getHeader("x-forwarded-for");
             }
-
-            if (!apiIpAddressService.validationIpAddressLegal(object.getString("merchId") , ip)) {
-                log.error("getRechargeProduct error!", "非法ip地址，请联系管理人员！");
-                throw ErrorHelp.genException(SysCode.System, ErrorCode.IP_ERROR, "非法ip地址，请联系管理人员！");
-            }
+//
+//            if (!apiIpAddressService.validationIpAddressLegal(object.getString("merchId") , ip)) {
+//                log.error("getRechargeProduct error!", "非法ip地址，请联系管理人员！");
+//                throw ErrorHelp.genException(SysCode.System, ErrorCode.IP_ERROR, "非法ip地址，请联系管理人员！");
+//            }
 
             if (
                             StringUtils.isBlank(object.getString("mchOrderNo")) ||
@@ -330,10 +333,10 @@ public class orderController {
                 ip = request.getHeader("x-forwarded-for");
             }
 
-            if (!apiIpAddressService.validationIpAddressLegal(object.getString("merchId") , ip)) {
-                log.error("getRechargeProduct error!", "非法ip地址，请联系管理人员！");
-                throw ErrorHelp.genException(SysCode.System, ErrorCode.IP_ERROR, "非法ip地址，请联系管理人员！");
-            }
+//            if (!apiIpAddressService.validationIpAddressLegal(object.getString("merchId") , ip)) {
+//                log.error("getRechargeProduct error!", "非法ip地址，请联系管理人员！");
+//                throw ErrorHelp.genException(SysCode.System, ErrorCode.IP_ERROR, "非法ip地址，请联系管理人员！");
+//            }
 
             if (
                     StringUtils.isBlank(object.getString("mchOrderNo")) ||
@@ -403,10 +406,10 @@ public class orderController {
                 ip = request.getHeader("x-forwarded-for");
             }
 
-            if (!apiIpAddressService.validationIpAddressLegal(object.getString("merchId") , ip)) {
-                log.error("getRechargeProduct error!", "非法ip地址，请联系管理人员！");
-                throw ErrorHelp.genException(SysCode.System, ErrorCode.IP_ERROR, "非法ip地址，请联系管理人员！");
-            }
+//            if (!apiIpAddressService.validationIpAddressLegal(object.getString("merchId") , ip)) {
+//                log.error("getRechargeProduct error!", "非法ip地址，请联系管理人员！");
+//                throw ErrorHelp.genException(SysCode.System, ErrorCode.IP_ERROR, "非法ip地址，请联系管理人员！");
+//            }
 
             if (
                             StringUtils.isBlank(object.getString("paySerialNo")) ||
@@ -449,4 +452,81 @@ public class orderController {
     }
 
 
+
+    @RequestMapping(value = "/getThirdOrderByOrderNo", method = RequestMethod.GET)
+    @ResponseBody
+    @ApiOperation(value = "查询第三方订单详情")
+    public ResponseData getThirdOrderByOrderNo(@RequestParam(name = "mchOrderNo", required = true) String mchOrderNo , HttpServletRequest request) {
+        try {
+
+            String ip = "";
+            // 有的user可能使用代理，为处理用户使用代理的情况，使用x-forwarded-for
+            if  (request.getHeader("x-forwarded-for") == null)  {
+                ip = request.getRemoteAddr();
+            }  else  {
+                ip = request.getHeader("x-forwarded-for");
+            }
+
+//            if (!apiIpAddressService.validationIpAddressLegal(object.getString("merchId") , ip)) {
+//                log.error("getRechargeProduct error!", "非法ip地址，请联系管理人员！");
+//                throw ErrorHelp.genException(SysCode.System, ErrorCode.IP_ERROR, "非法ip地址，请联系管理人员！");
+//            }
+
+            ApiOrder apiOrder = apiOrderService.findByOrderNo(mchOrderNo , null);
+
+            HighOrder order = highOrderService.getOrderByOrderNo(apiOrder.getOrderNo());
+
+            JSONObject object;
+            List<Map<String, Object>> list = new ArrayList<>();
+
+
+            if (order.getHighChildOrderList().get(0).getGoodsType() == 4) {
+
+                object = QianZhuConfig.getKfcOrderByOrderNo(order.getHighChildOrderList().get(0).getChannelOrderNo());
+                if (object.getBoolean("success")) {
+                    if (object.getJSONObject("data").getString("ticket") != null) {
+                        String[] s =  object.getJSONObject("data").getString("ticket").split(",");
+
+                        for (String s1 : s) {
+                            Map<String , Object> map = new HashMap<>();
+                            String[] childString = s1.split("\\|");
+                            map.put("code" , childString[0]);
+                            list.add(map);
+                        }
+
+                    }
+
+                } else {
+                    log.error("getThirdOrderByOrderId error!", "查询失败！");
+                    throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, object.getString("message"));
+                }
+            } else if (order.getHighChildOrderList().get(0).getGoodsType() == 9) {
+
+                object = QianZhuConfig.starbucksOrderByOrderNo(order.getHighChildOrderList().get(0).getChannelOrderNo());
+                if (object.getBoolean("success")) {
+
+                    JSONArray jsonObject = object.getJSONObject("data").getJSONArray("orderItems");
+
+                    for (Object a : jsonObject) {
+                        JSONObject orderItem = (JSONObject) a;
+                        Map<String , Object> map = new HashMap<>();
+                        map.put("code" , orderItem.getString("code"));
+                        list.add(map);
+                    }
+
+
+                }else {
+                    log.error("getThirdOrderByOrderId error!", "查询失败！");
+                    throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, object.getString("message"));
+                }
+            }
+            return ResponseMsgUtil.success(list);
+        } catch (Exception e) {
+            log.error("HighUserCardController --> oilCardRefund() error!", e);
+            return ResponseMsgUtil.exception(e);
+        }
+    }
+
+
+
 }