'use strict';

const Service = require('../core/base_service');

const { Op } = require('sequelize');

const moment = require('moment');

const fileName = "Radio";

class RadioService extends Service {
  // 管理系统新增单选题
  async addRadio(form) {
    const { ctx } = this;
    try {
      const result = await ctx.model2.Radio.bulkCreate(form, { ignoreDuplicates: true });
      return result.length == 0 ? false : result;
    } catch (error) {
      const blockName = fileName + "--" + "addRadio";
      ctx.app.middleware.log('../../serviceLog', blockName + ">>>>" + error);
      return 'error';
    }
  }

    // 管理系统查看单选题
    async showRadio(uid, body) {
      const { ctx } = this;
      try {
        let { offset, limit, searchOptions, sortOptions } = body;
        offset = (offset - 1) * limit;
        let attributes = ['stem', 'options_a', 'options_b', 'options_c', 'options_d', 'answer', 'difficulty'],
          where = {}, order = [], dbOptions,
          joinSubstring = [],
          substring = ['stem', 'options_a', 'options_b', 'options_c', 'options_d', 'answer'],
          key = ['difficulty'],
          between = [];
        attributes.forEach(element => {
          if (searchOptions[element]) {
            if (searchOptions[element] == '*空') {
              if (joinSubstring.includes(element)) {
                where[element] = null;
              } else {
                where[element] = [null, ''];
              }
            } else if (joinSubstring.includes(element)) {
              let targetKeyArr = [];
              where[element] = targetKeyArr.length > 0 ? targetKeyArr : 'null';
            } else if (substring.includes(element)) {
              where[element] = { [Op.substring]: searchOptions[element] };
            } else if (key.includes(element)) {
              where[element] = searchOptions[element];
            } else if (between.includes(element)) {
              where[element] = { [Op.between]: [searchOptions[element][0], searchOptions[element][1]] };
            }
          }
          if (sortOptions[element] == true) {
            order.push([element, 'ASC']);
          } else if (sortOptions[element] == false) {
            order.push([element, 'DESC']);
          }
        });
        dbOptions = { attributes, offset, limit, where, order };
        const result = await ctx.model2.Radio.findAndCountAll(dbOptions);
        return result.rows.length == 0 ? false : result;
      } catch (error) {
        const blockName = fileName + "--" + "showRadio";
        ctx.app.middleware.log('../../serviceLog', blockName + ">>>>" + error);
        return 'error';
      }
    }
  
    // 管理系统编辑单选题
    async editRadio(uid, modelType, updateMsg, requestMsg) {
      const { ctx } = this;
      try {
        const result = await ctx.model.Manager.findOne({ where: { uid } });
        if (!result || result.dataValues.role < 1) return false;
        let where = {};
        if (modelType == "single") {
          const { stem, options_a, options_b, options_c, options_d, answer, difficulty } = requestMsg;
          where = { stem, options_a, options_b, options_c, options_d, answer, difficulty };
        } else if (modelType == "multiple") {
          let stem = [], options_a = [], options_b = [], options_c = [], options_d = [], answer = [], difficulty = [];
          for (const key in requestMsg) {
            requestMsg[key].forEach(element => {
              stem.push(element.stem);
              options_a.push(element.options_a);
              options_b.push(element.options_b);
              options_c.push(element.options_c);
              options_d.push(element.options_d);
              answer.push(element.answer);
              difficulty.push(element.difficulty);
            });
          }
          where = { stem, options_a, options_b, options_c, options_d, answer, difficulty };
        }
        const resultList = await ctx.model2.Radio.update(updateMsg, { where });
        return resultList[0] == 0 ? false : resultList;
      } catch (error) {
        const blockName = fileName + "--" + "editRadio";
        ctx.app.middleware.log('../../serviceLog', blockName + ">>>>" + error);
        return 'error';
      }
    }
  
    // 管理系统删除单选题
    async deleteRadio(uid, modelType, password, requestMsg) {
      const { ctx } = this;
      const systemMonitoring = {
        operate: 2,
        operate_msg: '删除用户账号信息',
        type: 0,
        status: 0,
        affect_entries: 0,
        user: uid,
        created_at: new Date()
      };
      try {
        const result = await ctx.model.Manager.findOne({ where: { uid } });
        if (!result || result.dataValues.password !== this.shaForm(password, this.decryptRequest(result.dataValues.salt)) || result.dataValues.role < 2) {
          if (!result) systemMonitoring.status = 0;
          else if (result.dataValues.password !== this.shaForm(password, this.decryptRequest(result.dataValues.salt))) systemMonitoring.status = 1;
          else if (result.dataValues.role < 2) systemMonitoring.status = 2;
          await ctx.model.Monitoring.create(systemMonitoring);
          return false;
        };
        let where = {};
        if (modelType == "single") {
          const { stem, options_a, options_b, options_c, options_d, answer, difficulty } = requestMsg;
          where = { stem, options_a, options_b, options_c, options_d, answer, difficulty };
        } else if (modelType == "multiple") {
          let stem = [], options_a = [], options_b = [], options_c = [], options_d = [], answer = [], difficulty = [];
          for (const key in requestMsg) {
            requestMsg[key].forEach(element => {
              stem.push(element.stem);
              options_a.push(element.options_a);
              options_b.push(element.options_b);
              options_c.push(element.options_c);
              options_d.push(element.options_d);
              answer.push(element.answer);
              difficulty.push(element.difficulty);
            });
          }
          where = { stem, options_a, options_b, options_c, options_d, answer, difficulty };
        }
        const resultList = await ctx.model2.Radio.destroy({ where });
        systemMonitoring.status = resultList == 0 ? 3 : 4;
        systemMonitoring.affect_entries = resultList;
        await ctx.model.Monitoring.create(systemMonitoring);
        return resultList == 0 ? false : true;
      } catch (error) {
        systemMonitoring.status = 5;
        await ctx.model.Monitoring.create(systemMonitoring);
        const blockName = fileName + "--" + "deleteRadio";
        ctx.app.middleware.log('../../serviceLog', blockName + ">>>>" + error);
        return 'error';
      }
    }
  
    // 管理系统导出单选题数据
    async downloadRadioData(uid, searchMsg) {
      const { ctx } = this;
      try {
        const user = await ctx.model.Manager.findOne({ where: { uid } });
        if (!user || user.dataValues.role < 1) return { code: false };
        let { searchOptions, sortOptions } = searchMsg;
        let attributes = ['stem', 'options_a', 'options_b', 'options_c', 'options_d', 'answer', 'difficulty'],
          where = {}, order = [], dbOptions,
          joinSubstring = [],
          substring = ['stem', 'options_a', 'options_b', 'options_c', 'options_d', 'answer', 'difficulty'],
          key = [],
          between = [];
        attributes.forEach(element => {
          if (searchOptions[element]) {
            if (searchOptions[element] == '*空') {
              if (joinSubstring.includes(element)) {
                where[element] = null;
              } else {
                where[element] = [null, ''];
              }
            } else if (joinSubstring.includes(element)) {
              let targetKeyArr = [];
              where[element] = targetKeyArr.length > 0 ? targetKeyArr : 'null';
            } else if (substring.includes(element)) {
              where[element] = { [Op.substring]: searchOptions[element] };
            } else if (key.includes(element)) {
              where[element] = searchOptions[element];
            } else if (between.includes(element)) {
              where[element] = { [Op.between]: [searchOptions[element][0], searchOptions[element][1]] };
            }
          }
          if (sortOptions[element] == true) {
            order.push([element, 'ASC']);
          } else if (sortOptions[element] == false) {
            order.push([element, 'DESC']);
          }
        });
        dbOptions = { attributes, where, order };
        const result = await ctx.model2.Radio.findAll(dbOptions);
        if (result.length == 0) return { code: false };
        let data = [];
        const difficultyOptions = [
          {
            value: "0",
            label: "简单"
          },
          {
            value: "1",
            label: "普通"
          },
          {
            value: "2",
            label: "困难"
          },
        ];
        result.forEach(element => {
          difficultyOptions.forEach((item) => {
            if (item.value == element.dataValues["difficulty"]) {
              element.dataValues["difficulty"] = item.label;
            }
          });
          data.push(element.dataValues);
        });
        return { code: true, data };
      } catch (error) {
        const blockName = fileName + "--" + "downloadRadioData";
        ctx.app.middleware.log('../../serviceLog', blockName + ">>>>" + error);
        return 'error';
      }
    }
}

module.exports = RadioService;