feat:我要赚米

pjcloud-integrated/pjcloud-integrated-api/src/main/java/com/bsd/pjcloud/integrated/api/feign/RemoteAdRecordService.java

@@ -0,0 +1,18 @@
+package com.bsd.pjcloud.integrated.api.feign;
+
+import com.bsd.pjcloud.common.core.constant.ServiceNameConstants;
+import com.bsd.pjcloud.common.core.util.R;
+import com.bsd.pjcloud.common.feign.annotation.NoToken;
+import com.bsd.pjcloud.integrated.dto.ad.AdRecordDto;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+@FeignClient(contextId = "remoteAdRecordService", value = ServiceNameConstants.INTEGRATED_SERVICE)
+public interface RemoteAdRecordService {
+
+    @NoToken
+    @PostMapping("/ad-record/remote/count")
+    R<Long> remoteCount(@RequestBody AdRecordDto dto);
+
+}

pjcloud-integrated/pjcloud-integrated-api/src/main/java/com/bsd/pjcloud/integrated/dto/ad/AdRecordDto.java

@@ -0,0 +1,20 @@
+package com.bsd.pjcloud.integrated.dto.ad;
+
+import com.bsd.pjcloud.integrated.entity.AdRecordEntity;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+/**
+ * @author liusiyang_dxm
+ * @since 2026/4/10
+ */
+@Data
+public class AdRecordDto extends AdRecordEntity {
+
+    private String integralNumNullStatus;
+
+    private LocalDateTime[] createTimeList;
+
+}
+

pjcloud-integrated/pjcloud-integrated-api/src/main/java/com/bsd/pjcloud/integrated/entity/AdRecordEntity.java

@@ -0,0 +1,143 @@
+package com.bsd.pjcloud.integrated.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import com.bsd.pjcloud.common.core.util.TenantTable;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.time.LocalDateTime;
+
+/**
+ * 广告记录
+ */
+@Data
+@TenantTable
+@TableName("ad_record")
+@EqualsAndHashCode(callSuper = true)
+@Schema(description = "广告记录")
+public class AdRecordEntity extends Model<AdRecordEntity> {
+
+    /**
+     * 主键
+     */
+    @TableId(type = IdType.ASSIGN_ID)
+    @Schema(description = "主键")
+    private Long id;
+
+    /**
+     * 观看广告用户id
+     */
+    @Schema(description = "观看广告用户id")
+    private Long userId;
+
+    /**
+     * 交易id
+     */
+    @Schema(description = "交易id")
+    private String transId;
+
+    /**
+     * 广告id
+     */
+    @Schema(description = "广告id")
+    private String adId;
+
+    /**
+     * 广告类型
+     */
+    @Schema(description = "广告类型")
+    private String adType;
+
+    /**
+     * 广告服务商
+     */
+    @Schema(description = "广告服务商")
+    private String adProvider;
+
+    /**
+     * 观看手机平台
+     */
+    @Schema(description = "观看手机平台")
+    private String visitPlatform;
+
+    /**
+     * 观看开始时间
+     */
+    @Schema(description = "观看开始时间")
+    private LocalDateTime visitStartTime;
+
+    /**
+     * 观看结束时间
+     */
+    @Schema(description = "观看结束时间")
+    private LocalDateTime visitEndTime;
+
+    /**
+     * 观看时长(秒)
+     */
+    @Schema(description = "观看时长(秒)")
+    private Integer visitDuration;
+
+    /**
+     * 观看状态
+     */
+    @Schema(description = "观看状态")
+    private String status;
+
+    /**
+     * 额外参数
+     */
+    @Schema(description = "额外参数")
+    private String extra;
+
+
+    /**
+     * 广告预计收入
+     */
+    @Schema(description = "广告预计收入")
+    private Integer adPredictPrice;
+
+    /**
+     * 创建人
+     */
+    @TableField(fill = FieldFill.INSERT)
+    @Schema(description = "创建人")
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    @TableField(fill = FieldFill.INSERT)
+    @Schema(description = "创建时间")
+    private LocalDateTime createTime;
+
+    /**
+     * 更新人
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    @Schema(description = "更新人")
+    private String updateBy;
+
+    /**
+     * 更新时间
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    @Schema(description = "更新时间")
+    private LocalDateTime updateTime;
+
+    /**
+     * 删除时间
+     */
+    @TableLogic
+    @TableField(fill = FieldFill.INSERT)
+    @Schema(description = "删除时间")
+    private String delFlag;
+
+    /**
+     * tenantId
+     */
+    @Schema(description = "tenantId")
+    private Long tenantId;
+}

pjcloud-integrated/pjcloud-integrated-api/src/main/java/com/bsd/pjcloud/integrated/vo/ad/AdRecordVo.java

@@ -0,0 +1,20 @@
+package com.bsd.pjcloud.integrated.vo.ad;
+
+import com.bsd.pjcloud.admin.api.vo.base.BaseUserDeptInterface;
+import com.bsd.pjcloud.integrated.entity.AdRecordEntity;
+import lombok.Data;
+
+
+@Data
+public class AdRecordVo extends AdRecordEntity implements BaseUserDeptInterface {
+
+    /**
+     * 用户相关
+     */
+    private String username;
+    private String userMobile;
+    private String userAvatar;
+    private Long userDeptId;
+    private String userDeptName;
+
+}