|
|
using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.Linq;
|
|
|
using System.Text;
|
|
|
using Mesnac.Action.Base;
|
|
|
using Mesnac.Communication;
|
|
|
using Mesnac.Codd.Session;
|
|
|
using System.Data;
|
|
|
using Mesnac.Action.Feeding.BasicInfo;
|
|
|
using Mesnac.Basic;
|
|
|
using System.Net.Sockets;
|
|
|
|
|
|
namespace Mesnac.Action.Feeding.Socket
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// Socket接收消息处理
|
|
|
/// </summary>
|
|
|
public class StartReciveProcess : FeedingAction, IAction
|
|
|
{
|
|
|
#region 事件定义
|
|
|
|
|
|
/// <summary>
|
|
|
/// 刷新计划事件
|
|
|
/// </summary>
|
|
|
public static event EventHandler OnRefreshPlan;
|
|
|
/// <summary>
|
|
|
/// 刷新计划执行类型：单个、连续 事件
|
|
|
/// </summary>
|
|
|
public static event EventHandler OnRefreshPlanExecuteType;
|
|
|
/// <summary>
|
|
|
/// 换班后，刷新主机手信息事件
|
|
|
/// </summary>
|
|
|
public static event EventHandler OnRefreshWorkerInfo;
|
|
|
/// <summary>
|
|
|
/// 刷新有新新网络计划通知
|
|
|
/// </summary>
|
|
|
public static event EventHandler OnRefreshNewNetNote;
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
/// <summary>
|
|
|
/// 业务入口
|
|
|
/// </summary>
|
|
|
/// <param name="runtime">参数</param>
|
|
|
public void Run(RuntimeParameter runtime)
|
|
|
{
|
|
|
base.RunIni(runtime);
|
|
|
TcpService.Instance.ProcessAcceptComplete += new EventHandler<SocketAsyncEventArgs>(Instance_ProcessAcceptComplete); //客户端连接完成事件
|
|
|
TcpService.Instance.ReceiveMsgHandler += new SocketListener.ReceiveMsgHandler(Instance_ReceiveMsgHandler); //接收到客户端消息的事件
|
|
|
}
|
|
|
|
|
|
#region 业务处理
|
|
|
|
|
|
#region 客户端连接时，把当前计划列表发送给客户端
|
|
|
/// <summary>
|
|
|
/// 客户端连接时，把当前计划列表发送给客户端
|
|
|
/// </summary>
|
|
|
/// <param name="sender">客户端IP</param>
|
|
|
/// <param name="e"></param>
|
|
|
private void Instance_ProcessAcceptComplete(object sender, SocketAsyncEventArgs e)
|
|
|
{
|
|
|
if (PlanCommon.PlanLog != null)
|
|
|
{
|
|
|
PlanCommon.SendInit(base.CurrEquipCode, PlanCommon.PlanLog.LastSelectDate, PlanCommon.PlanLog.LastSelectShiftID, PlanCommon.PlanLog.LastClassID, base.GetConfigValue("LastUserID", "0"));
|
|
|
//1、发送计划列表
|
|
|
//PlanCommon.SendNetPlanMsg(base.CurrEquipCode, PlanCommon.PlanLog.LastSelectDate, PlanCommon.PlanLog.LastSelectShiftID);
|
|
|
//2、发送当前计划号
|
|
|
//string netMsg = "{0}:{1}/";
|
|
|
//netMsg = String.Format(netMsg, Global.ProtocalHeader.ReceivePlanIdIpNumber, PlanCommon.PlanLog.LastPlanID);
|
|
|
//Mesnac.Communication.TcpService.Instance.NetSendMsg(netMsg);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
string sbNetMsg = Global.ProtocalHeader.ReceivePlanIpNumber + ":/";
|
|
|
Mesnac.Communication.TcpService.Instance.NetSendMsg(sbNetMsg.ToString()); //发送网络消息
|
|
|
ICSharpCode.Core.LoggingService.Debug("没有计划日志!");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 接收消息时的事件处理程序
|
|
|
/// <summary>
|
|
|
/// 接收消息时的事件处理程序
|
|
|
/// </summary>
|
|
|
/// <param name="uid">客户端IP</param>
|
|
|
/// <param name="info">接收到的消息</param>
|
|
|
private void Instance_ReceiveMsgHandler(string uid, string info)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
|
|
|
if (!String.IsNullOrEmpty(info) && info.Length > 4)
|
|
|
{
|
|
|
string[] infoArrary = info.Split('/');
|
|
|
for (int i = 0; i < infoArrary.Length; i++)
|
|
|
{
|
|
|
if (string.IsNullOrEmpty(infoArrary[i]))
|
|
|
continue;
|
|
|
info = infoArrary[i]+"/";
|
|
|
string protocal = info.Substring(0, 4); //协议头
|
|
|
//System.Threading.Thread.Sleep(500);
|
|
|
string msg = info.Substring(4).Replace(":", string.Empty); //消息内容
|
|
|
switch (protocal)
|
|
|
{
|
|
|
case Global.ProtocalHeader.SendPlanIpNumber:
|
|
|
//客户端添加计划后，通知上辅机进行刷新。
|
|
|
this.ExecSendPlan(msg);
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SelectPlanIpNumber:
|
|
|
//客户端查询对应日期、班次的本地计划信息
|
|
|
this.ExecSelectPlan(msg);
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendExcPlanIpNumber:
|
|
|
//客户端设置配方运行方式
|
|
|
this.ExecSendExcPlan(msg);
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendStopPlanIpNumber:
|
|
|
//客户端终止计划
|
|
|
this.ExecSendStopPlan();
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendResetInNumber:
|
|
|
//客户端配方重传
|
|
|
this.ExecSendReset();
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendWorkerBarcode:
|
|
|
//换班 胶料秤客户端发送的操作主手的员工编号
|
|
|
PlanCommon.IsShift = true;//交接班标记
|
|
|
this.ExecSendWorkerBarcode(msg);
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendMaterBarcode:
|
|
|
//扫描的架子条码
|
|
|
this.ExecSendMaterBarcode(msg);
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendAddPlanIpNumbar:
|
|
|
//客户端新增计划
|
|
|
this.ExecSendAddPlan(msg);
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendNetNewPlan:
|
|
|
//网络计划下达时，通知中控室机台有新计划下达
|
|
|
this.ExecSendNetNewPlan();
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendWareInfo:
|
|
|
//气力输送发送过来的日罐的料位信息
|
|
|
this.ExecSendWareInfo(msg);
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendBarRight:
|
|
|
// 胶料秤客户端扫描条码错误时发送，中控室上位机向plc设置报警位 置胶料秤报警灯
|
|
|
// DownLoadSetRubLamp(1);
|
|
|
this.ExecSendBarRight();
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendRepair:
|
|
|
//停机维修，设置维修标志
|
|
|
this.ExecSendRepair();
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendNewMessage:
|
|
|
//显示网络下发来的通知
|
|
|
this.ExecSendNewMessage(msg);
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendModifyPlanNum:
|
|
|
//客户端修改正在执行的计划车数，并下传到PLC
|
|
|
this.ExecSendModifyPlanNum(msg);
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendChanYong:
|
|
|
//把掺用物料添加到配方中,并下传至PLC
|
|
|
this.ExecSendChanYong(msg);
|
|
|
break;
|
|
|
case Global.ProtocalHeader.SendStopChanYong:
|
|
|
this.ExecSendStopChanYong();
|
|
|
break;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Debug(ex.Message);
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 业务处理辅助方法
|
|
|
|
|
|
#region 客户端添加计划后，通知上辅机进行刷新
|
|
|
|
|
|
/// <summary>
|
|
|
/// 客户端添加计划后，通知上辅机进行刷新
|
|
|
/// </summary>
|
|
|
/// <param name="msg">客户端发送过来的计划列表，格式：date|shift|Name+code+set+finish+planId~Name+code+set+finish+planId........~</param>
|
|
|
private void ExecSendPlan(string msg)
|
|
|
{
|
|
|
this.SynchroPlanList(msg);
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 客户端查询对应日期、班次的本地计划信息
|
|
|
/// <summary>
|
|
|
/// 客户端查询对应日期、班次的本地计划信息
|
|
|
/// </summary>
|
|
|
/// <param name="msg">客户端发送的消息，格式：SelectPlanIpNumber + ':' + G_PlanDate + '|' + G_ShiftID + '|' + G_ClassID + '|' + G_OperID + '/'</param>
|
|
|
private void ExecSelectPlan(string msg)
|
|
|
{
|
|
|
if (!String.IsNullOrEmpty(msg))
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
if (msg.Substring(msg.Length - 1) != "/")
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Warn("客户端发送的消息格式不正确，正确格式：SelectPlanIpNumber + ':' + G_PlanDate + '|' + G_ShiftID + '|' + G_ClassID + '|' + G_OperID + '/'");
|
|
|
return;
|
|
|
}
|
|
|
string[] strs = msg.Replace("/", string.Empty).Split(new char[] { '|' });
|
|
|
if (strs == null || strs.Length != 2)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Warn("客户端发送的消息式不正确，正确格式：SelectPlanIpNumber + ':' + G_PlanDate + '|' + G_ShiftID +'/'");
|
|
|
return;
|
|
|
}
|
|
|
DateTime planDate = Convert.ToDateTime(strs[0]);
|
|
|
int shiftID = Convert.ToInt32(strs[1]);
|
|
|
//int classID = Convert.ToInt32(strs[2]);
|
|
|
//int operID = Convert.ToInt32(strs[3]);
|
|
|
|
|
|
//发送计划列表
|
|
|
PlanCommon.SendNetPlanMsg(base.CurrEquipCode, planDate, shiftID, 0, base.GetConfigValue("LastUserID", "0"));
|
|
|
//交接班，保存当前班次信息
|
|
|
if (PlanCommon.IsShift)
|
|
|
{
|
|
|
PlanLog log = PlanCommon.PlanLog;
|
|
|
if (log == null)
|
|
|
{
|
|
|
log = new PlanLog();
|
|
|
}
|
|
|
log.LastSelectDate = planDate;
|
|
|
ICSharpCode.Core.LoggingService.Debug("辅值last日期：" + planDate);
|
|
|
log.LastSelectShiftID = shiftID;
|
|
|
//log.LastClassID = classID;
|
|
|
PlanCommon.PlanLog = log;
|
|
|
//刷新界面上的主机手信息
|
|
|
if (StartReciveProcess.OnRefreshWorkerInfo != null)
|
|
|
{
|
|
|
StartReciveProcess.OnRefreshWorkerInfo(null, System.EventArgs.Empty);
|
|
|
}
|
|
|
//刷新界面上的计划列表
|
|
|
if (StartReciveProcess.OnRefreshPlan != null)
|
|
|
{
|
|
|
StartReciveProcess.OnRefreshPlan(null, System.EventArgs.Empty);
|
|
|
}
|
|
|
PlanCommon.IsShift = false;
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error("Socket ExecSelectPlan 错误：" + ex.Message, ex);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region 客户端设置配方运行方式
|
|
|
/// <summary>
|
|
|
/// 客户端设置配方运行方式
|
|
|
/// </summary>
|
|
|
/// <param name="msg">格式：协议头:0/ 协议头:1/</param>
|
|
|
private void ExecSendExcPlan(string msg)
|
|
|
{
|
|
|
if (!String.IsNullOrEmpty(msg))
|
|
|
{
|
|
|
if (msg.Substring(msg.Length - 1) != "/")
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Warn("客户端发送的消息格式不正确，正确格式：SelectPlanIpNumber + ':' + G_PlanDate + '|' + G_ShiftID + '|' + G_ClassID + '|' + G_OperID + '/'");
|
|
|
return;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
int execPlanType = Convert.ToInt32(msg.Replace("/", String.Empty).Replace(":", string.Empty));
|
|
|
RunSchema.Instance.UpdateNodeValueToRunSchema("PlanExecuteType", execPlanType.ToString());
|
|
|
|
|
|
ProducingPlan.ExecutePlan execplan = new ProducingPlan.ExecutePlan();
|
|
|
execplan.PlanExecute(PlanCommon.ExecClass, PlanCommon.ExecShift, PlanCommon.ExecDate);
|
|
|
|
|
|
//刷新界面
|
|
|
if (StartReciveProcess.OnRefreshPlanExecuteType != null)
|
|
|
{
|
|
|
StartReciveProcess.OnRefreshPlanExecuteType(null, System.EventArgs.Empty);
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error("解析客户端设置计划运行方式失败：" + ex.Message, ex);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region 客户端终止计划
|
|
|
/// <summary>
|
|
|
/// 客户端终止计划
|
|
|
/// </summary>
|
|
|
private void ExecSendStopPlan()
|
|
|
{
|
|
|
new FeedingPlc.PausePlan().ExecPause();
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 客户端配方重传
|
|
|
/// <summary>
|
|
|
/// 客户端配方重传
|
|
|
/// </summary>
|
|
|
private void ExecSendReset()
|
|
|
{
|
|
|
string msg = String.Empty;
|
|
|
PlanLog planLog = PlanCommon.PlanLog;
|
|
|
if (planLog == null)
|
|
|
{
|
|
|
msg = "没有正在生产的计划，不能进行配方重传！";
|
|
|
ICSharpCode.Core.LoggingService.Info(msg);
|
|
|
return;
|
|
|
}
|
|
|
PlanStates planStates = PlanCommon.GetPlanState(planLog.LastPlanID);
|
|
|
if (planStates != PlanStates.Producting)
|
|
|
{
|
|
|
msg = "当前计划未处于生产状态，不能进行配方重传！";
|
|
|
ICSharpCode.Core.LoggingService.Info(msg);
|
|
|
return;
|
|
|
}
|
|
|
if (new PLCRecipe().RecipeReset() > 0)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Info("配方重传成功！");
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error("配方重传失败！");
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region 换班 胶料秤客户端发送的操作主手的员工编号
|
|
|
/// <summary>
|
|
|
/// 换班 胶料秤客户端发送的操作主手的员工编号
|
|
|
/// </summary>
|
|
|
/// <param name="msg">换班的主机手编号</param>
|
|
|
private void ExecSendWorkerBarcode(string msg)
|
|
|
{
|
|
|
if (!String.IsNullOrEmpty(msg))
|
|
|
{
|
|
|
if (msg.Substring(msg.Length - 1) != "/")
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Warn("客户端发送的消息格式不正确，正确格式：协议头 + ':' + HRCode + '/'");
|
|
|
return;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
string hrCode = msg.Replace("/", String.Empty); //获取主机手编号
|
|
|
string hrName = String.Empty;
|
|
|
if (base.NetType == NetTypes.Net)
|
|
|
{
|
|
|
//如果是网络版获取主机手名称
|
|
|
hrName = this.GetUserNameByHRCode(hrCode);
|
|
|
}
|
|
|
//更新配置文件（RunSchema.xml）中当前主机手编号和主机手名称
|
|
|
RunSchema.Instance.UpdateNodeValueToRunSchema("LastUserID", hrCode);
|
|
|
RunSchema.Instance.UpdateNodeValueToRunSchema("LastUserName", hrName);
|
|
|
//刷新界面
|
|
|
//if (StartReciveProcess.OnRefreshWorkerInfo != null)
|
|
|
//{
|
|
|
// StartReciveProcess.OnRefreshWorkerInfo(null, System.EventArgs.Empty);
|
|
|
//}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error("解析客户端设置计划运行方式失败：" + ex.Message, ex);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 扫描架子条码
|
|
|
/// <summary>
|
|
|
/// 扫描架子条码
|
|
|
/// </summary>
|
|
|
/// <param name="msg"></param>
|
|
|
private void ExecSendMaterBarcode(string msg)
|
|
|
{
|
|
|
PlanCommon.GetScanBarcode();
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 客户端新增计划
|
|
|
/// <summary>
|
|
|
/// 客户端新增计划
|
|
|
/// </summary>
|
|
|
/// <param name="msg"></param>
|
|
|
private void ExecSendAddPlan(string msg)
|
|
|
{
|
|
|
//预留
|
|
|
ICSharpCode.Core.LoggingService.Debug("预留方法！");
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 网络计划下达时，通知中控室机台有新计划下达
|
|
|
/// <summary>
|
|
|
/// 网络计划下达时，通知中控室机台有新计划下达
|
|
|
/// </summary>
|
|
|
private void ExecSendNetNewPlan()
|
|
|
{
|
|
|
if (StartReciveProcess.OnRefreshNewNetNote != null)
|
|
|
{
|
|
|
string msg = String.Format("{0}网络有新计划下达", DateTime.Now);
|
|
|
StartReciveProcess.OnRefreshNewNetNote(msg, System.EventArgs.Empty);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 气力输送发送过来的日罐的料位信息
|
|
|
/// <summary>
|
|
|
/// 气力输送发送过来的日罐的料位信息
|
|
|
/// </summary>
|
|
|
/// <param name="msg"></param>
|
|
|
private void ExecSendWareInfo(string msg)
|
|
|
{
|
|
|
//预留
|
|
|
ICSharpCode.Core.LoggingService.Debug("预留方法！");
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 胶料秤客户端扫描条码错误时发送，中控室上位机向plc设置报警位 置胶料秤报警灯
|
|
|
/// <summary>
|
|
|
/// 胶料秤客户端扫描条码错误时发送，中控室上位机向plc设置报警位 置胶料秤报警灯
|
|
|
/// </summary>
|
|
|
private void ExecSendBarRight()
|
|
|
{
|
|
|
//预留
|
|
|
ICSharpCode.Core.LoggingService.Debug("预留方法！");
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 维修
|
|
|
|
|
|
private void ExecSendRepair()
|
|
|
{
|
|
|
//预留
|
|
|
ICSharpCode.Core.LoggingService.Debug("预留方法！");
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 显示Socket通知
|
|
|
/// <summary>
|
|
|
/// 显示Socket通知
|
|
|
/// </summary>
|
|
|
/// <param name="msg">发送的通知内容</param>
|
|
|
private void ExecSendNewMessage(string msg)
|
|
|
{
|
|
|
if (StartReciveProcess.OnRefreshNewNetNote != null)
|
|
|
{
|
|
|
StartReciveProcess.OnRefreshNewNetNote(msg, System.EventArgs.Empty);
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region 客户端修改生产车数，并下传至PLC
|
|
|
/// <summary>
|
|
|
/// 客户端修改生产车数，并下传至PLC
|
|
|
/// </summary>
|
|
|
/// <param name="msg">客户端发送的Socket指令，格式：协议头：PlanID:PlanNum/</param>
|
|
|
private void ExecSendModifyPlanNum(string msg)
|
|
|
{
|
|
|
if (base.NetType == NetTypes.Net)
|
|
|
{
|
|
|
if (!String.IsNullOrEmpty(msg))
|
|
|
{
|
|
|
if (msg.Substring(msg.Length - 1) != "/")
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Warn("客户端发送的消息格式不正确，正确格式：协议头 + ':' + PlanID + ':' + PlanNum + '/'");
|
|
|
return;
|
|
|
}
|
|
|
string[] values = msg.Split(new char[] { ':' });
|
|
|
if (values == null || values.Length != 2)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Warn("客户端发送的消息格式不正确，正确格式：协议头 + ':' + PlanID + ':' + PlanNum + '/'");
|
|
|
return;
|
|
|
}
|
|
|
try
|
|
|
{
|
|
|
string planId = values[0];
|
|
|
int planNum = Convert.ToInt32(values[1].Replace("/", String.Empty));
|
|
|
new FeedingPlc.ModifyPlanNum().SimpleModifyPlanNum(planId, planNum);
|
|
|
//刷新当班计划界面
|
|
|
if (StartReciveProcess.OnRefreshPlan != null)
|
|
|
{
|
|
|
StartReciveProcess.OnRefreshPlan(null, System.EventArgs.Empty);
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Warn("客户端修改生产车数失败：" + ex.Message, ex);
|
|
|
return;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 把掺用物料添加到配方中,并下传至PLC
|
|
|
/// <summary>
|
|
|
/// 把掺用物料添加到配方中,并下传至PLC
|
|
|
/// </summary>
|
|
|
/// <param name="msg">要掺用的物料编码</param>
|
|
|
private void ExecSendChanYong(string msg)
|
|
|
{
|
|
|
if (base.NetType != NetTypes.Net)
|
|
|
{
|
|
|
return;
|
|
|
}
|
|
|
//防止并发执行
|
|
|
lock (String.Empty)
|
|
|
{
|
|
|
string downFlag = this.GetDownFlag();
|
|
|
if (downFlag.CompareTo("1") > 0)
|
|
|
{
|
|
|
return;
|
|
|
}
|
|
|
this.ModifyAndDownLoadPF(msg);
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region 停止掺用物料
|
|
|
/// <summary>
|
|
|
/// 停止掺用物料
|
|
|
/// </summary>
|
|
|
private void ExecSendStopChanYong()
|
|
|
{
|
|
|
string downFlag = String.Empty;
|
|
|
string strSql = String.Empty;
|
|
|
PlanLog log = PlanCommon.PlanLog;
|
|
|
|
|
|
if (base.NetType != NetTypes.Net)
|
|
|
{
|
|
|
return;
|
|
|
}
|
|
|
lock (String.Empty)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
downFlag = this.GetDownFlag();
|
|
|
if (downFlag != "3")
|
|
|
{
|
|
|
return;
|
|
|
}
|
|
|
//1、更新下传标志
|
|
|
DbHelper localHelper = base.NewDbHelper(DataSourceFactory.MCDbType.Local);
|
|
|
if (localHelper == null)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error("修改下传配方失败：获取本地数据连接失败！");
|
|
|
return;
|
|
|
}
|
|
|
localHelper.CommandType = CommandType.Text;
|
|
|
localHelper.ClearParameter();
|
|
|
strSql = "update pmt_ChanYong set Download_Flag = '4'";
|
|
|
localHelper.CommandText = strSql;
|
|
|
localHelper.ExecuteNonQuery();
|
|
|
|
|
|
//2、从网络获取最新配方并下传
|
|
|
if (log == null)
|
|
|
{
|
|
|
return;
|
|
|
}
|
|
|
List<string> msgList = null;
|
|
|
int result = new BasicInfo.PLCRecipe().SendPlan(log.LastPlanID, out msgList);
|
|
|
if (result != 1)
|
|
|
{
|
|
|
base.LogError("配方下传失败...");
|
|
|
}
|
|
|
|
|
|
|
|
|
//3、清空掺用物料
|
|
|
localHelper.ClearParameter();
|
|
|
strSql = "truncate table pmt_ChanYong";
|
|
|
localHelper.CommandText = strSql;
|
|
|
localHelper.ExecuteNonQuery();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error(ex.Message, ex);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 辅助方法
|
|
|
|
|
|
#region 解析客户端发送的计划列表
|
|
|
/// <summary>
|
|
|
/// 解析客户端发送的计划列表
|
|
|
/// </summary>
|
|
|
/// <param name="msg">客户端发送过来的计划列表，格式：date|shift|Name+code+set+finish+planId~Name+code+set+finish+planId......../</param>
|
|
|
/// <returns>返回解析的计划列表</returns>
|
|
|
public List<SimplePlan> ParsePlanFromMsg(string msg)
|
|
|
{
|
|
|
List<SimplePlan> planList = new List<SimplePlan>();
|
|
|
if (!String.IsNullOrEmpty(msg))
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
if (msg.Substring(msg.Length - 1) != "/")
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Warn("客户端发送的计划列表格式不正确，正确格式：date|shift|Name+code+set+finish+planId~Name+code+set+finish+planId......../_1");
|
|
|
return planList;
|
|
|
}
|
|
|
string[] strs = msg.Replace(":", string.Empty).Split(new char[] { '|' });
|
|
|
if (strs == null || strs.Length != 3)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Warn("客户端发送的计划列表格式不正确，正确格式：date|shift|Name+code+set+finish+planId~Name+code+set+finish+planId......../_2");
|
|
|
return planList;
|
|
|
}
|
|
|
DateTime planDate = Convert.ToDateTime(strs[0]); //获取计划日期
|
|
|
PlanCommon.ExecDate = strs[0];
|
|
|
int shifID = Convert.ToInt32(strs[1]); //获取班次
|
|
|
PlanCommon.ExecShift = strs[1];
|
|
|
//int classID = Convert.ToInt32(strs[2]);
|
|
|
//PlanCommon.ExecClass = strs[2];
|
|
|
//string userID = strs[3];
|
|
|
strs[2] = strs[2].Replace("/", String.Empty);
|
|
|
string[] temps = strs[2].Split(new char[] { '~' });
|
|
|
if (temps != null && temps.Length > 0)
|
|
|
{
|
|
|
SimplePlan plan = null;
|
|
|
for (int i = 0; i < temps.Length; i++)
|
|
|
{
|
|
|
string[] planData = temps[i].Replace("/", String.Empty).Split(new char[] { '+' });
|
|
|
if (planData == null || planData.Length != 5)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Warn("客户端发送的计划列表格式不正确，正确格式：date|shift|Name+code+set+finish+planId~Name+code+set+finish+planId......../_3");
|
|
|
continue;
|
|
|
}
|
|
|
plan = new SimplePlan();
|
|
|
plan.PlanDate = planDate; //计划日期
|
|
|
plan.ShiftID = shifID; //班次
|
|
|
//plan.ClassID = classID;
|
|
|
plan.RecipeMaterialName = planData[0]; //物料名称
|
|
|
plan.RecipeMaterialCode = planData[1]; //物料代码
|
|
|
plan.PlanNum = Convert.ToInt32(planData[2]); //计划车数
|
|
|
string strRealNum = planData[3];
|
|
|
if (planData[3].IndexOf("[") > 0)
|
|
|
{
|
|
|
strRealNum = planData[3].Substring(0, planData[3].IndexOf("["));
|
|
|
}
|
|
|
plan.RealNum = Convert.ToInt32(strRealNum); //完成车数
|
|
|
plan.PlanID = planData[4]; //计划ID
|
|
|
//plan.UserID = userID;
|
|
|
|
|
|
planList.Add(plan);
|
|
|
}
|
|
|
}
|
|
|
//如果没有计划，则删除当前所有计划
|
|
|
if (planList.Count == 0)
|
|
|
{
|
|
|
PlanCommon.DelCurrentPlan(base.CurrEquipCode, planDate, shifID);
|
|
|
//刷新界面上的计划列表
|
|
|
if (StartReciveProcess.OnRefreshPlan != null)
|
|
|
{
|
|
|
StartReciveProcess.OnRefreshPlan(null, System.EventArgs.Empty);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error("解析客户端发送的计划列表错误：" + ex.Message, ex);
|
|
|
}
|
|
|
}
|
|
|
return planList;
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region 获取配方ID
|
|
|
/// <summary>
|
|
|
/// 获取配方ID
|
|
|
/// </summary>
|
|
|
/// <param name="equipCode">机台号</param>
|
|
|
/// <param name="recipeMaterialCode">配方物料编码</param>
|
|
|
/// <param name="recipeMaterialName">配方物料名称</param>
|
|
|
/// <returns>返回配方ID，获取失败返回0</returns>
|
|
|
public int GetRecipeID(string equipCode, string recipeMaterialCode, string recipeMaterialName)
|
|
|
{
|
|
|
DbHelper localHelper = base.NewDbHelper(Basic.DataSourceFactory.MCDbType.Local);
|
|
|
if (localHelper == null)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error("获取配方ID失败：获取本地数据连接失败!");
|
|
|
return 0;
|
|
|
}
|
|
|
localHelper.CommandType = System.Data.CommandType.Text;
|
|
|
localHelper.ClearParameter();
|
|
|
string strSql = "select ObjID from pmt_recipe where equip_code = @RecipeEquipCode and mater_code = @RecipeMaterialCode and mater_name = @RecipeMaterialName";
|
|
|
localHelper.CommandText = strSql;
|
|
|
localHelper.AddParameter("@RecipeEquipCode", equipCode);
|
|
|
localHelper.AddParameter("@RecipeMaterialCode", recipeMaterialCode);
|
|
|
localHelper.AddParameter("@RecipeMaterialName", recipeMaterialName);
|
|
|
object result = localHelper.ToScalar();
|
|
|
if (result != null && result != System.DBNull.Value)
|
|
|
{
|
|
|
return Convert.ToInt32(result);
|
|
|
}
|
|
|
return 0;
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region 同步客户端发送的计划列表，支持客户端添加、删除、上移、下移
|
|
|
/// <summary>
|
|
|
/// 同步客户端发送的计划列表，支持客户端添加、删除、上移、下移
|
|
|
/// </summary>
|
|
|
/// <param name="msg">客户端发送的计划列表</param>
|
|
|
public void SynchroPlanList(string msg)
|
|
|
{
|
|
|
List<string> errorList = new List<string>();
|
|
|
//1、解析计划列表
|
|
|
List<SimplePlan> planList = this.ParsePlanFromMsg(msg);
|
|
|
if (planList == null || planList.Count == 0)
|
|
|
{
|
|
|
//如果是NULL全部删除本地当班计划
|
|
|
return;
|
|
|
}
|
|
|
DateTime planDate = planList[0].PlanDate;
|
|
|
int shiftId = planList[0].ShiftID;
|
|
|
//2、判断是网络版还是单机版
|
|
|
if (base.NetType == NetTypes.Net)
|
|
|
{
|
|
|
//网络版
|
|
|
foreach (SimplePlan plan in planList)
|
|
|
{
|
|
|
//如果本地表中没有计划则从网络接收计划
|
|
|
if (!PlanCommon.PlanExists(Basic.DataSourceFactory.MCDbType.Local, base.CurrEquipCode, plan.PlanID))
|
|
|
{
|
|
|
PlanCommon.RecivePlan(plan.PlanID, base.CurrEquipCode, plan.PlanDate, plan.ShiftID);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
//单机版
|
|
|
foreach (SimplePlan plan in planList)
|
|
|
{
|
|
|
//如果本地表中没有计划则添加计划
|
|
|
if (!PlanCommon.PlanExists(Basic.DataSourceFactory.MCDbType.Local, base.CurrEquipCode, plan.PlanID))
|
|
|
{
|
|
|
int recipeObjId = this.GetRecipeID(base.CurrEquipCode.Substring(3, 2), plan.RecipeEquipCode, plan.RecipeMaterialName);
|
|
|
PlanLog log = PlanCommon.PlanLog;
|
|
|
if (log != null)
|
|
|
{
|
|
|
plan.ClassID = log.LastClassID;
|
|
|
}
|
|
|
PlanCommon.AddPlan(Basic.DataSourceFactory.MCDbType.Local, base.CurrEquipCode, plan.PlanDate, plan.ShiftID, plan.ClassID, recipeObjId.ToString(),0, plan.PlanNum, out errorList);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
//3、获取当班计划列表，如果客户端发送的计划列表中没有，则删除本地库的计划
|
|
|
DataTable table = PlanCommon.GetPlanData(Basic.DataSourceFactory.MCDbType.Local, base.CurrEquipCode, planDate, shiftId);
|
|
|
if (table != null && table.Rows.Count > 0)
|
|
|
{
|
|
|
foreach (DataRow row in table.Rows)
|
|
|
{
|
|
|
string planId = row["PlanID"] as string;
|
|
|
bool flag = false;
|
|
|
foreach (SimplePlan plan in planList)
|
|
|
{
|
|
|
if (planId.Trim() == plan.PlanID.Trim())
|
|
|
{
|
|
|
flag = true;
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
//如果客户端发送的计划列表中没有此计划
|
|
|
if (!flag)
|
|
|
{
|
|
|
PlanStates planState = PlanCommon.GetPlanState(planId);
|
|
|
if (planState != PlanStates.Producting && planState != PlanStates.Completed)
|
|
|
{
|
|
|
//在本地库中删除此计划
|
|
|
PlanCommon.DeleteByPlanID(planId);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
//4、对更新本地计划列表排序
|
|
|
for (int i = 0; i < planList.Count; i++)
|
|
|
{
|
|
|
PlanCommon.UpdateActionOrder(planList[i].PlanID, i + 1);
|
|
|
}
|
|
|
|
|
|
//5、刷新界面上的计划列表
|
|
|
if (StartReciveProcess.OnRefreshPlan != null)
|
|
|
{
|
|
|
StartReciveProcess.OnRefreshPlan(null, System.EventArgs.Empty);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 从网络库中获取主机手名
|
|
|
/// <summary>
|
|
|
/// 从网络库中获取主机手名
|
|
|
/// </summary>
|
|
|
/// <param name="hrCode">主机手的HRCode</param>
|
|
|
/// <returns>返回对应主机手的名称</returns>
|
|
|
public string GetUserNameByHRCode(string hrCode)
|
|
|
{
|
|
|
DbHelper serverHelper = base.NewDbHelper(DataSourceFactory.MCDbType.Server);
|
|
|
if (serverHelper == null)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error("从网络库中获取主机手名失败：获取网络数据连接失败!");
|
|
|
return String.Empty;
|
|
|
}
|
|
|
serverHelper.CommandType = CommandType.Text;
|
|
|
serverHelper.ClearParameter();
|
|
|
//string strSql = "select UserName from BasUser where HRCode = @HRCode";
|
|
|
string strSql = "select top 1 [USER_NAME] from SYS_USER where Worker_barcode=@HRCode";
|
|
|
serverHelper.CommandText = strSql;
|
|
|
serverHelper.AddParameter("@HRCode", hrCode);
|
|
|
object result = serverHelper.ToScalar();
|
|
|
if (result == null || result == System.DBNull.Value)
|
|
|
{
|
|
|
return String.Empty;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return result.ToString();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 从本地库的pmt_ChanYong表中取出掺用标志
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获取下传标志
|
|
|
/// </summary>
|
|
|
/// <returns>成功返回掺用标志，失败返回String.Empty</returns>
|
|
|
public string GetDownFlag()
|
|
|
{
|
|
|
DbHelper localHelper = base.NewDbHelper(DataSourceFactory.MCDbType.Local);
|
|
|
if (localHelper == null)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error("获取掺用标志失败：获取本地数据连接失败！");
|
|
|
return String.Empty;
|
|
|
}
|
|
|
localHelper.CommandType = CommandType.Text;
|
|
|
localHelper.ClearParameter();
|
|
|
string strSql = "select top 1 Download_Flag from pmt_ChanYong";
|
|
|
localHelper.CommandText = strSql;
|
|
|
object result = localHelper.ToScalar();
|
|
|
if (result != null && result != System.DBNull.Value)
|
|
|
{
|
|
|
return result.ToString();
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return String.Empty;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#region 添加掺用物料，修改配方
|
|
|
|
|
|
/// <summary>
|
|
|
/// 添加掺用物料，修改配方
|
|
|
/// </summary>
|
|
|
/// <param name="materCode"></param>
|
|
|
public void ModifyAndDownLoadPF(string materCode)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
string cyType = "1"; //定义掺用类型变量
|
|
|
string cyWeight = "0"; //掺用重量
|
|
|
string smatercode = String.Empty;
|
|
|
string edtCode = "1"; //配方版本号
|
|
|
string weightID = "1"; //称量序号
|
|
|
string mWeightId = String.Empty; //
|
|
|
string materName = String.Empty; //物料名称
|
|
|
|
|
|
object result = null; //保存临时结果
|
|
|
PlanLog log = null; //当前计划日志
|
|
|
materCode = materCode.Replace("/", String.Empty);
|
|
|
string strSql = String.Empty;
|
|
|
//1、更新下传标志
|
|
|
DbHelper localHelper = base.NewDbHelper(DataSourceFactory.MCDbType.Local);
|
|
|
if (localHelper == null)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error("修改下传配方失败：获取本地数据连接失败！");
|
|
|
return;
|
|
|
}
|
|
|
localHelper.CommandType = CommandType.Text;
|
|
|
localHelper.ClearParameter();
|
|
|
strSql = "update pmt_ChanYong set Download_Flag = '1'";
|
|
|
localHelper.CommandText = strSql;
|
|
|
localHelper.ExecuteNonQuery();
|
|
|
|
|
|
//获取物料名称
|
|
|
localHelper.ClearParameter();
|
|
|
strSql = "select mater_name from pmt_material where mater_code = @mater_code";
|
|
|
localHelper.CommandText = strSql;
|
|
|
localHelper.AddParameter("@mater_code", materCode);
|
|
|
result = localHelper.ToScalar();
|
|
|
if (result != null && result != System.DBNull.Value)
|
|
|
{
|
|
|
materName = result.ToString();
|
|
|
}
|
|
|
|
|
|
//2、获取掺用类型，掺用类型 1代表不掺用,2计重掺用,3不计重掺用
|
|
|
|
|
|
|
|
|
localHelper.ClearParameter();
|
|
|
strSql = "select * from Pmt_ChanYong where mater_Code= @mater_code";
|
|
|
localHelper.CommandText = strSql;
|
|
|
localHelper.AddParameter("@mater_code", materCode);
|
|
|
DataTable table = localHelper.ToDataTable();
|
|
|
if (table != null && table.Rows.Count > 0)
|
|
|
{
|
|
|
cyType = Mesnac.Basic.DataProcessor.RowValue(table.Rows[0], "ChanYong_Type", "0");
|
|
|
cyWeight = Mesnac.Basic.DataProcessor.RowValue(table.Rows[0], "ChangYong_Weight", 0).ToString();
|
|
|
smatercode = Mesnac.Basic.DataProcessor.RowValue(table.Rows[0], "smater_Code", String.Empty);
|
|
|
}
|
|
|
if (cyType.CompareTo("2") < 0)
|
|
|
{
|
|
|
return;
|
|
|
}
|
|
|
//3、获取当前计划的配方版本号
|
|
|
log = PlanCommon.PlanLog;
|
|
|
if (log == null)
|
|
|
{
|
|
|
return;
|
|
|
}
|
|
|
localHelper.ClearParameter();
|
|
|
strSql = "select edt_code from ppt_plan where plan_id = @PlanID";
|
|
|
localHelper.CommandText = strSql;
|
|
|
localHelper.AddParameter("@PlanID", log.LastPlanID);
|
|
|
result = localHelper.ToScalar();
|
|
|
if (result != null && result != System.DBNull.Value)
|
|
|
{
|
|
|
edtCode = result.ToString().Trim();
|
|
|
}
|
|
|
//4、修改配方
|
|
|
weightID = "1";
|
|
|
string recipeMaterialCode = String.Empty; //计划配方对应的物料编码
|
|
|
DataRow planRow = PlanCommon.GetPlanData(DataSourceFactory.MCDbType.Local, log.LastPlanID);
|
|
|
if (planRow != null)
|
|
|
{
|
|
|
recipeMaterialCode = planRow["RecipeMaterialCode"] as string;
|
|
|
}
|
|
|
|
|
|
localHelper.ClearParameter();
|
|
|
strSql = "select max(weight_id) from pmt_weigh where father_code = @father_code and equip_code = @equip_code and edt_code = @edt_code and weigh_type = 2";
|
|
|
localHelper.CommandText = strSql;
|
|
|
localHelper.AddParameter("@father_code", recipeMaterialCode);
|
|
|
localHelper.AddParameter("@equip_code", base.CurrEquipCode.Substring(3, 2));
|
|
|
localHelper.AddParameter("@edt_code", edtCode);
|
|
|
result = localHelper.ToScalar();
|
|
|
if (result != null && result != System.DBNull.Value)
|
|
|
{
|
|
|
weightID = (Convert.ToInt32(result.ToString().Trim()) + 1).ToString();
|
|
|
}
|
|
|
|
|
|
if (cyType == "2") //计重掺用,配方内掺用
|
|
|
{
|
|
|
localHelper.ClearParameter();
|
|
|
strSql = "select top 1 Weight_id from pmt_weigh where father_code= @father_code and equip_code= @equip_code and edt_code= @edt_code and weigh_type=2 and child_code>'2' order by Set_weight desc";
|
|
|
localHelper.CommandText = strSql;
|
|
|
localHelper.AddParameter("@father_code", recipeMaterialCode);
|
|
|
localHelper.AddParameter("@equip_code", base.CurrEquipCode.Substring(3, 2));
|
|
|
localHelper.AddParameter("@edt_code", edtCode);
|
|
|
result = localHelper.ToScalar();
|
|
|
if (result != null && result != System.DBNull.Value)
|
|
|
{
|
|
|
mWeightId = result.ToString().Trim();
|
|
|
if (String.IsNullOrEmpty(mWeightId))
|
|
|
{
|
|
|
mWeightId = "1";
|
|
|
}
|
|
|
}
|
|
|
|
|
|
strSql = "update pmt_weigh set set_weight=set_weight-{0} where weight_id={1} and father_code='{2}' and equip_code='{3}' and edt_code='{4}' and weigh_type=2;";
|
|
|
strSql = String.Format(strSql, cyWeight, mWeightId, recipeMaterialCode, base.CurrEquipCode.Substring(3, 2), edtCode);
|
|
|
}
|
|
|
else if (cyType == "3") //不计重掺用,配方外掺用
|
|
|
{
|
|
|
strSql = "update pmt_recipe set total_weight = total_weight + {0} where mater_code='{1}' and equip_code='{2}' and edt_code='{3}';";
|
|
|
strSql = String.Format(strSql, cyWeight, recipeMaterialCode, base.CurrEquipCode.Substring(3, 2), edtCode);
|
|
|
}
|
|
|
strSql += "insert into pmt_weigh(RecipeObjID,weight_id,father_code,equip_code,edt_code,weigh_type,act_code,child_code,child_name,set_weight,error_allow,ChanYong_Flag)";
|
|
|
strSql += " values(@RecipeObjID,@weight_id,@father_code,@equip_code,@edt_code,2,0,@child_code,@child_name,@set_weight,0.5,'1')";
|
|
|
localHelper.ClearParameter();
|
|
|
localHelper.CommandText = strSql;
|
|
|
localHelper.AddParameter("@RecipeObjID", RecipeCache.Instance.RecipeInfo.ObjID);
|
|
|
localHelper.AddParameter("@weight_id", weightID);
|
|
|
localHelper.AddParameter("@father_code", recipeMaterialCode);
|
|
|
localHelper.AddParameter("@equip_code", base.CurrEquipCode.Substring(3, 2));
|
|
|
localHelper.AddParameter("@edt_code", edtCode);
|
|
|
localHelper.AddParameter("@child_code", materCode);
|
|
|
localHelper.AddParameter("@child_name", materName);
|
|
|
localHelper.AddParameter("@set_weight", cyWeight);
|
|
|
localHelper.ExecuteNonQuery();
|
|
|
|
|
|
//配方重传
|
|
|
if (new PLCRecipe().RecipeReset() > 0)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Info("掺用配方下传成功!");
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error("掺用配方下传失败!");
|
|
|
}
|
|
|
|
|
|
//更新下传标志
|
|
|
localHelper.ClearParameter();
|
|
|
strSql = "update pmt_ChanYong set Download_Flag = '2'";
|
|
|
localHelper.CommandText = strSql;
|
|
|
localHelper.ExecuteNonQuery();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
ICSharpCode.Core.LoggingService.Error("修改下传配方失败：" + ex.Message, ex);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
|
|
#endregion
|
|
|
}
|
|
|
}
|