直播使用sop发送

fs-service/src/main/java/com/fs/live/service/impl/LiveWatchUserServiceImpl.java

@@ -775,44 +775,65 @@ public class LiveWatchUserServiceImpl implements ILiveWatchUserService {
 
         //根据配置给每位用户打上标签
         List<HandleUserTagVO> handleUserTagVOS = new ArrayList<>();
-        liveWatchLogs.forEach(log->{
+        liveWatchLogs.forEach(liveLog -> {
             HandleUserTagVO addItem = new HandleUserTagVO();
             addItem.setLiveId(liveId);
-            addItem.setExternalId(log.getExternalContactId());
-            List<Long> tags = new ArrayList<>();
-            switch(log.getLogType())
-            {
+            addItem.setExternalId(liveLog.getExternalContactId());
+            LiveTagItemVO liveTagItemVO = null;
+            List<String> tags = new ArrayList<>();
+            switch (liveLog.getLogType()) {
                 //1看课中
                 case 1:
                     //打标签 直播到课未完课
-                    LiveTagItemVO liveTagItemVO = liveTagMp.get(3);
-                    tags.add(liveTagItemVO.getQwTagId());
+                    liveTagItemVO = liveTagMp.get(3);
+                    if (null != liveTagItemVO) {
+                        tags.add(liveTagItemVO.getQwTagRealId());
+                    }
                     break;
                 //2完课
                 case 2:
-                    //打标签
+                    //打标签 直播已完课
+                    liveTagItemVO = liveTagMp.get(5);
+                    if (null != liveTagItemVO) {
+                        tags.add(liveTagItemVO.getQwTagRealId());
+                    }
                     break;
                 //3待看课
                 case 3:
-                    //打标签
+
+                    //打标签 直播未到课
+                    liveTagItemVO = liveTagMp.get(1);
+                    if (null != liveTagItemVO) {
+                        tags.add(liveTagItemVO.getQwTagRealId());
+                    }
                     break;
                 //4看课中断
                 case 4:
-                    //打标签
+                    //打标签 直播未到课
+                    liveTagItemVO = liveTagMp.get(3);
+                    if (null != liveTagItemVO) {
+                        tags.add(liveTagItemVO.getQwTagRealId());
+                    }
                     break;
                 default:
                     break;
             }
-
+            if (null != liveLog.getLiveBuy() && liveLog.getLiveBuy().equals(1)) {
+                liveTagItemVO = liveTagMp.get(7);
+                if (null != liveTagItemVO) {
+                    tags.add(liveTagItemVO.getQwTagRealId());
+                }
+            }
             handleUserTagVOS.add(addItem);
         });
+        handleUserTags2Qw(handleUserTagVOS);
     }
 
     /**
      * 对企微用户打标签
      * @param userTagVOS 用户标签列表，包含外部联系人ID和要添加的标签列表
      */
-    private void test(List<HandleUserTagVO> userTagVOS) {
+    private void handleUserTags2Qw(List<HandleUserTagVO> userTagVOS) {
         if (CollUtil.isEmpty(userTagVOS)) {
             log.warn("用户标签列表为空，跳过打标签操作");
             return;