package com.atguigu.springcloud.controller;

import cn.hutool.core.date.DateUtil;
import com.atguigu.springcloud.mapper.TestMapper;
import com.atguigu.springcloud.thread.ThreadPoolDemo;
import com.atguigu.springcloud.utils.MyCache;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;

@Controller()
public class TestThreadPool {

    @Autowired
    private TestMapper testMapper;

    @Autowired
    private ThreadPoolDemo threadPoolDemo;
    private static int t = 1;
    private volatile static AtomicInteger atomicInteger = new AtomicInteger(1);

    @ResponseBody
    @RequestMapping("/hello")
    public void hello() {
        for (int i = 0; i < 10000; i++) {
            try {
//                Thread.sleep(1000);
                threadPoolDemo.Hello("你好" + atomicInteger.getAndAdd(1) + "==" + Thread.currentThread().getName());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

    }

    //1.加缓存
    @ResponseBody
    @RequestMapping("/addMyCache")
    public Map<String, String> addMyCache(String key, String value) {
        Map<String, String> map = new HashMap<>();
        map.put("key", key);
        map.put("value", value);
        try {
            MyCache.put(key, value);
            map.put("code", "200");
            return map;
        } catch (Exception e) {
            map.put("code", "500");
            return map;
        }
    }


    //3.清缓存
    @ResponseBody
    @RequestMapping("/deleteMyCache")
    public Map<String, String> deleteMyCache(String key) {
        Map<String, String> map = new HashMap<>();

        Object o = MyCache.get(key);
        if (null != o) {
            Object remove = MyCache.remove(key);
            map.put("key", key);
            map.put("value", remove.toString());
            return map;
        }
        map.put(key, "不存在");
        return map;
    }


    @ResponseBody
    @RequestMapping("/get1")
    public List<Map<String, Object>> sel() {
        Map<String, String> map = new HashMap<>();
        map.put("NET_CARD", "NET_CARD");
        map.put("TRAFFIC", "TRAFFIC");
        map.put("FLOW_TIME", "FLOW_TIME");
        map.put("tablename", "snmap_network_traffic");
        map.put("nowTime", DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
        List<Map<String, Object>> mapList = testMapper.select(map);
        return mapList;
    }
}