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.

360 lines
17 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年04月25日
* 创建者: 李跃升
* Copy Right: 北京科技大学设计研究院有限公司
********************************************************/
namespace ibk.IPD.Controller.IPD_MR.HotRoll
{
[RoutePrefix("ipd/ipdMr")]
public class SlabDefinitionController : 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(MILL_PLT_SLAB 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.NO))
if (cncs.NO.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;
}
if (string.IsNullOrEmpty(cncs.SHORT_SIDE_MIN_LEN) || !CommonUtils.IsNumber(cncs.SHORT_SIDE_MIN_LEN) || cncs.SHORT_SIDE_MIN_LEN.Length > 6)
{
result.msg = "坯料短边最小长度是不可为空且长度不可超过6的数字";
result.code = "0";
return false;
}
if (string.IsNullOrEmpty(cncs.SHORT_SIDE_MAX_LEN) || !CommonUtils.IsNumber(cncs.SHORT_SIDE_MAX_LEN) || cncs.SHORT_SIDE_MAX_LEN.Length > 6)
{
result.msg = "坯料短边最大长度是不可为空且长度不可超过6的数字";
result.code = "0";
return false;
}
if (string.IsNullOrEmpty(cncs.LEN_SIDE_MIN_LEN) || !CommonUtils.IsNumber(cncs.LEN_SIDE_MIN_LEN) || cncs.LEN_SIDE_MIN_LEN.Length > 6)
{
result.msg = "坯料长边最小长度是不可为空且长度不可超过6的数字";
result.code = "0";
return false;
}
if (string.IsNullOrEmpty(cncs.LEN_SIDE_MAX_LEN) || !CommonUtils.IsNumber(cncs.LEN_SIDE_MAX_LEN) || cncs.LEN_SIDE_MAX_LEN.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(MILL_PLT_SLAB primaryKeyEntity)
{
StringBuilder strSql = new StringBuilder();
//因为主键为自增数字, 所以将执行主键重复查询,改为执行数据重复查询
// PLT , NO , SLAB_THICK , THK_MIN , THK_MAX , SHORT_SIDE_MIN_LEN , SHORT_SIDE_MAX_LEN , LEN_SIDE_MIN_LEN , LEN_SIDE_MAX_LEN
strSql.AppendLine(" AND PLT = '" + primaryKeyEntity.PLT + "'");
strSql.AppendLine(" AND NO = '" + primaryKeyEntity.NO + "'");
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 SHORT_SIDE_MIN_LEN = '" + primaryKeyEntity.SHORT_SIDE_MIN_LEN + "'");
strSql.AppendLine(" AND SHORT_SIDE_MAX_LEN = '" + primaryKeyEntity.SHORT_SIDE_MAX_LEN + "'");
strSql.AppendLine(" AND LEN_SIDE_MIN_LEN = '" + primaryKeyEntity.LEN_SIDE_MIN_LEN + "'");
strSql.AppendLine(" AND LEN_SIDE_MAX_LEN = '" + primaryKeyEntity.LEN_SIDE_MAX_LEN + "'");
return strSql.ToString();
}
/// <summary>
/// 获取主键查询的sql
/// </summary>
/// <param name="checkEntity"></param>
/// <returns>主键查询sql</returns>
public string GetCheckString(MILL_PLT_SLAB checkEntity)
{
string strSql = "SELECT PLT , NO , SLAB_THICK , THK_MIN , THK_MAX , SHORT_SIDE_MIN_LEN , SHORT_SIDE_MAX_LEN , LEN_SIDE_MIN_LEN , LEN_SIDE_MAX_LEN FROM MILL_PLT_SLAB WHERE 1=1 " + GetPrimaryKeyString(checkEntity);
return strSql;
}
/// <summary>
/// 查询接口
/// </summary>
/// <param name="queryArgs"></param>
/// <returns></returns>
[HttpPost, Route("hotRoll/getSlabDefinition")]
public RequestEntity GetBlankDefinition(MillPltSlabQueryArgs queryArgs)
{
RequestEntity result = new RequestEntity(); //声明返回参数实体类
StringBuilder strSql = new StringBuilder(); //声明拼接Sql语句变量
DataTable dtCheck = new DataTable();
//查询字段
//PLT , NO , SLAB_THICK , THK_MIN , THK_MAX , SHORT_SIDE_MIN_LEN , SHORT_SIDE_MAX_LEN , LEN_SIDE_MIN_LEN , LEN_SIDE_MAX_LEN
strSql.AppendLine("SELECT PK , PLT , NO , SLAB_THICK , THK_MIN , THK_MAX , SHORT_SIDE_MIN_LEN , SHORT_SIDE_MAX_LEN , LEN_SIDE_MIN_LEN , LEN_SIDE_MAX_LEN ,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 FROM MILL_PLT_SLAB WHERE 1 = 1 ");
if (queryArgs != null)
{
if (!string.IsNullOrWhiteSpace(queryArgs.PLT)) strSql.AppendLine(" AND PLT LIKE '%" + queryArgs.PLT + "%'");
if (!string.IsNullOrWhiteSpace(queryArgs.NO)) strSql.AppendLine(" AND NO LIKE '%" + queryArgs.NO + "%'");
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(queryArgs.SHORT_SIDE_MIN_LEN) && CommonUtils.IsNumber(queryArgs.SHORT_SIDE_MIN_LEN)) strSql.AppendLine(" AND SHORT_SIDE_MIN_LEN >=" + queryArgs.SHORT_SIDE_MIN_LEN);
if (!string.IsNullOrWhiteSpace(queryArgs.SHORT_SIDE_MAX_LEN) && CommonUtils.IsNumber(queryArgs.SHORT_SIDE_MAX_LEN)) strSql.AppendLine(" AND SHORT_SIDE_MAX_LEN <=" + queryArgs.SHORT_SIDE_MAX_LEN);
if (!string.IsNullOrWhiteSpace(queryArgs.LEN_SIDE_MIN_LEN) && CommonUtils.IsNumber(queryArgs.LEN_SIDE_MIN_LEN)) strSql.AppendLine(" AND LEN_SIDE_MIN_LEN >=" + queryArgs.LEN_SIDE_MIN_LEN);
if (!string.IsNullOrWhiteSpace(queryArgs.LEN_SIDE_MAX_LEN) && CommonUtils.IsNumber(queryArgs.LEN_SIDE_MAX_LEN)) strSql.AppendLine(" AND LEN_SIDE_MAX_LEN <=" + queryArgs.LEN_SIDE_MAX_LEN);
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 ");
dtCheck = db.Query(strSql.ToString());
result.data = db.Query<MILL_PLT_SLAB>(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("GetBlankDefinition 报错", ex);
}
return result;
}
/// <summary>
/// 添加接口
/// </summary>
/// <param name="insertModel"></param>
/// <returns></returns>
[HttpPost, Route("hotRoll/addSlabDefinition")]
public RequestEntity AddBlankDefinition(MILL_PLT_SLAB 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<MILL_PLT_SLAB>(insertModel) > 0)
{
result.msg = "操作成功";
result.code = "1";
}
}
}
catch (Exception ex)
{
result.msg = "数据库错误!";
result.code = "0";
logger.Error("AddBlankDefinition 报错 : ", ex);
}
return result;
}
/// <summary>
/// 更新接口
/// </summary>
/// <param name="requestData"></param>
/// <returns></returns>
[HttpPost, Route("hotRoll/updSlabDefinition")]
public RequestEntity UpdBlankDefinition(IList<MILL_PLT_SLAB> 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 MILL_PLT_SLAB SET " + string.Format(" PLT = '{0}' , NO = '{1}' , SLAB_THICK = '{2}' , THK_MIN = '{3}' ,THK_MAX = '{4}' ,SHORT_SIDE_MIN_LEN = '{5}' ,SHORT_SIDE_MAX_LEN = '{6}' ,LEN_SIDE_MIN_LEN = '{7}' ,LEN_SIDE_MAX_LEN = '{8}' , UPD_DATE = '{9}' , UPD_TIME='{10}',UPD_EMP = '{11}' WHERE 1 = 1 ",
requestData[1].PLT, requestData[1].NO, requestData[1].SLAB_THICK, requestData[1].THK_MIN, requestData[1].THK_MAX, requestData[1].SHORT_SIDE_MIN_LEN, requestData[1].SHORT_SIDE_MAX_LEN, requestData[1].LEN_SIDE_MIN_LEN, requestData[1].LEN_SIDE_MAX_LEN, requestData[1].UPD_DATE, requestData[1].UPD_TIME, requestData[1].UPD_EMP) +
//根据主键字段可以确定唯一数据即要修改的数据
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("UpdBlankDefinition 报错", ex);
return result;
}
}
/// <summary>
/// 删除接口
/// </summary>
/// <param name="delModel"></param>
/// <returns></returns>
[HttpPost, Route("hotRoll/delSlabDefinition")]
public RequestEntity DelBlankDefinition(MILL_PLT_SLAB delModel)
{
RequestEntity result = new RequestEntity();
StringBuilder strSql = new StringBuilder();
try
{
strSql.AppendLine("DELETE FROM MILL_PLT_SLAB 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("DelBlankDefinition 报错", ex);
}
return result;
}
}
}