#include "usecache.h"
#include "..\\CacheSource\\callin.h"
#include <io.h>
#include <windows.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <stdlib.h>

extern "C"{
        extern  char			shdir[256];
}

    int LastErrorNumber;
    CACHE_STR LastError;  
    CACHE_STR LastError2; 
    CACHE_STR LastErrorSrc;  
    int LastErrorOffset;


int	displayerr(
        int code, // код ошибки, возвращенный от Cache
        CACHE_STR *errmsg, 
        CACHE_STR *srcline,
        CACHE_STR *errmsg2,
        int &offset, 
        int &errornum 
        )
{
    int	rc;
    errornum=code;

    if (code==CACHE_SUCCESS) {
        errmsg->len=0;
        errmsg2->len=0;
        srcline->len=0;
        offset=0;
        errmsg->str[0]=0;
        errmsg2->str[0]=0;
        return code;
    }

    errmsg->len = CACHE_MAXSTRLEN;
    if ((rc=CacheErrxlate(code,errmsg)) == CACHE_ERUNKNOWN)
    {
        strcpy((char*)errmsg->str,"Unknown error!");
        errmsg->len=strlen((char*)errmsg->str);
    }

    errmsg2->len = srcline->len = CACHE_MAXSTRLEN;
    if ((rc=CacheError(errmsg2, srcline, &offset)) != CACHE_SUCCESS)
    {
        strcpy((char*)errmsg2->str,"Unknown error!");
        errmsg2->len=strlen((char*)errmsg2->str);
        srcline->len=0;
        offset=0;
    }
    errmsg->str[errmsg->len]=0;
    errmsg2->str[errmsg2->len]=0;

    return code;
}


// запуск терминальной команды CACHE
int	CacheExecuteCommand(const char * command)
{
    CACHE_STR  query;
    int rc=0;

    strcpy((char *)query.str, command);
    query.len = (unsigned short)strlen((char *)query.str);
    rc=CacheExecute(&query);
    if (rc > 0) return rc;

    return CACHE_SUCCESS;
}

int GetCacheDirectory(char *szCacheDir, unsigned long *dwStrLen)
{
    if (*dwStrLen>strlen(shdir))
    {
        strcpy( szCacheDir, shdir );
        return 1;
    }
    else
    {
        return 0;
    }

}

// для dll установить каталог их расположения
void SetCacheMgrDirectory(void)
{
    unsigned long CacheBinDirLen=512;
    char CacheBinDir[512]={0};
    CacheBinDirLen-=5;
    if ( GetCacheDirectory( ( char* ) CacheBinDir, &CacheBinDirLen ) > 0 )
    {
        strcat( ( char* ) CacheBinDir, "\\mgr" );
        CACHESETDIR( CacheBinDir );
    }
}

//---------------------------------------------------------------------------
// для dll установить каталог их расположения
void SetCacheBinDirectory(void)
{
    unsigned long CacheBinDirLen=512;
    char CacheBinDir[512]={0};
    CacheBinDirLen-=5;

    if ( GetCacheDirectory( ( char* ) CacheBinDir, &CacheBinDirLen ) > 0 )
    {
        strcat( ( char* ) CacheBinDir, "\\bin" );
        SetDllDirectoryA( CacheBinDir );
    }
}

extern "C" void __declspec(dllexport) cacheInit(char* CachePath=NULL)
{
    if (!CachePath)
    {
        strcpy(shdir,"c:\\intersystems\\cache");
        while (shdir[strlen(shdir)-1]=='\\')
            shdir[strlen(shdir)-1] = 0;
    }
    CoInitializeEx(0, COINIT_MULTITHREADED);

    SetCacheBinDirectory();

    SetCacheMgrDirectory();

}

extern "C" void __declspec(dllexport) cacheFinish(void)
{
    CoUninitialize();
}


extern "C" int __declspec(dllexport) cacheConnect(void)
{
    int	rc;
    LastErrorNumber=0;
    CACHE_STR pout,pin,pusername,ppassword,pexename;
    int termflag = CACHE_TTNEVER/*CACHE_TTCALLIN*//*CACHE_TTSTART*//*CACHE_TTALL*/;
    int timeout = 15;

    sprintf((char *) pexename.str,"%d", 123456);
    pexename.len = (unsigned short)strlen((char *) pexename.str);

    *(pin.str)	= '\0';
    pin.len		= 0;
    *(pout.str)	= '\0';
    pout.len	= 0;

    strcpy((char *) pusername.str,"_SYSTEM");
    strcpy((char *) ppassword.str,"SYS");
    pusername.len = (unsigned short)strlen((char *) pusername.str);
    ppassword.len = (unsigned short)strlen((char *)ppassword.str);

    rc=CACHESECURESTART(&pusername,&ppassword,&pexename,termflag, timeout, &pin, &pout);

    if (rc!=CACHE_SUCCESS)
    {
        displayerr(
                    rc,
                    LastError,
                    LastErrorSrc,
                    LastError2,
                    LastErrorOffset,
                    LastErrorNumber
                  );
    }
    else
    {
        rc=CacheExecuteCommand("zn \"Localbase\"");
        displayerr(
                    rc,
                    LastError,
                    LastErrorSrc,
                    LastError2,
                    LastErrorOffset,
                    LastErrorNumber
                  );
    }
    return(rc);
}

extern "C" int __declspec(dllexport) cacheDisconnect(void)
{
    CacheEnd();
}

extern "C" int __declspec(dllexport) cacheCall(
           char* DBName,           // имя локальной БД и области к ней
           int &counter  
        )
{
    CACHE_STR  query;
    sprintf((char*)query.str,"zn \"%s\"",DBName);
    int rc=CacheExecuteCommand((char*)query.str);
    // Вот тут имеем в rc CACHE_SUCCESS, все нормально выполнилось.
    if (rc!=CACHE_SUCCESS)
    {
        return(rc);
    }
    strcpy((char *)query.str, "##class(Data.Table).Process()");
    query.len = (unsigned short)strlen((char *)query.str);
    rc=CacheEval(&query);
    // Вот тут имеем в rc CACHE_CONBROKEN
    if (rc != CACHE_SUCCESS)
    {
        displayerr(
                    rc,
                    LastError,
                    LastErrorSrc,
                    LastError2,
                    LastErrorOffset,
                    LastErrorNumber
                  );
        return rc;
    }
    rc=CACHECONVERT(CACHE_INT,&counter);
    if (rc != CACHE_SUCCESS)
    {
        displayerr(
                    rc,
                    LastError,
                    LastErrorSrc,
                    LastError2,
                    LastErrorOffset,
                    LastErrorNumber
                  );
        return rc;
    }
    displayerr(
                CACHE_SUCCESS,
                LastError,
                LastErrorSrc,
                LastError2,
                LastErrorOffset,
                LastErrorNumber
              );
    return CACHE_SUCCESS;
}