阅读 186

利用小程序云函数 生成Excel+打通钉钉HOOK+邮箱推送Excel

生成Excel+打通钉钉HOOK+邮箱推送Excel


基本介绍


云函数即在云端(服务器端)运行的函数。在物理设计上,一个云函数可由多个文件组成,占用一定量的 CPU 内存等计算资源;各云函数完全独立;可分别部署在不同的地区。开发者无需购买、搭建服务器,只需编写函数代码并部署到云端即可在小程序端调用,同时云函数之间也可互相调用。

一个云函数的写法与一个在本地定义的 JavaScript 方法无异,代码运行在云端 Node.js 中。当云函数被小程序端调用时,定义的代码会被放在 Node.js 运行环境中执行。我们可以如在 Node.js 环境中使用 JavaScript 一样在云函数中进行网络请求等操作,而且我们还可以通过云函数后端 SDK 搭配使用多种服务,比如使用云函数 SDK 中提供的数据库和存储 API 进行数据库和存储的操作。

基础使用


需要安装的依赖

	wx-server-sdk 
    crypto 加密算法
    node-xlsx 生成表格
    nodemailer 发送邮件
    axios 请求
    cnpm wx-server-sdk crypto node-xlsx nodemailer axios -S
    cnpm安装或者npm 或者其他包管理器
复制代码

获取云数据库数据


此处查询的是昨天到今天的数据

	let  userdata = [];
	const db = cloud.database()
  	const _ = db.command
    const today = new Date().toLocaleDateString() //获取今天的年月日
	const yesterday=new Date(new Date()-24*60*60*1000).toLocaleDateString() //获取昨天的年月日
    await db.collection('你的表名').where({
      create: _.and(_.gte(new Date(yesterday + " 20:00:00")), _.lte(new Date(today + " 20:00:00")))
    }).field({
      phone: true
    }).get().then(async res => {
    	 if(res.data.length===0){
        console.log('当日无数据');
        return 
      }
    await res.data.forEach(item => {
        userdata.push(item.phone)
      })
    })
复制代码

生成Excel表格并获取下载链接


/**
 * @author Chenhongguang
 * @param {array} userdata 表格内容
 */
async function createExcel(userdata){
  const  alldata = []
  let dataCVS = `${new Date().getFullYear()}-${new Date().getMonth() + 1}-${new Date().getDate()}.xlsx`
  let row = ['手机号码']; //表属性
    alldata.push(row);
    userdata.forEach(item => {
      alldata.push([item])//表数据
    })
    //把数据保存到excel里
    const buffer =  xlsx.build([{
      name: name,
      data: alldata
    }]);
    let path = ''
    //把excel文件保存到云存储里
    await cloud.uploadFile({
      cloudPath: dataCVS,
      fileContent: buffer, //excel二进制文件
    }).then(async res => {
     await cloud.getTempFileURL({
        fileList: [res.fileID]
      }).then(res => {
        path=res.fileList[0].tempFileURL
      })
    })
    return path 
}
复制代码

调用方法 const path=createExcel(userdata)

发送邮件并添加附件


此处是QQ邮箱发送的案列 其他请参考nodemailer

/**
 * @author Chenhongguang
 * @param {string} name 邮件标题
 * @param {string} path 邮件附件链接
 */
function sendEmail(name,path){
  const transporter = nodemailer.createTransport({
    host: "smtp.qq.com",
    port: 465,
    secure: true,
   	auth: {
      user: '登录邮箱账号',
      pass: 'SMTP生成的密钥'//此处不是密码 参考QQ SMTP生成的密钥
    }
  });
  const mailOptions = {
    from: '你的邮箱', // 发送者
    to: '接收者邮箱', // 接受者,可以同时发送多个,以逗号隔开
    subject: name, // 标题
    //text: 'Hello world', // 文本
    html: `<h2>node-xlsx+nodemailer自动构建@Chenhongguang</h2>`,
    attachments: [
      {
        filename: name,
        path: path //云存储临时下载链接
      },
    ]
  };
  transporter.sendMail(mailOptions, (err, info) => {
    if (err) {
      console.log('邮件推送失败',err);
    }
    console.log('邮件推送成功');
  });
}
复制代码

发送到钉钉hook


开通钉钉群聊hook 选择自定义机器人 安全设置选择 加签并复制密钥 拿到webhook请求地址

async function sendDIngMsg(name,path){
  /**
       * 钉钉请求加签 
       * @author Chenhongguang
       * @param timestamp 当前时间戳
       * @param sign hash加密
       * @param ddData 模板数据
       * @param DDurl 加密后的请求地址
       */
      const timestamp = Date.now()
      const hmac = crypto.createHmac('sha256', '密钥')
      hmac.update(timestamp + '\n' + '密钥');
      const sign = encodeURIComponent(hmac.digest('base64'))
      const DDurl=`webhook请求地址&timestamp=${timestamp}&sign=${sign}`
      const ddData={
        "msgtype": "link", 
        "link": {
            "text": "数据构建成功", 
            "title": name, 
            "picUrl": "", 
            "messageUrl": path
        }
    }
    await  axios({
        method: "POST",
        headers: { "Content-Type": "application/json;charset=utf-8" },
        url: DDurl,
        data: ddData
     }).then(res=>{
       console.log(res);
       console.log('钉钉消息推送成功');
     }).catch(e=>{
      console.log('钉钉消息推送失败');
     })
复制代码

完整代码


// 云函数入口文件
const cloud = require('wx-server-sdk')
const crypto = require('crypto');
const xlsx = require('node-xlsx');
const nodemailer = require('nodemailer')
const axios = require("axios");
cloud.init()

const db = cloud.database()
const _ = db.command
//获取当前时间把 Date 对象的日期部分转换为字符串"2020/8/4"
const today = new Date().toLocaleDateString()
const yesterday=new Date(new Date()-24*60*60*1000).toLocaleDateString()
// 云函数入口函数
exports.main = async (event, context) => {
  let  userdata = [];

  try {
    console.log(today,yesterday);
    
    await db.collection('表名').where({
      create: _.and(_.gte(new Date(yesterday + " 20:00:00")), _.lte(new Date(today + " 20:00:00")))
    }).field({
      phone: true
    }).get().then(async res => {
      if(res.data.length===0){
        console.log('当日无数据');
        return 
      }
    await res.data.forEach(item => {
        userdata.push(item.phone)
      })
      //文件名
      const name = `${new Date().getFullYear()}-${new Date().getMonth() + 1}-${new Date().getDate()}.xlsx`
       const path=await createExcel(userdata)
       sendEmail(name,path)
       sendDIngMsg(name,path)
    })
    return '执行完成'
  } catch (e) {
    console.error(e)
  }
}
/**
 * @author Chenhongguang
 * @param {array} userdata 表格内容
 */
async function createExcel(userdata){
  const  alldata = []
  let dataCVS = `${new Date().getFullYear()}-${new Date().getMonth() + 1}-${new Date().getDate()}.xlsx`
  let row = ["开户号码"]; //表属性
    alldata.push(row);
    userdata.forEach(item => {
      alldata.push([item])
    })
    //3,把数据保存到excel里
    const buffer =  xlsx.build([{
      name: name,
      data: alldata
    }]);
    let path = ''
    //4,把excel文件保存到云存储里
    await cloud.uploadFile({
      cloudPath: dataCVS,
      fileContent: buffer, //excel二进制文件
    }).then(async res => {
     await cloud.getTempFileURL({
        fileList: [res.fileID]
      }).then(res => {
        path=res.fileList[0].tempFileURL
      })
    })
    return path 
}
/**
 * @author Chenhongguang
 * @param {string} name 邮件标题
 * @param {string} path 邮件附件链接
 */
function sendEmail(name,path){
  const transporter = nodemailer.createTransport({
    host: "smtp.qq.com",
    port: 465,
    secure: true,
    auth: {
      user: '登录邮箱账号',
      pass: 'SMTP生成的密钥'//此处不是密码 参考QQ SMTP生成的密钥
    }
  });
  const mailOptions = {
    from: '你的邮箱', // 发送者
    to: '接收者邮箱', // 接受者,可以同时发送多个,以逗号隔开
    subject: name, // 标题
    //text: 'Hello world', // 文本
    html: `<h2>node-xlsx+nodemailer自动构建@Chenhongguang</h2>`,
    attachments: [
      {
        filename: name,
        path: path
      },
    ]
  };
  transporter.sendMail(mailOptions, (err, info) => {
    if (err) {
      console.log('邮件推送失败',err);
    }
    console.log('邮件推送成功');
  });
}
/**
 * @author Chenhongguang
 * @param {string} name 钉钉title
 * @param {string} path 钉钉link网络地址
 */
async function sendDIngMsg(name,path){
  /**
       * 钉钉请求加签 
       * @author Chenhongguang
       * @param timestamp 当前时间戳
       * @param sign hash加密
       * @param ddData 模板数据
       * @param DDurl 加密后的请求地址
       */
      const timestamp = Date.now()
      const hmac = crypto.createHmac('sha256', '密钥')
      hmac.update(timestamp + '\n' + '密钥');
      const sign = encodeURIComponent(hmac.digest('base64'))
      const DDurl=`webhook请求地址&timestamp=${timestamp}&sign=${sign}`
      const ddData={
        "msgtype": "link", 
        "link": {
            "text": "数据构建成功", 
            "title": name, 
            "picUrl": "", 
            "messageUrl": path
        }
    }
    await  axios({
        method: "POST",
        headers: { "Content-Type": "application/json;charset=utf-8" },
        url: DDurl,
        data: ddData
     }).then(res=>{
       console.log(res);
       console.log('钉钉消息推送成功');
     }).catch(e=>{
      console.log('钉钉消息推送失败');
     })
}
复制代码