111

tjx

2025-12-05 e2778527b8db64879a5080a64669e5dd9ab016d2

111

 StandardPda/MES.Service/Dto/service/GetTransferListResponse.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,25 @@
using System.Collections.Generic;

namespace MES.Service.Dto.service
{
    public class GetTransferListResponse
    {
        public int Code { get; set; }
        public string Msg { get; set; }
        public TransferListData Data { get; set; }
    }

    public class TransferListData
    {
        public string StackCode { get; set; }
        public List<SnItem> SnList { get; set; }
    }

    public class SnItem
    {
        public string SnNo { get; set; }
        public string TickeNo { get; set; }
        public string SnStatus { get; set; }
        public string MediumBoxCode { get; set; }
    }
}

 StandardPda/MES.Service/Modes/MesPalletBinding1.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,96 @@
using SqlSugar;

namespace MES.Service.Modes;

/// <summary>
///     æ ˆæ¿ç»‘定信息表
/// </summary>
[SugarTable("MES_PALLET_BINDING")]
public class MesPalletBinding1
{
    /// <summary>
    ///     ä¸»é”®ID
    /// </summary>
    [SugarColumn(ColumnName = "ID",
        OracleSequenceName = "SEQ_MES_PALLET_BINDING_ID",
        IsPrimaryKey = true)]
    public decimal Id { get; set; }

    /// <summary>
    ///     æ ˆæ¿ç 
    /// </summary>
    [SugarColumn(ColumnName = "STACKCODE")]
    public string Stackcode { get; set; }

    /// <summary>
    ///     ç™»å½•å·
    /// </summary>
    [SugarColumn(ColumnName = "LOGIN_ID")]
    public string LoginId { get; set; }

    /// <summary>
    ///     SN号
    /// </summary>
    [SugarColumn(ColumnName = "SN_NO")]
    public string SnNo { get; set; }

    /// <summary>
    ///     å·¥å•å•å·
    /// </summary>
    [SugarColumn(ColumnName = "TICKET_NO")]
    public string TicketNo { get; set; }

    /// <summary>
    ///     ä¸­ç®±ç 
    /// </summary>
    [SugarColumn(ColumnName = "MEDIUMBOXCODE")]
    public string Mediumboxcode { get; set; }

    /// <summary>
    ///     åˆ›å»ºæ—¶é—´(解绑时间)
    /// </summary>
    [SugarColumn(ColumnName = "CREATE_DATE")]
    public DateTime? CreateDate { get; set; }

    /// <summary>
    ///     åˆ›å»ºäºº
    /// </summary>
    [SugarColumn(ColumnName = "CREATED_BY")]
    public string CreatedBy { get; set; }

    /// <summary>
    ///     å…¥åº“标识：0-未入库，1-已入库，2-已销售出库，默认0
    /// </summary>
    [SugarColumn(ColumnName = "IS_INBOUND")]
    public decimal IsInbound { get; set; }

    /// <summary>
    ///     å…¥åº“时间
    /// </summary>
    [SugarColumn(ColumnName = "INBOUND_TIME")]
    public DateTime? InboundTime { get; set; }

    /// <summary>
    ///     äº§æµ‹æ ˆæ¿ç»‘定时间(接口TransitTime)
    /// </summary>
    [SugarColumn(ColumnName = "BIND_TRANSIT_TIME")]
    public DateTime? BindTransitTime { get; set; }

    /// <summary>
    ///     çº¿ä½“编码
    /// </summary>
    [SugarColumn(ColumnName = "LINE_NO")]
    public string LineNo { get; set; }

    /// <summary>
    ///     å…¥åº“单号
    /// </summary>
    [SugarColumn(ColumnName = "RK_NO")]
    public string RkNo { get; set; }

    /// <summary>
    ///     å…¥åº“条码
    /// </summary>
    [SugarColumn(ColumnName ="RK_CODE")]
    public string RkCode { get; set; }
}

 StandardPda/MES.Service/service/Warehouse/MesPalletBinding1Manager.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,166 @@
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;
        }
    }
}

 StandardPda/MESApplication/Controllers/Warehouse/MesPalletBinding1Controller.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,113 @@
using MES.Service.Dto.service;
using MES.Service.Modes;
using MES.Service.service;
using MES.Service.service.Warehouse;
using MES.Service.util;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;

namespace MESApplication.Controllers.Warehouse
{
    [ApiController]
    [Route("api/[controller]")]
    public class MesPalletBinding1Controller : ControllerBase
    {
        private readonly MessageCenterManager _manager = new();
        private readonly MesPalletBinding1Manager m = new();
        private readonly string METHOD = "POST";
        private readonly string TableName = "mespalletbinding1";

        private readonly string URL =
            "http://localhost:10054/api/mespalletbinding1/";

        /// <summary>
        /// ä»Žå¤–部接口获取栈板绑定信息并保存到数据库
        /// </summary>
        /// <param name="palletBinding">栈板绑定信息</param>
        /// <returns></returns>
        [HttpPost("SavePalletBindingData")]
        public ResponseResult SavePalletBindingData([FromBody] MesPalletBinding palletBinding)
        {
            try
            {
                // è°ƒç”¨ä¸šåŠ¡é€»è¾‘层方法将数据保存到数据库
                int insertedCount = m.InsertPalletBindingData(palletBinding);

                if (insertedCount > 0)
                {
                    return new ResponseResult
                    {
                        status = 0,
                        message = $"成功插入 {insertedCount} æ¡æ ˆæ¿ç»‘定数据",
                        data = insertedCount
                    };
                }
                else
                {
                    return new ResponseResult
                    {
                        status = 1,
                        message = "未插入任何数据，可能是因为接口返回的数据为空",
                        data = null
                    };
                }
            }
            catch (Exception ex)
            {
                return ResponseResult.ResponseError(ex);
            }
        }

        /// <summary>
        /// æ£€æŸ¥æ ˆæ¿ç åœ¨æ•°æ®åº“中是否存在
        /// </summary>
        /// <param name="stackCode">栈板码</param>
        /// <returns></returns>
        [HttpPost("CheckStackCodeExists")]
        public ResponseResult CheckStackCodeExists([FromBody] dynamic request)
        {
            try
            {
                string stackCode = request.stackCode;
                bool exists = m.CheckStackCodeExists(stackCode);

                return new ResponseResult
                {
                    status = 0,
                    message = exists ? "栈板码已存在" : "栈板码不存在",
                    data = exists
                };
            }
            catch (Exception ex)
            {
                return ResponseResult.ResponseError(ex);
            }
        }

        /// <summary>
        /// ä»Žå¤–部接口获取栈板绑定信息并保存到数据库（带存在性检查）
        /// </summary>
        /// <param name="palletBinding">栈板绑定信息</param>
        /// <returns></returns>
        [HttpPost("SavePalletBindingDataWithCheck")]
        public async Task<ResponseResult> SavePalletBindingDataWithCheck([FromBody] MesPalletBinding palletBinding)
        {
            try
            {
                // è°ƒç”¨ä¸šåŠ¡é€»è¾‘层方法将数据保存到数据库（带存在性检查）
                int result = await m.InsertPalletBindingDataWithCheckAsync(palletBinding);

                return new ResponseResult
                {
                    status = 0,
                    message = result > 0 ? $"成功处理 {result} æ¡æ ˆæ¿ç»‘定数据" : "未处理任何数据，可能是因为接口返回的数据为空",
                    data = result
                };
            }
            catch (Exception ex)
            {
                return ResponseResult.ResponseError(ex);
            }
        }
    }
}