Module_OcppBackend20.h 4.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170
  1. /*
  2. * Sample_OCPP_Task.h
  3. *
  4. * Created on: 2020¦~5¤ë26¤é
  5. * Author: foluswen
  6. */
  7. #ifndef HEADER_MODULE_OCPPBACKEND20_H_
  8. #define HEADER_MODULE_OCPPBACKEND20_H_
  9. #include <sys/time.h>
  10. #include <sys/timeb.h>
  11. #include <sys/types.h>
  12. #include <sys/stat.h>
  13. #include <sys/ioctl.h>
  14. #include <sys/socket.h>
  15. #include <sys/ipc.h>
  16. #include <sys/shm.h>
  17. #include <sys/mman.h>
  18. #include <linux/wireless.h>
  19. #include <linux/sockios.h>
  20. #include <linux/socket.h>
  21. #include <arpa/inet.h>
  22. #include <netinet/in.h>
  23. #include <unistd.h>
  24. #include <stdarg.h>
  25. #include <stdio.h>
  26. #include <stdlib.h>
  27. #include <unistd.h>
  28. #include <fcntl.h>
  29. #include <termios.h>
  30. #include <errno.h>
  31. #include <string.h>
  32. #include <time.h>
  33. #include <ctype.h>
  34. #include <ifaddrs.h>
  35. #include <pthread.h>
  36. #include <mcheck.h>
  37. #include <uuid/uuid.h>
  38. #include <libwebsockets.h>
  39. #include <lws_config.h>
  40. #include <sqlite3.h>
  41. #include <json-c/json.h>
  42. #include "hashmap.h"
  43. #include "SystemLogMessage.h"
  44. #include "MessageHandler.h"
  45. #define is_error(ptr) ((unsigned long)ptr > (unsigned long)-4000L)
  46. #define PASS 1
  47. #define FAIL -1
  48. typedef enum {
  49. NO=0,
  50. YES
  51. }Logic_Value;
  52. typedef enum {
  53. OFF=0,
  54. ON
  55. }Switch_Value;
  56. enum GUN_TYPE
  57. {
  58. GUN_TYPE_UNKNOWN=0,
  59. GUN_TYPE_CHAdeMO,
  60. GUN_TYPE_CCS,
  61. GUN_TYPE_GBT,
  62. GUN_TYPE_DO,
  63. GUN_TYPE_AC
  64. };
  65. #ifndef SPEC_LATEST_SUPPORTED
  66. #define SPEC_LATEST_SUPPORTED 13
  67. #endif
  68. // Hash map operation constant
  69. #define HASH_OP_ADD 0
  70. #define HASH_OP_GET 1
  71. #define HASH_OP_REMOVE 2
  72. // OCPP Message type constant
  73. #define MESSAGE_TYPE_CALL 2
  74. #define MESSAGE_TYPE_CALLRESULT 3
  75. #define MESSAGE_TYPE_CALLERROR 4
  76. // Queue operation constant
  77. #define QUEUE_OPERATION_SHOWQUEUE 0
  78. #define QUEUE_OPERATION_SHOWFRONT 1
  79. #define QUEUE_OPERATION_DEL 2
  80. #define QUEUE_OPERATION_SENT 3
  81. #define QUEUE_OPERATION_ADD 4
  82. #define QUEUE_OPERATION_STORE 5
  83. #define QUEUE_MESSAGE_LENGTH 1024*20
  84. struct yuarel {
  85. char *scheme; /* scheme, without ":" and "//" */
  86. char *username; /* username, default: NULL */
  87. char *password; /* password, default: NULL */
  88. char *host; /* hostname or IP address */
  89. int port; /* port, default: 0 */
  90. char *path; /* path, without leading "/", default: NULL */
  91. char *query; /* query, default: NULL */
  92. char *fragment; /* fragment, default: NULL */
  93. };
  94. /* A struct to hold the query string parameter values. */
  95. struct yuarel_param {
  96. char *key;
  97. char *val;
  98. };
  99. extern int yuarel_parse(struct yuarel *url, char *url_str);
  100. extern int yuarel_split_path(char *path, char **parts, int max_parts);
  101. extern int yuarel_parse_query(char *query, char delimiter, struct yuarel_param *params, int max_params);
  102. extern void CheckSystemValue(void);
  103. extern void checkNetworkProfile(void);
  104. extern int FirstHeartBeatResponse(void);
  105. extern void OCPP_get_TableAuthlocalAllData(void);
  106. extern int TransactionMessageAttemptsGet(void);
  107. extern int TransactionMessageRetryIntervalGet(void);
  108. extern int GetOcppConnStatus(void);
  109. extern void SetOcppConnStatus(uint8_t status);
  110. extern int GetHeartBeatWithNOResponse(void);
  111. extern void SetHeartBeatWithNOResponse(void);
  112. extern int DB_Initial();
  113. extern uint8_t GetOcppSecurityProfile();
  114. extern void GetOcppChargerBoxId(uint8_t *data);
  115. extern void GetOcppSecurityPassword(uint8_t *data);
  116. extern int InitShareMemory();
  117. extern int ProcessShareMemory();
  118. extern void CheckSystemValue(void);
  119. extern int isQueueOverSize();
  120. extern int showfront(char *uuid, char *data);
  121. extern int addq(char *uuid, char *data) ;
  122. extern int delq();
  123. extern int sentqueue();
  124. extern void CheckTransactionPacket(char *uuid);
  125. extern int queue_operation(int type, char *frontUUID, char *frontData);
  126. extern char *random_uuid( char buf[37]);
  127. extern void work(char s[]);
  128. extern char* strchr(const char *p, int ch);
  129. extern void splitstring(char *src, const char *separator, char **dest,int *num);
  130. extern char* stringtrim( char * s );
  131. extern char* stringtrimspace( char * s );
  132. extern char * strtrim( char * s );
  133. extern struct lws *wsi_client;
  134. extern struct lws_context *context;
  135. extern unsigned char SendBuffer[1024*20];
  136. extern int SendBufLen;
  137. extern char OcppPath[384];
  138. extern char OcppProtocol[10];
  139. extern char OcppHost[128];
  140. extern char OcppTempPath[256];
  141. extern int OcppPort;
  142. extern unsigned char StartTransactionIdTagTemp[20];
  143. extern pthread_mutex_t lock_send;
  144. extern uint32_t startTimeDog;
  145. extern uint32_t startTimeQueue;
  146. extern uint8_t isWebsocketSendable;
  147. extern uint8_t counterLwsRestart;
  148. extern uint8_t counterQueueSent;
  149. #endif /* HEADER_MODULE_OCPPBACKEND20_H_ */