mes-client/UAS_CheckWork/Form1.cs

using Check.DataOperate;
using System;
using System.Collections.Generic;
using System.Data;
using System.Text;
using System.Threading;
using System.Windows.Forms;
using UAS_MES.PublicForm;

namespace UAS_CheckWork
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
        DataHelper dh;
        //Create Standalone SDK class dynamicly.
        public zkemkeeper.CZKEMClass axCZKEM1 = new zkemkeeper.CZKEMClass();
        private bool bIsConnected = false;//the boolean value identifies whether the device is connected
        private int iMachineNumber = 1;//the serial number of the device.After connecting the device ,this value will be changed.
        //开启线程
        Thread InitGetInfo;
        private void btnConnect_Click(object sender, EventArgs e)
        {
            if (txtIP.Text.Trim() == "" || txtPort.Text.Trim() == "")
            {
                MessageBox.Show("请先输入IP和端口", "Error");
                return;
            }
            int idwErrorCode = 0;

            Cursor = Cursors.WaitCursor;
            if (btnConnect.Text == "断开连接")
            {
                axCZKEM1.Disconnect();
                bIsConnected = false;
                btnConnect.Text = "连接";
                lblState.Text = "状态:未连接";
                Cursor = Cursors.Default;
                return;
            }
            bIsConnected = axCZKEM1.Connect_Net(txtIP.Text, Convert.ToInt32(txtPort.Text));
            if (bIsConnected)
            {
                btnConnect.Text = "断开连接";
                btnConnect.Refresh();
                lblState.Text = "状态:已连接";
                iMachineNumber = 1;//In fact,when you are using the tcp/ip communication,this parameter will be ignored,that is any integer will all right.Here we use 1.
                axCZKEM1.RegEvent(iMachineNumber, 65535);//Here you can register the realtime events that you want to be triggered(the parameters 65535 means registering all)
            }
            else
            {
                axCZKEM1.GetLastError(ref idwErrorCode);
                MessageBox.Show("无法连接设备,ErrorCode=" + idwErrorCode.ToString(), "Error");
            }
            Cursor = Cursors.Default;
        }

        private void getAllData_Click(object sender, EventArgs e)
        {
            if (!bIsConnected)
            {
                MessageBox.Show("请先连接设备", "Error");
                return;
            }
            InitGetInfo = new Thread(InPrint);
            SetLoadingWindow stw = new SetLoadingWindow(InitGetInfo, "正在同步数据...");
            stw.StartPosition = FormStartPosition.CenterParent;
            stw.ShowDialog();
        }

        private void InPrint()
        {
            int idwErrorCode = 0;
            //获取所有的考勤记录
            if (axCZKEM1.ReadGeneralLogData(iMachineNumber))
            {
                //循环获取
                DataTable dt = new DataTable();
                dt.Columns.Add("cl_emcode");
                dt.Columns.Add("cl_time");
                string enrollNumber = "";//记录用户ID
                int verifyCode = 0;//记录用户验证方式  0 为密码验证，1 为指纹验证，2 为卡验证 
                int inoutMode = 0;//考勤状态，具体含义如下： 默认 0—Check-In 1—Check-Out 2—Break-Out 3—Break-In 4—OT-In 5—OT-Out 
                int year = 0;//记录考勤年份
                int month = 0;//记录考勤月份
                int day = 0;//记录考勤日期
                int hour = 0;//记录考勤小时
                int minute = 0;//记录考勤分钟
                int second = 0;//记录考勤秒
                int workCode = 0; //记录workCode
                List<string> cl_emcode = new List<string>();
                List<string> cl_time = new List<string>();
                StringBuilder sql = new StringBuilder();
                sql.Append("insert into cardlog (cl_id,cl_emcode,cl_time) values (cardlog_seq.nextval,:cl_emcode,TO_DATE(:cl_time,'yyyy-MM-dd hh24:mi:ss'))");
                int count = 0;
                while (axCZKEM1.SSR_GetGeneralLogData(iMachineNumber, out enrollNumber, out verifyCode, out inoutMode, out year, out month, out day, out hour, out minute, out second, ref workCode))
                {
                    cl_emcode.Add(enrollNumber);
                    cl_time.Add(year + "-" + month + "-" + day + " " + hour + ":" + minute + ":" + second);
                    if (count % 1000 == 0)
                    {
                        dh.BatchInsert(sql.ToString(), new string[] { "cl_emcode", "cl_time" }, cl_emcode.ToArray(), cl_time.ToArray());
                        cl_emcode.Clear();
                        cl_time.Clear();
                    }
                    count = count + 1;
                    //将数据加入DataTable中
                    DataRow dr = dt.NewRow();
                    dr["cl_emcode"] = enrollNumber;
                    dr["cl_time"] = year + "-" + month + "-" + day + " " + hour + ":" + minute + ":" + second;
                    dt.Rows.Add(dr);
                }
                dh.BatchInsert(sql.ToString(), new string[] { "cl_emcode", "cl_time" }, cl_emcode.ToArray(), cl_time.ToArray());
                allData.DataSource = dt;
                //显示
                showDataGrid.DataSource = (DataTable)allData.DataSource;
            }
            else
            {
                axCZKEM1.GetLastError(ref idwErrorCode);
                MessageBox.Show("Unable to get data,ErrorCode=" + idwErrorCode.ToString(), "Error");
            }
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            CheckForIllegalCrossThreadCalls = false;//可跨线程
            StartPosition = FormStartPosition.CenterScreen;
            dh = new DataHelper();
        }

        private void saveData_Click(object sender, EventArgs e)
        {
            //点击保存数据
            string lastTime = dh.getFieldDataByCondition("cardlog", "TO_CHAR(max(wl_indate),'yyyy-MM-dd hh24:mi:ss')", "1=1").ToString();
            //筛选数据
            DataTable fd = dh.filterDataTable((DataTable)allData.DataSource, "cl_time > '" + lastTime + "'");
            //插入数据库
            //新增的数据
            List<string> cl_emcode = new List<string>();
            List<string> cl_time = new List<string>();
            for (int i = 0; i < fd.Rows.Count; i++)
            {
                cl_emcode.Add(fd.Rows[i]["cl_emcode"].ToString());
                cl_time.Add(fd.Rows[i]["cl_time"].ToString());
            }
            //批量插入
            StringBuilder sql = new StringBuilder();
            sql.Append("insert into cardlog (cl_id,cl_emcode,cl_time) values (cardlog_seq.nextval,:cl_emcode,TO_DATE(:cl_time,'yyyy-MM-dd hh24:mi:ss'))");
            dh.BatchInsert(sql.ToString(), new string[] { "cl_emcode", "cl_time" }, cl_emcode.ToArray(), cl_time.ToArray());
        }
    }
}