package org.springblade.jfpt.animalheat.service.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.springblade.jfpt.animalheat.entity.BladeAnimalHeat;
|
import org.springblade.jfpt.animalheat.mapper.AnimalHeatMapper;
|
import org.springblade.jfpt.animalheat.service.AnimalHeatService;
|
import org.springblade.jfpt.animalheat.util.ImageUtil;
|
import org.springblade.jfpt.animalheat.vo.AnimalHeatVo;
|
import org.springblade.jfpt.animalheat.vo.StatisVo;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.validation.Valid;
|
import java.util.List;
|
import java.util.Map;
|
import static org.springblade.core.tool.utils.DateUtil.now;
|
|
/**
|
* 体温数据服务层
|
*
|
*/
|
@Service
|
public class AnimalHeatServiceImpl extends ServiceImpl<AnimalHeatMapper, BladeAnimalHeat> implements AnimalHeatService {
|
@Override
|
public boolean save(BladeAnimalHeat entity) {
|
return false;
|
}
|
|
@Value("${picture.addUrl}")
|
private String picAddUrl;
|
|
@Value("${picture.pre}")
|
private String picPre;
|
|
|
/**
|
* 新增体温数据
|
* @param body 体温数据
|
*/
|
@Override
|
@Transactional
|
public void save(String body) {
|
//1.截取信息
|
int i = body.indexOf("{");
|
//2.从 ｛ 处开始截取
|
int length = body.length();
|
//3.截取,由于获取数据时，｝ 被去除，需要加上
|
String dataBody = body.substring(i, length)+"}";
|
System.out.println("dataBody = " + dataBody);
|
//4.数据转换
|
Map<String,Object> data = (Map<String, Object>) JSONObject.parse(dataBody);
|
System.out.println("data = " + data);
|
//5.创建体温数据对象
|
BladeAnimalHeat bladeAnimalHeat = new BladeAnimalHeat();
|
//6.取出数据，封装数据到对象
|
String picture = data.get("picture").toString();
|
//将二进制原始图片转换成图片
|
ImageUtil.base64StringToImage(picture);
|
//bladeAnimalHeat.setPicture(data.get("picture").toString()); //暂时不存入
|
String temp_red =data.get("temp_red").toString();
|
String[] temRedArr = temp_red.substring(1,temp_red.length()-1).split(",");
|
if (temRedArr.length>1){
|
//比较两个温度的大小，取大的值
|
float v = Float.parseFloat(temRedArr[0]);
|
float v1 = Float.parseFloat(temRedArr[1]);
|
int compare = Float.compare(v, v1);
|
bladeAnimalHeat.setTempRed(compare>=0 ? v:v1);
|
//和标志温度比较，大于37度为高温，标记为1，小于则为正常0
|
int compare1 = Float.compare(37, compare >= 0 ? v : v1);
|
bladeAnimalHeat.setStatus(compare1>0 ?0:1);
|
}else {
|
bladeAnimalHeat.setTempRed(Float.parseFloat(temRedArr[0]));
|
int compare1 = Float.compare(37, Float.parseFloat(temRedArr[0]));
|
bladeAnimalHeat.setStatus(compare1>0 ?0:1);
|
}
|
String person_rects = data.get("person_rect").toString();
|
bladeAnimalHeat.setPersonRect(person_rects.substring(2,person_rects.length()-2));
|
bladeAnimalHeat.setCreateTime(now());
|
//7.插入数据
|
int idata = baseMapper.insert(bladeAnimalHeat);
|
}
|
|
|
/**
|
* 获取体温数据统计
|
* @param animalHeatVo 条件参数 开始时间，结束时间
|
* @return
|
*/
|
@Override
|
public List<StatisVo> getAnimalStatis(AnimalHeatVo animalHeatVo) {
|
if(null!= animalHeatVo.getStatus()){
|
//查询当天的统计数据
|
if (animalHeatVo.getStatus()==0){
|
return baseMapper.getAnimalStatis();
|
}
|
//查询本周的统计数据
|
if (animalHeatVo.getStatus()==1){
|
return baseMapper.getAnimalStatisWeek();
|
}
|
}
|
return null;
|
}
|
|
|
/**
|
* 体温数据的分页数据
|
* @param animalHeatVo 查询条件
|
* @param page 查询页码
|
* @return
|
*/
|
@Override
|
public IPage<BladeAnimalHeat> selectAnimalHeatPage(IPage<BladeAnimalHeat> page, AnimalHeatVo animalHeatVo) {
|
return page.setRecords(baseMapper.selectAnimalHeatPageList(page, animalHeatVo));
|
}
|
}
|
