拍爱

views.py 24KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712
  1. # -*- coding: utf-8 -*-
  2. from __future__ import division
  3. from curtail_uuid import CurtailUUID
  4. from django.conf import settings
  5. from django.db import connection, transaction
  6. from logit import logit
  7. from paginator import pagination
  8. from rest_framework import viewsets
  9. from TimeConvert import TimeConvert as tc
  10. from account.models import UserInfo
  11. from group.models import GroupInfo, GroupPhotoInfo, GroupUserInfo, PhotoCommentInfo, PhotoThumbUpInfo
  12. from group.serializers import GroupInfoSerializer, GroupPhotoInfoSerializer, GroupUserInfoSerializer
  13. from message.models import UserMessageInfo
  14. from utils.error.errno_utils import GroupPhotoStatusCode, GroupStatusCode, GroupUserStatusCode, UserStatusCode
  15. from utils.error.response_utils import response
  16. from utils.group_photo_utils import get_current_photos
  17. from utils.qiniucdn import qiniu_file_url
  18. from utils.redis.connect import r
  19. from utils.redis.rgroup import (del_group_photo_thumbup_flag, get_group_info, get_group_photo_comment_list,
  20. get_group_photo_data, get_group_photo_thumbup_flag, get_group_photo_thumbup_list,
  21. get_group_photo_watchers, get_group_users_info, set_group_info, set_group_info_by_id,
  22. set_group_photo_comment_list, set_group_photo_data, set_group_photo_thumbup_flag,
  23. set_group_photo_thumbup_list, set_group_users_info)
  24. from utils.redis.rkeys import GROUP_LAST_PHOTO_PK, GROUP_PHOTO_WATCHER_SET, GROUP_USERS_PASSED_SET
  25. from utils.redis.rlock import upload_lock
  26. from utils.redis.rorder import get_lensman_order_record
  27. from utils.redis.rprice import get_lensman_price_fixed
  28. from utils.sql.raw import PAI2_HOME_API
  29. from utils.storage_qiniu_utils import file_save
  30. from utils.time_utils import origin_expired_stamps
  31. from utils.url_utils import share_url
  32. @logit
  33. @transaction.atomic
  34. def group_create_api(request):
  35. """ 群组创建 """
  36. user_id = request.POST.get('user_id', '')
  37. group_name = request.POST.get('group_name', '')
  38. group_default_avatar = int(request.POST.get('group_default_avatar', 0))
  39. # 用户校验
  40. try:
  41. user = UserInfo.objects.get(user_id=user_id)
  42. except UserInfo.DoesNotExist:
  43. return response(UserStatusCode.USER_NOT_FOUND)
  44. # 群组唯一标识
  45. group_id = CurtailUUID.uuid(GroupInfo, 'group_id')
  46. # 群组记录创建
  47. group = GroupInfo.objects.create(
  48. group_id=group_id,
  49. admin_id=user_id,
  50. group_name=group_name,
  51. group_default_avatar=group_default_avatar,
  52. group_from=GroupInfo.APP_GROUP,
  53. )
  54. # Redis 群组数据缓存
  55. group_info = set_group_info(group)
  56. # 群组用户记录创建
  57. GroupUserInfo.objects.create(
  58. group_id=group_id,
  59. user_id=user_id,
  60. nickname=user.final_nickname,
  61. avatar=user.avatar,
  62. admin=True,
  63. user_status=GroupUserInfo.PASSED,
  64. passed_at=tc.utc_datetime(),
  65. )
  66. # Redis 群组用户数据缓存
  67. group_users = set_group_users_info(group)
  68. # Redis 群组通过集合缓存
  69. r.sadd(GROUP_USERS_PASSED_SET % group_id, user_id)
  70. return response(200, 'Create Group Success', u'群组创建成功', {
  71. 'group_id': group_id,
  72. 'group': group_info,
  73. 'users': group_users,
  74. })
  75. @logit
  76. def group_detail_api(request):
  77. """ 群组详情 """
  78. group_id = request.POST.get('group_id', '')
  79. user_id = request.POST.get('user_id', '')
  80. return response(200, 'Get Group Detail Info Success', u'获取群组详情成功', {
  81. 'group_id': group_id,
  82. 'group': get_group_info(group_id),
  83. 'users': get_group_users_info(group_id, user_id),
  84. })
  85. @logit
  86. def group_update_api(request):
  87. """ 群组更新 """
  88. group_id = request.POST.get('group_id', '')
  89. admin_id = request.POST.get('admin_id', '') or request.POST.get('user_id', '')
  90. group_name = request.POST.get('group_name', '')
  91. group_desc = request.POST.get('group_desc', '')
  92. group_avatar = request.FILES.get('group_avatar', '')
  93. # 群组校验
  94. try:
  95. group = GroupInfo.objects.get(group_id=group_id)
  96. except GroupInfo.DoesNotExist:
  97. return response(GroupStatusCode.GROUP_NOT_FOUND)
  98. # 权限校验
  99. if group.admin_id != admin_id:
  100. return response(GroupStatusCode.NOT_GROUP_ADMIN)
  101. # 群组名称更新
  102. if group_name:
  103. group.group_name = group_name
  104. # 群组描述更新
  105. if group_desc:
  106. group.group_desc = group_desc
  107. # 群组头像更新
  108. if group_avatar:
  109. group.group_avatar = file_save(group_avatar, prefix='group', ext='.jpeg').photo_path
  110. group.save()
  111. # Redis 群组数据缓存更新
  112. group_info = set_group_info(group)
  113. return response(200, 'Update Group Success', u'群组更新成功', {
  114. 'group_id': group_id,
  115. 'group': group_info,
  116. 'users': get_group_users_info(group_id, admin_id),
  117. })
  118. @logit
  119. def group_delete_api(request):
  120. """ 群组删除 """
  121. group_id = request.POST.get('group_id', '')
  122. admin_id = request.POST.get('admin_id', '') or request.POST.get('user_id', '')
  123. # 群组校验
  124. try:
  125. group = GroupInfo.objects.get(group_id=group_id)
  126. except GroupInfo.DoesNotExist:
  127. return response(GroupStatusCode.GROUP_NOT_FOUND)
  128. # 权限校验
  129. if group.admin_id != admin_id:
  130. return response(GroupStatusCode.NOT_GROUP_ADMIN)
  131. # 照片数量校验
  132. if GroupPhotoInfo.objects.filter(group_id=group_id, status=True).count():
  133. return response(GroupStatusCode.GROUP_PHOTO_NOT_EMPTY)
  134. # 删除群组
  135. group.status = False
  136. group.save()
  137. # 删除群组用户
  138. GroupUserInfo.objects.filter(group_id=group_id).update(status=False)
  139. return response(200, 'Delete Group Success', u'群组删除成功')
  140. @logit
  141. def group_list_api(request):
  142. """ 群组列表 """
  143. user_id = request.POST.get('user_id', '')
  144. page = int(request.POST.get('page', 1))
  145. num = int(request.POST.get('num', settings.GROUP_NUM_PER_PAGE))
  146. group_users = GroupUserInfo.objects.filter(user_id=user_id, user_status=GroupUserInfo.PASSED, status=True).order_by('-pk')
  147. group_users, left = pagination(group_users, page, num)
  148. groups = []
  149. for group_user in group_users:
  150. group_info = get_group_info(group_user.group_id)
  151. groups.append(group_info) if group_info else None
  152. return response(200, 'Get Group List Success', u'获取群组列表成功', {
  153. 'groups': groups,
  154. 'left': left,
  155. })
  156. @logit
  157. def group_lock_api(request):
  158. """ 群组锁定 """
  159. group_id = request.POST.get('group_id', '')
  160. admin_id = request.POST.get('admin_id', '') or request.POST.get('user_id', '')
  161. # 群组校验
  162. try:
  163. group = GroupInfo.objects.get(group_id=group_id)
  164. except GroupInfo.DoesNotExist:
  165. return response(GroupStatusCode.GROUP_NOT_FOUND)
  166. # 权限校验
  167. if group.admin_id != admin_id:
  168. return response(GroupStatusCode.NOT_GROUP_ADMIN)
  169. # 群组锁定
  170. group.group_lock = True
  171. group.save()
  172. # Redis 群组数据缓存更新
  173. set_group_info(group)
  174. return response(200, 'Lock Success', u'锁定成功')
  175. @logit
  176. def group_unlock_api(request):
  177. """ 群组解锁 """
  178. group_id = request.POST.get('group_id', '')
  179. admin_id = request.POST.get('admin_id', '') or request.POST.get('user_id', '')
  180. # 群组校验
  181. try:
  182. group = GroupInfo.objects.get(group_id=group_id)
  183. except GroupInfo.DoesNotExist:
  184. return response(GroupStatusCode.GROUP_NOT_FOUND)
  185. # 权限校验
  186. if group.admin_id != admin_id:
  187. return response(GroupStatusCode.NOT_GROUP_ADMIN)
  188. # 群组解锁
  189. group.group_lock = False
  190. group.save()
  191. # Redis 群组数据缓存更新
  192. set_group_info(group)
  193. return response(200, 'Unlock Success', u'解锁成功')
  194. @logit
  195. def group_data_api(request):
  196. """ 群组数据,评论数,点赞数 """
  197. group_id = request.POST.get('group_id', '')
  198. return response(200, 'Get Group Data Success', u'获取群组数据成功', {
  199. 'photo_datas': get_group_photo_data(group_id),
  200. })
  201. @logit(body=settings.LOGIT_BODY_FLAG, res=settings.LOGIT_RES_FLAG)
  202. def flyimg_upload_api(request):
  203. """ 飞图上传 """
  204. group_id = request.POST.get('group_id', '')
  205. user_id = request.POST.get('user_id', '')
  206. nickname = request.POST.get('nickname', '')
  207. photo = request.FILES.get('photo', '')
  208. current_id = int(request.POST.get('current_id', -1))
  209. # 用户校验
  210. try:
  211. user = UserInfo.objects.get(user_id=user_id)
  212. except UserInfo.DoesNotExist:
  213. return response(UserStatusCode.USER_NOT_FOUND)
  214. # 群组用户校验
  215. try:
  216. group_user = GroupUserInfo.objects.get(group_id=group_id, user_id=user_id, user_status=GroupUserInfo.PASSED)
  217. except GroupUserInfo.DoesNotExist:
  218. return response(GroupUserStatusCode.GROUP_USER_NOT_FOUND)
  219. if photo and upload_lock(group_id, user_id, photo):
  220. photo_info = file_save(photo, prefix='fly', ext='.jpeg', thumbnail=True)
  221. # 群组照片记录创建
  222. group_photo, created = GroupPhotoInfo.objects.get_or_create(
  223. group_id=group_id,
  224. user_id=user_id,
  225. photo_md5=photo_info.photo_md5,
  226. defaults={
  227. 'nickname': nickname or user.final_nickname,
  228. 'avatar': user.avatar,
  229. 'photo_path': photo_info.photo_path,
  230. 'photo_w': photo_info.photo_w,
  231. 'photo_h': photo_info.photo_h,
  232. 'photo_thumbnail_path': photo_info.photo_thumbnail_path,
  233. 'photo_thumbnail_w': photo_info.photo_thumbnail_w,
  234. 'photo_thumbnail_h': photo_info.photo_thumbnail_h,
  235. 'photo_thumbnail2_path': photo_info.photo_thumbnail2_path,
  236. 'photo_thumbnail2_w': photo_info.photo_thumbnail2_w,
  237. 'photo_thumbnail2_h': photo_info.photo_thumbnail2_h,
  238. }
  239. )
  240. if created:
  241. # 设置群组最后一张照片PK
  242. r.set(GROUP_LAST_PHOTO_PK % group_id, group_photo.pk)
  243. # Redis 群组数据缓存
  244. set_group_info_by_id(group_id)
  245. curinfo = get_current_photos(group_id, user_id, max(current_id, group_user.current_id), request=request)
  246. return response(200, 'Flyimg Upload Success', u'飞图上传成功', curinfo)
  247. @logit
  248. def flyimg_list_api(request):
  249. """ 飞图列表 """
  250. group_id = request.POST.get('group_id', '')
  251. user_id = request.POST.get('user_id', '')
  252. current_id = int(request.POST.get('current_id', -1))
  253. # 群组用户校验
  254. try:
  255. group_user = GroupUserInfo.objects.get(group_id=group_id, user_id=user_id, user_status=GroupUserInfo.PASSED)
  256. except GroupUserInfo.DoesNotExist:
  257. return response(GroupUserStatusCode.GROUP_USER_NOT_FOUND)
  258. curinfo = get_current_photos(group_id, user_id, max(current_id, group_user.current_id), request=request)
  259. return response(200, 'Get Flyimg List Success', u'获取飞图上传成功', curinfo)
  260. @logit
  261. def flyimg_detail_api(request):
  262. user_id = request.POST.get('user_id', '')
  263. photo_id = request.POST.get('photo_id', '')
  264. # 群组照片校验
  265. try:
  266. group_photo = GroupPhotoInfo.objects.get(photo_id=photo_id)
  267. except GroupPhotoInfo.DoesNotExist:
  268. return response(GroupPhotoStatusCode.GROUP_PHOTO_NOT_FOUND)
  269. return response(200, 'Get Flyimg Detail Success', u'获取飞图详情成功', {
  270. 'photo_info': group_photo.photo_info(user_id),
  271. 'comments': get_group_photo_comment_list(photo_id),
  272. 'thumbup': get_group_photo_thumbup_flag(photo_id, user_id), # user_id 是否点赞 photo_id
  273. 'thumbups': get_group_photo_thumbup_list(photo_id), # 群组照片点赞列表
  274. })
  275. @logit
  276. def comment_submit_api(request):
  277. """ 飞图评论提交 """
  278. group_id = request.POST.get('group_id', '')
  279. user_id = request.POST.get('user_id', '')
  280. to_uid = request.POST.get('to_uid', '')
  281. photo_id = request.POST.get('photo_id', '')
  282. comment = request.POST.get('comment', '')
  283. # 群组用户校验
  284. try:
  285. group_user = GroupUserInfo.objects.get(group_id=group_id, user_id=user_id, user_status=GroupUserInfo.PASSED)
  286. except GroupUserInfo.DoesNotExist:
  287. return response(GroupUserStatusCode.GROUP_USER_NOT_FOUND)
  288. # 群组照片校验
  289. try:
  290. group_photo = GroupPhotoInfo.objects.get(photo_id=photo_id)
  291. except GroupPhotoInfo.DoesNotExist:
  292. return response(GroupPhotoStatusCode.GROUP_PHOTO_NOT_FOUND)
  293. # 评论内容校验
  294. if not comment:
  295. return response(GroupPhotoStatusCode.COMMENT_CONTENT_EMPTY)
  296. # 群组照片评论记录创建
  297. PhotoCommentInfo.objects.create(
  298. photo_id=photo_id,
  299. user_id=user_id,
  300. nickname=group_user.nickname,
  301. avatar=group_user.avatar,
  302. to_uid=to_uid,
  303. comment=comment,
  304. )
  305. # 群组照片评论数更新
  306. group_photo.comment_num += 1
  307. group_photo.save()
  308. # Redis 群组照片数据缓存
  309. set_group_photo_data(group_id)
  310. # Redis 群组照片评论列表缓存刷新
  311. set_group_photo_comment_list(photo_id)
  312. r.sadd(GROUP_PHOTO_WATCHER_SET % photo_id, user_id)
  313. # 判断群组照片发布者是否已经被管理员移除/主动退出,如若移除/退出,则不给发布者提醒
  314. if r.sismember(GROUP_USERS_PASSED_SET % group_photo.group_id, group_photo.user_id):
  315. UserMessageInfo.objects.create(
  316. from_uid=user_id,
  317. from_nickname=group_user.nickname,
  318. from_avatar=group_user.avatar,
  319. to_uid=group_photo.user_id,
  320. group_id=group_photo.group_id,
  321. photo_id=group_photo.photo_id,
  322. msg_type=UserMessageInfo.COMMENT,
  323. msg_title=u'评论',
  324. msg_content=comment,
  325. )
  326. # 给所有关注者(评论/点赞)发送提醒,移除(评论/点赞)者和照片所有者
  327. watchers = get_group_photo_watchers(photo_id, [user_id, group_photo.user_id])
  328. for watcher in watchers:
  329. UserMessageInfo.objects.create(
  330. from_uid=user_id,
  331. from_nickname=group_user.nickname,
  332. from_avatar=group_user.avatar,
  333. to_uid=watcher,
  334. group_id=group_photo.group_id,
  335. photo_id=group_photo.photo_id,
  336. msg_type=UserMessageInfo.COMMENT,
  337. msg_title=u'评论',
  338. msg_content=comment,
  339. )
  340. return response(200, 'Comment Success', u'评论成功', {
  341. 'comments': get_group_photo_comment_list(photo_id),
  342. })
  343. @logit
  344. def comment_list_api(request):
  345. """ 飞图评论列表 """
  346. photo_id = request.POST.get('photo_id', '')
  347. # 群组照片校验
  348. if not GroupPhotoInfo.objects.filter(photo_id=photo_id).exists():
  349. return response(GroupPhotoStatusCode.GROUP_PHOTO_NOT_FOUND)
  350. return response(200, 'Get Comment List Success', u'获取评论列表成功', {
  351. 'comments': get_group_photo_comment_list(photo_id),
  352. })
  353. @logit
  354. def thumbup_submit_api(request):
  355. """ 飞图点赞提交 """
  356. group_id = request.POST.get('group_id', '')
  357. user_id = request.POST.get('user_id', '')
  358. photo_id = request.POST.get('photo_id', '')
  359. # 群组用户校验
  360. try:
  361. group_user = GroupUserInfo.objects.get(group_id=group_id, user_id=user_id, user_status=GroupUserInfo.PASSED)
  362. except GroupUserInfo.DoesNotExist:
  363. return response(GroupUserStatusCode.GROUP_USER_NOT_FOUND)
  364. # 群组照片校验
  365. try:
  366. group_photo = GroupPhotoInfo.objects.get(photo_id=photo_id)
  367. except GroupPhotoInfo.DoesNotExist:
  368. return response(GroupPhotoStatusCode.GROUP_PHOTO_NOT_FOUND)
  369. # user_id 是否点赞 photo_id
  370. if get_group_photo_thumbup_flag(photo_id, user_id):
  371. return response(GroupPhotoStatusCode.DUPLICATE_THUMB_UP)
  372. # 群组照片点赞记录创建/更新
  373. photo_thumbup, created = PhotoThumbUpInfo.objects.get_or_create(
  374. photo_id=photo_id,
  375. user_id=user_id,
  376. )
  377. photo_thumbup.nickname = group_user.nickname
  378. photo_thumbup.avatar = group_user.avatar
  379. photo_thumbup.thumbup = True
  380. photo_thumbup.save()
  381. # Redis 群组照片点赞数据缓存
  382. set_group_photo_thumbup_flag(photo_id, user_id)
  383. # 群组照片点赞数更新
  384. group_photo.thumbup_num += 1
  385. group_photo.save()
  386. # Redis 群组照片数据缓存
  387. set_group_photo_data(group_id)
  388. # Redis 群组照片点赞列表缓存刷新
  389. set_group_photo_thumbup_list(photo_id)
  390. r.sadd(GROUP_PHOTO_WATCHER_SET % photo_id, user_id)
  391. # 判断群组照片发布者是否已经被管理员移除/主动退出,如若移除/退出,则不给发布者提醒
  392. if r.sismember(GROUP_USERS_PASSED_SET % group_photo.group_id, group_photo.user_id):
  393. UserMessageInfo.objects.create(
  394. from_uid=user_id,
  395. from_nickname=group_user.nickname,
  396. from_avatar=group_user.avatar,
  397. to_uid=group_photo.user_id,
  398. group_id=group_photo.group_id,
  399. photo_id=group_photo.photo_id,
  400. msg_type=UserMessageInfo.THUMBUP,
  401. msg_title=u'点赞',
  402. msg_content=u'点赞',
  403. )
  404. # 给所有关注者(评论/点赞)发送提醒,移除(评论/点赞)者和照片所有者
  405. watchers = get_group_photo_watchers(photo_id, [user_id, group_photo.user_id])
  406. for watcher in watchers:
  407. UserMessageInfo.objects.create(
  408. from_uid=user_id,
  409. from_nickname=group_user.nickname,
  410. from_avatar=group_user.avatar,
  411. to_uid=watcher,
  412. group_id=group_photo.group_id,
  413. photo_id=group_photo.photo_id,
  414. msg_type=UserMessageInfo.THUMBUP,
  415. msg_title=u'点赞',
  416. msg_content=u'点赞',
  417. )
  418. return response(200, 'Thumbup Success', u'点赞提交成功', {
  419. 'thumbup': True,
  420. 'thumbups': get_group_photo_thumbup_list(photo_id),
  421. })
  422. @logit
  423. def thumbup_list_api(request):
  424. """ 飞图点赞列表 """
  425. user_id = request.POST.get('user_id', '')
  426. photo_id = request.POST.get('photo_id', '')
  427. return response(200, 'Get Thumbup List Success', u'获取点赞列表成功', {
  428. 'thumbup': get_group_photo_thumbup_flag(photo_id, user_id), # user_id 是否点赞 photo_id
  429. 'thumbups': get_group_photo_thumbup_list(photo_id), # 群组照片点赞列表
  430. })
  431. @logit
  432. def thumbup_cancel_api(request):
  433. """ 飞图点赞取消 """
  434. group_id = request.POST.get('group_id', '')
  435. user_id = request.POST.get('user_id', '')
  436. photo_id = request.POST.get('photo_id', '')
  437. # 群组用户校验
  438. try:
  439. group_user = GroupUserInfo.objects.get(group_id=group_id, user_id=user_id, user_status=GroupUserInfo.PASSED)
  440. except GroupUserInfo.DoesNotExist:
  441. return response(GroupUserStatusCode.GROUP_USER_NOT_FOUND)
  442. # 群组照片校验
  443. try:
  444. group_photo = GroupPhotoInfo.objects.get(photo_id=photo_id)
  445. except GroupPhotoInfo.DoesNotExist:
  446. return response(GroupPhotoStatusCode.GROUP_PHOTO_NOT_FOUND)
  447. # user_id 是否点赞 photo_id
  448. if not get_group_photo_thumbup_flag(photo_id, user_id):
  449. return response(GroupPhotoStatusCode.THUMB_UP_NOT_FOUND)
  450. # 群组照片点赞取消
  451. photo_thumbup, created = PhotoThumbUpInfo.objects.get_or_create(
  452. photo_id=photo_id,
  453. user_id=user_id,
  454. )
  455. photo_thumbup.thumbup = False
  456. photo_thumbup.save()
  457. # Redis 群组照片点赞数据移除
  458. del_group_photo_thumbup_flag(photo_id, user_id)
  459. # 群组照片点赞数更新
  460. group_photo.thumbup_num -= 1
  461. group_photo.save()
  462. # Redis 群组照片数据缓存
  463. set_group_photo_data(group_id)
  464. # Redis 群组照片点赞列表缓存刷新
  465. set_group_photo_thumbup_list(photo_id)
  466. # 判断群组照片发布者是否已经被管理员移除/主动退出,如若移除/退出,则不给发布者提醒
  467. if r.sismember(GROUP_USERS_PASSED_SET % group_photo.group_id, group_photo.user_id):
  468. UserMessageInfo.objects.create(
  469. from_uid=user_id,
  470. from_nickname=group_user.nickname,
  471. from_avatar=group_user.avatar,
  472. to_uid=group_photo.user_id,
  473. group_id=group_photo.group_id,
  474. photo_id=group_photo.photo_id,
  475. msg_type=UserMessageInfo.THUMBUP,
  476. msg_title=u'取消点赞',
  477. msg_content=u'取消点赞',
  478. )
  479. # 群组照片点赞列表
  480. photo_thumbups = PhotoThumbUpInfo.objects.filter(photo_id=photo_id, thumbup=True, status=True)
  481. return response(200, 'Thumbup Cancel Success', u'点赞取消成功', {
  482. 'thumbup': False,
  483. 'thumbups': [thumbup.thumbup_info for thumbup in photo_thumbups],
  484. })
  485. @logit
  486. def pai2_home_api(request):
  487. """ 首页照片信息 """
  488. user_id = request.POST.get('user_id', '')
  489. page = int(request.POST.get('page', 1))
  490. num = int(request.POST.get('num', settings.PAI2_HOME_PER_PAGE))
  491. # 执行原生 SQL 语句,获取首页照片列表
  492. cursor = connection.cursor()
  493. cursor.execute(PAI2_HOME_API.format(
  494. user_id=user_id,
  495. offset=0,
  496. rows=settings.PAI2_HOME_MAX_ROWS,
  497. ))
  498. rows = cursor.fetchall()
  499. # 首页照片分页
  500. rows, left = pagination(rows, page, num)
  501. # 首页照片信息
  502. rows = [{
  503. 'group_id': row[0],
  504. 'group_name': row[1],
  505. 'group_default_avatar': row[2],
  506. 'group_avatar': row[3],
  507. 'group_from': row[4],
  508. 'photo_id': row[5],
  509. 'photo_url': qiniu_file_url(row[6], bucket='photo'),
  510. 'photo_w': row[7],
  511. 'photo_h': row[8],
  512. 'photo_thumbnail_url': qiniu_file_url(row[9], bucket='thumbnail'),
  513. 'photo_thumbnail_w': row[10],
  514. 'photo_thumbnail_h': row[11],
  515. 'photo_thumbnail2_url': qiniu_file_url(row[12], bucket='thumbnail2'),
  516. 'photo_thumbnail2_w': row[13],
  517. 'photo_thumbnail2_h': row[14],
  518. 'photo_share_url': share_url(row[5]), # Warning: Index of This Line is 5
  519. 'user_id': row[15],
  520. 'nickname': row[16],
  521. 'avatar': row[17],
  522. 'comment_num': row[18],
  523. 'thumbup_num': row[19],
  524. 'photo_from': row[20],
  525. 'session_id': row[21],
  526. 'nomark': row[22],
  527. 'origin': row[23],
  528. 'created_at': row[24],
  529. 'origin_expired_stamps': origin_expired_stamps(row[24], row[15]),
  530. 'thumbup': get_group_photo_thumbup_flag(row[5], user_id),
  531. 'porder': get_lensman_order_record(row[5], user_id) if row[20] == GroupPhotoInfo.SESSION_GROUP else {},
  532. } for row in rows]
  533. return response(200, 'Get Home Data Success', u'获取首页数据成功', {
  534. 'photos': rows,
  535. 'left': left,
  536. })
  537. @logit
  538. def lensman_photo_price(request):
  539. """ 摄影师照片价格获取 """
  540. user_id = request.POST.get('user_id', '')
  541. photo_id = request.POST.get('photo_id', '')
  542. photo_type = request.POST.get('photo_type', 'nomark') # nomark for 去除水印, origin for 获取高清图
  543. # 群组照片校验
  544. try:
  545. group_photo = GroupPhotoInfo.objects.get(photo_id=photo_id)
  546. except GroupPhotoInfo.DoesNotExist:
  547. return response(GroupPhotoStatusCode.GROUP_PHOTO_NOT_FOUND)
  548. # 获取摄影师定价
  549. price = get_lensman_price_fixed(group_photo.user_id).get(photo_type, 999)
  550. return response(200, 'Get Price Success', u'获取价格成功', {
  551. 'price': price
  552. })
  553. @logit
  554. def lensman_photo_bought(request):
  555. """ 摄影师照片已购买 """
  556. user_id = request.POST.get('user_id', '')
  557. photo_id = request.POST.get('photo_id', '')
  558. return response(200, 'Get Bought Data Success', u'获取购买数据成功', {
  559. 'porder': get_lensman_order_record(photo_id, user_id)
  560. })
  561. class GroupInfoViewSet(viewsets.ModelViewSet):
  562. queryset = GroupInfo.objects.all().order_by('-pk')
  563. serializer_class = GroupInfoSerializer
  564. class GroupUserInfoViewSet(viewsets.ModelViewSet):
  565. queryset = GroupUserInfo.objects.all().order_by('-pk')
  566. serializer_class = GroupUserInfoSerializer
  567. class GroupPhotoInfoViewSet(viewsets.ModelViewSet):
  568. queryset = GroupPhotoInfo.objects.all().order_by('-pk')
  569. serializer_class = GroupPhotoInfoSerializer