using Dapper;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Data.SqlClient;
|
using System.Linq;
|
using System.Web;
|
using VueWebApi.Models;
|
using VueWebApi.Tools;
|
|
namespace VueWebApi.DLL.DAL
|
{
|
public class ProductionManagementDAL
|
{
|
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[ERP订单查询]
|
public static ToMessage ErpOrderSearch(string erporderstus, string erpordercode, string partcode, string partname, string partspec, int startNum, string paydatestartdate, string paydateenddate, string paydatestartdate1, string paydateenddate2, string creatuser, int endNum, string prop, string order)
|
{
|
var dynamicParams = new DynamicParameters();
|
string search = "";
|
try
|
{
|
if (erporderstus != "" && erporderstus != null)
|
{
|
search += "and A.status=@erporderstus ";
|
dynamicParams.Add("@erporderstus", erporderstus);
|
}
|
if (erpordercode != "" && erpordercode != null)
|
{
|
search += "and A.wo like '%'+@erpordercode+'%' ";
|
dynamicParams.Add("@erpordercode", erpordercode);
|
}
|
if (partcode != "" && partcode != null)
|
{
|
search += "and A.materiel_code like '%'+@partcode+'%' ";
|
dynamicParams.Add("@partcode", partcode);
|
}
|
if (partname != "" && partname != null)
|
{
|
search += "and B.partname like '%'+@partname+'%' ";
|
dynamicParams.Add("@partname", partname);
|
}
|
if (partspec != "" && partspec != null)
|
{
|
search += "and B.partspec like '%'+@partspec+'%' ";
|
dynamicParams.Add("@partspec", partspec);
|
}
|
if (paydatestartdate != "" && paydatestartdate != null)
|
{
|
search += "and A.planstartdate between @paydatestartdate and @paydateenddate ";
|
dynamicParams.Add("@paydatestartdate", paydatestartdate + " 00:00:00");
|
dynamicParams.Add("@paydateenddate", paydateenddate + " 23:59:59");
|
}
|
if (paydatestartdate1 != "" && paydatestartdate1 != null)
|
{
|
search += "and A.planenddate between @paydatestartdate1 and @paydateenddate2 ";
|
dynamicParams.Add("@paydatestartdate1", paydatestartdate1);
|
dynamicParams.Add("@paydateenddate2", paydateenddate2 + " 23:59:59");
|
}
|
if (creatuser != "" && creatuser != null)
|
{
|
search += "and U.username like '%'+@creatuser+'%' ";
|
dynamicParams.Add("@creatuser", creatuser);
|
}
|
|
if (search == "")
|
{
|
search = "and 1=1 ";
|
}
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select A.id, A.status,A.wo,A.materiel_code as partcode,B.partname,B.partspec,A.qty,A.relse_qty,A.wkshp_code,C.org_name as wkshp_name,
|
A.stck_code,D.name as stck_name,A.planstartdate,A.planenddate,U.username as createuser,A.createdate
|
from TKimp_Ewo A
|
left join TMateriel_Info B on A.materiel_code=B.partcode
|
left join TOrganization C on A.wkshp_code=C.org_code
|
left join T_Sec_Stck D on A.stck_code=D.code
|
left join TUser U on A.createuser=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[ERP订单下达]
|
public static ToMessage MarkSaveErpOrder(string erporderid, string erpordercode, string partcode, string wkshopcode, string warehousecode, string erpqty, string markqty, string ordernum, string relse_qty, string username)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
list.Clear();
|
//获取拆单数量:向下取整
|
decimal cdqty = Math.Floor(decimal.Parse(markqty) / decimal.Parse(ordernum));
|
//定义累计下单数量
|
decimal sumqty = 0;
|
//定义最新生成的工单号
|
string wo = "";
|
//定义工单流水号
|
int num = 0;
|
//循环下单单数(生成对应几张MES工单)
|
for (int i = 1; i <= Convert.ToInt32(ordernum); i++)
|
{
|
sumqty += cdqty;
|
//获取最大单据号
|
if (i == 1) //首单获取工单号
|
{
|
sql = @"select isnull(max(substring(wo_code,charindex('_',wo_code)+1,len(wo_code)-charindex('_',wo_code))),0)+1 as worknumb from TK_Wrk_Man where m_po=@erpordercode";
|
dynamicParams.Add("@erpordercode", erpordercode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
num = Convert.ToInt32(data.Rows[0]["WORKNUMB"].ToString());
|
wo = erpordercode + "_" + num;
|
}
|
else
|
{
|
num = num + 1;
|
wo = erpordercode + "_" + num;
|
}
|
if (i == Convert.ToInt32(ordernum)) //最后一单时
|
{
|
sql = @"insert into TK_Wrk_Man(wo_code,status,wkshp_code,plan_qty,stck_code,materiel_code,m_po,lm_user,lm_date) values(@wo_code,@status,@wkshp_code,@plan_qty,@stck_code,@materiel_code,@m_po,@username,@CreateDate)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
wo_code = wo,
|
status = "NEW",
|
wkshp_code = wkshopcode,
|
plan_qty = cdqty + (decimal.Parse(markqty) - sumqty), //末单下单数量=切分数量+(下单数量-累计切分下单数量)
|
stck_code = warehousecode,
|
materiel_code = partcode,
|
m_po = erpordercode,
|
username = username,
|
CreateDate = DateTime.Now.ToString()
|
}
|
});
|
sumqty = sumqty + (decimal.Parse(markqty) - sumqty);
|
}
|
else
|
{
|
|
sql = @"insert into TK_Wrk_Man(wo_code,status,wkshp_code,plan_qty,stck_code,materiel_code,m_po,lm_user,lm_date) values(@wo_code,@status,@wkshp_code,@plan_qty,@stck_code,@materiel_code,@m_po,@username,@CreateDate)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
wo_code = wo,
|
status = "NEW",
|
wkshp_code = wkshopcode,
|
plan_qty = cdqty,
|
stck_code = warehousecode,
|
materiel_code = partcode,
|
m_po = erpordercode,
|
username = username,
|
CreateDate = DateTime.Now.ToString()
|
}
|
});
|
}
|
}
|
if (decimal.Parse(erpqty) == decimal.Parse(markqty) + decimal.Parse(relse_qty)) //如果ERP订单=下单数量+已下单数量,则更新ERP订单表状态为CREATED:已创建
|
{
|
sql = @"update TKimp_Ewo set status='CREATED',relse_qty=relse_qty+@sumqty where wo=@wo and id=@erporderid";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
wo = erpordercode,
|
erporderid = erporderid,
|
sumqty = sumqty
|
}
|
});
|
}
|
else //更新ERP订单表状态为CREATING:创建中
|
{
|
sql = @"update TKimp_Ewo set status='CREATING',relse_qty=relse_qty+@sumqty where wo=@wo and id=@erporderid";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
wo = erpordercode,
|
erporderid = erporderid,
|
sumqty = sumqty
|
}
|
});
|
}
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.Message = "下达MES工单成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "下达MES工单成功失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[ERP订单关闭]
|
public static ToMessage ClosedErpOrder(string erporderid,string erpordercode, string username)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
sql = @"select * from TK_Wrk_Man where m_po=@erpordercode and status<> 'CLOSED'";
|
dynamicParams.Add("@erpordercode", erpordercode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "当前订单有下达未关闭的MES工单,订单不允许关闭,请先删除或关闭相关工单!";
|
mes.data = null;
|
}
|
else
|
{
|
//关闭订单
|
sql = @"update TKimp_Ewo set status='CLOSED' where wo=@wo and id=@erporderid";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
wo = erpordercode,
|
erporderid= erporderid
|
}
|
});
|
}
|
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[MES工单查询]
|
public static ToMessage ErpOrderSearch(string mesorderstus, string mesordercode, string partcode, string partname, string partspec, int startNum, string creatuser, string createdate, int endNum, string prop, string order)
|
{
|
var dynamicParams = new DynamicParameters();
|
string search = "";
|
try
|
{
|
if (mesorderstus != "" && mesorderstus != null)
|
{
|
search += "and A.status=@mesorderstus ";
|
dynamicParams.Add("@mesorderstus", mesorderstus);
|
}
|
if (mesordercode != "" && mesordercode != null)
|
{
|
search += "and A.wo_code like '%'+@mesordercode+'%' ";
|
dynamicParams.Add("@mesordercode", mesordercode);
|
}
|
if (partcode != "" && partcode != null)
|
{
|
search += "and A.materiel_code like '%'+@partcode+'%' ";
|
dynamicParams.Add("@partcode", partcode);
|
}
|
if (partname != "" && partname != null)
|
{
|
search += "and B.partname like '%'+@partname+'%' ";
|
dynamicParams.Add("@partname", partname);
|
}
|
if (partspec != "" && partspec != null)
|
{
|
search += "and B.partspec like '%'+@partspec+'%' ";
|
dynamicParams.Add("@partspec", partspec);
|
}
|
if (createdate != "" && createdate != null)
|
{
|
search += "and CONVERT(varchar(100),A.lm_date,23)=@createdate ";
|
dynamicParams.Add("@createdate", createdate);
|
}
|
if (creatuser != "" && creatuser != null)
|
{
|
search += "and U.username like '%'+@creatuser+'%' ";
|
dynamicParams.Add("@creatuser", creatuser);
|
}
|
|
if (search == "")
|
{
|
search = "and 1=1 ";
|
}
|
// --------------查询指定数据--------------
|
var total = 0; //总条数
|
var sql = @"select A.status,A.wo_code,A.materiel_code as partcode,B.partname,B.partspec,A.plan_qty,A.wkshp_code,C.org_name as wkshp_name,
|
A.route_code,E.name as route_name,A.stck_code,F.name as stck_name,A.plan_startdate,A.plan_enddate,A.piroque,A.m_po,U.username as lm_user,A.lm_date
|
from TK_Wrk_Man A
|
left join TMateriel_Info B on A.materiel_code=B.partcode
|
left join TOrganization C on A.wkshp_code=C.org_code
|
left join T_Sec_Stck D on A.stck_code=D.code
|
left join TFlw_Rout E on A.route_code=E.code
|
left join T_Sec_Stck F on A.stck_code=F.code
|
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 PartSelectRoute(string partcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取车间下拉框数据
|
sql = @"select R.code,R.name,A.default_route from TMateriel_Info A
|
inner join TMateriel_Route M on A.partcode=M.materiel_code
|
inner join TFlw_Rout R on M.route_code=R.code
|
where A.partcode=@partcode ";
|
dynamicParams.Add("@partcode", partcode);
|
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 RouteSelectWkshop(string partcode, string routecode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取车间下拉框数据
|
sql = @"select distinct F.org_code,F.org_name from TFlw_Rout A
|
inner join TMateriel_Route M on A.code=M.route_code
|
inner join TFlw_Rtdt B on A.code=B.rout_code
|
inner join TStep C on B.step_code=C.stepcode
|
inner join TFlw_Rteqp D on C.stepcode=D.step_code
|
inner join TEqpInfo E on D.eqp_code=E.code
|
left join TOrganization F on E.wksp_code=F.org_code
|
where A.code=@routecode and M.materiel_code=@partcode ";
|
dynamicParams.Add("@partcode", partcode);
|
dynamicParams.Add("@routecode", routecode);
|
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 SelectRouteStep(string routecode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取工艺路线对应工序信息
|
sql = @"select A.seq,T.stepcode,T.stepname,T.flwtype,T.descr from TFlw_Rtdt A
|
left join TStep T on A.step_code=T.stepcode
|
where A.rout_code=@partcode ";
|
dynamicParams.Add("@partcode", routecode);
|
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[MES工单新增、编辑提交]
|
public static ToMessage AddUpdateMesOrder(string mesorderstus, string mesordercode, string partcode, string mesqty, string routecode, string wkshopcode, string planstartdate, string planenddate, string orderlev, string username, string opertype)
|
{
|
var sql = "";
|
var dynamicParams = new DynamicParameters();
|
List<object> list = new List<object>();
|
try
|
{
|
if (opertype == "Add")
|
{
|
//写入工单表
|
sql = @"insert into TK_Wrk_Man(wo_code,status,wkshp_code,plan_qty,plan_startdate,plan_enddate,route_code,stck_code,lm_user,lm_date,materiel_code,m_po,piroque)
|
values(@mesordercode,@mesorderstus,@wkshopcode,@mesqty,@planstartdate,@planenddate,@routecode,@stck_code,@username,@CreateDate,@materiel_code,@m_po,@orderlev)";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
mesordercode = mesordercode,
|
mesorderstus = "ALLO", //派发
|
wkshopcode = wkshopcode,
|
mesqty = mesqty,
|
planstartdate = planstartdate,
|
planenddate = planenddate,
|
routecode = routecode,
|
stck_code = "",
|
username = username,
|
CreateDate = DateTime.Now.ToString(),
|
materiel_code = partcode,
|
m_po = "",
|
orderlev = orderlev
|
}
|
});
|
//写入工序任务表
|
sql = @"insert into TK_Wrk_Step(wo_code,seq,step_code,plan_qty,plan_startdate,plan_enddate,status,isbott,isend,route_code,lm_user,lm_date)
|
select @mesordercode as wo_code,A.seq,A.step_code,@mesqty as plan_qty,@planstartdate as plan_startdate,@planenddate as plan_enddate,@status as status,
|
A.first_choke,A.last_choke,A.rout_code,@username,@CreateDate
|
from TFlw_Rtdt A
|
left join TStep B on A.step_code=B.stepcode
|
left join TFlw_Rout C on A.rout_code=C.code
|
where A.rout_code=@routecode
|
and B.is_delete<>'1' and C.enable='Y' and C.is_delete<>'1'";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
mesordercode = mesordercode,
|
mesqty = mesqty,
|
planstartdate = planstartdate,
|
planenddate = planenddate,
|
routecode = routecode,
|
status = "ALLO", //派发
|
username = username,
|
CreateDate = DateTime.Now.ToString()
|
}
|
});
|
|
bool aa = DapperHelper.DoTransaction(list);
|
if (aa)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.Message = "MES工单新建派发成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "MES工单新建派发失败!";
|
mes.data = null;
|
}
|
}
|
if (opertype == "Update")
|
{
|
sql = @"update TK_Wrk_Man set route_code=@routecode,wkshp_code=@wkshopcode,plan_startdate=@planstartdate,plan_enddate=@planenddate,status=@status,piroque=@orderlev,lm_user=@username,lm_date=@CreateDate where wo_code=@mesordercode";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
mesordercode = mesordercode,
|
wkshopcode = wkshopcode,
|
planstartdate = planstartdate,
|
planenddate = planenddate,
|
status = "ALLO", //派发
|
routecode = routecode,
|
username = username,
|
CreateDate = DateTime.Now.ToString(),
|
orderlev = orderlev
|
}
|
});
|
//写入工序任务表
|
sql = @"insert into TK_Wrk_Step(wo_code,seq,step_code,plan_qty,plan_startdate,plan_enddate,status,isbott,isend,route_code,lm_user,lm_date)
|
select @mesordercode as wo_code,A.seq,A.step_code,@mesqty as plan_qty,@planstartdate as plan_startdate,@planenddate as plan_enddate,@status as status,
|
A.first_choke,A.last_choke,A.rout_code,@username,@CreateDate
|
from TFlw_Rtdt A
|
left join TStep B on A.step_code=B.stepcode
|
left join TFlw_Rout C on A.rout_code=C.code
|
where A.rout_code=@routecode
|
and B.is_delete<>'1' and C.enable='Y' and C.is_delete<>'1'";
|
list.Add(new
|
{
|
str = sql,
|
parm = new
|
{
|
mesordercode = mesordercode,
|
mesqty = mesqty,
|
planstartdate = planstartdate,
|
planenddate = planenddate,
|
status = "ALLO", //派发
|
username = username,
|
routecode = routecode,
|
CreateDate = 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[MES工单删除]
|
public static ToMessage DeleteMesOrder(string wocode, string m_po, string orderqty)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//判断工单是否为未开始状态或者已派发状态(满足其中一种都可删除，否则不允许删除)
|
sql = @"select * from TK_Wrk_Man where wo_code=@wocode and status='NEW' or status='ALLO'";
|
dynamicParams.Add("@wocode", wocode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
if (m_po != "" && m_po != null)
|
{
|
//查询生产订单表数据
|
sql = @"select * from TKimp_Ewo where wo=@m_po";
|
dynamicParams.Add("@m_po", m_po);
|
var data0 = DapperHelper.selectdata(sql, dynamicParams);
|
decimal relse_qty = decimal.Parse(data0.Rows[0]["RELSE_QTY"].ToString());//以下单数量
|
if ((relse_qty - decimal.Parse(orderqty)) == 0) //全部撤销 订单状态回写未开始,已下单数量为0
|
{
|
//回写订单表状态及已下单数量
|
sql = @"update TKimp_Ewo set status='NEW',relse_qty=0 where wo=@m_po";
|
list.Add(new { str = sql, parm = new { m_po = m_po } });
|
}
|
else
|
{
|
//回写订单表状态及已下单数量
|
sql = @"update TKimp_Ewo set status='CREATING',relse_qty=relse_qty-@orderqty where wo=@m_po";
|
list.Add(new { str = sql, parm = new { m_po = m_po, orderqty = decimal.Parse(orderqty) } });
|
}
|
}
|
//删除工单工序表
|
sql = @"delete TK_Wrk_Step where wo_code=@wocode";
|
list.Add(new { str = sql, parm = new { wocode = wocode } });
|
|
//删除工单表
|
sql = @"update TK_Wrk_Man set is_delete='1' where wo_code=@wocode";
|
list.Add(new { str = sql, parm = new { wocode = wocode } });
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "工单执行中或已关闭，不允许删除!";
|
mes.data = null;
|
}
|
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[MES工单关闭]
|
public static ToMessage ClosedMesOrder(string wocode, string m_po)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//关闭工单对应工序任务
|
sql = @"update TK_Wrk_Step set status='CLOSED' where wo_code=@wocode";
|
list.Add(new { str = sql, parm = new { wocode = wocode } });
|
//回写工单表状态为(关闭)
|
sql = @"update TK_Wrk_Man set status='CLOSED' where wo_code=@wocode";
|
list.Add(new { str = sql, parm = new { wocode = wocode } });
|
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[MES工单查看工序任务]
|
public static ToMessage SearchWorkStep(string wo_code)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取工序任务信息
|
sql = @"select A.wo_code,P.partcode,P.partname,P.partspec,A.seq,B.stepcode,B.stepname,A.plan_qty,A.good_qty,A.ng_qty from TK_Wrk_Step A
|
left join TStep B on A.step_code=B.stepcode
|
left join TK_Wrk_Man M on A.wo_code=M.wo_code
|
left join TMateriel_Info P on M.materiel_code=P.partcode
|
where A.wo_code=@wo_code";
|
dynamicParams.Add("@wo_code", wo_code);
|
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 MesOrderStepSearch(string orderstepqrcode, int startNum, int endNum, string prop, string order)
|
{
|
var sql = "";
|
string search = "";
|
string ordercode = "";
|
string stepcode = "";
|
var dynamicParams = new DynamicParameters();
|
var total = 0; //总条数
|
try
|
{
|
if (orderstepqrcode != "" && orderstepqrcode != null)
|
{
|
string[] arra = orderstepqrcode.Split(';');
|
if (arra.Length == 1) //工单号二维码
|
{
|
ordercode = arra[0]; //获取指定字符串前面的字符
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "请扫描工序二维码!";
|
mes.data = null;
|
return mes;
|
}
|
if (arra.Length == 2) //工单号+工序号二维码
|
{
|
ordercode = arra[0]; //获取指定字符串前面的字符
|
stepcode = arra[1]; //获取指定字符串前面的字符
|
}
|
|
if (ordercode != "" && ordercode != null) //工单号不为空,工序号为空
|
{
|
search += "and A.wo_code=@ordercode ";
|
dynamicParams.Add("@ordercode", ordercode);
|
}
|
if (ordercode != "" && stepcode != "") //工单号不为空,工序号不为空
|
{
|
search += "and A.wo_code=@ordercode ";
|
dynamicParams.Add("@ordercode", ordercode);
|
search += "and S.stepcode=@stepcode ";
|
dynamicParams.Add("@stepcode", stepcode);
|
}
|
}
|
//else
|
//{
|
// mes.code = "300";
|
// mes.count = 0;
|
// mes.Message = "二维码信息为空!";
|
// mes.data = null;
|
// return mes;
|
//}
|
if (stepcode != "")
|
{
|
//查找当前工序属性
|
sql = @"select * from TStep where stepcode=@stepcode";
|
dynamicParams.Add("@stepcode", stepcode);
|
var data0 = DapperHelper.selectdata(sql, dynamicParams);
|
if (data0.Rows.Count > 0)
|
{
|
if (data0.Rows[0]["FLWTYPE"].ToString() == "W")
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "当前工序任务为外协工序任务,请前往外协操作页签执行!";
|
mes.data = null;
|
return mes;
|
}
|
}
|
}
|
//根据条件查询工单工序任务(自制工序)
|
sql = @"select A.status,A.wo_code,B.route_code,M.partcode,M.partname,M.partspec,A.seq,A.isbott,A.isend,
|
S.stepcode,S.stepname,S.descr,A.plan_qty,A.good_qty,A.ng_qty,A.plan_startdate
|
from TK_Wrk_Step A
|
left join TK_Wrk_Man B on A.wo_code=B.wo_code
|
left join TMateriel_Info M on B.materiel_code=M.partcode
|
left join TStep S on A.step_code=S.stepcode
|
where A.status<>'CLOSED' and S.flwtype='Z' " + search;
|
var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
|
if (data.ToList().Count > 0)
|
{
|
mes.code = "200";
|
mes.count = total;
|
mes.Message = "查询成功!";
|
mes.data = data.ToList();
|
return mes;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "无可执行的生产任务,任务已完成或已关闭!";
|
mes.data = null;
|
return mes;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[生产开报工扫码获取工单对应工序任务(外协)]
|
public static ToMessage MesOrderWxStepSearch(string orderstepqrcode, int startNum, int endNum, string prop, string order)
|
{
|
var sql = "";
|
string search = "";
|
string ordercode = "";
|
string stepcode = "";
|
var dynamicParams = new DynamicParameters();
|
var total = 0; //总条数
|
try
|
{
|
if (orderstepqrcode != "" && orderstepqrcode != null)
|
{
|
string[] arra = orderstepqrcode.Split(';');
|
if (arra.Length == 1) //工单号二维码
|
{
|
ordercode = arra[0]; //获取指定字符串前面的字符
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "请扫描工序二维码!";
|
mes.data = null;
|
return mes;
|
}
|
if (arra.Length == 2) //工单号+工序号二维码
|
{
|
ordercode = arra[0]; //获取指定字符串前面的字符
|
stepcode = arra[1]; //获取指定字符串前面的字符
|
}
|
if (ordercode != "" && ordercode != null) //工单号不为空,工序号为空
|
{
|
search += "and A.wo_code=@ordercode ";
|
dynamicParams.Add("@ordercode", ordercode);
|
}
|
if (ordercode != "" && stepcode != "") //工单号不为空,工序号不为空
|
{
|
search += "and A.wo_code=@ordercode ";
|
dynamicParams.Add("@ordercode", ordercode);
|
search += "and S.stepcode=@stepcode ";
|
dynamicParams.Add("@stepcode", stepcode);
|
}
|
}
|
//else
|
//{
|
// mes.code = "300";
|
// mes.count = 0;
|
// mes.Message = "二维码信息为空!";
|
// mes.data = null;
|
// return mes;
|
//}
|
if (stepcode != "")
|
{
|
//查找当前工序属性
|
sql = @"select * from TStep where stepcode=@stepcode";
|
dynamicParams.Add("@stepcode", stepcode);
|
var data0 = DapperHelper.selectdata(sql, dynamicParams);
|
if (data0.Rows.Count > 0)
|
{
|
if (data0.Rows[0]["FLWTYPE"].ToString() == "Z")
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "当前工序任务为自制工序任务,请前往自制操作页签执行!";
|
mes.data = null;
|
return mes;
|
}
|
}
|
}
|
//根据条件查询工单工序任务(自制工序)
|
sql = @"select A.status,A.wo_code,B.route_code,M.partcode,M.partname,M.partspec,A.seq,A.isbott,A.isend,
|
S.stepcode,S.stepname,S.descr,A.plan_qty,A.good_qty,A.ng_qty,A.plan_startdate
|
from TK_Wrk_Step A
|
left join TK_Wrk_Man B on A.wo_code=B.wo_code
|
left join TMateriel_Info M on B.materiel_code=M.partcode
|
left join TStep S on A.step_code=S.stepcode
|
where A.status<>'CLOSED' and S.flwtype='W' " + search;
|
var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
|
if (data.ToList().Count > 0)
|
{
|
mes.code = "200";
|
mes.count = total;
|
mes.Message = "查询成功!";
|
mes.data = data.ToList();
|
return mes;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "无可执行的生产任务,任务已完成或已关闭!";
|
mes.data = null;
|
return mes;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region [生产开报工：开工(开始/报工)/外协发料时条件判断及数据返回接口]
|
public static ToMessage MesOrderStepStart(string OperType, string SelectType, string orderstepqrcode)
|
{
|
var sql = "";
|
string search = "";
|
string ordercode = "";
|
string serialnumber = "";
|
string stepcode = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
if (orderstepqrcode != "" && orderstepqrcode != null)
|
{
|
string[] arra = orderstepqrcode.Split(';');
|
if (arra.Length == 1) //工单号二维码
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "请扫描工序条码!";
|
mes.data = null;
|
return mes;
|
}
|
if (arra.Length == 2) //工单号+工序号二维码
|
{
|
ordercode = arra[0]; //获取指定字符串前面的字符
|
stepcode = arra[1]; //获取指定字符串前面的字符
|
}
|
switch (OperType)
|
{
|
case "ZZ":
|
mes = ScanStartReport.ZZEncodingSeach(ordercode, stepcode);
|
break;
|
case "WX":
|
mes = ScanStartReport.WXEncodingSeach(SelectType, ordercode, stepcode);
|
break;
|
default:
|
break;
|
}
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "二维码信息为空!";
|
mes.data = null;
|
return mes;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
|
#endregion
|
|
#region[生产开报工：开工时获取设备下拉列表]
|
public static ToMessage MesOrderStepStartSelectEqp(string orderstepqrcode)
|
{
|
string sql = "";
|
string ordercode = "";
|
string stepcode = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
if (orderstepqrcode != "" && orderstepqrcode != null)
|
{
|
string[] arra = orderstepqrcode.Split(';');
|
if (arra.Length == 1) //工单号二维码
|
{
|
ordercode = arra[0]; //获取指定字符串前面的字符
|
}
|
if (arra.Length == 2) //工单号+工序号二维码
|
{
|
ordercode = arra[0]; //获取指定字符串前面的字符
|
stepcode = arra[1]; //获取指定字符串前面的字符
|
}
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "二维码信息为空!";
|
mes.data = null;
|
return mes;
|
}
|
//获取工序关联的设备
|
sql = @"select B.code,B.name from TFlw_Rteqp A
|
left join TEqpInfo B on A.eqp_code=B.code
|
where A.style='E' and A.step_code=@stepcode";
|
dynamicParams.Add("@stepcode", stepcode);
|
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 MesOrderStepReportSelectUserGroup()
|
{
|
string sql = "";
|
try
|
{
|
//获取用户组
|
sql = @"select group_code,group_name from TGroup";
|
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 MesOrderGroupSelectUser(string usergroupcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//班组获取人员列表
|
sql = @"select usercode,username from TUser where usergroup_code=@usergroupcode and is_delete<>'1'";
|
dynamicParams.Add("@usergroupcode", usergroupcode);
|
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 MesOrderSelectUser(string usercode)
|
{
|
string sql = "";
|
string search = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
if (usercode != "" && usercode != null) //工单号不为空,工序号为空
|
{
|
search += "and usercode=@usercode ";
|
dynamicParams.Add("@usercode", usercode);
|
}
|
//班组获取人员列表
|
sql = @"select usercode,username from TUser where is_delete<>'1' " + search;
|
dynamicParams.Add("@usercode", usercode);
|
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 MesOrderStepSelectWX(string orderstepqrcode)
|
{
|
string sql = "";
|
string ordercode = "";
|
string stepcode = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
if (orderstepqrcode != "" && orderstepqrcode != null)
|
{
|
string[] arra = orderstepqrcode.Split(';');
|
if (arra.Length == 1) //工单号二维码
|
{
|
ordercode = arra[0]; //获取指定字符串前面的字符
|
}
|
if (arra.Length == 2) //工单号+工序号二维码
|
{
|
ordercode = arra[0]; //获取指定字符串前面的字符
|
stepcode = arra[1]; //获取指定字符串前面的字符
|
}
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "二维码信息为空!";
|
mes.data = null;
|
return mes;
|
}
|
//获取外协下拉框
|
sql = @"select C.code,C.name from TFlw_Rteqp A
|
left join TCustomer C on A.eqp_code=C.code
|
where A.step_code=@stepcode and A.style='W'";
|
dynamicParams.Add("@stepcode", stepcode);
|
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 MesOrderStepSelectCause(string orderstepqrcode)
|
{
|
string sql = "";
|
string ordercode = "";
|
string stepcode = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
if (orderstepqrcode != "" && orderstepqrcode != null)
|
{
|
string[] arra = orderstepqrcode.Split(';');
|
if (arra.Length == 1) //工单号二维码
|
{
|
ordercode = arra[0]; //获取指定字符串前面的字符
|
}
|
if (arra.Length == 2) //工单号+工序号二维码
|
{
|
ordercode = arra[0]; //获取指定字符串前面的字符
|
stepcode = arra[1]; //获取指定字符串前面的字符
|
}
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "二维码信息为空!";
|
mes.data = null;
|
return mes;
|
}
|
//获取工序关联缺陷
|
sql = @"select B.code,B.name from TDefect_Step A
|
left join TDefect B on A.defect_code=B.code
|
where A.step_code=@stepcode";
|
dynamicParams.Add("@stepcode", stepcode);
|
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 SavaMesOrderStepStart(string mesordercode, string partcode, string stepseq, string stepcode, string eqpcode, string taskqty, string startqty, string username)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
string date = DateTime.Now.ToString(); //获取系统时间
|
list.Clear();
|
//判断是否有开工记录
|
sql = @"select * from TK_Wrk_Record where wo_code=@wo_code and step_code=@step_code and style='S'";
|
dynamicParams.Add("@wo_code", mesordercode);
|
dynamicParams.Add("@step_code", stepcode);
|
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 = @"insert into TK_Wrk_Record(wo_code,step_seq,step_code,eqp_code,materiel_code,open_person,open_time,task_qty,start_qty,style,lm_user,lm_date)
|
values(@mesordercode,@stepseq,@stepcode,@eqpcode,@partcode,@username,@opentime,@taskqty,@startqty,@style,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepseq = stepseq, stepcode = stepcode, eqpcode = eqpcode, partcode = partcode, username = username, opentime = date, taskqty = taskqty, startqty = startqty, style = "S", lm_user = username, lm_date = date } });
|
//回写工单工序表状态为START: 开工
|
sql = @"update TK_Wrk_Step set status='START' where wo_code=@mesordercode and step_code=@stepcode";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepcode = stepcode } });
|
|
//回写工单工序表状态为已开工
|
sql = @"update TK_Wrk_Step set status='START' where wo_code=@mesordercode and step_code=@stepcode";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepcode = stepcode} });
|
//回写工单表状态为： 开工：START
|
sql = @"update TK_Wrk_Man set status='START' where wo_code=@mesordercode";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode } });
|
|
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 SavaMesOrderStepReport(string mesordercode, string partcode, string stepseq, string stepcode, string eqpcode, string usergroupcode, string reportuser, string taskqty, string startqty, string reportqty, string ngqty, string badcode, string username)
|
{
|
var sql = "";
|
string[] arra = new string[] { };
|
string[] arra1 = new string[] { };
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
string date = DateTime.Now.ToString(); //获取系统时间
|
//截取报工人员
|
arra = reportuser.Split(';');
|
if (ngqty != "" || ngqty != "0")
|
{
|
//截取不良原因
|
arra1 = badcode.Split(';');
|
}
|
|
list.Clear();
|
//判断是否有报工记录(有：修改 无：新增)
|
sql = @"select * from TK_Wrk_Record where wo_code=@wo_code and step_code=@step_code and style='B'";
|
dynamicParams.Add("@wo_code", mesordercode);
|
dynamicParams.Add("@step_code", stepcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
//获取开工记录的默认选中的设备(产线)与报工时的设备产线做对比判断
|
sql = @"select A.eqp_code,B.name from TK_Wrk_Record A
|
inner join TEqpInfo B on A.eqp_code=B.code
|
where A.wo_code=@wo_code and A.step_code=@step_code and A.style='S'";
|
dynamicParams.Add("@wo_code", mesordercode);
|
dynamicParams.Add("@step_code", stepcode);
|
var da = DapperHelper.selectdata(sql, dynamicParams);
|
if (da.Rows[0]["EQP_CODE"].ToString() != eqpcode)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "操作失败,当前报工产线应为："+ da.Rows[0]["NAME"].ToString() + "!";
|
mes.data = null;
|
return mes;
|
}
|
if (data.Rows.Count > 0)
|
{
|
//修改报工记录
|
sql = @"update TK_Wrk_Record set good_qty=good_qty+@reportqty,ng_qty=ng_qty+@ngqty,
|
lm_user=@username,lm_date=@CreateDate where wo_code=@mesordercode and step_code=@stepcode and style='B'";
|
list.Add(new { str = sql, parm = new { reportqty = decimal.Parse(reportqty), ngqty = decimal.Parse(ngqty), mesordercode = mesordercode, stepcode = stepcode, username = username, CreateDate = date } });
|
//写入子表
|
for (int i = 0; i < arra.Length; i++)
|
{
|
sql = @"insert into TK_Wrk_RecordSub(m_id,eqp_code,report_person,report_date,report_qty,usergroup_code,ng_qty,style,lm_user,lm_date)
|
values(@m_id,@eqp_code,@report_person,@report_date,@report_qty,@usergroup_code,@ng_qty,@style,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { m_id = int.Parse(data.Rows[0]["ID"].ToString()), eqp_code = eqpcode, report_person = arra[i], report_date = date, report_qty = reportqty, usergroup_code = usergroupcode, ng_qty = ngqty, style = "B", lm_user = username, lm_date = date } });
|
|
}
|
if (badcode != "" && ngqty != "0")
|
{
|
//写入缺陷记录表
|
for (int i = 0; i < arra1.Length; i++)
|
{
|
sql = @"insert into CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,style,lm_user,lm_date)
|
values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@style,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { record_id = int.Parse(data.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i], style = "B", lm_user = username, lm_date = date } });
|
|
}
|
}
|
}
|
else
|
{
|
//获取主表最大ID
|
sql = @"select ISNULL(IDENT_CURRENT('TK_Wrk_Record')+1,1) as id";
|
var dt = DapperHelper.selecttable(sql);
|
//写入开报工记录表
|
sql = @"insert into TK_Wrk_Record(wo_code,step_seq,step_code,eqp_code,materiel_code,task_qty,start_qty,good_qty,ng_qty,style,lm_user,lm_date)
|
values(@mesordercode,@stepseq,@stepcode,@eqpcode,@partcode,@taskqty,@startqty,@reportqty,@ngqty,@style,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepseq = stepseq, stepcode = stepcode, eqpcode = eqpcode, partcode = partcode, taskqty = taskqty, startqty = startqty, reportqty = reportqty, ngqty = ngqty, style = "B", lm_user = username, lm_date = date } });
|
|
//写入子表
|
for (int i = 0; i < arra.Length; i++)
|
{
|
sql = @"insert into TK_Wrk_RecordSub(m_id,eqp_code,report_person,report_date,report_qty,usergroup_code,ng_qty,style,lm_user,lm_date)
|
values(@m_id,@eqp_code,@report_person,@report_date,@report_qty,@usergroup_code,@ng_qty,@style,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { m_id = int.Parse(dt.Rows[0]["ID"].ToString()), eqp_code = eqpcode, report_person = arra[i], report_date = date, report_qty = reportqty, usergroup_code = usergroupcode, ng_qty = ngqty, style = "B", lm_user = username, lm_date = date } });
|
|
}
|
if (badcode != "" && ngqty != "0")
|
{
|
//写入缺陷记录表
|
for (int i = 0; i < arra1.Length; i++)
|
{
|
sql = @"insert into CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,style,lm_user,lm_date)
|
values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@style,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { record_id = int.Parse(dt.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i], style = "B", lm_user = username, lm_date = date } });
|
|
}
|
}
|
}
|
|
|
//回写工单工序表合格数量、不良数量
|
sql = @"update TK_Wrk_Step set good_qty=good_qty+@reportqty,ng_qty=ng_qty+@ngqty where wo_code=@mesordercode and step_code=@stepcode";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepcode = stepcode, reportqty = reportqty, ngqty = ngqty } });
|
|
//回写工单表合格数量、不良数量
|
sql = @"update TK_Wrk_Man set good_qty=good_qty+@reportqty,ng_qty=ng_qty+@ngqty where wo_code=@mesordercode";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, reportqty = reportqty, ngqty = ngqty } });
|
|
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 SavaMesOrderStepOut(string mesordercode, string partcode, string stepseq, string stepcode, string wxcode, string outuser, string taskqty, string fqty, string username)
|
{
|
var sql = "";
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
string date = DateTime.Now.ToString(); //获取系统时间
|
list.Clear();
|
//判断是否有发料记录(有(同工单+工序+外协供方修改) 无：新增)
|
sql = @"select * from TK_Wrk_OutRecord where wo_code=@wo_code and step_code=@step_code and wx_code=@wx_code and style='F'";
|
dynamicParams.Add("@wo_code", mesordercode);
|
dynamicParams.Add("@step_code", stepcode);
|
dynamicParams.Add("@wx_code", wxcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
//修改发料记录
|
sql = @"update TK_Wrk_OutRecord set fqty=fqty+@fqty,lm_user=@username,lm_date=@CreateDate
|
where wo_code=@mesordercode and step_code=@stepcode and wx_code=@wx_code and style='F'";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepcode = stepcode, wx_code = wxcode, fqty = decimal.Parse(fqty), username = username, CreateDate = date } });
|
//写入子表
|
sql = @"insert into TK_Wrk_OutRecordSub(m_id,wx_code,out_person,out_time,fqty,style,lm_user,lm_date)
|
values(@m_id,@wx_code,@out_person,@out_time,@fqty,@style,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { m_id = int.Parse(data.Rows[0]["ID"].ToString()), wx_code = wxcode, out_person = outuser, out_time = date, fqty = fqty, style = 'F', lm_user = username, lm_date = date } });
|
}
|
else
|
{
|
//获取主表最大ID
|
sql = @"select ISNULL(IDENT_CURRENT('TK_Wrk_OutRecord')+1,1) as id";
|
var dt = DapperHelper.selecttable(sql);
|
//写入外协记录主表
|
sql = @"insert into TK_Wrk_OutRecord(wo_code,step_seq,step_code,wx_code,materiel_code,style,fqty,lm_user,lm_date)
|
values(@mesordercode,@stepseq,@stepcode,@wx_code,@partcode,@style,@fqty,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepseq = stepseq, stepcode = stepcode, wx_code = wxcode, partcode = partcode, style = 'F', fqty = fqty, lm_user = username, lm_date = date } });
|
|
//写入子表
|
sql = @"insert into TK_Wrk_OutRecordSub(m_id,wx_code,out_person,out_time,fqty,style,lm_user,lm_date)
|
values(@m_id,@wx_code,@out_person,@out_time,@fqty,@style,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { m_id = int.Parse(dt.Rows[0]["ID"].ToString()), wx_code = wxcode, out_person = outuser, out_time = date, fqty = fqty, style = 'F', lm_user = username, lm_date = date } });
|
}
|
//回写工单工序表状态为START: 开工
|
sql = @"update TK_Wrk_Step set status='START' where wo_code=@mesordercode and step_code=@stepcode";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepcode = stepcode } });
|
|
|
//回写工单表状态为： 开工：START
|
sql = @"update TK_Wrk_Man set status='START' where wo_code=@mesordercode";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode } });
|
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 SavaMesOrderStepIn(string mesordercode, string partcode, string stepseq, string stepcode, string wxcode, string inuser, string taskqty, string sqty, string ngqty, string badcode, string username)
|
{
|
var sql = "";
|
string[] arra1 = new string[] { };
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
string date = DateTime.Now.ToString(); //获取系统时间
|
//截取不良原因
|
if (ngqty != "" || ngqty != "0")
|
{
|
//截取不良原因
|
arra1 = badcode.Split(';');
|
}
|
|
list.Clear();
|
//判断是否有收料记录(有：（同工单+工序+外协供方修改） 无：新增)
|
sql = @"select * from TK_Wrk_OutRecord where wo_code=@wo_code and step_code=@step_code and wx_code=@wx_code and style='S'";
|
dynamicParams.Add("@wo_code", mesordercode);
|
dynamicParams.Add("@step_code", stepcode);
|
dynamicParams.Add("@wx_code", wxcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
//获取发料记录的默认选中的外协供应商与收料时的外协供应商做对比判断
|
sql = @"select A.wx_code,B.name from TK_Wrk_OutRecord A
|
inner join TCustomer B on A.wx_code=B.code
|
where A.wo_code=@wo_code and A.step_code=@step_code and A.style='F' ";
|
dynamicParams.Add("@wo_code", mesordercode);
|
dynamicParams.Add("@step_code", stepcode);
|
var da = DapperHelper.selectdata(sql, dynamicParams);
|
if (da.Rows[0]["WX_CODE"].ToString() != wxcode)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "操作失败,当前收料外协供方应为：" + da.Rows[0]["NAME"].ToString() + "!";
|
mes.data = null;
|
return mes;
|
}
|
if (data.Rows.Count > 0)
|
{
|
//修改外协记录主表
|
sql = @"update TK_Wrk_OutRecord set sqty=sqty+@sqty,ng_qty=ng_qty+@ngqty,lm_user=@username,lm_date=@CreateDate
|
where wo_code=@mesordercode and step_code=@stepcode and wx_code=@wx_code and style='S'";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepcode = stepcode, wx_code = wxcode, sqty = decimal.Parse(sqty), ngqty = decimal.Parse(ngqty), username = username, CreateDate = date } });
|
//写入外协记录子表
|
sql = @"insert into TK_Wrk_OutRecordSub(m_id,wx_code,in_person,in_time,sqty,ng_qty,style,lm_user,lm_date)
|
values(@m_id,@wx_code,@in_person,@in_time,@sqty,@ngqty,@style,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { m_id = int.Parse(data.Rows[0]["ID"].ToString()), wx_code = wxcode, in_person = inuser, in_time = date, sqty = sqty, ngqty = ngqty, style = 'S', lm_user = username, lm_date = date } });
|
|
if (badcode != "" && ngqty != "0")
|
{
|
//写入缺陷记录表
|
for (int i = 0; i < arra1.Length; i++)
|
{
|
sql = @"insert into CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,style,lm_user,lm_date)
|
values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@style,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { record_id = int.Parse(data.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i], style = "S", lm_user = username, lm_date = date } });
|
|
}
|
}
|
}
|
else
|
{
|
//获取主表最大ID
|
sql = @"select ISNULL(IDENT_CURRENT('TK_Wrk_OutRecord')+1,1) as id";
|
var dt = DapperHelper.selecttable(sql);
|
//写入外协记录主表
|
sql = @"insert into TK_Wrk_OutRecord(wo_code,step_seq,step_code,wx_code,materiel_code,style,sqty,ng_qty,lm_user,lm_date)
|
values(@mesordercode,@stepseq,@stepcode,@wx_code,@partcode,@style,@sqty,@ngqty,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepseq = stepseq, stepcode = stepcode, wx_code = wxcode, partcode = partcode, style = 'S', sqty = sqty, ngqty = ngqty, lm_user = username, lm_date = date } });
|
|
//写入外协记录子表
|
sql = @"insert into TK_Wrk_OutRecordSub(m_id,wx_code,in_person,in_time,sqty,ng_qty,style,lm_user,lm_date)
|
values(@m_id,@wxcode,@in_person,@in_time,@sqty,@ng_qty,@style,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { m_id = int.Parse(dt.Rows[0]["ID"].ToString()), wxcode = wxcode, in_person = inuser, in_time = date, sqty = sqty, ng_qty = ngqty, style = "S", lm_user = username, lm_date = date } });
|
|
if (badcode != "" && ngqty != "0")
|
{
|
//写入缺陷记录表
|
for (int i = 0; i < arra1.Length; i++)
|
{
|
sql = @"insert into CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,style,lm_user,lm_date)
|
values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@style,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { record_id = int.Parse(dt.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i], style = "S", lm_user = username, lm_date = date } });
|
|
}
|
}
|
}
|
//回写工单工序表合格数量、不良数量
|
sql = @"update TK_Wrk_Step set good_qty=good_qty+@sqty,ng_qty=ng_qty+@ngqty where wo_code=@mesordercode and step_code=@stepcode";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepcode = stepcode, sqty = sqty, ngqty = ngqty } });
|
|
//回写工单表合格数量、不良数量
|
sql = @"update TK_Wrk_Man set good_qty=good_qty+@sqty,ng_qty=ng_qty+@ngqty where wo_code=@mesordercode";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, sqty = sqty, ngqty = ngqty } });
|
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 MesOrderStepCheckSearch(string orderstepqrcode)
|
{
|
var sql = "";
|
string ordercode = "";
|
string stepcode = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
if (orderstepqrcode != "" && orderstepqrcode != null)
|
{
|
string[] arra = orderstepqrcode.Split(';');
|
if (arra.Length == 1) //工单号二维码
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "请扫描工序条码!";
|
mes.data = null;
|
return mes;
|
}
|
if (arra.Length == 2) //工单号+工序号二维码
|
{
|
ordercode = arra[0]; //获取指定字符串前面的字符
|
stepcode = arra[1]; //获取指定字符串前面的字符
|
}
|
//通过扫描二维码信息查找任务信息
|
sql = @"select A.wo_code,M.partcode,M.partname,M.partspec,S.stepcode,S.stepname
|
from TK_Wrk_Step A
|
inner join TK_Wrk_Man P on A.wo_code=P.wo_code
|
left join TMateriel_Info M on P.materiel_code=M.partcode
|
left join TStep S on A.step_code=S.stepcode
|
where A.wo_code=@wo_code and A.step_code=@stepcode";
|
dynamicParams.Add("@wo_code", ordercode);
|
dynamicParams.Add("@stepcode", stepcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.Message = "查询成功!";
|
mes.data = data;
|
return mes;
|
}
|
else
|
{
|
mes.code = "300";
|
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 e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[生产开报工,工序检验获取检验标准下拉框数据]
|
public static ToMessage MesOrderStepCheckSelect()
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取工序检验标准
|
sql = @"select code,name from TStepCheckStandard 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 MesOrderStepCheckItemList(string checkstandcode)
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//根据检验标准编码获取工序检验项目
|
sql = @"select B.code,B.name,A.stepcheckitem_desc,A.stepcheckitem_seq from TStepCheckStandardSub A
|
left join TStepCheckItem B on A.stepcheckitem_code=B.code
|
where B.is_delete<>'1' and A.stepstaned_code=@checkstandcode";
|
dynamicParams.Add("@checkstandcode", checkstandcode);
|
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 SaveMesOrderStepCheckItem(string mesordercode, string partcode, string stepcode, string checkstanedcode, string checkusercode, string checktypecode, string checkresult, string checkdescr, string username, List<StepCheck> json)
|
{
|
var sql = "";
|
string[] arra = new string[] { };
|
string[] arra1 = new string[] { };
|
List<object> list = new List<object>();
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
string date = DateTime.Now.ToString(); //获取系统时间
|
|
list.Clear();
|
|
//写入工序检验记录主表
|
sql = @"insert into TStepCheckRecord(wo_code,partcode,step_code,checkstaned_code,check_user,check_type,check_result,check_descr,lm_user,lm_date)
|
values(@mesordercode,@partcode,@stepcode,@checkstanedcode,@checkusercode,@checktypecode,@checkresult,@checkdescr,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { mesordercode = mesordercode, partcode = partcode, stepcode = stepcode, checkstanedcode = checkstanedcode, checkusercode = checkusercode, checktypecode = checktypecode, checkresult = checkresult, checkdescr = checkdescr, lm_user = username, lm_date = date } });
|
//写入工序检验记录子表
|
//获取主表最大ID
|
sql = @"select ISNULL(IDENT_CURRENT('TStepCheckRecord')+1,1) as id";
|
var dt = DapperHelper.selecttable(sql);
|
for (int i = 0; i < json.Count; i++)
|
{
|
sql = @"insert into TStepCheckRecordSub(m_id,checkitem_seq,checkitem_code,checkitem_name,checkitem_descr,check_result,lm_user,lm_date)
|
values(@m_id,@checkiem_seq,@checkitem_code,@checkitem_name,@checkitem_descr,@check_result,@lm_user,@lm_date)";
|
list.Add(new { str = sql, parm = new { m_id = int.Parse(dt.Rows[0]["ID"].ToString()), checkiem_seq = int.Parse(json[i].seq), checkitem_code = json[i].code, checkitem_name = json[i].name, checkitem_descr = json[i].descr, check_result = json[i].checkresult, lm_user = username, lm_date = date } });
|
|
}
|
|
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
|
|
}
|
}
|
