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;
|
|
namespace Tiger.Business
|
{
|
public partial class Biz
|
{
|
/// <summary>
|
/// 客户
|
/// </summary>
|
public partial class MqModelInfo : IModelInfo
|
{
|
/// <summary>
|
/// 获取分页
|
/// </summary>
|
/// <param name="pageList"></param>
|
/// <returns></returns>
|
public async Task<ApiAction<PageAble<ModelInfo>>> GetModelInfo(PageAble<ModelInfo> pageList)
|
{
|
var res = new ApiAction<PageAble<ModelInfo>>();
|
try
|
{
|
RefAsync<int> total = 0;
|
pageList.data = await Db.Queryable<ModelInfo>().WhereIF(!string.IsNullOrEmpty(pageList.sqlcmd), x => x.Model.Contains(pageList.sqlcmd)).OrderBy(x=>x.Model).ToPageListAsync(pageList.pageIndex, pageList.pageSize, total);
|
pageList.totals = total;
|
}
|
catch (Exception ex)
|
{
|
res.CatchExceptionWithLog(ex, "获取产品信息异常");
|
}
|
res.Data = pageList;
|
return res;
|
}
|
|
/// <summary>
|
/// 导入
|
/// </summary>
|
/// <param name="list"></param>
|
/// <returns></returns>
|
public async Task<ApiAction> SaveImportModelInfo(List<ModelInfo> list)
|
{
|
var res = new ApiAction();
|
//更新机型记录
|
var db = Db;
|
var dbTran = await db.UseTranAsync(async () =>
|
{
|
await db.Saveable(list).ExecuteCommandAsync();
|
});
|
if (!dbTran.IsSuccess)
|
{
|
res.IsSuccessed = false;
|
res.Message = $"导入异常";
|
}
|
return res;
|
}
|
|
/// <summary>
|
/// 保存机型
|
/// </summary>
|
/// <param name="user"></param>
|
/// <returns></returns>
|
public async Task<ApiAction> SaveModel(ModelInfo modelInfo)
|
{
|
var result = new ApiAction();
|
try
|
{
|
|
var db = Db;
|
var dbTran = db.UseTran(() =>
|
{
|
var y = db.Storageable(modelInfo)
|
.WhereColumns(t => new { t.Model })
|
.ToStorage();
|
y.AsInsertable.ExecuteCommand();
|
y.AsUpdateable.ExecuteCommand();
|
});
|
if (!dbTran.IsSuccess)
|
{
|
result.IsSuccessed = false;
|
result.Message = $"导入异常";
|
}
|
}
|
catch (Exception ex)
|
{
|
result.CatchExceptionWithLog(ex, "保存机型异常");
|
}
|
return result;
|
}
|
}
|
}
|
}
|
