仁风控代码定期更新支持全球新闻20230105FX

leo

2023-01-05 c889bfe7a219257fcc549a3e3f9aba20d681dbc2

仁风控代码定期更新支持全球新闻20230105FX

 .vs/RiskControlRR/v15/Server/sqlite3/storage.ide

Binary files differ

 CommonHelper/Format/ConvertHelper.cs

@@ -1041,6 +1041,7 @@
        /// <returns></returns>
        public static string GetPYFull(string str)
        {
            if (str == "" || str==null) return "";
            string PYstr = "";
            foreach (char item in str.ToCharArray())
            {

 CommonHelper/Weixin/WechatHelper.cs

@@ -8,9 +8,9 @@
    public  class WechatHelper
    {
        //维优微信服务号--预警用途
        private const string oauth_app_id = "wx8299fc761b813125";
        private const string oauth_app_key = "52c062aa880ed82ca6716dc8c30e6dbc";
        
        private const string oauth_app_id = "wxb00487d99ff5e2de";//
        private const string oauth_app_key = "cd0edc6a98a1718a1e7325e9bfc8f93f";

        /// <summary>
        /// 获得公众账号访问密钥
        /// </summary>

 GasolineBlend.BLL/TushareNewsBLL.cs

@@ -176,10 +176,54 @@

        }

        public DataPageMajor GetMajorNewsList(string ParContent, int PageSize, int PageIndex)
        {
            int TotalCount = 0;
            var StrWhere = " 1=1 ";
            if (ParContent != "")
            {
                ParContent = ParContent.Replace("(", "").Replace(")", "");
                StrWhere += $" and  Contents like '%{ParContent}%' or Title like '%{ParContent}%' ";
            }
            //var list = _acc.GetNewsList(Channels1, Channels2, SubClassId, ParContent);
            var slist = GetPagingDAL.GetUserAccess<TushareMajorNews>("id,Contents,Title,PubTime", "TushareMajorNews", PageIndex, PageSize, StrWhere, "PubTime", ref TotalCount);
            #region 分页
            DataPageMajor dataPage = new DataPageMajor();
            //获取总条数
            var totalcount = TotalCount;
            //获取总页数
            var totalpages = Math.Ceiling(TotalCount * 1.0 / PageSize);
            //总条数 总页数 
            dataPage.TotalItems = totalcount;
            dataPage.TotalPages = Convert.ToInt32(totalpages);
            dataPage.CurrentPage = PageIndex;
            dataPage.PageSize = PageSize;
            //var slist = list.Skip((PageIndex - 1) * PageSize)
            //             .Take(PageSize).ToList();
            if (slist != null)
            {
                for (int i = 0; i < slist.Count; i++)
                {
                    if (slist[i].Title == slist[i].Contents)
                    {
                        slist[i].Contents = "";
                    }
                }
            }

            dataPage.TrTushareMajorNewses = slist;
            return dataPage;
            #endregion

        }
        public List<NewsSubClass> GetSubClassList()
        {
            return _acc.GetSubClassList();
        }

        public bool UpdTushareMajorNew(string Contents, int Id)
        {
            return _acc.UpdTushareMajorNew(Contents, Id);
        }
    }
}

 GasolineBlend.DAL/TushareNewsDAL.cs

@@ -78,5 +78,13 @@
            return Conn.Execute(sql, paras) > 0;
        }

        public bool UpdTushareMajorNew(string Contents, int Id)
        {
            var sql = $"update TushareMajorNews set  Contents=@Contents where Id=@Id";
            DynamicParameters paras = new DynamicParameters();
            paras.Add("Contents", Contents);
            paras.Add("Id", Id);
            return Conn.Execute(sql, paras) > 0;
        }
    }
}

 GasolineBlend.Entity/GasolineBlend.Entity.csproj

@@ -213,6 +213,7 @@
    <Compile Include="TushareBalanceSheet.cs" />
    <Compile Include="TushareCashFlow.cs" />
    <Compile Include="TushareIncome.cs" />
    <Compile Include="TushareMajorNews.cs" />
    <Compile Include="TushareNews.cs" />
    <Compile Include="TushareStockBasic.cs" />
    <Compile Include="Vote.cs" />

 GasolineBlend.Entity/QccSearchInfo.cs

@@ -45,7 +45,8 @@
        [Display(Name = "投资事件图谱投资方")] InvestKGInputTZ = 8,
        [Display(Name = "半导体知识图谱公司")] SimiKGInputCompany = 9,
        [Display(Name = "半导体知识图谱产业链")] SemiKGInputIndustry = 10,
        [Display(Name = "半导体海关微数据")] SemiKGInputCustoms = 11
        [Display(Name = "半导体海关微数据")] SemiKGInputCustoms = 11,
        [Display(Name = "上市公司智能投顾")] InvestSmart = 12
    };

}

 GasolineBlend.Entity/TushareMajorNews.cs

New file
@@ -0,0 +1,56 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace GasolineBlend.Entity
{
   public class TushareMajorNews
    {
        /// <summary>
        /// 编号
        /// </summary>
        public int id { get; set; }
        /// <summary>
        /// 内容
        /// </summary>
        public string Contents { get; set; }
        /// <summary>
        /// 标题
        /// </summary>
        public string Title { get; set; }
        /// <summary>
        /// 来源
        /// </summary>
        public string Src { get; set; }
        /// <summary>
        /// 日期
        /// </summary>
        public DateTime PubTime { get; set; }

    }
   public class DataPageMajor
   {
       /// <summary>
       /// 总记录数
       /// </summary>
       public int TotalItems { get; set; }
       /// <summary>
       /// 总页数
       /// </summary>
       public int TotalPages { get; set; }
       /// <summary>
       /// 当前页数
       /// </summary>
       public int CurrentPage { get; set; }
       /// <summary>
       /// 每页条数
       /// </summary>
       public int PageSize { get; set; }
       /// <summary>
       /// 新闻列表
       /// </summary>
       public List<TushareMajorNews> TrTushareMajorNewses { get; set; }
   }
}

 GasolineBlend/Controllers/QiChaChaController.cs

@@ -93,7 +93,7 @@
                    result.Message, searchType);
            }

            if (result!=null &&result.Message.Contains("当前的KEY无效"))
            if (result!=null && result.Message!=null &&result.Message.Contains("当前的KEY无效"))
            {
                result.Message = "您的查询额度不足！请联系管理员开通!";
            }

 GasolineBlend/Controllers/TushareNewsController.cs

@@ -53,6 +53,10 @@
            }
        }

        /// <summary>
        /// 获取新闻类型分类-非登录
        /// </summary>
        /// <returns></returns>
        [LoginChecked(false)]
        [HttpPost]
        public ActionResult GetSubClassListNoCheck()
@@ -65,11 +69,19 @@
            catch (Exception e)
            {

                LogHelper.Write(Level.Error, "获取新闻类型分类 GetSubClassListNoCheck", e, OperatorProvider.Instance.Current == null ? "GuestEx" : OperatorProvider.Instance.Current.LoginName);
                LogHelper.Write(Level.Error, "获取新闻类型分类-非登录 GetSubClassListNoCheck", e, OperatorProvider.Instance.Current == null ? "GuestEx" : OperatorProvider.Instance.Current.LoginName);
                return Error();
            }
        }

        /// <summary>
        /// 获取新闻详细信息-非登录
        /// </summary>
        /// <param name="SubClassId"></param>
        /// <param name="ParContent"></param>
        /// <param name="PageSize"></param>
        /// <param name="PageIndex"></param>
        /// <returns></returns>
        [HttpPost]
        [LoginChecked(false)]
        public ActionResult GetNewsListNoCheck(int SubClassId, string ParContent, int PageSize = 50, int PageIndex = 1)
@@ -82,7 +94,79 @@
            catch (Exception e)
            {

                LogHelper.Write(Level.Error, "获取新闻详细信息 GetNewsListNoCheck", e, OperatorProvider.Instance.Current == null ? "GuestEx" : OperatorProvider.Instance.Current.LoginName);
                LogHelper.Write(Level.Error, "获取新闻详细信息-非登录 GetNewsListNoCheck", e, OperatorProvider.Instance.Current == null ? "GuestEx" : OperatorProvider.Instance.Current.LoginName);
                return Error();
            }
        }

        /// <summary>
        /// 获取新闻资讯信息
        /// </summary>
        /// <param name="ParContent"></param>
        /// <param name="PageSize"></param>
        /// <param name="PageIndex"></param>
        /// <returns></returns>
        [HttpPost]
        public ActionResult GetMajorNewsList(string ParContent, int PageSize = 50, int PageIndex = 1)
        {
            try
            {
                var list = _acc.GetMajorNewsList(ParContent, PageSize, PageIndex);
                //用来更新清洗新闻数据20230105FX
                //for (int i = 0; i < list.TrTushareMajorNewses.Count; i++)
                //{
                //    if (list.TrTushareMajorNewses[i].Contents != null && list.TrTushareMajorNewses[i].Contents.IndexOf("关注同花顺财经（ths518）") > 0)
                //    {
                //        list.TrTushareMajorNewses[i].Contents = list.TrTushareMajorNewses[i].Contents.Substring(0, list.TrTushareMajorNewses[i].Contents.IndexOf("关注同花顺财经（ths518）"));
                //    }

                //    if (list.TrTushareMajorNewses[i].Contents != null)
                //    {
                //        list.TrTushareMajorNewses[i].Contents = list.TrTushareMajorNewses[i].Contents.Replace("(image_address", "<img src").Replace("\")", "\"/>");
                //    }

                //    try
                //    {
                //        _acc.UpdTushareMajorNew(list.TrTushareMajorNewses[i].Contents, list.TrTushareMajorNewses[i].id);
                //    }
                //    catch (Exception e)
                //    {
                //        Console.WriteLine(e);
                //        throw;
                //    }
                   
                //}
                return SuccessNoShowNoCheck(data: list);
            }
            catch (Exception e)
            {

                LogHelper.Write(Level.Error, "获取新闻资讯信息 GetMajorNewsList", e, OperatorProvider.Instance.Current == null ? "GuestEx" : OperatorProvider.Instance.Current.LoginName);
                return Error();
            }
        }

        /// <summary>
        /// 获取新闻资讯信息-非登录
        /// </summary>
        /// <param name="SubClassId"></param>
        /// <param name="ParContent"></param>
        /// <param name="PageSize"></param>
        /// <param name="PageIndex"></param>
        /// <returns></returns>
        [HttpPost]
        [LoginChecked(false)]
        public ActionResult GetMajorNewsListNoCheck(int SubClassId, string ParContent, int PageSize = 50, int PageIndex = 1)
        {
            try
            {
                var list = _acc.GetMajorNewsList(ParContent, PageSize, PageIndex);
                return SuccessNoShowNoCheck(data: list);
            }
            catch (Exception e)
            {

                LogHelper.Write(Level.Error, "获取新闻资讯信息-非登录 GetMajorNewsListNoCheck", e, OperatorProvider.Instance.Current == null ? "GuestEx" : OperatorProvider.Instance.Current.LoginName);
                return Error();
            }
        }

 GasolineBlend/Controllers/UserController.cs

@@ -57,7 +57,7 @@
            }
            catch (Exception e)
            {
                LogHelper.Write(Level.Error, "获取存量现金资产列表 GetAssessCapitalList", e, OperatorProvider.Instance.Current==null?"GuestEx":OperatorProvider.Instance.Current.LoginName);
                LogHelper.Write(Level.Error, "获取用户信息列表 GetAccountList", e, OperatorProvider.Instance.Current==null?"GuestEx":OperatorProvider.Instance.Current.LoginName);
                return Error();
            }
        }
@@ -1050,7 +1050,7 @@
                       return Error("当前账号已绑定微信推送！请不要重复绑定！");

                   bool bResult = _acc.BindWXAlarmAccount(userName, password, companyRemark, AlarmWXId);
                   return bResult ? Success(message: $"当前微信号已成功绑定维优账号（企业识别码:{companyRemark}；用户名:{userName}），如需解除绑定请联系维优客服顾问！") : Error();
                   return bResult ? Success(message: $"当前微信号已成功绑定仁风控账号（用户名:{userName}），如需解除绑定请联系仁软客服顾问！") : Error();

               }


 GasolineBlend/Web.config

@@ -6,8 +6,9 @@
<configuration>
  <connectionStrings>
    <add name="connIndustry" connectionString="Data Source=47.92.245.94,1433;Initial Catalog=RiskControlRR;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />
    <add name="connStr" connectionString="Data Source=47.92.245.94,1433;Initial Catalog=RiskControlRR;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />
    <!--<add name="connStr" connectionString="Data Source=106.54.94.174,1433;Initial Catalog=RiskControlDB;Integrated Security=False;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />-->
    <!--<add name="connStr" connectionString="Data Source=47.103.92.119,1433;Initial Catalog=RiskControlRR;User ID=sa;Password=win2021!" providerName="System.Data.SqlClient" />-->
    <!--<add name="connStr" connectionString="Data Source=47.92.245.94,1433;Initial Catalog=RiskControlRR;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />-->
    <add name="connStr" connectionString="Data Source=47.103.92.119,1433;Initial Catalog=RiskControlRR;Integrated Security=False;User ID=sa;Password=win2021!" providerName="System.Data.SqlClient" />
    <add name="connStrCreditRating" connectionString="Data Source=47.92.245.94,1433;Initial Catalog=RiskControlCR;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />
    <add name="connStrNews" connectionString="Data Source=47.92.245.94,1433;Initial Catalog=RiskControlNews;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />
    <add name="connStrNeeq" connectionString="Data Source=47.92.245.94,1433;Initial Catalog=RiskControlNeeq;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />
@@ -17,7 +18,8 @@
    <add name="connStrXt" connectionString="Data Source=47.103.92.119,1433;Initial Catalog=RiskControlStockDL;User ID=sa;Password=win2021!" providerName="System.Data.SqlClient" />
    <add name="connStrWX" connectionString="Data Source=47.92.245.94,1433;Initial Catalog=RiskControlWX;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />
    <add name="connStrTushare" connectionString="Data Source=47.92.245.94,1433;Initial Catalog=TushareDB;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />
    <add name="connStrAlarm" connectionString="Data Source=47.92.245.94,1433;Initial Catalog=RiskControlAlarm;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />
    <!--<add name="connStrAlarm" connectionString="Data Source=47.92.245.94,1433;Initial Catalog=RiskControlAlarm;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />-->
    <add name="connStrAlarm" connectionString="Data Source=47.103.92.119,1433;Initial Catalog=RiskControlAlarm;User ID=sa;Password=win2021!" providerName="System.Data.SqlClient" />
    <add name="connStrStockA" connectionString="Data Source=47.92.245.94,1433;Initial Catalog=RiskControlStockA;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />
    <add name="connStrStockB" connectionString="Data Source=47.92.245.94,1433;Initial Catalog=RiskControlStockB;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />
    <add name="connStrStockC" connectionString="Data Source=47.92.245.94,1433;Initial Catalog=RiskControlStockC;User ID=sa;Password=12345sa!" providerName="System.Data.SqlClient" />

 RiskControl.NewService/Service/AlarmService.cs

@@ -65,7 +65,7 @@
            {
                eventTypeSql = @"
  SELECT '公告类' level1,EventType level2,SUM(num) num FROM #temp 
  WHERE EventType IN ('深度信息-上市信息-公司公告-业绩预告','深度信息-上市信息-公司公告-公司公告','深度信息-新三板上市信息-公司公告')
  WHERE EventType IN ('深度信息-上市信息-公司公告-业绩预告','深度信息-上市信息-公司公告-公司公告','深度信息-新三板上市信息-公司公告','深度信息-上市信息-行情走势-交易行情-每日指标', '深度信息 - 上市信息 - 行情走势 - 股东增减持')
  GROUP BY EventType";
            }
            else
@@ -158,7 +158,7 @@
                "深度信息-经营信息-招投标", "深度信息-经营信息-购地信息", "深度信息-经营信息-招聘信息", "深度信息-经营信息-新闻舆论", "深度信息-经营信息-商标信息",
                "深度信息-经营信息-专利信息"
            };
            var anTypeArr = new[] {"深度信息-上市信息-公司公告-业绩预告", "深度信息-上市信息-公司公告-公司公告", "深度信息-新三板上市信息-公司公告"};
            var anTypeArr = new[] {"深度信息-上市信息-公司公告-业绩预告", "深度信息-上市信息-公司公告-公司公告", "深度信息-新三板上市信息-公司公告", "深度信息-上市信息-行情走势-交易行情-每日指标", "深度信息-上市信息-行情走势-股东增减持" };


            var sqlTemp = $@"SELECT EventType,WarnLevel,COUNT(1) Num  FROM dbo.ComDynamic WHERE CompanyName IN ('{string.Join("','", companyNames)}')
@@ -233,7 +233,7 @@
                "深度信息-经营信息-招投标", "深度信息-经营信息-购地信息", "深度信息-经营信息-招聘信息", "深度信息-经营信息-新闻舆论", "深度信息-经营信息-商标信息",
                "深度信息-经营信息-专利信息"
            };
            var anTypeArr = new[] { "深度信息-上市信息-公司公告-业绩预告", "深度信息-上市信息-公司公告-公司公告", "深度信息-新三板上市信息-公司公告" };
            var anTypeArr = new[] { "深度信息-上市信息-公司公告-业绩预告", "深度信息-上市信息-公司公告-公司公告", "深度信息-新三板上市信息-公司公告", "深度信息-上市信息-行情走势-交易行情-每日指标", "深度信息-上市信息-行情走势-股东增减持" };
            var result = alarmDb.Queryable<ComDynamic>()
                .WhereIF(startTime != null, a => a.ContentTime >= startTime)
                .WhereIF(endTime != null, a => a.ContentTime <= endTime)
@@ -272,7 +272,7 @@
                "深度信息-经营信息-招投标", "深度信息-经营信息-购地信息", "深度信息-经营信息-招聘信息", "深度信息-经营信息-新闻舆论", "深度信息-经营信息-商标信息",
                "深度信息-经营信息-专利信息"
            };
            var anTypeArr = new[] { "深度信息-上市信息-公司公告-业绩预告", "深度信息-上市信息-公司公告-公司公告", "深度信息-新三板上市信息-公司公告" };
            var anTypeArr = new[] { "深度信息-上市信息-公司公告-业绩预告", "深度信息-上市信息-公司公告-公司公告", "深度信息-新三板上市信息-公司公告", "深度信息-上市信息-行情走势-交易行情-每日指标", "深度信息-上市信息-行情走势-股东增减持" };
            var orWhere = Expressionable.Create<ComDynamic>();
            orWhere.AndIF(eventType1.Contains("经营预警类"), a => a.EventType.StartsWith("深度信息-经营预警"))
                .OrIF(eventType1.Contains("司法涉诉类"), a => a.EventType.StartsWith("深度信息-司法涉诉"))