Merge branch 'test'

pom.xml

@@ -146,6 +146,13 @@
             <artifactId>4dkankan-utils-sign</artifactId>
             <version>3.0.0-SNAPSHOT</version>
         </dependency>
+
+        <dependency>
+            <groupId>com.maxmind.geoip2</groupId>
+            <artifactId>geoip2</artifactId>
+            <version>2.15.0</version>
+        </dependency>
+
     </dependencies>
 
     <build>

src/main/java/com/fdkankan/ucenter/common/RedisKeyUtil.java

@@ -18,6 +18,8 @@ public class RedisKeyUtil {
 
     public static final String laserCopyLock = "ucenter:laser:copy:lock:";
     public static String copySpaceLock =  "ucenter:scene:copy:lock:%s";
-
     public static String downE57Key =  "ucenter:down:e57:lock:%s";
+
+    public static String CONTACT_US_KEY =  "ucenter:contactus:%s";
+
 }

src/main/java/com/fdkankan/ucenter/common/constants/ResultCode.java

@@ -21,6 +21,12 @@ public enum ResultCode {
 
     SIGN_ERROR(99991, "签名错误"),
 
+    email_submit(500009, "邮件已提交"),
+    email_submit_error(500010, "邮件发送失败"),
+    USER_EXSIT(500011, "用户已存在"),
+    url_exprix(500012, "链接已过期"),
+
+
     ;
     private Integer code;
     private String message;

src/main/java/com/fdkankan/ucenter/config/UcenterConfig.java

@@ -2,13 +2,26 @@ package com.fdkankan.ucenter.config;
 
 import lombok.Data;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.context.annotation.Configuration;
 
 @Data
 @Configuration
+@RefreshScope
 public class UcenterConfig {
+
     @Value("${4dkk.laserService.basePath}")
     private String basePath;
+
     @Value("${spring.profiles.active}")
     private String active;
+
+    @Value("${ucenter.contactUs.callBackUrl}")
+    private String contactUsCallBackUrl;
+
+    @Value("${ucenter.contactUs.dfPassword}")
+    private String contactUsDfPassword;
+
+    @Value("${ucenter.contactUs.emailExTime}")
+    private Long emailExTime;
 }

src/main/java/com/fdkankan/ucenter/config/WebAppConfig.java

@@ -40,7 +40,8 @@ public class WebAppConfig implements WebMvcConfigurer {
 						"/**/vaild/cameras/**",
 						"/**/hot/shop/**",
 						"/**/getIncrementType/**",
-						"/**/system/**"
+						"/**/system/**",
+						"/**/contactUs/**"
 				);
 		registry.addInterceptor(ucenterInterceptor).addPathPatterns("/**/user/scene/**")
 				.excludePathPatterns(

src/main/java/com/fdkankan/ucenter/controller/ContactUsController.java

@@ -0,0 +1,61 @@
+package com.fdkankan.ucenter.controller;
+
+
+import cn.hutool.extra.servlet.ServletUtil;
+import com.fdkankan.ucenter.common.BaseController;
+import com.fdkankan.ucenter.common.RequestBase;
+import com.fdkankan.ucenter.common.Result;
+import com.fdkankan.ucenter.entity.ContactUs;
+import com.fdkankan.ucenter.entity.ContactUsPoint;
+import com.fdkankan.ucenter.geo.IPUtils;
+import com.fdkankan.ucenter.service.IContactUsService;
+import com.fdkankan.ucenter.vo.response.LoginVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletResponse;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author 
+ * @since 2025-10-20
+ */
+@RestController
+@RequestMapping("/ucenter/contactUs")
+public class ContactUsController extends BaseController {
+
+    @Autowired
+    IContactUsService contactUsService;
+
+    @GetMapping("/sceneList")
+    public Result sceneList(){
+        return Result.success(contactUsService.sceneList());
+    }
+
+    @PostMapping("/submit")
+    public Result submit(@RequestBody ContactUs contactUs){
+        String ip = IPUtils.getIpAddr(request);
+        contactUs.setIpAddress(ip);
+        contactUs.setSessionId(request.getSession().getId());
+        contactUsService.submit(contactUs);
+        return Result.success();
+    }
+
+    @GetMapping("/callBack/{uuid}")
+    public Result callBack(@PathVariable String uuid){
+        return Result.success(contactUsService.callBack(uuid));
+    }
+
+    @PostMapping("/point")
+    public Result point(@RequestBody ContactUsPoint contactUsPoint){
+        String ip = IPUtils.getIpAddr(request);
+        contactUsPoint.setIpAddress(ip);
+        contactUsPoint.setSessionId(request.getSession().getId());
+        contactUsService.point(contactUsPoint);
+        return Result.success();
+    }
+}
+

src/main/java/com/fdkankan/ucenter/entity/ContactUs.java

@@ -0,0 +1,69 @@
+package com.fdkankan.ucenter.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author 
+ * @since 2025-10-20
+ */
+@Getter
+@Setter
+@TableName("t_contact_us")
+public class ContactUs implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    @TableField("name")
+    private String name;
+
+    @TableField("tel")
+    private String tel;
+
+    @TableField("email")
+    private String email;
+
+    @TableField("company")
+    private String company;
+
+    @TableField("note")
+    private String note;
+
+    @TableField("ip_address")
+    private String ipAddress;
+
+    @TableField("country")
+    private String country;
+
+    @TableField("redirect_url")
+    private String redirectUrl;
+
+    @TableField("session_id")
+    private String sessionId;
+
+    @TableField("rec_status")
+    @TableLogic(value = "A",delval = "I")
+    private String recStatus;
+
+    @TableField("create_time")
+    private Date createTime;
+
+    @TableField("update_time")
+    private Date updateTime;
+
+
+}

src/main/java/com/fdkankan/ucenter/entity/ContactUsPoint.java

@@ -0,0 +1,78 @@
+package com.fdkankan.ucenter.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author 
+ * @since 2025-10-21
+ */
+@Getter
+@Setter
+@TableName("t_contact_us_point")
+public class ContactUsPoint implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    @TableField("session_id")
+    private String sessionId;
+
+    @TableField("page_name")
+    private String pageName;
+
+    @TableField("page_url")
+    private String pageUrl;
+
+    @TableField("utm_source")
+    private String utmSource;
+
+    @TableField("device_type")
+    private String deviceType;
+
+    @TableField("ip_address")
+    private String ipAddress;
+
+    @TableField("country")
+    private String country;
+
+    @TableField("scroll_depth")
+    private String scrollDepth;
+
+    @TableField("stop_time")
+    private Long stopTime;
+
+    @TableField("load_time")
+    private String loadTime;
+
+    @TableField("network_type")
+    private String networkType;
+
+    @TableField("lang")
+    private String lang;
+
+    @TableField("rec_status")
+    @TableLogic(value = "A",delval = "I")
+    private String recStatus;
+
+    @TableField("create_time")
+    private Date createTime;
+
+    @TableField("update_time")
+    private Date updateTime;
+
+
+}

src/main/java/com/fdkankan/ucenter/entity/ContactUsScene.java

@@ -0,0 +1,45 @@
+package com.fdkankan.ucenter.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author 
+ * @since 2025-10-23
+ */
+@Getter
+@Setter
+@TableName("t_contact_us_scene")
+public class ContactUsScene implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    @TableField("num")
+    private String num;
+
+    @TableField("rec_status")
+    @TableLogic(value = "A",delval = "I")
+    private String recStatus;
+
+    @TableField("create_time")
+    private Date createTime;
+
+    @TableField("update_time")
+    private Date updateTime;
+
+
+}

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

@@ -18,7 +18,7 @@ public class AutoGenerate {
         String path =System.getProperty("user.dir") ;
 
         generate(path,"ucenter", getTables(new String[]{
-                "t_app_secret"
+                "t_contact_us_scene"
         }));
 
 //        generate(path,"goods", getTables(new String[]{

src/main/java/com/fdkankan/ucenter/geo/IPLocation.java

@@ -0,0 +1,24 @@
+package com.fdkankan.ucenter.geo;
+
+public class IPLocation {
+    private String ip;
+    private String country;
+    private String countryCode;
+    private String city;
+    private Double latitude;
+    private Double longitude;
+
+    // getters and setters
+    public String getIp() { return ip; }
+    public void setIp(String ip) { this.ip = ip; }
+    public String getCountry() { return country; }
+    public void setCountry(String country) { this.country = country; }
+    public String getCountryCode() { return countryCode; }
+    public void setCountryCode(String countryCode) { this.countryCode = countryCode; }
+    public String getCity() { return city; }
+    public void setCity(String city) { this.city = city; }
+    public Double getLatitude() { return latitude; }
+    public void setLatitude(Double latitude) { this.latitude = latitude; }
+    public Double getLongitude() { return longitude; }
+    public void setLongitude(Double longitude) { this.longitude = longitude; }
+}

src/main/java/com/fdkankan/ucenter/geo/IPLocationService.java

@@ -0,0 +1,58 @@
+package com.fdkankan.ucenter.geo;
+
+import com.maxmind.geoip2.DatabaseReader;
+import com.maxmind.geoip2.model.CityResponse;
+import com.maxmind.geoip2.model.CountryResponse;
+import org.springframework.core.io.ClassPathResource;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.InetAddress;
+
+public class IPLocationService {
+    private DatabaseReader dbReader;
+
+    public IPLocationService(String dbPath) throws IOException {
+        ClassPathResource resource = new ClassPathResource(dbPath);
+        InputStream inputStream = resource.getInputStream();
+        dbReader = new DatabaseReader.Builder(inputStream).build();
+    }
+
+    public String getCountryByIP(String ip) {
+        try {
+            InetAddress ipAddress = InetAddress.getByName(ip);
+            CountryResponse response = dbReader.country(ipAddress);
+            return response.getCountry().getName();
+        } catch (Exception e) {
+            return "Unknown";
+        }
+    }
+
+    public IPLocation getLocationByIP(String ip) {
+        try {
+            InetAddress ipAddress = InetAddress.getByName(ip);
+            CityResponse response = dbReader.city(ipAddress);
+
+            IPLocation location = new IPLocation();
+            location.setIp(ip);
+            location.setCountry(response.getCountry().getName());
+            location.setCountryCode(response.getCountry().getIsoCode());
+            location.setCity(response.getCity().getName());
+            location.setLatitude(response.getLocation().getLatitude());
+            location.setLongitude(response.getLocation().getLongitude());
+
+            return location;
+        } catch (Exception e) {
+            return null;
+        }
+    }
+
+    public void close() throws IOException {
+        if (dbReader != null) {
+            dbReader.close();
+        }
+    }
+}
+
+

src/main/java/com/fdkankan/ucenter/geo/IPUtils.java

@@ -0,0 +1,45 @@
+package com.fdkankan.ucenter.geo;
+
+import cn.hutool.extra.servlet.ServletUtil;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.HashMap;
+import java.util.Map;
+
+public class IPUtils {
+    private static IPLocationService locationService;
+
+    static {
+        try {
+            locationService = new IPLocationService("geo/GeoLite2-City.mmdb");
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    public static String getCountry(String ip) {
+        if (locationService != null) {
+            return locationService.getCountryByIP(ip);
+        }
+        return "Unknown";
+    }
+
+    public static Map<String, String> getLocationInfo(String ip) {
+        Map<String, String> info = new HashMap<>();
+        if (locationService != null) {
+            IPLocation location = locationService.getLocationByIP(ip);
+            if (location != null) {
+                info.put("country", location.getCountry());
+                info.put("city", location.getCity());
+                info.put("latitude", String.valueOf(location.getLatitude()));
+                info.put("longitude", String.valueOf(location.getLongitude()));
+            }
+        }
+        return info;
+    }
+
+    public static String getIpAddr(HttpServletRequest request) {
+        return ServletUtil.getClientIP(request);
+    }
+
+}

src/main/java/com/fdkankan/ucenter/interceptor/ControllerAopInterceptor.java

@@ -1,6 +1,7 @@
 package com.fdkankan.ucenter.interceptor;
 
 import com.alibaba.fastjson.JSONObject;
+import com.fdkankan.ucenter.geo.IPUtils;
 import org.aspectj.lang.ProceedingJoinPoint;
 import org.aspectj.lang.annotation.Around;
 import org.aspectj.lang.annotation.Aspect;
@@ -50,7 +51,7 @@ public class ControllerAopInterceptor {
 		HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
 		// 请求的URL
 		String requestURL = request.getRequestURL().toString();
-		String ip = getIpAddr(request);
+		String ip = IPUtils.getIpAddr(request);
 
 		StringBuilder paramsBuf = new StringBuilder();
 		// 获取请求参数集合并进行遍历拼接
@@ -75,36 +76,5 @@ public class ControllerAopInterceptor {
 		return result;
 	}
 
-	/**
-	 * @Title: getIpAddr
-	 * @Description: 获取ip
-	 * @param request
-	 * @return
-	 * @return String 返回类型
-	 */
-	public String getIpAddr(HttpServletRequest request) {
-		String ipAddress = null;
-		ipAddress = request.getHeader("x-forwarded-for");
-		if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
-			ipAddress = request.getHeader("Proxy-Client-IP");
-		}
-		if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
-			ipAddress = request.getHeader("WL-Proxy-Client-IP");
-		}
-		if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
-			ipAddress = request.getRemoteAddr();
-		}
-
-// 对于通过多个代理的情况，第一个IP为客户端真实IP,多个IP按照','分割
-		if (ipAddress != null && ipAddress.length() > 15) { // "***.***.***.***".length()
-			// = 15
-			if (ipAddress.indexOf(",") > 0) {
-				ipAddress = ipAddress.substring(0, ipAddress.indexOf(","));
-			}
-		}
-		// 或者这样也行,对于通过多个代理的情况，第一个IP为客户端真实IP,多个IP按照','分割
-//return ipAddress!=null&&!"".equals(ipAddress)?ipAddress.split(",")[0]:null;
-		return ipAddress;
-	}
 }
 

src/main/java/com/fdkankan/ucenter/mapper/IContactUsMapper.java

@@ -0,0 +1,18 @@
+package com.fdkankan.ucenter.mapper;
+
+import com.fdkankan.ucenter.entity.ContactUs;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author 
+ * @since 2025-10-20
+ */
+@Mapper
+public interface IContactUsMapper extends BaseMapper<ContactUs> {
+
+}

src/main/java/com/fdkankan/ucenter/mapper/IContactUsPointMapper.java

@@ -0,0 +1,18 @@
+package com.fdkankan.ucenter.mapper;
+
+import com.fdkankan.ucenter.entity.ContactUsPoint;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author 
+ * @since 2025-10-21
+ */
+@Mapper
+public interface IContactUsPointMapper extends BaseMapper<ContactUsPoint> {
+
+}

src/main/java/com/fdkankan/ucenter/mapper/IContactUsSceneMapper.java

@@ -0,0 +1,18 @@
+package com.fdkankan.ucenter.mapper;
+
+import com.fdkankan.ucenter.entity.ContactUsScene;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author 
+ * @since 2025-10-23
+ */
+@Mapper
+public interface IContactUsSceneMapper extends BaseMapper<ContactUsScene> {
+
+}

src/main/java/com/fdkankan/ucenter/mapper/IScenePlusMapper.java

@@ -8,6 +8,7 @@ import com.fdkankan.ucenter.vo.request.AppSceneParam;
 import com.fdkankan.ucenter.vo.request.LaserSceneParam;
 import com.fdkankan.ucenter.vo.response.AppSceneVo;
 import com.fdkankan.ucenter.vo.response.SceneNumVo;
+import com.fdkankan.ucenter.vo.response.SceneVo;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
@@ -38,4 +39,6 @@ public interface IScenePlusMapper extends BaseMapper<ScenePlus> {
     Page<RelicsSceneInitQueueDTO> pageLaserScene(Page<RelicsSceneInitQueueDTO> page, LaserSceneParam param);
 
     Long getCountByAndIsObj(@Param("userId")Long userId, @Param("sceneSourceList")List<String> sourceList, @Param("isObj")Integer isObj,@Param("isLaser")Integer isLaser);
+
+    List<SceneVo> getVoByNumList(@Param("numList")List<String> numList);
 }

src/main/java/com/fdkankan/ucenter/service/IContactUsPointService.java

@@ -0,0 +1,17 @@
+package com.fdkankan.ucenter.service;
+
+import com.fdkankan.ucenter.entity.ContactUsPoint;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author 
+ * @since 2025-10-21
+ */
+public interface IContactUsPointService extends IService<ContactUsPoint> {
+
+    ContactUsPoint getBySessionId(String sessionId);
+}

src/main/java/com/fdkankan/ucenter/service/IContactUsSceneService.java

@@ -0,0 +1,16 @@
+package com.fdkankan.ucenter.service;
+
+import com.fdkankan.ucenter.entity.ContactUsScene;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author 
+ * @since 2025-10-23
+ */
+public interface IContactUsSceneService extends IService<ContactUsScene> {
+
+}

src/main/java/com/fdkankan/ucenter/service/IContactUsService.java

@@ -0,0 +1,31 @@
+package com.fdkankan.ucenter.service;
+
+import com.fdkankan.ucenter.entity.ContactUs;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.fdkankan.ucenter.entity.ContactUsPoint;
+import com.fdkankan.ucenter.vo.response.LoginVo;
+import com.fdkankan.ucenter.vo.response.SceneVo;
+import org.springframework.http.ResponseEntity;
+
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author 
+ * @since 2025-10-20
+ */
+public interface IContactUsService extends IService<ContactUs> {
+
+    void submit(ContactUs contactUs);
+
+    LoginVo callBack(String email);
+
+    void point(ContactUsPoint contactUsPoint);
+
+    List<SceneVo> sceneList();
+}

src/main/java/com/fdkankan/ucenter/service/IMailTemplateService.java

@@ -53,4 +53,8 @@ public interface IMailTemplateService extends IService<MailTemplate> {
     void sendPayErrorMail(String email,String memberLevels);
 
     void sendSubcriptionCancelledMail(String email,String memberLevels);
+
+    Boolean sendContactUs(String email,String callBackUrl);
+
+    void sendContactUs2(String email);
 }

src/main/java/com/fdkankan/ucenter/service/IScenePlusService.java

@@ -12,6 +12,7 @@ import com.fdkankan.ucenter.vo.ResponseScene;
 import com.fdkankan.ucenter.vo.request.LaserSceneParam;
 import com.fdkankan.ucenter.vo.request.RequestScene;
 import com.fdkankan.ucenter.vo.response.SceneNumVo;
+import com.fdkankan.ucenter.vo.response.SceneVo;
 import org.springframework.web.bind.annotation.RequestParam;
 
 import java.io.IOException;
@@ -66,4 +67,6 @@ public interface IScenePlusService extends IService<ScenePlus> {
     Page<RelicsSceneInitQueueDTO> pageLaserScene(Page<RelicsSceneInitQueueDTO> objectPage, LaserSceneParam param);
 
     Long getCountByAndIsObj(Long userId, List<String> sourceList, Integer isObj,Integer isLaser);
+
+    List<SceneVo> getVoByNumList(List<String> numList);
 }

src/main/java/com/fdkankan/ucenter/service/impl/ContactUsPointServiceImpl.java

@@ -0,0 +1,27 @@
+package com.fdkankan.ucenter.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.fdkankan.ucenter.entity.ContactUsPoint;
+import com.fdkankan.ucenter.mapper.IContactUsPointMapper;
+import com.fdkankan.ucenter.service.IContactUsPointService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author 
+ * @since 2025-10-21
+ */
+@Service
+public class ContactUsPointServiceImpl extends ServiceImpl<IContactUsPointMapper, ContactUsPoint> implements IContactUsPointService {
+
+    @Override
+    public ContactUsPoint getBySessionId(String sessionId) {
+        LambdaQueryWrapper<ContactUsPoint> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(ContactUsPoint::getSessionId,sessionId);
+        return this.getOne(wrapper);
+    }
+}

src/main/java/com/fdkankan/ucenter/service/impl/ContactUsSceneServiceImpl.java

@@ -0,0 +1,20 @@
+package com.fdkankan.ucenter.service.impl;
+
+import com.fdkankan.ucenter.entity.ContactUsScene;
+import com.fdkankan.ucenter.mapper.IContactUsSceneMapper;
+import com.fdkankan.ucenter.service.IContactUsSceneService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author 
+ * @since 2025-10-23
+ */
+@Service
+public class ContactUsSceneServiceImpl extends ServiceImpl<IContactUsSceneMapper, ContactUsScene> implements IContactUsSceneService {
+
+}

src/main/java/com/fdkankan/ucenter/service/impl/ContactUsServiceImpl.java

@@ -0,0 +1,169 @@
+package com.fdkankan.ucenter.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.fdkankan.common.constant.ConstantUrl;
+import com.fdkankan.common.util.SecurityUtil;
+import com.fdkankan.redis.util.RedisUtil;
+import com.fdkankan.ucenter.common.RedisKeyUtil;
+import com.fdkankan.ucenter.common.SceneSourceUtil;
+import com.fdkankan.ucenter.common.constants.ResultCode;
+import com.fdkankan.ucenter.config.UcenterConfig;
+import com.fdkankan.ucenter.entity.*;
+import com.fdkankan.ucenter.exception.BusinessException;
+import com.fdkankan.ucenter.geo.IPUtils;
+import com.fdkankan.ucenter.mapper.IContactUsMapper;
+import com.fdkankan.ucenter.service.*;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fdkankan.ucenter.util.DateUserUtil;
+import com.fdkankan.ucenter.vo.request.RegisterParam;
+import com.fdkankan.ucenter.vo.response.LoginVo;
+import com.fdkankan.ucenter.vo.response.SceneInfoVo;
+import com.fdkankan.ucenter.vo.response.ScenePlusVo;
+import com.fdkankan.ucenter.vo.response.SceneVo;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author 
+ * @since 2025-10-20
+ */
+@Service
+@Slf4j
+public class ContactUsServiceImpl extends ServiceImpl<IContactUsMapper, ContactUs> implements IContactUsService {
+
+    @Autowired
+    RedisUtil redisUtil;
+    @Autowired
+    IMailTemplateService mailTemplateService;
+    @Autowired
+    IUserService userService;
+    @Autowired
+    LoginService loginService;
+    @Autowired
+    IContactUsPointService contactUsPointService;
+    @Autowired
+    UcenterConfig ucenterConfig;
+
+    @Override
+    public void submit(ContactUs contactUs) {
+        if(StringUtils.isBlank(contactUs.getName()) || StringUtils.isBlank(contactUs.getTel())
+                || StringUtils.isBlank(contactUs.getEmail()) || StringUtils.isBlank(contactUs.getCompany())){
+            throw new BusinessException(ResultCode.PARAM_MISS);
+        }
+        String redisKey = String.format(RedisKeyUtil.CONTACT_US_KEY,contactUs.getEmail());
+        if(redisUtil.hasKey(redisKey)){
+            throw new BusinessException(ResultCode.email_submit);
+        }
+        String uuid = UUID.randomUUID().toString().replace("-", "");
+        String redisKey2 = String.format(RedisKeyUtil.CONTACT_US_KEY,uuid);
+
+        User user = userService.getByUserName(contactUs.getEmail());
+        contactUs.setCountry(IPUtils.getCountry(contactUs.getIpAddress()));
+        if(user !=null){
+            mailTemplateService.sendContactUs2(contactUs.getEmail());
+            this.save(contactUs);
+            return;
+        }
+        String callBackUrl = ucenterConfig.getContactUsCallBackUrl() + uuid;
+        Boolean b = mailTemplateService.sendContactUs(contactUs.getEmail(),callBackUrl);
+        if(b){
+            redisUtil.set(redisKey, uuid,ucenterConfig.getEmailExTime());
+            redisUtil.set(redisKey2, JSONObject.toJSONString(contactUs),ucenterConfig.getEmailExTime());
+        }
+        this.save(contactUs);
+    }
+
+    @Override
+    public LoginVo callBack(String uuid) {
+        String rediskey = String.format(RedisKeyUtil.CONTACT_US_KEY,uuid);
+        String rediskey2 = null;
+        if(!redisUtil.hasKey(rediskey)){
+            throw new BusinessException(ResultCode.url_exprix);
+        }
+
+        try {
+            if(redisUtil.hasKey(rediskey) ){
+                ContactUs contactUs = JSONObject.parseObject( redisUtil.get(rediskey),ContactUs.class);
+                rediskey2 = String.format(RedisKeyUtil.CONTACT_US_KEY,contactUs.getEmail());
+                User userEntity = userService.getByUserName(contactUs.getEmail());
+                if(userEntity == null){
+                    userEntity = new User();
+                    userEntity.setPassword(SecurityUtil.MD5(ucenterConfig.getContactUsDfPassword()));
+                    userEntity.setEmail(contactUs.getEmail());
+                    userEntity.setUserName(contactUs.getEmail());
+                    userEntity.setNickName(contactUs.getName());
+                    userEntity.setHead(ConstantUrl.DEFAULT_USER_HEAD);
+                    userEntity.setStatus(1);
+                    userEntity.setIsNotice(1);
+                    userEntity.setRecStatus("A");
+                    userEntity.setCreateTime(DateUserUtil.getDate(new Date()));
+                    userEntity.setUpdateTime(DateUserUtil.getDate(new Date()));
+                    userEntity.setAgentKey("wherefor");
+                    userService.save(userEntity);
+                }
+                LoginVo login = loginService.login(userEntity);
+                return login;
+            }
+
+        }catch (Exception e){
+            log.info("contact-us-callback-error:{}",e);
+        }finally {
+            redisUtil.del(rediskey);
+            if(rediskey2 != null){
+                redisUtil.del(rediskey2);
+            }
+        }
+        return null;
+    }
+
+    @Override
+    public  void point(ContactUsPoint contactUsPoint) {
+        ContactUsPoint contactUsPoint2 = contactUsPointService.getBySessionId(contactUsPoint.getSessionId());
+        if(contactUsPoint2 == null){
+            contactUsPoint.setStopTime(1L);
+            contactUsPoint.setCountry(IPUtils.getCountry(contactUsPoint.getIpAddress()));
+        }
+        if(contactUsPoint2 != null){
+            contactUsPoint.setId(contactUsPoint2.getId());
+            contactUsPoint.setStopTime(contactUsPoint2.getStopTime() + 1);
+        }
+        contactUsPointService.saveOrUpdate(contactUsPoint);
+    }
+
+    @Autowired
+    IContactUsSceneService contactUsSceneService;
+    @Autowired
+    IScenePlusService scenePlusService;
+    @Override
+    public List<SceneVo> sceneList() {
+        List<ContactUsScene> list = contactUsSceneService.list();
+        List<String> numList = list.stream().map(ContactUsScene::getNum).collect(Collectors.toList());
+        if(numList.isEmpty()){
+            return new ArrayList<>();
+        }
+        List<SceneVo> sceneVos = scenePlusService.getVoByNumList(numList);
+        for (SceneVo sceneVo : sceneVos) {
+            if(SceneSourceUtil.isLaser(sceneVo.getSceneSource())){
+                if(ucenterConfig.getActive().contains("prod")){
+                    sceneVo.setWebSite(ucenterConfig.getBasePath() +"/index.html?m="+sceneVo.getNum());
+                }else {
+                    sceneVo.setWebSite(ucenterConfig.getBasePath() +"/uat/index.html?m="+sceneVo.getNum());
+                }
+                sceneVo.setSceneName(sceneVo.getLaserTitle());
+            }
+        }
+        return sceneVos;
+    }
+}

src/main/java/com/fdkankan/ucenter/service/impl/FusionService.java

@@ -3,6 +3,7 @@ package com.fdkankan.ucenter.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.fdkankan.common.exception.BusinessException;
+import com.fdkankan.common.util.SecurityUtil;
 import com.fdkankan.ucenter.common.PageInfo;
 import com.fdkankan.ucenter.constant.LoginConstant;
 import com.fdkankan.ucenter.entity.*;

src/main/java/com/fdkankan/ucenter/service/impl/MailTemplateServiceImpl.java

@@ -13,6 +13,7 @@ import com.fdkankan.ucenter.service.IScenePlusExtService;
 import com.fdkankan.ucenter.util.SendMailUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
+import org.aspectj.apache.bcel.generic.RET;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -55,7 +56,12 @@ public class MailTemplateServiceImpl extends ServiceImpl<IMailTemplateMapper, Ma
         wrapper.eq(MailTemplate::getLang,lang);
         return this.getOne(wrapper);
     }
-
+    public MailTemplate getTemplateEn(Integer type) {
+        LambdaQueryWrapper<MailTemplate> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(MailTemplate::getType,type);
+        wrapper.eq(MailTemplate::getLang,"en");
+        return this.getOne(wrapper);
+    }
 
     @Override
     public Boolean sendCodeMail(String email, String code,String lang) {
@@ -244,6 +250,26 @@ public class MailTemplateServiceImpl extends ServiceImpl<IMailTemplateMapper, Ma
         sendMail(email,mailTemplate,null);
     }
 
+    @Override
+    public Boolean sendContactUs(String email,String callBackUrl) {
+        MailTemplate mailTemplate = this.getTemplateEn(12);
+        //<a href="{callBackUrl}" target="_blank" rel="noopener">{callBackUrl}</a>
+        if(mailTemplate != null){
+            String msg = mailTemplate.getMsg();
+            if(StringUtils.isNotBlank(callBackUrl)){
+                msg = msg.replace("{callBackUrl}",callBackUrl);
+            }
+            mailTemplate.setMsg(msg);
+        }
+       return sendMail(email,mailTemplate,null);
+    }
+
+    @Override
+    public void sendContactUs2(String email) {
+        MailTemplate mailTemplate = this.getTemplateEn(13);
+        sendMail(email,mailTemplate,null);
+    }
+
     public  String getMemberLeversMsg(String memberLevels){
         switch (memberLevels){
             case "PR" :return "PREMIUM";

src/main/java/com/fdkankan/ucenter/service/impl/ScenePlusServiceImpl.java

@@ -446,4 +446,9 @@ public class ScenePlusServiceImpl extends ServiceImpl<IScenePlusMapper, ScenePlu
     public Long getCountByAndIsObj(Long userId, List<String> sourceList, Integer isObj,Integer isLaser) {
         return this.getBaseMapper().getCountByAndIsObj(userId,sourceList,isObj, isLaser);
     }
+
+    @Override
+    public List<SceneVo> getVoByNumList(List<String> numList) {
+        return this.getBaseMapper().getVoByNumList(numList);
+    }
 }

src/main/resources/mapper/ucenter/ContactUsMapper.xml

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

src/main/resources/mapper/ucenter/ContactUsPointMapper.xml

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

src/main/resources/mapper/ucenter/ContactUsSceneMapper.xml

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

src/main/resources/mapper/ucenter/ScenePlusMapper.xml

@@ -174,4 +174,12 @@
         </if>
         order by s.create_time desc
     </select>
+    <select id="getVoByNumList" resultType="com.fdkankan.ucenter.vo.response.SceneVo">
+        select * from t_scene_plus s left join  t_scene_plus_ext e on s.id = e.plus_id
+        where s.rec_status= 'A'
+        and s.num in
+        <foreach collection="numList" item="num" open="(" separator="," close=")">
+            #{num}
+        </foreach>
+    </select>
 </mapper>