notify.js

const db =  require("./Toolkits/dataBase.js");
const moment = require('moment');
const schedule = require('node-schedule');
const Telebot = require("./bot.js");
const {notify} = require("./config.js");

// 启动任务
let notifyJob = schedule.scheduleJob(notify.notifyTime, () => {
  console.log("订单通知任务"+new Date());
  let tgUsers =  new Map();
  let payType =  new Map();
  db("SELECT uid,phone FROM pay_user WHERE length(phone)>0")
  .then((users)=>{
  	users.forEach((user)=>{
  		tgUsers.set(user.uid,user.phone);
  	})
  });
  db("SELECT * FROM pay_type")
  .then((types)=>{
  	types.forEach((type)=>{
  		payType.set(type.id,type.showname);
  	})
  });
  let today = moment();
  let pretime = today.subtract(notify.time, notify.timeUnit).format('YYYY-MM-DD HH:mm:ss');
  db("SELECT * FROM pay_order WHERE endtime >= ? AND param is NULL ORDER BY trade_no ASC Limit "+notify.count
  ,[pretime])
  .then((r)=>{
  	if(r.length == 0){
  		console.log("没有异步通知任务");
  		return;
  	}
  	let tradeGroup = new Array();
  	r.forEach((s)=>{
  		tradeGroup.push(s.trade_no);
  		if(tgUsers.has(s.uid)){
			let type = payType.has(s.type)?payType.get(s.type):"";
			Telebot.bot.sendMessage(tgUsers.get(s.uid),type+"收款提醒！\n💰金额："+s.money+"\n🔗订单号:"+s.trade_no+"\n⚖️商品名:"+s.name);
  		}
  	})
  	db("UPDATE `pay_order` SET `param` = '1' WHERE trade_no in ("+tradeGroup+")")
  	.catch((e)=>{
  		console.log(e)
  	})
  })
});

let settleJob = schedule.scheduleJob(notify.settleTime, ()=>{
	console.log("结算通知任务"+new Date());
	let tgUsers =  new Map();
	db("SELECT uid,phone FROM pay_user WHERE length(phone)>0")
	.then((users)=>{
		users.forEach((user)=>{
			tgUsers.set(user.uid,user.phone);
		})
	})
	let today = moment();
	let pretime = today.format('YYYY-MM-DD 00:00:00');
	db("SELECT * FROM pay_settle where status=1 and result is null and endtime >= ?",[pretime])
	.then((r)=>{
		if(r.length == 0){
			console.log("没有结算通知任务");
			return;
		}
		let settleGroup = new Array();
		r.forEach((s)=>{
			settleGroup.push(s.id);
			if(tgUsers.has(s.uid)){
				let nmessage = Telebot.bot.sendMessage(tgUsers.get(s.uid),"📣结算提醒！\n🔗结算账户"+s.account+"\n💵实际到账金额："+s.realmoney+"\n⏰完成时间:"+s.endtime);
				nmessage.then((message)=>{
					Telebot.bot.pinChatMessage(tgUsers.get(s.uid),message.message_id);
				})
			}
		})
		db("UPDATE `pay_settle` SET `result` = '1' WHERE id in ("+settleGroup+")")
		.catch((e)=>{
			console.log(e)
		})
	})
	
});
module.exports = {notifyJob,settleJob};