添加图片

src/main/java/com/usky/dxtop/service/impl/StaffServiceImpl.java

@@ -108,7 +108,9 @@ public class StaffServiceImpl extends ServiceImpl<StaffMapper, Staff> implements
     @Override
     public void faceSendMessage(Staff staff){
         long seq = System.nanoTime();
-        String encode = Base64.encode(ImageUtils.getImage(staff.getFaceId()));
+        String s = StaffServiceImpl.replaceDomainAndPort("10.21.39.3", "19930", staff.getFaceId());
+        String replace = s.replace("https", "http");
+        String encode = Base64.encode(ImageUtils.getImage(replace));
         Map<String,Object> map = new HashMap<>();
         map.put("mob",staff.getSId());
         MsgLog msgLog = new MsgLog();
@@ -125,6 +127,31 @@ public class StaffServiceImpl extends ServiceImpl<StaffMapper, Staff> implements
         RabbitmqUtils.getRabbitmqTemplate(RabbitmqBeenCode.PROFILE_FACE_CONSUMER).convertAndSend(msgLog.getExchange(), msgLog.getRoutingKey(), map,correlationData);
     }
 
+
+    public static String replaceDomainAndPort(String domain,String port,String url){
+        String url_bak = "";
+        if(url.indexOf("//") != -1 ){
+            String[] splitTemp = url.split("//");
+            url_bak = splitTemp[0]+"//";
+            if(port != null){
+                url_bak = url_bak + domain+":"+port;
+            }else{
+                url_bak = url_bak + domain;
+            }
+
+            if(splitTemp.length >=1 && splitTemp[1].indexOf("/") != -1){
+                String[] urlTemp2 = splitTemp[1].split("/");
+                if(urlTemp2.length > 1){
+                    for(int i = 1;i < urlTemp2.length; i++){
+                        url_bak = url_bak +"/"+urlTemp2[i];
+                    }
+                }
+            }
+        }
+        return url_bak;
+    }
+
+
     @Override
     public List<Staff> selectStaffByPhoneList(List<String> phoneList) {
         return baseMapper.selectListByPhones(phoneList);