linux_door/jni/logic/DeviceUpdateLogic.cc

#pragma once
#include "uart/ProtocolSender.h"

#include "manager/ConfigManager.h"
#include "net/NetManager.h"
#include "core/update_assistant.h"
#include "edge/popup_service.h"
#include "base/strings.hpp"
#include "restclient-cpp/restclient.h"
#include "base/http_client.h"
#include "net/tcp_client.h"
#include "os/UpgradeMonitor.h"

#include "core/utilities.h"
#include "core/jhws.h"
#include "service/BusinessConfig.h"
#include "manager/LanguageManager.h"

namespace {
	base::UpdateAssistant assistant;
	base::VersionInfo info;

	enum Timer {
		kTimerProgress,
	};

	int loading_index = 0;
}

Json::Value linuxVersionList;
string updateUrl;
int chooseVersionId;

static void getLinuxVersionList() {
		std::string url = getHttpGateway() + "/util/get_linux_version_list";

		LOGD("请求Linux设备初始化版本列表. url = %s", url.c_str());
		//发起HTTP GET请求
		RestClient::Response r = RestClient::get(url);
		if (r.code != 200) {
			LOGD("请求Linux设备初始化版本列表-> 错误代码： %d", r.code);
			return;
		}

		LOGD("获得Linux设备初始化版本列表. result = %s", r.body.c_str());
		//解析json
		Json::Reader reader;
		Json::Value root;

		if(reader.parse(r.body, root, false)) {
			linuxVersionList = root;
			mDeviceTypeListViewPtr->refreshListView();
		}
	}


void NavibarSetProgressWindowVisible(bool visible) {
	mProgressWindowPtr->setVisible(visible);
}

void NavibarSetDialog1WindowVisible(bool visible) {
	mDialogWindowPtr->setVisible(visible);
}

void NavibarSetProgressMessage(const std::string& msg) {
	mProgressMessageTextViewPtr->setText(msg);
}

void NavibarSetDialog1Message(const std::string& msg) {
	mDialogTextViewPtr->setText(msg);
}

void NavibarProgressAnimation(bool visible) {
	mProgressLoadingTextViewPtr->setVisible(visible);
	if (visible) {
		loading_index = 0;
		mActivityPtr->registerUserTimer(kTimerProgress, 100);
		return;
	}
	mActivityPtr->unregisterUserTimer(kTimerProgress);
}

void NavibarDialog1ClickOk() {
	while (PopupService::instance()->busy_) {
		PopupService::instance()->busy_ = false;
	}
	//EASYUICONTEXT->hideNaviBar();
}

void updateDevice(){
	PopupService::Show([](PopupService* srv){

		base::HttpClient client;
		client.SetConnectionTimeout(5000);
		client.SetTimeout(120 * 1000);

		std::string url = getHttpGateway() + "/" + info.url.c_str();
		LOGD("请求更新文件的url： %s", url.c_str());

		base::HttpRequest req("GET", url, "");	// 去获取文件
		const char* tmp_file = "/tmp/update.img";
		base::HttpResponse response =
			client.Do(req, tmp_file, [srv, info](int64_t dltotal,
			int64_t dlnow, int64_t ultotal, int64_t ulnow){
	      LOGD("downloading %lld/%lld", dlnow, dltotal);

	      string msg = LANGUAGEMANAGER->getValue("Downloading") + " %.0f%%";
		  srv->SetMessage(base::format(msg.c_str(),
			  dltotal == 0 ? 0 : (dlnow * 1.0/dltotal * 100)));
		  return 0;
		});

		if (response.StatusCode() != 200) {	// 下载失败
			string msg = LANGUAGEMANAGER->getValue("DownloadFailed") + "%d";
		  srv->SetMessage(base::format(msg.c_str(), response.ErrorCode()));
		  return -1;
		}

		// TODO: 应该去判断一下，下载的版本是否真的大于当前版本号
		UpgradeMonitor::getInstance()->checkUpgradeFile("/mnt/extsd");
		LOGD("img版本-> %s", "");

		system("touch /tmp/zkautoupgrade");
		UPGRADEMONITOR->checkUpgradeFile("/tmp");

//		const char* msg = "-1";
//		TcpClient::instance()->sendMsg(msg);
		return 0;
	});
}

void openInitWindow() {
	getLinuxVersionList();

	chooseVersionId = 0;
	mInitWindowPtr->showWnd();
}


/**
 * 注册定时器
 * 填充数组用于注册定时器
 * 注意：id不能重复
 */
static S_ACTIVITY_TIMEER REGISTER_ACTIVITY_TIMER_TAB[] = {
	//{0,  6000}, //定时器id=0, 时间间隔6秒
	//{1,  1000},
};

/**
 * 当界面构造时触发
 */
static void onUI_init(){
//	mVersionPtr->setText(StoragePreferences::getString(WDKL_VERSION, GetVersion()));
//	int currentVersionNo = StoragePreferences::getInt(JHWS_VERSION_NUMBER, GetVersionNo());

	std::string currentVersion = getVersion();
	int currentVersionNo = getVersionNo();

	mVersionPtr->setText(currentVersion);	// 写入界面的版本
	mVersionNoPtr->setText(to_string(currentVersionNo));	// 写入界面的版本号
	mProgressWindowPtr->setVisible(false);
	mDialogWindowPtr->setVisible(false);
	mInitWindowPtr->hideWnd();
}

/**
 * 当切换到该界面时触发
 */
static void onUI_intent(const Intent *intentPtr) {
    if (intentPtr != NULL) {
    	std::string _appUpdate = intentPtr->getExtra(appUpdate);
    	if (_appUpdate == "true") {
    		int ret = assistant.GetLatest("bed", &info);
//    		int currentVersionNo = StoragePreferences::getInt(JHWS_VERSION_NUMBER, GetVersionNo());
    		int currentVersionNo = getVersionNo();
			LOGD("from server : %s %d, from device: %d", info.version.c_str(), info.versionNo, currentVersionNo);
			if (currentVersionNo < info.versionNo) {
				updateDevice();
			}
    	}
    }
}

/*
 * 当界面显示时触发
 */
static void onUI_show() {

}

/*
 * 当界面隐藏时触发
 */
static void onUI_hide() {

}

/*
 * 当界面完全退出时触发
 */
static void onUI_quit() {

}

/**
 * 串口数据回调接口
 */
static void onProtocolDataUpdate(const SProtocolData &data) {

}

/**
 * 定时器触发函数
 * 不建议在此函数中写耗时操作，否则将影响UI刷新
 * 参数： id
 *         当前所触发定时器的id，与注册时的id相同
 * 返回值: true
 *             继续运行当前定时器
 *         false
 *             停止运行当前定时器
 */
static bool onUI_Timer(int id){
	switch (id) {
		case kTimerProgress: {
				loading_index = (loading_index + 1) % 8;
				mProgressLoadingTextViewPtr->setBackgroundPic(
						base::format("loading/%d.png", loading_index).c_str());
			}
			break;
		default:
			break;
	}
    return true;
}

/**
 * 有新的触摸事件时触发
 * 参数：ev
 *         新的触摸事件
 * 返回值：true
 *            表示该触摸事件在此被拦截，系统不再将此触摸事件传递到控件上
 *         false
 *            触摸事件将继续传递到控件上
 */
static bool ondeviceUpdateActivityTouchEvent(const MotionEvent &ev) {
    switch (ev.mActionStatus) {
		case MotionEvent::E_ACTION_DOWN://触摸按下
			//LOGD("时刻 = %ld 坐标  x = %d, y = %d", ev.mEventTime, ev.mX, ev.mY);
			break;
		case MotionEvent::E_ACTION_MOVE://触摸滑动
			break;
		case MotionEvent::E_ACTION_UP:  //触摸抬起
			break;
		default:
			break;
	}
	return false;
}
static bool onButtonClick_sys_back(ZKButton *pButton) {
    LOGD(" ButtonClick sys_back !!!\n");
    return false;
}

static int getListItemCount_DeviceTypeListView(const ZKListView *pListView) {
    //LOGD("getListItemCount_DeviceTypeListView !\n");
	if (linuxVersionList.size() > 4) {
		return linuxVersionList.size();
	}
    return 4;
}

static void obtainListItemData_DeviceTypeListView(ZKListView *pListView,ZKListView::ZKListItem *pListItem, int index) {
    //LOGD(" obtainListItemData_ DeviceTypeListView  !!!\n");
	string version = linuxVersionList[index]["type_name"].asString() + "         " + linuxVersionList[index]["version_code"].asString();
		if (version != "         ") {
			pListItem->setText(version);
		}
		else {
			pListItem->setText("");
		}

		if (index == chooseVersionId) {
			updateUrl = linuxVersionList[chooseVersionId]["app_path"].asString();
			pListItem->setSelected(true);
		}
		else {
			pListItem->setSelected(false);
		}
}

static void onListItemClick_DeviceTypeListView(ZKListView *pListView, int index, int id) {
    //LOGD(" onListItemClick_ DeviceTypeListView  !!!\n");
	chooseVersionId = index;
	updateUrl = linuxVersionList[index]["app_path"].asString();
}

static bool onButtonClick_BackButton(ZKButton *pButton) {
    LOGD(" ButtonClick BackButton !!!\n");
    mInitWindowPtr->hideWnd();
    return false;
}
static bool onButtonClick_FindBackButton(ZKButton *pButton) {
    LOGD(" ButtonClick FindBackButton !!!\n");
    EASYUICONTEXT->goBack();
    return false;
}

static bool onButtonClick_UpdateButton(ZKButton *pButton) {
    LOGD(" ButtonClick UpdateButton !!!\n");
    PopupService::Show([](PopupService* srv){
		string msg = LANGUAGEMANAGER->getValue("Searching");
		srv->SetMessage(msg);
		if (!NETMANAGER->getEthernetManager()->isConnected()) {
			std::string msg = LANGUAGEMANAGER->getValue("EthernetDisconnect");
		  srv->SetMessage(msg);
		  return -1;
		}
		int ret = assistant.GetLatest("bed", &info);
		if (ret != 0) {
		  LOGE("get latest failed ret %d", ret);
		  msg = LANGUAGEMANAGER->getValue("GetVersionFailed") + "%d";
		  srv->SetMessage(base::format(msg.c_str(), ret));
		  return ret;
		}

//		int currentVersionNo = StoragePreferences::getInt(JHWS_VERSION_NUMBER, GetVersionNo());
		int currentVersionNo = getVersionNo();
//		LOGD("from server : %s %d, from device: %d", info.version.c_str(), info.versionNo, currentVersionNo);
		LOGD("更新版本，服务器版本-> %s， 版本号-> %d, 本机版本号-> %d", info.version.c_str(), info.versionNo, currentVersionNo);
		if (currentVersionNo >= info.versionNo) {	// 判断本身的版本大于新的版本时，不进行升级
			msg = LANGUAGEMANAGER->getValue("IsTheLastVersion");	// 已经是最新版本

		  srv->SetMessage(msg);
		  return -1;
		}

		mVersionNewPtr->setText(info.version);
		mVersionNoNewPtr->setText(to_string(info.versionNo));
		mFindWindowPtr->showWnd();
		return 0;
	});
    return false;
}

static bool onButtonClick_InitButton(ZKButton *pButton) {
    LOGD(" ButtonClick InitButton !!!\n");
    Intent* intent = new Intent();
	intent->putExtra(functionWindows, "init");
	EASYUICONTEXT->openActivity("functionActivity", intent);
    return false;
}

static bool onButtonClick_InstantlyButton(ZKButton *pButton) {
    LOGD(" ButtonClick InstantlyButton !!!\n");
    updateDevice();
    return false;
}

static bool onButtonClick_DialogButton(ZKButton *pButton) {
    LOGD(" ButtonClick DialogButton !!!\n");
    return false;
}

static bool onButtonClick_InitUpdateButton(ZKButton *pButton) {
    LOGD(" ButtonClick InitUpdateButton !!!\n");
    // 小于的时候，代表在linuxVersionList里面
	if (updateUrl != "") {
		mProgressWindowPtr->showWnd();

		PopupService::Show([](PopupService* srv){

			base::HttpClient client;
			client.SetConnectionTimeout(5000);
			client.SetTimeout(120 * 1000);

			std::string url = getHttpGateway() + "/" + updateUrl;
			LOGD("请求更新文件的url： %s", url.c_str());

			base::HttpRequest req("GET", url, "");	// 去获取文件
			const char* tmp_file = "/tmp/update.img";
			base::HttpResponse response =
				client.Do(req, tmp_file, [srv, info](int64_t dltotal,
				int64_t dlnow, int64_t ultotal, int64_t ulnow){
			  LOGD("downloading %lld/%lld", dlnow, dltotal);

			  string msg = LANGUAGEMANAGER->getValue("Downloading") + " %.0f%%";
			  srv->SetMessage(base::format(msg.c_str(),
				  dltotal == 0 ? 0 : (dlnow * 1.0/dltotal * 100)));
			  return 0;
			});

			if (response.StatusCode() != 200) {	// 下载失败
				string msg = LANGUAGEMANAGER->getValue("DownloadFailed") + "%d";
			  srv->SetMessage(base::format(msg.c_str(), response.ErrorCode()));
			  mProgressWindowPtr->hideWnd();
			  return -1;
			}

			// TODO: 应该去判断一下，下载的版本是否真的大于当前版本号
			UpgradeMonitor::getInstance()->checkUpgradeFile("/mnt/extsd");
			LOGD("img版本-> %s", "");

			const char* msg = "-1";
			TcpClient::instance()->sendMsg(msg);
			system("touch /tmp/zkautoupgrade");
			UPGRADEMONITOR->checkUpgradeFile("/tmp");
			return 0;
		});
	}
    return false;
}