fix

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/MessageApiServiceImpl.java

@@ -3,6 +3,8 @@ package com.gic.haoban.manage.service.service.out.impl;
 import com.alibaba.fastjson.JSON;
 import com.gic.commons.util.EntityUtil;
 import com.gic.commons.util.GICMQClientUtil;
+import com.gic.commons.util.GlobalInfo;
+import com.gic.commons.util.GlobalVar;
 import com.gic.haoban.base.api.common.Constant;
 import com.gic.haoban.base.api.common.ServiceResponse;
 import com.gic.haoban.manage.api.dto.DepartmentDTO;
@@ -22,10 +24,15 @@ import com.gic.haoban.manage.service.config.Config;
 import com.gic.haoban.manage.service.entity.*;
 import com.gic.haoban.manage.service.service.*;
 import com.gic.mq.sdk.GicMQClient;
+import com.gic.thirdparty.api.dto.PicUploadResDTO;
+import com.gic.thirdparty.api.service.QQCloudPicService;
 import com.gic.wechat.api.service.qywx.QywxDepartmentApiService;
 
+import java.io.InputStream;
+import java.net.URL;
 import java.util.List;
 
+import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang.StringUtils;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
@@ -61,6 +68,9 @@ public class MessageApiServiceImpl implements MessageApiService {
     @Autowired
     private QywxDepartmentApiService qywxDepartmentApiService;
     
+    @Autowired
+	private QQCloudPicService qqCloudPicService;
+    
     private final String CONTACT_APP = "contactSuiteId";
 
     @Override
@@ -254,7 +264,9 @@ public class MessageApiServiceImpl implements MessageApiService {
             staff.setStaffName(qywxCallBackDTO.getUserName());
             staff.setWxUserId(qywxCallBackDTO.getUserid());
             staff.setPostion(qywxCallBackDTO.getPosition());
-            staff.setHeadImg(qywxCallBackDTO.getAvatar());
+            if(StringUtils.isNotBlank(qywxCallBackDTO.getAvatar())){
+            	staff.setHeadImg(changeHeaderImageUrl(qywxCallBackDTO.getAvatar()));
+            }
             staff.setNationCode("86");
             //激活状态
             if(qywxCallBackDTO.getStatus() != null && qywxCallBackDTO.getStatus() == 1){
@@ -405,6 +417,20 @@ public class MessageApiServiceImpl implements MessageApiService {
             }
         }
     }
+    
+    private String changeHeaderImageUrl(String headImgUrl) {
+
+		try {
+			InputStream in = new URL(headImgUrl).openStream();
+			byte[] data = IOUtils.toByteArray(in);
+			PicUploadResDTO uploadPic = qqCloudPicService.uploadPic(GlobalVar.ctxPropertiesMap.get(GlobalInfo.QQPIC_KEY_ENTERPRISE), data);
+			log.info("腾讯云万象优图返回" + JSON.toJSONString(uploadPic));
+			return uploadPic.downloadUrl;
+		}catch (Exception e){
+			log.info("上传腾讯云万象优图返回失败了：", e);
+			return headImgUrl;
+		}
+	}
     /**
      * 通过关联的父级ID链查询父级部门
      * @param parentChain