// 云函数入口文件
const cloud = require(‘wx-server-sdk’)

cloud.init()
let db = cloud.database({
env:“xxx”
})
const rp = require(‘request-promise’);
const URL = "http://musicapi.xiecheng.live/personalized"
const playlistCollection = db.collection(“playlist”)
// 云函数入口函数
exports.main = async (event, context) => {
let list =await playlistCollection.get()
let playlist =await rp(URL).then((res)=>{
return JSON.parse(res).result
})
const newData = []
for(let i=0, len1 = playlist.length; i < len1; i++) {
let flag = true
for(let j=0, len2 = list.data.length; j < len2; j++){
if(playlist[i].id === list.data[j].id) {
flag = false
break
}
}
if(flag){
newData.push(playlist[i])
}
}
for(let i = 0 , len = playlist.length; i < len ; i++){
await playlistCollection.add({
data:{
…playlist[i],
createTime:db.serverDate()
}
}).then((res)=>{
console.log(“success”)
}).catch((err)=>{
console.error(“err”)
})
}
return newData.length
}