Network-Modules/Drivers/Modules/ec800m/Ec800m_Regist.c

#include "CONFIG.h"
#if  EC800M

/**
  ******************************************************************************
  * 版   本       ：V1.0.0
  * 作   者       ：liuyanbin
  * 版权所有，盗版必究。
  * Copyright(C) All rights reserved
  ******************************************************************************
  *                             历史记录
  *     序号      版本        变更内容          作者              日期
  *      1        V0.0.1      实现4G注册      刘艳斌          2023/12/20
  *      2        V0.0.2      实现NB注册      刘艳斌          2023/12/20
  *      3        V0.0.3      整合4g和nb      刘艳斌          2024/1/24
  *
  ******************************************************************************
  */
#include "stm32f10x.h"
#include "Regist.h"
#include "ec800m.h"
#include "INflash.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"
static uint8_t mcu_id[8] = "1234567";

static uint8_t register_status;//注册成功，向flash存储标志

static Coefficient_Data flashdata;

static uint8_t tcpconnectID = 2;
// 生成环境
static char * REGIST_SERVER = "iot.tuoren.com" ; //注册服务器地址
static uint16_t REGIST_PORT = 8888; //端口号
// 开发环境
//static char * REGIST_SERVER = "z18z017026.51vip.biz" ; //注册服务器地址
//static uint16_t REGIST_PORT = 31396; //端口号

// 注册参数
static struct Regist_Params_Struct regist_params_struct = {
	.platform = "aliyun",
	.connType = "CoAP",
	.deviceId = "3431228A1936013C",
	.userId = 4562
};
static uint8_t regist_data[512];
static uint16_t regist_data_length;

//清空flash
void clearflash(void){
	flashdata.read_flag=0;
	memset(flashdata.deviceSecret, 0, sizeof(flashdata.deviceSecret));
	memset(flashdata.productKey, 0, sizeof(flashdata.productKey));
	memset(flashdata.deviceName, 0, sizeof(flashdata.deviceName));
	my_delay_ms(10);
	STMFLASH_Write(FLASH_SAVE_ADDR,(uint16_t*)&flashdata,sizeof(flashdata));
}

void storedata(void)
{
	flashdata.read_flag=1;
	strcpy(flashdata.deviceSecret, regist_params_struct.deviceSecret);
	strcpy(flashdata.productKey, regist_params_struct.productKey);
	strcpy(flashdata.deviceName, regist_params_struct.deviceName);
	
	my_delay_ms(10);
	STMFLASH_Write(FLASH_SAVE_ADDR,(uint16_t*)&flashdata,sizeof(flashdata));
	flashdata.read_flag=0;
	my_delay_ms(10);
	Log_Printf_Debug("写入数据完成\r\n");
	STMFLASH_Read(FLASH_SAVE_ADDR,(uint16_t*)&flashdata,sizeof(flashdata));
	Log_Printf_Debug("读取完成read_flag:%d,deviceSecret:%s,productKey:%s,deviceName:%s\r\n",flashdata.read_flag,flashdata.deviceSecret,flashdata.productKey,flashdata.deviceName);

}

//4G模块注册流程
uint8_t regist_Handle()
{
	uint8_t mode,stat,regist_flag = 0;
	uint16_t lac,err = 0;
	uint32_t ci = 0;
	enum Result result = Result_None;
	ec800m.exit_sleep();//退出休眠
	my_delay_ms(10);
	result=ec800m.set_sleep_sync(1);//设置休眠模式
	if(result==Result_Success)
	{
		result=ec800m.set_cfun_sync(1);//设置全功能模式
	}
	
	if(result==Result_Success)
	{
		result=ec800m.set_cgreg_sync(2);//设置网络状态
	}
	
	if(result==Result_Success)
	{
		for(int i=0;i<20;i++){
			my_delay_ms(400);
			result=ec800m.query_cgreg_sync(&mode,&stat,&lac,&ci);//循环查询网络状态最多20次
			if(stat==1)
			{
				i=20;
			}
		}
	}

	if(result==Result_Success&&stat==1)
	{
		//tcp连接流程
		result=ec800m.open_socket_sync(tcpconnectID,"TCP",REGIST_SERVER,REGIST_PORT,1,&err);//连接tcp
	}

	if(result==Result_Success)
	{
		result = ec800m.set_qisde_sync(0);//关闭回显
	}
	
	if(result==Result_Success)
	{
		memset(regist_params_struct.deviceId, 0, sizeof(regist_params_struct.deviceId));
		byteToHexStr(mcu_id, regist_params_struct.deviceId, sizeof(mcu_id));
		memset(regist_data, 0, sizeof(regist_data));
		packRegistParams(regist_data, &regist_data_length, regist_params_struct);
		printf_regist_param_struct(regist_params_struct);
		result =ec800m.send_sync(tcpconnectID, regist_data, regist_data_length);//数据发送
		Log_Printf_Debug("regist_data:\r\n");
		Log_SendHex(regist_data, regist_data_length);
		Log_Printf_Debug("\r\n");
	}

	if(result==Result_Success)
	{
		Log_Printf_Debug("数据发送成功\r\n");
		memset(regist_data, 0, sizeof(regist_data));
		result =ec800m.recv_with_time_sync(tcpconnectID,regist_data,&regist_data_length,10000);
		
	}
	
	if(result==Result_Success)
	{
		// 解析注册数据
		regist_flag = analysisRegistData(regist_data, regist_data_length, &regist_params_struct);
		printf_regist_param_struct(regist_params_struct);
		
		result=ec800m.close_socket_sync(tcpconnectID);//断开tcp连接
	}

	if(result==Result_Success)
	{
		Log_Printf_Debug("断开tcp连接成功\r\n");
	}
	
	ec800m.set_cfun_sync(0);//设置最小功能模式
	ec800m.enter_sleep();//进入休眠状态
	
	return regist_flag;
}



uint8_t regist_device_sync(void)
{
	flashdata.read_flag=0;
	//读取flash
	Log_Printf_Debug("读取前read_flag:%d\r\n",flashdata.read_flag);
	STMFLASH_Read(FLASH_SAVE_ADDR,(u16*)&flashdata,sizeof(flashdata));//读取flash
	my_delay_ms(10);
	//已经注册。读取flash成功
	if(flashdata.read_flag == 1)
	{
		register_status=1;
		Log_Printf_Debug("读取flash成功read_flag:%d,\ndeviceSecret:%s,\n productKey:%s,\ndeviceName:%s\r\n",flashdata.read_flag,flashdata.deviceSecret,flashdata.productKey,flashdata.deviceName); 
		return 1;
	}
	//未注册开始注册流程
	register_status=regist_Handle();//注册流程
	if (register_status==0)//注册流程失败不储存flash
	{
		clearflash();
		return 0;
	}
	else
	{
		storedata();//存储到flash
		return 1;
	}
}
enum Regist_Result regist_get_result(void)
{
  if(register_status == 1){
    return Regist_Result_Success;
  }
  else
  {
    return Regist_Result_Failure;
  }
}

char * regist_get_aliyun_productKey(void)
{
	return flashdata.productKey;
}
char * regist_get_aliyun_deviceName(void)
{
  return flashdata.deviceName;
}
char * regist_get_aliyun_deviceSecret(void)
{
	return flashdata.deviceSecret;
}


#endif