/******************************************
   qtsylib.c
   前臺(tái)收銀程序的 DB-Library 函數(shù)庫(kù)
 ****************************************** */
#define DBMSDOS
#include <sqlfront.h>
#include <sqldb.h>
#include <dos.h>
#include <errno.h>
#include <bios.h>
#include <io.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <conio.h>
#include <math.h>
#include <time.h>
#include <fcntl.h>
#include <stdarg.h>
#include <user.h>
#include <publ.h>
#include "direct.h"
//
/*全局變量定義*/
char Syy_No[5];                 //收銀員代碼
char Syy_mm[7];                 //收銀員密碼
char Syy_Name[9]="于小蓉";      //收銀員名稱(chēng)
char Bc_Name[11]="01";          //班次

int  g_lsh=1;            //流水號(hào)
int  g_jycs=0;           //交易次數(shù)
int  g_xsbs=0;           //銷(xiāo)售筆數(shù)
int  g_dyys=1000;        //打印延時(shí)
char g_lsdh[5];          //連鎖店號(hào)
char g_lsdhex[5];

char g_qt_lsdh[3];       //缺省連鎖店號(hào)前兩位
char g_gzrq[6]="00";     //工作日期
char g_scjbsj[30];       //上次交班時(shí)間
char g_fkfs[2],g_bc[7],g_now[30],g_tm[2];    // 付款方式,班次,時(shí)間變量
char g_pos[2]="1";       //收銀機(jī)類(lèi)型
			 //1-普通 (兼容機(jī),串口打印機(jī))
			 //2-普通 (兼容機(jī),并口打印機(jī))
			 //3-IBM收銀機(jī)
			 //4-富士通收銀機(jī)
double g_bx;             //補(bǔ)現(xiàn)
double g_flhj[5];        //分類(lèi)合計(jì)
char g_xyksy[2];
XYKLB _XykLb[20];

char *g_sjwj="s";
char g_gz_mode[2]="0";            //工作方式
char g_gz_modeex[5];

char g_cashcode[11]="ytpos";      //管理員密碼
char g_scmc[81]="";       //用戶(hù)簡(jiǎn)稱(chēng)

char g_server_thk[21];            //遠(yuǎn)程提貨卡
char g_customer[2];	          //商場(chǎng)類(lèi)型
char g_VIPsw[2];	          //VIP卡首位
char g_VIPyhl[5];	          //VIP卡優(yōu)惠率

char __LoginUser[11];             //登錄數(shù)據(jù)庫(kù)的用戶(hù)
char __bvalue[300];
				  //本地銷(xiāo)售單記錄格式化字符串
char __pxsd[120]="%7d.00%8s%-20s%14.3f%19.4f%19.4f%19.4f%19.4f%1s%19.4f%6s"
		 "%3s%6s%4s%4s%2s%1s%2s%5s%3s%1s%1s%4s%8s%8.2f%4s ";

char __xsdbuf[300];               //本地銷(xiāo)售單記錄緩沖區(qū)
int _hour,_minute,_second;        //當(dāng)前時(shí)，小時(shí)、分、秒
long __prostart,__pronow;
short __sqlerrormark=0;           // sql錯(cuò)誤標(biāo)記,當(dāng)出現(xiàn)網(wǎng)絡(luò)錯(cuò)誤是置為1
short __sqlok=0;                  // 0-不連SQL,1-已連SQL,3-并且已連遠(yuǎn)程提貨卡
short __syfs=2;                   // 收銀方式,0-單機(jī)，1-半單機(jī)，2-聯(lián)機(jī)
char  _jxc_xsdb[10]="jxc_xsdb";   // 提交表
char  _OrigXsd[80];               // 當(dāng)前數(shù)據(jù)存儲(chǔ)路徑
				  // 等于Data\\班次前4位\\x班次.dbf
char  _OrigWqb[80];               //                 ...\\w班次.dbf
char  Yyy_No[5];                  // 當(dāng)前營(yíng)業(yè)員編碼
extern char p_Formats[31][61];
extern char _pFeedLine;
//bank
long    recno = 0;
//字段結(jié)構(gòu)
typedef struct
{
  char FieldName[11]; //字段名稱(chēng)
  char DataType[2];   //字段類(lèi)型
  int  Size;          //字段寬度
  int  Dec;           //小數(shù)位數(shù)
  int  xOff;          //在記錄緩沖中的偏余量
} TField;
//數(shù)據(jù)集結(jié)構(gòu)
typedef struct
{
  char TableName[40]; //表名稱(chēng)
  int  hLen;          //文件頭長(zhǎng)度
  int  rLen;          //記錄長(zhǎng)度
  int  FieldCount;    //字段數(shù)
  long int RCount;    //記錄數(shù)
  int xOff;           //關(guān)鍵字段在記錄緩沖中的偏余量
  int fLen;           //關(guān)鍵字段長(zhǎng)度
  char *buffer;       //記錄緩沖指針
} TDataSet;

char _tbuffer[220];   //公共記錄緩沖

PTOH    ptoh;
HTOP    htop;

extern int  _spmcws;
extern int  _nFormat;
extern int  _nFormatx;
//
extern TOption Param;
/*商品數(shù)據(jù)結(jié)構(gòu)*/
extern _SPLists *SPLists;
extern _SPLists __SPLists[];
//
extern int MsgBoxEx(char *,int);
extern void ResetAll(void);
extern void Reset(_SPLists *lp);
extern void SleepEx(clock_t nDelay);
extern void Printf(char *String,unsigned char Co);
extern void dbf_TranToServer(char *File1,char *File2,
			     int hLen1,int rLen1,int hLen2,int rLen2);
extern int CreateXspz(_SPLists *_SPList,int Att,char *_Time,int Fixed);

extern void ShowBc_Name(void);
extern int ValidCheck(char *s);
//
DBPROCESS  *dbproc,*dbproc_thk; // 與SQL Server的聯(lián)結(jié)
RETCODE    result_code;         // SQL命令執(zhí)行的結(jié)果代碼
int sql_connectdb(char *user,char *pass,char *server,int flag);
//單機(jī)收銀系列函數(shù)
TField _SPBFields[12];
TDataSet _SPBDataSet;
TField _SYSFields[2];
TDataSet _SYSDataSet;
TField _SDBFields[10];
TDataSet _SDBDataSet;
TField _SYJFields[16];
TDataSet _SYJDataSet;
TField _SYYFields[12];
TDataSet _SYYDataSet;
TField _DTMFields[7];
TDataSet _DTMDataSet;
TField _LBBFields[3];
TDataSet _LBBDataSet;
TField _TMCFields[9];
TDataSet _TMCDataSet;
TField _WQBFields[26];
TDataSet _WQBDataSet;
TField _XSDFields[26];  //銷(xiāo)售單表
TDataSet _XSDDataSet;
TField _XSBFields[10];   //銷(xiāo)售單簡(jiǎn)表,
TDataSet _XSBDataSet;   //用來(lái)存儲(chǔ)從服務(wù)器下載的銷(xiāo)售單關(guān)鍵詞,
			//以決定需要上傳的本地?cái)?shù)據(jù)

double  uf_round(double num,double dig)   // 四舍五入(數(shù),位數(shù)),返回舍入后的數(shù)
{
  char buf[30];
  sprintf(buf,"%.2f",num);
  return atof(buf);
}
void __process(char *sour)
{
  int i,j=0;
  char value[81];
  unsigned char c;
  strcpy(value,sour);
  for(i=0;i<=(int)strlen(value);i++)
  {
   if(value[i]=='%')
   {
    sour[j++]=0xa3;
    sour[j++]=0xa5;
   }
   else
    sour[j++]=value[i];
  }
  j=0;
  for(i=0;i<=(int)strlen(sour);i++)
  {
   c = (unsigned char)sour[i];
   if(c>=0xa0)  // 是漢字
    if(!j)      // 高8位
     j++;
    else        // 低8位
     j=0;
   if(i>=_spmcws)
    {
     if(j) sour[i]=' ';
     sour[i+1]='\0';
     break;
    }
  }
  for(i=(int)strlen(sour);i<=_spmcws;i++)
  {
   sour[i]=' ';
   sour[i+1]='\0';
  }
}

int uf_strmidEx(char *dest,char *sour)
{
  int i,l,j=0;
  l = strlen(sour);
  for(i=0;i<l;i++)
   if((sour[i]>='0'&&sour[i]<='9')||
      (sour[i]>='A'&&sour[i]<='Z')||
      (sour[i]>='a'&&sour[i]<='z'))
    break;
  if(i>=l) return 0;
  for(j=i;j<l;j++)
   dest[j-i]=sour[j];
  dest[j-i]='\0';
  return 1;
}

int uf_strmid(char *dest,char *sour,int from,int count)
// 截取字符串(返回串,原串,起始位,截取位數(shù))
{
  int i,l,j=0;
  dest[0]='\0';
  l=strlen(sour);
  if(from<0||from>=l) return 0;
  for(i=from;i<l&&j<count;i++)
   dest[j++]=sour[i];
  dest[j]='\0';
  return 1;
}

int uf_strmidex(char *dest,char *sour,char c)
// 截取字符串(返回串,原串,起始位,截取位數(shù))
{
  int i,l,j=0;
  l=strlen(sour);
  for(i=0;i<l;i++)
   if(sour[i]==c)
   {
    i++;
    break;
   }
  if(i>=l) return 0;
  for(j=i;j<=l;j++)
   dest[j-i]=sour[j];
  return 1;
}

int  uf_strfcat(char *dest,char *sour)
// 在字符串前加入串(返回串,要加上的串)
{
  char tmpstr[81];
  strcpy(tmpstr,sour);
  strcat(tmpstr,dest);
  strcpy(dest,tmpstr);
  return 1;
}

void CopyStr(char *d,char *s,int nfrom,int nlen,int Blank)
{
 int i,j;
 j = nfrom;
 for(i=0;i<nlen;i++)
  d[i]=s[j++];
 d[i]='\0';
 for(i=nlen;i>=0&&Blank&&(d[i]=='\0'||d[i]==' ');i--)
  d[i]='\0';
}
void StrToLower(char *s)
{
  int i;
  for(i=0;i<(int)strlen(s);i++)
   s[i] = (char)tolower(s[i]);
}
void ClearBuffer(char *s,int rLen)
{
  int i;
  for(i=0;i<rLen;i++)
   s[i]='\0';
}
//檢查某個(gè)文件是否存在
//存在時(shí)返回非0
int FileExists(const char *FileName)
{
  int Han;
  unsigned _nError;
  _nError = _dos_open(FileName,O_RDONLY|O_BINARY,&Han);

/*printf("_nError:%d ENOENT:%d EMFILE:%d EACCES:%d\n",
	  _nError,ENOENT,EMFILE,EACCES);
  getchar(); */

  if(_nError==0)
  {
   _dos_close(Han);
   return 1;
  }
  else return 0;
}
//初始化某個(gè)表
int OpenTable(const char *TableName,TDataSet *DataSet,TField TStr[],
	      const char *KeyField)
{
  FILE *fp;
  int i;
  char buffer[33],_Size[2],_Dec[2];
  unsigned char a[4];

  strcpy(DataSet->TableName,TableName);
  DataSet->buffer = _tbuffer;
  //讀取表的結(jié)構(gòu)
  fp = fopen(TableName,"rb");
  if(fp)
  {
    fseek(fp,4,0);             //記錄數(shù)
    fread(&a,4,1,fp);
    DataSet->RCount = a[0]+(long int)a[1]*0x100+(long int)a[2]*0x100*0x100;
    fseek(fp,8,0);             //庫(kù)結(jié)構(gòu)說(shuō)明長(zhǎng)度
    fread(&a,2,1,fp);
    DataSet->hLen = a[0]+a[1]*0x100+1;
    fseek(fp,10,0);             //記錄長(zhǎng)度
    fread(&a,2,1,fp);
    DataSet->rLen = a[0]+a[1]*0x100;
    DataSet->FieldCount = DataSet->hLen/32-1; //字段數(shù)
    //讀取庫(kù)結(jié)構(gòu)
    for(i=0;i<DataSet->FieldCount;i++)
    {
     fseek(fp,32+i*32,0);      //讀取記錄描述
     fread(&buffer,32,1,fp);
     CopyStr(TStr[i].FieldName,buffer,0,10,1);

     StrToLower(TStr[i].FieldName);

     CopyStr(TStr[i].DataType, buffer,11,1,1);
     CopyStr(_Size,buffer,16,1,0);
     CopyStr(_Dec,buffer,17,1,0);
     TStr[i].Size=(int)_Size[0];
     TStr[i].Dec=(int)_Dec[0];
     if(i)
      TStr[i].xOff=TStr[i-1].xOff+TStr[i-1].Size;
     else
      TStr[i].xOff=0;
     if(!strcmp(TStr[i].FieldName,KeyField))
     {
      DataSet->xOff = TStr[i].xOff;
      DataSet->fLen = TStr[i].Size;
     }
    }
   fclose(fp);
   return 1;
  }
  return 0;
}
//
void OpenAllDataSet(void)
{
  OpenTable("DATA\\JXC_SPB.DBF", &_SPBDataSet,_SPBFields,"spbm");
  OpenTable("DATA\\JXC_SYS.DBF", &_SYSDataSet,_SYSFields,"var_name");
  OpenTable("DATA\\JXC_SDDZ.DBF",&_SDBDataSet,_SDBFields,"bm");
  OpenTable("DATA\\JXC_SYJB.DBF",&_SYJDataSet,_SYJFields,"syjh");
  OpenTable("DATA\\JXC_SYYB.DBF",&_SYYDataSet,_SYYFields,"syybm");
  OpenTable("DATA\\JXC_DTMB.DBF",&_DTMDataSet,_DTMFields,"tm");
  OpenTable("DATA\\JXC_LBB.DBF", &_LBBDataSet,_LBBFields,"lbbm");
  OpenTable("DATA\\JXC_TMCB.DBF",&_TMCDataSet,_TMCFields,"tplu");
  OpenTable("DATA\\JXC_XSDB.DBF",&_XSDDataSet,_XSDFields,"spbm");
  OpenTable("DATA\\SER_XSJB.DBF",&_XSBDataSet,_XSBFields,"syjh");
}
//分表從服務(wù)器下載數(shù)據(jù)到本地表中JXC_SPB
long int GetSPBFromServer(char *pWhere,int rLen)
{
  FILE *fpt;
  long int RecordCount=0;
  char tmpbuf[500];
  DBCHAR spbm[9],spmc[33],ggxh[11],jldw[5],jyfs[3],csbm[7],splb[7],gzbm[5];
  DBFLT8 jj,sj,yhj,spsl;
  char *pFor="%-8s%-32s%-10s%-4s%-2s%-6s%10.2f%10.2f%10.2f%-6s%-4s%6.2f";

  dbfreebuf(dbproc);
  dbcmd(dbproc,"select spbm,spmc,ggxh,jldw,jyfs,csbm,jj,sj,yhj,splb,gzbm,spsl\n");
  dbcmd(dbproc,"from jxc_spb\n");
  if(pWhere[0]!='\0')
   dbfcmd(dbproc,"where %s\n",pWhere);
  dbcmd(dbproc,"order by spbm");
  dbsqlexec(dbproc);
  while((result_code=dbresults(dbproc))!= NO_MORE_RESULTS)
   if (result_code == SUCCEED)
    {
     fpt = fopen("temp.dat","wb+");
     dbbind(dbproc, 1, NTBSTRINGBIND, (DBINT)0,spbm);
     dbbind(dbproc, 2, NTBSTRINGBIND, (DBINT)0,spmc);
     dbbind(dbproc, 3, NTBSTRINGBIND, (DBINT)0,ggxh);
     dbbind(dbproc, 4, NTBSTRINGBIND, (DBINT)0,jldw);
     dbbind(dbproc, 5, NTBSTRINGBIND, (DBINT)0,jyfs);
     dbbind(dbproc, 6, NTBSTRINGBIND, (DBINT)0,csbm);
     dbbind(dbproc, 7, FLT8BIND, (DBINT) 0,(BYTE *) &jj);
     dbbind(dbproc, 8, FLT8BIND, (DBINT) 0,(BYTE *) &sj);
     dbbind(dbproc, 9, FLT8BIND, (DBINT) 0,(BYTE *) &yhj);
     dbbind(dbproc,10, NTBSTRINGBIND, (DBINT)0,splb);
     dbbind(dbproc,11, NTBSTRINGBIND, (DBINT)0,gzbm);
     dbbind(dbproc,12, FLT8BIND, (DBINT) 0,(BYTE *) &spsl);
     while(dbnextrow(dbproc)!=NO_MORE_ROWS)
     {
      sprintf(tmpbuf,pFor,spbm,spmc,ggxh,jldw,jyfs,csbm,jj,sj,yhj,splb,gzbm,spsl);
      fwrite(&tmpbuf,rLen,1,fpt);
      RecordCount++;
     }
     fclose(fpt);
    }
  return RecordCount;
}
//系統(tǒng)表JXC_SYS
long int GetSYSFromServer(int rLen)
{
  FILE *fpt;
  long int RecordCount=0;
  char tmpbuf[100];
  DBCHAR varname[11],varsave[81];
  char *pFor="%-10s%-80s";

  dbfreebuf(dbproc);
  dbcmd(dbproc,"select var_name,var_save\n");
  dbcmd(dbproc,"from ytsys_globle\n");
  dbcmd(dbproc,"order by var_name");
  dbsqlexec(dbproc);
  while((result_code=dbresults(dbproc))!= NO_MORE_RESULTS)
   if (result_code == SUCCEED)
    {
     fpt = fopen("temp.dat","wb+");
     dbbind(dbproc, 1, NTBSTRINGBIND, (DBINT)0,varname);
     dbbind(dbproc, 2, NTBSTRINGBIND, (DBINT)0,varsave);
     while(dbnextrow(dbproc)!=NO_MORE_ROWS)
     {
      sprintf(tmpbuf,pFor,varname,varsave);
      fwrite(&tmpbuf,rLen,1,fpt);
      RecordCount++;
     }
     fclose(fpt);
    }
  return RecordCount;
}
//時(shí)點(diǎn)打折表JXC_SDDZ
long int GetSDDZFromServer(char *pWhere,int rLen)
{
  FILE *fpt;
  long int RecordCount=0;
  char tmpbuf[200];
  DBCHAR bm[9],stime[21],etime[21],srr[9],srtime[21],qfr[9],qftime[21],qfbz[2],dzlx[2];
  DBFLT8 yhl;
  char *pFor="%-8s%-20s%-20s%12.4f%-8s%-20s%-8s%-20s%-1s%-1s";
  dbfreebuf(dbproc);
  dbcmd(dbproc,"select bm,stime=convert(char(11),stime,102)+convert(char(9),stime,8),\n");
  dbcmd(dbproc,"       etime=convert(char(11),etime,102)+convert(char(9),etime,8),yhl,\n");