ccrc

src/main/java/com/zoniot/ccrc/controller/system/DeviceController.java

@@ -0,0 +1,51 @@
+package com.zoniot.ccrc.controller.system;
+
+import com.zoniot.ccrc.commom.model.AjaxMessage;
+import com.zoniot.ccrc.commom.model.Pagination;
+import com.zoniot.ccrc.commom.model.ResultStatus;
+import com.zoniot.ccrc.dto.DeviceDto;
+import com.zoniot.ccrc.service.DeviceService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+@Controller
+@RequestMapping("device")
+@Api(tags = "设备管理")
+public class DeviceController {
+    @Autowired
+    private DeviceService deviceService;
+
+    @ResponseBody
+    @GetMapping("/pageList")
+    @ApiOperation(value = "获取设备分页")
+    public AjaxMessage<Pagination<DeviceDto>> devicePageList(
+            @ApiParam(value = "系统id", required = false) @RequestParam(required = false) Integer sysId,
+            @ApiParam(value = "设备类型id", required = false) @RequestParam(required = false) Integer deviceTypeId,
+            @ApiParam(value = "机构id", required = false) @RequestParam(required = false) Integer orgId,
+            @ApiParam(value = "省", required = false) @RequestParam(required = false) Integer province,
+            @ApiParam(value = "市", required = false) @RequestParam(required = false) Integer city,
+            @ApiParam(value = "区", required = false) @RequestParam(required = false) Integer region,
+            @ApiParam(value = "小区id", required = false) @RequestParam(required = false) Integer communityId,
+            @ApiParam(value = "建筑id", required = false) @RequestParam(required = false) Integer buildingId,
+            @ApiParam(value = "设备编号", required = false) @RequestParam(required = false) String deviceNo,
+            @ApiParam(value = "客户名称", required = false) @RequestParam(required = false) String clientName,
+            @ApiParam(value = "位置描述", required = false) @RequestParam(required = false) String locDesc,
+            @ApiParam(value = "设备状态  1:正常 2:故障 3:无 4: 预警 5:未启用", required = false) @RequestParam(required = false) Integer status,
+            @ApiParam(value = "阀门状态 0：关阀 1：开阀  2：无阀", required = false) @RequestParam(required = false) Integer valveStatus,
+            @ApiParam(value = "排序参数，对应列表字段", required = false) @RequestParam(required = false,defaultValue = "sd.date_create") String sortColumn,
+            @ApiParam(value = "排序方式，顺序：ASC  倒序：DESC", required = false) @RequestParam(required = false, defaultValue = "DESC") String sortOrder,
+            @ApiParam(value = "页数,非必传，默认第一页", required = false, defaultValue = "1") @RequestParam(required = false, defaultValue = "1") int pageNum,
+            @ApiParam(value = "条数，非必传，默认15条", required = false, defaultValue = "15") @RequestParam(required = false, defaultValue = "15") int pageSize
+    ) {
+        Pagination<DeviceDto> pageInfo = deviceService.pageList(sysId,deviceTypeId,orgId,province,city,region,communityId,buildingId,deviceNo,clientName,locDesc,status,valveStatus, sortColumn, sortOrder, pageNum, pageSize);
+        return new AjaxMessage<>(ResultStatus.OK, pageInfo);
+    }
+}

src/main/java/com/zoniot/ccrc/dao/DeviceMapper.java

@@ -0,0 +1,17 @@
+package com.zoniot.ccrc.dao;
+
+import com.zoniot.ccrc.entity.Device;
+import java.util.List;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+@Mapper
+public interface DeviceMapper {
+    int insertSelective(Device record);
+
+    int updateByPrimaryKeySelective(Device record);
+
+    int updateBatch(List<Device> list);
+
+    int batchInsert(@Param("list") List<Device> list);
+}

src/main/java/com/zoniot/ccrc/dto/DeviceDto.java

@@ -0,0 +1,8 @@
+package com.zoniot.ccrc.dto;
+
+import com.zoniot.ccrc.entity.Device;
+import lombok.Data;
+
+@Data
+public class DeviceDto extends Device {
+}

src/main/java/com/zoniot/ccrc/entity/Device.java

@@ -0,0 +1,73 @@
+package com.zoniot.ccrc.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.time.LocalDateTime;
+import lombok.Data;
+
+@ApiModel(value="设备")
+@Data
+public class Device {
+    @ApiModelProperty(value="")
+    private Long id;
+
+    @ApiModelProperty(value="设备编号")
+    private String deviceNo;
+
+    @ApiModelProperty(value="设备电子号")
+    private String meterNo;
+
+    @ApiModelProperty(value="设备档案号")
+    private String fileNo;
+
+    @ApiModelProperty(value="铅封号")
+    private String sealNo;
+
+    @ApiModelProperty(value="站点id")
+    private Integer siteId;
+
+    @ApiModelProperty(value="系统id")
+    private Integer sysId;
+
+    @ApiModelProperty(value="设备id")
+    private Integer deviceTypeId;
+
+    @ApiModelProperty(value="厂商id")
+    private Integer manufacturerId;
+
+    @ApiModelProperty(value="建筑id")
+    private Integer buildingId;
+
+    @ApiModelProperty(value="小区id")
+    private Integer communityId;
+
+    @ApiModelProperty(value="安装地址")
+    private String locDesc;
+
+    @ApiModelProperty(value="水表读数")
+    private Long meterReading;
+
+    @ApiModelProperty(value="阀门状态 0：关阀 1：开阀 2：异常")
+    private Integer valveStatus;
+
+    @ApiModelProperty(value="设备状态  1:正常 2:故障 3:无 4: 预警 5:未启用")
+    private String deviceStatus;
+
+    @ApiModelProperty(value="最后上报时间")
+    private LocalDateTime lastReceiveTime;
+
+    @ApiModelProperty(value="状态")
+    private Boolean status;
+
+    @ApiModelProperty(value="创建人")
+    private String createBy;
+
+    @ApiModelProperty(value="创建时间")
+    private LocalDateTime dateCreate;
+
+    @ApiModelProperty(value="更新人")
+    private String updateBy;
+
+    @ApiModelProperty(value="更新时间")
+    private LocalDateTime dateUpdate;
+}

src/main/java/com/zoniot/ccrc/service/DeviceService.java

@@ -0,0 +1,20 @@
+package com.zoniot.ccrc.service;
+
+import java.util.List;
+
+import com.zoniot.ccrc.commom.model.Pagination;
+import com.zoniot.ccrc.dto.DeviceDto;
+import com.zoniot.ccrc.entity.Device;
+public interface DeviceService{
+
+
+    int insertSelective(Device record);
+
+    int updateByPrimaryKeySelective(Device record);
+
+    int updateBatch(List<Device> list);
+
+    int batchInsert(List<Device> list);
+
+    Pagination<DeviceDto> pageList(Integer sysId, Integer deviceTypeId, Integer orgId, Integer province, Integer city, Integer region, Integer communityId, Integer buildingId, String deviceNo, String clientName, String locDesc, Integer status, Integer valveStatus, String sortColumn, String sortOrder, int pageNum, int pageSize);
+}

src/main/java/com/zoniot/ccrc/service/impl/DeviceServiceImpl.java

@@ -0,0 +1,41 @@
+package com.zoniot.ccrc.service.impl;
+
+import com.zoniot.ccrc.commom.model.Pagination;
+import com.zoniot.ccrc.dto.DeviceDto;
+import org.springframework.stereotype.Service;
+import javax.annotation.Resource;
+import java.util.List;
+import com.zoniot.ccrc.entity.Device;
+import com.zoniot.ccrc.dao.DeviceMapper;
+import com.zoniot.ccrc.service.DeviceService;
+@Service
+public class DeviceServiceImpl implements DeviceService{
+
+    @Resource
+    private DeviceMapper deviceMapper;
+
+    @Override
+    public int insertSelective(Device record) {
+        return deviceMapper.insertSelective(record);
+    }
+
+    @Override
+    public int updateByPrimaryKeySelective(Device record) {
+        return deviceMapper.updateByPrimaryKeySelective(record);
+    }
+
+    @Override
+    public int updateBatch(List<Device> list) {
+        return deviceMapper.updateBatch(list);
+    }
+
+    @Override
+    public int batchInsert(List<Device> list) {
+        return deviceMapper.batchInsert(list);
+    }
+
+    @Override
+    public Pagination<DeviceDto> pageList(Integer sysId, Integer deviceTypeId, Integer orgId, Integer province, Integer city, Integer region, Integer communityId, Integer buildingId, String deviceNo, String clientName, String locDesc, Integer status, Integer valveStatus, String sortColumn, String sortOrder, int pageNum, int pageSize) {
+        return null;
+    }
+}

src/main/resources/mapper/DeviceMapper.xml

@@ -0,0 +1,355 @@
+<?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.zoniot.ccrc.dao.DeviceMapper">
+  <resultMap id="BaseResultMap" type="com.zoniot.ccrc.entity.Device">
+    <!--@mbg.generated-->
+    <!--@Table sc_device-->
+    <id column="id" property="id" />
+    <result column="device_no" property="deviceNo" />
+    <result column="meter_no" property="meterNo" />
+    <result column="file_no" property="fileNo" />
+    <result column="seal_no" property="sealNo" />
+    <result column="site_id" property="siteId" />
+    <result column="sys_id" property="sysId" />
+    <result column="device_type_id" property="deviceTypeId" />
+    <result column="manufacturer_id" property="manufacturerId" />
+    <result column="building_id" property="buildingId" />
+    <result column="community_id" property="communityId" />
+    <result column="loc_desc" property="locDesc" />
+    <result column="meter_reading" property="meterReading" />
+    <result column="valve_status" property="valveStatus" />
+    <result column="device_status" property="deviceStatus" />
+    <result column="last_receive_time" property="lastReceiveTime" />
+    <result column="status" property="status" />
+    <result column="create_by" property="createBy" />
+    <result column="date_create" property="dateCreate" />
+    <result column="update_by" property="updateBy" />
+    <result column="date_update" property="dateUpdate" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, device_no, meter_no, file_no, seal_no, site_id, sys_id, device_type_id, manufacturer_id, 
+    building_id, community_id, loc_desc, meter_reading, valve_status, device_status, 
+    last_receive_time, `status`, create_by, date_create, update_by, date_update
+  </sql>
+  <insert id="insertSelective" keyColumn="id" keyProperty="id" parameterType="com.zoniot.ccrc.entity.Device" useGeneratedKeys="true">
+    <!--@mbg.generated-->
+    insert into sc_device
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="deviceNo != null">
+        device_no,
+      </if>
+      <if test="meterNo != null">
+        meter_no,
+      </if>
+      <if test="fileNo != null">
+        file_no,
+      </if>
+      <if test="sealNo != null">
+        seal_no,
+      </if>
+      <if test="siteId != null">
+        site_id,
+      </if>
+      <if test="sysId != null">
+        sys_id,
+      </if>
+      <if test="deviceTypeId != null">
+        device_type_id,
+      </if>
+      <if test="manufacturerId != null">
+        manufacturer_id,
+      </if>
+      <if test="buildingId != null">
+        building_id,
+      </if>
+      <if test="communityId != null">
+        community_id,
+      </if>
+      <if test="locDesc != null">
+        loc_desc,
+      </if>
+      <if test="meterReading != null">
+        meter_reading,
+      </if>
+      <if test="valveStatus != null">
+        valve_status,
+      </if>
+      <if test="deviceStatus != null">
+        device_status,
+      </if>
+      <if test="lastReceiveTime != null">
+        last_receive_time,
+      </if>
+      <if test="status != null">
+        `status`,
+      </if>
+      <if test="createBy != null">
+        create_by,
+      </if>
+      <if test="dateCreate != null">
+        date_create,
+      </if>
+      <if test="updateBy != null">
+        update_by,
+      </if>
+      <if test="dateUpdate != null">
+        date_update,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="deviceNo != null">
+        #{deviceNo},
+      </if>
+      <if test="meterNo != null">
+        #{meterNo},
+      </if>
+      <if test="fileNo != null">
+        #{fileNo},
+      </if>
+      <if test="sealNo != null">
+        #{sealNo},
+      </if>
+      <if test="siteId != null">
+        #{siteId},
+      </if>
+      <if test="sysId != null">
+        #{sysId},
+      </if>
+      <if test="deviceTypeId != null">
+        #{deviceTypeId},
+      </if>
+      <if test="manufacturerId != null">
+        #{manufacturerId},
+      </if>
+      <if test="buildingId != null">
+        #{buildingId},
+      </if>
+      <if test="communityId != null">
+        #{communityId},
+      </if>
+      <if test="locDesc != null">
+        #{locDesc},
+      </if>
+      <if test="meterReading != null">
+        #{meterReading},
+      </if>
+      <if test="valveStatus != null">
+        #{valveStatus},
+      </if>
+      <if test="deviceStatus != null">
+        #{deviceStatus},
+      </if>
+      <if test="lastReceiveTime != null">
+        #{lastReceiveTime},
+      </if>
+      <if test="status != null">
+        #{status},
+      </if>
+      <if test="createBy != null">
+        #{createBy},
+      </if>
+      <if test="dateCreate != null">
+        #{dateCreate},
+      </if>
+      <if test="updateBy != null">
+        #{updateBy},
+      </if>
+      <if test="dateUpdate != null">
+        #{dateUpdate},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.zoniot.ccrc.entity.Device">
+    <!--@mbg.generated-->
+    update sc_device
+    <set>
+      <if test="deviceNo != null">
+        device_no = #{deviceNo},
+      </if>
+      <if test="meterNo != null">
+        meter_no = #{meterNo},
+      </if>
+      <if test="fileNo != null">
+        file_no = #{fileNo},
+      </if>
+      <if test="sealNo != null">
+        seal_no = #{sealNo},
+      </if>
+      <if test="siteId != null">
+        site_id = #{siteId},
+      </if>
+      <if test="sysId != null">
+        sys_id = #{sysId},
+      </if>
+      <if test="deviceTypeId != null">
+        device_type_id = #{deviceTypeId},
+      </if>
+      <if test="manufacturerId != null">
+        manufacturer_id = #{manufacturerId},
+      </if>
+      <if test="buildingId != null">
+        building_id = #{buildingId},
+      </if>
+      <if test="communityId != null">
+        community_id = #{communityId},
+      </if>
+      <if test="locDesc != null">
+        loc_desc = #{locDesc},
+      </if>
+      <if test="meterReading != null">
+        meter_reading = #{meterReading},
+      </if>
+      <if test="valveStatus != null">
+        valve_status = #{valveStatus},
+      </if>
+      <if test="deviceStatus != null">
+        device_status = #{deviceStatus},
+      </if>
+      <if test="lastReceiveTime != null">
+        last_receive_time = #{lastReceiveTime},
+      </if>
+      <if test="status != null">
+        `status` = #{status},
+      </if>
+      <if test="createBy != null">
+        create_by = #{createBy},
+      </if>
+      <if test="dateCreate != null">
+        date_create = #{dateCreate},
+      </if>
+      <if test="updateBy != null">
+        update_by = #{updateBy},
+      </if>
+      <if test="dateUpdate != null">
+        date_update = #{dateUpdate},
+      </if>
+    </set>
+    where id = #{id}
+  </update>
+  <update id="updateBatch" parameterType="java.util.List">
+    <!--@mbg.generated-->
+    update sc_device
+    <trim prefix="set" suffixOverrides=",">
+      <trim prefix="device_no = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.deviceNo}
+        </foreach>
+      </trim>
+      <trim prefix="meter_no = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.meterNo}
+        </foreach>
+      </trim>
+      <trim prefix="file_no = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.fileNo}
+        </foreach>
+      </trim>
+      <trim prefix="seal_no = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.sealNo}
+        </foreach>
+      </trim>
+      <trim prefix="site_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.siteId}
+        </foreach>
+      </trim>
+      <trim prefix="sys_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.sysId}
+        </foreach>
+      </trim>
+      <trim prefix="device_type_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.deviceTypeId}
+        </foreach>
+      </trim>
+      <trim prefix="manufacturer_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.manufacturerId}
+        </foreach>
+      </trim>
+      <trim prefix="building_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.buildingId}
+        </foreach>
+      </trim>
+      <trim prefix="community_id = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.communityId}
+        </foreach>
+      </trim>
+      <trim prefix="loc_desc = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.locDesc}
+        </foreach>
+      </trim>
+      <trim prefix="meter_reading = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.meterReading}
+        </foreach>
+      </trim>
+      <trim prefix="valve_status = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.valveStatus}
+        </foreach>
+      </trim>
+      <trim prefix="device_status = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.deviceStatus}
+        </foreach>
+      </trim>
+      <trim prefix="last_receive_time = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.lastReceiveTime}
+        </foreach>
+      </trim>
+      <trim prefix="`status` = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.status}
+        </foreach>
+      </trim>
+      <trim prefix="create_by = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.createBy}
+        </foreach>
+      </trim>
+      <trim prefix="date_create = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.dateCreate}
+        </foreach>
+      </trim>
+      <trim prefix="update_by = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.updateBy}
+        </foreach>
+      </trim>
+      <trim prefix="date_update = case" suffix="end,">
+        <foreach collection="list" index="index" item="item">
+          when id = #{item.id} then #{item.dateUpdate}
+        </foreach>
+      </trim>
+    </trim>
+    where id in
+    <foreach close=")" collection="list" item="item" open="(" separator=", ">
+      #{item.id}
+    </foreach>
+  </update>
+  <insert id="batchInsert" keyColumn="id" keyProperty="id" parameterType="map" useGeneratedKeys="true">
+    <!--@mbg.generated-->
+    insert into sc_device
+    (device_no, meter_no, file_no, seal_no, site_id, sys_id, device_type_id, manufacturer_id, 
+      building_id, community_id, loc_desc, meter_reading, valve_status, device_status, 
+      last_receive_time, `status`, create_by, date_create, update_by, date_update)
+    values
+    <foreach collection="list" item="item" separator=",">
+      (#{item.deviceNo}, #{item.meterNo}, #{item.fileNo}, #{item.sealNo}, #{item.siteId}, 
+        #{item.sysId}, #{item.deviceTypeId}, #{item.manufacturerId}, #{item.buildingId}, 
+        #{item.communityId}, #{item.locDesc}, #{item.meterReading}, #{item.valveStatus}, 
+        #{item.deviceStatus}, #{item.lastReceiveTime}, #{item.status}, #{item.createBy}, 
+        #{item.dateCreate}, #{item.updateBy}, #{item.dateUpdate})
+    </foreach>
+  </insert>
+</mapper>