zzkj/smart_storage_java
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

电站远程控制

Browse Source
This commit is contained in:
root
2025-12-03 17:00:26 +08:00
parent 861155b2e5
commit 219caadd45
6 changed files with 241 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
business-service-api/src/main/java/com/ho/business/entity/StationRemoteControl.java Normal file
View File

@ -0,0 +1,42 @@
package com.ho.business.entity;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.ho.common.tools.constant.CommonConstant;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
@Data
public class StationRemoteControl implements Serializable {
@ApiModelProperty(value = "id")
private Integer id;
@ApiModelProperty(value = "电站id")
private Integer stationId;
@ApiModelProperty(value = "远程访问ip、也可以是域名")
private String ip;
@ApiModelProperty(value = "端口")
private String port;
@ApiModelProperty(value = "账号")
private String userName;
@ApiModelProperty(value = "密码")
private String password;
@ApiModelProperty(value = "内网ip")
private String intranetIp;
@JsonFormat(pattern = CommonConstant.DATE)
@ApiModelProperty(value = "创建时间")
private Date createTime;
@JsonFormat(pattern = CommonConstant.DATE)
@ApiModelProperty(value = "修改时间")
private Date updateTime;
}

16
business-service-dao/src/main/java/com/ho/business/mapper/StationRemoteControlMapper.java Normal file
View File

@ -0,0 +1,16 @@
package com.ho.business.mapper;
import com.ho.business.entity.StationRemoteControl;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@Mapper
public interface StationRemoteControlMapper {
void insert(@Param("entity") StationRemoteControl entity);
void update(@Param("entity") StationRemoteControl entity);
void delete(@Param("id") Integer id);
StationRemoteControl search(@Param("stationId") Integer stationId);
}

13
business-service-dao/src/main/java/com/ho/business/service/StationRemoteControlService.java Normal file
View File

@ -0,0 +1,13 @@
package com.ho.business.service;
import com.ho.business.entity.StationRemoteControl;
public interface StationRemoteControlService {
void insert(StationRemoteControl entity);
void update(StationRemoteControl entity);
void delete(Integer id);
StationRemoteControl search(Integer stationId);
}

36
business-service-dao/src/main/java/com/ho/business/service/impl/StationRemoteControlServiceImpl.java Normal file
View File

@ -0,0 +1,36 @@
package com.ho.business.service.impl;
import com.ho.business.entity.StationRemoteControl;
import com.ho.business.mapper.StationRemoteControlMapper;
import com.ho.business.service.StationRemoteControlService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
@Slf4j
public class StationRemoteControlServiceImpl implements StationRemoteControlService {
@Autowired
StationRemoteControlMapper stationRemoteControlMapper;
@Override
public void insert(StationRemoteControl entity) {
stationRemoteControlMapper.insert(entity);
}
@Override
public void update(StationRemoteControl entity) {
stationRemoteControlMapper.update(entity);
}
@Override
public void delete(Integer id) {
stationRemoteControlMapper.delete(id);
}
@Override
public StationRemoteControl search(Integer stationId) {
return stationRemoteControlMapper.search(stationId);
}
}

64
business-service-dao/src/main/resources/mapper/StationRemoteControlMapper.xml Normal file
View File

@ -0,0 +1,64 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ho.business.mapper.StationRemoteControlMapper">
<insert id="insert" keyColumn="id" keyProperty="id" parameterType="com.ho.business.entity.StationRemoteControl"
useGeneratedKeys="true">
insert into station_remote_control
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="entity.id != null">id,</if>
<if test="entity.stationId != null">station_id,</if>
<if test="entity.ip != null">ip,</if>
<if test="entity.port != null">port,</if>
<if test="entity.userName != null">user_name,</if>
<if test="entity.password != null">password,</if>
<if test="entity.intranetIp != null">intranet_ip,</if>
<if test="entity.createTime != null">create_time,</if>
<if test="entity.updateTime != null">update_time,</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="entity.id != null">#{entity.id,jdbcType=INTEGER},</if>
<if test="entity.stationId != null">#{entity.stationId,jdbcType=INTEGER},</if>
<if test="entity.ip != null">#{entity.ip,jdbcType=VARCHAR},</if>
<if test="entity.port != null">#{entity.port,jdbcType=VARCHAR},</if>
<if test="entity.userName != null">#{entity.userName,jdbcType=VARCHAR},</if>
<if test="entity.password != null">#{entity.password,jdbcType=VARCHAR},</if>
<if test="entity.intranetIp != null">#{entity.intranetIp,jdbcType=VARCHAR},</if>
<if test="entity.createTime != null">#{entity.createTime,jdbcType=TIMESTAMP},</if>
<if test="entity.updateTime != null">#{entity.updateTime,jdbcType=TIMESTAMP},</if>
</trim>
</insert>
<update id="update" parameterType="com.ho.business.entity.StationRemoteControl">
update station_remote_control
<set>
<if test="entity.ip != null">
ip = #{entity.ip,jdbcType=VARCHAR},
</if>
<if test="entity.port != null">
port = #{entity.port,jdbcType=VARCHAR},
</if>
<if test="entity.userName != null">
user_name = #{entity.userName,jdbcType=VARCHAR},
</if>
<if test="entity.password != null">
password = #{entity.password,jdbcType=VARCHAR},
</if>
<if test="entity.intranetIp != null">
intranet_ip = #{entity.intranetIp,jdbcType=VARCHAR},
</if>
<if test="entity.updateTime != null">
update_time = #{entity.updateTime,jdbcType=VARCHAR},
</if>
</set>
where id = #{entity.id,jdbcType=INTEGER}
</update>
<delete id="delete">
delete from station_remote_control where id = #{id,jdbcType=INTEGER}
</delete>
<select id="search" resultType="com.ho.business.entity.StationRemoteControl">
select * from station_remote_control where station_id = #{stationId,jdbcType=INTEGER}
</select>
</mapper>

70
business-service/src/main/java/com/ho/business/controller/StationRemoteController.java Normal file
View File

@ -0,0 +1,70 @@
package com.ho.business.controller;
import com.ho.business.entity.Station;
import com.ho.business.entity.StationRemoteControl;
import com.ho.business.service.StationRemoteControlService;
import com.ho.business.service.StationService;
import com.ho.common.tools.annotation.LogAnnotation;
import com.ho.common.tools.annotation.TokenIgnore;
import com.ho.common.tools.constant.ContextConstant;
import com.ho.common.tools.exception.BaseResponseCode;
import com.ho.common.tools.exception.BusinessException;
import com.ho.common.tools.exception.DataResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import jodd.util.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
import java.util.Date;
@RequestMapping(ContextConstant.BUSINESS + "stationRemote")
@RestController
@Api(tags = "业务模块-电站远控管理")
public class StationRemoteController {
@Autowired
private StationRemoteControlService stationRemoteControlService;
@Autowired
private StationService stationService;
@PostMapping("saveOrUpdate")
@ApiOperation(value = "新增/修改远控电站信息")
@LogAnnotation(title = "电站远控管理", action = "新增/修改新增远控电站信息")
public DataResult saveOrUpdate(@RequestBody @Valid StationRemoteControl entity) {
if(entity==null){
throw new BusinessException(BaseResponseCode.DATA_NOT_EXISTS);
}
if(entity.getId()==null){
//新增
StationRemoteControl stationRemoteControl = stationRemoteControlService.search(entity.getStationId());
if (stationRemoteControl != null) {
throw new BusinessException(BaseResponseCode.STATION_ALREADY_EXISTS);
}
entity.setCreateTime(new Date());
stationRemoteControlService.insert(entity);
}else{
//修改
entity.setUpdateTime(new Date());
stationRemoteControlService.update(entity);
}
return DataResult.success();
}
@DeleteMapping("delete")
@ApiOperation(value = "删除远控电站信息")
@LogAnnotation(title = "电站远控管理", action = "删除远控电站信息")
public DataResult delete(@RequestBody Integer id) {
stationRemoteControlService.delete(id);
return DataResult.success();
}
@PostMapping("search")
@ApiOperation(value = "查询远控电站信息")
public DataResult<StationRemoteControl> search(@RequestBody Integer StationId) {
StationRemoteControl stationRemoteControl=stationRemoteControlService.search(StationId);
return DataResult.success(stationRemoteControl);
}
}