namespace AsiaINFO.SMS.APPCMPP2.MyThread.DataThread { using AsiaINFO.SMS.APPCMPP2; using AsiaINFO.SMS.APPCMPP2.MyThread; using AsiaINFO.SMS.BusinessFactory; using AsiaINFO.SMS.CMPP2; using System; public class MTWaitResetThread : ThreadBase { private string _out_gateway_id; public MTWaitResetThread(SyncEvents syncEvents, string out_gateway_id) : base(syncEvents) { this._out_gateway_id = out_gateway_id; } protected override void Run() { bool flag = false; do { try { MTBusiness.UpdateMTWait(this._out_gateway_id, ShareData.CurrentISMG); flag = true; string msg = string.Format("重置数据库待下行数据{0}成功", this._out_gateway_id); base.OnMsg(msg, MsgLevel.Debug); } catch (Exception exception) { base.OnMsg("重置数据库数据错误" + exception.Message, MsgLevel.Err); } } while (!flag && !base._syncEvents.ExitThreadEvent.WaitOne(0x1388, false)); } } }