|
using JiepeiWMS.IServices;
|
using JiepeiWMS.Model.Models;
|
using JiepeiWMS.Services.BASE;
|
using JiepeiWMS.IRepository.Base;
|
using System.Threading.Tasks;
|
using JiepeiWMS.Common.HttpContextUser;
|
using JiepeiWMS.Common.Enums;
|
using JiepeiWMS.Common.Helper;
|
using System;
|
using JiepeiWMS.Model.ViewModels;
|
using System.Linq;
|
using System.Collections.Generic;
|
using JiepeiWMS.Model;
|
using System.Linq.Expressions;
|
using System.Security.Claims;
|
using JiepeiWMS.Extends;
|
using SqlSugar;
|
using JiepeiWMS.Common.Config;
|
using JiepeiWMS.IRepository;
|
using JiepeiWMS.Common;
|
using JiepeiWMS.Common.HttpRestSharp;
|
using JiepeiWMS.Model.Result;
|
using System.Threading;
|
using Microsoft.Extensions.Logging;
|
using Newtonsoft.Json;
|
|
namespace JiepeiWMS.Services
|
{
|
public class WMSaleInfoServices : BaseServices<WMSaleInfo>, IWMSaleInfoServices
|
{
|
private readonly IBaseRepository<WMSaleInfo> _dal;
|
private readonly IWMSaleDetailRepository _wMSaleDetailRepository;
|
private readonly IWMProductListRepository _wMProductListRepository;
|
private readonly IWMWareHouseRepository _wMWareHouseRepository;
|
private readonly IWMProductSpecRepository _wMProductSpecRepository;
|
private readonly IWMProductUnitRepository _wMProductUnitRepository;
|
private readonly IWMCheckInfoRepository _wMCheckInfo;
|
private readonly IDepartmentRepository _departmentRepository;
|
private readonly IBaseRepository<sysUserInfo> _sysUserInfoRepository;
|
private readonly IUser _user;
|
private readonly IBaseRepository<UserRole> _userRoleRepository;
|
private readonly IBaseRepository<Role> _roleRepository;
|
private readonly ILogger<WMSaleInfoServices> _logger;
|
public WMSaleInfoServices(IBaseRepository<WMSaleInfo> dal,
|
IWMSaleDetailRepository WMSaleDetailRepository,
|
IWMProductListRepository WMProductListRepository,
|
IWMWareHouseRepository WMWareHouseRepository,
|
IWMProductSpecRepository WMProductSpecRepository,
|
IWMProductUnitRepository WMProductUnitRepository,
|
IWMCheckInfoRepository WMCheckInfo,
|
IDepartmentRepository DepartmentRepository,
|
IBaseRepository<sysUserInfo> SysUserInfoRepository,
|
IUser user,
|
IBaseRepository<Role> RoleRepository,
|
IBaseRepository<UserRole> UserRoleRepository,
|
ILogger<WMSaleInfoServices> logger)
|
{
|
this._dal = dal;
|
base.BaseDal = dal;
|
_wMSaleDetailRepository = WMSaleDetailRepository;
|
_wMProductListRepository = WMProductListRepository;
|
_wMWareHouseRepository = WMWareHouseRepository;
|
_wMProductSpecRepository = WMProductSpecRepository;
|
_wMProductUnitRepository = WMProductUnitRepository;
|
_wMCheckInfo = WMCheckInfo;
|
_departmentRepository = DepartmentRepository;
|
_sysUserInfoRepository = SysUserInfoRepository;
|
_user = user;
|
_roleRepository = RoleRepository;
|
_userRoleRepository = UserRoleRepository;
|
_logger = logger;
|
}
|
|
private string materialoutUrl = "/uapws/rest/ic/manage/materialout/add";
|
|
/// <summary>
|
/// 获取领料分页
|
/// </summary>
|
/// <returns></returns>
|
public async Task<PageModel<WMSaleInfo>> GetWMSaleInfoPage(int page, int intPageSize, string key = "", string options = "", string typeoptions = "", DateTime? startdate = null, DateTime? enddate = null, string statusoptions = "")
|
{
|
Expression<Func<WMSaleInfo, bool>> whereExpression = SaleInfo => SaleInfo.Status > 0;
|
|
//获取角色信息,判断是否数据展示
|
var role = string.Join(",", _user.GetClaimValueByType(ClaimTypes.Role));
|
if (role.Contains("SuperAdmin") || role.Contains("超级管理员") || role.Contains("仓库管理员"))
|
{
|
|
}
|
else
|
{
|
whereExpression = whereExpression.And(SaleInfo => SaleInfo.CheckAdminId == _user.ID || SaleInfo.EmployeeId == _user.ID);
|
}
|
//筛选主体Id
|
var userInfoModel = await _sysUserInfoRepository.QueryById(_user.ID);
|
if (userInfoModel != null)
|
{
|
whereExpression = whereExpression.And(SaleInfo => SaleInfo.SysOrgId == userInfoModel.SysOrgId);
|
}
|
if (!string.IsNullOrWhiteSpace(key))
|
{
|
//筛选商品名称、商品编号
|
var ProductListList = (await _wMProductListRepository.Query(s => s.Name.Contains(key.Trim()) || s.Code.Contains(key.Trim()))).Select(c => c.Id);
|
var SaleDetailList = (await _wMSaleDetailRepository.Query(x => ProductListList.Contains(x.ProductId))).Select(c => c.SaleId).Distinct();
|
|
whereExpression = whereExpression.And(SaleInfo => SaleInfo.SaleCode.Contains(key.Trim()) || SaleDetailList.Contains(SaleInfo.Id));
|
}
|
if (!string.IsNullOrWhiteSpace(options))
|
{
|
whereExpression = whereExpression.And(SaleInfo => SaleInfo.WareHouseId == options.ObjToInt());
|
}
|
if (!string.IsNullOrWhiteSpace(typeoptions))
|
{
|
whereExpression = whereExpression.And(SaleInfo => SaleInfo.PayType == typeoptions.ObjToInt());
|
}
|
if (startdate != null)
|
{
|
whereExpression = whereExpression.And(SaleInfo => SaleInfo.CreateTime >= startdate);
|
}
|
if (enddate != null)
|
{
|
whereExpression = whereExpression.And(SaleInfo => SaleInfo.CreateTime <= enddate);
|
}
|
if (!string.IsNullOrWhiteSpace(statusoptions))
|
{
|
whereExpression = whereExpression.And(SaleInfo => SaleInfo.Status == statusoptions.ObjToInt());
|
}
|
|
var PageList = await base.QueryTabsPage<WMSaleInfo, WMWareHouse, sysUserInfo, sysUserInfo, WMSaleInfo>(
|
(SaleInfo, WareHouse, UserInfo, UserInfo2) => new object[]
|
{
|
JoinType.Left,SaleInfo.WareHouseId==WareHouse.Id,
|
JoinType.Left,SaleInfo.EmployeeId==UserInfo.uID,
|
JoinType.Left,SaleInfo.CheckAdminId==UserInfo2.uID
|
},
|
(SaleInfo, WareHouse, UserInfo, UserInfo2) => new WMSaleInfo()
|
{
|
Id = SaleInfo.Id,
|
Status = SaleInfo.Status,
|
CheckKey = SaleInfo.CheckKey,
|
EmployeeId = SaleInfo.EmployeeId,
|
PayType = SaleInfo.PayType,
|
Remark = SaleInfo.Remark,
|
PayAmount = SaleInfo.PayAmount,
|
CheckRank = SaleInfo.CheckRank,
|
CreateTime = SaleInfo.CreateTime,
|
SaleCode = SaleInfo.SaleCode,
|
UpdateTime = SaleInfo.UpdateTime,
|
WareHouseName = WareHouse.Name,
|
EmployeeName = UserInfo.uRealName,
|
CheckAdminName = UserInfo2.uRealName,
|
DepartmentId = UserInfo.DepartmentId.Value
|
},
|
whereExpression,
|
page,
|
intPageSize,
|
" SaleInfo.Id desc"
|
);
|
|
foreach (var item in PageList.data)
|
{
|
//领料状态
|
var dicStatus = typeof(EnumWMSaleStatus)._GetValueDescriptionDicFromEnumType<EnumWMSaleStatus>();
|
string nameStatus;
|
item.SaleStatus = dicStatus.TryGetValue((EnumWMSaleStatus)item.Status, out nameStatus) ? nameStatus : string.Empty;
|
|
//领料类型
|
var dicType = typeof(EnumWMSaleType)._GetValueDescriptionDicFromEnumType<EnumWMSaleType>();
|
string nameType;
|
item.PayTypeName = dicType.TryGetValue((EnumWMSaleType)item.PayType, out nameType) ? nameType : string.Empty;
|
|
//部门信息
|
if (item.DepartmentId > 0)
|
{
|
var DepartmentModel = await _departmentRepository.QueryById(item.DepartmentId.Value);
|
if (DepartmentModel != null)
|
item.DepartmentName = DepartmentModel.Name;
|
}
|
|
//商品信息
|
var SaleDetailModel = await _wMSaleDetailRepository.GetModel(x => x.SaleId == item.Id);
|
if (SaleDetailModel != null)
|
{
|
var ProductListModel = await _wMProductListRepository.QueryById(SaleDetailModel.ProductId);
|
if (ProductListModel != null)
|
{
|
item.ProductName = ProductListModel.Name;
|
item.ProductCode = ProductListModel.Code;
|
}
|
}
|
|
var userrolemodel = await _userRoleRepository.GetModel(r => r.UserId == _user.ID);
|
if (userrolemodel != null)
|
{
|
var rolemodel = await _roleRepository.QueryById(userrolemodel.RoleId);
|
if (rolemodel != null && rolemodel.Name == RoleConfig.SaleCangKuStaff)
|
{
|
item.MayOut = true;//显示出库按钮
|
}
|
}
|
}
|
|
return PageList;
|
}
|
|
/// <summary>
|
/// 获取领料或出库详情
|
/// </summary>
|
/// <param name="Id"></param>
|
/// <returns></returns>
|
public async Task<WMSaleInfo> GetWMSaleInfo(int Id)
|
{
|
var model = await base.GetModel(w => w.Id == Id);
|
model.SaleDetailList = await _wMSaleDetailRepository.Query(w => w.SaleId == Id);
|
|
//仓库名称
|
var WMWareHouseModel = await _wMWareHouseRepository.GetModel(w => w.Id == model.WareHouseId);
|
if (WMWareHouseModel != null)
|
model.WareHouseName = WMWareHouseModel.Name;
|
|
|
//用户模型
|
var UserModel = await _sysUserInfoRepository.GetModel(u => u.uID == model.EmployeeId);
|
if (UserModel != null)
|
{
|
model.DepartmentId = UserModel.DepartmentId.Value;
|
model.EmployeeName = UserModel.uRealName;
|
//部门名称
|
var DepartmentModel = await _departmentRepository.GetModel(d => d.Id == UserModel.DepartmentId);
|
if (DepartmentModel != null)
|
model.DepartmentName = DepartmentModel.Name;
|
}
|
|
//var UserModel1 = await _sysUserInfoRepository.GetModel(u => u.uID == model.CheckAdminId);
|
//if (UserModel1 != null)
|
// model.CheckAdminName = UserModel1.uRealName;
|
|
var roleMdoel = await _roleRepository.GetModel(x => x.Name == RoleConfig.SaleCangKuStaff);
|
if (roleMdoel != null && model.Status >= EnumWMSaleStatus.OutWareHouse.GetHashCode())
|
{
|
var userRoleMdoel = await _userRoleRepository.GetModel(x => x.RoleId == roleMdoel.Id);
|
if (userRoleMdoel != null)
|
{
|
var UserModel2 = await _sysUserInfoRepository.GetModel(u => u.uID == userRoleMdoel.UserId);
|
if (UserModel2 != null)
|
model.IssueName = UserModel2.uRealName;
|
}
|
}
|
|
//领料状态
|
var dicSaleStatus = typeof(EnumWMSaleStatus)._GetValueDescriptionDicFromEnumType<EnumWMSaleStatus>();
|
string nameSaleStatus;
|
model.SaleStatus = dicSaleStatus.TryGetValue((EnumWMSaleStatus)model.Status, out nameSaleStatus) ? nameSaleStatus : string.Empty;
|
|
//领料类型
|
var dicType = typeof(EnumWMSaleType)._GetValueDescriptionDicFromEnumType<EnumWMSaleType>();
|
string nameType;
|
model.PayTypeName = dicType.TryGetValue((EnumWMSaleType)model.PayType, out nameType) ? nameType : string.Empty;
|
|
//获取审批流
|
var checkModel = await _wMCheckInfo.GetModel(w => w.SysOrgId == _user.SysOrgId && w.Key == model.CheckKey);
|
if (checkModel != null)
|
{
|
var rankList = JsonHelper.DeserializeObject<CheckRankList>(checkModel.Json);
|
var checkarr = rankList.checkRankList.Select(w => w.AdminName).ToArray();
|
|
for (int i = 0; i < checkarr.Length; i++)
|
{
|
model.CheckAdminName = checkarr[i] + " ";
|
}
|
model.CheckStrStep = checkarr.ToList();
|
//model.CheckRankStep = model.CheckRank == 0 ? (checkarr.Count() - 1) : (model.CheckRank - 2);
|
model.CheckRankStep = model.CheckRank == 0 ? checkarr.Count() : (model.CheckRank - 1);
|
}
|
else
|
{
|
model.CheckStrStep = new List<string>();
|
model.CheckRankStep = 0;
|
}
|
|
model.AdminId = _user.ID;
|
|
foreach (var item in model.SaleDetailList)
|
{
|
//商品信息
|
var ProductListModel = await _wMProductListRepository.GetModel(w => w.Id == item.ProductId);
|
if (ProductListModel != null)
|
{
|
item.ProductCode = ProductListModel.Code;
|
item.ProductName = ProductListModel.Name;
|
if (ProductListModel.SpecIds > 0)
|
{
|
//商品规格
|
var ProductSpecModel = await _wMProductSpecRepository.QueryById(ProductListModel.SpecIds);
|
if (ProductSpecModel != null)
|
{
|
item.ProductSpec = ProductSpecModel.Name;
|
}
|
}
|
if (ProductListModel.Unit > 0)
|
{
|
//商品单位
|
var ProductUnitModel = await _wMProductUnitRepository.QueryById(ProductListModel.Unit);
|
if (ProductUnitModel != null)
|
{
|
item.ProductUnit = ProductUnitModel.Unit;
|
}
|
}
|
}
|
|
item.CheckNum = item.Quantity;
|
item.GiveNum = item.Quantity;
|
if (item.Checked <= 0)
|
{
|
item.Checked = 1;
|
}
|
|
//商品状态
|
var dicProductStatus = typeof(EnumWMSaleStatus)._GetValueDescriptionDicFromEnumType<EnumWMSaleStatus>();
|
string nameProductStatus;
|
item.ProductStatus = dicProductStatus.TryGetValue((EnumWMSaleStatus)item.Status, out nameProductStatus) ? nameProductStatus : string.Empty;
|
}
|
|
return model;
|
}
|
|
/// <summary>
|
/// 获取领料最大的Id
|
/// </summary>
|
/// <returns></returns>
|
public async Task<int> GetSaleInfoMaxId()
|
{
|
var db = await base.QueryTable("SELECT ISNULL(MAX(Id),0) FROM dbo.WMSaleInfo");
|
return db.Rows[0][0].ObjToInt();
|
}
|
|
/// <summary>
|
/// 调用友物料出库接口
|
/// </summary>
|
/// <returns></returns>
|
public async Task<Tuple<string, bool>> BeginMaterialOutInNC(WMSaleInfo infoModel, List<WMSaleDetail> detailList)
|
{
|
try
|
{
|
#region
|
NCMaterialOutViewModels pos = new NCMaterialOutViewModels();
|
NCMaterialOutViewModels.Ufinterface uface = new NCMaterialOutViewModels.Ufinterface();
|
NCMaterialOutViewModels.Bill bill = new NCMaterialOutViewModels.Bill();
|
NCMaterialOutViewModels.Billhead head = new NCMaterialOutViewModels.Billhead();
|
NCMaterialOutViewModels.Cgeneralbid cgeneralbid = new NCMaterialOutViewModels.Cgeneralbid();
|
List<NCMaterialOutViewModels.Item> item = new List<NCMaterialOutViewModels.Item>();
|
|
var UnitCode = "";
|
var SupplierModel = new WMSupplier();
|
var ProductListModel = new WMProductList();
|
|
//赋uface
|
uface.account = "01";
|
uface.billtype = "4D";//物料出库
|
uface.isexchange = "Y";
|
uface.replace = "Y";
|
uface.sender = "JPKJ001";
|
uface.groupcode = "JPKJ";
|
|
//赋head
|
head.pk_group = "JPKJ";
|
head.pk_org = "1001";
|
head.corpoid = "1001";
|
head.corpvid = "1001";
|
head.pk_org = "1001";
|
head.pk_org_v = "1001";
|
head.cwarehouseid = "01";
|
head.vtrantypecode = "4D-01";
|
head.cdrawcalbodyoid = "1001";
|
head.cdrawcalbodyvid = "1001";
|
head.fbillflag = "2";
|
|
//赋item
|
foreach (var detailItem in detailList)
|
{
|
if (detailItem.ProductId > 0)
|
{
|
ProductListModel = await _wMProductListRepository.QueryById(detailItem.ProductId);
|
if (ProductListModel != null)
|
{
|
var qt = await QueryTable("select UnitCode from WMProductUnit where id=" + ProductListModel.Unit);
|
UnitCode = qt.Rows._Select(t => t["UnitCode"]._ToDbStr()).FirstOrDefault();
|
}
|
}
|
|
var ItemModel = new NCMaterialOutViewModels.Item();
|
ItemModel.cmaterialoid = ProductListModel.Code;
|
ItemModel.cmaterialvid = ProductListModel.Code;
|
ItemModel.cunitid = UnitCode;
|
ItemModel.castunitid = UnitCode;
|
ItemModel.vchangerate = "1/1";//换算率
|
ItemModel.nshouldnum = detailItem.GiveNum.ToString();
|
ItemModel.nshouldassistnum = detailItem.GiveNum.ToString();
|
ItemModel.nnum = detailItem.GiveNum.ToString();
|
ItemModel.nassistnum = detailItem.GiveNum.ToString();
|
item.Add(ItemModel);
|
}
|
|
//所有集合赋值
|
cgeneralbid.item = item;
|
head.cgeneralbid = cgeneralbid;
|
bill.billhead = head;
|
uface.bill = bill;
|
pos.ufinterface = uface;
|
var json = JsonConvert.SerializeObject(pos);
|
|
//物料出库接口
|
var apinchost = Appsettings.app("AppSettings", "ApiNCHost");
|
NCJsonResult jsonResult = HttpHelper.PostApi<NCJsonResult>(apinchost + materialoutUrl, pos);
|
Thread.Sleep(300);
|
#endregion
|
|
var resultdescription = jsonResult.data.ufinterface.sendresult[0].resultdescription;
|
if (jsonResult.data.ufinterface.successful == "Y")
|
{
|
return new Tuple<string, bool>("用友物料出库接口成功", true);
|
}
|
else
|
{
|
string[] strArray = resultdescription.Split("异常信息:");
|
return new Tuple<string, bool>("用友物料出库接口失败："+strArray[1], false);
|
}
|
}
|
catch (Exception ex)
|
{
|
_logger.LogError(ex, ex.ToString());
|
return new Tuple<string, bool>(ex.ToString(), false);
|
}
|
}
|
}
|
}
|
