lilytalk.py

   1 #!/usr/bin/env python2
   2 # vim:fileencoding=utf-8
   3
   4 import re
   5 import logging
   6 import datetime
   7
   8 from google.appengine.ext import db
   9 from google.appengine.api import xmpp
  10
  11 import utils
  12 import config
  13
  14 notice = u'这是一个测试群'
  15 helpre = re.compile(r'^\W{0,2}help$')
  16
  17 #用户所有资源离线时，会加上“完全”二字
  18 OFFLINE = u'离线'
  19 AWAY    = u'离开'
  20 XAWAY   = u'离开'
  21 BUSY    = u'忙碌'
  22 ONLINE  = u'在线'
  23 CHAT    = u'和我说话吧'
  24
  25 NEW        = u'加入'
  26 LEAVE      = u'退出'
  27 NICK       = u'昵称更改 (%s -> %s)'
  28 SNOOZE     = u'snooze %ds'
  29 BLACK      = u'禁言 %s %ds'
  30 BLACK_AUTO = u'被禁言 %ds'
  31 KICK       = u'删除 %s (%s)'
  32 ADMIN      = u'%s 成为管理员 (by %s)'
  33 UNADMIN    = u'%s 不再是管理员 (by %s)'
  34
  35 STATUS_CODE = {
  36   '':     ONLINE,
  37   'away': AWAY,
  38   'dnd':  BUSY,
  39   'xa':   XAWAY,
  40   'chat': CHAT,
  41 }
  42
  43 #状态的排序顺序
  44 STATUS_LIST = [CHAT, ONLINE, AWAY, XAWAY, BUSY, OFFLINE]
  45
  46 timezone = datetime.timedelta(hours=config.timezoneoffset)
  47
  48 class User(db.Model):
  49   jid = db.StringProperty(required=True, indexed=True)
  50   nick = db.StringProperty(required=True, indexed=True)
  51
  52   add_date = db.DateTimeProperty(auto_now_add=True)
  53   last_online_date = db.DateTimeProperty()
  54   last_offline_date = db.DateTimeProperty()
  55   last_speak_date = db.DateTimeProperty()
  56
  57   msg_count = db.IntegerProperty(required=True, default=0)
  58   msg_chars = db.IntegerProperty(required=True, default=0)
  59   credit = db.IntegerProperty(required=True, default=0)
  60
  61   black_before = db.DateTimeProperty(auto_now_add=True)
  62   snooze_before = db.DateTimeProperty()
  63   flooding_point = db.IntegerProperty(default=0)
  64
  65   avail = db.StringProperty(required=True)
  66   is_admin = db.BooleanProperty(required=True, default=False)
  67   resources = db.StringListProperty(required=True)
  68   #允许他人私信？
  69   reject_pm = db.BooleanProperty(default=False)
  70
  71   prefix = db.StringProperty(required=True, default=config.default_prefix)
  72   nick_pattern = db.StringProperty(required=True, default='[%s]')
  73   nick_changed = db.BooleanProperty(required=True, default=False)
  74   intro = db.StringProperty()
  75
  76 class Log(db.Model):
  77   time = db.DateTimeProperty(auto_now_add=True, indexed=True)
  78   msg = db.StringProperty(required=True, multiline=True)
  79   jid = db.StringProperty()
  80   nick = db.StringProperty()
  81   type = db.StringProperty(required=True, indexed=True,
  82                            choices=set(['chat', 'member', 'misc']))
  83
  84 def log_msg(sender, msg):
  85   l = Log(jid=sender.jid, nick=sender.nick,
  86           type='chat', msg=msg)
  87   l.put()
  88
  89 def log_onoff(sender, action, resource=''):
  90   if resource:
  91     if action == OFFLINE and not sender.resources:
  92       msg = u'完全%s (%s)' % (action, resource)
  93     else:
  94       msg = '%s (%s)' % (action, resource)
  95   else:
  96     msg = action
  97   l = Log(jid=sender.jid, nick=sender.nick,
  98           type='member', msg=msg)
  99   l.put()
 100
 101 def get_user_by_jid(jid):
 102   return User.gql('where jid = :1', jid.lower()).get()
 103
 104 def get_user_by_nick(nick):
 105   return User.gql('where nick = :1', nick).get()
 106
 107 def get_member_list():
 108   r = []
 109   now = datetime.datetime.now()
 110   #一个查询中最多只能有一个不等比较
 111   l = User.gql('where avail != :1', OFFLINE)
 112   for u in l:
 113     r.append(u)
 114   return [unicode(x.jid) for x in r \
 115           if x.snooze_before is None or x.snooze_before < now]
 116
 117 def send_to_all_except(jid, message):
 118   if isinstance(jid, str):
 119     jids = [x for x in get_member_list() if x != jid]
 120   else:
 121     jids = [x for x in get_member_list() if x not in jid]
 122   logging.debug(jid)
 123   logging.debug(jids)
 124   try:
 125     xmpp.send_message(jids, message)
 126   except xmpp.InvalidJidError:
 127     pass
 128
 129 def send_to_all(message):
 130   jids = get_member_list()
 131   xmpp.send_message(jids, message)
 132
 133 def handle_message(msg):
 134   sender = get_user_by_jid(msg.sender.split('/')[0])
 135   if sender is None:
 136     msg.reply('很抱歉，出错了，请重新添加好友。')
 137     return
 138   if msg.body.startswith('?OTR:'):
 139     msg.reply('不支持 OTR 加密！')
 140     return
 141   if len(msg.body) > 500:
 142     msg.reply('由于技术限制，每条消息最长为 500 字。大段文本请贴 paste 网站。')
 143     return
 144   if sender.is_admin or sender.jid == config.root:
 145     ch = AdminCommand(msg, sender)
 146   else:
 147     ch = BasicCommand(msg, sender)
 148   if not ch.handled:
 149     now = datetime.datetime.now()
 150     if sender.black_before is not None \
 151        and sender.black_before > now:
 152       if (datetime.datetime.today()+timezone).date() == \
 153          (sender.black_before+timezone).date():
 154         format = '%H时%M分%S秒'
 155       else:
 156         format = '%m月%d日 %H时%M分%S秒'
 157       msg.reply('你已被禁言至 ' \
 158                 + (sender.black_before+timezone).strftime(format))
 159       return
 160
 161     if sender.last_speak_date is not None:
 162       d = now - sender.last_speak_date
 163       t = d.seconds
 164       if d.days > 0 or t > 60:
 165         sender.flooding_point = 0
 166       else:
 167         k = 1000 / (t * t + 1)
 168         if k > 0:
 169           sender.flooding_point += k
 170         else:
 171           sender.flooding_point = 0
 172
 173         k = sender.flooding_point / 1500
 174         if k > 0:
 175           msg.reply('刷屏啊？禁言 %d 分钟！' % k)
 176           send_to_all_except(sender.jid,
 177             (u'%s 已因刷屏而被禁言 %d 分钟。' % (sender.nick, k)) \
 178                                   .encode('utf-8'))
 179           log_onoff(sender, BLACK_AUTO % (60 * k))
 180           sender.black_before = now + datetime.timedelta(seconds=60*k)
 181           sender.put()
 182           return
 183
 184     sender.last_speak_date = now
 185     sender.snooze_before = None
 186     try:
 187       sender.msg_count += 1
 188       sender.msg_chars += len(msg.body)
 189     except TypeError:
 190       sender.msg_count = 1
 191       sender.msg_chars = len(msg.body)
 192     sender.put()
 193     body = utils.removelinks(msg.body)
 194     for u in User.gql('where avail != :1', OFFLINE):
 195       if u.snooze_before is not None and u.snooze_before >= now:
 196         continue
 197       if u.jid == sender.jid:
 198         continue
 199       try:
 200         message = '%s %s' % (
 201           u.nick_pattern % sender.nick,
 202           body
 203         )
 204         xmpp.send_message(u.jid, message)
 205       except xmpp.InvalidJidError:
 206         pass
 207     log_msg(sender, msg.body)
 208
 209 def try_add_user(jid, show=OFFLINE, resource=''):
 210   '''使用 memcache 作为锁添加用户'''
 211   L = utils.MemLock('add_user')
 212   L.require()
 213   try:
 214     u = get_user_by_jid(jid)
 215     if u is not None:
 216       return
 217     u = add_user(jid, show, resource)
 218   finally:
 219     L.release()
 220   if show != OFFLINE:
 221     log_onoff(u, show, resource)
 222   logging.info(u'%s added', jid)
 223
 224 def add_user(jid, show=OFFLINE, resource=''):
 225   '''resource 在 presence type 为 available 里使用'''
 226   nick = jid.split('@')[0]
 227   old = get_user_by_nick(nick)
 228   while old:
 229     nick += '_'
 230     old = get_user_by_nick(nick)
 231   u = User(jid=jid.lower(), avail=show, nick=nick)
 232   if show != OFFLINE:
 233     u.last_online_date = datetime.datetime.now()
 234   if resource:
 235     u.resources.append(resource)
 236   u.put()
 237   log_onoff(u, NEW)
 238   logging.info(u'%s 已经加入' % jid)
 239   send_to_all_except(jid, u'%s 已经加入' % u.nick)
 240   xmpp.send_presence(jid, status=notice)
 241   xmpp.send_message(jid, u'欢迎 %s 加入！获取使用帮助，请输入 %shelp' % (
 242     u.nick, u.prefix))
 243   return u
 244
 245 class BasicCommand:
 246   handled = True
 247   def __init__(self, msg, sender):
 248     self.sender = sender
 249     self.msg = msg
 250
 251     if helpre.match(msg.body):
 252       self.do_help()
 253     elif msg.body.startswith(sender.prefix):
 254       cmd = msg.body[len(sender.prefix):].split()
 255       try:
 256         handle = getattr(self, 'do_' + cmd[0])
 257       except AttributeError:
 258         msg.reply(u'错误：未知命令 %s' % cmd[0])
 259       except IndexError:
 260         msg.reply(u'错误：无命令')
 261       except UnicodeEncodeError:
 262         msg.reply(u'错误：命令名解码失败。此问题在 GAE 升级其 Python 到 3.x 后方能解决。')
 263       else:
 264         handle(cmd[1:])
 265         logging.debug('%s did command %s' % (sender.jid, cmd[0]))
 266     else:
 267       self.handled = False
 268
 269   def do_online(self, args):
 270     '''在线成员列表'''
 271     r = []
 272     now = datetime.datetime.now()
 273     l = User.gql('where avail != :1', OFFLINE)
 274     for u in l:
 275       m = u.nick
 276       status = u.avail
 277       if status != u'在线':
 278         m += u' (%s)' % status
 279       if u.snooze_before is not None and u.snooze_before > now:
 280         m += u' (snoozing)'
 281       if u.black_before is not None and u.black_before > now:
 282         m += u' (已禁言)'
 283       r.append(unicode('* ' + m))
 284     r.sort()
 285     n = len(r)
 286     r.insert(0, u'在线成员列表:')
 287     r.append(u'共 %d 人在线。' % n)
 288     self.msg.reply(u'\n'.join(r).encode('utf-8'))
 289
 290   def do_lsadmin(self, args):
 291     '''管理员列表'''
 292     r = []
 293     now = datetime.datetime.now()
 294     l = User.gql('where is_admin = :1', True)
 295     for u in l:
 296       m = u.nick
 297       status = u.avail
 298       if status != u'在线':
 299         m += u' (%s)' % status
 300       if u.snooze_before is not None and u.snooze_before > now:
 301         m += u' (snoozing)'
 302       if u.black_before is not None and u.black_before > now:
 303         m += u' (已禁言)'
 304       r.append(unicode('* ' + m))
 305     r.sort()
 306     n = len(r)
 307     r.insert(0, u'管理员列表:')
 308     r.append(u'共 %d 位管理员。' % n)
 309     self.msg.reply(u'\n'.join(r).encode('utf-8'))
 310
 311   def do_chatty(self, args):
 312     '''消息数排行'''
 313     r = []
 314     for u in User.gql('ORDER BY msg_chars ASC'):
 315       m = u.nick
 316       m = u'* %s:\t%5d条，共 %s' % (
 317         u.nick, u.msg_count,
 318         utils.filesize(u.msg_chars))
 319       r.append(m)
 320     n = len(r)
 321     r.insert(0, u'消息数量排行:')
 322     r.append(u'共 %d 人。' % n)
 323     self.msg.reply(u'\n'.join(r).encode('utf-8'))
 324
 325   def do_nick(self, args):
 326     '''更改昵称，需要一个参数，不能使用大部分标点符号'''
 327     if len(args) != 1:
 328       self.msg.reply('错误：请给出你想到的昵称（不能包含空格）')
 329       return
 330
 331     q = get_user_by_nick(args[0])
 332     if q is not None:
 333       self.msg.reply('错误：该昵称已被使用，请使用其它昵称')
 334     elif not utils.checkNick(args[0]):
 335       self.msg.reply('错误：非法的昵称')
 336     else:
 337       if not config.nick_can_change and self.sender.nick_changed:
 338         self.msg.reply('乖哦，你已经没机会再改昵称了')
 339         return
 340       old_nick = self.sender.nick
 341       log_onoff(self.sender, NICK % (old_nick, args[0]))
 342       self.sender.nick = args[0]
 343       self.sender.nick_changed = True
 344       self.sender.put()
 345       send_to_all_except(self.sender.jid,
 346         (u'%s 的昵称改成了 %s' % (old_nick, args[0])).encode('utf-8'))
 347       self.msg.reply('昵称更改成功！')
 348   do_nick.__doc__ += '，最长 %d 字节' % config.nick_maxlen
 349
 350   def do_whois(self, args):
 351     '''查看用户信息，参数为用户昵称'''
 352     if len(args) != 1:
 353       self.msg.reply('错误：你想知道关于谁的信息？')
 354       return
 355
 356     u = get_user_by_nick(args[0])
 357     if u is None:
 358       self.msg.reply(u'Sorry，查无此人。')
 359       return
 360
 361     now = datetime.datetime.now()
 362     status = u.avail
 363     addtime = (u.add_date + timezone).strftime('%Y年%m月%d日 %H时%M分').decode('utf-8')
 364     allowpm = u'否' if u.reject_pm else u'是'
 365     if u.snooze_before is not None and u.snooze_before > now:
 366       status += u' (snoozing)'
 367     if u.black_before is not None and u.black_before > now:
 368       status += u' (已禁言)'
 369     r = u'昵称：\t\t%s\n状态：\t\t%s\n消息数：\t\t%d\n消息总量：\t%s\n加入时间：\t%s\n接受私信：\t%s\n自我介绍：\t%s' % (
 370       u.nick, status, u.msg_count, utils.filesize(u.msg_chars), addtime,
 371       allowpm, u.intro)
 372     self.msg.reply(r.encode('utf-8'))
 373
 374   def do_help(self, args=()):
 375     '''显示本帮助。参数 long 显示详细帮助，也可指定命令名。'''
 376     doc = []
 377     prefix = self.sender.prefix
 378
 379     if len(args) > 1:
 380       self.msg.reply('参数错误。')
 381       return
 382     arg = args[0] if args else None
 383
 384     if arg is None or arg == 'long':
 385       for b in self.__class__.__bases__ + (self.__class__,):
 386         for c, f in b.__dict__.items():
 387           if c.startswith('do_'):
 388             if arg is None:
 389               doc.append(u'%s%s:\t%s' % (prefix, c[3:], f.__doc__.decode('utf-8').split(u'，', 1)[0].split(u'。', 1)[0]))
 390             else:
 391               doc.append(u'%s%s:\t%s' % (prefix, c[3:], f.__doc__.decode('utf-8')))
 392       doc.sort()
 393       if arg is None:
 394         doc.insert(0, u'** 命令指南 **\n(当前命令前缀 %s，可设置。使用参数 long 显示详细帮助)' % prefix)
 395       else:
 396         doc.insert(0, u'** 命令指南 **\n(当前命令前缀 %s，可设置)' % prefix)
 397       doc.append(u'要离开，直接删掉好友即可。')
 398       self.msg.reply(u'\n'.join(doc).encode('utf-8'))
 399     else:
 400       try:
 401         handle = getattr(self, 'do_' + arg)
 402       except AttributeError:
 403         self.msg.reply(u'错误：未知命令 %s' % arg)
 404       except UnicodeEncodeError:
 405         self.msg.reply(u'错误：命令名解码失败。此问题在 GAE 升级其 Python 到 3.x 后方能解决。')
 406       else:
 407         self.msg.reply(u'%s%s:\t%s' % (prefix, arg, handle.__doc__.decode('utf-8')))
 408
 409   def do_iam(self, args):
 410     '''查看自己的信息'''
 411     u = self.sender
 412     addtime = (u.add_date + timezone).strftime('%Y年%m月%d日 %H时%M分').decode('utf-8')
 413     allowpm = u'否' if u.reject_pm else u'是'
 414     r = u'昵称：\t\t%s\nJID：\t\t%s\n消息数：\t\t%d\n消息总量：\t%s\n加入时间：\t%s\n接受私信：\t%s\n命令前缀：\t%s\n自我介绍：\t%s' % (
 415       u.nick, u.jid, u.msg_count, utils.filesize(u.msg_chars), addtime,
 416       allowpm, u.prefix, u.intro)
 417     self.msg.reply(r.encode('utf-8'))
 418
 419   def do_m(self, args):
 420     '''发私信，需要昵称和内容两个参数。私信不会以任何方式被记录。'''
 421     if len(args) < 2:
 422       self.msg.reply('请给出昵称和内容。')
 423       return
 424
 425     target = get_user_by_nick(args[0])
 426     if target is None:
 427       self.msg.reply('Sorry，查无此人。')
 428       return
 429
 430     if target.reject_pm:
 431       self.msg.reply('很抱歉，对方不接受私信。')
 432       return
 433
 434     msg = self.msg.body[len(self.sender.prefix):].split(None, 2)[-1]
 435     msg = u'_私信_ %s %s' % (target.nick_pattern % self.sender.nick, msg)
 436     if xmpp.send_message(target.jid, msg) == xmpp.NO_ERROR:
 437       self.msg.reply(u'OK')
 438     else:
 439       self.msg.reply(u'消息发送失败')
 440
 441   def do_intro(self, arg):
 442     '''设置自我介绍信息'''
 443     if not arg:
 444       self.msg.reply('请给出自我介绍的内容。')
 445       return
 446
 447     msg = self.msg.body[len(self.sender.prefix):].split(None, 1)[-1]
 448     u = self.sender
 449     try:
 450       u.intro = msg
 451     except db.BadValueError:
 452       # 过长文本已在 handle_message 中被拦截
 453       self.msg.reply('错误：自我介绍内容只能为一行。')
 454       return
 455
 456     u.put()
 457     send_to_all_except(u.jid,
 458       (u'%s 的新自我介绍：%s' % (u.nick, msg)).encode('utf-8'))
 459     self.msg.reply(u'设置成功！')
 460
 461   def do_snooze(self, args):
 462     '''暂停接收消息，参数为时间（默认单位为秒）。再次发送消息时自动清除'''
 463     if len(args) != 1:
 464       self.msg.reply('你想停止接收消息多久？')
 465       return
 466     else:
 467       try:
 468         n = utils.parseTime(args[0])
 469       except ValueError:
 470         self.msg.reply('Sorry，我无法理解你说的时间。')
 471         return
 472
 473     try:
 474       self.sender.snooze_before = datetime.datetime.now() + datetime.timedelta(seconds=n)
 475     except OverflowError:
 476       self.msg.reply('Sorry，你不能睡太久。')
 477       return
 478     self.sender.put()
 479     if n == 0:
 480       self.msg.reply('你已经醒来。')
 481     else:
 482       self.msg.reply('OK，停止接收消息 %d 秒。' % n)
 483     log_onoff(self.sender, SNOOZE % n)
 484
 485   def do_offline(self, args):
 486     '''假装离线，让程序认为你的所有资源已离线。如在你离线时程序仍认为你在线，请使用此命令。'''
 487     del self.sender.resources[:]
 488     self.sender.avail = OFFLINE
 489     self.sender.last_offline_date = datetime.datetime.now()
 490     self.sender.put()
 491     self.msg.reply('OK，在下次你说你在线之前我都认为你已离线。')
 492
 493   def do_old(self, args):
 494     '''聊天记录查询，可选一个数字参数。默认为最后20条。特殊参数 OFFLINE （不区分大小写）显示离线消息（最多 100 条）'''
 495     s = self.sender
 496     q = False
 497     if not args:
 498       q = Log.gql("WHERE type = 'chat' ORDER BY time DESC LIMIT 20")
 499     elif len(args) == 1:
 500       try:
 501         n = int(args[0])
 502         if n > 0:
 503           q = Log.gql("WHERE type = 'chat' ORDER BY time DESC LIMIT %d" % n)
 504       except ValueError:
 505         if args[0].upper() == 'OFFLINE':
 506           q = Log.gql("WHERE time < :1 AND time > :2 AND type = 'chat' ORDER BY time DESC LIMIT 100", s.last_online_date, s.last_offline_date)
 507         else:
 508           pass
 509     if q is not False:
 510       r = []
 511       q = list(q)
 512       q.reverse()
 513       if q:
 514         if datetime.datetime.today() - q[0].time > datetime.timedelta(hours=24):
 515           show_date = True
 516         else:
 517           show_date = False
 518       for l in q:
 519         message = '%s %s %s' % (
 520           utils.strftime(l.time, timezone, show_date),
 521           s.nick_pattern % l.nick,
 522           l.msg
 523         )
 524         r.append(message)
 525       if r:
 526         self.msg.reply(u'\n'.join(r).encode('utf-8'))
 527       else:
 528         self.msg.reply('没有符合的聊天记录。')
 529     else:
 530       self.msg.reply('Oops, 参数不正确哦。')
 531
 532   def do_set(self, args):
 533     '''设置参数。参数格式 key=value；不带参数以查看说明。'''
 534     #注意：选项名/值中不能包含空格
 535     if len(args) != 1:
 536       doc = []
 537       for c, f in self.__class__.__dict__.items():
 538         if c.startswith('set_'):
 539           doc.append(u'* %s:\t%s' % (c[4:], f.__doc__.decode('utf-8')))
 540       for b in self.__class__.__bases__:
 541         for c, f in b.__dict__.items():
 542           if c.startswith('set_'):
 543             doc.append(u'* %s:\t%s' % (c[4:], f.__doc__.decode('utf-8')))
 544       doc.sort()
 545       doc.insert(0, u'设置选项：')
 546       self.msg.reply(u'\n'.join(doc).encode('utf-8'))
 547     else:
 548       msg = self.msg
 549       cmd = msg.body.split(None, 1)[1].split('=', 1)
 550       if len(cmd) == 1:
 551         msg.reply(u'错误：请给出选项值')
 552         return
 553       try:
 554         handle = getattr(self, 'set_' + cmd[0])
 555       except AttributeError:
 556         msg.reply(u'错误：未知选项 %s' % cmd[0])
 557       except IndexError:
 558         msg.reply(u'错误：无选项')
 559       except UnicodeEncodeError:
 560         msg.reply(u'错误：选项名解码失败。此问题在 GAE 升级其 Python 到 3.x 后方能解决。')
 561       else:
 562         handle(cmd[1])
 563
 564   def set_prefix(self, arg):
 565     '''设置命令前缀'''
 566     self.sender.prefix = arg
 567     self.sender.put()
 568     self.msg.reply(u'设置成功！')
 569
 570   def set_nickpattern(self, arg):
 571     '''设置昵称显示格式，用 %s 表示昵称的位置'''
 572     try:
 573       arg % 'test'
 574     except (TypeError, ValueError):
 575       self.msg.reply(u'错误：不正确的格式')
 576       return
 577
 578     self.sender.nick_pattern = arg
 579     self.sender.put()
 580     self.msg.reply(u'设置成功！')
 581
 582   def set_allowpm(self, arg):
 583     '''设置是否接受私信，参数为 y（接受）或者 n（拒绝）'''
 584     if arg not in 'yn':
 585       self.msg.reply(u'错误的参数。')
 586       return
 587
 588     if arg == 'y':
 589       self.sender.reject_pm = False
 590     else:
 591       self.sender.reject_pm = True
 592     self.sender.put()
 593     self.msg.reply(u'设置成功！')
 594
 595 class AdminCommand(BasicCommand):
 596   def do_kick(self, args):
 597     '''删除某人。他仍可以重新加入。'''
 598     if len(args) != 1:
 599       self.msg.reply('请给出昵称。')
 600       return
 601
 602     target = get_user_by_nick(args[0])
 603     if target is None:
 604       self.msg.reply('Sorry，查无此人。')
 605       return
 606
 607     if target.jid == config.root:
 608       self.msg.reply('不能删除 root 用户')
 609       return
 610
 611     targetjid = target.jid
 612     targetnick = target.nick
 613     target.delete()
 614     self.msg.reply((u'OK，删除 %s。' % target.nick).encode('utf-8'))
 615     send_to_all_except(self.sender.jid, (u'%s 已被删除。' % self.sender.nick) \
 616                        .encode('utf-8'))
 617     xmpp.send_message(targetjid, u'你已被管理员从此群中删除，请删除该好友。')
 618     log_onoff(self.sender, KICK % (targetnick, targetjid))
 619
 620   def do_quiet(self, args):
 621     '''禁言某人，参数为昵称和时间（默认单位秒）'''
 622     if len(args) != 2:
 623       self.msg.reply('请给出昵称和时间。')
 624       return
 625     else:
 626       try:
 627         n = utils.parseTime(args[1])
 628       except ValueError:
 629         self.msg.reply('Sorry，我无法理解你说的时间。')
 630         return
 631
 632     target = get_user_by_nick(args[0])
 633     if target is None:
 634       self.msg.reply('Sorry，查无此人。')
 635       return
 636
 637     target.black_before = datetime.datetime.now() + datetime.timedelta(seconds=n)
 638     target.put()
 639     self.msg.reply((u'OK，禁言 %s %d 秒。' % (target.nick, n)).encode('utf-8'))
 640     send_to_all_except((self.sender.jid, target.jid),
 641                        (u'%s 已被禁言 %s 秒。' % (self.sender.nick, n)) \
 642                        .encode('utf-8'))
 643     xmpp.send_message(target.jid, u'你已被管理员禁言 %d 秒。' % n)
 644     log_onoff(self.sender, BLACK % (target.nick, n))
 645
 646   def do_admin(self, args):
 647     '''将某人添加为管理员'''
 648     if len(args) != 1:
 649       self.msg.reply(u'请给出昵称。')
 650       return
 651
 652     target = get_user_by_nick(args[0])
 653     if target is None:
 654       self.msg.reply(u'Sorry，查无此人。')
 655       return
 656
 657     if target.is_admin:
 658       self.msg.reply(u'%s 已经是管理员了。' % target.nick)
 659       return
 660
 661     target.is_admin = True
 662     target.put()
 663     send_to_all_except(target.jid,
 664                        (u'%s 已成为管理员。' % target.nick) \
 665                        .encode('utf-8'))
 666     xmpp.send_message(target.jid, u'你已是本群管理员。')
 667     log_onoff(self.sender, ADMIN % (target.nick, self.sender.nick))
 668
 669   def do_unadmin(self, args):
 670     '''取消某人管理员的权限'''
 671     if len(args) != 1:
 672       self.msg.reply(u'请给出昵称。')
 673       return
 674
 675     target = get_user_by_nick(args[0])
 676     if target is None:
 677       self.msg.reply(u'Sorry，查无此人。')
 678       return
 679
 680     if not target.is_admin:
 681       self.msg.reply(u'%s 不是管理员。' % target.nick)
 682       return
 683
 684     target.is_admin = False
 685     target.put()
 686     send_to_all_except(target.jid,
 687                        (u'%s 已不再是管理员。' % target.nick) \
 688                        .encode('utf-8'))
 689     xmpp.send_message(target.jid, u'你已不再是本群管理员。')
 690     log_onoff(self.sender, UNADMIN % (target.nick, self.sender.nick))
 691