package com.landtool.lanbase.modules.res.controller;

import java.io.File;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.UUID;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.io.FileUtils;
import org.apache.commons.lang.StringEscapeUtils;
import org.apache.shiro.SecurityUtils;
import org.jsoup.Jsoup;
import org.jsoup.nodes.Document;
import org.jsoup.select.Elements;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.landtool.lanbase.common.annotation.LogAction;
import com.landtool.lanbase.common.utils.HttpOperateUtils;
import com.landtool.lanbase.config.SysTemPropertyConfig;
import com.landtool.lanbase.modules.api.utils.DeleteFileUtils;
import com.landtool.lanbase.modules.res.entity.Res_ExtDataSource;
import com.landtool.lanbase.modules.res.entity.Res_ExtFileSource;
import com.landtool.lanbase.modules.res.entity.Res_FileSource_Way;
import com.landtool.lanbase.modules.res.entity.Res_MainInfo;
import com.landtool.lanbase.modules.res.entity.Res_StorageConfig;
import com.landtool.lanbase.modules.res.entity.Res_Storage_Relation;
import com.landtool.lanbase.modules.res.entity.JSONModels.NcConfig;
import com.landtool.lanbase.modules.res.entity.JSONModels.NcMessage;
import com.landtool.lanbase.modules.res.entity.ViewModels.FileSourceList;
import com.landtool.lanbase.modules.res.service.ResExtDataSourceService;
import com.landtool.lanbase.modules.res.service.ResExtFileSourceService;
import com.landtool.lanbase.modules.res.service.ResFileSourceWayService;
import com.landtool.lanbase.modules.res.service.ResMainInfoService;
import com.landtool.lanbase.modules.res.service.ResStorageConfigService;
import com.landtool.lanbase.modules.res.service.ResStorageRelaTionService;
import com.landtool.lanbase.modules.sys.service.SysFieldvalueService;

import cn.hutool.json.JSONUtil;

/**
 * @Author: lizhao
 * @Date: 2018-03-06 14:49
 * @Description:11系统资源扩展(文档数据)(RES_EXTFILESOURCE)
 */
@Controller
@RequestMapping("/res")
public class ResExtFileSourceController {
    @Autowired
    private ResExtFileSourceService resExtFileSourceService;

    @Autowired
    private SysTemPropertyConfig sysConfig;

    @Autowired
    private ResMainInfoService resMainInfoService;

    @Autowired
    private ResFileSourceWayService resFileSourceWayService;

    @Autowired
    private SysFieldvalueService FieldUtils;
    
    @Autowired
	private ResStorageConfigService resStorageConfigService;
    
    @Autowired
	private ResStorageRelaTionService resStorageRelaTionService;
    
    @Autowired
	private ResExtDataSourceService resExtDataSourceService;

    private String wenjianjiaPath() {
        return sysConfig.getUploadPath() + "FileSource\\wenjianjia\\";
    }

    private String wenjianPath() {
        return sysConfig.getUploadPath() + "FileSource\\wenjian\\";
    }

    /**
     * 访问资源文档数据图层信息页面
     */
    @RequestMapping("/ResManage/ResRegister/ExtFileSource")
    public String ExtFileSource(int resMainInfoId, Model model) {
        String unit = "";
        Res_ExtFileSource resExtFileSource = resExtFileSourceService.selectByPrimaryKey(resMainInfoId);
        if (resExtFileSource != null) {
            model.addAttribute("Res_ExtFileSource", resExtFileSource);
            model.addAttribute("resMainInfoId", resMainInfoId);
            model.addAttribute("uploadPath", resExtFileSource.getServerurl());
    		model.addAttribute("absolutePath", sysConfig.getUploadPath()+resExtFileSource.getServerurl());
            //判断是否有大小
            if (resExtFileSource.getFilesize() != null) {
                String unitConvert = resExtFileSource.getFilesize() < 1 ? "1" : (resExtFileSource.getFilesize() < 1024 ? "2" : (resExtFileSource.getFilesize() < 1024 * 1024 ? "3" : "4"));
                model.addAttribute("unitConvert", unitConvert);
                switch (unitConvert) {
                    case "1":
                        unit = "bytes";
                        break;
                    case "2":
                        unit = "KB";
                        break;
                    case "3":
                        unit = "MB";
                        break;
                    case "4":
                        unit = "GB";
                        break;
                }
            } else {
                String unitConvert = "5";
                model.addAttribute("unitConvert", unitConvert);
            }
            Res_MainInfo res_mainInfo = resMainInfoService.selectByPrimaryKey(resMainInfoId);
            model.addAttribute("resMainInfo", res_mainInfo);

            // 文件夹
            if (resExtFileSource.getSourcetype() != null && resExtFileSource.getSourcetype().equals("文件夹")) {
                if (resExtFileSource.getServerurl() != null && resExtFileSource.getStoragemode() != null && resExtFileSource.getStoragemode().equals("本地")) {
                    File file = new File(sysConfig.getUploadPath() + resExtFileSource.getServerurl());
                    if (file.isDirectory()) {
                        System.out.println(resExtFileSource.getServerurl());
                        String[] fileLists = file.list();
                        File[] files = file.listFiles();
                        List <FileSourceList> fileSourceLists = new ArrayList <>();
                        for (int i = 0; i < fileLists.length; i++) {
                            File file1 = new File(fileLists[i]);
                            File file2 = new File(files[i].getAbsolutePath());
                            String size = com.landtool.lanbase.common.utils.FileUtils.setSize(file2.length());
                            String path2 = wenjianjiaPath() + file1.getName(); // 文件映射路径
                            FileSourceList sourceList = new FileSourceList();
                            sourceList.setName(file1.getName());
                            sourceList.setPath(path2);
                            sourceList.setSize(size);
                            Res_Storage_Relation res_Storage_Relation = new Res_Storage_Relation();
                            res_Storage_Relation.setResourceid(resMainInfoId);
                            res_Storage_Relation.setFilename(file1.getName());
                            Res_Storage_Relation resStorageRelation = resStorageRelaTionService.selectByResourceidAndFileName(res_Storage_Relation);
                            if(resStorageRelation!=null && resStorageRelation.getIsstorage()==1){
                            	sourceList.setStorageConfig("已入库");
                            }else{
                            	sourceList.setStorageConfig("未入库");
                            }
                            
                            if(resStorageRelation!=null && resStorageRelation.getIsgeneration()==1){
                            	sourceList.setNcjson("已生成");
                            }else{
                            	sourceList.setNcjson("未生成");
                            }
                            fileSourceLists.add(sourceList);
                        }
                        model.addAttribute("filelist", fileSourceLists);
                    }
                }
            }
        } else {
            model.addAttribute("unitConvert", "5");
            unit = "KB";
            Res_ExtFileSource resExtFileSource1 = new Res_ExtFileSource();
            model.addAttribute("Res_ExtFileSource", resExtFileSource1);
            model.addAttribute("resMainInfo", new Res_MainInfo());
        }

        model.addAttribute("unit", unit);
        // 获取文档类型列表
        LinkedHashMap <String, String> filetypelist = FieldUtils.getFieldListByKey("FileType");
        model.addAttribute("filetypelist", filetypelist);

        if (SecurityUtils.getSubject().isPermitted("org_user_admin")) {
            //判断当前用户是否是管理员，是管理员或是未提交的资源才可以修改资源相关信息
            model.addAttribute("admin", true);
        } else {
            model.addAttribute("admin", false);
        }
        model.addAttribute("ncSyncStorageUrl", sysConfig.getNcStorageUrl().substring(0, sysConfig.getNcStorageUrl().length()-9)+"jobs/");
        model.addAttribute("readNcFileURL", sysConfig.getReadNcFileURL());
        return "ResManage/ResRegister/ExtFileSource";
    }

    /**
     * 数据文件下的 展现方式
     */
    @RequestMapping("/ResManage/ResRegister/ExtPresentationMode")
    public String ExtPresentationMode(int resMainInfoId, Model model) {
        model.addAttribute("resMainInfoId", resMainInfoId);
        List <Res_FileSource_Way> list = resFileSourceWayService.selectById(resMainInfoId);
        model.addAttribute("FileSourceWay", list);
        return "ResManage/ResRegister/ExtPresentationMode";
    }

    /**
     * 添加或者更新 数据文件展现方式
     */
    @ResponseBody
    @RequestMapping("/ResManage/ResRegister/insertSelectiveAndUpdate")
    @LogAction("资源管理,资源发布,资源修改,修改|zy")
    public int insertSelectiveAndUpdate(Res_MainInfo resMainInfo, String extMapUrlStr) {
        // 删除id 对应的所有文件展示方式
        try {
            if (resMainInfo.getResourceid() != null) {
                resFileSourceWayService.deleteByPrimaryKey(resMainInfo.getResourceid());
            }
            if (!extMapUrlStr.equals("")) {
                String[] extMapUrlArray = extMapUrlStr.split("\\|");
                // 插入资源支持协议与地址表
                for (int i = 0; i < extMapUrlArray.length; i++) {
                    String[] extMapUrlArray2 = extMapUrlArray[i].split(",");
                    String Showway = extMapUrlArray2[0];
                    String url = extMapUrlArray2[1];
                    String remark = extMapUrlArray2[2];
                    Res_FileSource_Way resFileSourceWay = new Res_FileSource_Way();
                    resFileSourceWay.setShowway(Showway);
                    resFileSourceWay.setUrl(url);
                    resFileSourceWay.setRemark(remark);
                    resFileSourceWay.setResourceid(resMainInfo.getResourceid());
                    resFileSourceWay.setCreatedate(new Date());
                    resFileSourceWayService.insertSelective(resFileSourceWay);
                }
            }
            return 1;
        } catch (Exception e) {
            return 0;
        }
    }


    /**
     * 根据id 删除文档数据列表功能
     */
    @ResponseBody
    @RequestMapping("/resExtFileSource/deleteByPrimaryKey")
    public int deleteByPrimaryKey(int resourceid) {

        // 删除数据库信息先把文件删除
        Res_ExtFileSource res_extFileSource = resExtFileSourceService.selectByPrimaryKey(resourceid);
        String path = res_extFileSource.getServerurl();
        if (res_extFileSource.getSourcetype().equals("文件夹")) {
            //alert by ykm 2019/08/30 有的路径已经包含了文件夹还是文件目录
            if(path.indexOf("wenjianjia") == -1) {
                path = wenjianjiaPath() + path + "/";
            }
            else {
                path = sysConfig.getUploadPath() + path + "/";
            }
        }
        if (res_extFileSource.getSourcetype().equals("文件")) {
            //alert by ykm 2019/08/30 有的路径已经包含了文件夹还是文件目录
            if (path.indexOf("wenjian") == -1) {
                path = wenjianPath() + path;
            }
            else {
                path = sysConfig.getUploadPath() + path;
            }
        }
        DeleteFileUtils.deletefileUtils(path);
        return resExtFileSourceService.deleteByPrimaryKey(resourceid);
    }

    /**
     * 插入文档数据列表功能(所有元素不能为空)
     */
    @ResponseBody
    @RequestMapping("/resExtFileSource/insert")
    public int insert(Res_ExtFileSource record) {
        return resExtFileSourceService.insert(record);
    }

    /**
     * 插入文档数据列表功能(可以只填写必填字段)
     */
    @ResponseBody
    @RequestMapping("/resExtFileSource/insertSelective")
    public int insertSelective(Res_ExtFileSource record) {
        return resExtFileSourceService.insertSelective(record);
    }

    /**
     * 插入文档数据列表功能(可以只填写必填字段)
     */
    @ResponseBody
    @RequestMapping("/resExtFileSource/insertSelectiveAndUpdate")
    public int insertSelectiveAndUpdate(Res_ExtFileSource record, double savedsizenum) {
        record.setFilesize(savedsizenum);
        record.setServerurl(StringEscapeUtils.unescapeHtml(record.getServerurl()));
        Res_ExtFileSource resExtFileSource = resExtFileSourceService.selectByPrimaryKey(record.getResourceid());
        if (resExtFileSource == null) {
            // 添加
            if (record.getDownloadmodel().equals("FTP")) { // 把不属于FTP的字段设置为空
                record.setGettype(null);
            } else if (record.getDownloadmodel().equals("HTTP")) {
                record.setFtpusername(null);
                record.setFtppwd(null);
            }
            if (record.getSourcetype().equals("文件")) {
                TiHuanLuJin(record.getServerurl());
                record.setServerurl(record.getServerurl().replace("temp/", ""));
            }
            return resExtFileSourceService.insertSelective(record);
        } else {
            // 更新
            if (record.getSourcetype().equals("文件")) {
                TiHuanLuJin(record.getServerurl());
                if (!record.getServerurl().equals("") && !resExtFileSource.getServerurl().equals("") && resExtFileSource.getStoragemode().equals("本地")) {
                    String path = resExtFileSource.getServerurl();
                    path = sysConfig.getUploadPath() + path;
                    File file = new File(path);
                    if (file.exists()) {
                        DelectEquealFile(record.getServerurl(), resExtFileSource.getServerurl());
                    }
                }
                record.setServerurl(record.getServerurl().replace("temp/", ""));
            }
            if (record.getDownloadmodel().equals("FTP")) {
                record.setGettype(null);
            } else if (record.getDownloadmodel().equals("HTTP")) {
                record.setFtpusername(null);
                record.setFtppwd(null);
            }
            // 如果文件资源类型改变则把原有的文件删除
            if (!record.getSourcetype().equals(resExtFileSource.getSourcetype()) || record.getStoragemode().equals("远程")) {
                String path = resExtFileSource.getServerurl();
                if (resExtFileSource.getSourcetype().equals("文件夹") && resExtFileSource.getStoragemode() != null && resExtFileSource.getStoragemode().equals("本地")) {
                    path = sysConfig.getUploadPath() + path;
                    File file = new File(path);
                    if (file.exists()) {
                        DeleteFileUtils.deletefileUtils(path);
                    }
                }
                if (resExtFileSource.getSourcetype().equals("文件") && resExtFileSource.getStoragemode() != null && resExtFileSource.getStoragemode().equals("本地")) {
                    path = sysConfig.getUploadPath() + path;
                    File file = new File(path);
                    if (file.exists()) {
                        DeleteFileUtils.deletefileUtils(path);
                    }
                }
            }
            return resExtFileSourceService.updateByPrimaryKey(record);
        }
    }

    //删除相同文件
    private void DelectEquealFile(@RequestBody String NEWString, String OLDString) {
        String oldourl = OLDString.substring(OLDString.lastIndexOf("/"), OLDString.length());
        String newurl = NEWString.substring(NEWString.lastIndexOf("/"), NEWString.length());
        if (!oldourl.equals(newurl)) {

            File OLDFile = new File(sysConfig.getUploadPath() + OLDString.replace("/", "\\"));
            System.out.println(OLDFile);
            OLDFile.delete();
        }
    }

    //替换路径
    private void TiHuanLuJin(@RequestBody String lujin) {
        String oldFileUrl = sysConfig.getUploadPath() + lujin.replace("/", "\\");
        File oldFile = new File(oldFileUrl);
        String NewFileUrl = sysConfig.getUploadPath() + lujin.replace("temp", "").replace("/", "\\");
        NewFileUrl = NewFileUrl.substring(0, NewFileUrl.lastIndexOf("\\")) + "\\";
        File NewFile = new File(NewFileUrl);
        if (!NewFile.exists()) { // 当前地址不为空，判断该路径是否存在，不存在则创建新的文件夹
            File newfilePath = new File(NewFile + "\\"); // 创建对应的年月文件夹
            newfilePath.mkdirs();
        }
        com.landtool.lanbase.common.utils.FileUtils.moveTotherFolders(oldFileUrl, NewFileUrl);
    }

    /**
     * 根据id查询文档数据列表
     */
    @ResponseBody
    @RequestMapping("/resExtFileSource/selectByPrimaryKey")
    public Res_ExtFileSource selectByPrimaryKey(int resourceid) {
        return resExtFileSourceService.selectByPrimaryKey(resourceid);
    }

    /**
     * 根据id更新文档数据列表(更新部分数据)
     */
    @ResponseBody
    @RequestMapping("/resExtFileSource/updateByPrimaryKeySelective")
    public int updateByPrimaryKeySelective(Res_ExtFileSource record) {
        return resExtFileSourceService.updateByPrimaryKeySelective(record);
    }

    /**
     * 根据id更新文档数据列表(更新所有数据)
     */
    @ResponseBody
    @RequestMapping("/resExtFileSource/updateByPrimaryKey")
    public int updateByPrimaryKey(Res_ExtFileSource record) {
        return resExtFileSourceService.updateByPrimaryKey(record);
    }

    /** 文件上传 */
    /**
     * @param sourcetype 文件资源类型
     * @return resourceid 资源ID
     * @Description:
     * @author ykm
     * @date 2018/4/19
     */
    @ResponseBody
    @RequestMapping("/resExtFileSource/uploadfile")
    public String uploadfile(@RequestParam("myFile") MultipartFile[] file, String sourcetype, String resourceid) {

        String thisSize = ""; // 当前文件大小
        String Filename = null;// 文件名称
        List Filenames = new ArrayList();// 文件名称总和
        List finasizes = new ArrayList();
        String name = ""; // 文件全称（上传时候的文件名称）
        String res = "";
        long size = 0; // 文件大小
        long totalSize = 0; //批量上传文件大小和
        for (int i = 0; i < file.length; i++) {
            if (file[i].isEmpty()) {
                return "No File";
            }
            String uuid = UUID.randomUUID().toString().replaceAll("-", "");

            name = file[i].getOriginalFilename();
            String Fname = name.trim().substring(name.lastIndexOf("\\") + 1);

            String fileType = name.substring(name.lastIndexOf("."));
            size = file[i].getSize();
            totalSize += size;

            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM");
            String timePath = sdf.format(new Date().getTime());
            timePath = timePath.replace("-", "");
            File desFile = null;
            String path2 = null;
            String webpath = null; // 映射地址
            boolean rename = false; // 检查是否存在文件名相同的文件
            //alter: Xxx 处理资源向导数据文件资源文件上传问题 20181226
            Res_ExtFileSource resExtFileSource = new Res_ExtFileSource();
            if(resourceid != null && !resourceid.isEmpty()) {
                resExtFileSource = resExtFileSourceService.selectByPrimaryKey(Integer.parseInt(resourceid));
            }
            String path = null;
            if (sourcetype.equals("文件夹")) {
                Filename = Fname;

                if (resExtFileSource != null && resExtFileSource.getServerurl() != null) { // 判断数据库服务地址字段是否为空
                    path = sysConfig.getUploadPath() + resExtFileSource.getServerurl().replaceAll("/", "\\\\");
                    File filePath = new File(path);
                    File[] files = filePath.listFiles();
                    if (filePath.isDirectory()) {
                        String[] fileLists = filePath.list();
                        for (int j = 0; j < fileLists.length; j++) {
                            File file1 = new File(fileLists[j]);
                            if (Filename.equals(file1.getName())) {
                                rename = true;
                                break;
                            }
                        }
                    }
                    if (!rename) {
                        if (!filePath.exists()) { // 当前数据库服务地址不为空，判断该路径是否存在，不存在则创建新的文件夹
                            path = sysConfig.getUploadPath() + "FileSource\\wenjianjia\\" + timePath + "\\" + resourceid + "\\";
                            File newfilePath = new File(path); // 创建对应的年月文件夹
                            newfilePath.mkdirs();
                            webpath = "FileSource/wenjianjia/" + timePath + "/" + resourceid;
                        } else {
                            webpath = "FileSource/wenjianjia/" + timePath + "/" + resourceid; // 类型为文件夹则指向到文件夹
                        }
                    }
                } else { // 当前数据库服务地址为空，则直接创建新的文件夹
                    path = sysConfig.getUploadPath() + "FileSource\\wenjianjia\\" + timePath + "\\" + resourceid + "\\";
                    File newfilePath = new File(path); // 创建对应的年月文件夹
                    if (!newfilePath.exists()) {
                        newfilePath.mkdirs();
                    }
                    webpath = "FileSource/wenjianjia/" + timePath + "/" + resourceid; // 类型为文件夹则指向到文件夹
                }
                // path2 = env.getProperty("webroot") + "wenjianjia/";
                if (!rename) {
                    path = sysConfig.getUploadPath() + "FileSource\\wenjianjia\\" + timePath + "\\" + resourceid + "\\";
                    desFile = new File(path + Filename);
                    String info = desFile.getAbsolutePath();
                    System.out.println("info:" + info);
                }
            }
            if (sourcetype.equals("文件")) {
                Filename = uuid + fileType;
                // 当文件资源类型为文件时，判断是否该资源已经存在文件，如果有则先删除再执行上传新文件
                if (resExtFileSource != null && resExtFileSource.getServerurl() != null) {
                    String dirpath = resExtFileSource.getServerurl().substring(0, resExtFileSource.getServerurl().lastIndexOf("/") + 1);
                    String oldfile = sysConfig.getUploadPath() + resExtFileSource.getServerurl().replaceAll("/", "\\\\");
                    String ofile = sysConfig.getUploadPath() + dirpath.replaceAll("/", "\\\\");
//					DeleteFileUtils.deletefileUtils(oldfile);
                    File file1 = new File(ofile);
                    if (!file1.exists()) {
                        path = sysConfig.getUploadPath() + "temp\\FileSource\\wenjian\\" + timePath + "\\";
                        File newfilePath = new File(path); // 创建对应的年月文件夹
                        newfilePath.mkdirs();
                        webpath = "temp/FileSource/wenjian/" + timePath + "/" + Filename;  // 类型为文件指向文件
                    } else {
                        path = sysConfig.getUploadPath() + "temp\\FileSource\\wenjian\\" + timePath + "\\";
                        //文件网络地址
                        webpath = "temp/FileSource/wenjian/" + timePath + "/" + Filename; // 类型为文件指向文件
                    }
                } else {
                    path = sysConfig.getUploadPath() + "temp\\FileSource\\wenjian\\" + timePath + "\\";
                    File filePath = new File(path); // 创建对应的年月文件夹
                    if (!filePath.exists()) {
                        filePath.mkdirs();
                    }
                    //文件网络地址
                    webpath = "temp/FileSource/wenjian/" + timePath + "/" + Filename; // 类型为文件指向文件
                }
                desFile = new File(path + Filename);
                String info = desFile.getAbsolutePath();
                System.out.println("info:" + info);
            }
            if (!rename) {
                //当sourcetype.equals("文件")
                String finasize = "";
                if (sourcetype.equals("文件")) {
                    finasize = com.landtool.lanbase.common.utils.FileUtils.setSize(size);
                } else {
                    final long total = com.landtool.lanbase.common.utils.FileUtils.getTotalSizeOfFilesInDir(new File(path));
                    finasize = com.landtool.lanbase.common.utils.FileUtils.setSize(total + size);
                }
                try {

                    FileUtils.copyInputStreamToFile(file[i].getInputStream(), desFile);
                    Filenames.add(Fname);
                    finasizes.add(com.landtool.lanbase.common.utils.FileUtils.setSize(size));
                    res = "{'result':'1','finasizes':'" + finasizes + "','name':'" + Filenames + "','Path':'" + webpath + "','Filename':'" + name.substring(name.lastIndexOf("/") + 1, name.lastIndexOf(".")) + "','size':'" + finasize.substring(0, finasize.lastIndexOf(" ")) + "','unit':'" + finasize.substring(finasize.lastIndexOf(" ") + 1, finasize.length()) + "'}";
                    System.out.println(res);
                } catch (IOException e) {
                    e.printStackTrace();
                    res = "{'result':'0'}";
                }
            } else {
                res = "{'result':'3'}";
            }

        }
        return res;

    }

    /**
     * @param filepath 文件路径
     * @return
     * @Description: 文件删除
     * @author ykm
     * @date 2018/4/19 16:38
     */
    @ResponseBody
    @RequestMapping("/resExtFileSource/deletefile")
    public String deletefile(String filepath, String sourcetype, String name, Res_ExtFileSource resExtFileSource) {
        String res = "";
        String lujin = filepath;
        if (sourcetype.equals("文件夹")) {

            filepath = sysConfig.getUploadPath() + filepath.replaceAll("/", "\\\\") + "\\" + name;
            //读取删除之后文件夹大小
            boolean flag = DeleteFileUtils.deletefileUtils(filepath);
            final long total = com.landtool.lanbase.common.utils.FileUtils.getTotalSizeOfFilesInDir(new File(sysConfig.getUploadPath() + lujin.replaceAll("/", "\\\\")));
            String finasize = com.landtool.lanbase.common.utils.FileUtils.setSize(total);
            res = "{'result':'" + flag + "','size':'" + finasize.substring(0, finasize.lastIndexOf(" ")) + "','unit':'" + finasize.substring(finasize.lastIndexOf(" ") + 1, finasize.length()) + "'}";
            //将大小写入 数据库
            resExtFileSource.setFilesize((double) (total / 1000));
            resExtFileSourceService.updateByPrimaryKeySelective(resExtFileSource);
        }
        if (sourcetype.equals("文件")) {
            filepath = sysConfig.getUploadPath() + filepath.replaceAll("/", "\\\\") + "\\" + name;
            boolean flag = DeleteFileUtils.deletefileUtils(filepath);
            res = "{'result':'" + flag + "','size':'null','unit':'null'}";
        }
        return res;
    }

    /**
     * @Author: lizhao
     * @Date: 2018-04-25 16:23
     * @param查询本地固定地址的文件
     * @Description:
     */

    @ResponseBody
    @RequestMapping("/resExtFileSource/OpenFileName")
    public String OpenFileName(Model model) {

        File file = new File(wenjianPath());
        // 获取该目录下的所有文件大小
        File[] files = file.listFiles();

        // 获取文件名称
        String[] fileLists = file.list();
        StringBuilder rsb = new StringBuilder();

        rsb.append("{'topics':[");
        for (Integer i = 0; i < files.length; i++) {
            // 大小
            File file2 = new File(files[i].getAbsolutePath());
            String size = FileUtils.byteCountToDisplaySize(file2.length());
            // 名称
            File file1 = new File(fileLists[i]);
            String name = file1.getName();
            if (i != 0) {
                rsb.append(",");
            }
            rsb.append("{'name':'" + name + "'");
            rsb.append(",'size':'" + size + "'}");
        }
        rsb.append("]}");
        return rsb.toString();
    }

    @ResponseBody
    @RequestMapping("/resExtFileSource/FuWuDiZi")
    public String FuWuDiZi(String url) {
        String NeiRong = "";
        try {
            NeiRong = HttpOperateUtils.httpGet(url);
        } catch (IOException e) {
            e.printStackTrace();
            NeiRong = "失败";
        }
        return NeiRong;
    }

    @RequestMapping("/resExtFileSource/download")
    public void download(HttpServletResponse response, String path, String Title, HttpServletRequest request) {

        System.out.println(sysConfig.getUploadPath() + path.replaceAll("/", "\\\\").replace("\\uploadPath", ""));
        System.out.println(Title);
        com.landtool.lanbase.common.utils.FileUtils.download(sysConfig.getUploadPath() + path.replaceAll("/", "\\\\").replace("\\uploadPath", ""), Title, response);

    }

    /**
     * /*jsoup只支持http、https协议连接，不支持ftp
     */
    @ResponseBody
    @RequestMapping("/resExtFileSource/getUrlList")
    public String jsoupDetail(String url) {
        try {
            Document doc = Jsoup.connect(url).get();
            StringBuilder sb = new StringBuilder();

            //目前只考虑了目录结构为table和pre标签下的目录,即Tomcat和IIS
            Elements tableElements = doc.getElementsByTag("table"); //http://www.zhjg.com:8080/javapubzy/BootStrap4/
            Elements preElements = doc.getElementsByTag("pre");     //http://10.1.4.27/shuqu/
            if (tableElements.size() > 0) {
                Document tableDoc = Jsoup.parse(tableElements.toString());
                int trSize = tableDoc.select("tr").size();
                int tdSize = tableDoc.select("tr").first().select("td").size(); //获取第一行tr下的td数
                String[][] tableList = new String[trSize][2];
                int tr = -1;
                int td = -1;
                for (int i = 0; i < tdSize; i++) {
                    tableList[0][i] = tableDoc.select("tr").get(0).select("td").get(i).text();
                    if (tableList[0][i].equals("Filename") && tr == -1) {
                        tr = i;
                    }
                    if (tableList[0][i].equals("Size") && td == -1) {
                        td = i;
                    }
                    if (tr != -1 && td != -1) {
                        break;
                    }
                }
                sb.append("[");
                for (int i = 1; i < trSize; i++) {
                    if (i != 1) sb.append(",");
                    tableList[i][0] = tableDoc.select("tr").get(i).select("td").get(tr).select("A").get(0).text();
                    tableList[i][1] = tableDoc.select("tr").get(i).select("td").get(td).select("tt").get(0).text();
                    sb.append("{");
                    sb.append("filename: '" + tableList[i][0] + "'");
                    sb.append(",size: '" + tableList[i][1] + "'");
                    sb.append("}");
                }
                sb.append("]");
                return sb.toString();
            } else if (preElements.size() > 0) {
                int aSize = preElements.select("A").size(); //获取a标签个数
                sb.append("[");
                for (int i = 1; i < aSize; i++) {
                    if (i != 1) sb.append(",");
                    String aName = preElements.select("A").get(i).text();
                    sb.append("{");
                    sb.append("filename: '" + aName + "'");
                    sb.append(",size: ''");
                    sb.append("}");
                }
                sb.append("]");
                return sb.toString();
            } else {
                sb.append("[{");
                sb.append("filename: '无法获取该地址下的目录！'");
                sb.append(",size: ''");
                sb.append("}]");
                return sb.toString();
            }

        } catch (IOException e) {
            e.printStackTrace();
            return "[{filename:'无法获取该地址下的目录！',size:''}]";
        }
    }

    @RequestMapping("/ResManage/ResRegister/NcFileConfig")
	public String NcFileConfig(int resourceType,int resourceid,Model model){
		Res_ExtFileSource res_ExtFileSource = resExtFileSourceService.selectByPrimaryKey(resourceid);
		if(res_ExtFileSource.getNcconfig()!=null && !res_ExtFileSource.getNcconfig().equals("")){
			JSONObject jsonObject = JSONObject.parseObject(res_ExtFileSource.getNcconfig());
			JSONArray jsonArray = jsonObject.getJSONArray("ncconfig");
			NcConfig ncConfig = JSONUtil.toBean(String.valueOf(jsonArray.get(0)), NcConfig.class);
			model.addAttribute("ncConfig", ncConfig);
		}
		model.addAttribute("pubzyWebRoot", sysConfig.getPubzyWebRoot());
		model.addAttribute("ncFileConfigURL", sysConfig.getNcFileConfigURL()+"?resourceType="+resourceType+"&uploadPath="+sysConfig.getUploadPath()+res_ExtFileSource.getServerurl());
		model.addAttribute("readNcFileURL", sysConfig.getReadNcFileURL());
		model.addAttribute("res_ExtFileSource", res_ExtFileSource);
		model.addAttribute("resourceid", resourceid);
		model.addAttribute("resourceType", resourceType);
		model.addAttribute("uploadPath", res_ExtFileSource.getServerurl());
		model.addAttribute("absolutePath", sysConfig.getUploadPath()+res_ExtFileSource.getServerurl());
		return "ResManage/ResRegister/NcFileConfig";
	}
	
	@RequestMapping("/ResManage/ResRegister/StorageConfig")
	public String StorageConfig(int resourceType,int resourceid,Model model){
		Res_ExtFileSource res_ExtFileSource = resExtFileSourceService.selectByPrimaryKey(resourceid);
		if(res_ExtFileSource.getNcconfig()!=null && !res_ExtFileSource.getNcconfig().equals("")){
			JSONObject jsonObject = JSONObject.parseObject(res_ExtFileSource.getNcconfig());
			JSONArray jsonArray = jsonObject.getJSONArray("ncconfig");
			NcConfig ncConfig = JSONUtil.toBean(String.valueOf(jsonArray.get(0)), NcConfig.class);
			model.addAttribute("ncConfig", ncConfig);
		}
		Res_StorageConfig resStorageConfig = resStorageConfigService.findStorageConfigByResourceid(resourceid);
		if(resStorageConfig!=null && resStorageConfig.getVariableparams()!=null && !resStorageConfig.getVariableparams().equals("")){
			JSONArray jsonarray = JSONArray.parseArray(resStorageConfig.getVariableparams());
			model.addAttribute("jsonarray", jsonarray);
		}
		if(resStorageConfig!=null && resStorageConfig.getUvparams()!=null && !resStorageConfig.getUvparams().equals("")){
			JSONArray uvjson = JSONArray.parseArray(resStorageConfig.getUvparams());
			model.addAttribute("uvjson", uvjson);
		}
		model.addAttribute("resStorageConfig", resStorageConfig);
		model.addAttribute("pubzyWebRoot", sysConfig.getPubzyWebRoot());
		model.addAttribute("ncFileConfigURL", sysConfig.getNcFileConfigURL()+"?resourceType="+resourceType+"&uploadPath="+sysConfig.getUploadPath()+res_ExtFileSource.getServerurl());
		model.addAttribute("readNcFileURL", sysConfig.getReadNcFileURL());
		model.addAttribute("res_ExtFileSource", res_ExtFileSource);
		model.addAttribute("resourceid", resourceid);
		model.addAttribute("resourceType", resourceType);
		model.addAttribute("ncSyncStorageUrl", sysConfig.getNcStorageUrl().substring(0, sysConfig.getNcStorageUrl().length()-9)+"jobs/");
		return "ResManage/ResRegister/StorageConfig";
	}
	
	@RequestMapping("/ResManage/ResRegister/updateNcJsonPath")
	@ResponseBody
	public int updateNcJsonPath(Res_ExtFileSource res_ExtFileSource){
		return resExtFileSourceService.updateByPrimaryKeySelective(res_ExtFileSource);
	}
	
	//保存入库配置
	@RequestMapping("/ResManage/ResRegister/saveStorageConfig")
	@ResponseBody
	public int saveStorageConfig(Res_StorageConfig res_storageConfig){
		Res_StorageConfig storage = resStorageConfigService.findStorageConfigByResourceid(res_storageConfig.getResourceid());
		if(storage==null){
			return resStorageConfigService.insertStorageConfig(res_storageConfig);
		}else{
			return resStorageConfigService.updateStorageConfig(res_storageConfig);
		}
	}
	
	//NC配置
	@RequestMapping("/ResManage/ResRegister/getNcConfig")
	@ResponseBody
	public String getNcConfig(int resourceid){
		Res_ExtFileSource res_ExtFileSource = resExtFileSourceService.selectByPrimaryKey(resourceid);
		return res_ExtFileSource.getNcconfig();
	}
		
	//入库配置
	@RequestMapping("/ResManage/ResRegister/findParams")
	@ResponseBody
	public String findParams(int resourceid){
		String params = "";
		Res_StorageConfig res_storageConfig = resStorageConfigService.findStorageConfigByResourceid(resourceid);
		if(res_storageConfig!=null && res_storageConfig.getVariableparams()!=null && !res_storageConfig.getVariableparams().equals("")){
			params = res_storageConfig.getVariableparams();
		}else if(res_storageConfig!=null && res_storageConfig.getUvparams()!=null && !res_storageConfig.getUvparams().equals("")){
			params = res_storageConfig.getUvparams();
		}
		return params;
	}
	
	//清空配置
	@RequestMapping("/ResManage/ResRegister/clearConfig")
	@ResponseBody
	public int clearConfig(int resourceid,int type){
		int total=0;
		switch (type) {
		case 1:	//nc配置清空
			Res_ExtFileSource resExtFileSource = new Res_ExtFileSource();
			resExtFileSource.setResourceid(resourceid);
			resExtFileSource.setNcconfig("");
			total = resExtFileSourceService.updateByPrimaryKeySelective(resExtFileSource);
			break;

		case 2: //入库配置清空
			total = resStorageConfigService.deleteByResourceid(resourceid);
			break;
			
		default: 
			Res_ExtFileSource res_ExtFileSource = new Res_ExtFileSource();
			res_ExtFileSource.setResourceid(resourceid);
			res_ExtFileSource.setNcconfig("");
			res_ExtFileSource.setNcjsonattribute("");
			res_ExtFileSource.setNcjsonpath("");
			total = resExtFileSourceService.updateByPrimaryKeySelective(res_ExtFileSource);
			total+= resStorageConfigService.deleteByResourceid(resourceid);
			break;
		}
		return total;
	}
	
	//调用服务入库
	@RequestMapping("/ResManage/ResRegister/saveStorage")
	@ResponseBody
	public String saveStorage(int resourceid,String fileName,String param){
		Res_StorageConfig res_storageConfig = resStorageConfigService.findStorageConfigByResourceid(resourceid);
		if(res_storageConfig.getVariableparams()!=null && !res_storageConfig.getVariableparams().equals("")){
			res_storageConfig.setVariableparams(param);
		}else{
			res_storageConfig.setUvparams(param);
		}
		String databaseid ="";
		if(res_storageConfig.getVariableparams()!=null && !res_storageConfig.getVariableparams().equals("")){
			databaseid = JSONObject.parseObject(res_storageConfig.getVariableparams()).get("databaseid").toString();			
		}else if(res_storageConfig.getUvparams()!=null && !res_storageConfig.getUvparams().equals("")){
			databaseid = JSONObject.parseObject(res_storageConfig.getUvparams()).get("databaseid").toString();		
		}
		Res_ExtDataSource res_ExtDataSource = resExtDataSourceService.selectByPrimaryKey(Integer.valueOf(databaseid));
		Res_ExtFileSource res_ExtFileSource = resExtFileSourceService.selectByPrimaryKey(res_storageConfig.getResourceid());
		String ncFilePath = sysConfig.getUploadRootPath()+res_ExtFileSource.getServerurl();
		String body ="";
		List<String> jobids = new ArrayList<String>();
		NcMessage message = new NcMessage();
		body = resStorageConfigService.invoke(res_storageConfig,res_ExtDataSource,ncFilePath+"/"+fileName);	
		String jobId = (String) JSONObject.parseObject(body).get("jobId");
		String messages = (String) JSONObject.parseObject(body).get("messages");
		if(jobId!=null && !jobId.equals("")){
			message.setCode(1);
			jobids.add(jobId);
		}else{
			message.setCode(2); 	//返回包含result message 代表同步
			if(messages!=null && !messages.equals("")){
				JSONArray jsonArray = JSON.parseArray(messages);
				String description = jsonArray.getJSONObject(jsonArray.size()-1).get("description").toString();
				if(description.contains("Succeeded")){
					message.setMessage("success");
				}
			}
			if(body.contains("error")){
				message.setMessage("error");
			}
		}
		message.setJobids(jobids);
		return JSON.toJSON(message).toString();
	}

	//异步调用服务入库
	@RequestMapping("/ResManage/ResRegister/syncSaveStorage")
	@ResponseBody
	public String syncSaveStorage(Res_StorageConfig res_storageConfig,int resourceType){
		String databaseid ="";
		if(res_storageConfig.getVariableparams()!=null && !res_storageConfig.getVariableparams().equals("")){
			databaseid = JSONObject.parseObject(res_storageConfig.getVariableparams()).get("databaseid").toString();			
		}else if(res_storageConfig.getUvparams()!=null && !res_storageConfig.getUvparams().equals("")){
			databaseid = JSONObject.parseObject(res_storageConfig.getUvparams()).get("databaseid").toString();		
		}
		Res_ExtDataSource res_ExtDataSource = resExtDataSourceService.selectByPrimaryKey(Integer.valueOf(databaseid));
		Res_ExtFileSource res_ExtFileSource = resExtFileSourceService.selectByPrimaryKey(res_storageConfig.getResourceid());
		String ncFilePath = sysConfig.getUploadRootPath()+res_ExtFileSource.getServerurl();
		String body ="";
		List<String> jobids = new ArrayList<String>();
		NcMessage message = new NcMessage();
		if(resourceType==1){	//文件
			body = resStorageConfigService.invoke(res_storageConfig,res_ExtDataSource,ncFilePath);	
			System.out.println(body);
			String jobId = (String) JSONObject.parseObject(body).get("jobId");
			String messages = (String) JSONObject.parseObject(body).get("messages");
			if(jobId!=null && !jobId.equals("")){	//返回包含jobId 代表异步
				message.setCode(1);
				jobids.add(jobId);
			}else{
				message.setCode(2); 	//返回包含result message 代表同步
				if(messages!=null && !messages.equals("")){
					JSONArray jsonArray = JSON.parseArray(messages);
					String description = jsonArray.getJSONObject(jsonArray.size()-1).get("description").toString();
					if(description.contains("Succeeded")){
						message.setMessage("success");
					}
				}
				if(body.contains("error")){
					message.setMessage("error");
				}
			}
		}else{	//资源目录
			File files = new File(sysConfig.getUploadPath().replace("\\", "/")+res_ExtFileSource.getServerurl());
			File[] listFiles = files.listFiles();
			if(listFiles.length>0){
				for(File file : listFiles){
					if(!file.isDirectory() && file.getName().contains(".nc")){
						String path =ncFilePath+"/"+file.getName();
						body = resStorageConfigService.invoke(res_storageConfig,res_ExtDataSource,path);	
						System.out.println(body);
						String jobId = (String) JSONObject.parseObject(body).get("jobId");
						String messages = (String) JSONObject.parseObject(body).get("messages");
						if(jobId!=null && !jobId.equals("")){
							message.setCode(1);
							jobids.add(jobId);
						}else{
							message.setCode(2);
							if(messages!=null && !messages.equals("")){
								JSONArray jsonArray = JSON.parseArray(messages);
								String description = jsonArray.getJSONObject(jsonArray.size()-1).get("description").toString();
								if(description.contains("Succeeded")){
									message.setMessage("success");
								}
							}
							if(body.contains("error")){
								message.setMessage("error");
							}
						}
					}
				}
			}
		}
		message.setJobids(jobids);
		return JSON.toJSON(message).toString();
	}
	
	@RequestMapping("/ResManage/ResRegister/saveStorageRelation")
	@ResponseBody
	public void saveStorageRelation(Res_Storage_Relation storageRelation){
		Res_Storage_Relation res_Storage_Relation = resStorageRelaTionService.selectByResourceidAndFileName(storageRelation);
		if(res_Storage_Relation==null){
			storageRelation.setIsstorage(1);
			resStorageRelaTionService.insert(storageRelation);
		}else{
			storageRelation.setIsstorage(1);
			resStorageRelaTionService.update(storageRelation);
		}
	}
	
	@RequestMapping("/ResManage/ResRegister/insertStorageRelation")
	@ResponseBody
	public void insertStorageRelation(Res_Storage_Relation storageRelation){
		Res_Storage_Relation res_Storage_Relation = resStorageRelaTionService.selectByResourceidAndFileName(storageRelation);
		if(res_Storage_Relation==null){
			storageRelation.setIsgeneration(1);
			resStorageRelaTionService.insert(storageRelation);
		}else{
			storageRelation.setIsgeneration(1);
			resStorageRelaTionService.update(storageRelation);
		}
	}
}