📄 kaitai.cpp
字号:
// Kaitai.cpp : implementation file
//
#include "stdafx.h"
#include "resource.h"
#include "Kaitai.h"
#include "chyuDlg.h"
#include "database.h"
#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif
/////////////////////////////////////////////////////////////////////////////
// CKaitai dialog
CKaitai::CKaitai(CWnd* pParent /*=NULL*/)
: CDialog(CKaitai::IDD, pParent)
{
//{{AFX_DATA_INIT(CKaitai)
m_bianhao = _T("");
m_louceng = _T("");
m_renshu = _T("");
m_taiming = _T("");
//}}AFX_DATA_INIT
}
void CKaitai::DoDataExchange(CDataExchange* pDX)
{
CDialog::DoDataExchange(pDX);
//{{AFX_DATA_MAP(CKaitai)
DDX_Text(pDX, IDC_EDIT_BIANHAO, m_bianhao);
DDV_MaxChars(pDX, m_bianhao, 20);
DDX_Text(pDX, IDC_EDIT_LOUCENG, m_louceng);
DDV_MaxChars(pDX, m_louceng, 10);
DDX_Text(pDX, IDC_EDIT_RENSHU, m_renshu);
DDV_MaxChars(pDX, m_renshu, 10);
DDX_Text(pDX, IDC_EDIT_TAIMING, m_taiming);
DDV_MaxChars(pDX, m_taiming, 30);
//}}AFX_DATA_MAP
}
BEGIN_MESSAGE_MAP(CKaitai, CDialog)
//{{AFX_MSG_MAP(CKaitai)
//}}AFX_MSG_MAP
END_MESSAGE_MAP()
/////////////////////////////////////////////////////////////////////////////
// CKaitai message handlers
void CKaitai::OnOK()
{
SOCKET s_sock;
struct sockaddr_in addrClient;
int nCnt,i,j,sendlen;
char sendbuf[257],recbuf[257];
char bianhao[21],renshu[11],LiuShuiHao[11],ShiJian[21],louceng[51],taiming[51];
unsigned short crc;
u_short portid;
u_long SAddr;
char oprid[21];
//CCeDBDatabase m_db;
//CCeDBRecord rs;
//CCeDBProp props[7];
//int num;
CString strCode1;
WCHAR wcCode[257];
int taiweilen,caipulen;
HANDLE hFile;
unsigned long len;
UpdateData(TRUE);
WideCharToMultiByte(CP_ACP,0,m_bianhao,-1,bianhao,255,NULL,NULL);
WideCharToMultiByte(CP_ACP,0,m_renshu,-1,renshu,255,NULL,NULL);
WideCharToMultiByte(CP_ACP,0,m_louceng,-1,louceng,255,NULL,NULL);
WideCharToMultiByte(CP_ACP,0,m_taiming,-1,taiming,255,NULL,NULL);
hFile = CreateFile(CONFIGFILE, GENERIC_READ, FILE_SHARE_READ,
NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);
if (hFile==INVALID_HANDLE_VALUE)
{
MessageBox(TEXT("打开配置文件失败,请点“配置”按钮重新配置"));
return ;
}
ReadFile(hFile,&SAddr,4,&len,NULL);
ReadFile(hFile,&portid,2,&len,NULL);
ReadFile(hFile,&taiweilen,4,&len,NULL);
ReadFile(hFile,&caipulen,4,&len,NULL);
ReadFile(hFile,oprid,20,&len,NULL);
CloseHandle(hFile);
sprintf(sendbuf,"%c%s%c%s%c%s%c",0x01,bianhao,0x1b,renshu,0x1b,oprid,0x1b);
crc=0;
sendlen=strlen(sendbuf);
i=0;
while (i<sendlen)
{
crc+=(unsigned char)sendbuf[i];
i++;
}
sendbuf[i]=crc/256;
sendbuf[i+1]=crc%256;
sendbuf[i+2]=0;
sendlen+=3;
s_sock = socket (AF_INET, SOCK_STREAM, 0);
if (s_sock == INVALID_SOCKET)
{
MessageBox(TEXT("通讯失败,请检查设备"));
//CDialog::OnCancel();
return;
}
addrClient.sin_family=AF_INET;
addrClient.sin_addr.s_addr=SAddr;
addrClient.sin_port=portid;
if (connect(s_sock, (struct sockaddr *)&addrClient, sizeof (addrClient))==SOCKET_ERROR )
{
closesocket(s_sock);
MessageBox(TEXT("通讯失败,请检查设备"));
//CDialog::OnCancel();
return;
}
i=0;
while (i<5)
{
i++;
if (send (s_sock, sendbuf, sendlen, 0) == SOCKET_ERROR)
{
continue;
}
if ((nCnt=recv (s_sock, recbuf, 256, 0)) == SOCKET_ERROR)
{
continue;
}
crc=0;
j=0;
while (j<nCnt-3)
{
crc+=(unsigned char)recbuf[j];
j++;
}
if (crc!=(unsigned char)recbuf[j]*256+(unsigned char)recbuf[j+1]) continue;
if (recbuf[1]==0x01) continue;
if (recbuf[1]==0x03)
{
closesocket(s_sock);
MessageBox(TEXT("开台失败"));
return;
}
closesocket(s_sock);
i=0;
j=3;
while (recbuf[j]!=0x1b)
{
LiuShuiHao[i]=recbuf[j];
i++;
j++;
}
while(i<10)
{
LiuShuiHao[i]=(char)0xff;
i++;
}
LiuShuiHao[i]=0;
i=0;
j++;
while (recbuf[j]!=0x1b)
{
ShiJian[i]=recbuf[j];
i++;
j++;
}
while(i<20)
{
ShiJian[i]=(char)0xff;
i++;
}
ShiJian[i]=0;
/*strcpy(LiuShuiHao,"1111");
strcpy(ShiJian,"1234");
if(!m_db.Open (DB_TAIWEI))
{
MessageBox(TEXT("打开数据库失败"));
return ;
}
num=(int)m_db.GetNumRecords ();
m_db.SeekFirst();
for(i=0;i<num;i++)
{
m_db.ReadCurrRecord (&rs);
strCode1=rs.GetPropFromIdent(PROP_CODE(1))->GetString ();
if (!strCode1.Compare(m_bianhao))
{
strCode1=rs.GetPropFromIdent(PROP_CODE(3))->GetString ();
swprintf(wcCode,L"%s",m_bianhao);
props[0]=CCeDBProp(wcCode,PROP_CODE(1));
swprintf(wcCode,L"%s",m_taiming);
props[1]=CCeDBProp(wcCode,PROP_CODE(2));
swprintf(wcCode,L"%s",strCode1);
props[2]=CCeDBProp(wcCode,PROP_CODE(3));
swprintf(wcCode,L"%s",m_louceng);
props[3]=CCeDBProp(wcCode,PROP_CODE(4));
MultiByteToWideChar(CP_ACP,0,LiuShuiHao,-1,wcCode,255);
props[4]=CCeDBProp(wcCode,PROP_CODE(5));
swprintf(wcCode,L"%s",m_renshu);
props[5]=CCeDBProp(wcCode,PROP_CODE(6));
MultiByteToWideChar(CP_ACP,0,ShiJian,-1,wcCode,255);
props[6]=CCeDBProp(wcCode,PROP_CODE(7));
if (!rs.AddProps (props,7));
if (!m_db.WriteCurrRecord(&rs));
MessageBox(L"1");
break;
}
m_db.SeekNext();
}*/
////
char RecordBuf[257],*ptchar,field[257];
HANDLE hFile;
unsigned long len;
hFile = CreateFile(DB_TAIWEI, GENERIC_READ|GENERIC_WRITE, FILE_SHARE_READ|FILE_SHARE_WRITE,
NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
if (hFile==INVALID_HANDLE_VALUE)
{
closesocket(s_sock);
return;
}
while(fGetRecord(hFile,RecordBuf))
{
ptchar=RecordBuf;
ptchar=fGetaField(ptchar,field);
MultiByteToWideChar(CP_ACP,0,field,-1,wcCode,255);
if (!m_bianhao.Compare(wcCode))
{
sprintf(recbuf,"%s%c%s%c%s%c%s%c%s%c%s%c%c%c",bianhao,0x1b,taiming,0x1b,"开台",0x1b,louceng,0x1b,LiuShuiHao,0x1b,ShiJian,0x1b,0x0d,0x0a);
// sprintf(recbuf,"%s%c%s",LiuShuiHao,0x1b,ShiJian);
SetFilePointer(hFile,-2-strlen(RecordBuf),0,FILE_CURRENT);
WriteFile(hFile,recbuf,strlen(recbuf),&len,NULL);
}
}
CloseHandle(hFile);
hFile = CreateFile(m_bianhao, GENERIC_WRITE, FILE_SHARE_WRITE,
NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);
if (hFile==INVALID_HANDLE_VALUE) return;
CloseHandle(hFile);
////
CDialog::OnOK();
return;
}
closesocket(s_sock);
MessageBox(TEXT("通讯失败,请检查设备"));
//CDialog::OnCancel();
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -