添加场站列表

yudao-framework/yudao-common/pom.xml

@@ -144,6 +144,45 @@
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
         </dependency>
+
+    <dependency>
+        <groupId>org.junit</groupId>
+        <artifactId>junit-bom</artifactId>
+        <version>5.10.2</version>
+        <type>pom</type>
+        <scope>import</scope>
+    </dependency>
+
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter</artifactId>
+            <version>5.10.2</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.assertj</groupId>
+            <artifactId>assertj-core</artifactId>
+            <version>3.26.0</version>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <version>5.10.2</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.14.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-collections4</artifactId>
+            <version>4.5.0-M1</version>
+        </dependency>
+
     </dependencies>
 
 </project>

yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/controller/admin/db/ProBasicPowerstationController.java

@@ -0,0 +1,40 @@
+package cn.iocoder.yudao.module.infra.controller.admin.db;
+
+import cn.iocoder.yudao.framework.common.pojo.CommonResult;
+import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
+import cn.iocoder.yudao.module.infra.controller.admin.db.vo.DataSourceConfigRespVO;
+import cn.iocoder.yudao.module.infra.controller.admin.db.vo.DataSourceConfigSaveReqVO;
+import cn.iocoder.yudao.module.infra.dal.dataobject.db.DataSourceConfigDO;
+import cn.iocoder.yudao.module.infra.dal.dataobject.db.ProBasicPowerstationDO;
+import cn.iocoder.yudao.module.infra.service.db.DataSourceConfigService;
+import cn.iocoder.yudao.module.infra.service.db.ProBasicPowerstationService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.annotation.Resource;
+import jakarta.validation.Valid;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
+
+@Tag(name = "管理后台 - 场站列表")
+@RestController
+@RequestMapping("/terminal")
+@Validated
+public class ProBasicPowerstationController {
+
+    @Resource
+    private ProBasicPowerstationService proBasicPowerstationService;
+
+
+    @GetMapping("/getYardStationData")
+    @Operation(summary = "获得场站列表")
+    public CommonResult<List<ProBasicPowerstationDO>> getYardStationData() {
+        List<ProBasicPowerstationDO> list = proBasicPowerstationService.getYardStationData();
+        return success(BeanUtils.toBean(list, ProBasicPowerstationDO.class));
+    }
+}

yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/dal/dataobject/db/ProBasicEquipmentPointDO.java

@@ -0,0 +1,144 @@
+package cn.iocoder.yudao.module.infra.dal.dataobject.db;
+
+
+import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.KeySequence;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 设备测点
+ * </p>
+ *
+ * @author shilin
+ * @since 2022-10-31
+ */
+@TableName(value = "pro_basic_equipment", autoResultMap = true)
+@Data
+public class ProBasicEquipmentPointDO  {
+
+
+
+    /**
+     * 编号
+     */
+    @TableId(value = "ID",type = IdType.ASSIGN_ID)
+    private String id;
+
+    /**
+     * 编码
+     */
+    private String nemCode;
+
+    /**
+     * 名称
+     */
+    private String name;
+
+    /**
+     * 实时库名称
+     */
+    private String aname;
+
+    /**
+     * 型号
+     */
+    private String model;
+
+    /**
+     * 单位
+     */
+    private String valueUnit;
+
+    /**
+     * 英文名称
+     */
+    private String englishName;
+
+    /**
+     * 类型编号
+     */
+    private String typeId;
+
+    /**
+     * 所属型号
+     */
+    private String modelId;
+
+    /**
+     * 最大值
+     */
+    private Double maxval;
+
+    /**
+     * 最小值
+     */
+    private Double minval;
+
+    /**
+     * 合理最大值
+     */
+    private Double reasonableMaxval;
+
+    /**
+     * 合理最小值
+     */
+    private Double reasonableMinval;
+
+    /**
+     * 风机编号
+     */
+    private String windturbineId;
+
+    /**
+     * 统一编码
+     */
+    private String uniformCode;
+
+    /**
+     * 短ID
+     */
+    private String shortId;
+
+    /**
+     * 长ID
+     */
+    private String longId;
+
+    /**
+     * 场站编号
+     */
+    private String windpowerstationId;
+
+    /**
+     * 实时配置编号
+     */
+    private String realtimeId;
+
+    /**
+     * 部件编号
+     */
+    private String logicalUnitId;
+
+    /**
+     * 集团测点编号
+     */
+    private String groupPointId;
+
+    /**
+     * 具体名称
+     */
+    private String specificName;
+
+    /**
+     * 系数
+     */
+    private Double coefficient;
+
+
+}

yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/dal/dataobject/db/ProBasicLineDO.java

@@ -0,0 +1,98 @@
+package cn.iocoder.yudao.module.infra.dal.dataobject.db;
+
+
+import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 集电线路
+ * </p>
+ *
+ * @author shilin
+ * @since 2022-10-31
+ */
+@TableName(value = "pro_basic_line", autoResultMap = true)
+@Data
+public class ProBasicLineDO  {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 编号
+     */
+    @TableId(value = "ID",type = IdType.ASSIGN_ID)
+    private String id;
+
+    /**
+     * 编码
+     */
+    private String nemCode;
+
+    /**
+     * 名称
+     */
+    private String name;
+
+    /**
+     * 别名
+     */
+    private String aname;
+
+    /**
+     * 工程编号
+     */
+    private String projectId;
+
+    /**
+     * 顺序
+     */
+    private Integer orderNum;
+
+    /**
+     * 装机容量
+     */
+    private Double capacity;
+
+    /**
+     * 容量单位
+     */
+    private String capacityUnit;
+
+    /**
+     * 装机数量
+     */
+    private Integer quantity;
+
+    /**
+     * 是否可用
+     */
+    private Integer isAble;
+
+    /**
+     * 备用1
+     */
+    private String spare1;
+
+    /**
+     * 备用2
+     */
+    private String spare2;
+
+    /**
+     * 备用3
+     */
+    private String spare3;
+
+    /**
+     * 备用4
+     */
+    private String spare4;
+
+
+}

yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/dal/dataobject/db/ProBasicPowerstationDO.java

@@ -0,0 +1,200 @@
+package cn.iocoder.yudao.module.infra.dal.dataobject.db;
+
+
+import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+/**
+ * <p>
+ * 场站表
+ * </p>
+ *
+ * @author shilin
+ * @since 2022-10-31
+ */
+@TableName(value = "pro_basic_powerstation", autoResultMap = true)
+@Data
+public class ProBasicPowerstationDO  {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 编号
+     */
+    @TableId(value = "ID",type = IdType.ASSIGN_ID)
+    private String id;
+
+    /**
+     * 编码
+     */
+    private String nemCode;
+
+    /**
+     * 名称
+     */
+    private String name;
+
+    /**
+     * 地址
+     */
+    private String address;
+
+    /**
+     * 电话
+     */
+    private String telephone;
+
+    private Double windCapacity;
+
+    private String windCapacityUnit;
+
+    private Integer windQuantityHs;
+
+    private Integer windQuantityLd;
+
+    private Double capacity;
+
+    private String capacityUnit;
+
+    private Integer quantityJz;
+
+    private Integer quantityZc;
+
+    private Double jrwindCapacity;
+
+    private String jrwindCapacityUnit;
+
+    private Integer jrwindQuantityHs;
+
+    private Integer jrwindQuantityLd;
+
+    private Double jrCapacity;
+
+    private String jrCapacityUnit;
+
+    private Integer jrquantityJz;
+
+    private Integer jrquantityZc;
+
+
+    /**
+     * 别名
+     */
+    private String aname;
+
+    /**
+     * 地球经度
+     */
+    private Double longitude;
+
+    /**
+     * 地球纬度
+     */
+    private Double latitude;
+
+    /**
+     * 图片
+     */
+    private String photo;
+
+    /**
+     * 系统厂家
+     */
+    private String systemManufact;
+
+    /**
+     * 场长
+     */
+    private String headfarm;
+
+    /**
+     * 场长电话
+     */
+    private String headfarmPhone;
+
+    /**
+     * 机型
+     */
+    private String model;
+
+    /**
+     * 顺序
+     */
+    private Integer orderNum;
+
+    /**
+     * 海拔高度
+     */
+    private Double height;
+
+    /**
+     * 场站类型
+     */
+    private String windType;
+
+    /**
+     * 公司编号
+     */
+    private String companyId;
+
+    /**
+     * 区域编号
+     */
+    private String regionId;
+
+    /**
+     * 集团编号
+     */
+    private String groupId;
+
+    /**
+     * 是否可用
+     */
+    private Integer isAble;
+
+    /**
+     * 备用1
+     */
+    private String spare1;
+
+    /**
+     * 备用2
+     */
+    private String spare2;
+
+    /**
+     * 备用3
+     */
+    private String spare3;
+
+    /**
+     * 备用4
+     */
+    private String spare4;
+
+    private Double appCapacity;
+    private Double conCapacity;
+    private Double gridCapacity;
+    private Double hoiCapacity;
+    private Date firstGridTime;
+    private Date wholeGridTime;
+    private Double anemoNumber;
+    private Double stationNumber;
+
+
+
+
+
+
+
+
+
+
+}

yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/dal/dataobject/db/ProBasicProjectDO.java

@@ -0,0 +1,130 @@
+package cn.iocoder.yudao.module.infra.dal.dataobject.db;
+
+
+import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+/**
+ * <p>
+ * 工程表
+ * </p>
+ *
+ * @author shilin
+ * @since 2022-10-31
+ */
+@TableName(value = "pro_basic_project", autoResultMap = true)
+@Data
+public class ProBasicProjectDO {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 编号
+     */
+    @TableId(value = "ID",type = IdType.ASSIGN_ID)
+    private String id;
+
+    /**
+     * 编码
+     */
+    private String nemCode;
+
+    /**
+     * 名称
+     */
+    private String name;
+
+    /**
+     * 别名
+     */
+    private String aname;
+
+    /**
+     * 风场编号
+     */
+    private String windpowerstationId;
+
+    /**
+     * 装机容量
+     */
+    private Double capacity;
+
+    /**
+     * 容量单位
+     */
+    private String capacityUnit;
+
+    /**
+     * 装机数量
+     */
+    private Integer quantity;
+
+    /**
+     * 机型
+     */
+    private String model;
+
+    /**
+     * 投产日期
+     */
+    private Date commissionDate;
+
+    /**
+     * 主控电话
+     */
+    private String masterPhone;
+
+    /**
+     * 值长
+     */
+    private String shiftforeMan;
+
+    /**
+     * 值长电话
+     */
+    private String shiftforeManPhone;
+
+    /**
+     * 顺序
+     */
+    private Integer orderNum;
+
+    /**
+     * 变电所ID
+     */
+    private String windsubStationId;
+
+    /**
+     * 是否可用
+     */
+    private Integer isAble;
+
+    /**
+     * 备用1
+     */
+    private String spare1;
+
+    /**
+     * 备用2
+     */
+    private String spare2;
+
+    /**
+     * 备用3
+     */
+    private String spare3;
+
+    /**
+     * 备用4
+     */
+    private String spare4;
+
+
+}

yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/dal/mysql/db/ProBasicEquipmentPointMapper.java

@@ -0,0 +1,11 @@
+package cn.iocoder.yudao.module.infra.dal.mysql.db;
+
+import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
+import cn.iocoder.yudao.module.infra.dal.dataobject.db.DataSourceConfigDO;
+import cn.iocoder.yudao.module.infra.dal.dataobject.db.ProBasicEquipmentPointDO;
+import org.apache.ibatis.annotations.Mapper;
+
+
+@Mapper
+public interface ProBasicEquipmentPointMapper extends BaseMapperX<ProBasicEquipmentPointDO> {
+}

yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/dal/mysql/db/ProBasicLineMapper.java

@@ -0,0 +1,11 @@
+package cn.iocoder.yudao.module.infra.dal.mysql.db;
+
+import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
+import cn.iocoder.yudao.module.infra.dal.dataobject.db.ProBasicEquipmentPointDO;
+import cn.iocoder.yudao.module.infra.dal.dataobject.db.ProBasicLineDO;
+import org.apache.ibatis.annotations.Mapper;
+
+
+@Mapper
+public interface ProBasicLineMapper extends BaseMapperX<ProBasicLineDO> {
+}

yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/dal/mysql/db/ProBasicPowerstationMapper.java

@@ -0,0 +1,15 @@
+package cn.iocoder.yudao.module.infra.dal.mysql.db;
+
+import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
+import cn.iocoder.yudao.module.infra.dal.dataobject.db.DataSourceConfigDO;
+import cn.iocoder.yudao.module.infra.dal.dataobject.db.ProBasicPowerstationDO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 数据源配置 Mapper
+ *
+ * @author 芋道源码
+ */
+@Mapper
+public interface ProBasicPowerstationMapper extends BaseMapperX<ProBasicPowerstationDO> {
+}

yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/dal/mysql/db/ProBasicProjectMapper.java

@@ -0,0 +1,14 @@
+package cn.iocoder.yudao.module.infra.dal.mysql.db;
+
+import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
+import cn.iocoder.yudao.module.infra.dal.dataobject.db.DataSourceConfigDO;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 数据源配置 Mapper
+ *
+ * @author 芋道源码
+ */
+@Mapper
+public interface ProBasicProjectMapper extends BaseMapperX<DataSourceConfigDO> {
+}

yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/service/db/ProBasicPowerstationDOServiceImpl.java

@@ -0,0 +1,39 @@
+package cn.iocoder.yudao.module.infra.service.db;
+
+import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
+import cn.iocoder.yudao.framework.mybatis.core.util.JdbcUtils;
+import cn.iocoder.yudao.module.infra.controller.admin.db.vo.DataSourceConfigSaveReqVO;
+import cn.iocoder.yudao.module.infra.dal.dataobject.db.DataSourceConfigDO;
+import cn.iocoder.yudao.module.infra.dal.dataobject.db.ProBasicPowerstationDO;
+import cn.iocoder.yudao.module.infra.dal.mysql.db.DataSourceConfigMapper;
+import cn.iocoder.yudao.module.infra.dal.mysql.db.ProBasicPowerstationMapper;
+import com.baomidou.dynamic.datasource.creator.DataSourceProperty;
+import com.baomidou.dynamic.datasource.spring.boot.autoconfigure.DynamicDataSourceProperties;
+import jakarta.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.validation.annotation.Validated;
+
+import java.util.List;
+import java.util.Objects;
+
+import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.iocoder.yudao.module.infra.enums.ErrorCodeConstants.DATA_SOURCE_CONFIG_NOT_EXISTS;
+import static cn.iocoder.yudao.module.infra.enums.ErrorCodeConstants.DATA_SOURCE_CONFIG_NOT_OK;
+
+
+@Service
+@Validated
+public class ProBasicPowerstationDOServiceImpl implements ProBasicPowerstationService {
+
+    @Resource
+    private ProBasicPowerstationMapper ProBasicPowerstationMapper;
+
+    @Override
+    public  List<ProBasicPowerstationDO> getYardStationData() {
+        List<ProBasicPowerstationDO>  ls= ProBasicPowerstationMapper.selectList();
+        return ls;
+    }
+
+
+
+}

yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/service/db/ProBasicPowerstationService.java

@@ -0,0 +1,18 @@
+package cn.iocoder.yudao.module.infra.service.db;
+
+import cn.iocoder.yudao.module.infra.controller.admin.db.vo.DataSourceConfigSaveReqVO;
+import cn.iocoder.yudao.module.infra.dal.dataobject.db.DataSourceConfigDO;
+import cn.iocoder.yudao.module.infra.dal.dataobject.db.ProBasicPowerstationDO;
+import jakarta.validation.Valid;
+
+import java.util.List;
+
+
+public interface ProBasicPowerstationService {
+
+
+    List<ProBasicPowerstationDO> getYardStationData();
+
+
+
+}

yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/auth/AdminAuthServiceImpl.java

@@ -3,6 +3,7 @@ package cn.iocoder.yudao.module.system.service.auth;
 import cn.hutool.core.util.ObjectUtil;
 import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
 import cn.iocoder.yudao.framework.common.enums.UserTypeEnum;
+import cn.iocoder.yudao.framework.common.thealgorithms.conversions.AnyBaseToDecimal;
 import cn.iocoder.yudao.framework.common.util.monitor.TracerUtils;
 import cn.iocoder.yudao.framework.common.util.servlet.ServletUtils;
 import cn.iocoder.yudao.framework.common.util.validation.ValidationUtils;
@@ -89,6 +90,8 @@ public class AdminAuthServiceImpl implements AdminAuthService {
             createLoginLog(user.getId(), username, logTypeEnum, LoginResultEnum.USER_DISABLED);
             throw exception(AUTH_LOGIN_USER_DISABLED);
         }
+
+
         return user;
     }
 

yudao-server/src/main/resources/application.yaml

@@ -154,6 +154,7 @@ yudao:
   security:
     permit-all_urls:
       - /admin-api/mp/open/** # 微信公众号开放平台，微信回调接口，不需要登录
+      - /admin-api/terminal/getYardStationData
   websocket:
     enable: true # websocket的开关
     path: /infra/ws # 路径