|
|
@ -72,155 +72,192 @@ import java.util.List; |
|
|
@Service |
|
|
@Service |
|
|
public class ScmCollectionRebateDistributionService extends MybatisBaseService<ScmCollectionRebateDistributionMapper, ScmCollectionRebateDistribution> { |
|
|
public class ScmCollectionRebateDistributionService extends MybatisBaseService<ScmCollectionRebateDistributionMapper, ScmCollectionRebateDistribution> { |
|
|
|
|
|
|
|
|
@Autowired |
|
|
@Autowired |
|
|
private ScmCollectionRebateDistributionVehService scmCollectionRebateDistributionVehService; |
|
|
private ScmCollectionRebateDistributionVehService scmCollectionRebateDistributionVehService; |
|
|
@Autowired |
|
|
@Autowired |
|
|
private SysUserFeign sysUserFeign; |
|
|
private SysUserFeign sysUserFeign; |
|
|
@Autowired |
|
|
@Autowired |
|
|
private ScmFileService scmFileService; |
|
|
private ScmFileService scmFileService; |
|
|
@Autowired |
|
|
@Autowired |
|
|
FileUploadComponent fileUploadComponent; |
|
|
FileUploadComponent fileUploadComponent; |
|
|
|
|
|
|
|
|
public PagerVo<ScmCollectionRebateDistributionVo> listPageVo(PagerQuery<ScmCollectionRebateDistributionQuery> pq) { |
|
|
public PagerVo<ScmCollectionRebateDistributionVo> listPageVo(PagerQuery<ScmCollectionRebateDistributionQuery> pq) { |
|
|
ScmCollectionRebateDistributionQuery query = pq.getParams(); |
|
|
ScmCollectionRebateDistributionQuery query = pq.getParams(); |
|
|
QueryWrapper<ScmCollectionRebateDistribution> qw = new QueryWrapper<>(); |
|
|
QueryWrapper<ScmCollectionRebateDistribution> qw = new QueryWrapper<>(); |
|
|
//========================================数据授权开始
|
|
|
//========================================数据授权开始
|
|
|
if (StringUtils.isNotBlank(query.getMenuUrl())) { |
|
|
if (StringUtils.isNotBlank(query.getMenuUrl())) { |
|
|
PrivilegeQuery privilegeQuery = new PrivilegeQuery(); |
|
|
PrivilegeQuery privilegeQuery = new PrivilegeQuery(); |
|
|
privilegeQuery.setOrgPath(query.getOrgPath()); |
|
|
privilegeQuery.setOrgPath(query.getOrgPath()); |
|
|
privilegeQuery.setMenuUrl(query.getMenuUrl()); |
|
|
privilegeQuery.setMenuUrl(query.getMenuUrl()); |
|
|
privilegeQuery.setMenuSid(query.getMenuSid()); |
|
|
privilegeQuery.setMenuSid(query.getMenuSid()); |
|
|
privilegeQuery.setUserSid(query.getUserSid()); |
|
|
privilegeQuery.setUserSid(query.getUserSid()); |
|
|
ResultBean<String> defaultIdReltBean = sysUserFeign.selectPrivilegeLevel(privilegeQuery); |
|
|
ResultBean<String> defaultIdReltBean = sysUserFeign.selectPrivilegeLevel(privilegeQuery); |
|
|
if (StringUtils.isNotBlank(defaultIdReltBean.getData())) { |
|
|
if (StringUtils.isNotBlank(defaultIdReltBean.getData())) { |
|
|
//数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
|
|
|
//数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
|
|
|
String orgSidPath = query.getOrgPath(); |
|
|
String orgSidPath = query.getOrgPath(); |
|
|
orgSidPath = orgSidPath + "/"; |
|
|
orgSidPath = orgSidPath + "/"; |
|
|
int i1 = orgSidPath.indexOf("/"); |
|
|
int i1 = orgSidPath.indexOf("/"); |
|
|
int i2 = orgSidPath.indexOf("/", i1 + 1); |
|
|
int i2 = orgSidPath.indexOf("/", i1 + 1); |
|
|
int i3 = orgSidPath.indexOf("/", i2 + 1); |
|
|
int i3 = orgSidPath.indexOf("/", i2 + 1); |
|
|
int i4 = orgSidPath.indexOf("/", i3 + 1); |
|
|
int i4 = orgSidPath.indexOf("/", i3 + 1); |
|
|
String orgLevelKey = defaultIdReltBean.getData(); |
|
|
String orgLevelKey = defaultIdReltBean.getData(); |
|
|
if ("1".equals(orgLevelKey)) { |
|
|
if ("1".equals(orgLevelKey)) { |
|
|
orgSidPath = orgSidPath.substring(0, i1); |
|
|
orgSidPath = orgSidPath.substring(0, i1); |
|
|
qw.like("u.orgSidPath", orgSidPath); |
|
|
qw.like("u.orgSidPath", orgSidPath); |
|
|
} else if ("2".equals(orgLevelKey)) { |
|
|
} else if ("2".equals(orgLevelKey)) { |
|
|
orgSidPath = orgSidPath.substring(0, i2); |
|
|
orgSidPath = orgSidPath.substring(0, i2); |
|
|
qw.like("u.orgSidPath", orgSidPath); |
|
|
qw.like("u.orgSidPath", orgSidPath); |
|
|
} else if ("3".equals(orgLevelKey)) { |
|
|
} else if ("3".equals(orgLevelKey)) { |
|
|
orgSidPath = orgSidPath.substring(0, i3); |
|
|
orgSidPath = orgSidPath.substring(0, i3); |
|
|
qw.like("u.orgSidPath", orgSidPath); |
|
|
qw.like("u.orgSidPath", orgSidPath); |
|
|
} else if ("4".equals(orgLevelKey)) { |
|
|
} else if ("4".equals(orgLevelKey)) { |
|
|
orgSidPath = orgSidPath.substring(0, i4); |
|
|
orgSidPath = orgSidPath.substring(0, i4); |
|
|
qw.like("u.orgSidPath", orgSidPath); |
|
|
qw.like("u.orgSidPath", orgSidPath); |
|
|
} else if ("5".equals(orgLevelKey)) { |
|
|
} else if ("5".equals(orgLevelKey)) { |
|
|
qw.eq("sd.createBySid", query.getUserSid()); |
|
|
qw.eq("sd.createBySid", query.getUserSid()); |
|
|
} else { |
|
|
} else { |
|
|
PagerVo<ScmCollectionRebateDistributionVo> p = new PagerVo<>(); |
|
|
PagerVo<ScmCollectionRebateDistributionVo> p = new PagerVo<>(); |
|
|
return p; |
|
|
return p; |
|
|
} |
|
|
} |
|
|
} else { |
|
|
} else { |
|
|
PagerVo<ScmCollectionRebateDistributionVo> p = new PagerVo<>(); |
|
|
PagerVo<ScmCollectionRebateDistributionVo> p = new PagerVo<>(); |
|
|
return p; |
|
|
return p; |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
if (StringUtils.isNotBlank(query.getCreateOrgName())){ |
|
|
if (query.getIsAuit()) { |
|
|
qw.like("sd.createOrgName",query.getCreateOrgName()); |
|
|
qw.ne("sd.state", 0); |
|
|
} |
|
|
} |
|
|
if (StringUtils.isNotBlank(query.getPurchaseSystemName())){ |
|
|
if (StringUtils.isNotBlank(query.getState())) { |
|
|
qw.like("sd.purchaseSystemName",query.getPurchaseSystemName()); |
|
|
qw.eq("sd.state", query.getState()); |
|
|
} |
|
|
} |
|
|
if (StringUtils.isNotBlank(query.getBrandName())){ |
|
|
if (StringUtils.isNotBlank(query.getCreateOrgName())) { |
|
|
qw.like("sd.brandName",query.getBrandName()); |
|
|
qw.like("sd.createOrgName", query.getCreateOrgName()); |
|
|
} |
|
|
} |
|
|
String subitDateStart = query.getSubitDateStart(); |
|
|
if (StringUtils.isNotBlank(query.getPurchaseSystemName())) { |
|
|
String subitDateEnd = query.getSubitDateEnd(); |
|
|
qw.like("sd.purchaseSystemName", query.getPurchaseSystemName()); |
|
|
qw.apply(StringUtils.isNotBlank(subitDateStart), "date_format (sd.subitDate,'%Y-%m-%d') >= date_format('" + subitDateStart + "','%Y-%m-%d')"). |
|
|
} |
|
|
apply(StringUtils.isNotBlank(subitDateEnd), "date_format (sd.subitDate,'%Y-%m-%d') <= date_format('" + subitDateEnd + "','%Y-%m-%d')" |
|
|
if (StringUtils.isNotBlank(query.getBrandName())) { |
|
|
); |
|
|
qw.like("sd.brandName", query.getBrandName()); |
|
|
IPage<ScmCollectionRebateDistribution> page = PagerUtil.queryToPage(pq); |
|
|
} |
|
|
IPage<ScmCollectionRebateDistributionVo> pagging = baseMapper.selectPageVo(page, qw); |
|
|
String subitDateStart = query.getSubitDateStart(); |
|
|
PagerVo<ScmCollectionRebateDistributionVo> p = PagerUtil.pageToVo(pagging, null); |
|
|
String subitDateEnd = query.getSubitDateEnd(); |
|
|
return p; |
|
|
qw.apply(StringUtils.isNotBlank(subitDateStart), "date_format (sd.subitDate,'%Y-%m-%d') >= date_format('" + subitDateStart + "','%Y-%m-%d')"). |
|
|
} |
|
|
apply(StringUtils.isNotBlank(subitDateEnd), "date_format (sd.subitDate,'%Y-%m-%d') <= date_format('" + subitDateEnd + "','%Y-%m-%d')" |
|
|
|
|
|
); |
|
|
|
|
|
qw.groupBy("sd.sid"); |
|
|
|
|
|
IPage<ScmCollectionRebateDistribution> page = PagerUtil.queryToPage(pq); |
|
|
|
|
|
IPage<ScmCollectionRebateDistributionVo> pagging = baseMapper.selectPageVo(page, qw); |
|
|
|
|
|
PagerVo<ScmCollectionRebateDistributionVo> p = PagerUtil.pageToVo(pagging, null); |
|
|
|
|
|
return p; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
public ResultBean saveOrUpdateDto(ScmCollectionRebateDistributionDto dto){ |
|
|
public ResultBean saveOrUpdateDto(ScmCollectionRebateDistributionDto dto) { |
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
String dtoSid = dto.getSid(); |
|
|
String dtoSid = dto.getSid(); |
|
|
List<ScmCollectionRebateDistributionFile> urls = dto.getUrls(); |
|
|
List<ScmCollectionRebateDistributionFile> urls = dto.getUrls(); |
|
|
List<ScmCollectionRebateDistributionVehDto> scmCollectionRebateVehs = dto.getScmCollectionRebateVehs(); |
|
|
List<ScmCollectionRebateDistributionVehDto> scmCollectionRebateVehs = dto.getScmCollectionRebateVehs(); |
|
|
if (StringUtils.isBlank(dtoSid)) { |
|
|
String state = dto.getState(); |
|
|
String sid = this.insertByDto(dto); |
|
|
if ("0".equals(state)) { |
|
|
if (!scmCollectionRebateVehs.isEmpty()){ |
|
|
if (StringUtils.isBlank(dtoSid)) { |
|
|
for (ScmCollectionRebateDistributionVehDto scmCollectionRebateVehDto : scmCollectionRebateVehs) { |
|
|
String sid = this.insertByDto(dto); |
|
|
scmCollectionRebateVehDto.setMainSid(sid); |
|
|
if (scmCollectionRebateVehs != null) { |
|
|
scmCollectionRebateDistributionVehService.insertByDto(scmCollectionRebateVehDto); |
|
|
for (ScmCollectionRebateDistributionVehDto scmCollectionRebateVehDto : scmCollectionRebateVehs) { |
|
|
} |
|
|
scmCollectionRebateVehDto.setMainSid(sid); |
|
|
} |
|
|
scmCollectionRebateDistributionVehService.insertByDto(scmCollectionRebateVehDto); |
|
|
for (ScmCollectionRebateDistributionFile url : urls) { |
|
|
} |
|
|
String filePath = url.getUrl().replace(fileUploadComponent.getUrlPrefix(), ""); |
|
|
} |
|
|
ScmFile scmFile = new ScmFile(); |
|
|
for (ScmCollectionRebateDistributionFile url : urls) { |
|
|
scmFile.setFilePath(filePath); |
|
|
String filePath = url.getUrl().replace(fileUploadComponent.getUrlPrefix(), ""); |
|
|
scmFile.setLinkSid(sid); |
|
|
ScmFile scmFile = new ScmFile(); |
|
|
scmFileService.save(scmFile); |
|
|
scmFile.setFilePath(filePath); |
|
|
} |
|
|
scmFile.setLinkSid(sid); |
|
|
return rb.success().setMsg("添加成功"); |
|
|
scmFileService.save(scmFile); |
|
|
|
|
|
} |
|
|
|
|
|
return rb.success().setMsg("添加成功"); |
|
|
|
|
|
} |
|
|
|
|
|
ScmCollectionRebateDistribution scmCollectionRebateDistribution = fetchBySid(dtoSid); |
|
|
|
|
|
if (scmCollectionRebateDistribution == null) { |
|
|
|
|
|
return rb.setMsg("该分配信息不存在"); |
|
|
|
|
|
} |
|
|
|
|
|
this.updateByDto(dto); |
|
|
|
|
|
scmCollectionRebateDistributionVehService.delByMainSid(dtoSid); |
|
|
|
|
|
scmFileService.delByMainSid(dtoSid); |
|
|
|
|
|
if (scmCollectionRebateVehs != null) { |
|
|
|
|
|
for (ScmCollectionRebateDistributionVehDto scmCollectionRebateVehDto : scmCollectionRebateVehs) { |
|
|
|
|
|
scmCollectionRebateVehDto.setMainSid(dtoSid); |
|
|
|
|
|
scmCollectionRebateDistributionVehService.insertByDto(scmCollectionRebateVehDto); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
for (ScmCollectionRebateDistributionFile url : urls) { |
|
|
|
|
|
String filePath = url.getUrl().replace(fileUploadComponent.getUrlPrefix(), ""); |
|
|
|
|
|
ScmFile scmFile = new ScmFile(); |
|
|
|
|
|
scmFile.setFilePath(filePath); |
|
|
|
|
|
scmFile.setLinkSid(dtoSid); |
|
|
|
|
|
scmFileService.save(scmFile); |
|
|
|
|
|
} |
|
|
|
|
|
return rb.success().setMsg("修改成功"); |
|
|
|
|
|
} else if ("1".equals(state)) { |
|
|
|
|
|
baseMapper.updateStateAndSubmitDate(dtoSid, state); |
|
|
|
|
|
return rb.success().setMsg("提交成功"); |
|
|
|
|
|
} else if ("2".equals(state)) { |
|
|
|
|
|
baseMapper.updateState(dtoSid, state); |
|
|
|
|
|
return rb.success().setMsg("确认成功"); |
|
|
|
|
|
} else if ("3".equals(state)) { |
|
|
|
|
|
baseMapper.updateState(dtoSid, state); |
|
|
|
|
|
return rb.success().setMsg("退回成功"); |
|
|
} |
|
|
} |
|
|
ScmCollectionRebateDistribution scmCollectionRebateDistribution = fetchBySid(dtoSid); |
|
|
return rb.success(); |
|
|
if (scmCollectionRebateDistribution == null){ |
|
|
} |
|
|
return rb.setMsg("该分配信息不存在"); |
|
|
|
|
|
} |
|
|
|
|
|
this.updateByDto(dto); |
|
|
|
|
|
scmCollectionRebateDistributionVehService.delByMainSid(dtoSid); |
|
|
|
|
|
scmFileService.delByMainSid(dtoSid); |
|
|
|
|
|
if (!scmCollectionRebateVehs.isEmpty()){ |
|
|
|
|
|
for (ScmCollectionRebateDistributionVehDto scmCollectionRebateVehDto : scmCollectionRebateVehs) { |
|
|
|
|
|
scmCollectionRebateVehDto.setMainSid(dtoSid); |
|
|
|
|
|
scmCollectionRebateDistributionVehService.insertByDto(scmCollectionRebateVehDto); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
for (ScmCollectionRebateDistributionFile url : urls) { |
|
|
|
|
|
String filePath = url.getUrl().replace(fileUploadComponent.getUrlPrefix(), ""); |
|
|
|
|
|
ScmFile scmFile = new ScmFile(); |
|
|
|
|
|
scmFile.setFilePath(filePath); |
|
|
|
|
|
scmFile.setLinkSid(dtoSid); |
|
|
|
|
|
scmFileService.save(scmFile); |
|
|
|
|
|
} |
|
|
|
|
|
return rb.success().setMsg("修改成功"); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public String insertByDto(ScmCollectionRebateDistributionDto dto){ |
|
|
public String insertByDto(ScmCollectionRebateDistributionDto dto) { |
|
|
ScmCollectionRebateDistribution entity = new ScmCollectionRebateDistribution(); |
|
|
ScmCollectionRebateDistribution entity = new ScmCollectionRebateDistribution(); |
|
|
BeanUtil.copyProperties(dto, entity, "id", "sid"); |
|
|
BeanUtil.copyProperties(dto, entity, "id", "sid"); |
|
|
baseMapper.insert(entity); |
|
|
baseMapper.insert(entity); |
|
|
return entity.getSid(); |
|
|
return entity.getSid(); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
public void updateByDto(ScmCollectionRebateDistributionDto dto){ |
|
|
public void updateByDto(ScmCollectionRebateDistributionDto dto) { |
|
|
String dtoSid = dto.getSid(); |
|
|
String dtoSid = dto.getSid(); |
|
|
if (StringUtils.isBlank(dtoSid)) { |
|
|
if (StringUtils.isBlank(dtoSid)) { |
|
|
return; |
|
|
return; |
|
|
} |
|
|
} |
|
|
ScmCollectionRebateDistribution entity = fetchBySid(dtoSid); |
|
|
ScmCollectionRebateDistribution entity = fetchBySid(dtoSid); |
|
|
BeanUtil.copyProperties(dto, entity, "id", "sid"); |
|
|
BeanUtil.copyProperties(dto, entity, "id", "sid"); |
|
|
baseMapper.updateById(entity); |
|
|
baseMapper.updateById(entity); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public ResultBean<ScmCollectionRebateDistributionDetailsVo> fetchDetailsVoBySid(String sid) { |
|
|
|
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
|
|
|
ScmCollectionRebateDistribution entity = fetchBySid(sid); |
|
|
|
|
|
ScmCollectionRebateDistributionDetailsVo vo = new ScmCollectionRebateDistributionDetailsVo(); |
|
|
|
|
|
BeanUtil.copyProperties(entity, vo); |
|
|
|
|
|
List<ScmCollectionRebateDistributionVehDetailsVo> scmCollectionRebateDistributionVehDetailsVos = scmCollectionRebateDistributionVehService.selByMainSid(sid); |
|
|
|
|
|
vo.setScmCollectionRebateVehs(scmCollectionRebateDistributionVehDetailsVos); |
|
|
|
|
|
List<ScmFileVo> scmFileVos = scmFileService.fetchByMainSid(sid); |
|
|
|
|
|
List<ScmCollectionRebateDistributionFile> urls = new ArrayList<>(); |
|
|
|
|
|
for (ScmFileVo scmFileVo : scmFileVos) { |
|
|
|
|
|
ScmCollectionRebateDistributionFile scmCollectionRebateDistributionFile = new ScmCollectionRebateDistributionFile(); |
|
|
|
|
|
scmCollectionRebateDistributionFile.setUrl(fileUploadComponent.getUrlPrefix() + scmFileVo.getFilePath()); |
|
|
|
|
|
urls.add(scmCollectionRebateDistributionFile); |
|
|
|
|
|
} |
|
|
|
|
|
vo.setUrls(urls); |
|
|
|
|
|
return rb.success().setData(vo); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
public ResultBean<ScmCollectionRebateDistributionDetailsVo> fetchDetailsVoBySid(String sid){ |
|
|
public ResultBean<List<String>> selVinNo() { |
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
ScmCollectionRebateDistribution entity = fetchBySid(sid); |
|
|
List<String> vinNos = baseMapper.selVinNo(); |
|
|
ScmCollectionRebateDistributionDetailsVo vo = new ScmCollectionRebateDistributionDetailsVo(); |
|
|
return rb.success().setData(vinNos); |
|
|
BeanUtil.copyProperties(entity, vo); |
|
|
} |
|
|
List<ScmCollectionRebateDistributionVehDetailsVo> scmCollectionRebateDistributionVehDetailsVos = scmCollectionRebateDistributionVehService.selByMainSid(sid); |
|
|
|
|
|
vo.setScmCollectionRebateVehs(scmCollectionRebateDistributionVehDetailsVos); |
|
|
public ResultBean delAll(String[] sids) { |
|
|
List<ScmFileVo> scmFileVos = scmFileService.fetchByMainSid(sid); |
|
|
ResultBean rb = ResultBean.fireFail(); |
|
|
List<ScmCollectionRebateDistributionFile> urls = new ArrayList<>(); |
|
|
//查询该sid中是否有流程不是待提交的
|
|
|
for (ScmFileVo scmFileVo : scmFileVos) { |
|
|
int count = baseMapper.selectBySid(StringUtils.join(sids, ",")); |
|
|
ScmCollectionRebateDistributionFile scmCollectionRebateDistributionFile = new ScmCollectionRebateDistributionFile(); |
|
|
if (count > 0) { |
|
|
scmCollectionRebateDistributionFile.setUrl(fileUploadComponent.getUrlPrefix() + scmFileVo.getFilePath()); |
|
|
return rb.setMsg("删除的数据中包含已经提交审批的数据，删除失败"); |
|
|
urls.add(scmCollectionRebateDistributionFile); |
|
|
} |
|
|
} |
|
|
delBySids(sids); |
|
|
vo.setUrls(urls); |
|
|
return rb.success(); |
|
|
return rb.success().setData(vo); |
|
|
} |
|
|
} |
|
|
|
|
|
} |
|
|
} |
God
8 months ago