|
|
@@ -131,8 +131,12 @@ public class FsTagUpdateServiceImpl implements FsTagUpdateService {
|
|
|
task.setRetryCount(0);
|
|
|
task.setQwExternalContactId(item.getQwExternalContactId());
|
|
|
task.setQwUserId(item.getQwUserId());
|
|
|
-
|
|
|
FsUserCourseVideo fsUserCourseVideo = courseVideoMap.get(task.getVideoId());
|
|
|
+ if(ObjectUtil.isNull(item.getQwUserId())){
|
|
|
+ log.error("qwUserId is null 已跳过");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
String corpId = qwUserCacheService.queryCorpIdByQwUserId(item.getQwUserId());
|
|
|
if(StringUtils.isNotNull(corpId)){
|
|
|
task.setCorpId(corpId);
|
|
|
@@ -190,6 +194,11 @@ public class FsTagUpdateServiceImpl implements FsTagUpdateService {
|
|
|
task.setQwExternalContactId(item.getQwExternalContactId());
|
|
|
task.setQwUserId(item.getQwUserId());
|
|
|
task.setLogType(1);
|
|
|
+ if(ObjectUtil.isNull(item.getQwUserId())){
|
|
|
+ log.error("qwUserId is null 已跳过");
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
String corpId = qwUserCacheService.queryCorpIdByQwUserId(item.getQwUserId());
|
|
|
if(StringUtils.isNotNull(corpId)){
|
|
|
task.setCorpId(corpId);
|