域名映射功能测试、bug修复

neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/dal/LicenseMapper.java

@@ -72,7 +72,7 @@ public interface LicenseMapper extends BaseMapper<LicenseDO> {
 
     default void updateOnlineStatus(Integer isOnline, Date updateTime) {
         this.update(null, new LambdaUpdateWrapper<LicenseDO>()
-                .set(LicenseDO::getIsOnline, updateTime)
+                .set(LicenseDO::getIsOnline, isOnline)
                 .set(LicenseDO::getUpdateTime, updateTime)
         );
     }

neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/proxy/core/HttpProxy.java

@@ -1,7 +1,6 @@
 package org.dromara.neutrinoproxy.server.proxy.core;
 
 import cn.hutool.core.util.StrUtil;
-import com.sun.deploy.net.proxy.ProxyType;
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.*;

neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/LicenseService.java

@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.github.pagehelper.Page;
 import com.github.pagehelper.PageHelper;
 import com.google.common.collect.Sets;
+import org.dromara.neutrinoproxy.server.base.db.DBInitialize;
 import org.dromara.neutrinoproxy.server.base.page.PageInfo;
 import org.dromara.neutrinoproxy.server.base.page.PageQuery;
 import org.dromara.neutrinoproxy.server.base.rest.SystemContextHolder;
@@ -27,6 +28,7 @@ import org.apache.ibatis.solon.annotation.Db;
 import org.dromara.neutrinoproxy.server.controller.res.proxy.*;
 import org.jetbrains.annotations.Nullable;
 import org.noear.solon.annotation.Component;
+import org.noear.solon.annotation.Init;
 import org.noear.solon.annotation.Inject;
 import org.noear.solon.core.Lifecycle;
 import org.noear.solon.core.bean.LifecycleBean;
@@ -50,6 +52,8 @@ public class LicenseService implements LifecycleBean {
 	private UserMapper userMapper;
 	@Inject
 	private VisitorChannelService visitorChannelService;
+	@Inject
+	private DBInitialize dbInitialize;
 
 	public PageInfo<LicenseListRes> page(PageQuery pageQuery, LicenseListReq req) {
 		Page<LicenseListRes> result = PageHelper.startPage(pageQuery.getCurrent(), pageQuery.getSize());
@@ -217,9 +221,15 @@ public class LicenseService implements LifecycleBean {
 	/**
 	 * 服务端项目停止、启动时，更新在线状态为离线
 	 */
+	@Init
+	public void init() {
+		licenseMapper.updateOnlineStatus(OnlineStatusEnum.OFFLINE.getStatus(), new Date());
+	}
+
+
 	@Override
 	public void start() throws Throwable {
-		licenseMapper.updateOnlineStatus(OnlineStatusEnum.OFFLINE.getStatus(), new Date());
+
 	}
 
 	/**

neutrino-proxy-server/src/main/java/org/dromara/neutrinoproxy/server/service/PortMappingService.java

@@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.github.pagehelper.Page;
 import com.github.pagehelper.PageHelper;
 import com.google.common.collect.Sets;
+import org.dromara.neutrinoproxy.server.base.db.DBInitialize;
 import org.dromara.neutrinoproxy.server.base.page.PageInfo;
 import org.dromara.neutrinoproxy.server.base.page.PageQuery;
 import org.dromara.neutrinoproxy.server.base.proxy.ProxyConfig;
@@ -34,6 +35,7 @@ import org.apache.ibatis.solon.annotation.Db;
 import org.dromara.neutrinoproxy.server.controller.res.proxy.*;
 import org.dromara.neutrinoproxy.server.util.ProxyUtil;
 import org.noear.solon.annotation.Component;
+import org.noear.solon.annotation.Init;
 import org.noear.solon.annotation.Inject;
 import org.noear.solon.core.Lifecycle;
 import org.noear.solon.core.bean.LifecycleBean;
@@ -66,6 +68,8 @@ public class PortMappingService implements LifecycleBean {
 	private PortPoolService portPoolService;
 	@Inject
 	private ProxyConfig proxyConfig;
+	@Inject
+	private DBInitialize dbInitialize;
 
 	public PageInfo<PortMappingListRes> page(PageQuery pageQuery, PortMappingListReq req) {
 		Page<PortMappingListRes> result = PageHelper.startPage(pageQuery.getCurrent(), pageQuery.getSize());
@@ -274,8 +278,8 @@ public class PortMappingService implements LifecycleBean {
 	/**
 	 * 服务端项目停止、启动时，更新在线状态为离线
 	 */
-	@Override
-	public void start() throws Throwable {
+	@Init
+	public void init() {
 		portMappingMapper.updateOnlineStatus(OnlineStatusEnum.OFFLINE.getStatus(), new Date());
 
 		// 未配置域名，则不需要处理域名映射逻辑
@@ -297,6 +301,11 @@ public class PortMappingService implements LifecycleBean {
 		});
 	}
 
+	@Override
+	public void start() throws Throwable {
+
+	}
+
 	/**
 	 * 服务端项目停止、启动时，更新在线状态为离线
 	 */