package com.moral.api.controller;
|
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.moral.api.entity.HistoryFiveMinutely;
|
import com.moral.api.entity.Sensor;
|
import com.moral.api.entity.Test;
|
import com.moral.api.mapper.HistoryFiveMinutelyMapper;
|
import com.moral.api.mapper.SensorMapper;
|
import com.moral.api.service.TestService;
|
import com.moral.constant.Constants;
|
import com.moral.constant.ResultMessage;
|
import com.moral.redis.RedisUtil;
|
import com.moral.util.PageResult;
|
import io.swagger.annotations.*;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.kafka.core.KafkaTemplate;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.servlet.handler.WebRequestHandlerInterceptorAdapter;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
|
@Slf4j
|
@Api(tags = {"测试"})
|
@RestController
|
@RequestMapping("/test")
|
public class TestController {
|
|
@Autowired
|
private KafkaTemplate kafkaTemplate;
|
|
@Autowired
|
private TestService testService;
|
|
@Autowired
|
private SensorMapper sensorMapper;
|
|
@Autowired
|
private HistoryFiveMinutelyMapper historyFiveMinutelyMapper;
|
/**
|
* name 姓名
|
* email 郵箱
|
* mobile 手機號
|
*/
|
@ApiOperation(value = "测试插入", notes = "测试插入")
|
@RequestMapping(value = "/saveTest", method = RequestMethod.POST)
|
public ResultMessage save() {
|
|
Test test=new Test();
|
test.setEmail("test@qq.com");
|
test.setName("name");
|
test.setMobile("13965898745");
|
testService.save(test);
|
return ResultMessage.ok();
|
|
}
|
/**
|
* page 當前頁
|
* size 每頁大小
|
*/
|
@ApiOperation(value = "分頁", notes = "分頁")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name="page",value="當前頁數",required=true,paramType="path",dataType="Int"),
|
@ApiImplicitParam(name="size",value="每頁大小",required=true,paramType="path",dataType="Int")
|
})
|
@RequestMapping(value = "search/{page}/{size}", method = RequestMethod.GET)
|
public ResultMessage findBypage(@PathVariable("page") Integer page, @PathVariable("size") Integer size) {
|
|
log.info("page is:"+ page+" size is:"+size);
|
//根据条件分页查询
|
Page<Test> userPage = testService.selectByPage(null, page, size);
|
//封装分页返回对象
|
PageResult<Test> pageResult = new PageResult<>(
|
userPage.getTotal(), userPage.getPages(),userPage.getRecords()
|
);
|
//返回数据
|
return ResultMessage.ok(pageResult);
|
}
|
|
|
/**
|
* redis測試
|
*/
|
@ApiOperation(value = "redis測試", notes = "redis測試")
|
@RequestMapping(value = "redis", method = RequestMethod.GET)
|
public ResultMessage testRedis() {
|
RedisUtil.set("redistest","test");
|
return ResultMessage.ok(RedisUtil.get("redistest"));
|
|
}
|
|
/**
|
* 事務
|
*/
|
@ApiOperation(value = "事務測試", notes = "事務測試")
|
@RequestMapping(value = "saveTest", method = RequestMethod.GET)
|
public ResultMessage saveTest() throws Exception{
|
testService.saveTest();
|
return ResultMessage.ok();
|
|
}
|
|
/**
|
* kafka測試
|
*/
|
@ApiOperation(value = "kafka測試", notes = "kafka測試")
|
@RequestMapping(value = "kafkaTest", method = RequestMethod.GET)
|
public void kafkaTest() {
|
kafkaTemplate.send("test_topic","test111111111111111");
|
}
|
|
@GetMapping("test")
|
public void test(){
|
|
}
|
|
|
}
|
