Browse Source

迁移风控参数模块、开发财务参数接口

master
fanzongzhe 2 years ago
parent
commit
e1d40d161d
  1. 5
      anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basedistributor/BaseDistributorService.java
  2. 5
      anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basedistributorapply/BaseDistributorApplyService.java
  3. 5
      anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/busdeliveredapply/BusDeliveredApplyService.java
  4. 7
      anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/finbillapplication/FinBillApplicationService.java
  5. 30
      anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameter.java
  6. 32
      anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameterDetailsVo.java
  7. 33
      anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameterDto.java
  8. 80
      anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameterFeign.java
  9. 60
      anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameterFeignFallback.java
  10. 29
      anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameterQuery.java
  11. 25
      anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameterVo.java
  12. 35
      anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysparameter/SysParameterMapper.java
  13. 35
      anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysparameter/SysParameterMapper.xml
  14. 74
      anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysparameter/SysParameterRest.java
  15. 310
      anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysparameter/SysParameterService.java

5
anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basedistributor/BaseDistributorService.java

@ -40,6 +40,7 @@ import com.yxt.anrui.flowable.api.utils.ProcDefEnum;
import com.yxt.anrui.flowable.sqloperationsymbol.BusinessVariables;
import com.yxt.anrui.portal.api.sysorganization.SysOrganizationFeign;
import com.yxt.anrui.portal.api.sysorganization.SysOrganizationVo;
import com.yxt.anrui.portal.api.sysparameter.SysParameterFeign;
import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrg;
import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgFeign;
import com.yxt.anrui.portal.api.sysuser.PrivilegeQuery;
@ -117,7 +118,7 @@ public class BaseDistributorService extends MybatisBaseService<BaseDistributorMa
@Autowired
private BaseDistributorApplyService baseDistributorApplyService;
@Autowired
private LoanParameterFeign loanParameterFeign;
private SysParameterFeign sysParameterFeign;
/**
* 经销商分页列表
@ -1336,7 +1337,7 @@ public class BaseDistributorService extends MybatisBaseService<BaseDistributorMa
vo.setDistributorSid(sid);
vo.setApplyDate(new Date());
//----风控参数中获取有效期------
String jxsbayxq = loanParameterFeign.fetchByParNo("JXSBAYXQ").getData();
String jxsbayxq = sysParameterFeign.fetchByParNo("JXSBAYXQ").getData();
if (StringUtils.isNotBlank(jxsbayxq)) {
Date dateByDay = getDateByDay(new Date(), Integer.valueOf(jxsbayxq));
vo.setEffectiveDate(DateUtil.format(dateByDay, "yyyy-MM-dd"));

5
anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/basedistributorapply/BaseDistributorApplyService.java

@ -55,6 +55,7 @@ import com.yxt.anrui.flowable.api.processcomment.ProcessCommentFeign;
import com.yxt.anrui.flowable.api.utils.ProcDefEnum;
import com.yxt.anrui.flowable.sqloperationsymbol.BusinessVariables;
import com.yxt.anrui.portal.api.sysorganization.*;
import com.yxt.anrui.portal.api.sysparameter.SysParameterFeign;
import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrg;
import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgFeign;
import com.yxt.anrui.portal.api.sysuser.PrivilegeQuery;
@ -120,7 +121,7 @@ public class BaseDistributorApplyService extends MybatisBaseService<BaseDistribu
@Autowired
private BaseDistributorAppendixService baseDistributorAppendixService;
@Autowired
private LoanParameterFeign loanParameterFeign;
private SysParameterFeign sysParameterFeign;
@Autowired
private BaseDistributorApplyService baseDistributorApplyService;
@Autowired
@ -1252,7 +1253,7 @@ public class BaseDistributorApplyService extends MybatisBaseService<BaseDistribu
AppSalesDeptVo appSalesDeptVo = new AppSalesDeptVo();
appSalesDeptVo.setApplyDate(sdf.format(new Date()));
//----风控参数中获取有效期------
String jxsbayxq = loanParameterFeign.fetchByParNo("JXSBAYXQ").getData();
String jxsbayxq = sysParameterFeign.fetchByParNo("JXSBAYXQ").getData();
if (StringUtils.isNotBlank(jxsbayxq)) {
Date dateByDay = getDateByDay(new Date(), Integer.valueOf(jxsbayxq));
appSalesDeptVo.setEffectiveDate(DateUtil.format(dateByDay, "yyyy-MM-dd"));

5
anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/busdeliveredapply/BusDeliveredApplyService.java

@ -135,6 +135,7 @@ import com.yxt.anrui.portal.api.dictcommon.DictCommonFeign;
import com.yxt.anrui.portal.api.dictcommon.DictCommonVo;
import com.yxt.anrui.portal.api.sysorganization.SysOrganizationFeign;
import com.yxt.anrui.portal.api.sysorganization.SysOrganizationVo;
import com.yxt.anrui.portal.api.sysparameter.SysParameterFeign;
import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgFeign;
import com.yxt.anrui.portal.api.sysuser.PrivilegeQuery;
import com.yxt.anrui.portal.api.sysuser.SysUserFeign;
@ -252,7 +253,7 @@ public class BusDeliveredApplyService extends MybatisBaseService<BusDeliveredApp
@Autowired
private BusBillTrailerService busBillTrailerService;
@Autowired
private LoanParameterFeign loanParameterFeign;
private SysParameterFeign sysParameterFeign;
@Autowired
private BusValcustFilingService busValcustFilingService;
@Autowired
@ -928,7 +929,7 @@ public class BusDeliveredApplyService extends MybatisBaseService<BusDeliveredApp
int i = money.compareTo(BigDecimal.ZERO);
if (i == 1) {
busValcustFilingDto.setIsGdk("0");
String parameterValue = loanParameterFeign.fetchByParNo("CW_JZPZSXFBL").getData();
String parameterValue = sysParameterFeign.fetchByParNo("CW_JZPZSXFBL").getData();
busValcustFilingDto.setYsMoney(money.multiply(new BigDecimal(parameterValue)).toString());
} else {
busValcustFilingDto.setIsGdk("1");

7
anrui-fin/anrui-fin-biz/src/main/java/com/yxt/anrui/fin/biz/finbillapplication/FinBillApplicationService.java

@ -99,6 +99,7 @@ import com.yxt.anrui.flowable.sqloperationsymbol.BusinessVariables;
import com.yxt.anrui.portal.api.flow.PCHistTaskListAndCommentList;
import com.yxt.anrui.portal.api.sysorganization.SysOrganizationFeign;
import com.yxt.anrui.portal.api.sysorganization.SysOrganizationVo;
import com.yxt.anrui.portal.api.sysparameter.SysParameterFeign;
import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrg;
import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgFeign;
import com.yxt.anrui.portal.api.sysuser.*;
@ -211,7 +212,7 @@ public class FinBillApplicationService extends MybatisBaseService<FinBillApplica
@Autowired
private BusValcustFilingFeign busValcustFilingFeign;
@Autowired
private LoanParameterFeign loanParameterFeign;
private SysParameterFeign sysParameterFeign;
private QueryWrapper<FinBillApplication> createQueryWrapper(FinBillApplicationQuery query) {
// todo: 这里根据具体业务调整查询条件
@ -787,7 +788,7 @@ public class FinBillApplicationService extends MybatisBaseService<FinBillApplica
int i = money.compareTo(BigDecimal.ZERO);
if (i == 1) {
busValcustFilingDto.setIsGdk("0");
String parameterValue = loanParameterFeign.fetchByParNo("CW_JZPZSXFBL").getData();
String parameterValue = sysParameterFeign.fetchByParNo("CW_JZPZSXFBL").getData();
busValcustFilingDto.setYsMoney(money.multiply(new BigDecimal(parameterValue)).toString());
} else {
busValcustFilingDto.setIsGdk("1");
@ -2286,7 +2287,7 @@ public class FinBillApplicationService extends MybatisBaseService<FinBillApplica
int i = money.compareTo(BigDecimal.ZERO);
if (i == 1) {
busValcustFilingDto.setIsGdk("0");
String parameterValue = loanParameterFeign.fetchByParNo("CW_JZPZSXFBL").getData();
String parameterValue = sysParameterFeign.fetchByParNo("CW_JZPZSXFBL").getData();
busValcustFilingDto.setYsMoney(money.multiply(new BigDecimal(parameterValue)).toString());
} else {
busValcustFilingDto.setIsGdk("1");

30
anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameter.java

@ -0,0 +1,30 @@
package com.yxt.anrui.portal.api.sysparameter;
import com.baomidou.mybatisplus.annotation.TableName;
import com.yxt.common.core.domain.BaseEntity;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @author Administrator
* @description
* @date 2023/8/16 14:34
*/
@Data
@ApiModel(value = "风控参数、财务参数", description = "风控参数、财务参数")
@TableName("sys_parameter")
public class SysParameter extends BaseEntity {
@ApiModelProperty("参数编码")
private String parameterNo;
@ApiModelProperty("参数名称")
private String parameterName;
@ApiModelProperty("参数值")
private String parameterValue;
@ApiModelProperty("使用组织sid")
private String useOrgSid;
@ApiModelProperty("使用组织名称")
private String useOrgName;
@ApiModelProperty("使用组织全路径")
private String orgSidPath;
}

32
anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameterDetailsVo.java

@ -0,0 +1,32 @@
package com.yxt.anrui.portal.api.sysparameter;
import com.yxt.common.core.vo.Vo;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.ArrayList;
import java.util.List;
/**
* @author Administrator
* @description
* @date 2023/8/21 9:13
*/
@Data
public class SysParameterDetailsVo implements Vo {
private String sid;
private String remarks;
private String userSid;
@ApiModelProperty("参数编码")
private String parameterNo;
@ApiModelProperty("参数名称")
private String parameterName;
@ApiModelProperty("参数值")
private String parameterValue;
@ApiModelProperty("使用组织全路径")
private String orgPath;
@ApiModelProperty("使用组织sid")
private List<String> useOrgSids = new ArrayList<>();
@ApiModelProperty("使用组织名称")
private List<String> useOrgNames = new ArrayList<>();
}

33
anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameterDto.java

@ -0,0 +1,33 @@
package com.yxt.anrui.portal.api.sysparameter;
import com.yxt.common.core.dto.Dto;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.ArrayList;
import java.util.List;
/**
* @author Administrator
* @description
* @date 2023/8/21 9:12
*/
@Data
public class SysParameterDto implements Dto {
private String sid;
private String remarks;
private String userSid;
@ApiModelProperty("参数编码")
private String parameterNo;
@ApiModelProperty("参数名称")
private String parameterName;
@ApiModelProperty("参数值")
private String parameterValue;
@ApiModelProperty("使用组织全路径")
private String orgPath;
@ApiModelProperty("使用组织sid")
private List<String> useOrgSids = new ArrayList<>();
@ApiModelProperty("使用组织名称")
private List<String> useOrgNames = new ArrayList<>();
}

80
anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameterFeign.java

@ -0,0 +1,80 @@
package com.yxt.anrui.portal.api.sysparameter;
import com.yxt.common.core.query.PagerQuery;
import com.yxt.common.core.result.ResultBean;
import com.yxt.common.core.vo.PagerVo;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.*;
/**
* @description: 风控参数
* @author: fan
* @date: 2023/7/6
**/
@Api(tags = "风控参数")
@FeignClient(
contextId = "anrui-portal-SysParameter",
name = "anrui-portal",
path = "v1/sysparameter",
fallback = SysParameterFeignFallback.class)
public interface SysParameterFeign {
/**
* 根据条件分页查询数据的列表已测试
*
* @param pq
*/
@ApiOperation("根据条件分页查询数据的列表")
@PostMapping("/listPage")
public ResultBean<PagerVo<SysParameterVo>> listPage(@RequestBody PagerQuery<SysParameterQuery> pq);
@ApiOperation("新增或修改")
@PostMapping("/saveOrUpdate")
@ResponseBody
public ResultBean saveOrUpdateParameter(@RequestBody SysParameterDto dto);
@ApiOperation("批量删除")
@DeleteMapping("/deleteBySids")
@ResponseBody
public ResultBean deleteBySids(@RequestBody String[] sids);
@ApiOperation("根据SID获取一条记录")
@GetMapping("/fetchDetailsBySid/{sid}")
@ResponseBody
public ResultBean<SysParameterDetailsVo> fetchDetailsBySid(@PathVariable("sid") String sid);
@ApiOperation("根据参数编码查询参数值")
@PostMapping("/fetchByParNo")
@ResponseBody
ResultBean<String> fetchByParNo(@RequestParam("parNo") String parNo);
@ApiOperation("根据参数编码查询记录")
@PostMapping("/fetchOneByParNo")
@ResponseBody
ResultBean<SysParameter> fetchOneByParNo(@RequestParam("parNo") String parNo);
/**
* 根据条件分页查询数据的列表已测试
*
* @param pq
*/
@ApiOperation("根据条件分页查询财务参数数据的列表")
@PostMapping("/finListPage")
public ResultBean<PagerVo<SysParameterVo>> finListPage(@RequestBody PagerQuery<SysParameterQuery> pq);
@ApiOperation("新增或修改")
@PostMapping("/finSave")
@ResponseBody
public ResultBean finSaveParameter(@RequestBody SysParameterDto dto);
@ApiOperation("根据SID获取一条记录")
@GetMapping("/fetchFinDetailsBySid/{sid}")
@ResponseBody
public ResultBean<SysParameterDetailsVo> fetchFinDetailsBySid(@PathVariable("sid") String sid);
}

60
anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameterFeignFallback.java

@ -0,0 +1,60 @@
package com.yxt.anrui.portal.api.sysparameter;
import com.yxt.common.core.query.PagerQuery;
import com.yxt.common.core.result.ResultBean;
import com.yxt.common.core.vo.PagerVo;
import org.springframework.stereotype.Component;
/**
* @author Administrator
* @description
* @date 2023/8/16 14:36
*/
@Component
public class SysParameterFeignFallback implements SysParameterFeign {
@Override
public ResultBean<PagerVo<SysParameterVo>> listPage(PagerQuery<SysParameterQuery> pq) {
return null;
}
@Override
public ResultBean saveOrUpdateParameter(SysParameterDto dto) {
return null;
}
@Override
public ResultBean deleteBySids(String[] sids) {
return null;
}
@Override
public ResultBean<SysParameterDetailsVo> fetchDetailsBySid(String sid) {
return null;
}
@Override
public ResultBean<String> fetchByParNo(String parNo) {
return null;
}
@Override
public ResultBean<SysParameter> fetchOneByParNo(String parNo) {
return null;
}
@Override
public ResultBean<PagerVo<SysParameterVo>> finListPage(PagerQuery<SysParameterQuery> pq) {
return null;
}
@Override
public ResultBean finSaveParameter(SysParameterDto dto) {
return null;
}
@Override
public ResultBean<SysParameterDetailsVo> fetchFinDetailsBySid(String sid) {
return null;
}
}

29
anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameterQuery.java

@ -0,0 +1,29 @@
package com.yxt.anrui.portal.api.sysparameter;
import com.yxt.common.core.query.Query;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @author Administrator
* @description
* @date 2023/8/16 15:05
*/
@Data
public class SysParameterQuery implements Query {
@ApiModelProperty("参数编码")
private String parameterNo;
@ApiModelProperty("参数名称")
private String parameterName;
@ApiModelProperty("组织全路径")
private String orgPath;
@ApiModelProperty("菜单sid")
private String menuSid;
@ApiModelProperty("菜单url")
private String menuUrl;
@ApiModelProperty("用户sid")
private String userSid;
}

25
anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysparameter/SysParameterVo.java

@ -0,0 +1,25 @@
package com.yxt.anrui.portal.api.sysparameter;
import com.yxt.common.core.vo.Vo;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @author Administrator
* @description
* @date 2023/8/16 15:04
*/
@Data
public class SysParameterVo implements Vo {
private String sid;
@ApiModelProperty("参数编码")
private String parameterNo;
@ApiModelProperty("参数名称")
private String parameterName;
@ApiModelProperty("参数值")
private String parameterValue;
@ApiModelProperty("备注")
private String remarks;
@ApiModelProperty("分公司")
private String useOrgName;
}

35
anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysparameter/SysParameterMapper.java

@ -0,0 +1,35 @@
package com.yxt.anrui.portal.biz.sysparameter;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.yxt.anrui.portal.api.sysparameter.SysParameter;
import com.yxt.anrui.portal.api.sysparameter.SysParameterVo;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
/**
* @description:
* @author: fan
* @date: 2023/8/21
**/
@Mapper
public interface SysParameterMapper extends BaseMapper<SysParameter> {
IPage<SysParameterVo> listPage(IPage<SysParameter> page, @Param(Constants.WRAPPER) QueryWrapper<SysParameter> qw);
int updateBySidDelete(String sid);
@Select("select parameterValue from sys_parameter where parameterNo = #{parNo}")
String fetchByParNo(String parNo);
@Select("select * from sys_parameter where parameterNo = #{parNo} and isDelete = 0")
SysParameter fetchOneByParNo(String parNo);
int selectParameterByNo(String pNo);
int selectAllByIdAndpNo(@Param("pNo") String pNo, @Param("sid") String sid);
}

35
anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysparameter/SysParameterMapper.xml

@ -0,0 +1,35 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yxt.anrui.portal.biz.sysparameter.SysParameterMapper">
<update id="updateBySidDelete">
update sys_parameter
set isDelete = 1
where sid = #{sid}
</update>
<select id="listPage" resultType="com.yxt.anrui.portal.api.sysparameter.SysParameterVo">
SELECT sid,
parameterNo,
parameterName,
parameterValue,
remarks,
useOrgName
from sys_parameter
<where>
${ew.sqlSegment}
</where>
</select>
<select id="selectParameterByNo" resultType="java.lang.Integer">
select count(*)
FROM sys_parameter
where parameterNo = #{pNo}
and isDelete != 1
</select>
<select id="selectAllByIdAndpNo" resultType="java.lang.Integer">
select count(*)
FROM sys_parameter
where sid != #{sid}
and parameterNo = #{pNo}
and isDelete != 1
</select>
</mapper>

74
anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysparameter/SysParameterRest.java

@ -0,0 +1,74 @@
package com.yxt.anrui.portal.biz.sysparameter;
import com.yxt.anrui.portal.api.sysparameter.*;
import com.yxt.common.core.query.PagerQuery;
import com.yxt.common.core.result.ResultBean;
import com.yxt.common.core.vo.PagerVo;
import io.swagger.annotations.Api;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @description:
* @author: fan
* @date: 2023/8/21
**/
@Api(tags = "风控(财务)参数")
@RestController
@RequestMapping("v1/sysparameter")
public class SysParameterRest implements SysParameterFeign {
@Autowired
private SysParameterService parameterService;
@Override
public ResultBean<PagerVo<SysParameterVo>> listPage(PagerQuery<SysParameterQuery> pq) {
ResultBean<PagerVo<SysParameterVo>> rb = ResultBean.fireFail();
PagerVo<SysParameterVo> pv = parameterService.listPage(pq);
return rb.success().setData(pv);
}
@Override
public ResultBean saveOrUpdateParameter(SysParameterDto dto) {
return parameterService.saveOrUpdateParameter(dto);
}
@Override
public ResultBean deleteBySids(String[] sids) {
return parameterService.deleteBySids(sids);
}
@Override
public ResultBean<SysParameterDetailsVo> fetchDetailsBySid(String sid) {
return parameterService.fetchDetailsBySid(sid);
}
@Override
public ResultBean<String> fetchByParNo(String parNo) {
return parameterService.fetchByParNo(parNo);
}
@Override
public ResultBean<SysParameter> fetchOneByParNo(String parNo) {
return parameterService.fetchOneByParNo(parNo);
}
@Override
public ResultBean<PagerVo<SysParameterVo>> finListPage(PagerQuery<SysParameterQuery> pq) {
ResultBean<PagerVo<SysParameterVo>> rb = ResultBean.fireFail();
PagerVo<SysParameterVo> pv = parameterService.finListPage(pq);
return rb.success().setData(pv);
}
@Override
public ResultBean finSaveParameter(SysParameterDto dto) {
return parameterService.finSaveParameter(dto);
}
@Override
public ResultBean<SysParameterDetailsVo> fetchFinDetailsBySid(String sid) {
return parameterService.fetchFinDetailsBySid(sid);
}
}

310
anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysparameter/SysParameterService.java

@ -0,0 +1,310 @@
package com.yxt.anrui.portal.biz.sysparameter;
import cn.hutool.core.bean.BeanUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.yxt.anrui.portal.api.sysorganization.SysOrganization;
import com.yxt.anrui.portal.api.sysorganization.SysOrganizationFeign;
import com.yxt.anrui.portal.api.sysorganization.SysOrganizationVo;
import com.yxt.anrui.portal.api.sysparameter.*;
import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgFeign;
import com.yxt.anrui.portal.api.sysuser.PrivilegeQuery;
import com.yxt.anrui.portal.api.sysuser.SysUserFeign;
import com.yxt.anrui.portal.biz.sysorganization.SysOrganizationService;
import com.yxt.anrui.portal.biz.sysstafforg.SysStaffOrgService;
import com.yxt.anrui.portal.biz.sysuser.SysUserService;
import com.yxt.common.base.service.MybatisBaseService;
import com.yxt.common.base.utils.PagerUtil;
import com.yxt.common.core.query.PagerQuery;
import com.yxt.common.core.result.ResultBean;
import com.yxt.common.core.vo.PagerVo;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
/**
* @description:
* @author: fan
* @date: 2023/8/21
**/
@Service
public class SysParameterService extends MybatisBaseService<SysParameterMapper, SysParameter> {
@Autowired
private SysUserService sysUserService;
@Autowired
private SysStaffOrgService sysStaffOrgService;
@Autowired
private SysOrganizationService sysOrganizationService;
public PagerVo<SysParameterVo> listPage(PagerQuery<SysParameterQuery> pq) {
IPage<SysParameter> page = PagerUtil.queryToPage(pq);
SysParameterQuery pagerQuery = pq.getParams();
QueryWrapper<SysParameter> qw = new QueryWrapper<>();
//=======================
PrivilegeQuery privilegeQuery = new PrivilegeQuery();
privilegeQuery.setOrgPath(pagerQuery.getOrgPath());
privilegeQuery.setMenuSid(pagerQuery.getMenuSid());
privilegeQuery.setMenuUrl(pagerQuery.getMenuUrl());
privilegeQuery.setUserSid(pagerQuery.getUserSid());
ResultBean<String> defaultIdReltBean = sysUserService.selectPrivilegeLevel(privilegeQuery);
if (StringUtils.isNotBlank(defaultIdReltBean.getData())) {
//数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
String orgSidPath = pagerQuery.getOrgPath();
orgSidPath = orgSidPath + "/";
int i1 = orgSidPath.indexOf("/");
int i2 = orgSidPath.indexOf("/", i1 + 1);
int i3 = orgSidPath.indexOf("/", i2 + 1);
int i4 = orgSidPath.indexOf("/", i3 + 1);
String orgLevelKey = defaultIdReltBean.getData();
if ("1".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i1);
qw.like("orgSidPath", orgSidPath);
} else if ("2".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i2);
qw.like("orgSidPath", orgSidPath);
} else if ("3".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i3);
qw.like("orgSidPath", orgSidPath);
} else if ("4".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i4);
qw.like("orgSidPath", orgSidPath);
} else if ("5".equals(orgLevelKey)) {
qw.eq("createBySid", pagerQuery.getUserSid());
} else {
PagerVo<SysParameterVo> p = new PagerVo<>();
return p;
}
} else {
PagerVo<SysParameterVo> p = new PagerVo<>();
return p;
}
//=======================
//参数编码
if (StringUtils.isNotBlank(pagerQuery.getParameterNo())) {
qw.like("parameterNo", pagerQuery.getParameterNo());
}
//参数名称
if (StringUtils.isNotBlank(pagerQuery.getParameterName())) {
qw.like("parameterName", pagerQuery.getParameterName());
}
qw.eq("isDelete", 0);
qw.eq("state", 0);
qw.orderByDesc("createTime");
IPage<SysParameterVo> pagging = baseMapper.listPage(page, qw);
PagerVo<SysParameterVo> p = PagerUtil.pageToVo(pagging, null);
return p;
}
/**
* 根据风控参数编码查询是否存在与风控参数编码相同的数据
*
* @return
*/
public int selectParameterByNo(String pNo) {
return baseMapper.selectParameterByNo(pNo);
}
/**
* 修改时 根据风控参数编码查询是否存在与风控参数编码相同的数据
*
* @param pNo 风控参数编码
* @param sid 风控参数sid
*/
public int selectAllByIdAndpNo(String pNo, String sid) {
return baseMapper.selectAllByIdAndpNo(pNo, sid);
}
public ResultBean saveOrUpdateParameter(SysParameterDto dto) {
ResultBean rb = ResultBean.fireFail();
if (StringUtils.isBlank(dto.getParameterNo())) {
return rb.setMsg("参数编码不能为空!");
}
if (StringUtils.isNotBlank(dto.getSid())) {
int count = selectAllByIdAndpNo(dto.getParameterNo(), dto.getSid());
if (count > 0) {
return ResultBean.fireFail().setMessage("参数编码已存在");
}
SysParameter loanParameter = fetchBySid(dto.getSid());
BeanUtil.copyProperties(dto, loanParameter, "id", "sid");
baseMapper.updateById(loanParameter);
} else {
int count = selectParameterByNo(dto.getParameterNo());
if (count > 0) {
return ResultBean.fireFail().setMsg("添加失败,参数编码已存在");
}
SysParameter loanParameter = new SysParameter();
BeanUtil.copyProperties(dto, loanParameter, "id", "sid");
loanParameter.setOrgSidPath(dto.getOrgPath());
loanParameter.setCreateBySid(dto.getUserSid());
ResultBean<String> orgSidByPath = sysStaffOrgService.getOrgSidByPath(dto.getOrgPath());
if (orgSidByPath.getSuccess()) {
String userOrgSid = orgSidByPath.getData();
loanParameter.setUseOrgSid(userOrgSid);
SysOrganization organizationVo = sysOrganizationService.fetchBySid(userOrgSid);
if (null != organizationVo) {
loanParameter.setUseOrgName(organizationVo.getName());
}
}
loanParameter.setState(0);
baseMapper.insert(loanParameter);
}
return rb.success();
}
public ResultBean deleteBySids(String[] sids) {
ResultBean rb = ResultBean.fireFail();
for (String sid : sids) {
int count = baseMapper.updateBySidDelete(sid);
if (count == 0) {
return rb.setMsg("删除失败");
}
}
return ResultBean.fireSuccess().setMsg("删除成功");
}
public ResultBean<SysParameterDetailsVo> fetchDetailsBySid(String sid) {
ResultBean<SysParameterDetailsVo> rb = ResultBean.fireFail();
SysParameterDetailsVo vo = new SysParameterDetailsVo();
SysParameter loanParameter = fetchBySid(sid);
BeanUtil.copyProperties(loanParameter, vo);
vo.setUserSid(loanParameter.getCreateBySid());
vo.setOrgPath(loanParameter.getOrgSidPath());
return rb.success().setData(vo);
}
public ResultBean<String> fetchByParNo(String parNo) {
ResultBean rb = ResultBean.fireFail();
String parameterValue = baseMapper.fetchByParNo(parNo);
return rb.success().setData(parameterValue);
}
public ResultBean<SysParameter> fetchOneByParNo(String parNo) {
ResultBean rb = ResultBean.fireFail();
SysParameter parameter = baseMapper.fetchOneByParNo(parNo);
return rb.success().setData(parameter);
}
public PagerVo<SysParameterVo> finListPage(PagerQuery<SysParameterQuery> pq) {
IPage<SysParameter> page = PagerUtil.queryToPage(pq);
SysParameterQuery pagerQuery = pq.getParams();
QueryWrapper<SysParameter> qw = new QueryWrapper<>();
//=======================
PrivilegeQuery privilegeQuery = new PrivilegeQuery();
privilegeQuery.setOrgPath(pagerQuery.getOrgPath());
privilegeQuery.setMenuSid(pagerQuery.getMenuSid());
privilegeQuery.setMenuUrl(pagerQuery.getMenuUrl());
privilegeQuery.setUserSid(pagerQuery.getUserSid());
ResultBean<String> defaultIdReltBean = sysUserService.selectPrivilegeLevel(privilegeQuery);
if (StringUtils.isNotBlank(defaultIdReltBean.getData())) {
//数据权限ID(1集团、2事业部、3分公司、4部门、5个人)
String orgSidPath = pagerQuery.getOrgPath();
orgSidPath = orgSidPath + "/";
int i1 = orgSidPath.indexOf("/");
int i2 = orgSidPath.indexOf("/", i1 + 1);
int i3 = orgSidPath.indexOf("/", i2 + 1);
int i4 = orgSidPath.indexOf("/", i3 + 1);
String orgLevelKey = defaultIdReltBean.getData();
if ("1".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i1);
qw.like("orgSidPath", orgSidPath);
} else if ("2".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i2);
qw.like("orgSidPath", orgSidPath);
} else if ("3".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i3);
qw.like("orgSidPath", orgSidPath);
} else if ("4".equals(orgLevelKey)) {
orgSidPath = orgSidPath.substring(0, i4);
qw.like("orgSidPath", orgSidPath);
} else if ("5".equals(orgLevelKey)) {
qw.eq("createBySid", pagerQuery.getUserSid());
} else {
PagerVo<SysParameterVo> p = new PagerVo<>();
return p;
}
} else {
PagerVo<SysParameterVo> p = new PagerVo<>();
return p;
}
//=======================
//参数编码
if (StringUtils.isNotBlank(pagerQuery.getParameterNo())) {
qw.like("parameterNo", pagerQuery.getParameterNo());
}
//参数名称
if (StringUtils.isNotBlank(pagerQuery.getParameterName())) {
qw.like("parameterName", pagerQuery.getParameterName());
}
qw.eq("isDelete", 0);
qw.eq("state", 1);
qw.orderByDesc("createTime");
IPage<SysParameterVo> pagging = baseMapper.listPage(page, qw);
PagerVo<SysParameterVo> p = PagerUtil.pageToVo(pagging, null);
return p;
}
public ResultBean finSaveParameter(SysParameterDto dto) {
ResultBean rb = ResultBean.fireFail();
if (StringUtils.isBlank(dto.getParameterNo())) {
return rb.setMsg("参数编码不能为空!");
}
String useOrgSid = "";
String useOrgName = "";
if (!dto.getUseOrgSids().isEmpty()) {
useOrgSid = String.join(",", dto.getUseOrgSids());
}
if (!dto.getUseOrgNames().isEmpty()) {
useOrgName = String.join(",", dto.getUseOrgNames());
}
if (StringUtils.isNotBlank(dto.getSid())) {
int count = selectAllByIdAndpNo(dto.getParameterNo(), dto.getSid());
if (count > 0) {
return ResultBean.fireFail().setMessage("参数编码已存在");
}
SysParameter loanParameter = fetchBySid(dto.getSid());
BeanUtil.copyProperties(dto, loanParameter, "id", "sid");
loanParameter.setUseOrgSid(useOrgSid);
loanParameter.setUseOrgName(useOrgName);
baseMapper.updateById(loanParameter);
} else {
int count = selectParameterByNo(dto.getParameterNo());
if (count > 0) {
return ResultBean.fireFail().setMsg("添加失败,参数编码已存在");
}
SysParameter parameter = new SysParameter();
BeanUtil.copyProperties(dto, parameter, "id", "sid");
parameter.setOrgSidPath(dto.getOrgPath());
parameter.setCreateBySid(dto.getUserSid());
parameter.setUseOrgSid(useOrgSid);
parameter.setUseOrgName(useOrgName);
parameter.setState(1);
baseMapper.insert(parameter);
}
return rb.success();
}
public ResultBean<SysParameterDetailsVo> fetchFinDetailsBySid(String sid) {
ResultBean<SysParameterDetailsVo> rb = ResultBean.fireFail();
SysParameterDetailsVo vo = new SysParameterDetailsVo();
SysParameter loanParameter = fetchBySid(sid);
BeanUtil.copyProperties(loanParameter, vo);
vo.setUserSid(loanParameter.getCreateBySid());
vo.setOrgPath(loanParameter.getOrgSidPath());
if (StringUtils.isNotBlank(loanParameter.getUseOrgSid())) {
List<String> userOrgSid = Arrays.stream(loanParameter.getUseOrgSid().split(",")).collect(Collectors.toList());
vo.setUseOrgSids(userOrgSid);
}
if (StringUtils.isNotBlank(loanParameter.getUseOrgName())) {
List<String> userOrgName = Arrays.stream(loanParameter.getUseOrgSid().split(",")).collect(Collectors.toList());
vo.setUseOrgNames(userOrgName);
}
return rb.success().setData(vo);
}
}
Loading…
Cancel
Save