using Model; using Newtonsoft.Json; using Newtonsoft.Json.Linq; using Pub_Class; using System; using System.Collections; using System.Collections.Generic; using System.Data; using System.Data.SqlClient; using System.Diagnostics; using System.IO; using System.Web; using System.Web.Http; using System.Windows.Forms; using WebAPI.Models; namespace WebAPI.Controllers { //工序出站汇报单Controller public class Cj_StationOutBillController : ApiController { public DBUtility.ClsPub.Enum_BillStatus BillStatus; Pub_Class.ClsXt_SystemParameter oSystemParameter = new Pub_Class.ClsXt_SystemParameter(); public DAL.ClsSc_ICMOBill BillOld = new DAL.ClsSc_ICMOBill(); private json objJsonResult = new json(); SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); DataSet ds; DataSet ds1; string fileip = System.Configuration.ConfigurationManager.AppSettings["FileIP"]; #region 新增单据-保存按钮 [Route("Cj_StationOutBill/AddBill")] [HttpPost] public object AddBill([FromBody] JObject oMain) { var _value = oMain["oMain"].ToString(); string msg1 = _value.ToString(); string[] sArray = msg1.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries); try { //反序列化 string msg2 = "[" + sArray[0].ToString() + "]"; string user = sArray[1].ToString();//用户名 string OperationType = sArray[2].ToString();//类型 string HComputerName = SystemInformation.ComputerName; //设备名称 if (OperationType == "5") { //判断是否有编辑权限 if (!DBUtility.ClsPub.Security_Log("Cj_StationOutBill_Sub_Edit", 1, false, user)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "完工单无编辑权限!"; objJsonResult.data = null; return objJsonResult; } } else { //判断是否有编辑权限 if (!DBUtility.ClsPub.Security_Log("Cj_StationOutBill_Edit", 1, false, user)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "出站单无编辑权限!"; objJsonResult.data = null; return objJsonResult; } } Stopwatch sw = new Stopwatch(); sw.Start();//开始计时 List list = Newtonsoft.Json.JsonConvert.DeserializeObject>(msg2); long HMainInterID = 0; HMainInterID = list[0].HMainInterID; string eventType = list[0].eventType; string BillType = "3791"; string HBillSubType = "3791"; long HInterID = list[0].HInterID;//递入type得到的单据ID string HBillNo = list[0].HBillNo;//递入type得到的单据号 int HBillStatus = 0; string HMaker = user;//制单人 string HMouldNum = list[0].HMouldNum;//模穴号 int HYear = DateTime.Now.Year; double HPeriod = DateTime.Now.Month; string HRemark = list[0].HRemark;//备注 string HSourceName = list[0].HSourceName;//生产资源名称 double HPieceQty = list[0].HPieceQty;//进站PCS数 double HWasterQty = list[0].HWasterQty;//报废数量 double HPlanPieceQty = list[0].HPlanPieceQty;//进站PNL数 double HBadPNL = list[0].HBadPNL;//报废PNL数 long HICMOInterID = list[0].HICMOInterID;//任务单ID string HICMOBillNo = list[0].HICMOBillNo;//任务单 int HProcPlanInterID = 0; int HProcPlanEntryID = 0; string HProcPlanBillNo = ""; long HProcExchInterID = list[0].lngBillKey; long HProcExchEntryID = list[0].lngBillSubKey; string HProcExchBillNo = list[0].HProcExchBillNo;//流转卡 long HMaterID = list[0].HMaterID;//产品ID long HProcID = list[0].HProcID;//当前工序ID double HICMOQty = list[0].HICMOQty;//任务单数量 double HPlanQty = list[0].HPlanQty;//移交PNL数 DateTime HStationOutTime = list[0].HStationOutTime;//汇报时间 long HSourceID = list[0].HSourceID;//生产资源ID long HPayProcID = list[0].HPayProcID;//核算工序ID long HGroupID = list[0].HGroupID;//班组ID long HDeptID = 0; long HEmpID = list[0].HEmpID;//操作员ID string HBarCode = list[0].HBarCode;//条形码 string HAddr = ""; string HBarCodeMaker = ""; long HSourceID2 = list[0].HSourceID2;//生产资源2ID long HSourceID3 = list[0].HSourceID3;//生产资源3ID long HSourceID4 = list[0].HSourceID4;//生产资源4ID long HSourceID5 = list[0].HSourceID5;//生产资源5ID long HSupID = 0; double HQty = list[0].HQty;//合格数量 double HPrice = 0; double HMoney = 0; double HBadCount = list[0].HBadCount;//不良数量 long HCenterID = list[0].HCenterID;//工作中心ID string HProcNo = list[0].HProcNo;//流水号 string HOrderProcNO = list[0].HOrderProcNO;//订单跟踪号 string HSourceNameList = list[0].HSourceNameList;//设备清单 long HMainSourceInterID = list[0].HInterID;//递入type得到的单据ID string HMainSourceBillNo = list[0].HBillNo;//递入type得到的单据号 string HMainSourceBillType = "3790"; bool HLastSubProc = list[0].HLastSubProc;//转下工序 long HEmpID2 = list[0].HEmpID2;//操作员2ID long HEmpID3 = list[0].HEmpID3;//操作员3ID long HEmpID4 = list[0].HEmpID4;//操作员4ID long HEmpID5 = list[0].HEmpID5;//操作员5ID double HDSQty = list[0].HDSQty;//折弯刀数 double HChongQty = list[0].HChongQty;//NCT冲次数 double HPriceRate = list[0].HPriceRate;//系数 double HWorkTimes = list[0].HWorkTimes;//工时 long HQCCheckID = list[0].HQCCheckID;//检验员ID long HPRDOrgID = list[0].HPRDOrgID;//组织ID double HmaterOutqty = list[0].HmaterOutqty;//白坯发布 double HProcPriceRate = list[0].HProcPriceRate;//工价系数 int HTemporaryAreaID = list[0].HTemporaryAreaID;//暂放区 LogService.Write($"1.字段赋值,用时" + sw.Elapsed ); //单据完整性判断 if (HProcExchInterID <= 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "流转卡没有选择!请扫描条形码或输入条形码后回车"; objJsonResult.data = null; return objJsonResult; } if (HProcExchEntryID <= 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "流水号没有选择!请输入流水号后回车"; objJsonResult.data = null; return objJsonResult; } if (HProcNo == "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "流水号没有选择!"; objJsonResult.data = null; return objJsonResult; } if (HProcExchBillNo == "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "流转卡号没有选择!"; objJsonResult.data = null; return objJsonResult; } if (HMaterID == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "产品没有选择!"; objJsonResult.data = null; return objJsonResult; } //if (HGroupID == 0) //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "生产班组没有选择!"; // objJsonResult.data = null; // return objJsonResult; //} if (HProcID == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "当前工序没有选择!"; objJsonResult.data = null; return objJsonResult; } //if (HQCCheckID == 0) //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "检验员没有选择!"; // objJsonResult.data = null; // return objJsonResult; //} //获取系统参数 string Ret = ""; if (oSystemParameter.ShowBill(ref Ret)) { //判断客户不为龙山汽配 if (oSystemParameter.omodel.WMS_CampanyName != "龙山汽配"&& oSystemParameter.omodel.WMS_CampanyName != "瑞与祺") //系统参数 { if (HSourceID == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "生产资源没有选择!"; objJsonResult.data = null; return objJsonResult; } } //判断客户为龙山汽配 else if (oSystemParameter.omodel.WMS_CampanyName == "龙山汽配") { //判断是否为多工位 ds = oCN.RunProcReturn("select * from h_v_GetStationOutBill_Detail where 工序ID = " + HProcID + " and 物料ID = " + HMaterID + " and 流转卡号 = '" + HProcExchBillNo + "'", "h_v_GetStationOutBill_Detail"); if (ds != null && ds.Tables[0].Rows.Count <= 1) { if (HEmpID == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "操作员没有选择!"; objJsonResult.data = null; return objJsonResult; } } } //判断客户为瑞与祺 else if (oSystemParameter.omodel.WMS_CampanyName == "瑞与祺") { if (HEmpID == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "操作员没有选择!"; objJsonResult.data = null; return objJsonResult; } } } //if (HCenterID == 0) //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "工作中心没有选择!"; // objJsonResult.data = null; // return objJsonResult; //} if (HQty + HWasterQty <= 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "合格数量加报废数量不能为0!"; objJsonResult.data = null; return objJsonResult; } //if (HWorkTimes <= 0) //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "工时必须大于0!"; // objJsonResult.data = null; // return objJsonResult; //} //if (HEmpID2 == 0 ) //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "操作员2没有选择!"; // objJsonResult.data = null; // return objJsonResult; //} //if (HEmpID3 == 0 ) //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "操作员3没有选择!"; // objJsonResult.data = null; // return objJsonResult; //} //if (HEmpID4 == 0 ) //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "操作员4没有选择!"; // objJsonResult.data = null; // return objJsonResult; //} //if (HEmpID5 == 0 ) //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "操作员5没有选择!"; // objJsonResult.data = null; // return objJsonResult; //} //LogService.Write($"2.条件判断,用时" + sw.Elapsed); var num = 0; //LogService.Write($"3.事务开始,用时" + sw.Elapsed); //若MAINDI重复则重新获取 oCN.BeginTran(); if ("Add".Equals(eventType)) { num = 1; if (!AllowbillNo(HBillNo)) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据号重复!"; objJsonResult.data = null; return objJsonResult; } LogService.Write($"3.1,用时" + sw.Elapsed); oCN.RunProc("Insert Into Sc_StationOutBillMain " + "(HBillType,HBillSubType,HInterID,HBillNo,HBillStatus,HDate,HMaker,HMakeDate,HMouldNum" + ",HYear,HPeriod,HRemark,HSourceName,HPieceQty,HWasterQty,HPlanPieceQty,HBadPNL" + ",HICMOInterID,HICMOBillNo,HProcPlanInterID,HProcPlanEntryID,HProcPlanBillNo,HProcExchInterID,HProcExchEntryID" + ",HProcExchBillNo,HMaterID,HProcID,HICMOQty,HPlanQty,HStationOutTime,HSourceID,HPayProcID" + ",HGroupID,HDeptID,HEmpID,HBarCode,HAddr,HBarCodeMaker,HBarCodeMakeDate,HSourceID2,HSourceID3,HSourceID4,HSourceID5" + ",HSupID,HQty,HPrice,HMoney,HBadCount,HCenterID,HProcNo,HOrderProcNO,HSourceNameList" + ",HMainSourceInterID,HMainSourceBillNo,HMainSourceBillType,HLastSubProc" + ",HEmpID2,HEmpID3,HEmpID4,HEmpID5,HDSQty,HChongQty,HPriceRate,HWorkTimes,HQCCheckID,HMainInterID,HPRDOrgID" + ",HmaterOutqty,HProcPriceRate,HTemporaryAreaID" + ") " + " values('" + BillType + "','" + (OperationType == "5" ? "SUB" : HBillSubType) + "'," + HInterID + ",'" + HBillNo + "'," + HBillStatus + ",getdate(),'" + HMaker + "',getdate(),'" + HMouldNum + "'" + "," + HYear + "," + HPeriod + ",'" + HRemark + "','" + HSourceName + "'," + HPieceQty + "," + HWasterQty + "," + HPlanPieceQty + "," + HBadPNL + "," + HICMOInterID + ",'" + HICMOBillNo + "'," + HProcPlanInterID + "," + HProcPlanEntryID + ",'" + HProcPlanBillNo + "'," + HProcExchInterID + "," + HProcExchEntryID + ",'" + HProcExchBillNo + "'," + HMaterID + "," + HProcID + "," + HICMOQty + "," + HPlanQty + ",getdate()," + HSourceID + "," + HPayProcID + "," + HGroupID + "," + HDeptID + "," + HEmpID + ",'" + HBarCode + "','" + HAddr + "','" + HBarCodeMaker + "',getdate()" + "," + HSourceID2 + "," + HSourceID3 + "," + HSourceID4 + "," + HSourceID5 + "," + HSupID + "," + HQty + "," + HPrice + "," + HMoney + "," + HBadCount + "," + HCenterID + "," + HProcNo + ",'" + HOrderProcNO + "'" + ",'" + HSourceNameList + "'" + "," + HMainSourceInterID + ",'" + HMainSourceBillNo + "','" + HMainSourceBillType + "'," + Convert.ToString(HLastSubProc ? 1 : 0) + "," + HEmpID2 + "," + HEmpID3 + "," + HEmpID4 + "," + HEmpID5 + "," + HDSQty + "," + HChongQty + "," + HPriceRate + "," + HWorkTimes + "," + HQCCheckID + "," + HMainInterID + "," + HPRDOrgID + ","+ HmaterOutqty + "," + HProcPriceRate + ","+ HTemporaryAreaID + ") "); LogService.Write($"4.新增结束,用时" + sw.Elapsed); LogService.Write("用户:" + user + ",日期:" + DateTime.Now + ",新增工序出站单据:" + HBillNo); oCN.RunProc("Insert into System_log (GeginDate, userid, WorkstationName, WorkList, SystemName, NetuserName, State) select GETDATE(),'" + user + "','" + HComputerName + "','" + "新增工序出站单据:" + HBillNo + "','LMES-工序出站模块','" + DBUtility.ClsPub.IPAddress + "','新增单据'", ref DBUtility.ClsPub.sExeReturnInfo); } else if ("Modify".Equals(eventType)) { num = 2; oCN.RunProc("UpDate Sc_StationOutBillMain set " + "HUpDater='" + HMaker + "'" + ",HUpDateDate=getdate()" + ",HSourceName='" + HSourceName + "'" + ",HRemark='" + HRemark + "'" + ",HQCCheckID=" + HQCCheckID + ",HEmpID=" + HEmpID + ",HEmpID2=" + HEmpID2 + ",HEmpID3=" + HEmpID3 + ",HEmpID4=" + HEmpID4 + ",HEmpID5=" + HEmpID5 + ",HSourceID=" + HSourceID + ",HSourceID2=" + HSourceID2 + ",HSourceID3=" + HSourceID3 + ",HSourceID4=" + HSourceID4 + ",HSourceID5=" + HSourceID5 + ",HPayProcID=" + HPayProcID + ",HWorkTimes=" + HWorkTimes + ",HSaveBillFlag=0 " + ",HPieceQty=" + HPieceQty + ",HQty=" + HQty + ",HDSQty=" + HDSQty + ",HChongQty=" + HChongQty + ",HTemporaryAreaID=" + HTemporaryAreaID + ",HMouldNum='" + HMouldNum + "'" + ",HSourceNameList='" + HSourceNameList + "'" + ",HWasterQty=" + HWasterQty + ",HLastSubProc=" + Convert.ToString(HLastSubProc ? 1 : 0) + " where HInterID=" + HInterID); LogService.Write("用户:" + user + ",日期:" + DateTime.Now + ",修改工序出站单据:" + HBillNo); oCN.RunProc("Insert into System_log (GeginDate, userid, WorkstationName, WorkList, SystemName, NetuserName, State) select GETDATE(),'" + user + "','" + HComputerName + "','" + "修改工序出站单据:" + HBillNo + "','LMES-工序出站模块','" + DBUtility.ClsPub.IPAddress + "','修改单据'", ref DBUtility.ClsPub.sExeReturnInfo); } else { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "操作类型无效!"; objJsonResult.data = null; return objJsonResult; } //主表 //LogService.Write($"5.系统控制查询判断,用时" + sw.Elapsed); ds = oCN.RunProcReturn("exec h_p_MES_StationOutBill_QtyCtrl " + HInterID + "", "h_p_MES_StationOutBill_QtyCtrl"); if (ds == null) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "判断数量失败!"; objJsonResult.data = null; return objJsonResult; } //LogService.Write($"5.1,用时" + sw.Elapsed); if (ds.Tables[0].Rows.Count == 0) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "判断数量失败!"; objJsonResult.data = null; return objJsonResult; } //LogService.Write($"5.2,用时" + sw.Elapsed); if (ClsPub.isStrNull(ds.Tables[0].Rows[0]["HBack"]) == "2") { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "数量控制," + ClsPub.isStrNull(ds.Tables[0].Rows[0]["HBackRemark"]); objJsonResult.data = null; return objJsonResult; } //LogService.Write($"6.判断结束,用时" + sw.Elapsed); oCN.RunProc("exec h_p_Mes_ProcessExchangeRelationQty_Out " + HInterID + ","+ num + ""); //LogService.Write($"6.1,用时" + sw.Elapsed); oCN.RunProc("exec h_p_Mes_ProcessExchangeChangeStatus " + HInterID + " "); //LogService.Write($"6.2,用时" + sw.Elapsed); oCN.RunProc("exec h_p_Mes_StationOutBillBackBarCode " + HInterID + " "); //LogService.Write($"7.存储过程结束,用时" + sw.Elapsed); //判断是否是 末道工序 ds1 = oCN.RunProcReturn(" select HLastProc,HFstProc from Sc_ProcessExchangeBillMain a " + " inner join Sc_ProcessExchangeBillSub b on a.HInterID=b.HInterID " + " Where a.HInterID=" + HProcExchInterID + " and b.HEntryID=" + HProcExchEntryID + " ", "Sc_ProcessExchangeBillMain"); //判断是否是新增 if ("Add".Equals(eventType)) { //判断是否是末道工序 if (ClsPub.isStrNull(ds1.Tables[0].Rows[0]["HLastProc"]) == "是") { //获取系统参数 string Return = ""; if (oSystemParameter.ShowBill(ref Return)) { //判断末道 生产汇报汇报 是否勾选 if (oSystemParameter.omodel.MES_StationOutBill_LastAutoICMOReport == "Y") //系统参数 { //LogService.Write($"7.1,用时" + sw.Elapsed); //同步生产汇报单 objJsonResult = (json)SaveICMOReportBill(HInterID.ToString(), user, HBillNo, HPRDOrgID.ToString()); //LogService.Write($"7.2,用时" + sw.Elapsed); if (objJsonResult.count == 0) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = objJsonResult.Message; objJsonResult.data = null; return objJsonResult; } //LogService.Write($"8.生产汇报结束,用时" + sw.Elapsed); } //判断末道 生产入库 是否勾选 else if (oSystemParameter.omodel.MES_StationOutBill_AutoStockIn == "Y") //系统参数 { //LogService.Write($"8.1,用时" + sw.Elapsed); //同步生产入库单 objJsonResult =(json)SaveProcdutInBill(HBillNo); //LogService.Write($"8.2,用时" + sw.Elapsed); if (objJsonResult.count == 0) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = objJsonResult.Message; objJsonResult.data = null; return objJsonResult; } //LogService.Write($"9.生产入库结束,用时" + sw.Elapsed); } } } } //LogService.Write($"10.事务结束,用时" + sw.Elapsed); oCN.Commit(); string sReturn = ""; if (oSystemParameter.ShowBill(ref sReturn) == true) { if (oSystemParameter.omodel.MES_StationOutBill_SaveAutoAddnew == "Y") //系统参数 页面保存自动变成新增状态 { objJsonResult.Verify = "Y"; } else { objJsonResult.Verify = "N"; } } sw.Stop();//结束计时 LogService.Write($"11.参数查询结束,新增结束,用时" + sw.Elapsed); objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "新增单据成功!"; objJsonResult.data = ds.Tables[0]; return objJsonResult; } catch (Exception e) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #region 批量新增单据-保存按钮 [Route("Cj_StationOutBill/BatchAddBill")] [HttpPost] public object BatchAddBill([FromBody] JObject oMain) { var _value = oMain["oMain"].ToString(); string msg1 = _value.ToString(); string[] sArray = msg1.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries); try { //反序列化 string msg2 = "[" + sArray[0].ToString() + "]"; //表头 string user = sArray[1].ToString();//用户名 string msg3 = sArray[2].ToString(); //表体 Int64 OperationType = Convert.ToInt64(sArray[3]); //操作类型 //判断是否有编辑权限 if (!DBUtility.ClsPub.Security_Log("Cj_StationOutBill_Edit", 1, false, user)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "无编辑权限!"; objJsonResult.data = null; return objJsonResult; } List list = Newtonsoft.Json.JsonConvert.DeserializeObject>(msg2); List listSub = Newtonsoft.Json.JsonConvert.DeserializeObject>(msg3); oCN.BeginTran(); for (int i = 0;i < listSub.Count; i++) { long HMainInterID = 0; HMainInterID = list[0].HMainInterID; string eventType = list[0].eventType; string BillType = "3791"; string HBillSubType = "3791"; long HInterID = listSub[i].HInterID;//递入type得到的单据ID string HBillNo = listSub[i].HBillNo;//递入type得到的单据号 int HBillStatus = 0; string HMaker = user;//制单人 string HMouldNum = list[0].HMouldNum;//模穴号 int HYear = DateTime.Now.Year; double HPeriod = DateTime.Now.Month; string HRemark = list[0].HRemark;//备注 string HSourceName = listSub[i].HSourceName;//生产资源名称 double HPieceQty = list[0].HPieceQty;//进站PCS数 double HWasterQty = listSub[i].HWasterQty;//报废数量 double HPlanPieceQty = list[0].HPlanPieceQty;//进站PNL数 double HBadPNL = list[0].HBadPNL;//报废PNL数 long HICMOInterID = listSub[i].HICMOInterID;//任务单ID string HICMOBillNo = listSub[i].HICMOBillNo;//任务单 int HProcPlanInterID = 0; int HProcPlanEntryID = 0; string HProcPlanBillNo = ""; long HProcExchInterID = listSub[i].lngBillKey; long HProcExchEntryID = listSub[i].lngBillSubKey; string HProcExchBillNo = listSub[i].HProcExchBillNo;//流转卡 long HMaterID = listSub[i].HMaterID;//产品ID long HProcID = listSub[i].HProcID;//当前工序ID double HICMOQty = listSub[i].HICMOQty;//任务单数量 double HPlanQty = list[0].HPlanQty;//移交PNL数 DateTime HStationOutTime = list[0].HStationOutTime;//汇报时间 long HSourceID = listSub[i].HSourceID;//生产资源ID long HPayProcID = list[0].HPayProcID;//核算工序ID long HGroupID = list[0].HGroupID;//班组ID long HDeptID = 0; long HEmpID = listSub[i].HEmpID;//操作员ID string HBarCode = list[0].HBarCode;//条形码 string HAddr = ""; string HBarCodeMaker = ""; long HSourceID2 = list[0].HSourceID2;//生产资源2ID long HSourceID3 = list[0].HSourceID3;//生产资源3ID long HSourceID4 = list[0].HSourceID4;//生产资源4ID long HSourceID5 = list[0].HSourceID5;//生产资源5ID long HSupID = 0; double HQty = listSub[i].HQty;//合格数量 double HPrice = 0; double HMoney = 0; double HBadCount = list[0].HBadCount;//不良数量 long HCenterID = listSub[0].HCenterID;//工作中心ID string HProcNo = listSub[i].HProcNo;//流水号 string HOrderProcNO = list[0].HOrderProcNO;//订单跟踪号 string HSourceNameList = list[0].HSourceNameList;//设备清单 long HMainSourceInterID = list[0].HInterID;//递入type得到的单据ID string HMainSourceBillNo = list[0].HBillNo;//递入type得到的单据号 string HMainSourceBillType = "3790"; bool HLastSubProc = list[0].HLastSubProc;//转下工序 long HEmpID2 = list[0].HEmpID2;//操作员2ID long HEmpID3 = list[0].HEmpID3;//操作员3ID long HEmpID4 = list[0].HEmpID4;//操作员4ID long HEmpID5 = list[0].HEmpID5;//操作员5ID double HDSQty = list[0].HDSQty;//折弯刀数 double HChongQty = list[0].HChongQty;//NCT冲次数 double HPriceRate = list[0].HPriceRate;//系数 double HWorkTimes = list[0].HWorkTimes;//工时 long HQCCheckID = list[0].HQCCheckID;//检验员ID long HPRDOrgID = list[0].HPRDOrgID;//组织ID var num = 0; //若MAINDI重复则重新获取 if (OperationType == 1)//新增 { num = 1; if (!AllowbillNo(HBillNo)) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据号重复!"; objJsonResult.data = null; return objJsonResult; } oCN.RunProc("Insert Into Sc_StationOutBillMain " + "(HBillType,HBillSubType,HInterID,HBillNo,HBillStatus,HDate,HMaker,HMakeDate,HMouldNum" + ",HYear,HPeriod,HRemark,HSourceName,HPieceQty,HWasterQty,HPlanPieceQty,HBadPNL" + ",HICMOInterID,HICMOBillNo,HProcPlanInterID,HProcPlanEntryID,HProcPlanBillNo,HProcExchInterID,HProcExchEntryID" + ",HProcExchBillNo,HMaterID,HProcID,HICMOQty,HPlanQty,HStationOutTime,HSourceID,HPayProcID" + ",HGroupID,HDeptID,HEmpID,HBarCode,HAddr,HBarCodeMaker,HBarCodeMakeDate,HSourceID2,HSourceID3,HSourceID4,HSourceID5" + ",HSupID,HQty,HPrice,HMoney,HBadCount,HCenterID,HProcNo,HOrderProcNO,HSourceNameList" + ",HMainSourceInterID,HMainSourceBillNo,HMainSourceBillType,HLastSubProc" + ",HEmpID2,HEmpID3,HEmpID4,HEmpID5,HDSQty,HChongQty,HPriceRate,HWorkTimes,HQCCheckID,HMainInterID,HPRDOrgID" + ") " + " values('" + BillType + "','" + HBillSubType + "'," + HInterID + ",'" + HBillNo + "'," + HBillStatus + ",getdate(),'" + HMaker + "',getdate(),'" + HMouldNum + "'" + "," + HYear + "," + HPeriod + ",'" + HRemark + "','" + HSourceName + "'," + HPieceQty + "," + HWasterQty + "," + HPlanPieceQty + "," + HBadPNL + "," + HICMOInterID + ",'" + HICMOBillNo + "'," + HProcPlanInterID + "," + HProcPlanEntryID + ",'" + HProcPlanBillNo + "'," + HProcExchInterID + "," + HProcExchEntryID + ",'" + HProcExchBillNo + "'," + HMaterID + "," + HProcID + "," + HICMOQty + "," + HPlanQty + ",getdate()," + HSourceID + "," + HPayProcID + "," + HGroupID + "," + HDeptID + "," + HEmpID + ",'" + HBarCode + "','" + HAddr + "','" + HBarCodeMaker + "',getdate()" + "," + HSourceID2 + "," + HSourceID3 + "," + HSourceID4 + "," + HSourceID5 + "," + HSupID + "," + HQty + "," + HPrice + "," + HMoney + "," + HBadCount + "," + HCenterID + "," + HProcNo + ",'" + HOrderProcNO + "'" + ",'" + HSourceNameList + "'" + "," + HMainSourceInterID + ",'" + HMainSourceBillNo + "','" + HMainSourceBillType + "'," + Convert.ToString(HLastSubProc ? 1 : 0) + "," + HEmpID2 + "," + HEmpID3 + "," + HEmpID4 + "," + HEmpID5 + "," + HDSQty + "," + HChongQty + "," + HPriceRate + "," + HWorkTimes + "," + HQCCheckID + "," + HMainInterID + "," + HPRDOrgID + ") "); } else { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "操作类型无效!"; objJsonResult.data = null; return objJsonResult; } //主表 ds = oCN.RunProcReturn("exec h_p_MES_StationOutBill_QtyCtrl " + HInterID + "", "h_p_MES_StationOutBill_QtyCtrl"); if (ds == null) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "判断数量失败!"; objJsonResult.data = null; return objJsonResult; } if (ds.Tables[0].Rows.Count == 0) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "判断数量失败!"; objJsonResult.data = null; return objJsonResult; } if (ClsPub.isStrNull(ds.Tables[0].Rows[0]["HBack"]) == "2") { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "数量控制," + ClsPub.isStrNull(ds.Tables[0].Rows[0]["HBackRemark"]); objJsonResult.data = null; return objJsonResult; } oCN.RunProc("exec h_p_Mes_ProcessExchangeRelationQty_Out " + HInterID + "," + num + ""); oCN.RunProc("exec h_p_Mes_ProcessExchangeChangeStatus " + HInterID + " "); oCN.RunProc("exec h_p_Mes_StationOutBillBackBarCode " + HInterID + " "); //判断是否是 末道工序 ds1 = oCN.RunProcReturn(" select HLastProc,HFstProc from Sc_ProcessExchangeBillMain a " + " inner join Sc_ProcessExchangeBillSub b on a.HInterID=b.HInterID " + " Where a.HInterID=" + HProcExchInterID + " and b.HEntryID=" + HProcExchEntryID + " ", "Sc_ProcessExchangeBillMain"); //判断是否是新增 if (OperationType == 1) { //判断是否是末道工序 if (ClsPub.isStrNull(ds1.Tables[0].Rows[0]["HLastProc"]) == "是") { //获取系统参数 string Return = ""; if (oSystemParameter.ShowBill(ref Return)) { //判断末道 生产汇报汇报 是否勾选 if (oSystemParameter.omodel.MES_StationOutBill_LastAutoICMOReport == "Y") //系统参数 { //同步生产汇报单 objJsonResult = (json)SaveICMOReportBill(HInterID.ToString(), user, HBillNo, HPRDOrgID.ToString()); if (objJsonResult.count == 0) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = objJsonResult.Message; objJsonResult.data = null; return objJsonResult; } } //判断末道 生产入库 是否勾选 else if (oSystemParameter.omodel.MES_StationOutBill_AutoStockIn == "Y") //系统参数 { //同步生产入库单 objJsonResult = (json)SaveProcdutInBill(HBillNo); if (objJsonResult.count == 0) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = objJsonResult.Message; objJsonResult.data = null; return objJsonResult; } } } } } } oCN.Commit(); string sReturn = ""; if (oSystemParameter.ShowBill(ref sReturn) == true) { if (oSystemParameter.omodel.MES_StationOutBill_SaveAutoAddnew == "Y") //系统参数 自动审核 { objJsonResult.Verify = "Y"; } else { objJsonResult.Verify = "N"; } } objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "新增单据成功!"; objJsonResult.data = ds.Tables[0]; return objJsonResult; } catch (Exception e) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion #region 末道工序 生产汇报 public object SaveICMOReportBill(string InterID, string user, string BillNo, string OrganizationID) { try { //获取生产汇报单最大InterID和单据号 Int64 HInterID = DBUtility.ClsPub.CreateBillID("3711", ref DBUtility.ClsPub.sExeReturnInfo); string HBillNo = DBUtility.ClsPub.CreateBillCode("3711", ref DBUtility.ClsPub.sExeReturnInfo, true); //获取组织代码 string OrganizationNUM = oCN.RunProcReturn("select HNumber from Xt_ORGANIZATIONS where HItemID=" + OrganizationID, "Xt_ORGANIZATIONS").Tables[0].Rows[0]["HNumber"].ToString(); //根据工序汇报单主ID获取工序汇报入库单的数据 DataSet ds = oCN.RunProcReturn("select * from h_v_MES_StationOutBillList_LastProc where HInterID=" + InterID, "h_v_MES_StationOutBillList_LastProc"); if (ds.Tables[0].Rows.Count <= 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "生成生产汇报单过程中没有查询到出站单"; objJsonResult.data = null; return objJsonResult; } DataRow dr = ds.Tables[0].Rows[0]; //保存 //oCN.BeginTran(); DataSet DsTable = oCN.RunProcReturn($"select * from Sc_ICMOReportBillMain where HBillNo='{HBillNo}'", "Sc_ICMOReportBillMain"); if (DsTable.Tables[0].Rows.Count > 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "已入库,请不要重复入库"; objJsonResult.data = null; return objJsonResult; } //生产汇报单主表 oCN.RunProc("Insert Into Sc_ICMOReportBillMain " + "(HBillType,HBillSubType,HInterID,HBillNo,HDate,HMaker,HMakeDate,HBillStatus,HChecker,HCheckDate" + ",HYear,HPeriod,HRemark,HEmpID,HEmpNumber" + ",HGroupID,HDeptID,HDeptNumber" + ",HMainSourceBillNo,HMainSourceInterID,HMainSourceEntryID,HMainSourceBillType" + ") " + " values('3711','3711'," + HInterID.ToString() + ",'" + HBillNo + "',getdate(),'" + user + "',getdate(),2,'" + user + "',getdate()" + ",DATENAME(YEAR,GETDATE()),0,'','" + dr["HEmpID"].ToString() + "','" + dr["操作员代码"].ToString() + "','" + dr["HGroupID"].ToString() + "',0,''" + ",'" + BillNo.ToString() + "'," + InterID.ToString() + ", 0,'3791'" + ") "); //生产汇报单子表 oCN.RunProc("Insert into Sc_ICMOReportBillSub " + " (HInterID,HEntryID,HMaterID,HMaterNumber" + ",HQty,HUnitID,HUnitNumber,HTimes,HSourceID" + ",HQtyMust,HWorkerID,HWorkerNumber,HBadCount,HWasterQty," + "HCloseMan,HCloseType,HRemark," + "HSourceInterID,HSourceEntryID,HSourceBillNo,HSourceBillType,HRelationQty,HRelationMoney" + ",HSeOrderInterID,HSeOrderEntryID,HSeOrderBillNo" + ",HICMOInterID,HICMOBillNo,HBarCode" + ") values(" + HInterID.ToString() + ",1," + dr["HMaterID"].ToString() + ",'" + dr["产品代码"].ToString() + "'" + "," + dr["合格数量"].ToString() + ",0,'',0,0" + "," + dr["接收数量"].ToString() + "," + dr["HEmpID"].ToString() + ",'" + dr["操作员代码"].ToString() + "'," + dr["不良数量"].ToString() + "," + dr["报废数量"].ToString() + ",'',0,''" + "," + InterID.ToString() + ",0,'" + BillNo.ToString() + "','3791',0,0" + ",0,0,''" + "," + dr["HICMOInterID"].ToString() + ",'" + dr["任务单"].ToString() + "',''" + ") "); //同步金蝶 //访问金蝶 var loginRet = InvokeHelper.Login(); var isSuccess = JObject.Parse(loginRet)["LoginResultType"].Value(); if (isSuccess == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "操作失败,金蝶账号登录异常。" + loginRet; objJsonResult.data = null; return objJsonResult; } //根据任务单查找到金蝶的生产订单 DataSet ds1 = oCN.RunProcReturn("select * from h_v_TOERP_StationOutBillList_LastProc where HICMOEntryID=" + dr["HICMOEntryID"].ToString(), "h_v_TOERP_StationOutBillList_LastProc"); DataRow dr1 = ds1.Tables[0].Rows[0]; JObject model = new JObject(); model.Add("FBillType", new JObject() { ["Fnumber"] = "SCHBD01_SYS" }); //单据类型生产汇报“SCHBD02_SYS” 入库汇报SCHBD01_SYS model.Add("FPrdOrgId", new JObject() { ["Fnumber"] = dr1["FPrdOrgNUMBER"].ToString() }); //生产组织1 model.Add("FDate", DateTime.Now.ToString("yyyy-MM-dd")); //单据日期1 model.Add("FHZYMESFLAG", "是");// 是否为MES同步 model.Add("FBillNo", HBillNo); JArray Fentity = new JArray(); foreach (DataRow item in ds.Tables[0].Rows) { JObject FentityModel = new JObject(); FentityModel.Add("FIsNew", false);// 源单类型 FentityModel.Add("FReportType", new JObject() { ["Fnumber"] = dr1["FREPORTTYPENUMBER"].ToString() });//生产汇报类型 FentityModel.Add("FSrcBillType", "PRD_MO");// 源单类型 FentityModel.Add("FProductType", "1");// 产品类型 FentityModel.Add("FSrcBillNo", item["任务单"].ToString());// 源单编号 FentityModel.Add("FSrcInterId", dr1["FMOID"].ToString());// 源单内码 FentityModel.Add("FSrcEntryId", dr1["FMOENTRYID"].ToString());// 源单分录内码、 FentityModel.Add("FSRCENTRYSEQ", dr1["FMOENTRYSEQ"].ToString());// 源单分录行号 FentityModel.Add("FUNITID", new JObject() { ["Fnumber"] = dr1["FUNITNUMBER"].ToString() });//单位 FentityModel.Add("FTimeUnitId", "1");//时间单位 FentityModel.Add("FWorkshipId", new JObject() { ["Fnumber"] = dr1["FWorkShopNUM"].ToString() }); // 生产车间 FentityModel.Add("FStandHourUnitId", "3600"); // 单位标准工时单位 FentityModel.Add("FMaterialId", new JObject() { ["Fnumber"] = dr1["FMaterialNUM"].ToString() }); // 物料编码 FentityModel.Add("FMoEntrySeq", dr1["FMOENTRYSEQ"].ToString());//生产订单行号 FentityModel.Add("FMoId", dr1["HICMOInterID"].ToString());//生产订单内码 FentityModel.Add("FFinishQty", item["接收数量"].ToString());//完成数量1 FentityModel.Add("FQuaQty", item["合格数量"].ToString());//合格数量1FFailQty FentityModel.Add("FFailQty", item["不良数量"].ToString());//不合格数量 FentityModel.Add("FStockInOrgId ", new JObject() { ["Fnumber"] = OrganizationNUM });// 入库组织 FentityModel.Add("FStockId", new JObject() { ["Fnumber"] = dr1["FStockNUM"].ToString() }); // 仓库 FentityModel.Add("FMOID", dr1["FMOID"].ToString());// FentityModel.Add("FMOBILLNO", dr1["FMOBILLNO"].ToString());// FentityModel.Add("FMOENTRYID", dr1["FMOENTRYID"].ToString());// FentityModel.Add("FMOENTRYSEQ", dr1["FMOENTRYSEQ"].ToString());// FentityModel.Add("FOwnerTypeId", dr1["FOWNERTYPEID"].ToString()); //货主类型:FOwnerTypeId(必填项) FentityModel.Add("FOwnerId", new JObject() { ["Fnumber"] = dr1["FOwnerNumber"].ToString() }); //货主:FOwnerId(必填项) FentityModel.Add("FBomId", new JObject() { ["Fnumber"] = dr1["FBOMNUM"].ToString() }); //BOM版本:FBomId(必填项) FentityModel.Add("FCostRate", dr1["FCostRate"].ToString());// 成本权重 FentityModel.Add("FISBACKFLUSH", dr1["FISBACKFLUSH"].ToString() == "1" ? true : false);// 倒冲领料 FentityModel.Add("FMOMAINENTRYID", dr1["FMOENTRYID"].ToString());// //FentityModel.Add("F_bsv_Base1", new JObject() { ["Fnumber"] = dr1["FPREBDONENUMBER"].ToString() }); //包装标识 FentityModel.Add("FLot", new JObject() { ["FNumber"] = dr1["FBATCHNO"].ToString() }); //批号 FentityModel.Add("F_bsv_Text", dr1["工序流转卡号"].ToString()); //流转卡号 JArray Fentity2 = new JArray(); JObject FentityModel2 = new JObject(); FentityModel2.Add("FEntity_Link_FFlowId", "f6e6eec3-5267-4f02-8593-b633da508a72"); FentityModel2.Add("FEntity_Link_FFlowLineId", "PRD_MO2MORPT"); FentityModel2.Add("FEntity_Link_FRuleId", "3"); FentityModel2.Add("FEntity_Link_FSTableId", "0"); FentityModel2.Add("FEntity_Link_FSTableName", "T_PRD_MOENTRY"); FentityModel2.Add("FEntity_Link_FSBillId", dr1["FMOID"].ToString()); FentityModel2.Add("FEntity_Link_FSId", dr1["FMOENTRYID"].ToString()); FentityModel2.Add("FEntity_Link_FBaseQuaQtyOld", item["合格数量"].ToString()); FentityModel2.Add("FEntity_Link_FBaseQuaQty", item["合格数量"].ToString()); Fentity2.Add(FentityModel2); FentityModel.Add("FEntity_Link", Fentity2); FentityModel.Add("FBFLowId", new JObject() { ["FID"] = "f6e6eec3-5267-4f02-8593-b633da508a72" }); // Fentity.Add(FentityModel); } model.Add("FEntity", Fentity); //明细信息 JObject jsonRoot = new JObject() { ["Creator"] = "", ["NeedUpDateFields"] = new JArray(), ["NeedReturnFields"] = new JArray(), ["IsDeleteEntry"] = "false", ["SubSystemId"] = "", ["IsVerifyBaseDataField"] = "false", //["IsAutoSubmitAndAudit"] = true,//自动调用提交和审核功能 ["Model"] = model }; string result = InvokeHelper.Save("PRD_MORPT", JsonConvert.SerializeObject(jsonRoot));//保存 //判断保存是否成功 if (JObject.Parse(result)["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE") { LogService.Write("工序汇报单入库错误jsonRoot:" + jsonRoot); oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = $"工序汇报入库单同步金蝶云失败!单号:{dr["单据号"].ToString()}" + result; objJsonResult.data = null; return objJsonResult; } //提交审核 string result1 = string.Empty; string result2 = string.Empty; var fID = JObject.Parse(result)["Result"]["Id"].ToString(); var fBillNo = JObject.Parse(result)["Result"]["Number"].ToString(); var json = new { Ids = fID, }; result1 = InvokeHelper.Submit("PRD_MORPT", JsonConvert.SerializeObject(json));//提交 result2 = InvokeHelper.Audit("PRD_MORPT", JsonConvert.SerializeObject(json));//提交 if (JObject.Parse(result1)["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE") { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = $"生产汇报单单号:{fBillNo},提交失败" + result; objJsonResult.data = null; return objJsonResult; } oCN.RunProc("update Sc_StationOutBillMain set HRelationQty=1 where HBillNo='" + BillNo + "'"); //oCN.Commit(); objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "保存成功!"; objJsonResult.data = 1; return objJsonResult; } catch (Exception e) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion #region 末道工序 生产入库 public object SaveProcdutInBill(string BillNo) { try { //获取生产汇报单最大InterID和单据号 Int64 HInterID = DBUtility.ClsPub.CreateBillID("1202", ref DBUtility.ClsPub.sExeReturnInfo); string HBillNo = DBUtility.ClsPub.CreateBillCode("1202", ref DBUtility.ClsPub.sExeReturnInfo, true); ////判断入库的合格数量是否为0 //var DTable = oCN.RunProcReturn("select * from Sc_StationOutBillMain where HBillNo='" + BillNo + "' ", "Sc_StationOutBillMain").Tables[0]; //if (double.Parse(DTable.Rows[0]["HQty"].ToString()) == 0) //{ // objJsonResult.code = "1"; // objJsonResult.count = 2; // objJsonResult.Message = "合格数量为0,不需要入库!"; // objJsonResult.data = null; // return objJsonResult; //} //保存 //oCN.BeginTran(); //同步金蝶 //访问金蝶 var loginRet = InvokeHelper.Login(); var isSuccess = JObject.Parse(loginRet)["LoginResultType"].Value(); if (isSuccess == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "操作失败,金蝶账号登录异常。" + loginRet; objJsonResult.data = null; return objJsonResult; } DataSet ds1 = oCN.RunProcReturn("exec h_p_TOERPProcduct_LastProc_Mes '" + BillNo + "'", "h_p_TOERPProcduct_LastProc_Mes"); DataRow dr1 = ds1.Tables[0].Rows[0]; if (double.Parse(dr1[0].ToString()) <= 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "未找到对应的生产汇报单记录;1.未查询到对应的生产汇报单;2.请确保当前工序是末道工序3.汇报单对应的入库数量已满 请在金蝶云查看入库记录!"; objJsonResult.data = null; return objJsonResult; } JObject model = new JObject(); model.Add("FBillType", new JObject() { ["FNumber"] = "SCRKD01_SYS" }); //单据类型 model.Add("FDate", DateTime.Now.ToString("yyyy-MM-dd")); //单据日期 model.Add("FStockOrgId", new JObject() { ["FNumber"] = dr1["HPrdOrgNumber"].ToString() }); //库存组织代码 model.Add("FPrdOrgId", new JObject() { ["FNumber"] = dr1["HPrdOrgNumber"].ToString() }); //生产组织代码 model.Add("FOwnerTypeId0", "BD_OwnerOrg"); model.Add("FOwnerId0", new JObject() { ["FNumber"] = dr1["HPrdOrgNumber"].ToString() }); // model.Add("FIsEntrust", "false");// model.Add("FCurrId", new JObject() { ["FNumber"] = "PRE001" }); // model.Add("FBillNo", BillNo); JArray Fentity = new JArray(); foreach (DataRow item in ds1.Tables[0].Rows) { JObject FentityModel = new JObject(); FentityModel.Add("FSrcEntryId", item["HSourceEntryID"].ToString());// 源单分录内码、 FentityModel.Add("FIsNew", "false");// 源单类型 FentityModel.Add("FMaterialId", new JObject() { ["FNumber"] = item["HMaterNumber"].ToString() }); // 物料编码 FentityModel.Add("FCheckProduct", "false");// FentityModel.Add("FInStockType", "1");// FentityModel.Add("FProductType", "1");// FentityModel.Add("FUNITID", new JObject() { ["FNumber"] = item["HUnitNumber"].ToString() });//单位 FentityModel.Add("FMustQty", item["数量"].ToString());// FentityModel.Add("FRealQty", item["数量"].ToString());// FentityModel.Add("FCostRate", "100");// FentityModel.Add("FBaseUnitId", new JObject() { ["FNumber"] = item["HUnitNumber"].ToString() });//单位 FentityModel.Add("FBaseMustQty", item["数量"].ToString());// FentityModel.Add("FBaseRealQty", item["数量"].ToString());// FentityModel.Add("FOwnerTypeId", "BD_OwnerOrg");// FentityModel.Add("FOwnerId", new JObject() { ["FNumber"] = item["HPrdOrgNumber"].ToString() });// FentityModel.Add("FStockId", new JObject() { ["FNumber"] = item["HStockNumber"].ToString() }); // 仓库 FentityModel.Add("FLot", new JObject() { ["FNumber"] = item["HBatchNo"].ToString() }); //批号 FentityModel.Add("FISBACKFLUSH", "true");// FentityModel.Add("FWorkShopId1", new JObject() { ["FNumber"] = item["HWorkShopNumber"].ToString() }); // 生产车间 FentityModel.Add("FMOBILLNO", item["HMOBillNo"].ToString());// FentityModel.Add("FMoId", item["HICMOInterID"].ToString());//生产订单内码 FentityModel.Add("FMoEntryId", item["HMOEntryID"].ToString());// FentityModel.Add("FMoEntrySeq", item["HMOEntrySEQ"].ToString());//生产订单行号 FentityModel.Add("FStockUnitId", new JObject() { ["FNumber"] = item["HUnitNumber"].ToString() });//库存单位 FentityModel.Add("FStockRealQty", item["数量"].ToString());// FentityModel.Add("FSrcBillType", "PRD_MORPT");// FentityModel.Add("FSrcBillNo", item["HSourceBillNo"].ToString());// FentityModel.Add("FSrcInterId", item["HSourceInterID"].ToString());// FentityModel.Add("FBasePrdRealQty", item["数量"].ToString());// FentityModel.Add("FIsFinished", "false");// FentityModel.Add("FStockStatusId", new JObject() { ["FNumber"] = "KCZT01_SYS" }); // FentityModel.Add("FSrcEntrySeq", item["HSourceSeQ"].ToString());// 源单分录行号 FentityModel.Add("FMOMAINENTRYID", item["HMOEntryID"].ToString());// FentityModel.Add("FKeeperTypeId", "BD_KeeperOrg"); FentityModel.Add("FKeeperId", new JObject() { ["FNumber"] = item["HPrdOrgNumber"].ToString() });// FentityModel.Add("FIsOverLegalOrg", "false");// FentityModel.Add("F_bsv_Base1", new JObject() { ["FNumber"] = item["HBZBS"].ToString() });// FentityModel.Add("F_BSV_TEXT", item["HLZKH"].ToString());// FentityModel.Add("F_BSV_TEXT1", item["HWYID"].ToString());// //批号 //FFLOWID FFLOWLINEID FRULEID FSTABLENAME //f6e6eec3 - 5267 - 4f02 - 8593 - b633da508a72 3 PRD_MO2MORPT T_PRD_MOENTRY //业务流程图:FEntity_Link_FFlowId //推进路线:FEntity_Link_FFlowLineId //转换规则:FEntity_Link_FRuleId //源单表内码:FEntity_Link_FSTableId //源单表:FEntity_Link_FSTableName //源单内码:FEntity_Link_FSBillId //源单分录内码:FEntity_Link_FSId //原始携带量:FEntity_Link_FBaseQuaQtyOld //修改携带量:FEntity_Link_FBaseQuaQty JArray Fentity2 = new JArray(); JObject FentityModel2 = new JObject(); FentityModel2.Add("FEntity_Link_FFlowId", "f6e6eec3-5267-4f02-8593-b633da508a72"); FentityModel2.Add("FEntity_Link_FFlowLineId", "5"); FentityModel2.Add("FEntity_Link_FRuleId", "PRD_MORPT2INSTOCK"); FentityModel2.Add("FEntity_Link_FSTableName", "T_PRD_MORPTENTRY"); FentityModel2.Add("FEntity_Link_FSTableId", "0"); FentityModel2.Add("FEntity_Link_FSBillId", item["HSourceInterID"].ToString()); FentityModel2.Add("FEntity_Link_FSId", item["HSourceEntryID"].ToString()); FentityModel2.Add("FEntity_Link_FBasePrdRealQtyOld", item["关联数量"].ToString()); FentityModel2.Add("FEntity_Link_FBasePrdRealQty", item["数量"].ToString()); Fentity2.Add(FentityModel2); FentityModel.Add("FEntity_Link", Fentity2); FentityModel.Add("FBFLowId", new JObject() { ["FID"] = "f6e6eec3-5267-4f02-8593-b633da508a72" }); // Fentity.Add(FentityModel); //Fentity.Add(FentityModel); } model.Add("FEntity", Fentity); //明细信息 JObject jsonRoot = new JObject() { ["Creator"] = "", ["NeedUpDateFields"] = new JArray(), ["NeedReturnFields"] = new JArray(), //["IsDeleteEntry"] = "true", //["SubSystemId"] = "", //["IsVerifyBaseDataField"] = "false", ["IsDeleteEntry"] = "true", ["SubSystemId"] = "", ["IsVerifyBaseDataField"] = "true", ["IsEntryBatchFill"] = "false", ["ValidateFlag"] = "true", ["NumberSearch"] = "true", ["IsAutoAdjustField"] = "false", ["InterationFlags"] = "", ["IgnoreInterationFlag"] = "", //["IsAutoSubmitAndAudit"] = true,//自动调用提交和审核功能 ["Model"] = model }; string result = InvokeHelper.Save("PRD_INSTOCK", JsonConvert.SerializeObject(jsonRoot));//保存 //判断保存是否成功 if (JObject.Parse(result)["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE") { LogService.Write("生产入库错误jsonRoot:" + jsonRoot); oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = $"生产入库单同步金蝶云失败!单号:{HBillNo.ToString()}" + result + jsonRoot; objJsonResult.data = null; return objJsonResult; } //提交审核 string result1 = string.Empty; string result2 = string.Empty; var fID = JObject.Parse(result)["Result"]["Id"].ToString(); var fBillNo = JObject.Parse(result)["Result"]["Number"].ToString(); var json = new { Ids = fID, }; result1 = InvokeHelper.Submit("PRD_INSTOCK", JsonConvert.SerializeObject(json));//提交 //result2 = InvokeHelper.Audit("PRD_INSTOCK", JsonConvert.SerializeObject(json));//提交 if (JObject.Parse(result1)["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE") { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = $"生产入库单单号:{fBillNo},提交失败" + result; objJsonResult.data = null; return objJsonResult; } oCN.RunProc("update Sc_StationOutBillMain set HRelationQty=1 where HBillNo='" + BillNo + "'"); //oCN.Commit(); objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "保存成功!"; objJsonResult.data = 1; return objJsonResult; } catch (Exception e) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion /// /// 新增单据-批量出站单保存按钮 ///参数:string sql。 ///返回值:object。 /// [Route("Cj_StationOutBill/AddBill_Mul")] [HttpPost] public object AddBill_Mul([FromBody] JObject oMain) { string UserName = ""; try { var _value = oMain["oMain"].ToString(); string msg1 = _value.ToString(); string[] sArray = msg1.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries); string msg2 = sArray[0].ToString(); string msg3 = sArray[1].ToString(); string msg4 = sArray[2].ToString(); string msg5 = sArray[3].ToString(); List list = new List(); msg1 = msg1.Replace("\\", ""); msg1 = msg1.Replace("\n", ""); //\n ListModels oListModels = new ListModels(); list = oListModels.getObjectByJson_Sc_StationOutBillMain(msg2); int i = 0; int j = 0; foreach (Model.ClsSc_StationOutBillMain oItemSub in list) { DAL.ClsSc_StationOutBill oBill = new DAL.ClsSc_StationOutBill(); j++; oBill.omodel.HInterID = list[i].HInterID; oBill.omodel.HBillNo = msg3 + "- " + j; oBill.omodel.HBillStatus = 0; oBill.omodel.HMouldNum = list[i].HMouldNum; oBill.omodel.HYear = DateTime.Now.Year; oBill.omodel.HPeriod = DateTime.Now.Month; oBill.omodel.HRemark = list[i].HRemark; oBill.omodel.HSourceName = list[i].HSourceName; oBill.omodel.HPieceQty = list[i].HPieceQty; oBill.omodel.HWasterQty = list[i].HWasterQty; oBill.omodel.HPlanPieceQty = list[i].HPlanPieceQty; oBill.omodel.HBadPNL = list[i].HBadPNL; oBill.omodel.HICMOInterID = list[i].HICMOInterID; oBill.omodel.HICMOBillNo = list[i].HICMOBillNo; oBill.omodel.HProcExchInterID = list[i].HProcExchInterID; oBill.omodel.HProcExchEntryID = list[i].HProcExchEntryID; oBill.omodel.HProcExchBillNo = list[i].HProcExchBillNo; oBill.omodel.HMaterID = list[i].HMaterID; oBill.omodel.HProcID = list[i].HProcID; oBill.omodel.HICMOQty = list[i].HICMOQty; oBill.omodel.HPlanQty = list[i].HPlanQty; oBill.omodel.HStationOutTime = list[i].HStationOutTime; oBill.omodel.HSourceID = list[i].HSourceID; oBill.omodel.HPayProcID = list[i].HPayProcID; oBill.omodel.HGroupID = list[i].HGroupID; oBill.omodel.HDeptID = list[i].HDeptID; oBill.omodel.HEmpID = list[i].HEmpID; oBill.omodel.HBarCode = list[i].HBarCode; oBill.omodel.HAddr = list[i].HAddr; //oBill.omodel.HBarCodeMaker = list[i].HBarCodeMaker; oBill.omodel.HBarCodeMaker = msg4; oBill.omodel.HSourceID2 = list[i].HSourceID2; oBill.omodel.HSourceID3 = list[i].HSourceID3; oBill.omodel.HSourceID4 = list[i].HSourceID4; oBill.omodel.HSourceID5 = list[i].HSourceID5; oBill.omodel.HSupID = list[i].HSupID; oBill.omodel.HQty = list[i].HQty; oBill.omodel.HPrice = list[i].HPrice; oBill.omodel.HMoney = list[i].HMoney; oBill.omodel.HBadCount = list[i].HBadCount; oBill.omodel.HCenterID = list[i].HCenterID; oBill.omodel.HProcNo = list[i].HProcNo; oBill.omodel.HOrderProcNO = list[i].HOrderProcNO; oBill.omodel.HSourceNameList = list[i].HSourceNameList; oBill.omodel.HMainSourceInterID = list[i].HMainSourceInterID; oBill.omodel.HMainSourceBillNo = list[i].HMainSourceBillNo; oBill.omodel.HMainSourceBillType = list[i].HMainSourceBillType; oBill.omodel.HLastSubProc = true; oBill.omodel.HEmpID2 = list[i].HEmpID2; oBill.omodel.HEmpID3 = list[i].HEmpID3; oBill.omodel.HEmpID4 = list[i].HEmpID4; oBill.omodel.HEmpID5 = list[i].HEmpID5; oBill.omodel.HDSQty = list[i].HDSQty; oBill.omodel.HChongQty = list[i].HChongQty; oBill.omodel.HPriceRate = list[i].HPriceRate; oBill.omodel.HWorkTimes = list[i].HWorkTimes; oBill.omodel.HQCCheckID = list[i].HQCCheckID; oBill.omodel.HMaker = msg4; oBill.omodel.HEmpNum = msg5; //string HBillSubType = "3791"; //long HInterID = list[0].HInterID;//递入type得到的单据ID //string HBillNo = msg3 + "- " + i;//递入type得到的单据号 //int HBillStatus = 0; //string HMaker = list[0].HMaker;//制单人 //string HMouldNum = list[0].HMouldNum;//模穴号 //int HYear = 2021; //double HPeriod = 1; //string HRemark = list[0].HRemark;//备注 //string HSourceName = list[0].HSourceName;//生产资源名称 //double HPieceQty = list[0].HPieceQty;//进站PCS数 //double HWasterQty = list[0].HWasterQty;//报废数量 //double HPlanPieceQty = list[0].HPlanPieceQty;//进站PNL数 //double HBadPNL = list[0].HBadPNL;//报废PNL数 //long HICMOInterID = list[0].HICMOInterID;//任务单ID //string HICMOBillNo = list[0].HICMOBillNo;//任务单 //int HProcPlanInterID = 0; //int HProcPlanEntryID = 0; //string HProcPlanBillNo = ""; //long HProcExchInterID = list[0].HProcExchInterID; //long HProcExchEntryID = list[0].HProcExchEntryID; //string HProcExchBillNo = list[0].HProcExchBillNo;//流转卡 //long HMaterID = list[0].HMaterID;//产品ID //long HProcID = list[0].HProcID;//当前工序ID //double HICMOQty = list[0].HICMOQty;//任务单数量 //double HPlanQty = list[0].HPlanQty;//移交PNL数 //DateTime HStationOutTime = list[0].HStationOutTime;//汇报时间 //long HSourceID = list[0].HSourceID;//生产资源ID //long HPayProcID = list[0].HPayProcID;//核算工序ID //long HGroupID = list[0].HGroupID;//班组ID //long HDeptID = 0; //long HEmpID = list[0].HEmpID;//操作员ID //string HBarCode = list[0].HBarCode;//条形码 //string HAddr = ""; //string HBarCodeMaker = ""; //long HSourceID2 = list[0].HSourceID2;//生产资源2ID //long HSourceID3 = list[0].HSourceID3;//生产资源3ID //long HSourceID4 = list[0].HSourceID4;//生产资源4ID //long HSourceID5 = list[0].HSourceID5;//生产资源5ID //long HSupID = 0; //double HQty = list[0].HQty;//合格数量 //double HPrice = 0; //double HMoney = 0; //double HBadCount = list[0].HBadCount;//不良数量 //long HCenterID = list[0].HCenterID;//工作中心ID //long HProcNo = list[0].HProcNo;//流水号 //string HOrderProcNO = list[0].HOrderProcNO;//订单跟踪号 //string HSourceNameList = list[0].HSourceNameList;//设备清单 //long HMainSourceInterID = list[0].HInterID;//递入type得到的单据ID //string HMainSourceBillNo = list[0].HBillNo;//递入type得到的单据号 //string HMainSourceBillType = "3790"; //bool HLastSubProc = list[0].HLastSubProc;//转下工序 //long HEmpID2 = list[0].HEmpID2;//操作员2ID //long HEmpID3 = list[0].HEmpID3;//操作员3ID //long HEmpID4 = list[0].HEmpID4;//操作员4ID //long HEmpID5 = list[0].HEmpID5;//操作员5ID //double HDSQty = list[0].HDSQty;//折弯刀数 //double HChongQty = list[0].HChongQty;//NCT冲次数 //double HPriceRate = list[0].HPriceRate;//系数 //double HWorkTimes = list[0].HWorkTimes;//工时 //long HQCCheckID = list[0].HQCCheckID;//检验员ID //保存 //保存完毕后处理 bool bResult; // bResult = oBill.AddBill(ref DBUtility.ClsPub.sExeReturnInfo); bResult = oBill.AddBill(ref DBUtility.ClsPub.sExeReturnInfo); oCN.RunProc($"update Sc_StationOutBillMain set HMaker='{msg4}' where HInterID={oBill.omodel.HInterID}"); i++; //if (bResult) //{ // objJsonResult.code = "0"; // objJsonResult.count = 1; // objJsonResult.Message = "保存成功!"; // //WebAPIController.Add_Log("送货单下推", UserName, "生成送货单"); // objJsonResult.data = 1; // return objJsonResult; //} //else //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "保存失败!" + DBUtility.ClsPub.sExeReturnInfo; // objJsonResult.data = 1; // return objJsonResult; //} } objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "保存成功!"; objJsonResult.data = 1; return objJsonResult; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "保存失败!" + e.ToString(); objJsonResult.data = 1; return objJsonResult; } } //递入物料信息 返回未完全汇报的流转卡 [Route("LEMS/Sc_StationOutBill_Mul_RYQ")] [HttpGet] public object Sc_StationOutBill_Mul_RYQ(String HMaterName,string HProcNumber, Int64 HOrgID) { try { SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); DataSet ds = oCN.RunProcReturn("exec h_p_CJGXPLHB_Query '" + HMaterName + "'," + HOrgID + ",'"+ HProcNumber + "'", "h_p_CJGXPLHB_Query"); if (ds == null || ds.Tables[0].Rows.Count <= 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "没有返回任何记录!"; objJsonResult.data = null; return objJsonResult; //DBUtility.ClsPub.MessageBeep((int)DBUtility.ClsPub.BeepType.Warning); } else { objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "获取信息成功!"; objJsonResult.data = ds.Tables[0]; return objJsonResult; } } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "没有返回任何记录!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } //选中网格里面的某一行流转卡 返回该流转卡的进出站情况 [Route("LEMS/Mul_RYQ_DisPlayBillList")] [HttpGet] public object Mul_RYQ_DisPlayBillList(String HBillNo,String HProcName) { try { SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); DataSet ds = oCN.RunProcReturn("exec h_P_Mul_RYQ_DisPlayBillList '" + HBillNo + "','" + HProcName + "'", "h_P_Mul_RYQ_DisPlayBillList"); if (ds == null || ds.Tables[0].Rows.Count <= 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "没有返回任何记录!"; objJsonResult.data = null; return objJsonResult; //DBUtility.ClsPub.MessageBeep((int)DBUtility.ClsPub.BeepType.Warning); } else { objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "获取信息成功!"; objJsonResult.data = ds.Tables[0]; return objJsonResult; } } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "没有返回任何记录!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } private bool AllowbillNo(string HBillNo) { ds = oCN.RunProcReturn("select HBillNo from Sc_StationOutBillMain where HBillNo = '" + HBillNo + "'", "Sc_StationOutBillMain"); if (ds == null || ds.Tables[0].Rows.Count == 0) { return true; } return false; } #endregion #region 返回工序出站汇报单列表 [Route("Cj_StationOutBill/get_Display")] [HttpGet] public object get_Display(string sWhere,string user,string HBillSubType) { try { List columnNameList = new List(); if (HBillSubType == "SUB") { //判断是否有查询权限 if (!DBUtility.ClsPub.Security_Log("Cj_StationOutBill_Sub_Query", 1, false, user)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "完工单无查询权限!"; objJsonResult.data = null; return objJsonResult; } } else { //判断是否有查询权限 if (!DBUtility.ClsPub.Security_Log("Cj_StationOutBill_Query", 1, false, user)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "出站单无查询权限!"; objJsonResult.data = null; return objJsonResult; } } //获取系统参数 string Ret = ""; if (oSystemParameter.ShowBill(ref Ret)) { //判断客户为龙山汽配 if (oSystemParameter.omodel.WMS_CampanyName == "龙山汽配") { //获取需要拼接的字符串 string sql_splice = DBUtility.ClsPub.SpliceSQL(user, "工序汇报单列表"); if (sql_splice == "没有查询到相关用户信息") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "没有查询到相关用户信息!"; objJsonResult.data = null; return objJsonResult; } else { sWhere += sql_splice; } } } if (sWhere == null || sWhere.Equals("")) { ds = oCN.RunProcReturn("select * from h_v_MES_StationOutBillList where 1 = 1" + sWhere + "order by hmainid desc", "h_v_MES_StationOutBillList"); } else { string sql1 = "select * from h_v_MES_StationOutBillList where 1 = 1 "; string sql = sql1 + sWhere+ " order by hmainid desc"; ds = oCN.RunProcReturn(sql, "h_v_MES_StationOutBillList"); } //添加列名 foreach (DataColumn col in ds.Tables[0].Columns) { Type dataType = col.DataType; string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}"; columnNameList.Add(JsonConvert.DeserializeObject(ColmString));//获取到DataColumn列对象的列名 } //if (ds.Tables[0].Rows.Count != 0 || ds != null) //{ objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "Sucess!"; objJsonResult.list = columnNameList; objJsonResult.data = ds.Tables[0]; return objJsonResult; //} //else //{ //objJsonResult.code = "0"; //objJsonResult.count = 0; //objJsonResult.Message = "无数据"; //objJsonResult.data = null; //return objJsonResult; //} } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion #region 编辑页面根据id获取工序出站汇报单信息 [Route("Cj_StationOutBill/GetStationOutBill")] [HttpGet] public object GetStationOutBill(int HInterID) { try { ds = oCN.RunProcReturn("select * from h_v_GetStationOutBill where HInterID = " + HInterID, "h_v_GetStationOutBill"); if (ds == null || ds.Tables[0].Rows.Count == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "工序出站汇报单信息获取失败!"; objJsonResult.data = null; return objJsonResult; } else { objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "Sucess!"; objJsonResult.data = ds.Tables[0]; return objJsonResult; } } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion #region 工序出站汇报单文件上传处理 [Route("Cj_StationOutBill/UploadFile1")] [HttpPost] public object UploadFile1() { string HBillNo = HttpContext.Current.Request.Params["HBillNo"]; //单据号 string HRemark = HttpContext.Current.Request.Params["HRemark"]; //备注 string HUserName = HttpContext.Current.Request.Params["HUserName"]; //创建人 HttpPostedFile files = HttpContext.Current.Request.Files["file"]; string path = HttpContext.Current.Server.MapPath("~/../Files/" + HBillNo); //string path = @"D:\\Files\\"+ HBillNo; dynamic dyResult = UpLoadFile(files, path, HBillNo, HRemark, HUserName); if (dyResult != null && dyResult.result == 1) { objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "上传成功!"; objJsonResult.data = null; return objJsonResult; } else { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = dyResult.returnval; objJsonResult.data = null; return objJsonResult; } } public dynamic UpLoadFile(HttpPostedFile files, string path, string HBillNo, string HRemark, string HUserName) { dynamic Result_Ob = new { result = 1, returnval = "上传成功!" }; string filePath = Path.GetFullPath(files.FileName);//文件上传路径 string fileExtension = Path.GetExtension(files.FileName);// 文件扩展名 string filename = files.FileName;//文件名 string fileSavePath = path;// 上传保存路径 int filesize = files.ContentLength;//获取上传文件的大小单位为字节byte int Maxsize = 40000 * 1024;//定义上传文件的最大空间大小为40M try { if (files == null || files.ContentLength <= 0) { Result_Ob = new { result = 0, returnval = "文件不能为空!" }; return Result_Ob; } if (filesize >= Maxsize) { Result_Ob = new { result = 0, returnval = "上传文件超过40M,不能上传!" }; return Result_Ob; } string fileurl = Path.Combine(fileSavePath, filename); if (Directory.Exists(fileurl) == true) //如果存在重名文件就提示 { Result_Ob = new { result = 0, returnval = "存在同名文件!" }; return Result_Ob; } //删除数据表数据 ds = oCN.RunProcReturn("delete from MES_AccessoriesList where HSourceBillNo ='" + HBillNo + "' and HFileName='"+ filename + "'", "MES_AccessoriesList"); if (Directory.Exists(path)) { File.Delete(fileurl); //删除指定文件 files.SaveAs(fileurl); string StrPath = "/files/"+ HBillNo+"/"+ filename; if (File.Exists(fileurl)) { //这里可以执行一些其它的操作,比如更新数据库 //写入数据表 oCN.RunProc("Insert into MES_AccessoriesList (HFileName,HFilePath,HFilePath_Cus,HFileType" + ",HLoadMan,HLoadDate,HRemark,HVerNum,HFileSize" + ",HFileClsID,HSourceBillNo" + ") values('" + filename.ToString() + "','" + StrPath.ToString() + "','" + filePath.ToString() + "','" + fileExtension.ToString() + "'" + ",'" + HUserName + "',getdate(),'" + HRemark + "','V1','" + filesize + "','" + 0 + "','" + HBillNo + "') "); } else { Result_Ob = new { result = 0, returnval = "上传失败!此文件为恶意文件" }; } } else { Directory.CreateDirectory(fileSavePath); //添加文件夹 files.SaveAs(fileurl); string StrPath = "/files/" + HBillNo + "/" + filename; if (File.Exists(fileurl)) { //这里可以执行一些其它的操作,比如更新数据库 //写入数据表 oCN.RunProc("Insert into MES_AccessoriesList (HFileName,HFilePath,HFilePath_Cus,HFileType" + ",HLoadMan,HLoadDate,HRemark,HVerNum,HFileSize" + ",HFileClsID,HSourceBillNo" + ") values('" + filename.ToString() + "','" + StrPath.ToString() + "','" + filePath.ToString() + "','" + fileExtension.ToString() + "'" + ",'" + HUserName + "',getdate(),'" + HRemark + "','V1','" + filesize + "','" + 0 + "','" + HBillNo + "') "); } else { Result_Ob = new { result = 0, returnval = "上传失败!此文件为恶意文件" }; } } } catch(Exception e) { Result_Ob = new { result = 0, returnval = e.Message }; } return Result_Ob; } [Route("Cj_StationOutBill/UploadFile2")] [HttpPost] public object UploadFile2() { string HBillNo = HttpContext.Current.Request.Params["HBillNo"]; //单据号 string HRemark = HttpContext.Current.Request.Params["HRemark"]; //备注 string HUserName = HttpContext.Current.Request.Params["HUserName"]; //创建人 HttpPostedFile files = HttpContext.Current.Request.Files["file"]; string path = HttpContext.Current.Server.MapPath("~/../Files/" + HBillNo); //string path = @"D:\\Files\\"+ HBillNo; dynamic dyResult = UpLoadFile1(files, path, HBillNo, HRemark, HUserName); if (dyResult != null && dyResult.result == 1) { objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "上传成功!"; objJsonResult.data = null; return objJsonResult; } else { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = dyResult.returnval; objJsonResult.data = null; return objJsonResult; } } public dynamic UpLoadFile1(HttpPostedFile files, string path, string HBillNo, string HRemark, string HUserName) { dynamic Result_Ob = new { result = 1, returnval = "上传成功!" }; string filePath = Path.GetFullPath(files.FileName);//文件上传路径 string fileExtension = Path.GetExtension(files.FileName);// 文件扩展名 string filename = files.FileName;//文件名 string fileSavePath = path;// 上传保存路径 int filesize = files.ContentLength;//获取上传文件的大小单位为字节byte int Maxsize = 40000 * 1024;//定义上传文件的最大空间大小为40M try { if (files == null || files.ContentLength <= 0) { Result_Ob = new { result = 0, returnval = "文件不能为空!" }; return Result_Ob; } if (filesize >= Maxsize) { Result_Ob = new { result = 0, returnval = "上传文件超过40M,不能上传!" }; return Result_Ob; } string fileurl = Path.Combine(fileSavePath, filename); if (Directory.Exists(fileurl) == true) //如果存在重名文件就提示 { Result_Ob = new { result = 0, returnval = "存在同名文件!" }; return Result_Ob; } //删除数据表数据 ds = oCN.RunProcReturn("delete from MES_AccessoriesList where HSourceBillNo ='" + HBillNo + "' and HFileName='" + filename + "'", "MES_AccessoriesList"); if (Directory.Exists(path)) { File.Delete(fileurl); //删除指定文件 files.SaveAs(fileurl); string StrPath = "/files/" + HBillNo + "/" + filename; if (File.Exists(fileurl)) { //这里可以执行一些其它的操作,比如更新数据库 //写入数据表 oCN.RunProc("Insert into MES_AccessoriesList (HFileName,HFilePath,HFilePath_Cus,HFileType" + ",HLoadMan,HLoadDate,HRemark,HVerNum,HFileSize" + ",HFileClsID,HSourceBillNo" + ") values('" + filename.ToString() + "','" + StrPath.ToString() + "','" + filePath.ToString() + "','" + fileExtension.ToString() + "'" + ",'" + HUserName + "',getdate(),'" + HRemark + "','V1','" + filesize + "','" + 0 + "','" + HBillNo + "') "); } else { Result_Ob = new { result = 0, returnval = "上传失败!此文件为恶意文件" }; } } else { Directory.CreateDirectory(fileSavePath); //添加文件夹 files.SaveAs(fileurl); string StrPath = "/files/" + HBillNo + "/" + filename; if (File.Exists(fileurl)) { //这里可以执行一些其它的操作,比如更新数据库 //写入数据表 oCN.RunProc("Insert into MES_AccessoriesList (HFileName,HFilePath,HFilePath_Cus,HFileType" + ",HLoadMan,HLoadDate,HRemark,HVerNum,HFileSize" + ",HFileClsID,HSourceBillNo" + ") values('" + filename.ToString() + "','" + fileurl.ToString() + "','" + filePath.ToString() + "','" + fileExtension.ToString() + "'" + ",'" + HUserName + "',getdate(),'" + HRemark + "','V1','" + filesize + "','" + 0 + "','" + HBillNo + "') "); } else { Result_Ob = new { result = 0, returnval = "上传失败!此文件为恶意文件" }; } } } catch (Exception e) { Result_Ob = new { result = 0, returnval = e.Message }; } return Result_Ob; } /// /// 输出json结果 返回2个值 result (输出succes的值) returnval (输出str的值) /// /// /// 是否操作成功,0表示失败;1表示成功 /// 输出字符串 protected void JsonResult(HttpContext context, int success, string str) { context.Response.Write("{\"result\" :\"" + success.ToString() + "\",\"returnval\" :\"" + str + "\"}"); context.Response.End(); } /// /// 根据单据号查找上传文件列表 /// /// /// [Route("Cj_StationOutBill/Filelist")] [HttpGet] public object Filelist(string HBillNo) { var url = fileip + "/files/" + HBillNo+"/"; //@"C:\\files\\" try { ds = oCN.RunProcReturn("select *,'" + url + "'+CAST(HFileName as varchar(200))as url from MES_AccessoriesList where HSourceBillNo='" + HBillNo+"'", "MES_AccessoriesList"); objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "Sucess!"; objJsonResult.data = ds.Tables[0]; return objJsonResult; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } /// /// 根据ID,单据号,文件名 删除文件 /// /// /// [Route("Cj_StationOutBill/DeleteFilelist")] [HttpGet] public object DeleteFilelist(string HItemID, string HSourceBillNo,string HFileName) { try { oCN.RunProc("delete from MES_AccessoriesList where HItemID =" + HItemID); string fileurl = Path.Combine(HttpContext.Current.Server.MapPath("~/../Files/" + HSourceBillNo), HFileName); File.Delete(fileurl); //删除指定文件 objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "删除成功!"; objJsonResult.data = null; return objJsonResult; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion #region 根据id删除出站单 [Route("Cj_StationOutBill/del_StationOutBill")] [HttpGet] public object del_StationOutBill(long HInterID, string HDeleteMan,string HBillSubType) { try { string HComputerName = SystemInformation.ComputerName; //设备名称 if (HBillSubType == "SUB") { //编辑权限 if (!DBUtility.ClsPub.Security_Log("Cj_StationOutBill_Sub_Drop", 1, false, HDeleteMan)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "完工单无权限!"; objJsonResult.data = null; return objJsonResult; } } else { //编辑权限 if (!DBUtility.ClsPub.Security_Log("Cj_StationOutBill_Drop", 1, false, HDeleteMan)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "出站单无权限!"; objJsonResult.data = null; return objJsonResult; } } DAL.ClsSc_StationOutBill oBill = new DAL.ClsSc_StationOutBill(); if (oBill.ShowBill(HInterID, ref DBUtility.ClsPub.sExeReturnInfo)) { string sReturn = ""; if (oSystemParameter.ShowBill(ref sReturn)) { if (oSystemParameter.omodel.MES_StationOutBill_DeleteCtl == "Y") { if (oBill.omodel.HMaker != HDeleteMan && (HDeleteMan != "admin" && HDeleteMan != "Admin")) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "只能删除本人的单据!"; objJsonResult.data = null; return objJsonResult; } } } SQLHelper.ClsCN oCn = new SQLHelper.ClsCN(); DataSet ds; //判断是否存在 相同单据号 的领料单 判断生产订单是否已结案,要求计划手工反结案 ds = oCn.RunProcReturn("exec h_p_MES_StationOutBill_DelCtrl '" + oBill.omodel.HBillNo + "'", "h_p_MES_StationOutBill_DelCtrl"); if (ds == null) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "判断关联失败!"; objJsonResult.data = null; return objJsonResult; } if (ds.Tables[0].Rows.Count > 0 && Pub_Class.ClsPub.isInt(ds.Tables[0].Rows[0][0]) == 2) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = Pub_Class.ClsPub.isStrNull(ds.Tables[0].Rows[0][1]); objJsonResult.data = null; return objJsonResult; } if (oBill.omodel.HChecker != "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据已经审核,不能删除!"; objJsonResult.data = null; return objJsonResult; } ds = oCn.RunProcReturn($"exec h_p_DelOutInBill {HInterID},'MES_StationOutBill_DeleteRelationCtl'", "h_p_DelOutInBill"); if (ds.Tables[0].Rows[0][0].ToString()== "0") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "系统参数控制,已有下道工序,不能删除!"; objJsonResult.data = null; return objJsonResult; } if (!oBill.DeleteBill(oBill.omodel.HInterID, oBill.omodel.HProcExchInterID, oBill.omodel.HProcExchEntryID, ref DBUtility.ClsPub.sExeReturnInfo)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = DBUtility.ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; } else { //写入删除日志 LogService.Write("用户:" + HDeleteMan + ",日期:" + DateTime.Now + ",删除工序出站单据:" + oBill.omodel.HBillNo); oCN.RunProc("Insert into System_log (GeginDate, userid, WorkstationName, WorkList, SystemName, NetuserName, State) select GETDATE(),'" + HDeleteMan + "','" + HComputerName + "','" + "删除工序出站单据:" + oBill.omodel.HBillNo + "','LMES-工序出站模块','" + DBUtility.ClsPub.IPAddress + "','删除单据'", ref DBUtility.ClsPub.sExeReturnInfo); objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "删除成功!"; objJsonResult.data = null; return objJsonResult; } } else { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据未找到!"; objJsonResult.data = null; return objJsonResult; } } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "异常!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion #region 根据单据号 同步报错删除出站单 [Route("Cj_StationOutBill/DelStationOutBill")] [HttpGet] public object DelStationOutBill(string HInterID) { try { DAL.ClsSc_StationOutBill oBill = new DAL.ClsSc_StationOutBill(); SQLHelper.ClsCN oCn = new SQLHelper.ClsCN(); DataTable DTable; int num = 0; //判断入库是否同步 DTable = oCN.RunProcReturn("select * from Sc_StationOutBillMain where HInterID='" + HInterID + "' and HRelationQty=0", "Sc_StationOutBillMain").Tables[0]; if (DTable.Rows.Count != 0) { num++; } //判断本次报废是否同步 DTable = oCN.RunProcReturn("select * from Sc_StationOutBillMain where HProcExchInterID='" + DTable.Rows[0]["HProcExchInterID"].ToString() + "' and HBFFlag=0 ", "Sc_StationOutBillMain").Tables[0]; if (DTable.Rows.Count != 0) { num++; } if (num == 2) { if (!oBill.DeleteBill(long.Parse(HInterID), 0, 0, ref DBUtility.ClsPub.sExeReturnInfo)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = DBUtility.ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; } else { objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "删除成功!"; objJsonResult.data = null; return objJsonResult; } } else { objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "无须删除!"; objJsonResult.data = null; return objJsonResult; } } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "异常!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion #region 编辑前判断 [Route("Cj_StationOutBill/set_ShowBillJudge")] [HttpGet] public object set_ShowBillJudge(string HBillNo) { try { ds = oCN.RunProcReturn("exec h_p_MES_StationOutBill_DelCtrl '" + HBillNo + "'", "h_p_MES_StationOutBill_DelCtrl"); if (ds == null || ds.Tables[0].Rows.Count == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "判断关联失败!"; objJsonResult.data = null; return objJsonResult; } else if (ds.Tables[0].Rows.Count > 0 && Pub_Class.ClsPub.isInt(ds.Tables[0].Rows[0][0]) == 2) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = Pub_Class.ClsPub.isStrNull(ds.Tables[0].Rows[0][1]); objJsonResult.data = null; return objJsonResult; } else { objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "Sucess!"; objJsonResult.data = ds.Tables[0]; return objJsonResult; } } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion #region 审核 [Route("Cj_StationOutBill/set_CheckBill")] [HttpGet] public object set_CheckBill(string HInterID, string CurUserName,string HBillSubType) { try { if (HBillSubType == "SUB") { ////审核权限 if (!DBUtility.ClsPub.Security_Log("Cj_StationOutBill_Sub_Check", 1, false, CurUserName)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "完工单审核失败!无权限!"; objJsonResult.data = null; return objJsonResult; } } else { ////审核权限 if (!DBUtility.ClsPub.Security_Log("Cj_StationOutBill_Check", 1, false, CurUserName)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "出站单审核失败!无权限!"; objJsonResult.data = null; return objJsonResult; } } var HBillNo = HInterID.Split(','); DAL.ClsSc_StationOutBill oBill = new DAL.ClsSc_StationOutBill(); for (int i = 0; i < HBillNo.Length; i++) { if (HBillNo[i] == "0") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "第"+(i+1)+"行:单据ID为0,不能审核!"; objJsonResult.data = null; return objJsonResult; } //查看是否已审核,关闭,作废 if (oBill.ShowBill(long.Parse(HBillNo[i]), ref DBUtility.ClsPub.sExeReturnInfo)) { if (oBill.omodel.HChecker.Trim() != "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "第" + (i + 1) + "行:单据已审核!不能再次审核"; objJsonResult.data = null; return objJsonResult; } } else { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "第" + (i + 1) + "行:单据不存在!原因:" + DBUtility.ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; } } int j = 0; for (int i = 0; i < HBillNo.Length; i++) { //审核 if (Cj_StationOutBillCheckBill(long.Parse(HBillNo[i]), CurUserName, oBill.omodel.HLastSubProc, ref DBUtility.ClsPub.sExeReturnInfo)) { j += 1; } else { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "成功:" + j + "行,第" + (i + 1) + "行:审核失败!原因:" + DBUtility.ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; } } objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "全部执行成功!"; objJsonResult.data = null; return objJsonResult; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "审核失败!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } //审核 public bool Cj_StationOutBillCheckBill(Int64 lngBillKey, string CurUserName,bool HLastSubProc, ref string sReturn) { try { string HChecker = CurUserName; string HCheckDate = DBUtility.ClsPub.GetServerDate(-1); oCN.BeginTran(); ds = oCN.RunProcReturn("Select * from Sc_StationOutBillMain Where HInterID=" + lngBillKey.ToString(), "Sc_StationOutBillMain"); if (ds.Tables[0].Rows.Count == 0) { sReturn = "单据未找到!"; return false; } oCN.RunProc(" Update Sc_StationOutBillMain set HChecker='" + HChecker + "',HCheckDate='" + HCheckDate + "' Where HInterID=" + lngBillKey.ToString()); oCN.RunProc("exec h_p_Mes_ProcessExchangeRelationQty_Check_In " + lngBillKey.ToString() + ",1"); //判断是否是 末道工序 DataSet ds1; ds1 = oCN.RunProcReturn("select HLastProc,HFstProc " + " from Sc_ProcessExchangeBillMain a " + " inner join Sc_ProcessExchangeBillSub b on a.HInterID=b.HInterID " + " Where a.HInterID=(Select HProcExchInterID from Sc_StationOutBillMain Where HInterID=" + lngBillKey + ") " + " and b.HEntryID=(Select HProcExchEntryID from Sc_StationOutBillMain Where HInterID=" + lngBillKey + ")", "Sc_ProcessExchangeBillMain"); if (ds1 == null || ds1.Tables[0].Rows.Count == 0 || HLastSubProc ==false) { } else if (Pub_Class.ClsPub.isStrNull(ds1.Tables[0].Rows[0]["HFstProc"]) == "是") { } sReturn = sReturn + " 审核功能!"; oCN.Commit(); return true; } catch (Exception e) { sReturn = e.Message; oCN.RollBack(); return false; ; } } #endregion #region 反审核 [Route("Cj_StationOutBill/set_AbandonCheck")] [HttpGet] public object set_AbandonCheck(string HInterID, string CurUserName,string HBillSubType) { try { if (HBillSubType == "SUB") { ////审核权限 if (!DBUtility.ClsPub.Security_Log("Cj_StationOutBill_Sub_Check", 1, false, CurUserName)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "完工单反审核失败!无权限!"; objJsonResult.data = null; return objJsonResult; } } else { ////审核权限 if (!DBUtility.ClsPub.Security_Log("Cj_StationOutBill_Check", 1, false, CurUserName)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "出站单反审核失败!无权限!"; objJsonResult.data = null; return objJsonResult; } } var HBillNo = HInterID.Split(','); DAL.ClsSc_StationOutBill oBill = new DAL.ClsSc_StationOutBill(); //获取系统参数 string Ret = ""; oSystemParameter.ShowBill(ref Ret); for (int i = 0; i < HBillNo.Length; i++) { if (long.Parse(HBillNo[i]) == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "第" + (i + 1) + "行:单据ID为0,不能反审核!"; objJsonResult.data = null; return objJsonResult; } //查看是否已审核,关闭,作废 if (oBill.ShowBill(long.Parse(HBillNo[i]), ref DBUtility.ClsPub.sExeReturnInfo)) { if (oBill.omodel.HChecker.Trim() == "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "第" + (i + 1) + "行:单据未审核!不需要反审核!"; objJsonResult.data = null; return objJsonResult; } //审核人必须和反审核人保持一致 乔一 if (oSystemParameter.omodel.WMS_CampanyName == "乔一") { if (oBill.omodel.HChecker.Trim() != CurUserName) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "第" + (i + 1) + "行:审核人和反审核人不一致!"; objJsonResult.data = null; return objJsonResult; } } } else { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "第" + (i + 1) + "行:单据不存在!原因:" + DBUtility.ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; } } int j = 0; for (int i = 0; i < HBillNo.Length; i++) { //反审核 if (Cj_StationOutBillAbandonCheckBill(long.Parse(HBillNo[i]), CurUserName, oBill.omodel.HLastSubProc, ref DBUtility.ClsPub.sExeReturnInfo)) { j += 1; } else { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "成功:" + j + "行,第" + (i + 1) + "行:反审核失败!原因:" + DBUtility.ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; } } objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "全部执行成功!"; objJsonResult.data = null; return objJsonResult; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "反审核失败!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } //反审核 public bool Cj_StationOutBillAbandonCheckBill(Int64 lngBillKey, string CurUserName, bool HLastSubProc, ref string sReturn) { if (Cj_StationInBillisUse(lngBillKey, ref sReturn)) { return false; } try { string HChecker = CurUserName; string HCheckDate = DBUtility.ClsPub.GetServerDate(-1); oCN.BeginTran(); ds = oCN.RunProcReturn("Select * from Sc_StationOutBillMain Where HInterID=" + lngBillKey.ToString(), "Sc_StationOutBillMain"); if (ds.Tables[0].Rows.Count == 0) { sReturn = "单据未找到!"; return false; } oCN.RunProc(" Update Sc_StationOutBillMain set HChecker='',HCheckDate=null Where HInterID=" + lngBillKey.ToString()); //oCN.RunProc("exec h_p_Mes_ProcessExchangeRelationQty_Check_Out " + lngBillKey.ToString() + ",-1"); //判断是否是 首道工序 DataSet ds1; ds1 = oCN.RunProcReturn("select HLastProc,HFstProc " + " from Sc_ProcessExchangeBillMain a " + " inner join Sc_ProcessExchangeBillSub b on a.HInterID=b.HInterID " + " Where a.HInterID=(Select HProcExchInterID from Sc_StationOutBillMain Where HInterID=" + lngBillKey + ") " + " and b.HEntryID=(Select HProcExchEntryID from Sc_StationOutBillMain Where HInterID=" + lngBillKey + ")", "Sc_ProcessExchangeBillMain"); if (ds1 == null || ds1.Tables[0].Rows.Count == 0) { } else if (Pub_Class.ClsPub.isStrNull(ds1.Tables[0].Rows[0]["HFstProc"]) == "是") { } sReturn = sReturn + "反审核功能!"; oCN.Commit(); return true; } catch (Exception e) { sReturn = e.Message; oCN.RollBack(); return false; ; } } #region 工序出站关闭/反关闭功能 [Route("Cj_StationOutBill/CloseCj_StationOutBill")] [HttpGet] public object CloseCj_StationOutBill(string HInterID, int Type, string user,string HBillSubType) { try { if (HBillSubType == "SUB") { //判断是否有删除权限 if (!DBUtility.ClsPub.Security_Log("Cj_StationOutBill_Sub_Close", 1, false, user)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "完工单无权限关闭!"; objJsonResult.data = null; return objJsonResult; } } else { //判断是否有删除权限 if (!DBUtility.ClsPub.Security_Log("Cj_StationOutBill_Close", 1, false, user)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "出站单无权限关闭!"; objJsonResult.data = null; return objJsonResult; } } if (string.IsNullOrWhiteSpace(HInterID)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "HInterID为空!"; objJsonResult.data = null; return objJsonResult; } ClsPub.CurUserName = user; BillOld.MvarItemKey = "Sc_StationOutBillMain"; oCN.BeginTran();//开始事务 //Type 1 关闭 2 反关闭 if (Type == 1) { //判断单据是否已经关闭 DataSet ds; string sql = "select * from " + BillOld.MvarItemKey + " where HinterID = " + HInterID; ds = oCN.RunProcReturn(sql, BillOld.MvarItemKey); if (ds.Tables[0] != null && ds.Tables[0].Rows.Count > 0) { if (ds.Tables[0].Rows[0]["HCloseMan"] != null && ds.Tables[0].Rows[0]["HCloseMan"].ToString() != "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据已关闭!不需要再关闭!"; objJsonResult.data = null; return objJsonResult; } } //关闭单据 if (!BillOld.CloseBill(Int64.Parse(HInterID), ref ClsPub.sExeReturnInfo)) { objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "关闭失败!原因:" + ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; } } else { //判断单据是否已经反关闭 DataSet ds; string sql = "select * from " + BillOld.MvarItemKey + " where HinterID = " + HInterID; ds = oCN.RunProcReturn(sql, BillOld.MvarItemKey); if (ds.Tables[0] != null && ds.Tables[0].Rows.Count > 0) { if (ds.Tables[0].Rows[0]["HCloseMan"] == null || ds.Tables[0].Rows[0]["HCloseMan"].ToString() == "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据已反关闭!不需要再反关闭!"; objJsonResult.data = null; return objJsonResult; } } //反关闭单据 if (!BillOld.CancelClose(Int64.Parse(HInterID), ref ClsPub.sExeReturnInfo)) { objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "反关闭失败!原因:" + ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; } } oCN.Commit();//提交事务 objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "执行成功!"; objJsonResult.data = null; return objJsonResult; ; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "执行失败!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion //是否被关联 public bool Cj_StationInBillisUse(Int64 lngBillKey, ref string sReturn) { try { //查询主表 DataSet Ds; //Ds = oCN.RunProcReturn("Select HinterID from " + MvarItemKeySub + " Where HInterID=" + lngBillKey.ToString() + " and isnull(HRelationQty,0)<>0 ", MvarItemKey); //if (Ds.Tables[0].Rows.Count != 0) //{ // sReturn = "单据已被关联,不能操作!"; // return true; //} sReturn = ""; return false; } catch (Exception e) { sReturn = e.Message; throw (e); } } #endregion //批量出站 #region 批量出站模块返回明细信息列表 [Route("Cj_StationOutBill/get_BarCodeDetail")] [HttpGet] public object get_BarCodeDetail(string HMainInterID) { try { ds = oCN.RunProcReturn( "select a.HBillNo,a.HInterID,a.HQty,a.HProcExchBillNo,a.HICMOBillNo" + ",b.HNumber HMaterNumber,b.HName HMaterName,b.HModel HMaterModel,c.HName HSourceName,d.HName HGroupName" + ",e.HName HEmpName,a.HMaker,a.HMakeDate " + " from Sc_StationOutBillMain a " + " left join Gy_Material b on a.HMaterID = b.HItemID " + " left join Gy_Source c on a.HSourceID = c.HItemID " + " left join Gy_Group d on a.HGroupID = d.HItemID " + " left join Gy_Employee e on a.HEmpID = e.HItemID " + " where HMainInterID = " + HMainInterID + " order by a.HMakeDate desc", "Sc_StationOutBillMain"); if (ds == null || ds.Tables[0].Rows.Count == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "无返回记录!"; objJsonResult.data = null; return objJsonResult; } else { objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "返回记录成功!"; objJsonResult.data = ds.Tables[0]; return objJsonResult; } } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "查询数据异常,请与管理员联系!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion #region 返回工序出站汇报单明细列表 [Route("Cj_StationOutBill_Detail/get_Display2")] [HttpGet] public object get_Display2(string HMaterID, string HWorkProcID, string HProcExchBillNo) { try { ds = oCN.RunProcReturn("select * from h_v_GetStationOutBill_Detail where 工序ID = " + HWorkProcID + " and 物料ID = " + HMaterID + " and 流转卡号 = '" + HProcExchBillNo + "'" , "h_v_GetStationOutBill_Detail"); if (ds == null || ds.Tables[0].Rows.Count == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "工序出站汇报单明细信息获取失败!"; objJsonResult.data = null; return objJsonResult; } else { objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "Sucess!"; objJsonResult.data = ds.Tables[0]; return objJsonResult; } } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion #region 明细 保存/编辑功能 [Route("Cj_StationOutBill/AddBill_Detail")] [HttpPost] public object AddBill_Detail([FromBody] JObject sMain) { try { var _value = sMain["sMainSub"].ToString(); string msg1 = _value.ToString(); oCN.BeginTran(); //保存主表 objJsonResult = Add_Detail(msg1); if (objJsonResult.code == "0") { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = objJsonResult.Message; objJsonResult.data = null; return objJsonResult; } oCN.Commit(); objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "单据保存成功!"; objJsonResult.data = null; return objJsonResult; } catch (Exception e) { oCN.RollBack(); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "保存失败!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } public json Add_Detail(string msg1) { string[] sArray = msg1.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries); string msg2 = sArray[0].ToString(); //表头数据 string msg3 = sArray[1].ToString(); //表体数据 var a = sArray[2].ToString(); int OperationType = int.Parse(sArray[2].ToString()); // 数据类型 1添加 3修改 string user = sArray[3].ToString(); //用户名 try { msg2 = "[" + msg2.ToString() + "]"; List mainList = Newtonsoft.Json.JsonConvert.DeserializeObject>(msg2); List subList = Newtonsoft.Json.JsonConvert.DeserializeObject>(msg3); long HInterID = mainList[0].HInterID; long HWorkEmpID = subList[0].HWorkEmpID; long HWorkSourceID = subList[0].HWorkSourceID; decimal HQty = subList[0].HQty; decimal HRate = subList[0].HRate; decimal HProcPrice = subList[0].HProcPrice; decimal HMoney = subList[0].HMoney; long HWorkProcID = mainList[0].HWorkProcID; var EntryID = 0; foreach (ClsSc_StationOutBillSub_Emp oSub in subList) { //ds = oCN.RunProcReturn("select * from h_v_IF_ICMOBillList where hmainid=" + HInterID + " and 单据号='" + HBillNo + "'", "h_v_IF_ICMOBillList"); if ((OperationType == 1 || OperationType == 2))//新增 && ds.Tables[0].Rows.Count == 0 { EntryID++; string sql = string.Empty; sql = $@" Insert into Sc_StationOutBillSub_Emp (HInterID,HEntryID,HBillNo_bak ,HRemark ,HSourceInterID ,HSourceEntryID ,HSourceBillNo ,HSourceBillType ,HRelationQty ,HRelationMoney ,HWorkEmpID ,HWorkSourceID ,HQty ,HRate ,HProcPrice ,HMoney ,HWorkProcID) values(" + HInterID + "," + EntryID + "," + "'" + mainList[0].HBillNo_bak + "','" + mainList[0].HRemark + "'," + 0 + "," + 0 + ",'" + " " + "','" + " " + "'," + "0" + "," + 0 + "," + oSub.HWorkEmpID + "," + oSub.HWorkSourceID + "," + oSub.HQty + "," + oSub.HRate + "," + oSub.HProcPrice + "," + oSub.HMoney + "," + HWorkProcID + ")"; oCN.RunProc(sql); } } objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = null; objJsonResult.data = null; return objJsonResult; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception!" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion } }