新增智能电表、空调管理

doum

7 天以前 074bcb8394fab66ce531c219e1e7de7c142ff2d5

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

@@ -203,7 +203,7 @@
        return null;
    }
    /**
     * 电表开户_电表充值
     * 电表_电表充值
     */
    public static ElectronicBaseResponse   recharger(List<OpenAccountRequest> param) {
        if(param ==null || param.size()==0){
@@ -216,7 +216,7 @@
            String r = requestAsync(url, request_content);
            return parseAsyncMeterResponse(r);
        }catch (Exception e){
            log.error("电表==============开户",e);
            log.error("电表==============充值",e);
        }
        return null;
    }
@@ -227,7 +227,7 @@
        if(param ==null || param.size()==0){
            return null;
        }
        String url = ElectronicConstant.api2_url+"/Api_v2/ele_security/ele_control";
        String url = ElectronicConstant.api2_url+"/Api_v2/ele_control";

        try {
            String request_content = JSON.toJSONString(param);
@@ -239,6 +239,69 @@
        return null;
    }
    /**
     * 查询异步操作任务状态（/Api_v2/request/status）。
     * request_content 为 JSON 数组，可合并传入多个 opr_id 一次查询。
     * 调用成功后建议 30s 首次查询，后续间隔递增（1h、2h、4h…），禁止频繁调用。
     * 响应 SUCCESS、FAIL、TIMEOUT、CANCELED、RESPONSE_FAIL 后无需再查询。
     */
    public static ElectronicBaseResponse requestStatus(List<RequestStatusRequest> param) {
        if (param == null || param.isEmpty()) {
            return null;
        }
        String url = ElectronicConstant.api2_url + "/Api_v2/request/status";
        try {
            String request_content = JSON.toJSONString(param);
            String r = request(url, request_content);
            return parseAsyncMeterResponse(r);
        } catch (Exception e) {
            log.error("电表==============查询异步任务状态", e);
        }
        return null;
    }

    /**
     * 按 opr_id 列表合并查询异步任务状态。
     */
    public static ElectronicBaseResponse requestStatusByOprIds(List<String> oprIds) {
        if (oprIds == null || oprIds.isEmpty()) {
            return null;
        }
        List<RequestStatusRequest> param = new ArrayList<>();
        for (String oprId : oprIds) {
            if (StringUtils.isNotBlank(oprId)) {
                RequestStatusRequest req = new RequestStatusRequest();
                req.setOpr_id(oprId.trim());
                param.add(req);
            }
        }
        return param.isEmpty() ? null : requestStatus(param);
    }

    /**
     * 查询单个异步操作任务状态。
     */
    public static ElectronicBaseResponse requestStatus(String oprId) {
        if (StringUtils.isBlank(oprId)) {
            return null;
        }
        RequestStatusRequest req = new RequestStatusRequest();
        req.setOpr_id(oprId.trim());
        return requestStatus(Collections.singletonList(req));
    }

    /**
     * 异步任务是否已到达终态，平台后续不再处理，无需再轮询。
     */
    public static boolean isAsyncStatusFinal(String status) {
        if (StringUtils.isBlank(status)) {
            return false;
        }
        String s = status.trim().toUpperCase(Locale.ROOT);
        return "SUCCESS".equals(s) || "FAIL".equals(s) || "TIMEOUT".equals(s)
                || "CANCELED".equals(s) || "RESPONSE_FAIL".equals(s);
    }

    /**
     * 电表_立即抄表
     */
    public static ElectronicBaseResponse   eleRead(List<EleReadRequest> param) {