modify

Helius

2021-06-08 30c1c9d16a57d2bbc7cd1511d02c5ddcc6a143f6

modify

 src/main/java/com/xcong/excoin/modules/otc/dao/OtcReturnMoneyDao.java

@@ -11,7 +11,7 @@

public interface OtcReturnMoneyDao extends BaseMapper<OtcReturnMoney> {

    IPage<TeamVo> selectMyTeamAmountInPage(String inviteId, Long memberId, Page<TeamVo> page);
    IPage<TeamVo> selectMyTeamAmountInPage(@Param("inviteId") String inviteId, @Param("memberId") Long memberId, Page<TeamVo> page);

    BigDecimal selectTotalAmount(@Param("memberId") Long memberId);
}

 src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcOrderServiceImpl.java

@@ -34,6 +34,7 @@
import com.xcong.excoin.modules.otc.vo.SaleOrderDetailVo;
import com.xcong.excoin.rabbit.producer.OtcProducter;
import com.xcong.excoin.utils.RedisUtils;
import com.xcong.excoin.utils.ThreadPoolUtils;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
@@ -153,6 +154,7 @@
        this.baseMapper.insert(otcOrder);
        this.baseMapper.insert(sale);

        ThreadPoolUtils.sendOrderMsg();
        return Result.ok("购买成功", otcOrder.getId());
    }

@@ -250,6 +252,8 @@
        this.baseMapper.insert(buy);

        memberWalletCoinDao.updateFrozenBalance(member.getId(), wallet.getId(), orderAddDto.getUsdtAmount());

        ThreadPoolUtils.sendOrderMsg();
        return Result.ok("出售成功", otcOrder.getId());
    }


 src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java

@@ -120,4 +120,13 @@
            }
        });
    }

    public static void sendOrderMsg() {
        EXECUTOR.execute(new Runnable() {
            @Override
            public void run() {
                DingTalkUtils.sendOrderMsg();
            }
        });
    }
}

 src/main/java/com/xcong/excoin/utils/dingtalk/DingTalkUtils.java

@@ -86,6 +86,30 @@
        }
    }

    public static void sendOrderMsg() {
        ApplicationProperties properties = SpringContextHolder.getBean(ApplicationProperties.class);
        try {
            DingTalkClient client = initClient(URL, SECRET);
            OapiRobotSendRequest request = new OapiRobotSendRequest();
            request.setMsgtype("actionCard");
            OapiRobotSendRequest.Actioncard actionCard = new OapiRobotSendRequest.Actioncard();
            actionCard.setTitle(properties.getProject() + "--" + "老板开门啊");
            actionCard.setBtnOrientation("1");
            actionCard.setText(properties.getProject() + "--" + "老板关门不好吧");
            List<OapiRobotSendRequest.Btns> btns = new ArrayList<>();
            OapiRobotSendRequest.Btns btn1 = new OapiRobotSendRequest.Btns();
            btn1.setTitle("查看详情");
            btn1.setActionURL("http://baidu.com");
            btns.add(btn1);
            actionCard.setBtns(btns);

            request.setActionCard(actionCard);
            client.execute(request);
        } catch (Exception e) {
            log.error("#dingtalk send error#", e);
        }
    }


    private static String generateSign(Long timestamp, String secret) throws Exception {
        String stringToToken = timestamp + "\n" + secret;