添加登录同步失败后服务开启数据同步

app/src/main/AndroidManifest.xml

@@ -193,6 +193,11 @@
 
 
         <receiver android:name=".receiver.UpDataReceiver"/>
+        <!--下载数据服务-->
+        <service android:name=".servier.DownLoadService"/>
+
+
+        <receiver android:name=".receiver.DownLoadReceiver"/>
     </application>
 
 

app/src/main/java/com/kuxuan/moneynote/receiver/DownLoadReceiver.java

@@ -0,0 +1,17 @@
+package com.kuxuan.moneynote.receiver;
+
+import android.content.BroadcastReceiver;
+import android.content.Context;
+import android.content.Intent;
+
+/**
+ * Created by xieshengqi on 2018/4/9.
+ */
+
+public class DownLoadReceiver  extends BroadcastReceiver {
+    @Override
+    public void onReceive(Context context, Intent intent) {
+        Intent i = new Intent(context, com.kuxuan.moneynote.servier.DownLoadService.class);
+        context.startService(i);
+    }
+}

app/src/main/java/com/kuxuan/moneynote/servier/DownLoadService.java

@@ -0,0 +1,149 @@
+package com.kuxuan.moneynote.servier;
+
+import android.app.AlarmManager;
+import android.app.PendingIntent;
+import android.app.Service;
+import android.content.Intent;
+import android.os.IBinder;
+import android.os.SystemClock;
+import android.support.annotation.Nullable;
+
+import com.kuxuan.moneynote.api.ExceptionHandle;
+import com.kuxuan.moneynote.api.MyObsever;
+import com.kuxuan.moneynote.api.RetrofitClient;
+import com.kuxuan.moneynote.db.BillCategoreDaoOperator;
+import com.kuxuan.moneynote.db.CategoryDBbean;
+import com.kuxuan.moneynote.db.CategoryDaoOperator;
+import com.kuxuan.moneynote.json.BeanNewJson;
+import com.kuxuan.moneynote.json.UploadBeanJson;
+import com.kuxuan.moneynote.json.UploadDbjson;
+import com.kuxuan.moneynote.receiver.DownLoadReceiver;
+import com.kuxuan.moneynote.ui.activitys.eventbus.RefreshEvent;
+import com.kuxuan.moneynote.utils.LoginStatusUtil;
+import com.kuxuan.moneynote.utils.TimeUtlis;
+
+import org.greenrobot.eventbus.EventBus;
+
+import java.util.ArrayList;
+
+import io.reactivex.android.schedulers.AndroidSchedulers;
+import io.reactivex.schedulers.Schedulers;
+
+/**
+ * Created by xieshengqi on 2018/4/9.
+ */
+
+public class DownLoadService extends Service {
+
+    /**
+     * 每3分钟更新一次数据
+     */
+    private static final int ONE_Miniute = 30 * 1000;
+    private static final int PENDING_REQUEST = 0;
+    AlarmManager alarmManager;
+    PendingIntent pIntent;
+
+    public DownLoadService() {
+    }
+
+    @Override
+    public int onStartCommand(Intent intent, int flags, int startId) {
+        //这里模拟后台操作
+//上传数据
+        if (LoginStatusUtil.isLoginin()) {
+            syncData(0);
+
+//        Log.e("UpDataService", "我在执行");
+
+        }
+        return super.onStartCommand(intent, flags, startId);
+    }
+
+
+    @Override
+    public void onDestroy() {
+        if(alarmManager!=null)
+        alarmManager.cancel(pIntent);//关闭的服务的时候同时关闭广播注册者
+        super.onDestroy();
+    }
+
+    @Nullable
+    @Override
+    public IBinder onBind(Intent intent) {
+        return null;
+    }
+
+    /**
+     * 同步数据
+     */
+    private void syncData(final int page) {
+        RetrofitClient.getApiService().getDownLoadData(page).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new MyObsever<BeanNewJson<UploadBeanJson>>() {
+            @Override
+            public void onError(ExceptionHandle.ResponeThrowable e) {
+                alarmManager = (AlarmManager) getSystemService(ALARM_SERVICE);
+                long triggerAtTime = SystemClock.elapsedRealtime() + ONE_Miniute;//从开机到现在的毫秒书（手机睡眠(sleep)的时间也包括在内
+                Intent i = new Intent(DownLoadService.this, DownLoadReceiver.class);
+                pIntent = PendingIntent.getBroadcast(DownLoadService.this, PENDING_REQUEST, i, PENDING_REQUEST);
+                alarmManager.set(AlarmManager.ELAPSED_REALTIME_WAKEUP, triggerAtTime, pIntent);
+            }
+
+            @Override
+            public void onSuccess(BeanNewJson<UploadBeanJson> objectBaseJson) {
+                if (objectBaseJson != null && objectBaseJson.getCode() == 0) {
+                    UploadBeanJson res = objectBaseJson.getRes();
+                    if (res != null) {
+                        int number = res.getNumber();
+                        if (res.getData() != null) {
+                            insertDb(objectBaseJson.getRes().getData());
+                            if (res.getData().size() < number) {
+                                //结束
+                                EventBus.getDefault().post(new RefreshEvent());
+                                //结束服务
+                                stopService(new Intent(DownLoadService.this, DownLoadService.class));
+                            } else {
+                                int count = page;
+                                syncData(count++);
+                            }
+                        } else {
+
+                        }
+
+                    } else {
+
+                    }
+                }
+
+            }
+        });
+    }
+
+    private void insertDb(ArrayList<UploadDbjson> uploadDbjsons) {
+        if (uploadDbjsons == null) {
+            return;
+        }
+        CategoryDaoOperator categoryDaoOperator = CategoryDaoOperator.newInstance();
+        int loginUserId = LoginStatusUtil.getLoginUserId();
+        for (UploadDbjson uploadDbjson : uploadDbjsons) {
+            CategoryDBbean categoryDBbean = new CategoryDBbean();
+            categoryDBbean.setName(uploadDbjson.getCategory_name());
+            categoryDBbean.setType_imagepath(BillCategoreDaoOperator.newInstance().getDetaillIconUrlById(uploadDbjson.getCategory_id()));
+            categoryDBbean.setType(uploadDbjson.getType());
+            categoryDBbean.setCategory_id(uploadDbjson.getCategory_id());
+            categoryDBbean.setDemo(uploadDbjson.getDemo());
+            long time = uploadDbjson.getTime() * 1000;
+            categoryDBbean.setCreateTime(uploadDbjson.getTime());
+            categoryDBbean.setUpdateTime(uploadDbjson.getTime());
+            String data = TimeUtlis.getData(time);
+            String[] split = data.split("-");
+            categoryDBbean.setYear(Integer.parseInt(split[0]));
+            categoryDBbean.setMonth(Integer.parseInt(split[1]));
+            categoryDBbean.setDay(Integer.parseInt(split[2]));
+            categoryDBbean.setUser_id(loginUserId);
+            categoryDBbean.setAccount(Double.parseDouble(uploadDbjson.getAccount()));
+            categoryDBbean.setBill_id(uploadDbjson.getIdentification());
+            categoryDaoOperator.insert(categoryDBbean, true);
+        }
+
+    }
+}
+

app/src/main/java/com/kuxuan/moneynote/servier/ServiceUtil.java

@@ -12,7 +12,7 @@ public class ServiceUtil {
 
 
     /**
-     * 开启服务
+     * 开启上传服务
      *
      * @param context
      */
@@ -20,7 +20,15 @@ public class ServiceUtil {
         Intent intent = new Intent(context, UpDataService.class);
         context.startService(intent);
     }
-
+    /**
+     * 开启下载服务
+     *
+     * @param context
+     */
+    public static void startDownLoadData(Context context) {
+        Intent intent = new Intent(context, DownLoadService.class);
+        context.startService(intent);
+    }
 
     /**
      * 关闭服务

app/src/main/java/com/kuxuan/moneynote/ui/activitys/login/LoginActivity.java

@@ -30,7 +30,6 @@ import com.kuxuan.moneynote.ui.activitys.MainActivity;
 import com.kuxuan.moneynote.ui.activitys.eventbus.LoginEvent;
 import com.kuxuan.moneynote.ui.activitys.register.RegisterFirstActivity;
 import com.kuxuan.moneynote.ui.weight.ActionSheetDialog;
-import com.kuxuan.moneynote.ui.weight.MyToast;
 import com.kuxuan.moneynote.utils.AppManager;
 import com.kuxuan.moneynote.utils.GlideRoundTransform;
 import com.kuxuan.moneynote.utils.LoginStatusUtil;
@@ -297,8 +296,9 @@ public class LoginActivity extends BaseFragmentActivity {
             @Override
             public void onError(ExceptionHandle.ResponeThrowable e) {
                 closeProgressDialog();
+                ServiceUtil.startDownLoadData(LoginActivity.this);
                 goToNext();
-                MyToast.makeText(LoginActivity.this, "数据同步失败", Toast.LENGTH_SHORT);
+//                MyToast.makeText(LoginActivity.this, "数据同步失败", Toast.LENGTH_SHORT);
             }
 
             @Override

app/src/main/java/com/kuxuan/moneynote/ui/activitys/login/PhoneLoginActivity.java

@@ -379,6 +379,7 @@ public class PhoneLoginActivity extends BaseActivity {
                     LoginStatusUtil.setToken(loginJsonBaseJson.getData().getToken(), loginJsonBaseJson.getData().getId());
                     SPUtil.putAndApply(PhoneLoginActivity.this, Constant.IsFirstWEiChatLogin.ISWEICHATLOGIN, false);
                     syncData(0);
+                    goMain();
                 } else {
                     closeProgressDialog();
                     ToastUtil.show(PhoneLoginActivity.this, loginJsonBaseJson.getError().get(0));
@@ -412,6 +413,7 @@ public class PhoneLoginActivity extends BaseActivity {
             @Override
             public void onError(ExceptionHandle.ResponeThrowable e) {
                 closeProgressDialog();
+                ServiceUtil.startDownLoadData(PhoneLoginActivity.this);
                 goMain();
                 MyToast.makeText(PhoneLoginActivity.this, "数据同步失败", Toast.LENGTH_SHORT);
             }

app/src/main/java/com/kuxuan/moneynote/ui/fragments/details/DetialPresent.java

@@ -337,8 +337,8 @@ public class DetialPresent extends DetialContract.DetialPresent implements View.
                     BillData billData = bill_data.get(i);
                     List<TypeDataJson> day_data = billData.getDay_data();
                     if (day_data != null) {
-                        for (int j = 0; j < day_data.size(); j++) {
-                            if (j == 0) {
+                        for (int j = day_data.size()-1; j>=0; j--) {
+                            if (j == day_data.size()-1) {
                                 day_data.get(j).setFirst(true);
                             }
                             day_data.get(j).setDay_type(billData.getTime());