Commit f60f1a19 authored by shiyu's avatar shiyu

Merge branch 'qiandao_v1.0.1' into qiandao_v1.0

# Conflicts:
#	ch-dao/src/main/java/com/wwdz/ch/db/dao/qiandao/SignInTaskDao.java
#	ch-dao/src/main/java/com/wwdz/ch/db/impl/qiandao/SignInTaskDaoImpl.java
#	ch-wx-api/src/main/java/com/wwdz/ch/wx/impl/qiandao/SignInTaskServiceImpl.java
#	ch-wx-api/src/main/java/com/wwdz/ch/wx/service/qiandao/SignInTaskService.java
parents 77d8c97d 8c488527
package com.wwdz.ch.core.consts.qiandao;
import com.wwdz.ch.core.consts.AfterSaleEnum;
public class SignInTaskEnum {
/**
* 签到任务状态
*/
public enum StateEnum {
NOT_START(0, "未开始"),
PROCESSING(1, "进行中"),
END(2, "已结束"),
DELETED(-1, "已删除"),
;
private int code;
private String des;
StateEnum(int code, String des) {
this.code = code;
this.des = des;
}
public static String getNameByCode(int code) {
for (SignInTaskEnum.StateEnum stateEnum : SignInTaskEnum.StateEnum.values()) {
if (code == stateEnum.getCode()) {
return stateEnum.getDes();
}
}
return null;
}
public int getCode() {
return code;
}
public String getDes() {
return des;
}
}
/**
* 签到任务状态
*/
public enum TypeEnum {
CONTINUOUS(1, "连续签到任务"),
ACCUMULATE(2, "累计签到任务"),
;
private int code;
private String des;
TypeEnum(int code, String des) {
this.code = code;
this.des = des;
}
public static String getNameByCode(int code) {
for (SignInTaskEnum.TypeEnum typeEnum : SignInTaskEnum.TypeEnum.values()) {
if (code == typeEnum.getCode()) {
return typeEnum.getDes();
}
}
return null;
}
public int getCode() {
return code;
}
public String getDes() {
return des;
}
}
}
package com.wwdz.ch.db.dao.qiandao;
import com.wwdz.ch.db.domain.qiandao.QdUserSignIn;
import com.wwdz.ch.db.dto.request.qiandao.QdUserSignInRequestDto;
import java.util.List;
public interface QdUserSignInDao {
boolean insert(QdUserSignIn qdUserSignIn);
QdUserSignIn findLastedRecord(long userId);
List<QdUserSignIn> findList(QdUserSignInRequestDto dto);
/**
* 查询昨天的签到记录
* @param userId
* @return
*/
QdUserSignIn findYesterdayRecord(long userId);
QdUserSignIn findTodayRecord(long userId);
/**
* 判断某一日期是否签到过
* @param userId
* @param date
* @return
*/
boolean isExisted(long userId, String date);
QdUserSignIn findRecord(long userId, String date, Integer consecutiveDays);
boolean update(QdUserSignIn userSignin);
boolean updateByPrimaryKey(QdUserSignIn userSignin);
boolean deleteTodayRecord(long userId);
boolean updateInvalid(QdUserSignInRequestDto dto);
}
package com.wwdz.ch.db.dao.qiandao;
import com.wwdz.ch.db.domain.qiandao.QdUserSignInNote;
import com.wwdz.ch.db.dto.request.qiandao.QdUserSignInNoteRequestDto;
import java.util.List;
public interface QdUserSignInNoteDao {
boolean insert(QdUserSignInNote qdUserSignInNote);
List<QdUserSignInNote> findByPage(QdUserSignInNoteRequestDto dto);
}
package com.wwdz.ch.db.dao.qiandao; package com.wwdz.ch.db.dao.qiandao;
import com.wwdz.ch.db.domain.qiandao.SignInTask;
import com.wwdz.ch.db.dto.request.qiandao.SignInTaskRequestDto; import com.wwdz.ch.db.dto.request.qiandao.SignInTaskRequestDto;
public interface SignInTaskDao { import java.util.List;
int insert(SignInTaskRequestDto signInTaskRequestDto);
int delete(SignInTaskRequestDto signInTaskRequestDto);
public interface SignInTaskDao {
boolean insert(SignInTask signInTask);
List<SignInTask> findByPage(SignInTaskRequestDto dto);
} }
package com.wwdz.ch.db.domain.qiandao;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import com.xxdxxs.entity.Entity;
import lombok.Data;
/**
* @author shiyu
* @date 2024/12/19
*/
@Data
public class QdGiveLikeRecord implements Entity {
/**
* id
*/
private Long id;
/**
* 用户id
*/
private Long userId;
/**
* 笔记id
*/
private Long noteId;
/**
* 笔记创建人id
*/
private Long noteCreatorId;
/**
* 点赞时间
*/
private Date createTime;
/**
* 更新时间
*/
private Integer updateTime;
/**
* 是否有效
*/
private Boolean isValid;
private static final long serialVersionUID = 1L;
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append(getClass().getSimpleName());
sb.append(" [");
sb.append("Hash = ").append(hashCode());
sb.append(", id=").append(id);
sb.append(", userId=").append(userId);
sb.append(", noteId=").append(noteId);
sb.append(", noteCreatorId=").append(noteCreatorId);
sb.append(", createTime=").append(createTime);
sb.append(", updateTime=").append(updateTime);
sb.append(", isValid=").append(isValid);
sb.append(", serialVersionUID=").append(serialVersionUID);
sb.append("]");
return sb.toString();
}
@Override
public boolean equals(Object that) {
if (this == that) {
return true;
}
if (that == null) {
return false;
}
if (getClass() != that.getClass()) {
return false;
}
QdGiveLikeRecord other = (QdGiveLikeRecord) that;
return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
&& (this.getUserId() == null ? other.getUserId() == null : this.getUserId().equals(other.getUserId()))
&& (this.getNoteId() == null ? other.getNoteId() == null : this.getNoteId().equals(other.getNoteId()))
&& (this.getNoteCreatorId() == null ? other.getNoteCreatorId() == null : this.getNoteCreatorId().equals(other.getNoteCreatorId()))
&& (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
&& (this.getUpdateTime() == null ? other.getUpdateTime() == null : this.getUpdateTime().equals(other.getUpdateTime()))
&& (this.getIsValid() == null ? other.getIsValid() == null : this.getIsValid().equals(other.getIsValid()));
}
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
result = prime * result + ((getUserId() == null) ? 0 : getUserId().hashCode());
result = prime * result + ((getNoteId() == null) ? 0 : getNoteId().hashCode());
result = prime * result + ((getNoteCreatorId() == null) ? 0 : getNoteCreatorId().hashCode());
result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
result = prime * result + ((getUpdateTime() == null) ? 0 : getUpdateTime().hashCode());
result = prime * result + ((getIsValid() == null) ? 0 : getIsValid().hashCode());
return result;
}
/**
* This enum was generated by MyBatis Generator.
* This enum corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
public enum Column {
id("id", "id", "BIGINT", false),
userId("user_id", "userId", "BIGINT", false),
noteId("note_id", "noteId", "BIGINT", false),
noteCreatorId("note_creator_id", "noteCreatorId", "BIGINT", false),
createTime("create_time", "createTime", "TIMESTAMP", false),
updateTime("update_time", "updateTime", "INTEGER", false),
isValid("is_valid", "isValid", "BIT", false);
/**
* This field was generated by MyBatis Generator.
* This field corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
private static final String BEGINNING_DELIMITER = "`";
/**
* This field was generated by MyBatis Generator.
* This field corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
private static final String ENDING_DELIMITER = "`";
/**
* This field was generated by MyBatis Generator.
* This field corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
private final String column;
/**
* This field was generated by MyBatis Generator.
* This field corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
private final boolean isColumnNameDelimited;
/**
* This field was generated by MyBatis Generator.
* This field corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
private final String javaProperty;
/**
* This field was generated by MyBatis Generator.
* This field corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
private final String jdbcType;
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
public String value() {
return this.column;
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
public String getValue() {
return this.column;
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
public String getJavaProperty() {
return this.javaProperty;
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
public String getJdbcType() {
return this.jdbcType;
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
Column(String column, String javaProperty, String jdbcType, boolean isColumnNameDelimited) {
this.column = column;
this.javaProperty = javaProperty;
this.jdbcType = jdbcType;
this.isColumnNameDelimited = isColumnNameDelimited;
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
public String desc() {
return this.getEscapedColumnName() + " DESC";
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
public String asc() {
return this.getEscapedColumnName() + " ASC";
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
public static Column[] excludes(Column ... excludes) {
ArrayList<Column> columns = new ArrayList<>(Arrays.asList(Column.values()));
if (excludes != null && excludes.length > 0) {
columns.removeAll(new ArrayList<>(Arrays.asList(excludes)));
}
return columns.toArray(new Column[]{});
}
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
public String getEscapedColumnName() {
if (this.isColumnNameDelimited) {
return new StringBuilder().append(BEGINNING_DELIMITER).append(this.column).append(ENDING_DELIMITER).toString();
} else {
return this.column;
}
}
}
}
\ No newline at end of file
...@@ -4,6 +4,8 @@ import java.io.Serializable; ...@@ -4,6 +4,8 @@ import java.io.Serializable;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.Date; import java.util.Date;
import com.xxdxxs.entity.Entity;
import lombok.Data; import lombok.Data;
/** /**
...@@ -11,7 +13,7 @@ import lombok.Data; ...@@ -11,7 +13,7 @@ import lombok.Data;
* @date 2024/12/18 * @date 2024/12/18
*/ */
@Data @Data
public class QdUser implements Serializable { public class QdUser implements Entity {
/** /**
* This field was generated by MyBatis Generator. * This field was generated by MyBatis Generator.
* This field corresponds to the database table qd_user * This field corresponds to the database table qd_user
......
...@@ -4,6 +4,8 @@ import java.io.Serializable; ...@@ -4,6 +4,8 @@ import java.io.Serializable;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.Date; import java.util.Date;
import com.xxdxxs.entity.Entity;
import lombok.Data; import lombok.Data;
/** /**
...@@ -11,7 +13,7 @@ import lombok.Data; ...@@ -11,7 +13,7 @@ import lombok.Data;
* @date 2024/12/18 * @date 2024/12/18
*/ */
@Data @Data
public class QdUserSignIn implements Serializable { public class QdUserSignIn implements Entity {
/** /**
* id * id
*/ */
......
package com.wwdz.ch.db.domain.qiandao; package com.wwdz.ch.db.domain.qiandao;
import java.io.Serializable;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.Date; import java.util.Date;
import com.xxdxxs.entity.Entity;
import lombok.Data; import lombok.Data;
/** /**
...@@ -11,7 +11,7 @@ import lombok.Data; ...@@ -11,7 +11,7 @@ import lombok.Data;
* @date 2024/12/18 * @date 2024/12/18
*/ */
@Data @Data
public class QdUserSignInNote implements Serializable { public class QdUserSignInNote implements Entity {
private Long id; private Long id;
/** /**
......
...@@ -4,6 +4,8 @@ import java.io.Serializable; ...@@ -4,6 +4,8 @@ import java.io.Serializable;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.Date; import java.util.Date;
import com.xxdxxs.entity.Entity;
import lombok.Data; import lombok.Data;
/** /**
...@@ -11,7 +13,7 @@ import lombok.Data; ...@@ -11,7 +13,7 @@ import lombok.Data;
* @date 2024/12/18 * @date 2024/12/18
*/ */
@Data @Data
public class QdUserSignInTask implements Serializable { public class QdUserSignInTask implements Entity {
private Long id; private Long id;
/** /**
......
package com.wwdz.ch.db.dto.request.qiandao;
import com.wwdz.ch.db.dto.request.BaseRequestDto;
import com.xxdxxs.entity.Entity;
import lombok.Data;
import java.util.Date;
@Data
public class QdUserSignInNoteRequestDto extends BaseRequestDto implements Entity {
/**
* 用户id
*/
private Long userId;
/**
* 签到任务id
*/
private Long taskId;
/**
* 标题
*/
private String title;
/**
* 内容
*/
private String content;
/**
* 图片,分号分割
*/
private String image;
/**
* 音频
*/
private String audio;
/**
* 对应签到的日期
*/
private String signInDate;
/**
* 对应签到记录的id
*/
private Long recordId;
/**
* 是否公开
*/
private Boolean isPrivate;
/**
* 创建时间
*/
private Date createTime;
/**
* 更新时间
*/
private Date updateTime;
/**
* 是否删除
*/
private Boolean isDeleted;
}
package com.wwdz.ch.db.dto.request.qiandao;
import com.wwdz.ch.db.dto.request.BaseRequestDto;
import com.xxdxxs.entity.Entity;
import lombok.Data;
import java.util.Date;
@Data
public class QdUserSignInRequestDto extends BaseRequestDto implements Entity {
/**
* id
*/
private Long id;
/**
* 签到任务id
*/
private Long taskId;
/**
* 用户id
*/
private Long userId;
/**
* 签到时间
*/
private Date createTime;
/**
* 更新时间
*/
private Date updateTime;
private Date startQueryTime;
private Date endQueryTime;
/**
* 签到日期
*/
private String signInDate;
/**
* 连续天数
*/
private Integer consecutiveDays;
/**
* 是否有奖励
*/
private Boolean isReward;
/**
* 奖励等级
*/
private Integer rewardLevel;
/**
* 是否领取奖励
*/
private Boolean isGet;
/**
* 是否有效
*/
private Boolean isValid;
}
package com.wwdz.ch.db.dto.request.qiandao; package com.wwdz.ch.db.dto.request.qiandao;
import com.wwdz.ch.db.dto.request.BaseRequestDto;
import com.xxdxxs.entity.Entity; import com.xxdxxs.entity.Entity;
import lombok.Data; import lombok.Data;
import java.util.Date; import java.util.Date;
@Data @Data
public class SignInTaskRequestDto implements Entity { public class SignInTaskRequestDto extends BaseRequestDto implements Entity {
private Long id; private Long id;
......
package com.wwdz.ch.db.impl.qiandao;
import com.wwdz.ch.db.dao.qiandao.QdUserSignInDao;
import com.wwdz.ch.db.domain.qiandao.QdUserSignIn;
import com.wwdz.ch.db.domain.qiandao.QdUserSignInExample;
import com.wwdz.ch.db.dto.request.qiandao.QdUserSignInRequestDto;
import com.wwdz.ch.db.mapper.qiandao.QdUserSignInMapper;
import com.xxdxxs.db.component.JdbcHelper;
import com.xxdxxs.utils.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.time.LocalDate;
import java.util.List;
@Repository
public class QdUserSignInDaoImpl implements QdUserSignInDao {
@Autowired
QdUserSignInMapper qdUserSignInMapper;
@Override
public boolean insert(QdUserSignIn qdQdUserSignIn) {
qdQdUserSignIn.setIsValid(true);
return qdUserSignInMapper.insert(qdQdUserSignIn) > 0;
}
@Override
public QdUserSignIn findLastedRecord(long userId) {
QdUserSignInExample example = new QdUserSignInExample();
QdUserSignInExample.Criteria criteria = example.createCriteria();
criteria.andUserIdEqualTo(userId);
criteria.andIsValidEqualTo(true);
example.setOrderByClause("create_time desc");
return qdUserSignInMapper.selectOneByExample(example);
}
@Override
public List<QdUserSignIn> findList(QdUserSignInRequestDto dto) {
QdUserSignInExample example = new QdUserSignInExample();
QdUserSignInExample.Criteria criteria = example.createCriteria();
criteria.andUserIdEqualTo(dto.getUserId());
JdbcHelper.ifPresent(dto.getStartQueryTime(), criteria :: andCreateTimeGreaterThanOrEqualTo);
JdbcHelper.ifPresent(dto.getEndQueryTime(), criteria :: andCreateTimeLessThanOrEqualTo);
criteria.andIsValidEqualTo(true);
example.setOrderByClause("create_time desc");
return qdUserSignInMapper.selectByExample(example);
}
@Override
public QdUserSignIn findYesterdayRecord(long userId) {
LocalDate yesterday = LocalDate.now().minusDays(1);
String yesterdayString = DateUtils.DATE.format(yesterday);
QdUserSignInExample example = new QdUserSignInExample();
QdUserSignInExample.Criteria criteria = example.createCriteria();
criteria.andUserIdEqualTo(userId);
criteria.andSignInDateEqualTo(yesterdayString);
criteria.andIsValidEqualTo(true);
return qdUserSignInMapper.selectOneByExample(example);
}
@Override
public QdUserSignIn findTodayRecord(long userId) {
LocalDate today = LocalDate.now();
String todayString = DateUtils.DATE.format(today);
QdUserSignInExample example = new QdUserSignInExample();
QdUserSignInExample.Criteria criteria = example.createCriteria();
criteria.andUserIdEqualTo(userId);
criteria.andSignInDateEqualTo(todayString);
criteria.andIsValidEqualTo(true);
return qdUserSignInMapper.selectOneByExample(example);
}
@Override
public boolean isExisted(long userId, String date) {
QdUserSignInExample example = new QdUserSignInExample();
QdUserSignInExample.Criteria criteria = example.createCriteria();
criteria.andUserIdEqualTo(userId);
criteria.andSignInDateEqualTo(date);
criteria.andIsValidEqualTo(true);
return qdUserSignInMapper.countByExample(example) > 0;
}
@Override
public QdUserSignIn findRecord(long userId, String date, Integer consecutiveDays) {
QdUserSignInExample example = new QdUserSignInExample();
QdUserSignInExample.Criteria criteria = example.createCriteria();
criteria.andUserIdEqualTo(userId);
criteria.andSignInDateEqualTo(date);
JdbcHelper.ifPresent(consecutiveDays, criteria::andConsecutiveDaysEqualTo);
criteria.andIsValidEqualTo(true);
return qdUserSignInMapper.selectOneByExample(example);
}
@Override
public boolean update(QdUserSignIn userSignin) {
QdUserSignInExample example = new QdUserSignInExample();
QdUserSignInExample.Criteria criteria = example.createCriteria();
criteria.andUserIdEqualTo(userSignin.getUserId());
criteria.andSignInDateEqualTo(userSignin.getSignInDate());
return qdUserSignInMapper.updateByExampleSelective(userSignin, example) > 0;
}
@Override
public boolean updateByPrimaryKey(QdUserSignIn userSignin) {
return qdUserSignInMapper.updateByPrimaryKeySelective(userSignin) > 0;
}
@Override
public boolean deleteTodayRecord(long userId) {
LocalDate today = LocalDate.now();
String todayString = DateUtils.DATE.format(today);
QdUserSignInExample example = new QdUserSignInExample();
QdUserSignInExample.Criteria criteria = example.createCriteria();
criteria.andUserIdEqualTo(userId);
criteria.andSignInDateEqualTo(todayString);
return qdUserSignInMapper.deleteByExample(example) > 0;
}
@Override
public boolean updateInvalid(QdUserSignInRequestDto dto) {
QdUserSignInExample example = new QdUserSignInExample();
QdUserSignInExample.Criteria criteria = example.createCriteria();
JdbcHelper.ifPresent(dto.getStartQueryTime(), criteria::andCreateTimeGreaterThan);
JdbcHelper.ifPresent(dto.getSignInDate(), criteria::andSignInDateEqualTo);
criteria.andUserIdEqualTo(dto.getUserId());
criteria.andIsValidEqualTo(true);
QdUserSignIn userSignin = new QdUserSignIn();
userSignin.setIsValid(false);
return qdUserSignInMapper.updateByExampleSelective(userSignin, example) > 0;
}
}
package com.wwdz.ch.db.impl.qiandao;
import com.github.pagehelper.PageHelper;
import com.wwdz.ch.db.dao.qiandao.QdUserSignInDao;
import com.wwdz.ch.db.dao.qiandao.QdUserSignInNoteDao;
import com.wwdz.ch.db.domain.qiandao.QdUserSignInNote;
import com.wwdz.ch.db.domain.qiandao.QdUserSignInNoteExample;
import com.wwdz.ch.db.dto.request.qiandao.QdUserSignInNoteRequestDto;
import com.wwdz.ch.db.mapper.qiandao.QdUserSignInNoteMapper;
import com.xxdxxs.db.component.JdbcHelper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public class QdUserSignInNoteDaoImpl implements QdUserSignInNoteDao {
@Autowired
QdUserSignInNoteMapper qdUserSignInNoteMapper;
@Override
public boolean insert(QdUserSignInNote qdUserSignInNote) {
return qdUserSignInNoteMapper.insert(qdUserSignInNote) > 0;
}
@Override
public List<QdUserSignInNote> findByPage(QdUserSignInNoteRequestDto dto) {
QdUserSignInNoteExample example = new QdUserSignInNoteExample();
QdUserSignInNoteExample.Criteria criteria = example.createCriteria();
JdbcHelper.ifPresent(dto.getTaskId(), criteria :: andTaskIdEqualTo);
JdbcHelper.ifPresent(dto.getUserId(), criteria :: andUserIdEqualTo);
JdbcHelper.ifPresent(dto.getIsPrivate(), criteria :: andIsPrivateEqualTo);
PageHelper.startPage(dto.getPage(), dto.getLimit());
example.setOrderByClause("create_time desc");
return qdUserSignInNoteMapper.selectByExample(example);
}
}
package com.wwdz.ch.db.impl.qiandao; package com.wwdz.ch.db.impl.qiandao;
import com.github.pagehelper.PageHelper;
import com.wwdz.ch.db.dao.qiandao.SignInTaskDao; import com.wwdz.ch.db.dao.qiandao.SignInTaskDao;
import com.wwdz.ch.db.domain.qiandao.SignInTask;
import com.wwdz.ch.db.domain.qiandao.SignInTaskExample;
import com.wwdz.ch.db.dto.request.qiandao.SignInTaskRequestDto; import com.wwdz.ch.db.dto.request.qiandao.SignInTaskRequestDto;
import com.wwdz.ch.db.mapper.qiandao.SignInTaskMapper; import com.wwdz.ch.db.mapper.qiandao.SignInTaskMapper;
import com.xxdxxs.db.component.JdbcHelper;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import java.util.Date;
import java.util.List;
@Repository @Repository
public class SignInTaskDaoImpl implements SignInTaskDao { public class SignInTaskDaoImpl implements SignInTaskDao {
@Autowired @Autowired
SignInTaskMapper signInTaskMapper; SignInTaskMapper signInTaskMapper;
@Override @Override
public int insert(SignInTaskRequestDto signInTaskRequestDto) { public boolean insert(SignInTask signInTask) {
Date now = new Date();
signInTask.setCreateTime(now);
signInTask.setUpdateTime(now);
return signInTaskMapper.insert(signInTask) > 0;
}
return signInTaskMapper.insert(signInTaskRequestDto) ; @Override
public List<SignInTask> findByPage(SignInTaskRequestDto dto) {
SignInTaskExample example = new SignInTaskExample();
SignInTaskExample.Criteria criteria = example.createCriteria();
JdbcHelper.ifPresent(dto.getCreatorId(), criteria :: andCreatorIdEqualTo);
PageHelper.startPage(dto.getPage(), dto.getLimit());
example.setOrderByClause("create_time desc");
return signInTaskMapper.selectByExample(example);
} }
} }
package com.wwdz.ch.db.mapper.qiandao;
import com.wwdz.ch.db.domain.qiandao.QdGiveLikeRecord;
import com.wwdz.ch.db.domain.qiandao.QdGiveLikeRecordExample;
import java.util.List;
import org.apache.ibatis.annotations.Param;
public interface QdGiveLikeRecordMapper {
long countByExample(QdGiveLikeRecordExample example);
int deleteByExample(QdGiveLikeRecordExample example);
int deleteByPrimaryKey(Long id);
int insert(QdGiveLikeRecord record);
int insertSelective(QdGiveLikeRecord record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
QdGiveLikeRecord selectOneByExample(QdGiveLikeRecordExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
QdGiveLikeRecord selectOneByExampleSelective(@Param("example") QdGiveLikeRecordExample example, @Param("selective") QdGiveLikeRecord.Column ... selective);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
List<QdGiveLikeRecord> selectByExampleSelective(@Param("example") QdGiveLikeRecordExample example, @Param("selective") QdGiveLikeRecord.Column ... selective);
List<QdGiveLikeRecord> selectByExample(QdGiveLikeRecordExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table qd_give_like_record
*
* @mbg.generated
* @project https://github.com/itfsw/mybatis-generator-plugin
*/
QdGiveLikeRecord selectByPrimaryKeySelective(@Param("id") Long id, @Param("selective") QdGiveLikeRecord.Column ... selective);
QdGiveLikeRecord selectByPrimaryKey(Long id);
int updateByExampleSelective(@Param("record") QdGiveLikeRecord record, @Param("example") QdGiveLikeRecordExample example);
int updateByExample(@Param("record") QdGiveLikeRecord record, @Param("example") QdGiveLikeRecordExample example);
int updateByPrimaryKeySelective(QdGiveLikeRecord record);
int updateByPrimaryKey(QdGiveLikeRecord record);
}
\ No newline at end of file
...@@ -3,8 +3,11 @@ package com.wwdz.ch.db.mapper.qiandao; ...@@ -3,8 +3,11 @@ package com.wwdz.ch.db.mapper.qiandao;
import com.wwdz.ch.db.domain.qiandao.QdUserSignIn; import com.wwdz.ch.db.domain.qiandao.QdUserSignIn;
import com.wwdz.ch.db.domain.qiandao.QdUserSignInExample; import com.wwdz.ch.db.domain.qiandao.QdUserSignInExample;
import java.util.List; import java.util.List;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
@Mapper
public interface QdUserSignInMapper { public interface QdUserSignInMapper {
long countByExample(QdUserSignInExample example); long countByExample(QdUserSignInExample example);
......
...@@ -3,8 +3,11 @@ package com.wwdz.ch.db.mapper.qiandao; ...@@ -3,8 +3,11 @@ package com.wwdz.ch.db.mapper.qiandao;
import com.wwdz.ch.db.domain.qiandao.QdUserSignInNote; import com.wwdz.ch.db.domain.qiandao.QdUserSignInNote;
import com.wwdz.ch.db.domain.qiandao.QdUserSignInNoteExample; import com.wwdz.ch.db.domain.qiandao.QdUserSignInNoteExample;
import java.util.List; import java.util.List;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
@Mapper
public interface QdUserSignInNoteMapper { public interface QdUserSignInNoteMapper {
long countByExample(QdUserSignInNoteExample example); long countByExample(QdUserSignInNoteExample example);
......
...@@ -72,7 +72,7 @@ ...@@ -72,7 +72,7 @@
<javaClientGenerator type="XMLMAPPER" targetPackage="com.wwdz.ch.db.mapper.qiandao" <javaClientGenerator type="XMLMAPPER" targetPackage="com.wwdz.ch.db.mapper.qiandao"
targetProject="ch-dao/src/main/java"/> targetProject="ch-dao/src/main/java"/>
<table tableName="qd_user_sign_in_note" enableCountByExample="true" enableUpdateByExample="true" enableDeleteByExample="true" enableSelectByExample="true" selectByExampleQueryId="true"> <table tableName="qd_give_like_record" enableCountByExample="true" enableUpdateByExample="true" enableDeleteByExample="true" enableSelectByExample="true" selectByExampleQueryId="true">
<generatedKey column="id" sqlStatement="Mysql" identity="true" /> <generatedKey column="id" sqlStatement="Mysql" identity="true" />
</table> </table>
......
package com.wwdz.ch.wx.impl.qiandao; package com.wwdz.ch.wx.impl.qiandao;
import com.wwdz.ch.core.consts.qiandao.SignInTaskEnum;
import com.wwdz.ch.core.type.Result; import com.wwdz.ch.core.type.Result;
import com.wwdz.ch.db.dao.qiandao.SignInTaskDao; import com.wwdz.ch.db.dao.qiandao.SignInTaskDao;
import com.wwdz.ch.db.domain.qiandao.SignInTask; import com.wwdz.ch.db.domain.qiandao.SignInTask;
import com.wwdz.ch.db.dto.request.qiandao.SignInTaskRequestDto; import com.wwdz.ch.db.dto.request.qiandao.SignInTaskRequestDto;
import com.wwdz.ch.db.mapper.qiandao.SignInTaskMapper;
import com.wwdz.ch.wx.service.qiandao.SignInTaskService; import com.wwdz.ch.wx.service.qiandao.SignInTaskService;
import com.xxdxxs.utils.EntityMapper;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
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.Date;
import java.util.HashMap;
@Service @Service
public class SignInTaskServiceImpl implements SignInTaskService { public class SignInTaskServiceImpl implements SignInTaskService {
@Autowired
SignInTaskDao signInTaskDao;
private static final Logger logger = LoggerFactory.getLogger(SignInTaskServiceImpl.class); private static final Logger logger = LoggerFactory.getLogger(SignInTaskServiceImpl.class);
@Autowired
SignInTaskDao signInTaskDao;
@Override @Override
public Result addSign(SignInTaskRequestDto dto) { public Result add(SignInTaskRequestDto dto) {
try {
dto.setCreateTime(new Date()); SignInTask signInTask = new SignInTask();
dto.setUpdateTime(new Date()); EntityMapper.copyAttribute(dto, signInTask);
signInTaskDao.insert(dto); signInTask.setState(SignInTaskEnum.StateEnum.NOT_START.getCode());
signInTaskDao.insert(signInTask);
return Result.success(); return Result.success();
} catch (Exception e) {
logger.error("新增签到任务失败 error :{}", e);
} }
return Result.failed();
@Override
public void findlist(int pageNum, int pageSize) throws Exception {
} }
} }
...@@ -5,11 +5,10 @@ import com.wwdz.ch.db.dto.request.qiandao.SignInTaskRequestDto; ...@@ -5,11 +5,10 @@ import com.wwdz.ch.db.dto.request.qiandao.SignInTaskRequestDto;
public interface SignInTaskService { public interface SignInTaskService {
Result addSign(SignInTaskRequestDto dto); /**
* 新增签到任务
void findlist(int pageNum ,int pageSize) throws Exception; * @param dto
* @return
*/
Result add(SignInTaskRequestDto dto);
} }
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment