注册账号 spotify

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/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/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/RegisterOrderDon.java

@@ -0,0 +1,87 @@
+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 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/manage/request/SpotifyRegisterReq.java → netflix-dao/src/main/java/com/cyksj/model/manage/request/RegisterReq.java

@@ -7,7 +7,13 @@ import lombok.Data;
  * @date 2022/11/3 3:49 PM
  */
 @Data
-public class SpotifyRegisterReq {
+public class RegisterReq {
+
+    /**
+     *  平台 Spotify google apple
+     */
+    private String platform;
+
     private String creationPoint;
 
     private String displayname;
@@ -28,5 +34,7 @@ public class SpotifyRegisterReq {
 
     private String email;
 
-    private String iagree;
+    private String country;
+
+    private String phone;
 }

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

@@ -13,6 +13,8 @@ import lombok.ToString;
 @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,176 @@
+package com.cyksj.service.register.impl;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.date.DateField;
+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.model.dto.H5JsPayParams;
+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 SysConfigService sysConfigService;
+
+    /**
+     * 判断是否免费
+     * @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 false;
+        }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();
+        BeanUtil.copyProperties(req,orderDon);
+        SysConfig register_price = sysConfigService.getOne(Wrappers.lambdaQuery(SysConfig.class).eq(SysConfig::getSysKey, "register_price").last("limit 1"));
+        Map<String, String> map = Jsons.toMap(register_price.getSysValue());
+
+        orderDon.setOrderNo(SEQUENCE.nextId() + "");
+        orderDon.setIsFree(isFree);
+        orderDon.setMoney(isFree ? BigDecimal.ZERO : new BigDecimal(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-web/src/main/java/com/cyksj/web/controller/manage/spotify/SpotifyController.java → netflix-service/src/main/java/com/cyksj/service/register/impl/SpotifyServiceImpl.java

@@ -1,4 +1,4 @@
-package com.cyksj.web.controller.manage.spotify;
+package com.cyksj.service.register.impl;
 
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.util.RandomUtil;
@@ -14,18 +14,16 @@ 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.mapper.RegisterOrderDonMapper;
 import com.cyksj.model.entity.Proxys;
+import com.cyksj.model.entity.RegisterOrderDon;
 import com.cyksj.model.entity.SpotifyRegister;
-import com.cyksj.model.manage.request.SpotifyRegisterReq;
 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.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 org.springframework.stereotype.Service;
 
 import java.net.InetSocketAddress;
 import java.net.Proxy;
@@ -36,17 +34,16 @@ import java.util.stream.Collectors;
 
 /**
  * @author chan
- * @date 2022/11/3 3:50 PM
+ * @date 2022/11/7 1:54 PM
  */
-@RequestMapping("/spotify")
-@RestController
+@Service
 @Slf4j
 @RequiredArgsConstructor
-public class SpotifyController {
+public class SpotifyServiceImpl implements SpotifyService {
 
     private final ProxysMapper proxysMapper;
 
-    private final SpotifyRegisterMapper spotifyRegisterMapper;
+    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)",
@@ -84,9 +81,10 @@ public class SpotifyController {
             "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);
+    @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())));
@@ -101,16 +99,16 @@ public class SpotifyController {
         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());
+        jsonObject.put("displayname",registerOrderDon.getNickname());
+        jsonObject.put("password_repeat",registerOrderDon.getPassword());
+        jsonObject.put("password",registerOrderDon.getPassword());
+        jsonObject.put("username",registerOrderDon.getUsername());
+        jsonObject.put("birth_year",registerOrderDon.getBirthYear());
+        jsonObject.put("birth_month",registerOrderDon.getBirthMonth());
+        jsonObject.put("birth_day",registerOrderDon.getBirthDay());
+        jsonObject.put("gender",registerOrderDon.getGender());
+        jsonObject.put("email",registerOrderDon.getEmail());
+        jsonObject.put("iagree","1");
         request.setMethod(Method.POST);
 
         request.form(jsonObject);
@@ -123,7 +121,7 @@ public class SpotifyController {
 
         int start = 1;
         int limit = 20;
-
+        boolean regFlag = false;
         while (true){
             for (ProxyInfo proxyInfo : proxyInfos) {
                 try {
@@ -135,20 +133,39 @@ public class SpotifyController {
                     String body = response.body();
                     log.info("spotify 返回body:{}",body);
                     JSONObject resObj = JSONUtil.parseObj(body);
+                    JSONObject errors = resObj.getJSONObject("errors");
+                    String errorMsg = errors.getStr("generic_error");
+                    if (!errors.isEmpty()) {
+                        if ("你似乎正在使用代理服务。请关闭此类服务，然后再试一次。如需更多帮助，请联系客服服务。".equals(errorMsg)) {
+                            log.info("spotify 注册 被监测出代理服务 。 删除该代理 ip:{}",proxyInfo.getIp());
+                            if(proxyInfo.getId() != null){
+                                proxysMapper.deleteById(proxyInfo.getId());
+                            }
+                            continue;
+                        }else {
+                            registerOrderDon.setErrorMsg(errorMsg);
+                            registerOrderDon.setStatus(RegisterOrderDon.Status.error);
+                            registerOrderDonMapper.updateById(registerOrderDon);
+                            break;
+                        }
+                    }
                     if(StringUtils.isNotBlank(resObj.getStr("login_token"))){
                         log.info("注册成功！");
-                        SpotifyRegister spotifyRegister = new SpotifyRegister();
-                        BeanUtil.copyProperties(registerReq,spotifyRegister);
-                        spotifyRegisterMapper.insert(spotifyRegister);
+                        registerOrderDon.setStatus(RegisterOrderDon.Status.complete);
+                        registerOrderDonMapper.updateById(registerOrderDon);
+                        regFlag = true;
                         break;
                     }
-                    return GatewayResponse.SUCCESS.newBuilder().toResult("注册成功！");
                 }catch (Exception e){
                     e.printStackTrace();
                     log.error("错误 ip:{}",proxyInfo.getIp());
                 }
             }
 
+            if(regFlag){
+                break;
+            }
+
             List<Proxys> records = proxysMapper.selectPage(new Page<>(start, limit), Wrappers.lambdaQuery(Proxys.class).orderByDesc(Proxys::getId)).getRecords();
             if(records.isEmpty()){
                 break;
@@ -160,10 +177,7 @@ public class SpotifyController {
                 return proxyInfo;
             }).collect(Collectors.toList());
         }
-
-        return GatewayResponse.FAIL.newBuilder().toResult("注册失败！");
     }
 
 
 }
-

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;
+
 
     /**
      * 统计前一天数据
@@ -53,7 +64,7 @@ public class Scheduler {
 
     }
 
-    //@Scheduled(cron = "0 0 9 * * ?")
+    @Scheduled(cron = "0 0 9 * * ?")
     public void expiryWxMsg() throws Exception {
         DateTime now = new DateTime();
         DateTime zero = DateUtil.offset(now, DateField.HOUR, -9);
@@ -126,4 +137,29 @@ public class Scheduler {
             orderDonService.closeOrder(orderDon.getId());
         });
     }
+
+    /**
+     * spotify 注册
+     */
+    @Scheduled(cron = "0 0/5 0 * * ?")
+    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,117 @@
+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(){
+        SearchResult<RegisterOrderDon> search = beanSearcher.search(RegisterOrderDon.class, MapUtils.flatBuilder(request.getParameterMap()).build());
+        return GatewayResponse.SUCCESS.newBuilder().toResult(search);
+    }
+
+
+
+}