zw/pkAssistant
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: zw:4c0d5dbd75618792f994b32f1721f6e16e58660d
Branches Tags
zw:main
...
compare: zw:7882b94c0893593ef499fc69ca19b24ab3969ac2
Branches Tags
zw:main

4 Commits
4c0d5dbd75 ... 7882b94c08

Author SHA1 Message Date
Ziin
7882b94c08 1.忽略 target 目录 2025-08-01 21:20:06 +08:00
Ziin
c0f4d05f00 1.移除无用improt 2025-08-01 21:18:08 +08:00
Ziin
e9ee9d6b90 1.优化主播代码模块代码，添加统一异常处理 2025-08-01 21:15:16 +08:00
Ziin
93c10482d0 1.优化目录结构 2025-08-01 15:10:15 +08:00
63 changed files with 473 additions and 420 deletions
Expand all files Collapse all files

1
.gitignore vendored
View File

@@ -24,3 +24,4 @@
hs_err_pid*
replay_pid*
!/target/

BIN
.idea/.cache/.Apifox_Helper/.toolWindow.db generated Normal file
View File

Binary file not shown.

6
.idea/ApifoxUploaderProjectSetting.xml generated Normal file
View File

@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ApifoxUploaderProjectSetting">
<option name="apiAccessToken" value="APS-bCiUm0GlQrVfnvxUtLKidqmrUwG2Uqx6" />
</component>
</project>

10
.idea/dataSources.xml generated
View File

@@ -1,11 +1,17 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="DataSourceManagerImpl" format="xml" multifile-model="true">
<data-source source="LOCAL" name="vv_assistant@120.26.251.180" uuid="825abb89-80f2-475c-9ee4-5b0afe788f5b">
<data-source source="LOCAL" name="vv_assistant@localhost" uuid="a97b176f-f814-4c14-b11c-1945b687d99f">
<driver-ref>mysql.8</driver-ref>
<synchronize>true</synchronize>
<imported>true</imported>
<jdbc-driver>com.mysql.cj.jdbc.Driver</jdbc-driver>
<jdbc-url>jdbc:mysql://120.26.251.180:3326/vv_assistant</jdbc-url>
<jdbc-url>jdbc:mysql://localhost:3306/vv_assistant?allowMultiQueries=true</jdbc-url>
<jdbc-additional-properties>
<property name="com.intellij.clouds.kubernetes.db.host.port" />
<property name="com.intellij.clouds.kubernetes.db.enabled" value="false" />
<property name="com.intellij.clouds.kubernetes.db.container.port" />
</jdbc-additional-properties>
<working-dir>$ProjectFileDir$</working-dir>
</data-source>
</component>

13
.idea/libraries/Maven__com_vaadin_external_google_android_json_0_0_20131108_vaadin1.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: com.vaadin.external.google:android-json:0.0.20131108.vaadin1">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/com/vaadin/external/google/android-json/0.0.20131108.vaadin1/android-json-0.0.20131108.vaadin1.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/com/vaadin/external/google/android-json/0.0.20131108.vaadin1/android-json-0.0.20131108.vaadin1-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/com/vaadin/external/google/android-json/0.0.20131108.vaadin1/android-json-0.0.20131108.vaadin1-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__jakarta_activation_jakarta_activation_api_1_2_2.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: jakarta.activation:jakarta.activation-api:1.2.2">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/jakarta/activation/jakarta.activation-api/1.2.2/jakarta.activation-api-1.2.2.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/jakarta/activation/jakarta.activation-api/1.2.2/jakarta.activation-api-1.2.2-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/jakarta/activation/jakarta.activation-api/1.2.2/jakarta.activation-api-1.2.2-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__jakarta_annotation_jakarta_annotation_api_1_3_5.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: jakarta.annotation:jakarta.annotation-api:1.3.5">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/jakarta/annotation/jakarta.annotation-api/1.3.5/jakarta.annotation-api-1.3.5.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/jakarta/annotation/jakarta.annotation-api/1.3.5/jakarta.annotation-api-1.3.5-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/jakarta/annotation/jakarta.annotation-api/1.3.5/jakarta.annotation-api-1.3.5-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__jakarta_xml_bind_jakarta_xml_bind_api_2_3_3.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: jakarta.xml.bind:jakarta.xml.bind-api:2.3.3">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/jakarta/xml/bind/jakarta.xml.bind-api/2.3.3/jakarta.xml.bind-api-2.3.3.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/jakarta/xml/bind/jakarta.xml.bind-api/2.3.3/jakarta.xml.bind-api-2.3.3-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/jakarta/xml/bind/jakarta.xml.bind-api/2.3.3/jakarta.xml.bind-api-2.3.3-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_apache_logging_log4j_log4j_to_slf4j_2_17_2.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.apache.logging.log4j:log4j-to-slf4j:2.17.2">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/apache/logging/log4j/log4j-to-slf4j/2.17.2/log4j-to-slf4j-2.17.2.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/apache/logging/log4j/log4j-to-slf4j/2.17.2/log4j-to-slf4j-2.17.2-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/apache/logging/log4j/log4j-to-slf4j/2.17.2/log4j-to-slf4j-2.17.2-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_apiguardian_apiguardian_api_1_1_2.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.apiguardian:apiguardian-api:1.1.2">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/apiguardian/apiguardian-api/1.1.2/apiguardian-api-1.1.2.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/apiguardian/apiguardian-api/1.1.2/apiguardian-api-1.1.2-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/apiguardian/apiguardian-api/1.1.2/apiguardian-api-1.1.2-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_hamcrest_hamcrest_2_2.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.hamcrest:hamcrest:2.2">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/hamcrest/hamcrest/2.2/hamcrest-2.2.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/hamcrest/hamcrest/2.2/hamcrest-2.2-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/hamcrest/hamcrest/2.2/hamcrest-2.2-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_junit_jupiter_junit_jupiter_5_8_2.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.junit.jupiter:junit-jupiter:5.8.2">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/jupiter/junit-jupiter/5.8.2/junit-jupiter-5.8.2.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/jupiter/junit-jupiter/5.8.2/junit-jupiter-5.8.2-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/jupiter/junit-jupiter/5.8.2/junit-jupiter-5.8.2-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_junit_jupiter_junit_jupiter_api_5_8_2.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.junit.jupiter:junit-jupiter-api:5.8.2">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/jupiter/junit-jupiter-api/5.8.2/junit-jupiter-api-5.8.2.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/jupiter/junit-jupiter-api/5.8.2/junit-jupiter-api-5.8.2-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/jupiter/junit-jupiter-api/5.8.2/junit-jupiter-api-5.8.2-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_junit_jupiter_junit_jupiter_engine_5_8_2.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.junit.jupiter:junit-jupiter-engine:5.8.2">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/jupiter/junit-jupiter-engine/5.8.2/junit-jupiter-engine-5.8.2.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/jupiter/junit-jupiter-engine/5.8.2/junit-jupiter-engine-5.8.2-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/jupiter/junit-jupiter-engine/5.8.2/junit-jupiter-engine-5.8.2-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_junit_jupiter_junit_jupiter_params_5_8_2.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.junit.jupiter:junit-jupiter-params:5.8.2">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/jupiter/junit-jupiter-params/5.8.2/junit-jupiter-params-5.8.2.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/jupiter/junit-jupiter-params/5.8.2/junit-jupiter-params-5.8.2-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/jupiter/junit-jupiter-params/5.8.2/junit-jupiter-params-5.8.2-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_junit_platform_junit_platform_commons_1_8_2.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.junit.platform:junit-platform-commons:1.8.2">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/platform/junit-platform-commons/1.8.2/junit-platform-commons-1.8.2.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/platform/junit-platform-commons/1.8.2/junit-platform-commons-1.8.2-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/platform/junit-platform-commons/1.8.2/junit-platform-commons-1.8.2-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_junit_platform_junit_platform_engine_1_8_2.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.junit.platform:junit-platform-engine:1.8.2">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/platform/junit-platform-engine/1.8.2/junit-platform-engine-1.8.2.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/platform/junit-platform-engine/1.8.2/junit-platform-engine-1.8.2-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/junit/platform/junit-platform-engine/1.8.2/junit-platform-engine-1.8.2-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_objenesis_objenesis_3_2.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.objenesis:objenesis:3.2">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/objenesis/objenesis/3.2/objenesis-3.2.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/objenesis/objenesis/3.2/objenesis-3.2-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/objenesis/objenesis/3.2/objenesis-3.2-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_opentest4j_opentest4j_1_2_0.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.opentest4j:opentest4j:1.2.0">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/opentest4j/opentest4j/1.2.0/opentest4j-1.2.0.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/opentest4j/opentest4j/1.2.0/opentest4j-1.2.0-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/opentest4j/opentest4j/1.2.0/opentest4j-1.2.0-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_skyscreamer_jsonassert_1_5_1.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.skyscreamer:jsonassert:1.5.1">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/skyscreamer/jsonassert/1.5.1/jsonassert-1.5.1.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/skyscreamer/jsonassert/1.5.1/jsonassert-1.5.1-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/skyscreamer/jsonassert/1.5.1/jsonassert-1.5.1-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_slf4j_jul_to_slf4j_1_7_36.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.slf4j:jul-to-slf4j:1.7.36">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/slf4j/jul-to-slf4j/1.7.36/jul-to-slf4j-1.7.36.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/slf4j/jul-to-slf4j/1.7.36/jul-to-slf4j-1.7.36-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/slf4j/jul-to-slf4j/1.7.36/jul-to-slf4j-1.7.36-sources.jar!/" />
</SOURCES>
</library>
</component>

13
.idea/libraries/Maven__org_slf4j_slf4j_api_1_7_36.xml generated
View File

@@ -1,13 +0,0 @@
<component name="libraryTable">
<library name="Maven: org.slf4j:slf4j-api:1.7.36">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/slf4j/slf4j-api/1.7.36/slf4j-api-1.7.36.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/slf4j/slf4j-api/1.7.36/slf4j-api-1.7.36-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/slf4j/slf4j-api/1.7.36/slf4j-api-1.7.36-sources.jar!/" />
</SOURCES>
</library>
</component>

2
.idea/misc.xml generated
View File

@@ -8,5 +8,5 @@
</list>
</option>
</component>
<component name="ProjectRootManager" version="2" project-jdk-name="Python 3.12 (tiktok-data)" project-jdk-type="Python SDK" />
<component name="ProjectRootManager" version="2" languageLevel="JDK_24" project-jdk-name="17" project-jdk-type="JavaSDK" />
</project>

8
.idea/modules.xml generated Normal file
View File

@@ -0,0 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ProjectModuleManager">
<modules>
<module fileurl="file://$PROJECT_DIR$/vvPkAssistant.iml" filepath="$PROJECT_DIR$/vvPkAssistant.iml" />
</modules>
</component>
</project>

6
.idea/vcs.xml generated Normal file
View File

@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="VcsDirectoryMappings">
<mapping directory="" vcs="Git" />
</component>
</project>

23
.xcodemap/config/xcodemap-class-filter.yaml Normal file
View File

@@ -0,0 +1,23 @@
autoDetectedPackages:
- vvpkassistant
enableAutoDetect: true
entryDisplayConfig:
excludedPathPatterns: []
skipJsCss: true
funcDisplayConfig:
skipConstructors: false
skipFieldAccess: true
skipFieldChange: true
skipGetters: false
skipNonProjectPackages: false
skipPrivateMethods: false
skipSetters: false
ignoreSameClassCall: null
ignoreSamePackageCall: null
includedPackagePrefixes: null
includedParentClasses: null
name: xcodemap-filter
recordMode: all
sourceDisplayConfig:
color: blue
startOnDebug: false

78
src/main/java/vvpkassistant/Anchors/AnchorsController.java
View File

@@ -1,78 +0,0 @@
package vvpkassistant.Anchors;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import vvpkassistant.Data.ResponseData;
import vvpkassistant.Data.ResponseInfo;
import vvpkassistant.pk.PkRecordDao;
import java.util.List;
import java.util.Map;
@RestController
@RequestMapping("anchor")
public class AnchorsController {
@Autowired
private AnchorDao anchorDao;
@Autowired
private PkRecordDao recordDao;
// 添加新主播
@PostMapping("add")
public ResponseData<Object> addNewAnchor(@RequestBody AnchorModel model) {
//查询是否存在重复主播
int r = anchorDao.selectAnchorWithAnchorIdAndUserId(model.getAnchorId(), model.getCreateUserId());
if (r != 0) {
return ResponseData.error(ResponseInfo.ERROR,"该主播已存在");
}
int insert = anchorDao.insert(model);
return insert == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR,"添加失败");
}
// 查询我的主播列表
@PostMapping("list")
public ResponseData<Object> myAnchorList(@RequestBody Map<String,Integer> map) {
Integer userId = map.get("id");
List<AnchorModel> anchorModels = anchorDao.selectMyAnchor(userId);
return ResponseData.success(anchorModels);
}
// 删除我的主播
@PostMapping("deleteMyAnchor")
public ResponseData<Object> deleteMyAnchor(@RequestBody Map<String,Integer> map) {
Integer id = map.get("id");
AnchorModel anchorModel = anchorDao.selectById(id);
try {
String anchorId = anchorModel.getAnchorId();
// 根据主播id查询该主播是否存在pk记录
int i = recordDao.existsPkRecordByAnchor(anchorId);
if (i > 0) {
return ResponseData.error(ResponseInfo.ERROR,"该主播已有pk记录。无法删除");
}
int r = anchorDao.deleteById(id);
return r == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR,null);
} catch (Exception e) {
return ResponseData.error(ResponseInfo.ERROR,"非法数据，操作失败");
}
}
// 更新主播信息
@PostMapping("updateAnchorInfo")
public ResponseData<Object> updateAnchorInfo(@RequestBody AnchorModel model) {
// 查询该主播是否存在记录
int i = recordDao.existsPkRecordByAnchor(model.getAnchorId());
if (i > 0) {
return ResponseData.error(ResponseInfo.ERROR,"该主播已有pk记录。无法修改信息");
}
int r = anchorDao.updateById(model);
return r == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR,null);
}
}

51
src/main/java/vvpkassistant/Anchors/controller/AnchorsController.java Normal file
View File

@@ -0,0 +1,51 @@
package vvpkassistant.Anchors.controller;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import vvpkassistant.Anchors.model.AnchorModel;
import vvpkassistant.Anchors.service.AnchorsService;
import vvpkassistant.Data.ResponseData;
import vvpkassistant.common.ErrorCode;
import javax.annotation.Resource;
import java.util.Map;
@RestController
@RequestMapping("anchor")
public class AnchorsController {
@Resource
private AnchorsService anchorsService;
// 添加新主播
@PostMapping("add")
public ResponseData<Object> addNewAnchor(@RequestBody AnchorModel model) {
return anchorsService.addNewAnchor(model) == 1 ? ResponseData.success("") : ResponseData.error(ErrorCode.ADD_FAILED);
}
// 查询我的主播列表
@PostMapping("list")
public ResponseData<Object> myAnchorList(@RequestBody Map<String,Integer> map) {
Integer userId = map.get("id");
return ResponseData.success(anchorsService.selectMyAnchor(userId));
}
// 删除我的主播
@PostMapping("deleteMyAnchor")
public ResponseData<Object> deleteMyAnchor(@RequestBody Map<String,Integer> map) {
Integer id = map.get("id");
return anchorsService.deleteMyAnchor(id) == 1 ? ResponseData.success(""):ResponseData.error(ErrorCode.DELETE_FAILED );
}
// 更新主播信息
@PostMapping("updateAnchorInfo")
public ResponseData<Object> updateAnchorInfo(@RequestBody AnchorModel model) {
return anchorsService.updateAnchorInfo(model) == 1 ? ResponseData.success(""):ResponseData.error(ErrorCode.UPDATE_FAILED);
}
}

3
src/main/java/vvpkassistant/Anchors/AnchorDao.java → src/main/java/vvpkassistant/Anchors/mapper/AnchorDao.java
View File

@@ -1,9 +1,10 @@
package vvpkassistant.Anchors;
package vvpkassistant.Anchors.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import vvpkassistant.Anchors.model.AnchorModel;
import java.util.List;

2
src/main/java/vvpkassistant/Anchors/AnchorModel.java → src/main/java/vvpkassistant/Anchors/model/AnchorModel.java
View File

@@ -1,4 +1,4 @@
package vvpkassistant.Anchors;
package vvpkassistant.Anchors.model;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;

20
src/main/java/vvpkassistant/Anchors/service/AnchorsService.java Normal file
View File

@@ -0,0 +1,20 @@
package vvpkassistant.Anchors.service;
import vvpkassistant.Anchors.model.AnchorModel;
import vvpkassistant.Data.ResponseData;
import java.util.List;
/*
* @author: ziin
* @date: 2025/8/1 19:59
*/
public interface AnchorsService {
Integer addNewAnchor(AnchorModel model);
List<AnchorModel> selectMyAnchor(Integer userId);
Integer deleteMyAnchor(Integer id);
Integer updateAnchorInfo(AnchorModel model);
}

69
src/main/java/vvpkassistant/Anchors/service/AnchorsServiceImpl.java Normal file
View File

@@ -0,0 +1,69 @@
package vvpkassistant.Anchors.service;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import vvpkassistant.Anchors.mapper.AnchorDao;
import vvpkassistant.Anchors.model.AnchorModel;
import vvpkassistant.Data.ResponseData;
import vvpkassistant.Data.ResponseInfo;
import vvpkassistant.common.ErrorCode;
import vvpkassistant.exception.BusinessException;
import vvpkassistant.pk.mapper.PkRecordDao;
import javax.annotation.Resource;
import java.util.List;
/*
* @author: ziin
* @date: 2025/8/1 19:59
*/
@Service
public class AnchorsServiceImpl implements AnchorsService {
@Resource
private AnchorDao anchorDao;
@Resource
private PkRecordDao recordDao;
@Override
public Integer addNewAnchor(AnchorModel model) {
//查询是否存在重复主播
int r = anchorDao.selectAnchorWithAnchorIdAndUserId(model.getAnchorId(), model.getCreateUserId());
if (r != 0) {
throw new BusinessException(ErrorCode.ANCHOR_ALREADY_EXISTS);
}
return anchorDao.insert(model);
}
@Override
public List<AnchorModel> selectMyAnchor(Integer userId) {
return anchorDao.selectMyAnchor(userId);
}
@Override
public Integer deleteMyAnchor(Integer id) {
AnchorModel anchorModel = anchorDao.selectById(id);
if (anchorModel == null) {
throw new BusinessException(ErrorCode.PARAMS_ERROR,"主播不存在");
}
String anchorId = anchorModel.getAnchorId();
// 根据主播id查询该主播是否存在pk记录
int i = recordDao.existsPkRecordByAnchor(anchorId);
if (i > 0) {
throw new BusinessException(ErrorCode.ANCHOR_HAS_PKRECORD,"该主播已有pk记录。无法删除");
}
return anchorDao.deleteById(id);
}
@Override
public Integer updateAnchorInfo(AnchorModel model) {
// 查询该主播是否存在记录
int i = recordDao.existsPkRecordByAnchor(model.getAnchorId());
if (i > 0) {
throw new BusinessException(ErrorCode.ANCHOR_HAS_PKRECORD,"该主播已有pk记录。无法修改信息");
}
return anchorDao.updateById(model);
}
}

43
src/main/java/vvpkassistant/Data/ResponseData.java
View File

@@ -1,36 +1,45 @@
package vvpkassistant.Data;
import lombok.Data;
import org.springframework.lang.Nullable;
import vvpkassistant.common.ErrorCode;
import java.io.Serializable;
@Data
public class ResponseData<T> {
public class ResponseData<T> implements Serializable {
// 状态码
T data = null;
private T data ;
public String msg;
public Integer code;
ResponseData() {}
public ResponseData(int code, T data,String message) {
this.code = code;
this.data = data;
this.msg = message;
}
public ResponseData(int code, T data) {
this(code,data,"");
}
public ResponseData(ErrorCode errorCode) {
this(errorCode.getCode(), null, errorCode.getMessage());
}
// 成功的返回方法
public static <T> ResponseData<T> success(@Nullable T param) {
ResponseInfo info = ResponseInfo.SUCCESS;
ResponseData<T> data = new ResponseData<>();
data.setData(param);
data.setCode(info.getCode());
data.setMsg(info.getDesc());
return data;
public static <T> ResponseData<T> success(T data) {
return new ResponseData<>(ResponseInfo.SUCCESS.getCode(),data,"ok");
}
// 返回错误的方法
public static ResponseData<Object> error(ResponseInfo info, @Nullable String msg) {
ResponseData<Object> data = new ResponseData<>();
data.msg = msg != null ? msg : info.getDesc();
data.code = info.getCode();
data.data = null;
return data;
public static ResponseData<Object> error(int code,String message) {
return new ResponseData<>(code, message);
}
public static ResponseData<Object> error(ErrorCode errorCode) {
return new ResponseData<>(errorCode);
}
}

9
src/main/java/vvpkassistant/FunctionConfig/FunctionConfigController.java → src/main/java/vvpkassistant/FunctionConfig/controller/FunctionConfigController.java
View File

@@ -1,8 +1,11 @@
package vvpkassistant.FunctionConfig;
package vvpkassistant.FunctionConfig.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import vvpkassistant.Data.ResponseData;
import vvpkassistant.Data.ResponseInfo;
import vvpkassistant.FunctionConfig.mapper.FunctionConfigMapper;
import vvpkassistant.FunctionConfig.model.FunctionConfigModel;
import vvpkassistant.config.FunctionConfigHolder;
@RestController
@RequestMapping("config")
@@ -34,7 +37,7 @@ public class FunctionConfigController {
boolean isDuplicate = FunctionConfigHolder.CONFIGS.stream()
.anyMatch(config -> name.equals(config.getFunctionName()));
if (isDuplicate) {
return ResponseData.error(ResponseInfo.ERROR,"配置名称重复");
return ResponseData.error(ResponseInfo.ERROR.getCode(),"配置名称重复");
}else {
configMapper.insert(newModel);
FunctionConfigHolder.CONFIGS.add(newModel);
@@ -49,7 +52,7 @@ public class FunctionConfigController {
FunctionConfigHolder.CONFIGS.removeIf(c -> model.getId().equals(c.getId()));
return ResponseData.success("");
}else {
return ResponseData.error(ResponseInfo.ERROR,null);
return ResponseData.error(ResponseInfo.ERROR.getCode(),null);
}
}

3
src/main/java/vvpkassistant/FunctionConfig/FunctionConfigMapper.java → src/main/java/vvpkassistant/FunctionConfig/mapper/FunctionConfigMapper.java
View File

@@ -1,8 +1,9 @@
package vvpkassistant.FunctionConfig;
package vvpkassistant.FunctionConfig.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import vvpkassistant.FunctionConfig.model.FunctionConfigModel;
@Mapper
public interface FunctionConfigMapper extends BaseMapper<FunctionConfigModel> {

2
src/main/java/vvpkassistant/FunctionConfig/FunctionConfigModel.java → src/main/java/vvpkassistant/FunctionConfig/model/FunctionConfigModel.java
View File

@@ -1,4 +1,4 @@
package vvpkassistant.FunctionConfig;
package vvpkassistant.FunctionConfig.model;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;

4
src/main/java/vvpkassistant/SystemMessage/SystemMessageController.java → src/main/java/vvpkassistant/SystemMessage/controller/SystemMessageController.java
View File

@@ -1,4 +1,4 @@
package vvpkassistant.SystemMessage;
package vvpkassistant.SystemMessage.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
@@ -6,6 +6,8 @@ import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import vvpkassistant.Data.ResponseData;
import vvpkassistant.SystemMessage.mapper.SystemMessageDao;
import vvpkassistant.SystemMessage.model.SystemMessage;
import vvpkassistant.Tools.VVTools;
import java.util.List;

3
src/main/java/vvpkassistant/SystemMessage/SystemMessageDao.java → src/main/java/vvpkassistant/SystemMessage/mapper/SystemMessageDao.java
View File

@@ -1,9 +1,10 @@
package vvpkassistant.SystemMessage;
package vvpkassistant.SystemMessage.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import vvpkassistant.SystemMessage.model.SystemMessage;
import java.util.List;

2
src/main/java/vvpkassistant/SystemMessage/SystemMessage.java → src/main/java/vvpkassistant/SystemMessage/model/SystemMessage.java
View File

@@ -1,4 +1,4 @@
package vvpkassistant.SystemMessage;
package vvpkassistant.SystemMessage.model;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;

3
src/main/java/vvpkassistant/Tools/VVRequester.java
View File

@@ -5,11 +5,8 @@ import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.google.gson.reflect.TypeToken;
import lombok.SneakyThrows;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import vvpkassistant.Data.WxChatParam;
import vvpkassistant.Data.WxParam;
import vvpkassistant.User.UserModel;
import java.io.BufferedReader;
import java.io.DataOutputStream;

50
src/main/java/vvpkassistant/User/UserController.java → src/main/java/vvpkassistant/User/controller/UserController.java
View File

@@ -1,4 +1,4 @@
package vvpkassistant.User;
package vvpkassistant.User.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import vvpkassistant.CoinRecords.CoinRecords;
@@ -6,13 +6,15 @@ import vvpkassistant.CoinRecords.CoinRecordsDao;
import vvpkassistant.Data.ResponseData;
import vvpkassistant.Data.ResponseInfo;
import vvpkassistant.Data.WxChatParam;
import vvpkassistant.FunctionConfig.FunctionConfigHolder;
import vvpkassistant.User.mapper.UserDao;
import vvpkassistant.User.model.UserModel;
import vvpkassistant.config.FunctionConfigHolder;
import vvpkassistant.Tools.VVRequester;
import vvpkassistant.Tools.VVTools;
import vvpkassistant.pk.PkInfoDao;
import vvpkassistant.pk.PkInfoModel;
import vvpkassistant.pk.PkRecordDetail;
import vvpkassistant.pk.PkRecordDetailDao;
import vvpkassistant.pk.mapper.PkInfoDao;
import vvpkassistant.pk.model.PkInfoModel;
import vvpkassistant.pk.model.PkRecordDetail;
import vvpkassistant.pk.mapper.PkRecordDetailDao;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -44,11 +46,11 @@ public class UserController {
public ResponseData<Object> inputUserInfo(@RequestBody Map<String,Object> param) {
if (!param.containsKey("code")) {
return ResponseData.error(ResponseInfo.ERROR, "code不能为空");
return ResponseData.error(ResponseInfo.ERROR.getCode(), "code不能为空");
}
if (!param.containsKey("id")) {
return ResponseData.error(ResponseInfo.ERROR, "id不能为空");
return ResponseData.error(ResponseInfo.ERROR.getCode(), "id不能为空");
}
//获取前端传递过来的code
@@ -62,23 +64,23 @@ public class UserController {
Integer errcode = Integer.valueOf(wx_result.get("errcode").toString());
if (errcode == 45011) {
return ResponseData.error(ResponseInfo.ERROR, "API 调用太频繁，请稍候再试。");
return ResponseData.error(ResponseInfo.ERROR.getCode(), "API 调用太频繁，请稍候再试。");
}
if (errcode == 40029) {
return ResponseData.error(ResponseInfo.ERROR, "js_code 无效");
return ResponseData.error(ResponseInfo.ERROR.getCode(), "js_code 无效");
}
if (errcode == 40226) {
return ResponseData.error(ResponseInfo.ERROR, "该账号为风险用户。禁止登录小程序");
return ResponseData.error(ResponseInfo.ERROR.getCode(), "该账号为风险用户。禁止登录小程序");
}
if (errcode == -1) {
return ResponseData.error(ResponseInfo.ERROR, "系统繁忙");
return ResponseData.error(ResponseInfo.ERROR.getCode(), "系统繁忙");
}
if (!wx_result.containsKey("openid")) {
return ResponseData.error(ResponseInfo.ERROR, "获取用户信息失败，请稍后再试。");
return ResponseData.error(ResponseInfo.ERROR.getCode(), "获取用户信息失败，请稍后再试。");
}
}
@@ -109,7 +111,7 @@ public class UserController {
return ResponseData.success(result);
}
return ResponseData.error(ResponseInfo.ERROR,"未知错误");
return ResponseData.error(ResponseInfo.ERROR.getCode(),"未知错误");
}
// 手机号登录 / 注册
@@ -117,14 +119,14 @@ public class UserController {
public ResponseData<Object> loginWithPhoneNumber(@RequestBody Map<String,Object> param) {
if (!param.containsKey("code")) {
return ResponseData.error(ResponseInfo.ERROR,"code不能为空");
return ResponseData.error(ResponseInfo.ERROR.getCode(),"code不能为空");
}
String code = param.get("code").toString();
String phoneNumber = vvRequester.queryPhoneNumber(code);
if (phoneNumber.isEmpty()) {
return ResponseData.error(ResponseInfo.ERROR,"手机号码无法查询");
return ResponseData.error(ResponseInfo.ERROR.getCode(),"手机号码无法查询");
}
// 查询是否存在用户。如果用户存在直接返回 如果用户不存在则新建用户
@@ -179,7 +181,7 @@ public class UserController {
Map<String,Object> result = new HashMap<>();
result.put("info", userDao.selectById(map.get("id").toString()));
result.put("newAccount", false);
return i == 1 ? ResponseData.success(result) : ResponseData.error(ResponseInfo.ERROR, "");
return i == 1 ? ResponseData.success(result) : ResponseData.error(ResponseInfo.ERROR.getCode(), "");
}
// 获取用户信息
@@ -219,7 +221,7 @@ public class UserController {
// 别人邀请我的pk数据
return ResponseData.success(userDao.getMyGuestPkList(id, page * size, size));
}
return ResponseData.error(ResponseInfo.ERROR,"未知错误");
return ResponseData.error(ResponseInfo.ERROR.getCode(),"未知错误");
}
@@ -237,7 +239,7 @@ public class UserController {
Integer userId = map.get("userId");
int i = userDao.checkSignStatus(userId);
if (i != 0) {
return ResponseData.error(ResponseInfo.ERROR,"当天已签到");
return ResponseData.error(ResponseInfo.ERROR.getCode(),"当天已签到");
}
int result = userDao.signIn(userId);
@@ -256,7 +258,7 @@ public class UserController {
coinRecordsDao.insert(coinRecords);
return ResponseData.success(null);
}else {
return ResponseData.error(ResponseInfo.ERROR,null);
return ResponseData.error(ResponseInfo.ERROR.getCode(),null);
}
}
@@ -303,13 +305,13 @@ public class UserController {
// 返回给前端数据
return ResponseData.success(info);
}else {
return ResponseData.error(ResponseInfo.ERROR,null);
return ResponseData.error(ResponseInfo.ERROR.getCode(),null);
}
}else {
return ResponseData.error(ResponseInfo.ERROR,String.format("积分不足,需要%d积分",totalCoin));
return ResponseData.error(ResponseInfo.ERROR.getCode(),String.format("积分不足,需要%d积分",totalCoin));
}
}else {
return ResponseData.error(ResponseInfo.ERROR,"用户不存在");
return ResponseData.error(ResponseInfo.ERROR.getCode(),"用户不存在");
}
}
@@ -343,7 +345,7 @@ public class UserController {
coinRecordsDao.insert(coinRecords);
return ResponseData.success(String.format("操作成功，返还%d积分",totalCoin));
}else {
return ResponseData.error(ResponseInfo.ERROR,null);
return ResponseData.error(ResponseInfo.ERROR.getCode(),null);
}
}

5
src/main/java/vvpkassistant/User/UserDao.java → src/main/java/vvpkassistant/User/mapper/UserDao.java
View File

@@ -1,11 +1,12 @@
package vvpkassistant.User;
package vvpkassistant.User.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import vvpkassistant.pk.PkRecord;
import vvpkassistant.User.model.UserModel;
import vvpkassistant.pk.model.PkRecord;
import java.util.List;
@Mapper

2
src/main/java/vvpkassistant/User/UserModel.java → src/main/java/vvpkassistant/User/model/UserModel.java
View File

@@ -1,4 +1,4 @@
package vvpkassistant.User;
package vvpkassistant.User.model;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;

6
src/main/java/vvpkassistant/chat/ChatController.java → src/main/java/vvpkassistant/chat/controller/ChatController.java
View File

@@ -1,10 +1,12 @@
package vvpkassistant.chat;
package vvpkassistant.chat.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import vvpkassistant.Data.ResponseData;
import vvpkassistant.Data.ResponseInfo;
import vvpkassistant.chat.mapper.ChatDao;
import vvpkassistant.chat.model.ChatModel;
import java.util.HashMap;
import java.util.Map;
@@ -20,7 +22,7 @@ public class ChatController {
@PostMapping("add")
public ResponseData<Object> add(@RequestBody ChatModel model) {
int insert = chatDao.insert(model);
return insert == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR,null);
return insert == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR.getCode(),null);
}
//根据ip查询数据

3
src/main/java/vvpkassistant/chat/ChatDao.java → src/main/java/vvpkassistant/chat/mapper/ChatDao.java
View File

@@ -1,9 +1,10 @@
package vvpkassistant.chat;
package vvpkassistant.chat.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import vvpkassistant.chat.model.ChatModel;
@Mapper
public interface ChatDao extends BaseMapper<ChatModel> {

2
src/main/java/vvpkassistant/chat/ChatModel.java → src/main/java/vvpkassistant/chat/model/ChatModel.java
View File

@@ -1,4 +1,4 @@
package vvpkassistant.chat;
package vvpkassistant.chat.model;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;

41
src/main/java/vvpkassistant/common/ErrorCode.java Normal file
View File

@@ -0,0 +1,41 @@
package vvpkassistant.common;
import lombok.Getter;
@Getter
public enum ErrorCode {
SUCCESS(0, "ok"),
ADD_FAILED(1, "添加失败"),
DELETE_FAILED(2, "删除失败"),
UPDATE_FAILED(2, "删除失败"),
ANCHOR_ALREADY_EXISTS(101,"主播已存在"),
ANCHOR_HAS_PKRECORD(102,"主播存在PK记录"),
SYSTEM_ERROR(50000, "系统错误"),
PARAMS_ERROR(40000, "请求参数错误")
;
/**
* 状态码
*/
private final int code;
/**
* 信息
*/
private final String message;
ErrorCode(int code, String message) {
this.code = code;
this.message = message;
}
public int getCode() {
return code;
}
public String getMessage() {
return message;
}
}

7
src/main/java/vvpkassistant/FunctionConfig/FunctionConfigHolder.java → src/main/java/vvpkassistant/config/FunctionConfigHolder.java
View File

@@ -1,8 +1,9 @@
package vvpkassistant.FunctionConfig;
package vvpkassistant.config;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
import vvpkassistant.FunctionConfig.mapper.FunctionConfigMapper;
import vvpkassistant.FunctionConfig.model.FunctionConfigModel;
import javax.annotation.PostConstruct;
import java.util.List;
@@ -12,7 +13,7 @@ import java.util.concurrent.CopyOnWriteArrayList;
@RequiredArgsConstructor
public class FunctionConfigHolder {
// 线程安全的全局配置容器
static final List<FunctionConfigModel> CONFIGS = new CopyOnWriteArrayList<>();
public static final List<FunctionConfigModel> CONFIGS = new CopyOnWriteArrayList<>();
@Autowired
private FunctionConfigMapper configMapper;

32
src/main/java/vvpkassistant/exception/BusinessException.java Normal file
View File

@@ -0,0 +1,32 @@
package vvpkassistant.exception;
import vvpkassistant.common.ErrorCode;
public class BusinessException extends RuntimeException {
/**
* 错误码
*/
private final int code;
public BusinessException(int code, String message) {
super(message);
this.code = code;
}
public BusinessException(ErrorCode errorCode) {
super(errorCode.getMessage());
this.code = errorCode.getCode();
}
public BusinessException(ErrorCode errorCode, String message) {
super(message);
this.code = errorCode.getCode();
}
public int getCode() {
return code;
}
}

33
src/main/java/vvpkassistant/exception/GlobalExceptionHandler.java Normal file
View File

@@ -0,0 +1,33 @@
package vvpkassistant.exception;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import vvpkassistant.Data.ResponseData;
import vvpkassistant.Data.ResponseInfo;
import vvpkassistant.common.ErrorCode;
/**
* 全局异常处理器
*
* @author <a href="https://github.com/liyupi">程序员鱼皮</a>
* @from <a href="https://yupi.icu">编程导航知识星球</a>
*/
@RestControllerAdvice
@Slf4j
public class GlobalExceptionHandler {
@ExceptionHandler(BusinessException.class)
public ResponseData<?> businessExceptionHandler(BusinessException e) {
log.error("BusinessException", e);
return ResponseData.error(e.getCode(), e.getMessage());
}
@ExceptionHandler(RuntimeException.class)
public ResponseData<?> runtimeExceptionHandler(RuntimeException e) {
log.error("RuntimeException", e);
return ResponseData.error(ErrorCode.SYSTEM_ERROR);
}
}

46
src/main/java/vvpkassistant/exception/ThrowUtils.java Normal file
View File

@@ -0,0 +1,46 @@
package vvpkassistant.exception;
import vvpkassistant.common.ErrorCode;
/**
* 抛异常工具类
*
* @author <a href="https://github.com/liyupi">程序员鱼皮</a>
* @from <a href="https://yupi.icu">编程导航知识星球</a>
*/
public class ThrowUtils {
/**
* 条件成立则抛异常
*
* @param condition
* @param runtimeException
*/
public static void throwIf(boolean condition, RuntimeException runtimeException) {
if (condition) {
throw runtimeException;
}
}
/**
* 条件成立则抛异常
*
* @param condition
* @param errorCode
*/
public static void throwIf(boolean condition, ErrorCode errorCode) {
throwIf(condition, new BusinessException(errorCode));
}
/**
* 条件成立则抛异常
*
* @param condition
* @param errorCode
* @param message
*/
public static void throwIf(boolean condition, ErrorCode errorCode, String message) {
throwIf(condition, new BusinessException(errorCode, message));
}
}

38
src/main/java/vvpkassistant/pk/PkController.java → src/main/java/vvpkassistant/pk/controller/PkController.java
View File

@@ -1,14 +1,20 @@
package vvpkassistant.pk;
package vvpkassistant.pk.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import vvpkassistant.CoinRecords.CoinRecords;
import vvpkassistant.CoinRecords.CoinRecordsDao;
import vvpkassistant.Data.ResponseData;
import vvpkassistant.Data.ResponseInfo;
import vvpkassistant.FunctionConfig.FunctionConfigHolder;
import vvpkassistant.config.FunctionConfigHolder;
import vvpkassistant.Tools.VVTools;
import vvpkassistant.User.UserDao;
import vvpkassistant.User.UserModel;
import vvpkassistant.User.mapper.UserDao;
import vvpkassistant.User.model.UserModel;
import vvpkassistant.pk.mapper.PkInfoDao;
import vvpkassistant.pk.mapper.PkRecordDao;
import vvpkassistant.pk.mapper.PkRecordDetailDao;
import vvpkassistant.pk.model.PkInfoModel;
import vvpkassistant.pk.model.PkRecord;
import vvpkassistant.pk.model.PkRecordDetail;
import java.util.List;
import java.util.Map;
@@ -57,11 +63,11 @@ public class PkController {
// 判断该主播在当日是否已发布过pk信息
if (pkInfoModels.size() > 0) {
return ResponseData.error(ResponseInfo.ERROR,"该主播当日已有pk信息");
return ResponseData.error(ResponseInfo.ERROR.getCode(),"该主播当日已有pk信息");
}
int insert = pkDao.insert(pkModel);
return insert == 1 ? ResponseData.success(pkModel) : ResponseData.error(ResponseInfo.ERROR,null);
return insert == 1 ? ResponseData.success(pkModel) : ResponseData.error(ResponseInfo.ERROR.getCode(),null);
}
// 更新pk信息
@@ -118,7 +124,7 @@ public class PkController {
// 更新pk邀请记录
int update = recordDao.updateById(recordModel);
return update == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR,null);
return update == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR.getCode(),null);
}
// 创建PK记录
@@ -131,12 +137,12 @@ public class PkController {
Integer dataCount = recordDao.getPendingInvitations(anchorIdA, anchorIdB);
if (dataCount > 0) {
return ResponseData.error(ResponseInfo.ERROR,"已存在一条未处理的pk申请，不能重复发送，");
return ResponseData.error(ResponseInfo.ERROR.getCode(),"已存在一条未处理的pk申请，不能重复发送，");
}
record.setPkStatus(0);
int insert = recordDao.insert(record);
return insert == 1 ? ResponseData.success(record) : ResponseData.error(ResponseInfo.ERROR,null);
return insert == 1 ? ResponseData.success(record) : ResponseData.error(ResponseInfo.ERROR.getCode(),null);
}
// pk列表
@@ -214,7 +220,7 @@ public class PkController {
PkInfoModel pkInfoModel = pkDao.selectById(id);
if (pkInfoModel == null) {
return ResponseData.error(ResponseInfo.ERROR,"该信息不存在");
return ResponseData.error(ResponseInfo.ERROR.getCode(),"该信息不存在");
}
if (from == 1) {
@@ -233,7 +239,7 @@ public class PkController {
}
return ResponseData.success(pkInfoModel);
}else {
return ResponseData.error(ResponseInfo.ERROR,"当前信息已无效");
return ResponseData.error(ResponseInfo.ERROR.getCode(),"当前信息已无效");
}
}else{
Integer isHave = pkDao.checkIfUnfinishedPKExistsWithAnchor(userId, pkInfoModel.getAnchorId());
@@ -253,18 +259,18 @@ public class PkController {
PkInfoModel pkInfoModel = pkDao.selectById(id);
if (pkInfoModel.getPinExpireTime() > VVTools.currentTimeStamp()) {
return ResponseData.error(ResponseInfo.ERROR,"该信息在置顶中。如要删除清先取消置顶");
return ResponseData.error(ResponseInfo.ERROR.getCode(),"该信息在置顶中。如要删除清先取消置顶");
}
Integer result = pkDao.deletePkDataWithId(id);
return result == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR,"删除数据失败");
return result == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR.getCode(),"删除数据失败");
}
//修改pk信息内容
@PostMapping("updatePkInfoById")
public ResponseData<Object> updatePkInfoById(@RequestBody PkInfoModel infoModel) {
int result = pkDao.updateById(infoModel);
return result == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR,null);
return result == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR.getCode(),null);
}
// 根据id查询pk记录
@@ -312,7 +318,7 @@ public class PkController {
@PostMapping("updatePkRecordInfo")
public ResponseData<Object> updatePkRecordInfo(@RequestBody PkRecord record) {
int i = recordDao.updateById(record);
return i == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR,null);
return i == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR.getCode(),null);
}
// 插入pk明细表数据
@@ -320,7 +326,7 @@ public class PkController {
public ResponseData<Object> insert(@RequestBody PkRecordDetail detail) {
detail.setCreateTime(VVTools.currentTimeStamp());
int insert = detailDao.insert(detail);
return insert == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR,null);
return insert == 1 ? ResponseData.success("") : ResponseData.error(ResponseInfo.ERROR.getCode(),null);
}
}

3
src/main/java/vvpkassistant/pk/PkInfoDao.java → src/main/java/vvpkassistant/pk/mapper/PkInfoDao.java
View File

@@ -1,7 +1,8 @@
package vvpkassistant.pk;
package vvpkassistant.pk.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.*;
import org.jetbrains.annotations.Nullable;
import vvpkassistant.pk.model.PkInfoModel;
import java.util.List;
import java.util.Map;

5
src/main/java/vvpkassistant/pk/PkRecordDao.java → src/main/java/vvpkassistant/pk/mapper/PkRecordDao.java
View File

@@ -1,9 +1,12 @@
package vvpkassistant.pk;
package vvpkassistant.pk.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import vvpkassistant.pk.model.PkRecordDetail;
import vvpkassistant.pk.model.PkRecord;
import java.util.List;

3
src/main/java/vvpkassistant/pk/PkRecordDetailDao.java → src/main/java/vvpkassistant/pk/mapper/PkRecordDetailDao.java
View File

@@ -1,9 +1,10 @@
package vvpkassistant.pk;
package vvpkassistant.pk.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import vvpkassistant.pk.model.PkRecordDetail;
import java.util.List;

2
src/main/java/vvpkassistant/pk/PkInfoModel.java → src/main/java/vvpkassistant/pk/model/PkInfoModel.java
View File

@@ -1,4 +1,4 @@
package vvpkassistant.pk;
package vvpkassistant.pk.model;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;

2
src/main/java/vvpkassistant/pk/PkRecord.java → src/main/java/vvpkassistant/pk/model/PkRecord.java
View File

@@ -1,4 +1,4 @@
package vvpkassistant.pk;
package vvpkassistant.pk.model;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;

2
src/main/java/vvpkassistant/pk/PkRecordDetail.java → src/main/java/vvpkassistant/pk/model/PkRecordDetail.java
View File

@@ -1,4 +1,4 @@
package vvpkassistant.pk;
package vvpkassistant.pk.model;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;

4
src/main/resources/application-local.yml
View File

@@ -4,8 +4,8 @@ spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: wfn53400
url: jdbc:mysql://mysql.text.zhukeping.com:3326/vv_assistant?allowMultiQueries=true
password: 123asd
url: jdbc:mysql://localhost:3306/vv_assistant?allowMultiQueries=true
chat:

2
src/main/resources/application.yml
View File

@@ -3,7 +3,7 @@ server:
spring:
profiles:
active: dev
active: local

4
target/classes/application-local.yml
View File

@@ -4,8 +4,8 @@ spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: wfn53400
url: jdbc:mysql://mysql.text.zhukeping.com:3326/vv_assistant?allowMultiQueries=true
password: 123asd
url: jdbc:mysql://localhost:3306/vv_assistant?allowMultiQueries=true
chat:

2
target/classes/application.yml
View File

@@ -3,7 +3,7 @@ server:
spring:
profiles:
active: dev
active: local

17
vvPkAssistant.iml
View File

@@ -1,17 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<module version="4">
<component name="FacetManager">
<facet type="web" name="Web">
<configuration>
<webroots />
<sourceRoots>
<root url="file://$MODULE_DIR$/src/main/java" />
<root url="file://$MODULE_DIR$/src/main/resources" />
</sourceRoots>
</configuration>
</facet>
<facet type="Spring" name="Spring">
<configuration />
</facet>
<component name="AdditionalModuleElements">
<content url="file://$MODULE_DIR$" dumb="true">
<excludeFolder url="file://$MODULE_DIR$/.idea/dataSources" />
</content>
</component>
</module>