package com.ycl.task;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
|
import com.github.pagehelper.PageInfo;
|
import com.ycl.platform.domain.entity.DeviceInfo;
|
import com.ycl.platform.mapper.DeviceInfoMapper;
|
import com.ycl.platform.wvp.Device;
|
import com.ycl.platform.wvp.WVPResult;
|
import com.ycl.utils.http.HttpUtils;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Objects;
|
import java.util.stream.Collectors;
|
|
/**
|
* "国标设备"同步
|
*
|
* @author：xp
|
* @date：2024/8/21 15:18
|
*/
|
@RequiredArgsConstructor
|
@Component("deviceSynTask")
|
public class DeviceSynTask {
|
|
private final DeviceInfoMapper deviceInfoMapper;
|
|
@Value("${rtsp.server:http://127.0.0.1:7788}")
|
private String rtspServer;
|
|
public void run() {
|
String result = HttpUtils.sendGet(rtspServer + "/api/device/query/devices?page=1&count=15");
|
WVPResult wvpResult = JSON.parseObject(result, WVPResult.class);
|
if (0 == wvpResult.getCode()) {
|
JSONObject data = (JSONObject) wvpResult.getData();
|
List<Device> list = data.getList("list", Device.class);
|
if (! CollectionUtils.isEmpty(list)) {
|
list.stream().forEach(item -> {
|
DeviceInfo device = new LambdaQueryChainWrapper<>(deviceInfoMapper)
|
.eq(DeviceInfo::getDeviceId, item.getDeviceId())
|
.one();
|
if (Objects.isNull(device)) {
|
DeviceInfo deviceInfo = new DeviceInfo();
|
deviceInfo.setDeviceId(item.getDeviceId());
|
deviceInfo.setDeviceName(item.getName());
|
Date now = new Date();
|
deviceInfo.setCreateTime(now);
|
deviceInfo.setUpdateTime(now);
|
deviceInfo.setDeleted(0);
|
deviceInfoMapper.insert(deviceInfo);
|
} else {
|
device.setDeviceName(item.getName());
|
deviceInfoMapper.updateById(device);
|
}
|
});
|
}
|
}
|
}
|
|
}
|
