活码数据api迁移

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/hm/HmLinkController.java

@@ -9,6 +9,8 @@ import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 
+import com.alibaba.fastjson.JSON;
+import com.gic.haoban.manage.web.utils.DataApiHttpUtils;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang.StringUtils;
 import org.apache.logging.log4j.LogManager;
@@ -652,13 +654,13 @@ public class HmLinkController {
             jsonObject.put("linkType", "1,2");
         }
         if (qdto.getStartDate() != null) {
-            jsonObject.put("startTime", DateUtil.datetimeToString19(qdto.getStartDate()));
+            jsonObject.put("startDate", DateUtil.datetimeToString19(qdto.getStartDate()));
         }
         if (qdto.getEndDate() != null) {
-            jsonObject.put("endTime", DateUtil.datetimeToString19(qdto.getEndDate()));
+            jsonObject.put("endDate", DateUtil.datetimeToString19(qdto.getEndDate()));
         }
         if (StringUtils.isNotBlank(qdto.getSearchParams())) {
-            jsonObject.put("linkSelect", qdto.getSearchParams());
+            jsonObject.put("vagueQuery", qdto.getSearchParams());
         }
         List<String> creatorIdList = CreatorUtils.getCreatorIdList(0);
         if (CollectionUtils.isNotEmpty(creatorIdList)) {
@@ -670,13 +672,29 @@ public class HmLinkController {
         if (StringUtils.isBlank(qdto.getSortType())) {
             qdto.setSortType("desc");
         }
-        jsonObject.put("orderByField", qdto.getSortColumn() + " " + qdto.getSortType());
-        JSONObject param = DataStatisticsParamUtils.getParam(basePageInfo, jsonObject);
-        Page page = DataStatisticsParamUtils
-                .getPage(DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_link_list, param));
-        if (page == null) {
-            return RestResponse.successResult();
-        }
+        jsonObject.put("orderByType", qdto.getSortType().contains("desc") ? 2 : 1);
+        Map<String, Integer> orderByFieldMap = new HashMap<String, Integer>(8){{
+            put("createTime", 13);
+            put("addNumT", 6);
+            put("addNum", 7);
+            put("clickTimesT", 8);
+            put("clickTimes", 9);
+            put("clickNumT", 10);
+            put("clickNum", 11);
+        }};
+        jsonObject.put("orderByFields", qdto.getSortType().contains("desc") ? 2 : 1);
+        DataApiHttpUtils.dealParamJsonOrderBy(jsonObject, qdto.getSortColumn(), "createTime", orderByFieldMap);
+//        jsonObject.put("orderByField", qdto.getSortColumn() + " " + qdto.getSortType());
+        jsonObject.put("pageNum", basePageInfo.getPageNum());
+        jsonObject.put("pageSize", basePageInfo.getPageSize());
+//        Page page = DataStatisticsParamUtils
+//                .getPage(DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_link_list, param));
+//        if (page == null) {
+//            return RestResponse.successResult();
+//        }
+        Map<String, Object> res = DataApiHttpUtils.http(jsonObject.toJSONString(), StatisticsApolloKeyConstant.data_haoban_link_list);
+        Page page = DataApiHttpUtils.getPageData(res);
+
         Page<HmLinkListVO> retPage = EntityUtil.changeEntityByJSON(Page.class, page);
         if (CollectionUtils.isEmpty(page.getResult())) {
             return RestResponse.successResult(retPage);
@@ -753,9 +771,10 @@ public class HmLinkController {
         jsonObject.put("enterpriseId", loginUser.getEnterpriseId());
         jsonObject.put("linkId", qo.getLinkId());
         JSONObject param = DataStatisticsParamUtils.getParamNoPage(jsonObject);
+//        DataStatisticsParamUtils.responseOne(DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_link_overview, param));
         // HmLinkStatisticsVO vo = new HmLinkStatisticsVO();
-        return DataStatisticsParamUtils
-                .responseOne(DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_link_overview, param));
+        Map<String, Object> res = DataApiHttpUtils.http(jsonObject.toJSONString(), StatisticsApolloKeyConstant.data_haoban_link_overview);
+        return RestResponse.successResult(DataApiHttpUtils.getDataOne(res));
     }
 
     // 统计图表
@@ -773,8 +792,8 @@ public class HmLinkController {
 
         jsonObject.put("enterpriseId", loginUser.getEnterpriseId());
         jsonObject.put("linkId", linkId);
-        jsonObject.put("startTime", df.format(startTime));
-        jsonObject.put("endTime", df.format(endTime));
+        jsonObject.put("startDate", df.format(startTime));
+        jsonObject.put("endDate", df.format(endTime));
         // 日期填充
         List<String> dateList = DateUtils.getDateList(startTimeStr, endTimeStr, null);
         // 用于链接添加趋势图数据 企业+链接+日期
@@ -786,12 +805,17 @@ public class HmLinkController {
             apolloKey = "data_haoban_link_add_trend_m";
             clickApolloKey = "data_haoban_link_click_trend_m";
         }
-        JSONObject param = DataStatisticsParamUtils.getParamNoPage(jsonObject);
-        StatisticsDTO newDTO = DataHttpUtil.post(apolloKey, param);
-        Map<String, JSONObject> newMap = getTrendMap(newDTO);
+//        JSONObject param = DataStatisticsParamUtils.getParamNoPage(jsonObject);
+//        StatisticsDTO newDTO = DataHttpUtil.post(apolloKey, param);
+
+        Map<String, Object> res = DataApiHttpUtils.http(jsonObject.toJSONString(), apolloKey);
+        List<JSONObject> resList = DataApiHttpUtils.getDataList(res);
+        Map<String, JSONObject> newMap = getTrendMapNew(resList);
         //
-        StatisticsDTO clickDTO = DataHttpUtil.post(clickApolloKey, param);
-        Map<String, JSONObject> clickMap = getTrendMap(clickDTO);
+//        StatisticsDTO clickDTO = DataHttpUtil.post(clickApolloKey, param);
+        Map<String, Object> clerkRes = DataApiHttpUtils.http(jsonObject.toJSONString(), clickApolloKey);
+        List<JSONObject> clerkResList = DataApiHttpUtils.getDataList(clerkRes);
+        Map<String, JSONObject> clickMap = getTrendMapNew(clerkResList);
         List<JSONObject> resultList = new ArrayList<>();
         for (String date : dateList) {
             JSONObject vo = new JSONObject();
@@ -820,8 +844,19 @@ public class HmLinkController {
     public RestResponse<Object> statisticsClerk(@RequestBody HmLinkClerkListQO qo) {
         WebLoginDTO loginUser = AuthWebRequestUtil.getLoginUser();
         qo.getInFields().setEnterpriseId(loginUser.getEnterpriseId());
-        return DataStatisticsParamUtils
-                .responsePage(DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_link_detail, qo));
+
+        JSONObject paramJson = (JSONObject) JSON.toJSON(qo.getInFields());
+        DataApiHttpUtils.dealParamJsonClerkSelect(paramJson, "linkSelect1", "vagueQueryStore");
+        DataApiHttpUtils.dealParamJsonClerkSelect(paramJson, "linkSelect2", "vagueQueryClerk");
+        DataApiHttpUtils.dealParamJsonDate(paramJson);
+        Map<String, Integer> orderByFieldMap = new HashMap<String, Integer>(8){{
+            put("addNumT", 8);
+            put("addNum", 9);
+        }};
+        DataApiHttpUtils.dealParamJsonOrderBy(paramJson, qo.getInFields().getOrderByField(), "addNum", orderByFieldMap);
+        Map<String, Object> res = DataApiHttpUtils.http(paramJson.toJSONString(), StatisticsApolloKeyConstant.data_haoban_link_detail);
+
+        return RestResponse.successResult(DataApiHttpUtils.getPageData(res));
     }
 
     /**
@@ -851,4 +886,14 @@ public class HmLinkController {
         return newMap;
     }
 
+    private static Map<String, JSONObject> getTrendMapNew(List<JSONObject> list) {
+        Map<String, JSONObject> newMap = new HashMap<>();
+        if (CollectionUtils.isNotEmpty(list)) {
+            for (JSONObject temp : list) {
+                newMap.put(temp.getString("bizDate"), temp);
+            }
+        }
+        return newMap;
+    }
+
 }

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/hm/HmQrcodeController.java

@@ -10,6 +10,9 @@ import java.util.Map;
 import java.util.TreeSet;
 import java.util.stream.Collectors;
 
+import com.alibaba.fastjson.JSONObject;
+import com.gic.haoban.manage.api.dto.statistics.StatisticsPage;
+import com.gic.haoban.manage.web.utils.DataApiHttpUtils;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.logging.log4j.LogManager;
@@ -196,8 +199,29 @@ public class HmQrcodeController {
             hmIds.forEach(c -> stringBuffer.append(c).append(","));
             hmQrcodeListQO.getInFields().setHmId(stringBuffer.toString());
         }
-        StatisticsDTO statisticsDTO = DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_hm_list, hmQrcodeListQO);
-        List<HmQrcodeListDTO> data = JSON.parseArray(JSON.toJSONString(statisticsDTO.getData()), HmQrcodeListDTO.class);
+//        StatisticsDTO statisticsDTO = DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_hm_list, hmQrcodeListQO);
+//        List<HmQrcodeListDTO> data = JSON.parseArray(JSON.toJSONString(statisticsDTO.getData()), HmQrcodeListDTO.class);
+
+        JSONObject paramJson = (JSONObject) JSON.toJSON(hmQrcodeListQO.getInFields());
+        paramJson.put("pageNum", hmQrcodeListQO.getPageNo());
+        paramJson.put("pageSize", hmQrcodeListQO.getPageSize());
+        DataApiHttpUtils.dealParamJsonDate(paramJson);
+        Map<String, Integer> orderByFieldMap = new HashMap<String, Integer>(8){{
+            put("createTime", 15);
+            put("addNumT", 6);
+            put("addNum", 7);
+        }};
+        DataApiHttpUtils.dealParamJsonOrderBy(paramJson, hmQrcodeListQO.getInFields().getOrderByField(), "createTime", orderByFieldMap);
+        //todo guojx 参数调整
+        Map<String, Object> res = DataApiHttpUtils.http(paramJson.toJSONString(), StatisticsApolloKeyConstant.data_haoban_hm_list);
+        List<HmQrcodeListDTO> data = DataApiHttpUtils.parsePageList(res, HmQrcodeListDTO.class);
+        Page resPage = DataApiHttpUtils.getPageData(res);
+
+        StatisticsDTO statisticsDTO = new StatisticsDTO();
+        StatisticsPage page = EntityUtil.changeEntityNew(StatisticsPage.class, resPage);
+        statisticsDTO.setPage(page);
+        statisticsDTO.setErrorCode(1);
+        statisticsDTO.setSuccess(true);
         if (CollectionUtils.isNotEmpty(data)) {
             for (HmQrcodeListDTO hmQrcodeListDTO : data) {
                 List<HmStoreDTO> storeDTOList = new ArrayList<>();
@@ -368,18 +392,33 @@ public class HmQrcodeController {
         Integer type = hmTrendQO.getInFields().getType();
         WebLoginDTO loginUser = AuthWebRequestUtil.getLoginUser();
         hmTrendQO.getInFields().setEnterpriseId(loginUser.getEnterpriseId());
-        StatisticsDTO statisticsDTO = DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_hm_overview, hmTrendQO);
-        HmOverviewDTO hmOverviewDTO = JSON.parseObject(JSON.toJSONString(statisticsDTO.getOne()), HmOverviewDTO.class);
+//        StatisticsDTO statisticsDTO = DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_hm_overview, hmTrendQO);
+//        HmOverviewDTO hmOverviewDTO = JSON.parseObject(JSON.toJSONString(statisticsDTO.getOne()), HmOverviewDTO.class);
+
+        JSONObject paramJson = (JSONObject) JSON.toJSON(hmTrendQO.getInFields());
+        Map<String, Object> res = DataApiHttpUtils.http(paramJson.toJSONString(), StatisticsApolloKeyConstant.data_haoban_hm_overview);
+        List<HmOverviewDTO> resList = DataApiHttpUtils.parseList(res, HmOverviewDTO.class);
+
+        HmOverviewDTO hmOverviewDTO = CollectionUtils.isEmpty(resList) ? null : resList.get(0);
+
         HmTrendVO hmTrendVO = EntityUtil.changeEntityNew(HmTrendVO.class, hmOverviewDTO);
         List<Map> list = new ArrayList<>();
+
+        Map<String, Object> trendRes = null;
+        DataApiHttpUtils.dealParamJsonDate(paramJson);
         if (type == 1) {
             //天
-            StatisticsDTO dto = DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_hm_trend_d, hmTrendQO);
-            list = JSON.parseArray(JSON.toJSONString(dto.getData()), Map.class);
+//            StatisticsDTO dto = DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_hm_trend_d, hmTrendQO);
+            trendRes = DataApiHttpUtils.http(paramJson.toJSONString(),
+                    StatisticsApolloKeyConstant.data_haoban_hm_trend_d);
         } else if (type == 2) {
             //月
-            StatisticsDTO dto = DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_hm_trend_m, hmTrendQO);
-            list = JSON.parseArray(JSON.toJSONString(dto.getData()), Map.class);
+//            StatisticsDTO dto = DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_hm_trend_m, hmTrendQO);
+            trendRes = DataApiHttpUtils.http(paramJson.toJSONString(),
+                    StatisticsApolloKeyConstant.data_haoban_hm_trend_m);
+        }
+        if (trendRes != null) {
+            list = JSON.parseArray(JSON.toJSONString(DataApiHttpUtils.getDataList(trendRes)), Map.class);
         }
         if (hmTrendVO == null) {
             hmTrendVO = new HmTrendVO();
@@ -456,12 +495,31 @@ public class HmQrcodeController {
         }
         Integer hmType = hmQrcodeDTO.getHmType();
         StatisticsDTO statisticsDTO = null;
+
+        JSONObject paramJson = (JSONObject) JSON.toJSON(hmDetailClerkListQO.getInFields());
+        paramJson.put("pageNum", hmDetailClerkListQO.getPageNo());
+        paramJson.put("pageSize", hmDetailClerkListQO.getPageSize());
+        Map<String, Integer> orderByFieldMap = new HashMap<String, Integer>(8){{
+            put("addNumT", 9);
+            put("addNum", 10);
+        }};
+        DataApiHttpUtils.dealParamJsonClerkSelect(paramJson, "storeSelect", "vagueQueryStore");
+        DataApiHttpUtils.dealParamJsonClerkSelect(paramJson, "clerkSelect", "vagueQueryClerk");
+        DataApiHttpUtils.dealParamJsonDate(paramJson);
+        DataApiHttpUtils.dealParamJsonOrderBy(paramJson, hmDetailClerkListQO.getInFields().getOrderByField(), "addNum", orderByFieldMap);
+        Map<String, Object> res = null;
+        Page page = new Page();
         if (hmType == 1) {
-            statisticsDTO = DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_hm_single_detail, hmDetailClerkListQO);
+//            statisticsDTO = DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_hm_single_detail, hmDetailClerkListQO);
+            res = DataApiHttpUtils.http(paramJson.toJSONString(), StatisticsApolloKeyConstant.data_haoban_hm_single_detail);
+            page.setResult(DataApiHttpUtils.getPageList(res));
         } else if (hmType == 2) {
-            statisticsDTO = DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_hm_many_detail, hmDetailClerkListQO);
+//            statisticsDTO = DataHttpUtil.post(StatisticsApolloKeyConstant.data_haoban_hm_many_detail, hmDetailClerkListQO);
+            res = DataApiHttpUtils.http(paramJson.toJSONString(), StatisticsApolloKeyConstant.data_haoban_hm_many_detail);
+            page = DataApiHttpUtils.getPageData(res);
         }
-        return DataStatisticsParamUtils.responsePage(statisticsDTO);
+
+        return RestResponse.successResult(page);
     }
 
 

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/exception/GlobalExceptionHandler.java

 package com.gic.haoban.manage.web.exception;
 
+import com.gic.commons.webapi.reponse.RestResponse;
 import com.gic.haoban.base.api.common.ShowFrontMessageException;
 import com.gic.haoban.common.utils.HaobanResponse;
 import com.gic.haoban.manage.web.controller.WebBaseController;
 import com.gic.haoban.manage.web.errCode.HaoBanErrCode;
+import com.gic.marketing.api.exception.ErrmsgException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.validation.BindException;
@@ -140,4 +142,17 @@ public class GlobalExceptionHandler extends WebBaseController {
         return resultResponse(HaoBanErrCode.ERR_4);
     }
 
+    /**
+     * valid 异常告警
+     * @param response
+     * @param ex
+     * @return
+     */
+    @ResponseBody
+    @ExceptionHandler(ErrmsgException.class)
+    public RestResponse rrrmsgException(HttpServletResponse response, ErrmsgException ex) {
+        logger.info("exceoprion:{}", ex);
+        return RestResponse.failure("-1", ex.getMessage());
+    }
+
 }

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/utils/DataApiHttpUtils.java

+package com.gic.haoban.manage.web.utils;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.ctrip.framework.apollo.Config;
+import com.ctrip.framework.apollo.ConfigService;
+import com.gic.api.base.commons.Page;
+import com.gic.commons.util.EntityUtil;
+import com.gic.commons.util.HttpClient;
+import com.gic.commons.webapi.reponse.RestResponse;
+import com.gic.marketing.api.exception.ErrmsgException;
+import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.lang.StringUtils;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 数据组http接口调用工具类
+ * @Author guojx
+ * @Date 2023/6/25 14:39
+ */
+public class DataApiHttpUtils {
+    private static final Logger LOGGER = LogManager.getLogger(DataApiHttpUtils.class);
+
+    public static <T> RestResponse<Page<T>> responsePage(Map<String, Object> res, Class clazz) {
+        if (isSuccess(res)) {
+            Page page = getPageData(res);
+            if (CollectionUtils.isNotEmpty(page.getResult())) {
+                Page<T> resPage = EntityUtil.changeEntityNew(Page.class, page);
+                List voList = JSONObject.parseArray(JSON.toJSONString(page.getResult()), clazz);
+                resPage.setResult(voList);
+                return RestResponse.successResult(resPage);
+            }
+            return RestResponse.successResult(page);
+        }
+        return errorRes(res);
+    }
+
+    public static <T> RestResponse<List<T>> responsePageList(Map<String, Object> res, Class clazz) {
+        return RestResponse.successResult(parsePageList(res, clazz));
+    }
+
+    public static <T> List<T> parsePageList(Map<String, Object> res, Class clazz) {
+        Page page = getPageData(res);
+        if (CollectionUtils.isNotEmpty(page.getResult())) {
+            List voList = JSONObject.parseArray(JSON.toJSONString(page.getResult()), clazz);
+            return voList;
+        }
+        return Collections.EMPTY_LIST;
+    }
+
+    public static boolean isSuccess(Map<String, Object> res) {
+        return res.get("errCode").toString().equals("0");
+    }
+
+    public static RestResponse errorRes(Map<String, Object> res) {
+        return RestResponse.failure(res.get("errCode").toString(), res.get("errMsg").toString());
+    }
+
+    public static <T> List<T> parseList(Map<String, Object> res, Class clazz) {
+        List<JSONObject> list = getDataList(res);
+        if (CollectionUtils.isNotEmpty(list)) {
+            List voList = JSONObject.parseArray(JSON.toJSONString(list), clazz);
+            return voList;
+        }
+        return Collections.EMPTY_LIST;
+    }
+
+    public static List<JSONObject> getDataList(Map<String, Object> res) {
+        return (List<JSONObject>) res.get("data");
+    }
+    public static JSONObject getDataOne(Map<String, Object> res) {
+        List<JSONObject> list = getDataList(res);
+        return CollectionUtils.isNotEmpty(list) ? list.get(0) : null;
+    }
+
+    public static Page getPageData(Map<String, Object> res) {
+        if (!isSuccess(res)) {
+            throw new ErrmsgException(res.get("errMsg").toString());
+        }
+        JSONObject data = (JSONObject) res.get("data");
+        Page page = new Page();
+        page.setTotalCount(data.getIntValue("totalNum"));
+        page.setPageSize(data.getIntValue("pageSize"));
+        page.setCurrentPage(data.getIntValue("pageNum"));
+        List<JSONObject> list = (List<JSONObject>) data.get("rows");
+        page.setResult(list);
+        return page;
+    }
+
+    public static JSONObject getPageOne(Map<String, Object> res) {
+        Page page = getPageData(res);
+        if (CollectionUtils.isNotEmpty(page.getResult())) {
+            return (JSONObject) page.getResult().get(0);
+        }
+        return new JSONObject();
+    }
+
+    public static List<JSONObject> getPageList(Map<String, Object> res) {
+        Page page = getPageData(res);
+        if (CollectionUtils.isNotEmpty(page.getResult())) {
+            return (List<JSONObject>) page.getResult();
+        }
+        return Collections.EMPTY_LIST;
+    }
+
+    public static Map<String, Object> http(String jsonParam, String apolloKey) {
+        if (StringUtils.isNotBlank(jsonParam)) {
+            JSONObject jsonObject = JSONObject.parseObject(jsonParam);
+            dealStoreIdParam(jsonObject);
+            jsonParam = jsonObject.toJSONString();
+        }
+        LOGGER.info("接口的key：{}", apolloKey);
+        Config config = ConfigService.getConfig("COMMON.data-api-config");
+        String value = config.getProperty(apolloKey, "");
+        if (StringUtils.isBlank(value)) {
+            throw new ErrmsgException("数据接口配置有误！");
+        }
+        LOGGER.info("{}：Apollo查询的配置信息：{}", apolloKey, value);
+        String[] split = value.split("\\+\\+\\+\\+");
+        String url = split[0];
+        String token = split[1];
+
+        Map<String, String> head = new HashMap<>();
+        head.put("Content-Type", "application/json");
+        head.put("Authorization", token);
+        Map<String, Object> res = HttpClient.getWinxinResByJson(url, jsonParam, head);
+        if (!isSuccess(res)) {
+            throw new ErrmsgException(res.get("errMsg").toString());
+        }
+        LOGGER.info("调用接口{}，返回结果:{}", url, res);
+        return res;
+    }
+
+    public static void dealStoreIdParam(JSONObject objParam) {
+        if (objParam != null) {
+            if (objParam.containsKey("storeId")) {
+                Object storeId = objParam.get("storeId");
+                if (storeId == null || StringUtils.isBlank(storeId.toString())) {
+                    objParam.remove("storeId");
+                }
+            }
+        }
+    }
+
+    public static int getOrderByType(String str) {
+        if (StringUtils.isBlank(str)) {
+            return 2;
+        }
+        if (str.contains("desc")) {
+            return 2;
+        }
+        return 1;
+    }
+
+    public static int getOrderByFields(String str, String defaultStr, Map<String, Integer> map) {
+        if (StringUtils.isBlank(str)) {
+            str = defaultStr;
+        }
+        str = str.replace(" desc", "");
+        str = str.replace(" asc", "");
+        str = str.replace(" ", "");
+        return map.get(str);
+    }
+
+    public static void dealParamJsonDate(JSONObject paramJson) {
+        dealParamJsonClerkSelect(paramJson, "startTime", "startDate");
+        dealParamJsonClerkSelect(paramJson, "endTime", "endDate");
+    }
+
+    public static void dealParamJsonClerkSelect(JSONObject paramJson, String field, String httpField) {
+        if (paramJson.containsKey(field)) {
+            paramJson.put(httpField, paramJson.get(field));
+        }
+    }
+
+    public static void dealParamJsonOrderBy(JSONObject paramJson, String orderByStr, String defaultField, Map<String, Integer> orderByFieldMap) {
+        paramJson.put("orderByType", getOrderByType(orderByStr));
+        paramJson.put("orderByFields", getOrderByFields(orderByStr,
+                defaultField, orderByFieldMap));
+    }
+}