添加相关交易重置功能

Areas/Api/Controllers/v1/Main1/MerchantAddInfoController.cs

@@ -417,5 +417,35 @@ namespace MySystem.Areas.Api.Controllers.v1.Main1
         }
         #endregion
 
+
+        #region 重置交易额-直连重置商户交易额
+        [Authorize]
+        public JsonResult DirectResetMerchantAmount(string value)
+        {
+            value = PublicFunction.DesDecrypt(value); ;
+            JsonData data = JsonMapper.ToObject(value);
+            AppResultJson result = DirectResetMerchantAmountDo(value);
+            return Json(new AppResultJson() { Status = result.Status, Info = result.Info, Data = result.Data });
+        }
+        private AppResultJson DirectResetMerchantAmountDo(string value)
+        {
+            JsonData data = JsonMapper.ToObject(value);
+            string MerchantId = data["MerchantId"].ToString(); //商户Id
+            string TradeDate = data["TradeDate"].ToString(); //交易时间
+            if (string.IsNullOrEmpty(data["MerchantId"].ToString()) || string.IsNullOrEmpty(data["TradeDate"].ToString()))
+            {
+                return new AppResultJson() { Status = "-1", Info = "商户Id和交易时间不能为空" };
+            }
+            string[] datelist = TradeDate.Split(new string[] { " - " }, StringSplitOptions.None);
+            string start = DateTime.Parse(datelist[0]).ToString("yyyyMMdd");
+            string end = DateTime.Parse(datelist[1]).ToString("yyyyMMdd");
+            string info = "{\"MerchantId\":\"" + MerchantId + "\",\"StartDate\":\"" + start + "\",\"EndDate\": \"" + end + "\"}";
+            RedisDbconn.Instance.AddList("ResetMerchantStatDataQueue", info);
+            Dictionary<string, object> Obj = new Dictionary<string, object>();
+
+            return new AppResultJson() { Status = "1", Info = "", Data = Obj };
+        }
+        #endregion
+
     }
 }

Areas/Api/Controllers/v1/Main1/PosMachinesTwoController.cs

@@ -0,0 +1,97 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
+using Microsoft.AspNetCore.Authorization;
+using System.Web;
+using MySystem.Models.Main1;
+using MySystem.Service.Main1;
+using LitJson;
+using Library;
+
+namespace MySystem.Areas.Api.Controllers.v1.Main1
+{
+    [Area("Api")]
+    [Route("/v1/QrCodePlateMain/[controller]/[action]")]
+    public class PosMachinesTwoController : BaseController
+    {
+        public PosMachinesTwoController(IHttpContextAccessor accessor) : base(accessor)
+        {
+        }
+
+
+        #region 重置交易额-直连重置码牌交易额
+        [Authorize]
+        public JsonResult DirectResetQrCodeAmount(string value)
+        {
+            value = PublicFunction.DesDecrypt(value); ;
+            JsonData data = JsonMapper.ToObject(value);
+            AppResultJson result = DirectResetQrCodeAmountDo(value);
+            return Json(new AppResultJson() { Status = result.Status, Info = result.Info, Data = result.Data });
+        }
+        private AppResultJson DirectResetQrCodeAmountDo(string value)
+        {
+            JsonData data = JsonMapper.ToObject(value);
+            string PosSn = data["PosSn"].ToString(); //码牌Sn
+            string TradeDate = data["TradeDate"].ToString(); //交易时间
+            if (string.IsNullOrEmpty(data["PosSn"].ToString()) || string.IsNullOrEmpty(data["TradeDate"].ToString()))
+            {
+                return new AppResultJson() { Status = "-1", Info = "码牌Sn和交易时间不能为空" };
+            }
+            var pos = PosMachinesTwoService.Query(" and PosSn=" + PosSn + "");
+            if (pos.Id == 0 || pos.OpId != 1)
+            {
+                return new AppResultJson() { Status = "-1", Info = "未找到该码牌Sn或该码牌通道不符" };
+            }
+            string[] datelist = TradeDate.Split(new string[] { " - " }, StringSplitOptions.None);
+            string start = DateTime.Parse(datelist[0]).ToString("yyyyMMdd");
+            string end = DateTime.Parse(datelist[1]).ToString("yyyyMMdd");
+            string info = "{\"SnNo\":\"" + PosSn + "\",\"StartDate\":\"" + start + "\",\"EndDate\": \"" + end + "\"}";
+            RedisDbconn.Instance.AddList("ResetSnStatDataQueue", info);
+            Dictionary<string, object> Obj = new Dictionary<string, object>();
+
+            return new AppResultJson() { Status = "1", Info = "", Data = Obj };
+        }
+        #endregion
+
+
+        #region 重置交易额-银联重置码牌交易额
+        [Authorize]
+        public JsonResult UnionPayResetQrCodeAmount(string value)
+        {
+            value = PublicFunction.DesDecrypt(value); ;
+            JsonData data = JsonMapper.ToObject(value);
+            AppResultJson result = UnionPayResetQrCodeAmountDo(value);
+            return Json(new AppResultJson() { Status = result.Status, Info = result.Info, Data = result.Data });
+        }
+        private AppResultJson UnionPayResetQrCodeAmountDo(string value)
+        {
+            JsonData data = JsonMapper.ToObject(value);
+            string PosSn = data["PosSn"].ToString(); //码牌Sn
+            string TradeDate = data["TradeDate"].ToString(); //交易时间
+            if (string.IsNullOrEmpty(data["PosSn"].ToString()) || string.IsNullOrEmpty(data["TradeDate"].ToString()))
+            {
+                return new AppResultJson() { Status = "-1", Info = "码牌Sn和交易时间不能为空" };
+            }
+            var pos = PosMachinesTwoService.Query(" and PosSn=" + PosSn + "");
+            if (pos.Id == 0 || pos.OpId != 2)
+            {
+                return new AppResultJson() { Status = "-1", Info = "未找到该码牌Sn或该码牌通道不符" };
+            }
+            string[] datelist = TradeDate.Split(new string[] { " - " }, StringSplitOptions.None);
+            string start = DateTime.Parse(datelist[0]).ToString("yyyyMMdd");
+            string end = DateTime.Parse(datelist[1]).ToString("yyyyMMdd");
+            string info = "{\"SnNo\":\"" + PosSn + "\",\"StartDate\":\"" + start + "\",\"EndDate\": \"" + end + "\"}";
+            RedisDbconn.Instance.AddList("ResetSnStatDataQueue2", info);
+            Dictionary<string, object> Obj = new Dictionary<string, object>();
+
+            return new AppResultJson() { Status = "1", Info = "", Data = Obj };
+        }
+        #endregion
+
+
+    }
+}

Areas/Api/Controllers/v1/Main1/UsersController.cs

@@ -0,0 +1,167 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
+using Microsoft.AspNetCore.Authorization;
+using System.Web;
+using MySystem.Models.Main1;
+using MySystem.Service.Main1;
+using LitJson;
+using Library;
+using MySystem.Service.KxsMain;
+
+namespace MySystem.Areas.Api.Controllers.v1.Main1
+{
+    [Area("Api")]
+    [Route("/v1/QrCodePlateMain/[controller]/[action]")]
+    public class UsersController : BaseController
+    {
+        public UsersController(IHttpContextAccessor accessor) : base(accessor)
+        {
+        }
+
+        #region 重置交易额-直连重置创客个人交易额
+        [Authorize]
+        public JsonResult DirectResetUserPersonalAmount(string value)
+        {
+            value = PublicFunction.DesDecrypt(value); ;
+            JsonData data = JsonMapper.ToObject(value);
+            AppResultJson result = DirectResetUserPersonalAmountDo(value);
+            return Json(new AppResultJson() { Status = result.Status, Info = result.Info, Data = result.Data });
+        }
+        private AppResultJson DirectResetUserPersonalAmountDo(string value)
+        {
+            JsonData data = JsonMapper.ToObject(value);
+            string MakerCode = data["MakerCode"].ToString(); //创客编号
+            string TradeDate = data["TradeDate"].ToString(); //交易时间
+            if (string.IsNullOrEmpty(data["MakerCode"].ToString()) || string.IsNullOrEmpty(data["TradeDate"].ToString()))
+            {
+                return new AppResultJson() { Status = "-1", Info = "创客编号和交易时间不能为空" };
+            }
+            var user = UsersService.QueryByMakerCode(MakerCode);
+            if (user.Id == 0)
+            {
+                return new AppResultJson() { Status = "-1", Info = "未找到" + MakerCode + "相关信息" };
+            }
+            string[] datelist = TradeDate.Split(new string[] { " - " }, StringSplitOptions.None);
+            string start = DateTime.Parse(datelist[0]).ToString("yyyyMMdd");
+            string end = DateTime.Parse(datelist[1]).ToString("yyyyMMdd");
+            string info = "{\"UserId\":\"" + user.Id + "\",\"StartDate\":\"" + start + "\",\"EndDate\": \"" + end + "\"}";
+            RedisDbconn.Instance.AddList("ResetUserSelfStatDataQueue", info);
+            Dictionary<string, object> Obj = new Dictionary<string, object>();
+
+            return new AppResultJson() { Status = "1", Info = "", Data = Obj };
+        }
+        #endregion
+
+
+        #region 重置交易额-银联重置创客个人交易额
+        [Authorize]
+        public JsonResult UnionPayResetUserPersonalAmount(string value)
+        {
+            value = PublicFunction.DesDecrypt(value); ;
+            JsonData data = JsonMapper.ToObject(value);
+            AppResultJson result = UnionPayResetUserPersonalAmountDo(value);
+            return Json(new AppResultJson() { Status = result.Status, Info = result.Info, Data = result.Data });
+        }
+        private AppResultJson UnionPayResetUserPersonalAmountDo(string value)
+        {
+            JsonData data = JsonMapper.ToObject(value);
+            string MakerCode = data["MakerCode"].ToString(); //创客编号
+            string TradeDate = data["TradeDate"].ToString(); //交易时间
+            if (string.IsNullOrEmpty(data["MakerCode"].ToString()) || string.IsNullOrEmpty(data["TradeDate"].ToString()))
+            {
+                return new AppResultJson() { Status = "-1", Info = "创客编号和交易时间不能为空" };
+            }
+            var user = UsersService.QueryByMakerCode(MakerCode);
+            if (user.Id == 0)
+            {
+                return new AppResultJson() { Status = "-1", Info = "未找到" + MakerCode + "相关信息" };
+            }
+            string[] datelist = TradeDate.Split(new string[] { " - " }, StringSplitOptions.None);
+            string start = DateTime.Parse(datelist[0]).ToString("yyyyMMdd");
+            string end = DateTime.Parse(datelist[1]).ToString("yyyyMMdd");
+            string info = "{\"UserId\":\"" + user.Id + "\",\"StartDate\":\"" + start + "\",\"EndDate\": \"" + end + "\"}";
+            RedisDbconn.Instance.AddList("ResetUserSelfStatDataQueue2", info);
+            Dictionary<string, object> Obj = new Dictionary<string, object>();
+
+            return new AppResultJson() { Status = "1", Info = "", Data = Obj };
+        }
+        #endregion
+
+
+        #region 重置交易额-直连重置创客团队交易额
+        [Authorize]
+        public JsonResult DirectResetUserTeamAmount(string value)
+        {
+            value = PublicFunction.DesDecrypt(value); ;
+            JsonData data = JsonMapper.ToObject(value);
+            AppResultJson result = DirectResetUserTeamAmountDo(value);
+            return Json(new AppResultJson() { Status = result.Status, Info = result.Info, Data = result.Data });
+        }
+        private AppResultJson DirectResetUserTeamAmountDo(string value)
+        {
+            JsonData data = JsonMapper.ToObject(value);
+            string MakerCode = data["MakerCode"].ToString(); //创客编号
+            string TradeDate = data["TradeDate"].ToString(); //交易时间
+            if (string.IsNullOrEmpty(data["MakerCode"].ToString()) || string.IsNullOrEmpty(data["TradeDate"].ToString()))
+            {
+                return new AppResultJson() { Status = "-1", Info = "创客编号和交易时间不能为空" };
+            }
+            var user = UsersService.QueryByMakerCode(MakerCode);
+            if (user.Id == 0)
+            {
+                return new AppResultJson() { Status = "-1", Info = "未找到" + MakerCode + "相关信息" };
+            }
+            string[] datelist = TradeDate.Split(new string[] { " - " }, StringSplitOptions.None);
+            string start = DateTime.Parse(datelist[0]).ToString("yyyyMMdd");
+            string end = DateTime.Parse(datelist[1]).ToString("yyyyMMdd");
+            string info = "{\"UserId\":\"" + user.Id + "\",\"StartDate\":\"" + start + "\",\"EndDate\": \"" + end + "\"}";
+            RedisDbconn.Instance.AddList("ResetUserTeamStatDataQueue", info);
+            Dictionary<string, object> Obj = new Dictionary<string, object>();
+
+            return new AppResultJson() { Status = "1", Info = "", Data = Obj };
+        }
+        #endregion
+
+
+        #region 重置交易额-银联重置创客团队交易额
+        [Authorize]
+        public JsonResult UnionPayResetUserTeamAmount(string value)
+        {
+            value = PublicFunction.DesDecrypt(value); ;
+            JsonData data = JsonMapper.ToObject(value);
+            AppResultJson result = UnionPayResetUserTeamAmountDo(value);
+            return Json(new AppResultJson() { Status = result.Status, Info = result.Info, Data = result.Data });
+        }
+        private AppResultJson UnionPayResetUserTeamAmountDo(string value)
+        {
+            JsonData data = JsonMapper.ToObject(value);
+            string MakerCode = data["MakerCode"].ToString(); //创客编号
+            string TradeDate = data["TradeDate"].ToString(); //交易时间
+            if (string.IsNullOrEmpty(data["MakerCode"].ToString()) || string.IsNullOrEmpty(data["TradeDate"].ToString()))
+            {
+                return new AppResultJson() { Status = "-1", Info = "创客编号和交易时间不能为空" };
+            }
+            var user = UsersService.QueryByMakerCode(MakerCode);
+            if (user.Id == 0)
+            {
+                return new AppResultJson() { Status = "-1", Info = "未找到" + MakerCode + "相关信息" };
+            }
+            string[] datelist = TradeDate.Split(new string[] { " - " }, StringSplitOptions.None);
+            string start = DateTime.Parse(datelist[0]).ToString("yyyyMMdd");
+            string end = DateTime.Parse(datelist[1]).ToString("yyyyMMdd");
+            string info = "{\"UserId\":\"" + user.Id + "\",\"StartDate\":\"" + start + "\",\"EndDate\": \"" + end + "\"}";
+            RedisDbconn.Instance.AddList("ResetUserTeamStatDataQueue2", info);
+            Dictionary<string, object> Obj = new Dictionary<string, object>();
+
+            return new AppResultJson() { Status = "1", Info = "", Data = Obj };
+        }
+        #endregion
+
+
+    }
+}

Areas/Api/Controllers/v1/Main2/MerchantAddInfoController.cs

@@ -437,8 +437,7 @@ namespace MySystem.Areas.Api.Controllers.v1.Main2
             string MerchantNo = data["MerchantNo"].ToString(); //商户号
             string SettlementDate = data["SettlementDate"].ToString(); //结算时间(必填)
             string pageSize = data["page_size"].ToString();
-            string pageNum = data["page_num"].ToString()    ;
-            string condition = "";
+            string pageNum = data["page_num"].ToString();
             var MerchantId = 0;
             string StartDate = "";
             string EndDate = "";
@@ -464,5 +463,35 @@ namespace MySystem.Areas.Api.Controllers.v1.Main2
         #endregion
 
 
+        #region 重置交易额-银联重置商户交易额
+        [Authorize]
+        public JsonResult UnionPayResetMerchantAmount(string value)
+        {
+            value = PublicFunction.DesDecrypt(value); ;
+            JsonData data = JsonMapper.ToObject(value);
+            AppResultJson result = UnionPayResetMerchantAmountDo(value);
+            return Json(new AppResultJson() { Status = result.Status, Info = result.Info, Data = result.Data });
+        }
+        private AppResultJson UnionPayResetMerchantAmountDo(string value)
+        {
+            JsonData data = JsonMapper.ToObject(value);
+            string MerchantId = data["MerchantId"].ToString(); //商户Id
+            string TradeDate = data["TradeDate"].ToString(); //交易时间
+            if (string.IsNullOrEmpty(data["MerchantId"].ToString()) || string.IsNullOrEmpty(data["TradeDate"].ToString()))
+            {
+                return new AppResultJson() { Status = "-1", Info = "商户Id和交易时间不能为空" };
+            }
+            string[] datelist = TradeDate.Split(new string[] { " - " }, StringSplitOptions.None);
+            string start = DateTime.Parse(datelist[0]).ToString("yyyyMMdd");
+            string end = DateTime.Parse(datelist[1]).ToString("yyyyMMdd");
+            string info = "{\"MerchantId\":\"" + MerchantId + "\",\"StartDate\":\"" + start + "\",\"EndDate\": \"" + end + "\"}";
+            RedisDbconn.Instance.AddList("ResetMerchantStatDataQueue2", info);
+            Dictionary<string, object> Obj = new Dictionary<string, object>();
+
+            return new AppResultJson() { Status = "1", Info = "成功", Data = Obj };
+        }
+        #endregion
+
+
     }
 }

Areas/Api/Controllers/v1/Main2/PosMachinesTwoController.cs

@@ -0,0 +1,27 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
+using Microsoft.AspNetCore.Authorization;
+using System.Web;
+using MySystem.Models.Main2;
+using MySystem.Service.Main2;
+using LitJson;
+using Library;
+
+namespace MySystem.Areas.Api.Controllers.v1.Main2
+{
+    [Area("Api")]
+    [Route("/v1/QrCodePlateMain/[controller]/[action]")]
+    public class PosMachinesTwoController : BaseController
+    {
+        public PosMachinesTwoController(IHttpContextAccessor accessor) : base(accessor)
+        {
+        }
+
+
+    }
+}

Service/Main1/PosMachinesTwoService.cs

@@ -0,0 +1,287 @@
+/*
+ * 机具库
+ */
+
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Data;
+using MySystem.Models.Main1;
+using Library;
+using LitJson;
+
+namespace MySystem.Service.Main1
+{
+    public class PosMachinesTwoService
+    {
+        static string _conn = ConfigurationManager.AppSettings["SqlConnStr1"].ToString();
+
+        /// <summary>
+        /// 查询列表(适合多表关联查询)
+        /// </summary>
+        /// <param name="relationData">关联表</param>
+        /// <param name="condition">查询条件(sql语句)</param>
+        /// <param name="count">总数（输出）</param>
+        /// <param name="page">页码</param>
+        /// <param name="limit">每页条数</param>
+        /// <returns></returns>
+        public static List<Dictionary<string, object>> List(List<RelationData> relationData, string condition, out int count, int page = 1, int limit = 30, string orderBy = "sort desc,id desc")
+        {
+            List<string> fields = new List<string>(); //要显示的列，不设置则返回全部字段
+            Dictionary<string, object> obj = new DbServiceNew(AppConfig.Base.main1Tables, _conn).IndexData("PosMachinesTwo", relationData, orderBy, page, limit, condition, fields);
+            List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
+            count = int.Parse(obj["count"].ToString());
+            return diclist;
+        }
+        public static List<Dictionary<string, object>> List(List<RelationData> relationData, string condition, int page = 1, int limit = 30, string orderBy = "sort desc,id desc")
+        {
+            List<string> fields = new List<string>(); //要显示的列，不设置则返回全部字段
+            Dictionary<string, object> obj = new DbServiceNew(AppConfig.Base.main1Tables, _conn).IndexData("PosMachinesTwo", relationData, orderBy, page, limit, condition, fields);
+            List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
+            return diclist;
+        }
+
+        /// <summary>
+        /// 查询列表(单表)
+        /// </summary>
+        /// <param name="fieldList">返回的字段</param>
+        /// <param name="condition">查询条件</param>
+        /// <param name="page">页码</param>
+        /// <param name="limit">每页条数</param>
+        /// <param name="orderBy">排序</param>
+        /// <returns></returns>
+        public static List<Dictionary<string, object>> List(string fieldList, string condition, int page = 1, int limit = 30, string orderBy = "sort desc,id desc")
+        {
+            List<string> fields = fieldList.Split(',').ToList(); //要显示的列
+            Dictionary<string, object> obj = new DbServiceNew(AppConfig.Base.main1Tables, _conn).IndexData("PosMachinesTwo", new List<RelationData>(), orderBy, page, limit, condition, fields);
+            List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
+            return diclist;
+        }
+
+        /// <summary>
+        /// 查询一条记录
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        /// <returns></returns>
+        public static PosMachinesTwo Query(int Id)
+        {
+            Dictionary<string, object> obj = new DbServiceNew(AppConfig.Base.main1Tables, _conn).Query("*", "PosMachinesTwo", Id);
+            if(obj.Keys.Count > 0)
+            {
+                return Newtonsoft.Json.JsonConvert.DeserializeObject<PosMachinesTwo>(Newtonsoft.Json.JsonConvert.SerializeObject(obj));
+            }
+            return new PosMachinesTwo();
+        }
+
+        /// <summary>
+        /// 查询一条记录
+        /// </summary>
+        /// <param name="condition">查询条件(sql语句)</param>
+        /// <returns></returns>
+        public static PosMachinesTwo Query(string condition)
+        {
+            Dictionary<string, object> obj = new DbServiceNew(AppConfig.Base.main1Tables, _conn).Query("*", "PosMachinesTwo", condition);
+            if(obj.Keys.Count > 0)
+            {
+                return Newtonsoft.Json.JsonConvert.DeserializeObject<PosMachinesTwo>(Newtonsoft.Json.JsonConvert.SerializeObject(obj));
+            }
+            return new PosMachinesTwo();
+        }
+
+        /// <summary>
+        /// 查询一条记录
+        /// </summary>
+        /// <param name="condition">查询条件(sql语句)</param>
+        /// <param name="fields">返回的字段</param>
+        /// <returns></returns>
+        public static Dictionary<string, object> Query(string condition, string fields)
+        {
+            Dictionary<string, object> obj = new DbServiceNew(AppConfig.Base.main1Tables, _conn).Query(fields, "PosMachinesTwo", condition);
+            return obj;
+        }
+        
+        public static decimal Sum(string condition, string field)
+        {
+            decimal amount = 0;
+            Dictionary<string, object> obj = new DbServiceNew(AppConfig.Base.main1Tables, _conn).Query("Sum(" + field + ") " + field + "", "PosMachinesTwo", condition);
+            if(obj.Keys.Count > 0)
+            {
+                amount = decimal.Parse(obj[field].ToString());
+            }
+            return amount;
+        }
+
+        /// <summary>
+        /// 查询记录数
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        /// <returns></returns>
+        public static int Count(string condition = "", string field = "Id")
+        {
+            int result = 0;
+            Dictionary<string, object> obj = new DbServiceNew(AppConfig.Base.main1Tables, _conn).Query("count(" + field + ") " + field + "", "PosMachinesTwo", condition);
+            if(obj.Keys.Count > 0)
+            {
+                result = int.Parse(function.CheckInt(obj[field].ToString()));
+            }
+            return result;
+        }
+
+        /// <summary>
+        /// 查询是否存在
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        /// <returns></returns>
+        public static bool Exist(string condition)
+        {
+            Dictionary<string, object> obj = new DbServiceNew(AppConfig.Base.main1Tables, _conn).Query("1", "PosMachinesTwo", condition);
+            if(obj.Keys.Count > 0)
+            {
+                return true;
+            }
+            return false;
+        }
+
+        /// <summary>
+        /// 添加数据
+        /// </summary>
+        /// <param name="Fields">要设置的字段</param>
+        /// <returns></returns>
+        public static AppResultJson Add(Dictionary<string, object> fields, bool check = true)
+        {
+            if(check)
+            {
+                if (string.IsNullOrEmpty(fields["UserId"].ToString()))
+{
+    return new AppResultJson() { Status = "-1", Info = "请填写所属创客" };
+}
+if (string.IsNullOrEmpty(fields["PosSn"].ToString()))
+{
+    return new AppResultJson() { Status = "-1", Info = "请填写SN编号" };
+}
+if (string.IsNullOrEmpty(fields["BuyUserId"].ToString()))
+{
+    return new AppResultJson() { Status = "-1", Info = "请填写购买人" };
+}
+if (string.IsNullOrEmpty(fields["OpId"].ToString()))
+{
+    return new AppResultJson() { Status = "-1", Info = "请填写运营中心" };
+}
+if (!function.IsInt(fields["IsSupplement"].ToString()))
+{
+    return new AppResultJson() { Status = "-1", Info = "请填写正确的补录标记" };
+}
+if (!function.IsInt(fields["IsOpAct"].ToString()))
+{
+    return new AppResultJson() { Status = "-1", Info = "请填写正确的补激活奖标记" };
+}
+
+            }
+            int Id = new DbServiceNew(AppConfig.Base.main1Tables, _conn).Add("PosMachinesTwo", fields, 0);
+            return new AppResultJson(){ Status = "1", Data = Id };
+        }
+
+        /// <summary>
+        /// 修改数据
+        /// </summary>
+        /// <param name="Fields">要设置的字段</param>
+        /// <param name="Id">主键Id</param>
+        public static AppResultJson Edit(Dictionary<string, object> fields, int Id, bool check = true)
+        {
+            if(check)
+            {
+                if (string.IsNullOrEmpty(fields["UserId"].ToString()))
+{
+    return new AppResultJson() { Status = "-1", Info = "请填写所属创客" };
+}
+if (string.IsNullOrEmpty(fields["PosSn"].ToString()))
+{
+    return new AppResultJson() { Status = "-1", Info = "请填写SN编号" };
+}
+if (string.IsNullOrEmpty(fields["BuyUserId"].ToString()))
+{
+    return new AppResultJson() { Status = "-1", Info = "请填写购买人" };
+}
+if (string.IsNullOrEmpty(fields["OpId"].ToString()))
+{
+    return new AppResultJson() { Status = "-1", Info = "请填写运营中心" };
+}
+if (!function.IsInt(fields["IsSupplement"].ToString()))
+{
+    return new AppResultJson() { Status = "-1", Info = "请填写正确的补录标记" };
+}
+if (!function.IsInt(fields["IsOpAct"].ToString()))
+{
+    return new AppResultJson() { Status = "-1", Info = "请填写正确的补激活奖标记" };
+}
+
+            }
+            new DbServiceNew(AppConfig.Base.main1Tables, _conn).Edit("PosMachinesTwo", fields, Id);
+            return new AppResultJson(){ Status = "1", Data = Id };
+        }
+
+        /// <summary>
+        /// 逻辑删除
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        public static void Remove(int Id)
+        {
+            Dictionary<string, object> fields = new Dictionary<string, object>();
+            fields.Add("Status", -1);
+            new DbServiceNew(AppConfig.Base.main1Tables, _conn).Edit("PosMachinesTwo", fields, Id);
+        }
+
+        /// <summary>
+        /// 删除数据
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        public static void Delete(int Id)
+        {
+            new DbServiceNew(AppConfig.Base.main1Tables, _conn).Delete("PosMachinesTwo", Id);
+        }
+
+        /// <summary>
+        /// 排序
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        /// <param name="Sort">排序序号</param>
+        public static void Sort(int Id, int Sort)
+        {
+            new DbServiceNew(AppConfig.Base.main1Tables, _conn).Sort("PosMachinesTwo", Sort, Id);
+        }
+
+        /// <summary>
+        /// 导入数据
+        /// </summary>
+        /// <param name="ExcelData">json数据</param>
+        public static void Import(string ExcelData)
+        {
+            // WebCMSEntities db = new WebCMSEntities();
+            // JsonData list = JsonMapper.ToObject(ExcelData);
+            // for (int i = 1; i < list.Count;i++ )
+            // {
+            //     JsonData dr = list[i];
+                
+            //     db.PosMachinesTwo.Add(new PosMachinesTwo()
+            //     {
+            //         CreateDate = DateTime.Now,
+            //         UpdateDate = DateTime.Now,
+                    
+            //     });
+            //     db.SaveChanges();
+            // }
+            // db.Dispose();
+        }
+
+        /// <summary>
+        /// 导出excel表格
+        /// </summary>
+        /// <param name="fields">查询条件(单个字段)</param>
+        /// <param name="condition">查询条件(sql语句)</param>
+        /// <returns></returns>
+        // public static void ExportExcel(List<RelationData> relationData, string condition)
+        // {
+            
+        // }
+    }
+}