From 5e9d03d507aad324a803eb8795e0eed6fb671761 Mon Sep 17 00:00:00 2001 From: guowenxue <guowenxue@gmail.com> Date: Mon, 10 Jul 2023 15:24:52 +0800 Subject: [PATCH] Merge branch 'master' of http://master.iot-yun.club:8088/r/raspberrypi --- apue/project_socket/src/packet.c | 96 ++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 96 insertions(+), 0 deletions(-) diff --git a/apue/project_socket/src/packet.c b/apue/project_socket/src/packet.c new file mode 100644 index 0000000..9bb680f --- /dev/null +++ b/apue/project_socket/src/packet.c @@ -0,0 +1,96 @@ +/********************************************************************************* + * Copyright: (C) 2022 LingYun IoT System Studio + * All rights reserved. + * + * Filename: packet.c + * Description: This file is packet API functions + * + * Version: 1.0.0(18/04/22) + * Author: Guo Wenxue <guowenxue@gmail.com> + * ChangeLog: 1, Release initial version on "18/04/22 16:30:25" + * + ********************************************************************************/ + +#include <stdio.h> +#include <string.h> +#include <unistd.h> +#include <time.h> +#include "packet.h" +#include "logger.h" +#include "ds18b20.h" + +int get_devid(char *devid, int size, int sn) +{ + if( !devid || size<DEVID_LEN ) + { + log_error("Invalid input arugments\n"); + return -1; + } + + memset(devid, 0, size); + snprintf(devid, size, "rpi#%04d", sn); + return 0; +} + +int get_time(struct tm *ptm) +{ + if( !ptm ) + { + log_error("Invalid input arugments\n"); + return -1; + } + + + time_t now = time(NULL); + localtime_r(&now, ptm); + + return 0; +} + +int packet_segmented_pack(pack_info_t *pack_info, char *pack_buf, int size) +{ + char strtime[TIME_LEN] = {'\0'}; + struct tm *ptm; + + if( !pack_info || !pack_buf || size<=0 ) + { + log_error("Invalid input arguments\n"); + return -1; + } + + ptm = &pack_info->sample_time; + snprintf(strtime, sizeof(strtime), "%04d-%02d-%2d %02d:%02d:%02d", + ptm->tm_year+1900, ptm->tm_mon+1, ptm->tm_mday, + ptm->tm_hour, ptm->tm_min, ptm->tm_sec); + + + memset(pack_buf, 0, size); + snprintf(pack_buf, size, "%s|%s|%d.%d", pack_info->devid, strtime, + temper_integer(pack_info->temper), temper_fract(pack_info->temper)); + + return strlen(pack_buf); +} + +int packet_json_pack(pack_info_t *pack_info, char *pack_buf, int size) +{ + char strtime[TIME_LEN] = {'\0'}; + struct tm *ptm; + + if( !pack_info || !pack_buf || size<=0 ) + { + log_error("Invalid input arguments\n"); + return -1; + } + + ptm = &pack_info->sample_time; + snprintf(strtime, sizeof(strtime), "%04d-%02d-%2d %02d:%02d:%02d", + ptm->tm_year+1900, ptm->tm_mon+1, ptm->tm_mday, + ptm->tm_hour, ptm->tm_min, ptm->tm_sec); + + memset(pack_buf, 0, size); + snprintf(pack_buf, size, "{\"devid\":\"%s\", \"time\":\"%s\",\"temperature\":\"%d.%d\"}", + pack_info->devid, strtime, temper_integer(pack_info->temper), temper_fract(pack_info->temper)); + + return strlen(pack_buf); +} + -- Gitblit v1.9.1