From edb19b1fec14d667363b38b90dbb4585a0cc37ef Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 04 Mar 2021 11:32:42 +0800
Subject: [PATCH] 20210304   消息提醒日志

---
 src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java |   13 ++++++++++++-
 1 files changed, 12 insertions(+), 1 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java b/src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java
index 413965b..cd0d7e9 100644
--- a/src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java
@@ -88,9 +88,19 @@
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void addFollowerOrder(Long id) {
-        log.info("进入跟单处理逻辑");
+        log.info("进入跟单处理逻辑 : {}", id);
         // 查询交易员订单
         ContractHoldOrderEntity holdOrderEntity = contractHoldOrderDao.selectById(id);
+
+        while (holdOrderEntity == null) {
+            try {
+                log.info("等待事务提交:{}", id);
+                Thread.sleep(200);
+                holdOrderEntity = contractHoldOrderDao.selectById(id);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }
 
         List<FollowFollowerSettingEntity> followerSettings = followFollowerSettingDao.selectAllFollowerSettingByTradeMemberId(holdOrderEntity.getMemberId());
         log.info("进入跟单处理逻辑---跟单人数"+followerSettings.size());
@@ -220,6 +230,7 @@
                     //更新更新消息提醒的状态
                     MemberSettingEntity memberSettingEntity = memberSettingDao.selectMemberSettingByMemberId(memberEntity.getId());
                     if(ObjectUtil.isNotEmpty(memberSettingEntity)){
+                    	log.info("更新更新消息提醒的状态");
                     	memberSettingEntity.setMessageReminder(1);
                     	memberSettingDao.updateById(memberSettingEntity);
                     }

--
Gitblit v1.9.1