exchange.git - Gitblit

			@@ -6,6 +6,7 @@
			import com.alibaba.fastjson.JSONObject;
			import com.baomidou.mybatisplus.core.conditions.Wrapper;
			import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
			import com.xcong.excoin.common.contants.AppContants;
			import com.xcong.excoin.common.enumerates.CoinTypeEnum;
			import com.xcong.excoin.common.enumerates.MemberWalletCoinEnum;
			import com.xcong.excoin.common.enumerates.RabbitPriceTypeEnum;
			@@ -35,10 +36,7 @@
			import com.xcong.excoin.rabbit.pricequeue.OrderModel;
			import com.xcong.excoin.rabbit.producer.FollowProducer;
			import com.xcong.excoin.rabbit.producer.OrderProducer;
			import com.xcong.excoin.utils.CacheSettingUtils;
			import com.xcong.excoin.utils.CalculateUtil;
			import com.xcong.excoin.utils.LogRecordUtils;
			import com.xcong.excoin.utils.ThreadPoolUtils;
			import com.xcong.excoin.utils.*;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.stereotype.Service;
			@@ -89,7 +87,8 @@
			private FollowProducer followProducer;
			@Autowired
			private FollowTraderProfitDetailDao followTraderProfitDetailDao;

			@Resource
			private RedisUtils redisUtils;

			@Override
			@Transactional(rollbackFor = Exception.class)
			@@ -123,8 +122,17 @@
			Long tradeMemberId = holdOrderEntity.getMemberId();
			if (CollUtil.isNotEmpty(followerSettings)) {
			for (FollowFollowerSettingEntity followerSetting : followerSettings) {
			// 加redis锁，同一个用户不能同时触发两个跟单任务，否则会出现金额问题
			while(true) {
			Long followerMemberId = (Long) redisUtils.get(AppContants.MEMBER_HAS_FOLLOW);
			log.info("#跟单用户任务已存在:{}#", followerMemberId);
			if (followerMemberId == null) {
			log.info("跳出");
			break;
			}
			}

			//更新更新消息提醒的状态
			//更新更新消息提醒的状态
			MemberSettingEntity memberSettingEntity = memberSettingDao.selectMemberSettingByMemberId(followerSetting.getMemberId());
			if(ObjectUtil.isNotEmpty(memberSettingEntity)){
			Long memberId = memberSettingEntity.getMemberId();
			@@ -243,6 +251,8 @@
			LogRecordUtils.insertFollowerNotice(memberEntity.getId(), NoticeConstant.OPEN_ORDER_TITLE, StrUtil.format(NoticeConstant.OPEN_ORDER_CONTENT, holdOrderEntity.getSymbol() + "开空", openPrice.setScale(2, BigDecimal.ROUND_HALF_UP).toString(), followTraderInfoEntity.getNickname()));
			}
			}

			redisUtils.del(AppContants.MEMBER_HAS_FOLLOW);
			}
			}
			}

	src/main/java/com/xcong/excoin/common/contants/AppContants.java	1 ●●●●● patch \| view \| raw \| blame \| history
	src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java	22 ●●●●● patch \| view \| raw \| blame \| history

			@@ -89,5 +89,6 @@

			public static final String HOLD_BOND_RATIO = "hold_bond_ratio";
			public static final String WHOLE_BOMB_MAP = "whole_bomb_map";
			public static final String MEMBER_HAS_FOLLOW = "follower_member_id";

			}