/** 版本信息模板在安装目录下,可自行修改。 * pow_achievement.cs * * 功 能: N/A * 类 名: pow_achievement * * Ver 变更日期 负责人 变更内容 * ─────────────────────────────────── * V0.01 2022/7/3 15:08:38 N/A 初版 * * Copyright (c) 2012 Maticsoft Corporation. All rights reserved. *┌──────────────────────────────────┐ *│ 此技术信息为本公司机密信息,未经本公司书面同意禁止向第三方披露. │ *│ 版权所有:动软卓越(北京)科技有限公司              │ *└──────────────────────────────────┘ */ using System; using System.Data; using System.Text; using MySql.Data.MySqlClient; using Maticsoft.DBUtility; using System.Collections.Generic; using Competition.Mysql.Other; namespace Competition.Mysql.DAL { /// /// 数据访问类:pow_achievement /// public partial class pow_achievement { public pow_achievement() { } #region BasicMethod /// /// 是否存在该记录 /// public bool Exists(string AchievementId) { StringBuilder strSql = new StringBuilder(); strSql.Append("select count(1) from pow_achievement"); strSql.Append(" where AchievementId=@AchievementId "); MySqlParameter[] parameters = { new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32) }; parameters[0].Value = AchievementId; return DbHelperMySQL.Exists(strSql.ToString(), parameters); } /// /// 增加一条数据 /// public bool Add(Competition.Mysql.Model.pow_achievement model) { StringBuilder strSql = new StringBuilder(); strSql.Append("insert into pow_achievement("); strSql.Append("AchievementId,ExamId,ExamName,UserId,LoginName,RealName,ExamEndTime,TotalScore,ProvinceId,ProvinceName,CityId,CityName,ExamStartTime,Remark1,Remark2,Remark3,Remark4,Remark5)"); strSql.Append(" values ("); strSql.Append("@AchievementId,@ExamId,@ExamName,@UserId,@LoginName,@RealName,@ExamEndTime,@TotalScore,@ProvinceId,@ProvinceName,@CityId,@CityName,@ExamStartTime,@Remark1,@Remark2,@Remark3,@Remark4,@Remark5)"); MySqlParameter[] parameters = { new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32), new MySqlParameter("@ExamId", MySqlDbType.VarChar,32), new MySqlParameter("@ExamName", MySqlDbType.VarChar,255), new MySqlParameter("@UserId", MySqlDbType.VarChar,50), new MySqlParameter("@LoginName", MySqlDbType.VarChar,255), new MySqlParameter("@RealName", MySqlDbType.VarChar,255), new MySqlParameter("@ExamEndTime", MySqlDbType.DateTime), new MySqlParameter("@TotalScore", MySqlDbType.Float,11), new MySqlParameter("@ProvinceId", MySqlDbType.VarChar,255), new MySqlParameter("@ProvinceName", MySqlDbType.VarChar,255), new MySqlParameter("@CityId", MySqlDbType.VarChar,255), new MySqlParameter("@CityName", MySqlDbType.VarChar,255), new MySqlParameter("@ExamStartTime", MySqlDbType.DateTime), new MySqlParameter("@Remark1", MySqlDbType.VarChar,255), new MySqlParameter("@Remark2", MySqlDbType.VarChar,255), new MySqlParameter("@Remark3", MySqlDbType.VarChar,255), new MySqlParameter("@Remark4", MySqlDbType.VarChar,255), new MySqlParameter("@Remark5", MySqlDbType.VarChar,255)}; parameters[0].Value = model.AchievementId; parameters[1].Value = model.ExamId; parameters[2].Value = model.ExamName; parameters[3].Value = model.UserId; parameters[4].Value = model.LoginName; parameters[5].Value = model.RealName; parameters[6].Value = model.ExamEndTime; parameters[7].Value = model.TotalScore; parameters[8].Value = model.ProvinceId; parameters[9].Value = model.ProvinceName; parameters[10].Value = model.CityId; parameters[11].Value = model.CityName; parameters[12].Value = model.ExamStartTime; parameters[13].Value = model.Remark1; parameters[14].Value = model.Remark2; parameters[15].Value = model.Remark3; parameters[16].Value = model.Remark4; parameters[17].Value = model.Remark5; int rows = DbHelperMySQL.ExecuteSql(strSql.ToString(), parameters); if (rows > 0) { return true; } else { return false; } } /// /// 更新一条数据 /// public bool Update(Competition.Mysql.Model.pow_achievement model) { StringBuilder strSql = new StringBuilder(); strSql.Append("update pow_achievement set "); strSql.Append("ExamId=@ExamId,"); strSql.Append("ExamName=@ExamName,"); strSql.Append("UserId=@UserId,"); strSql.Append("LoginName=@LoginName,"); strSql.Append("RealName=@RealName,"); strSql.Append("ExamEndTime=@ExamEndTime,"); strSql.Append("TotalScore=@TotalScore,"); strSql.Append("ProvinceId=@ProvinceId,"); strSql.Append("ProvinceName=@ProvinceName,"); strSql.Append("CityId=@CityId,"); strSql.Append("CityName=@CityName,"); strSql.Append("ExamStartTime=@ExamStartTime,"); strSql.Append("Remark1=@Remark1,"); strSql.Append("Remark2=@Remark2,"); strSql.Append("Remark3=@Remark3,"); strSql.Append("Remark4=@Remark4,"); strSql.Append("Remark5=@Remark5"); strSql.Append(" where AchievementId=@AchievementId "); MySqlParameter[] parameters = { new MySqlParameter("@ExamId", MySqlDbType.VarChar,32), new MySqlParameter("@ExamName", MySqlDbType.VarChar,255), new MySqlParameter("@UserId", MySqlDbType.VarChar,50), new MySqlParameter("@LoginName", MySqlDbType.VarChar,255), new MySqlParameter("@RealName", MySqlDbType.VarChar,255), new MySqlParameter("@ExamEndTime", MySqlDbType.DateTime), new MySqlParameter("@TotalScore", MySqlDbType.Float,11), new MySqlParameter("@ProvinceId", MySqlDbType.VarChar,255), new MySqlParameter("@ProvinceName", MySqlDbType.VarChar,255), new MySqlParameter("@CityId", MySqlDbType.VarChar,255), new MySqlParameter("@CityName", MySqlDbType.VarChar,255), new MySqlParameter("@ExamStartTime", MySqlDbType.DateTime), new MySqlParameter("@Remark1", MySqlDbType.VarChar,255), new MySqlParameter("@Remark2", MySqlDbType.VarChar,255), new MySqlParameter("@Remark3", MySqlDbType.VarChar,255), new MySqlParameter("@Remark4", MySqlDbType.VarChar,255), new MySqlParameter("@Remark5", MySqlDbType.VarChar,255), new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32)}; parameters[0].Value = model.ExamId; parameters[1].Value = model.ExamName; parameters[2].Value = model.UserId; parameters[3].Value = model.LoginName; parameters[4].Value = model.RealName; parameters[5].Value = model.ExamEndTime; parameters[6].Value = model.TotalScore; parameters[7].Value = model.ProvinceId; parameters[8].Value = model.ProvinceName; parameters[9].Value = model.CityId; parameters[10].Value = model.CityName; parameters[11].Value = model.ExamStartTime; parameters[12].Value = model.Remark1; parameters[13].Value = model.Remark2; parameters[14].Value = model.Remark3; parameters[15].Value = model.Remark4; parameters[16].Value = model.Remark5; parameters[17].Value = model.AchievementId; int rows = DbHelperMySQL.ExecuteSql(strSql.ToString(), parameters); if (rows > 0) { return true; } else { return false; } } /// /// 删除一条数据 /// public bool Delete(string AchievementId) { StringBuilder strSql = new StringBuilder(); strSql.Append("delete from pow_achievement "); strSql.Append(" where AchievementId=@AchievementId "); MySqlParameter[] parameters = { new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32) }; parameters[0].Value = AchievementId; int rows = DbHelperMySQL.ExecuteSql(strSql.ToString(), parameters); if (rows > 0) { return true; } else { return false; } } /// /// 批量删除数据 /// public bool DeleteList(string AchievementIdlist) { StringBuilder strSql = new StringBuilder(); strSql.Append("delete from pow_achievement "); strSql.Append(" where AchievementId in (" + AchievementIdlist + ") "); int rows = DbHelperMySQL.ExecuteSql(strSql.ToString()); if (rows > 0) { return true; } else { return false; } } /// /// 得到一个对象实体 /// public Competition.Mysql.Model.pow_achievement GetModel(string AchievementId) { StringBuilder strSql = new StringBuilder(); strSql.Append("select AchievementId,ExamId,ExamName,UserId,LoginName,RealName,ExamEndTime,TotalScore,ProvinceId,ProvinceName,CityId,CityName,ExamStartTime,Remark1,Remark2,Remark3,Remark4,Remark5 from pow_achievement "); strSql.Append(" where AchievementId=@AchievementId "); MySqlParameter[] parameters = { new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32) }; parameters[0].Value = AchievementId; Competition.Mysql.Model.pow_achievement model = new Competition.Mysql.Model.pow_achievement(); DataSet ds = DbHelperMySQL.Query(strSql.ToString(), parameters); if (ds.Tables[0].Rows.Count > 0) { return DataRowToModel(ds.Tables[0].Rows[0]); } else { return null; } } /// /// 得到一个对象实体 /// public Competition.Mysql.Model.pow_achievement DataRowToModel(DataRow row) { Competition.Mysql.Model.pow_achievement model = new Competition.Mysql.Model.pow_achievement(); if (row != null) { if (row["AchievementId"] != null) { model.AchievementId = row["AchievementId"].ToString(); } if (row["ExamId"] != null) { model.ExamId = row["ExamId"].ToString(); } if (row["ExamName"] != null) { model.ExamName = row["ExamName"].ToString(); } if (row["UserId"] != null) { model.UserId = row["UserId"].ToString(); } if (row["LoginName"] != null) { model.LoginName = row["LoginName"].ToString(); } if (row["RealName"] != null) { model.RealName = row["RealName"].ToString(); } if (row["ExamEndTime"] != null && row["ExamEndTime"].ToString() != "") { model.ExamEndTime = DateTime.Parse(row["ExamEndTime"].ToString()); } if (row["TotalScore"] != null && row["TotalScore"].ToString() != "") { model.TotalScore = decimal.Parse(row["TotalScore"].ToString()); } if (row["ProvinceId"] != null) { model.ProvinceId = row["ProvinceId"].ToString(); } if (row["ProvinceName"] != null) { model.ProvinceName = row["ProvinceName"].ToString(); } if (row["CityId"] != null) { model.CityId = row["CityId"].ToString(); } if (row["CityName"] != null) { model.CityName = row["CityName"].ToString(); } if (row["ExamStartTime"] != null && row["ExamStartTime"].ToString() != "") { model.ExamStartTime = DateTime.Parse(row["ExamStartTime"].ToString()); } if (row["Remark1"] != null) { model.Remark1 = row["Remark1"].ToString(); } if (row["Remark2"] != null) { model.Remark2 = row["Remark2"].ToString(); } if (row["Remark3"] != null) { model.Remark3 = row["Remark3"].ToString(); } if (row["Remark4"] != null) { model.Remark4 = row["Remark4"].ToString(); } if (row["Remark5"] != null) { model.Remark5 = row["Remark5"].ToString(); } } return model; } /// /// 获得数据列表 /// public DataSet GetList(string strWhere) { StringBuilder strSql = new StringBuilder(); strSql.Append("select AchievementId,ExamId,ExamName,UserId,LoginName,RealName,ExamEndTime,TotalScore,ProvinceId,ProvinceName,CityId,CityName,ExamStartTime,Remark1,Remark2,Remark3,Remark4,Remark5 "); strSql.Append(" FROM pow_achievement "); if (strWhere.Trim() != "") { strSql.Append(" where " + strWhere); } return DbHelperMySQL.Query(strSql.ToString()); } public DataSet GetListByuser(string strWhere) { StringBuilder strSql = new StringBuilder(); //strSql.Append("select AchievementId,ExamId,ExamName,UserId,LoginName,RealName,ExamEndTime,TotalScore,ProvinceId,ProvinceName,CityId,CityName,ExamStartTime,Remark1,Remark2,Remark3,Remark4,Remark5 "); //strSql.Append(" FROM pow_achievement "); strSql.Append("select T1.*,T2.OwnCity,T2.unit_name from pow_achievement T1 left join admin_user T2 on T1.UserId =T2.user_id left join pow_exam T3 on T3.ExamId=T1.ExamId "); if (strWhere.Trim() != "") { strSql.Append(" where " + strWhere); } return DbHelperMySQL.Query(strSql.ToString()); } /// /// 获取记录总数 /// public int GetRecordCount(string strWhere) { StringBuilder strSql = new StringBuilder(); strSql.Append("select count(1) FROM pow_achievement "); if (strWhere.Trim() != "") { strSql.Append(" where " + strWhere); } object obj = DbHelperMySQL.GetSingle(strSql.ToString()); if (obj == null) { return 0; } else { return Convert.ToInt32(obj); } } /// /// 分页获取数据列表 /// public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex) { StringBuilder strSql = new StringBuilder(); strSql.Append("SELECT * FROM ( "); strSql.Append(" SELECT ROW_NUMBER() OVER ("); if (!string.IsNullOrEmpty(orderby.Trim())) { strSql.Append("order by T." + orderby); } else { strSql.Append("order by T.AchievementId desc"); } strSql.Append(")AS Row, T.* from pow_achievement T "); if (!string.IsNullOrEmpty(strWhere.Trim())) { strSql.Append(" WHERE " + strWhere); } strSql.Append(" ) TT"); strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex); return DbHelperMySQL.Query(strSql.ToString()); } /* /// /// 分页获取数据列表 /// public DataSet GetList(int PageSize,int PageIndex,string strWhere) { MySqlParameter[] parameters = { new MySqlParameter("@tblName", MySqlDbType.VarChar, 255), new MySqlParameter("@fldName", MySqlDbType.VarChar, 255), new MySqlParameter("@PageSize", MySqlDbType.Int32), new MySqlParameter("@PageIndex", MySqlDbType.Int32), new MySqlParameter("@IsReCount", MySqlDbType.Bit), new MySqlParameter("@OrderType", MySqlDbType.Bit), new MySqlParameter("@strWhere", MySqlDbType.VarChar,1000), }; parameters[0].Value = "pow_achievement"; parameters[1].Value = "AchievementId"; parameters[2].Value = PageSize; parameters[3].Value = PageIndex; parameters[4].Value = 0; parameters[5].Value = 0; parameters[6].Value = strWhere; return DbHelperMySQL.RunProcedure("UP_GetRecordByPage",parameters,"ds"); }*/ #endregion BasicMethod #region ExtensionMethod /// /// 获得数据列表 /// public DataSet GetUserList(string strWhere) { StringBuilder strSql = new StringBuilder(); strSql.Append("select T1.*,T2.province,T2.city,1 as has_video,T3.ExamName,CONCAT(T1.RealName,'-',T3.ExamName,'-',T1.TotalScore,'分') as video_title from pow_achievement T1 left join admin_user T2 on T2.user_id=T1.UserId left join pow_exam T3 on T3.ExamId=T1.ExamId "); if (strWhere.Trim() != "") { strSql.Append(" where " + strWhere); } return DbHelperMySQL.Query(strSql.ToString()); } /// /// 获得数据列表 /// public DataSet GetExamList(string strWhere) { StringBuilder strSql = new StringBuilder(); strSql.Append("select T1.AchievementId,T2.ExamId,T2.ExamName,T1.UserId,T1.LoginName,T1.RealName,T1.ExamEndTime,T1.TotalScore,T1.ProvinceId,T1.ProvinceName,T1.CityId,T1.CityName,T1.ExamStartTime,T1.Remark1,T1.Remark2,T1.Remark3,T1.Remark4,T1.Remark5 from pow_achievement T1 right join pow_exam T2 on T2.ExamId=T1.ExamId "); if (strWhere.Trim() != "") { strSql.Append(" where " + strWhere); } return DbHelperMySQL.Query(strSql.ToString()); } /// /// 更新一条数据 /// public bool UpdateScore(string achievement_id, decimal total_score) { StringBuilder strSql = new StringBuilder(); strSql.Append("update pow_achievement set "); strSql.Append("TotalScore=TotalScore+@TotalScore"); strSql.Append(" where AchievementId=@AchievementId "); MySqlParameter[] parameters = { new MySqlParameter("@TotalScore", MySqlDbType.Float,11), new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32)}; parameters[0].Value = total_score; parameters[1].Value = achievement_id; int rows = DbHelperMySQL.ExecuteSql(strSql.ToString(), parameters); if (rows > 0) { return true; } else { return false; } } /// /// 使用事务批量操作删除 /// /// public int OperationDelData(string AchievementId) { List com = new List(); if (!string.IsNullOrEmpty(AchievementId)) { StringBuilder strSql = new StringBuilder(); strSql.Append("delete from pow_achievement "); strSql.Append(" where AchievementId=@AchievementId "); MySqlParameter[] parameters = { new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32) }; parameters[0].Value = AchievementId; com.Add(new CommandInfo(strSql.ToString(), parameters)); StringBuilder strSql2 = new StringBuilder(); strSql2.Append("delete from pow_achievement_details "); strSql2.Append(" where AchievementId=@AchievementId "); MySqlParameter[] parameters2 = { new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32) }; parameters2[0].Value = AchievementId; com.Add(new CommandInfo(strSql2.ToString(), parameters2)); StringBuilder strSql3 = new StringBuilder(); strSql3.Append("delete from pow_video "); strSql3.Append(" where AchievementId=@AchievementId "); MySqlParameter[] parameters3 = { new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32) }; parameters3[0].Value = AchievementId; com.Add(new CommandInfo(strSql3.ToString(), parameters3)); } return DbHelperMySQL.ExecuteSqlTran(com); } /// /// 使用事务批量操作批量删除 /// /// public int OperationDelAllData(List data) { List com = new List(); foreach (var item in data) { StringBuilder strSql = new StringBuilder(); strSql.Append("delete from pow_achievement "); strSql.Append(" where AchievementId=@AchievementId "); MySqlParameter[] parameters = { new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32) }; parameters[0].Value = item.AchievementId; com.Add(new CommandInfo(strSql.ToString(), parameters)); StringBuilder strSql2 = new StringBuilder(); strSql2.Append("delete from pow_achievement_details "); strSql2.Append(" where AchievementId=@AchievementId "); MySqlParameter[] parameters2 = { new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32) }; parameters2[0].Value = item.AchievementId; com.Add(new CommandInfo(strSql2.ToString(), parameters2)); StringBuilder strSql3 = new StringBuilder(); strSql3.Append("delete from pow_video "); strSql3.Append(" where AchievementId=@AchievementId "); MySqlParameter[] parameters3 = { new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32) }; parameters3[0].Value = item.AchievementId; com.Add(new CommandInfo(strSql3.ToString(), parameters3)); StringBuilder strSql4 = new StringBuilder(); strSql4.Append("delete from pow_user_exam "); strSql4.Append(" where ExamId=@ExamId and UserId=@UserId "); MySqlParameter[] parameters4 = { new MySqlParameter("@ExamId", MySqlDbType.VarChar,32), new MySqlParameter("@UserId", MySqlDbType.VarChar,50) }; parameters4[0].Value = item.ExamId; parameters4[1].Value = item.UserId; com.Add(new CommandInfo(strSql4.ToString(), parameters4)); StringBuilder strSql5 = new StringBuilder(); strSql5.Append("delete from pow_user_exam_log "); strSql5.Append(" where ExamId=@ExamId and UserId=@UserId "); MySqlParameter[] parameters5 = { new MySqlParameter("@ExamId", MySqlDbType.VarChar,32), new MySqlParameter("@UserId", MySqlDbType.VarChar,50) }; parameters5[0].Value = item.ExamId; parameters5[1].Value = item.UserId; com.Add(new CommandInfo(strSql5.ToString(), parameters5)); StringBuilder strSql6 = new StringBuilder(); strSql6.Append("delete from pow_user_fault "); strSql6.Append(" where ExamId=@ExamId and UserId=@UserId "); MySqlParameter[] parameters6 = { new MySqlParameter("@ExamId", MySqlDbType.VarChar,32), new MySqlParameter("@UserId", MySqlDbType.VarChar,50) }; parameters6[0].Value = item.ExamId; parameters6[1].Value = item.UserId; com.Add(new CommandInfo(strSql6.ToString(), parameters6)); StringBuilder strSql7 = new StringBuilder(); strSql7.Append("delete from pow_user_fault_record "); strSql7.Append(" where ExamId=@ExamId and UserId=@UserId "); MySqlParameter[] parameters7 = { new MySqlParameter("@ExamId", MySqlDbType.VarChar,32), new MySqlParameter("@UserId", MySqlDbType.VarChar,50) }; parameters7[0].Value = item.ExamId; parameters7[1].Value = item.UserId; com.Add(new CommandInfo(strSql7.ToString(), parameters7)); StringBuilder strSql8 = new StringBuilder(); strSql8.Append("delete from pow_user_operation_proc_ticket "); strSql8.Append(" where ExamId=@ExamId and UserId=@UserId "); MySqlParameter[] parameters8 = { new MySqlParameter("@ExamId", MySqlDbType.VarChar,32), new MySqlParameter("@UserId", MySqlDbType.VarChar,50) }; parameters8[0].Value = item.ExamId; parameters8[1].Value = item.UserId; com.Add(new CommandInfo(strSql8.ToString(), parameters8)); StringBuilder strSql9 = new StringBuilder(); strSql9.Append("delete from pow_user_operation_ticket "); strSql9.Append(" where ExamId=@ExamId and UserId=@UserId "); MySqlParameter[] parameters9 = { new MySqlParameter("@ExamId", MySqlDbType.VarChar,32), new MySqlParameter("@UserId", MySqlDbType.VarChar,50) }; parameters9[0].Value = item.ExamId; parameters9[1].Value = item.UserId; com.Add(new CommandInfo(strSql9.ToString(), parameters9)); StringBuilder strSql10 = new StringBuilder(); strSql10.Append("delete from pow_user_tool "); strSql10.Append(" where ExamId=@ExamId and UserId=@UserId "); MySqlParameter[] parameters10 = { new MySqlParameter("@ExamId", MySqlDbType.VarChar,32), new MySqlParameter("@UserId", MySqlDbType.VarChar,50) }; parameters10[0].Value = item.ExamId; parameters10[1].Value = item.UserId; com.Add(new CommandInfo(strSql10.ToString(), parameters10)); } return DbHelperMySQL.ExecuteSqlTran(com); } /// /// 使用事务批量操作新增详情、修改分数 /// /// public int OperationAddUpdateData(List details_list, string achievement_id, decimal total_score) { List com = new List(); foreach (var details in details_list) { StringBuilder strSql = new StringBuilder(); strSql.Append("insert into pow_achievement_details("); strSql.Append("DetailsId,AchievementId,ItemName,ItemizedScore,CreateTime,Type,TotalScore,FaultDesc,ScoreType,Remark1,Remark2,Remark3,Remark4,Remark5)"); strSql.Append(" values ("); strSql.Append("@DetailsId,@AchievementId,@ItemName,@ItemizedScore,@CreateTime,@Type,@TotalScore,@FaultDesc,@ScoreType,@Remark1,@Remark2,@Remark3,@Remark4,@Remark5)"); MySqlParameter[] parameters = { new MySqlParameter("@DetailsId", MySqlDbType.VarChar,32), new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32), new MySqlParameter("@ItemName", MySqlDbType.VarChar,1000), new MySqlParameter("@ItemizedScore", MySqlDbType.Float,11), new MySqlParameter("@CreateTime", MySqlDbType.DateTime), new MySqlParameter("@Type", MySqlDbType.VarChar,255), new MySqlParameter("@TotalScore", MySqlDbType.Float,11), new MySqlParameter("@FaultDesc", MySqlDbType.VarChar,500), new MySqlParameter("@ScoreType", MySqlDbType.VarChar,255), new MySqlParameter("@Remark1", MySqlDbType.VarChar,255), new MySqlParameter("@Remark2", MySqlDbType.VarChar,255), new MySqlParameter("@Remark3", MySqlDbType.VarChar,255), new MySqlParameter("@Remark4", MySqlDbType.VarChar,255), new MySqlParameter("@Remark5", MySqlDbType.VarChar,255)}; parameters[0].Value = details.DetailsId; parameters[1].Value = details.AchievementId; parameters[2].Value = details.ItemName; parameters[3].Value = details.ItemizedScore; parameters[4].Value = details.CreateTime; parameters[5].Value = details.Type; parameters[6].Value = details.TotalScore; parameters[7].Value = details.FaultDesc; parameters[8].Value = details.ScoreType; parameters[9].Value = details.Remark1; parameters[10].Value = details.Remark2; parameters[11].Value = details.Remark3; parameters[12].Value = details.Remark4; parameters[13].Value = details.Remark5; com.Add(new CommandInfo(strSql.ToString(), parameters)); } if (!string.IsNullOrEmpty(achievement_id)) { StringBuilder strSql = new StringBuilder(); strSql.Append("update pow_achievement set "); strSql.Append("TotalScore=TotalScore+@TotalScore"); strSql.Append(" where AchievementId=@AchievementId "); MySqlParameter[] parameters = { new MySqlParameter("@TotalScore", MySqlDbType.Float,11), new MySqlParameter("@AchievementId", MySqlDbType.VarChar,32)}; parameters[0].Value = total_score; parameters[1].Value = achievement_id; com.Add(new CommandInfo(strSql.ToString(), parameters)); } return DbHelperMySQL.ExecuteSqlTran(com); } /// /// 得到一个对象实体 /// public Competition.Mysql.Other.achievement_user DataRowToUserModel(DataRow row) { Competition.Mysql.Other.achievement_user model = new Competition.Mysql.Other.achievement_user(); if (row != null) { if (row["AchievementId"] != null) { model.AchievementId = row["AchievementId"].ToString(); } if (row["ExamId"] != null) { model.ExamId = row["ExamId"].ToString(); } if (row["ExamName"] != null) { model.ExamName = row["ExamName"].ToString(); } if (row["UserId"] != null) { model.UserId = row["UserId"].ToString(); } if (row["LoginName"] != null) { model.LoginName = row["LoginName"].ToString(); } if (row["RealName"] != null) { model.RealName = row["RealName"].ToString(); } if (row["ExamEndTime"] != null && row["ExamEndTime"].ToString() != "") { model.ExamEndTime = DateTime.Parse(row["ExamEndTime"].ToString()); } if (row["TotalScore"] != null && row["TotalScore"].ToString() != "") { model.TotalScore = decimal.Parse(row["TotalScore"].ToString()); } if (row["ProvinceId"] != null) { model.ProvinceId = row["ProvinceId"].ToString(); } if (row["ProvinceName"] != null) { model.ProvinceName = row["ProvinceName"].ToString(); } if (row["CityId"] != null) { model.CityId = row["CityId"].ToString(); } if (row["CityName"] != null) { model.CityName = row["CityName"].ToString(); } if (row["ExamStartTime"] != null && row["ExamStartTime"].ToString() != "") { model.ExamStartTime = DateTime.Parse(row["ExamStartTime"].ToString()); } if (row["Remark1"] != null) { model.Remark1 = row["Remark1"].ToString(); } if (row["Remark2"] != null) { model.Remark2 = row["Remark2"].ToString(); } if (row["Remark3"] != null) { model.Remark3 = row["Remark3"].ToString(); } if (row["Remark4"] != null) { model.Remark4 = row["Remark4"].ToString(); } if (row["Remark5"] != null) { model.Remark5 = row["Remark5"].ToString(); } if (row["OwnCity"] != null) { model.OwnCity = row["OwnCity"].ToString(); } if (row["unit_name"] != null) { model.unit_name = row["unit_name"].ToString(); } } return model; } /// /// 修改IP /// /// /// /// /// public int UpdateIP(string ExamId, string UserId, string IP) { StringBuilder strSql = new StringBuilder(); strSql.Append(" update pow_achievement set "); strSql.AppendFormat(" Remark1='{0}'", IP); strSql.AppendFormat(" where ExamId='{0}' and UserId='{1}' ", ExamId, UserId); var sql = strSql.ToString(); return DbHelperMySQL.ExecuteSql(sql); } /// /// 使用事务批量操作新增详情、修改分数 /// /// public int AddExamLogUpdateIP(Competition.Mysql.Model.pow_user_exam_log model, string IP) { List com = new List(); if (null != model) { StringBuilder strSql = new StringBuilder(); strSql.Append("insert into pow_user_exam_log("); strSql.Append("UserExamLogId,UserId,ExamId,CreateTime,LoginIP,R1,R2,R3)"); strSql.Append(" values ("); strSql.Append("@UserExamLogId,@UserId,@ExamId,@CreateTime,@LoginIP,@R1,@R2,@R3)"); MySqlParameter[] parameters = { new MySqlParameter("@UserExamLogId", MySqlDbType.VarChar,50), new MySqlParameter("@UserId", MySqlDbType.VarChar,50), new MySqlParameter("@ExamId", MySqlDbType.VarChar,32), new MySqlParameter("@CreateTime", MySqlDbType.DateTime), new MySqlParameter("@LoginIP", MySqlDbType.VarChar,255), new MySqlParameter("@R1", MySqlDbType.VarChar,255), new MySqlParameter("@R2", MySqlDbType.VarChar,255), new MySqlParameter("@R3", MySqlDbType.VarChar,255)}; parameters[0].Value = model.UserExamLogId; parameters[1].Value = model.UserId; parameters[2].Value = model.ExamId; parameters[3].Value = model.CreateTime; parameters[4].Value = model.LoginIP; parameters[5].Value = model.R1; parameters[6].Value = model.R2; parameters[7].Value = model.R3; com.Add(new CommandInfo(strSql.ToString(), parameters)); } if (!string.IsNullOrEmpty(IP)) { StringBuilder strSql = new StringBuilder(); strSql.Append(" update pow_achievement set "); strSql.Append(" Remark1=@Remark1"); strSql.Append(" where ExamId=@ExamId and UserId=@UserId "); MySqlParameter[] parameters = { new MySqlParameter("@Remark1", MySqlDbType.VarChar,50), new MySqlParameter("@ExamId", MySqlDbType.VarChar,50), new MySqlParameter("@UserId", MySqlDbType.VarChar,50)}; parameters[0].Value = IP; parameters[1].Value = model.ExamId; parameters[2].Value = model.UserId; com.Add(new CommandInfo(strSql.ToString(), parameters)); } return DbHelperMySQL.ExecuteSqlTran(com); } /// /// 使用事务批量操作删除 /// /// public int OperationDeleteData() { List com = new List(); StringBuilder strSql = new StringBuilder(); strSql.Append("truncate table pow_achievement "); MySqlParameter[] parameters = { }; com.Add(new CommandInfo(strSql.ToString(), parameters)); StringBuilder strSql2 = new StringBuilder(); strSql2.Append("truncate table pow_achievement_details "); MySqlParameter[] parameters2 = { }; com.Add(new CommandInfo(strSql2.ToString(), parameters2)); StringBuilder strSql3 = new StringBuilder(); strSql3.Append("truncate table pow_user_exam "); MySqlParameter[] parameters3 = { }; com.Add(new CommandInfo(strSql3.ToString(), parameters3)); StringBuilder strSql4 = new StringBuilder(); strSql4.Append("truncate table pow_user_exam_log "); MySqlParameter[] parameters4 = { }; com.Add(new CommandInfo(strSql4.ToString(), parameters4)); StringBuilder strSql5 = new StringBuilder(); strSql5.Append("truncate table pow_user_fault "); MySqlParameter[] parameters5 = { }; com.Add(new CommandInfo(strSql5.ToString(), parameters5)); StringBuilder strSql6 = new StringBuilder(); strSql6.Append("truncate table pow_user_fault_record "); MySqlParameter[] parameters6 = { }; com.Add(new CommandInfo(strSql6.ToString(), parameters6)); StringBuilder strSql7 = new StringBuilder(); strSql7.Append("truncate table pow_user_operation_proc_ticket "); MySqlParameter[] parameters7 = { }; com.Add(new CommandInfo(strSql7.ToString(), parameters7)); StringBuilder strSql8 = new StringBuilder(); strSql8.Append("truncate table pow_user_operation_ticket "); MySqlParameter[] parameters8 = { }; com.Add(new CommandInfo(strSql8.ToString(), parameters8)); StringBuilder strSql9 = new StringBuilder(); strSql9.Append("truncate table pow_user_tool "); MySqlParameter[] parameters9 = { }; com.Add(new CommandInfo(strSql9.ToString(), parameters9)); return DbHelperMySQL.ExecuteSqlTran(com); } /// /// 获取记录总数 /// public int GetRecordExamCount(string strWhere) { StringBuilder strSql = new StringBuilder(); strSql.Append("select count(1) FROM pow_achievement T1 left join pow_exam T3 on T3.ExamId=T1.ExamId "); if (strWhere.Trim() != "") { strSql.Append(" where " + strWhere); } object obj = DbHelperMySQL.GetSingle(strSql.ToString()); if (obj == null) { return 0; } else { return Convert.ToInt32(obj); } } #endregion ExtensionMethod } }