lb_ex_ms.c

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

/* header include files -- defines (.h) */
#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"

S16 LbActvTsk(Pst * pst, Buffer * mbuf)
{
	Data buf[256];
	if(pst == NULLP || mbuf == NULLP)
	{
		RXLOGERROR(ENTLB, 0, mbuf, "invalid param");
		RETVALUE(RFAILED);
	}
	sprintf(buf, "recv %d", pst->event);
	rxLog(buf);

	switch(pst->event)
	{
	case 0x01: /* gun up msg ind*/
		lbRecvGunUpIndAck(mbuf);
		break;

	case 0x02: /* gun down ind*/
		lbRecvGunDownIndAck(mbuf);
		break;

	case 0x03: /* work on ind*/
		lbRecvWorkOnIndAck(mbuf);
		break;

	case 0x04: /* card insert ind*/
		lbRecvCardInsertIndAck(mbuf);
		break;

	case 0x05: /* crrnt casr info ind*/
		lbRecvCardOutIndAck(mbuf);
		break;

	case 0x06:
		lbRecvCardInfoIndAck(mbuf);
		break;

	case 0x08: /* tran record ind */
		lbRecvTranInfoIndAck(mbuf);
		break;

	case 0x09: /* black list notify rqst*/
		lbRecvBlkLstInProvinceNtfy(mbuf);
		break;

	case 0x0a: /* fill volume ind*/
		lbRecvFillInfoIndAck(mbuf);
		
		break;
	case 0x0b: /* work down ind*/
		lbRecvWorkDownIndAck(mbuf);

		break;
	case 0x0c: /* get station code rqst*/
		lbRecvGetStaCodeIndAck(mbuf);

		break;
	case 0x0d: /* get equipment notify */
		lbRecvGetEquInfoNtfy(mbuf);

		break;
	case 0x0e: /* get special station code */
		lbRecvGetSpecStaCodeRqst(mbuf);

		break;
	case 0x0f: /* get histroy */
		lbRecvGetHistroyRqst(mbuf);

		break;
	case 0x10: /* set crrnt key version */
		
		lbRecvSetKeyVerRqst(mbuf);

		break;
	case 0x11: /* set key info */
		lbRecvSetKeyInfoRqst(mbuf);

		break;
	case 0x12: /* enable in bank app */
		lbRecvEnaIBankAppRqst(mbuf);
		break;
	case 0x14: /* card bank code */
		lbRecvCardBankCodeRqst(mbuf);
		break;
	case 0x15: /* set crrnt key index */
		lbRecvSetKeyIdxRqst(mbuf);

		break;
	case 0x16: /* enable second poney card */
		lbRecvEnaSecPoneyRqst(mbuf);

		break;
	case 0x17: /* get pump code */
		lbRecvGetPumpCodeRqst(mbuf);

		break;
	case 0x18: /* set crrnt price */
		lbRecvSetPriceRqst(mbuf);

		break;
	case 0x19: /* get crrnt price */
		lbRecvGetPriceRqst(mbuf);

		break;
	case 0x1a: /* dismention notify */
		lbRecvDisNtfy(mbuf);

		break;
	case 0x1c: /* stop fill */
		lbRecvStopFillRqst(mbuf);

		break;
	case 0x1d: /* resume fill */
		lbRecvResFillRqst(mbuf);

		break;
	case 0x1e: /* grey list update notify */
		lbRecvGreyListUpdateNtfy(mbuf);
		
		break;
	case 0x1f: /* black list update notify */
		lbRecvBlkLstInCountryNtfy(mbuf);
		break;
	}

	if(mbuf != NULLP)
	{
		SPutMsg(mbuf);
	}
	RETVALUE(ROK);
}