| ¶Ô±ÈÐÂÎļþ |
| | |
| | | using Dapper; |
| | | using System; |
| | | using System.Collections.Generic; |
| | | using System.Data; |
| | | using System.Data.SqlClient; |
| | | using System.Linq; |
| | | using System.Threading.Tasks; |
| | | using VueWebCoreApi.Models; |
| | | using VueWebCoreApi.Models.UnitMaterial; |
| | | using VueWebCoreApi.Tools; |
| | | |
| | | namespace VueWebCoreApi.DLL.DAL |
| | | { |
| | | public class ProductModelDAL |
| | | { |
| | | public static DataTable dt; //å®ä¹å
¨å±åédt |
| | | public static bool res; //å®ä¹å
¨å±åédt |
| | | public static ToMessage mes = new ToMessage(); //å®ä¹å
¨å±è¿åä¿¡æ¯å¯¹è±¡ |
| | | public static string strProcName = ""; //å®ä¹å
¨å±sqlåé |
| | | public static List<SqlParameter> listStr = new List<SqlParameter>(); //å®ä¹å
¨å±åæ°éå |
| | | public static SqlParameter[] parameters; //å®ä¹å
¨å±SqlParameteråæ°æ°ç» |
| | | |
| | | |
| | | #region[计éåä½ç»ä¿¡æ¯] |
| | | public static ToMessage TUnitGroup() |
| | | { |
| | | string sql = ""; |
| | | try |
| | | { |
| | | //è·å计éåä½ç»ä¿¡æ¯ |
| | | sql = @"select code,name,'1' as isGroup,data_sources from TUnitGroup "; |
| | | 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 TUnitData(string tunittype, string tunitgroupcode, int startNum, int endNum, string prop, string order) |
| | | { |
| | | var dynamicParams = new DynamicParameters(); |
| | | string sql = ""; |
| | | IEnumerable<object> data; |
| | | try |
| | | { |
| | | if (tunittype == "" || tunittype == null) |
| | | { |
| | | sql = @"select code,name,lm_user,lm_date,isGroup,idunitgroup,data_sources |
| | | from TUnit T where T.isGroup='0' |
| | | union all |
| | | select code,name,lm_user,lm_date,'1' as isGroup,code as idunitgroup,data_sources |
| | | from TUnitGroup "; |
| | | } |
| | | if (tunittype == "S") //å计é |
| | | { |
| | | sql = @"select code,name,lm_user,lm_date,isGroup,idunitgroup,data_sources from TUnit where isSingleUnit='1' and isGroup='0'"; |
| | | } |
| | | if (tunittype == "M" && (tunitgroupcode == "" || tunitgroupcode == null)) //å¤è®¡é,ä¸å¤è®¡éç»ç¼ç 为空 |
| | | { |
| | | sql = @"select code,name,lm_user,lm_date,'1' as isGroup,code as idunitgroup,data_sources from TUnitGroup"; |
| | | } |
| | | if (tunittype == "M" && (tunitgroupcode != "" && tunitgroupcode != null)) //å¤è®¡é,ä¸å¤è®¡éç»ç¼ç ä¸ä¸ºç©º |
| | | { |
| | | sql = @"select code,name,isMainUnit,changeRate,rateDescription,lm_user,lm_date,isGroup,idunitgroup,data_sources |
| | | from TUnit where isSingleUnit='0' and isGroup='1' and idunitgroup=@tunitgroupcode"; |
| | | dynamicParams.Add("@tunitgroupcode", tunitgroupcode); |
| | | } |
| | | // --------------æ¥è¯¢æå®æ°æ®-------------- |
| | | var total = 0; //æ»æ¡æ° |
| | | 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 TUnitGroupProject(string unitcode, string isgroup, User us) |
| | | { |
| | | var dynamicParams = new DynamicParameters(); |
| | | string sql = ""; |
| | | try |
| | | { |
| | | //è·å计éåä½ç»å¯¹åºç计éåä½ä¿¡æ¯ |
| | | sql = @"select code,name,isMainUnit,changeRate,rateDescription,lm_user,lm_date,data_sources |
| | | from TUnit where isSingleUnit='0' and isGroup=@isgroup and idunitgroup=@tunitgroupcode "; |
| | | dynamicParams.Add("@isGroup", isgroup); |
| | | dynamicParams.Add("@tunitgroupcode", unitcode); |
| | | 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 AddUpdateTUnit(string menucode, string data_sources, string tunittype, string tunitgroupcode, string OperType, List<Unit> listjson, User us) |
| | | { |
| | | string sql = ""; |
| | | List<object> list = new List<object>(); |
| | | var dynamicParams = new DynamicParameters(); |
| | | try |
| | | { |
| | | if (OperType == "Add") |
| | | { |
| | | //è·å计éåä½ç¼ç |
| | | mes = SeachEncodeJob.EncodingSeach(menucode); |
| | | if (mes.code == "300") |
| | | { |
| | | return mes; |
| | | } |
| | | if (tunittype == "S") //å计é |
| | | { |
| | | sql = @"select * from TUnit where isGroup='0' and name=@name"; |
| | | dynamicParams.Add("@name", listjson[0].unitname); |
| | | var data = DapperHelper.selectdata(sql, dynamicParams); |
| | | if (data.Rows.Count > 0) |
| | | { |
| | | mes.code = "300"; |
| | | mes.count = 0; |
| | | mes.Message = "计éåä½çåç§°ä¸è½éå¤,è¯·éæ°è¾å
¥!"; |
| | | mes.data = null; |
| | | return mes; |
| | | } |
| | | } |
| | | if (tunittype == "M")//å¤è®¡é |
| | | { |
| | | sql = @"select * from TUnitGroup where name=@name"; |
| | | dynamicParams.Add("@name", listjson[0].unitname); |
| | | 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 TUnitGroup(code,name,lm_user,lm_date,data_sources) |
| | | values(@code,@name,@lm_user,@lm_date,@data_sources)"; |
| | | list.Add(new |
| | | { |
| | | str = sql, |
| | | parm = new |
| | | { |
| | | code = ((List<string>)mes.data)[0].ToString(), |
| | | name = listjson[0].unitname, |
| | | data_sources = data_sources, |
| | | lm_user = us.usercode, |
| | | lm_date = DateTime.Now.ToString() |
| | | } |
| | | }); |
| | | } |
| | | for (int i = 0; i < listjson[0].children.Count; i++) |
| | | { |
| | | //åå
¥è®¡éåä½ |
| | | sql = @"insert into TUnit(code,name,isMainUnit,changeRate,rateDescription,isSingleUnit,disabled,idunitgroup,isGroup,data_sources,lm_user,lm_date) |
| | | values(@code,@name,@isMainUnit,@changeRate,@rateDescription,@isSingleUnit,@disabled,@idunitgroup,@isGroup,@data_sources,@lm_user,@lm_date)"; |
| | | list.Add(new |
| | | { |
| | | str = sql, |
| | | parm = new |
| | | { |
| | | code = tunittype == "S" ? ((List<string>)mes.data)[0].ToString() : listjson[0].children[i].unitcode, |
| | | name = listjson[0].children[i].unitname, |
| | | isMainUnit = listjson[0].children[i].isMainUnit, |
| | | changeRate = listjson[0].children[i].changeRate, |
| | | rateDescription = listjson[0].children[i].rateDescription, |
| | | isSingleUnit = listjson[0].children[i].isSingleUnit, |
| | | disabled = listjson[0].children[i].disabled, |
| | | idunitgroup = ((List<string>)mes.data)[0].ToString(), |
| | | isGroup = listjson[0].children[i].isGroup, |
| | | data_sources = data_sources, |
| | | lm_user = us.usercode, |
| | | lm_date = DateTime.Now.ToString() |
| | | } |
| | | }); |
| | | } |
| | | //ååç¼ç è§å表 |
| | | list.AddRange(SeachEncodeJob.StrEncodingUpdate(menucode, ((List<string>)mes.data)[1].ToString())); |
| | | bool aa = DapperHelper.DoTransaction(list); |
| | | if (aa) |
| | | { |
| | | //åå
¥æä½è®°å½è¡¨ |
| | | LogHelper.DbOperateLog(us.usercode, "æ°å¢", "æ°å¢äºè®¡éåä½", 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") |
| | | { |
| | | if (tunittype == "S") //å计é |
| | | { |
| | | sql = @"select * from TUnit where isGroup='0' and name=@name"; |
| | | dynamicParams.Add("@name", listjson[0].unitname); |
| | | 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 = @"update TUnit set name=@name,lm_user=@lm_user,lm_date=@lm_date |
| | | where code=@code and isSingleUnit=@isSingleUnit and isGroup=@isGroup"; |
| | | list.Add(new |
| | | { |
| | | str = sql, |
| | | parm = new |
| | | { |
| | | code = listjson[0].children[0].unitcode, |
| | | name = listjson[0].children[0].unitname, |
| | | isSingleUnit = listjson[0].children[0].isSingleUnit, |
| | | isGroup = listjson[0].children[0].isGroup, |
| | | lm_user = us.usercode, |
| | | lm_date = DateTime.Now.ToString() |
| | | } |
| | | }); |
| | | |
| | | } |
| | | if (tunittype == "M")//å¤è®¡é |
| | | { |
| | | sql = @"select * from TUnitGroup where name=@name"; |
| | | dynamicParams.Add("@name", listjson[0].unitname); |
| | | 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 = @"update TUnitGroup set name=@name,lm_user=@lm_user,lm_date=@lm_date where code=@code"; |
| | | list.Add(new |
| | | { |
| | | str = sql, |
| | | parm = new |
| | | { |
| | | code = listjson[0].unitcode, |
| | | name = listjson[0].unitname, |
| | | lm_user = us.usercode, |
| | | lm_date = DateTime.Now.ToString() |
| | | } |
| | | }); |
| | | //å é¤è®¡éåä½ç»æç»(ä»è®¡éåä½è¡¨å é¤) |
| | | sql = @"delete TUnit where idunitgroup=@idunitgroup"; |
| | | list.Add(new |
| | | { |
| | | str = sql, |
| | | parm = new |
| | | { |
| | | idunitgroup = tunitgroupcode |
| | | } |
| | | }); |
| | | for (int i = 0; i < listjson[0].children.Count; i++) |
| | | { |
| | | //åå
¥è®¡éåä½ |
| | | sql = @"insert into TUnit(code,name,isMainUnit,changeRate,rateDescription,isSingleUnit,disabled,idunitgroup,isGroup,data_sources,lm_user,lm_date) |
| | | values(@code,@name,@isMainUnit,@changeRate,@rateDescription,@isSingleUnit,@disabled,@idunitgroup,@isGroup,@data_sources,@lm_user,@lm_date)"; |
| | | list.Add(new |
| | | { |
| | | str = sql, |
| | | parm = new |
| | | { |
| | | code = listjson[0].children[i].unitcode, |
| | | name = listjson[0].children[i].unitname, |
| | | isMainUnit = listjson[0].children[i].isMainUnit, |
| | | changeRate = listjson[0].children[i].changeRate, |
| | | rateDescription = listjson[0].children[i].rateDescription, |
| | | isSingleUnit = listjson[0].children[i].isSingleUnit, |
| | | disabled = listjson[0].children[i].disabled, |
| | | idunitgroup = listjson[0].children[i].idunitgroup, |
| | | isGroup = listjson[0].children[i].isGroup, |
| | | data_sources = data_sources, |
| | | lm_user = us.usercode, |
| | | lm_date = DateTime.Now.ToString() |
| | | } |
| | | }); |
| | | } |
| | | } |
| | | |
| | | bool aa = DapperHelper.DoTransaction(list); |
| | | if (aa) |
| | | { |
| | | //åå
¥æä½è®°å½è¡¨ |
| | | LogHelper.DbOperateLog(us.usercode, "ä¿®æ¹", "ä¿®æ¹äºè®¡éåä½", 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 DeleteTUnit(string data_sources, string tunittype, string tunitgroupcode, string tunitcode, User us) |
| | | { |
| | | string sql = ""; |
| | | List<object> list = new List<object>(); |
| | | var dynamicParams = new DynamicParameters(); |
| | | try |
| | | { |
| | | if (tunittype == "S") //å计é |
| | | { |
| | | sql = @"select * from TMateriel_Info where isSingleUnit='1' and idunit=@idunit"; |
| | | dynamicParams.Add("@idunit", tunitgroupcode); |
| | | 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 TUnit where isSingleUnit='1' and isGroup='0' and code=@code and data_sources=@data_sources"; |
| | | list.Add(new |
| | | { |
| | | str = sql, |
| | | parm = new |
| | | { |
| | | code = tunitcode, |
| | | data_sources = data_sources |
| | | } |
| | | }); |
| | | } |
| | | if (tunittype == "M" && (tunitgroupcode == "" || tunitgroupcode == null)) //å¤è®¡é,ä¸å¤è®¡éç»ç¼ç 为空 |
| | | { |
| | | sql = @"select * from TUnit T |
| | | inner join TMateriel_Info M on T.idunitgroup=M.idunitgroup and T.code=M.idunit |
| | | where T.isSingleUnit='0' and T.idunitgroup=@idunitgroup"; |
| | | dynamicParams.Add("@idunitgroup", tunitgroupcode); |
| | | 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 TUnitGroup where code=@code and data_sources=@data_sources"; |
| | | list.Add(new |
| | | { |
| | | str = sql, |
| | | parm = new |
| | | { |
| | | code = tunitgroupcode, |
| | | data_sources = data_sources |
| | | } |
| | | }); |
| | | //å é¤å¤è®¡éåä½ç»ä¸ææè®¡éåä½ |
| | | sql = @"delete TUnit where isSingleUnit='0' and isGroup='1' where idunitgroup=@idunitgroup and data_sources=@data_sources"; |
| | | list.Add(new |
| | | { |
| | | str = sql, |
| | | parm = new |
| | | { |
| | | idunitgroup= tunitgroupcode, |
| | | data_sources = data_sources |
| | | } |
| | | }); |
| | | } |
| | | if (tunittype == "M" && (tunitgroupcode != "" && tunitgroupcode != null)) //å¤è®¡é,ä¸å¤è®¡éç»ç¼ç ä¸ä¸ºç©º |
| | | { |
| | | sql = @"select * from TUnit T |
| | | inner join TMateriel_Info M on T.idunitgroup=M.idunitgroup and T.code=M.idunit |
| | | where T.isSingleUnit='0' and M.isSingleUnit='0' and T.idunitgroup=@idunitgroup and T.code=@idunit"; |
| | | dynamicParams.Add("@idunitgroup", tunitgroupcode); |
| | | dynamicParams.Add("@idunit", tunitcode); |
| | | 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 TUnit where isSingleUnit='0' and isGroup='1' where idunitgroup=@idunitgroup and code=@code and data_sources=@data_sources"; |
| | | list.Add(new |
| | | { |
| | | str = sql, |
| | | parm = new |
| | | { |
| | | idunitgroup = tunitgroupcode, |
| | | code = tunitcode, |
| | | data_sources = data_sources |
| | | } |
| | | }); |
| | | } |
| | | bool aa = DapperHelper.DoTransaction(list); |
| | | if (aa) |
| | | { |
| | | //åå
¥æä½è®°å½è¡¨ |
| | | LogHelper.DbOperateLog(us.usercode, "å é¤", "å é¤äºè®¡éåä½", 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 |
| | | } |
| | | } |