mirror of
https://github.com/oopuuu/zTC1.git
synced 2025-12-13 05:28:14 +08:00
recover source code
This commit is contained in:
zogodo
358
TC1/user_function.c
Normal file
358
TC1/user_function.c
Normal file
@@ -0,0 +1,358 @@
|
||||
#define os_log(format, ...) custom_log("FUNCTION", format, ##__VA_ARGS__)
|
||||
|
||||
#include "TimeUtils.h"
|
||||
|
||||
#include "main.h"
|
||||
#include "user_gpio.h"
|
||||
#include "cJSON/cJSON.h"
|
||||
#include "user_ota.h"
|
||||
#include "user_mqtt_client.h"
|
||||
#include "user_udp.h"
|
||||
|
||||
uint32_t last_time = 0;
|
||||
|
||||
void user_function_set_last_time( )
|
||||
{
|
||||
last_time = UpTicks( );
|
||||
}
|
||||
|
||||
bool json_plug_analysis( int udp_flag, unsigned char x, cJSON * pJsonRoot, cJSON * pJsonSend );
|
||||
bool json_plug_task_analysis( unsigned char x, unsigned char y, cJSON * pJsonRoot, cJSON * pJsonSend );
|
||||
|
||||
void user_send( int udp_flag, char *s )
|
||||
{
|
||||
if ( udp_flag || !user_mqtt_isconnect( ) )
|
||||
user_udp_send( s ); //<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
|
||||
else
|
||||
user_mqtt_send( s );
|
||||
}
|
||||
|
||||
void user_function_cmd_received( int udp_flag, uint8_t *pusrdata )
|
||||
{
|
||||
|
||||
unsigned char i;
|
||||
bool update_user_config_flag = false; //<2F><>־λ,<2C><>¼<EFBFBD><C2BC><EFBFBD><EFBFBD><EFBFBD>Ƿ<EFBFBD><C7B7><EFBFBD>Ҫ<EFBFBD><D2AA><EFBFBD>´<EFBFBD><C2B4><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
|
||||
bool return_flag = true; //Ϊtrueʱ<65><CAB1><EFBFBD><EFBFBD>json<6F><6E><EFBFBD><EFBFBD>,<2C><><EFBFBD><EFBFBD><F2B2BBB7><EFBFBD>
|
||||
|
||||
cJSON * pJsonRoot = cJSON_Parse( pusrdata );
|
||||
if ( !pJsonRoot )
|
||||
{
|
||||
os_log( "this is not a json data:\r\n%s\r\n", pusrdata );
|
||||
return;
|
||||
}
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD>UDP<44><50><EFBFBD><EFBFBD>device report(MQTTͬ<54><CDAC><EFBFBD>ظ<EFBFBD><D8B8><EFBFBD><EFBFBD><EFBFBD>)
|
||||
cJSON *p_cmd = cJSON_GetObjectItem( pJsonRoot, "cmd" );
|
||||
if ( p_cmd && cJSON_IsString( p_cmd ) && strcmp( p_cmd->valuestring, "device report" ) == 0 )
|
||||
{
|
||||
cJSON *pRoot = cJSON_CreateObject( );
|
||||
cJSON_AddStringToObject( pRoot, "name", sys_config->micoSystemConfig.name );
|
||||
cJSON_AddStringToObject( pRoot, "mac", strMac );
|
||||
cJSON_AddNumberToObject( pRoot, "type", TYPE );
|
||||
cJSON_AddStringToObject( pRoot, "type_name", TYPE_NAME );
|
||||
|
||||
IPStatusTypedef para;
|
||||
micoWlanGetIPStatus( ¶, Station );
|
||||
cJSON_AddStringToObject( pRoot, "ip", para.ip );
|
||||
|
||||
char *s = cJSON_Print( pRoot );
|
||||
// os_log( "pRoot: %s\r\n", s );
|
||||
user_send( udp_flag, s ); //<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
|
||||
free( (void *) s );
|
||||
cJSON_Delete( pRoot );
|
||||
// cJSON_Delete(p_cmd);
|
||||
}
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD>Ϊ<EFBFBD><CEAA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EEB2BF>
|
||||
cJSON *p_name = cJSON_GetObjectItem( pJsonRoot, "name" );
|
||||
cJSON *p_mac = cJSON_GetObjectItem( pJsonRoot, "mac" );
|
||||
|
||||
//<2F><>ʼ<EFBFBD><CABC>ʽ<EFBFBD><CABD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
|
||||
if ( (p_name && cJSON_IsString( p_name ) && strcmp( p_name->valuestring, sys_config->micoSystemConfig.name ) == 0) //name
|
||||
|| (p_mac && cJSON_IsString( p_mac ) && strcmp( p_mac->valuestring, strMac ) == 0) //mac
|
||||
)
|
||||
{
|
||||
cJSON *json_send = cJSON_CreateObject( );
|
||||
cJSON_AddStringToObject( json_send, "mac", strMac );
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
|
||||
// cJSON *p_cmd = cJSON_GetObjectItem( pJsonRoot, "name" );
|
||||
if(p_cmd && cJSON_IsString( p_cmd ) && strcmp( p_cmd->valuestring, "restart" ) == 0)
|
||||
{
|
||||
os_log("cmd:restart");
|
||||
mico_system_power_perform( mico_system_context_get( ), eState_Software_Reset );
|
||||
}
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD><EFBFBD>汾
|
||||
cJSON *p_version = cJSON_GetObjectItem( pJsonRoot, "version" );
|
||||
if ( p_version )
|
||||
{
|
||||
os_log("version:%s",VERSION);
|
||||
cJSON_AddStringToObject( json_send, "version", VERSION );
|
||||
}
|
||||
//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʱ<EFBFBD><CAB1>
|
||||
cJSON *p_total_time = cJSON_GetObjectItem( pJsonRoot, "total_time" );
|
||||
if ( p_total_time )
|
||||
{
|
||||
cJSON_AddNumberToObject( json_send, "total_time", total_time );
|
||||
}
|
||||
//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
|
||||
cJSON *p_power = cJSON_GetObjectItem( pJsonRoot, "power" );
|
||||
if ( p_power )
|
||||
{
|
||||
uint8_t *temp_buf = malloc( 16 );
|
||||
if ( temp_buf != NULL )
|
||||
{
|
||||
sprintf( temp_buf, "%d.%d", power / 10, power % 10 );
|
||||
cJSON_AddStringToObject( json_send, "power", temp_buf );
|
||||
free( temp_buf );
|
||||
}
|
||||
os_log("power:%d",power);
|
||||
}
|
||||
//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>setting-----------------------------------------------------------------
|
||||
cJSON *p_setting = cJSON_GetObjectItem( pJsonRoot, "setting" );
|
||||
if ( p_setting )
|
||||
{
|
||||
//<2F><><EFBFBD><EFBFBD>ota
|
||||
cJSON *p_ota = cJSON_GetObjectItem( p_setting, "ota" );
|
||||
if ( p_ota )
|
||||
{
|
||||
if ( cJSON_IsString( p_ota ) )
|
||||
user_ota_start( p_ota->valuestring, NULL );
|
||||
}
|
||||
|
||||
cJSON *json_setting_send = cJSON_CreateObject( );
|
||||
//<2F><><EFBFBD><EFBFBD><EFBFBD>豸<EFBFBD><E8B1B8><EFBFBD><EFBFBD>/deviceid
|
||||
cJSON *p_setting_name = cJSON_GetObjectItem( p_setting, "name" );
|
||||
if ( p_setting_name && cJSON_IsString( p_setting_name ) )
|
||||
{
|
||||
update_user_config_flag = true;
|
||||
sprintf( sys_config->micoSystemConfig.name, p_setting_name->valuestring );
|
||||
}
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD>mqtt ip
|
||||
cJSON *p_mqtt_ip = cJSON_GetObjectItem( p_setting, "mqtt_uri" );
|
||||
if ( p_mqtt_ip && cJSON_IsString( p_mqtt_ip ) )
|
||||
{
|
||||
update_user_config_flag = true;
|
||||
sprintf( user_config->mqtt_ip, p_mqtt_ip->valuestring );
|
||||
}
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD>mqtt port
|
||||
cJSON *p_mqtt_port = cJSON_GetObjectItem( p_setting, "mqtt_port" );
|
||||
if ( p_mqtt_port && cJSON_IsNumber( p_mqtt_port ) )
|
||||
{
|
||||
update_user_config_flag = true;
|
||||
user_config->mqtt_port = p_mqtt_port->valueint;
|
||||
}
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD>mqtt user
|
||||
cJSON *p_mqtt_user = cJSON_GetObjectItem( p_setting, "mqtt_user" );
|
||||
if ( p_mqtt_user && cJSON_IsString( p_mqtt_user ) )
|
||||
{
|
||||
update_user_config_flag = true;
|
||||
sprintf( user_config->mqtt_user, p_mqtt_user->valuestring );
|
||||
}
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD>mqtt password
|
||||
cJSON *p_mqtt_password = cJSON_GetObjectItem( p_setting, "mqtt_password" );
|
||||
if ( p_mqtt_password && cJSON_IsString( p_mqtt_password ) )
|
||||
{
|
||||
update_user_config_flag = true;
|
||||
sprintf( user_config->mqtt_password, p_mqtt_password->valuestring );
|
||||
}
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
|
||||
//<2F><><EFBFBD><EFBFBD><EFBFBD>豸ota
|
||||
if ( p_ota ) cJSON_AddStringToObject( json_setting_send, "ota", p_ota->valuestring );
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD><EFBFBD>豸<EFBFBD><E8B1B8><EFBFBD><EFBFBD>/deviceid
|
||||
if ( p_setting_name ) cJSON_AddStringToObject( json_setting_send, "name", sys_config->micoSystemConfig.name );
|
||||
//<2F><><EFBFBD><EFBFBD>mqtt ip
|
||||
if ( p_mqtt_ip ) cJSON_AddStringToObject( json_setting_send, "mqtt_uri", user_config->mqtt_ip );
|
||||
//<2F><><EFBFBD><EFBFBD>mqtt port
|
||||
if ( p_mqtt_port ) cJSON_AddNumberToObject( json_setting_send, "mqtt_port", user_config->mqtt_port );
|
||||
//<2F><><EFBFBD><EFBFBD>mqtt user
|
||||
if ( p_mqtt_user ) cJSON_AddStringToObject( json_setting_send, "mqtt_user", user_config->mqtt_user );
|
||||
//<2F><><EFBFBD><EFBFBD>mqtt password
|
||||
if ( p_mqtt_password ) cJSON_AddStringToObject( json_setting_send, "mqtt_password", user_config->mqtt_password );
|
||||
|
||||
cJSON_AddItemToObject( json_send, "setting", json_setting_send );
|
||||
}
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD>plug-----------------------------------------------------------------
|
||||
for ( i = 0; i < PLUG_NUM; i++ )
|
||||
{
|
||||
if ( json_plug_analysis( udp_flag, i, pJsonRoot, json_send ) )
|
||||
update_user_config_flag = true;
|
||||
}
|
||||
|
||||
cJSON_AddStringToObject( json_send, "name", sys_config->micoSystemConfig.name );
|
||||
|
||||
if ( return_flag == true )
|
||||
{
|
||||
char *json_str = cJSON_Print( json_send );
|
||||
// os_log( "pRoot: %s\r\n", json_str );
|
||||
user_send( udp_flag, json_str ); //<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
|
||||
free( (void *) json_str );
|
||||
}
|
||||
cJSON_Delete( json_send );
|
||||
}
|
||||
|
||||
if ( update_user_config_flag )
|
||||
{
|
||||
mico_system_context_update( sys_config );
|
||||
update_user_config_flag = false;
|
||||
}
|
||||
|
||||
cJSON_Delete( pJsonRoot );
|
||||
|
||||
}
|
||||
|
||||
/*
|
||||
*<2A><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʱ<EFBFBD><CAB1><EFBFBD><EFBFBD>json
|
||||
*udp_flag:<3A><><EFBFBD><EFBFBD>udp/mqtt<74><74>־λ,<2C>˴<EFBFBD><CBB4>IJ<DEB8><C4B2><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>״̬ʱ,<2C><>Ҫʵʱ<CAB5><CAB1><EFBFBD>¸<EFBFBD>domoticz
|
||||
*x:<3A><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
|
||||
*/
|
||||
bool json_plug_analysis( int udp_flag, unsigned char x, cJSON * pJsonRoot, cJSON * pJsonSend )
|
||||
{
|
||||
if ( !pJsonRoot ) return false;
|
||||
if ( !pJsonSend ) return false;
|
||||
char i;
|
||||
bool return_flag = false;
|
||||
char plug_str[] = "plug_X";
|
||||
plug_str[5] = x + '0';
|
||||
|
||||
cJSON *p_plug = cJSON_GetObjectItem( pJsonRoot, plug_str );
|
||||
if ( !p_plug ) return_flag = false;
|
||||
|
||||
cJSON *json_plug_send = cJSON_CreateObject( );
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD>plug on------------------------------------------------------
|
||||
if ( p_plug )
|
||||
{
|
||||
cJSON *p_plug_on = cJSON_GetObjectItem( p_plug, "on" );
|
||||
if ( p_plug_on )
|
||||
{
|
||||
if ( cJSON_IsNumber( p_plug_on ) )
|
||||
{
|
||||
user_relay_set( x, p_plug_on->valueint );
|
||||
return_flag = true;
|
||||
}
|
||||
user_mqtt_send_plug_state( x );
|
||||
}
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD>plug<75><67>setting<6E><67>Ŀ----------------------------------------------
|
||||
cJSON *p_plug_setting = cJSON_GetObjectItem( p_plug, "setting" );
|
||||
if ( p_plug_setting )
|
||||
{
|
||||
cJSON *json_plug_setting_send = cJSON_CreateObject( );
|
||||
//<2F><><EFBFBD><EFBFBD>plug<75><67>setting<6E><67>name----------------------------------------
|
||||
cJSON *p_plug_setting_name = cJSON_GetObjectItem( p_plug_setting, "name" );
|
||||
if ( p_plug_setting_name )
|
||||
{
|
||||
if ( cJSON_IsString( p_plug_setting_name ) )
|
||||
{
|
||||
return_flag = true;
|
||||
sprintf( user_config->plug[x].name, p_plug_setting_name->valuestring );
|
||||
user_mqtt_hass_auto_name( x );
|
||||
}
|
||||
cJSON_AddStringToObject( json_plug_setting_send, "name", user_config->plug[x].name );
|
||||
}
|
||||
|
||||
//<2F><><EFBFBD><EFBFBD>plug<75><67>setting<6E><67>task----------------------------------------
|
||||
for ( i = 0; i < PLUG_TIME_TASK_NUM; i++ )
|
||||
{
|
||||
if ( json_plug_task_analysis( x, i, p_plug_setting, json_plug_setting_send ) )
|
||||
return_flag = true;
|
||||
}
|
||||
|
||||
cJSON_AddItemToObject( json_plug_send, "setting", json_plug_setting_send );
|
||||
}
|
||||
}
|
||||
// cJSON *p_nvalue = cJSON_GetObjectItem( pJsonRoot, "nvalue" );
|
||||
// if ( p_plug || p_nvalue )
|
||||
cJSON_AddNumberToObject( json_plug_send, "on", user_config->plug[x].on );
|
||||
|
||||
cJSON_AddItemToObject( pJsonSend, plug_str, json_plug_send );
|
||||
return return_flag;
|
||||
}
|
||||
|
||||
/*
|
||||
*<2A><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʱ<EFBFBD><CAB1><EFBFBD><EFBFBD>json
|
||||
*x:<3A><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> y:<3A><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
|
||||
*/
|
||||
bool json_plug_task_analysis( unsigned char x, unsigned char y, cJSON * pJsonRoot, cJSON * pJsonSend )
|
||||
{
|
||||
if ( !pJsonRoot ) return false;
|
||||
bool return_flag = false;
|
||||
|
||||
char plug_task_str[] = "task_X";
|
||||
plug_task_str[5] = y + '0';
|
||||
|
||||
cJSON *p_plug_task = cJSON_GetObjectItem( pJsonRoot, plug_task_str );
|
||||
if ( !p_plug_task ) return false;
|
||||
|
||||
cJSON *json_plug_task_send = cJSON_CreateObject( );
|
||||
|
||||
cJSON *p_plug_task_hour = cJSON_GetObjectItem( p_plug_task, "hour" );
|
||||
cJSON *p_plug_task_minute = cJSON_GetObjectItem( p_plug_task, "minute" );
|
||||
cJSON *p_plug_task_repeat = cJSON_GetObjectItem( p_plug_task, "repeat" );
|
||||
cJSON *p_plug_task_action = cJSON_GetObjectItem( p_plug_task, "action" );
|
||||
cJSON *p_plug_task_on = cJSON_GetObjectItem( p_plug_task, "on" );
|
||||
|
||||
if ( p_plug_task_hour && p_plug_task_minute && p_plug_task_repeat &&
|
||||
p_plug_task_action
|
||||
&& p_plug_task_on )
|
||||
{
|
||||
|
||||
if ( cJSON_IsNumber( p_plug_task_hour )
|
||||
&& cJSON_IsNumber( p_plug_task_minute )
|
||||
&& cJSON_IsNumber( p_plug_task_repeat )
|
||||
&& cJSON_IsNumber( p_plug_task_action )
|
||||
&& cJSON_IsNumber( p_plug_task_on )
|
||||
)
|
||||
{
|
||||
return_flag = true;
|
||||
user_config->plug[x].task[y].hour = p_plug_task_hour->valueint;
|
||||
user_config->plug[x].task[y].minute = p_plug_task_minute->valueint;
|
||||
user_config->plug[x].task[y].repeat = p_plug_task_repeat->valueint;
|
||||
user_config->plug[x].task[y].action = p_plug_task_action->valueint;
|
||||
user_config->plug[x].task[y].on = p_plug_task_on->valueint;
|
||||
}
|
||||
|
||||
}
|
||||
cJSON_AddNumberToObject( json_plug_task_send, "hour", user_config->plug[x].task[y].hour );
|
||||
cJSON_AddNumberToObject( json_plug_task_send, "minute", user_config->plug[x].task[y].minute );
|
||||
cJSON_AddNumberToObject( json_plug_task_send, "repeat", user_config->plug[x].task[y].repeat );
|
||||
cJSON_AddNumberToObject( json_plug_task_send, "action", user_config->plug[x].task[y].action );
|
||||
cJSON_AddNumberToObject( json_plug_task_send, "on", user_config->plug[x].task[y].on );
|
||||
|
||||
cJSON_AddItemToObject( pJsonSend, plug_task_str, json_plug_task_send );
|
||||
return return_flag;
|
||||
}
|
||||
|
||||
unsigned char strtohex( char a, char b )
|
||||
{
|
||||
if ( a >= 0x30 && a <= 0x39 )
|
||||
a -= 0x30;
|
||||
else if ( a >= 0x41 && a <= 0x46 )
|
||||
{
|
||||
a = a + 10 - 0x41;
|
||||
} else if ( a >= 0x61 && a <= 0x66 )
|
||||
{
|
||||
a = a + 10 - 0x61;
|
||||
}
|
||||
|
||||
if ( b >= 0x30 && b <= 0x39 )
|
||||
b -= 0x30;
|
||||
else if ( b >= 0x41 && b <= 0x46 )
|
||||
{
|
||||
b = b + 10 - 0x41;
|
||||
} else if ( b >= 0x61 && b <= 0x66 )
|
||||
{
|
||||
b = b + 10 - 0x61;
|
||||
}
|
||||
|
||||
return a * 16 + b;
|
||||
}
|
||||
Reference in New Issue
Block a user