package com.nb.admin;

import cn.dev33.satoken.stp.StpUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.json.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.nb.web.service.bus.controller.vo.ClinicStatsVo;
import com.nb.web.service.bus.entity.BusClinicEntity;
import com.nb.web.service.bus.entity.BusDocEntity;
import com.nb.web.service.bus.entity.BusInfusionHistoryEntity;
import com.nb.web.service.bus.service.LocalBusClinicService;
import com.nb.web.service.bus.service.LocalBusDocService;
import com.nb.web.service.bus.service.LocalBusInfusionHistoryService;
import com.nb.web.service.bus.service.dto.ClinicStatsReturnResult;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.redisson.api.RBlockingQueue;
import org.redisson.api.RDelayedQueue;
import org.redisson.api.RedissonClient;
import org.redisson.codec.JsonJacksonCodec;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;

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

    @Autowired
    private RedissonClient redissonClient;
    @Autowired
    private LocalBusClinicService clinicService;
    @Autowired
    private ObjectMapper objectMapper;
    @Autowired
    private LocalBusInfusionHistoryService infusionHistoryService;
@Autowired
private LocalBusDocService docService;
    @Test
    public void stats(){
        ClinicStatsVo clinicStatsVo = new ClinicStatsVo();
        clinicStatsVo.setContinueDose(true);
        clinicStatsVo.setInValidCount(true);
        clinicStatsVo.setValidCount(true);
        clinicStatsVo.setClinicId("1519516923748319234");
        clinicStatsVo.setDeviceId("456");
        ClinicStatsReturnResult stats = clinicService.stats(clinicStatsVo);
        System.out.println(stats);
    }

    @Test
    public void redisson(){
        RBlockingQueue<Object> blockingFairQueue = redissonClient.getBlockingQueue("delay_queue",new JsonJacksonCodec());
        RDelayedQueue<Object> delayedQueue = redissonClient.getDelayedQueue(blockingFairQueue);
        JSONObject jsonObject = new JSONObject();
        jsonObject.putOpt(DateUtil.now(),"1");
        System.out.println(jsonObject);

        delayedQueue.offerAsync(jsonObject,60, TimeUnit.SECONDS);
        while (true){

        }
    }

    @Test
    public void save(){
        List<Map<String, Object>> mapList = infusionHistoryService
                .listMaps(new QueryWrapper<BusInfusionHistoryEntity>()
                        .select("clinic_id","count(1) as c")
                        .lambda()
                        .groupBy(BusInfusionHistoryEntity::getClinicId));
        System.out.println(mapList);
    }


    @Test
    @Transactional(rollbackFor = ArithmeticException.class)
    public void test(){
        clinicService.update(new UpdateWrapper<BusClinicEntity>().lambda().eq(BusClinicEntity::getId,"1528668113304244226")
        .set(BusClinicEntity::getSurgeryName,"临床数据5"));
        docService.update(new UpdateWrapper<BusDocEntity>().lambda().eq(BusDocEntity::getId,"1512720050274963458")
        .set(BusDocEntity::getType,"about1"));
        int i=1/0;
    }


    @Test
    public void publish(){
        List<String> tokenValueListByLoginId = StpUtil.getTokenValueListByLoginId(1);
        System.out.println(tokenValueListByLoginId);
    }

}