DudaoServiceImpl.java

package com.subsidy.service.impl;

import com.alibaba.fastjson.JSON;
import com.subsidy.common.configure.RenSheConfig;
import com.subsidy.dto.renshe.*;
import com.subsidy.mapper.ClassDictMapper;
import com.subsidy.mapper.DudaoMapper;
import com.subsidy.mapper.RenSheJuMapper;
import com.subsidy.mapper.RenshejuHistoryMapper;
import com.subsidy.model.*;
import com.subsidy.service.DudaoService;
import com.subsidy.util.DudaoConstant;
import com.subsidy.vo.renshe.*;
import net.sf.json.JSONObject;
import okhttp3.*;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.IOException;
import java.sql.Timestamp;
import java.util.*;

@Service
public class DudaoServiceImpl implements DudaoService {

//    /**
//     * 测试环境
//     */
//    public static final String PREFIX_URL = "http://180.167.195.117:18015/ddproject";
//
//    /**
//     * 正式环境
//     */
//    public static final String PROD_URL = "http://180.167.195.117:18025/ddproject";

    @Autowired
    private RenSheConfig renSheConfig;

    @Autowired
    private ClassDictMapper classDictMapper;

    @Autowired
    RenshejuHistoryMapper renshejuHistoryMapper;

    @Autowired
    private DudaoMapper dudaoMapper;

//    @Autowired
//    private RenSheJuMapper renSheJuMapper;

    public RensheResponseVO all()throws IOException{

        classBaseInfo();
        classHourBehavior();
        uploadChapterBehavior();
        uploadClassAnswerQuestionBehavior();
        uploadClassCode();

        return new RensheResponseVO();
    }

    public RensheResponseVO classBaseInfo() throws IOException {

        OkHttpClient client = new OkHttpClient().newBuilder()
                .build();
        MediaType mediaType = MediaType.parse("application/json");

        //拼数据
        ClassBaseInfoDTO classBaseInfoDTO = new ClassBaseInfoDTO();
        classBaseInfoDTO.setPrivateKey(getSecret());

        List<EpidemicSituationClassBasic> epidemicSituationClassBasics = new ArrayList<>();

        //查找前一天产生数据的班级

        //看视频
        List<Long> vodClassIds = dudaoMapper.vodClassIds("0");

        //考试
        List<Long> examClassIds = dudaoMapper.examClassIds("0");

        //答疑
        List<Long> answerClassIds = dudaoMapper.answerClassIds("0");

        //人脸识别
        List<Long> imageClassIds = dudaoMapper.imageClassIds("0");

        Set<Long> classIds = new HashSet<>();

        vodClassIds.stream().forEach(x->classIds.add(x));
        examClassIds.stream().forEach(x->classIds.add(x));
        answerClassIds.stream().forEach(x->classIds.add(x));
        imageClassIds.stream().forEach(x->classIds.add(x));

        try {
            if (classIds.size() > 0) {
                for (Long classId : classIds) {
                    EpidemicSituationClassBasic epidemicSituationClassBasic = new EpidemicSituationClassBasic();
                    //班级基本信息
                    ClassBaseInfoVO classBaseInfoVO = dudaoMapper.classBaseInfo(classId);
                    BeanUtils.copyProperties(classBaseInfoVO, epidemicSituationClassBasic);
                    epidemicSituationClassBasic.setClassCode(classBaseInfoVO.getDownCode());

                    //章节
                    List<ChapterList2> chapterLists = dudaoMapper.classChapters(classId);
                    ChapterList2 chapterList2 = chapterLists.get(chapterLists.size() - 1);
                    chapterList2.setIsExam(1);
                    epidemicSituationClassBasic.setChapterList(chapterLists);

                    //学员列表
                    List<MemberVO> memberVOS = dudaoMapper.classMembers(classId);
                    epidemicSituationClassBasic.setStudentList(memberVOS);

                    epidemicSituationClassBasics.add(epidemicSituationClassBasic);
                }
                classBaseInfoDTO.setEpidemicSituationClassBasic(epidemicSituationClassBasics);

                System.out.println(JSONObject.fromObject(classBaseInfoDTO).toString());

                RequestBody body = RequestBody.create(mediaType, JSONObject.fromObject(classBaseInfoDTO).toString());
                Request request = new Request.Builder()
                        .url(renSheConfig.getPutuo() + "/classbasicinformation/insertClassBasicInformation")
                        .method("POST", body)
                        .addHeader("User-Agent", "Apifox/1.0.0 (https://www.apifox.cn)")
                        .addHeader("Content-Type", "application/json")
                        .build();
                Response response = client.newCall(request).execute();

                RensheResponseVO rensheResponseVO = JSON.parseObject(response.body().string(), RensheResponseVO.class);
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_1);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(classBaseInfoDTO).toString());
                if (200 == response.code()) {
                    if (null != rensheResponseVO.getCtt()){
                        renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
                    }else {
                        renshejuHistoryDO.setOutputParam(rensheResponseVO.getMsg());
                    }
                } else {
                    renshejuHistoryDO.setOutputParam(DudaoConstant.API_ERROR);
                }
                renshejuHistoryMapper.insert(renshejuHistoryDO);
                return rensheResponseVO;
            } else {
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_1);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(classBaseInfoDTO).toString());
                renshejuHistoryDO.setOutputParam(DudaoConstant.NO_DATA);
                renshejuHistoryMapper.insert(renshejuHistoryDO);
                return null;
            }

        } catch (Exception e) {
            e.printStackTrace();
            RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
            renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_1);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(classBaseInfoDTO).toString());
            renshejuHistoryDO.setOutputParam(DudaoConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
        }
        return null;
    }

    public RensheResponseVO classHourBehavior() throws IOException {

        OkHttpClient client = new OkHttpClient().newBuilder()
                .build();
        MediaType mediaType = MediaType.parse("application/json");

        ClassHourBehaviorDTO classHourBehaviorDTO = new ClassHourBehaviorDTO();

        classHourBehaviorDTO.setPrivateKey(getSecret());

        List<ClassHourBasic> classHourBasics = new ArrayList<>();
        try {

            //产生视频学习数据的班级
            List<Long> vodClassIds = dudaoMapper.vodClassIds("0");

            List<DailyStudyInfoVO> result = new ArrayList<>();

            for (Long classId : vodClassIds){
                //产生数据的班级
                List<DailyStudyInfoVO> dailyStudyInfoVOS = dudaoMapper.dailyStudyInfo1(classId);
                result.addAll(dailyStudyInfoVOS);
            }

            for (DailyStudyInfoVO dailyStudyInfoVO : result) {
                ClassHourBasic classHourBasic = new ClassHourBasic();
                BeanUtils.copyProperties(dailyStudyInfoVO, classHourBasic);
                classHourBasic.setClassCode(dailyStudyInfoVO.getClassCode());

                //上线时间列表
                //找到当天每次上线下线时间
                //上线时间
                List<OprMemDictDO> loginRecords = dudaoMapper.loginRecords(dailyStudyInfoVO.getMemberId());
                //下线时间
                List<OprMemDictDO> loginOutRecords = dudaoMapper.loginOutRecords(dailyStudyInfoVO.getMemberId());

                List<LoginList> loginLists = new ArrayList<>();
                for (int i = 0; i < loginRecords.size(); i++) {
                    LoginList loginList = new LoginList();
                    loginList.setIp(loginRecords.get(i).getIpAddress());
                    loginList.setStartTime(Timestamp.valueOf(loginRecords.get(i).getCreateDate()).getTime());
                    loginList.setEndTime(Timestamp.valueOf(loginOutRecords.get(i).getCreateDate()).getTime());

                    //查看这个人该时间段的学习记录
                    List<ChapterList3> chapterList3s = dudaoMapper.dailyStudyRecords(dailyStudyInfoVO.getMemberId(), dailyStudyInfoVO.getClassId(), loginRecords.get(i).getCreateDate().toString().replace("T", " "), loginOutRecords.get(i).getCreateDate().toString().replace("T", " "));
                    if (chapterList3s.size() > 0) {
                        loginList.setChapterList(chapterList3s);
                        loginLists.add(loginList);
                    }
                }
                classHourBasic.setLoginList(loginLists);

                //活跃度列表
                List<ActivityList> activityLists = new ArrayList<>();
                List<DailyActivitiesVO> activityDetectionDOS = dudaoMapper.dailyActivities(dailyStudyInfoVO.getClassId(), dailyStudyInfoVO.getMemberId());
                for (DailyActivitiesVO dailyActivitiesVO : activityDetectionDOS) {

                    ActivityList activityList = new ActivityList();
                    if (null == dailyActivitiesVO.getAccess() || 0 == dailyActivitiesVO.getAccess()) {
                        activityList.setAccess(1);
                        activityList.setErrorInfo(2);
                    } else {
                        activityList.setAccess(0);
                    }

                    if (0 == dailyActivitiesVO.getCheckType()) {
                        activityList.setActivityDetection(2);
                    } else if (1 == dailyActivitiesVO.getCheckType()) {
                        activityList.setActivityDetection(1);
                    }

                    activityList.setActivityTime(dailyActivitiesVO.getActivityTime());
                    activityLists.add(activityList);
                }
                classHourBasic.setActivityList(activityLists);
                classHourBasics.add(classHourBasic);
            }


            classHourBehaviorDTO.setClassHourBasic(classHourBasics);

            System.out.println(com.alibaba.fastjson.JSONObject.toJSONString(classHourBehaviorDTO));

            if (classHourBasics.size()>0){
                RequestBody body = RequestBody.create(mediaType, JSONObject.fromObject(classHourBehaviorDTO).toString());

                Request request = new Request.Builder()
                        .url(renSheConfig.getPutuo() + "/learnduration/insertLearnDuration")
                        .method("POST", body)
                        .addHeader("User-Agent", "Apifox/1.0.0 (https://www.apifox.cn)")
                        .addHeader("Content-Type", "application/json")
                        .build();
                Response response = client.newCall(request).execute();

                RensheResponseVO rensheResponseVO = JSON.parseObject(response.body().string(), RensheResponseVO.class);
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_2);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(classHourBehaviorDTO).toString());
                if (200 == response.code()) {
                    if (null != rensheResponseVO.getCtt()){
                        renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
                    }else {
                        renshejuHistoryDO.setOutputParam(rensheResponseVO.getMsg());
                    }
                } else {
                    renshejuHistoryDO.setOutputParam(DudaoConstant.API_ERROR);
                }
                renshejuHistoryMapper.insert(renshejuHistoryDO);
                return rensheResponseVO;
            }else {
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_2);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(classHourBehaviorDTO).toString());
                renshejuHistoryDO.setOutputParam(DudaoConstant.NO_DATA);
                renshejuHistoryMapper.insert(renshejuHistoryDO);
                return null;
            }
//            return null;
        } catch (Exception e) {
            e.printStackTrace();
            RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
            renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_2);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(classHourBehaviorDTO).toString());
            renshejuHistoryDO.setOutputParam(DudaoConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
        }
        return null;
    }

    public RensheResponseVO uploadChapterBehavior() throws IOException {

        OkHttpClient client = new OkHttpClient().newBuilder()
                .build();
        MediaType mediaType = MediaType.parse("application/json");

        UploadChapterBehaviorDTO uploadChapterBehaviorDTO = new UploadChapterBehaviorDTO();

        uploadChapterBehaviorDTO.setPrivateKey(getSecret());

        List<ChapterExamBasic> chapterExamBasics = new ArrayList<>();

        //找出前一天产生考试数据的班级
        List<Long> classIds = dudaoMapper.dailyExamBasic("0");

        try {
            if (classIds.size() > 0) {
                for (Long classId : classIds) {

                    //具体哪些人做了
                    List<MemberDO> memberDOList = dudaoMapper.memberIds(classId);

                    ClassDictDO classDictDO = classDictMapper.selectById(classId);

                    for (MemberDO memberDO : memberDOList) {

                        //章节课程考试时间列表
                        ChapterExamBasic chapterExamBasic = new ChapterExamBasic();
                        chapterExamBasic.setClassCode(classDictDO.getClassCode());

                        //最后一节课作为chapterCode
                        String vodId = dudaoMapper.classVodName(classId);
                        chapterExamBasic.setChapterCode(vodId);

                        chapterExamBasic.setStudentName(memberDO.getUserName());
                        chapterExamBasic.setPhone(memberDO.getTelephone());
                        chapterExamBasic.setIdentity(memberDO.getIdCard());

                        //考试花了多长时间
                        Long examLength = dudaoMapper.examLength(memberDO.getId(), classId);
                        chapterExamBasic.setExamTime(examLength);

                        //考试活跃度列表
                        List<ActivityList> activityLists = new ArrayList<>();
                        List<ExamActivitiesVO> activityDetectionDOS = dudaoMapper.examActivities(classId, memberDO.getId());
                        for (ExamActivitiesVO dailyActivitiesVO : activityDetectionDOS) {

                            ActivityList activityList = new ActivityList();
                            if (null == dailyActivitiesVO.getAccess() || 0 == dailyActivitiesVO.getAccess()) {
                                activityList.setAccess(1);
                                activityList.setErrorInfo(1);
                            } else {
                                activityList.setAccess(0);
                            }
                            activityList.setActivityDetection(1);
                            activityList.setActivityTime(dailyActivitiesVO.getActivityTime());
                            activityLists.add(activityList);
                        }
                        chapterExamBasic.setActivityList(activityLists);


                        List<ExamList> examLists = new ArrayList<>();
                        //上线时间
                        List<OprMemDictDO> loginRecords = dudaoMapper.loginRecords(memberDO.getId());
                        //下线时间
                        List<OprMemDictDO> loginOutRecords = dudaoMapper.loginOutRecords(memberDO.getId());

//                        boolean flag = false;

                        for (int i = 0; i < loginRecords.size(); i++) {
                            //找到该时间段内的测评
                            List<ExerciseDoneResultDO> exerciseDoneResultDOS = dudaoMapper.dailyExerciseDone(memberDO.getId(), loginRecords.get(i).getCreateDate().toString().replace("T", " "), loginOutRecords.get(i).getCreateDate().toString().replace("T", " "), classId);
                            for (ExerciseDoneResultDO exerciseDoneResultDO : exerciseDoneResultDOS) {
                                ExamList examList = new ExamList();
                                examList.setStartTime(Timestamp.valueOf(exerciseDoneResultDO.getStartDate()).getTime());
                                examList.setEndTime(Timestamp.valueOf(exerciseDoneResultDO.getCreateDate()).getTime());
                                examList.setIp(loginRecords.get(i).getIpAddress());
//                                if ("合格".equals(exerciseDoneResultDO.getResult())) {
//                                    flag = true;
//                                }
                                examLists.add(examList);
                            }
                        }
//                        if (flag == true) {
//                            chapterExamBasic.setAccess(0L);
//                        } else {
//                            chapterExamBasic.setAccess(1L);
//                        }
                        chapterExamBasic.setExamList(examLists);
                        chapterExamBasics.add(chapterExamBasic);
                    }
                }

                uploadChapterBehaviorDTO.setChapterExamBasic(chapterExamBasics);

                System.out.println(com.alibaba.fastjson.JSONObject.toJSONString(uploadChapterBehaviorDTO));

                RequestBody body = RequestBody.create(mediaType, JSONObject.fromObject(uploadChapterBehaviorDTO).toString());
                Request request = new Request.Builder()
                        .url(renSheConfig.getPutuo() + "/examinformation/insertExamInformation")
                        .method("POST", body)
                        .addHeader("User-Agent", "Apifox/1.0.0 (https://www.apifox.cn)")
                        .addHeader("Content-Type", "application/json")
                        .build();
                Response response = client.newCall(request).execute();
                RensheResponseVO rensheResponseVO = JSON.parseObject(response.body().string(), RensheResponseVO.class);
                System.out.println(rensheResponseVO);
                if (200 == response.code()) {
                    RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                    renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_3);
                    renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadChapterBehaviorDTO).toString());
                    if (200 == response.code()) {
                        if (null != rensheResponseVO.getCtt()){
                            renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
                        }else {
                            renshejuHistoryDO.setOutputParam(rensheResponseVO.getMsg());
                        }
                    } else {
                        renshejuHistoryDO.setOutputParam(DudaoConstant.API_ERROR);
                    }
                    renshejuHistoryMapper.insert(renshejuHistoryDO);
                }
                return rensheResponseVO;
            } else {
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_3);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadChapterBehaviorDTO).toString());
                renshejuHistoryDO.setOutputParam(DudaoConstant.NO_DATA);
                renshejuHistoryMapper.insert(renshejuHistoryDO);
                return null;
            }
        } catch (Exception e) {
            RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
            renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_3);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadChapterBehaviorDTO).toString());
            renshejuHistoryDO.setOutputParam(DudaoConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
        }
        return null;
    }

    public RensheResponseVO uploadClassAnswerQuestionBehavior() throws IOException {

        OkHttpClient client = new OkHttpClient().newBuilder()
                .build();
        MediaType mediaType = MediaType.parse("application/json");

        UploadClassAnswerQuestionBehaviorDTO uploadClassAnswerQuestionBehaviorDTO = new UploadClassAnswerQuestionBehaviorDTO();

        //秘钥
        uploadClassAnswerQuestionBehaviorDTO.setPrivateKey(getSecret());

        List<DailyAnswerVO> dailyAnswerVOS = dudaoMapper.dailyAnswer("0");

        try {
            if (dailyAnswerVOS.size() > 0) {
                HashMap<String, List<AnswerAndQuestionList>> hashMap = new HashMap<>();
                for (DailyAnswerVO dailyAnswerVO : dailyAnswerVOS) {

                    if (!hashMap.containsKey(dailyAnswerVO.getDownCode() + ":" + dailyAnswerVO.getIdentity())) {
                        List<AnswerAndQuestionList> answerAndQuestionLists = new ArrayList<>();
                        AnswerAndQuestionList answerAndQuestionList = new AnswerAndQuestionList();
                        answerAndQuestionList.setAnswer(dailyAnswerVO.getAnswer());
                        answerAndQuestionList.setQuestion(dailyAnswerVO.getQuestion());
                        answerAndQuestionLists.add(answerAndQuestionList);
                        hashMap.put(dailyAnswerVO.getDownCode() + ":" + dailyAnswerVO.getIdentity(), answerAndQuestionLists);
                    } else {
                        List<AnswerAndQuestionList> answerAndQuestionLists = hashMap.get(dailyAnswerVO.getDownCode() + ":" + dailyAnswerVO.getIdentity());
                        AnswerAndQuestionList answerAndQuestionList = new AnswerAndQuestionList();
                        answerAndQuestionList.setAnswer(dailyAnswerVO.getAnswer());
                        answerAndQuestionList.setQuestion(dailyAnswerVO.getQuestion());
                        answerAndQuestionLists.add(answerAndQuestionList);
                        hashMap.put(dailyAnswerVO.getDownCode() + ":" + dailyAnswerVO.getIdentity(), answerAndQuestionLists);
                    }
                }

                List<AnswerBasic> answerBasics = new ArrayList<>();

                for (String key : hashMap.keySet()) {
                    AnswerBasic answerBasic = new AnswerBasic();
                    String downCode = key.split(":")[0];
                    String identity = key.split(":")[1];
                    answerBasic.setClassCode(downCode);
                    answerBasic.setIdentity(identity);
                    answerBasic.setAnswerAndQuestionList(hashMap.get(key));
                    answerBasics.add(answerBasic);
                }

                uploadClassAnswerQuestionBehaviorDTO.setAnswerBasic(answerBasics);
                System.out.println(com.alibaba.fastjson.JSONObject.toJSONString(uploadClassAnswerQuestionBehaviorDTO));
                RequestBody body = RequestBody.create(mediaType, JSONObject.fromObject(uploadClassAnswerQuestionBehaviorDTO).toString());
                Request request = new Request.Builder()
                        .url(renSheConfig.getPutuo() + "/answertutor/insertAnswerTutor")
                        .method("POST", body)
                        .addHeader("User-Agent", "Apifox/1.0.0 (https://www.apifox.cn)")
                        .addHeader("Content-Type", "application/json")
                        .build();
                Response response = client.newCall(request).execute();
                RensheResponseVO rensheResponseVO = JSON.parseObject(response.body().string(), RensheResponseVO.class);

                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_4);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadClassAnswerQuestionBehaviorDTO).toString());
                if (200 == response.code()) {
                    if (null != rensheResponseVO.getCtt()){
                        renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
                    }else {
                        renshejuHistoryDO.setOutputParam(rensheResponseVO.getMsg());
                    }
                } else {
                    renshejuHistoryDO.setOutputParam(DudaoConstant.API_ERROR);
                }
                renshejuHistoryMapper.insert(renshejuHistoryDO);

                return rensheResponseVO;
            } else {
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_4);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadClassAnswerQuestionBehaviorDTO).toString());
                renshejuHistoryDO.setOutputParam(DudaoConstant.NO_DATA);
                renshejuHistoryMapper.insert(renshejuHistoryDO);
                return null;
            }
        } catch (Exception e) {
            RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
            renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_4);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadClassAnswerQuestionBehaviorDTO).toString());
            renshejuHistoryDO.setOutputParam(DudaoConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
        }
        return null;
    }

    public RensheResponseVO uploadClassCode() throws IOException {

        OkHttpClient client = new OkHttpClient().newBuilder()
                .build();
        MediaType mediaType = MediaType.parse("application/json");

        UploadClassCodeDTO uploadClassCodeDTO = new UploadClassCodeDTO();

        uploadClassCodeDTO.setPrivateKey(getSecret());

        //所有班级
        List<Long> classIds = dudaoMapper.newClasses("0");

        List<ClassCodeBasic> classCodeBasics = new ArrayList<ClassCodeBasic>();
        for (Long classId : classIds) {
            ClassCodeBasic classCodeBasic = new ClassCodeBasic();
            ClassDictDO classDictDO = classDictMapper.selectById(classId);
            classCodeBasic.setDownCode(String.valueOf(classDictDO.getId()));
            classCodeBasic.setClassCode(classDictDO.getClassCode());
            classCodeBasics.add(classCodeBasic);
        }
        uploadClassCodeDTO.setClassCodeBasic(classCodeBasics);

        System.out.println(com.alibaba.fastjson.JSONObject.toJSONString(uploadClassCodeDTO));
        try {
            RequestBody body = RequestBody.create(mediaType, JSONObject.fromObject(uploadClassCodeDTO).toString());
            Request request = new Request.Builder()
                    .url(renSheConfig.getPutuo() + "/bindclass/insertBindClass")
                    .method("POST", body)
                    .addHeader("User-Agent", "Apifox/1.0.0 (https://www.apifox.cn)")
                    .addHeader("Content-Type", "application/json")
                    .build();
            Response response = client.newCall(request).execute();
            RensheResponseVO rensheResponseVO = JSON.parseObject(response.body().string(), RensheResponseVO.class);
            System.out.println(rensheResponseVO);

            RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
            renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_5);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadClassCodeDTO).toString());
            if (200 == response.code()) {
                if (null != rensheResponseVO.getCtt()){
                    renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
                }else {
                    renshejuHistoryDO.setOutputParam(rensheResponseVO.getMsg());
                }
            } else {
                renshejuHistoryDO.setOutputParam(DudaoConstant.API_ERROR);
            }
            renshejuHistoryMapper.insert(renshejuHistoryDO);
            return rensheResponseVO;
//            return null;
        } catch (Exception e) {
            RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
            renshejuHistoryDO.setInterfaceName(DudaoConstant.POST_5);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadClassCodeDTO).toString());
            renshejuHistoryDO.setOutputParam(DudaoConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
        }
        return null;
    }

     public String getSecret() throws IOException {
        OkHttpClient client = new OkHttpClient().newBuilder()
                .build();
//        MediaType mediaType = MediaType.parse("text/plain");
//        RequestBody body = new MultipartBody.Builder().setType(MultipartBody.FORM)
//                .addFormDataPart("publicKey", "ykhl65032260")
//                .build();
//        Request request = new Request.Builder()
//                .url(renSheConfig.getUrl() + "/token/accessPrivateKey")
//                .method("POST", body)
//                .addHeader("User-Agent", "Apifox/1.0.0 (https://www.apifox.cn)")
//                .build();
//        Response response = client.newCall(request).execute();
//        GetSecretVO getSecretVO = JSON.parseObject(response.body().string(), GetSecretVO.class);
        return "ykhl65032260";
    }

}