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..789a74f --- /dev/null +++ b/business-service-api/src/main/java/com/ho/business/entity/StationRemoteControl.java @@ -0,0 +1,48 @@ +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 = "电站名称") + private String stationName; + + @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; + + @ApiModelProperty(value = "ems页面类型") + private String type; + + @JsonFormat(pattern = CommonConstant.DATE) + @ApiModelProperty(value = "创建时间") + private Date createTime; + + @JsonFormat(pattern = CommonConstant.DATE) + @ApiModelProperty(value = "修改时间") + private Date updateTime; +} diff --git a/business-service-api/src/main/java/com/ho/business/vo/req/StationRemoteControlPageVo.java b/business-service-api/src/main/java/com/ho/business/vo/req/StationRemoteControlPageVo.java new file mode 100644 index 0000000..bbf6adf --- /dev/null +++ b/business-service-api/src/main/java/com/ho/business/vo/req/StationRemoteControlPageVo.java @@ -0,0 +1,16 @@ +package com.ho.business.vo.req; + +import com.ho.business.entity.StationRemoteControl; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +@Data +public class StationRemoteControlPageVo extends StationRemoteControl { + + @ApiModelProperty(value = "第几页") + private Integer pageNum=1; + + @ApiModelProperty(value = "分页数量") + private Integer pageSize=10; + +} 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..987a4da --- /dev/null +++ b/business-service-dao/src/main/java/com/ho/business/mapper/StationRemoteControlMapper.java @@ -0,0 +1,21 @@ +package com.ho.business.mapper; + +import com.ho.business.entity.StationRemoteControl; +import com.ho.business.vo.req.StationRemoteControlPageVo; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +@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); + + List selectList(@Param("vo") StationRemoteControlPageVo vo); +} 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..f5cadfb --- /dev/null +++ b/business-service-dao/src/main/java/com/ho/business/service/StationRemoteControlService.java @@ -0,0 +1,17 @@ +package com.ho.business.service; + +import com.ho.business.entity.StationRemoteControl; +import com.ho.business.vo.req.StationRemoteControlPageVo; +import com.ho.common.tools.util.PageResult; + +public interface StationRemoteControlService { + void insert(StationRemoteControl entity); + + void update(StationRemoteControl entity); + + void delete(Integer id); + + StationRemoteControl search(Integer stationId); + + PageResult selectPageList(StationRemoteControlPageVo vo); +} 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..1916a32 --- /dev/null +++ b/business-service-dao/src/main/java/com/ho/business/service/impl/StationRemoteControlServiceImpl.java @@ -0,0 +1,50 @@ +package com.ho.business.service.impl; + +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; +import com.ho.business.entity.StationRemoteControl; +import com.ho.business.mapper.StationRemoteControlMapper; +import com.ho.business.service.StationRemoteControlService; +import com.ho.business.vo.req.StationRemoteControlPageVo; +import com.ho.common.tools.util.PageResult; +import com.ho.common.tools.util.PageUtils; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; + +@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); + } + + @Override + public PageResult selectPageList(StationRemoteControlPageVo vo) { + PageHelper.startPage(vo.getPageNum(), vo.getPageSize()); + List list = stationRemoteControlMapper.selectList(vo); + return PageUtils.getPageResult(new PageInfo<>(list)); + } +} 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..3d4d022 --- /dev/null +++ b/business-service-dao/src/main/resources/mapper/StationRemoteControlMapper.xml @@ -0,0 +1,99 @@ + + + + + + + insert into station_remote_control + + id, + station_id, + ip, + port, + user_name, + password, + intranet_ip, + type, + 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.type,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}, + + + type = #{entity.type,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..75ada7f --- /dev/null +++ b/business-service/src/main/java/com/ho/business/controller/StationRemoteController.java @@ -0,0 +1,72 @@ +package com.ho.business.controller; + +import com.ho.business.entity.StationRemoteControl; +import com.ho.business.service.StationRemoteControlService; +import com.ho.business.vo.req.StationRemoteControlPageVo; +import com.ho.common.tools.annotation.LogAnnotation; +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 com.ho.common.tools.util.PageResult; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +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; + + @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 StationRemoteControlPageVo vo) { + StationRemoteControl stationRemoteControl=stationRemoteControlService.search(vo.getStationId()); + return DataResult.success(stationRemoteControl); + } + + @PostMapping("pageList") + @ApiOperation(value = "查询远控电站信息") + public DataResult> pageList(@RequestBody StationRemoteControlPageVo vo) { + PageResult page = stationRemoteControlService.selectPageList(vo); + return DataResult.success(page); + } +}