微信公众号定时提醒

const express = require("express");
const router = express.Router();
const jsSHA = require("jssha");
/**
 * 授权验证
 */
router.get("/", function (req, res, next) {
  // 这里写你刚刚在上面随机生成的字符串
  const token = "";
  //1.获取微信服务器Get请求的参数 signature、timestamp、nonce、echostr
  let signature = req.query.signature, //微信加密签名
    timestamp = req.query.timestamp, //时间戳
    nonce = req.query.nonce, //随机数
    echostr = req.query.echostr; //随机字符串

  //2.将token、timestamp、nonce三个参数进行字典序排序
  let array = [token, timestamp, nonce];
  array.sort();

  //3.将三个参数字符串拼接成一个字符串进行sha1加密
  let tempStr = array.join("");
  let shaObj = new jsSHA("SHA-1", "TEXT");
  shaObj.update(tempStr);
  let scyptoString = shaObj.getHash("HEX");

  //4.开发者获得加密后的字符串可与signature对比，标识该请求来源于微信
  if (signature === scyptoString) {
    console.log("验证成功");
    res.send(echostr);
  } else {
    console.log("验证失败");
    res.send("验证失败");
  }
});

module.exports = router;

const fs = require("fs");
const path = require("path");
const axios = require("axios");
const moment = require("moment");
const info = require("./info");
function getToken() {
  return new Promise((resolve, reject) => {
    const tokenFile = path.join(__dirname, "token.json");
    fs.readFile(tokenFile, "utf-8", function (err, data) {
      if (err) {
        reject(err);
      } else {
        if (data) {
          const token = JSON.parse(data);
          if (token.expires_in > moment().unix()) {
            resolve(token.access_token);
            return;
          }
        }
        axios
          .get(
            `https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=${info.appId}&secret=${info.appSecret}`
          )
          .then((res) => {
            resolve(res.data.access_token);
            const t = res.data;
            t.expires_in = t.expires_in + moment().unix() - 1200;
            fs.writeFile(
              tokenFile,
              JSON.stringify(t, "", "\t"),
              function (err) {
                if (err) {
                  reject(err);
                }
              }
            );
          })
          .catch((err) => reject(err));
      }
    });
  });
}
module.exports = getToken;

const axios = require("axios");

function postMessage(token, templateId, openId, data) {
  axios
    .post(
      "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" +
        token,
      {
        touser: openId,
        template_id: templateId, // 模板信息id
        topcolor: "#FF0000",
        data: data,
      }
    )
    .then((res) => {
      console.log(res.data);
    })
    .catch((err) => {
      console.log(err);
    });
}

module.exports = postMessage;

module.exports = {
  appId: "", //appID
  appSecret: "", //appsecret
  gouldKey: "", //搞得天气的key
  //使用encodeURL，不然在node中中文编码可能会出问题
  address: encodeURI(""), //需要获取天气的地址，使用地址获取abccode，防止abccode改动
  city: encodeURI(""), //需要获取天气的城市 可不要
  openId: "", //加密后的微信号，关注公众号之后可以看到
  myOpenId: "", //自己的，用看看有没有发送成功
};

const info = require("../info");
const getToken = require("../getToken");
const postMessage = require("../postMessage");
const axios = require("axios");
const moment = require("moment");
// 模板id
const templateId = "";

const postAfterWork = async () => {
  const city = await axios
    .get(
      `https://restapi.amap.com/v3/geocode/geo?key=${info.gouldKey}&address=${info.address}&city=${info.city}`
    )
    .catch((err) => console.log(err));
  const { data: weatherInfo } = await axios
    .get(
      `https://restapi.amap.com/v3/weather/weatherInfo?key=${info.gouldKey}&city=${city.data.geocodes[0].adcode}&extensions=all&output=JSON`
    )
    .catch((err) => console.log(err));
  if (weatherInfo.status === "1") {
    const todayWeather = weatherInfo.forecasts[0].casts[0];
    const tomorrowWeather = weatherInfo.forecasts[0].casts[1];

    const getReminder = () => {
      const day = 5 - moment().weekday();
      switch (day) {
        case 0:
          return "恭喜你又熬到了周末，要好好休息享受周末啦";
        case 1:
          return "今天星期四，明天星期五，周末就要来啦";
        case 2:
          return "还有两天就周末了，开心起来!!!";
        case 3:
          return "叮~ 第二天工作结束，继续加油鸭!";
        case 4:
          return "本周第一天工作结束啦! 是不是很难熬~ 还有四天哦 O(∩_∩)O哈哈~";
      }
    };
    const data = {
      Weather: {
        value: tomorrowWeather.dayweather,
        color: "#ff9900",
      },
      Temperature: {
        value: `${tomorrowWeather.daytemp}℃ ~ ${tomorrowWeather.nighttemp}℃`,
        color: "#2d8cf0",
      },
      Reminder: {
        value: getReminder(),
        color: "#ffc0cb",
      },
    };
    getToken()
      .then((token) => {
        // 接受信息的人的openid
        postMessage(token, templateId, info.myOpenId, data);
        postMessage(token, templateId, info.openId, data);
      })
      .catch((err) => {
        console.log(err);
      });
  }
};
module.exports = postAfterWork;

const postAfterWork = require("./posts/afterWork");
// 轮询时间,发送对应的post
const cycle = setInterval(async function () {
  const h = moment().hour();
  const m = moment().minute();
  const week = moment().weekday();
  // 不同时间执行不行的post
  try {
    //周一到周五 下午五点五十九
    if (h === 5 && m === 59 && week && week < 6) {
      postAfterWork();
    }
  } catch (error) {
    console.log(error);
    clearInterval(cycle);
  }
}, 1000 * 60);