给110推工单

CallCenterApi/CallCenterApi.DB/CallCenterApi.DB.csproj

@@ -30,6 +30,9 @@
     <WarningLevel>4</WarningLevel>
   </PropertyGroup>
   <ItemGroup>
+    <Reference Include="MySql.Data">
+      <HintPath>D:\web\地铁\DLL\MySql.Data.dll</HintPath>
+    </Reference>
     <Reference Include="System" />
     <Reference Include="System.Configuration" />
     <Reference Include="System.Core" />
@@ -42,6 +45,7 @@
   </ItemGroup>
   <ItemGroup>
     <Compile Include="CommandInfo.cs" />
+    <Compile Include="DbHelperMySQL.cs" />
     <Compile Include="DbHelperSQL.cs" />
     <Compile Include="DbHelperSQLold.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />

CallCenterApi/CallCenterApi.DB/DbHelperMySQL.cs

@@ -0,0 +1,463 @@
+using MySql.Data.MySqlClient;
+using System;
+using System.Collections.Generic;
+using System.Configuration;
+using System.Data;
+using System.Data.SqlClient;
+
+namespace CallCenterApi.DB
+{
+    public abstract class DbHelperMySQL
+    {
+        //数据库连接字符串(web.config来配置)，可以动态更改connectionString支持多数据库.		
+        public static string connectionString = ConfigurationManager.ConnectionStrings["MySqlconnection"].ConnectionString;
+        public DbHelperMySQL() { }
+        #region 公用方法
+        /// <summary>
+        /// 得到最大值
+        /// </summary>
+        /// <param name="FieldName"></param>
+        /// <param name="TableName"></param>
+        /// <returns></returns>
+        public static int GetMaxID(string FieldName, string TableName)
+        {
+            string strsql = "select max(" + FieldName + ")+1 from " + TableName;
+            object obj = GetSingle(strsql);
+            if (obj == null)
+            {
+                return 1;
+            }
+            else
+            {
+                return int.Parse(obj.ToString());
+            }
+        }
+        /// <summary>
+        /// 是否存在
+        /// </summary>
+        /// <param name="strSql"></param>
+        /// <returns></returns>
+        public static bool Exists(string strSql)
+        {
+            object obj = GetSingle(strSql);
+            int cmdresult;
+            if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
+            {
+                cmdresult = 0;
+            }
+            else
+            {
+                cmdresult = int.Parse(obj.ToString());
+            }
+            if (cmdresult == 0)
+            {
+                return false;
+            }
+            else
+            {
+                return true;
+            }
+        }
+       
+        #endregion
+
+        #region  执行简单SQL语句
+
+        /// <summary>
+        /// 执行SQL语句，返回影响的记录数
+        /// </summary>
+        /// <param name="SQLString">SQL语句</param>
+        /// <returns>影响的记录数</returns>
+        public static int ExecuteSql(string SQLString)
+        {
+            using (MySqlConnection connection = new MySqlConnection(connectionString))
+            {
+                using (MySqlCommand cmd = new MySqlCommand(SQLString, connection))
+                {
+                    try
+                    {
+                        connection.Open();
+                        int rows = cmd.ExecuteNonQuery();
+                        return rows;
+                    }
+                    catch (MySql.Data.MySqlClient.MySqlException e)
+                    {
+                        connection.Close();
+                        throw e;
+                    }
+                }
+            }
+        }
+
+
+
+        /// <summary>
+        /// 执行SQL语句，返回影响的记录数
+        /// </summary>
+        /// <param name="SQLString">SQL语句</param>
+        /// <returns>影响的记录数</returns>
+        public static int ExecuteSqlConn(string SQLString, string connectStr)
+        {
+            using (MySqlConnection connection = new MySqlConnection(connectStr))
+            {
+                using (MySqlCommand cmd = new MySqlCommand(SQLString, connection))
+                {
+                    try
+                    {
+                        connection.Open();
+                        int rows = cmd.ExecuteNonQuery();
+                        return rows;
+                    }
+                    catch (MySql.Data.MySqlClient.MySqlException e)
+                    {
+                        connection.Close();
+                        throw e;
+                    }
+                }
+            }
+        }
+
+        public static int ExecuteSqlByTime(string SQLString, int Times)
+        {
+            using (MySqlConnection connection = new MySqlConnection(connectionString))
+            {
+                using (MySqlCommand cmd = new MySqlCommand(SQLString, connection))
+                {
+                    try
+                    {
+                        connection.Open();
+                        cmd.CommandTimeout = Times;
+                        int rows = cmd.ExecuteNonQuery();
+                        return rows;
+                    }
+                    catch (MySql.Data.MySqlClient.MySqlException e)
+                    {
+                        connection.Close();
+                        throw e;
+                    }
+                }
+            }
+        }
+
+
+        /// <summary>
+        /// 执行多条SQL语句，实现数据库事务。
+        /// </summary>
+        /// <param name="SQLStringList">多条SQL语句</param>        
+        public static int ExecuteSqlTran(List<String> SQLStringList)
+        {
+            using (MySqlConnection conn = new MySqlConnection(connectionString))
+            {
+                conn.Open();
+                MySqlCommand cmd = new MySqlCommand();
+                cmd.Connection = conn;
+                MySqlTransaction tx = conn.BeginTransaction();
+                cmd.Transaction = tx;
+                try
+                {
+                    int count = 0;
+                    for (int n = 0; n < SQLStringList.Count; n++)
+                    {
+                        string strsql = SQLStringList[n];
+                        if (strsql.Trim().Length > 1)
+                        {
+                            cmd.CommandText = strsql;
+                            count += cmd.ExecuteNonQuery();
+                        }
+                    }
+                    tx.Commit();
+                    return count;
+                }
+                catch (Exception ex)
+                {
+                    tx.Rollback();
+                    throw ex;
+                    return 0;
+                }
+            }
+        }
+        /// <summary>
+        /// 执行带一个存储过程参数的的SQL语句。
+        /// </summary>
+        /// <param name="SQLString">SQL语句</param>
+        /// <param name="content">参数内容,比如一个字段是格式复杂的文章，有特殊符号，可以通过这个方式添加</param>
+        /// <returns>影响的记录数</returns>
+        public static int ExecuteSql(string SQLString, string content)
+        {
+            using (MySqlConnection connection = new MySqlConnection(connectionString))
+            {
+                MySqlCommand cmd = new MySqlCommand(SQLString, connection);
+                MySql.Data.MySqlClient.MySqlParameter myParameter = new MySql.Data.MySqlClient.MySqlParameter("@content", SqlDbType.NText);
+                myParameter.Value = content;
+                cmd.Parameters.Add(myParameter);
+                try
+                {
+                    connection.Open();
+                    int rows = cmd.ExecuteNonQuery();
+                    return rows;
+                }
+                catch (MySql.Data.MySqlClient.MySqlException e)
+                {
+                    throw e;
+                }
+                finally
+                {
+                    cmd.Dispose();
+                    connection.Close();
+                }
+            }
+        }
+        /// <summary>
+        /// 执行带一个存储过程参数的的SQL语句。
+        /// </summary>
+        /// <param name="SQLString">SQL语句</param>
+        /// <param name="content">参数内容,比如一个字段是格式复杂的文章，有特殊符号，可以通过这个方式添加</param>
+        /// <returns>影响的记录数</returns>
+        public static object ExecuteSqlGet(string SQLString, string content)
+        {
+            using (MySqlConnection connection = new MySqlConnection(connectionString))
+            {
+                MySqlCommand cmd = new MySqlCommand(SQLString, connection);
+                MySql.Data.MySqlClient.MySqlParameter myParameter = new MySql.Data.MySqlClient.MySqlParameter("@content", SqlDbType.NText);
+                myParameter.Value = content;
+                cmd.Parameters.Add(myParameter);
+                try
+                {
+                    connection.Open();
+                    object obj = cmd.ExecuteScalar();
+                    if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
+                    {
+                        return null;
+                    }
+                    else
+                    {
+                        return obj;
+                    }
+                }
+                catch (MySql.Data.MySqlClient.MySqlException e)
+                {
+                    throw e;
+                }
+                finally
+                {
+                    cmd.Dispose();
+                    connection.Close();
+                }
+            }
+        }
+        /// <summary>
+        /// 向数据库里插入图像格式的字段(和上面情况类似的另一种实例)
+        /// </summary>
+        /// <param name="strSQL">SQL语句</param>
+        /// <param name="fs">图像字节,数据库的字段类型为image的情况</param>
+        /// <returns>影响的记录数</returns>
+        public static int ExecuteSqlInsertImg(string strSQL, byte[] fs)
+        {
+            using (MySqlConnection connection = new MySqlConnection(connectionString))
+            {
+                MySqlCommand cmd = new MySqlCommand(strSQL, connection);
+                MySql.Data.MySqlClient.MySqlParameter myParameter = new MySql.Data.MySqlClient.MySqlParameter("@fs", SqlDbType.Image);
+                myParameter.Value = fs;
+                cmd.Parameters.Add(myParameter);
+                try
+                {
+                    connection.Open();
+                    int rows = cmd.ExecuteNonQuery();
+                    return rows;
+                }
+                catch (MySql.Data.MySqlClient.MySqlException e)
+                {
+                    throw e;
+                }
+                finally
+                {
+                    cmd.Dispose();
+                    connection.Close();
+                }
+            }
+        }
+
+        /// <summary>
+        /// 执行一条计算查询结果语句，返回查询结果（object）。
+        /// </summary>
+        /// <param name="SQLString">计算查询结果语句</param>
+        /// <returns>查询结果（object）</returns>
+        public static object GetSingle(string SQLString)
+        {
+            using (MySqlConnection connection = new MySqlConnection(connectionString))
+            {
+                using (MySqlCommand cmd = new MySqlCommand(SQLString, connection))
+                {
+                    try
+                    {
+                        connection.Open();
+                        object obj = cmd.ExecuteScalar();
+                        if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
+                        {
+                            return null;
+                        }
+                        else
+                        {
+                            return obj;
+                        }
+                    }
+                    catch (MySql.Data.MySqlClient.MySqlException e)
+                    {
+                        connection.Close();
+                        throw e;
+                    }
+                }
+            }
+        }
+        public static object GetSingle(string SQLString, int Times)
+        {
+            using (MySqlConnection connection = new MySqlConnection(connectionString))
+            {
+                using (MySqlCommand cmd = new MySqlCommand(SQLString, connection))
+                {
+                    try
+                    {
+                        connection.Open();
+                        cmd.CommandTimeout = Times;
+                        object obj = cmd.ExecuteScalar();
+                        if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
+                        {
+                            return null;
+                        }
+                        else
+                        {
+                            return obj;
+                        }
+                    }
+                    catch (MySql.Data.MySqlClient.MySqlException e)
+                    {
+                        connection.Close();
+                        throw e;
+                    }
+                }
+            }
+        }
+        /// <summary>
+        /// 执行查询语句，返回MySqlDataReader ( 注意：调用该方法后，一定要对MySqlDataReader进行Close )
+        /// </summary>
+        /// <param name="strSQL">查询语句</param>
+        /// <returns>MySqlDataReader</returns>
+        public static MySqlDataReader ExecuteReader(string strSQL)
+        {
+            MySqlConnection connection = new MySqlConnection(connectionString);
+            MySqlCommand cmd = new MySqlCommand(strSQL, connection);
+            try
+            {
+                connection.Open();
+                MySqlDataReader myReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
+                return myReader;
+            }
+            catch (MySql.Data.MySqlClient.MySqlException e)
+            {
+                throw e;
+            }
+
+        }
+
+
+        /// <summary>
+        /// 执行查询语句，返回MySqlDataReader ( 注意：调用该方法后，一定要对MySqlDataReader进行Close )
+        /// </summary>
+        /// <param name="strSQL">查询语句</param>
+        /// <returns>MySqlDataReader</returns>
+        public static MySqlDataReader ExecuteReader(string strSQL, string connectionStr)
+        {
+            MySqlConnection connection = new MySqlConnection(connectionStr);
+            MySqlCommand cmd = new MySqlCommand(strSQL, connection);
+            try
+            {
+                connection.Open();
+                MySqlDataReader myReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
+                return myReader;
+            }
+            catch (MySql.Data.MySqlClient.MySqlException e)
+            {
+                throw e;
+            }
+
+        }
+
+        /// <summary>
+        /// 执行查询语句，返回DataSet
+        /// </summary>
+        /// <param name="SQLString">查询语句</param>
+        /// <returns>DataSet</returns>
+        public static DataSet Query(string SQLString)
+        {
+            using (MySqlConnection connection = new MySqlConnection(connectionString))
+            {
+                DataSet ds = new DataSet();
+                try
+                {
+                    connection.Open();
+                    MySqlDataAdapter command = new MySqlDataAdapter(SQLString, connection);
+                    command.Fill(ds, "ds");
+                }
+                catch (MySql.Data.MySqlClient.MySqlException ex)
+                {
+                    throw new Exception(ex.Message);
+                }
+                return ds;
+            }
+        }
+
+        /// <summary>
+        /// 执行查询语句，返回DataSet
+        /// </summary>
+        /// <param name="SQLString">查询语句</param>
+        /// <returns>DataSet</returns>
+        public static DataSet QueryConn(string SQLString, string conStr)
+        {
+            using (MySqlConnection connection = new MySqlConnection(conStr))
+            {
+                DataSet ds = new DataSet();
+                try
+                {
+                    connection.Open();
+                    MySqlDataAdapter command = new MySqlDataAdapter(SQLString, connection);
+                    command.Fill(ds, "ds");
+                }
+                catch (MySql.Data.MySqlClient.MySqlException ex)
+                {
+                    throw new Exception(ex.Message);
+                }
+                finally
+                {
+                    connection.Close();
+                }
+                return ds;
+            }
+        }
+
+        public static DataSet Query(string SQLString, int Times)
+        {
+            using (MySqlConnection connection = new MySqlConnection(connectionString))
+            {
+                DataSet ds = new DataSet();
+                try
+                {
+                    connection.Open();
+                    MySqlDataAdapter command = new MySqlDataAdapter(SQLString, connection);
+                    command.SelectCommand.CommandTimeout = Times;
+                    command.Fill(ds, "ds");
+                }
+                catch (MySql.Data.MySqlClient.MySqlException ex)
+                {
+                    throw new Exception(ex.Message);
+                }
+                return ds;
+            }
+        }
+
+
+
+        #endregion
+
+
+    }
+}

CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Configs/system.config

@@ -107,7 +107,7 @@
   <add key="10086SmsPassword" value="Ay+12345-Rx" />
   <add key="10086SmsSign" value="q4dGVsCk2" />
   <!-- ================== 14：其他配置 ================== -->
-  <add key="AuthDate" value="2023-10-12" />
+  <add key="AuthDate" value="2035-10-12" />
   <add key="OutSignCode" value="$AY12345#" />
   <add key="Affairs" value="0" />
 
@@ -144,5 +144,7 @@
   <add key="SendToPhone" value="15605815106"/>
 
   <add key="maindeptid" value="1600"/>
+  <add key="PushErrorOrder" value="http://localhost:51927/api/Info/addorder"/>
   
+
 </appSettings>

CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Controllers/APPController.cs

@@ -2381,5 +2381,250 @@ namespace CallCenterApi.Interface.Controllers
                 string Dataurl = web.DownloadString(url + "case_material_info" + "?WorkOrderId=" + WorkOrderId + "&file=" + file  + "&id=" + id + "&type=" + type);
             }
         }
+
+        
+        public ActionResult PushErrorWorkOrder()
+        {
+            var dt = DbHelperSQL.Query("select * from t_PushError where F_Success=0 and F_PushCount<5").Tables[0];
+
+            if (dt != null && dt.Rows.Count > 0)
+            {
+                foreach (DataRow item in dt.Rows)
+                {
+                    // 存到mysql表里
+                 
+
+                    var modelT_Bus_WorkOrder = workorderBLL.GetModel(item["F_WorkOrderCode"].ToString());
+                    string strlevel = "";
+                    if (modelT_Bus_WorkOrder.F_Level != null)
+                    {
+                        if (modelT_Bus_WorkOrder.F_Level == 1)
+                        {
+                            strlevel = "一般";
+                        }
+                        else
+                        {
+                            strlevel = "紧急";
+                        }
+                    }
+                    string strsjlx = "";
+                    var sjlx = DbHelperSQL.GetSingle($"select dbo.GetDictionaryName('{modelT_Bus_WorkOrder.F_Key}' ) ");
+                    if (sjlx != null)
+                    {
+                        strsjlx = sjlx.ToString();
+                    }
+                    string strsjly = "";
+                    var sjly = DbHelperSQL.GetSingle($"select dbo .GetDictionaryName('{modelT_Bus_WorkOrder.F_InfoSource}' ) ");
+
+                    if (sjly != null)
+                    {
+                        strsjly = sjly.ToString();
+                    }
+                    string strsex = "";
+                    if (modelT_Bus_WorkOrder.F_CusSex != null)
+                    {
+                        if (modelT_Bus_WorkOrder.F_CusSex == "1")
+                        {
+                            strsex = "女";
+                        }
+                        else
+                        {
+                            strsex = "男";
+                        }
+                    }
+                    string strsjdd = "";
+                    var sjdd = DbHelperSQL.GetSingle($"select  dbo.GetAreaName('{modelT_Bus_WorkOrder.F_SourceArea}') + isnull(  dbo.GetAreaChildrenCode('{modelT_Bus_WorkOrder.F_Township}'),'') + ISNULL( dbo.GetAreaChildrenCode('{modelT_Bus_WorkOrder.F_Village}') ,'')");
+                    if (sjdd != null)
+                    {
+                        strsjdd = sjdd.ToString();
+                    }
+                    Guid guid = Guid.NewGuid();
+                    string insertsql = $"insert into BM_hbszwf_rxyzf_001(RowGuid,sjmc,fssj,fsdd,sjjb,sjlx,sjly,dsrxm,dsrdh,dsrxb,dsrjzxz,sjjs,sjbh) values('{guid}','{modelT_Bus_WorkOrder.F_ComTitle}','{modelT_Bus_WorkOrder.F_CreateTime}','{strsjdd}','{strlevel}','{strsjlx}','{strsjly}','{modelT_Bus_WorkOrder.F_CusName}','{modelT_Bus_WorkOrder.F_CusPhone}','{strsex}','{modelT_Bus_WorkOrder.F_SourceAddress}','{modelT_Bus_WorkOrder.F_ComContent}','{modelT_Bus_WorkOrder.F_WorkOrderId}')";
+                    try
+                    {
+
+                      //  string url = "http://localhost:51927/api/Info/addorder";
+                        string url = Configs.GetValue("PushErrorOrder");
+                        Dictionary<string, object> dic = new Dictionary<string, object>();
+
+                        dic.Add("sql", insertsql);
+
+                        var resss = Post(url, dic);
+
+
+                        if (Convert.ToInt32(resss) > 0)
+                        {
+                            DbHelperSQL.ExecuteSql($" update t_PushError set F_Success=1,F_UpdateTime=getdate()   where F_WorkOrderCode='{modelT_Bus_WorkOrder.F_WorkOrderId}'");
+                        }
+                        else
+                        {
+                            // 更新推送次数
+                            DbHelperSQL.ExecuteSql($" update t_PushError set F_PushCount=F_PushCount+1 ,F_UpdateTime=getdate()   where F_WorkOrderCode='{modelT_Bus_WorkOrder.F_WorkOrderId}'");
+                        }
+                        #region 注释
+                        //int res = DbHelperMySQL.ExecuteSql(insertsql);
+
+                        ////查看是否mysql数据库是否有数据
+                        ////有数据更新本地表的success=1
+                        ////     没数据 count+1;
+                        //var exist = DbHelperMySQL.GetSingle($" select count(1) from BM_hbszwf_rxyzf_001 where sjbh='{modelT_Bus_WorkOrder.F_WorkOrderId}'");
+                        //if (Convert.ToInt32(exist) > 0)
+                        //{
+                        //    DbHelperSQL.ExecuteSql($" update t_PushError set F_Success=1,F_UpdateTime=getdate()   where F_WorkOrderCode='{modelT_Bus_WorkOrder.F_WorkOrderId}'");
+
+                        //    return Success("");
+                        //}
+                        //else
+                        //{
+                        //    DbHelperSQL.ExecuteSql($" update t_PushError set F_PushCount=F_PushCount+1 ,F_UpdateTime=getdate()   where F_WorkOrderCode='{modelT_Bus_WorkOrder.F_WorkOrderId}'");
+                        //    return Success("");
+                        //}
+#endregion
+                    }
+                    catch  
+                    {
+
+                        DbHelperSQL.ExecuteSql($" update t_PushError set F_PushCount=F_PushCount+1 ,F_UpdateTime=getdate()   where F_WorkOrderCode='{modelT_Bus_WorkOrder.F_WorkOrderId}'");
+                        return Success("");
+                    }
+                  
+
+                  
+                    //查看是否mysql数据库是否有数据
+                    //有数据更新本地表的success=1
+                    //     没数据 count+1;
+                }
+            }
+            return Success("");
+
+
+
+
+        }
+        public static string Post(string url, Dictionary<string, object> dic)
+        {
+            string result = "";
+            HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);
+            req.Method = "POST";
+            req.ContentType = "application/x-www-form-urlencoded";
+            #region 添加Post 参数
+            StringBuilder builder = new StringBuilder();
+            int i = 0;
+            foreach (var item in dic)
+            {
+                if (i > 0)
+                    builder.Append("&");
+                builder.AppendFormat("{0}={1}", item.Key, item.Value);
+                i++;
+            }
+            byte[] data = Encoding.UTF8.GetBytes(builder.ToString());
+            req.ContentLength = data.Length;
+            using (Stream reqStream = req.GetRequestStream())
+            {
+                reqStream.Write(data, 0, data.Length);
+                reqStream.Close();
+            }
+            #endregion
+            HttpWebResponse resp = (HttpWebResponse)req.GetResponse();
+            Stream stream = resp.GetResponseStream();
+            //获取响应内容
+            using (StreamReader reader = new StreamReader(stream, Encoding.UTF8))
+            {
+                result = reader.ReadToEnd();
+            }
+            return result;
+        }
+
+        public ActionResult PushSingleErrorWorkOrder(string code)
+        {
+                    // 存到mysql表里
+                    var modelT_Bus_WorkOrder = workorderBLL.GetModel(code);
+                    string strlevel = "";
+                    if (modelT_Bus_WorkOrder.F_Level != null)
+                    {
+                        if (modelT_Bus_WorkOrder.F_Level == 1)
+                        {
+                            strlevel = "一般";
+                        }
+                        else
+                        {
+                            strlevel = "紧急";
+                        }
+                    }
+                    string strsjlx = "";
+                    var sjlx = DbHelperSQL.GetSingle($"select dbo.GetDictionaryName('{modelT_Bus_WorkOrder.F_Key}' ) ");
+                    if (sjlx != null)
+                    {
+                        strsjlx = sjlx.ToString();
+                    }
+                    string strsjly = "";
+                    var sjly = DbHelperSQL.GetSingle($"select dbo .GetDictionaryName('{modelT_Bus_WorkOrder.F_InfoSource}' ) ");
+
+                    if (sjly != null)
+                    {
+                        strsjly = sjly.ToString();
+                    }
+                    string strsex = "";
+                    if (modelT_Bus_WorkOrder.F_CusSex != null)
+                    {
+                        if (modelT_Bus_WorkOrder.F_CusSex == "1")
+                        {
+                            strsex = "女";
+                        }
+                        else
+                        {
+                            strsex = "男";
+                        }
+                    }
+                    string strsjdd = "";
+                    var sjdd = DbHelperSQL.GetSingle($"select  dbo.GetAreaName('{modelT_Bus_WorkOrder.F_SourceArea}') + isnull(  dbo.GetAreaChildrenCode('{modelT_Bus_WorkOrder.F_Township}'),'') + ISNULL( dbo.GetAreaChildrenCode('{modelT_Bus_WorkOrder.F_Village}') ,'')");
+                    if (sjdd != null)
+                    {
+                        strsjdd = sjdd.ToString();
+                    }
+                    Guid guid = Guid.NewGuid();
+                    string insertsql = $"insert into BM_hbszwf_rxyzf_001(RowGuid,sjmc,fssj,fsdd,sjjb,sjlx,sjly,dsrxm,dsrdh,dsrxb,dsrjzxz,sjjs,sjbh) values('{guid}','{modelT_Bus_WorkOrder.F_ComTitle}','{modelT_Bus_WorkOrder.F_CreateTime}','{strsjdd}','{strlevel}','{strsjlx}','{strsjly}','{modelT_Bus_WorkOrder.F_CusName}','{modelT_Bus_WorkOrder.F_CusPhone}','{strsex}','{modelT_Bus_WorkOrder.F_SourceAddress}','{modelT_Bus_WorkOrder.F_ComContent}','{modelT_Bus_WorkOrder.F_WorkOrderId}')";
+                    try
+                    {
+
+                        
+                        string url = Configs.GetValue("PushErrorOrder");
+                        Dictionary<string, object> dic = new Dictionary<string, object>();
+
+                        dic.Add("sql", insertsql);
+
+                        var resss = Post(url, dic);
+
+
+                        if (Convert.ToInt32(resss) > 0)
+                        {
+                            DbHelperSQL.ExecuteSql($" update t_PushError set F_Success=1,F_UpdateTime=getdate()   where F_WorkOrderCode='{modelT_Bus_WorkOrder.F_WorkOrderId}'");
+                        }
+                        else
+                        {
+                            // 更新推送次数
+                            DbHelperSQL.ExecuteSql($" update t_PushError set F_PushCount=F_PushCount+1 ,F_UpdateTime=getdate()   where F_WorkOrderCode='{modelT_Bus_WorkOrder.F_WorkOrderId}'");
+                        }
+                     
+                    }
+                    catch
+                    {
+
+                        DbHelperSQL.ExecuteSql($" update t_PushError set F_PushCount=F_PushCount+1 ,F_UpdateTime=getdate()   where F_WorkOrderCode='{modelT_Bus_WorkOrder.F_WorkOrderId}'");
+                        return Success("");
+                    }
+
+
+             
+                    //成功更新本地表的success=1
+                    //    没成功 推送次数count+1;
+                
+          
+            return Success("执行完成");
+
+
+
+
+        }
     }
 }

CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Web.config

@@ -30,7 +30,7 @@
     <add name="ConnectionString" connectionString="Data Source=192.168.1.36;User ID=sa;pwd=hykj800100;Initial Catalog=HB12345;" />
 
     <add name="ConnectionStringOld" connectionString="Data Source=192.168.1.36;User ID=sa;pwd=hykj800100;Initial Catalog=HBSZRX;" />
-
+    <add name="MySqlconnection" connectionString="server=192.168.1.200;Port=3306;User ID=root;Password=800100;database=ay110;charset=utf8mb4;Allow User Variables=true;" />
 
   </connectionStrings>
   <system.web>

CallCenterCommon/CallCenter.QuartzService/PushWorkorder.cs

@@ -24,7 +24,26 @@ namespace CallCenter.QuartzService
 
         public void PushApp(object sender, EventArgs e)
         {
-            var Dataurl = HttpMethods.HttpPost("http://10.0.38.106:8002/PushMessage/SmsOverTime");
+            
+            try
+            {
+                var Dataurl = HttpMethods.HttpPost("http://10.0.38.106:8002/PushMessage/SmsOverTime");
+            }
+            catch (Exception)
+            {
+
+                
+            }
+            try
+            {
+                //var Dataurl2 = HttpMethods.HttpPost("http://10.0.38.106:8002/WorkOrder/PushErrorWorkOrder");
+                var Dataurl2 = HttpMethods.HttpPost("http://localhost:63663/App/PushErrorWorkOrder");
+            }
+            catch (Exception)
+            {
+
+
+            }
         }