修复数据库表字段不匹配、读取重量错误处理等逻辑

kazelee

2025-05-20 ef839d119eec2c28fac5f5ba175d71f926afae44

 Services/DebugService.cs

@@ -1,30 +1,121 @@
using HH.WCS.Mobox3.AnGang.Models;
using HH.WCS.Mobox3.AnGang.config;
using System;
using System;
using System.Collections.Generic;
using System.Globalization;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using CsvHelper;
using CsvHelper.Configuration;

using HH.WCS.Mobox3.AnGang.Helper;
using HH.WCS.Mobox3.AnGang.Helpers;
using HH.WCS.Mobox3.AnGang.Models;
using HH.WCS.Mobox3.AnGang.Services;

using Newtonsoft.Json;

using static HH.WCS.Mobox3.AnGang.Dtos.Request.AgvRequest;
using static HH.WCS.Mobox3.AnGang.Dtos.Request.DebugRequest;
using static HH.WCS.Mobox3.AnGang.Dtos.Response.AgvResponse;
using static HH.WCS.Mobox3.AnGang.Dtos.Response.DebugResponse;
using static HH.WCS.Mobox3.AnGang.Models.DebugModel;

namespace HH.WCS.Mobox3.AnGang.Debug {
    public class DebugService {
        /// <summary>
        /// 模拟 AGV 多次回报任务状态
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public static ReturnResults AgvSeriesReports(UpdateTaskState model) {
            var returnResults = new ReturnResults();
            returnResults.ResultList = new List<ReturnResult>();

            //if (!AgvHelper.IsTaskState(model.NextState)) {
            //    return returnResults;
            //}

            var agvCurrentState = 1; // 如果没有找到最新的 TaskAction，默认当前状态为 1(执行)  

            // 查询 TaskAction 表中与当前任务号匹配的最新记录
            var db = DbHelper.GetDbClient();
            var taskAction = db.Queryable<TN_Task_Action>()
                .Where(a => a.S_TASK_CODE == model.TaskID)
                .OrderBy(a => a.T_CREATE, SqlSugar.OrderByType.Desc).First();

            if (taskAction != null) {
                // 如果有匹配，将当前任务状态设置为表单中的最新状态
                agvCurrentState = taskAction.N_ACTION_CODE;
            }

            if (!AgvHelper.IsNextStateOk(agvCurrentState, model.NextState)) {
                LogHelper.Info($"Debug: AGV 状态 '{model.NextState}' 不是 '{agvCurrentState}' 的 合法下一状态");
                return returnResults;
            }

            var agvTaskState = new AgvTaskState() {
                task_no = model.TaskID,
                forklift_no = model.ForkliftNo,
            };

            var result = new ReturnResult();

            // 当前状态没有达到最终状态时，循环加入返回列表
            while (agvCurrentState != model.NextState) {
                agvTaskState.state = agvCurrentState;
                result = AgvService.OperateAgvTaskStatus(agvTaskState);
                returnResults.ResultList.Add(result);
                agvCurrentState = AgvHelper.GetNextState(agvCurrentState);
            }

            // 将循环没有到达的最终状态，也加入返回列表
            agvTaskState.state = model.NextState;
            result = AgvService.OperateAgvTaskStatus(agvTaskState);
            returnResults.ResultList.Add(result);

            return returnResults;
        }

        /// <summary>
        /// 初始数据库建立
        /// </summary>
        /// <returns></returns>
        public string CreateDatabase() {
        public static string CreateDatabase(bool cover = true) {
            try {
                var db = DbHelper.GetDbClient();

                db.CodeFirst.InitTables<TN_CG_Detail>();
                db.CodeFirst.InitTables<TN_WorkOrder>();
                db.CodeFirst.InitTables<TN_CAR_IN>();
                //db.CodeFirst.InitTables<SYSHelper.OI_SYS_MAXID>();
                db.CodeFirst.InitTables<TN_Task_Action>();
                db.CodeFirst.InitTables<TN_Task>();
                db.CodeFirst.InitTables<TN_Location>();
                db.CodeFirst.InitTables<TN_Loc_Container>();
                var entityTypes = new Type[] {
                    typeof(TN_CAR_IN),
                    typeof(TN_CG_Detail),
                    typeof(TN_Container),
                    typeof(TN_Loc_Container),
                    typeof(TN_Location),
                    typeof(TN_Task),
                    typeof(TN_Task_Action),
                    typeof(SysHelper.OI_SYS_MAXID),

                };

                using (var tran = db.Ado.UseTran()) {
                    if (cover) {
                        // 删除所有表（按依赖关系倒序）
                        var tables = db.DbMaintenance.GetTableInfoList();
                        foreach (var table in tables.OrderByDescending(t => t.Name)) {
                            db.DbMaintenance.DropTable(table.Name);
                        }

                        // 创建新表
                        db.CodeFirst.InitTables(entityTypes);

                        //db.CodeFirst.BackupTable().InitTables(entityTypes);
                    }
                    else {
                        db.CodeFirst.InitTables(entityTypes);
                    }

                    tran.CommitTran();
                }

            }
            catch (Exception ex) {
                LogHelper.Info($"发生了异常");
@@ -34,6 +125,119 @@
            return "成功";
        }

        public static string InsertLocCntrCg(LocCntrCg locCntrCg) {
            var db = DbHelper.GetDbClient();

            try {
                using (var tran = db.UseTran()) {
                    LogHelper.Info("LogCntrCg：" + JsonConvert.SerializeObject(locCntrCg));
                    if (string.IsNullOrEmpty(locCntrCg.LocCode)) {
                        return "参数非法";
                    }

                    var loc = db.Queryable<TN_Location>().First(a => a.S_CODE == locCntrCg.LocCode);
                    if (loc == null) {
                        var newLoc = new TN_Location {
                            S_CODE = locCntrCg.LocCode,
                            S_AREA_CODE = locCntrCg.LocArea ?? ""
                        };

                        if (db.Insertable<TN_Location>(newLoc).ExecuteCommand() <= 0) {
                            tran.RollbackTran();
                            LogHelper.Info($"插入位置{locCntrCg.LocCode}失败");
                            return "插入失败";
                        }

                        loc = newLoc;
                    }

                    //if (loc.N_CURRENT_NUM == 0) {
                    //    loc.N_CURRENT_NUM = 1;
                    //    if (db.Updateable<TN_Location>(loc).UpdateColumns(
                    //        it => new { it.N_CURRENT_NUM, it.T_MODIFY }).ExecuteCommand() <= 0) {
                    //        tran.RollbackTran();
                    //        LogHelper.Info($"修改位置{locCntrCg.LocCode}失败");
                    //        continue;
                    //    }
                    //}

                    if (string.IsNullOrEmpty(locCntrCg.CntrCode)) {
                        tran.CommitTran();
                        LogHelper.Info("容器号为空，不再读取后面的数据");
                        return "容器号为空，不再读取后面的数据";
                    }

                    var locCntrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == locCntrCg.LocCode
                        && a.S_CNTR_CODE == locCntrCg.CntrCode);

                    if (locCntrRel == null) {
                        var newLocCntrRel = new TN_Loc_Container {
                            S_LOC_CODE = locCntrCg.LocCode,
                            S_CNTR_CODE = locCntrCg.CntrCode
                        };

                        loc.N_CURRENT_NUM = 1;

                        if (db.Insertable<TN_Loc_Container>(newLocCntrRel).ExecuteCommand() <= 0
                            && db.Updateable<TN_Location>(loc).UpdateColumns(c => c.N_CURRENT_NUM).ExecuteCommand() <= 0) {
                            tran.RollbackTran();
                            LogHelper.Info($"插入位置托盘关系{locCntrCg.LocCode}-{locCntrCg.CntrCode}失败");
                            return "插入失败";
                        }
                    }

                    if (string.IsNullOrEmpty(locCntrCg.ItemCode)) {
                        tran.CommitTran();
                        LogHelper.Info("物料号为空，不再读取后面的数据");
                        return "物料号为空，不再读取后面的数据";
                    }

                    var cgDetail = db.Queryable<TN_CG_Detail>().First(a => a.S_CNTR_CODE == locCntrCg.CntrCode
                        && a.S_ITEM_CODE == locCntrCg.ItemCode);
                    if (cgDetail == null) {
                        var locList = new List<TN_CG_Detail>();
                        locList.Add(new TN_CG_Detail { S_CNTR_CODE = locCntrCg.CntrCode, S_ITEM_CODE = locCntrCg.ItemCode, S_BATCH_NO = locCntrCg.BatchNo ?? "" });
                        if (db.Insertable<TN_CG_Detail>(locList).ExecuteCommand() <= 0) {
                            tran.RollbackTran();
                            LogHelper.Info($"插入托盘物料关系{locCntrCg.CntrCode}-{locCntrCg}失败");
                            return "插入失败";
                        }
                    }
                    tran.CommitTran();
                }

                return "插入数据成功";

            }
            catch (Exception ex) {
                return $"{ex.Message}";
            }
        }

        public static string SetTaskWeight(SetTaskWeightInfo model) {
            var db = DbHelper.GetDbClient();
            var cgDetail = db.Queryable<TN_CG_Detail, TN_Task>((d, t) => d.S_CNTR_CODE == t.S_CNTR_CODE)
                .Where((d, t) => t.S_CODE == model.TaskNo).First();

            if (cgDetail == null) {
                return "找不到对应的物料信息";
            }

            cgDetail.F_QTY = model.Weight;

            try {
                if (db.Updateable<TN_CG_Detail>(cgDetail).UpdateColumns(it => it.F_QTY)
                    .ExecuteCommand() <= 0 ) {
                    return "修改失败";
                }
                return "修改成功";

            }
            catch (Exception ex) {

                return ex.Message;
            }

        }
    }
}