using System.Data;
|
using System.Dynamic;
|
using PadApplication.DB;
|
using PadApplication.Entites.DbModels;
|
using PadApplication.Entites.Dto;
|
using SqlSugar;
|
using DbType = System.Data.DbType;
|
|
namespace PadApplication.Services;
|
|
/// <summary>
|
/// 物料条码管理服务类
|
/// 负责处理生产过程中的物料条码生成、更新、删除等操作
|
/// 主要功能包括：
|
/// 1. 生成物料条码并关联到工单
|
/// 2. 更新条码数量信息
|
/// 3. 删除条码记录
|
/// 4. 验证工单状态和数量限制
|
/// </summary>
|
public class MesInvItemBarcodesManager : Repository<MesInvItemBarcodes>
|
{
|
//当前类已经继承了 Repository 增、删、查、改的方法
|
private readonly WomdaaManager _womdaaManager = new();
|
|
// 物料分类数组，用于判断物料类型
|
private readonly string[] ItemSort = ["A1", "B1", "C1", "D1", "E1", "F2"];
|
private readonly MesQaItemsDetect02Manager qaItemsDetect02Manager = new();
|
|
// 工单状态数组
|
private readonly string[] statusArray = ["开工", "暂停", "完工"];
|
|
/// <summary>
|
/// 添加物料条码
|
/// </summary>
|
/// <param name="query">工单机器信息DTO，包含工单号、打印数量等信息</param>
|
/// <returns>打印DTO列表，包含条码打印所需的所有信息</returns>
|
/// <exception cref="Exception">当打印数量超过限制、工单不存在、工单未开工等情况下抛出异常</exception>
|
public List<PrintDto> AddItemToBarcodes(OrderMachineDto query)
|
{
|
// 验证打印数量和总数是否有效
|
if (query.PrintQty is null or <= 0) return null;
|
if (query.Count is null or <= 0) return null;
|
|
// 幂等性检查 - 防重复提交
|
if (!string.IsNullOrWhiteSpace(query.RequestId))
|
{
|
// 检查是否已处理过此请求
|
var existsCount = Db.Queryable<MesInvItemBarcodes>()
|
.Where(x => x.RequestId == query.RequestId)
|
.Count();
|
|
if (existsCount > 0)
|
{
|
throw new Exception("条码已生成，请勿重复提交");
|
}
|
}
|
|
// 执行工单验证
|
Execute(query);
|
|
// 获取工单打印信息
|
var query1 = new OrderMachineDto();
|
query1.OrderId = query.OrderId;
|
var womdaaPrintById = _womdaaManager.GetWomdaaPrintById(query1);
|
|
// 验证打印总数是否超过可打印总数
|
if (query.Count * query.PrintQty > womdaaPrintById.Bqty)
|
throw new Exception("打印总数超过可打印总数");
|
|
// 获取工单信息
|
var womdaa = Db.Queryable<Womdaa>()
|
.Where(s => s.Daa001 == query.orderNo)
|
.First();
|
|
if (womdaa == null) throw new Exception("工单单号不存在");
|
|
// 验证工单状态是否允许打印
|
if (Array.IndexOf(statusArray, womdaa.Daa018) == -1)
|
throw new Exception("工单未开工，不能打印条码，请先开工！！！");
|
|
// 获取标准包装数
|
var mesItemsPackageQty = Db.Queryable<MesItemsPackageQty>()
|
.Where(a => a.ItemCode == womdaa.Daa002).First();
|
|
if (mesItemsPackageQty == null) throw new Exception("请维护标准包装数！");
|
|
// 检查工单状态
|
womdaa.State ??= "F";
|
if ("C".Equals(womdaa.State)) throw new Exception("工单已结案！");
|
|
// 获取首检信息
|
var findSjByOrderNo = qaItemsDetect02Manager.FindSJByOrderNo(query);
|
if (findSjByOrderNo == null) throw new Exception("没有查询到首检单");
|
//if (!"合格".Equals(findSjByOrderNo.FcheckResu) || !"特采使用".Equals(findSjByOrderNo.FcheckResu))
|
if ("不合格".Equals(findSjByOrderNo.FcheckResu))
|
throw new Exception("首检不合格，不允许报工");
|
|
// 计算已打印总数
|
var sum = Db.Queryable<MesInvItemBarcodes>()
|
.Where(s => s.PbillNo == womdaa.Daa001)
|
.Sum(s => s.Quantity);
|
|
// 验证打印数量是否超出工单数量
|
var aa = query.Count * query.PrintQty;
|
if (aa + sum > womdaa.Daa008) throw new Exception("打印数量超出工单数量！");
|
|
// 初始化返回列表
|
var list = new List<PrintDto>();
|
var barcodes = new List<MesInvItemBarcodes>();
|
|
// 循环生成条码
|
for (var i = 0; i < query.Count; i++)
|
{
|
// 获取物料信息
|
var mesItems2 = Db.Queryable<MesItems2>()
|
.Where(b => b.ItemNo == womdaa.Daa002 && b.AddressCode == "ALL")
|
.First();
|
|
if (mesItems2 == null) throw new Exception("物料信息不存在该物料编码，请维护！");
|
|
// 获取工序信息
|
var womcaa = Db.Queryable<Womcaa>()
|
.Where(c => c.Caa001 == womdaa.Daa029).First();
|
|
womcaa.IsGy ??= 0;
|
|
// 验证是否是最后一道工序
|
if (womcaa.IsGy == 1)
|
{
|
var maxProc = Db.Queryable<Womdaa>()
|
.Where(a => a.Daa029 == womdaa.Daa029)
|
.Select(a =>
|
SqlFunc.AggregateMax(SqlFunc.ToDecimal(a.ProcNum)))
|
.Single();
|
|
if (Convert.ToDecimal(womdaa.ProcNum) != maxProc)
|
throw new Exception("工序工单只有最后一道可以打印条码！");
|
}
|
|
// 设置批次号
|
var lotNo = "";
|
if (Array.IndexOf(ItemSort, mesItems2) > -1) lotNo = womdaa.LotNo;
|
|
// 设置条码类型
|
var typeCode = 25;
|
if (womdaa.Daa001.StartsWith("HSA") ||
|
womdaa.Daa001.StartsWith("HSB"))
|
typeCode = 16;
|
|
// 获取条码类型信息
|
var mesBarcodeType = Db.Queryable<MesBarcodeType>()
|
.Where(d =>
|
d.TypeCode == typeCode && d.Factory == "10000" &&
|
d.Company == "1000").First();
|
|
// 获取当前日期
|
var cIndate = DateTime.Now.ToString("yyyyMMdd");
|
|
// 获取部门信息
|
var sysDepartment = Db.Queryable<SysDepartment>()
|
.Where(e => e.Departmentcode == womdaa.DepartmentNo).First();
|
|
var Departmentname = womdaa.DepartmentNo;
|
if (sysDepartment != null)
|
Departmentname = sysDepartment.Departmentname;
|
|
var now = DateTime.Now.ToString("yyyy-MM-dd");
|
var print = query.PrintQty;
|
|
// 调用存储过程获取条码
|
var barcodeResult = SpGetBarcode2("1000", "1000", mesBarcodeType.Id,
|
womdaa.Daa002 + cIndate, womdaa.Daa002 + cIndate, 0);
|
string serial = barcodeResult.Value;
|
string poBarcodeComand = barcodeResult.Msg;
|
|
if (!string.IsNullOrEmpty(poBarcodeComand)) return null;
|
|
// 生成物料条码
|
var itemBarCode = womdaa.Daa002 + "-B" + cIndate + serial;
|
|
// 构建打印DTO
|
var printDto = new PrintDto
|
{
|
Out1 = Departmentname, //生产部门
|
Out2 = womdaa.Daa002, //物料编码
|
Out3 = womdaa.Daa003, //物料名称
|
Out4 = query.user, //报工人
|
Out5 = womdaa.Daa001.Substring(0, 3) == "XSG"
|
? womdaa.Daa029
|
: womdaa.LotNo, //批次号
|
Out6 = mesItems2.ItemName, //产品型号
|
Out7 = print + " " + womdaa.Daa005, //条码数量
|
Out8 = now, //日期
|
Out9 = "颜色:" + mesItems2.ColorName + ", 图号:" +
|
mesItems2.EngineeringNo
|
+ ", 材质:" + mesItems2.Material, //规格型号
|
Out10 = womcaa.Caa015, //销售单号
|
Out11 = womdaa.Daa001, //工单号
|
Out12 = itemBarCode //条码
|
};
|
|
// 验证条码是否已存在
|
var count = Db.Queryable<MesInvItemBarcodes>()
|
.Where(f => f.ItemBarcode == itemBarCode).Count();
|
|
if (count != 0) return null;
|
|
// 分割用户信息
|
var strings = query.user.Split(':');
|
|
// 创建条码实体
|
var entity = new MesInvItemBarcodes
|
{
|
ItemBarcode = itemBarCode,
|
BillNo = womdaa.Daa001,
|
ItemNo = womdaa.Daa002,
|
Quantity = print,
|
EpFlag = 1,
|
TaskNo = womdaa.Daa021,
|
CreateBy = strings[0],
|
CreateDate = DateTime.Now,
|
LastupdateBy = strings[0],
|
LastupdateDate = DateTime.Now,
|
Mblnr = "",
|
Barcodestatus = 0,
|
Oldqty = print,
|
Unit = womdaa.Daa005,
|
LotDate = now,
|
Memo = "成品入库",
|
SuppNo = "",
|
ItemSname = womdaa.Daa003,
|
Factory = "1000",
|
Company = "1000",
|
TrLotno = cIndate,
|
UrgentFlag = 0,
|
WorkFlg = 1,
|
WorkLine = 1,
|
WorkNo = womdaa.Daa029,
|
ComeFlg = 1,
|
Hbdy = 0,
|
AddressCode = womdaa.AddressCode,
|
PbillNo = womdaa.Daa001,
|
LineNo = 1,
|
RequestId = query.RequestId // 保存请求唯一标识符，用于防重复提交
|
};
|
|
// 创建报工记录
|
var mesReporting = new MesReporting
|
{
|
CheckType = 0,
|
ItemNoCade = itemBarCode,
|
CreateBy = strings[0],
|
BgDate = DateTime.Now,
|
BgPerson = strings[0],
|
AddressCode = womdaa.AddressCode,
|
MachineNo = womdaa.MachineNo,
|
// BfQty = query.bf,
|
OkQty = print,
|
ItemNo = womdaa.Daa002,
|
BillNo = womdaa.Daa001
|
};
|
|
// 插入报工记录和条码记录
|
if (Db.Insertable(mesReporting)
|
.IgnoreColumns(true).ExecuteCommand() > 0)
|
{
|
Db.Insertable(entity).IgnoreColumns(true).ExecuteCommand();
|
UpdateAmount(mesReporting, query1);
|
}
|
|
list.Add(printDto);
|
barcodes.Add(entity);
|
}
|
|
// 更新条码数量
|
UpdateBarcodeAmount(barcodes);
|
return list;
|
}
|
|
/// <summary>
|
/// 更新报工数量信息
|
/// </summary>
|
/// <param name="mesReporting">报工记录</param>
|
/// <param name="query">工单机器信息</param>
|
public bool AddBFToBarcodes(OrderMachineDto query)
|
{
|
var womdaa = Db.Queryable<Womdaa>()
|
.Where(s => s.Daa001 == query.orderNo)
|
.First();
|
|
if (womdaa == null) throw new Exception("工单单号不存在");
|
|
// 创建报工记录
|
var mesReporting = new MesReporting
|
{
|
CheckType = 1,
|
// ItemNoCade = itemBarCode,
|
// CreateBy = strings[0],
|
BgDate = DateTime.Now,
|
// BgPerson = strings[0],
|
AddressCode = womdaa.AddressCode,
|
MachineNo = womdaa.MachineNo,
|
BfQty = query.bf,//不良数量
|
OkQty = query.currentCjNum - query.initCjNum - query.bf,//良品数量
|
CsQty = query.initCjNum,//初始采集数
|
CjQty = query.currentCjNum,//报工时采集数
|
ItemNo = womdaa.Daa002,
|
BillNo = womdaa.Daa001,
|
BgPerson = query.staffNo // 新增：报工人编号
|
};
|
|
// 插入报工记录和条码记录
|
return Db.Insertable(mesReporting)
|
.IgnoreColumns(true).ExecuteCommand() > 0;
|
}
|
|
/// <summary>
|
/// 更新报工数量信息
|
/// </summary>
|
/// <param name="mesReporting">报工记录</param>
|
/// <param name="query">工单机器信息</param>
|
private void UpdateAmount(MesReporting mesReporting, OrderMachineDto query)
|
{
|
// 获取已打印数据
|
var DyQty = Db.Queryable<VPrint>()
|
.Where(s => s.Id == query.OrderId).Select(s => s.SQuantity).First();
|
|
var s1 = DateTime.Now.ToString("yyyy-MM-dd");
|
|
// 获取数采数据
|
var CjQty = Db.Queryable<MesNumericalBycl>()
|
.Where(s =>
|
s.MachineNo == mesReporting.MachineNo && s.EditDate == s1)
|
.OrderByDescending(s => s.CjTiem)
|
.Select(s => s.CjNum).First();
|
|
// 获取锚点数据
|
var anchors = Db.Queryable<MesAnchors>()
|
.Where(a => a.OrderId == query.OrderId)
|
// && a.EditDate == s1
|
.OrderByDescending(a => a.EditDate)
|
.First() ?? new MesAnchors
|
{
|
InitialValue = 0,
|
Qty = 0
|
};
|
|
// 计算各种数量
|
var jt = CjQty;
|
var ljcj = CjQty - anchors.InitialValue;
|
var anchorsQty = anchors.Qty ?? 0;
|
var BlQty = (ljcj + anchorsQty) - DyQty;
|
var bfQty = BlQty;
|
|
// 获取上一次报工记录
|
var reporting = Db.Queryable<MesReporting>()
|
.Where(a => a.BillNo == mesReporting.BillNo
|
&& a.ItemNoCade != mesReporting.ItemNoCade)
|
.OrderByDescending(a => a.Id)
|
.First();
|
|
if (reporting != null)
|
bfQty = BlQty - Convert.ToDecimal(reporting.BlQty);
|
|
// 更新报工记录
|
Db.Updateable<MesReporting>()
|
.SetColumns(a => a.BlQty == BlQty)
|
.SetColumns(a => a.CsQty == (anchors.InitialValue ?? 0))
|
.SetColumns(a => a.JtQty == jt)
|
// .SetColumns(a => a.BfQty == bfQty)
|
.SetColumns(a => a.CjQty == ljcj)
|
.SetColumns(a => a.DyQty == DyQty)
|
.Where(a => a.ItemNoCade == mesReporting.ItemNoCade)
|
.ExecuteCommand();
|
}
|
|
/// <summary>
|
/// 更新条码数量
|
/// </summary>
|
/// <param name="barcodesList">条码列表</param>
|
/// <returns>更新是否成功</returns>
|
private bool UpdateBarcodeAmount(List<MesInvItemBarcodes> barcodesList)
|
{
|
// 验证条码列表是否有效
|
if (barcodesList == null || !barcodesList.Any()) return true;
|
|
// 获取条码列表
|
var list = barcodesList.Select(s => s.ItemBarcode).ToList();
|
|
// 查询条码记录
|
var mesInvItemBarcodesList = Db.Queryable<MesInvItemBarcodes>()
|
.Where(a => list.Contains(a.ItemBarcode)).ToList();
|
|
if (mesInvItemBarcodesList == null || mesInvItemBarcodesList.Count == 0)
|
return true;
|
|
// 使用事务更新数据
|
UseTransaction(db =>
|
{
|
var billNos = mesInvItemBarcodesList.Select(p => p.PbillNo)
|
.Distinct().ToList();
|
var executeCommand = 0;
|
|
// 更新每个工单的数量
|
foreach (var billNo in billNos)
|
{
|
var sum = db.Queryable<MesInvItemBarcodes>()
|
.Where(s => s.PbillNo == billNo)
|
.Sum(s => s.Oldqty);
|
|
executeCommand += db.Updateable<Womdaa>()
|
.SetColumns(x => x.Daa011 == sum)
|
.Where(x => x.Daa001 == billNo)
|
.ExecuteCommand();
|
}
|
|
if (executeCommand < 1) throw new Exception("更新条码失败");
|
|
return executeCommand;
|
});
|
|
return true;
|
}
|
|
/// <summary>
|
/// 执行工单验证
|
/// 验证工单的发料情况、数量限制等
|
/// </summary>
|
/// <param name="query">工单机器信息</param>
|
/// <exception cref="Exception">当工单发料未齐套、报工数量超过限制等情况下抛出异常</exception>
|
private void Execute(OrderMachineDto query)
|
{
|
// 查询工单发料比例
|
var sql = string.Format(
|
"SELECT nvl(B3.LLQT, 0) FROM WOMDAA A LEFT JOIN (SELECT round(min(case when nvl(B2.DAB022, 0) = 0 then 0 WHEN NVL(B2.DAB007, 0) / B2.DAB022 * NVL(B2.DAB023, 0) > A2.DAA008 then A2.daa008 when b2.DAB020 = 4 then A2.Daa008 ELSE NVL(B2.DAB007, 0) / B2.DAB022 * NVL(B2.DAB023, 0) end), 2) LLQT, B2.DAB001, B2.PID FROM WOMDAB B2 left join WOMDAA A2 on A2.id = B2.pid where nvl(B2.Dab006, 0) <> 0 GROUP BY B2.DAB001, B2.PID) B3 on B3.PID = A.ID WHERE A.DAA001 = '{0}'",
|
query.orderNo);
|
|
var sqlQuerySingle = Db.Ado.SqlQuerySingle<int?>(sql);
|
|
// 验证工单发料是否齐套
|
if (sqlQuerySingle is null or 0) throw new Exception("工单发料未齐套！");
|
|
// 计算打印数量
|
var c_quantity = query.Count * query.PrintQty;
|
|
// 获取工单信息
|
var womdaa = Db.Queryable<Womdaa>()
|
.Where(s => s.Daa001 == query.orderNo).First();
|
|
// 验证报工数量是否超过发料比例
|
if (c_quantity + womdaa.Daa011 > sqlQuerySingle)
|
throw new Exception("报工数量超过工单发料比例,请联系领导或班长通知发料!");
|
|
// 验证首检
|
if (womdaa.FType == 0 &&
|
!new[] { "23", "24", "25", "26", "27", "28" }.Contains(
|
womdaa.MachineNo))
|
{
|
var cNum = Db.Queryable<MesQaItemsDetect02>()
|
.Where(a =>
|
a.Ftype == "首检" && a.Ismodify1 == 1 &&
|
a.Aufnr == query.orderNo)
|
.Count();
|
if (cNum == 0) throw new Exception("工单未首检,报工失败,请联系品质检验!");
|
}
|
}
|
|
/// <summary>
|
/// 更新条码数量
|
/// </summary>
|
/// <param name="query">工单机器信息</param>
|
/// <returns>更新是否成功</returns>
|
public bool UpdateBarcodeAmount(OrderMachineDto query)
|
{
|
// 验证条码数组是否有效
|
if (query.barcodes == null || query.barcodes.Length == 0) return true;
|
|
// 查询条码记录
|
var mesInvItemBarcodesList = Db.Queryable<MesInvItemBarcodes>()
|
.Where(a => query.barcodes.Contains(a.ItemBarcode)).ToList();
|
|
if (mesInvItemBarcodesList == null || mesInvItemBarcodesList.Count == 0)
|
return true;
|
|
// 分割用户信息
|
var strings = query.user.Split(':');
|
|
// 使用事务更新数据
|
UseTransaction(db =>
|
{
|
// 更新条码记录
|
var executeCommand = db.Updateable<MesInvItemBarcodes>()
|
.SetColumns(s => s.CreateBy == strings[0])
|
.Where(s => query.barcodes.Contains(s.ItemBarcode))
|
.ExecuteCommand();
|
|
if (executeCommand <= 0) return 0;
|
|
// 获取地址代码和工单号
|
var addressCodes = mesInvItemBarcodesList.Select(p => p.AddressCode)
|
.Distinct().ToList();
|
|
var billNos = mesInvItemBarcodesList.Select(p => p.PbillNo)
|
.Distinct().ToList();
|
|
// 更新报工记录
|
executeCommand += db.Updateable<MesReporting>()
|
.SetColumns(s => s.CreateBy == strings[0])
|
.SetColumns(s => s.BgPerson == strings[0])
|
.Where(s =>
|
addressCodes.Contains(s.AddressCode) &&
|
billNos.Contains(s.BillNo) &&
|
query.barcodes.Contains(s.ItemNoCade))
|
.ExecuteCommand();
|
|
// 更新工单数量
|
foreach (var billNo in billNos)
|
{
|
var sum = db.Queryable<MesInvItemBarcodes>()
|
.Where(s => s.PbillNo == billNo)
|
.Sum(s => s.Oldqty);
|
|
executeCommand += db.Updateable<Womdaa>()
|
.SetColumns(x => x.Daa011 == sum)
|
.Where(x => x.Daa001 == billNo)
|
.ExecuteCommand();
|
}
|
|
if (executeCommand <= 2) throw new Exception("更新条码失败");
|
|
return executeCommand;
|
});
|
|
return true;
|
}
|
|
/// <summary>
|
/// 删除条码记录
|
/// </summary>
|
/// <param name="query">工单机器信息</param>
|
/// <returns>删除是否成功</returns>
|
public bool DeleteBarcode(OrderMachineDto query)
|
{
|
// 验证条码数组是否有效
|
if (query.barcodes == null || query.barcodes.Length == 0) return true;
|
|
// 查询条码记录
|
var mesInvItemBarcodesList = Db.Queryable<MesInvItemBarcodes>()
|
.Where(a => query.barcodes.Contains(a.ItemBarcode)).ToList();
|
|
if (mesInvItemBarcodesList == null || mesInvItemBarcodesList.Count == 0)
|
return true;
|
|
// 获取地址代码和工单号
|
var addressCodes = mesInvItemBarcodesList.Select(p => p.AddressCode)
|
.Distinct().ToList();
|
|
var billNos = mesInvItemBarcodesList.Select(p => p.PbillNo)
|
.Distinct().ToList();
|
|
var itemNos = mesInvItemBarcodesList.Select(p => p.ItemNo)
|
.Distinct().ToList();
|
|
// 查询报工记录
|
var mesReportings = Db.Queryable<MesReporting>()
|
.Where(s =>
|
addressCodes.Contains(s.AddressCode) &&
|
billNos.Contains(s.BillNo) &&
|
itemNos.Contains(s.ItemNo)
|
&& query.barcodes.Contains(s.ItemNoCade)).ToList();
|
|
if (mesReportings == null || mesReportings.Count == 0)
|
return true;
|
|
// 使用事务删除数据
|
UseTransaction(db =>
|
{
|
var decimals = mesInvItemBarcodesList.Select(s => s.Id).ToArray();
|
var executeCommand = db.Deleteable<MesInvItemBarcodes>()
|
.In(decimals).ExecuteCommand();
|
|
// 删除报工记录
|
if (mesReportings.Count == query.barcodes.Length)
|
{
|
var array = mesReportings.Select(s => s.Id).ToArray();
|
executeCommand += db.Deleteable<MesReporting>()
|
.In(array).ExecuteCommand();
|
}
|
else
|
{
|
var array = mesReportings.Take(query.barcodes.Length)
|
.Select(s => s.Id).ToArray();
|
executeCommand += db.Deleteable<MesReporting>()
|
.In(array).ExecuteCommand();
|
}
|
|
if (executeCommand < 1) throw new Exception("删除条码失败");
|
|
return executeCommand;
|
});
|
return true;
|
}
|
|
/// <summary>
|
/// 检查是否可以打印条码
|
/// </summary>
|
/// <param name="query">工单机器信息</param>
|
/// <returns>可打印的数量，-1表示不可打印</returns>
|
/// <exception cref="Exception">当剩余打印次数为0时抛出异常</exception>
|
private int isPrint(OrderMachineDto query)
|
{
|
// 获取打印相关数据
|
var womdaaPrint = _womdaaManager.GetWomdaaPrintById(query);
|
var totalItems = womdaaPrint.Bqty; // 总数量
|
var boxSize = womdaaPrint.Qqty; // 每箱的数量
|
var remainingPrintableTimes = womdaaPrint.RmiPrQty; // 剩余可打印次数
|
var maxPrintableTimes = womdaaPrint.Icount; //总打印条码张数
|
|
// 验证数据有效性
|
if (!totalItems.HasValue || !boxSize.HasValue ||
|
!remainingPrintableTimes.HasValue ||
|
!maxPrintableTimes.HasValue) return -1;
|
|
if (maxPrintableTimes <= 0) return -1;
|
|
// 根据剩余打印次数判断
|
switch (remainingPrintableTimes)
|
{
|
case <= 0:
|
throw new Exception("剩余打印次数为 0，停止打印。");
|
// 计算下一次打印的数量
|
// 判断是否是最后一次打印
|
case 1:
|
{
|
// 如果是最后一次，使用尾数
|
var printedItems = totalItems.Value -
|
(maxPrintableTimes - 1) * boxSize.Value;
|
return (int)printedItems;
|
}
|
default:
|
return (int)boxSize;
|
}
|
}
|
|
/// <summary>
|
/// 调用存储过程获取条码
|
/// </summary>
|
/// <param name="p0">工厂代码</param>
|
/// <param name="p1">公司代码</param>
|
/// <param name="cBid">条码类型ID</param>
|
/// <param name="cItemNo">任务编号</param>
|
/// <param name="cIndate">日期</param>
|
/// <param name="p5">是否提交标志</param>
|
/// <returns>包含条码值和消息的动态对象</returns>
|
/// <exception cref="Exception">当存储过程执行失败时抛出异常</exception>
|
private dynamic SpGetBarcode2(string p0, string p1, decimal cBid,
|
string cItemNo, string cIndate, int p5)
|
{
|
try
|
{
|
// 定义输出参数
|
var outputResult = new SugarParameter("PO_VALUE", null,
|
DbType.Int32, ParameterDirection.Output,
|
4000);
|
|
var outputMessage = new SugarParameter("PO_MSG", null,
|
DbType.String,
|
ParameterDirection.Output, 4000);
|
|
// 定义输入参数
|
var parameters = new List<SugarParameter>
|
{
|
new("PI_FACTORY", p0,
|
DbType.String, ParameterDirection.Input),
|
new("PI_COMPANY", p1, DbType.String,
|
ParameterDirection.Input),
|
new("P_BARCODE_TYPE_ID", cBid, DbType.String,
|
ParameterDirection.Input),
|
new("P_TASK_NO", cItemNo, DbType.String,
|
ParameterDirection.Input),
|
new("P_TASK_ITEM", cIndate, DbType.String,
|
ParameterDirection.Input),
|
new("P_IF_COMMIT", p5, DbType.String,
|
ParameterDirection.Input),
|
outputResult,
|
outputMessage
|
};
|
|
// 执行存储过程
|
Db.Ado.ExecuteCommand(
|
"BEGIN SP_GET_BARCODE2(:PI_FACTORY, :PI_COMPANY, :P_BARCODE_TYPE_ID, :P_TASK_NO, :P_TASK_ITEM, :P_IF_COMMIT, :PO_VALUE, :PO_MSG); END;",
|
parameters.ToArray());
|
|
// 获取输出参数值
|
var resultValue = outputResult.Value?.ToString();
|
var messageValue = outputMessage.Value?.ToString();
|
|
// 返回动态对象
|
dynamic m = new ExpandoObject();
|
m.Value = resultValue;
|
m.Msg = messageValue;
|
|
return m;
|
}
|
catch (Exception ex)
|
{
|
throw new Exception(ex.Message);
|
}
|
}
|
}
|
