tijian_jichuang/Code/SOH.JianYan/frmWsxmjs.cs
2025-02-20 11:54:48 +08:00

963 lines
40 KiB
C#
Raw Permalink Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using SOH.Kernel;
using EAS.Services;
using SOH.BLL;
using SOH.Entities;
using SOH.Data;
using SOH.Common;
using System.Text.RegularExpressions;
using SOH;
using System.Data.SqlClient;
using System.Data.OleDb;
namespace SOH.JianYan
{
[ModuleAttribute(ModuleID = "DDD8EA26-0D9A-402A-8369-0844FCFD4C8D", ModuleName = "外检数据传输")]
public partial class frmWsxmjs : SOH.Window.baseChildForm
{
public frmWsxmjs()
{
InitializeComponent();
}
int fddm;
int zdsh;
DataTable dgvDt = new DataTable();
private static SqlConnection connection;
private static SqlConnection connection1;
private static SqlConnection zbconnection;
private static SqlConnection zbconnection1;
private void button1_Click(object sender, EventArgs e)
{
shuaxin();
}
public void shuaxin()
{
string strDate = dtStart.Value.ToString("yyyy-MM-dd") + " 00:00:000";
string endDate = dtEnd.Value.ToString("yyyy-MM-dd") + " 23:59:000";
string mapSql = "select * from KM_ItemMap_tr";
DataTable mapDt = new DataTable();
DataTable dt = new DataTable();
string KM_Sql1 = "select F_SingleItem,F_HospSampleID,F_SamplingDate,F_SingleItemName,F_Name," +
"case F_Sex when '0' then '女'" +
"when '1' then '男'" +
"else '不详' end as xb," +
"F_Age,F_Result," +
"case F_Status when '0' then '未出结果'" +
"when '1' then '已出结果'" +
"when '2' then '已经接收'" +
"else '未知' end as status,F_Reference from V_KM_LIS_Result where F_Status=1" +
"and F_SamplingDate between '" + strDate + "' and '" + endDate + "'";
string KM_Sql2 = "select F_SingleItem,F_HospSampleID,F_SamplingDate,F_SingleItemName,F_Name," +
"case F_Sex when '0' then '女'" +
"when '1' then '男'" +
"else '不详' end as xb," +
"F_Age,F_Result," +
"case F_Status when '0' then '未出结果'" +
"when '1' then '已出结果'" +
"when '2' then '已经接收'" +
"else '未知' end as status,F_Reference from V_KM_LIS_Result where F_Status=1" +
"and F_SamplingDate between '" + strDate + "' and '" + endDate + "'";
if (fddm == 1)
{
dt = DzGetKingmedDataSet(KM_Sql1);
mapDt = DzGetKingmedDataSet(mapSql);
}
else
{
dt = ZbGetKingmedDataSet(KM_Sql2);
mapDt = ZbGetKingmedDataSet(mapSql);
}
if (dt.Rows.Count != 0)
{
foreach (DataRow dr in dt.Rows)
{
string aaa = dr["F_SingleItem"].ToString();
DataRow[] mapDrArr = mapDt.Select("F_KMItemCode='" + dr["F_SingleItem"].ToString() + "'");//查询
if (mapDrArr.Length > 0)
{
string newTm = "";
DataTable jcxmdzDt = new DataTable();
foreach (DataRow drfro in mapDrArr)
{
if (dr["F_HospSampleID"].ToString().Length > 10)
{
newTm = dr["F_HospSampleID"].ToString().Substring(0, 10);
}
else
{
if (dr["F_HospSampleID"].ToString().Length == 10)
{
if (dr["F_HospSampleID"].ToString().Substring(0, 1) == "2" || dr["F_HospSampleID"].ToString().Substring(0, 1) == "3")
{
newTm = dr["F_HospSampleID"].ToString().Substring(0, 8);
}
else
{
newTm = dr["F_HospSampleID"].ToString();
}
}
else
{
newTm = dr["F_HospSampleID"].ToString();
}
}
string jcxmdzSql = "select * from t_jcxm j where jcxmbm in (select xmbm from t_zhxmmx where zhbm in (select zhbm from t_tempdjxm where tm='" + newTm + "'))";
if (fddm == 1)
{
jcxmdzDt = GetDataSet1(jcxmdzSql);
}
else
{
jcxmdzDt = GetZbDataSet1(jcxmdzSql);
}
if (jcxmdzDt.Rows.Count != 0)
{
DataRow[] mapdrs = jcxmdzDt.Select("jcxmbm=" + drfro["F_ItemCode"]);
if (mapdrs.Length > 0)
{
//if(Convert.ToInt32(mapdrs[0]["jcxmbm"])!=3801)
//{
DataRow drs = dgvDt.NewRow();
//drs["jyxmbm"] = dr["F_SingleItem"].ToString();
drs["jyxmbm"] = mapdrs[0]["tqbm"].ToString();
drs["tm"] = dr["F_HospSampleID"].ToString();
drs["datetime"] = dr["F_SamplingDate"].ToString();
drs["jcxmmc"] = mapdrs[0]["jcxmmc"].ToString();
drs["name"] = dr["F_Name"].ToString();
drs["sex"] = dr["xb"].ToString();
drs["age"] = dr["F_Age"].ToString();
drs["result"] = dr["F_Result"].ToString();
drs["ckfw"] = dr["F_Reference"].ToString();
drs["status"] = dr["status"].ToString();
drs["jcxmbm"] = Convert.ToInt32(mapdrs[0]["jcxmbm"]);
dgvDt.Rows.Add(drs);
//}
}
}
}
}
else
{
}
}
dataGridView1.DataSource = dgvDt;
}
else
{
dataGridView1.DataSource = null;
}
}
private void button2_Click(object sender, EventArgs e)
{
if (checkBox1.Checked == true)
{
zdsh = 4;
}
else
{
zdsh = 1;
}
DataTable ygDt = new DataTable();
ygDt.Columns.Add("tmh", System.Type.GetType("System.String"));
string zdhsZd = "";
if (dgvDt.Rows.Count != 0)
{
foreach (DataRow dr in dgvDt.Rows)
{
string tmh = "";
if (dr["tm"].ToString().Length > 10)
{
tmh = dr["tm"].ToString().Substring(0, 10);
}
else
{
//tmh = dr["tm"].ToString();
if (dr["tm"].ToString().Length == 10)
{
if (dr["tm"].ToString().Substring(0, 1) == "2" || dr["tm"].ToString().Substring(0, 1) == "3")
{
tmh = dr["tm"].ToString().Substring(0, 8);
}
else
{
tmh = dr["tm"].ToString();
}
}
else
{
tmh = dr["tm"].ToString();
}
}
string xmbm = dr["jyxmbm"].ToString();
string jcxmSql = "select * from t_jcxm where zhuxiao=0 and tqbm='" + dr["jyxmbm"].ToString() + "' and jcxmbm='" + dr["jcxmbm"].ToString() + "'";
DataTable resultDt = new DataTable();
if (fddm == 1)
{
resultDt = GetDataSet1(jcxmSql);
}
else
{
resultDt = GetZbDataSet1(jcxmSql);
}
if (resultDt.Rows.Count > 0)
{
//录入体检结果
t_tjjg tjjg = new t_tjjg();
tjjg.tm = Convert.ToInt32(tmh);
int xmbms = Convert.ToInt32(resultDt.Rows[0]["jcxmbm"].ToString());
if (fddm == 2)
{
if (xmbms == 2906 || xmbms == 2907 || xmbms == 2908 || xmbms == 2909 || xmbms == 2910)
{
zdhsZd = "\r\n" + dr["jcxmmc"].ToString() + ":" + dr["result"].ToString() + "(" + dr["ckfw"].ToString() + ")";
}
}
if (fddm == 1)
{
if (xmbms == 2901 || xmbms == 2902 || xmbms == 2903 || xmbms == 2904 || xmbms == 2905)
{
zdhsZd = "\r\n" + dr["jcxmmc"].ToString() + ":" + dr["result"].ToString();
}
}
tjjg.xmbm = Convert.ToInt32(resultDt.Rows[0]["jcxmbm"].ToString());
tjjg.jg = dr["result"].ToString();
tjjg.dw = resultDt.Rows[0]["dw"].ToString();
tjjg.lx = 0;
var vservice2 = ServiceContainer.GetService<It_tempdjxm>();
String dataXb = vservice2.getXb(Convert.ToInt32(tmh));
DataTable dtXb = Newtonsoft.Json.JsonConvert.DeserializeObject(dataXb, typeof(DataTable)) as DataTable;
int xb = Convert.ToInt32(dtXb.Rows[0]["xb"]);
if (xb==0)
{
tjjg.cksx = resultDt.Rows[0]["cksx"].ToString();
tjjg.ckxx = resultDt.Rows[0]["ckxx"].ToString();
tjjg.cksx = tjjg.cksx.Equals("") ? "0" : tjjg.cksx;
tjjg.ckxx = tjjg.ckxx.Equals("") ? "0" : tjjg.ckxx;
}
else
{
tjjg.cksx = resultDt.Rows[0]["cksx1"].ToString();
tjjg.ckxx = resultDt.Rows[0]["ckxx1"].ToString();
tjjg.cksx = tjjg.cksx.Equals("") ? "0" : tjjg.cksx;
tjjg.ckxx = tjjg.ckxx.Equals("") ? "0" : tjjg.ckxx;
}
tjjg.czy = LoginUser.username;
tjjg.dyckfw = dr["ckfw"].ToString();
tjjg.upflag = 5;
var vservice = ServiceContainer.GetService<It_tjjg>();
vservice.Update(tjjg);
//修改金域数据状态值为2
string upStataSql = "update KM_LIS_Result set F_Status=2 where F_HospSampleID='" + dr["tm"].ToString() + "' and F_SingleItem='" + xmbm + "'";
if (fddm == 1)
{
int km = ExecuteCommand(upStataSql);
}
else
{
int kmZb = ZbExecuteCommand(upStataSql);
}
short ksbm = Convert.ToInt16(resultDt.Rows[0]["ksbm"].ToString());
//计算体检诊断
if (fddm == 1 && ksbm == 38)
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + ":" + tjjg.jg + "\r\n";
}
else if (tjjg.jg.IndexOf(">") > -1 && ksbm != 38)
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + "偏高\r\n";
}
else if (tjjg.jg.IndexOf("<") > -1 && ksbm != 38 && resultDt.Rows[0]["tqbm"].ToString()!= "30178"
&& resultDt.Rows[0]["tqbm"].ToString() != "30179" && resultDt.Rows[0]["tqbm"].ToString() != "30131")
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + "偏低\r\n";
}
else if (isnumeric(tjjg.jg) && tjjg.jg != "")
{
decimal dbjg = Convert.ToDecimal(tjjg.jg);
try
{
if (dbjg > Convert.ToDecimal(tjjg.cksx))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + "偏高\r\n";
}
else if (dbjg < Convert.ToDecimal(tjjg.ckxx))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + "偏低\r\n";
}
else if (tjjg.jg.Trim().Equals("阳性"))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + " 阳性\r\n";
}
else if (tjjg.jg.Trim().Equals("+"))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + " 阳性\r\n";
}
else if (tjjg.jg.Trim().Equals("+-"))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + " 弱阳性\r\n";
}
else if (tjjg.jg.Trim().Equals("弱阳"))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + " 弱阳性\r\n";
}
else if (tjjg.jg.Trim().Equals("弱阳性"))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + " 弱阳性\r\n";
}
else if (tjjg.jg.IndexOf("阳性(+") > 0)
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + " 阳性\r\n";
}
else
{
zdhsZd = "未见异常";
}
}
catch
{
//zdhsZd = "未见异常";
}
}
else
{
try
{
decimal dbjg = Convert.ToDecimal(tjjg.jg);
if (dbjg > Convert.ToDecimal(tjjg.cksx))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + "偏高\r\n";
}
else if (dbjg < Convert.ToDecimal(tjjg.ckxx))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + "偏低\r\n";
}
else if (tjjg.jg.Trim().Equals("阳性"))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + " 阳性\r\n";
}
else if (tjjg.jg.Trim().Equals("+"))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + " 阳性\r\n";
}
else if (tjjg.jg.Trim().Equals("+-"))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + " 弱阳性\r\n";
}
else if (tjjg.jg.Trim().Equals("弱阳"))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + " 弱阳性\r\n";
}
else if (tjjg.jg.Trim().Equals("弱阳性"))
{
zdhsZd = resultDt.Rows[0]["jcxmmc"].ToString() + " 弱阳性\r\n";
}
else
{
zdhsZd = "未见异常";
}
}
catch
{
//zdhsZd = "未见异常";
}
}
//录入体检诊断
string tjjdSql = "select * from t_tjjd where tm=" + tmh + " and ksbm=" + resultDt.Rows[0]["ksbm"].ToString() + "";
DataTable tjjdDt = new DataTable();
string ksSql = "select * from t_ks where ksbm=" + resultDt.Rows[0]["ksbm"].ToString() + "";
DataTable ksDt = new DataTable();
if (fddm == 1)
{
tjjdDt = GetDataSet1(tjjdSql);
ksDt = GetDataSet1(ksSql);
}
else
{
tjjdDt = GetZbDataSet1(tjjdSql);
ksDt = GetZbDataSet1(ksSql);
}
t_tjjd tjjd = new t_tjjd();
tjjd.tm = Convert.ToInt32(tmh);
tjjd.ksbm = ksbm;
if (ksbm == 80)
{
tjjd.zdjg = "详情请见检验结果报告单";
}
else
{
if (tjjdDt.Rows.Count == 0)
{
if (zdhsZd == "")
{
tjjd.zdjg = "未见异常";
}
else
{
tjjd.zdjg = zdhsZd;
}
}
else
{
if (tjjdDt.Rows[0]["zdjg"].ToString().Trim() == ksDt.Rows[0]["kszdjg"].ToString().Trim())
{
tjjd.zdjg = zdhsZd;
}
else
{
if (!"未见异常".Equals(zdhsZd))
{
if (tjjdDt.Rows[0]["zdjg"].ToString().Trim().IndexOf(zdhsZd) > 0)
{
tjjd.zdjg = tjjdDt.Rows[0]["zdjg"].ToString();
}
else
{
tjjd.zdjg = tjjdDt.Rows[0]["zdjg"].ToString() + zdhsZd;
}
}
else
{
tjjd.zdjg = tjjdDt.Rows[0]["zdjg"].ToString();
}
}
}
}
if (fddm == 2)
{
if (ksbm == 6 || ksbm == 141 || ksbm == 38)
{
//tjjd.zdjg = "详情请见检验结果报告单";
tjjd.zdjg = dr["result"].ToString();
}
if (ksbm == 29)
{
tjjd.zdjg = "乙肝诊断详见报告单";
//DataRow ygDr = ygDt.NewRow();
//ygDr["tmh"] = tmh;
//ygDt.Rows.Add(ygDr.ItemArray);
}
if (ksbm == 26)
{
tjjd.zdjg = "详情请见检验结果报告单";
}
}
tjjd.czy = LoginUser.username;
if (fddm == 2)
{
tjjd.zdys = "杜文经";
}
else
{
if (ksbm == 38)
{
//zdys = '赵爱民',czy = 'dzzam' where ksbm = 38
tjjd.zdys = "赵爱民";
tjjd.czy = "dzzam";
}
else
{
tjjd.zdys = LoginUser.xm;
}
}
tjjd.djsj = DateTime.Now.ToString("yyyy-MM-dd");
tjjd.upflag = 5;
var vservice1 = ServiceContainer.GetService<It_tjjd>();
vservice1.Update(tjjd, false, short.Parse(LoginUser.yydm));
zdhsZd = "";
//修改检查项目状态
string tempdjxmSql = "select * from t_tempdjxm where tm='" + tmh + "' and ksbm=" + ksbm + " and ztz !=4";
DataTable tempdjxmDt = new DataTable();
if (fddm == 1)
{
tempdjxmDt = GetDataSet1(tempdjxmSql);
}
else
{
tempdjxmDt = GetZbDataSet1(tempdjxmSql);
}
string message = "";
if (tempdjxmDt.Rows.Count != 0)
{
foreach (DataRow dr1 in tempdjxmDt.Rows)
{
string tjjg2Sql = "select * from t_tjjg where tm='" + tmh + "' and xmbm in (select xmbm from t_zhxmmx where zhbm='" + dr1["zhbm"].ToString() + "')";
DataTable tjjg2Dt = new DataTable();
string zhxmmxSql = "select * from t_zhxmmx where zhbm='" + dr1["zhbm"].ToString() + "'";
DataTable zhxmmxDt = new DataTable();
if (fddm == 1)
{
tjjg2Dt = GetDataSet1(tjjg2Sql);
zhxmmxDt = GetDataSet1(zhxmmxSql);
}
else
{
tjjg2Dt = GetZbDataSet1(tjjg2Sql);
zhxmmxDt = GetZbDataSet1(zhxmmxSql);
}
if (tjjg2Dt.Rows.Count == zhxmmxDt.Rows.Count)
{
t_tempdjxm tempdjxm = new t_tempdjxm();
tempdjxm.tm = Convert.ToInt32(tmh);
tempdjxm.zhbm = Convert.ToInt32(dr1["zhbm"].ToString());
if (fddm == 2)
{
if (Convert.ToInt32(dr1["ksbm"].ToString()) == 6 || Convert.ToInt32(dr1["ksbm"].ToString()) == 141)
{
tempdjxm.ztz = Convert.ToInt16(4);
string tempsql2 = "update t_tempdjxm set ztz=1 where tm=" + tmh + " and ksbm=" + Convert.ToInt32(dr1["ksbm"].ToString());
if (fddm == 2)
{
int aa = ExecuteCommand1(tempsql2);
}
}
else
{
tempdjxm.ztz = Convert.ToInt16(zdsh);
}
}
else
{
tempdjxm.ztz = Convert.ToInt16(zdsh);
}
//tempdjxm.ztz = Convert.ToInt16(zdsh);
tempdjxm.czy = LoginUser.username;
tempdjxm.upflag = 1;
//int ksbm = Convert.ToInt32(cbxhyxm.SelectedValue.ToString());
tempdjxm.ksbm = ksbm;
tempdjxm.operid = "";
var tempvs = ServiceContainer.GetService<It_tempdjxm>();
tempvs.updateZtz(tempdjxm);
}
else
{
message += "条码号:" + tmh + "组合项目:" + dr1["zhbm"].ToString() + "中有项目未录入结果,无法自动审核。\r\n ";
}
}
}
if (message != "")
{
//MessageBox.Show(message);
}
else
{
//MessageBox.Show("审核成功!");
}
}
else
{
string sql = " select * from KM_ItemMap_tr where F_ItemCode='" + dr["jcxmbm"].ToString() + "' and F_KMItemCode='" + dr["jyxmbm"].ToString() + "' ";
MessageBox.Show("" + dr["jyxmbm"].ToString() + dr["jcxmmc"].ToString() + "---金域项目编码系统中没有对照:请与管理员联系!");
continue;
}
}
shuaxin();
}
}
private void frmWsxmjs_Load(object sender, EventArgs e)
{
fddm = short.Parse(LoginUser.yydm);
dtStart.Value = DateTime.Now.Date;
dtEnd.Value = DateTime.Now.Date;
//初始化
dgvDt.Columns.Add("jyxmbm", typeof(string));
dgvDt.Columns.Add("tm", typeof(string));
dgvDt.Columns.Add("datetime", typeof(string));
dgvDt.Columns.Add("jcxmmc", typeof(string));
dgvDt.Columns.Add("name", typeof(string));
dgvDt.Columns.Add("sex", typeof(string));
dgvDt.Columns.Add("age", typeof(int));
dgvDt.Columns.Add("result", typeof(string));
dgvDt.Columns.Add("ckfw", typeof(string));
dgvDt.Columns.Add("status", typeof(string));
dgvDt.Columns.Add("jcxmbm", typeof(int));
}
#region
public static SqlConnection Connection
{
get
{
string con = "";
System.Configuration.Configuration cm = System.Configuration.ConfigurationManager.OpenExeConfiguration(AppDomain.CurrentDomain.BaseDirectory + "\\local.ext");
con = cm.AppSettings.Settings["kingmed0627"].Value;
if (connection == null)
{
connection = new SqlConnection(con);
connection.Open();
}
else if (connection.State == System.Data.ConnectionState.Closed)
{
connection.Open();
}
else if (connection.State == System.Data.ConnectionState.Broken)
{
connection.Close();
connection.Open();
}
return connection;
}
}
public static SqlConnection zbConnection
{
get
{
string con = "";
System.Configuration.Configuration cm = System.Configuration.ConfigurationManager.OpenExeConfiguration(AppDomain.CurrentDomain.BaseDirectory + "\\local.ext");
con = cm.AppSettings.Settings["kingmed0628"].Value;
if (zbconnection == null)
{
zbconnection = new SqlConnection(con);
zbconnection.Open();
}
else if (zbconnection.State == System.Data.ConnectionState.Closed)
{
zbconnection.Open();
}
else if (zbconnection.State == System.Data.ConnectionState.Broken)
{
zbconnection.Close();
zbconnection.Open();
}
return zbconnection;
}
}
public static SqlConnection Connection1
{
get
{
string con = "";
System.Configuration.Configuration cm = System.Configuration.ConfigurationManager.OpenExeConfiguration(AppDomain.CurrentDomain.BaseDirectory + "\\local.ext");
con = cm.AppSettings.Settings["bodycheck"].Value;
if (connection1 == null)
{
connection1 = new SqlConnection(con);
connection1.Open();
}
else if (connection1.State == System.Data.ConnectionState.Closed)
{
connection1.Open();
}
else if (connection1.State == System.Data.ConnectionState.Broken)
{
connection1.Close();
connection1.Open();
}
return connection1;
}
}
public static SqlConnection zbConnection1
{
get
{
string con = "";
System.Configuration.Configuration cm = System.Configuration.ConfigurationManager.OpenExeConfiguration(AppDomain.CurrentDomain.BaseDirectory + "\\local.ext");
con = cm.AppSettings.Settings["zbbodycheck"].Value;
if (zbconnection1 == null)
{
zbconnection1 = new SqlConnection(con);
zbconnection1.Open();
}
else if (zbconnection1.State == System.Data.ConnectionState.Closed)
{
zbconnection1.Open();
}
else if (zbconnection1.State == System.Data.ConnectionState.Broken)
{
zbconnection1.Close();
zbconnection1.Open();
}
return zbconnection1;
}
}
public static DataTable DzGetKingmedDataSet(string safeSql)
{
DataSet ds = new DataSet();
SqlCommand cmd = new SqlCommand(safeSql, Connection);
SqlDataAdapter da = new SqlDataAdapter(cmd);
da.Fill(ds);
return ds.Tables[0];
}
public static DataTable ZbGetKingmedDataSet(string safeSql)
{
DataSet ds = new DataSet();
SqlCommand cmd = new SqlCommand(safeSql, zbConnection);
SqlDataAdapter da = new SqlDataAdapter(cmd);
da.Fill(ds);
return ds.Tables[0];
}
public static DataTable GetDataSet1(string safeSql)
{
DataSet ds = new DataSet();
SqlCommand cmd = new SqlCommand(safeSql, Connection1);
SqlDataAdapter da = new SqlDataAdapter(cmd);
da.Fill(ds);
return ds.Tables[0];
}
public static DataTable GetZbDataSet1(string safeSql)
{
DataSet ds = new DataSet();
SqlCommand cmd = new SqlCommand(safeSql, zbConnection1);
SqlDataAdapter da = new SqlDataAdapter(cmd);
da.Fill(ds);
return ds.Tables[0];
}
public static DataTable ZBGetDataSet1(string safeSql)
{
DataSet ds = new DataSet();
SqlCommand cmd = new SqlCommand(safeSql, zbConnection1);
SqlDataAdapter da = new SqlDataAdapter(cmd);
da.Fill(ds);
return ds.Tables[0];
}
public static DataTable ExecuteCommand(string procName, string value)
{
SqlCommand cmd = new SqlCommand();
cmd.Connection = Connection;
cmd.CommandText = procName;
cmd.CommandType = CommandType.StoredProcedure;
cmd.Parameters.AddWithValue("@khbm", value);
SqlDataAdapter sda = new SqlDataAdapter(cmd);
DataTable dt = new DataTable();
sda.Fill(dt);
return dt;
}
public static int ExecuteCommand(string safeSql)
{
SqlCommand cmd = new SqlCommand(safeSql, Connection);
int result = cmd.ExecuteNonQuery();
return result;
}
public static int ExecuteCommand1(string safeSql)
{
SqlCommand cmd = new SqlCommand(safeSql, zbConnection1);
int result = cmd.ExecuteNonQuery();
return result;
}
public static int ZbExecuteCommand(string safeSql)
{
SqlCommand cmd = new SqlCommand(safeSql, zbConnection);
int result = cmd.ExecuteNonQuery();
return result;
}
public static int ZbExecuteCommand222(string safeSql)
{
SqlCommand cmd = new SqlCommand(safeSql, zbConnection1);
int result = cmd.ExecuteNonQuery();
return result;
}
public static int ExecuteCommand(string sql, params SqlParameter[] values)
{
SqlCommand cmd = new SqlCommand(sql, Connection);
cmd.Parameters.AddRange(values);
return cmd.ExecuteNonQuery();
}
public static int GetScalar(string safeSql)
{
SqlCommand cmd = new SqlCommand(safeSql, Connection);
int result = Convert.ToInt32(cmd.ExecuteScalar());
return result;
}
public static int GetScalar(params SqlParameter[] values)
{
SqlCommand cmd = new SqlCommand();
cmd.Connection = Connection;
cmd.CommandText = "Pro_InsertOrder";
cmd.CommandType = CommandType.StoredProcedure;
cmd.Parameters.AddRange(values);
int result = Convert.ToInt32(cmd.ExecuteScalar());
return result;
}
public static int GetScalar(string sql, params SqlParameter[] values)
{
SqlCommand cmd = new SqlCommand(sql, Connection);
cmd.Parameters.AddRange(values);
int result = Convert.ToInt32(cmd.ExecuteScalar());
return result;
}
public static SqlDataReader GetReader(string safeSql)
{
SqlCommand cmd = new SqlCommand(safeSql, Connection);
SqlDataReader reader = cmd.ExecuteReader();
return reader;
}
public static SqlDataReader GetReader(string sql, params SqlParameter[] values)
{
SqlCommand cmd = new SqlCommand(sql, Connection);
cmd.Parameters.AddRange(values);
SqlDataReader reader = cmd.ExecuteReader();
return reader;
}
public static DataTable GetDataSet(string safeSql)
{
DataSet ds = new DataSet();
SqlCommand cmd = new SqlCommand(safeSql, Connection);
SqlDataAdapter da = new SqlDataAdapter(cmd);
da.Fill(ds);
return ds.Tables[0];
}
public static DataTable GetDataSet(string sql, params SqlParameter[] values)
{
DataSet ds = new DataSet();
SqlCommand cmd = new SqlCommand(sql, Connection);
cmd.Parameters.AddRange(values);
SqlDataAdapter da = new SqlDataAdapter(cmd);
da.Fill(ds);
return ds.Tables[0];
}
public static void ExecuteSqlTran(List<string> SQLStringList)
{
SqlCommand cmd = new SqlCommand();
cmd.Connection = Connection;
SqlTransaction tx = Connection.BeginTransaction();
cmd.Transaction = tx;
try
{
for (int n = 0; n < SQLStringList.Count; n++)
{
string strsql = SQLStringList[n].ToString();
if (strsql.Trim().Length > 1)
{
cmd.CommandText = strsql;
cmd.ExecuteNonQuery();
}
}
tx.Commit();
}
catch (System.Data.SqlClient.SqlException E)
{
tx.Rollback();
//throw new Exception(E.Message);
MessageBox.Show("登记失败!");
}
}
#endregion
public bool isnumeric(string str)
{
char[] ch = new char[str.Length];
ch = str.ToCharArray();
for (int i = 0; i < str.Length; i++)
{
if (ch[i] < 48 || ch[i] > 57)
return false;
}
return true;
}
private void button3_Click(object sender, EventArgs e)
{
string sqlold = "select * from zbbodycheck20190420.dbo.t_jcxm"; //zbConnection1
DataTable jcxmold = new DataTable();
jcxmold = GetZbDataSet1(sqlold);
string sqlnew = "select * from t_jcxm";
DataTable jcxmnew = new DataTable();
jcxmnew = GetZbDataSet1(sqlnew);
foreach (DataRow drnew in jcxmnew.Rows)
{
foreach (DataRow drold in jcxmold.Rows)
{
if (drnew["jcxmbm"].ToString() == drold["jcxmbm"].ToString())
{
string upSql = "update t_jcxm set xssx=" + drold["xssx"].ToString() + " where jcxmbm=" + drnew["jcxmbm"].ToString();
int kmZb = ZbExecuteCommand222(upSql);
}
}
}
}
}
}