访客系统
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
doum
3 天以前 48d06fac940e6f28d599eb7fbf05c2cce41ecb30 
 server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/common/PublicCloudController.java


@@ -1,5 +1,6 @@


package com.doumee.cloud.common;




import cn.hutool.core.io.IoUtil;


import com.alibaba.fastjson.JSONArray;


import com.alibaba.fastjson.JSONObject;


import com.doumee.api.BaseController;


@@ -7,10 +8,17 @@


import com.doumee.core.annotation.trace.Trace;


import com.doumee.core.constants.ResponseStatus;


import com.doumee.core.exception.BusinessException;


import com.doumee.core.haikang.model.HKConstants;


import com.doumee.core.haikang.model.param.BaseResponse;


import com.doumee.core.haikang.model.param.request.FacePictureCheckRequest;


import com.doumee.core.haikang.model.param.respose.FacePictureCheckResponse;


import com.doumee.core.haikang.service.HKService;


import com.doumee.core.utils.Constants;


import com.doumee.core.utils.DateUtil;


import com.doumee.core.utils.FtpUtil;


import com.doumee.core.utils.HttpsUtil;


import com.doumee.core.utils.aliyun.ALiYunUtil;


import com.doumee.dao.business.dto.DownloadFileDTO;


import com.doumee.dao.system.model.SystemDict;


import com.doumee.dao.system.model.SystemDictData;


import io.swagger.annotations.Api;


@@ -18,6 +26,9 @@


import io.swagger.annotations.ApiImplicitParams;


import io.swagger.annotations.ApiOperation;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.compress.archivers.zip.Zip64Mode;


import org.apache.commons.compress.archivers.zip.ZipArchiveEntry;


import org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream;


import org.apache.commons.lang3.StringUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.web.bind.annotation.*;


@@ -25,12 +36,12 @@


import org.springframework.web.multipart.MultipartHttpServletRequest;


import org.springframework.web.multipart.commons.CommonsMultipartResolver;




import javax.servlet.ServletOutputStream;


import javax.servlet.http.HttpServletRequest;


import javax.servlet.http.HttpServletResponse;


import java.io.File;


import java.io.IOException;


import java.io.InputStream;


import java.io.PrintWriter;


import java.io.*;


import java.net.URLEncoder;


import java.nio.charset.Charset;


import java.util.*;




/**


@@ -43,8 +54,6 @@


@RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/public")


@Slf4j


public class PublicCloudController extends BaseController {






    @Autowired


    private SystemDictDataBiz systemDictDataBiz;




@@ -100,8 +109,8 @@


                        String endType = originname.substring(originname.lastIndexOf("."), originname.length());


                        String date = DateUtil.getNowShortDate();


                        String fName = date + "/" + UUID.randomUUID() + endType;


                        String fileName = folder + "/" + fName;


                        boolean r = ftp.uploadInputstreamBatch(is, fileName, Constants.equalsInteger(index ,fileList.size()));


                        String fileName = folder + fName;


                        boolean r = ftp.uploadInputstreamBatch(is, fileName, Constants.equalsInteger(index ,fileList.size()),index);


                        if (r) {


                            JSONObject fileJSON = new JSONObject();


                            fileJSON.put("url", prefixPath + fileName);


@@ -148,11 +157,48 @@


        return;


    }




    @ApiOperation(value = "下载网络文件")


    @RequestMapping(method= RequestMethod.POST,value="/downloadFile")


    @ResponseBody


    public void downloadFile(@RequestBody DownloadFileDTO param,  HttpServletRequest request, HttpServletResponse response) throws Exception {


        if(StringUtils.isBlank(param.getUrl())){


            throw  new BusinessException(ResponseStatus.BAD_REQUEST);


        }


        InputStream inputStream = HttpsUtil.connectionInputsteam(param.getUrl(),"GET",null,null);


        if(inputStream == null){


            throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"文件下载失败，请检查文件路径是否合法！");


        }


        if(StringUtils.isBlank(param.getFileName())){


            param.setFileName(System.currentTimeMillis()+"");


            if(param.getUrl().lastIndexOf(".") >0){


                String nfix = param.getUrl().substring(param.getUrl().lastIndexOf("."));


                param.setFileName(System.currentTimeMillis()+"."+nfix);


            }


        }




        String encodeFileName = URLEncoder.encode(param.getFileName(), Charset.forName("UTF-8").toString());


        response.setHeader("Content-Disposition","attachment;filename=" + encodeFileName);


        response.setContentType("application/octet-stream");


        response.setHeader("eva-opera-type", "download");


        response.setHeader("eva-download-filename", encodeFileName);




        OutputStream os = new BufferedOutputStream(response.getOutputStream());


        byte[] buffer = new byte[4096];


        int bytesRead;


        while ((bytesRead = inputStream.read(buffer)) != -1) {


            os.write(buffer, 0, bytesRead);


        }


        os.flush();


        os.close();


        inputStream.close();


    }


    @ApiOperation(value = "上传文件到FTP")


    @RequestMapping(method= RequestMethod.POST,value="/upload")


    @ResponseBody


    public void upload(HttpServletRequest request, HttpServletResponse response, String folder) throws Exception {


    public void upload(HttpServletRequest request, HttpServletResponse response, String folder,Integer isFace) throws Exception {


//        folder = systemDictDataBiz.queryByCode(Constants.FTP,folder).getCode();


        Date d1 = new Date();


        log.error("总得上传文件成功=============开始========="+DateUtil.getPlusTime2(d1));


        folder =StringUtils.defaultString(folder).replace("/", "");


        String prefixPath = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode();


        InputStream is = null;


@@ -177,12 +223,48 @@


                    MultipartFile file = multipartRequest.getFile(it.next());


                    String originname = file.getOriginalFilename();


                    is = file.getInputStream();


                    String endType = originname.substring(originname.lastIndexOf("."),originname.length());


                    String endType = ".jpg";


                    if(originname.indexOf(".")>0){


                        endType=originname.substring(originname.lastIndexOf("."),originname.length());


                    }


                    String date = DateUtil.getNowShortDate();


                    String fName =  date+"/"+ UUID.randomUUID()+endType;


                    String fileName = folder+"/"+fName;


                    boolean r = ftp.uploadInputstream(is,fileName);


                    if(r){


                        isFace = null;


                         if(Objects.nonNull(isFace) && Constants.equalsInteger(isFace,Constants.ZERO)){


                            //验证人脸评分


                            //人脸评分


                            FacePictureCheckRequest param = new FacePictureCheckRequest();


                            String prefixUrl = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_LOCAL_RESOURCE_PATH).getCode();


                            param.setFacePicUrl(prefixUrl + fileName);


                            BaseResponse<FacePictureCheckResponse> responseBaseResponse = HKService.facePictureCheck(param);


                            if(responseBaseResponse == null || !StringUtils.equals(responseBaseResponse.getCode(), HKConstants.RESPONSE_SUCCEE)){


                                context.put("code", 0);


                                context.put("message", "对不起，人脸评分获取数据失败~");


                                context.put("errno",0);


                                writerJson(response, context);


                                return;


                            }


                            FacePictureCheckResponse facePictureCheckResponse = responseBaseResponse.getData();


                            if(Objects.isNull(facePictureCheckResponse) || Objects.isNull(facePictureCheckResponse.getCheckResult())){


                                context.put("code", 0);


                                context.put("message", "对不起，人脸评分获取数据失败~");


                                context.put("errno",0);


                                writerJson(response, context);


                                return;


                            }


                            if(!facePictureCheckResponse.getCheckResult()){


                                context.put("code", 0);


                                context.put("message", facePictureCheckResponse.getStatusMessage());


                                context.put("errno",0);


                                writerJson(response, context);


                                return;


                            }




                        }




                        context.put("success", true);


                        context.put("code", 200);


                        context.put("errno",0);


@@ -191,11 +273,14 @@


//                        fileJSON.put("folder", folder);


                        fileJSON.put("url", prefixPath+fileName);


                        fileJSON.put("imgaddr", fName);


                        fileJSON.put("fileSize", file.getSize());


                        fileJSON.put("imgname", fileName);


                        fileJSON.put("originname", originname);


                        context.put("data",fileJSON);


                        context.put("message","请求成功");


                        writerJson(response, context);


                        Date d2= new Date();


                        log.error("总的上传文件成功=============结束========="+DateUtil.getPlusTime2(d2) +"耗时秒："+( (d2.getTime()-d1.getTime()) /1000));


                        return;


                    }


                }


@@ -303,9 +388,6 @@


            e.printStackTrace();


        }


    }










    public void uploadFileLocal(HttpServletRequest request, String folder, HttpServletResponse response, String rootPath,String dir) throws Exception {


        response.setCharacterEncoding("UTF-8");