Skip to content

T
tamp_fund
Commit c745c999 authored by 张亚辉's avatar 张亚辉
Browse files
Options

Merge branch 'ht_order_bouns' into dev

parents 3ac13787 dcc9bbad
Hide whitespace changes
Inline Side-by-side
Showing with 263 additions and 1442 deletions
pom.xml
View file @ c745c999
......@@ -36,12 +36,34 @@
<artifactId>commons-pool2</artifactId>
<groupId>org.apache.commons</groupId>
</exclusion>
<exclusion>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
</exclusion>
<exclusion>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
</exclusion>
<exclusion>
<artifactId>fastjson</artifactId>
<groupId>com.alibaba</groupId>
</exclusion>
<exclusion>
<artifactId>commons-logging</artifactId>
<groupId>commons-logging</groupId>
</exclusion>
</exclusions>
</dependency>
<!-- 支持链路追踪的日志 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-sleuth</artifactId>
<exclusions>
<exclusion>
<artifactId>bcprov-jdk15on</artifactId>
<groupId>org.bouncycastle</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
......@@ -64,10 +86,45 @@
<artifactId>spring-boot-starter-undertow</artifactId>
</dependency>
<!-- <dependency>-->
<!-- <groupId>org.mybatis.spring.boot</groupId>-->
<!-- <artifactId>mybatis-spring-boot-starter</artifactId>-->
<!-- <version>2.1.2</version>-->
<!-- </dependency>-->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.1.2</version>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.4.3.1</version>
<exclusions>
<exclusion>
<artifactId>jsqlparser</artifactId>
<groupId>com.github.jsqlparser</groupId>
</exclusion>
<exclusion>
<artifactId>mybatis-spring</artifactId>
<groupId>org.mybatis</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
<version>2.9.2</version>
<exclusions>
<exclusion>
<artifactId>swagger-annotations</artifactId>
<groupId>io.swagger</groupId>
</exclusion>
<exclusion>
<artifactId>swagger-models</artifactId>
<groupId>io.swagger</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.github.xiaoymin</groupId>
<artifactId>swagger-bootstrap-ui</artifactId>
<version>1.9.3</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
......@@ -91,6 +148,10 @@
<artifactId>bcprov-jdk15on</artifactId>
<groupId>org.bouncycastle</groupId>
</exclusion>
<exclusion>
<artifactId>commons-io</artifactId>
<groupId>commons-io</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
......@@ -121,8 +182,8 @@
<version>1.2.13</version>
<exclusions>
<exclusion>
<artifactId>mybatis-spring-boot-starter</artifactId>
<groupId>org.mybatis.spring.boot</groupId>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
</exclusion>
</exclusions>
</dependency>
......@@ -215,6 +276,12 @@
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml</artifactId>
<version>4.1.2</version>
<exclusions>
<exclusion>
<artifactId>commons-collections4</artifactId>
<groupId>org.apache.commons</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
......
src/main/java/com/tanpu/fund/FundApplication.java
View file @ c745c999
package com.tanpu.fund;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
......@@ -17,6 +18,7 @@ import org.springframework.scheduling.annotation.EnableAsync;
"com.tanpu.common",
"com.tanpu.fund"
})
@MapperScan("com.tanpu.fund.mapper.generator")
public class FundApplication {
public static void main(String[] args) {
......
src/main/java/com/tanpu/fund/api/ProductOrderApi.java
View file @ c745c999
package com.tanpu.fund.api;
import com.tanpu.common.model.fund.resq.FundBounsResp;
import com.tanpu.common.model.product.resp.*;
import com.tanpu.common.resp.CommonResp;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
......@@ -26,4 +28,9 @@ public interface ProductOrderApi {
@GetMapping("/get/fund/lastnet")
CommonResp<List<NetBigDecimal>> getFundLastNet(@RequestParam("list") List<String> list);
@ApiOperation("查询基金分红信息")
@GetMapping("/get/fund/bounsinfo")
CommonResp<List<FundBounsResp>> getFundBounsinfo(@ApiParam("基金代码") @RequestParam("list") List<String> list,
@ApiParam("指定日期") @RequestParam("date") String date);
}
src/main/java/com/tanpu/fund/config/MybatisPlusConfig.java 0 → 100644
View file @ c745c999
package com.tanpu.fund.config;
import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
@MapperScan("com.tanpu.fund.mapper.**.*Mapper")
public class MybatisPlusConfig {
// 最新版
@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor() {
MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
return interceptor;
}
}
src/main/java/com/tanpu/fund/controller/ProductOrderController.java
View file @ c745c999
package com.tanpu.fund.controller;
import com.tanpu.common.model.fund.resq.FundBounsResp;
import com.tanpu.common.model.product.resp.*;
import com.tanpu.common.resp.CommonResp;
import com.tanpu.fund.api.ProductOrderApi;
import com.tanpu.fund.service.ProductOrderService;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
......@@ -38,4 +40,14 @@ public class ProductOrderController implements ProductOrderApi {
return CommonResp.success(this.productOrderService.getFundLastNet(list));
}
@Override
public CommonResp<List<FundBounsResp>> getFundBounsinfo(List<String> list, String date) {
if (CollectionUtils.isEmpty(list) || StringUtils.isBlank(date)) {
return CommonResp.error(CommonResp.PARAMETER_INVALID_STATUS_CODE, CommonResp.PARAMETER_INVALID_MESSAGE);
}
return CommonResp.success(this.productOrderService.getFundBounsinfo(list, date));
}
}
src/main/java/com/tanpu/fund/entity/generator/TxFundDistribution.java
View file @ c745c999
package com.tanpu.fund.entity.generator;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.math.BigDecimal;
import java.util.Date;
import lombok.AllArgsConstructor;
......@@ -7,43 +11,90 @@ import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* 基金分红
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@TableName(value = "tamp_fund.tx_fund_distribution")
public class TxFundDistribution {
private String id;
/**
* ID
*/
@TableField(value = "id")
private Long id;
/**
* 基金Id
*/
private String fundId;
* 最原始版本基金id
*/
@TableField(value = "fund_id")
private Long fundId;
@TableField(value = "fund_code")
private String fundCode;
/**
* 分配日期
*/
private Date distributeDate;
* 中文名称缩写
*/
@TableField(value = "fund_short_name")
private String fundShortName;
/**
* 基金分配类型标志：-1-其他，1-分红，2-拆分 3-业绩报酬 -1-其他
*/
private Integer distributeType;
* 信息发布日期
*/
@TableField(value = "ann_date")
private Date annDate;
/**
* 分红/拆分比例
*/
private BigDecimal distribution;
* 权益登记日
*/
@TableField(value = "register_date")
private Date registerDate;
private String createBy;
/**
* 发放日
*/
@TableField(value = "distribute_date")
private Date distributeDate;
private Date createTime;
/**
* 除权日
*/
@TableField(value = "ex_date")
private Date exDate;
private String updateBy;
/**
* 红利再投资日
*/
@TableField(value = "confirm_date")
private Date confirmDate;
@TableField(value = "distribution")
private BigDecimal distribution;
/**
* 修改日期
*/
@TableField(value = "update_time")
private Date updateTime;
@TableField(value = "delete_tag")
private Integer deleteTag;
@TableField(value = "distribute_type")
private byte[] distributeType;
@TableField(value = "create_by")
private byte[] createBy;
@TableField(value = "create_time")
private byte[] createTime;
@TableField(value = "update_by")
private byte[] updateBy;
@TableField(value = "org_id")
private byte[] orgId;
@TableField(value = "org")
private byte[] org;
}
\ No newline at end of file
src/main/java/com/tanpu/fund/entity/generator/TxFundDistributionExample.java deleted 100644 → 0
View file @ 3ac13787
package com.tanpu.fund.entity.generator;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
public class TxFundDistributionExample {
protected String orderByClause;
protected boolean distinct;
protected List<Criteria> oredCriteria;
public TxFundDistributionExample() {
oredCriteria = new ArrayList<>();
}
public void setOrderByClause(String orderByClause) {
this.orderByClause = orderByClause;
}
public String getOrderByClause() {
return orderByClause;
}
public void setDistinct(boolean distinct) {
this.distinct = distinct;
}
public boolean isDistinct() {
return distinct;
}
public List<Criteria> getOredCriteria() {
return oredCriteria;
}
public void or(Criteria criteria) {
oredCriteria.add(criteria);
}
public Criteria or() {
Criteria criteria = createCriteriaInternal();
oredCriteria.add(criteria);
return criteria;
}
public Criteria createCriteria() {
Criteria criteria = createCriteriaInternal();
if (oredCriteria.size() == 0) {
oredCriteria.add(criteria);
}
return criteria;
}
protected Criteria createCriteriaInternal() {
Criteria criteria = new Criteria();
return criteria;
}
public void clear() {
oredCriteria.clear();
orderByClause = null;
distinct = false;
}
protected abstract static class GeneratedCriteria {
protected List<Criterion> criteria;
protected GeneratedCriteria() {
super();
criteria = new ArrayList<>();
}
public boolean isValid() {
return criteria.size() > 0;
}
public List<Criterion> getAllCriteria() {
return criteria;
}
public List<Criterion> getCriteria() {
return criteria;
}
protected void addCriterion(String condition) {
if (condition == null) {
throw new RuntimeException("Value for condition cannot be null");
}
criteria.add(new Criterion(condition));
}
protected void addCriterion(String condition, Object value, String property) {
if (value == null) {
throw new RuntimeException("Value for " + property + " cannot be null");
}
criteria.add(new Criterion(condition, value));
}
protected void addCriterion(String condition, Object value1, Object value2, String property) {
if (value1 == null || value2 == null) {
throw new RuntimeException("Between values for " + property + " cannot be null");
}
criteria.add(new Criterion(condition, value1, value2));
}
protected void addCriterionForJDBCDate(String condition, Date value, String property) {
if (value == null) {
throw new RuntimeException("Value for " + property + " cannot be null");
}
addCriterion(condition, new java.sql.Date(value.getTime()), property);
}
protected void addCriterionForJDBCDate(String condition, List<Date> values, String property) {
if (values == null || values.size() == 0) {
throw new RuntimeException("Value list for " + property + " cannot be null or empty");
}
List<java.sql.Date> dateList = new ArrayList<>();
Iterator<Date> iter = values.iterator();
while (iter.hasNext()) {
dateList.add(new java.sql.Date(iter.next().getTime()));
}
addCriterion(condition, dateList, property);
}
protected void addCriterionForJDBCDate(String condition, Date value1, Date value2, String property) {
if (value1 == null || value2 == null) {
throw new RuntimeException("Between values for " + property + " cannot be null");
}
addCriterion(condition, new java.sql.Date(value1.getTime()), new java.sql.Date(value2.getTime()), property);
}
public Criteria andIdIsNull() {
addCriterion("id is null");
return (Criteria) this;
}
public Criteria andIdIsNotNull() {
addCriterion("id is not null");
return (Criteria) this;
}
public Criteria andIdEqualTo(String value) {
addCriterion("id =", value, "id");
return (Criteria) this;
}
public Criteria andIdNotEqualTo(String value) {
addCriterion("id <>", value, "id");
return (Criteria) this;
}
public Criteria andIdGreaterThan(String value) {
addCriterion("id >", value, "id");
return (Criteria) this;
}
public Criteria andIdGreaterThanOrEqualTo(String value) {
addCriterion("id >=", value, "id");
return (Criteria) this;
}
public Criteria andIdLessThan(String value) {
addCriterion("id <", value, "id");
return (Criteria) this;
}
public Criteria andIdLessThanOrEqualTo(String value) {
addCriterion("id <=", value, "id");
return (Criteria) this;
}
public Criteria andIdLike(String value) {
addCriterion("id like", value, "id");
return (Criteria) this;
}
public Criteria andIdNotLike(String value) {
addCriterion("id not like", value, "id");
return (Criteria) this;
}
public Criteria andIdIn(List<String> values) {
addCriterion("id in", values, "id");
return (Criteria) this;
}
public Criteria andIdNotIn(List<String> values) {
addCriterion("id not in", values, "id");
return (Criteria) this;
}
public Criteria andIdBetween(String value1, String value2) {
addCriterion("id between", value1, value2, "id");
return (Criteria) this;
}
public Criteria andIdNotBetween(String value1, String value2) {
addCriterion("id not between", value1, value2, "id");
return (Criteria) this;
}
public Criteria andFundIdIsNull() {
addCriterion("fund_id is null");
return (Criteria) this;
}
public Criteria andFundIdIsNotNull() {
addCriterion("fund_id is not null");
return (Criteria) this;
}
public Criteria andFundIdEqualTo(String value) {
addCriterion("fund_id =", value, "fundId");
return (Criteria) this;
}
public Criteria andFundIdNotEqualTo(String value) {
addCriterion("fund_id <>", value, "fundId");
return (Criteria) this;
}
public Criteria andFundIdGreaterThan(String value) {
addCriterion("fund_id >", value, "fundId");
return (Criteria) this;
}
public Criteria andFundIdGreaterThanOrEqualTo(String value) {
addCriterion("fund_id >=", value, "fundId");
return (Criteria) this;
}
public Criteria andFundIdLessThan(String value) {
addCriterion("fund_id <", value, "fundId");
return (Criteria) this;
}
public Criteria andFundIdLessThanOrEqualTo(String value) {
addCriterion("fund_id <=", value, "fundId");
return (Criteria) this;
}
public Criteria andFundIdLike(String value) {
addCriterion("fund_id like", value, "fundId");
return (Criteria) this;
}
public Criteria andFundIdNotLike(String value) {
addCriterion("fund_id not like", value, "fundId");
return (Criteria) this;
}
public Criteria andFundIdIn(List<String> values) {
addCriterion("fund_id in", values, "fundId");
return (Criteria) this;
}
public Criteria andFundIdNotIn(List<String> values) {
addCriterion("fund_id not in", values, "fundId");
return (Criteria) this;
}
public Criteria andFundIdBetween(String value1, String value2) {
addCriterion("fund_id between", value1, value2, "fundId");
return (Criteria) this;
}
public Criteria andFundIdNotBetween(String value1, String value2) {
addCriterion("fund_id not between", value1, value2, "fundId");
return (Criteria) this;
}
public Criteria andDistributeDateIsNull() {
addCriterion("distribute_date is null");
return (Criteria) this;
}
public Criteria andDistributeDateIsNotNull() {
addCriterion("distribute_date is not null");
return (Criteria) this;
}
public Criteria andDistributeDateEqualTo(Date value) {
addCriterionForJDBCDate("distribute_date =", value, "distributeDate");
return (Criteria) this;
}
public Criteria andDistributeDateNotEqualTo(Date value) {
addCriterionForJDBCDate("distribute_date <>", value, "distributeDate");
return (Criteria) this;
}
public Criteria andDistributeDateGreaterThan(Date value) {
addCriterionForJDBCDate("distribute_date >", value, "distributeDate");
return (Criteria) this;
}
public Criteria andDistributeDateGreaterThanOrEqualTo(Date value) {
addCriterionForJDBCDate("distribute_date >=", value, "distributeDate");
return (Criteria) this;
}
public Criteria andDistributeDateLessThan(Date value) {
addCriterionForJDBCDate("distribute_date <", value, "distributeDate");
return (Criteria) this;
}
public Criteria andDistributeDateLessThanOrEqualTo(Date value) {
addCriterionForJDBCDate("distribute_date <=", value, "distributeDate");
return (Criteria) this;
}
public Criteria andDistributeDateIn(List<Date> values) {
addCriterionForJDBCDate("distribute_date in", values, "distributeDate");
return (Criteria) this;
}
public Criteria andDistributeDateNotIn(List<Date> values) {
addCriterionForJDBCDate("distribute_date not in", values, "distributeDate");
return (Criteria) this;
}
public Criteria andDistributeDateBetween(Date value1, Date value2) {
addCriterionForJDBCDate("distribute_date between", value1, value2, "distributeDate");
return (Criteria) this;
}
public Criteria andDistributeDateNotBetween(Date value1, Date value2) {
addCriterionForJDBCDate("distribute_date not between", value1, value2, "distributeDate");
return (Criteria) this;
}
public Criteria andDistributeTypeIsNull() {
addCriterion("distribute_type is null");
return (Criteria) this;
}
public Criteria andDistributeTypeIsNotNull() {
addCriterion("distribute_type is not null");
return (Criteria) this;
}
public Criteria andDistributeTypeEqualTo(Integer value) {
addCriterion("distribute_type =", value, "distributeType");
return (Criteria) this;
}
public Criteria andDistributeTypeNotEqualTo(Integer value) {
addCriterion("distribute_type <>", value, "distributeType");
return (Criteria) this;
}
public Criteria andDistributeTypeGreaterThan(Integer value) {
addCriterion("distribute_type >", value, "distributeType");
return (Criteria) this;
}
public Criteria andDistributeTypeGreaterThanOrEqualTo(Integer value) {
addCriterion("distribute_type >=", value, "distributeType");
return (Criteria) this;
}
public Criteria andDistributeTypeLessThan(Integer value) {
addCriterion("distribute_type <", value, "distributeType");
return (Criteria) this;
}
public Criteria andDistributeTypeLessThanOrEqualTo(Integer value) {
addCriterion("distribute_type <=", value, "distributeType");
return (Criteria) this;
}
public Criteria andDistributeTypeIn(List<Integer> values) {
addCriterion("distribute_type in", values, "distributeType");
return (Criteria) this;
}
public Criteria andDistributeTypeNotIn(List<Integer> values) {
addCriterion("distribute_type not in", values, "distributeType");
return (Criteria) this;
}
public Criteria andDistributeTypeBetween(Integer value1, Integer value2) {
addCriterion("distribute_type between", value1, value2, "distributeType");
return (Criteria) this;
}
public Criteria andDistributeTypeNotBetween(Integer value1, Integer value2) {
addCriterion("distribute_type not between", value1, value2, "distributeType");
return (Criteria) this;
}
public Criteria andDistributionIsNull() {
addCriterion("distribution is null");
return (Criteria) this;
}
public Criteria andDistributionIsNotNull() {
addCriterion("distribution is not null");
return (Criteria) this;
}
public Criteria andDistributionEqualTo(BigDecimal value) {
addCriterion("distribution =", value, "distribution");
return (Criteria) this;
}
public Criteria andDistributionNotEqualTo(BigDecimal value) {
addCriterion("distribution <>", value, "distribution");
return (Criteria) this;
}
public Criteria andDistributionGreaterThan(BigDecimal value) {
addCriterion("distribution >", value, "distribution");
return (Criteria) this;
}
public Criteria andDistributionGreaterThanOrEqualTo(BigDecimal value) {
addCriterion("distribution >=", value, "distribution");
return (Criteria) this;
}
public Criteria andDistributionLessThan(BigDecimal value) {
addCriterion("distribution <", value, "distribution");
return (Criteria) this;
}
public Criteria andDistributionLessThanOrEqualTo(BigDecimal value) {
addCriterion("distribution <=", value, "distribution");
return (Criteria) this;
}
public Criteria andDistributionIn(List<BigDecimal> values) {
addCriterion("distribution in", values, "distribution");
return (Criteria) this;
}
public Criteria andDistributionNotIn(List<BigDecimal> values) {
addCriterion("distribution not in", values, "distribution");
return (Criteria) this;
}
public Criteria andDistributionBetween(BigDecimal value1, BigDecimal value2) {
addCriterion("distribution between", value1, value2, "distribution");
return (Criteria) this;
}
public Criteria andDistributionNotBetween(BigDecimal value1, BigDecimal value2) {
addCriterion("distribution not between", value1, value2, "distribution");
return (Criteria) this;
}
public Criteria andCreateByIsNull() {
addCriterion("create_by is null");
return (Criteria) this;
}
public Criteria andCreateByIsNotNull() {
addCriterion("create_by is not null");
return (Criteria) this;
}
public Criteria andCreateByEqualTo(String value) {
addCriterion("create_by =", value, "createBy");
return (Criteria) this;
}
public Criteria andCreateByNotEqualTo(String value) {
addCriterion("create_by <>", value, "createBy");
return (Criteria) this;
}
public Criteria andCreateByGreaterThan(String value) {
addCriterion("create_by >", value, "createBy");
return (Criteria) this;
}
public Criteria andCreateByGreaterThanOrEqualTo(String value) {
addCriterion("create_by >=", value, "createBy");
return (Criteria) this;
}
public Criteria andCreateByLessThan(String value) {
addCriterion("create_by <", value, "createBy");
return (Criteria) this;
}
public Criteria andCreateByLessThanOrEqualTo(String value) {
addCriterion("create_by <=", value, "createBy");
return (Criteria) this;
}
public Criteria andCreateByLike(String value) {
addCriterion("create_by like", value, "createBy");
return (Criteria) this;
}
public Criteria andCreateByNotLike(String value) {
addCriterion("create_by not like", value, "createBy");
return (Criteria) this;
}
public Criteria andCreateByIn(List<String> values) {
addCriterion("create_by in", values, "createBy");
return (Criteria) this;
}
public Criteria andCreateByNotIn(List<String> values) {
addCriterion("create_by not in", values, "createBy");
return (Criteria) this;
}
public Criteria andCreateByBetween(String value1, String value2) {
addCriterion("create_by between", value1, value2, "createBy");
return (Criteria) this;
}
public Criteria andCreateByNotBetween(String value1, String value2) {
addCriterion("create_by not between", value1, value2, "createBy");
return (Criteria) this;
}
public Criteria andCreateTimeIsNull() {
addCriterion("create_time is null");
return (Criteria) this;
}
public Criteria andCreateTimeIsNotNull() {
addCriterion("create_time is not null");
return (Criteria) this;
}
public Criteria andCreateTimeEqualTo(Date value) {
addCriterion("create_time =", value, "createTime");
return (Criteria) this;
}
public Criteria andCreateTimeNotEqualTo(Date value) {
addCriterion("create_time <>", value, "createTime");
return (Criteria) this;
}
public Criteria andCreateTimeGreaterThan(Date value) {
addCriterion("create_time >", value, "createTime");
return (Criteria) this;
}
public Criteria andCreateTimeGreaterThanOrEqualTo(Date value) {
addCriterion("create_time >=", value, "createTime");
return (Criteria) this;
}
public Criteria andCreateTimeLessThan(Date value) {
addCriterion("create_time <", value, "createTime");
return (Criteria) this;
}
public Criteria andCreateTimeLessThanOrEqualTo(Date value) {
addCriterion("create_time <=", value, "createTime");
return (Criteria) this;
}
public Criteria andCreateTimeIn(List<Date> values) {
addCriterion("create_time in", values, "createTime");
return (Criteria) this;
}
public Criteria andCreateTimeNotIn(List<Date> values) {
addCriterion("create_time not in", values, "createTime");
return (Criteria) this;
}
public Criteria andCreateTimeBetween(Date value1, Date value2) {
addCriterion("create_time between", value1, value2, "createTime");
return (Criteria) this;
}
public Criteria andCreateTimeNotBetween(Date value1, Date value2) {
addCriterion("create_time not between", value1, value2, "createTime");
return (Criteria) this;
}
public Criteria andUpdateByIsNull() {
addCriterion("update_by is null");
return (Criteria) this;
}
public Criteria andUpdateByIsNotNull() {
addCriterion("update_by is not null");
return (Criteria) this;
}
public Criteria andUpdateByEqualTo(String value) {
addCriterion("update_by =", value, "updateBy");
return (Criteria) this;
}
public Criteria andUpdateByNotEqualTo(String value) {
addCriterion("update_by <>", value, "updateBy");
return (Criteria) this;
}
public Criteria andUpdateByGreaterThan(String value) {
addCriterion("update_by >", value, "updateBy");
return (Criteria) this;
}
public Criteria andUpdateByGreaterThanOrEqualTo(String value) {
addCriterion("update_by >=", value, "updateBy");
return (Criteria) this;
}
public Criteria andUpdateByLessThan(String value) {
addCriterion("update_by <", value, "updateBy");
return (Criteria) this;
}
public Criteria andUpdateByLessThanOrEqualTo(String value) {
addCriterion("update_by <=", value, "updateBy");
return (Criteria) this;
}
public Criteria andUpdateByLike(String value) {
addCriterion("update_by like", value, "updateBy");
return (Criteria) this;
}
public Criteria andUpdateByNotLike(String value) {
addCriterion("update_by not like", value, "updateBy");
return (Criteria) this;
}
public Criteria andUpdateByIn(List<String> values) {
addCriterion("update_by in", values, "updateBy");
return (Criteria) this;
}
public Criteria andUpdateByNotIn(List<String> values) {
addCriterion("update_by not in", values, "updateBy");
return (Criteria) this;
}
public Criteria andUpdateByBetween(String value1, String value2) {
addCriterion("update_by between", value1, value2, "updateBy");
return (Criteria) this;
}
public Criteria andUpdateByNotBetween(String value1, String value2) {
addCriterion("update_by not between", value1, value2, "updateBy");
return (Criteria) this;
}
public Criteria andUpdateTimeIsNull() {
addCriterion("update_time is null");
return (Criteria) this;
}
public Criteria andUpdateTimeIsNotNull() {
addCriterion("update_time is not null");
return (Criteria) this;
}
public Criteria andUpdateTimeEqualTo(Date value) {
addCriterion("update_time =", value, "updateTime");
return (Criteria) this;
}
public Criteria andUpdateTimeNotEqualTo(Date value) {
addCriterion("update_time <>", value, "updateTime");
return (Criteria) this;
}
public Criteria andUpdateTimeGreaterThan(Date value) {
addCriterion("update_time >", value, "updateTime");
return (Criteria) this;
}
public Criteria andUpdateTimeGreaterThanOrEqualTo(Date value) {
addCriterion("update_time >=", value, "updateTime");
return (Criteria) this;
}
public Criteria andUpdateTimeLessThan(Date value) {
addCriterion("update_time <", value, "updateTime");
return (Criteria) this;
}
public Criteria andUpdateTimeLessThanOrEqualTo(Date value) {
addCriterion("update_time <=", value, "updateTime");
return (Criteria) this;
}
public Criteria andUpdateTimeIn(List<Date> values) {
addCriterion("update_time in", values, "updateTime");
return (Criteria) this;
}
public Criteria andUpdateTimeNotIn(List<Date> values) {
addCriterion("update_time not in", values, "updateTime");
return (Criteria) this;
}
public Criteria andUpdateTimeBetween(Date value1, Date value2) {
addCriterion("update_time between", value1, value2, "updateTime");
return (Criteria) this;
}
public Criteria andUpdateTimeNotBetween(Date value1, Date value2) {
addCriterion("update_time not between", value1, value2, "updateTime");
return (Criteria) this;
}
public Criteria andDeleteTagIsNull() {
addCriterion("delete_tag is null");
return (Criteria) this;
}
public Criteria andDeleteTagIsNotNull() {
addCriterion("delete_tag is not null");
return (Criteria) this;
}
public Criteria andDeleteTagEqualTo(Integer value) {
addCriterion("delete_tag =", value, "deleteTag");
return (Criteria) this;
}
public Criteria andDeleteTagNotEqualTo(Integer value) {
addCriterion("delete_tag <>", value, "deleteTag");
return (Criteria) this;
}
public Criteria andDeleteTagGreaterThan(Integer value) {
addCriterion("delete_tag >", value, "deleteTag");
return (Criteria) this;
}
public Criteria andDeleteTagGreaterThanOrEqualTo(Integer value) {
addCriterion("delete_tag >=", value, "deleteTag");
return (Criteria) this;
}
public Criteria andDeleteTagLessThan(Integer value) {
addCriterion("delete_tag <", value, "deleteTag");
return (Criteria) this;
}
public Criteria andDeleteTagLessThanOrEqualTo(Integer value) {
addCriterion("delete_tag <=", value, "deleteTag");
return (Criteria) this;
}
public Criteria andDeleteTagIn(List<Integer> values) {
addCriterion("delete_tag in", values, "deleteTag");
return (Criteria) this;
}
public Criteria andDeleteTagNotIn(List<Integer> values) {
addCriterion("delete_tag not in", values, "deleteTag");
return (Criteria) this;
}
public Criteria andDeleteTagBetween(Integer value1, Integer value2) {
addCriterion("delete_tag between", value1, value2, "deleteTag");
return (Criteria) this;
}
public Criteria andDeleteTagNotBetween(Integer value1, Integer value2) {
addCriterion("delete_tag not between", value1, value2, "deleteTag");
return (Criteria) this;
}
}
public static class Criteria extends GeneratedCriteria {
protected Criteria() {
super();
}
}
public static class Criterion {
private String condition;
private Object value;
private Object secondValue;
private boolean noValue;
private boolean singleValue;
private boolean betweenValue;
private boolean listValue;
private String typeHandler;
public String getCondition() {
return condition;
}
public Object getValue() {
return value;
}
public Object getSecondValue() {
return secondValue;
}
public boolean isNoValue() {
return noValue;
}
public boolean isSingleValue() {
return singleValue;
}
public boolean isBetweenValue() {
return betweenValue;
}
public boolean isListValue() {
return listValue;
}
public String getTypeHandler() {
return typeHandler;
}
protected Criterion(String condition) {
super();
this.condition = condition;
this.typeHandler = null;
this.noValue = true;
}
protected Criterion(String condition, Object value, String typeHandler) {
super();
this.condition = condition;
this.value = value;
this.typeHandler = typeHandler;
if (value instanceof List<?>) {
this.listValue = true;
} else {
this.singleValue = true;
}
}
protected Criterion(String condition, Object value) {
this(condition, value, null);
}
protected Criterion(String condition, Object value, Object secondValue, String typeHandler) {
super();
this.condition = condition;
this.value = value;
this.secondValue = secondValue;
this.typeHandler = typeHandler;
this.betweenValue = true;
}
protected Criterion(String condition, Object value, Object secondValue) {
this(condition, value, secondValue, null);
}
}
}
\ No newline at end of file
src/main/java/com/tanpu/fund/mapper/generator/TxFundDistributionMapper.java
View file @ c745c999
package com.tanpu.fund.mapper.generator;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.tanpu.fund.entity.generator.TxFundDistribution;
import com.tanpu.fund.entity.generator.TxFundDistributionExample;
import java.util.List;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@Mapper
public interface TxFundDistributionMapper {
long countByExample(TxFundDistributionExample example);
int deleteByExample(TxFundDistributionExample example);
/**
* delete by primary key
* @param id primaryKey
* @return deleteCount
*/
int deleteByPrimaryKey(String id);
/**
* insert record to table
* @param record the record
* @return insert count
*/
int insert(TxFundDistribution record);
int insertOrUpdate(TxFundDistribution record);
int insertOrUpdateSelective(TxFundDistribution record);
/**
* insert record to table selective
* @param record the record
* @return insert count
*/
int insertSelective(TxFundDistribution record);
List<TxFundDistribution> selectByExample(TxFundDistributionExample example);
/**
* select by primary key
* @param id primary key
* @return object by primary key
*/
TxFundDistribution selectByPrimaryKey(String id);
int updateByExampleSelective(@Param("record") TxFundDistribution record, @Param("example") TxFundDistributionExample example);
int updateByExample(@Param("record") TxFundDistribution record, @Param("example") TxFundDistributionExample example);
/**
* update record selective
* @param record the updated record
* @return update count
*/
int updateByPrimaryKeySelective(TxFundDistribution record);
/**
* update record
* @param record the updated record
* @return update count
*/
int updateByPrimaryKey(TxFundDistribution record);
int updateBatch(List<TxFundDistribution> list);
int batchInsert(@Param("list") List<TxFundDistribution> list);
}
\ No newline at end of file
public interface TxFundDistributionMapper extends BaseMapper<TxFundDistribution> {
}
src/main/java/com/tanpu/fund/service/ProductOrderService.java
View file @ c745c999
package com.tanpu.fund.service;
import com.tanpu.common.model.fund.resq.FundBounsResp;
import com.tanpu.common.model.product.resp.AttachmentInfoVO;
import com.tanpu.common.model.product.resp.FilePreviewResp;
import com.tanpu.common.model.product.resp.FundInfoResp;
......@@ -19,4 +20,6 @@ public interface ProductOrderService {
List<NetBigDecimal> getFundLastNet(List<String> list);
List<FilePreviewResp> getFilePreview(List<String> list);
List<FundBounsResp> getFundBounsinfo(List<String> list, String date);
}
src/main/java/com/tanpu/fund/service/impl/ProductOrderServiceImpl.java
View file @ c745c999
package com.tanpu.fund.service.impl;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.google.common.collect.Lists;
import com.tanpu.common.enums.BizEnums;
import com.tanpu.common.enums.Constant;
import com.tanpu.common.enums.fund.FundFileTypeEnum;
import com.tanpu.common.model.fund.resq.FundBounsResp;
import com.tanpu.common.model.product.resp.*;
import com.tanpu.common.utils.BigDecimalUtil;
import com.tanpu.fund.entity.generator.*;
......@@ -44,6 +47,12 @@ public class ProductOrderServiceImpl implements ProductOrderService, Constant {
@Resource
private FundInfoCustomMapper fundInfoCustomMapper;
@Resource
private TxFundDistributionMapper txFundDistributionMapper;
@Resource
private TxFundNavMapper txFundNavMapper;
@Override
public List<FundInfoResp> getFundInfos(List<String> list) {
FundInfoExample example = new FundInfoExample();
......@@ -119,4 +128,42 @@ public class ProductOrderServiceImpl implements ProductOrderService, Constant {
return this.fundInfoCustomMapper.getFilePreviewUrl(list.stream().collect(Collectors.joining("','", "'", "'")))
.stream().peek(f -> f.setPreviewUrl(suffix + f.getPreviewUrl().substring(f.getPreviewUrl().lastIndexOf("/") + 1, f.getPreviewUrl().lastIndexOf(".")))).collect(Collectors.toList());
}
@Override
public List<FundBounsResp> getFundBounsinfo(List<String> list, String date) {
LambdaQueryWrapper<TxFundDistribution> queryWrapper = new LambdaQueryWrapper<>();
final List<TxFundDistribution> distributionList = this.txFundDistributionMapper
.selectList(queryWrapper.ge(TxFundDistribution::getRegisterDate, date)
.in(TxFundDistribution::getFundCode, list).eq(TxFundDistribution::getDeleteTag, BizEnums.DeleteTag.tag_init));
if (CollectionUtils.isNotEmpty(distributionList)) {
// 查询分红权益日内基金净值
TxFundNavExample fundNavExample = new TxFundNavExample();
fundNavExample.createCriteria()
.andFundIdIn(distributionList.stream().map(c -> String.valueOf(c.getFundId())).collect(Collectors.toList()))
.andPriceDateIn(distributionList.stream().map(TxFundDistribution::getRegisterDate).collect(Collectors.toList()))
.andDeleteTagEqualTo(BizEnums.DeleteTag.tag_init);
final Map<String, List<TxFundNav>> txFundNavMap = this.txFundNavMapper.selectByExample(fundNavExample)
.stream().collect(Collectors.groupingBy(TxFundNav::getFundId));
return distributionList.stream().map(c -> {
final FundBounsResp build = FundBounsResp.builder()
.fundId(c.getFundId())
.fundCode(c.getFundCode())
.registerDate(c.getRegisterDate())
.distributeDate(c.getDistributeDate())
.distribution(c.getDistribution())
.build();
final TxFundNav txFundNav = txFundNavMap.get(String.valueOf(c.getFundId())).stream()
.filter(nav -> StringUtils.equals(String.valueOf(c.getFundId()), nav.getFundId())
&& c.getRegisterDate().getTime() == nav.getPriceDate().getTime()).findFirst().get();
build.setFundNet(txFundNav.getNav());
return build;
}).collect(Collectors.toList());
}
return new ArrayList<>(0);
}
}
src/main/resources/application-test.properties
View file @ c745c999
......@@ -19,6 +19,7 @@ company.oss.prefix = https://tamp-pro.oss-cn-shanghai.aliyuncs.com/
#mybatis
mybatis.mapper-locations=classpath:mybatis/generator/*.xml,classpath:mybatis/customize/*.xml
mybatis-plus.mapper-locations=classpath:mybatis/generator/*.xml,classpath:mybatis/customize/*.xml
#redis\u96C6\u7FA4\u914D\u7F6E
spring.redis.host=118.190.63.109
......
src/main/resources/mybatis/generator/TxFundDistributionMapper.xml
View file @ c745c999
......@@ -3,497 +3,37 @@
<mapper namespace="com.tanpu.fund.mapper.generator.TxFundDistributionMapper">
<resultMap id="BaseResultMap" type="com.tanpu.fund.entity.generator.TxFundDistribution">
<!--@mbg.generated-->
<!--@Table tx_fund_distribution-->
<id column="id" jdbcType="VARCHAR" property="id" />
<result column="fund_id" jdbcType="VARCHAR" property="fundId" />
<result column="distribute_date" jdbcType="DATE" property="distributeDate" />
<result column="distribute_type" jdbcType="INTEGER" property="distributeType" />
<!--@Table tamp_fund.tx_fund_distribution-->
<result column="id" jdbcType="BIGINT" property="id" />
<result column="fund_id" jdbcType="BIGINT" property="fundId" />
<result column="fund_code" jdbcType="VARCHAR" property="fundCode" />
<result column="fund_short_name" jdbcType="VARCHAR" property="fundShortName" />
<result column="ann_date" jdbcType="TIMESTAMP" property="annDate" />
<result column="register_date" jdbcType="TIMESTAMP" property="registerDate" />
<result column="distribute_date" jdbcType="TIMESTAMP" property="distributeDate" />
<result column="ex_date" jdbcType="TIMESTAMP" property="exDate" />
<result column="confirm_date" jdbcType="TIMESTAMP" property="confirmDate" />
<result column="distribution" jdbcType="DECIMAL" property="distribution" />
<result column="create_by" jdbcType="VARCHAR" property="createBy" />
<result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
<result column="update_by" jdbcType="VARCHAR" property="updateBy" />
<result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
<result column="delete_tag" jdbcType="INTEGER" property="deleteTag" />
</resultMap>
<sql id="Example_Where_Clause">
<!--@mbg.generated-->
<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">
<!--@mbg.generated-->
<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>
<resultMap extends="BaseResultMap" id="ResultMapWithBLOBs" type="com.tanpu.fund.entity.generator.TxFundDistribution">
<!--@mbg.generated-->
<!--@Table tamp_fund.tx_fund_distribution-->
<result column="distribute_type" jdbcType="VARBINARY" property="distributeType" />
<result column="create_by" jdbcType="VARBINARY" property="createBy" />
<result column="create_time" jdbcType="VARBINARY" property="createTime" />
<result column="update_by" jdbcType="VARBINARY" property="updateBy" />
<result column="org_id" jdbcType="VARBINARY" property="orgId" />
<result column="org" jdbcType="VARBINARY" property="org" />
</resultMap>
<sql id="Base_Column_List">
<!--@mbg.generated-->
id, fund_id, distribute_date, distribute_type, distribution, create_by, create_time,
update_by, update_time, delete_tag
id, fund_id, fund_code, fund_short_name, ann_date, register_date, distribute_date,
ex_date, confirm_date, distribution, update_time, delete_tag
</sql>
<select id="selectByExample" parameterType="com.tanpu.fund.entity.generator.TxFundDistributionExample" resultMap="BaseResultMap">
<!--@mbg.generated-->
select
<if test="distinct">
distinct
</if>
<include refid="Base_Column_List" />
from tx_fund_distribution
<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">
<!--@mbg.generated-->
select
<include refid="Base_Column_List" />
from tx_fund_distribution
where id = #{id,jdbcType=VARCHAR}
</select>
<delete id="deleteByPrimaryKey" parameterType="java.lang.String">
<!--@mbg.generated-->
delete from tx_fund_distribution
where id = #{id,jdbcType=VARCHAR}
</delete>
<delete id="deleteByExample" parameterType="com.tanpu.fund.entity.generator.TxFundDistributionExample">
<!--@mbg.generated-->
delete from tx_fund_distribution
<if test="_parameter != null">
<include refid="Example_Where_Clause" />
</if>
</delete>
<insert id="insert" parameterType="com.tanpu.fund.entity.generator.TxFundDistribution">
<!--@mbg.generated-->
insert into tx_fund_distribution (id, fund_id, distribute_date,
distribute_type, distribution, create_by,
create_time, update_by, update_time,
delete_tag)
values (#{id,jdbcType=VARCHAR}, #{fundId,jdbcType=VARCHAR}, #{distributeDate,jdbcType=DATE},
#{distributeType,jdbcType=INTEGER}, #{distribution,jdbcType=DECIMAL}, #{createBy,jdbcType=VARCHAR},
#{createTime,jdbcType=TIMESTAMP}, #{updateBy,jdbcType=VARCHAR}, #{updateTime,jdbcType=TIMESTAMP},
#{deleteTag,jdbcType=INTEGER})
</insert>
<insert id="insertSelective" parameterType="com.tanpu.fund.entity.generator.TxFundDistribution">
<sql id="Blob_Column_List">
<!--@mbg.generated-->
insert into tx_fund_distribution
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
id,
</if>
<if test="fundId != null">
fund_id,
</if>
<if test="distributeDate != null">
distribute_date,
</if>
<if test="distributeType != null">
distribute_type,
</if>
<if test="distribution != null">
distribution,
</if>
<if test="createBy != null">
create_by,
</if>
<if test="createTime != null">
create_time,
</if>
<if test="updateBy != null">
update_by,
</if>
<if test="updateTime != null">
update_time,
</if>
<if test="deleteTag != null">
delete_tag,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="id != null">
#{id,jdbcType=VARCHAR},
</if>
<if test="fundId != null">
#{fundId,jdbcType=VARCHAR},
</if>
<if test="distributeDate != null">
#{distributeDate,jdbcType=DATE},
</if>
<if test="distributeType != null">
#{distributeType,jdbcType=INTEGER},
</if>
<if test="distribution != null">
#{distribution,jdbcType=DECIMAL},
</if>
<if test="createBy != null">
#{createBy,jdbcType=VARCHAR},
</if>
<if test="createTime != null">
#{createTime,jdbcType=TIMESTAMP},
</if>
<if test="updateBy != null">
#{updateBy,jdbcType=VARCHAR},
</if>
<if test="updateTime != null">
#{updateTime,jdbcType=TIMESTAMP},
</if>
<if test="deleteTag != null">
#{deleteTag,jdbcType=INTEGER},
</if>
</trim>
</insert>
<select id="countByExample" parameterType="com.tanpu.fund.entity.generator.TxFundDistributionExample" resultType="java.lang.Long">
<!--@mbg.generated-->
select count(*) from tx_fund_distribution
<if test="_parameter != null">
<include refid="Example_Where_Clause" />
</if>
</select>
<update id="updateByExampleSelective" parameterType="map">
<!--@mbg.generated-->
update tx_fund_distribution
<set>
<if test="record.id != null">
id = #{record.id,jdbcType=VARCHAR},
</if>
<if test="record.fundId != null">
fund_id = #{record.fundId,jdbcType=VARCHAR},
</if>
<if test="record.distributeDate != null">
distribute_date = #{record.distributeDate,jdbcType=DATE},
</if>
<if test="record.distributeType != null">
distribute_type = #{record.distributeType,jdbcType=INTEGER},
</if>
<if test="record.distribution != null">
distribution = #{record.distribution,jdbcType=DECIMAL},
</if>
<if test="record.createBy != null">
create_by = #{record.createBy,jdbcType=VARCHAR},
</if>
<if test="record.createTime != null">
create_time = #{record.createTime,jdbcType=TIMESTAMP},
</if>
<if test="record.updateBy != null">
update_by = #{record.updateBy,jdbcType=VARCHAR},
</if>
<if test="record.updateTime != null">
update_time = #{record.updateTime,jdbcType=TIMESTAMP},
</if>
<if test="record.deleteTag != null">
delete_tag = #{record.deleteTag,jdbcType=INTEGER},
</if>
</set>
<if test="_parameter != null">
<include refid="Update_By_Example_Where_Clause" />
</if>
</update>
<update id="updateByExample" parameterType="map">
<!--@mbg.generated-->
update tx_fund_distribution
set id = #{record.id,jdbcType=VARCHAR},
fund_id = #{record.fundId,jdbcType=VARCHAR},
distribute_date = #{record.distributeDate,jdbcType=DATE},
distribute_type = #{record.distributeType,jdbcType=INTEGER},
distribution = #{record.distribution,jdbcType=DECIMAL},
create_by = #{record.createBy,jdbcType=VARCHAR},
create_time = #{record.createTime,jdbcType=TIMESTAMP},
update_by = #{record.updateBy,jdbcType=VARCHAR},
update_time = #{record.updateTime,jdbcType=TIMESTAMP},
delete_tag = #{record.deleteTag,jdbcType=INTEGER}
<if test="_parameter != null">
<include refid="Update_By_Example_Where_Clause" />
</if>
</update>
<update id="updateByPrimaryKeySelective" parameterType="com.tanpu.fund.entity.generator.TxFundDistribution">
<!--@mbg.generated-->
update tx_fund_distribution
<set>
<if test="fundId != null">
fund_id = #{fundId,jdbcType=VARCHAR},
</if>
<if test="distributeDate != null">
distribute_date = #{distributeDate,jdbcType=DATE},
</if>
<if test="distributeType != null">
distribute_type = #{distributeType,jdbcType=INTEGER},
</if>
<if test="distribution != null">
distribution = #{distribution,jdbcType=DECIMAL},
</if>
<if test="createBy != null">
create_by = #{createBy,jdbcType=VARCHAR},
</if>
<if test="createTime != null">
create_time = #{createTime,jdbcType=TIMESTAMP},
</if>
<if test="updateBy != null">
update_by = #{updateBy,jdbcType=VARCHAR},
</if>
<if test="updateTime != null">
update_time = #{updateTime,jdbcType=TIMESTAMP},
</if>
<if test="deleteTag != null">
delete_tag = #{deleteTag,jdbcType=INTEGER},
</if>
</set>
where id = #{id,jdbcType=VARCHAR}
</update>
<update id="updateByPrimaryKey" parameterType="com.tanpu.fund.entity.generator.TxFundDistribution">
<!--@mbg.generated-->
update tx_fund_distribution
set fund_id = #{fundId,jdbcType=VARCHAR},
distribute_date = #{distributeDate,jdbcType=DATE},
distribute_type = #{distributeType,jdbcType=INTEGER},
distribution = #{distribution,jdbcType=DECIMAL},
create_by = #{createBy,jdbcType=VARCHAR},
create_time = #{createTime,jdbcType=TIMESTAMP},
update_by = #{updateBy,jdbcType=VARCHAR},
update_time = #{updateTime,jdbcType=TIMESTAMP},
delete_tag = #{deleteTag,jdbcType=INTEGER}
where id = #{id,jdbcType=VARCHAR}
</update>
<update id="updateBatch" parameterType="java.util.List">
<!--@mbg.generated-->
update tx_fund_distribution
<trim prefix="set" suffixOverrides=",">
<trim prefix="fund_id = case" suffix="end,">
<foreach collection="list" index="index" item="item">
when id = #{item.id,jdbcType=VARCHAR} then #{item.fundId,jdbcType=VARCHAR}
</foreach>
</trim>
<trim prefix="distribute_date = case" suffix="end,">
<foreach collection="list" index="index" item="item">
when id = #{item.id,jdbcType=VARCHAR} then #{item.distributeDate,jdbcType=DATE}
</foreach>
</trim>
<trim prefix="distribute_type = case" suffix="end,">
<foreach collection="list" index="index" item="item">
when id = #{item.id,jdbcType=VARCHAR} then #{item.distributeType,jdbcType=INTEGER}
</foreach>
</trim>
<trim prefix="distribution = case" suffix="end,">
<foreach collection="list" index="index" item="item">
when id = #{item.id,jdbcType=VARCHAR} then #{item.distribution,jdbcType=DECIMAL}
</foreach>
</trim>
<trim prefix="create_by = case" suffix="end,">
<foreach collection="list" index="index" item="item">
when id = #{item.id,jdbcType=VARCHAR} then #{item.createBy,jdbcType=VARCHAR}
</foreach>
</trim>
<trim prefix="create_time = case" suffix="end,">
<foreach collection="list" index="index" item="item">
when id = #{item.id,jdbcType=VARCHAR} then #{item.createTime,jdbcType=TIMESTAMP}
</foreach>
</trim>
<trim prefix="update_by = case" suffix="end,">
<foreach collection="list" index="index" item="item">
when id = #{item.id,jdbcType=VARCHAR} then #{item.updateBy,jdbcType=VARCHAR}
</foreach>
</trim>
<trim prefix="update_time = case" suffix="end,">
<foreach collection="list" index="index" item="item">
when id = #{item.id,jdbcType=VARCHAR} then #{item.updateTime,jdbcType=TIMESTAMP}
</foreach>
</trim>
<trim prefix="delete_tag = case" suffix="end,">
<foreach collection="list" index="index" item="item">
when id = #{item.id,jdbcType=VARCHAR} then #{item.deleteTag,jdbcType=INTEGER}
</foreach>
</trim>
</trim>
where id in
<foreach close=")" collection="list" item="item" open="(" separator=", ">
#{item.id,jdbcType=VARCHAR}
</foreach>
</update>
<insert id="batchInsert" parameterType="map">
<!--@mbg.generated-->
insert into tx_fund_distribution
(id, fund_id, distribute_date, distribute_type, distribution, create_by, create_time,
update_by, update_time, delete_tag)
values
<foreach collection="list" item="item" separator=",">
(#{item.id,jdbcType=VARCHAR}, #{item.fundId,jdbcType=VARCHAR}, #{item.distributeDate,jdbcType=DATE},
#{item.distributeType,jdbcType=INTEGER}, #{item.distribution,jdbcType=DECIMAL},
#{item.createBy,jdbcType=VARCHAR}, #{item.createTime,jdbcType=TIMESTAMP}, #{item.updateBy,jdbcType=VARCHAR},
#{item.updateTime,jdbcType=TIMESTAMP}, #{item.deleteTag,jdbcType=INTEGER})
</foreach>
</insert>
<insert id="insertOrUpdate" parameterType="com.tanpu.fund.entity.generator.TxFundDistribution">
<!--@mbg.generated-->
insert into tx_fund_distribution
(id, fund_id, distribute_date, distribute_type, distribution, create_by, create_time,
update_by, update_time, delete_tag)
values
(#{id,jdbcType=VARCHAR}, #{fundId,jdbcType=VARCHAR}, #{distributeDate,jdbcType=DATE},
#{distributeType,jdbcType=INTEGER}, #{distribution,jdbcType=DECIMAL}, #{createBy,jdbcType=VARCHAR},
#{createTime,jdbcType=TIMESTAMP}, #{updateBy,jdbcType=VARCHAR}, #{updateTime,jdbcType=TIMESTAMP},
#{deleteTag,jdbcType=INTEGER})
on duplicate key update
id = #{id,jdbcType=VARCHAR},
fund_id = #{fundId,jdbcType=VARCHAR},
distribute_date = #{distributeDate,jdbcType=DATE},
distribute_type = #{distributeType,jdbcType=INTEGER},
distribution = #{distribution,jdbcType=DECIMAL},
create_by = #{createBy,jdbcType=VARCHAR},
create_time = #{createTime,jdbcType=TIMESTAMP},
update_by = #{updateBy,jdbcType=VARCHAR},
update_time = #{updateTime,jdbcType=TIMESTAMP},
delete_tag = #{deleteTag,jdbcType=INTEGER}
</insert>
<insert id="insertOrUpdateSelective" parameterType="com.tanpu.fund.entity.generator.TxFundDistribution">
<!--@mbg.generated-->
insert into tx_fund_distribution
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
id,
</if>
<if test="fundId != null">
fund_id,
</if>
<if test="distributeDate != null">
distribute_date,
</if>
<if test="distributeType != null">
distribute_type,
</if>
<if test="distribution != null">
distribution,
</if>
<if test="createBy != null">
create_by,
</if>
<if test="createTime != null">
create_time,
</if>
<if test="updateBy != null">
update_by,
</if>
<if test="updateTime != null">
update_time,
</if>
<if test="deleteTag != null">
delete_tag,
</if>
</trim>
values
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
#{id,jdbcType=VARCHAR},
</if>
<if test="fundId != null">
#{fundId,jdbcType=VARCHAR},
</if>
<if test="distributeDate != null">
#{distributeDate,jdbcType=DATE},
</if>
<if test="distributeType != null">
#{distributeType,jdbcType=INTEGER},
</if>
<if test="distribution != null">
#{distribution,jdbcType=DECIMAL},
</if>
<if test="createBy != null">
#{createBy,jdbcType=VARCHAR},
</if>
<if test="createTime != null">
#{createTime,jdbcType=TIMESTAMP},
</if>
<if test="updateBy != null">
#{updateBy,jdbcType=VARCHAR},
</if>
<if test="updateTime != null">
#{updateTime,jdbcType=TIMESTAMP},
</if>
<if test="deleteTag != null">
#{deleteTag,jdbcType=INTEGER},
</if>
</trim>
on duplicate key update
<trim suffixOverrides=",">
<if test="id != null">
id = #{id,jdbcType=VARCHAR},
</if>
<if test="fundId != null">
fund_id = #{fundId,jdbcType=VARCHAR},
</if>
<if test="distributeDate != null">
distribute_date = #{distributeDate,jdbcType=DATE},
</if>
<if test="distributeType != null">
distribute_type = #{distributeType,jdbcType=INTEGER},
</if>
<if test="distribution != null">
distribution = #{distribution,jdbcType=DECIMAL},
</if>
<if test="createBy != null">
create_by = #{createBy,jdbcType=VARCHAR},
</if>
<if test="createTime != null">
create_time = #{createTime,jdbcType=TIMESTAMP},
</if>
<if test="updateBy != null">
update_by = #{updateBy,jdbcType=VARCHAR},
</if>
<if test="updateTime != null">
update_time = #{updateTime,jdbcType=TIMESTAMP},
</if>
<if test="deleteTag != null">
delete_tag = #{deleteTag,jdbcType=INTEGER},
</if>
</trim>
</insert>
distribute_type, create_by, create_time, update_by, org_id, org
</sql>
</mapper>
\ 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