111

.gitignore

@@ -0,0 +1,37 @@
+# Created by .ignore support plugin (hsz.mobi)
+### Java template
+# Compiled class file
+*.class
+
+# Log file
+*.log
+
+# BlueJ files
+*.ctxt
+
+# Mobile Tools for Java (J2ME)
+.mtj.tmp/
+
+# Package Files #
+*.jar
+*.war
+*.nar
+*.ear
+*.zip
+*.tar.gz
+*.rar
+
+# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
+hs_err_pid*
+
+### Example user template template
+### Example user template
+
+# IntelliJ project files
+.idea
+*.iml
+out
+gen
+/**/target/
+sqlite.db
+classpath

pom.xml

@@ -0,0 +1,326 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.3.12.RELEASE</version>
+        <relativePath/>
+    </parent>
+
+    <groupId>com.fdkankan</groupId>
+    <artifactId>4dkankan-scene-deploy</artifactId>
+    <version>1.0.0-SNAPSHOT</version>
+
+    <repositories>
+        <repository>
+            <id>releases</id>
+            <url>http://192.168.0.115:8081/nexus-2.14.2-01/content/repositories/releases/</url>
+        </repository>
+        <repository>
+            <id>snapshots</id>
+            <url>http://192.168.0.115:8081/nexus-2.14.2-01/content/repositories/snapshots/</url>
+        </repository>
+        <repository>
+            <id>nexus-aliyun</id>
+            <url>http://maven.aliyun.com/nexus/content/groups/public</url>
+        </repository>
+    </repositories>
+
+    <properties>
+        <java.version>1.8</java.version>
+        <hutool-version>5.7.17</hutool-version>
+        <spring.cloud-version>Hoxton.SR8</spring.cloud-version>
+        <fdkankan.common-version>2.0.0-SNAPSHOT</fdkankan.common-version>
+        <fastjson-version>1.2.83</fastjson-version>
+        <servlet-api-version>2.4</servlet-api-version>
+        <spring.boot-mybatis-version>1.3.2</spring.boot-mybatis-version>
+        <spring.plugin.metadata-version>1.2.0.RELEASE</spring.plugin.metadata-version>
+        <jwt-version>3.10.3</jwt-version>
+        <ant-version>1.8.2</ant-version>
+        <shiro.version>1.7.1</shiro.version>
+        <version>0.6.0</version>
+        <jjwt.version>0.6.0</jjwt.version>
+        <protobuf-java.version>3.2.0</protobuf-java.version>
+        <commons-pool2.version>2.5.0</commons-pool2.version>
+        <zxing.version>2.1</zxing.version>
+    </properties>
+
+    <dependencies>
+
+<!--        <dependency>-->
+<!--            <groupId>org.springframework.boot</groupId>-->
+<!--            <artifactId>spring-boot-starter-web</artifactId>-->
+<!--        </dependency>-->
+
+        <dependency>
+            <groupId>com.fdkankan</groupId>
+            <artifactId>4dkankan-common-web</artifactId>
+            <version>3.0.0-SNAPSHOT</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.bytedeco</groupId>
+                    <artifactId>javacv</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>org.bytedeco</groupId>
+                    <artifactId>javacpp</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>org.bytedeco</groupId>
+                    <artifactId>javacv-platform</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>joinery</groupId>
+                    <artifactId>jave</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>com.aliyun</groupId>
+                    <artifactId>aliyun-java-sdk-dysmsapi</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>com.aliyun</groupId>
+                    <artifactId>aliyun-java-sdk-core</artifactId>
+                </exclusion>
+<!--                <exclusion>-->
+<!--                    <groupId>org.springframework</groupId>-->
+<!--                    <artifactId>spring-web</artifactId>-->
+<!--                </exclusion>-->
+                <exclusion>
+                    <groupId>com.alibaba.cloud</groupId>
+                    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>com.alibaba.cloud</groupId>
+                    <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+
+        <dependency>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+            <version>${hutool-version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>${fastjson-version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.yomahub</groupId>
+            <artifactId>tlog-web-spring-boot-starter</artifactId>
+            <version>1.3.6</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.yomahub</groupId>
+            <artifactId>tlog-feign-spring-boot-starter</artifactId>
+            <version>1.3.6</version>
+        </dependency>
+
+        <!--        htt请求工具-->
+        <dependency>
+            <groupId>com.dtflys.forest</groupId>
+            <artifactId>forest-spring-boot-starter</artifactId>
+            <version>1.5.19</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.google.firebase</groupId>
+            <artifactId>firebase-admin</artifactId>
+            <version>6.8.1</version>
+        </dependency>
+
+        <dependency>
+            <groupId>net.lingala.zip4j</groupId>
+            <artifactId>zip4j</artifactId>
+            <version>1.3.2</version>
+        </dependency>
+
+        <!-- mybatis -->
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+            <version>3.4.3.4</version>
+        </dependency>
+
+        <!-- sqlite -->
+        <dependency>
+            <groupId>org.xerial</groupId>
+            <artifactId>sqlite-jdbc</artifactId>
+            <version>3.36.0.3</version>
+        </dependency>
+
+        <!--mybatis-plus代码生成器-->
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-generator</artifactId>
+            <scope>compile</scope>
+            <version>3.5.1</version>
+        </dependency>
+
+        <!--velocity模板-->
+        <dependency>
+            <groupId>org.apache.velocity</groupId>
+            <artifactId>velocity-engine-core</artifactId>
+            <version>2.3</version>
+        </dependency>
+
+        <dependency>
+            <groupId>cn.dev33</groupId>
+            <artifactId>sa-token-spring-boot-starter</artifactId>
+            <version>1.34.0</version>
+        </dependency>
+        <dependency>
+            <groupId>cn.dev33</groupId>
+            <artifactId>sa-token-jwt</artifactId>
+            <version>1.34.0</version>
+        </dependency>
+
+    </dependencies>
+
+    <dependencyManagement>
+
+        <dependencies>
+
+            <dependency>
+                <groupId>com.alibaba.cloud</groupId>
+                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
+                <version>2.2.7.RELEASE</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+
+            <dependency>
+                <groupId>org.springframework.cloud</groupId>
+                <artifactId>spring-cloud-dependencies</artifactId>
+                <version>${spring.cloud-version}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+
+            <dependency>
+                <groupId>cn.hutool</groupId>
+                <artifactId>hutool-all</artifactId>
+                <version>${hutool-version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.alibaba</groupId>
+                <artifactId>fastjson</artifactId>
+                <version>${fastjson-version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>javax.servlet</groupId>
+                <artifactId>servlet-api</artifactId>
+                <version>${servlet-api-version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>org.mybatis.spring.boot</groupId>
+                <artifactId>mybatis-spring-boot-starter</artifactId>
+                <version>${spring.boot-mybatis-version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>org.springframework.plugin</groupId>
+                <artifactId>spring-plugin-metadata</artifactId>
+                <version>${spring.plugin.metadata-version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.auth0</groupId>
+                <artifactId>java-jwt</artifactId>
+                <version>${jwt-version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>org.apache.ant</groupId>
+                <artifactId>ant</artifactId>
+                <version>${ant-version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>org.apache.shiro</groupId>
+                <artifactId>shiro-spring</artifactId>
+                <version>${shiro.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>io.jsonwebtoken</groupId>
+                <artifactId>jjwt</artifactId>
+                <version>${jjwt.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.google.protobuf</groupId>
+                <artifactId>protobuf-java</artifactId>
+                <version>${protobuf-java.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>org.apache.commons</groupId>
+                <artifactId>commons-lang3</artifactId>
+                <version>${commons-lang3.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.commons</groupId>
+                <artifactId>commons-pool2</artifactId>
+                <version>${commons-pool2.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>org.apache.logging.log4j</groupId>
+                <artifactId>log4j-api</artifactId>
+                <version>2.17.0</version>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.logging.log4j</groupId>
+                <artifactId>log4j-to-slf4j</artifactId>
+                <version>2.17.0</version>
+            </dependency>
+
+        </dependencies>
+    </dependencyManagement>
+
+
+    <build>
+        <finalName>${artifactId}</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+    <distributionManagement>
+        <repository>
+            <id>releases</id>
+            <url>http://192.168.0.115:8081/nexus-2.14.2-01/content/repositories/releases/</url>
+        </repository>
+
+        <snapshotRepository>
+            <id>snapshots</id>
+            <url>http://192.168.0.115:8081/nexus-2.14.2-01/content/repositories/snapshots/</url>
+        </snapshotRepository>
+    </distributionManagement>
+
+</project>

src/main/java/com/fdkankan/deploy/Application.java

@@ -0,0 +1,16 @@
+package com.fdkankan.deploy;
+
+import com.dtflys.forest.springboot.annotation.ForestScan;
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+@MapperScan("com.fdkankan.deploy.mapper")
+@ForestScan(basePackages = "com.fdkankan.deploy.httpclient")
+public class Application {
+    public static void main(String[] args) {
+        SpringApplication.run(Application.class, args);
+    }
+
+}

src/main/java/com/fdkankan/deploy/auth/RoleType.java

@@ -0,0 +1,16 @@
+package com.fdkankan.deploy.auth;
+
+/**
+ * 角色类型
+ *
+ * @author dhb
+ */
+public class RoleType {
+
+
+    public static final String SUPER_ADMIN = "SUPER_ADMIN";
+
+    public static final String SYS_ADMIN = "SYS_ADMIN";
+
+    public static final String ROLE_PMS = "ROLE_PMS";
+}

src/main/java/com/fdkankan/deploy/auth/RoleValidateAspect.java

@@ -0,0 +1,42 @@
+package com.fdkankan.deploy.auth;
+
+import cn.dev33.satoken.stp.StpUtil;
+import org.aspectj.lang.JoinPoint;
+import org.aspectj.lang.Signature;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Before;
+import org.aspectj.lang.annotation.Pointcut;
+import org.aspectj.lang.reflect.MethodSignature;
+import org.springframework.stereotype.Component;
+
+/**
+ * 角色检查切面
+ *
+ * @author dhb
+ */
+@Aspect
+@Component
+public class RoleValidateAspect {
+
+
+    @Pointcut("@annotation(Roles)")
+    public void pointcut() {
+
+    }
+
+
+    /**
+     * 在执行方法前处理
+     *
+     * @param joinPoint jp
+     */
+    @Before("pointcut()")
+    public void before(JoinPoint joinPoint) {
+        Signature signature = joinPoint.getSignature();
+        if (signature instanceof MethodSignature) {
+            MethodSignature methodSignature= (MethodSignature)signature;
+            Roles roles = methodSignature.getMethod().getAnnotation(Roles.class);
+            StpUtil.checkRoleOr(roles.value());
+        }
+    }
+}

src/main/java/com/fdkankan/deploy/auth/Roles.java

@@ -0,0 +1,20 @@
+package com.fdkankan.deploy.auth;
+
+import java.lang.annotation.*;
+
+/**
+ * 标识角色权限
+ */
+@Target(ElementType.METHOD)
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+public @interface Roles {
+
+    /**
+     * role编码
+     *
+     * @return role编码
+     */
+    String[] value();
+
+}

src/main/java/com/fdkankan/deploy/auth/SaTokenConfigure.java

@@ -0,0 +1,49 @@
+package com.fdkankan.deploy.auth;
+
+import cn.dev33.satoken.interceptor.SaInterceptor;
+import cn.dev33.satoken.jwt.StpLogicJwtForStateless;
+import cn.dev33.satoken.router.SaRouter;
+import cn.dev33.satoken.router.SaRouterStaff;
+import cn.dev33.satoken.stp.StpLogic;
+import cn.dev33.satoken.stp.StpUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * SaToken的配置类
+ */
+@Configuration
+public class SaTokenConfigure implements WebMvcConfigurer {
+
+    public static final String JWT_USER_ID_KEY = "userId";
+
+    public static final String JWT_USERNAME_KEY = "username";
+
+    public static final String JWT_ROLE_LIST_KEY = "roleCodes";
+
+    public static final String JWT_CURRENT_ROLE_KEY = "currentRoleCode";
+
+    @Bean
+    public StpLogic getStpLogicJwt() {
+        return new StpLogicJwtForStateless();
+    }
+
+    @Autowired
+    HttpServletRequest httpServletRequest;
+
+    @Override
+    public void addInterceptors(InterceptorRegistry registry) {
+        registry.addInterceptor(new SaInterceptor(handle -> {
+            SaRouterStaff check = SaRouter.match("/**")
+                    .notMatch("/user/login")
+                    .check(r -> StpUtil.checkLogin());
+        }));
+    }
+
+
+}

src/main/java/com/fdkankan/deploy/auth/StpInterfaceImpl.java

@@ -0,0 +1,28 @@
+package com.fdkankan.deploy.auth;
+
+import cn.dev33.satoken.stp.StpInterface;
+import cn.dev33.satoken.stp.StpUtil;
+import cn.hutool.core.collection.CollUtil;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 鉴权
+ *
+ * @author dhb
+ */
+@Component
+public class StpInterfaceImpl implements StpInterface {
+
+    @Override
+    public List<String> getPermissionList(Object loginId, String loginType) {
+        return null;
+    }
+
+    @Override
+    public List<String> getRoleList(Object loginId, String loginType) {
+        String role = (String) StpUtil.getExtra(SaTokenConfigure.JWT_CURRENT_ROLE_KEY);
+        return CollUtil.newArrayList(role);
+    }
+}

src/main/java/com/fdkankan/deploy/bean/SceneDeployBean.java

@@ -0,0 +1,24 @@
+package com.fdkankan.deploy.bean;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class SceneDeployBean {
+
+    private String num;
+    private String title;
+    private String calcTime;
+    private String syncTime;
+    private String sceneType;
+
+    public String getKey(){
+        return num + "-" + sceneType;
+    }
+
+}

src/main/java/com/fdkankan/deploy/callback/ErrorCallback.java

@@ -0,0 +1,39 @@
+package com.fdkankan.deploy.callback;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.dtflys.forest.callback.OnError;
+import com.dtflys.forest.exceptions.ForestRuntimeException;
+import com.dtflys.forest.http.ForestRequest;
+import com.dtflys.forest.http.ForestResponse;
+import com.fdkankan.common.exception.BusinessException;
+import com.fdkankan.web.response.ResultData;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * <p>
+ * TODO
+ * </p>
+ *
+ * @author dengsixing
+ * @since 2022/4/25
+ **/
+@Slf4j
+public class ErrorCallback implements OnError {
+
+    @Override
+    public void onError(ForestRuntimeException e, ForestRequest forestRequest,
+        ForestResponse forestResponse) {
+        JSONObject jsonObject = JSON.parseObject(forestResponse.getContent());
+        Integer status = jsonObject.getInteger("status");
+        if(status != null && status == 500){
+            log.error("接口报错,url:{},status:{},error:{}", forestRequest.getUrl(), status, jsonObject.getString("error"));
+            throw e;
+        }
+        ResultData result = JSON.parseObject(forestResponse.getContent(), ResultData.class);
+        if(result.getCode() != 0){
+            throw new BusinessException(result.getCode(), result.getMessage());
+        }
+        throw new BusinessException(-1, "未知异常");
+    }
+}

src/main/java/com/fdkankan/deploy/callback/SuccessCallback.java

@@ -0,0 +1,25 @@
+package com.fdkankan.deploy.callback;
+
+import com.dtflys.forest.callback.OnSuccess;
+import com.dtflys.forest.http.ForestRequest;
+import com.dtflys.forest.http.ForestResponse;
+import com.fdkankan.web.response.ResultData;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * <p>
+ * TODO
+ * </p>
+ *
+ * @author dengsixing
+ * @since 2022/4/25
+ **/
+@Slf4j
+public class SuccessCallback implements OnSuccess<ResultData> {
+
+    @Override
+    public void onSuccess(ResultData result, ForestRequest forestRequest,
+        ForestResponse forestResponse) {
+        log.info("请求成功，url:{},result:{}", forestRequest.getUrl(), forestResponse.getContent());
+    }
+}

src/main/java/com/fdkankan/deploy/callback/SuccessCondition.java

@@ -0,0 +1,49 @@
+package com.fdkankan.deploy.callback;
+
+import cn.hutool.core.util.StrUtil;
+import com.alibaba.fastjson.JSON;
+import com.dtflys.forest.callback.SuccessWhen;
+import com.dtflys.forest.http.ForestRequest;
+import com.dtflys.forest.http.ForestResponse;
+import com.fdkankan.web.response.ResultData;
+
+/**
+ * <p>
+ *  自定义成功/失败条件实现类
+ *  需要实现 SuccessWhen 接口
+ * </p>
+ *
+ * @author dengsixing
+ * @since 2022/4/25
+ **/
+
+public class SuccessCondition implements SuccessWhen {
+
+    /**
+     * 请求成功条件
+     * @param req Forest请求对象
+     * @param res Forest响应对象
+     * @return 是否成功，true: 请求成功，false: 请求失败
+     */
+    @Override
+    public boolean successWhen(ForestRequest req, ForestResponse res) {
+        boolean reqStatus = res.noException() &&   // 请求过程没有异常
+            res.statusOk() &&     // 并且状态码在 100 ~ 399 范围内
+            res.statusIsNot(203);
+        if(!reqStatus){
+            return reqStatus;
+        }
+
+        String content = res.getContent();
+        if(StrUtil.isEmpty(content)){
+            reqStatus = false;
+            return reqStatus;
+        }
+        ResultData result = JSON.parseObject(content, ResultData.class);
+        if(result.getCode() != 0){
+            reqStatus = false;
+            return reqStatus;
+        }
+        return true;
+    }
+}

src/main/java/com/fdkankan/deploy/config/MybatisPlusConfigure.java

@@ -0,0 +1,33 @@
+package com.fdkankan.deploy.config;
+
+import com.baomidou.mybatisplus.annotation.DbType;
+import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
+import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * mybatis plus配置
+ *
+ * @author dhb
+ */
+@Configuration
+@MapperScan("com.fdkankan.deploy.mapper")
+public class MybatisPlusConfigure {
+
+
+    /**
+     * 分页插件
+     *
+     * @return bean
+     */
+    @Bean
+    public MybatisPlusInterceptor mybatisPlusInterceptor() {
+        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
+        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.SQLITE));
+        return interceptor;
+    }
+
+
+}

src/main/java/com/fdkankan/deploy/controller/SceneController.java

@@ -0,0 +1,57 @@
+package com.fdkankan.deploy.controller;
+
+
+import com.fdkankan.deploy.entity.Scene;
+import com.fdkankan.deploy.service.SceneService;
+import com.fdkankan.web.response.ResultData;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.Map;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author 
+ * @since 2025-11-05
+ */
+@RestController
+@RequestMapping("/scene")
+public class SceneController {
+
+    @Autowired
+    private SceneService sceneService;
+
+    @GetMapping
+    private ResultData test(){
+        return ResultData.ok(sceneService.list());
+    }
+
+    @GetMapping("test2")
+    private ResultData test2(){
+        Scene scene = new Scene();
+        scene.setNum("123");
+        scene.setTitle("123");
+        scene.setSpace(123);
+        scene.setUploadTime("123");
+        scene.setShootCount(123);
+        sceneService.save(scene);
+        return ResultData.ok();
+    }
+
+    @PostMapping("/receive")
+    public ResultData receive(@RequestBody Map<String, Object> params){
+        return sceneService.receive(params);
+    }
+
+    @PostMapping("/receive2")
+    public ResultData receive2(HttpServletRequest request) throws Exception {
+        return sceneService.receive2(request);
+    }
+
+
+}
+

src/main/java/com/fdkankan/deploy/controller/UserController.java

@@ -0,0 +1,56 @@
+package com.fdkankan.deploy.controller;
+
+
+import com.dtflys.forest.annotation.Post;
+import com.fdkankan.deploy.dto.LoginTokenDto;
+import com.fdkankan.deploy.entity.User;
+import com.fdkankan.deploy.request.LoginRequest;
+import com.fdkankan.deploy.service.UserService;
+import com.fdkankan.web.response.ResultData;
+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 javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpSession;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author 
+ * @since 2025-11-05
+ */
+@RestController
+@RequestMapping("/user")
+public class UserController {
+
+    private static final String CAPTCHA_KEY = "captchaKey";
+
+    @Autowired
+    private UserService userService;
+
+    /**
+     * 用户登录接口.
+     *
+     * @param request 请求
+     * @return 返回token
+     */
+    @PostMapping("/login")
+    public ResultData<LoginTokenDto> login(@RequestBody final LoginRequest request,
+                                           HttpServletRequest httpServletRequest) {
+        HttpSession session = httpServletRequest.getSession();
+        String captchaKey = (String) session.getAttribute(CAPTCHA_KEY);
+//        if (captchaKey != null) {
+//            request.setCaptchaKey(captchaKey);
+//        }
+        LoginTokenDto tokenDto = userService.login(request);
+        return ResultData.ok(tokenDto);
+    }
+
+}
+

src/main/java/com/fdkankan/deploy/dto/LoginTokenDto.java

@@ -0,0 +1,18 @@
+package com.fdkankan.deploy.dto;
+
+import lombok.Data;
+
+/**
+ * 登录响应token
+ *
+ * @author dhb
+ */
+@Data
+public class LoginTokenDto {
+
+    /**
+     * 通过登录获取的token
+     */
+    private String accessToken;
+
+}

src/main/java/com/fdkankan/deploy/entity/Scene.java

@@ -0,0 +1,36 @@
+package com.fdkankan.deploy.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author 
+ * @since 2025-11-05
+ */
+@Getter
+@Setter
+@TableName("t_scene")
+public class Scene implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private Integer id;
+
+    private String title;
+
+    private String num;
+
+    private String uploadTime;
+
+    private Integer shootCount;
+
+    private Integer space;
+
+
+}

src/main/java/com/fdkankan/deploy/entity/User.java

@@ -0,0 +1,30 @@
+package com.fdkankan.deploy.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author 
+ * @since 2025-11-05
+ */
+@Getter
+@Setter
+@TableName("t_user")
+public class User implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private Integer id;
+
+    private String userName;
+
+    private String password;
+
+
+}

src/main/java/com/fdkankan/deploy/generate/AutoGenerate.java

@@ -0,0 +1,81 @@
+package com.fdkankan.deploy.generate;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.generator.FastAutoGenerator;
+import com.baomidou.mybatisplus.generator.config.OutputFile;
+import com.baomidou.mybatisplus.generator.config.rules.DateType;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
+
+public class AutoGenerate {
+
+
+    public static void main(String[] args) {
+
+        String path =System.getProperty("user.dir");
+
+        generate(path,"deploy", getTables(new String[]{
+                "t_user"
+        }));
+    }
+
+    public static List<String> getTables(String [] tableNames){
+        return new ArrayList<>(Arrays.asList(tableNames));
+    }
+
+
+    public static void  generate(String path,String moduleName,  List<String> tables){
+        FastAutoGenerator.create("jdbc:sqlite:sqlite.db",
+            null,null)
+                .globalConfig(builder -> {
+                    builder.author("")               //作者
+                            .outputDir(path+"\\src\\main\\java")    //输出路径(写到java目录)
+                            //.enableSwagger()           //开启swagger
+                            .commentDate("yyyy-MM-dd")
+                            .dateType(DateType.ONLY_DATE)
+                            .fileOverride();            //开启覆盖之前生成的文件
+
+                })
+                .packageConfig(builder -> {
+                    builder.parent("com.fdkankan")
+                            .moduleName(moduleName)
+                            .entity("entity")
+                            .service("service")
+                            .serviceImpl("service.impl")
+//                            .controller("manage.controller")
+                            .mapper("mapper")
+                            .xml("test.mapper")
+                            .pathInfo(Collections.singletonMap(OutputFile.mapperXml,path+"\\src\\main\\resources\\mapper\\"+moduleName));
+                })
+                .strategyConfig(builder -> {
+                    builder.addInclude(tables)
+                            .addTablePrefix("t_")
+
+                            .serviceBuilder()
+                            .formatServiceFileName("%sService")
+                            .formatServiceImplFileName("%sServiceImpl")
+
+                            .entityBuilder()
+                            .enableLombok()
+//                            .logicDeleteColumnName("enable")
+//                            .enableTableFieldAnnotation()
+//                            .superClass(BaseEntity.class)
+
+
+                            .controllerBuilder()
+                            .formatFileName("%sController")
+                            .enableRestStyle()
+
+                            .mapperBuilder()
+                            .superClass(BaseMapper.class)
+                            .formatMapperFileName("%sMapper")
+                            .enableMapperAnnotation()
+                            .formatXmlFileName("%sMapper");
+                })
+                // .templateEngine(new FreemarkerTemplateEngine()) // 使用Freemarker引擎模板，默认的是Velocity引擎模板
+                .execute();
+    }
+}

src/main/java/com/fdkankan/deploy/httpclient/HttpClient.java

@@ -0,0 +1,45 @@
+package com.fdkankan.deploy.httpclient;
+
+import com.dtflys.forest.annotation.*;
+import com.dtflys.forest.callback.OnError;
+import com.dtflys.forest.callback.OnSuccess;
+import com.fdkankan.deploy.callback.SuccessCondition;
+import com.fdkankan.web.response.ResultData;
+import com.yomahub.tlog.forest.TLogForestInterceptor;
+
+import java.util.Map;
+
+/**
+ * <p>
+ * TODO
+ * </p>
+ *
+ * @author dengsixing
+ * @since 2022/4/24
+ **/
+@Success(condition = SuccessCondition.class)
+public interface HttpClient {
+
+    @Get(
+        url="{url}",
+        interceptor = TLogForestInterceptor.class    //加这个拦截器，打印的tlog日志会详细一些，包括头信息等等
+    )
+    @Retry(maxRetryCount = "3", maxRetryInterval = "100")
+    ResultData<Map<String, Object>> get(@Var("url") String url, @Header Map<String, Object> headerMap, OnSuccess<ResultData> onSuccess, OnError onError);
+
+    @Post(
+            url="{url}",
+            interceptor = TLogForestInterceptor.class    //加这个拦截器，打印的tlog日志会详细一些，包括头信息等等
+    )
+    @Retry(maxRetryCount = "3", maxRetryInterval = "100")
+    ResultData<Map<String, Object>> post(@Var("url") String url, @Header Map<String, Object> headerMap, @JSONBody Object param, OnSuccess<ResultData> onSuccess, OnError onError);
+
+    @Post(
+            url="{url}", timeout = 5 * 1000//
+//            ,
+//            interceptor = TLogForestInterceptor.class    //加这个拦截器，打印的tlog日志会详细一些，包括头信息等等
+    )
+    @Retry(maxRetryCount = "3", maxRetryInterval = "100")
+    ResultData post2(@Var("url") String url, @JSONBody Object param, OnSuccess<ResultData> onSuccess, OnError onError);
+
+}

src/main/java/com/fdkankan/deploy/mapper/SceneMapper.java

@@ -0,0 +1,18 @@
+package com.fdkankan.deploy.mapper;
+
+import com.fdkankan.deploy.entity.Scene;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author 
+ * @since 2025-11-05
+ */
+@Mapper
+public interface SceneMapper extends BaseMapper<Scene> {
+
+}

src/main/java/com/fdkankan/deploy/mapper/UserMapper.java

@@ -0,0 +1,18 @@
+package com.fdkankan.deploy.mapper;
+
+import com.fdkankan.deploy.entity.User;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author 
+ * @since 2025-11-05
+ */
+@Mapper
+public interface UserMapper extends BaseMapper<User> {
+
+}

src/main/java/com/fdkankan/deploy/request/LoginRequest.java

@@ -0,0 +1,23 @@
+package com.fdkankan.deploy.request;
+
+import lombok.Data;
+
+/**
+ * 登录请求参数
+ *
+ * @author dhb
+ */
+@Data
+public class LoginRequest {
+
+    /**
+     * 用户名
+     */
+    private String username;
+
+    /**
+     * 密码
+     */
+    private String password;
+
+}

src/main/java/com/fdkankan/deploy/response/PageInfo.java

@@ -0,0 +1,38 @@
+package com.fdkankan.deploy.response;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 包装分页数据
+ */
+@Data
+public class PageInfo<T> {
+
+    private List<T> pageData;
+
+    private Long total;
+
+    private Long pageSize;
+
+    private Long pageNum;
+
+
+    /**
+     * mpPage转成Page
+     *
+     * @param mpPage mp的分页结果
+     * @param <T>    类型
+     * @return page
+     */
+    public static <T> PageInfo<T> convert(IPage<T> mpPage) {
+        PageInfo<T> page = new PageInfo<>();
+        page.setPageData(mpPage.getRecords());
+        page.setTotal(mpPage.getTotal());
+        page.setPageNum(mpPage.getCurrent());
+        page.setPageSize(mpPage.getSize());
+        return page;
+    }
+}

src/main/java/com/fdkankan/deploy/service/SceneService.java

@@ -0,0 +1,24 @@
+package com.fdkankan.deploy.service;
+
+import com.fdkankan.deploy.entity.Scene;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.fdkankan.web.response.ResultData;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.Map;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author 
+ * @since 2025-11-05
+ */
+public interface SceneService extends IService<Scene> {
+    ResultData receive(Map<String, Object> params);
+
+    void donloadAndDeploy();
+
+    ResultData receive2(HttpServletRequest request) throws Exception;
+}

src/main/java/com/fdkankan/deploy/service/UserService.java

@@ -0,0 +1,20 @@
+package com.fdkankan.deploy.service;
+
+import com.fdkankan.deploy.dto.LoginTokenDto;
+import com.fdkankan.deploy.entity.User;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.fdkankan.deploy.request.LoginRequest;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author 
+ * @since 2025-11-05
+ */
+public interface UserService extends IService<User> {
+
+    LoginTokenDto login(LoginRequest request);
+
+}

src/main/java/com/fdkankan/deploy/service/impl/SceneDeployRunnerImpl.java

@@ -0,0 +1,32 @@
+//package com.fdkankan.deploy.service.impl;
+//
+//import cn.hutool.core.thread.ExecutorBuilder;
+//import com.fdkankan.deploy.service.ISceneService;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.boot.CommandLineRunner;
+//import org.springframework.stereotype.Component;
+//
+//@Slf4j
+//@Component
+//public class SceneDeployRunnerImpl implements CommandLineRunner {
+//
+//    @Autowired
+//    private ISceneService sceneService;
+//
+//    @Override
+//    public void run(String... args) throws Exception {
+//
+//        ExecutorBuilder.create().setCorePoolSize(1).setMaxPoolSize(3).build().execute(()->{
+//            for(;;){
+//                try {
+//                    sceneService.donloadAndDeploy();
+//                    Thread.sleep(10000L);
+//                }catch (Exception e){
+//                    log.error("下载并部署场景报错", e);
+//                }
+//            }
+//        });
+//    }
+//
+//}

src/main/java/com/fdkankan/deploy/service/impl/SceneServiceImpl.java

@@ -0,0 +1,274 @@
+package com.fdkankan.deploy.service.impl;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.io.FileUtil;
+import cn.hutool.core.util.ZipUtil;
+import cn.hutool.http.HttpUtil;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.fdkankan.common.util.DateExtUtil;
+import com.fdkankan.deploy.bean.SceneDeployBean;
+import com.fdkankan.deploy.entity.Scene;
+import com.fdkankan.deploy.mapper.SceneMapper;
+import com.fdkankan.deploy.service.SceneService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fdkankan.web.response.ResultData;
+import lombok.extern.slf4j.Slf4j;
+import net.lingala.zip4j.core.ZipFile;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import javax.servlet.http.HttpServletRequest;
+import java.io.File;
+import java.io.InputStream;
+import java.nio.charset.StandardCharsets;
+import java.util.*;
+import java.util.function.Function;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author 
+ * @since 2025-11-05
+ */
+@Slf4j
+@Service
+public class SceneServiceImpl extends ServiceImpl<SceneMapper, Scene> implements SceneService {
+    @Value("${scene.download.waiting-path}")
+    private String waitingFilePath;
+    @Value("${scene.download.zip-dir}")
+    private String zipDir;
+    @Value("${scene.deploy.kankan}")
+    private String delpoyKankan;
+    @Value("${scene.deploy.laser}")
+    private String delpoyLaser;
+    @Value("${scene.download.completed-file}")
+    private String completedFile;
+    @Value("${scene.download.fail-file}")
+    private String failFile;
+    @Value("${scene.list-file-path}")
+    private String listFilePath;
+    private static final String  pattern = "^\\[\\d{2}:\\d{2}:\\d{2}\\]";
+
+    @Override
+    public ResultData receive(Map<String, Object> params) {
+
+        String num = (String)params.get("num");
+
+        String waitingFileName =  Calendar.getInstance().getTimeInMillis() + "-" + num + ".txt";
+
+        FileUtil.mkParentDirs(waitingFilePath + waitingFileName);
+        FileUtil.writeUtf8String(JSON.toJSONString(params), FileUtil.file(waitingFilePath + waitingFileName));
+
+        return ResultData.ok();
+    }
+
+    @Override
+    public void donloadAndDeploy() {
+        FileUtil.mkdir(waitingFilePath);
+        List<String> waitingFileList = FileUtil.listFileNames(waitingFilePath);
+        if(CollUtil.isEmpty(waitingFileList)){
+            return;
+        }
+        String fileName = waitingFileList.stream().sorted(Comparator.comparing(String::toString)).collect(Collectors.toList()).get(0);
+        String taskStr = FileUtil.readUtf8String(waitingFilePath + fileName);
+        try {
+            JSONObject taskObj = JSON.parseObject(taskStr);
+            String num = taskObj.getString("num");
+            String downloadUrl = taskObj.getString("downloadUrl");
+            String zipType = taskObj.getString("zipType");
+            String title = taskObj.getString("title");
+            int version = taskObj.getIntValue("version");
+
+            String zipPath = zipDir + FileUtil.getPrefix(fileName) + "/";
+            String zipFilePath = zipPath + num + ".zip";
+            FileUtil.mkParentDirs(zipFilePath);
+            HttpUtil.downloadFile(downloadUrl, zipFilePath);
+            ZipUtil.unzip(zipFilePath);
+
+            if("kankan".equals(zipType)){
+                FileUtil.copy(zipPath + num+ "/wwwroot/scene_view_data/" + num, delpoyKankan, true);
+            }else{
+                FileUtil.copy(zipPath + num + "/www/" + num, delpoyLaser, true);
+            }
+
+            //写入部署清单文件
+            SceneDeployBean deployBean = SceneDeployBean.builder()
+                    .num(num).title(title).sceneType(zipType).calcTime(DateExtUtil.format(new Date(), DateExtUtil.dateStyle8))
+                    .syncTime(DateExtUtil.format(new Date(), DateExtUtil.dateStyle8)).build();
+            this.writeListJson(deployBean);
+
+            //部署完毕后写入已下载任务，删除待下载任务
+            FileUtil.mkParentDirs(completedFile);
+            FileUtil.appendUtf8String(JSON.toJSONString(taskObj) + "\n", completedFile);
+
+        }catch (Exception e){
+            log.error("部署失败,task:{}", taskStr, e);
+            FileUtil.mkParentDirs(failFile);
+            FileUtil.appendUtf8String(taskStr + "\n", failFile);
+        } finally {
+            FileUtil.del(waitingFilePath + fileName);
+        }
+    }
+
+    private synchronized void writeListJson(SceneDeployBean deployBean){
+
+        Map<String, SceneDeployBean> sceneMap = null;
+        if(FileUtil.exist(listFilePath)){
+            String listStr = FileUtil.readUtf8String(listFilePath);
+            List<SceneDeployBean> sceneDeployBeans = JSON.parseArray(listStr, SceneDeployBean.class);
+            if(CollUtil.isNotEmpty(sceneDeployBeans)){
+                sceneMap = sceneDeployBeans.stream().collect(Collectors.toMap(SceneDeployBean::getKey, Function.identity()));
+            }
+        }
+        if(CollUtil.isEmpty(sceneMap)){
+            sceneMap = new HashMap<>();
+        }
+
+        sceneMap.put(deployBean.getNum() + "-" + deployBean.getSceneType(), deployBean);
+
+        Collection<SceneDeployBean> values = sceneMap.values();
+
+        FileUtil.writeUtf8String(JSON.toJSONString(values), listFilePath);
+    }
+
+    @Override
+    public ResultData receive2(HttpServletRequest request) throws Exception {
+        String id = request.getParameter("id");
+        String action = request.getParameter("action");
+        String fileName = request.getParameter("fileName");
+        String num = request.getParameter("num");
+        String zipPath = zipDir + id + "/";
+        String zipFilePath = zipPath.concat(fileName);
+
+        if("upload".equals(action)){
+            InputStream ins = request.getPart("file").getInputStream();
+            FileUtil.mkParentDirs(zipFilePath);
+            FileUtil.writeFromStream(ins,zipFilePath);
+        }else{
+            ZipFile zipFile = new ZipFile(new File(zipFilePath));
+            zipFile.extractAll(zipPath);
+            String zipType = request.getParameter("zipType");
+            String title = request.getParameter("title");
+            int computeTime = Integer.valueOf(request.getParameter("computeTime"));
+            if("kankan".equals(zipType)){
+                FileUtil.copy(zipPath + num, delpoyKankan, true);
+            }else{
+                FileUtil.copy(zipPath + num, delpoyLaser, true);
+            }
+
+            //重写日志文件
+            this.reWriteLog(num, zipPath + num + "/console.log", computeTime);
+
+            //写入部署清单文件
+            SceneDeployBean deployBean = SceneDeployBean.builder()
+                    .num(num).title(title).sceneType(zipType).calcTime(DateExtUtil.format(new Date(), DateExtUtil.dateStyle8))
+                    .syncTime(DateExtUtil.format(new Date(), DateExtUtil.dateStyle8)).build();
+            this.writeListJson(deployBean);
+        }
+
+        return ResultData.ok();
+    }
+
+    @Value("${scene.log.path}")
+    private String sceneLogPath;
+
+    private void reWriteLog(String num, String logPath, int time){
+        List<String> strings = FileUtil.readLines(logPath, StandardCharsets.UTF_8);
+        Date endTime = Calendar.getInstance().getTime();
+        Date startTime = DateUtil.offsetSecond(endTime, -time);
+        int flag = strings.size()/time;
+        int skipIndex = time/(strings.size()%time);
+        if(time%(strings.size()%time) != 0){
+            skipIndex++;
+        }
+        String targetLog = String.format(sceneLogPath, num);
+        List<String> list = new ArrayList<>();
+        int index = 1;
+
+        int count = 0;
+        for (String str : strings) {
+            if(this.checkStartWithTime(str)){
+                list.add("[" + DateExtUtil.format(startTime, DateExtUtil.dateStyle2) + "]" + str.substring(10));
+            }else{
+                list.add(str);
+            }
+            if(count == 0){
+                if(index%flag==0){
+                    if(index%skipIndex != 0){
+                        startTime = DateUtil.offsetSecond(startTime, 1);
+                    }else{
+                        count = (++index)%skipIndex;
+                    }
+                }
+            }else{
+                if(count-- == 0){
+                    startTime = DateUtil.offsetSecond(startTime, 1);
+                }
+            }
+
+            index++;
+        }
+
+        FileUtil.writeUtf8Lines(list, targetLog);
+
+
+
+    }
+
+    public static void main(String[] args) throws Exception{
+//        net.lingala.zip4j.core.ZipFile zipFile = new ZipFile(new File("D:\\test\\KJ-t-WypZvHxCR4X.zip"));
+//        zipFile.extractAll("D:\\test\\");
+//        FileUtils.unZip("D:\\test\\aa\\KJ-t-WypZvHxCR4X.zip", "D:\\test\\aa\\");
+//        List<String> strings = FileUtil.readLines("D:\\test\\console.log", StandardCharsets.UTF_8);
+//        int time = 20 * 60;
+//        Date endTime = Calendar.getInstance().getTime();
+//        Date startTime = DateUtil.offsetSecond(endTime, -time);
+//        System.out.println("开始时间:" + DateExtUtil.format(startTime, DateExtUtil.dateStyle2));
+//        System.out.println("结束时间:" + DateExtUtil.format(endTime, DateExtUtil.dateStyle2));
+//        int flag = strings.size()/time;
+//        int test = time/(strings.size()%time);
+//        if(time%(strings.size()%time) != 0){
+//            test++;
+//        }
+//        String targetLog = "D:\\test\\aaa.log";
+//        List<String> list = new ArrayList<>();
+//        int index = 1;
+//
+//        for (String str : strings) {
+//            if(checkStartWithTime(str)){
+//                list.add("[" + DateExtUtil.format(startTime, DateExtUtil.dateStyle2) + "]" + str.substring(10));
+//            }else{
+//                list.add(str);
+//            }
+//            if(index%flag==0){
+//                if(index%test != 0){
+//                    startTime = DateUtil.offsetSecond(startTime, 1);
+//                }
+//            }
+//
+//            index++;
+//
+//        }
+//
+//        FileUtil.writeUtf8Lines(list, targetLog);
+
+
+    }
+
+    public boolean checkStartWithTime(String content){
+        Pattern r = Pattern.compile(pattern);
+        Matcher m = r.matcher(content);
+        if (m.find()) {
+            return true;
+        } else {
+            return false;
+        }
+    }
+}

src/main/java/com/fdkankan/deploy/service/impl/UserServiceImpl.java

@@ -0,0 +1,73 @@
+package com.fdkankan.deploy.service.impl;
+
+import cn.dev33.satoken.stp.SaLoginConfig;
+import cn.dev33.satoken.stp.SaTokenInfo;
+import cn.dev33.satoken.stp.StpUtil;
+import cn.hutool.core.codec.Base64;
+import cn.hutool.crypto.digest.BCrypt;
+import com.fdkankan.common.constant.ErrorCode;
+import com.fdkankan.common.exception.BusinessException;
+import com.fdkankan.deploy.auth.RoleType;
+import com.fdkankan.deploy.auth.SaTokenConfigure;
+import com.fdkankan.deploy.dto.LoginTokenDto;
+import com.fdkankan.deploy.entity.User;
+import com.fdkankan.deploy.mapper.UserMapper;
+import com.fdkankan.deploy.request.LoginRequest;
+import com.fdkankan.deploy.service.UserService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author 
+ * @since 2025-11-05
+ */
+@Service
+public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
+
+    @Override
+    public LoginTokenDto login(LoginRequest request) {
+        User user = lambdaQuery().eq(User::getUserName, request.getUsername()).one();
+        if (user == null) {
+            throw new BusinessException(ErrorCode.NON_TOKEN);
+        }
+        // 预览环境下可快速登录，不用验证码
+//        if (Boolean.TRUE.equals(request.getIsQuick()) && Boolean.TRUE.equals(previewProperties.getPreview())) {
+//            return login(request, user);
+//        }
+//        if (StrUtil.isBlank(request.getCaptchaKey())
+//            || !captchaService.verify(request.getCaptchaKey(), request.getCaptcha())) {
+//            throw new BizException(BizResponseCode.ERR_10003);
+//        }
+        return login(request, user);
+    }
+
+    private LoginTokenDto login(LoginRequest request, User user) {
+        boolean checkPw = BCrypt.checkpw(Base64.decodeStr(request.getPassword()), user.getPassword());
+        if (checkPw) {
+            String roleCode = "general";
+            if(user.getUserName().equals("admin")){
+                roleCode = RoleType.SUPER_ADMIN;
+            }
+            return generateToken(user, roleCode);
+        } else {
+            throw new BusinessException(ErrorCode.PASSWORD_ERROR);
+        }
+    }
+
+    private LoginTokenDto generateToken(User user, String roleCode) {
+        // 密码验证成功
+        StpUtil.login(user.getId(),
+                SaLoginConfig.setExtra(SaTokenConfigure.JWT_USER_ID_KEY, user.getId())
+                        .setExtra(SaTokenConfigure.JWT_USERNAME_KEY, user.getUserName())
+                        .setExtra(SaTokenConfigure.JWT_CURRENT_ROLE_KEY, roleCode));
+        SaTokenInfo tokenInfo = StpUtil.getTokenInfo();
+        LoginTokenDto dto = new LoginTokenDto();
+        dto.setAccessToken(tokenInfo.getTokenValue());
+        return dto;
+    }
+
+}

src/main/resources/application.yml

@@ -0,0 +1,58 @@
+server:
+  port: 8080
+spring:
+  application:
+    name: 4dkankan-scene-deploy
+  servlet:
+    multipart:
+      # 设置单个文件大小
+      max-file-size: -1
+      # 设置单次请求文件的总大小
+      max-request-size: -1
+  datasource:
+    url: jdbc:sqlite:sqlite.db
+    driver-class-name: org.sqlite.JDBC
+    schema: classpath:db/schema.sql
+    data: classpath:db/data.sql
+    initialization-mode: always
+    continue-on-error: true
+
+mybatis-plus:
+  mapper-locations: classpath:mapper/*.xml
+  configuration:
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+  global-config:
+    db-config:
+      id-type: auto
+  type-aliases-package: com.fdkankan.deploy.entity
+
+forest:
+  ## 日志总开关，打开/关闭Forest请求/响应日志（默认为 true）
+  log-enabled: true
+  ## 打开/关闭Forest请求日志（默认为 true）
+  log-request: true
+  ## 打开/关闭Forest响应状态日志（默认为 true）
+  log-response-status: true
+  ## 打开/关闭Forest响应内容日志（默认为 false）
+  log-response-content: true
+  ## 请求超时时间，单位为毫秒, 默认值为3000
+  timeout: 10000
+  ## 连接超时时间，单位为毫秒, 默认值为2000
+  connect-timeout: 10000
+
+scene:
+  dir: /mnt/data
+  list-file-path: ${scene.dir}/wwwroot/list.json
+  download:
+    waiting-path: ${scene.dir}/download/waiting/
+    completed-file: ${scene.dir}/download/completed.txt
+    fail-file: ${scene.dir}/download/fail.txt
+    zip-dir: ${scene.dir}/download/zip/
+  deploy:
+    kankan: ${scene.dir}/wwwroot/scene_view_data/
+    laser: ${scene.dir}/wwwroot/
+  log:
+    path: ${scene.dir}/log/%s.log
+
+
+

src/main/resources/db/data.sql

@@ -0,0 +1 @@
+INSERT INTO t_user(user_name, password) VALUES ("admin", "123456");

src/main/resources/db/schema.sql

@@ -0,0 +1,29 @@
+CREATE TABLE IF NOT EXISTS "t_scene"  (
+  "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+  "title" TEXT NOT NULL,
+  "num" TEXT NOT NULL,
+  "upload_time" text NOT NULL,
+  "shoot_count" integer,
+  "space" integer NOT NULL
+);
+
+CREATE UNIQUE INDEX IF NOT EXISTS "IDX_NUM"
+ON "t_scene" (
+  "num"
+);
+
+CREATE INDEX IF NOT EXISTS"IDX_TITLE"
+ON "t_scene" (
+  "title"
+);
+
+CREATE TABLE IF NOT EXISTS "t_user"  (
+  "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+  "user_name" TEXT NOT NULL,
+  "password" TEXT NOT NULL
+);
+
+CREATE UNIQUE INDEX IF NOT EXISTS "IDX_USERNAME"
+ON "t_user" (
+  "user_name"
+);

src/main/resources/logback-spring.xml

@@ -0,0 +1,236 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!-- 日志级别从低到高分为TRACE < DEBUG < INFO < WARN < ERROR < FATAL，如果设置为WARN，则低于WARN的信息都不会输出 -->
+<!-- scan:当此属性设置为true时，配置文件如果发生改变，将会被重新加载，默认值为true -->
+<!-- scanPeriod:设置监测配置文件是否有修改的时间间隔，如果没有给出时间单位，默认单位是毫秒。当scan为true时，此属性生效。默认的时间间隔为1分钟。 -->
+<!-- debug:当此属性设置为true时，将打印出logback内部日志信息，实时查看logback运行状态。默认值为false。 -->
+<configuration scan="true" scanPeriod="10 seconds">
+
+	<springProperty scope="context" name="LOG_PATH" source="logging.path"/>
+
+	<contextName>logback</contextName>
+	<!-- name的值是变量的名称，value的值时变量定义的值。通过定义的值会被插入到logger上下文中。定义变量后，可以使“${}”来使用变量。 -->
+	<property name="log.path" value="${LOG_PATH}/scene-deploy/logs" />
+
+	<!-- 彩色日志 -->
+	<!-- 彩色日志依赖的渲染类 -->
+	<conversionRule conversionWord="clr" converterClass="org.springframework.boot.logging.logback.ColorConverter" />
+	<conversionRule conversionWord="wex" converterClass="org.springframework.boot.logging.logback.WhitespaceThrowableProxyConverter" />
+	<conversionRule conversionWord="wEx" converterClass="org.springframework.boot.logging.logback.ExtendedWhitespaceThrowableProxyConverter" />
+	<!-- 彩色日志格式 -->
+	<property name="CONSOLE_LOG_PATTERN"
+		value="${CONSOLE_LOG_PATTERN:-%clr(%d{yyyy-MM-dd HH:mm:ss.SSS}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}}" />
+
+	<!--输出到控制台 -->
+	<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
+		<!--此日志appender是为开发使用，只配置最底级别，控制台输出的日志级别是大于或等于此级别的日志信息 -->
+		<filter class="ch.qos.logback.classic.filter.ThresholdFilter">
+			<level>info</level>
+		</filter>
+		<encoder>
+			<Pattern>${CONSOLE_LOG_PATTERN}</Pattern>
+			<!-- 设置字符集 -->
+			<charset>UTF-8</charset>
+		</encoder>
+	</appender>
+	<!--输出到文件 -->
+
+	<!-- 时间滚动输出 level为 DEBUG 日志 -->
+	<appender name="DEBUG_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
+		<!-- 正在记录的日志文件的路径及文件名 -->
+		<file>${log.path}/log_debug.log</file>
+		<!--日志文件输出格式 -->
+		<encoder>
+			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
+			<charset>UTF-8</charset> <!-- 设置字符集 -->
+		</encoder>
+		<!-- 日志记录器的滚动策略，按日期，按大小记录 -->
+		<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+			<!-- 日志归档 -->
+			<fileNamePattern>${log.path}/debug/log-debug-%d{yyyy-MM-dd}.%i.log
+			</fileNamePattern>
+			<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+				<maxFileSize>100MB</maxFileSize>
+			</timeBasedFileNamingAndTriggeringPolicy>
+			<!--日志文件保留天数 -->
+			<maxHistory>15</maxHistory>
+		</rollingPolicy>
+		<!-- 此日志文件只记录debug级别的 -->
+		<filter class="ch.qos.logback.classic.filter.LevelFilter">
+			<level>debug</level>
+			<onMatch>ACCEPT</onMatch>
+			<onMismatch>DENY</onMismatch>
+		</filter>
+	</appender>
+
+	<appender name="ASYNC_DEBUG_FILE" class="com.yomahub.tlog.core.enhance.logback.async.AspectLogbackAsyncAppender">
+		<!--默认情况下，当BlockingQueue还有20%容量，他将丢弃TRACE、DEBUG和INFO级别的event，只保留WARN和ERROR级别的event。为了保持所有的events，设置该值为0。-->
+		<discardingThreshold>0</discardingThreshold>
+		<!--queue配置最大容量为256个events。如果队列被填满，应用程序线程被阻止记录新的events，直到工作线程有机会来转发一个或多个events。
+		因此队列深度需要根据业务场景进行相应的测试，做出相应的更改，以达到较好的性能。-->
+		<queueSize>2048</queueSize>
+		<includeCallerData>false</includeCallerData>
+		<appender-ref ref="DEBUG_FILE"/>
+	</appender>
+
+	<!-- 时间滚动输出 level为 INFO 日志 -->
+	<appender name="INFO_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
+		<!-- 正在记录的日志文件的路径及文件名 -->
+		<file>${log.path}/log_info.log</file>
+		<!--日志文件输出格式 -->
+		<encoder>
+			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
+			<charset>UTF-8</charset>
+		</encoder>
+		<!-- 日志记录器的滚动策略，按日期，按大小记录 -->
+		<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+			<!-- 每天日志归档路径以及格式 -->
+			<fileNamePattern>${log.path}/info/log-info-%d{yyyy-MM-dd}.%i.log
+			</fileNamePattern>
+			<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+				<maxFileSize>100MB</maxFileSize>
+			</timeBasedFileNamingAndTriggeringPolicy>
+			<!--日志文件保留天数 -->
+			<maxHistory>15</maxHistory>
+		</rollingPolicy>
+		<!-- 此日志文件只记录info级别的 -->
+		<filter class="ch.qos.logback.classic.filter.LevelFilter">
+			<level>info</level>
+			<onMatch>ACCEPT</onMatch>
+			<onMismatch>DENY</onMismatch>
+		</filter>
+	</appender>
+
+	<appender name="ASYNC_INFO_FILE" class="com.yomahub.tlog.core.enhance.logback.async.AspectLogbackAsyncAppender">
+		<!--默认情况下，当BlockingQueue还有20%容量，他将丢弃TRACE、DEBUG和INFO级别的event，只保留WARN和ERROR级别的event。为了保持所有的events，设置该值为0。-->
+		<discardingThreshold>0</discardingThreshold>
+		<!--queue配置最大容量为256个events。如果队列被填满，应用程序线程被阻止记录新的events，直到工作线程有机会来转发一个或多个events。
+		因此队列深度需要根据业务场景进行相应的测试，做出相应的更改，以达到较好的性能。-->
+		<queueSize>2048</queueSize>
+		<includeCallerData>false</includeCallerData>
+		<appender-ref ref="INFO_FILE"/>
+	</appender>
+
+	<!-- 时间滚动输出 level为 WARN 日志 -->
+	<appender name="WARN_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
+		<!-- 正在记录的日志文件的路径及文件名 -->
+		<file>${log.path}/log_warn.log</file>
+		<!--日志文件输出格式 -->
+		<encoder>
+			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
+			<charset>UTF-8</charset> <!-- 此处设置字符集 -->
+		</encoder>
+		<!-- 日志记录器的滚动策略，按日期，按大小记录 -->
+		<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+			<fileNamePattern>${log.path}/warn/log-warn-%d{yyyy-MM-dd}.%i.log
+			</fileNamePattern>
+			<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+				<maxFileSize>100MB</maxFileSize>
+			</timeBasedFileNamingAndTriggeringPolicy>
+			<!--日志文件保留天数 -->
+			<maxHistory>15</maxHistory>
+		</rollingPolicy>
+		<!-- 此日志文件只记录warn级别的 -->
+		<filter class="ch.qos.logback.classic.filter.LevelFilter">
+			<level>warn</level>
+			<onMatch>ACCEPT</onMatch>
+			<onMismatch>DENY</onMismatch>
+		</filter>
+	</appender>
+
+	<appender name="ASYNC_WARN_FILE" class="com.yomahub.tlog.core.enhance.logback.async.AspectLogbackAsyncAppender">
+		<!--默认情况下，当BlockingQueue还有20%容量，他将丢弃TRACE、DEBUG和INFO级别的event，只保留WARN和ERROR级别的event。为了保持所有的events，设置该值为0。-->
+		<discardingThreshold>0</discardingThreshold>
+		<!--queue配置最大容量为256个events。如果队列被填满，应用程序线程被阻止记录新的events，直到工作线程有机会来转发一个或多个events。
+		因此队列深度需要根据业务场景进行相应的测试，做出相应的更改，以达到较好的性能。-->
+		<queueSize>2048</queueSize>
+		<includeCallerData>false</includeCallerData>
+		<appender-ref ref="WARN_FILE"/>
+	</appender>
+
+
+	<!-- 时间滚动输出 level为 ERROR 日志 -->
+	<appender name="ERROR_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
+		<!-- 正在记录的日志文件的路径及文件名 -->
+		<file>${log.path}/log_error.log</file>
+		<!--日志文件输出格式 -->
+		<encoder>
+			<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
+			<charset>UTF-8</charset> <!-- 此处设置字符集 -->
+		</encoder>
+		<!-- 日志记录器的滚动策略，按日期，按大小记录 -->
+		<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+			<fileNamePattern>${log.path}/error/log-error-%d{yyyy-MM-dd}.%i.log
+			</fileNamePattern>
+			<timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+				<maxFileSize>100MB</maxFileSize>
+			</timeBasedFileNamingAndTriggeringPolicy>
+			<!--日志文件保留天数 -->
+			<maxHistory>15</maxHistory>
+		</rollingPolicy>
+		<!-- 此日志文件只记录ERROR级别的 -->
+		<filter class="ch.qos.logback.classic.filter.LevelFilter">
+			<level>ERROR</level>
+			<onMatch>ACCEPT</onMatch>
+			<onMismatch>DENY</onMismatch>
+		</filter>
+	</appender>
+
+	<appender name="ASYNC_ERROR_FILE" class="com.yomahub.tlog.core.enhance.logback.async.AspectLogbackAsyncAppender">
+		<!--默认情况下，当BlockingQueue还有20%容量，他将丢弃TRACE、DEBUG和INFO级别的event，只保留WARN和ERROR级别的event。为了保持所有的events，设置该值为0。-->
+		<discardingThreshold>0</discardingThreshold>
+		<!--queue配置最大容量为256个events。如果队列被填满，应用程序线程被阻止记录新的events，直到工作线程有机会来转发一个或多个events。
+		因此队列深度需要根据业务场景进行相应的测试，做出相应的更改，以达到较好的性能。-->
+		<queueSize>2048</queueSize>
+		<includeCallerData>false</includeCallerData>
+		<appender-ref ref="ERROR_FILE"/>
+	</appender>
+
+
+	<!-- <logger>用来设置某一个包或者具体的某一个类的日志打印级别、 以及指定<appender>。<logger>仅有一个name属性， 一个可选的level和一个可选的addtivity属性。 name:用来指定受此logger约束的某一个包或者具体的某一个类。 level:用来设置打印级别，大小写无关：TRACE,
+		DEBUG, INFO, WARN, ERROR, ALL 和 OFF， 还有一个特俗值INHERITED或者同义词NULL，代表强制执行上级的级别。 如果未设置此属性，那么当前logger将会继承上级的级别。 addtivity:是否向上级logger传递打印信息。默认是true。 -->
+	<!--<logger name="org.springframework.web" level="info"/> -->
+	<!--<logger name="org.springframework.scheduling.annotation.ScheduledAnnotationBeanPostProcessor" level="INFO"/> -->
+	<!-- 使用mybatis的时候，sql语句是debug下才会打印，而这里我们只配置了info，所以想要查看sql语句的话，有以下两种操作： 第一种把<root level="info">改成<root level="DEBUG">这样就会打印sql，不过这样日志那边会出现很多其他消息 第二种就是单独给dao下目录配置debug模式，代码如下，这样配置sql语句会打印，其他还是正常info级别： -->
+	<!-- root节点是必选节点，用来指定最基础的日志输出级别，只有一个level属性 level:用来设置打印级别，大小写无关：TRACE, DEBUG, INFO, WARN, ERROR, ALL 和 OFF， 不能设置为INHERITED或者同义词NULL。默认是DEBUG 可以包含零个或多个元素，标识这个appender将会添加到这个logger。 -->
+
+	<root level="info">
+		<appender-ref ref="CONSOLE" />
+		<appender-ref ref="ASYNC_DEBUG_FILE" />
+		<appender-ref ref="ASYNC_INFO_FILE" />
+		<appender-ref ref="ASYNC_WARN_FILE" />
+		<appender-ref ref="ASYNC_ERROR_FILE" />
+	</root>
+
+	<springProfile name="dev">
+		<root level="info">
+			<appender-ref ref="CONSOLE" />
+			<appender-ref ref="ASYNC_DEBUG_FILE" />
+			<appender-ref ref="ASYNC_INFO_FILE" />
+			<appender-ref ref="ASYNC_WARN_FILE" />
+			<appender-ref ref="ASYNC_ERROR_FILE" />
+		</root>
+	</springProfile>
+
+	<springProfile name="test">
+		<root level="info">
+			<appender-ref ref="CONSOLE" />
+			<appender-ref ref="ASYNC_DEBUG_FILE" />
+			<appender-ref ref="ASYNC_INFO_FILE" />
+			<appender-ref ref="ASYNC_WARN_FILE" />
+			<appender-ref ref="ASYNC_ERROR_FILE" />
+		</root>
+	</springProfile>
+
+	<springProfile name="pro">
+		<root level="info">
+			<appender-ref ref="CONSOLE" />
+			<appender-ref ref="ASYNC_DEBUG_FILE" />
+			<appender-ref ref="ASYNC_INFO_FILE" />
+			<appender-ref ref="ASYNC_WARN_FILE" />
+			<appender-ref ref="ASYNC_ERROR_FILE" />
+		</root>
+	</springProfile>
+
+</configuration>
+
+

src/main/resources/mapper/deploy/SceneMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.fdkankan.deploy.mapper.SceneMapper">
+
+</mapper>

src/main/resources/mapper/deploy/UserMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.fdkankan.deploy.mapper.UserMapper">
+
+</mapper>