szx-1277 增加事务注解

This commit is contained in:
Caojr
2025-10-29 15:13:47 +08:00
parent 4110d0632f
commit a72a042636
3 changed files with 22 additions and 26 deletions

View File

@@ -301,6 +301,7 @@ public class CourseManageApi extends ApiBaseController{
* @return * @return
*/ */
@PostMapping("/save") @PostMapping("/save")
@Transactional(rollbackFor = Exception.class)
@AutoLog(module = "课程",action = "保存课程基本信息",info = "") @AutoLog(module = "课程",action = "保存课程基本信息",info = "")
public JsonResponse<CourseFullDto> saveCourseFull(@RequestBody CourseFullDto dto, HttpServletRequest request){ public JsonResponse<CourseFullDto> saveCourseFull(@RequestBody CourseFullDto dto, HttpServletRequest request){
if(dto.getCourse()==null){ if(dto.getCourse()==null){
@@ -322,30 +323,25 @@ public class CourseManageApi extends ApiBaseController{
} }
//填充必要的信息 //填充必要的信息
try { if(StringUtils.isBlank(dto.getCourse().getId())) {
if(StringUtils.isBlank(dto.getCourse().getId())) { //只有在第一次添加保存时才会这样
//只有在第一次添加保存时才会这样 fillCourseData(dto.getCourse());
fillCourseData(dto.getCourse()); courseService.save(dto);
courseService.save(dto); }else {
}else { //修改后重置,重新提交审核,重新发布
//修改后重置,重新提交审核,重新发布 dto.getCourse().setPublished(false);
dto.getCourse().setPublished(false); dto.getCourse().setStatus(Course.STATUS_NONE);
dto.getCourse().setStatus(Course.STATUS_NONE); courseService.update(dto);
courseService.update(dto); }
} String token = request.getHeader("Xboe-Access-Token");
String token = request.getHeader("Xboe-Access-Token"); log.info("---------------在线课开始同步到讲师管理 ------- token = " + token);
log.info("---------------在线课开始同步到讲师管理 ------- token = " + token); CourseParam param = new CourseParam();
CourseParam param = new CourseParam(); param.setId(dto.getCourse().getId());
param.setId(dto.getCourse().getId()); param.setOrgId(dto.getCourse().getOrgId());
param.setOrgId(dto.getCourse().getOrgId()); param.setOrgName(dto.getCourse().getOrgName());
param.setOrgName(dto.getCourse().getOrgName()); thirdApi.updateOrSaveCourse(param,token);
thirdApi.updateOrSaveCourse(param,token); log.info("---------------在线课同步到讲师管理完毕 -------");
log.info("---------------在线课同步到讲师管理完毕 -------"); return success(dto);
return success(dto);
} catch (Exception e) {
log.error("整体保存课程信息错误",e);
return error("保存失败",e.getMessage());
}
} }
/*** /***

View File

@@ -161,7 +161,7 @@ public interface ICourseService {
* 课程信息的整体更新,用于对课程的编辑处理 * 课程信息的整体更新,用于对课程的编辑处理
* @param full * @param full
*/ */
void update(CourseFullDto full)throws Exception; void update(CourseFullDto full);
/** /**
* 提交课程,提交进入课程审核,独立的方法处理 * 提交课程,提交进入课程审核,独立的方法处理

View File

@@ -976,7 +976,7 @@ public class CourseServiceImpl implements ICourseService {
} }
@Override @Override
public void update(CourseFullDto full) throws Exception { public void update(CourseFullDto full) {
Course c = full.getCourse();//当前的课程信息 Course c = full.getCourse();//当前的课程信息
Course nowCourse = courseDao.get(c.getId());//修改之前的课程信息 Course nowCourse = courseDao.get(c.getId());//修改之前的课程信息