modify

Helius

2021-05-14 e16ab23cc4b872436edf3743f7e9e5639c45d770

 src/main/java/com/xcong/excoin/modules/yunding/service/Impl/XchProfitServiceImpl.java

@@ -16,6 +16,7 @@
import com.xcong.excoin.modules.yunding.entity.YdOrderEntity;
import com.xcong.excoin.modules.yunding.entity.YdProductEntity;
import com.xcong.excoin.modules.yunding.service.XchProfitService;
import com.xcong.excoin.rabbit.producer.YunDingProducter;
import com.xcong.excoin.utils.LogRecordUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -43,6 +44,9 @@

    @Autowired
    private YdBasicLevelSettingDao ydBasicLevelSettingDao;

    @Autowired
    private YunDingProducter yunDingProducter;

    @Override
    @Transactional(rollbackFor = Exception.class)
@@ -147,6 +151,8 @@
    public void usdtProfitDistributorByOrderId(Long id) {
        YdOrderEntity ydOrderEntity = ydOrderDao.selectById(id);
        usdtProfitDistributor(ydOrderEntity);

        yunDingProducter.sendYunDingAutoAgent(ydOrderEntity.getMemberId());
    }

    private void usdtProfitDistributor(YdOrderEntity order) {
@@ -262,6 +268,7 @@
                    LogRecordUtils.insertMemberAccountMoneyChangeWithId(order.getMemberId(), content, remainProfit, "XCH", 1, 4, order.getId());
                    MemberWalletCoinEntity walletCoin = memberWalletCoinDao.selectWalletCoinBymIdAndCode(order.getMemberId(), "XCH");

                    ydOrderDao.updateOrderProfit(remainProfit, order.getId());
                    memberWalletCoinDao.updateBlockBalance(walletCoin.getId(), remainProfit, BigDecimal.ZERO, 0);
                }
            }