sop模板修改

fs-admin/src/main/java/com/fs/core/config/DataSourceConfig.java

@@ -48,9 +48,9 @@ public class DataSourceConfig {
                                         @Qualifier("sopDataSource") DataSource sopDataSource,
                                         @Qualifier("slaveDataSource") DataSource slaveDataSource) {
         Map<Object, Object> targetDataSources = new HashMap<>();
-        targetDataSources.put(DataSourceType.MASTER, masterDataSource);
+        targetDataSources.put(DataSourceType.MASTER.name(), masterDataSource);
 
-        targetDataSources.put(DataSourceType.SLAVE, slaveDataSource);
+        targetDataSources.put(DataSourceType.SLAVE.name(), slaveDataSource);
         targetDataSources.put(DataSourceType.SOP.name(), sopDataSource);
         return new DynamicDataSource(masterDataSource, targetDataSources);
     }

fs-admin/src/main/java/com/fs/core/datasource/DynamicDataSourceContextHolder.java

@@ -40,6 +40,7 @@ public class DynamicDataSourceContextHolder
      */
     public static void clearDataSourceType()
     {
+        log.info("清除当前{}数据源", getDataSourceType());
         CONTEXT_HOLDER.remove();
     }
 }

fs-admin/src/main/java/com/fs/course/controller/FsUserCourseVideoController.java

@@ -9,6 +9,7 @@ import com.fs.common.enums.BusinessType;
 import com.fs.common.utils.poi.ExcelUtil;
 import com.fs.course.domain.FsUserCourseVideo;
 import com.fs.course.mapper.FsUserCourseVideoMapper;
+import com.fs.course.param.CourseVideoUpdates;
 import com.fs.course.service.IFsUserCourseVideoService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.security.access.prepost.PreAuthorize;
@@ -118,4 +119,10 @@ public class FsUserCourseVideoController extends BaseController
     {
         return R.ok().put("data",fsUserCourseVideoService.selectCourseVideoSort(courseId));
     }
+
+    @PostMapping("/updates")
+    public R updates(@RequestBody CourseVideoUpdates vo){
+        fsUserCourseVideoService.updates(vo);
+        return R.ok();
+    }
 }

fs-admin/src/main/java/com/fs/qw/controller/QwSopController.java

@@ -0,0 +1,225 @@
+package com.fs.qw.controller;
+
+import com.fs.common.annotation.Log;
+import com.fs.common.annotation.RepeatSubmit;
+import com.fs.common.core.controller.BaseController;
+import com.fs.common.core.domain.AjaxResult;
+import com.fs.common.core.domain.R;
+import com.fs.common.core.page.TableDataInfo;
+import com.fs.common.enums.BusinessType;
+import com.fs.common.utils.ServletUtils;
+import com.fs.common.utils.poi.ExcelUtil;
+import com.fs.core.security.LoginUser;
+import com.fs.core.web.service.TokenService;
+import com.fs.course.mapper.FsUserCourseMapper;
+import com.fs.course.mapper.FsUserCourseVideoMapper;
+import com.fs.his.vo.OptionsVO;
+import com.fs.qw.domain.QwSopUpdateStatus;
+import com.fs.qw.service.IQwUserService;
+import com.fs.sop.domain.QwSop;
+import com.fs.sop.params.QwSopAutoTime;
+import com.fs.sop.params.QwSopEditQwUserParam;
+import com.fs.sop.service.IQwSopService;
+import com.fs.sop.vo.SopVoiceListVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.*;
+
+import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 企微sopController
+ *
+ * @author fs
+ * @date 2024-07-31
+ */
+@RestController
+@RequestMapping("/qw/sop")
+public class QwSopController extends BaseController
+{
+    @Autowired
+    private IQwSopService qwSopService;
+
+    @Autowired
+    private IQwUserService qwUserService;
+    @Autowired
+    private TokenService tokenService;
+
+    @Autowired
+    private FsUserCourseMapper fsUserCourseMapper;
+    @Autowired
+    private FsUserCourseVideoMapper fsUserCourseVideoMapper;
+    /**
+     * 查询企微sop列表
+     */
+    @PreAuthorize("@ss.hasPermi('qw:sop:list')")
+    @GetMapping("/list")
+    public TableDataInfo list(QwSop qwSop)
+    {
+        startPage();
+        List<QwSop> list = qwSopService.selectQwSopList(qwSop);
+        return getDataTable(list);
+    }
+
+    /**
+     * 查询aiChatsop列表
+     */
+    @GetMapping("/listAiChatSop")
+    public TableDataInfo listAiChatSop(QwSop qwSop)
+    {
+        startPage();
+        List<QwSop> list = qwSopService.selectAiChatQwSopList(qwSop);
+        return getDataTable(list);
+    }
+    @GetMapping("/courseList")
+    public R courseList()
+    {
+        List<OptionsVO> optionsVOS = fsUserCourseMapper.selectFsUserCourseAllList();
+        return R.ok().put("list", optionsVOS);
+    }
+
+    @GetMapping(value = "/videoList/{id}")
+    public R videoList(@PathVariable("id") Long id)
+    {
+        List<OptionsVO> optionsVOS = fsUserCourseVideoMapper.selectFsUserCourseVodeAllList(id);
+        return R.ok().put("list", optionsVOS);
+    }
+    /**
+     * 查询企微sop列表-我的
+     */
+    @PreAuthorize("@ss.hasPermi('qw:sop:myList')")
+    @GetMapping("/myList")
+    public TableDataInfo myList(QwSop qwSop)
+    {
+        startPage();
+        List<QwSop> list = qwSopService.selectQwSopMyList(qwSop);
+        return getDataTable(list);
+    }
+    /**
+     * 导出企微sop列表
+     */
+    @PreAuthorize("@ss.hasPermi('qw:sop:export')")
+    @Log(title = "企微sop", businessType = BusinessType.EXPORT)
+    @GetMapping("/export")
+    public AjaxResult export(QwSop qwSop)
+    {
+        List<QwSop> list = qwSopService.selectQwSopList(qwSop);
+        ExcelUtil<QwSop> util = new ExcelUtil<QwSop>(QwSop.class);
+        return util.exportExcel(list, "企微sop数据");
+    }
+
+    /**
+     * 获取企微sop详细信息
+     */
+    @GetMapping(value = "/{id}")
+    public AjaxResult getInfo(@PathVariable("id") String id)
+    {
+        return AjaxResult.success(qwSopService.selectQwSopById(id));
+    }
+
+    /**
+     * 新增企微sop
+     */
+    @PreAuthorize("@ss.hasPermi('qw:sop:add')")
+    @Log(title = "企微sop", businessType = BusinessType.INSERT)
+    @PostMapping
+    public AjaxResult add(@RequestBody QwSop qwSop)
+    {
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+        LoginUser loginUser = tokenService.getLoginUser(ServletUtils.getRequest());
+        qwSop.setCreateBy(loginUser.getUser().getNickName());
+        qwSop.setCreateTime(sdf.format(new Date()));
+
+        return toAjax(qwSopService.insertQwSop(qwSop));
+
+    }
+
+    /**
+     * 修改企微sop
+     */
+    @PreAuthorize("@ss.hasPermi('qw:sop:edit')")
+    @Log(title = "修改企微sop", businessType = BusinessType.UPDATE)
+    @PutMapping
+    public R edit(@RequestBody QwSop qwSop)
+    {
+        return qwSopService.updateQwSop(qwSop);
+    }
+
+
+    /**
+     * 暂停企微sop
+     */
+    @Log(title = "暂停企微sop", businessType = BusinessType.UPDATE)
+    @PostMapping("/updateSopStatus")
+    @RepeatSubmit
+    public R  updateSopStatus(@RequestBody QwSopUpdateStatus param)
+    {
+        return qwSopService.updateSopStatus(param);
+    }
+
+    /**
+     * 修改企微sop自动创建时间
+     */
+    @Log(title = "企微sop自动创建时间", businessType = BusinessType.UPDATE)
+    @PostMapping("/updateAutoSopTime")
+    @RepeatSubmit
+    public AjaxResult updateAutoSopTime(@RequestBody QwSopAutoTime param)
+    {
+        return toAjax(qwSopService.updateAutoSopTime(param));
+    }
+
+    /**
+     * 删除企微sop
+     */
+    @PreAuthorize("@ss.hasPermi('qw:sop:remove')")
+    @Log(title = "企微sop", businessType = BusinessType.DELETE)
+	@DeleteMapping("/{ids}")
+    public AjaxResult remove(@PathVariable String[] ids)
+    {
+        return toAjax(qwSopService.deleteQwSopByIds(ids));
+    }
+
+
+    /**
+     * 批量执行SOP
+     */
+    @GetMapping(value = "/updateStatus/{ids}")
+    public R batchDoSop(@PathVariable String[] ids)
+    {
+        return qwSopService.updateStatusQwSopByIds(ids);
+    }
+
+    /**
+     * 修改sop员工
+     */
+    @PostMapping( "/updateSopQwUser")
+    @Log(title = "修改sop员工", businessType = BusinessType.UPDATE)
+    @PreAuthorize("@ss.hasPermi('qw:sop:updateSopQwUser')")
+    public R updateSopQwUser(@RequestBody QwSopEditQwUserParam param)
+    {
+        return qwSopService.updateSopQwUser(param);
+    }
+
+    /**
+    * 服务器图片地址 转 企业微信地址
+    */
+    @PostMapping(value = "/updateMediaImage")
+    public R updateMediaImage(@RequestParam("url") String url) throws IOException {
+
+        String  cropId=null;
+        return qwSopService.updateMediaImage(url,cropId);
+    }
+    /**
+    * 服务器图片地址 转 企业微信地址
+    */
+    @GetMapping(value = "/getSopVoiceList")
+    public TableDataInfo getSopVoiceList(String id) {
+        startPage();
+        List<SopVoiceListVo> list = qwSopService.getSopVoiceList(id);
+        return getDataTable(list);
+    }
+}

fs-admin/src/main/java/com/fs/qw/controller/QwSopTempController.java

@@ -5,8 +5,14 @@ import com.fs.common.core.controller.BaseController;
 import com.fs.common.core.domain.AjaxResult;
 import com.fs.common.core.page.TableDataInfo;
 import com.fs.common.enums.BusinessType;
+import com.fs.common.utils.ServletUtils;
 import com.fs.common.utils.poi.ExcelUtil;
+import com.fs.core.security.LoginUser;
+import com.fs.core.web.service.TokenService;
+import com.fs.qw.vo.SortDayVo;
 import com.fs.sop.domain.QwSopTemp;
+import com.fs.sop.domain.QwSopTempDay;
+import com.fs.sop.params.QwSopShareTempParam;
 import com.fs.sop.service.IQwSopTempService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.security.access.prepost.PreAuthorize;
@@ -28,14 +34,18 @@ public class QwSopTempController extends BaseController
 {
     @Autowired
     private IQwSopTempService qwSopTempService;
+    @Autowired
+    private TokenService tokenService;
     /**
      * 查询sop模板列表
      */
+    @PreAuthorize("@ss.hasPermi('qw:sopTemp:list')")
     @GetMapping("/list")
     public TableDataInfo list(QwSopTemp qwSopTemp)
     {
         startPage();
-        List<QwSopTemp> list = qwSopTempService.selectQwSopTempList(qwSopTemp);
+//        List<QwSopTemp> list = qwSopTempService.selectQwSopTempList(qwSopTemp);
+        List<QwSopTemp> list = qwSopTempService.selectQwSopTempListNew(qwSopTemp);
         return getDataTable(list);
     }
 
@@ -60,15 +70,13 @@ public class QwSopTempController extends BaseController
     {
         return AjaxResult.success(qwSopTempService.selectQwSopTempById(id));
     }
-
     /**
      * 新增sop模板
      */
     @PreAuthorize("@ss.hasPermi('qw:sopTemp:add')")
     @Log(title = "sop模板", businessType = BusinessType.INSERT)
     @PostMapping
-    public AjaxResult add(@RequestBody QwSopTemp qwSopTemp)
-    {
+    public AjaxResult add(@RequestBody QwSopTemp qwSopTemp){
         return toAjax(qwSopTempService.insertQwSopTemp(qwSopTemp));
     }
 
@@ -99,4 +107,70 @@ public class QwSopTempController extends BaseController
 //        qwSopTempService.deleteQwSopTempByIds(ids);
         return toAjax(qwSopTempService.updateQwSopTempByIds(ids));
     }
+
+    /** 分享sop模板 */
+    @PreAuthorize("@ss.hasPermi('qw:sopTemp:share')")
+    @Log(title = "分享sop模板", businessType = BusinessType.DELETE)
+    @PostMapping("/shareTemp")
+    public AjaxResult shareTemp(@RequestBody QwSopShareTempParam param)
+    {
+        return toAjax(qwSopTempService.shareQwSopTemp(param));
+    }
+
+
+
+    @PreAuthorize("@ss.hasPermi('qw:sopTemp:add')")
+    @Log(title = "sop模板", businessType = BusinessType.INSERT)
+    @PostMapping("/add")
+    public AjaxResult addNew(@RequestBody QwSopTemp qwSopTemp){
+        LoginUser loginUser = tokenService.getLoginUser(ServletUtils.getRequest());
+        qwSopTemp.setCreateBy(loginUser.getUser().getUserId().toString());
+        int i = qwSopTempService.addNew(qwSopTemp);
+        if(qwSopTemp.getSendType() == 5){
+            qwSopTempService.createSopTempRules(qwSopTemp);
+        }
+        return toAjax(i);
+    }
+    @PreAuthorize("@ss.hasPermi('qw:sopTemp:edit')")
+    @Log(title = "sop模板", businessType = BusinessType.UPDATE)
+    @PostMapping("/update")
+    public AjaxResult updateNew(@RequestBody QwSopTemp qwSopTemp){
+        int update = qwSopTempService.update(qwSopTemp);
+        return toAjax(update);
+    }
+    @PreAuthorize("@ss.hasPermi('qw:sopTemp:edit')")
+    @Log(title = "sop模板规则", businessType = BusinessType.UPDATE)
+    @PostMapping("/addOrUpdateSetting")
+    public AjaxResult addOrUpdateSetting(@RequestBody QwSopTempDay day){
+        return AjaxResult.success(qwSopTempService.addOrUpdateSetting(day));
+    }
+    @PreAuthorize("@ss.hasPermi('qw:sopTemp:edit')")
+    @Log(title = "sop模板规则", businessType = BusinessType.DELETE)
+    @GetMapping("/delRules")
+    public AjaxResult delRules(Long id){
+        qwSopTempService.delRules(id);
+        return toAjax(1);
+    }
+    @PreAuthorize("@ss.hasPermi('qw:sopTemp:list')")
+    @GetMapping("/selectRulesInfo")
+    public AjaxResult selectRulesInfo(Long id){
+        return AjaxResult.success(qwSopTempService.selectRulesInfo(id));
+    }
+    @PreAuthorize("@ss.hasPermi('qw:sopTemp:edit')")
+    @PostMapping("/copyTemplate")
+    public AjaxResult copyTemplate(@RequestBody QwSopTemp qwSopTemp){
+        qwSopTempService.copyTemplate(qwSopTemp);
+        return toAjax(1);
+    }
+    @PreAuthorize("@ss.hasPermi('qw:sopTemp:edit')")
+    @PostMapping("/sortDay")
+    public AjaxResult sortDay(@RequestBody List<SortDayVo> list){
+        qwSopTempService.sortDay(list);
+        return toAjax(1);
+    }
+    @PreAuthorize("@ss.hasPermi('qw:sopTemp:edit')")
+    @GetMapping("/dayList")
+    public AjaxResult dayList(String id){
+        return AjaxResult.success(qwSopTempService.dayList(id));
+    }
 }

fs-company/src/main/resources/application.yml

@@ -43,8 +43,8 @@ spring:
     # 国际化资源文件路径
     basename: i18n/messages
   profiles:
-#    active: dev
-    active: druid
+    active: dev
+#    active: druid
     include: config
   # 文件上传
   servlet:

fs-qw-task/src/main/resources/application.yml

@@ -43,8 +43,8 @@ spring:
     # 国际化资源文件路径
     basename: i18n/messages
   profiles:
-    active: druid
-#    active: dev
+#    active: druid
+    active: dev
     include: config
   # 文件上传
   servlet:

fs-service-system/src/main/java/com/fs/course/domain/FsUserCourseVideo.java

@@ -1,9 +1,12 @@
 package com.fs.course.domain;
 
+import com.fasterxml.jackson.annotation.JsonFormat;
 import com.fs.common.annotation.Excel;
 import com.fs.common.core.domain.BaseEntity;
 import lombok.Data;
 
+import java.time.LocalTime;
+
 /**
  * 课堂视频对象 fs_user_course_video
  *
@@ -85,4 +88,13 @@ public class FsUserCourseVideo extends BaseEntity
 
     private String transcodeFileKey;//转码的文件key
 
+    @JsonFormat(pattern = "HH:mm:ss")
+    private LocalTime viewStartTime;//转码的文件key
+
+    @JsonFormat(pattern = "HH:mm:ss")
+    private LocalTime viewEndTime;//转码的文件key
+
+    @JsonFormat(pattern = "HH:mm:ss")
+    private LocalTime lastJoinTime;//转码的文件key
+
 }

fs-service-system/src/main/java/com/fs/course/mapper/FsUserCourseVideoMapper.java

@@ -4,6 +4,7 @@ import java.util.List;
 import java.util.Map;
 
 import com.fs.course.domain.FsUserCourseVideo;
+import com.fs.course.param.CourseVideoUpdates;
 import com.fs.course.param.FsUserCourseVideoListUParam;
 import com.fs.course.param.FsUserCourseVideoParam;
 import com.fs.course.param.newfs.UserCourseVideoPageParam;
@@ -166,4 +167,5 @@ public interface FsUserCourseVideoMapper
 
     List<FsUserCourseVideoPageListVO> selectFsUserCourseVideoPageList(UserCourseVideoPageParam param);
 
+    void updates(CourseVideoUpdates vo);
 }

fs-service-system/src/main/java/com/fs/course/param/CourseVideoUpdates.java

@@ -0,0 +1,23 @@
+package com.fs.course.param;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+
+import java.time.LocalTime;
+import java.util.List;
+
+@Data
+public class CourseVideoUpdates {
+
+    private List<Long> ids;
+
+    @JsonFormat(pattern = "HH:mm:ss")
+    private LocalTime viewStartTime;//转码的文件key
+
+    @JsonFormat(pattern = "HH:mm:ss")
+    private LocalTime viewEndTime;//转码的文件key
+
+    @JsonFormat(pattern = "HH:mm:ss")
+    private LocalTime lastJoinTime;//转码的文件key
+
+}

fs-service-system/src/main/java/com/fs/course/service/IFsUserCourseVideoService.java

@@ -144,4 +144,5 @@ public interface IFsUserCourseVideoService
      */
     R updateWatchDurationWx(FsUserCourseVideoUParam param);
 
+    void updates(CourseVideoUpdates vo);
 }

fs-service-system/src/main/java/com/fs/course/service/impl/FsUserCourseVideoServiceImpl.java

@@ -1014,6 +1014,11 @@ public class FsUserCourseVideoServiceImpl implements IFsUserCourseVideoService
         }
     }
 
+    @Override
+    public void updates(CourseVideoUpdates vo) {
+        fsUserCourseVideoMapper.updates(vo);
+    }
+
     //会员-更新心跳时间
     public void updateHeartbeatWx(FsUserCourseVideoUParam param) {
         String redisKey = "h5wxuser:watch:heartbeat:" + param.getUserId() + ":" + param.getVideoId();

fs-service-system/src/main/java/com/fs/course/vo/FsUserCourseVideoQVO.java

@@ -1,10 +1,12 @@
 package com.fs.course.vo;
 
+import com.fasterxml.jackson.annotation.JsonFormat;
 import com.fs.common.annotation.Excel;
 import com.fs.common.core.domain.BaseEntity;
 import com.fs.course.domain.FsCourseQuestionBank;
 import lombok.Data;
 
+import java.time.LocalTime;
 import java.util.List;
 
 /**
@@ -82,4 +84,12 @@ public class FsUserCourseVideoQVO extends BaseEntity {
 
     private String packageJson;
     private Integer isFirst;
+    @JsonFormat(pattern = "HH:mm:ss")
+    private LocalTime viewStartTime;//转码的文件key
+
+    @JsonFormat(pattern = "HH:mm:ss")
+    private LocalTime viewEndTime;//转码的文件key
+
+    @JsonFormat(pattern = "HH:mm:ss")
+    private LocalTime lastJoinTime;//转码的文件key
 }

fs-service-system/src/main/java/com/fs/sop/domain/QwSop.java

@@ -123,7 +123,7 @@ public class QwSop implements Serializable {
     private Integer courseDateNum;
     // 新课对话模板
     private String newTemplateId;
-    private String project;
+    private Long project;
     // 群聊ID
     private String chatId;
 

fs-service-system/src/main/java/com/fs/sop/domain/QwSopTemp.java

@@ -61,7 +61,8 @@ public class QwSopTemp implements Serializable
     private String updateTime;
 
     private String createBy;
-    private String project;
+    private Long project;
+    private Long courseId;
 
     @TableField(exist = false)
     private List<Map<String, Object>> rules;
@@ -69,5 +70,7 @@ public class QwSopTemp implements Serializable
     private boolean cuoser;
     @TableField(exist = false)
     private List<QwSopTempDay> list = new ArrayList<>();
+    @TableField(exist = false)
+    private List<String> timeList;
 
 }

fs-service-system/src/main/java/com/fs/sop/service/IQwSopTempService.java

@@ -90,4 +90,6 @@ public interface IQwSopTempService
     void sortDay(List<SortDayVo> list);
 
     List<QwSopTempDay> dayList(String id);
+
+    void createSopTempRules(QwSopTemp qwSopTemp);
 }

fs-service-system/src/main/java/com/fs/sop/service/impl/QwSopTempServiceImpl.java

@@ -7,8 +7,13 @@ import com.fs.common.annotation.DataSource;
 import com.fs.common.enums.DataSourceType;
 import com.fs.common.exception.base.BaseException;
 import com.fs.common.utils.PubFun;
+import com.fs.course.domain.FsUserCourse;
+import com.fs.course.domain.FsUserCourseVideo;
+import com.fs.course.mapper.FsUserCourseMapper;
+import com.fs.course.mapper.FsUserCourseVideoMapper;
 import com.fs.fastGpt.domain.FastGptChatReplaceWords;
 import com.fs.fastGpt.mapper.FastGptChatReplaceWordsMapper;
+import com.fs.qw.vo.QwSopTempSetting2;
 import com.fs.qw.vo.SortDayVo;
 import com.fs.sop.domain.QwSopTemp;
 import com.fs.sop.domain.QwSopTempContent;
@@ -21,10 +26,13 @@ import com.fs.sop.vo.VoiceVo;
 import lombok.AllArgsConstructor;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.text.SimpleDateFormat;
 import java.time.LocalTime;
+import java.time.format.DateTimeFormatter;
 import java.util.*;
+import java.util.concurrent.atomic.AtomicInteger;
 import java.util.function.Consumer;
 import java.util.stream.Collectors;
 
@@ -45,6 +53,8 @@ public class QwSopTempServiceImpl implements IQwSopTempService
     private final IQwSopTempContentService qwSopTempContentService;
     private final IQwSopTempVoiceService qwSopTempVoiceService;
     private final RocketMQTemplate rocketMQTemplate;
+    private final FsUserCourseMapper fsUserCourseMapper;
+    private final FsUserCourseVideoMapper fsUserCourseVideoMapper;
 
     /**
      * 查询sop模板
@@ -56,6 +66,7 @@ public class QwSopTempServiceImpl implements IQwSopTempService
     public QwSopTemp selectQwSopTempById(String id){
 //        QwSopTemp qwSopTemp = qwSopTempMapper.selectQwSopTempById(id);
         QwSopTemp qwSopTemp = qwSopTempMapper.selectQwSopTempById(id);
+        if(qwSopTemp == null) return null;
         List<QwSopTempDay> qwSopTempDays = qwSopTempDayService.listByTempId(id);
         qwSopTemp.setList(qwSopTempDays);
 //        List<QwSopTempRules> rulesList = qwSopTempRulesService.listByTempId(id);
@@ -164,6 +175,7 @@ public class QwSopTempServiceImpl implements IQwSopTempService
         return qwSopTempMapper.deleteQwSopTempById(id);
     }
 
+
     @Override
     public int addNew(QwSopTemp qwSopTemp) {
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@@ -172,6 +184,82 @@ public class QwSopTempServiceImpl implements IQwSopTempService
         return qwSopTempMapper.insertQwSopTemp(qwSopTemp);
     }
 
+    @Override
+    public void createSopTempRules(QwSopTemp temp) {
+        FsUserCourse fsUserCourse = fsUserCourseMapper.selectFsUserCourseByCourseId(temp.getCourseId());
+        temp.setProject(fsUserCourse.getProject());
+        qwSopTempMapper.updateQwSopTemp(temp);
+        List<FsUserCourseVideo> videoList = fsUserCourseVideoMapper.selectVideoByCourseId(fsUserCourse.getCourseId());
+        AtomicInteger i = new AtomicInteger(1);
+        Integer gap = temp.getGap();
+        List<QwSopTempDay> collect = videoList.stream().map(e -> {
+            QwSopTempDay day = new QwSopTempDay();
+            day.setTempId(temp.getId());
+            day.setDayNum(i.getAndIncrement() * gap);
+            day.setName("第" + day.getDayNum() + "天");
+            day.setSorts(day.getDayNum());
+            day.setList(new ArrayList<>());
+            QwSopTempRules rules = new QwSopTempRules();
+            rules.setTempId(temp.getId());
+            rules.setName(day.getName());
+            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("HH:mm");
+            rules.setTime(e.getViewStartTime().format(formatter));
+            rules.setContentType(2);
+            rules.setType(2);
+            rules.setCourseType(0);
+            rules.setCourseId(e.getCourseId());
+            rules.setVideoId(e.getVideoId());
+            rules.setSorts(0);
+            day.getList().add(rules);
+            QwSopTempContent content = new QwSopTempContent();
+            content.setTempId(temp.getId());
+            content.setContentType(3);
+            QwSopTempSetting2.Content.Setting setting = new QwSopTempSetting2.Content.Setting();
+            setting.setLinkTitle(fsUserCourse.getCourseName());
+            setting.setIsBindUrl(1);
+            setting.setLinkDescribe(e.getTitle());
+            setting.setLinkImageUrl(fsUserCourse.getImgUrl());
+            setting.setContentType("3");
+            content.setContent(JSON.toJSONString(setting));
+            content.setIsBindUrl(1);
+            rules.setList(Collections.singletonList(content));
+
+
+
+            if(temp.getTimeList() != null &&  !temp.getTimeList().isEmpty()){
+                AtomicInteger sorts = new AtomicInteger(1);
+                List<QwSopTempRules> rulesList = temp.getTimeList().stream().map(time -> {
+                    QwSopTempRules rulesSub = new QwSopTempRules();
+                    rulesSub.setTempId(temp.getId());
+                    rulesSub.setName(day.getName());
+                    rulesSub.setTime(time);
+                    rulesSub.setContentType(1);
+                    rulesSub.setType(1);
+                    rulesSub.setSorts(sorts.getAndIncrement());
+                    QwSopTempContent contentSbu = new QwSopTempContent();
+                    contentSbu.setTempId(temp.getId());
+                    contentSbu.setContentType(1);
+                    QwSopTempSetting2.Content.Setting settingSub = new QwSopTempSetting2.Content.Setting();
+                    settingSub.setContentType("1");
+                    settingSub.setValue("");
+                    contentSbu.setContent(JSON.toJSONString(settingSub));
+                    rulesSub.setList(Collections.singletonList(contentSbu));
+                    return rulesSub;
+                }).collect(Collectors.toList());
+                day.getList().addAll(rulesList);
+            }
+            return day;
+        }).collect(Collectors.toList());
+        qwSopTempDayService.addOrUpdateBatch(collect);
+        List<QwSopTempRules> ruleList = collect.stream().flatMap(e -> e.getList().stream().peek(r -> r.setDayId(e.getId()))).collect(Collectors.toList());
+        qwSopTempRulesService.saveList(ruleList);
+        List<QwSopTempContent> contentList = ruleList.stream().flatMap(e -> e.getList().stream().peek(r -> {
+            r.setDayId(e.getDayId());
+            r.setRulesId(e.getId());
+        })).collect(Collectors.toList());
+        qwSopTempContentService.saveList(contentList);
+    }
+
     @Override
     @DataSource(DataSourceType.SOP)
     public int update(QwSopTemp qwSopTemp) {

fs-service-system/src/main/resources/mapper/course/FsUserCourseVideoMapper.xml

@@ -32,10 +32,13 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <result property="packageJson"    column="package_json"    />
         <result property="isTranscode"    column="is_transcode"    />
         <result property="transcodeFileKey"    column="transcode_file_key"    />
+        <result property="viewStartTime"    column="view_start_time"    />
+        <result property="viewEndTime"    column="view_end_time"    />
+        <result property="lastJoinTime"    column="last_join_time"    />
     </resultMap>
 
     <sql id="selectFsUserCourseVideoVo">
-        select video_id,line_one,package_json,is_transcode,transcode_file_key,file_size,file_key,round,red_packet_money,line_two,upload_type,line_three, file_id,file_name,is_del, title, description, video_url, thumbnail, duration, update_time, create_time, talent_id, course_id, status, course_sort, question_bank_id from fs_user_course_video
+        select * from fs_user_course_video
     </sql>
 
     <select id="selectFsUserCourseVideoList" parameterType="FsUserCourseVideo" resultMap="FsUserCourseVideoResult">
@@ -89,6 +92,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="packageJson != null">package_json,</if>
             <if test="isTranscode != null">is_transcode,</if>
             <if test="transcodeFileKey != null">transcode_file_key,</if>
+            <if test="viewStartTime != null">view_start_time,</if>
+            <if test="viewEndTime != null">view_end_time,</if>
+            <if test="lastJoinTime != null">last_join_time,</if>
          </trim>
         <trim prefix="values (" suffix=")" suffixOverrides=",">
             <if test="fileId != null">#{fileId},</if>
@@ -117,6 +123,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="packageJson != null">#{packageJson},</if>
             <if test="isTranscode != null">#{isTranscode},</if>
             <if test="transcodeFileKey != null">#{transcodeFileKey},</if>
+            <if test="viewStartTime != null">#{viewStartTime},</if>
+            <if test="viewEndTime != null">#{viewEndTime},</if>
+            <if test="lastJoinTime != null">#{lastJoinTime},</if>
          </trim>
     </insert>
 
@@ -149,6 +158,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="packageJson != null">package_json = #{packageJson},</if>
             <if test="isTranscode != null">is_transcode = #{isTranscode},</if>
             <if test="transcodeFileKey != null">transcode_file_key = #{transcodeFileKey},</if>
+            <if test="viewStartTime != null">view_start_time = #{viewStartTime},</if>
+            <if test="viewEndTime != null">view_end_time = #{viewEndTime},</if>
+            <if test="lastJoinTime != null">last_join_time = #{lastJoinTime},</if>
         </trim>
         where video_id = #{videoId}
     </update>
@@ -163,6 +175,12 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             #{videoId}
         </foreach>
     </update>
+    <update id="updates">
+        update fs_user_course_video set view_start_time = #{viewStartTime},view_end_time = #{viewEndTime},last_join_time = #{lastJoinTime} where video_id in
+        <foreach item="videoId" collection="ids" open="(" separator="," close=")">
+            #{videoId}
+        </foreach>
+    </update>
 
     <select id="selectFsUserCourseVideoPageList" resultType="FsUserCourseVideoPageListVO">
         SELECT

fs-service-system/src/main/resources/mapper/sop/QwSopTempMapper.xml

@@ -74,6 +74,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="data.gap != null">gap,</if>
             <if test="data.sendType != null">send_type,</if>
             <if test="data.updateTime != null">update_time,</if>
+            <if test="data.project != null">project,</if>
+            <if test="data.courseId != null">course_id,</if>
          </trim>
         <trim prefix="values (" suffix=")" suffixOverrides=",">
             <if test="data.id != null">#{data.id},</if>
@@ -87,6 +89,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="data.gap != null">#{data.gap},</if>
             <if test="data.sendType != null">#{data.sendType},</if>
             <if test="data.updateTime != null">#{data.updateTime},</if>
+            <if test="data.project != null">#{data.project},</if>
+            <if test="data.courseId != null">#{data.courseId},</if>
          </trim>
     </insert>
 
@@ -104,6 +108,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="data.sendType != null">send_type = #{data.sendType},</if>
             <if test="data.updateTime != null">update_time = #{data.updateTime},</if>
             <if test="data.project != null">project = #{data.project},</if>
+            <if test="data.courseId != null">course_id = #{data.courseId},</if>
         </trim>
         where id = #{data.id}
     </update>