using System.Data;
|
using System.Data.SqlClient;
|
using System.Dynamic;
|
using System.Text;
|
using Gs.Entity.BaseInfo;
|
using Gs.Entity.Dto;
|
using Gs.Entity.QC;
|
using Gs.Entity.Sys;
|
using Gs.Entity.Warehouse;
|
using Gs.Entity.Wom;
|
using Gs.Toolbox;
|
using Gs.Toolbox.ApiCore.Abstract.Mvc;
|
using Gs.Toolbox.ApiCore.Common.Mvc;
|
using Gs.Toolbox.ApiCore.Entity;
|
using Gs.Toolbox.ApiCore.Group;
|
using Gs.Warehouse.Models;
|
using Microsoft.AspNetCore.Http;
|
using Microsoft.AspNetCore.Mvc;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using SqlSugar;
|
using SqlDataAdapter = System.Data.SqlClient.SqlDataAdapter;
|
|
namespace Gs.Warehouse.Services;
|
|
[ApiGroup(ApiGroupNames.PerMission)]
|
public class MesInvItemOutsManager : Repository<MesInvItemOuts>, IRomteService
|
{
|
//
|
private readonly IHttpContextAccessor _http;
|
private readonly MesInvItemOutCDetailsManager _mesInvItemOutCDetailsManager;
|
|
private readonly MesInvItemOutItemsManager _mesInvItemOutsManager;
|
|
private readonly string _userCode, _userGuid, _orgFids;
|
|
public MesInvItemOutsManager(IHttpContextAccessor httpContextAccessor)
|
{
|
_http = httpContextAccessor;
|
(_userCode, _userGuid, _orgFids) =
|
UtilityHelper.GetUserGuidAndOrgGuid(_http);
|
|
_mesInvItemOutsManager = new MesInvItemOutItemsManager();
|
_mesInvItemOutCDetailsManager = new MesInvItemOutCDetailsManager();
|
}
|
|
|
//[RequestMethod(RequestMethods.POST)]
|
//public ReturnDto<int> MESToERP([FromBody] MesInvItemOutItems model)
|
//{
|
// var _msgObj = MesToErpParam(model.Guid, model.ItemOutId, "", ErpOperationType.PurchaseReturnAudit);
|
// var responses = InterfaceUtil.ResendERP(_msgObj);
|
// if (responses.StartsWith("返回报错"))
|
// {
|
// LogHelper.Debug(ToString(), "erp：" + responses);
|
// return ReturnDto<int>.QuickReturn(0,
|
// ReturnCode.Default, responses);
|
// }
|
|
// return ReturnDto<int>.QuickReturn(1, ReturnCode.Success, "操作成功！");
|
//}
|
|
//private string GetErpParametersMx(Guid guid)
|
//{
|
// var materials = Db
|
// .Queryable<MesInvItemOuts, MesInvItemOutItems,
|
// MesItems, MesUnit, MesInvItemArnDetail, MesDepots>(
|
// (a, b, c, d, e, f) => new JoinQueryInfos(
|
// JoinType.Left, a.Guid == b.ItemOutId,
|
// JoinType.Left, b.ItemId == c.Id,
|
// JoinType.Left, d.Id.ToString() == c.ItemUnit,
|
// JoinType.Left,
|
// e.CbillNo == b.WorkNo && e.ItemId == b.ItemId,
|
// JoinType.Left, f.DepotId == a.DepotId
|
// )).Where((a, b, c, d, e, f) => b.Guid == guid)
|
// .Select<Material>((a, b, c, d, e, f) => new Material
|
// {
|
// FMaterialId = c.ItemNo,
|
// FRMREALQTY = b.Quantity.ToString(),
|
// FStockId = f.DepotCode,
|
// FUnitID = d.Fnumber,
|
// FLot = b.WorkNo,
|
// F_MES_ENTRYID = b.Guid,
|
// FsrcEntryId = e.Guid.ToString()
|
// }).ToList();
|
|
|
// var mm = Db.Queryable<MesInvItemOuts>()
|
// .Where(a => a.Guid == guid).First();
|
|
// var jsonEntries = materials.Select(d => new
|
// {
|
// d.FMaterialId,
|
// d.FRMREALQTY,
|
// d.FStockId,
|
// d.FUnitID,
|
// d.FLot,
|
// F_MES_ENTRYID = d.F_MES_ENTRYID.ToString(),
|
// d.FsrcEntryId
|
// }).ToList();
|
// var fdate = DateTime.Now.ToString("yyyy-MM-dd");
|
// var jsonString = JsonConvert.SerializeObject(jsonEntries);
|
// var encodedUrl = "taskname=CGTL&mesid=" + guid +
|
// "&optype=create&datajson={\"F_MES_ID\":\"" + guid
|
// + "\",\"FDate\":\"" + fdate
|
// + "\",\"FSRCBillTypeId\":\"" + "采购入库单"
|
// + "\",\"FDESCRIPTION\":\"" + mm.Remark
|
// + "\",\"FMRMODE\":\"" + mm.Fmrmode
|
// + "\",\"cgtlentry\":" + jsonString
|
// + "}";
|
// return encodedUrl;
|
//}
|
|
//public MessageCenter MesToErpParam(Guid formId, Guid? guid,
|
// string ErpUrl, ErpOperationType operationType)
|
//{
|
// var mm = Db.Queryable<MesInvItemOuts>()
|
// .Where(a => a.Guid == guid).First();
|
|
// var tableName = "";
|
// var title = "";
|
// var pageName = "";
|
|
// var _strErpParameters ="";
|
|
// switch (operationType)
|
// {
|
// case ErpOperationType.PurchaseReturnListReview:
|
// tableName = "INV_ITEM_OUTS_A";
|
// title = "生产领料单 " + mm.ItemOutNo + " 审核";
|
// pageName = "Warehouse/ProductionPick/ProductionPick?id=" +
|
// mm.Guid +
|
// "&itemOutNo=" + mm.ItemOutNo;
|
// _strErpParameters = SCLLAuditErpParamet(formId);
|
// break;
|
// case ErpOperationType.ProductionPickReverseAudit:
|
// tableName = "INV_ITEM_OUTS_A";
|
// title = "生产领料单 " + mm.ItemOutNo + " 反审核";
|
// pageName = "Warehouse/ProductionPick/ProductionPick?id=" +
|
// mm.Guid +
|
// "&itemOutNo=" + mm.ItemOutNo;
|
// _strErpParameters = SCLLReverseAuditErpParamet(formId);
|
// break;
|
|
// case ErpOperationType.PurchaseReturnAudit:
|
// tableName = "MesInvItemOuts";
|
// title = "采购退料单 " + mm.ItemOutNo;
|
// pageName = "Warehouse/PurchaseReturn/Add?id=" + mm.Guid +
|
// "&itemOutNo=" + mm.ItemOutNo;
|
// _strErpParameters = GetErpParametersMx(formId);
|
// break;
|
|
// default:
|
|
// throw new ArgumentOutOfRangeException(nameof(operationType),
|
// "Invalid ERP operation type");
|
// }
|
|
// var message = new MessageCenter
|
// {
|
// TableName = tableName,
|
// Url = ErpUrl,
|
// Status = 1,
|
// CreateBy = _userCode,
|
// Route = guid.ToString(),
|
// Title = title,
|
// PageName = pageName,
|
// CreateDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
|
// Method = "POST",
|
// Seq = 1,
|
// Data = _strErpParameters,
|
// IsMessage = 0,
|
// ContentType = "application/x-www-form-urlencoded"
|
// };
|
// return message;
|
//}
|
|
|
#region 生产领料单
|
|
///// <summary>
|
///// 生产领料单审核
|
///// </summary>
|
///// <param name="model"></param>
|
///// <returns></returns>
|
//[RequestMethod(RequestMethods.POST)]
|
//public ReturnDto<int> SCLLAuditSendErp([FromBody] MesInvItemOuts model)
|
//{
|
// var mesInvItemOuts = Db.Queryable<MesInvItemOuts>()
|
// .Where(a => a.ItemOutNo == model.ItemOutNo).First();
|
|
// if (mesInvItemOuts == null) throw new Exception("领料单号不存在");
|
|
|
// var womcaa = Db.Queryable<Womcaa>()
|
// .Where(s => s.Caa022.ToString() == mesInvItemOuts.WorkNo).First();
|
|
// if (womcaa == null) throw new Exception("任务单号不存在");
|
|
// var womdaa = Db.Queryable<Womdaa>()
|
// .Where(s => s.Daa001 == mesInvItemOuts.PbillNo).First();
|
|
// if (womdaa == null) throw new Exception("工单号不存在");
|
|
// var C_DEPARTMENTCODE = Db.Queryable<SysDepartment, MesInvItemOuts>(
|
// (a, b) => new object[]
|
// {
|
// JoinType.Left, a.Departmentid.ToString() == b.OutPart
|
// }).Where((a, b) => b.OutPart == mesInvItemOuts.OutPart)
|
// .Select((a, b) => a.Departmentcode).First();
|
|
// if (C_DEPARTMENTCODE == null) throw new Exception("部门信息不存在");
|
|
// if (mesInvItemOuts.Status == 1) throw new Exception("领料单已审核，不能重复推送");
|
|
// var _msgObj = MesToErpParam(mesInvItemOuts.Guid, null, "", ErpOperationType.PurchaseReturnListReview);
|
// var responses = InterfaceUtil.ResendERP(_msgObj);
|
// if (responses.StartsWith("返回报错"))
|
// {
|
// LogHelper.Debug(ToString(), "erp：" + responses);
|
// return ReturnDto<int>.QuickReturn(0,
|
// ReturnCode.Default, responses);
|
// }
|
|
// return ReturnDto<int>.QuickReturn(1, ReturnCode.Success, "操作成功！");
|
//}
|
|
///// <summary>
|
///// 生产领料单反审核
|
///// </summary>
|
///// <param name="model"></param>
|
///// <returns></returns>
|
//[RequestMethod(RequestMethods.POST)]
|
//public ReturnDto<int> SCLLReverseAuditErp([FromBody] MesInvItemOuts model)
|
//{
|
// var mesInvItemOuts = Db.Queryable<MesInvItemOuts>()
|
// .Where(a => a.ItemOutNo == model.ItemOutNo).First();
|
|
// if (mesInvItemOuts == null) throw new Exception("领料单号不存在");
|
|
// var womcaa = Db.Queryable<Womcaa>()
|
// .Where(s => s.Caa022.ToString() == mesInvItemOuts.WorkNo).First();
|
|
// if (womcaa == null) throw new Exception("任务单号不存在");
|
|
// var womdaa = Db.Queryable<Womdaa>()
|
// .Where(s => s.Daa001 == mesInvItemOuts.PbillNo).First();
|
|
// if (womdaa == null) throw new Exception("工单号不存在");
|
|
// var C_DEPARTMENTCODE = Db.Queryable<SysDepartment, MesInvItemOuts>(
|
// (a, b) => new object[]
|
// {
|
// JoinType.Left, a.Departmentid.ToString() == b.OutPart
|
// }).Where((a, b) => b.OutPart == mesInvItemOuts.OutPart)
|
// .Select((a, b) => a.Departmentcode).First();
|
|
// if (C_DEPARTMENTCODE == null) throw new Exception("部门信息不存在");
|
|
// // if (mesInvItemOuts.Status == 1) throw new Exception("领料单已审核，不能重复推送");
|
|
// var _msgObj = MesToErpParam(mesInvItemOuts.Guid, null, "", ErpOperationType.ProductionPickReverseAudit);
|
// var responses = InterfaceUtil.ResendERP(_msgObj);
|
// if (responses.StartsWith("返回报错"))
|
// {
|
// LogHelper.Debug(ToString(), "erp：" + responses);
|
// return ReturnDto<int>.QuickReturn(0,
|
// ReturnCode.Default, responses);
|
// }
|
|
// return ReturnDto<int>.QuickReturn(1, ReturnCode.Success, "操作成功！");
|
//}
|
|
//private string SCLLReverseAuditErpParamet(Guid formId)
|
//{
|
// var encodedUrl = "taskname=SCLL&mesid=" + formId +
|
// "&optype=delete&datajson={}";
|
|
// return encodedUrl;
|
//}
|
|
/// <summary>
|
/// 生产领料单查询
|
/// </summary>
|
/// <param name="query"></param>
|
/// <returns></returns>
|
[RequestMethod(RequestMethods.POST)]
|
public ReturnDto<PageList<MesInvItemOuts>> GetListPageSCLL(PageQuery query)
|
{
|
var itemsList = GetOut(query, Guid.Empty);
|
|
var pageList = new PageList<MesInvItemOuts>(itemsList.Item1,
|
itemsList.totalCount,
|
query.everyPageSize);
|
return ReturnDto<PageList<MesInvItemOuts>>.QuickReturn(pageList,
|
ReturnCode.Success, "读取成功");
|
}
|
|
[RequestMethod(RequestMethods.POST)]
|
public ReturnDto<MesInvItemOuts> GetModelSCLL(
|
[FromBody] MesInvItemOuts model)
|
{
|
var query = new PageQuery
|
{
|
currentPage = 1,
|
everyPageSize = 1
|
};
|
|
var (mesInvItemOutsList, totalCount) = GetOut(query, model.Guid);
|
|
if (totalCount <= 0)
|
return ReturnDto<MesInvItemOuts>.QuickReturn(new MesInvItemOuts(),
|
ReturnCode.Default,
|
"读取失败！");
|
|
var mesInvItemOuts = mesInvItemOutsList[0];
|
|
mesInvItemOuts.MesInvItemOutCDetailsList =
|
GetMesInvItemOutCDetailsSCLL(mesInvItemOuts.Guid);
|
|
mesInvItemOuts.MesInvItemOutItemsList =
|
getInvItemOutItemsListSCLL(mesInvItemOuts.Guid);
|
|
return ReturnDto<MesInvItemOuts>.QuickReturn(mesInvItemOuts,
|
ReturnCode.Success, "读取成功！");
|
}
|
|
private List<MesInvItemOutCDetails> GetMesInvItemOutCDetailsSCLL(
|
Guid? itemOutId)
|
{
|
return Db.Queryable<MesInvItemOutCDetails, MesItems,
|
MesDepots, MesDepotSections>(
|
(b, c, d, e) => new object[]
|
{
|
JoinType.Left, b.ItemId == c.Id,
|
JoinType.Left, b.DepotId == d.DepotId,
|
JoinType.Left, b.DepotSectionCode == e.DepotSectionCode
|
})
|
.Where((b, c, d, e) => b.ItemOutId == itemOutId)
|
.Select<MesInvItemOutCDetails>((b, c, d, e) =>
|
new MesInvItemOutCDetails
|
{
|
Guid = b.Guid,
|
DepotSectionCode = b.DepotSectionCode,
|
DepotCode = d.DepotCode,
|
ForceOutFlag = b.ForceOutFlag,
|
ItemNo = c.ItemNo,
|
Quantity = b.Quantity,
|
ItemBarcode = b.ItemBarcode,
|
ItemName = c.ItemName,
|
ItemModel = c.ItemModel,
|
ColorName = c.ColorName,
|
DepotName = d.DepotName,
|
DepotSectionName = e.DepotSectionName
|
}).ToList();
|
}
|
|
private List<MesInvItemOutItems> getInvItemOutItemsListSCLL(Guid itemOutId)
|
{
|
var mesInvItemOutItemsList = Db.Queryable<MesInvItemOutItems, MesItems>(
|
(c, s) => new object[]
|
{
|
JoinType.Inner, c.ItemId == s.Id
|
}).Where((c, s) => c.ItemOutId == itemOutId)
|
.Select<MesInvItemOutItems>((c, s) => new MesInvItemOutItems
|
{
|
Guid = c.Guid,
|
WorkNo = c.WorkNo,
|
Remark = c.Remark,
|
Quantity = c.Quantity,
|
ItemNo = s.ItemNo,
|
ItemName = s.ItemName,
|
ItemModel = s.ItemModel,
|
ItemUnit = s.ItemUnit
|
}).ToList();
|
|
return mesInvItemOutItemsList;
|
}
|
|
private (List<MesInvItemOuts>, int totalCount) GetOut(PageQuery query,
|
Guid? guid)
|
{
|
var _sbWhere = new StringBuilder(" 1=1" + query.keyWhere);
|
var _sbBy =
|
new StringBuilder(query.sortName + " " + query.sortOrder);
|
var totalCount = 0;
|
|
var result = Db
|
.Queryable<MesInvItemOuts, MesItems, MesInvBillType,
|
MesInvTransaction, SysDepartment, MesDepots, MesSupplier>(
|
(a, s, b, c, t, o, i) => new object[]
|
{
|
JoinType.Left, a.BoardItem == s.Id.ToString(),
|
JoinType.Left, a.BillTypeId == b.Id,
|
JoinType.Left, a.TransactionNo == c.TransactionNo,
|
JoinType.Left, a.OutPart == t.Id.ToString(),
|
JoinType.Left, a.DepotId == o.DepotId,
|
JoinType.Left, a.SuppId == i.Id
|
})
|
.Select((a, s, b, c, t, o, i) => new MesInvItemOuts
|
{
|
Guid = a.Guid,
|
OutType = a.OutType,
|
OutPart = a.OutPart,
|
BoardItem = a.BoardItem,
|
PbillNo = a.PbillNo,
|
OutDate = a.OutDate,
|
CheckDate = a.CheckDate,
|
WorkNo = a.WorkNo,
|
Status = a.Status,
|
CreateBy = a.CreateBy,
|
ItemOutNo = a.ItemOutNo,
|
ItemNo = s.ItemNo,
|
ItemName = s.ItemName,
|
BillTypeName = b.BillTypeName,
|
TransactionName = c.TransactionName,
|
DepotName = o.DepotName,
|
Departmentname = t.Departmentname,
|
SuppName = i.SuppName
|
})
|
.Where(a =>
|
a.BillTypeId == 200 && a.TransactionNo == 201 &&
|
a.IsVisual == true)
|
.Where(_sbWhere.ToString())
|
.WhereIF(UtilityHelper.CheckGuid(guid),
|
a => a.Guid == guid).OrderBy(_sbBy.ToString())
|
.ToPageList(query.currentPage, query.everyPageSize,
|
ref totalCount);
|
|
return (result, totalCount);
|
}
|
|
private string SCLLAuditErpParamet(Guid formId)
|
{
|
var materials = Db
|
.Queryable<MesInvItemOutCDetails, MesItems, MesUnit, MesDepots,
|
Womdab, Womcaa>(
|
(a, s, u, d, e, f) => new JoinQueryInfos(
|
JoinType.Left, a.ItemId == s.Id,
|
JoinType.Left, u.Id.ToString() == s.ItemUnit,
|
JoinType.Left, a.DepotId == d.DepotId,
|
JoinType.Left, a.Dabid == e.Guid,
|
JoinType.Left, e.Eid == f.Erpid
|
))
|
.Where((a, s, u, d, e, f) =>
|
a.ItemOutId == formId) // 根据 ITEM_OUT_ID 过滤
|
.GroupBy((a, s, u, d, e, f) => new
|
{
|
s.ItemNo, d.DepotCode, u.Fnumber, a.Guid, e.Erpid, f.Mtono,
|
f.Lot
|
})
|
.Select<Material>((a, s, u, d, e, f) => new Material
|
{
|
FMaterialId = s.ItemNo,
|
FUnitID = u.Fnumber,
|
FAppQty = SqlFunc.AggregateSum(a.Quantity).ToString() ?? "0",
|
FActualQty = SqlFunc.AggregateSum(a.Quantity).ToString() ?? "0",
|
FMtoNo = f.Mtono,
|
FLot = f.Lot,
|
FStockId = d.DepotCode,
|
FPPBomEntryId = e.Erpid.ToString(),
|
F_MES_ENTRYID = a.Guid
|
}).ToList();
|
|
|
var mm = Db.Queryable<MesInvItemOuts>()
|
.Where(a => a.Guid == formId).First();
|
|
var jsonEntries = materials.Select(d => new
|
{
|
d.FMaterialId,
|
d.FUnitID,
|
d.FAppQty,
|
d.FActualQty,
|
d.FMtoNo,
|
d.FLot,
|
d.FStockId,
|
d.FPPBomEntryId,
|
d.F_MES_ENTRYID
|
}).ToList();
|
var fdate = DateTime.Now.ToString("yyyy-MM-dd");
|
var jsonString = JsonConvert.SerializeObject(jsonEntries);
|
var encodedUrl = "taskname=SCLL&mesid=" + formId +
|
"&optype=create&datajson={\"F_MES_ID\":\"" + formId
|
+ "\",\"FDate\":\"" + fdate
|
+ "\",\"FPickerId\":\"" + _userCode
|
+ "\",\"scllentry\":" + jsonString
|
+ "}";
|
return encodedUrl;
|
}
|
|
|
/// <summary>
|
/// 生产领料单审核和反审核
|
/// </summary>
|
/// <param name="mode"></param>
|
/// <returns></returns>
|
[RequestMethod(RequestMethods.POST)]
|
public ReturnDto<ExpandoObject> EditModelSubmit([FromBody] dynamic mode)
|
{
|
string _guid = mode.guid;
|
dynamic m = new ExpandoObject();
|
m.outSum = 0;
|
m.outMsg = "";
|
using (var conn = new SqlConnection(DbHelperSQL.strConn))
|
{
|
using (var cmd = new SqlCommand("prc_scll_submit", conn))
|
{
|
try
|
{
|
conn.Open();
|
cmd.CommandType = CommandType.StoredProcedure;
|
SqlParameter[] parameters =
|
{
|
new("@outMsg", SqlDbType.NVarChar, 300),
|
new("@outSum", SqlDbType.Int),
|
new("@inEdtUserGuid", _userGuid),
|
new("@inOrderGuid", _guid),
|
new("@inFieldValue", 1),
|
new("@in1", ""),
|
new("@in2", "")
|
};
|
parameters[0].Direction = ParameterDirection.Output;
|
parameters[1].Direction = ParameterDirection.Output;
|
foreach (var parameter in parameters)
|
cmd.Parameters.Add(parameter);
|
cmd.ExecuteNonQuery();
|
m.outSum = parameters[1].Value.ToString();
|
m.outMsg = parameters[0].Value.ToString();
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Debug(ToString(),
|
"prc_scll_submit error：" + ex.Message);
|
return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default,
|
ex.Message);
|
}
|
finally
|
{
|
conn.Close();
|
}
|
}
|
}
|
|
return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Success, "操作成功！");
|
}
|
|
|
|
#endregion
|
|
#region CRUD
|
|
/// <summary>
|
/// 根据供应商id 读取退货物料
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[RequestMethod(RequestMethods.POST)]
|
public ReturnDto<PageList<dynamic>> GetCgtlViews([FromBody] dynamic model)
|
{
|
int currentPage = model.currentPage;
|
int everyPageSize = model.everyPageSize;
|
string sortName = model.sortName;
|
string keyWhere = model.keyWhere;
|
string inBusType = model.inBusType;
|
string inSupId = model.inSupId;
|
var dset = new DataSet();
|
try
|
{
|
using (var conn = new SqlConnection(DbHelperSQL.strConn))
|
{
|
using (var cmd = new SqlCommand("[prc_cgth_select]", conn))
|
{
|
conn.Open();
|
cmd.CommandType = CommandType.StoredProcedure;
|
SqlParameter[] parameters =
|
{
|
new("@inCurrentPage", currentPage),
|
new("@inEveryPageSize", everyPageSize),
|
new("@inSortName", sortName),
|
new("@inSortOrder", ""),
|
new("@inQueryWhere", keyWhere),
|
new("@inBusType", inBusType),
|
new("@inSupId", inSupId),
|
new("@inP1", ""),
|
new("@inP2", "")
|
};
|
foreach (var parameter in parameters)
|
cmd.Parameters.Add(parameter);
|
using (var dt =
|
new SqlDataAdapter(cmd))
|
{
|
dt.Fill(dset, "0");
|
}
|
}
|
|
conn.Close();
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Debug(ToString(), "GetListPage error：" + ex.Message);
|
return ReturnDto<PageList<dynamic>>.QuickReturn(
|
default(PageList<dynamic>), ReturnCode.Exception, "读取失败");
|
}
|
|
var _pglist = new PageList<dynamic>
|
{
|
total = 0,
|
everyPageSize = 0,
|
pages = 0,
|
list = new List<dynamic>()
|
};
|
if (dset != null && dset.Tables.Count > 0 &&
|
dset.Tables[0].Rows.Count > 0) //有数据
|
{
|
var intTotal =
|
int.Parse(dset.Tables[1].Rows[0]["intTotal"].ToString());
|
var pages = intTotal % everyPageSize != 0
|
? intTotal / everyPageSize + 1
|
: intTotal / everyPageSize;
|
_pglist.total = intTotal;
|
_pglist.everyPageSize = everyPageSize;
|
_pglist.pages = pages;
|
var _dy = dset.Tables[0].TableToDynamicList();
|
_pglist.list = _dy;
|
}
|
|
return ReturnDto<PageList<dynamic>>.QuickReturn(_pglist,
|
ReturnCode.Success, "读取成功");
|
}
|
|
/// <summary>
|
/// 根据用户选择的采购明细guid，读取需要作入库到货单的明细
|
/// </summary>
|
/// <param name="query"></param>
|
/// <returns></returns>
|
[RequestMethod(RequestMethods.POST)]
|
public ReturnDto<List<dynamic>> GetListPageByThmxGuid(
|
JArray guidList)
|
{
|
var intArray = guidList.ToObject<string[]>();
|
var sbLine = new StringBuilder();
|
foreach (var str in intArray)
|
{
|
if (sbLine.Length > 0)
|
sbLine.Append(",");
|
sbLine.Append(str);
|
}
|
|
var lst = new List<dynamic>();
|
var dset = new DataSet();
|
using (var conn = new SqlConnection(DbHelperSQL.strConn))
|
{
|
using (var cmd = new SqlCommand("[prc_cgth_get_mx_from_dh]", conn))
|
{
|
try
|
{
|
conn.Open();
|
cmd.CommandType = CommandType.StoredProcedure;
|
SqlParameter[] parameters =
|
{
|
new("@inP1", sbLine.ToString())
|
};
|
foreach (var parameter in parameters)
|
cmd.Parameters.Add(parameter);
|
using (var dt =
|
new SqlDataAdapter(cmd))
|
{
|
dt.Fill(dset, "0");
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Debug(ToString(),
|
"prc_cgth_get_mx_from_dh error：" + ex.Message);
|
}
|
finally
|
{
|
conn.Close();
|
}
|
}
|
}
|
|
if (dset != null && dset.Tables.Count > 0 &&
|
dset.Tables[0].Rows.Count > 0) //有数据
|
lst = dset.Tables[0].TableToDynamicList();
|
|
return ReturnDto<List<dynamic>>.QuickReturn(lst, ReturnCode.Success,
|
"读取成功！");
|
}
|
|
|
/// <summary>
|
/// 查询列表，支持分页
|
/// </summary>
|
/// <param name="query"></param>
|
/// <returns></returns>
|
[RequestMethod(RequestMethods.POST)]
|
public ReturnDto<PageList<MesInvItemOuts>> GetListPage(PageQuery query)
|
{
|
var itemsList = getPage(query, Guid.Empty);
|
|
var pageList = new PageList<MesInvItemOuts>(itemsList.Item1,
|
itemsList.totalCount,
|
query.everyPageSize);
|
return ReturnDto<PageList<MesInvItemOuts>>.QuickReturn(pageList,
|
ReturnCode.Success, "读取成功");
|
}
|
|
private (List<MesInvItemOuts>, int totalCount) getPage(PageQuery query,
|
Guid? guid)
|
{
|
var totalCount = 0;
|
|
var mesInvItemOutsList = Db
|
.Queryable<MesInvItemOuts, MesDepots, MesSupplier, SysUser,
|
SysUser>(
|
(a, e, i, u1, u3) => new object[]
|
{
|
JoinType.Left, a.DepotId == e.DepotId,
|
JoinType.Left, a.SuppId == i.Id,
|
JoinType.Left, a.CreateBy == u1.Account,
|
JoinType.Left, a.CheckUser == u3.Account
|
})
|
.WhereIF(UtilityHelper.CheckGuid(guid),
|
(a, e, i, u1, u3) => a.Guid == guid)
|
.OrderByDescending((a, e, i, u1, u3) => a.ItemOutNo)
|
.Select((a, e, i, u1, u3) => new MesInvItemOuts
|
{
|
Guid = a.Guid,
|
FType = a.FType,
|
SuppNo = i.SuppNo,
|
CheckDate = a.CheckDate,
|
CheckUser = a.CheckUser,
|
Nflag = a.Nflag,
|
Reason = a.Reason,
|
Remark = a.Remark,
|
Fmrmode = a.Fmrmode,
|
DepotCode = e.DepotCode,
|
CreateDate = a.CreateDate,
|
CreateBy = a.CreateBy,
|
Status = a.Status,
|
ItemOutNo = a.ItemOutNo,
|
DepotName = e.DepotName,
|
SuppName = i.SuppName,
|
CreateByFname = u1.UserName,
|
CheckUserFname = u3.UserName,
|
DepotId = a.DepotId,
|
SuppId = a.SuppId
|
}).ToPageList(query.currentPage, query.everyPageSize,
|
ref totalCount);
|
|
return (mesInvItemOutsList, totalCount);
|
}
|
|
/// <summary>
|
/// 根据主表id读取主表和子表
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[RequestMethod(RequestMethods.POST)]
|
public ReturnDto<MesInvItemOuts> GetModel(
|
[FromBody] MesInvItemOuts model)
|
{
|
var query = new PageQuery
|
{
|
currentPage = 1,
|
everyPageSize = 1
|
};
|
|
var (mesInvItemOutsList, totalCount) = getPage(query, model.Guid);
|
|
if (totalCount <= 0)
|
return ReturnDto<MesInvItemOuts>.QuickReturn(new MesInvItemOuts(),
|
ReturnCode.Default,
|
"读取失败！");
|
|
var mesInvItemOuts = mesInvItemOutsList[0];
|
|
mesInvItemOuts.MesInvItemOutCDetailsList =
|
GetMesInvItemOutCDetails(mesInvItemOuts.Guid);
|
|
mesInvItemOuts.MesInvItemOutItemsList =
|
getMesInvItemOutItemsList(mesInvItemOuts.Guid);
|
|
return ReturnDto<MesInvItemOuts>.QuickReturn(mesInvItemOuts,
|
ReturnCode.Success, "读取成功！");
|
}
|
|
private List<MesInvItemOutCDetails> GetMesInvItemOutCDetails(Guid itemOutId)
|
{
|
return Db.Queryable<MesInvItemOutCDetails, MesInvItemBarcodes, MesItems,
|
MesDepots, MesUnit>(
|
(b, bar, c, d, e) => new object[]
|
{
|
JoinType.Left, b.ItemBarcode == bar.ItemBarcode,
|
JoinType.Left, b.ItemId == c.Id,
|
JoinType.Left, b.DepotId == d.DepotId,
|
JoinType.Left, c.ItemUnit == e.Id.ToString()
|
})
|
.Where((b, bar, c, d, e) => b.ItemOutId == itemOutId)
|
.Select<MesInvItemOutCDetails>((b, bar, c, d, e) =>
|
new MesInvItemOutCDetails
|
{
|
Guid = b.Guid,
|
Quantity = b.Quantity,
|
DepotCode = b.DepotCode,
|
DepotSectionCode = b.DepotSectionCode,
|
EbelnK3id = b.EbelnK3id,
|
LineK3id = b.LineK3id,
|
ItemNo = c.ItemNo,
|
ItemBarcode = b.ItemBarcode,
|
ItemName = c.ItemName,
|
ItemModel = c.ItemModel,
|
DepotName = d.DepotName,
|
Fnumber = e.Fnumber,
|
DepotId = b.DepotId,
|
ItemId = b.ItemId,
|
ItemOutId = b.ItemOutId
|
}).ToList();
|
}
|
|
private List<MesInvItemOutItems> getMesInvItemOutItemsList(Guid itemOutId)
|
{
|
var mesInvItemOutItemsList = Db.Queryable<MesInvItemOutItems, MesItems>(
|
(c, s) => new object[]
|
{
|
JoinType.Inner, c.ItemId == s.Id
|
}).Where((c, s) => c.ItemOutId == itemOutId)
|
.Select<MesInvItemOutItems>((c, s) => new MesInvItemOutItems
|
{
|
Guid = c.Guid,
|
TlQty = c.TlQty,
|
WorkLine = c.WorkLine,
|
PbillNo = c.PbillNo,
|
LineK3id = c.LineK3id,
|
DepotCode = c.DepotCode,
|
Status = c.Status,
|
Remark = c.Remark,
|
EbelnK3id = c.EbelnK3id,
|
Quantity = c.Quantity,
|
ItemNo = s.ItemNo,
|
ItemName = s.ItemName,
|
ItemModel = s.ItemModel,
|
ItemId = c.ItemId,
|
RkNo = c.RkNo,
|
WorkNo = c.WorkNo,
|
AboutGuid = c.AboutGuid
|
}).ToList();
|
|
foreach (var mesInvItemOutItemse in mesInvItemOutItemsList)
|
{
|
var u = Db.Queryable<MesInvItemOutItems>()
|
.GroupBy(it => new
|
{ it.ItemId, it.PbillNo, it.WorkLine, it.RkNo })
|
.Where(it => it.ItemId == mesInvItemOutItemse.ItemId
|
// && it.PbillNo == mesInvItemOutItemse.PbillNo
|
// && it.WorkLine == mesInvItemOutItemse.WorkLine
|
&& it.RkNo == mesInvItemOutItemse.RkNo)
|
.Select(it => new
|
{
|
KtQty = SqlFunc.AggregateSum(it.Quantity ?? 0)
|
}).First();
|
|
var s1 = Db.Queryable<MesInvItemInCItems>()
|
.GroupBy(it => new
|
{ it.ItemId, it.Ebeln, it.WorkLine, it.BillNo })
|
.Where(it => it.ItemId == mesInvItemOutItemse.ItemId
|
&& it.CbillNo == mesInvItemOutItemse.WorkNo
|
// && it.WorkLine == mesInvItemOutItemse.WorkLine
|
// && it.BillNo == mesInvItemOutItemse.RkNo
|
)
|
.Select(it => new
|
{
|
RkQty = SqlFunc.AggregateSum(it.Quantity ?? 0)
|
}).First();
|
|
mesInvItemOutItemse.KtQty = s1.RkQty - u.KtQty;
|
}
|
|
return mesInvItemOutItemsList;
|
}
|
|
/// <summary>
|
/// 增加或编辑实体
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[RequestMethod(RequestMethods.POST)]
|
public ReturnDto<string?> EditModel([FromBody] MesInvItemOuts model)
|
{
|
Guid? guid = model.Guid; //主键
|
var bz = model.Remark; //备注
|
var gysId = model.SuppId; //供应商
|
var ckId = model.DepotId; //仓库
|
var fType = model.FType; //0=采购，1=委外
|
var Remark = model.Remark;
|
var Fmrmode = model.Fmrmode;
|
var Reason = model.Reason;
|
var _sb = new StringBuilder();
|
var _split = "|";
|
foreach (var m in model.MesInvItemOutItemsList)
|
{
|
var _line = m.AboutGuid + _split + m.Quantity + _split +
|
(UtilityHelper.CheckGuid(m.Guid)
|
? m.Guid.ToString()
|
: Guid.Empty.ToString());
|
if (_sb.Length > 0)
|
_sb.Append("~");
|
_sb.Append(_line);
|
}
|
|
var _outMsg = "";
|
var _outSum = -1;
|
using (var conn = new SqlConnection(DbHelperSQL.strConn))
|
{
|
using (var cmd = new SqlCommand("[prc_cgth_edt]", conn))
|
{
|
try
|
{
|
conn.Open();
|
cmd.CommandType = CommandType.StoredProcedure;
|
SqlParameter[] parameters =
|
{
|
new("@outMsg", SqlDbType.NVarChar, 300),
|
new("@outSum", SqlDbType.Int),
|
new("@inOrderGuid",
|
UtilityHelper.CheckGuid(guid)
|
? guid
|
: DBNull.Value),
|
new("@inBz", bz),
|
new("@inGysId", gysId),
|
new("@inCkId", ckId),
|
new("@inFType", fType),
|
new("@Fmrmode", Fmrmode),
|
new("@Reason", Reason),
|
new("@inEdtUserGuid ", _userGuid),
|
new("@inLineList ", _sb.ToString())
|
};
|
parameters[0].Direction = ParameterDirection.Output;
|
parameters[1].Direction = ParameterDirection.Output;
|
foreach (var parameter in parameters)
|
cmd.Parameters.Add(parameter);
|
cmd.ExecuteNonQuery();
|
_outMsg = parameters[0].Value.ToString();
|
_outSum = int.Parse(parameters[1].Value.ToString());
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Debug(ToString(),
|
"prc_cgdhd_Edt error：" + ex.Message);
|
_outMsg = ex.Message;
|
_outSum = -1;
|
}
|
finally
|
{
|
conn.Close();
|
}
|
}
|
}
|
|
if (_outSum <= 0)
|
return ReturnDto<string>.QuickReturn(guid.ToString(),
|
ReturnCode.Exception, _outMsg);
|
return ReturnDto<string>.QuickReturn(guid.ToString(),
|
ReturnCode.Success, _outMsg);
|
}
|
|
|
/// <summary>
|
/// 删除主表
|
/// </summary>
|
/// <param name="guid"></param>
|
/// <returns></returns>
|
[RequestMethod(RequestMethods.POST)]
|
public ReturnDto<int?> DeleteModel([FromBody] JArray guidList)
|
{
|
var intArray = guidList.ToObject<string[]>();
|
var cont = IsChkOrUnChk(intArray[0]);
|
if (cont > 0)
|
return ReturnDto<int>.QuickReturn(default(int?),
|
ReturnCode.Exception, "删除失败，该信息已被审核！");
|
|
int? rtnInt = base.DeleteByIds(intArray)
|
? intArray.Length
|
: 0;
|
|
var guidArray = Guid.Empty;
|
|
foreach (var t in intArray)
|
{
|
if (Guid.TryParse(t, out var guid))
|
guidArray = guid;
|
|
Db.Deleteable<MesInvItemOutItems>()
|
.Where(s => s.ItemOutId == guidArray)
|
.ExecuteCommand();
|
|
Db.Deleteable<MesInvItemOutCDetails>()
|
.Where(s => s.ItemOutId == guidArray)
|
.ExecuteCommand();
|
}
|
|
return rtnInt > 0
|
? ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Success,
|
"操作成功，共删除" + rtnInt + "条数据！")
|
: ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Exception,
|
"删除失败，请重试！");
|
}
|
|
|
/// <summary>
|
/// 删除明细实体，支持批量删除
|
/// </summary>
|
/// <param name="guid"></param>
|
/// <returns></returns>
|
[RequestMethod(RequestMethods.POST)]
|
public ReturnDto<int?> DeleteModelMx2([FromBody] JArray guidList)
|
{
|
var intArray = guidList.ToObject<string[]>();
|
var cont = 0;
|
cont = IsChkOrUnChkByMx2(intArray[0]);
|
if (cont > 0)
|
return ReturnDto<int>.QuickReturn(default(int?),
|
ReturnCode.Exception, "删除失败，该信息已被审核！");
|
int? rtnInt = (int)ReturnCode.Default;
|
var _manager = new MesInvItemOutItemsManager();
|
rtnInt = _manager.DeleteById(intArray) ? intArray.Length : 0;
|
if (rtnInt > 0)
|
return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Success,
|
"操作成功，共删除" + rtnInt + "条数据！");
|
return ReturnDto<int>.QuickReturn(rtnInt, ReturnCode.Exception,
|
"删除失败，请重试！");
|
}
|
|
|
private int IsChkOrUnChkByMx2(string _mxGuid)
|
{
|
var _manager = new MesInvItemOutItemsManager();
|
var md = _manager.GetById(_mxGuid);
|
return IsChkOrUnChk(md.ItemOutId.ToString());
|
}
|
|
//查询主表是否审核
|
private int IsChkOrUnChk(string? _guid)
|
{
|
var cont = Db.Queryable<MesInvItemOuts>()
|
.Where(it =>
|
it.Guid == Guid.Parse(_guid) && it.Status == 1)
|
.Count();
|
return cont;
|
}
|
|
#endregion
|
}
|
