Merge branch 'master' of https://git.neoteched.com/zhangwei/ops

cms_log/cms_log/check_pay_stat.py

@@ -43,8 +43,8 @@ if __name__ == '__main__':
     count=0
     dbname="summer_hill"
     d=db.openMysql(host,port,user,password,dbname)
-    #sql='''select id,product_id,user_id,state,ctime,mtime from summer_hill.order where state='new';'''
-    sql='''select id,product_id,user_id,state,ctime,mtime from summer_hill.order where state='closed';'''
+    sql='''select id,product_id,user_id,state,ctime,mtime from summer_hill.order where state='new';'''
+    #sql='''select id,product_id,user_id,state,ctime,mtime from summer_hill.order where state='closed';'''
     c=d.cursor()
     c.execute(sql)
     rs=c.fetchall()

cms_log/cms_log/util/db.py

+# -*- coding:utf8 -*-
+
 import os
 import times
 import sys

company/AlertWeixin.conf

+[default]
+appid       = wx20cb1a787a86cae4
+secret      = 98706957fa4efcbe6d406a0d685072a8 
+template_id = BXxZZPZHztuD_0YTmVZCGsCMMuhczZTB80he7EnhY0U 

company/AlertWeixin.py

+#!/usr/bin/env python
+
+import sys,os
+import ConfigParser
+import json
+import requests
+
+conf = './AlertWeixin.conf'
+
+config = ConfigParser.ConfigParser()
+config.read(conf)
+
+wxappid         = config.get('default', 'appid')
+wxsecret        = config.get('default', 'secret')
+template_id     = config.get('default', 'template_id')
+
+
+useropenid  = sys.argv[1]
+touser      = useropenid
+first       = sys.argv[2]
+keyword1    = sys.argv[3]
+keyword2    = sys.argv[4]
+keyword3    = sys.argv[5]
+remark      = sys.argv[6]
+
+
+
+gettokenuri="https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s"%(wxappid,wxsecret)
+
+get_token = requests.get(gettokenuri)
+get_token=json.loads(get_token.text)
+token=get_token['access_token']
+
+
+payload='{\n\
+"touser":"%s",\n\
+"template_id":"%s",\n\
+"url":"http://weixin.qq.com/download",\n\
+"topcolor":"#FF0000",\n\
+"data":{\n\
+"first": {\n\
+"value":"%s",\n\
+"color":"#173177"\n\
+},\n\
+"keyword1":{\n\
+"value":"%s",\n\
+"color":"#173177"\n\
+},\n\
+"keyword2":{\n\
+"value":"%s",\n\
+"color":"#173177"\n\
+},\n\
+"keyword3":{\n\
+"value":"%s",\n\
+"color":"#173177"\n\
+},\n\
+"remark":{\n\
+"value":"%s",\n\
+"color":"#173177"\n\
+}\n\
+}\n\
+}'%(touser,template_id,first,keyword1,keyword2,keyword3,remark)
+
+alteruri="https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=%s"%(token)
+
+AlertWeixin = requests.post(alteruri, data=payload)

company/AlertWeixin.sh

+#!/bin/bash
+user="$1"
+content="$2"
+severity="$3"
+subject="ping-check from aliyun to company "
+
+useropenid=$user
+eventtime=$(date  +"%Y-%m-%d %H:%M:%S")
+
+touser=$useropenid
+first="$subject"
+keyword1="severity"
+keyword2=$content
+keyword3=$eventtime
+remark=""
+
+
+#cd /usr/lib/zabbix/alertscripts/AlertWeixin/
+
+python ./AlertWeixin.py "$touser" "$first" "$keyword1" "$keyword2" "$keyword3" "$remark" 2>&1 |\
+  grep -i -v insecureplatformwarning >> AlertWeixin.log 

company/checkping.sh

+#!/bin/bash
+
+function alert() {
+    content=$1
+    severity=$2
+    ./AlertWeixin.sh oLvc1wW388DWx1eW1ovLh1yuvfaQ "$content" "$severity"
+}
+
+ip=210.12.30.146
+stime=$(date +"%H")
+#ip=210.12.30.31
+rs=$(ping -c 2 $ip |awk 'NR==6 {print $4}')
+if [ "$rs" !=  "2" ];then
+    content="ping down"
+    severity="Worning"
+    alert "$content" "$severity"
+fi    
+
+if [ "$stime" == "23" ];then
+    content="ping up"
+    severity="OK"
+    alert "$content" "$severity"
+fi

company/wxUserInfo.py

+#!/usr/bin/env python
+
+import sys,os
+import ConfigParser
+import json
+import requests
+
+conf = 'AlertWeixin.conf'
+
+config = ConfigParser.ConfigParser()
+config.read(conf)
+
+wxappid         = config.get('default', 'appid')
+wxsecret        = config.get('default', 'secret')
+template_id     = config.get('default', 'template_id')
+
+
+gettokenuri="https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s"%(wxappid,wxsecret)
+
+get_token = requests.get(gettokenuri)
+get_token=json.loads(get_token.text)
+token=get_token['access_token']
+
+
+getuseruri="https://api.weixin.qq.com/cgi-bin/user/get?access_token=%s"%(token)
+
+get_user = requests.get(getuseruri)
+get_user = json.loads(get_user.text)
+openids  = get_user['data']['openid']
+
+for openid in openids:
+    userinfouri="https://api.weixin.qq.com/cgi-bin/user/info?access_token=%s&openid=%s"%(token,openid)
+    user_info = requests.get(userinfouri)
+    user_info = json.loads(user_info.text)
+    print 'nickname: ',   user_info['nickname']
+    print 'openid: ',     user_info['openid']
+    print 'headimgurl: ', user_info['headimgurl']