From e648b8f3c2647be4248ce6eed4fa21c9412ddb65 Mon Sep 17 00:00:00 2001
From: 啊鑫 <t2856754968@163.com>
Date: 星期六, 11 一月 2025 15:52:58 +0800
Subject: [PATCH] 11
---
service/Warehouse/TransferOutManager.cs | 282 +++++++++----------------------------------------------
1 files changed, 49 insertions(+), 233 deletions(-)
diff --git a/service/Warehouse/TransferOutManager.cs b/service/Warehouse/TransferOutManager.cs
index 0524c81..1314b8c 100644
--- a/service/Warehouse/TransferOutManager.cs
+++ b/service/Warehouse/TransferOutManager.cs
@@ -1,13 +1,14 @@
-锘縰sing NewPdaSqlServer.DB;
+锘縰sing System.Data;
+using System.Data.SqlClient;
+using NewPdaSqlServer.DB;
using NewPdaSqlServer.Dto.service;
using NewPdaSqlServer.entity;
-using NewPdaSqlServer.util;
using SqlSugar;
namespace NewPdaSqlServer.service.Warehouse;
/// <summary>
-/// 璋冩嫧鍑哄簱绠＄悊绫�
+/// 璋冩嫧鍑哄叆搴撶鐞嗙被
/// 璐熻矗澶勭悊璋冩嫧鍑哄簱鐩稿叧鐨勪笟鍔￠�昏緫
/// </summary>
public class TransferOutManager : Repository<TransferOut>
@@ -91,11 +92,7 @@
ScanMoveBarcode(WarehouseQuery query)
{
var p_bill_no = query.billNo;
- var c_user = query.userName;
var p_item_barcode = query.barcode;
-
- var p_bill_type_id = 300; // 鍗曟嵁绫诲瀷ID
- var p_transaction_no = 301; // 浜ゆ槗缂栧彿
// 楠岃瘉鍗曟嵁鍙�
if (string.IsNullOrEmpty(p_bill_no)) throw new Exception("璇烽�夊彇鍗曟嵁鍙凤紒");
@@ -114,245 +111,64 @@
.First();
if (stock == null) throw new Exception($"搴撳瓨涓棤姝ゆ潯鐮侊紝璇锋牳瀵癸紒{p_item_barcode}");
- // 楠岃瘉浠撳簱涓�鑷存��
- if (stock.DepotsCode != transferOut.InvCode)
- throw new Exception(
- $"鏉＄爜搴撳瓨浠撳簱{stock.DepotsCode}鍜岀敵璇蜂粨搴撲笉涓�鑷磠transferOut.InvCode}");
-
// 鏌ヨ鐗╂枡淇℃伅
var item = Db.Queryable<MesItems>()
.Where(x => x.Id == stock.ItemId)
.First();
if (item == null) throw new Exception("鏈壘鍒扮墿鏂�");
- // 鏌ヨ璋冩嫧鏄庣粏骞堕獙璇�
- var detail = Db.Queryable<TransferOutDetail>()
- .Where(x => x.ItemId == stock.ItemId && x.Pid == transferOut.Guid)
- .First();
- if (detail == null) throw new Exception("鏈壘鍒版潯鐮佺墿鏂欑浉搴旂殑璋冩嫧鐢宠");
-
- // 楠岃瘉鏁伴噺鏄惁瓒呭嚭鏈壂鏁伴噺
- if ((detail.ShNum ?? 0) - (detail.YsNum ?? 0) < stock.Quantity)
- throw new Exception("鏉＄爜鏁伴噺澶т簬鐢宠鏈壂鏁伴噺锛岃鎷嗗垎浜嗗啀鎵爜");
-
- // 浣跨敤浜嬪姟澶勭悊鏁版嵁鏇存柊
- UseTransaction(db =>
+ var _strMsg = "";
+ var _intSum = "";
+ using (var conn = new SqlConnection(DbHelperSQL.strConn))
{
- // 鏌ヨ鐜版湁绉诲簱璁板綍
- var existingMove = db.Queryable<MesInvItemMoves>()
- .Where(x => x.TaskNo == p_bill_no
- && x.TransactionNo == p_transaction_no
- && (x.Status ?? 0) == 0)
- .First();
-
- var commit = 0; // 璁板綍鏇存柊鎿嶄綔娆℃暟
- var c_id = Guid.Empty;
-
- // 澶勭悊绉诲簱涓昏〃璁板綍
- if (existingMove != null)
+ using (var cmd = new SqlCommand("[prc_pda_DBCK]", conn))
{
- // 鏇存柊鐜版湁璁板綍鐨勬渶鍚庝慨鏀逛俊鎭�
- commit += db.Updateable<MesInvItemMoves>()
- .SetColumns(s => s.LastupdateDate == DateTime.Now)
- .SetColumns(s => s.LastupdateBy == c_user)
- .Where(s => s.Guid == existingMove.Guid)
- .ExecuteCommand();
-
- c_id = existingMove.Guid;
- }
- else
- {
- // 鏌ヨ鐩稿叧浠撳簱淇℃伅
- var mesDepots = db.Queryable<MesDepots>()
- .Where(s => s.DepotCode == transferOut.FromCode)
- .First();
-
- var invMesDepots = db.Queryable<MesDepots>()
- .Where(s => s.DepotCode == transferOut.InvCode)
- .First();
-
- c_id = Guid.NewGuid();
-
- // 鍒涘缓鏂扮殑绉诲簱璁板綍
- var newMove = new MesInvItemMoves
+ try
{
- Guid = c_id,
- BillNo = BillNo.GetBillNo("DBCKD"),
- CreateBy = c_user,
- CreateDate = DateTime.Now,
- BillTypeId = p_bill_type_id,
- TransactionNo = p_transaction_no,
- InvDepotSectionsId = mesDepots.DepotId,
- // InvDepotSectionsCode = transferOut.FromCode,
- // FromDepotsCode = transferOut.InvCode,
- FromDepotsId = invMesDepots.DepotId.ToString(),
- TaskNo = p_bill_no
- };
- commit += db.Insertable(newMove).IgnoreColumns(true)
- .ExecuteCommand();
- }
+ conn.Open();
+ cmd.CommandType = CommandType.StoredProcedure;
+ SqlParameter[] parameters =
+ {
+ new("@outMsg", SqlDbType.NVarChar, 300),
+ new("@outSum", SqlDbType.NVarChar, 300),
+ new("@barcode_num", SqlDbType.NVarChar, 300),
+ new("@split_num", SqlDbType.NVarChar, 300),
+ new("@c_user", query.userName),
+ new("@p_bill_no", p_bill_no),
+ new("@p_item_barcode", p_item_barcode),
+ };
+ parameters[0].Direction = ParameterDirection.Output;
+ parameters[1].Direction = ParameterDirection.Output;
+ parameters[2].Direction = ParameterDirection.Output;
+ parameters[3].Direction = ParameterDirection.Output;
+ foreach (var parameter in parameters)
+ cmd.Parameters.Add(parameter);
+ cmd.ExecuteNonQuery();
+ _strMsg = parameters[0].Value.ToString();
+ _intSum = parameters[1].Value.ToString();
- // 鍐欏叆鑰佹潯鐮佷氦鏄撴槑缁�
- var business = new MesInvBusiness2
- {
- Guid = Guid.NewGuid(),
- Status = 1,
- BillTypeId = p_bill_type_id,
- TransactionCode = p_transaction_no.ToString(),
- BusinessType = -1,
- ItemBarcode = p_item_barcode,
- ItemNo = item.ItemNo,
- LotNo = stock.LotNo,
- EpFlag = true,
- Quantity = stock.Quantity,
- FromInvDepotsCode = stock.DepotsCode,
- FromInvDepotSectionsCode = stock.DepotSectionsCode,
- ToInvDepotsCode = transferOut.FromCode,
- ToInvDepotSectionsCode = stock.DepotSectionsCode,
- CreateBy = c_user,
- CreateDate = DateTime.Now,
- LastupdateBy = c_user,
- LastupdateDate = DateTime.Now,
- Factory = stock.Factory,
- Company = stock.Company,
- TaskNo = stock.TaskNo,
- BillNo = p_bill_no,
- WorkNo = stock.WorkNo,
- WorkLine = stock.WorkLine,
- SuppNo = stock.SuppNo,
- ItemId = stock.ItemId,
- EbelnK3id = stock.EbelnK3id,
- LineK3id = stock.LineK3id
- // RkDepot = transferOut.RkDepot,
- // CkDepot = transferOut.CkDepot
- };
+ var barcodeNum = parameters[2].Value.ToString();
+ var splitNum = parameters[3].Value.ToString();
+
+ var result = Convert.ToInt32(_intSum);
+ if (result <= 0) throw new Exception(_strMsg);
- commit += db.Insertable(business).IgnoreColumns(true)
- .ExecuteCommand();
+ query.itemNo = item.ItemNo;
+ query.Num = Convert.ToDecimal(barcodeNum);
+ query.Fum = Convert.ToDecimal(splitNum);
- // 鍐欏叆鏂版潯鐮佷氦鏄撴槑缁�
- var moveDetail = new MesInvItemMovesCDetails
- {
- Guid = Guid.NewGuid(),
- ItemMoveGuid = c_id,
- ItemBarcode = p_item_barcode,
- CItemCode = stock.CItemCode,
- ItemNo = item.ItemNo,
- LotNo = stock.LotNo,
- Quantity = stock.Quantity,
- EpFlag = stock.EpFlag,
- CreateBy = c_user,
- CreateDate = DateTime.Now,
- LastupdateBy = c_user,
- LastupdateDate = DateTime.Now,
- // CustomerNo = stock.CustomerNo,
- TaskNo = stock.TaskNo,
- FromDepotsCode = stock.DepotsCode,
- FromDepotSectionsCode = stock.DepotSectionsCode,
- Factory = stock.Factory,
- Company = stock.Company,
- InvDepotsCode = transferOut.FromCode,
- // InvDepotSectionsCode = p_sectioncode,
- IqcStatus = stock.IqcStatus,
- Fcar = stock.Fcar,
- IndepDate = stock.IndepDate,
- VisableSubmit = stock.VisableSubmit,
- VisableSubmitBy = stock.VisableSubmitBy,
- VisableSubmitDate = stock.VisableSubmitDate,
- BoardStyle = stock.BoardStyle,
- WorkNo = stock.WorkNo,
- WorkLine = stock.WorkLine,
- SuppNo = stock.SuppNo,
- ItemId = (int)stock.ItemId,
- EbelnK3id = stock.EbelnK3id,
- LineK3id = stock.LineK3id
- // RkDepot = transferOut.RkDepot,
- // CkDepot = transferOut.CkDepot
- };
-
- commit += db.Insertable(moveDetail).IgnoreColumns(true)
- .ExecuteCommand();
-
- // 鏇存柊鎴栨彃鍏ュ嚭搴撴槑缁嗚褰�
- var outItem = db.Queryable<MesInvItemOutItems>()
- .Where(x => x.ItemOutId == c_id && x.ItemId == stock.ItemId)
- .First();
-
- if (outItem != null)
- {
- // 鏇存柊鐜版湁璁板綍鐨勬暟閲�
- outItem.Quantity += stock.Quantity;
- commit += db.Updateable<MesInvItemOutItems>()
- .SetColumns(x => x.Quantity == outItem.Quantity)
- .Where(x => x.Guid == outItem.Guid)
- .ExecuteCommand();
- }
- else
- {
- // 鎻掑叆鏂拌褰�
- var newOutItem = new MesInvItemOutItems
+ // 杩斿洖鏇存柊鍚庣殑琛ㄥ崟鍜屽緟澶勭悊鏄庣粏
+ return (query, GetTransferOutDetailListByBillNo(query));
+ }
+ catch (Exception ex)
{
- Guid = Guid.NewGuid(),
- ItemOutId = c_id,
- ItemId = stock.ItemId,
- CreateBy = c_user,
- CreateDate = DateTime.Now,
- TaskNo = stock.TaskNo,
- WorkNo = stock.WorkNo,
- WorkLine = stock.WorkLine,
- EbelnK3id = (int)stock.EbelnK3id,
- LineK3id = (int)stock.LineK3id,
- Quantity = stock.Quantity
- // Unit = stock.ItemUnit
- };
-
- commit += db.Insertable(newOutItem).IgnoreColumns(true)
- .ExecuteCommand();
- }
-
- // 鏇存柊璋冩嫧鐢宠宸叉壂鏁伴噺
- detail = db.Queryable<TransferOutDetail>()
- .Where(x => x.Guid == detail.Guid)
- .First();
-
- if (detail != null)
- {
- detail.YsNum = (detail.YsNum ?? 0) + stock.Quantity as int?;
- commit += db.Updateable<TransferOutDetail>()
- .SetColumns(x => x.YsNum == detail.YsNum)
- .Where(x => x.Guid == detail.Guid)
- .ExecuteCommand();
- }
-
- // 妫�鏌ユ槸鍚︽墍鏈夋槑缁嗛兘宸插畬鎴�
- var totals = db.Queryable<TransferOutDetail, TransferOut>((b, a) =>
- new JoinQueryInfos(JoinType.Left, b.Pid == a.Guid))
- .Where((b, a) => a.BillNo == p_bill_no)
- .Select((b, a) => new
+ throw new Exception(ex.Message);
+ }
+ finally
{
- ShNum = SqlFunc.AggregateSum(b.ShNum), // 鐢宠鎬绘暟閲�
- YsNum = SqlFunc.AggregateSum(b.YsNum) // 宸叉壂鎬绘暟閲�
- })
- .First();
-
- // 濡傛灉鐢宠鏁伴噺绛変簬宸叉壂鏁伴噺锛屾洿鏂板崟鎹畬鎴愮姸鎬�
- if (totals.ShNum == totals.YsNum)
- commit += db.Updateable<TransferOut>()
- .SetColumns(x => x.IsWc == 1)
- .Where(x => x.BillNo == p_bill_no)
- .ExecuteCommand();
-
- // 鏇存柊杩斿洖鍙傛暟
- query.itemNo = item.ItemNo;
- query.Num = stock.Quantity;
-
- // 楠岃瘉鏇存柊鎿嶄綔鏄惁鍏ㄩ儴鎴愬姛
- if (commit < 4) throw new Exception("鏇存柊澶辫触");
-
- return commit;
- });
-
- // 杩斿洖鏇存柊鍚庣殑琛ㄥ崟鍜屽緟澶勭悊鏄庣粏
- return (query, GetTransferOutDetailListByBillNo(query));
+ conn.Close();
+ }
+ }
+ }
}
}
\ No newline at end of file
--
Gitblit v1.9.3