[新增功能](master): 新加一个土拨鼠AB单推送接口
parent
ba3e65c96b
commit
2a7212a6e9
@ -0,0 +1,31 @@
|
||||
package com.yuyou.openapi.openapi.dao;
|
||||
|
||||
import com.yuyou.openapi.openapi.model.dataobject.TuBoShuMessageDO;
|
||||
import org.springframework.data.jpa.repository.JpaRepository;
|
||||
import org.springframework.data.jpa.repository.Modifying;
|
||||
import org.springframework.data.jpa.repository.Query;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* Copyright (C), 2012 - 2018, qyx
|
||||
* FileName: LuoshiMessageRepository
|
||||
* Author: 钱昱欣
|
||||
* Date: 2020/10/22 2:52 PM
|
||||
* Description: TODO
|
||||
* History:
|
||||
* <author> <time> <version> <desc>
|
||||
* 钱昱欣 2020/10/22 v1.0 创建此文件
|
||||
*/
|
||||
@Repository
|
||||
public interface TuBoShuMessageRepository extends JpaRepository<TuBoShuMessageDO, Long>{
|
||||
@Modifying
|
||||
@Query("update TuBoShuMessageDO t set t.sendStatus = ?1 where t.recId = ?2")
|
||||
void updateSendStatus(Integer sendStatus, Long recId);
|
||||
|
||||
@Query("from TuBoShuMessageDO a where a.pushTime >= ?1 and a.pushTime < ?2 and a.sendStatus = ?3 ")
|
||||
List<TuBoShuMessageDO> findAllByPushTimeAndSendStatus(Date startPushTime, Date endPushTime, Integer sendStatus);
|
||||
}
|
||||
|
||||
@ -0,0 +1,81 @@
|
||||
package com.yuyou.openapi.openapi.model.dataobject;
|
||||
|
||||
import lombok.Data;
|
||||
import org.springframework.data.annotation.CreatedDate;
|
||||
import org.springframework.data.annotation.LastModifiedDate;
|
||||
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
|
||||
|
||||
import javax.persistence.*;
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* liehe AB表单数据层映射类
|
||||
* @version 1.0
|
||||
* @date 2020/8/6
|
||||
*/
|
||||
@Data
|
||||
@Table(name = "tuboshu_message")
|
||||
@Entity
|
||||
@EntityListeners(AuditingEntityListener.class)
|
||||
public class TuBoShuMessageDO {
|
||||
|
||||
@Id
|
||||
@GeneratedValue(strategy= GenerationType.IDENTITY)
|
||||
private Long id;
|
||||
|
||||
@Column(name = "gmt_create")
|
||||
@CreatedDate
|
||||
private Date gmtCreate;
|
||||
|
||||
@Column(name = "gmt_modified")
|
||||
@LastModifiedDate
|
||||
private Date gmtModified;
|
||||
|
||||
/**
|
||||
* 记录id
|
||||
*/
|
||||
@Column(name = "rec_id")
|
||||
private Long recId;
|
||||
|
||||
/**
|
||||
* 业务码
|
||||
*/
|
||||
@Column(name = "pnum")
|
||||
private String pnum;
|
||||
|
||||
/**
|
||||
* 业务名
|
||||
*/
|
||||
@Column(name = "act_name")
|
||||
private String actName;
|
||||
|
||||
/**
|
||||
* 业务开始时间
|
||||
*/
|
||||
@Column(name = "start_time")
|
||||
private Date startTime;
|
||||
|
||||
/**
|
||||
* 业务类别(1:A,2:B,3:C,4:D,5:E,6:F)
|
||||
*/
|
||||
@Column(name = "client_type")
|
||||
private Integer clientType;
|
||||
|
||||
/**
|
||||
* 上游推送用户id
|
||||
*/
|
||||
@Column(name = "app_id")
|
||||
private String appId;
|
||||
|
||||
/**
|
||||
* 上游推送时间
|
||||
*/
|
||||
@Column(name = "push_time")
|
||||
private Date pushTime;
|
||||
|
||||
/**
|
||||
* 默认值为0 是否处理过请求 0 - 未处理 1 - 处理过
|
||||
*/
|
||||
@Column(name = "send_status")
|
||||
private Integer sendStatus = 0;
|
||||
}
|
||||
@ -0,0 +1,26 @@
|
||||
package com.yuyou.openapi.openapi.model.pojo;
|
||||
|
||||
import com.alibaba.fastjson.annotation.JSONField;
|
||||
import com.fasterxml.jackson.annotation.JsonIgnore;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
|
||||
@Data
|
||||
@AllArgsConstructor
|
||||
@NoArgsConstructor
|
||||
public class TuBoShuDTO {
|
||||
|
||||
@JsonIgnore
|
||||
private String recId;
|
||||
|
||||
@JSONField(name = "mobile")
|
||||
private Long mobile;
|
||||
|
||||
@JSONField(name = "city")
|
||||
private String city;
|
||||
|
||||
@JSONField(name = "time")
|
||||
@JsonIgnore
|
||||
private Long time;
|
||||
}
|
||||
Loading…
Reference in New Issue