编写测试代码

src/main/java/com/usky/dxtop/controller/web/TestController.java

@@ -3,11 +3,13 @@ package com.usky.dxtop.controller.web;
 
 import com.usky.dxtop.service.config.rabbitmq.ChargeTransConfig;
 import com.usky.dxtop.service.config.rabbitmq.DishTransConfig;
+import com.usky.dxtop.service.config.rabbitmq.charge.ChargeProduceConfig;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.Date;
@@ -30,6 +32,11 @@ public class TestController {
     private RabbitTemplate dishTransRabbitTemplate;
 
 
+    @Autowired
+    @Qualifier(ChargeProduceConfig.TEMPLATE)
+    private RabbitTemplate cart;
+
+
 
     @GetMapping("/chargeTest")
     public String sendDirectMessageCharge() {
@@ -81,4 +88,14 @@ public class TestController {
         return "ok";
     }
 
+    @GetMapping("/cartPay")
+    public void  cartPay(@RequestParam("id") Long id){
+        Map<String,Object> map = new HashMap<>();
+        map.put("seq",id);
+        map.put("seq_charge",1111);
+        map.put("code",1);
+        map.put("msd","成功");
+        dishTransRabbitTemplate.convertAndSend(DishTransConfig.NAME, DishTransConfig.NAME, map);
+    }
+
 }

src/main/java/com/usky/dxtop/framework/config/SecurityConfig.java

@@ -13,7 +13,6 @@ import org.springframework.security.config.annotation.method.configuration.Enabl
 import org.springframework.security.config.annotation.web.builders.HttpSecurity;
 import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
 import org.springframework.security.config.http.SessionCreationPolicy;
-import org.springframework.security.core.userdetails.UserDetailsService;
 import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
 import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter;
 import org.springframework.security.web.authentication.logout.LogoutFilter;
@@ -99,7 +98,7 @@ public class SecurityConfig extends WebSecurityConfigurerAdapter
                 // 过滤请求
                 .authorizeRequests()
                 // 对于登录login 注册register 验证码captchaImage 允许匿名访问
-                .antMatchers("/login", "/register", "/captchaImage","/top/notify").anonymous()
+                .antMatchers("/login", "/register", "/captchaImage","/top/notify","/dxtop/order/topScanPayApi").anonymous()
                 .antMatchers(
                         HttpMethod.GET,
                         "/",

src/main/java/com/usky/dxtop/service/job/CardJob.java

@@ -34,6 +34,7 @@ public class CardJob {
         List<Order> list = orderService.list(queryWrapper);
         for (Order order:list) {
             try {
+                //TODO 卡充值记录查询api
                 order.setOrderFlag(OrderStatus.COMPLETE.getCode());
                 orderService.updateById(order);
             }catch (Exception e){

src/main/java/com/usky/dxtop/service/listener/ChargeMqListener.java

@@ -32,7 +32,7 @@ public class ChargeMqListener {
             log.info("charge_trans_produce:接受到的消息"+s);
             JSONObject jsonObject = JSONObject.parseObject(s);
             Order order = new Order();
-            order.setId(Long.parseLong(jsonObject.get("code").toString()));
+            order.setId(Long.parseLong(jsonObject.get("seq").toString()));
             if ("1".equals(jsonObject.get("code"))) {
                 order.setOrderFlag(OrderStatus.COMPLETE.getCode());
             }else {