add pictorial api

api/pictorial.py

+import json
+from utils.base import APIView
+from utils.logger import error_logger
+
+
+class PictorialListView(APIView):
+    def get(self, request):
+        star_id = request.GET.get('star_id')
+        user_id = request.GET.get('user_id')
+        offset = int(request.GET.get('page', 0))
+        limit = int(request.GET.get('limit', 10))
+        filters = self.handle_filter(request.GET.get('filter', ""))
+        if star_id:
+            filters.update({'star_id': star_id})
+        if user_id:
+            filters.update({'user_id': user_id})
+        try:
+            data = self.rpc['venus/sun/pictorial/list'](filters=filters, offset=(offset-1)*limit, limit=limit).unwrap()
+        except Exception as e:
+            error_logger.error(u'获取画报列表失败%s' , e)
+            raise
+        return data
+
+    def post(self, request):
+        ids = json.loads(request.POST.get('ids', '[]'))
+        updates = json.loads(request.POST.get('updates', '{}'))
+        try:
+            self.rpc['venus/sun/pictorial/batch/update'](updates=updates, ids=ids).unwrap()
+        except Exception as e:
+            error_logger.error(u'批量更新失败%s', e)
+            raise
+        return {
+            "message": "更新成功"
+        }
+
+
+class PictorialUpdateOrCreate(APIView):
+    def get(self, request):
+        id = request.GET.get('id').split(':')[0]
+        try:
+            data = self.rpc['venus/sun/pictorial/get'](id=id).unwrap()
+        except Exception as e:
+            error_logger.error(u'获取%s用户信息失败%s'%(id, e))
+            raise
+        return data
+
+    def post(self, request):
+        id = request.POST.get('id')
+        star_ids = list(map(lambda x: x.split(":")[0], json.loads(request.POST.get('star', '[]'))))
+        pictorial_user_ids = list(map(lambda x: x.split(":")[0], json.loads(request.POST.get('pictorial_users', '[]'))))
+        data = {
+            'name': request.POST.get('name', ''),
+            'description': request.POST.get('description', ''),
+            'creator_id': request.POST.get('user', '').split(':')[0],
+            'celebrity_ids': star_ids,
+            'is_online': int(request.POST.get('is_online', 0)),
+            'is_recommend': int(request.POST.get('is_recommend', 0)),
+            'pictorial_user_ids':pictorial_user_ids,
+            'icon': request.POST.get('icon', '')[:-2]
+        }
+        try:
+            self.rpc['venus/sun/pictorial/edit'](id=id, data=data).unwrap()
+        except Exception as e:
+            error_logger.error(u'编辑%s用户信息失败%s' % (id, e))
+            raise
+        return {
+            'message': '更新成功'
+        }
+
+
+class PictorialRelatedUser(APIView):
+    def get(self, request):
+        id = request.GET.get('id')
+        offset = int(request.GET.get('page', 0))
+        count = int(request.GET.get('limit', 10))
+        filters = {'pictorial_id': id}
+        try:
+            data = self.rpc['venus/sun/pictorial/user/list'](filters=filters, offset=(offset - 1) * count, limit=count).unwrap()
+        except Exception as e:
+            error_logger.error(u'获取画报用户信息失败%s' , e)
+            raise
+        return data
+
+
+class PictorialRelatedUserGET(APIView):
+    def get(self, request):
+        id = request.GET.get('id', '').split(':')[0]
+        try:
+            data = self.rpc['venus/sun/pictorial/user/get'](id=id).unwrap()
+        except Exception as e:
+            error_logger.error(u'获取画报用户信息失败%s', e)
+            raise
+        return [data, ]
+
+    def post(self, request):
+        pictorial_id = request.POST.get('pictorial_id')
+        user_id = request.POST.get('user_id')
+        data = {
+            'role_id': request.POST.get('original_pictorial_identify'),
+        }
+        try:
+            self.rpc['venus/sun/pictorial/user/edit'](id=pictorial_id, user_id=user_id, data=data).unwrap()
+        except Exception as e:
+            error_logger.error(u'编辑画报用户%s信息失败%s'%(user_id, e))
+            raise
+        return
\ No newline at end of file

api/search.py

@@ -104,3 +104,16 @@ class TagTypeSearchView(APIView):
         return {
             'data': ['{id}:{name}'.format(id=search_data['id'], name=search_data['name']) for search_data in data]
         }
+
+    
+class PictorialSearchView(APIView):
+    def get(self, request):
+        name = request.GET.get('name')
+        try:
+            data = self.rpc['venus/sun/pictorial/search'](name=name).unwrap()
+        except Exception as e:
+            raise e
+
+        return {
+            'data': ['{id}:{name}'.format(id=search_data['id'], name=search_data['name']) for search_data in data]
+        }

api/urls.py

@@ -21,6 +21,7 @@ from .face_star import *
 from .advertise import *
 from .channel_build import *
 from .commons import *
+from .pictorial import *
 
 urlpatterns = [
     # 登陆,注销相关
@@ -128,6 +129,15 @@ urlpatterns = [
     url(r'^channel_build/version/create', VersionCreate.as_view()),
 
     url(r'^suggestion/list$', SuggestionListView.as_view())
+
+    # 画报相关
+    url(r'^pictorial/list$', PictorialListView.as_view()),
+    url(r'^pictorial/list/update$', PictorialListView.as_view()),
+    url(r'^pictorial/get$', PictorialUpdateOrCreate.as_view()),
+    url(r'^pictorial/create$', PictorialUpdateOrCreate.as_view()),
+    url(r'^pictorial/user/list$', PictorialRelatedUser.as_view()),
+    url(r'^pictorial/user/get$', PictorialRelatedUserGET.as_view()),
+    url(r'^pictorial/user/edit_group_identify', PictorialRelatedUserGET.as_view()),
 ]
 
 search_urlpatterns = [
@@ -139,6 +149,7 @@ search_urlpatterns = [
     url(r'search/city$', CitySearchView.as_view()),
     url(r'search/topic$', TopicSearchView.as_view()),
     url(r'search/tagtype$', TagTypeSearchView.as_view()),
+    url(r'search/pictorial$', PictorialSearchView.as_view()),
 ]
 
 common_urlpatterns = [