typescript 示例dinamic查询类似looporm与typeorm

Posted 2021-05-20

import { GruposEntity } from './../entity/GruposEntity';

import "reflect-metadata";
import { createConnection, getManager } from "typeorm";
import { ObrasEntity } from "../entity/ObrasEntity";
import { PersonasEntity } from '../entity/PersonasEntity';
import { UnidadesEnterramientoEntity } from '../entity/UnidadesEnterramientoEntity';
import { UsuariosGruposEntity } from '../entity/UsuariosGruposEntity';
import { DifuntosEntity } from './../entity/DifuntosEntity';
import { MovimientosEntity } from '../entity/MovimientosEntity';
import { TiposMovimientosEntity } from '../entity/TiposMovimientosEntity';
import { DerechosFunerariosEntity } from '../entity/DerechosFunerariosEntity';
import { resolve } from 'path';

var document: any;

const fs = require('fs-extra') // this is no longer necessary
const hbs = require('handlebars');
const path = require('path');

module.exports = function (Custom) {

  // Ficheros comunes    
  var app = require('../../server/server');

  function sqlDinamica(manager, include, tabla) {

    console.log("Pasamos");

    if (include) {
      var arrayInlclude = (!Array.isArray(include)) ? Array(include) : include
      arrayInlclude.forEach(element => {


        if (element.tipo && element.tipo === "left") {
          manager.leftJoin(tabla.concat("." + element.relation), element.relation)
        } else {
          manager.innerJoinAndSelect(tabla.concat("." + element.relation), element.relation)
        }


        // where
        var arrayWhere = Array()
        if (element.where) {
          arrayWhere = !Array.isArray(element.where) ? Array(element.where) : element.where
        }
        arrayWhere.forEach(where => {

          var key = Object.keys(where)[0]
          if (key) {
            if (where[key] && where[key].regexp) {
              var nodo = {}
              nodo[key] = where[key].regexp
              manager.andWhere(element.relation + "." + key + " REGEXP " + ":" + key, nodo)
            } else {
              var clause = where.clausesql;
              delete where.clausesql;
              manager.andWhere(element.relation + "." + key + " " + clause + " " + ":" + key, where)
            }
          }

        });

        // or
        var arrayOr = Array()
        if (element.or) {
          arrayOr = !Array.isArray(element.or) ? Array(element.or) : element.or
        }
        arrayOr.forEach(or => {
          var key = Object.keys(or)[0]
          manager.orWhere(element.relation + "." + key + " = " + ":" + key, or)
        });

        // order
        if (element.order) {
          var arrayOrder = Array()
          arrayOrder = (!Array.isArray(element.order)) ? Array(element.order) : element.order
          arrayOrder.forEach(e => {
            var order = e.split(" ")
            if (e.indexOf(".") > -1) {
              manager.orderBy(order[0].trim(), order[1].trim())
            } else {
              order = e.split(" ")
              manager.orderBy(tabla + "." + order[0].trim(), order[1].trim())
            }
          });
        }


        // Recursividad
        if (element.include) {
          sqlDinamica(manager, element.include, element.relation);
        }

      });
    }

  }


  Custom.custom = function (options, tabla, filter, cb) {
    try {
      console.log("filter");
      console.log(filter);
      var rawSql = false;
      let manager = getManager().getRepository(tabla).createQueryBuilder(tabla)

      if (filter) {
        if (filter.fields) {

          var select = [];

          if (filter.fields.length === 1 && filter.fields[0].count) { // Solo tenemos count sacamos los datos de la tabla padre
            filter.fields.forEach(field => {
              if (field['count']) {
                select.push("COUNT(" + field.count.table + "." + field.count.field + ") AS " + field.count.table + "_count")
                //select.push("COUNT(" + field.table + "." + field.field + ") AS " + field.table + "_count")
                rawSql = true;
              }
              select.push(tabla + ".*")
            });

          } else {
            filter.fields.forEach(field => {
              if (field['count']) {
                select.push("COUNT(" + field.count.table + "." + field.count.field + ") AS " + field.count.table + "_count")
                rawSql = true;
              } else {
                select.push(field.field.table + "." + field.field.field + " AS " + field.field.field)
              }
            });
          }
          manager.select(select)
        }
        if (filter.groupby) {
          var groups = !Array.isArray(filter.groupby) ? Array(filter.groupby) : filter.groupby;
          groups.forEach(group => {
            manager.addGroupBy(group.table + "." + group.field)
          })
        }

        // Base para el where
        manager.where("1 = 1")

        // Dinamica 
        sqlDinamica(manager, filter.include, tabla);


        // wheres de la tabla base
        if (filter.where) {
          var arrayWhere = Array()
          if (filter.where) {
            arrayWhere = !Array.isArray(filter.where) ? Array(filter.where) : filter.where
          }
          arrayWhere.forEach(where => {

            var key = Object.keys(where)[0]
            if (key) {
              if (where[key] && where[key].regexp) {
                var nodo = {}
                nodo[key] = where[key].regexp
                manager.andWhere(tabla + "." + key + " REGEXP " + ":" + key, nodo)
              } else {
                manager.andWhere(tabla + "." + key + " = " + ":" + key, where)
              }
            }

          });
        }

        if (filter.or) {
          var arrayOr = Array()
          if (filter.or) {
            arrayOr = (!Array.isArray(filter.or)) ? Array(filter.or) : filter.or
          }
          arrayOr.forEach(or => {
            var key = Object.keys(or)[0]
            manager.orWhere(tabla + "." + key + " = " + ":" + key, or)
          });
        }

        // order
        if (filter.order) {
          var arrayOrder = Array()
          arrayOrder = (!Array.isArray(filter.order)) ? Array(filter.order) : filter.order
          arrayOrder.forEach(e => {
            var order = e.split(" ")
            if (e.indexOf(".") > -1) { // sin especificar la tabla 
              if ("table_count") { // para ordenar por el propio count 
                manager.orderBy(order[0].replace("table_count.", "").trim(), order[1].trim())
              } else {
                manager.orderBy(order[0].trim(), order[1].trim())
              }

            } else { // especificando la tabla
              order = e.split(" ")
              manager.orderBy(tabla + "." + order[0].trim(), order[1].trim())
            }
          });
        }

        // skip
        if (filter.skip) {

          manager.skip(filter.skip)
        }
        // limit
        if (filter.limit) {
          manager.limit(filter.limit)
        }
      }

      //  devuelve los datos  y un object  del total de registros

      if (rawSql) {
        manager.getRawMany().then(data => {
          cb(null, data);
        }).catch(error => {
          console.log(error);
          cb(null, error);
        })
      } else if (filter && filter.get && filter.get === "datacount") {
        manager.getManyAndCount().then(data => {
          cb(null, data);
        }).catch(error => {
          console.log(error);
          cb(null, error);
        })
      } else if (filter && filter.get && filter.get === "count") {
        manager.getCount().then(data => {
          cb(null, data);
        }).catch(error => {
          console.log(error);
          cb(null, error);
        })
      } else {
        manager.getMany().then(data => {
          cb(null, data);
        }).catch(error => {
          console.log(error);
          cb(null, error);
        })
      }

    } catch (error) {
      console.log(error);
      cb(error);
    }

  };

  Custom.pdf = function (options, req, res, cb) {

    const puppeteer = require('puppeteer');
    req.headers['Content-Disposition'] = 'inline; filename=nombre_fichero.pdf';
    var Difuntos = app.models.Difuntos

    hbs.registerHelper('formatDate', function (options) {
      if (this) {
        if (options) {
          var d = new Date(options);
          let month = String(d.getMonth() + 1);
          let day = String(d.getDate());
          const year = String(d.getFullYear());
          if (month.length < 2) month = '0' + month;
          if (day.length < 2) day = '0' + day;
          return `${day}/${month}/${year}`;
        } else {
          return null;
        }

      }
    });
  }


  Custom.remoteMethod(
    'custom', {
      accepts: [
        {
          "arg": "options",
          "type": "object",
          "http": "optionsFromRequest",

        },
        { arg: 'tabla', type: 'string', required: true },
        { arg: 'filter', type: 'object' }
      ],
      http: {
        path: '/custom/:tabla',
        verb: 'get'
      },
      returns: {
        arg: 'custom',
        type: 'array', root: true
      }
    }
  );

};