From fcffced7184a04f15fa95aa47c0e2dfcbc0dbad4 Mon Sep 17 00:00:00 2001 From: eric <465889110@qq.com> Date: Sun, 17 Aug 2025 14:11:08 +0800 Subject: [PATCH] no message --- .gitignore | 35 +++ Dockerfile | 10 + Dockerfile.buildagent | 15 ++ Jenkinsfile | 85 +++++++ README.md | 1 + pom.xml | 234 ++++++++++++++++++ settings.xml | 12 + src/main/java/com/sczx/sync/Application.java | 29 +++ .../java/com/sczx/sync/common/IApiCode.java | 12 + .../java/com/sczx/sync/common/Result.java | 123 +++++++++ .../sczx/sync/common/enums/ApiErrorCode.java | 55 ++++ .../common/enums/MiniProgramTypeEnum.java | 19 ++ .../sczx/sync/common/enums/YesOrNoEnum.java | 20 ++ .../com/sczx/sync/config/AsyncConfig.java | 54 ++++ .../sczx/sync/config/MyBatisPlusConfig.java | 18 ++ .../com/sczx/sync/config/SwaggerConfig.java | 47 ++++ .../sczx/sync/config/ThirdPartyConfig.java | 25 ++ .../controller/ReceiveBatteryController.java | 49 ++++ .../sync/controller/SendDataController.java | 86 +++++++ .../java/com/sczx/sync/dto/DataRceiveReq.java | 22 ++ .../com/sczx/sync/dto/ReceiveMealReq.java | 22 ++ .../java/com/sczx/sync/entity/Response.java | 31 +++ .../com/sczx/sync/exception/BizException.java | 85 +++++++ .../exception/GlobalExceptionHandler.java | 50 ++++ .../sczx/sync/exception/InnerException.java | 86 +++++++ .../sczx/sync/mapper/BatteryMealMapper.java | 13 + .../sczx/sync/mapper/CompanyStoreMapper.java | 13 + .../sync/mapper/DataReceiveRecordMapper.java | 14 ++ .../java/com/sczx/sync/po/DataReceivePo.java | 101 ++++++++ .../java/com/sczx/sync/po/SyncDataInfo.java | 150 +++++++++++ .../java/com/sczx/sync/po/SyncRequest.java | 42 ++++ .../com/sczx/sync/service/ReceiveService.java | 8 + .../sczx/sync/service/SendDataService.java | 28 +++ .../service/ThirdPartyForwardService.java | 12 + .../sync/service/impl/ReceiveServiceImpl.java | 65 +++++ .../service/impl/SendDataServiceImpl.java | 197 +++++++++++++++ .../impl/ThirdPartyForwardServiceImpl.java | 112 +++++++++ .../com/sczx/sync/utils/ComputerInfo.java | 159 ++++++++++++ src/main/resources/application.yml | 69 ++++++ src/main/resources/doc/dbInit.sql | 40 +++ src/main/resources/logback.xml | 53 ++++ src/main/resources/mapper/BatteryMeal.xml | 59 +++++ .../resources/mapper/CompanyStoreMapper.xml | 18 ++ 43 files changed, 2378 insertions(+) create mode 100644 .gitignore create mode 100644 Dockerfile create mode 100644 Dockerfile.buildagent create mode 100644 Jenkinsfile create mode 100644 README.md create mode 100644 pom.xml create mode 100644 settings.xml create mode 100644 src/main/java/com/sczx/sync/Application.java create mode 100644 src/main/java/com/sczx/sync/common/IApiCode.java create mode 100644 src/main/java/com/sczx/sync/common/Result.java create mode 100644 src/main/java/com/sczx/sync/common/enums/ApiErrorCode.java create mode 100644 src/main/java/com/sczx/sync/common/enums/MiniProgramTypeEnum.java create mode 100644 src/main/java/com/sczx/sync/common/enums/YesOrNoEnum.java create mode 100644 src/main/java/com/sczx/sync/config/AsyncConfig.java create mode 100644 src/main/java/com/sczx/sync/config/MyBatisPlusConfig.java create mode 100644 src/main/java/com/sczx/sync/config/SwaggerConfig.java create mode 100644 src/main/java/com/sczx/sync/config/ThirdPartyConfig.java create mode 100644 src/main/java/com/sczx/sync/controller/ReceiveBatteryController.java create mode 100644 src/main/java/com/sczx/sync/controller/SendDataController.java create mode 100644 src/main/java/com/sczx/sync/dto/DataRceiveReq.java create mode 100644 src/main/java/com/sczx/sync/dto/ReceiveMealReq.java create mode 100644 src/main/java/com/sczx/sync/entity/Response.java create mode 100644 src/main/java/com/sczx/sync/exception/BizException.java create mode 100644 src/main/java/com/sczx/sync/exception/GlobalExceptionHandler.java create mode 100644 src/main/java/com/sczx/sync/exception/InnerException.java create mode 100644 src/main/java/com/sczx/sync/mapper/BatteryMealMapper.java create mode 100644 src/main/java/com/sczx/sync/mapper/CompanyStoreMapper.java create mode 100644 src/main/java/com/sczx/sync/mapper/DataReceiveRecordMapper.java create mode 100644 src/main/java/com/sczx/sync/po/DataReceivePo.java create mode 100644 src/main/java/com/sczx/sync/po/SyncDataInfo.java create mode 100644 src/main/java/com/sczx/sync/po/SyncRequest.java create mode 100644 src/main/java/com/sczx/sync/service/ReceiveService.java create mode 100644 src/main/java/com/sczx/sync/service/SendDataService.java create mode 100644 src/main/java/com/sczx/sync/service/ThirdPartyForwardService.java create mode 100644 src/main/java/com/sczx/sync/service/impl/ReceiveServiceImpl.java create mode 100644 src/main/java/com/sczx/sync/service/impl/SendDataServiceImpl.java create mode 100644 src/main/java/com/sczx/sync/service/impl/ThirdPartyForwardServiceImpl.java create mode 100644 src/main/java/com/sczx/sync/utils/ComputerInfo.java create mode 100644 src/main/resources/application.yml create mode 100644 src/main/resources/doc/dbInit.sql create mode 100644 src/main/resources/logback.xml create mode 100644 src/main/resources/mapper/BatteryMeal.xml create mode 100644 src/main/resources/mapper/CompanyStoreMapper.xml diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..0d7f4db --- /dev/null +++ b/.gitignore @@ -0,0 +1,35 @@ +HELP.md +target/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### STS ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### IntelliJ IDEA ### +.idea +*.iws +*.iml +*.ipr + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ +logs/ +src/main/resources/rebel.xml diff --git a/Dockerfile b/Dockerfile new file mode 100644 index 0000000..fd863fa --- /dev/null +++ b/Dockerfile @@ -0,0 +1,10 @@ +# 使用 OpenJDK 8 镜像构建 +FROM openjdk:8-jdk +# 添加作者信息 +LABEL maintainer="123879394@qq.com" + +WORKDIR /app +# 复制 jar 包 +COPY target/*.jar app.jar +# 设置 JVM 参数和启动命令 +ENTRYPOINT ["java", "-jar", "-Xms64m", "-Xmx128m", "app.jar"] \ No newline at end of file diff --git a/Dockerfile.buildagent b/Dockerfile.buildagent new file mode 100644 index 0000000..f893f6c --- /dev/null +++ b/Dockerfile.buildagent @@ -0,0 +1,15 @@ +# 使用 JDK 8 作为构建环境 +FROM openjdk:8-jdk + +# 使用阿里云的 apt 镜像源（Debian 11 bullseye） +RUN sed -i 's/deb.debian.org/mirrors.aliyun.com/g' /etc/apt/sources.list && \ + sed -i 's/security.debian.org/mirrors.aliyun.com/g' /etc/apt/sources.list + +# 更新包列表并安装 Maven 和 Git +RUN apt update && \ + apt install -y maven git && \ + mvn --version && \ + git --version + +# 设置工作目录 +WORKDIR /home/jenkins/workspace \ No newline at end of file diff --git a/Jenkinsfile b/Jenkinsfile new file mode 100644 index 0000000..c65a3ea --- /dev/null +++ b/Jenkinsfile @@ -0,0 +1,85 @@ +pipeline { + agent any +// tools { +// maven 'M3' // 必须在 Jenkins → Manage Jenkins → Global Tool Configuration 中配置过 +// } + environment { + APP_NAME = "sczx_sync" + DOCKER_IMAGE = "${APP_NAME}:latest" + CONTAINER_NAME = "${APP_NAME}-container" + } + + stages { +// stage('Checkout') { +// steps { +// echo "📦 正在拉取代码..." +// git branch: 'main', url: 'http://115.190.8.52:3000/sczx_group/sczx_order.git' +// } +// } + + stage('Build with Maven in JDK 8') { + agent { + dockerfile { + filename "Dockerfile.buildagent" + } + } + steps { + echo "🛠️ 正在使用 Maven 构建..." + sh 'mvn clean package -s settings.xml' + } + } + + stage('Check Jar File') { + agent any + steps { + sh 'ls -la target/' // 确保 jar 文件存在 + } + } + + stage('Build Docker Image') { + agent any + steps { + echo "🐋 正在构建 Docker 镜像..." + sh 'docker build -t "$DOCKER_IMAGE" .' + } + } + + stage('Stop Old Container') { + agent any + steps { + echo "🛑 正在停止旧的容器（如果存在）..." + sh ''' + if [ "$(docker ps -f 'name=sczx_sync-container' --format '{{.Status}}')" ]; then + docker stop sczx_sync-container + docker rm sczx_sync-container + fi + ''' + } + } + + stage('Run New Container') { + agent any + steps { + echo "🟢 正在运行新的容器..." + sh """ + docker run -d \ + --name \${CONTAINER_NAME} \ + --network sczx-net \ + -p 8016:8016 \ + -e JAVA_OPTS="-Xms256m -Xmx512m -Duser.timezone=Asia/Shanghai" \ + --restart always \ + \${DOCKER_IMAGE} + """ + } + } + } + + post { + success { + echo "🎉 构建成功！" + } + failure { + echo "❌ 构建失败，请检查日志！" + } + } +} \ No newline at end of file diff --git a/README.md b/README.md new file mode 100644 index 0000000..ea786ff --- /dev/null +++ b/README.md @@ -0,0 +1 @@ +readme \ No newline at end of file diff --git a/pom.xml b/pom.xml new file mode 100644 index 0000000..af8a580 --- /dev/null +++ b/pom.xml @@ -0,0 +1,234 @@ + + + 4.0.0 + + com.sczx + sczx_sync + 1.0.0 + jar + + sczx_sync + sczx_sync service + + + 1.8 + 2.3.12.RELEASE + Hoxton.SR12 + 2.2.9.RELEASE + + + + + org.springframework.boot + spring-boot-starter-parent + 2.3.12.RELEASE + + + + + + + + + org.springframework.cloud + spring-cloud-dependencies + ${spring-cloud.version} + pom + import + + + + + com.alibaba.cloud + spring-cloud-alibaba-dependencies + ${spring-cloud-alibaba.version} + pom + import + + + + + + + + + org.springframework.boot + spring-boot-starter + + + + + org.springframework.boot + spring-boot-starter-web + + + + + org.springframework.boot + spring-boot-starter-actuator + + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-discovery + + + + org.springframework.boot + spring-boot-configuration-processor + + + + org.springframework.cloud + spring-cloud-commons + + + + + org.projectlombok + lombok + 1.18.30 + + + + + + org.springframework.retry + spring-retry + 1.3.1 + + + + org.springframework.boot + spring-boot-starter-aop + + + + + org.mybatis.spring.boot + mybatis-spring-boot-starter + 2.3.1 + + + + + com.baomidou + mybatis-plus-boot-starter + 3.5.3.1 + + + + + + mysql + mysql-connector-java + 8.0.33 + + + + + io.springfox + springfox-swagger2 + 2.9.2 + + + + io.springfox + springfox-swagger-ui + 2.9.2 + + + + + javax.xml.bind + jaxb-api + 2.3.1 + + + + io.projectreactor + reactor-core + 3.2.2.RELEASE + + + + + org.mapstruct + mapstruct + 1.5.5.Final + + + + + org.mapstruct + mapstruct-processor + 1.5.5.Final + provided + + + + + com.alibaba + fastjson + 1.2.83 + + + + + + sczx_sync + + + src/main/resources + + *.yml + + true + + + src/main/resources + + *.yml + + + + + + + org.apache.maven.plugins + maven-compiler-plugin + + ${java.version} + ${java.version} + + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + repackage + + + + + + org.apache.maven.plugins + maven-source-plugin + + + org.apache.maven.plugins + maven-deploy-plugin + + true + + + + + + \ No newline at end of file diff --git a/settings.xml b/settings.xml new file mode 100644 index 0000000..06004f8 --- /dev/null +++ b/settings.xml @@ -0,0 +1,12 @@ + + + + aliyun-maven + * + Aliyun Maven + https://maven.aliyun.com/repository/public + + + \ No newline at end of file diff --git a/src/main/java/com/sczx/sync/Application.java b/src/main/java/com/sczx/sync/Application.java new file mode 100644 index 0000000..f307db1 --- /dev/null +++ b/src/main/java/com/sczx/sync/Application.java @@ -0,0 +1,29 @@ +package com.sczx.sync; + +import com.sczx.sync.utils.ComputerInfo; +import lombok.extern.slf4j.Slf4j; +import org.mybatis.spring.annotation.MapperScan; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.cloud.client.discovery.EnableDiscoveryClient; +import org.springframework.context.ConfigurableApplicationContext; +import org.springframework.core.env.Environment; +import org.springframework.retry.annotation.EnableRetry; +import org.springframework.transaction.annotation.EnableTransactionManagement; + +import java.io.IOException; + +@Slf4j +@SpringBootApplication +@EnableDiscoveryClient // 启用服务注册与发现 +@EnableRetry +@EnableTransactionManagement +@MapperScan("com.sczx.sync.mapper") // 扫描 Mapper 接口 +public class Application { + + public static void main(String[] args) throws IOException { + ConfigurableApplicationContext context = SpringApplication.run(Application.class, args); + Environment environment = context.getBean(Environment.class); + log.info("启动成功，后端服务API地址：http://{}:{}/swagger-ui.html", ComputerInfo.getIpAddr(), environment.getProperty("server.port")); + } +} diff --git a/src/main/java/com/sczx/sync/common/IApiCode.java b/src/main/java/com/sczx/sync/common/IApiCode.java new file mode 100644 index 0000000..5243b0f --- /dev/null +++ b/src/main/java/com/sczx/sync/common/IApiCode.java @@ -0,0 +1,12 @@ +package com.sczx.sync.common; + +/** + * @Author: 张黎 + * @Date: 2025/07/09/20:20 + * @Description: + */ +public interface IApiCode { + String getCode(); + + String getMsg(); +} diff --git a/src/main/java/com/sczx/sync/common/Result.java b/src/main/java/com/sczx/sync/common/Result.java new file mode 100644 index 0000000..9126fd9 --- /dev/null +++ b/src/main/java/com/sczx/sync/common/Result.java @@ -0,0 +1,123 @@ +package com.sczx.sync.common; + + + + +import com.sczx.sync.common.enums.ApiErrorCode; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Builder; +import lombok.Data; +import org.apache.commons.lang.StringUtils; + +import java.io.Serializable; +import java.util.HashMap; +import java.util.Map; + +/** + * @Author: 张黎 + * @Date: 2025/07/09/20:25 + * @Description: + */ +@ApiModel(value = "公共返回结果") +@Builder +@Data +public class Result implements Serializable { + private static final long serialVersionUID = 1331134667810352183L; + @ApiModelProperty(value = "成功标识") + private boolean success; + @ApiModelProperty(value = "返回编码") + private String code; + @ApiModelProperty(value = "返回信息说明") + private String msg; + private String issue; + @ApiModelProperty(value = "返回数据") + private T data; + + public Result(boolean success, String code, String msg, String issue, T data) { + this.success = success; + this.code = code; + this.msg = msg; + this.issue = issue; + this.data = data; + } + + public static Result result(IApiCode apiCode) { + return result(apiCode, (Object)null); + } + + public static Result result(IApiCode apiCode, Object data) { + return result(apiCode, apiCode.getMsg(), data); + } + + public static Result result(IApiCode apiCode, String issue, Object data) { + return result((IApiCode)apiCode, (String)null, issue, data); + } + + public static Result result(IApiCode apiCode, String msg, String issue, Object data) { + String message = apiCode.getMsg(); + if (StringUtils.isNotBlank(msg)) { + message = msg; + } + + return result(apiCode.getCode(), message, issue, data); + } + + public static Result result(String code, String msg, String issue, Object data) { + return builder().code(code).success("0".equals(code)).msg(msg).issue(issue).data(data).build(); + } + + public static Result ok() { + return ok((Object)null); + } + + public static Result ok(Object data) { + return result(ApiErrorCode.SUCCESS, data); + } + + public static Result ok(String key, Object value) { + Map map = new HashMap(1); + map.put(key, value); + return ok(map); + } + + public static Result fail(String msg) { + return result((IApiCode)ApiErrorCode.FAIL, msg, msg, (Object)null); + } + + public static Result fail(IApiCode apiCode) { + return result(apiCode, (Object)null); + } + + public static Result fail(IApiCode apiCode, String issue) { + return result(apiCode, issue, (Object)null); + } + + public static Result fail(String code, String msg) { + return result((String)code, msg, msg, (Object)null); + } + + public static Result fail(String code, String msg, String issue) { + return result((String)code, msg, issue, (Object)null); + } + + public static Result fail(String code, String msg, String issue, Object data) { + return result(code, msg, issue, data); + } + + public static Result fail(IApiCode apiCode, String issue, Object data) { + if (ApiErrorCode.SUCCESS == apiCode) { + throw new RuntimeException("失败结果状态码不能为" + ApiErrorCode.SUCCESS.getCode()); + } else { + return result(apiCode, issue, data); + } + } + + public static Result fail(String key, Object value) { + Map map = new HashMap(); + map.put(key, value); + return result(ApiErrorCode.FAIL, map); + } + public Result() { + } +} diff --git a/src/main/java/com/sczx/sync/common/enums/ApiErrorCode.java b/src/main/java/com/sczx/sync/common/enums/ApiErrorCode.java new file mode 100644 index 0000000..a3e2256 --- /dev/null +++ b/src/main/java/com/sczx/sync/common/enums/ApiErrorCode.java @@ -0,0 +1,55 @@ +package com.sczx.sync.common.enums; + + +import com.sczx.sync.common.IApiCode; + +/** + * @Author: 张黎 + * @Date: 2025/07/09/20:22 + * @Description: + */ +public enum ApiErrorCode implements IApiCode { + SUCCESS("0", "操作成功"), + ARG_ERROR("401000", "参数错误"), + NOT_PERMISSION("401001", "没有权限"), + HTTP_MEDIA_TYPE_NOT_SUPPORTED_ERROR("401002", "media类型出错"), + HTTP_METHOD_NOT_ALLOW_ERROR("401003", "http请求method错误"), + BODY_NOT_MATCH("401004", "请求的数据格式不符!"), + NOT_FOUND("404000", "你请求的路径不存在"), + UNAUTHORIZED("404001", "非法访问"), + FAIL("500000", "操作失败"), + INNER_ERROR("500001", "服务器内部异常"); + + private final String code; + private final String msg; + + private ApiErrorCode(String code, String msg) { + this.code = code; + this.msg = msg; + } + + public static ApiErrorCode getApiCode(String code) { + ApiErrorCode[] ecs = values(); + ApiErrorCode[] var2 = ecs; + int var3 = ecs.length; + + for(int var4 = 0; var4 < var3; ++var4) { + ApiErrorCode ec = var2[var4]; + if (ec.getCode().equals(code)) { + return ec; + } + } + + return SUCCESS; + } + + @Override + public String getCode() { + return this.code; + } + + @Override + public String getMsg() { + return this.msg; + } +} diff --git a/src/main/java/com/sczx/sync/common/enums/MiniProgramTypeEnum.java b/src/main/java/com/sczx/sync/common/enums/MiniProgramTypeEnum.java new file mode 100644 index 0000000..d906938 --- /dev/null +++ b/src/main/java/com/sczx/sync/common/enums/MiniProgramTypeEnum.java @@ -0,0 +1,19 @@ +package com.sczx.sync.common.enums; + +import lombok.Getter; + +/** + * 小程序类型枚举 + */ +@Getter +public enum MiniProgramTypeEnum { + WECHAT("wechat"), + ALIPAY("alipay"); + + private final String type; + + MiniProgramTypeEnum(String type) { + this.type = type; + } + +} diff --git a/src/main/java/com/sczx/sync/common/enums/YesOrNoEnum.java b/src/main/java/com/sczx/sync/common/enums/YesOrNoEnum.java new file mode 100644 index 0000000..7e8bb9d --- /dev/null +++ b/src/main/java/com/sczx/sync/common/enums/YesOrNoEnum.java @@ -0,0 +1,20 @@ +package com.sczx.sync.common.enums; + +import lombok.AllArgsConstructor; +import lombok.Getter; + +/** + * @Author: 张黎 + * @Date: 2024/03/08/17:42 + * @Description: 报考场次:统考unified,区域专场areaSpecial + */ +@AllArgsConstructor +@Getter +public enum YesOrNoEnum { + YES(1, "是"), + NO(0, "否"), + ; + private final Integer code; + + private final String msg; +} diff --git a/src/main/java/com/sczx/sync/config/AsyncConfig.java b/src/main/java/com/sczx/sync/config/AsyncConfig.java new file mode 100644 index 0000000..3821d74 --- /dev/null +++ b/src/main/java/com/sczx/sync/config/AsyncConfig.java @@ -0,0 +1,54 @@ +package com.sczx.sync.config; + +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.scheduling.annotation.EnableAsync; +import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; + +import java.util.concurrent.Executor; +import java.util.concurrent.ThreadPoolExecutor; + +/** + * 异步配置类 + * + * @author sczx + */ +@Configuration +@EnableAsync +public class AsyncConfig { + + /** + * 异步任务执行器 + */ + @Bean("taskExecutor") + public Executor taskExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + + // 核心线程数 + executor.setCorePoolSize(10); + + // 最大线程数 + executor.setMaxPoolSize(20); + + // 队列容量 + executor.setQueueCapacity(500); + + // 线程空闲时间 + executor.setKeepAliveSeconds(60); + + // 线程名前缀 + executor.setThreadNamePrefix("async-task-"); + + // 拒绝策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + + // 等待所有任务结束后再关闭线程池 + executor.setWaitForTasksToCompleteOnShutdown(true); + + // 等待时间 + executor.setAwaitTerminationSeconds(60); + + executor.initialize(); + return executor; + } +} diff --git a/src/main/java/com/sczx/sync/config/MyBatisPlusConfig.java b/src/main/java/com/sczx/sync/config/MyBatisPlusConfig.java new file mode 100644 index 0000000..a97e3f0 --- /dev/null +++ b/src/main/java/com/sczx/sync/config/MyBatisPlusConfig.java @@ -0,0 +1,18 @@ +package com.sczx.sync.config; + +import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor; +import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +@Configuration +public class MyBatisPlusConfig { + + + @Bean + public MybatisPlusInterceptor mybatisPlusInterceptor() { + MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); + interceptor.addInnerInterceptor(new PaginationInnerInterceptor()); + return interceptor; + } +} diff --git a/src/main/java/com/sczx/sync/config/SwaggerConfig.java b/src/main/java/com/sczx/sync/config/SwaggerConfig.java new file mode 100644 index 0000000..4b9bcfb --- /dev/null +++ b/src/main/java/com/sczx/sync/config/SwaggerConfig.java @@ -0,0 +1,47 @@ +package com.sczx.sync.config; + + +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import springfox.documentation.builders.ApiInfoBuilder; +import springfox.documentation.builders.ParameterBuilder; +import springfox.documentation.builders.PathSelectors; +import springfox.documentation.builders.RequestHandlerSelectors; +import springfox.documentation.schema.ModelRef; +import springfox.documentation.service.ApiInfo; +import springfox.documentation.spi.DocumentationType; +import springfox.documentation.spring.web.plugins.Docket; +import springfox.documentation.swagger2.annotations.EnableSwagger2; + +import java.util.Arrays; + +@Configuration +@EnableSwagger2 +public class SwaggerConfig { + @Bean + public Docket createRestApi() { + return new Docket(DocumentationType.SWAGGER_2) + .apiInfo(apiInfo()) + .select() + .apis(RequestHandlerSelectors.basePackage("com.sczx.sync.controller")) // 修改为你的 controller 包路径 + .paths(PathSelectors.any()) + .build() + .globalOperationParameters(Arrays.asList( + new ParameterBuilder() + .name("Authorization") + .description("Bearer Token") + .modelRef(new ModelRef("string")) + .parameterType("header") + .required(true) + .build() + )); + } + + private ApiInfo apiInfo() { + return new ApiInfoBuilder() + .title("订单服务接口文档") + .description("sczx_order订单服务接口文档") + .version("1.0") + .build(); + } +} diff --git a/src/main/java/com/sczx/sync/config/ThirdPartyConfig.java b/src/main/java/com/sczx/sync/config/ThirdPartyConfig.java new file mode 100644 index 0000000..692763b --- /dev/null +++ b/src/main/java/com/sczx/sync/config/ThirdPartyConfig.java @@ -0,0 +1,25 @@ +package com.sczx.sync.config; + +import org.springframework.beans.factory.annotation.Value; +import org.springframework.stereotype.Component; + +/** + * 第三方平台配置实体 + * + * @author sczx + */ +@Component +public class ThirdPartyConfig { + + @Value("${third-party.platform.app-id}") + private String appId; + @Value("${third-party.platform.access-token}") + private String accessToken; + @Value("${third-party.platform.api-url}") + private String apiUrl; + @Value("${third-party.platform.timeout}") + private int timeOut; + @Value("${third-party.platform.retry-times}") + private int retryTimes; + +} diff --git a/src/main/java/com/sczx/sync/controller/ReceiveBatteryController.java b/src/main/java/com/sczx/sync/controller/ReceiveBatteryController.java new file mode 100644 index 0000000..bb9bd51 --- /dev/null +++ b/src/main/java/com/sczx/sync/controller/ReceiveBatteryController.java @@ -0,0 +1,49 @@ +package com.sczx.sync.controller; + + +import com.sczx.sync.common.Result; +import com.sczx.sync.common.enums.ApiErrorCode; +import com.sczx.sync.dto.DataRceiveReq; +import com.sczx.sync.dto.ReceiveMealReq; +import com.sczx.sync.mapper.CompanyStoreMapper; +import com.sczx.sync.service.ReceiveService; +import com.sczx.sync.service.SendDataService; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.extern.slf4j.Slf4j; +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 static com.sczx.sync.common.enums.ApiErrorCode.NOT_PERMISSION; + +/** + * 数据同步控制器 + * + * @author sczx + */ +@Api(value = "租电平台推送数据至租车平台", tags = "租电平台推送数据至租车平台") +@Slf4j +@RestController +@RequestMapping("/b2c") +public class ReceiveBatteryController { + + + @Autowired + private ReceiveService receiveService; + + @ApiOperation(value = "接收租电数据接口") + @PostMapping("/batterymeal") + public Result batterymeal(@RequestBody String receiveMealReq){ + Boolean bool = receiveService.recceiveMeals(receiveMealReq); + if (!bool.booleanValue()){ + return Result.fail(NOT_PERMISSION); + } + return Result.ok(); + } + + + + +} diff --git a/src/main/java/com/sczx/sync/controller/SendDataController.java b/src/main/java/com/sczx/sync/controller/SendDataController.java new file mode 100644 index 0000000..56e00a6 --- /dev/null +++ b/src/main/java/com/sczx/sync/controller/SendDataController.java @@ -0,0 +1,86 @@ +package com.sczx.sync.controller; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.alibaba.fastjson.TypeReference; +import com.sczx.sync.common.Result; +import com.sczx.sync.dto.DataRceiveReq; +import com.sczx.sync.mapper.CompanyStoreMapper; +import com.sczx.sync.service.SendDataService; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.extern.slf4j.Slf4j; +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 java.util.HashMap; +import java.util.List; +import java.util.Map; + + +/** + * 数据同步控制器 + * + * @author sczx + */ +@Api(value = "接收平台同步数据接口", tags = "接收平台同步数据接口") +@Slf4j +@RestController +@RequestMapping("/send") +public class SendDataController { + + @Autowired + private SendDataService sendDataService; + + @Autowired + private CompanyStoreMapper companyStoreMapper; + + @ApiOperation(value = "接收需同步数据接口") + @PostMapping("/dataToBattery") + public Result sendDataToBattery(@RequestBody DataRceiveReq dataRceiveReq){ + return Result.ok(sendDataService.recAndSend(dataRceiveReq)); + } + +// @ApiOperation(value = "c2btest") +// @PostMapping("/json") +// public Result json(@RequestBody String dataRceiveReq){ +// +// Map returnMap = new HashMap<>(); +// +// JSONObject jsonObject=JSON.parseObject(dataRceiveReq.toString()); +// jsonObject.remove("status"); +// jsonObject.remove("msg"); +// JSONObject jsonObj = JSON.parseObject(jsonObject.toJSONString()); +// for (Map.Entry entry : jsonObj.entrySet()) { +// String keyStr = entry.getKey(); +// switch (keyStr){ +// case "order_no": +// System.out.println(entry.getValue()); +// long numberLong3 = Long.parseLong(entry.getValue().toString()); +// int vv3 = 30; +// long ll3 = vv3; +// companyStoreMapper.updateOdId(numberLong3,vv3); +// break; +// case "store_id": +// System.out.println(entry.getValue().getClass()); +// long numberLong = Long.parseLong(entry.getValue().toString()); +// int vv = 55; +// long ll = vv; +// companyStoreMapper.updateStoreId(numberLong,vv); +// break; +// case "operator_id": +// System.out.println(entry.getValue()) ; +// long numberLong2 = Long.parseLong(entry.getValue().toString()); +// int vv2 = 10; +// long ll2 = vv2; +// companyStoreMapper.updateOpeId(numberLong2,vv2); +// break; +// } +// } +// +// } + +} diff --git a/src/main/java/com/sczx/sync/dto/DataRceiveReq.java b/src/main/java/com/sczx/sync/dto/DataRceiveReq.java new file mode 100644 index 0000000..2aa3b17 --- /dev/null +++ b/src/main/java/com/sczx/sync/dto/DataRceiveReq.java @@ -0,0 +1,22 @@ +package com.sczx.sync.dto; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.util.Map; + +@Data +@ApiModel +public class DataRceiveReq { + + @ApiModelProperty("传入数据类型") + private String dataType; + + @ApiModelProperty("租车平台对应表主键ID") + private Long Cid; + + @ApiModelProperty("传入数据Map") + private Map businessData; + +} diff --git a/src/main/java/com/sczx/sync/dto/ReceiveMealReq.java b/src/main/java/com/sczx/sync/dto/ReceiveMealReq.java new file mode 100644 index 0000000..420f6a4 --- /dev/null +++ b/src/main/java/com/sczx/sync/dto/ReceiveMealReq.java @@ -0,0 +1,22 @@ +package com.sczx.sync.dto; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.util.Map; + +@Data +@ApiModel +public class ReceiveMealReq { + + @ApiModelProperty("APPID") + private String appid; + + @ApiModelProperty("租车平台对应表主键ID") + private String access_token; + + @ApiModelProperty("传入数据Map") + private Map Data; + +} diff --git a/src/main/java/com/sczx/sync/entity/Response.java b/src/main/java/com/sczx/sync/entity/Response.java new file mode 100644 index 0000000..a07f9c4 --- /dev/null +++ b/src/main/java/com/sczx/sync/entity/Response.java @@ -0,0 +1,31 @@ +package com.sczx.sync.entity; + +public class Response { + private String status; + private String msg; + private T data; + + public String getStatus() { + return status; + } + + public void setStatus(String status) { + this.status = status; + } + + public String getMessage() { + return msg; + } + + public void setMessage(String message) { + this.msg = message; + } + + public T getData() { + return data; + } + + public void setData(T data) { + this.data = data; + } +} \ No newline at end of file diff --git a/src/main/java/com/sczx/sync/exception/BizException.java b/src/main/java/com/sczx/sync/exception/BizException.java new file mode 100644 index 0000000..7e7bab7 --- /dev/null +++ b/src/main/java/com/sczx/sync/exception/BizException.java @@ -0,0 +1,85 @@ +package com.sczx.sync.exception; + + +import com.sczx.sync.common.IApiCode; +import com.sczx.sync.common.enums.ApiErrorCode; + +/** + * + * @author zhangli + */ +public class BizException extends RuntimeException { + + private static final long serialVersionUID = 1L; + + /** + * 错误码 + */ + protected String errorCode; + /** + * 错误信息 + */ + protected String errorMsg; + + public BizException() { + super(); + } + + public BizException(IApiCode apiCode) { + super(apiCode.getCode()); + this.errorCode = apiCode.getCode(); + this.errorMsg = apiCode.getMsg(); + } + + public BizException(IApiCode apiCode, Throwable cause) { + super(apiCode.getCode(), cause); + this.errorCode = apiCode.getCode(); + this.errorMsg = apiCode.getMsg(); + } + + public BizException(String errorMsg) { + super(errorMsg); + this.errorCode = ApiErrorCode.FAIL.getCode(); + this.errorMsg = errorMsg; + } + + public BizException(String errorCode, String errorMsg) { + super(errorCode); + this.errorCode = errorCode; + this.errorMsg = errorMsg; + } + + public BizException(String errorCode, String errorMsg, Throwable cause) { + super(errorCode, cause); + this.errorCode = errorCode; + this.errorMsg = errorMsg; + } + + + public String getErrorCode() { + return errorCode; + } + + public void setErrorCode(String errorCode) { + this.errorCode = errorCode; + } + + public String getErrorMsg() { + return errorMsg; + } + + public void setErrorMsg(String errorMsg) { + this.errorMsg = errorMsg; + } + + @Override + public String getMessage() { + return errorMsg; + } + + @Override + public Throwable fillInStackTrace() { + return this; + } + +} diff --git a/src/main/java/com/sczx/sync/exception/GlobalExceptionHandler.java b/src/main/java/com/sczx/sync/exception/GlobalExceptionHandler.java new file mode 100644 index 0000000..f41b100 --- /dev/null +++ b/src/main/java/com/sczx/sync/exception/GlobalExceptionHandler.java @@ -0,0 +1,50 @@ +package com.sczx.sync.exception; + + + +import com.sczx.sync.common.Result; +import lombok.extern.slf4j.Slf4j; +import org.springframework.web.bind.annotation.ControllerAdvice; +import org.springframework.web.bind.annotation.ExceptionHandler; +import org.springframework.web.bind.annotation.ResponseBody; + +import javax.servlet.http.HttpServletRequest; + + +/** + * @author zhangli + */ +@Slf4j +@ControllerAdvice +public class GlobalExceptionHandler { + + + /** + * 处理自定义的业务异常 + * + * @param req + * @param e + * @return + */ + @ExceptionHandler(value = BizException.class) + @ResponseBody + public Result bizExceptionHandler(HttpServletRequest req, BizException e) { + log.warn("发生业务异常！原因是：{}", e.getErrorMsg(), e); + return Result.fail(e.getErrorCode(), e.getErrorMsg()); + } + + @ExceptionHandler(value = InnerException.class) + @ResponseBody + public Result innerExceptionHandler(HttpServletRequest req, InnerException e) { + log.error("发生服务内部异常！原因是：{}", e.getErrorMsg(), e); + return Result.fail(e.getErrorCode(), e.getErrorMsg()); + } + + @ExceptionHandler(value = Exception.class) + @ResponseBody + public Result exceptionHandler(HttpServletRequest req, Exception e) { + log.error("意料外异常！原因是：{}", e.getMessage(), e); + return Result.fail("99999", "系统内部异常"); + } + +} diff --git a/src/main/java/com/sczx/sync/exception/InnerException.java b/src/main/java/com/sczx/sync/exception/InnerException.java new file mode 100644 index 0000000..dc412aa --- /dev/null +++ b/src/main/java/com/sczx/sync/exception/InnerException.java @@ -0,0 +1,86 @@ +package com.sczx.sync.exception; + + +import com.sczx.sync.common.IApiCode; +import com.sczx.sync.common.enums.ApiErrorCode; + +/** + * + * @author zhangli + + */ +public class InnerException extends RuntimeException { + + private static final long serialVersionUID = 1L; + + /** + * 错误码 + */ + protected String errorCode; + /** + * 错误信息 + */ + protected String errorMsg; + + public InnerException() { + super(); + } + + public InnerException(IApiCode apiCode) { + super(apiCode.getCode()); + this.errorCode = apiCode.getCode(); + this.errorMsg = apiCode.getMsg(); + } + + public InnerException(IApiCode apiCode, Throwable cause) { + super(apiCode.getCode(), cause); + this.errorCode = apiCode.getCode(); + this.errorMsg = apiCode.getMsg(); + } + + public InnerException(String errorMsg) { + super(errorMsg); + this.errorCode = ApiErrorCode.INNER_ERROR.getCode(); + this.errorMsg = errorMsg; + } + + public InnerException(String errorCode, String errorMsg) { + super(errorCode); + this.errorCode = errorCode; + this.errorMsg = errorMsg; + } + + public InnerException(String errorCode, String errorMsg, Throwable cause) { + super(errorCode, cause); + this.errorCode = errorCode; + this.errorMsg = errorMsg; + } + + + public String getErrorCode() { + return errorCode; + } + + public void setErrorCode(String errorCode) { + this.errorCode = errorCode; + } + + public String getErrorMsg() { + return errorMsg; + } + + public void setErrorMsg(String errorMsg) { + this.errorMsg = errorMsg; + } + + @Override + public String getMessage() { + return errorMsg; + } + + @Override + public Throwable fillInStackTrace() { + return this; + } + +} diff --git a/src/main/java/com/sczx/sync/mapper/BatteryMealMapper.java b/src/main/java/com/sczx/sync/mapper/BatteryMealMapper.java new file mode 100644 index 0000000..27e6e47 --- /dev/null +++ b/src/main/java/com/sczx/sync/mapper/BatteryMealMapper.java @@ -0,0 +1,13 @@ +package com.sczx.sync.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.sczx.sync.po.SyncDataInfo; +import org.apache.ibatis.annotations.Mapper; + +@Mapper +public interface BatteryMealMapper extends BaseMapper { + + int insertZcRentBatteyRule(SyncDataInfo syncDataInfo); + + int updateBatteryRule(SyncDataInfo syncDataInfo); +} diff --git a/src/main/java/com/sczx/sync/mapper/CompanyStoreMapper.java b/src/main/java/com/sczx/sync/mapper/CompanyStoreMapper.java new file mode 100644 index 0000000..7558b4c --- /dev/null +++ b/src/main/java/com/sczx/sync/mapper/CompanyStoreMapper.java @@ -0,0 +1,13 @@ +package com.sczx.sync.mapper; + +import org.apache.ibatis.annotations.Mapper; + +@Mapper +public interface CompanyStoreMapper { + + int updateStoreId(long bpStoreId, long cId); + + int updateOpeId(long bOpId, long cId); + + int updateOdId(long bOdId, long cId); +} diff --git a/src/main/java/com/sczx/sync/mapper/DataReceiveRecordMapper.java b/src/main/java/com/sczx/sync/mapper/DataReceiveRecordMapper.java new file mode 100644 index 0000000..de2dedb --- /dev/null +++ b/src/main/java/com/sczx/sync/mapper/DataReceiveRecordMapper.java @@ -0,0 +1,14 @@ +package com.sczx.sync.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.sczx.sync.po.DataReceivePo; +import org.apache.ibatis.annotations.Mapper; + +/** + * 数据接收记录Mapper接口 + * + * @author sczx + */ +@Mapper +public interface DataReceiveRecordMapper extends BaseMapper { +} diff --git a/src/main/java/com/sczx/sync/po/DataReceivePo.java b/src/main/java/com/sczx/sync/po/DataReceivePo.java new file mode 100644 index 0000000..fc2a507 --- /dev/null +++ b/src/main/java/com/sczx/sync/po/DataReceivePo.java @@ -0,0 +1,101 @@ +package com.sczx.sync.po; + +import com.baomidou.mybatisplus.annotation.*; +import lombok.Data; +import lombok.EqualsAndHashCode; + +import java.time.LocalDateTime; + +/** + * 数据接收记录实体 + * + * @author sczx + */ +@Data +@EqualsAndHashCode(callSuper = false) +@TableName("data_receive_record") +public class DataReceivePo { + + /** + * 主键ID + */ + @TableId(value = "id", type = IdType.AUTO) + private Long id; + + @TableField("app_id") + private String appId; + + @TableField("access_token") + private String accessToken; + + /** + * 接口数据类型 + */ + @TableField("data_type") + private String dataType; + + @TableField("c_id") + private Long Cid; + + + /** + * 请求数据 + */ + @TableField("request_data") + private String requestData; + + /** + * 请求时间 + */ + @TableField("request_time") + private LocalDateTime requestTime; + + /** + * 状态：0-待转发，1-转发中，2-转发成功，3-转发失败 + */ + @TableField("status") + private Integer status; + + /** + * 转发时间 + */ + @TableField("forward_time") + private LocalDateTime forwardTime; + + /** + * 响应数据 + */ + @TableField("response_data") + private String responseData; + + /** + * 错误信息 + */ + @TableField("error_message") + private String errorMessage; + + /** + * 重试次数 + */ + @TableField("retry_count") + private Integer retryCount; + + /** + * 创建时间 + */ + @TableField(value = "create_time", fill = FieldFill.INSERT) + private LocalDateTime createTime; + + /** + * 更新时间 + */ + @TableField(value = "update_time", fill = FieldFill.INSERT_UPDATE) + private LocalDateTime updateTime; + + /** + * 是否删除 + */ + @TableLogic + @TableField("deleted") + private Integer deleted; +} diff --git a/src/main/java/com/sczx/sync/po/SyncDataInfo.java b/src/main/java/com/sczx/sync/po/SyncDataInfo.java new file mode 100644 index 0000000..8d705b0 --- /dev/null +++ b/src/main/java/com/sczx/sync/po/SyncDataInfo.java @@ -0,0 +1,150 @@ +package com.sczx.sync.po; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; + +import java.io.Serializable; +import java.time.LocalDateTime; + +@TableName("zc_rent_battey_rule") +public class SyncDataInfo implements Serializable { + private static final long serialVersionUID = 1L; + @TableField("id") + private Long id; + @TableField("meal_id") + private Integer mealId; + @TableField("title") + private String title; + @TableField("detail") + private String detail; + @TableField("voltage") + private Integer voltage; + @TableField("ah") + private Integer ah; + @TableField("rent_price") + private Double rentPrice; + @TableField("duration_type") + private Integer durationType; + @TableField("duration") + private Integer duration; + @TableField("city_id") + private Integer cityId; + @TableField("province_id") + private Integer provinceId; + @TableField("category_id") + private Integer categoryId; + @TableField("operator_id") + private Integer operatorId; + + public LocalDateTime getSyncTime() { + return syncTime; + } + + public void setSyncTime(LocalDateTime syncTime) { + this.syncTime = syncTime; + } + + private LocalDateTime syncTime; + + // Getters and Setters + public void setId(Long id) { this.id = id;} + + public Long getId() { return id; } + + public Integer getMealId() { + return mealId; + } + + public void setMealId(Integer mealId) { + this.mealId = mealId; + } + + public String getTitle() { + return title; + } + + public void setTitle(String title) { + this.title = title; + } + + public String getDetail() { + return detail; + } + + public void setDetail(String detail) { + this.detail = detail; + } + + public Integer getVoltage() { + return voltage; + } + + public void setVoltage(Integer voltage) { + this.voltage = voltage; + } + + public Integer getAh() { + return ah; + } + + public void setAh(Integer ah) { + this.ah = ah; + } + + public Double getRentPrice() { + return rentPrice; + } + + public void setRentPrice(Double rentPrice) { + this.rentPrice = rentPrice; + } + + public Integer getDurationType() { + return durationType; + } + + public void setDurationType(Integer durationType) { + this.durationType = durationType; + } + + public Integer getDuration() { + return duration; + } + + public void setDuration(Integer duration) { + this.duration = duration; + } + + public Integer getCityId() { + return cityId; + } + + public void setCityId(Integer cityId) { + this.cityId = cityId; + } + + public Integer getProvinceId() { + return provinceId; + } + + public void setProvinceId(Integer provinceId) { + this.provinceId = provinceId; + } + + public Integer getCategoryId() { + return categoryId; + } + + public void setCategoryId(Integer categoryId) { + this.categoryId = categoryId; + } + + public Integer getOperatorId() { + return operatorId; + } + + public void setOperatorId(Integer operatorId) { + this.operatorId = operatorId; + } + +} \ No newline at end of file diff --git a/src/main/java/com/sczx/sync/po/SyncRequest.java b/src/main/java/com/sczx/sync/po/SyncRequest.java new file mode 100644 index 0000000..ed252fe --- /dev/null +++ b/src/main/java/com/sczx/sync/po/SyncRequest.java @@ -0,0 +1,42 @@ +package com.sczx.sync.po; + +import com.baomidou.mybatisplus.annotation.TableField; +import java.io.Serializable; + +public class SyncRequest implements Serializable { + private static final long serialVersionUID = 1L; + + private String appid; + + private String accessToken; + + @TableField("Data") + private SyncDataInfo data; + + // Getters and Setters + public String getAppid() { + return appid; + } + + public void setAppid(String appid) { + this.appid = appid; + } + + public String getAccessToken() { + return accessToken; + } + + public void setAccessToken(String accessToken) { + this.accessToken = accessToken; + } + + public SyncDataInfo getData() { + return data; + } + + public void setData(SyncDataInfo data) { + this.data = data; + } + + +} \ No newline at end of file diff --git a/src/main/java/com/sczx/sync/service/ReceiveService.java b/src/main/java/com/sczx/sync/service/ReceiveService.java new file mode 100644 index 0000000..3163edc --- /dev/null +++ b/src/main/java/com/sczx/sync/service/ReceiveService.java @@ -0,0 +1,8 @@ +package com.sczx.sync.service; + + +import com.sczx.sync.dto.ReceiveMealReq; + +public interface ReceiveService { + boolean recceiveMeals(String request); +} diff --git a/src/main/java/com/sczx/sync/service/SendDataService.java b/src/main/java/com/sczx/sync/service/SendDataService.java new file mode 100644 index 0000000..1417d89 --- /dev/null +++ b/src/main/java/com/sczx/sync/service/SendDataService.java @@ -0,0 +1,28 @@ +package com.sczx.sync.service; + +import com.sczx.sync.dto.DataRceiveReq; + +public interface SendDataService { + + /** + * 接收数据并异步转发 + * + * @param request 数据接收请求 + * @return 是否接收成功 + */ + boolean recAndSend(DataRceiveReq request); + + /** + * 异步转发数据到第三方平台 + * + * @param recordId 记录ID + */ + void forwardToThirdParty(Long recordId,String url); + + /** + * 重试失败的数据转发 + * + * @param recordId 记录ID + */ + void retryForward(Long recordId); +} diff --git a/src/main/java/com/sczx/sync/service/ThirdPartyForwardService.java b/src/main/java/com/sczx/sync/service/ThirdPartyForwardService.java new file mode 100644 index 0000000..e8b47f8 --- /dev/null +++ b/src/main/java/com/sczx/sync/service/ThirdPartyForwardService.java @@ -0,0 +1,12 @@ +package com.sczx.sync.service; + + +/** + * 第三方平台转发服务接口 + * + * @author sczx + */ +public interface ThirdPartyForwardService { + + String forwardData(String datatype,String data); +} diff --git a/src/main/java/com/sczx/sync/service/impl/ReceiveServiceImpl.java b/src/main/java/com/sczx/sync/service/impl/ReceiveServiceImpl.java new file mode 100644 index 0000000..f227830 --- /dev/null +++ b/src/main/java/com/sczx/sync/service/impl/ReceiveServiceImpl.java @@ -0,0 +1,65 @@ +package com.sczx.sync.service.impl; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.sczx.sync.dto.DataRceiveReq; +import com.sczx.sync.dto.ReceiveMealReq; +import com.sczx.sync.mapper.BatteryMealMapper; +import com.sczx.sync.mapper.CompanyStoreMapper; +import com.sczx.sync.mapper.DataReceiveRecordMapper; +import com.sczx.sync.po.DataReceivePo; +import com.sczx.sync.po.SyncDataInfo; +import com.sczx.sync.po.SyncRequest; +import com.sczx.sync.service.ReceiveService; +import com.sczx.sync.service.ThirdPartyForwardService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.scheduling.annotation.Async; +import org.springframework.stereotype.Component; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.time.LocalDateTime; +import java.util.Map; + +@Slf4j +@Service +@Component +public class ReceiveServiceImpl implements ReceiveService { + + + @Autowired + private BatteryMealMapper batteryMealMapper; + + + @Value("${battery-platform.appid}") + private String appId; + @Value("${battery-platform.access-token}") + private String accessToken; + + @Override + public boolean recceiveMeals(String request) { + + SyncRequest meals = JSON.parseObject(request, SyncRequest.class); + + if(!meals.getAppid().equals(appId)||!meals.getAccessToken().equals(accessToken)){ + return false; + } + SyncDataInfo syncDataInfo = meals.getData(); + syncDataInfo.setSyncTime(LocalDateTime.now()); + QueryWrapper syncDataInfoQueryWrapper = new QueryWrapper<>(); + QueryWrapper eq = syncDataInfoQueryWrapper.eq("meal_id", meals.getData().getMealId()); + if(batteryMealMapper.selectOne(eq)!=null){ + + batteryMealMapper.updateBatteryRule(syncDataInfo); + }else { + batteryMealMapper.insertZcRentBatteyRule(syncDataInfo); + } + + + + return true; + } +} diff --git a/src/main/java/com/sczx/sync/service/impl/SendDataServiceImpl.java b/src/main/java/com/sczx/sync/service/impl/SendDataServiceImpl.java new file mode 100644 index 0000000..6d83c6e --- /dev/null +++ b/src/main/java/com/sczx/sync/service/impl/SendDataServiceImpl.java @@ -0,0 +1,197 @@ +package com.sczx.sync.service.impl; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.sczx.sync.dto.DataRceiveReq; + +import com.sczx.sync.mapper.CompanyStoreMapper; +import com.sczx.sync.mapper.DataReceiveRecordMapper; +import com.sczx.sync.po.DataReceivePo; +import com.sczx.sync.service.SendDataService; +import com.sczx.sync.service.ThirdPartyForwardService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.scheduling.annotation.Async; +import org.springframework.stereotype.Component; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.time.LocalDateTime; +import java.util.Map; + +@Slf4j +@Service +@Component +public class SendDataServiceImpl implements SendDataService { + + @Autowired + private DataReceiveRecordMapper dataReceiveRecordMapper; + + @Autowired + private CompanyStoreMapper companyStoreMapper; + + @Autowired + private ThirdPartyForwardService thirdPartyForwardService; + + @Value("${third-party.platform.api-url}") + private String URL; + @Value("${third-party.platform.app-id}") + private String appId; + @Value("${third-party.platform.access-token}") + private String accessToken; + + + @Override + @Transactional + public boolean recAndSend(DataRceiveReq dataRceiveReq) { + String dataType = dataRceiveReq.getDataType(); + + System.out.println("dataType "+dataType); + + switch (dataType){ + case "userinfo": + + return saveRecord(dataRceiveReq,URL+"/"+dataType); + case "companyinfo": + return saveRecord(dataRceiveReq,URL+"/"+dataType); + + case "storeinfo": + return saveRecord(dataRceiveReq,URL+"/"+dataType); + + case "batteryorder": + return saveRecord(dataRceiveReq,URL+"/"+dataType); + + } + + return false; + } + + @Override + @Async + public void forwardToThirdParty(Long recordId,String url) { + try { + // 更新状态为转发中 + DataReceivePo record = dataReceiveRecordMapper.selectById(recordId); + if (record == null) { + log.error("记录不存在，ID: {}", recordId); + return; + } + + record.setStatus(1); // 转发中 + dataReceiveRecordMapper.updateById(record); + + String dataType = record.getDataType(); + // 转发数据 + String response = thirdPartyForwardService.forwardData(dataType,record.getRequestData()); + + modifyData(dataType,record.getCid(),response); + + // 更新记录状态 + record.setStatus(2); // 转发成功 + record.setForwardTime(LocalDateTime.now()); + record.setResponseData(response); + dataReceiveRecordMapper.updateById(record); + + log.info("数据转发成功，记录ID: {}", recordId); + } catch (Exception e) { + log.error("数据转发失败，记录ID: {}", recordId, e); + updateRecordStatus(recordId, 3, e.getMessage()); + } + } + + @Override + @Async + public void retryForward(Long recordId) { + try { + DataReceivePo record = dataReceiveRecordMapper.selectById(recordId); + if (record == null) { + log.error("记录不存在，ID: {}", recordId); + return; + } + + // 检查重试次数 + if (record.getRetryCount() >= 3) { + log.warn("重试次数已达上限，记录ID: {}", recordId); + return; + } + + // 增加重试次数 + record.setRetryCount(record.getRetryCount() + 1); + dataReceiveRecordMapper.updateById(record); + // 重新转发 + forwardToThirdParty(recordId,URL+"/"+record.getDataType()); + } catch (Exception e) { + log.error("重试转发失败，记录ID: {}", recordId, e); + } + } + + /** + * 更新记录状态 + */ + private void updateRecordStatus(Long recordId, Integer status, String errorMessage) { + try { + DataReceivePo record = new DataReceivePo(); + record.setId(recordId); + record.setStatus(status); + record.setErrorMessage(errorMessage); + record.setUpdateTime(LocalDateTime.now()); + dataReceiveRecordMapper.updateById(record); + } catch (Exception e) { + log.error("更新记录状态失败，记录ID: {}", recordId, e); + } + } + + private boolean saveRecord(DataRceiveReq request,String url) { + System.out.println(url); + + try { + + // 保存接收记录 + DataReceivePo record = new DataReceivePo(); + record.setDataType(request.getDataType()); + record.setCid(request.getCid()); + record.setRequestData(JSON.toJSONString(request.getBusinessData())); + record.setRequestTime(LocalDateTime.now()); + record.setStatus(0); // 待转发 + record.setRetryCount(0); + + dataReceiveRecordMapper.insert(record); + + // 异步转发数据 + forwardToThirdParty(record.getId(),url); + + log.info("数据接收成功，记录ID: {}", record.getId()); + return true; + } catch (Exception e) { + log.error("数据接收失败", e); + return false; + } + } + + private void modifyData(String dataType,Long Cid,String response){ + + JSONObject jsonObject=JSON.parseObject(response.toString()); + jsonObject.remove("status"); + jsonObject.remove("msg"); + JSONObject jsonObj = JSON.parseObject(jsonObject.toJSONString()); + for (Map.Entry entry : jsonObj.entrySet()) { + System.out.println(entry.getKey() + ":" + entry.getValue()); + String keyStr = entry.getKey(); + long bId = Long.parseLong(entry.getValue().toString()); + switch (keyStr){ + case "order_no": + companyStoreMapper.updateOdId(bId,Cid); + break; + case "store_id": + companyStoreMapper.updateStoreId(bId,Cid); + break; + case "operator_id": + companyStoreMapper.updateOpeId(bId,Cid); + break; + } + } + + } + +} diff --git a/src/main/java/com/sczx/sync/service/impl/ThirdPartyForwardServiceImpl.java b/src/main/java/com/sczx/sync/service/impl/ThirdPartyForwardServiceImpl.java new file mode 100644 index 0000000..8ad2965 --- /dev/null +++ b/src/main/java/com/sczx/sync/service/impl/ThirdPartyForwardServiceImpl.java @@ -0,0 +1,112 @@ +package com.sczx.sync.service.impl; + +import com.alibaba.fastjson.JSON; +import com.sczx.sync.config.ThirdPartyConfig; +import com.sczx.sync.service.ThirdPartyForwardService; +import lombok.extern.slf4j.Slf4j; +import org.apache.http.HttpEntity; +import org.apache.http.client.config.RequestConfig; +import org.apache.http.client.methods.CloseableHttpResponse; +import org.apache.http.client.methods.HttpPost; +import org.apache.http.entity.StringEntity; +import org.apache.http.impl.client.CloseableHttpClient; +import org.apache.http.impl.client.HttpClients; +import org.apache.http.util.EntityUtils; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.stereotype.Service; + +import java.nio.charset.StandardCharsets; +import java.util.HashMap; +import java.util.Map; + +/** + * 第三方平台转发服务实现类 + * + * @author sczx + */ +@Slf4j +@Service +public class ThirdPartyForwardServiceImpl implements ThirdPartyForwardService { + + @Value("${third-party.platform.api-url}") + private String URL; + @Value("${third-party.platform.app-id}") + private String appId; + @Value("${third-party.platform.access-token}") + private String accessToken; + @Value("${third-party.platform.api-url}") + private String apiUrl; + @Value("${third-party.platform.timeout}") + private int timeOut; + @Value("${third-party.platform.retry-times}") + private int retryTimes; + + @Override + public String forwardData(String datatype,String data) { + CloseableHttpClient httpClient = null; + CloseableHttpResponse response = null; + + + + try { + // 创建HTTP客户端 + httpClient = HttpClients.createDefault(); + String url = URL+'/'+datatype; + // 创建POST请求 + HttpPost httpPost = new HttpPost(url); + + // 设置请求头 + httpPost.setHeader("Content-Type", "application/json;charset=UTF-8"); + httpPost.setHeader("User-Agent", "SczxSync/1.0"); + + // 构建请求体 + Map requestBody = new HashMap<>(); + requestBody.put("appId", appId); + requestBody.put("accessToken",accessToken); + requestBody.put("data", JSON.parse(data)); + requestBody.put("timestamp", System.currentTimeMillis()); + + StringEntity entity = new StringEntity(JSON.toJSONString(requestBody), StandardCharsets.UTF_8); + httpPost.setEntity(entity); + + // 设置超时配置 + RequestConfig requestConfig = RequestConfig.custom() + .setConnectTimeout(timeOut) + .setSocketTimeout(timeOut) + .build(); + httpPost.setConfig(requestConfig); + + log.info("开始转发数据到第三方平台: {}, 数据: {}", url, data); + + // 执行请求 + response = httpClient.execute(httpPost); + HttpEntity responseEntity = response.getEntity(); + String responseBody = EntityUtils.toString(responseEntity, StandardCharsets.UTF_8); + + int statusCode = response.getStatusLine().getStatusCode(); + if (statusCode == 200) { + log.info("数据转发成功，响应: {}", responseBody); + return responseBody; + } else { + log.error("数据转发失败，状态码: {}, 响应: {}", statusCode, responseBody); + throw new RuntimeException("第三方平台响应异常，状态码: " + statusCode); + } + + } catch (Exception e) { + log.error("数据转发异常", e); + throw new RuntimeException("数据转发异常: " + e.getMessage(), e); + } finally { + // 关闭资源 + try { + if (response != null) { + response.close(); + } + if (httpClient != null) { + httpClient.close(); + } + } catch (Exception e) { + log.error("关闭HTTP客户端异常", e); + } + } + } +} diff --git a/src/main/java/com/sczx/sync/utils/ComputerInfo.java b/src/main/java/com/sczx/sync/utils/ComputerInfo.java new file mode 100644 index 0000000..75a88a3 --- /dev/null +++ b/src/main/java/com/sczx/sync/utils/ComputerInfo.java @@ -0,0 +1,159 @@ +package com.sczx.sync.utils; + +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStreamReader; +import java.net.InetAddress; +import java.util.ArrayList; +import java.util.Iterator; +import java.util.List; +import java.util.regex.Matcher; +import java.util.regex.Pattern; + +/* + * <取网卡物理地址-- + * 1.在Windows,Linux系统下均可用； + * 2.通过ipconifg,ifconfig获得计算机信息； + * 3.再用模式匹配方式查找MAC地址，与操作系统的语言无关> + * + * //* Description: <取计算机名--从环境变量中取> + * abstract 限制继承/创建实例 + */ +public abstract class ComputerInfo { + private static String macAddressStr = null; + private static String computerName = System.getenv().get("COMPUTERNAME"); + + private static final String[] windowsCommand = { "ipconfig", "/all" }; + private static final String[] linuxCommand = { "/sbin/ifconfig", "-a" }; + private static final String[] macCommand = { "ifconfig", "-a" }; + private static final Pattern macPattern = Pattern.compile(".*((:?[0-9a-f]{2}[-:]){5}[0-9a-f]{2}).*", + Pattern.CASE_INSENSITIVE); + + /** + * 获取多个网卡地址 + * + * @return + * @throws IOException + */ + private final static List getMacAddressList() throws IOException { + final ArrayList macAddressList = new ArrayList(); + final String os = System.getProperty("os.name"); + final String command[]; + + if (os.startsWith("Windows")) { + command = windowsCommand; + } else if (os.startsWith("Linux")) { + command = linuxCommand; + } else if (os.startsWith("Mac")){ + command = macCommand; + } + else { + throw new IOException("Unknow operating system:" + os); + } + // 执行命令 + final Process process = Runtime.getRuntime().exec(command); + + BufferedReader bufReader = new BufferedReader(new InputStreamReader(process.getInputStream())); + for (String line = null; (line = bufReader.readLine()) != null;) { + Matcher matcher = macPattern.matcher(line); + if (matcher.matches()) { + macAddressList.add(matcher.group(1)); + // macAddressList.add(matcher.group(1).replaceAll("[-:]", + // ""));//去掉MAC中的“-” + } + } + + process.destroy(); + bufReader.close(); + return macAddressList; + } + + /** + * 获取一个网卡地址（多个网卡时从中获取一个） + * + * @return + */ + public static String getMacAddress() { + if (macAddressStr == null || macAddressStr.equals("")) { + StringBuffer sb = new StringBuffer(); // 存放多个网卡地址用，目前只取一个非0000000000E0隧道的值 + try { + List macList = getMacAddressList(); + for (Iterator iter = macList.iterator(); iter.hasNext();) { + String amac = iter.next(); + if (!"0000000000E0".equals(amac)) { + sb.append(amac); + break; + } + } + } catch (IOException e) { + e.printStackTrace(); + } + + macAddressStr = sb.toString(); + + } + + return macAddressStr; + } + + /** + * 获取电脑名 + * + * @return + */ + public static String getComputerName() { + if (computerName == null || computerName.equals("")) { + computerName = System.getenv().get("COMPUTERNAME"); + } + return computerName; + } + + /** + * 获取客户端IP地址 + * + * @return + */ + public static String getIpAddrAndName() throws IOException { + return InetAddress.getLocalHost().toString(); + } + + /** + * 获取客户端IP地址 + * + * @return + */ + public static String getIpAddr() throws IOException { + return InetAddress.getLocalHost().getHostAddress().toString(); + } + + /** + * 获取电脑唯一标识 + * + * @return + */ + public static String getComputerID() { + String id = getMacAddress(); + if (id == null || id.equals("")) { + try { + id = getIpAddrAndName(); + } catch (IOException e) { + e.printStackTrace(); + } + } + return computerName; + } + + /** + * 限制创建实例 + */ + private ComputerInfo() { + + } + + public static void main(String[] args) throws IOException { + System.out.println(ComputerInfo.getMacAddress()); + System.out.println(ComputerInfo.getComputerName()); + System.out.println(ComputerInfo.getIpAddr()); + System.out.println(ComputerInfo.getIpAddrAndName()); + } +} diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml new file mode 100644 index 0000000..4884c45 --- /dev/null +++ b/src/main/resources/application.yml @@ -0,0 +1,69 @@ + +server: + port: 8016 + +spring: + application: + name: sczx-sync # 微服务名称 + http: + encoding: + charset: UTF-8 + enabled: true + force: true + mvc: + async: + request-timeout: -1 + jackson: + date-format: yyyy-MM-dd HH:mm:ss + time-zone: GMT+8 + cloud: + nacos: + discovery: + server-addr: 115.190.8.52:8848 # Nacos 地址 + group: DEFAULT_GROUP + metadata: + version: 1.0.0 + env: dev + lifecycle: + timeout-per-shutdown-phase: 30s # 设置优雅停机时间 + datasource: + url: jdbc:mysql://115.190.8.52:3306/sczx?useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true + username: sczx_user + password: Sczx123@ + driver-class-name: com.mysql.cj.jdbc.Driver + hikari: + maximum-pool-size: 10 + auto-commit: true + +management: + endpoints: + web: + exposure: + include: "*" # 暴露所有监控端点 + endpoint: + health: + show-details: always + + + + +mybatis-plus: + mapper-locations: classpath*:mapper/**/*.xml + type-aliases-package: com.sczx.sync.po # 实体类包路径 + configuration: + mapUnderscoreToCamelCase: true + log-impl: org.apache.ibatis.logging.stdout.StdOutImpl # 控制台打印 SQL（调试用） + + +# 第三方平台配置 +third-party: + platform: + app-id: 111 + access-token: 111 + api-url: 127.0.0.1:8081/api/ddd + timeout: 30000 + retry-times: 3 + +battery-platform: + appid: 12312321 + access_token: 23213213 \ No newline at end of file diff --git a/src/main/resources/doc/dbInit.sql b/src/main/resources/doc/dbInit.sql new file mode 100644 index 0000000..314c3de --- /dev/null +++ b/src/main/resources/doc/dbInit.sql @@ -0,0 +1,40 @@ +CREATE TABLE `zc_order_main` ( + `order_id` bigint NOT NULL AUTO_INCREMENT COMMENT '订单ID（主键）', + `order_no` varchar(50) NOT NULL COMMENT '订单编号', + `order_status` varchar(20) NOT NULL COMMENT '订单状态:下单未提车、租赁中、已结束-自动、已结束-手动', + `operator_id` bigint NOT NULL COMMENT '所属运营商ID', + `store_id` bigint NOT NULL COMMENT '所属门店ID', + `vehicle_id` bigint DEFAULT NULL COMMENT '车辆ID', + `car_model_id` bigint NOT NULL COMMENT '车型ID', + `customer_id` bigint NOT NULL COMMENT '客户id', + `customer_name` varchar(50) NOT NULL COMMENT '客户姓名', + `customer_phone` varchar(20) NOT NULL COMMENT '客户联系电话', + `battery_type` varchar(50) DEFAULT '' COMMENT '选择的电池类型(48V标准版/100km,48V超长版/200km等)', + `rental_type` varchar(20) NOT NULL COMMENT '租赁类型(时租/日租/按天数/以租代售)', + `rental_days` int DEFAULT NULL COMMENT '租赁天数(当类型为"按天数"时使用)', + `rental_price` decimal(10,2) NOT NULL COMMENT '租车价格(元)', + `deposit_price` decimal(10,2) NOT NULL COMMENT '押金价格(元)', + `overdue_fee` decimal(10,2) NOT NULL COMMENT '逾期金额(元)', + `overdue_type` varchar(10) DEFAULT '按日计费' COMMENT '逾期计费类型(按日计费/按月计费)', + `is_deposit_free` tinyint(1) NOT NULL DEFAULT '0' COMMENT '是否开通免押', + `is_auto_deduct` tinyint(1) NOT NULL DEFAULT '0' COMMENT '是否开通代扣', + `first_order_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '首次下单时间', + `start_rent_time` datetime DEFAULT NULL COMMENT '开始计费时间', + `end_rent_time` datetime DEFAULT NULL COMMENT '预计还车时间', + `req_end_rent_time` datetime DEFAULT NULL COMMENT '申请还车时间', + `act_end_rent_time` datetime DEFAULT NULL COMMENT '实际还车时间', + `overdue_days` int NOT NULL DEFAULT '0' COMMENT '逾期天数', + `renewal_times` int NOT NULL DEFAULT '0' COMMENT '续租次数', + `charge_times` int NOT NULL DEFAULT '0' COMMENT '充电次数', + `rent_car_rule_id` bigint DEFAULT NULL COMMENT '租车套餐id', + `rent_battey_rule_id` bigint DEFAULT NULL COMMENT '租电套餐id', + `end_order_time` datetime DEFAULT NULL COMMENT '订单结束时间', + `del_flag` char(1) DEFAULT '0' COMMENT '删除标志（0代表存在 2代表删除）', + `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', + `update_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', + PRIMARY KEY (`order_id`), + KEY `idx_order_no` (`order_no`), + KEY `idx_customer_id` (`customer_id`), + KEY `idx_operator_id` (`operator_id`), + KEY `idx_store_id` (`store_id`) +) ENGINE=InnoDB AUTO_INCREMENT=13 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='租车订单信息'; \ No newline at end of file diff --git a/src/main/resources/logback.xml b/src/main/resources/logback.xml new file mode 100644 index 0000000..e594345 --- /dev/null +++ b/src/main/resources/logback.xml @@ -0,0 +1,53 @@ + + + + + + + + + ${PATTERN} + + + + + + ${LOG_FILE_PATH}/${hostname}/info.%d{yyyy-MM-dd}.log + 31 + + + + ${PATTERN} + + + + WARN + DENY + NEUTRAL + + + ERROR + DENY + NEUTRAL + + + + + + WARN + + ${LOG_FILE_PATH}/${hostname}/warn.log + true + + ${PATTERN} + + + + + + + + + \ No newline at end of file diff --git a/src/main/resources/mapper/BatteryMeal.xml b/src/main/resources/mapper/BatteryMeal.xml new file mode 100644 index 0000000..df2cfd8 --- /dev/null +++ b/src/main/resources/mapper/BatteryMeal.xml @@ -0,0 +1,59 @@ + + + + + + insert into zc_rent_battey_rule + + title, + detail, + + voltage, + ah, + + rent_price, + duration_type, + duration, + city_id, + operator_id, + province_id, + category_id, + meal_id, + sync_time, + + + #{title}, + #{detail}, + #{voltage}, + #{ah}, + #{rentPrice}, + #{durationType}, + #{duration}, + #{cityId}, + #{operatorId}, + #{provinceId}, + #{categoryId}, + #{mealId}, + #{syncTime}, + + + + + update zc_rent_battey_rule + + title = #{title}, + detail = #{detail}, + voltage = #{voltage}, + ah = #{ah}, + rent_price = #{rentPrice}, + duration_type = #{durationType}, + duration = #{duration}, + city_id = #{cityId}, + operator_id = #{operatorId}, + province_id = #{provinceId}, + category_id = #{categoryId}, + sync_time = #{syncTime}, + + where meal_id = #{mealId} + + diff --git a/src/main/resources/mapper/CompanyStoreMapper.xml b/src/main/resources/mapper/CompanyStoreMapper.xml new file mode 100644 index 0000000..4d8b555 --- /dev/null +++ b/src/main/resources/mapper/CompanyStoreMapper.xml @@ -0,0 +1,18 @@ + + + + + + update zc_company_store set bp_store_id = #{bpStoreId} where id =#{cId} + + + + update zc_company set b_op_id = #{bOpId} where id =#{cId} + + + + update zc_order_sub set b_order_id = #{bOdId} where order_id =#{cId} and suborder_type = "RENTBATTEY" + + + +