处理 图片文件

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/handler/MaoDengImageHandler.java

 package com.liquidnet.service.sweet.handler;
 
 
+import com.fasterxml.jackson.core.type.TypeReference;
 import com.liquidnet.common.third.shumei.util.ShumeiUtil;
+import com.liquidnet.commons.lang.util.HttpUtil;
+import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.commons.lang.util.StringUtil;
+import com.liquidnet.service.adam.dto.vo.AdamUserInfoVo;
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.kylin.dto.vo.basicServices.UploadVo;
 import com.liquidnet.service.sweet.config.WechatMaConfigure;
 import com.liquidnet.service.sweet.utils.WechatUsersRedisUtils;
 import com.liquidnet.service.sweet.vo.SweetMaoDengVo;
@@ -16,7 +22,10 @@ import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
 import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
 import me.chanjar.weixin.mp.bean.message.WxMpXmlOutTextMessage;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
 
 import java.util.Map;
 
@@ -24,6 +33,8 @@ import java.util.Map;
 @Slf4j
 public class MaoDengImageHandler implements WxMpMessageHandler {
 
+    @Value("${liquidnet.service.platform.url}")
+    private String platformUrl;
     @Autowired
     private WechatUsersRedisUtils redisUtils;
     @Autowired
@@ -37,7 +48,7 @@ public class MaoDengImageHandler implements WxMpMessageHandler {
         String picUrl = wxMessage.getPicUrl();//图片url
 
         //猫登天空活动开启
-        if (StringUtil.isNotEmpty(redisUtils.getSweetMaoDengOpen(fromUser))){
+        if (StringUtil.isNotEmpty(redisUtils.getSweetMaoDengOpen(fromUser))) {
 
             //图片非法判断
             if (!shumeiUtil.checkImage(fromUser, picUrl)) {
@@ -49,11 +60,21 @@ public class MaoDengImageHandler implements WxMpMessageHandler {
             }
             SweetMaoDengVo sweetMaoDengVo = SweetMaoDengVo.getNew();
             sweetMaoDengVo.setUserId(fromUser);
+
+            if (picUrl != null && !picUrl.equals("")) {
+                MultiValueMap<String, String> params = new LinkedMultiValueMap();
+                params.add("pathName", "other.jpeg");
+                params.add("picUrl", picUrl);
+                String returnData = HttpUtil.post(platformUrl.concat("/platform/basicServices/alOss/uploadUrl"), params);
+                ResponseDto<UploadVo> dto = JsonUtils.fromJson(returnData, new TypeReference<ResponseDto<UploadVo>>() {
+                });
+                picUrl = "https://img.zhengzai.tv/".concat(dto.getData().getOssPath());
+            }
             sweetMaoDengVo.setPicUrl(picUrl);
             //活动已开启  持久化  redis
             SweetMaoDengVo sweetMaoDeng = redisUtils.getSweetMaoDengTransfer(fromUser);
-            if (sweetMaoDeng != null){
-                String textMsg=sweetMaoDeng.getTextMsg();
+            if (sweetMaoDeng != null) {
+                String textMsg = sweetMaoDeng.getTextMsg();
                 sweetMaoDengVo.setTextMsg(textMsg);
             }