package cn.gistack.sm.sjztmd.service.impl;
|
|
import cn.gistack.sm.sjztmd.entity.AttResStagCapDics;
|
import cn.gistack.sm.sjztmd.excel.AttResStagCapDiscExcel;
|
import cn.gistack.sm.sjztmd.mapper.AttResStagCapDicsMapper;
|
import cn.gistack.sm.sjztmd.service.IAttResStagCapDicsService;
|
import cn.gistack.system.user.entity.User;
|
import cn.gistack.system.user.feign.IUserClient;
|
import com.baomidou.dynamic.datasource.annotation.DS;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.springblade.core.secure.utils.AuthUtil;
|
import org.springblade.core.tool.utils.BeanUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Objects;
|
import java.util.stream.Collectors;
|
|
/**
|
* @ClassName AttResStagCapDicsServiceImpl
|
* @Description TODO
|
* @author zhongrj
|
* @date 2023/09/04
|
*/
|
@Service
|
@DS("zt")
|
public class AttResStagCapDicsServiceImpl extends ServiceImpl<AttResStagCapDicsMapper, AttResStagCapDics> implements IAttResStagCapDicsService {
|
|
/**
|
* 查询水库填报详情信息
|
* @param guid
|
* @return
|
*/
|
@Override
|
public List<AttResStagCapDics> getDetailByGuid(String guid) {
|
return baseMapper.getDetailByResGuid(guid);
|
}
|
|
/**
|
* 批量导入水库库容数据
|
* @param data
|
* @param resGuid 水库guid
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void importAttResStagCapDiscData(List<AttResStagCapDiscExcel> data,String resGuid) {
|
if (data.size()>0) {
|
// 判断是否为当前水库
|
// 先清空数据，再导入数据
|
QueryWrapper<AttResStagCapDics> wrapper = new QueryWrapper<>();
|
wrapper.eq("\"res_guid\"",data.get(0).getResGuid());
|
// 删除
|
boolean remove = remove(wrapper);
|
List<AttResStagCapDics> list = new ArrayList<>();
|
for (AttResStagCapDiscExcel capDiscExcel : data) {
|
// 判断是否为当前水库guid
|
if (null==capDiscExcel.getResGuid() || capDiscExcel.getResGuid().equals("") || !capDiscExcel.getResGuid().equals(resGuid)){
|
continue;
|
}
|
// 组装数据
|
AttResStagCapDics attResStagCapDics = Objects.requireNonNull(BeanUtil.copy(capDiscExcel, AttResStagCapDics.class));
|
// 设置日期数据
|
Date date = new Date();
|
attResStagCapDics.setCreateTime(date);
|
attResStagCapDics.setUpdateTime(date);
|
attResStagCapDics.setCollectTime(date);
|
attResStagCapDics.setSysResource("手工录入");
|
// 加入集合
|
list.add(attResStagCapDics);
|
}
|
// 批量新增
|
saveBatch(list);
|
}
|
}
|
}
|
