lb_bdy6.c

中国石油二期加油站IC系统后台通讯软件

/*
***********************************************************************************************************
                                                      Amos
                                          The Real_Time Operation System
                                                   Multi Task
                                 (c) Copyright 1998-2002, ShangYaoHui, Shenzhen
                                              All Right Reserved
                                                  VERSION 6.01

" By  : 商耀挥(ShangYaoHui)
 create time: 2002-7-6 18:24:18  
***********************************************************************************************************
*/

/************ head file list *************/
#include "envopt.h"        /* environment options */
#include "envdep.h"        /* environment dependent */
#include "envind.h"        /* environment independent */

#include "gen.h"           /* general */
#include "cm5.h"           /* common functions */
#include "ssi.h"           /* system services */

/* header/extern include files (.x) */

#include "gen.x"           /* general */
#include "cm5.x"           /* common functions */
#include "ssi.x"           /* system services */

#include "cm_llist.h"
#include "cm_llist.x"

#ifdef WIN32
	#include "winbase.h"
#endif

#include "rx.h"
#include "rx.x"

#include "rx_msg.h"
#include "rx_msg.x"

#include "lb_cm.h"
#include "lb_cm.x"

#include "lb_recv.h"
#include "lb_recv.x"
#include "lb_xmit.h"
#include "lb_xmit.x"
#include "lb_msg.h"
#include "lb_msg.x"

#include "lb_bdy1.h"
#include "lb_bdy1.x"
#include "lb_bdy2.h"
#include "lb_bdy2.x"
#include "lb_bdy4.h"
#include "lb_bdy3.h"
#include "lb_bdy3.x"
#include "lb_bdy4.h"
#include "lb_bdy4.h"
#include "lb_bdy4.x"
#include "lb_bdy5.h"
#include "lb_bdy5.x"
/************* const define **************/

/******** import variable declare ********/

/******* gloable variable declare ********/

/*********** function declare ************/

/********** function prototype ***********/
S16 lbIndRetxTmr(U32 machId)
{
	RETVALUE(ROK);
}
 
S16 lbRqstRetxTmr(U32 machId)
{
	RETVALUE(ROK);
}

S16 lbQueryTmr(U32 machId)
{
	EquCfgEntry_s * equ;
	TranCb_s * tran;
	RxCmdEntry_s * entry;
	static U32 shDebug = 0;
	Bool flag = FALSE;

	static U32 timeCnt = 0;

	equ = (EquCfgEntry_s *)cmLListFirst(&rxCb.pEquCfgList);
	if (equ != NULLP && LBGETCMDENTRYLEN() < 1)
	{
		LBGETCMDENTRY(0xa0, CMD_DIR, entry);
		while(equ != NULLP)
		{
			if(equ->stat != NO_ACTIVE)
			{
				LBGETTRAN(entry, equ, tran);
				lbBuildRqstStat(equ,tran );
				flag = TRUE;
			}

			equ = (EquCfgEntry_s *)cmLListNext(&rxCb.pEquCfgList);
		}
		if(flag == FALSE)
		{
			lbCmdDestroyCmdEntry(entry);
		}

	}
	equ = (EquCfgEntry_s *)cmLListFirst(&rxCb.pEquCfgList);

    while(equ != NULLP)
	{
		if(equ->first == TRUE)
		{
			LBGETCMDENTRY(0, CMD_DIR, entry);
			LBGETTRAN(entry, equ, tran);
			if((timeCnt % 18000) == 0)
			{
				lbBuildSetTimeCmd(equ,tran );
			}
			lbBuildSetNetModeCmd(equ, tran);
			equ->first = FALSE;
		}


		lbRecvProc(equ->entry.gunId);
		lbXmitProc(equ->entry.gunId);
		equ = (EquCfgEntry_s *)cmLListNext(&rxCb.pEquCfgList);
	}
	
	if ((shDebug++ % 600) == 0 )
		SRegShow(0 , 0);

	if (ROK != lbSchdTmr(QUERY_TMR_INTERVAL, QUERY_TMR, STOP_TMR))
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}
	if (ROK != lbSchdTmr(QUERY_TMR_INTERVAL, QUERY_TMR, START_TMR))
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}
	timeCnt++;

	RETVALUE(ROK);
}
 
 
/******************* modify histroy list *******************
001. create at: 2002-7-6 18:24:18 by Shangyaohui

****************** modify histroy list end ****************/