You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
101 lines
2.9 KiB
101 lines
2.9 KiB
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using Utils.Datas;
|
|
using WeighBusiness.BO;
|
|
using WeighBusiness.Utils;
|
|
using WeighBusiness.Utils.SqlUtils;
|
|
|
|
namespace WeighBusiness.BL
|
|
{
|
|
public class SettingBL
|
|
{
|
|
private const string LoadAllSql = "select first 1 ID,A,B from {0} order by ID";
|
|
private const string LoadRrecentSql = "select first 1 ID,A from {0} order by ID";
|
|
public static SettingData Load(bool loadAll = true)//true:查询全部；false:只查询 ID与最近用户
|
|
{
|
|
var sql = loadAll ? LoadAllSql : LoadRrecentSql;
|
|
var querySql = sql.FormatWith(TableNames.配置表);
|
|
var table = SqlHelperEx.DoQuery(querySql);
|
|
if (table.Rows.Count == 0)
|
|
return new Setting() { RecentUser = "1|system" }.ToSettingData(loadAll);
|
|
|
|
return GetUseSetting(table.Rows[0], loadAll).ToSettingData(loadAll);
|
|
}
|
|
|
|
private static Setting GetUseSetting(DataRow row, bool loadAll)
|
|
{
|
|
var setting = new Setting() {
|
|
ID = DataTypeUtil.GetLongNum(row["ID"]),
|
|
RecentUser = row["A"].ToString(),
|
|
};
|
|
if (loadAll)
|
|
setting.Settings = row["B"].ToString();
|
|
return setting;
|
|
}
|
|
|
|
public static void Save(SettingData setting, bool saveAll)//插入时：全部插入；更新时：true:更新全部；false:只更新最近用户
|
|
{
|
|
var config = setting.ToSetting();
|
|
|
|
if (config.ID == 0)
|
|
Insert(config);
|
|
else
|
|
Update(config, saveAll);
|
|
}
|
|
|
|
public static void UpdateRecentUser(long recentUserID, string recentUserName)
|
|
{
|
|
var setting = Load(false);
|
|
setting.RecentUserID = recentUserID;
|
|
setting.RecentUserName = recentUserName;
|
|
var config = setting.ToSetting();
|
|
Update(config, false);
|
|
}
|
|
|
|
private static void Insert(Setting config)
|
|
{
|
|
var insertSql = InsertUtil.GetInsertSql(TableNames.配置表,
|
|
new string[] { "A", "B" },
|
|
new string[] { config.RecentUser, config.Settings });
|
|
|
|
bool success;
|
|
using (var she = new SqlHelperEx()) {
|
|
she.CreateTransaction();
|
|
she.ExecuteNonQuery(insertSql, out success);
|
|
if (!success)
|
|
she.Rollback();
|
|
else
|
|
she.Commit();
|
|
}
|
|
|
|
if (!success)//TODO:如何处理？
|
|
throw new ApplicationException("保存配置文件出错");
|
|
}
|
|
|
|
private static void Update(Setting config, bool updateAll = true)//true:更新所有数据；false;更新最近用户
|
|
{
|
|
var needUpdateFieldsValuesPairs = new Dictionary<string, string>();
|
|
needUpdateFieldsValuesPairs.Add("A", config.RecentUser);
|
|
if (updateAll)
|
|
needUpdateFieldsValuesPairs.Add("B", config.Settings);
|
|
var updateSql = UpdateUtil.GetUpdateString(TableNames.配置表, "ID", config.ID.ToString(), needUpdateFieldsValuesPairs);
|
|
|
|
bool success = true;
|
|
using (var she = new SqlHelperEx()) {
|
|
she.CreateTransaction();
|
|
she.ExecuteNonQuery(updateSql, out success);
|
|
if (success)
|
|
she.Commit();
|
|
else
|
|
she.Rollback();
|
|
}
|
|
|
|
if (!success)//TODO:如何处理？
|
|
throw new ApplicationException("保存配置文件出错");
|
|
}
|
|
|
|
}
|
|
}
|