using Model.ModelDto.SysDto;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WMS.Entity.Context;
|
using WMS.Entity.SysEntity;
|
using WMS.IDAL.ISysInterface;
|
|
namespace WMS.DAL.SysInfrastructure
|
{
|
public class ExceptionRepository : BaseRepository<SysException>, IExceptionRepository
|
{
|
private static readonly SqlSugarScope Db = DataContext.Db;
|
public ExceptionRepository() : base(DataContext.Db)
|
{
|
}
|
|
|
/// <summary>
|
/// 获取异常处理信息列表
|
/// </summary>
|
/// <param name="exceptionNo">异常号</param>
|
/// <param name="palletNo">托盘号</param>
|
/// <param name="excLocatNo">异常储位</param>
|
/// <param name="orderNo">关联单号</param>
|
/// <param name="taskNo">关联任务号</param>
|
/// <param name="type">异常类型</param>
|
/// <param name="status">状态</param>
|
/// <returns></returns>
|
public List<ExceptionDto> GetExceptionList(string exceptionNo, string palletNo, string excLocatNo, string orderNo, string taskNo, string type, string status)
|
{
|
string str = "select exception.*,user1.UserName CreateUserName from SysException exception left join SysUserInfor user1 on exception.CreateUser = user1.Id where exception.IsDel = @isdel";
|
//判断异常号
|
if (!string.IsNullOrEmpty(exceptionNo))
|
{
|
str += " and exception.ExceptionNo like @exceptionno";
|
}
|
//判断托盘号
|
if (!string.IsNullOrEmpty(palletNo))
|
{
|
str += " and exception.PalletNo like @palletno";
|
}
|
//判断异常储位号
|
if (!string.IsNullOrEmpty(excLocatNo))
|
{
|
str += " and exception.ExcLocatNo like @exclocatno";
|
}
|
//判断关联单号
|
if (!string.IsNullOrEmpty(orderNo))
|
{
|
str += " and exception.OrderNo like @orderno";
|
}
|
//判断关联任务号
|
if (!string.IsNullOrEmpty(taskNo))
|
{
|
str += " and exception.TaskNo like @taskno";
|
}
|
//判断异常类型
|
if (!string.IsNullOrEmpty(type))
|
{
|
str += " and exception.Type = @type";
|
}
|
//判断状态
|
if (!string.IsNullOrEmpty(status))
|
{
|
str += " and exception.Status = @status";
|
}
|
str += " order by exception.CreateTime desc";
|
List<ExceptionDto> tablelist = Db.Ado.SqlQuery<ExceptionDto>(str, new
|
{
|
isdel = "0", //是否删除
|
exceptionno = "%" + exceptionNo + "%", //异常号
|
palletno = "%" + palletNo + "%", //托盘号
|
exclocatno = "%" + excLocatNo + "%", //异常储位
|
orderno = "%" + orderNo + "%", //关联单号
|
taskno = "%" + taskNo + "%", //关联任务号
|
type, //异常类型
|
status //状态
|
});
|
return tablelist;
|
}
|
|
/// <summary>
|
/// 根据id获取异常信息
|
/// </summary>
|
/// <param name="id">异常id</param>
|
/// <returns></returns>
|
public SysException GetExceptionById(int id)
|
{
|
string str = "select * from SysException where IsDel = @isdel and Id = @id";
|
SysException exception = Db.Ado.SqlQuerySingle<SysException>(str, new
|
{
|
isdel = "0", //是否删除
|
id //id
|
});
|
return exception;
|
}
|
|
/// <summary>
|
/// 新增异常处理
|
/// </summary>
|
/// <param name="exceptionNo">异常号</param>
|
/// <param name="type">异常类型</param>
|
/// <param name="palletNo">托盘号</param>
|
/// <param name="excLocatNo">异常储位</param>
|
/// <param name="orderNo">关联单号</param>
|
/// <param name="taskNo">关联任务号</param>
|
/// <param name="demo">备注</param>
|
/// <param name="uid">创建人</param>
|
/// <returns></returns>
|
public async Task<int> InsertException(string exceptionNo, string type, string palletNo, string excLocatNo, string orderNo, string taskNo, string demo, int uid)
|
{
|
string str = "Insert into SysException values(@exceptionno, @type, @palletno, @exclocatno, @orderno, @taskno, @status, @text, @demo, @isdel, @createtime, @createuser, null, null)";
|
int i = await Db.Ado.ExecuteCommandAsync(str, new
|
{
|
exceptionno = exceptionNo, //异常号
|
type, //异常类型
|
palletno = palletNo, //托盘号
|
exclocatno = excLocatNo, //异常储位
|
orderno = orderNo, //关联单号
|
taskno = taskNo, //关联任务号
|
status = "0", //状态
|
text = "", //处理描述
|
demo, //备注
|
isdel = "0",//是否删除
|
createtime = Db.GetDate(), //创建时间
|
createuser = uid //创建人
|
});
|
return i;
|
|
//异常号获取最大值加一 ExceptionNo 1
|
//异常类型 0：空取 要去一个库取东西 到了以后发现没东西 1：满入 要去一个地方放东西 到了以后发现放不下 2：双工位异常 例如：目标区域有两个地方可以放东西 我要把东西放在二号区域 二号区域被一号区域挡住了 放不了 取货反之Type
|
//托盘号PalletNo
|
//异常储位 多储位用;号区分ExcLocatNo
|
//关联单号 入库单、出库单、移库单OrderNo
|
//关联任务号TaskNo
|
//状态Status 默认未处理
|
//处理描述Text //空
|
//备注Demo 1
|
|
//是否删除 0 1
|
//创建时间 Db.GetDate(); 1
|
//创建人 ：操作人 1
|
|
}
|
|
/// <summary>
|
/// 处理异常状态
|
/// </summary>
|
/// <param name="exception"></param>
|
/// <returns></returns>
|
public async Task<int> EditStatus(SysException exception)
|
{
|
string str = "update SysException set Status = @status,Demo = @demo,Text = @text,UpdateTime = @updatetime,UpdateUser = @updateuser where Id = @id";
|
int i = await Db.Ado.ExecuteCommandAsync(str, new
|
{
|
status = "1", //状态
|
demo = exception.Demo, //备注
|
text = exception.Text, //处理描述
|
updatetime = Db.GetDate(), //更改时间
|
updateuser = exception.UpdateUser, //更改人
|
id = exception.Id //id
|
});
|
return i;
|
}
|
|
/// <summary>
|
/// 获取最大异常号
|
/// </summary>
|
/// <returns></returns>
|
public SysException GetMaxExceptionNo()
|
{
|
string str = "select MAX(ExceptionNo) ExceptionNo from SysException";
|
SysException table = Db.Ado.SqlQuerySingle<SysException>(str);
|
return table;
|
}
|
}
|
}
|
