HEGII.ss.mes.wcf/DK.Service/CMNModuleService/PLCWorkLogic..cs

/*******************************************************************************
 * Copyright(c) 2014 DongkeSoft All rights reserved. / Confidential
 * 类的信息：
 *      1.程序名称：PLCModuleLogic.cs
 *      2.功能描述：发送信息到智能设备。
 * 编辑履历：
 *      作者            日期                版本            修改内容
 *      陈晓野          2018/10/18          1.00            新建
 *******************************************************************************/

using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Net.Sockets;
using System.Text;

using Curtain.Core;
using Curtain.DataAccess;
using Curtain.Framework.Json;
using Curtain.Net.Sockets.PLC;
using Curtain.Net.Sockets.PLC.Model.Siemens;
using Dongke.IBOSS.PRD.Basics.BaseResources;
using Dongke.IBOSS.PRD.Basics.DataAccess;
using Dongke.IBOSS.PRD.Service.DataModels;
using Dongke.IBOSS.PRD.WCF.DataModels;

using Microsoft.Win32;

using Newtonsoft.Json.Linq;

namespace Dongke.IBOSS.PRD.Service.CMNModuleService
{
	/// <summary>
	/// PLC相关处理
	/// </summary>
	public class PLCModuleLogic
	{
		#region 恒洁三水三车间工位对应PLC操作
		/// <summary>
		/// 恒洁三水三车间工位对应PLC操作 xuwei modify 2020-06-29
		/// </summary>
		/// <param name="sUserInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity DoPLCWorkByUser_HEGII_S3(SUserInfo sUserInfo, string barcode,
			int procedureid, int workStationType = 0, decimal weight = 0)
		{
			using (IDataAccess conn = DataAccess.Create())
			{
				//调用PLC的参数集合
				Hashtable plcPara = new Hashtable();

				try
				{
					//按当前登录用户在工位表中的当前工号查找工位类型
					workStationType = getWorkStationType(conn, sUserInfo.UserCode);

					//成检交接3211
					if (workStationType == 3211)
					{
						//读取产品型号
						object goodsModel = conn.ExecuteScalar(@"
                            SELECT
	                            g.SEATCOVERCODE
                            FROM
	                            TP_PM_GROUTINGDAILYDETAIL p 
	                            LEFT JOIN TP_MST_GOODS g ON g.GOODSID = p.GOODSID
                            WHERE
                                p.VALUEFLAG = '1'
	                            AND p.BARCODE = @BARCODE@
                            ",
							new CDAParameter("BARCODE", barcode)
						);

						plcPara.Add("usercode", sUserInfo.UserCode);
						plcPara.Add("barcode", barcode);
						plcPara.Add("procedureid", procedureid);
						plcPara.Add("goodsmodel", goodsModel);
						plcPara.Add("finishflag", 1);
						return plcWrite(conn, sUserInfo.UserCode, workStationType, plcPara);

					}

					// 成检二检3212
					// 读取plc重量 add by fubin 2020-7-20
					if (workStationType == 3212)
					{
						if (weight > 0)
						{
							try
							{
								conn.ExecuteNonQuery(@"
								INSERT INTO tp_pm_goodsweighing
								(barcode
								,groutingdailydetailid
								,smartdevicepointcode
								,procedureid
								,goodsweight
								,accountid
								,createuserid)
								SELECT @barcode@
										,gd.groutingdailydetailid
										,'3_2_2'
										,@procedureid@
										,@goodsweight@
										,@accountid@
										,@userid@
									FROM tp_pm_groutingdailydetail gd
									WHERE gd.barcode = @barcode@",
									new CDAParameter("barcode", barcode),
									new CDAParameter("procedureid", procedureid),
									new CDAParameter("goodsweight", weight),
									new CDAParameter("accountid", sUserInfo.AccountID),
									new CDAParameter("userid", sUserInfo.UserID)
								);
							}
							catch (Exception)
							{
								return new ServiceResultEntity()
								{
									Status = Constant.ServiceResultStatus.Other,
									Message = "重量写入失败！"
								};
							}

							plcPara.Add("finishflag", 1);
							return plcWrite(conn, sUserInfo.UserCode, workStationType, plcPara);
						}
						return new ServiceResultEntity() { Status = Constant.ServiceResultStatus.Success };
					}

					// 3#上水3320
					if (workStationType == 3320)
					{
						//读取产品型号
						object goodsModel = conn.ExecuteScalar(@"
                            SELECT
	                            g.SEATCOVERCODE
                            FROM
	                            TP_PM_GROUTINGDAILYDETAIL p 
	                            LEFT JOIN TP_MST_GOODS g ON g.GOODSID = p.GOODSID
                            WHERE
                                p.VALUEFLAG = '1'
	                            AND p.BARCODE = @BARCODE@
                            ",
							new CDAParameter("BARCODE", barcode)
						);

                        if (goodsModel.ToInt32() == 0)
                        {
							plcPara.Add("goodsmodel", 0);
							plcPara.Add("finishflag", 1);
							plcPara.Add("error", 1);
						}
                        else
                        {
							plcPara.Add("goodsmodel", goodsModel);
							plcPara.Add("finishflag", 1);
							plcPara.Add("error", 0);
						}

						return plcWrite(conn, sUserInfo.UserCode, workStationType, plcPara);

					}
					return new ServiceResultEntity() { Status = Constant.ServiceResultStatus.Other, Message = "当前工号无工位信息" };
				}
				catch (Exception ex)
				{
					Curtain.Log.Logger.Error(ex);
					string plcParaStr = "";
					foreach (string key in plcPara.Keys) plcParaStr += " " + key + ":" + plcPara[key].ToString() + " ";
					Curtain.Log.Logger.Debug("PLC写入失败！" + plcParaStr);
					return new ServiceResultEntity()
					{
						Status = Constant.ServiceResultStatus.Other,
						Message = "PLC写入失败！" + plcParaStr
					};
				}
				finally
				{
					conn?.Close();
				}
			}
		}

		/// <summary>
		/// 恒洁三水三车间成检二检获取PLC重量 fubin add 2020-07-20
		/// </summary>
		/// <param name="sUserInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity ReadPLCWeightByUser_HEGII_S3(SUserInfo sUserInfo)
		{
			using (IDataAccess conn = DataAccess.Create())
			{
				//调用PLC的参数集合
				Hashtable plcPara = new Hashtable();

				try
				{
					//按当前登录用户在工位表中的当前工号查找工位类型
					int workStationType = getWorkStationType(conn, sUserInfo.UserCode);

					// 成检二检3212
					// 读取plc重量 add by fubin 2020-7-20
					if (workStationType == 3212)
					{
						return plcRead(conn, sUserInfo.UserCode, workStationType);
					}

					return new ServiceResultEntity() { Status = Constant.ServiceResultStatus.Other, Result = 0 };

				}
				catch (Exception ex)
				{
					Curtain.Log.Logger.Error(ex);
					return new ServiceResultEntity() { Status = Constant.ServiceResultStatus.Other, Result = 0 };
				}
				finally
				{
					conn?.Close();
				}
			}
		}

		/// <summary>
		/// 获取工位类型ID xuwei add 2020-06-29
		/// </summary>
		/// <param name="conn"></param>
		/// <param name="userCode"></param>
		/// <returns></returns>
		private static int getWorkStationType(IDataAccess conn, string userCode)
		{
			return Convert.ToInt32(conn.ExecuteScalar(@"
                SELECT
	                t.WORKSTATIONTYPEID 
                FROM
	                TP_MST_WORKSTATION w
	                LEFT JOIN TP_SYS_WORKSTATIONTYPE t ON w.WORKSTATIONTYPEID = t.WORKSTATIONTYPEID 
                WHERE
	                w.USERCODE = @USERCODE@
                ",
				new CDAParameter("USERCODE", userCode)
			));
		}

		/// <summary>
		/// 写PLC xuwei add 2020-06-29
		/// </summary>
		/// <param name="conn"></param>
		/// <param name="userCode"></param>
		/// <param name="workStationType"></param>
		/// <param name="plcPara"></param>
		/// <returns></returns>
		private static ServiceResultEntity plcWrite(IDataAccess conn, string userCode, int workStationType, Hashtable plcPara)
		{
			//读取工位配置信息
			DataTable dataTable = conn.ExecuteDatatable(@"
                SELECT
	                * 
                FROM
	                TP_MST_WORKSTATION t 
                WHERE
	                t.WORKSTATIONTYPEID = @WORKSTATIONTYPE@
	                AND USERCODE =@USERCODE@
                ",
				new CDAParameter("WORKSTATIONTYPE", workStationType),
				new CDAParameter("USERCODE", userCode)
			 );
			if (dataTable == null || dataTable.Rows.Count == 0)
			{
				return new ServiceResultEntity() { Status = Constant.ServiceResultStatus.Other, Message = "当前工号无工位信息" };
			}
			string ip = dataTable.Rows[0]["PLCIP"] + "";
			int port = Convert.ToInt32(dataTable.Rows[0]["PLCPORT"]);
			JArray plcObj = JArray.Parse(dataTable.Rows[0]["PLCOBJECT"].ToString());

			//写入PLC
			using (SocketClient<SiemensS7_1200Model> plc = new SocketClient<SiemensS7_1200Model>())
			{
				//测试静态数据 测试成功
				//plc.Connect(ip, port);
				//plc.Write<string>("D", "102.2", "2020070101");
				//plc.Write<short>("D", "102.14", Convert.ToInt16(10));

				//手动写
				//plc.Connect(ip, port);
				//plc.Write<string>("D", "102.2", plcPara["barcode"].ToString());
				//plc.Write<short>("D", "102.14", Convert.ToInt16(plcPara["goodsmodel"]));

				//自动按配置写
				plc.Connect(ip, port);
				for (int i = 0; i < plcObj.Count; i++)
				{
					if (plcObj[i]["type"].ToString().ToLower() == "string")
						plc.Write<string>(plcObj[i]["code"].ToString(), plcObj[i]["number"].ToString(), plcPara[plcObj[i]["name"].ToString()].ToString());
					else if (plcObj[i]["type"].ToString().ToLower() == "int")
						plc.Write<short>(plcObj[i]["code"].ToString(), plcObj[i]["number"].ToString(), Convert.ToInt16(plcPara[plcObj[i]["name"].ToString()]));
				}

			}

			//写入操作成功日志
			string plcParaStr = "";
			foreach (string key in plcPara.Keys) plcParaStr += " " + key + ":" + plcPara[key].ToString() + " ";
			Curtain.Log.Logger.Debug("PLC写入成功！" + plcParaStr);

			//PLC操作成功
			return new ServiceResultEntity()
			{
				Status = Constant.ServiceResultStatus.Success,
				Message = "" //一定不可以有值，为空时才是提交成功
			};

		}

		/// <summary>
		/// 读取PLC
		/// </summary>
		/// <param name="conn"></param>
		/// <param name="workStationID"></param>
		/// <returns></returns>
		private static ServiceResultEntity plcRead(IDataAccess conn, string userCode, int workStationType)
		{
			try
			{
				//读取工位配置信息
				DataTable dataTable = conn.ExecuteDatatable(@"
					SELECT
						* 
					FROM
						TP_MST_WORKSTATION t 
					WHERE
						t.WORKSTATIONTYPEID = @WORKSTATIONTYPE@
						AND USERCODE =@USERCODE@
					",
					new CDAParameter("WORKSTATIONTYPE", workStationType),
					new CDAParameter("USERCODE", userCode)
				 );

				if (dataTable == null || dataTable.Rows.Count == 0)
				{
					return new ServiceResultEntity() { Status = Constant.ServiceResultStatus.Other, Message = "当前工号无工位信息" };
				}

				string ip = dataTable.Rows[0]["PLCIP"] + "";
				int port = Convert.ToInt32(dataTable.Rows[0]["PLCPORT"]);
				JArray plcObj = JArray.Parse(dataTable.Rows[0]["PLCOBJECTREAD"].ToString());

				// 读取PLC
				using (SocketClient<SiemensS7_1200Model> plc = new SocketClient<SiemensS7_1200Model>())
				{
					//自动按配置写
					plc.Connect(ip, port);
					for (int i = 0; i < plcObj.Count; i++)
					{
						if (plcObj[i]["type"].ToString().ToLower() == "float")
						{
							PLCResult<float> result = plc.Read<float>(plcObj[i]["code"].ToString(), plcObj[i]["number"].ToString());
							plcObj[i]["weight"] = result.Data;
						}
					}
				}

				//写入操作成功日志
				Curtain.Log.Logger.Debug("PLC读取成功！" + plcObj.ToJson());

				//PLC操作成功
				return new ServiceResultEntity()
				{
					Status = Constant.ServiceResultStatus.Success,
					Message = "", //一定不可以有值，为空时才是提交成功
					Result = plcObj
				};
			}
			catch (Exception ex)
			{
				throw ex;
			}
		}
		#endregion

		/// <summary>
		/// 写PLC，通过工位类型
		/// </summary>
		/// <param name="conn"></param>
		/// <param name="workStationType"></param>
		/// <param name="plcPara"></param>
		/// <returns></returns>
		public static ServiceResultEntity PlcWriteByWorkStationType(int workStationType, Hashtable plcPara)
		{
			using (IDataAccess conn = DataAccess.Create())
			{
				//读取工位配置信息
				DataTable dataTable = conn.ExecuteDatatable(@"
					SELECT
						* 
					FROM
						TP_MST_WORKSTATION t 
					WHERE
						t.WORKSTATIONTYPEID = @WORKSTATIONTYPE@
					",
					new CDAParameter("WORKSTATIONTYPE", workStationType)
				 );

				if (dataTable == null || dataTable.Rows.Count == 0)
				{
					return new ServiceResultEntity() { Status = Constant.ServiceResultStatus.Other, Message = "无当前工位信息" };
				}

				string ip = dataTable.Rows[0]["PLCIP"] + "";
				int port = Convert.ToInt32(dataTable.Rows[0]["PLCPORT"]);
				JArray plcObj = JArray.Parse(dataTable.Rows[0]["PLCOBJECT"].ToString());

				//写入PLC
				using (SocketClient<SiemensS7_1200Model> plc = new SocketClient<SiemensS7_1200Model>())
				{
					//自动按配置写
					plc.Connect(ip, port);
					for (int i = 0; i < plcObj.Count; i++)
					{
						if (plcObj[i]["type"].ToString().ToLower() == "string")
							plc.Write<string>(plcObj[i]["code"].ToString(), plcObj[i]["number"].ToString(), plcPara[plcObj[i]["name"].ToString()].ToString());
						else if (plcObj[i]["type"].ToString().ToLower() == "int")
							plc.Write<short>(plcObj[i]["code"].ToString(), plcObj[i]["number"].ToString(), Convert.ToInt16(plcPara[plcObj[i]["name"].ToString()]));
						else if (plcObj[i]["type"].ToString().ToLower() == "bool")
							plc.Write<bool>(plcObj[i]["code"].ToString(), plcObj[i]["number"].ToString(), Convert.ToBoolean(plcPara[plcObj[i]["name"].ToString()]));
					}

				}

				//写入操作成功日志
				string plcParaStr = "";
				foreach (string key in plcPara.Keys) plcParaStr += " " + key + ":" + plcPara[key].ToString() + " ";
				Curtain.Log.Logger.Debug("PLC写入成功！" + plcParaStr);

				//PLC操作成功
				return new ServiceResultEntity()
				{
					Status = Constant.ServiceResultStatus.Success,
					Message = "" //一定不可以有值，为空时才是提交成功
				};
			}
		}
	}
}