Untitled

module.exports = app => {
  const menu = {
    parentMenu: app.parentMenu.sdh,
    menus: {
      7642: {
        title: 'Quản lý đề tài (2)', link: '/user/sau-dai-hoc/de-tai', parentKey: 7500
      }
    }
  };

  app.permission.add(
    { name: 'sdhDeTai:read', menu },
    { name: 'sdhDeTai:write' },
    { name: 'sdhDeTai:delete' },
  );

  app.get('/user/sau-dai-hoc/de-tai', app.permission.check('sdhDeTai:read'), app.templates.admin);
  app.get('/user/sau-dai-hoc/so-quyet-dinh/:mssv', app.permission.check('sdhDeTai:read'), app.templates.admin);

  //APIs----------------------------------------------------------------------------------------------------------------------------------
  app.get('/api/sdh/de-tai', app.permission.check('sdhDeTai:read'), async (req, res) => {
    try {
      const items = await app.model.sdhDeTai.getAll({}, '*', 'ID');
      res.send({ items });
    } catch (error) {
      app.consoleError(req, error);
      res.send({ error });
    }
  });

  app.get('/api/sdh/de-tai/page/:pageNumber/:pageSize', app.permission.check('sdhDeTai:read'), async (req, res) => {
    try {
      const { pageNumber, pageSize } = req.params;
      let { filter } = req.query || {};
      filter = filter || {};


      const { rows: list, pagenumber, pagesize, pagetotal, totalitem, newestsoquyetdinh } = await app.model.sdhDeTai.searchPage(Number(pageNumber), Number(pageSize), app.utils.stringify(filter));

      list.forEach(item => {
        item.canBo = app.utils.parse(item.canBo);
        if (Array.isArray(item.canBo)) {
          item.canBo = item.canBo.filter(canBo =>
            !(canBo.MSCB === null &&
              canBo.vaiTro === null &&
              canBo.hoTenCanBo === null &&
              canBo.from === null)
          );
        }
      });


      res.send({ page: { list, pageNumber: pagenumber, pageSize: pagesize, pageTotal: pagetotal, totalItem: totalitem, newestSoQuyetDinh: newestsoquyetdinh } });
    } catch (error) {
      app.consoleError(app, error);
      res.send({ error });
    }
  });

  app.get('/api/sdh/cbhd/page/:pageNumber/:pageSize', app.permission.check('sdhDeTai:read'), async (req, res) => {
    try {
      const { pageNumber, pageSize } = req.params;
      let { filter } = req.query || {};
      filter = filter || {};
      const searchTerm = typeof req.query.condition === 'string' ? req.query.condition : '';

      const { rows: list, pagenumber, pagesize, pagetotal, totalitem } = await app.model.sdhDeTai.sdhCanBoHuongDanSearchPage(Number(pageNumber), Number(pageSize), app.utils.stringify(filter), searchTerm);

      res.send({ page: { list, pageNumber: pagenumber, pageSize: pagesize, pageTotal: pagetotal, totalItem: totalitem } });
    } catch (error) {
      app.consoleError(error);
      res.send({ error });
    }
  });

  app.get('/api/sdh/cbhd/item/:shcc', app.permission.check('sdhDeTai:read'), async (req, res) => {
    try {
      const mscb = req.params.shcc;
      const { belongTo } = req.query;
      const belongToMapper = {
        'TCHC': () => app.model.tchcCanBo.get({ shcc: mscb, belongTo: 'TCHC' }),
        'CBNT': () => app.model.dtCanBoNgoaiTruong.get({ shcc: mscb, belongTo: 'CBNT' }),
        'SDHCB': () => app.model.sdhCanBo.get({ id: mscb }).then(item => ({ ...item, shcc: item.id, belongTo: 'SDHCB' })),
      };

      const canBo = await belongToMapper[belongTo]();

      res.send({
        item: { ...canBo }
      });
    } catch (error) {
      app.consoleError(error);
      res.send({ error });
    }
  });

  app.post('/api/sdh/de-tai', app.permission.check('sdhDeTai:write'), async (req, res) => {
    try {
      const { data } = req.body;
      const deTaiData = {
        'tenDeTai': data.tenDeTai,
        'mssv': data.mssv,
        'ghiChu': data.ghiChu,
        'noiDung': data.noiDung
      };

      const deTaiItem = await app.model.sdhDeTai.create(deTaiData);

      const soQuyetDinhData = {
        'ten': data.tenSqd,
        'time': Date.now(),
        'idDeTai': deTaiItem.id,
        'id': data.soQuyetDinh
      };

      const soQuyetDinhItem = await app.model.sdhSoQuyetDinh.create(soQuyetDinhData);

      const updatedCbhd = await Promise.all(data.cbhd.map(async (item) => {
        if (!item.shcc && item.hoTenCanBo && item.trinhDo) {
          const [firstName, ...lastNameParts] = item.hoTenCanBo.split(' ');
          const lastName = lastNameParts.join(' ');
          const temp = await app.model.sdhCanBo.create({
            'ho': firstName,
            'ten': lastName,
            'trinhDo': item.trinhDo,
          });
          temp.shcc = temp.id;
          delete temp.id;
          return { ...temp, belongTo: 'SDHCB', 'vaiTro': item?.vaiTro };
        }
        return item;
      }));

      await Promise.all(updatedCbhd.flatMap(item => {
        if (item.belongTo !== 'SDHCB') {
          const [shcc, belongTo] = item.shcc.split(' - ');
          item.belongTo = belongTo;
          item.shcc = shcc;
        }
        app.model.sdhCbhd.create({
          'vaiTro': item.vaiTro,
          'idCanBo': item.shcc,
          'mssv': data.mssv,
          'belongTo': item.belongTo,
        });
        app.model.sdhSoQuyetDinhDetail.create({
          'soQuyetDinh': soQuyetDinhItem.soQuyetDinh,
          'tenDeTai': data.tenDeTai,
          'typeShcc': 0,
          ...item
        });
      }));

      const item = {
        deTai: deTaiItem,
        soQuyetDinh: soQuyetDinhItem,
      };

      res.send({ item });
    } catch (error) {
      app.consoleError(req, error);
      res.send({ error });
    }
  });

  app.put('/api/sdh/de-tai', app.permission.check('sdhDeTai:write'), async (req, res) => {
    try {
      const { data, id } = req.body;
      const deTaiData = {
        'tenDeTai': data.tenDeTai,
        'mssv': data.mssv,
        'ghiChu': data.ghiChu,
        'noiDung': data.noiDung
      };

      const soQuyetDinhData = {
        'ten': data.tenSqd,
        'time': Date.now(),
        'idDeTai': id,
        'id': data.soQuyetDinh
      };

      const updatedCbhd = await Promise.all(data.cbhd.map(async (item) => {
        if (!item.shcc && item.hoTenCanBo && item.trinhDo) {
          const [firstName, ...lastNameParts] = item.hoTenCanBo.split(' ');
          const lastName = lastNameParts.join(' ');
          const temp = await app.model.sdhCanBo.create({
            'ho': firstName,
            'ten': lastName,
            'trinhDo': item.trinhDo,
          });
          temp.shcc = temp.id;
          delete temp.id;
          return { ...temp, belongTo: 'SDHCB', 'vaiTro': item?.vaiTro };
        }
        return item;
      }));


      await app.model.sdhCbhd.delete({ mssv: data.mssv });
      await Promise.all([
        app.model.sdhSoQuyetDinh.update({ idDeTai: id, active: 0 }, { active: 1 }),
        app.model.sdhDeTai.update({ id }, deTaiData),

        app.model.sdhSoQuyetDinh.create(soQuyetDinhData),
        ...updatedCbhd.flatMap(item => [
          app.model.sdhCbhd.create({
            'vaiTro': item.vaiTro,
            'idCanBo': item.belongTo !== 'SDHCB' ? item.shcc.split(' - ')[0] : item.shcc,
            'belongTo': item.belongTo !== 'SDHCB' ? item.shcc.split(' - ')[1] : item.shcc,
            'mssv': data.mssv
          }),
          app.model.sdhSoQuyetDinhDetail.create({
            'soQuyetDinh': soQuyetDinhData.id,
            'tenDeTai': data.tenDeTai,
            'shcc': item.belongTo !== 'SDHCB' ? item.shcc.split(' - ')[0] : item.shcc,
            'vaiTro': item.vaiTro,
            'typeShcc': 0,
          })
        ])
      ]);

      res.send({ 'message': 'success' });
    } catch (error) {
      app.consoleError(req, error);
      res.send({ error });
    }
  });

  app.get('/api/sdh/de-tai-sinh-vien/page/:pageNumber/:pageSize', app.permission.check('sdhDeTai:read'), async (req, res) => {
    try {
      const pagenumber = parseInt(req.params.pageNumber),
        pagesize = parseInt(req.params.pageSize),
        { condition, filter, sortTerm = 'ten_ASC' } = req.query,
        searchTerm = typeof condition === 'string' ? condition : '';
      const page = await app.model.sdhDeTai.sinhVienWithDeTaiSearchPage(pagenumber, pagesize, searchTerm, app.utils.stringify(filter), sortTerm.split('_')[0], sortTerm.split('_')[1]);
      const { totalitem: totalItem, pagesize: pageSize, pagetotal: pageTotal, pagenumber: pageNumber, rows: list } = page;
      res.send({ page: { totalItem, pageSize, pageTotal, pageNumber, list } });
    } catch (error) {
      res.send({ error });
    }
  });
};