201 lines
9.7 KiB
C#
201 lines
9.7 KiB
C#
using Microsoft.Extensions.Logging;
|
||
using NUglify.Helpers;
|
||
using Seyounth.Auto.Hs.Runtime.Balances;
|
||
using Seyounth.Auto.Hs.Runtime.Plc;
|
||
using Seyounth.Auto.Hs.Runtime.Printer;
|
||
using Syc.Abp.Application.Contracts;
|
||
using Syc.Basic.Web.WMS.Entitys;
|
||
using Syc.Basic.Web.WMS.Service;
|
||
using Syc.Basic.Web.WMS.WebSocket;
|
||
using Syc.Core.Tools;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
using Volo.Abp.Domain.Repositories;
|
||
using Volo.Abp.Uow;
|
||
|
||
namespace Syc.Basic.Web.WMS.DeviceEventHandle
|
||
{
|
||
public class DefaultBalanceEventHandle : IBalanceEventHandle
|
||
{
|
||
private readonly IRepository<Silk> silkRepository;
|
||
private readonly IPlcService plcService;
|
||
private readonly IRepository<Produce> produceRepository;
|
||
private readonly IRepository<Box> boxRepository;
|
||
private readonly IPrinterService printerService;
|
||
private readonly IUnitOfWorkManager unitOfWork;
|
||
private readonly ILogger<DefaultBalanceEventHandle> logger;
|
||
private readonly static object _lock = new object();
|
||
public DefaultBalanceEventHandle(IRepository<Silk> silkRepository,IPlcService plcService,IRepository<Produce> produceRepository,IRepository<Box> boxRepository,IPrinterService printerService,IUnitOfWorkManager unitOfWork, ILogger<DefaultBalanceEventHandle> logger)
|
||
{
|
||
this.silkRepository = silkRepository;
|
||
this.plcService = plcService;
|
||
this.produceRepository = produceRepository;
|
||
this.boxRepository = boxRepository;
|
||
this.printerService = printerService;
|
||
this.unitOfWork = unitOfWork;
|
||
this.logger = logger;
|
||
}
|
||
|
||
public async Task ExecAsync(decimal weight, int id)
|
||
{
|
||
|
||
using (var uow = unitOfWork.Reserve(UnitOfWork.UnitOfWorkReservationName))
|
||
{
|
||
try
|
||
{
|
||
|
||
if (weight <= 0)
|
||
return;
|
||
|
||
//logger.LogInformation($"重量稳定:{weight}");
|
||
|
||
if (id == 1)
|
||
await Yanr(weight);
|
||
else
|
||
await Box(weight);
|
||
await uow.CompleteAsync();
|
||
}
|
||
catch (Exception ex) when (ex is FriendlyException friendlyException)
|
||
{
|
||
logger.LogError(ex.GetBaseException(), "称重报错");
|
||
await WebSocketManager.SocketManager.BroadcastAsync(friendlyException.Message);
|
||
await uow.RollbackAsync();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
logger.LogError(ex.GetBaseException(), "称重报错");
|
||
await uow.RollbackAsync();
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 丝锭称重
|
||
/// </summary>
|
||
/// <param name="weight"></param>
|
||
/// <returns></returns>
|
||
public async Task Yanr(decimal weight)
|
||
{
|
||
if (await silkRepository.AnyAsync(e => e.Status == 0 && e.IsDelete == 0))
|
||
{
|
||
var silk = await silkRepository.FirstOrDefaultAsync(e => e.Status == 0 && e.IsDelete == 0);//QueueManage.YarnBalanceQueue.Dequeue();
|
||
silk.Status = 1;
|
||
silk.Status_Details = "已称重待装箱";
|
||
silk.Net_Weight = (double)weight;
|
||
await silkRepository.UpdateAsync(silk);
|
||
string content = "#!A1" +
|
||
"\r\n#N13" +
|
||
"\r\n#PC1017/0" +
|
||
"\r\n#IMR44/46" +
|
||
//"\r\n#HV50" +
|
||
"\r\n#PR6//" +
|
||
"\r\n#PO0" +
|
||
"\r\n#ERNC/1//0.00" +
|
||
"\r\n#R0/0" +
|
||
"\r\n#T3.64 #J43.18 #FD/0/L #SS100/BVUN/21X21/0 #VW/L/\"YuLinHengShenXinCaiLiaoYouXianGongSi\"#G" +
|
||
"\r\n#T11.85 #J40.47 #FD/0/L #SS100/BVUN/19X19/0 #VW/L/\"Yulin Hengshen COLtd\"#G" +
|
||
"\r\n#T2.28 #J25.31 #FD/0/L #SS100/BVUN/20X20/0 #VW/L/\"Name " + silk.Name +"\"#G" +
|
||
"\r\n#T2.28 #J20.91 #FD/0/L #SS100/BVUN/20X20/0 #VW/L/\"Type " +silk.Type+ "\"#G" +
|
||
"\r\n#T2.28 #J16.51 #FD/0/L #SS100/BVUN/20X20/0 #VW/L/\"Net Weight "+silk.Net_Weight+ "\"#G" +
|
||
"\r\n#T2.28 #J12.61 #FD/0/L #SS100/BVUN/20X20/0 #VW/L/\"Length "+silk.Length+ "\"#G" +
|
||
"\r\n#T2.28 #J7.95 #FD/0/L #SS100/BVUN/20X20/0 #VW/L/\"Date "+silk.Date.ToString()+ "\"#G" +
|
||
"\r\n#T2.28 #J3.89 #FD/0/L #SS100/BVUN/20X20/0 #VW/L/\"Lot No "+silk.Lot_No+ "\"#G" +
|
||
"\r\n#T11.51 #J29.54 #FD/0/L #SB13/ONKP2.0/8.80/2 #VW/L/\"" + silk.Code+"\"#G" +
|
||
"\r\n#Q1#G" +
|
||
"\r\n#!P1" +
|
||
"\r\n";
|
||
await printerService.PrintAsync(1, content);
|
||
|
||
logger.LogInformation($"Silk({silk.Id}|{silk.Code})状态更改为【已称重待装箱】，同时向打印机发送打印标签指令");
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 整箱称重
|
||
/// </summary>
|
||
/// <param name="weight"></param>
|
||
public async Task Box(decimal weight)
|
||
{
|
||
/* PLC未给顶升到位信号则忽略此次事件处理 */
|
||
if (!await plcService.IsTop()) return;
|
||
|
||
|
||
if (await silkRepository.AnyAsync(e => e.Status == 1 && e.IsDelete == 0))
|
||
{
|
||
var query = await silkRepository.GetQueryableAsync();
|
||
query =query.Where(x => x.Status == 1 && x.IsDelete == 0);
|
||
var count = query.Count();
|
||
var produce = await produceRepository.FirstOrDefaultAsync(e => e.IfUse == 1);
|
||
if (produce is null)
|
||
throw Oops.Oh("无生产信息，请先设置生产信息再扫码");
|
||
if (produce.Qty.Value > count)
|
||
{
|
||
throw Oops.Oh("数量未满箱，无法打印标签");
|
||
}
|
||
logger.LogInformation($"当前生产信息：{produce.Name}|{produce.Spec}|{produce.Lot_No}|{produce.BoxSpec}|{produce.Qty}");
|
||
//var netWeight = query.FirstOrDefault(e => e.Code == QueueManage.BoxQueue.FirstOrDefault()).Net_Weight * produce.Qty.Value;
|
||
var takeQuery = query.Take(produce.Qty.Value);
|
||
var netWeight = takeQuery.Sum(e => e.Net_Weight);
|
||
var box = new Box()
|
||
{
|
||
Dom_Time = DateTime.Now,
|
||
Type = produce.Type,
|
||
Exp_Time = produce.Exp_Time,
|
||
Qty = produce.Qty,
|
||
Length = produce.Length,
|
||
Lot_No = produce.Lot_No,
|
||
Code = Guid.NewGuid().ToString().Substring(9, 18),
|
||
Net_Weight = netWeight,
|
||
Spec = produce.BoxSpec,
|
||
Gross_Weight = (double)weight,
|
||
IsUse = true,
|
||
IsDelete = 0
|
||
};
|
||
string content = "#!A1" +
|
||
"\r\n#N13" +
|
||
"\r\n#PC1017/0" +
|
||
"\r\n#IMR104/130" +
|
||
//"\r\n#HV50" +
|
||
"\r\n#PR6//" +
|
||
"\r\n#PO0" +
|
||
"\r\n#ERNC/1//0.00" +
|
||
"\r\n#R0/0" +
|
||
"\r\n#T7.28 #J11.17 #FD/1/L #SS100/BVUN/51X68/0 #VW/L/\"YuLinHengShenXinCaiLiaoYouXianGongSi\"#G" +
|
||
"\r\n#T13.37 #J40.30 #FD/1/L #SS100/BVUN/46X62/0 #VW/L/\"Yulin Hengshen COLtd\"#G" +
|
||
"\r\n#T52.15 #J9.14 #FD/1/L #SS100/BVUN/47X63/0 #VW/L/\"TYPE " + box.Type + "\"#G" +
|
||
"\r\n#T67.39 #J9.14 #FD/1/L #SS100/BVUN/47X63/0 #VW/L/\"QTY/PCS " + box.Qty + "\"#G" +
|
||
"\r\n#T82.63 #J9.14 #FD/1/L #SS100/BVUN/47X63/0 #VW/L/\"LOT NO. " + box.Lot_No + "\"#G" +
|
||
"\r\n#T98.97 #J9.14 #FD/1/L #SS100/BVUN/47X63/0 #VW/L/\"DOM. " + box.Dom_Time.ToString() + "\"#G" +
|
||
"\r\n#T52.15 #J69.25 #FD/1/L #SS100/BVUN/47X63/0 #VW/L/\"SPEC " + box.Spec + "\"#G" +
|
||
"\r\n#T67.39 #J69.25 #FD/1/L #SS100/BVUN/47X63/0 #VW/L/\"CTY./NO. " + box.Net_Weight + "\"#G" +
|
||
"\r\n#T81.19 #J69.25 #FD/1/L #SS100/BVUN/47X63/0 #VW/L/\"LENGTH " + box.Length + "\"#G" +
|
||
"\r\n#T98.21 #J69.25 #FD/1/L #SS100/BVUN/47X63/0 #VW/L/\"EXP. " + box.Exp_Time.ToString() + "\"#G" +
|
||
"\r\n#T41.06 #J6.68 #FD/1/L #SB13/ONKP2.0/20.82/5 #VW/L/\"" + box.Code + "\"#G" +
|
||
"\r\n#Q1#G\r\n#!P1\r\n";
|
||
|
||
var entity = await boxRepository.InsertAsync(box, true);
|
||
var silks = takeQuery.ToList();
|
||
var codes = silks.Select(e => e.Code);
|
||
logger.LogInformation($"从数据库中待装箱编号：{string.Join(";", codes)}");
|
||
|
||
silks.ForEach(e =>
|
||
{
|
||
logger.LogInformation($"{e.Code}已装箱");
|
||
e.BoxId = entity.Id;
|
||
e.Status = 2;
|
||
e.Status_Details = "已装箱";
|
||
});
|
||
await silkRepository.UpdateManyAsync(silks);
|
||
await printerService.PrintAsync(2, content);
|
||
await plcService.ClearTop();
|
||
await plcService.BoxTagPrintDoneAsync((short)1);
|
||
logger.LogInformation($"称重完成，已将数据({box.Id}|{box.Code})插入到box表，同时向打印机发送出标指令");
|
||
}
|
||
}
|
||
}
|
||
}
|