实体类

src/main/java/com/quantgroup/asset/distribution/service/jpa/entity/ChannelRuleEntity.java

+package com.quantgroup.asset.distribution.service.jpa.entity;
+
+import javax.persistence.*;
+import java.sql.Timestamp;
+import java.util.Objects;
+
+/**
+ * @author shihuajun
+ * @date 2021/8/26 17:57
+ * @ describing
+ */
+@Entity
+@Table(name = "channel_rule", schema = "asset-distribution")
+public class ChannelRuleEntity {
+    private long id;
+    private long fundProductId;
+    private long channelId;
+    private Byte publishStatus;
+    private long fundId;
+    private long fundCorpId;
+    private String fundName;
+    private String fundType;
+    private String orgType;
+    private String businessType;
+    private int creditResult;
+    private String userTag;
+    private String userLevel;
+    private int priority;
+    private Byte enable;
+    private Timestamp createdAt;
+    private Timestamp updatedAt;
+
+    @Id
+    @Column(name = "id", nullable = false)
+    public long getId() {
+        return id;
+    }
+
+    public void setId(long id) {
+        this.id = id;
+    }
+
+    @Basic
+    @Column(name = "fund_product_id", nullable = false)
+    public long getFundProductId() {
+        return fundProductId;
+    }
+
+    public void setFundProductId(long fundProductId) {
+        this.fundProductId = fundProductId;
+    }
+
+    @Basic
+    @Column(name = "channel_id", nullable = false)
+    public long getChannelId() {
+        return channelId;
+    }
+
+    public void setChannelId(long channelId) {
+        this.channelId = channelId;
+    }
+
+    @Basic
+    @Column(name = "publish_status", nullable = true)
+    public Byte getPublishStatus() {
+        return publishStatus;
+    }
+
+    public void setPublishStatus(Byte publishStatus) {
+        this.publishStatus = publishStatus;
+    }
+
+    @Basic
+    @Column(name = "fund_id", nullable = false)
+    public long getFundId() {
+        return fundId;
+    }
+
+    public void setFundId(long fundId) {
+        this.fundId = fundId;
+    }
+
+    @Basic
+    @Column(name = "fund_corp_id", nullable = false)
+    public long getFundCorpId() {
+        return fundCorpId;
+    }
+
+    public void setFundCorpId(long fundCorpId) {
+        this.fundCorpId = fundCorpId;
+    }
+
+    @Basic
+    @Column(name = "fund_name", nullable = false, length = 100)
+    public String getFundName() {
+        return fundName;
+    }
+
+    public void setFundName(String fundName) {
+        this.fundName = fundName;
+    }
+
+    @Basic
+    @Column(name = "fund_type", nullable = false, length = 20)
+    public String getFundType() {
+        return fundType;
+    }
+
+    public void setFundType(String fundType) {
+        this.fundType = fundType;
+    }
+
+    @Basic
+    @Column(name = "org_type", nullable = false, length = 20)
+    public String getOrgType() {
+        return orgType;
+    }
+
+    public void setOrgType(String orgType) {
+        this.orgType = orgType;
+    }
+
+    @Basic
+    @Column(name = "business_type", nullable = false, length = 20)
+    public String getBusinessType() {
+        return businessType;
+    }
+
+    public void setBusinessType(String businessType) {
+        this.businessType = businessType;
+    }
+
+    @Basic
+    @Column(name = "credit_result", nullable = false)
+    public int getCreditResult() {
+        return creditResult;
+    }
+
+    public void setCreditResult(int creditResult) {
+        this.creditResult = creditResult;
+    }
+
+    @Basic
+    @Column(name = "user_tag", nullable = false, length = 500)
+    public String getUserTag() {
+        return userTag;
+    }
+
+    public void setUserTag(String userTag) {
+        this.userTag = userTag;
+    }
+
+    @Basic
+    @Column(name = "user_level", nullable = false, length = 500)
+    public String getUserLevel() {
+        return userLevel;
+    }
+
+    public void setUserLevel(String userLevel) {
+        this.userLevel = userLevel;
+    }
+
+    @Basic
+    @Column(name = "priority", nullable = false)
+    public int getPriority() {
+        return priority;
+    }
+
+    public void setPriority(int priority) {
+        this.priority = priority;
+    }
+
+    @Basic
+    @Column(name = "enable", nullable = true)
+    public Byte getEnable() {
+        return enable;
+    }
+
+    public void setEnable(Byte enable) {
+        this.enable = enable;
+    }
+
+    @Basic
+    @Column(name = "created_at", nullable = false)
+    public Timestamp getCreatedAt() {
+        return createdAt;
+    }
+
+    public void setCreatedAt(Timestamp createdAt) {
+        this.createdAt = createdAt;
+    }
+
+    @Basic
+    @Column(name = "updated_at", nullable = false)
+    public Timestamp getUpdatedAt() {
+        return updatedAt;
+    }
+
+    public void setUpdatedAt(Timestamp updatedAt) {
+        this.updatedAt = updatedAt;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) {
+            return true;
+        }
+        if (o == null || getClass() != o.getClass()) {
+            return false;
+        }
+        ChannelRuleEntity that = (ChannelRuleEntity) o;
+        return id == that.id && fundProductId == that.fundProductId && channelId == that.channelId && fundId == that.fundId && fundCorpId == that.fundCorpId && creditResult == that.creditResult && priority == that.priority && Objects.equals(publishStatus, that.publishStatus) && Objects.equals(fundName, that.fundName) && Objects.equals(fundType, that.fundType) && Objects.equals(orgType, that.orgType) && Objects.equals(businessType, that.businessType) && Objects.equals(userTag, that.userTag) && Objects.equals(userLevel, that.userLevel) && Objects.equals(enable, that.enable) && Objects.equals(createdAt, that.createdAt) && Objects.equals(updatedAt, that.updatedAt);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(id, fundProductId, channelId, publishStatus, fundId, fundCorpId, fundName, fundType, orgType, businessType, creditResult, userTag, userLevel, priority, enable, createdAt, updatedAt);
+    }
+}

src/main/java/com/quantgroup/asset/distribution/service/jpa/entity/FundProductEntity.java

+package com.quantgroup.asset.distribution.service.jpa.entity;
+
+import javax.persistence.*;
+import java.sql.Timestamp;
+import java.util.Objects;
+
+/**
+ * @author shihuajun
+ * @date 2021/8/26 17:57
+ * @ describing
+ */
+@Entity
+@Table(name = "fund_product", schema = "asset-distribution")
+public class FundProductEntity {
+    private long id;
+    private long fundId;
+    private long fundCorpId;
+    private String fundName;
+    private String fundType;
+    private String orgType;
+    private String businessType;
+    private String systermType;
+    private String basicRule;
+    private String otherRule;
+    private String ruleList;
+    private Byte enable;
+    private Timestamp createdAt;
+    private Timestamp updatedAt;
+
+    @Id
+    @Column(name = "id", nullable = false)
+    public long getId() {
+        return id;
+    }
+
+    public void setId(long id) {
+        this.id = id;
+    }
+
+    @Basic
+    @Column(name = "fund_id", nullable = false)
+    public long getFundId() {
+        return fundId;
+    }
+
+    public void setFundId(long fundId) {
+        this.fundId = fundId;
+    }
+
+    @Basic
+    @Column(name = "fund_corp_id", nullable = false)
+    public long getFundCorpId() {
+        return fundCorpId;
+    }
+
+    public void setFundCorpId(long fundCorpId) {
+        this.fundCorpId = fundCorpId;
+    }
+
+    @Basic
+    @Column(name = "fund_name", nullable = false, length = 100)
+    public String getFundName() {
+        return fundName;
+    }
+
+    public void setFundName(String fundName) {
+        this.fundName = fundName;
+    }
+
+    @Basic
+    @Column(name = "fund_type", nullable = false, length = 20)
+    public String getFundType() {
+        return fundType;
+    }
+
+    public void setFundType(String fundType) {
+        this.fundType = fundType;
+    }
+
+    @Basic
+    @Column(name = "org_type", nullable = false, length = 20)
+    public String getOrgType() {
+        return orgType;
+    }
+
+    public void setOrgType(String orgType) {
+        this.orgType = orgType;
+    }
+
+    @Basic
+    @Column(name = "business_type", nullable = false, length = 20)
+    public String getBusinessType() {
+        return businessType;
+    }
+
+    public void setBusinessType(String businessType) {
+        this.businessType = businessType;
+    }
+
+    @Basic
+    @Column(name = "systerm_type", nullable = false, length = 20)
+    public String getSystermType() {
+        return systermType;
+    }
+
+    public void setSystermType(String systermType) {
+        this.systermType = systermType;
+    }
+
+    @Basic
+    @Column(name = "basic_rule", nullable = false, length = 500)
+    public String getBasicRule() {
+        return basicRule;
+    }
+
+    public void setBasicRule(String basicRule) {
+        this.basicRule = basicRule;
+    }
+
+    @Basic
+    @Column(name = "other_rule", nullable = false, length = 500)
+    public String getOtherRule() {
+        return otherRule;
+    }
+
+    public void setOtherRule(String otherRule) {
+        this.otherRule = otherRule;
+    }
+
+    @Basic
+    @Column(name = "rule_list", nullable = false, length = 500)
+    public String getRuleList() {
+        return ruleList;
+    }
+
+    public void setRuleList(String ruleList) {
+        this.ruleList = ruleList;
+    }
+
+    @Basic
+    @Column(name = "enable", nullable = true)
+    public Byte getEnable() {
+        return enable;
+    }
+
+    public void setEnable(Byte enable) {
+        this.enable = enable;
+    }
+
+    @Basic
+    @Column(name = "created_at", nullable = false)
+    public Timestamp getCreatedAt() {
+        return createdAt;
+    }
+
+    public void setCreatedAt(Timestamp createdAt) {
+        this.createdAt = createdAt;
+    }
+
+    @Basic
+    @Column(name = "updated_at", nullable = false)
+    public Timestamp getUpdatedAt() {
+        return updatedAt;
+    }
+
+    public void setUpdatedAt(Timestamp updatedAt) {
+        this.updatedAt = updatedAt;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        FundProductEntity that = (FundProductEntity) o;
+        return id == that.id && fundId == that.fundId && fundCorpId == that.fundCorpId && Objects.equals(fundName, that.fundName) && Objects.equals(fundType, that.fundType) && Objects.equals(orgType, that.orgType) && Objects.equals(businessType, that.businessType) && Objects.equals(systermType, that.systermType) && Objects.equals(basicRule, that.basicRule) && Objects.equals(otherRule, that.otherRule) && Objects.equals(ruleList, that.ruleList) && Objects.equals(enable, that.enable) && Objects.equals(createdAt, that.createdAt) && Objects.equals(updatedAt, that.updatedAt);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(id, fundId, fundCorpId, fundName, fundType, orgType, businessType, systermType, basicRule, otherRule, ruleList, enable, createdAt, updatedAt);
+    }
+}

src/main/java/com/quantgroup/asset/distribution/service/jpa/entity/ProductRuleEntity.java

+package com.quantgroup.asset.distribution.service.jpa.entity;
+
+import javax.persistence.*;
+import java.sql.Timestamp;
+import java.util.Objects;
+
+/**
+ * @author shihuajun
+ * @date 2021/8/26 17:57
+ * @ describing
+ */
+@Entity
+@Table(name = "product_rule", schema = "asset-distribution")
+public class ProductRuleEntity {
+    private long id;
+    private String ruleName;
+    private String ruleEnglish;
+    private String ruleChinese;
+    private Byte enable;
+    private Timestamp createdAt;
+    private Timestamp updatedAt;
+
+    @Id
+    @Column(name = "id", nullable = false)
+    public long getId() {
+        return id;
+    }
+
+    public void setId(long id) {
+        this.id = id;
+    }
+
+    @Basic
+    @Column(name = "rule_name", nullable = false, length = 50)
+    public String getRuleName() {
+        return ruleName;
+    }
+
+    public void setRuleName(String ruleName) {
+        this.ruleName = ruleName;
+    }
+
+    @Basic
+    @Column(name = "rule_english", nullable = false, length = 50)
+    public String getRuleEnglish() {
+        return ruleEnglish;
+    }
+
+    public void setRuleEnglish(String ruleEnglish) {
+        this.ruleEnglish = ruleEnglish;
+    }
+
+    @Basic
+    @Column(name = "rule_chinese", nullable = false, length = 50)
+    public String getRuleChinese() {
+        return ruleChinese;
+    }
+
+    public void setRuleChinese(String ruleChinese) {
+        this.ruleChinese = ruleChinese;
+    }
+
+    @Basic
+    @Column(name = "enable", nullable = true)
+    public Byte getEnable() {
+        return enable;
+    }
+
+    public void setEnable(Byte enable) {
+        this.enable = enable;
+    }
+
+    @Basic
+    @Column(name = "created_at", nullable = false)
+    public Timestamp getCreatedAt() {
+        return createdAt;
+    }
+
+    public void setCreatedAt(Timestamp createdAt) {
+        this.createdAt = createdAt;
+    }
+
+    @Basic
+    @Column(name = "updated_at", nullable = false)
+    public Timestamp getUpdatedAt() {
+        return updatedAt;
+    }
+
+    public void setUpdatedAt(Timestamp updatedAt) {
+        this.updatedAt = updatedAt;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        ProductRuleEntity that = (ProductRuleEntity) o;
+        return id == that.id && Objects.equals(ruleName, that.ruleName) && Objects.equals(ruleEnglish, that.ruleEnglish) && Objects.equals(ruleChinese, that.ruleChinese) && Objects.equals(enable, that.enable) && Objects.equals(createdAt, that.createdAt) && Objects.equals(updatedAt, that.updatedAt);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(id, ruleName, ruleEnglish, ruleChinese, enable, createdAt, updatedAt);
+    }
+}

src/main/java/com/quantgroup/asset/distribution/service/jpa/entity/RoutingRecordEntity.java

+package com.quantgroup.asset.distribution.service.jpa.entity;
+
+import javax.persistence.*;
+import java.sql.Timestamp;
+import java.util.Objects;
+
+/**
+ * @author shihuajun
+ * @date 2021/8/26 17:57
+ * @ describing
+ */
+@Entity
+@Table(name = "routing_record", schema = "asset-distribution")
+public class RoutingRecordEntity {
+    private long id;
+    private String phone;
+    private String uuid;
+    private String creditNo;
+    private Byte status;
+    private String routedResult;
+    private Timestamp routedAt;
+    private Timestamp createdAt;
+    private Timestamp updatedAt;
+
+    @Id
+    @Column(name = "id", nullable = false)
+    public long getId() {
+        return id;
+    }
+
+    public void setId(long id) {
+        this.id = id;
+    }
+
+    @Basic
+    @Column(name = "phone", nullable = false, length = 20)
+    public String getPhone() {
+        return phone;
+    }
+
+    public void setPhone(String phone) {
+        this.phone = phone;
+    }
+
+    @Basic
+    @Column(name = "uuid", nullable = false, length = 50)
+    public String getUuid() {
+        return uuid;
+    }
+
+    public void setUuid(String uuid) {
+        this.uuid = uuid;
+    }
+
+    @Basic
+    @Column(name = "credit_no", nullable = false, length = 50)
+    public String getCreditNo() {
+        return creditNo;
+    }
+
+    public void setCreditNo(String creditNo) {
+        this.creditNo = creditNo;
+    }
+
+    @Basic
+    @Column(name = "status", nullable = true)
+    public Byte getStatus() {
+        return status;
+    }
+
+    public void setStatus(Byte status) {
+        this.status = status;
+    }
+
+    @Basic
+    @Column(name = "routed_result", nullable = false, length = 2000)
+    public String getRoutedResult() {
+        return routedResult;
+    }
+
+    public void setRoutedResult(String routedResult) {
+        this.routedResult = routedResult;
+    }
+
+    @Basic
+    @Column(name = "routed_at", nullable = false)
+    public Timestamp getRoutedAt() {
+        return routedAt;
+    }
+
+    public void setRoutedAt(Timestamp routedAt) {
+        this.routedAt = routedAt;
+    }
+
+    @Basic
+    @Column(name = "created_at", nullable = false)
+    public Timestamp getCreatedAt() {
+        return createdAt;
+    }
+
+    public void setCreatedAt(Timestamp createdAt) {
+        this.createdAt = createdAt;
+    }
+
+    @Basic
+    @Column(name = "updated_at", nullable = false)
+    public Timestamp getUpdatedAt() {
+        return updatedAt;
+    }
+
+    public void setUpdatedAt(Timestamp updatedAt) {
+        this.updatedAt = updatedAt;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        RoutingRecordEntity that = (RoutingRecordEntity) o;
+        return id == that.id && Objects.equals(phone, that.phone) && Objects.equals(uuid, that.uuid) && Objects.equals(creditNo, that.creditNo) && Objects.equals(status, that.status) && Objects.equals(routedResult, that.routedResult) && Objects.equals(routedAt, that.routedAt) && Objects.equals(createdAt, that.createdAt) && Objects.equals(updatedAt, that.updatedAt);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(id, phone, uuid, creditNo, status, routedResult, routedAt, createdAt, updatedAt);
+    }
+}

src/main/java/com/quantgroup/asset/distribution/service/jpa/entity/WhiteListEntity.java

+package com.quantgroup.asset.distribution.service.jpa.entity;
+
+import javax.persistence.*;
+import java.sql.Timestamp;
+import java.util.Objects;
+
+/**
+ * @author shihuajun
+ * @date 2021/8/26 17:57
+ * @ describing
+ */
+@Entity
+@Table(name = "white_list", schema = "asset-distribution")
+public class WhiteListEntity {
+    private long id;
+    private long fundProductId;
+    private String phone;
+    private long fundId;
+    private long fundCorpId;
+    private String fundName;
+    private String fundType;
+    private String orgType;
+    private String businessType;
+    private Byte status;
+    private Timestamp createdAt;
+    private Timestamp updatedAt;
+
+    @Id
+    @Column(name = "id", nullable = false)
+    public long getId() {
+        return id;
+    }
+
+    public void setId(long id) {
+        this.id = id;
+    }
+
+    @Basic
+    @Column(name = "fund_product_id", nullable = false)
+    public long getFundProductId() {
+        return fundProductId;
+    }
+
+    public void setFundProductId(long fundProductId) {
+        this.fundProductId = fundProductId;
+    }
+
+    @Basic
+    @Column(name = "phone", nullable = true, length = 20)
+    public String getPhone() {
+        return phone;
+    }
+
+    public void setPhone(String phone) {
+        this.phone = phone;
+    }
+
+    @Basic
+    @Column(name = "fund_id", nullable = false)
+    public long getFundId() {
+        return fundId;
+    }
+
+    public void setFundId(long fundId) {
+        this.fundId = fundId;
+    }
+
+    @Basic
+    @Column(name = "fund_corp_id", nullable = false)
+    public long getFundCorpId() {
+        return fundCorpId;
+    }
+
+    public void setFundCorpId(long fundCorpId) {
+        this.fundCorpId = fundCorpId;
+    }
+
+    @Basic
+    @Column(name = "fund_name", nullable = false, length = 100)
+    public String getFundName() {
+        return fundName;
+    }
+
+    public void setFundName(String fundName) {
+        this.fundName = fundName;
+    }
+
+    @Basic
+    @Column(name = "fund_type", nullable = false, length = 20)
+    public String getFundType() {
+        return fundType;
+    }
+
+    public void setFundType(String fundType) {
+        this.fundType = fundType;
+    }
+
+    @Basic
+    @Column(name = "org_type", nullable = false, length = 20)
+    public String getOrgType() {
+        return orgType;
+    }
+
+    public void setOrgType(String orgType) {
+        this.orgType = orgType;
+    }
+
+    @Basic
+    @Column(name = "business_type", nullable = false, length = 20)
+    public String getBusinessType() {
+        return businessType;
+    }
+
+    public void setBusinessType(String businessType) {
+        this.businessType = businessType;
+    }
+
+    @Basic
+    @Column(name = "status", nullable = true)
+    public Byte getStatus() {
+        return status;
+    }
+
+    public void setStatus(Byte status) {
+        this.status = status;
+    }
+
+    @Basic
+    @Column(name = "created_at", nullable = false)
+    public Timestamp getCreatedAt() {
+        return createdAt;
+    }
+
+    public void setCreatedAt(Timestamp createdAt) {
+        this.createdAt = createdAt;
+    }
+
+    @Basic
+    @Column(name = "updated_at", nullable = false)
+    public Timestamp getUpdatedAt() {
+        return updatedAt;
+    }
+
+    public void setUpdatedAt(Timestamp updatedAt) {
+        this.updatedAt = updatedAt;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        WhiteListEntity that = (WhiteListEntity) o;
+        return id == that.id && fundProductId == that.fundProductId && fundId == that.fundId && fundCorpId == that.fundCorpId && Objects.equals(phone, that.phone) && Objects.equals(fundName, that.fundName) && Objects.equals(fundType, that.fundType) && Objects.equals(orgType, that.orgType) && Objects.equals(businessType, that.businessType) && Objects.equals(status, that.status) && Objects.equals(createdAt, that.createdAt) && Objects.equals(updatedAt, that.updatedAt);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(id, fundProductId, phone, fundId, fundCorpId, fundName, fundType, orgType, businessType, status, createdAt, updatedAt);
+    }
+}

src/main/java/com/quantgroup/asset/distribution/service/jpa/repository/IChannelRuleRepository.java

+package com.quantgroup.asset.distribution.service.jpa.repository;
+
+import com.quantgroup.asset.distribution.service.jpa.entity.ChannelRuleEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+
+public interface IChannelRuleRepository extends JpaRepository<ChannelRuleEntity, Long>{
+
+}

src/main/java/com/quantgroup/asset/distribution/service/jpa/repository/IFundProductRepository.java

+package com.quantgroup.asset.distribution.service.jpa.repository;
+
+import com.quantgroup.asset.distribution.service.jpa.entity.FundProductEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+
+public interface IFundProductRepository extends JpaRepository<FundProductEntity, Long>{
+
+}

src/main/java/com/quantgroup/asset/distribution/service/jpa/repository/IProductRuleRepository.java

+package com.quantgroup.asset.distribution.service.jpa.repository;
+
+import com.quantgroup.asset.distribution.service.jpa.entity.ProductRuleEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+
+public interface IProductRuleRepository extends JpaRepository<ProductRuleEntity, Long>{
+
+}

src/main/java/com/quantgroup/asset/distribution/service/jpa/repository/IRoutingRecordRepository.java

+package com.quantgroup.asset.distribution.service.jpa.repository;
+
+import com.quantgroup.asset.distribution.service.jpa.entity.RoutingRecordEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+
+public interface IRoutingRecordRepository extends JpaRepository<RoutingRecordEntity, Long>{
+
+}

src/main/java/com/quantgroup/asset/distribution/service/jpa/repository/IWhiteListRepository.java

+package com.quantgroup.asset.distribution.service.jpa.repository;
+
+import com.quantgroup.asset.distribution.service.jpa.entity.WhiteListEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+
+public interface IWhiteListRepository extends JpaRepository<WhiteListEntity, Long>{
+
+}