添加风险信息查询接口

Areas/Api/Controllers/Main/MerchantAddInfoController.cs

@@ -179,11 +179,6 @@ namespace MySystem.Areas.Api.Controllers.v1
             int Finish = int.Parse(function.CheckInt(data.getItem("Finish").ToString()));
             int UserId = int.Parse(function.CheckInt(data.getItem("UserId").ToString()));
             int MerchantAddInfoId = int.Parse(function.CheckInt(data.getItem("Id").ToString()));
-            var checks = main1db.UserSwapWhite.FirstOrDefault(m => m.UserId == UserId) ?? new Models.Main1.UserSwapWhite();
-            if (checks.Id > 0)
-            {
-                return new AppResultJson() { Status = "-1", Info = "参数错误" };
-            }
             string BankBranchId = "";
             if (Finish == 1)
             {

Areas/Api/Controllers/Main/UserSwapWhiteController.cs

@@ -0,0 +1,56 @@
+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.Main1;
+
+namespace MySystem.Areas.Api.Controllers.v1.Main1
+{
+    [Area("Api")]
+    [Route("/v1/QrCodePlateMain/[controller]/[action]")]
+    public class UserSwapWhiteController : BaseController
+    {
+        public UserSwapWhiteController(IHttpContextAccessor accessor) : base(accessor)
+        {
+        }
+
+
+        #region 风险管理-风险创客列表
+        [Authorize]
+        public JsonResult RiskMakerList(string value)
+        {
+            value = PublicFunction.DesDecrypt(value);
+            JsonData data = JsonMapper.ToObject(value);
+            Dictionary<string, object> Obj = RiskMakerListDo(value);
+            return Json(new AppResultJson() { Status = "1", Info = "", Data = Obj });
+        }
+        private Dictionary<string, object> RiskMakerListDo(string value)
+        {
+            JsonData data = JsonMapper.ToObject(value);
+            int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); //风控创客Id
+            var RiskFlag = 0;
+            var Remark = "";
+            var info = UserSwapWhiteService.Query(" and UserId=" + UserId + "");
+            if (info.Id > 0)
+            {
+                RiskFlag = 1;
+                Remark = info.Remark;
+            }
+            Dictionary<string, object> Obj = new Dictionary<string, object>();
+            Obj.Add("RiskFlag", RiskFlag);
+            Obj.Add("Remark", Remark);
+            return Obj;
+        }
+        #endregion
+
+    }
+}

Config/Base.cs

@@ -10,10 +10,12 @@ namespace AppConfig
         public static string Database = Library.ConfigurationManager.AppSettings["Database"].ToString();
         public static string defaultImage = Library.ConfigurationManager.AppSettings["Host"].ToString() + "/skin/app/default/static/images/default.jpg";
         public static string SqlConnStr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
-        public static string ZsSqlConnStr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
+        public static string ZsSqlConnStr = Library.ConfigurationManager.AppSettings["ZsSqlConnStr"].ToString();
+        public static string KxsSqlConnStr = Library.ConfigurationManager.AppSettings["KxsSqlConnStr"].ToString();
         public static string StatConnRds = Library.ConfigurationManager.AppSettings["StatSqlConnStr"].ToString();
         
         #region 数据库结构
+        public static Dictionary<string, Dictionary<string, string>> kxsMainTables = new Dictionary<string, Dictionary<string, string>>();
         public static Dictionary<string, Dictionary<string, string>> mainTables = new Dictionary<string, Dictionary<string, string>>();
         public static Dictionary<string, Dictionary<string, string>> main1Tables = new Dictionary<string, Dictionary<string, string>>();
         public static Dictionary<string, Dictionary<string, string>> statTables = new Dictionary<string, Dictionary<string, string>>();

Service/KxsMain/UsersService.cs

@@ -0,0 +1,261 @@
+/*
+ * 创客
+ */
+
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Data;
+using MySystem.Models.KxsMainModels;
+using Library;
+using LitJson;
+
+namespace MySystem.Service.KxsMain
+{
+    public class UsersService
+    {
+        static string _conn = ConfigurationManager.AppSettings["KxsSqlConnStr"].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>(); //要显示的列
+            fields.Add("Id");
+            fields.Add("CreateDate"); //注册时间
+            fields.Add("Status"); //状态
+            fields.Add("MakerCode"); //创客编号
+            fields.Add("RealName"); //真实姓名
+            fields.Add("Mobile"); //手机号
+            fields.Add("CertId"); //身份证号
+            fields.Add("UserLevel"); //创客等级
+            fields.Add("AgentAreas"); //代理区域
+            fields.Add("MerchantType"); //商户创客类型
+            fields.Add("MerchantDate"); //成为商户型创客时间
+            fields.Add("AuthFlag"); //实名标识
+            fields.Add("AuthDate"); //实名时间
+            fields.Add("RiskFlag"); //风控标识
+            fields.Add("ParentUserId"); //直属创客Id
+            fields.Add("ParentNav"); //父级集合
+            fields.Add("SettleBankCardNo");
+            fields.Add("SettleBankName");
+            // fields.Add("SettleAmount"); //最低结算金额
+            // fields.Add("CashFreezeAmt"); //提现冻结金额
+            // fields.Add("CertValidStartDate"); //身份证有效期开始时间
+            // fields.Add("CertValidEndDate"); //身份证有效期结束时间
+            // fields.Add("SettleBankCardName"); //结算银行卡户名
+            // fields.Add("AgentLevel"); //代理等级
+            // fields.Add("CashStatus"); //代付账户状态
+            // fields.Add("LeaderLevel"); //盟主等级
+            // fields.Add("BusinessFlag"); //企业标记
+            // fields.Add("DeviceType"); //设备类型
+            // fields.Add("HelpProfitAgree"); //助利宝协议标记
+            // fields.Add("HelpProfitAgreeDate"); //助利宝协议标记时间
+
+            Dictionary<string, object> obj = new DbService(AppConfig.Base.KxsSqlConnStr, _conn).IndexData("Users", 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>(); //要显示的列
+            fields.Add("Id");
+            fields.Add("CreateDate"); //添加时间
+            fields.Add("Status"); //状态
+            fields.Add("RealName"); //真实姓名
+            fields.Add("CertId"); //身份证号
+            fields.Add("UserLevel"); //创客等级
+            fields.Add("MerchantType"); //商户创客类型
+            fields.Add("MerchantDate"); //成为商户型创客时间
+            fields.Add("AuthFlag"); //实名标识
+            fields.Add("RiskFlag"); //风控标识
+            fields.Add("MakerCode"); //创客编号
+            fields.Add("SettleAmount"); //最低结算金额
+            fields.Add("CashFreezeAmt"); //提现冻结金额
+            fields.Add("CertValidStartDate"); //身份证有效期开始时间
+            fields.Add("CertValidEndDate"); //身份证有效期结束时间
+            fields.Add("SettleBankCardName"); //结算银行卡户名
+            fields.Add("AgentLevel"); //代理等级
+            fields.Add("AgentAreas"); //代理区域
+            fields.Add("CashStatus"); //代付账户状态
+            fields.Add("LeaderLevel"); //盟主等级
+            fields.Add("BusinessFlag"); //企业标记
+            fields.Add("DeviceType"); //设备类型
+            fields.Add("HelpProfitAgree"); //助利宝协议标记
+            fields.Add("HelpProfitAgreeDate"); //助利宝协议标记时间
+
+            Dictionary<string, object> obj = new DbService(AppConfig.Base.KxsSqlConnStr, _conn).IndexData("Users", 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 Users Query(int Id)
+        {
+            WebCMSEntities db = new WebCMSEntities();
+            Users editData = db.Users.FirstOrDefault(m => m.Id == Id) ?? new Users();
+            db.Dispose();
+            return editData;
+        }
+
+        public static Users Query(string condition, string fields = "*")
+        {
+            // DataTable dt = new DbService(AppConfig.Base.KxsSqlConnStr, _conn).QueryDetail(fields, "Users", condition);
+            // if(dt.Rows.Count > 0)
+            // {
+            //     Dictionary<string, object> row = new Dictionary<string, object>();
+            //     foreach(DataColumn dc in dt.Columns)
+            //     {
+            //         row.Add(dc.ColumnName, dt.Rows[0][dc.ColumnName].ToString());
+            //     }
+            //     return Newtonsoft.Json.JsonConvert.DeserializeObject<Users>(Newtonsoft.Json.JsonConvert.SerializeObject(row));
+            // }
+            var users = new DbService(AppConfig.Base.KxsSqlConnStr, _conn).Query(fields, "Users", condition);
+            if (users.Count > 0)
+            {
+                return Newtonsoft.Json.JsonConvert.DeserializeObject<Users>(Newtonsoft.Json.JsonConvert.SerializeObject(users));
+            }
+            return new Users();
+        }
+
+        /// <summary>
+        /// 通过创客编号查询一条记录
+        /// </summary>
+        /// <param name="MakerCode">创客编号</param>
+        /// <returns></returns>
+        public static Users QueryByMakerCode(string MakerCode)
+        {
+            WebCMSEntities db = new WebCMSEntities();
+            Users editData = db.Users.FirstOrDefault(m => m.MakerCode == MakerCode) ?? new Users();
+            db.Dispose();
+            return editData;
+        }
+
+        /// <summary>
+        /// 查询记录数
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        /// <returns></returns>
+        public static int Count(string condition = "")
+        {
+            int result = 0;
+            DataTable dt = CustomerSqlConn.dtable("select count(Id) from Users where 1=1" + condition, _conn);
+            if (dt.Rows.Count > 0)
+            {
+                result = int.Parse(function.CheckInt(dt.Rows[0][0].ToString()));
+            }
+            return result;
+        }
+
+        /// <summary>
+        /// 查询是否存在
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        /// <returns></returns>
+        public static bool Exist(int Id)
+        {
+            WebCMSEntities db = new WebCMSEntities();
+            bool check = db.Users.Any(m => m.Id == Id);
+            db.Dispose();
+            return check;
+        }
+
+        /// <summary>
+        /// 添加数据
+        /// </summary>
+        /// <param name="Fields">要设置的字段</param>
+        /// <returns></returns>
+        public static AppResultJson Add(Dictionary<string, object> fields, bool check = true)
+        {
+            int Id = new DbService(AppConfig.Base.KxsSqlConnStr, _conn).Add("Users", 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)
+        {
+            new DbService(AppConfig.Base.KxsSqlConnStr, _conn).Edit("Users", 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 DbService(AppConfig.Base.KxsSqlConnStr, _conn).Edit("Users", fields, Id);
+        }
+
+        /// <summary>
+        /// 删除数据
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        public static void Delete(int Id)
+        {
+            new DbService(AppConfig.Base.KxsSqlConnStr, _conn).Delete("Users", Id);
+        }
+
+        /// <summary>
+        /// 排序
+        /// </summary>
+        /// <param name="Id">主键Id</param>
+        /// <param name="Sort">排序序号</param>
+        public static void Sort(int Id, int Sort)
+        {
+            new DbService(AppConfig.Base.KxsSqlConnStr, _conn).Sort("Users", 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.Users.Add(new Users()
+                {
+                    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)
+        // {
+
+        // }
+    }
+}

Startup.cs

@@ -131,6 +131,7 @@ namespace MySystem
                     pattern: "{controller=Home}/{action=Index}/{Id?}");
             });
 
+            initKxsMainServer();//客小爽主库
             initMainServer();
             initMain1Server();
             InitStat();
@@ -138,6 +139,33 @@ namespace MySystem
         }
 
         //初始化数据结构
+        private void initKxsMainServer()
+        {
+            Dictionary<string, Dictionary<string, string>> tables = new Dictionary<string, Dictionary<string, string>>();
+            string connstr = Configuration["Setting:KxsSqlConnStr"];
+            string dbName = "KxsMainServer";
+            // if(Library.ConfigurationManager.EnvironmentFlag == 2)
+            // {
+            //     dbName = "KxsProfitServer";
+            // }
+            System.Data.DataTable tablecollection = Library.CustomerSqlConn.dtable("select DISTINCT TABLE_NAME from information_schema.columns where table_schema = '" + dbName + "'", connstr);
+            foreach (System.Data.DataRow subtable in tablecollection.Rows)
+            {
+                Dictionary<string, string> Columns = new Dictionary<string, string>();
+                System.Data.DataTable columncollection = Library.CustomerSqlConn.dtable("select COLUMN_NAME,DATA_TYPE from information_schema.columns where table_schema = '" + dbName + "' and TABLE_NAME='" + subtable["TABLE_NAME"].ToString() + "'", connstr);
+                foreach (System.Data.DataRow column in columncollection.Rows)
+                {
+                    string datatype = column["DATA_TYPE"].ToString();
+                    if (datatype == "decimal")
+                    {
+                        datatype = "numeric";
+                    }
+                    Columns.Add(column["COLUMN_NAME"].ToString(), datatype);
+                }
+                tables.Add(subtable["TABLE_NAME"].ToString(), Columns);
+            }
+            AppConfig.Base.kxsMainTables = tables;
+        }
         private void initMainServer()
         {
             Dictionary<string, Dictionary<string, string>> tables = new Dictionary<string, Dictionary<string, string>>();