SendNotify.vbs
 1'********************************************************************
 2'Author: 碟子 http://cancelpj.cnblogs.com/
 3'Date: 2008-02-17
 4'Detail: 定时从数据库取得消息队列，并调用RTX接口发送即时消息提醒。
 5'********************************************************************
 6
 7'循环周期（分钟）
 8Const CycleTime = 1
 9'日志文件
10Const LogFile = "RTX_Notify.log"
11'追加写入模式
12Const ForAppending = 8
13
14Dim RTXObj, RTXParams
15Dim RTXResult
16Dim objFSO, objLogFile
17Dim cnSrc, rst
18
19Set RTXObj =  CreateObject("rtxserver.rtxobj")
20Set RTXParams = CreateObject("rtxserver.collection")
21RTXObj.Name = "SYSTOOLS"
22
23Set objFSO = CreateObject("Scripting.FileSystemObject")
24set cnSrc = CreateObject("ADODB.Connection")
25set rst = CreateObject("ADODB.RecordSet") 
26
27While 1
28    cnSrc.Open "Provider=sqloledb;server=RTX数据库地址;Uid=rtx;Pwd=rtx;Database=RTX"
29    set rst = cnSrc.Execute _
30        ("SELECT MsgID,DelayTime,Receiver,Title,MsgInfo,Type,SendMode FROM Msg_Queue")
31
32    Set objLogFile = objFSO.OpenTextFile(LogFile, ForAppending, True)
33
34    Do until rst.eof
35        'Wscript.StdOut.WriteLine(rst("now() & VBTAB & MsgID : " & rst("MsgID") & VBTAB & rst("Title") & VBTAB & rst("MsgInfo"))
36        RTXParams.Remove "SENDMODE"
37
38        'RTXParams.Add "MSGID", rst("MsgID")
39        'RTXParams.Add "ASSTYPE", "0"
40        RTXParams.Add "DELAYTIME", rst("DelayTime")*1000
41        RTXParams.Add "USERNAME", rst("Receiver")
42        RTXParams.Add "TITLE", rst("Title")
43        RTXParams.Add "MSGINFO", rst("MsgInfo")
44        RTXParams.Add "TYPE", rst("Type")    '0 - 普通消息；1 - 紧急消息
45
46        iSendMode = 0
47        if rst("SendMode") = 1 then
48            iSendMode = iSendMode + &H1    '发送给所有用户
49        end if
50        if iSendMode > 0 then 
51            iSendMode = iSendMode + &H10    '需要查询状态
52            RTXParams.Add "SENDMODE", iSendMode
53        end if
54       
55        On error resume next
56        RTXResult = ""
57        RTXResult = RTXobj.Call2(&H2100, RTXParams) 
58        if( err.number < 0) then 
59            objLogFile.Write now() & VBTAB & err.Description
60            objLogFile.Write VBTAB & "MsgID : " & rst("MsgID") & VBTAB & rst("Title")
61            objLogFile.Write VBTAB & rst("MsgInfo")
62            objLogFile.Write VbCrLf
63        else 
64            objLogFile.Write now() & VBTAB & "发送成功"
65            objLogFile.Write VBTAB & "MsgID : " & rst("MsgID") & VBTAB & rst("Title")
66            objLogFile.Write VBTAB & rst("MsgInfo")
67            objLogFile.Write VbCrLf
68            
69            cnSrc.Execute "DELETE FROM Msg_Queue WHERE MsgID=" & rst("MsgID")
70            'rst.Delete
71            Wscript.Sleep 10*1000
72        end if
73        
74        rst.MoveNext
75    Loop
76
77    set rst = Nothing
78    cnSrc.close
79    objLogFile.Close
80    Wscript.Sleep CycleTime*1000*60
81WEnd

FG_TR_MessageQueue
 1 IF EXISTS (SELECT name 
 2        FROM   sysobjects 
 3        WHERE  name = N'FG_TR_MessageQueue' 
 4        AND       type = 'TR')
 5     DROP TRIGGER FG_TR_MessageQueue
 6 GO
 7 
 8 CREATE TRIGGER FG_TR_MessageQueue
 9 ON CFWiTodo
10 AFTER INSERT
11 AS 
12 /***********************************************
13 Author: 碟子 http://cancelpj.cnblogs.com/
14 Date: 2008-02-17
15 Description: 当Excel服务器产生新的工作流待办事宜时，
16     将信息发送到RTX消息队列。
17 ***********************************************/
18 BEGIN
19 
20 DECLARE   @Receiver   VarChar(20)  
21 DECLARE   @MsgInfo   VarChar(500)  
22   
23 --获取接收人的RTX号，以及待发送的消息内容。
24 SELECT @Receiver = u.MobilePhone,
25 /**
26     p.pName+'_'+t.tName as [任务],
27     case wi.state1
28     when 2
29         then isnull(wi.untreadName,wi.creByName)
30     else wi.creByName
31     end as [交办人],
32     convert(smalldatetime,case wi.state1
33     when 2
34         then isnull(wi.UntreadTime,wi.creDate)
35     else wi.creDate 
36     end,120) as [交办时间],
37 **/
38     @MsgInfo = case wi.state1
39       when 1
40           then N'暂存：'
41       when 2
42           then N'被退回：'
43       else ''
44       end + '
45 任务：'+
46     p.pName+'_'+t.tName + '
47 交办人：'+
48     case wi.state1
49     when 2
50         then isnull(wi.untreadName,wi.creByName)
51     else wi.creByName
52     end + '
53 交办时间：'+
54     convert(nvarchar,case wi.state1
55     when 2
56         then isnull(wi.UntreadTime,wi.creDate)
57     else wi.creDate 
58     end,120)
59     -- + wi.wiDesc
60 FROM CFWorkitems wi, CFTasks t, CFwiTodo a, CFProcesses p, Users u, Inserted i 
61 WHERE u.UserID = a.userId and wi.wiId = a.wiId --and wi.tId=t.tId and wi.pId=p.pId 
62     and t.tType<>3 and wi.state =0 and a.userId = i.userId
63 ORDER BY (case wi.state1 when 2 then isnull(wi.Untreadtime,wi.creDate) else wi.creDate end) desc 
64 
65 
66 --由于ES本身在存储表单数据的过程中使用了事务，再在触发器中操作远程数据库就会引起【嵌套事务】。
67 --以上是个人猜测，未经证实；以下是针对“无法在此会话中启动更多的事务”的解决方法。
68 --用于 SQL Server 的 Microsoft OLE DB 提供程序不支持嵌套事务。
69 --因此，对于隐性或显式事务的内部数据修改操作和分布式分区视图上的数据修改操作，
70 --应将 XACT_ABORT 设置为 ON。
71 SET XACT_ABORT ON
72 
73 --用触发器修改远程数据的两种方式。
74 --方式一：较安全，配置较复杂。
75 --    需要在源数据库服务器建立一个指向目标服务器的链接服务器，
76 --    登陆方式保存在链接服务器中，不会在触发器中显示，比较安全。
77 /**
78 INSERT INTO [RTX数据库地址].RTX.dbo.Msg_Queue(Receiver,Title,MsgInfo) 
79     VALUES(@Receiver,'Excel服务器消息提醒',@MsgInfo)   
80 **/
81 --方式二：不安全，无需另外配置。
82 INSERT INTO OPENDATASOURCE('SQLOLEDB','Data Source=RTX数据库地址;User ID=rtx;Password=rtx'
83     ).RTX.dbo.Msg_Queue(Receiver,Title,MsgInfo) 
84     VALUES(@Receiver,'消息提醒','Excel服务器消息提醒
85 '+@MsgInfo)   
86 
87 END
88 
89 GO
90 
91 --设置该触发器为最后执行
92 EXEC sp_settriggerorder 'FG_TR_MessageQueue','Last','Insert'