新增智能电表、空调管理

doum

2026-05-25 74190ebc24e6e850d418ad0ce041fd91b795c23e

 server/visits/dmvisit_service/src/main/java/com/doumee/core/device/ElectronicToolUtil.java

@@ -155,8 +155,8 @@
    }
    public static void main(String[] args) {
        QueryDataRequest param = new QueryDataRequest();
        param.setStart_time("2026-05-19 10:00::00");
        param.setEnd_time("2026-05-19 12:24:25");
        param.setStart_time("2026-05-25 10:00::00");
        param.setEnd_time("2026-05-25 14:24:25");
        param.setLimit(1);
        param.setFunctionids("253");
        param.setOffset(0);
@@ -178,10 +178,7 @@
        try {
            String request_content = JSON.toJSONString(param);
            String r = requestAsync(url, request_content);
            TypeReference typeReference =
                    new TypeReference< ElectronicBaseResponse<List<MeterDealResponse>> >(){};
            ElectronicBaseResponse  result = JSONObject.parseObject(r, typeReference.getType());
            return  result;
            return parseAsyncMeterResponse(r);
        }catch (Exception e){
            log.error("电表==============开户",e);
        }
@@ -199,10 +196,7 @@
        try {
            String request_content = JSON.toJSONString(param);
            String r = requestAsync(url, request_content);
            TypeReference typeReference =
                    new TypeReference< ElectronicBaseResponse<List<MeterDealResponse>> >(){};
            ElectronicBaseResponse  result = JSONObject.parseObject(r, typeReference.getType());
            return  result;
            return parseAsyncMeterResponse(r);
        }catch (Exception e){
            log.error("电表==============开户",e);
        }
@@ -220,10 +214,7 @@
        try {
            String request_content = JSON.toJSONString(param);
            String r = requestAsync(url, request_content);
            TypeReference typeReference =
                    new TypeReference< ElectronicBaseResponse<List<MeterDealResponse>> >(){};
            ElectronicBaseResponse  result = JSONObject.parseObject(r, typeReference.getType());
            return  result;
            return parseAsyncMeterResponse(r);
        }catch (Exception e){
            log.error("电表==============开户",e);
        }
@@ -241,17 +232,14 @@
        try {
            String request_content = JSON.toJSONString(param);
            String r = requestAsync(url, request_content);
            TypeReference typeReference =
                    new TypeReference< ElectronicBaseResponse<List<MeterDealResponse>> >(){};
            ElectronicBaseResponse  result = JSONObject.parseObject(r, typeReference.getType());
            return  result;
            return parseAsyncMeterResponse(r);
        }catch (Exception e){
            log.error("电表==============拉合闸",e);
        }
        return null;
    }
    /**
     * 电表_拉合闸
     * 电表_立即抄表
     */
    public static ElectronicBaseResponse   eleRead(List<EleReadRequest> param) {
        if(param ==null || param.size()==0){
@@ -262,12 +250,9 @@
        try {
            String request_content = JSON.toJSONString(param);
            String r = requestAsync(url, request_content);
            TypeReference typeReference =
                    new TypeReference< ElectronicBaseResponse<List<MeterDealResponse>> >(){};
            ElectronicBaseResponse  result = JSONObject.parseObject(r, typeReference.getType());
            return  result;
            return parseAsyncMeterResponse(r);
        }catch (Exception e){
            log.error("电表==============拉合闸",e);
            log.error("电表==============立即抄表",e);
        }
        return null;
    }
@@ -363,6 +348,14 @@
        }
        return null;
    }

    /**
     * 查询历史数据接口
     */
    public static ElectronicDataResponse queryDataRequest() {
        return queryDataRequest(null);
    }

    /**
     * 查询历史数据接口
     */
@@ -474,6 +467,58 @@
    }

    // 打印响应内容
    /**
     * 解析 Api_v2 异步电表操作响应。
     * 平台 response_content 可能是 JSON 数组，也可能是字符串形式的 JSON 数组。
     */
    public static ElectronicBaseResponse parseAsyncMeterResponse(String r) {
        if (StringUtils.isBlank(r)) {
            return null;
        }
        try {
            JSONObject jsonObject = JSON.parseObject(r);
            if (jsonObject == null) {
                return null;
            }
            ElectronicBaseResponse<List<MeterDealResponse>> result = new ElectronicBaseResponse<>();
            result.setStatus(jsonObject.getString("status"));
            result.setTimestamp(jsonObject.getString("timestamp"));
            result.setError_msg(jsonObject.getString("error_msg"));
            result.setSign(jsonObject.getString("sign"));
            result.setResponse_content(parseResponseContentList(jsonObject.get("response_content"), MeterDealResponse.class));
            return result;
        } catch (Exception e) {
            log.error("parse async meter response failed, raw={}", r, e);
            return null;
        }
    }

    private static <T> List<T> parseResponseContentList(Object content, Class<T> clazz) {
        if (content == null) {
            return null;
        }
        if (content instanceof JSONArray) {
            return ((JSONArray) content).toJavaList(clazz);
        }
        if (content instanceof JSONObject) {
            T one = ((JSONObject) content).toJavaObject(clazz);
            return one != null ? Collections.singletonList(one) : null;
        }
        String text = String.valueOf(content);
        if (StringUtils.isBlank(text) || "null".equalsIgnoreCase(text.trim())) {
            return null;
        }
        text = text.trim();
        if (text.startsWith("[")) {
            return JSON.parseArray(text, clazz);
        }
        if (text.startsWith("{")) {
            T one = JSON.parseObject(text, clazz);
            return one != null ? Collections.singletonList(one) : null;
        }
        return null;
    }

    public static void printResponse(String response) {
        JSONObject jsonObject = JSON.parseObject(response);