using Dapper;
|
using Microsoft.AspNetCore.Http;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Data.SqlClient;
|
using System.IO;
|
using System.Linq;
|
using System.Threading.Tasks;
|
using VueWebCoreApi.Models;
|
using VueWebCoreApi.Tools;
|
|
namespace VueWebCoreApi.DLL.DAL
|
{
|
public class DeviceManagerDAL
|
{
|
public static DataTable dt; //定义全局变量dt
|
public static bool res; //定义全局变量dt
|
public static ToMessage mes = new ToMessage(); //定义全局返回信息对象
|
public static string strProcName = ""; //定义全局sql变量
|
public static List<SqlParameter> listStr = new List<SqlParameter>(); //定义全局参数集合
|
public static SqlParameter[] parameters; //定义全局SqlParameter参数数组
|
|
|
#region[设备组查询]
|
public static ToMessage DeviceGroupSearch(int startNum, int endNum, string prop, string order)
|
{
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select A.code,A.name,A.eqptype_code,B.name as eqptype_name,A.remark
|
from TEqpGroup A
|
inner join TEqpType B on A.eqptype_code=B.code
|
where A.is_delete<>'1' ";
|
var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.count = total;
|
mes.data = data.ToList();
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备组新增]
|
public static ToMessage AddUpdateDeviceGroup(List<ObjectDataCont> json, string username)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
list.Clear();
|
//循环写入设备类型表
|
for (int i = 0; i < json.Count; i++)
|
{
|
sql = @"insert into TEqpGroup(code,name,lm_user,lm_date,remark,eqptype_code) values(@code,@name,@username,@createdate,@description,@eqptype_code)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
code = json[i].code,
|
name = json[i].name,
|
username = username,
|
createdate = DateTime.Now.ToString(),
|
description = json[i].description,
|
eqptype_code = json[i].group
|
}
|
});
|
}
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "操作失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备类型删除]
|
public static ToMessage DeleteDeviceGroup(string devicegroupcode)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
list.Clear();
|
//判断设备组下是否关联设备
|
sql = @"select * from TEqpInfo where eqpgroup_code=@devicegroupcode and is_delete<>'1'";
|
dynamicParams.Add("@devicegroupcode", devicegroupcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "当前设备组已有关联设备组,不允许删除!";
|
mes.data = null;
|
}
|
else
|
{
|
//删除设备组
|
sql = @"delete TEqpGroup where code=@devicegroupcode";
|
list.Add(new { str = sql, parm = new { devicegroupcode = devicegroupcode } });
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "删除成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "删除失败!";
|
mes.data = null;
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
|
#region[设备类型查找设备组]
|
public static ToMessage DeviceTypeSelectGroup(string eqptypecode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
List<TreeObejct> list = new List<TreeObejct>();
|
try
|
{
|
//获取设备类型数据
|
sql = @"select code,name from TEqpGroup where eqptype_code=@eqptypecode and is_delete<>'1'";
|
dynamicParams.Add("@eqptypecode", eqptypecode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[所属车间下拉接口]
|
public static ToMessage WorkShopSelect(string stu_torgcode, string description)
|
{
|
string sql = "";
|
string search = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取设备类型数据
|
switch (description)
|
{
|
case "":
|
search += "and parent.description=@description ";
|
dynamicParams.Add("@description", "W");
|
break;
|
case "D":
|
search += "and child.org_code=@stu_torgcode ";
|
dynamicParams.Add("@stu_torgcode", stu_torgcode);
|
break;
|
case "W":
|
search += "and parent.org_code=@stu_torgcode ";
|
dynamicParams.Add("@stu_torgcode", stu_torgcode);
|
break;
|
default:
|
break;
|
}
|
sql = @"select parent.org_code as code,parent.org_name as name
|
from TOrganization parent
|
left join TOrganization as child on parent.parent_id=child.id
|
where parent.is_delete<>'1' " + search;
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[所属车间查找所属产线接口]
|
public static ToMessage WorkShopSelectLine(string workshopcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
List<TreeObejct> list = new List<TreeObejct>();
|
try
|
{
|
//获取角色类型集合(包含绑定标识)
|
dynamicParams.Add("@workshop_code", workshopcode);
|
var data = DapperHelper.selectProcedure("h_p_T_WorkShopSelectLine", dynamicParams);
|
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
|
|
|
|
|
|
|
#region[设备类型查询]
|
public static ToMessage DeviceTypeSearch()
|
{
|
try
|
{
|
// --------------查询指定数据--------------
|
var sql = @"select id, code,name
|
from TEqpType";
|
var data = DapperHelper.selecttable(sql);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.count = data.Rows.Count;
|
mes.data = data;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备类型新增]
|
public static ToMessage AddUpdateDeviceType(string OperType, List<ObjectDataCont> json, User us)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
list.Clear();
|
if (OperType == "Add")
|
{
|
//判断设备类型是否重复
|
sql = @"select * from TEqpType where code=@devtypecode";
|
dynamicParams.Add("@devtypecode", json[0].code);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "设备类型编码已存在,请重新输入!";
|
mes.data = null;
|
return mes;
|
}
|
//判断设备类型名称是否重复
|
sql = @"select * from TEqpType where name=@devtypename";
|
dynamicParams.Add("@devtypename", json[0].name);
|
var data1 = DapperHelper.selectdata(sql, dynamicParams);
|
if (data1.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "设备类型名称已存在,请重新输入!";
|
mes.data = null;
|
return mes;
|
}
|
//循环写入设备类型表
|
for (int i = 0; i < json.Count; i++)
|
{
|
sql = @"insert into TEqpType(code,name,lm_user,lm_date,remark) values(@code,@name,@username,@createdate,@description)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
code = json[i].code,
|
name = json[i].name,
|
username = us.usercode,
|
createdate = DateTime.Now.ToString(),
|
description = json[i].description
|
}
|
});
|
}
|
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
//写入操作记录表
|
LogHelper.DbOperateLog(us.usercode, "新增", "新增了设备类型:" + string.Join(",", json.Select(m => m.code)), us.usertype);
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "操作失败!";
|
mes.data = null;
|
}
|
}
|
if (OperType == "Update")
|
{
|
//判断设备名称是否重复
|
sql = @"select * from TEqpType where code<>@devtypecode and name=@devtypename";
|
dynamicParams.Add("@devtypecode", json[0].code);
|
dynamicParams.Add("@devtypename", json[0].name);
|
var data1 = DapperHelper.selectdata(sql, dynamicParams);
|
if (data1.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "设备类型名称已存在,请重新输入!";
|
mes.data = null;
|
return mes;
|
}
|
for (int i = 0; i < json.Count; i++)
|
{
|
sql = @"update TEqpType set name=@devtypename,remark=@remark,lm_user=@lm_user,lm_date=@lm_date
|
where code=@devtypecode";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
devtypecode = json[i].code,
|
devtypename = json[i].name,
|
remark = json[i].description,
|
lm_user = us.usercode,
|
lm_date = DateTime.Now.ToString()
|
}
|
});
|
}
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
//写入操作记录表
|
LogHelper.DbOperateLog(us.usercode, "修改", "修改了设备类型:" + string.Join(",", json.Select(m => m.code)), us.usertype);
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "操作失败!";
|
mes.data = null;
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备类型删除]
|
public static ToMessage DeleteDeviceType(string devicetypecode, User us)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
list.Clear();
|
//判断设备有无关联设备类型
|
sql = @"select * from TEqpInfo where eqptype_code=@devicetypecode";
|
dynamicParams.Add("@devicetypecode", devicetypecode);
|
var data0 = DapperHelper.selectdata(sql, dynamicParams);
|
if (data0.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "当前设备类型已有关联设备,不允许删除!";
|
mes.data = null;
|
}
|
else
|
{
|
sql = @"delete TEqpType where code=@devicetypecode";
|
list.Add(new { str = sql, parm = new { devicetypecode = devicetypecode } });
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
//写入操作记录表
|
LogHelper.DbOperateLog(us.usercode, "删除", "删除了设备类型:" + devicetypecode, us.usertype);
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "删除成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "删除失败!";
|
mes.data = null;
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
#region [设备清单查询]
|
public static ToMessage DeviceMangerSearch(string devicecode, string devicename, string status, string storgcode, string devicetype, int startNum, int endNum, string prop, string order)
|
{
|
var dynamicParams = new DynamicParameters();
|
string search = "";
|
try
|
{
|
if (devicecode != "" && devicecode != null)
|
{
|
search += "and A.code like '%'+@devicecode+'%' ";
|
dynamicParams.Add("@devicecode", devicecode);
|
}
|
if (devicename != "" && devicename != null)
|
{
|
search += "and A.name like '%'+@devicename+'%' ";
|
dynamicParams.Add("@devicename", devicename);
|
}
|
if (status != "" && status != null)
|
{
|
search += "and A.enable=@status ";
|
dynamicParams.Add("@status", status);
|
}
|
if (storgcode != "" && storgcode != null)
|
{
|
search += "and A.torg_code=@storgcode ";
|
dynamicParams.Add("@storgcode", storgcode);
|
}
|
if (devicetype != "" && devicetype != null)
|
{
|
search += "and A.eqptype_code=@devicetype ";
|
dynamicParams.Add("@devicetype", devicetype);
|
}
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select A.id,A.code,A.name,A.eqptype_code,B.name as eqptype_name,A.enable,A.torg_code,T.torg_name,A.opc_uom,U.username as lm_user,A.lm_date
|
from TEqpInfo A
|
left join TEqpType B on A.eqptype_code=B.code
|
left join TOrganization T on A.torg_code=T.torg_code
|
left join TUser U on A.lm_user=U.usercode
|
where 1=1 " + search;
|
var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.count = total;
|
mes.data = data.ToList();
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备信息新增编辑]
|
public static ToMessage AddUpdateDeviceManger(string devicecode, string devicename, string devicetype, string storgcode, string status, string OperType, User us)
|
{
|
var dynamicParams = new DynamicParameters();
|
string sql = "";
|
try
|
{
|
if (OperType == "Add")
|
{
|
//判断设备编码是否重复
|
sql = @"select * from TEqpInfo where code=@devicecode";
|
dynamicParams.Add("@devicecode", devicecode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "设备编码已存在,请重新输入!";
|
mes.data = null;
|
return mes;
|
}
|
//判断设备名称是否重复
|
sql = @"select * from TEqpInfo where name=@devicename";
|
dynamicParams.Add("@devicename", devicename);
|
var data1 = DapperHelper.selectdata(sql, dynamicParams);
|
if (data1.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "设备名称已存在,请重新输入!";
|
mes.data = null;
|
return mes;
|
}
|
|
sql = @"insert into TEqpInfo(code,name,eqptype_code,torg_code,enable,opc_uom,lm_user,lm_date)
|
values(@devicecode,@devicename,@devicetype,@torg_code,@status,@uom,@usercode,@CreateDate)";
|
dynamicParams.Add("@devicecode", devicecode);
|
dynamicParams.Add("@devicename", devicename);
|
dynamicParams.Add("@devicetype", devicetype);
|
dynamicParams.Add("@torg_code", storgcode);
|
dynamicParams.Add("@status", status);
|
dynamicParams.Add("@uom", "台");
|
dynamicParams.Add("@usercode", us.usercode);
|
dynamicParams.Add("@CreateDate", DateTime.Now.ToString());
|
int cont = DapperHelper.SQL(sql, dynamicParams);
|
if (cont > 0)
|
{
|
//写入操作记录表
|
LogHelper.DbOperateLog(us.usercode, "新增", "新增了设备:" + devicecode, us.usertype);
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "新增操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "新增操作失败!";
|
mes.data = null;
|
}
|
}
|
if (OperType == "Update")
|
{
|
//判断设备名称是否重复
|
sql = @"select * from TEqpInfo where code<>@code and name=@name";
|
dynamicParams.Add("@code", devicecode);
|
dynamicParams.Add("@name", devicename);
|
var data1 = DapperHelper.selectdata(sql, dynamicParams);
|
if (data1.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "设备名称已存在,请重新输入!";
|
mes.data = null;
|
return mes;
|
}
|
sql = @"update TEqpInfo set name=@devicename,eqptype_code=@devicetype,torg_code=@torg_code,enable=@status,lm_user=@usercode,lm_date=@CreateDate
|
where code=@devicecode";
|
dynamicParams.Add("@devicecode", devicecode);
|
dynamicParams.Add("@devicename", devicename);
|
dynamicParams.Add("@devicetype", devicetype);
|
dynamicParams.Add("@torg_code", storgcode);
|
dynamicParams.Add("@status", status);
|
dynamicParams.Add("@usercode", us.usercode);
|
dynamicParams.Add("@CreateDate", DateTime.Now.ToString());
|
int cont = DapperHelper.SQL(sql, dynamicParams);
|
if (cont > 0)
|
{
|
//写入操作记录表
|
LogHelper.DbOperateLog(us.usercode, "修改", "修改了设备:" + devicecode, us.usertype);
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "修改操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "修改操作失败!";
|
mes.data = null;
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备信息删除]
|
public static ToMessage DeleteDeviceManger(string devicecode, User us)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
list.Clear();
|
//判断设备是否有开报工,不允许删除
|
|
//删除设备
|
sql = @"delete TEqpInfo where code=@devicecode";
|
list.Add(new { str = sql, parm = new { devicecode = devicecode } });
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
//写入操作记录表
|
LogHelper.DbOperateLog(us.usercode, "删除", "删除了设备:" + devicecode, us.usertype);
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "删除成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "删除失败!";
|
mes.data = null;
|
}
|
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备信息查看SOP]
|
public static ToMessage DeviceSopSearch(string eqptypecode, string eqpcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取SOP文件信息
|
sql = @"select filename,filepath,version from TDeviceSop
|
where eqptypecode=@eqptypecode and eqpcode=@eqpcode
|
order by version";
|
dynamicParams.Add("@eqptypecode", eqptypecode);
|
dynamicParams.Add("@eqpcode", eqpcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.message = "当前设备暂无SOP文件!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
#region[设备点检项列表查询]
|
public static ToMessage DeviceCheckItemSearch(string checkitemcode, string checkitemname, string checkdescr, string isqrcode, string cycle, int startNum, int endNum, string prop, string order)
|
{
|
var dynamicParams = new DynamicParameters();
|
string search = "";
|
try
|
{
|
if (checkitemcode != "" && checkitemcode != null)
|
{
|
search += "and A.code like '%'+@checkitemcode+'%' ";
|
dynamicParams.Add("@checkitemcode", checkitemcode);
|
}
|
if (checkitemname != "" && checkitemname != null)
|
{
|
search += "and A.name like '%'+@checkitemname+'%' ";
|
dynamicParams.Add("@checkitemname", checkitemname);
|
}
|
if (checkdescr != "" && checkdescr != null)
|
{
|
search += "and A.description like '%'+@checkdescr+'%' ";
|
dynamicParams.Add("@checkdescr", checkdescr);
|
}
|
if (isqrcode != "" && isqrcode != null)
|
{
|
search += "and A.isscan=@isqrcode ";
|
dynamicParams.Add("@isqrcode", isqrcode);
|
}
|
if (cycle != "" && cycle != null)
|
{
|
search += "and A.cycle=@cycle ";
|
dynamicParams.Add("@cycle", cycle);
|
}
|
if (search == "")
|
{
|
search = "and 1=1 ";
|
}
|
//search = search.Substring(3);//截取索引2后面的字符
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select A.id,A.code,A.name,A.description,A.isscan,A.cycle,U.username as lm_user,A.lm_date
|
from TEqpchk_Item A
|
left join TUser U on A.lm_user=U.usercode
|
where A.is_delete<>'1' " + search;
|
var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.count = total;
|
mes.data = data.ToList();
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备点检项新增编辑]
|
public static ToMessage AddUpdateDeviceCheckItem(string checkitemid, string checkitemcode, string checkitemname, string checkitemdescr, string cycle, string isqrcode, User us, string operType)
|
{
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
if (operType == "Add")
|
{
|
var sql = @"insert into TEqpchk_Item(code,name,description,isscan,cycle,lm_user,lm_date)
|
values(@checkitemcode,@checkitemname,@checkitemdescr,@isqrcode,@cycle,@usercode,@CreateDate)";
|
dynamicParams.Add("@checkitemcode", checkitemcode);
|
dynamicParams.Add("@checkitemname", checkitemname);
|
dynamicParams.Add("@checkitemdescr", checkitemdescr);
|
dynamicParams.Add("@isqrcode", isqrcode);
|
dynamicParams.Add("@cycle", cycle);
|
dynamicParams.Add("@usercode", us.usercode);
|
dynamicParams.Add("@CreateDate", DateTime.Now.ToString());
|
int cont = DapperHelper.SQL(sql, dynamicParams);
|
if (cont > 0)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "新增操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "新增操作失败!";
|
mes.data = null;
|
}
|
}
|
if (operType == "Update")
|
{
|
var sql = @"update TEqpchk_Item set name=@checkitemname,description=@checkitemdescr,isscan=@isqrcode,cycle=@cycle,
|
lm_user=@usercode,lm_date=@CreateDate
|
where id=@checkitemid";
|
dynamicParams.Add("@checkitemid", checkitemid);
|
dynamicParams.Add("@checkitemname", checkitemname);
|
dynamicParams.Add("@checkitemdescr", checkitemdescr);
|
dynamicParams.Add("@isqrcode", isqrcode);
|
dynamicParams.Add("@cycle", cycle);
|
dynamicParams.Add("@usercode", us.usercode);
|
dynamicParams.Add("@CreateDate", DateTime.Now.ToString());
|
int cont = DapperHelper.SQL(sql, dynamicParams);
|
if (cont > 0)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "修改操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "修改操作失败!";
|
mes.data = null;
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备点检项删除]
|
public static ToMessage DeleteDeviceCheckItem(string checkitemcode)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
list.Clear();
|
//判断点检标准项目是否有关联点检标准,不允许删除
|
sql = @"select * from TEqpchk_Deta
|
where code=@checkitemcode";
|
dynamicParams.Add("@checkitemcode", checkitemcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "当前点检项目已关联标准,不允许删除!";
|
mes.data = null;
|
return mes;
|
}
|
|
//删除点检项目
|
sql = @"delete TEqpchk_Item where code=@checkitemcode";
|
list.Add(new { str = sql, parm = new { checkitemcode = checkitemcode } });
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "删除成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "删除失败!";
|
mes.data = null;
|
}
|
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
#region[设备保养项列表查询]
|
public static ToMessage DeviceMaiItemSearch(string maiitemcode, string maiitemname, string maidescr, string isqrcode, int startNum, int endNum, string prop, string order)
|
{
|
var dynamicParams = new DynamicParameters();
|
string search = "";
|
try
|
{
|
if (maiitemcode != "" && maiitemcode != null)
|
{
|
search += "and A.code like '%'+@maiitemcode+'%' ";
|
dynamicParams.Add("@maiitemcode", maiitemcode);
|
}
|
if (maiitemname != "" && maiitemname != null)
|
{
|
search += "and A.name like '%'+@maiitemname+'%' ";
|
dynamicParams.Add("@maiitemname", maiitemname);
|
}
|
if (maidescr != "" && maidescr != null)
|
{
|
search += "and A.description like '%'+@maidescr+'%' ";
|
dynamicParams.Add("@maidescr", maidescr);
|
}
|
if (isqrcode != "" && isqrcode != null)
|
{
|
search += "and A.isscan=@isqrcode ";
|
dynamicParams.Add("@isqrcode", isqrcode);
|
}
|
if (search == "")
|
{
|
search = "and 1=1 ";
|
}
|
//search = search.Substring(3);//截取索引2后面的字符
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select A.id,A.code,A.name,A.description,A.isscan,U.username as lm_user,A.lm_date
|
from TEqpmai_Item A
|
left join TUser U on A.lm_user=U.usercode
|
where A.is_delete<>'1' " + search;
|
var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.count = total;
|
mes.data = data.ToList();
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备保养项新增编辑]
|
public static ToMessage AddUpdateDeviceMaiItem(string maiitemid, string maiitemcode, string maiitemname, string maiitemdescr, string isqrcode, User us, string operType)
|
{
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
if (operType == "Add")
|
{
|
var sql = @"insert into TEqpmai_Item(code,name,description,isscan,lm_user,lm_date)
|
values(@maiitemcode,@maiitemname,@maiitemdescr,@isqrcode,@usercode,@CreateDate)";
|
dynamicParams.Add("@maiitemcode", maiitemcode);
|
dynamicParams.Add("@maiitemname", maiitemname);
|
dynamicParams.Add("@maiitemdescr", maiitemdescr);
|
dynamicParams.Add("@isqrcode", isqrcode);
|
dynamicParams.Add("@usercode", us.usercode);
|
dynamicParams.Add("@CreateDate", DateTime.Now.ToString());
|
int cont = DapperHelper.SQL(sql, dynamicParams);
|
if (cont > 0)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "新增操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "新增操作失败!";
|
mes.data = null;
|
}
|
}
|
if (operType == "Update")
|
{
|
var sql = @"update TEqpmai_Item set name=@maiitemname,description=@maiitemdescr,isscan=@isqrcode,
|
lm_user=@usercode,lm_date=@CreateDate
|
where id=@maiitemid";
|
dynamicParams.Add("@maiitemid", maiitemid);
|
dynamicParams.Add("@maiitemname", maiitemname);
|
dynamicParams.Add("@maiitemdescr", maiitemdescr);
|
dynamicParams.Add("@isqrcode", isqrcode);
|
dynamicParams.Add("@usercode", us.usercode);
|
dynamicParams.Add("@CreateDate", DateTime.Now.ToString());
|
int cont = DapperHelper.SQL(sql, dynamicParams);
|
if (cont > 0)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "修改操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "修改操作失败!";
|
mes.data = null;
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备保养项删除]
|
public static ToMessage DeleteDeviceMaiItem(string maiitemcode)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
list.Clear();
|
//判断保养标准项目是否有关联保养标准,不允许删除
|
sql = @"select * from TEqpmai_Deta
|
where code=@maiitemcode";
|
dynamicParams.Add("@maiitemcode", maiitemcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "当前保养项目已关联标准,不允许删除!";
|
mes.data = null;
|
return mes;
|
}
|
|
//删除保养项目
|
sql = @"delete TEqpmai_Item where code=@maiitemcode";
|
list.Add(new { str = sql, parm = new { maiitemcode = maiitemcode } });
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "删除成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "删除失败!";
|
mes.data = null;
|
}
|
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
#region[设备点检标准列表查询]
|
public static ToMessage DeviceCheckStandArdSearch(User us, string checkstandcode, string checkstandname, string checkcontr, int startNum, int endNum, string prop, string order)
|
{
|
var dynamicParams = new DynamicParameters();
|
string search = "";
|
try
|
{
|
if (checkstandcode != "" && checkstandcode != null)
|
{
|
search += "and A.code like '%'+@checkstandcode+'%' ";
|
dynamicParams.Add("@checkstandcode", checkstandcode);
|
}
|
if (checkstandname != "" && checkstandname != null)
|
{
|
search += "and A.name like '%'+@checkstandname+'%' ";
|
dynamicParams.Add("@checkstandname", checkstandname);
|
}
|
if (checkcontr != "" && checkcontr != null)
|
{
|
search += "and A.iscontr=@checkcontr ";
|
dynamicParams.Add("@checkcontr", checkcontr);
|
}
|
if (search == "")
|
{
|
search = "and 1=1 ";
|
}
|
//search = search.Substring(3);//截取索引2后面的字符
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select A.id,A.code,A.name,A.description,A.iscontr,
|
(case when isnull(M.eqpchkmain_code,'')='' then 'N' else 'Y' end) as is_checkeqp,U.username as lm_user,A.lm_date
|
from TEqpchk_Main A
|
left join TUser U on A.lm_user=U.usercode
|
left join (
|
select distinct eqpchkmain_code from TEqpchk_Eqp M
|
) M on A.code=M.eqpchkmain_code where A.is_delete<>'1' " + search;
|
var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.count = total;
|
mes.data = data.ToList();
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备点检标准新增、编辑获取检验项目下拉列表]
|
public static ToMessage DeviceCheckItemSelect()
|
{
|
string sql = "";
|
try
|
{
|
//获取设备点检项目数据
|
sql = @"select code,name,description from TEqpchk_Item where is_delete<>'1' ";
|
var data = DapperHelper.selecttable(sql);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备点检标准编辑/查看获取数据]
|
public static ToMessage ViewDeviceCheckStanedSearch(string checkstand_code)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取设备点检标准信息
|
sql = @"select code,name,description,iscontr
|
from TEqpchk_Main
|
where code=@checkstand_code and is_delete<>'1'";
|
dynamicParams.Add("@checkstand_code", checkstand_code);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
RoutEdit rout = new RoutEdit();
|
if (data.Rows.Count > 0)
|
{
|
rout.code = data.Rows[0]["CODE"].ToString();
|
rout.name = data.Rows[0]["NAME"].ToString();
|
rout.description = data.Rows[0]["DESCRIPTION"].ToString();
|
rout.enable = data.Rows[0]["ISCONTR"].ToString();
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "无点检标准信息!";
|
mes.data = null;
|
return mes;
|
}
|
//根据设备点检标准编码获取关联的检验项目信息
|
sql = @"select B.code,B.name,A.chkdesc,A.isscan,A.cycle from TEqpchk_Deta A
|
left join TEqpchk_Item B on A.code=B.code
|
where A.eqpchk_main_code=@checkstaned_code order by A.seq asc";
|
dynamicParams.Add("@checkstaned_code", rout.code);
|
var data0 = DapperHelper.selectdata(sql, dynamicParams);
|
rout.Data = data0;
|
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = rout;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备点检标准新增编辑]
|
public static ToMessage AddUpdateDeviceCheckStandArd(string opertype, RoutEdit json, User us)
|
{
|
var sql = "";
|
var dynamicParams = new DynamicParameters();
|
List<object> list = new List<object>();
|
try
|
{
|
if (opertype == "Add")
|
{
|
//新增设备点检标准主表
|
sql = @"insert into TEqpchk_Main(code,name,description,iscontr,lm_user,lm_date) values(@code,@name,@descr,@iscontr,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { code = json.code, name = json.name, descr = json.description, iscontr = json.enable, lm_user = us.usercode, lm_date = DateTime.Now.ToString() } });
|
for (int i = 0; i < json.Data.Rows.Count; i++)
|
{
|
//新增设备点检标准关联点检项子表
|
sql = @"insert TEqpchk_Deta (seq,code,name,eqpchk_main_code,cycle,chkdesc,isscan,lm_user,lm_date)
|
values(@checkitem_seq,@checkitem_code,@checkitem_name,@code,@cycle,@chkdesc,@isscan,@lm_user,@lm_date)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
checkitem_seq = Convert.ToInt32(json.Data.Rows[i]["CHECKITEM_SEQ"].ToString()),
|
checkitem_code = json.Data.Rows[i]["CHECKITEM_CODE"].ToString(),
|
checkitem_name = json.Data.Rows[i]["CHECKITEM_NAME"].ToString(),
|
code = json.code,
|
cycle = json.Data.Rows[i]["CYCLE"].ToString(),
|
chkdesc = json.Data.Rows[i]["CHECKITEM_DESCR"].ToString(),
|
isscan = json.Data.Rows[i]["ISSCAN"].ToString(),
|
lm_user = us.usercode,
|
lm_date = DateTime.Now.ToString()
|
}
|
});
|
}
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "操作失败!";
|
mes.data = null;
|
}
|
}
|
if (opertype == "Update")
|
{
|
//删除点检标准关联点检项目子表
|
sql = @"delete from TEqpchk_Deta where eqpchk_main_code=@checkstaned_code";
|
list.Add(new { str = sql, parm = new { checkstaned_code = json.code } });
|
//修改点检标准主表
|
sql = @"update TEqpchk_Main set name=@checkstaned_name,description=@checkstaned_desc,iscontr=@iscontr where code=@checkstaned_code";
|
list.Add(new { str = sql, parm = new { checkstaned_code = json.code, checkstaned_name = json.name, checkstaned_desc = json.description, iscontr = json.enable } });
|
//新增点检标准关联点检项目子表
|
for (int i = 0; i < json.Data.Rows.Count; i++)
|
{
|
sql = @"insert TEqpchk_Deta (seq,code,name,eqpchk_main_code,cycle,chkdesc,isscan,lm_user,lm_date)
|
values(@checkitem_seq,@checkitem_code,@checkitem_name,@code,@cycle,@chkdesc,@isscan,@lm_user,@lm_date)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
checkitem_seq = Convert.ToInt32(json.Data.Rows[i]["CHECKITEM_SEQ"].ToString()),
|
checkitem_code = json.Data.Rows[i]["CHECKITEM_CODE"].ToString(),
|
checkitem_name = json.Data.Rows[i]["CHECKITEM_NAME"].ToString(),
|
code = json.code,
|
cycle = json.Data.Rows[i]["CYCLE"].ToString(),
|
chkdesc = json.Data.Rows[i]["CHECKITEM_DESCR"].ToString(),
|
isscan = json.Data.Rows[i]["ISSCAN"].ToString(),
|
lm_user = us.usercode,
|
lm_date = DateTime.Now.ToString()
|
}
|
});
|
}
|
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "操作失败!";
|
mes.data = null;
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备点检标准删除]
|
public static ToMessage DeleteDeviceCheckStaned(string checkstand_code)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
sql = @"select * from TEqpchk_Proc_Main where eqpchkmain_code=@checkstand_code";
|
dynamicParams.Add("@checkstand_code", checkstand_code);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "当前点检标准已生成点检记录,不允许删除!";
|
mes.data = null;
|
return mes;
|
}
|
//删除设备点检标准主表
|
sql = @"delete TEqpchk_Main where code=@checkstand_code";
|
list.Add(new { str = sql, parm = new { checkstand_code = checkstand_code } });
|
//删除设备点检标准关联点检项目子表
|
sql = @"delete TEqpchk_Deta where eqpchk_main_code=@checkstand_code";
|
list.Add(new { str = sql, parm = new { checkstand_code = checkstand_code } });
|
//删除设备点检标准关联设备表
|
sql = @"delete TEqpchk_Eqp where eqpchkmain_code=@checkstand_code";
|
list.Add(new { str = sql, parm = new { checkstand_code = checkstand_code } });
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "设备点检标准删除成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "设备点检标准删除失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备点检标准关联工作站查询]
|
public static ToMessage DeviceCheckStanedAssociationEqp(User us, string checkstand_code)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
List<StandEqp> list = new List<StandEqp>();
|
try
|
{
|
//获取工作站集合(车间,包含已绑定工作站标识)
|
sql = @"select distinct E.torg_code as wksp_code,T.torg_name as wksp_name,'E' as type,(case when B.wksp_code is null then 'N' else 'Y' end) flag
|
from TEqpInfo E
|
left join TOrganization T on E.torg_code=T.torg_code
|
left join(
|
select distinct B.torg_code as wksp_code from TEqpchk_Eqp A
|
inner join TEqpInfo B on A.eqp_code=B.code
|
where A.eqpchkmain_code=@checkstand_code
|
) B on T.torg_code=B.wksp_code";
|
dynamicParams.Add("@checkstand_code", checkstand_code);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
for (int i = 0; i < data.Rows.Count; i++)
|
{
|
StandEqp rout = new StandEqp();
|
rout.code = data.Rows[i]["WKSP_CODE"].ToString();
|
rout.name = data.Rows[i]["WKSP_NAME"].ToString();
|
rout.type = data.Rows[i]["TYPE"].ToString();
|
rout.flag = data.Rows[i]["FLAG"].ToString();
|
rout.children = new List<StandEqpCn>();
|
sql = @"select * from(
|
select AA.code,AA.name,'E' as type,(case when BB.eqpchkmain_code is null then 'N' else 'Y' end) flag,(case when AA.eqpchkmain_code is null then 'N' else 'Y' end) flage1
|
from(
|
select A.code,A.name,'' as eqpchkmain_code
|
from TEqpInfo A
|
where A.torg_code=@wkspcode
|
) as AA
|
left join (
|
select A.code,A.name,B.eqpchkmain_code
|
from TEqpInfo A
|
inner join TEqpchk_Eqp B on A.code=B.eqp_code
|
where A.torg_code=@wkspcode and B.eqpchkmain_code=@checkstand_code
|
) as BB on AA.code=BB.code
|
) as CC ";
|
dynamicParams.Add("@checkstand_code", checkstand_code);
|
dynamicParams.Add("@wkspcode", data.Rows[i]["WKSP_CODE"].ToString());
|
var data0 = DapperHelper.selectdata(sql, dynamicParams);
|
for (int j = 0; j < data0.Rows.Count; j++)
|
{
|
StandEqpCn cn = new StandEqpCn();
|
cn.code = data0.Rows[j]["CODE"].ToString();//设备编码
|
cn.name = data0.Rows[j]["NAME"].ToString();//设备名称
|
cn.type = data0.Rows[j]["TYPE"].ToString();//工作站类型(E:设备 W:外协供方)
|
cn.flag = data0.Rows[j]["FLAG"].ToString();//关联标识
|
rout.children.Add(cn);
|
}
|
list.Add(rout);
|
}
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = list;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region [设备点检标准关联工作站提交]
|
public static ToMessage SaveDeviceCheckStanedAssociationEqp(User us, string checkstand_code, List<ObjectData> json)
|
{
|
var sql = "";
|
var dynamicParams = new DynamicParameters();
|
List<object> list = new List<object>();
|
try
|
{
|
list.Clear();
|
//清除设备点检标准关联设备表数据
|
sql = @"delete TEqpchk_Eqp where eqpchkmain_code=@checkstand_code";
|
list.Add(new { str = sql, parm = new { checkstand_code = checkstand_code } });
|
//循环写入设备点检标准关联设备表
|
for (int i = 0; i < json.Count; i++)
|
{
|
sql = @"insert into TEqpchk_Eqp(eqpchkmain_code,eqp_code,lm_user,lm_date,torg_code) values(@checkstand_code,@eqp_code,@lm_user,@lm_date,@torg_code)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
eqp_code = json[i].code,
|
checkstand_code = checkstand_code,
|
lm_user = us.usercode,
|
lm_date = DateTime.Now.ToString(),
|
torg_code = json[i].flag
|
}
|
});
|
}
|
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "操作失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
#region[设备保养标准列表查询]
|
public static ToMessage DeviceRepairStandArdSearch(User us, string repairstandcode, string repairstandname, string repairstanddescr, int startNum, int endNum, string prop, string order)
|
{
|
var dynamicParams = new DynamicParameters();
|
string search = "";
|
try
|
{
|
if (repairstandcode != "" && repairstandcode != null)
|
{
|
search += "and A.code like '%'+@repairstandcode+'%' ";
|
dynamicParams.Add("@repairstandcode", repairstandcode);
|
}
|
if (repairstandname != "" && repairstandname != null)
|
{
|
search += "and A.name like '%'+@repairstandname+'%' ";
|
dynamicParams.Add("@repairstandname", repairstandname);
|
}
|
if (repairstanddescr != "" && repairstanddescr != null)
|
{
|
search += "and A.description like '%'+@repairstanddescr+'%' ";
|
dynamicParams.Add("@repairstanddescr", repairstanddescr);
|
}
|
|
if (search == "")
|
{
|
search = "and 1=1 ";
|
}
|
//search = search.Substring(3);//截取索引2后面的字符
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select A.id,A.code,A.name,A.description,
|
(case when isnull(M.eapmai_code,'')='' then 'N' else 'Y' end) as is_repaireqp,
|
A.main_cycle,U.username as lm_user,A.lm_date
|
from TEqpmai_Main A
|
left join TUser U on A.lm_user=U.usercode
|
left join (
|
select distinct eapmai_code from TEqpmai_Eqp M
|
) M on A.code=M.eapmai_code where A.is_delete<>'1' " + search;
|
var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.count = total;
|
mes.data = data.ToList();
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备保养标准新增、编辑获取保养项目下拉列表]
|
public static ToMessage DeviceRepairItemSelect()
|
{
|
string sql = "";
|
try
|
{
|
//获取设备保养项目数据
|
sql = @"select code,name,description from TEqpmai_Item where is_delete<>'1' ";
|
var data = DapperHelper.selecttable(sql);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备保养标准编辑/查看获取数据]
|
public static ToMessage ViewDeviceRepairStanedSearch(string repairstand_code)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取设备保养标准信息
|
sql = @"select code,name,description,main_cycle
|
from TEqpmai_Main
|
where code=@repairstand_code and is_delete<>'1'";
|
dynamicParams.Add("@repairstand_code", repairstand_code);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
EqpRepair rout = new EqpRepair();
|
if (data.Rows.Count > 0)
|
{
|
rout.code = data.Rows[0]["CODE"].ToString();
|
rout.name = data.Rows[0]["NAME"].ToString();
|
rout.repaircycle = data.Rows[0]["MAIN_CYCLE"].ToString();
|
rout.description = data.Rows[0]["DESCRIPTION"].ToString();
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "无保养标准信息!";
|
mes.data = null;
|
return mes;
|
}
|
//根据设备保养标准编码获取关联的保养项目信息
|
sql = @"select B.code,B.name,A.chk_desc,A.isscan,A.cycle from TEqpmai_Deta A
|
left join TEqpmai_Item B on A.code=B.code
|
where A.eapmai_code=@repairstand_code order by A.seq asc";
|
dynamicParams.Add("@repairstand_code", rout.code);
|
var data0 = DapperHelper.selectdata(sql, dynamicParams);
|
rout.Data = data0;
|
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = rout;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备保养标准新增编辑]
|
public static ToMessage AddUpdateDeviceRepairStandArd(string opertype, EqpRepair json, User us)
|
{
|
var sql = "";
|
var dynamicParams = new DynamicParameters();
|
List<object> list = new List<object>();
|
try
|
{
|
if (opertype == "Add")
|
{
|
//新增设备保养标准主表
|
sql = @"insert into TEqpmai_Main(code,name,description,main_cycle,lm_user,lm_date) values(@code,@name,@descr,@main_cycle,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { code = json.code, name = json.name, descr = json.description, main_cycle = json.repaircycle, lm_user = us.usercode, lm_date = DateTime.Now.ToString() } });
|
for (int i = 0; i < json.Data.Rows.Count; i++)
|
{
|
//新增设备保养标准关联保养项子表
|
sql = @"insert TEqpmai_Deta (seq,code,name,eapmai_code,chk_desc,isscan,lm_user,lm_date)
|
values(@repairitem_seq,@repairitem_code,@repairitem_name,@code,@repairdesc,@isscan,@lm_user,@lm_date)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
repairitem_seq = Convert.ToInt32(json.Data.Rows[i]["REPAIRITEM_SEQ"].ToString()),
|
repairitem_code = json.Data.Rows[i]["REPAIRITEM_CODE"].ToString(),
|
repairitem_name = json.Data.Rows[i]["REPAIRITEM_NAME"].ToString(),
|
code = json.code,
|
repairdesc = json.Data.Rows[i]["REPAIRITEM_DESCR"].ToString(),
|
isscan = json.Data.Rows[i]["ISSCAN"].ToString(),
|
lm_user = us.usercode,
|
lm_date = DateTime.Now.ToString()
|
}
|
});
|
}
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "操作失败!";
|
mes.data = null;
|
}
|
}
|
if (opertype == "Update")
|
{
|
//删除保养标准关联点检项目子表
|
sql = @"delete from TEqpmai_Deta where eapmai_code=@repairstaned_code";
|
list.Add(new { str = sql, parm = new { repairstaned_code = json.code } });
|
//修改保养标准主表
|
sql = @"update TEqpmai_Main set name=@repairstaned_name,description=@repairstaned_desc,main_cycle=@main_cycle where code=@repairstaned_code";
|
list.Add(new { str = sql, parm = new { repairstaned_code = json.code, repairstaned_name = json.name, repairstaned_desc = json.description, main_cycle = json.repaircycle } });
|
//新增点检标准关联点检项目子表
|
for (int i = 0; i < json.Data.Rows.Count; i++)
|
{
|
sql = @"insert TEqpmai_Deta (seq,code,name,eapmai_code,chk_desc,isscan,lm_user,lm_date)
|
values(@repairitem_seq,@repairitem_code,@repairitem_name,@code,@repairdesc,@isscan,@lm_user,@lm_date)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
repairitem_seq = Convert.ToInt32(json.Data.Rows[i]["REPAIRITEM_SEQ"].ToString()),
|
repairitem_code = json.Data.Rows[i]["REPAIRITEM_CODE"].ToString(),
|
repairitem_name = json.Data.Rows[i]["REPAIRITEM_NAME"].ToString(),
|
code = json.code,
|
repairdesc = json.Data.Rows[i]["REPAIRITEM_DESCR"].ToString(),
|
isscan = json.Data.Rows[i]["ISSCAN"].ToString(),
|
lm_user = us.usercode,
|
lm_date = DateTime.Now.ToString()
|
}
|
});
|
}
|
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "操作失败!";
|
mes.data = null;
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备保养标准删除]
|
public static ToMessage DeleteDeviceRepairStaned(string repairstand_code)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
sql = @"select * from TEqpmaint_Proc_Main where eqpmaint_code=@repairstand_code";
|
dynamicParams.Add("@repairstand_code", repairstand_code);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "当前保养标准已生成保养记录,不允许删除!";
|
mes.data = null;
|
return mes;
|
}
|
//删除设备保养标准主表
|
sql = @"delete TEqpmai_Main where code=@repairstand_code";
|
list.Add(new { str = sql, parm = new { repairstand_code = repairstand_code } });
|
//删除设备保养标准关联保养项目子表
|
sql = @"delete TEqpmai_Deta where eapmai_code=@repairstand_code";
|
list.Add(new { str = sql, parm = new { repairstand_code = repairstand_code } });
|
//删除设备保养标准关联设备表
|
sql = @"delete TEqpmai_Eqp where eapmai_code=@repairstand_code";
|
list.Add(new { str = sql, parm = new { repairstand_code = repairstand_code } });
|
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "设备保养标准删除成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "设备保养标准删除失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备保养标准关联工作站查询]
|
public static ToMessage DeviceRepairStanedAssociationEqp(User us, string repairstand_code)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
List<StandEqp> list = new List<StandEqp>();
|
try
|
{
|
//获取工作站集合(车间,包含已绑定工作站标识)
|
sql = @"select distinct E.torg_code as wksp_code,T.torg_name as wksp_name,'E' as type,(case when B.wksp_code is null then 'N' else 'Y' end) flag
|
from TEqpInfo E
|
left join TOrganization T on E.torg_code=T.torg_code
|
left join(
|
select distinct B.torg_code as wksp_code from TEqpmai_Eqp A
|
inner join TEqpInfo B on A.eqp_code=B.code
|
where A.eapmai_code=@repairstand_code
|
) B on T.torg_code=B.wksp_code ";
|
|
dynamicParams.Add("@repairstand_code", repairstand_code);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
for (int i = 0; i < data.Rows.Count; i++)
|
{
|
StandEqp rout = new StandEqp();
|
rout.code = data.Rows[i]["WKSP_CODE"].ToString();
|
rout.name = data.Rows[i]["WKSP_NAME"].ToString();
|
rout.type = data.Rows[i]["TYPE"].ToString();
|
rout.flag = data.Rows[i]["FLAG"].ToString();
|
rout.children = new List<StandEqpCn>();
|
//根据车间编码查找设备(包含已关联标识)
|
sql = @"select * from(
|
select AA.code,AA.name,'E' as type,(case when BB.eapmai_code is null then 'N' else 'Y' end) flag,(case when AA.eapmai_code is null then 'N' else 'Y' end) flage1
|
from(
|
select A.code,A.name,'' as eapmai_code
|
from TEqpInfo A
|
where A.torg_code=@wkspcode
|
) as AA
|
left join (
|
select A.code,A.name,B.eapmai_code
|
from TEqpInfo A
|
inner join TEqpmai_Eqp B on A.code=B.eqp_code
|
where A.torg_code=@wkspcode and B.eapmai_code=@repairstand_code
|
) as BB on AA.code=BB.code
|
) as CC";
|
dynamicParams.Add("@repairstand_code", repairstand_code);
|
dynamicParams.Add("@wkspcode", data.Rows[i]["WKSP_CODE"].ToString());
|
var data0 = DapperHelper.selectdata(sql, dynamicParams);
|
for (int j = 0; j < data0.Rows.Count; j++)
|
{
|
StandEqpCn cn = new StandEqpCn();
|
cn.code = data0.Rows[j]["CODE"].ToString();//设备编码
|
cn.name = data0.Rows[j]["NAME"].ToString();//设备名称
|
cn.type = data0.Rows[j]["TYPE"].ToString();//工作站类型(E:设备 W:外协供方)
|
cn.flag = data0.Rows[j]["FLAG"].ToString();//关联标识
|
rout.children.Add(cn);
|
}
|
list.Add(rout);
|
}
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = list;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region [设备保养标准关联工作站提交]
|
public static ToMessage SaveDeviceRepairStanedAssociationEqp(User us, string repairstand_code, List<ObjectData> json)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
try
|
{
|
list.Clear();
|
sql = @"delete TEqpmai_Eqp where eapmai_code=@repairstand_code";
|
list.Add(new { str = sql, parm = new { repairstand_code = repairstand_code } });
|
//循环写入设备保养标准关联设备表
|
for (int i = 0; i < json.Count; i++)
|
{
|
sql = @"insert into TEqpmai_Eqp(eapmai_code,eqp_code,lm_user,lm_date,torg_code) values(@repairstand_code,@eqp_code,@lm_user,@lm_date,@torg_code)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
eqp_code = json[i].code,
|
repairstand_code = repairstand_code,
|
lm_user = us.usercode,
|
lm_date = DateTime.Now.ToString(),
|
torg_code = json[i].flag
|
}
|
});
|
}
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "操作成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "操作失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
#region[日常点检,扫描工位/设备二维码]
|
public static ToMessage CheckScanDeviceQrCodeData(string eqpcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取对应设备及所属车间
|
sql = @"select A.code,A.name,T.torg_code as wksp_code,T.torg_name as wksp_name,E.eqpchkmain_code
|
from TEqpInfo A
|
left join TOrganization T on A.torg_code=T.torg_code
|
left join TEqpchk_Eqp E on A.code=E.eqp_code
|
where A.code=@eqpcode and A.enable='Y'";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.message = "当前设备/工位不存在或异常!";
|
mes.data = data;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[日常点检,扫描工位/设备二维码查找点检标准]
|
public static ToMessage CheckScanDeviceTemp(string eqpcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取对应设备点检标准
|
sql = @"select M.code,M.name from TEqpchk_Eqp E
|
inner join TEqpchk_Main M on E.eqpchkmain_code=M.code
|
where E.eqp_code=@eqpcode order by M.lm_date desc";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.message = "当前设备/工位未指定点检标准!";
|
mes.data = data;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
|
#endregion
|
|
#region[日常点检,选择扫码设备列表带出点检项]
|
public static ToMessage SelectScanDeviceQrCodeItem(string eqpcode, string checktempcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取对应设备关联的点检项目
|
sql = @"select S.seq,S.code,S.name,S.chkdesc,S.isscan,S.cycle
|
from TEqpchk_Eqp A
|
inner join TEqpchk_Main B on A.eqpchkmain_code=B.code
|
inner join TEqpchk_Deta S on B.code=S.eqpchk_main_code
|
where A.eqp_code=@eqpcode and B.code=@checktempcode
|
order by S.seq asc";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
dynamicParams.Add("@checktempcode", checktempcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.message = "当前设备未设置点检标准绑定点检项目!";
|
mes.data = data;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[日常点检、提交保存]
|
public static ToMessage AppDeviceCheckSave(User us, AppDevicecCheck json)
|
{
|
var sql = "";
|
string djwo = "", numvalue = "";
|
List<object> list = new List<object>();
|
try
|
{
|
list.Clear();
|
mes = SeachEncode.EncodingSeach("2400"); //APP端日常点检生成单号
|
if (mes.code == "300")
|
{
|
return mes;
|
}
|
else
|
{
|
List<string> wo = (List<string>)mes.data;
|
djwo = wo[0].ToString(); //获取单号
|
numvalue = wo[1].ToString(); //获取流水号
|
}
|
if (json == null || json.children.Count <= 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "点检项信息不能为空!";
|
mes.data = null;
|
return mes;
|
}
|
|
//写入点检记录主表
|
sql = @"insert into TEqpchk_Proc_Main(djwo,eqp_code,eqpchkmain_code,chk_user,chk_date,chk_result)
|
values(@djwo,@eqp_code,@eqpchkmain_code,@lm_user,@lm_date,@chk_result)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
djwo = djwo,
|
eqp_code = json.code,
|
eqpchkmain_code = json.standcode,
|
lm_user = us.usercode,
|
lm_date = DateTime.Now.ToString(),
|
chk_result = json.result
|
}
|
});
|
//循环写入点检记录子表
|
for (int i = 0; i < json.children.Count; i++)
|
{
|
sql = @"insert into TEqpchk_Proc_Deta(seq,djwo,eqpchkdeta_code,chk_cyc,result,chk_value)
|
values(@seq,@djwo,@eqpchkdeta_code,@chk_cyc,@result,@chk_value)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
seq = json.children[i].seq,
|
djwo = djwo,
|
eqpchkdeta_code = json.children[i].itemcode,
|
chk_cyc = json.children[i].cycle,
|
result = json.children[i].result,
|
chk_value = json.children[i].value
|
}
|
}); ;
|
}
|
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
//写入操作记录表
|
LogHelper.DbOperateLog(us.usercode, "设备点检", "点检了设备：" + json.code, us.usertype);
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "点检成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "点检失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
|
#region[定期保养,扫描工位/设备二维码]
|
public static ToMessage RepairScanDeviceQrCodeData(string eqpcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取对应设备及所属车间
|
sql = @"select A.code,A.name,T.torg_code as wksp_code,T.torg_name as wksp_name,
|
E.eapmai_code,M.name as eapmai_name,M.main_cycle
|
from TEqpInfo A
|
left join TOrganization T on A.torg_code=T.torg_code
|
left join TEqpmai_Eqp E on A.code=E.eqp_code
|
left join TEqpmai_Main M on E.eapmai_code=M.code
|
where A.code=@eqpcode and A.enable='Y'";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.message = "当前设备异常!";
|
mes.data = data;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[定期保养,扫描工位/设备二维码查找保养标准]
|
public static ToMessage RepairScanDeviceTemp(string eqpcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取对应设备保养标准
|
sql = @"select M.code,M.name,main_cycle from TEqpmai_Eqp E
|
inner join TEqpmai_Main M on E.eapmai_code=M.code
|
where E.eqp_code=@eqpcode
|
order by M.lm_date desc";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.message = "当前设备/工位未指定保养标准!";
|
mes.data = data;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[日常保养,选择扫码设备列表带出保养项]
|
public static ToMessage RepairSelectScanDeviceQrCodeItem(string eqpcode, string repartempcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取对应设备关联的保养项目
|
sql = @"select S.seq,S.code,S.name,S.chk_desc,S.isscan,B.main_cycle
|
from TEqpmai_Eqp A
|
inner join TEqpmai_Main B on A.eapmai_code=B.code
|
inner join TEqpmai_Deta S on B.code=S.eapmai_code
|
where A.eqp_code=@eqpcode and B.code=@repartempcode
|
order by S.seq asc";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
dynamicParams.Add("@repartempcode", repartempcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.message = "当前设备未设置保养标准绑定点检项目!";
|
mes.data = data;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[日常保养,提交保存]
|
public static ToMessage AppDeviceRepairSave(User us, string maintcyc, AppDevicecCheck json)
|
{
|
var sql = "";
|
string bywo = "", numvalue = "";
|
List<object> list = new List<object>();
|
try
|
{
|
list.Clear();
|
mes = SeachEncode.EncodingSeach("2401"); //APP端定期保养生成单号
|
if (mes.code == "300")
|
{
|
return mes;
|
}
|
else
|
{
|
List<string> wo = (List<string>)mes.data;
|
bywo = wo[0].ToString(); //获取单号
|
numvalue = wo[1].ToString(); //获取流水号
|
}
|
if (json == null || json.children.Count <= 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "保养项信息不能为空!";
|
mes.data = null;
|
return mes;
|
}
|
|
//写入保养记录主表
|
sql = @"insert into TEqpmaint_Proc_Main(bywo,eqp_code,eqpmaint_code,maint_cyc,maint_result,maint_user,maint_date)
|
values(@bywo,@eqp_code,@eqpmaint_code,@maintcyc,@maint_result,@lm_user,@lm_date)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
bywo = bywo,
|
eqp_code = json.code,
|
eqpmaint_code = json.standcode,
|
maintcyc = maintcyc,
|
lm_user = us.usercode,
|
lm_date = DateTime.Now.ToString(),
|
maint_result = json.result
|
}
|
});
|
//循环写入保养记录子表
|
for (int i = 0; i < json.children.Count; i++)
|
{
|
sql = @"insert into TEqpmaint_Proc_Deta(seq,bywo,eqpmaideta_code,result,maint_cyc,maint_value)
|
values(@seq,@bywo,@eqpmaideta_code,@result,@maint_cyc,@maint_value)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
seq = json.children[i].seq,
|
bywo = bywo,
|
eqpmaideta_code = json.children[i].itemcode,
|
maint_cyc = json.children[i].cycle,
|
result = json.children[i].result,
|
maint_value = json.children[i].value
|
}
|
}); ;
|
}
|
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
//写入操作记录表
|
LogHelper.DbOperateLog(us.usercode, "设备保养", "保养了设备：" + json.code, us.usertype);
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "保养成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "保养失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
|
#region[设备维修申请,扫描工位/设备二维码]
|
public static ToMessage MaintainScanDeviceApplyQrCodeData(string eqpcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取当前扫码设备是否存在已申请或已维修状态数据
|
sql = @"select * from TEqp_RepairRequest where eqp_code=@eqpcode and status<>'CONFIR'";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
var data0 = DapperHelper.selectdata(sql, dynamicParams);
|
if (data0.Rows.Count > 0)
|
{
|
//查看维修记录里面是否有已申请未维修及维修确认的数据
|
var rows = data0.AsEnumerable().Where(item => item["STATUS"].ToString().Equals("REPA")).ToArray();
|
if (rows.Length > 0)
|
{
|
mes.code = "300";
|
mes.message = "当前设备/工位已申请,待维修!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.message = "当前设备/工位已维修,待确认验证!";
|
mes.data = null;
|
}
|
}
|
else
|
{
|
//获取对应设备及所属车间
|
sql = @"select A.code,A.name,T.torg_code as wksp_code,T.torg_name as wksp_name,E.eqpchkmain_code
|
from TEqpInfo A
|
left join TOrganization T on A.torg_code=T.torg_code
|
left join TEqpchk_Eqp E on A.code=E.eqp_code
|
where A.code=@eqpcode and A.enable='Y' ";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.message = "当前设备/工位不存在或异常!";
|
mes.data = data;
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备维修申请,提交保存]
|
public static ToMessage MaintainScanDeviceApplySave(User us, string eqpcode, string wkshpcode, string faultsourcecode, string faultdescr, IFormFileCollection files)
|
{
|
var sql = "";
|
string wxwo = "", numvalue = "";
|
List<object> list = new List<object>();
|
try
|
{
|
list.Clear();
|
mes = SeachEncode.EncodingSeach("2404"); //APP端设备维修申请生成单号
|
if (mes.code == "300")
|
{
|
return mes;
|
}
|
else
|
{
|
List<string> wo = (List<string>)mes.data;
|
wxwo = wo[0].ToString(); //获取单号
|
numvalue = wo[1].ToString(); //获取流水号
|
}
|
//维修申请上传图片
|
if (files != null && files.Count > 0)
|
{
|
for (int i = 0; i < files.Count; i++)
|
{
|
IFormFile file = files[i];
|
string imgName = "SQ" + DateTime.Now.ToString("yyyyMMddhhmmss") + i.ToString();
|
string filePath = "wwwroot/DeviceRecordImage/" + imgName + file.FileName; //通过此对象获取文件名(存文件地址)
|
string filePath1 = "DeviceRecordImage/" + imgName + file.FileName; //通过此对象获取文件名(存数据表地址)
|
|
// 生成文件名
|
//var fileName = "SQ" + DateTime.Now.ToString("yyyyMMddhhmmss") + i.ToString() + Path.GetExtension(files[i].FileName);
|
|
// 拼接文件保存路径
|
//var filePath = Path.Combine("wwwroot/MouldRecordImage", fileName);
|
|
// 保存文件var stream = new FileStream(filePath, FileMode.Create)
|
using (var stream = new FileStream(filePath, FileMode.Create))
|
{
|
files[i].CopyTo(stream);
|
}
|
//循环写维修记录对应图片表
|
sql = @"insert into TEqp_RepairImage(source_wo,wo_type,img1url)
|
values(@source_wo,@wo_type,@img1url)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
source_wo = wxwo,
|
wo_type = "REPA",
|
img1url = filePath1
|
}
|
});
|
}
|
}
|
|
//写入维修申请记录表
|
sql = @"insert into TEqp_RepairRequest(docu_code,docu_date,status,wksp_code,eqp_code,request_person,request_date,failure_descript,source)
|
values(@docu_code,@docu_date,@status,@wksp_code,@eqp_code,@request_person,@request_date,@failure_descript,@source)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
docu_code = wxwo,
|
docu_date = DateTime.Now.ToString(),
|
status = "REPA",
|
wksp_code = wkshpcode,
|
eqp_code = eqpcode,
|
request_person = us.usercode,
|
request_date = DateTime.Now.ToString(),
|
failure_descript = faultdescr,
|
source = faultsourcecode
|
}
|
});
|
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
//写入操作记录表
|
LogHelper.DbOperateLog(us.usercode, "设备维修申请", "维修申请设备：" + eqpcode, us.usertype);
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "维修申请成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "维修申请失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
|
#region[设备维修上传图片]
|
public static ToMessage UploadImageSave(User us, string type, IFormFileCollection files)
|
{
|
string filePath = "", filePath1 = "";
|
List<string> list = new List<string>();
|
try
|
{
|
|
if (type == "G")
|
{
|
//验证上传图片
|
if (files != null && files.Count > 0)
|
{
|
for (int i = 0; i < files.Count; i++)
|
{
|
|
string imgName = "WX" + DateTime.Now.ToString("yyyyMMddhhmmss") + i.ToString();
|
filePath = "wwwroot/DeviceRecordImage/image1/" + imgName + files[i].FileName; //通过此对象获取文件名(存文件地址)
|
filePath1 = "DeviceRecordImage/image1/" + imgName + files[i].FileName; //通过此对象获取文件名(存数据表地址)
|
// 保存文件var stream = new FileStream(filePath, FileMode.Create)
|
using (var stream = new FileStream(filePath, FileMode.Create))
|
{
|
files[i].CopyTo(stream);
|
}
|
list.Add(filePath1);
|
}
|
}
|
}
|
if (type == "B")
|
{
|
//验证上传图片
|
if (files != null && files.Count > 0)
|
{
|
for (int i = 0; i < files.Count; i++)
|
{
|
string imgName = "WX" + DateTime.Now.ToString("yyyyMMddhhmmss") + i.ToString();
|
filePath = "wwwroot/DeviceRecordImage/image2/" + imgName + files[i].FileName; //通过此对象获取文件名(存文件地址)
|
filePath1 = "DeviceRecordImage/image2/" + imgName + files[i].FileName; //通过此对象获取文件名(存数据表地址)
|
// 保存文件var stream = new FileStream(filePath, FileMode.Create)
|
using (var stream = new FileStream(filePath, FileMode.Create))
|
{
|
files[i].CopyTo(stream);
|
}
|
list.Add(filePath1);
|
}
|
}
|
}
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "图片上传成功!";
|
mes.data = list;
|
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "图片上传失败" + e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备维修删除上传图片]
|
public static ToMessage UploadImageDelete(User us, ObjectModel model)
|
{
|
List<string> list = new List<string>();
|
|
// 清理和验证路径，确保它不会指向不应该被删除的文件或目录
|
// 例如，只允许删除uploads目录下的文件
|
if (!model.url.StartsWith("DeviceRecordImage/"))
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "无效的图片路径!";
|
mes.data = null;
|
return mes;
|
}
|
// 构建完整的文件路径
|
var filePath = Path.Combine("wwwroot", model.url);
|
try
|
{
|
// 检查文件是否存在
|
if (System.IO.File.Exists(filePath))
|
{
|
// 删除文件
|
System.IO.File.Delete(filePath);
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "图片删除成功!";
|
mes.data = null;
|
return mes;
|
}
|
else
|
{
|
// 文件不存在
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "图片不存在!";
|
mes.data = null;
|
return mes;
|
}
|
}
|
catch (Exception ex)
|
{
|
// 捕获异常并返回错误信息
|
// 这里可以记录异常到日志中，以便后续分析
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "删除图片时发生错误:" + ex.Message;
|
mes.data = null;
|
return mes;
|
}
|
}
|
|
#endregion
|
|
#region[设备维修列表]
|
public static ToMessage RepairScanDeviceQrCodeDataList()
|
{
|
string sql = "";
|
try
|
{
|
//获取设备维修列表已申请未维修的数据
|
sql = @"select A.docu_code,B.code as eqpcode,B.name as eqpname,
|
T.torg_code as wksp_code,T.torg_name as wksp_name,
|
A.request_person,A.request_date,
|
(case when A.source='A' then '点检' when A.source='B' then '保养' when A.source='C' then '安灯' when A.source='D' then '手工' end) as source,
|
A.failure_descript
|
from TEqp_RepairRequest A
|
inner join TEqpInfo B on A.eqp_code=B.code
|
inner join TOrganization T on A.wksp_code=T.torg_code
|
where A.status='REPA'";
|
var data = DapperHelper.selecttable(sql);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.message = "暂无维修申请记录!";
|
mes.data = data;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备维修提交]
|
public static ToMessage RepairScanDeviceSave(User us, DeviceUpdate model)
|
{
|
var sql = "";
|
string wxwo = "", numvalue = "";
|
List<object> list = new List<object>();
|
try
|
{
|
list.Clear();
|
mes = SeachEncode.EncodingSeach("2402"); //APP设备维修生成单号
|
if (mes.code == "300")
|
{
|
return mes;
|
}
|
else
|
{
|
List<string> wo = (List<string>)mes.data;
|
wxwo = wo[0].ToString(); //获取单号
|
numvalue = wo[1].ToString(); //获取流水号
|
}
|
if (model.groupimage1.Count > 0)
|
{
|
for (int i = 0; i < model.groupimage1.Count; i++)
|
{
|
//循环写维修记录对应图片表
|
sql = @"insert into TEqp_RepairImage(source_wo,wo_type,img1url)
|
values(@source_wo,@wo_type,@img1url)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
source_wo = wxwo,
|
wo_type = "COMP",
|
img1url = model.groupimage1[i].ToString()
|
}
|
});
|
}
|
}
|
if (model.groupimage2.Count > 0)
|
{
|
for (int i = 0; i < model.groupimage2.Count; i++)
|
{
|
//循环写维修记录对应图片表
|
sql = @"insert into TEqp_RepairImage(source_wo,wo_type,img2url)
|
values(@source_wo,@wo_type,@img2url)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
source_wo = wxwo,
|
wo_type = "COMP",
|
img2url = model.groupimage2[i].ToString()
|
}
|
});
|
}
|
}
|
//写入维修记录表
|
sql = @"insert into TEqp_Repair(repair_code,docu_date,status,wksp_code,eqp_code,repair_person,repair_date,repair_content,repair_part,failure_descript,is_shutdown,source_wo)
|
values(@repair_code,@docu_date,@status,@wksp_code,@eqp_code,@repair_person,@repair_date,@repair_content,@repair_part,@failure_descript,@is_shutdown,@source_wo)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
repair_code = wxwo,
|
docu_date = DateTime.Now.ToString(),
|
status = "COMP",
|
wksp_code = model.wkshpcode,
|
eqp_code = model.eqpcode,
|
repair_person = us.usercode,
|
repair_date = DateTime.Now.ToString(),
|
repair_content = model.repaircontent,
|
repair_part = model.replaceparts,
|
failure_descript = model.faultdescr,
|
is_shutdown = model.is_stoprepair,
|
source_wo = model.docu_code
|
}
|
});
|
//更新维修申请单状态
|
sql = @"update TEqp_RepairRequest set status=@status where docu_code=@docu_code and wksp_code=@wkshpcode and eqp_code=@eqpcode";
|
list.Add(new { str = sql, parm = new { docu_code = model.docu_code, wkshpcode = model.wkshpcode, eqpcode = model.eqpcode, status = "COMP" } });
|
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
//写入操作记录表
|
LogHelper.DbOperateLog(us.usercode, "设备维修", "维修了设备：" + model.eqpcode, us.usertype);
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "维修成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "维修失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
#region[维修验证列表]
|
public static ToMessage RepairVerificationScanDeviceData()
|
{
|
string sql = "";
|
try
|
{
|
//获取设备维修列表已维修的数据
|
sql = @"select A.repair_code,B.code as eqpcode,B.name as eqpname,
|
T.torg_code as wksp_code,T.torg_name as wksp_name,
|
A.repair_person,A.repair_date,A.is_shutdown,
|
A.failure_descript
|
from TEqp_Repair A
|
inner join TEqpInfo B on A.eqp_code=B.code
|
inner join TOrganization T on A.wksp_code=T.torg_code
|
where A.status='COMP'";
|
var data = DapperHelper.selecttable(sql);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.message = "暂无维修记录!";
|
mes.data = data;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[维修验证详情信息]
|
public static ToMessage RepairVerificationScanDeviceDataSub(string repair_code, string eqpcode, string wkshpcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
Dictionary<string, object> dict = new Dictionary<string, object>();
|
try
|
{
|
//根据设备编码\车间编码获取维修详情
|
sql = @"select repair_code,failure_descript,is_shutdown,repair_content,repair_part
|
from TEqp_Repair
|
where repair_code=@repair_code and wksp_code=@wkshpcode and eqp_code=@eqpcode";
|
dynamicParams.Add("@repair_code", repair_code);
|
dynamicParams.Add("@wkshpcode", wkshpcode);
|
dynamicParams.Add("@eqpcode", eqpcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
dict.Add("failure_descript", data.Rows[0]["failure_descript"].ToString()); //故障描述
|
|
//获取故障上传图片
|
sql = @"select img1url from TEqp_RepairImage where source_wo=@source_wo and wo_type='COMP'";
|
dynamicParams.Add("@source_wo", data.Rows[0]["repair_code"].ToString());
|
var data0 = DapperHelper.selectdata(sql, dynamicParams);
|
if (data0.Rows.Count > 0)
|
{
|
dict.Add("failure_descriptimg", data0); //故障上传图片
|
}
|
if (data.Rows[0]["is_shutdown"].ToString() == "N") //是否停机维修
|
{
|
dict.Add("repair_content", data.Rows[0]["repair_content"].ToString()); //维修内容
|
dict.Add("repair_part", data.Rows[0]["repair_part"].ToString()); //更换备件
|
|
//获取更换备件上传图片
|
sql = @"select img2url from TEqp_RepairImage where source_wo=@source_wo and wo_type='COMP'";
|
dynamicParams.Add("@source_wo", data.Rows[0]["repair_code"].ToString());
|
var data1 = DapperHelper.selectdata(sql, dynamicParams);
|
if (data1.Rows.Count > 0)
|
{
|
dict.Add("repair_partimage", data1); //故障上传图片
|
}
|
}
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = dict;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.message = "暂无维修记录!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[维修验证提交]
|
public static ToMessage RepairVerificationScanDeviceSave(User us, string repairwo, string eqpcode, string wkshpcode, string result)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
list.Clear();
|
//根据设备维修单查找源单(维修申请单)
|
sql = @"select source_wo from TEqp_Repair where repair_code=@repairwo";
|
dynamicParams.Add("@repairwo", repairwo);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
//更新设备维修记录验证人员、验证时间、验证结果、验证状态
|
sql = @"update TEqp_Repair set status=@status,is_verifi=@is_verifi,verify_result=@verify_result,verify_person=@verify_person,verify_date=@verify_date
|
where repair_code=@repair_code and wksp_code=@wksp_code and eqp_code=@eqp_code";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
status = "CONFIR",
|
is_verifi = "Y",
|
verify_result = result,
|
verify_person = us.usercode,
|
verify_date = DateTime.Now.ToString(),
|
repair_code = repairwo,
|
wksp_code = wkshpcode,
|
eqp_code = eqpcode
|
}
|
});
|
//更新维修申请单状态
|
sql = @"update TEqp_RepairRequest set status=@status where docu_code=@docu_code and wksp_code=@wkshpcode and eqp_code=@eqpcode";
|
list.Add(new { str = sql, parm = new { docu_code = data.Rows[0]["source_wo"].ToString(), wkshpcode = wkshpcode, eqpcode = eqpcode, status = "CONFIR" } });
|
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.message = "维修验证成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = "维修验证失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
|
#region[设备点检记录查询]
|
public static ToMessage DeviceCheckTakeSearch(User us, string wkshopcode, string eqpcode, string eqpname, string stanedname, string checkuser, string checkopendate, string checkclosedate, int startNum, int endNum, string prop, string order)
|
{
|
var dynamicParams = new DynamicParameters();
|
string search = "";
|
try
|
{
|
if (wkshopcode != "" && wkshopcode != null)
|
{
|
search += "and T.torg_code=@wkshopcode ";
|
dynamicParams.Add("@wkshopcode", wkshopcode);
|
}
|
if (eqpcode != "" && eqpcode != null)
|
{
|
search += "and A.eqp_code like '%'+@eqpcode+'%' ";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
}
|
if (eqpname != "" && eqpname != null)
|
{
|
search += "and E.name like '%'+@eqpname+'%' ";
|
dynamicParams.Add("@eqpname", eqpname);
|
}
|
if (stanedname != "" && stanedname != null)
|
{
|
search += "and M.name like '%'+@stanedname+'%' ";
|
dynamicParams.Add("@stanedname", stanedname);
|
}
|
if (checkuser != "" && checkuser != null)
|
{
|
search += "and A.chk_user like '%'+@checkuser+'%' ";
|
dynamicParams.Add("@checkuser", checkuser);
|
}
|
if (checkopendate != "" && checkopendate != null)
|
{
|
search += "and A.chk_date between @checkopendate and @checkclosedate ";
|
dynamicParams.Add("@checkopendate", checkopendate + " 00:00:00");
|
dynamicParams.Add("@checkclosedate", checkclosedate + " 23:59:59");
|
}
|
if (search == "")
|
{
|
search = "and 1=1 ";
|
}
|
//search = search.Substring(3);//截取索引2后面的字符
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select A.djwo,T.torg_code,T.torg_name,A.eqp_code,E.name as eqp_name,M.code as stanedcode,M.name as stanedname,
|
A.chk_user,A.chk_result,A.chk_date
|
from TEqpchk_Proc_Main A
|
left join TEqpInfo E on A.eqp_code=E.code
|
left join TEqpchk_Main M on A.eqpchkmain_code=M.code
|
left join TOrganization T on E.torg_code=T.torg_code
|
where 1=1 " + search;
|
var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.count = total;
|
mes.data = data.ToList();
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备点检记录明细查询]
|
public static ToMessage DeviceCheckSubTakeSearch(string djwo)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
sql = @"select A.seq,T.code as itemcode,T.name as itemname,A.result,A.chk_value,A.remark
|
from TEqpchk_Proc_Deta A
|
left join TEqpchk_Item T on A.eqpchkdeta_code=T.code
|
where A.djwo=@djwo";
|
dynamicParams.Add("@djwo", djwo);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备点检记录导出]
|
public static ToMessage DeviceCheckTakeOutExcel(User us, string wkshopcode, string eqpcode, string eqpname, string stanedname, string checkuser, string checkopendate, string checkclosedate)
|
{
|
var dynamicParams = new DynamicParameters();
|
string search = "";
|
try
|
{
|
if (wkshopcode != "" && wkshopcode != null)
|
{
|
search += "and T.torg_code=@wkshopcode ";
|
dynamicParams.Add("@wkshopcode", wkshopcode);
|
}
|
if (eqpcode != "" && eqpcode != null)
|
{
|
search += "and A.eqp_code like '%'+@eqpcode+'%' ";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
}
|
if (eqpname != "" && eqpname != null)
|
{
|
search += "and E.name like '%'+@eqpname+'%' ";
|
dynamicParams.Add("@eqpname", eqpname);
|
}
|
if (stanedname != "" && stanedname != null)
|
{
|
search += "and M.name like '%'+@stanedname+'%' ";
|
dynamicParams.Add("@stanedname", stanedname);
|
}
|
if (checkuser != "" && checkuser != null)
|
{
|
search += "and A.chk_user like '%'+@checkuser+'%' ";
|
dynamicParams.Add("@checkuser", checkuser);
|
}
|
if (checkopendate != "" && checkopendate != null)
|
{
|
search += "and A.chk_date between @checkopendate and @checkclosedate ";
|
dynamicParams.Add("@checkopendate", checkopendate + " 00:00:00");
|
dynamicParams.Add("@checkclosedate", checkclosedate + " 23:59:59");
|
}
|
if (search == "")
|
{
|
search = "and 1=1 ";
|
}
|
//search = search.Substring(3);//截取索引2后面的字符
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.djwo ORDER BY B.eqpchkdeta_code) = 1 THEN A.djwo
|
ELSE ''END AS '点检单号',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY E.torg_code ORDER BY B.eqpchkdeta_code) = 1 THEN T.torg_name
|
ELSE ''END AS '生产车间',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.eqp_code ORDER BY B.eqpchkdeta_code) = 1 THEN A.eqp_code
|
ELSE ''END AS '设备编号',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.eqp_code ORDER BY B.eqpchkdeta_code) = 1 THEN E.name
|
ELSE ''END AS '设备名称',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.eqpchkmain_code ORDER BY B.eqpchkdeta_code) = 1 THEN A.eqpchkmain_code
|
ELSE ''END AS '点检标准编码',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.eqpchkmain_code ORDER BY B.eqpchkdeta_code) = 1 THEN M.name
|
ELSE ''END AS '点检标准名称',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.chk_user ORDER BY B.eqpchkdeta_code) = 1 THEN A.chk_user
|
ELSE ''END AS '检验人员',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.chk_result ORDER BY B.eqpchkdeta_code) = 1 THEN A.chk_result
|
ELSE ''END AS '检验结果',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.chk_date ORDER BY B.eqpchkdeta_code) = 1 THEN A.chk_date
|
END AS '检验时间',
|
B.seq as '点检部位序号',H.code '点检部位编码',H.name '点检部位名称',B.result '点检结果',B.chk_value '数值',B.remark '备注'
|
from TEqpchk_Proc_Main A
|
left join TEqpchk_Proc_Deta B on A.djwo=B.djwo
|
left join TEqpInfo E on A.eqp_code=E.code
|
left join TEqpchk_Main M on A.eqpchkmain_code=M.code
|
left join TOrganization T on E.torg_code=T.torg_code
|
left join TEqpchk_Item H on B.eqpchkdeta_code=H.code
|
where 1=1 " + search;
|
DataTable data = DapperHelper.selectdata(sql, dynamicParams);
|
data.TableName = "Table"; //设置DataTable的名称
|
string msg = DownLoad.DataTableToExcel(data, "工序检验记录");
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.count = total;
|
mes.data = msg;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
|
#region[设备保养记录查询]
|
public static ToMessage DeviceCheckTakeSearch(User us, string wkshopcode, string eqpcode, string eqpname, string stanedname, string repairuser, string repairopendate, string repairclosedate, string repairresult, int startNum, int endNum, string prop, string order)
|
{
|
var dynamicParams = new DynamicParameters();
|
string search = "";
|
try
|
{
|
if (wkshopcode != "" && wkshopcode != null)
|
{
|
search += "and T.torg_code=@wkshopcode ";
|
dynamicParams.Add("@wkshopcode", wkshopcode);
|
}
|
if (eqpcode != "" && eqpcode != null)
|
{
|
search += "and A.eqp_code like '%'+@eqpcode+'%' ";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
}
|
if (eqpname != "" && eqpname != null)
|
{
|
search += "and E.name like '%'+@eqpname+'%' ";
|
dynamicParams.Add("@eqpname", eqpname);
|
}
|
if (stanedname != "" && stanedname != null)
|
{
|
search += "and M.name like '%'+@stanedname+'%' ";
|
dynamicParams.Add("@stanedname", stanedname);
|
}
|
if (repairuser != "" && repairuser != null)
|
{
|
search += "and A.maint_user like '%'+@repairuser+'%' ";
|
dynamicParams.Add("@repairuser", repairuser);
|
}
|
if (repairopendate != "" && repairopendate != null)
|
{
|
search += "and A.maint_date between @repairopendate and @repairclosedate ";
|
dynamicParams.Add("@repairopendate", repairopendate + " 00:00:00");
|
dynamicParams.Add("@repairclosedate", repairclosedate + " 23:59:59");
|
}
|
if (repairresult != "" && repairresult != null)
|
{
|
search += "and A.maint_result=@repairresult ";
|
dynamicParams.Add("@repairresult", repairresult);
|
}
|
if (search == "")
|
{
|
search = "and 1=1 ";
|
}
|
//search = search.Substring(3);//截取索引2后面的字符
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select A.bywo,T.torg_code,T.torg_name,A.eqp_code,E.name as eqp_name,M.code as stanedcode,M.name as stanedname,A.maint_cyc,
|
A.maint_user,A.maint_result,A.maint_date
|
from TEqpmaint_Proc_Main A
|
left join TEqpInfo E on A.eqp_code=E.code
|
left join TEqpmai_Main M on A.eqpmaint_code=M.code
|
left join TOrganization T on E.torg_code=T.torg_code
|
where 1=1 " + search;
|
var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.count = total;
|
mes.data = data.ToList();
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备保养记录明细查询]
|
public static ToMessage DeviceRepairSubTakeSearch(string bywo)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
sql = @"select A.seq,T.code as itemcode,T.name as itemname,A.result,A.maint_value,A.remark
|
from TEqpmaint_Proc_Deta A
|
left join TEqpmai_Item T on A.eqpmaideta_code=T.code
|
where A.bywo=@bywo";
|
dynamicParams.Add("@bywo", bywo);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = data;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备保养记录导出]
|
public static ToMessage DeviceRepairTakeOutExcel(User us, string wkshopcode, string eqpcode, string eqpname, string stanedname, string repairuser, string repairopendate, string repairclosedate, string repairresult)
|
{
|
var dynamicParams = new DynamicParameters();
|
string search = "";
|
try
|
{
|
if (wkshopcode != "" && wkshopcode != null)
|
{
|
search += "and T.torg_code=@wkshopcode ";
|
dynamicParams.Add("@wkshopcode", wkshopcode);
|
}
|
if (eqpcode != "" && eqpcode != null)
|
{
|
search += "and A.eqp_code like '%'+@eqpcode+'%' ";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
}
|
if (eqpname != "" && eqpname != null)
|
{
|
search += "and E.name like '%'+@eqpname+'%' ";
|
dynamicParams.Add("@eqpname", eqpname);
|
}
|
if (stanedname != "" && stanedname != null)
|
{
|
search += "and M.name like '%'+@stanedname+'%' ";
|
dynamicParams.Add("@stanedname", stanedname);
|
}
|
if (repairuser != "" && repairuser != null)
|
{
|
search += "and A.maint_user like '%'+@repairuser+'%' ";
|
dynamicParams.Add("@repairuser", repairuser);
|
}
|
if (repairopendate != "" && repairopendate != null)
|
{
|
search += "and A.chk_date between @repairopendate and @repairclosedate ";
|
dynamicParams.Add("@repairopendate", repairopendate + " 00:00:00");
|
dynamicParams.Add("@repairclosedate", repairclosedate + " 23:59:59");
|
}
|
if (repairresult != "" && repairresult != null)
|
{
|
search += "and A.maint_result=@repairresult ";
|
dynamicParams.Add("@repairresult", repairresult);
|
}
|
if (search == "")
|
{
|
search = "and 1=1 ";
|
}
|
//search = search.Substring(3);//截取索引2后面的字符
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.bywo ORDER BY B.eqpmaideta_code) = 1 THEN A.bywo
|
ELSE ''END AS '保养单号',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY E.torg_code ORDER BY B.eqpmaideta_code) = 1 THEN T.torg_name
|
ELSE ''END AS '生产车间',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.eqp_code ORDER BY B.eqpmaideta_code) = 1 THEN A.eqp_code
|
ELSE ''END AS '设备编号',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.eqp_code ORDER BY B.eqpmaideta_code) = 1 THEN E.name
|
ELSE ''END AS '设备名称',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.eqpmaint_code ORDER BY B.eqpmaideta_code) = 1 THEN A.eqpmaint_code
|
ELSE ''END AS '保养标准编码',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.eqpmaint_code ORDER BY B.eqpmaideta_code) = 1 THEN M.name
|
ELSE ''END AS '保养标准名称',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.maint_cyc ORDER BY B.eqpmaideta_code) = 1 THEN A.maint_cyc
|
ELSE ''END AS '保养周期',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.maint_user ORDER BY B.eqpmaideta_code) = 1 THEN A.maint_user
|
ELSE ''END AS '保养人员',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.maint_result ORDER BY B.eqpmaideta_code) = 1 THEN A.maint_result
|
ELSE ''END AS '保养结果',
|
CASE WHEN
|
ROW_NUMBER() OVER (PARTITION BY A.maint_date ORDER BY B.eqpmaideta_code) = 1 THEN A.maint_date
|
END AS '保养时间',
|
B.seq as '保养部位序号',H.code '保养部位编码',H.name '保养部位名称',B.result '保养结果',B.maint_value '数值',B.remark '备注'
|
from TEqpmaint_Proc_Main A
|
left join TEqpmaint_Proc_Deta B on A.bywo=B.bywo
|
left join TEqpInfo E on A.eqp_code=E.code
|
left join TEqpmai_Main M on A.eqpmaint_code=M.code
|
left join TOrganization T on E.torg_code=T.torg_code
|
left join TEqpmai_Item H on B.eqpmaideta_code=H.code
|
where 1=1 " + search;
|
DataTable data = DapperHelper.selectdata(sql, dynamicParams);
|
data.TableName = "Table"; //设置DataTable的名称
|
string msg = DownLoad.DataTableToExcel(data, "工序检验记录");
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.count = total;
|
mes.data = msg;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
|
|
#region[设备维修记录查询]
|
public static ToMessage DeviceUpdateSearch(User us, string wkshopcode, string eqpcode, string eqpname, string reportuser, string repairuser, string vrifcatuser, string reportopendate, string reportclosedate, string repairopendate, string repairclosedate, string vrifcatopendate, string vrifcatclosedate, int startNum, int endNum, string prop, string order)
|
{
|
var dynamicParams = new DynamicParameters();
|
string search = "";
|
try
|
{
|
if (wkshopcode != "" && wkshopcode != null)
|
{
|
search += "and A.wksp_code=@wkshopcode ";
|
dynamicParams.Add("@wkshopcode", wkshopcode);
|
}
|
if (eqpcode != "" && eqpcode != null)
|
{
|
search += "and A.eqp_code like '%'+@eqpcode+'%' ";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
}
|
if (eqpname != "" && eqpname != null)
|
{
|
search += "and E.name like '%'+@eqpname+'%' ";
|
dynamicParams.Add("@eqpname", eqpname);
|
}
|
if (reportuser != "" && reportuser != null)
|
{
|
search += "and B.request_person like '%'+@reportuser+'%' ";
|
dynamicParams.Add("@reportuser", reportuser);
|
}
|
if (repairuser != "" && repairuser != null)
|
{
|
search += "and A.repair_person like '%'+@repairuser+'%' ";
|
dynamicParams.Add("@repairuser", repairuser);
|
}
|
if (vrifcatuser != "" && vrifcatuser != null)
|
{
|
search += "and A.verify_person like '%'+@vrifcatuser+'%' ";
|
dynamicParams.Add("@vrifcatuser", vrifcatuser);
|
}
|
if (reportopendate != "" && reportopendate != null)
|
{
|
search += "and B.request_date between @reportopendate and @reportclosedate ";
|
dynamicParams.Add("@reportopendate", reportopendate + " 00:00:00");
|
dynamicParams.Add("@reportclosedate", reportclosedate + " 23:59:59");
|
}
|
if (repairopendate != "" && repairopendate != null)
|
{
|
search += "and A.repair_date between @repairopendate and @repairclosedate ";
|
dynamicParams.Add("@repairopendate", repairopendate + " 00:00:00");
|
dynamicParams.Add("@repairclosedate", repairclosedate + " 23:59:59");
|
}
|
if (vrifcatopendate != "" && vrifcatopendate != null)
|
{
|
search += "and A.verify_date between @vrifcatopendate and @vrifcatclosedate ";
|
dynamicParams.Add("@vrifcatopendate", vrifcatopendate + " 00:00:00");
|
dynamicParams.Add("@vrifcatclosedate", vrifcatclosedate + " 23:59:59");
|
}
|
|
if (search == "")
|
{
|
search = "and 1=1 ";
|
}
|
//search = search.Substring(3);//截取索引2后面的字符
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select A.repair_code,A.wksp_code,T.torg_name as wksp_name,A.eqp_code,E.name as eqp_name,B.request_person,B.request_date,
|
A.repair_person,A.repair_date,CAST(datediff(minute, B.request_date,A.repair_date)/60.0 AS decimal(9,1)) as cycleDate,
|
A.verify_person,A.verify_date,(case when A.verify_result='OK' then '通过' when A.verify_result='NG' then '不通过' end)as verify_result
|
from TEqp_Repair A
|
left join TEqp_RepairRequest B on A.source_wo=B.docu_code
|
left join TEqpInfo E on A.eqp_code=E.code
|
left join TOrganization T on A.wksp_code=T.torg_code
|
where 1=1 " + search;
|
var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.count = total;
|
mes.data = data.ToList();
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备维修记录明细查询]
|
public static ToMessage DeviceUpdateSubSearch(string repair_code)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
Dictionary<object, object> Dict = new Dictionary<object, object>();
|
try
|
{
|
//获取设备报修申请数据
|
sql = @"select B.docu_code,
|
(
|
case when B.source='A' then '设备点检'
|
when B.source='B' then '设备保养'
|
when B.source='C' then '安灯呼叫'
|
when B.source='C' then '手工创建' end
|
) as source,B.failure_descript from TEqp_Repair A
|
left join TEqp_RepairRequest B on A.source_wo=B.docu_code
|
where A.repair_code=@repair_code";
|
dynamicParams.Add("@repair_code", repair_code);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
DeviceReport report = new DeviceReport();
|
report.faultsource = data.Rows[0]["source"].ToString();
|
report.faultdescr = data.Rows[0]["failure_descript"].ToString();
|
//获取设备报修申请图片数据
|
sql = @"select M.img1url from TEqp_Repair A
|
left join TEqp_RepairRequest B on A.source_wo=B.docu_code
|
left join TEqp_RepairImage M on B.docu_code=M.source_wo
|
where A.repair_code=@repair_code and M.wo_type='REPA'";
|
dynamicParams.Add("@repair_code", repair_code);
|
var data0 = DapperHelper.selectdata(sql, dynamicParams);
|
report.faultimage = data0;
|
Dict.Add("data1", report);
|
|
//获取设备维修数据
|
sql = @"select A.failure_descript,A.is_shutdown,A.repair_content,A.repair_part from TEqp_Repair A
|
left join TEqp_RepairRequest B on A.source_wo=B.docu_code
|
where A.repair_code=@repair_code";
|
dynamicParams.Add("@repair_code", repair_code);
|
var data1 = DapperHelper.selectdata(sql, dynamicParams);
|
DeviceRepair repair = new DeviceRepair();
|
repair.faultdescr = data1.Rows[0]["failure_descript"].ToString();
|
repair.isstoprepair = data1.Rows[0]["is_shutdown"].ToString();
|
repair.repaircontent = data1.Rows[0]["repair_content"].ToString();
|
repair.repairpart = data1.Rows[0]["repair_part"].ToString();
|
//获取设备维修图片数据
|
sql = @"select M.img1url,M.img2url from TEqp_Repair A
|
left join TEqp_RepairImage M on A.repair_code=M.source_wo
|
where A.repair_code=@repair_code and M.wo_type='COMP'";
|
dynamicParams.Add("@repair_code", repair_code);
|
var data3 = DapperHelper.selectdata(sql, dynamicParams);
|
repair.repairimage = data3;
|
Dict.Add("data2", repair);
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = Dict;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[设备维修记录导出]
|
public static ToMessage DeviceUpdateOutExcel(User us, string wkshopcode, string eqpcode, string eqpname, string reportuser, string repairuser, string vrifcatuser, string reportopendate, string reportclosedate, string repairopendate, string repairclosedate, string vrifcatopendate, string vrifcatclosedate)
|
{
|
var dynamicParams = new DynamicParameters();
|
string search = "";
|
try
|
{
|
if (wkshopcode != "" && wkshopcode != null)
|
{
|
search += "and A.wksp_code=@wkshopcode ";
|
dynamicParams.Add("@wkshopcode", wkshopcode);
|
}
|
if (eqpcode != "" && eqpcode != null)
|
{
|
search += "and A.eqp_code like '%'+@eqpcode+'%' ";
|
dynamicParams.Add("@eqpcode", eqpcode);
|
}
|
if (eqpname != "" && eqpname != null)
|
{
|
search += "and E.name like '%'+@eqpname+'%' ";
|
dynamicParams.Add("@eqpname", eqpname);
|
}
|
if (reportuser != "" && reportuser != null)
|
{
|
search += "and B.request_person like '%'+@reportuser+'%' ";
|
dynamicParams.Add("@reportuser", reportuser);
|
}
|
if (repairuser != "" && repairuser != null)
|
{
|
search += "and A.repair_person like '%'+@repairuser+'%' ";
|
dynamicParams.Add("@repairuser", repairuser);
|
}
|
if (vrifcatuser != "" && vrifcatuser != null)
|
{
|
search += "and A.verify_person like '%'+@vrifcatuser+'%' ";
|
dynamicParams.Add("@vrifcatuser", vrifcatuser);
|
}
|
if (reportopendate != "" && reportopendate != null)
|
{
|
search += "and B.request_date between @reportopendate and @reportclosedate ";
|
dynamicParams.Add("@reportopendate", reportopendate + " 00:00:00");
|
dynamicParams.Add("@reportclosedate", reportclosedate + " 23:59:59");
|
}
|
if (repairopendate != "" && repairopendate != null)
|
{
|
search += "and A.repair_date between @repairopendate and @repairclosedate ";
|
dynamicParams.Add("@repairopendate", repairopendate + " 00:00:00");
|
dynamicParams.Add("@repairclosedate", repairclosedate + " 23:59:59");
|
}
|
if (vrifcatopendate != "" && vrifcatopendate != null)
|
{
|
search += "and A.verify_date between @vrifcatopendate and @vrifcatclosedate ";
|
dynamicParams.Add("@vrifcatopendate", vrifcatopendate + " 00:00:00");
|
dynamicParams.Add("@vrifcatclosedate", vrifcatclosedate + " 23:59:59");
|
}
|
|
if (search == "")
|
{
|
search = "and 1=1 ";
|
}
|
//search = search.Substring(3);//截取索引2后面的字符
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select
|
A.repair_code as '维修单号',
|
T.torg_name as '所属车间',
|
A.eqp_code as '设备编码',
|
E.name as '设备名称',
|
B.request_person as '报修人员',
|
B.request_date as '报修时间',
|
A.repair_person as '维修人员',
|
A.repair_date as '维修时间',
|
CAST(datediff(minute, B.request_date,A.repair_date)/60.0 AS decimal(9,1)) as '维修时长(小时)',
|
A.verify_person as '验证人员',
|
A.verify_date as '验证时间',
|
(case when A.verify_result='OK' then '通过' when A.verify_result='NG' then '不通过' end)as '验证结果'
|
from TEqp_Repair A
|
left join TEqp_RepairRequest B on A.source_wo=B.docu_code
|
left join TEqpInfo E on A.eqp_code=E.code
|
left join TOrganization T on A.wksp_code=T.torg_code
|
where 1=1 " + search;
|
DataTable data = DapperHelper.selectdata(sql, dynamicParams);
|
data.TableName = "Table"; //设置DataTable的名称
|
string msg = DownLoad.DataTableToExcel(data, "设备维修记录");
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.count = total;
|
mes.data = msg;
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
}
|
}
|
