wechatSync/regMobile

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/controller/SweetWechatSyncDataController.java

+package com.liquidnet.service.sweet.controller;
+
+import com.google.gson.Gson;
+import com.google.gson.JsonObject;
+import com.liquidnet.commons.lang.util.HttpUtil;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.io.*;
+
+@Api(tags = "同步微信用户数据")
+@RestController
+@RequestMapping("/wechatSync")
+public class SweetWechatSyncDataController {
+
+    @GetMapping("regMobile")
+    @ApiOperation("注册")
+    public void regMobile() throws IOException {
+        String filePath = "/Users/jiangxiulong/Desktop/keys2.txt";
+        String encoding = "UTF-8";
+        File file = new File(filePath);
+        if (file.isFile() && file.exists()) { //判断文件是否存在
+            InputStreamReader read = new InputStreamReader(new FileInputStream(file), encoding);//考虑到编码格式
+            BufferedReader bufferedReader = new BufferedReader(read);
+            String mobile = null;
+            while ((mobile = bufferedReader.readLine()) != null) {
+                System.out.println(mobile);
+
+                try {
+                    MultiValueMap<String, String> params = new LinkedMultiValueMap();
+                    params.add("mobile", mobile);
+
+//                    String url = "http://127.0.0.1:9001/adam/rsc/reg/mobile";
+                    String url = "http://testadam.zhengzai.tv/adam/rsc/reg/mobile";
+                    HttpUtil.post(url, params);
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+
+            }
+            read.close();
+        } else {
+            System.out.println("找不到指定的文件");
+        }
+    }
+
+    @GetMapping("users")
+    @ApiOperation("关注用户")
+    public void getUsers() {
+    }
+
+}