NB_NetPump/nb-admin/src/test/java/com/nb/admin/AliyunTest.java

package com.nb.admin;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.nb.aliyun.api.service.AliyunIotSdk;
import com.nb.web.api.entity.BusDeviceEntity;
import com.nb.web.service.bus.entity.BusInfusionHistoryEntity;
import com.nb.web.service.bus.listener.event.bean.DeviceInfoEvent;
import com.nb.web.service.bus.service.LocalBusDeviceService;
import com.nb.web.service.bus.service.LocalBusInfusionHistoryService;
import com.nb.web.api.entity.common.BusDeviceRunningEntity;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.ApplicationContext;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.Date;
import java.util.List;

/**
 * @Author longsanlang
 * @Date 2022-04-06 17:55:44
 * @Version 1.0
 * @Description XXX
 */
@RunWith(SpringRunner.class)
@SpringBootTest(classes = AdminApplication.class)
public class AliyunTest {

    @Autowired
    private ApplicationContext applicationContext;

    @Autowired
    private LocalBusInfusionHistoryService localBusInfusionHistoryService;

    @Autowired
    private LocalBusDeviceService deviceService;
    @Autowired
    private LocalBusInfusionHistoryService infusionHistoryService;

    @Autowired
    private AliyunIotSdk aliyunIotSdk;

    @Test
    public void test001(){
        BusDeviceRunningEntity pump = new BusDeviceRunningEntity();
        pump.setAlias("123456777");
        DeviceInfoEvent event = new DeviceInfoEvent(this,pump,"123");
        applicationContext.publishEvent(event);

        try {
            Thread.sleep(2000000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    @Test
    public void test002(){
        List<BusDeviceEntity> deviceList = deviceService.list();
        for (BusDeviceEntity deviceEntity : deviceList) {
            BusInfusionHistoryEntity one = infusionHistoryService.getOne(new QueryWrapper<BusInfusionHistoryEntity>()
                    .lambda().eq(BusInfusionHistoryEntity::getDeviceId, deviceEntity.getDeviceId())
                    .orderByDesc(BusInfusionHistoryEntity::getStartTime)
                    .last("limit 1"));
            if(one!=null){
                deviceEntity.setInfusionId(one.getId());
            }
        }
        deviceService.updateBatchById(deviceList);
    }

    @Test
    public void test003(){
        BusDeviceEntity deviceEntity = new BusDeviceEntity();
        deviceEntity.setDeviceId("572157323738029F");
        deviceService.saveDevice(deviceEntity);
    }

    @Test
    public void test004(){
        deviceService.syncDeviceFromIot();
    }

    @Test
    public void test005(){
        BusInfusionHistoryEntity infusionHistory = infusionHistoryService.getById("1549329948024553473");
        Date date = new Date(1658227636571L);
        System.out.println(infusionHistory.getLastUploadTime().equals(date));
    }
}