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.

335 lines
14 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.InspectionCycle;
using ibk.IPD.Entity.IPD_MR.InspectionCycle.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月21日
* 创建者: 李跃升
* Copy Right: 北京科技大学设计研究院有限公司
********************************************************/
namespace ibk.IPD.Controller.IPD_MR.InspectionCycle
{
[RoutePrefix("ipd/ipdMr")]
public class TestEquProcessCapController : 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(TEST_EQU_PROCESS_CAP cncs, RequestEntity result)
{
#region 参数判断
if (string.IsNullOrEmpty(cncs.EQU_MODEL) || CommonUtils.GetLength(cncs.EQU_MODEL) > 6)
{
result.msg = "设备型号不可为空且长度不可超过6";
result.code = "0";
return false;
}
if (string.IsNullOrEmpty(cncs.TEST_TYPE) || CommonUtils.GetLength(cncs.TEST_TYPE) > 20)
{
result.msg = "试验类型不可为空且长度不可超过20";
result.code = "0";
return false;
}
if (string.IsNullOrEmpty(cncs.STEEL_GRADE) || CommonUtils.GetLength(cncs.STEEL_GRADE) > 200)
{
result.msg = "钢种不可为空且长度不可超过200";
result.code = "0";
return false;
}
if (string.IsNullOrEmpty(cncs.THICK_MIN) || !CommonUtils.IsNumber(cncs.THICK_MIN) || CommonUtils.GetLength(cncs.THICK_MIN) > 6)
{
result.msg = "厚度最小值是长度不可超过6的数字";
result.code = "0";
return false;
}
if (string.IsNullOrEmpty(cncs.THICK_MAX) || !CommonUtils.IsNumber(cncs.THICK_MAX) || CommonUtils.GetLength(cncs.THICK_MAX) > 6)
{
result.msg = "厚度最大值是长度不可超过6的数字";
result.code = "0";
return false;
}
if (string.IsNullOrEmpty(cncs.STANDARD_PROCESS_CYCLE) || CommonUtils.GetLength(cncs.STANDARD_PROCESS_CYCLE) > 4)
{
result.msg = "标准加工周期不可为空且长度不可超过4";
result.code = "0";
return false;
}
return true;
#endregion
}
/// <summary>
/// 获取主键的条件
/// </summary>
/// <param name="primaryKeyEntity"></param>
/// <returns>AND 开头的 主键条件字符串</returns>
public string GetPrimaryKeyString(TEST_EQU_PROCESS_CAP primaryKeyEntity)
{
StringBuilder strSql = new StringBuilder();
//if (!string.IsNullOrWhiteSpace(primaryKeyEntity.APLY_ITEM))
//因为主键是自增主键, 所以将判断主键重复换成重复数据判断
strSql.AppendLine(" AND EQU_MODEL = '" + primaryKeyEntity.EQU_MODEL + "'");
strSql.AppendLine(" AND TEST_TYPE = '" + primaryKeyEntity.TEST_TYPE + "'");
strSql.AppendLine(" AND STEEL_GRADE = '" + primaryKeyEntity.STEEL_GRADE + "'");
strSql.AppendLine(" AND THICK_MIN = '" + primaryKeyEntity.THICK_MIN + "'");
strSql.AppendLine(" AND THICK_MAX = '" + primaryKeyEntity.THICK_MAX + "'");
strSql.AppendLine(" AND STANDARD_PROCESS_CYCLE = '" + primaryKeyEntity.STANDARD_PROCESS_CYCLE + "'");
return strSql.ToString();
}
/// <summary>
/// 获取主键查询的sql
/// </summary>
/// <param name="checkEntity"></param>
/// <returns>主键查询sql</returns>
public string GetCheckString(TEST_EQU_PROCESS_CAP checkEntity)
{
string strSql = "SELECT * FROM TEST_EQU_PROCESS_CAP WHERE 1=1 " + GetPrimaryKeyString(checkEntity);
return strSql;
}
/// <summary>
/// 查询接口
/// </summary>
/// <param name="queryArgs"></param>
/// <returns></returns>
[HttpPost, Route("inspectionCycle/getTestEquProcessCap")]
public RequestEntity GetTestEquProcessCap(TestEquProcessCapQueryArgs queryArgs)
{
RequestEntity result = new RequestEntity(); //声明返回参数实体类
StringBuilder strSql = new StringBuilder(); //声明拼接Sql语句变量
DataTable dtCheck = new DataTable();
//查询
//PK , EQU_MODEL , TEST_TYPE , STEEL_GRADE , THICK_MIN , THICK_MAX , STANDARD_PROCESS_CYCLE
strSql.AppendLine("SELECT PK , EQU_MODEL , TEST_TYPE , STEEL_GRADE , THICK_MIN , THICK_MAX , STANDARD_PROCESS_CYCLE ,to_date(INS_DATE || INS_TIME ,'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 TEST_EQU_PROCESS_CAP WHERE 1 = 1 ");
if (queryArgs != null)
{
if (!string.IsNullOrWhiteSpace(queryArgs.EQU_MODEL)) strSql.AppendLine(" AND EQU_MODEL LIKE '%" + queryArgs.EQU_MODEL + "%'");
if (!string.IsNullOrWhiteSpace(queryArgs.TEST_TYPE)) strSql.AppendLine(" AND TEST_TYPE LIKE '%" + queryArgs.TEST_TYPE + "%'");
if (!string.IsNullOrWhiteSpace(queryArgs.STEEL_GRADE)) strSql.AppendLine(" AND STEEL_GRADE LIKE '%" + queryArgs.STEEL_GRADE + "%'");
if (!string.IsNullOrWhiteSpace(queryArgs.THICK_MIN) && CommonUtils.IsNumber(queryArgs.THICK_MIN)) strSql.AppendLine(" AND THICK_MIN >=" + queryArgs.THICK_MIN);
if (!string.IsNullOrWhiteSpace(queryArgs.THICK_MAX) && CommonUtils.IsNumber(queryArgs.THICK_MAX)) strSql.AppendLine(" AND THICK_MAX <=" + queryArgs.THICK_MAX);
if (!string.IsNullOrWhiteSpace(queryArgs.STANDARD_PROCESS_CYCLE)) strSql.AppendLine(" AND STANDARD_PROCESS_CYCLE LIKE '%" + queryArgs.STANDARD_PROCESS_CYCLE + "%'");
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 INS_DATE DESC ");
dtCheck = db.Query(strSql.ToString());
result.data = db.Query<TEST_EQU_PROCESS_CAP>(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("GetTestEquProcessCap 报错", ex);
}
return result;
}
/// <summary>
/// 添加接口
/// </summary>
/// <param name="insertModel"></param>
/// <returns></returns>
[HttpPost, Route("inspectionCycle/addTestEquProcessCap")]
public RequestEntity AddTestEquProcessCap(TEST_EQU_PROCESS_CAP 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<TEST_EQU_PROCESS_CAP>(insertModel) > 0)
{
result.msg = "操作成功";
result.code = "1";
}
}
}
catch (Exception ex)
{
result.msg = "数据库错误!";
result.code = "0";
logger.Error("AddTestEquProcessCap 报错 : ", ex);
}
return result;
}
/// <summary>
/// 更新接口
/// </summary>
/// <param name="requestData"></param>
/// <returns></returns>
[HttpPost, Route("inspectionCycle/updTestEquProcessCap")]
public RequestEntity UpdTestEquProcessCap(IList<TEST_EQU_PROCESS_CAP> 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
{
//更新哪些字段
//PK , EQU_MODEL , TEST_TYPE , STEEL_GRADE , THICK_MIN , THICK_MAX , STANDARD_PROCESS_CYCLE
if (db.Execute("UPDATE TEST_EQU_PROCESS_CAP SET " + string.Format(" EQU_MODEL = '{0}' , TEST_TYPE = '{1}' , STEEL_GRADE = '{2}' , THICK_MIN = '{3}' , THICK_MAX = '{4}' , STANDARD_PROCESS_CYCLE = '{5}' , UPD_DATE = '{6}' , UPD_TIME='{7}',UPD_EMP = '{8}' WHERE 1 = 1 ",
requestData[1].EQU_MODEL, requestData[1].TEST_TYPE, requestData[1].STEEL_GRADE, requestData[1].THICK_MIN, requestData[1].THICK_MAX, requestData[1].STANDARD_PROCESS_CYCLE, 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("UpdTestEquProcessCap 报错", ex);
return result;
}
}
/// <summary>
/// 删除接口
/// </summary>
/// <param name="delModel"></param>
/// <returns></returns>
[HttpPost, Route("inspectionCycle/delTestEquProcessCap")]
public RequestEntity DelTestEquProcessCap(TEST_EQU_PROCESS_CAP delModel)
{
RequestEntity result = new RequestEntity();
StringBuilder strSql = new StringBuilder();
try
{
strSql.AppendLine("DELETE FROM TEST_EQU_PROCESS_CAP 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("DelTestEquProcessCap 报错", ex);
}
return result;
}
}
}