123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295 |
- /*
- * UartContext.cpp
- *
- */
- #include <stdio.h>
- #include <unistd.h>
- #include <fcntl.h>
- #include <memory.h>
- #include <termio.h>
- #include <string>
- #include <sys/ioctl.h>
- #include "uart/UartContext.h"
- #include "utils/Log.h"
- #include "base/strings.hpp"
- #include "service/BusinessConfig.h"
- #define UART_DATA_BUF_LEN 16384 // 16KB
- extern int parseProtocol(const BYTE *pData, UINT len);
- extern void buildProtocolData(std::string info);
- static const char* getBaudRate(UINT baudRate) {
- struct {
- UINT baud;
- const char *pBaudStr;
- } baudInfoTab[] = {
- { B1200, "B1200" },
- { B2400, "B2400" },
- { B4800, "B4800" },
- { B9600, "B9600" },
- { B19200, "B19200" },
- { B38400, "B38400" },
- { B57600, "B57600" },
- { B115200, "B115200" },
- { B230400, "B230400" },
- { B460800, "B460800" },
- { B921600, "B921600" }
- };
- int len = sizeof(baudInfoTab) / sizeof(baudInfoTab[0]);
- for (int i = 0; i < len; ++i) {
- if (baudInfoTab[i].baud == baudRate) {
- return baudInfoTab[i].pBaudStr;
- }
- }
- return NULL;
- }
- UartContext::UartContext(int uartNum) :
- mIsOpen(false),
- mUartID(0),
- mDataBufPtr(NULL),
- mDataBufLen(0),
- mUartNumber(uartNum){
- }
- UartContext::~UartContext() {
- delete[] mDataBufPtr;
- closeUart();
- }
- static bool mUart1IsOpen = false;
- static bool mUart3IsOpen = false;
- // 打开串口,pFileName为串口号,baudRate为波特率
- bool UartContext::openUart(const char *pFileName, UINT baudRate) {
- // LOGD("打开串口 串口号 = %s, 波特率 = %s\n", pFileName, getBaudRate(baudRate));
- mUartID = open(pFileName, O_RDWR|O_NOCTTY); // mUartID等于打开的串口
- if (mUartID <= 0) {
- mIsOpen = false;
- if(mUartNumber == 1) {
- mUart1IsOpen = false;
- }
- if(mUartNumber == 2) {
- mUart3IsOpen = false;
- }
- LOGD("uart%d open error", mUartNumber);
- } else {
- struct termios oldtio = { 0 };
- struct termios newtio = { 0 };
- tcgetattr(mUartID, &oldtio);
- newtio.c_cflag = baudRate|CS8|CLOCAL|CREAD;
- newtio.c_iflag = 0; // IGNPAR | ICRNL
- newtio.c_oflag = 0;
- newtio.c_lflag = 0; // ICANON
- newtio.c_cc[VTIME] = 0; /* inter-character timer unused */
- newtio.c_cc[VMIN] = 1; /* blocking read until 1 character arrives */
- tcflush(mUartID, TCIOFLUSH);
- tcsetattr(mUartID, TCSANOW, &newtio);
- // 设置为非阻塞 Set to non-blocking
- fcntl(mUartID, F_SETFL, O_NONBLOCK);
- mIsOpen = run("uart");
- if (!mIsOpen) {
- close(mUartID);
- mUartID = 0;
- }
- if(mUartNumber == 1) {
- mUart1IsOpen = true;
- }
- if(mUartNumber == 3) {
- mUart3IsOpen = true;
- }
- LOGD("openUart mIsOpen = %d\n", mIsOpen);
- }
- return mIsOpen;
- }
- void UartContext::closeUart() {
- LOGD("closeUart mIsOpen: %d...\n", mIsOpen);
- if (mIsOpen) {
- requestExit();
- close(mUartID);
- mUartID = 0;
- mIsOpen = false;
- }
- }
- // 发送串口消息
- bool UartContext::send(const BYTE *pData, UINT len) {
- // 这里是串口没有打开
- if (!mIsOpen) {
- LOGD("uart%d not opend", mUartNumber);
- return false;
- }
- int ret = write(mUartID, pData, len); // 这是发送串口消息
- if (ret != (int) len) { // 这里是发送失败
- LOGD("发送串口消息失败\n");
- return false;
- }
- std::string logInfo = " >>> ";
- for (int i = 0; i < len; ++i) {
- logInfo += base::format("%02x",pData[i]);
- }
- LOGD("%s",logInfo.c_str());
- // success
- LOGD("send Success\n");
- return true;
- }
- //UartContext* UartContext::getInstance() {
- // static UartContext sUC;
- // return &sUC;
- //}
- bool UartContext::readyToRun() {
- if (mDataBufPtr == NULL) {
- mDataBufPtr = new BYTE[UART_DATA_BUF_LEN];
- }
- if (mDataBufPtr == NULL) {
- closeUart();
- }
- return (mDataBufPtr != NULL);
- }
- bool UartContext::threadLoop() {
- if (mIsOpen) {
- #if 0
- // 可能上一次解析后有残留数据,需要拼接起来
- int readNum = read(mUartID, mDataBufPtr + mDataBufLen, UART_DATA_BUF_LEN - mDataBufLen);
- if (readNum > 0) {
- mDataBufLen += readNum;
- // 解析协议
- int len = parseProtocol(mDataBufPtr, mDataBufLen);
- if ((len > 0) && (len < mDataBufLen)) {
- // 将未解析的数据移到头部
- memcpy(mDataBufPtr, mDataBufPtr + len, mDataBufLen - len);
- }
- mDataBufLen -= len;
- } else {
- Thread::sleep(50);
- }
- #else
- unsigned char buffer[1024] = {0};
- int ret = read(mUartID, buffer, sizeof(buffer));
- if (ret > 0) {
- if (buffer[0]==CMD_HEAD && buffer[ret-2] == CMD_END1 && buffer[ret-1] == CMD_END2){
- std::string revStr = "";
- //std::string logInfo = " <<< ";
- //依次将读取到的数据输出到日志
- for (int i = 0; i < ret; ++i) {
- if (i==0 || i==ret-1 || i==ret-2){
- continue;
- }
- //LOGD(" <<< %02x", buffer[i]);
- revStr += buffer[i];
- //logInfo += base::format("%02x",buffer[i]);
- }
- //LOGD(" %s",logInfo.c_str());
- buildProtocolData(revStr);
- }
- else if (buffer[0] == 0xfe && buffer[2] == 0x03) {
- if (buffer[1] == 0x08) {
- std::string revStr = "";
- for (int i = 0; i < ret; ++i) {
- if (i==0 || i==1 || i==2 || i==3 || i==4 || i==ret-1){
- continue;
- }
- char buf[1024];
- sprintf(buf, "%02x", buffer[i]);
- revStr += buf;
- }
- LOGD("revStr == %s", revStr.c_str());
- nfcLogin(revStr);
- }
- }
- } else {
- //没收到数据时,休眠50ms,防止过度消耗cpu
- usleep(1000 * 50);
- }
- #endif
- return true;
- }
- return false;
- }
- static UartContext* uart0 = NULL;
- static UartContext* uart1 = NULL;
- static UartContext* uart2 = NULL;
- static UartContext* uart3 = NULL;
- void UartContext::init() {
- // uart0 = new UartContext(UART_TTYS0);
- // uart0->openUart("/dev/ttyS0", B115200);
- // uart1 = new UartContext(UART_TTYS1);
- // uart1->openUart("/dev/ttyS1", B115200);
- // 20221108的板子打开了串口2
- uart2 = new UartContext(UART_TTYS2);
- uart2->openUart("/dev/ttyS2", B115200);
- uart3 = new UartContext(UART_TTYS3);
- uart3->openUart("/dev/ttyS3", B115200);
- LOGD("打开串口");
- }
- void UartContext::destroy() {
- if (uart0) {
- delete uart0;
- uart0 = NULL;
- }
- if (uart1) {
- delete uart1;
- uart1 = NULL;
- }
- if (uart2) {
- delete uart1;
- uart2 = NULL;
- }
- if (uart3) {
- delete uart1;
- uart3 = NULL;
- }
- }
- bool UartContext::sendTo(int uart, const BYTE* pData, UINT len) {
- switch (uart) {
- case UART_TTYS0:
- return uart0->send(pData, len);
- case UART_TTYS1:
- return uart1->send(pData, len);
- case UART_TTYS2:
- return uart2->send(pData, len);
- case UART_TTYS3:
- return uart3->send(pData, len);
- }
- LOGD("无效的串口号");
- return false;
- }
- bool UartContext::Uart1IsOpen() {return mUart1IsOpen;}
- bool UartContext::Uart3IsOpen() {return mUart3IsOpen;}
|