lifecycle

import 'dart:async';
import 'dart:convert';
import 'dart:isolate';
import 'dart:typed_data';

import 'package:coocafe_tecnico_app/helpers/cultura_helper.dart';
import 'package:coocafe_tecnico_app/helpers/notificacao_propriedade_helper.dart';
import 'package:coocafe_tecnico_app/helpers/notificacoes_helper.dart';
import 'package:coocafe_tecnico_app/helpers/produtor_helper.dart';
import 'package:coocafe_tecnico_app/helpers/filial_helper.dart';
import 'package:coocafe_tecnico_app/helpers/propriedade_helper.dart';
import 'package:coocafe_tecnico_app/helpers/safra_helper.dart';
import 'package:coocafe_tecnico_app/helpers/talhao_helper.dart';
import 'package:coocafe_tecnico_app/helpers/tipo_titulo_helper.dart';
import 'package:coocafe_tecnico_app/helpers/notificacoes_cooperado_helper.dart';
import 'package:coocafe_tecnico_app/helpers/titulos_cp_helper.dart';
import 'package:coocafe_tecnico_app/helpers/titulos_cr_helper.dart';
import 'package:coocafe_tecnico_app/widgets/drawer.dart';
import 'package:coocafe_tecnico_app/pages/lista-produtor-page.dart';
import 'package:coocafe_tecnico_app/pages/login_page.dart';
import 'package:coocafe_tecnico_app/pages/notificacoes-page.dart';
import 'package:coocafe_tecnico_app/pages/produtor_page.dart';
import 'package:flutter/material.dart';
import 'package:flutter/services.dart';
import 'package:flutter_string_encryption/flutter_string_encryption.dart';
import 'package:shared_preferences/shared_preferences.dart';
import 'package:url_launcher/url_launcher.dart';
import 'package:http/http.dart' as http;
import 'package:date_format/date_format.dart';
import 'package:html/parser.dart' show parse;
import 'package:connectivity/connectivity.dart';

class HomePage extends StatefulWidget {
  static String tag = "home-page";
  final bool refreshDrawer;

  HomePage({this.refreshDrawer});

  @override
  _HomePageState createState() => _HomePageState();
}

class _HomePageState extends State<HomePage> with WidgetsBindingObserver {
  final String url = 'http://coocafe.com.br/vSite/views/soap/app_tecnico/hom/';
  //final String url = 'http://coocafe.com.br/vSite/views/soap/app_tecnico/prod/';
  static final _pageCtrl = PageController();
  ProdutorHelper prodHelper = ProdutorHelper();
  FilialHelper filialHelper = FilialHelper();
  TipoTituloHelper tipoTituloHelper = TipoTituloHelper();
  PropriedadeHelper propriedadeHelper = PropriedadeHelper();
  TalhaoHelper talhaoHelper = TalhaoHelper();
  SafraHelper safraHelper = SafraHelper();
  CulturaHelper culturaHelper = CulturaHelper();
  NotificacoesCoopHelper notProdutorHelper = NotificacoesCoopHelper();
  TitulosCRHelper titCRHelper = TitulosCRHelper();
  TitulosCPHelper titCPHelper = TitulosCPHelper();
  NotificacoesHelper notificacoesHelper = NotificacoesHelper();
  NotificacoesPropHelper notPropriedadeHelper = NotificacoesPropHelper();
  List<Produtor> _listaProdutor = List();
  ScrollController _scrollCtrl = ScrollController();
  String _dataRefresh = "";
  static int _qtdNot;
  static int progresso;
  static String textProgress = "Requisitando dados...";
  static bool _refresh = false;
  bool _refreshDrawer = false;
  static Future<List<Produtor>> tempList;
  String _connectionStatus = "Unknown";
  final Connectivity _connectivity = Connectivity();
  StreamSubscription<ConnectivityResult> _connectivitySubscription;
  ListaProdutorPage pageListaProdutor = ListaProdutorPage(controller: _pageCtrl,);
  NotificacoesPage pageNotificacoes = NotificacoesPage();
  AppLifecycleState _lastLifecycleState;

  @override
  void initState() {
    super.initState();

    WidgetsBinding.instance.addObserver(this);

    initConnectivity();
    _connectivitySubscription =
        _connectivity.onConnectivityChanged.listen((ConnectivityResult result) {
          setState(() => _connectionStatus = result.toString());
        });

    _refresh = false;
    progresso = 0;

    SharedPreferences.getInstance().then((data) {
      if(data.getString("TextoAtualizacao") != null) {
        _dataRefresh = data.getString("TextoAtualizacao");
      }
    });

    filialHelper.getAll().then((list) {
      if (list.length <= 0) _getListaFilial().then((filiais) {});
    });

    safraHelper.getAll().then((list) {
      if (list.length <= 0) _getListaSafra().then((safras) {});
    });

    culturaHelper.getAll().then((list) {
      if (list.length <= 0) _getListaCultura().then((culturas) {});
    });

    tipoTituloHelper.getAll().then((list) {
      if (list.length <= 0) _getListaTipoTitulo().then((tipos) {});
    });

    notificacoesHelper.getAll().then((list) {
      if (list.length <= 0) _getListaNotificacoesTecnico().then((notificacoes) {});
    });

    tempList = _getListaProdutorLocal();

    _refreshDrawer = widget.refreshDrawer != null ? widget.refreshDrawer : false;
    if(_refreshDrawer) {
      setState(() {
        final int alarmID = 0;
        progresso = 0;
        textProgress = "Requisitando dados...";

        _atualizarTalhoes();
      });
    }

    notificacoesHelper.getCountNotificacaoTec().then((value) {
      setState(() {
        _qtdNot = value;
      });
    });
  }

  @override
  void dispose() {
    _connectivitySubscription.cancel();
    WidgetsBinding.instance.removeObserver(this);

    super.dispose();
  }

  @override
  void didChangeAppLifecycleState(AppLifecycleState state) {
    setState(() {
      _lastLifecycleState = state;
    });
  }

  @override
  Widget build(BuildContext context) {
    print('Estado do app: $_lastLifecycleState.');
    return PageView(
      controller: _pageCtrl,
      physics: NeverScrollableScrollPhysics(),
      children: <Widget>[
        Scaffold(
          backgroundColor: Colors.white,
          drawer: DrawerPage(pageCtrl: _pageCtrl, qtdNot: _qtdNot,),
          appBar: AppBar(
            title: Text("App Técnico"),
            centerTitle: true,
            actions: <Widget>[
              ButtonTheme(
                minWidth: 44.0,
                padding: EdgeInsets.all(0.0),
                child: ButtonBar(
                  children: <Widget>[
                    FlatButton(
                      child: IconTheme(
                        data: IconThemeData(color: Colors.white),
                        child: Icon(Icons.refresh),
                      ),
                      onPressed: () async {
                        if(_connectionStatus == "ConnectivityResult.none") {
                          showDialog(
                            context: context,
                            barrierDismissible: false,
                            builder: (BuildContext context) {
                              return AlertDialog(
                                title: Text("Atenção!"),
                                content: Text("Sem conexão no momento. Tente novamente com o dispositivo conectado à internet."),
                                actions: <Widget>[
                                  FlatButton(
                                    child: Text("OK"),
                                    onPressed: () {
                                      Navigator.of(context).pop();
                                    },
                                  )
                                ],
                              );
                            }
                          );
                        } else {
                          showDialog(
                            context: context,
                            barrierDismissible: false,
                            builder: (BuildContext context) {
                              return AlertDialog(
                                title: Text("Sincronizar Dados"),
                                content: Text(
                                    "Deseja sincronizar os dados com o servidor?"),
                                actions: <Widget>[
                                  FlatButton(
                                    child: Text("Não"),
                                    onPressed: () {
                                      Navigator.of(context).pop();
                                    },
                                  ),
                                  FlatButton(
                                    child: Text("Sim"),
                                    onPressed: () async {
                                      Navigator.of(context).pop();

                                      try {
                                        setState(() async {
                                          progresso = 0;
                                          textProgress = "Requisitando dados...";

                                          await _atualizarTalhoes();
                                        });
                                      } on TimeoutException catch (e) {
                                        _showDialog(context, e.message);
                                      } catch (e) {
                                        _showDialog(context, e);
                                      }
                                    },
                                  )
                                ],
                              );
                            }
                          );
                        }
                      },
                    ),
                  ],
                ),
              )
            ],
          ),
          body: FutureBuilder(
              future: tempList,
              builder: (context, snapshot) {
                switch(snapshot.connectionState) {
                  case ConnectionState.none:
                  case ConnectionState.waiting:
                    return Column(
                      mainAxisAlignment: MainAxisAlignment.center,
                      crossAxisAlignment: CrossAxisAlignment.stretch,
                      children: <Widget>[
                        Container(
                            width: 200.00,
                            height: 200.00,
                            alignment: Alignment.center,
                            child: Column(
                              children: <Widget>[
                                CircularProgressIndicator(
                                  valueColor: AlwaysStoppedAnimation<Color>(Colors.green),
                                  strokeWidth: 5.0,
                                ),
                                Text(textProgress, style: TextStyle(fontSize: 15.0, color: Colors.black),),
                              ],
                            )
                        )
                      ],
                    );
                    break;
                  default:
                    if(_connectionStatus == "ConnectivityResult.none") {
                      return Container(
                        child: Column(
                          crossAxisAlignment: CrossAxisAlignment.stretch,
                          mainAxisAlignment: MainAxisAlignment.center,
                          children: <Widget>[
                            Icon(Icons.signal_wifi_off, size: 40.0, color: Colors.red,),
                            Center(
                              child: Text(
                                "Dispositivo Off-line",
                                style: TextStyle(fontSize: 20.0),
                              ),
                            ),
                          ],
                        ),
                      );
                    } else
                    if(snapshot.hasData) {
                      return Container(
                        padding: EdgeInsets.only(top: 10.0),
                        child: Column(
                          children: <Widget>[
                            Center(
                              child: Text(_dataRefresh),
                            ),
                          ],
                        ),
                      );
                    } else if(snapshot.hasError) {
                      return Container(
                        child: Column(
                          crossAxisAlignment: CrossAxisAlignment.stretch,
                          mainAxisAlignment: MainAxisAlignment.center,
                          children: <Widget>[
                            Icon(
                              Icons.error_outline,
                              size: 40.0,
                              color: Colors.red,
                            ),
                            Center(
                              child: Text(
                                "Erro ao atualizar os dados!",
                                style: TextStyle(fontSize: 20.0),
                              ),
                            ),
                            Text(snapshot.error.toString())
                          ],
                        ),
                      );
                    } else {
                      return Container();
                    }
                    break;
                }
              }
          ),
        ),
        Scaffold(
          backgroundColor: Colors.white,
          body: pageListaProdutor,
        ),
        Scaffold(
          backgroundColor: Colors.white,
          drawer: DrawerPage(pageCtrl: _pageCtrl, qtdNot: _qtdNot,),
          appBar: AppBar(
            title: Text("Notificações"),
            centerTitle: true,
          ),
          body: pageNotificacoes,
        )
      ],
    );
  }

  Future<List> _getListaFilial() async {
    FilialHelper filialHelper = FilialHelper();
    print('--> Atualizando Filiais');
    Map<String, dynamic> myMap = Map();
    SharedPreferences prefs = await SharedPreferences.getInstance();
    List<Filial> lista = List();

    String usuario = prefs.get("user");
    String senha = prefs.get("pass");
    String key = prefs.get("key");

    final cryptor = new PlatformStringCryptor();
    final String encrypted = await cryptor.decrypt(senha, key);

    Map dados = {"user": usuario, "password": encrypted};
    String ldados = json.encode(dados);

    http.Response response = await http.post(
        url + "filial.php",
        body: ldados).catchError((error) {
          _showDialog(context, error);
        });

    Map<String, dynamic> retorno = json.decode(response.body);

    if (retorno["status"] != "" && retorno["status"] != null) {
      _showDialog(context, "Erro ao processar a requisição.");
    } else {
      var listaFilial = retorno['lista'];

      await filialHelper.deleteAll();

      for (Map itens in listaFilial) {
        Filial filialIns = await filialHelper.saveFilial(Filial.fromMap(itens));
        lista.add(filialIns);
      }
    }

    return lista;
  }

  Future<List> _getListaSafra() async {
    SafraHelper safraHelper = SafraHelper();
    print('--> Atualizando Safras');
    Map<String, dynamic> myMap = Map();
    SharedPreferences prefs = await SharedPreferences.getInstance();
    List<Safra> lista = List();

    String usuario = prefs.get("user");
    String senha = prefs.get("pass");
    String key = prefs.get("key");

    final cryptor = new PlatformStringCryptor();
    final String encrypted = await cryptor.decrypt(senha, key);

    Map dados = {"user": usuario, "password": encrypted};
    String ldados = json.encode(dados);

    http.Response response = await http.post(
        url + "safra.php",
        body: ldados).catchError((error) {
          _showDialog(context, error);
        });
    Map<String, dynamic> retorno = json.decode(response.body);

    if (retorno["status"] != "" && retorno["status"] != null) {
      _showDialog(context, "Erro ao processar a requisição.");
    } else {
      var listaSafra = retorno['lista'];

      await safraHelper.deleteAll();

      for (Map itens in listaSafra) {
        Safra safraIns = await safraHelper.saveSafra(Safra.fromMap(itens));
        lista.add(safraIns);
      }
    }

    return lista;
  }

  Future<List> _getListaCultura() async {
    CulturaHelper culturaHelper = CulturaHelper();
    print('--> Atualizando Culturas');
    Map<String, dynamic> myMap = Map();
    SharedPreferences prefs = await SharedPreferences.getInstance();
    List<Cultura> lista = List();

    String usuario = prefs.get("user");
    String senha = prefs.get("pass");
    String key = prefs.get("key");

    final cryptor = new PlatformStringCryptor();
    final String encrypted = await cryptor.decrypt(senha, key);

    Map dados = {"user": usuario, "password": encrypted};
    String ldados = json.encode(dados);

    http.Response response = await http.post(
        url + "cultura.php",
        body: ldados).catchError((error) {
          _showDialog(context, error);
        });
    Map<String, dynamic> retorno = json.decode(response.body);

    if (retorno["status"] != "" && retorno["status"] != null) {
      _showDialog(context, "Erro ao processar a requisição.");
    } else {
      var listaCultura = retorno['lista'];

      await culturaHelper.deleteAll();

      for (Map itens in listaCultura) {
        Cultura culturaIns = await culturaHelper.saveCultura(Cultura.fromMap(itens));
        lista.add(culturaIns);
      }
    }

    return lista;
  }

  Future<List> _getListaTipoTitulo() async {
    TipoTituloHelper tipoTituloHelper = TipoTituloHelper();
    print('--> Atualizando Tipos de Título');
    Map<String, dynamic> myMap = Map();
    SharedPreferences prefs = await SharedPreferences.getInstance();
    List<TipoTitulo> lista = List();
    List<TipoTitulo> tiposTitulo = List();

    String usuario = prefs.get("user");
    String senha = prefs.get("pass");
    String key = prefs.get("key");

    final cryptor = new PlatformStringCryptor();
    final String encrypted = await cryptor.decrypt(senha, key);

    Map dados = {"user": usuario, "password": encrypted};
    String ldados = json.encode(dados);

    http.Response response = await http.post(
        url + "tipoTitulo.php",
        body: ldados).catchError((error) {
          _showDialog(context, error);
        });

    Map<String, dynamic> retorno = json.decode(response.body);

    if (retorno["status"] != "" && retorno["status"] != null) {
      _showDialog(context, "Erro ao processar a requisição.");
    } else {
      var listaTipoTitulo = retorno['lista'];

      await tipoTituloHelper.deleteAll();

      for (Map itens in listaTipoTitulo) {
        TipoTitulo tipoTituloIns = TipoTitulo();

        tipoTituloIns = await tipoTituloHelper.saveTipoTitulo(TipoTitulo.fromMap(itens));

        tiposTitulo.add(tipoTituloIns);
      }
    }

    return tiposTitulo;
  }

  Future<List> _getListaNotificacoesTecnico() async {
    NotificacoesHelper notificacoesHelper = NotificacoesHelper();
    print('--> Atualizando Notificações do Técnico');
    Map<String, dynamic> myMap = Map();
    SharedPreferences prefs = await SharedPreferences.getInstance();
    List<Notificacoes> lista = List();

    String usuario = prefs.get("user");
    String senha = prefs.get("pass");
    String key = prefs.get("key");

    final cryptor = new PlatformStringCryptor();
    final String encrypted = await cryptor.decrypt(senha, key);

    Map dados = {"user": usuario, "password": encrypted};
    String ldados = json.encode(dados);

    http.Response response = await http.post(
        url + "notificacoes.php",
        body: ldados).catchError((error) {
          _showDialog(context, error);
        });
    Map<String, dynamic> retorno = json.decode(response.body);

    if (retorno["status"] != "" && retorno["status"] != null) {
      _showDialog(context, "Erro ao processar a requisição.");
    } else {
      var listaNotificacoes = retorno['lista'];

      //await notificacoesHelper.deleteAll();

      if(listaNotificacoes != null) {
        for (Map itens in listaNotificacoes) {
          Notificacoes not = Notificacoes.fromMap(itens);
          Notificacoes notificacao = await notificacoesHelper.saveNotificacao(not);

          lista.add(notificacao);
        }
      }
    }
    return lista;
  }

  Future<List<Produtor>> _getListaProdutor() async {
    try {
      ProdutorHelper prodHelper = ProdutorHelper();
      PropriedadeHelper propriedadeHelper = PropriedadeHelper();
      TalhaoHelper talhaoHelper = TalhaoHelper();
      NotificacoesCoopHelper notProdutorHelper = NotificacoesCoopHelper();
      TitulosCRHelper titCRHelper = TitulosCRHelper();
      NotificacoesPropHelper notPropriedadeHelper = NotificacoesPropHelper();
      print('--> Atualizando dados');
      int totalRegistros = 0;

      Map<String, dynamic> myMap = Map();
      SharedPreferences prefs = await SharedPreferences.getInstance();
      List<Produtor> lista = List();
      List<Propriedade> propriedades = List();
      //String listaTalhao;

      String usuario = prefs.get("user");
      String senha = prefs.get("pass");
      String key = prefs.get("key");

      final cryptor = new PlatformStringCryptor();
      final String encrypted = await cryptor.decrypt(senha, key);

      //listaTalhao = await talhaoHelper.getListaTalhaoParaAtualizar();

      //print(listaTalhao.toString());

      Map dados = {
        "user": usuario,
        "password": encrypted,
        "talhao": "",
        "opeExe": ""
      };

      String ldados = json.encode(dados);

      http.Response response = await http.post(
          url + 'produtor.php',
          body: ldados).catchError((error) {
            _showDialog(context, error);
          });

      Map<String, dynamic> retorno = json.decode(response.body);

      if (retorno["status"] != null && retorno["status"] != "") {
        _showDialog(context, retorno["status"]);
      } else {
        var listaProdutor = retorno['lista'];
        totalRegistros = retorno['qtdReg'];

        await notProdutorHelper.deleteAll();
        await notPropriedadeHelper.deleteAll();
        await talhaoHelper.deleteAll();
        await propriedadeHelper.deleteAll();
        await titCRHelper.deleteAll();
        await titCPHelper.deleteAll();
        await prodHelper.deleteAll();

        //print('--> Atualizando Produtores');
        for (Map itens in listaProdutor) {
          Produtor prod = Produtor();

          if (itens["codigo"] != 0 && itens["codigo"] != null) {
            Produtor prod = Produtor.fromMap(itens);

            prodHelper.saveProdutor(prod).then((prodInsert) {
              prod = prodInsert;

              setState(() {
                progresso = progresso + 1;
                textProgress = "Atualizando $progresso de $totalRegistros registros";
              });
            });

            lista.add(prod);

            //print('--> Atualizando Notificações do Produtor');
            var listaNotificacoes = itens['notificacoesProdutor'];

            if(listaNotificacoes != null) {
              for (Map m in listaNotificacoes) {
                NotificacoesCoop notificacao = await notProdutorHelper
                    .saveNotificacaoCoop(NotificacoesCoop.fromMap(m));

                setState(() {
                  progresso = progresso + 1;
                  textProgress = "Atualizando $progresso de $totalRegistros registros";
                });
              }
            }

            var listaPropriedades = itens['propriedade'];
            var listaTitulosCR = itens['titulosCR'];

            //print('--> Atualizando Títulos a Receber');
            if (itens['titulosCR'].toString().startsWith("[")) {
              //É uma lista
              var titulosCR = itens['titulosCR'];

              if(titulosCR != null) {
                for (Map titCR in titulosCR) {
                  TitulosCR tituloCR = await titCRHelper.saveTituloCR(
                      TitulosCR.fromMap(titCR));

                  setState(() {
                    progresso = progresso + 1;
                    textProgress = "Atualizando $progresso de $totalRegistros registros";
                  });
                }
              }
            } else {
              //É um objeto
              if (itens['titulosCR'] != null) {
                var titulosCR = TitulosCR.fromMap(itens['titulosCR']);

                TitulosCR titCR = await titCRHelper.saveTituloCR(titulosCR);

                setState(() {
                  progresso = progresso + 1;
                  textProgress = "Atualizando $progresso de $totalRegistros registros";
                });
              }
            }

            //print('--> Atualizando Títulos a Pagar');
            if (itens['titulosCP'].toString().startsWith("[")) {
              //É uma lista
              var titulosCP = itens['titulosCP'];

              if(titulosCP != null) {
                for (Map titCP in titulosCP) {
                  TitulosCP tituloCP = await titCPHelper.saveTituloCP(
                      TitulosCP.fromMap(titCP));

                  setState(() {
                    progresso = progresso + 1;
                    textProgress = "Atualizando $progresso de $totalRegistros registros";
                  });
                }
              }
            } else {
              //É um objeto
              if (itens['titulosCP'] != null) {
                var titulosCP = TitulosCP.fromMap(itens['titulosCP']);

                TitulosCP titCR = await titCPHelper.saveTituloCP(titulosCP);

                setState(() {
                  progresso = progresso + 1;
                  textProgress = "Atualizando $progresso de $totalRegistros registros";
                });
              }
            }

            //print('--> Atualizando Propriedades');
            if (itens['propriedade'].toString().startsWith("[")) {
              //É uma lista
              var listaProp = itens['propriedade'];

              if(listaProp != null) {
                for (Map prop in listaProp) {
                  Propriedade propi = await propriedadeHelper.savePropriedade(
                      Propriedade.fromMap(prop));

                  setState(() {
                    progresso = progresso + 1;
                    textProgress = "Atualizando $progresso de $totalRegistros registros";
                  });

                  //print('--> Atualizando Notificações da Propriedade');
                  if(prop['notificacoesPropriedade'] != null) {
                    for (Map not in prop['notificacoesPropriedade']) {
                      NotificacoesProp notProp = await notPropriedadeHelper
                          .saveNotificacaoCoop(NotificacoesProp.fromMap(not));

                      setState(() {
                        progresso = progresso + 1;
                        textProgress = "Atualizando $progresso de $totalRegistros registros";
                      });
                    }
                  }
                }
              }
            } else {
              //É um objeto
              if (itens['propriedade'] != null) {
                var propriedades = Propriedade.fromMap(itens['propriedade']);
                //var talhao = Talhao.fromMap(listaPropriedades['talhao']);

                Propriedade prop = await propriedadeHelper.savePropriedade(propriedades);

                setState(() {
                  progresso = progresso + 1;
                  textProgress = "Atualizando $progresso de $totalRegistros registros";
                });

                //print('--> Atualizando Notificações da Propriedade');
                if(itens['propriedade']['notificacoesPropriedade'] != null) {
                  for (Map not in itens['propriedade']['notificacoesPropriedade']) {
                    NotificacoesProp notProp = await notPropriedadeHelper
                        .saveNotificacaoCoop(NotificacoesProp.fromMap(not));

                    setState(() {
                      progresso = progresso + 1;
                      textProgress = "Atualizando $progresso de $totalRegistros registros";
                    });
                  }
                }

                //print('--> Atualizando Talhões produtor: ${propriedades.idProdutor}');
                if (itens['propriedade']['talhao'].toString().startsWith('[')) {
                  //Lista de Talhões
                  if(itens['propriedade']['talhao'] != null) {
                    for (Map talhao in itens['propriedade']['talhao']) {
                      if (talhao != null) {
                        Talhao tal = await talhaoHelper.saveTalhao(Talhao.fromMap(talhao));
                      }

                      setState(() {
                        progresso = progresso + 1;
                        textProgress = "Atualizando $progresso de $totalRegistros registros";
                      });
                    }
                  }
                } else {
                  //Objeto Talhão
                  if (itens['propriedade']['talhao'] != null) {
                    Talhao tal = await talhaoHelper.saveTalhao(Talhao.fromMap(itens['propriedade']['talhao']));

                    setState(() {
                      progresso = progresso + 1;
                      textProgress = "Atualizando $progresso de $totalRegistros registros";
                    });
                  }
                }
              }
            }
          }
        }
      }

      /*getCountNotProp();
      getCountNotTec();
      getCountTitCP();
      getCountTitCR();
      getCountNotProd();
      getCountTalhao();
      getCountProdutor();
      getCountPropriedade();*/

      setState(() {
        _refresh = false;
        progresso = 0;
        _dataRefresh = "Atualizado em " + formatDate(
            DateTime.now(), [dd, '/', mm, '/', yyyy]) + " às " +
            formatDate(DateTime.now(), [HH, ':', nn, ':', ss]);
      });

      return lista;
    } catch(e) {
      _showDialog(context, e);
    }
  }

  Future<List<Produtor>> _getListaProdutorLocal() async {
    List<Produtor> lista = List();

    lista = await prodHelper.getAll();

    return lista;
  }

  Future<String> _atualizarTalhoes() async {
    setState(() async {
      try {
        print('--> Atualizando Talhões');
        Map<String, dynamic> myMap = Map();
        SharedPreferences prefs = await SharedPreferences.getInstance();
        List<Produtor> lista = List();
        List<Propriedade> propriedades = List();
        List listaTalhao;

        String usuario = prefs.get("user");
        String senha = prefs.get("pass");
        String key = prefs.get("key");

        final cryptor = new PlatformStringCryptor();
        final String encrypted = await cryptor.decrypt(senha, key);

        listaTalhao = await talhaoHelper.getListaTalhaoParaAtualizar();

        if (listaTalhao.length > 0) {
          print('--> Existe talhão para atualizar');
          Map dados = {
            "user": usuario,
            "password": encrypted,
            "talhao": listaTalhao,
            "opeExe": "A"
          };

          String ldados = json.encode(dados);

          http.Response response = await http.post(
              url + 'produtor.php',
              body: ldados).catchError((error) {
                _showDialog(context, error);
              });

          Map<String, dynamic> retorno = json.decode(response.body);

          if (retorno["status"] != null && retorno["status"] != "") {
            _showDialog(context, retorno["status"]);
          } else {
            var result = retorno["lista"];
            if(result != null) {
              var resultPropriedade = result["propriedade"];

              if(resultPropriedade["talhao"].toString().startsWith("[")) {
                for (Map m in resultPropriedade["talhao"]) {
                  if (m["retorno"] != null) {
                    Notificacoes not = Notificacoes();
                    not.Descricao = m["retorno"];
                    not.Data = formatDate(DateTime.now(), [dd, '/', mm, '/', yyyy]);
                    not.Situacao = "Não Lida";

                    print('--> Salvando notificação');

                    switch(_lastLifecycleState) {
                      case AppLifecycleState.resumed:
                      case AppLifecycleState.paused:
                      case AppLifecycleState.inactive:
                        await notificacoesHelper.saveNotificacao(not).then((notificacao) {});;
                        break;
                      default:
                        await notificacoesHelper.saveNotificacao(not).then((notificacao) {});;
                        break;
                    }
                  }
                }
              } else {
                String retorno = resultPropriedade["talhao"]["retorno"];

                Notificacoes not = Notificacoes();
                not.Descricao = retorno;
                not.Data = DateTime.now().toIso8601String();
                not.Situacao = "Não Lida";

                notificacoesHelper.saveNotificacao(not).then((notificacao) {});
              }
            }

            _getListaSafra();
            _getListaCultura();
            _getListaFilial();
            _getListaTipoTitulo();
            _getListaNotificacoesTecnico();
            tempList = _getListaProdutor();
            _dataRefresh = "Atualizado em " + formatDate(DateTime.now(), [dd, '/', mm, '/', yyyy ]) + " às " + formatDate(DateTime.now(), [HH, ':', nn, ':', ss ]);

            prefs.setString("TextoAtualizacao", _dataRefresh);
          }
        } else {
          print('--> Não existe talhão para atualizar');

          setState(() {
            _getListaSafra();
            _getListaCultura();
            _getListaFilial();
            _getListaTipoTitulo();
            _getListaNotificacoesTecnico();
            tempList = _getListaProdutor();
            _dataRefresh = "Atualizado em " + formatDate(DateTime.now(), [dd, '/', mm, '/', yyyy ]) + " às " + formatDate(DateTime.now(), [HH, ':', nn, ':', ss ]);

            prefs.setString("TextoAtualizacao", _dataRefresh);
          });

          return null;
        }
      } catch(e) {
        _showDialog(context, e);
      }
    });
  }

  Future<Null> initConnectivity() async {
    String connectionStatus;
    // Platform messages may fail, so we use a try/catch PlatformException.
    try {
      connectionStatus = (await _connectivity.checkConnectivity()).toString();
    } catch (e) {
      print(e.toString());
      connectionStatus = 'Failed to get connectivity.';
    }

    // If the widget was removed from the tree while the asynchronous platform
    // message was in flight, we want to discard the reply rather than calling
    // setState to update our non-existent appearance.
    if (!mounted) {
      return;
    }

    setState(() {
      _connectionStatus = connectionStatus;
    });
  }

  void getCountNotProp() {
    notPropriedadeHelper.getCount().then((value) {
      print('Not. Propriedade: ' + value.toString());
    });
  }

  void getCountNotTec() {
    notificacoesHelper.getCount().then((value) {
      print('Not. Tecnico: ' + value.toString());
    });
  }

  void getCountTitCP() {
    titCPHelper.getCount().then((value) {
      print('Titulos CP: ' + value.toString());
    });
  }

  void getCountTitCR() {
    titCRHelper.getCount().then((value) {
      print('Titulos CR: ' + value.toString());
    });
  }

  void getCountNotProd() {
    notProdutorHelper.getCount().then((value) {
      print('Not. Produtor: ' + value.toString());
    });
  }

  void getCountCultura() {
    culturaHelper.getCount().then((value) {
      print('Culturas: ' + value.toString());
    });
  }

  void getCountSafra() {
    safraHelper.getCount().then((value) {
      print('Safras: ' + value.toString());
    });
  }

  void getCountTalhao() {
    talhaoHelper.countTalhao().then((value) {
      print('Talhões: ' + value.toString());
    });
  }

  void getCountProdutor() {
    prodHelper.getCount().then((value) {
      print('Produtores: ' + value.toString());
    });
  }

  void getCountFilial() {
    filialHelper.getCount().then((value) {
      print('Filiais: ' + value.toString());
    });
  }

  void getCountTipoTitulo() {
    tipoTituloHelper.getCount().then((value) {
      print('Tipos de Título: ' + value.toString());
    });
  }

  void getCountPropriedade() {
    propriedadeHelper.getCount().then((value) {
      print('Propriedades: ' + value.toString());
    });
  }

  void _showDialog(BuildContext context, String texto) {
    // flutter defined function
    showDialog(
      barrierDismissible: false,
      context: context,
      builder: (BuildContext context) {
        // return object of type Dialog
        return AlertDialog(
          title: new Text("Atenção"),
          content: new Text(texto),
          actions: <Widget>[
            // usually buttons at the bottom of the dialog
            new FlatButton(
              child: new Text("OK"),
              onPressed: () {
                Navigator.of(context).pop();
              },
            ),
          ],
        );
      },
    );
  }
}