4G-NB/Drivers/Regist.c

/**
  ******************************************************************************
  * 版   本       ：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 "AT.h"
#include "4GAES.h"
#include "ec800m.h"
#include "bc260.h"
#include "INflash.h"
#include "sys.h"
#include <stdio.h>
#include <stdarg.h>
#include <string.h>
#include <stdlib.h>
#include "cJSON.h"

extern valid_data_t valid_data;
#if  NBFLAG
uint8_t mcu_id[8]="8945809";
#else
uint8_t mcu_id[8]="ceshi001";
#endif
uint16_t Version_data = 1032;
uint8_t regist_result =0;
char registData[100] = {0};
//uint8_t registlen=0;

extern struct AT_Struct AT;
unsigned char key[17]="tuorenzhinenghua";
unsigned char expansionkey[15 * 16];
extern Coefficient_Data flashdata;
extern uint8_t register_success;
//static uint8_t tcpcontextID = 1;
static uint8_t tcpconnectID = 2;
static char * REGIST_SERVER ="8337239yf4.yicp.fun" ; //注册服务器地址
static uint16_t REGIST_PORT=22155; //端口号

/**
* 
*注册信息打包
*/
enum Result packRegistDataAnd(uint8_t *length){
	 enum Result result = Result_None;
//	 int i=0;
	int datalen = 0;
	char qcciddata[31]={0};//
     memset(registData,0, sizeof(registData));
	char* dataPtr = registData+2; //dataPtr指针指向registData第三个字节
	//复制muid，并转化为16进制
	byteToHexStr(mcu_id, dataPtr, sizeof(mcu_id));
	memcpy(dataPtr+strlen(dataPtr),"&",1);
	//获取qccid
	AT_Clear();
	//get_qccid_flag=get_qccid(qcciddata);
	
	#if  NBFLAG
	 result=bc260y.query_qccid_sync(qcciddata);
	#endif
	#if  _4GFLAG
	result=ec800m.query_qccid_sync(qcciddata);
	#endif
	
	  if(result==Result_Failed)
     {
      return result;
     }
    //获取复制qccid
	memcpy(dataPtr+strlen(dataPtr),qcciddata,31);
	//复制版本号
	snprintf(dataPtr+strlen(dataPtr),10,"&%d.%03d",Version_data/1000,Version_data%1000);
	Log_Printf_Debug("device data:%s\r\n",dataPtr);//串口打印
	Log_Printf_Debug("regist data:%s\r\n",registData+2);
	ScheduleKey(key, expansionkey, 4, 10);//生成密钥
	datalen = ECBAesEncrypt((unsigned char*)dataPtr, expansionkey, 10);		//2、AES 加密
	registData[0] = datalen>>8;//头2个字节赋值数据长度
	registData[1] = datalen;
	Log_Printf_Debug("strlendata:%d,datalen=%d\r\n",strlen(dataPtr),datalen);
	 *length=datalen+2;
	 return Result_Success;
}
/**
* 
*注册数据解密
*/
enum Result analysis_recvdata()
{
	enum Result result = Result_None;
	char recvdata[1024]={0};
	uint16_t recvdata_length=0;
  cJSON *json = NULL,*json_productKey = NULL,*json_deviceName = NULL,*json_deviceSecret = NULL;
	#if  NBFLAG
  result =bc260y.recv_with_time_sync(tcpconnectID,(uint8_t *)recvdata,&recvdata_length,10000);
	#endif
	#if  _4GFLAG
	 result =ec800m.recv_with_time_sync(tcpconnectID,(uint8_t *)recvdata,&recvdata_length,10000);
	#endif
	
     if(result==Result_Failed)
 {
   return result;
 }
 	//memset(valid_data.buf, 0, sizeof(valid_data.buf));
//    memcpy(valid_data.buf,recvdata,recvdata_length);
  ScheduleKey(key, expansionkey, 4, 10);
//  valid_data.len=recvdata_length;
  ECBAesDecrypt((unsigned char*)recvdata,recvdata_length, expansionkey, 10);//AES 解密
 Log_Printf_Debug("解密数据recvdata:%s,%d,%d\r\n",recvdata,strlen(recvdata),recvdata_length);
  			json = cJSON_Parse(recvdata);
		if(!json)
			{
				Log_Printf_Debug("json parse error,%s\r\n",cJSON_GetErrorPtr());
				cJSON_Delete(json);
				return Result_Failed;
		
			}else{
				json_deviceSecret = cJSON_GetObjectItem(json,"deviceSecret");
				json_productKey = cJSON_GetObjectItem(json,"productKey");
				json_deviceName = cJSON_GetObjectItem(json,"deviceName");
				Log_Printf_Debug("获取数据成功deviceSecret:%s,json_productKey:%s,deviceName:%s\r\n",json_deviceSecret->valuestring,json_productKey->valuestring,json_deviceName->valuestring);
//				memcpy(flashdata.deviceSecret,json_deviceSecret->valuestring,Secretsize);
//                memcpy(flashdata.productKey,json_productKey->valuestring,strlen(json_deviceName->valuestring));
//				memcpy(flashdata.deviceName,json_deviceName->valuestring,strlen(json_deviceName->valuestring));
				strcpy(flashdata.deviceSecret,json_deviceSecret->valuestring);
               strcpy(flashdata.productKey,json_productKey->valuestring);
				strcpy(flashdata.deviceName,json_deviceName->valuestring);
				memset(&register_success, 1, sizeof(register_success));
				cJSON_Delete(json);
				
				return Result_Success;
			
			}
}

#if  NBFLAG
uint8_t regist_Handle()
{
 uint8_t stat,length=0;
	uint16_t lac,err=0;
	uint32_t ci=0;
 enum Result result = Result_None;
GPIO_SetBits(WAKE_GPIO, WAKE_GPIO_Pin);
 bc260y.exit_sleep_sync();//退出休眠
 delay_ms(100);
	bc260y.reset();
 result = bc260y.set_qisde_sync(0);//关闭回显
   if(result==Result_Failed)
 {
   return 0;
 }
  result=bc260y.set_sleep_sync(1);//设置休眠模式
  if(result==Result_Failed)
 {
   return 0;
 }
  result=bc260y.set_cfun_sync(1);//设置全功能模式
 
  if(result==Result_Failed)
 {
   return 0;
 }
    result=bc260y.set_cgreg_sync(2);//设置网络状态
  if(result==Result_Failed)
 {
   return 0;
 }

 
for(int i=0;i<20;i++){
 delay_ms(400);
result=bc260y.query_cgreg_sync(&regist_result,&stat,&lac,&ci);//循环查询网络状态最多20次
	if(stat==1)
	{i=20;
	
	}
}

  if(result==Result_Failed)
 {
   return 0;
 }
   if(stat==0)
 {
	  Log_Printf_Debug(" stat=%d\r\n", stat);
   return 0;
 }
  
 result =(enum Result)packRegistDataAnd(&length);//数据打包
   if(result==Result_Failed)
 {
   return 0;
 }
 result=bc260y.close_socket_sync(tcpconnectID);//防止以前链接没断开，断开tcp链接
   if(result==Result_Failed)
 {
	Log_Printf_Debug(" result=%d\r\n", result);
   return 0;
 }
  //tcp连接流程
  result=bc260y.open_socket_sync(tcpconnectID,"TCP",REGIST_SERVER,REGIST_PORT,1,&err);//连接tcp
  if(result==Result_Failed)
 {
	Log_Printf_Debug(" result=%d\r\n", result);
   return 0;
 }

   result = bc260y.dataformat_sync(1);//配置发送数据格式
   if(result==Result_Failed)
 {
   return 0;
 }


 result =bc260y.send_sync(tcpconnectID,(uint8_t *)registData,length);//数据发送
    if(result==Result_Failed)
 {
   return 0;
 }
  

   result =analysis_recvdata();
    if(result==Result_Failed)
 {
   return 0;
 }

 result=bc260y.close_socket_sync(tcpconnectID);//断开tcp连接
  if(result==Result_Failed)
 {
   return 0;
 }


 bc260y.enter_sleep();//进入休眠状态
  return 1;
}
#endif

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

  if(result==Result_Failed)
 {
   return 0;
 }
   if(stat==0)
 {
	  Log_Printf_Debug(" stat=%d\r\n", stat);
   return 0;
 }
  //tcp连接流程
  result=ec800m.open_socket_sync(tcpconnectID,"TCP",REGIST_SERVER,REGIST_PORT,1,&err);//连接tcp
  if(result==Result_Failed)
 {
	Log_Printf_Debug(" result=%d\r\n", result);
   return 0;
 }
 
 if(result==Result_Failed)
 {
   return 0;
 }
  result =(enum Result)packRegistDataAnd(&length);//数据打包
  Log_Printf_Debug("data length=%d\r\n", length);
   if(result==Result_Failed)
 {
   return 0;
 }
 result = ec800m.set_qisde_sync(0);//关闭回显
   if(result==Result_Failed)
 {
   return 0;
 }
 result =ec800m.send_sync(tcpconnectID,(uint8_t *)registData,length);//数据发送
    if(result==Result_Failed)
 {
   return 0;
 }

   result =analysis_recvdata();
    if(result==Result_Failed)
 {
   return 0;
 }
 
 result=ec800m.close_socket_sync(tcpconnectID);//断开tcp连接
  if(result==Result_Failed)
 {
   return 0;
 }
  result=ec800m.set_cfun_sync(0);//设置最小功能模式
 
  if(result==Result_Failed)
 {
   return 0;
 }

 ec800m.enter_sleep();//进入休眠状态
  return 1;
}

#endif
uint8_t regist_device(void)
{
 flashdata.read_flag=0;
 uint8_t regist_flag=0;
 Log_Printf_Debug("读取前read_flag:%d\r\n",flashdata.read_flag);
 STMFLASH_Read(FLASH_SAVE_ADDR,(u16*)&flashdata,sizeof(flashdata));//读取flash
 delay_ms(10);
 if(flashdata.read_flag==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;
 }
 regist_flag=regist_Handle();//注册流程
 if(regist_flag==0)//注册流程失败不储存flash
 {
  return 0;
 }
 store();//存储到flash
  return 1;
}