Demo.java

package com.example.demo;

import cn.cigem.data.sync.config.CommunicationConfig;
import cn.cigem.data.sync.model.PayloadContent;
import cn.cigem.data.sync.service.IBusinessService;
import cn.cigem.data.sync.service.ICommunicationService;
import cn.cigem.data.sync.service.ISecretService;
import cn.cigem.data.sync.service.IShareService;
import cn.cigem.data.sync.service.impl.*;
import cn.cigem.data.sync.utility.PayloadWrapperUtil;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.brilliance.bo.RspComBo;
import com.brilliance.bo.RspMonitorPointAllBo;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import java.util.HashMap;
import java.util.Map;
import com.alibaba.fastjson.JSON;


/**
 * 建立与加解密网关的通讯
 */
@Slf4j
@Service
public class Demo {

    public final IBusinessService _businessService;
    public final EspEncryption _encryption;
    private final IShareService _shareService;


    /*public Demo(IBusinessService iBusinessService, EspEncryption espEncryption ,IShareService iShareService) {
        this.iBusinessService = iBusinessService;
        this.espEncryption = espEncryption;
        this._shareService = iShareService;
    }*/

    public Demo() {
        ICommunicationService iCommunicationService = before();
        IBusinessService iBusinessService = new BusinessService(iCommunicationService);
        ISecretService iSecretService = new SecretService(iCommunicationService);
        EspEncryption espEncryption = new EspEncryption(iSecretService);
        IShareService iShareService = new ShareService(iCommunicationService);
        this._shareService = iShareService;
        this._businessService = iBusinessService;
        this._encryption = espEncryption;
    }






    public static ICommunicationService before(){

        RestTemplate restTemplate = new RestTemplate();
        CommunicationConfig communicationConfig = new CommunicationConfig();
        communicationConfig.setAccessKey("621b965d7ee24dbc");
        communicationConfig.setSecretKey("fb7e13e69b6648d59dcaaf4800d1c349");
        ICommunicationService iCommunicationService = new CommunicationService(restTemplate,communicationConfig);
        return iCommunicationService;
    }

    /**
     * 2.3.5.监测点下设备及传感器列表
     * @param
     * @throws Exception
     */
    public static String getMonitorPointInfo(String payload){

        ICommunicationService iCommunicationService = before();
        IBusinessService iBusinessService = new BusinessService(iCommunicationService);
        return iBusinessService.getMonitorDeviceList(payload);
    }



    //2.3.4.监测点列表
    public void main() throws Exception {
        int cod = _encryption.initiate();
        log.info("建立与加解密网关的通讯结果：",cod);
        Map<String, String> p = new HashMap<>();
        p.put("key", "云岩区黔灵镇");
        p.put("year", "");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .params(p)
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _businessService.getMonitorPointAll(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<RspMonitorPointAllBo> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<RspMonitorPointAllBo>>() {});
        log.info("rsp++++++:" + rsp.toString());

    }

    //2.3.5.监测点详情
    public void getMonitorPointInfo() throws Exception {
        int cod = _encryption.initiate();
        log.info("建立与加解密网关的通讯结果：",cod);
        Map<String, String> p = new HashMap<>();
        p.put("areaCode", "430281");
        p.put("startDate","2024-10-30 15:34:01");
        p.put("endDate","");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .params(p)
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _shareService.getDataPoint(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<RspMonitorPointAllBo> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<RspMonitorPointAllBo>>() {});
        log.info("rsp++++++:" + rsp.toString());

    }

    //2.3.6.监测点下设备及传感器列表
    public void getMonitorDeviceList() throws Exception {

        Map<String, String> p = new HashMap<>();
        p.put("monitorpointcode", "520102020004");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .params(p)
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _businessService.getMonitorDeviceList(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<RspMonitorPointAllBo> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<RspMonitorPointAllBo>>() {});
        log.info("rsp++++++:" + rsp.toString());

    }

    //2.3.7.监测数据获取
    public void getDBDataPoints() throws Exception {

        Map<String, String> p = new HashMap<>();
        p.put("sensorcode", "4302810000130101YL01");
        p.put("start","2024-10-30 15:34:01");
        p.put("end","");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .params(p)
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _businessService.getDBDataPoints(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<RspMonitorPointAllBo> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<RspMonitorPointAllBo>>() {});
        log.info("rsp++++++:" + rsp.toString());

    }


    //2.3.9.地震速报数据获取
    public void getEarthReport() throws Exception {

        _encryption.initiate();
        Map<String, String> p = new HashMap<>();
        p.put("lon", "102.79");
        p.put("lat", "35.70");
        p.put("time", "2023-12-18 23:59:30");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .body(JSONObject.toJSONString(p))
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _shareService.getEarthReport(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);

    }

    //2.3.10.重大事件速报数据获取
    public void getImportReport() throws Exception {

        Map<String, String> p = new HashMap<>();
        p.put("eventname", "");
        p.put("period","1");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .body(JSONObject.toJSONString(p))
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _shareService.getImportReport(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<RspMonitorPointAllBo> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<RspMonitorPointAllBo>>() {});
        log.info("rsp++++++:" + rsp.toString());
    }

    //2.3.11.不同时间段不同地区设备在线率
    public void getAvgOnlineRate() throws Exception {
        int cod = _encryption.initiate();
        log.info("建立与加解密网关的通讯结果：",cod);
        Map<String, String> p = new HashMap<>();
        p.put("areaCode", "520100");
        p.put("startDate","2024-10-30");
        p.put("endDate","2024-11-7");
        p.put("manufacturerName", "");
        p.put("typeArr", "");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .params(p)
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _shareService.getAvgOnlineRate(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        JSONObject json = JSONObject.parseObject(jsonStr);
        json.getInteger("status");
        log.info("status++++++:" + json.getInteger("status"));
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<RspMonitorPointAllBo> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<RspMonitorPointAllBo>>() {});
        log.info("rsp++++++:" + rsp.toString());

    }

    //2.3.12.各省/厂商设备在线率及排名
    public void getOnlineRateRank() throws Exception {
        int cod = _encryption.initiate();
        log.info("建立与加解密网关的通讯结果：",cod);
        Map<String, String> p = new HashMap<>();
        p.put("type", "2");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .params(p)
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _shareService.getOnlineRateRank(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<RspMonitorPointAllBo> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<RspMonitorPointAllBo>>() {});
        log.info("rsp++++++:" + rsp.toString());

    }

    //2.3.13.气象速报数据获取
    public void getWeatherReport() throws Exception {
        int cod = _encryption.initiate();
        log.info("建立与加解密网关的通讯结果：",cod);
        Map<String, String> p = new HashMap<>();
        p.put("date", "2024-10-05");
        p.put("period","1");
        p.put("hour","24");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .body(JSONObject.toJSONString(p))
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _shareService.getWeatherReport(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<RspMonitorPointAllBo> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<RspMonitorPointAllBo>>() {});
        log.info("rsp++++++:" + rsp.toString());

    }

    //2.3.14.地震二期速报未来24小时趋势数据获取
    public void getEarthReportTrendData() throws Exception {
        int cod = _encryption.initiate();
        log.info("建立与加解密网关的通讯结果：",cod);
        Map<String, String> p = new HashMap<>();
        p.put("lon", "102.79");
        p.put("lat", "35.70");
        p.put("time", "2023-12-18 23:59:30");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .body(JSONObject.toJSONString(p))
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _shareService.getEarthReportTrendData(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<RspMonitorPointAllBo> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<RspMonitorPointAllBo>>() {});
        log.info("rsp++++++:" + rsp.toString());

    }

    /*//2.3.15.不同时间段不同地区设备和传感器类型和个数
    public void getDeviceAndSensorCount() throws Exception {
        int cod = _encryption.initiate();
        log.info("建立与加解密网关的通讯结果：",cod);
        Map<String, String> p = new HashMap<>();
        p.put("startTime", "2023-10-20 00:00:00");
        p.put("endTime", "");
        p.put("areaCode", "630100");
        p.put("deviceType", "");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .body(JSONObject.toJSONString(p))
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _shareService.getDeviceAndSensorCount(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<RspMonitorPointAllBo> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<RspMonitorPointAllBo>>() {});
        log.info("rsp++++++:" + rsp.toString());

    }

    //2.3.16.不同时间段不同地区预警处置和虚警情况
    public void getWarnMsgDisposeRate() throws Exception {
        int cod = _encryption.initiate();
        log.info("建立与加解密网关的通讯结果：",cod);
        Map<String, String> p = new HashMap<>();
        p.put("startTime", "2024-10-20 00:00:00");
        p.put("endTime", "2024-11-06 23:59:59");
        p.put("areaCode", "");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .body(JSONObject.toJSONString(p))
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _shareService.getWarnMsgDisposeRate(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<RspMonitorPointAllBo> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<RspMonitorPointAllBo>>() {});
        log.info("rsp++++++:" + rsp.toString());

    }


    //2.3.17.按年统计每月在线率
    public void getOnlineRateOfMonth() throws Exception {
        int cod = _encryption.initiate();
        log.info("建立与加解密网关的通讯结果：",cod);
        Map<String, String> p = new HashMap<>();
        p.put("year", "2023");
        p.put("areaCode", "");
        p.put("typeArr", "设备，地表位移");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .params(p)
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _shareService.getOnlineRateOfMonth(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<RspMonitorPointAllBo> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<RspMonitorPointAllBo>>() {});
        log.info("rsp++++++:" + rsp.toString());

    }

    //2.3.18.按年统计每月处置率、虚警率
    public void getWarnMsgDisposeRateOfMonth() throws Exception {
        int cod = _encryption.initiate();
        log.info("建立与加解密网关的通讯结果：",cod);
        Map<String, String> p = new HashMap<>();
        p.put("year", "2023");
        p.put("areaCode", "");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .params(p)
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _shareService.getWarnMsgDisposeRateOfMonth(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<RspMonitorPointAllBo> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<RspMonitorPointAllBo>>() {});
        log.info("rsp++++++:" + rsp.toString());

    }*/

    //2.3.19.关键字查询厂商集合
    public void getManuInfosBySimpleName() throws Exception {
        int cod = _encryption.initiate();
        log.info("建立与加解密网关的通讯结果：",cod);
        Map<String, String> p = new HashMap<>();
        p.put("simplename", "中物");
        byte[] jsonBytes = JSON.toJSONBytes(PayloadContent.builder()
                .params(p)
                .build());
        byte[] encrypt = _encryption.encrypt(jsonBytes);
        String payload = PayloadWrapperUtil.byte2hex(encrypt);
        String result = _shareService.getManuInfosBySimpleName(payload);
        String jsonStr = new String(_encryption.decrypt(PayloadWrapperUtil.hex2byte(result)));
        log.info("jsonstr++++++:" + jsonStr);
        jsonStr = jsonStr.substring(1,jsonStr.length()-1).replace("\\","");
        log.info("jsonstr++++++:" + jsonStr);
        RspComBo<String> rsp = JSONObject.parseObject(jsonStr,  new TypeReference<RspComBo<String>>() {});
        log.info("rsp++++++:" + rsp.toString());

    }
}