修改

codegit/CallCenterApi/CallCenterApi.DAL/T_Call_CallRecords.cs

@@ -14,6 +14,7 @@ namespace CallCenterApi.DAL
     /// </summary>
     public partial class T_Call_CallRecords
     {
+        private static readonly object Global_Lock = new object();
         public T_Call_CallRecords()
         { }
         #region  BasicMethod
@@ -747,19 +748,22 @@ namespace CallCenterApi.DAL
         public bool UpdateCallInRingTelRecord(Model.T_Call_CallRecords model)
         {
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("update T_Call_CallRecords set ");
-            //strSql.Append("IvrLongTime=datediff(second,IvrStartTime,IvrEndTime),");
-            //strSql.Append("WaitEndTime=getdate(),");
-            //strSql.Append("WaitLongTime=datediff(second,WaitStartTime,getdate()),");
-            //strSql.Append("RingStartTime=getdate(),");
-            //strSql.Append("UserId=@UserId,");
-            //strSql.Append("UserCode=@UserCode,");
-            //strSql.Append("UserName=@UserName,");
-            //strSql.Append("ExtNumber=@ExtNumber,");
-            //strSql.Append("NoCallState=3,");//未接状态为振铃
-            strSql.Append("DealType=@DealType");
-            strSql.Append(" where CallId=@CallId ");
-            SqlParameter[] parameters = {
+           
+            lock (DAL.T_Call_CallRecords.Global_Lock)
+            {
+                strSql.Append("update T_Call_CallRecords set ");
+                //strSql.Append("IvrLongTime=datediff(second,IvrStartTime,IvrEndTime),");
+                //strSql.Append("WaitEndTime=getdate(),");
+                //strSql.Append("WaitLongTime=datediff(second,WaitStartTime,getdate()),");
+                //strSql.Append("RingStartTime=getdate(),");
+                //strSql.Append("UserId=@UserId,");
+                //strSql.Append("UserCode=@UserCode,");
+                //strSql.Append("UserName=@UserName,");
+                //strSql.Append("ExtNumber=@ExtNumber,");
+                //strSql.Append("NoCallState=3,");//未接状态为振铃
+                strSql.Append("DealType=@DealType");
+                strSql.Append(" where CallId=@CallId ");
+                SqlParameter[] parameters = {
                     //new SqlParameter("@UserId", SqlDbType.Int,4),
                     //new SqlParameter("@UserCode", SqlDbType.VarChar,50),
                     //new SqlParameter("@UserName", SqlDbType.NVarChar,20),
@@ -767,20 +771,31 @@ namespace CallCenterApi.DAL
                     new SqlParameter("@CallId", SqlDbType.VarChar,50),
                     new SqlParameter("@DealType", SqlDbType.Int,4)};
 
-            //parameters[0].Value = model.UserId;
-            //parameters[1].Value = model.UserCode;
-            //parameters[2].Value = model.UserName;
-            //parameters[3].Value = model.ExtNumber;
-            parameters[0].Value = model.CallId;
-            parameters[1].Value = model.DealType;
-            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
-            if (rows > 0)
-            {
-                return true;
-            }
-            else
-            {
-                return false;
+                //parameters[0].Value = model.UserId;
+                //parameters[1].Value = model.UserCode;
+                //parameters[2].Value = model.UserName;
+                //parameters[3].Value = model.ExtNumber;
+                parameters[0].Value = model.CallId;
+                parameters[1].Value = model.DealType;
+                try
+                {
+                    int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
+
+                    if (rows > 0)
+                    {
+                        return true;
+                    }
+                    else
+                    {
+                        return false;
+                    }
+                }
+                catch (Exception)
+                {
+
+                    return false;
+                }
+            
             }
         }
 
@@ -794,28 +809,31 @@ namespace CallCenterApi.DAL
         public bool UpdateCallInAnswerTelRecord(Model.T_Call_CallRecords model)
         {
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("update T_Call_CallRecords set ");
-            strSql.Append("CallState=@CallState,");
-            //strSql.Append("RingEndTime=getdate(),");
-            //strSql.Append("RingLongTime=datediff(second,RingStartTime,getdate()),");
-            //strSql.Append("TalkStartTime=getdate(),");
-            strSql.Append("DealType=@DealType");
-            strSql.Append(" where CallId=@CallId");
-            SqlParameter[] parameters = {
+            lock (DAL.T_Call_CallRecords.Global_Lock)
+            {
+                strSql.Append("update T_Call_CallRecords set ");
+                strSql.Append("CallState=@CallState,");
+                //strSql.Append("RingEndTime=getdate(),");
+                //strSql.Append("RingLongTime=datediff(second,RingStartTime,getdate()),");
+                //strSql.Append("TalkStartTime=getdate(),");
+                strSql.Append("DealType=@DealType");
+                strSql.Append(" where CallId=@CallId");
+                SqlParameter[] parameters = {
                     new SqlParameter("@CallId", SqlDbType.VarChar,50),
                     new SqlParameter("@CallState", SqlDbType.Int,4),
                       new SqlParameter("@DealType", SqlDbType.Int,4)};
-            parameters[0].Value = model.CallId;
-            parameters[1].Value = model.CallState;
-            parameters[2].Value = model.DealType;
-            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
-            if (rows > 0)
-            {
-                return true;
-            }
-            else
-            {
-                return false;
+                parameters[0].Value = model.CallId;
+                parameters[1].Value = model.CallState;
+                parameters[2].Value = model.DealType;
+                int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
+                if (rows > 0)
+                {
+                    return true;
+                }
+                else
+                {
+                    return false;
+                }
             }
         }
 
@@ -829,20 +847,23 @@ namespace CallCenterApi.DAL
         public bool UpdateCallInHookTelRecord(string p_CallId)
         {
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("update T_Call_CallRecords SET DealType=(case CallState when 1 then 6 else DealType end)");
-            strSql.Append(" where CallId=@CallId");
-            SqlParameter[] parameters = {
+            lock (DAL.T_Call_CallRecords.Global_Lock)
+            {
+                strSql.Append("update T_Call_CallRecords SET DealType=(case CallState when 1 then 6 else DealType end)");
+                strSql.Append(" where CallId=@CallId");
+                SqlParameter[] parameters = {
                     new SqlParameter("@CallId", SqlDbType.VarChar,50)};
-            parameters[0].Value = p_CallId;
+                parameters[0].Value = p_CallId;
 
-            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
-            if (rows > 0)
-            {
-                return true;
-            }
-            else
-            {
-                return false;
+                int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
+                if (rows > 0)
+                {
+                    return true;
+                }
+                else
+                {
+                    return false;
+                }
             }
         }
 
@@ -856,28 +877,31 @@ namespace CallCenterApi.DAL
         public bool UpdateCallInPathTelRecord(Model.T_Call_CallRecords model)
         {
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("update T_Call_CallRecords set ");
-            strSql.Append("CallState=@CallState,");
-            //strSql.Append("FilePath=@FilePath,");
-            strSql.Append("DealType=@DealType");
-            strSql.Append(" where CallId=@CallId");
-            SqlParameter[] parameters = {
+            lock (DAL.T_Call_CallRecords.Global_Lock)
+            {
+                strSql.Append("update T_Call_CallRecords set ");
+                strSql.Append("CallState=@CallState,");
+                //strSql.Append("FilePath=@FilePath,");
+                strSql.Append("DealType=@DealType");
+                strSql.Append(" where CallId=@CallId");
+                SqlParameter[] parameters = {
                     new SqlParameter("@CallId", SqlDbType.VarChar,50),
                     new SqlParameter("@CallState", SqlDbType.Int,4),
                     //new SqlParameter("@FilePath", SqlDbType.VarChar,200),
                       new SqlParameter("@DealType", SqlDbType.Int,4)};
-            parameters[0].Value = model.CallId;
-            parameters[1].Value = model.CallState;
-            //parameters[2].Value = model.FilePath;
-            parameters[2].Value = model.DealType;
-            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
-            if (rows > 0)
-            {
-                return true;
-            }
-            else
-            {
-                return false;
+                parameters[0].Value = model.CallId;
+                parameters[1].Value = model.CallState;
+                //parameters[2].Value = model.FilePath;
+                parameters[2].Value = model.DealType;
+                int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
+                if (rows > 0)
+                {
+                    return true;
+                }
+                else
+                {
+                    return false;
+                }
             }
         }
 
@@ -960,24 +984,27 @@ namespace CallCenterApi.DAL
         public bool UpdateCallInRecordDealType(string callid, int type)
         {
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("update T_Call_CallRecords set ");
-            strSql.Append("DealType=@DealType");
-            strSql.Append(" where CallId=@CallId ");
-            SqlParameter[] parameters = {
+            lock (DAL.T_Call_CallRecords.Global_Lock)
+            {
+                strSql.Append("update T_Call_CallRecords set ");
+                strSql.Append("DealType=@DealType");
+                strSql.Append(" where CallId=@CallId ");
+                SqlParameter[] parameters = {
                     new SqlParameter("@CallId", SqlDbType.VarChar,50),
                     new SqlParameter("@DealType", SqlDbType.Int,4)};
 
 
-            parameters[0].Value = callid;
-            parameters[1].Value = type;
-            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
-            if (rows > 0)
-            {
-                return true;
-            }
-            else
-            {
-                return false;
+                parameters[0].Value = callid;
+                parameters[1].Value = type;
+                int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
+                if (rows > 0)
+                {
+                    return true;
+                }
+                else
+                {
+                    return false;
+                }
             }
         }