大侠帮看看，实在看不出哪有问题！！！！！！！！
private void button1_Click_1(object sender, EventArgs e)
{
string connections = "Server=localhost;User ID=root;Password=wencui2006;Persist Security Info=True;DataBase=ken;charset=utf8";
MySqlConnection conn = new MySqlConnection(connections);
if (conn.State == ConnectionState.Closed)
{
conn.Open();
}
int machineID;
string IP = Dns.GetHostEntry(Dns.GetHostName()).AddressList[0].ToString();
string[] array = IP.Split('.');
machineID = Convert.ToInt32(array[3].ToString());//获取IP最后一位作为机器号
//string FileName = Application.StartupPath + "\\Data\\" + "H" + DateTime.Now.ToString("yyyyMMdd") + "S." + machineID;
string FileName = Application.StartupPath + "\\456.123";
if (!File.Exists(FileName))
{
MessageBox.Show(FileName + "\n" + " 文件丢失");
}
else
{
/
ckd ckd1 = new ckd();
ckdsp ckdsp1 = new ckdsp();
FileStream fs1 = new FileStream(FileName,FileMode.Open,FileAccess.Read);
byte[] byteckd1=new byte[Marshal.SizeOf(typeof(ckd))];
byte[] byteckdsp1=new byte[Marshal.SizeOf(typeof(ckdsp))];
while (fs1.Read(byteckd1, 0, byteckd1.Length) == byteckd1.Length)
{
ckd1 = (ckd)BytesToStuct(byteckd1,typeof(ckd));
//MessageBox.Show(ckd1.lsh64.ToString());
for (int i = 0; i < ckd1.wLength; i++) //ckd1.wLength记录项目数（记录ckdsp1结构体中有多少条记录 ）
{
if (fs1.Read(byteckdsp1, 0, byteckdsp1.Length) == byteckdsp1.Length)
{
ckdsp1 = (ckdsp)BytesToStuct(byteckdsp1,typeof(ckdsp));
//MessageBox.Show(ckdsp1.iGoodsID.ToString());
}
}
}
string createtime = new string(ckd1.rq).Trim();
fs1.Flush();
fs1.Close();
string sqlLSH = string.Format("select a.FCreateTime from ShoprecentSalesM a,ShoprecentSalesD b where a.FID={0} and a.FID=b.FID", ckd1.lsh64);
MySqlCommand sqlLSHCmd = new MySqlCommand(sqlLSH, conn); /
try
{
string gets = sqlLSHCmd.ExecuteScalar().ToString();
DateTime dt = Convert.ToDateTime(gets);
string CreateTimes = dt.ToString("yyyyMMddHHmmss");
// MessageBox.Show(CreateTimes);
if (string.Compare(createtime, CreateTimes) == 0) /
{
MessageBox.Show("该文件已上传");
}
else
{
MessageBox.Show("该文件没有上传过");
}
}
catch
{
int SuccessOrFailed = 0;
int countsStopDupWriteToDb2 ;
int countStopDupWreteToDb2D;
ckd ckd2 = new ckd();
ckdsp ckdsp2 = new ckdsp();
byte[] bytedatacdk2=new byte[Marshal.SizeOf(typeof(ckd))];
byte[] bytedatacdksp2 = new byte[Marshal.SizeOf(typeof(ckdsp))];
FileStream fs2=new FileStream(FileName,FileMode.Open,FileAccess.Read);
while (fs2.Read(bytedatacdk2, 0, bytedatacdk2.Length) == bytedatacdk2.Length)
{
ckd2 = (ckd)BytesToStuct(bytedatacdk2, typeof(ckd));
string RQ = new string(ckd2.rq).Trim();
float ReturnMoney2 = ckd2.fXj - ckd2.fYs;
string StopDupWriteToDb2 = string.Format("select count(*) FROM shoprecentsalesm m WHERE m.FID={0} ", ckd2.lsh64); //---------- FID主键
MySqlCommand StopDupWriteToDb2Cmd = new MySqlCommand(StopDupWriteToDb2, conn);
countsStopDupWriteToDb2 = Convert.ToInt32(StopDupWriteToDb2Cmd.ExecuteScalar());
if (countsStopDupWriteToDb2 > 0)
{
MessageBox.Show("OK");
//continue;
}
else
{
//string InertIntoShoprecentsalesm2 = string.Format("INSERT INTO shoprecentsalesm VALUES ({0},0,{1}, {2},{3}, null,{4}, null, {5}, {6}, {7}, {8}, 0, {9}, {10}, 0, {11}, {12}, {13}, 0, null, {14}, {15}, {16}, '{17}')", ckd2.lsh64, ckd2.iShopID, ckd2.iShopID, machineID, ckd2.iMemberID, ckd2.fRes, ckd2.fYs, ckd2.fSs, ReturnMoney2, ckd2.fQt, ckd2.fXj, ckd2.fCk, ckd2.fZp, ckd2.fXy, ckd2.IDoperator, RQ, ckd2.IDgrantor, DateTime.Now.ToString());
//MySqlCommand InertIntoShoprecentsalesm2Cmd = new MySqlCommand(InertIntoShoprecentsalesm2, conn);
//InertIntoShoprecentsalesm2Cmd.ExecuteNonQuery();
//for (int j = 0; j < ckd2.wLength; j++)
//{
// if (fs2.Read(bytedatacdksp2, 0, bytedatacdksp2.Length) == bytedatacdksp2.Length)
// {
// ckdsp2 = (ckdsp)BytesToStuct(bytedatacdksp2, typeof(ckdsp));
// }
//}
MessageBox.Show("ERRor");
}
}
}
}
}
在防止重复插入数据这里不起作用，是代码写错了？还是哪出问题了！！！！
[解决办法]
断点调试下，找条重复的数据，插入时看下生成的ckd2.lsh64这个值是什么，应不是想要的id，因此不起作用
