package com.engine.salary.action.salaryArchive;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import weaver.conn.RecordSet;
import weaver.soa.workflow.request.RequestInfo;

import java.util.List;
import java.util.Map;

public class SalaryArchiveCommon {

    public static Map<String,Object> getImportDatas(String requestId,String tableName){
        RecordSet rs = new RecordSet();
        String sql = "select xzxmdr,xzxmpldr from "+tableName+" where requestid="+requestId;
        rs.executeQuery(sql);
        Map<String,Object> dataMap = Maps.newHashMap();
        List<Map<String, Object>> importDatas = Lists.newArrayList();
        dataMap.put("importDatas",importDatas);
        if (rs.next()){
            String data = rs.getString("xzxmdr");
            dataMap.put("imageId",rs.getString("xzxmpldr"));
            if (data != null && !"".equals(data)){
                if (data.contains("&quot;")){
                    data = data.replaceAll("&quot;","\"");
                }
                JSONArray jsonObject = JSONObject.parseArray(data);
                jsonObject.forEach(e -> {
                    Map<String, Object> map = (Map<String, Object>)e;
                    importDatas.add(map);
                });
            }
        }
        String queryImageId = "select imagefileid from docimagefile where docid = ?";
        if (dataMap.get("imageId") != null && !"".equals(dataMap.get("imageId"))){
            rs.executeQuery(queryImageId,dataMap.get("imageId"));
            if (rs.next()){
                dataMap.put("imageId",rs.getString("imagefileid"));
            }
        }

        return dataMap;
    }
}