using MES.Service.DB;
|
using MES.Service.Dto.service;
|
using MES.Service.Modes;
|
using Newtonsoft.Json;
|
using System.Text;
|
|
namespace MES.Service.service.Warehouse;
|
|
public class MesPalletBinding1Manager : Repository<MesPalletBinding1>
|
{
|
/// <summary>
|
/// 调用接口获取栈板绑定信息
|
/// </summary>
|
/// <param name="stackCode">栈板码</param>
|
/// <returns>接口返回结果</returns>
|
public async Task<GetTransferListResponse> GetTransferListByStackCodeAsync(
|
MesPalletBinding palletBinding)
|
{
|
try
|
{
|
// API URL
|
string apiUrl =
|
"http://no2api.dream-maker.com/bu/storage/pallet/getTransferList";
|
|
// 构建请求体
|
var requestData = new { stackCode = palletBinding.StackCode };
|
var jsonContent = JsonConvert.SerializeObject(requestData);
|
var content = new StringContent(jsonContent, Encoding.UTF8,
|
"application/json");
|
|
// 发送HTTP请求
|
using (var httpClient = new HttpClient())
|
{
|
var response = await httpClient.PostAsync(apiUrl, content);
|
var responseContent =
|
await response.Content.ReadAsStringAsync();
|
|
// 反序列化响应
|
var result =
|
JsonConvert.DeserializeObject<GetTransferListResponse>(
|
responseContent);
|
return result;
|
}
|
}
|
catch (Exception ex)
|
{
|
throw new Exception($"调用接口获取栈板绑定信息失败: {ex.Message}");
|
}
|
}
|
|
/// <summary>
|
/// 将接口返回的数据插入到数据库中
|
/// </summary>
|
/// <param name="palletBinding">栈板绑定信息</param>
|
/// <returns>插入记录数</returns>
|
public int InsertPalletBindingData(MesPalletBinding palletBinding)
|
{
|
var response = GetTransferListByStackCodeAsync(palletBinding).Result;
|
|
if (response?.Data?.SnList == null || string.IsNullOrEmpty(response.Data.StackCode))
|
{
|
return 0;
|
}
|
|
int insertedCount = 0;
|
|
try
|
{
|
// 准备要插入的数据列表
|
var bindingList = new List<MesPalletBinding1>();
|
|
foreach (var snItem in response.Data.SnList)
|
{
|
var binding = new MesPalletBinding1
|
{
|
Stackcode = response.Data.StackCode,
|
SnNo = snItem.SnNo,
|
TicketNo = snItem.TickeNo,
|
Mediumboxcode = snItem.MediumBoxCode,
|
CreateDate = DateTime.Now,
|
IsInbound = 0 // 默认未入库
|
};
|
|
bindingList.Add(binding);
|
}
|
|
// 批量插入数据到数据库
|
if (bindingList.Any())
|
{
|
// 批量插入新数据
|
var insertedIds = Db.Insertable(bindingList).PageSize(1)
|
.IgnoreColumnsNull()
|
.ExecuteCommand();
|
insertedCount = insertedIds;
|
}
|
}
|
catch (Exception ex)
|
{
|
throw new Exception($"插入栈板绑定数据失败: {ex.Message}");
|
}
|
|
return insertedCount;
|
}
|
|
/// <summary>
|
/// 检查栈板码在数据库中是否存在
|
/// </summary>
|
/// <param name="stackCode">栈板码</param>
|
/// <returns>存在返回true，否则返回false</returns>
|
public bool CheckStackCodeExists(string stackCode)
|
{
|
try
|
{
|
if (string.IsNullOrEmpty(stackCode))
|
{
|
return false;
|
}
|
|
// 查询MES_PALLET_BINDING表中是否存在该栈板码的数据
|
var exists = Db.Queryable<MesPalletBinding1>()
|
.Any(x => x.Stackcode == stackCode);
|
|
return exists;
|
}
|
catch (Exception ex)
|
{
|
throw new Exception($"检查栈板码是否存在时出错: {ex.Message}");
|
}
|
}
|
|
/// <summary>
|
/// 将接口返回的数据插入到数据库中（带存在性检查）
|
/// </summary>
|
/// <param name="palletBinding">栈板绑定信息</param>
|
/// <returns>操作结果</returns>
|
public async Task<int> InsertPalletBindingDataWithCheckAsync(MesPalletBinding palletBinding)
|
{
|
// 先检查栈板码是否存在
|
bool exists = CheckStackCodeExists(palletBinding.StackCode);
|
return exists ? 1 :
|
// 调用原来的插入方法
|
InsertPalletBindingData(palletBinding);
|
}
|
|
/// <summary>
|
/// 根据栈板码删除旧数据
|
/// </summary>
|
/// <param name="stackCode">栈板码</param>
|
/// <returns>删除记录数</returns>
|
private async Task<int> DeleteByStackCodeAsync(string stackCode)
|
{
|
try
|
{
|
var deleteResult = await Db.Deleteable<MesPalletBinding1>()
|
.Where(x => x.Stackcode == stackCode)
|
.ExecuteCommandAsync();
|
return deleteResult;
|
}
|
catch (Exception ex)
|
{
|
// 记录错误但不抛出异常，允许插入操作继续
|
Console.WriteLine($"删除旧数据时出错: {ex.Message}");
|
return 0;
|
}
|
}
|
}
|
