messageObj = new ProducerRecord<>(topic, message + i);
+ kafkaProducerTransactional.send(messageObj, (metadata, exception) -> {
+ if (null != exception) {
+ log.error("kafka 信息推送失败[" + messageObj + "]", exception);
+ }
+ });
+ }
+ log.info("消息发送成功");
+ kafkaProducerTransactional.commitTransaction();
+ }
+ catch (Exception e) {
+ log.error("kafka 事务消息推送失败", e);
+ kafkaProducerTransactional.abortTransaction();
+ }
+ finally {
+ kafkaProducerTransactional.close();
+ }
+
+ }
+
+}
diff --git a/kafka/src/test/java/com/wyl/kafka/test/ImageDataDTO.java b/kafka/src/test/java/com/wyl/kafka/test/ImageDataDTO.java
new file mode 100644
index 0000000..94d6cc5
--- /dev/null
+++ b/kafka/src/test/java/com/wyl/kafka/test/ImageDataDTO.java
@@ -0,0 +1,3234 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: ImageDTO.proto
+
+package com.wyl.kafka.test;
+
+public final class ImageDataDTO {
+ private ImageDataDTO() {
+ }
+
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistryLite registry) {
+ }
+
+ public static void registerAllExtensions(
+ com.google.protobuf.ExtensionRegistry registry) {
+ registerAllExtensions(
+ (com.google.protobuf.ExtensionRegistryLite) registry);
+ }
+
+ public interface ImageDTOOrBuilder extends
+ // @@protoc_insertion_point(interface_extends:ivf_tl_Entity.DTO.ImageDTO)
+ com.google.protobuf.MessageOrBuilder {
+
+ /**
+ *
+ * *
+ * tl设备编号
+ *
+ *
+ * string tlSn = 1;
+ *
+ * @return The tlSn.
+ */
+ String getTlSn();
+
+ /**
+ *
+ * *
+ * tl设备编号
+ *
+ *
+ * string tlSn = 1;
+ *
+ * @return The bytes for tlSn.
+ */
+ com.google.protobuf.ByteString
+ getTlSnBytes();
+
+ /**
+ *
+ * *
+ * 仓室编号:1-10
+ *
+ *
+ * int32 houseSn = 2;
+ *
+ * @return The houseSn.
+ */
+ int getHouseSn();
+
+ /**
+ *
+ * *
+ * well编号 1-16
+ *
+ *
+ * int32 wellSn = 3;
+ *
+ * @return The wellSn.
+ */
+ int getWellSn();
+
+ /**
+ *
+ * *
+ * ccd编号
+ *
+ *
+ * string ccdSn = 4;
+ *
+ * @return The ccdSn.
+ */
+ String getCcdSn();
+
+ /**
+ *
+ * *
+ * ccd编号
+ *
+ *
+ * string ccdSn = 4;
+ *
+ * @return The bytes for ccdSn.
+ */
+ com.google.protobuf.ByteString
+ getCcdSnBytes();
+
+ /**
+ *
+ * *
+ * 原图名字
+ *
+ *
+ * string sourceImageName = 5;
+ *
+ * @return The sourceImageName.
+ */
+ String getSourceImageName();
+
+ /**
+ *
+ * *
+ * 原图名字
+ *
+ *
+ * string sourceImageName = 5;
+ *
+ * @return The bytes for sourceImageName.
+ */
+ com.google.protobuf.ByteString
+ getSourceImageNameBytes();
+
+ /**
+ *
+ * *
+ * 原图的本地路径(不是上传后的保存路径)
+ *
+ *
+ * string sourceImagePath = 6;
+ *
+ * @return The sourceImagePath.
+ */
+ String getSourceImagePath();
+
+ /**
+ *
+ * *
+ * 原图的本地路径(不是上传后的保存路径)
+ *
+ *
+ * string sourceImagePath = 6;
+ *
+ * @return The bytes for sourceImagePath.
+ */
+ com.google.protobuf.ByteString
+ getSourceImagePathBytes();
+
+ /**
+ *
+ * *
+ * 原图宽
+ *
+ *
+ * int32 sourceImageWidth = 7;
+ *
+ * @return The sourceImageWidth.
+ */
+ int getSourceImageWidth();
+
+ /**
+ *
+ * *
+ * 原图高
+ *
+ *
+ * int32 sourceImageHeight = 8;
+ *
+ * @return The sourceImageHeight.
+ */
+ int getSourceImageHeight();
+
+ /**
+ *
+ * *
+ * 设备拍摄时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string imageTime = 9;
+ *
+ * @return The imageTime.
+ */
+ String getImageTime();
+
+ /**
+ *
+ * *
+ * 设备拍摄时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string imageTime = 9;
+ *
+ * @return The bytes for imageTime.
+ */
+ com.google.protobuf.ByteString
+ getImageTimeBytes();
+
+ /**
+ *
+ * *
+ * 受精时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string fertilizationTime = 10;
+ *
+ * @return The fertilizationTime.
+ */
+ String getFertilizationTime();
+
+ /**
+ *
+ * *
+ * 受精时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string fertilizationTime = 10;
+ *
+ * @return The bytes for fertilizationTime.
+ */
+ com.google.protobuf.ByteString
+ getFertilizationTimeBytes();
+
+ /**
+ *
+ * *
+ * 对焦还是ccd拍照 1 自动对焦 0 CCD拍照
+ *
+ *
+ * int32 photographType = 11;
+ *
+ * @return The photographType.
+ */
+ int getPhotographType();
+
+ /**
+ *
+ * *
+ * 拍照总层数
+ *
+ *
+ * int32 totalLayer = 12;
+ *
+ * @return The totalLayer.
+ */
+ int getTotalLayer();
+
+ /**
+ *
+ * *
+ * 图片层
+ *
+ *
+ * int32 pictureLayer = 13;
+ *
+ * @return The pictureLayer.
+ */
+ int getPictureLayer();
+
+ /**
+ *
+ * *
+ * 垂直电机位置
+ *
+ *
+ * int32 shootingPosition = 14;
+ *
+ * @return The shootingPosition.
+ */
+ int getShootingPosition();
+
+ /**
+ *
+ * *
+ * 是否是最清晰的(CCD拍照才有)0不是 1最清晰
+ *
+ *
+ * int32 clearest = 15;
+ *
+ * @return The clearest.
+ */
+ int getClearest();
+
+ /**
+ *
+ * *
+ * 拍照结束标记 1 结束 0 未结束 (结束后开始更新对焦起点,ccd拍照结束开始合成视频)
+ *
+ *
+ * int32 end = 16;
+ *
+ * @return The end.
+ */
+ int getEnd();
+
+ /**
+ *
+ * *
+ * 培养记录id
+ *
+ *
+ * uint64 embryoCultureRecordId = 17;
+ *
+ * @return The embryoCultureRecordId.
+ */
+ long getEmbryoCultureRecordId();
+
+ /**
+ *
+ * *
+ * 胚胎id
+ *
+ *
+ * uint64 embryoId = 18;
+ *
+ * @return The embryoId.
+ */
+ long getEmbryoId();
+
+ /**
+ *
+ * *
+ * 图片数据
+ *
+ *
+ * bytes imageData = 19;
+ *
+ * @return The imageData.
+ */
+ com.google.protobuf.ByteString getImageData();
+
+ /**
+ *
+ * *
+ * 水平电机位置
+ *
+ *
+ * int32 horizontalPosition = 20;
+ *
+ * @return The horizontalPosition.
+ */
+ int getHorizontalPosition();
+ }
+
+ /**
+ * Protobuf type {@code ivf_tl_Entity.DTO.ImageDTO}
+ */
+ public static final class ImageDTO extends
+ com.google.protobuf.GeneratedMessageV3 implements
+ // @@protoc_insertion_point(message_implements:ivf_tl_Entity.DTO.ImageDTO)
+ ImageDTOOrBuilder {
+ private static final long serialVersionUID = 0L;
+
+ // Use ImageDTO.newBuilder() to construct.
+ private ImageDTO(com.google.protobuf.GeneratedMessageV3.Builder> builder) {
+ super(builder);
+ }
+
+ private ImageDTO() {
+ tlSn_ = "";
+ ccdSn_ = "";
+ sourceImageName_ = "";
+ sourceImagePath_ = "";
+ imageTime_ = "";
+ fertilizationTime_ = "";
+ imageData_ = com.google.protobuf.ByteString.EMPTY;
+ }
+
+ @Override
+ @SuppressWarnings({"unused"})
+ protected Object newInstance(
+ UnusedPrivateParameter unused) {
+ return new ImageDTO();
+ }
+
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return ImageDataDTO.internal_static_ivf_tl_Entity_DTO_ImageDTO_descriptor;
+ }
+
+ @Override
+ protected FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return ImageDataDTO.internal_static_ivf_tl_Entity_DTO_ImageDTO_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ ImageDTO.class, Builder.class);
+ }
+
+ public static final int TLSN_FIELD_NUMBER = 1;
+ @SuppressWarnings("serial")
+ private volatile Object tlSn_ = "";
+
+ /**
+ *
+ * *
+ * tl设备编号
+ *
+ *
+ * string tlSn = 1;
+ *
+ * @return The tlSn.
+ */
+ @Override
+ public String getTlSn() {
+ Object ref = tlSn_;
+ if (ref instanceof String) {
+ return (String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ tlSn_ = s;
+ return s;
+ }
+ }
+
+ /**
+ *
+ * *
+ * tl设备编号
+ *
+ *
+ * string tlSn = 1;
+ *
+ * @return The bytes for tlSn.
+ */
+ @Override
+ public com.google.protobuf.ByteString
+ getTlSnBytes() {
+ Object ref = tlSn_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ tlSn_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int HOUSESN_FIELD_NUMBER = 2;
+ private int houseSn_ = 0;
+
+ /**
+ *
+ * *
+ * 仓室编号:1-10
+ *
+ *
+ * int32 houseSn = 2;
+ *
+ * @return The houseSn.
+ */
+ @Override
+ public int getHouseSn() {
+ return houseSn_;
+ }
+
+ public static final int WELLSN_FIELD_NUMBER = 3;
+ private int wellSn_ = 0;
+
+ /**
+ *
+ * *
+ * well编号 1-16
+ *
+ *
+ * int32 wellSn = 3;
+ *
+ * @return The wellSn.
+ */
+ @Override
+ public int getWellSn() {
+ return wellSn_;
+ }
+
+ public static final int CCDSN_FIELD_NUMBER = 4;
+ @SuppressWarnings("serial")
+ private volatile Object ccdSn_ = "";
+
+ /**
+ *
+ * *
+ * ccd编号
+ *
+ *
+ * string ccdSn = 4;
+ *
+ * @return The ccdSn.
+ */
+ @Override
+ public String getCcdSn() {
+ Object ref = ccdSn_;
+ if (ref instanceof String) {
+ return (String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ ccdSn_ = s;
+ return s;
+ }
+ }
+
+ /**
+ *
+ * *
+ * ccd编号
+ *
+ *
+ * string ccdSn = 4;
+ *
+ * @return The bytes for ccdSn.
+ */
+ @Override
+ public com.google.protobuf.ByteString
+ getCcdSnBytes() {
+ Object ref = ccdSn_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ ccdSn_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int SOURCEIMAGENAME_FIELD_NUMBER = 5;
+ @SuppressWarnings("serial")
+ private volatile Object sourceImageName_ = "";
+
+ /**
+ *
+ * *
+ * 原图名字
+ *
+ *
+ * string sourceImageName = 5;
+ *
+ * @return The sourceImageName.
+ */
+ @Override
+ public String getSourceImageName() {
+ Object ref = sourceImageName_;
+ if (ref instanceof String) {
+ return (String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ sourceImageName_ = s;
+ return s;
+ }
+ }
+
+ /**
+ *
+ * *
+ * 原图名字
+ *
+ *
+ * string sourceImageName = 5;
+ *
+ * @return The bytes for sourceImageName.
+ */
+ @Override
+ public com.google.protobuf.ByteString
+ getSourceImageNameBytes() {
+ Object ref = sourceImageName_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ sourceImageName_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int SOURCEIMAGEPATH_FIELD_NUMBER = 6;
+ @SuppressWarnings("serial")
+ private volatile Object sourceImagePath_ = "";
+
+ /**
+ *
+ * *
+ * 原图的本地路径(不是上传后的保存路径)
+ *
+ *
+ * string sourceImagePath = 6;
+ *
+ * @return The sourceImagePath.
+ */
+ @Override
+ public String getSourceImagePath() {
+ Object ref = sourceImagePath_;
+ if (ref instanceof String) {
+ return (String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ sourceImagePath_ = s;
+ return s;
+ }
+ }
+
+ /**
+ *
+ * *
+ * 原图的本地路径(不是上传后的保存路径)
+ *
+ *
+ * string sourceImagePath = 6;
+ *
+ * @return The bytes for sourceImagePath.
+ */
+ @Override
+ public com.google.protobuf.ByteString
+ getSourceImagePathBytes() {
+ Object ref = sourceImagePath_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ sourceImagePath_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int SOURCEIMAGEWIDTH_FIELD_NUMBER = 7;
+ private int sourceImageWidth_ = 0;
+
+ /**
+ *
+ * *
+ * 原图宽
+ *
+ *
+ * int32 sourceImageWidth = 7;
+ *
+ * @return The sourceImageWidth.
+ */
+ @Override
+ public int getSourceImageWidth() {
+ return sourceImageWidth_;
+ }
+
+ public static final int SOURCEIMAGEHEIGHT_FIELD_NUMBER = 8;
+ private int sourceImageHeight_ = 0;
+
+ /**
+ *
+ * *
+ * 原图高
+ *
+ *
+ * int32 sourceImageHeight = 8;
+ *
+ * @return The sourceImageHeight.
+ */
+ @Override
+ public int getSourceImageHeight() {
+ return sourceImageHeight_;
+ }
+
+ public static final int IMAGETIME_FIELD_NUMBER = 9;
+ @SuppressWarnings("serial")
+ private volatile Object imageTime_ = "";
+
+ /**
+ *
+ * *
+ * 设备拍摄时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string imageTime = 9;
+ *
+ * @return The imageTime.
+ */
+ @Override
+ public String getImageTime() {
+ Object ref = imageTime_;
+ if (ref instanceof String) {
+ return (String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ imageTime_ = s;
+ return s;
+ }
+ }
+
+ /**
+ *
+ * *
+ * 设备拍摄时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string imageTime = 9;
+ *
+ * @return The bytes for imageTime.
+ */
+ @Override
+ public com.google.protobuf.ByteString
+ getImageTimeBytes() {
+ Object ref = imageTime_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ imageTime_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int FERTILIZATIONTIME_FIELD_NUMBER = 10;
+ @SuppressWarnings("serial")
+ private volatile Object fertilizationTime_ = "";
+
+ /**
+ *
+ * *
+ * 受精时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string fertilizationTime = 10;
+ *
+ * @return The fertilizationTime.
+ */
+ @Override
+ public String getFertilizationTime() {
+ Object ref = fertilizationTime_;
+ if (ref instanceof String) {
+ return (String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ fertilizationTime_ = s;
+ return s;
+ }
+ }
+
+ /**
+ *
+ * *
+ * 受精时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string fertilizationTime = 10;
+ *
+ * @return The bytes for fertilizationTime.
+ */
+ @Override
+ public com.google.protobuf.ByteString
+ getFertilizationTimeBytes() {
+ Object ref = fertilizationTime_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ fertilizationTime_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ public static final int PHOTOGRAPHTYPE_FIELD_NUMBER = 11;
+ private int photographType_ = 0;
+
+ /**
+ *
+ * *
+ * 对焦还是ccd拍照 1 自动对焦 0 CCD拍照
+ *
+ *
+ * int32 photographType = 11;
+ *
+ * @return The photographType.
+ */
+ @Override
+ public int getPhotographType() {
+ return photographType_;
+ }
+
+ public static final int TOTALLAYER_FIELD_NUMBER = 12;
+ private int totalLayer_ = 0;
+
+ /**
+ *
+ * *
+ * 拍照总层数
+ *
+ *
+ * int32 totalLayer = 12;
+ *
+ * @return The totalLayer.
+ */
+ @Override
+ public int getTotalLayer() {
+ return totalLayer_;
+ }
+
+ public static final int PICTURELAYER_FIELD_NUMBER = 13;
+ private int pictureLayer_ = 0;
+
+ /**
+ *
+ * *
+ * 图片层
+ *
+ *
+ * int32 pictureLayer = 13;
+ *
+ * @return The pictureLayer.
+ */
+ @Override
+ public int getPictureLayer() {
+ return pictureLayer_;
+ }
+
+ public static final int SHOOTINGPOSITION_FIELD_NUMBER = 14;
+ private int shootingPosition_ = 0;
+
+ /**
+ *
+ * *
+ * 垂直电机位置
+ *
+ *
+ * int32 shootingPosition = 14;
+ *
+ * @return The shootingPosition.
+ */
+ @Override
+ public int getShootingPosition() {
+ return shootingPosition_;
+ }
+
+ public static final int CLEAREST_FIELD_NUMBER = 15;
+ private int clearest_ = 0;
+
+ /**
+ *
+ * *
+ * 是否是最清晰的(CCD拍照才有)0不是 1最清晰
+ *
+ *
+ * int32 clearest = 15;
+ *
+ * @return The clearest.
+ */
+ @Override
+ public int getClearest() {
+ return clearest_;
+ }
+
+ public static final int END_FIELD_NUMBER = 16;
+ private int end_ = 0;
+
+ /**
+ *
+ * *
+ * 拍照结束标记 1 结束 0 未结束 (结束后开始更新对焦起点,ccd拍照结束开始合成视频)
+ *
+ *
+ * int32 end = 16;
+ *
+ * @return The end.
+ */
+ @Override
+ public int getEnd() {
+ return end_;
+ }
+
+ public static final int EMBRYOCULTURERECORDID_FIELD_NUMBER = 17;
+ private long embryoCultureRecordId_ = 0L;
+
+ /**
+ *
+ * *
+ * 培养记录id
+ *
+ *
+ * uint64 embryoCultureRecordId = 17;
+ *
+ * @return The embryoCultureRecordId.
+ */
+ @Override
+ public long getEmbryoCultureRecordId() {
+ return embryoCultureRecordId_;
+ }
+
+ public static final int EMBRYOID_FIELD_NUMBER = 18;
+ private long embryoId_ = 0L;
+
+ /**
+ *
+ * *
+ * 胚胎id
+ *
+ *
+ * uint64 embryoId = 18;
+ *
+ * @return The embryoId.
+ */
+ @Override
+ public long getEmbryoId() {
+ return embryoId_;
+ }
+
+ public static final int IMAGEDATA_FIELD_NUMBER = 19;
+ private com.google.protobuf.ByteString imageData_ = com.google.protobuf.ByteString.EMPTY;
+
+ /**
+ *
+ * *
+ * 图片数据
+ *
+ *
+ * bytes imageData = 19;
+ *
+ * @return The imageData.
+ */
+ @Override
+ public com.google.protobuf.ByteString getImageData() {
+ return imageData_;
+ }
+
+ public static final int HORIZONTALPOSITION_FIELD_NUMBER = 20;
+ private int horizontalPosition_ = 0;
+
+ /**
+ *
+ * *
+ * 水平电机位置
+ *
+ *
+ * int32 horizontalPosition = 20;
+ *
+ * @return The horizontalPosition.
+ */
+ @Override
+ public int getHorizontalPosition() {
+ return horizontalPosition_;
+ }
+
+ private byte memoizedIsInitialized = -1;
+
+ @Override
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ @Override
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(tlSn_)) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 1, tlSn_);
+ }
+ if (houseSn_ != 0) {
+ output.writeInt32(2, houseSn_);
+ }
+ if (wellSn_ != 0) {
+ output.writeInt32(3, wellSn_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(ccdSn_)) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 4, ccdSn_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(sourceImageName_)) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 5, sourceImageName_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(sourceImagePath_)) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 6, sourceImagePath_);
+ }
+ if (sourceImageWidth_ != 0) {
+ output.writeInt32(7, sourceImageWidth_);
+ }
+ if (sourceImageHeight_ != 0) {
+ output.writeInt32(8, sourceImageHeight_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(imageTime_)) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 9, imageTime_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(fertilizationTime_)) {
+ com.google.protobuf.GeneratedMessageV3.writeString(output, 10, fertilizationTime_);
+ }
+ if (photographType_ != 0) {
+ output.writeInt32(11, photographType_);
+ }
+ if (totalLayer_ != 0) {
+ output.writeInt32(12, totalLayer_);
+ }
+ if (pictureLayer_ != 0) {
+ output.writeInt32(13, pictureLayer_);
+ }
+ if (shootingPosition_ != 0) {
+ output.writeInt32(14, shootingPosition_);
+ }
+ if (clearest_ != 0) {
+ output.writeInt32(15, clearest_);
+ }
+ if (end_ != 0) {
+ output.writeInt32(16, end_);
+ }
+ if (embryoCultureRecordId_ != 0L) {
+ output.writeUInt64(17, embryoCultureRecordId_);
+ }
+ if (embryoId_ != 0L) {
+ output.writeUInt64(18, embryoId_);
+ }
+ if (!imageData_.isEmpty()) {
+ output.writeBytes(19, imageData_);
+ }
+ if (horizontalPosition_ != 0) {
+ output.writeInt32(20, horizontalPosition_);
+ }
+ getUnknownFields().writeTo(output);
+ }
+
+ @Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(tlSn_)) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, tlSn_);
+ }
+ if (houseSn_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(2, houseSn_);
+ }
+ if (wellSn_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(3, wellSn_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(ccdSn_)) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(4, ccdSn_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(sourceImageName_)) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(5, sourceImageName_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(sourceImagePath_)) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(6, sourceImagePath_);
+ }
+ if (sourceImageWidth_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(7, sourceImageWidth_);
+ }
+ if (sourceImageHeight_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(8, sourceImageHeight_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(imageTime_)) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(9, imageTime_);
+ }
+ if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(fertilizationTime_)) {
+ size += com.google.protobuf.GeneratedMessageV3.computeStringSize(10, fertilizationTime_);
+ }
+ if (photographType_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(11, photographType_);
+ }
+ if (totalLayer_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(12, totalLayer_);
+ }
+ if (pictureLayer_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(13, pictureLayer_);
+ }
+ if (shootingPosition_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(14, shootingPosition_);
+ }
+ if (clearest_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(15, clearest_);
+ }
+ if (end_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(16, end_);
+ }
+ if (embryoCultureRecordId_ != 0L) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeUInt64Size(17, embryoCultureRecordId_);
+ }
+ if (embryoId_ != 0L) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeUInt64Size(18, embryoId_);
+ }
+ if (!imageData_.isEmpty()) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeBytesSize(19, imageData_);
+ }
+ if (horizontalPosition_ != 0) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(20, horizontalPosition_);
+ }
+ size += getUnknownFields().getSerializedSize();
+ memoizedSize = size;
+ return size;
+ }
+
+ @Override
+ public boolean equals(final Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof ImageDTO)) {
+ return super.equals(obj);
+ }
+ ImageDTO other = (ImageDTO) obj;
+
+ if (!getTlSn()
+ .equals(other.getTlSn())) return false;
+ if (getHouseSn()
+ != other.getHouseSn()) return false;
+ if (getWellSn()
+ != other.getWellSn()) return false;
+ if (!getCcdSn()
+ .equals(other.getCcdSn())) return false;
+ if (!getSourceImageName()
+ .equals(other.getSourceImageName())) return false;
+ if (!getSourceImagePath()
+ .equals(other.getSourceImagePath())) return false;
+ if (getSourceImageWidth()
+ != other.getSourceImageWidth()) return false;
+ if (getSourceImageHeight()
+ != other.getSourceImageHeight()) return false;
+ if (!getImageTime()
+ .equals(other.getImageTime())) return false;
+ if (!getFertilizationTime()
+ .equals(other.getFertilizationTime())) return false;
+ if (getPhotographType()
+ != other.getPhotographType()) return false;
+ if (getTotalLayer()
+ != other.getTotalLayer()) return false;
+ if (getPictureLayer()
+ != other.getPictureLayer()) return false;
+ if (getShootingPosition()
+ != other.getShootingPosition()) return false;
+ if (getClearest()
+ != other.getClearest()) return false;
+ if (getEnd()
+ != other.getEnd()) return false;
+ if (getEmbryoCultureRecordId()
+ != other.getEmbryoCultureRecordId()) return false;
+ if (getEmbryoId()
+ != other.getEmbryoId()) return false;
+ if (!getImageData()
+ .equals(other.getImageData())) return false;
+ if (getHorizontalPosition()
+ != other.getHorizontalPosition()) return false;
+ return getUnknownFields().equals(other.getUnknownFields());
+ }
+
+ @Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ hash = (37 * hash) + TLSN_FIELD_NUMBER;
+ hash = (53 * hash) + getTlSn().hashCode();
+ hash = (37 * hash) + HOUSESN_FIELD_NUMBER;
+ hash = (53 * hash) + getHouseSn();
+ hash = (37 * hash) + WELLSN_FIELD_NUMBER;
+ hash = (53 * hash) + getWellSn();
+ hash = (37 * hash) + CCDSN_FIELD_NUMBER;
+ hash = (53 * hash) + getCcdSn().hashCode();
+ hash = (37 * hash) + SOURCEIMAGENAME_FIELD_NUMBER;
+ hash = (53 * hash) + getSourceImageName().hashCode();
+ hash = (37 * hash) + SOURCEIMAGEPATH_FIELD_NUMBER;
+ hash = (53 * hash) + getSourceImagePath().hashCode();
+ hash = (37 * hash) + SOURCEIMAGEWIDTH_FIELD_NUMBER;
+ hash = (53 * hash) + getSourceImageWidth();
+ hash = (37 * hash) + SOURCEIMAGEHEIGHT_FIELD_NUMBER;
+ hash = (53 * hash) + getSourceImageHeight();
+ hash = (37 * hash) + IMAGETIME_FIELD_NUMBER;
+ hash = (53 * hash) + getImageTime().hashCode();
+ hash = (37 * hash) + FERTILIZATIONTIME_FIELD_NUMBER;
+ hash = (53 * hash) + getFertilizationTime().hashCode();
+ hash = (37 * hash) + PHOTOGRAPHTYPE_FIELD_NUMBER;
+ hash = (53 * hash) + getPhotographType();
+ hash = (37 * hash) + TOTALLAYER_FIELD_NUMBER;
+ hash = (53 * hash) + getTotalLayer();
+ hash = (37 * hash) + PICTURELAYER_FIELD_NUMBER;
+ hash = (53 * hash) + getPictureLayer();
+ hash = (37 * hash) + SHOOTINGPOSITION_FIELD_NUMBER;
+ hash = (53 * hash) + getShootingPosition();
+ hash = (37 * hash) + CLEAREST_FIELD_NUMBER;
+ hash = (53 * hash) + getClearest();
+ hash = (37 * hash) + END_FIELD_NUMBER;
+ hash = (53 * hash) + getEnd();
+ hash = (37 * hash) + EMBRYOCULTURERECORDID_FIELD_NUMBER;
+ hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+ getEmbryoCultureRecordId());
+ hash = (37 * hash) + EMBRYOID_FIELD_NUMBER;
+ hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+ getEmbryoId());
+ hash = (37 * hash) + IMAGEDATA_FIELD_NUMBER;
+ hash = (53 * hash) + getImageData().hashCode();
+ hash = (37 * hash) + HORIZONTALPOSITION_FIELD_NUMBER;
+ hash = (53 * hash) + getHorizontalPosition();
+ hash = (29 * hash) + getUnknownFields().hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static ImageDTO parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+
+ public static ImageDTO parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+
+ public static ImageDTO parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+
+ public static ImageDTO parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+
+ public static ImageDTO parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+
+ public static ImageDTO parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+
+ public static ImageDTO parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+
+ public static ImageDTO parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ public static ImageDTO parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input);
+ }
+
+ public static ImageDTO parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ public static ImageDTO parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+
+ public static ImageDTO parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ @Override
+ public Builder newBuilderForType() {
+ return newBuilder();
+ }
+
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+
+ public static Builder newBuilder(ImageDTO prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+
+ @Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @Override
+ protected Builder newBuilderForType(
+ BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+
+ /**
+ * Protobuf type {@code ivf_tl_Entity.DTO.ImageDTO}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessageV3.Builder implements
+ // @@protoc_insertion_point(builder_implements:ivf_tl_Entity.DTO.ImageDTO)
+ ImageDTOOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return ImageDataDTO.internal_static_ivf_tl_Entity_DTO_ImageDTO_descriptor;
+ }
+
+ @Override
+ protected FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return ImageDataDTO.internal_static_ivf_tl_Entity_DTO_ImageDTO_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ ImageDTO.class, Builder.class);
+ }
+
+ // Construct using com.aivfo.data.transmission.entity.dto.ImageDataDTO.ImageDTO.newBuilder()
+ private Builder() {
+
+ }
+
+ private Builder(
+ BuilderParent parent) {
+ super(parent);
+
+ }
+
+ @Override
+ public Builder clear() {
+ super.clear();
+ bitField0_ = 0;
+ tlSn_ = "";
+ houseSn_ = 0;
+ wellSn_ = 0;
+ ccdSn_ = "";
+ sourceImageName_ = "";
+ sourceImagePath_ = "";
+ sourceImageWidth_ = 0;
+ sourceImageHeight_ = 0;
+ imageTime_ = "";
+ fertilizationTime_ = "";
+ photographType_ = 0;
+ totalLayer_ = 0;
+ pictureLayer_ = 0;
+ shootingPosition_ = 0;
+ clearest_ = 0;
+ end_ = 0;
+ embryoCultureRecordId_ = 0L;
+ embryoId_ = 0L;
+ imageData_ = com.google.protobuf.ByteString.EMPTY;
+ horizontalPosition_ = 0;
+ return this;
+ }
+
+ @Override
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return ImageDataDTO.internal_static_ivf_tl_Entity_DTO_ImageDTO_descriptor;
+ }
+
+ @Override
+ public ImageDTO getDefaultInstanceForType() {
+ return ImageDTO.getDefaultInstance();
+ }
+
+ @Override
+ public ImageDTO build() {
+ ImageDTO result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ @Override
+ public ImageDTO buildPartial() {
+ ImageDTO result = new ImageDTO(this);
+ if (bitField0_ != 0) {
+ buildPartial0(result);
+ }
+ onBuilt();
+ return result;
+ }
+
+ private void buildPartial0(ImageDTO result) {
+ int from_bitField0_ = bitField0_;
+ if (((from_bitField0_ & 0x00000001) != 0)) {
+ result.tlSn_ = tlSn_;
+ }
+ if (((from_bitField0_ & 0x00000002) != 0)) {
+ result.houseSn_ = houseSn_;
+ }
+ if (((from_bitField0_ & 0x00000004) != 0)) {
+ result.wellSn_ = wellSn_;
+ }
+ if (((from_bitField0_ & 0x00000008) != 0)) {
+ result.ccdSn_ = ccdSn_;
+ }
+ if (((from_bitField0_ & 0x00000010) != 0)) {
+ result.sourceImageName_ = sourceImageName_;
+ }
+ if (((from_bitField0_ & 0x00000020) != 0)) {
+ result.sourceImagePath_ = sourceImagePath_;
+ }
+ if (((from_bitField0_ & 0x00000040) != 0)) {
+ result.sourceImageWidth_ = sourceImageWidth_;
+ }
+ if (((from_bitField0_ & 0x00000080) != 0)) {
+ result.sourceImageHeight_ = sourceImageHeight_;
+ }
+ if (((from_bitField0_ & 0x00000100) != 0)) {
+ result.imageTime_ = imageTime_;
+ }
+ if (((from_bitField0_ & 0x00000200) != 0)) {
+ result.fertilizationTime_ = fertilizationTime_;
+ }
+ if (((from_bitField0_ & 0x00000400) != 0)) {
+ result.photographType_ = photographType_;
+ }
+ if (((from_bitField0_ & 0x00000800) != 0)) {
+ result.totalLayer_ = totalLayer_;
+ }
+ if (((from_bitField0_ & 0x00001000) != 0)) {
+ result.pictureLayer_ = pictureLayer_;
+ }
+ if (((from_bitField0_ & 0x00002000) != 0)) {
+ result.shootingPosition_ = shootingPosition_;
+ }
+ if (((from_bitField0_ & 0x00004000) != 0)) {
+ result.clearest_ = clearest_;
+ }
+ if (((from_bitField0_ & 0x00008000) != 0)) {
+ result.end_ = end_;
+ }
+ if (((from_bitField0_ & 0x00010000) != 0)) {
+ result.embryoCultureRecordId_ = embryoCultureRecordId_;
+ }
+ if (((from_bitField0_ & 0x00020000) != 0)) {
+ result.embryoId_ = embryoId_;
+ }
+ if (((from_bitField0_ & 0x00040000) != 0)) {
+ result.imageData_ = imageData_;
+ }
+ if (((from_bitField0_ & 0x00080000) != 0)) {
+ result.horizontalPosition_ = horizontalPosition_;
+ }
+ }
+
+ @Override
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof ImageDTO) {
+ return mergeFrom((ImageDTO) other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(ImageDTO other) {
+ if (other == ImageDTO.getDefaultInstance())
+ return this;
+ if (!other.getTlSn().isEmpty()) {
+ tlSn_ = other.tlSn_;
+ bitField0_ |= 0x00000001;
+ onChanged();
+ }
+ if (other.getHouseSn() != 0) {
+ setHouseSn(other.getHouseSn());
+ }
+ if (other.getWellSn() != 0) {
+ setWellSn(other.getWellSn());
+ }
+ if (!other.getCcdSn().isEmpty()) {
+ ccdSn_ = other.ccdSn_;
+ bitField0_ |= 0x00000008;
+ onChanged();
+ }
+ if (!other.getSourceImageName().isEmpty()) {
+ sourceImageName_ = other.sourceImageName_;
+ bitField0_ |= 0x00000010;
+ onChanged();
+ }
+ if (!other.getSourceImagePath().isEmpty()) {
+ sourceImagePath_ = other.sourceImagePath_;
+ bitField0_ |= 0x00000020;
+ onChanged();
+ }
+ if (other.getSourceImageWidth() != 0) {
+ setSourceImageWidth(other.getSourceImageWidth());
+ }
+ if (other.getSourceImageHeight() != 0) {
+ setSourceImageHeight(other.getSourceImageHeight());
+ }
+ if (!other.getImageTime().isEmpty()) {
+ imageTime_ = other.imageTime_;
+ bitField0_ |= 0x00000100;
+ onChanged();
+ }
+ if (!other.getFertilizationTime().isEmpty()) {
+ fertilizationTime_ = other.fertilizationTime_;
+ bitField0_ |= 0x00000200;
+ onChanged();
+ }
+ if (other.getPhotographType() != 0) {
+ setPhotographType(other.getPhotographType());
+ }
+ if (other.getTotalLayer() != 0) {
+ setTotalLayer(other.getTotalLayer());
+ }
+ if (other.getPictureLayer() != 0) {
+ setPictureLayer(other.getPictureLayer());
+ }
+ if (other.getShootingPosition() != 0) {
+ setShootingPosition(other.getShootingPosition());
+ }
+ if (other.getClearest() != 0) {
+ setClearest(other.getClearest());
+ }
+ if (other.getEnd() != 0) {
+ setEnd(other.getEnd());
+ }
+ if (other.getEmbryoCultureRecordId() != 0L) {
+ setEmbryoCultureRecordId(other.getEmbryoCultureRecordId());
+ }
+ if (other.getEmbryoId() != 0L) {
+ setEmbryoId(other.getEmbryoId());
+ }
+ if (other.getImageData() != com.google.protobuf.ByteString.EMPTY) {
+ setImageData(other.getImageData());
+ }
+ if (other.getHorizontalPosition() != 0) {
+ setHorizontalPosition(other.getHorizontalPosition());
+ }
+ this.mergeUnknownFields(other.getUnknownFields());
+ onChanged();
+ return this;
+ }
+
+ @Override
+ public final boolean isInitialized() {
+ return true;
+ }
+
+ @Override
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ if (extensionRegistry == null) {
+ throw new NullPointerException();
+ }
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ case 10: {
+ tlSn_ = input.readStringRequireUtf8();
+ bitField0_ |= 0x00000001;
+ break;
+ } // case 10
+ case 16: {
+ houseSn_ = input.readInt32();
+ bitField0_ |= 0x00000002;
+ break;
+ } // case 16
+ case 24: {
+ wellSn_ = input.readInt32();
+ bitField0_ |= 0x00000004;
+ break;
+ } // case 24
+ case 34: {
+ ccdSn_ = input.readStringRequireUtf8();
+ bitField0_ |= 0x00000008;
+ break;
+ } // case 34
+ case 42: {
+ sourceImageName_ = input.readStringRequireUtf8();
+ bitField0_ |= 0x00000010;
+ break;
+ } // case 42
+ case 50: {
+ sourceImagePath_ = input.readStringRequireUtf8();
+ bitField0_ |= 0x00000020;
+ break;
+ } // case 50
+ case 56: {
+ sourceImageWidth_ = input.readInt32();
+ bitField0_ |= 0x00000040;
+ break;
+ } // case 56
+ case 64: {
+ sourceImageHeight_ = input.readInt32();
+ bitField0_ |= 0x00000080;
+ break;
+ } // case 64
+ case 74: {
+ imageTime_ = input.readStringRequireUtf8();
+ bitField0_ |= 0x00000100;
+ break;
+ } // case 74
+ case 82: {
+ fertilizationTime_ = input.readStringRequireUtf8();
+ bitField0_ |= 0x00000200;
+ break;
+ } // case 82
+ case 88: {
+ photographType_ = input.readInt32();
+ bitField0_ |= 0x00000400;
+ break;
+ } // case 88
+ case 96: {
+ totalLayer_ = input.readInt32();
+ bitField0_ |= 0x00000800;
+ break;
+ } // case 96
+ case 104: {
+ pictureLayer_ = input.readInt32();
+ bitField0_ |= 0x00001000;
+ break;
+ } // case 104
+ case 112: {
+ shootingPosition_ = input.readInt32();
+ bitField0_ |= 0x00002000;
+ break;
+ } // case 112
+ case 120: {
+ clearest_ = input.readInt32();
+ bitField0_ |= 0x00004000;
+ break;
+ } // case 120
+ case 128: {
+ end_ = input.readInt32();
+ bitField0_ |= 0x00008000;
+ break;
+ } // case 128
+ case 136: {
+ embryoCultureRecordId_ = input.readUInt64();
+ bitField0_ |= 0x00010000;
+ break;
+ } // case 136
+ case 144: {
+ embryoId_ = input.readUInt64();
+ bitField0_ |= 0x00020000;
+ break;
+ } // case 144
+ case 154: {
+ imageData_ = input.readBytes();
+ bitField0_ |= 0x00040000;
+ break;
+ } // case 154
+ case 160: {
+ horizontalPosition_ = input.readInt32();
+ bitField0_ |= 0x00080000;
+ break;
+ } // case 160
+ default: {
+ if (!super.parseUnknownField(input, extensionRegistry, tag)) {
+ done = true; // was an endgroup tag
+ }
+ break;
+ } // default:
+ } // switch (tag)
+ } // while (!done)
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw e.unwrapIOException();
+ } finally {
+ onChanged();
+ } // finally
+ return this;
+ }
+
+ private int bitField0_;
+
+ private Object tlSn_ = "";
+
+ /**
+ *
+ * *
+ * tl设备编号
+ *
+ *
+ * string tlSn = 1;
+ *
+ * @return The tlSn.
+ */
+ public String getTlSn() {
+ Object ref = tlSn_;
+ if (!(ref instanceof String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ tlSn_ = s;
+ return s;
+ } else {
+ return (String) ref;
+ }
+ }
+
+ /**
+ *
+ * *
+ * tl设备编号
+ *
+ *
+ * string tlSn = 1;
+ *
+ * @return The bytes for tlSn.
+ */
+ public com.google.protobuf.ByteString
+ getTlSnBytes() {
+ Object ref = tlSn_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ tlSn_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ /**
+ *
+ * *
+ * tl设备编号
+ *
+ *
+ * string tlSn = 1;
+ *
+ * @param value The tlSn to set.
+ * @return This builder for chaining.
+ */
+ public Builder setTlSn(
+ String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ tlSn_ = value;
+ bitField0_ |= 0x00000001;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * tl设备编号
+ *
+ *
+ * string tlSn = 1;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearTlSn() {
+ tlSn_ = getDefaultInstance().getTlSn();
+ bitField0_ = (bitField0_ & ~0x00000001);
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * tl设备编号
+ *
+ *
+ * string tlSn = 1;
+ *
+ * @param value The bytes for tlSn to set.
+ * @return This builder for chaining.
+ */
+ public Builder setTlSnBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+ tlSn_ = value;
+ bitField0_ |= 0x00000001;
+ onChanged();
+ return this;
+ }
+
+ private int houseSn_;
+
+ /**
+ *
+ * *
+ * 仓室编号:1-10
+ *
+ *
+ * int32 houseSn = 2;
+ *
+ * @return The houseSn.
+ */
+ @Override
+ public int getHouseSn() {
+ return houseSn_;
+ }
+
+ /**
+ *
+ * *
+ * 仓室编号:1-10
+ *
+ *
+ * int32 houseSn = 2;
+ *
+ * @param value The houseSn to set.
+ * @return This builder for chaining.
+ */
+ public Builder setHouseSn(int value) {
+
+ houseSn_ = value;
+ bitField0_ |= 0x00000002;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 仓室编号:1-10
+ *
+ *
+ * int32 houseSn = 2;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearHouseSn() {
+ bitField0_ = (bitField0_ & ~0x00000002);
+ houseSn_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private int wellSn_;
+
+ /**
+ *
+ * *
+ * well编号 1-16
+ *
+ *
+ * int32 wellSn = 3;
+ *
+ * @return The wellSn.
+ */
+ @Override
+ public int getWellSn() {
+ return wellSn_;
+ }
+
+ /**
+ *
+ * *
+ * well编号 1-16
+ *
+ *
+ * int32 wellSn = 3;
+ *
+ * @param value The wellSn to set.
+ * @return This builder for chaining.
+ */
+ public Builder setWellSn(int value) {
+
+ wellSn_ = value;
+ bitField0_ |= 0x00000004;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * well编号 1-16
+ *
+ *
+ * int32 wellSn = 3;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearWellSn() {
+ bitField0_ = (bitField0_ & ~0x00000004);
+ wellSn_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private Object ccdSn_ = "";
+
+ /**
+ *
+ * *
+ * ccd编号
+ *
+ *
+ * string ccdSn = 4;
+ *
+ * @return The ccdSn.
+ */
+ public String getCcdSn() {
+ Object ref = ccdSn_;
+ if (!(ref instanceof String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ ccdSn_ = s;
+ return s;
+ } else {
+ return (String) ref;
+ }
+ }
+
+ /**
+ *
+ * *
+ * ccd编号
+ *
+ *
+ * string ccdSn = 4;
+ *
+ * @return The bytes for ccdSn.
+ */
+ public com.google.protobuf.ByteString
+ getCcdSnBytes() {
+ Object ref = ccdSn_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ ccdSn_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ /**
+ *
+ * *
+ * ccd编号
+ *
+ *
+ * string ccdSn = 4;
+ *
+ * @param value The ccdSn to set.
+ * @return This builder for chaining.
+ */
+ public Builder setCcdSn(
+ String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ccdSn_ = value;
+ bitField0_ |= 0x00000008;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * ccd编号
+ *
+ *
+ * string ccdSn = 4;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearCcdSn() {
+ ccdSn_ = getDefaultInstance().getCcdSn();
+ bitField0_ = (bitField0_ & ~0x00000008);
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * ccd编号
+ *
+ *
+ * string ccdSn = 4;
+ *
+ * @param value The bytes for ccdSn to set.
+ * @return This builder for chaining.
+ */
+ public Builder setCcdSnBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+ ccdSn_ = value;
+ bitField0_ |= 0x00000008;
+ onChanged();
+ return this;
+ }
+
+ private Object sourceImageName_ = "";
+
+ /**
+ *
+ * *
+ * 原图名字
+ *
+ *
+ * string sourceImageName = 5;
+ *
+ * @return The sourceImageName.
+ */
+ public String getSourceImageName() {
+ Object ref = sourceImageName_;
+ if (!(ref instanceof String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ sourceImageName_ = s;
+ return s;
+ } else {
+ return (String) ref;
+ }
+ }
+
+ /**
+ *
+ * *
+ * 原图名字
+ *
+ *
+ * string sourceImageName = 5;
+ *
+ * @return The bytes for sourceImageName.
+ */
+ public com.google.protobuf.ByteString
+ getSourceImageNameBytes() {
+ Object ref = sourceImageName_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ sourceImageName_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ /**
+ *
+ * *
+ * 原图名字
+ *
+ *
+ * string sourceImageName = 5;
+ *
+ * @param value The sourceImageName to set.
+ * @return This builder for chaining.
+ */
+ public Builder setSourceImageName(
+ String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ sourceImageName_ = value;
+ bitField0_ |= 0x00000010;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 原图名字
+ *
+ *
+ * string sourceImageName = 5;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearSourceImageName() {
+ sourceImageName_ = getDefaultInstance().getSourceImageName();
+ bitField0_ = (bitField0_ & ~0x00000010);
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 原图名字
+ *
+ *
+ * string sourceImageName = 5;
+ *
+ * @param value The bytes for sourceImageName to set.
+ * @return This builder for chaining.
+ */
+ public Builder setSourceImageNameBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+ sourceImageName_ = value;
+ bitField0_ |= 0x00000010;
+ onChanged();
+ return this;
+ }
+
+ private Object sourceImagePath_ = "";
+
+ /**
+ *
+ * *
+ * 原图的本地路径(不是上传后的保存路径)
+ *
+ *
+ * string sourceImagePath = 6;
+ *
+ * @return The sourceImagePath.
+ */
+ public String getSourceImagePath() {
+ Object ref = sourceImagePath_;
+ if (!(ref instanceof String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ sourceImagePath_ = s;
+ return s;
+ } else {
+ return (String) ref;
+ }
+ }
+
+ /**
+ *
+ * *
+ * 原图的本地路径(不是上传后的保存路径)
+ *
+ *
+ * string sourceImagePath = 6;
+ *
+ * @return The bytes for sourceImagePath.
+ */
+ public com.google.protobuf.ByteString
+ getSourceImagePathBytes() {
+ Object ref = sourceImagePath_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ sourceImagePath_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ /**
+ *
+ * *
+ * 原图的本地路径(不是上传后的保存路径)
+ *
+ *
+ * string sourceImagePath = 6;
+ *
+ * @param value The sourceImagePath to set.
+ * @return This builder for chaining.
+ */
+ public Builder setSourceImagePath(
+ String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ sourceImagePath_ = value;
+ bitField0_ |= 0x00000020;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 原图的本地路径(不是上传后的保存路径)
+ *
+ *
+ * string sourceImagePath = 6;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearSourceImagePath() {
+ sourceImagePath_ = getDefaultInstance().getSourceImagePath();
+ bitField0_ = (bitField0_ & ~0x00000020);
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 原图的本地路径(不是上传后的保存路径)
+ *
+ *
+ * string sourceImagePath = 6;
+ *
+ * @param value The bytes for sourceImagePath to set.
+ * @return This builder for chaining.
+ */
+ public Builder setSourceImagePathBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+ sourceImagePath_ = value;
+ bitField0_ |= 0x00000020;
+ onChanged();
+ return this;
+ }
+
+ private int sourceImageWidth_;
+
+ /**
+ *
+ * *
+ * 原图宽
+ *
+ *
+ * int32 sourceImageWidth = 7;
+ *
+ * @return The sourceImageWidth.
+ */
+ @Override
+ public int getSourceImageWidth() {
+ return sourceImageWidth_;
+ }
+
+ /**
+ *
+ * *
+ * 原图宽
+ *
+ *
+ * int32 sourceImageWidth = 7;
+ *
+ * @param value The sourceImageWidth to set.
+ * @return This builder for chaining.
+ */
+ public Builder setSourceImageWidth(int value) {
+
+ sourceImageWidth_ = value;
+ bitField0_ |= 0x00000040;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 原图宽
+ *
+ *
+ * int32 sourceImageWidth = 7;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearSourceImageWidth() {
+ bitField0_ = (bitField0_ & ~0x00000040);
+ sourceImageWidth_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private int sourceImageHeight_;
+
+ /**
+ *
+ * *
+ * 原图高
+ *
+ *
+ * int32 sourceImageHeight = 8;
+ *
+ * @return The sourceImageHeight.
+ */
+ @Override
+ public int getSourceImageHeight() {
+ return sourceImageHeight_;
+ }
+
+ /**
+ *
+ * *
+ * 原图高
+ *
+ *
+ * int32 sourceImageHeight = 8;
+ *
+ * @param value The sourceImageHeight to set.
+ * @return This builder for chaining.
+ */
+ public Builder setSourceImageHeight(int value) {
+
+ sourceImageHeight_ = value;
+ bitField0_ |= 0x00000080;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 原图高
+ *
+ *
+ * int32 sourceImageHeight = 8;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearSourceImageHeight() {
+ bitField0_ = (bitField0_ & ~0x00000080);
+ sourceImageHeight_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private Object imageTime_ = "";
+
+ /**
+ *
+ * *
+ * 设备拍摄时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string imageTime = 9;
+ *
+ * @return The imageTime.
+ */
+ public String getImageTime() {
+ Object ref = imageTime_;
+ if (!(ref instanceof String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ imageTime_ = s;
+ return s;
+ } else {
+ return (String) ref;
+ }
+ }
+
+ /**
+ *
+ * *
+ * 设备拍摄时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string imageTime = 9;
+ *
+ * @return The bytes for imageTime.
+ */
+ public com.google.protobuf.ByteString
+ getImageTimeBytes() {
+ Object ref = imageTime_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ imageTime_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ /**
+ *
+ * *
+ * 设备拍摄时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string imageTime = 9;
+ *
+ * @param value The imageTime to set.
+ * @return This builder for chaining.
+ */
+ public Builder setImageTime(
+ String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ imageTime_ = value;
+ bitField0_ |= 0x00000100;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 设备拍摄时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string imageTime = 9;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearImageTime() {
+ imageTime_ = getDefaultInstance().getImageTime();
+ bitField0_ = (bitField0_ & ~0x00000100);
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 设备拍摄时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string imageTime = 9;
+ *
+ * @param value The bytes for imageTime to set.
+ * @return This builder for chaining.
+ */
+ public Builder setImageTimeBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+ imageTime_ = value;
+ bitField0_ |= 0x00000100;
+ onChanged();
+ return this;
+ }
+
+ private Object fertilizationTime_ = "";
+
+ /**
+ *
+ * *
+ * 受精时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string fertilizationTime = 10;
+ *
+ * @return The fertilizationTime.
+ */
+ public String getFertilizationTime() {
+ Object ref = fertilizationTime_;
+ if (!(ref instanceof String)) {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ String s = bs.toStringUtf8();
+ fertilizationTime_ = s;
+ return s;
+ } else {
+ return (String) ref;
+ }
+ }
+
+ /**
+ *
+ * *
+ * 受精时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string fertilizationTime = 10;
+ *
+ * @return The bytes for fertilizationTime.
+ */
+ public com.google.protobuf.ByteString
+ getFertilizationTimeBytes() {
+ Object ref = fertilizationTime_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (String) ref);
+ fertilizationTime_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+
+ /**
+ *
+ * *
+ * 受精时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string fertilizationTime = 10;
+ *
+ * @param value The fertilizationTime to set.
+ * @return This builder for chaining.
+ */
+ public Builder setFertilizationTime(
+ String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ fertilizationTime_ = value;
+ bitField0_ |= 0x00000200;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 受精时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string fertilizationTime = 10;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearFertilizationTime() {
+ fertilizationTime_ = getDefaultInstance().getFertilizationTime();
+ bitField0_ = (bitField0_ & ~0x00000200);
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 受精时间 格式2020-10-10 00:00:00
+ *
+ *
+ * string fertilizationTime = 10;
+ *
+ * @param value The bytes for fertilizationTime to set.
+ * @return This builder for chaining.
+ */
+ public Builder setFertilizationTimeBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ checkByteStringIsUtf8(value);
+ fertilizationTime_ = value;
+ bitField0_ |= 0x00000200;
+ onChanged();
+ return this;
+ }
+
+ private int photographType_;
+
+ /**
+ *
+ * *
+ * 对焦还是ccd拍照 1 自动对焦 0 CCD拍照
+ *
+ *
+ * int32 photographType = 11;
+ *
+ * @return The photographType.
+ */
+ @Override
+ public int getPhotographType() {
+ return photographType_;
+ }
+
+ /**
+ *
+ * *
+ * 对焦还是ccd拍照 1 自动对焦 0 CCD拍照
+ *
+ *
+ * int32 photographType = 11;
+ *
+ * @param value The photographType to set.
+ * @return This builder for chaining.
+ */
+ public Builder setPhotographType(int value) {
+
+ photographType_ = value;
+ bitField0_ |= 0x00000400;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 对焦还是ccd拍照 1 自动对焦 0 CCD拍照
+ *
+ *
+ * int32 photographType = 11;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearPhotographType() {
+ bitField0_ = (bitField0_ & ~0x00000400);
+ photographType_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private int totalLayer_;
+
+ /**
+ *
+ * *
+ * 拍照总层数
+ *
+ *
+ * int32 totalLayer = 12;
+ *
+ * @return The totalLayer.
+ */
+ @Override
+ public int getTotalLayer() {
+ return totalLayer_;
+ }
+
+ /**
+ *
+ * *
+ * 拍照总层数
+ *
+ *
+ * int32 totalLayer = 12;
+ *
+ * @param value The totalLayer to set.
+ * @return This builder for chaining.
+ */
+ public Builder setTotalLayer(int value) {
+
+ totalLayer_ = value;
+ bitField0_ |= 0x00000800;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 拍照总层数
+ *
+ *
+ * int32 totalLayer = 12;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearTotalLayer() {
+ bitField0_ = (bitField0_ & ~0x00000800);
+ totalLayer_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private int pictureLayer_;
+
+ /**
+ *
+ * *
+ * 图片层
+ *
+ *
+ * int32 pictureLayer = 13;
+ *
+ * @return The pictureLayer.
+ */
+ @Override
+ public int getPictureLayer() {
+ return pictureLayer_;
+ }
+
+ /**
+ *
+ * *
+ * 图片层
+ *
+ *
+ * int32 pictureLayer = 13;
+ *
+ * @param value The pictureLayer to set.
+ * @return This builder for chaining.
+ */
+ public Builder setPictureLayer(int value) {
+
+ pictureLayer_ = value;
+ bitField0_ |= 0x00001000;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 图片层
+ *
+ *
+ * int32 pictureLayer = 13;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearPictureLayer() {
+ bitField0_ = (bitField0_ & ~0x00001000);
+ pictureLayer_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private int shootingPosition_;
+
+ /**
+ *
+ * *
+ * 垂直电机位置
+ *
+ *
+ * int32 shootingPosition = 14;
+ *
+ * @return The shootingPosition.
+ */
+ @Override
+ public int getShootingPosition() {
+ return shootingPosition_;
+ }
+
+ /**
+ *
+ * *
+ * 垂直电机位置
+ *
+ *
+ * int32 shootingPosition = 14;
+ *
+ * @param value The shootingPosition to set.
+ * @return This builder for chaining.
+ */
+ public Builder setShootingPosition(int value) {
+
+ shootingPosition_ = value;
+ bitField0_ |= 0x00002000;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 垂直电机位置
+ *
+ *
+ * int32 shootingPosition = 14;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearShootingPosition() {
+ bitField0_ = (bitField0_ & ~0x00002000);
+ shootingPosition_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private int clearest_;
+
+ /**
+ *
+ * *
+ * 是否是最清晰的(CCD拍照才有)0不是 1最清晰
+ *
+ *
+ * int32 clearest = 15;
+ *
+ * @return The clearest.
+ */
+ @Override
+ public int getClearest() {
+ return clearest_;
+ }
+
+ /**
+ *
+ * *
+ * 是否是最清晰的(CCD拍照才有)0不是 1最清晰
+ *
+ *
+ * int32 clearest = 15;
+ *
+ * @param value The clearest to set.
+ * @return This builder for chaining.
+ */
+ public Builder setClearest(int value) {
+
+ clearest_ = value;
+ bitField0_ |= 0x00004000;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 是否是最清晰的(CCD拍照才有)0不是 1最清晰
+ *
+ *
+ * int32 clearest = 15;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearClearest() {
+ bitField0_ = (bitField0_ & ~0x00004000);
+ clearest_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private int end_;
+
+ /**
+ *
+ * *
+ * 拍照结束标记 1 结束 0 未结束 (结束后开始更新对焦起点,ccd拍照结束开始合成视频)
+ *
+ *
+ * int32 end = 16;
+ *
+ * @return The end.
+ */
+ @Override
+ public int getEnd() {
+ return end_;
+ }
+
+ /**
+ *
+ * *
+ * 拍照结束标记 1 结束 0 未结束 (结束后开始更新对焦起点,ccd拍照结束开始合成视频)
+ *
+ *
+ * int32 end = 16;
+ *
+ * @param value The end to set.
+ * @return This builder for chaining.
+ */
+ public Builder setEnd(int value) {
+
+ end_ = value;
+ bitField0_ |= 0x00008000;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 拍照结束标记 1 结束 0 未结束 (结束后开始更新对焦起点,ccd拍照结束开始合成视频)
+ *
+ *
+ * int32 end = 16;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearEnd() {
+ bitField0_ = (bitField0_ & ~0x00008000);
+ end_ = 0;
+ onChanged();
+ return this;
+ }
+
+ private long embryoCultureRecordId_;
+
+ /**
+ *
+ * *
+ * 培养记录id
+ *
+ *
+ * uint64 embryoCultureRecordId = 17;
+ *
+ * @return The embryoCultureRecordId.
+ */
+ @Override
+ public long getEmbryoCultureRecordId() {
+ return embryoCultureRecordId_;
+ }
+
+ /**
+ *
+ * *
+ * 培养记录id
+ *
+ *
+ * uint64 embryoCultureRecordId = 17;
+ *
+ * @param value The embryoCultureRecordId to set.
+ * @return This builder for chaining.
+ */
+ public Builder setEmbryoCultureRecordId(long value) {
+
+ embryoCultureRecordId_ = value;
+ bitField0_ |= 0x00010000;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 培养记录id
+ *
+ *
+ * uint64 embryoCultureRecordId = 17;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearEmbryoCultureRecordId() {
+ bitField0_ = (bitField0_ & ~0x00010000);
+ embryoCultureRecordId_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ private long embryoId_;
+
+ /**
+ *
+ * *
+ * 胚胎id
+ *
+ *
+ * uint64 embryoId = 18;
+ *
+ * @return The embryoId.
+ */
+ @Override
+ public long getEmbryoId() {
+ return embryoId_;
+ }
+
+ /**
+ *
+ * *
+ * 胚胎id
+ *
+ *
+ * uint64 embryoId = 18;
+ *
+ * @param value The embryoId to set.
+ * @return This builder for chaining.
+ */
+ public Builder setEmbryoId(long value) {
+
+ embryoId_ = value;
+ bitField0_ |= 0x00020000;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 胚胎id
+ *
+ *
+ * uint64 embryoId = 18;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearEmbryoId() {
+ bitField0_ = (bitField0_ & ~0x00020000);
+ embryoId_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ private com.google.protobuf.ByteString imageData_ = com.google.protobuf.ByteString.EMPTY;
+
+ /**
+ *
+ * *
+ * 图片数据
+ *
+ *
+ * bytes imageData = 19;
+ *
+ * @return The imageData.
+ */
+ @Override
+ public com.google.protobuf.ByteString getImageData() {
+ return imageData_;
+ }
+
+ /**
+ *
+ * *
+ * 图片数据
+ *
+ *
+ * bytes imageData = 19;
+ *
+ * @param value The imageData to set.
+ * @return This builder for chaining.
+ */
+ public Builder setImageData(com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ imageData_ = value;
+ bitField0_ |= 0x00040000;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 图片数据
+ *
+ *
+ * bytes imageData = 19;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearImageData() {
+ bitField0_ = (bitField0_ & ~0x00040000);
+ imageData_ = getDefaultInstance().getImageData();
+ onChanged();
+ return this;
+ }
+
+ private int horizontalPosition_;
+
+ /**
+ *
+ * *
+ * 水平电机位置
+ *
+ *
+ * int32 horizontalPosition = 20;
+ *
+ * @return The horizontalPosition.
+ */
+ @Override
+ public int getHorizontalPosition() {
+ return horizontalPosition_;
+ }
+
+ /**
+ *
+ * *
+ * 水平电机位置
+ *
+ *
+ * int32 horizontalPosition = 20;
+ *
+ * @param value The horizontalPosition to set.
+ * @return This builder for chaining.
+ */
+ public Builder setHorizontalPosition(int value) {
+
+ horizontalPosition_ = value;
+ bitField0_ |= 0x00080000;
+ onChanged();
+ return this;
+ }
+
+ /**
+ *
+ * *
+ * 水平电机位置
+ *
+ *
+ * int32 horizontalPosition = 20;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearHorizontalPosition() {
+ bitField0_ = (bitField0_ & ~0x00080000);
+ horizontalPosition_ = 0;
+ onChanged();
+ return this;
+ }
+
+ @Override
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.setUnknownFields(unknownFields);
+ }
+
+ @Override
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.mergeUnknownFields(unknownFields);
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:ivf_tl_Entity.DTO.ImageDTO)
+ }
+
+ // @@protoc_insertion_point(class_scope:ivf_tl_Entity.DTO.ImageDTO)
+ private static final ImageDTO DEFAULT_INSTANCE;
+
+ static {
+ DEFAULT_INSTANCE = new ImageDTO();
+ }
+
+ public static ImageDTO getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser
+ PARSER = new com.google.protobuf.AbstractParser() {
+ @Override
+ public ImageDTO parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ Builder builder = newBuilder();
+ try {
+ builder.mergeFrom(input, extensionRegistry);
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw e.setUnfinishedMessage(builder.buildPartial());
+ } catch (com.google.protobuf.UninitializedMessageException e) {
+ throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
+ } catch (java.io.IOException e) {
+ throw new com.google.protobuf.InvalidProtocolBufferException(e)
+ .setUnfinishedMessage(builder.buildPartial());
+ }
+ return builder.buildPartial();
+ }
+ };
+
+ public static com.google.protobuf.Parser parser() {
+ return PARSER;
+ }
+
+ @Override
+ public com.google.protobuf.Parser getParserForType() {
+ return PARSER;
+ }
+
+ @Override
+ public ImageDTO getDefaultInstanceForType() {
+ return DEFAULT_INSTANCE;
+ }
+
+ }
+
+ private static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_ivf_tl_Entity_DTO_ImageDTO_descriptor;
+ private static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_ivf_tl_Entity_DTO_ImageDTO_fieldAccessorTable;
+
+ public static com.google.protobuf.Descriptors.FileDescriptor
+ getDescriptor() {
+ return descriptor;
+ }
+
+ private static final com.google.protobuf.Descriptors.FileDescriptor
+ descriptor;
+
+ static {
+ String[] descriptorData = {
+ "\n\016ImageDTO.proto\022\021ivf_tl_Entity.DTO\"\270\003\n\010" +
+ "ImageDTO\022\014\n\004tlSn\030\001 \001(\t\022\017\n\007houseSn\030\002 \001(\005\022" +
+ "\016\n\006wellSn\030\003 \001(\005\022\r\n\005ccdSn\030\004 \001(\t\022\027\n\017source" +
+ "ImageName\030\005 \001(\t\022\027\n\017sourceImagePath\030\006 \001(\t" +
+ "\022\030\n\020sourceImageWidth\030\007 \001(\005\022\031\n\021sourceImag" +
+ "eHeight\030\010 \001(\005\022\021\n\timageTime\030\t \001(\t\022\031\n\021fert" +
+ "ilizationTime\030\n \001(\t\022\026\n\016photographType\030\013 " +
+ "\001(\005\022\022\n\ntotalLayer\030\014 \001(\005\022\024\n\014pictureLayer\030" +
+ "\r \001(\005\022\030\n\020shootingPosition\030\016 \001(\005\022\020\n\010clear" +
+ "est\030\017 \001(\005\022\013\n\003end\030\020 \001(\005\022\035\n\025embryoCultureR" +
+ "ecordId\030\021 \001(\004\022\020\n\010embryoId\030\022 \001(\004\022\021\n\timage" +
+ "Data\030\023 \001(\014\022\032\n\022horizontalPosition\030\024 \001(\005B6" +
+ "\n&com.aivfo.data.transmission.entity.dto" +
+ "B\014ImageDataDTOb\006proto3"
+ };
+ descriptor = com.google.protobuf.Descriptors.FileDescriptor
+ .internalBuildGeneratedFileFrom(descriptorData,
+ new com.google.protobuf.Descriptors.FileDescriptor[]{
+ });
+ internal_static_ivf_tl_Entity_DTO_ImageDTO_descriptor =
+ getDescriptor().getMessageTypes().get(0);
+ internal_static_ivf_tl_Entity_DTO_ImageDTO_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_ivf_tl_Entity_DTO_ImageDTO_descriptor,
+ new String[]{"TlSn", "HouseSn", "WellSn", "CcdSn", "SourceImageName", "SourceImagePath", "SourceImageWidth", "SourceImageHeight", "ImageTime", "FertilizationTime", "PhotographType", "TotalLayer", "PictureLayer", "ShootingPosition", "Clearest", "End", "EmbryoCultureRecordId", "EmbryoId", "ImageData", "HorizontalPosition",});
+ }
+
+ // @@protoc_insertion_point(outer_class_scope)
+}
diff --git a/kafka/src/test/java/com/wyl/kafka/test/TlPictureProducerTest.java b/kafka/src/test/java/com/wyl/kafka/test/TlPictureProducerTest.java
index 29e9569..b8fbbff 100644
--- a/kafka/src/test/java/com/wyl/kafka/test/TlPictureProducerTest.java
+++ b/kafka/src/test/java/com/wyl/kafka/test/TlPictureProducerTest.java
@@ -25,7 +25,7 @@ public class TlPictureProducerTest {
* 构建kafka 生产者
*/
KafkaProducer kafkaProducer = buildProducer();
- String topic = "CCD-PICTURE-NEO-1-wyltest";
+ String topic = "CCD-PICTURE-NEO-1-20230101";
AtomicReference partition = new AtomicReference<>(0);
LocalDateTime now = LocalDateTime.now();
String format = now.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
@@ -38,7 +38,8 @@ public class TlPictureProducerTest {
if (i == 80) {
end = 1;
}
- ImageDataDTO.ImageDTO image = makeSendData(null, embryo.getHouseSn(), id.getKey(), 1, format, embryo.getFertilizationTime(), i, shootingPosition * (125 + i), end, id.getValue(), embryo.getId());
+ ImageDataDTO.ImageDTO image = makeSendData(null, embryo.getHouseSn(), id.getKey(), 1, format, embryo.getFertilizationTime(), i, shootingPosition * (125 + i), end, embryo.getId(), id.getValue());
+ System.out.println(image.getImageData().size());
partition.set(image.getHouseSn() % 3);
ProducerRecord record = new ProducerRecord<>(topic, partition.get(), null, image.toByteArray());
/**
@@ -87,7 +88,7 @@ public class TlPictureProducerTest {
}
ImageDataDTO.ImageDTO image = makeSendData(c, embryo.getHouseSn(), id.getKey(), 0, format,
embryo.getFertilizationTime(), i, shootingPosition * (125 + i),
- end, id.getValue(), embryo.getId());
+ end, embryo.getId(), id.getValue());
partition.set(image.getHouseSn() % 3);
ProducerRecord record = new ProducerRecord<>(topic, partition.get(), null, image.toByteArray());
/**
@@ -134,8 +135,8 @@ public class TlPictureProducerTest {
* @Date 2023/7/18
* @Author wangyl
*/
- public static byte[] getImageData() throws IOException {
- File file = new File("C:\\Users\\95981\\Desktop\\wangyongliang.jpg");
+ private static byte[] getImageData() throws IOException {
+ File file = new File("C:\\Users\\95981\\Desktop\\picControlBreak1\\1_1_1_1_2023-09-25-17-37-08_66400_80200.jpg");
InputStream inputStream = new FileInputStream(file);
byte[] bytes = inputStream.readAllBytes();
return bytes;
diff --git a/mqtt/pom.xml b/mqtt/pom.xml
index da399f6..6ddb4cd 100644
--- a/mqtt/pom.xml
+++ b/mqtt/pom.xml
@@ -28,6 +28,11 @@
org.eclipse.paho.mqttv5.client
1.2.5