| | |
|---|
| | | 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.wvp.WVPResult; |
|---|
| | | import com.ycl.utils.http.HttpUtils; |
|---|
| | | import lombok.RequiredArgsConstructor; |
|---|
| | | import org.json.JSONObject; |
|---|
| | | import org.springframework.beans.factory.annotation.Value; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | import org.springframework.util.CollectionUtils; |
|---|
| | |
|---|
| | | String result = HttpUtils.sendGet(rtspServer + "/api/device/query/devices?page=1&count=15"); |
|---|
| | | WVPResult wvpResult = JSON.parseObject(result, WVPResult.class); |
|---|
| | | if (0 == wvpResult.getCode()) { |
|---|
| | | PageInfo<Device> page = (PageInfo) wvpResult.getData(); |
|---|
| | | List<Device> list = page.getList(); |
|---|
| | | 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) |
|---|
