清点增加分页

Rodney Chen

2025-03-18 406ac5eb58f06bde155443a34c76fbf187759808

 Tiger.Business.WMS/Transaction/Yada/Count_BIZ_U9_ASN.cs

@@ -11,6 +11,8 @@
using Tiger.IBusiness;
using Tiger.Model.MES.Yada;
using Tiger.Model.Entitys.MES.U9C;
using System.Security.Policy;
using Tiger.Model.Entitys.MES.Position;

namespace Tiger.Business.WMS.Transaction
{
@@ -258,7 +260,9 @@
                //执行清点数据处理
                CurSn.STATUS = WMS_ITEM.STATUSs.Counted.GetValue();
                CurSn.QTY = CurInvItem.Items.Sum(q => q.QTY);
            foreach (var item in CurInvItem.Items)
                CurSn.RECEIVER = UserCode;
                CurSn.RECEIVE_DATE = DateTime.Now;
                foreach (var item in CurInvItem.Items)
            {
               item.AUTH_ORG = CurSn.AUTH_ORG;
               item.STATUS = WMS_ITEM.STATUSs.Counted.GetValue();
@@ -347,6 +351,8 @@
            foreach (var sn in ScanList)
            {
               sn.STATUS = WMS_ITEM.STATUSs.Incoming.GetValue();
                    sn.RECEIVER = null;
                    sn.RECEIVE_DATE = DateTime.MinValue;
            }

            var historys = new List<WMS_ITEM_HIS>();
@@ -415,7 +421,9 @@
            var dbTran = db.UseTran(() =>
            {
               db.Updateable<BIZ_U9_ASN_SN>(UserCode).SetColumns(q => q.STATUS == WMS_ITEM.STATUSs.Incoming.GetValue())
                     .Where(q => q.SN == input.SN).ExecuteCommand();
                        .SetColumns(q => q.RECEIVER == null)
                        .SetColumns(q => q.RECEIVE_DATE == DateTime.MinValue)
                        .Where(q => q.SN == input.SN).ExecuteCommand();
               db.Updateable(item, UserCode).ExecuteCommand();
               db.Insertable(new WMS_ITEM_HIS(item, $"条码[{item.SN}]取消清点，操作单据[{order}]"), UserCode).ExecuteCommand();
            });
@@ -442,25 +450,29 @@
      ///  获取本次已清点的物料列表（带分页）
      /// </summary>
      /// <returns></returns>
      public async Task<PageAble<BIZ_U9_ASN_SN>> GetScannedList()
      public async Task<ApiAction<PageAble<BIZ_U9_ASN_SN>>> GetScannedList(BaseInputWithPage input)
      {
         return await Task.FromResult(new PageAble<BIZ_U9_ASN_SN>()
         {
            data = ScanList,
            totals = ScanList.Count(),
         });
      }
            var action = new ApiAction<PageAble<BIZ_U9_ASN_SN>>();
            action.Data = new PageAble<BIZ_U9_ASN_SN>();
            action.Data.pageSize = input.pageSize;
            action.Data.pageIndex = input.pageIndex;
            action.Data.totals = ScanList.Count;
            action.Data.data = ScanList.Skip((input.pageIndex - 1) * input.pageSize).Take(input.pageSize).ToList();
            //action.Data = query;
            return action;
        }

      /// <summary>
      ///  获取当前所有单据信息
      /// </summary>
      /// <returns></returns>
      public async Task<List<BIZ_U9_ASN>> GetOrderList()
        /// <summary>
        ///  获取当前所有单据信息
        /// </summary>
        /// <returns></returns>
        public async Task<ApiAction<List<BIZ_U9_ASN>>> GetOrderList()
        {
         var Orders = await Biz.Db.Queryable<BIZ_U9_ASN>().Where(q => OrderList.Contains(q.ORDER_NO)).IncludesAllFirstLayer().ToListAsync();
         if (!Orders.IsNullOrEmpty())
            var action = new ApiAction<List<BIZ_U9_ASN>>();
            action.Data = await Biz.Db.Queryable<BIZ_U9_ASN>().Where(q => OrderList.Contains(q.ORDER_NO)).IncludesAllFirstLayer().ToListAsync();
         if (!action.Data.IsNullOrEmpty())
         {
            foreach (var order in Orders)
            foreach (var order in action.Data)
            {
               foreach (var dtl in order.Details)
               {
@@ -469,7 +481,7 @@
               }
            }
         }
         return Orders;
         return action;
      }

        /// <summary>
@@ -566,7 +578,8 @@

            if (list != null && list.Count > 0)
            {
               receipt.AUTH_ORG = order.AUTH_ORG;
                    receipt.ID = list.First().RcvId.ToString();
                    receipt.AUTH_ORG = order.AUTH_ORG;
               receipt.STATUS = BIZ_U9_RECEIPT.STATUSs.InQC.GetValue();
               receipt.ORDER_NO = list.First().DocNo;
               receipt.SUPP_CODE = list.First().SupplierCode;
@@ -584,6 +597,7 @@
                  var asnDtl = order.Details.First(q => q.ID == item.SrcASNDocLineId.ToString());
                  BIZ_U9_RECEIPT_DTL receiptDt = new()
                  {
                            ID = item.RcvLineId.ToString(),
                            AUTH_ORG = receipt.AUTH_ORG,
                            STATUS = BIZ_U9_RECEIPT.STATUSs.InQC.GetValue(),
                     ORDER_NO = item.DocNo,
@@ -638,14 +652,20 @@
               item.TRANS_LINE = receipt.SnList.First(q => q.SN == item.SN).LINE_NO;
               historys.Add(new WMS_ITEM_HIS(item, $"送货单[{order.ORDER_NO}]的条码[{item.SN}]生成收货单[{receipt.ORDER_NO}]，待检验完成后可入库"));
            }
                order.STATUS = BIZ_U9_ASN.STATUSs.Finished.GetValue();
                order.RECEIVER_ID = receipt.ID;
                order.RECEIVER_NO = receipt.ORDER_NO;
                order.RECEIVER = UserCode;
                order.RECEIVE_DATE = DateTime.Now;

            //使用统一的事务DB对象
            var db = GetCommitDB();
                //使用统一的事务DB对象
                var db = GetCommitDB();
            var dbTran = db.UseTran(() =>
            {
               db.Updateable(items, UserCode).UpdateColumns(q => new { q.UPDATE_TIME, q.UPDATE_USER, q.STATUS, q.TRANS_CODE, q.TRANS_NO, q.TRANS_LINE, q.SOURCE_CODE, q.SOURCE_ORDER, q.SOURCE_LINE }).ExecuteCommandAsync();
               db.Updateable(items, UserCode).UpdateColumns(q => new { q.UPDATE_TIME, q.UPDATE_USER, q.STATUS, q.TRANS_CODE, q.TRANS_NO, q.TRANS_LINE, q.SOURCE_CODE, q.SOURCE_ORDER, q.SOURCE_LINE }).ExecuteCommand();
               db.Insertable(historys, UserCode).ExecuteCommand();
               db.Insertable(receipt, UserCode).ExecuteCommand();
                    db.Updateable(order, UserCode).UpdateColumns(q => new { q.UPDATE_TIME, q.UPDATE_USER, q.STATUS, q.RECEIVER, q.RECEIVE_DATE, q.RECEIVER_ID, q.RECEIVER_NO }).ExecuteCommand();
                    db.Insertable(receipt, UserCode).ExecuteCommand();
               db.Insertable(receipt.Details, UserCode).ExecuteCommand();
               db.Insertable(receipt.SnList, UserCode).ExecuteCommand();
            });