using DBUtility; using Model; using Newtonsoft.Json; using Newtonsoft.Json.Linq; using System; using System.Collections.Generic; using System.Data; using System.Linq; using System.Net; using System.Net.Http; using System.Web.Http; using WebAPI.Models; namespace WebAPI.Controllers.基础资料.基础资料 { public class Gy_OperatorController : ApiController { private json objJsonResult = new json(); SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); DataSet ds; #region 业务员 列表 [Route("Gy_Operator/OperatorList")] [HttpGet] public object OperatorList(string sWhere, string user, string Organization) { try { List columnNameList = new List(); //编辑权限 //if (!DBUtility.ClsPub.Security_Log_second("Gy_TaxRate_Query", 1, false, user)) //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "无查看权限!"; // objJsonResult.data = null; // return objJsonResult; //} #region 这里将为删除的数据 HIsPseDel 恢复为0 DataSet Cs; Cs = oCN.RunProcReturn("select HItemID from Gy_Operator where HIsPseDel = 1", "Gy_Operator"); string sqlupdate = string.Empty; for (var i = 0; i< Cs.Tables[0].Rows.Count; i++) { sqlupdate = $"update Gy_Operator set HIsPseDel = 0 where HItemID = {Cs.Tables[0].Rows[i]["HItemID"]} "; oCN.RunProc(sqlupdate); } #endregion string sql1 = string.Format(@"select * from h_v_Gy_OperatorList where 1 = 1 "); string sql = sql1 + sWhere; ds = oCN.RunProcReturn(sql, "h_v_Gy_OperatorList"); //添加列名 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列对象的列名 } objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "Sucess!"; objJsonResult.list = columnNameList; 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("Gy_Operator/OperatorEdit")] [HttpPost] public object OperatorEdit([FromBody] JObject sMainSub) { try { var _value = sMainSub["sMainSub"].ToString(); string msg1 = _value.ToString(); oCN.BeginTran(); //保存表 objJsonResult = AddBill(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 AddBill(string msg1) { string[] sArray = msg1.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries); string msg2 = sArray[0].ToString(); //主表数据 string msg3 = sArray[1].ToString(); //子表数据 try { msg2 = "[" + msg2.ToString() + "]"; List mainList = Newtonsoft.Json.JsonConvert.DeserializeObject>(msg2); string HOperatorType = mainList[0].HOperatorType;//业务员类型 List mainList2 = Newtonsoft.Json.JsonConvert.DeserializeObject>(msg3); long HItemID = mainList2[0].HItemID; string HNumber = mainList2[0].HNumber; string HName = mainList2[0].HName; string HHelpCode = mainList2[0].HHelpCode; string HShortNumber = mainList2[0].HShortNumber; long HParentID = mainList2[0].HParentID; long HLevel = mainList2[0].HLevel; bool HEndFlag = mainList2[0].HEndFlag; bool HStopflag = mainList2[0].HStopflag; string HRemark = mainList2[0].HRemark; string HUseFlag = mainList2[0].HUseFlag; long HUSEORGID = mainList2[0].HUSEORGID; long HOperatorId = mainList2[0].HOperatorId; long HSEQ = mainList2[0].HSEQ; long HStaffId = mainList2[0].HStaffId; long HIsUse = mainList2[0].HIsUse; long HIsPseDel = mainList2[0].HIsPseDel; int i = 0; string sql = string.Empty; sql = "set identity_insert Gy_Operator on"; oCN.RunProc(sql); foreach (ClsGy_Operator_Model oSub in mainList2) { i++; sql = $"delete Gy_Operator where HItemID = {oSub.HItemID}"; oCN.RunProc(sql); if(oSub.HItemID == 0) { DataSet Cs; Cs = oCN.RunProcReturn("select MAX(HItemID)HItemID from Gy_Operator", "Gy_Operator"); if (Cs.Tables[0].Rows.Count != 0 && ClsPub.isLong(Cs.Tables[0].Rows[0]["HItemID"].ToString()) != 0) { oSub.HItemID = ClsPub.isLong(Cs.Tables[0].Rows[0]["HItemID"].ToString()); oSub.HItemID += 1; } } //这里进行数据的真删除 if(oSub.HIsPseDel == 1) { sql = $"delete Gy_Operator where HItemID = {oSub.HItemID} and HIsPseDel = 1 "; oCN.RunProc(sql); } else { oCN.RunProc($@"Insert into Gy_Operator (HItemID,HNumber,HName,HHelpCode,HShortNumber,HParentID,HLevel,HEndFlag,HStopflag,HRemark,HUseFlag,HUSEORGID ,HOperatorId,HOperatorType,HSEQ,HStaffId,HIsUse) values({oSub.HItemID},'{oSub.HNumber}','{oSub.HName}','{oSub.HHelpCode}','{oSub.HShortNumber}',{oSub.HParentID},{oSub.HLevel},'{oSub.HEndFlag}','{oSub.HStopflag}','{oSub.HRemark}','{oSub.HUseFlag}',{oSub.HUSEORGID},{oSub.HOperatorId},'{HOperatorType}',{oSub.HSEQ},{oSub.HStaffId},{oSub.HIsUse})"); } } sql = "set identity_insert Gy_Operator off"; oCN.RunProc(sql); if (objJsonResult.code == "0") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = objJsonResult.Message; objJsonResult.data = null; return objJsonResult; } 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 ////#region 业务员 编辑 //[Route("Gy_Operator/OperatorEdit")] //[HttpPost] //public object OperatorEdit([FromBody] JObject msg) //{ // DataSet ds; // var _value = msg["msg"].ToString(); // string msg3 = _value.ToString(); // string[] sArray = msg3.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries); // string msg1 = sArray[0].ToString(); // string msg2 = sArray[1].ToString(); // //string msg_HUSEORGID = sArray[2].ToString(); // Int64 HItemID = 0; // SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); // //编辑权限 // //if (!DBUtility.ClsPub.Security_Log_second("Gy_TaxRate_Edit", 1, false, msg2)) // //{ // // objJsonResult.code = "0"; // // objJsonResult.count = 0; // // objJsonResult.Message = "无保存权限!"; // // objJsonResult.data = null; // // return objJsonResult; // //} // //获取最大ID值赋值 // //DataSet Maxds = oCN.RunProcReturn("select MAX(HItemID) HItemID from Gy_TaxRate ", "Gy_TaxRate"); // //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"].ToString()==""?0: Maxds.Tables[0].Rows[0]["HItemID"])); // // maxid += 1; // // HItemID = maxid; // //} // ListModels oListModels = new ListModels(); // List mainList = Newtonsoft.Json.JsonConvert.DeserializeObject>(msg2); // List mainList22 = Newtonsoft.Json.JsonConvert.DeserializeObject>(msg3); // string main = mainList + ";" + mainList22; // try // { // DAL.ClsGy_Operator_Ctl oBill = new DAL.ClsGy_Operator_Ctl(); // List lsmain = new List(); // msg1 = msg1.Replace("\\", ""); // msg1 = msg1.Replace("\n", ""); //\n // lsmain = oListModels.getObjectByJson_Gy_Operator(msg1); // foreach (Model.ClsGy_Operator_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; // } // //查询数据中是否存在重复代码 // ds = oCN.RunProcReturn("select * from Gy_Operator where HStopflag=0 and HNumber='" + oItem.HNumber.Trim() + "'", "Gy_Operator"); // if (oItem.HItemID == 0) // { // if (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) // { // if (ds.Tables[0].Rows[0]["HItemID"].ToString() != oItem.HItemID.ToString()) // { // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "保存失败!代码重复!"; // objJsonResult.data = null; // return objJsonResult; // } // } // } // //新增时判断 // #region 父级校验方法(api调用先注释掉,) // /* // if (oItem.HItemID == 0) // { // if (ds == null || ds.Tables[0].Rows.Count > 0) // { // 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; // } // } // } // */ // #endregion // //得到短代码 // 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.HUSEORGID = Convert.ToInt32(msg_HUSEORGID); //组织id // oItem.HShortNumber = sShortNumber;//短代码 // oItem.HEndFlag = true;//末级标志 // oItem.HLevel = 1; //等级 DBUtility.ClsPub.GetLevel(oItem.HNumber.Trim()) // oBill.oModel = oItem; // } // //保存 // //保存完毕后处理 // bool bResult; // if (oBill.oModel.HItemID == 0) // { // bResult = oBill.AddNew(); // } // else // { // bResult = oBill.ModifyByID(oBill.oModel.HItemID); // } // if (bResult) // { // objJsonResult.code = "1"; // 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; // } //} ////#endregion #region 业务员 删除 [Route("Gy_Operator/Delete")] [HttpGet] public object Delete(string HItemID, string user) { DataSet ds; try { SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); //删除权限 //if (!DBUtility.ClsPub.Security_Log("Gy_TaxRate_Drop", 1, false, user)) //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "无删除权限"; // objJsonResult.data = null; // return objJsonResult; //} 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_Operator where HItemID=" + HItemID, "Gy_Operator"); 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("delete from Gy_Operator 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; } } #endregion #region 业务员 伪删除 [Route("Gy_Operator/Delete2")] [HttpGet] public object Delete2(string HItemID, string user) { DataSet ds; try { SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); //删除权限 //if (!DBUtility.ClsPub.Security_Log("Gy_TaxRate_Drop", 1, false, user)) //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "无删除权限"; // objJsonResult.data = null; // return objJsonResult; //} 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_Operator where HItemID=" + HItemID, "Gy_Operator"); 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; } //因为将数据禁用后将无法删除,所以这里将使用标记更新为 1 代表为伪删除状态, //用户在进行保存操作时,将使用标记为 1 的数据真删除, //如若用户在编辑/新增页面还为进行保存操作就刷新页面,使用标记将被恢复为0 oCN.RunProc("update Gy_Operator set HIsPseDel = 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; } } #endregion #region 业务员 金蝶同步 [Route("Gy_Operator/SaveGy_OperatorListApi")] [HttpPost] public object SaveGy_OperatorListApi([FromBody] JObject msg) { try { var _value = msg["model"].ToString(); var operatorInfoModel = msg["model"]["HOperatorInfoEntry"].ToString(); SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); ListModels oListModels = new ListModels(); List lsmain = new List(); lsmain = oListModels.getObjectByJson_Gy_Operator(_value); string sql = string.Empty; List operatorInfos = Newtonsoft.Json.JsonConvert.DeserializeObject>(operatorInfoModel); //保存 oCN.BeginTran(); //sql = $"delete Gy_Operator where HItemID = {lsmain[0].HItemID}"; //oCN.RunProc(sql); //sql = "set identity_insert Gy_Operator on"; //oCN.RunProc(sql); //oCN.RunProc($@"insert into Gy_Operator(HItemID,HNumber,HName,HHelpCode,HShortNumber,HParentID // ,HLevel,HEndFlag,HStopflag,HRemark,HUseFlag,HUSEORGID,HOperatorId,HOperatorType,HSEQ,HStaffId,HIsUse) // values({lsmain[0].HItemID},'{lsmain[0].HNumber}','{lsmain[0].HName}','{lsmain[0].HHelpCode}','{lsmain[0].HShortNumber}', // {lsmain[0].HParentID},{lsmain[0].HLevel},{Convert.ToString(lsmain[0].HEndFlag ? 1 : 0)},{Convert.ToString(lsmain[0].HStopflag ? 1 : 0) }, // '{lsmain[0].HRemark}','{lsmain[0].HUseFlag}',{lsmain[0].HUSEORGID},{lsmain[0].HOperatorId},'{lsmain[0].HOperatorType}', // {lsmain[0].HSEQ},{lsmain[0].HStaffId},{lsmain[0].HIsUse})", ref DBUtility.ClsPub.sExeReturnInfo); sql = "set identity_insert Gy_Operator on"; oCN.RunProc(sql); foreach (var item in operatorInfos) { sql = $"delete Gy_Operator where HItemID = {item.HItemID}"; oCN.RunProc(sql); sql = $@"insert into Gy_Operator(HItemID,HNumber,HName,HHelpCode,HShortNumber,HParentID ,HLevel,HEndFlag,HStopflag,HRemark,HUseFlag,HUSEORGID,HOperatorId,HOperatorType,HSEQ,HStaffId,HIsUse) values({item.HItemID},'{item.HNumber}','{item.HName}','{item.HHelpCode}','{item.HShortNumber}', {item.HParentID},{item.HLevel},{Convert.ToString(item.HEndFlag ? 1 : 0)},{Convert.ToString(item.HStopflag ? 1 : 0) }, '{item.HRemark}','{item.HUseFlag}',{item.HUSEORGID},{item.HOperatorId},'{item.HOperatorType}', {item.HSEQ},{item.HStaffId},{item.HIsUse})"; oCN.RunProc(sql); } //修改上级为非末级代码 sql = "set identity_insert Gy_Operator off"; oCN.RunProc(sql); oCN.Commit(); objJsonResult.code = "1"; 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; } } #endregion } }