| | |
| | | using ExportMap.cs; |
| | | using ExportMap.Models; |
| | | using Npgsql; |
| | | using System; |
| | | using System.Collections.Generic; |
| | | using System.Data; |
| | |
| | | public class TaskDBHelper |
| | | { |
| | | /// <summary> |
| | | /// 根据停牌获取用户ID |
| | | /// </summary> |
| | | public static int SelectUserIdByToken(string token) |
| | | { |
| | | string sql = "select create_user from lf.sys_token where token=@token order by create_time desc limit 1;"; |
| | | DbParameter dp1 = new NpgsqlParameter("@token", token); |
| | | |
| | | object obj = Tools.DBHelper.GetScalar(sql, dp1); |
| | | |
| | | return null == obj ? 0 : int.Parse(obj.ToString()); |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 根据ID查询 |
| | | /// </summary> |
| | | public static SysTask SelectById(int id) |
| | | { |
| | | string sql = string.Format("select * from lf.sys_task where id = {0} order by id desc", id); |
| | | |
| | | DataTable dt = Tools.DBHelper.GetDataTable(sql); |
| | | List<SysTask> list = ModelHandler.FillModel<SysTask>(dt); |
| | | |
| | | return null == list || list.Count == 0 ? null : list[0]; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 根据ID集合查询 |
| | | /// </summary> |
| | | public static List<SysTask> SelectByIds(List<int> ids) |
| | | { |
| | | string sql = string.Format("select * from lf.sys_task where id in ({0}) order by id desc", string.Join(",", ids.ToArray())); |
| | | |
| | | DataTable dt = SQLiteHelper.GetDataTable(sql); |
| | | DataTable dt = Tools.DBHelper.GetDataTable(sql); |
| | | List<SysTask> list = ModelHandler.FillModel<SysTask>(dt); |
| | | |
| | | return list; |
| | |
| | | /// </summary> |
| | | public static int Insert(SysTask task) |
| | | { |
| | | string sql = "insert into lf.sys_task (name, status, type, descr, err, ip, pid, gids, depcode, dircode, create_user) values (@name, @status, @type, @descr, @err, @ip, @pid, @gids, @depcode, @dircode, @create_user)"; |
| | | string sql = "insert into lf.sys_task (name, status, type, descr, err, ip, pid, gids, depcode, dircode, create_user) values (@name, @status, @type, @descr, @err, @ip, @pid, @gids, @depcode, @dircode, @create_user) returning id"; |
| | | |
| | | List<DbParameter> list = Tools.GetParams<SysTask>(sql, task); |
| | | object obj = Tools.DBHelper.GetScalar(sql, list.ToArray()); |
| | |
| | | /// <summary> |
| | | /// 创建任务实体类 |
| | | /// </summary> |
| | | public static SysTask CreateTask(XYZArgs args, SysMeta meta) |
| | | public static SysTask CreateTask(XYZArgs args, string type, string descr) |
| | | { |
| | | SysTask task = new SysTask(); |
| | | // |
| | | task.name = args.name; |
| | | task.status = 1; |
| | | task.type = type; |
| | | task.descr = descr; |
| | | task.ip = Tools.GetLocalIP(); |
| | | task.gids = string.Join(",", args.ids.ToArray()); |
| | | task.depcode = args.depcode; |
| | | task.dircode = args.dircode; |
| | | task.create_user = args.userId; |
| | | |
| | | return task; |
| | | } |
| | | |
| | | /// <summary> |
| | | /// 创建任务实体类 |
| | | /// </summary> |
| | | public static SysTask CreateTask(XYZArgs args, SysMeta meta, string type, string descr) |
| | | { |
| | | SysTask task = new SysTask(); |
| | | task.name = meta.name; |
| | | task.status = 1; |
| | | task.type = type; |
| | | task.descr = descr; |
| | | task.ip = Tools.GetLocalIP(); |
| | | task.gids = meta.id.ToString(); |
| | | task.depcode = args.depcode; |
| | | task.dircode = args.dircode; |
| | | task.create_user = args.userId; |
| | | |
| | | return task; |
| | | } |