package com.jttech.pfcs.services.impl;

import java.io.File;
import java.util.concurrent.TimeUnit;

import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.Session;
import com.jttech.pfcs.util.SftpUtil;
import com.jttech.pfcs.vo.req.bill.FtpServerParam;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import com.alibaba.fastjson.JSONObject;
import com.jttech.pfcs.services.IBillService;
import com.jttech.pfcs.vo.resp.ResponseVo;
import com.jttech.pfcs.vo.req.bill.BillApiReqVo;
import com.jttech.pfcs.vo.resp.bill.BillApiRespVo;

import okhttp3.*;
import org.springframework.web.multipart.MultipartFile;

/**
 * 账单服务
 * @author wanghc
 * @version 1.0.0
 * @date 2023-03-08
 */
@Service
public class BillServiceImpl implements IBillService {

    private Logger mLogger = LoggerFactory.getLogger(getClass());

    private static final String contentType = "application/json;charset=utf-8";

    /**
     * 请求编码格式
     */
    private static final String charset = "UTF-8";


    private static final OkHttpClient client = new OkHttpClient.Builder()
            .connectionPool(new ConnectionPool(500, 5, TimeUnit.MINUTES)).connectTimeout(10000, TimeUnit.MILLISECONDS)
            .readTimeout(60000, TimeUnit.MILLISECONDS).build();

    /**
     * post请求
     *
     * @param reqVo
     * @return
     */
    @Override
    public ResponseVo post(BillApiReqVo reqVo) {
        try {
            mLogger.info("BillServiceImpl.post reqvo={}", reqVo);
            Request request = new Request.Builder().url(reqVo.getUrl())
                    .post(RequestBody.create(MediaType.parse(contentType), JSONObject.toJSONString(reqVo)))
                    .addHeader("Content-Type", contentType)
                    .build();
            Response resp = client.newCall(request).execute();
            String body = new String(resp.body().bytes(), charset);
            mLogger.info("BillServiceImpl.post resp={}", body);
            return new ResponseVo(JSONObject.parseObject(body, BillApiRespVo.class));
        } catch (Exception e) {
            mLogger.error("BillServiceImpl.post error={}", e);
            String errMsg = e.getMessage() == null ? "接口调用异常" : e.getMessage();
            errMsg = errMsg.substring(0, Math.min(20, errMsg.length()));
            return ResponseVo.fail(-999, errMsg);
        }
    }

    /**
     * 文件上传
     *
     * @param files
     * @param ftpServer
     * @return
     */
    @Override
    public ResponseVo fileUpload(MultipartFile[] files, FtpServerParam ftpServer) {
        Session session = null;
        ChannelSftp sftpChannel = null;
        try {
            session = SftpUtil.getSession(ftpServer.getIp(), ftpServer.getUser(), ftpServer.getPwd(), ftpServer.getPort());
            sftpChannel = SftpUtil.openChannel(session);
            //文件目录没有就需要创建
            String saveDirPath = ftpServer.getSaveDirPath();
            File targetDirFile = new File(saveDirPath);
            if (!targetDirFile.exists()) {
                if (!targetDirFile.mkdirs()) {
                    // 创建处理目录失败
                    throw new Exception("创建文件目录失败");
                }
            }
            SftpUtil.cd(sftpChannel, saveDirPath);
            for (MultipartFile file : files) {
                String fileName = file.getOriginalFilename();
                //放入文件
                SftpUtil.put(sftpChannel, file.getBytes(), fileName);
            }
        } catch (Exception e) {
            mLogger.error("BillServiceImpl.fileUpload err={} server={}", e, ftpServer);
            throw new RuntimeException(e.getMessage());
        } finally {
            if (null != sftpChannel) {
                sftpChannel.disconnect();
            }
            if (null != session) {
                session.disconnect();
            }
        }
        return ResponseVo.ok();
    }
}