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: 7543
      }
    }
  };

  app.permission.add(
    { name: 'sdhDeTai:read', menu },
    'sdhDeTai:write',
    '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 || {};


      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 = {
        'CBTT': async () => await app.model.tchcCanBo.get({ shcc: mscb }).then(item => ({ ...item, belongTo: 'CBTT' })),
        'CBNT': async () => await app.model.dtCanBoNgoaiTruong.get({ shcc: mscb }).then(item => ({ ...item, belongTo: 'CBNT' })),
        'CBSDH': async () => await app.model.sdhCanBo.get({ id: mscb }).then(item => ({ ...item, shcc: item.id, belongTo: 'CBSDH' })),
      };

      const canBo = await belongToMapper[belongTo]();
      res.send({
        item: { ...canBo }
      });
    } catch (error) {
      app.consoleError(req, 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: 'CBSDH', vaiTro: item?.vaiTro };
        }
        return item;
      }));

      await Promise.all(updatedCbhd.flatMap(item => {
        if (item.belongTo !== 'CBSDH') {
          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,
          ...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: 'CBSDH', 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 !== 'CBSDH' ? item.shcc.split(' - ')[0] : item.shcc,
            belongTo: item.belongTo !== 'CBSDH' ? item.shcc.split(' - ')[1] : item.shcc,
            mssv: data.mssv
          }),
          app.model.sdhSoQuyetDinhDetail.create({
            soQuyetDinh: soQuyetDinhData.id,
            tenDeTai: data.tenDeTai,
            shcc: item.belongTo !== 'CBSDH' ? item.shcc.split(' - ')[0] : item.shcc,
            vaiTro: item.vaiTro

          })
        ])
      ]);

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