|
@@ -18,7 +18,7 @@ import com.fdkankan.modeling.service.ISceneService;
|
|
import com.fdkankan.modeling.utils.DingDingUtils;
|
|
import com.fdkankan.modeling.utils.DingDingUtils;
|
|
import com.fdkankan.modeling.utils.PushMsgUtil;
|
|
import com.fdkankan.modeling.utils.PushMsgUtil;
|
|
import com.fdkankan.mq.message.BuildSceneMqMessage;
|
|
import com.fdkankan.mq.message.BuildSceneMqMessage;
|
|
-import com.fdkankan.oss.UploadUtils;
|
|
|
|
|
|
+import com.fdkankan.common.util.UploadToOssUtil;
|
|
import com.fdkankan.platform.api.vo.User;
|
|
import com.fdkankan.platform.api.vo.User;
|
|
import com.fdkankan.redis.util.RedisUtil;
|
|
import com.fdkankan.redis.util.RedisUtil;
|
|
import com.fdkankan.utils.constant.ConstantFilePath;
|
|
import com.fdkankan.utils.constant.ConstantFilePath;
|
|
@@ -42,6 +42,7 @@ import org.springframework.util.CollectionUtils;
|
|
import org.springframework.util.ObjectUtils;
|
|
import org.springframework.util.ObjectUtils;
|
|
import org.springframework.web.client.RestTemplate;
|
|
import org.springframework.web.client.RestTemplate;
|
|
|
|
|
|
|
|
+import javax.annotation.Resource;
|
|
import java.io.*;
|
|
import java.io.*;
|
|
import java.security.InvalidKeyException;
|
|
import java.security.InvalidKeyException;
|
|
import java.security.NoSuchAlgorithmException;
|
|
import java.security.NoSuchAlgorithmException;
|
|
@@ -90,8 +91,8 @@ public class BuildSceneReceiver implements MessageListenerConcurrently {
|
|
private String prefixAli;
|
|
private String prefixAli;
|
|
|
|
|
|
|
|
|
|
- @Autowired
|
|
|
|
- private UploadUtils uploadUtils;
|
|
|
|
|
|
+ @Resource
|
|
|
|
+ private UploadToOssUtil uploadUtils;
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgExt,
|
|
public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgExt,
|