package com.product.patch.service;

import com.alibaba.fastjson.JSONArray;
import com.product.common.io.FileUtils;
import com.product.core.dao.BaseDao;
import com.product.core.entity.FieldSetEntity;
import com.product.core.exception.BaseException;
import com.product.core.service.support.AbstractBaseService;
import com.product.core.spring.context.SpringMVCContextHolder;
import com.product.module.sys.entity.SystemUser;
import com.product.patch.config.CmnConst;
import com.product.patch.config.ErrorCode;
import com.product.patch.service.idel.IPatchDeployService;
import com.product.patch.util.RSAUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.File;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Map;

/**
 * Copyright © 6c
 *
 * @Date: 2022-04-02 16:59
 * @Author: 6c
 * @Description: 补丁部署
 */
@Service
public class PatchDeployService extends AbstractBaseService implements IPatchDeployService {
    @Autowired
    private BaseDao baseDao;

    public void testDeploy() {
//        FieldSetEntity fse = new FieldSetEntity();
//        fse.setTableName("temp_table");
//        deploy(fse);

        String clientUUID = "a34f8818-d36d-4d82-b1b0-dbc0d2e70a03";
        String fileName = "D:/worksoft/IDEA/workspace/product-server_v2.0.0/product-server-patch/patch/deploy_content.txt";
        String decodeData = extractPatchContent(clientUUID);
        FileUtils.writeToFile(fileName, decodeData, "utf-8", false);
        checkPatch(decodeData);
    }

    /**
     * 部署
     * @param fse
     */
    public void deploy(FieldSetEntity fse) {
        SystemUser curUser = SpringMVCContextHolder.getCurrentUser();
        String clientUUID = curUser == null ? fse.getString(CmnConst.FIELD_CLIENT_UUID) : curUser.getClientUuid();
        String decodeData = extractPatchContent(clientUUID);
        // 验证补丁
        checkPatch(decodeData);

    }

    /**
     * 提取补丁内容
     * @param clientUUID
     * @return
     */
    private String extractPatchContent(String clientUUID) {
        try {
            String filePath = "D:/worksoft/IDEA/workspace/product-server_v2.0.0/product-server-patch/patch/2022-04-08-admin.patch";
            File file = new File(filePath);
            String decodedData = FileUtils.readFileToString(file, "utf-8");
            // 解密
            FieldSetEntity mainFse = baseDao.getFieldSetEntityByFilter(CmnConst.TABLE_PRODUCT_SYS_ORG_LEVELS, "org_level_id=1", new Object[]{}, false);
            FieldSetEntity mainCryptFse = baseDao.getFieldSetEntityByFilter(CmnConst.TABLE_PRODUCT_SYS_PATCH_KEY, "org_level_uuid=?", new Object[]{mainFse.getUUID()}, false);
            String  mainPublicKey = mainCryptFse.getString(CmnConst.FIELD_PUBLIC_KEY);
            FieldSetEntity clientCryptFse = baseDao.getFieldSetEntityByFilter(CmnConst.TABLE_PRODUCT_SYS_PATCH_KEY, "org_level_uuid=?", new Object[]{clientUUID}, false);
            String clientPrivateKey = clientCryptFse.getString(CmnConst.FIELD_PIRVATE_KEY);
            decodedData = RSAUtil.privateDecrypt(decodedData, RSAUtil.getPrivateKey(clientPrivateKey));
            decodedData = RSAUtil.publicDecrypt(decodedData, RSAUtil.getPublicKey(mainPublicKey));
            return decodedData;
        } catch (Exception e) {
            e.printStackTrace();
            throw new BaseException(ErrorCode.EXTRACT_EXTRACT_CONTENT_FAIL);
        }
    }

    /**
     * 验证补丁内容
     * @param content
     */
    private void checkPatch(String content) {
        String curDate = new SimpleDateFormat(CmnConst.DATE_FORMAT_1).format(new Date());
        if (!content.startsWith(curDate + " " + CmnConst.DEFAULT_OPERATOR)) {
            throw new BaseException(ErrorCode.EXTRACT_UNQUALIFIED);
        }
    }

    private Map<String, String> getCurDatabaseInfo(JSONArray resultArr) {
        return null;
    }
}