Commit ed940b11 by lili

加上异步处理

parent 04ff7ca9
...@@ -300,7 +300,9 @@ public class BookAppealBizImpl implements BookAppealBiz { ...@@ -300,7 +300,9 @@ public class BookAppealBizImpl implements BookAppealBiz {
bookAdviser.setCreatedUser(bookAdviser.getAdviserId()); bookAdviser.setCreatedUser(bookAdviser.getAdviserId());
if (bookAdviser.getIsMainEditor()){ if (bookAdviser.getIsMainEditor()){
//删除书架上书籍 //删除书架上书籍
EXECUTOR_SERVICE.execute(()->{
bookcaseConsr.changeBookAdviser(bookAdviser.getAdviserId(), bookAdviser.getChannelId(), bookAdviser.getBookId()); bookcaseConsr.changeBookAdviser(bookAdviser.getAdviserId(), bookAdviser.getChannelId(), bookAdviser.getBookId());
});
mainAdviserId = bookAdviser.getAdviserId(); mainAdviserId = bookAdviser.getAdviserId();
} }
// 若为申诉编辑,设置申诉编辑图书类型 // 若为申诉编辑,设置申诉编辑图书类型
...@@ -311,7 +313,9 @@ public class BookAppealBizImpl implements BookAppealBiz { ...@@ -311,7 +313,9 @@ public class BookAppealBizImpl implements BookAppealBiz {
// 批量修改图书编辑关联关系 // 批量修改图书编辑关联关系
bookAdviserDao.insert(bookMainAdviserDto.getBookAdviserList()); bookAdviserDao.insert(bookMainAdviserDto.getBookAdviserList());
// 新增申诉编辑图书与二维码关联关系 // 新增申诉编辑图书与二维码关联关系
EXECUTOR_SERVICE.execute(()-> {
recoverBookQrcodeAssoc(bookId, bookAppealDto.getChannelId(), appealAdviserId); recoverBookQrcodeAssoc(bookId, bookAppealDto.getChannelId(), appealAdviserId);
});
} }
// 修改申诉状态 // 修改申诉状态
...@@ -338,6 +342,7 @@ public class BookAppealBizImpl implements BookAppealBiz { ...@@ -338,6 +342,7 @@ public class BookAppealBizImpl implements BookAppealBiz {
public void setOnlyOneAdviser(Long bookId, Long declarant, Long channelId, Long templetId, List<BookAdviserDto> adviserBooks) { public void setOnlyOneAdviser(Long bookId, Long declarant, Long channelId, Long templetId, List<BookAdviserDto> adviserBooks) {
//删除其余编辑与图书关联关系 //删除其余编辑与图书关联关系
bookAdviserBiz.deleteByBook(bookId); bookAdviserBiz.deleteByBook(bookId);
EXECUTOR_SERVICE.execute(()->{
//批量删除书架书籍 //批量删除书架书籍
adviserBooks.stream().forEach( adviserBooks.stream().forEach(
adviserBook->{ adviserBook->{
...@@ -346,6 +351,7 @@ public class BookAppealBizImpl implements BookAppealBiz { ...@@ -346,6 +351,7 @@ public class BookAppealBizImpl implements BookAppealBiz {
qrcodeSceneConsr.deleteBook(bookId, adviserBook.getChannelId(), adviserBook.getAdviserId()); qrcodeSceneConsr.deleteBook(bookId, adviserBook.getChannelId(), adviserBook.getAdviserId());
} }
); );
});
//加上申诉编辑与图书关联关系 //加上申诉编辑与图书关联关系
BookAdviser bookAdviser = new BookAdviser(); BookAdviser bookAdviser = new BookAdviser();
bookAdviser.setAdviserId(declarant); bookAdviser.setAdviserId(declarant);
...@@ -375,6 +381,7 @@ public class BookAppealBizImpl implements BookAppealBiz { ...@@ -375,6 +381,7 @@ public class BookAppealBizImpl implements BookAppealBiz {
private void sendAppealTemplate(Boolean isOnlyOneAdviser, Long appealAdviserId, List<BookAdviserDto> bookAdviserList, Long bookId, Long channelId, Long mainAdviserId) { private void sendAppealTemplate(Boolean isOnlyOneAdviser, Long appealAdviserId, List<BookAdviserDto> bookAdviserList, Long bookId, Long channelId, Long mainAdviserId) {
LOGGER.info("发送申诉审核后的模板消息appealAdviserId=" + appealAdviserId + "bookAdviserList=" + bookAdviserList + LOGGER.info("发送申诉审核后的模板消息appealAdviserId=" + appealAdviserId + "bookAdviserList=" + bookAdviserList +
"bookId=" + bookId + "channelId=" + channelId + "mainAdviserId=" + mainAdviserId); "bookId=" + bookId + "channelId=" + channelId + "mainAdviserId=" + mainAdviserId);
EXECUTOR_SERVICE.execute(()->{
// 获取图书详情 // 获取图书详情
BookDto bookDto = bookBiz.getBaseById(bookId); BookDto bookDto = bookBiz.getBaseById(bookId);
String bookName = bookDto.getBookName(); String bookName = bookDto.getBookName();
...@@ -399,6 +406,9 @@ public class BookAppealBizImpl implements BookAppealBiz { ...@@ -399,6 +406,9 @@ public class BookAppealBizImpl implements BookAppealBiz {
sendAppealSuccessToSubTemplate(bookName, appealAdviserId, channelId); sendAppealSuccessToSubTemplate(bookName, appealAdviserId, channelId);
} }
LOGGER.info("发送申诉审核后的模板消息【END】"); LOGGER.info("发送申诉审核后的模板消息【END】");
});
} }
/** /**
......
...@@ -139,7 +139,6 @@ public class BookAppealFacadeImpl implements BookAppealFacade { ...@@ -139,7 +139,6 @@ public class BookAppealFacadeImpl implements BookAppealFacade {
// token // token
Long auditUser = (Long) SessionUtil.getVlaue(token, SessionUtil.PARTY_ID); Long auditUser = (Long) SessionUtil.getVlaue(token, SessionUtil.PARTY_ID);
bookAppealBiz.setMainAdviser(auditUser, bookMainAdviserDto); bookAppealBiz.setMainAdviser(auditUser, bookMainAdviserDto);
return new ResponseDto<>(); return new ResponseDto<>();
} }
......
...@@ -62,7 +62,8 @@ ...@@ -62,7 +62,8 @@
UPDATE UPDATE
BOOK_ADVISER BOOK_ADVISER
SET SET
IS_DELETE = 1 IS_DELETE = 1,
LAST_MODIFIED_DATE = NOW()
WHERE WHERE
BOOK_ID = #{bookId, jdbcType=BIGINT} BOOK_ID = #{bookId, jdbcType=BIGINT}
</update> </update>
...@@ -72,7 +73,8 @@ ...@@ -72,7 +73,8 @@
UPDATE UPDATE
BOOK_ADVISER BOOK_ADVISER
SET SET
IS_DELETE = 1 IS_DELETE = 1,
LAST_MODIFIED_DATE = NOW()
WHERE WHERE
BOOK_ID IN BOOK_ID IN
<foreach collection="list" index="i" item="item" open="(" separator="," close=")"> <foreach collection="list" index="i" item="item" open="(" separator="," close=")">
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment