工单计划导入更新

Ben Lin

2024-12-30 6ca8cb2376f6f02e93e233130da9896565706a7f

工单计划导入更新

 Tiger.Business.MES/BIZ/ImportWoPlan.cs

@@ -16,6 +16,8 @@
using System.Reflection;
using Dm.filter;
using System.Dynamic;
using System.Data.Entity.Core.Metadata.Edm;
using SqlSugar;

namespace Tiger.Business.MES
{
@@ -76,40 +78,54 @@
        /// <param name="newEntity"></param>
        /// <param name="input"></param>
        /// <returns></returns>
        public async Task<ApiAction<List<T>>> ValidateTableImport<T>(T newEntity, ImportValidateInput input) {
        public async Task<ApiAction<List<T>>> ValidateTableImport<T>(T newEntity, ImportValidateInput input)
        {
            var result = new ApiAction<List<T>>();
            try
            {
                List<T> list = JsonConvert.DeserializeObject<List<T>>(input.EntityJson);
                List<BIZ_MES_WO_BATCH> baths = list as List<BIZ_MES_WO_BATCH>;
                List<string> chkColumns = JsonConvert.DeserializeObject<List<string>>(input.CheckJson);
                List<string> wheres = JsonConvert.DeserializeObject<List<string>>(input.where); //目前只有=，以后可以增加其他的查询条件
                Type entityType = typeof(T); //T泛型 
                //通过属性名获取属性值  “VALIDATION_TYPE”属性名称
                PropertyInfo typeInfo = entityType.GetProperty("VALIDATION_TYPE");
                //通过属性名获取属性值  “VALIDATION_RESULT”属性名称
                PropertyInfo retInfo = entityType.GetProperty("VALIDATION_RESULT");
                foreach (var item in list)
                foreach (var item in baths)
                {
                    string where = " 1=1 ";
                    typeInfo.SetValue(item, "新增");
                    retInfo.SetValue(item, "");
                    foreach (var col in chkColumns)
                    item.VALIDATION_TYPE = "新增";
                    item.VALIDATION_RESULT = "";
                    var _wo = await Biz.Db.Queryable<BIZ_MES_WO>().Where(x => x.ORDER_NO == item.ORDER_NO).FirstAsync();
                    if (_wo.IsNullOrEmpty())
                    {
                        PropertyInfo colInfo = entityType.GetProperty(col);
                        if (!colInfo.IsNullOrEmpty() && colInfo.GetValue(item).IsNullOrEmpty()) {
                            typeInfo.SetValue(item, "数据异常");
                            retInfo.SetValue(item, "值为空或不存在");
                        item.VALIDATION_TYPE = "异常";
                        item.VALIDATION_RESULT = "工单不存在，不能导入计划！";
                        }
                    }
                    foreach (var w in wheres)
                    else
                    {
                        PropertyInfo wInfo = entityType.GetProperty(w);
                        where += $"AND {w} = '{wInfo.GetValue(item)}'";
                    }
                    if (await Biz.Db.Queryable<T>().Where(where).AnyAsync())
                        var _batchWos = await Biz.Db.Queryable<V_MES_WO_BATCH>().Where(x => x.ORDER_NO == item.ORDER_NO).ToListAsync();
                        if (_batchWos.Count > 0)
                    {
                        typeInfo.SetValue(item, "修改");
                        retInfo.SetValue(item, "数据已经存在，使用更新");
                            item.BATCH_NO = $"{item.ORDER_NO}-{(_batchWos.Max(x => x.BATCH) + 1).ToString("D2")}";
                        }
                        else
                        {
                            item.BATCH_NO = $"{item.ORDER_NO}-01";
                        }

                        if (item.PLAN_DATE.IsNullOrEmpty())
                        {
                            item.VALIDATION_TYPE = "异常";
                            item.VALIDATION_RESULT += $"计划日期值为空或不存在; ";
                        }

                        if (item.PLAN_QTY.IsNullOrEmpty())
                        {
                            item.VALIDATION_TYPE = "异常";
                            item.VALIDATION_RESULT += $"计划数量为空; ";
                        }
                        var _woBatch = await Biz.Db.Queryable<BIZ_MES_WO_BATCH>().Where(x => x.ORDER_NO == item.ORDER_NO && SqlFunc.DateIsSame(x.PLAN_DATE, item.PLAN_DATE) && x.STATUS != BIZ_MES_WO_BATCH.STATUSs.Closed.GetValue()).FirstAsync();
                        if (!_woBatch.IsNullOrEmpty())
                        {
                            item.VALIDATION_TYPE = "异常";
                            item.VALIDATION_RESULT += $"数据已经存在，不能更新。存在的计划数量为[{_woBatch.PLAN_QTY}]";
                        }
                    }
                }
                result.Data = list;