[update] 修改目录com->utc.dt

signal-utc-dt-service/pom.xml

@@ -237,7 +237,7 @@
                         <!--                        <creationTime>2022-10-14T10:08:59.304+08:00</creationTime>-->
                         <creationTime>${maven.build.timestamp}</creationTime>
 
-                        <mainClass>net.wanji.com.DTApplication</mainClass>
+                        <mainClass>net.wanji.utc.dt.DTApplication</mainClass>
                     </container>
                     <!--可以进行HTTP-->
                     <allowInsecureRegistries>true</allowInsecureRegistries>

signal-utc-dt-service/src/main/java/net/wanji/com/DTApplication.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/DTApplication.java

-package net.wanji.com;
+package net.wanji.utc.dt;
 
-import net.wanji.com.netty.NettyClient;
+import net.wanji.utc.dt.netty.NettyClient;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.CommandLineRunner;
@@ -13,8 +13,8 @@ import org.springframework.transaction.annotation.EnableTransactionManagement;
  * @author duanruiming
  * @date 2023/05/08 13:37
  */
-@SpringBootApplication(scanBasePackages = {"net.wanji.com", "net.wanji.databus", "net.wanji.common"})
-@MapperScan(basePackages = {"net.wanji.com.mapper", "net.wanji.databus.dao.mapper"})
+@SpringBootApplication(scanBasePackages = {"net.wanji.utc.dt", "net.wanji.databus", "net.wanji.common"})
+@MapperScan(basePackages = {"net.wanji.databus.dao.mapper"})
 @EnableTransactionManagement
 @EnableScheduling
 @SuppressWarnings("all")

signal-utc-dt-service/src/main/java/net/wanji/com/cache/CrossInfoCache.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/cache/CrossInfoCache.java

-package net.wanji.com.cache;
+package net.wanji.utc.dt.cache;
 
 import lombok.extern.slf4j.Slf4j;
 import net.wanji.common.enums.BaseEnum;

signal-utc-dt-service/src/main/java/net/wanji/com/cache/SignalCommandInterfaceCache.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/cache/SignalCommandInterfaceCache.java

-package net.wanji.com.cache;
+package net.wanji.utc.dt.cache;
 
 import lombok.extern.slf4j.Slf4j;
-import net.wanji.com.service.controller.BeanMarkService;
-import net.wanji.com.service.controller.ControlCommandService;
-import net.wanji.com.service.controller.SignalStatusService;
-import net.wanji.com.service.controller.StaticInfoService;
-import net.wanji.com.common.enums.SignalInterfaceTypeEnum;
+import net.wanji.utc.dt.service.controller.BeanMarkService;
+import net.wanji.utc.dt.service.controller.ControlCommandService;
+import net.wanji.utc.dt.service.controller.SignalStatusService;
+import net.wanji.utc.dt.service.controller.StaticInfoService;
+import net.wanji.utc.dt.common.enums.SignalInterfaceTypeEnum;
 import net.wanji.common.framework.spring.ServiceBeanContext;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.stereotype.Component;

signal-utc-dt-service/src/main/java/net/wanji/com/cache/SignalDataCache.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/cache/SignalDataCache.java

-package net.wanji.com.cache;
+package net.wanji.utc.dt.cache;
 
-import net.wanji.com.pojo.dtconvert.PhaseInfoPojo;
-import net.wanji.com.pojo.dtconvert.PhaseStageInfoPojo;
-import net.wanji.com.pojo.dtconvert.SchemeInfoPojo;
+import net.wanji.utc.dt.pojo.dtconvert.PhaseInfoPojo;
+import net.wanji.utc.dt.pojo.dtconvert.PhaseStageInfoPojo;
+import net.wanji.utc.dt.pojo.dtconvert.SchemeInfoPojo;
 import org.springframework.stereotype.Component;
 
 import java.util.HashMap;

signal-utc-dt-service/src/main/java/net/wanji/com/cache/netty/NettyMessageCache.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/cache/netty/NettyMessageCache.java

-package net.wanji.com.cache.netty;
+package net.wanji.utc.dt.cache.netty;
 
-import net.wanji.com.pojo.netty.MessageResultPojo;
+import net.wanji.utc.dt.pojo.netty.MessageResultPojo;
 import net.wanji.databus.po.CrossInfoPO;
 
 import java.util.HashMap;

signal-utc-dt-service/src/main/java/net/wanji/com/common/constants/Constants.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/common/constants/Constants.java

-package net.wanji.com.common.constants;
+package net.wanji.utc.dt.common.constants;
 
-import net.wanji.com.util.CRC16Utils;
+import net.wanji.utc.dt.util.CRC16Utils;
 import org.springframework.stereotype.Component;
 
 import java.sql.Connection;

signal-utc-dt-service/src/main/java/net/wanji/com/common/enums/CommandResultSign.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/common/enums/CommandResultSign.java

-package net.wanji.com.common.enums;
+package net.wanji.utc.dt.common.enums;
 
 import lombok.Getter;
 import org.apache.commons.lang3.StringUtils;

signal-utc-dt-service/src/main/java/net/wanji/com/common/enums/ControlModelEnum.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/common/enums/ControlModelEnum.java

-package net.wanji.com.common.enums;
+package net.wanji.utc.dt.common.enums;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

signal-utc-dt-service/src/main/java/net/wanji/com/common/enums/ControlTypeEnum.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/common/enums/ControlTypeEnum.java

-package net.wanji.com.common.enums;
+package net.wanji.utc.dt.common.enums;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

signal-utc-dt-service/src/main/java/net/wanji/com/common/enums/PhaseLightColorEnum.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/common/enums/PhaseLightColorEnum.java

-package net.wanji.com.common.enums;
+package net.wanji.utc.dt.common.enums;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

signal-utc-dt-service/src/main/java/net/wanji/com/common/enums/SectionControlModeEnum.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/common/enums/SectionControlModeEnum.java

-package net.wanji.com.common.enums;
+package net.wanji.utc.dt.common.enums;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

signal-utc-dt-service/src/main/java/net/wanji/com/common/enums/SignalInterfaceTypeEnum.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/common/enums/SignalInterfaceTypeEnum.java

-package net.wanji.com.common.enums;
+package net.wanji.utc.dt.common.enums;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
-import net.wanji.com.service.controller.ControlCommandService;
-import net.wanji.com.service.controller.SignalStatusService;
-import net.wanji.com.service.controller.StaticInfoService;
+import net.wanji.utc.dt.service.controller.ControlCommandService;
+import net.wanji.utc.dt.service.controller.SignalStatusService;
+import net.wanji.utc.dt.service.controller.StaticInfoService;
 
 import java.util.Objects;
 

signal-utc-dt-service/src/main/java/net/wanji/com/config/Swagger2.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/config/Swagger2.java

-package net.wanji.com.config;
+package net.wanji.utc.dt.config;
 
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -21,7 +21,7 @@ public class Swagger2 {
                 .apiInfo(apiInfo())
                 .select()
                 //为当前包路径
-                .apis(RequestHandlerSelectors.basePackage("net.wanji.com.controller"))
+                .apis(RequestHandlerSelectors.basePackage("net.wanji.utc.dt.controller"))
                 .paths(PathSelectors.any())
                 .build();
     }

signal-utc-dt-service/src/main/java/net/wanji/com/controller/ControlCommandController.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/controller/ControlCommandController.java

-package net.wanji.com.controller;
+package net.wanji.utc.dt.controller;
 
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
 import lombok.RequiredArgsConstructor;
-import net.wanji.com.service.controller.ControlCommandService;
+import net.wanji.utc.dt.service.controller.ControlCommandService;
 import net.wanji.common.annotation.aspect.AspectLog;
 import net.wanji.common.enums.BaseEnum;
 import net.wanji.common.framework.rest.JsonViewObject;

signal-utc-dt-service/src/main/java/net/wanji/com/controller/SignalStatusController.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/controller/SignalStatusController.java

-package net.wanji.com.controller;
+package net.wanji.utc.dt.controller;
 
 /**
  * @author Kent HAN
@@ -10,7 +10,7 @@ import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiResponse;
 import io.swagger.annotations.ApiResponses;
 import lombok.RequiredArgsConstructor;
-import net.wanji.com.service.controller.SignalStatusService;
+import net.wanji.utc.dt.service.controller.SignalStatusService;
 import net.wanji.common.annotation.aspect.AspectLog;
 import net.wanji.common.enums.BaseEnum;
 import net.wanji.common.framework.rest.JsonViewObject;

signal-utc-dt-service/src/main/java/net/wanji/com/controller/StaticInfoController.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/controller/StaticInfoController.java

-package net.wanji.com.controller;
+package net.wanji.utc.dt.controller;
 
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiResponse;
 import io.swagger.annotations.ApiResponses;
 import lombok.RequiredArgsConstructor;
-import net.wanji.com.service.controller.StaticInfoService;
+import net.wanji.utc.dt.service.controller.StaticInfoService;
 import net.wanji.common.annotation.aspect.AspectLog;
 import net.wanji.common.enums.BaseEnum;
 import net.wanji.common.framework.rest.JsonViewObject;

signal-utc-dt-service/src/main/java/net/wanji/com/netty/NettyClient.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/NettyClient.java

-package net.wanji.com.netty;
+package net.wanji.utc.dt.netty;
 
 
 import cn.hutool.core.util.HexUtil;
@@ -9,12 +9,12 @@ import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.DatagramPacket;
 import io.netty.channel.socket.nio.NioDatagramChannel;
 import lombok.extern.slf4j.Slf4j;
-import net.wanji.com.cache.CrossInfoCache;
-import net.wanji.com.cache.netty.NettyMessageCache;
-import net.wanji.com.netty.codec.MessageDecoder;
-import net.wanji.com.netty.codec.MessageEnCoder;
-import net.wanji.com.netty.handler.NettyServerHandler;
-import net.wanji.com.pojo.netty.MessageResultPojo;
+import net.wanji.utc.dt.cache.CrossInfoCache;
+import net.wanji.utc.dt.cache.netty.NettyMessageCache;
+import net.wanji.utc.dt.netty.codec.MessageDecoder;
+import net.wanji.utc.dt.netty.codec.MessageEnCoder;
+import net.wanji.utc.dt.netty.handler.NettyServerHandler;
+import net.wanji.utc.dt.pojo.netty.MessageResultPojo;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

signal-utc-dt-service/src/main/java/net/wanji/com/netty/codec/MessageDecoder.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/codec/MessageDecoder.java

-package net.wanji.com.netty.codec;
+package net.wanji.utc.dt.netty.codec;
 
 import cn.hutool.core.util.HexUtil;
 import io.netty.buffer.ByteBuf;

signal-utc-dt-service/src/main/java/net/wanji/com/netty/codec/MessageEnCoder.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/codec/MessageEnCoder.java

-package net.wanji.com.netty.codec;
+package net.wanji.utc.dt.netty.codec;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;

signal-utc-dt-service/src/main/java/net/wanji/com/netty/commandsign/CommandResultSign.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/commandsign/CommandResultSign.java

-package net.wanji.com.netty.commandsign;
+package net.wanji.utc.dt.netty.commandsign;
 
 import org.apache.commons.lang3.StringUtils;
 

signal-utc-dt-service/src/main/java/net/wanji/com/netty/handler/NettyServerHandler.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/handler/NettyServerHandler.java

-package net.wanji.com.netty.handler;
+package net.wanji.utc.dt.netty.handler;
 
 import cn.hutool.core.util.HexUtil;
 import io.netty.buffer.ByteBuf;
@@ -6,12 +6,12 @@ import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
 import io.netty.channel.socket.DatagramPacket;
 import lombok.extern.slf4j.Slf4j;
-import net.wanji.com.cache.CrossInfoCache;
-import net.wanji.com.cache.netty.NettyMessageCache;
-import net.wanji.com.netty.commandsign.CommandResultSign;
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
-import net.wanji.com.pojo.netty.MessageResultPojo;
+import net.wanji.utc.dt.cache.CrossInfoCache;
+import net.wanji.utc.dt.cache.netty.NettyMessageCache;
+import net.wanji.utc.dt.netty.commandsign.CommandResultSign;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.pojo.netty.MessageResultPojo;
 import net.wanji.common.framework.spring.ServiceBeanContext;
 import net.wanji.databus.po.CrossInfoPO;
 import org.apache.commons.lang3.StringUtils;
@@ -21,8 +21,6 @@ import javax.annotation.Resource;
 import java.net.InetSocketAddress;
 import java.util.Objects;
 
-import static net.wanji.com.common.enums.CommandResultSign.getClassNameByHexSign;
-
 @Slf4j
 @Component
 public class NettyServerHandler extends SimpleChannelInboundHandler<DatagramPacket> {
@@ -50,7 +48,7 @@ public class NettyServerHandler extends SimpleChannelInboundHandler<DatagramPack
             log.error("返回命令标识为空hexSign: {}", hexSign);
             return;
         }
-        String className = getClassNameByHexSign(hexSign);
+        String className = net.wanji.utc.dt.common.enums.CommandResultSign.getClassNameByHexSign(hexSign);
         CommandResponseFactory commandResponseFactory = (CommandResponseFactory) ServiceBeanContext.getBean(className);
         String key = StringUtils.join("/", remote.getHostString(), ":", remote.getPort(), "/", hexSign);
         CommandPojo commandPojo = getCommandPojo(key, data);

signal-utc-dt-service/src/main/java/net/wanji/com/netty/pojo/CommandPojo.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/pojo/CommandPojo.java

-package net.wanji.com.netty.pojo;
+package net.wanji.utc.dt.netty.pojo;
 
 import lombok.Data;
 

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/CommandResponseFactory.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/CommandResponseFactory.java

-package net.wanji.com.netty.response;
+package net.wanji.utc.dt.netty.response;
 
-import net.wanji.com.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
 
 /**
  * @author duanruiming

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/HeartBeatService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/HeartBeatService.java

-package net.wanji.com.netty.response.impl;
+package net.wanji.utc.dt.netty.response.impl;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import net.wanji.com.cache.CrossInfoCache;
-import net.wanji.com.common.constants.Constants;
-import net.wanji.com.netty.NettyClient;
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
-import net.wanji.com.pojo.netty.MessageResultPojo;
+import net.wanji.utc.dt.cache.CrossInfoCache;
+import net.wanji.utc.dt.common.constants.Constants;
+import net.wanji.utc.dt.netty.NettyClient;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.pojo.netty.MessageResultPojo;
 import net.wanji.databus.po.CrossInfoPO;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetAlarmInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetAlarmInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetBaseInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetBaseInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetDailyPlanInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetDailyPlanInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetDetectorInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetDetectorInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetDeviceInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetDeviceInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetFaultInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetFaultInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetLightsGroupInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetLightsGroupInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetLightsStatusInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetLightsStatusInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetPhaseInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetPhaseInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetPhaseSecurityInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetPhaseSecurityInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetRunningStateInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetRunningStateInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetSchedulesInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetSchedulesInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetSchemeInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetSchemeInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetStageInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetStageInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetStageStatusService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetStageStatusService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/get/GetTrafficDataInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/get/GetTrafficDataInfoService.java

-package net.wanji.com.netty.response.impl.get;
+package net.wanji.utc.dt.netty.response.impl.get;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetAlarmInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetAlarmInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetBaseInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetBaseInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetControlInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetControlInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetDailyPlanInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetDailyPlanInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetDetectorInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetDetectorInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetDeviceInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetDeviceInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetFaultInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetFaultInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetLightsGroupInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetLightsGroupInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetPhaseInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetPhaseInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetPhaseSecurityInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetPhaseSecurityInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetSchedulesInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetSchedulesInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetSchemeInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetSchemeInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetStageInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetStageInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/netty/response/impl/set/SetTrafficDataInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/netty/response/impl/set/SetTrafficDataInfoService.java

-package net.wanji.com.netty.response.impl.set;
+package net.wanji.utc.dt.netty.response.impl.set;
 
-import net.wanji.com.netty.pojo.CommandPojo;
-import net.wanji.com.netty.response.CommandResponseFactory;
+import net.wanji.utc.dt.netty.pojo.CommandPojo;
+import net.wanji.utc.dt.netty.response.CommandResponseFactory;
 import org.springframework.stereotype.Service;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/pojo/dtconvert/DailyPlanInfoPojo.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/pojo/dtconvert/DailyPlanInfoPojo.java

-package net.wanji.com.pojo.dtconvert;
+package net.wanji.utc.dt.pojo.dtconvert;
 
 import lombok.Data;
 

signal-utc-dt-service/src/main/java/net/wanji/com/pojo/dtconvert/FaultInfoPojo.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/pojo/dtconvert/FaultInfoPojo.java

-package net.wanji.com.pojo.dtconvert;
+package net.wanji.utc.dt.pojo.dtconvert;
 
 import lombok.Data;
 

signal-utc-dt-service/src/main/java/net/wanji/com/pojo/dtconvert/LightsInfoPojo.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/pojo/dtconvert/LightsInfoPojo.java

-package net.wanji.com.pojo.dtconvert;
+package net.wanji.utc.dt.pojo.dtconvert;
 
 import lombok.Data;
 

signal-utc-dt-service/src/main/java/net/wanji/com/pojo/dtconvert/PhaseInfoPojo.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/pojo/dtconvert/PhaseInfoPojo.java

-package net.wanji.com.pojo.dtconvert;
+package net.wanji.utc.dt.pojo.dtconvert;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;

signal-utc-dt-service/src/main/java/net/wanji/com/pojo/dtconvert/PhaseStageInfoPojo.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/pojo/dtconvert/PhaseStageInfoPojo.java

-package net.wanji.com.pojo.dtconvert;
+package net.wanji.utc.dt.pojo.dtconvert;
 
 import lombok.Data;
 

signal-utc-dt-service/src/main/java/net/wanji/com/pojo/dtconvert/PhaseStageStatusPojo.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/pojo/dtconvert/PhaseStageStatusPojo.java

-package net.wanji.com.pojo.dtconvert;
+package net.wanji.utc.dt.pojo.dtconvert;
 
 import lombok.Data;
 

signal-utc-dt-service/src/main/java/net/wanji/com/pojo/dtconvert/RunningStatusPojo.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/pojo/dtconvert/RunningStatusPojo.java

-package net.wanji.com.pojo.dtconvert;
+package net.wanji.utc.dt.pojo.dtconvert;
 
 import lombok.Data;
 

signal-utc-dt-service/src/main/java/net/wanji/com/pojo/dtconvert/ScheduleInfoPojo.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/pojo/dtconvert/ScheduleInfoPojo.java

-package net.wanji.com.pojo.dtconvert;
+package net.wanji.utc.dt.pojo.dtconvert;
 
 import lombok.Data;
 

signal-utc-dt-service/src/main/java/net/wanji/com/pojo/dtconvert/SchemeInfoPojo.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/pojo/dtconvert/SchemeInfoPojo.java

-package net.wanji.com.pojo.dtconvert;
+package net.wanji.utc.dt.pojo.dtconvert;
 
 import lombok.Data;
 

signal-utc-dt-service/src/main/java/net/wanji/com/pojo/netty/MessageResultPojo.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/pojo/netty/MessageResultPojo.java

-package net.wanji.com.pojo.netty;
+package net.wanji.utc.dt.pojo.netty;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

signal-utc-dt-service/src/main/java/net/wanji/com/service/CommonService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/CommonService.java

-package net.wanji.com.service;
+package net.wanji.utc.dt.service;
 
 import lombok.NonNull;
 import lombok.RequiredArgsConstructor;

signal-utc-dt-service/src/main/java/net/wanji/com/service/controller/BeanMarkService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/controller/BeanMarkService.java

-package net.wanji.com.service.controller;
+package net.wanji.utc.dt.service.controller;
 
 /**
  * @author duanruiming

signal-utc-dt-service/src/main/java/net/wanji/com/service/controller/ControlCommandService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/controller/ControlCommandService.java

-package net.wanji.com.service.controller;
+package net.wanji.utc.dt.service.controller;
 
 import net.wanji.common.framework.rest.JsonViewObject;
 import net.wanji.databus.vo.*;

signal-utc-dt-service/src/main/java/net/wanji/com/service/controller/SignalStatusService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/controller/SignalStatusService.java

-package net.wanji.com.service.controller;
+package net.wanji.utc.dt.service.controller;
 
 import net.wanji.databus.po.SignalStatusLogPO;
 import net.wanji.databus.vo.LightsStatusVO;

signal-utc-dt-service/src/main/java/net/wanji/com/service/controller/StaticInfoService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/controller/StaticInfoService.java

-package net.wanji.com.service.controller;
+package net.wanji.utc.dt.service.controller;
 
 import net.wanji.databus.dao.entity.CrossSchedulesPO;
 import net.wanji.databus.dto.CrossInfoDTO;

signal-utc-dt-service/src/main/java/net/wanji/com/service/controller/impl/DTControlCommandServiceImpl.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/controller/impl/DTControlCommandServiceImpl.java

-package net.wanji.com.service.controller.impl;
+package net.wanji.utc.dt.service.controller.impl;
 
+import cn.hutool.core.util.HexUtil;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import net.wanji.com.cache.CrossInfoCache;
-import net.wanji.com.common.constants.Constants;
-import net.wanji.com.common.enums.ControlModelEnum;
-import net.wanji.com.common.enums.SectionControlModeEnum;
-import net.wanji.com.netty.NettyClient;
-import net.wanji.com.pojo.netty.MessageResultPojo;
-import net.wanji.com.service.controller.ControlCommandService;
-import net.wanji.com.util.CommonUtils;
+import net.wanji.utc.dt.cache.CrossInfoCache;
+import net.wanji.utc.dt.cache.SignalDataCache;
+import net.wanji.utc.dt.common.constants.Constants;
+import net.wanji.utc.dt.common.enums.ControlModelEnum;
+import net.wanji.utc.dt.common.enums.SectionControlModeEnum;
+import net.wanji.utc.dt.netty.NettyClient;
+import net.wanji.utc.dt.pojo.dtconvert.PhaseInfoPojo;
+import net.wanji.utc.dt.pojo.netty.MessageResultPojo;
+import net.wanji.utc.dt.service.controller.ControlCommandService;
+import net.wanji.utc.dt.util.CommonUtils;
 import net.wanji.common.enums.BaseEnum;
 import net.wanji.common.framework.rest.JsonViewObject;
 import net.wanji.databus.po.CrossInfoPO;
@@ -41,17 +44,20 @@ public class DTControlCommandServiceImpl implements ControlCommandService {
 
     @Override
     public JsonViewObject schemeSend(SchemeSendVO schemeSendVO) throws Exception {
-        String crossId = schemeSendVO.getCrossCode();
-        CrossInfoPO crossInfoPO = crossInfoCache.getCrossInfoCache().get(crossId);
-        List<SchemeSendVO.Pattern> schemeVOList = schemeSendVO.getPatternList();
-        setSchemePhaseStageInfo(crossInfoPO, schemeVOList);
+        try {
+            String crossId = schemeSendVO.getCrossCode();
+            CrossInfoPO crossInfoPO = crossInfoCache.getCrossInfoCache().get(crossId);
+            List<SchemeSendVO.Pattern> schemeVOList = schemeSendVO.getPatternList();
+            setSchemePhaseStageInfo(crossInfoPO, schemeVOList);
+        } catch (Exception e) {
+            throw new Exception("下发方案异常", e);
+        }
         return JsonViewObject.newInstance().success("下发方案成功");
     }
 
     private void setSchemePhaseStageInfo(CrossInfoPO crossInfoPO, List<SchemeSendVO.Pattern> schemeVOList) {
         setPhaseStageInfo(crossInfoPO, schemeVOList);
         setSchemeInfo(crossInfoPO, schemeVOList);
-
     }
 
     private void setSchemeInfo(CrossInfoPO crossInfoPO, List<SchemeSendVO.Pattern> schemeVOList) {
@@ -86,7 +92,7 @@ public class DTControlCommandServiceImpl implements ControlCommandService {
                     String phaseStageIdChain = getPhaseStageIdTimeChainHex(schemeVO.getRings());
                     sb.append(phaseStageIdChain).append(String.format("%02x", i)).append("14");
                 }
-                if (i == 7) {
+                if (i == 8) {
                     String phaseStageIdTypeChain = getPhaseStageIdTypeChainHex(schemeVO.getRings());
                     sb.append(phaseStageIdTypeChain).append(String.format("%02x", i)).append("05");
                 }
@@ -95,11 +101,11 @@ public class DTControlCommandServiceImpl implements ControlCommandService {
 
         String bodyValueLength = String.format("%02x", schemeVOList.size() * 7); // 调度数量 * 属性数量
         String message = String.format(Constants.COMMAND_SET_COMMON, Constants.COMMAND_SET, bodyValueLength, sb.substring(0, sb.length() - 4));
-        String planSign = StringUtils.join(Constants.COMMAND_SCHME_CONFIG, Constants.COMMAND_SET_REPLY);
-        String planMessageHex = Constants.buildMessage(message);
-        MessageResultPojo resultPojo = NettyClient.sendMessage(crossInfoPO.getIp(), crossInfoPO.getPort(), planMessageHex, planSign, 300);
+        String schemeSign = StringUtils.join(Constants.COMMAND_SCHME_CONFIG, Constants.COMMAND_SET_REPLY);
+        String schemeMessage = Constants.buildMessage(message);
+        MessageResultPojo resultPojo = NettyClient.sendMessage(crossInfoPO.getIp(), crossInfoPO.getPort(), schemeMessage, schemeSign, 300);
         if (Objects.nonNull(resultPojo) && StringUtils.isNotBlank(resultPojo.getHexMessageResult())) {
-            log.info("下发方案成功");
+            log.info("下发方案信息成功");
         }
     }
 
@@ -125,6 +131,7 @@ public class DTControlCommandServiceImpl implements ControlCommandService {
         }
         return StringUtils.leftPad(sb.toString(), 64, "0");
     }
+
     private String getPhaseStageIdChainHex(List<SchemeSendVO.Pattern.Ring> rings) {
         StringBuffer sb = new StringBuffer();
         for (SchemeSendVO.Pattern.Ring ring : rings) { // 都是单环模式 相位就是阶段
@@ -138,7 +145,43 @@ public class DTControlCommandServiceImpl implements ControlCommandService {
     }
 
     private void setPhaseStageInfo(CrossInfoPO crossInfoPO, List<SchemeSendVO.Pattern> schemeVOList) {
+        StringBuffer sb = new StringBuffer();
+        int phaseStageSize = 0;
+        String matchStr = "0602%s%s";
+        for (SchemeSendVO.Pattern pattern : schemeVOList) {
+            List<SchemeSendVO.Pattern.Ring> rings = pattern.getRings();
+            for (SchemeSendVO.Pattern.Ring ring : rings) { // 单环
+                List<SchemeSendVO.Pattern.Ring.Phase> phaseList = ring.getPhaseList();
+                phaseStageSize = phaseList.size();
+                for (SchemeSendVO.Pattern.Ring.Phase phase : phaseList) {
+                    Integer phaseNo = Integer.valueOf(phase.getPhaseNo());
+                    for (int i = 2; i <= 4; i++) {
+                        sb.append(String.format(matchStr, String.format("%02x", i), String.format("%02x", phaseNo)));
+                        if (i == 2) {
+                            sb.append(StringUtils.leftPad(HexUtil.toHex(CommonUtils.get4BinaryInteger(phaseNo)), 16, "0"));
+                            sb.append(String.format("%02x", i)).append("44");
+                        }
+                        if (i == 3) {
+                            sb.append("00000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000");
+                            sb.append(String.format("%02x", i)).append("44");
+                        }
+                        if (i == 4) {
+                            sb.append("00000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000");
+                            sb.append(String.format("%02x", i)).append("0c");
+                        }
+                    }
+                }
+            }
+        }
 
+        String bodyValueLength = String.format("%02x", phaseStageSize * 4);
+        String message = String.format(Constants.COMMAND_SET_COMMON, Constants.COMMAND_SET, bodyValueLength, sb.substring(0, sb.length() - 4));
+        String setPhaseStageSign = StringUtils.join(Constants.COMMAND_PHASE_STAGE_CONFIG, Constants.COMMAND_SET_REPLY);
+        String setPhaseStageMessage = Constants.buildMessage(message);
+        MessageResultPojo resultPojo = NettyClient.sendMessage(crossInfoPO.getIp(), crossInfoPO.getPort(), setPhaseStageMessage, setPhaseStageSign, 300);
+        if (Objects.nonNull(resultPojo) && StringUtils.isNotBlank(resultPojo.getHexMessageResult())) {
+            log.info("下发相位阶段成功");
+        }
     }
 
 
@@ -379,7 +422,9 @@ public class DTControlCommandServiceImpl implements ControlCommandService {
     }
 
     private void setPhaseInfo(CrossInfoPO crossInfoPO, List<PhaseTimingSendVO.Phase> phaseList) {
-        for (PhaseTimingSendVO.Phase phase : phaseList) {
+        String matchStr = "0402%s%s";
+        StringBuffer sb = new StringBuffer();
+        for (PhaseTimingSendVO.Phase phase : phaseList) { // 绿灯时间 = 阶段时间 - 黄灯 - 红灯  22 - 2 - 3
             Integer phaseNo = phase.getPhaseNo();
             Integer yellow = phase.getYellow();
             Integer allRed = phase.getAllred();
@@ -387,16 +432,76 @@ public class DTControlCommandServiceImpl implements ControlCommandService {
             String maxGreen = phase.getMaxGreen();
             String minGreen = phase.getMinGreen();
             List<PhaseTimingSendVO.Phase.Lane> lanes = phase.getLanes();
-
-            String matchStr = "0402%s%s";
-            StringBuffer sb = new StringBuffer();
-            for (int i = 2; i <= 31 ; i++) {
+            List<PhaseInfoPojo> phaseInfoList = SignalDataCache.phaseInfoCache.get(crossInfoPO.getId());
+            PhaseInfoPojo phaseInfoPojo = null;
+            for (PhaseInfoPojo element : phaseInfoList) {
+                if (Objects.equals(phaseNo, element.getPhaseId())) {
+                    phaseInfoPojo = element;
+                }
+            }
+            for (int i = 2; i <= 31; i++) {
                 sb.append(String.format(matchStr, String.format("%02x", i), String.format("%02x", phaseNo)));
                 if (i == 2) {
-                    sb.append("");
+                    String phaseHex = StringUtils.leftPad(CommonUtils.getBinary(phaseNo), 16, "0");
+                    sb.append(phaseHex).append(String.format("%02x", i)).append("05");
+                }
+                if (i == 3) {
+                    sb.append("20").append(String.format("%02x", i)).append("05"); // 绿灯类型
+                }
+                if (i == 4) {
+                    Integer greenTime = phaseInfoPojo.getGreenTime();
+                    sb.append(String.format("%02x", greenTime)).append(String.format("%02x", i)).append("05"); // 绿灯时间
+                }
+                if (i == 5) {
+                    sb.append("21").append(String.format("%02x", i)).append("05"); // 绿闪类型
+                }
+                if (i == 6) {
+                    sb.append(String.format("%02x", Integer.valueOf(greenFlash))).append(String.format("%02x", i)).append("05"); // 绿闪时间
+                }
+                if (i == 7) {
+                    sb.append("30").append(String.format("%02x", i)).append("05"); // 黄灯类型
+                }
+                if (i == 8) {
+                    sb.append(String.format("%02x", Integer.valueOf(yellow))).append(String.format("%02x", i)).append("05"); // 绿闪时间
+                }
+                if (i == 9) {
+                    sb.append("10").append(String.format("%02x", i)).append("05"); // 红灯类型
+                }
+                if (i == 10) {
+                    Integer redTime = Integer.valueOf(allRed) + Integer.valueOf(yellow) + Integer.valueOf(greenFlash) + phaseInfoPojo.getGreenTime();
+                    sb.append(String.format("%02x", redTime)).append(String.format("%02x", i)).append("05"); // 红灯时间
+                }
+                if (i == 11) {
+                    String str = "04020B%s000B0504020C%s000C0504020D%s000D0504020E%s000E0504020F%s310F05040210%s0A1005040211%s001105040212%s001205040213%s001305040214%s001405040215%s311505040216%s0A1605040217%s001705040218%s001805040219%s00190504021A%s001A06";
+                    sb.append(String.format(str, String.format("%02x", phaseNo)));
+                }
+                if (i > 11 && i <= 26) {
+                    continue;
+                }
+                if (i == 27) {
+                    String minGreenHex = StringUtils.leftPad(String.format("%02x", Integer.valueOf(minGreen)), 4, "0");
+                    sb.append(minGreenHex).append(String.format("%02x", i)).append("06");
+                }
+                if (i == 28 || i == 29) {
+                    String maxGreenHex = StringUtils.leftPad(String.format("%02x", Integer.valueOf(maxGreen)), 4, "0");
+                    sb.append(maxGreenHex).append(String.format("%02x", i)).append("06");
+                }
+                if (i == 30) {
+                    sb.append(String.format("04021E%s00031E0C", String.format("%02x", phaseNo))); // 延长绿时间
+                }
+                if (i == 31) {
+                    sb.append(String.format("04021F%s00000000000000001F0C",String.format("%02x", phaseNo)));
                 }
             }
+        }
 
+        String bodyValueLength = String.format("%02x", phaseList.size() * 31); // 调度数量 * 属性数量
+        String message = String.format(Constants.COMMAND_SET_COMMON, Constants.COMMAND_SET, bodyValueLength, sb.substring(0, sb.length() - 4));
+        String phaseSign = StringUtils.join(Constants.COMMAND_SCHME_CONFIG, Constants.COMMAND_SET_REPLY);
+        String phaseMessage = Constants.buildMessage(message);
+        MessageResultPojo resultPojo = NettyClient.sendMessage(crossInfoPO.getIp(), crossInfoPO.getPort(), phaseMessage, phaseSign, 300);
+        if (Objects.nonNull(resultPojo) && StringUtils.isNotBlank(resultPojo.getHexMessageResult())) {
+            log.info("下发相位成功");
         }
     }
 

signal-utc-dt-service/src/main/java/net/wanji/com/service/controller/impl/DTSignalStatusServiceImpl.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/controller/impl/DTSignalStatusServiceImpl.java

-package net.wanji.com.service.controller.impl;
+package net.wanji.utc.dt.service.controller.impl;
 
 import cn.hutool.core.util.HexUtil;
-import net.wanji.com.cache.CrossInfoCache;
-import net.wanji.com.cache.SignalDataCache;
-import net.wanji.com.common.constants.Constants;
-import net.wanji.com.common.enums.ControlModelEnum;
-import net.wanji.com.common.enums.ControlTypeEnum;
-import net.wanji.com.common.enums.PhaseLightColorEnum;
-import net.wanji.com.netty.NettyClient;
-import net.wanji.com.pojo.dtconvert.*;
-import net.wanji.com.pojo.netty.MessageResultPojo;
-import net.wanji.com.service.controller.SignalStatusService;
 import net.wanji.common.enums.BaseEnum;
 import net.wanji.databus.po.CrossInfoPO;
 import net.wanji.databus.po.SignalStatusLogPO;
 import net.wanji.databus.vo.LightsStatusVO;
+import net.wanji.utc.dt.cache.CrossInfoCache;
+import net.wanji.utc.dt.cache.SignalDataCache;
+import net.wanji.utc.dt.common.constants.Constants;
+import net.wanji.utc.dt.common.enums.ControlModelEnum;
+import net.wanji.utc.dt.common.enums.ControlTypeEnum;
+import net.wanji.utc.dt.common.enums.PhaseLightColorEnum;
+import net.wanji.utc.dt.netty.NettyClient;
+import net.wanji.utc.dt.pojo.dtconvert.*;
+import net.wanji.utc.dt.pojo.netty.MessageResultPojo;
+import net.wanji.utc.dt.service.controller.SignalStatusService;
+import net.wanji.utc.dt.util.CommonUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
@@ -218,15 +219,17 @@ public class DTSignalStatusServiceImpl implements SignalStatusService {
                         Map<String, Object> dirLampGroupMap = new HashMap<>();
                         if (!CollectionUtils.isEmpty(lightsStatus)) {
                             for (int i = 0; i < lightsStatus.size(); i++) {
+                                Map<Integer, String> turnColorMap = new HashMap<>();
                                 String wjLightColor = PhaseLightColorEnum.getWjLightColor(lightsStatus.get(i));
-                                List<PhaseInfoPojo> phaseInfoPojos = SignalDataCache.phaseInfoCache.get(crossId);
-                                if (!CollectionUtils.isEmpty(phaseInfoPojos)) {
-                                    for (PhaseInfoPojo phaseInfoPojo : phaseInfoPojos) {
-                                        if (Objects.equals(phaseInfoPojo.getLightsId(), i + 1)) {
-                                            Integer phaseId = phaseInfoPojo.getPhaseId();
-                                            dirLampGroupMap.put(String.valueOf(phaseId), wjLightColor);
-                                        }
-                                    }
+                                Integer turn = CommonUtils.getTurnByLightsId(i);
+                                turnColorMap.put(turn, wjLightColor);
+                                String dir = String.valueOf(CommonUtils.getDirByLightsId(i));
+                                if (dirLampGroupMap.isEmpty() || Objects.isNull(dirLampGroupMap.get(dir))) {
+                                    dirLampGroupMap.put(dir, turnColorMap);
+                                } else {
+                                    Map<Integer, String> currentTurnColorMap = (Map<Integer, String>) dirLampGroupMap.get(dir);
+                                    currentTurnColorMap.put(turn, wjLightColor);
+                                    dirLampGroupMap.put(dir, currentTurnColorMap);
                                 }
                             }
                         }

signal-utc-dt-service/src/main/java/net/wanji/com/service/controller/impl/DTStaticInfoServiceImpl.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/controller/impl/DTStaticInfoServiceImpl.java

-package net.wanji.com.service.controller.impl;
+package net.wanji.utc.dt.service.controller.impl;
 
 import cn.hutool.core.util.HexUtil;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import net.wanji.com.cache.CrossInfoCache;
-import net.wanji.com.cache.SignalDataCache;
-import net.wanji.com.common.constants.Constants;
-import net.wanji.com.common.enums.ControlModelEnum;
-import net.wanji.com.netty.NettyClient;
-import net.wanji.com.pojo.dtconvert.*;
-import net.wanji.com.pojo.netty.MessageResultPojo;
-import net.wanji.com.service.controller.StaticInfoService;
 import net.wanji.common.enums.BaseEnum;
 import net.wanji.common.enums.DateStyle;
 import net.wanji.common.utils.tool.DateUtil;
@@ -22,6 +14,14 @@ import net.wanji.databus.dto.SchemePhaseLightsDTO;
 import net.wanji.databus.po.CrossInfoPO;
 import net.wanji.databus.vo.PlanSectionVO;
 import net.wanji.databus.vo.SchemePhaseLightsVO;
+import net.wanji.utc.dt.cache.CrossInfoCache;
+import net.wanji.utc.dt.cache.SignalDataCache;
+import net.wanji.utc.dt.common.constants.Constants;
+import net.wanji.utc.dt.common.enums.ControlModelEnum;
+import net.wanji.utc.dt.netty.NettyClient;
+import net.wanji.utc.dt.pojo.dtconvert.*;
+import net.wanji.utc.dt.pojo.netty.MessageResultPojo;
+import net.wanji.utc.dt.service.controller.StaticInfoService;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
@@ -168,17 +168,24 @@ public class DTStaticInfoServiceImpl implements StaticInfoService {
                 crossPhasePO.setPlanId(schemeId);
                 crossPhasePO.setRingNo(1);
                 crossPhasePO.setGroupNo(1);
-                crossPhasePO.setPhaseTime(phaseStageTime);
                 crossPhasePO.setControlMode(1);
                 crossPhasePO.setPhaseType(1);
-                crossPhasePO.setPhaseTime(phaseStageTime);
                 PhaseInfoPojo phaseInfoPojo = PhaseInfoPojo.getPhaseInfoPojoByPhaseId(phaseId, phaseInfoPojos);
                 if (Objects.nonNull(phaseInfoPojo)) {
-                    crossPhasePO.setGreenTime(phaseInfoPojo.getGreenTime());
+                    int redTime = phaseInfoPojo.getRedTime() - phaseInfoPojo.getGreenFlashTime() - phaseInfoPojo.getGreenTime();
+                    if (phaseStageTime == 0) { // 相位阶段没有对应方案
+                        phaseStageTime = phaseInfoPojo.getGreenTime() + phaseInfoPojo.getGreenFlashTime() + phaseInfoPojo.getYellowTime() + redTime;
+                    }
+                    crossPhasePO.setPhaseTime(phaseStageTime);
+                    int greenTime = phaseStageTime - phaseInfoPojo.getYellowTime() - redTime - phaseInfoPojo.getGreenFlashTime() * 2;
+                    if (greenTime < 0) {
+                        greenTime = phaseInfoPojo.getGreenTime();
+                    }
+                    crossPhasePO.setGreenTime(greenTime);
                     crossPhasePO.setGreenFlashTime(phaseInfoPojo.getGreenFlashTime());
-                    crossPhasePO.setYellowFlashTime(phaseInfoPojo.getYellowFlashTime());
+                    crossPhasePO.setYellowFlashTime(phaseInfoPojo.getYellowFlashTime() * 2);
                     crossPhasePO.setYellowTime(phaseInfoPojo.getYellowTime());
-                    crossPhasePO.setRedTime(phaseInfoPojo.getRedTime());
+                    crossPhasePO.setRedTime(redTime);
                     crossPhasePO.setMinGreenTime(phaseInfoPojo.getMinGreenTime());
                     crossPhasePO.setMaxGreenTime(phaseInfoPojo.getMaxGreenTime());
                 }

signal-utc-dt-service/src/main/java/net/wanji/com/service/protocol/ProtocolConversion.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/protocol/ProtocolConversion.java

-package net.wanji.com.service.protocol;
+package net.wanji.utc.dt.service.protocol;
 
 import net.wanji.databus.po.CrossInfoPO;
 

signal-utc-dt-service/src/main/java/net/wanji/com/service/protocol/impl/base/DailyPlanProtocolConversionService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/protocol/impl/base/DailyPlanProtocolConversionService.java

-package net.wanji.com.service.protocol.impl.base;
+package net.wanji.utc.dt.service.protocol.impl.base;
 
-import net.wanji.com.service.protocol.ProtocolConversion;
+import net.wanji.utc.dt.service.protocol.ProtocolConversion;
 import net.wanji.databus.po.CrossInfoPO;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/service/protocol/impl/base/DetectorProtocolConversionService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/protocol/impl/base/DetectorProtocolConversionService.java

-package net.wanji.com.service.protocol.impl.base;
+package net.wanji.utc.dt.service.protocol.impl.base;
 
-import net.wanji.com.service.protocol.ProtocolConversion;
+import net.wanji.utc.dt.service.protocol.ProtocolConversion;
 import net.wanji.databus.po.CrossInfoPO;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/service/protocol/impl/base/LightsGroupProtocolConvertionService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/protocol/impl/base/LightsGroupProtocolConvertionService.java

-package net.wanji.com.service.protocol.impl.base;
+package net.wanji.utc.dt.service.protocol.impl.base;
 
-import net.wanji.com.service.protocol.ProtocolConversion;
+import net.wanji.utc.dt.service.protocol.ProtocolConversion;
 import net.wanji.databus.po.CrossInfoPO;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/service/protocol/impl/base/PhaseProtocolConversionService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/protocol/impl/base/PhaseProtocolConversionService.java

-package net.wanji.com.service.protocol.impl.base;
+package net.wanji.utc.dt.service.protocol.impl.base;
 
-import net.wanji.com.netty.NettyClient;
-import net.wanji.com.pojo.netty.MessageResultPojo;
-import net.wanji.com.service.protocol.ProtocolConversion;
+import net.wanji.utc.dt.netty.NettyClient;
+import net.wanji.utc.dt.pojo.netty.MessageResultPojo;
+import net.wanji.utc.dt.service.protocol.ProtocolConversion;
 import net.wanji.databus.po.CrossInfoPO;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/service/protocol/impl/base/PhaseSecurityProtocolConversionService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/protocol/impl/base/PhaseSecurityProtocolConversionService.java

-package net.wanji.com.service.protocol.impl.base;
+package net.wanji.utc.dt.service.protocol.impl.base;
 
-import net.wanji.com.service.protocol.ProtocolConversion;
+import net.wanji.utc.dt.service.protocol.ProtocolConversion;
 import net.wanji.databus.po.CrossInfoPO;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/service/protocol/impl/base/ScheduleProtocolConversionService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/protocol/impl/base/ScheduleProtocolConversionService.java

-package net.wanji.com.service.protocol.impl.base;
+package net.wanji.utc.dt.service.protocol.impl.base;
 
-import net.wanji.com.service.protocol.ProtocolConversion;
+import net.wanji.utc.dt.service.protocol.ProtocolConversion;
 import net.wanji.databus.po.CrossInfoPO;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/service/protocol/impl/base/SchemeProtocolConversionService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/protocol/impl/base/SchemeProtocolConversionService.java

-package net.wanji.com.service.protocol.impl.base;
+package net.wanji.utc.dt.service.protocol.impl.base;
 
-import net.wanji.com.service.protocol.ProtocolConversion;
+import net.wanji.utc.dt.service.protocol.ProtocolConversion;
 import net.wanji.databus.po.CrossInfoPO;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/service/protocol/impl/base/SignalDeviceProtocolConversionService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/protocol/impl/base/SignalDeviceProtocolConversionService.java

-package net.wanji.com.service.protocol.impl.base;
+package net.wanji.utc.dt.service.protocol.impl.base;
 
 import lombok.extern.slf4j.Slf4j;
-import net.wanji.com.netty.NettyClient;
-import net.wanji.com.pojo.netty.MessageResultPojo;
-import net.wanji.com.service.protocol.ProtocolConversion;
+import net.wanji.utc.dt.netty.NettyClient;
+import net.wanji.utc.dt.pojo.netty.MessageResultPojo;
+import net.wanji.utc.dt.service.protocol.ProtocolConversion;
 import net.wanji.databus.po.CrossInfoPO;
 import org.springframework.stereotype.Service;
 

signal-utc-dt-service/src/main/java/net/wanji/com/service/protocol/impl/base/StageProtocolConversionService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/protocol/impl/base/StageProtocolConversionService.java

-package net.wanji.com.service.protocol.impl.base;
+package net.wanji.utc.dt.service.protocol.impl.base;
 
-import net.wanji.com.service.protocol.ProtocolConversion;
+import net.wanji.utc.dt.service.protocol.ProtocolConversion;
 import net.wanji.databus.po.CrossInfoPO;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/service/protocol/impl/control/ControlProtocolConversionService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/protocol/impl/control/ControlProtocolConversionService.java

-package net.wanji.com.service.protocol.impl.control;
+package net.wanji.utc.dt.service.protocol.impl.control;
 
-import net.wanji.com.service.protocol.ProtocolConversion;
+import net.wanji.utc.dt.service.protocol.ProtocolConversion;
 import net.wanji.databus.po.CrossInfoPO;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/service/protocol/impl/status/RunningStateProtocolConversionService.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/service/protocol/impl/status/RunningStateProtocolConversionService.java

-package net.wanji.com.service.protocol.impl.status;
+package net.wanji.utc.dt.service.protocol.impl.status;
 
-import net.wanji.com.service.protocol.ProtocolConversion;
+import net.wanji.utc.dt.service.protocol.ProtocolConversion;
 import net.wanji.databus.po.CrossInfoPO;
 
 /**

signal-utc-dt-service/src/main/java/net/wanji/com/util/CRC16Utils.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/util/CRC16Utils.java

-package net.wanji.com.util;
+package net.wanji.utc.dt.util;
 
 import cn.hutool.core.util.HexUtil;
 

signal-utc-dt-service/src/main/java/net/wanji/com/util/CommonUtils.java → signal-utc-dt-service/src/main/java/net/wanji/utc/dt/util/CommonUtils.java

-package net.wanji.com.util;
+package net.wanji.utc.dt.util;
 
 import cn.hutool.core.util.HexUtil;
 import freemarker.template.utility.StringUtil;
@@ -11,6 +11,7 @@ public class CommonUtils {
 
     /**
      * 将数组转化为16进制字符串
+     *
      * @param array
      * @return
      */
@@ -25,6 +26,7 @@ public class CommonUtils {
 
     /**
      * 将时间转化为16进制 00：00 --> 061E0
+     *
      * @param time
      * @return
      */
@@ -36,6 +38,12 @@ public class CommonUtils {
         return sb.append(hour).append(minute).toString();
     }
 
+    /**
+     * 将相位转化为64位数组，在转化为16位的16进制
+     *
+     * @param param
+     * @return
+     */
     public static String getBinary(Integer param) {
         int[] array = new int[64];
         array[param - 1] = 1;
@@ -51,7 +59,69 @@ public class CommonUtils {
         return StringUtil.leftPad(resultSb.toString(), 16, "0");
     }
 
+    /**
+     * 将单个参数转化为4位二进制
+     *
+     * @param param
+     * @return
+     */
+    public static Integer get4BinaryInteger(Integer param) {
+        int[] array = new int[4];
+        int index = param % 4;
+        if (param % 4 != 0) {
+            array[4 - index] = 1;
+        } else {
+            array[0] = 1;
+        }
+        StringBuffer sb = new StringBuffer();
+        for (int j = 0; j < 4; j++) {
+            sb.append(array[j]);
+        }
+        return Integer.parseInt(sb.toString(), 2);
+    }
+
+    /**
+     * 通过灯组编号获取灯组转向， 1 左转 2 直右 3 非机动车 4 行人
+     *
+     * @param lightId
+     * @return
+     */
+    public static Integer getTurnByLightsId(Integer lightId) {
+        Integer turn = null;
+        if (lightId % 4 == 0) {
+            turn = 1;
+        }
+        if (lightId % 4 == 1) {
+            turn = 6;
+        }
+        if (lightId % 4 == 2) {
+            turn = 6;
+        }
+        if (lightId % 4 == 3) {
+            turn = 20;
+        }
+        return turn;
+    }
+
+    public static Integer getDirByLightsId(Integer lightsId) {
+        Integer dir = null;
+        if (lightsId < 4) {
+            dir = 1;
+        }
+        if (lightsId >= 4 && lightsId < 8) {
+            dir = 3;
+        }
+        if (lightsId >= 8 && lightsId < 12) {
+            dir = 5;
+        }
+        if (lightsId >= 12 && lightsId < 16) {
+            dir = 7;
+        }
+        return dir;
+    }
+
+
     public static void main(String[] args) {
-        System.err.println(getBinary(8));
+        System.err.println(get4BinaryInteger(4));
     }
 }

signal-utc-dt-service/src/main/resources/logback-spring.xml

@@ -15,7 +15,7 @@
 
     <!-- 配置打印INFO级别日志的环境 -->
     <springProfile name="prod">
-        <logger name="net.wanji.com" level="info" />
+        <logger name="net.wanji.utc.dt" level="info" />
     </springProfile>
 
     <appender name="consoleLog" class="ch.qos.logback.core.ConsoleAppender">