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.Web.Http; 
 | 
using WebAPI.Models; 
 | 
using WebAPI.Service; 
 | 
  
 | 
namespace WebAPI.Controllers 
 | 
{ 
 | 
    //生产资源Controller 
 | 
    public class Gy_SourceController : ApiController 
 | 
    { 
 | 
        public DBUtility.ClsPub.Enum_BillStatus BillStatus; 
 | 
  
 | 
        private json objJsonResult = new json(); 
 | 
        SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); 
 | 
        DataSet ds; 
 | 
  
 | 
  
 | 
        /// <summary> 
 | 
        /// 返回生产资源列表 
 | 
        ///参数:string sql。 
 | 
        ///返回值:object。 
 | 
        /// </summary> 
 | 
        [Route("Gy_Source/list")] 
 | 
        [HttpGet] 
 | 
        public object list(string sWhere) 
 | 
        { 
 | 
            try 
 | 
            { 
 | 
                if (sWhere == null || sWhere.Equals("")) 
 | 
                { 
 | 
                    ds = oCN.RunProcReturn("select * from h_v_IF_SourceList where 1=1 ", "h_v_IF_SourceList"); 
 | 
                } 
 | 
                else 
 | 
                { 
 | 
                    string sql1 = "select * from h_v_IF_SourceList where 1=1 "; 
 | 
                    string sql = sql1 + sWhere; 
 | 
                    ds = oCN.RunProcReturn(sql, "h_v_IF_SourceList"); 
 | 
                } 
 | 
                if (ds == null || ds.Tables[0].Rows.Count == 0) 
 | 
                { 
 | 
                    objJsonResult.code = "0"; 
 | 
                    objJsonResult.count = 0; 
 | 
                    objJsonResult.Message = "false!"; 
 | 
                    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; 
 | 
            } 
 | 
        } 
 | 
  
 | 
        /// <summary> 
 | 
        /// 保存生产资源 
 | 
        /// </summary> 
 | 
        /// <param name="msg"></param> 
 | 
        /// <returns></returns> 
 | 
        [Route("SaveGy_SourceList")] 
 | 
        [HttpPost] 
 | 
        public object SaveGy_SourceList([FromBody] JObject msg) 
 | 
        { 
 | 
            DataSet ds; 
 | 
            var _value = msg["msg"].ToString(); 
 | 
            string msg1 = _value.ToString(); 
 | 
            //string[] sArray = msg1.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries); 
 | 
            //string msg2 = sArray[0].ToString(); 
 | 
            //string msg3 = sArray[1].ToString(); 
 | 
            Int64 HItemID = 0; 
 | 
            SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); 
 | 
            //获取最大ID值赋值 
 | 
            DataSet Maxds = oCN.RunProcReturn("select MAX(HItemID) HItemID from Gy_Source ", "Gy_Unit"); 
 | 
            if (Maxds != null || Maxds.Tables[0].Rows.Count > 0) 
 | 
            { 
 | 
                //HItemID= Maxds.Tables[0].Rows[0]["HItemID"] 
 | 
                var maxid = Convert.ToInt32(Maxds.Tables[0].Rows[0]["HItemID"]); 
 | 
                maxid += 1; 
 | 
                HItemID = maxid; 
 | 
            } 
 | 
            ListModels oListModels = new ListModels(); 
 | 
            try 
 | 
            { 
 | 
                DAL.ClsGy_Source_Ctl oBill = new DAL.ClsGy_Source_Ctl(); 
 | 
                List<Model.ClsGy_Source_Model> lsmain = new List<Model.ClsGy_Source_Model>(); 
 | 
                msg1 = msg1.Replace("\\", ""); 
 | 
                msg1 = msg1.Replace("\n", "");  //\n 
 | 
                lsmain = oListModels.getObjectByJson_Gy_Source(msg1); 
 | 
                foreach (Model.ClsGy_Source_Model oItem in lsmain) 
 | 
                { 
 | 
                    if (oItem.HNumber.Trim() == "") 
 | 
                    { 
 | 
                        objJsonResult.code = "0"; 
 | 
                        objJsonResult.count = 0; 
 | 
                        objJsonResult.Message = "保存失败!代码不能为空!"; 
 | 
                        objJsonResult.data = 1; 
 | 
                        return objJsonResult; 
 | 
                    } 
 | 
                    if (oItem.HName.Trim() == "") 
 | 
                    { 
 | 
                        objJsonResult.code = "0"; 
 | 
                        objJsonResult.count = 0; 
 | 
                        objJsonResult.Message = "保存失败!名称不能为空!"; 
 | 
                        objJsonResult.data = 1; 
 | 
                        return objJsonResult; 
 | 
                    } 
 | 
                    if (!DBUtility.ClsPub.AllowNumber(oItem.HNumber.Trim())) 
 | 
                    { 
 | 
                        objJsonResult.code = "0"; 
 | 
                        objJsonResult.count = 0; 
 | 
                        objJsonResult.Message = "保存失败!代码中不能出现连续‘.’并且首位末位不能为‘.’!"; 
 | 
                        objJsonResult.data = 1; 
 | 
                        return objJsonResult; 
 | 
                    } 
 | 
                    //查询数据中是否存在重复代码 
 | 
  
 | 
                    ds = oCN.RunProcReturn("select * from  Gy_Source where HStopflag=0 and HNumber='" + oItem.HNumber.Trim() + "'", "Gy_Source"); 
 | 
                    if (oItem.HNumber.Trim() == "") 
 | 
                    { 
 | 
                        objJsonResult.code = "0"; 
 | 
                        objJsonResult.count = 0; 
 | 
                        objJsonResult.Message = "保存失败!代码为空!"; 
 | 
                        objJsonResult.data = 1; 
 | 
                        return objJsonResult; 
 | 
                    } 
 | 
                    //新增时判断 
 | 
                    if (oItem.HItemID == 0) 
 | 
                    { 
 | 
                        if (ds == null || ds.Tables[0].Rows.Count == 0) 
 | 
                        { 
 | 
  
 | 
                        } 
 | 
                        else 
 | 
                        { 
 | 
                            objJsonResult.code = "0"; 
 | 
                            objJsonResult.count = 0; 
 | 
                            objJsonResult.Message = "保存失败!代码重复!"; 
 | 
                            objJsonResult.data = 1; 
 | 
                            return objJsonResult; 
 | 
                        } 
 | 
                        //检查父级是否存在 
 | 
                        string sParent; 
 | 
                        sParent = DBUtility.ClsPub.GetParentCode(oItem.HNumber.Trim()); 
 | 
                        if (sParent.Trim() == "") 
 | 
                        { 
 | 
                            oBill.oModel.HParentID = 0; 
 | 
                        } 
 | 
                        else 
 | 
                        { 
 | 
                            if (oBill.HavParentCode(sParent.Trim(), HItemID)) 
 | 
                            { 
 | 
                                oBill.oModel.HParentID = oBill.oModel.HItemID; 
 | 
                            } 
 | 
                            else 
 | 
                            { 
 | 
                                objJsonResult.code = "0"; 
 | 
                                objJsonResult.count = 0; 
 | 
                                objJsonResult.Message = "保存失败!上级代码不存在或被禁用!"; 
 | 
                                objJsonResult.data = 1; 
 | 
                                return objJsonResult; 
 | 
                            } 
 | 
                        } 
 | 
                    } 
 | 
                    else//编辑时判断 
 | 
                    { 
 | 
                        //检查父级是否存在 
 | 
                        string sParent; 
 | 
                        sParent = DBUtility.ClsPub.GetParentCode(oItem.HNumber.Trim()); 
 | 
                        if (sParent.Trim() == "") 
 | 
                        { 
 | 
                            oBill.oModel.HParentID = 0; 
 | 
                        } 
 | 
                        else 
 | 
                        { 
 | 
                            if (oBill.HavParentCode(sParent.Trim(), oItem.HItemID)) 
 | 
                            { 
 | 
                                oBill.oModel.HParentID = oBill.oModel.HItemID; 
 | 
                            } 
 | 
                            else 
 | 
                            { 
 | 
                                objJsonResult.code = "0"; 
 | 
                                objJsonResult.count = 0; 
 | 
                                objJsonResult.Message = "保存失败!上级代码不存在或被禁用!"; 
 | 
                                objJsonResult.data = 1; 
 | 
                                return objJsonResult; 
 | 
                            } 
 | 
                        } 
 | 
                    } 
 | 
                    //得到短代码 
 | 
                    string sShortNumber; 
 | 
                    sShortNumber = DBUtility.ClsPub.GetShortNumber(oItem.HNumber.Trim()); 
 | 
                    if (sShortNumber.Trim() == "") 
 | 
                    { 
 | 
                        objJsonResult.code = "0"; 
 | 
                        objJsonResult.count = 0; 
 | 
                        objJsonResult.Message = "保存失败!短代码为空!"; 
 | 
                        objJsonResult.data = 1; 
 | 
                        return objJsonResult; 
 | 
                    } 
 | 
                    oItem.HShortNumber = sShortNumber;//短代码 
 | 
                    oItem.HEndFlag = true;//末级标志 
 | 
                    oItem.HLevel = DBUtility.ClsPub.GetLevel(oItem.HNumber.Trim()); //等级 
 | 
                    oItem.HEquipFileID_K3 = 0;//对应K3设备 
 | 
                    oItem.HGroupK3ID = 0;//默认K3生产班组     
 | 
                    oBill.oModel = oItem; 
 | 
                } 
 | 
  
 | 
                //保存 
 | 
                //保存完毕后处理 
 | 
                bool bResult; 
 | 
                if (oBill.oModel.HItemID == 0) 
 | 
                { 
 | 
                    // bResult = oBill.AddBill(ref DBUtility.ClsPub.sExeReturnInfo); 
 | 
                    bResult = oBill.AddNew(); 
 | 
                } 
 | 
                else 
 | 
                { 
 | 
                    bResult = oBill.ModifyByID(oBill.oModel.HItemID); 
 | 
                } 
 | 
                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; 
 | 
                } 
 | 
            } 
 | 
            catch (Exception e) 
 | 
            { 
 | 
                objJsonResult.code = "0"; 
 | 
                objJsonResult.count = 0; 
 | 
                objJsonResult.Message = "保存失败!" + e.ToString(); 
 | 
                objJsonResult.data = 1; 
 | 
                return objJsonResult; 
 | 
            } 
 | 
        } 
 | 
    
 | 
        /// <summary> 
 | 
        /// 生产资源获取信息 
 | 
        /// </summary> 
 | 
        /// <returns></returns> 
 | 
        [Route("GetGy_SourceDetail")] 
 | 
        [HttpGet] 
 | 
        public ApiResult<DataSet> GetGy_SourceDetail(string HID) 
 | 
        { 
 | 
            var model = LuBaoSevice.GetGy_SourceBillDetail(HID); 
 | 
            return model; 
 | 
        } 
 | 
  
 | 
        /// <summary> 
 | 
        /// 生产资源删除功能 
 | 
        /// </summary> 
 | 
        /// <returns></returns> 
 | 
        [Route("DeltetGy_Source")] 
 | 
        [HttpGet] 
 | 
        public object DeltetGy_Source(string HItemID) 
 | 
        { 
 | 
            DataSet ds; 
 | 
            //string ModRightNameCheck = "Sc_ProcessReport_check"; 
 | 
            try 
 | 
            { 
 | 
                //删除权限 
 | 
                //if (!DBUtility.ClsPub.Security_Log(ModRightNameCheck, 1, true, CurUserName)) 
 | 
                //{ 
 | 
                //    objJsonResult.code = "0"; 
 | 
                //    objJsonResult.count = 0; 
 | 
                //    objJsonResult.Message = "审核失败!无权限!"; 
 | 
                //    objJsonResult.data = null; 
 | 
                //    return objJsonResult; 
 | 
                //} 
 | 
  
 | 
                SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); 
 | 
                if (string.IsNullOrWhiteSpace(HItemID)) 
 | 
                { 
 | 
                    objJsonResult.code = "0"; 
 | 
                    objJsonResult.count = 0; 
 | 
                    objJsonResult.Message = "HItemID为空!"; 
 | 
                    objJsonResult.data = null; 
 | 
                    return objJsonResult; 
 | 
                } 
 | 
                oCN.BeginTran();//开始事务 
 | 
                ds = oCN.RunProcReturn("select * from Gy_Source where HItemID=" + HItemID, "Gy_Source"); 
 | 
                if (ds == null || ds.Tables[0].Rows.Count == 0) 
 | 
                { 
 | 
                    objJsonResult.code = "0"; 
 | 
                    objJsonResult.count = 0; 
 | 
                    objJsonResult.Message = "没有数据,无法删除!"; 
 | 
                    objJsonResult.data = null; 
 | 
                    return objJsonResult; ; 
 | 
                } 
 | 
                var HStopflag = Convert.ToBoolean(ds.Tables[0].Rows[0]["HStopflag"]); 
 | 
                if (HStopflag) 
 | 
                { 
 | 
                    oCN.RollBack();//回滚事务 
 | 
                    objJsonResult.code = "0"; 
 | 
                    objJsonResult.count = 0; 
 | 
                    objJsonResult.Message = "数据已删除无法再次删除!"; 
 | 
                    objJsonResult.data = null; 
 | 
                    return objJsonResult; 
 | 
                } 
 | 
  
 | 
                oCN.RunProc("update Gy_Source set HStopflag=1 where HItemID=" + HItemID); 
 | 
                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; 
 | 
            } 
 | 
        } 
 | 
  
 | 
    } 
 | 
} 
 |