模板里设置 app发送直播IM消息（待优化批量插入或更新语句）

fs-qw-task/src/main/java/com/fs/app/taskService/impl/SopLogsTaskServiceImpl.java

@@ -1631,6 +1631,12 @@ public class SopLogsTaskServiceImpl implements SopLogsTaskService {
 
                     setting.setMiniprogramPage(shortH5Link);
                     break;
+                // app发送直播IM消息
+                case "20":
+                    json = configService.selectConfigByKey("his.config");
+                    sysConfig= JSON.parseObject(json,FSSysConfig.class);
+                    createLiveWatchLogAndEnQueue(companyId,companyUserId,externalId, setting.getLiveId(),sysConfig.getAppId(),1,qwUserId,logVo.getCorpId());
+                    break;
                 default:
                     break;
             }
@@ -1958,6 +1964,12 @@ public class SopLogsTaskServiceImpl implements SopLogsTaskService {
                         log.error("浏览器看课模板解析失败：" + e);
                     }
 
+                    break;
+                // app发送直播IM消息
+                case "20":
+                    json = configService.selectConfigByKey("his.config");
+                    sysConfig= JSON.parseObject(json,FSSysConfig.class);
+                    createLiveWatchLogAndEnQueue(companyId,companyUserId,externalId, setting.getLiveId(),sysConfig.getAppId(),1,qwUserId,logVo.getCorpId());
                     break;
                 case "21"://短信看课
                     if (sopLogs.getFsUserId() != null && !Long.valueOf(0L).equals(sopLogs.getFsUserId())) {

fs-service/src/main/java/com/fs/sop/service/impl/SopUserLogsInfoServiceImpl.java

@@ -1443,7 +1443,7 @@ public class SopUserLogsInfoServiceImpl implements ISopUserLogsInfoService {
                             FSSysConfig sysConfig= JSON.parseObject(js,FSSysConfig.class);
                             //发个人看课记录处理
                             try {
-                                createLiveWatchLogAndInsert(qwUser.getCompanyId().toString(), qwUser.getCompanyUserId().toString(),item.getExternalId().toString(),Long.valueOf(st.getLiveId()),sysConfig.getAppId(),2, qwUserId,param.getCorpId());
+                                createLiveWatchLogAndInsert(qwUser.getCompanyId().toString(), qwUser.getCompanyUserId().toString(),item.getExternalId().toString(),Long.valueOf(st.getLiveId()),sysConfig.getAppId(),3, qwUserId,param.getCorpId());
 
                             } catch (Exception e) {
                                 log.error("群聊创建直播看课记录失败！", e);
@@ -1735,7 +1735,7 @@ public class SopUserLogsInfoServiceImpl implements ISopUserLogsInfoService {
                                         item.getExternalId().toString(),
                                         Long.valueOf(st.getLiveId()),
                                         sysConfig0.getAppId(),
-                                        2,
+                                        3,
                                         String.valueOf(qwUser.getId()),
                                         param.getCorpId());
                             } catch (Exception e) {
@@ -1753,7 +1753,7 @@ public class SopUserLogsInfoServiceImpl implements ISopUserLogsInfoService {
                                         item.getExternalId().toString(),
                                         Long.valueOf(st.getLiveId()),
                                         sysConfigLive.getAppId(),
-                                        2,
+                                        3,
                                         String.valueOf(qwUser.getId()),
                                         param.getCorpId());
                             } catch (Exception e) {
@@ -2410,7 +2410,7 @@ public class SopUserLogsInfoServiceImpl implements ISopUserLogsInfoService {
                     FSSysConfig sysConfig= JSON.parseObject(json,FSSysConfig.class);
                     //todo 发个人看课记录处理
                     try {
-                        createLiveWatchLogAndInsert(qwUser.getCompanyId().toString(), qwUser.getCompanyUserId().toString(),item.getExternalId().toString(),Long.valueOf(st.getLiveId()),sysConfig.getAppId(),2, String.valueOf(qwUser.getId()),param.getCorpId());
+                        createLiveWatchLogAndInsert(qwUser.getCompanyId().toString(), qwUser.getCompanyUserId().toString(),item.getExternalId().toString(),Long.valueOf(st.getLiveId()),sysConfig.getAppId(),3, String.valueOf(qwUser.getId()),param.getCorpId());
                     } catch (Exception e) {
                         log.error("群聊创建直播看课记录失败！", e);
                     }
@@ -2599,7 +2599,7 @@ public class SopUserLogsInfoServiceImpl implements ISopUserLogsInfoService {
                     sysConfig= JSON.parseObject(json,FSSysConfig.class);
                     //todo 发个人看课记录处理
                     try {
-                        createLiveWatchLogAndInsert(qwUser.getCompanyId().toString(), qwUser.getCompanyUserId().toString(),item.getExternalId().toString(),Long.valueOf(st.getLiveId()),sysConfig.getAppId(),2, String.valueOf(qwUser.getId()),param.getCorpId());
+                        createLiveWatchLogAndInsert(qwUser.getCompanyId().toString(), qwUser.getCompanyUserId().toString(),item.getExternalId().toString(),Long.valueOf(st.getLiveId()),sysConfig.getAppId(),3, String.valueOf(qwUser.getId()),param.getCorpId());
                     } catch (Exception e) {
                         log.error("群聊创建直播看课记录失败！", e);
                     }
@@ -2692,7 +2692,7 @@ public class SopUserLogsInfoServiceImpl implements ISopUserLogsInfoService {
                                 item.getExternalId().toString(),
                                 Long.valueOf(st.getLiveId()),
                                 sysConfig0.getAppId(),
-                                2,
+                                3,
                                 String.valueOf(qwUser.getId()),
                                 param.getCorpId());
                     } catch (Exception e) {
@@ -2710,7 +2710,7 @@ public class SopUserLogsInfoServiceImpl implements ISopUserLogsInfoService {
                                 item.getExternalId().toString(),
                                 Long.valueOf(st.getLiveId()),
                                 sysConfigLive.getAppId(),
-                                2,
+                                3,
                                 String.valueOf(qwUser.getId()),
                                 param.getCorpId());
                     } catch (Exception e) {