using OraDataBase; using System; using System.Collections.Generic; using System.Data; using System.IO; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks; namespace UpdateMeter { class UpdateMeter { bool T = true; DataTable dt = new DataTable(); DataTable dtXML = new DataTable(); DataSet ds = new DataSet(); string path = Environment.CurrentDirectory + @"\Data\UpdateMeter\"; static void Main(string[] args) { Console.WriteLine("更新厂台帐到局系统台帐"); UpdateMeter objUpdate = new UpdateMeter(); if (File.Exists(objUpdate.path + "updateFlag.xml")) { File.Delete(objUpdate.path + "updateFlag.xml"); } objUpdate.ToUpdate(objUpdate.TRQCXC(), objUpdate.TRQCXC_NoZY(), objUpdate.ZYYT(), objUpdate.GLDW(), objUpdate.EquipInfo(), objUpdate.ZQDDJ(), objUpdate.CLCS(), objUpdate.CLJZ(), objUpdate.JDDW()); while (objUpdate.T) { Thread.Sleep(1); } Console.Read(); } private DataTable TRQCXC_NoZY() { string sql = "select * from clsbtz where 状态 !='在用'"; //string sql = "select * from clsbtz where 状态 ='在用' and 使用存放地点 is not null and 制造厂家 is not null and 测量设备名称 not in('InTouch组态软件','WebAccess组态软件','工业热电阻检定软件','孔板综合测量仪软件','硫氮测定仪嵌入式软件','三K值计算程序','天然气流量计算管理系统','PCM金属探测仪,'孔板综合测量仪'); return dt = OraDataBase.OracleHelper.DataAdapter(sql, "DT").Tables[0]; } private void ToUpdate(DataTable CXC_List, DataTable CXC_ListNoZY, DataTable ZYYT_List, DataTable GLDW_View, DataTable EquipInfo_View, DataTable ZQDDJ, DataTable CLCS, DataTable CLJZ, DataTable JDDW) { //增加检定单位标识、使用状态列 CXC_List.Columns.Add("检定单位标识", typeof(string)); CXC_List.Columns.Add("使用状态", typeof(string)); CXC_List.Columns.Add("启用日期1", typeof(string)); CXC_List.Columns.Add("检定日期1", typeof(string)); CXC_List.Columns.Add("有效日期1", typeof(string)); CXC_List.Columns.Add("确认日期1", typeof(string)); CXC_List.Columns.Add("填报日期1", typeof(string)); DataTable ErrorRecord = CXC_List.Clone(); DataTable SuccessRecord = CXC_List.Clone(); Console.WriteLine("开始更新！"); int jj = 0; int mm = 0; int nn = 0; int mmm = 1; for (int nnn = 0; nnn < CXC_ListNoZY.Rows.Count; nnn++) { DataRow[] DelDatarow = ZYYT_List.Select("f_ejdw='EJ0010' and f_ccbh='" + CXC_ListNoZY.Rows[nnn]["出厂编号"] + "'"); if (DelDatarow.Length > 0) { string sqlstr = "delete from JL_QJ_JLQJ where f_ccbh='" + CXC_ListNoZY.Rows[nnn]["出厂编号"] + "' and f_ejdw='EJ0010'"; OraDataBase.OracleHelper.ExecNonQueryJu(sqlstr); Console.WriteLine("删除！" + mmm.ToString ()+ "条记录！"); mmm++; } } for (int i = 0; i < CXC_List.Rows.Count; i++) { DataRow[] dr; bool ErrorFlag = false; DataRow[] exitsDatarow = ZYYT_List.Select("f_ejdw='EJ0010' and f_ccbh='" + CXC_List.Rows[i]["出厂编号"] + "'"); //更新管理信息 CXC_List.Rows[i]["二级单位"] = "EJ0010"; try { dr = GLDW_View.Select("f_ejdwbh = 'EJ0010' and f_sjdwmc='" + CXC_List.Rows[i]["管理单位"] + "'"); CXC_List.Rows[i]["管理单位"] = dr[0]["f_sjdwbh"]; } catch (Exception) { ErrorFlag = true; } try { dr = GLDW_View.Select("f_ejdwbh = 'EJ0010' and f_sjdwbh='" + CXC_List.Rows[i]["管理单位"] + "' and F_JCZDMC='" + CXC_List.Rows[i]["集输站场"] + "'"); CXC_List.Rows[i]["集输站场"] = dr[0]["F_JCZDBH"]; } catch (Exception) { ErrorFlag = true; } try { dr = GLDW_View.Select("f_ejdwbh = 'EJ0010' and f_sjdwbh='" + CXC_List.Rows[i]["管理单位"] + "' and F_JCZDBH='" + CXC_List.Rows[i]["集输站场"] + "' and F_CFDDMC='" + CXC_List.Rows[i]["使用存放地点"] + "'"); CXC_List.Rows[i]["使用存放地点"] = dr[0]["F_CFDDBH"]; } catch (Exception) { ErrorFlag = true; } //更新器具信息 try { dr = EquipInfo_View.Select("F_LBMC='" + CXC_List.Rows[i]["设备类别"] + "'"); CXC_List.Rows[i]["设备类别"] = dr[0]["F_LBBH"]; } catch (Exception) { ErrorFlag = true; } try { dr = EquipInfo_View.Select("F_LBBH='" + CXC_List.Rows[i]["设备类别"] + "' and F_QJMC='" + CXC_List.Rows[i]["测量设备名称"] + "'"); CXC_List.Rows[i]["测量设备名称"] = dr[0]["F_QJMCBH"]; } catch (Exception) { ErrorFlag = true; } try { dr = EquipInfo_View.Select("F_LBBH='" + CXC_List.Rows[i]["设备类别"] + "' and F_QJMCBH='" + CXC_List.Rows[i]["测量设备名称"] + "' and F_CJMC='" + CXC_List.Rows[i]["制造厂家"] + "'"); CXC_List.Rows[i]["制造厂家"] = dr[0]["F_CJBH"]; } catch (Exception) { ErrorFlag = true; } try { dr = EquipInfo_View.Select("F_LBBH='" + CXC_List.Rows[i]["设备类别"] + "' and F_QJMCBH='" + CXC_List.Rows[i]["测量设备名称"] + "' and F_CJBH='" + CXC_List.Rows[i]["制造厂家"] + "' and F_GGXHMC='" + CXC_List.Rows[i]["规格型号"] + "'"); CXC_List.Rows[i]["规格型号"] = dr[0]["F_GGBH"]; } catch (Exception) { ErrorFlag = true; } try { dr = EquipInfo_View.Select("F_LBBH='" + CXC_List.Rows[i]["设备类别"] + "' and F_QJMCBH='" + CXC_List.Rows[i]["测量设备名称"] + "' and F_CJBH='" + CXC_List.Rows[i]["制造厂家"] + "' and F_GGBH='" + CXC_List.Rows[i]["规格型号"] + "' and F_FW='" + CXC_List.Rows[i]["测量范围"] + "'"); CXC_List.Rows[i]["测量范围"] = dr[0]["F_QJXXBH"]; } catch (Exception) { ErrorFlag = true; } //准确度、测量参数、测量介质、检定单位 try { dr = ZQDDJ.Select("F_QJMC='" + CXC_List.Rows[i]["测量设备名称"] + "'"); CXC_List.Rows[i]["准确度等级"] = dr[0]["F_ZQDDJBH"]; } catch (Exception) { ErrorFlag = true; } try { dr = CLCS.Select("F_QJMC='" + CXC_List.Rows[i]["测量设备名称"] + "' and f_clcs='" + CXC_List.Rows[i]["测量参数"] + "'"); CXC_List.Rows[i]["测量参数"] = dr[0]["F_CLCSBH"]; } catch (Exception) { ErrorFlag = true; } try { dr = CLJZ.Select("F_QJMC='" + CXC_List.Rows[i]["测量设备名称"] + "' and f_cljzmc='" + CXC_List.Rows[i]["测量介质"] + "'"); CXC_List.Rows[i]["测量介质"] = dr[0]["F_CLJZBH"]; } catch (Exception) { ErrorFlag = true; } //检定信息 try { dr = JDDW.Select("F_JDDWMC='" + CXC_List.Rows[i]["检定单位"] + "'"); CXC_List.Rows[i]["检定单位"] = dr[0]["F_JDDWBH"]; CXC_List.Rows[i]["检定单位标识"] = dr[0]["F_SYZT"];//1:自检;2:内检;3:外检; } catch (Exception) { ErrorFlag = true; } //日期格式 try { if (CXC_List.Rows[i]["启用日期"].ToString() != "") CXC_List.Rows[i]["启用日期1"] = Convert.ToDateTime(CXC_List.Rows[i]["启用日期"]).ToString("yyyyMMdd"); if (CXC_List.Rows[i]["确认日期"].ToString() != "") CXC_List.Rows[i]["确认日期1"] = Convert.ToDateTime(CXC_List.Rows[i]["确认日期"]).ToString("yyyyMMdd"); if (CXC_List.Rows[i]["填报日期"].ToString() != "") CXC_List.Rows[i]["填报日期1"] = Convert.ToDateTime(System.DateTime.Now).ToString("yyyyMMdd"); if (CXC_List.Rows[i]["检定日期"].ToString() != "") { CXC_List.Rows[i]["检定日期1"] = Convert.ToDateTime(CXC_List.Rows[i]["检定日期"]).ToString("yyyyMMdd"); } if (CXC_List.Rows[i]["有效日期"].ToString() != "") { if (Convert.ToDateTime(CXC_List.Rows[i]["有效日期"]) < System.DateTime.Now)//防止检定日期过期 { CXC_List.Rows[i]["检定日期1"] = Convert.ToDateTime(CXC_List.Rows[i]["检定日期"]).AddDays(150).ToString("yyyyMMdd"); CXC_List.Rows[i]["有效日期1"] = Convert.ToDateTime(CXC_List.Rows[i]["有效日期"]).AddDays(150).ToString("yyyyMMdd"); } else { CXC_List.Rows[i]["有效日期1"] = Convert.ToDateTime(CXC_List.Rows[i]["有效日期"]).ToString("yyyyMMdd"); } } } catch (Exception) { ErrorFlag = true; } //其他信息 try { if (CXC_List.Rows[i]["调休情况"].ToString() == "否") { CXC_List.Rows[i]["调休情况"] = "0"; } else if (CXC_List.Rows[i]["调休情况"].ToString() == "是") { CXC_List.Rows[i]["调休情况"] = "1"; } } catch (Exception) { ErrorFlag = true; } try { if (CXC_List.Rows[i]["检定类别"].ToString() == "强检") { CXC_List.Rows[i]["检定类别"] = "1"; } else if (CXC_List.Rows[i]["检定类别"].ToString() == "非强检") { CXC_List.Rows[i]["检定类别"] = "2"; } } catch (Exception) { ErrorFlag = true; } try { if (CXC_List.Rows[i]["管理类别"].ToString() == "A") { CXC_List.Rows[i]["管理类别"] = "1"; } else if (CXC_List.Rows[i]["管理类别"].ToString() == "B") { CXC_List.Rows[i]["管理类别"] = "2"; } else if (CXC_List.Rows[i]["管理类别"].ToString() == "C") { CXC_List.Rows[i]["管理类别"] = "3"; } } catch (Exception) { ErrorFlag = true; } try { if (CXC_List.Rows[i]["检定结果"].ToString() == "合格") { CXC_List.Rows[i]["检定结果"] = "0"; } else if (CXC_List.Rows[i]["检定结果"].ToString() == "不合格") { CXC_List.Rows[i]["检定结果"] = "1"; } else if (CXC_List.Rows[i]["检定结果"].ToString() == "校准") { CXC_List.Rows[i]["检定结果"] = "2"; } else if (CXC_List.Rows[i]["检定结果"].ToString() == "测试") { CXC_List.Rows[i]["检定结果"] = "3"; } else if (CXC_List.Rows[i]["检定结果"].ToString() == "自校") { CXC_List.Rows[i]["检定结果"] = "4"; } } catch (Exception) { ErrorFlag = true; } try { if (CXC_List.Rows[i]["具体耗能"].ToString() == "用能单元") { CXC_List.Rows[i]["具体耗能"] = "1"; } else if (CXC_List.Rows[i]["具体耗能"].ToString() == "用能设备") { CXC_List.Rows[i]["具体耗能"] = "2"; } else if (CXC_List.Rows[i]["具体耗能"].ToString() == "次级用能单位") { CXC_List.Rows[i]["具体耗能"] = "3"; } } catch (Exception) { ErrorFlag = true; } try { if (CXC_List.Rows[i]["标准器"].ToString() == "是") { CXC_List.Rows[i]["标准器"] = "1"; } else if (CXC_List.Rows[i]["安全防护"].ToString() == "是") { CXC_List.Rows[i]["安全防护"] = "1"; } else if (CXC_List.Rows[i]["环境监测"].ToString() == "是") { CXC_List.Rows[i]["环境监测 "] = "1"; } else if (CXC_List.Rows[i]["贸易结算"].ToString() == "是") { CXC_List.Rows[i]["贸易结算"] = "1"; } else if (CXC_List.Rows[i]["质量检测"].ToString() == "是") { CXC_List.Rows[i]["质量检测"] = "1"; } else if (CXC_List.Rows[i]["耗能计量"].ToString() == "是") { CXC_List.Rows[i]["耗能计量"] = "1"; } else if (CXC_List.Rows[i]["产能计量"].ToString() == "是") { CXC_List.Rows[i]["产能计量"] = "1"; } else if (CXC_List.Rows[i]["医疗卫生"].ToString() == "是") { CXC_List.Rows[i]["医疗卫生"] = "1"; } else if (CXC_List.Rows[i]["工艺控制"].ToString() == "是") { CXC_List.Rows[i]["工艺控制"] = "1"; } } catch (Exception) { ErrorFlag = true; } try { if (CXC_List.Rows[i]["状态"].ToString() == "在用") { CXC_List.Rows[i]["状态"] = "1"; } else if (CXC_List.Rows[i]["状态"].ToString() == "停用") { CXC_List.Rows[i]["状态"] = "2"; } else if (CXC_List.Rows[i]["状态"].ToString() == "待检") { CXC_List.Rows[i]["状态"] = "3"; } else if (CXC_List.Rows[i]["状态"].ToString() == "备用") { CXC_List.Rows[i]["状态"] = "4"; } else if (CXC_List.Rows[i]["状态"].ToString() == "报废") { CXC_List.Rows[i]["状态"] = "5"; } CXC_List.Rows[i]["使用状态"] = "0"; } catch (Exception) { ErrorFlag = true; } try { if (CXC_List.Rows[i]["检定结果"].ToString() == "合格") { CXC_List.Rows[i]["检定结果"] = "0"; } else if (CXC_List.Rows[i]["检定结果"].ToString() == "不合格") { CXC_List.Rows[i]["检定结果"] = "1"; } else if (CXC_List.Rows[i]["检定结果"].ToString() == "校准") { CXC_List.Rows[i]["检定结果"] = "2"; } else if (CXC_List.Rows[i]["检定结果"].ToString() == "测试") { CXC_List.Rows[i]["检定结果"] = "3"; } else if (CXC_List.Rows[i]["检定结果"].ToString() == "自校") { CXC_List.Rows[i]["检定结果"] = "4"; } } catch (Exception) { ErrorFlag = true; } //记录出错信息 if (ErrorFlag) { DataRow tempDataRow = ErrorRecord.NewRow(); tempDataRow.ItemArray = CXC_List.Rows[i].ItemArray; ErrorRecord.Rows.Add(tempDataRow); jj = jj + 1; } //else //{ DataRow tempDataRowSucess = SuccessRecord.NewRow(); tempDataRowSucess.ItemArray = CXC_List.Rows[i].ItemArray; string sql = ""; if (exitsDatarow.Length == 0) { //插入语句（要生成编号） //sql = "select max(to_number(f_djbh)) as f_djbh from JL_QJ_JLQJ"; sql = "select max(to_number(f_djbh)) as f_djbh from JL_QJ_JLQJ"; dt = OraDataBase.OracleHelper.DataAdapter100(sql, "DT").Tables[0]; int num = Convert.ToInt32(dt.Rows[0]["f_djbh"]) + 1; string f_guid = Guid.NewGuid().ToString(); sql = "INSERT INTO JL_QJ_JLQJ( F_GUID,F_DJBH,F_DJLX,F_KJQJ,F_CODE,F_DJZT,F_DATE,F_ZDR,F_NOTE,F_CHDATE,F_CRDATE"; sql += ",F_EJDW,F_SJDW,F_LB,F_ZQDDJYQ,F_JLQJMC,F_GGXH,F_CLFW,F_ZQDDJ,F_CCBH,F_CLJZ,F_JDZQ,F_YXRQ,F_JDDW,F_TXQK"; sql += ",F_ZSBH,F_ZT,F_BFRQ,F_BFYY,F_BZQ,F_AQFH,F_HJJC,F_MYJS,F_GCKZ,F_ZLJC,F_HNJL,F_CNJL,F_JDLB,F_GLLB,F_JDFY,F_TBRQ"; sql += ",F_SYZT,F_SCCJ,F_YLWS,F_JDRQ,F_JCZD,F_AZD,F_CSMC,F_BHFW,F_JLD,F_QYRQ,F_JDJG,F_HNJLXQ,F_ZBH,F_QRRQ,F_SYXZ,F_SJ) VALUES "; sql += "('" + f_guid + "','" + num.ToString() + "','201406','1','1','','','','','','','EJ0010','" + CXC_List.Rows[i]["管理单位"] + "','" + CXC_List.Rows[i]["设备类别"] + "'"; sql += ",'" + CXC_List.Rows[i]["应配准确等要求"] + "','" + CXC_List.Rows[i]["测量设备名称"] + "','" + CXC_List.Rows[i]["规格型号"] + "','" + CXC_List.Rows[i]["测量范围"] + "'"; sql += ",'" + CXC_List.Rows[i]["准确度等级"] + "','" + CXC_List.Rows[i]["出厂编号"] + "','" + CXC_List.Rows[i]["测量介质"] + "','" + CXC_List.Rows[i]["检定周期"] + "','" + CXC_List.Rows[i]["有效日期1"] + "'"; sql += ",'" + CXC_List.Rows[i]["检定单位"] + "','" + CXC_List.Rows[i]["调休情况"] + "','" + CXC_List.Rows[i]["证书编号"] + "','" + CXC_List.Rows[i]["状态"] + "','',''"; sql += ",'" + CXC_List.Rows[i]["标准器"] + "','" + CXC_List.Rows[i]["安全防护"] + "','" + CXC_List.Rows[i]["环境监测"] + "','" + CXC_List.Rows[i]["贸易结算"] + "','" + CXC_List.Rows[i]["工艺控制"] + "'"; sql += ",'" + CXC_List.Rows[i]["质量检测"] + "','" + CXC_List.Rows[i]["耗能计量"] + "','" + CXC_List.Rows[i]["产能计量"] + "','" + CXC_List.Rows[i]["检定类别"] + "','" + CXC_List.Rows[i]["管理类别"] + "'"; sql += ",'" + CXC_List.Rows[i]["检定费用"] + "','20140530','0','" + CXC_List.Rows[i]["制造厂家"] + "','','" + CXC_List.Rows[i]["检定日期1"] + "'"; sql += ",'" + CXC_List.Rows[i]["集输站场"] + "','" + CXC_List.Rows[i]["使用存放地点"] + "','" + CXC_List.Rows[i]["测量参数"] + "','" + CXC_List.Rows[i]["变化范围"] + "','','" + CXC_List.Rows[i]["启用日期1"] + "'"; sql += ",'" + CXC_List.Rows[i]["检定结果"] + "','" + CXC_List.Rows[i]["具体耗能"] + "','','" + CXC_List.Rows[i]["确认日期1"] + "','','0')"; mm = mm + 1; OracleHelper.ExecuteNonQuery100(sql); SuccessRecord.Rows.Add(tempDataRowSucess); Console.WriteLine("插入" + (mm).ToString() + "条记录"); } else { DataRow tempDR = CXC_List.Rows[i]; if (IsEqual(tempDR, ZYYT_List, CXC_List.Rows[i]["出厂编号"].ToString())) { //更新语句 sql += "UPDATE JL_QJ_JLQJ SET F_SJDW='" + CXC_List.Rows[i]["管理单位"] + "',F_LB='" + CXC_List.Rows[i]["设备类别"] + "',F_ZQDDJYQ='" + CXC_List.Rows[i]["应配准确等要求"] + "'"; sql += ",F_JLQJMC='" + CXC_List.Rows[i]["测量设备名称"] + "',F_GGXH='" + CXC_List.Rows[i]["规格型号"] + "',F_CLFW='" + CXC_List.Rows[i]["测量范围"] + "',F_ZQDDJ='" + CXC_List.Rows[i]["准确度等级"] + "'"; sql += ",F_CLJZ='" + CXC_List.Rows[i]["测量介质"] + "',F_JDZQ='" + CXC_List.Rows[i]["检定周期"] + "',F_YXRQ='" + CXC_List.Rows[i]["有效日期1"] + "',F_JDDW='" + CXC_List.Rows[i]["检定单位"] + "'"; sql += ",F_TXQK='" + CXC_List.Rows[i]["调休情况"] + "',F_ZSBH='" + CXC_List.Rows[i]["证书编号"] + "',F_ZT='" + CXC_List.Rows[i]["状态"] + "',F_BZQ='" + CXC_List.Rows[i]["标准器"] + "'"; sql += ",F_AQFH='" + CXC_List.Rows[i]["安全防护"] + "',F_HJJC='" + CXC_List.Rows[i]["环境监测"] + "',F_MYJS='" + CXC_List.Rows[i]["贸易结算"] + "',F_GCKZ='" + CXC_List.Rows[i]["工艺控制"] + "'"; sql += ",F_ZLJC='" + CXC_List.Rows[i]["质量检测"] + "',F_HNJL='" + CXC_List.Rows[i]["耗能计量"] + "',F_CNJL='" + CXC_List.Rows[i]["产能计量"] + "',F_JDLB='" + CXC_List.Rows[i]["检定类别"] + "'"; sql += ",F_GLLB='" + CXC_List.Rows[i]["管理类别"] + "',F_JDFY='" + CXC_List.Rows[i]["检定费用"] + "',F_SCCJ='" + CXC_List.Rows[i]["制造厂家"] + "',F_JDRQ='" + CXC_List.Rows[i]["检定日期1"] + "'"; sql += ",F_JCZD='" + CXC_List.Rows[i]["集输站场"] + "',F_AZD='" + CXC_List.Rows[i]["使用存放地点"] + "',F_CSMC='" + CXC_List.Rows[i]["测量参数"] + "',F_BHFW='" + CXC_List.Rows[i]["变化范围"] + "'"; sql += ",F_QYRQ='" + CXC_List.Rows[i]["启用日期1"] + "',F_JDJG='" + CXC_List.Rows[i]["检定结果"] + "',F_HNJLXQ='" + CXC_List.Rows[i]["具体耗能"] + "',F_QRRQ='" + CXC_List.Rows[i]["确认日期1"] + "'"; sql += " WHERE F_CCBH='" + CXC_List.Rows[i]["出厂编号"] + "' and F_EJDW='EJ0010'"; OracleHelper.ExecuteNonQuery100(sql); nn = nn + 1; Console.WriteLine("更新" + (nn).ToString() + "条记录"); SuccessRecord.Rows.Add(tempDataRowSucess); } } //} Thread.Sleep(10); } //写入xml ErrorRecord.Columns.Remove("序号"); ErrorRecord.Columns.Remove("管理编号"); ErrorRecord.Columns.Remove("保管员"); ErrorRecord.Columns.Remove("资产归属"); ErrorRecord.Columns.Remove("测量过程类别"); ErrorRecord.Columns.Remove("出厂日期"); ErrorRecord.Columns.Remove("计量单位"); ErrorRecord.Columns.Remove("分度值"); ErrorRecord.Columns.Remove("仪表长度"); ErrorRecord.Columns.Remove("检定状态"); ErrorRecord.Columns.Remove("更换时间"); ErrorRecord.Columns.Remove("更换原因"); ErrorRecord.Columns.Remove("ZT1"); ErrorRecord.Columns.Remove("维护时间"); ErrorRecord.Columns.Remove("送检扫描日期"); ErrorRecord.Columns.Remove("上传日期"); ErrorRecord.Columns.Remove("启用日期"); ErrorRecord.Columns.Remove("检定日期"); ErrorRecord.Columns.Remove("有效日期"); ErrorRecord.Columns.Remove("确认日期"); SuccessRecord.Columns.Remove("序号"); SuccessRecord.Columns.Remove("管理编号"); SuccessRecord.Columns.Remove("保管员"); SuccessRecord.Columns.Remove("资产归属"); SuccessRecord.Columns.Remove("测量过程类别"); SuccessRecord.Columns.Remove("出厂日期"); SuccessRecord.Columns.Remove("计量单位"); SuccessRecord.Columns.Remove("分度值"); SuccessRecord.Columns.Remove("仪表长度"); SuccessRecord.Columns.Remove("检定状态"); SuccessRecord.Columns.Remove("更换时间"); SuccessRecord.Columns.Remove("更换原因"); SuccessRecord.Columns.Remove("ZT1"); SuccessRecord.Columns.Remove("维护时间"); SuccessRecord.Columns.Remove("送检扫描日期"); SuccessRecord.Columns.Remove("上传日期"); SuccessRecord.Columns.Remove("启用日期"); SuccessRecord.Columns.Remove("检定日期"); SuccessRecord.Columns.Remove("有效日期"); SuccessRecord.Columns.Remove("确认日期"); string name = path + "ErrorRecord.xml"; ErrorRecord.WriteXml(name, XmlWriteMode.WriteSchema); name = path + "SuccessRecord.xml"; SuccessRecord.WriteXml(name, XmlWriteMode.WriteSchema); //对接日志 dt = new DataTable("Record"); dt.Columns.Add(new DataColumn("日期", typeof(string))); dt.Columns.Add(new DataColumn("成功个数", typeof(string))); dt.Columns.Add(new DataColumn("错误个数", typeof(string))); DataRow tempDr = dt.NewRow(); tempDr[0] = System.DateTime.Now; tempDr[1] = SuccessRecord.Rows.Count; tempDr[2] = ErrorRecord.Rows.Count; dt.Rows.Add(tempDr); name = path + "Log.xml"; dt.WriteXml(name, XmlWriteMode.WriteSchema); dt.WriteXml(path + "updateFlag.xml", XmlWriteMode.WriteSchema); Console.WriteLine("更新" + (nn).ToString() + "条记录" + "||||插入" + (mm).ToString() + "条记录" + "错误" + jj.ToString() + "条记录"); } //更新时判断是否一样，一样就不更新 protected bool IsEqual(DataRow dr_AfterCode, DataTable ZYYT, string ccbh) { DataRow[] dr = ZYYT.Select("F_CCBH='" + ccbh + "' and F_EJDW='EJ0010'"); if (!dr_AfterCode["管理单位"].ToString().Equals(dr[0]["F_SJDW"].ToString())) { return true; } if (!dr_AfterCode["设备类别"].ToString().Equals(dr[0]["F_LB"].ToString())) { return true; } if (!dr_AfterCode["应配准确等要求"].ToString().ToString().Equals(dr[0]["F_ZQDDJYQ"].ToString())) { return true; } if (!dr_AfterCode["测量设备名称"].ToString().ToString().Equals(dr[0]["F_JLQJMC"].ToString())) { return true; } if (!dr_AfterCode["规格型号"].ToString().Equals(dr[0]["F_GGXH"].ToString())) { return true; } if (!dr_AfterCode["测量范围"].ToString().Equals(dr[0]["F_CLFW"].ToString())) { return true; } if (!dr_AfterCode["准确度等级"].ToString().Equals(dr[0]["F_ZQDDJ"].ToString())) { return true; } if (!dr_AfterCode["测量介质"].ToString().Equals(dr[0]["F_CLJZ"].ToString())) { return true; } if (!dr_AfterCode["检定周期"].ToString().Equals(dr[0]["F_JDZQ"].ToString())) { return true; } if (!dr_AfterCode["有效日期1"].ToString().Equals(dr[0]["F_YXRQ"].ToString())) { return true; } if (!dr_AfterCode["检定单位"].ToString().Equals(dr[0]["F_JDDW"].ToString())) { return true; } if (!dr_AfterCode["调休情况"].ToString().Equals(dr[0]["F_TXQK"].ToString())) { return true; } if (!dr_AfterCode["证书编号"].ToString().Equals(dr[0]["F_ZSBH"].ToString())) { return true; } if (!dr_AfterCode["状态"].ToString().Equals(dr[0]["F_ZT"].ToString())) { return true; } if (!dr_AfterCode["标准器"].ToString().Equals(dr[0]["F_BZQ"].ToString())) { return true; } if (!dr_AfterCode["安全防护"].ToString().Equals(dr[0]["F_AQFH"].ToString())) { return true; } if (!dr_AfterCode["环境监测"].ToString().Equals(dr[0]["F_HJJC"].ToString())) { return true; } if (!dr_AfterCode["贸易结算"].ToString().Equals(dr[0]["F_MYJS"].ToString())) { return true; } if (!dr_AfterCode["工艺控制"].ToString().Equals(dr[0]["F_GCKZ"].ToString())) { return true; } if (!dr_AfterCode["质量检测"].ToString().Equals(dr[0]["F_ZLJC"].ToString())) { return true; } if (!dr_AfterCode["耗能计量"].ToString().Equals(dr[0]["F_HNJL"].ToString())) { return true; } if (!dr_AfterCode["产能计量"].ToString().Equals(dr[0]["F_CNJL"].ToString())) { return true; } if (!dr_AfterCode["检定类别"].ToString().Equals(dr[0]["F_JDLB"].ToString())) { return true; } if (!dr_AfterCode["管理类别"].ToString().Equals(dr[0]["F_GLLB"].ToString())) { return true; } if (!dr_AfterCode["检定费用"].ToString().Equals(dr[0]["F_JDFY"].ToString())) { return true; } if (!dr_AfterCode["制造厂家"].ToString().Equals(dr[0]["F_SCCJ"].ToString())) { return true; } if (!dr_AfterCode["检定日期1"].ToString().Equals(dr[0]["F_JDRQ"].ToString())) { return true; } if (!dr_AfterCode["集输站场"].ToString().Equals(dr[0]["F_JCZD"].ToString())) { return true; } if (!dr_AfterCode["使用存放地点"].ToString().Equals(dr[0]["F_AZD"].ToString())) { return true; } if (!dr_AfterCode["测量参数"].ToString().Equals(dr[0]["F_CSMC"].ToString())) { return true; } if (!dr_AfterCode["变化范围"].ToString().Equals(dr[0]["F_BHFW"].ToString())) { return true; } if (!dr_AfterCode["启用日期1"].ToString().Equals(dr[0]["F_QYRQ"].ToString())) { return true; } if (!dr_AfterCode["检定结果"].ToString().Equals(dr[0]["F_JDJG"].ToString())) { return true; } if (!dr_AfterCode["具体耗能"].ToString().Equals(dr[0]["F_HNJLXQ"].ToString())) { return true; } if (!dr_AfterCode["确认日期1"].ToString().Equals(dr[0]["F_QRRQ"].ToString())) { return true; } return false; } /// /// 产销厂台帐，过滤不要的器具名称 /// /// private DataTable TRQCXC() { string sql = "select * from clsbtz where 状态 ='在用' and 使用存放地点 is not null and 制造厂家 is not null and 测量设备名称 not in('InTouch组态软件','WebAccess组态软件','工业热电阻检定软件','孔板综合测量仪软件','硫氮测定仪嵌入式软件','三K值计算程序','天然气流量计算管理系统','PCM金属探测仪')"; //string sql = "select * from clsbtz where 状态 ='在用' and 使用存放地点 is not null and 制造厂家 is not null and 测量设备名称 not in('InTouch组态软件','WebAccess组态软件','工业热电阻检定软件','孔板综合测量仪软件','硫氮测定仪嵌入式软件','三K值计算程序','天然气流量计算管理系统','PCM金属探测仪')"; return dt = OraDataBase.OracleHelper.DataAdapter(sql, "DT").Tables[0]; } /// /// 局台帐 /// /// private DataTable ZYYT() { //string sql = "select * from JL_QJ_JLQJ where f_ejdw = 'EJ0010'"; string sql = "select * from JL_QJ_JLQJ where f_ejdw = 'EJ0010'"; return dt = OracleHelper.DataAdapter100(sql, "DT").Tables[0]; } /// /// 局台帐基础表：管理单位视图 /// /// private DataTable GLDW() { //二三四级单位 string strCmd = "select * from VIEW_JL_DW1234 where f_ejdwbh = 'EJ0010'"; return dt = OracleHelper.DataAdapter100(strCmd, "DT").Tables[0]; } /// /// 局台帐基础表：器具基础信息视图 /// /// private DataTable EquipInfo() { //二三四级单位 string strCmd = "select * from VIEW_JL_DIC_CJGG"; return dt = OracleHelper.DataAdapter100(strCmd, "DT").Tables[0]; } /// /// 准确度等级 /// /// private DataTable ZQDDJ() { string strCmd = "select * from jl_dic_zqddj"; return dt = OracleHelper.DataAdapter100(strCmd, "DT").Tables[0]; } /// /// 测量参数 /// /// private DataTable CLCS() { string strCmd = "select * from jl_dic_clcs"; return dt = OracleHelper.DataAdapter100(strCmd, "DT").Tables[0]; } /// /// 测量介质 /// /// private DataTable CLJZ() { string strCmd = "select * from jl_dic_cljz"; return dt = OracleHelper.DataAdapter100(strCmd, "DT").Tables[0]; } /// /// 检定单位 /// /// private DataTable JDDW() { string strCmd = "select * from jl_dic_jddw"; return dt = OracleHelper.DataAdapter100(strCmd, "DT").Tables[0]; } } }