package com.ubt.jimu.controller.syn; import android.text.TextUtils; import com.ubt.jimu.base.cache.Cache; import com.ubt.jimu.base.db.robot.RobotDbHandler; import com.ubt.jimu.base.entities.Robot; import com.ubt.jimu.base.entities.RobotLite; import com.ubt.jimu.base.http.ApiResponse; import com.ubt.jimu.transport.model.TransportFile; import com.ubt.jimu.transport3.api.DiyTransportServiceProxy; import com.ubt.jimu.transport3.bean.response.TransportFileBean; import com.ubt.jimu.transport3.dao.TransportFileDbHandler2; import com.ubt.jimu.transport3.download.TransportFileDownloader; import com.ubt.jimu.utils.LogUtils; import io.reactivex.functions.Consumer; import java.util.ArrayList; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.concurrent.BlockingQueue; import java.util.concurrent.Callable; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.TimeUnit; /* loaded from: classes.dex */ public class OfficialModelFileSynTask implements Callable { private RobotLite a; private DiyTransportServiceProxy b; private BlockingQueue c = new LinkedBlockingQueue(); public OfficialModelFileSynTask(RobotLite robotLite, DiyTransportServiceProxy diyTransportServiceProxy) { this.a = robotLite; this.b = diyTransportServiceProxy; } private List a(final String str) { Robot robotByModelName = RobotDbHandler.getRobotByModelName(this.a.getModelId()); if (robotByModelName == null) { return null; } final ArrayList arrayList = new ArrayList(); LogUtils.c("token:" + Cache.getInstance().getUserToken()); this.b.getModelFiles(str, (int) robotByModelName.getModelId(), Cache.getInstance().getUserToken()).subscribe(new Consumer>>(this) { // from class: com.ubt.jimu.controller.syn.OfficialModelFileSynTask.1 @Override // io.reactivex.functions.Consumer /* renamed from: a, reason: merged with bridge method [inline-methods] */ public void accept(ApiResponse> apiResponse) throws Exception { List models; LogUtils.c("listApiResponse:" + apiResponse + " 线程:" + Thread.currentThread().getName()); if (!apiResponse.isStatus() || (models = apiResponse.getModels()) == null || models.size() == 0) { return; } for (int i = 0; i < models.size(); i++) { TransportFileBean transportFileBean = models.get(i); if (transportFileBean.getIsDeleted() != 1) { long lastUploadTime = transportFileBean.getLastUploadTime(); TransportFile modelFile = TransportFileDbHandler2.getInstance().getModelFile(str, transportFileBean.getCustomModelId(), transportFileBean.getFileType()); if (modelFile == null) { arrayList.add(TransportFileBean.toTransportFile(str, transportFileBean)); } else if (lastUploadTime > modelFile.getLastUploadTime()) { arrayList.add(TransportFileBean.toTransportFile(str, transportFileBean)); } } } LogUtils.c("文件查询完毕"); } }); return arrayList; } /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable public Boolean call() throws Exception { LogUtils.c("开始获取模型文件"); if (!this.a.isOfficial()) { return false; } String userId = Cache.getInstance().getUserId(); if (TextUtils.isEmpty(userId) || "local".equals(userId)) { return false; } LogUtils.c("查询需要下载的文件"); List a = a(userId); if (a == null || a.size() == 0) { return null; } LogUtils.c("开始下载数据"); a(a); try { this.c.poll(5000L, TimeUnit.MILLISECONDS); LogUtils.c("流程结束"); return false; } catch (InterruptedException e) { e.printStackTrace(); Thread.currentThread().interrupt(); return false; } } private void a(List list) { new TransportFileDownloader().downloadFileSyn(list, new Consumer>() { // from class: com.ubt.jimu.controller.syn.OfficialModelFileSynTask.2 @Override // io.reactivex.functions.Consumer /* renamed from: a, reason: merged with bridge method [inline-methods] */ public void accept(HashMap hashMap) throws Exception { LogUtils.c("官方模型用户文件下载成功"); if (hashMap != null && hashMap.size() > 0) { Iterator it = hashMap.keySet().iterator(); while (it.hasNext()) { TransportFile transportFile = hashMap.get(it.next()); LogUtils.b("woo file download success: " + transportFile.getFullPath()); transportFile.setUploaded(true); transportFile.setIsModify(false); transportFile.setIsDeleted(false); transportFile.setId(1L); TransportFile selectUnique = TransportFileDbHandler2.getInstance().selectUnique(transportFile); if (selectUnique == null) { TransportFileDbHandler2.getInstance().insert(transportFile); } else { selectUnique.setId(transportFile.getId()); selectUnique.setUploaded(true); selectUnique.setIsModify(false); selectUnique.setModifyTime(transportFile.getModifyTime()); selectUnique.setLastUploadTime(transportFile.getLastUploadTime()); TransportFileDbHandler2.getInstance().update(selectUnique); } } LogUtils.c("文件下载完成"); } OfficialModelFileSynTask.this.c.offer(true); } }); } }