Compare commits
43
Commits
v1.3.60
...
v2.0.0-ambos
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5c9cb1905b | ||
|
|
a2d3dcc366 | ||
|
|
12e3d081a7 | ||
|
|
ad967bf0a1 | ||
|
|
d39cc7518b | ||
|
|
52bec03988 | ||
|
|
9639048bf7 | ||
|
|
b1585af3f9 | ||
|
|
155782f50a | ||
|
|
16972f4734 | ||
|
|
d3d5c4fbca | ||
|
|
5f1d9a4e2f | ||
|
|
cc45ed9df7 | ||
|
|
378a589572 | ||
|
|
50b0ba4498 | ||
|
|
7154901ce3 | ||
|
|
8b24a06496 | ||
|
|
3058908b37 | ||
|
|
9b1d45ae50 | ||
|
|
fbed0e57c2 | ||
|
|
362a76961b | ||
|
|
7a3a4b221b | ||
|
|
94bb8840ea | ||
|
|
dba7eb3856 | ||
|
|
7b3b7a9f1d | ||
|
|
5641de21f8 | ||
|
|
d77ad55fbd | ||
|
|
4a5cae8f2f | ||
|
|
313c740470 | ||
|
|
d21cb0a98d | ||
|
|
16bee1eacb | ||
|
|
c8016f076d | ||
|
|
b1a9f94231 | ||
|
|
42aadcca2c | ||
|
|
a8319d96a6 | ||
|
|
bf878545b3 | ||
|
|
22cda312cf | ||
|
|
d112ad061e | ||
|
|
be917f8fb7 | ||
|
|
cb48afeb9c | ||
|
|
2b8ff711ed | ||
|
|
9a4ccabd1b | ||
|
|
32728eec37 |
No files matched your search
@@ -250,25 +250,58 @@ impl SupabaseClient {
|
|||||||
|
|
||||||
/// Atualiza campos específicos de um fechamento pelo id_fechamento.
|
/// Atualiza campos específicos de um fechamento pelo id_fechamento.
|
||||||
pub fn atualizar_fechamento(&self, id_fechamento: &str, updates: &serde_json::Value) -> Result<Value, SupabaseError> {
|
pub fn atualizar_fechamento(&self, id_fechamento: &str, updates: &serde_json::Value) -> Result<Value, SupabaseError> {
|
||||||
|
// Campos que o frontend envia mas NÃO existem como colunas na tabela.
|
||||||
|
// Arrays e objetos são guardados no JSONB `dados` — não em colunas escalar.
|
||||||
|
static BLOCKED: &[&str] = &[
|
||||||
|
"id", "uuid", "criado_em", "atualizado_em", "enviado_por",
|
||||||
|
"ip_origem", "user_agent", "id_fechamento",
|
||||||
|
// arrays e objetos que existem dentro do JSONB `dados`
|
||||||
|
"vales", "despesas", "sangrias", "cancelamentos",
|
||||||
|
"pixcnpj", "receber",
|
||||||
|
"cartoes_credito", "cartoes_debito",
|
||||||
|
"cartoes_alimentacao", "cartoes_pix",
|
||||||
|
];
|
||||||
|
|
||||||
|
let map = updates.as_object().cloned().unwrap_or_default();
|
||||||
|
|
||||||
|
// Remove campos bloqueados
|
||||||
|
let filtered: serde_json::Map<String, serde_json::Value> = map
|
||||||
|
.into_iter()
|
||||||
|
.filter(|(k, _)| !BLOCKED.contains(&k.as_str()))
|
||||||
|
.collect();
|
||||||
|
|
||||||
|
if filtered.is_empty() {
|
||||||
|
return Err(SupabaseError::Api("Nenhum campo para atualizar".into()));
|
||||||
|
}
|
||||||
|
|
||||||
let url = format!(
|
let url = format!(
|
||||||
"{}/rest/v1/fechamentos_web?id_fechamento=eq.{}",
|
"{}/rest/v1/fechamentos_web?id_fechamento=eq.{}",
|
||||||
self.base_url,
|
self.base_url,
|
||||||
urlencoding::encode(id_fechamento)
|
urlencoding::encode(id_fechamento)
|
||||||
);
|
);
|
||||||
|
|
||||||
|
log::info!("[PATCH] url={} body={:#?}", url, filtered);
|
||||||
|
|
||||||
let resp = self
|
let resp = self
|
||||||
.http
|
.http
|
||||||
.patch(&url)
|
.patch(&url)
|
||||||
.headers(self.headers(true))
|
.headers(self.headers(true))
|
||||||
.header("Prefer", "return=representation")
|
.header("Prefer", "return=representation")
|
||||||
.json(updates)
|
.json(&filtered)
|
||||||
.send()?;
|
.send()?;
|
||||||
|
|
||||||
if resp.status().is_success() {
|
let status = resp.status();
|
||||||
|
if status.is_success() {
|
||||||
|
// Ler a resposta real do Supabase (retorna o registro atualizado)
|
||||||
|
if let Ok(ret) = resp.json::<serde_json::Value>() {
|
||||||
|
log::info!("[PATCH] sucesso — resposta: {}", ret);
|
||||||
|
} else {
|
||||||
|
log::warn!("[PATCH] sucesso mas não conseguiu ler resposta");
|
||||||
|
}
|
||||||
Ok(serde_json::json!({ "ok": true, "id_fechamento": id_fechamento }))
|
Ok(serde_json::json!({ "ok": true, "id_fechamento": id_fechamento }))
|
||||||
} else {
|
} else {
|
||||||
let status = resp.status();
|
|
||||||
let body = resp.text().unwrap_or_default();
|
let body = resp.text().unwrap_or_default();
|
||||||
|
log::error!("[PATCH] HTTP {} body: {}", status.as_u16(), body);
|
||||||
Err(SupabaseError::Api(format!(
|
Err(SupabaseError::Api(format!(
|
||||||
"HTTP {}: {}",
|
"HTTP {}: {}",
|
||||||
status.as_u16(),
|
status.as_u16(),
|
||||||
@@ -279,7 +312,7 @@ impl SupabaseClient {
|
|||||||
pub fn listar_recentes(&self, loja: &str, limite: i64) -> Result<Vec<Value>, SupabaseError> {
|
pub fn listar_recentes(&self, loja: &str, limite: i64) -> Result<Vec<Value>, SupabaseError> {
|
||||||
let loja_normalized = sem_acento(&loja.to_lowercase());
|
let loja_normalized = sem_acento(&loja.to_lowercase());
|
||||||
let url = format!(
|
let url = format!(
|
||||||
"{}/rest/v1/fechamentos_web?loja=eq.{}&order=data.desc,atualizado_em.desc&limit={}&select=id,id_fechamento,data,operador,turno,saldo_troco,saldo_esperado,fechamento_dinheiro,fechamento_cartoes,fechamento_areceber,diferenca,status_diferenca,observacoes,atualizado_em,dados",
|
"{}/rest/v1/fechamentos_web?loja=eq.{}&order=data.desc,atualizado_em.desc&limit={}&select=id,id_fechamento,data,operador,turno,saldo_troco,saldo_credito,saldo_debito,saldo_alimentacao,saldo_vales,saldo_areceber,saldo_esperado,total_pixcnpj,total_cartao_credito,total_cartao_debito,total_cartao_alimentacao,total_cartao_pix,total_cancelamentos,fechamento_dinheiro,fechamento_cartoes,fechamento_areceber,diferenca,status_diferenca,observacoes,atualizado_em,dados",
|
||||||
self.base_url,
|
self.base_url,
|
||||||
urlencoding::encode(&loja_normalized),
|
urlencoding::encode(&loja_normalized),
|
||||||
limite,
|
limite,
|
||||||
@@ -504,7 +537,7 @@ pub fn sb_buscar_por_id_fechamento(
|
|||||||
sb.buscar_por_id_fechamento(&id_fechamento)
|
sb.buscar_por_id_fechamento(&id_fechamento)
|
||||||
}
|
}
|
||||||
|
|
||||||
#[tauri::command]
|
#[tauri::command(rename_all = "snake_case")]
|
||||||
pub fn sb_atualizar_fechamento(
|
pub fn sb_atualizar_fechamento(
|
||||||
sb: State<'_, SupabaseClient>,
|
sb: State<'_, SupabaseClient>,
|
||||||
id_fechamento: String,
|
id_fechamento: String,
|
||||||
|
|||||||
+578
-201
File diff suppressed because it is too large.
Load diff
Reference in new issue
Block a user