Commit f5571fe2 authored by chenzhao's avatar chenzhao

质押关系

parent e952c5db
...@@ -19,4 +19,7 @@ public class DropDown { ...@@ -19,4 +19,7 @@ public class DropDown {
@ApiModelProperty(value = "单位名称+单位id") @ApiModelProperty(value = "单位名称+单位id")
private String text; private String text;
@ApiModelProperty(value = "单位名称+单位id")
private String id;
} }
...@@ -39,6 +39,9 @@ public class FinancingInfoDto extends BaseDto { ...@@ -39,6 +39,9 @@ public class FinancingInfoDto extends BaseDto {
@ApiModelProperty(value = "农户id") @ApiModelProperty(value = "农户id")
private Long peasantHouseholdId; private Long peasantHouseholdId;
@ApiModelProperty(value = "区域公司Id")
private Long regionalCompaniesSeq;
@ApiModelProperty(value = "放款时间") @ApiModelProperty(value = "放款时间")
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd") @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd")
private Date disbursementTime; private Date disbursementTime;
......
...@@ -28,6 +28,9 @@ public class FinancingRegionalDto extends BaseDto { ...@@ -28,6 +28,9 @@ public class FinancingRegionalDto extends BaseDto {
@ApiModelProperty(value = "区域公司名称") @ApiModelProperty(value = "区域公司名称")
private String regionalCompaniesSeq; private String regionalCompaniesSeq;
@ApiModelProperty(value = "区域公司名称")
private String regionalCompaniesCode;
@ApiModelProperty(value = "融资机构id") @ApiModelProperty(value = "融资机构id")
private String financingId; private String financingId;
......
...@@ -46,6 +46,9 @@ public class FinancingInfo extends BaseEntity { ...@@ -46,6 +46,9 @@ public class FinancingInfo extends BaseEntity {
@TableField("peasant_household_id") @TableField("peasant_household_id")
private Long peasantHouseholdId; private Long peasantHouseholdId;
@TableField("regional_companies_seq")
private Long regionalCompaniesSeq;
/** /**
* 放款时间 * 放款时间
*/ */
......
...@@ -35,6 +35,12 @@ public class FinancingRegional extends BaseEntity { ...@@ -35,6 +35,12 @@ public class FinancingRegional extends BaseEntity {
private String regionalCompaniesSeq; private String regionalCompaniesSeq;
/** /**
* 区域公司code
*/
@TableField("regional_companies_code")
private String regionalCompaniesCode;
/**
* 融资机构id * 融资机构id
*/ */
@TableField("financing_id") @TableField("financing_id")
......
...@@ -24,8 +24,12 @@ public interface FinancingInfoMapper extends BaseMapper<FinancingInfo> { ...@@ -24,8 +24,12 @@ public interface FinancingInfoMapper extends BaseMapper<FinancingInfo> {
List<Map<String,Object>> selectOrgList(); List<Map<String,Object>> selectOrgList();
List<Map<String,Object>> orgListByqyid(@Param("ids") List<String> ids);
Map<String,Object> selectRZOrgInfo(Long id); Map<String,Object> selectRZOrgInfo(Long id);
List<Map<String,Object>> selectCompany(@Param("ids")List<String> ids);
List<Map<String,Object>> selectRegion(); List<Map<String,Object>> selectRegion();
} }
package com.yeejoin.amos.boot.module.hygf.api.mapper; package com.yeejoin.amos.boot.module.hygf.api.mapper;
import com.yeejoin.amos.boot.module.hygf.api.config.UserEmpower;
import com.yeejoin.amos.boot.module.hygf.api.entity.FinancingRegional; import com.yeejoin.amos.boot.module.hygf.api.entity.FinancingRegional;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import java.util.List;
/** /**
* 融资机构区域公司绑定表 Mapper 接口 * 融资机构区域公司绑定表 Mapper 接口
* *
...@@ -11,4 +14,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; ...@@ -11,4 +14,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
*/ */
public interface FinancingRegionalMapper extends BaseMapper<FinancingRegional> { public interface FinancingRegionalMapper extends BaseMapper<FinancingRegional> {
@UserEmpower(field ={"regional_companies_code"} ,dealerField ={"regional_companies_code"}, fieldConditions ={"in","in"} ,relationship="and",specific=false)
List<FinancingRegional> queryDataForPage();
} }
...@@ -37,7 +37,10 @@ public interface JpStationMapper extends BaseMapper<JpStation> { ...@@ -37,7 +37,10 @@ public interface JpStationMapper extends BaseMapper<JpStation> {
List<JpStation> getJpStationList(@Param("dto") JpStationDto reviewDto); List<JpStation> getJpStationList(@Param("dto") JpStationDto reviewDto);
@UserEmpower(field ={"ORG_CODE"} ,dealerField ={"ORG_CODE"}, fieldConditions ={"in","in"} ,relationship="and",specific=false) @UserEmpower(field ={"ORG_CODE"} ,dealerField ={"ORG_CODE"}, fieldConditions ={"in","in"} ,relationship="and",specific=false)
List<DropDown> getRegion(String regionName,String province); List<DropDown> getRegion(String regionName);
@UserEmpower(field ={"ORG_CODE"} ,dealerField ={"ORG_CODE"}, fieldConditions ={"in","in"} ,relationship="and",specific=false)
List<DropDown> getRegionByProvince(String province);
List<DropDown> getRegionAll(); List<DropDown> getRegionAll();
......
...@@ -67,6 +67,23 @@ ...@@ -67,6 +67,23 @@
</select> </select>
<select id="orgListByqyid" resultType="java.util.Map">
select
*
from
privilege_company
where
PARENT_ID = (select SEQUENCE_NBR from privilege_company where COMPANY_NAME = '融资机构')
<if test="ids != null and ids.size()>0">
and SEQUENCE_NBR in
<foreach collection="ids" separator="," open="(" close=")" item="item">
#{item}
</foreach>
</if>
</select>
<select id="selectRZOrgInfo" resultType="java.util.Map"> <select id="selectRZOrgInfo" resultType="java.util.Map">
select select
* *
...@@ -76,6 +93,19 @@ ...@@ -76,6 +93,19 @@
SEQUENCE_NBR=#{id} SEQUENCE_NBR=#{id}
</select> </select>
<select id="selectCompany" resultType="java.util.Map">
select
*
from
privilege_company
<where>
SEQUENCE_NBR in
<foreach collection="ids" item="item" open="(" close=")" separator=",">
#{item}
</foreach>
</where>
</select>
<select id="selectRegion" resultType="java.util.Map"> <select id="selectRegion" resultType="java.util.Map">
select select
......
...@@ -2,4 +2,8 @@ ...@@ -2,4 +2,8 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yeejoin.amos.boot.module.hygf.api.mapper.FinancingRegionalMapper"> <mapper namespace="com.yeejoin.amos.boot.module.hygf.api.mapper.FinancingRegionalMapper">
<select id="queryDataForPage" resultType="com.yeejoin.amos.boot.module.hygf.api.entity.FinancingRegional">
select * from hygf_financing_regional
</select>
</mapper> </mapper>
...@@ -242,14 +242,23 @@ ...@@ -242,14 +242,23 @@
<select id="getRegion" resultType="com.yeejoin.amos.boot.module.hygf.api.dto.DropDown"> <select id="getRegion" resultType="com.yeejoin.amos.boot.module.hygf.api.dto.DropDown">
SELECT privilege_company.ORG_CODE orgCode, SELECT privilege_company.ORG_CODE orgCode,
privilege_company.COMPANY_NAME name, privilege_company.COMPANY_NAME name
CONCAT_WS('_',privilege_company.COMPANY_NAME,privilege_company.SEQUENCE_NBR) as text
FROM privilege_company FROM privilege_company
WHERE IS_DELETED = 0 WHERE IS_DELETED = 0
and privilege_company.COMPANY_TYPE = 'region' and privilege_company.COMPANY_TYPE = 'region'
<if test="regionName!=null and regionName!=''"> <if test="regionName!=null and regionName!=''">
and privilege_company.COMPANY_NAME like concat('%',#{regionName}, '%') and privilege_company.COMPANY_NAME like concat('%',#{regionName}, '%')
</if> </if>
</select>
<select id="getRegionByProvince" resultType="com.yeejoin.amos.boot.module.hygf.api.dto.DropDown">
SELECT privilege_company.ORG_CODE orgCode,
privilege_company.COMPANY_NAME name,
CONCAT_WS('_',privilege_company.COMPANY_NAME,privilege_company.SEQUENCE_NBR,privilege_company.ORG_CODE) as text,
privilege_company.SEQUENCE_NBR as id
FROM privilege_company
WHERE IS_DELETED = 0
and privilege_company.COMPANY_TYPE = 'region'
<if test="province!=null and province!=''"> <if test="province!=null and province!=''">
and privilege_company.ADDRESS like concat('%',#{province}, '%') and privilege_company.ADDRESS like concat('%',#{province}, '%')
</if> </if>
......
...@@ -211,4 +211,11 @@ public class FinancingInfoController extends BaseController { ...@@ -211,4 +211,11 @@ public class FinancingInfoController extends BaseController {
return CommonResponseNewUtil.success(financingInfoServiceImpl.selectOrgList()); return CommonResponseNewUtil.success(financingInfoServiceImpl.selectOrgList());
} }
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "融资机构列表根据区域公司Id过滤", notes = "orgListByqyid")
@GetMapping(value = "/orgListByqyid")
public ResponseModel<List<Map<String,Object>>> orgListByqyid(@RequestParam(value = "code") String code) {
return CommonResponseNewUtil.success(financingInfoServiceImpl.orgListByqyid(code));
}
} }
package com.yeejoin.amos.boot.module.hygf.biz.controller; package com.yeejoin.amos.boot.module.hygf.biz.controller;
import com.yeejoin.amos.boot.module.hygf.api.config.UserLimits;
import com.yeejoin.amos.boot.module.hygf.api.entity.FinancingRegional;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import com.yeejoin.amos.boot.biz.common.controller.BaseController; import com.yeejoin.amos.boot.biz.common.controller.BaseController;
import java.util.Arrays;
import java.util.List; import java.util.List;
import com.yeejoin.amos.boot.module.hygf.biz.service.impl.FinancingRegionalServiceImpl; import com.yeejoin.amos.boot.module.hygf.biz.service.impl.FinancingRegionalServiceImpl;
import org.typroject.tyboot.core.restful.utils.ResponseHelper; import org.typroject.tyboot.core.restful.utils.ResponseHelper;
...@@ -55,9 +59,9 @@ public class FinancingRegionalController extends BaseController { ...@@ -55,9 +59,9 @@ public class FinancingRegionalController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@PutMapping(value = "/{sequenceNbr}") @PutMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新融资机构区域公司绑定表", notes = "根据sequenceNbr更新融资机构区域公司绑定表") @ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新融资机构区域公司绑定表", notes = "根据sequenceNbr更新融资机构区域公司绑定表")
public ResponseModel<FinancingRegionalDto> updateBySequenceNbrFinancingRegional(@RequestBody FinancingRegionalDto model,@PathVariable(value = "sequenceNbr") Long sequenceNbr) { public ResponseModel<FinancingRegionalDto> updateBySequenceNbrFinancingRegional(@RequestBody FinancingRegionalDto model) {
model.setSequenceNbr(sequenceNbr); financingRegionalServiceImpl.updateModel(model);
return ResponseHelper.buildResponse(financingRegionalServiceImpl.updateWithModel(model)); return ResponseHelper.buildResponse(null);
} }
/** /**
...@@ -70,7 +74,10 @@ public class FinancingRegionalController extends BaseController { ...@@ -70,7 +74,10 @@ public class FinancingRegionalController extends BaseController {
@DeleteMapping(value = "/{sequenceNbr}") @DeleteMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除融资机构区域公司绑定表", notes = "根据sequenceNbr删除融资机构区域公司绑定表") @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除融资机构区域公司绑定表", notes = "根据sequenceNbr删除融资机构区域公司绑定表")
public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){ public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){
return ResponseHelper.buildResponse(financingRegionalServiceImpl.removeById(sequenceNbr));
financingRegionalServiceImpl.removeModel(sequenceNbr);
return ResponseHelper.buildResponse(null);
} }
/** /**
...@@ -83,7 +90,10 @@ public class FinancingRegionalController extends BaseController { ...@@ -83,7 +90,10 @@ public class FinancingRegionalController extends BaseController {
@GetMapping(value = "/{sequenceNbr}") @GetMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询单个融资机构区域公司绑定表", notes = "根据sequenceNbr查询单个融资机构区域公司绑定表") @ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询单个融资机构区域公司绑定表", notes = "根据sequenceNbr查询单个融资机构区域公司绑定表")
public ResponseModel<FinancingRegionalDto> selectOne(@PathVariable Long sequenceNbr) { public ResponseModel<FinancingRegionalDto> selectOne(@PathVariable Long sequenceNbr) {
return ResponseHelper.buildResponse(financingRegionalServiceImpl.queryBySeq(sequenceNbr)); FinancingRegionalDto financingRegionalDto = financingRegionalServiceImpl.queryBySeq(sequenceNbr);
financingRegionalDto.setFinancing(Arrays.asList(financingRegionalDto.getFinancingId().split(",")));
financingRegionalDto.setRegionalCompanies(Arrays.asList(financingRegionalDto.getRegionalCompaniesSeq().split(",")));
return ResponseHelper.buildResponse(financingRegionalDto);
} }
/** /**
...@@ -96,12 +106,11 @@ public class FinancingRegionalController extends BaseController { ...@@ -96,12 +106,11 @@ public class FinancingRegionalController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/page") @GetMapping(value = "/page")
@ApiOperation(httpMethod = "GET",value = "融资机构区域公司绑定表分页查询", notes = "融资机构区域公司绑定表分页查询") @ApiOperation(httpMethod = "GET",value = "融资机构区域公司绑定表分页查询", notes = "融资机构区域公司绑定表分页查询")
public ResponseModel<Page<FinancingRegionalDto>> queryForPage(@RequestParam(value = "current") int current,@RequestParam @UserLimits
public ResponseModel<Page<FinancingRegional>> queryForPage(@RequestParam(value = "current") int current, @RequestParam
(value = "size") int size) { (value = "size") int size) {
Page<FinancingRegionalDto> page = new Page<FinancingRegionalDto>();
page.setCurrent(current); return ResponseHelper.buildResponse(financingRegionalServiceImpl.queryForFinancingRegionalPage(current,size));
page.setSize(size);
return ResponseHelper.buildResponse(financingRegionalServiceImpl.queryForFinancingRegionalPage(page));
} }
/** /**
......
...@@ -423,15 +423,34 @@ public class JpStationController extends BaseController { ...@@ -423,15 +423,34 @@ public class JpStationController extends BaseController {
@ApiOperation(httpMethod = "GET", value = "查询当前登录人权限区域公司", notes = "查询当前登录人权限区域公司") @ApiOperation(httpMethod = "GET", value = "查询当前登录人权限区域公司", notes = "查询当前登录人权限区域公司")
@GetMapping(value = "/getRegion") @GetMapping(value = "/getRegion")
@UserLimits @UserLimits
public ResponseModel<List<Map<String, String>>> getRegion(@RequestParam(required = false) String regionName,String province) { public ResponseModel<List<Map<String, String>>> getRegion(@RequestParam(required = false) String regionName) {
List<DropDown> list = jpStationMapper.getRegion(regionName,province); List<DropDown> list = jpStationMapper.getRegion(regionName);
List<Map<String, String>> result = new ArrayList<>();
list.forEach(dropDown -> {
Map<String, String> item = new HashMap<>();
item.put("text", dropDown.getName());
item.put("value", dropDown.getOrgCode());
result.add(item);
});
return ResponseHelper.buildResponse(result);
}
//查询当前登录人权限区域公司
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "查询当前登录人权限区域公司", notes = "查询当前登录人权限区域公司")
@GetMapping(value = "/getRegionByProvince")
@UserLimits
public ResponseModel<List<Map<String, String>>> getRegionByProvince(String province) {
List<DropDown> list = jpStationMapper.getRegionByProvince(province);
List<Map<String, String>> result = new ArrayList<>(); List<Map<String, String>> result = new ArrayList<>();
list.forEach(dropDown -> { list.forEach(dropDown -> {
Map<String, String> item = new HashMap<>(); Map<String, String> item = new HashMap<>();
item.put("text", dropDown.getName()); item.put("text", dropDown.getName());
item.put("value", dropDown.getOrgCode()); item.put("value", dropDown.getOrgCode());
item.put("values", dropDown.getText()); item.put("values", dropDown.getText());
item.put("id", dropDown.getId());
result.add(item); result.add(item);
}); });
...@@ -850,9 +869,9 @@ public class JpStationController extends BaseController { ...@@ -850,9 +869,9 @@ public class JpStationController extends BaseController {
@ApiOperation(httpMethod = "GET", value = "查询当前登录人权限区域公司统计数据", notes = "查询当前登录人权限区域公司统计数据") @ApiOperation(httpMethod = "GET", value = "查询当前登录人权限区域公司统计数据", notes = "查询当前登录人权限区域公司统计数据")
@GetMapping(value = "/getRegionStatistics") @GetMapping(value = "/getRegionStatistics")
@UserLimits @UserLimits
public ResponseModel<List<Map<String, Object>>> getRegionStatistics(@RequestParam(required = false) String regionName,@RequestParam(required = false) String province) { public ResponseModel<List<Map<String, Object>>> getRegionStatistics(@RequestParam(required = false) String regionName) {
// 获取区域公司列表 // 获取区域公司列表
List<DropDown> regionlist = jpStationMapper.getRegion(regionName,province); List<DropDown> regionlist = jpStationMapper.getRegion(regionName);
List<Map<String, Object>> result = new ArrayList<>(); List<Map<String, Object>> result = new ArrayList<>();
......
...@@ -63,6 +63,8 @@ public class FinancingInfoServiceImpl extends BaseService<FinancingInfoDto, Fina ...@@ -63,6 +63,8 @@ public class FinancingInfoServiceImpl extends BaseService<FinancingInfoDto, Fina
@Autowired @Autowired
private WorkFlowService workFlowService; private WorkFlowService workFlowService;
@Autowired @Autowired
private PeasantHouseholdServiceImpl peasantHouseholdService;
@Autowired
private WorkflowImpl workflow; private WorkflowImpl workflow;
@Autowired @Autowired
private FinancingAuditingServiceImpl financingAuditingService; private FinancingAuditingServiceImpl financingAuditingService;
...@@ -78,7 +80,8 @@ public class FinancingInfoServiceImpl extends BaseService<FinancingInfoDto, Fina ...@@ -78,7 +80,8 @@ public class FinancingInfoServiceImpl extends BaseService<FinancingInfoDto, Fina
private AcceptanceCheckServiceImpl acceptanceCheckService; private AcceptanceCheckServiceImpl acceptanceCheckService;
@Autowired @Autowired
private AcceptanceCheckAuditingServiceImpl acceptanceCheckAuditingService; private AcceptanceCheckAuditingServiceImpl acceptanceCheckAuditingService;
@Autowired
private FinancingRegionalServiceImpl financingRegionalService;
@Resource(type = RedisLockUtil.class) @Resource(type = RedisLockUtil.class)
private RedisLockUtil redisLockUtil; private RedisLockUtil redisLockUtil;
...@@ -163,12 +166,18 @@ public class FinancingInfoServiceImpl extends BaseService<FinancingInfoDto, Fina ...@@ -163,12 +166,18 @@ public class FinancingInfoServiceImpl extends BaseService<FinancingInfoDto, Fina
queryWrapper.eq(FinancingInfo::getPeasantHouseholdId, Long.valueOf(e)); queryWrapper.eq(FinancingInfo::getPeasantHouseholdId, Long.valueOf(e));
FinancingInfo financingInfos = this.getBaseMapper().selectOne(queryWrapper); FinancingInfo financingInfos = this.getBaseMapper().selectOne(queryWrapper);
if (ObjectUtils.isEmpty(financingInfos)) { if (ObjectUtils.isEmpty(financingInfos)) {
LambdaQueryWrapper<PeasantHousehold> query= new LambdaQueryWrapper<>();
query.eq(BaseEntity::getSequenceNbr,e);
PeasantHousehold peasantHousehold = peasantHouseholdService.getBaseMapper().selectOne(query);
model.setStatus(FinancingAuditEnum.待融资审核.getName()); model.setStatus(FinancingAuditEnum.待融资审核.getName());
model.setPeasantHouseholdId(Long.valueOf(e)); model.setPeasantHouseholdId(Long.valueOf(e));
FinancingInfoDto financingInfoDto = new FinancingInfoDto(); FinancingInfoDto financingInfoDto = new FinancingInfoDto();
BeanUtils.copyProperties(model, financingInfoDto); BeanUtils.copyProperties(model, financingInfoDto);
financingInfoDto.setSequenceNbr(null); financingInfoDto.setSequenceNbr(null);
financingInfoDto.setBatchNo(batcvNo); financingInfoDto.setBatchNo(batcvNo);
financingInfoDto.setRegionalCompaniesSeq(peasantHousehold.getRegionalCompaniesSeq());
this.createWithModel(financingInfoDto); this.createWithModel(financingInfoDto);
//开启工作流 并执行一步 //开启工作流 并执行一步
ActWorkflowBatchDTO actWorkflowBatchDTO = new ActWorkflowBatchDTO(); ActWorkflowBatchDTO actWorkflowBatchDTO = new ActWorkflowBatchDTO();
...@@ -459,4 +468,19 @@ public class FinancingInfoServiceImpl extends BaseService<FinancingInfoDto, Fina ...@@ -459,4 +468,19 @@ public class FinancingInfoServiceImpl extends BaseService<FinancingInfoDto, Fina
}); });
} }
public Object orgListByqyid(String peasantHouseholdId) {
LambdaQueryWrapper<PeasantHousehold> query= new LambdaQueryWrapper<>();
query.eq(BaseEntity::getSequenceNbr,peasantHouseholdId);
PeasantHousehold peasantHousehold = peasantHouseholdService.getBaseMapper().selectOne(query);
LambdaQueryWrapper<FinancingRegional> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(FinancingRegional::getRegionalCompaniesSeq,peasantHousehold.getRegionalCompaniesSeq());
FinancingRegional financingRegional = financingRegionalService.getBaseMapper().selectOne(wrapper);
List<String> ids = Arrays.asList(financingRegional.getFinancingId().split(","));
return this.getBaseMapper().orgListByqyid(ids);
}
} }
\ No newline at end of file
...@@ -3,18 +3,26 @@ package com.yeejoin.amos.boot.module.hygf.biz.service.impl; ...@@ -3,18 +3,26 @@ package com.yeejoin.amos.boot.module.hygf.biz.service.impl;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity; import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.hygf.api.entity.FinancingInfo;
import com.yeejoin.amos.boot.module.hygf.api.entity.FinancingRegional; import com.yeejoin.amos.boot.module.hygf.api.entity.FinancingRegional;
import com.yeejoin.amos.boot.module.hygf.api.entity.PeasantHousehold;
import com.yeejoin.amos.boot.module.hygf.api.mapper.FinancingRegionalMapper; import com.yeejoin.amos.boot.module.hygf.api.mapper.FinancingRegionalMapper;
import com.yeejoin.amos.boot.module.hygf.api.service.IFinancingRegionalService; import com.yeejoin.amos.boot.module.hygf.api.service.IFinancingRegionalService;
import com.yeejoin.amos.boot.module.hygf.api.dto.FinancingRegionalDto; import com.yeejoin.amos.boot.module.hygf.api.dto.FinancingRegionalDto;
import org.springframework.beans.factory.annotation.Autowired;
import org.typroject.tyboot.core.rdbms.service.BaseService; import org.typroject.tyboot.core.rdbms.service.BaseService;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.typroject.tyboot.core.restful.exception.instance.BadRequest; import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/** /**
* 融资机构区域公司绑定表服务实现类 * 融资机构区域公司绑定表服务实现类
...@@ -24,11 +32,23 @@ import java.util.List; ...@@ -24,11 +32,23 @@ import java.util.List;
*/ */
@Service @Service
public class FinancingRegionalServiceImpl extends BaseService<FinancingRegionalDto,FinancingRegional,FinancingRegionalMapper> implements IFinancingRegionalService { public class FinancingRegionalServiceImpl extends BaseService<FinancingRegionalDto,FinancingRegional,FinancingRegionalMapper> implements IFinancingRegionalService {
@Autowired
private FinancingInfoServiceImpl financingInfoService;
/** /**
* 分页查询 * 分页查询
*/ */
public Page<FinancingRegionalDto> queryForFinancingRegionalPage(Page<FinancingRegionalDto> page) { public Page<FinancingRegional> queryForFinancingRegionalPage(int current,int size) {
return this.queryForPage(page, null, false); Page<FinancingRegional> page = new Page<>();
PageHelper.startPage(current,size);
List<FinancingRegional> list = this.getBaseMapper().queryDataForPage();
PageInfo<FinancingRegional> pageInfo = new PageInfo<>(list);
page.setSize(pageInfo.getSize());
page.setCurrent(pageInfo.getPageNum());
page.setTotal(pageInfo.getTotal());
page.setRecords(list);
return page;
} }
/** /**
...@@ -39,29 +59,44 @@ public class FinancingRegionalServiceImpl extends BaseService<FinancingRegionalD ...@@ -39,29 +59,44 @@ public class FinancingRegionalServiceImpl extends BaseService<FinancingRegionalD
} }
public void saveModel(FinancingRegionalDto model) { public void saveModel(FinancingRegionalDto model) {
List<String> ids = new ArrayList<>(); List<String> ids = new ArrayList<>();
List<String> exitNames = new ArrayList<>();
List<String> names = new ArrayList<>(); List<String> names = new ArrayList<>();
List<String> exitNames = new ArrayList<>();
ids.addAll(model.getFinancing());
ids.addAll(model.getRegionalCompanies());
List<FinancingRegional> models = new ArrayList<>(); List<FinancingRegional> models = new ArrayList<>();
model.getFinancing().forEach(e->{
ids.add(e.split("_")[1]);
names.add(e.split("_")[0]);
List<Map<String, Object>> orgInfo = financingInfoService.getBaseMapper().selectCompany(ids);
model.getFinancing().forEach(f->{
List<Map<String, Object>> map = orgInfo.stream().filter(b ->String.valueOf(b.get("SEQUENCE_NBR")) .equals(f)).collect(Collectors.toList());
map.forEach(a->{
names.add(a.get("COMPANY_NAME").toString());
});
}); });
model.getRegionalCompanies().forEach(e->{ model.getRegionalCompanies().forEach(e->{
FinancingRegional financingRegional = new FinancingRegional(); FinancingRegional financingRegional = new FinancingRegional();
financingRegional.setFinancingId(String.join(",",ids)); financingRegional.setFinancingId(String.join(",",String.join(",",model.getFinancing())));
financingRegional.setFinancingName(String.join(",",names)); financingRegional.setFinancingName(String.join(",",names));
orgInfo.stream().filter(b->String.valueOf(b.get("SEQUENCE_NBR")).equals(e)).forEach(a->{
financingRegional.setRegionalCompaniesSeq(String.valueOf(a.get("SEQUENCE_NBR")));
financingRegional.setRegionalCompaniesName(a.get("COMPANY_NAME").toString());
financingRegional.setRegionalCompaniesCode(a.get("ORG_CODE").toString());
});
LambdaQueryWrapper<FinancingRegional> wrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<FinancingRegional> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(FinancingRegional::getRegionalCompaniesSeq,e.split("_")[1]); wrapper.eq(FinancingRegional::getRegionalCompaniesSeq,e);
wrapper.eq(BaseEntity::getIsDelete,0); wrapper.eq(BaseEntity::getIsDelete,0);
List<FinancingRegional> financingRegionals = this.getBaseMapper().selectList(wrapper); List<FinancingRegional> financingRegionals = this.getBaseMapper().selectList(wrapper);
if (CollectionUtil.isNotEmpty(financingRegionals)){ if (CollectionUtil.isNotEmpty(financingRegionals)){
exitNames.add(e.split("_")[0]); exitNames.add(financingRegional.getRegionalCompaniesName());
} }
financingRegional.setRegionalCompaniesSeq(e.split("_")[1]); financingRegional.setProvince(model.getProvince());
financingRegional.setRegionalCompaniesName(e.split("_")[0]);
models.add(financingRegional); models.add(financingRegional);
}); });
if (CollectionUtil.isNotEmpty(exitNames)) { if (CollectionUtil.isNotEmpty(exitNames)) {
...@@ -69,4 +104,52 @@ public class FinancingRegionalServiceImpl extends BaseService<FinancingRegionalD ...@@ -69,4 +104,52 @@ public class FinancingRegionalServiceImpl extends BaseService<FinancingRegionalD
} }
this.saveBatch(models); this.saveBatch(models);
} }
public void removeModel(Long sequenceNbr) {
FinancingRegionalDto financingRegionalDto = this.queryBySeq(sequenceNbr);
LambdaQueryWrapper<FinancingInfo> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(FinancingInfo::getRegionalCompaniesSeq,financingRegionalDto.getRegionalCompaniesSeq());
wrapper.ne(FinancingInfo::getStatus,"放款完成");
List<FinancingInfo> financingInfos = financingInfoService.getBaseMapper().selectList(wrapper);
if (CollectionUtil.isNotEmpty(financingInfos)){
throw new BadRequest("该区域公司存在正在进行中的投融业务,不可删除");
}
this.removeById(sequenceNbr);
}
public void updateModel(FinancingRegionalDto model) {
FinancingRegionalDto financingRegionalDto = this.queryBySeq(model.getSequenceNbr());
List<String> ids = new ArrayList<>();
List<String> names = new ArrayList<>();
ids.addAll(model.getFinancing());
List<Map<String, Object>> orgInfo = financingInfoService.getBaseMapper().selectCompany(ids);
model.getFinancing().forEach(f->{
orgInfo.stream().filter(b->String.valueOf(b.get("SEQUENCE_NBR")).equals(f)).forEach(a->{
names.add(a.get("COMPANY_NAME").toString());
});
});
List<String> oldIds = new ArrayList<>(Arrays.asList(financingRegionalDto.getFinancingId().split(",")));
oldIds.removeAll(ids);
if (CollectionUtil.isNotEmpty(oldIds)){
oldIds.forEach(e->{
LambdaQueryWrapper<FinancingInfo> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(FinancingInfo::getRegionalCompaniesSeq,financingRegionalDto.getRegionalCompaniesSeq());
wrapper.eq(FinancingInfo::getFinancingCompaniesSeq,e);
wrapper.ne(FinancingInfo::getStatus,"放款完成");
List<FinancingInfo> financingInfos = financingInfoService.getBaseMapper().selectList(wrapper);
if (CollectionUtil.isNotEmpty(financingInfos)){
throw new BadRequest("无法解绑投融业务进行中的融资机构");
}
});
}
model.setFinancingId(String.join(",",model.getFinancing()));
model.setFinancingName(String.join(",",names));
this.updateWithModel(model);
}
} }
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment