fileUp.uploadXlsx = async function(params) {
try {
var fileName = params['fileName'];
var filePath = params['path'];
var fileType = params['fileType'];
console.log(fileName + ':' + fileType);
if( filePath != null && filePath != undefined) {
var sheets = xlsx.parse(filePath, { cellDates: true });
// var arr = [];
//sheets是一个数组,数组中的每一项对应test.xlsx这个文件里的多个表格,如sheets[0]对应test.xlsx里的“测试参数”这个表格,sheets[1]对应Sheet2这个表格
var sheet = sheets[0]
var newSheetsArr = [];
//sheet是一个json对象,格式为{name:"测试参数",data:[]},我们想要的数据就存储在data里
for(var i=1; i 0){
console.log("row",row)
//手机号码正则
if((/^1[3456789]d{9}$/.test(row[1]))&&row[0]>0&&row[2]){
//判断手机号是否存在,存在返回id,不存在创建用户并返回id
let userid = 0
let users = await daoUser.getByPhone(row[1])
if(users&&users.length>0){
userid = users[0].id;
await daoPoster.addComment([userid,row[0],row[2],row[3]])
}else{
//根据手机号码创建新用户
var dateNow = moment().utc().add(480,"minutes").toDate();
let addUserResult = await daoUser.addUser([row[1],row[1],dateNow]);
console.log("addUserResult",addUserResult)
if (addUserResult && addUserResult.insertId != 0){
userid=addUserResult.insertId;
await daoPoster.addComment([userid,row[0],row[2],row[3]])
}else{
console.log("添加用户失败,未取到userid")
return resultApi.helper(resultMsg.SYSTEM_ERROR.code,resultMsg.SYSTEM_ERROR.message);
}
}
//更新日活
await posterController.updateUserInteract(userid);
}else{
console.log("数据校验失败",row)
}
//否则数据跳过
}
}
// arr.push(newSheetsArr);
// console.log("arr",arr)
// sheets.forEach(function(sheet){
// });
return resultApi.helper(resultMsg.SUCCESS.code,resultMsg.SUCCESS.message);
}
} catch (error) {
console.log("error",error)
return resultApi.helper(resultMsg.SYSTEM_ERROR.code,resultMsg.SYSTEM_ERROR.message);
}
}