DIRCh*_*ן]h*_*ן]H$ %BITq* README.mdh h Ig} 1A6opom.xmlhi:~hi:~[1{Wc\--}hsrc/lib/common-1.3.8.jarh h \+/ zFR4 K&wsrc/lib/sdk-1.3.8.jarh*_+`h*_+` su+y9-Ԙ=src/main/java/com/bcxin/message/MessageCenterApplication.javah9a*qh9a*q "ܑ/.S6src/main/java/com/bcxin/message/ascept/AuthAspect.javah h  u0C]` 0/n%:src/main/java/com/bcxin/message/common/CommonConstant.javah h  %/W@ # Esrc/main/java/com/bcxin/message/common/emus/MsgGroupCreateStatus.javahxO/hxO/ &*üd .lEsrc/main/java/com/bcxin/message/common/emus/MsgSendRequestStatus.javahxO/hxO/ KeB*E"!/ A3>src/main/java/com/bcxin/message/common/emus/MsgSendSource.javah9a*qh9a*q  DWnLUJsrc/main/java/com/bcxin/message/common/emus/MsgSyncTimeTaskStatusEnum.javah*_+`h*_+` $ )x𢩜MKua;src/main/java/com/bcxin/message/common/emus/StatusCode.javah*_+`h*_+` wK=Y'J>Nsrc/main/java/com/bcxin/message/common/exception/AbstractRuntimeException.javah*_+`h*_+` BI)~̡ndhEsrc/main/java/com/bcxin/message/common/exception/AssertException.javah9a*qh9a*q IeB! "'=Lsrc/main/java/com/bcxin/message/common/exception/GlobalExceptionHandler.javah*_+p6h*_+p6 1H78ƷI8Esrc/main/java/com/bcxin/message/common/exception/RemoteException.javah*_+p6h*_+p6 `&;70x*ގ6w /Csrc/main/java/com/bcxin/message/common/exception/TaskException.javah*_+p6h*_+p6 ufm?eODsrc/main/java/com/bcxin/message/common/exception/TokenException.javah*_+p6h*_+p6 $2-|HVFnHsrc/main/java/com/bcxin/message/common/exception/ValidatedException.javah*_+p6h*_+p6 CpJ78o1.=src/main/java/com/bcxin/message/common/utils/AssertUtils.javahxO/hxO/ tS/Drgu/aYްsrc/main/java/com/bcxin/message/configs/MybatisPlusConfig.javah*_+p6h*_+p6 4rUt)S8src/main/java/com/bcxin/message/configs/RedisConfig.javah*_+p6h*_+p6 'd佟~X`1]QYt;src/main/java/com/bcxin/message/configs/RedissonConfig.javah9a*&(h9a*&( iV47v>'Esrc/main/java/com/bcxin/message/configs/ScheduleThreadPoolConfig.javah9a*&(h9a*&( >F3*2l0R@~^WCsrc/main/java/com/bcxin/message/configs/TenantDataSourceConfig.javah*_+p6h*_+p6 `ђ\UK&=src/main/java/com/bcxin/message/configs/ThreadPoolConfig.javah9a*&(h9a*&( ;+WOfCdP<Bsrc/main/java/com/bcxin/message/configs/YehuoDataSourceConfig.javah h qvBevNصj)Isrc/main/java/com/bcxin/message/consumer/MsgGroupCreateKafkaConsumer.javahQhQ4}4>7hIsrc/main/java/com/bcxin/message/consumer/MsgSendRequestKafkaConsumer.javah9a*&(h9a*&( @lS뜽߅ҠS=xEsrc/main/java/com/bcxin/message/controller/SendMessageController.javah9a*&(h9a*&( [ O,hn;-TUYFsrc/main/java/com/bcxin/message/controller/YehuoManagerController.javah9a*hnh9a*hn sD*{(KMc[Psrc/main/java/com/bcxin/message/dao/mapper/messagecenter/MsgAdminUserMapper.javah9a*hnh9a*hn G[ࡗJkllVsrc/main/java/com/bcxin/message/dao/mapper/messagecenter/MsgAdminUserSenderMapper.javah9a*hnh9a*hn s]& ꪵZsPsrc/main/java/com/bcxin/message/dao/mapper/messagecenter/MsgExceptionMapper.javah9a*hnh9a*hn z`(FT7t}ʁCRsrc/main/java/com/bcxin/message/dao/mapper/messagecenter/MsgExpiredTimeMapper.javahQhQy8u;!ߐmҾ/^Rsrc/main/java/com/bcxin/message/dao/mapper/messagecenter/MsgGroupCreateMapper.javah9a*hnh9a*hn :sz +:[x#vWsrc/main/java/com/bcxin/message/dao/mapper/messagecenter/MsgOrgEffectiveTimeMapper.javah9a*hnh9a*hn v[!4;)یw̎Qsrc/main/java/com/bcxin/message/dao/mapper/messagecenter/MsgRequestLogMapper.javah9a*hnh9a*hn mʼ5)*UmH䞶Nsrc/main/java/com/bcxin/message/dao/mapper/messagecenter/MsgSendLogMapper.javah9a*hnh9a*hn y7tl$n2LRsrc/main/java/com/bcxin/message/dao/mapper/messagecenter/MsgSendRequestMapper.javah9a*hnh9a*hn |Fy"}(iJE\Ssrc/main/java/com/bcxin/message/dao/mapper/messagecenter/MsgSyncTimeTaskMapper.javah9a*hnh9a*hnֹ4{[ZLsrc/main/java/com/bcxin/message/dao/mapper/tenant/ExternalMembersMapper.javah9a*hnh9a*hnɷ"E@4jLsrc/main/java/com/bcxin/message/dao/mapper/tenant/TenantEmployeesMapper.javahQhQ"!G82j] Hsrc/main/java/com/bcxin/message/dao/mapper/tenant/TenantUsersMapper.javah9a*hnh9a*hn"U'b|cwBsrc/main/java/com/bcxin/message/dao/mapper/yehuo/TGroupMapper.javah9a*hnh9a*hn"Ӯpbʣ+0Esrc/main/java/com/bcxin/message/dao/mapper/yehuo/TMessagesMapper.javahQhQCP̘|IRsrc/main/java/com/bcxin/message/dtos/kafka/message/MsgGroupCreateKafkaMessage.javahxO/hxO/0-ۏU9KhD(34(SRsrc/main/java/com/bcxin/message/dtos/kafka/message/MsgSendRequestKafkaMessage.javahChCY_k嶤C.Psrc/main/java/com/bcxin/message/dtos/kafka/record/MsgGroupCreateKafkaRecord.javahChCڠS5hQf{YF|(Fsrc/main/java/com/bcxin/message/dtos/response/SendMessageResponse.javah*_+xeh*_+xe Z7y{AFDLsrc/main/java/com/bcxin/message/dtos/response/result/AbstractRespResult.javah*_+xeh*_+xe Cےl{%eIsrc/main/java/com/bcxin/message/dtos/response/result/ErrorRespResult.javah*_+xeh*_+xe 5E'(.JJsrc/main/java/com/bcxin/message/dtos/response/result/RespCursorResult.javah*_+xeh*_+xe 02#yDsrc/main/java/com/bcxin/message/dtos/response/result/RespResult.javahx^qhx^q01[h293<;(f>src/main/java/com/bcxin/message/dtos/yehuo/MessageContent.javah9a*hnh9a*hn0>)Zb2%,D#1&Asrc/main/java/com/bcxin/message/dtos/yehuo/TMessagesResponse.javah9a*hnh9a*hnJxɱlkԹOvMaLsrc/main/java/com/bcxin/message/entity/messagecenter/MsgAdminUserEntity.javah9a*hnh9a*hnJy\;)m(XɶO8Rsrc/main/java/com/bcxin/message/entity/messagecenter/MsgAdminUserSenderEntity.javah9a*hnh9a*hnJzY&vU7x/ H Lsrc/main/java/com/bcxin/message/entity/messagecenter/MsgExceptionEntity.javah9a*hnh9a*hnJ{U2@xnxc Nsrc/main/java/com/bcxin/message/entity/messagecenter/MsgExpiredTimeEntity.javahChC!f{KGAڶNsrc/main/java/com/bcxin/message/entity/messagecenter/MsgGroupCreateEntity.javah9a*hnh9a*hnJL즀&rPT? Y'7*Ssrc/main/java/com/bcxin/message/entity/messagecenter/MsgOrgEffectiveTimeEntity.javah9a*hnh9a*hnJ 63M98ӎ~)#Msrc/main/java/com/bcxin/message/entity/messagecenter/MsgRequestLogEntity.javah9a*h9a*L74(zrsH$Jsrc/main/java/com/bcxin/message/entity/messagecenter/MsgSendLogEntity.javah9a*h9a*L8-2VDv@0xԜR^Nsrc/main/java/com/bcxin/message/entity/messagecenter/MsgSendRequestEntity.javah9a*h9a*L9݊LY e`lU2KOsrc/main/java/com/bcxin/message/entity/messagecenter/MsgSyncTimeTaskEntity.javah9a*h9a*L;9iDe#XJs8 Hsrc/main/java/com/bcxin/message/entity/tenant/ExternalMembersEntity.javah9a*h9a*L<R.c QtSU ,¿ɰHsrc/main/java/com/bcxin/message/entity/tenant/TenantEmployeesEntity.javahChCQo ٔU6( S@3$Dsrc/main/java/com/bcxin/message/entity/tenant/TenantUsersEntity.javah9a*/Bh9a*/BQYВiF9o01En߄>src/main/java/com/bcxin/message/entity/yehuo/TGroupEntity.javah9a*/Bh9a*/BQZՍH4MaDRAsrc/main/java/com/bcxin/message/entity/yehuo/TMessagesEntity.javah*_+xeh*_+xe %2s=ּE{>iMsrc/main/java/com/bcxin/message/scheduled/config/DruidConnectionProvider.javah*_+xeh*_+xe ̜%" Ù`Bsrc/main/java/com/bcxin/message/scheduled/config/QuartzConfig.javah*_+xeh*_+xe tV31YAx;ȁoFsrc/main/java/com/bcxin/message/scheduled/config/QuartzJobFactory.javah9a*/Bh9a*/B tAspmZ~Csrc/main/java/com/bcxin/message/scheduled/message/SendRetryJob.javah9a*/Bh9a*/B Po2V\:ꔦc>Isrc/main/java/com/bcxin/message/scheduled/message/SendRetryScheduler.javah9a*/Bh9a*/BQ\ДLON*'Zc 6vIsrc/main/java/com/bcxin/message/scheduled/task/CreateMsgSyncTimeTask.javahhgfa|ü}Hsrc/main/java/com/bcxin/message/scheduled/task/DeleteExpiredMsgTask.javah9a*/Bh9a*/BQ^9Y" Zti3n=Csrc/main/java/com/bcxin/message/scheduled/task/SyncMsgTimeTask.javah*_+xeh*_+xe 99sbQ(D87src/main/java/com/bcxin/message/service/RedisCache.javah9a*/Bh9a*/B L<n˛\'eDH"9src/main/java/com/bcxin/message/service/YehuoService.javah9a*qh9a*q /<ŧ968IUITsrc/main/java/com/bcxin/message/service/messagecenter/MsgAdminUserSenderService.javah9a*qh9a*q=RđLnpIQZYh;9Nsrc/main/java/com/bcxin/message/service/messagecenter/MsgAdminUserService.javah9a*qh9a*q,*y.g!wXSqU'Nsrc/main/java/com/bcxin/message/service/messagecenter/MsgExceptionService.javahhM]@3>% q"Psrc/main/java/com/bcxin/message/service/messagecenter/MsgExpiredTimeService.javahʽ&#hʽ&# _^DIhoи=aPsrc/main/java/com/bcxin/message/service/messagecenter/MsgGroupCreateService.javah9a*qh9a*q oslpiOet"TUsrc/main/java/com/bcxin/message/service/messagecenter/MsgOrgEffectiveTimeService.javah9a*qh9a*q]>w*vֿI/z4Osrc/main/java/com/bcxin/message/service/messagecenter/MsgRequestLogService.javahh21dv™0Lsrc/main/java/com/bcxin/message/service/messagecenter/MsgSendLogService.javah9a*qh9a*qZ0IKLw H\Psrc/main/java/com/bcxin/message/service/messagecenter/MsgSendRequestService.javah9a*qh9a*q+M{!l}Q~Rs9Qsrc/main/java/com/bcxin/message/service/messagecenter/MsgSyncTimeTaskService.javah9a*qh9a*qu[JG+WtܲL]6Jsrc/main/java/com/bcxin/message/service/tenant/ExternalMembersService.javah9a*qh9a*q^M;MXmz PQJsrc/main/java/com/bcxin/message/service/tenant/TenantEmployeesService.javahhﮙAo n9L@yFsrc/main/java/com/bcxin/message/service/tenant/TenantUsersService.javah9a*h9a*:ݵ7:]`m^@src/main/java/com/bcxin/message/service/yehuo/TGroupService.javah9a*h9a*: pH侲}%'}5X. OCsrc/main/java/com/bcxin/message/service/yehuo/TMessagesService.javah*_+xeh*_+xe [{ا' %q"JaľIsrc/main/java/com/bcxin/message/strategy/message/SendMessageStrategy.javahx^qhx^q  '8=h<Psrc/main/java/com/bcxin/message/strategy/message/SendMessageStrategyFactory.javah9a*8\h9a*8\04 $O ^? pqAMsrc/main/java/com/bcxin/message/strategy/message/impl/ChannelSendTextMsg.javah9a*8\h9a*8\05TGZ"b؅hZB\Ksrc/main/java/com/bcxin/message/strategy/message/impl/RobotSendLinkMsg.javah9a*8\h9a*8\06UkI&>ĸhCBMsrc/main/java/com/bcxin/message/strategy/message/impl/RobotSendNoticeMsg.javah9a*8\h9a*8\08 4QxתG,{=NG0ƨKsrc/main/java/com/bcxin/message/strategy/message/impl/RobotSendTextMsg.javah9a*8\h9a*8\0<n]+\y䃵&src/main/resources/application-dev.ymlh$h$ V[Qm/Nم'src/main/resources/application-prod.ymlh$h$r>bR;{W)'src/main/resources/application-test.ymlh*_+h*_+Jt`&kgY?@+z?"src/main/resources/application.ymlh$h$a0vaњr%src/main/resources/logback-spring.xmlh9a+h9a+ ~p sH|q/yKi?src/main/resources/mybatis/messagecenter/MsgAdminUserMapper.xmlh9a+h9a+ r#NoLfEsrc/main/resources/mybatis/messagecenter/MsgAdminUserSenderMapper.xmlh9a+h9a+ +.d!5! `m?src/main/resources/mybatis/messagecenter/MsgExceptionMapper.xmlh9a+h9a+ KH &;MnӅ,gAsrc/main/resources/mybatis/messagecenter/MsgExpiredTimeMapper.xmlh kh kZC:UEkuYZʚ&Asrc/main/resources/mybatis/messagecenter/MsgGroupCreateMapper.xmlh9a+h9a+ ZMKD2#WpˡԝFsrc/main/resources/mybatis/messagecenter/MsgOrgEffectiveTimeMapper.xmlh9a+h9a+ jH.,#WٮۭV;C\&|@src/main/resources/mybatis/messagecenter/MsgRequestLogMapper.xmlh9a+h9a+ רw 8wOvkڛ%=src/main/resources/mybatis/messagecenter/MsgSendLogMapper.xmlh9a+h9a+ P̋lm{ZAsrc/main/resources/mybatis/messagecenter/MsgSendRequestMapper.xmlh9a+h9a+ ~p sH|q/yKiBsrc/main/resources/mybatis/messagecenter/MsgSyncTimeTaskMapper.xmlh9a+h9a+ Q:!J+/G))P;src/main/resources/mybatis/tenant/ExternalMembersMapper.xmlh9a+h9a+ "Pc֬NPw&;src/main/resources/mybatis/tenant/TenantEmployeesMapper.xmlh kh k顇8#Z&;՟(_y\7src/main/resources/mybatis/tenant/TenantUsersMapper.xmlh9a+h9a+ )~]@ wE1src/main/resources/mybatis/yehuo/TGroupMapper.xmlh9a+h9a+ (a/:W/|Ay4src/main/resources/mybatis/yehuo/TMessagesMapper.xmlh*_+h*_+J|"kqG{)G"(src/main/resources/quartz-dev.propertiesh*_+h*_+J}"kqG{)G")src/main/resources/quartz-test.propertiesTREE143 1 c/ SI;|src141 2 }YA0ʤ[64Qlib2 0 iF?"ݔ,5 main139 2 1 q:F;ejava117 1 ߇Lk)f|ӱa6com117 1 oo.D<9څbcxin117 1 .,0P!=q8)imessage117 11 dm΂Wuב+]dao15 1 ]9^~?9wmapper15 3 H>0iKm@ yehuo2 0 N= P4IOtenant3 0 {&)!Ujmessagecenter10 0 !_ fidtos16 4 %UBb9jkafka4 2 ɔG*kbho3record2 0 l.0!N`W#;message2 0 mA!rF7yehuo2 0 ݰB8 큋request4 0 =羚#ݣH;B켟response6 1 Jw)w c1\result4 0 gxq%Y~<Sascept1 0 !GT42ʺ®jcommon21 3 vf}@uȷ\emus5 0 J$3g p*Q#utils8 0 -rgv# @R0y'J7exception7 0 Ŭ^ZC:Z:]]ƹentity15 3 yj!cu?wyehuo2 0 \ZSE +=e9mytenant3 0 ~XD}R5WV6Klmessagecenter10 0 5^o>)Ւ!configs13 0 M[+=&\Lfzservice17 3 2Y=&ȣivC`wϕkyehuo2 0 yT52&c=wVU\\tenant3 0 h\bIoNJ[AImessagecenter10 0 6  MlZ#4consumer2 0 ӁQz_QJ=˯strategy6 1 mybatis15 3 ӑZKz؉S0yehuo2 0 }]\ ؉tenant3 0 '7vr%_2 ?XLmessagecenter10 0 YhmZ;m\:,mZ ~͸YP