cyf
920 lines
47 KiB
C#
920 lines
47 KiB
C#
using Lskj.Control;
|
|
using Lskj.Core;
|
|
using Lskj.Data;
|
|
//using Lskj.Util;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.ComponentModel;
|
|
using System.Data;
|
|
using System.Data.SqlClient;
|
|
using System.Drawing;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading;
|
|
using System.Windows.Forms;
|
|
using static SynchronousOven.NewEmp;
|
|
|
|
namespace SynchronousOven
|
|
{
|
|
public partial class Form1 : Form
|
|
{
|
|
/// <summary>
|
|
/// ini文件内段落名
|
|
/// </summary>
|
|
public bool RunAutomatically = false;
|
|
|
|
/// <summary>
|
|
/// ini文件内段落名
|
|
/// </summary>
|
|
public string company = "烤箱同步工具";
|
|
/// <summary>
|
|
/// 初始时间间隔
|
|
/// </summary>
|
|
int second = 30;
|
|
/// <summary>
|
|
/// IP,端口，请求路径
|
|
/// </summary>
|
|
public string IP = "110.185.210.70";
|
|
public string port = "8881";
|
|
|
|
public System.Threading.Thread thread = null;
|
|
|
|
public System.Timers.Timer timer1 = new System.Timers.Timer();
|
|
|
|
public Form1()
|
|
{
|
|
InitializeComponent();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 初始化
|
|
/// </summary>
|
|
/// <param name="sender"></param>
|
|
/// <param name="e"></param>
|
|
private void Form1_Load(object sender, EventArgs e)
|
|
{
|
|
txtSeverId.Text = Lskj.Util.IniHelper.Read("Setting.ini", company, "serverName");
|
|
txtDataBase.Text = Lskj.Util.IniHelper.Read("Setting.ini", company, "dbName");
|
|
txtName.Text = Lskj.Util.IniHelper.Read("Setting.ini", company, "user");
|
|
txtPassword.Text = Lskj.Util.IniHelper.Read("Setting.ini", company, "password");
|
|
txtTimeInterval.Text = Lskj.Util.IniHelper.Read("Setting.ini", company, "interval");
|
|
|
|
//txtSeverId.Text = IniUtil.IniReadValue(company, "serverName");
|
|
//txtDataBase.Text = IniUtil.IniReadValue(company, "dbName");
|
|
//txtName.Text = IniUtil.IniReadValue(company, "user");
|
|
//txtPassword.Text = IniUtil.IniReadValue(company, "password");
|
|
//txtTimeInterval.Text = IniUtil.IniReadValue(company, "interval");
|
|
|
|
|
|
if (string.IsNullOrEmpty(txtTimeInterval.Text)) txtTimeInterval.Text = "30";
|
|
txtTimeInterval.LostFocus += new EventHandler(txtTimeInterval_LostFocus);
|
|
this.FormClosed += new FormClosedEventHandler(Form1_FormClosed);
|
|
this.timer1.Elapsed += new System.Timers.ElapsedEventHandler(timer1_Tick);
|
|
|
|
//数据都有的话就自动启动
|
|
if (!string.IsNullOrWhiteSpace(txtSeverId.Text) && !string.IsNullOrWhiteSpace(txtDataBase.Text) && !string.IsNullOrWhiteSpace(txtName.Text) && !string.IsNullOrWhiteSpace(txtPassword.Text) && !string.IsNullOrWhiteSpace(txtTimeInterval.Text))
|
|
{
|
|
RunAutomatically = Lskj.Util.IniHelper.Read("Setting.ini", company, "RunAutomatically").Equals("1");
|
|
if (RunAutomatically)
|
|
{
|
|
this.btnBegin_Click(null, null);
|
|
}
|
|
}
|
|
}
|
|
private void Form1_FormClosed(object sender, FormClosedEventArgs e)
|
|
{
|
|
if (thread != null)
|
|
{
|
|
thread.Abort();
|
|
}
|
|
this.Dispose();
|
|
this.Close();
|
|
}
|
|
|
|
|
|
|
|
/// <summary>
|
|
/// 时间间隔TextBox失去焦点事件
|
|
/// </summary>
|
|
/// <param name="sender"></param>
|
|
/// <param name="e"></param>
|
|
private void txtTimeInterval_LostFocus(object sender, EventArgs e)
|
|
{
|
|
string checkStr = txtTimeInterval.Text.ToString();
|
|
if (string.IsNullOrEmpty(checkStr)) txtTimeInterval.Text = "30";
|
|
int check = Convert.ToInt32(txtTimeInterval.Text.ToString());
|
|
if (check < 30)
|
|
{
|
|
txtTimeInterval.Text = "30";
|
|
}
|
|
second = Convert.ToInt32(txtTimeInterval.Text.ToString());
|
|
IniUtil.IniWriteValue(company, "interval", txtTimeInterval.Text.ToString());
|
|
}
|
|
|
|
//开始同步
|
|
private void btnBegin_Click(object sender, EventArgs e)
|
|
{
|
|
if (thread == null)
|
|
{
|
|
thread = new System.Threading.Thread(StartMethod);
|
|
thread.Start();
|
|
|
|
}
|
|
}
|
|
|
|
|
|
//同步事件
|
|
private void StartMethod()
|
|
{
|
|
try
|
|
{
|
|
if (ConnectServer())
|
|
{
|
|
//判断数据库是否有该配置列
|
|
DataTable DT = SqlHelper.ExecuteDataTable("select name from syscolumns where id=object_id('mrp_WorkTaskListTab') and name='SyncFlag'");
|
|
bool flag = DT.Rows.Count > 0;
|
|
if (!flag)
|
|
{
|
|
MessageBox.Show("同步失败，原因：数据库内无同步标识列！");
|
|
return;
|
|
}
|
|
timer1.Interval = second * 1000;
|
|
|
|
RefreshLogUIThread("开始同步");
|
|
SynchronizeWorkOrder();
|
|
|
|
SynchronizeStatus();
|
|
SynchronousMachiningParameter();
|
|
SynchronizePersonnelInformation();
|
|
RefreshLogUIThread("同步完成");
|
|
|
|
timer1.Enabled = true;
|
|
this.timer1.Start();
|
|
}
|
|
else
|
|
{
|
|
thread = null;
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
RefreshLogUIThread(DateTime.Now + string.Format("失败.原因:{0}.\r\n", ex.Message));
|
|
}
|
|
}
|
|
|
|
//private void RefreshTemperature()
|
|
//{
|
|
// Thread thread = new Thread(DatabaseMonitoring);
|
|
// thread.IsBackground = true;
|
|
// thread.Start();
|
|
//}
|
|
|
|
|
|
///// <summary>
|
|
///// timer2事件
|
|
///// </summary>
|
|
///// <param name="sender"></param>
|
|
///// <param name="e"></param>
|
|
//private void timer2_Tick(object sender, EventArgs e)
|
|
//{
|
|
// RefreshTemperature();
|
|
//}
|
|
|
|
/// <summary>
|
|
/// timer事件
|
|
/// </summary>
|
|
/// <param name="sender"></param>
|
|
/// <param name="e"></param>
|
|
private void timer1_Tick(object sender, EventArgs e)
|
|
{
|
|
timer1.Enabled = false;
|
|
ReClearLogUIThread();//清除内容
|
|
SynchronizeWorkOrder();
|
|
SynchronizeStatus();
|
|
SynchronousMachiningParameter();
|
|
SynchronizePersonnelInformation();
|
|
timer1.Enabled = true;
|
|
}
|
|
/// <summary>
|
|
///温度同步
|
|
/// </summary>
|
|
//public void DatabaseMonitoring()
|
|
//{
|
|
// string sqlValue = "select * from p_sbhottab";
|
|
// DataTable dt = SqlHelper.ExecuteDataTable(sqlValue);
|
|
// string url = "http://110.185.210.70:8881/business/receive/findEquipmentSetData?jtBillNo=";
|
|
// foreach (DataRow row in dt.Rows)
|
|
// {
|
|
// if (string.IsNullOrEmpty(row["sbhot"].ToString()) || row["sbhot"].ToString().Equals("0.00"))
|
|
// {
|
|
// url = "http://110.185.210.70:8881/business/receive/findEquipmentSetData?jtBillNo=";
|
|
// url += row["sbno"];
|
|
// ResponseMode mode = NewEmp.GetUrl(url);
|
|
// if (mode!=null&&0 == mode.ret)
|
|
// {
|
|
// string temp = mode.data.temp;
|
|
// sqlValue = string.Format("update p_sbhottab set sbhot='{0}' where sbno='{1}'", temp, row["sbno"].ToString());
|
|
// SqlHelper.ExecuteNonQuery(sqlValue);
|
|
// }
|
|
// else
|
|
// {
|
|
// string errorMsg = mode != null ? mode.msg : "未知原因.";
|
|
// RefreshLogUIThread(DateTime.Now + string.Format(" 维修状态,信息读取失败,错误原因:{0}.\r\n", errorMsg));
|
|
// }
|
|
// }
|
|
// }
|
|
|
|
//}
|
|
|
|
|
|
/// <summary>
|
|
/// 同步事件 人员账号信息
|
|
/// </summary>
|
|
private void SynchronizePersonnelInformation()
|
|
{
|
|
//现在用户信息表里的信息
|
|
string sqlValue = "select isnull(LoginAccount,'') as LoginAccount,isnull(Password,'') as Password,isnull(p_emp_status,'') as p_emp_status,isnull(EmployeeName,'') as EmployeeName,isnull(p_emp_linkphone,'') as p_emp_linkphone,isnull(p_emp_email,'') as p_emp_email from P_EmployeeTab";
|
|
DataTable dt = SqlHelper.ExecuteDataTable(sqlValue);
|
|
sqlValue = "select isnull(LoginAccount,'') as LoginAccount,isnull(UseFlag,0) as UseFlag from P_EmployeeTab";
|
|
DataTable useFlagTab = SqlHelper.ExecuteDataTable(sqlValue);
|
|
//人员信息对照表
|
|
sqlValue = "select * from P_EmployeeTab_temp";
|
|
DataTable lastimportDt = SqlHelper.ExecuteDataTable(sqlValue);
|
|
//有差别的数据 差集
|
|
DataTable changeContent = dt.Clone();
|
|
IEnumerable<DataRow> QCJ = dt.Select().AsEnumerable().Except(lastimportDt.Select().AsEnumerable(), DataRowComparer.Default);
|
|
try
|
|
{
|
|
DataTable jg = QCJ.CopyToDataTable();
|
|
changeContent = jg;
|
|
|
|
//sqlValue = "select LoginAccount,Password,p_emp_status,EmployeeName,p_emp_linkphone,p_emp_email from P_EmployeeTab where LoginAccount='09998'";
|
|
//changeContent = SqlHelper.ExecuteDataTable(sqlValue);
|
|
}
|
|
catch (System.InvalidOperationException ex) //如果差集为null，就回进当前报错
|
|
{
|
|
changeContent = dt.Clone();
|
|
}
|
|
finally
|
|
{
|
|
//更改表格列名
|
|
changeContent.Columns["LoginAccount"].ColumnName = "userName";
|
|
changeContent.Columns["Password"].ColumnName = "password";
|
|
changeContent.Columns["p_emp_status"].ColumnName = "status";
|
|
changeContent.Columns["EmployeeName"].ColumnName = "trueName";
|
|
changeContent.Columns["p_emp_linkphone"].ColumnName = "phone";
|
|
changeContent.Columns["p_emp_email"].ColumnName = "email";
|
|
}
|
|
|
|
string tokenName = "09998";
|
|
string token = GetToken();
|
|
|
|
try
|
|
{
|
|
foreach (DataRow item in changeContent.Rows)
|
|
{
|
|
string statusStr = item["status"] + "";
|
|
//判断更改状态
|
|
string loginAccount = item["userName"] + "";
|
|
DataTable selectTab = SqlHelper.ExecuteDataTable(string.Format("select * from P_EmployeeTab_temp where LoginAccount='{0}'", loginAccount));
|
|
if (selectTab.Rows.Count == 0)
|
|
{
|
|
item["status"] = "1";
|
|
}
|
|
else
|
|
{
|
|
string useFlag = useFlagTab.Select(string.Format("LoginAccount='{0}'", loginAccount))[0]["UseFlag"] + "";
|
|
DataRow selectRow = selectTab.Rows[0];
|
|
if ((item["status"] + "").Equals("离职") || useFlag.Equals("0") || useFlag.Equals(""))
|
|
{
|
|
item["status"] = "3";
|
|
}
|
|
else
|
|
{
|
|
item["status"] = "2";
|
|
}
|
|
}
|
|
if (!string.IsNullOrWhiteSpace(token))
|
|
{
|
|
string jsonObj = JsonUtil.ToJsonObject(item);
|
|
newResponseMode newmode = ExecutePost(tokenName, token, jsonObj);
|
|
|
|
//修改对比表数据
|
|
sqlValue = string.Format(@"if(select 1 from P_EmployeeTab_temp where LoginAccount='{0}')=1
|
|
begin
|
|
update P_EmployeeTab_temp set Password = '{1}', p_emp_status = '{2}',EmployeeName='{3}',p_emp_linkphone='{4}',p_emp_email='{5}' where LoginAccount='{0}';
|
|
end else
|
|
begin
|
|
insert into P_EmployeeTab_temp(LoginAccount,Password,p_emp_status,EmployeeName,p_emp_linkphone,p_emp_email) values('{0}', '{1}', '{2}','{3}','{4}','{5}')
|
|
end
|
|
", item["userName"], item["password"], statusStr, item["trueName"], item["phone"], item["email"]);
|
|
SqlHelper.ExecuteNonQuery(sqlValue);
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
RefreshLogUIThread(DateTime.Now + string.Format(" 人员账号信息,信息读取失败.\r\n" + " 原因:" + ex.Message + Environment.NewLine));
|
|
}
|
|
RefreshLogUIThread(DateTime.Now + "人员账号信息 同步完成.\r\n");
|
|
RefreshLogUIThread("--------------------分割线------------------------\r\n");
|
|
}
|
|
private newResponseMode ExecutePost(string tokenName, string token, string jsonStr, int num = 0)
|
|
{
|
|
string url = "http://110.185.210.70:8881/auth/sys/users/thirdPlatformData?userDb=ditoo&username={0}&token={1}";
|
|
url = string.Format(url, tokenName, token);
|
|
string jsonObj = jsonStr;
|
|
string newDeljson = jsonObj.Substring(1, jsonObj.Length - 2);
|
|
newResponseMode newmode = NewEmp.newPostMethodToObj(url, newDeljson);
|
|
if (newmode.msg.Equals("token验证失败,请重新登录!"))
|
|
{
|
|
if (num < 10)
|
|
{
|
|
num += 1;
|
|
token = GetToken();
|
|
newmode = ExecutePost(tokenName, token, jsonStr, num);
|
|
}
|
|
else
|
|
{
|
|
return newmode;
|
|
}
|
|
}
|
|
return newmode;
|
|
}
|
|
private string GetToken()
|
|
{
|
|
string token = string.Empty;
|
|
string tokenUrl = "http://110.185.210.70:8881/auth/sys/users/thirdPlatformData/login?userDb=ditoo";//获得令牌
|
|
string tokenSqlStr = "select isnull(LoginAccount,'') as LoginAccount,isnull(Password,'') as Password,isnull(p_emp_status,'') as p_emp_status,isnull(EmployeeName,'') as EmployeeName,isnull(p_emp_linkphone,'') as p_emp_linkphone,isnull(p_emp_email,'') as p_emp_email from P_EmployeeTab where LoginAccount='09998'";
|
|
DataTable tokenTab = SqlHelper.ExecuteDataTable(tokenSqlStr);
|
|
DataRow tokenRow = null;
|
|
if (tokenTab.Rows.Count > 0)
|
|
{
|
|
tokenRow = tokenTab.Rows[0];
|
|
}
|
|
if (tokenRow != null)
|
|
{
|
|
string tokenName = tokenRow["LoginAccount"] + "";
|
|
string tokenPassWord = tokenRow["Password"] + "";
|
|
string tokenJson = string.Format("\"userName\":\"{0}\",\"password\":\"{1}\"", tokenName, tokenPassWord);//sbs@4433 item["password"] + ""
|
|
tokenJson = "{" + tokenJson + "}";
|
|
newResponseMode mode = NewEmp.newPostMethodToObj(tokenUrl, tokenJson);
|
|
if (mode.data != null)
|
|
{
|
|
token = mode.data.token;
|
|
}
|
|
}
|
|
return token;
|
|
}
|
|
/// <summary>
|
|
/// 同步事件 维修状态
|
|
/// </summary>
|
|
private void SynchronizeStatus()
|
|
{
|
|
//当前最新的维修状态信息
|
|
string sqlValue = @"
|
|
select sbnumber as 'jtBillNo',isrepair,COALESCE((
|
|
select top 1 Ema_wx_wxman
|
|
from EMA_WxMaintab a left
|
|
join p_departmenttab b on a.Ema_wx_departmentid = b.Departmentid
|
|
where 1 = 1
|
|
and isnull(Ema_wx_Affirmer, 0) <> 0
|
|
and ISNULL(Ema_wx_stepcode, '') > 100 and Ema_wx_sbnumber = sbnumber order by Ema_wx_operatedate desc
|
|
) ,'')as 'ema_wx_wxman',
|
|
COALESCE((
|
|
select top 1 case when Ema_wx_receiveflag=1 then '维修中'
|
|
when Ema_wx_receiveflag=2 then '完工'
|
|
when Ema_wx_receiveflag=3 then '暂停'
|
|
else '未开工' end
|
|
from EMA_WxMaintab a left
|
|
join p_departmenttab b on a.Ema_wx_departmentid = b.Departmentid
|
|
where 1 = 1
|
|
and isnull(Ema_wx_Affirmer, 0) <> 0
|
|
and ISNULL(Ema_wx_stepcode, '') > 100 and Ema_wx_sbnumber = sbnumber order by Ema_wx_operatedate desc
|
|
) ,'')as 'stateOfRepair'
|
|
from(select a.*
|
|
,case when sbnumber in (select Ema_wx_sbnumber from EMA_WxMaintab where Ema_wx_receiveflag = 1) then '是'
|
|
else '' end as isrepair
|
|
,case when sbnumber in (select ema_sbnumber from EMA_stopTab where ema_type = '停用' ) then '停用'
|
|
when sbnumber in (select ema_pst_number from EMA_ScrapTab ) then '报废'
|
|
when sbnumber in (select Ema_wx_sbnumber from EMA_WxMaintab where isnull(Ema_wx_receiveflag,0) = 0) then '待修'
|
|
else '启用' end as Usage
|
|
from Wms_toolsTab a where 1 = 1
|
|
) a where 1 = 1 ";
|
|
|
|
//2022-1-20 zj让把Ema_wx_receiveflag 改为isnull(Ema_wx_receiveflag,0) 改前是按照设备档案sql查询
|
|
DataTable dt = SqlHelper.ExecuteDataTable(sqlValue);
|
|
//上一次同步时的维修信息
|
|
sqlValue = "select * from lastimport_repair";
|
|
DataTable lastimportDt = SqlHelper.ExecuteDataTable(sqlValue);
|
|
//有差别的数据 差集
|
|
DataTable changeContent = dt.Clone();
|
|
IEnumerable<DataRow> QCJ = dt.Select().AsEnumerable().Except(lastimportDt.Select().AsEnumerable(), DataRowComparer.Default);
|
|
try
|
|
{
|
|
DataTable jg = QCJ.CopyToDataTable();
|
|
changeContent = jg;
|
|
}
|
|
catch (System.InvalidOperationException ex) //如果差集为null，就回进当前报错
|
|
{
|
|
changeContent = dt.Clone();
|
|
}
|
|
|
|
string url = "http://110.185.210.70:8881/business/receive/maintainRecord";
|
|
try
|
|
{
|
|
foreach (DataRow item in changeContent.Rows)
|
|
{
|
|
string ema_wx_wxman = item["ema_wx_wxman"].ToString();
|
|
string name = (ema_wx_wxman.Split(','))[0];//维修人只传第一个
|
|
item["ema_wx_wxman"] = name;
|
|
|
|
string jtBillNo = item["jtBillNo"].ToString();
|
|
string newjtBillNo = jtBillNo.Trim();
|
|
item["jtBillNo"] = newjtBillNo;
|
|
|
|
string jsonObj = JsonUtil.ToJsonObject(item);
|
|
string deljson = jsonObj.Substring(1, jsonObj.Length - 2);
|
|
|
|
ResponseMode mode = NewEmp.PostMethodToObj(url, deljson);
|
|
item["ema_wx_wxman"] = ema_wx_wxman;
|
|
item["jtBillNo"] = jtBillNo;
|
|
if (mode != null && 0 == mode.ret)
|
|
{
|
|
//修改上一次查询表的数据,根据是否存在编号去修改或新增
|
|
sqlValue = string.Format(@"if(select 1 from lastimport_repair where jtBillNo='{0}')=1
|
|
begin
|
|
update lastimport_repair set isrepair = '{1}', ema_wx_wxman = '{2}',stateOfRepair='{3}' where jtBillNo='{0}';
|
|
end else
|
|
begin
|
|
insert into lastimport_repair(jtBillNo, isrepair, ema_wx_wxman,stateOfRepair) values('{0}', '{1}', '{2}','{3}')
|
|
end",
|
|
item["jtBillNo"], item["isrepair"], item["ema_wx_wxman"], item["stateOfRepair"]);
|
|
SqlHelper.ExecuteNonQuery(sqlValue);
|
|
string updareabak = DateTime.Now + string.Format(" 维修状态{0} 信息同步成功.\r\n", item["jtBillNo"]);
|
|
RefreshLogUIThread(updareabak);
|
|
}
|
|
else
|
|
{
|
|
string errorMsg = mode != null ? mode.msg : "未知原因.";
|
|
RefreshLogUIThread(DateTime.Now + string.Format(" 维修状态,信息读取失败,错误原因:{0}.\r\n", errorMsg));
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
RefreshLogUIThread(DateTime.Now + string.Format(" 维修状态,信息读取失败.\r\n" + " 原因:" + ex.Message + Environment.NewLine));
|
|
}
|
|
RefreshLogUIThread(DateTime.Now + "维修状态 同步完成.\r\n");
|
|
RefreshLogUIThread("--------------------分割线------------------------\r\n");
|
|
}
|
|
|
|
|
|
|
|
/// <summary>
|
|
/// 同步事件 加工参数
|
|
/// </summary>
|
|
private void SynchronousMachiningParameter()
|
|
{
|
|
//当前最新的加工参数数据
|
|
string sqlValue = @"select wms_ep_ProductId,wms_ep_mojuid,isnull(wms_ep_bzlhwd,0)as wms_ep_bzlhwd ,isnull(wms_ep_lhwdgc,0)as wms_ep_lhwdgc,
|
|
isnull(wms_ep_lhtime,0)as wms_ep_lhtime,isnull(wms_ep_sjgc,0)as wms_ep_sjgc,isnull(wms_ep_lhyl,0)as wms_ep_lhyl,
|
|
isnull(wms_ep_ylgc,0)as wms_ep_ylgc,isnull(wms_ep_bzedwd,0)as wms_ep_bzedwd,isnull(wms_ep_edwdgc,0)as wms_ep_edwdgc,
|
|
isnull(wms_ep_bzedtime,0)as wms_ep_bzedtime,isnull(wms_ep_edsjgc,0)as wms_ep_edsjgc,isnull(wms_ep_bzedwd2,0)as wms_ep_bzedwd2,
|
|
isnull(wms_ep_edwdgc2,0)as wms_ep_edwdgc2,isnull(wms_ep_bzedtime2,0)as wms_ep_bzedtime2,isnull(wms_ep_edsjgc2,0)as wms_ep_edsjgc2,
|
|
isnull(wms_ep_bzedwd3,0)as wms_ep_bzedwd3,isnull(wms_ep_edwdgc3,0)as wms_ep_edwdgc3,isnull(wms_ep_bzedtime3,0)as wms_ep_bzedtime3,
|
|
isnull(wms_ep_edsjgc3,0)as wms_ep_edsjgc3,isnull(wms_ep_bzedwd4,0)as wms_ep_bzedwd4,isnull(wms_ep_edwdgc4,0)as wms_ep_edwdgc4,
|
|
isnull(wms_ep_bzedtime4,0)as wms_ep_bzedtime4,isnull(wms_ep_edsjgc4,0)as wms_ep_edsjgc4,isnull(wms_ep_jfdy,0)as wms_ep_jfdy,
|
|
isnull(wms_ep_nyz,0)as wms_ep_nyz,isnull(wms_ep_nytime,0)as wms_ep_nytime,isnull(wms_ep_yl1,0)as wms_ep_yl1,isnull(wms_ep_yl2,0)as wms_ep_yl2,
|
|
isnull(wms_ep_yl3,0)as wms_ep_yl3,isnull(wms_ep_yl4,0)as wms_ep_yl4,isnull(wms_ep_yl5,0)as wms_ep_yl5,isnull(wms_ep_yl6,0)as wms_ep_yl6,
|
|
isnull(wms_ep_yl7,0)as wms_ep_yl7,isnull(wms_ep_yl8,0)as wms_ep_yl8,isnull(wms_ep_yl9,0)as wms_ep_yl9,isnull(wms_ep_yl10,0)as wms_ep_yl10
|
|
from wms_Equipmentparameterstab";
|
|
DataTable dt = SqlHelper.ExecuteDataTable(sqlValue);
|
|
// 上一次同步时物料加工标准参数
|
|
sqlValue = @"select wms_ep_ProductId,wms_ep_mojuid,wms_ep_bzlhwd,wms_ep_lhwdgc,wms_ep_lhtime,wms_ep_sjgc,wms_ep_lhyl,wms_ep_ylgc,
|
|
wms_ep_bzedwd,wms_ep_edwdgc,wms_ep_bzedtime,wms_ep_edsjgc,wms_ep_bzedwd2,wms_ep_edwdgc2,wms_ep_bzedtime2,wms_ep_edsjgc2,
|
|
wms_ep_bzedwd3,wms_ep_edwdgc3,wms_ep_bzedtime3,wms_ep_edsjgc3,wms_ep_bzedwd4,wms_ep_edwdgc4,wms_ep_bzedtime4,wms_ep_edsjgc4,
|
|
wms_ep_jfdy,wms_ep_nyz,wms_ep_nytime,wms_ep_yl1,wms_ep_yl2,wms_ep_yl3,wms_ep_yl4,wms_ep_yl5,wms_ep_yl6,wms_ep_yl7,wms_ep_yl8,
|
|
wms_ep_yl9,wms_ep_yl10
|
|
from lastimport_machining";
|
|
DataTable LastTimeDt = SqlHelper.ExecuteDataTable(sqlValue);
|
|
//需要同步的数据
|
|
DataTable changeContent = dt.Clone();
|
|
//差集
|
|
IEnumerable<DataRow> QCJ = dt.Select().AsEnumerable().Except(LastTimeDt.Select().AsEnumerable(), DataRowComparer.Default);
|
|
string url = "http://110.185.210.70:8881/business/receive/productionStandard";
|
|
try
|
|
{
|
|
DataTable jg = QCJ.CopyToDataTable();
|
|
changeContent = jg;
|
|
}
|
|
catch (System.InvalidOperationException ex) //如果差集为null，就回进当前报错
|
|
{
|
|
changeContent = dt.Clone();
|
|
}
|
|
|
|
try
|
|
{
|
|
foreach (DataRow item in changeContent.Rows)
|
|
{
|
|
string updateSql = "update {0} set {1} where {2}='{3}';";
|
|
string insertSql = "insert into {0}({1}) values({2});";
|
|
string updateFields = string.Empty;
|
|
string insertFields = string.Empty;
|
|
string insertValues = string.Empty;
|
|
|
|
string jsonObj = JsonUtil.ToJsonObject(item);
|
|
string deljson = jsonObj.Substring(1, jsonObj.Length - 2);
|
|
ResponseMode mode = NewEmp.PostMethodToObj(url, deljson);
|
|
if (mode != null && 0 == mode.ret)
|
|
{
|
|
//判断对照表中是否存在相同编码
|
|
DataRow[] dr = LastTimeDt.Select("wms_ep_ProductId" + "='" + item["wms_ep_ProductId"] + "'");
|
|
bool isupdate = dr.Length == 1 ? true : false;
|
|
//同步数据到对照表中
|
|
foreach (DataColumn column in changeContent.Columns)
|
|
{
|
|
if (isupdate)
|
|
{
|
|
//修改语句
|
|
if (!column.ColumnName.Equals("wms_ep_ProductId"))
|
|
{
|
|
if (column.DataType == typeof(Decimal) || column.DataType == typeof(Int32))
|
|
{
|
|
updateFields += string.Format("[{0}]='{1}',", column.ColumnName, 0);
|
|
}
|
|
else
|
|
{
|
|
updateFields += string.Format("[{0}]='{1}',", column.ColumnName, (item[column.ColumnName] + "").Replace("'", "''"));
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
//新增语句
|
|
string fieldValue = string.Empty;
|
|
fieldValue = (item[column.ColumnName] + "").Replace("'", "''");
|
|
insertFields += "[" + column.ColumnName + "],";
|
|
if (!string.IsNullOrWhiteSpace(fieldValue))
|
|
{
|
|
insertValues += column.DataType == typeof(DateTime) ? "'" + Convert.ToDateTime(fieldValue).ToString("yyyy-MM-dd HH:mm:ss") + "'," : "'" + fieldValue + "',";
|
|
}
|
|
else
|
|
{
|
|
if (column.DataType == typeof(Decimal) || column.DataType == typeof(Int32))
|
|
insertValues += "0,";
|
|
else if (column.DataType == typeof(DateTime))
|
|
insertValues += "NULL,";
|
|
else
|
|
insertValues += "'',";
|
|
}
|
|
}
|
|
}
|
|
updateFields = updateFields.TrimEnd(',');
|
|
insertFields = insertFields.TrimEnd(',');
|
|
insertValues = insertValues.TrimEnd(',');
|
|
|
|
if (!string.IsNullOrEmpty(updateFields))
|
|
{
|
|
sqlValue = string.Format(updateSql, "lastimport_machining", updateFields, "wms_ep_ProductId", item["wms_ep_ProductId"]);
|
|
}
|
|
if (!string.IsNullOrEmpty(insertFields))
|
|
{
|
|
sqlValue = string.Format(insertSql, "lastimport_machining", insertFields, insertValues);
|
|
}
|
|
SqlHelper.ExecuteNonQuery(sqlValue);
|
|
string updareabak = DateTime.Now + string.Format(" 加工参数{0} 信息同步成功.\r\n", item["wms_ep_ProductId"]);
|
|
RefreshLogUIThread(updareabak);
|
|
}
|
|
else
|
|
{
|
|
string errorMsg = mode != null ? mode.msg : "未知原因.";
|
|
RefreshLogUIThread(DateTime.Now + string.Format(" 加工参数 信息读取失败,错误原因:{0}.\r\n", errorMsg));
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
RefreshLogUIThread(DateTime.Now + string.Format("加工参数 信息读取失败.\r\n" + " 原因:" + ex.Message + Environment.NewLine));
|
|
}
|
|
RefreshLogUIThread(DateTime.Now + "加工参数 同步完成.\r\n");
|
|
RefreshLogUIThread("--------------------分割线------------------------\r\n");
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
/// 同步事件 工单明细信息
|
|
/// </summary>
|
|
private void SynchronizeWorkOrder()
|
|
{
|
|
// string sqlValue = @"select mrp_lwt_id,mrp_lwt_workno ,mrp_lwt_workordername ,stdt,
|
|
//(select (CASE mrp_lwt_workordername WHEN '硫化' THEN (select mrp_lwt_beforeAmount) ELSE( select (mrp_lwt_kxamount1+mrp_lwt_kxamount2 +mrp_lwt_kxamount3) as 'mrp_lwt_kxamount' from mrp_WorkTaskListTab where mrp_lwt_workno = a.mrp_lwt_workno and mrp_lwt_workordername=a.mrp_lwt_workordername and mrp_lwt_ProductId=a.mrp_lwt_ProductId and mrp_lwt_id=a.mrp_lwt_id )END )) as'mrp_lwt_beforeAmount',
|
|
//--mrp_lwt_beforeAmount,
|
|
// enddt,mrp_lwt_AfterAmount,mrp_lwt_badamount,
|
|
// (select EmployeeName from p_employeetab where employeeid = mrp_lwt_publishOper) as mrp_lwt_publishOper,
|
|
// mrp_lwt_ProductId,
|
|
// (select mrp_mwt_appellation from mrp_worktaskmaintab where mrp_mwt_workno = mrp_lwt_workno)as 'mrp_mwt_appellation',
|
|
|
|
//(select (CASE mrp_lwt_workordername WHEN '硫化' THEN (select jtBillNo from Mps_MachineSetTab where id =(select mrp_mwt_machine from mrp_worktaskmaintab where mrp_mwt_workno = a.mrp_lwt_workno)) ELSE( select mrp_lwt_kaoxiang1 from mrp_WorkTaskListTab where mrp_lwt_workno = a.mrp_lwt_workno and mrp_lwt_workordername=a.mrp_lwt_workordername and mrp_lwt_ProductId=a.mrp_lwt_ProductId and mrp_lwt_id=a.mrp_lwt_id )END )) as'jtBillNo',
|
|
//(select (CASE mrp_lwt_workordername WHEN '硫化' THEN (select jtname from Mps_MachineSetTab where id =(select mrp_mwt_machine from mrp_worktaskmaintab where mrp_mwt_workno = a.mrp_lwt_workno)) ELSE( select jtname from Mps_MachineSetTab where jtBillNo =(select mrp_lwt_kaoxiang1 from mrp_WorkTaskListTab where mrp_lwt_workno = a.mrp_lwt_workno and mrp_lwt_workordername=a.mrp_lwt_workordername and mrp_lwt_ProductId=a.mrp_lwt_ProductId and mrp_lwt_id=a.mrp_lwt_id ))END )) as'jtname',
|
|
// --(select jtBillNo from Mps_MachineSetTab where id =(select CASE mrp_lwt_workordername WHEN '硫化' THEN mrp_mwt_machine ELSE mrp_mwt_str3 END from mrp_worktaskmaintab where mrp_mwt_workno = mrp_lwt_workno)) as 'jtBillNo',
|
|
// --(select jtname from Mps_MachineSetTab where id =(select CASE mrp_lwt_workordername WHEN '硫化' THEN mrp_mwt_machine ELSE mrp_mwt_str3 END from mrp_worktaskmaintab where mrp_mwt_workno = mrp_lwt_workno)) as 'jtname',
|
|
//SyncFlag,
|
|
// (select mrp_mwt_comid from mrp_worktaskmaintab where mrp_mwt_workno = mrp_lwt_workno)as 'comid',
|
|
// (select mrp_mwt_finish from mrp_worktaskmaintab where mrp_mwt_workno = mrp_lwt_workno)as 'finish'
|
|
// from(
|
|
// select
|
|
// *, DATEDIFF(minute, a.mrp_lwt_starttime, a.mrp_lwt_endtime) / 60 as betweenTime
|
|
// ,case when isnull(mrp_lwt_glgx, '') = '' then b.mes_list_glgx else mrp_lwt_glgx end as glgx
|
|
// from mrp_WorkTaskListTab a with(nolock)
|
|
// left join(
|
|
// select mes_list_no, mes_List_Name , mes_list_glgx from mes_fl_list with(nolock)
|
|
// where isnull(sign,0)= 0
|
|
// ) b on b.mes_list_no = a.mrp_lwt_prolistno
|
|
// left join(
|
|
// select a.workno, a.taskid, MIN(optime) stdt, max(opendtime) enddt
|
|
// from mrp_worktaskoptimetab a
|
|
// group by a.workno, a.taskid
|
|
// ) aa on a.mrp_lwt_workno = aa.workno and a.mrp_lwt_id = aa.taskid
|
|
// where 1 = 1
|
|
// ) a where 1 = 1 and (mrp_lwt_workordername = '硫化' or mrp_lwt_workordername = '二段硫化') and ISNULL(SyncFlag,0)<>1 ";
|
|
//and stdt > '2021-11-19' and mrp_lwt_workno='CCP202201170056' and ISNULL(SyncFlag,0)<>1
|
|
|
|
|
|
string sqlValue = @"select mrp_lwt_id,mrp_lwt_workno ,mrp_lwt_workordername ,stdt,
|
|
(select (CASE mrp_lwt_workordername WHEN '硫化' THEN (select mrp_lwt_beforeAmount) ELSE( select (mrp_lwt_kxamount1+mrp_lwt_kxamount2 +mrp_lwt_kxamount3) as 'mrp_lwt_kxamount' from mrp_WorkTaskListTab where mrp_lwt_workno = a.mrp_lwt_workno and mrp_lwt_workordername=a.mrp_lwt_workordername and mrp_lwt_ProductId=a.mrp_lwt_ProductId and mrp_lwt_id=a.mrp_lwt_id )END )) as'mrp_lwt_beforeAmount',
|
|
enddt,mrp_lwt_AfterAmount,mrp_lwt_badamount,
|
|
(select EmployeeName from p_employeetab where employeeid = mrp_lwt_publishOper) as mrp_lwt_publishOper,
|
|
mrp_lwt_ProductId,
|
|
(select mrp_mwt_appellation from mrp_worktaskmaintab where mrp_mwt_workno = mrp_lwt_workno)as 'mrp_mwt_appellation',
|
|
(select (CASE mrp_lwt_workordername WHEN '硫化' THEN (select jtBillNo from Mps_MachineSetTab where id =(select mrp_mwt_machine from mrp_worktaskmaintab where mrp_mwt_workno = a.mrp_lwt_workno)) ELSE( select mrp_lwt_kaoxiang1 from mrp_WorkTaskListTab where mrp_lwt_workno = a.mrp_lwt_workno and mrp_lwt_workordername=a.mrp_lwt_workordername and mrp_lwt_ProductId=a.mrp_lwt_ProductId and mrp_lwt_id=a.mrp_lwt_id )END )) as'jtBillNo',
|
|
(select (CASE mrp_lwt_workordername WHEN '硫化' THEN (select jtname from Mps_MachineSetTab where id =(select mrp_mwt_machine from mrp_worktaskmaintab where mrp_mwt_workno = a.mrp_lwt_workno)) ELSE( select jtname from Mps_MachineSetTab where jtBillNo =(select mrp_lwt_kaoxiang1 from mrp_WorkTaskListTab where mrp_lwt_workno = a.mrp_lwt_workno and mrp_lwt_workordername=a.mrp_lwt_workordername and mrp_lwt_ProductId=a.mrp_lwt_ProductId and mrp_lwt_id=a.mrp_lwt_id ))END )) as'jtname',
|
|
SyncFlag,
|
|
(select mrp_mwt_comid from mrp_worktaskmaintab where mrp_mwt_workno = mrp_lwt_workno)as 'comid',
|
|
(select mrp_mwt_finish from mrp_worktaskmaintab where mrp_mwt_workno = mrp_lwt_workno)as 'finish'
|
|
--,mrp_mwt_Start
|
|
from(
|
|
select
|
|
*, DATEDIFF(minute, a.mrp_lwt_starttime, a.mrp_lwt_endtime) / 60 as betweenTime
|
|
,case when isnull(mrp_lwt_glgx, '') = '' then b.mes_list_glgx else mrp_lwt_glgx end as glgx
|
|
from mrp_WorkTaskListTab a with(nolock)
|
|
left join ( select mrp_mwt_Start,mrp_mwt_workno from mrp_worktaskmaintab ) ttt on ttt.mrp_mwt_workno=a.mrp_lwt_workno
|
|
left join(
|
|
select mes_list_no, mes_List_Name , mes_list_glgx from mes_fl_list with(nolock)
|
|
where isnull(sign,0)= 0
|
|
) b on b.mes_list_no = a.mrp_lwt_prolistno
|
|
left join(
|
|
select a.workno, a.taskid, MIN(optime) stdt, max(opendtime) enddt
|
|
from mrp_worktaskoptimetab a
|
|
group by a.workno, a.taskid
|
|
) aa on a.mrp_lwt_workno = aa.workno and a.mrp_lwt_id = aa.taskid
|
|
where 1 = 1 and mrp_mwt_Start=1
|
|
) a where 1 = 1 and (mrp_lwt_workordername = '硫化' or mrp_lwt_workordername = '二段硫化') and ISNULL(SyncFlag,0)<>1";
|
|
|
|
|
|
try
|
|
{
|
|
|
|
DataTable dt = SqlHelper.ExecuteDataTable(sqlValue);
|
|
|
|
|
|
dt.Columns.Remove("SyncFlag");
|
|
string url = "http://110.185.210.70:8881/business/receive/followWorkOrder";
|
|
for (int i = 0; i < dt.Rows.Count; i++)
|
|
{
|
|
if (string.IsNullOrWhiteSpace(dt.Rows[i]["jtBillNo"]+"")) continue;
|
|
|
|
string jsonObj = JsonUtil.ToJsonObject(dt.Rows[i]);
|
|
string deljson = jsonObj.Substring(1, jsonObj.Length - 2);
|
|
ResponseMode mode = NewEmp.PostMethodToObj(url, deljson);
|
|
|
|
if (mode!=null&&0 == mode.ret)
|
|
{
|
|
//有完工时间的行才会改变同步状态
|
|
if ("1".Equals(dt.Rows[i]["comid"] + "") || "1".Equals(dt.Rows[i]["finish"] + "") || !string.IsNullOrWhiteSpace(dt.Rows[i]["enddt"] + ""))
|
|
{
|
|
sqlValue = string.Format("update mrp_WorkTaskListTab set SyncFlag = 1 where mrp_lwt_workno='{0}' and mrp_lwt_workordername='{1}' and mrp_lwt_id='{2}'", dt.Rows[i]["mrp_lwt_workno"], dt.Rows[i]["mrp_lwt_workordername"], dt.Rows[i]["mrp_lwt_id"]);
|
|
SqlHelper.ExecuteNonQuery(sqlValue);
|
|
}
|
|
string updareabak = DateTime.Now + string.Format(" 工单号{0}，工序{1} 信息同步成功.\r\n", dt.Rows[i]["mrp_lwt_workno"], dt.Rows[i]["mrp_lwt_workordername"]);
|
|
RefreshLogUIThread(updareabak);
|
|
}
|
|
else
|
|
{
|
|
string errorMsg = mode != null ? mode.msg : "未知原因.";
|
|
RefreshLogUIThread(DateTime.Now + string.Format("工单明细信息 信息读取失败,错误原因:{0}.\r\n", errorMsg));
|
|
}
|
|
}
|
|
|
|
////删除或者取消下发的工单信息。 SyncFlag标识 0还未同步 1正在同步 2同步成功
|
|
//RefreshLogUIThread("正在同步已删除和取消下发工单信息\r\n");
|
|
//string sqlValue2 = "update DeleteWorkOrderTable set SyncFlag='1' where ISNULL(SyncFlag,0)=0";//
|
|
//SqlHelper.ExecuteNonQuery(sqlValue2);
|
|
//sqlValue2 = "select * from DeleteWorkOrderTable where SyncFlag='1'";
|
|
//DataTable deleteDt = SqlHelper.ExecuteDataTable(sqlValue2);
|
|
|
|
|
|
//deleteDt.Columns.Remove("SyncFlag");
|
|
////推送程序中删除或取消下发的工单数据
|
|
//for (int i = 0; i < deleteDt.Rows.Count; i++)
|
|
//{
|
|
// string jsonObj = JsonUtil.ToJsonObject(deleteDt.Rows[i]);
|
|
// string deljson = jsonObj.Substring(1, jsonObj.Length - 2);
|
|
// deljson = deljson.Replace("\"true\"", "true");
|
|
// //url = "http://110.185.210.70:8881/business/receive/followWorkOrder";
|
|
// ResponseMode mode = NewEmp.PostMethodToObj(url, deljson);
|
|
// if (mode != null && mode.msg.Equals("success"))
|
|
// {
|
|
// //修改标识
|
|
// //sqlValue2 = string.Format("update DeleteWorkOrderTable set SyncFlag='2' where SyncFlag='1' and mrp_lwt_workno='{0}' and mrp_lwt_workordername='{1}'", deleteDt.Rows[i]["mrp_lwt_workno"], deleteDt.Rows[i]["mrp_lwt_workordername"]);
|
|
// sqlValue2 = string.Format("update DeleteWorkOrderTable set SyncFlag='2' where SyncFlag='1' and mrp_lwt_workno='{0}' and mrp_lwt_workordername='{1}' and mrp_lwt_id='{2}'", deleteDt.Rows[i]["mrp_lwt_workno"], deleteDt.Rows[i]["mrp_lwt_workordername"], deleteDt.Rows[i]["mrp_lwt_id"]);
|
|
|
|
// SqlHelper.ExecuteNonQuery(sqlValue2);
|
|
// }
|
|
// else if(string.IsNullOrWhiteSpace(deleteDt.Rows[i]["jtBillNo"] +"")&& !string.IsNullOrWhiteSpace(deleteDt.Rows[i]["mrp_lwt_id"] + ""))
|
|
// {
|
|
// //如果机器编号未空，则直接算同步成功，不会再次同步
|
|
// sqlValue2 = string.Format("update DeleteWorkOrderTable set SyncFlag='2' where mrp_lwt_id='{0}'", deleteDt.Rows[i]["mrp_lwt_id"]);
|
|
// SqlHelper.ExecuteNonQuery(sqlValue2);
|
|
// }
|
|
//}
|
|
//清空删除信息表
|
|
//sqlValue2 = "delete DeleteWorkOrderTable where SyncFlag='1'";
|
|
|
|
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
RefreshLogUIThread(DateTime.Now + string.Format("工单明细信息 信息读取失败.\r\n" + " 原因:" + ex.Message + Environment.NewLine));
|
|
}
|
|
|
|
|
|
|
|
RefreshLogUIThread(DateTime.Now + "工单明细信息 同步完成.\r\n");
|
|
RefreshLogUIThread("--------------------分割线------------------------\r\n");
|
|
}
|
|
|
|
/// <summary>
|
|
/// 后台线程刷新数据
|
|
/// </summary>
|
|
/// <param name="msg"></param>
|
|
public void RefreshLogUIThread(string msg)
|
|
{
|
|
if (this.IsHandleCreated)
|
|
{
|
|
Invoke((EventHandler)delegate
|
|
{
|
|
txtLog.Text += msg;
|
|
txtLog.Select(txtLog.TextLength, 0);
|
|
txtLog.ScrollToCaret();
|
|
});
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 后台线程清理数据
|
|
/// </summary>
|
|
/// <param name="msg"></param>
|
|
public void ReClearLogUIThread()
|
|
{
|
|
if (this.IsHandleCreated)
|
|
{
|
|
Invoke((EventHandler)delegate
|
|
{
|
|
txtLog.Clear();
|
|
});
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 主线程刷新数据
|
|
/// </summary>
|
|
/// <param name="msg"></param>
|
|
public void RefreshLog(string msg)
|
|
{
|
|
txtLog.Text += msg;
|
|
txtLog.Select(txtLog.TextLength, 0);
|
|
txtLog.ScrollToCaret();
|
|
}
|
|
#region 连接服务器
|
|
/// <summary>
|
|
/// <para>说明：连接服务器</para>
|
|
/// <para>创建人：龚宇超</para>
|
|
/// <para>创建日期：2017-08-09 </para>
|
|
/// <para>修改人：</para>
|
|
/// <para>修改日期：</para>
|
|
/// <para>修改备注：</para>
|
|
/// <para>版本：1.0</para>
|
|
/// </summary>
|
|
/// <param name="isSave">if set to <c>true</c> [is save].</param>
|
|
public bool ConnectServer(bool isSave = false)
|
|
{
|
|
string serverName = this.txtSeverId.Text.Trim();//地址
|
|
string dbName = this.txtDataBase.Text.Trim();//数据库名
|
|
string user = this.txtName.Text.Trim();//用户名
|
|
string password = this.txtPassword.Text.Trim();//密码
|
|
|
|
if (string.IsNullOrWhiteSpace(serverName))
|
|
{
|
|
MessageUtil.Show(ResourceKeys.ServerNameIsNull);
|
|
return false;
|
|
}
|
|
|
|
if (string.IsNullOrWhiteSpace(dbName))
|
|
{
|
|
MessageUtil.Show(ResourceKeys.ServerDBIsNull);
|
|
return false;
|
|
}
|
|
|
|
if (string.IsNullOrWhiteSpace(user))
|
|
{
|
|
MessageUtil.Show("请重新输入用户名");
|
|
return false;
|
|
}
|
|
|
|
|
|
// 测试数据库连接
|
|
try
|
|
{
|
|
if (ConnectingToDatabase())
|
|
{
|
|
if (isSave)
|
|
{
|
|
|
|
}
|
|
else
|
|
{
|
|
IniUtil.IniWriteValue(company, "serverName", serverName);
|
|
IniUtil.IniWriteValue(company, "dbName", dbName);
|
|
IniUtil.IniWriteValue(company, "user", user);
|
|
IniUtil.IniWriteValue(company, "password", password);
|
|
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
MessageUtil.Show(ResourceKeys.ConnectFault);
|
|
return false;
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
MessageUtil.Show(ResourceKeys.ConnectFault);
|
|
|
|
}
|
|
return true;
|
|
}
|
|
|
|
/// <summary>
|
|
/// <para>说明：创建数据库连接</para>
|
|
/// <para>创建人：龚宇超</para>
|
|
/// <para>创建日期：2017-08-07 </para>
|
|
/// <para>修改人：</para>
|
|
/// <para>修改日期：</para>
|
|
/// <para>修改备注：</para>
|
|
/// <para>版本：1.0</para>
|
|
/// </summary>
|
|
/// <returns><c>true</c> if XXXX, <c>false</c> otherwise.</returns>
|
|
public bool ConnectingToDatabase()
|
|
{
|
|
string connStr = GetConnection();
|
|
if (SqlHelper._connection != null)
|
|
{
|
|
try
|
|
{
|
|
SqlHelper._connection.Close();
|
|
SqlHelper._connection.Dispose();
|
|
}
|
|
catch (Exception)
|
|
{
|
|
}
|
|
SqlHelper._connection = null;
|
|
}
|
|
try
|
|
{
|
|
SqlHelper._connection = new SqlConnection(connStr);
|
|
SqlHelper._connection.Open();
|
|
return true;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
// LogHelper.Instance.WriteLog(ex.Message);
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取连接服务器的字符串
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public string GetConnection()
|
|
{
|
|
return string.Format("Server={0};Database={1};Persist Security Info=True;User ID={2};Password={3};Connection Timeout=5;MultipleActiveResultSets=true", txtSeverId.Text.ToString(), txtDataBase.Text.ToString(), txtName.Text.ToString(), txtPassword.Text.ToString());
|
|
}
|
|
#endregion
|
|
|
|
|
|
}
|
|
}
|