czg_team/chaozhanggui
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改队列数据

Browse Source
This commit is contained in:
韩鹏辉
2023-07-07 18:00:54 +08:00
parent 457b5ce724
commit bcaea4df88
1 changed files with 14 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
pluss-service-bundle/src/main/java/cn/pluss/platform/sys/impl/QueueDataServiceImpl.java
View File

@@ -3,6 +3,7 @@ package cn.pluss.platform.sys.impl;
import cn.pluss.platform.entity.QueueData; import cn.pluss.platform.entity.QueueData;
import cn.pluss.platform.mapper.QueueDataMapper; import cn.pluss.platform.mapper.QueueDataMapper;
import cn.pluss.platform.sys.QueueDataService; import cn.pluss.platform.sys.QueueDataService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Propagation;
@@ -29,14 +30,20 @@ public class QueueDataServiceImpl extends ServiceImpl<QueueDataMapper, QueueData
public Integer newQueueData(String id) { public Integer newQueueData(String id) {
QueueData entity = new QueueData(); QueueData entity = new QueueData();
entity.setId(id); entity.setId(id);
QueryWrapper<QueueData> queryWrapper=new QueryWrapper<>();
queryWrapper.eq("id",id);
int countId= baseMapper.selectCount(queryWrapper);
int count=-1;
if(countId<=0){
try {
count = baseMapper.insert(entity);
} catch (Exception e) {
e.printStackTrace();
return -1;
}
}
int count;
try {
count = baseMapper.insert(entity);
} catch (Exception e) {
e.printStackTrace();
return -1;
}
return count; return count;
} }