pedido_view_model.dart 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410
  1. import 'package:collection/collection.dart';
  2. import 'package:flutter/material.dart';
  3. import 'package:intl/intl.dart';
  4. import 'package:sqflite/sqflite.dart';
  5. import '../data/api_response.dart';
  6. import '../models/models.dart';
  7. import '../services/services.dart';
  8. class PedidoViewModel extends ChangeNotifier {
  9. String _busqueda = "";
  10. String get busqueda => _busqueda;
  11. List<Pedido> _pedidos = [];
  12. Pedido? _selectedPedido;
  13. bool _isLoading = false;
  14. int _currentPage = 1;
  15. int _totalPedidos = 0;
  16. int _limit = 10;
  17. int get currentPage => _currentPage;
  18. int get totalPedidos => _totalPedidos;
  19. int get totalPages => (_totalPedidos / _limit).ceil();
  20. List<Pedido> get pedidos => _pedidos;
  21. Pedido? get selectedPedido => _selectedPedido;
  22. bool get isLoading => _isLoading;
  23. void setIsLoading(bool loading) {
  24. _isLoading = loading;
  25. notifyListeners();
  26. }
  27. Future<bool> guardarPedidoLocal({required Pedido pedido}) async {
  28. RepoService<Pedido> repoPedido = RepoService<Pedido>();
  29. if (pedido.id == null || pedido.id == 0) {
  30. int nextFolio = await repoPedido.obtenerProximoFolio();
  31. pedido.folio = nextFolio;
  32. }
  33. try {
  34. // Verifica si el pedido ya existe en la base de datos
  35. Pedido? pedidoExistente = await repoPedido.obtenerPorId(pedido.id!);
  36. if (pedidoExistente != null) {
  37. // Si existe, actualiza
  38. await repoPedido.guardar(pedido);
  39. } else {
  40. // Si no existe, inserta como nuevo
  41. int idPedido = await repoPedido.guardarLocal(pedido);
  42. pedido.id = idPedido;
  43. }
  44. RepoService<PedidoProducto> repoPedidoProducto =
  45. RepoService<PedidoProducto>();
  46. RepoService<PedidoProductoTopping> repoPedidoProductoTopping =
  47. RepoService<PedidoProductoTopping>();
  48. // Manejo de productos asociados al pedido
  49. for (var producto in pedido.productos) {
  50. PedidoProducto pedidoProducto = PedidoProducto(
  51. idPedido: pedido.id,
  52. idProducto: producto.idProducto,
  53. cantidad: producto.cantidad,
  54. costoUnitario: producto.costoUnitario,
  55. comentario: producto.comentario,
  56. );
  57. if (producto.id != null && producto.id! > 0) {
  58. await repoPedidoProducto.guardarLocal(pedidoProducto);
  59. } else {
  60. int idPedidoProducto =
  61. await repoPedidoProducto.guardarLocal(pedidoProducto);
  62. for (var topping in producto.toppings) {
  63. PedidoProductoTopping pedidoProductoTopping = PedidoProductoTopping(
  64. idPedidoProducto: idPedidoProducto,
  65. idTopping: topping.idTopping,
  66. idCategoria: topping.idCategoria,
  67. );
  68. await repoPedidoProductoTopping.guardarLocal(pedidoProductoTopping);
  69. }
  70. }
  71. }
  72. notifyListeners();
  73. return true;
  74. } catch (e) {
  75. print('Error al guardar el pedido: $e');
  76. return false;
  77. }
  78. }
  79. Future<bool> guardarPedidoConProductos({
  80. required Pedido pedido,
  81. required List<ItemCarrito> carrito,
  82. }) async {
  83. try {
  84. RepoService<Pedido> repoPedido = RepoService<Pedido>();
  85. RepoService<PedidoProducto> repoPedidoProducto =
  86. RepoService<PedidoProducto>();
  87. RepoService<PedidoProductoTopping> repoPedidoProductoTopping =
  88. RepoService<PedidoProductoTopping>();
  89. // Guardar el pedido en la base de datos
  90. if (pedido.id == null || pedido.id == 0) {
  91. int nextFolio = await repoPedido.obtenerProximoFolio();
  92. pedido.folio = nextFolio;
  93. pedido.id = await repoPedido.guardarLocal(pedido);
  94. } else {
  95. await repoPedido.guardar(pedido);
  96. }
  97. // Manejar los productos del carrito
  98. for (var item in carrito) {
  99. PedidoProducto pedidoProducto = PedidoProducto(
  100. idPedido: pedido.id,
  101. idProducto: item.producto.id,
  102. cantidad: item.cantidad,
  103. costoUnitario: item.producto.precio.toString(),
  104. sincronizado: null,
  105. );
  106. // Guardar o actualizar el producto
  107. int idPedidoProducto =
  108. await repoPedidoProducto.guardarPedidoProducto(pedidoProducto);
  109. // Manejar los toppings seleccionados
  110. for (var entry in item.selectedToppings.entries) {
  111. int categoriaId = entry.key;
  112. for (int toppingId in entry.value) {
  113. PedidoProductoTopping topping = PedidoProductoTopping(
  114. idPedidoProducto: idPedidoProducto,
  115. idTopping: toppingId,
  116. idCategoria: categoriaId,
  117. );
  118. await repoPedidoProductoTopping.guardarLocal(topping);
  119. }
  120. }
  121. }
  122. notifyListeners();
  123. return true;
  124. } catch (e) {
  125. print("Error al guardar el pedido con productos: $e");
  126. return false;
  127. }
  128. }
  129. Future<void> fetchLocalPedidos({int page = 1}) async {
  130. _isLoading = true;
  131. _currentPage = page;
  132. notifyListeners();
  133. RepoService<Pedido> repoPedido = RepoService<Pedido>();
  134. _totalPedidos = await repoPedido.contarPedidos();
  135. int offset = (_limit * (page - 1));
  136. List<Pedido> paginatedPedidos =
  137. await repoPedido.obtenerPedidosPaginados(_limit, offset);
  138. _pedidos = paginatedPedidos;
  139. _isLoading = false;
  140. notifyListeners();
  141. }
  142. void nextPage() {
  143. if (_currentPage < totalPages) {
  144. fetchLocalPedidosForScreen(page: _currentPage + 1);
  145. }
  146. }
  147. void previousPage() {
  148. if (_currentPage > 1) {
  149. fetchLocalPedidosForScreen(page: _currentPage - 1);
  150. }
  151. }
  152. Future<void> eliminarProductoDelPedido(int idProducto, int idPedido) async {
  153. RepoService<PedidoProducto> repoPedidoProducto =
  154. RepoService<PedidoProducto>();
  155. PedidoProducto? producto =
  156. await repoPedidoProducto.obtenerPorIdPedidoYProducto(
  157. idPedido: idPedido,
  158. idProducto: idProducto,
  159. );
  160. if (producto != null) {
  161. producto.eliminado = DateTime.now().toUtc();
  162. await repoPedidoProducto.guardar(producto);
  163. notifyListeners();
  164. }
  165. }
  166. Future<void> fetchLocalPedidosForScreen({int page = 1}) async {
  167. setIsLoading(true);
  168. RepoService<Pedido> repoPedido = RepoService<Pedido>();
  169. _currentPage = page;
  170. var db = await RepoService().db;
  171. int? count = Sqflite.firstIntValue(
  172. await db!.rawQuery('SELECT COUNT(*) FROM Pedido'));
  173. _totalPedidos = count ?? 0;
  174. int offset = (_limit * (page - 1));
  175. List<Pedido> localPedidos =
  176. await repoPedido.obtenerPedidosPaginados(_limit, offset);
  177. _pedidos = localPedidos;
  178. setIsLoading(false);
  179. notifyListeners();
  180. }
  181. Future<List<Pedido>> fetchAllLocalPedidos() async {
  182. setIsLoading(true);
  183. RepoService<Pedido> repoPedido = RepoService<Pedido>();
  184. List<Pedido> allPedidos = await repoPedido.obtenerTodos();
  185. setIsLoading(false);
  186. return allPedidos;
  187. }
  188. Future<List<Pedido>> fetchPedidosPorFechaSinLimit(
  189. DateTime startDate, DateTime endDate) async {
  190. setIsLoading(true);
  191. RepoService<Pedido> repoPedido = RepoService<Pedido>();
  192. List<Pedido> pedidos = await repoPedido.buscarPorFecha(startDate, endDate);
  193. setIsLoading(false);
  194. return pedidos;
  195. }
  196. Future<Pedido?> fetchPedidoConProductos(int idPedido) async {
  197. RepoService<Pedido> repoPedido = RepoService<Pedido>();
  198. Pedido? pedido = await repoPedido.obtenerPorId(idPedido);
  199. if (pedido != null) {
  200. RepoService<PedidoProducto> repoProducto = RepoService<PedidoProducto>();
  201. RepoService<Producto> repoProductoInfo = RepoService<Producto>();
  202. List<PedidoProducto> productos =
  203. await repoProducto.obtenerPorIdPedido(idPedido);
  204. productos = productos.where((p) => p.eliminado == null).toList();
  205. for (var producto in productos) {
  206. Producto? prodInfo =
  207. await repoProductoInfo.obtenerProductoPorId(producto.idProducto!);
  208. if (prodInfo != null) {
  209. producto.producto = prodInfo;
  210. }
  211. RepoService<PedidoProductoTopping> repoTopping =
  212. RepoService<PedidoProductoTopping>();
  213. List<PedidoProductoTopping> toppings =
  214. await repoTopping.obtenerToppingsPorPedidoProducto(producto.id!);
  215. for (var topping in toppings) {
  216. Producto? toppingInfo =
  217. await repoProductoInfo.obtenerProductoPorId(topping.idTopping!);
  218. if (toppingInfo != null) {
  219. topping.topping = toppingInfo;
  220. }
  221. }
  222. producto.toppings = toppings;
  223. }
  224. pedido.productos = productos;
  225. }
  226. return pedido;
  227. }
  228. Future<void> buscarPedidosPorFolio(String folio) async {
  229. setIsLoading(true);
  230. RepoService<Pedido> repoPedido = RepoService<Pedido>();
  231. List<Pedido> localPedidos = await repoPedido.buscarPorFolio(folio);
  232. _pedidos = localPedidos;
  233. setIsLoading(false);
  234. notifyListeners();
  235. }
  236. Future<void> buscarPedidosPorFecha(
  237. DateTime startDate, DateTime endDate) async {
  238. setIsLoading(true);
  239. RepoService<Pedido> repoPedido = RepoService<Pedido>();
  240. List<Pedido> localPedidos =
  241. await repoPedido.buscarPorFecha(startDate, endDate);
  242. _pedidos = localPedidos;
  243. setIsLoading(false);
  244. notifyListeners();
  245. }
  246. Future<List<Pedido>> buscarPorFecha(
  247. DateTime startDate, DateTime endDate) async {
  248. setIsLoading(true);
  249. RepoService<Pedido> repoPedido = RepoService<Pedido>();
  250. print('Consulta SQL de pedidos desde: $startDate hasta: $endDate');
  251. List<Pedido> pedidos = await repoPedido.buscarPorFecha(startDate, endDate);
  252. print('Pedidos obtenidos desde la base de datos: ${pedidos.length}');
  253. pedidos.forEach((pedido) => print(
  254. 'Pedido Folio: ${pedido.folio}, Estatus: ${pedido.estatus}, Total: ${pedido.totalPedido}'));
  255. setIsLoading(false);
  256. notifyListeners();
  257. return pedidos;
  258. }
  259. Future<void> cancelarPedido(int idPedido) async {
  260. var db = await RepoService().db;
  261. await db?.update(
  262. 'Pedido',
  263. {
  264. 'estatus': 'CANCELADO',
  265. 'sincronizado': null,
  266. },
  267. where: 'id = ?',
  268. whereArgs: [idPedido],
  269. );
  270. fetchLocalPedidosForScreen();
  271. }
  272. Future<bool> sincronizarPedidos() async {
  273. List<Pedido> pedidosNoSincronizados =
  274. await fetchAllLocalPedidosOrdenadosPorFecha();
  275. if (pedidosNoSincronizados.isNotEmpty) {
  276. Pedido pedidoNoSincronizado = pedidosNoSincronizados.first;
  277. if (pedidoNoSincronizado.productos.isEmpty) {
  278. pedidoNoSincronizado =
  279. await fetchPedidoConProductos(pedidoNoSincronizado.id) ??
  280. pedidoNoSincronizado;
  281. }
  282. Map<String, dynamic> pedidoJson =
  283. await prepararPedidoParaApi(pedidoNoSincronizado);
  284. // print('JSON enviado: $pedidoJson');
  285. var response = ApiResponse(await BaseService()
  286. .post('/pos/pedido/sincronizar', body: pedidoJson));
  287. if (response.isOk && response.detalle != null) {
  288. int idWeb = response.detalle!['id'];
  289. String sincronizado = response.detalle!['sincronizado'];
  290. await actualizarPedidoSincronizado(
  291. pedidoNoSincronizado.id!, idWeb, sincronizado);
  292. return true;
  293. } else {
  294. print('Error en la sincronización del pedido: ${response.mensaje}');
  295. return true;
  296. }
  297. } else {
  298. print('No se encontraron pedidos no sincronizados.');
  299. return false;
  300. }
  301. }
  302. Future<void> actualizarPedidoSincronizado(
  303. int idPedido, int idWeb, String sincronizado) async {
  304. var db = await RepoService().db;
  305. await db!.update(
  306. 'Pedido',
  307. {
  308. 'idWeb': idWeb,
  309. 'sincronizado': sincronizado,
  310. },
  311. where: 'id = ?',
  312. whereArgs: [idPedido],
  313. );
  314. }
  315. Future<List<Pedido>> fetchAllLocalPedidosOrdenadosPorFecha() async {
  316. setIsLoading(true);
  317. RepoService<Pedido> repoPedido = RepoService<Pedido>();
  318. List<Pedido> allPedidos =
  319. await repoPedido.obtenerPedidosOrdenadosPorFecha();
  320. setIsLoading(false);
  321. return allPedidos;
  322. }
  323. }
  324. Future<Map<String, dynamic>> prepararPedidoParaApi(Pedido pedido) async {
  325. String? claveSucursal =
  326. await RepoService().obtenerClaveSucursalSeleccionada();
  327. Map<String, dynamic> apiMap = pedido.toApi();
  328. apiMap['claveSucursal'] = claveSucursal;
  329. if (pedido.idWeb != null && pedido.idWeb! > 0) {
  330. apiMap['idWeb'] = pedido.idWeb;
  331. }
  332. return apiMap;
  333. }