package com.zjty.autotest.mq;

import com.alibaba.fastjson.JSON;
import com.zjty.autotest.pojo.sjq.*;
import com.zjty.autotest.service.AsyncService;
import com.zjty.autotest.service.AutoResultSetService;
import com.zjty.autotest.service.TestReportService;
import com.zjty.autotest.util.TimeUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

@Component
public class PushBlockQueueHandler implements Runnable {
    @Autowired
    private AsyncService asyncService;
    //消费的对象
    private Object obj;

    public PushBlockQueueHandler() {
    }

    public PushBlockQueueHandler(Object obj) {
        this.obj = obj;
    }

    //消费线程
    @Override
    public void run() {
//        doBusiness();
    }

    //消费行为
    private void doBusiness() {
       /* String id = (String) obj;
        System.out.println("id:" + id);
        TestChannel testChannel = (TestChannel) CacheManager.getCache(id);
        if (testChannel != null) {
            try {
                EvaReport evaReport = new EvaReport();
                evaReport.setBrowser(testChannel.getBrowser());
                evaReport.setFailCount(testChannel.getName() + "系统未通过测试，" + "未通过测试点共" + "10" + "个");
                evaReport.setProjectName(testChannel.getName());
                evaReport.setCreateTime(new Date());
                evaReport.setSystem("中标麒麟v7龙芯版");
                evaReport.setUrl(testChannel.getUrl());
                List<FailMessage> failMessages = new ArrayList<>();
                FailMessage failMessage = new FailMessage();
                failMessage.setUrl("https://voice.baidu.com/act/newpneumonia/newpneumonia/?from=osari_pc_1");
                failMessage.setMessage("抗击疫情打不开响应超时");
                failMessage.setPicture("https://timgsa.baidu.com/timg?image&quality=80&size=b9999_10000&sec=1584955247760&di=f073d6fd65cf71798843c6e4634358dd&imgtype=0&src=http%3A%2F%2Fa0.att.hudong.com%2F78%2F52%2F01200000123847134434529793168.jpg");
                failMessages.add(failMessage);
                evaReport.setFailMessages(failMessages);
                List<PageRoute> pageRoutes = new ArrayList<>();
                PageRoute pageRoute = new PageRoute();
                pageRoute.setPageName("https://www.baidu.com/");
                pageRoute.setAddress("/baidu");
                pageRoute.setMessage("");
                pageRoute.setResponseTime(300);
                pageRoute.setSuccess(0);
                pageRoute.setPicture("https://pics4.baidu.com/feed/500fd9f9d72a6059aecf87d92406529d013bbaca.jpeg?token=53433060d4d120e00d8ac6612d2303fd");
                PageRoute pageRoute1 = new PageRoute();
                pageRoute1.setPageName("https://www.baidu.com/");
                pageRoute1.setAddress("/baidu");
                pageRoute1.setMessage("不能访问");
                pageRoute1.setResponseTime(300);
                pageRoute1.setSuccess(1);
                pageRoute1.setPicture("https://pics4.baidu.com/feed/500fd9f9d72a6059aecf87d92406529d013bbaca.jpeg?token=53433060d4d120e00d8ac6612d2303fd");
                pageRoutes.add(pageRoute);
                pageRoutes.add(pageRoute1);
                evaReport.setPageRoutes(pageRoutes);
                List<PageContentTest> pageContents = new ArrayList<>();
                PageContentTest pageContentTest = new PageContentTest();
                pageContentTest.setUrl("http://news.baidu.com/");
                List<PageContent> contents = new ArrayList<>();
                PageContent pageContent = new PageContent();
                pageContent.setParms("国内");
                pageContent.setMessage("");
                pageContent.setResponseTime(300);
                pageContent.setSuccess(0);
                PageContent pageContent1 = new PageContent();
                pageContent1.setParms("国外");
                pageContent1.setMessage("响应时间过长");
                pageContent1.setResponseTime(30000);
                pageContent1.setSuccess(1);
                contents.add(pageContent);
                contents.add(pageContent1);
                pageContentTest.setContents(contents);
                pageContents.add(pageContentTest);
                evaReport.setPageContents(pageContents);

                //调用黄承天代码

                Thread.sleep(6000);
                if (testChannel.getCodeUrl() != null) {
                    //解压上传得代码
                    //获取前端代码中得网页路由地址
                    //比对黄承天代码中访问得地址和路由地址，黄承天是否访问全了。
                }
                System.out.println("修改状态");
                //改变报告状态
                String out = JSON.toJSONString(evaReport);
                String in = JSON.toJSONString(testChannel);
                System.out.println(id);
                TestReport testReport = new TestReport();
                testReport.setResultId(id);
                testReport.setOutReport(out);
                testReport.setInputReport(in);

                testReportService.save(testReport);
                autoResultSetService.updateByid(id);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

        }*/
        System.out.println(Thread.currentThread().getName() + "-收到消息：" + obj);
    }
}
