package com.tianbo.analysis.service.imp;

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.tianbo.analysis.config.CustomsProperties;
import com.tianbo.analysis.dao.TRANSTOARRIVEEXPORTMapper;
import com.tianbo.analysis.model.MANIFEST_AIR_CHANGE;
import com.tianbo.analysis.model.ResultJson;
import com.tianbo.analysis.model.TRANSTOARRIVEEXPORT;
import com.tianbo.analysis.service.TransArriveExportService;
import com.tianbo.analysis.tools.XmlTools;
import com.tianbo.util.Date.DateUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.FileUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.util.ResourceUtils;
import org.thymeleaf.TemplateEngine;
import org.thymeleaf.context.Context;
import org.thymeleaf.exceptions.TemplateInputException;
import org.xml.sax.SAXParseException;

import javax.annotation.Resource;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.Date;
import java.util.List;
import java.util.Locale;
import java.util.UUID;

@Service
@Slf4j
public class TransArriveExportImpl implements TransArriveExportService {

    @Resource
    TRANSTOARRIVEEXPORTMapper mapper;

    @Autowired
    private TemplateEngine templateEngine;

    @Autowired
    private CustomsProperties customsProperties;

    @Value("${customs.transarrive.xml-save}")
    private String saveXmlForSendDir;

    @Override
    public int addTransArriveExport(TRANSTOARRIVEEXPORT transtoarriveexport) {
        return mapper.insertSelective(transtoarriveexport);
    }

    @Override
    public int ediTransArriveExport(TRANSTOARRIVEEXPORT transtoarriveexport) {
        return mapper.updateByPrimaryKeySelective(transtoarriveexport);
    }

    @Override
    public int delTransArriveExport(String autoid) {
        return mapper.deleteByPrimaryKey(autoid);
    }

    @Override
    public PageInfo<TRANSTOARRIVEEXPORT> selectTrans(TRANSTOARRIVEEXPORT transtoarriveexport, int pageNum, int pageSize) {
        PageHelper.startPage(pageNum,pageSize);
        List<TRANSTOARRIVEEXPORT> list=mapper.selectTrans(transtoarriveexport);
        PageInfo<TRANSTOARRIVEEXPORT> pageInfo=new PageInfo<TRANSTOARRIVEEXPORT>(list);
        return pageInfo;
    }

    @Override
    public ResultJson send(TRANSTOARRIVEEXPORT record) {
        //设置海关相关信息配置
        record.setApplycode(customsProperties.getApplyCode());
        record.setApplyname(customsProperties.getApplyName());
        record.setCopcode(customsProperties.getCopCode());
        record.setClientseqno(customsProperties.getTransarrive().getClientSeqno());
        record.setHostid(customsProperties.getTransarrive().getHostId());
        record.setCertno(customsProperties.getTransarrive().getCertNo());
        //操作员IC卡号
        record.setInputopid(customsProperties.getInputOpId());
        // 操作员姓名
        record.setInputopname(customsProperties.getInputOpName());
        ResultJson resultJson= new ResultJson();
        try{

            String nowStr = DateUtil.getCurrentTime17();
            //从配置文件读取
            String messageID = "CN_"
                    + "TRANSARRIVE_EXPORT_DECLARE"
                    + "_1P0_"
                    + record.getCustomscode()+
                    "_" + nowStr;

            Context context = new Context();
            context.setVariable("declare",record);
            context.setLocale(Locale.SIMPLIFIED_CHINESE);

            //生成的文件名
            String fileName = messageID + ".xml";
            //生成的报文路径,带斜杠
            String filePath = customsProperties.getTransarrive().getXmlSave()+fileName;
            File file = ResourceUtils.getFile(filePath);
            /**
             * 中文的地方在模板中要用utext,否则中文会被 escape 转义
             */
            String xmlStr = templateEngine.process("transToArrive/EXPORT_DECLARE_TPL.xml",context);
            log.info("[XML-INFO]\n{}",xmlStr);

            boolean valied = XmlTools.validateXMLSchemaThrowError("xsd/ETAImportMessage.xsd", xmlStr);
            if (valied) {
                FileUtils.writeStringToFile(file, xmlStr, StandardCharsets.UTF_8);
                //todo:更新发送状态,插入发送日志

                resultJson.setCode("200");
                resultJson.setMsg("报文发送成功");
                log.info("[XML-BUILD]- 报文已生成到目录{}",filePath);
            }
        }catch (FileNotFoundException e){
            e.printStackTrace();
            resultJson.setCode("401");
            resultJson.setMsg("报文发送失败,文件未找到");
            resultJson.setError(e.toString());
            log.error("报文发送失败,[{}]文件未找到",e.toString());
        }catch (IOException e) {
            e.printStackTrace();
            resultJson.setCode("402");
            resultJson.setMsg("报文发送失败,文件读取失败");
            resultJson.setError(e.toString());
            log.error("报文发送失败,[{}]文件IO读取失败",e.toString());
        }catch (TemplateInputException e){
            resultJson.setCode("404");
            resultJson.setMsg("报文发送失败,报文模板未找到");
            resultJson.setError(e.toString());
            log.error("报文发送失败,[{}]报文模板未找到",e.toString());
        }catch (SAXParseException e){
            log.error("[XML-ERR]-xml报文校验失败:[{}]", e.getMessage());
            resultJson.setCode("400");
            resultJson.setMsg("报文发送失败,报文校验不通过");
            resultJson.setError(e.getMessage());
        } catch (Exception ignored){
            resultJson.setCode("405");
            resultJson.setMsg("报文发送失败,其他错误");
            resultJson.setError(ignored.toString());
            log.error("[XML-ERR]-报文发送失败,其他错误:[{}]", ignored.getMessage());
        }
        return resultJson;
    }

    @Override
    public ResultJson batchSend(List<String> autoIDlist) {
        ResultJson resultJson = new ResultJson();
        List<TRANSTOARRIVEEXPORT> list = selectListByAutoIDS(autoIDlist);
        for (TRANSTOARRIVEEXPORT manifestAirChange : list) {
            ResultJson result = send(manifestAirChange);
            /*if (!result){
                message = message + manifestAirChange.getWaybillnomaster() +"发送失败\n";
            }*/
        }
        return  resultJson;
    }

    @Override
    public List<TRANSTOARRIVEEXPORT> selectListByAutoIDS(List<String> autoIDlist) {
        List<TRANSTOARRIVEEXPORT> list =  mapper.selectListByAutoIDS(autoIDlist);
        return list;
    }
}