| | |
|---|
| | | "MainDB": "DB_WIDESEA", //当前项目的主库，所对应的连接字符串的Enabled必须为true |
|---|
| | | //连接字符串 |
|---|
| | | //"ConnectionString": "HTI6FB1H05Krd07mNm9yBCNhofW6edA5zLs9TY~MNthRYW3kn0qKbMIsGp~3yyPDF1YZUCPBQx8U0Jfk4PH~ajNFXVIwlH85M3F~v_qKYQ3CeAz3q1mLVDn8O5uWt1~3Ut2V3KRkEwYHvW2oMDN~QIDXPxDgXN0R2oTIhc9dNu7QNaLEknblqmHhjaNSSpERdDVZIgHnMKejU_SL49tralBkZmDNi0hmkbL~837j1NWe37u9fJKmv91QPb~16JsuI9uu0EvNZ06g6PuZfOSAeFH9GMMIZiketdcJG3tHelo=", |
|---|
| | | "ConnectionString": "Data Source=127.0.0.1;Initial Catalog=WIDESEA_WCS2F08;User ID=sa;Password=P@ssw0rd;Integrated Security=False;Connect Timeout=30;Encrypt=False;TrustServerCertificate=True;ApplicationIntent=ReadWrite;MultiSubnetFailover=True", |
|---|
| | | //"ConnectionString": "Data Source=127.0.0.1;Initial Catalog=WIDESEA_WCS2F08;User ID=sa;Password=P@ssw0rd;Integrated Security=False;Connect Timeout=30;Encrypt=False;TrustServerCertificate=True;ApplicationIntent=ReadWrite;MultiSubnetFailover=True", |
|---|
| | | //"ConnectionString": "Data Source=192.168.20.251;Initial Catalog=WIDESEA_WCSDB;User ID=sa;Password=123456@gy;Integrated Security=False;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False", |
|---|
| | | //"ConnectionString": "Data Source=192.168.5.251;Initial Catalog=WIDESEAWCS_TEST;User ID=sa;Password=P@ssw0rd;Integrated Security=False;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False", |
|---|
| | | "ConnectionString": "Data Source=192.168.5.251;Initial Catalog=WIDESEAWCS_TEST;User ID=sa;Password=P@ssw0rd;Integrated Security=False;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False", |
|---|
| | | //跨域 |
|---|
| | | "Cors": { |
|---|
| | | "PolicyName": "CorsIpAccess", //策略名称 |
|---|
| | |
|---|
| | | ConveyorLineTaskCommandWrite commandWrite = conveyorLine.ReadCustomer<ConveyorLineTaskCommandWrite>(childDeviceCode, "DeviceCommand"); |
|---|
| | | if (command != null && commandWrite != null) |
|---|
| | | { |
|---|
| | | |
|---|
| | | #region 调用事件总线通知前端 |
|---|
| | | |
|---|
| | | var tokenInfos = _cacheService.Get<List<UserInfo>>("Cache_UserToken"); |
|---|
| | | if (tokenInfos == null || !tokenInfos.Any()) |
|---|
| | | { |
|---|
| | | //throw new Exception(conveyorLine.DeviceName + "缓存中未找到Token缓存"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | var userTokenIds = tokenInfos?.Select(x => x.Token_ID).ToList(); |
|---|
| | | var userIds = tokenInfos?.Select(x => x.UserId).ToList(); |
|---|
| | | |
|---|
| | | object obj = new |
|---|
| | | { |
|---|
| | | command, |
|---|
| | | commandWrite |
|---|
| | | }; |
|---|
| | | _noticeService.LineData(userIds?.FirstOrDefault(), userTokenIds, new { conveyorLine.DeviceName, childDeviceCode, data = obj }); |
|---|
| | | |
|---|
| | | #endregion 调用事件总线通知前端 |
|---|
| | | |
|---|
| | | var structs = BitConverter.GetBytes(commandWrite.WriteInteractiveSignal).Reverse().ToArray().ToBoolArray(); |
|---|
| | | |
|---|
| | | List<DeviceProtocolDetailDTO>? deviceProtocolDetails = conveyorLine.DeviceProtocolDetailDTOs.Where(x => x.DeviceProParamName == nameof(ConveyorLineTaskCommand.InteractiveSignal)).ToList(); |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | #region 调用事件总线通知前端 |
|---|
| | | |
|---|
| | | var tokenInfos = _cacheService.Get<List<UserInfo>>("Cache_UserToken"); |
|---|
| | | if (tokenInfos == null || !tokenInfos.Any()) |
|---|
| | | { |
|---|
| | | //throw new Exception(conveyorLine.DeviceName + "缓存中未找到Token缓存"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | var userTokenIds = tokenInfos?.Select(x => x.Token_ID).ToList(); |
|---|
| | | var userIds = tokenInfos?.Select(x => x.UserId).ToList(); |
|---|
| | | |
|---|
| | | object obj = new |
|---|
| | | { |
|---|
| | | command, |
|---|
| | | commandWrite |
|---|
| | | }; |
|---|
| | | _noticeService.LineData(userIds?.FirstOrDefault(), userTokenIds, new { conveyorLine.DeviceName, childDeviceCode, data = obj }); |
|---|
| | | |
|---|
| | | #endregion 调用事件总线通知前端 |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | { |
|---|
| | | HandleTaskOut(conveyorLine, command, childDeviceCode, ProtocalDetailValue, task); |
|---|
| | | } |
|---|
| | | else |
|---|
| | | { |
|---|
| | | var next = task.NextAddress; |
|---|
| | | var taskCommand = MapTaskCommand(task, command); |
|---|
| | | task.NextAddress = next; |
|---|
| | | conveyorLine.SendCommand(taskCommand, childDeviceCode); |
|---|
| | | |
|---|
| | | ConsoleHelper.WriteWarningLine($"【{conveyorLine._deviceName}】任务号：【{command.TaskNum}】,托盘条码：【{command.Barcode}】已到达【{childDeviceCode}】请求扫码入库,下一目标地址【{taskCommand.TargetAddress}】"); |
|---|
| | | |
|---|
| | | ConveyorLineSendFinish(conveyorLine, childDeviceCode, ProtocalDetailValue, true); |
|---|
| | | _taskService.UpdateTaskStatusToNext(task); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | else |
|---|
| | | { |
|---|
| | |
|---|
| | | private Dt_Task? GetTask(CommonStackerCrane commonStackerCrane) |
|---|
| | | { |
|---|
| | | Dt_Task task; |
|---|
| | | var taskRun = _taskRepository.QueryFirst(x => x.Roadway == commonStackerCrane.DeviceCode && (x.TaskState == (int)TaskOutStatusEnum.SC_OutExecuting || x.TaskState == (int)TaskInStatusEnum.SC_InExecuting)); |
|---|
| | | if (taskRun != null) { return null; } |
|---|
| | | //var taskRun = _taskRepository.QueryFirst(x => x.Roadway == commonStackerCrane.DeviceCode && (x.TaskState == (int)TaskOutStatusEnum.SC_OutExecuting || x.TaskState == (int)TaskInStatusEnum.SC_InExecuting)); |
|---|
| | | //if (taskRun != null) { return null; } |
|---|
| | | if (commonStackerCrane.LastTaskType == null) |
|---|
| | | { |
|---|
| | | task = _taskService.QueryStackerCraneTask(commonStackerCrane.DeviceCode); |
|---|
| | |
|---|
| | | { field: 'isFull', title: '库存类型', type: 'bool', width: 110, align: 'left', bind: { key: "isFull", data: [] }, }, |
|---|
| | | { field: 'linedProcessFeedbackTime', title: '工艺开始时间', type: 'string', width: 110, align: 'left',}, |
|---|
| | | { field: 'specialParameterDuration', title: '工艺时长', type: 'string', width: 110, align: 'left', sort: true }, |
|---|
| | | { field: 'outboundTime', title: '应出库时间', type: 'string', width: 110, align: 'left', }, |
|---|
| | | { field: 'outboundTime', title: '应出库时间', type: 'string', width: 110, align: 'left', sort: true }, |
|---|
| | | { field: 'productionLine', title: '生产产线', type: 'string', width: 110, align: 'left', }, |
|---|
| | | { field: 'areaCode', title: '库区', type: 'string', width: 110, align: 'left', bind: { key: "AreaType", data: [] } }, |
|---|
| | | { field: 'remark', title: '电芯数量', type: 'string', width: 120, align: 'left', }, |
|---|
| | |
|---|
| | | } |
|---|
| | | return sortDic; |
|---|
| | | } |
|---|
| | | else if (propertyInfo.Any(x => x.Name == pageData.Sort)) |
|---|
| | | else if (propertyInfo.Any(x => x.Name.ToUpper() == pageData.Sort.ToUpper())) |
|---|
| | | { |
|---|
| | | return new Dictionary<string, OrderByType> { |
|---|
| | | { |
|---|
| | | pageData.Sort,pageData.Order?.ToLower() == OrderByType.Asc.ToString() ? OrderByType.Asc : OrderByType.Desc |
|---|
| | | pageData.Sort,pageData.Order?.ToLower() == OrderByType.Asc.ToString().ToLower()? OrderByType.Asc : OrderByType.Desc |
|---|
| | | } }; |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | { |
|---|
| | | SlotNo = x.OrderNo.ToInt32(), |
|---|
| | | SerialNo = x.SerialNumber, |
|---|
| | | SerialNoResult = isNG, |
|---|
| | | SerialNoResult = true, //isNG, |
|---|
| | | ParameterInfo = new List<ParameterInfoOutput> { |
|---|
| | | new ParameterInfoOutput() { |
|---|
| | | Value = outHours.ToString(), |
|---|
| | | ParameterCode =parameterInfo.ParameterCode, |
|---|
| | | ParameterDesc = parameterInfo.Description, |
|---|
| | | ParameterResult = isNG.ToString(), |
|---|
| | | ParameterResult = "OK", //isNG.ToString(), |
|---|
| | | TargetValue = parameterInfo.TargetValue, |
|---|
| | | LowerLomit = parameterInfo.LowerSpecificationsLimit, |
|---|
| | | UpperLimit = parameterInfo.UpperSpecificationsLimit, |
|---|
| | |
|---|
| | | if (result.SerialNos.Count <= 0) |
|---|
| | | { |
|---|
| | | // 空托盘入库逻辑 |
|---|
| | | return await RequestTrayInTaskAsync(input); |
|---|
| | | var staion = _stationManagerRepository.QueryFirst(x => x.stationChildCode == input.Position && x.stationType == 1 && x.remark == "IN"); |
|---|
| | | if (staion != null) |
|---|
| | | { |
|---|
| | | return await HandleErrorCells(input, area); |
|---|
| | | } |
|---|
| | | else |
|---|
| | | { |
|---|
| | | return await RequestTrayInTaskAsync(input); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | else |
|---|
| | | return content.Error(result.MOMMessage); |
|---|
| | |
|---|
| | | return content.Error(ex.Message); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | #endregion |
|---|
| | | |
|---|
| | | #region 异常口任务检测 |
|---|
| | | public async Task<Dt_Task> CheckAbnormalTaskAsync(RequestTaskDto input, Dt_StationManager stationManager) |
|---|
| | |
|---|
| | | return content.Error($"失败：{ex.Message}"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | /// <summary> |
|---|
| | | /// 电芯NG送至NG口 |
|---|
| | | /// </summary> |
|---|
| | | private async Task<WebResponseContent> HandleErrorCells(RequestTaskDto input, Dt_AreaInfo area, List<SerialNoDto> serialNosError) |
|---|
| | | private async Task<WebResponseContent> HandleErrorCells(RequestTaskDto input, Dt_AreaInfo area, List<SerialNoDto> serialNosError = null) |
|---|
| | | { |
|---|
| | | WebResponseContent content = new WebResponseContent(); |
|---|
| | | // TODO 创建任务送至NG排出口 |
|---|
| | |
|---|
| | | { |
|---|
| | | throw new Exception("未找到NG入库站台配置"); |
|---|
| | | } |
|---|
| | | List<string> NGStation = stationManagers.Roadway.Split(',').ToList(); |
|---|
| | | if (NGStation.Count <= 0) |
|---|
| | | { |
|---|
| | | NGStation = stationManagers.stationNGChildCode.Split(',').ToList(); |
|---|
| | | } |
|---|
| | | //List<string> NGStation = stationManagers.Roadway.Split(',').ToList(); |
|---|
| | | //if (NGStation.Count <= 0) |
|---|
| | | //{ |
|---|
| | | // NGStation = stationManagers.stationNGChildCode.Split(',').ToList(); |
|---|
| | | //} |
|---|
| | | List<string> NGStation = stationManagers.stationNGChildCode.Split(',').ToList(); |
|---|
| | | content = await CreateNewTask(input, NGStation, 2); |
|---|
| | | return content.Error("存在异常电芯"); |
|---|
| | | } |
|---|
