智云MES后端API代码
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
yusijie
2025-04-07 4f09261581ae965fd224985d04aa565e4c310920 
 WebAPI/Controllers/CJGL/Cj_StationInBillController.cs


@@ -6,6 +6,8 @@


using System.Collections.Generic;


using System.Data;


using System.Data.SqlClient;


using System.IO;


using System.Web;


using System.Web.Http;


using System.Windows.Forms;


using WebAPI.Models;


@@ -23,6 +25,7 @@


        private json objJsonResult = new json();


        SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();


        public DAL.ClsSc_ICMOBill BillOld = new DAL.ClsSc_ICMOBill();


        string fileip = System.Configuration.ConfigurationManager.AppSettings["FileIP"];


        DataSet ds;


        DataSet ds1;




@@ -386,7 +389,7 @@




                }




                //=========================保存后控制  


                //=========================保存后控制  ============================


                DataSet ds2 = oCN.RunProcReturn("Exec h_p_Sc_StationInBill_AfterSaveCtrl " + HInterID.ToString() + ", '" + HBillNo + "',1 ", "h_p_Sc_StationInBill_AfterSaveCtrl");


                if (ds2 == null)


                {


@@ -407,7 +410,7 @@


                    objJsonResult.data = null;


                    return objJsonResult;


                }


                //============================


                //=======================================================




                oCN.Commit();


               


@@ -632,7 +635,6 @@


        }


        #endregion






        #region 工序进站接收单流水号回车获取工序信息


        [Route("Cj_StationInBill/txtHProcNo_KeyDown_qiaoyi")]


        [HttpGet]


@@ -678,8 +680,6 @@


        }


        #endregion








        #region 工序进站接收单根据职员代码模糊回车查询


        [Route("Cj_StationInBill/GetMessageByEmpNumber")]


        [HttpGet]


@@ -714,8 +714,6 @@


            }


        }


        #endregion








        #region 工序进站接收单根据物料代码模糊回车查询


        [Route("Cj_StationInBill/GetMessageByMaterNumber")]


@@ -752,9 +750,6 @@


        }


        #endregion










        #region 返回工序进站接收单列表


        [Route("Cj_StationInBill/get_Display")]


        [HttpGet]


@@ -782,7 +777,7 @@


                    {


                        objJsonResult.code = "0";


                        objJsonResult.count = 0;


                        objJsonResult.Message = "进站单无查询权限!";


                        objJsonResult.Message = "进站单无查询权限!";    


                        objJsonResult.data = null;


                        return objJsonResult;


                    }


@@ -995,8 +990,6 @@


        {


            try


            {


                string ModRightNameCheck = "";




                if (HBillSubType == "SUB")


                {


                    //审核权限


@@ -1051,7 +1044,7 @@


                    return objJsonResult;


                }




                //审核前控制


                //审核前控制==========================================================================


                string HBillNo = oBill.omodel.HBillNo;


                string sql = "exec h_p_Sc_StationInBill_BeforeCheckCtrl " + HInterID + ",'" + HBillNo + "','" + CurUserName + "'";


                ds = oCN.RunProcReturn(sql, "h_p_Sc_StationInBill_BeforeCheckCtrl");


@@ -1072,7 +1065,7 @@


                    objJsonResult.data = null;


                    return objJsonResult;


                }




                //=============================================================================


                //审核


                if (Cj_StationInBillCheckBill(HInterID, HBillNo, CurUserName, ref DBUtility.ClsPub.sExeReturnInfo))


                {


@@ -1132,7 +1125,7 @@


                {


                }




                //审核后控制


                //审核后控制=======================================================


                string sql = "exec h_p_Sc_StationInBill_AfterCheckCtrl " + lngBillKey + ",'" + HBillNo + "','" + CurUserName + "'";


                ds = oCN.RunProcReturn(sql, "h_p_Sc_StationInBill_AfterCheckCtrl");


                if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)


@@ -1147,7 +1140,7 @@


                    oCN.RollBack();


                    return false;


                }




                //====================================================================


                sReturn = sReturn + " 审核功能！";


                oCN.Commit();


                return true;


@@ -1225,7 +1218,7 @@


                    return objJsonResult;


                }




                //反审核前控制


                //反审核前控制=============================================================================


                string HBillNo = oBill.omodel.HBillNo;


                string sql = "exec h_p_Sc_StationInBill_BeforeUnCheckCtrl " + HInterID + ",'" + HBillNo + "','" + CurUserName + "'";


                ds = oCN.RunProcReturn(sql, "h_p_Sc_StationInBill_BeforeUnCheckCtrl");


@@ -1246,7 +1239,7 @@


                    objJsonResult.data = null;


                    return objJsonResult;


                }




                //============================================================================================


                //反审核


                if (Cj_StationInBillAbandonCheckBill(HInterID, HBillNo, CurUserName, ref DBUtility.ClsPub.sExeReturnInfo))


                {


@@ -1310,7 +1303,7 @@


                {


                }




                //反审核后控制


                //反审核后控制========================================================================


                string sql = "exec h_p_Sc_StationInBill_AfterUnCheckCtrl " + lngBillKey + ",'" + HBillNo + "','" + CurUserName + "'";


                ds = oCN.RunProcReturn(sql, "h_p_Sc_StationInBill_AfterUnCheckCtrl");


                if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)


@@ -1325,7 +1318,7 @@


                    oCN.RollBack();


                    return false;


                }




                //============================================================================================


                sReturn = sReturn + "反审核功能！";


                oCN.Commit();


                return true;


@@ -1425,8 +1418,32 @@


                            return objJsonResult;


                        }


                    }


                    var HBillNo = ds.Tables[0].Rows[0]["HBillNo"].ToString();




                    //关闭前控制=========================================      


                    string sql1 = "exec h_p_Sc_ShiftsBeginInfoBill_BeforeCloseCtrl " + HInterID + ",'" +HBillNo + "','" + user + "'";


                    ds = oCN.RunProcReturn(sql1, "h_p_Sc_ShiftsBeginInfoBill_BeforeCloseCtrl");


                    if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)


                    {


                        objJsonResult.code = "0";


                        objJsonResult.count = 1;


                        objJsonResult.Message = "关闭失败!原因:关闭前判断失败，请与网络管理人员联系";


                        objJsonResult.data = null;


                        return objJsonResult;


                    }




                    if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")


                    {


                        objJsonResult.code = "0";


                        objJsonResult.count = 1;


                        objJsonResult.Message = "关闭失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;


                        objJsonResult.data = null;


                        return objJsonResult;


                    }


                    //==================================================================================    




                    //关闭单据


                    if (!BillOld.CloseBill(Int64.Parse(HInterID), ref ClsPub.sExeReturnInfo))


                    if (!BillOld.CloseBill(Int64.Parse(HInterID), HBillNo, "h_p_Sc_ShiftsBeginInfoBill_AfterCloseCtrl", user,ref ClsPub.sExeReturnInfo))


                    {


                        objJsonResult.code = "0";


                        objJsonResult.count = 1;


@@ -1452,8 +1469,32 @@


                            return objJsonResult;


                        }


                    }


                    var HBillNo = ds.Tables[0].Rows[0]["HBillNo"].ToString();


                    //反关闭前控制=========================================      


                    string sql1 = "exec h_p_Sc_StationInBill_BeforeUnCloseCtrl " + HInterID + ",'" + HBillNo + "','" + user + "'";


                    ds = oCN.RunProcReturn(sql1, "h_p_Sc_StationInBill_BeforeUnCloseCtrl");


                    if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)


                    {


                        objJsonResult.code = "0";


                        objJsonResult.count = 1;


                        objJsonResult.Message = "反关闭失败!原因:反关闭前判断失败，请与网络管理人员联系";


                        objJsonResult.data = null;


                        return objJsonResult;


                    }




                    if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")


                    {


                        objJsonResult.code = "0";


                        objJsonResult.count = 1;


                        objJsonResult.Message = "反关闭失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;


                        objJsonResult.data = null;


                        return objJsonResult;


                    }


                    //==================================================================================      






                    //反关闭单据


                    if (!BillOld.CancelClose(Int64.Parse(HInterID), ref ClsPub.sExeReturnInfo))


                    if (!BillOld.CancelClose(Int64.Parse(HInterID), HBillNo, "h_p_Sc_StationInBill_AfterUnCloseCtrl", user, ref ClsPub.sExeReturnInfo))


                    {


                        objJsonResult.code = "0";


                        objJsonResult.count = 1;


@@ -1778,5 +1819,188 @@


            }


        }


        #endregion




        #region  工序进站汇报单文件上传处理




        [Route("Cj_StationInBill/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/Cj_StationInBill/" + 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/Cj_StationInBill/" + 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/Cj_StationInBill/" + 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;


        }  






        /// <summary>


        /// 根据单据号查找上传文件列表


        /// </summary>


        /// <param name="sWhere"></param>


        /// <returns></returns>


        [Route("Cj_StationInBill/Filelist")]


        [HttpGet]


        public object Filelist(string HBillNo)


        {


            var url = fileip + "/files/Cj_StationInBill/" + 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;


            }


        }




        /// <summary>


        /// 根据ID,单据号,文件名 删除文件


        /// </summary>


        /// <param name="sWhere"></param>


        /// <returns></returns>


        [Route("Cj_StationInBill/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/Cj_StationInBill/" + 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


    }


}