using Asp.Versioning; using Microsoft.AspNetCore.Mvc; using StoreHub.KJDWebService.Services; namespace StoreHub.KJDWebService.Controllers { [ApiController] [ApiVersionNeutral] [Route("user/[action]")] public class UserController : BaseApiController { private readonly UserService _userService; private readonly UpdateService _updateService; public UserController(UserService userService, UpdateService updateService) { _userService = userService; _updateService = updateService; } [AcceptVerbs("GET", "POST")] public IActionResult hello_world() { return Content("Hello World"); } [AcceptVerbs("GET", "POST")] public IActionResult user_login() { string jsontext = GetRequestJsonString(); var result = jsontext; result = _userService.CheckUserLogin(jsontext); return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult get_package_sign() { string jsontext = GetRequestJsonString(); var result = jsontext; result = _userService.GetPackageSign(jsontext); return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult is_get_return_package() { string jsontext = GetRequestJsonString(); var result = jsontext; result = _userService.IsGetReturnPackage(jsontext); return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult change_password() { string jsontext = GetRequestJsonString(); var result = jsontext; result = _userService.ChangePassword(jsontext); return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult get_sub_user() { string jsontext = GetRequestJsonString(); var result = jsontext; result = _userService.GetSubUser(jsontext); return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult update_sub_user() { string jsontext = GetRequestJsonString(); var result = jsontext; result = _userService.UpdateSubUser(jsontext); return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult add_sub_user() { string jsontext = GetRequestJsonString(); var result = jsontext; result = _userService.AddSubUser(jsontext); return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult delete_user() { string jsontext = GetRequestJsonString(); var result = jsontext; result = _userService.DelUser(jsontext); return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult get_all_user() { string jsontext = GetRequestJsonString(); var result = jsontext; result = _userService.GetAllUser(jsontext); return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult update_user() { string jsontext = GetRequestJsonString(); var result = jsontext; result = _userService.UpdateUser(jsontext); return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult add_user() { string jsontext = GetRequestJsonString(); var result = jsontext; result = _userService.AddUser(jsontext); return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult get_user_amount() { string jsontext = GetRequestJsonString(); var result = jsontext; result = _userService.GetUserAmount(jsontext); return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult GetServer() { var softName = GetRequestJsonString(); var result = ""; //result = System.Configuration.ConfigurationManager.ConnectionStrings[softName + "ServerUrl"].ConnectionString; return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult GetUpdateInfo() { string jsontext = GetRequestJsonString(); var result = jsontext; result = _updateService.GetUpdate(jsontext); return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult DownloadFile() { string file = System.IO.Path.Combine(AppContext.BaseDirectory, "bin", "test.txt"); System.IO.FileStream fs = null; if (System.IO.File.Exists(file)) { try { fs = System.IO.File.OpenRead(file); int b1; System.IO.MemoryStream tempStream = new System.IO.MemoryStream(); while ((b1 = fs.ReadByte()) != -1) { tempStream.WriteByte(((byte)b1)); } return File(tempStream.ToArray(), "application/octet-stream"); } catch (Exception ex) { return Content(""); } finally { fs.Close(); } } else { return Content(""); } return Content(""); } [AcceptVerbs("GET", "POST")] public IActionResult AddComment() { string result=""; //// 输入为querystring //var jsonText = GetRequestJsonString(); //try //{ // var user_id = RegexUtils.GetStringJson(ref jsonText, "user_id"); // var comment = RegexUtils.GetStringJson(ref jsonText, "comment"); // if (string.IsNullOrEmpty(user_id)) // result = "{\"code\":1,\"msg\":\"未指定用户Id\"}"; // else if (string.IsNullOrEmpty(comment)) // result = "{\"code\":2,\"msg\":\"未指定留言内容\"}"; // else // { // string sql = "insert into pepdtp.comment "; // string sql1 = "("; // string sql2 = "("; // if (user_id != null) { sql1 += "user_id,"; sql2 += "'" + user_id + "',"; } // if (comment != null) { sql1 += "comment,"; sql2 += "'" + comment + "',"; } // var tTime = "'" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "',"; // sql1 += "add_time,"; // sql2 += tTime; // sql1 = sql1.TrimEnd(',') + ")"; // sql2 = sql2.TrimEnd(',') + ")"; // sql = sql + sql1 + " values " + sql2; // string conn = System.Configuration.ConfigurationManager.ConnectionStrings["Conn"].ConnectionString; // MysqlUtils mySql = new MysqlUtils(conn); // bool isSuccess = mySql.ExecuteNonQuery(sql); // if (!isSuccess) // { // result = "{\"code\":10001,\"msg\":\"添加留言入库出错,请稍后重试!\"}"; // } // else // { // result = "{\"code\":0,\"msg\":\"添加留言成功!\"}"; // } // mySql.Close(); // } //} //catch (Exception ex) //{ // result = "{\"code\":10001,\"msg\":\"添加留言出错,请稍后重试!\"}"; //}; return WriteJson(result); } [AcceptVerbs("GET", "POST")] public IActionResult EditUser() { string result=""; // 输入为querystring //var jsonText = GetRequestJsonString(); //try //{ // //var role = RegexUtils.GetStringJson(ref jsonText, "role"); // var name = RegexUtils.GetStringJson(ref jsonText, "name"); // //var school = RegexUtils.GetStringJson(ref jsonText, "school"); // var rkxd = RegexUtils.GetStringJson(ref jsonText, "rkxd"); // var zxxkc = RegexUtils.GetStringJson(ref jsonText, "zxxkc"); // //var is_import = RegexUtils.GetStringJson(ref jsonText, "is_import"); // //var password = RegexUtils.GetStringJson(ref jsonText, "password"); // //var order_id = RegexUtils.GetStringJson(ref jsonText, "order_id"); // var user_id = RegexUtils.GetStringJson(ref jsonText, "user_id"); // if (string.IsNullOrEmpty(user_id)) // result = "{\"code\":1,\"msg\":\"未指定用户Id\"}"; // else // { // string sql = "update pepdtp.user set "; // //if (role != null) sql += "role=" + role + ","; // if (name != null) sql += "name='" + name + "',"; // //if (school != null) sql += "school='" + school + "',"; // if (rkxd != null) sql += "rkxd='" + rkxd + "',"; // if (zxxkc != null) sql += "zxxkc='" + zxxkc + "',"; // //if (is_import != null) sql += "is_import='" + is_import + "',"; // //if (password != null) sql += "password='" + password + "',"; // //if (order_id != null) sql += "order_id='" + order_id + "',"; // sql += "mdy_time='" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "',"; // sql = sql.TrimEnd(' ').TrimEnd(','); // if (user_id.Contains(",")) // sql += " where user_id in ('" + user_id.Replace(",", "','") + "')"; // else // sql += " where user_id='" + user_id + "'"; // string conn = System.Configuration.ConfigurationManager.ConnectionStrings["Conn"].ConnectionString; // MysqlUtils mySql = new MysqlUtils(conn); // bool isSuccess = mySql.ExecuteNonQuery(sql); // if (!isSuccess) // { // result = "{\"code\":10001,\"msg\":\"修改用户入库出错,请稍后重试!\"}"; // } // else // { // result = "{\"code\":0,\"msg\":\"修改用户成功!\"}"; // } // mySql.Close(); // } //} //catch (Exception ex) //{ // result = "{\"code\":19999,\"msg\":\"修改用户出错,请稍后重试!\"}"; //}; return WriteJson(result); } } }