package com.ubt.jimu.sync;

import android.text.TextUtils;
import com.ubt.jimu.base.cache.Cache;
import com.ubt.jimu.base.http.ApiResponse;
import com.ubt.jimu.blockly.networkSync.utils.QiNiuUtils;
import com.ubt.jimu.transport3.api.DiyTransportServiceProxy;
import com.ubt.jimu.transport3.bean.request.UploadModelActionBean;
import com.ubt.jimu.transport3.dao.DiyModelActionDBHandler;
import com.ubt.jimu.transport3.model.DiyModelAction;
import com.ubt.jimu.upload.DataUploadProxy;
import com.ubt.jimu.upload.SimpleUploadCallback;
import com.ubt.jimu.upload.UploadFilePathUtils;
import com.ubt.jimu.upload.UploadRequest;
import com.ubt.jimu.upload.UploadResponse;
import com.ubt.jimu.utils.LogUtils;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.functions.Consumer;
import io.reactivex.schedulers.Schedulers;
import java.io.File;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

/* loaded from: classes2.dex */
public class OfflineUploadAction {
    private String a;
    private DiyModelActionDBHandler b;
    private DiyTransportServiceProxy c;

    public OfflineUploadAction(DiyTransportServiceProxy diyTransportServiceProxy) {
        if (this.b == null) {
            this.b = DiyModelActionDBHandler.getInstance();
        }
        this.c = diyTransportServiceProxy;
    }

    public void b() {
        List<DiyModelAction> syncServiceActionDB = this.b.getSyncServiceActionDB();
        if (syncServiceActionDB == null || syncServiceActionDB.size() == 0) {
            return;
        }
        for (DiyModelAction diyModelAction : syncServiceActionDB) {
            LogUtils.c("serviceActionDB:" + diyModelAction.getFileName());
            b(1, diyModelAction);
        }
    }

    public void c() {
        List<DiyModelAction> qiNiuActionDB = this.b.getQiNiuActionDB();
        if (qiNiuActionDB == null || qiNiuActionDB.size() == 0) {
            return;
        }
        Iterator<DiyModelAction> it = qiNiuActionDB.iterator();
        while (it.hasNext()) {
            a(1, it.next());
        }
    }

    public void a() {
        List<DiyModelAction> allOfflineUpdateBean;
        if (this.c == null || (allOfflineUpdateBean = this.b.getAllOfflineUpdateBean()) == null || allOfflineUpdateBean.size() == 0) {
            return;
        }
        Iterator<DiyModelAction> it = allOfflineUpdateBean.iterator();
        while (it.hasNext()) {
            a(it.next());
        }
    }

    private void c(final int i, final DiyModelAction diyModelAction) {
        String str = QiNiuUtils.getAndroidSystemRootPath() + QiNiuUtils.getDiyActionLoaclPath(diyModelAction);
        LogUtils.c("本地文件路径：" + str);
        if (TextUtils.isEmpty(str)) {
            return;
        }
        if (!new File(str).exists()) {
            LogUtils.c("Action file not exists");
            return;
        }
        UploadRequest uploadRequest = new UploadRequest();
        uploadRequest.b(str);
        uploadRequest.a(UploadFilePathUtils.a(str));
        DataUploadProxy.c().a(uploadRequest, new SimpleUploadCallback() { // from class: com.ubt.jimu.sync.OfflineUploadAction.2
            @Override // com.ubt.jimu.upload.IUploadCallback
            public void uploadFaulted(UploadRequest uploadRequest2, Exception exc) {
            }

            @Override // com.ubt.jimu.upload.IUploadCallback
            public void uploadSucceed(UploadResponse uploadResponse) {
                diyModelAction.setFileUrl(uploadResponse.c());
                diyModelAction.setUploaded(true);
                LogUtils.c("离线动作上传成功：" + uploadResponse.c());
                OfflineUploadAction.this.b.updateQiNiuState(diyModelAction);
                OfflineUploadAction.this.b(i, diyModelAction);
            }
        });
    }

    public void b(int i, final DiyModelAction diyModelAction) {
        int modelId = diyModelAction.getModelId();
        if (modelId <= 0) {
            return;
        }
        String customModelId = diyModelAction.getCustomModelId();
        DiyTransportServiceProxy diyTransportServiceProxy = new DiyTransportServiceProxy();
        this.a = Cache.getInstance().getUserToken();
        UploadModelActionBean uploadModelActionBean = new UploadModelActionBean(this.a, modelId, customModelId);
        UploadModelActionBean.UploadModelAction fromDiyModelAction = UploadModelActionBean.fromDiyModelAction(diyModelAction);
        ArrayList arrayList = new ArrayList();
        arrayList.add(fromDiyModelAction);
        if (i == -1) {
            uploadModelActionBean.setDeleteActions(arrayList);
        } else if (i == 0) {
            uploadModelActionBean.setUpdateActions(arrayList);
        } else if (i == 1) {
            uploadModelActionBean.setAddActions(arrayList);
        }
        diyTransportServiceProxy.uploadActions(uploadModelActionBean).subscribeOn(Schedulers.b()).observeOn(AndroidSchedulers.a()).subscribe(new Consumer<ApiResponse<Object>>() { // from class: com.ubt.jimu.sync.OfflineUploadAction.3
            @Override // io.reactivex.functions.Consumer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void accept(ApiResponse<Object> apiResponse) throws Exception {
                if (apiResponse == null || !apiResponse.isStatus()) {
                    return;
                }
                LogUtils.c("上传到本公司服务器成功");
                diyModelAction.setServerId(1L);
                diyModelAction.setModify(false);
                OfflineUploadAction.this.b.insertOrUpdate(diyModelAction);
            }
        });
    }

    private void a(final DiyModelAction diyModelAction) {
        this.a = Cache.getInstance().getUserToken();
        this.c.actions(diyModelAction.getModelId(), this.a).subscribeOn(Schedulers.b()).observeOn(AndroidSchedulers.a()).subscribe(new Consumer<ApiResponse<List<DiyModelAction>>>() { // from class: com.ubt.jimu.sync.OfflineUploadAction.1
            @Override // io.reactivex.functions.Consumer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void accept(ApiResponse<List<DiyModelAction>> apiResponse) throws Exception {
                List<DiyModelAction> models;
                if (apiResponse == null || !apiResponse.isStatus() || (models = apiResponse.getModels()) == null || models.size() == 0) {
                    return;
                }
                OfflineUploadAction.this.a(models, diyModelAction);
            }
        });
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void a(List<DiyModelAction> list, DiyModelAction diyModelAction) {
        for (DiyModelAction diyModelAction2 : list) {
            if (diyModelAction == null) {
                return;
            }
            String fileName = diyModelAction.getFileName();
            String fileName2 = diyModelAction2.getFileName();
            if (!TextUtils.isEmpty(fileName) && !TextUtils.isEmpty(fileName2) && fileName.equals(fileName2)) {
                if (diyModelAction2.getIsDeleted() == 1) {
                    this.b.deleteModelAction(diyModelAction);
                } else {
                    long lastUploadTime = diyModelAction.getLastUploadTime();
                    long lastUploadTime2 = diyModelAction2.getLastUploadTime();
                    if (lastUploadTime > lastUploadTime2 && lastUploadTime > lastUploadTime2) {
                        boolean uploaded = diyModelAction.getUploaded();
                        if (diyModelAction.getIsDeleted() == 1) {
                            b(-1, diyModelAction);
                        } else if (!uploaded) {
                            a(0, diyModelAction);
                        } else {
                            b(0, diyModelAction);
                        }
                    }
                }
            }
        }
    }

    public void a(int i, DiyModelAction diyModelAction) {
        LogUtils.c("获取七牛Key成功：" + QiNiuUtils.getDiyActionQiNiuKey(diyModelAction));
        c(i, diyModelAction);
    }

    public void a(String str, int i) {
        this.b.uploadUserIdAndModelId(str, i);
    }
}