diff --git a/lbbulk/model/BulkUpload.py b/lbbulk/model/BulkUpload.py index f99920d..25ccc4d 100644 --- a/lbbulk/model/BulkUpload.py +++ b/lbbulk/model/BulkUpload.py @@ -18,7 +18,8 @@ class BulkUpload(Base): __table__ = bulk_upload def verifica_registro(data): - q = session.query(BulkUpload).filter_by(id_source=data['id_source'], chave_externa=data['json_reg']['id_reg'] ) +# q = session.query(BulkUpload).filter_by(id_source=data['id_source'], chave_externa=data['json_reg']['id_reg'] ) + q = session.query(BulkUpload).filter_by(id_source=1, chave_externa=data['json_reg']['id_reg'] ) registro_existe = q.first() return registro_existe @@ -31,4 +32,4 @@ class BulkUploadContextFactory(SQLAlchemyORMContext): def get_member_id_as_string(self, member): id = self.get_member_id(member) - return json.dumps(id, cls=self.json_encoder) \ No newline at end of file + return json.dumps(id, cls=self.json_encoder) diff --git a/lbbulk/view/restfulview.py b/lbbulk/view/restfulview.py index a85e71c..b1a778e 100644 --- a/lbbulk/view/restfulview.py +++ b/lbbulk/view/restfulview.py @@ -36,8 +36,9 @@ class RegCustomView(RESTfulView): # print(existente.id_reg) print('\n\n\n\n\n\n\n\n\n\n') registro = self.is_error(data) - id_source = registro['id_source'] - registro.pop('id_source', None) + #id_source = registro['id_source'] + #registro.pop('id_source', None) + id_source = 1 chave_externa = registro['json_reg']['id_reg'] registro['json_reg'].pop('id_reg', None) registro['json_reg'] = json.dumps(registro['json_reg']) @@ -69,4 +70,4 @@ class RegCustomView(RESTfulView): def is_error_resp(self,r): if type(r) is dict: raise TypeError('Lightbase error ' + str(r['_status']) + ': ' + r['_error_message']) - return r \ No newline at end of file + return r -- libgit2 0.21.2