dsir.cpre

商业银行前置系统

/*
 * This is a part of the Application Preconsole
 * - Service Provide - DSI.
 * Copyright (C) 2000-2000 ABC.SDC.
 * All rights reserved.
 *
 * This source code is only intended as a supplement to the
 * Application Preconsole Reference and related
 * electronic documentation provided with the library.
 * See these sources for detailed information regarding the
 * Application Preconsole product. 
 *
 * Update record:
 * 2001-08-29 R.Cao         - create implementation file for
 *            Cheng Weihong   message receiving
 */

#include "ap.h"
#include "apsp.h"

EXEC SQL INCLUDE "dsi.h";

void main()
{
    void* pCommArea;
    unsigned long lRespCode;

    ISO8583STRU iso8583stru;

    UINT nSize;
    char szDelayId[8 + 1];
    char szTsqName[8 + 1];
    char szTraceNo[SIZE_TRACENO + 1];

    short sSize, sItem;

    EXEC CICS ADDRESS EIB(dfheiptr);
    EXEC CICS ADDRESS COMMAREA(pCommArea);
    
    if (!VERIFY_NULL(pCommArea))
        EXEC CICS RETURN;

    memset(&iso8583stru, 0, sizeof(ISO8583STRU));
    
    if (!VERIFY_NORMAL(CreateIso8583(&iso8583stru, ifistruDsi)) ||
        !VERIFY_NORMAL(ImportIso8583(&iso8583stru, pCommArea,
                                     dfheiptr->eibcalen)))
        EXEC CICS RETURN;

    bufclr(szDelayId);
    bufclr(szTsqName);
    bufclr(szTraceNo);
    
    nSize = SIZE_TRACENO;
    GetBitInIso8583(&iso8583stru, BIT_TRACENO, szTraceNo, &nSize);
    DeleteIso8583(&iso8583stru);
    
    strcpy(szDelayId, "DD");
    strncat(szDelayId, szTraceNo, SIZE_TRACENO);
    
    strcpy(szTsqName, "QD");
    strncat(szTsqName, szTraceNo, SIZE_TRACENO);

    sItem = 1;
    sSize = dfheiptr->eibcalen;
    EXEC CICS WRITEQ TS QUEUE(szTsqName) FROM(pCommArea) LENGTH(sSize)
              ITEM(sItem) REWRITE RESP(lRespCode);

    if (lRespCode != DFHRESP(NORMAL))
        EXEC CICS RETURN;

    EXEC CICS CANCEL REQID(szDelayId) RESP(lRespCode);

    if (lRespCode != DFHRESP(NORMAL))
        EXEC CICS RETURN;

    EXEC CICS RETURN;
}

/* End of this file */