service-center/app/service/teacher.js

'use strict';

const assert = require('assert');
const _ = require('lodash');
const moment = require('moment');
const XLSX = require('xlsx');
const { CrudService } = require('naf-framework-mongoose/lib/service');
const { BusinessError, ErrorCode } = require('naf-core').Error;
const stringRandom = require('string-random');
const { ObjectId } = require('mongoose').Types;

class TeacherService extends CrudService {
  constructor(ctx) {
    super(ctx, 'teacher');
    this.model = this.ctx.model.Teacher;
    this.umodel = this.ctx.model.User;
    const { baseUrl } = _.get(this.ctx.app.config, 'mission');
    if (baseUrl) this.missionBase = baseUrl;
  }

  async query({ name, ...info } = {}, { skip = 0, limit = 0 } = {}) {
    const query = { ...info };
    if (name) {
      query.name = { $regex: name };
    }
    let res = await this.model.find(query).skip(Number(skip)).limit(Number(limit));
    res = JSON.parse(JSON.stringify(res));
    for (const tea of res) {
      const r = await this.umodel.findOne({ uid: tea._id }, '+passwd');
      if (r) {
        const { passwd } = r;
        tea.secret = passwd.secret;
        tea.openid = _.get(r, 'openid');
      }
    }
    return res;
  }
  async count({ name, ...info } = {}) {
    const query = { ...info };
    if (name) {
      query.name = { $regex: name };
    }
    const res = await this.model.count(query);
    return res;
  }

  // 根据状态删除教师信息
  async deleteByStatus({ status }) {
    await this.model.deleteMany({ status });
    return 'deleted';
  }
  // 查询详情
  async fetchTeacher({ id }) {
    // 将文件拼到查询到的数据后
    return await this.model.findById(id, '+file');
  }
  async create(data) {
    const { name, phone: mobile } = data;
    const user = await this.umodel.findOne({ mobile });
    if (user) {
      throw new BusinessError(ErrorCode.DATA_EXIST, '电话已经存在');
    }
    // 创建教师信息
    const res = await this.model.create(data);
    // 再创建教师用户
    const passwd = stringRandom();
    const newdata = {
      name,
      mobile,
      type: '3',
      uid: ObjectId(res.id || res._id).toString(),
      passwd: { secret: passwd },
    };
    await this.umodel.create(newdata);
    // 返回教师信息
    return this.model.findById(res._id || res.id);
  }

  async delete({ id }) {
    await this.model.findByIdAndDelete(id);
    await this.umodel.deleteOne({ uid: id, type: '3' });
    return 'deleted';
  }

  // 批量查询教师
  async fetchteachers({ ids }) {
    return await this.model.find({ _id: { $in: ids } });
  }
  // 检查教师
  async checkarrange({ id, date }) {}

  async status(data) {
    const { teachersid, zlscore, msscore, status, remark } = data;
    for (const teacherid of teachersid) {
      const teacher = await this.model.findById(teacherid);
      console.log(status);
      teacher.status = status;
      if (zlscore) {
        teacher.zlscore = zlscore;
      }
      if (msscore) {
        teacher.msscore = msscore;
      }
      await teacher.save();
      let detail = '';
      if (status === '1') {
        const userInfo = await this.umodel.findOne({ uid: teacherid }, '+passwd');
        if (!userInfo) continue;
        const passwd = _.get(userInfo, 'passwd.secret');
        detail = '您的账号身份已确认，密码为:' + passwd + '请尽快登录账号上传课件资料附件';
      } else if (status === '4') {
        detail = '您已通过审核被正式录入教师库';
      }
      const date = await this.ctx.service.util.updatedate();

      const user = await this.umodel.findOne({ uid: teacher.id, type: '3' });

      if (user && user.openid) {
        await this.ctx.service.weixin.sendTemplateMsg(this.ctx.app.config.REVIEW_TEMPLATE_ID, user.openid, '您有一个新的通知', detail, date, remark);
      } else {
        await this.ctx.service.util.sendMail(teacher.email, '账号审核', detail, '');
      }
    }
  }

  // 教室分数上传
  async teaimport(data) {
    const { filepath } = data;
    assert(filepath, 'filepath不能为空');
    // 取得excle中数据
    const _filepath = this.ctx.app.config.baseUrl + filepath;
    const teadatas = await this.getImportXLSXData(_filepath);
    // 将得到的数据校验
    const datacheck = await this.datacheck(teadatas);
    if (datacheck.errorcode === '1') {
      return datacheck;
    }
    // 将数据存入数据库中
    for (const tea of teadatas) {
      const res = await this.model.findOne({
        idnumber: tea.idnumber,
        name: tea.name,
      });
      if (res) {
        res.beforescore = tea.xsscore;
        await res.save();
      }
    }
    return datacheck;
  }

  // 获取导入的XLSX文件中的数据
  async getImportXLSXData(filepath) {
    const file = await this.ctx.curl(filepath);
    const workbook = XLSX.read(file.data);
    // 读取内容
    let exceldata = [];
    const sheetNames = workbook.SheetNames; // 获取表名
    const sheet = workbook.Sheets[sheetNames[0]]; // 通过表名得到表对象
    // 遍历26个字母
    const theadRule = [];
    const range = XLSX.utils.decode_range(sheet['!ref']);
    const col_start = range.s.c;
    const col_end = range.e.c;
    for (let i = col_start; i <= col_end; i++) {
      const addr = XLSX.utils.encode_col(i) + XLSX.utils.encode_row(0);
      theadRule.push(sheet[addr].v);
    }
    const params = XLSX.utils.sheet_to_json(sheet); // 通过工具将表对象的数据读出来并转成json
    if (!params) return [];
    const length = params.length;
    const _datas = [];
    let data = {};
    for (let i = 0; i < length; i++) {
      data = params[i];
      _datas.push({
        idnumber: data[theadRule[1]],
        name: data[theadRule[2]],
        xsscore: data[theadRule[3]],
      });
    }
    exceldata = [ ...exceldata, ..._datas ];
    return exceldata;
  }

  // 获取导入的XLSX文件中的数据
  async datacheck(studatas) {
    let errorcode = '0';
    const errormsg = [];
    for (const data of studatas) {
      // 判断是否为空
      if (!data.idnumber) {
        errorcode = '1';
        data.msg = data.msg + '身份证号不允许为空，';
      }
      if (!data.name) {
        errorcode = '1';
        data.msg = data.msg + '姓名不允许为空，';
      }
      if (!data.xsscore) {
        errorcode = '1';
        data.msg = data.msg + '评分不允许为空，';
      }
      if (errorcode === '1') {
        errormsg.push(data);
      }
    }
    return { errorcode, errormsg };
  }

  // 建立任务
  async toExport(body) {
    const fn = `教师导出 ${moment().format('YYYY-MM-DD HH:SS:mm')}`;
    const data = {
      title: fn,
      params: {
        project: 'center',
        service: 'teacher',
        method: 'export',
        body,
      },
    };
    if (this.missionBase) {
      const url = `${this.missionBase}/api/mission`;
      const res = await this.ctx.curl(url, {
        method: 'post',
        headers: {
          'content-type': 'application/json',
        },
        data,
        dataType: 'json',
      });
      if (res.status !== 200 || res.data.errcode !== 0) {
        throw new BusinessError(ErrorCode.SERVICE_FAULT, '创建任务失败');
      }
    } else {
      throw new BusinessError(ErrorCode.SERVICE_FAULT, '未找到任务项目设置');
    }
  }

  // 导出
  async export({ missionid, model }) {
    assert(missionid, '缺少任务信息,无法执行任务');
    try {
      const head = model.map(i => {
        const { zh, model } = i;
        const headObj = { header: zh };
        if (model) headObj.key = model;
        headObj.width = 20;
        return headObj;
      });
      const fn = '教师导出';
      const data = await this.query();
      console.log(data.length);
      if (data.length <= 0) {
        throw new BusinessError(ErrorCode.DATA_NOT_EXIST, '未找到教师信息');
      }
      this.ctx.service.util.updateProcess(missionid, '50');
      const res = await this.ctx.service.util.toExcel(data, head, fn);
      console.log(res);
      if (!res) {
        console.error(`${moment().format('YYYY-MM-DD HH:mm:ss')} ${fn} 导出失败`);
        throw new BusinessError(ErrorCode.SERVICE_FAULT, `${fn}导出失败`);
      }
      this.ctx.service.util.updateProcess(missionid, '100', '2', {
        uri: res,
      });
    } catch (error) {
      console.log('in function:error');
      this.ctx.service.util.updateProcess(missionid, undefined, '3');
    }
  }
}

module.exports = TeacherService;