You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

316 lines
13 KiB
C#

This file contains ambiguous Unicode characters!

This file contains ambiguous Unicode characters that may be confused with others in your current locale. If your use case is intentional and legitimate, you can safely ignore this warning. Use the Escape button to highlight these characters.

using ibk.IPD.Common;
using ibk.IPD.Entity;
using ibk.IPD.Entity.IPD_MR.HotRoll;
using ibk.IPD.Entity.IPD_MR.HotRoll.QueryArgs;
using log4net;
using SOA.Objects;
using SOA.Persistent;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using System.Web.Http;
/********************************************************
* 简 介:南钢热轧制造规范管理
* 替代宽度限制维护后端接口
* 版本号V1.0
* 日 期2022年05月05日
* 创建者: 李跃升
* Copy Right: 北京科技大学设计研究院有限公司
********************************************************/
namespace ibk.IPD.Controller.IPD_MR.HotRoll
{
[RoutePrefix("ipd/ipdMr")]
public class SubThickLimitController : ApiController
{
private static readonly ILog logger = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
/// <summary>
/// 参数校验
/// </summary>
/// <param name="cncs"></param>
/// /// <param name="result"></param>
/// <returns>是否通过参数校验</returns>
public bool ParameterCalibration(SUBS_THICK_LIMIT cncs, RequestEntity result)
{
#region 参数判断
//因为主键PK是自增数字, 所以不需要添加参数校验
if (string.IsNullOrEmpty(cncs.PLT) || cncs.PLT.Length > 2)
{
result.msg = "工厂代码不可为空且长度不可超过2";
result.code = "0";
return false;
}
if (!string.IsNullOrEmpty(cncs.SLAB_THICK))
if (!CommonUtils.IsNumber(cncs.SLAB_THICK) || cncs.SLAB_THICK.Length > 8)
{
result.msg = "坯料厚度是不可超过8的数字";
result.code = "0";
return false;
}
if (!string.IsNullOrEmpty(cncs.THK_MIN))
if (!CommonUtils.IsNumber(cncs.THK_MIN) || cncs.THK_MIN.Length > 6)
{
result.msg = "轧制厚度最小值是不可超过6的数字";
result.code = "0";
return false;
}
if (!string.IsNullOrEmpty(cncs.THK_MAX))
if (!CommonUtils.IsNumber(cncs.THK_MAX) || cncs.THK_MAX.Length > 6)
{
result.msg = "轧制厚度最大值是不可超过6的数字";
result.code = "0";
return false;
}
return true;
#endregion
}
/// <summary>
/// 获取主键的条件
/// </summary>
/// <param name="primaryKeyEntity"></param>
/// <returns>AND 开头的 主键条件字符串</returns>
public string GetPrimaryKeyString(SUBS_THICK_LIMIT primaryKeyEntity)
{
StringBuilder strSql = new StringBuilder();
//因为主键为自增数字, 所以将执行主键重复查询,改为执行数据重复查询
// PLT , SLAB_THICK , THK_MIN , THK_MAX
strSql.AppendLine(" AND PLT = '" + primaryKeyEntity.PLT + "'");
strSql.AppendLine(" AND SLAB_THICK = '" + primaryKeyEntity.SLAB_THICK + "'");
strSql.AppendLine(" AND THK_MIN = '" + primaryKeyEntity.THK_MIN + "'");
strSql.AppendLine(" AND THK_MAX = '" + primaryKeyEntity.THK_MAX + "'");
strSql.AppendLine(" AND STLGRD = '" + primaryKeyEntity.STLGRD + "'");
return strSql.ToString();
}
/// <summary>
/// 获取主键查询的sql
/// </summary>
/// <param name="checkEntity"></param>
/// <returns>主键查询sql</returns>
public string GetCheckString(SUBS_THICK_LIMIT checkEntity)
{
string strSql = "SELECT * FROM SUBS_THICK_LIMIT WHERE 1=1 " + GetPrimaryKeyString(checkEntity);
return strSql;
}
/// <summary>
/// 查询接口
/// </summary>
/// <param name="queryArgs"></param>
/// <returns></returns>
[HttpPost, Route("hotRoll/getSubThickLimit")]
public RequestEntity GetSubThickLimit(SubsThickLimitQueryArgs queryArgs)
{
RequestEntity result = new RequestEntity(); //声明返回参数实体类
StringBuilder strSql = new StringBuilder(); //声明拼接Sql语句变量
DataTable dtCheck = new DataTable();
//查询字段
//PLT , SLAB_THICK , THK_MIN , THK_MAX
strSql.AppendLine("SELECT PK , PLT , SLAB_THICK , THK_MIN , THK_MAX ,TO_DATE(NVL(INS_DATE, '19910101') || NVL(INS_TIME, '000000'), 'yyyy-mm-dd hh24:mi:ss') as INS_DATE,INS_TIME,INS_EMP , to_date(UPD_DATE || UPD_TIME ,'yyyy-mm-dd hh24:mi:ss') as UPD_DATE, UPD_TIME,UPD_EMP,STLGRD FROM SUBS_THICK_LIMIT WHERE 1 = 1 ");
if (queryArgs != null)
{
if (!string.IsNullOrWhiteSpace(queryArgs.PLT)) strSql.AppendLine(" AND PLT LIKE '%" + queryArgs.PLT + "%'");
if (!string.IsNullOrWhiteSpace(queryArgs.START_SLAB_THICK) && CommonUtils.IsNumber(queryArgs.START_SLAB_THICK)) strSql.AppendLine(" AND SLAB_THICK >=" + queryArgs.START_SLAB_THICK);
if (!string.IsNullOrWhiteSpace(queryArgs.END_SLAB_THICK) && CommonUtils.IsNumber(queryArgs.END_SLAB_THICK)) strSql.AppendLine(" AND SLAB_THICK <=" + queryArgs.END_SLAB_THICK);
if (!string.IsNullOrWhiteSpace(queryArgs.THK_MIN) && CommonUtils.IsNumber(queryArgs.THK_MIN)) strSql.AppendLine(" AND THK_MIN >=" + queryArgs.THK_MIN);
if (!string.IsNullOrWhiteSpace(queryArgs.THK_MAX) && CommonUtils.IsNumber(queryArgs.THK_MAX)) strSql.AppendLine(" AND THK_MAX <=" + queryArgs.THK_MAX);
if (!string.IsNullOrWhiteSpace(CommonUtils.ObjectToStr(queryArgs.START_TIME)) && CommonUtils.ObjectToStr(queryArgs.START_TIME) != "0001/1/1 0:00:00") strSql.AppendLine(" AND to_date(INS_DATE ,'yyyy-mm-dd hh24:mi:ss') >= to_date('" + CommonUtils.ObjectToStr(queryArgs.START_TIME) + "','yyyy-mm-dd hh24:mi:ss')");
if (!string.IsNullOrWhiteSpace(CommonUtils.ObjectToStr(queryArgs.END_TIME)) && CommonUtils.ObjectToStr(queryArgs.END_TIME) != "0001/1/1 0:00:00") strSql.AppendLine(" AND to_date(INS_DATE ,'yyyy-mm-dd hh24:mi:ss') <= to_date('" + CommonUtils.ObjectToStr(queryArgs.END_TIME) + "','yyyy-mm-dd hh24:mi:ss')");
}
try
{
//开启数据库连接查询数据
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
{
strSql.AppendLine("Order By PLT ,SLAB_THICK ");
dtCheck = db.Query(strSql.ToString());
result.data = db.Query<SUBS_THICK_LIMIT>(strSql.ToString());
if (dtCheck.Rows.Count > 0)
{
result.msg = "操作成功!";
result.code = "1";
}
else
{
result.msg = "未找到查询所需数据!";
result.code = "1";
}
}
}
catch (Exception ex)
{
result.msg = "数据库错误!";
result.code = "0";
logger.Error("GetSubThickLimit 报错", ex);
}
return result;
}
/// <summary>
/// 添加接口
/// </summary>
/// <param name="insertModel"></param>
/// <returns></returns>
[HttpPost, Route("hotRoll/addSubThickLimit")]
public RequestEntity AddSubThickLimit(SUBS_THICK_LIMIT insertModel)
{
RequestEntity result = new RequestEntity();
DateTime dtNow = DateTime.Now;
try
{
#region 参数判断
if (!ParameterCalibration(insertModel, result))
return result;
#endregion
insertModel.INS_DATE = dtNow.ToString("yyyyMMdd");
insertModel.INS_TIME = dtNow.ToString("HHmmss");
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
{
// 执行数据重复查询
DataTable dtCheck = db.Query(GetCheckString(insertModel));
if (dtCheck.Rows.Count > 0) // 若数据库中存在则返回错误码0并msg提示用户
{
result.msg = "数据已存在,请确认后重试!";
result.code = "0";
return result;
}
if (db.Insert<SUBS_THICK_LIMIT>(insertModel) > 0)
{
result.msg = "操作成功";
result.code = "1";
}
}
}
catch (Exception ex)
{
result.msg = "数据库错误!";
result.code = "0";
logger.Error("AddSubThickLimit 报错 : ", ex);
}
return result;
}
/// <summary>
/// 更新接口
/// </summary>
/// <param name="requestData"></param>
/// <returns></returns>
[HttpPost, Route("hotRoll/updSubThickLimit")]
public RequestEntity UpdSubThickLimit(IList<SUBS_THICK_LIMIT> requestData)
{
RequestEntity result = new RequestEntity();
DataTable dtCheck = new DataTable();
DataTable dtCheckSelf = new DataTable();
StringBuilder strSql = new StringBuilder();
StringBuilder strSqlSelf = new StringBuilder();
DateTime dtNow = DateTime.Now;
requestData[1].UPD_DATE = dtNow.ToString("yyyyMMdd");
requestData[1].UPD_TIME = dtNow.ToString("HHmmss");
#region 参数判断
if (!ParameterCalibration(requestData[1], result))
return result;
#endregion
try
{
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
{
// 执行主键重复查询
dtCheck = db.Query(GetCheckString(requestData[1]));
dtCheckSelf = db.Query(GetCheckString(requestData[0]));
if (dtCheck.Rows.Count > 0 && !CommonUtils.CompareDataTable(dtCheck, dtCheckSelf)) // 若数据库中存在则返回错误码0并msg提示用户
{
result.msg = "相同数据已存在,请确认后重试!";
result.code = "0";
}
else
{
//更新哪些字段
//PLT , NO , SLAB_THICK , THK_MIN , THK_MAX , SHORT_SIDE_MIN_LEN , SHORT_SIDE_MAX_LEN , LEN_SIDE_MIN_LEN , LEN_SIDE_MAX_LEN
if (db.Execute("UPDATE SUBS_THICK_LIMIT SET " + string.Format(" PLT = '{0}' , SLAB_THICK = '{1}' , THK_MIN = '{2}' ,THK_MAX = '{3}' , UPD_DATE = '{4}' , UPD_TIME='{5}',UPD_EMP = '{6}' ,STLGRD='{7}' WHERE 1 = 1 ",
requestData[1].PLT, requestData[1].SLAB_THICK, requestData[1].THK_MIN, requestData[1].THK_MAX, requestData[1].UPD_DATE, requestData[1].UPD_TIME, requestData[1].UPD_EMP, requestData[1].STLGRD) +
//根据主键字段可以确定唯一数据即要修改的数据
string.Format(" AND PK = {0}", requestData[0].PK)) > 0)
{
result.msg = "操作成功";
result.code = "1";
}
else
{
result.msg = "数据未发生改变,请确认后重试!";
result.code = "0";
}
}
return result;
}
}
catch (Exception ex)
{
result.msg = "数据库错误!";
result.code = "0";
logger.Error("UpdSubThickLimit 报错", ex);
return result;
}
}
/// <summary>
/// 删除接口
/// </summary>
/// <param name="delModel"></param>
/// <returns></returns>
[HttpPost, Route("hotRoll/delSubThickLimit")]
public RequestEntity DelSubThickLimit(SUBS_THICK_LIMIT delModel)
{
RequestEntity result = new RequestEntity();
StringBuilder strSql = new StringBuilder();
try
{
strSql.AppendLine("DELETE FROM SUBS_THICK_LIMIT WHERE 1=1 AND");
strSql.AppendLine(string.Format("PK = {0}", delModel.PK));
using (IDbContext db = ObjectContainer.GetObject<IDbContext>("db"))
{
db.Execute(strSql.ToString()); // 执行删除数据操作
result.msg = "操作成功";
result.code = "1";
}
}
catch (Exception ex)
{
result.msg = "数据库错误!";
result.code = "0";
logger.Error("DelSubThickLimit 报错", ex);
}
return result;
}
}
}