package com.nuvole.four.service.impl;
|
|
import cn.hutool.core.util.StrUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.nuvole.base.domain.SysUser;
|
import com.nuvole.four.contants.Contants;
|
import com.nuvole.four.domain.SpecialFeeRate;
|
import com.nuvole.four.domain.dto.SpecialFeeRateDto;
|
import com.nuvole.four.domain.dto.StoreIndustryManageDto;
|
import com.nuvole.four.domain.query.SpecialFeeRateQuery;
|
import com.nuvole.four.mapper.SpecialFeeRateMapper;
|
import com.nuvole.four.service.SpecialFeeRateService;
|
import com.nuvole.four.util.SystemUtil;
|
import com.nuvole.util.IdGenerator;
|
import com.walker.infrastructure.utils.CollectionUtils;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* @Description 行业管理-特殊行业费率Service实现类
|
* @Author dqh
|
* @Date 2024-04-12 19:57:28
|
*/
|
@Service
|
@RequiredArgsConstructor
|
public class SpecialFeeRateServiceImpl implements SpecialFeeRateService {
|
|
private final SpecialFeeRateMapper specialFeeRateMapper;
|
|
|
|
/**
|
* 方法描述:批处理特殊费率
|
* id为空则新增；有值则修改
|
**/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int addSelective(SpecialFeeRateDto entity){
|
entity.setDeleted((short) 0);
|
entity.setStatus((short) 1);
|
SysUser user = SystemUtil.getLoginUser(Contants.LOGIN_TYPE_PC);
|
List<SpecialFeeRate> rateList =new ArrayList<>();
|
//组装行业集合的数据；进行批量插入 或 更新
|
if(StrUtil.isNotBlank(entity.getIndustryManages())){
|
Object object = JSON.parse(entity.getIndustryManages());
|
if(object instanceof JSONArray){
|
List<StoreIndustryManageDto> manageList = JSONArray.parseArray(entity.getIndustryManages(), StoreIndustryManageDto.class);
|
for (StoreIndustryManageDto i : manageList) {
|
SpecialFeeRate rate = new SpecialFeeRate();
|
BeanUtils.copyProperties(entity, rate);
|
rate.setIndustryCode(i.getIndustryCode());
|
rate.setIndustryName(i.getIndustryName());
|
if (i.getId() == null) {
|
//新增自动生成id
|
rate.setId(IdGenerator.getId());
|
rate.setCreateBy(user.getId());
|
rate.setCreateTime(new Date());
|
}else{
|
//修改直接取传过来的id
|
rate.setId(i.getId());
|
rate.setUpdateBy(user.getId());
|
rate.setUpdateTime(new Date());
|
}
|
rateList.add(rate);
|
}
|
}
|
}
|
return specialFeeRateMapper.batchInsert(rateList);
|
}
|
|
@Override
|
public int editSelective(SpecialFeeRate entity){
|
return specialFeeRateMapper.updateByPrimaryKeySelective(entity);
|
}
|
@Override
|
public SpecialFeeRate get(Long id){
|
return specialFeeRateMapper.selectByPrimaryKey(id);
|
}
|
@Override
|
public int del(Long id){
|
return specialFeeRateMapper.deleteByPrimaryKey(id);
|
}
|
|
@Override
|
public List<SpecialFeeRate> getList(SpecialFeeRateQuery query) {
|
return specialFeeRateMapper.selectList(query);
|
}
|
|
/**
|
* 方法描述:特殊费率配置查询
|
**/
|
@Override
|
public SpecialFeeRateDto getConfig(Long industryId,Long channelId) {
|
//根据行业id，查询所属通道的所有特殊费率配置
|
List<SpecialFeeRate> specialFeeRateList = specialFeeRateMapper.selectByIndustryId(industryId,channelId);
|
SpecialFeeRateDto dto = new SpecialFeeRateDto();
|
if(!CollectionUtils.isEmpty(specialFeeRateList)){
|
JSONArray jsonArray = new JSONArray();
|
specialFeeRateList.forEach( s -> {
|
BeanUtils.copyProperties(s,dto);
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("id",String.valueOf(s.getId()));
|
jsonObject.put("industryCode",s.getIndustryCode());
|
jsonObject.put("industryName",s.getIndustryName());
|
jsonArray.add(jsonObject);
|
});
|
dto.setIndustryManages(jsonArray.toJSONString());
|
}
|
return dto;
|
}
|
}
|
