using log4net; using Microsoft.Extensions.Caching.Memory; using SqlSugar; using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Threading.Tasks; using System.Web.Http; using UFIDA.U8.Framework.Api.ControlObject.Common; using UFIDA.U8.Framework.Api.ControlObject.Entity; using UFIDA.U8.Framework.Api.ControlObject.Json; using UFIDA.U8.Framework.Api.ControlObject.U8M; using UFIDA.U8.Framework.Api.Entity; using UFIDA.U8.Framework.Api.Unit; namespace UFIDA.U8.Framework.Api.Controllers.U8 { /// /// 生产订单 /// public class MOController : ApiController { /// /// 日志组件 /// private readonly ILog _logInfo = LogManager.GetLogger("logInfo"); private static readonly MemoryCache _cache = new MemoryCache(new MemoryCacheOptions { ExpirationScanFrequency = TimeSpan.FromMinutes(10) }); /// /// 查询特定单据部分 /// /// 系统号 /// 单据类型编码 /// 查询条件 /// 查询所属区域 H:表头,B:表体, L:列表 /// /// [HttpPost] [Route("api/U8/MO/{cCardNum}/Load")] [Route("api/U8/MO/{cCardNum}/Load/{cCardPostion}")] public async Task> Load(string cAccId, string cCardNum, [FromBody] Dictionary input, string cCardPostion = "H") { var workId = SnowFlakeSingle.Instance.NextId(); try { _logInfo.Debug($"作业Id:{workId}-----单据:{cCardNum},操作:查询,对接账套:{cAccId},条件:{input.ToJson()}"); if (!_cache.TryGetValue($"U8_{cAccId}", out BaseLogin baseLogin)) { _logInfo.Debug($"作业Id:{workId}-----未获取到缓存的登录信息,正在重新构建"); baseLogin = new BaseLogin(); var param = await CommUnit.GetLoginParamter(cAccId); if (param == null) { throw new Exception("未能加载指定系统号的登录信息"); } baseLogin.Init(param, false); _cache.Clear(); _cache.Set($"U8_{cAccId}", baseLogin); } var vouchers = CommonHelper.GetVouchers(baseLogin.Connection, cCardNum); if (vouchers == null) { throw new Exception("未能获取到单据配置信息"); } var db = new SqlSugarClient(new ConnectionConfig() { DbType = DbType.SqlServer, ConfigId = cAccId, ConnectionString = baseLogin.UFDataConnstringForNet, IsAutoCloseConnection = true, MoreSettings = new ConnMoreSettings() { IsWithNoLockQuery = true } }); var cBTQName = vouchers.cBTTblName; var cBWQName = vouchers.cBWTblName; var cExtQName = "mom_morder"; var cBTTblExtName = $"{vouchers.cBTTblName}_extradefine"; var cBWTblExtName = $"{vouchers.cBWTblName}_extradefine"; var voucherIdFieldName = vouchers.voucherIdFieldName; var vouchersIdFieldName = ""; var bExtHead = false; var bExtBody = false; var colList = new Dictionary(); var colListHead = new Dictionary(); var colListBody = new Dictionary(); var cols = db.DbMaintenance.GetColumnInfosByTableName(cBTQName); if (cols != null && cols.Count > 0) { foreach (var col in cols.Where(col => !colList.ContainsKey(col.DbColumnName.ToLower()))) { if (cCardPostion == "H" || cCardPostion == "L") colList.Add(col.DbColumnName.ToLower(), $"{cBTQName}.[{col.DbColumnName}]"); colListHead.Add(col.DbColumnName.ToLower(), $"{cBTQName}.[{col.DbColumnName}]"); } } if (db.DbMaintenance.IsAnyTable($"{cBTTblExtName}")) { bExtHead = true; var extcols = db.DbMaintenance.GetColumnInfosByTableName($"{cBTTblExtName}"); if (extcols != null && extcols.Count > 0) { foreach (var col in extcols.Where(col => !colList.ContainsKey(col.DbColumnName.ToLower()))) { if (cCardPostion == "H" || cCardPostion == "L") colList.Add(col.DbColumnName.ToLower(), $"{cBTTblExtName}.[{col.DbColumnName}]"); colListHead.Add(col.DbColumnName.ToLower(), $"{cBTTblExtName}.[{col.DbColumnName}]"); } } } cols = db.DbMaintenance.GetColumnInfosByTableName(cBWQName); if (cols != null && cols.Count > 0) { foreach (var col in cols.Where(col => !colList.ContainsKey(col.DbColumnName.ToLower()))) { if (cCardPostion == "B" || cCardPostion == "L") colList.Add(col.DbColumnName.ToLower(), $"{cBWQName}.[{col.DbColumnName}]"); colListBody.Add(col.DbColumnName.ToLower(), $"{cBWQName}.[{col.DbColumnName}]"); } } cols = db.DbMaintenance.GetColumnInfosByTableName(cExtQName); if (cols != null && cols.Count > 0) { foreach (var col in cols.Where(col => !colList.ContainsKey(col.DbColumnName.ToLower()))) { if (!colList.ContainsKey(col.DbColumnName.ToLower())) { if (cCardPostion == "B" || cCardPostion == "L") colList.Add(col.DbColumnName.ToLower(), $"{cExtQName}.[{col.DbColumnName}]"); colListBody.Add(col.DbColumnName.ToLower(), $"{cExtQName}.[{col.DbColumnName}]"); } } } if (db.DbMaintenance.IsAnyTable(cBWTblExtName)) { bExtBody = true; var extcols = db.DbMaintenance.GetColumnInfosByTableName($"{cBWTblExtName}"); if (extcols != null && extcols.Count > 0) { foreach (var col in extcols) { if (colList.ContainsKey(col.DbColumnName.ToLower())) { vouchersIdFieldName = col.DbColumnName.ToLower(); } else { if (cCardPostion == "B" || cCardPostion == "L") colList.Add(col.DbColumnName.ToLower(), $"{cBWTblExtName}.[{col.DbColumnName}]"); colListBody.Add(col.DbColumnName.ToLower(), $"{cBWTblExtName}.[{col.DbColumnName}]"); } } } } var cDefWhere = vouchers.cDefWhere; var query = db.Queryable().AS(cBTQName, cBTQName); if (bExtHead) { query.AddJoinInfo(cBTTblExtName, cBTTblExtName, $"{cBTQName}.[{voucherIdFieldName}]={cBTTblExtName}.[{voucherIdFieldName}]"); } query.AddJoinInfo(cBWQName, cBWQName, $"{cBTQName}.[{voucherIdFieldName}]={cBWQName}.[{voucherIdFieldName}]"); if (cCardNum == "MO21") { query.AddJoinInfo(cExtQName, cExtQName, $"{cBWQName}.[{vouchersIdFieldName}]={cExtQName}.[{vouchersIdFieldName}]"); } if (bExtBody) { query.AddJoinInfo(cBWTblExtName, cBWTblExtName, $"{cBWQName}.[{vouchersIdFieldName}]={cBWTblExtName}.[{vouchersIdFieldName}]"); } if (input != null) { var conModels = new List(); foreach (var o in input) { if (o.Key == "dModifyDate") { if (colListHead.Any(a => string.Equals(a.Key, "RelsTime", StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, "RelsTime", StringComparison.OrdinalIgnoreCase))) { var col = colListHead.First(a => string.Equals(a.Key, "RelsTime", StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, "RelsTime", StringComparison.OrdinalIgnoreCase)); conModels.Add(new ConditionalModel { FieldName = $"{col.Value}", ConditionalType = ConditionalType.GreaterThanOrEqual, FieldValue = $"{o.Value}" }); } if (colListBody.Any(a => string.Equals(a.Key, "RelsTime", StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, "RelsTime", StringComparison.OrdinalIgnoreCase))) { var col = colListBody.First(a => string.Equals(a.Key, "RelsTime", StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, "RelsTime", StringComparison.OrdinalIgnoreCase)); conModels.Add(new ConditionalModel { FieldName = $"{col.Value}", ConditionalType = ConditionalType.GreaterThanOrEqual, FieldValue = $"{o.Value}" }); } } else if (o.Key == "dModifyDate__2") { if (colListHead.Any(a => string.Equals(a.Key, "RelsTime", StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, "RelsTime", StringComparison.OrdinalIgnoreCase))) { var col = colListHead.First(a => string.Equals(a.Key, "RelsTime", StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, "RelsTime", StringComparison.OrdinalIgnoreCase)); conModels.Add(new ConditionalModel { FieldName = $"{col.Value}", ConditionalType = ConditionalType.LessThanOrEqual, FieldValue = $"{o.Value}" }); } if (colListBody.Any(a => string.Equals(a.Key, "dnveriRelsTimefytime", StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, "RelsTime", StringComparison.OrdinalIgnoreCase))) { var col = colListBody.First(a => string.Equals(a.Key, "RelsTime", StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, "RelsTime", StringComparison.OrdinalIgnoreCase)); conModels.Add(new ConditionalModel { FieldName = $"{col.Value}", ConditionalType = ConditionalType.LessThanOrEqual, FieldValue = $"{o.Value}" }); } } else if ($"{o.Value}".EndsWith("%") || $"{o.Value}".StartsWith("%")) { if (colListHead.Any(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase))) { var col = colListHead.First(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase)); conModels.Add(new ConditionalModel { FieldName = $"{col.Value}", ConditionalType = ConditionalType.Like, FieldValue = $"{o.Value}" }); } if (colListBody.Any(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase))) { var col = colListBody.First(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase)); conModels.Add(new ConditionalModel { FieldName = $"{col.Value}", ConditionalType = ConditionalType.Like, FieldValue = $"{o.Value}" }); } } else if (o.Key.EndsWith("__2")) { if (colListHead.Any(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase))) { var col = colListHead.First(a => string.Equals(a.Key, o.Key.Replace("__2", ""), StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key.Replace("__2", ""), StringComparison.OrdinalIgnoreCase)); conModels.Add(new ConditionalModel { FieldName = $"{col.Value}", ConditionalType = ConditionalType.LessThanOrEqual, FieldValue = $"{o.Value}" }); } if (colListBody.Any(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase))) { var col = colListBody.First(a => string.Equals(a.Key, o.Key.Replace("__2", ""), StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key.Replace("__2", ""), StringComparison.OrdinalIgnoreCase)); conModels.Add(new ConditionalModel { FieldName = $"{col.Value}", ConditionalType = ConditionalType.LessThanOrEqual, FieldValue = $"{o.Value}" }); } } else if (input.ContainsKey($"{o.Key}__2")) { if (colListHead.Any(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase))) { var col = colListHead.First(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase)); conModels.Add(new ConditionalModel { FieldName = $"{col.Value}", ConditionalType = ConditionalType.GreaterThanOrEqual, FieldValue = $"{o.Value}" }); } if (colListBody.Any(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase))) { var col = colListBody.First(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase)); conModels.Add(new ConditionalModel { FieldName = $"{col.Value}", ConditionalType = ConditionalType.GreaterThanOrEqual, FieldValue = $"{o.Value}" }); } } else if (colListHead.Any(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase))) { var col = colListHead.First(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase)); conModels.Add(new ConditionalModel { FieldName = col.Value, ConditionalType = ConditionalType.Equal, FieldValue = $"{o.Value}" }); } else if (colListBody.Any(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase))) { var col = colListBody.First(a => string.Equals(a.Key, o.Key, StringComparison.OrdinalIgnoreCase) || string.Equals(a.Value, o.Key, StringComparison.OrdinalIgnoreCase)); conModels.Add(new ConditionalModel { FieldName = col.Value, ConditionalType = ConditionalType.Equal, FieldValue = $"{o.Value}" }); } } query.Where(conModels); } query.Where(cDefWhere); var selector = colList.Select(col => new SelectModel { FieldName = $"{col.Value}", AsName = col.Key }).ToList(); query.Select(selector).Distinct(); _logInfo.Debug(query.ToSqlString()); return new BaseResult() { bSuccess = true, message = "查询成功", result = await query.ToListAsync() }; } catch (Exception ex) { _logInfo.Error(ex.Message, ex); return new BaseResult { bSuccess = false, message = ex.Message, result = ex.StackTrace }; } } } }