Explorar o código

Merge branch 'spotify_register' into register_account

chenbiao %!s(int64=3) %!d(string=hai) anos
pai
achega
5198f72868

+ 11 - 0
netflix-dao/src/main/java/com/cyksj/mapper/ProxysMapper.java

@@ -0,0 +1,11 @@
+package com.cyksj.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.cyksj.model.entity.Proxys;
+
+/**
+ * @author chan
+ * @date 2022/11/3 4:16 PM
+ */
+public interface ProxysMapper extends BaseMapper<Proxys> {
+}

+ 11 - 0
netflix-dao/src/main/java/com/cyksj/mapper/SpotifyRegisterMapper.java

@@ -0,0 +1,11 @@
+package com.cyksj.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.cyksj.model.entity.SpotifyRegister;
+
+/**
+ * @author chan
+ * @date 2022/11/3 4:16 PM
+ */
+public interface SpotifyRegisterMapper extends BaseMapper<SpotifyRegister> {
+}

+ 32 - 0
netflix-dao/src/main/java/com/cyksj/model/entity/Proxys.java

@@ -0,0 +1,32 @@
+package com.cyksj.model.entity;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * @author chan
+ * @date 2022/11/3 3:57 PM
+ */
+@Data
+public class Proxys {
+
+    private Integer id;
+
+    private String ip;
+
+    private Integer port;
+
+    private Integer types;
+
+    private Integer protocol;
+
+    private String country;
+
+    private String area;
+
+    private BigDecimal speed;
+
+    private Integer score;
+
+}

+ 34 - 0
netflix-dao/src/main/java/com/cyksj/model/entity/SpotifyRegister.java

@@ -0,0 +1,34 @@
+package com.cyksj.model.entity;
+
+import lombok.Data;
+
+/**
+ * @author chan
+ * @date 2022/11/3 4:08 PM
+ */
+@Data
+public class SpotifyRegister extends BaseEntity{
+
+    private String creationPoint;
+
+    private String displayname;
+
+    private String passwordRepeat;
+
+    private String password;
+
+    private String username;
+
+    private String birthYear;
+
+    private String birthMonth;
+
+    private String birthDay;
+
+    private String gender;
+
+    private String email;
+
+    private String iagree;
+
+}

+ 32 - 0
netflix-dao/src/main/java/com/cyksj/model/manage/request/SpotifyRegisterReq.java

@@ -0,0 +1,32 @@
+package com.cyksj.model.manage.request;
+
+import lombok.Data;
+
+/**
+ * @author chan
+ * @date 2022/11/3 3:49 PM
+ */
+@Data
+public class SpotifyRegisterReq {
+    private String creationPoint;
+
+    private String displayname;
+
+    private String passwordRepeat;
+
+    private String password;
+
+    private String username;
+
+    private String birthYear;
+
+    private String birthMonth;
+
+    private String birthDay;
+
+    private String gender;
+
+    private String email;
+
+    private String iagree;
+}

+ 20 - 0
netflix-dao/src/main/java/com/cyksj/model/response/ProxyInfo.java

@@ -0,0 +1,20 @@
+package com.cyksj.model.response;
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+
+/**
+ * @author chan
+ * @date 2022/11/3 4:00 PM
+ */
+@Getter
+@Setter
+@ToString
+public class ProxyInfo {
+
+    private String ip;
+
+    private Integer port;
+
+}

+ 169 - 0
netflix-web/src/main/java/com/cyksj/web/controller/manage/spotify/SpotifyController.java

@@ -0,0 +1,169 @@
+package com.cyksj.web.controller.manage.spotify;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.util.RandomUtil;
+import cn.hutool.http.HttpRequest;
+import cn.hutool.http.HttpResponse;
+import cn.hutool.http.HttpUtil;
+import cn.hutool.http.Method;
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.cyksj.dto.Result;
+import com.cyksj.enums.GatewayResponse;
+import com.cyksj.mapper.ProxysMapper;
+import com.cyksj.mapper.SpotifyRegisterMapper;
+import com.cyksj.model.entity.Proxys;
+import com.cyksj.model.entity.SpotifyRegister;
+import com.cyksj.model.manage.request.SpotifyRegisterReq;
+import com.cyksj.model.response.ProxyInfo;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.net.InetSocketAddress;
+import java.net.Proxy;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * @author chan
+ * @date 2022/11/3 3:50 PM
+ */
+@RequestMapping("/spotify")
+@RestController
+@Slf4j
+@RequiredArgsConstructor
+public class SpotifyController {
+
+    private final ProxysMapper proxysMapper;
+
+    private final SpotifyRegisterMapper spotifyRegisterMapper;
+
+    private static final List<String> User_Agent_LIST =  List.of(
+            "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; AcooBrowser; .NET CLR 1.1.4322; .NET CLR 2.0.50727)",
+            "Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 6.0; Acoo Browser; SLCC1; .NET CLR 2.0.50727; Media Center PC 5.0; .NET CLR 3.0.04506)",
+            "Mozilla/4.0 (compatible; MSIE 7.0; AOL 9.5; AOLBuild 4337.35; Windows NT 5.1; .NET CLR 1.1.4322; .NET CLR 2.0.50727)",
+            "Mozilla/5.0 (Windows; U; MSIE 9.0; Windows NT 9.0; en-US)",
+            "Mozilla/5.0 (compatible; MSIE 9.0; Windows NT 6.1; Win64; x64; Trident/5.0; .NET CLR 3.5.30729; .NET CLR 3.0.30729; .NET CLR 2.0.50727; Media Center PC 6.0)",
+            "Mozilla/5.0 (compatible; MSIE 8.0; Windows NT 6.0; Trident/4.0; WOW64; Trident/4.0; SLCC2; .NET CLR 2.0.50727; .NET CLR 3.5.30729; .NET CLR 3.0.30729; .NET CLR 1.0.3705; .NET CLR 1.1.4322)",
+            "Mozilla/4.0 (compatible; MSIE 7.0b; Windows NT 5.2; .NET CLR 1.1.4322; .NET CLR 2.0.50727; InfoPath.2; .NET CLR 3.0.04506.30)",
+            "Mozilla/5.0 (Windows; U; Windows NT 5.1; zh-CN) AppleWebKit/523.15 (KHTML, like Gecko, Safari/419.3) Arora/0.3 (Change: 287 c9dfb30)",
+            "Mozilla/5.0 (X11; U; Linux; en-US) AppleWebKit/527+ (KHTML, like Gecko, Safari/419.3) Arora/0.6",
+            "Mozilla/5.0 (Windows; U; Windows NT 5.1; en-US; rv:1.8.1.2pre) Gecko/20070215 K-Ninja/2.1.1",
+            "Mozilla/5.0 (Windows; U; Windows NT 5.1; zh-CN; rv:1.9) Gecko/20080705 Firefox/3.0 Kapiko/3.0",
+            "Mozilla/5.0 (X11; Linux i686; U;) Gecko/20070322 Kazehakase/0.4.5",
+            "Mozilla/5.0 (X11; U; Linux i686; en-US; rv:1.9.0.8) Gecko Fedora/1.9.0.8-1.fc10 Kazehakase/0.5.6",
+            "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/535.11 (KHTML, like Gecko) Chrome/17.0.963.56 Safari/535.11",
+            "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_7_3) AppleWebKit/535.20 (KHTML, like Gecko) Chrome/19.0.1036.7 Safari/535.20",
+            "Opera/9.80 (Macintosh; Intel Mac OS X 10.6.8; U; fr) Presto/2.9.168 Version/11.52",
+            "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/536.11 (KHTML, like Gecko) Chrome/20.0.1132.11 TaoBrowser/2.0 Safari/536.11",
+            "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.1 (KHTML, like Gecko) Chrome/21.0.1180.71 Safari/537.1 LBBROWSER",
+            "Mozilla/5.0 (compatible; MSIE 9.0; Windows NT 6.1; WOW64; Trident/5.0; SLCC2; .NET CLR 2.0.50727; .NET CLR 3.5.30729; .NET CLR 3.0.30729; Media Center PC 6.0; .NET4.0C; .NET4.0E; LBBROWSER)",
+            "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; QQDownload 732; .NET4.0C; .NET4.0E; LBBROWSER)",
+            "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/535.11 (KHTML, like Gecko) Chrome/17.0.963.84 Safari/535.11 LBBROWSER",
+            "Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 6.1; WOW64; Trident/5.0; SLCC2; .NET CLR 2.0.50727; .NET CLR 3.5.30729; .NET CLR 3.0.30729; Media Center PC 6.0; .NET4.0C; .NET4.0E)",
+            "Mozilla/5.0 (compatible; MSIE 9.0; Windows NT 6.1; WOW64; Trident/5.0; SLCC2; .NET CLR 2.0.50727; .NET CLR 3.5.30729; .NET CLR 3.0.30729; Media Center PC 6.0; .NET4.0C; .NET4.0E; QQBrowser/7.0.3698.400)",
+            "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; QQDownload 732; .NET4.0C; .NET4.0E)",
+            "Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 5.1; Trident/4.0; SV1; QQDownload 732; .NET4.0C; .NET4.0E; 360SE)",
+            "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; QQDownload 732; .NET4.0C; .NET4.0E)",
+            "Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 6.1; WOW64; Trident/5.0; SLCC2; .NET CLR 2.0.50727; .NET CLR 3.5.30729; .NET CLR 3.0.30729; Media Center PC 6.0; .NET4.0C; .NET4.0E)",
+            "Mozilla/5.0 (Windows NT 5.1) AppleWebKit/537.1 (KHTML, like Gecko) Chrome/21.0.1180.89 Safari/537.1",
+            "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.1 (KHTML, like Gecko) Chrome/21.0.1180.89 Safari/537.1",
+            "Mozilla/5.0 (iPad; U; CPU OS 4_2_1 like Mac OS X; zh-cn) AppleWebKit/533.17.9 (KHTML, like Gecko) Version/5.0.2 Mobile/8C148 Safari/6533.18.5",
+            "Mozilla/5.0 (Windows NT 6.1; Win64; x64; rv:2.0b13pre) Gecko/20110307 Firefox/4.0b13pre",
+            "Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:16.0) Gecko/20100101 Firefox/16.0",
+            "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.11 (KHTML, like Gecko) Chrome/23.0.1271.64 Safari/537.11",
+            "Mozilla/5.0 (X11; U; Linux x86_64; zh-CN; rv:1.9.2.10) Gecko/20100922 Ubuntu/10.10 (maverick) Firefox/3.6.10");
+
+    @PostMapping("/register")
+    public Result<String> register(@RequestBody SpotifyRegisterReq registerReq){
+        log.info("spotify 请求 params:{}",registerReq);
+        HttpRequest request = new HttpRequest("https://spclient.wg.spotify.com/signup/public/v1/account");
+
+        request.header("User-Agent", User_Agent_LIST.get(RandomUtil.randomInt(User_Agent_LIST.size())));
+        request.header("Connection","close");
+        request.header( "Accept","*/*");
+        request.header( "Content-Type","application/x-www-form-urlencoded");
+        request.header( "Referer","https://www.spotify.com/us/");
+        request.header( "Accept-Encoding","gzip, deflate, br");
+        request.header( "Host","spclient.wg.spotify.com");
+
+        Map<String,Object> jsonObject = new HashMap<>();
+        jsonObject.put("key","a1e486e2729f46d6bb368d6b2bcda326");
+        //creation_point=https://www.spotify.com/uk/
+        jsonObject.put("creation_point","https://www.spotify.com/us/");
+        jsonObject.put("displayname",registerReq.getDisplayname());
+        jsonObject.put("password_repeat",registerReq.getPasswordRepeat());
+        jsonObject.put("password",registerReq.getPassword());
+        jsonObject.put("username",registerReq.getUsername());
+        jsonObject.put("birth_year",registerReq.getBirthYear());
+        jsonObject.put("birth_month",registerReq.getBirthMonth());
+        jsonObject.put("birth_day",registerReq.getBirthDay());
+        jsonObject.put("gender",registerReq.getGender());
+        jsonObject.put("email",registerReq.getEmail());
+        jsonObject.put("iagree",registerReq.getIagree());
+        request.setMethod(Method.POST);
+
+        request.form(jsonObject);
+
+        String proxyJson = HttpUtil.get("http://inside.sxfoundation.com:8899/api/v1/proxies");
+        log.info(proxyJson);
+        JSONArray array = JSONUtil.parseObj(proxyJson).getJSONArray("proxies");
+        List<ProxyInfo> proxyInfos = array.toList(ProxyInfo.class);
+        log.info("{}",proxyInfos);
+
+        int start = 1;
+        int limit = 20;
+
+        while (true){
+            for (ProxyInfo proxyInfo : proxyInfos) {
+                try {
+                    log.info("执行:info:{}",proxyInfo);
+                    Proxy proxy = new Proxy(Proxy.Type.HTTP,
+                            new InetSocketAddress(proxyInfo.getIp(), proxyInfo.getPort()));
+                    request.setProxy(proxy);
+                    HttpResponse response = request.execute();
+                    String body = response.body();
+                    log.info("spotify 返回body:{}",body);
+                    JSONObject resObj = JSONUtil.parseObj(body);
+                    if(StringUtils.isNotBlank(resObj.getStr("login_token"))){
+                        log.info("注册成功!");
+                        SpotifyRegister spotifyRegister = new SpotifyRegister();
+                        BeanUtil.copyProperties(registerReq,spotifyRegister);
+                        spotifyRegisterMapper.insert(spotifyRegister);
+                        break;
+                    }
+                    return GatewayResponse.SUCCESS.newBuilder().toResult("注册成功!");
+                }catch (Exception e){
+                    e.printStackTrace();
+                    log.error("错误 ip:{}",proxyInfo.getIp());
+                }
+            }
+
+            List<Proxys> records = proxysMapper.selectPage(new Page<>(start, limit), Wrappers.lambdaQuery(Proxys.class).orderByDesc(Proxys::getId)).getRecords();
+            if(records.isEmpty()){
+                break;
+            }
+            proxyInfos = records.stream().map((proxy)->{
+                ProxyInfo proxyInfo = new ProxyInfo();
+                proxyInfo.setIp(proxy.getIp());
+                proxyInfo.setPort(proxy.getPort());
+                return proxyInfo;
+            }).collect(Collectors.toList());
+        }
+
+        return GatewayResponse.FAIL.newBuilder().toResult("注册失败!");
+    }
+
+
+}
+