index.js 1.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. // 云函数入口文件
  2. const cloud = require('wx-server-sdk')
  3. cloud.init()
  4. const db = cloud.database()
  5. // 云函数入口函数
  6. exports.main = async (event, context) => {
  7. const {
  8. OPENID
  9. } = cloud.getWXContext()
  10. const message_check = await db.collection('message')
  11. .where({
  12. _id: event.msg_id || ''
  13. })
  14. .get()
  15. if (message_check.data.length === 0) {
  16. return {
  17. errMsg: '信息不存在',
  18. status: 'ERR'
  19. }
  20. }
  21. const manager_check = await db.collection('manager')
  22. .where({
  23. pub_id: message_check.data[0].pub_id,
  24. user_id: OPENID
  25. })
  26. .get()
  27. if (manager_check.data.length === 0) {
  28. return {
  29. errMsg: '只有管理员可以修改',
  30. status: 'ERR'
  31. }
  32. }
  33. if (event.type === '纳新') {
  34. const publisher = await db.collection('publisher')
  35. .doc(message_check.data[0].pub_id)
  36. .get()
  37. event.type = publisher.data.type + '纳新'
  38. }
  39. const message = await db.collection('message')
  40. .doc(event.msg_id)
  41. .update({
  42. data: {
  43. name: event.name,
  44. type: event.type,
  45. brief: event.brief,
  46. poster: event.poster,
  47. photo: event.photo,
  48. tag: event.tag,
  49. orient: event.orient,
  50. time: event.time,
  51. place: event.place,
  52. contact: event.contact,
  53. detail: event.detail,
  54. link: event.link
  55. }
  56. })
  57. return {
  58. stats: message.stats,
  59. status: 'OK'
  60. }
  61. }