package com.peanut.modules.master.controller; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.peanut.common.utils.R; import com.peanut.modules.common.entity.*; import com.peanut.modules.master.service.CourseService; import com.peanut.modules.master.service.MyUserService; import com.peanut.modules.master.service.UserManageService; import lombok.extern.slf4j.Slf4j; 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; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.datasource.DriverManagerDataSource; import org.springframework.stereotype.Service; /** * 用户管理 */ @Slf4j @RestController("masterUserManage") @RequestMapping("master/userManage") public class UserManageController { @Autowired private UserManageService mergeService; @Autowired private CourseService courseService; @Autowired private MyUserService userService; //数据合并 @RequestMapping("/userMerge") public R userMerge(@RequestBody Map params) { return mergeService.userMerge(params); } //手动开课 @RequestMapping("/addUserCourseBuy") public R updateUserCourseBuy(@RequestBody UserCourseBuyEntity userCourseBuyEntity) { return mergeService.addUserCourseBuy(userCourseBuyEntity); } //课程列表 @RequestMapping("/courseAndChildrenList") public R courseAndChildrenList(@RequestBody Map params) { List list = courseService.courseAndChildrenList(params); return R.ok().put("list",list); } //课程目录列表 @RequestMapping("/catalogueListByCourse") public R catalogueListByCourse(@RequestBody Map params) { List list = courseService.catalogueListByCourse(params); return R.ok().put("list",list); } //获取用户已有课程列表 @RequestMapping("/getUserCourseList") public R getUserCourseList(@RequestBody Map params) { Page> page = courseService.getUserCourseList(params); return R.ok().put("result",page); } //获取vip用户列表 @RequestMapping("/getVipList") public R getVipList(@RequestBody Map params) { Page> page = userService.getVipList(params); return R.ok().put("result",page); } //获取vip历史开通记录 @RequestMapping("/getVipHistoryList") public R getVipHistoryList(@RequestBody Map params) { Page page = userService.getVipHistoryList(params); return R.ok().put("result",page); } @RequestMapping("/getTest") public R getTest(){ DriverManagerDataSource dataSourceSecond = new DriverManagerDataSource(); dataSourceSecond.setDriverClassName("com.mysql.cj.jdbc.Driver"); dataSourceSecond.setUrl("jdbc:mysql://goldorchid.mysql.rds.aliyuncs.com:3309/everhealth?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull"); dataSourceSecond.setUsername("yljkmaster"); dataSourceSecond.setPassword("Wu751019!@"); JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSourceSecond); List> maps = jdbcTemplate.queryForList("select * from t_customer where POINT>0 or pointbyjf>0 limit 100"); for (Map m:maps){ System.out.println(m.get("nameCN")+"/"+m.get("point")); } System.out.println(maps); return R.ok(); } }