using Rhea.Common;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Tiger.IBusiness;
|
using Tiger.Model;
|
using static Tiger.Business.Biz;
|
|
namespace Tiger.Business
|
{
|
public partial class Biz
|
{
|
/// <summary>
|
/// SN操作
|
/// </summary>
|
public partial class MqSNData : IMqSNData
|
{
|
/// <summary>
|
/// 退回删除条码
|
/// </summary>
|
/// <param name="barcode"></param>
|
/// <returns></returns>
|
public async Task<ApiAction> ReturnSN(string barcode)
|
{
|
var result = new ApiAction();
|
try
|
{
|
SNData_His data_His = await Db.Queryable<SNData_His>().Where(x => x.OriginalSN == barcode).FirstAsync();
|
if (data_His == null)
|
{
|
result.IsSuccessed = false;
|
result.Message = $"退回删除条码不存在";
|
return result;
|
}
|
List<SNData> sndatas = await Db.Queryable<SNData>().Where(x => x.SN == barcode || x.SN == data_His.SN).ToListAsync();
|
if (sndatas == null && sndatas.Count>0)
|
{
|
result.IsSuccessed = false;
|
result.Message = $"退回删除条码不存在";
|
return result;
|
}
|
result.Data = data_His.DeliveryNo;
|
var db = Db;
|
var dbTran = db.UseTran(() =>
|
{
|
db.Deleteable(data_His).ExecuteCommand();
|
db.Deleteable(sndatas).ExecuteCommand();
|
});
|
if (!dbTran.IsSuccess)
|
{
|
result.IsSuccessed = false;
|
result.Message = $"退回删除条码异常";
|
}
|
}
|
catch (Exception ex)
|
{
|
result.CatchExceptionWithLog(ex, "退回删除条码异常");
|
}
|
return result;
|
}
|
|
/// <summary>
|
/// 整单退回
|
/// </summary>
|
/// <param name="deliveryNo"></param>
|
/// <returns></returns>
|
public async Task<ApiAction> ReturnWhole(string deliveryNo)
|
{
|
var result = new ApiAction();
|
try
|
{
|
List<SNData_His> listHis = await Db.Queryable<SNData_His>().Where(x => x.DeliveryNo == deliveryNo).ToListAsync();
|
if (listHis.Count == 0)
|
{
|
result.IsSuccessed = false;
|
result.Message = $"退回送货单[{deliveryNo}]查不到要删除的条码";
|
return result;
|
}
|
List<SNData> sndatas = await Db.Queryable<SNData>().Where(x => x.DeliveryNo == deliveryNo).ToListAsync();
|
if (sndatas.Count == 0)
|
{
|
result.IsSuccessed = false;
|
result.Message = $"退回送货单[{deliveryNo}]查不到要删除的条码";
|
return result;
|
}
|
var db = Db;
|
var dbTran = db.UseTran(() =>
|
{
|
db.Deleteable(listHis).ExecuteCommand();
|
db.Deleteable(sndatas).ExecuteCommand();
|
});
|
if (!dbTran.IsSuccess)
|
{
|
result.IsSuccessed = false;
|
result.Message = $"退回删除条码异常";
|
}
|
}
|
catch (Exception ex)
|
{
|
result.CatchExceptionWithLog(ex, "退回删除条码异常");
|
}
|
return result;
|
}
|
|
/// <summary>
|
/// 分页
|
/// </summary>
|
/// <param name="pageList"></param>
|
/// <returns></returns>
|
public async Task<ApiAction<PageAble<SNData_His>>> GetSNDataHis(PageAble<SNData_His> pageList)
|
{
|
var res = new ApiAction<PageAble<SNData_His>>();
|
try
|
{
|
string[] strTime = pageList.sqlcmd?.Split(',');
|
RefAsync<int> total = 0;
|
pageList.data = await Db.Queryable<SNData_His>()
|
.WhereIF(!string.IsNullOrEmpty(strTime[0]), x => Convert.ToDateTime(x.ScanTime) > Convert.ToDateTime(strTime[0]))
|
.WhereIF(!string.IsNullOrEmpty(strTime[1]) && strTime.Length == 2, x => Convert.ToDateTime(x.ScanTime) < Convert.ToDateTime(strTime[1]))
|
.WhereIF(!string.IsNullOrEmpty(strTime[2]), x => x.ModelCode.Equals(strTime[2]))
|
.WhereIF(!string.IsNullOrEmpty(strTime[3]), x => x.CustomerCode.Equals(strTime[3]))
|
.WhereIF(!string.IsNullOrEmpty(strTime[4]), x => x.DeliveryNo.Equals(strTime[4]))
|
.WhereIF(!string.IsNullOrEmpty(strTime[5]), x => x.CustModel.Equals(strTime[5]))
|
.ToPageListAsync(pageList.pageIndex, pageList.pageSize, total);
|
pageList.totals = total;
|
}
|
catch (Exception ex)
|
{
|
res.CatchExceptionWithLog(ex, "查询异常");
|
}
|
res.Data = pageList;
|
return res;
|
}
|
|
/// <summary>
|
/// 获取所有条码，原厂条码和客户条码在同一行，按条件
|
/// </summary>
|
/// <param name="where"></param>
|
/// <returns></returns>
|
public async Task<ApiAction<List<SNData_His>>> GetAllSNDataHis(SNDataWhere where)
|
{
|
var res = new ApiAction<List<SNData_His>>();
|
List<SNData_His> list = new List<SNData_His>();
|
try
|
{
|
DateTime StartTime = DateTime.Now;
|
DateTime EndTime = DateTime.Now;
|
string[] strTime = where.strStartEnd?.Split(',');
|
if (!string.IsNullOrEmpty(where.strStartEnd)) { StartTime = Convert.ToDateTime(strTime[0].ToString()); EndTime = strTime.Length == 2 ? Convert.ToDateTime(strTime[1].ToString()) : DateTime.MinValue; }
|
RefAsync<int> total = 0;
|
list = await Db.Queryable<SNData_His>()
|
.WhereIF(!string.IsNullOrEmpty(where.strStartEnd), x => Convert.ToDateTime(x.ScanTime) > StartTime)
|
.WhereIF(!string.IsNullOrEmpty(where.strStartEnd) && strTime.Length == 2, x => Convert.ToDateTime(x.ScanTime) < EndTime)
|
.WhereIF(!string.IsNullOrEmpty(where.model), x => x.ModelCode == where.model)
|
.WhereIF(!string.IsNullOrEmpty(where.customerCode), x => x.CustomerCode.Equals(where.customerCode))
|
.WhereIF(!string.IsNullOrEmpty(where.deliveryNo), x => x.DeliveryNo.Equals(where.deliveryNo))
|
.WhereIF(!string.IsNullOrEmpty(where.custParam1), x => x.CustModel.Equals(where.custParam1))
|
.ToListAsync();
|
}
|
catch (Exception ex)
|
{
|
res.CatchExceptionWithLog(ex, "查询异常");
|
}
|
res.Data = list;
|
return res;
|
}
|
|
/// <summary>
|
/// 获取所有条码，原厂条码和客户条码分开两行，按条件
|
/// </summary>
|
/// <param name="where"></param>
|
/// <returns></returns>
|
public async Task<ApiAction<List<SNData>>> GetAllSNData(SNDataWhere where)
|
{
|
var res = new ApiAction<List<SNData>>();
|
List<SNData> list = new List<SNData>();
|
try
|
{
|
DateTime StartTime = DateTime.Now;
|
DateTime EndTime = DateTime.Now;
|
string[] strTime = where.strStartEnd?.Split(',');
|
if (!string.IsNullOrEmpty(where.strStartEnd)) { StartTime = Convert.ToDateTime(strTime[0].ToString()); EndTime = strTime.Length == 2 ? Convert.ToDateTime(strTime[1].ToString()) : DateTime.MinValue; }
|
RefAsync<int> total = 0;
|
list = await Db.Queryable<SNData>()
|
.WhereIF(!string.IsNullOrEmpty(where.strStartEnd), x => Convert.ToDateTime(x.CREATE_TIME) > StartTime)
|
.WhereIF(!string.IsNullOrEmpty(where.strStartEnd) && strTime.Length == 2, x => Convert.ToDateTime(x.CREATE_TIME) < EndTime)
|
.WhereIF(!string.IsNullOrEmpty(where.model), x => x.ItemCode == where.model)
|
.WhereIF(!string.IsNullOrEmpty(where.customerCode), x => x.CustomerCode.Equals(where.customerCode))
|
.WhereIF(!string.IsNullOrEmpty(where.deliveryNo), x => x.DeliveryNo.Equals(where.deliveryNo))
|
.WhereIF(!string.IsNullOrEmpty(where.custParam1), x => x.CustModel.Equals(where.custParam1))
|
.OrderBy(x=>x.CREATE_TIME).OrderBy(x => x.Scanner).ToListAsync();
|
}
|
catch (Exception ex)
|
{
|
res.CatchExceptionWithLog(ex, "查询异常");
|
}
|
res.Data = list;
|
return res;
|
}
|
}
|
}
|
}
|
