package com.jws.app.operater.service.impl;

import java.io.File;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileItemFactory;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import org.apache.log4j.Logger;
import org.springframework.stereotype.Service;

import net.sf.json.JSONObject;

import com.jws.app.operater.data.UserInfoMapper;
import com.jws.app.operater.model.UserInfo;
import com.jws.app.operater.service.PersionPhoteAuthServer;
import com.jws.common.constant.Constants;
import com.jws.common.constant.ConstantsCode;
import com.jws.common.util.JiveGlobe;
import com.jws.common.util.ResultPackaging;

@Service("persionPhoteAuthServerImpl")
public class PersionPhoteAuthServerImpl implements PersionPhoteAuthServer {
    @Resource
    private UserInfoMapper userInfoMapper;
    private final Logger logger = Logger.getLogger(this.getClass());

    @Override
    public JSONObject uploadPhoto(HttpServletRequest reques) {
        JSONObject returnObject = new JSONObject();
        String path =  Constants.imageUrl;
        File repositoryFile = new File(path);
        if (!repositoryFile.exists()) {repositoryFile.mkdirs();}
        FileItemFactory factory = new DiskFileItemFactory(1024 * 32,repositoryFile);
        ServletFileUpload upload = new ServletFileUpload(factory);
        upload.setHeaderEncoding("utf-8");
        upload.setSizeMax(1024 * 1024 * 500);
        List<?> fileItr = null;
        try {
             fileItr = upload.parseRequest(reques);
                // 讲非文件值放在map中
                HashMap<String, String> map = new HashMap<>();
                Iterator<?> iter = fileItr.iterator();
                while (iter.hasNext()) {
                    FileItem item = (FileItem) iter.next();
                    if (item.isFormField()) {
                        map.put(item.getFieldName(), item.getString());
                    }
                }
                // 验证参数
                if (map == null || !map.containsKey("openid")) {
                    returnObject =ResultPackaging.dealJsonObject(ConstantsCode.RESULT_CODE_FAIL, ConstantsCode.CODE_LACK_PARAMETER, null);
                    return returnObject;            
                }
                String openid  = map.get("openid");
                //处理文件
                boolean isTrue = true;
                String filename = "";
                Iterator<?> iter1 = fileItr.iterator();
                while (iter1.hasNext()) {
                    FileItem f = (FileItem) iter1.next();
                    if (!f.isFormField()) {
                //详情 name=abc.png,  size=376507 bytes,     isFormField=false, FieldName=picture1
                        filename = f.getName() == null ? "" : f.getName();
                        filename = JiveGlobe.getFromRom()+".jpg";
                        File saveFile = new File(path, filename);
                        if (saveFile.exists()) {
                            isTrue = false;break;}
                            f.write(saveFile);
                        } 
            }
            if(JiveGlobe.isEmpty(filename)){
                returnObject =ResultPackaging.dealJsonObject(ConstantsCode.RESULT_CODE_FAIL, ConstantsCode.CODE_LACK_PARAMETER, null);
                return returnObject;            
            }
            returnObject =ResultPackaging.dealJsonObject(ConstantsCode.RESULT_CODE_SUCCESS, ConstantsCode.RESULT_CODE_SUCCESS, null);
            //保存文件信息
            UserInfo rd = new UserInfo();
            rd.setSpareField1("1");
            rd.setSpareField3(filename);
            rd.setOpenId(openid);
            userInfoMapper.updateByPrimaryKey(rd);
        } catch (Exception e) {
            System.out.println(e);
            logger.error("###认证失败"+e);
        }
        return returnObject;
    }
    
    
}

@RequestMapping("/upload")
    @ResponseBody
    public String handleFileUpload(@RequestParam("file") MultipartFile file) {

        if (file.isEmpty()) {
            return "文件为空";
        }
        // 获取文件名
        String fileName = file.getOriginalFilename();
        System.out.println("上传的文件名为：" + fileName);
        // 获取文件的后缀名
        String suffixName = fileName.substring(fileName.lastIndexOf("."));
        System.out.println("上传的后缀名为：" + suffixName);
        // 文件上传后的路径
        String filePath = "D://";
        File dest = new File(filePath + fileName);
        // 检测是否存在目录
        if (!dest.getParentFile().exists()) {
            dest.getParentFile().mkdirs();
        }
        try {
            file.transferTo(dest);
            return "上传成功";
        } catch (IllegalStateException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return "上传失败";
    }

/**
     * 多文件具体上传时间，主要是使用了MultipartHttpServletRequest和MultipartFile
     * 
     * @param request
     * @return
     */
    @RequestMapping(value = "/batch/upload", method = RequestMethod.POST)
    public @ResponseBody String handleFileUpload1(HttpServletRequest request) {
        List<MultipartFile> files = ((MultipartHttpServletRequest) request).getFiles("file");
        String filePath = "D://";
        MultipartFile file = null;

        for (int i = 0; i < files.size(); ++i) {
            file = files.get(i);
            // 获取文件名
            String fileName = file.getOriginalFilename();
            System.out.println("上传的文件名为：" + fileName);

            if (!file.isEmpty()) {
                File dest = new File(filePath + fileName);
                // 检测是否存在目录
                if (!dest.getParentFile().exists()) {
                    dest.getParentFile().mkdirs();
                }
                try {
                    file.transferTo(dest);
                } catch (Exception e) {
                    return "上传失败 " + i + " => " + e.getMessage();
                }
            } else {
                return "上传失败 " + i + " 文件为空.";
            }
        }
        return "上传成功";
    }