From a75b18a4157ab486e0b51c438ac165ab3a08e3e0 Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期四, 25 七月 2024 18:10:00 +0800
Subject: [PATCH] 代码提交

---
 server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomZhongTaiServiceImpl.java |  100 +++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 78 insertions(+), 22 deletions(-)

diff --git a/server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomZhongTaiServiceImpl.java b/server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomZhongTaiServiceImpl.java
index 8abf61d..dc18be7 100644
--- a/server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomZhongTaiServiceImpl.java
+++ b/server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomZhongTaiServiceImpl.java
@@ -67,7 +67,7 @@
      */
    @Override
    public ZTSysuserGetTokenResponse getSysuserToken(String  mobile){
-       ZTBaseResponse<ZTSysuserGetTokenResponse> result = sendHttpRequest(
+       ZTBaseResponse<ZTSysuserGetTokenResponse> result = sendSysHttpRequest(
                ZTConstants.IntegerUrl.USER_MOBILE_FASTLOGIN_URL+"?mobile="+mobile,
                ZTConstants.IntegerName.USER_MOBILE_FASTLOGIN_NAME,
                null,
@@ -83,27 +83,7 @@
      * 鑾峰彇鐢ㄦ埛鐧婚檰token
      * @return
      */
-   @Override
-   public ZSZXCatalogResponse getZSZXCatalogs(){
-       ZSZXCatalogResponse response = new ZSZXCatalogResponse();
-       ZTCatalogListRequest param = new ZTCatalogListRequest();
-       param.setCatalogCode(ZTConstants.CatalogCode.ZHISHUO_ZHUANGXIU);
-       List<ZTCatalogInfoResponse> cataList = getCatalogList(param);
-        if(cataList!=null ){
-            for(ZTCatalogInfoResponse data : cataList){
-                if(StringUtils.equals(data.getCode(), ZTConstants.CatalogCode.JIADE_ID)){
-                    response.setJdId(data);
-                }else if(StringUtils.equals(data.getCode(), ZTConstants.CatalogCode.CHUFANGSHEJI)){
-                    response.setCfsj(data);
-                }else if(StringUtils.equals(data.getCode(), ZTConstants.CatalogCode.QW_SHEJI)){
-                    response.setQwsj(data);
-                }else if(StringUtils.equals(data.getCode(), ZTConstants.CatalogCode.SHOUNASHEJI)){
-                    response.setSnsj(data);
-                }
-            }
-        }
-       return response;
-   }
+
     /**
      * 鐢ㄦ埛淇℃伅鍚屾
      * @param param
@@ -692,6 +672,40 @@
         }
         return  null;
     }
+
+    public   <T>   ZTBaseResponse<T> sendSysHttpRequest(String url,String name,String token,String userType,String param,TypeReference<ZTBaseResponse<T>> typeReference){
+        log.info("銆�"+name+"銆�================寮�濮�===="+ JSONObject.toJSONString(param));
+        String res = null;
+        int success = 0;
+        try {
+            Map<String,String> headers = new HashMap<>();
+            if(StringUtils.equals(userType,ZTConstants.CUSTOMER)){
+                //濡傛灉鏄疌绔鎴�
+                headers.put(ZTConstants.HEADER_TOKEN,token);
+            }else{
+                //濡傛灉鏄疊绔敤鎴�
+                headers.put(ZTConstants.HEADER_SYSUSER_TOKEN,token);
+            }
+            headers.put(ZTConstants.HEADER_USERTYPE,userType);
+            String index = (String) redisTemplate.opsForValue().get(Constants.RedisKeys.ZBOM_ZHONGTAI_SYS_API_URL);
+            res = HttpsUtil.postJsonWithHeaders(index+url,param,headers);
+            ZTBaseResponse<T>  result = JSONObject.parseObject(res, typeReference.getType());
+            logResult(result,name);
+            if(Constants.equalsInteger(result.getCode(),ZTConstants.CODE_SUCCESS)){
+                return  result;
+            }else{
+                success =1;
+            }
+        }catch (Exception e){
+            success = 1;
+            log.error("銆�"+name+"銆�================澶辫触===="+ JSONObject.toJSONString(param));
+        }finally {
+            saveInterfaceLog(url,name,param,success,res);
+        }
+        return  null;
+    }
+
+
     public  void  saveInterfaceLog(String url,String name,String  param,Integer success,String respone){
         if(interfaceLogMapper ==null){
             return;
@@ -716,4 +730,46 @@
             log.error("銆愪腑鍙版帴鍙o細"+name+"銆�================澶辫触====锛歕n"+ res);
         }
     }
+
+
+    /**
+     * 鑾峰彇鎴戠殑鍠滄/鏀惰棌鍒楄〃
+     * @param param
+     * @return
+     */
+    @Override
+    public ZTBasePageResponse<ZTCollectLikeInfoResponse> collectLikePage(ZTCollectLikeRequest param){
+        ZTBaseResponse<ZTBasePageResponse<ZTCollectLikeInfoResponse>> result = sendHttpRequest(
+                ZTConstants.IntegerUrl.FAVORITES_PAGE_URL,
+                ZTConstants.IntegerName.FAVORITES_NAME,
+                param.getToken(),
+                param.getUserType(),
+                JSONObject.toJSONString(param ),
+                new TypeReference<ZTBaseResponse<ZTBasePageResponse<ZTCollectLikeInfoResponse>>>(){});
+        if(result!=null){
+            return result.getData();
+        }
+        return null;
+    }
+
+    /**
+     * 鑾峰彇鍒嗙被鍜屽垎绫讳笅鐨勬爣绛�
+     * @param param
+     * @return
+     */
+    @Override
+    public ZTBaseResponse batchAddLike(ZTBatchAddListRequest param){
+        ZTBaseResponse result = sendHttpRequest(
+                ZTConstants.IntegerUrl.BATCH_ADD_LIKE_URL,
+                ZTConstants.IntegerName.BATCH_ADD_LIKE_NAME,
+                param.getToken(),
+                param.getUserType(),
+                JSONObject.toJSONString(param ),
+                new TypeReference<ZTBaseResponse<Object>>(){});
+        if(result!=null){
+            return result;
+        }
+        return null;
+    }
+
 }

--
Gitblit v1.9.3