添加三方代码逻辑

src/main/java/com/baiyee/adcallback/api/dto/TripartiteDTO.java

@@ -11,21 +11,25 @@ public class TripartiteDTO {
 
     private String imei;
 
-    public TripartiteDTO(String imei, String oaid) {
-        this.imei = imei;
-        this.oaid = oaid;
-    }
 
     private String oaid;
 
 
-    private Integer sourceType;
+    private String pushType;
 
 
+    private Integer sourceType;
 
     public TripartiteDTO() {
     }
 
+    public TripartiteDTO(String imei, String oaid, String pushType, Integer sourceType) {
+        this.imei = imei;
+        this.oaid = oaid;
+        this.pushType = pushType;
+        this.sourceType = sourceType;
+    }
+
     public TripartiteDTO(String imei, String oaid, Integer sourceType) {
         this.imei = imei;
         this.oaid = oaid;

src/main/java/com/baiyee/adcallback/api/dto/TripartitePlatformDTO.java

@@ -15,4 +15,6 @@ public class TripartitePlatformDTO {
 
     private Integer type;
 
+    private String pushType;
+
 }

src/main/java/com/baiyee/adcallback/repository/TbJlTripartiteDataEntityRepository.java

@@ -26,7 +26,7 @@ public interface TbJlTripartiteDataEntityRepository extends BaseRepository<TbJlT
      * @param endDate
      * @return
      */
-    @Query("select new com.baiyee.adcallback.api.dto.TripartiteDTO(imei as imei,oaid as oaid, sourceType as sourceType) from " +
+    @Query("select new com.baiyee.adcallback.api.dto.TripartiteDTO(imei as imei,oaid as oaid,pushType as pushType , sourceType as sourceType) from " +
             " TbJlTripartiteDataEntity  where imei != :imeiStrFirst and imei != :imeiSecond  and gmtCreate >= :startDate and gmtCreate < :endDate")
     List<TripartiteDTO> queryPlateFormDTO(@Param("imeiStrFirst") String imeiStrFirst, @Param("imeiSecond") String imeiSecond, @Param("startDate") DateTime startDate, @Param("endDate") DateTime endDate);
 

src/main/java/com/baiyee/adcallback/repository/entity/TbJlTripartiteDataEntity.java

@@ -80,6 +80,11 @@ public class TbJlTripartiteDataEntity {
     @Column(name = "monit_type")
     private String monitType;
 
+    @Basic
+    @Column(name = "push_type")
+    private String pushType;
+
+
     @Basic
     @Column(name = "account_id")
     private Integer accountId;

src/main/java/com/baiyee/adcallback/service/impl/AdOriginalityManageServiceImpl.java

@@ -233,6 +233,7 @@ public class AdOriginalityManageServiceImpl implements AdOriginalityManageServic
         // 数据入库
         build.setSourceType(1);
         BeanUtil.copyProperties(dto, build);
+        build.setPushType(dto.getChannelCode());
         BeanUtil.copyProperties(dto, convertDTO);
         build.setOtherInfo(JSONUtil.toJsonStr(convertDTO));
         TbJlTripartiteDataEntity result = jlThirdDataEntityRepository.save(build);

src/main/java/com/baiyee/adcallback/service/impl/TripartiteServiceImpl.java

@@ -7,7 +7,6 @@ import com.baiyee.adcallback.service.TripartiteService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
-import java.time.OffsetDateTime;
 import java.util.List;
 
 /**

src/main/java/com/baiyee/adcallback/task/TripartiteRecordTask.java

@@ -69,13 +69,13 @@ public class TripartiteRecordTask {
                 if (StringUtils.isNotBlank(dto.getImei()) &&
                         !dto.getImei().equalsIgnoreCase(SpecialCheckParmConstant.ZERO_JL_IDFA)) {
                     TripartitePlatformDTO build =
-                            TripartitePlatformDTO.builder().type(0).nid(dto.getImei()).build();
+                            TripartitePlatformDTO.builder().type(0).nid(dto.getImei()).pushType(dto.getPushType()).build();
                     list.add(build);
                 }
                 if (StringUtils.isNotBlank(dto.getOaid()) &&
                         !dto.getOaid().equalsIgnoreCase(SpecialCheckParmConstant.ZERO_JL_IDFA)) {
                     TripartitePlatformDTO build =
-                            TripartitePlatformDTO.builder().type(1).nid(dto.getOaid()).build();
+                            TripartitePlatformDTO.builder().type(1).nid(dto.getOaid()).pushType(dto.getPushType()).build();
                     list.add(build);
                 }
             });