|
|
@@ -3,6 +3,7 @@ package com.cyksj.service.market.impl;
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
|
import cn.hutool.core.date.DateTime;
|
|
|
import cn.hutool.core.date.DateUtil;
|
|
|
+import cn.hutool.core.util.StrUtil;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.cyksj.common.constant.PointsRecordConst;
|
|
|
@@ -440,8 +441,10 @@ public class MarketFrontServiceImpl implements MarketFrontService {
|
|
|
data.setStatus(record.getStatus());
|
|
|
data.setTaskCompleteRecordId(record.getId());
|
|
|
}
|
|
|
- if (record == null && isWx) {
|
|
|
- CorpUser corpUser = corpUserMapper.selectOne(Wrappers.lambdaQuery(CorpUser.class).eq(CorpUser::getUnionid, user.getUnionid()).last("limit 1"));
|
|
|
+ if (record == null && isWx && StrUtil.isNotEmpty(user.getUnionid())) {
|
|
|
+ CorpUser corpUser = corpUserMapper.selectOne(Wrappers.lambdaQuery(CorpUser.class)
|
|
|
+ .eq(CorpUser::getUnionid, user.getUnionid())
|
|
|
+ .last("limit 1"));
|
|
|
if (corpUser != null) {
|
|
|
data.setStatus(TaskUserCompleteRecord.Status.complete);
|
|
|
if (redisService.setNx(RedisService.key.TASK_TIME_LIMIT_KEY.getNameFormat(String.format("wx_%s", userId)), userId, RedisService.key.TASK_TIME_LIMIT_KEY.getTimeout())) {
|