// 云函数入口文件

const cloud = require('wx-server-sdk')

cloud.init()

// 云函数入口函数

exports.main = async (event, context) => {

  console.log(event)

  return sendTemplateMessage(event)

}

​

//小程序模版消息推送

async function sendTemplateMessage(event) {

  const {

    OPENID

  } = cloud.getWXContext()

​

  const sendResult = await cloud.openapi.subscribeMessage.send({

    touser: event.POSTBODY.touser, //要推送的用户openid

    templateId: "pKSS8I8P-zjWKFsH3M_5T4eZNNYIX1erYqmHJ8JwOf4", //这边是你申请的模板的id

    page: '',

    data: {//这边是模板申请好了里面有字段的对应

      thing2: {

        value: event.POSTBODY.orderno,

      },

      phrase5: {

        value: event.POSTBODY.state,

      }

    }

  })

​

  return sendResult

}

 public String subscribe(String openid, String orderno, String state, String name) {

        String accessTokenUrl = "https://api.weixin.qq.com/tcb/invokecloudfunction?access_token=ACCESS_TOKEN&env=ENV&name=FUNCTION_NAME";

        Token token = tokenDao.selectByPrimaryKey(1);

        String access_token = token.getAccessToken();

        JSONObject jsonObject = new JSONObject();

        String env = "xxxx";

        JSONObject data = new JSONObject();

        data.put("touser", openid);

        data.put("orderno", orderno);

        data.put("state", state);

        jsonObject.put("POSTBODY", data);

        try {

            String url = accessTokenUrl.replace("ACCESS_TOKEN", access_token);

            url = url.replace("ENV", env);

            url = url.replace("FUNCTION_NAME", name);

            return RestTemplateUtil.post(url, jsonObject);

        } catch (Exception e) {

            e.printStackTrace();

            return "请求获取access_token出现异常";

        }

​

    }