bonus
/
Bonus-Cloud-JYY-Canteen
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

mq

This commit is contained in:
sxu 2025-04-10 18:48:00 +08:00
parent e13ee9c5c0
commit 66ee64f211
2 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/service/impl/AccInfoServiceImpl.java
View File

@ -29,10 +29,12 @@ import cn.hutool.json.JSONUtil;
import com.bonus.canteen.core.account.domain.AccInfoVo; import com.bonus.canteen.core.account.domain.AccInfoVo;
import com.bonus.canteen.core.account.domain.AccWalletInfo; import com.bonus.canteen.core.account.domain.AccWalletInfo;
import com.bonus.canteen.core.account.domain.WalletBalanceVO; import com.bonus.canteen.core.account.domain.WalletBalanceVO;
import com.bonus.canteen.core.common.utils.MqUtil;
import com.bonus.common.core.exception.ServiceException; import com.bonus.common.core.exception.ServiceException;
import com.bonus.common.core.utils.DateUtils; import com.bonus.common.core.utils.DateUtils;
import com.bonus.common.houqin.constant.LeCodeUseSceneEnum; import com.bonus.common.houqin.constant.LeCodeUseSceneEnum;
import com.bonus.common.houqin.constant.SourceTypeEnum; import com.bonus.common.houqin.constant.SourceTypeEnum;
import com.bonus.common.houqin.mq.constant.LeMqConstant;
import com.bonus.common.security.utils.SecurityUtils; import com.bonus.common.security.utils.SecurityUtils;
import com.bonus.system.api.domain.SysUser; import com.bonus.system.api.domain.SysUser;
import com.bonus.common.houqin.utils.SM4EncryptUtils; import com.bonus.common.houqin.utils.SM4EncryptUtils;
@ -202,7 +204,7 @@ public class AccInfoServiceImpl implements IAccInfoService {
accWalletInfos.add(accWalletInfo); accWalletInfos.add(accWalletInfo);
} }
//MqUtil.sendDataChange(sysUser.getUserId(), LeMqConstant.DataChangeType.ADD, LeMqConstant.Topic.DATA_CHANGE_CUSTOMER); MqUtil.sendDataChange(sysUser.getUserId(), LeMqConstant.DataChangeType.ADD, LeMqConstant.Topic.DATA_CHANGE_CUSTOMER);
return this.accWalletInfoService.batchInsertAccWalletInfo(accWalletInfos); return this.accWalletInfoService.batchInsertAccWalletInfo(accWalletInfos);
} }

7
bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/utils/CommonConfiguration.java
View File

@ -1,12 +1,15 @@
package com.bonus.canteen.core.utils; package com.bonus.canteen.core.utils;
import com.bonus.common.houqin.i18n.I18nConfiguration; import com.bonus.common.houqin.i18n.I18nConfiguration;
import com.bonus.canteen.core.common.utils.SpringContextHolder; import com.bonus.common.houqin.mq.MQConfiguration;
import com.bonus.common.houqin.mq.mqtt.MqttProperties;
import com.bonus.common.houqin.mq.rabbit.RabbitConfiguration;
import com.bonus.common.houqin.mq.rocket.RocketConfiguration;
import com.bonus.common.houqin.utils.id.IdWorkConfiguration; import com.bonus.common.houqin.utils.id.IdWorkConfiguration;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import; import org.springframework.context.annotation.Import;
@Configuration @Configuration
@Import({IdWorkConfiguration.class, I18nConfiguration.class, SpringContextHolder.class}) @Import({IdWorkConfiguration.class, I18nConfiguration.class, MQConfiguration.class, RabbitConfiguration.class, RocketConfiguration.class, MqttProperties.class})
public class CommonConfiguration { public class CommonConfiguration {
} }