fix

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

@@ -0,0 +1,13 @@
+package com.cyksj.mapper.netflix;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.cyksj.model.entity.netflix.NetflixUser;
+
+/**
+ * @author chan
+ * @date 2022/10/17 4:40 PM
+ */
+@DS("netfix")
+public interface NetflixUserMapper extends BaseMapper<NetflixUser> {
+}

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

@@ -0,0 +1,13 @@
+package com.cyksj.mapper.netflix;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.cyksj.model.entity.netflix.Ticket;
+
+/**
+ * @author chan
+ * @date 2022/10/17 4:43 PM
+ */
+@DS("netfix")
+public interface TicketMapper extends BaseMapper<Ticket> {
+}

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

@@ -0,0 +1,31 @@
+package com.cyksj.model.entity.netflix;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+/**
+ * @author chan
+ * @date 2022/10/17 3:28 PM
+ */
+@Data
+@TableName("user")
+public class NetflixUser {
+    private String id;
+
+    private String name;
+
+    private String type;
+
+    private Integer sex;
+
+    private String url;
+
+    private String phone;
+
+    private String password;
+
+    private String wxid;
+
+
+}

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

@@ -0,0 +1,25 @@
+package com.cyksj.model.entity.netflix;
+
+import lombok.Data;
+
+/**
+ * @author chan
+ * @date 2022/10/17 4:40 PM
+ */
+@Data
+public class Ticket {
+    private Integer id;
+
+    private String account;
+
+    private String password;
+
+    private String platName;
+
+    private String buyers;
+
+    private String creatTime;
+
+    private String type;
+
+}

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

@@ -3,10 +3,21 @@ package com.cyksj.web.controller.manage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.cyksj.dto.Result;
 import com.cyksj.enums.GatewayResponse;
+import com.cyksj.mapper.AccountMapper;
+import com.cyksj.mapper.GoodsDonMapper;
 import com.cyksj.mapper.GroupsRelationMapper;
+import com.cyksj.mapper.UserMapper;
+import com.cyksj.mapper.netflix.NetflixUserMapper;
+import com.cyksj.mapper.netflix.TicketMapper;
+import com.cyksj.model.dto.GzhUnionidUserinfo;
+import com.cyksj.model.entity.Account;
+import com.cyksj.model.entity.GoodsDon;
 import com.cyksj.model.entity.GroupsRelation;
 import com.cyksj.model.entity.User;
+import com.cyksj.model.entity.netflix.NetflixUser;
+import com.cyksj.model.entity.netflix.Ticket;
 import com.cyksj.model.manage.views.UserView;
+import com.cyksj.service.wechat.WeChatService;
 import com.ejlchina.searcher.BeanSearcher;
 import com.ejlchina.searcher.SearchResult;
 import com.ejlchina.searcher.util.MapUtils;
@@ -17,6 +28,8 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.servlet.http.HttpServletRequest;
+import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * @author chan
@@ -34,6 +47,19 @@ public class CmsUserController{
 
     private final GroupsRelationMapper relationMapper;
 
+    private final NetflixUserMapper netflixUserMapper;
+
+    private final TicketMapper ticketMapper;
+
+    private final UserMapper userMapper;
+
+    private final WeChatService weChatService;
+
+    private final AccountMapper accountMapper;
+
+    private final GoodsDonMapper goodsDonMapper;
+
+
 
     @GetMapping("/get")
     public Result<SearchResult<UserView>> get(){
@@ -45,6 +71,51 @@ public class CmsUserController{
     }
 
 
+    @GetMapping("/init")
+    public Result<String> init(){
+        List<NetflixUser> userList = netflixUserMapper.selectList(Wrappers.lambdaQuery());
+        List<User> users = userList.stream().map((netflixUser) -> {
 
+            User user = new User();
+            try {
+                user.setPhone(netflixUser.getPhone());
+                user.setNickname(netflixUser.getName());
+                user.setHeadimgurl(netflixUser.getUrl());
+                user.setSex(netflixUser.getSex());
+                user.setOpenId(netflixUser.getId());
+                //GzhUnionidUserinfo userInfo2 = weChatService.getUserInfo2(weChatService.getAccessToken(), netflixUser.getId());
+                //if (userInfo2.getSubscribe() == 1) {
+                //    user.setUnionid(userInfo2.getUnionid());
+                //}
+                return user;
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+            return user;
+        }).collect(Collectors.toList());
+        for (User user : users) {
+            userMapper.insert(user);
+        }
+        return GatewayResponse.SUCCESS.newBuilder().toResult();
+    }
+
+    @GetMapping("/account/init")
+    public Result<String> accountInit(){
+        List<Account> accounts = accountMapper.selectList(Wrappers.lambdaQuery());
+        accounts.forEach((account)->{
+            GoodsDon goodsDon = goodsDonMapper.selectOne(Wrappers.lambdaQuery(GoodsDon.class).eq(GoodsDon::getTitle, account.getTitle()));
+            account.setGoodsId(goodsDon.getId());
+            accountMapper.updateById(account);
+        });
+        return GatewayResponse.SUCCESS.newBuilder().toResult();
+    }
+
+    @GetMapping("/group/init")
+    public Result<String> groupInt(){
+        List<String> list = accountMapper.selectList(Wrappers.lambdaQuery()).stream().map(Account::getAccount).collect(Collectors.toList());
+        List<Ticket> tickets = ticketMapper.selectList(Wrappers.lambdaQuery(Ticket.class).in(Ticket::getAccount, list));
+
+        return GatewayResponse.SUCCESS.newBuilder().toResult();
+    }
 
 }

netflix-web/src/main/java/com/cyksj/web/controller/manage/goods/CmsGoodsDonSkuController.java

@@ -154,11 +154,6 @@ public class CmsGoodsDonSkuController {
 
         for (ReqGoodsSkuInsert.Sku sku : insert.getSkus()) {
             // 跳过空值的sku
-            final String picture = sku.getPicture();
-            if (StringUtils.isBlank(picture)) {
-                throw new RuntimeException("请上传商品sku展示图.");
-            }
-
             // 解析sku的规格属性
             final String specIds = sku.getSpecIds();
             if (StringUtils.isBlank(specIds)) {

pom.xml

@@ -121,6 +121,12 @@
             <version>3.8.0</version>
         </dependency>
 
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
+            <version>3.3.1</version>
+        </dependency>
+
     </dependencies>
 
     <build>