DDB/source/app/app_task_tcp.c

#include "app_task_tcp.h"
#include "../msp/uart0.h"
#include "../msp/uart2.h"
#include "../app/task_w600.h"
#include "../app/app_config.h"



TS_tcp ts_tcp;

void L3_task_tcp_init(void)
{
	L1_task_init(&ts_tcp.task);
	L3_task_s_go(ts_tcp,D_task_init);
	ts_tcp.slaverIndex = 0;
	ts_tcp.pkglen = 0;
	ts_tcp.retryTimes = 0;
	ts_tcp.ackFlag = 0;
}

#define D_task_tcp_constructor_modbus_pkg 0x51
#define D_task_tcp_send_modbus_pkg 0x52
#define D_task_tcp_wait_modbus_ack 0x53
#define D_task_tcp_switch_next_slaver 0x54

void L3_task_tcp_handle(TS_tcp *s)
{
  TTSS_Task_init()
		L2_task_go(D_task_tcp_constructor_modbus_pkg);	
	TTSS_Task_step(D_task_tcp_constructor_modbus_pkg)	//构造包
		if(G.ccmd_slaver_info[s->slaverIndex].mask > 0)
		{
			s->pkglen = L3_pack_ccmodbus(&s->loopPkg,G.ccmd_slaver_info + s->slaverIndex);
			s->ackFlag = 0;
			s->retryTimes = 0;
			L2_task_go(D_task_tcp_send_modbus_pkg);
		}
		else
		{
			L2_task_go(D_task_tcp_switch_next_slaver);
		}
	TTSS_Task_step(D_task_tcp_send_modbus_pkg)			//发送包
		if(G.ccmd_slaver_info[s->slaverIndex].mask == 1)
		{
			G.ccmd_slaver_info[s->slaverIndex].mask = 0;
			L3_gm35_send_data((U8*)&s->loopPkg,s->pkglen);
			//L0_uart2_sendArray((U8*)&s->loopPkg,s->pkglen);
			//L0_uart2_sendArray((U8 *)&points,ts_task_oid.extra);
			s->sendStamp = s_nos_tick.t_1s;
			L2_task_go(D_task_tcp_wait_modbus_ack);
		}
	TTSS_Task_step(D_task_tcp_wait_modbus_ack)			//等待ack
		//if((s->slaverIndex) == 0x00)
		switch(s->slaverIndex)
		{
			case 0:
//				if(s_uart2_tcp_rec.ok)
				{
//					s_uart2_tcp_rec.ok = 0;
					s_task_gm35_flow.tcp_last_recv_stmp = s_nos_tick.t_1s;
//					s->pAckPkg = (TS_PH3_ccmodbus*)(s_uart2_tcp_rec.sp);
					//L3_gm35_rcv_data((U8*)s->pAckPkg,s->pAckPkg->num);
					if(s->pAckPkg->slaver == G.ccmd_slaver_info[s->slaverIndex].slaver)
					{
						s->ackFlag = 1;
						
						//switch(s->slaverIndex)
						//{
						//case 0://如果oper == 90：成功，91 == 不成功
						switch(s->pAckPkg->oper)
						{
							case 0x90:
								G.authed = 1;
								break;
							case 0x91:
								G.authed = 0;
								break;
							default:
								break;
						}
					}
					L2_task_go(D_task_tcp_switch_next_slaver);
				}
				//#if 0
				if(s_nos_tick.t_1s - s->sendStamp >= 5)	//重发
				{	
					if(++s->retryTimes < 3)
					{
						L2_task_go(D_task_tcp_send_modbus_pkg);
					}
					else
					{
						L2_task_go(D_task_tcp_switch_next_slaver);
					}
				}
				//#endif
						//break;
					//case 1:
			break;
			case 1:
				L2_task_go(D_task_tcp_switch_next_slaver);
				break;
			default:
				break;
						//}
		}
			//}
		//}
		
		//else
		//{
			//L2_task_go(D_task_tcp_switch_next_slaver);
		//}
		//L0_uart0_uc(s->ackFlag);
	TTSS_Task_step(D_task_tcp_switch_next_slaver)		//切换下一个
		if(++ s->slaverIndex >= CCMD_SLAVER_INFO_MAX)
		{		
			s->slaverIndex = 0;
		}
		L2_task_go(D_task_tcp_constructor_modbus_pkg);
	TTSS_Task_end();
}