代码块

const thing1 = context.getArg('thing1')
const thing4 = context.getArg('thing4')
const date2 = context.getArg('date2')
const accountId = context.getArg('accountId')
const data = { thing1, date2, thing4 }
const gql = `mutation publishWechatMessage($data: Map_String_StringScalar,$accountId:Long!){
  publishWechatMessage(
    accountId: $accountId
    data: $data
    miniprogramState: FORMAL
    page: "pages/lil7gbne/lil7gbne"
    lang: CN
    templateId: "RQH7FafxS4_jQsRSN6ujLLKUoWuXpC3uLvYP1WL75Ys"
  )
}`
context.runGql(
  'publishWechatMessage',
  gql,
  { data, accountId },
  { role: 'admin' }
)

const phone_number = context.getArg('phone_number')
const result = `${phone_number.substring(0, 3)}****${phone_number.substring(7, 11)}`
context.setReturn('result_phone', result)

// gql 内容
const gql = `query findPaymentTransactionById ($paymentTransactionId: bigint!){
    response: payment_transaction_by_pk(id:$paymentTransactionId) {
      id
      status
      currency
      amount
      description
      order_id
      account_id
      payment_method
    }
  }`
// 运行 gql
context.runGql(
  'findPaymentTransactionById',
  gql,
  { paymentTransactionId: 1 },
  { role: 'admin' }
)

const gql1 = `query all_huodong{
  ud_huodongbiao_aed593(
    distinct_on: [id]
  ) {
    id
    ud_huodongmingcheng_683ab6
    ud_baomingfeiyong_a5f138
  }
}
` // 定义获取活动表中的 id 、活动名称、报名费用的所有数据的gal
 
const all_huodong = context.runGql('all_huodong', gql1, {}, { role: 'admin' }) // 运行这段 gql，获取数据并保存到 all_huodong 变量中
 
const gql2 = `mutation update_feiyong($value:bigint){
  update_ud_huodongbiao_aed593(_set: {ud_baomingfeiyong_a5f138:10086}, _inc: {}, where: {id:{_eq:$value}}) {
    affected_rows
    returning {
      id
      ud_baomingfeiyong_a5f138
  }
}
}` // 定义根据活动表的id（即过滤条件为活动表的id）更新活动报名费用字段，将所有的费用更新为 10086
 
const huodong_array = all_huodong.ud_huodongbiao_aed593 // gql 返回的结果是一个对象，要拿到对象中的数据数组
 
for (var i = 0; i < huodong_array.length; i++) {
  context.runGql(
    'update_feiyong',
    gql2,
    { value: huodong_array[i].id },
    { role: 'admin' }
  )
} // 通过循环的方式运行 gql 更新每一条数据

# 查询
query 命令名($argumentname1:type) {
  表名(where:{
        字段1:{判断方法:判断值},
        字段2:{判断方法:判断值},
        ... },
      order_by:[{字段:排序方式}],
      distinct_on:[去重字段],
      limit:1) {
      别名:需返回字段
    }
}

query getAccount($accountID: bigint) {
  account(where: { id: { _eq:$accountID } }) {
    id
    profile {
      id
      name: ud_xingming_e1693e
      gender: ud_xingbie_7644ed
      phone_number: ud_shoujihaoma_e3188e
    }
  }
}

# 请求某个活动的报名情况
query getsign_record($activityID: bigint) {
  activity(where: {}, order_by: [{}], distinct_on: [id], offset: 1, limit: 1) {
    id
    name
    image {
      url
    }
    sign_record(where: { activity_id_activity: { _eq: $activityID } }) {
      id
      activity_id_activity
      ud_account_id_zhanghu_999f9c
    }
  }
}

# 请求 reference 表的count，maxid
query getReferenceAggregate {
  reference_aggregate {
    aggregate {
      count(columns:[id,content],distinct:true)
      max {
        id
      }
    }
  }

# 请求 activity 表，让他按照报名表的count降序显示，并且显示报名数量
query activity_order_by_sign_count{
  activity(order_by: [{sign_record_aggregate:{count:desc}}]) {
    id
    name
    image{url}
    sign_record_aggregate{
      aggregate{count}
    }
  }
}

#添加
mutation 命令名{
    insert_表名(
    objects:[{数据1字段1:赋值1,数据1字段2:赋值2},{数据2字段1:赋值1，数据2字段2:赋值2}],
    on_conflict:{constraint:约束名,update_columns:[更新的字段1,更新的字段2],},
    )
    {
        无所谓填啥，新手不用管，想研究的可以自行查看Docs
    }
}

#更新
mutation 命令名{
    update_表名(
    _set:{字段1:赋值1,字段2:赋值2},
    _inc:{字段1:赋值1},
    where:{字段1:{判断方法:判断值}，字段2:{判断方法:判断值}}
    )
    {
        无所谓填啥，新手不用管，想研究的可以自行查看Docs
    }
}

# 删除
mutation 命令名{
  delete_表名(
  where:{字段1:{判断方法:判断值}，字段2:{判断方法:判断值}}
  ){
    无所谓填啥，新手不用管，想研究的可以自行查看 Docs
  }
}

context.callThirdPartyApi('$operationId', {'body'{"appKey": "f46dce7fa0566f0c","sign": "OTljNjYyNXXX=="}});

// 获取account_id
const account_id = context.getArg('account_id')
console.log(account_id)
// 取account信息的gql语句（入参为account id,即过滤的条件）
var gql = `query queryAccount($account_id:bigint!)
 
{
  account (where:{id:{_eq:$account_id}})
           {
            
            id
            oauth2_user_info_map
          }
        }`
 
// 执行这个gql语句，得到查询结果
var result_id = context.runGql(
  'queryAccount',
  gql,
  { account_id },
  { role: 'user' }
)
 
// 创建数组a, a为account信息里名为account的数组
var a = []
a = result_id.account
//情况1，account既有union_id,也有open_id
if (
  a.length != 0 &&
  a[0].oauth2_user_info_map.WECHAT.hasOwnProperty('unionId')
) {
  var open_id = a[0].oauth2_user_info_map.WECHAT.openId
  var union_id = a[0].oauth2_user_info_map.WECHAT.unionId
  context.setReturn('union_id', union_id)
  context.setReturn('open_id', open_id)
}
// 情况2，account只有open_id, 没有union_id
else if (
  a.length != 0 &&
  !a[0].oauth2_user_info_map.WECHAT.hasOwnProperty('unionId')
) {
  var open_id = a[0].oauth2_user_info_map.WECHAT.openId
  context.setReturn('union_id', '')
  context.setReturn('open_id', open_id)
}
// 情况3，account既没有open_id也没有union_id
else {
  context.setReturn('union_id', '')
  context.setReturn('open_id', '')
}

const url = '' // 过来的 url 链接
const headers = {}
const media = context.uploadMedia(url, headers) // $url: 图片地址; $headers: 请求需要的headers, 一般都填{}，除非你是向非本项目的数据库传文件。
// 返回值举例：{mediaType:"IMAGE", id:1020000000000003}
const imageID = media.id
const gql = `mutation inset_image($imageID: bigint){
    insert_表名(
      objects:[{图片字段_id:$imageID}])
      {
     returning{id}
    }
}`
context.runGql('inset_image', gql, { imageID }, { role: 'admin' })

const xx_id = context.getArg('xx_id') //获取过滤用的表id
const url = '' // 过来的 url 链接
const headers = {}
const media = context.uploadMedia(url, headers) // $url: 图片地址; $headers: 请求需要的headers, 一般都填{}，除非你是向非本项目的数据库传文件。
// 返回值举例：{mediaType:"IMAGE", id:1020000000000003}
const imageID = media.id
const gql = `mutation update_image($imageID: bigint,$xx_id:bigint){
    update_表名(
      _set:{图片字段_id:$imageID}
      where:{id:{_eq:$xx_id}})
      {
     returning{id}
    }
}`
context.runGql('update_image', gql, { imageID, xx_id }, { role: 'admin' })