Showing
5 changed files
with
10 additions
and
0 deletions
... | ... | @@ -27,6 +27,7 @@ import org.thingsboard.server.common.data.yunteng.utils.i18n.MessageUtils; |
27 | 27 | import org.thingsboard.server.common.data.yunteng.utils.tools.TkPageData; |
28 | 28 | import org.thingsboard.server.controller.BaseController; |
29 | 29 | import org.thingsboard.server.dao.yunteng.service.Tk3dComponentService; |
30 | +import org.thingsboard.server.queue.util.TbCoreComponent; | |
30 | 31 | |
31 | 32 | import javax.annotation.Resource; |
32 | 33 | import java.io.File; |
... | ... | @@ -47,6 +48,7 @@ import static org.thingsboard.server.common.data.yunteng.constant.QueryConstant. |
47 | 48 | * @since 2024-10-14 |
48 | 49 | */ |
49 | 50 | @RestController |
51 | +@TbCoreComponent | |
50 | 52 | @RequestMapping("api/yt/3d_component") |
51 | 53 | @Api(tags = {"3D模型管理"}) |
52 | 54 | @PreAuthorize("hasAnyAuthority('TENANT_ADMIN', 'CUSTOMER_USER')") | ... | ... |
... | ... | @@ -12,6 +12,7 @@ import org.thingsboard.server.common.data.yunteng.id.EntityIdProvider; |
12 | 12 | import org.thingsboard.server.common.data.yunteng.id.TkConfigurationCenterId; |
13 | 13 | import org.thingsboard.server.common.data.yunteng.sync.TkConfigurationCenter; |
14 | 14 | import org.thingsboard.server.gen.edge.v1.TkUpdateMsg; |
15 | +import org.thingsboard.server.queue.util.TbCoreComponent; | |
15 | 16 | import org.thingsboard.server.service.edge.rpc.yunteng.TkEdgeProcessor; |
16 | 17 | import org.thingsboard.server.service.edge.rpc.yunteng.TkEdgeProcessorRepository; |
17 | 18 | |
... | ... | @@ -19,6 +20,7 @@ import java.util.UUID; |
19 | 20 | |
20 | 21 | @Slf4j |
21 | 22 | @Component |
23 | +@TbCoreComponent | |
22 | 24 | @AllArgsConstructor |
23 | 25 | public class TkConfigurationCenterEdgeProcessor extends TkEdgeProcessor<TkConfigurationCenterId, TkConfigurationCenter> { |
24 | 26 | ... | ... |
... | ... | @@ -12,6 +12,7 @@ import org.thingsboard.server.common.data.yunteng.id.EntityIdProvider; |
12 | 12 | import org.thingsboard.server.common.data.yunteng.id.TkConfigurationContentId; |
13 | 13 | import org.thingsboard.server.common.data.yunteng.sync.TkConfigurationContent; |
14 | 14 | import org.thingsboard.server.gen.edge.v1.TkUpdateMsg; |
15 | +import org.thingsboard.server.queue.util.TbCoreComponent; | |
15 | 16 | import org.thingsboard.server.service.edge.rpc.yunteng.TkEdgeProcessor; |
16 | 17 | import org.thingsboard.server.service.edge.rpc.yunteng.TkEdgeProcessorRepository; |
17 | 18 | |
... | ... | @@ -19,6 +20,7 @@ import java.util.UUID; |
19 | 20 | |
20 | 21 | @Slf4j |
21 | 22 | @Component |
23 | +@TbCoreComponent | |
22 | 24 | @AllArgsConstructor |
23 | 25 | public class TkConfigurationContentEdgeProcessor extends TkEdgeProcessor<TkConfigurationContentId, TkConfigurationContent> { |
24 | 26 | ... | ... |
... | ... | @@ -12,6 +12,7 @@ import org.thingsboard.server.common.data.yunteng.id.EntityIdProvider; |
12 | 12 | import org.thingsboard.server.common.data.yunteng.id.TkConfigurationContentNodeId; |
13 | 13 | import org.thingsboard.server.common.data.yunteng.sync.TkConfigurationContentNode; |
14 | 14 | import org.thingsboard.server.gen.edge.v1.TkUpdateMsg; |
15 | +import org.thingsboard.server.queue.util.TbCoreComponent; | |
15 | 16 | import org.thingsboard.server.service.edge.rpc.yunteng.TkEdgeProcessor; |
16 | 17 | import org.thingsboard.server.service.edge.rpc.yunteng.TkEdgeProcessorRepository; |
17 | 18 | |
... | ... | @@ -19,6 +20,7 @@ import java.util.UUID; |
19 | 20 | |
20 | 21 | @Slf4j |
21 | 22 | @Component |
23 | +@TbCoreComponent | |
22 | 24 | @AllArgsConstructor |
23 | 25 | public class TkConfigurationContentNodeEdgeProcessor extends TkEdgeProcessor<TkConfigurationContentNodeId, TkConfigurationContentNode> { |
24 | 26 | ... | ... |
... | ... | @@ -16,6 +16,7 @@ import org.thingsboard.server.dao.yunteng.entities.TkDeviceProfileCategoryEntity |
16 | 16 | import org.thingsboard.server.dao.yunteng.jpa.entity.events.TkEventKvCompositeKey; |
17 | 17 | import org.thingsboard.server.dao.yunteng.jpa.entity.events.TkEventKvEntity; |
18 | 18 | import org.thingsboard.server.dao.yunteng.jpa.repository.event.EventKvRepository; |
19 | +import org.thingsboard.server.queue.util.TbCoreComponent; | |
19 | 20 | import org.thingsboard.server.service.edge.rpc.yunteng.TkEdgeProcessorRepository; |
20 | 21 | import org.thingsboard.server.service.state.DeviceStateService; |
21 | 22 | |
... | ... | @@ -23,6 +24,7 @@ import java.util.List; |
23 | 24 | import java.util.Optional; |
24 | 25 | |
25 | 26 | @Repository |
27 | +@TbCoreComponent | |
26 | 28 | @AllArgsConstructor |
27 | 29 | public class TkEventKvRepository implements TkEdgeProcessorRepository<TkEventKv> { |
28 | 30 | ... | ... |