[ARX 程序]：数据库反应器（database reactor）

bobofu

1. 
   
2. #include "rxobject.h"
   
3. #include "rxregsvc.h"
   
4. #include "rxdlinkr.h"
   
5. #include "rxditer.h"
   
6. #include "aced.h"
   
7. #include "dbmain.h"
   
8. #include "dbdict.h"
   
9. #include "dbidmap.h"
   
10. #include "dbapserv.h"
    
11. #include "adslib.h"
    
12. 
    
13. void printDbEvent(const AcDbObject*, const char* eventStr);
    
14. void printObj(const AcDbObject* pObj);
    
15. void watchDb();
    
16. void clearReactors();
    
17. extern "C"
    
18. AcRx::AppRetCode acrxEntryPoint(AcRx::AppMsgCode, void*);
    
19. 
    
20. class MyDbReactor;
    
21. 
    
22. long gEntAcc = 0;
    
23. MyDbReactor *gpDbr = NULL;
    
24. 
    
25. class MyDbReactor : public AcDbDatabaseReactor
    
26. {
    
27. public:
    
28. 
    
29.     virtual void objectAppended(const AcDbDatabase* dwg,
    
30.         const AcDbObject* dbObj);
    
31. 
    
32.     virtual void objectModified(const AcDbDatabase* dwg,
    
33.         const AcDbObject* dbObj);
    
34. 
    
35.     virtual void objectErased(const AcDbDatabase* dwg,
    
36.         const AcDbObject* dbObj, Adesk::Boolean pErased);
    
37. };
    
38. 
    
39. 
    
40. void
    
41. MyDbReactor::objectAppended(const AcDbDatabase* db,
    
42.     const AcDbObject* pObj)
    
43. {
    
44.     printDbEvent(pObj, "objectAppended");
    
45.     acutPrintf(" Db==%lx\n", (long) db);
    
46.     gEntAcc++;
    
47.     acutPrintf("Entity Count = %d\n", gEntAcc);
    
48. }
    
49. 
    
50. 
    
51. void
    
52. MyDbReactor::objectModified(const AcDbDatabase* db,
    
53.     const AcDbObject* pObj)
    
54. {
    
55.     printDbEvent(pObj, "objectModified");
    
56.     acutPrintf(" Db==%lx\n", (long) db);
    
57. }
    
58. 
    
59. void
    
60. MyDbReactor::objectErased(const AcDbDatabase* db,
    
61.     const AcDbObject* pObj, Adesk::Boolean pErased)
    
62. {
    
63.     if (pErased) {
    
64.         printDbEvent(pObj, "objectErased");
    
65.         gEntAcc--;
    
66.     } else {
    
67.         printDbEvent(pObj, "object(Un)erased");
    
68.         gEntAcc++;
    
69.     }
    
70.     acutPrintf(" Db==%lx\n", (long) db);
    
71.     acutPrintf("Entity Count = %d\n", gEntAcc);
    
72. }
    
73. 
    
74. 
    
75. void
    
76. printDbEvent(const AcDbObject* pObj, const char* pEvent)
    
77. {
    
78.     acutPrintf("  Event: AcDbDatabaseReactor::%s ", pEvent);
    
79.     printObj(pObj);
    
80. }
    
81. 
    
82. 
    
83. void
    
84. printObj(const AcDbObject* pObj)
    
85. {
    
86.     if (pObj == NULL) {
    
87.         acutPrintf("(NULL)");
    
88.         return;
    
89.     }
    
90. 
    
91.     AcDbHandle objHand;
    
92.     char  handbuf[17];
    
93. 
    
94.     pObj->getAcDbHandle(objHand);
    
95.     objHand.getIntoAsciiBuffer(handbuf);
    
96. 
    
97.     acutPrintf(
    
98.         "\n   (class==%s, handle==%s, id==%lx, db==%lx)",
    
99.         pObj->isA()->name(), handbuf,
    
100.         pObj->objectId().asOldId(), pObj->database());
     
101. }
     
102. 
     
103. 
     
104. void
     
105. watchDb()
     
106. {
     
107.     if (gpDbr == NULL) {
     
108.         gpDbr = new MyDbReactor();
     
109.     }
     
110.     acdbHostApplicationServices()->workingDatabase()->addReactor(gpDbr);
     
111.     acutPrintf(
     
112.         "  Added Database Reactor to "
     
113.         "acdbHostApplicationServices()->workingDatabase().\n");
     
114. }
     
115. 
     
116. 
     
117. void
     
118. clearReactors()
     
119. {
     
120.     if (acdbHostApplicationServices()->workingDatabase() != NULL) {
     
121.         acdbHostApplicationServices()->workingDatabase()->removeReactor(gpDbr);
     
122.         delete gpDbr;
     
123.         gpDbr = NULL;
     
124.     }
     
125. }
     
126. 
     
127. AcRx::AppRetCode
     
128. acrxEntryPoint(AcRx::AppMsgCode msg, void* appId)
     
129. {
     
130.     switch (msg) {
     
131.     case AcRx::kInitAppMsg:
     
132.         acrxDynamicLinker->unlockApplication(appId);
     
133.                 acrxDynamicLinker->registerAppNotMDIAware(appId);
     
134.         acedRegCmds->addCommand("EXAM10A",
     
135.             "WATCH",
     
136.             "WATCH",
     
137.             ACRX_CMD_TRANSPARENT,
     
138.             watchDb);
     
139. 
     
140.         acedRegCmds->addCommand("EXAM10A",
     
141.             "CLEAR",
     
142.             "CLEAR",
     
143.             ACRX_CMD_TRANSPARENT,
     
144.             clearReactors);
     
145.         break;
     
146.     case AcRx::kUnloadAppMsg:
     
147.         clearReactors();
     
148.         acedRegCmds->removeGroup("EXAM10A");
     
149.         break;
     
150.     }
     
151.     return AcRx::kRetOK;
     
152. }
     

复制代码