linux_door/jni/logic/updateLogic.cc

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

#include <sys/sysinfo.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"
/*
*此文件由GUI工具生成
*文件功能：用于处理用户的逻辑相应代码
*功能说明：
*========================onButtonClick_XXXX
当页面中的按键按下后系统会调用对应的函数，XXX代表GUI工具里面的[ID值]名称，
如Button1,当返回值为false的时候系统将不再处理这个按键，返回true的时候系统将会继续处理此按键。比如SYS_BACK.
*========================onSlideWindowItemClick_XXXX(int index) 
当页面中存在滑动窗口并且用户点击了滑动窗口的图标后系统会调用此函数,XXX代表GUI工具里面的[ID值]名称，
如slideWindow1;index 代表按下图标的偏移值
*========================onSeekBarChange_XXXX(int progress) 
当页面中存在滑动条并且用户改变了进度后系统会调用此函数,XXX代表GUI工具里面的[ID值]名称，
如SeekBar1;progress 代表当前的进度值
*========================ogetListItemCount_XXXX() 
当页面中存在滑动列表的时候，更新的时候系统会调用此接口获取列表的总数目,XXX代表GUI工具里面的[ID值]名称，
如List1;返回值为当前列表的总条数
*========================oobtainListItemData_XXXX(ZKListView::ZKListItem *pListItem, int index)
 当页面中存在滑动列表的时候，更新的时候系统会调用此接口获取列表当前条目下的内容信息,XXX代表GUI工具里面的[ID值]名称，
如List1;pListItem 是贴图中的单条目对象，index是列表总目的偏移量。具体见函数说明
*========================常用接口===============
*LOGD(...)  打印调试信息的接口
*mTextXXXPtr->setText("****") 在控件TextXXX上显示文字****
*mButton1Ptr->setSelected(true); 将控件mButton1设置为选中模式，图片会切换成选中图片，按钮文字会切换为选中后的颜色
*mSeekBarPtr->setProgress(12) 在控件mSeekBar上将进度调整到12
*mListView1Ptr->refreshListView() 让mListView1 重新刷新，当列表数据变化后调用
*mDashbroadView1Ptr->setTargetAngle(120) 在控件mDashbroadView1上指针显示角度调整到120度
*
* 在Eclipse编辑器中  使用 “alt + /”  快捷键可以打开智能提示
*/

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

	enum Timer {
		kTimerProgress,
	};

	int loading_index = 0;
}

Json::Value linuxVersionList;
string updateUrl;
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) {
	mWindowProgressPtr->setVisible(visible);
}

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

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

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

void NavibarProgressAnimation(bool visible) {
	mTextViewProgressLoadingPtr->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();
}

struct sysinfo info2;
static bool isUpdate = false;
bool getIsUpdate() {
	return isUpdate;
}

void updateDevice(){

    sysinfo(&info2);
    LOGD("关闭页面前，totalram == %ld", info2.totalram);
    LOGD("关闭页面前，freeram == %ld", info2.freeram);

	EASYUICONTEXT->closeActivity("mianActivity");
	EASYUICONTEXT->closeActivity("callActivity");
	EASYUICONTEXT->closeActivity("settingActivity");
	EASYUICONTEXT->closeActivity("sipTestActivity");
	EASYUICONTEXT->closeActivity("ui3Activity");
	EASYUICONTEXT->closeActivity("warnActivity");

    sysinfo(&info2);
    LOGD("关闭页面后，存在延迟，totalram == %ld", info2.totalram);
    LOGD("关闭页面后，存在延迟，freeram == %ld", info2.freeram);

    isUpdate = true;

	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());

        sysinfo(&info2);
        LOGD("进行下载前，totalram == %ld", info2.totalram);
        LOGD("进行下载前，freeram == %ld", info2.freeram);

		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()));
		  isUpdate = false;
		  return -1;
		}

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

		const char* msg = "-1";
		TcpClient::instance()->sendMsg(msg);
		TcpClient::instance()->closeTcp();

//		ReleaseTelephone();

		pingThreadExitPending();

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

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

/**
 * 当界面构造时触发
 */
static void onUI_init(){
    //Tips :添加 UI初始化的显示代码到这里,如:mText1Ptr->setText("123");

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

	mVersionPtr->setText(currentVersion);	// 写入界面的版本
	mVersionNoPtr->setText(to_string(currentVersionNo));	// 写入界面的版本号
	mWindowProgressPtr->setVisible(false);
	mWindowDialog1Ptr->setVisible(false);
}

/**
 * 当切换到该界面时触发
 */
static void onUI_intent(const Intent *intentPtr) {
    sysinfo(&info2);
    LOGD("跳转到升级页面，totalram == %ld", info2.totalram);
    LOGD("跳转到升级页面，freeram == %ld", info2.freeram);

    isUpdate = false;

    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();
			}
			else {
				EASYUICONTEXT->closeActivity("updateActivity");
			}
    	}
    }
}

/*
 * 当界面显示时触发
 */
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;
				mTextViewProgressLoadingPtr->setBackgroundPic(
						base::format("loading/%d.png", loading_index).c_str());
			}
			break;

		default:
			break;
	}
    return true;
}

/**
 * 有新的触摸事件时触发
 * 参数：ev
 *         新的触摸事件
 * 返回值：true
 *            表示该触摸事件在此被拦截，系统不再将此触摸事件传递到控件上
 *         false
 *            触摸事件将继续传递到控件上
 */
static bool onupdateActivityTouchEvent(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 bool onButtonClick_ButtonUpdate(ZKButton *pButton) {
    LOGD(" ButtonClick ButtonUpdate !!!\n");
    mWindow1Ptr->hideWnd();

    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);
		  mWindow1Ptr->showWnd();
		  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);
		  mWindow1Ptr->showWnd();
		  return -1;
		}

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

    return false;
}

static bool onButtonClick_ButtonInstantly(ZKButton *pButton) {
    LOGD(" ButtonClick ButtonInstantly !!!\n");
    updateDevice();
    return false;
}
static bool onButtonClick_ButtonDialog1(ZKButton *pButton) {
    LOGD(" ButtonClick ButtonDialog1 !!!\n");
    return false;
}
static bool onButtonClick_ButtonInit(ZKButton *pButton) {
    LOGD(" ButtonClick ButtonInit !!!\n");
//	getLinuxVersionList();
//  mWindowInitPtr->showWnd();
	mWindowPwdPtr->showWnd();
    return false;
}
static int getListItemCount_DeviceTypeListView(const ZKListView *pListView) {
    //LOGD("getListItemCount_DeviceTypeListView !\n");
	if (linuxVersionList.size() > 5) {
		return linuxVersionList.size();
	}
    return 5;
}

static void obtainListItemData_DeviceTypeListView(ZKListView *pListView,ZKListView::ZKListItem *pListItem, int index) {
    //LOGD(" obtainListItemData_ DeviceTypeListView  !!!\n");
	ZKListView::ZKListSubItem* down = pListItem->findSubItemByID(ID_UPDATE_DownSubItem);

	string version = linuxVersionList[index]["type_name"].asString() + "         " + linuxVersionList[index]["version_code"].asString();
	if (version != "         ") {
		pListItem->setText(version);
		down->setText(LANGUAGEMANAGER->getValue("SoftDown"));
	}
	else {
		pListItem->setText("");
		down->setText("");
	}
}

static void onListItemClick_DeviceTypeListView(ZKListView *pListView, int index, int id) {
    //LOGD(" onListItemClick_ DeviceTypeListView  !!!\n");

	// 小于的时候，代表在linuxVersionList里面
	if (linuxVersionList[index]["app_path"].asString() != "") {
		mWindowProgressPtr->showWnd();
		updateUrl = linuxVersionList[index]["app_path"].asString();

		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()));
			  mWindowProgressPtr->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;
		});
	}
}

static bool onButtonClick_BackButton(ZKButton *pButton) {
    LOGD(" ButtonClick BackButton !!!\n");
    mWindowInitPtr->hideWnd();
    return false;
}
static bool onButtonClick_FindBackButton(ZKButton *pButton) {
    LOGD(" ButtonClick FindBackButton !!!\n");
    EASYUICONTEXT->goBack();
    return false;
}
static void onEditTextChanged_EditTextPwd(const std::string &text) {
    //LOGD(" onEditTextChanged_ EditTextPwd %s !!!\n", text.c_str());
}

static bool onButtonClick_BtnPwdConfirm(ZKButton *pButton) {
    LOGD(" ButtonClick BtnPwdConfirm !!!\n");

    string pwd = mEditTextPwdPtr->getText();
	// 密码为666
	string cpwd = "666";
    if (pwd == cpwd){
    	getLinuxVersionList();
    	mWindowPwdPtr->hideWnd();
        mWindowInitPtr->showWnd();
		return false;
    } else {
    	mTextPwdInfoPtr->setTextTr("PasswordWrong");
    }
    return false;
}