var request = require('request');
var _ = require('lodash');
var fs = require('fs');
var http = require('http');

var config=global.global.Register;

var Utils={
 	objectToUrl:function(items){
 		var urls=[];
 		for(var name in items){
 			if(items.hasOwnProperty(name)&&items[name]){
 				// if(items[name]!=="undefined"){
 					urls.push(name+"="+items[name]);
 				// }
 			}
 		}
 		return urls.join('&');
 	},
 	createHttpHeader:function(req){
	    if (req.session && req.session.user) {
	        return {
	            'x-user-id': req.session.user.auth.pid,
	            'x-user-name': req.session.user.auth.account,
	            'x-site-type': 1,
	            'x-client-ip': req.ip,
	            'x-shop-id':req.session.user.auth.shopId
	            
	        };
	    } 
	},
	joinImg:function(url) {
	    var urlArr = url.split('/');
	    var domain = 'static.yhbimg.com/goodsimg';
	    var num = urlArr[urlArr.length - 1].substr(1, 1);
	    var url1 = domain + url;
	    if (num == 1) {
	        return 'http://img11.' + url1;
	    } else {
	        return 'http://img12.' + url1;
	    }
	}
 }

module.exports={
 	namespace:"common",
 	apis:{
 		multipart:function(req, callback){
 			var result={code: "500",message: "接口异常"};
 			var httpHeader=Utils.createHttpHeader(req);
 			if(!httpHeader){
                result = { code: "501", message: "用户失效,请重新登录" };
 				return callback(null, result);
 			}
 			var body=req.body;
 			if(body.__type == "batch-import"){
 				var url=Utils.objectToUrl(body);
 				body.file = fs.createReadStream(req.files[body.filename].path);
 				request.post({
	                url: config.domain + '/batch/import?' + url,
	                formData: body,
	                headers: httpHeader
	            }, function optionalCallback(error, httpResponse, rebody) {
	                if (!error && httpResponse.statusCode == 200) {
	                    result = JSON.parse(rebody);
	                    result.status = true;
	                }
	                return callback(null, result);
	            });
 			}else{
 				var files = req.files[req.body.filename];
	            //判断是单张传还是多张传
	            var flag = Object.prototype.toString.call(files) === '[object Array]';
	            //如果是单张，则数组化
	            if (!flag) {
	                files = [];
	                files.push(req.files[req.body.filename]);
	            }
	            req.body.files = [];
	            req.body.fileNames = [];
	            for (var index = 0; index < files.length; index++) {
	                req.body.files[index] = fs.createReadStream(files[index].path);
	                req.body.fileNames[index] = files[index].name;
	            }
 				if (req.body.bucket === 'goodsimg') {
		            request.post({
		                url: "http://upload.static.yohobuy.com",
		                formData: {
		                    fileData: req.body.files,
		                    project: req.body.bucket
		                }
		            }, function (error, httpResponse, rebody) {
		                if (!error && httpResponse.statusCode == 200) {
		                    var ret = JSON.parse(rebody);
	                        var imgs = ret.data.imagesList || [];
	                        var datas = [];
	                        for (var i = 0; i < imgs.length; i++) {
	                            datas.push(Utils.joinImg(imgs[i]))
	                        }
	                        result={
	                            code: 200,
	                            data: datas[0],
	                            datas:datas,
	                            names: req.body.fileNames,
	                            message: '上传成功',
	                            status: true
	                        };
		                }
		               return callback(null, result);
		            });
		        } else {
		            req.body.file = fs.createReadStream(req.files[req.body.filename].path);
		            request.post({
		                url: config.domain + '/fileupload/upload',
		                formData: req.body
		            }, function optionalCallback(error, httpResponse, rebody) {
		                if (!error && httpResponse.statusCode == 200) {
		                    result = JSON.parse(rebody);
		                    result.status = true;
 		                } 
		                return callback(null, result);
		            });
		        }
 			}
 		},
 		baiduUeditor:function(req, callback){
 			var result={code: "500",message: "接口异常"};
 			var httpHeader=Utils.createHttpHeader(req);
 			if(!httpHeader){
 				result={code: "501",message: "用户失效,请重新登录"};
 				return callback(null, result);
 			}
 			req.body.file = fs.createReadStream(req.files.upfile.path);
	        req.body.bucket="goodsimg";
	        request.post({
	                url: config.domain + '/fileupload/upload',
	                formData: req.body
	        }, function optionalCallback(error, httpResponse, rebody) {
	            if (!error && httpResponse.statusCode == 200) {
	                var json = JSON.parse(rebody);
	                result={};
	                result.originalName=json.data.substring(json.data.lastIndexOf('/')+1);
	                result.name=result.originalName;
	                result.url=json.data;
	                result.type=json.data.substring(json.data.lastIndexOf('.'));
	                result.state=json.message=="上传成功"?"SUCCESS":"FAIL";
	            }
	            return callback(null, result);
	        });
 		},
 		downExcel:function(req, callback){
            var result = request.get(config.domain + "/common/" + req.params.name + ".xlsx");
            return callback(null, result);
 		},
 		exportExcel:function(req, callback){
            var result = request({
		    	method: 'POST',
		        url: config.domain + '/batch/export',
		        headers: {
		            'content-type': 'application/json'
		        },
		        body: req.query,
		        json: true
            });
            return callback(null, result);
 		},
 		proxy:function(req, callback){
 			var httpHeader = Utils.createHttpHeader(req);
 			if(!httpHeader){
 				return null;
 			}
		    httpHeader['Content-Type'] = 'application/json';
		    
            var result=request({
		        headers:headers,
		        url:global.config.domain + req.query.url,
		        body:JSON.stringify(req.body)
            });
            return callback(null, result)
 		}

 	}
 }