ShehuihuaServiceImpl.java

package com.subsidy.service.impl;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.subsidy.common.configure.RenSheConfig;
import com.subsidy.dto.renshe.*;
import com.subsidy.dto.shehuihua.*;
import com.subsidy.mapper.ClassDictMapper;
import com.subsidy.mapper.ImageCheckRecordMapper;
import com.subsidy.mapper.RenSheJuMapper;
import com.subsidy.mapper.RenshejuHistoryMapper;
import com.subsidy.model.*;
import com.subsidy.service.ShehuihuaService;
import com.subsidy.util.OSSUtils;
import com.subsidy.util.RenSheJuConstant;
import com.subsidy.util.ShehuihuaConstant;
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.time.LocalDateTime;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

@Service
public class ShehuihuaServiceImpl implements ShehuihuaService {

    @Autowired
    private RenSheJuMapper renSheJuMapper;

    @Autowired
    private RenSheConfig renSheConfig;

    @Autowired
    RenshejuHistoryMapper renshejuHistoryMapper;

    @Autowired
    private ImageCheckRecordMapper imageCheckRecordMapper;

    public RensheResponseVO getClassCodeByPrivateKey() throws IOException {

        OkHttpClient client = new OkHttpClient().newBuilder()
                .build();
        MediaType mediaType = MediaType.parse("application/json");
        RequestBody body = RequestBody.create(mediaType,"{\"privateKey\":\""+getSecret()+"\"}");

        Request request = new Request.Builder()
                .url(renSheConfig.getUrl() + "/import/downstream/social/getClassCodeByPrivateKey")
                .method("POST", body)
                .addHeader("User-Agent", "Apifox/1.0.0 (https://www.apifox.cn)")
                .addHeader("Content-Type", "application/json")
                .build();
        try {
            Response response = client.newCall(request).execute();
            RensheResponseVO rensheResponseVO = JSON.parseObject(response.body().string(), RensheResponseVO.class);

            RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
            renshejuHistoryDO.setInterfaceName(ShehuihuaConstant.POST_2);
            renshejuHistoryDO.setInputParam(getSecret());
            if (200 == response.code()) {
                renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
            } else {
                renshejuHistoryDO.setOutputParam(RenSheJuConstant.API_ERROR);
            }
            renshejuHistoryMapper.insert(renshejuHistoryDO);
            return rensheResponseVO;

        } catch (Exception e) {
            RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
            renshejuHistoryDO.setInterfaceName(ShehuihuaConstant.POST_2);
            renshejuHistoryDO.setInputParam(getSecret());
            renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
        }
        return null;
    }


    public RensheResponseVO uploadClass() throws IOException {

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

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

        List<ClassInfoBasicDTO> classInfoBasicDTOS = new ArrayList<>();

        //查找前一天产生数据的班级
        List<Long> classIds = renSheJuMapper.newClasses("1");
        try {
            if (classIds.size() > 0) {
                for (Long classId : classIds) {
                    ClassInfoBasicDTO classInfoBasicDTO = new ClassInfoBasicDTO();
                    //班级基本信息
                    ClassBaseInfoVO classBaseInfoVO = renSheJuMapper.classBaseInfo(classId);
                    BeanUtils.copyProperties(classBaseInfoVO, classInfoBasicDTO);
                    classInfoBasicDTO.setClassCode(classBaseInfoVO.getDownCode());

                    //章节
                    List<ChapterList2> chapterLists = renSheJuMapper.classChapters(classId);
                    List<ChapterList22> chapterList22s = new ArrayList<>();
                    for (ChapterList2 chapterList2 : chapterLists){
                        ChapterList22 chapterList22 = new ChapterList22();
                        chapterList22.setChapterName(chapterList2.getChapterName());
                        chapterList22.setChapterCode(chapterList2.getChapterCode());
                        chapterList22s.add(chapterList22);
                    }
                    classInfoBasicDTO.setChapterList(chapterList22s);

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

                    classInfoBasicDTOS.add(classInfoBasicDTO);
                }
                classBaseInfoDTO.setClassInfoBasic(classInfoBasicDTOS);

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

//                RequestBody body = RequestBody.create(mediaType, JSONObject.fromObject(classBaseInfoDTO).toString());
//                Request request = new Request.Builder()
//                        .url(renSheConfig.getUrl() + "/import/downstream/social/uploadClass")
//                        .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(ShehuihuaConstant.POST_3);
//                renshejuHistoryDO.setInputParam(JSONObject.fromObject(classBaseInfoDTO).toString());
//                if (200 == response.code()) {
//                    renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
//                } else {
//                    renshejuHistoryDO.setOutputParam(RenSheJuConstant.API_ERROR);
//                }
//                renshejuHistoryMapper.insert(renshejuHistoryDO);
//                return rensheResponseVO;
                return null;
            } else {
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(ShehuihuaConstant.POST_3);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(classBaseInfoDTO).toString());
                renshejuHistoryDO.setOutputParam(RenSheJuConstant.NO_DATA);
                renshejuHistoryMapper.insert(renshejuHistoryDO);
                return null;
            }

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

    public RensheResponseVO classHourBehavior() throws IOException {

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

        ClassHourBehavior4DTO classHourBehaviorDTO = new ClassHourBehavior4DTO();

        classHourBehaviorDTO.setPrivateKey(getSecret());

        List<ClassHourBasic4DTO> classHourBasics = new ArrayList<>();
        try {
            //前一天新增视频学习数据的班级
            List<DailyStudyInfoVO> dailyStudyInfoVOS = renSheJuMapper.dailyStudyInfo("1");
            for (DailyStudyInfoVO dailyStudyInfoVO : dailyStudyInfoVOS) {
                ClassHourBasic4DTO classHourBasic = new ClassHourBasic4DTO();
                BeanUtils.copyProperties(dailyStudyInfoVO, classHourBasic);
                classHourBasic.setClassCode(dailyStudyInfoVO.getDownCode());

                //上线时间列表
                //找到当天每次上线下线时间
                //上线时间
                List<OprMemDictDO> loginRecords = renSheJuMapper.loginRecords(dailyStudyInfoVO.getMemberId());
                //下线时间
                List<OprMemDictDO> loginOutRecords = renSheJuMapper.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 = renSheJuMapper.dailyStudyRecords(dailyStudyInfoVO.getMemberId(), dailyStudyInfoVO.getDownCode(), 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 = renSheJuMapper.dailyActivities(dailyStudyInfoVO.getDownCode(), dailyStudyInfoVO.getMemberId());
                for (DailyActivitiesVO dailyActivitiesVO : activityDetectionDOS) {

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

                    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));

            RequestBody body = RequestBody.create(mediaType, JSONObject.fromObject(classHourBehaviorDTO).toString());

            Request request = new Request.Builder()
                    .url(renSheConfig.getUrl() + "/import/downstream/social/uploadClassHourBehavior")
                    .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(ShehuihuaConstant.POST_4);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(classHourBehaviorDTO).toString());
            if (200 == response.code()) {
                renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
            } else {
                renshejuHistoryDO.setOutputParam(RenSheJuConstant.API_ERROR);
            }
            renshejuHistoryMapper.insert(renshejuHistoryDO);
            return rensheResponseVO;
//            return null;
        } catch (Exception e) {
            e.printStackTrace();
            RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
            renshejuHistoryDO.setInterfaceName(ShehuihuaConstant.POST_4);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(classHourBehaviorDTO).toString());
            renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
        }
        return null;
    }

    public RensheResponseVO uploadChapterBehavior() throws IOException {

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

        UploadChapterBehavior5DTO uploadChapterBehaviorDTO = new UploadChapterBehavior5DTO();

        uploadChapterBehaviorDTO.setPrivateKey(getSecret());

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

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

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

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

                    for (MemberDO memberDO : memberDOList) {

                        //章节课程考试时间列表
                        ChapterExamBasic5 chapterExamBasic = new ChapterExamBasic5();
                        chapterExamBasic.setClassCode(String.valueOf(classId));

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

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

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

                        //考试活跃度列表
                        List<ActivityList> activityLists = new ArrayList<>();
                        List<ExamActivitiesVO> activityDetectionDOS = renSheJuMapper.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 = renSheJuMapper.loginRecords(memberDO.getId());
                        //下线时间
                        List<OprMemDictDO> loginOutRecords = renSheJuMapper.loginOutRecords(memberDO.getId());

                        boolean flag = false;

                        for (int i = 0; i < loginRecords.size(); i++) {
                            //找到该时间段内的测评
                            List<ExerciseDoneResultDO> exerciseDoneResultDOS = renSheJuMapper.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.getUrl() + "/import/downstream/social/uploadChapterBehavior")
                        .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(ShehuihuaConstant.POST_5);
                    renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadChapterBehaviorDTO).toString());
                    if (200 == response.code()) {
                        renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
                    } else {
                        renshejuHistoryDO.setOutputParam(RenSheJuConstant.API_ERROR);
                    }
                    renshejuHistoryMapper.insert(renshejuHistoryDO);
                }
                return rensheResponseVO;
//                return null;
            } else {
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(ShehuihuaConstant.POST_5);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadChapterBehaviorDTO).toString());
                renshejuHistoryDO.setOutputParam(RenSheJuConstant.NO_DATA);
                renshejuHistoryMapper.insert(renshejuHistoryDO);
                return null;
            }
        } catch (Exception e) {
            RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
            renshejuHistoryDO.setInterfaceName(ShehuihuaConstant.POST_5);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadChapterBehaviorDTO).toString());
            renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
        }
        return null;
    }

    public RensheResponseVO uploadClassAnswerQuestionBehavior() throws IOException {

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

        UploadClassAnswerQuestionBehavior6DTO uploadClassAnswerQuestionBehaviorDTO = new UploadClassAnswerQuestionBehavior6DTO();

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

        List<DailyAnswerVO> dailyAnswerVOS = renSheJuMapper.dailyAnswer("1");

        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<AnswerBasic6> answerBasics = new ArrayList<>();

                for (String key : hashMap.keySet()) {
                    AnswerBasic6 answerBasic = new AnswerBasic6();
                    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.getUrl() + "/import/downstream/social/uploadClassAnswerQuestionBehavior")
                        .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(ShehuihuaConstant.POST_6);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadClassAnswerQuestionBehaviorDTO).toString());
                if (200 == response.code()) {
                    renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
                } else {
                    renshejuHistoryDO.setOutputParam(RenSheJuConstant.API_ERROR);
                }
                renshejuHistoryMapper.insert(renshejuHistoryDO);

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

    public List<RensheResponseVO> uploadImage() throws IOException {

        List<RensheResponseVO> rensheResponseVOS = new ArrayList<>();

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


        //找到昨天做过人脸识别的班级
        List<Long> classIds = renSheJuMapper.checkClassIds("1");

        for (Long classId : classIds) {

            UploadImageDTO7 uploadImage = new UploadImageDTO7();
            uploadImage.setPrivateKey(getSecret());
            uploadImage.setClassCode(String.valueOf(classId));

            List<ImageDetailList> imageDetailLists = new ArrayList<ImageDetailList>();
            try {
                /**
                 * 第二次人脸识别
                 */
                List<ClassImageChecksVO> classImageChecksVOS2 = renSheJuMapper.studyCheck(classId);

                if (classImageChecksVOS2.size() > 0) {
                    for (ClassImageChecksVO cicon : classImageChecksVOS2) {
                        int count = imageCheckRecordMapper.selectCount(new QueryWrapper<ImageCheckRecordDO>()
                                .lambda()
                                .eq(ImageCheckRecordDO::getResult, 1)
                                .isNull(ImageCheckRecordDO::getPaperId)
                                .eq(ImageCheckRecordDO::getMemberId, cicon.getMemberId())
                                .eq(ImageCheckRecordDO::getClassId, cicon.getClassId()));

                        ImageDetailList imageDetailList = new ImageDetailList();
                        BeanUtils.copyProperties(cicon, imageDetailList);
                        imageDetailList.setImageBase64("data:image/jpeg;base64," + OSSUtils.image2Base64(cicon.getImage()));
                        if (count == 1) {
                            imageDetailList.setProcessType(0L);
                            imageDetailList.setDetectionType(0L);
                        } else if (count == 2) {
                            imageDetailList.setProcessType(1L);
                            imageDetailList.setDetectionType(1L);
                        }
                        imageDetailLists.add(imageDetailList);
                    }

                }

                /**
                 * 考试检测数据
                 */
                List<ClassImageChecksVO> examChecks = renSheJuMapper.examCheck(classId);

                if (examChecks.size() > 0) {
                    for (ClassImageChecksVO cicon : examChecks) {

                        ImageDetailList imageDetailList = new ImageDetailList();
                        BeanUtils.copyProperties(cicon, imageDetailList);
                        imageDetailList.setImageBase64("data:image/jpeg;base64," + OSSUtils.image2Base64(cicon.getImage()));
                        imageDetailList.setProcessType(2L);
                        imageDetailList.setDetectionType(1L);
                        imageDetailLists.add(imageDetailList);
                    }
                }

                uploadImage.setImageDetailList(imageDetailLists);

                if (imageDetailLists.size() > 0) {
                    System.out.println(com.alibaba.fastjson.JSONObject.toJSONString(uploadImage));
                    RequestBody body = RequestBody.create(mediaType, JSONObject.fromObject(uploadImage).toString());
                    Request request = new Request.Builder()
                            .url(renSheConfig.getUrl() + "/import/downstream/social/uploadImage")
                            .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(ShehuihuaConstant.POST_7);
                    renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadImage).toString());
                    renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
                    renshejuHistoryMapper.insert(renshejuHistoryDO);
                    rensheResponseVOS.add(rensheResponseVO);
                    System.out.println(111);
                } else {
                    RenshejuHistoryDO renshejuHistoryDO1 = new RenshejuHistoryDO();
                    renshejuHistoryDO1.setInterfaceName(ShehuihuaConstant.POST_7);
                    renshejuHistoryDO1.setInputParam(JSONObject.fromObject(uploadImage).toString());
                    renshejuHistoryDO1.setOutputParam(RenSheJuConstant.NO_DATA);
                    renshejuHistoryMapper.insert(renshejuHistoryDO1);
                }
//            return null;
            } catch (Exception e) {
                e.printStackTrace();
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(ShehuihuaConstant.POST_7);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadImage).toString());
                renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
                renshejuHistoryMapper.insert(renshejuHistoryDO);
            }
        }

        return rensheResponseVOS;
    }

    public RensheResponseVO getErrorClass() throws IOException {

        OkHttpClient client = new OkHttpClient().newBuilder()
                .build();
        MediaType mediaType = MediaType.parse("application/json");
        RequestBody body = RequestBody.create(mediaType,"{\"privateKey\":\""+getSecret()+"\"}");
        Request request = new Request.Builder()
                .url(renSheConfig.getUrl() + "/import/downstream/social/getErrorClass")
                .method("POST", body)
                .addHeader("User-Agent", "Apifox/1.0.0 (https://www.apifox.cn)")
                .addHeader("Content-Type", "application/json")
                .build();
        try {
            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(ShehuihuaConstant.POST_8);
            renshejuHistoryDO.setInputParam(getSecret());
            if (200 == response.code()) {
                renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
            } else {
                renshejuHistoryDO.setOutputParam(RenSheJuConstant.API_ERROR);
            }
            renshejuHistoryMapper.insert(renshejuHistoryDO);
            return rensheResponseVO;
        } catch (Exception e) {
            RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
            renshejuHistoryDO.setInterfaceName(ShehuihuaConstant.POST_8);
            renshejuHistoryDO.setInputParam(getSecret());
            renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
        }
        return null;
    }

    public RensheStringVO clear() throws IOException {

        OkHttpClient client = new OkHttpClient().newBuilder()
                .build();
        MediaType mediaType = MediaType.parse("application/json");
        RequestBody body = RequestBody.create(mediaType,"{\"privateKey\":\""+getSecret()+"\"}");
        Request request = new Request.Builder()
                .url(renSheConfig.getUrl() + "/import/downstream/social/clear")
                .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();
        RensheStringVO rensheStringVO = JSON.parseObject(response.body().string(), RensheStringVO.class);
        System.out.println(rensheStringVO);

        return rensheStringVO;
    }


    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", renSheConfig.getSecretKey())
                .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 getSecretVO.getCtt().getPrivateKey();
    }

    public static void main(String[] args) {
//        GetSecretVO getSecretVO = new GetSecretVO();
//
//        getSecretVO.setC(1);
//        getSecretVO.setMsg("aaaa");
//        GetSecretChildVO getSecretChildVO = new GetSecretChildVO();
//        getSecretChildVO.setIp("1121");
//        getSecretChildVO.setPrivateKey("1111111");
////        getSecretChildVO.setValidTime("2212");
//        getSecretVO.setCtt(getSecretChildVO);
//        String s = JSONObject.fromObject(getSecretVO).toString();
//        System.out.println(s);

        LocalDateTime localDateTime = LocalDateTime.now();
        System.out.println(localDateTime.toString());

    }

    public void test() {
        System.out.println("132222222222222222222222222222");
    }

}