var express = require("express");
var request = require('request');
var fs = require('fs');
var router = express.Router();
var _ = require("lodash");
var Opus = require("../models/index").Opus;
var Chapter = require("../models/index").Chapter;
var Picture = require("../models/index").Picture;
var gm = require("gm");var BosClient = require("bce-sdk-js").BosClient;const config = {endpoint: "https://bj.bcebos.com",   //传入Bucket所在区域域名
    credentials: {ak: "AccessKey",         //您的AccessKeysk: "SecretAccessKey"    //您的SecretAccessKey
    }
};var client = new BosClient(config);/*** 啥都没有*/
router.get("/", function (req, res, next) {res.send({message: "成功",stateCode: 0});
});/*** 添加一个漫画*/
router.get("/add", function (req, res, next) {Opus.create({name: "七龙珠",summary: "很久很久以前，地球上散落着七颗神奇的龙珠，传说只要聚齐它们，神龙就会出现，并可以为人实现一个愿望。为了寻找龙珠，布尔玛和孙悟空踏上了奇妙的寻珠之旅……",author: "鸟山明",cover: "http://iconan.bj.bcebos.com/2%2Fcover.jpg",type: 0,popularity: 0,score: 100,createtime: new Date(),updatetime: new Date()}).then(function () {console.info("插入数据完成");});res.send({message: "成功",stateCode: 0});
});/*** 重命名temp文件夹下除ok外所有文件夹*/
router.get("/rename", function (req, res, next) {fs.readdir("temp", function (err, files) {for (var key in files) {var dirname = files[key];if (dirname != "ok") {fs.renameSync("temp/" + dirname, "temp/第" + dirname.match(/龍珠完全版Vol_(\d+)/)[1] + "卷");}}});res.send({message: "成功",stateCode: 0});
});/*** 开始处理temp下所有文件夹*/
router.get("/start", function (req, res, next) {//需要手动修改为当前漫画idvar opusid = 2;var chapterid = 1;var chapterPosition = 0;fs.readdir("temp", function (err, files) {console.info(files);var dirFoo = [];for (var key in files) {var chaptername = files[key];if (chaptername != "ok") {dirFoo.push(function () {return new Promise(function (resolve, reject) {console.info("开始处理章节", chaptername);Chapter.create({opusid: opusid,name: chaptername,type: 0,position: chapterPosition++,createtime: new Date(),updatetime: new Date()}).then(function (model) {console.info("插入数据完成", model.dataValues);chapterid = model.dataValues.id;fs.readdir("temp/" + chaptername, function (err, files) {var pathUrl = "temp/ok/";var num = 0;var fooArr = [];fooArr.push(function () {return new Promise(function (resolve, reject) {fs.readdir("temp/ok", function (err, files) {for (var key in files) {fs.unlinkSync("temp/ok/" + files[key]);}resolve();});})});for (var key in files) {var fileName = files[key];console.info(fileName);fooArr.push(function () {return new Promise(function (resolve, reject) {var img = gm("temp/" + chaptername + "/" + fileName);//获取图片尺寸img.size(function (err, size) {//如果图片是横向长方形，那么就从中间裁切成2张单独的图片if (size.width / size.height > 1) {img.crop(Math.floor(size.width / 2), size.height, Math.floor(size.width / 2), 0).write(pathUrl + "p" + fill(num++, 4) + ".jpg", function (err) {err && console.info(err);//第二张图片在第一张裁切完再进行img.crop(Math.floor(size.width / 2), size.height, 0, 0).write(pathUrl + "p" + fill(num++, 4) + ".jpg", function (err) {err && console.info(err);resolve();});});}else {img.write(pathUrl + "p" + fill(num++, 4) + ".jpg", function (err) {err && console.info(err);resolve();});}});})})}//顺序同步执行fooArr里的方法reduce(fooArr).then(function () {console.info("裁切完成，开始上传");//清空方法数组fooArr.length = 0;var picturePosition = 0;//完成后上传fs.readdir("temp/ok", function (err, files) {for (var key in files) {var fileName = files[key];if (/^p\d+.jpg$/.test(fileName)) {console.info(fileName);fooArr.push(function () {return new Promise(function (resolve, reject) {console.info("开始上传");//获取图片尺寸gm(pathUrl + fileName).size(function (err, size) {var upFileName = opusid + "/" + chapterid + "/" + Date.now() + ".jpg";console.info(upFileName);//以文件形式上传client.putObjectFromFile("iconan", upFileName, pathUrl + fileName).then(function () {Picture.create({chapterid: chapterid,url: "http://iconan.bj.bcebos.com/" + upFileName,width: size.width,height: size.height,type: 0,position: picturePosition++,createtime: new Date(),updatetime: new Date()}).then(function () {console.info("插入数据完成");resolve();});}).catch(function () {console.info("上传失败", arguments);reject();});});})});}}reduce(fooArr).then(function () {console.info("上传完成");resolve();});});})});});})});}}reduce(dirFoo).then(function () {console.info("最终完成");})});res.send({message: "正在操作中，请在控制台查看进度",stateCode: 0});
});/*** 将数字补位* @param num 需要补位的数字* @param n 需要多少位* @returns {string}*/
function fill(num, n) {return (Array(n).join(0) + num).slice(-n);
}/*** 让一个promise的数组顺序执行*/
function reduce(arr) {var sequence = Promise.resolve();arr.forEach(function (item) {sequence = sequence.then(item)});return sequence
}module.exports = router;