| | |
| | | public static List<SqlParameter> listStr = new List<SqlParameter>(); //定义全局参数集合 |
| | | public static SqlParameter[] parameters; //定义全局SqlParameter参数数组 |
| | | |
| | | #region[设备类型查询] |
| | | public static ToMessage DeviceTypeSearch(int startNum, int endNum, string prop, string order) |
| | | { |
| | | var dynamicParams = new DynamicParameters(); |
| | | try |
| | | { |
| | | // --------------查询指定数据-------------- |
| | | var total = 0; //总条数 |
| | | var sql = @"select id, code,name,remark |
| | | from TEqpType |
| | | where 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 AddUpdateDeviceType(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 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 = username, |
| | | createdate = DateTime.Now.ToString(), |
| | | description = json[i].description |
| | | } |
| | | }); |
| | | } |
| | | 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 DeleteDeviceType(string devicetypecode) |
| | | { |
| | | var sql = ""; |
| | | List<object> list = new List<object>(); |
| | | var dynamicParams = new DynamicParameters(); |
| | | try |
| | | { |
| | | list.Clear(); |
| | | //判断设备类型下是否关联设备组 |
| | | sql = @"select * from TEqpGroup where eqptype_code=@devicetypecode and is_delete<>'1'"; |
| | | dynamicParams.Add("@devicetypecode", devicetypecode); |
| | | 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 TEqpInfo where eqptype_code=@devicetypecode and is_delete<>'1'"; |
| | | 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) |
| | | { |
| | | 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 DeviceTypeSelect() |
| | | { |
| | | string sql = ""; |
| | | var dynamicParams = new DynamicParameters(); |
| | | List<TreeObejct> list = new List<TreeObejct>(); |
| | | try |
| | | { |
| | | //获取设备类型数据 |
| | | sql = @"select code,name from TEqpType 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 DeviceGroupSearch(int startNum, int endNum, string prop, string order) |
| | |
| | | } |
| | | #endregion |
| | | |
| | | #region [设备清单查询] |
| | | public static ToMessage DeviceMangerSearch(string stu_torgcode, string description, string deviceCode, string deviceName, string status, string workShop, string deviceType, string deviceGroup, int startNum, int endNum, string prop, string order) |
| | | { |
| | | var dynamicParams = new DynamicParameters(); |
| | | string search = ""; |
| | | try |
| | | { |
| | | if (workShop != "" && workShop != null) |
| | | { |
| | | search += "and A.wksp_code=@workShop "; |
| | | dynamicParams.Add("@workShop", workShop); |
| | | } |
| | | else |
| | | { |
| | | switch (description) |
| | | { |
| | | case "": |
| | | search += "and T.description=@description "; |
| | | dynamicParams.Add("@description", "W"); |
| | | break; |
| | | case "D": |
| | | search += "and L.org_code=@stu_torgcode "; |
| | | dynamicParams.Add("@stu_torgcode", stu_torgcode); |
| | | break; |
| | | } |
| | | } |
| | | 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 (deviceType != "" && deviceType != null) |
| | | { |
| | | search += "and A.eqptype_code=@deviceType "; |
| | | dynamicParams.Add("@deviceType", deviceType); |
| | | } |
| | | if (deviceGroup != "" && deviceGroup != null) |
| | | { |
| | | search += "and A.eqpgroup_code=@deviceGroup "; |
| | | dynamicParams.Add("@deviceGroup", deviceGroup); |
| | | } |
| | | if (search == "") |
| | | { |
| | | search = "and 1=1 "; |
| | | } |
| | | //search = search.Substring(3);//截取索引2后面的字符 |
| | | // --------------查询指定数据-------------- |
| | | var total = 0; //总条数 |
| | | var sql = @"select A.id,A.code,A.name,A.eqptype_code,B.name as eqptype_name,A.eqpgroup_code,G.name as eqpgroup_name,A.enable, |
| | | A.input_date,A.wksp_code,T.org_name as wksp_name,A.Line_code,L.org_name as Line_name,A.opc_uom,A.operation_ration,U.username as lm_user,A.lm_date |
| | | from TEqpInfo A |
| | | left join TEqpType B on A.eqptype_code=B.code |
| | | left join TEqpGroup G on A.eqpgroup_code=G.code |
| | | left join TOrganization T on A.wksp_code=T.org_code |
| | | left join TOrganization as L on T.parent_id=L.id |
| | | 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 AddUpdateDeviceManger(string deviceid, string devicecode, string devicename, string devicetype, string devicegroup, string importdate, string workshop, string linecode, string status, string ratio, string usercode, string operType) |
| | | { |
| | | var dynamicParams = new DynamicParameters(); |
| | | try |
| | | { |
| | | if (operType == "Add") |
| | | { |
| | | var sql = @"insert into TEqpInfo(code,name,eqptype_code,eqpgroup_code,wksp_code,line_code,input_date,operation_ration,enable,opc_uom,lm_user,lm_date) |
| | | values(@devicecode,@devicename,@devicetype,@devicegroup,@workshop,@linecode,@importdate,@ratio,@status,@uom,@usercode,@CreateDate)"; |
| | | dynamicParams.Add("@devicecode", devicecode); |
| | | dynamicParams.Add("@devicename", devicename); |
| | | dynamicParams.Add("@devicetype", devicetype); |
| | | dynamicParams.Add("@devicegroup", devicegroup); |
| | | dynamicParams.Add("@workshop", workshop); |
| | | dynamicParams.Add("@linecode", linecode); |
| | | dynamicParams.Add("@importdate", importdate); |
| | | dynamicParams.Add("@ratio", ratio); |
| | | dynamicParams.Add("@status", status); |
| | | dynamicParams.Add("@uom", "台"); |
| | | dynamicParams.Add("@usercode", 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 TEqpInfo set name=@devicename,eqptype_code=@devicetype,eqpgroup_code=@devicegroup,input_date=@importdate, |
| | | wksp_code=@workshop,line_code=@linecode,enable=@status,operation_ration=@ratio,lm_user=@usercode,lm_date=@CreateDate |
| | | where id=@deviceid"; |
| | | dynamicParams.Add("@deviceid", deviceid); |
| | | dynamicParams.Add("@devicename", devicename); |
| | | dynamicParams.Add("@devicetype", devicetype); |
| | | dynamicParams.Add("@devicegroup", devicegroup); |
| | | dynamicParams.Add("@workshop", workshop); |
| | | dynamicParams.Add("@linecode", linecode); |
| | | dynamicParams.Add("@importdate", importdate); |
| | | dynamicParams.Add("@ratio", ratio); |
| | | dynamicParams.Add("@status", status); |
| | | dynamicParams.Add("@usercode", 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 DeleteDeviceManger(string devicecode) |
| | | { |
| | | var sql = ""; |
| | | List<object> list = new List<object>(); |
| | | var dynamicParams = new DynamicParameters(); |
| | | try |
| | | { |
| | | list.Clear(); |
| | | //判断设备是否有关联工艺路线的生产订单(未关闭),不允许删除 |
| | | sql = @"select A.code,M.wo_code,R.name from TEqpInfo A |
| | | inner join TFlw_Rteqp B on A.code=B.eqp_code |
| | | inner join TStep C on B.step_code=C.stepcode |
| | | inner join TFlw_Rtdt D on C.stepcode=D.step_code |
| | | inner join TFlw_Rout R on D.rout_code=R.code |
| | | inner join TK_Wrk_Man M on R.code=M.route_code |
| | | where A.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 TFlw_Rteqp |
| | | where eqp_code=@devicecode"; |
| | | dynamicParams.Add("@devicecode", devicecode); |
| | | var data0 = 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 TPrteEqp_Stad |
| | | where eqp_code=@devicecode"; |
| | | dynamicParams.Add("@devicecode", devicecode); |
| | | var data1 = DapperHelper.selectdata(sql, dynamicParams); |
| | | if (data.Rows.Count > 0) |
| | | { |
| | | mes.code = "300"; |
| | | mes.count = 0; |
| | | mes.Message = "当前设备已指定节拍工价,不允许删除!"; |
| | | mes.data = null; |
| | | return mes; |
| | | } |
| | | |
| | | //删除设备 |
| | | sql = @"update TEqpInfo set is_delete='1' where code=@devicecode"; |
| | | list.Add(new { str = sql, parm = new { devicecode = devicecode } }); |
| | | //删除设备关联点检标准表 |
| | | sql = @"delete TEqpchk_Eqp where eqp_code=@devicecode"; |
| | | list.Add(new { str = sql, parm = new { devicecode = devicecode } }); |
| | | //删除设备绑定保养标准表 |
| | | sql = @"delete TEqpmai_Eqp where eqp_code=@devicecode"; |
| | | list.Add(new { str = sql, parm = new { devicecode = devicecode } }); |
| | | 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 |
| | | |
| | | |
| | | |
| | |
| | | return mes; |
| | | } |
| | | #endregion |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | #region[设备类型查询] |
| | | public static ToMessage DeviceTypeSearch(int startNum, int endNum, string prop, string order) |
| | | { |
| | | var dynamicParams = new DynamicParameters(); |
| | | try |
| | | { |
| | | // --------------查询指定数据-------------- |
| | | var total = 0; //总条数 |
| | | var sql = @"select id, code,name,remark |
| | | from TEqpType"; |
| | | 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 AddUpdateDeviceType(List<ObjectDataCont> json, User us) |
| | | { |
| | | 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 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; |
| | | } |
| | | } |
| | | 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 |
| | | |
| | | |
| | | } |
| | | } |