update

whycxzp

2021-03-01 788fd95ad4fd8d1a1f81c59628c24cb8355783da

update

 src/main/java/com/whyc/controller/AFEInverterController.java

@@ -1,9 +1,14 @@
package com.whyc.controller;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
import com.whyc.pojo.AFEInverterState;
import com.whyc.service.AFEInverterService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import jdk.nashorn.internal.objects.annotations.Getter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -24,10 +29,26 @@
        return service.getAll(pageNum,pageSize);
    }

    @GetMapping("all2")
    @ApiOperation(value="查询所有")
    public Response getAll2(@RequestParam int pageNum,int pageSize){
        return service.getAll2(pageNum,pageSize);
    @GetMapping("infoByDeviceId")
    @ApiOperation(value = "查询单个:根据设备id")
    public Response<AFEInverterState> getInfoByDeviceId(@RequestParam int devId){
        return service.getInfoByDeviceId(devId);
    }

    @GetMapping("tableNames")
    @ApiOperation(value = "查询历史记录存在的表格")
    public Response<String> getTableNames(){
        return service.getTableNames();
    }

    /**
     * ======History======
     * 历史查询时,因为历史记录是按照日期分表的,如果查询所有的日期表(union)后再分页,会导致速度极慢,故查询按照单个日期查询
     * */
    @GetMapping("history/all")
    @ApiOperation(value = "获取所有历史记录")
    public Response<PageInfo<AFEInverterState>> getHistory(@RequestParam int pageNum, int pageSize,String tablePrefixTime){
        return service.getHistory(pageNum,pageSize,tablePrefixTime);
    }

}

 src/main/java/com/whyc/controller/AFERectifierController.java

@@ -1,7 +1,15 @@
package com.whyc.controller;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.whyc.dto.Response;
import com.whyc.pojo.AFERectifierState;
import com.whyc.service.AFERectifierService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
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.RestController;

@RestController
@@ -9,5 +17,19 @@
@Api(tags = "afe变频器-整流器的数据信息")
public class AFERectifierController {

    @Autowired
    AFERectifierService service;

    @GetMapping("all")
    @ApiOperation(value = "获取所有数据信息")
    public Response<IPage<AFERectifierState>> getAll(@RequestParam int pageNum, int pageSize){
        return service.getAll(pageNum,pageSize);
    }

    @GetMapping("infoByDevId")
    @ApiOperation(value = "获取单个数据信息:根据设备id")
    public Response<AFERectifierState> getInfoByDevId(@RequestParam int devId){
        return service.getInfoByDevId(devId);
    }

}

 src/main/java/com/whyc/controller/RectifierPowerController.java

@@ -1,7 +1,15 @@
package com.whyc.controller;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.whyc.dto.Response;
import com.whyc.pojo.RectifierPowerRT;
import com.whyc.service.RectifierPowerService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
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.RestController;

@RestController
@@ -9,5 +17,19 @@
@Api(tags = "大功率整流电源-数据信息")
public class RectifierPowerController {

    @Autowired
    RectifierPowerService service;

    @GetMapping("all")
    @ApiOperation(value = "获取所有信息")
    public Response<IPage<RectifierPowerRT>> getAll(@RequestParam int pageNum,int pageSize){
        return service.getAll(pageNum,pageSize);
    }

    @GetMapping("infoByDevId")
    @ApiOperation(value = "获取单个信息:根据设备id")
    public Response<RectifierPowerRT> getInfoByDevId(@RequestParam int devId){
        return service.getInfoByDevId(devId);
    }

}

 src/main/java/com/whyc/controller/RectifierPowerCtrlController.java

@@ -1,7 +1,15 @@
package com.whyc.controller;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.whyc.dto.Response;
import com.whyc.pojo.RectifierPowerControl;
import com.whyc.service.RectifierPowerCtrlService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
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.RestController;

@RestController
@@ -9,5 +17,19 @@
@Api(tags = "大功率整流电源-控制状态")
public class RectifierPowerCtrlController {

    @Autowired
    private RectifierPowerCtrlService service;

    @GetMapping("all")
    @ApiOperation(value = "获取所有信息")
    public Response<IPage<RectifierPowerControl>> getAll(@RequestParam int pageNum, int pageSize){
        return service.getAll(pageNum,pageSize);
    }

    @GetMapping("infoByDevId")
    @ApiOperation(value = "获取单个信息:根据设备id")
    public Response<RectifierPowerControl> getInfoByDevId(@RequestParam int devId){
        return service.getInfoByDevId(devId);
    }

}

 src/main/java/com/whyc/mapper/AFEInverterHistoryMapper.java

New file
@@ -0,0 +1,10 @@
package com.whyc.mapper;

import com.whyc.pojo.AFEInverterState;

import java.util.List;

public interface AFEInverterHistoryMapper {

    List<AFEInverterState> getHistory(List<String> tableNames);
}

 src/main/java/com/whyc/mapper/CommonMapper.java

New file
@@ -0,0 +1,12 @@
package com.whyc.mapper;

import net.sf.jsqlparser.expression.JdbcNamedParameter;
import org.apache.ibatis.annotations.Select;

import java.util.List;

public interface CommonMapper {

    @Select("select TABLE_NAME FROM information_schema.TABLES where TABLE_SCHEMA= #{dBName} and TABLE_NAME like concat(#{tableLike},'%')")
    List<String> getTableName(String dBName, String tableLike);
}

 src/main/java/com/whyc/service/AFEInverterService.java

@@ -1,11 +1,15 @@
package com.whyc.service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
import com.whyc.mapper.AFEInverterHistoryMapper;
import com.whyc.mapper.AFEInverterMapper;
import com.whyc.mapper.CommonMapper;
import com.whyc.pojo.AFEInverterState;
import org.springframework.stereotype.Service;

@@ -19,16 +23,47 @@
    @Resource
    AFEInverterMapper mapper;

    @Resource
    AFEInverterHistoryMapper historyMapper;

    @Resource
    CommonMapper commonMapper;

    /**分页*/
    public Response getAll(int pageNum,int pageSize) {
        PageHelper.startPage(pageNum,pageSize,true);
        List<AFEInverterState> afeInverterStates = mapper.selectAll();
        PageInfo<AFEInverterState> pageInfo = new PageInfo<>(afeInverterStates);
        return new Response().set(1,pageInfo);
    }

    public Response getAll2(int pageNum, int pageSize) {
        IPage<AFEInverterState> afeInverterStateIPage = mapper.selectPage(new Page<>(pageNum, pageSize), null);
        return new Response().set(1,afeInverterStateIPage);
    }


    public Response<AFEInverterState> getInfoByDeviceId(int devId) {
        QueryWrapper<AFEInverterState> query = Wrappers.query();
        query.eq("dev_id",devId);
        AFEInverterState afeInverterState = mapper.selectOne(query);

        return new Response<AFEInverterState>().set(1,afeInverterState);
    }

    /**======History======*/

    public Response<PageInfo<AFEInverterState>> getHistory(int pageNum, int pageSize,String tablePrefixTime) {


        PageHelper.startPage(pageNum,pageSize);
        List<AFEInverterState> afeInverterStates = historyMapper.getHistory(tableNames);
        PageInfo<AFEInverterState> afeInverterStatePageInfo = new PageInfo<>(afeInverterStates);
        return new Response<PageInfo<AFEInverterState>>().set(1,afeInverterStatePageInfo);
    }

    /**采用二叉树*/
    public Response<String> getTableNames() {
        List<String> tableNames = commonMapper.getTableName("`db_3.5mw_motor`", "tb_afe_inverter_state");
        for (int i = 0; i < tableNames.size(); i++) {
            String tableName = tableNames.get(i);
            String year = tableName.split("_")[4];
            String month = tableName.split("_")[5];
            String day = tableName.split("_")[6];
        }
        return null;
    }
}

 src/main/java/com/whyc/service/AFERectifierService.java

@@ -1,9 +1,33 @@
package com.whyc.service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.whyc.dto.Response;
import com.whyc.mapper.AFERectifierMapper;
import com.whyc.pojo.AFERectifierState;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.sql.Wrapper;

@Service
public class AFERectifierService {

    @Resource
    private AFERectifierMapper mapper;

    /**分页*/
    public Response<IPage<AFERectifierState>> getAll(int pageNum,int pageSize) {
        IPage<AFERectifierState> afeRectifierStateIPage = mapper.selectPage(new Page<>(pageNum, pageSize), null);
        return new Response<IPage<AFERectifierState>>().set(1,afeRectifierStateIPage);
    }

    public Response<AFERectifierState> getInfoByDevId(int devId) {
        QueryWrapper<AFERectifierState> query = Wrappers.query();
        query.eq("dev_id",devId);
        AFERectifierState afeRectifierState = mapper.selectOne(query);
        return new Response<AFERectifierState>().set(1,afeRectifierState);
    }
}

 src/main/java/com/whyc/service/RectifierPowerCtrlService.java

@@ -1,9 +1,31 @@
package com.whyc.service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.whyc.dto.Response;
import com.whyc.mapper.RectifierPowerCtrlMapper;
import com.whyc.pojo.RectifierPowerControl;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service
public class RectifierPowerCtrlService {

    @Resource
    private RectifierPowerCtrlMapper mapper;

    public Response<IPage<RectifierPowerControl>> getAll(int pageNum, int pageSize) {
        IPage<RectifierPowerControl> rectifierPowerControlIPage = mapper.selectPage(new Page<>(pageNum, pageSize), null);
        return new Response<IPage<RectifierPowerControl>>().set(1,rectifierPowerControlIPage);
    }

    public Response<RectifierPowerControl> getInfoByDevId(int devId) {
        QueryWrapper<RectifierPowerControl> query = Wrappers.query();
        query.eq("dev_id",devId);
        RectifierPowerControl rectifierPowerControl = mapper.selectOne(query);
        return new Response<RectifierPowerControl>().set(1,rectifierPowerControl);
    }
}

 src/main/java/com/whyc/service/RectifierPowerService.java

@@ -1,9 +1,32 @@
package com.whyc.service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.whyc.dto.Response;
import com.whyc.mapper.RectifierPowerMapper;
import com.whyc.pojo.RectifierPowerRT;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.sql.Wrapper;

@Service
public class RectifierPowerService {

    @Resource
    private RectifierPowerMapper mapper;

    public Response<IPage<RectifierPowerRT>> getAll(int pageNum, int pageSize) {
        IPage<RectifierPowerRT> rectifierPowerRTIPage = mapper.selectPage(new Page<>(pageNum, pageSize), null);
        return new Response<IPage<RectifierPowerRT>>().set(1,rectifierPowerRTIPage);
    }

    public Response<RectifierPowerRT> getInfoByDevId(int devId) {
        QueryWrapper<RectifierPowerRT> query = Wrappers.query();
        query.eq("dev_id",devId);
        RectifierPowerRT rectifierPowerRT = mapper.selectOne(query);
        return new Response<RectifierPowerRT>().set(1,rectifierPowerRT);
    }
}

 src/main/resources/mapper/AFEInverterHistoryMapper.xml

New file
@@ -0,0 +1,9 @@
<?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.whyc.mapper.AFEInverterHistoryMapper" >


    <select id="getHistory" resultType="com.whyc.pojo.AFEInverterState">

    </select>
</mapper>