service-live/app/service/users/personal.js

'use strict';
const { CrudService } = require('naf-framework-mongoose/lib/service');
const { BusinessError, ErrorCode } = require('naf-core').Error;
const { ObjectId } = require('mongoose').Types;
const _ = require('lodash');
const jwt = require('jsonwebtoken');
const assert = require('assert');
const Excel = require('exceljs');

// 个人用户
class PersonalService extends CrudService {
  constructor(ctx) {
    super(ctx, 'personal');
    this.redis = this.app.redis;
    this.model = this.ctx.model.Personal;
  }
  /**
   * 创建用户
   * @param {Object} params 用户信息
   */
  async create({ password, ...data }) {
    data.password = { secret: password };
    const { phone } = data;
    // 检查手机号
    const num = await this.model.count({ phone, isdel: '0' });
    if (num > 0) throw new BusinessError(ErrorCode.DATA_EXISTED, '已有个人用户使用该手机号');
    return await this.model.create(data);
  }
  /**
   * 修改密码
   * @param {Object} {id,password} 用户id和密码
   */
  async password({ id, password }) {
    const object = await this.model.findById(id);
    if (!object) throw new BusinessError(ErrorCode.DATA_NOT_EXIST, '未找到用户的信息');
    object.password = { secret: password };
    await object.save();
  }
  /**
   * 登陆
   * @param {Object} params 登陆信息
   * @property phone 手机号
   * @property password 密码
   */
  async login({ phone, password }) {
    const object = await this.model.findOne({ phone, isdel: '0' }, '+password');
    if (!object) throw new BusinessError(ErrorCode.DATA_NOT_EXIST, '未找到用户的信息');
    const { password: op, status } = object;
    const { secret } = op;
    if (status !== '1') throw new BusinessError(ErrorCode.ACCESS_DENIED, '拒绝访问!');
    if (secret !== password) throw new BusinessError(ErrorCode.BAD_PASSWORD, '密码错误');
    const data = _.omit(JSON.parse(JSON.stringify(object)), ['meta', 'password', '__v']);
    const { secret: secrets } = this.config.jwt;
    const token = jwt.sign(data, secrets);
    // 记录登陆
    // let number = await this.redis.get('login_number') || 0;
    // number++;
    // await this.redis.set('login_number', number);
    return token;
  }

  async delete({ id }) {
    const object = await this.model.findById(id);
    if (!object) throw new BusinessError(ErrorCode.DATA_NOT_EXIST, '未找到用户的信息');
    object.isdel = '1';
    await object.save();
  }
  /**
   * 个人升变专家
   * @param {Object} body 升变数据
   * 升级的时候要把所属的信息(产品,需求等)换到升级后的数据上,一种数据迁移
   */
  async upgrade({ id, ...data }) {
    assert(id, '缺少个人用户ID');
    const user = await this.model.findOne({ _id: ObjectId(id) }, '+password');
    if (!user) throw new BusinessError(ErrorCode.DATA_NOT_EXIST, '未找到用户的信息');
    data = _.omit(data, ['meta', '__v']);
    data.user_id = id;
    // 创建专家
    const is_expert = await this.ctx.model.Expert.count({ user_id: ObjectId(id) });
    if (is_expert > 0) throw new BusinessError(ErrorCode.DATA_EXISTED, '已升级为专家,无需再次升级');
    await this.ctx.model.Expert.create(data);
    user.is_expert = true;
    await user.save();
  }

  async import({ uri }) {
    assert(uri, '未获取到文件地址');
    let domain = 'http://127.0.0.1';
    const file = await this.ctx.curl(`${domain}${uri}`);
    if (!(file && file.data)) {
      throw new BusinessError(ErrorCode.DATA_NOT_EXIST, '未找到指定文件');
    }
    const workbook = new Excel.Workbook();
    await workbook.xlsx.load(file.data);
    const sheet = workbook.getWorksheet(1);
    let meta = this.importMeta();
    // 根据excel,将列序号加入meta中
    const head = _.get(sheet.getRow(1), 'values', []);
    for (let i = 0; i < head.length; i++) {
      const e = head[i];
      if (!e) continue;
      const r = meta.find((f) => f.column === e);
      if (r) r.index = i;
    }
    // 过滤出列表中不必要且不存在的字段
    meta = meta.filter((f) => f.required || f.index);
    const errorList = [];
    const dataList = [];
    sheet.eachRow(async (row, index) => {
      if (index !== 1) {
        const values = row.values;
        const obj = {};
        for (const m of meta) {
          const { required, key, index, method } = m;
          const value = values[index];
          if (required && !value) {
            // 必填且没值的情况
            errorList.push({ message: `第${index}行数据,缺少必填项;` });
            continue;
          }
          if (_.isFunction(method)) obj[key] = method(value);
          else obj[key] = value;
        }
        dataList.push(obj);
      }
    });
    if (errorList.length > 0) return errorList;
    for (const i of dataList) {
      try {
        await this.create(i);
      } catch (error) {
        errorList.push(error);
      }
    }

    return errorList;
  }

  importMeta() {
    return [
      { required: true, column: '用户名', key: 'name' },
      { required: true, column: '手机号', key: 'phone' },
      { required: true, column: '登录密码', key: 'password' },
      { required: true, column: '邀请码', key: 'code' },
      { required: true, column: '身份证号', key: 'card' },
      { column: '电子邮箱', key: 'email' },
      { column: '联系地址', key: 'addr' },
      { column: '办公电话', key: 'office_phone' },
      { column: '所属辖区', key: 'juris' },
      { column: '院校', key: 'school' },
      { column: '专业', key: 'major' },
      { column: '职务职称', key: 'zwzc' },
      { column: '审核状态', key: 'status' },
    ];
  }
}

module.exports = PersonalService;