/* eslint-disable @typescript-eslint/no-unsafe-argument */
import {Controller} from 'egg';
import ILogin from '../middleware/ILogin';
import * as dayjs from 'dayjs';
import {dateTime, date, nowTime} from '../util/now';
import lodash = require('lodash');
const debug = require('debug')('egg-bag:auth');
const query = {
  path: '/query.json',
  method: 'get',
  before: [ILogin],
  async handel(this: Controller, {
    query: {sqlCode, currentPage, pageSize, sortName, sortType, limitSelf, countSelf, sumSelf},
    queries
  }) {
    this.app.throwIf(!sqlCode, '没有指定sql语句编码!');
    const params: {
      [key: string]: any;
    } = {};
    if (this.app.config.queryDefaultParam) {
      for (const [name, key] of Object.entries(this.app.config.queryDefaultParam)) {
        params[name] = lodash.get(
          this.ctx.me,
          key
        );
      }
    }
    Object.keys(queries).forEach((item) => {
      if (queries[item].length > 1) {
        params[item] = queries[item];
      } else {
        params[item] = queries[item][0];
      }
    });
    const page = this.service.paasService
      .pageQueryMe(sqlCode)
      .pageNumber(currentPage)
      .pageSize(pageSize)
      .params(params)
      .limitSelf(limitSelf)
      .countSelf(countSelf)
      .sumSelf(sumSelf);
    if (sortName && sortType) {
      page.orderBy(`${ sortName } ${ sortType }`);
    }
    return await page.select();
  }
};
const query2 = {
  path: '/query.json',
  method: 'post',
  before: [ILogin],
  async handel(this: Controller, {
    body: {sqlCode, currentPage, pageSize, sortName, sortType, limitSelf, countSelf, sumSelf},
    body
  }) {
    this.app.throwIf(!sqlCode, '没有指定sql语句编码!');
    const params: {
      [key: string]: any;
    } = {...body};
    if (this.app.config.queryDefaultParam) {
      for (const [name, key] of Object.entries(this.app.config.queryDefaultParam)) {
        params[name] = lodash.get(
          this.ctx.me,
          key
        );
      }
    }
    const page = this.service.paasService
      .pageQueryMe(sqlCode)
      .pageNumber(currentPage)
      .pageSize(pageSize)
      .params(params)
      .limitSelf(limitSelf)
      .countSelf(countSelf)
      .sumSelf(sumSelf);
    if (sortName && sortType) {
      page.orderBy(`${ sortName } ${ sortType }`);
    }
    return await page.select();
  }
};
const query3 = {
  path: '/query3.json',
  method: 'post',
  before: [ILogin],
  async handel(this: Controller, {
    body: {sqlCode},
    body
  }) {
    this.app.throwIf(!sqlCode, '没有指定sql语句编码!');
    const params: {
      [key: string]: any;
    } = {...body};
    if (this.app.config.queryDefaultParam) {
      for (const [name, key] of Object.entries(this.app.config.queryDefaultParam)) {
        params[name] = lodash.get(
          this.ctx.me,
          key
        );
      }
    }
    return await this.service.paasService.queryBySqlId(sqlCode, params);
  }
};
const excel = {
  path: '/excel.xlsx',
  method: 'get',
  excel: true,
  before: [ILogin],
  async handel(this: Controller, {
    query: {sqlCode, sortName, sortType, sumSelf},
    queries
  }) {
    this.app.throwIf(!sqlCode, '没有指定sql语句编码!');
    const params: {
      [key: string]: any;
    } = {};
    if (this.app.config.queryDefaultParam) {
      for (const [name, key] of Object.entries(this.app.config.queryDefaultParam)) {
        params[name] = lodash.get(
          this.ctx.me,
          key
        );
      }
    }
    Object.keys(queries).forEach((item) => {
      if (queries[item].length > 1) {
        params[item] = queries[item];
      } else {
        params[item] = queries[item][0];
      }
    });
    const page = this.service.paasService
      .pageQueryMe(sqlCode)
      .params(params)
      .sumSelf(sumSelf);
    if (sortName && sortType) {
      page.orderBy(`${ sortName } ${ sortType }`);
    }
    await page.select();
    return {
      list: page.list,
      config: this.app._globalValues.GlobalMap,
      now: nowTime(),
      me: this.ctx.me,
      params,
      sum: page.sum
    };
  }
};
const excel2 = {
  path: '/excel2.xlsx',
  method: 'post',
  excel: true,
  before: [ILogin],
  async handel(this: Controller, {
    body: {sqlCode, sortName, sortType, sumSelf},
    body
  }) {
    this.app.throwIf(!sqlCode, '没有指定sql语句编码!');
    const params: {
      [key: string]: any;
    } = {...body};
    if (this.app.config.queryDefaultParam) {
      for (const [name, key] of Object.entries(this.app.config.queryDefaultParam)) {
        params[name] = lodash.get(
          this.ctx.me,
          key
        );
      }
    }
    const page = this.service.paasService
      .pageQueryMe(sqlCode)
      .params(params)
      .sumSelf(sumSelf);
    if (sortName && sortType) {
      page.orderBy(`${ sortName } ${ sortType }`);
    }
    await page.select();
    return {
      list: page.list,
      config: this.app._globalValues.GlobalMap,
      now: nowTime(),
      me: this.ctx.me,
      params,
      sum: page.sum
    };
  }
};
const queryMongo = {
  path: '/query-mongo.json',
  before: [ILogin],
  method: 'get',
  async handel(this: Controller, {
    query: {sqlCode, currentPage, pageSize, sortName, sortType, limitSelf, countSelf, sumSelf},
    queries
  }) {
    this.app.throwIf(!sqlCode, '没有指定sql语句编码!');
    const params: {
      [key: string]: any;
    } = {};
    if (this.app.config.queryDefaultParam) {
      for (const [name, key] of Object.entries(this.app.config.queryDefaultParam)) {
        params[name] = this.ctx.me[key];
      }
    }
    Object.keys(queries).forEach((item) => {
      if (queries[item].length > 1) {
        params[item] = queries[item];
      } else {
        params[item] = queries[item][0];
      }
    });
    const page = this.service.paasMongoService
      .pageQueryMe(sqlCode)
      .pageNumber(currentPage)
      .pageSize(pageSize)
      .params(params)
      .limitSelf(limitSelf)
      .countSelf(countSelf)
      .sumSelf(sumSelf);
    if (sortName && sortType) {
      page.orderByMongo(sortName, sortType === 'asc' ? 1 : -1);
    }
    return await page.select();
  }
};
const queryMongo2 = {
  path: '/query-mongo.json',
  before: [ILogin],
  method: 'post',
  async handel(this: Controller, {
    body: {sqlCode, currentPage, pageSize, sortName, sortType, limitSelf, countSelf, sumSelf},
    body
  }) {
    this.app.throwIf(!sqlCode, '没有指定sql语句编码!');
    const params: {
      [key: string]: any;
    } = {...body};
    if (this.app.config.queryDefaultParam) {
      for (const [name, key] of Object.entries(this.app.config.queryDefaultParam)) {
        params[name] = this.ctx.me[key];
      }
    }
    const page = this.service.paasMongoService
      .pageQueryMe(sqlCode)
      .pageNumber(currentPage)
      .pageSize(pageSize)
      .params(params)
      .limitSelf(limitSelf)
      .countSelf(countSelf)
      .sumSelf(sumSelf);
    if (sortName && sortType) {
      page.orderByMongo(sortName, sortType === 'asc' ? 1 : -1);
    }
    return await page.select();
  }
};
const excelMongo = {
  path: '/excel-mongo.xlsx',
  method: 'get',
  excel: true,
  before: [ILogin],
  async handel(this: Controller, {
    query: {sqlCode, sortName, sortType, sumSelf},
    queries
  }) {
    this.app.throwIf(!sqlCode, '没有指定sql语句编码!');
    const params: {
      [key: string]: any;
    } = {};
    if (this.app.config.queryDefaultParam) {
      for (const [name, key] of Object.entries(this.app.config.queryDefaultParam)) {
        params[name] = this.ctx.me[key];
      }
    }
    Object.keys(queries).forEach((item) => {
      if (queries[item].length > 1) {
        params[item] = queries[item];
      } else {
        params[item] = queries[item][0];
      }
    });
    const page = this.service.paasMongoService
      .pageQueryMe(sqlCode)
      .params(params)
      .sumSelf(sumSelf);
    if (sortName && sortType) {
      page.orderByMongo(sortName, sortType === 'asc' ? 1 : -1);
    }
    await page.select();
    return {
      list: page.list,
      config: this.app._globalValues.GlobalMap,
      now: nowTime(),
      me: this.ctx.me,
      params,
      sum: page.sum
    };
  }
};
const excelMongo2 = {
  path: '/excel-mongo.xlsx',
  method: 'post',
  excel: true,
  before: [ILogin],
  async handel(this: Controller, {
    body: {sqlCode, sortName, sortType, sumSelf},
    body
  }) {
    this.app.throwIf(!sqlCode, '没有指定sql语句编码!');
    const params: {
      [key: string]: any;
    } = {...body};
    if (this.app.config.queryDefaultParam) {
      for (const [name, key] of Object.entries(this.app.config.queryDefaultParam)) {
        params[name] = this.ctx.me[key];
      }
    }
    const page = this.service.paasMongoService
      .pageQueryMe(sqlCode)
      .params(params)
      .sumSelf(sumSelf);
    if (sortName && sortType) {
      page.orderByMongo(sortName, sortType === 'asc' ? 1 : -1);
    }
    await page.select();
    return {
      list: page.list,
      config: this.app._globalValues.GlobalMap,
      now: nowTime(),
      me: this.ctx.me,
      params,
      sum: page.sum
    };
  }
};
const now = {
  path: '/now.json',
  method: 'get',
  handel({query: {minute, hour, day, week, month, year, format}}) {
    return dayjs()
      .add(minute || 0, 'minute')
      .add(hour || 0, 'hour')
      .add(day || 0, 'day')
      .add(week || 0, 'week')
      .add(month || 0, 'month')
      .add(year || 0, 'year').format(format || dateTime);
  }
};
const unix = {
  path: '/unix.json',
  method: 'get',
  handel() {
    return dayjs().unix();
  }
};
const stamp = {
  path: '/stamp.json',
  method: 'get',
  handel() {
    return dayjs().valueOf();
  }
};
const today = {
  path: '/today.json',
  method: 'get',
  handel({query: {minute, hour, day, week, month, year, format}}) {
    return dayjs()
      .add(minute || 0, 'minute')
      .add(hour || 0, 'hour')
      .add(day || 0, 'day')
      .add(week || 0, 'week')
      .add(month || 0, 'month')
      .add(year || 0, 'year').format(format || date);
  }
};
const phoneCode = {
  path: '/code.json',
  method: 'get',
  async handel(this: Controller, {query: {phone}}: any) {
    return await this.service.paasService.sendCode(phone);
  }
};
const picCode = {
  path: '/pic-code.json',
  method: 'get',
  type: 'image/svg+xml',
  async handel(this: Controller, {query: {key}}) {
    return await this.service.paasService.picCode(key);
  }
};
const getConfigJson = {
  path: '/GlobalValues.json',
  method: 'get',
  handel(this: Controller) {
    return this.app._globalValues;
  }
};
const getWxIds = {
  path: '/wx-mini-ms-id.json',
  method: 'get',
  handel(this: Controller, {query: {code}}) {
    return this.app.getWxMini(code).getTemplIds();
  }
};
const getWxQr = {
  path: '/wx-mini-qr.png',
  method: 'get',
  type: 'image/png',
  async handel(this: Controller, {query: {model, page, fullpath, scene, png, code}}) {
    return this.app.getWxMini(code).getUnlimited({model, page, fullpath, scene, png});
  }
};
const wxDecrypt = {
  path: '/wx-decrypt',
  method: 'get',
  before: [ILogin],
  handel(this: Controller, {query: {encryptedData, iv, code}}) {
    return this.app.getWxMini(code).decrypt({
      sessionKey: this.ctx.me.wx_mini_session_key!,
      iv,
      encryptedData
    });
  }
};
const fetchFlow = {
  path: '/fetch-flow',
  method: 'post',
  before: [ILogin],
  async handel(this: Controller, {body: {flowPath, fromNodeId, fromNodeCode, req, skipData, key}}) {
    return await this.service.paasService.fetchFlow({flowPath, fromNodeId, fromNodeCode, req, skipData, key});
  }
};

const doFlow = {
  path: '/do-flow',
  method: 'post',
  lock: true,
  before: [ILogin],
  async handel(this: Controller, {body: {flowPath, fromNodeId, fromNodeCode, actionId, actionCode, req}}) {
    return await this.service.paasService.doFlow({flowPath, fromNodeId, fromNodeCode, actionId, actionCode, req});
  }
};
const getFlowLine = {
  path: '/get-flow-line',
  method: 'get',
  before: [ILogin],
  handel(this: Controller, {query: {flowCode, fromNodeId, fromNodeCode, actionId, actionCode}}) {
    return this.service.paasService.getLine({
      flowCode, fromNodeId, fromNodeCode, actionId, actionCode
    });
  }
};
const socketRoomIn = {
  path: '/login',
  before: [ILogin],
  handel(this: Controller, roomid: string) {
    this.ctx.socket.join(roomid);
    debug(`${ this.ctx.me.userid } join to ${ roomid }`);
  }
};
const socketRoomOut = {
  path: '/logout',
  handel(this: Controller, roomid: string) {
    this.ctx.socket.leave(roomid);
    debug(`${ this.ctx.me.userid } leave from ${ roomid }`);
  }
};

export const routes = [
  now, phoneCode, picCode, getConfigJson, today, getWxIds, getWxQr, wxDecrypt, fetchFlow, doFlow, getFlowLine, unix, stamp
];
export const querys = [
  query, queryMongo, excel, excelMongo,
  query2, queryMongo2, excel2, excelMongo2,
  query3
];
export const sockets = [
  socketRoomOut, socketRoomIn
];