Merge branch 'register_account'

netflix-common/src/main/java/com/cyksj/dto/RedisKey.java

@@ -38,4 +38,9 @@ public class RedisKey {
      */
     public static String GROUPS_RELATION_NUM_KEY = "group:relation:";
 
+    /**
+     * spotify 免费注册名额
+     */
+    public static String SPOTIFY_FREE_NUM = "register:free:spotify";
+
 }

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> {
+}

netflix-dao/src/main/java/com/cyksj/mapper/RegisterOrderDonMapper.java

@@ -0,0 +1,11 @@
+package com.cyksj.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.cyksj.model.entity.RegisterOrderDon;
+
+/**
+ * @author chan
+ * @date 2022/11/7 2:38 PM
+ */
+public interface RegisterOrderDonMapper extends BaseMapper<RegisterOrderDon> {
+}

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> {
+}

netflix-dao/src/main/java/com/cyksj/model/entity/BaseEntity.java

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.annotation.FieldFill;
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
+import com.ejlchina.searcher.bean.DbField;
 import lombok.Data;
 import lombok.experimental.Accessors;
 
@@ -18,17 +19,21 @@ import java.util.Date;
 public class BaseEntity {
 
     @TableId(value = "id",type = IdType.AUTO)
+    @DbField("id")
     private Long id;
 
     /**
      * 创建时间
      */
+
+    @DbField("created_time")
     @TableField(fill = FieldFill.INSERT)
     private Date createdTime;
 
     /**
      * 修改时间
      */
+    @DbField("update_time")
     @TableField(fill = FieldFill.INSERT_UPDATE)
     private Date updateTime;
 }

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;
+
+}

netflix-dao/src/main/java/com/cyksj/model/entity/RegisterOrderDon.java

@@ -0,0 +1,91 @@
+package com.cyksj.model.entity;
+
+import com.ejlchina.searcher.bean.SearchBean;
+import lombok.Getter;
+import lombok.Setter;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * @author chan
+ * @date 2022/11/7 1:57 PM
+ */
+@Getter
+@Setter
+public class RegisterOrderDon extends BaseEntity{
+
+    private String platform;
+
+    private String nickname;
+
+    private String username;
+
+    private String password;
+
+    private String email;
+
+    private String birthYear;
+
+    private String birthMonth;
+
+    private String birthDay;
+
+    private String gender;
+
+    private String phone;
+
+    private String country;
+
+    private String orderNo;
+
+    private BigDecimal money;
+
+    /**
+     * 微信订单号
+     */
+    private String transactionId;
+
+
+    /** 用户id */
+    private Long userId ;
+
+    /**
+     * openId
+     */
+    private String openId;
+
+    /** 支付状态 */
+    private Status status ;
+
+    /**
+     * 支付时间
+     */
+    private Date payTime;
+
+    private Boolean isFree;
+
+    private String errorMsg;
+
+    public enum Status {
+        /**
+         * 订单状态
+         */
+        close("关闭订单"),
+        noPayment("待付款"),
+        hasPayment("已付款"),
+        error("注册失败"),
+        complete("已完成"),
+        ;
+
+        private String desc;
+
+        Status(String desc) {
+            this.desc = desc;
+        }
+
+        public String getDesc() {
+            return desc;
+        }
+    }
+}

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;
+
+}

netflix-dao/src/main/java/com/cyksj/model/manage/request/RegisterReq.java

@@ -0,0 +1,42 @@
+package com.cyksj.model.manage.request;
+
+import lombok.Data;
+
+/**
+ * @author chan
+ * @date 2022/11/3 3:49 PM
+ */
+@Data
+public class RegisterReq {
+
+    /**
+     *  平台 Spotify google apple
+     */
+    private String platform;
+
+    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 country;
+
+    private String phone;
+
+    private String nickname;
+}

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

@@ -0,0 +1,22 @@
+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 Long id;
+
+    private String ip;
+
+    private Integer port;
+
+}

netflix-service/src/main/java/com/cyksj/service/register/RegisterOrderDonService.java

@@ -0,0 +1,23 @@
+package com.cyksj.service.register;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.cyksj.model.dto.H5JsPayParams;
+import com.cyksj.model.entity.RegisterOrderDon;
+import com.cyksj.model.manage.request.RegisterReq;
+
+import java.util.Map;
+
+/**
+ * @author chan
+ * @date 2022/11/7 2:39 PM
+ */
+public interface RegisterOrderDonService extends IService<RegisterOrderDon> {
+
+    boolean isFree(long userId, String platform);
+
+    RegisterOrderDon saveOrder(long userId, RegisterReq req, boolean isFree) throws Exception;
+
+    H5JsPayParams pay(Long orderId) throws Exception;
+
+    void prepayNotify(Map<String, String> map) throws Exception;
+}

netflix-service/src/main/java/com/cyksj/service/register/SpotifyService.java

@@ -0,0 +1,10 @@
+package com.cyksj.service.register;
+
+/**
+ * @author chan
+ * @date 2022/11/7 1:54 PM
+ */
+public interface SpotifyService {
+
+    void register(Long registerOrderId);
+}

netflix-service/src/main/java/com/cyksj/service/register/impl/RegisterOrderDonServiceImpl.java

@@ -0,0 +1,184 @@
+package com.cyksj.service.register.impl;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.date.DateUtil;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.cyksj.common.exception.BusinessRuntimeException;
+import com.cyksj.common.snowflake.Sequence;
+import com.cyksj.common.util.Codec;
+import com.cyksj.common.util.Jsons;
+import com.cyksj.config.WeChatConfig;
+import com.cyksj.dto.RedisKey;
+import com.cyksj.mapper.RegisterOrderDonMapper;
+import com.cyksj.mapper.UserMapper;
+import com.cyksj.model.dto.H5JsPayParams;
+import com.cyksj.model.entity.RegisterOrderDon;
+import com.cyksj.model.entity.SysConfig;
+import com.cyksj.model.entity.User;
+import com.cyksj.model.entity.*;
+import com.cyksj.model.manage.request.RegisterReq;
+import com.cyksj.model.request.OrderAttach;
+import com.cyksj.redis.RedisService;
+import com.cyksj.service.register.RegisterOrderDonService;
+import com.cyksj.service.register.SpotifyService;
+import com.cyksj.service.sys.SysConfigService;
+import com.cyksj.service.wechat.WeChatService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+
+/**
+ * @author chan
+ * @date 2022/11/7 2:39 PM
+ */
+@Service
+@Slf4j
+@RequiredArgsConstructor
+public class RegisterOrderDonServiceImpl extends ServiceImpl<RegisterOrderDonMapper ,RegisterOrderDon> implements RegisterOrderDonService {
+
+    private static final Sequence SEQUENCE = new Sequence(0);
+
+    private static final String REGISTER_PRICE_KEY = "register_price";
+
+    private final SpotifyService spotifyService;
+
+    private final RedisService redisService;
+
+    private final WeChatService weChatService;
+
+    private final WeChatConfig weChatConfig;
+
+    private final SysConfigService sysConfigService;
+
+    private final UserMapper userMapper;
+
+    /**
+     * 判断是否免费
+     * @author chan
+     * @date 2022-11-07 3:34 PM
+     */
+    @Override
+    public boolean isFree(long userId, String platform) {
+        int count = count(Wrappers.lambdaQuery(RegisterOrderDon.class)
+                .eq(RegisterOrderDon::getUserId, userId)
+                .ne(RegisterOrderDon::getStatus, RegisterOrderDon.Status.noPayment)
+                .eq(RegisterOrderDon::getIsFree, true));
+        if(count > 0){
+            return false;
+        }
+        Long num = redisService.decr(RedisKey.SPOTIFY_FREE_NUM, 1L);
+        if(num >= 0){
+            return true;
+        }else {
+            redisService.incr(RedisKey.SPOTIFY_FREE_NUM, 1L);
+        }
+        return false;
+    }
+
+    /**
+     * 保存注册资料
+     * @author chan
+     * @date 2022-11-07 3:34 PM
+     */
+    @Override
+    @Transactional(rollbackFor = Throwable.class)
+    public RegisterOrderDon saveOrder(long userId, RegisterReq req, boolean isFree) throws Exception {
+        RegisterOrderDon orderDon = new RegisterOrderDon();
+        User user = userMapper.selectById(userId);
+        BeanUtil.copyProperties(req,orderDon);
+        SysConfig register_price = sysConfigService.getOne(Wrappers.lambdaQuery(SysConfig.class).eq(SysConfig::getSysKey, "register_price").last("limit 1"));
+        Map<String, Integer> map = Jsons.toMap(register_price.getSysValue());
+
+        orderDon.setOrderNo(SEQUENCE.nextId() + "");
+        orderDon.setUserId(userId);
+        orderDon.setOpenId(user.getOpenId());
+        orderDon.setIsFree(isFree);
+        orderDon.setMoney(isFree ? BigDecimal.ZERO : BigDecimal.valueOf(map.get(req.getPlatform())));
+        orderDon.setStatus(isFree ? RegisterOrderDon.Status.hasPayment : RegisterOrderDon.Status.noPayment);
+        save(orderDon);
+
+        return orderDon;
+    }
+
+    @Override
+    public H5JsPayParams pay(Long orderId) throws Exception {
+        log.info("注册 账号调起微信支付[start] orderId:{}", orderId);
+        RegisterOrderDon orderDon = this.getById(orderId);
+
+        OrderAttach attach = new OrderAttach();
+        attach.setO(orderDon.getId());
+
+        String toWechatAttach = Codec.DoBase64.custom()
+                .setData(Jsons.toJson(attach)).encodeAsText();
+
+        H5JsPayParams params = weChatService.getJsPayParams(
+                weChatConfig.getAppid(),
+                orderDon.getOpenId(),
+                orderDon.getMoney().intValue(),
+                orderDon.getOrderNo(),
+                weChatConfig.getDomain() + "applets/register/prepay/notify",
+                toWechatAttach,
+                "注册服务"
+        );
+
+        log.info("微信支付成功[end]");
+        return params;
+    }
+
+    @Override
+    @Transactional(rollbackFor = Throwable.class)
+    public void prepayNotify(Map<String, String> map) throws Exception {
+        /* 此处处理订单等业务逻辑 */
+        // 获取订单 和 微信订单号 和 支付的金额
+
+        String attach = Codec.DoBase64.custom().setData(map.get("attach")).decodeAsText();
+
+        OrderAttach orderAttach = Jsons.parseObject(attach, OrderAttach.class);
+
+        final Long oid = orderAttach.getO();
+
+        //final Long shareId = orderAttach.getShared();
+
+        RegisterOrderDon order = this.getById(oid);
+
+        if (null == order) {
+            throw BusinessRuntimeException.getInstance("订单不存在.");
+        }
+
+        // 校验签名
+        boolean f = weChatService.checkSignWithMd5(map, weChatConfig.getShopKey());
+        if (!f) {
+            log.error("回调数据：{}", map);
+            throw BusinessRuntimeException.getInstance("支付成功回调, 校验签名失败.");
+        }
+
+        String transactionId = map.get("transaction_id");
+
+        if (order.getStatus().equals(RegisterOrderDon.Status.hasPayment)) {
+            log.info("已回调，重复修改状态 id:{}", order.getId());
+            return;
+        }
+
+        // 更改订单状态
+        order.setTransactionId(transactionId);
+        order.setStatus(RegisterOrderDon.Status.hasPayment);
+
+        order.setPayTime(DateUtil.parse(map.get("time_end"), "yyyyMMddHHmmss"));
+
+        if (StringUtils.isBlank(order.getOpenId())) {
+            order.setOpenId(map.get("openid"));
+        }
+
+
+        this.updateById(order);
+    }
+}

netflix-service/src/main/java/com/cyksj/service/register/impl/SpotifyServiceImpl.java

@@ -0,0 +1,198 @@
+package com.cyksj.service.register.impl;
+
+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.RegisterOrderDonMapper;
+import com.cyksj.model.entity.Proxys;
+import com.cyksj.model.entity.RegisterOrderDon;
+import com.cyksj.model.entity.SpotifyRegister;
+import com.cyksj.model.response.ProxyInfo;
+import com.cyksj.service.register.SpotifyService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+
+import java.net.InetSocketAddress;
+import java.net.Proxy;
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * @author chan
+ * @date 2022/11/7 1:54 PM
+ */
+@Service
+@Slf4j
+@RequiredArgsConstructor
+public class SpotifyServiceImpl implements SpotifyService {
+
+    private final ProxysMapper proxysMapper;
+
+    private final RegisterOrderDonMapper registerOrderDonMapper;
+
+    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");
+
+    @Override
+    public void register(Long registerOrderId){
+        log.info("spotify 注册 orderId:{}",registerOrderId);
+        RegisterOrderDon registerOrderDon = registerOrderDonMapper.selectById(registerOrderId);
+        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",Optional.ofNullable(registerOrderDon.getNickname()).orElse(registerOrderDon.getEmail()));
+        jsonObject.put("password_repeat",registerOrderDon.getPassword());
+        jsonObject.put("password",registerOrderDon.getPassword());
+        jsonObject.put("username",Optional.ofNullable(registerOrderDon.getUsername()).orElse(registerOrderDon.getEmail()));
+        jsonObject.put("birth_year", Optional.ofNullable(registerOrderDon.getBirthYear()).orElse("1995"));
+        jsonObject.put("birth_month",Optional.ofNullable(registerOrderDon.getBirthMonth()).orElse("01"));
+        jsonObject.put("birth_day",Optional.ofNullable(registerOrderDon.getBirthDay()).orElse("01"));
+        jsonObject.put("gender",registerOrderDon.getGender());
+        jsonObject.put("email",registerOrderDon.getEmail());
+        jsonObject.put("iagree","1");
+        request.setMethod(Method.POST);
+        request.setConnectionTimeout(15 * 1000);
+        request.setReadTimeout(15 * 1000);
+
+        request.form(jsonObject);
+
+
+
+
+
+        int start = 1;
+        int limit = 20;
+        boolean regFlag = false;
+        while (true) {
+
+            List<ProxyInfo> proxyInfos = new ArrayList<>();
+            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());
+
+            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);
+                    JSONObject errors = resObj.getJSONObject("errors");
+
+                    Integer status = resObj.getInt("status");
+                    if (status == 320) {
+                        String errorMsg = errors.getStr("generic_error");
+                        if (StringUtils.isNotBlank(errorMsg) || "你似乎正在使用代理服务。请关闭此类服务，然后再试一次。如需更多帮助，请联系客户服务。".equals(errorMsg) || errorMsg.contains("代理")) {
+                            log.info("spotify 注册 被监测出代理服务 。 删除该代理 ip:{}", proxyInfo.getIp());
+                            if (proxyInfo.getId() != null) {
+                                proxysMapper.deleteById(proxyInfo.getId());
+                            }
+                            continue;
+                        }
+                    }
+
+                    if (StringUtils.isNotBlank(resObj.getStr("login_token"))) {
+                        log.info("注册成功！");
+                        registerOrderDon.setStatus(RegisterOrderDon.Status.complete);
+                        registerOrderDonMapper.updateById(registerOrderDon);
+                        regFlag = true;
+                        break;
+                    } else {
+                        if (errors != null && !errors.isEmpty()) {
+                            StringBuilder error = new StringBuilder();
+                            for (String str : errors.keySet()) {
+                                error.append(errors.getStr(str));
+                            }
+                            registerOrderDon.setErrorMsg(error.toString());
+                            registerOrderDon.setStatus(RegisterOrderDon.Status.error);
+                            registerOrderDonMapper.updateById(registerOrderDon);
+                            regFlag = true;
+                            break;
+                        }
+                    }
+
+                } catch (Exception e) {
+                    if (proxyInfo.getId() != null) {
+                        proxysMapper.deleteById(proxyInfo.getId());
+                    }
+                    e.printStackTrace();
+                    log.error("错误 ip:{}", proxyInfo.getIp());
+                }
+            }
+
+            if (regFlag) {
+                break;
+            }
+
+        }
+    }
+
+
+}

netflix-service/src/main/java/com/cyksj/task/Scheduler.java

@@ -5,11 +5,14 @@ import cn.hutool.core.date.DateTime;
 import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.cyksj.common.util.Jsons;
+import com.cyksj.dto.RedisKey;
 import com.cyksj.mapper.*;
 import com.cyksj.model.dto.WxMpTemplateData;
 import com.cyksj.model.dto.WxMpTemplateMessage;
 import com.cyksj.model.entity.*;
+import com.cyksj.redis.RedisService;
 import com.cyksj.service.order.OrderDonService;
+import com.cyksj.service.register.SpotifyService;
 import com.cyksj.service.wechat.WeChatService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -44,6 +47,14 @@ public class Scheduler {
 
         private final CustomerServiceMapper customerServiceMapper;
 
+        private final SpotifyService spotifyService;
+
+        private final RegisterOrderDonMapper registerOrderDonMapper;
+
+        private final RedisService redisService;
+
+        private final SysConfigMapper sysConfigMapper;
+
 
     /**
      * 统计前一天数据
@@ -126,4 +137,29 @@ public class Scheduler {
             orderDonService.closeOrder(orderDon.getId());
         });
     }
+
+    /**
+     * spotify 注册
+     */
+    @Scheduled(cron = "0 0/5 * * * ?")
+    public void spotify() {
+        List<RegisterOrderDon> spotify = registerOrderDonMapper.selectList(Wrappers.lambdaQuery(RegisterOrderDon.class)
+                .select(RegisterOrderDon::getId)
+                .eq(RegisterOrderDon::getPlatform, "spotify")
+                .eq(RegisterOrderDon::getStatus, RegisterOrderDon.Status.hasPayment));
+        spotify.forEach((orderDon)->{
+            spotifyService.register(orderDon.getId());
+        });
+    }
+
+    /**
+     * 每日免单重置
+     */
+    @Scheduled(cron = "0 0 0 * * ?")
+    public void freeReset() {
+        log.info("每日重置 spotify 免单账户数 [start]");
+        SysConfig register_free_num = sysConfigMapper.selectOne(Wrappers.lambdaQuery(SysConfig.class).eq(SysConfig::getSysKey, "register_free_num"));
+        redisService.set(RedisKey.SPOTIFY_FREE_NUM, Long.parseLong(register_free_num.getSysValue()));
+        log.info("每日重置 spotify 免单账户数 [end] 数量:{}",register_free_num.getSysValue());
+    }
 }

netflix-web/src/main/java/com/cyksj/web/controller/manage/register/CmsRegisterController.java

@@ -0,0 +1,56 @@
+package com.cyksj.web.controller.manage.register;
+
+import com.cyksj.common.exception.BusinessRuntimeException;
+import com.cyksj.common.util.IoKit;
+import com.cyksj.common.util.Xmls;
+import com.cyksj.dto.Result;
+import com.cyksj.enums.GatewayResponse;
+import com.cyksj.model.dto.H5JsPayParams;
+import com.cyksj.model.entity.RegisterOrderDon;
+import com.cyksj.model.manage.request.RegisterReq;
+import com.cyksj.service.register.RegisterOrderDonService;
+import com.cyksj.web.util.StpUserUtil;
+import com.ejlchina.searcher.BeanSearcher;
+import com.ejlchina.searcher.SearchResult;
+import com.ejlchina.searcher.util.MapUtils;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.OutputStream;
+import java.util.Map;
+
+/**
+ * @author chan
+ * @date 2022/11/7 1:49 PM
+ */
+@Slf4j
+@RestController
+@RequestMapping("/manage/register")
+@RequiredArgsConstructor
+public class CmsRegisterController {
+
+    private final RegisterOrderDonService registerOrderDonService;
+
+    private final BeanSearcher beanSearcher;
+
+    private final HttpServletRequest request;
+
+    @GetMapping("/get")
+    public Result<SearchResult<RegisterOrderDon>> get(){
+        SearchResult<RegisterOrderDon> search = beanSearcher.search(RegisterOrderDon.class, MapUtils.flatBuilder(request.getParameterMap()).build());
+        return GatewayResponse.SUCCESS.newBuilder().toResult(search);
+    }
+
+    @PutMapping("/update")
+    public Result<RegisterOrderDon> update(@RequestBody RegisterOrderDon registerOrderDon){
+        registerOrderDonService.updateById(registerOrderDon);
+        return GatewayResponse.SUCCESS.newBuilder().toResult(registerOrderDon);
+    }
+
+
+
+}

netflix-web/src/main/java/com/cyksj/web/controller/register/RegisterController.java

@@ -0,0 +1,120 @@
+package com.cyksj.web.controller.register;
+
+import com.cyksj.common.exception.BusinessRuntimeException;
+import com.cyksj.common.util.IoKit;
+import com.cyksj.common.util.Xmls;
+import com.cyksj.dto.Result;
+import com.cyksj.enums.GatewayResponse;
+import com.cyksj.model.dto.H5JsPayParams;
+import com.cyksj.model.dto.H5PayParams;
+import com.cyksj.model.entity.RegisterOrderDon;
+import com.cyksj.model.manage.request.RegisterReq;
+import com.cyksj.redis.RedisService;
+import com.cyksj.service.register.RegisterOrderDonService;
+import com.cyksj.service.register.SpotifyService;
+import com.cyksj.web.util.StpUserUtil;
+import com.ejlchina.searcher.BeanSearcher;
+import com.ejlchina.searcher.SearchResult;
+import com.ejlchina.searcher.util.MapUtils;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.OutputStream;
+import java.util.Map;
+
+/**
+ * @author chan
+ * @date 2022/11/7 1:49 PM
+ */
+@Slf4j
+@RestController
+@RequestMapping("/applets/register")
+@RequiredArgsConstructor
+public class RegisterController {
+
+    private final RegisterOrderDonService registerOrderDonService;
+
+    private final BeanSearcher beanSearcher;
+
+    private final HttpServletRequest request;
+
+    @PostMapping
+    public Result<RegisterOrderDon> register(@RequestBody RegisterReq req) throws Exception {
+        long userId = StpUserUtil.getLoginIdAsLong();
+        //参数校验
+        boolean isFree = false;
+        //判断Spotify是否拥有免费资格
+        if("spotify".equals(req.getPlatform())){
+            isFree = registerOrderDonService.isFree(userId,req.getPlatform());
+        }
+        RegisterOrderDon orderDon = registerOrderDonService.saveOrder(userId,req,isFree);
+
+        orderDon.setPassword("");
+
+        return GatewayResponse.SUCCESS.newBuilder().toResult(orderDon);
+    }
+
+  /**
+   * 注册资料支付
+   * @author chan
+   * @date 2022-11-07 3:44 PM
+   */
+    @PostMapping("/post/pay/{orderId}")
+    public Result<H5JsPayParams> pay(@PathVariable Long orderId) throws Exception {
+        final String methodName = "提交注册资料 吊起微信支付";
+        log.info("{}[start] orderId:{}",methodName,orderId);
+
+        H5JsPayParams payParams = registerOrderDonService.pay(orderId);
+
+        return GatewayResponse.SUCCESS.newBuilder().toResult(payParams);
+    }
+
+    /**
+     * 微信支付回调
+     * @author chan
+     * @date 2021-10-11 下午5:42
+     */
+    @PostMapping("/prepay/notify")
+    public void prepayNotify(HttpServletRequest request, HttpServletResponse response) throws Exception {
+
+        String xml = IoKit.toString(request.getInputStream());
+        log.info("=== 基金会分发支付成功的回调: \n {}", xml);
+
+        // 解析xml
+        Map<String, String> map = Xmls.toMap(xml);
+
+        // 支付失败
+        if (!StringUtils.equals("SUCCESS", map.get("return_code")) || !StringUtils.equals("SUCCESS", map.get("result_code"))) {
+            throw BusinessRuntimeException.getInstance("支付失败.");
+        }
+
+        registerOrderDonService.prepayNotify(map);
+        String toWeChatXmlResponse = "<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>";
+
+        OutputStream out = null;
+        try {
+            out = response.getOutputStream();
+            IoKit.write(toWeChatXmlResponse, out);
+        } catch (Exception e) {
+            throw BusinessRuntimeException.getInstance(e,e.getMessage());
+        } finally {
+            IoKit.close(out);
+        }
+    }
+
+    @GetMapping("/get")
+    public Result<SearchResult<RegisterOrderDon>> get(){
+        long userId = StpUserUtil.getLoginIdAsLong();
+        SearchResult<RegisterOrderDon> search = beanSearcher.search(RegisterOrderDon.class, MapUtils.flatBuilder(request.getParameterMap())
+                .field(RegisterOrderDon::getUserId,userId)
+                .build());
+        return GatewayResponse.SUCCESS.newBuilder().toResult(search);
+    }
+
+
+
+}