using JCSoft.WX.Framework.Api; using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Http; using System; using System.Collections.Generic; using System.Linq; using System.Threading.Tasks; using Common.Wechat; using Common; using System.Data; using Common.Model; using ZcPeng.PublicLibrary; using CoreEntity.Entity; using CoreEntity.DAL; using System.Collections.Concurrent; using Newtonsoft.Json.Converters; using Newtonsoft.Json; using System.Data.SqlClient; using Microsoft.Extensions.Primitives; using Microsoft.Extensions.Caching.Memory; using Jwt; using PublicLibrary.Model; using Newtonsoft.Json.Linq; using SupplierWeb.Codes.mvc; using SupplierWeb.Codes.Auth; using Common.Config; namespace SupplierWeb.Controllers { [Route("web/Mem_DataDictory")] public class mem_DataDictoryController : BaseController { public mem_DataDictoryController(IMemoryCache cache, IApiClient client) : base(cache, client) { } private ConcurrentDictionary Mem_DataDictoryMap = new ConcurrentDictionary(); /// /// 获取组织机构列表 /// /// /// /// /// /// /// /// /// [AuthPermission] [HttpPost, Route("index")] public JsonResult Indexp(QueryFilter[] filters, Int32 pageIndex, Int32 pageSize, string sortField, Int32 sortDirection, string[] sumFields, [FromBody]dynamic data) { if (data != null) { filters = data.filters.ToObject(); pageIndex = data.pageIndex; pageSize = data.pageSize; sortField = data.sortField; sortDirection = data.sortDirection; sumFields = data.sumFields.ToObject(); } #region 获取机构列表 DataTable dt = new DataTable(); string result; IList permss = new List(0); List parameters = new List(); string filterstr = QueryFilter.getFilterSqlParam(filters, out parameters, new Mem_DataDictory(), "A."); string direct = " desc "; if (sortDirection != 1) { direct = " asc"; } int start = (pageIndex - 1) * pageSize; int end = (start + 1 + pageSize); string commandText0 = "select * from "; string commandText1 = "(" + "select A.*,row_number() over" + "( order by A.Id " + direct + " ) as rownum from " + "Mem_DataDictory as A " + " where 1=1 " + filterstr + ")AAA "; string commandText2 = " where AAA.rownum>" + start + " and AAA.rownum<" + end + " ORDER BY AAA.Id desc"; string commandText3 = commandText0 + commandText1 + commandText2; bool success = DataAccess.GetValues(commandText3, ref dt, parameters.ToArray(), out result); #endregion if (dt != null && dt.Rows.Count > 0) { // 把DataTable转换为IList permss = ModelConvertHelper.ConvertToModel(dt); } string result1; long totalcount = DataAccess.GetRowCountDefine("select count(Id) from " + commandText1, parameters.ToArray(), out result1); IsoDateTimeConverter timejson = new IsoDateTimeConverter { DateTimeFormat = "yyyy'-'MM'-'dd' 'HH':'mm':'ss" }; //IList menus = Permission.Convert(permss); var jsonData = JsonConvert.SerializeObject(permss, timejson); return Json(new { items = JsonConvert.DeserializeObject(jsonData), sum = new { }, totalCount = totalcount }); } /// /// 新增 /// /// /// /// /// /// /// /// /// /// /// /// [AuthPermission] [HttpPost, Route("add")] public JsonResult Addp( Int32 Id, String Key, String Text, string Value, string Remark,Int32 ParentId, Int32 SortKey, Int32 IsHide, string SyncStatus, [FromBody]dynamic data ) { if (data != null) { if (data.Key != null) { Key = data.Key; } else { Key = ""; } if (data.Text != null) { Text = data.Text; } else { Text = ""; } if (data.Value != null) { Value = data.Value; } else { Value = ""; } if (data.Remark != null) { Remark = data.Remark; } else { Remark = ""; } if (data.ParentId != null) { ParentId = data.ParentId; } else { ParentId = 0; } if (data.SortKey != null) { SortKey = data.SortKey; } else { SortKey = 0; } if (data.IsHide != null) { IsHide = data.IsHide; } else { IsHide = 0; } if (data.SyncStatus != null) { SyncStatus = data.SyncStatus; } else { SyncStatus = ""; } } #region 添加 //String uuid = System.Guid.NewGuid().ToString("N"); //int newid = Convert.ToInt32(ReturnMaxID("Id", "Mem_DataDictory")) + 1; string commandText = "INSERT INTO Mem_DataDictory (" + "[Key],Text,[Value],Remark,ParentId,SortKey,IsHide,SyncStatus)" + " VALUES (@Key,@Text,@Value,@Remark,@ParentId,@SortKey,@IsHide,@SyncStatus )"; string result; //准备参数 List> parameters = new List>(); parameters.Add(new List() { "Key", Key }); parameters.Add(new List() { "Text", Text }); parameters.Add(new List() { "Value", Value }); parameters.Add(new List() { "Remark", Remark }); parameters.Add(new List() { "ParentId", ParentId }); parameters.Add(new List() { "SortKey", SortKey }); parameters.Add(new List() { "IsHide", IsHide }); parameters.Add(new List() { "SyncStatus", SyncStatus }); List parameters1 = DataAccess.ToParameters(parameters); int success = DataAccess.ExecuteCommand(commandText, parameters1, out result); #endregion return Json(new { success = success }); } /// /// 修改 /// /// /// /// /// /// /// /// /// /// /// /// [AuthPermission] [HttpPost, Route("edit")] public JsonResult editp( Int32 Id, String Key, String Text, string Value, string Remark, Int32 ParentId, Int32 SortKey, Int32 IsHide, string SyncStatus, [FromBody]dynamic data ) { if (data != null) { if (data.Key != null) { Key = data.Key; } else { Key = ""; } if (data.Text != null) { Text = data.Text; } else { Text = ""; } if (data.Value != null) { Value = data.Value; } else { Value = ""; } if (data.Remark != null) { Remark = data.Remark; } else { Remark = ""; } if (data.ParentId != null) { ParentId = data.ParentId; } else { ParentId = 0; } if (data.SortKey != null) { SortKey = data.SortKey; } else { SortKey = 0; } if (data.IsHide != null) { IsHide = data.IsHide; } else { IsHide = 0; } if (data.SyncStatus != null) { SyncStatus = data.SyncStatus; } else { SyncStatus = ""; } } #region 编辑用户 string commandText = "UPDATE Mem_DataDictory " + " SET Id=@Id, [Key] = @Key,"; commandText += " Text = @Text" + ",[Value] = @Value" + " ,Remark = @Remark" + ",ParentId = @ParentId" + ",SortKey = @SortKey" + ",IsHide = @IsHide" + ",SyncStatus = @SyncStatus" + " WHERE Id= @Id"; string result; //准备参数 List> parameters = new List>(); parameters.Add(new List() { "Key", Key }); parameters.Add(new List() { "Text", Text }); parameters.Add(new List() { "Value", Value }); parameters.Add(new List() { "Remark", Remark }); parameters.Add(new List() { "ParentId", ParentId }); parameters.Add(new List() { "SortKey", SortKey }); parameters.Add(new List() { "IsHide", IsHide }); parameters.Add(new List() { "SyncStatus", SyncStatus }); List parameters1 = DataAccess.ToParameters(parameters); int success = DataAccess.ExecuteCommand(commandText, parameters1, out result); #endregion return Json(new { success = success, result = result, }); } /// /// 组织机构删除 /// /// /// [AuthPermission] [HttpPost, Route("delete")] public ActionResult Delete(string id) { //SQL语句 string commandText = "DELETE FROM Mem_DataDictory WHERE Id = @id"; string commandText1 = "DELETE FROM Mem_DataDictoryRole WHERE Id = @id"; //准备参数 List> parameters = new List>(); parameters.Add(new List() { "id", id }); string result = ""; string result1 = ""; //参数转换 List parameters1 = DataAccess.ToParameters(parameters); //执行并返回结果 int success = DataAccess.ExecuteCommand(commandText, parameters1, out result); int success1 = DataAccess.ExecuteCommand(commandText1, parameters1, out result1); //如果Mem_DataDictory和Mem_DataDictoryRole表记录都删除成功 int success2 = 0; if (success > 0 && success1 > 0) { success2 = success;//此处应该是success2 = success+success1,由于不清楚前端是怎么接收处理的,暂且这么处理。 } else { success2 = -1; } return Content("{success:" + success2 + "}"); } /// /// 获取最大的id /// /// /// /// public object ReturnMaxID(string field, string tablename) { string result; List parameters = new List(); bool boolen = DataAccess.GetOneValue("select max(" + field + ") from " + tablename, parameters.ToArray(), out object objValue, out result); if (boolen == true) { return objValue; } else { return result; } } } }