站点分页接口

周伟鹏
1 parent e3dc5c9c
Showing 3 changed files with 102 additions and 77 deletions
src/main/java/com/cnlive/shenhe/controller/SitesController.java
src/main/java/com/cnlive/shenhe/job/UsersJob.java → src/main/java/com/cnlive/shenhe/job/UsersSiteJob.java
src/main/java/com/cnlive/shenhe/serviceImpl/SitesServiceImpl.java
+package com.cnlive.shenhe.controller;
+
+import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
+import com.cnlive.shenhe.utils.CommonUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+/**
+ * @Auther: 周伟鹏
+ * @Date: 2018/11/30 17:28
+ * @Description:
+ */
+@Controller
+@RequestMapping("/users")
+public class SitesController {
+
+    @Autowired
+    SitesServiceImpl sitesService;
+
+
+    @GetMapping(value = "/page")
+    @ResponseBody
+    public Object getTest(Integer page,Integer pageSize,String orderByClause,String key,Integer spid){
+        if(CommonUtils.isNull(page))page=1;
+        if(CommonUtils.isNull(pageSize))pageSize=10;
+        return  sitesService.getPage(page,pageSize,orderByClause,key,spid);
+    }
+
+}
@@ -3,9 +3,14 @@ package com.cnlive.shenhe.job;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyUsers;
+import com.cnlive.shenhe.mapper.ShySitesMapper;
 import com.cnlive.shenhe.mapper.ShyUsersMapper;
-import com.cnlive.shenhe.utils.*;
+import com.cnlive.shenhe.utils.CommonConst;
+import com.cnlive.shenhe.utils.CommonUtils;
+import com.cnlive.shenhe.utils.HttpUtil;
+import com.cnlive.shenhe.utils.OpenUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -14,18 +19,19 @@ import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import tk.mybatis.mapper.entity.Example;
-import java.io.UnsupportedEncodingException;
-import java.net.URLEncoder;
-import java.util.*;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 /**
  * @Auther: 周伟鹏
  * @Date: 2018/11/30 11:31
- * @Description:
+ * @Description:同步用户和站点信息
  */
 @Component
-public class UsersJob {
-    private static Logger logger = LoggerFactory.getLogger(UsersJob.class);
+public class UsersSiteJob {
+    private static Logger logger = LoggerFactory.getLogger(UsersSiteJob.class);
     @Value("${sync_users_api}")
     private String syncUserApi;
@@ -36,6 +42,9 @@ public class UsersJob {
     @Autowired
     ShyUsersMapper shyUsersMapper;
+    @Autowired
+    ShySitesMapper shySitesMapper;
+
     @Scheduled(fixedRate = 30 * 60 * 1000)
     public void syncUsers() {
@@ -59,6 +68,7 @@ public class UsersJob {
             if ("0".equals(errorCode)) {
                 JSONArray data = result.getJSONArray("data");
                 for (int i = 0; i < data.size(); i++) {
+                    //用户信息入库
                     JSONObject user = data.getJSONObject(i);
                     Integer id = user.getInteger("sid");
                     String email = user.getString("email");
@@ -92,6 +102,16 @@ public class UsersJob {
                     } else {
                         shyUsersMapper.updateByPrimaryKeySelective(shyUsers);
                     }
+                    //站点信息入库
+                    ShySites shySites = new ShySites();
+                    shySites.setSpid(spid);
+                    List<ShySites> shySitesList = shySitesMapper.select(shySites);
+                    if(shySitesList.isEmpty()){
+                        shySites.setCompany(company);
+                        shySites.setName(company_brief);
+                        shySitesMapper.insertSelective(shySites);
+                    }
+
                 }
             } else {
                 logger.error("请求用户云失败，errorCode:{},errorMessage{}", errorCode, result.getString("errorMessage"));
@@ -103,74 +123,4 @@ public class UsersJob {
     }
-
-    /**
-     * 生成URL
-     *
-     * @param url
-     * @param params
-     * @param app_key
-     * @return
-     */
-    public static String buildURL(String url, Map<String, String> params, String app_key) {
-        Map<String, String> map = order(params);
-        if (map.containsKey("sign")) {
-            map.remove("sign");
-        }
-        String str = mapJoin(map, true, false);
-        String sign = SHA1.SHA1Digest(str + "&key=" + app_key).toUpperCase();
-        map.put("sign", sign);
-        return url + "?" + mapJoin(map, false, true);
-    }
-
-    /**
-     * Map key 排序
-     *
-     * @param map
-     * @return
-     */
-    private static Map<String, String> order(Map<String, String> map) {
-        HashMap<String, String> tempMap = new LinkedHashMap<String, String>();
-        List<Map.Entry<String, String>> infoIds = new ArrayList<Map.Entry<String, String>>(map.entrySet());
-
-        Collections.sort(infoIds, new Comparator<Map.Entry<String, String>>() {
-            public int compare(Map.Entry<String, String> o1, Map.Entry<String, String> o2) {
-                return (o1.getKey()).toString().compareTo(o2.getKey());
-            }
-        });
-
-        for (int i = 0; i < infoIds.size(); i++) {
-            Map.Entry<String, String> item = infoIds.get(i);
-            tempMap.put(item.getKey(), item.getValue());
-        }
-        return tempMap;
-    }
-
-    /**
-     * url 参数串连
-     *
-     * @param map
-     * @param keyLower
-     * @param valueUrlencode
-     * @return
-     */
-    private static String mapJoin(Map<String, String> map, boolean keyLower, boolean valueUrlencode) {
-        StringBuilder stringBuilder = new StringBuilder();
-        for (String key : map.keySet()) {
-            if (map.get(key) != null && !"".equals(map.get(key))) {
-                try {
-                    stringBuilder.append(key)
-                            .append("=")
-                            .append(valueUrlencode ? URLEncoder.encode(map.get(key), "utf-8").replace("+", "%20") : map.get(key))
-                            .append("&");
-                } catch (UnsupportedEncodingException e) {
-                    e.printStackTrace();
-                }
-            }
-        }
-        if (stringBuilder.length() > 0) {
-            stringBuilder.deleteCharAt(stringBuilder.length() - 1);
-        }
-        return stringBuilder.toString();
-    }
 }
+package com.cnlive.shenhe.serviceImpl;
+
+import com.cnlive.shenhe.entity.ShySites;
+import com.cnlive.shenhe.mapper.ShySitesMapper;
+import com.cnlive.shenhe.utils.CommonUtils;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import tk.mybatis.mapper.entity.Example;
+
+import java.util.List;
+
+/**
+ * @Auther: 周伟鹏
+ * @Date: 2018/11/29 14:23
+ * @Description:
+ */
+@Service
+public class SitesServiceImpl {
+    @Autowired
+    ShySitesMapper shySitesMapper;
+
+    public PageInfo<ShySites> getPage(Integer page, Integer pageSize, String orderByClause,String key, Integer spId){
+        Example example = new Example(ShySites.class);
+        Example.Criteria criteria = example.createCriteria();
+        if (CommonUtils.isNotEmpty(orderByClause)) {
+            example.setOrderByClause(orderByClause);
+        }
+        if (CommonUtils.isNotEmpty(key)){
+            criteria.andEqualTo("name", "%" + key + "%");
+            criteria.andLike("company", "%" + key + "%");
+        }
+        if (CommonUtils.isNotNull(spId))
+            criteria.andEqualTo("spid", spId);
+        PageHelper.startPage(page, pageSize, true);
+        List<ShySites> shySitesList = shySitesMapper.selectByExample(example);
+        PageInfo<ShySites> pageInfo = new PageInfo<ShySites>(shySitesList);
+        return pageInfo;
+    }
+
+
+}