zq-erp/src/main/java/com/matrix/config/RabbitMqConfig.java
@@ -1,3 +1,4 @@ /* package com.matrix.config; @@ -18,9 +19,11 @@ import java.util.ArrayList; import java.util.List; */ /** * 小型应用弃用rabbitmq，直接通过观察者模式对消息进行同步消费 参考 AsyncMessageManager */ *//* //@Configuration public class RabbitMqConfig { @@ -96,3 +99,4 @@ } */ zq-erp/src/main/java/com/matrix/system/app/action/ApiServiceOrderAction.java
@@ -67,8 +67,6 @@ @Autowired private SysBeauticianStateService sysBeauticianStateService; @Autowired private RabiitMqTemplate rabiitMqTemplate; @Autowired private AsyncMessageManager asyncMessageManager; zq-erp/src/main/java/com/matrix/system/hive/action/OrderController.java
@@ -96,8 +96,6 @@ @Autowired private SysOrderFlowDao sysOrderFlowDao; @Autowired RabiitMqTemplate rabiitMqTemplate; @Autowired private BusParameterSettingsDao busParameterSettingsDao; zq-erp/src/main/java/com/matrix/system/job/ServiceOvertimeNoticeJob.java
@@ -29,8 +29,6 @@ @Value("${evn}") private String evn; @Autowired private RabiitMqTemplate rabiitMqTemplate; @Autowired private AsyncMessageManager asyncMessageManager; zq-erp/src/main/java/com/matrix/system/shopXcx/action/ShopDeliveryInfoAction.java
@@ -1,7 +1,6 @@ package com.matrix.system.shopXcx.action; import com.matrix.component.asyncmessage.AsyncMessageManager; import com.matrix.component.rabbitmq.RabiitMqTemplate; import com.matrix.core.anotations.RemoveRequestToken; import com.matrix.core.anotations.SaveRequestToken; import com.matrix.core.constance.MatrixConstance; @@ -68,8 +67,6 @@ @Autowired private ShopLogisticsInfoDao shopLogisticsInfoDao; @Autowired private RabiitMqTemplate rabiitMqTemplate; //记录编辑前的值Before_Edit_Value public static final String BEV = "ShopDeliveryInfo_BEV"; zq-erp/src/main/java/com/matrix/system/shopXcx/action/ShopRefundRecordAction.java
@@ -81,8 +81,6 @@ @Value("${evn}") private String evn; @Autowired private RabiitMqTemplate rabiitMqTemplate; @Autowired BusParameterSettingsDao parameterSettingsDao; zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxBindingPhoneNumber.java
@@ -1,6 +1,5 @@ package com.matrix.system.shopXcx.api.action; import com.matrix.component.rabbitmq.RabiitMqTemplate; import com.matrix.component.redis.RedisUserLoginUtils; import com.matrix.component.tools.AES; import com.matrix.core.pojo.AjaxResult; @@ -39,8 +38,6 @@ @Autowired private RedisUserLoginUtils redisUserLoginUtils; @Autowired private RabiitMqTemplate mqTemplate; @Value("${evn}") private String evn; zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/WxCommonAction.java
@@ -1,7 +1,6 @@ package com.matrix.system.shopXcx.api.action; import com.matrix.component.asyncmessage.AsyncMessageManager; import com.matrix.component.rabbitmq.RabiitMqTemplate; import com.matrix.component.wechat.externalInterface.common.Signature; import com.matrix.component.wechat.externalInterface.common.Util; import com.matrix.component.wechat.externalInterface.protocol.queryProtocol.NotifyData; @@ -69,8 +68,6 @@ @Autowired private ShopPayLogDao shopPayLogDao; @Autowired private RabiitMqTemplate rabiitMqTemplate; @Autowired private ShopActivitiesGroupJoinUserDao shopActivitiesGroupJoinUserDao; zq-erp/src/main/java/com/matrix/system/shopXcx/api/action/YuyueAction.java
@@ -1,6 +1,5 @@ package com.matrix.system.shopXcx.api.action; import com.matrix.component.rabbitmq.RabiitMqTemplate; import com.matrix.component.redis.RedisUserLoginUtils; import com.matrix.core.exception.GlobleException; import com.matrix.core.pojo.AjaxResult; @@ -86,8 +85,6 @@ @Autowired SysVipInfoDao sysVipInfoDao; @Autowired RabiitMqTemplate rabiitMqTemplate; @Autowired SysProjUseDao projUseDao; zq-erp/src/main/java/com/matrix/system/shopXcx/api/service/impl/WXShopOrderServiceImpl.java
@@ -3,7 +3,6 @@ import cn.hutool.core.collection.CollUtil; import com.google.gson.Gson; import com.google.gson.GsonBuilder; import com.matrix.component.rabbitmq.RabiitMqTemplate; import com.matrix.component.redis.RedisUserLoginUtils; import com.matrix.component.tools.WxUtils; import com.matrix.component.wechat.externalInterface.protocol.paramProtocol.BrandWCPayRequestData; @@ -16,7 +15,6 @@ import com.matrix.system.common.dao.BusParameterSettingsDao; import com.matrix.system.common.dao.CustomerDataDictionaryDao; import com.matrix.system.common.interceptor.HostInterceptor; import com.matrix.system.constance.Dictionary; import com.matrix.system.hive.bean.SysVipInfo; import com.matrix.system.hive.dao.ShoppingGoodsDao; import com.matrix.system.hive.dao.SysVipInfoDao; @@ -614,8 +612,6 @@ * @param orderId * @return */ @Autowired RabiitMqTemplate rabiitMqTemplate; @Override public AjaxResult findOrderPayStatus(Integer orderId) { zq-erp/src/test/java/com/matrix/SourceFlowTests.java
@@ -1,16 +1,11 @@ package com.matrix; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.matrix.component.rabbitmq.RabiitMqTemplate; import com.matrix.component.wechat.externalInterface.weixinUtil.WeixinServiceUtil; import com.matrix.config.RabbitMqConfig; import com.matrix.core.tools.StringUtils; import com.matrix.system.fenxiao.dao.ShopSalesmanApplyDao; import com.matrix.system.hive.bean.*; import com.matrix.system.hive.dao.*; import com.matrix.system.hive.service.CodeService; import com.matrix.system.shopXcx.mqTask.MQTaskRouting; import com.matrix.system.shopXcx.vo.SalesmanVo; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; @@ -53,8 +48,6 @@ @Autowired private SysVipInfoDao vipInfoDao; @Autowired RabiitMqTemplate rabiitMqTemplate; @Autowired WeixinServiceUtil weixinServiceUtil; @@ -75,7 +68,7 @@ */ @Test public void testTopic() throws InterruptedException { rabiitMqTemplate.sendTopicMsg(RabbitMqConfig.MQ_EXCHANGE_TOPIC +"dev", MQTaskRouting.CREATE_ORDER+"dev", "123"); // rabiitMqTemplate.sendTopicMsg(RabbitMqConfig.MQ_EXCHANGE_TOPIC +"dev", MQTaskRouting.CREATE_ORDER+"dev", "123"); Thread.sleep(10000); }
