1.生产退库后台

南骏 池

2025-04-21 f53ddc0903c524e50959aeabfb6b93a6098fec8c

1.生产退库后台

 Controllers/Warehouse/MesSctkController.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,235 @@
using System.Dynamic;
using MES.Service.Models;
using Microsoft.AspNetCore.Mvc;
using NewPdaSqlServer.Dto.service;
using NewPdaSqlServer.entity;
using NewPdaSqlServer.service.Warehouse;
using NewPdaSqlServer.util;

namespace NewPdaSqlServer.Controllers.Warehouse;

[ApiController]
[Route("api/[controller]")]
public class MesSctkController : ControllerBase
{
    private readonly MesSctkManager m = new();


    /// <summary>
    ///     èŽ·å–所有已经审核的申请单
    /// </summary>
    /// <returns></returns>
    [HttpPost("GetMesSctkSq")]
    public ResponseResult GetMesSctkSq()
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            resultInfos.tbBillList = m.GetMesSctkSq();
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     èŽ·å–所有已经审核的申请单
    /// </summary>
    /// <returns></returns>
    [HttpPost("GetSumItem")]
    public ResponseResult GetSumItem(WarehouseQuery query)
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            resultInfos.tbBillList = m.GetSumItem(query);
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    //ScanCode
    /// <summary>
    ///     èŽ·å–所有已经审核的申请单
    /// </summary>
    /// <returns></returns>
    [HttpPost("ScanCode")]
    public ResponseResult ScanCode(WarehouseQuery query)
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            resultInfos.tbBillList = m.ScanCode(query);
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     èŽ·å–所有
    /// </summary>
    /// <returns></returns>
    [HttpPost("GetList")]
    public ResponseResult GetList()
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            resultInfos.tbBillList = m.GetList();
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }


    /// <summary>
    ///     æ ¹æ®ä¸»é”®èŽ·å–
    /// </summary>
    /// <returns></returns>
    [HttpPost("GetById")]
    public ResponseResult GetById(int id)
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            resultInfos.tbBillList = m.GetById(id);
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     æ ¹æ®ä¸»é”®åˆ é™¤
    /// </summary>
    /// <returns></returns>
    [HttpPost("DeleteByIds")]
    public ResponseResult DeleteByIds([FromBody] object[] ids)
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            resultInfos.tbBillList = m.DeleteByIds(ids);
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     æ·»åŠ 
    /// </summary>
    /// <returns></returns>
    [HttpPost("Insert")]
    public ResponseResult Add([FromBody] MesScthSq data)
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            resultInfos.tbBillList = m.Insert(data);
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     æ·»åŠ è¿”回自增
    /// </summary>
    /// <returns></returns>
    [HttpPost("InsertReturnIdentity")]
    public ResponseResult InsertReturnIdentity([FromBody] MesScthSq data)
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            resultInfos.tbBillList = m.InsertReturnIdentity(data);
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     ä¿®æ”¹
    /// </summary>
    /// <returns></returns>
    [HttpPost("Update")]
    public ResponseResult Update([FromBody] MesScthSq data)
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            resultInfos.tbBillList = m.Update(data);
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }
}

 entity/MesScthSq.cs

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

namespace MES.Service.Models;

/// <summary>
/// ç”Ÿäº§é€€è´§è¡¨å®žä½“ç±»
/// </summary>
[SugarTable("MES_SCTH_SQ")]
public class MesScthSq
{
    /// <summary>
    /// ä¸»é”®guid
    /// </summary>
    [SugarColumn(ColumnName = "ID")]
    public string Id { get; set; } // ä½¿ç”¨string类型来存储uniqueidentifier

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

    /// <summary>
    /// å»ºç«‹è€…
    /// </summary>
    [SugarColumn(ColumnName = "CREATE_BY")]
    public string CreateBy { get; set; }

    /// <summary>
    /// å»ºç«‹æ—¶é—´
    /// </summary>
    [SugarColumn(ColumnName = "CREATE_DATE")]
    public DateTime? CreateDate { get; set; }

    /// <summary>
    /// æ›´æ–°è€…
    /// </summary>
    [SugarColumn(ColumnName = "LAST_UPDATE_USER")]
    public string LastUpdateUser { get; set; }

    /// <summary>
    /// æ›´æ–°æ—¶é—´
    /// </summary>
    [SugarColumn(ColumnName = "LAST_UPDATE_TIME")]
    public DateTime? LastUpdateTime { get; set; }

    /// <summary>
    /// å®¡æ ¸è€…
    /// </summary>
    [SugarColumn(ColumnName = "CHECK_USER")]
    public string CheckUser { get; set; }

    /// <summary>
    /// å®¡æ ¸æ—¶é—´
    /// </summary>
    [SugarColumn(ColumnName = "CHECK_DATE")]
    public DateTime? CheckDate { get; set; }

    /// <summary>
    /// çŠ¶æ€
    /// </summary>
    [SugarColumn(ColumnName = "STATUS")]
    public bool Status { get; set; }

    /// <summary>
    /// å®Œæˆæ ‡è¯†
    /// </summary>
    [SugarColumn(ColumnName = "IS_FINISH")]
    public bool IsFinish { get; set; }

    /// <summary>
    /// é€€è´§åŽŸå› 
    /// </summary>
    [SugarColumn(ColumnName = "RETURN_TYPE")]
    public string ReturnType { get; set; }

    /// <summary>
    /// ä»“库
    /// </summary>
    [SugarColumn(ColumnName = "DEPOT_ID")]
    public int DepotId { get; set; }

    /// <summary>
    /// ç”³è¯·å¤‡æ³¨
    /// </summary>
    [SugarColumn(ColumnName = "REMARK")]
    public string Remark { get; set; }

    /// <summary>
    /// ç»„织
    /// </summary>
    [SugarColumn(ColumnName = "TH_ORG_ID")]
    public string ThOrgId { get; set; }
}

 entity/MesScthSqDetail.cs

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

namespace MES.Service.Models;

/// <summary>
/// ç”Ÿäº§é€€è´§æ˜Žç»†è¡¨å®žä½“ç±»
/// </summary>
[SugarTable("MES_SCTH_SQ_DETAIL")]
public class MesScthSqDetail
{
    /// <summary>
    /// ä¸»é”®
    /// </summary>
    [SugarColumn(ColumnName = "ID")]
    public string Id { get; set; } // ä½¿ç”¨string类型来存储uniqueidentifier

    /// <summary>
    /// å¤–é”®
    /// </summary>
    [SugarColumn(ColumnName = "MID")]
    public string Mid { get; set; } // ä½¿ç”¨string类型来存储uniqueidentifier

    /// <summary>
    /// ç‰©æ–™Id
    /// </summary>
    [SugarColumn(ColumnName = "ITEM_ID")]
    public int ItemId { get; set; }

    /// <summary>
    /// ç”³è¯·æ•°é‡
    /// </summary>
    [SugarColumn(ColumnName = "SQ_NUM")]
    public decimal SqNum { get; set; }

    /// <summary>
    /// å·²æ‰«æ•°é‡
    /// </summary>
    [SugarColumn(ColumnName = "YS_NUM")]
    public decimal YsNum { get; set; }

    /// <summary>
    /// å¤‡æ³¨
    /// </summary>
    [SugarColumn(ColumnName = "REMARK")]
    public string Remark { get; set; }

    /// <summary>
    /// å®Œç»“
    /// </summary>
    [SugarColumn(ColumnName = "IS_FINISH")]
    public bool IsFinish { get; set; }

    /// <summary>
    /// é¡¹æ¬¡
    /// </summary>
    [SugarColumn(ColumnName = "ORDER_NO")]
    public int OrderNo { get; set; }

    /// <summary>
    /// å…¥åº“GUID
    /// </summary>
    [SugarColumn(ColumnName = "RKMX_GUID")]
    public string RkmxGuid { get; set; } // ä½¿ç”¨string类型来存储uniqueidentifier
}

 service/Warehouse/MesSctkManager.cs

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,119 @@
using System.Data;
using System.Data.SqlClient;
using Masuit.Tools;
using MES.Service.Models;
using NewPdaSqlServer.DB;
using NewPdaSqlServer.Dto.service;
using NewPdaSqlServer.entity;
using NewPdaSqlServer.entity.Base;
using SqlSugar;

namespace NewPdaSqlServer.service.Warehouse;

public class MesSctkManager : Repository<MesScthSq>
{
    public List<MesScthSq> GetMesSctkSq()
    {
        return Db.Queryable<MesScthSq>()
            .Where(s => s.Status == true)
            .OrderByDescending(s => s.CreateDate)
            .ToList();
    }

    public ProductionPickDto GetSumItem(WarehouseQuery query)
    {
        if (string.IsNullOrEmpty(query.billNo)) throw new Exception("申请单号为空");

        var mesInvItemOuts = base.GetSingle(it => it.BillNo == query.billNo);
        if (mesInvItemOuts == null) throw new Exception("采购退货申请单不存在");

        var sql = string.Format(@"SELECT c.item_no ItemNo,c.item_name ItemName,c.item_model ItemModel,A.SQ_NUM FQty,A.YS_NUM SQty,A.SQ_NUM - A.YS_NUM DSQty,
       dbo.F_QX_GETRECODEPOTSE(A.ITEM_ID) as RecoKw
fROM MES_SCTH_SQ_DETAIL A
         LEFT JOIN MES_SCTH_SQ B ON A.MID = B.ID
         LEFT JOIN MES_ITEMS C ON A.ITEM_ID = C.item_id
WHERE B.BILL_NO = '{0}'", query.billNo);

        var womdabs = Db.Ado.SqlQuery<ItemDetailModel>(sql);


        var DS_list = womdabs.Where(s => s.DSQty > 0).ToList();

        var YS_list = womdabs.Where(s => s.SQty > 0).ToList();

        var dto = new ProductionPickDto
        {
            //daa001 = womdaa.Daa001,
            //PlanNo = womcaa.Caa020,
            items = DS_list,
            Ysitems = YS_list
        };

        return dto;
    }


    public ProductionPickDto ScanCode(WarehouseQuery query)
    {
        var _strMsg = "";
        var _intSum = "";
        using (var conn = new SqlConnection(DbHelperSQL.strConn))
        {
            if (query.userName.IsNullOrEmpty()) throw new Exception("用户名不允许为空");
            if (query.billNo.IsNullOrEmpty()) throw new Exception("领料单号不允许为空");
            if (query.barcode.IsNullOrEmpty()) throw new Exception("条码不允许为空");

            using (var cmd = new SqlCommand("[prc_pda_SCTK]", conn))
            {
                try
                {
                    conn.Open();
                    cmd.CommandType = CommandType.StoredProcedure;
                    SqlParameter[] parameters =
                    {
                        new("@outMsg", SqlDbType.NVarChar, 300),
                        new("@outSum", SqlDbType.NVarChar, 300),
                        new("@barcode_num", SqlDbType.NVarChar, 300),
                        new("@split_num", SqlDbType.NVarChar, 300),
                        new("@c_User", query.userName),
                        new("@p_biLL_no", query.billNo),
                        new("@p_item_barcode", query.barcode)
                    };
                    parameters[0].Direction = ParameterDirection.Output;
                    parameters[1].Direction = ParameterDirection.Output;
                    parameters[2].Direction = ParameterDirection.Output;
                    parameters[3].Direction = ParameterDirection.Output;
                    foreach (var parameter in parameters)
                        cmd.Parameters.Add(parameter);
                    cmd.ExecuteNonQuery();
                    _strMsg = parameters[0].Value.ToString();
                    _intSum = parameters[1].Value.ToString();

                    var barcodeNum = parameters[2].Value.ToString();
                    var splitNum = parameters[3].Value.ToString();

                    var result = Convert.ToInt32(_intSum);
                    if (result <= 0) throw new Exception(_strMsg);

                    var dto = new ProductionPickDto
                    {
                        daa001 = query.daa001,
                        barcodeNum = barcodeNum,
                        splitNum = splitNum,
                        barcode = query.barcode
                    };

                    return dto;
                }
                catch (Exception ex)
                {
                    throw new Exception(ex.Message);
                }
                finally
                {
                    conn.Close();
                }
            }
        }
    }
}