RenSheJuServiceImpl.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.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.RenSheJuService;
import com.subsidy.util.OSSUtils;
import com.subsidy.util.RenSheJuConstant;
import com.subsidy.util.SMSUtils;
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.*;
import java.util.stream.Collectors;
import java.util.stream.IntStream;

@Service
public class RenSheJuServiceImpl implements RenSheJuService {

    @Autowired
    private RenSheJuMapper renSheJuMapper;

    @Autowired
    private RenSheConfig renSheConfig;

    @Autowired
    private ClassDictMapper classDictMapper;

    @Autowired
    RenshejuHistoryMapper renshejuHistoryMapper;

    @Autowired
    private ImageCheckRecordMapper imageCheckRecordMapper;

    @Autowired
    private SMSUtils smsUtils;

    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 = renSheJuMapper.vodClassIds("0");

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

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

        //人脸识别
        List<Long> imageClassIds = renSheJuMapper.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 = renSheJuMapper.classBaseInfo(classId);
                    BeanUtils.copyProperties(classBaseInfoVO, epidemicSituationClassBasic);
                    epidemicSituationClassBasic.setClassCode(classBaseInfoVO.getDownCode());

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

                    //学员列表
                    List<MemberVO> memberVOS = renSheJuMapper.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.getUrl() + "/import/downstream/enterprise/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(RenSheJuConstant.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(RenSheJuConstant.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(RenSheJuConstant.POST_3);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(classBaseInfoDTO).toString());
            renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);

//            List<String> telephones = Arrays.asList(new String[]{"15201936167", "18201963812"});
//            for (String telephone : telephones) {
//                smsUtils.sendWarning("SMS_460945631", telephone, RenSheJuConstant.POST_2);
//            }
        }
        return null;
    }

    public RensheResponseVO classHourBehavior() throws IOException {

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

//      产生视频学习数据的班级
        List<VodClassIdsVO> vodClassIdsVOS = renSheJuMapper.vodClassCnt("0");

        for (VodClassIdsVO vodClassIdsVO : vodClassIdsVOS) {
            ClassHourBehaviorDTO classHourBehaviorDTO = new ClassHourBehaviorDTO();
            classHourBehaviorDTO.setPrivateKey(getSecret());

            //查看该班级今天产生的数据条数
            int count = renSheJuMapper.dataCount(vodClassIdsVO.getClassId());
            List<Long> longs = renSheJuMapper.classDistinctMember(vodClassIdsVO.getClassId());
            if (count > 300) {
                //某班级前一天数据人员去重
                int times = (int) Math.ceil((double) count / 300);
                int block = (int) Math.ceil((double) longs.size() / times);
                List<List<Long>> devide = devide(longs, block);
                for (List<Long> memberIds : devide) {
                    try {
                        sendStudyData(client, mediaType, classHourBehaviorDTO, vodClassIdsVO.getClassId(), memberIds);
                    } catch (Exception e) {
                        e.printStackTrace();
                        RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                        renshejuHistoryDO.setInterfaceName(RenSheJuConstant.POST_4);
                        renshejuHistoryDO.setInputParam(JSONObject.fromObject(classHourBehaviorDTO).toString());
                        renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
                        renshejuHistoryMapper.insert(renshejuHistoryDO);
                        List<String> telephones = Arrays.asList("15201936167", "18201963812");
                        for (String telephone : telephones) {
                            smsUtils.sendWarning("SMS_460945631", telephone, RenSheJuConstant.POST_3);
                        }
                    }
                }
            } else {
                try {
                    sendStudyData(client, mediaType, classHourBehaviorDTO, vodClassIdsVO.getClassId(), longs);
                } catch (Exception e) {
                    e.printStackTrace();
                    RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                    renshejuHistoryDO.setInterfaceName(RenSheJuConstant.POST_4);
                    renshejuHistoryDO.setInputParam(JSONObject.fromObject(classHourBehaviorDTO).toString());
                    renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
                    renshejuHistoryMapper.insert(renshejuHistoryDO);
                    List<String> telephones = Arrays.asList("15201936167", "18201963812");
                    for (String telephone : telephones) {
                        smsUtils.sendWarning("SMS_460945631", telephone, "3");
                    }
                }
            }
        }
        return null;
    }

    public void sendStudyData(OkHttpClient client, MediaType mediaType, ClassHourBehaviorDTO classHourBehaviorDTO, Long classId, List<Long> memberIds) throws Exception {

        List<ClassHourBasic> classHourBasics = new ArrayList<>();
        //产生数据的班级
        List<DailyStudyInfoVO> dailyStudyInfoVOS = renSheJuMapper.dailyStudyInfo(classId, memberIds);
        for (DailyStudyInfoVO dailyStudyInfoVO : dailyStudyInfoVOS) {
            ClassHourBasic classHourBasic = new ClassHourBasic();
            BeanUtils.copyProperties(dailyStudyInfoVO, classHourBasic);
            classHourBasic.setClassCode(dailyStudyInfoVO.getClassCode());

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

                ActivityList activityList = new ActivityList();

                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.getUrl() + "/import/downstream/enterprise/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(RenSheJuConstant.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);
            classHourBasics.clear();
        } else {
            RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
            renshejuHistoryDO.setInterfaceName(RenSheJuConstant.POST_4);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(classHourBehaviorDTO).toString());
            renshejuHistoryDO.setOutputParam(RenSheJuConstant.NO_DATA);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
        }
    }


    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 = renSheJuMapper.dailyExamBasic("0");

//        List<Long> classIds = new ArrayList<>();
//        classIds.add(490L);

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

                    //具体哪些人做了
                    List<MemberDO> memberDOList = renSheJuMapper.memberIds(classId);
                    ClassDictDO classDictDO = classDictMapper.selectById(classId);
                    for (MemberDO memberDO : memberDOList) {

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

                        //最后一节课作为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();
                            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());

                        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());
                                examLists.add(examList);
                            }
                        }

                        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/enterprise/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(RenSheJuConstant.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;
            } else {
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(RenSheJuConstant.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(RenSheJuConstant.POST_5);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadChapterBehaviorDTO).toString());
            renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);

//            List<String> telephones = Arrays.asList(new String[]{"15201936167", "18201963812"});
//            for (String telephone : telephones) {
//                smsUtils.sendWarning("SMS_460945631", telephone, RenSheJuConstant.POST_4);
//            }
        }
        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 = renSheJuMapper.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.getUrl() + "/import/downstream/enterprise/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);

                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(RenSheJuConstant.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;
            } else {
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(RenSheJuConstant.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(RenSheJuConstant.POST_6);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadClassAnswerQuestionBehaviorDTO).toString());
            renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
//            List<String> telephones = Arrays.asList(new String[]{"15201936167", "18201963812"});
//            for (String telephone : telephones) {
//                smsUtils.sendWarning("SMS_460945631", telephone, RenSheJuConstant.POST_5);
//            }
        }
        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("0");

//        List<Long> classIds = new ArrayList<>();
//        classIds.add(535L);
//        classIds.add(536L);
//        classIds.add(539L);

        for (Long classId : classIds) {

            UploadImageDTO uploadImage = new UploadImageDTO();
            uploadImage.setPrivateKey(getSecret());
            ClassDictDO classDictDO = classDictMapper.selectById(classId);
            uploadImage.setClassCode(classDictDO.getClassCode());

            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/enterprise/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(RenSheJuConstant.POST_7);
                    renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadImage).toString());
                    if (null != rensheResponseVO.getCtt()) {
                        renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
                    } else {
                        renshejuHistoryDO.setOutputParam(rensheResponseVO.getMsg());
                    }
                    renshejuHistoryMapper.insert(renshejuHistoryDO);
                    rensheResponseVOS.add(rensheResponseVO);
                } else {
                    RenshejuHistoryDO renshejuHistoryDO1 = new RenshejuHistoryDO();
                    renshejuHistoryDO1.setInterfaceName(RenSheJuConstant.POST_7);
                    renshejuHistoryDO1.setInputParam(JSONObject.fromObject(uploadImage).toString());
                    renshejuHistoryDO1.setOutputParam(RenSheJuConstant.NO_DATA);
                    renshejuHistoryMapper.insert(renshejuHistoryDO1);
                }
            } catch (Exception e) {
                e.printStackTrace();
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(RenSheJuConstant.POST_7);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadImage).toString());
                renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
                renshejuHistoryMapper.insert(renshejuHistoryDO);
//                List<String> telephones = Arrays.asList(new String[]{"15201936167", "18201963812"});
//                for (String telephone : telephones) {
//                    smsUtils.sendWarning("SMS_460945631", telephone, RenSheJuConstant.POST_6);
//                }
            }
        }

        return rensheResponseVOS;
    }

    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/enterprise/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(RenSheJuConstant.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(RenSheJuConstant.POST_8);
            renshejuHistoryDO.setInputParam(getSecret());
            renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
        }
        return null;

    }

    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/enterprise/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(RenSheJuConstant.POST_9);
            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(RenSheJuConstant.POST_9);
            renshejuHistoryDO.setInputParam(getSecret());
            renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
        }
        return null;
    }

    public RensheResponseVO post6plus() throws Exception {

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

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

        List<Long> classIds = new ArrayList<>();

//        classIds.add(477L);

        for (Long classId : classIds) {

            //计算开始时间和截止时间
            ClassDictDO classDictDO = classDictMapper.selectById(classId);

            UploadImageDTO uploadImage = new UploadImageDTO();
            uploadImage.setPrivateKey(getSecret());
            uploadImage.setClassCode(classDictDO.getClassCode());

            List<ImageDetailList> imageDetailLists = new ArrayList<>();
            try {

                List<ClassImageChecksVO> classImageChecksVOS2 = renSheJuMapper.post6plus(classId);

                for (ClassImageChecksVO cicon : classImageChecksVOS2) {
                    ImageDetailList imageDetailList = new ImageDetailList();
                    BeanUtils.copyProperties(cicon, imageDetailList);
                    imageDetailList.setImageBase64("data:image/jpeg;base64," + OSSUtils.image2Base64(cicon.getImage()));
                    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/enterprise/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(RenSheJuConstant.POST_7);
                    renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadImage).toString());
                    if (null != rensheResponseVO.getCtt()) {
                        renshejuHistoryDO.setOutputParam(rensheResponseVO.getCtt().toString());
                    } else {
                        renshejuHistoryDO.setOutputParam(rensheResponseVO.getMsg());
                    }
                    renshejuHistoryMapper.insert(renshejuHistoryDO);
                    rensheResponseVOS.add(rensheResponseVO);
                } else {
                    RenshejuHistoryDO renshejuHistoryDO1 = new RenshejuHistoryDO();
                    renshejuHistoryDO1.setInterfaceName(RenSheJuConstant.POST_7);
                    renshejuHistoryDO1.setInputParam(JSONObject.fromObject(uploadImage).toString());
                    renshejuHistoryDO1.setOutputParam(RenSheJuConstant.NO_DATA);
                    renshejuHistoryMapper.insert(renshejuHistoryDO1);
                }

            } catch (Exception e) {
                e.printStackTrace();
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(RenSheJuConstant.POST_7);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(uploadImage).toString());
                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/enterprise/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 RensheResponseVO pushClassMembersData(PushClassMembersDataDTO pushClassMembersDataDTO) throws Exception {

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

//      产生视频学习数据的班级

        ClassHourBehaviorDTO classHourBehaviorDTO = new ClassHourBehaviorDTO();
        classHourBehaviorDTO.setPrivateKey(getSecret());

        //查看该班级今天产生的数据条数
        List<Long> memberIds = new ArrayList<>();

        String[] strings = pushClassMembersDataDTO.getMemberIds().split(",");
        for (String string : strings) {
            memberIds.add(Long.valueOf(string));
        }

        try {
            List<ClassHourBasic> classHourBasics = new ArrayList<>();
            //产生数据的班级
            List<DailyStudyInfoVO> dailyStudyInfoVOS = renSheJuMapper.dailyStudyInfo(pushClassMembersDataDTO.getClassId(), memberIds);
            for (DailyStudyInfoVO dailyStudyInfoVO : dailyStudyInfoVOS) {
                ClassHourBasic classHourBasic = new ClassHourBasic();
                BeanUtils.copyProperties(dailyStudyInfoVO, classHourBasic);
                classHourBasic.setClassCode(dailyStudyInfoVO.getClassCode());

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

                    ActivityList activityList = new ActivityList();

                    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.getUrl() + "/import/downstream/enterprise/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(RenSheJuConstant.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);
                classHourBasics.clear();
            } else {
                RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
                renshejuHistoryDO.setInterfaceName(RenSheJuConstant.POST_4);
                renshejuHistoryDO.setInputParam(JSONObject.fromObject(classHourBehaviorDTO).toString());
                renshejuHistoryDO.setOutputParam(RenSheJuConstant.NO_DATA);
                renshejuHistoryMapper.insert(renshejuHistoryDO);
            }
        } catch (Exception e) {
            e.printStackTrace();
            RenshejuHistoryDO renshejuHistoryDO = new RenshejuHistoryDO();
            renshejuHistoryDO.setInterfaceName(RenSheJuConstant.POST_4);
            renshejuHistoryDO.setInputParam(JSONObject.fromObject(classHourBehaviorDTO).toString());
            renshejuHistoryDO.setOutputParam(RenSheJuConstant.PUSH_FAIL);
            renshejuHistoryMapper.insert(renshejuHistoryDO);
            List<String> telephones = Arrays.asList("15201936167", "18201963812");
            for (String telephone : telephones) {
                smsUtils.sendWarning("SMS_460945631", telephone, RenSheJuConstant.POST_3);
            }
        }

        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", 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());

//        int ttl = 1600;
//        int memCnt = 173;
//        System.out.println((int) Math.ceil((double) ttl / 500) + "=============");

        System.out.println(devide(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13), 3));
    }

    public static <T> List<List<T>> devide(List<T> origin, int size) {

        int block = (origin.size() + size - 1) / size;
        return IntStream.range(0, block)
                .boxed().map(i -> {
                    int start = i * size;
                    int end = Math.min(start + size, origin.size());
                    return origin.subList(start, end);
                }).collect(Collectors.toList());
    }

}