| | |
| | | { |
| | | code = json[i].code, |
| | | name = json[i].name, |
| | | digdect=json[i].digdect, |
| | | r_ule=json[i].r_ule, |
| | | username= username, |
| | | CreateDate= DateTime.Now.ToString() |
| | | digdect = json[i].digdect, |
| | | r_ule = json[i].r_ule, |
| | | username = username, |
| | | CreateDate = DateTime.Now.ToString() |
| | | } |
| | | }); |
| | | } |
| | |
| | | rout.code = data.Rows[i]["CODE"].ToString(); |
| | | rout.name = data.Rows[i]["NAME"].ToString(); |
| | | rout.flag = data.Rows[i]["FLAG"].ToString(); |
| | | |
| | | |
| | | //根据工艺路线编码获取关联的工序信息 |
| | | sql = @"select A.seq,B.stepcode,B.stepname,B.enable from TFlw_Rtdt A |
| | | inner join TStep B on A.step_code=B.stepcode |
| | |
| | | } |
| | | #endregion |
| | | |
| | | #region[存货档案关联工艺路线提交] |
| | | public static ToMessage SaveInventoryFile(string partcode, string username, List<ObjectData> json) |
| | | { |
| | | var sql = ""; |
| | | List<object> list = new List<object>(); |
| | | try |
| | | { |
| | | list.Clear(); |
| | | if (json == null || json.Count <= 0) |
| | | { |
| | | //清除物料关联工艺路线表数据 |
| | | sql = @"delete TMateriel_Route where materiel_code=@partcode"; |
| | | list.Add(new { str = sql, parm = new { partcode = partcode } }); |
| | | //标记物料表关联工艺路线标识 |
| | | sql = @"update TMateriel_Info set proute_id='N' where partcode=@partcode"; |
| | | list.Add(new { str = sql, parm = new { partcode = partcode } }); |
| | | } |
| | | else |
| | | { |
| | | //清除用户关联角色表数据 |
| | | sql = @"delete TMateriel_Route where materiel_code=@partcode"; |
| | | list.Add(new { str = sql, parm = new { partcode = partcode } }); |
| | | //循环写入用户关联角色表 |
| | | for (int i = 0; i < json.Count; i++) |
| | | { |
| | | sql = @"insert into TMateriel_Route(materiel_code,route_code,lm_user,lm_date) values(@materiel_code,@route_code,@lm_user,@lm_date)"; |
| | | list.Add(new |
| | | { |
| | | str = sql, |
| | | parm = new |
| | | { |
| | | materiel_code = partcode, |
| | | route_code = json[i].code, |
| | | lm_user = username, |
| | | lm_date = DateTime.Now.ToString() |
| | | } |
| | | }); |
| | | } |
| | | //标记物料表关联工艺路线标识 |
| | | sql = @"update TMateriel_Info set proute_id='Y' where partcode=@partcode"; |
| | | list.Add(new { str = sql, parm = new { partcode = partcode } }); |
| | | } |
| | | 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 RouteSearch(string routecode, string routename, string description, string createuser, int startNum, int endNum, string prop, string order) |
| | | { |
| | | var dynamicParams = new DynamicParameters(); |
| | | string search = ""; |
| | | try |
| | | { |
| | | if (routecode != "" && routecode != null) |
| | | { |
| | | search += "and code like '%'+@partcode+'%' "; |
| | | dynamicParams.Add("@routecode", routecode); |
| | | } |
| | | if (routename != "" && routename != null) |
| | | { |
| | | search += "and name like '%'+@routename+'%' "; |
| | | dynamicParams.Add("@routename", routename); |
| | | } |
| | | if (description != "" && description != null) |
| | | { |
| | | search += "and description=@description "; |
| | | dynamicParams.Add("@description", description); |
| | | } |
| | | if (createuser != "" && createuser != null) |
| | | { |
| | | search += "and lm_user=@createuser "; |
| | | dynamicParams.Add("@createuser", createuser); |
| | | } |
| | | if (search == "") |
| | | { |
| | | search = "and 1=1 "; |
| | | } |
| | | // --------------查询指定数据-------------- |
| | | var total = 0; //总条数 |
| | | var sql = @"select code,name,description,enable,lm_user,lm_date |
| | | from TFlw_Rout |
| | | where 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 ViewRoute(string routecode) |
| | | { |
| | | string sql = ""; |
| | | var dynamicParams = new DynamicParameters(); |
| | | List<RoutEdit> list = new List<RoutEdit>(); |
| | | try |
| | | { |
| | | //获取工艺路线信息 |
| | | sql = @"select code,name,description,enable |
| | | from TFlw_Rout |
| | | where code=@routecode and is_delete<>'1'"; |
| | | dynamicParams.Add("@routecode", routecode); |
| | | var data = DapperHelper.selectdata(sql, dynamicParams); |
| | | for (int i = 0; i < data.Rows.Count; i++) |
| | | { |
| | | RoutEdit rout = new RoutEdit(); |
| | | rout.code = data.Rows[i]["CODE"].ToString(); |
| | | rout.name = data.Rows[i]["NAME"].ToString(); |
| | | rout.enable = data.Rows[i]["ENABLE"].ToString(); |
| | | rout.description = data.Rows[i]["DESCRIPTION"].ToString(); |
| | | |
| | | //根据工艺路线编码获取关联的工序信息 |
| | | sql = @"select A.seq,B.stepcode,B.stepname,B.enable from TFlw_Rtdt A |
| | | inner join TStep B on A.step_code=B.stepcode |
| | | where A.rout_code=@route_code and B.is_delete<>'1' order by A.seq asc"; |
| | | dynamicParams.Add("@route_code", rout.code); |
| | | var data0 = DapperHelper.selectdata(sql, dynamicParams); |
| | | rout.Data = data0; |
| | | 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 AddUpdateRoute(string id, string opertype, string username, RoutEdit json) |
| | | { |
| | | var sql = ""; |
| | | var dynamicParams = new DynamicParameters(); |
| | | List<object> list = new List<object>(); |
| | | try |
| | | { |
| | | if (opertype == "Add") |
| | | { |
| | | //新增工艺路线表 |
| | | sql = @"insert into TFlw_Rout(code,name,description,enable,lm_user,lm_date) values(@code,@name,@description,@enable,@lm_user,@lm_date)"; |
| | | list.Add(new { str = sql, parm = new { code = json.code, name = json.name, description = json.description, enable = json.enable, lm_user = username, lm_date = DateTime.Now.ToString() } }); |
| | | string is_firststep = "N"; //是否首道工序 |
| | | string is_laststep = "N"; //是否末道工序 |
| | | for (int i = 0; i < json.Data.Rows.Count; i++) |
| | | { |
| | | if (json.Data.Rows[i]["SEQ"].ToString() == "1") //是否首道工序 |
| | | { |
| | | is_firststep = "Y"; |
| | | } |
| | | if (Convert.ToInt32(json.Data.Rows[i]["SEQ"].ToString()) == json.Data.Rows.Count) //是否末道工序 |
| | | { |
| | | is_laststep = "Y"; |
| | | } |
| | | //新增工艺路线关联工序表 |
| | | sql = @"insert TFlw_Rtdt (rout_code,seq,step_code,first_choke,last_choke,lm_user,lm_date) values()"; |
| | | list.Add(new { str = sql, parm = new { rout_code = json.code, seq = Convert.ToInt32(json.Data.Rows[i]["SEQ"].ToString()), step_code = json.Data.Rows[i]["STEPCODE"].ToString(), first_choke = is_firststep, last_choke = is_laststep, lm_user = username, 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 DeleteRoute(string routecode) |
| | | { |
| | | var sql = ""; |
| | | List<object> list = new List<object>(); |
| | | var dynamicParams = new DynamicParameters(); |
| | | try |
| | | { |
| | | //判断工艺路线是否被工单引用(被引用则不能删除) |
| | | sql = @"select * from TK_Wrk_Man where route_code=@routecode"; |
| | | dynamicParams.Add("@routecode", routecode); |
| | | var data = DapperHelper.selectdata(sql, dynamicParams); |
| | | if (data.Rows.Count > 0) |
| | | { |
| | | mes.code = "300"; |
| | | mes.count = 0; |
| | | mes.Message = "工艺路线已被工单引用,不允许删除!"; |
| | | mes.data = null; |
| | | } |
| | | else |
| | | { |
| | | //判断当前工艺路线是否有设置节拍工价(有设置,提示先删除节拍工价设置) |
| | | sql = @"select * from TPrteEqp_Stad where route_code=@routecode"; |
| | | dynamicParams.Add("@routecode", routecode); |
| | | 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 TFlw_Rtdt where rout_code=@routecode"; |
| | | list.Add(new { str = sql, parm = new { routecode = routecode } }); |
| | | //删除工艺路线表 |
| | | sql = @"delete TFlw_Rout where code=@routecode"; |
| | | list.Add(new { str = sql, parm = new { routecode = routecode } }); |
| | | //删除物料关联工艺路线表 |
| | | sql = @"delete TMateriel_Route where route_code=@routecode"; |
| | | list.Add(new { str = sql, parm = new { routecode = routecode } }); |
| | | } |
| | | } |
| | | 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 StepSearch(string stepcode, string stepname, string enable, string steptypecode, string createuser, int startNum, int endNum, string prop, string order) |
| | | { |
| | | var dynamicParams = new DynamicParameters(); |
| | | string search = ""; |
| | | try |
| | | { |
| | | if (stepcode != "" && stepcode != null) |
| | | { |
| | | search += "and stepcode like '%'+@stepcode+'%' "; |
| | | dynamicParams.Add("@stepcode", stepcode); |
| | | } |
| | | if (stepname != "" && stepname != null) |
| | | { |
| | | search += "and stepname like '%'+@stepname+'%' "; |
| | | dynamicParams.Add("@stepname", stepname); |
| | | } |
| | | if (enable != "" && enable != null) |
| | | { |
| | | search += "and enable=@enable "; |
| | | dynamicParams.Add("@enable", enable); |
| | | } |
| | | if (steptypecode != "" && steptypecode != null) |
| | | { |
| | | search += "and flwtype=@steptypecode "; |
| | | dynamicParams.Add("@steptypecode", steptypecode); |
| | | } |
| | | if (createuser != "" && createuser != null) |
| | | { |
| | | search += "and lm_user=@createuser "; |
| | | dynamicParams.Add("@createuser", createuser); |
| | | } |
| | | if (search == "") |
| | | { |
| | | search = "and 1=1 "; |
| | | } |
| | | // --------------查询指定数据-------------- |
| | | var total = 0; //总条数 |
| | | var sql = @"select stepcode,stepname,flwtype,enable,descr,lm_user,lm_date,is_eqp,is_defect |
| | | from TStep |
| | | where 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 AddUpdateStep(string stepid, string stepcode, string stepname, string steptypecode, string enable, string description, string username, string operType) |
| | | { |
| | | var dynamicParams = new DynamicParameters(); |
| | | try |
| | | { |
| | | if (operType == "Add") |
| | | { |
| | | var sql = @"insert into TStep(stepcode,stepname,flwtype,enable,descr,lm_user,lm_date) |
| | | values(@stepcode,@stepname,@steptypecode,@enable,@description,@username,@CreateDate)"; |
| | | dynamicParams.Add("@stepcode", stepcode); |
| | | dynamicParams.Add("@stepname", stepname); |
| | | dynamicParams.Add("@steptypecode", steptypecode); |
| | | dynamicParams.Add("@enable", enable); |
| | | dynamicParams.Add("@description", description); |
| | | dynamicParams.Add("@username", username); |
| | | 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") |
| | | { |
| | | //如果当前工序使用状态位N(未启用),需判断当前工序对应工艺路线被引用的工单是否关闭 |
| | | if (enable == "N") |
| | | { |
| | | var sql0 = @"select * from TFlw_Rtdt A |
| | | inner join TK_Wrk_Man B on A.rout_code=B.route_code |
| | | where A.step_code=@stepcode and B.status<>'CLOSED'"; |
| | | dynamicParams.Add("@stepcode", stepcode); |
| | | var data = DapperHelper.selectdata(sql0, dynamicParams); |
| | | if (data.Rows.Count > 0) |
| | | { |
| | | mes.code = "300"; |
| | | mes.count = 0; |
| | | mes.Message = "工序有为执行完的工单,工序状态不能为未启用!"; |
| | | mes.data = null; |
| | | return mes; |
| | | } |
| | | } |
| | | |
| | | var sql = @"update TStep set stepname=@stepname,flwtype=@steptypecode,enable=@enable,descr=@description, |
| | | lm_user=@username,lm_date=@CreateDate where id=@stepid"; |
| | | dynamicParams.Add("@stepid", stepid); |
| | | dynamicParams.Add("@stepname", stepname); |
| | | dynamicParams.Add("@steptypecode", steptypecode); |
| | | dynamicParams.Add("@enable", enable); |
| | | dynamicParams.Add("@description", description); |
| | | dynamicParams.Add("@username", username); |
| | | 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 DeleteStep(string stepcode) |
| | | { |
| | | var sql = ""; |
| | | List<object> list = new List<object>(); |
| | | var dynamicParams = new DynamicParameters(); |
| | | try |
| | | { |
| | | list.Clear(); |
| | | //当前工序是否关联工艺路线 |
| | | sql = @"select * from TFlw_Rtdt |
| | | where step_code=@stepcode"; |
| | | dynamicParams.Add("@stepcode", 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 = @"delete TPrteEqp_Stad where stepcode=@stepcode"; |
| | | list.Add(new { str = sql, parm = new { stepcode = stepcode } }); |
| | | //删除工序关联工作站表 |
| | | sql = @"delete TFlw_Rteqp where step_code=@stepcode"; |
| | | list.Add(new { str = sql, parm = new { stepcode = stepcode } }); |
| | | //删除缺陷关联工序表 |
| | | sql = @"update TDefect_Step where step_code=@stepcode"; |
| | | list.Add(new { str = sql, parm = new { stepcode = stepcode } }); |
| | | //删除工序 |
| | | sql = @"update TStep set is_delete='1' where partcode=@stepcode"; |
| | | list.Add(new { str = sql, parm = new { stepcode = stepcode } }); |
| | | 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 StepAssociationEqp(string stepcode) |
| | | { |
| | | string sql = ""; |
| | | var dynamicParams = new DynamicParameters(); |
| | | List<StepEqp> list = new List<StepEqp>(); |
| | | try |
| | | { |
| | | //获取工作站集合(车间、外协供应商,包含已绑定工作站标识) |
| | | sql = @"select distinct T.org_code as wksp_code,T.org_name as wksp_name,'E' as type,(case when B.eqp_code is null then 'N' else 'Y' end) flag from TOrganization T |
| | | left join( |
| | | select distinct A.eqp_code,B.wksp_code from TFlw_Rteqp A |
| | | inner join TEqpInfo B on A.eqp_code=B.code |
| | | where A.step_code=@stepcode and A.is_delete<>'1' and B.is_delete<>'1' |
| | | ) B on T.org_code=B.wksp_code where T.description='W' and is_delete<>'1' |
| | | UNION ALL |
| | | select distinct T.btype as wksp_code,(case T.btype when 'WX' then '外协供方' end ) as wksp_name,'W' as type,(case when B.btype is null then 'N' else 'Y' end) flag |
| | | from TCustomer T |
| | | left join( |
| | | select distinct A.eqp_code,B.btype from TFlw_Rteqp A |
| | | inner join TCustomer B on A.eqp_code=B.code |
| | | where A.step_code=@stepcode and A.is_delete<>'1' and B.is_delete<>'1' |
| | | ) B on T.code=B.eqp_code where T.btype='WX' and T.is_delete<>'1'"; |
| | | dynamicParams.Add("@stepcode", stepcode); |
| | | var data = DapperHelper.selectdata(sql, dynamicParams); |
| | | for (int i = 0; i < data.Rows.Count; i++) |
| | | { |
| | | StepEqp rout = new StepEqp(); |
| | | 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<StepEqpCn>(); |
| | | if (rout.code == "WX") //外协供方 |
| | | { |
| | | //根据外协供方标识编码查找外协供方信息(包含已关联标识) |
| | | sql = @"select A.code,A.name,'W' as type,(case when B.eqp_code is null then 'N' else 'Y' end) flag |
| | | from TCustomer A |
| | | left join( |
| | | select distinct A.eqp_code from TFlw_Rteqp A |
| | | inner join TCustomer B on A.eqp_code=B.code |
| | | where B.btype=@wxcode and A.is_delete<>'1' and B.is_delete<>'1' |
| | | ) B on A.code=B.eqp_code where A.btype=@wxcode and A.is_delete<>'1'"; |
| | | dynamicParams.Add("@wxcode", rout.code); |
| | | var data0 = DapperHelper.selectdata(sql, dynamicParams); |
| | | for (int k = 0; k < data0.Rows.Count; k++) |
| | | { |
| | | StepEqpCn cn = new StepEqpCn(); |
| | | cn.code = data0.Rows[k]["CODE"].ToString();//外协供方编码 |
| | | cn.name = data0.Rows[k]["NAME"].ToString();//外协供方名称 |
| | | cn.type = data0.Rows[k]["TYPE"].ToString();//工作站类型(E:设备 W:外协供方) |
| | | cn.flag = data0.Rows[k]["FLAG"].ToString();//关联标识 |
| | | rout.children.Add(cn); |
| | | } |
| | | list.Add(rout); |
| | | } |
| | | else |
| | | { |
| | | //根据车间编码查找设备(包含已关联标识) |
| | | sql = @"select A.code,A.name,'E' as type,(case when B.eqp_code is null then 'N' else 'Y' end) flag |
| | | from TEqpInfo A |
| | | left join( |
| | | select distinct A.eqp_code from TFlw_Rteqp A |
| | | inner join TEqpInfo B on A.eqp_code=B.code |
| | | where B.wksp_code='W001' and A.is_delete<>'1' and B.is_delete<>'1' |
| | | ) B on A.code=B.eqp_code and A.is_delete<>'1'"; |
| | | dynamicParams.Add("@stepcode", stepcode); |
| | | var data0 = DapperHelper.selectdata(sql, dynamicParams); |
| | | for (int j = 0; j < data0.Rows.Count; j++) |
| | | { |
| | | StepEqpCn cn = new StepEqpCn(); |
| | | 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 SaveStepAssociationEqp(string stepcode, string username, List<ObjectData> json) |
| | | { |
| | | var sql = ""; |
| | | List<object> list = new List<object>(); |
| | | try |
| | | { |
| | | list.Clear(); |
| | | if (json == null || json.Count <= 0) |
| | | { |
| | | //清除工序关联工作站表数据 |
| | | sql = @"delete TFlw_Rteqp where step_code=@stepcode"; |
| | | list.Add(new { str = sql, parm = new { stepcode = stepcode } }); |
| | | //标记工序表关联工作站标识 |
| | | sql = @"update TStep is_eqp='N' where stepcode=@stepcode"; |
| | | list.Add(new { str = sql, parm = new { stepcode = stepcode } }); |
| | | } |
| | | else |
| | | { |
| | | //清除工序关联工作站表数据 |
| | | sql = @"delete TFlw_Rteqp where step_code=@stepcode"; |
| | | list.Add(new { str = sql, parm = new { stepcode = stepcode } }); |
| | | //循环写入用户关联角色表 |
| | | for (int i = 0; i < json.Count; i++) |
| | | { |
| | | sql = @"insert into TFlw_Rteqp(eqp_code,step_code,style,lm_user,lm_date) values(@eqp_code,@stepcode,@style,@lm_user,@lm_date)"; |
| | | list.Add(new |
| | | { |
| | | str = sql, |
| | | parm = new |
| | | { |
| | | eqp_code = json[i].code, |
| | | stepcode = stepcode, |
| | | style = json[i].name, |
| | | lm_user = username, |
| | | lm_date = DateTime.Now.ToString() |
| | | } |
| | | }); |
| | | } |
| | | //标记物料表关联工艺路线标识 |
| | | sql = @"update TStep set is_eqp='Y' where stepcode=@stepcode"; |
| | | list.Add(new { str = sql, parm = new { stepcode = stepcode } }); |
| | | } |
| | | 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 |
| | | } |
| | | } |