Network-Modules/Drivers/Modules/bc260y/Bc260y_Regist.c

#include "CONFIG.h"
#if  BC260Y

#include "stm32f10x.h"
#include "Regist.h"
#include "FlashSetup.h"
#include <stdio.h>
#include <stdarg.h>
#include <string.h>
#include <stdlib.h>
#include "cJSON.h"
#include "mbedtls_util.h"
#include "Log_Module.h"
#include "At_Module.h"
#include "Common_Util.h"
#include "Tuoreniot.h"

#include "bc260y.h"

// 泵号
extern uint8_t mcu_id[8];
// socket ID
static uint8_t connectID = 2;

// 注册参数
static struct TUORENIOT_RegistRequestStruct regist_request = {
	.version = 1,
	.platform = "aliyun",
	.networkProtocol = "CoAP",
	.deviceId = "3431228A1936013C",
	.userId = 4562
};

// dns
static char pridnsaddr[20];


/**
* 
*注册参数信息打包
*/
void TUORENIOT_PackRegistRequest(uint8_t * pack_data, uint16_t * pack_data_length, struct TUORENIOT_RegistRequestStruct * registParams)
{
	
	Log_Printf_Debug("mcu_id: %s\r\n", mcu_id);
	byteToHexStr(mcu_id, registParams->deviceId, sizeof(mcu_id));

	sprintf((char *)(pack_data + 2), "{\"platform\":\"%s\",\"connectionType\":\"%s\",\"deviceId\":\"%s\"}", 
	registParams->platform, registParams->networkProtocol, registParams->deviceId); // 拼接AT指令
	Log_Printf_Debug("%s\r\n", (char *)(pack_data + 2));
	
	uint16_t datalen = utils_aes128_ECB_base64_enc_with_length(regist_key, (pack_data + 2));
	
	pack_data[0] = datalen>>8;//头2个字节赋值数据长度
	pack_data[1] = datalen;

	* pack_data_length = datalen + 2;
}


// 函数声明
static void REGIST_Process(void); // 注册流程
static void REGIST_SetStatus(enum REGIST_StatusEnum status); // 设置注册状态
static void REGIST_SetResult(enum REGIST_ResultEnum result); // 设置注册结果

static void goto_start(void); // 开始
static void goto_success(void); // 成功
static void goto_failure(char * _info); // 失败
static void goto_finish(void); // 结束


// 流程
enum Step{
	STEP_FINISH, // 结束
	STEP_START, // 开始
	STEP_EXIT_SLEEP, // 退出睡眠
	STEP_WAIT, // 等待
	
	STEP_STATE, // 查询状态
	STEP_OPEN, // 打开
	STEP_SET_SLEEP, // 设置休眠
	
	STEP_SET_QISDE_0, // 关闭发送回显
	STEP_SET_QISDE_1, // 打开发送回显
	STEP_SEND, // 发送
	STEP_RECV, // 等待发送结果
	
	STEP_QUERY_CFUN, // 查询功能模式
	STEP_SET_CFUN_0, // 设置最小功能模式
	STEP_SET_CFUN_1, // 设置全功能模式
	
	STEP_SET_CEREG_2, // 设置ps域允许上报网络注册和位置信息
	STEP_QUERY_CEREG, // 查询网络注册状态
	STEP_DATAFORMAT, // 配置发送格式
	
	STEP_CLOSE, // 关闭
	
	STEP_SUCCESS, // 成功
	STEP_FAILURE, // 失败
	STEP_QUERY_DNS, // 查询DNS
	STEP_SET_DNS, // 设置DNS
};

// 步骤跳转时的监听
static uint8_t STEP_SET_CFUN_1_times = 0; // 全功能模式的次数
static uint16_t goto_step_event(uint16_t ns)
{
	// 重置bc260y状态
	bc260y.reset();
	
	// 流程控制
	uint16_t step = ns;
	if(ns == STEP_SET_CFUN_1 && STEP_SET_CFUN_1_times++ >= 1)
	{
		goto_failure("重新联网次数过多");
		step = STEP_FAILURE;
	}
	return step;
}

// 流程控制
static struct PCTRL_Struct pctrl = {
	.current_step = STEP_FINISH,
	.next_step = STEP_FINISH,
	.step_wait = STEP_WAIT,
	.goto_step_listener = goto_step_event,
};


// 备注
static char info[40];
// 开始
static void goto_start(void)
{
	PCTRL_GotoStep(&pctrl, STEP_START, "开始");
}

// 成功
static void goto_success(void)
{
	REGIST_SetResult(REGIST_Result_Success);
	PCTRL_GotoStep(&pctrl, STEP_SUCCESS, "成功");
}
// 失败
static void goto_failure(char * _info)
{
	REGIST_SetResult(REGIST_Result_Failure);
	memset(info, 0, sizeof(info));
	strcpy(info, _info);
	PCTRL_GotoStep(&pctrl, STEP_FAILURE, "失败");
	Log_Printf_Debug("info：%s！\r\n", info);
}
// 结束
static void goto_finish(void)
{
	REGIST_SetStatus(REGIST_Status_Done);
	PCTRL_GotoStep(&pctrl, STEP_FINISH, "结束");
}


// 注册状态
static enum REGIST_StatusEnum regist_status = REGIST_Status_None;
// 注册结果
static enum REGIST_ResultEnum regist_result = REGIST_Result_None;
// 设置注册状态
static void REGIST_SetStatus(enum REGIST_StatusEnum status)
{
	regist_status = status;
}
// 获取注册状态
enum REGIST_StatusEnum REGIST_GetStatus(void)
{
	return regist_status;
}
// 设置注册结果
static void REGIST_SetResult(enum REGIST_ResultEnum result)
{
	regist_result = result;
}
// 获取注册结果
enum REGIST_ResultEnum REGIST_GetResult(void)
{
	return regist_result;
}
// 重置注册
enum EXECUTE_ResultEnum REGIST_Reset(void)
{
	if(REGIST_GetStatus() == REGIST_Status_Being)
	{
		Log_Printf_Debug("注册流程重置错误！\r\n");
		return EXECUTE_Result_Failure;
	}
	REGIST_SetStatus(REGIST_Status_None);
	REGIST_SetResult(REGIST_Result_None);
	return EXECUTE_Result_Success;
}
// 开始注册
enum EXECUTE_ResultEnum REGIST_Start(void)
{
	REGIST_Reset();
	if(REGIST_GetStatus() != REGIST_Status_None)
	{
		Log_Printf_Debug("注册流程启动错误！\r\n");
		return EXECUTE_Result_Failure;
	}
	goto_start();
	REGIST_SetStatus(REGIST_Status_Being);
	return EXECUTE_Result_Success;
}
// 注册流程处理，放到大循环里
void REGIST_ProcessHandle(void)
{
	if(REGIST_GetStatus() == REGIST_Status_Being)
	{
		REGIST_Process();
	}
}


// 注册流程
static enum Result result = Result_None;
static uint8_t cfun_mode, mode, stat = 0;
static uint16_t lac, err = 0;
static uint32_t ci = 0;
static void REGIST_Process()
{
	switch(pctrl.current_step)
	{
		case STEP_START: // 开始
			PCTRL_GotoStep(&pctrl, STEP_EXIT_SLEEP, "退出休眠");
			break;
		case STEP_EXIT_SLEEP: 
			result = bc260y.exit_sleep_2();//退出休眠
			if(result == Result_Success)
			{
				PCTRL_GotoStep(&pctrl, STEP_SET_QISDE_1, "开启回显");
			}
			else if(result == Result_Failed)
			{
				goto_failure("退出休眠失败");
			}
			break;
		case STEP_SET_QISDE_1:
			result = bc260y.set_qisde(1);//开启回显
			if(result == Result_Success)
			{
				PCTRL_GotoStep(&pctrl, STEP_SET_SLEEP, "设置休眠模式");
			}
			else if(result == Result_Failed)
			{
				goto_failure("开启回显失败");
			}
			break;
		case STEP_SET_SLEEP:
			result=bc260y.set_sleep(2);//设置休眠模式
			if(result == Result_Success)
			{
				PCTRL_GotoStep(&pctrl, STEP_DATAFORMAT, "设置数据格式");
			}
			else if(result == Result_Failed)
			{
				goto_failure("设置休眠模式失败");
			}
			break;
		case STEP_DATAFORMAT:
			result = bc260y.dataformat(1); // 设置数据格式, 十六进制
			if(result == Result_Success)
			{
				PCTRL_GotoStep(&pctrl, STEP_QUERY_CFUN, "查询功能模式");
			}
			else if(result == Result_Failed)
			{
				goto_failure("设置数据格式失败");
			}
			break;
		case STEP_QUERY_CFUN:
			result = bc260y.query_cfun(&cfun_mode); // 查询功能模式
			if(result == Result_Success)
			{
				if(cfun_mode == 1)
				{
					PCTRL_GotoStep(&pctrl, STEP_SET_CFUN_0, "设置最小功能模式");
				}
				else
				{
					PCTRL_GotoStep(&pctrl, STEP_SET_CFUN_1, "设置全功能模式");
				}
			}
			else if(result == Result_Failed)
			{
				goto_failure("查询功能模式失败");
			}
			break;
		case STEP_SET_CFUN_0:
			result=bc260y.set_cfun(0);//设置最小功能模式
			if(result == Result_Success)
			{
				if(REGIST_GetResult() != REGIST_Result_None)
				{
					goto_finish();
				}
				else
				{
					PCTRL_GotoStep(&pctrl, STEP_SET_CFUN_1, "设置全功能模式");
				}
			}
			else if(result == Result_Failed)
			{
				goto_failure("设置最小功能模式失败");
				goto_finish();
			}
			break;
		case STEP_SET_CFUN_1:
			result=bc260y.set_cfun(1);//设置全功能模式
			if(result == Result_Success)
			{
				PCTRL_GotoStep(&pctrl, STEP_QUERY_DNS, "查询DNS");
				memset(pridnsaddr, 0, sizeof(pridnsaddr));
			}
			else if(result == Result_Failed)
			{
				goto_failure("设置全功能模式失败");
			}
			break;
		case STEP_QUERY_DNS:
			result = bc260y.query_dns(pridnsaddr); // 查询DNS
			if(result == Result_Success)
			{
				Log_Printf_Debug("DNS: %s, %d\r\n", pridnsaddr, strlen(pridnsaddr));
				if(strlen(pridnsaddr) <= 1)
				{
					PCTRL_GotoStep(&pctrl, STEP_SET_DNS, "设置DNS");
				}
				else
				{
					PCTRL_GotoStep(&pctrl, STEP_SET_CEREG_2, "设置网络状态");
				}
			}
			else if(result == Result_Failed) goto_failure("查询DNS失败");
			break;
		case STEP_SET_DNS:
			result = bc260y.set_dns("114.114.114.114", "8.8.8.8"); // 设置DNS
			if(result == Result_Success)
			{
				PCTRL_GotoStep(&pctrl, STEP_SET_CFUN_0, "设置最小功能模式");
			}
			else if(result == Result_Failed)
			{
				goto_failure("设置DNS失败");
			}
			break;
		case STEP_SET_CEREG_2:
			result=bc260y.set_cereg(2); // 设置网络状态
			if(result == Result_Success)
			{
				PCTRL_GotoStep(&pctrl, STEP_QUERY_CEREG, "查询网络状态");
			}
			else if(result == Result_Failed)
			{
				goto_failure("设置网络状态失败");
			}
			break;
		case STEP_QUERY_CEREG:
			result=bc260y.query_cereg(&mode, &stat, &lac, &ci);// 查询网络状态
			if(result == Result_Success)
			{
				PCTRL_GotoStep(&pctrl, STEP_CLOSE, "断开tcp连接");
			}
			else if(result == Result_Failed)
			{
				goto_failure("查询网络状态失败");
			}
			break;
		case STEP_CLOSE:
			result=bc260y.close_socket(connectID);//防止以前链接没断开，断开tcp链接
			if(result == Result_Success)
			{
				if(REGIST_GetResult() != REGIST_Result_None)
				{
					PCTRL_GotoStep(&pctrl, STEP_SET_CFUN_0, "设置最小功能模式");
				}
				else
				{
					PCTRL_GotoStep(&pctrl, STEP_OPEN, "连接tcp");
				}
			}
			else if(result == Result_Failed)
			{
				goto_failure("断开tcp连接失败");
			}
			break;
		case STEP_OPEN:
			result=bc260y.open_socket(connectID, "TCP", REGIST_SERVER, REGIST_PORT, 1, &err); // 连接tcp
			if(result == Result_Success)
			{
				PCTRL_GotoStep(&pctrl, STEP_SEND, "发送数据");
				// 打包注册请求
				memset(regist_data, 0, sizeof(regist_data));
				TUORENIOT_PackRegistRequest(regist_data, &regist_data_length, &regist_request);
				TUORENIOT_PrintfRegistRequestStruct(&regist_request);
			}
			else if(result == Result_Failed)
			{
				goto_failure("连接tcp失败");
			}
			break;
		case STEP_SEND: // 发送数据
			result =bc260y.send_rai(connectID, regist_data, regist_data_length, 0);//数据发送
			if(result == Result_Success)
			{
				PCTRL_GotoStep(&pctrl, STEP_RECV, "等待结果");
				memset(regist_data, 0, sizeof(regist_data));
			}
			else if(result == Result_Failed)
			{
				goto_failure("发送数据失败");
			}
			break;
		case STEP_RECV: // 等待结果
			result =bc260y.recv_with_time(connectID, regist_data, &regist_data_length, 10000);
			if(result == Result_Success)
			{
				uint8_t res = TUORENIOT_AnalysisRegistData(regist_data, regist_data_length);
				if(res == 1) // 成功
				{
					goto_success();
				}
				else // 失败
				{
					goto_failure("解析失败");
				}
				PCTRL_GotoStep(&pctrl, STEP_CLOSE, "断开tcp连接");
			}
			else if(result == Result_Failed)
			{
				goto_failure("等待结果失败");
			}
			break;
		case STEP_WAIT: // 等待
			PCTRL_Wait(&pctrl);
			break;
		case STEP_SUCCESS: // 成功
			goto_finish();
			break;
		case STEP_FAILURE: // 失败
			PCTRL_GotoStep(&pctrl, STEP_SET_CFUN_0, "失败，设置最小功能模式");
			break;
		case STEP_FINISH: // 结束
			break;
		default: // 默认
			goto_failure("步骤不存在");
			break;
	}
}


#endif