Просмотр исходного кода

Merge remote-tracking branch 'origin/master'

master
qiubh 4 дней назад
Родитель
Сommit
ac5d4d64e4
24 измененных файлов: 553 добавлений и 290 удалений
  1. 3
    0
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQryCardBatchRequest.java
  2. 5
    44
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQryCardBatchResponse.java
  3. 4
    0
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQryCardsRequest.java
  4. 5
    48
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQryCardsResponse.java
  5. 4
    0
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQrySmObuBatchRequest.java
  6. 5
    36
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQrySmObuBatchResponse.java
  7. 4
    0
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQueryGmobusRequest.java
  8. 5
    44
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQueryGmobusResponse.java
  9. 4
    0
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQueryScobusRequest.java
  10. 5
    56
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQueryScobusResponse.java
  11. 4
    0
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQueryTriDesObusRequest.java
  12. 5
    44
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQueryTriDesObusResponse.java
  13. 55
    0
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/model/VfjQryCardBatchModel.java
  14. 59
    0
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/model/VfjQryCardsModel.java
  15. 47
    0
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/model/VfjQrySmObuBatchModel.java
  16. 55
    0
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/model/VfjQueryGmobusModel.java
  17. 67
    0
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/model/VfjQueryScobusModel.java
  18. 55
    0
      gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/model/VfjQueryTriDesObusModel.java
  19. 27
    3
      zhywpt-dps-iasq/src/main/java/cn/com/taiji/iasq/manager/quartz/vfj/VfjQryCardBatchManagerImpl.java
  20. 27
    3
      zhywpt-dps-iasq/src/main/java/cn/com/taiji/iasq/manager/quartz/vfj/VfjQryCardsManagerImpl.java
  21. 27
    3
      zhywpt-dps-iasq/src/main/java/cn/com/taiji/iasq/manager/quartz/vfj/VfjQrySmObuBatchManagerImpl.java
  22. 27
    3
      zhywpt-dps-iasq/src/main/java/cn/com/taiji/iasq/manager/quartz/vfj/VfjQueryGmobusManagerImpl.java
  23. 27
    3
      zhywpt-dps-iasq/src/main/java/cn/com/taiji/iasq/manager/quartz/vfj/VfjQueryScobusManagerImpl.java
  24. 27
    3
      zhywpt-dps-iasq/src/main/java/cn/com/taiji/iasq/manager/quartz/vfj/VfjQueryTriDesObusManagerImpl.java

+ 3
- 0
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQryCardBatchRequest.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss; package cn.com.taiji.core.model.comm.protocol.inss;


import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest; import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;


@Getter @Getter
@Setter @Setter
@JsonInclude(JsonInclude.Include.NON_NULL)
public class VfjQryCardBatchRequest extends AbstractSignTypeRequest<VfjQryCardBatchResponse> { public class VfjQryCardBatchRequest extends AbstractSignTypeRequest<VfjQryCardBatchResponse> {
public VfjQryCardBatchRequest() { public VfjQryCardBatchRequest() {
super(InssServiceCmd.QRYCARDBATCH); super(InssServiceCmd.QRYCARDBATCH);
/** 卡片厂商代码 */ /** 卡片厂商代码 */
@JsonProperty(value = "ProviderID") @JsonProperty(value = "ProviderID")
private String providerID; private String providerID;

} }

+ 5
- 44
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQryCardBatchResponse.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss; package cn.com.taiji.core.model.comm.protocol.inss;


import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse; import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse;
import cn.com.taiji.core.model.comm.protocol.inss.model.VfjQryCardBatchModel;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;


import java.util.List;

@Getter @Getter
@Setter @Setter
public class VfjQryCardBatchResponse extends AbstractSignTypeResponse { public class VfjQryCardBatchResponse extends AbstractSignTypeResponse {

/** 单号数据的结果集 */ /** 单号数据的结果集 */
@JsonProperty(value = "Datas") @JsonProperty(value = "Datas")
private String datas;

/** 批次号 */
@JsonProperty(value = "BatchNo")
private String batchNo;

/** 批次申请日期 */
@JsonProperty(value = "BatchDate")
private String batchDate;

/** 卡片类型 */
@JsonProperty(value = "CardType")
private String cardType;

/** 卡片起始号 */
@JsonProperty(value = "StartNum")
private String startNum;

/** 卡片结束号 */
@JsonProperty(value = "EndNum")
private String endNum;

/** 批次总张数 */
@JsonProperty(value = "TotalCount")
private String totalCount;

/** 申请状态 */
@JsonProperty(value = "Status")
private String status;

/** 卡片版本号 */
@JsonProperty(value = "CardVersion")
private Integer cardVersion;

/** 设备类型 */
@JsonProperty(value = "SeType")
private String seType;

/** 发行方代码 */
@JsonProperty(value = "OrgId")
private String orgId;
private List<VfjQryCardBatchModel> datas;


/** 渠道 */
@JsonProperty(value = "Chanel")
private String chanel;
} }

+ 4
- 0
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQryCardsRequest.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss; package cn.com.taiji.core.model.comm.protocol.inss;


import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest; import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;


@Getter @Getter
@Setter @Setter
@JsonInclude(JsonInclude.Include.NON_NULL)
public class VfjQryCardsRequest extends AbstractSignTypeRequest<VfjQryCardsResponse> { public class VfjQryCardsRequest extends AbstractSignTypeRequest<VfjQryCardsResponse> {
public VfjQryCardsRequest() { public VfjQryCardsRequest() {
super(InssServiceCmd.QRYCARDS); super(InssServiceCmd.QRYCARDS);
} }

/** 批次号 */ /** 批次号 */
@JsonProperty(value = "BatchNo") @JsonProperty(value = "BatchNo")
private String batchNo; private String batchNo;
/** 最后修改日期 */ /** 最后修改日期 */
@JsonProperty(value = "LastUpdateTime") @JsonProperty(value = "LastUpdateTime")
private String lastUpdateTime; private String lastUpdateTime;

} }

+ 5
- 48
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQryCardsResponse.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss; package cn.com.taiji.core.model.comm.protocol.inss;


import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse; import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse;
import cn.com.taiji.core.model.comm.protocol.inss.model.VfjQryCardsModel;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;


import java.util.List;

@Getter @Getter
@Setter @Setter
public class VfjQryCardsResponse extends AbstractSignTypeResponse { public class VfjQryCardsResponse extends AbstractSignTypeResponse {

/** 单号数据的结果集 */ /** 单号数据的结果集 */
@JsonProperty(value = "Datas") @JsonProperty(value = "Datas")
private String datas;

/** 批次号 */
@JsonProperty(value = "BatchNo")
private String batchNo;

/** 卡号 */
@JsonProperty(value = "CardNo")
private String cardNo;

/** 卡片厂商 */
@JsonProperty(value = "Provider")
private String provider;

/** 卡片类型 */
@JsonProperty(value = "CardType")
private String cardType;

/** 发行状态 */
@JsonProperty(value = "Status")
private Integer status;

/** 格式化日期 */
@JsonProperty(value = "FormatTime")
private String formatTime;

/** 最后修改日期 */
@JsonProperty(value = "LastUpdateTime")
private String lastUpdateTime;

/** 卡片SNR */
@JsonProperty(value = "CardSnr")
private String cardSnr;

/** 发行次数 */
@JsonProperty(value = "IssueCount")
private Integer issueCount;

/** 渠道 */
@JsonProperty(value = "Chanel")
private String chanel;

/** 渠道ID */
@JsonProperty(value = "ChanelId")
private String chanelId;
private List<VfjQryCardsModel> datas;


/** 卡片厂商代码 */
@JsonProperty(value = "ProviderID")
private String providerID;
} }

+ 4
- 0
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQrySmObuBatchRequest.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss; package cn.com.taiji.core.model.comm.protocol.inss;


import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest; import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;


@Getter @Getter
@Setter @Setter
@JsonInclude(JsonInclude.Include.NON_NULL)
public class VfjQrySmObuBatchRequest extends AbstractSignTypeRequest<VfjQrySmObuBatchResponse> { public class VfjQrySmObuBatchRequest extends AbstractSignTypeRequest<VfjQrySmObuBatchResponse> {
public VfjQrySmObuBatchRequest() { public VfjQrySmObuBatchRequest() {
super(InssServiceCmd.QRYSMOBUBATCH); super(InssServiceCmd.QRYSMOBUBATCH);
} }

/** 批次号 */ /** 批次号 */
@JsonProperty(value = "BatchNo") @JsonProperty(value = "BatchNo")
private String batchNo; private String batchNo;
/** 卡片厂商代码 */ /** 卡片厂商代码 */
@JsonProperty(value = "ProviderID") @JsonProperty(value = "ProviderID")
private String providerID; private String providerID;

} }

+ 5
- 36
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQrySmObuBatchResponse.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss; package cn.com.taiji.core.model.comm.protocol.inss;


import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse; import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse;
import cn.com.taiji.core.model.comm.protocol.inss.model.VfjQrySmObuBatchModel;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;


import java.util.List;

@Getter @Getter
@Setter @Setter
public class VfjQrySmObuBatchResponse extends AbstractSignTypeResponse { public class VfjQrySmObuBatchResponse extends AbstractSignTypeResponse {

/** 单号数据的结果集 */ /** 单号数据的结果集 */
@JsonProperty(value = "Datas") @JsonProperty(value = "Datas")
private String datas;

/** 批次号 */
@JsonProperty(value = "BatchNo")
private String batchNo;

/** 批次申请日期 */
@JsonProperty(value = "ApplyDate")
private String applyDate;

/** 卡片类型 */
@JsonProperty(value = "ObuType")
private String obuType;

/** OBU起始号 */
@JsonProperty(value = "StartNum")
private String startNum;

/** OBU结束号 */
@JsonProperty(value = "EndNum")
private String endNum;

/** 卡片起始号 */
@JsonProperty(value = "StartCardNum")
private String startCardNum;

/** 卡片结束号 */
@JsonProperty(value = "EndCardNum")
private String endCardNum;

/** 批次总张数 */
@JsonProperty(value = "TotalCount")
private String totalCount;
private List<VfjQrySmObuBatchModel> datas;


/** 渠道名称 */
@JsonProperty(value = "Chanel")
private String chanel;
} }

+ 4
- 0
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQueryGmobusRequest.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss; package cn.com.taiji.core.model.comm.protocol.inss;


import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest; import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;


@Getter @Getter
@Setter @Setter
@JsonInclude(JsonInclude.Include.NON_NULL)
public class VfjQueryGmobusRequest extends AbstractSignTypeRequest<VfjQueryGmobusResponse> { public class VfjQueryGmobusRequest extends AbstractSignTypeRequest<VfjQueryGmobusResponse> {
public VfjQueryGmobusRequest() { public VfjQueryGmobusRequest() {
super(InssServiceCmd.QUERYGMOBUS); super(InssServiceCmd.QUERYGMOBUS);
} }

/** 批次号 */ /** 批次号 */
@JsonProperty(value = "BatchNo") @JsonProperty(value = "BatchNo")
private String batchNo; private String batchNo;
/** 最后修改日期 */ /** 最后修改日期 */
@JsonProperty(value = "LastUpdateTime") @JsonProperty(value = "LastUpdateTime")
private String lastUpdateTime; private String lastUpdateTime;

} }

+ 5
- 44
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQueryGmobusResponse.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss; package cn.com.taiji.core.model.comm.protocol.inss;


import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse; import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse;
import cn.com.taiji.core.model.comm.protocol.inss.model.VfjQueryGmobusModel;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;


import java.util.List;

@Getter @Getter
@Setter @Setter
public class VfjQueryGmobusResponse extends AbstractSignTypeResponse { public class VfjQueryGmobusResponse extends AbstractSignTypeResponse {

/** 单号数据的结果集 */ /** 单号数据的结果集 */
@JsonProperty(value = "Datas") @JsonProperty(value = "Datas")
private String datas;

/** 批次号 */
@JsonProperty(value = "BatchNo")
private String batchNo;

/** 合同序列号号 */
@JsonProperty(value = "SerialNo")
private String serialNo;

/** 卡片厂商 */
@JsonProperty(value = "Provider")
private String provider;

/** 卡片厂商代码 */
@JsonProperty(value = "ProviderID")
private String providerID;

/** 激活日期 */
@JsonProperty(value = "ActiveDate")
private String activeDate;

/** 发行状态 */
@JsonProperty(value = "Status")
private Integer status;

/** 格式化日期 */
@JsonProperty(value = "FormatTime")
private String formatTime;

/** 最后修改日期 */
@JsonProperty(value = "LastUpdateTime")
private String lastUpdateTime;

/** OBU 物理号 */
@JsonProperty(value = "ObuMac")
private String obuMac;

/** 渠道 */
@JsonProperty(value = "Chanel")
private String chanel;
private List<VfjQueryGmobusModel> datas;


/** 渠道ID */
@JsonProperty(value = "ChanelId")
private String chanelId;
} }

+ 4
- 0
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQueryScobusRequest.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss; package cn.com.taiji.core.model.comm.protocol.inss;


import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest; import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;


@Getter @Getter
@Setter @Setter
@JsonInclude(JsonInclude.Include.NON_NULL)
public class VfjQueryScobusRequest extends AbstractSignTypeRequest<VfjQueryScobusResponse> { public class VfjQueryScobusRequest extends AbstractSignTypeRequest<VfjQueryScobusResponse> {
public VfjQueryScobusRequest() { public VfjQueryScobusRequest() {
super(InssServiceCmd.QUERYSCOBUS); super(InssServiceCmd.QUERYSCOBUS);
} }

/** 批次号 */ /** 批次号 */
@JsonProperty(value = "BatchNo") @JsonProperty(value = "BatchNo")
private String batchNo; private String batchNo;
/** 最后修改日期 */ /** 最后修改日期 */
@JsonProperty(value = "LastUpdateTime") @JsonProperty(value = "LastUpdateTime")
private String lastUpdateTime; private String lastUpdateTime;

} }

+ 5
- 56
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQueryScobusResponse.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss; package cn.com.taiji.core.model.comm.protocol.inss;


import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse; import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse;
import cn.com.taiji.core.model.comm.protocol.inss.model.VfjQueryScobusModel;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;


import java.util.List;

@Getter @Getter
@Setter @Setter
public class VfjQueryScobusResponse extends AbstractSignTypeResponse { public class VfjQueryScobusResponse extends AbstractSignTypeResponse {

/** 单号数据的结果集 */ /** 单号数据的结果集 */
@JsonProperty(value = "Datas") @JsonProperty(value = "Datas")
private String datas;

/** 批次号 */
@JsonProperty(value = "BatchNo")
private String batchNo;

/** 合同序列号号 */
@JsonProperty(value = "SerialNo")
private String serialNo;

/** 卡号 */
@JsonProperty(value = "CardNo")
private String cardNo;

/** 卡片类型 */
@JsonProperty(value = "CardType")
private String cardType;

/** 卡片厂商 */
@JsonProperty(value = "Provider")
private String provider;

/** 卡片厂商代码 */
@JsonProperty(value = "ProviderID")
private String providerID;

/** 激活日期 */
@JsonProperty(value = "ActiveDate")
private String activeDate;

/** 发行状态 */
@JsonProperty(value = "Status")
private Integer status;

/** 格式化日期 */
@JsonProperty(value = "FormatTime")
private String formatTime;

/** 最后修改日期 */
@JsonProperty(value = "LastUpdateTime")
private String lastUpdateTime;

/** OBU 物理号 */
@JsonProperty(value = "ObuMac")
private String obuMac;

/** 卡片SNR */
@JsonProperty(value = "CardSnr")
private String cardSnr;

/** 渠道 */
@JsonProperty(value = "Chanel")
private String chanel;
private List<VfjQueryScobusModel> datas;


/** 渠道ID */
@JsonProperty(value = "ChanelId")
private String chanelId;
} }

+ 4
- 0
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQueryTriDesObusRequest.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss; package cn.com.taiji.core.model.comm.protocol.inss;


import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest; import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;


@Getter @Getter
@Setter @Setter
@JsonInclude(JsonInclude.Include.NON_NULL)
public class VfjQueryTriDesObusRequest extends AbstractSignTypeRequest<VfjQueryTriDesObusResponse> { public class VfjQueryTriDesObusRequest extends AbstractSignTypeRequest<VfjQueryTriDesObusResponse> {
public VfjQueryTriDesObusRequest() { public VfjQueryTriDesObusRequest() {
super(InssServiceCmd.QUERYTRIDESOBUS); super(InssServiceCmd.QUERYTRIDESOBUS);
} }

/** 批次号 */ /** 批次号 */
@JsonProperty(value = "BatchNo") @JsonProperty(value = "BatchNo")
private String batchNo; private String batchNo;
/** 最后修改日期 */ /** 最后修改日期 */
@JsonProperty(value = "LastUpdateTime") @JsonProperty(value = "LastUpdateTime")
private String lastUpdateTime; private String lastUpdateTime;

} }

+ 5
- 44
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/VfjQueryTriDesObusResponse.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss; package cn.com.taiji.core.model.comm.protocol.inss;


import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse; import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse;
import cn.com.taiji.core.model.comm.protocol.inss.model.VfjQueryTriDesObusModel;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;


import java.util.List;

@Getter @Getter
@Setter @Setter
public class VfjQueryTriDesObusResponse extends AbstractSignTypeResponse { public class VfjQueryTriDesObusResponse extends AbstractSignTypeResponse {

/** 单号数据的结果集 */ /** 单号数据的结果集 */
@JsonProperty(value = "Datas") @JsonProperty(value = "Datas")
private String datas;

/** 批次号 */
@JsonProperty(value = "BatchNo")
private String batchNo;

/** 合同序列号号 */
@JsonProperty(value = "SerialNo")
private String serialNo;

/** 卡片厂商 */
@JsonProperty(value = "Provider")
private String provider;

/** 卡片厂商代码 */
@JsonProperty(value = "ProviderID")
private String providerID;

/** 激活日期 */
@JsonProperty(value = "ActiveDate")
private String activeDate;

/** 发行状态 */
@JsonProperty(value = "Status")
private Integer status;

/** 格式化日期 */
@JsonProperty(value = "FormatTime")
private String formatTime;

/** 最后修改日期 */
@JsonProperty(value = "LastUpdateTime")
private String lastUpdateTime;

/** OBU 物理号 */
@JsonProperty(value = "ObuMac")
private String obuMac;

/** 渠道 */
@JsonProperty(value = "Chanel")
private String chanel;
private List<VfjQueryTriDesObusModel> datas;


/** 渠道ID */
@JsonProperty(value = "ChanelId")
private String chanelId;
} }

+ 55
- 0
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/model/VfjQryCardBatchModel.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss.model;

import cn.com.taiji.common.model.BaseModel;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter;
import lombok.Setter;

@Getter
@Setter
public class VfjQryCardBatchModel extends BaseModel {

/** 批次号 */
@JsonProperty(value = "BatchNo")
private String batchNo;

/** 批次申请日期 */
@JsonProperty(value = "BatchDate")
private String batchDate;

/** 卡片类型 */
@JsonProperty(value = "CardType")
private String cardType;

/** 卡片起始号 */
@JsonProperty(value = "StartNum")
private String startNum;

/** 卡片结束号 */
@JsonProperty(value = "EndNum")
private String endNum;

/** 批次总张数 */
@JsonProperty(value = "TotalCount")
private Integer totalCount;

/** 申请状态 */
@JsonProperty(value = "Status")
private String status;

/** 卡片版本号 */
@JsonProperty(value = "CardVersion")
private Integer cardVersion;

/** 设备类型 */
@JsonProperty(value = "SeType")
private String seType;

/** 发行方代码 */
@JsonProperty(value = "OrgId")
private String orgId;

/** 渠道 */
@JsonProperty(value = "Chanel")
private String chanel;
}

+ 59
- 0
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/model/VfjQryCardsModel.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss.model;

import cn.com.taiji.common.model.BaseModel;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter;
import lombok.Setter;

@Getter
@Setter
public class VfjQryCardsModel extends BaseModel {

/** 批次号 */
@JsonProperty(value = "BatchNo")
private String batchNo;

/** 卡号 */
@JsonProperty(value = "CardNo")
private String cardNo;

/** 卡片厂商 */
@JsonProperty(value = "Provider")
private String provider;

/** 卡片类型 */
@JsonProperty(value = "CardType")
private String cardType;

/** 发行状态 */
@JsonProperty(value = "Status")
private Integer status;

/** 格式化日期 */
@JsonProperty(value = "FormatTime")
private String formatTime;

/** 最后修改日期 */
@JsonProperty(value = "LastUpdateTime")
private String lastUpdateTime;

/** 卡片SNR */
@JsonProperty(value = "CardSnr")
private String cardSnr;

/** 发行次数 */
@JsonProperty(value = "IssueCount")
private Integer issueCount;

/** 渠道 */
@JsonProperty(value = "Chanel")
private String chanel;

/** 渠道ID */
@JsonProperty(value = "ChanelId")
private String chanelId;

/** 卡片厂商代码 */
@JsonProperty(value = "ProviderID")
private String providerID;
}

+ 47
- 0
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/model/VfjQrySmObuBatchModel.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss.model;

import cn.com.taiji.common.model.BaseModel;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter;
import lombok.Setter;

@Getter
@Setter
public class VfjQrySmObuBatchModel extends BaseModel {

/** 批次号 */
@JsonProperty(value = "BatchNo")
private String batchNo;

/** 批次申请日期 */
@JsonProperty(value = "ApplyDate")
private String applyDate;

/** 卡片类型 */
@JsonProperty(value = "ObuType")
private String obuType;

/** OBU起始号 */
@JsonProperty(value = "StartNum")
private String startNum;

/** OBU结束号 */
@JsonProperty(value = "EndNum")
private String endNum;

/** 卡片起始号 */
@JsonProperty(value = "StartCardNum")
private String startCardNum;

/** 卡片结束号 */
@JsonProperty(value = "EndCardNum")
private String endCardNum;

/** 批次总张数 */
@JsonProperty(value = "TotalCount")
private String totalCount;

/** 渠道名称 */
@JsonProperty(value = "Chanel")
private String chanel;
}

+ 55
- 0
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/model/VfjQueryGmobusModel.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss.model;

import cn.com.taiji.common.model.BaseModel;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter;
import lombok.Setter;

@Getter
@Setter
public class VfjQueryGmobusModel extends BaseModel {

/** 批次号 */
@JsonProperty(value = "BatchNo")
private String batchNo;

/** 合同序列号号 */
@JsonProperty(value = "SerialNo")
private String serialNo;

/** 卡片厂商 */
@JsonProperty(value = "Provider")
private String provider;

/** 卡片厂商代码 */
@JsonProperty(value = "ProviderID")
private String providerID;

/** 激活日期 */
@JsonProperty(value = "ActiveDate")
private String activeDate;

/** 发行状态 */
@JsonProperty(value = "Status")
private Integer status;

/** 格式化日期 */
@JsonProperty(value = "FormatTime")
private String formatTime;

/** 最后修改日期 */
@JsonProperty(value = "LastUpdateTime")
private String lastUpdateTime;

/** OBU 物理号 */
@JsonProperty(value = "ObuMac")
private String obuMac;

/** 渠道 */
@JsonProperty(value = "Chanel")
private String chanel;

/** 渠道ID */
@JsonProperty(value = "ChanelId")
private String chanelId;
}

+ 67
- 0
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/model/VfjQueryScobusModel.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss.model;

import cn.com.taiji.common.model.BaseModel;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter;
import lombok.Setter;

@Getter
@Setter
public class VfjQueryScobusModel extends BaseModel {

/** 批次号 */
@JsonProperty(value = "BatchNo")
private String batchNo;

/** 合同序列号号 */
@JsonProperty(value = "SerialNo")
private String serialNo;

/** 卡号 */
@JsonProperty(value = "CardNo")
private String cardNo;

/** 卡片类型 */
@JsonProperty(value = "CardType")
private String cardType;

/** 卡片厂商 */
@JsonProperty(value = "Provider")
private String provider;

/** 卡片厂商代码 */
@JsonProperty(value = "ProviderID")
private String providerID;

/** 激活日期 */
@JsonProperty(value = "ActiveDate")
private String activeDate;

/** 发行状态 */
@JsonProperty(value = "Status")
private Integer status;

/** 格式化日期 */
@JsonProperty(value = "FormatTime")
private String formatTime;

/** 最后修改日期 */
@JsonProperty(value = "LastUpdateTime")
private String lastUpdateTime;

/** OBU 物理号 */
@JsonProperty(value = "ObuMac")
private String obuMac;

/** 卡片SNR */
@JsonProperty(value = "CardSnr")
private String cardSnr;

/** 渠道 */
@JsonProperty(value = "Chanel")
private String chanel;

/** 渠道ID */
@JsonProperty(value = "ChanelId")
private String chanelId;
}

+ 55
- 0
gly-base-core/src/main/java/cn/com/taiji/core/model/comm/protocol/inss/model/VfjQueryTriDesObusModel.java Просмотреть файл

package cn.com.taiji.core.model.comm.protocol.inss.model;

import cn.com.taiji.common.model.BaseModel;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Getter;
import lombok.Setter;

@Getter
@Setter
public class VfjQueryTriDesObusModel extends BaseModel {

/** 批次号 */
@JsonProperty(value = "BatchNo")
private String batchNo;

/** 合同序列号号 */
@JsonProperty(value = "SerialNo")
private String serialNo;

/** 卡片厂商 */
@JsonProperty(value = "Provider")
private String provider;

/** 卡片厂商代码 */
@JsonProperty(value = "ProviderID")
private String providerID;

/** 激活日期 */
@JsonProperty(value = "ActiveDate")
private String activeDate;

/** 发行状态 */
@JsonProperty(value = "Status")
private Integer status;

/** 格式化日期 */
@JsonProperty(value = "FormatTime")
private String formatTime;

/** 最后修改日期 */
@JsonProperty(value = "LastUpdateTime")
private String lastUpdateTime;

/** OBU 物理号 */
@JsonProperty(value = "ObuMac")
private String obuMac;

/** 渠道 */
@JsonProperty(value = "Chanel")
private String chanel;

/** 渠道ID */
@JsonProperty(value = "ChanelId")
private String chanelId;
}

+ 27
- 3
zhywpt-dps-iasq/src/main/java/cn/com/taiji/iasq/manager/quartz/vfj/VfjQryCardBatchManagerImpl.java Просмотреть файл

import cn.com.taiji.core.entity.invw.InvwQryCardBatch; import cn.com.taiji.core.entity.invw.InvwQryCardBatch;
import cn.com.taiji.core.model.comm.protocol.inss.VfjQryCardBatchRequest; import cn.com.taiji.core.model.comm.protocol.inss.VfjQryCardBatchRequest;
import cn.com.taiji.core.model.comm.protocol.inss.VfjQryCardBatchResponse; import cn.com.taiji.core.model.comm.protocol.inss.VfjQryCardBatchResponse;
import cn.com.taiji.core.model.comm.protocol.inss.model.VfjQryCardBatchModel;
import cn.com.taiji.core.repo.jpa.invw.InvwQryCardBatchRepo; import cn.com.taiji.core.repo.jpa.invw.InvwQryCardBatchRepo;
import cn.com.taiji.iasq.manager.AbstractCommManager; import cn.com.taiji.iasq.manager.AbstractCommManager;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;


import java.util.ArrayList;
import java.util.List;

@Service @Service
public class VfjQryCardBatchManagerImpl extends AbstractCommManager implements VfjQryCardBatchManager { public class VfjQryCardBatchManagerImpl extends AbstractCommManager implements VfjQryCardBatchManager {


logger.info("--卡片发行批次列表查询返回空响应--"); logger.info("--卡片发行批次列表查询返回空响应--");
return; return;
} }
InvwQryCardBatch entity = new InvwQryCardBatch();
BeanUtils.copyProperties(response, entity);
repo.save(entity);

// 1000条存一次
int batchSize = 1000;
List<InvwQryCardBatch> batchList = new ArrayList<>(batchSize);

for (int i = 0; i < response.getDatas().size(); i++) {
VfjQryCardBatchModel model = response.getDatas().get(i);
InvwQryCardBatch entity = new InvwQryCardBatch();
BeanUtils.copyProperties(model, entity);
batchList.add(entity);

// 当批次达到指定大小时,保存并清空批次列表
if (batchList.size() >= batchSize) {
repo.saveAll(batchList);
batchList.clear();
}
}

// 保存剩余的
if (!batchList.isEmpty()) {
repo.saveAll(batchList);
}

logger.info("--卡片发行批次列表查询结束--"); logger.info("--卡片发行批次列表查询结束--");
} catch (ManagerException e) { } catch (ManagerException e) {
logger.error("--卡片发行批次列表查询失败:", e); logger.error("--卡片发行批次列表查询失败:", e);

+ 27
- 3
zhywpt-dps-iasq/src/main/java/cn/com/taiji/iasq/manager/quartz/vfj/VfjQryCardsManagerImpl.java Просмотреть файл

import cn.com.taiji.core.entity.invw.InvwQryCards; import cn.com.taiji.core.entity.invw.InvwQryCards;
import cn.com.taiji.core.model.comm.protocol.inss.VfjQryCardsRequest; import cn.com.taiji.core.model.comm.protocol.inss.VfjQryCardsRequest;
import cn.com.taiji.core.model.comm.protocol.inss.VfjQryCardsResponse; import cn.com.taiji.core.model.comm.protocol.inss.VfjQryCardsResponse;
import cn.com.taiji.core.model.comm.protocol.inss.model.VfjQryCardsModel;
import cn.com.taiji.core.repo.jpa.invw.InvwQryCardsRepo; import cn.com.taiji.core.repo.jpa.invw.InvwQryCardsRepo;
import cn.com.taiji.iasq.manager.AbstractCommManager; import cn.com.taiji.iasq.manager.AbstractCommManager;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;


import java.util.ArrayList;
import java.util.List;

@Service @Service
public class VfjQryCardsManagerImpl extends AbstractCommManager implements VfjQryCardsManager { public class VfjQryCardsManagerImpl extends AbstractCommManager implements VfjQryCardsManager {


logger.info("--卡片发行批次列查询返回空响应--"); logger.info("--卡片发行批次列查询返回空响应--");
return; return;
} }
InvwQryCards entity = new InvwQryCards();
BeanUtils.copyProperties(response, entity);
repo.save(entity);

// 1000条存一次
int batchSize = 1000;
List<InvwQryCards> batchList = new ArrayList<>(batchSize);

for (int i = 0; i < response.getDatas().size(); i++) {
VfjQryCardsModel model = response.getDatas().get(i);
InvwQryCards entity = new InvwQryCards();
BeanUtils.copyProperties(model, entity);
batchList.add(entity);

// 当批次达到指定大小时,保存并清空批次列表
if (batchList.size() >= batchSize) {
repo.saveAll(batchList);
batchList.clear();
}
}

// 保存剩余的
if (!batchList.isEmpty()) {
repo.saveAll(batchList);
}

logger.info("--卡片发行批次列查询结束--"); logger.info("--卡片发行批次列查询结束--");
} catch (ManagerException e) { } catch (ManagerException e) {
logger.error("--卡片发行批次列查询失败:", e); logger.error("--卡片发行批次列查询失败:", e);

+ 27
- 3
zhywpt-dps-iasq/src/main/java/cn/com/taiji/iasq/manager/quartz/vfj/VfjQrySmObuBatchManagerImpl.java Просмотреть файл

import cn.com.taiji.core.entity.invw.InvwQryObuBatch; import cn.com.taiji.core.entity.invw.InvwQryObuBatch;
import cn.com.taiji.core.model.comm.protocol.inss.VfjQrySmObuBatchRequest; import cn.com.taiji.core.model.comm.protocol.inss.VfjQrySmObuBatchRequest;
import cn.com.taiji.core.model.comm.protocol.inss.VfjQrySmObuBatchResponse; import cn.com.taiji.core.model.comm.protocol.inss.VfjQrySmObuBatchResponse;
import cn.com.taiji.core.model.comm.protocol.inss.model.VfjQrySmObuBatchModel;
import cn.com.taiji.core.repo.jpa.invw.InvwQryObuBatchRepo; import cn.com.taiji.core.repo.jpa.invw.InvwQryObuBatchRepo;
import cn.com.taiji.iasq.manager.AbstractCommManager; import cn.com.taiji.iasq.manager.AbstractCommManager;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;


import java.util.ArrayList;
import java.util.List;

@Service @Service
public class VfjQrySmObuBatchManagerImpl extends AbstractCommManager implements VfjQrySmObuBatchManager { public class VfjQrySmObuBatchManagerImpl extends AbstractCommManager implements VfjQrySmObuBatchManager {


logger.info("--OBU发行批次列表查询返回空响应--"); logger.info("--OBU发行批次列表查询返回空响应--");
return; return;
} }
InvwQryObuBatch entity = new InvwQryObuBatch();
BeanUtils.copyProperties(response, entity);
repo.save(entity);

// 1000条存一次
int batchSize = 1000;
List<InvwQryObuBatch> batchList = new ArrayList<>(batchSize);

for (int i = 0; i < response.getDatas().size(); i++) {
VfjQrySmObuBatchModel model = response.getDatas().get(i);
InvwQryObuBatch entity = new InvwQryObuBatch();
BeanUtils.copyProperties(model, entity);
batchList.add(entity);

// 当批次达到指定大小时,保存并清空批次列表
if (batchList.size() >= batchSize) {
repo.saveAll(batchList);
batchList.clear();
}
}

// 保存剩余的
if (!batchList.isEmpty()) {
repo.saveAll(batchList);
}

logger.info("--OBU发行批次列表查询结束--"); logger.info("--OBU发行批次列表查询结束--");
} catch (ManagerException e) { } catch (ManagerException e) {
logger.error("--OBU发行批次列表查询失败:", e); logger.error("--OBU发行批次列表查询失败:", e);

+ 27
- 3
zhywpt-dps-iasq/src/main/java/cn/com/taiji/iasq/manager/quartz/vfj/VfjQueryGmobusManagerImpl.java Просмотреть файл

import cn.com.taiji.core.entity.invw.InvwQryObus; import cn.com.taiji.core.entity.invw.InvwQryObus;
import cn.com.taiji.core.model.comm.protocol.inss.VfjQueryGmobusRequest; import cn.com.taiji.core.model.comm.protocol.inss.VfjQueryGmobusRequest;
import cn.com.taiji.core.model.comm.protocol.inss.VfjQueryGmobusResponse; import cn.com.taiji.core.model.comm.protocol.inss.VfjQueryGmobusResponse;
import cn.com.taiji.core.model.comm.protocol.inss.model.VfjQueryGmobusModel;
import cn.com.taiji.core.repo.jpa.invw.InvwQryObusRepo; import cn.com.taiji.core.repo.jpa.invw.InvwQryObusRepo;
import cn.com.taiji.iasq.manager.AbstractCommManager; import cn.com.taiji.iasq.manager.AbstractCommManager;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;


import java.util.ArrayList;
import java.util.List;

@Service @Service
public class VfjQueryGmobusManagerImpl extends AbstractCommManager implements VfjQueryGmobusManager { public class VfjQueryGmobusManagerImpl extends AbstractCommManager implements VfjQueryGmobusManager {


logger.info("--双片国密OBU发行批次列表查询返回空响应--"); logger.info("--双片国密OBU发行批次列表查询返回空响应--");
return; return;
} }
InvwQryObus entity = new InvwQryObus();
BeanUtils.copyProperties(response, entity);
repo.save(entity);

// 1000条存一次
int batchSize = 1000;
List<InvwQryObus> batchList = new ArrayList<>(batchSize);

for (int i = 0; i < response.getDatas().size(); i++) {
VfjQueryGmobusModel model = response.getDatas().get(i);
InvwQryObus entity = new InvwQryObus();
BeanUtils.copyProperties(model, entity);
batchList.add(entity);

// 当批次达到指定大小时,保存并清空批次列表
if (batchList.size() >= batchSize) {
repo.saveAll(batchList);
batchList.clear();
}
}

// 保存剩余的
if (!batchList.isEmpty()) {
repo.saveAll(batchList);
}

logger.info("--双片国密OBU发行批次列表查询结束--"); logger.info("--双片国密OBU发行批次列表查询结束--");
} catch (ManagerException e) { } catch (ManagerException e) {
logger.error("--双片国密OBU发行批次列表查询失败:", e); logger.error("--双片国密OBU发行批次列表查询失败:", e);

+ 27
- 3
zhywpt-dps-iasq/src/main/java/cn/com/taiji/iasq/manager/quartz/vfj/VfjQueryScobusManagerImpl.java Просмотреть файл

import cn.com.taiji.core.entity.invw.InvwQryObus; import cn.com.taiji.core.entity.invw.InvwQryObus;
import cn.com.taiji.core.model.comm.protocol.inss.VfjQueryScobusRequest; import cn.com.taiji.core.model.comm.protocol.inss.VfjQueryScobusRequest;
import cn.com.taiji.core.model.comm.protocol.inss.VfjQueryScobusResponse; import cn.com.taiji.core.model.comm.protocol.inss.VfjQueryScobusResponse;
import cn.com.taiji.core.model.comm.protocol.inss.model.VfjQueryScobusModel;
import cn.com.taiji.core.repo.jpa.invw.InvwQryObusRepo; import cn.com.taiji.core.repo.jpa.invw.InvwQryObusRepo;
import cn.com.taiji.iasq.manager.AbstractCommManager; import cn.com.taiji.iasq.manager.AbstractCommManager;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;


import java.util.ArrayList;
import java.util.List;

@Service @Service
public class VfjQueryScobusManagerImpl extends AbstractCommManager implements VfjQueryScobusManager { public class VfjQueryScobusManagerImpl extends AbstractCommManager implements VfjQueryScobusManager {


logger.info("--双片国密OBU发行批次列表查询返回空响应--"); logger.info("--双片国密OBU发行批次列表查询返回空响应--");
return; return;
} }
InvwQryObus entity = new InvwQryObus();
BeanUtils.copyProperties(response, entity);
repo.save(entity);

// 1000条存一次
int batchSize = 1000;
List<InvwQryObus> batchList = new ArrayList<>(batchSize);

for (int i = 0; i < response.getDatas().size(); i++) {
VfjQueryScobusModel model = response.getDatas().get(i);
InvwQryObus entity = new InvwQryObus();
BeanUtils.copyProperties(model, entity);
batchList.add(entity);

// 当批次达到指定大小时,保存并清空批次列表
if (batchList.size() >= batchSize) {
repo.saveAll(batchList);
batchList.clear();
}
}

// 保存剩余的
if (!batchList.isEmpty()) {
repo.saveAll(batchList);
}

logger.info("--双片国密OBU发行批次列表查询结束--"); logger.info("--双片国密OBU发行批次列表查询结束--");
} catch (ManagerException e) { } catch (ManagerException e) {
logger.error("--双片国密OBU发行批次列表查询失败:", e); logger.error("--双片国密OBU发行批次列表查询失败:", e);

+ 27
- 3
zhywpt-dps-iasq/src/main/java/cn/com/taiji/iasq/manager/quartz/vfj/VfjQueryTriDesObusManagerImpl.java Просмотреть файл

import cn.com.taiji.core.entity.invw.InvwQryObus; import cn.com.taiji.core.entity.invw.InvwQryObus;
import cn.com.taiji.core.model.comm.protocol.inss.VfjQueryTriDesObusRequest; import cn.com.taiji.core.model.comm.protocol.inss.VfjQueryTriDesObusRequest;
import cn.com.taiji.core.model.comm.protocol.inss.VfjQueryTriDesObusResponse; import cn.com.taiji.core.model.comm.protocol.inss.VfjQueryTriDesObusResponse;
import cn.com.taiji.core.model.comm.protocol.inss.model.VfjQueryTriDesObusModel;
import cn.com.taiji.core.repo.jpa.invw.InvwQryObusRepo; import cn.com.taiji.core.repo.jpa.invw.InvwQryObusRepo;
import cn.com.taiji.iasq.manager.AbstractCommManager; import cn.com.taiji.iasq.manager.AbstractCommManager;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;


import java.util.ArrayList;
import java.util.List;

@Service @Service
public class VfjQueryTriDesObusManagerImpl extends AbstractCommManager implements VfjQueryTriDesObusManager { public class VfjQueryTriDesObusManagerImpl extends AbstractCommManager implements VfjQueryTriDesObusManager {


logger.info("--DESOBU发行批次列表查询返回空响应--"); logger.info("--DESOBU发行批次列表查询返回空响应--");
return; return;
} }
InvwQryObus entity = new InvwQryObus();
BeanUtils.copyProperties(response, entity);
repo.save(entity);

// 1000条存一次
int batchSize = 1000;
List<InvwQryObus> batchList = new ArrayList<>(batchSize);

for (int i = 0; i < response.getDatas().size(); i++) {
VfjQueryTriDesObusModel model = response.getDatas().get(i);
InvwQryObus entity = new InvwQryObus();
BeanUtils.copyProperties(model, entity);
batchList.add(entity);

// 当批次达到指定大小时,保存并清空批次列表
if (batchList.size() >= batchSize) {
repo.saveAll(batchList);
batchList.clear();
}
}

// 保存剩余的
if (!batchList.isEmpty()) {
repo.saveAll(batchList);
}

logger.info("--DESOBU发行批次列表查询结束--"); logger.info("--DESOBU发行批次列表查询结束--");
} catch (ManagerException e) { } catch (ManagerException e) {
logger.error("--DESOBU发行批次列表查询失败:", e); logger.error("--DESOBU发行批次列表查询失败:", e);

Загрузка…
Отмена
Сохранить