添加获取用户信息定时任务

周伟鹏
1 parent 3172f463
Showing 10 changed files with 1038 additions and 85 deletions
pom.xml
src/main/java/com/cnlive/shenhe/entity/ShySites.java
src/main/java/com/cnlive/shenhe/entity/ShyUsers.java
src/main/java/com/cnlive/shenhe/job/UsersJob.java
src/main/java/com/cnlive/shenhe/utils/CommonConst.java
src/main/java/com/cnlive/shenhe/utils/HttpUtil.java
src/main/java/com/cnlive/shenhe/utils/OpenUtil.java
src/main/java/com/cnlive/shenhe/utils/SHA1.java
src/main/resources/application.properties
src/main/resources/mapper/ShyUsersMapper.xml
@@ -90,6 +90,14 @@
             <artifactId>slf4j-api</artifactId>
             <version>1.7.25</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpmime</artifactId>
+        </dependency>
     </dependencies>
  
     <build>
@@ -27,7 +27,7 @@ public class ShySites {
     private String appid;
  
     /**
-     * 免审业务
+     * 免审业务,多种用,分割
      */
     private String write_business;
  
@@ -138,18 +138,18 @@ public class ShySites {
     }
  
     /**
-     * 获取免审业务
+     * 获取免审业务,多种用,分割
      *
-     * @return write_business - 免审业务
+     * @return write_business - 免审业务,多种用,分割
      */
     public String getWrite_business() {
         return write_business;
     }
  
     /**
-     * 设置免审业务
+     * 设置免审业务,多种用,分割
      *
-     * @param write_business 免审业务
+     * @param write_business 免审业务,多种用,分割
      */
     public void setWrite_business(String write_business) {
         this.write_business = write_business;
@@ -14,18 +14,6 @@ public class ShyUsers {
     private String username;
  
     /**
-     * 大网用户id
-     */
-    private Integer sid;
-
-    private String remember_token;
-
-    /**
-     * 联系人
-     */
-    private String contacts;
-
-    /**
      * 邮箱
      */
     private String email;
@@ -67,7 +55,9 @@ public class ShyUsers {
     /**
      * 接口最后一次更新时间
      */
-    private String tm;
+    private Long tm;
+
+    private String user_logo;
  
     /**
      * @return id
@@ -102,56 +92,6 @@ public class ShyUsers {
     }
  
     /**
-     * 获取大网用户id
-     *
-     * @return sid - 大网用户id
-     */
-    public Integer getSid() {
-        return sid;
-    }
-
-    /**
-     * 设置大网用户id
-     *
-     * @param sid 大网用户id
-     */
-    public void setSid(Integer sid) {
-        this.sid = sid;
-    }
-
-    /**
-     * @return remember_token
-     */
-    public String getRemember_token() {
-        return remember_token;
-    }
-
-    /**
-     * @param remember_token
-     */
-    public void setRemember_token(String remember_token) {
-        this.remember_token = remember_token;
-    }
-
-    /**
-     * 获取联系人
-     *
-     * @return contacts - 联系人
-     */
-    public String getContacts() {
-        return contacts;
-    }
-
-    /**
-     * 设置联系人
-     *
-     * @param contacts 联系人
-     */
-    public void setContacts(String contacts) {
-        this.contacts = contacts;
-    }
-
-    /**
      * 获取邮箱
      *
      * @return email - 邮箱
@@ -310,7 +250,7 @@ public class ShyUsers {
      *
      * @return tm - 接口最后一次更新时间
      */
-    public String getTm() {
+    public Long getTm() {
         return tm;
     }
  
@@ -319,7 +259,21 @@ public class ShyUsers {
      *
      * @param tm 接口最后一次更新时间
      */
-    public void setTm(String tm) {
+    public void setTm(Long tm) {
         this.tm = tm;
     }
+
+    /**
+     * @return user_logo
+     */
+    public String getUser_logo() {
+        return user_logo;
+    }
+
+    /**
+     * @param user_logo
+     */
+    public void setUser_logo(String user_logo) {
+        this.user_logo = user_logo;
+    }
 }
 \ No newline at end of file
 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.ShyUsers;
 import com.cnlive.shenhe.mapper.ShyUsersMapper;
-import com.cnlive.shenhe.serviceImpl.UsersServiceImpl;
+import com.cnlive.shenhe.utils.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import tk.mybatis.mapper.entity.Example;
  
-import java.util.List;
+import java.io.UnsupportedEncodingException;
+import java.net.URLEncoder;
+import java.util.*;
  
 /**
  * @Auther: 周伟鹏
@@ -20,19 +27,150 @@ import java.util.List;
 public class UsersJob {
     private static Logger logger = LoggerFactory.getLogger(UsersJob.class);
  
+    @Value("${sync_users_api}")
+    private String syncUserApi;
+
+    @Value("${sync_users_app_key}")
+    private String app_key;
  
     @Autowired
     ShyUsersMapper shyUsersMapper;
  
-    //@Scheduled(fixedRate = 30*60 * 1000)
+
+    @Scheduled(fixedRate = 30 * 60 * 1000)
     public void syncUsers() {
-        long tm = 0L;
-        Example usersExample = new Example(ShyUsers.class);
-        usersExample.setOrderByClause("tm desc");
-        List<ShyUsers> usersList = shyUsersMapper.selectByExample(usersExample);
-        if(!usersList.isEmpty()){
-            String tmStr = usersList.get(0).getTm();
+        try {
+            String tm = "0";
+            Example usersExample = new Example(ShyUsers.class);
+            usersExample.setOrderByClause("tm desc");
+            List<ShyUsers> usersList = shyUsersMapper.selectByExample(usersExample);
+            if (!usersList.isEmpty()) {
+                Long tmStr = usersList.get(0).getTm();
+                if (CommonUtils.isNotNull(tmStr)) tm = tmStr + "";
+            }
+            HashMap<String, String> dataMap = new HashMap<>();
+            dataMap.put("tm", tm);
+            dataMap.put("timestamp", new Date().getTime() / 1000 + "");
+            String httpUrl = OpenUtil.buildURL(syncUserApi, dataMap, app_key);
+            logger.info("httpUrl===" + httpUrl);
+            Map<String, String> resultMap = HttpUtil.init().post(httpUrl);
+            JSONObject result = JSON.parseObject(resultMap.get("result"));
+            String errorCode = result.getString("errorCode");
+            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");
+                    Integer spid = user.getInteger("new_sp_id");
+                    String userLogo = user.getString("userLogo");
+                    boolean master = user.getBoolean("master");
+                    Long utm = user.getLong("tm");
+                    String username = user.getString("contacts");
+                    boolean status = user.getIntValue("status") == CommonConst.USER_STATUS_USE;
+                    if (CommonUtils.isEmpty(username)) {
+                        username = Integer.toString(id);
+                    }
+                    String mobile = user.getString("mobile");
+                    String company_brief = user.getString("sname");
+                    String company = user.getString("company");
+                    ShyUsers shyUsers = new ShyUsers();
+                    shyUsers.setEmail(email);
+                    shyUsers.setId(id);
+                    shyUsers.setSp_id(spid);
+                    shyUsers.setMaster(master);
+                    shyUsers.setState(status);
+                    shyUsers.setMobile(mobile);
+                    shyUsers.setUsername(username);
+                    shyUsers.setCompany_brief(company_brief);
+                    shyUsers.setCompany_name(company);
+                    shyUsers.setUser_logo(userLogo);
+                    shyUsers.setTm(utm);
+                    ShyUsers old_shyUsers = shyUsersMapper.selectByPrimaryKey(id);
+                    if (CommonUtils.isNull(old_shyUsers)) {
+                        shyUsersMapper.insertSelective(shyUsers);
+                    } else {
+                        shyUsersMapper.updateByPrimaryKeySelective(shyUsers);
+                    }
+                }
+            } else {
+                logger.error("请求用户云失败，errorCode:{},errorMessage{}", errorCode, result.getString("errorMessage"));
+            }
+
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+    }
+
+
+    /**
+     * 生成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();
     }
 }
@@ -20,6 +20,13 @@ public class CommonConst {
     public static Integer AUDIT_REFUSE = 2;
  
  
-   
+    /**
+     * 用户状态：可用
+     */
+    public static Integer USER_STATUS_USE = 1;
+    /**
+     * 用户状态：禁用
+     */
+    public static Integer USER_STATUS_FORBID = 2;
  
 }
+package com.cnlive.shenhe.utils;
+
+import org.apache.http.Header;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpStatus;
+import org.apache.http.NameValuePair;
+import org.apache.http.auth.AuthScope;
+import org.apache.http.auth.UsernamePasswordCredentials;
+import org.apache.http.client.CredentialsProvider;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.config.RequestConfig.Builder;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.methods.HttpUriRequest;
+import org.apache.http.client.utils.URIBuilder;
+import org.apache.http.entity.ContentType;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.entity.mime.MultipartEntityBuilder;
+import org.apache.http.entity.mime.content.FileBody;
+import org.apache.http.impl.client.BasicCredentialsProvider;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
+import org.apache.http.message.BasicHeader;
+import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.util.EntityUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.util.CollectionUtils;
+import org.springframework.util.StringUtils;
+
+import java.io.File;
+import java.io.InputStream;
+import java.io.UnsupportedEncodingException;
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.nio.charset.UnsupportedCharsetException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Map.Entry;
+
+/**
+ * http请求工具类
+ *
+ * @author liujiong
+ */
+public class HttpUtil {
+
+    private Logger logger = LoggerFactory.getLogger(HttpUtil.class);
+
+    private static PoolingHttpClientConnectionManager pcm;//httpclient连接池
+    private CloseableHttpClient httpClient = null; //http连接
+    private int connectTimeout = 120000;//连接超时时间
+    private int connectionRequestTimeout = 10000;//从连接池获取连接超时时间
+    private int socketTimeout = 300000;//获取数据超时时间
+    private String charset = "utf-8";
+    private RequestConfig requestConfig = null;//请求配置
+    private Builder requestConfigBuilder = null;//build requestConfig
+
+    private List<NameValuePair> nvps = new ArrayList<>();
+    private List<Header> headers = new ArrayList<>();
+    private String requestParam = "";
+
+    static {
+        pcm = new PoolingHttpClientConnectionManager();
+        pcm.setMaxTotal(50);//整个连接池最大连接数
+        pcm.setDefaultMaxPerRoute(50);//每路由最大连接数，默认值是2
+    }
+
+    /**
+     * 默认设置
+     *
+     * @author Liu Jiong
+     * @createDate 2016年10月30日
+     */
+    private static HttpUtil defaultInit() {
+        HttpUtil httpUtil = new HttpUtil();
+        if (httpUtil.requestConfig == null) {
+            httpUtil.requestConfigBuilder = RequestConfig.custom().setConnectTimeout(httpUtil.connectTimeout)
+                    .setConnectionRequestTimeout(httpUtil.connectionRequestTimeout)
+                    .setSocketTimeout(httpUtil.socketTimeout);
+            httpUtil.requestConfig = httpUtil.requestConfigBuilder.build();
+        }
+        return httpUtil;
+    }
+
+    /**
+     * 初始化 httpUtil
+     */
+    public static HttpUtil init() {
+        HttpUtil httpUtil = defaultInit();
+        if (httpUtil.httpClient == null) {
+            httpUtil.httpClient = HttpClients.custom().setConnectionManager(pcm).build();
+        }
+        return httpUtil;
+    }
+
+    /**
+     * 初始化 httpUtil
+     */
+    public static HttpUtil init(Map<String, String> paramMap) {
+        HttpUtil httpUtil = init();
+        httpUtil.setParamMap(paramMap);
+        return httpUtil;
+    }
+
+    /**
+     * 验证初始化
+     */
+    public static HttpUtil initWithAuth(String ip, int port, String username, String password) {
+        HttpUtil httpUtil = defaultInit();
+        if (httpUtil.httpClient == null) {
+            CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
+            credentialsProvider.setCredentials(new AuthScope(ip, port, AuthScope.ANY_REALM), new UsernamePasswordCredentials(username, password));
+            httpUtil.httpClient = HttpClients.custom().setDefaultCredentialsProvider(credentialsProvider)
+                    .setConnectionManager(pcm).build();
+        }
+        return httpUtil;
+    }
+
+    /**
+     * 设置请求头
+     */
+    public HttpUtil setHeader(String name, String value) {
+        Header header = new BasicHeader(name, value);
+        headers.add(header);
+        return this;
+    }
+
+    /**
+     * 设置请求头
+     */
+    public HttpUtil setHeaderMap(Map<String, String> headerMap) {
+        for (Entry<String, String> param : headerMap.entrySet()) {
+            Header header = new BasicHeader(param.getKey(), param.getValue());
+            headers.add(header);
+        }
+        return this;
+    }
+
+    /**
+     * 设置请求参数
+     */
+    public HttpUtil setParam(String name, String value) {
+        nvps.add(new BasicNameValuePair(name, value));
+        return this;
+    }
+
+    /**
+     * 设置请求参数
+     */
+    public HttpUtil setParamMap(Map<String, String> paramMap) {
+        for (Entry<String, String> param : paramMap.entrySet()) {
+            nvps.add(new BasicNameValuePair(param.getKey(), param.getValue()));
+        }
+        return this;
+    }
+
+    /**
+     * 设置字符串参数
+     */
+    public HttpUtil setStringParam(String requestParam) {
+        this.requestParam = requestParam;
+        return this;
+    }
+
+    /**
+     * 设置连接超时时间
+     */
+    public HttpUtil setConnectTimeout(int connectTimeout) {
+        this.connectTimeout = connectTimeout;
+        this.requestConfigBuilder = requestConfigBuilder.setConnectTimeout(connectTimeout);
+        requestConfig = requestConfigBuilder.build();
+        return this;
+    }
+
+    /**
+     * http get 请求
+     */
+    public Map<String, String> get(String url) {
+        Map<String, String> resultMap = new HashMap<>();
+        //获取请求URI
+        URI uri = getUri(url);
+        if (uri != null) {
+            HttpGet httpGet = new HttpGet(uri);
+            httpGet.setConfig(requestConfig);
+            if (!CollectionUtils.isEmpty(headers)) {
+                Header[] header = new Header[headers.size()];
+                httpGet.setHeaders(headers.toArray(header));
+            }
+
+            //执行get请求
+            try {
+                CloseableHttpResponse response = httpClient.execute(httpGet);
+                return getHttpResult(response, url, httpGet, resultMap);
+            } catch (Exception e) {
+                httpGet.abort();
+                resultMap.put("result", e.getMessage());
+                logger.error("获取http GET请求返回值失败 url======" + url, e);
+            }
+        }
+        return resultMap;
+    }
+
+    /**
+     * http post 请求
+     */
+    public Map<String, String> post(String url) {
+        HttpPost httpPost = new HttpPost(url);
+        httpPost.setConfig(requestConfig);
+        if (!CollectionUtils.isEmpty(headers)) {
+            Header[] header = new Header[headers.size()];
+            httpPost.setHeaders(headers.toArray(header));
+        }
+        if (!CollectionUtils.isEmpty(nvps)) {
+            try {
+                httpPost.setEntity(new UrlEncodedFormEntity(nvps, charset));
+            } catch (UnsupportedEncodingException e) {
+                logger.error("http post entity form error", e);
+            }
+        }
+        if (!StringUtils.isEmpty(requestParam)) {
+            try {
+                httpPost.setEntity(new StringEntity(requestParam, charset));
+            } catch (UnsupportedCharsetException e) {
+                logger.error("http post entity form error", e);
+            }
+        }
+        Map<String, String> resultMap = new HashMap<>();
+        //执行post请求
+        try {
+            CloseableHttpResponse response = httpClient.execute(httpPost);
+            return getHttpResult(response, url, httpPost, resultMap);
+        } catch (Exception e) {
+            httpPost.abort();
+            resultMap.put("result", e.getMessage());
+            logger.error("获取http POST请求返回值失败 url======" + url, e);
+        }
+        return resultMap;
+    }
+
+    /**
+     * post 上传文件
+     */
+    public Map<String, String> postUploadFile(String url, Map<String, File> fileParam) {
+        HttpPost httpPost = new HttpPost(url);
+        httpPost.setConfig(requestConfig);
+        if (!CollectionUtils.isEmpty(headers)) {
+            Header[] header = new Header[headers.size()];
+            httpPost.setHeaders(headers.toArray(header));
+        }
+
+        MultipartEntityBuilder builder = MultipartEntityBuilder.create();
+        if (fileParam != null) {
+            for (Entry<String, File> entry : fileParam.entrySet()) {
+                //将要上传的文件转化为文件流
+                FileBody fileBody = new FileBody(entry.getValue());
+                //设置请求参数
+                builder.addPart(entry.getKey(), fileBody);
+            }
+        }
+
+        if (!CollectionUtils.isEmpty(nvps)) {
+            for (NameValuePair nvp : nvps) {
+                String value = nvp.getValue();
+                if (!StringUtils.isEmpty(value)) {
+                    builder.addTextBody(nvp.getName(), value, ContentType.create("text/plain", charset));
+                }
+            }
+        }
+        httpPost.setEntity(builder.build());
+        Map<String, String> resultMap = new HashMap<>();
+        //执行post请求
+        try {
+            CloseableHttpResponse response = httpClient.execute(httpPost);
+            return getHttpResult(response, url, httpPost, resultMap);
+        } catch (Exception e) {
+            httpPost.abort();
+            resultMap.put("result", e.getMessage());
+            logger.error("获取http postUploadFile 请求返回值失败 url======" + url, e);
+        }
+        return resultMap;
+    }
+
+    /**
+     * 获取请求返回值
+     */
+    private Map<String, String> getHttpResult(CloseableHttpResponse response, String url, HttpUriRequest request, Map<String, String> resultMap) {
+        String result = "";
+        int statusCode = response.getStatusLine().getStatusCode();
+        resultMap.put("statusCode", statusCode + "");
+        HttpEntity entity = response.getEntity();
+        if (entity != null) {
+            try {
+                result = EntityUtils.toString(entity, charset);
+                EntityUtils.consume(entity);//释放连接
+            } catch (Exception e) {
+                logger.error("获取http请求返回值解析失败", e);
+                request.abort();
+            }
+        }
+        if (statusCode != 200) {
+            result = "HttpClient status code :" + statusCode + "  request url===" + url;
+            logger.info("HttpClient status code :" + statusCode + "  request url===" + url);
+            request.abort();
+        }
+        resultMap.put("result", result);
+        return resultMap;
+    }
+
+    /**
+     * 获取重定向url返回的location
+     */
+    public String redirectLocation(String url) {
+        String location = "";
+        //获取请求URI
+        URI uri = getUri(url);
+        if (uri != null) {
+            HttpGet httpGet = new HttpGet(uri);
+            requestConfig = requestConfigBuilder.setRedirectsEnabled(false).build();//设置自动重定向false
+            httpGet.setConfig(requestConfig);
+            if (!CollectionUtils.isEmpty(headers)) {
+                Header[] header = new Header[headers.size()];
+                httpGet.setHeaders(headers.toArray(header));
+            }
+
+            try {
+                //执行get请求
+                CloseableHttpResponse response = httpClient.execute(httpGet);
+                int statusCode = response.getStatusLine().getStatusCode();
+                if (statusCode == HttpStatus.SC_MOVED_PERMANENTLY || statusCode == HttpStatus.SC_MOVED_TEMPORARILY) {//301 302
+                    Header header = response.getFirstHeader("Location");
+                    if (header != null) {
+                        location = header.getValue();
+                    }
+                }
+                HttpEntity entity = response.getEntity();
+                if (entity != null) {
+                    EntityUtils.consume(entity);
+                }
+            } catch (Exception e) {
+                logger.error("获取http GET请求获取 302 Location失败 url======" + url, e);
+                httpGet.abort();
+            }
+        }
+        return location;
+    }
+
+    /**
+     * 获取输入流
+     */
+    public InputStream getInputStream(String url) {
+        //获取请求URI
+        URI uri = getUri(url);
+        if (uri != null) {
+            HttpGet httpGet = new HttpGet(uri);
+            httpGet.setConfig(requestConfig);
+            if (!CollectionUtils.isEmpty(headers)) {
+                Header[] header = new Header[headers.size()];
+                httpGet.setHeaders(headers.toArray(header));
+            }
+            //执行get请求
+            try {
+                CloseableHttpResponse response = httpClient.execute(httpGet);
+                int statusCode = response.getStatusLine().getStatusCode();
+                if (statusCode != 200) {
+                    logger.info("HttpClient status code :" + statusCode + "  request url===" + url);
+                    httpGet.abort();
+                } else {
+                    HttpEntity entity = response.getEntity();
+                    if (entity != null) {
+                        InputStream in = entity.getContent();
+                        return in;
+                    }
+                }
+            } catch (Exception e) {
+                logger.error("获取http GET inputStream请求失败 url======" + url, e);
+                httpGet.abort();
+            }
+        }
+        return null;
+    }
+
+    private URI getUri(String url) {
+        URI uri = null;
+        try {
+            URIBuilder uriBuilder = new URIBuilder(url);
+            if (!CollectionUtils.isEmpty(nvps)) {
+                uriBuilder.setParameters(nvps);
+            }
+            uri = uriBuilder.build();
+        } catch (URISyntaxException e) {
+            logger.error("url 地址异常", e);
+        }
+        return uri;
+    }
+}
+package com.cnlive.shenhe.utils;
+
+import javax.servlet.ServletRequest;
+import java.io.UnsupportedEncodingException;
+import java.net.URLDecoder;
+import java.net.URLEncoder;
+import java.util.*;
+
+public class OpenUtil {
+
+
+    /**
+     * 验证签名
+     * 用于服务端
+     */
+    public static boolean validateSign(ServletRequest request, String spKey) {
+        return validateSign(request, spKey, null);
+    }
+
+    /**
+     * 验证签名
+     */
+    private static boolean validateSign(ServletRequest request, String spKey, String... ignore) {
+        Map<String, String> map = getRequestParam(request);
+        String sign = map.get("sign");
+        map.remove("sign");
+        if (ignore != null) {
+            for (String key : ignore) {
+                map.remove(key);
+            }
+        }
+        map = order(map);
+        String str = mapJoin(map, false);
+        String mySign = SHA1.SHA1Digest(str + "&key=" + spKey).toUpperCase();
+        return mySign.equals(sign);
+    }
+
+    /**
+     * 生成get 请求 URL
+     */
+    public static String buildURL(String url, Map<String, String> params, String spKey) {
+        Map<String, String> map = order(params);
+        if (map.containsKey("sign")) {
+            map.remove("sign");
+        }
+        String str = mapJoin(map, false);
+
+        String sign = SHA1.SHA1Digest(str + "&key=" + spKey).toUpperCase();
+        map.put("sign", sign);
+        return url + "?" + mapJoin(map, true);
+    }
+
+    /**
+     * 生成签名 sign
+     */
+    public static String sign(Map<String, String> params, String spKey) {
+        Map<String, String> map = order(params);
+        if (map.containsKey("sign")) {
+            map.remove("sign");
+        }
+        String str = mapJoin(map, false);
+        return SHA1.SHA1Digest(str + "&key=" + spKey).toUpperCase();
+    }
+
+    /**
+     * 获取请求参数
+     */
+    private static Map<String, String> getRequestParam(ServletRequest request) {
+        Map<String, String> map = new LinkedHashMap<>();
+        Map<String, String[]> map2 = request.getParameterMap();
+        for (String key : map2.keySet()) {
+            if (map2.get(key) == null || map2.get(key).length == 0) {
+                map.put(key, null);
+            } else {
+                try {
+                    String value = URLDecoder.decode(map2.get(key)[0], "utf-8");
+                    map.put(key, value);
+                } catch (UnsupportedEncodingException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+        return map;
+    }
+
+    /**
+     * 获取附加参数
+     */
+    public static Map<String, String> getAttachParam(ServletRequest servletRequest, boolean attachKey) {
+        Map<String, String[]> maps = servletRequest.getParameterMap();
+        Map<String, String> map = new LinkedHashMap<String, String>();
+        for (String key : maps.keySet()) {
+            String[] vk = key.split("\\.");
+            if (vk.length == 2 && vk[0].equals("attach")) {
+                map.put(attachKey ? key : vk[1], maps.get(key)[0]);
+            }
+        }
+        return map;
+    }
+
+
+    /**
+     * url 参数串连
+     */
+    private static String mapJoin(Map<String, String> map, 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();
+    }
+
+
+    /**
+     * Map key 排序
+     */
+    private static Map<String, String> order(Map<String, String> map) {
+        HashMap<String, String> tempMap = new LinkedHashMap<>();
+        List<Map.Entry<String, String>> infoIds = new ArrayList<>(map.entrySet());
+
+        infoIds.sort(new Comparator<Map.Entry<String, String>>() {
+            @Override
+            public int compare(Map.Entry<String, String> o1, Map.Entry<String, String> o2) {
+                return (o1.getKey()).compareTo(o2.getKey());
+            }
+        });
+
+        for (Map.Entry<String, String> item : infoIds) {
+            tempMap.put(item.getKey(), item.getValue());
+        }
+        return tempMap;
+    }
+
+}
+package com.cnlive.shenhe.utils;
+
+import java.io.UnsupportedEncodingException;
+import java.math.BigInteger;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+
+public class SHA1 {
+
+	private final int[] abcde = { 0x67452301, 0xefcdab89, 0x98badcfe,
+			0x10325476, 0xc3d2e1f0 };
+	
+	// 摘要数据存储数组
+	private int[] digestInt = new int[5];
+	
+	// 计算过程中的临时数据存储数组
+	private int[] tmpData = new int[80];
+
+	/**
+	 * 计算sha-1摘要
+	 * 
+	 * @param bytedata
+	 * @return
+	 */
+	private int process_input_bytes(byte[] bytedata) {
+		// 初试化常量
+		System.arraycopy(abcde, 0, digestInt, 0, abcde.length);
+		// 格式化输入字节数组，补10及长度数据
+		byte[] newbyte = byteArrayFormatData(bytedata);
+		// 获取数据摘要计算的数据单元个数
+		int MCount = newbyte.length / 64;
+		// 循环对每个数据单元进行摘要计算
+		for (int pos = 0; pos < MCount; pos++) {
+			// 将每个单元的数据转换成16个整型数据，并保存到tmpData的前16个数组元素中
+			for (int j = 0; j < 16; j++) {
+				tmpData[j] = byteArrayToInt(newbyte, (pos * 64) + (j * 4));
+			}
+			// 摘要计算函数
+			encrypt();
+		}
+		return 20;
+	}
+
+	/**
+	 * 格式化输入字节数组格式
+	 * 
+	 * @param bytedata
+	 * @return
+	 */
+	private byte[] byteArrayFormatData(byte[] bytedata) {
+		// 补0数量
+		int zeros = 0;
+		// 补位后总位数
+		int size = 0;
+		// 原始数据长度
+		int n = bytedata.length;
+		// 模64后的剩余位数
+		int m = n % 64;
+		// 计算添加0的个数以及添加10后的总长度
+		if (m < 56) {
+			zeros = 55 - m;
+			size = n - m + 64;
+		} else if (m == 56) {
+			zeros = 63;
+			size = n + 8 + 64;
+		} else {
+			zeros = 63 - m + 56;
+			size = (n + 64) - m + 64;
+		}
+		// 补位后生成的新数组内容
+		byte[] newbyte = new byte[size];
+		// 复制数组的前面部分
+		System.arraycopy(bytedata, 0, newbyte, 0, n);
+		// 获得数组Append数据元素的位置
+		int l = n;
+		// 补1操作
+		newbyte[l++] = (byte) 0x80;
+		// 补0操作
+		for (int i = 0; i < zeros; i++) {
+			newbyte[l++] = (byte) 0x00;
+		}
+		// 计算数据长度，补数据长度位共8字节，长整型
+		long N = (long) n * 8;
+		byte h8 = (byte) (N & 0xFF);
+		byte h7 = (byte) ((N >> 8) & 0xFF);
+		byte h6 = (byte) ((N >> 16) & 0xFF);
+		byte h5 = (byte) ((N >> 24) & 0xFF);
+		byte h4 = (byte) ((N >> 32) & 0xFF);
+		byte h3 = (byte) ((N >> 40) & 0xFF);
+		byte h2 = (byte) ((N >> 48) & 0xFF);
+		byte h1 = (byte) (N >> 56);
+		newbyte[l++] = h1;
+		newbyte[l++] = h2;
+		newbyte[l++] = h3;
+		newbyte[l++] = h4;
+		newbyte[l++] = h5;
+		newbyte[l++] = h6;
+		newbyte[l++] = h7;
+		newbyte[l++] = h8;
+		return newbyte;
+	}
+
+	private int f1(int x, int y, int z) {
+		return (x & y) | (~x & z);
+	}
+
+	private int f2(int x, int y, int z) {
+		return x ^ y ^ z;
+	}
+
+	private int f3(int x, int y, int z) {
+		return (x & y) | (x & z) | (y & z);
+	}
+
+	private int f4(int x, int y) {
+		return (x << y) | x >>> (32 - y);
+	}
+
+	/**
+	 * 单元摘要计算函数
+	 */
+	private void encrypt() {
+		for (int i = 16; i <= 79; i++) {
+			tmpData[i] = f4(tmpData[i - 3] ^ tmpData[i - 8] ^ tmpData[i - 14]
+					^ tmpData[i - 16], 1);
+		}
+		int[] tmpabcde = new int[5];
+		for (int i1 = 0; i1 < tmpabcde.length; i1++) {
+			tmpabcde[i1] = digestInt[i1];
+		}
+		for (int j = 0; j <= 19; j++) {
+			int tmp = f4(tmpabcde[0], 5)
+					+ f1(tmpabcde[1], tmpabcde[2], tmpabcde[3]) + tmpabcde[4]
+					+ tmpData[j] + 0x5a827999;
+			tmpabcde[4] = tmpabcde[3];
+			tmpabcde[3] = tmpabcde[2];
+			tmpabcde[2] = f4(tmpabcde[1], 30);
+			tmpabcde[1] = tmpabcde[0];
+			tmpabcde[0] = tmp;
+		}
+		for (int k = 20; k <= 39; k++) {
+			int tmp = f4(tmpabcde[0], 5)
+					+ f2(tmpabcde[1], tmpabcde[2], tmpabcde[3]) + tmpabcde[4]
+					+ tmpData[k] + 0x6ed9eba1;
+			tmpabcde[4] = tmpabcde[3];
+			tmpabcde[3] = tmpabcde[2];
+			tmpabcde[2] = f4(tmpabcde[1], 30);
+			tmpabcde[1] = tmpabcde[0];
+			tmpabcde[0] = tmp;
+		}
+		for (int l = 40; l <= 59; l++) {
+			int tmp = f4(tmpabcde[0], 5)
+					+ f3(tmpabcde[1], tmpabcde[2], tmpabcde[3]) + tmpabcde[4]
+					+ tmpData[l] + 0x8f1bbcdc;
+			tmpabcde[4] = tmpabcde[3];
+			tmpabcde[3] = tmpabcde[2];
+			tmpabcde[2] = f4(tmpabcde[1], 30);
+			tmpabcde[1] = tmpabcde[0];
+			tmpabcde[0] = tmp;
+		}
+		for (int m = 60; m <= 79; m++) {
+			int tmp = f4(tmpabcde[0], 5)
+					+ f2(tmpabcde[1], tmpabcde[2], tmpabcde[3]) + tmpabcde[4]
+					+ tmpData[m] + 0xca62c1d6;
+			tmpabcde[4] = tmpabcde[3];
+			tmpabcde[3] = tmpabcde[2];
+			tmpabcde[2] = f4(tmpabcde[1], 30);
+			tmpabcde[1] = tmpabcde[0];
+			tmpabcde[0] = tmp;
+		}
+		for (int i2 = 0; i2 < tmpabcde.length; i2++) {
+			digestInt[i2] = digestInt[i2] + tmpabcde[i2];
+		}
+		for (int n = 0; n < tmpData.length; n++) {
+			tmpData[n] = 0;
+		}
+	}
+
+	/**
+	 * 4字节数组转换为整数
+	 * 
+	 * @param bytedata
+	 * @param i
+	 * @return
+	 */
+	private int byteArrayToInt(byte[] bytedata, int i) {
+		return ((bytedata[i] & 0xff) << 24) | ((bytedata[i + 1] & 0xff) << 16)
+				| ((bytedata[i + 2] & 0xff) << 8) | (bytedata[i + 3] & 0xff);
+	}
+
+	// 
+	/**
+	 * 整数转换为4字节数组
+	 * 
+	 * @param intValue
+	 * @param byteData
+	 * @param i
+	 */
+	private void intToByteArray(int intValue, byte[] byteData, int i) {
+		byteData[i] = (byte) (intValue >>> 24);
+		byteData[i + 1] = (byte) (intValue >>> 16);
+		byteData[i + 2] = (byte) (intValue >>> 8);
+		byteData[i + 3] = (byte) intValue;
+	}
+
+	/**
+	 * 将字节转换为十六进制字符串
+	 * 
+	 * @param ib
+	 * @return
+	 */
+	private static String byteToHexString(byte ib) {
+		char[] Digit = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A',
+				'B', 'C', 'D', 'E', 'F' };
+		char[] ob = new char[2];
+		ob[0] = Digit[(ib >>> 4) & 0X0F];
+		ob[1] = Digit[ib & 0X0F];
+		String s = new String(ob);
+		return s;
+	}
+
+	/**
+	 * 将字节数组转换为十六进制字符串
+	 * 
+	 * @param bytearray
+	 * @return
+	 */
+	private static String byteArrayToHexString(byte[] bytearray) {
+		String strDigest = "";
+		for (int i = 0; i < bytearray.length; i++) {
+			strDigest += byteToHexString(bytearray[i]);
+		}
+		return strDigest;
+	}
+
+	/**
+	 * 计算sha-1摘要，返回相应的字节数组
+	 * 
+	 * @param byteData
+	 * @return
+	 */
+	public byte[] getDigestOfBytes(byte[] byteData) {
+		process_input_bytes(byteData);
+		byte[] digest = new byte[20];
+		for (int i = 0; i < digestInt.length; i++) {
+			intToByteArray(digestInt[i], digest, i * 4);
+		}
+		return digest;
+	}
+
+    /**
+     * 计算sha-1摘要，返回相应的十六进制字符串 
+     * 
+     * @param byteData
+     * @return
+     */
+    public String getDigestOfString(byte[] byteData) { 
+        return byteArrayToHexString(getDigestOfBytes(byteData)); 
+    } 
+	
+    /**
+     * @param data
+     * @return
+     */
+    public String Digest(String data){
+    	return this.getDigestOfString(data.getBytes());
+    }
+
+    /**
+     * @param data
+     * @return
+     */
+    public String Digest(String data,String encode){
+    	try {
+			return this.getDigestOfString(data.getBytes(encode));
+		} catch (UnsupportedEncodingException e) {
+			return this.Digest(data);
+		}
+    }
+    
+    /**
+     * @param text
+     * @return
+     */
+    public static String SHA1Digest(String text) {
+    	String pwd = "";
+		try {
+			MessageDigest md = MessageDigest.getInstance("SHA1");
+			md.update(text.getBytes());
+			pwd = new BigInteger(1, md.digest()).toString(16); 
+		} catch (NoSuchAlgorithmException e) {
+			e.printStackTrace();
+		}
+    	return pwd;
+    }
+    
+}
 \ No newline at end of file
@@ -9,4 +9,8 @@ spring.jpa.show-sql= true
  
  
 mybatis.mapper-locations=classpath:mapping/*.xml
-mybatis.type-aliases-package=com.cnlive.shenhe.entity
 \ No newline at end of file
+mybatis.type-aliases-package=com.cnlive.shenhe.entity
+
+
+sync_users_api=http://api.cnlive.com/open/api2/inner2/shenhe/getuser
+sync_users_app_key=314a9dd4-a9b7-4c12-bbbe-1150a36491ae
 \ No newline at end of file
@@ -7,9 +7,6 @@
     -->
     <id column="id" jdbcType="INTEGER" property="id" />
     <result column="username" jdbcType="VARCHAR" property="username" />
-    <result column="sid" jdbcType="INTEGER" property="sid" />
-    <result column="remember_token" jdbcType="VARCHAR" property="remember_token" />
-    <result column="contacts" jdbcType="VARCHAR" property="contacts" />
     <result column="email" jdbcType="VARCHAR" property="email" />
     <result column="master" jdbcType="BIT" property="master" />
     <result column="mobile" jdbcType="VARCHAR" property="mobile" />
@@ -19,6 +16,7 @@
     <result column="state" jdbcType="BIT" property="state" />
     <result column="created_at" jdbcType="TIMESTAMP" property="created_at" />
     <result column="updated_at" jdbcType="TIMESTAMP" property="updated_at" />
-    <result column="tm" jdbcType="VARCHAR" property="tm" />
+    <result column="tm" jdbcType="BIGINT" property="tm" />
+    <result column="user_logo" jdbcType="VARCHAR" property="user_logo" />
   </resultMap>
 </mapper>
 \ No newline at end of file