package com.ctx.controller;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.ctx.bean.Achievement;
import com.ctx.bean.Student;
import com.ctx.service.StudentService;

@RestController
public class StudentController {
    @Autowired
    private StudentService studentService;

    //单线程串行执行
    @GetMapping("/studentInfo")
    public String studentInfo(Long no) {
        //开始时间
        Long startTime = System.currentTimeMillis();
        //查询学生成绩
        Achievement achievement = studentService.findAchievementByNo(no);
        //查询学生基本信息
        Student student = studentService.findStudentByNo(no);
        String achievementStr = JSON.toJSONString(achievement);
        String studentStr = JSON.toJSONString(student);
        JSONObject achievementJson = JSONObject.parseObject(achievementStr);
        JSONObject studentJson = JSONObject.parseObject(studentStr);
        
        JSONObject jsonObject = new JSONObject();
        jsonObject.putAll(achievementJson);
        jsonObject.putAll(studentJson);
        String result = jsonObject.toString();
        //结束时间
        Long endTime = System.currentTimeMillis();
        Long diffTime=endTime-startTime;
        System.out.println("代码执行时间:"+diffTime);
        return result;
    }

    //多线程并行执行
        @GetMapping("/studentInfo2")
        public String studentInfo2(Long no) {
            //开始时间
            Long startTime = System.currentTimeMillis();
            //学生成绩
            Callable<JSONObject> achievementJSON = new Callable<JSONObject>() {
                @Override
                public JSONObject call() throws Exception {
                    Achievement achievement = studentService.findAchievementByNo(no);
                    String achievementStr = JSON.toJSONString(achievement);
                    JSONObject achievementJson = JSONObject.parseObject(achievementStr);
                    return achievementJson;
                    //return null;
                }
            };
            //学生基本信息
            Callable<JSONObject> studentJSON = new Callable<JSONObject>() {
                @Override
                public JSONObject call() throws Exception {
                    //查询学生基本信息
                    Student student = studentService.findStudentByNo(no);
                    String studentStr = JSON.toJSONString(student);
                    JSONObject studentJson = JSONObject.parseObject(studentStr);
                    return studentJson;
                }
            };
            FutureTask<JSONObject> achievementFutureTask = new FutureTask<JSONObject>(achievementJSON);
            FutureTask<JSONObject> studentFutureTask = new FutureTask<JSONObject>(studentJSON);
            //执行线程
            new Thread(achievementFutureTask).start();
            new Thread(studentFutureTask).start();
            
            JSONObject jsonObject = new JSONObject();
            try {
                //get()阻塞监听call()方法的返回值。
                jsonObject.putAll(achievementFutureTask.get());
                jsonObject.putAll(studentFutureTask.get());
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } catch (ExecutionException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
            String result = jsonObject.toString();
            //结束时间
            Long endTime = System.currentTimeMillis();
            Long diffTime=endTime-startTime;
            System.out.println("代码执行时间:"+diffTime);
            return result;
        }
}