modify

Helius

2020-09-08 1fc98d66589965b5b10e09334f715b28ed5ab455

 src/main/java/com/xcong/excoin/rabbit/init/OrderProducerInit.java

@@ -12,10 +12,12 @@
import com.xcong.excoin.rabbit.pricequeue.OrderModel;
import com.xcong.excoin.rabbit.producer.OrderProducer;
import com.xcong.excoin.utils.CalculateUtil;
import com.xcong.excoin.utils.ThreadPoolUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.DependsOn;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
@@ -31,6 +33,7 @@
 * @author helius
 */
@Slf4j
@DependsOn("springContextHolder")
@Component
@ConditionalOnProperty(prefix = "app", name = "newest-price-update-job", havingValue = "true")
public class OrderProducerInit {
@@ -136,7 +139,8 @@
                    memberEntity = memberDao.selectById(memberId);
                }

                CalculateUtil.getForceSetPriceForWhole(symbol, memberEntity);
//                ThreadPoolUtils.sendWholeForceClosingPrice(symbol, memberEntity);
                CalculateUtil.getForceSetPriceForWhole(null, memberEntity);
            }
        }