criado c100 e c170 importacao xml

chapzin · chapzin · commit 8e4ac9c853ca · 2019-10-02T22:12:23.000-03:00
diff --git a/src/app/blocos/blocoC.js b/src/app/blocos/blocoC.js
@@ -2,6 +2,10 @@ const {
   convertToFloat,
   convertStringToDateSped
 } = require("../util/conversores");
+const NFe = require("djf-nfe");
+const { lerXml } = require("../util/utilidades");
+const RegC100 = require("../models/classes/ClassRegC100");
+const RegC170 = require("../models/classes/ClassRegC170");
 
 const regC001 = (line, reg0000) => {
   const ln = line.split("|");
@@ -15,7 +19,50 @@ const regC001 = (line, reg0000) => {
   }
 };
 
-const regC100 = (line, reg0000) => {
+const regC100Xml = file => {
+  let nfe = NFe(lerXml(file).toString());
+  let info = nfe.identificacaoNFe();
+  let emitente = nfe.emitente();
+  let destinatario = nfe.destinatario();
+  let protocolo = nfe.informacoesProtocolo();
+  let total = nfe.total();
+  let regC100 = new RegC100(
+    (reg = "C100"),
+    (indOper = info.tipoOperacao()),
+    (indEmit = info.dataEmissao()),
+    (codPart = emitente.cpf() || emitente.cnpj()),
+    (codDest = destinatario.cpf() || destinatario.cnpj()),
+    (codMod = "55"),
+    (codSit = "00"),
+    (ser = info.serie()),
+    (numDoc = info.nrNota()),
+    (chvNfe = protocolo.chave() || "nfe sem protocolo"),
+    (dtDoc = info.dataEmissao()),
+    (dtES = info.dataEmissao()),
+    (vlDoc = total.valorNota()),
+    (indPgto = "0"),
+    (vlDesc = total.valorDesconto()),
+    (vlAbatNt = 0),
+    (vlMerc = total.valorProdutos()),
+    (indFrt = "0"),
+    (vlFrt = total.valorFrete()),
+    (vlSeg = total.valorSeguro()),
+    (vlOutDa = total.valorOutrasDespesas()),
+    (vlBcIcms = total.baseCalculoIcms()),
+    (vlIcms = total.valorIcms()),
+    (vlBcIcmsSt = total.baseCalculoIcmsST()),
+    (vlIcmsSt = total.valorIcmsST()),
+    (vlIpi = total.valorIPI()),
+    (vlPis = total.valorPIS()),
+    (vlCofins = total.valorCOFINS()),
+    (vlPisSt = "0.00"),
+    (vlCofinsSt = "0.00"),
+    (flag = "xml")
+  );
+  return regC100;
+};
+
+const regC100Sped = (line, reg0000) => {
   const ln = line.split("|");
   if (line[0] == "|" && ln[1] == "C100") {
     return {
@@ -302,6 +349,82 @@ const regC165 = (line, reg0000) => {
   }
 };
 
+const regC170Xml = file => {
+  const regsC170 = [];
+  const nfe = NFe(lerXml(file).toString());
+  const info = nfe.identificacaoNFe();
+  const emitente = nfe.emitente();
+  const destinatario = nfe.destinatario();
+  const protocolo = nfe.informacoesProtocolo();
+  const total = nfe.total();
+  const regC100xmlok = regC100Xml(file);
+  const totalItens = nfe.nrItens();
+
+  for (let i = 1; i <= totalItens; i++) {
+    let item = nfe.item(i);
+    let icms = item.imposto().icms();
+    let ipi = item.imposto().ipi();
+    let pis = item.imposto().pis();
+
+    let _cstIpi = "";
+    let _aliqIpi = "";
+    let _vlIpi = "";
+    let _BcIpi = "";
+
+    if (item.imposto().ipi()) {
+      _cstIpi = ipi.cst();
+      _aliqIpi = ipi.porcentagemIPI();
+      _vlIpi = ipi.valorIPI();
+      _BcIpi = ipi.baseCalculo();
+    }
+
+    let cofins = item.imposto().cofins();
+    const regC170 = new RegC170(
+      (reg = "C170"),
+      (numItem = i),
+      (codItem = item.codigo()),
+      (descrCompl = item.descricao()),
+      (qtd = item.quantidadeComercial()),
+      (unid = item.unidadeComercial()),
+      (vlItem = item.valorUnitario() * qtd),
+      (vlDesc = item.valorDesconto()),
+      (indMov = "0"),
+      (cstIcms = `${icms.origem()}${icms.cst()}`),
+      (cfop = item.cfop()),
+      (codNat = ""),
+      (vlBcIcms = icms.baseCalculo()),
+      (aliqIcms = icms.porcetagemIcms()),
+      (vlIcms = icms.valorIcms()),
+      (vlBcIcmsSt = icms.baseCalculoIcmsST()),
+      (aliqSt = icms.porcetagemIcmsST()),
+      (vlIcmsSt = icms.valorIcmsST()),
+      (indApur = ""),
+      (cstIpi = _cstIpi),
+      (codEnq = ""),
+      (vlBcIpi = _BcIpi),
+      (aliIpi = _aliqIpi),
+      (vlIpi = _vlIpi),
+      (cstPis = pis.cst()),
+      (vlBcPis = pis.baseCalculo()),
+      (aliqPis = pis.porcentagemPIS()),
+      (quantBcPis = ""),
+      (aliqPis2 = ""),
+      (vlPis = pis.valorPIS()),
+      (cstCofins = cofins.cst()),
+      (vlBcCofins = cofins.baseCalculo()),
+      (aliCofins = cofins.porcentagemCOFINS()),
+      (quantBcCofins = ""),
+      (aliCofins2 = ""),
+      (vlCofins = cofins.valorCOFINS()),
+      (codCta = ""),
+      (flag = "xml"),
+      (regC100 = regC100xmlok)
+    );
+    regsC170.push(regC170);
+  }
+  return regsC170;
+};
+
 const regC170 = (line, regC100, reg0000) => {
   const ln = line.split("|");
   if (line[0] == "|" && ln[1] == "C170") {
@@ -1189,7 +1312,8 @@ const regC990 = (line, reg0000) => {
 
 module.exports = {
   regC001,
-  regC100,
+  regC100Sped,
+  regC100Xml,
   regC101,
   regC105,
   regC110,
@@ -1206,6 +1330,7 @@ module.exports = {
   regC160,
   regC165,
   regC170,
+  regC170Xml,
   regC171,
   regC172,
   regC173,
diff --git a/src/app/models/BlocoC/RegC100.js b/src/app/models/BlocoC/RegC100.js
@@ -16,6 +16,9 @@ const RegSchema = new mongoose.Schema({
   codPart: {
     type: String
   },
+  codDest: {
+    type: String
+  },
   codMod: {
     type: String,
     required: true
diff --git a/src/app/models/BlocoC/RegC170.js b/src/app/models/BlocoC/RegC170.js
@@ -133,8 +133,7 @@ const RegSchema = new mongoose.Schema({
     required: true
   },
   reg0000: {
-    type: Object,
-    required: true
+    type: Object
   }
 });
 
diff --git a/src/app/models/classes/ClassRegC100.js b/src/app/models/classes/ClassRegC100.js
@@ -4,6 +4,7 @@ class RegC100 {
     indOper,
     indEmit,
     codPart,
+    codDest,
     codMod,
     codSit,
     ser,
@@ -35,6 +36,7 @@ class RegC100 {
     this.indOper = indOper;
     this.indEmit = indEmit;
     this.codPart = codPart;
+    this.codDest = codDest;
     this.codMod = codMod;
     this.codSit = codSit;
     this.ser = ser;
diff --git a/src/app/models/classes/ClassRegC170.js b/src/app/models/classes/ClassRegC170.js
@@ -0,0 +1,87 @@
+class RegC170 {
+  constructor(
+    reg,
+    numItem,
+    codItem,
+    descrCompl,
+    qtd,
+    unid,
+    vlItem,
+    vlDesc,
+    indMov,
+    cstIcms,
+    cfop,
+    codNat,
+    vlBcIcms,
+    aliqIcms,
+    vlIcms,
+    vlBcIcmsSt,
+    aliqSt,
+    vlIcmsSt,
+    indApur,
+    cstIpi,
+    codEnq,
+    vlBcIpi,
+    aliqIpi,
+    vlIpi,
+    cstPis,
+    vlBcPis,
+    aliqPis,
+    quantBcPis,
+    aliqPis2,
+    vlPis,
+    cstCofins,
+    vlBcCofins,
+    aliqCofins,
+    quantBcCofins,
+    aliqCofins2,
+    vlCofins,
+    codCta,
+    flag,
+    regC100,
+    reg0000
+  ) {
+    this.reg = reg;
+    this.numItem = numItem;
+    this.codItem = codItem;
+    this.descrCompl = descrCompl;
+    this.qtd = qtd;
+    this.unid = unid;
+    this.vlItem = vlItem;
+    this.vlDesc = vlDesc;
+    this.indMov = indMov;
+    this.cstIcms = cstIcms;
+    this.cfop = cfop;
+    this.codNat = codNat;
+    this.vlBcIcms = vlBcIcms;
+    this.aliqIcms = aliqIcms;
+    this.vlIcms = vlIcms;
+    this.vlBcIcmsSt = vlBcIcmsSt;
+    this.aliqSt = aliqSt;
+    this.vlIcmsSt = vlIcmsSt;
+    this.indApur = indApur;
+    this.cstIpi = cstIpi;
+    this.codEnq = codEnq;
+    this.vlBcIpi = vlBcIpi;
+    this.aliqIpi = aliqIpi;
+    this.vlIpi = vlIpi;
+    this.cstPis = cstPis;
+    this.vlBcPis = vlBcPis;
+    this.aliqPis = aliqPis;
+    this.quantBcPis = quantBcPis;
+    this.aliqPis2 = aliqPis2;
+    this.vlPis = vlPis;
+    this.cstCofins = cstCofins;
+    this.vlBcCofins = vlBcCofins;
+    this.aliqCofins = aliqCofins;
+    this.quantBcCofins = quantBcCofins;
+    this.aliqCofins2 = aliqCofins2;
+    this.vlCofins = vlCofins;
+    this.codCta = codCta;
+    this.flag = flag;
+    this.regC100 = regC100;
+    this.reg0000 = reg0000;
+  }
+}
+
+module.exports = RegC170;
diff --git a/src/app/util/utilidades.js b/src/app/util/utilidades.js
@@ -0,0 +1,8 @@
+const fs = require("fs");
+const path = require("path");
+
+const lerXml = file => {
+  return fs.readFileSync(path.resolve("uploads", "xmls", file), "utf-8");
+};
+
+module.exports = { lerXml };
diff --git a/src/varios_testes/importa_arquivos_sped.js b/src/varios_testes/importa_arquivos_sped.js
@@ -8,7 +8,7 @@ const {
   reg0200,
   reg0220
 } = require("../app/blocos/bloco0");
-const { regC100, regC170 } = require("../app/blocos/blocoC");
+const { regC100Sped, regC170 } = require("../app/blocos/blocoC");
 const { regH010 } = require("../app/blocos/blocoH");
 const { reg9999 } = require("../app/blocos/bloco9");
 const path = require("path");
@@ -105,9 +105,9 @@ const readSped = file => {
       });
     }
 
-    if (regC100(line, r0000)) {
-      regC100p = regC100(line, r0000);
-      RegC100Model.create(regC100(line, r0000), (err, result) => {
+    if (regC100Sped(line, r0000)) {
+      regC100p = regC100Sped(line, r0000);
+      RegC100Model.create(regC100Sped(line, r0000), (err, result) => {
         if (err) {
           console.log(err);
         } else {
diff --git a/src/varios_testes/importa_arquivos_xml.js b/src/varios_testes/importa_arquivos_xml.js
@@ -1,32 +1,39 @@
 const fs = require("fs");
 const path = require("path");
-const NFe = require("djf-nfe");
-const RegC100 = require("../app/models/classes/ClassRegC100");
 
-const files = fs.readdirSync(path.resolve("uploads", "xmls"));
-
-const lerXml = file => {
-  return fs.readFileSync(path.resolve("uploads", "xmls", file), "utf-8");
+const RegC100Model = require("../app/models/BlocoC/RegC100");
+const RegC170Model = require("../app/models/BlocoC/RegC170");
+const { regC100Xml, regC170Xml } = require("../app/blocos/blocoC");
+const mongoose = require("mongoose");
+const { mongodb } = require("../config/database");
+const database = uri => {
+  mongoose.connect(uri, {
+    useCreateIndex: true,
+    useNewUrlParser: true
+  });
 };
+database(mongodb.uri);
 
-let regC100 = new RegC100((reg = "C100"));
+const files = fs.readdirSync(path.resolve("uploads", "xmls"));
 
 files.forEach(file => {
-  let nfe = NFe(lerXml(file).toString());
-  let info = nfe.identificacaoNFe();
-  let emitente = nfe.emitente();
-  let protocolo = nfe.informacoesProtocolo();
-  let regC100 = new RegC100(
-    (reg = "C100"),
-    (indOper = info.tipoOperacao()),
-    (indEmit = info.dataEmissao()),
-    (codPart = emitente.cpf() || emitente.cnpj()),
-    (codMod = "55"),
-    (codSit = "00"),
-    (ser = info.serie()),
-    (numDoc = info.nrNota()),
-    (chvNfe = protocolo.chave() || "nfe sem protocolo")
-  );
-  // console.log(lerXml(file).toString());
-  console.log(regC100);
+  let regC100 = regC100Xml(file);
+  RegC100Model.create(regC100, (err, result) => {
+    if (err) {
+      console.log(err);
+    } else {
+      console.log(`Inseriu ${regC100.chvNfe}`);
+    }
+  });
+
+  let regC170 = regC170Xml(file);
+  regC170.forEach(itemRegC170 => {
+    RegC170Model.create(itemRegC170, (err, result) => {
+      if (err) {
+        console.log(err);
+      } else {
+        console.log(`Inseriu ${regC100.chvNfe}`);
+      }
+    });
+  });
 });
diff --git a/src/varios_testes/pesquisa.js b/src/varios_testes/pesquisa.js

Original file line number	Diff line number	Diff line change
`@@ -133,8 +133,7 @@ const RegSchema = new mongoose.Schema({`
`133`	`133`	`required: true`
`134`	`134`	`},`
`135`	`135`	`reg0000: {`
`136`		`- type: Object,`
`137`		`- required: true`
	`136`	`+ type: Object`
`138`	`137`	`}`
`139`	`138`	`});`
`140`	`139`