from pypxlib import Table
import sqlite3
from pymongo import MongoClient

client = MongoClient('localhost', username='revenda', password='r3v3nd@', authSource='DigisatServer', port=12220)
database = client["DigisatServer"]
collection = database["ProdutosServicosEmpresa"]


pipeline = [
    {
        u"$lookup": {
            u"from": u"ProdutosServicos",
            u"localField": u"ProdutoServicoReferencia",
            u"foreignField": u"_id",
            u"as": u"ProdutosServicos"
        }
    },
    {
        u"$lookup": {
            u"from": u"Precos",
            u"localField": u"PrecoReferencia",
            u"foreignField": u"_id",
            u"as": u"Precos"
        }
    }
]

cursor = collection.aggregate(
    pipeline,
    allowDiskUse = False
)
produtos = Table('banco/TABEST1.db')
conn = sqlite3.connect('db.sqlite3')
try:
    for doc in cursor:
        id = str(doc['ProdutosServicos'][0]['_id'])
        cursor1 = conn.cursor()
        cursor1.execute("SELECT * FROM produtos where mongo = '" + id + "';")
        result = cursor1.fetchone()
        if result == None:
            barras = ''
            caracteristica = ''
            if 'CodigoBarras' in doc['ProdutosServicos'][0]:
                barras = doc['ProdutosServicos'][0]['CodigoBarras']

            if 'Caracteristica' in doc['ProdutosServicos'][0]:
                caracteristica = doc['ProdutosServicos'][0]['Caracteristica']

            dados = (None,  # Controle
                     doc['ProdutosServicos'][0]['CodigoInterno'],  # Codigo
                     barras,  # CodInterno
                     doc['ProdutosServicos'][0]['Descricao'],  # Produto
                     None,  # LkSetor
                     caracteristica,  # Fabricante
                     None,  # LkFornec
                     doc['Precos'][0]['Custo']['Valor'],  # PrecoCusto
                     None,  # CustoMedio
                     doc['Precos'][0]['Venda']['Valor'],  # PrecoVenda
                     0,  # Quantidade
                     None,  # EstMinimo
                     doc['ProdutosServicos'][0]['UnidadeMedida']['Sigla'],  # Unidade
                     None,  # Lucro
                     None,  # Comissao
                     None,  # Moeda
                     None,  # UltReaj
                     None,  # Foto
                     None,  # Obs
                     0,  # NaoSaiTabela
                     0,  # Inativo
                     doc['NcmNbs']['Codigo'],  # CodIPI
                     None,  # IPI
                     None,  # CST
                     None,  # ICMS
                     100,  # BaseCalculo
                     None,  # PesoBruto
                     None,  # PesoLiq
                     None,  # LkModulo
                     None,  # Armazenamento
                     None,  # QntEmbalagem
                     None,  # ELV
                     None,  # Previsao
                     None,  # DataFoto
                     None,  # DataInc
                     1,  # LkUserInc
                     None,  # CodEx
                     None,  # IVA_ST
                     None,  # PFC
                     None,  # IPI_CST
                     None,  # IPI_BaseCalc
                     None,  # IPPT
                     None,  # IAT
                     None,  # DataUltMov
                     None,  # EAD
                     None,  # cEAN
                     None,  # cEANTri
                     None,  # cProdANP
                     None  # CEST
                     )
            paradox = produtos.insert(dados)
            insert = "INSERT INTO produtos (paradox, mongo) VALUES ({}, '{}')".format(int(paradox), id)
            cursor1.execute(insert)
        else:
            print(result)
finally:
    conn.commit()
    conn.close()
    produtos.close()
    client.close()