package com.hdl.linkpm.sdk.workbench.databackup.controller;
|
|
|
|
import android.os.Environment;
|
|
import com.google.gson.JsonObject;
|
import com.hdl.hdlhttp.HxHttp;
|
import com.hdl.hdlhttp.callback.HxException;
|
import com.hdl.linkpm.sdk.HDLLinkPMSdk;
|
import com.hdl.linkpm.sdk.core.api.HDLCloudUserApi;
|
import com.hdl.linkpm.sdk.core.bean.PageInfoListBean;
|
import com.hdl.linkpm.sdk.core.callback.IDefaultCallBack;
|
import com.hdl.linkpm.sdk.core.callback.IResponseCallBack;
|
import com.hdl.linkpm.sdk.core.exception.HDLException;
|
import com.hdl.linkpm.sdk.core.response.HDLResponse;
|
import com.hdl.linkpm.sdk.utils.HDLExceptionSubmitUtils;
|
import com.hdl.linkpm.sdk.utils.HDLFileUtils;
|
import com.hdl.linkpm.sdk.utils.HDLGsonUtils;
|
import com.hdl.linkpm.sdk.workbench.databackup.bean.BackupListBean;
|
import com.hdl.linkpm.sdk.workbench.databackup.bean.GatewayBackupBean;
|
|
import java.io.File;
|
import java.util.List;
|
|
import io.reactivex.rxjava3.disposables.Disposable;
|
import io.reactivex.rxjava3.subscribers.DisposableSubscriber;
|
import okhttp3.ResponseBody;
|
|
/**
|
* Created by hxb on 2022/2/23.
|
*/
|
public class DataBackupController {
|
/**
|
* instance
|
*/
|
private volatile static DataBackupController instance;
|
|
/**
|
* getInstance
|
*
|
* @return DataBackupController
|
*/
|
public static synchronized DataBackupController getInstance() {
|
if (instance == null) {
|
synchronized (DataBackupController.class) {
|
if (instance == null) {
|
instance = new DataBackupController();
|
}
|
}
|
}
|
return instance;
|
}
|
|
/**
|
* 上传备份数据
|
*
|
* @param homeId 住宅ID
|
* @param data 上传的数据内容
|
* @param callBack
|
* @return
|
*/
|
public Disposable dataBackupUpload(String homeId, byte[] data, IDefaultCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_BACKUP_UPLOAD + "?houseId=" + homeId;
|
String path = HDLLinkPMSdk.getContext().getExternalFilesDir(Environment.DIRECTORY_DOCUMENTS).getPath() + "/Temp/";
|
String fileName = System.currentTimeMillis() + "";
|
HDLFileUtils.byteToFile(data, path, fileName);
|
File file = new File(path + fileName);
|
|
return HxHttp.builder()
|
.file(file, "file")
|
.url(requestUrl)
|
.build()
|
.upload()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String code) {
|
HDLFileUtils.deleteFile(file);
|
if (callBack != null) {
|
callBack.onSuccess();
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLFileUtils.deleteFile(file);
|
HDLExceptionSubmitUtils.submit(requestUrl, homeId, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 删除备份数据
|
*
|
* @param homeId 住宅ID
|
* @param callBack
|
* @return
|
*/
|
public Disposable databackDel(String homeId, IDefaultCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_BACKUP_DEL;
|
JsonObject json = new JsonObject();
|
json.add("houseIds", HDLGsonUtils.toJsonArray(new String[]{homeId}));
|
return HxHttp.builder()
|
.raw(json.toString())
|
.url(requestUrl)
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String url) {
|
if (null != callBack) {
|
callBack.onSuccess();
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 获取数据最新下载路径
|
*
|
* @param homeId 住宅ID
|
* @param callBack
|
* @return
|
*/
|
public Disposable databackDownload(String homeId,String path, IDefaultCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_BACKUP_DOWNLOAD_URL;
|
JsonObject json = new JsonObject();
|
json.addProperty("houseId", homeId);
|
return HxHttp.builder()
|
.raw(json.toString())
|
.url(requestUrl)
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String url) {
|
HxHttp.builder()
|
.url(url)
|
.build()
|
.download()
|
.subscribe(new DisposableSubscriber<ResponseBody>() {
|
@Override
|
public void onNext(ResponseBody responseBody) {
|
if (HDLFileUtils.writeFile(path, responseBody.byteStream())) {
|
if (null != callBack) {
|
callBack.onSuccess();
|
}
|
} else {
|
if (callBack != null) {
|
callBack.onFailure(new HDLException(HxException.ErrorCode.UNKNOWN, "Download Fail"));
|
}
|
}
|
}
|
|
@Override
|
public void onError(Throwable t) {
|
if (callBack != null) {
|
callBack.onFailure(new HDLException(HxException.ErrorCode.UNKNOWN, t.getMessage()));
|
}
|
}
|
|
@Override
|
public void onComplete() {
|
|
}
|
});
|
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 获取备份列表
|
*
|
* @param userId 用户ID
|
* @param pageNo 开始索引
|
* @param pageSize 页面大小
|
* @param callBack
|
* @return
|
*/
|
public Disposable databackList(String userId,int pageNo, int pageSize, IResponseCallBack<PageInfoListBean<BackupListBean>> callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_BACKUP_LIST;
|
JsonObject json = new JsonObject();
|
json.addProperty("pageNo", pageNo);
|
json.addProperty("pageSize", pageSize);
|
json.addProperty("debugUserId", userId);
|
return HxHttp.builder()
|
.raw(json.toString())
|
.url(requestUrl)
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<PageInfoListBean<BackupListBean>>() {
|
@Override
|
public void onResponse(PageInfoListBean<BackupListBean> response) {
|
if (callBack != null) {
|
callBack.onSuccess(response);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
|
/**
|
* 获取网关最新的三份备份数据
|
*
|
* @param homeId 住宅Id
|
* @param gatewayId 云端上网关gatewayId
|
* @param callBack
|
* @return
|
*/
|
public Disposable getGatewayBackupDataList(String homeId, String gatewayId, IResponseCallBack<List<GatewayBackupBean>> callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_GATEWAY_BACKUP_LIST;
|
JsonObject json = new JsonObject();
|
json.addProperty("spaceCode", homeId);
|
json.addProperty("gatewayId", gatewayId);
|
return HxHttp.builder()
|
.raw(json.toString())
|
.url(requestUrl)
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<List<GatewayBackupBean>>() {
|
@Override
|
public void onResponse(List<GatewayBackupBean> response) {
|
if (callBack != null) {
|
callBack.onSuccess(response);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
/**
|
* 获取调试完成的备份文件回复
|
*
|
* @param homeId 住宅Id
|
* @param gatewayId 云端上网关gatewayId
|
* @param callBack
|
* @return
|
*/
|
public Disposable getDebugGatewayBackupDataList(String homeId, String gatewayId, IResponseCallBack<GatewayBackupBean> callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_GATEWAY_BACKUP_DEBUGCOMPLETEBACKUPFILE;
|
JsonObject json = new JsonObject();
|
json.addProperty("spaceCode", homeId);
|
json.addProperty("gatewayId", gatewayId);
|
return HxHttp.builder()
|
.raw(json.toString())
|
.url(requestUrl)
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<GatewayBackupBean>() {
|
@Override
|
public void onResponse(GatewayBackupBean response) {
|
if (callBack != null) {
|
callBack.onSuccess(response);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
/**
|
* 调试宝选择网关恢复的备份文件
|
*
|
* @param homeId 住宅Id
|
* @param gatewayId 云端上网关gatewayId
|
* @param recordId 备份记录id
|
* @param callBack 回调
|
* @return Disposable
|
*/
|
public Disposable getGatewayBackupRecover(String homeId, String gatewayId,long recordId, IResponseCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_GATEWAY_BACKUP_RECOVER;
|
JsonObject json = new JsonObject();
|
json.addProperty("spaceCode", homeId);
|
json.addProperty("gatewayId", gatewayId);
|
json.addProperty("recordId", recordId);
|
return HxHttp.builder()
|
.raw(json.toString())
|
.url(requestUrl)
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String response) {
|
if (callBack != null) {
|
callBack.onSuccess(response);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
/**
|
* 网关替换
|
*
|
* @param homeId 住宅Id
|
* @param gatewayId 云端上网关gatewayId
|
* @param newMac newMac 新网关mac
|
* @param callBack 回调
|
* @return Disposable
|
*/
|
public Disposable getGatewayReplace(String homeId, String gatewayId,String newMac, IResponseCallBack callBack) {
|
String requestUrl = HDLLinkPMSdk.getUserRegionUrl() + HDLCloudUserApi.POST_GATEWAY_REPLACE;
|
JsonObject json = new JsonObject();
|
json.addProperty("homeId", homeId);
|
json.addProperty("gatewayId", gatewayId);//旧网关id
|
json.addProperty("newMac", newMac);//newMac 新网关mac
|
return HxHttp.builder()
|
.raw(json.toString())
|
.url(requestUrl)
|
.build()
|
.post()
|
.subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String response) {
|
if (callBack != null) {
|
callBack.onSuccess(response);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, json, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
}
|
}
|
});
|
}
|
|
|
}
|
