diff --git a/business-service-api/src/main/java/com/ho/business/entity/StationRemoteControl.java b/business-service-api/src/main/java/com/ho/business/entity/StationRemoteControl.java new file mode 100644 index 0000000..29fc94f --- /dev/null +++ b/business-service-api/src/main/java/com/ho/business/entity/StationRemoteControl.java @@ -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; +} diff --git a/business-service-dao/src/main/java/com/ho/business/mapper/StationRemoteControlMapper.java b/business-service-dao/src/main/java/com/ho/business/mapper/StationRemoteControlMapper.java new file mode 100644 index 0000000..4cf137c --- /dev/null +++ b/business-service-dao/src/main/java/com/ho/business/mapper/StationRemoteControlMapper.java @@ -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); +} diff --git a/business-service-dao/src/main/java/com/ho/business/service/StationRemoteControlService.java b/business-service-dao/src/main/java/com/ho/business/service/StationRemoteControlService.java new file mode 100644 index 0000000..be283c7 --- /dev/null +++ b/business-service-dao/src/main/java/com/ho/business/service/StationRemoteControlService.java @@ -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); +} diff --git a/business-service-dao/src/main/java/com/ho/business/service/impl/StationRemoteControlServiceImpl.java b/business-service-dao/src/main/java/com/ho/business/service/impl/StationRemoteControlServiceImpl.java new file mode 100644 index 0000000..33fdfca --- /dev/null +++ b/business-service-dao/src/main/java/com/ho/business/service/impl/StationRemoteControlServiceImpl.java @@ -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); + } +} diff --git a/business-service-dao/src/main/resources/mapper/StationRemoteControlMapper.xml b/business-service-dao/src/main/resources/mapper/StationRemoteControlMapper.xml new file mode 100644 index 0000000..800a0bb --- /dev/null +++ b/business-service-dao/src/main/resources/mapper/StationRemoteControlMapper.xml @@ -0,0 +1,64 @@ + + + + + + + insert into station_remote_control + + id, + station_id, + ip, + port, + user_name, + password, + intranet_ip, + create_time, + update_time, + + + #{entity.id,jdbcType=INTEGER}, + #{entity.stationId,jdbcType=INTEGER}, + #{entity.ip,jdbcType=VARCHAR}, + #{entity.port,jdbcType=VARCHAR}, + #{entity.userName,jdbcType=VARCHAR}, + #{entity.password,jdbcType=VARCHAR}, + #{entity.intranetIp,jdbcType=VARCHAR}, + #{entity.createTime,jdbcType=TIMESTAMP}, + #{entity.updateTime,jdbcType=TIMESTAMP}, + + + + update station_remote_control + + + ip = #{entity.ip,jdbcType=VARCHAR}, + + + port = #{entity.port,jdbcType=VARCHAR}, + + + user_name = #{entity.userName,jdbcType=VARCHAR}, + + + password = #{entity.password,jdbcType=VARCHAR}, + + + intranet_ip = #{entity.intranetIp,jdbcType=VARCHAR}, + + + update_time = #{entity.updateTime,jdbcType=VARCHAR}, + + + where id = #{entity.id,jdbcType=INTEGER} + + + delete from station_remote_control where id = #{id,jdbcType=INTEGER} + + + diff --git a/business-service/src/main/java/com/ho/business/controller/StationRemoteController.java b/business-service/src/main/java/com/ho/business/controller/StationRemoteController.java new file mode 100644 index 0000000..3ef6524 --- /dev/null +++ b/business-service/src/main/java/com/ho/business/controller/StationRemoteController.java @@ -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 search(@RequestBody Integer StationId) { + StationRemoteControl stationRemoteControl=stationRemoteControlService.search(StationId); + return DataResult.success(stationRemoteControl); + } +}