get_data

bbztx/get_data.py

@@ -0,0 +1,76 @@
+#!/usr/bin/python
+# -*- coding:utf-8 -*-
+from util import pgsql_util
+import json
+import sys
+reload(sys)
+sys.setdefaultencoding('utf8')
+
+query_articles_sql = '''
+select a.aid,a.title,a.cities,a.cid,a.other_info,"array_agg"(t.tag_value),days,a.recom,a."rank",read_count
+from articles a
+LEFT JOIN article_tags t on a.aid = t.aid
+where a.crt_time > '2018-01-01' and a.atype = '0'
+and a.stock_aid is NULL
+GROUP BY a.aid
+limit 100 OFFSET 0
+'''
+
+query_sell_main_sql = '''
+select count(*)
+FROM order 
+where aid in (select aid from articles where stock_aid = %s)
+and pay_status = 7
+'''
+
+query_stock_main_sql = '''
+select sum(maxt::int)
+FROM zm_alipay 
+where aid in (select aid from articles where stock_aid = %s)
+and status in (1,2)
+'''
+
+query_sell_main_sql_2 = '''
+select count(*)
+FROM order 
+where aid = %s
+and pay_status = 7
+'''
+
+query_stock_main_sql_2 = '''
+select sum(maxt::int)
+FROM zm_alipay 
+where aid = %s
+and status in (1,2)
+'''
+
+def get_articles():
+    rows = pgsql_util.get_rows(query_articles_sql)
+
+    attr_list = []
+    for row in rows:
+        attr = {}
+        attr['city'] = row['cities'].encode('utf-8')
+        attr['cid'] = row['cid']
+
+        other_info = json.loads(row['other_info'])
+        attr['dtype'] = other_info.get('dtype')
+        attr['recruit'] = other_info.get('recruit')
+        attr['country'] = other_info.get('country')
+        attr['price'] = other_info.get('price').replace('元', '')
+
+        attr['days'] = row['days']
+        attr['recom'] = row['recom']
+        attr['rank'] = row['rank']
+        attr['read_count'] = row['read_count']
+
+
+
+
+        attr_list.append(attr)
+
+        print attr
+
+
+if __name__ == '__main__':
+    get_articles()