1

13693261870

2024-09-04 dbed0354a00fde9db87862b9f03db0fbf0d3aabc

 ExportMap/db/TaskDBHelper.cs

@@ -1,5 +1,6 @@
using ExportMap.cs;
using ExportMap.Models;
using Npgsql;
using System;
using System.Collections.Generic;
using System.Data;
@@ -12,13 +13,39 @@
    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;
@@ -53,12 +80,13 @@
        /// <summary>
        /// 创建任务实体类
        /// </summary>
        public static SysTask CreateTask(XYZArgs args, string type)
        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;
@@ -71,12 +99,13 @@
        /// <summary>
        /// 创建任务实体类
        /// </summary>
        public static SysTask CreateTask(XYZArgs args, SysMeta meta, string type)
        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;