using Aucma.Core.Scanner; using Aucma.Scada.HikRobot; using Aucma.Scada.Model.domain; using HighWayIot.Common; using HighWayIot.Config; using HighWayIot.Log4net; using HighWayIot.Repository.service; using HighWayIot.TouchSocket; using System; using System.Collections.Generic; using System.Linq; using System.Runtime.InteropServices; using System.Threading; using System.Threading.Tasks; using static Aucma.Scada.Business.InStoreTaskHandle; namespace Aucma.Scada.Business { /// /// 入库业务逻辑 /// public sealed class InStoreBusiness { #region 单例实现 private static readonly Lazy lazy = new Lazy(() => new InStoreBusiness()); public static InStoreBusiness Instance { get { return lazy.Value; } } #endregion #region 对象引用 private LogHelper logHelper = LogHelper.Instance; private AppConfig appConfig = AppConfig.Instance; private RegisterServices registerServices = RegisterServices.Instance; private InStoreTaskHandle taskHandle = InStoreTaskHandle.Instance; #endregion #region 接口引用 /// /// 货道信息 /// private IBaseSpaceInfoService _spaceInfoService; /// /// 实时任务 /// private IRealTaskInfoService _taskInfoService; private IBaseSpaceDetailService _baseSpaceDetailService; private IBaseBomInfoService _baseBomInfoService; private IRecordInStoreService _recordInStore; private IPrintBarCodeServices _printBarCodeServices; // 过点数据表 private IMaterialCompletionServices _iMaterialCompletionServices; private IProductPlanInfoService _productPlanInfoServices; #endregion #region 委托事件 /// /// 初始化入库任务 /// /// public delegate void RefreshInStoreTask(RealTaskInfo taskInfos, bool isFinsih = false); public event RefreshInStoreTask RefreshInStoreTaskEvent; /// /// 扫码信息刷新 /// /// /// /// /// public delegate void RefreshScanMateriaCode(string materialCode, string materialName, string spaceName, string materialType); public event RefreshScanMateriaCode RefreshScanMateriaCodeEvent; /// /// 日志信息刷新 /// /// public delegate void RefreshLogMessage(string message); public event RefreshLogMessage RefreshLogMessageEvent; #endregion #region 变量定义 private int shellNoReadFlag = 0; private int linerNoReadFlag = 0; private string shell_materialCodeStr = string.Empty; private string liner_materialCodeStr = string.Empty; #endregion private InStoreBusiness() { _spaceInfoService = registerServices.GetService(); _taskInfoService = registerServices.GetService(); _baseSpaceDetailService = registerServices.GetService(); _baseBomInfoService = registerServices.GetService(); _recordInStore = registerServices.GetService(); _printBarCodeServices = registerServices.GetService(); _productPlanInfoServices = registerServices.GetService(); _iMaterialCompletionServices = registerServices.GetService(); // taskHandle.InStoreFinsihEvent += InStoreFinish; taskHandle.InStoreAnswerEvent += InStoreAnswer; taskHandle.BareBoardHandleEvent += BareBoardInStore; // MvCodeHelper.MessageNoReadEvent += MessageNoRead; // MvCodeHelper.RefreshMaterialCodeStrEvent += InStore; TouchSocketBusiness.RefreshMaterialCodeStrEvent += InStore; // MvCodeHelper.RefreshLogMessageEvent += PrintLogInfoMessage; StartPassDown(); } #region 入库请求逻辑处理,创建入库任务,包含空板入库 /// /// 入库 /// /// /// public void InStore(string materialCode, string scannerIp) { Task.Run(() => { try { string storeCode = string.Empty; if (appConfig.shellHikRobotIp.Equals(scannerIp)) { storeCode = appConfig.shellStoreCode; } else { storeCode = appConfig.linerStoreCode; } taskHandle.ClearSpaceCode(storeCode); PrintLogInfoMessage($"扫码成功,物料码:{materialCode}"); if (storeCode == appConfig.shellStoreCode) { shell_materialCodeStr = materialCode; } else { liner_materialCodeStr = materialCode; } string materialType = SubStringMaterialCode(materialCode); var spaceInfo = GetSpaceInfoByMaterialType(storeCode, materialType); if (spaceInfo != null) { PrintLogInfoMessage($"匹配货道:{spaceInfo.spaceName}"); spaceInfo.materialType = materialType; spaceInfo.typeNameA = GetMaterialName(materialType); RefreshScanMateriaCodeEvent?.Invoke(materialCode, GetMaterialName(materialType), spaceInfo.spaceName, storeCode); //刷新界面扫码信息 // 创建任务前先判断该仓库是否存在未下发任务,如果有,不再重复创建任务 RealTaskInfo taskInfo = _taskInfoService.GetTaskInfoByStoreCode(storeCode, 1); if (taskInfo != null) { logHelper.Info($"仓库{storeCode}存在未下发任务,不再重复创建任务"); return; } var result = CreateInStoreTask(spaceInfo, materialCode); //创建入库任务 if (result) { taskHandle.ClearSpaceCode(storeCode); #region 2023-12-15 更新过点数据,插入记录到MATERIAL_COMPLETION表 PrintBarCode print = _printBarCodeServices.query(materialCode); if (print != null) { MaterialCompletion completion = new MaterialCompletion(); completion.OrderCode = print.OrderCode; completion.MaterialBarcode = materialCode; completion.MaterialCode = print.MaterialCode; completion.MaterialName = print.MaterialName; // 过点工位,与强哥确认 ,内胆存1003,箱壳1002 if (materialCode.Substring(0, 1) == "L") { completion.StationName = "1003"; } else { completion.StationName = appConfig.stationCode; } completion.CompleteDate = DateTime.Now; completion.ProductLineCode = "CX_02"; completion.IsDownLine = 0; _iMaterialCompletionServices.Add(completion); } #endregion _spaceInfoService.UpdateSpaceInfo(spaceInfo); } } else { //报警 PrintLogInfoMessage($"物料码:{materialCode};未匹配到可用货道"); BareBoardInStore(storeCode, false); } } catch (Exception ex) { PrintLogErrorMessage("入库业务异常", ex); } }); } private string last_shell_materialCodeStr = string.Empty; private string last_liner_materialCodeStr = string.Empty; /// /// 空板入库逻辑 /// /// private void BareBoardInStore(string storeCode, bool isFlag = true) { try { // 创建空板任务前先判断是否存在未下发任务,如果有,不再重复创建任务 RealTaskInfo taskInfo = _taskInfoService.GetTaskInfoByStoreCode(storeCode, 1); if (taskInfo != null) return; taskHandle.ClearSpaceCode(storeCode); string typeStr = isFlag ? "空板入库请求" : "读取失败自动进入异常道"; string logStr = storeCode == appConfig.shellStoreCode ? "收到箱壳" : "收到内胆"; PrintLogInfoMessage(logStr + typeStr + ";筛选异常货道创建入库任务"); //获取异常货道 var spaceList = _spaceInfoService.GetSpaceInfosByStoreCode(storeCode); if (spaceList != null) { var unusualspaceList = spaceList.Where(x => x.unusualFlag == 2).ToList(); BaseSpaceInfo spaceInfo = GetSpaceInfosByPlc(unusualspaceList, true); //判断货道库存,不存在合适的获取空白货道 if (spaceInfo != null) { CreateInStoreTask(spaceInfo, null); } else { string str = storeCode == appConfig.shellStoreCode ? "箱壳异常入库" : "内胆异常入库"; PrintLogInfoMessage(str + "; 未获取到可用的异常货道"); List emptySpaceInfo = _spaceInfoService.GetEmptySpaceInfo(storeCode); if (emptySpaceInfo != null && emptySpaceInfo.Count > 0) { BaseSpaceInfo empty_space = GetSpaceInfosByPlc(emptySpaceInfo, true); if (empty_space != null) { CreateInStoreTask(empty_space, null); empty_space.unusualFlag = 2; _spaceInfoService.UpdateSpaceInfo(empty_space); PrintLogInfoMessage($"{str}; 占用货道{empty_space.spaceName};为异常道"); } } else { BaseSpaceInfo zhanYong_space = GetSpaceInfosByPlc(spaceList, true); if (zhanYong_space != null) { CreateInStoreTask(zhanYong_space, null); PrintLogInfoMessage($"{str}; 没有异常道可分配,占用{zhanYong_space.spaceName};存放异常物料"); } } } } else { string str = storeCode == appConfig.shellStoreCode ? "箱壳异常入库" : "内胆异常入库"; PrintLogInfoMessage(str + ";系统内未设置异常货道"); } } catch (Exception ex) { PrintLogErrorMessage("空板入库逻辑处理异常", ex); } } /// /// 创建入库任务 /// /// private bool CreateInStoreTask(BaseSpaceInfo spaceInfo, string materialCode) { bool result = false; #region 任务赋值 RealTaskInfo realTaskInfo = new RealTaskInfo(); realTaskInfo.taskType = 1; realTaskInfo.taskCode = System.Guid.NewGuid().ToString("N").Substring(0, 6); realTaskInfo.storeCode = spaceInfo.storeCode; realTaskInfo.spaceCode = spaceInfo.spaceCode; realTaskInfo.materialType = spaceInfo.materialType; realTaskInfo.materialCode = materialCode; realTaskInfo.planAmount = 1; realTaskInfo.taskStatus = 1; realTaskInfo.createTime = DateTime.Now; #endregion result = _taskInfoService.AddTaskInfo(realTaskInfo); if (result) { PrintLogInfoMessage("入库任务创建成功"); RefreshInStoreTaskEvent?.Invoke(realTaskInfo); result = true; } else { PrintLogInfoMessage("入库任务创建失败"); } return result; } #endregion #region 轮询获取入库任务下发至PLC,等待PLC执行反馈,完成后再次下发 private SemaphoreSlim shellSemaphore = new SemaphoreSlim(0); private SemaphoreSlim linerSemaphore = new SemaphoreSlim(0); private void StartPassDown1() { Thread shellThread = new Thread(() => { while (true) { Console.WriteLine("箱壳入库线程任务下发"); PassDownShellTask(); Thread.Sleep(2000); } }); Thread linerThread = new Thread(() => { while (true) { Console.WriteLine("内胆入库线程任务下发"); PassDownLinerTask(); Thread.Sleep(2000); } }); shellThread.Start(); linerThread.Start(); } /// /// 任务下发 /// private void StartPassDown() { Task.Run(() => { while (true) { Console.WriteLine("箱壳入库线程任务下发"); PassDownShellTask(); Thread.Sleep(2000); } }); Task.Run(() => { while (true) { Console.WriteLine("内胆入库线程任务下发"); PassDownLinerTask(); Thread.Sleep(2000); } }); } /// /// 依次获取箱壳任务队列进行下发 /// /// /// private void PassDownShellTask() { try { lock (string.Empty) { RealTaskInfo taskInfo = _taskInfoService.GetTaskInfoByStoreCode(appConfig.shellStoreCode, appConfig.instoreTaskType); if (taskInfo != null) { shellNoReadFlag = 1; int result = taskHandle.SendShellTask_InStore(taskInfo); if (result == 1) { PrintLogInfoMessage($"箱壳入库任务:{taskInfo.taskCode};下发成功,等待PLC执行反馈"); Console.WriteLine("箱壳信号量锁住等待释放"); // shellSemaphore.Wait(); //一直堵塞直到信号量释放 Console.WriteLine("箱壳信号量释放"); shellNoReadFlag = 0; PrintLogInfoMessage($"箱壳入库任务:{taskInfo.taskCode};开始执行"); taskInfo.taskStatus = 2; _taskInfoService.UpdateTaskInfo(taskInfo); RefreshInStoreTaskEvent?.Invoke(taskInfo); } else if (result == 2) { PrintLogInfoMessage("箱壳入库任务下发失败,PLC接收任务未就绪"); } else { PrintLogInfoMessage($"箱壳入库任务:{taskInfo.taskCode};下发失败,请排除PLC连接"); } } } } catch (Exception ex) { PrintLogErrorMessage("依次获取箱壳任务队列进行下发逻辑异常", ex); } } /// /// 依次获取内胆任务队列进行下发 /// private void PassDownLinerTask() { try { lock (string.Empty) { RealTaskInfo taskInfo = _taskInfoService.GetTaskInfoByStoreCode(appConfig.linerStoreCode, appConfig.instoreTaskType); if (taskInfo != null) { linerNoReadFlag = 1; int result = taskHandle.SendLinerTask_InStore(taskInfo); if (result == 1) { PrintLogInfoMessage($"内胆入库任务:{taskInfo.taskCode};下发成功,等待PLC执行反馈"); Console.WriteLine("内胆信号量锁住等待释放"); // linerSemaphore.Wait(); //一直堵塞直到信号量释放 Console.WriteLine("内胆信号量释放"); linerNoReadFlag = 0; PrintLogInfoMessage($"内胆入库任务:{taskInfo.taskCode};开始执行"); taskInfo.taskStatus = 2; _taskInfoService.UpdateTaskInfo(taskInfo); RefreshInStoreTaskEvent?.Invoke(taskInfo); } else if (result == 2) { PrintLogInfoMessage("内胆入库任务下发失败,PLC接收任务未就绪"); } else { PrintLogInfoMessage($"内胆入库任务:{taskInfo.taskCode};下发失败,请排除PLC连接"); } } } } catch (Exception ex) { PrintLogErrorMessage("依次获取内胆任务队列进行下发逻辑异常", ex); } } #endregion #region PLC应答逻辑,应答后完成入库任务 /// /// 入库应答,PLC收到入库任务后进行应答 /// /// /// private void InStoreAnswer(string storeCode, string taskCode) { if (storeCode == appConfig.shellStoreCode) { PrintLogInfoMessage("箱壳应答成功,自动释放信号量,进行下发新任务"); // shellSemaphore.Release(); PrintLogInfoMessage($"箱壳任务:{taskCode};执行完成"); InStoreFinishHandle(taskCode, appConfig.shellStoreCode); } else { PrintLogInfoMessage("内胆应答成功,自动释放信号量,进行下发新任务"); // linerSemaphore.Release(); PrintLogInfoMessage($"内胆任务:{taskCode};执行完成"); InStoreFinishHandle(taskCode, appConfig.linerStoreCode); } } /// /// 入库完成逻辑处理 /// /// /// /// private void InStoreFinishHandle(string taskCode, string storeCode) { try { var taskInfo = _taskInfoService.GetTaskInfoByTaskCode(taskCode, storeCode); if (taskInfo != null) { var spaceInfo = _spaceInfoService.GetSpaceInfoBySpaceCode(taskInfo.storeCode, taskInfo.spaceCode); if (spaceInfo != null) { #region 添加货道明细 BaseSpaceDetail spaceDetail = new BaseSpaceDetail(); spaceDetail.materialType = taskInfo.materialType; spaceDetail.materialCode = taskInfo.materialCode; spaceDetail.materialName = GetMaterialName(taskInfo.materialType); spaceDetail.storeCode = spaceInfo.storeCode; spaceDetail.spaceCode = spaceInfo.spaceCode; spaceDetail.materialAmount = 1; spaceDetail.createTime = DateTime.Now; spaceDetail.detailCode = System.Guid.NewGuid().ToString("N").Substring(0, 10); _baseSpaceDetailService.InsertSpaceDetail(spaceDetail); #endregion #region 添加入库记录 RecordInstore recordInstore = new RecordInstore(); recordInstore.storeCode = taskInfo.storeCode; recordInstore.spaceCode = taskInfo.spaceCode; recordInstore.materialCode = taskInfo.materialCode; recordInstore.materialType = taskInfo.materialType; recordInstore.materialName = GetMaterialName(taskInfo.materialType); recordInstore.inStoreAmount = 1; recordInstore.inStoreTime = DateTime.Now; recordInstore.barcodeCode = taskInfo.materialCode; _recordInStore.InsertRecordInStore(recordInstore); #endregion } //清除任务信息 _taskInfoService.DeleteTaskInfo(taskCode, storeCode); } RefreshInStoreTaskEvent?.Invoke(taskInfo, true); } catch (Exception ex) { PrintLogErrorMessage("入库完成逻辑处理异常", ex); } } #endregion #region 通过PLC读取货道信息:在库、在途、货道状态 /// /// 通过PLC读取货道信息(在途数量、在库数量、货道状态) /// /// /// /// private BaseSpaceInfo GetSpaceInfoByMaterialType(string storeCode, string materialType) { BaseSpaceInfo result = null; try { List info = _spaceInfoService.GetBaseSpaceInfosByMaterialType(storeCode, materialType); if (info != null) { if (info.Count > 0) { info = info.Where(x => x.unusualFlag != 2).ToList(); result = GetSpaceInfosByPlc(info); if (result == null) { var list = _spaceInfoService.GetEmptySpaceInfo(storeCode); result = GetSpaceInfosByPlc(list); } } } } catch (Exception ex) { PrintLogErrorMessage("货道信息读取异常", ex); } return result; } /// /// 读取PLC货道信息 /// isFlag 是否空板 /// /// /// private BaseSpaceInfo GetSpaceInfosByPlc(List info, bool isFlag = true) { BaseSpaceInfo result = null; if (info != null) { if (info.Count > 0) { foreach (BaseSpaceInfo item in info) { var spaceInfo = taskHandle.ReadSpaceInfoByPlc(item); item.spaceStock = spaceInfo.spaceStock; item.onRouteAmount = spaceInfo.onRouteAmount; item.spaceStatus = spaceInfo.spaceStatus; PrintLogInfoMessage($"通过PLC读取货道信息,货道:{spaceInfo.spaceName};在库数量:{item.spaceStock};在途数量:{item.onRouteAmount};货道状态:{item.spaceStatus}"); } if (isFlag) { var list = info.Where(x => x.spaceStock > 0 ? x.spaceCapacity > (x.spaceStock + x.onRouteAmount) : 1 == 1 && x.spaceStatus == 1).ToList(); if (list.Count > 0) { result = list.OrderByDescending(x => x.spaceStock).First(); } } else { var list = info.Where(x => x.spaceStock > 0 ? x.spaceCapacity > (x.spaceStock + x.onRouteAmount) : 1 == 1 && x.spaceStatus == 4).ToList(); if (list.Count > 0) { result = list.OrderByDescending(x => x.spaceStock).First(); } } } } return result; } #endregion /// /// 截取条码 /// /// /// private string SubStringMaterialCode(string materialCode) { string result = string.Empty; if (!string.IsNullOrEmpty(materialCode)) { result = materialCode.Substring(7, 10); } return result; } /// /// 获取已创建的所有入库任务 /// /// public List GetInStoreTask() { return _taskInfoService.GetTaskInfosByStoreCode(new string[] { appConfig.shellStoreCode, appConfig.linerStoreCode }, appConfig.instoreTaskType); } /// /// 通过BOM获取物料名称 /// /// /// public string GetMaterialName(string materialType) { string materialName = string.Empty; var info = _baseBomInfoService.GetBomInfoByMaterialCode(materialType); if (info != null) { materialName = info.materialName; } return materialName; } /// /// 获取仓库物料库存 /// /// public List GetStock() { List infos = _spaceInfoService.GetSpaceInfosByTwoStoreCode(appConfig.shellStoreCode, appConfig.linerStoreCode); return infos; } /// /// 通过任务编号删除任务 /// /// 任务删除后是否需要还原库存,如果出库完成后减少库存则不需要 /// /// /// /// public bool DeleteTaskInfoByTaskCode(string taskCode, bool isFlag) { bool result = false; var info = _taskInfoService.GetTaskInfosByTaskCode(taskCode); if (info != null && info.Count > 0) { RealTaskInfo taskInfo = info[0]; result = _taskInfoService.DeleteTaskInfoById(taskInfo.objId); } return result; } #region 日志输出 /// /// 日志输出,界面刷新同时记录文件 /// /// private void PrintLogInfoMessage(string message) { RefreshLogMessageEvent?.Invoke(message); logHelper.Info(message); } /// /// 异常日志输出 /// /// /// private void PrintLogErrorMessage(string message, Exception ex = null) { RefreshLogMessageEvent?.Invoke(message); logHelper.Error(message, ex); } #endregion /// /// 通过货道号查找货道 /// /// public BaseSpaceInfo getSpaceBySpaceCode(string storeCode,string spaceCode) { return _spaceInfoService.GetSpaceInfoBySpaceCode(storeCode,spaceCode); } } }