csu3_am335x/EVSE/Modularization/logPackTools.c

#include 	<sys/time.h>
#include 	<sys/timeb.h>
#include    <sys/types.h>
#include    <sys/stat.h>
#include 	<sys/types.h>
#include 	<sys/ioctl.h>
#include 	<sys/socket.h>
#include 	<sys/ipc.h>
#include 	<sys/shm.h>
#include 	<sys/shm.h>
#include 	<sys/mman.h>
#include 	<linux/wireless.h>
#include 	<arpa/inet.h>
#include 	<netinet/in.h>

#include 	<unistd.h>
#include 	<stdarg.h>
#include    <stdio.h>      /*標準輸入輸出定義*/
#include    <stdlib.h>     /*標準函數庫定義*/
#include    <unistd.h>     /*Unix 標準函數定義*/
#include    <fcntl.h>      /*檔控制定義*/
#include    <termios.h>    /*PPSIX 終端控制定義*/
#include    <errno.h>      /*錯誤號定義*/
#include 	<errno.h>
#include 	<string.h>
#include	<time.h>
#include	<ctype.h>
#include 	<ifaddrs.h>
#include	"../Projects/define.h"

#include <math.h>
#define DEBUG_INFO(format, args...) StoreLogMsg("[%s:%d][%s][Info] "format, __FILE__, __LINE__, __FUNCTION__, ##args)
#define DEBUG_WARN(format, args...) StoreLogMsg("[%s:%d][%s][Warn] "format, __FILE__, __LINE__, __FUNCTION__, ##args)
#define DEBUG_ERROR(format, args...) StoreLogMsg("[%s:%d][%s][Error] "format, __FILE__, __LINE__, __FUNCTION__, ##args)

#define Debug
#define ARRAY_SIZE(A)		(sizeof(A) / sizeof(A[0]))
#define PASS				1
#define FAIL				-1
#define SystemLogMessage
struct SysConfigAndInfo *ShmSysConfigAndInfo;
struct StatusCodeData *ShmStatusCodeData;

void trim(char *s);
int mystrcmp(char *p1, char *p2);
void substr(char *dest, const char* src, unsigned int start, unsigned int cnt);
void split(char **arr, char *str, const char *del);

#ifdef SystemLogMessage
int StoreLogMsg(const char *fmt, ...) {
	char Buf[4096 + 256];
	char buffer[4096];
	time_t CurrentTime;
	struct tm *tm;
	va_list args;

	va_start(args, fmt);
	int rc = vsnprintf(buffer, sizeof(buffer), fmt, args);
	va_end(args);

	memset(Buf, 0, sizeof(Buf));
	CurrentTime = time(NULL);
	tm = localtime(&CurrentTime);
	sprintf(Buf,
			"echo \"[%04d.%02d.%02d %02d:%02d:%02d] - %s\" >> /Storage/SystemLog/[%04d.%02d]SystemLog",
			tm->tm_year + 1900, tm->tm_mon + 1, tm->tm_mday, tm->tm_hour,
			tm->tm_min, tm->tm_sec, buffer, tm->tm_year + 1900, tm->tm_mon + 1);
	system(Buf);
#ifdef Debug
	printf("[%04d.%02d.%02d %02d:%02d:%02d] - %s", tm->tm_year + 1900,
			tm->tm_mon + 1, tm->tm_mday, tm->tm_hour, tm->tm_min, tm->tm_sec,
			buffer);
#endif

	return rc;
}
#endif

int DiffTimeb(struct timeb ST, struct timeb ET) {
	//return milli-second
	unsigned int StartTime, StopTime;

	StartTime = (unsigned int) ST.time;
	StopTime = (unsigned int) ET.time;
	return (StopTime - StartTime) * 1000 + ET.millitm - ST.millitm;
}

//=================================
// Common routine
//=================================
void trim(char *s) {
	int i = 0, j, k, l = 0;

	while ((s[i] == ' ') || (s[i] == '\t') || (s[i] == '\n'))
		i++;

	j = strlen(s) - 1;
	while ((s[j] == ' ') || (s[j] == '\t') || (s[j] == '\n'))
		j--;

	if (i == 0 && j == strlen(s) - 1) {
	} else if (i == 0)
		s[j + 1] = '\0';
	else {
		for (k = i; k <= j; k++)
			s[l++] = s[k];
		s[l] = '\0';
	}
}

int mystrcmp(char *p1, char *p2) {
	while (*p1 == *p2) {
		if (*p1 == '\0' || *p2 == '\0')
			break;
		p1++;
		p2++;
	}
	if (*p1 == '\0' && *p2 == '\0')
		return (PASS);
	else
		return (FAIL);
}

void substr(char *dest, const char* src, unsigned int start, unsigned int cnt) {
	strncpy(dest, src + start, cnt);
	dest[cnt] = 0;
}

void split(char **arr, char *str, const char *del) {
	char *s = strtok(str, del);

	while (s != NULL) {
		*arr++ = s;
		s = strtok(NULL, del);
	}
}

int ConnectorType(char* connector){
	int result;
	if(strcmp(connector, "0") == 0){
		result= 0;
	}
	else if(strcmp(connector, "1") == 0 || strcmp(connector, "2") == 0 || strcmp(connector, "3") == 0 || strcmp(connector, "4") == 0 || strcmp(connector, "U") == 0 || strcmp(connector, "E") == 0){
		result= 1;//CCS
	}
	else if(strcmp(connector, "5") == 0 || strcmp(connector, "6") == 0 || strcmp(connector, "G") == 0){
		result= 2;//GB
	}
	else if(strcmp(connector, "J") == 0){
		result= 3;//CHAdeMO
	}
	else{

	}
	return result;
}

int ModelType(char* type,char* network){
	int result=0;
	if(strcmp(type, "A") == 0){
		if(strcmp(network, "0") == 0 || strcmp(network, "R") == 0 || strcmp(network, "B") == 0){
			result=0;
		}
		else if(strcmp(network, "E") == 0 || strcmp(network, "W") == 0 || strcmp(network, "T") == 0 || strcmp(network, "U") == 0){
			result=1;
		}
	}
	else if(strcmp(type, "D") == 0){
		result=2;
	}
	return result;
}
//==========================================
// Init all share memory
//==========================================
int InitShareMemory() {
	int result = PASS;
	int MeterSMId;

	//creat ShmSysConfigAndInfo
	if ((MeterSMId = shmget(ShmSysConfigAndInfoKey,
			sizeof(struct SysConfigAndInfo), 0777)) < 0) {
#ifdef SystemLogMessage
		DEBUG_ERROR("shmget ShmSysConfigAndInfo NG\n");
#endif
		result = FAIL;
	} else if ((ShmSysConfigAndInfo = shmat(MeterSMId, NULL, 0))
			== (void *) -1) {
#ifdef SystemLogMessage
		DEBUG_ERROR("shmat ShmSysConfigAndInfo NG\n");
#endif
		result = FAIL;
	} else {
	}

	//creat ShmStatusCodeData
	if ((MeterSMId = shmget(ShmStatusCodeKey, sizeof(struct StatusCodeData),
			0777)) < 0) {
#ifdef SystemLogMessage
		DEBUG_ERROR("shmget ShmStatusCodeData NG\n");
#endif
		result = FAIL;
	} else if ((ShmStatusCodeData = shmat(MeterSMId, NULL, 0)) == (void *) -1) {
#ifdef SystemLogMessage
		DEBUG_ERROR("shmat ShmStatusCodeData NG\n");
#endif
		result = FAIL;
	} else {
	}

	return result;
}

//================================================
// Main process
//================================================
int main(int argc, char *argv[]) {
	if (InitShareMemory() == FAIL) {
	#ifdef SystemLogMessage
		DEBUG_ERROR("InitShareMemory NG\n");
	#endif
	if (ShmStatusCodeData != NULL) {
		ShmStatusCodeData->AlarmCode.AlarmEvents.bits.FailToCreateShareMemory = 1;
	}
	sleep(5);
	return 0;
	}
	if(strcmp(argv[1], "log") == 0){
		unsigned char			SerialNo[64];;
		memcpy(SerialNo,ShmSysConfigAndInfo->SysConfig.SerialNumber,ARRAY_SIZE(ShmSysConfigAndInfo->SysConfig.SerialNumber));
		printf("%s", SerialNo);
		int year,month,i,ty,tm,cnt;
		char ym[7] ;
		char pwd[70];
		char cmd[100];
		time_t tt = time(0); //獲取當前時間
		struct tm *pst = localtime(&tt); //把time_t類型轉換為struct tm類型
		year = pst->tm_year + 1900;
		month = pst->tm_mon + 1;
		if((argc == 3) && isdigit(*argv[2])){
			cnt=atoi(argv[2]);
		}
		else{
			cnt=6;
		}
		for(i=0;i<cnt;i++){
			if(month-i<1){
				tm=month-i+12;
				ty=year-1;
			}
			else{
				tm=month-i;
				ty=year;
			}
			sprintf(ym,"%04d-%02d",ty,tm);
			sprintf(pwd,"%04d%02d%s",year,month,SerialNo);
			sprintf(cmd,"zip --password %s \t /mnt/%04d-%02d.zip \t /Storage/ChargeLog/*%04d*%02d*\n",pwd,year,month,ty,tm);
			system(cmd);
			sprintf(cmd,"zip --password %s \t /mnt/%04d-%02d.zip \t /Storage/EventLog/*%04d*%02d*\n",pwd,year,month,ty,tm);
			system(cmd);
			sprintf(cmd,"zip --password %s \t /mnt/%04d-%02d.zip \t /Storage/SystemLog/*%04d*%02d*\n",pwd,year,month,ty,tm);
			system(cmd);
			printf("Log packing is done!\n");
	//		zip --password "'.date('Ym').$SerialNumber.'" -r /var/www/log.zip /Storage/
		}
	}
}