port.c 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616
  1. /*
  2. * FreeModbus Libary: BARE Demo Application
  3. * Copyright (C) 2006 Christian Walter <wolti@sil.at>
  4. *
  5. * This program is free software; you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License as published by
  7. * the Free Software Foundation; either version 2 of the License, or
  8. * (at your option) any later version.
  9. *
  10. * This program is distributed in the hope that it will be useful,
  11. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  13. * GNU General Public License for more details.
  14. *
  15. * You should have received a copy of the GNU General Public License
  16. * along with this program; if not, write to the Free Software
  17. * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
  18. *
  19. * File: $Id$
  20. */
  21. /* ----------------------- Modbus includes ----------------------------------*/
  22. #include "mb.h"
  23. #include "mbport.h"
  24. #include "Main.h"
  25. #include "string.h"
  26. #include "At24cxx.h"
  27. #include "ReadEeprom.h"
  28. #include "gd32e230x_conf.h"
  29. #include "Timer.h"
  30. #include "Flash.h"
  31. #include "cfg.h"
  32. /* ----------------------- Defines ------------------------------------------*/
  33. //输入寄存器
  34. #define REG_INPUT_START 3000
  35. #define REG_INPUT_NREGS 4
  36. //保持寄存器
  37. #define REG_HOLD_START 4000
  38. #define REG_HOLD_NREGS 1500
  39. //线圈
  40. #define REG_COILS_START 0
  41. #define REG_COILS_NREGS 4
  42. //开关寄存器
  43. #define REG_DISCRETE_START 1000
  44. #define REG_DISCRETE_NREGS 4
  45. /* ----------------------- Static variables ---------------------------------*/
  46. static USHORT usRegInputStart = REG_INPUT_START;
  47. static USHORT usRegInputBuf[REG_INPUT_NREGS];
  48. static USHORT usRegHoldStart = REG_HOLD_START;
  49. static USHORT usRegHoldBuf[REG_HOLD_NREGS];
  50. static USHORT usRegCoilsStart = REG_COILS_START;
  51. static uint8_t usRegCoilsBuf[REG_COILS_NREGS];
  52. static USHORT usRegDiscreteStart = REG_DISCRETE_START;
  53. static uint8_t usRegDiscreteBuf[REG_DISCRETE_NREGS];
  54. extern unsigned long int Delay_Ms;
  55. extern unsigned char detection_value;
  56. /****************************************************************************
  57. * 名 称:eMBRegInputCB
  58. * 功 能:读取输入寄存器,对应功能码是 04 eMBFuncReadInputRegister
  59. * 入口参数:pucRegBuffer: 数据缓存区,用于响应主机
  60. * usAddress: 寄存器地址
  61. * usNRegs: 要读取的寄存器个数
  62. * 出口参数:
  63. * 注 意:上位机发来的 帧格式是: SlaveAddr(1 Byte)+FuncCode(1 Byte)
  64. * +StartAddrHiByte(1 Byte)+StartAddrLoByte(1 Byte)
  65. * +LenAddrHiByte(1 Byte)+LenAddrLoByte(1 Byte)+
  66. * +CRCAddrHiByte(1 Byte)+CRCAddrLoByte(1 Byte)
  67. * 3 区
  68. ****************************************************************************/
  69. eMBErrorCode
  70. eMBRegInputCB( UCHAR * pucRegBuffer, USHORT usAddress, USHORT usNRegs )
  71. {
  72. eMBErrorCode eStatus = MB_ENOERR;
  73. int iRegIndex;
  74. usAddress = usAddress - 1;
  75. if( ( usAddress >= REG_INPUT_START ) && ( usAddress + usNRegs <= REG_INPUT_START + REG_INPUT_NREGS ) )
  76. {
  77. iRegIndex = ( int )( usAddress - usRegInputStart );
  78. while( usNRegs > 0 )
  79. {
  80. *pucRegBuffer++ = ( unsigned char )( usRegInputBuf[iRegIndex] >> 8 );
  81. *pucRegBuffer++ = ( unsigned char )( usRegInputBuf[iRegIndex] & 0xFF );
  82. iRegIndex++;
  83. usNRegs--;
  84. }
  85. }
  86. else
  87. {
  88. eStatus = MB_ENOREG;
  89. }
  90. return eStatus;
  91. }
  92. /****************************************************************************
  93. * 名 称:eMBRegHoldingCB
  94. * 功 能:对应功能码有:06 写保持寄存器 eMBFuncWriteHoldingRegister
  95. * 16 写多个保持寄存器 eMBFuncWriteMultipleHoldingRegister
  96. * 03 读保持寄存器 eMBFuncReadHoldingRegister
  97. * 23 读写多个保持寄存器 eMBFuncReadWriteMultipleHoldingRegister
  98. * 入口参数:pucRegBuffer: 数据缓存区,用于响应主机
  99. * usAddress: 寄存器地址
  100. * usNRegs: 要读写的寄存器个数
  101. * eMode: 功能码
  102. * 出口参数:
  103. * 注 意:4 区
  104. ****************************************************************************/
  105. //unsigned int test1;
  106. //unsigned int test2;
  107. //unsigned int test3;
  108. //unsigned int test4;
  109. //unsigned long int test5=0x12345678;
  110. //USHORT test6[20];
  111. //unsigned char test[200]={0};
  112. unsigned char Chal_num;
  113. unsigned char WusNRegs;
  114. unsigned int WiRegIndex;
  115. unsigned int WeeiRegIndex;
  116. unsigned char Eeprom_Wbuf[200];
  117. extern ACDC_Wann_Read_Reg_t ACDC_Wann_All;
  118. extern EE_ACDC_ThresVal_struct_ReadReg EE_ACDC_All_ThrVal;
  119. extern EE_ACDC_State_All_Reg_En_t EE_ACDC_State_All_en;
  120. extern ACDC_Over_Func_WriteReg ACDC_Over_AllWriteReg;
  121. extern ACDC_Wann_Read_Reg_t ACDC_Wann_All;
  122. extern AC_Ele_struct_ReadReg AC_Ele_ReadReg_All;
  123. extern META_DATA_S meta_data ;
  124. extern information_t infomation;
  125. extern uint8_t upgreade_flag ;
  126. #if SUPPORT_SELF_LOCK
  127. extern uint8_t handle_k_1_status;
  128. extern uint8_t handle_k_2_status;
  129. extern uint8_t handle_k_3_status;
  130. extern uint8_t handle_k_4_status;
  131. #endif
  132. eMBErrorCode
  133. eMBRegHoldingCB( UCHAR * pucRegBuffer, USHORT usAddress, USHORT usNRegs, eMBRegisterMode eMode )
  134. {
  135. eMBErrorCode eStatus = MB_ENOERR;
  136. int iRegIndex;
  137. usAddress = usAddress - 1;
  138. if((usAddress >= REG_HOLD_START) && ((usAddress+usNRegs) <= (REG_HOLD_START + REG_HOLD_NREGS)))
  139. {
  140. iRegIndex = (int)(usAddress - usRegHoldStart);
  141. WiRegIndex = iRegIndex;
  142. switch(eMode)
  143. {
  144. case MB_REG_READ://读寄存器
  145. if((usAddress==Devid_ChalNumAddr)&&(usNRegs==Devid_ChalNumQua)) //读取设备类型和通道
  146. usRegHoldBuf[iRegIndex]= Devid_ChalNum;
  147. else if((usAddress>=AC_Sing_EleSmaAddr)&&(usAddress<=(AC_Sing_EleSmaAddr+AC_Sing_EleSmaQua)))//读取通道的参数
  148. {
  149. Chal_num = (usAddress-AC_Sing_EleSmaAddr)/12; //获取是哪个通道的数据
  150. memcpy(&usRegHoldBuf[iRegIndex],&AC_Ele_ReadReg[Chal_num],usNRegs*2);
  151. if(usAddress==AC_Sing_EleSmaAddr)
  152. Start_Read_Flag = 1;
  153. // else if(usAddress==(AC_Sing_EleSmaAddr+12*(RelaySlaveChaNum-1)))
  154. // Start_Read_Flag = 0;
  155. }
  156. else if((usAddress>=AC_Sing_State_SmaAddr)&&(usAddress<=(AC_Sing_State_SmaAddr+AC_Sing_State_SmaQua)))//读取通道的状态
  157. {
  158. Chal_num = (usAddress-AC_Sing_State_SmaAddr); //获取是哪个通道的数据
  159. //增加其他的状态,开关状态在继电器动作的函数中进行跟新
  160. for(int chn = 0; chn < usNRegs; chn++)
  161. {
  162. EE_ACDC_State_ReadRegTrue[chn].ACDC_Vol_Upthr_En = EE_ACDC_State_ReadReg[chn].ACDC_Vol_Upthr_En;
  163. EE_ACDC_State_ReadRegTrue[chn].ACDC_Vol_Upthr_Warn = EE_ACDC_State_ReadReg[chn].ACDC_Vol_Upthr_Warn;
  164. EE_ACDC_State_ReadRegTrue[chn].ACDC_Vol_Downthr_En = EE_ACDC_State_ReadReg[chn].ACDC_Vol_Downthr_En;
  165. EE_ACDC_State_ReadRegTrue[chn].ACDC_Vol_Downthr_Warn = EE_ACDC_State_ReadReg[chn].ACDC_Vol_Downthr_Warn;
  166. EE_ACDC_State_ReadRegTrue[chn].ACDC_Cur_Upthr_En = EE_ACDC_State_ReadReg[chn].ACDC_Cur_Upthr_En;
  167. EE_ACDC_State_ReadRegTrue[chn].ACDC_Cur_Upthr_Warn = EE_ACDC_State_ReadReg[chn].ACDC_Cur_Upthr_Warn;
  168. EE_ACDC_State_ReadRegTrue[chn].ACDC_Pow_Upthr_En = EE_ACDC_State_ReadReg[chn].ACDC_Pow_Upthr_En;
  169. EE_ACDC_State_ReadRegTrue[chn].ACDC_Pow_Upthr_Warn = EE_ACDC_State_ReadReg[chn].ACDC_Pow_Upthr_Warn;
  170. EE_ACDC_State_ReadRegTrue[chn].ACDC_Ele_Upthr_En = EE_ACDC_State_ReadReg[chn].ACDC_Ele_Upthr_En;
  171. EE_ACDC_State_ReadRegTrue[chn].ACDC_Ele_Upthr_Warn = EE_ACDC_State_ReadReg[chn].ACDC_Ele_Upthr_Warn;
  172. }
  173. memcpy(&usRegHoldBuf[iRegIndex],&EE_ACDC_State_ReadRegTrue[Chal_num],usNRegs*2);
  174. }else if((usAddress>=AC_Sing_Total_Consumer_Addr)&&(usAddress<=AC_Sing_Total_Consumer_Addr+AC_Sing_Total_ConsumerQua))
  175. {
  176. Chal_num = (usAddress-AC_Sing_Total_Consumer_Addr)/2;
  177. memcpy(&usRegHoldBuf[iRegIndex],&EE_ACDC_Total_Consum_Read_Reg[Chal_num],usNRegs*2);
  178. }else if((usAddress >= AC_Sing_All_Chn_ConsumerAddr) &&(usAddress <= AC_Sing_All_Chn_ConsumerAddr + AC_Sing_All_Chn_ConsumerQua))
  179. {
  180. memcpy(&usRegHoldBuf[iRegIndex],&ACDC_Total_All_Chn_Read_Reg,usNRegs*2);
  181. }else if(usAddress == AC_Sing_Detection_Addr)
  182. {
  183. memcpy(&usRegHoldBuf[iRegIndex],&detection_value,usNRegs*2);
  184. }else if(usAddress == AC_Sing_All_Over_Func_Wann_Addr)
  185. {
  186. memcpy(&usRegHoldBuf[iRegIndex],&ACDC_Wann_All,2);
  187. }else if(usAddress >= AC_Sing_All_EleSmaAddr && usAddress <= (AC_Sing_All_EleSmaAddr+AC_Sing_All_EleSmaQua))
  188. {
  189. Start_Read_Flag = 1;
  190. int base_addr = usAddress -AC_Sing_All_EleSmaAddr;
  191. uint32_t * base = (uint32_t *)(&AC_Ele_ReadReg_All);
  192. base += base_addr;
  193. memcpy(&usRegHoldBuf[iRegIndex],base,usNRegs*2);
  194. }else if(usAddress == AC_Sing_Information)
  195. {
  196. memcpy(&usRegHoldBuf[iRegIndex],&infomation,usNRegs*2);
  197. }
  198. while(usNRegs > 0)
  199. {
  200. *pucRegBuffer++ = (uint8_t)(usRegHoldBuf[iRegIndex] >> 8);
  201. *pucRegBuffer++ = (uint8_t)(usRegHoldBuf[iRegIndex] & 0xFF);
  202. iRegIndex++;
  203. usNRegs--;
  204. }
  205. break;
  206. case MB_REG_WRITE://写寄存器
  207. WusNRegs = usNRegs;
  208. while(usNRegs > 0)
  209. {
  210. usRegHoldBuf[iRegIndex] = *pucRegBuffer++ << 8;
  211. usRegHoldBuf[iRegIndex] |= *pucRegBuffer++;
  212. iRegIndex++;
  213. usNRegs--;
  214. }
  215. if((usAddress>=AC_Sing_Dela_OnSmaAddr)&&(usAddress<=AC_Sing_Dela_OnSmaAddr+AC_Sing_Dela_OnSmaQua)) //设置通道之间的开启延时
  216. {
  217. WeeiRegIndex = (int)(usAddress - AC_Sing_Dela_OnSmaAddr);
  218. Chal_num = (usAddress-AC_Sing_Dela_OnSmaAddr); //设置哪个通道的延时
  219. // memcpy(&ACDC_Delay_WriteReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs); //将接收的数据放入写结构体中
  220. memcpy(&EE_ACDC_Delay_ReadReg_On[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将接收的数据放入读结构体中
  221. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将数据由16进制转化为无符号数据存入数组
  222. AT24CxxWrite(Eepr_AC_Sing_Dela_OnSmaAddr+WeeiRegIndex*2,Eeprom_Wbuf, WusNRegs*2); //将数据写入到eeprom中
  223. memcpy(&Sort_Onbuf,&EE_ACDC_Delay_ReadReg_On,Eepr_AC_Sing_Dela_OnSmaQua); //将数据进行排序,然后存入数组中,确保开关的时序
  224. Bubble_Sort(Sort_Onbuf,RelaySlaveChaNum);
  225. // AT24CxxRead(Eepr_AC_Sing_DelaSmaAddr+WusNRegs*2, test, Eepr_AC_Sing_DelaSmaQua); //从eeprom中读出通道延时数据
  226. // memcpy(&EE_ACDC_Delay_ReadReg1,&test,Eepr_AC_Sing_DelaSmaQua); //将数据拷贝到指定的结构体,可能需要注意大小端问题
  227. }
  228. else if((usAddress>=AC_Sing_Dela_OffSmaAddr)&&(usAddress<=AC_Sing_Dela_OffSmaAddr+AC_Sing_Dela_OffSmaQua)) //设置通道之间的关闭延时
  229. {
  230. WeeiRegIndex = (int)(usAddress - AC_Sing_Dela_OffSmaAddr);
  231. Chal_num = (usAddress-AC_Sing_Dela_OffSmaAddr); //设置哪个通道的延时
  232. // memcpy(&ACDC_Delay_WriteReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs); //将接收的数据放入写结构体中
  233. memcpy(&EE_ACDC_Delay_ReadReg_Off[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将接收的数据放入读结构体中
  234. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将数据由16进制转化为无符号数据存入数组
  235. AT24CxxWrite(Eepr_AC_Sing_Dela_OffSmaAddr+WeeiRegIndex*2,Eeprom_Wbuf, WusNRegs*2); //将数据写入到eeprom中
  236. memcpy(&Sort_Offbuf,&EE_ACDC_Delay_ReadReg_Off,Eepr_AC_Sing_Dela_OffSmaQua); //将数据进行排序,然后存入数组中
  237. Bubble_Sort(Sort_Offbuf,RelaySlaveChaNum);
  238. // AT24CxxRead(Eepr_AC_Sing_DelaSmaAddr+WusNRegs*2, test, Eepr_AC_Sing_DelaSmaQua); //从eeprom中读出通道延时数据
  239. // memcpy(&EE_ACDC_Delay_ReadReg1,&test,Eepr_AC_Sing_DelaSmaQua); //将数据拷贝到指定的结构体,可能需要注意大小端问题
  240. }
  241. else if((usAddress>=AC_Sing_State_SmaWAddr)&&(usAddress<=AC_Sing_State_SmaWAddr+AC_Sing_State_SmaWQua))//设置通道的状态
  242. {
  243. #if(!SUPPORT_OUTPUT_NOT_CTRL)
  244. WeeiRegIndex = (int)(usAddress - AC_Sing_State_SmaWAddr);
  245. Chal_num = (usAddress-AC_Sing_State_SmaWAddr); //设置哪个通道的状态
  246. // memcpy(&ACDC_State_WriteReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs); //将接收的数据放入写结构体中
  247. memcpy(&EE_ACDC_State_ReadReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2);//将接收的数据放入读结构体中
  248. for(int i =0; i < RelaySlaveChaNum;i++)
  249. {
  250. if(EE_ACDC_ThresVal_ReadReg[i].ACDC_V_TopThres <= THRESHOULD_JUDGMENT)
  251. {
  252. EE_ACDC_State_ReadReg[i].ACDC_Vol_Upthr_En = false;
  253. }
  254. if(EE_ACDC_ThresVal_ReadReg[i].ACDC_V_DownThres <= THRESHOULD_JUDGMENT)
  255. {
  256. EE_ACDC_State_ReadReg[i].ACDC_Vol_Downthr_En = false;
  257. }
  258. if(EE_ACDC_ThresVal_ReadReg[i].ACDC_I_TopThres <= THRESHOULD_JUDGMENT)
  259. {
  260. EE_ACDC_State_ReadReg[i].ACDC_Cur_Upthr_En = false;
  261. }
  262. if(EE_ACDC_ThresVal_ReadReg[i].ACDC_P_TopThres <= THRESHOULD_JUDGMENT)
  263. {
  264. EE_ACDC_State_ReadReg[i].ACDC_Pow_Upthr_En = false;
  265. }
  266. if(EE_ACDC_ThresVal_ReadReg[i].ACDC_E_TopThres <= THRESHOULD_JUDGMENT)
  267. {
  268. EE_ACDC_State_ReadReg[i].ACDC_Ele_Upthr_En = false;
  269. }
  270. }
  271. #if SUPPORT_SELF_LOCK
  272. #if (RelaySlaveChaNum >= 1)
  273. if(handle_k_1_status == 0)
  274. {
  275. EE_ACDC_State_ReadReg[0].ACDC_Cha_On_Off_State = 0;
  276. }
  277. #endif
  278. #if (RelaySlaveChaNum >= 2)
  279. if(handle_k_2_status == 0)
  280. {
  281. EE_ACDC_State_ReadReg[1].ACDC_Cha_On_Off_State = 0;
  282. }
  283. #endif
  284. #if (RelaySlaveChaNum >= 3)
  285. if(handle_k_3_status == 0)
  286. {
  287. EE_ACDC_State_ReadReg[2].ACDC_Cha_On_Off_State = 0;
  288. }
  289. #endif
  290. #if (RelaySlaveChaNum >= 4)
  291. if(handle_k_4_status == 0)
  292. {
  293. EE_ACDC_State_ReadReg[3].ACDC_Cha_On_Off_State = 0;
  294. }
  295. #endif
  296. #endif
  297. memcpy(&Eeprom_Wbuf,&EE_ACDC_State_ReadReg[Chal_num],WusNRegs*2); //将数据由16进制转化为无符号数据存入数组
  298. AT24CxxWrite(Eepr_AC_Sing_State_SmaWAddr+WeeiRegIndex*2,Eeprom_Wbuf, WusNRegs*2); //将数据写入到eeprom中
  299. if((WusNRegs==RelaySlaveChaNum)&&(EE_ACDC_State_ReadReg[0].ACDC_Cha_On_Off_State==true)&&(EE_ACDC_State_ReadReg[0].ACDC_ALLCha_On_State==true))//通过下发的通道数和开关状态可以判断为全开
  300. {
  301. All_On_Flag = 1; //全开标志置1
  302. All_Off_Flag = 0;
  303. timer_enable(TIMER14);
  304. Delay_Ms_2 = 0;
  305. }
  306. else if((WusNRegs==RelaySlaveChaNum)&&(EE_ACDC_State_ReadReg[0].ACDC_Cha_On_Off_State==false)&&(EE_ACDC_State_ReadReg[0].ACDC_ALLCha_Off_State==true))//通过下发的通道数和开关状态可以判断为全关
  307. {
  308. All_Off_Flag = 1; //全关标志置1
  309. All_On_Flag = 0;
  310. timer_enable(TIMER14);
  311. Delay_Ms_2 = 0;
  312. }
  313. else
  314. {
  315. #if SUPPORT_DETECTION
  316. #if ((RelaySlaveChaNum == 6) || ((RelaySlaveChaNum == 8) && SUPPORT_2_DETECTION))
  317. if((detection_value & 0x1) == 0)
  318. {
  319. uint8_t k = 0;
  320. uint8_t channel = (RelaySlaveChaNum % 2) ? (RelaySlaveChaNum/2 +1) : (RelaySlaveChaNum / 2);
  321. for(k=0;k <channel;k++)
  322. EE_ACDC_State_ReadReg[k].ACDC_Cha_On_Off_State = false;
  323. }
  324. if((detection_value & 0x2) == 0)
  325. {
  326. uint8_t k = 0;
  327. uint8_t channel = (RelaySlaveChaNum % 2) ? (RelaySlaveChaNum/2 +1) : (RelaySlaveChaNum / 2);
  328. for(k=channel;k <RelaySlaveChaNum;k++)
  329. EE_ACDC_State_ReadReg[k].ACDC_Cha_On_Off_State = false;
  330. }
  331. #else
  332. if(detection_value != 0)
  333. #endif
  334. #endif
  335. //RelayState();
  336. RelayState_ch(Chal_num);
  337. }
  338. #endif
  339. }
  340. else if((usAddress>=AC_Sing_Thr_SmaAddr)&&(usAddress<=AC_Sing_Thr_SmaAddr+AC_Sing_Thr_SmaQua))//设置通道的阈值
  341. {
  342. WeeiRegIndex = (int)(usAddress - AC_Sing_Thr_SmaAddr);
  343. Chal_num = (usAddress-AC_Sing_Thr_SmaAddr)/16; //设置哪个通道的阈值
  344. // memcpy(&ACDC_ThresVal_WriteReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将接收的数据放入写结构体中
  345. memcpy(&EE_ACDC_ThresVal_ReadReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将接收的数据放入读结构体中
  346. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_V_TopThres <= THRESHOULD_JUDGMENT)
  347. {
  348. EE_ACDC_State_ReadReg[Chal_num].ACDC_Vol_Upthr_En = false;
  349. }else
  350. {
  351. EE_ACDC_State_ReadReg[Chal_num].ACDC_Vol_Upthr_En = true;
  352. }
  353. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_V_DownThres <= THRESHOULD_JUDGMENT)
  354. {
  355. EE_ACDC_State_ReadReg[Chal_num].ACDC_Vol_Downthr_En = false;
  356. }else
  357. {
  358. EE_ACDC_State_ReadReg[Chal_num].ACDC_Vol_Downthr_En = true;
  359. }
  360. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_I_TopThres <= THRESHOULD_JUDGMENT)
  361. {
  362. EE_ACDC_State_ReadReg[Chal_num].ACDC_Cur_Upthr_En = false;
  363. }else
  364. {
  365. EE_ACDC_State_ReadReg[Chal_num].ACDC_Cur_Upthr_En = true;
  366. }
  367. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_P_TopThres <= THRESHOULD_JUDGMENT)
  368. {
  369. EE_ACDC_State_ReadReg[Chal_num].ACDC_Pow_Upthr_En = false;
  370. }else
  371. {
  372. EE_ACDC_State_ReadReg[Chal_num].ACDC_Pow_Upthr_En = true;
  373. }
  374. if(EE_ACDC_ThresVal_ReadReg[Chal_num].ACDC_E_TopThres <= THRESHOULD_JUDGMENT)
  375. {
  376. EE_ACDC_State_ReadReg[Chal_num].ACDC_Ele_Upthr_En = false;
  377. }else
  378. {
  379. EE_ACDC_State_ReadReg[Chal_num].ACDC_Ele_Upthr_En = true;
  380. }
  381. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将数据由16进制转化为无符号数据存入数组
  382. AT24CxxWrite(Eepr_AC_Sing_Thr_SmaAddr+WeeiRegIndex*2,Eeprom_Wbuf, WusNRegs*2); //将数据写入到eeprom中
  383. }
  384. else if((usAddress>=AC_Sing_Coef_SmaAddr)&&(usAddress<=AC_Sing_Coef_SmaAddr+AC_Sing_Coef_SmaQua))//设置通道的系数
  385. {
  386. WeeiRegIndex = (int)(usAddress - AC_Sing_Coef_SmaAddr);
  387. Chal_num = (usAddress-AC_Sing_Coef_SmaAddr)/8; //设置哪个通道的系数
  388. // memcpy(&ACDC_Coef_WriteReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将接收的数据放入写结构体中
  389. memcpy(&EE_ACDC_Coef_ReadReg[Chal_num],&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将接收的数据放入读结构体中
  390. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],WusNRegs*2); //将数据由16进制转化为无符号数据存入数组
  391. AT24CxxWrite(Eepr_AC_Sing_Coef_SmaAddr+WeeiRegIndex*2,Eeprom_Wbuf, WusNRegs*2); //将数据写入到eeprom中
  392. }else if((usAddress>=AC_Sing_Channel_Func)&&(usAddress<=AC_Sing_Channel_Func+AC_Sing_Channel_FuncQua))
  393. {
  394. WeeiRegIndex = (int)(usAddress - AC_Sing_Channel_Func);
  395. memcpy(&ACDC_Over_WriteReg[WeeiRegIndex],&usRegHoldBuf[WiRegIndex],WusNRegs*2);
  396. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],WusNRegs*2);
  397. AT24CxxWrite(Eepr_AC_Sing_Channel_Func_SmaAddr+WeeiRegIndex*2,Eeprom_Wbuf, WusNRegs*2);
  398. }else if(usAddress >= AC_Sing_Clear_Consumer && usAddress <= AC_Sing_Clear_Consumer+ AC_Sing_Clear_ConsumerQua)
  399. {
  400. //WeeiRegIndex = (int)(usAddress - AC_Sing_Clear_Consumer);
  401. Chal_num = usAddress-AC_Sing_Clear_Consumer;
  402. //AT24CxxRead(Eepr_AC_Sing_Total_Consumer_addr, Eeprom_Rbuf, Eepr_AC_Sing_Total_Consumer_SmaQua);
  403. uint16_t recive = 0;
  404. memcpy(&recive,&usRegHoldBuf[WiRegIndex],WusNRegs*2);
  405. EE_ACDC_Consumer_Clear[Chal_num].flag = 1;
  406. EE_ACDC_Consumer_Clear[Chal_num].value = recive;
  407. consumer_clear_flag = 1;
  408. }else if(usAddress == AC_Sing_Clear_Consumer_all)
  409. {
  410. uint16_t recive = 0;
  411. memcpy(&recive,&usRegHoldBuf[WiRegIndex],WusNRegs*2);
  412. consumer_clear_flag = 1;
  413. for(int i = 0; i < RelaySlaveChaNum;i++)
  414. {
  415. EE_ACDC_Consumer_Clear[i].flag = 1;
  416. EE_ACDC_Consumer_Clear[i].value = recive;
  417. }
  418. }else if(usAddress >= AC_Sing_All_Thr_SmaAddr && (usAddress <=(AC_Sing_All_Thr_SmaAddr + AC_Sing_All_Thr_SmaAddr_Qua)))
  419. {
  420. WeeiRegIndex = (int)(usAddress - AC_Sing_Thr_SmaAddr);
  421. //Chal_num = (usAddress-AC_Sing_All_Thr_SmaAddr)/16;
  422. memcpy(&EE_ACDC_All_ThrVal,&usRegHoldBuf[WiRegIndex],WusNRegs*2);
  423. if(EE_ACDC_All_ThrVal.ACDC_V_TopThres <= THRESHOULD_JUDGMENT)
  424. {
  425. EE_ACDC_State_All_en.ACDC_Vol_Upper_En = false;
  426. }else
  427. {
  428. EE_ACDC_State_All_en.ACDC_Vol_Upper_En = true;
  429. }
  430. if(EE_ACDC_All_ThrVal.ACDC_V_DownThres <= THRESHOULD_JUDGMENT)
  431. {
  432. EE_ACDC_State_All_en.ACDC_Vol_Lower_En= false;
  433. }else
  434. {
  435. EE_ACDC_State_All_en.ACDC_Vol_Lower_En= true;
  436. }
  437. if(EE_ACDC_All_ThrVal.ACDC_I_TopThres <= THRESHOULD_JUDGMENT)
  438. {
  439. EE_ACDC_State_All_en.ACDC_Current_Upper_En = false;
  440. }else
  441. {
  442. EE_ACDC_State_All_en.ACDC_Current_Upper_En= true;
  443. }
  444. if(EE_ACDC_All_ThrVal.ACDC_P_TopThres <= THRESHOULD_JUDGMENT)
  445. {
  446. EE_ACDC_State_All_en.ACDC_Power_Upper_En = false;
  447. }else
  448. {
  449. EE_ACDC_State_All_en.ACDC_Power_Upper_En = true;
  450. }
  451. if(EE_ACDC_All_ThrVal.ACDC_E_TopThres <= THRESHOULD_JUDGMENT)
  452. {
  453. EE_ACDC_State_All_en.ACDC_Consumer_Upper_En = false;
  454. }else
  455. {
  456. EE_ACDC_State_All_en.ACDC_Consumer_Upper_En= true;
  457. }
  458. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],WusNRegs*2);
  459. AT24CxxWrite(Eepr_AC_Sing_All_Thr_SmaAddr,Eeprom_Wbuf, WusNRegs*2);
  460. }else if(usAddress == AC_Sing_All_Over_FuncAddr)
  461. {
  462. memcpy(&ACDC_Over_AllWriteReg,&usRegHoldBuf[WiRegIndex],2);
  463. memcpy(&Eeprom_Wbuf,&usRegHoldBuf[WiRegIndex],2);
  464. AT24CxxWrite(Eepr_AC_Sing_All_Over_SmaAddr,Eeprom_Wbuf,2);
  465. }else if(AC_Sing_Break_Upgrade == usAddress)
  466. {
  467. if(usRegHoldBuf[WiRegIndex] == 0XA5A5)
  468. upgreade_flag = 1;
  469. }
  470. }
  471. }
  472. else//错误
  473. {
  474. eStatus = MB_ENOREG;
  475. }
  476. return eStatus;
  477. }
  478. /****************************************************************************
  479. * 名 称:eMBRegCoilsCB
  480. * 功 能:对应功能码有:01 读线圈 eMBFuncReadCoils
  481. * 05 写线圈 eMBFuncWriteCoil
  482. * 15 写多个线圈 eMBFuncWriteMultipleCoils
  483. * 入口参数:pucRegBuffer: 数据缓存区,用于响应主机
  484. * usAddress: 线圈地址
  485. * usNCoils: 要读写的线圈个数
  486. * eMode: 功能码
  487. * 出口参数:
  488. * 注 意:如继电器
  489. * 0 区
  490. ****************************************************************************/
  491. eMBErrorCode
  492. eMBRegCoilsCB( UCHAR * pucRegBuffer, USHORT usAddress, USHORT usNCoils, eMBRegisterMode eMode )
  493. {
  494. eMBErrorCode eStatus = MB_ENOERR;
  495. USHORT iRegIndex;
  496. USHORT usCoilGroups = ((usNCoils - 1) / 8 + 1);
  497. UCHAR ucStatus = 0;
  498. UCHAR ucBits = 0;
  499. UCHAR ucDisp = 0;
  500. usAddress = usAddress - 1;
  501. if((usAddress >= REG_COILS_START) && ((usAddress + usNCoils) <= (REG_COILS_START + REG_COILS_NREGS)))
  502. {
  503. iRegIndex = (int)(usAddress - usRegCoilsStart);
  504. switch(eMode)
  505. {
  506. case MB_REG_READ://读线圈
  507. while(usCoilGroups--)
  508. {
  509. ucDisp = 0;
  510. ucBits = 8;
  511. while((usNCoils--) != 0 && (ucBits--) != 0)
  512. {
  513. ucStatus |= (usRegCoilsBuf[iRegIndex++] << (ucDisp++));
  514. }
  515. *pucRegBuffer++ = ucStatus;
  516. }
  517. break;
  518. case MB_REG_WRITE://写线圈
  519. while(usCoilGroups--)
  520. {
  521. ucStatus = *pucRegBuffer++;
  522. ucBits = 8;
  523. while((usNCoils--) != 0 && (ucBits--) != 0)
  524. {
  525. usRegCoilsBuf[iRegIndex++] = ucStatus & 0X01;
  526. ucStatus >>= 1;
  527. }
  528. }
  529. }
  530. }
  531. else//错误
  532. {
  533. eStatus = MB_ENOREG;
  534. }
  535. return eStatus;
  536. }
  537. /****************************************************************************
  538. * 名 称:eMBRegDiscreteCB
  539. * 功 能:读取离散寄存器,对应功能码有:02 读离散寄存器 eMBFuncReadDiscreteInputs
  540. * 入口参数:pucRegBuffer: 数据缓存区,用于响应主机
  541. * usAddress: 寄存器地址
  542. * usNDiscrete: 要读取的寄存器个数
  543. * 出口参数:
  544. * 注 意:1 区
  545. ****************************************************************************/
  546. eMBErrorCode
  547. eMBRegDiscreteCB( UCHAR * pucRegBuffer, USHORT usAddress, USHORT usNDiscrete )
  548. {
  549. eMBErrorCode eStatus = MB_ENOERR;
  550. USHORT iRegIndex;
  551. USHORT usDiscreteGroups = ((usNDiscrete - 1) / 8 + 1);
  552. UCHAR ucStatus = 0;
  553. UCHAR ucBits = 0;
  554. UCHAR ucDisp = 0;
  555. usAddress = usAddress - 1;
  556. if((usAddress >= REG_DISCRETE_START) && ((usAddress + usNDiscrete) <= (REG_DISCRETE_START + REG_DISCRETE_NREGS)))
  557. {
  558. iRegIndex = (int)(usAddress - usRegDiscreteStart);
  559. while(usDiscreteGroups--)
  560. {
  561. ucDisp = 0;
  562. ucBits = 8;
  563. while((usNDiscrete--) != 0 && (ucBits--) != 0)
  564. {
  565. if(usRegDiscreteBuf[iRegIndex])
  566. {
  567. ucStatus |= (1 << ucDisp);
  568. }
  569. ucDisp++;
  570. }
  571. *pucRegBuffer++ = ucStatus;
  572. }
  573. }
  574. else//错误
  575. {
  576. eStatus = MB_ENOREG;
  577. }
  578. return eStatus;
  579. }