百人千团 统计定时任务已完成, 后台接口已完成

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

@@ -1,11 +1,14 @@
 package com.kxs.product.biz.mq;
 
 import com.alibaba.fastjson.JSON;
+import com.kxs.common.core.constant.SecurityConstants;
 import com.kxs.product.api.amqp.rabbit.RabbitKxsOrderQueueMQ;
 import com.kxs.product.api.amqp.rabbit.RabbitShopTimeoutQueueMQ;
 import com.kxs.product.api.model.KxsShopOrder;
 import com.kxs.product.biz.constant.enums.KxsShopEnum;
 import com.kxs.product.biz.service.KxsShopOrderService;
+import com.kxs.system.api.dto.kxsapp.camp.CampAddBcqtTeamDTO;
+import com.kxs.system.api.feign.RemoteUserService;
 import com.rabbitmq.client.Channel;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -27,6 +30,7 @@ import java.io.IOException;
 @Slf4j
 @RequiredArgsConstructor
 public class RabbitKxsOrderQueueListener {
+	private final RemoteUserService remoteUserService;
 
 	/**
 	 * 监听 老平台订单队列
@@ -41,7 +45,10 @@ public class RabbitKxsOrderQueueListener {
 			RabbitKxsOrderQueueMQ.MsgEntity parse = RabbitKxsOrderQueueMQ.parse(msg);
 			//处理百城千团订单，创建活动
 			if(parse.getProductId() == 100 && parse.getStatus() == 2){
-
+				CampAddBcqtTeamDTO campAddBcqtTeamDTO = new CampAddBcqtTeamDTO();
+				campAddBcqtTeamDTO.setCaptainId(Long.valueOf(parse.getUserId()));
+				campAddBcqtTeamDTO.setTeamName(parse.getRemark());
+				remoteUserService.addBcqtTeam(campAddBcqtTeamDTO, SecurityConstants.FROM_IN);
 			}
 
 			channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);

kxs-system/kxs-system-biz/src/main/java/com/kxs/system/biz/controller/admin/SysCampController.java

@@ -181,12 +181,6 @@ public class SysCampController {
 
         return kxsBcqtTeamService.getByBcqtPage(page, param);
     }
-
-    /**
-     * 修改团名
-     * @param kxsBcqtTeam  实体
-     * @return
-     */
     @PostMapping("/updateBcqt")
 //    @PreAuthorize("@pms.hasPermission('sys_camp_bcqt_update')")
     public R updateBcqt(@RequestBody KxsBcqtTeam kxsBcqtTeam) {
@@ -194,18 +188,5 @@ public class SysCampController {
         return R.ok();
     }
 
-    /**
-     * 训练营-百城千团列表-激活统计
-     *
-     * @param id 查询团队id
-     * @return 训练营-百城千团列表
-     */
-    @GetMapping("/bcqtGetDetail")
-//    @PreAuthorize("@pms.hasPermission('sys_camp_bcqt_detail')")
-    public R bcqtGetDetail(@RequestParam("id") Long id) {
-
-        return kxsBcqtTeamService.bcqtGetDetail(id);
-    }
-
 }
 

kxs-system/kxs-system-biz/src/main/java/com/kxs/system/biz/service/KxsBcqtTeamService.java

@@ -85,6 +85,5 @@ public interface KxsBcqtTeamService extends IService<KxsBcqtTeam> {
 
     void updateBcqt(KxsBcqtTeam kxsBcqtTeam);
 
-    R bcqtGetDetail(Long id);
 }
 

kxs-system/kxs-system-biz/src/main/java/com/kxs/system/biz/service/impl/KxsBcqtTeamServiceImpl.java

@@ -404,44 +404,6 @@ public class KxsBcqtTeamServiceImpl extends ServiceImpl<KxsBcqtTeamMapper, KxsBc
         kxsBcqtTeam1.setTeamName(kxsBcqtTeam.getTeamName());
         kxsBcqtTeamMapper.updateById(kxsBcqtTeam1);
     }
-
-    @Override
-    public R bcqtGetDetail(Long id) {
-        KxsBcqtTeam kxsBcqtTeam = kxsBcqtTeamMapper.selectById(id);
-        if (kxsBcqtTeam == null){
-            return R.failed("团队不存在");
-        }
-        List<KxsBcqtTeamDetail> kxsBcqtTeamDetails = kxsBcqtTeamDetailMapper.selectList(Wrappers.<KxsBcqtTeamDetail>query().lambda().eq(KxsBcqtTeamDetail::getTeamId, kxsBcqtTeam.getId()));
-        return R.ok(kxsBcqtTeamDetails);
-    }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
 
 
 }