万物互联iot，你准备好了嘛

前言

之前我们介绍了如何在涂鸦智能平台创建智能设备， 以及开发环境搭建， 今天我们就来分析源码，一步步了解对接涂鸦云过程以及API接口，文章所涉及的工程源码，我会上传到我的github：，需要的小伙伴自行下载。喜欢diy的小伙伴可以参考此工程，结合以下的源码分析，可以改造成自己的智能设备，实现远程控制。好了，进入我们的正题~

分析首先需要知道应用入口函数是： OPERATE_RET device_init(VOID) ，在device.c文件中。

	OPERATE_RET device_init(VOID){	OPERATE_RET op_ret;		PR_NOTICE("fireware info name:%s version:%s", APP_BIN_NAME, USER_SW_VER);	//Product_Init();  //1. 涂鸦设备初始化， 参数： pid， app控制回调	op_ret = tuya_device_init(PRODECT_KEY, device_cb, USER_SW_VER);	if (op_ret != OPRT_OK)	{		return op_ret;	}		tuya_active_reg(syn_active_data);	op_ret = sys_add_timer(syn_timer_cb, NULL, &Syntimer);    if(OPRT_OK != op_ret) 	{		PR_ERR("add syn_timer err");    	return op_ret;    }	else 	{    	sys_start_timer(Syntimer, SYN_TIME*1000, TIMER_CYCLE);    }	Product_Init();		op_ret = device_differ_init();	if (op_ret != OPRT_OK)	{		return op_ret;	}	return op_ret;}

分析：

1. tuya_device_init(PRODECT_KEY, device_cb, USER_SW_VER);

功能：该函数主要完成涂鸦设备初始化。

参数1：设备pid，pid在涂鸦平台创建智能设备时获取，大家根据自己创建的设备为准

参数2：在app操作，下发指令给设备的回调函数：

VOID device_cb(SMART_CMD_E cmd,cJSON *root){	CHAR *buf = cJSON_PrintUnformatted(root);	if (NULL == buf)	{		PR_ERR("malloc error");		return;	}	PR_DEBUG("root cmd:%s",buf);	//实际控制设备	device_ControlByApp(root);		Free(buf);}

如：上述例子中的， 将收到的指令传递给device_ControlByApp(root)函数，完成实际对设备的控制：

/************************************************************  Function: Motor_ControlByApp*  Description: 接受app控制处理函数*  Input: root命令*  Output: *  Return: ***********************************************************/void device_ControlByApp(cJSON *root){		cJSON *cmd = cJSON_GetObjectItem(root, DP_control);	//DP_control是在涂鸦平台定义的数据点	if(cmd != NULL){		switch_dev.statu = (bool)cmd->valueint;			tuya_write_gpio_level(WF_SWITCH_GPIO_PIN, switch_dev.statu);	}	cmd = cJSON_GetObjectItem(root, DP_delayoff);////DP_delayoff是在涂鸦平台定义的数据点	if(cmd != NULL){		switch_dev.delayoff = cmd->valueint;	}	PostSemaphore(Upload_SemHandle);}

说明：DP_control 和 DP_delayoff 是在涂鸦平台定义的设备数据点：

PostSemaphore(Upload_SemHandle); 是 二值信号量(作用：任务同步，因为我们在另外开了一个任务，专门用于上报设备状态，如下代码)，用于上报设备状态的， 这里我们控制完设备后， 就应该主动上报下设备状态，以便app能实时。

//================上报设备状态的任务====================void MSG_Upload_Poll_Task(PVOID pArg){		OPERATE_RET ret;	  //创建信号量	Upload_SemHandle = CreateSemaphore();	if(Upload_SemHandle == NULL)	{		PR_ERR("Create Upload_Sem failed");			ThrdJoin(Upload_TaskHandle, NULL);		return;	}  //初始化为二值信号量，且初始化值为0	InitSemaphore(Upload_SemHandle, 0, 1);	  //创建互斥量，用于上报设备状态时加锁(这里可以省去，不影响）	ret = CreateMutexAndInit(&Upload_mutexHandle);	if(ret != OPRT_OK)	{		PR_ERR("Create Upload_Mutex failed");			ThrdJoin(Upload_TaskHandle, NULL);		return;	}		while(1)	{    //一直等待信号量，等到了就上报设备状态		if(WaitSemaphore(Upload_SemHandle) == OPRT_OK)		{			ret = msg_upload_proc();			if(ret != OPRT_OK)				PR_ERR("***msg_upload failed!***");		}			}}

其中msg_upload_proc();就是实现设备状态上报：

/************************************************************  Function: msg_upload_proc*  Description: dp上报函数*  Input: *  Output: *  Return: ***********************************************************/INT msg_upload_proc(void){	OPERATE_RET err;  //判断连接涂鸦云的状态，如果是断开的，也就没必要上报了	if(tuya_get_cloud_stat() == FALSE)		return OPRT_DP_REPORT_CLOUD_ERR;	MutexLock(Upload_mutexHandle);//判断wifi连接状态，如果不是正常连接，那也没必要上报了    GW_WIFI_STAT_E wf_stat = tuya_get_wf_status();    if(STAT_UNPROVISION == wf_stat || \       STAT_STA_UNCONN == wf_stat || \       (tuya_get_gw_status() != STAT_WORK)) {		err = OPRT_WF_CONN_FAIL;		goto exit;    }//================以下是设备数据点格式转化==================	cJSON *root = cJSON_CreateObject();    if(NULL == root) {		err = OPRT_BUF_NOT_ENOUGH;        goto exit;    }	//根据实际情况上报设备数据点	cJSON_AddBoolToObject(root, DP_control, switch_dev.statu);	cJSON_AddNumberToObject(root, DP_delayoff, switch_dev.delayoff);	    CHAR *out = cJSON_PrintUnformatted(root);    cJSON_Delete(root);    if(NULL == out) {        PR_ERR("cJSON_PrintUnformatted err:");		    err = OPRT_CJSON_PARSE_ERR;        goto exit;    }    	PR_DEBUG("out[%s]", out);//=======================end===========================//最终调用该函数实现数据点上报    OPERATE_RET op_ret = tuya_obj_dp_trans_report(out);    Free(out);        if( OPRT_OK == op_ret ) {		err = OPRT_OK;        goto exit;    }else {		PR_DEBUG("msg upload error");		err = OPRT_DP_REPORT_CLOUD_ERR;       	goto exit;    }exit:	MutexUnLock(Upload_mutexHandle);	return err;}

以上我们完成了设备控制和状态上报功能。

回到device_init用户主函数中，接着继续分析下面的代码：

tuya_active_reg(syn_active_data);

该函数作用是：当设备连接涂鸦云成功激活的回调函数，主要是上报下设备状态，相当于设备重新上电启动连接云端时，同步下app显示的设备状态。

参数： syn_active_data

STATIC VOID syn_active_data(VOID){	PR_DEBUG("sys active data");	if(tuya_get_cloud_stat())		PostSemaphore(Upload_SemHandle);	else		PR_DEBUG("cloud unconnect !!!");}

其函数主要是判断下设备是否成功连接云端，如果不是，则直接退出，如果是，则上报设备状态。

继续device_init代码块：

op_ret = sys_add_timer(syn_timer_cb, NULL, &Syntimer);    if(OPRT_OK != op_ret) 	{		PR_ERR("add syn_timer err");    	return op_ret;    }	else 	{    	sys_start_timer(Syntimer, SYN_TIME*1000, TIMER_CYCLE);    }

以上是开启一个定时器， 每2秒(SYN_TIME*1000)去查询连接云端状态，我们看下定时器的回调函数：

STATIC VOID syn_timer_cb(UINT timerID,PVOID pTimerArg){	PR_DEBUG("syn timer cb ...");	if( FALSE == tuya_get_cloud_stat() ) {        return;    }	PostSemaphore(Upload_SemHandle); 	sys_stop_timer(Syntimer);}

可以看到其作用和上面的syn_active_data一样， 只是定时器是主动查询。

Product_Init();

void Product_Init(void){  //设备初始化	memset(&switch_dev, 0x0, sizeof(switch_dev));	//设置GPIO	PIN_FUNC_SELECT(WF_SWITCH_GPIO_MUX, WF_SWITCH_GPIO_FUNC);	GPIO_DIS_OUTPUT(WF_SWITCH_GPIO_PIN);//设置成输入模式	//内部实现了按键轮询事件(实现了一键配网功能， 具体见代码)	Key_Init();	OPERATE_RET op_ret;//用于延迟关闭检测定时器	op_ret = sys_add_timer(Timer_delayoff, NULL, &delayoffTimer);    if(OPRT_OK != op_ret) {		PR_ERR("add Timer_TaskKEY err");    	//return op_ret;    }else{		sys_start_timer(delayoffTimer, 1000, TIMER_CYCLE);	}    	}

该函数是我们自己定义实现的，其函数内部主要是初始化了相关的gpio， 以及按键轮询事件定时器，主要是为了实现一键配网功能（以便更换一个网络，再次对设备进行配网）

其中switch_dev是设备属性的结构体，用于管理设备(我这里是开关为例子)，

device_init主函数中的最后一个函数device_differ_init：

op_ret = device_differ_init();	if (op_ret != OPRT_OK)	{		return op_ret;	}

其作用是设备的一些个性化初始化， 其实和上面的Product_Init()函数一样，只是涂鸦sdk规范了结构而已。 具体看代码：

STATIC OPERATE_RET device_differ_init(VOID){	OPERATE_RET op_ret;	TIMER_ID timer;	CreateAndStart(&Upload_TaskHandle, MSG_Upload_Poll_Task, NULL, 2048, TRD_PRIO_2, "msg_upload_task");		op_ret = sys_add_timer(wfl_timer_cb, NULL, &timer);	if (OPRT_OK != op_ret)	{		return op_ret;	}	else	{		sys_start_timer(timer, 300, TIMER_CYCLE);	}		return OPRT_OK;}

可以看到在这里我们创建了上面提及的设备状态上报任务MSG_Upload_Poll_Task， 以及创建了一个wifi状态定时查询的定时器：

STATIC VOID wfl_timer_cb(UINT timerID, PVOID pTimerArg){	STATIC UINT last_wf_stat = 0xffffffff;	GW_WIFI_STAT_E wf_stat = tuya_get_wf_status();	//The system is about to restart without monitoring！	if (last_wf_stat != wf_stat)	{		PR_DEBUG("wf_stat:%d",wf_stat);		switch (wf_stat)		{			case STAT_UNPROVISION:				PR_DEBUG("STAT_UNPROVISION");				break;			case STAT_AP_STA_UNCONN:			case STAT_AP_STA_CONN:				PR_DEBUG("STAT_AP_STA_UNCONN");				break;			case STAT_STA_CONN:				PR_DEBUG("STAT_STA_CONN");				break;			default:				break;		}		last_wf_stat = wf_stat;	}}

在wifi定时查询状态回调中，可以实现不同状态，不同led状态显示， 方便用户根据led状态，知道设备目前是处于啥情况，是断网了呢， 还是成功连接着路由器，还是断开了云端等等（根据自己的情况处理即可）。

编译下载，控制设备

至此，主线的代码已经简单分析完了，剩余一些，如一键配网等函数，很简单，大家可以自行查阅代码，有任何不明白的都可私信或直接在github中提问都可。接下来我们就编译我们的工程，

根据上一篇的开发环境搭建，我们打开虚拟机，进入到sdk下的app，输入以下指令：

sh build_app.sh wifi_switch 1.0.0

编译过程：

可以到sdk路径/bin/upgrade目录中，查看我们编译得到的固件

说明：wifi_switch(1)_1.0.0.bin 是 烧录固件

wifi_switch(2)_1.0.0.bin 是OTA在线升级固件

接着我们烧录我们的固件，打开乐鑫的下载工具：ESPFlashDownloadTool_v3.6.4.exe

根据以下设置(TYWE1S模组，若使用其他模组，根据实际情况下载)：

好了，看到“FINSH 完成”就表明下载成功， 接着下载涂鸦智能app(可到涂鸦官网或手机应用搜索”涂鸦智能“自行下载，这里不方便贴出二维码~~)

打开app后，我们可以使用“手动搜索” 或 ”自动搜索“ 添加设备(当然此时设备要上电啦~)

成功添加后，可以进入我们的设备控制主界面：

之后我们就可以进行控制啦~ （同时我们可以将设备连接电脑串口，观察app控制时，串口接收到数据）

小结

好了，以上就是涂鸦sdk源码分析和下载验证，相信经过上面的介绍，小伙伴参看代码可以一步步实现自己的智能设备啦，开始行动吧~， 当然有什么不明白的地方，可以私信或下方评论。 另外如果大家对sdk这种方式理解有点困难(涉及一些操作系统知识，如信号量，互斥量，任务等概念)， 之后我会另开一篇文章介绍如何使用mcu串口对接， 方便大家更好的入手。 OK， 今天先到此，感兴趣的小伙伴记得关注，收藏，转发~