文件补充

cnf

2025-09-10 1b3db8f5683373dd8e179b006e7314783dd1f9db

 WebApi/Gs.Wom/WorkService/WorkProController.cs

@@ -13,8 +13,8 @@
using static Gs.Toolbox.UtilityHelper;


namespace Gs.Wom.WorkService;

namespace Gs.Wom.WorkService
{
[ApiGroup(ApiGroupNames.BaseInfo)]
public class WorkProController : IRomteService
{
@@ -30,7 +30,6 @@
    }

    #region

    /// <summary>
    ///     读取列表，支持分页
    /// </summary>
@@ -39,6 +38,9 @@
    [RequestMethod(RequestMethods.POST)]
    public ReturnDto<PageList<dynamic>> GetListPage([FromBody] PageQuery model)
    {

            //(case a.isStatus when 1 then '正常' when - 1 then  '禁用'  else cast(a.isStatus as nvarchar(4))  end) as isStatusTxt

        var currentPage = model.currentPage;
        var everyPageSize = model.everyPageSize;
        var sortName = string.IsNullOrEmpty(model.sortName)
@@ -50,7 +52,7 @@
        sbSql.Append("( ");
        sbSql.Append("select top 100000 ROW_NUMBER() over(order by " +
                     sortName + " " + model.sortOrder +
                     ") as rowIndex,cast(0 as bit) as chkInt,a.*,(a.processNo+':'+a.processName) as processNoAndName,(case  a.isStatus when 1 then '正常' when -1 then  '禁用'  else  cast(a.isStatus as nvarchar(4))  end) as isStatusTxt from WORK_PROCESS a  where 1=1" +
                         ") as rowIndex,cast(0 as bit) as chkInt,  a.*,(a.PROC_NO+':'+a.PROC_NAME) as processNoAndName from MES_PROC_INFO a  where 1=1" +
                     keyWhere);
        sbSql.Append(") as T ");
        sbSql.Append(" where T.rowindex>(" + currentPage + "-1)*" +
@@ -58,7 +60,7 @@
                     everyPageSize);
        sbSql.Append(" order by rowindex asc ");
        sbSql.Append(
            " select count(1) as intTotal  from WORK_PROCESS a  where 1=1 " +
                " select count(1) as intTotal  from MES_PROC_INFO a  where 1=1 " +
            keyWhere);
        var dset = new DataSet();
        try
@@ -68,10 +70,8 @@
        catch (Exception ex)
        {
            LogHelper.Debug(ToString(), "GetListPage error：" + ex.Message);
            return ReturnDto<PageList<dynamic>>.QuickReturn(
                default(PageList<dynamic>), ReturnCode.Exception, ex.Message);
                return ReturnDto<PageList<dynamic>>.QuickReturn(default(PageList<dynamic>), ReturnCode.Exception, ex.Message);
        }

        var _pglist = new PageList<dynamic>
        {
            total = 0,
@@ -93,10 +93,10 @@
            var _dy = dset.Tables[0].TableToDynamicList();
            _pglist.list = _dy;
        }

        return ReturnDto<PageList<dynamic>>.QuickReturn(_pglist,
            ReturnCode.Success, "读取成功");
    }



    /// <summary>
@@ -107,14 +107,13 @@
    [RequestMethod(RequestMethods.POST)]
    public ReturnDto<int?> DeleteModel([FromBody] JArray guidList)
    {
        var intArray = guidList.ToObject<string[]>();
        var sbGuid = new StringBuilder();
        foreach (var val in intArray)
            string[] intArray = guidList.ToObject<string[]>();
            System.Text.StringBuilder sbGuid = new StringBuilder();
            foreach (string val in intArray)
        {
            if (sbGuid.Length > 0) sbGuid.Append(", ");
            sbGuid.Append(val);
        }

        var rtnInt = (int)ReturnCode.Default;
        var cont = 0;
        try
@@ -123,10 +122,9 @@
            if (cont > 0)
                return ReturnDto<int>.QuickReturn(default(int?),
                    ReturnCode.Exception, "删除失败，该信息已被审核！");
            var sbSql = new StringBuilder();
            sbSql.Append("delete from WORK_PROCESS ");
            sbSql.Append(" where guid in (select line from dbo.fn_split('" +
                         sbGuid + "',','))");
                System.Text.StringBuilder sbSql = new StringBuilder();
                sbSql.Append("delete from MES_PROC_INFO ");
                sbSql.Append(" where guid in (select line from dbo.fn_split('" + sbGuid.ToString() + "',','))");
            var rows = DbHelperSQL.ExecuteSql(sbSql.ToString());
            rtnInt = rows;
        }
@@ -137,7 +135,6 @@
            return ReturnDto<int>.QuickReturn(default(int?),
                ReturnCode.Exception, "删除失败，" + ex.Message);
        }

        if (rtnInt > 0)
            return ReturnDto<int>.QuickReturn(default(int?), ReturnCode.Success,
                "操作成功，共删除" + rtnInt + "条数据！");
@@ -159,30 +156,19 @@
        string remark = model.remark;
        string isBack = model.isBack;
        string isStatus = model.isStatus;
        string isZsm = model.isZsm;
        string isTbm = model.isTbm;
        string description = model.description;
        int? rtnInt = (int)ReturnCode.Default;
        var sbSql = new StringBuilder();
            System.Text.StringBuilder sbSql = new StringBuilder();
        if (!CheckGuid(guid))
        {
            guid = Guid.NewGuid().ToString();
            sbSql.Append(
                "INSERT INTO [dbo].[WORK_PROCESS] ([guid] ,[processNo] ,[processName] ,[remark] ,[isBack] ,[isStatus] ,[description] ,[createBy] ,[createDate] ,[lastUpdateBy] ,[lastUpdateDate],isZsm,isTbm)");
            sbSql.Append(" values( '" + guid +
                         "',@processNo,@processName,@remark,@isBack,@isStatus,@description,'" +
                         _userCode + "',getdate(),'" + _userCode +
                         "',getdate(),@isZsm,@isTbm)");
                sbSql.Append("INSERT INTO [dbo].[WORK_PROCESS] ([guid] ,[processNo] ,[processName] ,[remark] ,[isBack] ,[isStatus] ,[description] ,[createBy] ,[createDate] ,[lastUpdateBy] ,[lastUpdateDate])");
                sbSql.Append(" values( '"+ guid + "',@processNo,@processName,@remark,@isBack,@isStatus,@description,'" + _userCode + "',getdate(),'" + _userCode + "',getdate())");
        }
        else
        {
            sbSql.Append(
                "UPDATE [dbo].[WORK_PROCESS]  SET [processNo] =@processNo,[processName] =@processName,[remark] =@remark,[isBack] =@isBack,[isStatus] =@isStatus,[description] =@description,[lastUpdateBy] ='" +
                _userCode +
                "',[lastUpdateDate] =getdate(),isZsm=@isZsm,isTbm=@isTbm where guid='" +
                guid + "'");
                sbSql.Append("UPDATE [dbo].[WORK_PROCESS]  SET [processNo] =@processNo,[processName] =@processName,[remark] =@remark,[isBack] =@isBack,[isStatus] =@isStatus,[description] =@description,[lastUpdateBy] ='" + _userCode + "',[lastUpdateDate] =getdate() where guid='"+guid.ToString()+"'");
        }

        SqlParameter[] parameters =
        {
            new("@processNo", processNo),
@@ -191,8 +177,6 @@
            new("@isBack", isBack),
            new("@isStatus", isStatus),
            new("@description", description),
            new("@isZsm", isZsm),
            new("@isTbm", isTbm)
        };
        try
        {
@@ -202,15 +186,12 @@
        {
            LogHelper.Debug(ToString(), "EditModel error：" + ex.Message);
            rtnInt = (int)ReturnCode.Exception;
            return ReturnDto<string>.QuickReturn("", ReturnCode.Exception,
                ex.Message);
                return ReturnDto<string>.QuickReturn("", ReturnCode.Exception, ex.Message);
        }

        if (rtnInt > 0)
            return ReturnDto<string>.QuickReturn(guid, ReturnCode.Success,
                "操作成功！");
        return ReturnDto<string>.QuickReturn("", ReturnCode.Exception,
            "增加失败，请重试！");
                return ReturnDto<string>.QuickReturn(guid, ReturnCode.Success, "操作成功！");
            return ReturnDto<string>.QuickReturn("", ReturnCode.Exception, "增加失败，请重试！");
    }

    /// <summary>
@@ -238,7 +219,6 @@
                return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Success,
                    "读取成功！");
            }

            return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default,
                "读取失败！");
        }
@@ -259,6 +239,6 @@
        //    .ToString());
        return cont;
    }

    #endregion
}
}