Compare commits

..
5 Commits
Author SHA1 Message Date
zk 30b9a62d2a 添加部署文件 2026-07-10 15:41:11 +08:00
zk bcdd1419e5 用户 / 订单 / 商品 管理 2026-07-10 15:27:16 +08:00
zk 20ab909329 用户 / 订单 / 商品 管理 2026-07-10 14:36:44 +08:00
zk 45b2c3073f 添加登录页面 2026-07-10 14:18:48 +08:00
zk 4585c824b7 admin 初始化 2026-07-10 11:44:17 +08:00
47 changed files with 2597 additions and 0 deletions
+45
View File
@@ -0,0 +1,45 @@
# ==================== 第一阶段:编译 ====================
FROM maven:3.8-openjdk-17 AS builder
WORKDIR /build
# 阿里云 Maven 镜像加速
COPY settings.xml /root/.m2/settings.xml
# 先拷贝 pom 利用 Docker 缓存层(依赖不变时跳过下载)
COPY pom.xml .
COPY common/pom.xml common/pom.xml
COPY manager/pom.xml manager/pom.xml
COPY admin/pom.xml admin/pom.xml
# 拷贝源码
COPY . .
# 构建(从父 pom 编译,admin 依赖 common 和 manager
RUN --mount=type=cache,target=/root/.m2/repository \
mvn clean package -pl admin -am -DskipTests
# ==================== 第二阶段:运行 ====================
FROM alibabadragonwell/dragonwell:17-anolis
ENV TZ=Asia/Shanghai
ENV PROFILES_ACTIVE=prod
ENV JAVA_OPTS="-XX:MaxRAMPercentage=75.0 \
-XX:+UseG1GC \
-XX:+HeapDumpOnOutOfMemoryError \
-XX:HeapDumpPath=/app/logs/heapdump.hprof \
-Dfile.encoding=UTF-8 \
-Duser.timezone=Asia/Shanghai"
# 时区 + curl(健康检查用)
RUN ln -sf /usr/share/zoneinfo/$TZ /etc/localtime && echo $TZ > /etc/timezone \
&& yum install -y curl && yum clean all
RUN mkdir -p /app/logs
WORKDIR /app
EXPOSE 8081
COPY --from=builder /build/admin/target/admin.jar ./admin.jar
CMD java $JAVA_OPTS -jar admin.jar
+202
View File
@@ -0,0 +1,202 @@
/**
* OfferPie Backend Admin 蓝绿部署流水线
*
* 架构:Jenkins 本地编译 → scp 镜像到目标机 → SSH 远程蓝绿切换
* 目标机目录:/opt/offerpie/admin/
*/
pipeline {
agent any
parameters {
choice(name: 'BRANCH', choices: ['master', 'pre', 'dev', 'test'], description: '选择要部署的分支')
}
environment {
// 目标服务器配置
DEPLOY_HOST = '8.148.237.97'
DEPLOY_PORT = '22'
DEPLOY_USER = 'root'
DEPLOY_PASS = 'Mzpy520@126.com'
// 项目配置
IMAGE_NAME = 'offerpie-backend-admin'
IMAGE_TAG = 'latest'
CONTAINER_PREFIX = 'offerpie-backend-admin'
REMOTE_DIR = '/opt/offerpie/admin'
HEALTH_URL = 'http://localhost:8081/admin/public/actuator/health'
// SSH 命令前缀
SSH_CMD = "sshpass -p '${DEPLOY_PASS}' ssh -o StrictHostKeyChecking=no -p ${DEPLOY_PORT} ${DEPLOY_USER}@${DEPLOY_HOST}"
SCP_CMD = "sshpass -p '${DEPLOY_PASS}' scp -o StrictHostKeyChecking=no -P ${DEPLOY_PORT}"
}
stages {
stage('环境检查') {
steps {
sh 'sshpass -V'
}
}
stage('拉取代码') {
steps {
echo "拉取 ${params.BRANCH} 分支代码"
git branch: "${params.BRANCH}",
credentialsId: 'gitea-fab089c1-b55d-4b58-9fad',
url: 'http://git.jianshixingqiu.com/offerpai/offerpai_backend.git'
}
}
stage('本地编译') {
steps {
echo "开始构建镜像"
sh "docker build -f admin/Dockerfile -t ${IMAGE_NAME}:${IMAGE_TAG} ."
echo "导出镜像"
sh "docker save -o ${IMAGE_NAME}.tar ${IMAGE_NAME}:${IMAGE_TAG}"
}
}
stage('文件传输') {
steps {
echo "传输文件到目标服务器"
sh "${SSH_CMD} 'mkdir -p ${REMOTE_DIR}'"
sh "${SCP_CMD} ${IMAGE_NAME}.tar ${DEPLOY_USER}@${DEPLOY_HOST}:${REMOTE_DIR}/"
sh "${SCP_CMD} admin/nginx.conf ${DEPLOY_USER}@${DEPLOY_HOST}:${REMOTE_DIR}/nginx.conf"
sh "${SCP_CMD} docker-compose.admin.yml ${DEPLOY_USER}@${DEPLOY_HOST}:${REMOTE_DIR}/docker-compose.yml"
}
}
stage('加载镜像') {
steps {
sh "${SSH_CMD} 'docker load < ${REMOTE_DIR}/${IMAGE_NAME}.tar'"
}
}
stage('检测部署目标') {
steps {
script {
def blueRunning = sh(script: "${SSH_CMD} 'docker ps -q -f name=${CONTAINER_PREFIX}-blue'", returnStdout: true).trim()
def greenRunning = sh(script: "${SSH_CMD} 'docker ps -q -f name=${CONTAINER_PREFIX}-green'", returnStdout: true).trim()
env.DEPLOY_TARGET = ''
if (blueRunning && !greenRunning) {
env.DEPLOY_TARGET = 'green'
}
if (greenRunning && !blueRunning) {
env.DEPLOY_TARGET = 'blue'
}
if (!env.DEPLOY_TARGET) {
echo "当前环境未部署服务或状态异常,默认部署 blue"
env.DEPLOY_TARGET = 'blue'
}
env.OTHER_TARGET = (env.DEPLOY_TARGET == 'blue') ? 'green' : 'blue'
echo "当前激活: ${env.OTHER_TARGET},即将部署: ${env.DEPLOY_TARGET}"
}
}
}
stage('启动新版本') {
steps {
script {
def existingContainer = sh(script: "${SSH_CMD} 'docker ps -aq -f name=${CONTAINER_PREFIX}-${env.DEPLOY_TARGET}'", returnStdout: true).trim()
if (existingContainer) {
sh "${SSH_CMD} 'docker rm -f ${CONTAINER_PREFIX}-${env.DEPLOY_TARGET}'"
}
sh "${SSH_CMD} 'cd ${REMOTE_DIR} && docker compose up -d ${env.DEPLOY_TARGET}'"
sh 'sleep 35'
}
}
}
stage('检查Nginx') {
steps {
script {
def nginxExists = sh(script: "${SSH_CMD} 'docker ps -aq -f name=${CONTAINER_PREFIX}-nginx'", returnStdout: true).trim()
if (!nginxExists) {
echo "首次部署,初始化 Nginx 容器"
sh "${SSH_CMD} 'cd ${REMOTE_DIR} && docker compose up -d nginx'"
sh 'sleep 3'
} else {
def nginxRunning = sh(script: "${SSH_CMD} 'docker ps -q -f name=${CONTAINER_PREFIX}-nginx'", returnStdout: true).trim()
if (!nginxRunning) {
echo "Nginx 容器已停止,重新启动"
sh "${SSH_CMD} 'docker start ${CONTAINER_PREFIX}-nginx'"
sh 'sleep 2'
}
echo "Nginx 容器已存在且运行中"
}
// docker cp nginx.conf 进容器(覆盖更新配置模板)
sh "${SSH_CMD} 'docker cp ${REMOTE_DIR}/nginx.conf ${CONTAINER_PREFIX}-nginx:/etc/nginx/nginx.conf'"
}
}
}
stage('健康检查') {
steps {
script {
def maxRetries = 3
def retryCount = 0
def healthy = false
while (retryCount < maxRetries && !healthy) {
try {
sh "${SSH_CMD} 'docker exec ${CONTAINER_PREFIX}-${env.DEPLOY_TARGET} curl -f ${HEALTH_URL}'"
healthy = true
} catch (Exception e) {
retryCount++
if (retryCount < maxRetries) {
echo "健康检查失败,5秒后重试 (${retryCount}/${maxRetries})"
sleep 5
}
}
}
if (!healthy) {
error "健康检查失败,部署中止"
}
echo "✅ ${CONTAINER_PREFIX}-${env.DEPLOY_TARGET} 健康检查通过"
}
}
}
stage('切换流量') {
steps {
script {
sh "${SSH_CMD} 'docker exec ${CONTAINER_PREFIX}-nginx sed -i \"s/proxy_pass http:\\/\\/\\(blue\\|green\\):8081;/proxy_pass http:\\/\\/${env.DEPLOY_TARGET}:8081;/\" /etc/nginx/nginx.conf'"
sh "${SSH_CMD} 'docker exec ${CONTAINER_PREFIX}-nginx nginx -s reload'"
echo "✅ 流量已切换到 ${env.DEPLOY_TARGET}"
}
}
}
stage('删除旧版本') {
steps {
script {
def otherExists = sh(script: "${SSH_CMD} 'docker ps -aq -f name=${CONTAINER_PREFIX}-${env.OTHER_TARGET}'", returnStdout: true).trim()
if (otherExists) {
sh "${SSH_CMD} 'docker rm -f ${CONTAINER_PREFIX}-${env.OTHER_TARGET}'"
echo "旧版本 ${env.OTHER_TARGET} 已删除"
}
}
}
}
stage('清理') {
steps {
sh "${SSH_CMD} 'rm -f ${REMOTE_DIR}/${IMAGE_NAME}.tar'"
sh "rm -f ${IMAGE_NAME}.tar"
}
}
}
post {
success {
echo "✅ 蓝绿部署成功!当前运行: ${env.DEPLOY_TARGET}"
}
failure {
echo '❌ 部署失败,请检查日志'
sh "rm -f ${IMAGE_NAME}.tar || true"
}
}
}
+210
View File
@@ -0,0 +1,210 @@
/**
* OfferPie Backend Admin 蓝绿部署流水线(测试环境)
*
* 架构:Jenkins 本地编译 → scp 镜像到目标机 → SSH 远程蓝绿切换
* 目标机目录:/opt/offerpie/admin/
*
* 与生产差异:
* - 部署目标为测试服务器
* - 默认分支 test
* - 镜像 tag = test(与生产 latest 隔离,避免同一 Jenkins 并发构建串包)
* - tar 文件名带 tag(双保险)
* - 运行时 PROFILES_ACTIVE=test(在 docker-compose.test.admin.yml 中设置)
*/
pipeline {
agent any
parameters {
choice(name: 'BRANCH', choices: ['test', 'dev', 'pre', 'master'], description: '选择要部署的分支')
}
environment {
// 目标服务器配置(测试)
DEPLOY_HOST = '8.163.131.234'
DEPLOY_PORT = '22'
DEPLOY_USER = 'root'
DEPLOY_PASS = 'Mzpy520@126.com'
// 项目配置
IMAGE_NAME = 'offerpie-backend-admin'
IMAGE_TAG = 'test'
IMAGE_TAR = 'offerpie-backend-admin-test.tar'
CONTAINER_PREFIX = 'offerpie-backend-admin'
REMOTE_DIR = '/opt/offerpie/admin'
HEALTH_URL = 'http://localhost:8081/admin/public/actuator/health'
// SSH 命令前缀
SSH_CMD = "sshpass -p '${DEPLOY_PASS}' ssh -o StrictHostKeyChecking=no -p ${DEPLOY_PORT} ${DEPLOY_USER}@${DEPLOY_HOST}"
SCP_CMD = "sshpass -p '${DEPLOY_PASS}' scp -o StrictHostKeyChecking=no -P ${DEPLOY_PORT}"
}
stages {
stage('环境检查') {
steps {
sh 'sshpass -V'
}
}
stage('拉取代码') {
steps {
echo "拉取 ${params.BRANCH} 分支代码"
git branch: "${params.BRANCH}",
credentialsId: 'gitea-fab089c1-b55d-4b58-9fad',
url: 'http://git.jianshixingqiu.com/offerpai/offerpai_backend.git'
}
}
stage('本地编译') {
steps {
echo "开始构建镜像"
sh "docker build -f admin/Dockerfile -t ${IMAGE_NAME}:${IMAGE_TAG} ."
echo "导出镜像"
sh "docker save -o ${IMAGE_TAR} ${IMAGE_NAME}:${IMAGE_TAG}"
}
}
stage('文件传输') {
steps {
echo "传输文件到目标服务器"
sh "${SSH_CMD} 'mkdir -p ${REMOTE_DIR}'"
sh "${SCP_CMD} ${IMAGE_TAR} ${DEPLOY_USER}@${DEPLOY_HOST}:${REMOTE_DIR}/"
sh "${SCP_CMD} admin/nginx.conf ${DEPLOY_USER}@${DEPLOY_HOST}:${REMOTE_DIR}/nginx.conf"
sh "${SCP_CMD} docker-compose.test.admin.yml ${DEPLOY_USER}@${DEPLOY_HOST}:${REMOTE_DIR}/docker-compose.yml"
}
}
stage('加载镜像') {
steps {
sh "${SSH_CMD} 'docker load < ${REMOTE_DIR}/${IMAGE_TAR}'"
}
}
stage('检测部署目标') {
steps {
script {
def blueRunning = sh(script: "${SSH_CMD} 'docker ps -q -f name=${CONTAINER_PREFIX}-blue'", returnStdout: true).trim()
def greenRunning = sh(script: "${SSH_CMD} 'docker ps -q -f name=${CONTAINER_PREFIX}-green'", returnStdout: true).trim()
env.DEPLOY_TARGET = ''
if (blueRunning && !greenRunning) {
env.DEPLOY_TARGET = 'green'
}
if (greenRunning && !blueRunning) {
env.DEPLOY_TARGET = 'blue'
}
if (!env.DEPLOY_TARGET) {
echo "当前环境未部署服务或状态异常,默认部署 blue"
env.DEPLOY_TARGET = 'blue'
}
env.OTHER_TARGET = (env.DEPLOY_TARGET == 'blue') ? 'green' : 'blue'
echo "当前激活: ${env.OTHER_TARGET},即将部署: ${env.DEPLOY_TARGET}"
}
}
}
stage('启动新版本') {
steps {
script {
def existingContainer = sh(script: "${SSH_CMD} 'docker ps -aq -f name=${CONTAINER_PREFIX}-${env.DEPLOY_TARGET}'", returnStdout: true).trim()
if (existingContainer) {
sh "${SSH_CMD} 'docker rm -f ${CONTAINER_PREFIX}-${env.DEPLOY_TARGET}'"
}
sh "${SSH_CMD} 'cd ${REMOTE_DIR} && docker compose up -d ${env.DEPLOY_TARGET}'"
sh 'sleep 70'
}
}
}
stage('检查Nginx') {
steps {
script {
def nginxExists = sh(script: "${SSH_CMD} 'docker ps -aq -f name=${CONTAINER_PREFIX}-nginx'", returnStdout: true).trim()
if (!nginxExists) {
echo "首次部署,初始化 Nginx 容器"
sh "${SSH_CMD} 'cd ${REMOTE_DIR} && docker compose up -d nginx'"
sh 'sleep 3'
} else {
def nginxRunning = sh(script: "${SSH_CMD} 'docker ps -q -f name=${CONTAINER_PREFIX}-nginx'", returnStdout: true).trim()
if (!nginxRunning) {
echo "Nginx 容器已停止,重新启动"
sh "${SSH_CMD} 'docker start ${CONTAINER_PREFIX}-nginx'"
sh 'sleep 2'
}
echo "Nginx 容器已存在且运行中"
}
// docker cp nginx.conf 进容器(覆盖更新配置模板)
sh "${SSH_CMD} 'docker cp ${REMOTE_DIR}/nginx.conf ${CONTAINER_PREFIX}-nginx:/etc/nginx/nginx.conf'"
}
}
}
stage('健康检查') {
steps {
script {
def maxRetries = 3
def retryCount = 0
def healthy = false
while (retryCount < maxRetries && !healthy) {
try {
sh "${SSH_CMD} 'docker exec ${CONTAINER_PREFIX}-${env.DEPLOY_TARGET} curl -f ${HEALTH_URL}'"
healthy = true
} catch (Exception e) {
retryCount++
if (retryCount < maxRetries) {
echo "健康检查失败,5秒后重试 (${retryCount}/${maxRetries})"
sleep 5
}
}
}
if (!healthy) {
error "健康检查失败,部署中止"
}
echo "✅ ${CONTAINER_PREFIX}-${env.DEPLOY_TARGET} 健康检查通过"
}
}
}
stage('切换流量') {
steps {
script {
sh "${SSH_CMD} 'docker exec ${CONTAINER_PREFIX}-nginx sed -i \"s/proxy_pass http:\\/\\/\\(blue\\|green\\):8081;/proxy_pass http:\\/\\/${env.DEPLOY_TARGET}:8081;/\" /etc/nginx/nginx.conf'"
sh "${SSH_CMD} 'docker exec ${CONTAINER_PREFIX}-nginx nginx -s reload'"
echo "✅ 流量已切换到 ${env.DEPLOY_TARGET}"
}
}
}
stage('删除旧版本') {
steps {
script {
def otherExists = sh(script: "${SSH_CMD} 'docker ps -aq -f name=${CONTAINER_PREFIX}-${env.OTHER_TARGET}'", returnStdout: true).trim()
if (otherExists) {
sh "${SSH_CMD} 'docker rm -f ${CONTAINER_PREFIX}-${env.OTHER_TARGET}'"
echo "旧版本 ${env.OTHER_TARGET} 已删除"
}
}
}
}
stage('清理') {
steps {
sh "${SSH_CMD} 'rm -f ${REMOTE_DIR}/${IMAGE_TAR}'"
sh "rm -f ${IMAGE_TAR}"
}
}
}
post {
success {
echo "✅ 蓝绿部署成功!当前运行: ${env.DEPLOY_TARGET}"
}
failure {
echo '❌ 部署失败,请检查日志'
sh "rm -f ${IMAGE_TAR} || true"
}
}
}
+54
View File
@@ -0,0 +1,54 @@
worker_processes auto;
error_log /var/log/nginx/error.log warn;
events {
worker_connections 1024;
use epoll;
multi_accept on;
}
http {
include /etc/nginx/mime.types;
default_type application/octet-stream;
log_format main '$remote_addr - $remote_user [$time_local] "$request" '
'$status $body_bytes_sent "$http_referer" '
'"$http_user_agent" "$http_x_forwarded_for"';
access_log /var/log/nginx/access.log main;
sendfile on;
tcp_nopush on;
tcp_nodelay on;
keepalive_timeout 65;
client_max_body_size 20m;
server {
listen 80;
server_name _;
# Nginx 自身健康检查
location /health {
access_log off;
return 200 'ok';
add_header Content-Type text/plain;
}
# 默认代理到 blue,部署时通过 sed 切换
location / {
proxy_pass http://blue:8081;
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
proxy_set_header X-Forwarded-Proto $scheme;
proxy_connect_timeout 300s;
proxy_send_timeout 300s;
proxy_read_timeout 300s;
proxy_buffer_size 128k;
proxy_buffers 4 256k;
proxy_busy_buffers_size 256k;
}
}
}
+54
View File
@@ -0,0 +1,54 @@
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.jiayunet</groupId>
<artifactId>back_end</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<artifactId>admin</artifactId>
<version>1.0-SNAPSHOT</version>
<dependencies>
<dependency>
<groupId>org.jiayunet</groupId>
<artifactId>manager</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>
</dependencies>
<build>
<finalName>admin</finalName>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>17</source>
<target>17</target>
</configuration>
</plugin>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>2.6.13</version>
<configuration>
<fork>true</fork>
</configuration>
<executions>
<execution>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
@@ -0,0 +1,22 @@
package org.jiayunet;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.scheduling.annotation.EnableScheduling;
/**
* B 端管理后台启动类
*
* @author zk
*/
@SpringBootApplication(scanBasePackages = "org.jiayunet")
@MapperScan("org.jiayunet.**.mapper")
@EnableScheduling
@EnableAspectJAutoProxy
public class AdminApplication {
public static void main(String[] args) {
SpringApplication.run(AdminApplication.class, args);
}
}
@@ -0,0 +1,18 @@
package org.jiayunet.admin.constant;
/**
* B 端管理后台 Redis Key 常量
*
* @author zk
*/
public interface AdminRedisKeyName {
/** 管理员登录 token 前缀,完整 key: admin:login:token:{adminId} */
String LOGIN_TOKEN = "login:token:";
/** 登录失败次数计数,完整 key: admin:login:fail:{username} */
String LOGIN_FAIL_COUNT = "login:fail:";
/** 账号锁定标记,完整 key: admin:login:lock:{username} */
String LOGIN_LOCK = "login:lock:";
}
@@ -0,0 +1,29 @@
package org.jiayunet.admin.controller;
import lombok.AllArgsConstructor;
import org.jiayunet.admin.pojo.param.login.AdminLoginParam;
import org.jiayunet.admin.service.AdminLoginService;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
/**
* 管理员登录控制类
*
* @author zk
*/
@RestController
@RequestMapping("/public")
@AllArgsConstructor
@Validated
public class AdminLoginController {
private AdminLoginService adminLoginService;
@PostMapping("/login")
public Long login(@Validated @RequestBody AdminLoginParam param, HttpServletRequest request, HttpServletResponse response) {
return adminLoginService.login(param.getUsername(), param.getPassword(), request, response);
}
}
@@ -0,0 +1,36 @@
package org.jiayunet.admin.controller;
import lombok.AllArgsConstructor;
import org.jiayunet.admin.pojo.dto.order.OrderListDto;
import org.jiayunet.admin.pojo.dto.order.OrderStatsDto;
import org.jiayunet.admin.pojo.param.order.OrderPageParam;
import org.jiayunet.admin.service.AdminOrderService;
import org.jiayunet.pojo.PageResult;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
/**
* 管理后台-订单管理控制类
*
* @author zk
*/
@RestController
@RequestMapping("/order")
@AllArgsConstructor
@Validated
public class AdminOrderController {
private AdminOrderService adminOrderService;
/** 订单分页列表 */
@PostMapping("/list")
public PageResult<OrderListDto> list(@Validated @RequestBody OrderPageParam param) {
return adminOrderService.pageList(param);
}
/** 订单统计 */
@GetMapping("/stats")
public OrderStatsDto stats() {
return adminOrderService.stats();
}
}
@@ -0,0 +1,48 @@
package org.jiayunet.admin.controller;
import lombok.AllArgsConstructor;
import org.jiayunet.admin.pojo.param.product.ProductPageParam;
import org.jiayunet.admin.pojo.param.product.ProductSaveParam;
import org.jiayunet.admin.service.AdminProductService;
import org.jiayunet.pojo.PageResult;
import org.jiayunet.pojo.po.MemberProduct;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
/**
* 管理后台-商品管理控制类
*
* @author zk
*/
@RestController
@RequestMapping("/product")
@AllArgsConstructor
@Validated
public class AdminProductController {
private AdminProductService adminProductService;
/** 商品分页列表 */
@PostMapping("/list")
public PageResult<MemberProduct> list(@Validated @RequestBody ProductPageParam param) {
return adminProductService.pageList(param);
}
/** 新增/编辑商品 */
@PostMapping("/save")
public void save(@Validated @RequestBody ProductSaveParam param) {
adminProductService.save(param);
}
/** 上架/下架 */
@PostMapping("/updateStatus")
public void updateStatus(@RequestParam Long id, @RequestParam Integer status) {
adminProductService.updateStatus(id, status);
}
/** 删除商品 */
@PostMapping("/delete")
public void delete(@RequestParam Long id) {
adminProductService.delete(id);
}
}
@@ -0,0 +1,42 @@
package org.jiayunet.admin.controller;
import lombok.AllArgsConstructor;
import org.jiayunet.admin.pojo.dto.user.UserListDto;
import org.jiayunet.admin.pojo.dto.user.UserStatsDto;
import org.jiayunet.admin.pojo.param.user.UserPageParam;
import org.jiayunet.admin.service.AdminUserService;
import org.jiayunet.pojo.PageResult;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
/**
* 管理后台-用户管理控制类
*
* @author zk
*/
@RestController
@RequestMapping("/user")
@AllArgsConstructor
@Validated
public class AdminUserController {
private AdminUserService adminUserService;
/** 用户分页列表 */
@PostMapping("/list")
public PageResult<UserListDto> list(@Validated @RequestBody UserPageParam param) {
return adminUserService.pageList(param);
}
/** 用户统计(总数/今日/本周/本月) */
@GetMapping("/stats")
public UserStatsDto stats() {
return adminUserService.stats();
}
/** 禁用/启用用户 */
@PostMapping("/updateStatus")
public void updateStatus(@RequestParam Long userId, @RequestParam Integer status) {
adminUserService.updateStatus(userId, status);
}
}
@@ -0,0 +1,27 @@
package org.jiayunet.admin.controller;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
/**
* 页面路由控制器(返回 Thymeleaf 视图名,不走 UnifiedResponseBodyAdvice
*
* @author zk
*/
@Controller
@RequestMapping("/page")
public class PageController {
/** 登录页 */
@GetMapping("/login")
public String login() {
return "login";
}
/** 管理后台首页(需登录) */
@GetMapping("/index")
public String index() {
return "index";
}
}
@@ -0,0 +1,35 @@
package org.jiayunet.admin.pojo.dto.order;
import lombok.Data;
import java.time.Instant;
/**
* 订单列表出参
*
* @author zk
*/
@Data
public class OrderListDto {
/** 订单ID */
private Long id;
/** 订单编号 */
private String orderNo;
/** 用户昵称 */
private String userNick;
/** 用户手机号 */
private String mobileNumber;
/** 商品名称 */
private String productName;
/** 实付金额(分) */
private Integer payAmount;
/** 支付渠道 1=微信 2=支付宝 */
private Integer payChannel;
/** 订单状态 0=待支付 1=已支付 2=已退款 3=已关闭 */
private Integer status;
/** 下单时间 */
private Instant createTime;
/** 支付时间 */
private Instant payTime;
}
@@ -0,0 +1,29 @@
package org.jiayunet.admin.pojo.dto.order;
import lombok.Data;
/**
* 订单统计出参
*
* @author zk
*/
@Data
public class OrderStatsDto {
/** 总订单数 */
private Long totalCount;
/** 已支付订单数 */
private Long paidCount;
/** 今日已支付 */
private Long todayPaid;
/** 本周已支付 */
private Long weekPaid;
/** 本月已支付 */
private Long monthPaid;
/** 今日收入(分) */
private Long todayIncome;
/** 本周收入(分) */
private Long weekIncome;
/** 本月收入(分) */
private Long monthIncome;
}
@@ -0,0 +1,29 @@
package org.jiayunet.admin.pojo.dto.user;
import lombok.Data;
import java.time.Instant;
/**
* 用户列表出参
*
* @author zk
*/
@Data
public class UserListDto {
/** 用户ID */
private Long id;
/** 昵称 */
private String nick;
/** 真实姓名 */
private String realName;
/** 手机号 */
private String mobileNumber;
/** 状态 0=正常 1=禁用 */
private Integer status;
/** 简历数量 */
private Integer resumeCount;
/** 注册时间 */
private Instant createTime;
}
@@ -0,0 +1,21 @@
package org.jiayunet.admin.pojo.dto.user;
import lombok.Data;
/**
* 用户统计出参
*
* @author zk
*/
@Data
public class UserStatsDto {
/** 用户总数 */
private Long total;
/** 今日新增 */
private Long today;
/** 本周新增 */
private Long thisWeek;
/** 本月新增 */
private Long thisMonth;
}
@@ -0,0 +1,23 @@
package org.jiayunet.admin.pojo.param.login;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.Size;
/**
* 管理员登录入参
*
* @author zk
*/
@Data
public class AdminLoginParam {
@NotBlank(message = "账号不能为空")
@Size(max = 32, message = "账号长度不能超过32位")
private String username;
@NotBlank(message = "密码不能为空")
@Size(min = 6, max = 32, message = "密码长度6-32位")
private String password;
}
@@ -0,0 +1,28 @@
package org.jiayunet.admin.pojo.param.order;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.jiayunet.pojo.PageParam;
import java.time.Instant;
/**
* 订单分页查询入参
*
* @author zk
*/
@Data
@EqualsAndHashCode(callSuper = true)
public class OrderPageParam extends PageParam {
/** 订单状态 0=待支付 1=已支付 2=已退款 3=已关闭 */
private Integer status;
/** 支付渠道 1=微信 2=支付宝 */
private Integer payChannel;
/** 用户手机号(模糊) */
private String mobileNumber;
/** 下单时间-起 */
private Instant startTime;
/** 下单时间-止 */
private Instant endTime;
}
@@ -0,0 +1,18 @@
package org.jiayunet.admin.pojo.param.product;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.jiayunet.pojo.PageParam;
/**
* 商品分页查询入参
*
* @author zk
*/
@Data
@EqualsAndHashCode(callSuper = true)
public class ProductPageParam extends PageParam {
/** 状态筛选 0=下架 1=上架 */
private Integer status;
}
@@ -0,0 +1,51 @@
package org.jiayunet.admin.pojo.param.product;
import lombok.Data;
import javax.validation.constraints.Min;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
/**
* 商品新增/编辑入参
*
* @author zk
*/
@Data
public class ProductSaveParam {
/** 商品ID(编辑时必传,新增时不传) */
private Long id;
@NotBlank(message = "商品名称不能为空")
private String productName;
/** 标签,如"限时优惠" */
private String tag;
/** 主推标识 0=否 1=是 */
private Integer isFeatured;
/** 购买按钮文字 */
private String buyButtonText;
@NotNull(message = "价格不能为空")
@Min(value = 1, message = "价格必须大于0")
private Integer price;
/** 划线价(分) */
private Integer originalPrice;
/** 折算月价(分) */
private Integer monthlyPrice;
@NotNull(message = "有效天数不能为空")
@Min(value = 1, message = "有效天数必须大于0")
private Integer durationDays;
/** 排序 */
private Integer sortOrder;
/** 状态 0=下架 1=上架 */
private Integer status;
}
@@ -0,0 +1,21 @@
package org.jiayunet.admin.pojo.param.user;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.jiayunet.pojo.PageParam;
/**
* 用户分页查询入参
*
* @author zk
*/
@Data
@EqualsAndHashCode(callSuper = true)
public class UserPageParam extends PageParam {
/** 手机号(模糊搜索) */
private String mobileNumber;
/** 状态筛选 0=正常 1=禁用 */
private Integer status;
}
@@ -0,0 +1,156 @@
package org.jiayunet.admin.service;
import com.auth0.jwt.JWT;
import com.auth0.jwt.algorithms.Algorithm;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import lombok.extern.slf4j.Slf4j;
import org.jiayunet.admin.constant.AdminRedisKeyName;
import org.jiayunet.mapper.AdminUserMapper;
import org.jiayunet.pojo.login.RedisLoginTokenInfo;
import org.jiayunet.pojo.po.AdminUser;
import org.jiayunet.tool.HttpIpTool;
import org.jiayunet.tool.server.RedisServerTool;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.util.Assert;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.time.Instant;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
/**
* 管理员登录服务
* <p>依赖:AdminUserMapper(管理员查询)、RedisServerTooltoken管理与登录失败计数)</p>
* <p>使用表:bg_admin_user(查询管理员账号)</p>
* <p>使用Redislogin:token:{adminId}(登录令牌)、login:fail:{username}(失败计数)、login:lock:{username}(账号锁定)</p>
*
* @author zk
*/
@Service
@Slf4j
public class AdminLoginService {
/** 密码错误允许最大次数 */
private static final int MAX_FAIL_COUNT = 3;
/** 账号锁定时长(小时) */
private static final int LOCK_HOURS = 24;
@Value("${app.secret.token:youweiqingnian123}")
private String secret;
@Value("${app.login.token.exceed_time:43200}")
private int tokenExceedTime;
@Value("${app.login.device_online_quantity:5}")
private int deviceOnlineQuantity;
@Autowired
private AdminUserMapper adminUserMapper;
@Autowired
private RedisServerTool redisServerTool;
/**
* 账号密码登录
* <p>1. 校验账号锁定状态 2. 查询管理员 3. 校验密码(失败累计,3次锁定24小时) 4. 生成JWT 5. 写入Redis管理多设备 6. 设置Cookie</p>
*/
public Long login(String username, String password, HttpServletRequest request, HttpServletResponse response) {
Assert.hasText(username, "账号不能为空");
Assert.hasText(password, "密码不能为空");
// 检查账号是否被锁定
Assert.isTrue(!redisServerTool.hasKey(AdminRedisKeyName.LOGIN_LOCK + username), "账号已被锁定,请24小时后再试");
// 查询管理员
AdminUser admin = adminUserMapper.selectOne(new LambdaQueryWrapper<AdminUser>().eq(AdminUser::getUsername, username).eq(AdminUser::getStatus, 0));
Assert.notNull(admin, "账号或密码错误");
// 校验密码:MD5(明文 + salt)
if (!md5(password + secret).equals(admin.getPassword())) {
handleLoginFail(username);
throw new IllegalArgumentException("账号或密码错误");
}
// 登录成功,清除失败计数
clearLoginFail(username);
// 生成JWT
String uuId = UUID.randomUUID().toString().replace("-", "");
String token = JWT.create().withClaim("userId", admin.getId()).withClaim("uuId", uuId).sign(Algorithm.HMAC256(secret));
// 构建Redis登录信息
String redisKey = AdminRedisKeyName.LOGIN_TOKEN + admin.getId();
RedisLoginTokenInfo info = redisServerTool.get(redisKey, RedisLoginTokenInfo.class);
if (info == null) {
info = new RedisLoginTokenInfo();
info.setUserId(admin.getId());
info.setAuthority(new ArrayList<>());
info.setRole(new ArrayList<>());
}
// 过滤过期设备
List<RedisLoginTokenInfo.LoginDevice> devices = info.getLoginDevices() == null ? new ArrayList<>() : info.getLoginDevices();
long expireMillis = System.currentTimeMillis() - tokenExceedTime * 1000L;
devices = devices.stream().filter(d -> d.getLastLoginTime().isAfter(Instant.ofEpochMilli(expireMillis))).collect(Collectors.toList());
// 超过设备上限,移除最早的
while (devices.size() >= deviceOnlineQuantity) {
devices.stream().min(Comparator.comparing(RedisLoginTokenInfo.LoginDevice::getLastLoginTime)).ifPresent(devices::remove);
}
// 添加当前设备
RedisLoginTokenInfo.LoginDevice device = new RedisLoginTokenInfo.LoginDevice();
device.setUuId(uuId);
device.setLastLoginTime(Instant.now());
device.setLoginIp(HttpIpTool.gteRealIP(request));
devices.add(device);
info.setLoginDevices(devices);
redisServerTool.set(redisKey, info, tokenExceedTime, TimeUnit.SECONDS);
// 设置Cookie
Cookie cookie = new Cookie("Token", token);
cookie.setHttpOnly(true);
cookie.setPath("/");
cookie.setMaxAge(tokenExceedTime);
response.addCookie(cookie);
return admin.getId();
}
/** 处理登录失败:累计失败次数,达到上限则锁定账号24小时 */
private void handleLoginFail(String username) {
String failKey = AdminRedisKeyName.LOGIN_FAIL_COUNT + username;
Integer failCount = redisServerTool.get(failKey, Integer.class);
int currentCount = (failCount == null ? 0 : failCount) + 1;
if (currentCount >= MAX_FAIL_COUNT) {
redisServerTool.set(AdminRedisKeyName.LOGIN_LOCK + username, true, LOCK_HOURS, TimeUnit.HOURS);
redisServerTool.delete(failKey);
log.warn("管理员账号 [{}] 密码错误{}次,已锁定{}小时", username, MAX_FAIL_COUNT, LOCK_HOURS);
} else {
redisServerTool.set(failKey, currentCount, LOCK_HOURS, TimeUnit.HOURS);
}
}
/** 登录成功后清除失败计数 */
private void clearLoginFail(String username) {
redisServerTool.delete(AdminRedisKeyName.LOGIN_FAIL_COUNT + username);
}
/** MD5 加密 */
private String md5(String input) {
try {
java.security.MessageDigest md = java.security.MessageDigest.getInstance("MD5");
byte[] digest = md.digest(input.getBytes(java.nio.charset.StandardCharsets.UTF_8));
StringBuilder sb = new StringBuilder();
for (byte b : digest) { sb.append(String.format("%02x", b)); }
return sb.toString();
} catch (java.security.NoSuchAlgorithmException e) {
throw new RuntimeException(e);
}
}
}
@@ -0,0 +1,119 @@
package org.jiayunet.admin.service;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.extern.slf4j.Slf4j;
import org.jiayunet.admin.pojo.dto.order.OrderListDto;
import org.jiayunet.admin.pojo.dto.order.OrderStatsDto;
import org.jiayunet.admin.pojo.param.order.OrderPageParam;
import org.jiayunet.mapper.MemberOrderMapper;
import org.jiayunet.mapper.MemberProductMapper;
import org.jiayunet.mapper.UserMapper;
import org.jiayunet.pojo.PageResult;
import org.jiayunet.pojo.po.MemberOrder;
import org.jiayunet.pojo.po.MemberProduct;
import org.jiayunet.pojo.po.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.time.*;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
/**
* 管理后台-订单管理服务
* <p>依赖:MemberOrderMapper、UserMapper、MemberProductMapper</p>
* <p>使用表:bg_member_order(订单列表/统计)、bg_user(关联用户信息)、bg_member_product(关联商品名)</p>
*
* @author zk
*/
@Service
@Slf4j
public class AdminOrderService {
@Autowired
private MemberOrderMapper memberOrderMapper;
@Autowired
private UserMapper userMapper;
@Autowired
private MemberProductMapper memberProductMapper;
/**
* 订单分页列表
* <p>1. 如果按手机号筛选,先查用户ID集合 2. 分页查订单 3. 批量关联用户和商品信息 4. 组装DTO</p>
*/
public PageResult<OrderListDto> pageList(OrderPageParam param) {
// 如果传了手机号,先查对应用户ID
Set<Long> userIdFilter = null;
if (StringUtils.hasText(param.getMobileNumber())) {
List<User> users = userMapper.selectList(new LambdaQueryWrapper<User>().like(User::getMobileNumber, param.getMobileNumber()).select(User::getId));
userIdFilter = users.stream().map(User::getId).collect(Collectors.toSet());
if (userIdFilter.isEmpty()) return new PageResult<>(param.getPageNum().longValue(), param.getPageSize().longValue(), 0L, List.of());
}
LambdaQueryWrapper<MemberOrder> wrapper = new LambdaQueryWrapper<MemberOrder>()
.eq(param.getStatus() != null, MemberOrder::getStatus, param.getStatus())
.eq(param.getPayChannel() != null, MemberOrder::getPayChannel, param.getPayChannel())
.ge(param.getStartTime() != null, MemberOrder::getCreateTime, param.getStartTime())
.le(param.getEndTime() != null, MemberOrder::getCreateTime, param.getEndTime())
.in(userIdFilter != null, MemberOrder::getUserId, userIdFilter)
.orderByDesc(MemberOrder::getCreateTime);
Page<MemberOrder> page = memberOrderMapper.selectPage(param.toPage(), wrapper);
if (page.getRecords().isEmpty()) return PageResult.from((Page<OrderListDto>) page.convert(o -> new OrderListDto()));
// 批量查用户和商品
Set<Long> userIds = page.getRecords().stream().map(MemberOrder::getUserId).collect(Collectors.toSet());
Set<Long> productIds = page.getRecords().stream().map(MemberOrder::getProductId).collect(Collectors.toSet());
Map<Long, User> userMap = userMapper.selectBatchIds(userIds).stream().collect(Collectors.toMap(User::getId, u -> u));
Map<Long, MemberProduct> productMap = memberProductMapper.selectBatchIds(productIds).stream().collect(Collectors.toMap(MemberProduct::getId, p -> p));
Page<OrderListDto> dtoPage = (Page<OrderListDto>) page.convert(order -> {
OrderListDto dto = new OrderListDto();
dto.setId(order.getId());
dto.setOrderNo(order.getOrderNo());
dto.setPayAmount(order.getPayAmount());
dto.setPayChannel(order.getPayChannel());
dto.setStatus(order.getStatus());
dto.setCreateTime(order.getCreateTime());
dto.setPayTime(order.getPayTime());
User user = userMap.get(order.getUserId());
if (user != null) { dto.setUserNick(user.getNick()); dto.setMobileNumber(user.getMobileNumber()); }
MemberProduct product = productMap.get(order.getProductId());
if (product != null) { dto.setProductName(product.getProductName()); }
return dto;
});
return PageResult.from(dtoPage);
}
/**
* 订单统计:总数/已支付数/今日本周本月已支付数和收入
*/
public OrderStatsDto stats() {
OrderStatsDto dto = new OrderStatsDto();
ZoneId zone = ZoneId.of("Asia/Shanghai");
LocalDate now = LocalDate.now(zone);
Instant todayStart = now.atStartOfDay(zone).toInstant();
Instant weekStart = now.with(DayOfWeek.MONDAY).atStartOfDay(zone).toInstant();
Instant monthStart = now.withDayOfMonth(1).atStartOfDay(zone).toInstant();
dto.setTotalCount(memberOrderMapper.selectCount(new LambdaQueryWrapper<MemberOrder>()));
dto.setPaidCount(memberOrderMapper.selectCount(new LambdaQueryWrapper<MemberOrder>().eq(MemberOrder::getStatus, 1)));
// 今日/本周/本月已支付订单
List<MemberOrder> todayOrders = memberOrderMapper.selectList(new LambdaQueryWrapper<MemberOrder>().eq(MemberOrder::getStatus, 1).ge(MemberOrder::getPayTime, todayStart));
List<MemberOrder> weekOrders = memberOrderMapper.selectList(new LambdaQueryWrapper<MemberOrder>().eq(MemberOrder::getStatus, 1).ge(MemberOrder::getPayTime, weekStart));
List<MemberOrder> monthOrders = memberOrderMapper.selectList(new LambdaQueryWrapper<MemberOrder>().eq(MemberOrder::getStatus, 1).ge(MemberOrder::getPayTime, monthStart));
dto.setTodayPaid((long) todayOrders.size());
dto.setWeekPaid((long) weekOrders.size());
dto.setMonthPaid((long) monthOrders.size());
dto.setTodayIncome(todayOrders.stream().mapToLong(o -> o.getPayAmount() == null ? 0 : o.getPayAmount()).sum());
dto.setWeekIncome(weekOrders.stream().mapToLong(o -> o.getPayAmount() == null ? 0 : o.getPayAmount()).sum());
dto.setMonthIncome(monthOrders.stream().mapToLong(o -> o.getPayAmount() == null ? 0 : o.getPayAmount()).sum());
return dto;
}
}
@@ -0,0 +1,67 @@
package org.jiayunet.admin.service;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.extern.slf4j.Slf4j;
import org.jiayunet.admin.pojo.param.product.ProductPageParam;
import org.jiayunet.admin.pojo.param.product.ProductSaveParam;
import org.jiayunet.mapper.MemberProductMapper;
import org.jiayunet.pojo.PageResult;
import org.jiayunet.pojo.po.MemberProduct;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.Assert;
/**
* 管理后台-商品管理服务
* <p>依赖:MemberProductMapper</p>
* <p>使用表:bg_member_productCRUD</p>
*
* @author zk
*/
@Service
@Slf4j
public class AdminProductService {
@Autowired
private MemberProductMapper memberProductMapper;
/** 商品分页列表 */
public PageResult<MemberProduct> pageList(ProductPageParam param) {
LambdaQueryWrapper<MemberProduct> wrapper = new LambdaQueryWrapper<MemberProduct>()
.eq(param.getStatus() != null, MemberProduct::getStatus, param.getStatus())
.orderByAsc(MemberProduct::getSortOrder);
Page<MemberProduct> page = memberProductMapper.selectPage(param.toPage(), wrapper);
return PageResult.from(page);
}
/** 新增/编辑商品 */
public void save(ProductSaveParam param) {
MemberProduct product = new MemberProduct();
BeanUtils.copyProperties(param, product);
if (param.getId() == null) {
if (product.getStatus() == null) product.setStatus(0);
if (product.getSortOrder() == null) product.setSortOrder(0);
if (product.getIsFeatured() == null) product.setIsFeatured(0);
memberProductMapper.insert(product);
} else {
product.setId(param.getId());
memberProductMapper.updateById(product);
}
}
/** 上架/下架商品 */
public void updateStatus(Long id, Integer status) {
Assert.notNull(id, "商品ID不能为空");
Assert.isTrue(status == 0 || status == 1, "状态值非法");
memberProductMapper.update(null, new LambdaUpdateWrapper<MemberProduct>().eq(MemberProduct::getId, id).set(MemberProduct::getStatus, status));
}
/** 删除商品(逻辑删除) */
public void delete(Long id) {
Assert.notNull(id, "商品ID不能为空");
memberProductMapper.deleteById(id);
}
}
@@ -0,0 +1,102 @@
package org.jiayunet.admin.service;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.extern.slf4j.Slf4j;
import org.jiayunet.admin.pojo.dto.user.UserListDto;
import org.jiayunet.admin.pojo.dto.user.UserStatsDto;
import org.jiayunet.admin.pojo.param.user.UserPageParam;
import org.jiayunet.mapper.UserMapper;
import org.jiayunet.mapper.UserResumeMapper;
import org.jiayunet.pojo.PageResult;
import org.jiayunet.pojo.po.User;
import org.jiayunet.pojo.po.UserResume;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.Assert;
import org.springframework.util.StringUtils;
import java.time.*;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* 管理后台-用户管理服务
* <p>依赖:UserMapper(用户查询/更新)、UserResumeMapper(简历数量统计)</p>
* <p>使用表:bg_user(用户列表/统计/禁用)、bg_user_resume(简历数量)</p>
*
* @author zk
*/
@Service
@Slf4j
public class AdminUserService {
@Autowired
private UserMapper userMapper;
@Autowired
private UserResumeMapper userResumeMapper;
/**
* 用户分页列表
* <p>1. 分页查询用户 2. 批量查询每个用户的简历数量 3. 组装返回</p>
*/
public PageResult<UserListDto> pageList(UserPageParam param) {
LambdaQueryWrapper<User> wrapper = new LambdaQueryWrapper<User>()
.like(StringUtils.hasText(param.getMobileNumber()), User::getMobileNumber, param.getMobileNumber())
.like(StringUtils.hasText(param.getKeyword()), User::getNick, param.getKeyword())
.eq(param.getStatus() != null, User::getStatus, param.getStatus())
.orderByDesc(User::getCreateTime);
Page<User> page = userMapper.selectPage(param.toPage(), wrapper);
if (page.getRecords().isEmpty()) return PageResult.from((Page<UserListDto>) page.convert(u -> new UserListDto()));
// 批量查询简历数量
List<Long> userIds = page.getRecords().stream().map(User::getId).collect(Collectors.toList());
List<UserResume> resumes = userResumeMapper.selectList(new LambdaQueryWrapper<UserResume>().in(UserResume::getUserId, userIds).select(UserResume::getUserId));
Map<Long, Long> resumeCountMap = resumes.stream().collect(Collectors.groupingBy(UserResume::getUserId, Collectors.counting()));
// 组装DTO
Page<UserListDto> dtoPage = (Page<UserListDto>) page.convert(user -> {
UserListDto dto = new UserListDto();
dto.setId(user.getId());
dto.setNick(user.getNick());
dto.setRealName(user.getRealName());
dto.setMobileNumber(user.getMobileNumber());
dto.setStatus(user.getStatus());
dto.setResumeCount(resumeCountMap.getOrDefault(user.getId(), 0L).intValue());
dto.setCreateTime(user.getCreateTime());
return dto;
});
return PageResult.from(dtoPage);
}
/**
* 用户统计:总数 / 今日 / 本周 / 本月 新增
*/
public UserStatsDto stats() {
UserStatsDto dto = new UserStatsDto();
ZoneId zone = ZoneId.of("Asia/Shanghai");
LocalDate now = LocalDate.now(zone);
Instant todayStart = now.atStartOfDay(zone).toInstant();
Instant weekStart = now.with(DayOfWeek.MONDAY).atStartOfDay(zone).toInstant();
Instant monthStart = now.withDayOfMonth(1).atStartOfDay(zone).toInstant();
dto.setTotal(userMapper.selectCount(new LambdaQueryWrapper<User>()));
dto.setToday(userMapper.selectCount(new LambdaQueryWrapper<User>().ge(User::getCreateTime, todayStart)));
dto.setThisWeek(userMapper.selectCount(new LambdaQueryWrapper<User>().ge(User::getCreateTime, weekStart)));
dto.setThisMonth(userMapper.selectCount(new LambdaQueryWrapper<User>().ge(User::getCreateTime, monthStart)));
return dto;
}
/**
* 禁用/启用用户
*/
public void updateStatus(Long userId, Integer status) {
Assert.notNull(userId, "用户ID不能为空");
Assert.isTrue(status == 0 || status == 1, "状态值非法");
userMapper.update(null, new LambdaUpdateWrapper<User>().eq(User::getId, userId).set(User::getStatus, status));
}
}
@@ -0,0 +1,67 @@
# tomcat 端口配置
server:
port: 8081
# 数据源配置
spring:
datasource:
url: jdbc:mysql://${MYSQL_HOST:192.168.31.105}:${MYSQL_PORT:3306}/${DB_NAME:offerpie}?useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true
username: ${MYSQL_USERNAME:root}
password: ${MYSQL_PASSWORD:123456}
driver-class-name: com.mysql.cj.jdbc.Driver
redis:
host: ${REDIS_HOST:192.168.31.105}
password: ${REDIS_PASSWORD:123456}
port: ${REDIS_PORT:6379}
timeout: 8s
database: 0
# 开发环境关闭模板缓存,方便调试
thymeleaf:
cache: false
# 电子邮箱
email:
status: close
account: ${EMAIL_ACCOUNT:xxx@163.com}
authorization: ${EMAIL_AUTHORIZATION:123456}
# 微信支付
wx_pay:
status: close
# 支付宝支付
alipay:
status: close
app:
# 加密秘钥配置
secret:
token: ${SECRET_TOKEN:Aa123123}
# 登陆配置
login:
token:
exceed_time: 5184000
device_online_quantity: 3
# 短信
sms:
service_provider: aliyun
aliyun:
access_key_id: LTAI5tJBVUUJhB7yp14UDzVf
access_key_secret: Opf0iO5FKNrdwI63DPhXazW7utAGTj
oss:
service_provider: aliyun
aliyun:
access_key_id: LTAI5tEdLKKQUKhTyUpfH5Mk
access_key_secret: RjUdTrq0V5qA4b3BUElNhXqs3ZLp5k
# 防刷配置
prevent_replay:
if_open: false
interval_time: 20
limit_number: 20
# 开放接口(登录页面 + 静态资源 + 登录接口)
ignore:
urls: "/public/**,/page/**,/static/**,/css/**,/js/**,/img/**,/favicon.ico"
@@ -0,0 +1,64 @@
# tomcat 端口配置
server:
port: 8081
# 数据源配置
spring:
datasource:
url: jdbc:mysql://${MYSQL_HOST:8.163.14.142}:${MYSQL_PORT:30006}/${DB_NAME:offerpie}?useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true
username: ${MYSQL_USERNAME:root}
password: ${MYSQL_PASSWORD:^CgDatabase2020}
driver-class-name: com.mysql.cj.jdbc.Driver
redis:
host: ${REDIS_HOST:8.163.14.142}
password: ${REDIS_PASSWORD:#8kPCdAsser}
port: ${REDIS_PORT:30089}
timeout: 10s
database: 0
# 电子邮箱
email:
status: close
account: ${EMAIL_ACCOUNT:xxx@163.com}
authorization: ${EMAIL_AUTHORIZATION:123456}
# 微信支付
wx_pay:
status: close
# 支付宝支付
alipay:
status: close
app:
# 加密秘钥配置
secret:
token: ${SECRET_TOKEN:Aa123123}
# 登陆配置
login:
token:
exceed_time: 5184000
device_online_quantity: 3
# 短信
sms:
service_provider: aliyun
aliyun:
access_key_id: LTAI5tJBVUUJhB7yp14UDzVf
access_key_secret: Opf0iO5FKNrdwI63DPhXazW7utAGTj
oss:
service_provider: aliyun
aliyun:
access_key_id: LTAI5tEdLKKQUKhTyUpfH5Mk
access_key_secret: RjUdTrq0V5qA4b3BUElNhXqs3ZLp5k
# 防刷配置
prevent_replay:
if_open: false
interval_time: 20
limit_number: 20
# 开放接口
ignore:
urls: "/public/**,/page/**,/static/**,/css/**,/js/**,/img/**,/favicon.ico"
@@ -0,0 +1,64 @@
# tomcat 端口配置
server:
port: 8081
# 数据源配置
spring:
datasource:
url: jdbc:mysql://${MYSQL_HOST:8.163.14.142}:${MYSQL_PORT:30006}/${DB_NAME:offerpie_test}?useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true
username: ${MYSQL_USERNAME:root}
password: ${MYSQL_PASSWORD:^CgDatabase2020}
driver-class-name: com.mysql.cj.jdbc.Driver
redis:
host: ${REDIS_HOST:8.163.14.142}
password: ${REDIS_PASSWORD:#8kPCdAsser}
port: ${REDIS_PORT:30089}
timeout: 10s
database: 1
# 电子邮箱
email:
status: close
account: ${EMAIL_ACCOUNT:xxx@163.com}
authorization: ${EMAIL_AUTHORIZATION:123456}
# 微信支付
wx_pay:
status: close
# 支付宝支付
alipay:
status: close
app:
# 加密秘钥配置
secret:
token: ${SECRET_TOKEN:Aa123123}
# 登陆配置
login:
token:
exceed_time: 5184000
device_online_quantity: 3
# 短信
sms:
service_provider: aliyun
aliyun:
access_key_id: LTAI5tJBVUUJhB7yp14UDzVf
access_key_secret: Opf0iO5FKNrdwI63DPhXazW7utAGTj
oss:
service_provider: aliyun
aliyun:
access_key_id: LTAI5tEdLKKQUKhTyUpfH5Mk
access_key_secret: RjUdTrq0V5qA4b3BUElNhXqs3ZLp5k
# 防刷配置
prevent_replay:
if_open: false
interval_time: 20
limit_number: 20
# 开放接口
ignore:
urls: "/public/**,/page/**,/static/**,/css/**,/js/**,/img/**,/favicon.ico"
+77
View File
@@ -0,0 +1,77 @@
# tomcat config
server:
tomcat:
accept-count: 100
threads:
max: 200
min-spare: 10
servlet:
context-path: /admin
# spring config
spring:
application:
name: admin
profiles:
active: ${PROFILES_ACTIVE:dev}
datasource:
hikari:
maximum-pool-size: 50
minimum-idle: 20
connection-timeout: 5000
idle-timeout: 300000
max-lifetime: 900000
servlet:
multipart:
max-file-size: 4MB
max-request-size: 20MB
# Thymeleaf 配置
thymeleaf:
prefix: classpath:/templates/
suffix: .html
mode: HTML
encoding: UTF-8
# 开启静态资源映射
web:
resources:
add-mappings: true
static-locations: classpath:/static/
cache:
redis:
cache-null-values: true
key-prefix: "${spring.application.name}:"
time-to-live: 24h
jackson:
default-property-inclusion: non_null
property-naming-strategy: LOWER_CAMEL_CASE
serialization:
fail-on-empty-beans: false
write-date-keys-as-timestamps: true
write-date-timestamps-as-nanoseconds: false
write-dates-as-timestamps: true
deserialization:
fail-on-unknown-properties: false
fail-on-numbers-for-enums: true
read-date-timestamps-as-nanoseconds: false
# mybatis plus config
mybatis-plus:
mapper-locations: classpath*:mapper/**/*.xml
global-config:
db-config:
id-type: assign_id
insert-strategy: not_null
update-strategy: not_null
logic-delete-field: isDelete
logic-delete-value: '1'
logic-not-delete-value: '0'
configuration:
map-underscore-to-camel-case: true
auto-mapping-unknown-column-behavior: warning
cache-enabled: false
call-setters-on-nulls: true
jdbc-type-for-null: 'null'
# 日志
logging:
level:
org:
mybatis: info
Binary file not shown.

After

Width:  |  Height:  |  Size: 9.2 KiB

@@ -0,0 +1,9 @@
/**
* 认证相关 API
*/
const authApi = {
/** 登录 */
login(username, password) {
return request.post('/public/login', { username, password });
}
};
@@ -0,0 +1,13 @@
/**
* 订单管理 API
*/
const orderApi = {
/** 订单分页列表 */
list(params) {
return request.post('/order/list', params);
},
/** 订单统计 */
stats() {
return request.get('/order/stats');
}
};
@@ -0,0 +1,21 @@
/**
* 商品管理 API
*/
const productApi = {
/** 商品分页列表 */
list(params) {
return request.post('/product/list', params);
},
/** 新增/编辑商品 */
save(data) {
return request.post('/product/save', data);
},
/** 上架/下架 */
updateStatus(id, status) {
return request.post('/product/updateStatus?id=' + id + '&status=' + status);
},
/** 删除商品 */
delete(id) {
return request.post('/product/delete?id=' + id);
}
};
@@ -0,0 +1,17 @@
/**
* 用户管理 API
*/
const userApi = {
/** 用户分页列表 */
list(params) {
return request.post('/user/list', params);
},
/** 用户统计 */
stats() {
return request.get('/user/stats');
},
/** 禁用/启用用户 */
updateStatus(userId, status) {
return request.post('/user/updateStatus?userId=' + userId + '&status=' + status);
}
};
@@ -0,0 +1,60 @@
/**
* 统一请求封装
*/
const request = (() => {
const BASE_URL = '/admin';
/** 从 cookie 中获取 Token */
function getToken() {
const match = document.cookie.match(/(?:^|;\s*)Token=([^;]*)/);
return match ? match[1] : '';
}
/** 统一请求方法 */
async function http(url, options = {}) {
const config = {
headers: { 'Content-Type': 'application/json', 'Token': getToken(), ...options.headers },
...options
};
const response = await fetch(BASE_URL + url, config);
// 401 未登录,跳转登录页
if (response.status === 401) {
window.location.href = BASE_URL + '/page/login';
return Promise.reject('未登录');
}
// 解析响应体
let result;
try { result = await response.json(); } catch (e) {
const msg = 'HTTP ' + response.status + ' 请求失败';
ElementPlus ? ElementPlus.ElMessage.error(msg) : alert(msg);
return Promise.reject(msg);
}
// 业务异常:code 不为 "0" 表示失败
if (result.code !== '0') {
const msg = result.msg || '请求失败';
ElementPlus ? ElementPlus.ElMessage.error(msg) : alert(msg);
return Promise.reject(msg);
}
return result.data;
}
return {
get(url, params) {
const query = params ? '?' + new URLSearchParams(params).toString() : '';
return http(url + query, { method: 'GET' });
},
post(url, data) {
return http(url, { method: 'POST', body: data != null ? JSON.stringify(data) : undefined });
},
put(url, data) {
return http(url, { method: 'PUT', body: JSON.stringify(data) });
},
del(url, data) {
return http(url, { method: 'DELETE', body: data ? JSON.stringify(data) : undefined });
}
};
})();
@@ -0,0 +1,58 @@
const DashboardView = {
template: `
<div>
<h2 style="margin-bottom: 24px; font-size: 18px; font-weight: 600; color: #303133;">数据概览</h2>
<el-row :gutter="20" style="margin-bottom: 24px;">
<el-col :span="6">
<el-card shadow="hover" body-style="padding: 24px;">
<el-statistic title="用户总数" :value="userStats.total"><template #suffix><span style="font-size: 12px; color: #909399;"> 人</span></template></el-statistic>
</el-card>
</el-col>
<el-col :span="6">
<el-card shadow="hover" body-style="padding: 24px;">
<el-statistic title="今日新增" :value="userStats.today"><template #suffix><span style="font-size: 12px; color: #909399;"> 人</span></template></el-statistic>
</el-card>
</el-col>
<el-col :span="6">
<el-card shadow="hover" body-style="padding: 24px;">
<el-statistic title="本月订单" :value="orderStats.monthPaid"><template #suffix><span style="font-size: 12px; color: #909399;"> 笔</span></template></el-statistic>
</el-card>
</el-col>
<el-col :span="6">
<el-card shadow="hover" body-style="padding: 24px;">
<el-statistic title="本月收入" :value="monthIncome"><template #prefix><span style="font-size: 14px;">¥</span></template></el-statistic>
</el-card>
</el-col>
</el-row>
<el-row :gutter="20">
<el-col :span="6">
<el-card shadow="hover" body-style="padding: 24px;"><el-statistic title="本周新增用户" :value="userStats.thisWeek"/></el-card>
</el-col>
<el-col :span="6">
<el-card shadow="hover" body-style="padding: 24px;"><el-statistic title="本月新增用户" :value="userStats.thisMonth"/></el-card>
</el-col>
<el-col :span="6">
<el-card shadow="hover" body-style="padding: 24px;"><el-statistic title="本周订单" :value="orderStats.weekPaid"/></el-card>
</el-col>
<el-col :span="6">
<el-card shadow="hover" body-style="padding: 24px;">
<el-statistic title="本周收入" :value="weekIncome"><template #prefix><span style="font-size: 14px;">¥</span></template></el-statistic>
</el-card>
</el-col>
</el-row>
</div>
`,
setup() {
const { ref, onMounted, computed } = Vue;
const userStats = ref({ total: 0, today: 0, thisWeek: 0, thisMonth: 0 });
const orderStats = ref({ totalCount: 0, paidCount: 0, todayPaid: 0, weekPaid: 0, monthPaid: 0, monthIncome: 0, weekIncome: 0 });
const monthIncome = computed(() => (orderStats.value.monthIncome / 100).toFixed(2));
const weekIncome = computed(() => (orderStats.value.weekIncome / 100).toFixed(2));
const toNum = (obj) => { const r = {}; for (const k in obj) r[k] = Number(obj[k]); return r; };
onMounted(async () => {
try { userStats.value = toNum(await userApi.stats()); } catch(e) {}
try { orderStats.value = toNum(await orderApi.stats()); } catch(e) {}
});
return { userStats, orderStats, monthIncome, weekIncome };
}
};
@@ -0,0 +1,77 @@
const OrderView = {
template: `
<div>
<el-row :gutter="16" style="margin-bottom: 20px;">
<el-col :span="6"><el-card shadow="hover" body-style="padding: 20px;"><el-statistic title="总订单" :value="stats.totalCount"/></el-card></el-col>
<el-col :span="6"><el-card shadow="hover" body-style="padding: 20px;"><el-statistic title="已支付" :value="stats.paidCount"/></el-card></el-col>
<el-col :span="6"><el-card shadow="hover" body-style="padding: 20px;"><el-statistic title="今日支付" :value="stats.todayPaid"/></el-card></el-col>
<el-col :span="6"><el-card shadow="hover" body-style="padding: 20px;"><el-statistic title="今日收入(元)" :value="todayIncome"/></el-card></el-col>
</el-row>
<el-card shadow="never">
<template #header><span style="font-size: 16px; font-weight: 600;">订单管理</span></template>
<el-form :inline="true" style="margin-bottom: 16px;">
<el-form-item label="手机号"><el-input v-model="query.mobileNumber" placeholder="用户手机号" clearable @clear="loadData" style="width: 150px;"/></el-form-item>
<el-form-item label="状态">
<el-select v-model="query.status" placeholder="全部" clearable @change="loadData" style="width: 110px;">
<el-option label="待支付" :value="0"/><el-option label="已支付" :value="1"/><el-option label="已退款" :value="2"/><el-option label="已关闭" :value="3"/>
</el-select>
</el-form-item>
<el-form-item label="渠道">
<el-select v-model="query.payChannel" placeholder="全部" clearable @change="loadData" style="width: 100px;">
<el-option label="微信" :value="1"/><el-option label="支付宝" :value="2"/>
</el-select>
</el-form-item>
<el-form-item><el-button type="primary" @click="loadData">查询</el-button></el-form-item>
</el-form>
<el-table :data="tableData" stripe v-loading="loading" style="width: 100%;">
<el-table-column prop="orderNo" label="订单编号" min-width="150"/>
<el-table-column prop="userNick" label="用户" min-width="100"/>
<el-table-column prop="mobileNumber" label="手机号" min-width="120"/>
<el-table-column prop="productName" label="商品" min-width="120"/>
<el-table-column label="金额(元)" width="100" align="center">
<template #default="{row}">{{(row.payAmount/100).toFixed(2)}}</template>
</el-table-column>
<el-table-column label="渠道" width="80" align="center">
<template #default="{row}"><el-tag size="small" :type="row.payChannel===1?'success':'primary'">{{row.payChannel===1?'微信':'支付宝'}}</el-tag></template>
</el-table-column>
<el-table-column label="状态" width="90" align="center">
<template #default="{row}"><el-tag size="small" :type="statusType(row.status)">{{statusText(row.status)}}</el-tag></template>
</el-table-column>
<el-table-column label="下单时间" min-width="160">
<template #default="{row}">{{formatTime(row.createTime)}}</template>
</el-table-column>
<el-table-column label="支付时间" min-width="160">
<template #default="{row}">{{formatTime(row.payTime)}}</template>
</el-table-column>
</el-table>
<div style="margin-top: 16px; display: flex; justify-content: flex-end;">
<el-pagination background layout="total, prev, pager, next" :total="total" :page-size="query.pageSize" v-model:current-page="query.pageNum" @current-change="loadData"/>
</div>
</el-card>
</div>
`,
setup() {
const { ref, reactive, onMounted, computed } = Vue;
const loading = ref(false);
const tableData = ref([]);
const total = ref(0);
const stats = ref({ totalCount: 0, paidCount: 0, todayPaid: 0, todayIncome: 0 });
const todayIncome = computed(() => (stats.value.todayIncome / 100).toFixed(2));
const query = reactive({ pageNum: 1, pageSize: 10, mobileNumber: '', status: null, payChannel: null });
const loadData = async () => {
loading.value = true;
try { const res = await orderApi.list(query); tableData.value = res.list; total.value = Number(res.total); } catch(e) {}
finally { loading.value = false; }
};
const loadStats = async () => { try { const s = await orderApi.stats(); const r = {}; for (const k in s) r[k] = Number(s[k]); stats.value = r; } catch(e) {} };
const statusText = (s) => ['待支付','已支付','已退款','已关闭'][s] || '-';
const statusType = (s) => ['warning','success','info','danger'][s] || 'info';
const formatTime = (ts) => {
if (!ts) return '-';
const d = new Date(ts);
return d.getFullYear() + '-' + String(d.getMonth()+1).padStart(2,'0') + '-' + String(d.getDate()).padStart(2,'0') + ' ' + String(d.getHours()).padStart(2,'0') + ':' + String(d.getMinutes()).padStart(2,'0');
};
onMounted(() => { loadData(); loadStats(); });
return { loading, tableData, total, stats, todayIncome, query, loadData, statusText, statusType, formatTime };
}
};
@@ -0,0 +1,107 @@
const ProductView = {
template: `
<div>
<el-card shadow="never">
<template #header>
<div style="display: flex; align-items: center; justify-content: space-between;">
<span style="font-size: 16px; font-weight: 600;">商品管理</span>
<el-button type="primary" @click="openDialog(null)"><el-icon><Plus/></el-icon> 新增商品</el-button>
</div>
</template>
<el-form :inline="true" style="margin-bottom: 16px;">
<el-form-item label="状态">
<el-select v-model="query.status" placeholder="全部" clearable @change="loadData" style="width: 120px;">
<el-option label="上架" :value="1"/><el-option label="下架" :value="0"/>
</el-select>
</el-form-item>
<el-form-item><el-button type="primary" @click="loadData">查询</el-button></el-form-item>
</el-form>
<el-table :data="tableData" stripe v-loading="loading" style="width: 100%;">
<el-table-column prop="productName" label="商品名称" min-width="140"/>
<el-table-column prop="tag" label="标签" width="120"/>
<el-table-column label="价格(元)" width="100" align="center">
<template #default="{row}">{{(row.price/100).toFixed(2)}}</template>
</el-table-column>
<el-table-column label="划线价(元)" width="110" align="center">
<template #default="{row}">{{row.originalPrice?(row.originalPrice/100).toFixed(2):'-'}}</template>
</el-table-column>
<el-table-column prop="durationDays" label="有效天数" width="90" align="center"/>
<el-table-column prop="sortOrder" label="排序" width="70" align="center"/>
<el-table-column label="状态" width="80" align="center">
<template #default="{row}"><el-tag :type="row.status===1?'success':'info'" size="small">{{row.status===1?'上架':'下架'}}</el-tag></template>
</el-table-column>
<el-table-column label="操作" width="180" align="center" fixed="right">
<template #default="{row}">
<el-button link type="primary" size="small" @click="openDialog(row)">编辑</el-button>
<el-button link :type="row.status===1?'warning':'success'" size="small" @click="toggleStatus(row)">{{row.status===1?'下架':'上架'}}</el-button>
<el-popconfirm title="确定删除该商品?" @confirm="handleDelete(row)"><template #reference><el-button link type="danger" size="small">删除</el-button></template></el-popconfirm>
</template>
</el-table-column>
</el-table>
<div style="margin-top: 16px; display: flex; justify-content: flex-end;">
<el-pagination background layout="total, prev, pager, next" :total="total" :page-size="query.pageSize" v-model:current-page="query.pageNum" @current-change="loadData"/>
</div>
</el-card>
<el-dialog v-model="dialogVisible" :title="form.id?'编辑商品':'新增商品'" width="520px" destroy-on-close>
<el-form :model="form" label-width="90px">
<el-form-item label="商品名称"><el-input v-model="form.productName" maxlength="32"/></el-form-item>
<el-form-item label="标签"><el-input v-model="form.tag" maxlength="16" placeholder="如:限时优惠"/></el-form-item>
<el-row :gutter="16">
<el-col :span="12"><el-form-item label="价格(分)"><el-input-number v-model="form.price" :min="1" style="width: 100%;"/></el-form-item></el-col>
<el-col :span="12"><el-form-item label="划线价(分)"><el-input-number v-model="form.originalPrice" :min="0" style="width: 100%;"/></el-form-item></el-col>
</el-row>
<el-row :gutter="16">
<el-col :span="12"><el-form-item label="月价(分)"><el-input-number v-model="form.monthlyPrice" :min="0" style="width: 100%;"/></el-form-item></el-col>
<el-col :span="12"><el-form-item label="有效天数"><el-input-number v-model="form.durationDays" :min="1" style="width: 100%;"/></el-form-item></el-col>
</el-row>
<el-row :gutter="16">
<el-col :span="12"><el-form-item label="排序"><el-input-number v-model="form.sortOrder" :min="0" style="width: 100%;"/></el-form-item></el-col>
<el-col :span="12"><el-form-item label="主推"><el-switch v-model="form.isFeatured" :active-value="1" :inactive-value="0"/></el-form-item></el-col>
</el-row>
<el-form-item label="按钮文字"><el-input v-model="form.buyButtonText" maxlength="16" placeholder="如:立即开通"/></el-form-item>
</el-form>
<template #footer>
<el-button @click="dialogVisible=false">取消</el-button>
<el-button type="primary" :loading="saving" @click="handleSave">保存</el-button>
</template>
</el-dialog>
</div>
`,
setup() {
const { ref, reactive, onMounted } = Vue;
const loading = ref(false);
const saving = ref(false);
const dialogVisible = ref(false);
const tableData = ref([]);
const total = ref(0);
const query = reactive({ pageNum: 1, pageSize: 10, status: null });
const form = reactive({ id: null, productName: '', tag: '', price: null, originalPrice: null, monthlyPrice: null, durationDays: null, sortOrder: 0, isFeatured: 0, buyButtonText: '' });
const loadData = async () => {
loading.value = true;
try { const res = await productApi.list(query); tableData.value = res.list; total.value = Number(res.total); } catch(e) {}
finally { loading.value = false; }
};
const openDialog = (row) => {
if (row) { Object.assign(form, { id: row.id, productName: row.productName, tag: row.tag, price: row.price, originalPrice: row.originalPrice, monthlyPrice: row.monthlyPrice, durationDays: row.durationDays, sortOrder: row.sortOrder, isFeatured: row.isFeatured, buyButtonText: row.buyButtonText }); }
else { Object.assign(form, { id: null, productName: '', tag: '', price: null, originalPrice: null, monthlyPrice: null, durationDays: null, sortOrder: 0, isFeatured: 0, buyButtonText: '' }); }
dialogVisible.value = true;
};
const handleSave = async () => {
if (!form.productName || !form.price || !form.durationDays) { ElementPlus.ElMessage.warning('请填写必填项'); return; }
saving.value = true;
try { await productApi.save(form); dialogVisible.value = false; ElementPlus.ElMessage.success('保存成功'); loadData(); } catch(e) {}
finally { saving.value = false; }
};
const toggleStatus = async (row) => {
const newStatus = row.status === 1 ? 0 : 1;
try { await productApi.updateStatus(row.id, newStatus); row.status = newStatus; ElementPlus.ElMessage.success('操作成功'); } catch(e) {}
};
const handleDelete = async (row) => {
try { await productApi.delete(row.id); ElementPlus.ElMessage.success('删除成功'); loadData(); } catch(e) {}
};
onMounted(loadData);
return { loading, saving, dialogVisible, tableData, total, query, form, loadData, openDialog, handleSave, toggleStatus, handleDelete };
}
};
@@ -0,0 +1,64 @@
const UserView = {
template: `
<div>
<el-card shadow="never">
<template #header><span style="font-size: 16px; font-weight: 600;">用户管理</span></template>
<el-form :inline="true" style="margin-bottom: 16px;">
<el-form-item label="手机号"><el-input v-model="query.mobileNumber" placeholder="手机号" clearable @clear="loadData" style="width: 150px;"/></el-form-item>
<el-form-item label="昵称"><el-input v-model="query.keyword" placeholder="昵称" clearable @clear="loadData" style="width: 150px;"/></el-form-item>
<el-form-item label="状态">
<el-select v-model="query.status" placeholder="全部" clearable @change="loadData" style="width: 100px;">
<el-option label="正常" :value="0"/><el-option label="禁用" :value="1"/>
</el-select>
</el-form-item>
<el-form-item><el-button type="primary" @click="loadData">查询</el-button></el-form-item>
</el-form>
<el-table :data="tableData" stripe v-loading="loading" style="width: 100%;">
<el-table-column prop="nick" label="昵称" min-width="100"/>
<el-table-column prop="realName" label="真实姓名" min-width="100"/>
<el-table-column prop="mobileNumber" label="手机号" min-width="130"/>
<el-table-column prop="resumeCount" label="简历数" width="80" align="center"/>
<el-table-column label="状态" width="80" align="center">
<template #default="{row}"><el-tag :type="row.status===0?'success':'danger'" size="small">{{row.status===0?'正常':'禁用'}}</el-tag></template>
</el-table-column>
<el-table-column label="注册时间" min-width="160">
<template #default="{row}">{{formatTime(row.createTime)}}</template>
</el-table-column>
<el-table-column label="操作" width="90" align="center" fixed="right">
<template #default="{row}">
<el-popconfirm :title="row.status===0?'确定禁用该用户?':'确定启用该用户?'" @confirm="toggleStatus(row)">
<template #reference><el-button link :type="row.status===0?'danger':'success'" size="small">{{row.status===0?'禁用':'启用'}}</el-button></template>
</el-popconfirm>
</template>
</el-table-column>
</el-table>
<div style="margin-top: 16px; display: flex; justify-content: flex-end;">
<el-pagination background layout="total, prev, pager, next" :total="total" :page-size="query.pageSize" v-model:current-page="query.pageNum" @current-change="loadData"/>
</div>
</el-card>
</div>
`,
setup() {
const { ref, reactive, onMounted } = Vue;
const loading = ref(false);
const tableData = ref([]);
const total = ref(0);
const query = reactive({ pageNum: 1, pageSize: 10, mobileNumber: '', keyword: '', status: null });
const loadData = async () => {
loading.value = true;
try { const res = await userApi.list(query); tableData.value = res.list; total.value = Number(res.total); } catch(e) {}
finally { loading.value = false; }
};
const toggleStatus = async (row) => {
const newStatus = row.status === 0 ? 1 : 0;
try { await userApi.updateStatus(row.id, newStatus); row.status = newStatus; ElementPlus.ElMessage.success('操作成功'); } catch(e) {}
};
const formatTime = (ts) => {
if (!ts) return '-';
const d = new Date(ts);
return d.getFullYear() + '-' + String(d.getMonth()+1).padStart(2,'0') + '-' + String(d.getDate()).padStart(2,'0') + ' ' + String(d.getHours()).padStart(2,'0') + ':' + String(d.getMinutes()).padStart(2,'0');
};
onMounted(loadData);
return { loading, tableData, total, query, loadData, toggleStatus, formatTime };
}
};
@@ -0,0 +1,91 @@
<!DOCTYPE html>
<html lang="zh-CN" xmlns:th="http://www.thymeleaf.org">
<head>
<meta charset="UTF-8"/>
<meta name="viewport" content="width=device-width, initial-scale=1.0"/>
<title>OfferPie 管理后台</title>
<link rel="stylesheet" href="https://unpkg.com/element-plus@2.7.3/dist/index.css"/>
<style>
html, body, #app { margin: 0; padding: 0; height: 100%; font-family: -apple-system, BlinkMacSystemFont, 'PingFang SC', 'Microsoft YaHei', sans-serif; }
.layout { height: 100%; }
.aside { background: #1d1e3c; overflow-y: auto; }
.aside .logo { height: 60px; display: flex; align-items: center; justify-content: center; padding: 0 16px; border-bottom: 1px solid rgba(255,255,255,0.06); }
.aside .logo img { height: 32px; max-width: 100%; object-fit: contain; }
.aside .el-menu { border-right: none; background: transparent; padding-top: 8px; }
.aside .el-menu-item { margin: 4px 10px; border-radius: 6px; }
.aside .el-menu-item.is-active { background: rgba(64,158,255,0.18) !important; }
.header { background: #fff; display: flex; align-items: center; justify-content: space-between; padding: 0 24px; height: 60px; box-shadow: 0 1px 4px rgba(0,21,41,0.08); z-index: 10; }
.header .title { font-size: 16px; font-weight: 600; color: #303133; }
.header .admin-info { display: flex; align-items: center; gap: 10px; font-size: 14px; color: #606266; }
.main-content { padding: 20px; background: #f0f2f5; overflow-y: auto; }
</style>
</head>
<body>
<div id="app" v-cloak>
<el-container class="layout">
<el-aside width="210px" class="aside">
<div class="logo">
<img src="/admin/img/logo.png" alt="logo"/>
</div>
<el-menu :default-active="currentView" background-color="#1d1e3c" text-color="rgba(255,255,255,0.65)" active-text-color="#fff" @select="handleMenuSelect">
<el-menu-item index="dashboard"><el-icon><data-board/></el-icon><span>数据概览</span></el-menu-item>
<el-menu-item index="user"><el-icon><user/></el-icon><span>用户管理</span></el-menu-item>
<el-menu-item index="order"><el-icon><tickets/></el-icon><span>订单管理</span></el-menu-item>
<el-menu-item index="product"><el-icon><goods/></el-icon><span>商品管理</span></el-menu-item>
</el-menu>
</el-aside>
<el-container>
<el-header class="header">
<span class="title">{{ title }}</span>
<div class="admin-info">
<el-button type="primary" plain @click="handleLogout">退出登录</el-button>
</div>
</el-header>
<el-main class="main-content">
<component :is="currentComponent"></component>
</el-main>
</el-container>
</el-container>
</div>
<script src="https://unpkg.com/vue@3.4.21/dist/vue.global.prod.js"></script>
<script src="https://unpkg.com/element-plus@2.7.3/dist/index.full.min.js"></script>
<script src="https://unpkg.com/@element-plus/icons-vue@2.3.1/dist/index.iife.min.js"></script>
<script src="/admin/js/request.js"></script>
<script src="/admin/js/api/auth.js"></script>
<script src="/admin/js/api/user.js"></script>
<script src="/admin/js/api/order.js"></script>
<script src="/admin/js/api/product.js"></script>
<script src="/admin/js/views/dashboard.js"></script>
<script src="/admin/js/views/user.js"></script>
<script src="/admin/js/views/order.js"></script>
<script src="/admin/js/views/product.js"></script>
<style>[v-cloak] { display: none; }</style>
<script>
const { createApp, ref, computed } = Vue;
const app = createApp({
setup() {
const currentView = ref('dashboard');
const views = { dashboard: DashboardView, user: UserView, order: OrderView, product: ProductView };
const titles = { dashboard: '数据概览', user: '用户管理', order: '订单管理', product: '商品管理' };
const currentComponent = computed(() => views[currentView.value]);
const title = computed(() => titles[currentView.value]);
const handleMenuSelect = (index) => { currentView.value = index; };
const handleLogout = () => {
document.cookie = 'Token=; path=/; max-age=0';
window.location.href = '/admin/page/login';
};
return { currentView, currentComponent, title, handleMenuSelect, handleLogout };
}
});
// 注册 Element Plus 图标(容错:CDN 未加载时不阻断应用)
if (window.ElementPlusIconsVue) {
for (const [key, component] of Object.entries(ElementPlusIconsVue)) {
app.component(key, component);
}
}
app.use(ElementPlus);
app.mount('#app');
</script>
</body>
</html>
@@ -0,0 +1,126 @@
<!DOCTYPE html>
<html lang="zh-CN" xmlns:th="http://www.thymeleaf.org">
<head>
<meta charset="UTF-8"/>
<meta name="viewport" content="width=device-width, initial-scale=1.0"/>
<title>OfferPie 管理后台</title>
<link rel="stylesheet" href="https://unpkg.com/element-plus@2.7.3/dist/index.css"/>
<style>[v-cloak] { display: none; }</style>
<style>
body { margin: 0; padding: 0; }
#app {
min-height: 100vh;
display: flex;
background: #f5f7fa;
}
.left-panel {
flex: 1;
background: linear-gradient(160deg, #1d1e3c 0%, #2b2d5e 100%);
display: flex;
flex-direction: column;
justify-content: center;
padding: 0 80px;
position: relative;
overflow: hidden;
}
.left-panel::before {
content: '';
position: absolute;
width: 400px;
height: 400px;
border-radius: 50%;
background: rgba(64, 158, 255, 0.06);
top: 10%;
right: -100px;
}
.left-panel .logo { display: flex; align-items: center; gap: 14px; margin-bottom: 24px; }
.left-panel .logo img { height: 44px; }
.left-panel .logo span { font-size: 26px; font-weight: 600; color: #fff; }
.left-panel .desc { font-size: 15px; color: rgba(255,255,255,0.5); line-height: 1.8; }
.left-panel .footer { position: absolute; bottom: 30px; left: 80px; font-size: 12px; color: rgba(255,255,255,0.2); }
.right-panel {
width: 480px;
display: flex;
align-items: center;
justify-content: center;
padding: 40px;
}
.login-box { width: 100%; max-width: 340px; }
.login-box h2 { font-size: 22px; color: #303133; margin-bottom: 6px; }
.login-box .sub { font-size: 13px; color: #909399; margin-bottom: 32px; }
.login-box .el-button { width: 100%; margin-top: 8px; }
@media (max-width: 900px) {
.left-panel { display: none; }
.right-panel { width: 100%; }
}
</style>
</head>
<body>
<div id="app" v-cloak>
<div class="left-panel">
<div class="logo">
<img src="/admin/img/logo.png" alt="logo"/>
<span>OfferPie</span>
</div>
<div class="desc">运营管理后台</div>
<div class="footer">© 2025 OfferPie</div>
</div>
<div class="right-panel">
<div class="login-box">
<h2>欢迎回来</h2>
<p class="sub">请登录管理员账号</p>
<el-form :model="form" :rules="rules" ref="formRef" @keyup.enter="handleLogin">
<el-form-item prop="username">
<el-input v-model="form.username" placeholder="账号" prefix-icon="User" size="large" maxlength="32"/>
</el-form-item>
<el-form-item prop="password">
<el-input v-model="form.password" type="password" placeholder="密码" prefix-icon="Lock" size="large" maxlength="32" show-password/>
</el-form-item>
<el-form-item>
<el-button type="primary" size="large" :loading="loading" @click="handleLogin">登录</el-button>
</el-form-item>
</el-form>
</div>
</div>
</div>
<script src="https://unpkg.com/vue@3.4.21/dist/vue.global.prod.js"></script>
<script src="https://unpkg.com/element-plus@2.7.3/dist/index.full.min.js"></script>
<script src="https://unpkg.com/@element-plus/icons-vue@2.3.1/dist/index.iife.min.js"></script>
<script src="/admin/js/request.js"></script>
<script src="/admin/js/api/auth.js"></script>
<script>
const { createApp, ref, reactive } = Vue;
const app = createApp({
setup() {
const formRef = ref(null);
const loading = ref(false);
const form = reactive({ username: '', password: '' });
const rules = {
username: [{ required: true, message: '请输入账号', trigger: 'blur' }],
password: [{ required: true, message: '请输入密码', trigger: 'blur' }, { min: 6, max: 32, message: '密码长度6-32位', trigger: 'blur' }]
};
const handleLogin = async () => {
const valid = await formRef.value.validate().catch(() => false);
if (!valid) return;
loading.value = true;
try {
await authApi.login(form.username, form.password);
window.location.href = '/admin/page/index';
} catch (e) { }
finally { loading.value = false; }
};
return { formRef, form, rules, loading, handleLogin };
}
});
// 注册 Element Plus 图标(容错)
if (window.ElementPlusIconsVue) {
for (const [key, component] of Object.entries(ElementPlusIconsVue)) {
app.component(key, component);
}
}
app.use(ElementPlus);
app.mount('#app');
</script>
</body>
</html>
+65
View File
@@ -0,0 +1,65 @@
services:
nginx:
image: nginx:alpine
container_name: offerpie-backend-admin-nginx
restart: unless-stopped
ports:
- "10062:80"
healthcheck:
test: ["CMD", "wget", "--spider", "-q", "http://localhost/health"]
interval: 30s
timeout: 10s
retries: 3
deploy:
resources:
limits:
memory: 256M
cpus: '1'
blue:
image: offerpie-backend-admin:latest
container_name: offerpie-backend-admin-blue
restart: unless-stopped
expose:
- "8081"
environment:
- APP_VERSION=blue
- PROFILES_ACTIVE=prod
- TZ=Asia/Shanghai
healthcheck:
test: ["CMD", "curl", "-f", "http://localhost:8081/admin/public/actuator/health"]
interval: 30s
timeout: 10s
retries: 3
start_period: 40s
volumes:
- /logs/offerpie-backend-admin:/app/logs
deploy:
resources:
limits:
memory: 1G
cpus: '1'
green:
image: offerpie-backend-admin:latest
container_name: offerpie-backend-admin-green
restart: unless-stopped
expose:
- "8081"
environment:
- APP_VERSION=green
- PROFILES_ACTIVE=prod
- TZ=Asia/Shanghai
healthcheck:
test: ["CMD", "curl", "-f", "http://localhost:8081/admin/public/actuator/health"]
interval: 30s
timeout: 10s
retries: 3
start_period: 40s
volumes:
- /logs/offerpie-backend-admin:/app/logs
deploy:
resources:
limits:
memory: 1G
cpus: '1'
+65
View File
@@ -0,0 +1,65 @@
services:
nginx:
image: nginx:alpine
container_name: offerpie-backend-admin-nginx
restart: unless-stopped
ports:
- "10062:80"
healthcheck:
test: ["CMD", "wget", "--spider", "-q", "http://localhost/health"]
interval: 30s
timeout: 10s
retries: 3
deploy:
resources:
limits:
memory: 256M
cpus: '1'
blue:
image: offerpie-backend-admin:test
container_name: offerpie-backend-admin-blue
restart: unless-stopped
expose:
- "8081"
environment:
- APP_VERSION=blue
- PROFILES_ACTIVE=test
- TZ=Asia/Shanghai
healthcheck:
test: ["CMD", "curl", "-f", "http://localhost:8081/admin/public/actuator/health"]
interval: 30s
timeout: 10s
retries: 3
start_period: 40s
volumes:
- /logs/offerpie-backend-admin:/app/logs
deploy:
resources:
limits:
memory: 1G
cpus: '1'
green:
image: offerpie-backend-admin:test
container_name: offerpie-backend-admin-green
restart: unless-stopped
expose:
- "8081"
environment:
- APP_VERSION=green
- PROFILES_ACTIVE=test
- TZ=Asia/Shanghai
healthcheck:
test: ["CMD", "curl", "-f", "http://localhost:8081/admin/public/actuator/health"]
interval: 30s
timeout: 10s
retries: 3
start_period: 40s
volumes:
- /logs/offerpie-backend-admin:/app/logs
deploy:
resources:
limits:
memory: 1G
cpus: '1'
@@ -0,0 +1,11 @@
package org.jiayunet.mapper;
import org.jiayunet.pojo.po.AdminUser;
/**
* 管理员用户 Mapper
*
* @author zk
*/
public interface AdminUserMapper extends CommonMapper<AdminUser> {
}
@@ -0,0 +1,54 @@
package org.jiayunet.pojo.po;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableLogic;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.time.Instant;
/**
* 管理员用户表(bg_admin_user
*
* @author zk
*/
@Data
@TableName("bg_admin_user")
public class AdminUser {
/** 主键 */
@TableId(type = IdType.ASSIGN_ID)
private Long id;
/** 登录账号 */
private String username;
/** 密码(BCrypt */
private String password;
/** 真实姓名 */
private String realName;
/** 昵称 */
private String nickName;
/** 手机号码 */
private String mobileNumber;
/** 头像URL */
private String avatar;
/** 状态 0=正常 1=禁用 */
private Integer status;
/** 创建时间 */
private Instant createTime;
/** 更新时间 */
private Instant updateTime;
/** 逻辑删除 0=正常 */
@TableLogic(value = "0", delval = "UNIX_TIMESTAMP()")
private Long isDelete;
}
+1
View File
@@ -14,6 +14,7 @@
<module>common</module> <module>common</module>
<module>client-api</module> <module>client-api</module>
<module>manager</module> <module>manager</module>
<module>admin</module>
</modules> </modules>
<properties> <properties>