fixed:寻址功能加入

service/impl/ProtocolImpl.cpp

 
 #include "ProtocolImpl.h"
 
+
 #include <cmath>
 #include <cstdlib>
 #include <vector>
 #include <sstream>
 #include <stdexcept>
 #include <iostream>
-
+#include <unistd.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <termios.h>
+#include <errno.h>
+#include <string.h>
 
 #include "../../common/GUID.cpp"
 #include "../../servicemodel/Base.h"
 #include "../../servicemodel/Device.h"
 #include "../../servicemodel/Item.h"
 #include "../../servicemodel/Packet.h"
-
 using namespace std;
 bool ProtocolImpl::hasInit = false;
 
+
 uint8_t ProtocolImpl::retBigEndian(uint32_t value, int offset)
 {
 	uint8_t ret = 0;
 	ret = (value >> offset) & 0xFF;
 	return ret;
 }
+
 int ProtocolImpl::getRegAddrMax(Packet *ppacket, Item *pitem)
 {
 	std::string sParaRegAddr;
 		}
 		else
 		{
-
 		}
 	}
 	log_i("最大的起始地址:0x%x", maxRegAddr);
 
 	return iMinRegAddr;
 }
+
 int ProtocolImpl::retStateResponse(Packet *ppacket, Item *pitem, const int len)
 {
 	int maxRegAddr = -1;
 	std::map<int, int> dataSet;
 	iPbufId = getRealFrame(pbuf, 0);
 
-
+    log_i("handleDataLess");
 	for (int i = 0; i < regNum; i++)
 	{
 		uint16_t regValue = 0;
 			count += 12)
 	{
 		iPbufId = getRealFrame(pbuf, count);
-
-
 		for (int i = 0; i < 4 && regNum > 0; i++,regNum --)   // i代表第i个寄存器
 		{
 
 
 }
 
+//返回IO数据集
+std::map<int,int> ProtocolImpl::retIoDataSet(Packet *ppacket, Item *pitem,PBYTE pbuf,int len)
+{
+	std::map<int, int> dataSet;
+
+	dataSet = handleIoData(pbuf);
+	return dataSet;
+
+}
+
+std::map<int,int> ProtocolImpl::handleIoData(PBYTE pbuf)
+{
+	int iPbufId;
+	std::map<int, int> dataSet;
+	iPbufId = getRealFrame(pbuf, 0);
+	uint16_t regValue = 0;
+	regValue = pbuf[7];
+	dataSet[iPbufId] = regValue;
+
+	log_i("handleIoData");
+
+	for (const auto &entry : dataSet)
+	{
+		log_i("addrFrame = 0x%x, value = 0x%x", entry.first, entry.second);
+	}
+
+	return dataSet;
+}
 std::map<int,int>ProtocolImpl::retDataSet(Packet *ppacket, Item *pitem,PBYTE pbuf,int len)
 {
 	std::map<int, int> dataSet; // 存储寄存器地址和值
 	int datasLen = 0;
 	maxRegAddr = getRegAddrMax(ppacket, pitem);
 	minRegAddr = getRegAddrMin(ppacket, pitem);
+
 	regNum = maxRegAddr - minRegAddr + 1;
 	datasLen = getRealValidLen(regNum);
+	log_i("regNum:%d,dataLen:%d",regNum,datasLen);
 	if (datasLen <= 12)
 	{
 		dataSet = handleDataLess(pbuf,len,regNum,datasLen);
 		dataSet = handleDataGreater(pbuf,len,regNum,datasLen);
 	}
 	return dataSet;
-
-
 }
+
 int ProtocolImpl::iGetItemParaConfig(Item *pitem,std::string attribute)
 {
-
 	Item *t_item = pitem;
 	Base &t_base = t_item->getBase();
 	string sAttribute = "";
 
 	iAttribute = strtol(sAttribute.c_str(), NULL, HEX);
 	log_i("retV:0x%x",iAttribute);
-
-
 	return iAttribute;
-
 }
 
 std::string  ProtocolImpl::sGetItemParaConfig(Item *pitem, std::string attribute)
 	string sAttribute = "";
 	sAttribute = t_base.getParam(attribute);
 	log_i("%s: %s",attribute.c_str(), sAttribute.c_str());
-
 	return sAttribute;
-
 }
 
 void ProtocolImpl::setData(Item *pitem,int16_t pbuf,int receiveData,int paraData,std::string t_sDataType,std::string t_sByteOrder,string t_sBits)
 		{
 			log_i("数据类型为I，调用merge16函数,buf=0x%x",buf);
 			t_item->setValue(merge16(buf, t_sByteOrder));
-
-
 		}
 		else if (t_sDataType == "UI")
 		{
 				snprintf(t, 256, "%d", bits);
 				t_str = t;
 				t_item->setValue(t_str);
-
 			}
-
 		}
 	}
+}
+
+int ProtocolImpl::set_gpio_value(const std::string& gpio_path, const std::string& value)
+{
+	int fd = open(gpio_path.c_str(), O_WRONLY);
+	if (fd < 0)
+	{
+		 log_e("Failed to open GPIO value file: %s", gpio_path.c_str());
+		return -1;
+	}
+
+	if (write(fd, value.c_str(), value.length()) < 0)
+	{
+		 log_e("Failed to write to GPIO value file: %s", gpio_path.c_str());
+		close(fd);
+		return -1;
+	}
+
+	close(fd);
+	return 0;
+}
+
+
+void ProtocolImpl::proceessReplyFrame(int frame,int datas)
+{
+	log_i("当前状态:%d ---0-初始化，1-发送，2-接收,3-结束",currentState);
+	  if (frame == 0x7F0) // 总主分配ID回复帧的CANID
+	  {
+		  log_i("processReply datas = %d",datas);
+	        unsigned char reply_id = datas; // 回复自身的ID编号
+	        log_i("reply_id = 0x%x",reply_id);
+	        if (reply_id == currentId)
+	        {
+	        	log_i("收到设备%d的回复", reply_id);
+	        	if(currentId ==  2)
+	        	{
+	        		log_i("回复帧，currentId = %d",currentId );
+	        		currentState = END;
+	        		idSuccessFlag =2;
+	        	}
+	        	else
+	        	{
+					if (orderMode == 0) // 根据分配次序修改下一个要分配的ID
+					{
+						currentId ++; // 正序分配
+						currentState = SEND;
+					}
+					else
+					{
+						currentId --;  // 倒序分配
+						currentState = SEND;
+					}
+					// 使能下一个设备
+					//数据发送正确，且有回复，开始发送下一帧
+	        	}
+
+
+	        }
+	        else
+	        {
+	        	currentId = 1;
+	        	idSuccessFlag = 0;
+	            log_i("收到错误的回复帧，ID不匹配");
+	        }
+	    }
+	  	else
+	    {
+	  		//currentId = 1;
+	  		currentState = SEND;
+	  		idSuccessFlag = 0;
+	        log_i("收到未知的CAN帧");
+	    }
+	  	if(idSuccessFlag == 2)
+	  	{
+	  		 findAddrFlag = 1;
+	  		 currentId = 1;
+	  		currentState = END;
+	  	}
 
 
 }
 
+//发送分配帧
+void  ProtocolImpl::sendAllocFrame(PBYTE pbuf, int id, int &len)
+{
+	pbuf[0] = 0x00;
+	pbuf[1] = 0x00;
+	pbuf[2] = 0x07;
+	pbuf[3] = 0xf0;
+	pbuf[4] = static_cast<uint8_t>(id); // 转换为字节
+	pbuf[5] = static_cast<uint8_t>(maxId); // 转换为字节
+	pbuf[6] = static_cast<uint8_t>(orderMode); // 转换为字节
+	pbuf[7] = static_cast<uint8_t>(orderState); // 转换为字节
+	pbuf[8] = 0;
+	pbuf[9] = 0;
+	pbuf[10] = 0;
+	pbuf[11] = 0;
+	// 打印调试信息
+	log_i("发送分配地址帧: ");
+	for (int i = 0; i < 8; i++) {
+		log_i("%02X ", pbuf[i]);
+	}
+	currentState = RECEIVED ;
+
+	len = 12;
+
+}
+
+void ProtocolImpl::initIO()
+{
+	currentId = 1;
+	if(count == 1)
+	{
+		if (set_gpio_value(devPath, lowLevel) == 0)
+		{
+			log_i("Set GPIO 436 to high");
+		}
+		else
+		{
+			log_e("Failed to set GPIO 436 to high");
+		}
+	}
+	else
+	{
+		if(count > 4)
+		{
+		  // 设置 GPIO 436 为低电平
+		  if (set_gpio_value(devPath, highLevel) == 0)
+		  {
+			  log_i("Set GPIO 436 to low");
+			  currentState = SEND;
+		  }
+		  else
+		  {
+			  log_e("Failed to set GPIO 436 to low");
+		  }
+
+		  count = 0;
+
+		}
+	}
+	count ++;
+}
+
 HRESULT ProtocolImpl::queryInterface(const IID &iid, void **ppv)
 {
 	if (iid == IID_IProtocol)
 HRESULT ProtocolImpl::onRead(Device *pdevice, Packet *ppacket, Item *pitem,
 		PBYTE pbuf, int &len)
 {
-	log_i("onRead");
-
-
 
+	log_i("onRead");
+	int deviceCounts;
+	Channel *pC = pdevice->getParent();
 
-	if (ppacket->getVitem().size() == 0)
+	log_i("Channel pointer: %p", pC);
+	if (pC == nullptr)
 	{
+		log_i("Channel pointer is null");
 		return S_FALSE;
 	}
+	if (m_tmpItems.count(pC->getBase().getObjid().toString()) == 0)
+	{
+		deviceCounts = pC->getDeviceCount();
+		//maxId = deviceCounts;
+		maxId = 2;
 
-	pdevice->getBase().setRwstate(READ_WAIT);	//----设置设备状态
-
-	std::string sParaId;
-	int iParaId;
-	Base &t_base = ppacket->getVitem().at(0)->getBase();
-	sParaId = t_base.getParam("功能码");
-	log_i("Parameter ID: %s", sParaId.c_str());
-	iParaId = strtol(sParaId.c_str(), NULL, HEX);
-	log_i("Parameter ID: %s", sParaId.c_str());
-	log_i("Converted Parameter ID: 0x%x", iParaId);
-	int frameFuncCode  = (iParaId & 0x070000);
-	log_i("frameFuncCode = 0x%x",frameFuncCode);
-	if (ppacket == nullptr || pitem == nullptr)
+		log_i("maxid =%d",maxId);
+	}
+	log_i("当前状态:%d ---0-初始化，1-发送，2-接收,3-结束",currentState);
+	if(currentState == INIT)
 	{
-		log_i("Invalid packet or item");
-		return S_FALSE;
+		initIO();
 	}
-	string t_saddr;
-	t_saddr = pdevice->getBase().getParam("站地址");
-	int t_iaddr = 0;
-	t_iaddr = strtol(t_saddr.c_str(), NULL, HEX);
-	log_i("stationAddr = %d",t_iaddr);
-	iParaId |=  (t_iaddr << 19);
-	log_i("onread -addStation-id = 0x%x",iParaId);
-
-    //判断寄存器是读寄存器
-	if(frameFuncCode == 0x030000)
+	if(currentState == SEND)
+	{
+		sendAllocFrame(pbuf,currentId , len);
+		timeOut = 0;
+		//pdevice->getBase().setRwstate(READ_WAIT);
+		pdevice->getBase().setRwstate(WRITE_WAIT);
+	}
+	if(currentState == RECEIVED)
+	{
+		if(timeOut > 30)
+		{
+			currentState = INIT;
+		}
+		timeOut ++;
+	}
+	if(currentState != END)
 	{
-		int maxRegAddr = getRegAddrMax(ppacket, pitem);
-		int minRegAddr = getRegAddrMin(ppacket, pitem);
-		log_i("MaxRegAddr: 0x%x, MinRegAddr: 0x%x", maxRegAddr, minRegAddr);
+		  log_i("len的长度:%d",len);
+
+		  return S_OK;
+	}
 
-		if (maxRegAddr < minRegAddr)
+//	if(findAddrFlag  == 0)
+//	{
+//		log_i("寻址标志是0");
+//       if(currentId == 1)
+//       {
+//    	   //setGpioDetrict();
+//
+//    	   // 设置 GPIO 436 为高电平
+//    	   log_i("计数count = %d",count);
+//    	  if(count == 1)
+//    	  {
+//			  if (set_gpio_value(devPath, lowLevel) == 0)
+//			  {
+//				  log_i("Set GPIO 436 to high");
+//			  }
+//			  else
+//			  {
+//				  log_e("Failed to set GPIO 436 to high");
+//			  }
+//    	  }
+//
+//    	  else
+//    	  {
+//    		  if(count > 4)
+//    		  {
+//    			  // 设置 GPIO 436 为低电平
+//				  if (set_gpio_value(devPath, highLevel) == 0)
+//				  {
+//					  log_i("Set GPIO 436 to low");
+//				  }
+//				  else
+//				  {
+//					  log_e("Failed to set GPIO 436 to low");
+//				  }
+//				  sendAllocFrame(pbuf,currentId , len);
+//				  count = 0;
+//    		  }
+//    	  }
+//    	  count ++;
+//
+//
+//       }
+//       if()
+//       {
+//    	   sendAllocFrame(pbuf,currentId , len);
+//       }
+//       log_i("len的长度:%d",len);
+//       return S_OK;
+
+	//}
+	if(currentState == END)
+	//if(findAddrFlag  == 1)
+	{
+		idSuccessFlag = 0;
+		if (ppacket->getVitem().size() == 0)
 		{
-			log_i("Invalid register address range");
 			return S_FALSE;
 		}
-		int regNum = maxRegAddr - minRegAddr + 1;
 
-		pbuf[0] = retBigEndian(iParaId + minRegAddr, 24);
-		pbuf[1] = retBigEndian(iParaId + minRegAddr, 16);
-		pbuf[2] = retBigEndian(iParaId + minRegAddr, 8);
-		pbuf[3] = retBigEndian(iParaId + minRegAddr, 0);
-		pbuf[4] = retBigEndian(regNum, 8);
-		pbuf[5] = retBigEndian(regNum, 0);
-		len = 6;
-
-		if (pbuf == nullptr)
+		pdevice->getBase().setRwstate(READ_WAIT);	//----设置设备状态
+
+		std::string sParaId;
+		int iParaId;
+		Base &t_base = ppacket->getVitem().at(0)->getBase();
+		sParaId = t_base.getParam("功能码");
+		log_i("Parameter ID: %s", sParaId.c_str());
+		iParaId = strtol(sParaId.c_str(), NULL, HEX);
+		log_i("Parameter ID: %s", sParaId.c_str());
+		log_i("Converted Parameter ID: 0x%x", iParaId);
+		int frameFuncCode  = (iParaId & 0x070000);
+		log_i("frameFuncCode = 0x%x",frameFuncCode);
+		if (ppacket == nullptr || pitem == nullptr)
 		{
-			log_i("pbuf is null");
+			log_i("Invalid packet or item");
 			return S_FALSE;
 		}
-		for (int i = 0; i < 6; i++)
+		string t_saddr;
+		t_saddr = pdevice->getBase().getParam("站地址");
+		int t_iaddr = 0;
+		t_iaddr = strtol(t_saddr.c_str(), NULL, HEX);
+		log_i("stationAddr = %d",t_iaddr);
+		iParaId |=  (t_iaddr << 19);
+		log_i("onread -addStation-id = 0x%x",iParaId);
+
+		//判断寄存器是读寄存器
+		if(frameFuncCode == 0x030000)
 		{
-			log_i("onRead-读数据:pbuf[%d]:0x%x", i, pbuf[i]);
+			int maxRegAddr = getRegAddrMax(ppacket, pitem);
+			int minRegAddr = getRegAddrMin(ppacket, pitem);
+			log_i("MaxRegAddr: 0x%x, MinRegAddr: 0x%x", maxRegAddr, minRegAddr);
+
+			if (maxRegAddr < minRegAddr)
+			{
+				log_i("Invalid register address range");
+				return S_FALSE;
+			}
+			int regNum = maxRegAddr - minRegAddr + 1;
+
+			pbuf[0] = retBigEndian(iParaId + minRegAddr, 24);
+			pbuf[1] = retBigEndian(iParaId + minRegAddr, 16);
+			pbuf[2] = retBigEndian(iParaId + minRegAddr, 8);
+			pbuf[3] = retBigEndian(iParaId + minRegAddr, 0);
+			pbuf[4] = retBigEndian(regNum, 8);
+			pbuf[5] = retBigEndian(regNum, 0);
+			len = 6;
+
+			if (pbuf == nullptr)
+			{
+				log_i("pbuf is null");
+				return S_FALSE;
+			}
+			for (int i = 0; i < 6; i++)
+			{
+				log_i("onRead-读数据:pbuf[%d]:0x%x", i, pbuf[i]);
+			}
 		}
-	}
 
-	Channel *pC = pdevice->getParent();
-	log_i("Channel pointer: %p", pC);
-	if (pC == nullptr)
-	{
-		log_i("Channel pointer is null");
-		return S_FALSE;
-	}
-	if (pC != NULL)
-	{
-		if (m_tmpItems.count(pC->getBase().getObjid().toString()) == 0)
+		//初始化数据库容器
+		if (pC != NULL)
 		{
-			log_i("Temporary items not found for Channel ID: %s",
-					pC->getBase().getObjid().toString().c_str());
-			int ccount = pC->getDeviceCount();
-			log_i("Channel device count: %d", ccount);
-			std::multimap<int, Item*> tmpItems;
-			for (int i = 0; i < ccount; i++)
+			if (m_tmpItems.count(pC->getBase().getObjid().toString()) == 0)
 			{
-
-				for (size_t j = 0;
-						j < pC->getVDevice().at(i)->getVitem().size(); j++)
+				log_i("Temporary items not found for Channel ID: %s",
+						pC->getBase().getObjid().toString().c_str());
+				int ccount = pC->getDeviceCount();
+				log_i("Channel device count: %d", ccount);
+				std::multimap<int, Item*> tmpItems;
+				for (int i = 0; i < ccount; i++)
 				{
-					string t_sId;
-					Base &t_base =
-							pC->getVDevice().at(i)->getVitem().at(j)->getBase();
-					t_sId = t_base.getParam("写功能码");
-					log_i("写功能码: %s", t_sId.c_str());
-					int t_iId = 0;
-					t_iId = strtol(t_sId.c_str(), NULL, HEX);	//----获取帧ID
-					log_i("功能码转换为整数: 0x%x", t_iId);
-					string t_stype;
-					t_stype = t_base.getParam("帧类型");
-					log_i("帧类型: %s", t_stype.c_str());
-
-					if (t_stype == "1")
+
+					for (size_t j = 0;
+							j < pC->getVDevice().at(i)->getVitem().size(); j++)
 					{
-						t_iId |= 0x80000000;
-						log_i("帧类型为1，功能码更新为: 0x%x", t_iId);
-					}
+						string t_sId;
+						Base &t_base =
+								pC->getVDevice().at(i)->getVitem().at(j)->getBase();
+						t_sId = t_base.getParam("写功能码");
+						log_i("写功能码: %s", t_sId.c_str());
+						int t_iId = 0;
+						t_iId = strtol(t_sId.c_str(), NULL, HEX);	//----获取帧ID
+						log_i("功能码转换为整数: 0x%x", t_iId);
+						string t_stype;
+						t_stype = t_base.getParam("帧类型");
+						log_i("帧类型: %s", t_stype.c_str());
+
+						if (t_stype == "1")
+						{
+							t_iId |= 0x80000000;
+							log_i("帧类型为1，功能码更新为: 0x%x", t_iId);
+						}
 
-					string sStartAddr;
-					//sStartAddr = pC->getVDevice().at(i)->getBase().getParam("起始地址");
-					sStartAddr = t_base.getParam("起始地址");
-					log_i("起始地址 =%s", sStartAddr.c_str());
-
-					int iStartAddr = 0;
-					iStartAddr = strtol(sStartAddr.c_str(), NULL, HEX);
-					log_i("起始地址转换为整数: 0x%x", iStartAddr);
-					t_iId += iStartAddr;
-					string t_saddr;
-					t_saddr = pC->getVDevice().at(i)->getBase().getParam("站地址");
-					int t_iaddr = 0;
-					t_iaddr = strtol(t_saddr.c_str(), NULL, HEX);
-					t_iId |=  (t_iaddr << 19);
-					tmpItems.insert(
-							make_pair(t_iId,
-									pC->getVDevice().at(i)->getVitem().at(j)));
-					log_i("插入临时条目: ID=0x%x", t_iId);
+						string sStartAddr;
+						//sStartAddr = pC->getVDevice().at(i)->getBase().getParam("起始地址");
+						sStartAddr = t_base.getParam("起始地址");
+						log_i("起始地址 =%s", sStartAddr.c_str());
+
+						int iStartAddr = 0;
+						iStartAddr = strtol(sStartAddr.c_str(), NULL, HEX);
+						log_i("起始地址转换为整数: 0x%x", iStartAddr);
+						t_iId += iStartAddr;
+						string t_saddr;
+						t_saddr = pC->getVDevice().at(i)->getBase().getParam("站地址");
+						int t_iaddr = 0;
+						t_iaddr = strtol(t_saddr.c_str(), NULL, HEX);
+						t_iId |=  (t_iaddr << 19);
+						tmpItems.insert(
+								make_pair(t_iId,
+										pC->getVDevice().at(i)->getVitem().at(j)));
+						log_i("插入临时条目: ID=0x%x", t_iId);
+					}
 				}
-			}
 
-			m_tmpItems.insert(
-					make_pair(pC->getBase().getObjid().toString(), tmpItems));
-		}
-		else
-		{
-			log_i("Temporary items already exist for Channel ID: %s",
-					pC->getBase().getObjid().toString().c_str());
+				m_tmpItems.insert(
+						make_pair(pC->getBase().getObjid().toString(), tmpItems));
+			}
+			else
+			{
+				log_i("Temporary items already exist for Channel ID: %s",
+						pC->getBase().getObjid().toString().c_str());
+			}
 		}
-	}
 
-	return S_OK;
+		return S_OK;
+	}
 }
 
 /**
 {
 	log_i("isResponseOk");
 	int ret;
-
+	if(findAddrFlag == 0)
+	{
+		return S_OK;
+	}
 	switch (pdevice->getBase().getRwstate())
 	{
 	case READ_O:
 
 }
 
-/**
- * @content:解析数据
- * @time:2016-9-9
- * @author:Mr_zhu
- * @param: pdevice（设备句柄），ppacket（包句柄），pitem（点句柄），pbuf（数据缓冲区），len（返回报文长度），deletelen（待删除数据长度）
- * @return: HRESULT(S_OK，S_FALSE)
- * @decribe
- * 1#2016-9-9#V1.0#首次生成
- */
-HRESULT ProtocolImpl::onResponse(Device *pdevice, Packet *ppacket, Item *pitem,
-		PBYTE pbuf, const int len, int &deletelen)
+//寻址未成功，解析寻址报文
+void ProtocolImpl::ioResponse(Packet *ppacket, Item *pitem,PBYTE pbuf, const int len)
 {
+	std::map<int, int> dataSets; // 存储寄存器地址和值
+	int id;
+	int16_t buf;
+	dataSets=retIoDataSet(ppacket, pitem, pbuf, len);
+	log_i("pbuf[4]= 0x%x,pbuf[5] = 0x%x,pbuf[6] = 0x%x,pbuf[7] = 0x%x",pbuf[4],pbuf[5],pbuf[6],pbuf[7]);
 
-	log_i("onResponse");
-	int validlen = len;
-	int t_iRWState = pdevice->getBase().getRwstate();	//----设备读写状态
-	Base *pbase = new Base();
-	Base &base = *pbase;
+	for (const auto &entry : dataSets)
+	{
+		log_i("addrFrame = 0x%x, value = 0x%x", entry.first,
+				entry.second);
+	}
+	for (const auto &dataPair : dataSets)
+	{
+		log_i("addData.size=%d", dataSets.size());
+		id = dataPair.first;
 
-	std::vector<Item*> items = ppacket->getVitem();
-	std::map<int, int> dataSet; // 存储寄存器地址和值
+		id = (0x7fffffff) & id;
+		buf = dataPair.second;
+		log_i("id = 0x%x,dataPair.second =0x%x",id,buf);
+
+		if(currentState == RECEIVED )
+		{
+			proceessReplyFrame(id,buf);
+		}
+	}
+
+}
+
+//寻址成功，解析BMS传的数据
+int ProtocolImpl::normalDatasResponse(Device* pdevice,Packet* ppacket,Item* pitem,PBYTE pbuf,const int len)
+{
+	std::map<int, int> dataSet;
 	int id;
 	int16_t buf;
-
 	Channel *pC = pdevice->getParent();
+
 	if (pC == NULL)
 	{
 		log_e("%s, 父通道为空, 无法进行数据解析", pdevice->getBase().getName().c_str());
 		return S_FALSE;
 	}
-	switch (t_iRWState)
-	{
-	case READ_O:
-	case READ_WAIT:
-	case WRITE_WAIT:
-		log_i("WRITE_WAIT");
-		if (validlen >= 6)
-		{
-			dataSet=retDataSet(ppacket, pitem,pbuf,len);
-			log_i("pbuf[4]= 0x%x,pbuf[5] = 0x%x",pbuf[4],pbuf[5]);
+	dataSet = retDataSet(ppacket, pitem,pbuf,len);
+	log_i("pbuf[4]= 0x%x,pbuf[5] = 0x%x,pbuf[6] = 0x%x,pbuf[7] = 0x%x",pbuf[4],pbuf[5],pbuf[6],pbuf[7]);
 
-			for (const auto &entry : dataSet)
-			{
-				log_i("addrFrame = 0x%x, value = 0x%x", entry.first,
-						entry.second);
-			}
-			for (const auto &dataPair : dataSet)
-			{
-				log_i("addData.size=%d", dataSet.size());
-				id = dataPair.first;
-
-				id = (0x7fffffff) & id;
-				buf = dataPair.second;
-				log_i("dataPair.second =0x%x",buf);
+	for (const auto &entry : dataSet)
+	{
+		log_i("addrFrame = 0x%x, value = 0x%x", entry.first,
+				entry.second);
+	}
+	for (const auto &dataPair : dataSet)
+	{
+		log_i("addData.size=%d", dataSet.size());
+		id = dataPair.first;
 
+		id = (0x7fffffff) & id;
+		buf = dataPair.second;
 
-				//buf = (PBYTE) &dataPair.second;
-				//log_i("buf[0] =0x%x,buf[1] =0x%x",buf[0],buf[1]);
+		log_i("Processing data pair with ID: 0x%x", id);
 
+		if (m_tmpItems.count(pC->getBase().getObjid().toString()) > 0)
+		{
 
-				log_i("Processing data pair with ID: 0x%x", id);
+			log_i("Found temporary items for Channel ID: %s",
+					pC->getBase().getObjid().toString().c_str());
+			std::multimap<int, Item*> tmpItms = m_tmpItems.find(
+					pC->getBase().getObjid().toString())->second; //是否有效
+			for (const auto &data : tmpItms)
+			{
+				log_i("缓存条目中的缓存地址:0x%x,0x%x", data.first, data.second);
+			}
+			log_i("Temporary items size: %zu", tmpItms.size());
 
-				if (m_tmpItems.count(pC->getBase().getObjid().toString()) > 0)
+			std::multimap<int, Item*>::size_type cnt = tmpItms.count(
+					id);
+			log_i("Number of items with ID 0x%x: %zu", id, cnt);
+			std::multimap<int, Item*>::iterator iter = tmpItms.find(id);
+			if (iter != tmpItms.end())
+			{
+				for (; cnt > 0; cnt--, iter++)
 				{
+					log_i("Processing item %zu for ID 0x%x", cnt, id);
+					Item *t_item = iter->second;
+					//Device *ptdevice = (Device*) (t_item->getParent());
 
-					log_i("Found temporary items for Channel ID: %s",
-							pC->getBase().getObjid().toString().c_str());
-					std::multimap<int, Item*> tmpItms = m_tmpItems.find(
-							pC->getBase().getObjid().toString())->second; //是否有效
-					for (const auto &data : tmpItms)
+					if (t_item != NULL && pdevice != NULL)
 					{
-						log_i("缓存条目中的缓存地址:0x%x,0x%x", data.first, data.second);
+						log_i("Item and Device are valid");
+						int iId = iGetItemParaConfig(t_item,"写功能码");
+						int iStartAddr = iGetItemParaConfig(t_item,"起始地址");
+						string t_stype = sGetItemParaConfig(t_item,"帧类型");
+						string t_sDataType = sGetItemParaConfig(t_item,"数据类型");
+						string t_sByteOrder = sGetItemParaConfig(t_item,"字节序");
+						string t_sBits= sGetItemParaConfig(t_item ,"位地址");
+						iId += iStartAddr;
+						string t_saddr;
+						t_saddr = pdevice->getBase().getParam("站地址");
+						int t_iaddr = 0;
+						t_iaddr = strtol(t_saddr.c_str(), NULL, HEX);
+						log_i("t_iId = 0x%x,t_iaddr =%d,",iId,t_iaddr);
+
+						iId |=  (t_iaddr << 19);
+
+						log_i("设置的数据buf=%d,paraID = 0x%x",buf,iId);
+						setData(t_item, buf,id,iId,t_sDataType,t_sByteOrder,t_sBits);
 					}
-					log_i("Temporary items size: %zu", tmpItms.size());
 
-					std::multimap<int, Item*>::size_type cnt = tmpItms.count(
-							id);
-					log_i("Number of items with ID 0x%x: %zu", id, cnt);
-					std::multimap<int, Item*>::iterator iter = tmpItms.find(id);
-					if (iter != tmpItms.end())
+					else
 					{
-						for (; cnt > 0; cnt--, iter++)
+						if(t_item == NULL)
 						{
-							log_i("Processing item %zu for ID 0x%x", cnt, id);
-							Item *t_item = iter->second;
-							//Device *ptdevice = (Device*) (t_item->getParent());
-
-							if (t_item != NULL && pdevice != NULL)
-							{
-								log_i("Item and Device are valid");
-								int iId = iGetItemParaConfig(t_item,"写功能码");
-								int iStartAddr = iGetItemParaConfig(t_item,"起始地址");
-								string t_stype = sGetItemParaConfig(t_item,"帧类型");
-								string t_sDataType = sGetItemParaConfig(t_item,"数据类型");
-								string t_sByteOrder = sGetItemParaConfig(t_item,"字节序");
-								string t_sBits= sGetItemParaConfig(t_item ,"位地址");
-								iId += iStartAddr;
-
-								string t_saddr;
-								t_saddr = pdevice->getBase().getParam("站地址");
-								int t_iaddr = 0;
-								t_iaddr = strtol(t_saddr.c_str(), NULL, HEX);
-								log_i("t_iId = 0x%x,t_iaddr =%d,",iId,t_iaddr);
-
-								iId |=  (t_iaddr << 19);
-
-								log_i("设置的数据buf=%d,paraID = 0x%x",buf,iId);
-								setData(t_item, buf,id,iId,t_sDataType,t_sByteOrder,t_sBits);
-							}
-
-							else
-							{
-								if(t_item == NULL)
-								{
-									log_i("......item== NULL......");
-								}
-								return S_FALSE;
-							}
+							log_i("......item== NULL......");
 						}
+						return S_FALSE;
 					}
 				}
-				else
-				{
-					log_i("m_tmpItems.count(pC->getBase().getObjid().toString()) <0");
-					return S_FALSE;
-				}
-
 			}
-
-		    return S_OK;
-
-
 		}
-
-		if (pitem != nullptr)
+		else
 		{
-			delete pitem;
+			log_i("m_tmpItems.count(pC->getBase().getObjid().toString()) <0");
+			return S_FALSE;
 		}
+	}
+	return S_OK;
+}
 
-			break;
 
-			case WRITE_O:
-			break;
 
-			default:
-			break;
-		}
-		if (pbase != NULL)
+
+
+/**
+ * @content:解析数据
+ * @time:2016-9-9
+ * @author:Mr_zhu
+ * @param: pdevice（设备句柄），ppacket（包句柄），pitem（点句柄），pbuf（数据缓冲区），len（返回报文长度），deletelen（待删除数据长度）
+ * @return: HRESULT(S_OK，S_FALSE)
+ * @decribe
+ * 1#2016-9-9#V1.0#首次生成
+ */
+HRESULT ProtocolImpl::onResponse(Device *pdevice, Packet *ppacket, Item *pitem,
+		PBYTE pbuf, const int len, int &deletelen)
+{
+	log_i("onResponse");
+	int validlen = len;
+	int t_iRWState = pdevice->getBase().getRwstate();	//----设备读写状态
+	std::vector<Item*> items = ppacket->getVitem();
+	switch (t_iRWState)
+	{
+	case READ_O:
+	case READ_WAIT:
+	case WRITE_WAIT:
+		log_i("WRITE_WAIT");
+		log_i("当前状态:%d ---0-初始化，1-发送，2-接收,3-结束",currentState);
+		if (validlen >= 6)
 		{
-			delete pbase;
-			pbase = NULL;
-		}
+			if(findAddrFlag == 0)
+			{
+				//寻址成功前，BCU -BAU寻址数据回应处理
+				ioResponse(ppacket, pitem, pbuf,  len);
+				return S_OK;
+			}
+			else
+			{
+				//寻址成功，正常解析bms上传数据
+				normalDatasResponse(pdevice, ppacket, pitem,pbuf,len);
+			}
 
-		return S_OK;
+		}
+	break;
+	case WRITE_O:
+	break;
 
+	default:
+	break;
 	}
+	return S_OK;
+}
+
+
 #ifdef __cplusplus
 	extern "C" IUnknown* CreateInstance()
 	{

service/impl/ProtocolImpl.h

 		BYTE data1;
 	};
 
+	enum state
+	{
+		INIT= 0,
+		SEND ,
+		RECEIVED ,
+		END,
+
+	};
+
 private:
 	volatile long m_cRef;
 	int m_Level;
 	std::map<std::string, std::multimap<int, Item*> > m_tmpItems;
 	const ULONG VERSION;
 	int findAddrFlag = 0;
+	int idSuccessFlag = 0;
+	int sendCurrentId = 0;
+	int currentId = 1; //分配ID编号
+	int maxId = 0;    //最大分配ID
+	int orderMode = 0; //分配模式
+	int orderState  = 0; //分配状态
+
+	int firstResponSuccessFlag = 0;
+	int timeOut = 0;
+
+
+	std::string devPath = "/sys/class/gpio/gpio436/value"; //输入输出电平值设备
+	std::string exportPath = "/sys/class/gpio/export";    //GPIO设备导出设备
+	std::string directPath = "/sys/class/gpio/gpio436/direction"; //GPIO输入输出控制设备
+	std::string out ="out";
+	std::string in  = "in";
+	std::string gpio = "436";
+	std::string highLevel = "1";
+	std::string lowLevel  = "0";
+	int count  = 0;
+
+	int currentState = 0;
+
+
+
+
 private:
 	unsigned short getMinStartAddr(Packet* ppacket);
 	unsigned short getMaxStartAddr(Packet* ppacket, unsigned short& regnum);
 	unsigned short getRegNum(Packet* ppacket);
 	unsigned short getExpectLen(Packet* ppacket);
 
+
 	unsigned short GetCRC(PBYTE pchMsg, unsigned short usDataLen);
 
 	uint8_t retBigEndian(uint32_t value, int offset);
 	std::string sGetItemParaConfig(Item *pitem, std::string attribute);
 	void setData(Item *pitem,int16_t pbuf,int receiveData,int paraData,std::string t_sDataType,std::string t_sByteOrder,std::string t_sBits);
 
-
-
-
-
+	int setGpioDetrict();
+	void proceessReplyFrame(int frame,int datas);
+	void sendAllocFrame(PBYTE pbuf, int id,int &len);
+	void checkAllocStatus() ;
+	void reportAlarm() ;
+	int set_gpio_value(const std::string& gpio_path, const std::string& value) ;
+
+	void initIO();
+	void receiveAllocFrameRes();
+	void ending();
+	void ioFrameDeal(PBYTE pbuf,int len);
+	void ioResponse(Packet *ppacket, Item *pitem,PBYTE pbuf, const int len);
+	int normalDatasResponse(Device* pdevice,Packet* ppacket,Item* pitem,PBYTE pbuf,const int len);
+
+	std::map<int,int> retIoDataSet(Packet *ppacket, Item *pitem,PBYTE pbuf,int len);
+	std::map<int,int> handleIoData(PBYTE pbuf);
 
 	std::vector<uint8_t> intToBytes(int value);
 	inline std::string merge8(PBYTE pbuf, std::string byteorder)