package com.rnt.service;

import java.math.BigDecimal;
import java.util.HashMap;
import java.util.Map;

import com.rnt.vo.RoadsideRequest;
import org.beetl.sql.core.kit.StringKit;

import com.alibaba.fastjson.JSONObject;
import com.jfinal.kit.Prop;
import com.jfinal.kit.PropKit;
import com.jfinal.log.Log;
import com.rnt.commo.enums.ErrorType;
import com.rnt.commo.enums.OrderTypeEnum;
import com.rnt.model.park.IrainPknoRelation;
import com.rnt.model.zf.Order;
import com.rnt.model.zf.OrderDetailPark;
import com.rnt.utils.HttpClientTutorial;
import com.rnt.utils.MD5Utils;
import com.rnt.vo.BizResult;

/**
 * 艾润费用查询service.<br/>
 *
 * Copyright: Copyright (c) 2017  zteits
 *
 * @ClassName: IRainQueryService.java
 * @Description:
 * @version: v1.0.0
 * @author: wangfs
 * @date: 2017年6月13日   上午9:25:31
 * Modification History:
 * Date             Author          Version            Description
 * ---------------------------------------------------------*
 * 2017年6月13日      wangfs           v1.0.0               创建
 */
public class IRainQueryService {
    private static final Log logger = Log.getLog(IRainQueryService.class);

	 /**
	  * 调用艾润查询费用接口.<br/>
	  * @param carNum
	  * @param parkCode
	  * @return
	  */
	public Map<String, String> billQuery(String carNum,String parkCode) {
		logger.info("---begin调用艾润查询费用接口,入参={carNum,parkCode}="+"{"+carNum+","+parkCode+"}");
		//1.查询停车场关系映射表－获取艾润停车场查询费用编码 ztetis-park.irain_pkno_relation
		StringBuffer sql = new StringBuffer("select a.irain_pkno1");
		sql.append(" from irain_pkno_relation a");
		sql.append(" where a.park_lotpkno = ?");
		String rs  = "";
		Map<String, String> map = new HashMap<String, String>();
		IrainPknoRelation irainPknoRelation = new IrainPknoRelation().findFirst(sql.toString(), parkCode);
		logger.info("获取查询费用编码数据结果="+JSONObject.toJSON(irainPknoRelation));
		if(irainPknoRelation != null && StringKit.isNotBlank(irainPknoRelation.getIrainPkno1())){
			/****  以下为模拟入参    实际入参 由app提供-------------------------------------*/
			Prop prop = PropKit.use("a_little_config.txt");
		    Long time = System.currentTimeMillis();
			String md5  = MD5Utils.enMD5(prop.get("irain.appid")+prop.get("irain.appsecret")+time);
			Map<String, Object> params = new HashMap<>();
			params.put("appid", prop.get("irain.appid"));
			params.put("sign", md5);
			params.put("timestamp", time);
			params.put("vpl_number", carNum);
			params.put("park_code", irainPknoRelation.getIrainPkno1());
			
			try {
				logger.info("irain 查询停车费用入参:" + JSONObject.toJSONString(params));
				 rs = HttpClientTutorial.httpPostRequest(prop.get("irain.url")+"/bill/Query", params);
				logger.info("irain 查询停车费用返回:" + JSONObject.toJSONString(rs));
				 if (StringKit.isNotBlank(rs) && !"NO_PARK_RECORD".equals(JSONObject.parseObject(rs).get("code"))) {
			         map = this.jsonToMapForIrunResult(rs);
				 }else{
					 logger.info("调用艾润费用查询接口:无停车记录");
				 }
				
			} catch (Exception e) {
				logger.info("irain 查询停车费用出错:" + e);
			}
		}else{
			logger.info("没有查询到艾润查询费用编码");
		}
		 
		logger.info("---end调用艾润查询费用接口,结果＝"+JSONObject.toJSON(map));
		
	
		return map;
	}
	
	/**
	 * 青岛路侧费用查询接口.<br/>
	 * @param recordId
	 * @return
	 */
	public static Map<String, String> queryBillRoadside(String recordId){
		logger.info("---begin调用青岛路侧费用查询接口,入参={recordId}="+"{"+recordId+"}");
		Prop prop = PropKit.use("a_little_config.txt");
		Map<String, Object> params = new HashMap<>();
		 Long time = System.currentTimeMillis();
		params.put("orderCode", recordId);
		params.put("timestamp",time);
		Map<String, String> rsMap = new HashMap<String, String>();
		try{
			System.out.println("调用接口地址＝"+prop.get("qindao.url"));
			String qingdaors = HttpClientTutorial.httpPostRequest(prop.get("qindao.url")+"", JSONObject.toJSONString(params));
			logger.info("青岛路侧查询停车费用返回:" + JSONObject.toJSONString(qingdaors));
			RoadsideRequest roadsideRequest = JSONObject.parseObject(qingdaors,RoadsideRequest.class);
			logger.info("青岛路侧返回JSON转换对象结果"+JSONObject.toJSON(roadsideRequest));
			if(roadsideRequest != null){
				rsMap.put("record_id", roadsideRequest.getOrderCode());
				// 出场时间
				rsMap.put("park_out_time", roadsideRequest.getOuttime());
				//入场时间
				rsMap.put("park_in_time", roadsideRequest.getIntime());
				//总费用
				rsMap.put("order_total_fee", roadsideRequest.getOrderPay() != null ? roadsideRequest.getOrderPay().toString() :"1");
                //已付费用
				rsMap.put("order_payed_fee", "0");
                //未支付费用(本次应付金额)
				rsMap.put("order_not_pay_fee", roadsideRequest.getOrderPay() != null ? roadsideRequest.getOrderPay().toString() :"1");
				//停车时长  单位：秒
				rsMap.put("parking_duration",roadsideRequest.getStaytime() != null ? String.valueOf(roadsideRequest.getStaytime()) :"1");
				//停车场名车
				rsMap.put("park_name", roadsideRequest.getParkName());
			}
			
		}catch (Exception e) {
			e.printStackTrace();
		}
		logger.info("---end调用青岛路侧费用查询接口,结果＝"+JSONObject.toJSON(rsMap));
		return rsMap;
	}
	
	
	
	/**
     * 获取查询费用返回结果.<br/>
     *
     * @param json
     * @return
     */
    private  Map<String, String> jsonToMapForIrunResult(String json) {

        JSONObject jsobj = JSONObject.parseObject(json);
        Map<String, String> map = new HashMap<String, String>();
        if (jsobj != null) {
            if (!jsobj.get("status").toString().equals("0")) {
                JSONObject data = (JSONObject)jsobj.get("data");
                // 出场时间对象
                JSONObject parkOutObject = (JSONObject)data.get("out");
                //停车记录id
                map.put("record_id", data.getString("id"));
                // 出场时间
                map.put("park_out_time", parkOutObject.getString("time"));
                if (data.get("park") != null) {
                    map.put("park_name", JSONObject.parseObject(data.get("park").toString()).get("name") + "");
                    map.put("park_address", JSONObject.parseObject(data.get("park").toString()).get("address") + "");
                }

                //入场时间
                if (data.get("in") != null) {
                    map.put("park_in_time", JSONObject.parseObject(data.get("in").toString()).getString("time"));
                }
                //总费用
                map.put("order_total_fee", JSONObject.parseObject(data.get("charge").toString()).getString("due"));
                //已付费用
                map.put("order_payed_fee", JSONObject.parseObject(data.get("charge").toString()).getString("paid"));
                //未支付费用(本次应付金额)
                map.put("order_not_pay_fee", JSONObject.parseObject(data.get("charge").toString()).getString("unpaid"));
                //停车时长  单位：秒
                map.put("parking_duration",
                    JSONObject.parseObject(data.get("charge").toString()).getString("duration"));
            }
        }
        return map;
    }
    
  
    
    /***
     * 支付完成,停车通过栏杆
     */

    public BizResult<String> passHandrail(String orderId) throws Exception {
        BizResult<String> bizResult = new BizResult<>();
        logger.info(" 支付完成，通知抬杆 ----start--- req=" + orderId);
        Order order = Order.dao.findFirst("SELECT * FROM  td_b_order t where t.order_id = ?", orderId);
        if (null == order) {
            logger.info(" 支付完成，通知抬杆 订单不存在 orderId=" + orderId);
            bizResult.setErrorMessage(ErrorType.ORDER_NO_EXISTS, "订单不存在");
            return bizResult;
        }

        if (order.getSourceType().equals(OrderTypeEnum.ORDER_SOURCE_TYPE_IN)) {
            /**
             * 艾润通知
             */
            bizResult = passIRail(order.getCarNumber(), order.getParkId(), order.getOrderTotalFee());
            logger.info("艾润抬杆通知 返回为: bizResult=" + JSONObject.toJSONString(bizResult));

        } else if (order.getSourceType().equals(OrderTypeEnum.ORDER_SOURCE_TYPE_OUT)) {
            /**
             * 青岛
             */
            bizResult = passQD(order);

        } else {
            logger.info("支付完成，通知抬杆  未知的订单来源类型: orderSourceType=" + order.getSourceType());
            bizResult.setErrorMessage(ErrorType.BIZ_ERROR, "未知的订单来源类型");
        }

        return bizResult;

    }

    /**
     * 艾润抬杆设置
     */
    private BizResult<String> passIRail(String vpl_number, String park_code, BigDecimal amount) throws Exception {
        BizResult<String> bizResult = new BizResult<>();
        //1.查询停车场关系映射表－获取艾润停车场查询费用编码 ztetis-park.irain_pkno_relation
        StringBuffer sql = new StringBuffer("select a.irain_pkno1");
        sql.append(" from irain_pkno_relation a");
        sql.append(" where a.park_lotpkno = ?");
        String rs = "";
        IrainPknoRelation irainPknoRelation = new IrainPknoRelation().findFirst(sql.toString(), park_code);

        if (irainPknoRelation != null && StringKit.isNotBlank(irainPknoRelation.getIrainPkno2())) {
            /****  以下为模拟入参    实际入参 由app提供-------------------------------------*/
            Prop prop = PropKit.use("a_little_config.txt");
            Long time = System.currentTimeMillis();
            String md5 = MD5Utils.enMD5(prop.get("irain.appid") + prop.get("irain.appsecret") + time);
            Map<String, Object> params = new HashMap<>();
            params.put("appid", prop.get("irain.appid"));
            params.put("sign", md5);
            params.put("timestamp", time);
            params.put("vpl_number", vpl_number);
            //要用进出场上报的那个编码
            params.put("park_code", irainPknoRelation.getIrainPkno2());
            params.put("amount", amount.intValue());

            logger.info("开始通知irain 支付已经完成:" + JSONObject.toJSONString(params));
            rs = HttpClientTutorial.httpPostRequest(prop.get("irain.url") + "/pay/Issued", params);
            logger.info("结束通知irain 支付已经完成::" + rs);
            JSONObject result = JSONObject.parseObject(rs);

            if ("OK".equals(result.getString("message"))) {
                bizResult.setData("通知成功!");
            } else {
                bizResult.setErrorMessage(ErrorType.BIZ_ERROR, "通知irain 支付已经完成失败!");

            }
            return bizResult;

        } else {
            logger.info("没有查询到艾润进出场上报编码");
            bizResult.setErrorMessage(ErrorType.BIZ_ERROR, "未查询到艾润进出场上报编码");
            return bizResult;
        }

    }

    /**
     * 青岛抬杆设置
     */
    private BizResult<String> passQD(Order order) throws Exception {
        BizResult<String> bizResult = new BizResult<>();
        String url = PropKit.get("qd.retrun_fee_url");
        OrderDetailPark orderDetailPark = OrderDetailPark.dao.findFirst(
            "SELECT  * FROM  td_b_order_detail_park t where t.order_id = ?", order.getOrderId());

        Map<String, Object> params = new HashMap<>();
        params.put("orderCode", orderDetailPark.getRecordId());
        params.put("amount", order.getOrderTotalFee().intValue());
        params.put("orderPay", order.getOrderPayedFee().intValue());
        params.put("payType", 1);

        logger.info("开始通知irain 支付已经完成:" + JSONObject.toJSONString(params));
        String rs = HttpClientTutorial.httpPostRequest(url, JSONObject.toJSONString(params));
        logger.info("结束通知irain 支付已经完成:" + rs);
        JSONObject result = JSONObject.parseObject(rs);
        if ("1".equals(result.getString("status"))) {
            bizResult.setData("通知成功!");
        } else {
            bizResult.setErrorMessage(ErrorType.BIZ_ERROR, "通知青岛 支付已经完成失败!");
        }
        return bizResult;
    }

    public static void main(String[] args) {
		queryBillRoadside("869775012497209-170030-2017-05-31 09:10:00");
	}
   
}