package com.whyc.service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.whyc.dto.Response;
|
import com.whyc.mapper.Fbs9100sDfuStateMapper;
|
import com.whyc.pojo.Fbs9100sDfuState;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
|
@Service
|
public class Fbs9100sDfuStateService {
|
@Resource
|
private Fbs9100sDfuStateMapper mapper;
|
//查询正在升级的设备
|
public Response searchAll() {
|
List list=mapper.searchAll();
|
PageInfo pageInfo=new PageInfo(list);
|
return new Response().set(1,pageInfo);
|
}
|
|
public Response searchA059(int pageNum,int pageSize,String stationName1,String stationName2,String stationName5,int uId){
|
PageHelper.startPage(pageNum,pageSize);
|
List list = mapper.searchA059(stationName1,stationName2,stationName5,uId);
|
PageInfo<Fbs9100sDfuState> pageInfo = new PageInfo<>(list);
|
return new Response().set(1,pageInfo,"查询成功");
|
}
|
|
public Response updateA059(Fbs9100sDfuState fbs9100sDfuState){
|
//UpdateWrapper updateWrapper = new UpdateWrapper();
|
//updateWrapper.eq("dev_id",fbs9100sDfuState.getDevId());
|
int flag = 0;
|
if (fbs9100sDfuState.getDfuEn()==3){//升级失败
|
flag = mapper.updateDfuEn(fbs9100sDfuState.getNum());
|
}else {
|
flag = mapper.updateById(fbs9100sDfuState);
|
}
|
return new Response().set(1,flag>0?true:false);
|
}
|
|
//添加
|
public Response addPro(String stationName,int num) {
|
int flag=mapper.addPro(stationName,num);
|
return new Response().set(flag>0?1:0);
|
}
|
//批量升级
|
public Response updatePro(String dfuFile, List<Integer> devIds) {
|
int flag=mapper.updatePro(dfuFile,devIds);
|
return new Response().set(flag>0?1:0);
|
}
|
|
//查询添加列表
|
public Response serchInserStation(String stationName, int num) {
|
List list=mapper.serchInserStation(stationName,num);
|
PageInfo pageInfo=new PageInfo(list);
|
return new Response().set(1,pageInfo);
|
}
|
//验证设备是否允许设备进行远程升级
|
public Response judgeStation(List<Integer> devIds) {
|
List list=mapper.judgeStation(devIds);
|
PageInfo pageInfo=new PageInfo(list);
|
return new Response().set(1,pageInfo);
|
}
|
//更新设备更新的表格
|
public Response serchByCondition(List<Integer> devIds) {
|
QueryWrapper wrapper=new QueryWrapper();
|
wrapper.in("dev_id",devIds);
|
List list=mapper.selectList(wrapper);
|
PageInfo pageInfo=new PageInfo(list);
|
return new Response().set(1,pageInfo);
|
}
|
}
|