package com.ruoyi.http.service.impl;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONArray;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.ruoyi.common.utils.http.HttpUtils;
|
import com.ruoyi.http.config.TqdianbiaoConfig;
|
import com.ruoyi.http.mapper.TqdianbiaoCollectorMapper;
|
import com.ruoyi.http.pojo.TqdianbiaoCollector;
|
import com.ruoyi.http.service.TqdianbiaoCollectorSyncService;
|
import com.ruoyi.http.service.TqdianbiaoSyncLogService;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
|
import java.time.LocalDateTime;
|
|
@Service
|
@Slf4j
|
@RequiredArgsConstructor
|
public class TqdianbiaoCollectorSyncServiceImpl implements TqdianbiaoCollectorSyncService {
|
|
private final TqdianbiaoConfig config;
|
private final TqdianbiaoCollectorMapper collectorMapper;
|
private final TqdianbiaoSyncLogService syncLogService;
|
|
@Override
|
public int syncCollectors() {
|
String syncType = "collector";
|
try {
|
String url = config.getBaseUrl() + "/Api/Collector";
|
String param = "auth=" + config.getAuth();
|
String raw = HttpUtils.sendGet(url, param);
|
JSONArray list = parseList(raw);
|
LocalDateTime now = LocalDateTime.now();
|
int count = 0;
|
for (int i = 0; i < list.size(); i++) {
|
JSONObject item = list.getJSONObject(i);
|
String collectorId = item.getString("id");
|
if (collectorId == null) {
|
continue;
|
}
|
TqdianbiaoCollector entity = collectorMapper.selectOne(
|
Wrappers.<TqdianbiaoCollector>lambdaQuery()
|
.eq(TqdianbiaoCollector::getCollectorId, collectorId)
|
.last("LIMIT 1"));
|
if (entity == null) {
|
entity = new TqdianbiaoCollector();
|
entity.setCollectorId(collectorId);
|
}
|
entity.setCollectorNo(item.getString("collectorid"));
|
entity.setOnline(item.getBoolean("online"));
|
entity.setCsq(item.getInteger("csq"));
|
entity.setConnectTime(item.getString("connect_time"));
|
entity.setDisconnectTime(item.getString("disconnect_time"));
|
entity.setDescription(item.getString("description"));
|
entity.setSyncTime(now);
|
if (entity.getId() == null) {
|
collectorMapper.insert(entity);
|
} else {
|
collectorMapper.updateById(entity);
|
}
|
count++;
|
}
|
syncLogService.logSuccess(syncType, null, null, count);
|
return count;
|
} catch (Exception e) {
|
log.error("采集器同步失败", e);
|
syncLogService.logFailure(syncType, null, null, e.getMessage());
|
throw e;
|
}
|
}
|
|
private JSONArray parseList(String raw) {
|
Object parsed = JSON.parse(raw);
|
if (parsed instanceof JSONArray) {
|
return (JSONArray) parsed;
|
}
|
JSONObject root = (JSONObject) parsed;
|
if (root.getIntValue("status") != 1) {
|
throw new IllegalStateException("采集器接口返回异常: " + raw);
|
}
|
Object data = root.get("data");
|
if (data instanceof JSONArray) {
|
return (JSONArray) data;
|
}
|
return new JSONArray();
|
}
|
}
|
