|
@@ -1,9 +1,11 @@
|
|
|
package com.fdkankan.manage_jp.mq.consumer;
|
|
|
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
+import com.fdkankan.manage_jp.service.IProjectSceneGpsService;
|
|
|
import com.fdkankan.manage_jp.service.impl.SceneCommonService;
|
|
|
import com.rabbitmq.client.Channel;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.apache.poi.ss.formula.functions.Odd;
|
|
|
import org.springframework.amqp.core.Message;
|
|
|
import org.springframework.amqp.rabbit.annotation.Queue;
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
@@ -23,6 +25,8 @@ public class SceneCopyResultConsumer {
|
|
|
|
|
|
@Autowired
|
|
|
SceneCommonService sceneCommonService;
|
|
|
+ @Autowired
|
|
|
+ IProjectSceneGpsService projectSceneGpsService;
|
|
|
|
|
|
@RabbitListener(
|
|
|
queuesToDeclare = @Queue("${queue.scene.copy.result:ucenter-copy-scene-result}")
|
|
@@ -40,7 +44,7 @@ public class SceneCopyResultConsumer {
|
|
|
String newNum = jsonObject.getString("newNum");
|
|
|
|
|
|
sceneCommonService.copyResult(newNum);
|
|
|
-
|
|
|
+ projectSceneGpsService.saveByCopy(oldNum,newNum);
|
|
|
}catch (Exception e){
|
|
|
log.info("copy-scene-result----消费失败",e);
|
|
|
}
|