fix: 数据接入，控制器需要判断开关数据和溶解氧数据。

# Conflicts:
#	intc-modules/intc-iot/src/main/resources/application.yml
#	intc-modules/intc-tdengine/src/main/resources/mapper/tdengine/DeviceSensorDataMapper.xml
#	intc-modules/intc-weixin/src/main/resources/application.yml

intc-admin/Dockerfile

@@ -5,11 +5,11 @@ FROM bellsoft/liberica-openjdk-rocky:17.0.16-cds
 
 LABEL maintainer="Lion Li"
 
-RUN mkdir -p /ruoyi/server/logs \
-    /ruoyi/server/temp \
-    /ruoyi/skywalking/agent
+RUN mkdir -p /intc/server/logs \
+    /intc/server/temp \
+    /intc/skywalking/agent
 
-WORKDIR /ruoyi/server
+WORKDIR /intc/server
 
 ENV SERVER_PORT=8080 SNAIL_PORT=28080 LANG=C.UTF-8 LC_ALL=C.UTF-8 JAVA_OPTS=""
 
@@ -17,7 +17,7 @@ EXPOSE ${SERVER_PORT}
 # 暴露 snail job 客户端端口 用于定时任务调度中心通信
 EXPOSE ${SNAIL_PORT}
 
-ADD ./target/ruoyi-admin.jar ./app.jar
+ADD ./target/intc-admin.jar ./app.jar
 
 SHELL ["/bin/bash", "-c"]
 

intc-admin/pom.xml

@@ -3,13 +3,13 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>ruoyi-vue-plus</artifactId>
-        <groupId>org.dromara</groupId>
+        <artifactId>intc-vue-ultra</artifactId>
+        <groupId>com.intc</groupId>
         <version>${revision}</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <packaging>jar</packaging>
-    <artifactId>ruoyi-admin</artifactId>
+    <artifactId>intc-admin</artifactId>
 
     <description>
         web服务入口
@@ -22,6 +22,11 @@
             <groupId>com.mysql</groupId>
             <artifactId>mysql-connector-j</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.taosdata.jdbc</groupId>
+            <artifactId>taos-jdbcdriver</artifactId>
+            <version>2.0.38</version>
+        </dependency>
 
 <!--        &lt;!&ndash; mp支持的数据库均支持 只需要增加对应的jdbc依赖即可 &ndash;&gt;-->
 <!--        &lt;!&ndash; Oracle &ndash;&gt;-->
@@ -46,56 +51,74 @@
 <!--        </dependency>-->
 
         <dependency>
-            <groupId>org.dromara</groupId>
-            <artifactId>ruoyi-common-doc</artifactId>
+            <groupId>com.intc</groupId>
+            <artifactId>intc-common-doc</artifactId>
         </dependency>
 
         <dependency>
-            <groupId>org.dromara</groupId>
-            <artifactId>ruoyi-common-social</artifactId>
+            <groupId>com.intc</groupId>
+            <artifactId>intc-common-social</artifactId>
         </dependency>
 
         <dependency>
-            <groupId>org.dromara</groupId>
-            <artifactId>ruoyi-common-ratelimiter</artifactId>
+            <groupId>com.intc</groupId>
+            <artifactId>intc-common-ratelimiter</artifactId>
         </dependency>
 
         <dependency>
-            <groupId>org.dromara</groupId>
-            <artifactId>ruoyi-common-mail</artifactId>
+            <groupId>com.intc</groupId>
+            <artifactId>intc-common-mail</artifactId>
         </dependency>
 
         <dependency>
-            <groupId>org.dromara</groupId>
-            <artifactId>ruoyi-system</artifactId>
+            <groupId>com.intc</groupId>
+            <artifactId>intc-system</artifactId>
         </dependency>
 
         <dependency>
-            <groupId>org.dromara</groupId>
-            <artifactId>ruoyi-job</artifactId>
+            <groupId>com.intc</groupId>
+            <artifactId>intc-job</artifactId>
         </dependency>
 
         <!-- 代码生成-->
         <dependency>
-            <groupId>org.dromara</groupId>
-            <artifactId>ruoyi-generator</artifactId>
+            <groupId>com.intc</groupId>
+            <artifactId>intc-generator</artifactId>
         </dependency>
 
         <!--  demo模块  -->
         <dependency>
-            <groupId>org.dromara</groupId>
-            <artifactId>ruoyi-demo</artifactId>
+            <groupId>com.intc</groupId>
+            <artifactId>intc-demo</artifactId>
         </dependency>
         <!--  鱼测云模块  -->
         <dependency>
-            <groupId>org.dromara</groupId>
-            <artifactId>ruoyi-fishery</artifactId>
+            <groupId>com.intc</groupId>
+            <artifactId>intc-fishery</artifactId>
+            <version>${revision}</version> <!-- 使用项目统一版本变量 -->
+        </dependency>
+        <!--  时序数据  -->
+        <dependency>
+            <groupId>com.intc</groupId>
+            <artifactId>intc-tdengine</artifactId>
             <version>${revision}</version> <!-- 使用项目统一版本变量 -->
         </dependency>
         <!--  工作流模块  -->
         <dependency>
-            <groupId>org.dromara</groupId>
-            <artifactId>ruoyi-workflow</artifactId>
+            <groupId>com.intc</groupId>
+            <artifactId>intc-workflow</artifactId>
+        </dependency>
+        <!--  物联网模块  -->
+        <dependency>
+            <groupId>com.intc</groupId>
+            <artifactId>intc-iot</artifactId>
+            <version>${revision}</version>
+        </dependency>
+        <!--  微信对接模块  -->
+        <dependency>
+            <groupId>com.intc</groupId>
+            <artifactId>intc-weixin</artifactId>
+            <version>${revision}</version>
         </dependency>
 
         <dependency>

intc-admin/src/main/java/com/intc/IntcUltraApplication.java

@@ -1,4 +1,4 @@
-package org.dromara;
+package com.intc;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
@@ -11,13 +11,13 @@ import org.springframework.boot.context.metrics.buffering.BufferingApplicationSt
  */
 
 @SpringBootApplication
-public class DromaraApplication {
+public class IntcUltraApplication {
 
     public static void main(String[] args) {
-        SpringApplication application = new SpringApplication(DromaraApplication.class);
+        SpringApplication application = new SpringApplication(IntcUltraApplication.class);
         application.setApplicationStartup(new BufferingApplicationStartup(2048));
         application.run(args);
-        System.out.println("(♥◠‿◠)ﾉﾞ  RuoYi-Vue-Plus启动成功   ლ(´ڡ`ლ)ﾞ");
+        System.out.println("(♥◠‿◠)ﾉﾞ  Intc-Vue-Ultra启动成功   ლ(´ڡ`ლ)ﾞ");
     }
 
 }

intc-admin/src/main/java/com/intc/IntcUltraServletInitializer.java

@@ -1,4 +1,4 @@
-package org.dromara;
+package com.intc;
 
 import org.springframework.boot.builder.SpringApplicationBuilder;
 import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
@@ -8,11 +8,11 @@ import org.springframework.boot.web.servlet.support.SpringBootServletInitializer
  *
  * @author Lion Li
  */
-public class DromaraServletInitializer extends SpringBootServletInitializer {
+public class IntcUltraServletInitializer extends SpringBootServletInitializer {
 
     @Override
     protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
-        return application.sources(DromaraApplication.class);
+        return application.sources(IntcUltraApplication.class);
     }
 
 }

intc-admin/src/main/java/com/intc/web/controller/AuthController.java

@@ -1,4 +1,4 @@
-package org.dromara.web.controller;
+package com.intc.web.controller;
 
 import cn.dev33.satoken.annotation.SaIgnore;
 import cn.dev33.satoken.exception.NotLoginException;
@@ -6,6 +6,41 @@ import cn.dev33.satoken.stp.StpUtil;
 import cn.hutool.core.codec.Base64;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.ObjectUtil;
+import com.intc.common.core.constant.SystemConstants;
+import com.intc.common.core.domain.R;
+import com.intc.common.core.domain.model.LoginBody;
+import com.intc.common.core.domain.model.RegisterBody;
+import com.intc.common.core.domain.model.SocialLoginBody;
+import com.intc.common.core.exception.ServiceException;
+import com.intc.common.core.utils.*;
+import com.intc.common.encrypt.annotation.ApiEncrypt;
+import com.intc.common.json.utils.JsonUtils;
+import com.intc.common.ratelimiter.annotation.RateLimiter;
+import com.intc.common.ratelimiter.enums.LimitType;
+import com.intc.common.satoken.utils.LoginHelper;
+import com.intc.common.social.config.properties.SocialLoginConfigProperties;
+import com.intc.common.social.config.properties.SocialProperties;
+import com.intc.common.social.utils.SocialUtils;
+import com.intc.common.sse.dto.SseMessageDto;
+import com.intc.common.sse.utils.SseMessageUtils;
+import com.intc.common.tenant.helper.TenantHelper;
+import com.intc.fishery.domain.AquUser;
+import com.intc.system.domain.bo.SysTenantBo;
+import com.intc.system.domain.vo.SysClientVo;
+import com.intc.system.domain.vo.SysTenantVo;
+import com.intc.system.service.ISysClientService;
+import com.intc.system.service.ISysConfigService;
+import com.intc.system.service.ISysSocialService;
+import com.intc.system.service.ISysTenantService;
+import com.intc.web.domain.vo.LoginTenantVo;
+import com.intc.web.domain.vo.LoginVo;
+import com.intc.web.domain.vo.TenantListVo;
+import com.intc.web.service.IAuthStrategy;
+import com.intc.web.service.SysLoginService;
+import com.intc.web.service.SysRegisterService;
+import com.intc.weixin.domain.bo.ReqWxLogin;
+import com.intc.weixin.service.WxLoginService;
+import com.intc.weixin.config.WxMaProperties;
 import jakarta.servlet.http.HttpServletRequest;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -13,36 +48,7 @@ import me.zhyd.oauth.model.AuthResponse;
 import me.zhyd.oauth.model.AuthUser;
 import me.zhyd.oauth.request.AuthRequest;
 import me.zhyd.oauth.utils.AuthStateUtils;
-import org.dromara.common.core.constant.SystemConstants;
-import org.dromara.common.core.domain.R;
-import org.dromara.common.core.domain.model.LoginBody;
-import org.dromara.common.core.domain.model.RegisterBody;
-import org.dromara.common.core.domain.model.SocialLoginBody;
-import org.dromara.common.core.utils.*;
-import org.dromara.common.encrypt.annotation.ApiEncrypt;
-import org.dromara.common.json.utils.JsonUtils;
-import org.dromara.common.ratelimiter.annotation.RateLimiter;
-import org.dromara.common.ratelimiter.enums.LimitType;
-import org.dromara.common.satoken.utils.LoginHelper;
-import org.dromara.common.social.config.properties.SocialLoginConfigProperties;
-import org.dromara.common.social.config.properties.SocialProperties;
-import org.dromara.common.social.utils.SocialUtils;
-import org.dromara.common.sse.dto.SseMessageDto;
-import org.dromara.common.sse.utils.SseMessageUtils;
-import org.dromara.common.tenant.helper.TenantHelper;
-import org.dromara.system.domain.bo.SysTenantBo;
-import org.dromara.system.domain.vo.SysClientVo;
-import org.dromara.system.domain.vo.SysTenantVo;
-import org.dromara.system.service.ISysClientService;
-import org.dromara.system.service.ISysConfigService;
-import org.dromara.system.service.ISysSocialService;
-import org.dromara.system.service.ISysTenantService;
-import org.dromara.web.domain.vo.LoginTenantVo;
-import org.dromara.web.domain.vo.LoginVo;
-import org.dromara.web.domain.vo.TenantListVo;
-import org.dromara.web.service.IAuthStrategy;
-import org.dromara.web.service.SysLoginService;
-import org.dromara.web.service.SysRegisterService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
@@ -75,6 +81,12 @@ public class AuthController {
     private final ISysClientService clientService;
     private final ScheduledExecutorService scheduledExecutorService;
 
+    @Autowired(required = false)
+    private WxLoginService wxLoginService;
+
+    @Autowired(required = false)
+    private WxMaProperties wxMaProperties;
+
 
     /**
      * 登录方法
@@ -106,7 +118,7 @@ public class AuthController {
         Long userId = LoginHelper.getUserId();
         scheduledExecutorService.schedule(() -> {
             SseMessageDto dto = new SseMessageDto();
-            dto.setMessage("欢迎登录RuoYi-Vue-Plus后台管理系统");
+            dto.setMessage("欢迎登录水产养殖监测平台");
             dto.setUserIds(List.of(userId));
             SseMessageUtils.publishMessage(dto);
         }, 5, TimeUnit.SECONDS);
@@ -239,4 +251,73 @@ public class AuthController {
         return R.ok(result);
     }
 
+    /**
+     * 微信小程序登录
+     *
+     * @param body 微信登录请求JSON字符串
+     * @return 结果
+     */
+    @ApiEncrypt
+    @PostMapping("/wechat_login")
+    public R<LoginVo> wechatLogin(@RequestBody String body) {
+        try {
+            ReqWxLogin request = JsonUtils.parseObject(body, ReqWxLogin.class);
+            ValidatorUtils.validate(request);
+            
+            // 如果未传递 clientId，使用默认配置的 clientId
+            if (StringUtils.isBlank(request.getClientId()) && wxMaProperties != null) {
+                request.setClientId(wxMaProperties.getDefaultClientId());
+                // 更新 body 中的 clientId
+                body = JsonUtils.toJsonString(request);
+            }
+            
+            String clientId = request.getClientId();
+            String grantType = "wechat"; // 微信登录的授权类型
+            
+            log.info("收到微信登录请求: clientId={}, tenantId={}", clientId, request.getTenantId());
+
+            // 1. 检查服务是否可用
+            if (wxLoginService == null) {
+                log.error("微信登录服务未启用，请检查配置: wx.miniapp.app-id");
+                return R.fail("微信登录服务未启用，请联系管理员");
+            }
+
+            // 2. 校验客户端
+            SysClientVo client = clientService.queryByClientId(clientId);
+            if (ObjectUtil.isNull(client)) {
+                log.error("客户端不存在: clientId={}", clientId);
+                return R.fail(MessageUtils.message("auth.grant.type.error"));
+            }
+            // 校验 client 内是否包含 grantType
+            if (!StringUtils.contains(client.getGrantType(), grantType)) {
+                log.error("客户端不支持该授权类型: clientId={}, grantType={}", clientId, grantType);
+                return R.fail(MessageUtils.message("auth.grant.type.error"));
+            }
+            if (!SystemConstants.NORMAL.equals(client.getStatus())) {
+                log.error("客户端已被禁用: clientId={}, status={}", clientId, client.getStatus());
+                return R.fail(MessageUtils.message("auth.grant.type.blocked"));
+            }
+
+            // 3. 校验租户
+            if (StringUtils.isNotBlank(request.getTenantId())) {
+                loginService.checkTenant(request.getTenantId());
+            }
+
+            // 4. 使用标准的 IAuthStrategy 登录方法
+            LoginVo loginVo = IAuthStrategy.login(body, client, grantType);
+            
+            log.info("微信登录成功: userId={}, accessToken={}",
+                loginVo.getUserId(), loginVo.getAccessToken() != null ? "***" : "null");
+
+            return R.ok(loginVo);
+
+        } catch (ServiceException e) {
+            log.error("微信登录业务异常: {}", e.getMessage(), e);
+            return R.fail(e.getMessage());
+        } catch (Exception e) {
+            log.error("微信登录系统异常", e);
+            return R.fail("登录失败: " + e.getMessage());
+        }
+    }
+
 }

intc-admin/src/main/java/com/intc/web/controller/CaptchaController.java

@@ -1,36 +1,40 @@
-package org.dromara.web.controller;
+package com.intc.web.controller;
 
 import cn.dev33.satoken.annotation.SaIgnore;
 import cn.hutool.captcha.AbstractCaptcha;
 import cn.hutool.captcha.generator.CodeGenerator;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.RandomUtil;
+import com.intc.common.core.constant.Constants;
+import com.intc.common.core.constant.GlobalConstants;
+import com.intc.common.core.domain.R;
+import com.intc.common.core.exception.ServiceException;
+import com.intc.common.core.utils.SpringUtils;
+import com.intc.common.core.utils.StringUtils;
+import com.intc.common.core.utils.reflect.ReflectUtils;
+import com.intc.common.mail.config.properties.MailProperties;
+import com.intc.common.mail.utils.MailUtils;
+import com.intc.common.ratelimiter.annotation.RateLimiter;
+import com.intc.common.ratelimiter.enums.LimitType;
+import com.intc.common.redis.utils.RedisUtils;
+import com.intc.common.sms.config.properties.SmsProperties;
+import com.intc.common.web.config.properties.CaptchaProperties;
+import com.intc.common.web.enums.CaptchaType;
+import com.intc.web.domain.vo.CaptchaVo;
+import com.intc.fishery.domain.bo.ReqVerifySmsCode;
 import jakarta.validation.constraints.NotBlank;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.dromara.common.core.constant.Constants;
-import org.dromara.common.core.constant.GlobalConstants;
-import org.dromara.common.core.domain.R;
-import org.dromara.common.core.exception.ServiceException;
-import org.dromara.common.core.utils.SpringUtils;
-import org.dromara.common.core.utils.StringUtils;
-import org.dromara.common.core.utils.reflect.ReflectUtils;
-import org.dromara.common.mail.config.properties.MailProperties;
-import org.dromara.common.mail.utils.MailUtils;
-import org.dromara.common.ratelimiter.annotation.RateLimiter;
-import org.dromara.common.ratelimiter.enums.LimitType;
-import org.dromara.common.redis.utils.RedisUtils;
-import org.dromara.common.web.config.properties.CaptchaProperties;
-import org.dromara.common.web.enums.CaptchaType;
 import org.dromara.sms4j.api.SmsBlend;
 import org.dromara.sms4j.api.entity.SmsResponse;
 import org.dromara.sms4j.core.factory.SmsFactory;
-import org.dromara.web.domain.vo.CaptchaVo;
 import org.springframework.expression.Expression;
 import org.springframework.expression.ExpressionParser;
 import org.springframework.expression.spel.standard.SpelExpressionParser;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.time.Duration;
@@ -50,6 +54,7 @@ public class CaptchaController {
 
     private final CaptchaProperties captchaProperties;
     private final MailProperties mailProperties;
+    private final SmsProperties smsProperties;
 
     /**
      * 短信验证码
@@ -60,21 +65,74 @@ public class CaptchaController {
     @GetMapping("/resource/sms/code")
     public R<Void> smsCode(@NotBlank(message = "{user.phonenumber.not.blank}") String phonenumber) {
         String key = GlobalConstants.CAPTCHA_CODE_KEY + phonenumber;
-        String code = RandomUtil.randomNumbers(4);
+        String code = RandomUtil.randomNumbers(6);
         RedisUtils.setCacheObject(key, code, Duration.ofMinutes(Constants.CAPTCHA_EXPIRATION));
-        // 验证码模板id 自行处理 (查数据库或写死均可)
-        String templateId = "";
+        // 验证码模板id 从配置文件读取
+        String templateId = smsProperties.getCodeTemplateId();
+        if (StringUtils.isBlank(templateId)) {
+            log.error("短信验证码模板ID未配置，请在配置文件中设置 sms.plus.code-template-id");
+            return R.fail("短信服务配置错误，请联系管理员");
+        }
         LinkedHashMap<String, String> map = new LinkedHashMap<>(1);
         map.put("code", code);
         SmsBlend smsBlend = SmsFactory.getSmsBlend("config1");
         SmsResponse smsResponse = smsBlend.sendMessage(phonenumber, templateId, map);
         if (!smsResponse.isSuccess()) {
             log.error("验证码短信发送异常 => {}", smsResponse);
-            return R.fail(smsResponse.getData().toString());
+            // 解析错误信息
+            String errorMsg = "短信发送失败";
+            if (smsResponse.getData() != null) {
+                String data = smsResponse.getData().toString();
+                if (data.contains("SMS_TEMPLATE_ILLEGAL")) {
+                    errorMsg = "短信模板不存在，请联系管理员配置正确的模板ID";
+                } else if (data.contains("SMS_SIGNATURE_ILLEGAL")) {
+                    errorMsg = "短信签名不存在，请联系管理员配置正确的签名";
+                } else if (data.contains("Message")) {
+                    // 尝试提取Message字段
+                    try {
+                        int msgStart = data.indexOf("Message\":\"") + 10;
+                        int msgEnd = data.indexOf("\"", msgStart);
+                        if (msgStart > 10 && msgEnd > msgStart) {
+                            String message = data.substring(msgStart, msgEnd);
+                            errorMsg = "短信发送失败：" + message;
+                        }
+                    } catch (Exception e) {
+                        log.warn("解析短信错误信息失败", e);
+                    }
+                } else if (data.contains("isv.")) {
+                    errorMsg = "短信服务配置错误，请联系管理员";
+                }
+            }
+            return R.fail(errorMsg);
         }
         return R.ok();
     }
 
+    /**
+     * 验证短信验证码
+     *
+     * @param request 手机号和验证码数据
+     * @return 验证结果
+     */
+    @PostMapping("/resource/sms/verify")
+    public R<Void> verifySmsCode(@Validated @RequestBody ReqVerifySmsCode request) {
+        String key = GlobalConstants.CAPTCHA_CODE_KEY + request.getMobilePhone();
+        String cachedCode = RedisUtils.getCacheObject(key);
+        
+        if (StringUtils.isBlank(cachedCode)) {
+            return R.fail("短信验证码已过期");
+        }
+        
+        if (!cachedCode.equals(request.getSmsCode())) {
+            return R.fail("短信验证码错误");
+        }
+        
+        // 验证成功后删除验证码（根据 C# 代码中的 true 参数）
+        RedisUtils.deleteObject(key);
+        
+        return R.ok();
+    }
+
     /**
      * 邮箱验证码
      *

intc-admin/src/main/java/com/intc/web/controller/IndexController.java

@@ -1,9 +1,9 @@
-package org.dromara.web.controller;
+package com.intc.web.controller;
 
 import cn.dev33.satoken.annotation.SaIgnore;
+import com.intc.common.core.utils.SpringUtils;
+import com.intc.common.core.utils.StringUtils;
 import lombok.RequiredArgsConstructor;
-import org.dromara.common.core.utils.SpringUtils;
-import org.dromara.common.core.utils.StringUtils;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
 

intc-admin/src/main/java/com/intc/web/domain/vo/CaptchaVo.java

@@ -1,4 +1,4 @@
-package org.dromara.web.domain.vo;
+package com.intc.web.domain.vo;
 
 import lombok.Data;
 

intc-admin/src/main/java/com/intc/web/domain/vo/LoginTenantVo.java

@@ -1,4 +1,4 @@
-package org.dromara.web.domain.vo;
+package com.intc.web.domain.vo;
 
 import lombok.Data;
 

intc-admin/src/main/java/com/intc/web/domain/vo/LoginVo.java

@@ -1,4 +1,4 @@
-package org.dromara.web.domain.vo;
+package com.intc.web.domain.vo;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import lombok.Data;
@@ -51,4 +51,20 @@ public class LoginVo {
      */
     private String openid;
 
+
+    /**
+     * 用户ID
+     */
+    private Long userId;
+
+    /**
+     * 用户名
+     */
+    private String userName;
+
+    /**
+     * 昵称
+     */
+    private String nickName;
+
 }

intc-admin/src/main/java/com/intc/web/domain/vo/TenantListVo.java

@@ -1,6 +1,6 @@
-package org.dromara.web.domain.vo;
+package com.intc.web.domain.vo;
 
-import org.dromara.system.domain.vo.SysTenantVo;
+import com.intc.system.domain.vo.SysTenantVo;
 import io.github.linpeilie.annotations.AutoMapper;
 import lombok.Data;
 

intc-admin/src/main/java/com/intc/web/listener/UserActionListener.java

@@ -1,4 +1,4 @@
-package org.dromara.web.listener;
+package com.intc.web.listener;
 
 import cn.dev33.satoken.listener.SaTokenListener;
 import cn.dev33.satoken.stp.StpUtil;
@@ -6,20 +6,20 @@ import cn.dev33.satoken.stp.parameter.SaLoginParameter;
 import cn.hutool.core.convert.Convert;
 import cn.hutool.http.useragent.UserAgent;
 import cn.hutool.http.useragent.UserAgentUtil;
+import com.intc.common.core.constant.CacheConstants;
+import com.intc.common.core.constant.Constants;
+import com.intc.common.core.domain.dto.UserOnlineDTO;
+import com.intc.common.core.utils.MessageUtils;
+import com.intc.common.core.utils.ServletUtils;
+import com.intc.common.core.utils.SpringUtils;
+import com.intc.common.core.utils.ip.AddressUtils;
+import com.intc.common.log.event.LogininforEvent;
+import com.intc.common.redis.utils.RedisUtils;
+import com.intc.common.satoken.utils.LoginHelper;
+import com.intc.common.tenant.helper.TenantHelper;
+import com.intc.web.service.SysLoginService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.dromara.common.core.constant.CacheConstants;
-import org.dromara.common.core.constant.Constants;
-import org.dromara.common.core.domain.dto.UserOnlineDTO;
-import org.dromara.common.core.utils.MessageUtils;
-import org.dromara.common.core.utils.ServletUtils;
-import org.dromara.common.core.utils.SpringUtils;
-import org.dromara.common.core.utils.ip.AddressUtils;
-import org.dromara.common.log.event.LogininforEvent;
-import org.dromara.common.redis.utils.RedisUtils;
-import org.dromara.common.satoken.utils.LoginHelper;
-import org.dromara.common.tenant.helper.TenantHelper;
-import org.dromara.web.service.SysLoginService;
 import org.springframework.stereotype.Component;
 
 import java.time.Duration;

intc-admin/src/main/java/com/intc/web/service/IAuthStrategy.java

@@ -1,11 +1,10 @@
-package org.dromara.web.service;
+package com.intc.web.service;
 
 
-import org.dromara.common.core.exception.ServiceException;
-import org.dromara.common.core.utils.SpringUtils;
-import org.dromara.system.domain.SysClient;
-import org.dromara.system.domain.vo.SysClientVo;
-import org.dromara.web.domain.vo.LoginVo;
+import com.intc.common.core.exception.ServiceException;
+import com.intc.common.core.utils.SpringUtils;
+import com.intc.system.domain.vo.SysClientVo;
+import com.intc.web.domain.vo.LoginVo;
 
 /**
  * 授权策略

intc-admin/src/main/java/com/intc/web/service/SysLoginService.java

@@ -1,4 +1,4 @@
-package org.dromara.web.service;
+package com.intc.web.service;
 
 import cn.dev33.satoken.exception.NotLoginException;
 import cn.dev33.satoken.stp.StpUtil;
@@ -7,31 +7,31 @@ import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.lang.Opt;
 import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.lock.annotation.Lock4j;
+import com.intc.common.core.constant.CacheConstants;
+import com.intc.common.core.constant.Constants;
+import com.intc.common.core.constant.SystemConstants;
+import com.intc.common.core.constant.TenantConstants;
+import com.intc.common.core.domain.dto.PostDTO;
+import com.intc.common.core.domain.dto.RoleDTO;
+import com.intc.common.core.domain.model.LoginUser;
+import com.intc.common.core.enums.LoginType;
+import com.intc.common.core.exception.ServiceException;
+import com.intc.common.core.exception.user.UserException;
+import com.intc.common.core.utils.*;
+import com.intc.common.log.event.LogininforEvent;
+import com.intc.common.mybatis.helper.DataPermissionHelper;
+import com.intc.common.redis.utils.RedisUtils;
+import com.intc.common.satoken.utils.LoginHelper;
+import com.intc.common.tenant.exception.TenantException;
+import com.intc.common.tenant.helper.TenantHelper;
+import com.intc.system.domain.SysUser;
+import com.intc.system.domain.bo.SysSocialBo;
+import com.intc.system.domain.vo.*;
+import com.intc.system.mapper.SysUserMapper;
+import com.intc.system.service.*;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import me.zhyd.oauth.model.AuthUser;
-import org.dromara.common.core.constant.CacheConstants;
-import org.dromara.common.core.constant.Constants;
-import org.dromara.common.core.constant.SystemConstants;
-import org.dromara.common.core.constant.TenantConstants;
-import org.dromara.common.core.domain.dto.PostDTO;
-import org.dromara.common.core.domain.dto.RoleDTO;
-import org.dromara.common.core.domain.model.LoginUser;
-import org.dromara.common.core.enums.LoginType;
-import org.dromara.common.core.exception.ServiceException;
-import org.dromara.common.core.exception.user.UserException;
-import org.dromara.common.core.utils.*;
-import org.dromara.common.log.event.LogininforEvent;
-import org.dromara.common.mybatis.helper.DataPermissionHelper;
-import org.dromara.common.redis.utils.RedisUtils;
-import org.dromara.common.satoken.utils.LoginHelper;
-import org.dromara.common.tenant.exception.TenantException;
-import org.dromara.common.tenant.helper.TenantHelper;
-import org.dromara.system.domain.SysUser;
-import org.dromara.system.domain.bo.SysSocialBo;
-import org.dromara.system.domain.vo.*;
-import org.dromara.system.mapper.SysUserMapper;
-import org.dromara.system.service.*;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 

intc-admin/src/main/java/com/intc/web/service/SysRegisterService.java

@@ -1,27 +1,27 @@
-package org.dromara.web.service;
+package com.intc.web.service;
 
 import cn.hutool.crypto.digest.BCrypt;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.intc.common.core.constant.Constants;
+import com.intc.common.core.constant.GlobalConstants;
+import com.intc.common.core.domain.model.RegisterBody;
+import com.intc.common.core.enums.UserType;
+import com.intc.common.core.exception.user.CaptchaException;
+import com.intc.common.core.exception.user.CaptchaExpireException;
+import com.intc.common.core.exception.user.UserException;
+import com.intc.common.core.utils.MessageUtils;
+import com.intc.common.core.utils.ServletUtils;
+import com.intc.common.core.utils.SpringUtils;
+import com.intc.common.core.utils.StringUtils;
+import com.intc.common.log.event.LogininforEvent;
+import com.intc.common.redis.utils.RedisUtils;
+import com.intc.common.tenant.helper.TenantHelper;
+import com.intc.common.web.config.properties.CaptchaProperties;
+import com.intc.system.domain.SysUser;
+import com.intc.system.domain.bo.SysUserBo;
+import com.intc.system.mapper.SysUserMapper;
+import com.intc.system.service.ISysUserService;
 import lombok.RequiredArgsConstructor;
-import org.dromara.common.core.constant.Constants;
-import org.dromara.common.core.constant.GlobalConstants;
-import org.dromara.common.core.domain.model.RegisterBody;
-import org.dromara.common.core.enums.UserType;
-import org.dromara.common.core.exception.user.CaptchaException;
-import org.dromara.common.core.exception.user.CaptchaExpireException;
-import org.dromara.common.core.exception.user.UserException;
-import org.dromara.common.core.utils.MessageUtils;
-import org.dromara.common.core.utils.ServletUtils;
-import org.dromara.common.core.utils.SpringUtils;
-import org.dromara.common.core.utils.StringUtils;
-import org.dromara.common.log.event.LogininforEvent;
-import org.dromara.common.redis.utils.RedisUtils;
-import org.dromara.common.tenant.helper.TenantHelper;
-import org.dromara.common.web.config.properties.CaptchaProperties;
-import org.dromara.system.domain.SysUser;
-import org.dromara.system.domain.bo.SysUserBo;
-import org.dromara.system.mapper.SysUserMapper;
-import org.dromara.system.service.ISysUserService;
 import org.springframework.stereotype.Service;
 
 /**

intc-admin/src/main/java/com/intc/web/service/impl/EmailAuthStrategy.java

@@ -1,33 +1,33 @@
-package org.dromara.web.service.impl;
+package com.intc.web.service.impl;
 
 import cn.dev33.satoken.stp.StpUtil;
 import cn.dev33.satoken.stp.parameter.SaLoginParameter;
 import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.intc.common.core.constant.Constants;
+import com.intc.common.core.constant.GlobalConstants;
+import com.intc.common.core.constant.SystemConstants;
+import com.intc.common.core.domain.model.EmailLoginBody;
+import com.intc.common.core.domain.model.LoginUser;
+import com.intc.common.core.enums.LoginType;
+import com.intc.common.core.exception.user.CaptchaExpireException;
+import com.intc.common.core.exception.user.UserException;
+import com.intc.common.core.utils.MessageUtils;
+import com.intc.common.core.utils.StringUtils;
+import com.intc.common.core.utils.ValidatorUtils;
+import com.intc.common.json.utils.JsonUtils;
+import com.intc.common.redis.utils.RedisUtils;
+import com.intc.common.satoken.utils.LoginHelper;
+import com.intc.common.tenant.helper.TenantHelper;
+import com.intc.system.domain.SysUser;
+import com.intc.system.domain.vo.SysClientVo;
+import com.intc.system.domain.vo.SysUserVo;
+import com.intc.system.mapper.SysUserMapper;
+import com.intc.web.domain.vo.LoginVo;
+import com.intc.web.service.IAuthStrategy;
+import com.intc.web.service.SysLoginService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.dromara.common.core.constant.Constants;
-import org.dromara.common.core.constant.GlobalConstants;
-import org.dromara.common.core.constant.SystemConstants;
-import org.dromara.common.core.domain.model.EmailLoginBody;
-import org.dromara.common.core.domain.model.LoginUser;
-import org.dromara.common.core.enums.LoginType;
-import org.dromara.common.core.exception.user.CaptchaExpireException;
-import org.dromara.common.core.exception.user.UserException;
-import org.dromara.common.core.utils.MessageUtils;
-import org.dromara.common.core.utils.StringUtils;
-import org.dromara.common.core.utils.ValidatorUtils;
-import org.dromara.common.json.utils.JsonUtils;
-import org.dromara.common.redis.utils.RedisUtils;
-import org.dromara.common.satoken.utils.LoginHelper;
-import org.dromara.common.tenant.helper.TenantHelper;
-import org.dromara.system.domain.SysUser;
-import org.dromara.system.domain.vo.SysClientVo;
-import org.dromara.system.domain.vo.SysUserVo;
-import org.dromara.system.mapper.SysUserMapper;
-import org.dromara.web.domain.vo.LoginVo;
-import org.dromara.web.service.IAuthStrategy;
-import org.dromara.web.service.SysLoginService;
 import org.springframework.stereotype.Service;
 
 /**

intc-admin/src/main/java/com/intc/web/service/impl/PasswordAuthStrategy.java

@@ -1,36 +1,36 @@
-package org.dromara.web.service.impl;
+package com.intc.web.service.impl;
 
 import cn.dev33.satoken.stp.StpUtil;
 import cn.dev33.satoken.stp.parameter.SaLoginParameter;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.crypto.digest.BCrypt;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.intc.common.core.constant.Constants;
+import com.intc.common.core.constant.GlobalConstants;
+import com.intc.common.core.constant.SystemConstants;
+import com.intc.common.core.domain.model.LoginUser;
+import com.intc.common.core.domain.model.PasswordLoginBody;
+import com.intc.common.core.enums.LoginType;
+import com.intc.common.core.exception.user.CaptchaException;
+import com.intc.common.core.exception.user.CaptchaExpireException;
+import com.intc.common.core.exception.user.UserException;
+import com.intc.common.core.utils.MessageUtils;
+import com.intc.common.core.utils.StringUtils;
+import com.intc.common.core.utils.ValidatorUtils;
+import com.intc.common.json.utils.JsonUtils;
+import com.intc.common.redis.utils.RedisUtils;
+import com.intc.common.satoken.utils.LoginHelper;
+import com.intc.common.tenant.helper.TenantHelper;
+import com.intc.common.web.config.properties.CaptchaProperties;
+import com.intc.system.domain.SysUser;
+import com.intc.system.domain.vo.SysClientVo;
+import com.intc.system.domain.vo.SysUserVo;
+import com.intc.system.mapper.SysUserMapper;
+import com.intc.web.domain.vo.LoginVo;
+import com.intc.web.service.IAuthStrategy;
+import com.intc.web.service.SysLoginService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.dromara.common.core.constant.Constants;
-import org.dromara.common.core.constant.GlobalConstants;
-import org.dromara.common.core.constant.SystemConstants;
-import org.dromara.common.core.domain.model.LoginUser;
-import org.dromara.common.core.domain.model.PasswordLoginBody;
-import org.dromara.common.core.enums.LoginType;
-import org.dromara.common.core.exception.user.CaptchaException;
-import org.dromara.common.core.exception.user.CaptchaExpireException;
-import org.dromara.common.core.exception.user.UserException;
-import org.dromara.common.core.utils.MessageUtils;
-import org.dromara.common.core.utils.StringUtils;
-import org.dromara.common.core.utils.ValidatorUtils;
-import org.dromara.common.json.utils.JsonUtils;
-import org.dromara.common.redis.utils.RedisUtils;
-import org.dromara.common.satoken.utils.LoginHelper;
-import org.dromara.common.tenant.helper.TenantHelper;
-import org.dromara.common.web.config.properties.CaptchaProperties;
-import org.dromara.system.domain.SysUser;
-import org.dromara.system.domain.vo.SysClientVo;
-import org.dromara.system.domain.vo.SysUserVo;
-import org.dromara.system.mapper.SysUserMapper;
-import org.dromara.web.domain.vo.LoginVo;
-import org.dromara.web.service.IAuthStrategy;
-import org.dromara.web.service.SysLoginService;
 import org.springframework.stereotype.Service;
 
 /**

intc-admin/src/main/java/com/intc/web/service/impl/SmsAuthStrategy.java

@@ -0,0 +1,317 @@
+package com.intc.web.service.impl;
+
+import cn.dev33.satoken.stp.StpUtil;
+import cn.dev33.satoken.stp.parameter.SaLoginParameter;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.crypto.digest.BCrypt;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.intc.common.core.constant.Constants;
+import com.intc.common.core.constant.GlobalConstants;
+import com.intc.common.core.constant.SystemConstants;
+import com.intc.common.core.domain.model.LoginUser;
+import com.intc.common.core.domain.model.SmsLoginBody;
+import com.intc.common.core.enums.LoginType;
+import com.intc.common.core.exception.user.CaptchaExpireException;
+import com.intc.common.core.exception.user.UserException;
+import com.intc.common.core.utils.MessageUtils;
+import com.intc.common.core.utils.StringUtils;
+import com.intc.common.core.utils.ValidatorUtils;
+import com.intc.common.json.utils.JsonUtils;
+import com.intc.common.redis.utils.RedisUtils;
+import com.intc.common.satoken.utils.LoginHelper;
+import com.intc.common.tenant.helper.TenantHelper;
+import com.intc.fishery.domain.AquUser;
+import com.intc.fishery.domain.bo.AquUserBo;
+import com.intc.fishery.mapper.AquUserMapper;
+import com.intc.fishery.service.IAquUserService;
+import com.intc.system.domain.SysUser;
+import com.intc.system.domain.bo.SysUserBo;
+import com.intc.system.domain.vo.SysClientVo;
+import com.intc.system.domain.vo.SysUserVo;
+import com.intc.system.mapper.SysUserMapper;
+import com.intc.system.service.ISysUserService;
+import com.intc.web.domain.vo.LoginVo;
+import com.intc.web.service.IAuthStrategy;
+import com.intc.web.service.SysLoginService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 短信认证策略
+ *
+ * @author Michelle.Chung
+ */
+@Slf4j
+@Service("sms" + IAuthStrategy.BASE_NAME)
+@RequiredArgsConstructor
+public class SmsAuthStrategy implements IAuthStrategy {
+
+    private final SysLoginService loginService;
+    private final SysUserMapper userMapper;
+    private final ISysUserService userService;
+    private final AquUserMapper aquUserMapper;
+    private final IAquUserService aquUserService;
+
+    @Override
+    public LoginVo login(String body, SysClientVo client) {
+        SmsLoginBody loginBody = JsonUtils.parseObject(body, SmsLoginBody.class);
+        ValidatorUtils.validate(loginBody);
+        String tenantId = loginBody.getTenantId();
+        String phonenumber = loginBody.getPhonenumber();
+        String smsCode = loginBody.getSmsCode();
+        LoginUser loginUser = TenantHelper.dynamic(tenantId, () -> {
+            SysUserVo user = loadUserByPhonenumber(phonenumber);
+            loginService.checkLogin(LoginType.SMS, tenantId, user.getUserName(), () -> !validateSmsCode(tenantId, phonenumber, smsCode));
+            // 此处可根据登录用户的数据不同 自行创建 loginUser 属性不够用继承扩展就行了
+            return loginService.buildLoginUser(user);
+        });
+        loginUser.setClientKey(client.getClientKey());
+        loginUser.setDeviceType(client.getDeviceType());
+        SaLoginParameter model = new SaLoginParameter();
+        model.setDeviceType(client.getDeviceType());
+        // 自定义分配 不同用户体系 不同 token 授权时间 不设置默认走全局 yml 配置
+        // 例如: 后台用户30分钟过期 app用户1天过期
+        model.setTimeout(client.getTimeout());
+        model.setActiveTimeout(client.getActiveTimeout());
+        model.setExtra(LoginHelper.CLIENT_KEY, client.getClientId());
+        // 生成token
+        LoginHelper.login(loginUser, model);
+
+        LoginVo loginVo = new LoginVo();
+        loginVo.setAccessToken(StpUtil.getTokenValue());
+        loginVo.setExpireIn(StpUtil.getTokenTimeout());
+        loginVo.setClientId(client.getClientId());
+        loginVo.setUserId(loginUser.getUserId());
+        loginVo.setNickName(loginUser.getNickname());
+        loginVo.setUserName(loginUser.getUsername());
+        return loginVo;
+    }
+
+    /**
+     * 校验短信验证码
+     */
+    private boolean validateSmsCode(String tenantId, String phonenumber, String smsCode) {
+        String code = RedisUtils.getCacheObject(GlobalConstants.CAPTCHA_CODE_KEY + phonenumber);
+        if (StringUtils.isBlank(code)) {
+            loginService.recordLogininfor(tenantId, phonenumber, Constants.LOGIN_FAIL, MessageUtils.message("user.jcaptcha.expire"));
+            throw new CaptchaExpireException();
+        }
+        return code.equals(smsCode);
+    }
+
+    /**
+     * 根据手机号加载系统用户，如果不存在则自动创建
+     * 逻辑：先查AquUser，再查系统用户
+     * 1. 如果AquUser不存在，先创建AquUser，再创建系统用户
+     * 2. 如果AquUser存在但系统用户不存在，根据AquUser数据创建系统用户
+     * 3. 如果都存在，直接返回系统用户
+     *
+     * @param phonenumber 手机号
+     * @return 系统用户信息
+     */
+    private SysUserVo loadUserByPhonenumber(String phonenumber) {
+        // 1. 先查询AquUser
+        AquUser aquUser = aquUserMapper.selectOne(
+            new LambdaQueryWrapper<AquUser>()
+                .eq(AquUser::getMobilePhone, phonenumber)
+        );
+        
+        // 2. 查询系统用户
+        SysUserVo sysUser = userMapper.selectVoOne(
+            new LambdaQueryWrapper<SysUser>()
+                .eq(SysUser::getPhonenumber, phonenumber)
+        );
+        
+        // 3. 根据不同情况处理
+        if (ObjectUtil.isNull(aquUser)) {
+            // 情况1：AquUser不存在，先创建AquUser，再创建系统用户
+            log.info("AquUser不存在，先创建AquUser再创建系统用户: phone={}", phonenumber);
+            aquUser = createAquUserFirst(phonenumber);
+            sysUser = createSysUserFromPhone(phonenumber, aquUser);
+        } else if (ObjectUtil.isNull(sysUser)) {
+            // 情况2：AquUser存在但系统用户不存在，根据AquUser创建系统用户
+            log.info("AquUser存在但系统用户不存在，根据AquUser创建系统用户: phone={}, aquUserId={}", 
+                phonenumber, aquUser.getId());
+            sysUser = createSysUserFromAquUser(aquUser);
+        }
+        
+        // 检查用户状态
+        if (SystemConstants.DISABLE.equals(sysUser.getStatus())) {
+            log.info("登录用户：{} 已被停用.", phonenumber);
+            throw new UserException("user.blocked", phonenumber);
+        }
+        
+        return sysUser;
+    }
+
+    /**
+     * 先创建AquUser（当AquUser不存在时）
+     *
+     * @param phone 手机号
+     * @return 新创建的AquUser
+     */
+    private AquUser createAquUserFirst(String phone) {
+        try {
+            // 构建报警电话列表
+            List<String> warnPhoneList = new ArrayList<>();
+            warnPhoneList.add(phone);
+            String warnPhoneJson = JsonUtils.toJsonString(warnPhoneList);
+
+            // 创建鱼测云用户对象
+            AquUserBo aquUserBo = new AquUserBo();
+            aquUserBo.setUserName("用户" + phone.substring(phone.length() - 4));
+            aquUserBo.setMobilePhone(phone);
+            aquUserBo.setWarnPhoneJson(warnPhoneJson);
+            aquUserBo.setIsManager(0L);
+            aquUserBo.setHasScreen(0L);
+            aquUserBo.setRemark("短信登录自动创建");
+
+            // 调用服务创建鱼测云用户
+            boolean success = aquUserService.insertByBo(aquUserBo);
+
+            if (!success) {
+                log.error("创建AquUser失败: phone={}", phone);
+                throw new UserException("user.register.error");
+            }
+
+            // 查询刚创建的AquUser
+            AquUser createdAquUser = aquUserMapper.selectOne(
+                new LambdaQueryWrapper<AquUser>()
+                    .eq(AquUser::getMobilePhone, phone)
+            );
+
+            if (ObjectUtil.isNull(createdAquUser)) {
+                log.error("创建AquUser后查询失败: phone={}", phone);
+                throw new UserException("user.register.error");
+            }
+
+            log.info("成功创建AquUser: phone={}, aquUserId={}, userName={}",
+                phone, createdAquUser.getId(), createdAquUser.getUserName());
+
+            return createdAquUser;
+
+        } catch (Exception e) {
+            log.error("创建AquUser异常: phone={}, error={}", phone, e.getMessage(), e);
+            throw new UserException("user.register.error");
+        }
+    }
+
+    /**
+     * 根据手机号创建系统用户（当AquUser已创建但系统用户不存在时）
+     *
+     * @param phone 手机号
+     * @param aquUser AquUser信息
+     * @return 新创建的系统用户
+     */
+    private SysUserVo createSysUserFromPhone(String phone, AquUser aquUser) {
+        try {
+            // 构建新用户对象
+            SysUserBo newUser = new SysUserBo();
+            // 使用AquUser的ID作为系统用户ID，保持一致
+            newUser.setUserId(aquUser.getId());
+            newUser.setUserName(phone);
+            newUser.setNickName(StringUtils.isNotBlank(aquUser.getUserName()) ? 
+                aquUser.getUserName() : "用户" + phone.substring(phone.length() - 4));
+            newUser.setPhonenumber(phone);
+            newUser.setUserType("sys_user");
+            newUser.setDeptId(SystemConstants.DEFAULT_DEPT_ID);
+            newUser.setStatus(SystemConstants.NORMAL);
+            newUser.setSex("2");
+            newUser.setPassword(BCrypt.hashpw("yuceyun@123"));
+            newUser.setCreateBy(0L);
+            newUser.setUpdateBy(0L);
+
+            // 调用用户服务创建用户
+            boolean success = userService.registerUser(newUser, LoginHelper.getTenantId());
+
+            if (!success) {
+                log.error("创建系统用户失败: phone={}, aquUserId={}", phone, aquUser.getId());
+                throw new UserException("user.register.error");
+            }
+
+            // 查询刚创建的用户信息
+            SysUserVo createdUser = userMapper.selectVoOne(
+                new LambdaQueryWrapper<SysUser>()
+                    .eq(SysUser::getPhonenumber, phone)
+            );
+
+            if (ObjectUtil.isNull(createdUser)) {
+                log.error("创建系统用户后查询失败: phone={}, aquUserId={}", phone, aquUser.getId());
+                throw new UserException("user.register.error");
+            }
+
+            log.info("成功创建系统用户(ID与AquUser一致): phone={}, userId={}, aquUserId={}, userName={}",
+                phone, createdUser.getUserId(), aquUser.getId(), createdUser.getUserName());
+
+            return createdUser;
+
+        } catch (Exception e) {
+            log.error("创建系统用户异常: phone={}, aquUserId={}, error={}", phone, aquUser.getId(), e.getMessage(), e);
+            throw new UserException("user.register.error");
+        }
+    }
+
+    /**
+     * 根据AquUser信息创建系统用户
+     *
+     * @param aquUser AquUser信息
+     * @return 新创建的系统用户
+     */
+    private SysUserVo createSysUserFromAquUser(AquUser aquUser) {
+        try {
+            String phone = aquUser.getMobilePhone();
+            
+            // 构建新用户对象
+            SysUserBo newUser = new SysUserBo();
+            // 使用AquUser的ID作为系统用户ID，保持一致
+            newUser.setUserId(aquUser.getId());
+            newUser.setUserName(phone);
+            // 使用AquUser的用户名作为昵称
+            newUser.setNickName(StringUtils.isNotBlank(aquUser.getUserName()) ? 
+                aquUser.getUserName() : "用户" + phone.substring(phone.length() - 4));
+            newUser.setPhonenumber(phone);
+            newUser.setUserType("sys_user");
+            newUser.setDeptId(SystemConstants.DEFAULT_DEPT_ID);
+            newUser.setStatus(SystemConstants.NORMAL);
+            newUser.setSex("2");
+            newUser.setPassword(BCrypt.hashpw("yuceyun@123"));
+            newUser.setCreateBy(0L);
+            newUser.setUpdateBy(0L);
+
+            // 调用用户服务创建用户
+            boolean success = userService.registerUser(newUser, LoginHelper.getTenantId());
+
+            if (!success) {
+                log.error("根据AquUser创建系统用户失败: phone={}, aquUserId={}", phone, aquUser.getId());
+                throw new UserException("user.register.error");
+            }
+
+            // 查询刚创建的用户信息
+            SysUserVo createdUser = userMapper.selectVoOne(
+                new LambdaQueryWrapper<SysUser>()
+                    .eq(SysUser::getPhonenumber, phone)
+            );
+
+            if (ObjectUtil.isNull(createdUser)) {
+                log.error("根据AquUser创建系统用户后查询失败: phone={}, aquUserId={}", phone, aquUser.getId());
+                throw new UserException("user.register.error");
+            }
+
+            log.info("根据AquUser成功创建系统用户(ID一致): phone={}, userId={}, aquUserId={}, userName={}",
+                phone, createdUser.getUserId(), aquUser.getId(), createdUser.getUserName());
+
+            return createdUser;
+
+        } catch (Exception e) {
+            log.error("根据AquUser创建系统用户异常: aquUserId={}, error={}", aquUser.getId(), e.getMessage(), e);
+            throw new UserException("user.register.error");
+        }
+    }
+
+
+
+}

intc-admin/src/main/java/com/intc/web/service/impl/SocialAuthStrategy.java

@@ -1,33 +1,33 @@
-package org.dromara.web.service.impl;
+package com.intc.web.service.impl;
 
 import cn.dev33.satoken.stp.StpUtil;
 import cn.dev33.satoken.stp.parameter.SaLoginParameter;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.ObjectUtil;
+import com.intc.common.core.constant.SystemConstants;
+import com.intc.common.core.domain.model.LoginUser;
+import com.intc.common.core.domain.model.SocialLoginBody;
+import com.intc.common.core.exception.ServiceException;
+import com.intc.common.core.exception.user.UserException;
+import com.intc.common.core.utils.StreamUtils;
+import com.intc.common.core.utils.ValidatorUtils;
+import com.intc.common.json.utils.JsonUtils;
+import com.intc.common.satoken.utils.LoginHelper;
+import com.intc.common.social.config.properties.SocialProperties;
+import com.intc.common.social.utils.SocialUtils;
+import com.intc.common.tenant.helper.TenantHelper;
+import com.intc.system.domain.vo.SysClientVo;
+import com.intc.system.domain.vo.SysSocialVo;
+import com.intc.system.domain.vo.SysUserVo;
+import com.intc.system.mapper.SysUserMapper;
+import com.intc.system.service.ISysSocialService;
+import com.intc.web.domain.vo.LoginVo;
+import com.intc.web.service.IAuthStrategy;
+import com.intc.web.service.SysLoginService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import me.zhyd.oauth.model.AuthResponse;
 import me.zhyd.oauth.model.AuthUser;
-import org.dromara.common.core.constant.SystemConstants;
-import org.dromara.common.core.domain.model.LoginUser;
-import org.dromara.common.core.domain.model.SocialLoginBody;
-import org.dromara.common.core.exception.ServiceException;
-import org.dromara.common.core.exception.user.UserException;
-import org.dromara.common.core.utils.StreamUtils;
-import org.dromara.common.core.utils.ValidatorUtils;
-import org.dromara.common.json.utils.JsonUtils;
-import org.dromara.common.satoken.utils.LoginHelper;
-import org.dromara.common.social.config.properties.SocialProperties;
-import org.dromara.common.social.utils.SocialUtils;
-import org.dromara.common.tenant.helper.TenantHelper;
-import org.dromara.system.domain.vo.SysClientVo;
-import org.dromara.system.domain.vo.SysSocialVo;
-import org.dromara.system.domain.vo.SysUserVo;
-import org.dromara.system.mapper.SysUserMapper;
-import org.dromara.system.service.ISysSocialService;
-import org.dromara.web.domain.vo.LoginVo;
-import org.dromara.web.service.IAuthStrategy;
-import org.dromara.web.service.SysLoginService;
 import org.springframework.stereotype.Service;
 
 import java.util.List;

intc-admin/src/main/java/com/intc/web/service/impl/WechatAuthStrategy.java

@@ -0,0 +1,210 @@
+package com.intc.web.service.impl;
+
+import cn.dev33.satoken.stp.StpUtil;
+import cn.dev33.satoken.stp.parameter.SaLoginParameter;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.crypto.digest.BCrypt;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.intc.common.core.constant.SystemConstants;
+import com.intc.common.core.domain.model.LoginUser;
+import com.intc.common.core.exception.ServiceException;
+import com.intc.common.core.exception.user.UserException;
+import com.intc.common.core.utils.StringUtils;
+import com.intc.common.core.utils.ValidatorUtils;
+import com.intc.common.json.utils.JsonUtils;
+import com.intc.common.core.utils.MapstructUtils;
+import com.intc.common.satoken.utils.LoginHelper;
+import com.intc.common.tenant.helper.TenantHelper;
+import com.intc.fishery.domain.AquUser;
+import com.intc.system.domain.SysUser;
+import com.intc.system.domain.bo.SysUserBo;
+import com.intc.system.domain.vo.SysClientVo;
+import com.intc.system.domain.vo.SysUserVo;
+import com.intc.system.mapper.SysUserMapper;
+import com.intc.system.service.ISysUserService;
+import com.intc.web.domain.vo.LoginVo;
+import com.intc.web.service.IAuthStrategy;
+import com.intc.web.service.SysLoginService;
+import com.intc.weixin.domain.bo.ReqWxLogin;
+import com.intc.weixin.service.WxLoginService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+/**
+ * 微信小程序认证策略
+ *
+ * @author intc
+ */
+@Slf4j
+@Service("wechat" + IAuthStrategy.BASE_NAME)
+@RequiredArgsConstructor
+public class WechatAuthStrategy implements IAuthStrategy {
+
+    private final WxLoginService wxLoginService;
+    private final SysLoginService loginService;
+    private final SysUserMapper userMapper;
+    private final ISysUserService userService;
+
+    @Override
+    public LoginVo login(String body, SysClientVo client) {
+        ReqWxLogin loginBody = JsonUtils.parseObject(body, ReqWxLogin.class);
+        ValidatorUtils.validate(loginBody);
+        
+        String tenantId = loginBody.getTenantId();
+        String code = loginBody.getCode();
+        String jsCode = loginBody.getJsCode();
+
+        // 在租户上下文中执行登录
+        AquUser[] aquUserHolder = new AquUser[1]; // 用于保存 AquUser
+        LoginUser loginUser = TenantHelper.dynamic(tenantId, () -> {
+            // 1. 调用微信登录服务获取或创建渔业用户（用于获取手机号和openId）
+            AquUser aquUser = wxLoginService.loginByWeChat(code, jsCode, tenantId);
+            
+            if (aquUser == null) {
+                log.error("微信登录失败，未返回用户信息");
+                throw new ServiceException("登录失败，请重试");
+            }
+            
+            aquUserHolder[0] = aquUser; // 保存以便后续使用
+            
+            log.info("获取微信用户信息成功: aquUserId={}, mobilePhone={}", 
+                aquUser.getId(), aquUser.getMobilePhone());
+            
+            // 2. 根据手机号查询系统用户
+            String mobilePhone = aquUser.getMobilePhone();
+            if (StringUtils.isBlank(mobilePhone)) {
+                log.error("微信用户手机号为空: aquUserId={}", aquUser.getId());
+                throw new ServiceException("获取手机号失败，请重新授权");
+            }
+            
+            // 3. 根据手机号加载或创建系统用户（传入aquUser以保持ID一致）
+            SysUserVo sysUser = loadUserByPhone(mobilePhone, aquUser);
+            
+            log.info("找到对应的系统用户: sysUserId={}, userName={}", 
+                sysUser.getUserId(), sysUser.getUserName());
+            
+            // 4. 使用系统用户构建 LoginUser（包含完整的权限信息）
+            return loginService.buildLoginUser(sysUser);
+        });
+
+        // 3. 设置客户端信息
+        loginUser.setClientKey(client.getClientKey());
+        loginUser.setDeviceType(client.getDeviceType());
+
+        // 4. 配置登录参数
+        SaLoginParameter model = new SaLoginParameter();
+        model.setDeviceType(client.getDeviceType());
+        model.setTimeout(client.getTimeout());
+        model.setActiveTimeout(client.getActiveTimeout());
+        model.setExtra(LoginHelper.CLIENT_KEY, client.getClientId());
+
+        // 5. 执行登录，生成 token
+        LoginHelper.login(loginUser, model);
+
+        // 6. 构建返回对象
+        LoginVo loginVo = new LoginVo();
+        loginVo.setAccessToken(StpUtil.getTokenValue());
+        loginVo.setExpireIn(StpUtil.getTokenTimeout());
+        loginVo.setClientId(client.getClientId());
+        loginVo.setOpenid(aquUserHolder[0].getWxOpenId()); // 从 AquUser 中获取 openId
+        loginVo.setUserId(loginUser.getUserId());
+        loginVo.setUserName(loginUser.getUsername());
+        loginVo.setNickName(loginUser.getNickname());
+
+        return loginVo;
+    }
+
+    /**
+     * 根据手机号加载系统用户，如果不存在则自动创建
+     *
+     * @param phone 手机号
+     * @param aquUser 已存在的鱼测云用户（用于保持ID一致）
+     * @return 系统用户信息
+     */
+    private SysUserVo loadUserByPhone(String phone, AquUser aquUser) {
+        SysUserVo user = userMapper.selectVoOne(
+            new LambdaQueryWrapper<SysUser>()
+                .eq(SysUser::getPhonenumber, phone)
+        );
+        
+        // 如果用户不存在，创建新用户
+        if (ObjectUtil.isNull(user)) {
+            log.info("系统中不存在该手机号的用户，自动创建新用户: phone={}", phone);
+            user = createNewUser(phone, aquUser);
+        }
+        
+        // 检查用户状态
+        if (SystemConstants.DISABLE.equals(user.getStatus())) {
+            log.error("用户已被停用: phone={}, userId={}", phone, user.getUserId());
+            throw new UserException("user.blocked", phone);
+        }
+        
+        return user;
+    }
+
+    /**
+     * 创建新的系统用户
+     *
+     * @param phone 手机号
+     * @param aquUser 已存在的鱼测云用户（用于保持ID一致）
+     * @return 新创建的用户信息
+     */
+    private SysUserVo createNewUser(String phone, AquUser aquUser) {
+        try {
+            // 构建新用户对象
+            SysUserBo newUser = new SysUserBo();
+            // 使用AquUser的ID作为系统用户ID，保持一致
+            newUser.setUserId(aquUser.getId());
+            // 使用手机号作为用户名
+            newUser.setUserName(phone);
+            // 使用手机号作为昵称
+            newUser.setNickName("用户" + phone.substring(phone.length() - 4));
+            // 设置手机号
+            newUser.setPhonenumber(phone);
+            // 设置用户类型为系统用户
+            newUser.setUserType("sys_user");
+            // 设置默认部门ID
+            newUser.setDeptId(SystemConstants.DEFAULT_DEPT_ID);
+            // 设置状态为正常
+            newUser.setStatus(SystemConstants.NORMAL);
+            // 设置性别为未知
+            newUser.setSex("2");
+            // 设置默认密码
+            newUser.setPassword(BCrypt.hashpw("yuceyun@123"));
+            // 设置创建人和更新人为系统
+            newUser.setCreateBy(0L);
+            newUser.setUpdateBy(0L);
+            
+            // 直接插入用户（不使用registerUser，因为ID已经指定）
+            SysUser sysUser = MapstructUtils.convert(newUser, SysUser.class);
+            sysUser.setTenantId(LoginHelper.getTenantId());
+            int rows = userMapper.insert(sysUser);
+            
+            if (rows <= 0) {
+                log.error("创建新用户失败: phone={}, aquUserId={}", phone, aquUser.getId());
+                throw new ServiceException("创建用户失败，请联系管理员");
+            }
+            
+            // 查询刚创建的用户信息
+            SysUserVo createdUser = userMapper.selectVoOne(
+                new LambdaQueryWrapper<SysUser>()
+                    .eq(SysUser::getPhonenumber, phone)
+            );
+            
+            if (ObjectUtil.isNull(createdUser)) {
+                log.error("创建用户后查询失败: phone={}", phone);
+                throw new ServiceException("创建用户失败，请联系管理员");
+            }
+            
+            log.info("成功创建系统用户: phone={}, userId={}, userName={}, 与AquUser ID保持一致", 
+                phone, createdUser.getUserId(), createdUser.getUserName());
+            
+            return createdUser;
+            
+        } catch (Exception e) {
+            log.error("创建新用户异常: phone={}, error={}", phone, e.getMessage(), e);
+            throw new ServiceException("创建用户失败: " + e.getMessage());
+        }
+    }
+}

intc-admin/src/main/java/com/intc/web/service/impl/XcxAuthStrategy.java

@@ -1,8 +1,20 @@
-package org.dromara.web.service.impl;
+package com.intc.web.service.impl;
 
 import cn.dev33.satoken.stp.StpUtil;
 import cn.dev33.satoken.stp.parameter.SaLoginParameter;
 import cn.hutool.core.util.ObjectUtil;
+import com.intc.common.core.constant.SystemConstants;
+import com.intc.common.core.domain.model.XcxLoginBody;
+import com.intc.common.core.domain.model.XcxLoginUser;
+import com.intc.common.core.exception.ServiceException;
+import com.intc.common.core.utils.ValidatorUtils;
+import com.intc.common.json.utils.JsonUtils;
+import com.intc.common.satoken.utils.LoginHelper;
+import com.intc.system.domain.vo.SysClientVo;
+import com.intc.system.domain.vo.SysUserVo;
+import com.intc.web.domain.vo.LoginVo;
+import com.intc.web.service.IAuthStrategy;
+import com.intc.web.service.SysLoginService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import me.zhyd.oauth.config.AuthConfig;
@@ -12,18 +24,6 @@ import me.zhyd.oauth.model.AuthToken;
 import me.zhyd.oauth.model.AuthUser;
 import me.zhyd.oauth.request.AuthRequest;
 import me.zhyd.oauth.request.AuthWechatMiniProgramRequest;
-import org.dromara.common.core.constant.SystemConstants;
-import org.dromara.common.core.domain.model.XcxLoginBody;
-import org.dromara.common.core.domain.model.XcxLoginUser;
-import org.dromara.common.core.exception.ServiceException;
-import org.dromara.common.core.utils.ValidatorUtils;
-import org.dromara.common.json.utils.JsonUtils;
-import org.dromara.common.satoken.utils.LoginHelper;
-import org.dromara.system.domain.vo.SysClientVo;
-import org.dromara.system.domain.vo.SysUserVo;
-import org.dromara.web.domain.vo.LoginVo;
-import org.dromara.web.service.IAuthStrategy;
-import org.dromara.web.service.SysLoginService;
 import org.springframework.stereotype.Service;
 
 /**

intc-admin/src/main/resources/application-dev.yml

@@ -13,7 +13,7 @@ spring.boot.admin.client:
 
 --- # snail-job 配置
 snail-job:
-  enabled: true
+  enabled: false
   # 需要在 SnailJob 后台组管理创建对应名称的组,然后创建任务的时候选择对应的组,才能正确分派任务
   group: "ruoyi_group"
   # SnailJob 接入验证令牌 详见 script/sql/ry_job.sql `sj_group_config` 表
@@ -35,7 +35,7 @@ spring:
     # 动态数据源文档 https://www.kancloud.cn/tracy5546/dynamic-datasource/content
     dynamic:
       # 性能分析插件(有性能损耗 不建议生产环境使用)
-      p6spy: true
+      p6spy: false
       # 设置默认的数据源或者数据源组,默认值即为 master
       primary: master
       # 严格模式 匹配不到数据源则报错
@@ -51,17 +51,23 @@ spring:
 #          username: root
 #          password: root
           driverClassName: org.postgresql.Driver
-          url: jdbc:postgresql://117.72.197.29:15432/ruoyi-plus?useUnicode=true&characterEncoding=utf8&useSSL=true&autoReconnect=true&reWriteBatchedInserts=true
+          url: jdbc:postgresql://81.70.89.108:15432/fishery_dev?useUnicode=true&characterEncoding=utf8&useSSL=true&autoReconnect=true&reWriteBatchedInserts=true
           username: postgres
           password: intc@123987
-#        # 从库数据源
-#        slave:
-#          lazy: true
-#          type: ${spring.datasource.type}
-#          driverClassName: com.mysql.cj.jdbc.Driver
-#          url: jdbc:mysql://localhost:3306/ry-vue?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&autoReconnect=true&rewriteBatchedStatements=true&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true
-#          username:
-#          password:
+        # 从库数据源 - TDengine
+        taos:
+          lazy: false
+          type: ${spring.datasource.type}
+          driverClassName: com.taosdata.jdbc.rs.RestfulDriver
+          # 不指定数据库名，在 SQL 中使用完整路径 fishery.table_name
+          url: jdbc:TAOS-RS://81.70.89.108:6041?timezone=Shanghai&charset=UTF-8&locale=en_US.UTF-8
+          username: root
+          password: intc@123456
+          hikari:
+            connection-timeout: 60000
+            validation-timeout: 10000
+            max-pool-size: 5
+            min-idle: 2
 #        oracle:
 #          type: ${spring.datasource.type}
 #          driverClassName: oracle.jdbc.OracleDriver
@@ -100,13 +106,13 @@ spring:
 spring.data:
   redis:
     # 地址
-    host: 117.72.197.29
+    host: 81.70.89.108
     # 端口，默认为6379
-    port: 6379
+    port: 26379
     # 数据库索引
-    database: 6
+    database: 9
     # redis 密码必须配置
-    password: intc@123987
+    password: bbd4b56e5d3f
     # 连接超时时间
     timeout: 10s
     # 是否开启ssl
@@ -176,10 +182,12 @@ sms:
       # 框架定义的厂商名称标识，标定此配置是哪个厂商，详细请看厂商标识介绍部分
       supplier: alibaba
       # 有些称为accessKey有些称之为apiKey，也有称为sdkKey或者appId。
-      access-key-id: 您的accessKey
+      access-key-id: LTAI5tRnPowmTLjH181nSbsR
       # 称为accessSecret有些称之为apiSecret
-      access-key-secret: 您的accessKeySecret
-      signature: 您的短信签名
+      access-key-secret: Vh2LoAM1t3XuMUVy2wTWSACJ97kOUW
+      # 短信签名：需要在阿里云控制台创建并审核通过，格式如：鱼测云（不带【】符号）
+      # 请在阿里云短信服务控制台 -> 国内消息 -> 签名管理 中查看您的签名
+      signature: 鱼测云  # TODO: 请填写您的阿里云短信签名（不带【】符号）
       sdk-app-id: 您的sdkAppId
     config2:
       # 厂商标识，标定此配置是哪个厂商，详细请看厂商标识介绍部分
@@ -188,7 +196,56 @@ sms:
       access-key-secret: 您的accessKeySecret
       signature: 您的短信签名
       sdk-app-id: 您的sdkAppId
+  # plus扩展配置
+  plus:
+    # 短信验证码模板ID(请根据实际短信服务商的模板ID配置)
+    # 请在阿里云短信服务控制台获取真实的模板CODE，格式如：SMS_460655548
+    # 模板内容需包含 ${code} 参数
+    code-template-id: 'SMS_465720430'  # TODO: 请填写您的阿里云短信模板CODE
 
+    # 设备类型到 ProductKey 的映射配置
+device-type:
+    # 1-水质检测仪 ProductKey（请填写实际的 ProductKey）
+    water-quality-monitor: a15hA3oBPmB  # TODO: 请替换为实际的水质检测仪 ProductKey
+    # 2-控制一体机 ProductKey（请填写实际的 ProductKey）
+    control-integrated: a1Xj9dagTIx  # TODO: 请替换为实际的控制一体机 ProductKey
+--- # 阿里云生活物联网平台（飞燕平台）配置
+aliyun:
+  living-iot:
+    # 阿里云 AccessKey ID（必填）
+    access-key-id: LTAI5tRnPowmTLjH181nSbsR
+    # 阿里云 AccessKey Secret（必填）
+    access-key-secret: Vh2LoAM1t3XuMUVy2wTWSACJ97kOUW
+    # 地域节点（必填）
+    region-id: cn-shanghai
+    # 飞燕平台项目ID（Project ID）
+    project-id: a123nMibvh0q4UnU
+    # App Key（用于 API 调用）
+    app-key: 334224397
+    # App Secret
+    app-secret: 70de3018ec39423e9ca1e1b6a6a84ad6
+    # AMQP 服务端订阅配置（使用数据同步的 AppKey + AppSecret）
+    amqp:
+      # 是否启用
+      enabled: true
+      # 数据同步 AppKey（与上面的 app-key 不同！）
+      data-sync-app-key: 334224409
+      # 数据同步 AppSecret（请在阿里云控制台查看）
+      data-sync-app-secret: 17fdd58f9a4c4c90be236897b1f8e8f7
+      # AMQP 接入点地址（使用生活物联网平台官方地址）
+      endpoint: amqps://ilop.iot-amqp.cn-shanghai.aliyuncs.com:5671
+      # 消费组 ID（按照官方文档，应该与数据同步 AppKey 相同）
+      consumer-group-id: 334224409
+      # 客户端 ID（建议使用机器 UUID、MAC 地址等唯一标识）
+      client-id: fishery-backend-001
+      # 连接超时时间（毫秒）
+      connection-timeout: 80000
+      # 是否自动重连
+      auto-reconnect: true
+      # 最大重连次数
+      max-reconnect-attempts: 10
+      # 重连延迟（毫秒）
+      reconnect-delay: 30000
 
 --- # 三方授权
 justauth:
@@ -272,3 +329,77 @@ justauth:
       client-id: 10**********6
       client-secret: 1f7d08**********5b7**********29e
       redirect-uri: ${justauth.address}/social-callback?source=gitea
+
+--- # 微信支付选项配置
+wx:
+  # 微信公众号配置
+  mp:
+    # 公众号appId（必填）
+    app-id: wx182a393d5c5e3479
+    # 公众号Secret（必填）
+    secret: 559d7bf12a781651c9772f525faa38e2
+    # 公众号token（选填，用于消息加解密）
+    token: your_token_here
+    # 公众号EncodingAESKey（选填，用于消息加解密）
+    aes-key: your_aes_key_here_43_characters_base64
+
+  # 微信小程序配置
+  miniapp:
+    # 小程序appId（必填）
+    app-id: wx9fb4034ebe52af77
+    # 小程序Secret（必填）
+    secret: 9b0eb221d9fa6bb46a463c24304f6d12
+    # 小程序token（选填，用于消息加解密）
+    token: your_miniapp_token
+    # 小程序EncodingAESKey（选填，用于消息加解密）
+    aes-key: your_miniapp_aes_key_43_characters_b64
+    # 消息格式，XML或者JSON
+    msg-data-format: JSON
+
+  # 微信支付配置
+  pay:
+    # 商户号（必填）
+    mch-id: 1671289865
+    # 商户密钥（V2版本必填）
+    mch-key: your_mch_key_here_32_characters_md5
+    # 证书路径（退款等操作需要，选填）
+    key-path: classpath:cert/apiclient_cert.p12
+    # apiV3秘钥（V3版本必填）
+    api-v3-key: lms8a288e6694a429a2f15c718b1b17e
+    # 证书序列号（V3版本必填）
+    cert-serial-no: 6EFD85369A957FB27680825035E456065FD575D2
+    # 私钥路径（V3版本选填，与private-content二选一）
+    # private-key-path: classpath:cert/apiclient_key.pem
+    # 私钥内容（V3版本选填，与private-key-path二选一，推荐使用此方式）
+    private-content: "-----BEGIN PRIVATE KEY-----\nMIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQDLEVxkdX6NJtDo\nzXOzkxn7kqR3MMc05/duLON4yjmLhTPQD8iiDoCOEuZEy8dLloi1OlXO3zu/F5jd\n9ynk8x++Px5A8gBQ16GZAMH18BQDzcFzy0EPe9ckiN3IXO8GT8Ht9oP430ugxF6t\nGM7Ixh93v48n7tUOZTISX5TzZCbXOiITH40b++/LB2LaMo9xAC4dEQs+2S4x5gO9\nPAh637ZAtVlbYxmJMYxzUM09KyXAoDlmO6YlO25EBkei7ZbyQob698s35+rSeq93\noFfUiegEL35SWeuuwp8ZFFvq24EUW7/n4U50/rS5hIFerEfcrFj2yPhP3sQtd4I+\nFjaEKzQLAgMBAAECggEBALxeUV9a4labUCT0GETWyr5j7C4oUFHSb+KCv0uYA0NZ\n/5McYRd67mNcQsBEa43BiPTbtSdeSnTbtdEI6pLXuHVo5W6HTiWvsNZWLpYt6tMQ\ndUgtnh932D2qvFiVZKBtMc7E4uzkbaonHk/heEgkCKKzTl9Tm81rr8P9aBVSrPjt\n6Xs7lORsD9bCoweYwfcrHELb+sLek/dOd9eCyabq7r5FV4EqOwJhw8btD7xgjw+o\nuVF3kWyhLSEwjpN/oo4w5r4yVPlMnSTn7MtTRFyJcU/w5YBk8MedGSTKRIvzPv4s\nRWU3ChTP5evGAh/FnpP6JGEhyvYGW0DqmuJUXK1n0fECgYEA/sSCT6Z+HSlwu/ui\nOSlDDFKZ/ci7vJcuksgf5Tw5Kj0fBVhgImO8hTS9nqCQx73JJTsUpTzyYOVxUd9b\nAqp42dgVbDYTmkfBi0xAZpnQD4Z4LUj6OkS2k3+2CPNN+jQpibGjGy11NDV/U8EQ\nP/9ioz+PoqwENG6wsaCT9LOC2DkCgYEAzAzUXJdH5T2LpSeO8e2NHtW6flemsJJ0\n+m0O03OWxQr6KNjFpNkTFoK6A2NYOiyqMZcQb+viHGFTFpFHkozo3QPaXpZsz3BC\ny9nQzqDbP3/MtfksE/MXOOw0qtdqT3csIxiXZqIjGYqAU08xcKyItZJGnIh/aKYn\nyobDnKkCRmMCgYB9mvbAPE6bJA4/r/03/17eGW9wjuH4RfUhSudmxn1MlNvRb9Pd\nwJx2dB00sucOg0RDRdCU8upw2U44Vk1xkAiLJpzRQAwEGXKTseFidFz++oYPlZZA\n2hXFvMZLvWDphYQhLeJDiPLq7aE78siHNOs1nyW6xuI/037r5EZt838ECQKBgQDC\n3+XY3+ob92Fsw5DzYIoMTtajXxalP9pUaN9l9tihKtCrPgvUWjSupP79yV0zggCx\nB7L9EOyLai+uN+WBAu5KVimxeDxHCNHiWg3fqSR7SpS5nlUIYHtnM79BAiZX6lrO\n0eeWb3bSJ8JSzilLkJunvSGO0ZXM3hLWi0o6TfcMPQKBgQDlmSC6/Ja4M+lGZEMx\nraCryScSi1kj3KkZFcGQEEejltpet2u06af/qA+tmMW7uxjLj5R80yqsYmUqS6Md\npHc1U7XsqU2MinqVJz47H8WZwYMDDLjNOI2f4coqbtBBOA6GKt+gYYqYxkpvVanT\noShAmWqOcPsioBVCFRVGvMlcNA==\n-----END PRIVATE KEY-----\n"
+
+  # 支付选项列表配置
+  pay-item:
+    pay-items:
+      - id: 1
+        amount: 9900  # 金额，单位：分 (99元)
+        add-month: 1  # 增加月份
+        title: "一个月会员"
+        description: "享受一个月全部功能"
+      - id: 2
+        amount: 29900  # 299元
+        add-month: 3  # 3个月
+        title: "三个月会员"
+        description: "享受三个月全部功能"
+      - id: 3
+        amount: 59900  # 599元
+        add-month: 6  # 6个月
+        title: "半年会员"
+        description: "享受半年全部功能"
+      - id: 4
+        amount: 99900  # 999元
+        add-month: 12  # 12个月
+        title: "一年会员"
+        description: "享受一年全部功能，最划算"
+
+  # 支付回调通知配置
+  pay-notify:
+    # 支付回调通知URL（需根据实际域名配置）
+    notify-url: "https://api.yuceyun.cn/fishery-api/weixin/pay_notify"
+    # 微信商户号（与上面wx.pay.mch-id保持一致）
+    mch-id: "1671289865"

intc-admin/src/main/resources/application-prod.yml

@@ -187,6 +187,10 @@ sms:
       access-key-secret: 您的accessKeySecret
       signature: 您的短信签名
       sdk-app-id: 您的sdkAppId
+  # plus扩展配置
+  plus:
+    # 短信验证码模板ID(请根据实际短信服务商的模板ID配置)
+    code-template-id: SMS_123456789
 
 --- # 三方授权
 justauth:

intc-admin/src/main/resources/application.yml

@@ -35,7 +35,7 @@ captcha:
 # 日志配置
 logging:
   level:
-    org.dromara: @logging.level@
+    org.dromara: info
     org.springframework: warn
     org.mybatis.spring.mapper: error
     org.apache.fury: warn
@@ -69,7 +69,7 @@ spring:
     # 国际化资源文件路径
     basename: i18n/messages
   profiles:
-    active: @profiles.active@
+    active: dev
   # 文件上传
   servlet:
     multipart:
@@ -118,6 +118,9 @@ security:
     - /*/api-docs
     - /*/api-docs/**
     - /warm-flow-ui/config
+    - /iot/test
+    - /iot/device/**
+    - /iot/amqp/**
 
 # 多租户配置
 tenant:
@@ -141,12 +144,12 @@ tenant:
 mybatis-plus:
   # 自定义配置 是否全局开启逻辑删除 关闭后 所有逻辑删除功能将失效
   enableLogicDelete: true
-  # 多包名使用 例如 org.dromara.**.mapper,org.xxx.**.mapper
-  mapperPackage: org.dromara.**.mapper
+  # 多包名使用 例如 com.intc.**.mapper,org.xxx.**.mapper
+  mapperPackage: com.intc.**.mapper
   # 对应的 XML 文件位置
   mapperLocations: classpath*:mapper/**/*Mapper.xml
   # 实体扫描，多个package用逗号或者分号分隔
-  typeAliasesPackage: org.dromara.**.domain
+  typeAliasesPackage: com.intc.**.domain
   global-config:
     dbConfig:
       # 主键类型
@@ -171,7 +174,7 @@ mybatis-encryptor:
 # api接口加密
 api-decrypt:
   # 是否开启全局接口加密
-  enabled: true
+  enabled: false
   # AES 加密头标识
   headerFlag: encrypt-key
   # 响应加密公钥 非对称算法的公私钥 如：SM2，RSA 使用者请自行更换

intc-common/intc-common-bom/pom.xml

@@ -4,8 +4,8 @@
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
 
-    <groupId>org.dromara</groupId>
-    <artifactId>ruoyi-common-bom</artifactId>
+    <groupId>com.intc</groupId>
+    <artifactId>intc-common-bom</artifactId>
     <version>${revision}</version>
     <packaging>pom</packaging>
 
@@ -21,161 +21,161 @@
         <dependencies>
             <!-- 核心模块 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-core</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-core</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 接口模块 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-doc</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-doc</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- excel -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-excel</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-excel</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 幂等 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-idempotent</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-idempotent</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 调度模块 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-job</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-job</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 日志记录 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-log</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-log</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 邮件服务 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-mail</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-mail</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 数据库服务 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-mybatis</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-mybatis</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- OSS -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-oss</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-oss</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 限流 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-ratelimiter</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-ratelimiter</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 缓存服务 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-redis</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-redis</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- satoken -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-satoken</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-satoken</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 安全模块 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-security</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-security</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 短信模块 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-sms</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-sms</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-social</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-social</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- web服务 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-web</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-web</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 翻译模块 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-translation</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-translation</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 脱敏模块 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-sensitive</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-sensitive</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 序列化模块 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-json</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-json</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 数据库加解密模块 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-encrypt</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-encrypt</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- 租户模块 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-tenant</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-tenant</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- WebSocket模块 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-websocket</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-websocket</artifactId>
                 <version>${revision}</version>
             </dependency>
 
             <!-- SSE模块 -->
             <dependency>
-                <groupId>org.dromara</groupId>
-                <artifactId>ruoyi-common-sse</artifactId>
+                <groupId>com.intc</groupId>
+                <artifactId>intc-common-sse</artifactId>
                 <version>${revision}</version>
             </dependency>
 

intc-common/intc-common-core/pom.xml

@@ -3,13 +3,13 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <groupId>org.dromara</groupId>
-        <artifactId>ruoyi-common</artifactId>
+        <groupId>com.intc</groupId>
+        <artifactId>intc-common</artifactId>
         <version>${revision}</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
-    <artifactId>ruoyi-common-core</artifactId>
+    <artifactId>intc-common-core</artifactId>
 
     <description>
         ruoyi-common-core 核心模块

intc-common/intc-common-core/src/main/java/com/intc/common/core/config/ApplicationConfig.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.config;
+package com.intc.common.core.config;
 
 import org.springframework.boot.autoconfigure.AutoConfiguration;
 import org.springframework.context.annotation.EnableAspectJAutoProxy;

intc-common/intc-common-core/src/main/java/com/intc/common/core/config/ThreadPoolConfig.java

@@ -1,11 +1,11 @@
-package org.dromara.common.core.config;
+package com.intc.common.core.config;
 
 import jakarta.annotation.PreDestroy;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.concurrent.BasicThreadFactory;
-import org.dromara.common.core.config.properties.ThreadPoolProperties;
-import org.dromara.common.core.utils.SpringUtils;
-import org.dromara.common.core.utils.Threads;
+import com.intc.common.core.config.properties.ThreadPoolProperties;
+import com.intc.common.core.utils.SpringUtils;
+import com.intc.common.core.utils.Threads;
 import org.springframework.boot.autoconfigure.AutoConfiguration;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Bean;

intc-common/intc-common-core/src/main/java/com/intc/common/core/config/ValidatorConfig.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.config;
+package com.intc.common.core.config;
 
 import jakarta.validation.Validator;
 import org.hibernate.validator.HibernateValidator;

intc-common/intc-common-core/src/main/java/com/intc/common/core/config/properties/DeviceTypeProperties.java

@@ -0,0 +1,62 @@
+package com.intc.common.core.config.properties;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+/**
+ * 设备类型配置
+ *
+ * @author intc
+ */
+@Data
+@Component
+@ConfigurationProperties(prefix = "device-type")
+public class DeviceTypeProperties {
+
+    /**
+     * 水质检测仪 ProductKey
+     */
+    private String waterQualityMonitor;
+
+    /**
+     * 控制一体机 ProductKey
+     */
+    private String controlIntegrated;
+
+    /**
+     * 根据 ProductKey 判断设备类型
+     * @param productKey ProductKey
+     * @return 设备类型: 1-水质检测仪, 2-控制一体机, null-未知类型
+     */
+    public Integer getDeviceTypeByProductKey(String productKey) {
+        if (productKey == null) {
+            return null;
+        }
+        if (productKey.equals(waterQualityMonitor)) {
+            return 1;
+        } else if (productKey.equals(controlIntegrated)) {
+            return 2;
+        }
+        return null;
+    }
+
+    /**
+     * 根据设备类型获取 ProductKey
+     * @param deviceType 1-水质检测仪, 2-控制一体机
+     * @return ProductKey
+     */
+    public String getProductKeyByType(Integer deviceType) {
+        if (deviceType == null) {
+            return null;
+        }
+        switch (deviceType) {
+            case 1:
+                return waterQualityMonitor;
+            case 2:
+                return controlIntegrated;
+            default:
+                return null;
+        }
+    }
+}

intc-common/intc-common-core/src/main/java/com/intc/common/core/config/properties/ThreadPoolProperties.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.config.properties;
+package com.intc.common.core.config.properties;
 
 import lombok.Data;
 import org.springframework.boot.context.properties.ConfigurationProperties;

intc-common/intc-common-core/src/main/java/com/intc/common/core/constant/CacheConstants.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.constant;
+package com.intc.common.core.constant;
 
 /**
  * 缓存的key 常量

intc-common/intc-common-core/src/main/java/com/intc/common/core/constant/CacheNames.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.constant;
+package com.intc.common.core.constant;
 
 /**
  * 缓存组名称常量

intc-common/intc-common-core/src/main/java/com/intc/common/core/constant/Constants.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.constant;
+package com.intc.common.core.constant;
 
 /**
  * 通用常量信息

intc-common/intc-common-core/src/main/java/com/intc/common/core/constant/GlobalConstants.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.constant;
+package com.intc.common.core.constant;
 
 /**
  * 全局的key常量 (业务无关的key)

intc-common/intc-common-core/src/main/java/com/intc/common/core/constant/HttpStatus.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.constant;
+package com.intc.common.core.constant;
 
 /**
  * 返回状态码

intc-common/intc-common-core/src/main/java/com/intc/common/core/constant/RegexConstants.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.constant;
+package com.intc.common.core.constant;
 
 import cn.hutool.core.lang.RegexPool;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/constant/SystemConstants.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.constant;
+package com.intc.common.core.constant;
 
 /**
  * 系统常量信息

intc-common/intc-common-core/src/main/java/com/intc/common/core/constant/TenantConstants.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.constant;
+package com.intc.common.core.constant;
 
 /**
  * 租户常量信息

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/R.java

@@ -1,6 +1,6 @@
-package org.dromara.common.core.domain;
+package com.intc.common.core.domain;
 
-import org.dromara.common.core.constant.HttpStatus;
+import com.intc.common.core.constant.HttpStatus;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/dto/CompleteTaskDTO.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.dto;
+package com.intc.common.core.domain.dto;
 
 import lombok.Data;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/dto/DeptDTO.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.dto;
+package com.intc.common.core.domain.dto;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/dto/DictDataDTO.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.dto;
+package com.intc.common.core.domain.dto;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/dto/DictTypeDTO.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.dto;
+package com.intc.common.core.domain.dto;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/dto/FlowCopyDTO.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.dto;
+package com.intc.common.core.domain.dto;
 
 import lombok.Data;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/dto/OssDTO.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.dto;
+package com.intc.common.core.domain.dto;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/dto/PostDTO.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.dto;
+package com.intc.common.core.domain.dto;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/dto/RoleDTO.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.dto;
+package com.intc.common.core.domain.dto;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/dto/StartProcessDTO.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.dto;
+package com.intc.common.core.domain.dto;
 
 
 import lombok.Data;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/dto/StartProcessReturnDTO.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.dto;
+package com.intc.common.core.domain.dto;
 
 
 import lombok.Data;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/dto/TaskAssigneeDTO.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.dto;
+package com.intc.common.core.domain.dto;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/dto/UserDTO.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.dto;
+package com.intc.common.core.domain.dto;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/dto/UserOnlineDTO.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.dto;
+package com.intc.common.core.domain.dto;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/event/ProcessDeleteEvent.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.event;
+package com.intc.common.core.domain.event;
 
 import lombok.Data;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/event/ProcessEvent.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.event;
+package com.intc.common.core.domain.event;
 
 import lombok.Data;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/event/ProcessTaskEvent.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.event;
+package com.intc.common.core.domain.event;
 
 import lombok.Data;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/model/EmailLoginBody.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.model;
+package com.intc.common.core.domain.model;
 
 import jakarta.validation.constraints.Email;
 import jakarta.validation.constraints.NotBlank;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/model/LoginBody.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.model;
+package com.intc.common.core.domain.model;
 
 import jakarta.validation.constraints.NotBlank;
 import lombok.Data;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/model/LoginUser.java

@@ -1,9 +1,9 @@
-package org.dromara.common.core.domain.model;
+package com.intc.common.core.domain.model;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;
-import org.dromara.common.core.domain.dto.PostDTO;
-import org.dromara.common.core.domain.dto.RoleDTO;
+import com.intc.common.core.domain.dto.PostDTO;
+import com.intc.common.core.domain.dto.RoleDTO;
 
 import java.io.Serial;
 import java.io.Serializable;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/model/PasswordLoginBody.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.model;
+package com.intc.common.core.domain.model;
 
 import jakarta.validation.constraints.NotBlank;
 import lombok.Data;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/model/RegisterBody.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.model;
+package com.intc.common.core.domain.model;
 
 import jakarta.validation.constraints.NotBlank;
 import lombok.Data;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/model/SmsLoginBody.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.model;
+package com.intc.common.core.domain.model;
 
 import jakarta.validation.constraints.NotBlank;
 import lombok.Data;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/model/SocialLoginBody.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.model;
+package com.intc.common.core.domain.model;
 
 import jakarta.validation.constraints.NotBlank;
 import lombok.Data;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/model/TaskAssigneeBody.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.model;
+package com.intc.common.core.domain.model;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/model/XcxLoginBody.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.model;
+package com.intc.common.core.domain.model;
 
 import jakarta.validation.constraints.NotBlank;
 import lombok.Data;

intc-common/intc-common-core/src/main/java/com/intc/common/core/domain/model/XcxLoginUser.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.domain.model;
+package com.intc.common.core.domain.model;
 
 import lombok.Data;
 import lombok.EqualsAndHashCode;

intc-common/intc-common-core/src/main/java/com/intc/common/core/enums/BusinessStatusEnum.java

@@ -1,10 +1,10 @@
-package org.dromara.common.core.enums;
+package com.intc.common.core.enums;
 
 import cn.hutool.core.util.StrUtil;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
-import org.dromara.common.core.exception.ServiceException;
-import org.dromara.common.core.utils.StringUtils;
+import com.intc.common.core.exception.ServiceException;
+import com.intc.common.core.utils.StringUtils;
 
 import java.util.Arrays;
 import java.util.List;

intc-common/intc-common-core/src/main/java/com/intc/common/core/enums/DeviceType.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.enums;
+package com.intc.common.core.enums;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

intc-common/intc-common-core/src/main/java/com/intc/common/core/enums/FormatsType.java

@@ -1,8 +1,8 @@
-package org.dromara.common.core.enums;
+package com.intc.common.core.enums;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;
-import org.dromara.common.core.utils.StringUtils;
+import com.intc.common.core.utils.StringUtils;
 
 /*
  * 日期格式

intc-common/intc-common-core/src/main/java/com/intc/common/core/enums/LoginType.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.enums;
+package com.intc.common.core.enums;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

intc-common/intc-common-core/src/main/java/com/intc/common/core/enums/UserStatus.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.enums;
+package com.intc.common.core.enums;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

intc-common/intc-common-core/src/main/java/com/intc/common/core/enums/UserType.java

@@ -1,8 +1,8 @@
-package org.dromara.common.core.enums;
+package com.intc.common.core.enums;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;
-import org.dromara.common.core.utils.StringUtils;
+import com.intc.common.core.utils.StringUtils;
 
 /**
  * 用户类型

intc-common/intc-common-core/src/main/java/com/intc/common/core/exception/ServiceException.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.exception;
+package com.intc.common.core.exception;
 
 import cn.hutool.core.text.StrFormatter;
 import lombok.AllArgsConstructor;

intc-common/intc-common-core/src/main/java/com/intc/common/core/exception/SseException.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.exception;
+package com.intc.common.core.exception;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

intc-common/intc-common-core/src/main/java/com/intc/common/core/exception/base/BaseException.java

@@ -1,8 +1,8 @@
-package org.dromara.common.core.exception.base;
+package com.intc.common.core.exception.base;
 
 import lombok.AllArgsConstructor;
-import org.dromara.common.core.utils.MessageUtils;
-import org.dromara.common.core.utils.StringUtils;
+import com.intc.common.core.utils.MessageUtils;
+import com.intc.common.core.utils.StringUtils;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.NoArgsConstructor;

intc-common/intc-common-core/src/main/java/com/intc/common/core/exception/file/FileException.java

@@ -1,6 +1,6 @@
-package org.dromara.common.core.exception.file;
+package com.intc.common.core.exception.file;
 
-import org.dromara.common.core.exception.base.BaseException;
+import com.intc.common.core.exception.base.BaseException;
 
 import java.io.Serial;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/exception/file/FileNameLengthLimitExceededException.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.exception.file;
+package com.intc.common.core.exception.file;
 
 import java.io.Serial;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/exception/file/FileSizeLimitExceededException.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.exception.file;
+package com.intc.common.core.exception.file;
 
 import java.io.Serial;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/exception/user/CaptchaException.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.exception.user;
+package com.intc.common.core.exception.user;
 
 import java.io.Serial;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/exception/user/CaptchaExpireException.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.exception.user;
+package com.intc.common.core.exception.user;
 
 import java.io.Serial;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/exception/user/UserException.java

@@ -1,6 +1,6 @@
-package org.dromara.common.core.exception.user;
+package com.intc.common.core.exception.user;
 
-import org.dromara.common.core.exception.base.BaseException;
+import com.intc.common.core.exception.base.BaseException;
 
 import java.io.Serial;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/factory/RegexPatternPoolFactory.java

@@ -1,7 +1,7 @@
-package org.dromara.common.core.factory;
+package com.intc.common.core.factory;
 
 import cn.hutool.core.lang.PatternPool;
-import org.dromara.common.core.constant.RegexConstants;
+import com.intc.common.core.constant.RegexConstants;
 
 import java.util.regex.Pattern;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/factory/YmlPropertySourceFactory.java

@@ -1,6 +1,6 @@
-package org.dromara.common.core.factory;
+package com.intc.common.core.factory;
 
-import org.dromara.common.core.utils.StringUtils;
+import com.intc.common.core.utils.StringUtils;
 import org.springframework.beans.factory.config.YamlPropertiesFactoryBean;
 import org.springframework.core.env.PropertiesPropertySource;
 import org.springframework.core.env.PropertySource;

intc-common/intc-common-core/src/main/java/com/intc/common/core/service/ConfigService.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.service;
+package com.intc.common.core.service;
 
 /**
  * 通用 参数配置服务

intc-common/intc-common-core/src/main/java/com/intc/common/core/service/DeptService.java

@@ -1,6 +1,6 @@
-package org.dromara.common.core.service;
+package com.intc.common.core.service;
 
-import org.dromara.common.core.domain.dto.DeptDTO;
+import com.intc.common.core.domain.dto.DeptDTO;
 
 import java.util.List;
 import java.util.Map;

intc-common/intc-common-core/src/main/java/com/intc/common/core/service/DictService.java

@@ -1,7 +1,7 @@
-package org.dromara.common.core.service;
+package com.intc.common.core.service;
 
-import org.dromara.common.core.domain.dto.DictDataDTO;
-import org.dromara.common.core.domain.dto.DictTypeDTO;
+import com.intc.common.core.domain.dto.DictDataDTO;
+import com.intc.common.core.domain.dto.DictTypeDTO;
 
 import java.util.List;
 import java.util.Map;

intc-common/intc-common-core/src/main/java/com/intc/common/core/service/OssService.java

@@ -1,6 +1,6 @@
-package org.dromara.common.core.service;
+package com.intc.common.core.service;
 
-import org.dromara.common.core.domain.dto.OssDTO;
+import com.intc.common.core.domain.dto.OssDTO;
 
 import java.util.List;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/service/PermissionService.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.service;
+package com.intc.common.core.service;
 
 import java.util.Set;
 

intc-common/intc-common-core/src/main/java/com/intc/common/core/service/PostService.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.service;
+package com.intc.common.core.service;
 
 import java.util.List;
 import java.util.Map;

intc-common/intc-common-core/src/main/java/com/intc/common/core/service/RoleService.java

@@ -1,4 +1,4 @@
-package org.dromara.common.core.service;
+package com.intc.common.core.service;
 
 import java.util.List;
 import java.util.Map;

intc-common/intc-common-core/src/main/java/com/intc/common/core/service/TaskAssigneeService.java

@@ -1,7 +1,7 @@
-package org.dromara.common.core.service;
+package com.intc.common.core.service;
 
-import org.dromara.common.core.domain.dto.TaskAssigneeDTO;
-import org.dromara.common.core.domain.model.TaskAssigneeBody;
+import com.intc.common.core.domain.dto.TaskAssigneeDTO;
+import com.intc.common.core.domain.model.TaskAssigneeBody;
 
 /**
  * 工作流设计器获取任务执行人

intc-common/intc-common-core/src/main/java/com/intc/common/core/service/UserService.java

@@ -1,6 +1,6 @@
-package org.dromara.common.core.service;
+package com.intc.common.core.service;
 
-import org.dromara.common.core.domain.dto.UserDTO;
+import com.intc.common.core.domain.dto.UserDTO;
 
 import java.util.List;
 import java.util.Map;

intc-common/intc-common-core/src/main/java/com/intc/common/core/service/WorkflowService.java

@@ -1,8 +1,8 @@
-package org.dromara.common.core.service;
+package com.intc.common.core.service;
 
-import org.dromara.common.core.domain.dto.CompleteTaskDTO;
-import org.dromara.common.core.domain.dto.StartProcessDTO;
-import org.dromara.common.core.domain.dto.StartProcessReturnDTO;
+import com.intc.common.core.domain.dto.CompleteTaskDTO;
+import com.intc.common.core.domain.dto.StartProcessDTO;
+import com.intc.common.core.domain.dto.StartProcessReturnDTO;
 
 import java.util.List;
 import java.util.Map;

intc-common/intc-common-core/src/main/java/com/intc/common/core/utils/DateUtils.java

@@ -1,8 +1,8 @@
-package org.dromara.common.core.utils;
+package com.intc.common.core.utils;
 
 import org.apache.commons.lang3.time.DateFormatUtils;
-import org.dromara.common.core.enums.FormatsType;
-import org.dromara.common.core.exception.ServiceException;
+import com.intc.common.core.enums.FormatsType;
+import com.intc.common.core.exception.ServiceException;
 
 import java.lang.management.ManagementFactory;
 import java.text.ParseException;