Merge remote-tracking branch 'origin/master'

master
xiaoCJ 1 year ago
commit 273a7ea915

@ -47,10 +47,8 @@ public class InquiryIssuanceController {
@AnonymousAccess
@GetMapping("/queryInquiryInvestors")
@ApiOperation("询价投资者查看")
public ResultEntity<PageInfo<AllotmentObjectDTO>> queryInquiryInvestors(@ApiParam("流程ID") String flowId,
@ApiParam("每页条数") Integer size,
@ApiParam("当前页") Integer index){
PageInfo<AllotmentObjectDTO> pageInfo=inquiryIssuanceService.queryInquiryInvestors(flowId,size,index);
public ResultEntity<PageInfo<AllotmentObjectDTO>> queryInquiryInvestors(String flowId){
PageInfo<AllotmentObjectDTO> pageInfo=inquiryIssuanceService.queryInquiryInvestors(flowId);
return new ResultEntity<>(HttpStatus.OK,"成功",pageInfo);
}
@ -144,13 +142,12 @@ public class InquiryIssuanceController {
@AnonymousAccess
@GetMapping("/basicInformationStorage")
@ApiOperation("投资者参与询价--基本信息保存")
public ResultEntity basicInformationStorage(@RequestBody JSONObject jsonObject){
String objectivityEvaluation = jsonObject.getString("objectivityEvaluation");
String valuationMethodRationalityEvaluation = jsonObject.getString("valuationMethodRationalityEvaluation");
Integer overallEvaluation = jsonObject.getInteger("overallEvaluation");
String operator = jsonObject.getString("operator");
BigDecimal declarationPrice = jsonObject.getBigDecimal("declarationPrice");
String flowId = jsonObject.getString("flowId");
public ResultEntity basicInformationStorage(@RequestParam @ApiParam("客观性评价") String objectivityEvaluation,
@RequestParam @ApiParam("估值方法合理性评价") String valuationMethodRationalityEvaluation,
@RequestParam @ApiParam("总体评价(1-100整数)") Integer overallEvaluation,
@RequestParam @ApiParam("经办人") String operator,
@RequestParam @ApiParam("申报价格") BigDecimal declarationPrice,
@RequestParam @ApiParam("流程ID") String flowId){
inquiryIssuanceService.basicInformationStorage(objectivityEvaluation,overallEvaluation,
valuationMethodRationalityEvaluation,operator,declarationPrice,flowId);
return new ResultEntity<>(HttpStatus.OK,"保存成功");

@ -1,6 +1,7 @@
package com.sztzjy.fund_investment.entity;
import java.util.Date;
import java.util.UUID;
import io.swagger.annotations.ApiModelProperty;
/**
@ -39,6 +40,22 @@ public class AllotmentObject {
@ApiModelProperty("逻辑删除(0、不展示 1、展示)")
private Integer logic;
public AllotmentObject(){
}
public AllotmentObject(String flowId){
this.id= String.valueOf(UUID.randomUUID());
this.flowId=flowId;
this.allotmentObjectName="测试";
this.allotmentObjectType="其他";
this.investorCode=3;
this.investorName="测试";
this.investorType="合格境外机构投资者";
this.logic=1;
this.allotmentObjectCode="I000030001";
}
public String getId() {
return id;
}

@ -29,4 +29,6 @@ public interface AllotmentObjectMapper {
int updateByPrimaryKeySelective(AllotmentObject record);
int updateByPrimaryKey(AllotmentObject record);
List<AllotmentObject> selectByFlowId(String flowId);
}

@ -13,7 +13,7 @@ import java.util.List;
* @date 2023/12/5 8:58
*/
public interface InquiryIssuanceService {
PageInfo<AllotmentObjectDTO> queryInquiryInvestors(String flowId, Integer size, Integer index);
PageInfo<AllotmentObjectDTO> queryInquiryInvestors(String flowId);
// List<AllotmentObject> queryBuiltIn(String flowId);

@ -296,62 +296,59 @@ public class ContractInvestmentServiceImpl implements ContractInvestmentService
issuanceInfoExample.createCriteria().andFlowIdEqualTo(issuanceInfo.getFlowId());
List<IssuanceInfo> issuanceInfos = issuanceInfoMapper.selectByExample(issuanceInfoExample);
//查询有无第一次录入的数据
if (issuanceInfos.size() > 0) {
if (!issuanceInfos.get(0).getSecurityCode().equals(issuanceInfo.getSecurityCode()))
{
issuanceInfo.setSecurityCode(issuanceInfos.get(0).getSecurityCode());
}
//获取上一次录入的数据和这一次录入的做对比
String s = compareFields(issuanceInfo, issuanceInfos.get(0));
if (!s.isEmpty()) {
issuanceInfoMapper.deleteByExample(issuanceInfoExample);
Map<String, String> map = new HashMap<>();
map.put("flowId","流程ID");
map.put("companyName","公司名称");
map.put("securityCode","证券代码");
map.put("minimumNonRestrictedASharesMarketValue","最低非限售A股市值");
map.put("initialInquiryStartDate","初步询价起始日期");
map.put("offlineSubscriptionStartDate","网下申购起始日期");
map.put("totalIssuanceVolume","发行总量");
map.put("minimumSubscriptionVolume","最低申购量");
map.put("minimumSubscriptionVolumeChangeUnit","申购量变动最小单位");
map.put("maximumPriceToMinimumPriceRatio","初步询价最高申报价格与最低申报价格的最大比值");
map.put("leadUnderwriterPeRatioValuationLowerLimit","主承销商市盈率估值区间下限");
map.put("settlementReserveAccountOpened","是否已在结算公司开立结算备付金账户");
map.put("remainingShareRegistrationAccountShenzhen","余股登记账户");
map.put("jointUnderwriters","联合承销商");
map.put("securityAbbreviation","证券简称");
map.put("pricingMethod","定价方式");
map.put("voluntaryLockupPeriod","是否设自愿锁定期");
map.put("initialInquiryDeadline","初步询价截止日期");
map.put("offlineSubscriptionDeadline","网下申购截止日期");
map.put("offlineIssuanceQuantity","网下发行数量");
map.put("maximumSubscriptionQuantity","最高由购量");
map.put("numberOfPriceLevelsInInitialInquiryStage","初步询价阶段的价格档位数量");
map.put("leadUnderwriterPeRatioValuationUpperLimit","主承销商市盈率估值区间上限");
map.put("reserveAccount","备付金账户");
map.put("remainingShareCustodianSeatShenzhen","余股托管席位(深市)");
int colonIndex = s.indexOf(":");
// 截取字符串
String key = s.substring(0, colonIndex);
String value = map.get(key);
return new ResultEntity<>(HttpStatus.BAD_REQUEST, "两次输入的"+"(" + value + ")" + "不同!",s);
}
//完成新建发行申请3分
performanceScoreService.calculateScoreByModule("newPricingIssuanceScore", 3, issuanceInfo.getFlowId());
return new ResultEntity<>(HttpStatus.OK, s, "添加成功");
// if (!issuanceInfos.get(0).getSecurityCode().equals(issuanceInfo.getSecurityCode()))
// {
// issuanceInfo.setSecurityCode(issuanceInfos.get(0).getSecurityCode());
// }
//
// //获取上一次录入的数据和这一次录入的做对比
// String s = compareFields(issuanceInfo, issuanceInfos.get(0));
// if (!s.isEmpty()) {
// issuanceInfoMapper.deleteByExample(issuanceInfoExample);
// Map<String, String> map = new HashMap<>();
// map.put("flowId","流程ID");
// map.put("companyName","公司名称");
// map.put("securityCode","证券代码");
// map.put("minimumNonRestrictedASharesMarketValue","最低非限售A股市值");
// map.put("initialInquiryStartDate","初步询价起始日期");
// map.put("offlineSubscriptionStartDate","网下申购起始日期");
// map.put("totalIssuanceVolume","发行总量");
// map.put("minimumSubscriptionVolume","最低申购量");
// map.put("minimumSubscriptionVolumeChangeUnit","申购量变动最小单位");
// map.put("maximumPriceToMinimumPriceRatio","初步询价最高申报价格与最低申报价格的最大比值");
// map.put("leadUnderwriterPeRatioValuationLowerLimit","主承销商市盈率估值区间下限");
// map.put("settlementReserveAccountOpened","是否已在结算公司开立结算备付金账户");
// map.put("remainingShareRegistrationAccountShenzhen","余股登记账户");
// map.put("jointUnderwriters","联合承销商");
// map.put("securityAbbreviation","证券简称");
// map.put("pricingMethod","定价方式");
// map.put("voluntaryLockupPeriod","是否设自愿锁定期");
// map.put("initialInquiryDeadline","初步询价截止日期");
// map.put("offlineSubscriptionDeadline","网下申购截止日期");
// map.put("offlineIssuanceQuantity","网下发行数量");
// map.put("maximumSubscriptionQuantity","最高由购量");
// map.put("numberOfPriceLevelsInInitialInquiryStage","初步询价阶段的价格档位数量");
// map.put("leadUnderwriterPeRatioValuationUpperLimit","主承销商市盈率估值区间上限");
// map.put("reserveAccount","备付金账户");
// map.put("remainingShareCustodianSeatShenzhen","余股托管席位(深市)");
//
// int colonIndex = s.indexOf(":");
// // 截取字符串
// String key = s.substring(0, colonIndex);
//
// String value = map.get(key);
// return new ResultEntity<>(HttpStatus.BAD_REQUEST, "两次输入的"+"(" + value + ")" + "不同!",s);
// }
// //完成新建发行申请3分
// performanceScoreService.calculateScoreByModule("newPricingIssuanceScore", 3, issuanceInfo.getFlowId());
// return new ResultEntity<>(HttpStatus.OK, s, "添加成功");
return new ResultEntity(HttpStatus.BAD_REQUEST, "请勿重复录入!");
}
//第一次录入和估值做计算
else {
// else {
//查询立项公司估值
FoundProjectExample foundProjectExample = new FoundProjectExample();
foundProjectExample.createCriteria().andFlowIdEqualTo(issuanceInfo.getFlowId());
@ -381,6 +378,8 @@ public class ContractInvestmentServiceImpl implements ContractInvestmentService
issuanceInfo.setId(IdUtil.fastSimpleUUID());
//插入数据
issuanceInfoMapper.insert(issuanceInfo);
//加分
performanceScoreService.calculateScoreByModule("newPricingIssuanceScore", 3, issuanceInfo.getFlowId());
return new ResultEntity(HttpStatus.OK);
} else {
@ -390,18 +389,21 @@ public class ContractInvestmentServiceImpl implements ContractInvestmentService
if (info / aLong > 0.25) {
issuanceInfo.setId(IdUtil.fastSimpleUUID());
//插入数据
performanceScoreService.calculateScoreByModule("newPricingIssuanceScore", 3, issuanceInfo.getFlowId());
issuanceInfoMapper.insert(issuanceInfo);
return new ResultEntity(HttpStatus.OK,"",issuanceInfo.getSecurityCode());
return new ResultEntity(HttpStatus.OK);
} else {
return new ResultEntity(HttpStatus.BAD_REQUEST, "发行总量小于估值的25%");
}
}
//取出发行总量
}
}
}
return new ResultEntity<>(HttpStatus.BAD_REQUEST, "第一次未录入");
return null;
}
@ -469,49 +471,50 @@ public class ContractInvestmentServiceImpl implements ContractInvestmentService
List<IssuanceParameterInput> issuanceParameterInputList = issuanceParameterInputMapper.selectByExample(issuanceParameterInputExample);
//查询有无第一次录入的数据
if (issuanceParameterInputList.size() > 0) {
//获取上一次录入的数据和这一次录入的做对比
String s = compareFieldsTwo(issuanceParameterInput, issuanceParameterInputList.get(0));
if (!s.isEmpty()) {
issuanceParameterInputMapper.deleteByExample(issuanceParameterInputExample);
Map<String, String> map = new HashMap<>();
map.put("flowId","流程ID");
map.put("allotmentObjectCode","配售对象编码");
map.put("companyName","公司名称");
map.put("securityCode","证券代码");
map.put("securityAbbreviation","证券简称");
map.put("totalIssuanceVolume","发行总量");
map.put("issuancePrice","发行价格");
map.put("offlineIssuanceQuantity","网下发行数量");
map.put("minimumSubscriptionToShortlistedRatio","个配售对象申购数下限与入围数最之间的比值(%)");
map.put("maximumSubscriptionToShortlistedRatio","每个配售对象申购数上限与入围数最之间的比值");
map.put("dilutedPeRatio","摊薄前市盈率");
map.put("undilutedPeRatio","摊薄后市盈率");
int colonIndex = s.indexOf(":");
// 截取字符串
String key = s.substring(0, colonIndex);
String value = map.get(key);
return new ResultEntity<>(HttpStatus.BAD_REQUEST, "两次输入的"+"(" + value + ")" + "不同!",s);
}
//询价结果查询及发行参数录入2分
performanceScoreService.calculateScoreByModule("pricingIssuanceEnteringScore", 3, issuanceParameterInput.getFlowId());
PerformanceScore performanceScore = performanceScoreService.getByFlowId(issuanceParameterInput.getFlowId());
//询价发行完成时间
performanceScore.setPricingIssuanceTime(new Date());
performanceScoreMapper.updateByPrimaryKey(performanceScore);
// //获取上一次录入的数据和这一次录入的做对比
// String s = compareFieldsTwo(issuanceParameterInput, issuanceParameterInputList.get(0));
// if (!s.isEmpty()) {
// issuanceParameterInputMapper.deleteByExample(issuanceParameterInputExample);
//
// Map<String, String> map = new HashMap<>();
// map.put("flowId","流程ID");
// map.put("allotmentObjectCode","配售对象编码");
// map.put("companyName","公司名称");
// map.put("securityCode","证券代码");
// map.put("securityAbbreviation","证券简称");
// map.put("totalIssuanceVolume","发行总量");
// map.put("issuancePrice","发行价格");
// map.put("offlineIssuanceQuantity","网下发行数量");
// map.put("minimumSubscriptionToShortlistedRatio","个配售对象申购数下限与入围数最之间的比值(%)");
// map.put("maximumSubscriptionToShortlistedRatio","每个配售对象申购数上限与入围数最之间的比值");
// map.put("dilutedPeRatio","摊薄前市盈率");
// map.put("undilutedPeRatio","摊薄后市盈率");
//
// int colonIndex = s.indexOf(":");
// // 截取字符串
// String key = s.substring(0, colonIndex);
//
// String value = map.get(key);
//
//
// return new ResultEntity<>(HttpStatus.BAD_REQUEST, "两次输入的"+"(" + value + ")" + "不同!",s);
// }
// //询价结果查询及发行参数录入2分
// performanceScoreService.calculateScoreByModule("pricingIssuanceEnteringScore", 2, issuanceParameterInput.getFlowId());
//
// PerformanceScore performanceScore = performanceScoreService.getByFlowId(issuanceParameterInput.getFlowId());
// //询价发行完成时间
// performanceScore.setPricingIssuanceTime(new Date());
// performanceScoreMapper.updateByPrimaryKey(performanceScore);
return new ResultEntity<>(HttpStatus.OK, s, "添加成功");
return new ResultEntity(HttpStatus.BAD_REQUEST, "请勿重复录入!");
}
//第一次录入和估值做计算
else {
issuanceParameterInput.setId(IdUtil.fastSimpleUUID());
issuanceParameterInputMapper.insertSelective(issuanceParameterInput);
performanceScoreService.calculateScoreByModule("pricingIssuanceEnteringScore", 2, issuanceParameterInput.getFlowId());
return new ResultEntity<>(HttpStatus.OK);
}

@ -44,30 +44,16 @@ public class InquiryIssuanceServiceImpl implements InquiryIssuanceService {
PerformanceScoreMapper performanceScoreMapper;
@Override
public PageInfo<AllotmentObjectDTO> queryInquiryInvestors(String flowId, Integer size, Integer index) {
//开启分页
PageHelper.startPage(size,index);
public PageInfo<AllotmentObjectDTO> queryInquiryInvestors(String flowId) {
AllotmentObjectExample allotmentObjectExample=new AllotmentObjectExample();
allotmentObjectExample.createCriteria().andFlowIdEqualTo(flowId);
List<AllotmentObject> allotmentObjects = allotmentObjectMapper.selectByExample(allotmentObjectExample);
List<AllotmentObjectDTO> allotmentObjectDTOS =new ArrayList<>();
if(allotmentObjects.isEmpty()){
AllotmentObjectExample allotmentObjectExample1=new AllotmentObjectExample();
allotmentObjectExample1.createCriteria().andFlowIdIsNull();
List<AllotmentObject> list = allotmentObjectMapper.selectByExample(allotmentObjectExample1);
if(list.size()>0){
for (int i = 0; i < list.size(); i++) {
list.get(i).setId(String.valueOf(UUID.randomUUID()));
list.get(i).setLogic(1);
list.get(i).setFlowId(flowId);
allotmentObjectMapper.insert(list.get(i));
AllotmentObjectDTO allotmentObjectDTO = convertUtil.entityToDTO(list.get(i), AllotmentObjectDTO.class);
allotmentObjectDTO.setSure("是");
allotmentObjectDTOS.add(allotmentObjectDTO);
}
}
PageInfo<AllotmentObjectDTO> pageInfo=new PageInfo<>(allotmentObjectDTOS);
return pageInfo;
if(allotmentObjects.isEmpty()) {
AllotmentObject allotmentObject = new AllotmentObject(flowId);
allotmentObjectMapper.insert(allotmentObject);
allotmentObjects.add(allotmentObject);
}
for (int i = 0; i < allotmentObjects.size(); i++) {
AllotmentObjectDTO allotmentObjectDTO = convertUtil.entityToDTO(allotmentObjects.get(i), AllotmentObjectDTO.class);
@ -285,7 +271,11 @@ public class InquiryIssuanceServiceImpl implements InquiryIssuanceService {
@Override
public void basicInformationStorage(String objectivityEvaluation, Integer overallEvaluation, String valuationMethodRationalityEvaluation, String operator, BigDecimal declarationPrice,String flowId) {
InquiryParticipation inquiryParticipation=new InquiryParticipation();
InquiryParticipationExample example = new InquiryParticipationExample();
example.createCriteria().andFlowIdEqualTo(flowId);
List<InquiryParticipation> inquiryParticipations = inquiryParticipationMapper.selectByExample(example);
if(inquiryParticipations.isEmpty()){
InquiryParticipation inquiryParticipation = new InquiryParticipation();
inquiryParticipation.setId(String.valueOf(UUID.randomUUID()));
inquiryParticipation.setObjectivityEvaluation(objectivityEvaluation);
inquiryParticipation.setValuationMethodRationalityEvaluation(valuationMethodRationalityEvaluation);
@ -295,6 +285,20 @@ public class InquiryIssuanceServiceImpl implements InquiryIssuanceService {
inquiryParticipation.setFlowId(flowId);
inquiryParticipation.setStatus("0");
inquiryParticipationMapper.insert(inquiryParticipation);
}else {
InquiryParticipation inquiryParticipation = inquiryParticipations.get(0);
if(!inquiryParticipation.getStatus().equals("0")){
throw new RuntimeException("已提交报价无法更改");
}
inquiryParticipation.setObjectivityEvaluation(objectivityEvaluation);
inquiryParticipation.setValuationMethodRationalityEvaluation(valuationMethodRationalityEvaluation);
inquiryParticipation.setOverallEvaluation(overallEvaluation);
inquiryParticipation.setOperator(operator);
inquiryParticipation.setDeclarationPrice(declarationPrice);
inquiryParticipation.setFlowId(flowId);
inquiryParticipationMapper.updateByPrimaryKey(inquiryParticipation);
}
}
@Override
@ -345,17 +349,12 @@ public class InquiryIssuanceServiceImpl implements InquiryIssuanceService {
inquiryParticipation.setRemark(inquiryParticipation.getRemark());
inquiryParticipation1.setDeclarationPrice(inquiryParticipation.getDeclarationPrice());
inquiryParticipation1.setIntendedSubscriptionQuantity(inquiryParticipation.getIntendedSubscriptionQuantity());
inquiryParticipation1.setStatus("1");
inquiryParticipationMapper.updateByPrimaryKey(inquiryParticipation1);
PerformanceScoreExample performanceScoreExample=new PerformanceScoreExample();
performanceScoreExample.createCriteria().andFlowIdEqualTo(inquiryParticipation.getFlowId());
List<PerformanceScore> performanceScores = performanceScoreMapper.selectByExample(performanceScoreExample);
if(performanceScores.size()>0){
if(performanceScores.get(0).getInitPricingIssuanceScore()==null){
//计入分数
performanceScoreService.calculateScoreByModule("initPricingIssuanceScore",2,inquiryParticipation.getFlowId());
}
}
}
}
@Override
public PageInfo<PreliminaryStructureOfInquiryDTO> queryPreliminaryStructureOfInquiry(String flowId, Integer size, Integer index) {

@ -1,291 +0,0 @@
<?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.sztzjy.fund_investment.mapper.AllotmentObjectMapper">
<resultMap id="BaseResultMap" type="com.sztzjy.fund_investment.entity.AllotmentObject">
<id column="id" jdbcType="VARCHAR" property="id" />
<result column="allotment_object_code" jdbcType="VARCHAR" property="allotmentObjectCode" />
<result column="flow_id" jdbcType="VARCHAR" property="flowId" />
<result column="allotment_object_name" jdbcType="VARCHAR" property="allotmentObjectName" />
<result column="allotment_object_type" jdbcType="VARCHAR" property="allotmentObjectType" />
<result column="investor_code" jdbcType="INTEGER" property="investorCode" />
<result column="investor_name" jdbcType="VARCHAR" property="investorName" />
<result column="investor_type" jdbcType="VARCHAR" property="investorType" />
<result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
<result column="logic" jdbcType="INTEGER" property="logic" />
</resultMap>
<sql id="Example_Where_Clause">
<where>
<foreach collection="oredCriteria" item="criteria" separator="or">
<if test="criteria.valid">
<trim prefix="(" prefixOverrides="and" suffix=")">
<foreach collection="criteria.criteria" item="criterion">
<choose>
<when test="criterion.noValue">
and ${criterion.condition}
</when>
<when test="criterion.singleValue">
and ${criterion.condition} #{criterion.value}
</when>
<when test="criterion.betweenValue">
and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}
</when>
<when test="criterion.listValue">
and ${criterion.condition}
<foreach close=")" collection="criterion.value" item="listItem" open="(" separator=",">
#{listItem}
</foreach>
</when>
</choose>
</foreach>
</trim>
</if>
</foreach>
</where>
</sql>
<sql id="Update_By_Example_Where_Clause">
<where>
<foreach collection="example.oredCriteria" item="criteria" separator="or">
<if test="criteria.valid">
<trim prefix="(" prefixOverrides="and" suffix=")">
<foreach collection="criteria.criteria" item="criterion">
<choose>
<when test="criterion.noValue">
and ${criterion.condition}
</when>
<when test="criterion.singleValue">
and ${criterion.condition} #{criterion.value}
</when>
<when test="criterion.betweenValue">
and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}
</when>
<when test="criterion.listValue">
and ${criterion.condition}
<foreach close=")" collection="criterion.value" item="listItem" open="(" separator=",">
#{listItem}
</foreach>
</when>
</choose>
</foreach>
</trim>
</if>
</foreach>
</where>
</sql>
<sql id="Base_Column_List">
id, allotment_object_code, flow_id, allotment_object_name, allotment_object_type,
investor_code, investor_name, investor_type, create_time, logic
</sql>
<select id="selectByExample" parameterType="com.sztzjy.fund_investment.entity.AllotmentObjectExample" resultMap="BaseResultMap">
select
<if test="distinct">
distinct
</if>
<include refid="Base_Column_List" />
from allotment_object
<if test="_parameter != null">
<include refid="Example_Where_Clause" />
</if>
<if test="orderByClause != null">
order by ${orderByClause}
</if>
</select>
<select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from allotment_object
where id = #{id,jdbcType=VARCHAR}
</select>
<delete id="deleteByPrimaryKey" parameterType="java.lang.String">
delete from allotment_object
where id = #{id,jdbcType=VARCHAR}
</delete>
<delete id="deleteByExample" parameterType="com.sztzjy.fund_investment.entity.AllotmentObjectExample">
delete from allotment_object
<if test="_parameter != null">
<include refid="Example_Where_Clause" />
</if>
</delete>
<insert id="insert" parameterType="com.sztzjy.fund_investment.entity.AllotmentObject">
insert into allotment_object (id, allotment_object_code, flow_id,
allotment_object_name, allotment_object_type,
investor_code, investor_name, investor_type,
create_time, logic)
values (#{id,jdbcType=VARCHAR}, #{allotmentObjectCode,jdbcType=VARCHAR}, #{flowId,jdbcType=VARCHAR},
#{allotmentObjectName,jdbcType=VARCHAR}, #{allotmentObjectType,jdbcType=VARCHAR},
#{investorCode,jdbcType=INTEGER}, #{investorName,jdbcType=VARCHAR}, #{investorType,jdbcType=VARCHAR},
#{createTime,jdbcType=TIMESTAMP}, #{logic,jdbcType=INTEGER})
</insert>
<insert id="insertSelective" parameterType="com.sztzjy.fund_investment.entity.AllotmentObject">
insert into allotment_object
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
id,
</if>
<if test="allotmentObjectCode != null">
allotment_object_code,
</if>
<if test="flowId != null">
flow_id,
</if>
<if test="allotmentObjectName != null">
allotment_object_name,
</if>
<if test="allotmentObjectType != null">
allotment_object_type,
</if>
<if test="investorCode != null">
investor_code,
</if>
<if test="investorName != null">
investor_name,
</if>
<if test="investorType != null">
investor_type,
</if>
<if test="createTime != null">
create_time,
</if>
<if test="logic != null">
logic,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="id != null">
#{id,jdbcType=VARCHAR},
</if>
<if test="allotmentObjectCode != null">
#{allotmentObjectCode,jdbcType=VARCHAR},
</if>
<if test="flowId != null">
#{flowId,jdbcType=VARCHAR},
</if>
<if test="allotmentObjectName != null">
#{allotmentObjectName,jdbcType=VARCHAR},
</if>
<if test="allotmentObjectType != null">
#{allotmentObjectType,jdbcType=VARCHAR},
</if>
<if test="investorCode != null">
#{investorCode,jdbcType=INTEGER},
</if>
<if test="investorName != null">
#{investorName,jdbcType=VARCHAR},
</if>
<if test="investorType != null">
#{investorType,jdbcType=VARCHAR},
</if>
<if test="createTime != null">
#{createTime,jdbcType=TIMESTAMP},
</if>
<if test="logic != null">
#{logic,jdbcType=INTEGER},
</if>
</trim>
</insert>
<select id="countByExample" parameterType="com.sztzjy.fund_investment.entity.AllotmentObjectExample" resultType="java.lang.Long">
select count(*) from allotment_object
<if test="_parameter != null">
<include refid="Example_Where_Clause" />
</if>
</select>
<update id="updateByExampleSelective" parameterType="map">
update allotment_object
<set>
<if test="record.id != null">
id = #{record.id,jdbcType=VARCHAR},
</if>
<if test="record.allotmentObjectCode != null">
allotment_object_code = #{record.allotmentObjectCode,jdbcType=VARCHAR},
</if>
<if test="record.flowId != null">
flow_id = #{record.flowId,jdbcType=VARCHAR},
</if>
<if test="record.allotmentObjectName != null">
allotment_object_name = #{record.allotmentObjectName,jdbcType=VARCHAR},
</if>
<if test="record.allotmentObjectType != null">
allotment_object_type = #{record.allotmentObjectType,jdbcType=VARCHAR},
</if>
<if test="record.investorCode != null">
investor_code = #{record.investorCode,jdbcType=INTEGER},
</if>
<if test="record.investorName != null">
investor_name = #{record.investorName,jdbcType=VARCHAR},
</if>
<if test="record.investorType != null">
investor_type = #{record.investorType,jdbcType=VARCHAR},
</if>
<if test="record.createTime != null">
create_time = #{record.createTime,jdbcType=TIMESTAMP},
</if>
<if test="record.logic != null">
logic = #{record.logic,jdbcType=INTEGER},
</if>
</set>
<if test="_parameter != null">
<include refid="Update_By_Example_Where_Clause" />
</if>
</update>
<update id="updateByExample" parameterType="map">
update allotment_object
set id = #{record.id,jdbcType=VARCHAR},
allotment_object_code = #{record.allotmentObjectCode,jdbcType=VARCHAR},
flow_id = #{record.flowId,jdbcType=VARCHAR},
allotment_object_name = #{record.allotmentObjectName,jdbcType=VARCHAR},
allotment_object_type = #{record.allotmentObjectType,jdbcType=VARCHAR},
investor_code = #{record.investorCode,jdbcType=INTEGER},
investor_name = #{record.investorName,jdbcType=VARCHAR},
investor_type = #{record.investorType,jdbcType=VARCHAR},
create_time = #{record.createTime,jdbcType=TIMESTAMP},
logic = #{record.logic,jdbcType=INTEGER}
<if test="_parameter != null">
<include refid="Update_By_Example_Where_Clause" />
</if>
</update>
<update id="updateByPrimaryKeySelective" parameterType="com.sztzjy.fund_investment.entity.AllotmentObject">
update allotment_object
<set>
<if test="allotmentObjectCode != null">
allotment_object_code = #{allotmentObjectCode,jdbcType=VARCHAR},
</if>
<if test="flowId != null">
flow_id = #{flowId,jdbcType=VARCHAR},
</if>
<if test="allotmentObjectName != null">
allotment_object_name = #{allotmentObjectName,jdbcType=VARCHAR},
</if>
<if test="allotmentObjectType != null">
allotment_object_type = #{allotmentObjectType,jdbcType=VARCHAR},
</if>
<if test="investorCode != null">
investor_code = #{investorCode,jdbcType=INTEGER},
</if>
<if test="investorName != null">
investor_name = #{investorName,jdbcType=VARCHAR},
</if>
<if test="investorType != null">
investor_type = #{investorType,jdbcType=VARCHAR},
</if>
<if test="createTime != null">
create_time = #{createTime,jdbcType=TIMESTAMP},
</if>
<if test="logic != null">
logic = #{logic,jdbcType=INTEGER},
</if>
</set>
where id = #{id,jdbcType=VARCHAR}
</update>
<update id="updateByPrimaryKey" parameterType="com.sztzjy.fund_investment.entity.AllotmentObject">
update allotment_object
set allotment_object_code = #{allotmentObjectCode,jdbcType=VARCHAR},
flow_id = #{flowId,jdbcType=VARCHAR},
allotment_object_name = #{allotmentObjectName,jdbcType=VARCHAR},
allotment_object_type = #{allotmentObjectType,jdbcType=VARCHAR},
investor_code = #{investorCode,jdbcType=INTEGER},
investor_name = #{investorName,jdbcType=VARCHAR},
investor_type = #{investorType,jdbcType=VARCHAR},
create_time = #{createTime,jdbcType=TIMESTAMP},
logic = #{logic,jdbcType=INTEGER}
where id = #{id,jdbcType=VARCHAR}
</update>
</mapper>
Loading…
Cancel
Save