| | |
| | | import com.qianwen.core.tool.utils.DateUtil; |
| | | import com.qianwen.core.tool.utils.Func; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/common/utils/TimeUtils.class */ |
| | | public final class TimeUtils { |
| | | private TimeUtils() { |
| | | throw new UnsupportedOperationException("This is a utility class and cannot be instantiated"); |
| | |
| | | |
| | | @RocketMQMessageListener(topic = "telemetry-data", consumerGroup = "telemetry-data-real-time-consumer", consumeMode = ConsumeMode.ORDERLY) |
| | | @Component |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/message/consumer/TelemetryDataRealTimeConsumer.class */ |
| | | public class TelemetryDataRealTimeConsumer implements RocketMQListener<TelemetryDataMessage>, RocketMQPushConsumerLifecycleListener { |
| | | private static final Logger log = LoggerFactory.getLogger(TelemetryDataRealTimeConsumer.class); |
| | | |
| | |
| | | package com.qianwen.smartman.modules.cps.message.dto; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/message/dto/AlarmInfoDTO.class */ |
| | | public class AlarmInfoDTO { |
| | | private String code; |
| | | private String msg; |
| | |
| | | |
| | | import java.io.Serializable; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/message/dto/TelemetryDataResponseDTO.class */ |
| | | public class TelemetryDataResponseDTO implements Serializable { |
| | | private String v; |
| | | private Long t; |
| | |
| | | package com.qianwen.smartman.modules.cps.message.event; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/message/event/TelemetryDataMessage.class */ |
| | | public class TelemetryDataMessage { |
| | | private String machineId; |
| | | private String name; |
| | |
| | | import java.util.Map; |
| | | import javax.validation.constraints.Email; |
| | | import javax.validation.constraints.NotBlank; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/vo/InitSettingVO.class */ |
| | | /** |
| | | * 系统初始化vo(在前端init界面提交的配置数据) |
| | | */ |
| | | public class InitSettingVO implements Serializable { |
| | | private static final long serialVersionUID = 6115052904161316657L; |
| | | @NotBlank(message = "账号不能为空") |
| | |
| | | import com.qianwen.core.tool.utils.Func; |
| | | import com.qianwen.smartman.modules.resource.enums.TemplateEnum; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/enums/BusinessTypeEnums.class */ |
| | | public enum BusinessTypeEnums { |
| | | PLAN_ORDER(1, "计划工单", TemplateEnum.PLAN), |
| | | PRODUCT(2, "产品", TemplateEnum.PRODUCT); |
| | |
| | | |
| | | import com.qianwen.smartman.common.constant.ExcelConstant; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/enums/ConfigTypeEnum.class */ |
| | | public enum ConfigTypeEnum { |
| | | NEW_PAGE(1, "新建页"), |
| | | EDIT_PAGE(2, "编辑页"), |
| | |
| | | package com.qianwen.smartman.modules.system.enums; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/enums/CustomFieldTypeEnums.class */ |
| | | public enum CustomFieldTypeEnums { |
| | | INPUT(1, "输入框"), |
| | | DIGITAL_INPUT(2, "数字输入框"), |
| | |
| | | |
| | | import java.util.Objects; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/enums/ImportSpecialHandlingEnum.class */ |
| | | public enum ImportSpecialHandlingEnum { |
| | | PRODUCT_CODE("productId", "产品", "产品编号", 1); |
| | | |
| | |
| | | package com.qianwen.smartman.modules.system.enums; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/enums/ParamKeyEnum.class */ |
| | | public enum ParamKeyEnum { |
| | | Theme("system.theme"); |
| | | |
| | |
| | | |
| | | import com.qianwen.smartman.common.constant.CommonGroupConstant; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/enums/ThemeEnums.class */ |
| | | public enum ThemeEnums { |
| | | DEFAULT(0, CommonGroupConstant.DEFAULT_NAME), |
| | | BLUE(1, "深海蓝"); |
| | |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | @Component |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/init/FmsInitBean.class */ |
| | | public class FmsInitBean implements CommandLineRunner { |
| | | private static final Logger log = LoggerFactory.getLogger(FmsInitBean.class); |
| | | private final IParamService paramService; |
| | |
| | | import com.qianwen.smartman.modules.system.entity.ApiScope; |
| | | import com.qianwen.smartman.modules.system.vo.ApiScopeVO; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/wrapper/ApiScopeWrapper.class */ |
| | | public class ApiScopeWrapper extends BaseEntityWrapper<ApiScope, ApiScopeVO> { |
| | | public static ApiScopeWrapper build() { |
| | | return new ApiScopeWrapper(); |
| | |
| | | import com.qianwen.smartman.modules.system.entity.DataScope; |
| | | import com.qianwen.smartman.modules.system.vo.DataScopeVO; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/wrapper/DataScopeWrapper.class */ |
| | | public class DataScopeWrapper extends BaseEntityWrapper<DataScope, DataScopeVO> { |
| | | public static DataScopeWrapper build() { |
| | | return new DataScopeWrapper(); |
| | |
| | | import com.qianwen.smartman.modules.system.entity.Dept; |
| | | import com.qianwen.smartman.modules.system.vo.DeptVO; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/wrapper/DeptWrapper.class */ |
| | | public class DeptWrapper extends BaseEntityWrapper<Dept, DeptVO> { |
| | | public static DeptWrapper build() { |
| | | return new DeptWrapper(); |
| | |
| | | } |
| | | |
| | | public List<DeptVO> listNodeVO(List<Dept> list) { |
| | | List<DeptVO> collect = (List) list.stream().map(dept -> { |
| | | List<DeptVO> collect = list.stream().map(dept -> { |
| | | DeptVO deptVO = (DeptVO) BeanUtil.copy(dept, DeptVO.class); |
| | | String category = DictCache.getValue(DictEnum.DATA_SCOPE_CATEGORY, dept.getDeptCategory()); |
| | | ((DeptVO) Objects.requireNonNull(deptVO)).setDeptCategoryName(category); |
| | |
| | | } |
| | | |
| | | public List<DeptVO> listNodeLazyVO(List<DeptVO> list) { |
| | | List<DeptVO> collect = (List) list.stream().peek(dept -> { |
| | | List<DeptVO> collect = list.stream().peek(dept -> { |
| | | String category = DictCache.getValue(DictEnum.DATA_SCOPE_CATEGORY, dept.getDeptCategory()); |
| | | ((DeptVO) Objects.requireNonNull(dept)).setDeptCategoryName(category); |
| | | }).collect(Collectors.toList()); |
| | |
| | | import com.qianwen.smartman.modules.system.entity.DictBiz; |
| | | import com.qianwen.smartman.modules.system.vo.DictBizVO; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/wrapper/DictBizWrapper.class */ |
| | | public class DictBizWrapper extends BaseEntityWrapper<DictBiz, DictBizVO> { |
| | | public static DictBizWrapper build() { |
| | | return new DictBizWrapper(); |
| | |
| | | } |
| | | |
| | | public List<DictBizVO> listNodeVO(List<DictBiz> list) { |
| | | List<DictBizVO> collect = (List) list.stream().map(dict -> { |
| | | return (DictBizVO) BeanUtil.copy(dict, DictBizVO.class); |
| | | List<DictBizVO> collect = list.stream().map(dict -> { |
| | | return BeanUtil.copy(dict, DictBizVO.class); |
| | | }).collect(Collectors.toList()); |
| | | return ForestNodeMerger.merge(collect); |
| | | } |
| | |
| | | import com.qianwen.smartman.modules.system.entity.Dict; |
| | | import com.qianwen.smartman.modules.system.vo.DictVO; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/wrapper/DictWrapper.class */ |
| | | public class DictWrapper extends BaseEntityWrapper<Dict, DictVO> { |
| | | public static DictWrapper build() { |
| | | return new DictWrapper(); |
| | |
| | | import com.qianwen.smartman.modules.system.entity.Menu; |
| | | import com.qianwen.smartman.modules.system.vo.MenuVO; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/wrapper/MenuWrapper.class */ |
| | | public class MenuWrapper extends BaseEntityWrapper<Menu, MenuVO> { |
| | | public static MenuWrapper build() { |
| | | return new MenuWrapper(); |
| | |
| | | import com.qianwen.smartman.modules.system.entity.MetaObjectTypeField; |
| | | import com.qianwen.smartman.modules.system.vo.MetaObjectTypeFieldVO; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/wrapper/MetaObjectTypeFieldWrapper.class */ |
| | | public class MetaObjectTypeFieldWrapper extends BaseEntityWrapper<MetaObjectTypeField, MetaObjectTypeFieldVO> { |
| | | public static MetaObjectTypeFieldWrapper build() { |
| | | return new MetaObjectTypeFieldWrapper(); |
| | |
| | | import com.qianwen.smartman.modules.system.entity.Post; |
| | | import com.qianwen.smartman.modules.system.vo.PostVO; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/wrapper/PostWrapper.class */ |
| | | public class PostWrapper extends BaseEntityWrapper<Post, PostVO> { |
| | | public static PostWrapper build() { |
| | | return new PostWrapper(); |
| | |
| | | import com.qianwen.smartman.modules.system.entity.Region; |
| | | import com.qianwen.smartman.modules.system.vo.RegionVO; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/wrapper/RegionWrapper.class */ |
| | | public class RegionWrapper extends BaseEntityWrapper<Region, RegionVO> { |
| | | public static RegionWrapper build() { |
| | | return new RegionWrapper(); |
| | |
| | | import com.qianwen.smartman.modules.system.entity.Role; |
| | | import com.qianwen.smartman.modules.system.vo.RoleVO; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/wrapper/RoleWrapper.class */ |
| | | public class RoleWrapper extends BaseEntityWrapper<Role, RoleVO> { |
| | | public static RoleWrapper build() { |
| | | return new RoleWrapper(); |
| | |
| | | import com.qianwen.smartman.modules.system.entity.User; |
| | | import com.qianwen.smartman.modules.system.vo.UserVO; |
| | | |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/wrapper/UserWrapper.class */ |
| | | public class UserWrapper extends BaseEntityWrapper<User, UserVO> { |
| | | public static UserWrapper build() { |
| | | return new UserWrapper(); |
| | |
| | | # tdengine |
| | | tdengine: |
| | | driver: com.taosdata.jdbc.rs.RestfulDriver |
| | | url: jdbc:TAOS-RS://192.168.1.41:6041/iot_data?charset=UTF-8&locale=en_US.UTF-8&timezone=UTC-8 |
| | | #url: jdbc:TAOS-RS://192.168.1.41:6041/iot_data?charset=UTF-8&locale=en_US.UTF-8&timezone=UTC-8 |
| | | url: jdbc:TAOS-RS://localhost:6041/iot_data?charset=UTF-8&locale=en_US.UTF-8&timezone=UTC-8 |
| | | username: root |
| | | password: taosdata |
| | | |