Skip to content

D
DataCenter_Core2.1_20190520
Commit 9b7b6737 by guanzhenshan
Options

增加获取任务接口；增加更新任务接口；

parent f22c60fe
Showing with 74 additions and 89 deletions
Bailun.DC.Services/TaskCenterServices.cs
...@@ -363,6 +363,38 @@ namespace Bailun.DC.Services ...@@ -363,6 +363,38 @@ namespace Bailun.DC.Services
return obj; return obj;
} }
} }
/// <summary>
/// 更新任务状态
/// </summary>
/// <param name="id">任务id</param>
/// <param name="status">任务状态 0：未认领，1：任务执行失败，2：已认领，3：执行成功</param>
/// <param name="fileurl">可下载的文件地址</param>
/// <returns></returns>
public string UpdateTask(int id,int status,string fileurl)
{
using (var cn = new MySqlConnection(Common.GlobalConfig.ConnectionString))
{
if (cn.State == System.Data.ConnectionState.Closed)
{
cn.Open();
}
var obj = cn.QueryFirstOrDefault<taskcenter_tasklist>("select t1.* from taskcenter_tasklist t1 where id="+id);
if (obj == null)
{
return "找不到该任务";
}
obj.status = status;
obj.fileurl = fileurl;
obj.lastupdatetime = DateTime.Now;
cn.Update(obj);
return "";
}
#endregion #endregion
} }
......
Bailun.DC.Web/Controllers/ApiController.cs
...@@ -1130,101 +1130,55 @@ namespace Bailun.DC.Web.Controllers ...@@ -1130,101 +1130,55 @@ namespace Bailun.DC.Web.Controllers
} }
/// <summary>
/// 获取一个下载任务
/// </summary>
/// <returns></returns>
[HttpPost]
public JsonResult GetOneDownloadTask()
{
//获取当前未执行的一个下载任务
var obj = new Services.TaskCenterServices().ListTask(null, 0);
//public JsonResult TestInsertBuyer() return Json(new {
//{ success = true,
// using (var read = new System.IO.StreamReader(@"C:\Allan\百伦\2020年之前的客户.csv")) msg = "",
// { data = obj,
// if (read != null) });
// { }
// int index = 0;
// var str_insert = "insert into temp_buyer2020 (buyer_id) values ";
// var str_value = "";
// while (read.Read() > 0)
// {
// var str = read.ReadLine();
// str = str.Replace("\"", "");
// str = str.Replace("'", "''");
// str = str.Replace(@"\", @"\\");
// if (!string.IsNullOrEmpty(str))
// {
// str_value += "('"+str+"'),";
// index++;
// if (index % 1000 == 0)
// {
// SaveBuyerData(str_insert + str_value.Substring(0,str_value.Length-1));
// str_value = "";
// }
// //using (var cn = new MySql.Data.MySqlClient.MySqlConnection(Common.GlobalConfig.ConnectionString))
// //{
// // if (cn.State == System.Data.ConnectionState.Closed)
// // {
// // cn.Open();
// // }
// // using (var cm = new MySql.Data.MySqlClient.MySqlCommand())
// // {
// // cm.Connection = cn;
// // cm.CommandText = "insert into temp_buyer2020 (buyer_id) value ('" + str + "')";
// // cm.ExecuteNonQuery();
// // }
// //}
// }
// }
// if(!string.IsNullOrEmpty(str_value))
// {
// SaveBuyerData(str_insert + str_value.Substring(0, str_value.Length - 1));
// }
// }
// }
// return Json("");
//}
//private void SaveBuyerData(string sql)
//{
// try
// {
// using (var cn = new MySql.Data.MySqlClient.MySqlConnection(Common.GlobalConfig.ConnectionString))
// {
// if (cn.State == System.Data.ConnectionState.Closed)
// {
// cn.Open();
// }
// using (var cm = new MySql.Data.MySqlClient.MySqlCommand())
// {
// cm.Connection = cn;
// cm.CommandText = sql;
// cm.ExecuteNonQuery();
// }
// }
// }
// catch (Exception ex)
// {
// SaveBuyerData(sql);
// }
//}
/// <summary> /// <summary>
/// 首次入库时间 /// 更新下载任务的状态
/// </summary> /// </summary>
/// <param name="start">开始时间</param> /// <param name="id">任务id</param>
/// <param name="end">结束时间</param> /// <param name="status">0：未认领，1：任务执行失败，2：已认领，3：执行成功</param>
/// <param name="fileurl">已经下载完，可下载的文件地址</param>
/// <returns></returns> /// <returns></returns>
//[HttpPost] [HttpPost]
//public JsonResult FirstPutinTime(DateTime start, DateTime end) public JsonResult ChangeTaskStatus(int id,int status,string fileurl)
//{ {
try
{
var result = new Services.TaskCenterServices().UpdateTask(id, status, fileurl);
return Json(new
{
success = string.IsNullOrEmpty(result),
msg = result,
});
}
catch (Exception ex)
{
return Json(new
{
success = false,
msg = ex.Message,
});
}
}
//}
} }
} }
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment