package com.yeshi.fanli.service.impl.integral;
|
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Set;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.yeshi.utils.DateUtil;
|
|
import com.yeshi.fanli.dao.mybatis.integral.IntegralTaskRecordMapper;
|
import com.yeshi.fanli.dto.msg.MsgOtherRewardIntegralDTO;
|
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
|
import com.yeshi.fanli.entity.integral.IntegralDetail;
|
import com.yeshi.fanli.entity.integral.IntegralTask;
|
import com.yeshi.fanli.entity.integral.IntegralTask.FrequencyEnum;
|
import com.yeshi.fanli.entity.integral.IntegralTaskClass;
|
import com.yeshi.fanli.entity.integral.IntegralTaskClass.UniqueKeyEnum;
|
import com.yeshi.fanli.entity.integral.IntegralTaskRecord;
|
import com.yeshi.fanli.exception.integral.IntegralTaskRecordException;
|
import com.yeshi.fanli.exception.user.UserInfoExtraException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.config.ConfigService;
|
import com.yeshi.fanli.service.inter.integral.IntegralDetailService;
|
import com.yeshi.fanli.service.inter.integral.IntegralTaskClassService;
|
import com.yeshi.fanli.service.inter.integral.IntegralTaskRecordService;
|
import com.yeshi.fanli.service.inter.integral.IntegralTaskService;
|
import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService;
|
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.TimeUtil;
|
|
@Service
|
public class IntegralTaskRecordServiceImpl implements IntegralTaskRecordService {
|
|
@Resource
|
private IntegralTaskRecordMapper integralTaskRecordMapper;
|
|
@Resource
|
private UserInfoExtraService userInfoExtraService;
|
|
@Resource
|
private IntegralDetailService integralDetailService;
|
|
@Resource
|
private IntegralTaskService integralTaskService;
|
|
@Resource
|
private IntegralTaskClassService integralTaskClassService;
|
|
@Resource
|
private UserOtherMsgNotificationService userOtherMsgNotificationService;
|
|
@Resource
|
private ConfigService configService;
|
|
|
|
@Override
|
public Integer getTotalGoldCoin(long uid, Long cid, Integer dateType) {
|
return integralTaskRecordMapper.getTotalGoldCoin(uid, cid, dateType);
|
}
|
|
@Override
|
public Integer countFinished(long uid, Long cid, Integer dateType) {
|
return integralTaskRecordMapper.countFinished(uid, cid, dateType);
|
}
|
|
@Override
|
public void finishedTask(long uid, long cid, long taskId, int goldCoin) {
|
IntegralTaskRecord taskRecord = new IntegralTaskRecord();
|
taskRecord.setUid(uid);
|
taskRecord.setCid(cid);
|
taskRecord.setTaskId(taskId);
|
taskRecord.setGoldCoin(goldCoin);
|
taskRecord.setState(0);
|
taskRecord.setCreateTime(new Date());
|
taskRecord.setUpdateTime(new Date());
|
integralTaskRecordMapper.insertSelective(taskRecord);
|
}
|
|
@Override
|
public boolean isToDaySign(long uid, Long cid) {
|
Integer countFinished = integralTaskRecordMapper.countFinished(uid, cid, 1);
|
if (countFinished != null && countFinished > 0) {
|
return true;
|
}
|
return false;
|
}
|
|
@Override
|
public Integer getNowdaySignNum(long uid, Long cid) {
|
int num = 1;
|
try {
|
// 签到时间倒序查询近7天数据
|
List<IntegralTaskRecord> list = integralTaskRecordMapper.listDaySignRecord(uid, cid);
|
if (list != null && list.size() > 0) {
|
Date today = new Date();
|
for (IntegralTaskRecord record : list) {
|
if (DateUtil.daysBetween2(record.getCreateTime(), today) == 0) {
|
continue;
|
}
|
|
if (DateUtil.daysBetween2(record.getCreateTime(), today) != 1) {
|
break; // 天数未连续
|
}
|
today = record.getCreateTime();
|
num++;
|
}
|
}
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
|
if (num > 7) {
|
num = 7;
|
}
|
return num;
|
}
|
|
@Override
|
public List<IntegralTaskRecord> getSignDaysRecord(long uid, Long cid) {
|
List<IntegralTaskRecord> listRecord = new ArrayList<IntegralTaskRecord>();
|
try {
|
// 签到时间正序序查询近7天数据
|
List<IntegralTaskRecord> list = integralTaskRecordMapper.listDaySignRecord(uid, cid);
|
if (list != null && list.size() > 0) {
|
Date date = new Date();
|
for (IntegralTaskRecord record : list) {
|
Date createTime = record.getCreateTime();
|
if (DateUtil.daysBetween2(createTime, date) > 1) {
|
break; // 天数未连续
|
}
|
date = createTime;
|
listRecord.add(record);
|
}
|
}
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
return listRecord;
|
}
|
|
@Override
|
public List<IntegralTaskRecord> listNotReceived(int count, long uid) {
|
return integralTaskRecordMapper.listNotReceived(count, uid);
|
}
|
|
@Override
|
public List<IntegralTaskRecord> listNotReceivedExcludeId(int count, long uid, Set<Long> idList) {
|
if (idList != null && idList.size() == 0) {
|
idList = null;
|
}
|
return integralTaskRecordMapper.listNotReceivedExcludeId(count, uid, idList);
|
}
|
|
@Override
|
@Transactional
|
public Integer receiveGoldCoinALL(Long uid) throws IntegralTaskRecordException {
|
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
|
if (userInfoExtra == null)
|
throw new IntegralTaskRecordException(1, "用户信息不全");
|
|
List<IntegralTaskRecord> list = integralTaskRecordMapper.listNotReceived(Integer.MAX_VALUE, uid);
|
if (list == null || list.size() == 0)
|
throw new IntegralTaskRecordException(1, "暂无可领取");
|
|
Integer totalGoldCoin = 0;
|
for (IntegralTaskRecord record : list) {
|
if (addDetail(uid, record))
|
totalGoldCoin += record.getGoldCoin();
|
}
|
|
Integer goldCoin = userInfoExtra.getGoldCoin();
|
if (goldCoin == null)
|
goldCoin = 0;
|
|
UserInfoExtra extra = new UserInfoExtra();
|
extra.setId(userInfoExtra.getId());
|
extra.setGoldCoin(goldCoin + totalGoldCoin);
|
try {
|
userInfoExtraService.saveUserInfoExtra(extra);
|
} catch (UserInfoExtraException e) {
|
throw new IntegralTaskRecordException(1, "用户信息不全");
|
}
|
|
return extra.getGoldCoin();
|
}
|
|
@Override
|
@Transactional
|
public Integer receiveGoldCoin(Long uid, Set<Long> idList) throws IntegralTaskRecordException {
|
if (idList == null || idList.size() == 0) {
|
throw new IntegralTaskRecordException(1, "id为空");
|
}
|
|
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
|
if (userInfoExtra == null) {
|
throw new IntegralTaskRecordException(1, "用户信息不全");
|
}
|
|
Integer totalGoldCoin = 0;
|
for (Long id : idList) {
|
IntegralTaskRecord record = integralTaskRecordMapper.selectByPrimaryKey(id);
|
if (record == null)
|
continue;
|
|
if (addDetail(uid, record))
|
totalGoldCoin += record.getGoldCoin();
|
}
|
|
Integer goldCoin = userInfoExtra.getGoldCoin();
|
if (goldCoin == null)
|
goldCoin = 0;
|
|
UserInfoExtra extra = new UserInfoExtra();
|
extra.setId(userInfoExtra.getId());
|
extra.setGoldCoin(goldCoin + totalGoldCoin);
|
try {
|
userInfoExtraService.saveUserInfoExtra(extra);
|
} catch (UserInfoExtraException e) {
|
throw new IntegralTaskRecordException(1, "用户信息不全");
|
}
|
|
return extra.getGoldCoin();
|
}
|
|
public boolean addDetail(Long uid, IntegralTaskRecord record) throws IntegralTaskRecordException {
|
|
Long uid2 = record.getUid();
|
if (uid2 == null || uid.longValue() != uid2.longValue())
|
return false; // 用户id不符合
|
|
if (record.getState() != null && record.getState().intValue() == 1) {
|
return false; // 已领取
|
}
|
|
IntegralTaskRecord taskRecord = new IntegralTaskRecord();
|
taskRecord.setId(record.getId());
|
taskRecord.setState(1); // 已领取
|
taskRecord.setUpdateTime(new Date());
|
integralTaskRecordMapper.updateByPrimaryKeySelective(taskRecord);
|
|
Long cid = record.getCid();
|
if (cid == null)
|
return false;
|
|
IntegralTaskClass taskClass = integralTaskClassService.selectByPrimaryKey(cid);
|
if (taskClass == null)
|
return false;
|
|
Long taskId = record.getTaskId();
|
if (taskId == null)
|
return false;
|
|
IntegralTask integralTask = integralTaskService.selectByPrimaryKey(taskId);
|
if (integralTask == null)
|
return false;
|
|
// 加入明细
|
IntegralDetail detail = new IntegralDetail();
|
if (UniqueKeyEnum.dailySign == taskClass.getUniqueKey()) {
|
SimpleDateFormat format = new SimpleDateFormat("yy-MM-dd HH:mm:ss");
|
Date recordTime = record.getCreateTime();
|
List<IntegralTaskRecord> list = integralTaskRecordMapper.listSignRecordByDateTime(uid, cid,
|
format.format(recordTime));
|
int num = 1;
|
if (list != null && list.size() > 0) {
|
try {
|
Date nextDate = null;
|
for (IntegralTaskRecord tntegralTaskRecord : list) {
|
if (nextDate == null) {
|
nextDate = tntegralTaskRecord.getCreateTime();
|
continue;
|
}
|
|
if (DateUtil.daysBetween2(tntegralTaskRecord.getCreateTime(), nextDate) != 1) {
|
break; // 天数未连续
|
}
|
nextDate = tntegralTaskRecord.getCreateTime();
|
num++;
|
}
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
}
|
detail.setTitle(taskClass.getName() + "-第" + num + "天");
|
} else {
|
int num = 0;
|
FrequencyEnum frequency = integralTask.getFrequency();
|
if (frequency == FrequencyEnum.everyday) {
|
num = integralTaskRecordMapper.countByTaskIdTodayNum(uid, taskId,
|
TimeUtil.getWholeTime(record.getCreateTime().getTime()));
|
} else if (frequency == FrequencyEnum.onlyOne) {
|
num = 1;
|
}
|
|
if (num <= 0)
|
num = 1;
|
String title = taskClass.getName() + "-" + integralTask.getName() + "-第" + num + "次";
|
detail.setTitle(title);
|
}
|
|
detail.setUid(uid);
|
detail.setMoney(record.getGoldCoin());
|
detail.setCreateTime(record.getCreateTime());
|
integralDetailService.insertSelective(detail);
|
|
return true;
|
}
|
|
@Override
|
public int countGetCountByTaskIdAndDay(Long taskId, Long uid, Date day) {
|
Date minTime = null;
|
Date maxTime = null;
|
if (day == null) {
|
minTime = new Date(TimeUtil.convertToTimeTemp("1970-01-01", "yyyy-MM-dd"));
|
maxTime = new Date(TimeUtil.convertToTimeTemp("2100-01-01", "yyyy-MM-dd"));
|
} else {
|
minTime = new Date(
|
TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(day.getTime(), "yyyy-MM-dd"), "yyyy-MM-dd"));
|
maxTime = new Date(minTime.getTime() + 1000 * 60 * 60 * 24L);
|
}
|
return integralTaskRecordMapper.countGetCountByTaskIdAndDay(taskId, uid, minTime, maxTime);
|
}
|
|
@Override
|
public IntegralTaskRecord addRecord(IntegralTaskRecord record) throws IntegralTaskRecordException {
|
if (record == null)
|
throw new IntegralTaskRecordException(1, "记录为空");
|
|
if (record.getCid() == null || record.getTaskId() == null || record.getGoldCoin() == null
|
|| record.getState() == null || record.getUid() == null)
|
throw new IntegralTaskRecordException(2, "数据不完成");
|
|
if (record.getCreateTime() == null)
|
record.setCreateTime(new Date());
|
|
if (record.getUpdateTime() == null)
|
record.setUpdateTime(new Date());
|
integralTaskRecordMapper.insertSelective(record);
|
return record;
|
}
|
|
@Override
|
public List<IntegralTaskRecord> listByCidAndUidAndCreateTime(Long cid, Long uid, Date minTime, Date maxTime,
|
int page, int count) {
|
return integralTaskRecordMapper.listByCidAndUidAndCreateTime(cid, uid, minTime, maxTime, (page - 1) * count,
|
count);
|
}
|
|
@Override
|
public long countByCidAndUidAndCreateTime(Long cid, Long uid, Date minTime, Date maxTime) {
|
return integralTaskRecordMapper.countByCidAndUidAndCreateTime(cid, uid, minTime, maxTime);
|
}
|
|
@Override
|
public List<IntegralTaskRecord> listByUidAndTaskId(Long uid, Long taskId, int page, int count) {
|
return integralTaskRecordMapper.listByUidAndTaskId(uid, taskId, (page - 1) * count, count);
|
}
|
|
/**
|
* 被邀请人下了首单（第一笔返利订单） 直接给邀请人一笔金币
|
* @param uid
|
*/
|
@Override
|
public void firstOrderRewardInviter(Long uid, String beizu) {
|
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
|
if (userInfoExtra == null)
|
return;
|
|
String reward = configService.get("first_order_reward_boss");
|
if (StringUtil.isNullOrEmpty(reward))
|
return;
|
|
Integer goldCoin = userInfoExtra.getGoldCoin();
|
if (goldCoin == null)
|
goldCoin = 0;
|
|
int addGoldCoin = Integer.parseInt(reward);
|
goldCoin = goldCoin + addGoldCoin;
|
|
try {
|
// 增加金币
|
UserInfoExtra extra = new UserInfoExtra();
|
extra.setId(userInfoExtra.getId());
|
extra.setGoldCoin(goldCoin);
|
userInfoExtraService.saveUserInfoExtra(extra);
|
} catch (UserInfoExtraException e) {
|
e.printStackTrace();
|
return;
|
}
|
|
// 金币详情
|
IntegralDetail detail = new IntegralDetail();
|
detail.setTitle("队员首笔奖励");
|
detail.setUid(uid);
|
detail.setMoney(addGoldCoin);
|
detail.setRemark(beizu);
|
detail.setCreateTime(new Date());
|
integralDetailService.insertSelective(detail);
|
|
// 消息
|
MsgOtherRewardIntegralDTO msgOther = new MsgOtherRewardIntegralDTO();
|
msgOther.setTitle("金币奖励");
|
msgOther.setSource("一级队员首笔下单，系统奖励邀请人金币");
|
msgOther.setNum(addGoldCoin + "金币");
|
msgOther.setTotal(goldCoin + "金币");
|
msgOther.setExplain("仅一级队员首笔下单奖励（已到账）");
|
userOtherMsgNotificationService.firstOrderRewardMsg(uid, "", msgOther);
|
}
|
|
}
|
