using Dapper;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Data.SqlClient;
|
using System.Linq;
|
using System.Threading.Tasks;
|
using VueWebCoreApi.Models;
|
using VueWebCoreApi.Tools;
|
|
namespace VueWebCoreApi.DLL.DAL
|
{
|
public class AppAnDonDAL
|
{
|
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 AppAnDonCallScanSearch(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 AppAnDonCallItemSearch(string eqpcode, string wkshpcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
List<AnDnDate> list = new List<AnDnDate>();
|
try
|
{
|
//根据车间代码查找呼叫类型数据
|
sql = @"select A.id,B.code,B.name,(case when F.type is null then 'N' else 'Y' end) flag
|
from TAnDon_Roul_ConFig A
|
inner join TAnDonType B on A.andotype_code=B.code
|
inner join TEqpInfo E on A.wkshp_code=e.torg_code
|
left join(
|
select type,wkshp_code,eqp_code from TAnDon_Task_Info where eqp_code=@eqpcode and wkshp_code=@wkshpcode and status='START'
|
) F on A.wkshp_code=F.wkshp_code and E.code=F.eqp_code and B.code=F.type
|
where A.wkshp_code=@wkshpcode and E.code=@eqpcode and A.enable='N'";
|
dynamicParams.Add("@wkshpcode", wkshpcode);
|
dynamicParams.Add("@eqpcode", eqpcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
for (int i = 0; i < data.Rows.Count; i++)
|
{
|
AnDnDate mn = new AnDnDate();
|
mn.code = data.Rows[i]["CODE"].ToString();
|
mn.name = data.Rows[i]["NAME"].ToString();
|
mn.flag = data.Rows[i]["FLAG"].ToString();
|
mn.children = new List<AnDnDateSub>();
|
//根据呼叫类型id查找绑定人员
|
sql = @"select U.usercode,U.username,U.rid
|
from TAnDon_Roul_ConFigUser A
|
inner join TUser U on A.usercode=U.usercode
|
where A.ando_cogfigid=@id";
|
dynamicParams.Add("@id", data.Rows[i]["ID"].ToString());
|
var data0 = DapperHelper.selectdata(sql, dynamicParams);
|
if (data0.Rows.Count > 0)
|
{
|
for (int j = 0; j < data0.Rows.Count; j++)
|
{
|
AnDnDateSub sn = new AnDnDateSub();
|
sn.rid = data0.Rows[j]["RID"].ToString();//rid
|
sn.alias = data0.Rows[j]["RID"].ToString() + data0.Rows[j]["USERCODE"].ToString(); //别名
|
sn.usercode = data0.Rows[j]["USERCODE"].ToString();
|
sn.username = data0.Rows[j]["USERNAME"].ToString();
|
mn.children.Add(sn);
|
}
|
}
|
list.Add(mn);
|
}
|
mes.code = "200";
|
mes.message = "查询成功!";
|
mes.data = list;
|
}
|
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 AppAnDonCallSave(User us, string eqpcode, string wkshpcode, List<AnDnDate> json)
|
{
|
string sql = "";
|
int AnDnID = 0; //最大id
|
var dynamicParams = new DynamicParameters();
|
List<object> list = new List<object>();
|
List<string> list1 = new List<string>();
|
try
|
{
|
list.Clear();
|
//获取主表最大ID
|
AnDnID = DapperHelper.insertReturnId("TAnDon_Task_Info");
|
for (int i = 0; i < json.Count; i++)
|
{
|
AnDnID = AnDnID + 1;//自增1
|
string code = json[i].code.ToString();
|
string name = json[i].name.ToString();
|
sql = @"select * from TAnDon_Task_Info where wkshp_code=@wkshpcode and eqp_code=@eqpcode and type=@typecode and status='START'";
|
dynamicParams.Add("@wkshpcode", wkshpcode);
|
dynamicParams.Add("@eqpcode", eqpcode);
|
dynamicParams.Add("@typecode", code);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.message = "当前设备已经呼叫【" + name + "】,请先响应!";
|
mes.data = null;
|
return mes;
|
}
|
else
|
{
|
//写入安灯呼叫表
|
sql = @"insert into TAnDon_Task_Info(wkshp_code,eqp_code,type,start_date,start_user,status)
|
values(@wkshp_code,@eqp_code,@type,@start_date,@start_user,@status)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
wkshp_code = wkshpcode,
|
eqp_code = eqpcode,
|
type = code,
|
start_date = DateTime.Now.ToString(),
|
start_user = us.usercode,
|
status = "START"
|
}
|
});
|
|
//for (int j = 0; j < json[i].children.Count; j++)
|
//{
|
// //写入安灯记录推送人员表
|
// sql = @"insert into TAnDnMessagePush(m_id,wkshp_code,eqp_code,type,resp_user,status)
|
// values(@m_id,@wkshp_code,@eqp_code,@type,@resp_user,@status)";
|
// list.Add(new
|
// {
|
// str = sql,
|
// parm = new
|
// {
|
// m_id = AnDnID,
|
// //m_id = int.Parse(dt.Rows[0]["ID"].ToString()),
|
// wkshp_code = wkshpcode,
|
// eqp_code = eqpcode,
|
// type = code,
|
// resp_user = json[i].children[j].usercode,
|
// alias = json[i].children[j].alias,
|
// status = "N"
|
// }
|
// });
|
//}
|
}
|
}
|
//极光推送
|
//mes = JPushManage.ExecutePushByUserId(us.usercode, wkshpcode, eqpcode, json);
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
//写入操作记录表
|
LogHelper.DbOperateLog(us.usercode, "安灯呼叫", "呼叫了:" + string.Join(",", json.Select(item => item.name)), 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 AppAnDonLampResponseScanSearch(string eqpcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取对应设备及所属车间的安灯呼叫记录
|
sql = @"select A.eqp_code,B.name as eqp_name,T.torg_code as wksp_code,T.torg_name as wksp_name,A.type as typecode,D.name as typename
|
from TAnDon_Task_Info A
|
left join TEqpInfo B on A.eqp_code=B.code
|
left join TOrganization T on B.torg_code=T.torg_code
|
left join TAnDonType D on A.type=D.code
|
where A.eqp_code=@eqpcode and A.status='START' and B.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 AppAnDonLampResponseSave(User us, string eqpcode, string wkshpcode, List<ObjectData> json)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
List<object> list = new List<object>();
|
try
|
{
|
list.Clear();
|
for (int i = 0; i < json.Count; i++)
|
{
|
string code = json[i].code.ToString();
|
string name = json[i].name.ToString();
|
//更新安灯呼叫表
|
sql = @"update TAnDon_Task_Info set resp_user=@resp_user,resp_date=@resp_date,status='CLOSED',taking=cast ( cast ( datediff ( ss, start_date, @resp_date) / ( 60 * 60 * 24 ) as int ) as varchar ) + '天' +
|
cast ( cast ( datediff ( ss, start_date, @resp_date ) % 86400 / 3600 as int ) as varchar ) + '小时' +
|
cast ( cast ( datediff ( ss, start_date, @resp_date ) % 3600 / 60 as int ) as varchar ) + '分' +
|
cast ( cast ( datediff ( ss, start_date, @resp_date ) % 60 as int ) as varchar ) + '秒'
|
where wkshp_code=@wkshp_code and eqp_code=@eqp_code and type=@type and status='START'";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
wkshp_code = wkshpcode,
|
eqp_code = eqpcode,
|
type = code,
|
resp_date = DateTime.Now.ToString(),
|
resp_user = us.usercode,
|
status = "START"
|
}
|
});
|
}
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
LogHelper.DbOperateLog(us.usercode, "安灯响应", "响应了:" + string.Join(",", json.Select(item => item.name)), 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
|
}
|
}
|
