Sfoglia il codice sorgente

接收客小爽激活队列。

mac 2 anni fa
parent
commit
be7be1476c

+ 7 - 1
kxs-product/kxs-product-biz/src/main/java/com/kxs/product/biz/mq/RabbitKxsOrderQueueListener.java

@@ -48,7 +48,13 @@ public class RabbitKxsOrderQueueListener {
 				remoteSysService.addBcqtTeam(campAddBcqtTeamDTO, SecurityConstants.FROM_IN);
 			}
 			//训练营订单处理
-			if(parse.getStatus() == 2 && (parse.getProductId() == 10 || parse.getProductId() == 11) ){
+			if(parse.getStatus() == 2
+					&& (parse.getProductId() == 10
+					|| parse.getProductId() == 11
+					|| parse.getProductId() == 77
+					|| parse.getProductId() == 78
+					|| parse.getProductId() == 79
+					|| parse.getProductId() == 92) ){
 				PrizePoolDTO prizePoolDTO = new PrizePoolDTO();
 				BeanUtils.copyProperties(parse,  prizePoolDTO);
 				remoteSysService.prizePoolIsRefreshed(prizePoolDTO, SecurityConstants.FROM_IN);

+ 1 - 1
kxs-system/kxs-system-api/src/main/java/com/kxs/system/api/feign/RemoteSysService.java

@@ -61,5 +61,5 @@ public interface RemoteSysService {
 	 * @param param 请求参数
 	 */
 	@PostExchange("/camp/campOpenNumStat")
-	void campOpenNumStat(CampOpenNumStatDTO param, @RequestHeader(SecurityConstants.FROM) String fromIn);
+	void campOpenNumStat(@RequestBody CampOpenNumStatDTO param, @RequestHeader(SecurityConstants.FROM) String fromIn);
 }

+ 1 - 1
kxs-system/kxs-system-biz/src/main/resources/mapper/KxsCampMapper.xml

@@ -41,7 +41,7 @@
 
 
     <select id="selectUserCamp" resultType="com.kxs.system.api.model.KxsCamp">
-        SELECT a.id, a.status, a.camp_num, a.camp_type, a.pic_url, a.title, a.bonus_pool, a.open_num, a.order_num
+        SELECT a.id, a.status, a.camp_num, a.camp_type, a.pic_url, a.title, a.bonus_pool, a.open_num, a.order_num, a.start_time, a.end_time
         from kxs_camp a
         left join kxs_camp_user b on a.id = b.camp_id
         <where>