上传接口替换

haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/controller/UploadController.java

 package com.gic.haoban.manage.web.controller;
 
 import java.io.File;
+import java.io.FileInputStream;
 import java.io.InputStream;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -10,6 +11,7 @@ import java.util.Map;
 
 import javax.servlet.http.HttpServletRequest;
 
+import com.gic.clerk.api.dto.AuthorizedUser;
 import org.apache.commons.lang.StringUtils;
 import org.apache.logging.log4j.LogManager;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -45,12 +47,20 @@ public class UploadController extends WebBaseController {
 
     @RequestMapping("upload-img")
     @IgnoreLogin
-    public HaobanResponse imgUpload(HttpServletRequest request) throws Exception {
+    public HaobanResponse imgUpload(HttpServletRequest request,String enterpriseId) throws Exception {
+        EnterpriseDTO enterprise = this.enterpriseService.getEnterpriseById(enterpriseId) ;
+        if(null == enterprise) {
+            return resultResponse(HaoBanErrCode.ERR_OTHER, "商户不存在") ;
+        }
+        String factoryCode = enterprise.getFactoryCode() ;
         MultipartHttpServletRequest multiRequest = (MultipartHttpServletRequest) request;
         Iterator<String> iter = multiRequest.getFileNames();
         java.util.List<Map<String, Object>> picList = new ArrayList<>();
         while (iter.hasNext()) {
             String fileName = iter.next();
+            //获取文件名后缀
+            String suffix = fileName.substring(fileName.lastIndexOf(".") + 1);
+            logger.info("文件的后缀为:{}",suffix);
             List<MultipartFile> list = multiRequest.getMultiFileMap().get(fileName);
             Map<String, Object> map = null;
             for (int i = 0; i < list.size(); i++) {
@@ -63,12 +73,15 @@ public class UploadController extends WebBaseController {
                     fileBuffer = new byte[len];
                     in.read(fileBuffer);
                 }
-                PicUploadResDTO picUploadResDTO = qqCloudPicService.uploadPic(
-                        GlobalVar.ctxPropertiesMap.get(GlobalInfo.QQPIC_KEY_ENTERPRISE), fileBuffer);
-                if (picUploadResDTO != null) {
-                    picUploadResDTO.print();
-                    map.put("qcloudImageUrl", picUploadResDTO.downloadUrl);
-                    map.put("imageFiledCode", picUploadResDTO.fileId);
+                //上传接口替换
+//                PicUploadResDTO picUploadResDTO = qqCloudPicService.uploadPic(
+//                        GlobalVar.ctxPropertiesMap.get(GlobalInfo.QQPIC_KEY_ENTERPRISE), fileBuffer);
+                CloudFileTypeEnum cloudFileTypeEnum = CloudFileTypeEnum.IMAGE;
+                CloudFileInfo cloudFileInfo =   CloudFileUtil.uploadFile(fileBuffer, suffix, cloudFileTypeEnum,factoryCode, CloudFileBusinessOptEnum.HAOBAN_COMMON);
+                logger.info("上传返回的实体信息为:{}",cloudFileInfo);
+                if (cloudFileInfo != null) {
+                    map.put("qcloudImageUrl", cloudFileInfo.getOrgFileUrl());
+                    map.put("imageFiledCode", cloudFileInfo.getFileId());
                 }
                 picList.add(map);
             }