//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by FernFlower decompiler)
//

package com.zteits.park.util;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.jtjt.upload.client.common.AbstractManager;
import com.jtjt.upload.client.common.TokenUtil;
import com.jtjt.upload.client.constant.ParkClassConstant;
import com.jtjt.upload.client.constant.ParkClassificationConstant;
import com.jtjt.upload.client.constant.ParkLocationClassConstant;
import com.jtjt.upload.client.constant.ParkNatureConstant;
import com.jtjt.upload.client.constant.ParkShareConstant;
import com.jtjt.upload.client.constant.ParkStageConstant;
import com.jtjt.upload.client.constant.ParkTypeConstant;
import com.jtjt.upload.client.constant.ParkingTypeConstant;
import com.jtjt.upload.client.constant.PayTypeConstant;
import com.jtjt.upload.client.constant.PropertyTypeConstant;
import com.jtjt.upload.client.constant.SpaceLocConstant;
import com.jtjt.upload.client.constant.VehicleColorConstant;
import com.jtjt.upload.client.vo.BerthsVO;
import com.jtjt.upload.client.vo.ChargePileVO;
import com.jtjt.upload.client.vo.ChargeStandardsVO;
import com.jtjt.upload.client.vo.ClientDetails;
import com.jtjt.upload.client.vo.CollectEquipmentVO;
import com.jtjt.upload.client.vo.CompanyVO;
import com.jtjt.upload.client.vo.MechanicalParkVO;
import com.jtjt.upload.client.vo.ParkEntracneExitInfoVo;
import com.jtjt.upload.client.vo.ParkEntranceExitInfoListVo;
import com.jtjt.upload.client.vo.ParkEntryVO;
import com.jtjt.upload.client.vo.ParkExitVO;
import com.jtjt.upload.client.vo.ParkFreeVO;
import com.jtjt.upload.client.vo.ParkInfoVO;
import com.jtjt.upload.client.vo.ParkOrder;
import com.jtjt.upload.client.vo.TokenInfo;
import java.io.IOException;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;

import com.zteits.clouds.api.apibase.constants.ErrorType;
import com.zteits.clouds.api.apibase.exception.BizException;
import com.zteits.park.domain.HubEnterpriseInfo;
import com.zteits.park.domain.HubParkingInfoBO;
import com.zteits.park.job.datahub.ParkingInfoPushJob;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
import org.apache.commons.lang3.tuple.Pair;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class ParkInfoUtil extends AbstractManager {
    private static final Logger logger = LoggerFactory.getLogger(ParkInfoUtil.class);
    private static ParkInfoUtil singObj = null;
    private OkHttpClient client = null;

    private ParkInfoUtil() {
    }

    public static ParkInfoUtil getSingleInstance() {
        if (null == singObj) {
            synchronized(TokenUtil.class) {
                if (null == singObj) {
                    singObj = new ParkInfoUtil();
                    singObj.client = (new OkHttpClient()).newBuilder().build();
                }
            }
        }

        return singObj;
    }

    public int sendCompany(String urlPrefix, String accessToken, HubEnterpriseInfo companyVO) {
        this.validateField(companyVO);
        MediaType mediaType = MediaType.parse("application/json");
        String content = JSON.toJSONString(companyVO, new SerializerFeature[]{SerializerFeature.WriteEnumUsingToString});
        logger.info("发送运营企业信息:{}", content);
        RequestBody body = RequestBody.create(mediaType, content);
        Request request = (new Request.Builder()).url(urlPrefix + "/parkdatacenter/odsCompany/insert").method("POST", body).addHeader("Authorization", "Bearer " + accessToken).addHeader("Content-Type", "application/json").build();

        try (Response response = this.client.newCall(request).execute()) {
            String str = response.body().string();
            if (response.isSuccessful()) {
                logger.info("发送运营企业信息成功" + str);
            } else {
                logger.info("发送运营企业信息失败：" + str);
            }
            return response.code();
        } catch (IOException e) {
            logger.error("发送异常", e);
        }
        return -1;
    }

    public int sendParkInfo(String urlPrefix, String accessToken, HubParkingInfoBO parkInfoVO) {
        this.validateField(parkInfoVO);
        MediaType mediaType = MediaType.parse("application/json");
        String content = JSON.toJSONString(parkInfoVO);
        logger.info("发送车场信息:{}", content);
        RequestBody body = RequestBody.create(mediaType, content);
        Request request = (new Request.Builder()).url(urlPrefix + "/parkdatacenter/parkMessageLifeCycleInfo/updateStatic").method("POST", body).addHeader("Authorization", "Bearer " + accessToken).addHeader("Content-Type", "application/json").build();

        try (Response response = this.client.newCall(request).execute()) {
            String str = response.body().string();
            if (response.isSuccessful()) {
                logger.info("发送车场信息成功" + str);
            } else {
                logger.info("发送车场信息失败：" + str);
            }
            return response.code();
        } catch (IOException e) {
            logger.error("发送异常", e);
        }
        return -1;
    }

    public Pair<Integer, String> sendParkEntry(String urlPrefix, String accessToken, ParkEntryVO parkEntryVO) {
        this.validateField(parkEntryVO);
        MediaType mediaType = MediaType.parse("application/json");
        String content = JSON.toJSONString(parkEntryVO, new SerializerFeature[]{SerializerFeature.WriteEnumUsingToString});
        logger.info("发送入场信息:{}", content);
        RequestBody body = RequestBody.create(mediaType, content);
        Request request = (new Request.Builder()).url(urlPrefix + "/parkdatacenter/parkDataDetail/odsParkingInInsert").method("POST", body).addHeader("Authorization", "Bearer " + accessToken).addHeader("Content-Type", "application/json").build();

        try (Response response = this.client.newCall(request).execute()) {
            String str = response.body().string();
            logger.info("发送入场响应:{},{}",response.code(),str);
            return Pair.of(response.code(), str);
        } catch (IOException e) {
            logger.error("发送入场异常", e);
            return Pair.of(-1, e.getMessage());
        }
    }

    public Pair<Integer, String> sendParkExit(String urlPrefix, String accessToken, ParkExitVO parkExitVO) {
        this.validateField(parkExitVO);
        MediaType mediaType = MediaType.parse("application/json");
        String content = JSON.toJSONString(parkExitVO, new SerializerFeature[]{SerializerFeature.WriteEnumUsingToString});
        logger.info("发送出场信息:{}", content);
        RequestBody body = RequestBody.create(mediaType, content);
        Request request = (new Request.Builder()).url(urlPrefix + "/parkdatacenter/parkDataDetail/odsParkingOutInsert").method("POST", body).addHeader("Authorization", "Bearer " + accessToken).addHeader("Content-Type", "application/json").build();

        try (Response response = this.client.newCall(request).execute()) {
            String str = response.body().string();
            logger.info("发送出场响应:{},{}",response.code(),str);
            return Pair.of(response.code(), str);
        } catch (IOException e) {
            logger.error("发送出场异常", e);
            return Pair.of(-1, e.getMessage());
        }
    }

    public Pair<Integer, String> sendParkFree(String urlPrefix, String accessToken, ParkFreeVO parkFreeVO) {
        this.validateField(parkFreeVO);
        MediaType mediaType = MediaType.parse("application/json");
        String content = JSON.toJSONString(parkFreeVO, new SerializerFeature[]{SerializerFeature.WriteEnumUsingToString});
        logger.info("发送空余泊位:{}", content);
        RequestBody body = RequestBody.create(mediaType, content);
        Request request = (new Request.Builder()).url(urlPrefix + "/parkdatacenter/parkDataDetail/odsParkFreeInsert").method("POST", body).addHeader("Authorization", "Bearer " + accessToken).addHeader("Content-Type", "application/json").build();

        try (Response response = this.client.newCall(request).execute()) {
            String str = response.body().string();
            logger.info("发送空余泊位响应:{},{}",response.code(),str);
            return Pair.of(response.code(), str);
        } catch (IOException e) {
            logger.error("发送异常", e);
            return Pair.of(-1, e.getMessage());
        }
    }

    public int sendEntracneExitInfo(String urlPrefix, String accessToken, ParkEntracneExitInfoVo parkEntracneExitInfoVo) {
        this.validateField(parkEntracneExitInfoVo);
        MediaType mediaType = MediaType.parse("application/json");
        String content = JSON.toJSONString(parkEntracneExitInfoVo, new SerializerFeature[]{SerializerFeature.WriteEnumUsingToString});
        logger.info("发送出入口信息:{}", content);
        RequestBody body = RequestBody.create(mediaType, content);
        Request request = (new Request.Builder()).url(urlPrefix + "/parkdatacenter/ods-entrance-exit/insert").method("POST", body).addHeader("Authorization", "Bearer " + accessToken).addHeader("Content-Type", "application/json").build();

        try (Response response = this.client.newCall(request).execute()) {
            String str = response.body().string();
            if (response.isSuccessful()) {
                logger.info("发送出入口信息成功" + str);
            } else {
                logger.info("发送出入口信息失败：" + str);
            }
            return response.code();
        } catch (IOException e) {
            logger.error("发送异常", e);
        }
        return -1;
    }

    public int sendChargePile(String urlPrefix, String accessToken, ChargePileVO chargePileVO) {
        this.validateField(chargePileVO);
        MediaType mediaType = MediaType.parse("application/json");
        String content = JSON.toJSONString(chargePileVO, new SerializerFeature[]{SerializerFeature.WriteEnumUsingToString});
        logger.info("发送充电桩:{}", content);
        RequestBody body = RequestBody.create(mediaType, content);
        Request request = (new Request.Builder()).url(urlPrefix + "/parkdatacenter/charge-pile/insert").method("POST", body).addHeader("Authorization", "Bearer " + accessToken).addHeader("Content-Type", "application/json").build();

        try (Response response = this.client.newCall(request).execute()) {
            String str = response.body().string();
            if (response.isSuccessful()) {
                logger.info("发送充电桩成功" + str);
            } else {
                logger.info("发送充电桩失败：" + str);
            }
            return response.code();
        } catch (IOException e) {
            logger.error("发送异常", e);
        }
        return -1;
    }

    public int sendCollectEqiupment(String urlPrefix, String accessToken, List<CollectEquipmentVO> collectEquipmentVO) {
        MediaType mediaType = MediaType.parse("application/json");
        String content = JSON.toJSONString(collectEquipmentVO, new SerializerFeature[]{SerializerFeature.WriteEnumUsingToString});
        logger.info("发送采集设备信息:{}", content);
        RequestBody body = RequestBody.create(mediaType, content);
        Request request = (new Request.Builder()).url(urlPrefix + "/parkdatacenter/collect-equipment/insert").method("POST", body).addHeader("Authorization", "Bearer " + accessToken).addHeader("Content-Type", "application/json").build();

        try (Response response = this.client.newCall(request).execute()) {
            String str = response.body().string();
            if (response.isSuccessful()) {
                logger.info("发送采集设备成功" + str);
            } else {
                logger.info("发送采集设备失败：" + str);
            }
            return response.code();
        } catch (IOException e) {
            logger.error("发送异常", e);
        }
        return -1;
    }

    public static void main(String[] args) throws IllegalAccessException {
        String urlPrefix = "https://prm.bj-jtjt.cn/api";
        ClientDetails clientDetails = new ClientDetails();
        clientDetails.setClient_id("test");
        clientDetails.setClient_secret("123456");
        clientDetails.setScope("read");
        clientDetails.setGrant_type("client_credentials");
        TokenInfo token = TokenUtil.getSingleInstance().getTokenInfo(urlPrefix, clientDetails);
        System.out.println(JSON.toJSONString(token));
//        CompanyVO companyVO = new CompanyVO();
//        companyVO.setBizId("test");
//        companyVO.setName("运营企业名称");
//        companyVO.setCompanyCode("运营企业编码");
//        companyVO.setCompanyAddress("123");
//        companyVO.setGeneralManager("123");
//        companyVO.setCompanyPhone("1111");
//        System.out.println(JSON.toJSONString(companyVO, new SerializerFeature[]{SerializerFeature.WriteEnumUsingToString}));
//        getSingleInstance().sendCompany(urlPrefix, token.getAccess_token(), companyVO);
//        ParkInfoVO parkInfoVO = new ParkInfoVO();
//        parkInfoVO.setBizId("test");
//        parkInfoVO.setParkCode("110229200013");
//        parkInfoVO.setParkName("STA001停车场名称");
//        parkInfoVO.setLicence("STA001");
//        parkInfoVO.setParkAddress("北京市**区**街道**号");
//        parkInfoVO.setOrganizationNo("运营企业组织机构代码");
//        parkInfoVO.setOrganizationName("运营企业名称");
//        parkInfoVO.setLegalRepresentative("张三");
//        parkInfoVO.setSocialCreditCode("911238498489JJ234Lk");
//        parkInfoVO.setCompanyAddress("北京市丰台区****");
//        parkInfoVO.setBerths(100);
//        parkInfoVO.setOpenParkPlaceNum(100);
//        parkInfoVO.setChargeNum(0);
//        parkInfoVO.setParkPlaceNum01(100);
//        parkInfoVO.setParkPlaceNum02(0);
//        parkInfoVO.setParkPlaceNum03(0);
//        parkInfoVO.setParkPlaceNum04(0);
//        parkInfoVO.setParkPlaceNum05(0);
//        parkInfoVO.setParkPlaceNum06(0);
//        parkInfoVO.setChargeNum(0);
//        parkInfoVO.setFreeNum(0);
//        parkInfoVO.setLargeVehicleNum(0);
//        parkInfoVO.setLightVehicleNum(100);
//        parkInfoVO.setParkStage(ParkStageConstant.Stage1);
//        parkInfoVO.setParkNature(ParkNatureConstant.ParkNature1);
//        parkInfoVO.setParkRegionId1("18");
//        parkInfoVO.setParkRegionId2("S1");
//        parkInfoVO.setParkUseDate(LocalDate.now());
//        parkInfoVO.setRecordEffectDate(LocalDate.now());
//        parkInfoVO.setRecordInvalidDate(LocalDate.now());
//        parkInfoVO.setPropertyType(PropertyTypeConstant.PropertyType1);
//        parkInfoVO.setPropertyOwner("北京静态交通柚子运营有限公司");
//        String propertyDateStr = "2023-12-31 00:00:00";
//        LocalDateTime propertyDate = LocalDateTime.parse(propertyDateStr, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
//        parkInfoVO.setPropertyDate(propertyDate);
//        parkInfoVO.setParkType(ParkTypeConstant.ParkTypeG);
//        parkInfoVO.setParkClass(ParkClassConstant.ParkClass10);
//        parkInfoVO.setParkClassification(ParkClassificationConstant.SHOPPING_BUILDING);
//        parkInfoVO.setGrossArea(1000.0F);
//        parkInfoVO.setParkLon("116.405285");
//        parkInfoVO.setParkLac("39.904989");
//        parkInfoVO.setSpaceLoc(SpaceLocConstant.SpaceLoc1);
//        parkInfoVO.setParkLocationClass(ParkLocationClassConstant.ParkLocationClass1);
//        parkInfoVO.setWorkerNum(3);
//        parkInfoVO.setParkCharger("张三");
//        parkInfoVO.setMobilePhone("18888888888");
//        parkInfoVO.setTelPhone("01025648798");
//        parkInfoVO.setIsShared(ParkShareConstant.ParkShareFalse);
//        parkInfoVO.setSharedTime("19:00:00-07:00:00");
//        parkInfoVO.setSharedParkPlaceNum(0);
//        parkInfoVO.setEntranceNum(1);
//        parkInfoVO.setExitNum(1);
//        parkInfoVO.setDayTimeStart(LocalTime.parse("07:00:00"));
//        parkInfoVO.setDayTimeEnd(LocalTime.parse("19:00:00"));
//        parkInfoVO.setChargingStandardTempSmallCarDayFirstHour("2");
//        parkInfoVO.setDaySmallCarChrononMinsFirstHour(15);
//        parkInfoVO.setChargingStandardTempSmallCarDay("2");
//        parkInfoVO.setDaySmallCarChrononMins(15);
//        parkInfoVO.setChargingStandardTempBigCarDayFirstHour("4");
//        parkInfoVO.setDayBigCarChrononMinsFirstHour(15);
//        parkInfoVO.setChargingStandardTempBigCarDay("4");
//        parkInfoVO.setDayBigCarChrononMins(15);
//        parkInfoVO.setNightTimeStart(LocalTime.parse("19:00:00"));
//        parkInfoVO.setNightTimeEnd(LocalTime.parse("07:00:00"));
//        parkInfoVO.setChargingStandardTempSmallCarNight("1");
//        parkInfoVO.setNightSmallCarChrononMins(120);
//        parkInfoVO.setChargingStandardTempBigCarNight("2");
//        parkInfoVO.setNightBigCarChrononMins(120);
//        parkInfoVO.setChargingStandardLeaseSmallCar("300");
//        parkInfoVO.setChargingStandardLeaseBigCar("600");
//        parkInfoVO.setTsaaFee(5.0F);
//        parkInfoVO.setTbaaFee(10.0F);
//        parkInfoVO.setSentDateTime(LocalDateTime.now());
//        getSingleInstance().sendParkInfo(urlPrefix, token.getAccess_token(), parkInfoVO);
        List<CollectEquipmentVO> collectEquipmentVOs = new ArrayList();
        CollectEquipmentVO collectEquipmentVO = new CollectEquipmentVO();
        collectEquipmentVO.setBizId("test");
        collectEquipmentVO.setName("北京静态交通投资运营有限公司");
        collectEquipmentVO.setCode("A001");
        collectEquipmentVO.setParkCode("110229200013");
        collectEquipmentVO.setType("01");
        collectEquipmentVO.setSentTime(LocalDateTime.now());
        collectEquipmentVOs.add(collectEquipmentVO);
        getSingleInstance().sendCollectEqiupment(urlPrefix, token.getAccess_token(), collectEquipmentVOs);
        ParkEntracneExitInfoVo parkEntracneExitInfoVo = new ParkEntracneExitInfoVo();
        parkEntracneExitInfoVo.setBizId("test");
        parkEntracneExitInfoVo.setParkCode("110229200013");
        parkEntracneExitInfoVo.setEntranceNum(1);
        parkEntracneExitInfoVo.setExitNum(1);
        parkEntracneExitInfoVo.setSentTime(LocalDateTime.now());
        List<ParkEntranceExitInfoListVo> list = new ArrayList();
        ParkEntranceExitInfoListVo parkEntranceExitInfoListVo = new ParkEntranceExitInfoListVo();
        parkEntranceExitInfoListVo.setEntranceType(1);
        parkEntranceExitInfoListVo.setCrName("北入口");
        parkEntranceExitInfoListVo.setCrNo("A1");
        parkEntranceExitInfoListVo.setCrRoadName("西局北街");
        parkEntranceExitInfoListVo.setCrLongitude("116.238239");
        parkEntranceExitInfoListVo.setCrLatitude("39.299312");
        parkEntranceExitInfoListVo.setCrPicture("https://park-data-center-test.oss-cn-beijing.aliyuncs.com/XXX/parkCode/out.jpg");
        list.add(parkEntranceExitInfoListVo);
        parkEntracneExitInfoVo.setList(list);
        getSingleInstance().sendEntracneExitInfo(urlPrefix, token.getAccess_token(), parkEntracneExitInfoVo);
        ChargePileVO chargePileVO = new ChargePileVO();
        chargePileVO.setBizId("test");
        chargePileVO.setParkCode("110229200013");
        chargePileVO.setChargePileNum(5);
        chargePileVO.setDcChargePileNum(2);
        chargePileVO.setAcChargePileNum(3);
        chargePileVO.setChargeStationOperationName("北京静态交通投资运行有限公司");
        chargePileVO.setSentTime(LocalDateTime.now());
        getSingleInstance().sendChargePile(urlPrefix, token.getAccess_token(), chargePileVO);
        ParkFreeVO parkFreeVO = new ParkFreeVO();
        parkFreeVO.setBerths(76);
        parkFreeVO.setFreeBerths(40);
        parkFreeVO.setParkCode("110229200013");
        parkFreeVO.setSentDateTime(LocalDateTime.now());
        getSingleInstance().sendParkFree(urlPrefix, token.getAccess_token(), parkFreeVO);
        ParkEntryVO parkEntryVO = new ParkEntryVO();
        parkEntryVO.setParkCode("110229200013");
        parkEntryVO.setPlateNumber("京A123348");
        parkEntryVO.setVehicleColor(VehicleColorConstant.BLUE);
        parkEntryVO.setEntranceCode("A1");
        String inDateTimeStr = "2023-12-31 00:00:00";
        LocalDateTime indateTime = LocalDateTime.parse(inDateTimeStr, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
        parkEntryVO.setInDateTime(indateTime);
        parkEntryVO.setPhotoInUrl("https://park-data-center-test.oss-cn-beijing.aliyuncs.com/XXX/parkCode/京A123348In.jpg");
        parkEntryVO.setParkingInCode("11020104881230401");
        parkEntryVO.setSentDateTime(LocalDateTime.now());
        getSingleInstance().sendParkEntry(urlPrefix, token.getAccess_token(), parkEntryVO);
        ParkExitVO parkExitVO = new ParkExitVO();
        parkExitVO.setParkCode("110229200013");
        parkExitVO.setPlateNumber("京NF0L12");
        parkExitVO.setVehicleColor(VehicleColorConstant.BLUE);
        parkExitVO.setEntranceCode("A1");
        String inDateTimeStr2 = "2023-12-31 00:00:00";
        LocalDateTime indateTime2 = LocalDateTime.parse(inDateTimeStr2, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
        parkExitVO.setInDateTime(indateTime2);
        parkExitVO.setPhotoInUrl("http://park-data-center.oss-cn-beijing.aliyuncs.com/1d3b3731e3a7b596244ceba37ea8abd1/顺013G007/22/05/11/ParkingIn/20220511123040080_10.1.28.78_京NF0L12.jpg");
        parkExitVO.setParkingInCode("202205111407550000111901");
        parkExitVO.setParkingOutCode("202205111407550000111903");
        parkExitVO.setExitCode("11020348931290");
        String outDateTimeStr = "2022-03-12 14:07:55";
        LocalDateTime outDateTime = LocalDateTime.parse(outDateTimeStr, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
        parkExitVO.setOutDateTime(outDateTime);
        parkExitVO.setParkingType(ParkingTypeConstant.ParkingTypeTemporary);
        parkExitVO.setPhotoOutUrl("http://park-data-center.oss-cn-beijing.aliyuncs.com/1d3b3731e3a7b596244ceba37ea8abd1/顺013G007/22/05/11/ParkingOut/20220511140756302_10.1.28.79_京NF0L12.jpg");
        parkExitVO.setPayType(PayTypeConstant.PayType1);
        parkExitVO.setParkingTimes(10);
        parkExitVO.setParkingRefee(3.0);
        parkExitVO.setParkingFee(3.0);
        parkExitVO.setPayStatus(1);
        parkExitVO.setPayTime(new Date());
        parkExitVO.setSentDateTime(LocalDateTime.now());
        parkExitVO.setParkName("停车场");
        getSingleInstance().sendParkExit(urlPrefix, token.getAccess_token(), parkExitVO);
    }
}