继续完善

jinlicong

2024-04-30 ee3c90168f81ce19529904d80f9c9de4fed23bb8

 Function/FLOW_METER_DATA_COLLECT/rs485_read_data.c

@@ -1,81 +1,209 @@
#include "rs485_read_data.h"
#include "rs485_data_analysis_pro.h"
__IO RS485_COM_STATUS_T   rs485_com_status_g = RS485_COM_IDLE;
#include "tim.h"

/****ÕûÌå¿ØÖÆ˼·******************
*RS485ÕûÌå¿ØÖÆ·ÖΪÉϵ硢·¢ËͶÁÈ¡Ö¸Áî¡¢µÈ´ý½ÓÊÕÊý¾Ý²¢´¦ÀíÈý¸ö״̬»ú²½Ö裻¿ÉÒÔʵÏֵȴý³¬Ê±ÅжϺͶà´ÎÖضÁ¡£
*Õë¶ÔmodbusµØÖ··ÖµÄ±È½Ï¿ª£¬²»ÄÜÒ»´ÎÐÔ¶ÁÈ¡µÄÇé¿ö£¬·ÖRS485_MODBUS_STEP_STATUS_T¶ÁÈ¡£¬ÊÂÏÈÅäÖÃ×îºóÒ»¸öSTEP£¬ËùÓÐÐͺŵĵÚÒ»¸ö²½Ö趼ÊÇSTEP1£¬
*µ±³É¹¦¶ÁÈ¡Ò»´ÎÖ¸ÁîÖ®ºó£¬Åжϵ±Ç°STEPÊÇ·ñ´óÓÚµÈÓÚ×îºóÒ»¸öSTEP£¬ÊÇÔò±íʾȫ²¿¶ÁÈ¡Íê³É£¬·ñ´ú±íÐèÒª¼ÌÐø·¢ËÍÏÂÒ»¸öSTEPµÄ¶ÁÈ¡Ö¸Á
*
**********************************/

//__IO RS485_COM_STATUS_T   rs485_com_status_g = RS485_COM_IDLE;

//¸ù¾ÝÉ豸´úÂë´¦Àí£¬²¢·µ»Ø¹©µçÑÓʱʱ¼äms
uint16_t rs485GetDelayTime(uint16_t device_code)
//__IO FlagStatus   rs485_pwr_delay_status_g = RESET; //¹©µçʱ¼äµ½´ï±êÖ¾

//static uint8_t   rs485_pwr_delay_time_out_cnt =0;

__IO RS485_COM_CTRL_PARA_T rs485_com_ctrl_pata_g={
   .status = RS485_COM_IDLE,                        \
   .reread_num_cnt =0,                                   \
};

RS485_COM_UART_PARA_T   rs485_com_uart_data_g ={
   .recv_flag = RESET,                     \
};

//¸ù¾ÝÉ豸´úÂë´¦Àí£¬²¢·µ»Ø¹©µçÑÓʱʱ¼äÕûÊýÃë
uint8_t rs485GetDelayTime(uint16_t device_code)
{

   //ÓÉÓÚ±¾Éí¹¤×÷ÖÜÆÚÊÇ1ÃëÒ»´Î£¬ËùÒÔÑÓʱµÄ²½½øÊÇ1000ms£¬ ±ÈÈçÊýÖµÔÚ0-1000msÖ®¼ä£¬Êµ¼ÊÑÓʱ¶¼Îª1Ãë×óÓÒ£¬ ÊýÖµÔÚ1000-2000msÖ®¼ä£¬Êµ¼ÊÑÓʱ¶¼Îª2Ãë×óÓÒ
   switch (device_code){
      
            case SIZHUMODBUS1:      return 900;
            case SIZHUMODBUS2:   return 900;
            case SIZHUMODBUS3:   return 900;
        case SIZHUMODBUSV2_0:      return 900;
        case TIANXINCUSTOM:      return 900;
            case TIANXINMODBUS:   return 900;
            //ÐèÒª²¹³ä......
            case SIZHUMODBUS1:   rs485_com_ctrl_pata_g.modbus_last_status = MODBUS_STEP1;   return 1;
            case SIZHUMODBUS2:   rs485_com_ctrl_pata_g.modbus_last_status = MODBUS_STEP1;   return 1;
            case SIZHUMODBUS3:   rs485_com_ctrl_pata_g.modbus_last_status = MODBUS_STEP1;return 1;
        case SIZHUMODBUSV2_0:      rs485_com_ctrl_pata_g.modbus_last_status = MODBUS_STEP1;return 1;
        case TIANXINCUSTOM:      rs485_com_ctrl_pata_g.modbus_last_status = MODBUS_STEP1;return 1;
            case TIANXINMODBUS:   rs485_com_ctrl_pata_g.modbus_last_status = MODBUS_STEP1;return 1;
		
            case EKMODBUS:   rs485_com_ctrl_pata_g.modbus_last_status = MODBUS_STEP3;return 1;
            //?ÐèÒª²¹³ä......
        default:return 100;
    }
   
}




RS485_COM_STATUS_T   rs485ComPwrOnHandle(void)
//¸ù¾ÝÉ豸´úÂë·¢ËͶÁÈ¡Ö¡
void rs485SendReadData(uint16_t device_code,uint8_t slaveAddress)
{
   uint16_t delay_time;
   //IO¿Ú³õʼ»¯
	
	
   //´ò¿ª¹©µç
	
   //´ò¿ª¶¨Ê±Æ÷Öжϣ¬²»Í¬É豸¹©µçÑÓʱ²»µÈ£¬Òª²»Òª¿¼Âǹ©µçºó¿ÉÒÔÁ¢Âí¶ÁÈ¡µÄÇé¿ö£¿
   delay_time = rs485GetDelayTime(SIZHUMODBUSV2_0);
	

   switch (device_code){
		
            case SIZHUMODBUS1:   break;
            case SIZHUMODBUS2:   break;
            case SIZHUMODBUS3:   break;
        case SIZHUMODBUSV2_0:      sendModbusReadFrame(slaveAddress,501,49);break;
        case TIANXINCUSTOM:      break;
            case TIANXINMODBUS:   break;
		
            case EKMODBUS:	
                  if(rs485_com_ctrl_pata_g.modbus_step_status ==MODBUS_STEP1)
                     sendModbusReadFrame(slaveAddress,100,4);
                  else if(rs485_com_ctrl_pata_g.modbus_step_status ==MODBUS_STEP2)
                     sendModbusReadFrame(slaveAddress,306,4);
                  else if(rs485_com_ctrl_pata_g.modbus_step_status ==MODBUS_STEP3)
                     sendModbusReadFrame(slaveAddress,326,4);
            break;
            //?ÐèÒª²¹³ä......
        default:break;
    }
   
}









void rs485ReadDataPro(void)
RS485_COM_STATUS_T   rs485ComPwrOnHandle(void)
{
   uint8_t delay_time_s;
	
   //?IO¿Ú³õʼ»¯
	
   //?´ò¿ª¹©µç
	
   //´ò¿ª¶¨Ê±Æ÷Öжϣ¬²»Í¬É豸¹©µçÑÓʱ²»µÈ£¬Òª²»Òª¿¼Âǹ©µçºó¿ÉÒÔÁ¢Âí¶ÁÈ¡µÄÇé¿ö£¿
   delay_time_s = rs485GetDelayTime(SIZHUMODBUSV2_0);
   rs485_com_ctrl_pata_g.pwr_delay_status = RESET;
   rs485_com_ctrl_pata_g.pwr_delay_time_out_cnt = 0;
   
   
   if(1)//ÅжÏ485²É¼¯±êʶ
   //²ÎÊý״̬ÖÃλ
   rs485_com_ctrl_pata_g.reread_num_cnt = RS485_REREAD_NUM;
   rs485_com_ctrl_pata_g.reread_wait_time_cnt = RS485_REREAD_WATI_TIME;
	
   rs485_com_ctrl_pata_g.pwr_delay_time_out_cnt = delay_time_s;
	
   rs485_com_ctrl_pata_g.modbus_step_status = MODBUS_STEP1;
	
   return RS485_COM_SEND;
		
}


RS485_COM_STATUS_T   rs485ComSendHandle(void)
{
   //ÑÓʱÏÈ--£¬ Èç¹ûÑÓʱ1Ã룬ÏÈ--¾ÍµÈÓÚ0ÁË£¬ ÔÙÅжÏ==0¾Í¿ÉÒÔ¶ÁÈ¡Êý¾Ý¡£ÒòΪÉϵ絽·¢ËÍÊý¾Ý°´×´Ì¬»úÖ´ÐУ¬±¾Éí¾Í²îÁËÒ»¸öÑ­»·ÖÜÆÚµÄʱ¼ä£¨ÖÜÆÚ1Ã룩
   if(rs485_com_ctrl_pata_g.pwr_delay_time_out_cnt)
   {
		
      if(rs485_com_status_g == RS485_COM_IDLE)
      {
         rs485_com_status_g = RS485_COM_PWR_ON;
      }
		
		
		
      rs485_com_ctrl_pata_g.pwr_delay_time_out_cnt--;
   }
   
   
   switch (rs485_com_status_g){
   if(rs485_com_ctrl_pata_g.pwr_delay_time_out_cnt == 0)  //ÑÓʱµ½0¾Í¿ÉÒÔ·¢ËͶÁÈ¡Ö¸Áî
   {		
      rs485SendReadData(SIZHUMODBUSV2_0,1); //?´Ë´¦Èë²ÎÒª¸Ä
      rs485_com_ctrl_pata_g.reread_wait_time_cnt = RS485_REREAD_WATI_TIME; //ÖØÖõȴýÏìӦʱ¼ä
      return RS485_COM_WAIT_ANSWER;
   }
	
		
}



RS485_COM_STATUS_T   rs485ComWaitAnswerHandle(void)
{
   ErrorStatus   read_ok = FAIL;
   //?¼ì²é´®¿ÚÊý¾Ý
	
	
   //·ÖÎöÊý¾Ý,Èç¹û³É¹¦¶Áµ½Êý¾Ýread_ok = PASS
   if(rs485_com_uart_data_g.recv_flag == SET)
   {
      rs485_com_uart_data_g.recv_flag =RESET;
		
      read_ok = rs485ComDataAnalysis(rs485_com_uart_data_g,SIZHUMODBUSV2_0,1,rs485_com_ctrl_pata_g ) ;//?É豸´úÂë¡¢´Ó»úµØÖ·Èë²ÎÒª¸Ä
   }
	
	
   if(read_ok==PASS)
   {
		
      if(rs485_com_ctrl_pata_g.modbus_step_status >= rs485_com_ctrl_pata_g.modbus_last_status)  
      {
         //?´ú±íͨѶȫ²¿³É¹¦£¬½øÐÐÏàÓ¦µÄ´¦Àí
         //¹Ø±ÕµçÔ´¡¢¹Ø±Õ´®¿Ú
			
         return RS485_COM_IDLE;
      }
      else
      {
         rs485_com_ctrl_pata_g.modbus_step_status ++;
         return RS485_COM_SEND;
      }
   }
	
   if((--rs485_com_ctrl_pata_g.reread_wait_time_cnt)==0)
   {
      if((--rs485_com_ctrl_pata_g.reread_num_cnt)==0)
      {
         //?³¬Ê±ÇÒÖضÁ´ÎÊýÓÃÍ꣬´ú±íͨѶ×îÖÕÒÔʧ°Ü¸æÖÕ£¬½øÐÐÏàÓ¦µÄ´¦Àí
			
         //¹Ø±ÕµçÔ´¡¢¹Ø±Õ´®¿Ú£¬RS485ͨѶʧ°Ü+1,
			
         return RS485_COM_IDLE;
      }else
      {
         //³¬Ê±µ«ÊÇÖظ´´ÎÊý»¹ÓУ¬·µ»ØÖØз¢ËͶÁÈ¡Êý¾Ý
         return RS485_COM_SEND;
      }
		
   }

   return RS485_COM_WAIT_ANSWER;
		
}



void rs485ReadDataPro(FUN_START_CTRL_PARA_T * sys_fun_run_ctrl_p)
{
	
	
   if((sys_fun_run_ctrl_p->rs485_ctrl_flag.start_flag ==SET)&&(sys_fun_run_ctrl_p->valve_ctrl_flag.running_flag == RESET)&&(sys_fun_run_ctrl_p->wrc_ctrl_flag.running_flag == RESET))//?ÅжÏ485²É¼¯±êʶ
   {	
      sys_fun_run_ctrl_p->rs485_ctrl_flag.start_flag = RESET;
      if(rs485_com_ctrl_pata_g.status == RS485_COM_IDLE)
      {
         rs485_com_ctrl_pata_g.status = RS485_COM_PWR_ON;
         sys_fun_run_ctrl_p->rs485_ctrl_flag.running_flag = SET;
      }
	
   }
	
	
   switch (rs485_com_ctrl_pata_g.status){
      
            case RS485_COM_IDLE:      break;
            case RS485_COM_PWR_ON:   break;
            case RS485_COM_SEND:   break;
        case RS485_COM_WAIT_ANSWER:      break;
        case RS485_COM_TIMEOUT:      break;
            case RS485_COM_OFF:   break;
		
            case RS485_COM_PWR_ON:   rs485_com_ctrl_pata_g.status = rs485ComPwrOnHandle();break;
            case RS485_COM_SEND:   rs485_com_ctrl_pata_g.status = rs485ComSendHandle();break;
        case RS485_COM_WAIT_ANSWER:      rs485_com_ctrl_pata_g.status = rs485ComWaitAnswerHandle();break;
	
        default:;
    }
   
   if(rs485_com_ctrl_pata_g.status == RS485_COM_IDLE)
      sys_fun_run_ctrl_p->rs485_ctrl_flag.running_flag = RESET;
   
   
}