using MES.Service.Dto.webApi.RealTimeInventory;
|
|
namespace MESApplication.Controllers.RealTimeInventory;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.Extensions.Configuration;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using Oracle.ManagedDataAccess.Client;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.IO;
|
using System.Net;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
[Route("api/[controller]")]
|
[ApiController]
|
|
public class RealTimeInventoryController : ControllerBase
|
{
|
private readonly string _connectionString;
|
private readonly string _baseUrl = "http://122.227.249.70:5050/k3cloud";
|
|
public RealTimeInventoryController(IConfiguration configuration)
|
{
|
_connectionString = configuration["AppSettings:DataBaseConn"];
|
}
|
|
[HttpPost("syncInventory")]
|
public async Task<IActionResult> SyncInventory()
|
{
|
HttpClientEx httpClient = new HttpClientEx();
|
httpClient.Url = $"{_baseUrl}/Kingdee.BOS.WebApi.ServicesStub.AuthService.ValidateUser.common.kdsvc";
|
|
var parameters = new List<object>
|
{
|
"6654201b47f099", // 帐套Id
|
"Administrator", // 用户名
|
"Lts88666*", // 密码
|
2052 // 语言（中文）
|
};
|
|
httpClient.Content = JsonConvert.SerializeObject(parameters);
|
var result = JObject.Parse(httpClient.AsyncRequest())["LoginResultType"].Value<int>();
|
|
if (result != 1)
|
return BadRequest("登录失败");
|
|
List<string> depotCodes = FetchDepotCodes();
|
if (depotCodes.Count == 0)
|
return NotFound("未找到有效的DEPOTS_CODE");
|
|
DeleteInventoryData();
|
|
string depotCodesStr = string.Join(",", depotCodes);
|
bool hasMoreData = true;
|
int pageIndex = 1;
|
|
while (hasMoreData)
|
{
|
InventoryParamModel model = new InventoryParamModel
|
{
|
fstocknumbers = depotCodesStr,
|
isshowauxprop = true,
|
isshowstockloc = true,
|
pageindex = pageIndex,
|
pagerows = 10000
|
};
|
|
httpClient.Url = $"{_baseUrl}/Kingdee.K3.SCM.WebApi.ServicesStub.InventoryQueryService.GetInventoryData.common.kdsvc";
|
httpClient.Content = JsonConvert.SerializeObject(new List<object> { model });
|
string response = httpClient.AsyncRequest();
|
var inventoryData = JsonConvert.DeserializeObject<InventoryResponse>(response);
|
|
if (inventoryData?.Data == null || inventoryData.Data.Count == 0)
|
hasMoreData = false;
|
else
|
{
|
InsertInventoryData(inventoryData);
|
pageIndex++;
|
}
|
}
|
|
return Ok("库存数据导入完成");
|
}
|
|
private List<string> FetchDepotCodes()
|
{
|
List<string> depotCodes = new List<string>();
|
using (var connection = new OracleConnection(_connectionString))
|
{
|
try
|
{
|
connection.Open();
|
string query = "SELECT DEPOTS_CODE FROM MES_INV_ITEM_STOCKS WHERE DEPOTS_CODE IS NOT NULL AND DEPOTS_CODE NOT IN ('MJ','CY-MJ') GROUP BY DEPOTS_CODE";
|
using (var cmd = new OracleCommand(query, connection))
|
using (var reader = cmd.ExecuteReader())
|
{
|
while (reader.Read())
|
depotCodes.Add(reader.GetString(0));
|
}
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine("获取仓库代码时出错: " + ex.Message);
|
}
|
}
|
return depotCodes;
|
}
|
|
private void DeleteInventoryData()
|
{
|
using (var connection = new OracleConnection(_connectionString))
|
{
|
try
|
{
|
connection.Open();
|
using (var transaction = connection.BeginTransaction())
|
{
|
using (var deleteCmd = new OracleCommand("DELETE FROM ERPKCPC", connection))
|
{
|
deleteCmd.ExecuteNonQuery();
|
}
|
transaction.Commit();
|
}
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine("删除库存数据时出错: " + ex.Message);
|
}
|
}
|
}
|
|
private void InsertInventoryData(InventoryResponse inventoryData)
|
{
|
using (var connection = new OracleConnection(_connectionString))
|
{
|
try
|
{
|
connection.Open();
|
using (var transaction = connection.BeginTransaction())
|
{
|
foreach (var item in inventoryData.Data)
|
{
|
string query = "INSERT INTO ERPKCPC (ITEM_ID, DEPOT_CODE, FQTY, ITEM_NO, ORGID) VALUES (:ITEM_ID, :DEPOT_CODE, :FQTY, :ITEM_NO, :ORGID)";
|
using (var cmd = new OracleCommand(query, connection))
|
{
|
cmd.Parameters.Add(new OracleParameter(":ITEM_ID", item.FmaterialId));
|
cmd.Parameters.Add(new OracleParameter(":DEPOT_CODE", item.FstockNumber));
|
cmd.Parameters.Add(new OracleParameter(":FQTY", item.Fqty));
|
cmd.Parameters.Add(new OracleParameter(":ITEM_NO", item.FmaterialNumber));
|
cmd.Parameters.Add(new OracleParameter(":ORGID", item.FstockorgId));
|
|
try
|
{
|
cmd.ExecuteNonQuery();
|
}
|
catch (Exception ex)
|
{
|
transaction.Rollback();
|
Console.WriteLine("插入库存数据时出错: " + ex.Message);
|
return;
|
}
|
}
|
}
|
transaction.Commit();
|
}
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine("数据库连接出错: " + ex.Message);
|
}
|
}
|
}
|
}
|
