moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v1.1: mq日志级别调整、许愿池奖品配置编辑失效修复

Browse Source
This commit is contained in:
lzm
2022-10-24 19:19:47 +08:00
parent fad8e6d42e
commit ce60c57c33
2 changed files with 19 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
accompany-admin/accompany-admin-web/src/main/resources/static/html/prize/prize_admin.html
View File

@@ -87,9 +87,9 @@
<div class="form-group awardChoose">
<label for="awardChoose" class="col-sm-3 control-label">选择礼物：</label>
<div class="col-sm-8">
<select name="awardChoose" id="awardChoose">
<select name="awardChoose" id="awardChoose" onchange="updateAward(this)">
<!-- <option value="0">选取礼物</option> -->
</select>
</div>
@@ -884,10 +884,16 @@
// $('#addForm').find('select option').attr('selected',false);
}
})
// select框监听事件
function updateAward(obj) {
console.log('------------------ change')
// 赋值
let referenceId = parseInt($('#awardChoose').siblings('.combobox-container').find('input:hidden').val())
$('#addForm').data('referenceID',referenceId);
}
</script>

20
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/mq/ActiveMQService.java
View File

@@ -82,7 +82,7 @@ public class ActiveMQService extends BaseService {
* @param message
*/
public void sendOpenBoxMessage(final BoxPrizeMessage message) {
logger.debug("sendOpenBoxMessage message: {}", JSON.toJSONString(message));
logger.info("sendOpenBoxMessage message: {}", JSON.toJSONString(message));
// giftJmsTemplate.send("openbox-queue", new MessageCreator() {
// @Override
// public Message createMessage(Session session) throws JMSException {
@@ -94,18 +94,18 @@ public class ActiveMQService extends BaseService {
public void sendWishStarCupMessage(WishStarCupPrizeMessage message) {
logger.debug("sendWishStarCupMessage message: {}", JSON.toJSONString(message));
logger.info("sendWishStarCupMessage message: {}", JSON.toJSONString(message));
wishStarCupJmsTemplate.convertAndSend("wishstarcup-queue",message);
}
public void sendOpenBoxMessage(BoxPrizeMessage message, String queueName) {
logger.debug("sendOpenBoxMessage on {}, message: {}", queueName, JSON.toJSONString(message));
logger.info("sendOpenBoxMessage on {}, message: {}", queueName, JSON.toJSONString(message));
openBoxJmsTemplate.convertAndSend(queueName,message);
}
public void sendLinearlyPoolDrawMessage(LinearlyPoolPrizeMessage message, String queueName) {
logger.debug("sendLinearlyPoolDrawMessage on {}, message: {}", queueName, JSON.toJSONString(message));
logger.info("sendLinearlyPoolDrawMessage on {}, message: {}", queueName, JSON.toJSONString(message));
linearlyPoolJmsTemplate.convertAndSend(queueName,message);
}
@@ -127,7 +127,7 @@ public class ActiveMQService extends BaseService {
}
public void sendGiftTopicMessage(final GiftMessage giftMessage){
logger.debug("sendGiftTopicMessage({})", giftMessage);
logger.info("sendGiftTopicMessage({})", giftMessage);
// this.giftTopicJmsTemplate.send("accompany-gift-topic", new MessageCreator() {
// @Override
// public Message createMessage(Session session) throws JMSException {
@@ -191,7 +191,7 @@ public class ActiveMQService extends BaseService {
* @param message
*/
public void sendSignDrawGoldMessage(final SignDrawGoldMessage message) {
logger.debug("sendSignDrawGoldMessage message: {}", JSON.toJSONString(message));
logger.info("sendSignDrawGoldMessage message: {}", JSON.toJSONString(message));
// giftJmsTemplate.send("sign-draw-gold-queue", new MessageCreator() {
// @Override
// public Message createMessage(Session session) throws JMSException {
@@ -207,7 +207,7 @@ public class ActiveMQService extends BaseService {
* @param message
*/
public void sendSignMessage(final SignMessage message) {
logger.debug("sendSignMessage message: {}", JSON.toJSONString(message));
logger.info("sendSignMessage message: {}", JSON.toJSONString(message));
// giftJmsTemplate.send("sign-queue", new MessageCreator() {
// @Override
// public Message createMessage(Session session) throws JMSException {
@@ -222,7 +222,7 @@ public class ActiveMQService extends BaseService {
* @param message
*/
public void sendRadishGiftMessage(final RadishGiftMessage message) {
logger.debug("sendRadishGiftMessage message: {}", JSON.toJSONString(message));
logger.info("sendRadishGiftMessage message: {}", JSON.toJSONString(message));
// giftJmsTemplate.send("radish-gift-queue", new MessageCreator() {
// @Override
// public Message createMessage(Session session) throws JMSException {
@@ -248,7 +248,7 @@ public class ActiveMQService extends BaseService {
* @param message
*/
public void sendVoiceLikeMessage(final VoiceLikeMessage message) {
logger.debug("sendVoiceLikeMessage message: {}", JSON.toJSONString(message));
logger.info("sendVoiceLikeMessage message: {}", JSON.toJSONString(message));
jmsTemplate.convertAndSend("voice-like-queue",message);
}
@@ -257,7 +257,7 @@ public class ActiveMQService extends BaseService {
* @param msg
*/
public void sendYidunIMTextAntiMsg(YidunIMAntiMessage msg) {
logger.debug("sendYidunIMTextAntiMsg message: {}", JSON.toJSONString(msg));
logger.info("sendYidunIMTextAntiMsg message: {}", JSON.toJSONString(msg));
jmsTemplate.convertAndSend("yindun-text-anti-queue",msg);
}
}