4dkankan-fusion/src/main/java/com/fdkankan/fusion/mq/consumer/OsgbToB3dmConsumer.java

package com.fdkankan.fusion.mq.consumer;

import cn.hutool.core.io.FileUtil;
import com.alibaba.fastjson.JSONObject;
import com.fdkankan.fusion.common.FilePath;
import com.fdkankan.fusion.common.ResultCode;
import com.fdkankan.fusion.common.util.*;
import com.fdkankan.fusion.exception.BusinessException;
import com.fdkankan.fusion.service.ICommonUploadService;
import com.fdkankan.geo.GeoTransformUtil;
import com.fdkankan.redis.util.RedisUtil;
import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j;
import org.locationtech.proj4j.ProjCoordinate;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.w3c.dom.Document;
import org.w3c.dom.Element;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import java.io.File;
import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.UUID;

/**
 * 场景封存解封 mq
 */
@Slf4j
@Component
public class OsgbToB3dmConsumer {

    @Autowired
    ICommonUploadService commonUploadService;
    @Value("${upload.query-path}")
    private String ossUrlPrefix;
    @RabbitListener(
            queuesToDeclare = @Queue("${queue.model.osgbToB3dm:queue-model-osgbToB3dm}")
            ,concurrency = "1"
    )
    public void consumerQueue(Channel channel, Message message)  {
        String localPath = null;
        try {
            String messageId = message.getMessageProperties().getMessageId();
            String msg = new String(message.getBody(), StandardCharsets.UTF_8);
            log.info("osgbToB3dm-mq--messageId:{},msg:{}",messageId,msg);

            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
            JSONObject jsonObject = JSONObject.parseObject(msg);
            localPath = jsonObject.getString("path");

            File file = new File(localPath);
            if(!file.exists()){
                log.info("osgbToB3dm-mq--messageId:{},msg:{},文件不存在",messageId,localPath);
                return;
            }
            commonUploadService.updateStatus(localPath,0);
            ///mnt/manage/media-library/result/ea041f3237df46568f4e83e723e743d4
            String sourcePath = file.getParentFile().getPath() +"/"+UUID.randomUUID().toString().replace("-","");

            OBJToGLBUtil.OsgbToB3dm(localPath,sourcePath);
            String b3dmJsonPath =  FileWriterUtil.checkB3dmTileset(new File(sourcePath));
            if(b3dmJsonPath == null){
                log.info("osgbToB3dm-mq--messageId:{},msg:{},转化失败tileset.json不存在",messageId,localPath);
                throw new BusinessException(-1,"转化失败tileset.json不存在");
            }
            String ossPath = sourcePath.replace("/mnt/","");
            ShellUtil.yunUpload(sourcePath,ossPath);
            String url = ossUrlPrefix + b3dmJsonPath.replace("/mnt/","");
            HashMap<String,String> resultMap = ReadXmlUtil.getLatMap(file);
            if(resultMap != null && !resultMap.isEmpty()){
                commonUploadService.updateByPath(localPath,url,resultMap.get("wgs84"),resultMap.get("gcj02"));
            }else {
                commonUploadService.updateByPath(localPath,url);
            }
            FileUtil.del(localPath);
            FileUtil.del(sourcePath);
        }catch (Exception e){
            log.info("osgbToB3dm-status----消费失败",e);
            if(localPath != null){
                commonUploadService.updateStatus(localPath,-1);
            }
        }finally {

        }

    }

}