package com.whyc.service;
|
|
import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.whyc.dto.Response;
|
import com.whyc.mapper.MotorStateMapper;
|
import com.whyc.pojo.MotorState;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.text.DateFormat;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
|
@Service
|
@Slf4j
|
public class MotorStateService {
|
@Resource
|
private MotorStateMapper motorStateMapper;
|
|
public Response add(MotorState motorState){
|
if(motorStateMapper.insert(motorState)>0){
|
return new Response<>().set(1,true);
|
}else{
|
return new Response<>().set(0, false, "添加失败");
|
}
|
|
}
|
|
public Response update(MotorState motorState){
|
motorStateMapper.updateById(motorState);
|
return new Response().set(1, true, "修改成功");
|
}
|
|
public List<MotorState> getAll(){
|
return motorStateMapper.selectList(null);
|
}
|
|
/**
|
* 分页查询
|
* @param pageNum
|
* @param pageSize
|
* @return
|
*/
|
public Response<IPage<MotorState>> getAll(int pageNum,int pageSize){
|
QueryWrapper<MotorState> wrapper = Wrappers.query();
|
IPage<MotorState> page = motorStateMapper.selectPage(new Page<>(pageNum,pageSize),wrapper);
|
return new Response<IPage<MotorState>>().set(1,page);
|
}
|
|
|
public Response getById(int deviceId){
|
QueryWrapper<MotorState> wrapper = Wrappers.query();
|
wrapper.eq("device_id",deviceId);
|
MotorState motorState = motorStateMapper.selectOne(wrapper);
|
if(motorState!=null){
|
return new Response().set(1,motorState);
|
}else{
|
return new Response().set(0,false,"未找到此电机数据");
|
}
|
|
}
|
|
public boolean delete(int deviceId){
|
return motorStateMapper.deleteById(deviceId)>0;
|
}
|
|
/**
|
* 通过设备id，开始结束时间获取设备历史数据
|
* @param deviceId
|
* @param startTime
|
* @param endTime
|
* @return
|
*/
|
public List<MotorState> getHistoryData(String deviceId,String startTime,String endTime){
|
//获取时间拼接数据表名
|
String dateStr = startTime.substring(0,10).replace('-','_');
|
String tableName="tb_motor_state_realdata_"+deviceId+"_"+dateStr;
|
List<MotorState> data = motorStateMapper.getDataByTime(tableName,startTime,endTime);
|
return data;
|
}
|
|
}
|
