合肥佳通AGV项目
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
lss
2025-05-30 9b015b21e39bb427c8fcfdcbda795d3a3c450d52 
 HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/api/ApiHelper.cs


@@ -11,8 +11,11 @@


using System;


using System.Collections.Generic;


using System.Linq;


using System.Reflection.Emit;


using System.ServiceModel;


using System.Threading;


using System.Threading.Tasks;


using System.Web.UI.WebControls;


using static HH.WCS.JiaTong.api.ApiModel;


using static HH.WCS.JiaTong.api.OtherModel;


using static HH.WCS.JiaTong.LISTA.process.HttpModel;


@@ -155,6 +158,7 @@


                }


                else if (taskData.taskType == 2)//入库流程，直接使用起点货位和终点货位生成任务，起点需要有托盘


                {


                    note = "入库";


                    startloc = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == taskData.pickStation).First();


                    if (startloc != null)


                    {


@@ -173,12 +177,7 @@


                        }




                    }


                    //判断是否是空托回库


                    var CntrItem = db.Queryable<CntrItemDetail>().Where(a => a.S_CNTR_CODE.Trim() == CntrCode).First();


                    if (CntrItem == null)


                    {


                        note = "空托回库";//井松空托回库，需要与叠盘机安全交互


                    }




                    endloc = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == taskData.dropStation).First();


                    if (endloc != null)


                    {


@@ -194,8 +193,8 @@


                }


                else if (taskData.taskType == 3)//移库流程，直接使用起点货位和终点货位生成任务，


                {


                    note = "出库";


                    //创建托盘物料绑定信息，并计算终点货位




                    startloc = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == taskData.pickStation).First();


                    if (startloc != null)


                    {


@@ -388,6 +387,7 @@


                //暂存位回库


                else if (taskData.taskType == 6)//入库流程，直接使用起点货位和终点货位生成任务


                {


                    note = "入库";


                    //根据托盘号找货位


                    var CntrRel = db.Queryable<LocCntrRel>().Where(a => a.S_CNTR_CODE == partData.rfid).First();


                    if (CntrRel != null)


@@ -806,6 +806,7 @@


                        result.msg = $"根据起点仓库编码：{startloc.S_WH_CODE}未找到对应配置文件";


                        LogHelper.Info($"Putin==> {result.msg}");


                        AddErrorInfo("查找库区失败", result.msg, Source);


                        return result;


                    }




                    //判断有无相同物料排


@@ -826,6 +827,7 @@


                        result.msg = $"库区:{areacode}无可用货位";


                        LogHelper.Info($"Putin==> {result.msg}");


                        AddErrorInfo("查找库区失败", result.msg, Source);


                        return result;


                    }


                }


                else


@@ -835,6 +837,7 @@


                    result.msg = $"任务起点:{Start}找不到对应货位，请检查货位表";


                    LogHelper.Info($"Putin==> {result.msg}");


                    AddErrorInfo("查找货位失败", result.msg, Source);


                    return result;


                }


                #endregion




@@ -939,6 +942,7 @@


                    result.msg = $"根据机台编码：{model.WorkCenter}未找到对应货位";


                    LogHelper.Info($"Putin==> {result.msg}");


                    AddErrorInfo("查找库区失败", result.msg, Source);


                    return result;


                }


                //根据仓库 计算库区


                var whcode = Settings.wareLoc.Where(a => a.AreaCode == locJt.S_WH_CODE).FirstOrDefault();


@@ -973,6 +977,7 @@


                    result.msg = $"根据终点库区仓库编码：{locJt.S_WH_CODE}未找到对应配置文件";


                    LogHelper.Info($"Putin==> {result.msg}");


                    AddErrorInfo("查找库区失败", result.msg, Source);


                    return result;


                }


                #endregion




@@ -991,6 +996,14 @@


                    {


                        End = Endloc.S_CODE;


                    }


                    else


                    {


                        result.code = "1";


                        result.msg = $"Computeloc==》根据机台编码：{model.WorkCenter},工装类型：{cntrType} 未找到空货位数据，请检查货位表";


                        LogHelper.Info($"ItemBack：{result.msg}");


                        AddErrorInfo("查找库区失败", result.msg, Source);


                        return result;


                    }


                }


                else


                {


@@ -999,6 +1012,7 @@


                    result.msg = $"任务物料:{itemcode}找不到对应库存";


                    LogHelper.Info($"ItemBack：{result.msg}");


                    AddErrorInfo("查找库区失败", result.msg, Source);


                    return result;


                }


                #endregion




@@ -1192,6 +1206,7 @@


                            result.msg = $"根据起点仓库编码：{startloc.S_WH_CODE}未找到对应配置文件";


                            LogHelper.Info($"Putin==> {result.msg}");


                            AddErrorInfo("查找库区失败", result.msg, Source);


                            return result;


                        }


                        #endregion




@@ -1333,11 +1348,12 @@


                        result.msg = $"根据起点仓库编码：{endloc.S_WH_CODE}未找到对应配置文件";


                        LogHelper.Info($"Putin==> {result.msg}");


                        AddErrorInfo("查找库区失败", result.msg, Source);


                        return result;


                    }






                    //计算出库托盘


                    startloc = airlift(areacode, itemcode);


                    startloc = LocationHelper.GetLocByAreacode(areacode);


                    if (startloc != null)


                    {


                        var cntr = db.Queryable<LocCntrRel>().Where(a => a.S_LOC_CODE.Trim() == startloc.S_CODE).First();


@@ -1365,7 +1381,7 @@


                    result.msg = $"任务起点:{End}找不到对应货位，请检查货位表";


                    LogHelper.Info($"callfixture:{result.msg}");


                    AddErrorInfo("查找货位失败", result.msg, Source);




                    return result;


                }


                #endregion




@@ -1551,7 +1567,8 @@


                            var EndLocs = db.Queryable<Location>().Where(a => a.S_AREA_CODE.Trim() == areacode).ToList();


                            if (EndLocs.Count > 0)


                            {


                                loc = EndLocs.Find(a => a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0);


                                //loc =  EndLocs.Find(a => a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0);


                                loc = FindEndcolByLocList(EndLocs);


                                if (loc != null)


                                {


                                    End = loc.S_CODE;


@@ -1598,6 +1615,7 @@


                        result.msg = $"根据起点仓库编码：{startloc.S_WH_CODE}未找到对应配置文件";


                        LogHelper.Info($"Putin==> {result.msg}");


                        AddErrorInfo("查找库区失败", result.msg, Source);


                        return result;


                    }




                }


@@ -2133,8 +2151,8 @@


                        if (CntrItem != null)


                        {




                            LocationHelper.UnBindingLoc(loc, new List<string>() { "cntrcode" });


                            //  db.Deleteable<LocCntrRel>().Where(it => it.S_LOC_CODE.Trim() == loc).ExecuteCommand();


                            LocationHelper.UnBindingLoc(loc, new List<string>() { cntrcode });


                            // db.Deleteable<LocCntrRel>().Where(it => it.S_LOC_CODE.Trim() == loc).ExecuteCommand();


                            db.Deleteable<CntrItemDetail>().Where(it => it.S_CNTR_CODE.Trim() == cntrcode).ExecuteCommand();




                        }


@@ -2169,7 +2187,99 @@




            return result;


        }


        /// <summary>


        /// 设备状态上报


        /// </summary>


        /// <returns></returns>


        internal static DeviceInfoModel Device()


        {


            var db = new SqlHelper<HangChaAGV>().GetInstance();


            DeviceInfoModel device = new DeviceInfoModel();




            List<DeviceInfos> deviceInfos = new List<DeviceInfos>();//叠盘机报错信息


            List<AgvInfos> agvInfos = new List<AgvInfos>();//agv报错信息




            //获取内存中叠盘机的报错信息


            foreach (var dpjInfo in DeviceProcess.DpjInfoDirectory)


            {


                deviceInfos.Add(new DeviceInfos() { Device = dpjInfo.Value.DeviceName, DeviceInfo = dpjInfo.Value.ErrorInfo });


            }


            device.DeviceInfos = deviceInfos;


            //获取车辆报警信息


            var agvDeviceInfo = db.Queryable<HangChaAGV>().ToList();


            if (agvDeviceInfo.Count > 0)


            {


                device.AgvQty = agvDeviceInfo.Count;


                device.AgvErrorQty = agvDeviceInfo.FindAll(a => a.agvErrCode != "0" || a.agvErrCode != "0" || a.faildCode != "0").Count;


                device.AgvChargeQty = agvDeviceInfo.FindAll(a =>  a.agvErrCode == "1").Count;


                device.AgvRunQty = agvDeviceInfo.FindAll(a =>  a.agvErrCode == "1").Count;


                foreach (var agv in agvDeviceInfo)


                {


                    string agvErrorInfo = GetAgvAlarmSendCodeTwo(agv.agvErrCode, agv.errCode2, agv.faildCode);


                    agvInfos.Add(new AgvInfos() { AgvNo = agv.agvNo, AgvInfo = agvErrorInfo });


                }


            }


            device.AgvInfos = agvInfos;




            return device;


        }




        /// <summary>


        /// agv小车故障码处理


        /// </summary>


        /// <param name="errCode1">错误码1</param>


        /// <param name="errCode2">错误码2</param>


        /// <param name="faildCode">错误码3</param>


        /// <returns></returns>


        private static string GetAgvAlarmSendCodeTwo(string errCode1, string errCode2, string faildCode)


        {


            string result = "";


            //将报警信息整合


            string binSW1 = Convert.ToString(int.Parse(errCode1), 2).PadLeft(22, '0');


            string binSW2 = Convert.ToString(int.Parse(errCode1), 2).PadLeft(20, '0');


            string binFc = Convert.ToString(int.Parse(errCode1), 2).PadLeft(16, '0');


            var arr1 = binSW1.ToArray();


            var arr2 = binSW2.ToArray();


            var arr3 = binFc.ToArray();




            for (int i = 0; i <= arr1.Length; i++)


            {


                if (arr1[i] == '1')


                {


                    var ErrorInfo = Settings.agvErrorCode1.Where(a => a.ErrorCode == i).FirstOrDefault();


                    if (ErrorInfo != null)


                    {


                        result = result + "," + $"{ErrorInfo.ErrorInfo}";


                    }




                }


            }


            for (int i = 0; i <= arr2.Length; i++)


            {


                if (arr1[i] == '1')


                {


                    var ErrorInfo = Settings.agvErrorCode2.Where(a => a.ErrorCode == i).FirstOrDefault();


                    if (ErrorInfo != null)


                    {


                        result = result + "," + $"{ErrorInfo.ErrorInfo}";


                    }




                }


            }


            for (int i = 0; i <= arr3.Length; i++)


            {


                if (arr1[i] == '1')


                {


                    var ErrorInfo = Settings.agvFaildCode.Where(a => a.ErrorCode == i).FirstOrDefault();


                    if (ErrorInfo != null)


                    {


                        result = result + "," + $"{ErrorInfo.ErrorInfo}";


                    }




                }


            }


            return result;


        }


        #endregion




        #region 合肥佳通业务方法


@@ -2297,7 +2407,12 @@


            #endregion


            var loc = LocationHelper.GetLocByItemCode(areacode, itemcode, level);


            LogHelper.Info($"airlift=>根据库区编码:{areacode}，物料编码:{itemcode},物料等级计算出有托盘货位{JsonConvert.SerializeObject(loc)}");


            result = FindStartcolByLoclist(loc);


            // result = FindStartcolByLoclist(loc);


            if (loc.Count > 0)


            {


                result = loc.OrderByDescending(a => a.N_COL).First();


            }




            LogHelper.Info($"airlift=>可用货位为：{JsonConvert.SerializeObject(result)}");


            return result;


        }


@@ -2415,7 +2530,7 @@


        /// </summary>


        /// <param name="locations"></param>


        /// <returns></returns>


        internal static Location FindEndcolByLocList(List<Location> locations, string itemcode)


        internal static Location FindEndcolByLocList(List<Location> locations)


        {


            try


            {


@@ -2508,9 +2623,9 @@


            }




        }






        #endregion








        internal static CodeInfo GetCodeInfo(string code, string org)


        {