表具后台管理

src/main/java/org/rcisoft/business/manage/controller/BusDeviceMeterController.java

+package org.rcisoft.business.manage.controller;
+
+
+/*固定导入*/
+import io.swagger.annotations.ApiOperation;
+import org.rcisoft.business.manage.entity.BusDeviceMeter;
+import org.rcisoft.business.manage.service.BusDeviceMeterService;
+import org.rcisoft.core.constant.MessageConstant;
+import org.rcisoft.core.controller.PaginationController;
+import org.rcisoft.core.model.GridModel;
+import org.rcisoft.core.model.PersistModel;
+import org.rcisoft.core.result.Result;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.validation.Valid;
+
+/**
+* Created by  on 2018-5-2 16:09:29.
+*/
+@RestController
+@RequestMapping("busdevicemeter")
+public class BusDeviceMeterController extends PaginationController<BusDeviceMeter> {
+
+    @Autowired
+    private BusDeviceMeterService busDeviceMeterServiceImpl;
+
+
+    @ApiOperation(value="添加", notes="添加")
+    @PostMapping(value = "/add")
+    public Result add(@Valid BusDeviceMeter busDeviceMeter) {
+        PersistModel data = busDeviceMeterServiceImpl.save(busDeviceMeter);
+        return Result.builder(data,
+            MessageConstant.MESSAGE_ALERT_SUCCESS,
+            MessageConstant.MESSAGE_ALERT_ERROR,
+        busDeviceMeter);
+    }
+
+
+    @ApiOperation(value="修改表具", notes="修改表具")
+    @PutMapping("/update")
+    public Result update(@Valid BusDeviceMeter busDeviceMeter) {
+        PersistModel data = busDeviceMeterServiceImpl.merge(busDeviceMeter);
+        return Result.builder(data,
+            MessageConstant.MESSAGE_ALERT_SUCCESS,
+            MessageConstant.MESSAGE_ALERT_ERROR,
+        busDeviceMeter);
+    }
+
+    @ApiOperation(value="删除表具", notes="删除表具")
+    @PutMapping("/delete")
+    public Result delete(@RequestParam String metNum) {
+        PersistModel data = busDeviceMeterServiceImpl.delete(metNum);
+        return Result.builder(data,
+                MessageConstant.MESSAGE_ALERT_SUCCESS,
+                MessageConstant.MESSAGE_ALERT_ERROR,
+                metNum);
+    }
+
+    @ApiOperation(value="查看表具集合", notes="查看表具集合")
+    @GetMapping(value = "/queryBusDeviceMeterByPagination")
+    public GridModel listByPagination(BusDeviceMeter busDeviceMeter) {
+        busDeviceMeterServiceImpl.findAllByPagination(getPaginationUtility(), busDeviceMeter);
+        return getGridModelResponse();
+    }
+}

src/main/java/org/rcisoft/business/manage/dao/BusDeviceMeterRepository.java

+package org.rcisoft.business.manage.dao;
+
+import org.apache.ibatis.annotations.ResultMap;
+import org.apache.ibatis.annotations.Select;
+import org.rcisoft.business.manage.entity.BusDeviceMeter;
+import org.rcisoft.core.base.BaseMapper;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+* Created with  on 2018-5-2 16:09:29.
+*/
+@Repository
+public interface BusDeviceMeterRepository extends BaseMapper<BusDeviceMeter> {
+
+    /**
+    * 分页查询 busDeviceMeter
+    *
+    */
+    @Select("<script>select * from bus_device_meter where 1=1 "
+            + "</script>")
+    @ResultMap(value = "BaseResultMap" )
+    List<BusDeviceMeter> queryBusDeviceMeters(BusDeviceMeter busDeviceMeter);
+
+    /**
+     * 查询传感器是否有原始数据
+     * @param map
+     * @return
+     */
+    @Select("<script>select a.tm from total_original a,bus_device_meter b where a.dev_num = b.met_num and b.met_num = #{met_num} limit 1</script>")
+    List<Map<String,Object>> queryOriginalByMet(Map<String,Object> map);
+}
+

src/main/java/org/rcisoft/business/manage/entity/BusDeviceMeter.java

+package org.rcisoft.business.manage.entity;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+/**
+* Created with  on 2018-5-2 16:09:29.
+*/
+@Entity
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@Table(name = "bus_device_meter")
+public class BusDeviceMeter{
+
+
+
+     private String metId;
+
+     private String metNum;
+
+     private String metNm;
+
+     private String devNum;
+
+
+}
+

src/main/java/org/rcisoft/business/manage/service/BusDeviceMeterService.java

+package org.rcisoft.business.manage.service;
+
+import org.rcisoft.business.manage.entity.BusDeviceMeter;
+import org.rcisoft.core.aop.PageUtil;
+import org.rcisoft.core.model.PersistModel;
+
+import java.util.List;
+
+/**
+ * Created by  on 2018-5-2 16:09:29.
+ */
+public interface BusDeviceMeterService {
+
+    /**
+    * 保存 
+    * @param busDeviceMeter
+    * @return
+    */
+    PersistModel save(BusDeviceMeter busDeviceMeter);
+
+    /**
+    * 删除
+    * @return
+    */
+     PersistModel delete(String metNum);
+
+    /**
+    * 修改 
+    * @param busDeviceMeter
+    * @return
+    */
+    PersistModel merge(BusDeviceMeter busDeviceMeter);
+
+
+    /**
+    * 分页查询 
+    * @param busDeviceMeter
+    * @return
+    */
+    List<BusDeviceMeter> findAllByPagination(PageUtil<BusDeviceMeter> paginationUtility,
+                                             BusDeviceMeter busDeviceMeter);
+
+
+
+
+}

src/main/java/org/rcisoft/business/manage/service/impl/BusDeviceMeterServiceImpl.java

+package org.rcisoft.business.manage.service.impl;
+
+import lombok.extern.slf4j.Slf4j;
+import org.rcisoft.business.manage.dao.BusDeviceMeterRepository;
+import org.rcisoft.business.manage.entity.BusDeviceMeter;
+import org.rcisoft.business.manage.service.BusDeviceMeterService;
+import org.rcisoft.core.aop.PageUtil;
+import org.rcisoft.core.model.PersistModel;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Isolation;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+import tk.mybatis.mapper.entity.Example;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+
+/**
+ * Created by  on 2018-5-2 16:09:29.
+ */
+@Service
+@Transactional(readOnly = true,propagation = Propagation.NOT_SUPPORTED)
+@Slf4j
+public class BusDeviceMeterServiceImpl implements BusDeviceMeterService {
+
+    @Autowired
+    private BusDeviceMeterRepository busDeviceMeterRepository;
+
+
+    /**
+    * 保存 busDeviceMeter
+    * @param busDeviceMeter
+    * @return
+    */
+    @Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.DEFAULT)
+    @Override
+    public PersistModel save(BusDeviceMeter busDeviceMeter){
+        //增加操作
+        busDeviceMeter.setMetId(UUID.randomUUID().toString().replace("-",""));
+        int line = busDeviceMeterRepository.insertSelective(busDeviceMeter);
+        return new PersistModel(line);
+    }
+
+    @Override
+    public PersistModel delete(String metNum) {
+        int line = 0;
+        Example example = new Example(BusDeviceMeter.class);
+        Example.Criteria criteria = example.createCriteria();
+        Map<String,Object> map = new HashMap<>();
+        map.put("met_num",metNum);
+        criteria.andEqualTo("metNum",metNum);
+        if(busDeviceMeterRepository.queryOriginalByMet(map)==null || busDeviceMeterRepository.queryOriginalByMet(map).size()<1){
+            line = busDeviceMeterRepository.deleteByExample(example);
+        }
+        return new PersistModel(line);
+    }
+
+
+    /**
+    * 修改 busDeviceMeter
+    * @param busDeviceMeter
+    * @return
+    */
+    @Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.DEFAULT)
+    @Override
+    public PersistModel merge(BusDeviceMeter busDeviceMeter){
+        Example example = new Example(BusDeviceMeter.class);
+        Example.Criteria criteria = example.createCriteria();
+        criteria.andEqualTo("metNum",busDeviceMeter.getMetNum());
+        int line = busDeviceMeterRepository.updateByExampleSelective(busDeviceMeter,example);
+        return new PersistModel(line);
+    }
+
+    /**
+    * 分页查询 busDeviceMeter
+    * @param busDeviceMeter
+    * @return
+    */
+    public List<BusDeviceMeter> findAllByPagination(PageUtil<BusDeviceMeter> paginationUtility,
+        BusDeviceMeter busDeviceMeter){
+        return busDeviceMeterRepository.queryBusDeviceMeters(busDeviceMeter);
+    }
+
+}

src/main/resources/mapper/sys/manage.mapper/BusDeviceMeterMapper.xml

+<?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="org.rcisoft.business.manage.dao.BusDeviceMeterRepository">
+    <resultMap id="BaseResultMap" type="org.rcisoft.business.manage.entity.BusDeviceMeter">
+            <id column="MET_ID" jdbcType="VARCHAR" property="metId"/>
+            <result column="MET_NUM" jdbcType="VARCHAR" property="metNum"/>
+            <result column="MET_NM" jdbcType="VARCHAR" property="metNm"/>
+            <result column="DEV_NUM" jdbcType="VARCHAR" property="devNum"/>
+    </resultMap>
+
+    <!--<cache type="${corePackag!}.util.RedisCache"/>-->
+</mapper>
\ No newline at end of file