Merge branch 'base-modify' of http://113.105.137.151:22280/youjj/cloud-platform into base-modify

ace-common/src/main/java/com/github/wxiaoqi/security/common/util/ReferralCodeUtil.java

+package com.github.wxiaoqi.security.common.util;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
+
+public class ReferralCodeUtil {
+	//验证码长度
+	private static final int LEN = 6;
+	//验证码字符初始列表
+	private static final char STUFFS[] = {
+			'E','5','F','C','D','G','3','H',
+			'Q','A','4','B','1','N','P','I',
+			'J','2','R','S','T','U','V','6',
+			'7','M','W','X','8','K','L','Y'};
+	
+	private static final int PERMUTATION;
+	private static final int MAX_COMBINATION;
+
+	private static char[] _stuffs = STUFFS;
+	
+	static {
+		PERMUTATION = permutation(LEN);
+		MAX_COMBINATION = combination(_stuffs.length, LEN);
+	}
+
+//	public static void resetStuffs() {
+//		int length = STUFFS.length;
+//		char[] stuffs = new char[length];
+//		for (int i = 0; i < length; ++i) {
+//			stuffs[i] = STUFFS[i];
+//		}
+//		Random random = new Random();
+//		for (int i = 0; i < length; i++) {
+//			int p = random.nextInt(length);
+//			char tmp = stuffs[i];
+//			stuffs[i] = stuffs[p];
+//			stuffs[p] = tmp;
+//		}
+//		_stuffs = stuffs;
+//	}
+	
+	private static int combination(int n,int m) {
+		int com = 1;
+		for(int i = n - m + 1; i <= n ; ++i) {
+			com *= i;
+		}
+		for(int i = 2; i <= m ; ++i ) {
+			com /= i;
+		}
+		return com;
+	}
+	
+	private static int permutation(int n) {
+		int per = 1;
+		for(int i = 2; i <= n ; ++i) {
+			per *= i;
+		}
+		return per;
+	}
+	
+	public static int decode(String code) {
+		if(code.length() != LEN) {
+			throw new RuntimeException("invalid code");
+		}
+		char[] chars = new char[LEN];
+		for(int i = 0; i < LEN;++i) {
+			chars[i] = code.charAt(i);
+		}
+		int com = combination(chars);
+		int per = permutation(chars);
+		return com * PERMUTATION + per;
+	}
+	
+	public static String encode(int val) {
+		int com = val / PERMUTATION;
+		if(com >= MAX_COMBINATION) {
+			throw new RuntimeException("id can't be greater than 652458239");
+		}
+		int per = val % PERMUTATION;
+		char[] chars = combination(com);
+		chars = permutation(chars,per);
+		return new String(chars);
+	}
+	
+	private static char[] combination(int com){
+		char[] chars = new char[LEN];
+		int start = 0;
+		int index = 0;
+		while (index < LEN) {
+			for(int s = start; s < _stuffs.length; ++s ) {
+				int c = combination(_stuffs.length - s - 1, LEN - index - 1);
+				if(com >= c) {
+					com -= c;
+					continue;
+				}
+				chars[index++] = _stuffs[s];
+				start = s + 1;
+				break;
+			}
+		}
+		return chars;
+	}
+	
+	private static char[] sort(char[] src) {
+		char[] sort = new char[src.length];
+		int index = 0;
+		for(int i = 0; i < _stuffs.length; ++i) {
+			if(find(src, _stuffs[i]) != -1) {
+				sort[index++] = _stuffs[i];
+			}
+		}
+		return sort;
+	}
+	
+	private static int combination(char[] chars) {
+		int[] offset = new int[LEN];
+		char[] sort = sort(chars);
+		for(int i = 0; i < sort.length;++i) {
+			offset[i] = find(_stuffs, sort[i]);
+			if(offset[i] == -1) {
+				throw new RuntimeException("invalid code");
+			}
+		}
+		int com = 0;
+		for(int i = 0;i < offset.length;++i) {
+			if(i == 0) {
+				if(offset[0] == 0) {
+					continue;
+				}
+				for(int n = 0; n < offset[0];++n) {
+					com += combination(_stuffs.length -  n - 1, LEN - 1);
+				}
+				continue;
+			}
+			
+			if(offset[i] - offset[i - 1] <= 1) {
+				continue;
+			}
+			
+			for(int n = offset[i-1] + 1; n < offset[i];++n) {
+				com += combination(_stuffs.length -  n - 1, LEN - i - 1);
+			}
+		}
+		
+		return com;
+	}
+	
+	private static char[] permutation(char[] chars,int per){
+		char[] tmpchars = new char[chars.length];
+		System.arraycopy(chars, 0, tmpchars, 0, chars.length);
+		int[] offset = new int[chars.length];
+		int step = chars.length;
+		for(int i = chars.length -1;i >= 0;--i) {
+			offset[i] = per % step;
+			per /= step;
+			step --;
+		}
+		
+		for(int i = 0; i < chars.length;++i) {
+			if(offset[i] == 0)
+				continue;
+			char tmp = tmpchars[i];
+			tmpchars[i] = tmpchars[i - offset[i]];
+			tmpchars[i - offset[i]] = tmp;
+		}
+		
+		return tmpchars;
+	}
+	
+	private static int find(char[] chars,char ch) {
+		for(int i = 0;i < chars.length;++i) {
+			if(chars[i] == ch) {
+				return i;
+			}
+		}
+		return -1;
+	}
+	
+	private static int permutation(char[] chars){
+		char[] sort = sort(chars);
+		int[] offset = new int[chars.length];
+		for(int i =chars.length -1;i >=0;--i ) {
+			int f = find(chars, sort[i]);
+			offset[i] = i - f;
+			char tmp = chars[i];
+			chars[i] = chars[i - offset[i]];
+			chars[i - offset[i]] = tmp;
+		}
+		int per = 0;
+		int step = 1;
+		for(int i = 0; i < offset.length;++i ) {
+			per = per * step + offset[i];
+			step++;
+		}
+		return per;
+	}
+
+	public static void main(String[] args) {
+//		try {
+//			List<String> lists = new ArrayList<>();
+//			Set<String> sets = new HashSet<>();
+//			File file = new File("./log2.txt");
+//			BufferedOutputStream buff = new BufferedOutputStream(new FileOutputStream(file));
+//			resetStuffs();
+//			for (int i = 1; i< 10000000; ++i) {
+//				String code = encode(i);
+//				int nid = decode(code);
+//				if (i != nid) {
+//					break;
+//				}
+//				String str = i + "->" + code + "->" + nid + "\n";
+//				buff.write(str.getBytes());
+//
+//				lists.add(code);
+//				sets.add(code);
+//			}
+//			String result = "lists.size=" + lists.size() + ", sets.size=" + sets.size() + "\n";
+//			buff.write(result.getBytes());
+//			buff.flush();
+//			buff.close();
+//		} catch (Exception e) {
+//			e.printStackTrace();
+//		}
+		Map<String, Integer> map = new HashMap<String, Integer>();
+		for (int i = 0; i < 10000; i++) {
+			String key = encode(i);
+			System.out.println(key);
+			if(null == map.get(key)) {
+				map.put(key, 1);
+			}else {
+				System.out.println("重复"+ key+ ":"+ i);
+				map.put(key, map.get(key) + 1);
+			}
+		}
+
+		int flag = 0;
+		Set<Map.Entry<String, Integer>> list = map.entrySet();
+		for(Map.Entry<String, Integer> e : list) {
+			if(e.getValue() > 1) {
+				flag++;
+				System.out.println(e.getKey()+ ":"+ e.getValue());
+			}
+		}
+		System.out.println("flag : "+ flag);
+	}
+}
\ No newline at end of file

ace-modules/ace-admin-api/src/main/java/com/github/wxiaoqi/security/admin/feign/UserFeign.java

@@ -27,9 +27,15 @@ public interface UserFeign {
     public static final int MEMBER_DAYS_CONFIRM = 2;
     public static final int MEMBER_DAYS_WITHDRAW = 3;
 
+    //后台用户
     @RequestMapping(value = "/public/userinfo-by-token")
     public ObjectRestResponse<UserDTO> userinfoByToken(@RequestParam("token") String token);
 
+    @RequestMapping(value = "/public/userinfo-by-uid")
+    public ObjectRestResponse<UserDTO> userinfoByUid(@RequestParam("uid") Integer uid);
+
+
+
     /**
      * token获取用户信息
      * @param token
@@ -37,9 +43,6 @@ public interface UserFeign {
      */
     @RequestMapping(value = "/public/app/userinfo-by-token")
     public ObjectRestResponse<AppUserDTO> userDetailByToken(@RequestParam("token") String token);
-    @RequestMapping(value = "/public/userinfo-by-uid")
-    public ObjectRestResponse<UserDTO> userinfoByUid(@RequestParam("uid") Integer uid);
-
     /**
      * id获取用户信息
      * @param id

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/AppUserSellingWaterBiz.java

@@ -176,7 +176,12 @@ public class AppUserSellingWaterBiz extends BaseBiz<AppUserSellingWaterMapper, A
         int r = amount.compareTo(BigDecimal.ZERO);
         //更新钱包
         if (r == 1 && userId > 0) {
-            myWaterBiz.updMyWater(userId, orderId, amount);
+            MyWalletDetail detail=new MyWalletDetail();
+            detail.setUserId(userId);
+            detail.setAmount(amount);
+            detail.setCono(orderId);
+            detail.setSource(1);
+            myWaterBiz.updMyWater(detail);
         }
 
     }
@@ -209,7 +214,12 @@ public class AppUserSellingWaterBiz extends BaseBiz<AppUserSellingWaterMapper, A
         int r = amount.compareTo(BigDecimal.ZERO);
         //更新钱包
         if (r == 1 && userId > 0) {
-            myWaterBiz.updMyWater(userId, orderId, amount);
+            MyWalletDetail detail=new MyWalletDetail();
+            detail.setUserId(userId);
+            detail.setAmount(amount);
+            detail.setCono(orderId);
+            detail.setSource(1);
+            myWaterBiz.updMyWater(detail);
         }
 
     }

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/MyWaterBiz.java

@@ -35,8 +35,14 @@ public class MyWaterBiz extends BaseBiz<MyWalletMapper, MyWallet>{
 
 
     //我的钱包入账
-    public  void updMyWater(Integer userId, Integer orderId,BigDecimal amount){
-        log.info("---我的钱包入账----userId==="+userId+"----orderId===="+orderId+"----amount===="+amount);
+    public  void updMyWater(MyWalletDetail walletDetail){
+        if (walletDetail==null){
+            log.info("钱包入账-----参数为空");
+        }
+        Integer userId= walletDetail.getUserId();
+        BigDecimal amount= walletDetail.getAmount();
+        Integer source=walletDetail.getSource();
+        log.info("---我的钱包入账----userId==="+userId+"----source===="+source+"----amount===="+amount);
         MyWallet wallet=new MyWallet();
         wallet.setUserId(userId);
         wallet=selectOne(wallet);
@@ -70,12 +76,7 @@ public class MyWaterBiz extends BaseBiz<MyWalletMapper, MyWallet>{
 
         }
         log.info("---我的钱包入账----userId==="+userId+"----balance===="+balance+"----totalAmount===="+totalAmount+"---todayAmount==="+todayAmount+"---unbooked=="+unbooked);
-        MyWalletDetail walletDetail=new MyWalletDetail();
-        walletDetail.setUserId(userId);
-        walletDetail.setSource(1);
-        walletDetail.setCono(orderId);
         walletDetail.setItype(1);
-        walletDetail.setAmount(amount);
         walletDetail.setBalance(oldBalance);
         walletDetailBiz.insertSelective(walletDetail);
         Long time=System.currentTimeMillis();

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/config/RabbitAdminConfig.java

@@ -22,8 +22,14 @@ public class RabbitAdminConfig extends RabbitCommonConfig {
     public static final String ORDER_FINLISH_USER_RE_QUEUE = "order.cancel.userRe.queue";
     //钱包50入账
     public static final String  WALLET_ADD_QUEUE = "wallet.add.queue";
+
+    //支付完成后永久绑定关系
+    public static final String ORDER_RELATION_QUEUE = "order.relation.queue";
     static {
             myQueue = new ArrayList<BindDTO>(){{
+            //支付完成后永久绑定关系
+            add(new BindDTO(ORDER_RELATION_QUEUE, ADMIN_TOPIC, KEY_ORDER_PAY));
+            //拥金计算
             add(new BindDTO(ORDER_WATER_QUEUE, ADMIN_TOPIC, KEY_ORDER_PAY));
             add(new BindDTO(ORDER_WATER_QUEUE, ADMIN_TOPIC, KEY_ORDER_FINLISH));
             add(new BindDTO(ORDER_WATER_QUEUE, ADMIN_TOPIC, KEY_ORDER_CANCEL));

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/handler/RelationMQHandler.java

+package com.github.wxiaoqi.security.admin.handler;
+
+
+import cn.hutool.json.JSONUtil;
+import com.github.wxiaoqi.security.admin.biz.AppUserRelationBiz;
+import com.github.wxiaoqi.security.admin.biz.AppUserSellingWaterBiz;
+import com.github.wxiaoqi.security.admin.entity.AppUserRelation;
+import com.rabbitmq.client.Channel;
+import com.xxfc.platform.order.pojo.mq.OrderMQDTO;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.amqp.support.AmqpHeaders;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.messaging.handler.annotation.Headers;
+import org.springframework.stereotype.Component;
+
+import java.io.IOException;
+import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+import static com.github.wxiaoqi.security.admin.config.RabbitAdminConfig.ORDER_RELATION_QUEUE;
+
+@Component
+@Slf4j
+public class RelationMQHandler {
+
+    @Autowired
+    AppUserRelationBiz relationBiz;
+
+    /**
+     * 永久关系绑定
+     * @param
+     */
+    @RabbitListener(queues = ORDER_RELATION_QUEUE)
+    public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) {
+        ExecutorService executorService = Executors.newCachedThreadPool();
+        executorService.execute(new Runnable() {
+            @Override
+            public void run() {
+                try {
+                    String messageId = message.getMessageProperties().getMessageId();
+                    String msg = new String(message.getBody(), "UTF-8");
+                    log.info("接收到的消息-----msg===="+msg);
+                    OrderMQDTO orderMQDTO = JSONUtil.toBean(msg, OrderMQDTO.class);
+                    Integer sign=orderMQDTO.getSign();
+                    Integer userId=orderMQDTO.getUserId();
+                    log.info("接收到的消息-----sign===="+sign+"-----userId===="+userId);
+                    relationBiz.foreverBind(userId);
+                    executorService.shutdown();
+                    Long deliveryTag = (Long) headers.get(AmqpHeaders.DELIVERY_TAG);
+                    // 手动签收
+                    channel.basicAck(deliveryTag, false);
+                } catch (Exception e) {
+                    log.info("接收到的消息失败");
+                    try {
+                        channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, false);
+                    } catch (IOException i) {
+                        i.printStackTrace();
+                    }
+                    e.printStackTrace();
+                }
+            }
+        });
+    }
+
+
+
+}

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/handler/WalletMQHandler.java

@@ -3,6 +3,9 @@ package com.github.wxiaoqi.security.admin.handler;
 
 import cn.hutool.json.JSONUtil;
 import com.github.wxiaoqi.security.admin.biz.AppUserSellingWaterBiz;
+import com.github.wxiaoqi.security.admin.biz.MyWalletBiz;
+import com.github.wxiaoqi.security.admin.biz.MyWaterBiz;
+import com.github.wxiaoqi.security.admin.entity.MyWalletDetail;
 import com.rabbitmq.client.Channel;
 import com.xxfc.platform.order.pojo.mq.OrderMQDTO;
 import lombok.extern.slf4j.Slf4j;
@@ -24,10 +27,10 @@ import static com.github.wxiaoqi.security.admin.config.RabbitAdminConfig.*;
 public class WalletMQHandler {
 
     @Autowired
-    AppUserSellingWaterBiz waterBiz;
+    MyWaterBiz waterBiz;
 
     /**
-     * 佣金
+     * 钱包入账
      * @param
      */
     @RabbitListener(queues = WALLET_ADD_QUEUE)
@@ -39,10 +42,9 @@ public class WalletMQHandler {
                 try {
                     String messageId = message.getMessageProperties().getMessageId();
                     String msg = new String(message.getBody(), "UTF-8");
-
-                    OrderMQDTO orderMQDTO = JSONUtil.toBean(msg, OrderMQDTO.class);
-
-
+                    log.info("接收到的消息-----msg===="+msg);
+                    MyWalletDetail detail = JSONUtil.toBean(msg, MyWalletDetail.class);
+                    waterBiz.updMyWater(detail);
                     executorService.shutdown();
                     Long deliveryTag = (Long) headers.get(AmqpHeaders.DELIVERY_TAG);
                     // 手动签收

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/handler/WaterMQHandler.java

@@ -24,6 +24,7 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
 import static com.github.wxiaoqi.security.admin.config.RabbitAdminConfig.*;
+import static com.xxfc.platform.order.pojo.mq.OrderMQDTO.*;
 
 @Component
 @Slf4j
@@ -46,16 +47,29 @@ public class WaterMQHandler {
                     String messageId = message.getMessageProperties().getMessageId();
                     String msg = new String(message.getBody(), "UTF-8");
                     OrderMQDTO orderMQDTO = JSONUtil.toBean(msg, OrderMQDTO.class);
-                    OrderWaterDTO orderWaterDTO = new OrderWaterDTO(){{
+                    OrderWaterDTO orderWaterDTO = new OrderWaterDTO() {{
                         setUserId(orderMQDTO.getUserId());
                         setOrderNo(orderMQDTO.getNo());
                         setOrderId(orderMQDTO.getId());
                     }};
+                    switch (orderMQDTO.getSign()) {
+                        case ORDER_PAY:
+                            orderWaterDTO.setStatus(1);
+                            break;
+                        case ORDER_FINISH:
+                            orderWaterDTO.setStatus(2);
+                            break;
+                        case ORDER_CANCEL:
+                            orderWaterDTO.setStatus(3);
+                            break;
+                        default:
+                            break;
+                    }
                     switch (OrderTypeEnum.get(orderMQDTO.getType())) {
                         case RENT_VEHICLE:
                             orderWaterDTO.setGoodsDTOList(
-                                    new ArrayList<OrderGoodsDTO>(){{
-                                        add(new OrderGoodsDTO(){{
+                                    new ArrayList<OrderGoodsDTO>() {{
+                                        add(new OrderGoodsDTO() {{
                                             setGoodId(orderMQDTO.getOrderRentVehicleDetail().getModelId());
                                             setGoodNumber(1);
                                             setImg(orderMQDTO.getPicture());
@@ -68,8 +82,8 @@ public class WaterMQHandler {
                             break;
                         case TOUR:
                             orderWaterDTO.setGoodsDTOList(
-                                    new ArrayList<OrderGoodsDTO>(){{
-                                        add(new OrderGoodsDTO(){{
+                                    new ArrayList<OrderGoodsDTO>() {{
+                                        add(new OrderGoodsDTO() {{
                                             setGoodId(orderMQDTO.getOrderTourDetail().getGoodId());
                                             setGoodNumber(1);
                                             setImg(orderMQDTO.getPicture());
@@ -82,8 +96,8 @@ public class WaterMQHandler {
                             break;
                         case MEMBER:
                             orderWaterDTO.setGoodsDTOList(
-                                    new ArrayList<OrderGoodsDTO>(){{
-                                        add(new OrderGoodsDTO(){{
+                                    new ArrayList<OrderGoodsDTO>() {{
+                                        add(new OrderGoodsDTO() {{
                                             setGoodId(orderMQDTO.getOrderMemberDetail().getMemberLevelId());
                                             setGoodNumber(1);
                                             setImg(orderMQDTO.getPicture());
@@ -115,31 +129,5 @@ public class WaterMQHandler {
                 }
             }
         });
-
-//        log.info("接收到的消息：json = {}", json);
-//        try{
-//
-//            OrderWaterDTO orderWaterDTO = JSONObject.parseObject(json, OrderWaterDTO.class);
-//            waterBiz.orderWater(orderWaterDTO);
-//        }catch (Exception e){
-//            log.info("接收到的消息失败");
-//            e.printStackTrace();
-//        }
-
-    }
-
-    @RabbitListener(queues = {ORDER_FINLISH_USER_RE_QUEUE})
-    public void integralHandler2(String json) {
-        log.info("接收到的消息：json = {}", json);
-        try{
-            OrderWaterDTO orderWaterDTO = JSONObject.parseObject(json, OrderWaterDTO.class);
-            waterBiz.orderWater(orderWaterDTO);
-        }catch (Exception e){
-            log.info("接收到的消息失败");
-            e.printStackTrace();
-        }
-
     }
-
-
 }

ace-modules/ace-admin/src/main/resources/mapper/AppUserDetailMapper.xml

@@ -29,7 +29,7 @@
         <result column="position_id" property="positionId"/>
         <result column="source" property="source"/>
         <result column="code" property="code"/>
-        <result column="invitera_ccount" property="inviterAccount"/>
+        <result column="inviter_account" property="inviterAccount"/>
         <result column="state" property="state"/>
     </resultMap>
 

xx-activity/xx-activity-server/pom.xml

@@ -18,6 +18,12 @@
             <artifactId>xx-activity-api</artifactId>
             <version>2.0-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>com.xxfc.platform</groupId>
+            <artifactId>xx-order-api</artifactId>
+            <version>2.0-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 
     <build>

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/biz/ActivityPopularizeBiz.java

@@ -51,7 +51,7 @@ public class ActivityPopularizeBiz extends BaseBiz<ActivityPopularizeMapper,Acti
         AppUserDTO appUserDTO = userFeign.userDetailById(registerQueueDTO.getAppUserId()).getData();
 
         //获取活动code,并且注册来源是app 并且 非普通登录
-        if(POPULARIZE_0101.equals(registerQueueDTO.getInParamDTO().getActivityCode())
+        if(POPULARIZE_0101.equals(activityCode)
                 && !RegisterQueueDTO.SIGN_LOGIN.equals(registerQueueDTO.getSign())) {
 
             //查询出活动

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/config/RabbitActivityConfig.java

@@ -6,6 +6,8 @@ import com.github.wxiaoqi.security.common.config.rabbit.RabbitConstant;
 import org.springframework.context.annotation.Configuration;
 
 import java.util.ArrayList;
+import static com.github.wxiaoqi.security.common.config.rabbit.RabbitConstant.*;
+
 
 /**
  * rabbitmq配置类
@@ -21,14 +23,19 @@ public class RabbitActivityConfig extends RabbitCommonConfig {
     //新人注册有礼
     public static final String ACTIVITY_NEW_QUEUE = "activity.new.queue";
     public static final String INTEGRAL_HANDLE_QUEUE = "integral_handle_queue";
+
+    //优惠券
+    public static final String COUPON_CANCEL_QUEUE = "coupon.cancel.queue";
+
     static {
         myQueue = new ArrayList<BindDTO>(){{
-            add(new BindDTO(INTEGRAL_QUEUE,  RabbitConstant.ORDER_TOPIC, "order.#"));
-            add(new BindDTO(POPULARZIE_0101_QUEUE,  RabbitConstant.ADMIN_TOPIC, "appUser.register"));
-            add(new BindDTO(POPULARZIE_0101_QUEUE,  RabbitConstant.ADMIN_TOPIC, "appUser.auth"));
-            add(new BindDTO(ACTIVITY_NEW_QUEUE,  RabbitConstant.ADMIN_TOPIC, "appUser.register"));
-            add(new BindDTO(ACTIVITY_NEW_QUEUE,  RabbitConstant.ADMIN_TOPIC, "appUser.auth"));
-            add(new BindDTO(INTEGRAL_HANDLE_QUEUE, RabbitConstant.INTEGRAL_TOPIC, RabbitConstant.INTEGRAL_ROUTING_KEY));
+            add(new BindDTO(INTEGRAL_QUEUE,  ORDER_TOPIC, "order.#"));
+            add(new BindDTO(POPULARZIE_0101_QUEUE,  ADMIN_TOPIC, KEY_APPUSER_REGISTER));
+            add(new BindDTO(POPULARZIE_0101_QUEUE,  ADMIN_TOPIC, KEY_APPUSER_AUTH));
+            add(new BindDTO(ACTIVITY_NEW_QUEUE,  ADMIN_TOPIC, KEY_APPUSER_REGISTER));
+            add(new BindDTO(ACTIVITY_NEW_QUEUE,  ADMIN_TOPIC, KEY_APPUSER_AUTH));
+            add(new BindDTO(INTEGRAL_HANDLE_QUEUE, INTEGRAL_TOPIC, INTEGRAL_ROUTING_KEY));
+            add(new BindDTO(COUPON_CANCEL_QUEUE, ORDER_TOPIC, KEY_ORDER_CANCEL));
         }};
     }
 

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/handler/CouponMQHandler.java

+package com.xxfc.platform.activity.handler;
+
+
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSONUtil;
+import com.github.wxiaoqi.security.admin.dto.RegisterQueueDTO;
+import com.rabbitmq.client.Channel;
+import com.xxfc.platform.activity.biz.ActivityPopularizeBiz;
+import com.xxfc.platform.activity.biz.ActivityUserJoinBiz;
+import com.xxfc.platform.activity.biz.UserCouponBiz;
+import com.xxfc.platform.activity.config.RabbitActivityConfig;
+import com.xxfc.platform.order.pojo.mq.OrderMQDTO;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.amqp.support.AmqpHeaders;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.messaging.handler.annotation.Headers;
+import org.springframework.stereotype.Component;
+
+import java.io.IOException;
+import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+@Component
+@Slf4j
+public class CouponMQHandler {
+
+    @Autowired
+    ActivityPopularizeBiz activityPopularizeBiz;
+
+    @Autowired
+    ActivityUserJoinBiz activityUserJoinBiz;
+
+    @Autowired
+    UserCouponBiz userCouponBiz;
+
+    @RabbitListener(queues = {RabbitActivityConfig.COUPON_CANCEL_QUEUE})
+    public void popularizeHandler(Message message, @Headers Map<String, Object> headers, Channel channel) {
+        ExecutorService executorService = Executors.newCachedThreadPool();
+        executorService.execute(new Runnable() {
+            @Override
+            public void run() {
+                try {
+                    String messageId = message.getMessageProperties().getMessageId();
+                    String msg = new String(message.getBody(), "UTF-8");
+                    log.info("接收到的消息：msg = {}, 消息ID是：messageId = {} ", msg, messageId);
+
+                    if (StringUtils.isNotBlank(msg)) {
+                        OrderMQDTO orderMQDTO = JSONUtil.toBean(msg, OrderMQDTO.class);
+                        if(StrUtil.isNotBlank(orderMQDTO.getCouponTickerNos())) {
+                            for(String tickerNo : orderMQDTO.getCouponTickerNos().split(",")) {
+                                // 返还优惠券
+                                userCouponBiz.cancelTickerNo(tickerNo);
+                            }
+                        }
+                    }
+
+                    executorService.shutdown();
+                    Long deliveryTag = (Long) headers.get(AmqpHeaders.DELIVERY_TAG);
+                    // 手动签收
+                    channel.basicAck(deliveryTag, false);
+                } catch (Exception e) {
+                    log.info("接收到的消息失败");
+                    try {
+                        channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, false);
+                    } catch (IOException i) {
+                        i.printStackTrace();
+                    }
+                    e.printStackTrace();
+                }
+            }
+        });
+    }
+
+}

xx-order/xx-order-api/src/main/java/com/xxfc/platform/order/entity/BaseOrder.java

@@ -235,4 +235,11 @@ public class BaseOrder implements Serializable {
 	@ApiModelProperty(value = "优惠券优惠的价格")
 	@Column(name = "coupon_amount")
 	private BigDecimal couponAmount;
+
+	/**
+	 * 使用的优惠券票号，逗号分割
+	 */
+	@ApiModelProperty(value = "使用的优惠券票号，逗号分割")
+	@Column(name = "coupon_ticker_no")
+	private String couponTickerNos;
 }

xx-order/xx-order-api/src/main/java/com/xxfc/platform/order/pojo/mq/OrderMQDTO.java

@@ -9,10 +9,10 @@ import lombok.Data;
 @Data
 public class OrderMQDTO extends BaseOrder {
 
-    public static final Integer ORDER_CRT = 1;
-    public static final Integer ORDER_CANCEL = 2;
-    public static final Integer ORDER_PAY = 4;
-    public static final Integer ORDER_FINISH = 6;
+    public static final int ORDER_CRT = 1;
+    public static final int ORDER_CANCEL = 2;
+    public static final int ORDER_PAY = 4;
+    public static final int ORDER_FINISH = 6;
 
     OrderRentVehicleDetail orderRentVehicleDetail;
 

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/BaseOrderBiz.java

@@ -12,6 +12,7 @@ import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.util.IntervalUtil;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
 import com.google.common.collect.Lists;
+import com.xxfc.platform.activity.feign.ActivityFeign;
 import com.xxfc.platform.order.biz.inner.OrderMsgBiz;
 import com.xxfc.platform.order.contant.enumerate.OrderStatusEnum;
 import com.xxfc.platform.order.contant.enumerate.OrderTypeEnum;
@@ -93,6 +94,9 @@ public class BaseOrderBiz extends BaseBiz<BaseOrderMapper,BaseOrder> {
     @Autowired
     OrderMsgBiz orderMsgBiz;
 
+    @Autowired
+    ActivityFeign activityFeign;
+
     public List<OrderPageVO> pageByParm(Map<String, Object> paramMap){
         return mapper.pageByParm(paramMap);
     }

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/service/OrderRentVehicleService.java

@@ -245,6 +245,9 @@ public class OrderRentVehicleService extends AbstractOrderHandle<OrderRentVehicl
         //待完成
         if(null != detail.getTickerNo() && detail.getTickerNo().size() > 0) {
             couponAmount = activityFeign.use(dto.getUserid(), detail.getTickerNo().get(0), detail.getOrder().getNo(), channel, goodsAmount, ActivityFeign.TYPE_NO_USE);
+            if(couponAmount.compareTo(BigDecimal.ZERO) > 0) {
+                detail.getOrder().setCouponTickerNos(detail.getTickerNo().get(0));
+            }
         }
 
             //总价格（包含押金）

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/service/OrderTourService.java

@@ -218,6 +218,9 @@ public class OrderTourService extends AbstractOrderHandle<OrderTourDetailBiz, To
         //待完成
         if(null != detail.getTickerNo() && detail.getTickerNo().size() > 0) {
             couponAmount = activityFeign.use(dto.getUserid(), detail.getTickerNo().get(0), detail.getOrder().getNo(), channel, goodsAmount, ActivityFeign.TYPE_NO_USE);
+            if(couponAmount.compareTo(BigDecimal.ZERO) > 0) {
+                detail.getOrder().setCouponTickerNos(detail.getTickerNo().get(0));
+            }
         }
 
             //总价格