📄 lb_bdy5.c

📁 中国石油二期加油站IC系统后台通讯软件
💻 C
字号:
/*
***********************************************************************************************************
													  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 1:44:56  
***********************************************************************************************************
*/

/************ 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 lbIndGunUpMsg(EquCfgEntry_s * equ, TranCb_s * tran)
{
	CmdMsg_s * cmdNode;

	if(ROK != lbCmGetCmdNode(tran, &cmdNode))
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}
	if(equ == NULLP)
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}
	cmdNode->machId = equ->entry.machId;
	cmdNode->sideId = equ->entry.sideId;

	cmdNode->gunId = equ->entry.gunId;
	cmdNode->msgCode = 0x01;
	cmdNode->dir =IND_DIR;
	cmdNode->msg = NULLP;
	cmdNode->rqstParam = equ->entry.gunId;

	cmdNode->retry = 1;
	cmdNode->timer = 1;
	cmdNode->loadTimer = IND_TMR_EXPIRE;
	cmdNode->stat = RDY_SEND;

	RETVALUE(ROK);
}

S16 lbIndGunDownMsg(EquCfgEntry_s * equ, TranCb_s * tran)
{
	CmdMsg_s * cmdNode;

	if(ROK != lbCmGetCmdNode(tran, &cmdNode))
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}
	if(equ == NULLP)
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}
	cmdNode->machId = equ->entry.machId;
	cmdNode->sideId = equ->entry.sideId;

	cmdNode->gunId = equ->entry.gunId;
	cmdNode->msgCode = 0x02;
	cmdNode->dir =IND_DIR;
	cmdNode->msg = NULLP;
	cmdNode->rqstParam = equ->entry.gunId;

	cmdNode->retry = 1;
	cmdNode->timer = 1;
	cmdNode->loadTimer = IND_TMR_EXPIRE;
	cmdNode->stat = RDY_SEND;

	RETVALUE(ROK);
}

S16 lbIndUpdateTrans(EquCfgEntry_s * equ, TranCb_s * tran, U32 account, U32 volume)
{
	CmdMsg_s * cmdNode;

	if(ROK != lbCmGetCmdNode(tran, &cmdNode))
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}

	if(equ == NULLP)
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}

	cmdNode->machId = equ->entry.machId;
	cmdNode->sideId = equ->entry.sideId;

	cmdNode->gunId = equ->entry.gunId;

	cmdNode->msgCode = 0x0a;
	cmdNode->dir =IND_DIR;
	cmdNode->msg = NULLP;
	cmdNode->stat = ROK;
	cmdNode->rqstParam = equ->entry.gunId;

	cmdNode->retry = 1;
	cmdNode->timer = 1;
	cmdNode->loadTimer = IND_TMR_EXPIRE;
	cmdNode->stat = RDY_SEND;

	RETVALUE(ROK);
}

S16 lbIndWorkOnMsg(EquCfgEntry_s * equ, TranCb_s * tran)
{
	CmdMsg_s * cmdNode;

	if(ROK != lbCmGetCmdNode(tran, &cmdNode))
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}
	if(equ == NULLP)
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}


	cmdNode->machId = equ->entry.machId;
	cmdNode->sideId = equ->entry.sideId;

	cmdNode->gunId = equ->entry.gunId;

	cmdNode->msgCode = 0x03;
	cmdNode->dir =IND_DIR;
	cmdNode->msg = NULLP;
	cmdNode->stat = ROK;
	cmdNode->rqstParam = equ->entry.gunId;

	cmdNode->retry = 1;
	cmdNode->timer = 1;
	cmdNode->loadTimer = IND_TMR_EXPIRE;
	cmdNode->stat = RDY_SEND;

	RETVALUE(ROK);
}

S16 lbIndWorkOutMsg(EquCfgEntry_s * equ, TranCb_s * tran)
{
	CmdMsg_s * cmdNode;

	if(ROK != lbCmGetCmdNode(tran, &cmdNode))
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}

	if(equ == NULLP)
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}

	cmdNode->machId = equ->entry.machId;
	cmdNode->sideId = equ->entry.sideId;

	cmdNode->gunId = equ->entry.gunId;

	cmdNode->msgCode = 0x0b;
	cmdNode->dir =IND_DIR;
	cmdNode->msg = NULLP;
	cmdNode->stat = ROK;
	cmdNode->rqstParam = equ->entry.gunId;

	cmdNode->retry = 1;
	cmdNode->timer = 1;
	cmdNode->loadTimer = IND_TMR_EXPIRE;
	cmdNode->stat = RDY_SEND;

	RETVALUE(ROK);
}

S16 lbIndCardInMsg(EquCfgEntry_s * equ, TranCb_s * tran)
{
	CmdMsg_s * cmdNode;

	if(ROK != lbCmGetCmdNode(tran, &cmdNode))
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}
	if(equ == NULLP)
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}


	cmdNode->machId = equ->entry.machId;
	cmdNode->sideId = equ->entry.sideId;

	cmdNode->gunId = equ->entry.gunId;

	cmdNode->msgCode = 0x04;
	cmdNode->dir =IND_DIR;
	cmdNode->msg = NULLP;
	cmdNode->stat = ROK;
	cmdNode->rqstParam = equ->entry.gunId;

	cmdNode->retry = 1;
	cmdNode->timer = 1;
	cmdNode->loadTimer = IND_TMR_EXPIRE;
	cmdNode->stat = RDY_SEND;

	RETVALUE(ROK);
}


S16 lbIndCardOutMsg(EquCfgEntry_s * equ, TranCb_s * tran)
{
	CmdMsg_s * cmdNode;

	if(ROK != lbCmGetCmdNode(tran, &cmdNode))
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}

	if(equ == NULLP)
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}

	cmdNode->machId = equ->entry.machId;
	cmdNode->sideId = equ->entry.sideId;

	cmdNode->gunId = equ->entry.gunId;

	cmdNode->msgCode = 0x05;
	cmdNode->dir =IND_DIR;
	cmdNode->msg = NULLP;
	cmdNode->stat = ROK;
	cmdNode->rqstParam = equ->entry.gunId;

	cmdNode->retry = 1;
	cmdNode->timer = 1;
	cmdNode->loadTimer = IND_TMR_EXPIRE;
	cmdNode->stat = RDY_SEND;

	RETVALUE(ROK);
}


S16 lbIndRecMsg(EquCfgEntry_s * equ, TranCb_s * tran)
{
	CmdMsg_s * cmdNode;

	if(ROK != lbCmGetCmdNode(tran, &cmdNode))
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}
	if(equ == NULLP)
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}

	cmdNode->machId = equ->entry.machId;
	cmdNode->sideId = equ->entry.sideId;

	cmdNode->gunId = equ->entry.gunId;

	cmdNode->msgCode = 0x08;
	cmdNode->dir =IND_DIR;
	cmdNode->msg = NULLP;
	cmdNode->stat = ROK;
	cmdNode->rqstParam = equ->entry.gunId;

	cmdNode->retry = 3;
	cmdNode->timer = 1;
	cmdNode->loadTimer = 250;
	cmdNode->stat = RDY_SEND;

	RETVALUE(ROK);

}

S16 lbIndCardInfoMsg(EquCfgEntry_s * equ, TranCb_s * tran, U32 action)
{
	CmdMsg_s * cmdNode;

	if(ROK != lbCmGetCmdNode(tran, &cmdNode))
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}
	if(equ == NULLP)
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}

	cmdNode->machId = equ->entry.machId;
	cmdNode->sideId = equ->entry.sideId;

	cmdNode->gunId = equ->entry.gunId;

	cmdNode->msgCode = 0x06;
	cmdNode->dir =IND_DIR;
	cmdNode->msg = NULLP;
	cmdNode->stat = ROK;
	cmdNode->rqstParam = equ->entry.gunId;

	cmdNode->retry = 1;
	cmdNode->timer = 1;
	cmdNode->loadTimer = IND_TMR_EXPIRE;
	cmdNode->stat = RDY_SEND;

	RETVALUE(ROK);

}

S16 lbIndGetStationCodeMsg(EquCfgEntry_s * equ, TranCb_s * tran, U32 action)
{
	CmdMsg_s * cmdNode;

	if(ROK != lbCmGetCmdNode(tran, &cmdNode))
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}

	cmdNode->msgCode = 0x0c;
	cmdNode->dir =IND_DIR;
	cmdNode->msg = NULLP;
	cmdNode->stat = ROK;
	cmdNode->rqstParam = 0;

	cmdNode->retry = 1;
	cmdNode->timer = 1;
	cmdNode->loadTimer = IND_TMR_EXPIRE;
	cmdNode->stat = RDY_SEND;

	RETVALUE(ROK);
}

S16 lbIndCommonAckMsg(EquCfgEntry_s * equ, U8 cmdCode, U8 stat, U32 seq, TranCb_s * tran, U32 action)
{
	CmdMsg_s * cmdNode;

	if(ROK != lbCmGetCmdNode(tran, &cmdNode))
	{
		RXLOGERROR(0, 0, 0, "ERROR");
		RETVALUE(RFAILED);
	}


	if(equ != NULLP)
	{
		cmdNode->machId = equ->entry.machId;
		cmdNode->sideId = equ->entry.sideId;

		cmdNode->gunId = equ->entry.gunId;
	}

	cmdNode->msgCode = cmdCode;
	cmdNode->dir =IND_DIR;
	cmdNode->msg = NULLP;
	cmdNode->stat = stat;

	cmdNode->retry = 1;
	cmdNode->timer = 1;
	cmdNode->loadTimer = IND_TMR_EXPIRE;
	cmdNode->stat = RDY_SEND;

	RETVALUE(ROK);
}


/******************* modify histroy list *******************
001. create at: 2002-7-6 1:44:56 by Shangyaohui

****************** modify histroy list end ****************/
⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -