package com.fdkankan.scene.controller;

import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.fastjson.JSONObject;
import com.fdkankan.common.controller.BaseController;
import com.fdkankan.common.response.ResultData;
import com.fdkankan.common.util.SpringUtil;
import com.fdkankan.mq.message.BuildSceneMqMessage;
import com.fdkankan.mq.util.RocketMQProducer;
import com.fdkankan.platform.api.dto.Camera;
import com.fdkankan.platform.api.dto.Company;
import com.fdkankan.platform.api.dto.User;
import com.fdkankan.platform.api.feign.PlatformGoodsClient;
import com.fdkankan.platform.api.feign.PlatformUserClient;
import com.fdkankan.rabbitmq.config.ModelingQueueConfig;
import com.fdkankan.rabbitmq.util.RabbitMqProducer;
import com.fdkankan.redis.util.RedisLockUtil;
import com.fdkankan.redis.util.RedisUtil;
import com.fdkankan.scene.service.IFolderService;
import com.fdkankan.scene.service.IScene3dNumService;
import com.fdkankan.scene.service.ISceneService;
import com.fdkankan.scene.vo.SceneVO;
import com.google.common.collect.Lists;
import com.yomahub.tlog.task.spring.SpringScheduledTaskAop;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
import javax.sql.DataSource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RefreshScope
@RestController
@RequestMapping("/service/scene/test")
@Slf4j
public class TestController extends BaseController {



    @Autowired
    RedisUtil redisUtil;

    @Autowired
    IFolderService folderService;

    @GetMapping("/testdb")
    public List testdb(){
        return folderService.list();
    }

    @Autowired
    private PlatformUserClient platformUserClient;

    @Autowired
    private PlatformGoodsClient platformGoodsClient;

    @Autowired
    private RocketMQProducer rocketMQProducer;

    @Autowired
    private IScene3dNumService scene3dNumService;

    @Autowired
    RedisTemplate redisTemplate;

    @Autowired
    RedisLockUtil redisLockUtil;

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Autowired
    ModelingQueueConfig modelingQueueConfig;
    @Autowired
    private RabbitMqProducer rabbitMqProducer;



    @PostMapping("/test")
    public ResultData test(String aaa) throws Exception {

        SpringScheduledTaskAop bean = SpringUtil.getBean(SpringScheduledTaskAop.class);
        System.out.println("123");

//        JSONObject dataJson = new JSONObject();
//        dataJson.put("obj2txt", true);
//        dataJson.put("split_type", "SPLIT_V6");
//        dataJson.put("data_describe", "double spherical");
//        dataJson.put("skybox_type", "SKYBOX_V5");
//        FileUtils.writeFile(path + "/data.json", dataJson.toString());
//
//        if("V2".equals(buildType)){
//            CreateObjUtil.objToTxt(path , "1");
//        }
//        if("V3".equals(buildType)){
//            CreateObjUtil.build3dModel(path , "1");
//        }

//        folderService.list();

//        long aaaaaaa = redisUtil.incr("aaaaaaa", 1);

//        String test = "123";
//        if(test.equals("123")){
//            throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
//        }

//        ArrayList<String> strings = new ArrayList<>();
//        strings.add("1.jpg");
//        strings.add("2.jpg");
//        return ResultData.ok(new UploadPanoramaVO(5, strings));

//        BuildSceneMqMessage buildSceneMqMessage = new BuildSceneMqMessage();
//        buildSceneMqMessage.setFileId("123123123123");
//        TLogMqWrapBean<BuildSceneMqMessage> tLogMqWrap = new TLogMqWrapBean(buildSceneMqMessage);
//        rocketMQProducer.syncSend("test_topic_dsx", tLogMqWrap);

//        ResultData<Camera> cameraById = platformGoodsClient.getCameraById(123L);
//        Enumeration<String> headerNames = request.getHeaderNames();
//        while (headerNames.hasMoreElements()){
//            String s = headerNames.nextElement();
//            log.info(s + "=" + request.getHeader(s));
//        }
//
//        TLogIdGenerator bean = SpringUtil.getBean(TLogIdGenerator.class);
//        log.info(bean.generateTraceId());

        for(int i=0; i<5; i++){
            BuildSceneMqMessage message = new BuildSceneMqMessage();
            message.setFileId("hhjjS鬼地方个" + "-" + i);
            rabbitMqProducer.sendByWorkQueue(modelingQueueConfig.modelingPre, message);
        }

        return ResultData.ok();

    }

    public static void main(String[] args) throws Exception {

//        MatrixToImageWriterUtil.createQRCode("http://baidu.com" + "123123", ConstantFilePath.BASE_PATH + File.separator + "sceneQRcode/"+"123123"+".png",
//                ConstantFilePath.SCENE_PATH + "images/images" + "123123" + "/QRShareLogo.png");
    }

    @GetMapping("/testSetStr")
    public void testSetStr() throws Exception {
        redisUtil.set("testIncr", "1");
        redisUtil.incr("testIncr",1);
        String testIncr = redisUtil.get("testIncr");
        System.out.println(testIncr);


    }

    @GetMapping("/testGetStr")
    public String testGetStr() throws Exception {
        boolean b = redisUtil.hasKey("90c82bdac_202201050951313830");
        String abc = (String)redisUtil.get("abc");
        return "123";
    }

    @GetMapping("/testSetObject")
    public boolean testSetObject() throws Exception {
//        User user = new User();
//        user.setCity("珠海");
//        user.setId(123l);
//
//        String jsons = JSON.toJSONString(user);
//
//        redisTemplate.opsForValue().set("test:66", jsons);
//        redisTemplate.opsForValue().set("test:67", jsons);

        ResultData<Camera>  cameraById = platformGoodsClient.getCameraById(111L);

        Camera data = cameraById.getData();

        ResultData<Company> companyById = platformUserClient.getCompanyById(111L);






        return true;
    }

//
    @GetMapping("/testGetObject")
    public User testGetObject() throws Exception {
        String test12 = redisUtil.get("test66");
        User user = JSONObject.parseObject(test12, User.class);
        return user;
    }


    @GetMapping("/testSetList")
    public boolean testSetList() throws Exception {

        List<String> users = Lists.newArrayList();
        users.add("sdfsdf");
        users.add("dfgdfg");
        return redisUtil.lRightPushAll("test5595jj", users);
    }

    @GetMapping("/testGetList")
    public List<String> testGetList() throws Exception {
        return redisUtil.lGet("test5595jj", 0, -1);
    }

    @GetMapping("/testSetMap")
    public boolean testSetMap() throws Exception {

        Map<String, User> userMap = new HashMap<>();

        User user1 = new User();
        user1.setCity("珠海");
        user1.setId(123l);

        User user2 = new User();
        user2.setCity("广州");
        user2.setId(124l);

        userMap.put("user1", user1);
        userMap.put("user2", user2);


        return redisUtil.hmset("userMap", userMap);
    }

    @GetMapping("/testGetMap")
    public Map<String ,User> testGetMap() throws Exception {
        return redisUtil.hmget("userMap");
    }

    @Autowired
    ISceneService sceneService;

    @GetMapping("/testSchedule")
    public void testSchedule(){
        sceneService.updatePv();
    }

    @Value("${rocketmq.build-scene.topicName.topic-modeling-a}")
    private String topicModelingA;

    @GetMapping("/testMQ")
    public void testMQ(int count){
//        SceneVO body = SceneVO.builder().buildType("123").childName("sdfsdfsdf").dataSource("sadfdhgf").id(1213L).build();
        for(int i = 1; i <= count; i++){
            rocketMQProducer.sendOneWay("test_topic_dsx", "消息体" + i);
        }
    }

    @GetMapping("/testAsynMQ")
    public void testAsynMQ(){
        SceneVO body = SceneVO.builder().buildType("123").childName("sdfsdfsdf").dataSource("sadfdhgf").id(1213L).build();
        rocketMQProducer.asyncSend("abc","tag3", UUID.randomUUID().toString(), body,null,5000l);
    }

    @GetMapping("/testsenOnway")
    public void testsenOnway(){
        SceneVO body = SceneVO.builder().buildType("123").childName("sdfsdfsdf").dataSource("sadfdhgf").id(1213L).build();
        rocketMQProducer.sendOneWay("qqq","tag6", UUID.randomUUID().toString(), body);
    }

    @RefreshScope
    @GetMapping("/testsenOnway1")
    public void testsenOnway1(){
        SceneVO body = SceneVO.builder().buildType("123").childName("sdfsdfsdf").dataSource("sadfdhgf").id(1213L).build();
        rocketMQProducer.sendOneWay(topicModelingA, null);
    }

    @RefreshScope
    @GetMapping("/testResult")
    public void testResult(){
//        rocketMQProducer.sendOneWay("topic_modeling_a_result", BuildSceneResultMqMessage.builder().buildSuccess(true).cameraType("3").build());
        String dsfsdf = (String) redisUtil.get("dsfsdf");
        System.out.println(2134);

    }

    @Autowired
    DataSource dataSource;

    @GetMapping("/testDatasource")
    public void testDatasource() throws SQLException {
//        Connection connection = dataSource.getConnection();
//        System.out.println(connection);

        System.out.println(dataSource.getClass());
        DruidDataSource druidDataSource = (DruidDataSource) dataSource;
        System.out.println(druidDataSource.getName());
        System.out.println("druidDataSource 数据源最大连接数：" + druidDataSource.getMaxActive());
        System.out.println("druidDataSource 数据源初始化连接数：" + druidDataSource.getInitialSize());

//        connection.close();

    }

}