package com.huimv.center.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.huimv.center.pojo.BizDeviceRegisteredFlow;
import com.huimv.center.mapper.BizDeviceRegisteredFlowMapper;
import com.huimv.center.service.BizDeviceRegisteredFlowService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.huimv.center.utils.IDUtil;
import com.huimv.eartag2.common.utils.DateUtil;
import com.huimv.eartag2.common.utils.Result;
import com.huimv.eartag2.common.utils.ResultCode;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.text.ParseException;
/**
*
* 服务实现类
*
*
* @author zn
* @since 2022-06-22
*/
@Service
public class BizDeviceRegisteredFlowServiceImpl extends ServiceImpl implements BizDeviceRegisteredFlowService {
@Autowired
private BizDeviceRegisteredFlowMapper deviceRegisteredFlowMapper;
@Autowired
private com.huimv.center.utils.ResultUtil ResultUtil;
@Autowired
private IDUtil idUtil;
/**
* @Method : addRegisteredFlow
* @Description : 添加流水
* @Params : [chipId, deviceCode, clientIp]
* @Return : com.huimv.eartag2.common.utils.Result
*
* @Author : ZhuoNing
* @Date : 2022/6/23
* @Time : 17:07
*/
@Override
public Result addRegisteredFlow(String chipId,String deviceCode,String clientIp) throws ParseException {
DateUtil dateUtil = new DateUtil();
BizDeviceRegisteredFlow deviceRegisteredFlow = new BizDeviceRegisteredFlow();
deviceRegisteredFlow.setChipId(chipId);
deviceRegisteredFlow.setDeviceCode(deviceCode);
deviceRegisteredFlow.setClientIp(clientIp);
deviceRegisteredFlow.setAddTime(dateUtil.getTodayDatetime());
int rows = deviceRegisteredFlowMapper.insert(deviceRegisteredFlow);
return ResultUtil.result(rows);
}
/**
* @Method : removeRegisteredFlow
* @Description :
* @Params : [ids]
* @Return : com.huimv.eartag2.common.utils.Result
*
* @Author : ZhuoNing
* @Date : 2022/6/23
* @Time : 17:29
*/
@Override
public Result removeDeviceRegisteredFlow(String ids){
int rows = deviceRegisteredFlowMapper.deleteBatchIds(idUtil.convert(ids));
return ResultUtil.result(rows);
}
/**
* @Method : listDeviceRegisteredFlow
* @Description :
* @Params : [pageNo, pageSize, chipId]
* @Return : com.huimv.eartag2.common.utils.Result
*
* @Author : ZhuoNing
* @Date : 2022/6/23
* @Time : 18:01
*/
@Override
public Result listDeviceRegisteredFlow(Integer pageNo, Integer pageSize, String chipId, String deviceCode){
if(pageNo == 0){
pageNo = 1;
}
Page page = new Page<>(pageNo, pageSize);
QueryWrapper queryWrapper = new QueryWrapper<>();
// if(StringUtils.isNotEmpty(chipId)){
// queryWrapper.eq("chip_id", chipId);
// }
queryWrapper.like(StringUtils.isNotBlank(chipId),"chip_id", chipId);
queryWrapper.like(StringUtils.isNotBlank(deviceCode),"device_code", deviceCode);
//创建时间降序
queryWrapper.orderByDesc("id");
Page pageBizDeviceRegisteredFlow = deviceRegisteredFlowMapper.selectPage(page, queryWrapper);
return new Result(ResultCode.SUCCESS,pageBizDeviceRegisteredFlow);
}
}