From d39965b032d1a75f0413869f7b24088c109e580b Mon Sep 17 00:00:00 2001 From: wuchunlei Date: Fri, 17 May 2024 17:59:38 +0800 Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=90=88=E5=B9=B6-=E6=B9=96?= =?UTF-8?q?=E5=88=86=20=E7=AE=A1=E7=90=86=E7=AB=AF-=E6=B9=96=E5=88=86?= =?UTF-8?q?=E7=AE=A1=E7=90=86=20=E9=80=9A=E7=94=A8=E6=A8=A1=E5=9D=97-?= =?UTF-8?q?=E6=B9=96=E5=88=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../common/utils/DataMigrationUtil.java | 63 ++++++++++++---- .../UserContributionController.java | 58 ++++++++++++++ .../common/dao/UserContributionDao.java | 9 +++ .../common/entity/UserContribution.java | 38 ++++++++++ .../service/UserContributionService.java | 7 ++ .../impl/UserContributionServiceImpl.java | 13 ++++ .../UserContributionController.java | 75 +++++++++++++++++++ .../service/UserContributionService.java | 7 ++ .../impl/UserContributionServiceImpl.java | 13 ++++ 9 files changed, 268 insertions(+), 15 deletions(-) create mode 100644 src/main/java/com/peanut/modules/common/controller/UserContributionController.java create mode 100644 src/main/java/com/peanut/modules/common/dao/UserContributionDao.java create mode 100644 src/main/java/com/peanut/modules/common/entity/UserContribution.java create mode 100644 src/main/java/com/peanut/modules/common/service/UserContributionService.java create mode 100644 src/main/java/com/peanut/modules/common/service/impl/UserContributionServiceImpl.java create mode 100644 src/main/java/com/peanut/modules/master/controller/UserContributionController.java create mode 100644 src/main/java/com/peanut/modules/master/service/UserContributionService.java create mode 100644 src/main/java/com/peanut/modules/master/service/impl/UserContributionServiceImpl.java diff --git a/src/main/java/com/peanut/common/utils/DataMigrationUtil.java b/src/main/java/com/peanut/common/utils/DataMigrationUtil.java index c857a47f..0c681d81 100644 --- a/src/main/java/com/peanut/common/utils/DataMigrationUtil.java +++ b/src/main/java/com/peanut/common/utils/DataMigrationUtil.java @@ -15,11 +15,13 @@ public class DataMigrationUtil extends Thread { Map map; int i; + Connection yljkconn; Connection fzdsconn; - public DataMigrationUtil(Map map,int i,Connection fzdsconn){ + public DataMigrationUtil(Map map,int i,Connection yljkconn,Connection fzdsconn){ this.map = map; this.i = i; + this.yljkconn = yljkconn; this.fzdsconn = fzdsconn; } @@ -29,8 +31,8 @@ public class DataMigrationUtil extends Thread { // courseCatalogue(); // courseCatalogueChapter(); // courseCatalogueChapterVideo(); -// user();//用的都是copy表里的数据 -//TRUNCATE + user();//用的都是copy表里的数据 +// truncate(); } @@ -337,7 +339,27 @@ public class DataMigrationUtil extends Thread { } } + public static void truncate(){ + try { + Connection fzdsconn = DriverManager.getConnection( + "jdbc:mysql://rm-2zev4157t67trxuu3yo.mysql.rds.aliyuncs.com:3306/e_book_test?rewriteBatchedStatements=true", + "nuttyreading", "Wu751019!"); + PreparedStatement statement = fzdsconn.prepareStatement("TRUNCATE table user_copy1;"); + statement.execute(); + PreparedStatement statement2 = fzdsconn.prepareStatement("TRUNCATE table user_vip_copy1;"); + statement2.execute(); + PreparedStatement statement3 = fzdsconn.prepareStatement("TRUNCATE table transaction_details_copy1;"); + statement3.execute(); + PreparedStatement statement4 = fzdsconn.prepareStatement("TRUNCATE table user_contribution;"); + statement4.execute(); + System.out.println("清空完成"); + }catch (SQLException e) { + System.out.println(e.getMessage()); + } + } + public static void user(){ + truncate(); try { long startTime = System.currentTimeMillis(); Connection yljkconn = DriverManager.getConnection( @@ -362,15 +384,13 @@ public class DataMigrationUtil extends Thread { list.add(map); } resultSet.close(); - statement.close(); - yljkconn.close(); Connection fzdsconn = DriverManager.getConnection( "jdbc:mysql://rm-2zev4157t67trxuu3yo.mysql.rds.aliyuncs.com:3306/e_book_test?rewriteBatchedStatements=true", "nuttyreading", "Wu751019!"); // 1、创建服务，创建线程池 ExecutorService service = Executors.newFixedThreadPool(50); for (int i=0;i { +} diff --git a/src/main/java/com/peanut/modules/common/entity/UserContribution.java b/src/main/java/com/peanut/modules/common/entity/UserContribution.java new file mode 100644 index 00000000..dee2e100 --- /dev/null +++ b/src/main/java/com/peanut/modules/common/entity/UserContribution.java @@ -0,0 +1,38 @@ +package com.peanut.modules.common.entity; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableLogic; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; +import java.util.Date; + +@Data +@TableName("user_contribution") +public class UserContribution { + + @TableId + private Integer id; + + private Integer userId; + + //分数 + private Double score; + + //明细 + private String detail; + + //类型 在线教学 01 学术期刊 03 太湖讲堂 05 创作技术 07 注册邀请 11 课程邀请 13 + private String type; + + //兑换标志 未兑换0 兑换完毕1 + private Integer conversionFlag; + + private Date createTime; + + @TableLogic + private Integer delFlag; + + @TableField(exist = false) + private MyUserEntity user; +} diff --git a/src/main/java/com/peanut/modules/common/service/UserContributionService.java b/src/main/java/com/peanut/modules/common/service/UserContributionService.java new file mode 100644 index 00000000..3e962c13 --- /dev/null +++ b/src/main/java/com/peanut/modules/common/service/UserContributionService.java @@ -0,0 +1,7 @@ +package com.peanut.modules.common.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.peanut.modules.common.entity.UserContribution; + +public interface UserContributionService extends IService { +} diff --git a/src/main/java/com/peanut/modules/common/service/impl/UserContributionServiceImpl.java b/src/main/java/com/peanut/modules/common/service/impl/UserContributionServiceImpl.java new file mode 100644 index 00000000..f47bb079 --- /dev/null +++ b/src/main/java/com/peanut/modules/common/service/impl/UserContributionServiceImpl.java @@ -0,0 +1,13 @@ +package com.peanut.modules.common.service.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.peanut.modules.common.dao.UserContributionDao; +import com.peanut.modules.common.entity.UserContribution; +import com.peanut.modules.common.service.UserContributionService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +@Slf4j +@Service("commonUserContributionService") +public class UserContributionServiceImpl extends ServiceImpl implements UserContributionService { +} diff --git a/src/main/java/com/peanut/modules/master/controller/UserContributionController.java b/src/main/java/com/peanut/modules/master/controller/UserContributionController.java new file mode 100644 index 00000000..5e779305 --- /dev/null +++ b/src/main/java/com/peanut/modules/master/controller/UserContributionController.java @@ -0,0 +1,75 @@ +package com.peanut.modules.master.controller; + +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.github.yulichang.wrapper.MPJLambdaWrapper; +import com.peanut.common.utils.R; +import com.peanut.modules.common.entity.MyUserEntity; +import com.peanut.modules.common.entity.UserContribution; +import com.peanut.modules.master.service.MyUserService; +import com.peanut.modules.master.service.UserContributionService; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.List; +import java.util.Map; + +/** + * 湖分管理 + */ +@Slf4j +@RestController("masterUserContribution") +@RequestMapping("master/userContribution") +public class UserContributionController { + + @Autowired + private UserContributionService contributionService; + @Autowired + private MyUserService userService; + + @RequestMapping("/listByPage") + public R listByPage(@RequestBody Map params) { + MPJLambdaWrapper wrapper = new MPJLambdaWrapper(); + wrapper.selectAll(UserContribution.class); + wrapper.leftJoin(MyUserEntity.class, MyUserEntity::getId, UserContribution::getUserId); + if (params.containsKey("userName")&& StringUtils.isNotEmpty(params.get("userName").toString())) { + wrapper.like(MyUserEntity::getName,params.get("userName")); + wrapper.like(MyUserEntity::getNickname,params.get("userName")); + } + if (params.containsKey("tel")&& StringUtils.isNotEmpty(params.get("tel").toString())) { + wrapper.like(MyUserEntity::getTel,params.get("tel")); + } + if (params.containsKey("email")&& StringUtils.isNotEmpty(params.get("email").toString())) { + wrapper.like(MyUserEntity::getEmail,params.get("email")); + } + if (params.containsKey("type")&& StringUtils.isNotEmpty(params.get("type").toString())) { + wrapper.eq(UserContribution::getType,params.get("type")); + } + wrapper.orderByDesc(UserContribution::getCreateTime); + Page page = contributionService.page(new Page<>( + Long.parseLong(params.get("current").toString()), Long.parseLong(params.get("limit").toString())), wrapper); + List userContributions = page.getRecords(); + if (userContributions.size() > 0){ + for (UserContribution contribution : userContributions) { + contribution.setUser(userService.getById(contribution.getUserId())); + } + } + return R.ok().put("result", page); + } + + @RequestMapping("/saveUserContribution") + public R saveUserContribution(@RequestBody UserContribution contribution) { + contributionService.save(contribution); + return R.ok(); + } + + @RequestMapping("/delUserContribution") + public R delMessage(String id) { + contributionService.removeById(id); + return R.ok(); + } + +} diff --git a/src/main/java/com/peanut/modules/master/service/UserContributionService.java b/src/main/java/com/peanut/modules/master/service/UserContributionService.java new file mode 100644 index 00000000..ea9c4d2e --- /dev/null +++ b/src/main/java/com/peanut/modules/master/service/UserContributionService.java @@ -0,0 +1,7 @@ +package com.peanut.modules.master.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.peanut.modules.common.entity.UserContribution; + +public interface UserContributionService extends IService { +} diff --git a/src/main/java/com/peanut/modules/master/service/impl/UserContributionServiceImpl.java b/src/main/java/com/peanut/modules/master/service/impl/UserContributionServiceImpl.java new file mode 100644 index 00000000..4cc2c751 --- /dev/null +++ b/src/main/java/com/peanut/modules/master/service/impl/UserContributionServiceImpl.java @@ -0,0 +1,13 @@ +package com.peanut.modules.master.service.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.peanut.modules.common.dao.UserContributionDao; +import com.peanut.modules.common.entity.UserContribution; +import com.peanut.modules.master.service.UserContributionService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +@Slf4j +@Service("masterUserContributionService") +public class UserContributionServiceImpl extends ServiceImpl implements UserContributionService { +}