-

admin

2 天以前 6e9d579cde59b29a06e481c7f0438c2a1fbaa882

 billion-main/src/main/java/com/billion/main/plc/sub/OPCUaSubscription.java

@@ -223,6 +223,8 @@
            return Long.parseLong(value);
        } else if (type == Boolean.class || type == boolean.class) {
            return Boolean.parseBoolean(value);
        } else if (type == Byte.class || type == byte.class) {
            return Byte.parseByte(value);
        } else if (type == Date.class) {
            try {
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@@ -240,22 +242,23 @@
            WebSocketUsers.sendMessageToUserByText(map.get("IGBT"), "21");

            // 发送HTTP请求
//            HttpResponse response = HttpRequest.post(Constants.SY_MES_URL)
//            HttpResponse response = HttpRequest.post(Constants.WC_TEST_MES_URL)
//                    .header("token", "XNY")
//                    .body(JSONUtil.toJsonStr(stationObject))
//                    .timeout(5000) // 设置超时时间
//                    .execute();
//            System.out.println("--------------------------"+response.body());
//            log.info("发送数益MES结果{}", response.body());
//            log.info("发送潍柴MES结果{}", response.body());
//            // 解析响应
//            if (response.isOk()) { // 请求成功
//                JSONObject jsonResponse = JSONUtil.parseObj(response.body());
//                String message = jsonResponse.getStr("message");
//                Integer code = jsonResponse.getInt("code");
//
//                if ("ok".equals(message)) {
//                    // 响应不是ok，保存失败记录
//                    saveMesFailRecord(stationObject, device, "响应正常：" + message, "1");
//                if (code == 200) {
//                    // 响应不是200，保存失败记录
//                    saveMesFailRecord(stationObject, device, "响应正常：" + code, "1");
//                }else {
//                    saveMesFailRecord(stationObject, device, "响应异常：" + message,Constants.ZERO);
//                    saveMesFailRecord(stationObject, device, "响应异常：" + code,Constants.ZERO);
//                }
//            } else {
//                // HTTP请求失败，保存失败记录
@@ -306,15 +309,15 @@
            // 清理已处理的历史数据
            List<DaFailRecord> unHandledList = failRecordService.list(new LambdaQueryWrapper<DaFailRecord>().eq(DaFailRecord::getStatus, "0"));
            for (DaFailRecord daFailRecord : unHandledList) {
                HttpResponse response = HttpRequest.post(Constants.SY_MES_URL)
                HttpResponse response = HttpRequest.post(Constants.WC_TEST_MES_URL)
                        .body(JSONUtil.toJsonStr(daFailRecord.getRequestData()))
                        .timeout(5000) // 设置超时时间
                        .execute();
                // 解析响应
                if (response.isOk()) { // 请求成功
                    JSONObject jsonResponse = JSONUtil.parseObj(response.body());
                    String message = jsonResponse.getStr("message");
                    if ("ok".equals(message)) {
                    Integer code = jsonResponse.getInt("code");
                    if (code == 200) {
                        failRecordService.deleteDaFailRecordById(daFailRecord.getId());
                    }else {
                        this.updateFailRecordRetryCount(daFailRecord);