package com.nb.admin;

import cn.hutool.core.util.RandomUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.nb.web.api.entity.BusDeviceEntity;
import com.nb.web.api.enums.DeviceStatusEnum2;
import com.nb.web.service.bus.service.LocalBusDeviceService;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
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.test.context.junit4.SpringRunner;

import java.util.List;

/**
 * @author lifang
 * @version 1.0.0
 * @ClassName BusHospitalTest.java
 * @Description TODO
 * @createTime 2022年03月19日 10:27:00
 */
@RunWith(SpringRunner.class)
@SpringBootTest(classes = AdminApplication.class)
public class BusNetpumpTest {

    @Autowired
    private LocalBusDeviceService deviceService;


    @Autowired
    private ObjectMapper objectMapper;


    @Test
    public void json() throws JsonProcessingException {
        BusDeviceEntity device = new BusDeviceEntity();
        System.out.println(objectMapper.writeValueAsString(device));

    }
    @Test
    public void update(){
        BusDeviceEntity device=new BusDeviceEntity();
        device.setId("43036339393103CD");
        device.setStatus(DeviceStatusEnum2.OFFLINE);
        device.setAlias("");
        deviceService.updateDevice(device);
    }
    @Test
    public void save(){
//        StpUtil.login();
        BusDeviceEntity deviceEntity = deviceService.getOne(new QueryWrapper<BusDeviceEntity>().last("limit 1"));
//        netPumpEntity.setWarn(DeviceWarnEnum.ComingEnd);
        for (int i = 0; i < 2; i++) {
            deviceEntity.setId(null);
            deviceEntity.setAlias("");
            deviceEntity.setDeviceId(RandomUtil.randomString(5));
            deviceEntity.setTenantId("1505808170691784706");
            deviceService.save(deviceEntity);
        }

    }

    @Test
    public void query(){
        List<BusDeviceEntity> list = deviceService.list(new QueryWrapper<BusDeviceEntity>().lambda().eq(BusDeviceEntity::getTenantId,"1"));

//        BusDeviceRunningEntity runningEntity = deviceRunningService.getOne(new QueryWrapper<BusDeviceRunningEntity>().last("limit 1"));
//        for (int i = 0; i < 2000; i++) {
//            for (BusDeviceEntity deviceEntity : contactList) {
//                deviceEntity.setDeviceId(RandomUtil.randomString(5));
//                deviceEntity.setId(null);
//                deviceEntity.setMqttConnInfo("1");
//                deviceService.save(deviceEntity);
//
//                runningEntity.setDataNumber( runningEntity.getDataNumber());
//                runningEntity.setDeviceId(deviceEntity.getDeviceId());
//                runningEntity.setHistoryId(deviceEntity.getTenantId());
//                runningEntity.setTenantId("1");
//                runningEntity.setUploadTime(DateUtil.yesterday());
//                runningEntity.setId(null);
//                try {
//                    SpringUtil.publishEvent(new DeviceInfoEvent(this,runningEntity,runningEntity.getDeviceId()));
//                }catch (Exception e){
//                    e.printStackTrace();
//                }
//
//            }
//        }
//        while (true){
//
//        }
//        BusDeviceEntity deviceEntity = new BusDeviceEntity();
//        deviceEntity.setAlias("456");
//        deviceEntity.setType(DeviceTypeEnum.intelligent);
//        deviceEntity.setDeviceId("456");
//        deviceEntity.setEnable(true);
//        deviceEntity.setTenantId("1505808170691784706");
//        BusDeviceEntity deviceEntity1 = new BusDeviceEntity();
//        deviceEntity1.setAlias("123");
//        deviceEntity1.setType(DeviceTypeEnum.continuous);
//        deviceEntity1.setDeviceId("123");
//        deviceEntity1.setTenantId("1505808170691784706");
//        deviceEntity1.setEnable(true);
//        deviceService.save(deviceEntity);
//        deviceService.save(deviceEntity1);
//        List<BusDeviceRunningEntity> contactList = netPumpService.contactList();
//        System.out.println(contactList);

    }

    @Test
    public void queryRegistry(){

    }

    @Test
    public void alias(){
        BusDeviceEntity device = new BusDeviceEntity();
        device.setDeviceId("43047342373902A5");
        device.setStatus(DeviceStatusEnum2.OFFLINE);
        // 更新设备状态
        deviceService.updateDevice(device);

    }
}