package com.ibeetl.jlw.service;

import cn.jlw.util.ToolUtils;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.ibeetl.admin.core.entity.CoreUser;
import com.ibeetl.admin.core.service.CoreBaseService;
import com.ibeetl.admin.core.util.PlatformException;
import com.ibeetl.admin.core.web.JsonResult;
import com.ibeetl.admin.core.web.JsonReturnCode;
import com.ibeetl.jlw.dao.TeacherOpenCourseMergeScheduleSessionDao;
import com.ibeetl.jlw.entity.FileEntity;
import com.ibeetl.jlw.entity.TeacherOpenCourseMergeScheduleSession;
import com.ibeetl.jlw.web.query.TeacherOpenCourseMergeScheduleSessionQuery;
import org.apache.commons.lang3.StringUtils;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.beetl.sql.core.SqlId;
import org.beetl.sql.core.engine.PageQuery;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;

import java.io.*;
import java.util.*;

import static com.ibeetl.admin.core.util.ExcelUtil.getCellFormatValue;

/**
 * 开课关联排课配置 Service
 * 当分布式ID开启后请勿使用insert(*,true)
 */

@Service
@Transactional
@Validated
public class TeacherOpenCourseMergeScheduleSessionService extends CoreBaseService<TeacherOpenCourseMergeScheduleSession>{

    @Autowired private TeacherOpenCourseMergeScheduleSessionDao teacherOpenCourseMergeScheduleSessionDao;

    public PageQuery<TeacherOpenCourseMergeScheduleSession>queryByCondition(PageQuery query){
        PageQuery ret =  teacherOpenCourseMergeScheduleSessionDao.queryByCondition(query);
        queryListAfter(ret.getList());
        return ret;
    }

    public PageQuery<TeacherOpenCourseMergeScheduleSession>queryByConditionQuery(PageQuery query){
        PageQuery ret =  teacherOpenCourseMergeScheduleSessionDao.queryByConditionQuery(query);
        queryListAfter(ret.getList());
        return ret;
    }

    public void deleteByList(List list){
        String ids = "";
        ToolUtils.deleteNullList(list);
        for(int i=0;null != list && i<list.size();i++){
            ids += list.get(i).toString()+(i==list.size()-1?"":",");
        }
        if(StringUtils.isNotBlank(ids)){
            teacherOpenCourseMergeScheduleSessionDao.deleteTeacherOpenCourseMergeScheduleSessionByIds(ids);
        }
    }

    public void deleteTeacherOpenCourseMergeScheduleSession(String ids){
        try {
            teacherOpenCourseMergeScheduleSessionDao.deleteTeacherOpenCourseMergeScheduleSessionByIds(ids);
        } catch (Exception e) {
            throw new PlatformException("批量删除开课关联排课配置失败", e);
        }
    }

    public String addAll(TeacherOpenCourseMergeScheduleSessionQuery teacherOpenCourseMergeScheduleSessionQuery){
        String msg = "";
        List<TeacherOpenCourseMergeScheduleSession> teacherOpenCourseMergeScheduleSessionList = new ArrayList<>();
        try {
            teacherOpenCourseMergeScheduleSessionList = JSON.parseArray(teacherOpenCourseMergeScheduleSessionQuery.getTeacherOpenCourseMergeScheduleSessionJsonStr(), TeacherOpenCourseMergeScheduleSession.class);
        } catch (Exception e) {
            try {
                teacherOpenCourseMergeScheduleSessionList.add(JSONObject.parseObject(teacherOpenCourseMergeScheduleSessionQuery.getTeacherOpenCourseMergeScheduleSessionJsonStr(), TeacherOpenCourseMergeScheduleSession.class));
            } catch (Exception e1) {}
        }
        ToolUtils.deleteNullList(teacherOpenCourseMergeScheduleSessionList);
        if(null != teacherOpenCourseMergeScheduleSessionList && teacherOpenCourseMergeScheduleSessionList.size()>0){
            for(int i=0;i<teacherOpenCourseMergeScheduleSessionList.size();i++){
                TeacherOpenCourseMergeScheduleSession teacherOpenCourseMergeScheduleSession = teacherOpenCourseMergeScheduleSessionList.get(i);
                teacherOpenCourseMergeScheduleSession.setTeacherOpenCourseMergeScheduleSessionAddTime(teacherOpenCourseMergeScheduleSessionQuery.getTeacherOpenCourseMergeScheduleSessionAddTime());
                teacherOpenCourseMergeScheduleSession.setUserId(teacherOpenCourseMergeScheduleSessionQuery.getUserId());
                teacherOpenCourseMergeScheduleSession.setOrgId(teacherOpenCourseMergeScheduleSessionQuery.getOrgId());
            }
            insertBatch(teacherOpenCourseMergeScheduleSessionList);
        }
        return msg;
    }

    public JsonResult add(TeacherOpenCourseMergeScheduleSessionQuery teacherOpenCourseMergeScheduleSessionQuery){
        String msg = "";
        TeacherOpenCourseMergeScheduleSession teacherOpenCourseMergeScheduleSession = teacherOpenCourseMergeScheduleSessionQuery.pojo();
        teacherOpenCourseMergeScheduleSession.setTeacherOpenCourseMergeScheduleSessionAddTime(new Date());
        teacherOpenCourseMergeScheduleSessionDao.insert(teacherOpenCourseMergeScheduleSession);
        teacherOpenCourseMergeScheduleSessionQuery.setTeacherOpenCourseMergeScheduleSessionId(teacherOpenCourseMergeScheduleSession.getTeacherOpenCourseMergeScheduleSessionId());
        JsonResult jsonResult = new JsonResult();
        jsonResult.setData(teacherOpenCourseMergeScheduleSession.getTeacherOpenCourseMergeScheduleSessionId());//自增的ID丢进去
        jsonResult.setCode(JsonReturnCode.SUCCESS.getCode());
        jsonResult.setMsg(msg);
        return jsonResult;
    }

    public String edit(TeacherOpenCourseMergeScheduleSessionQuery teacherOpenCourseMergeScheduleSessionQuery){
        String msg = "";
        TeacherOpenCourseMergeScheduleSession teacherOpenCourseMergeScheduleSession = teacherOpenCourseMergeScheduleSessionQuery.pojo();
        teacherOpenCourseMergeScheduleSessionDao.updateTemplateById(teacherOpenCourseMergeScheduleSession);
        return msg;
    }

    public String updateGivenByIds(TeacherOpenCourseMergeScheduleSessionQuery teacherOpenCourseMergeScheduleSessionQuery){
        String msg = "";
        if(StringUtils.isNotBlank(teacherOpenCourseMergeScheduleSessionQuery.get_given())){
            boolean flag = teacherOpenCourseMergeScheduleSessionDao.updateGivenByIds(teacherOpenCourseMergeScheduleSessionQuery) > 0;
            if(!flag){
                msg = "更新指定参数失败";
            }
        }else{
            msg = "指定参数为空";
        }
        return msg;
    }

    public List<TeacherOpenCourseMergeScheduleSession> getValues (Object paras){
        return sqlManager.select(SqlId.of("jlw.teacherOpenCourseMergeScheduleSession.getTeacherOpenCourseMergeScheduleSessionValues"), TeacherOpenCourseMergeScheduleSession.class, paras);
    }

    public List<TeacherOpenCourseMergeScheduleSession> getValuesByQuery (TeacherOpenCourseMergeScheduleSessionQuery teacherOpenCourseMergeScheduleSessionQuery){
        return teacherOpenCourseMergeScheduleSessionDao.getValuesByQuery(teacherOpenCourseMergeScheduleSessionQuery);
    }

    public List<TeacherOpenCourseMergeScheduleSession> getValuesByQueryNotWithPermission (TeacherOpenCourseMergeScheduleSessionQuery teacherOpenCourseMergeScheduleSessionQuery){
        return teacherOpenCourseMergeScheduleSessionDao.getValuesByQueryNotWithPermission(teacherOpenCourseMergeScheduleSessionQuery);
    }

    public TeacherOpenCourseMergeScheduleSession getInfo (Long teacherOpenCourseMergeScheduleSessionId){
        TeacherOpenCourseMergeScheduleSessionQuery teacherOpenCourseMergeScheduleSessionQuery = new TeacherOpenCourseMergeScheduleSessionQuery();
        teacherOpenCourseMergeScheduleSessionQuery.setTeacherOpenCourseMergeScheduleSessionId(teacherOpenCourseMergeScheduleSessionId);
        List<TeacherOpenCourseMergeScheduleSession> list = teacherOpenCourseMergeScheduleSessionDao.getValuesByQuery(teacherOpenCourseMergeScheduleSessionQuery);
        if(null != list && list.size()>0){
            return list.get(0);
        }else{
            return null;
        }
    }

    public TeacherOpenCourseMergeScheduleSession getInfo (TeacherOpenCourseMergeScheduleSessionQuery teacherOpenCourseMergeScheduleSessionQuery){
        List<TeacherOpenCourseMergeScheduleSession> list = teacherOpenCourseMergeScheduleSessionDao.getValuesByQuery(teacherOpenCourseMergeScheduleSessionQuery);
        if(null != list && list.size()>0){
            return list.get(0);
        }else{
            return null;
        }
    }


    public JsonResult importTemplate(List<FileEntity> fileEntityList,List<Long>list,CoreUser coreUser){
        List<String[]>errMsg = new ArrayList<>();
        String msg ="";
        int count = 0;
        Date date = new Date();
        for(int item=0;null != fileEntityList && item<fileEntityList.size();item++){
            FileEntity fileEntity = fileEntityList.get(item);
            if(null != fileEntity){
                File file = new File(fileEntity.getAbsoluteUrl());
                if(file.exists() && file.isFile() && file.canRead() && ToolUtils.findInSet("xls,xlsx",fileEntity.getFormat())){
                    Workbook wb = null;
                    InputStream is = null;
                    try {
                        is = new FileInputStream(fileEntity.getAbsoluteUrl());
                        if("xls".equals(fileEntity.getFormat())){
                            wb = new HSSFWorkbook(is);
                        }else if("xlsx".equals(fileEntity.getFormat())){
                            wb = new XSSFWorkbook(is);
                        }
                    } catch (FileNotFoundException e) {
                        e.printStackTrace();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                    try {
                        if(null != is){
                        is.close();
                    }
                    }catch (Exception e){
                        e.printStackTrace();
                    }
                    if(wb != null){
                        //获取Sheet1
                        Sheet sheet = wb.getSheet("Sheet1");
                        //获取最大行数
                        int rowNum = sheet.getPhysicalNumberOfRows();
                        //获取第一行
                        Row firstRow = sheet.getRow(0);
                        //获取最大列数
                        int colNum = firstRow.getPhysicalNumberOfCells();

                        String columns[] = {
                                        "开课",
                                        "课程排课配置",
                                        "状态",
                        };

                        Map<String,Integer> map = new HashMap<>();//获取需要的表头的列

                        //从第一列找到需要的表头
                        for (int i=0; i<colNum; i++){
                            String cellData = getCellFormatValue(firstRow.getCell(i));
                            for(int j=0;j<columns.length;j++){
                                if(columns[j].equals(cellData)){
                                    map.put(columns[j],i);
                                }
                            }
                        }

                        //验证所需要的表头是否全
                        Integer flag = 0;
                        for(int i=0;i<columns.length;i++){
                            if(null != map.get(columns[i])){
                                flag ++;
                            }
                        }
                        if(flag != columns.length){
                            String str = " ";
                            for(int i=0;i<columns.length;i++){
                                str += "\""+columns[i]+"\""+(i == columns.length-1?"":", ");
                            }
                            return JsonResult.failMessage("导入失败，表格表头应包含"+str);
                        }

                        for (int i = 1; i<rowNum; i++) {
                            Row row = sheet.getRow(i);
                            if(null == row){
                                errMsg.add(new String[]{"第"+(i+1)+"数据为空"});
                                continue;
                            }

                            String teacherOpenCourseId = getCellFormatValue(row.getCell(map.get(columns[0])));
                            String teacherOpenCourseScheduleSessionId = getCellFormatValue(row.getCell(map.get(columns[1])));
                            String teacherOpenCourseMergeScheduleSessionStatus = getCellFormatValue(row.getCell(map.get(columns[2])));
                            //TODO 判断（如重复等复杂判断要额外写）
                            if(StringUtils.isBlank(teacherOpenCourseId)){
                                errMsg.add(new String[]{"第"+ToolUtils.numberToLetter(map.get(columns[0])+1)+"列，第"+(i+1)+"行开课为空"});
                                continue;
                            }else
                            if(StringUtils.isBlank(teacherOpenCourseScheduleSessionId)){
                                errMsg.add(new String[]{"第"+ToolUtils.numberToLetter(map.get(columns[1])+1)+"列，第"+(i+1)+"行课程排课配置为空"});
                                continue;
                            }else
                            if(StringUtils.isBlank(teacherOpenCourseMergeScheduleSessionStatus)){
                                errMsg.add(new String[]{"第"+ToolUtils.numberToLetter(map.get(columns[2])+1)+"列，第"+(i+1)+"行状态为空"});
                                continue;
                            }else
                            {
                            //TODO 保存
                            TeacherOpenCourseMergeScheduleSession teacherOpenCourseMergeScheduleSession = new TeacherOpenCourseMergeScheduleSession();
                            teacherOpenCourseMergeScheduleSession.setTeacherOpenCourseId(Long.parseLong(teacherOpenCourseId));
                            teacherOpenCourseMergeScheduleSession.setTeacherOpenCourseScheduleSessionId(Long.parseLong(teacherOpenCourseScheduleSessionId));
                            teacherOpenCourseMergeScheduleSession.setTeacherOpenCourseMergeScheduleSessionAddTime(new Date());
                            teacherOpenCourseMergeScheduleSession.setTeacherOpenCourseMergeScheduleSessionStatus(Integer.parseInt(teacherOpenCourseMergeScheduleSessionStatus));
                            teacherOpenCourseMergeScheduleSession.setOrgId(coreUser.getOrgId());
                            teacherOpenCourseMergeScheduleSession.setUserId(coreUser.getId());

                            count++;
                            }
                        }
                    }
                }
            }
        }
        JsonResult jsonResult = new JsonResult();
        jsonResult.setCode(count>0?JsonReturnCode.SUCCESS.getCode():JsonReturnCode.FAIL.getCode());
        jsonResult.setData(errMsg);
        jsonResult.setMsg((count>0?"导入成功,共导入"+count+"条":"导入失败")+(StringUtils.isNotBlank(msg)?"<br>"+msg:""));
        return jsonResult;
    }

    public List<Map<String,Object>> getExcelValues (TeacherOpenCourseMergeScheduleSessionQuery teacherOpenCourseMergeScheduleSessionQuery){
        return teacherOpenCourseMergeScheduleSessionDao.getExcelValues(teacherOpenCourseMergeScheduleSessionQuery);
    }


}