Proyectos de Subversion Android Microlearning - Nuevo Interface

Rev

Rev 31 | Rev 33 | Ir a la última revisión | Mostrar el archivo completo | | | Autoría | Ultima modificación | Ver Log |

Rev 31 Rev 32
Línea 2638... Línea 2638...
2638
 
2638
 
2639
 
2639
 
2640
                Calendar calendar = Calendar.getInstance();
2640
                Calendar calendar = Calendar.getInstance();
-
 
2641
                long timeNow = calendar.getTime().getTime();
-
 
2642
                 if (timeNow > (timeLast + Constants.CHECK_CHANGES_INTERVAL)) {
-
 
2643
 
-
 
2644
                     if(preference.isRefreshTokenIsRequired()) {
-
 
2645
                         FirebaseMessaging.getInstance().getToken().addOnCompleteListener(new OnCompleteListener<String>() {
-
 
2646
                            @Override
-
 
2647
                            public void onComplete(@NonNull Task<String> task) {
-
 
2648
                                if (!task.isSuccessful()) {
-
 
2649
                                    Log.w(TAG, "Fetching FCM registration token failed", task.getException());
-
 
2650
                                    return;
-
 
2651
                                }
-
 
2652
 
-
 
2653
                                // Get new FCM registration token
-
 
2654
                                String token = task.getResult();
-
 
2655
 
-
 
2656
                                Log.e("BUG Token", "Token 3 :  " + token);
-
 
2657
 
-
 
2658
                                createSyncRecordNewToken(token);
-
 
2659
 
-
 
2660
                                preference.setRefreshTokenIsRequired(false);
-
 
2661
                                preference.save();
-
 
2662
                            }
-
 
2663
                        });
-
 
2664
 
-
 
2665
 
-
 
2666
                     } else {
-
 
2667
 
-
 
2668
                         if (preference.getDeviceToken().isEmpty()) {
-
 
2669
                             FirebaseMessaging.getInstance().deleteToken().addOnCompleteListener(new OnCompleteListener<Void>() {
-
 
2670
                                 @Override
-
 
2671
                                 public void onComplete(@NonNull Task<Void> task) {
-
 
2672
                                     preference.setRefreshTokenIsRequired(true);
-
 
2673
                                     preference.save();
-
 
2674
 
-
 
2675
 
-
 
2676
                                 }
-
 
2677
                             });
-
 
2678
                         }
-
 
2679
                     }
-
 
2680
 
2641
                long timeNow = calendar.getTime().getTime();
2681
 
2642
                 if (timeNow > (timeLast + Constants.CHECK_CHANGES_INTERVAL)) {
2682
 
2643
                    requestCheckChanges();
2683
                    requestCheckChanges();
2644
                }
2684
                }
Línea 2691... Línea 2731...
2691
                    call.enqueue(new okhttp3.Callback() {
2731
                    call.enqueue(new okhttp3.Callback() {
2692
                        public void onResponse(Call call, Response response)
2732
                        public void onResponse(Call call, Response response)
2693
                                throws IOException {
2733
                                throws IOException {
2694
                            Log.d(TAG, "Response Device :  " +  response.body().toString());
2734
                            Log.d(TAG, "Response Device :  " +  response.body().toString());
Línea 2695... Línea 2735...
2695
 
2735
 
2696
                            processResponseSyncToServer(response.body().string(), "device");
2736
                            processResponseSyncToServer(response.body().string());
Línea 2697... Línea 2737...
2697
                        }
2737
                        }
2698
 
2738
 
2699
                        public void onFailure(Call call, IOException e) {
2739
                        public void onFailure(Call call, IOException e) {
Línea 2730... Línea 2770...
2730
                    call.enqueue(new okhttp3.Callback() {
2770
                    call.enqueue(new okhttp3.Callback() {
2731
                        public void onResponse(Call call, Response response)
2771
                        public void onResponse(Call call, Response response)
2732
                                throws IOException {
2772
                                throws IOException {
2733
                            isSyncToken = false;
2773
                            isSyncToken = false;
2734
                            Log.e("Se envio", "Procesando respuesta");
2774
                            Log.e("Se envio", "Procesando respuesta");
2735
                            processResponseSyncToServer(response.body().string(), "fcmtoken");
2775
                            processResponseSyncToServer(response.body().string());
2736
                        }
2776
                        }
Línea 2737... Línea 2777...
2737
 
2777
 
2738
                        public void onFailure(Call call, IOException e) {
2778
                        public void onFailure(Call call, IOException e) {
2739
                            Log.d(TAG, "Error :  " +  e.getMessage());
2779
                            Log.d(TAG, "Error :  " +  e.getMessage());
Línea 2774... Línea 2814...
2774
 
2814
 
2775
                Call call = client.newCall(request);
2815
                Call call = client.newCall(request);
2776
                call.enqueue(new okhttp3.Callback() {
2816
                call.enqueue(new okhttp3.Callback() {
2777
                    public void onResponse(Call call, Response response) throws IOException {
2817
                    public void onResponse(Call call, Response response) throws IOException {
2778
                        isSyncBatch = false;
2818
                        isSyncBatch = false;
2779
                        processResponseServerBatch(response.body().string(),"");
2819
                        processResponseServerBatch(response.body().string());
Línea 2780... Línea 2820...
2780
                    }
2820
                    }
2781
 
2821
 
2782
                    public void onFailure(Call call, IOException e) {
2822
                    public void onFailure(Call call, IOException e) {
Línea 2791... Línea 2831...
2791
        }
2831
        }
Línea 2792... Línea 2832...
2792
 
2832
 
Línea 2793... Línea 2833...
2793
 
2833
 
2794
    }
2834
    }
2795
 
2835
 
2796
    private void processResponseServerBatch(String dataString, String origen)
2836
    private void processResponseServerBatch(String dataString)
Línea 2797... Línea 2837...
2797
    {
2837
    {
Línea 2841... Línea 2881...
2841
            }
2881
            }
2842
            if(success && sync_id > 0) {
2882
            if(success && sync_id > 0) {
2843
                Log.d(TAG, "DELETE SYNC RECORD : " + sync_id);
2883
                Log.d(TAG, "DELETE SYNC RECORD : " + sync_id);
2844
                mAppDatabase.getSyncDao().remove(sync_id);
2884
                mAppDatabase.getSyncDao().remove(sync_id);
Línea 2845... Línea -...
2845
 
-
 
2846
                if(origen.equals("device"))
-
 
2847
                {
-
 
2848
                    Log.e("Sync","device exitoso, ahora sigo con TokenFCM");
-
 
2849
                    isSyncDevice=true;
-
 
2850
                    syncToServerOrCheckChanges();
-
 
2851
                }
-
 
2852
                if(origen.equals("fcmtoken")){
-
 
2853
                    Log.e("Token", "termino de sync con exito");
-
 
2854
                }
2885
 
2855
            }
2886
            }
2856
        } catch (JSONException e) {
2887
        } catch (JSONException e) {
2857
            e.printStackTrace();
2888
            e.printStackTrace();
2858
        }
2889
        }
Línea 2859... Línea 2890...
2859
    }
2890
    }
2860
 
2891
 
2861
    private void processResponseSyncToServer(String dataString, String origen)
2892
    private void processResponseSyncToServer(String dataString)
2862
    {
2893
    {
Línea 2863... Línea 2894...
2863
        boolean success = false;
2894
        boolean success = false;
2864
        long sync_id = 0;
2895
        long sync_id = 0;
2865
 
2896
 
2866
        Log.d(TAG, "processResponseServer = " + dataString);
2897
        Log.d(TAG, "processResponseServer = " + dataString);
2867
        try {
2898
        try {
2868
            JSONObject objJSON = new JSONObject(dataString);
2899
            JSONObject objJSON = new JSONObject(dataString);
2869
            success = objJSON.has("success") ? objJSON.getBoolean("success")  : false;
-
 
2870
            if(success  && objJSON.has("data")) {
-
 
2871
                JSONObject jsonObjectData = objJSON.getJSONObject("data");
-
 
2872
                if(origen.equals("device"))
-
 
2873
                {
-
 
-
 
2900
            success = objJSON.has("success") ? objJSON.getBoolean("success")  : false;
Línea 2874... Línea 2901...
2874
                    Log.e("El origen","De la peticion es el dispositivo");
2901
            if(success  && objJSON.has("data")) {
2875
                    isSyncDevice=true;
2902
                JSONObject jsonObjectData = objJSON.getJSONObject("data");
2876
                }
2903
 
Línea 2903... Línea 2930...
2903
        } catch (JSONException e) {
2930
        } catch (JSONException e) {
2904
            e.printStackTrace();
2931
            e.printStackTrace();
2905
        }
2932
        }
2906
    }
2933
    }
Línea -... Línea 2934...
-
 
2934
 
2907
 
2935
    /*
2908
    private void processResponseSyncTokenFCMtoServer(String dataString)
2936
    private void processResponseSyncTokenFCMtoServer(String dataString)
2909
    {
2937
    {
2910
        Log.e("Respuesta",""+dataString);
2938
        Log.e("Respuesta",""+dataString);
Línea 2921... Línea 2949...
2921
            e.printStackTrace();
2949
            e.printStackTrace();
2922
        }
2950
        }
2923
    }
2951
    }
Línea -... Línea 2952...
-
 
2952
 
-
 
2953
 
Línea 2924... Línea 2954...
2924
 
2954
     */
2925
 
2955
 
Línea 2926... Línea 2956...
2926
 
2956