package com.uas.eis.service.Impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.uas.eis.core.config.SpObserver;
import com.uas.eis.dao.BaseDao;
import com.uas.eis.dao.SqlRowList;
import com.uas.eis.sdk.dto.*;
import com.uas.eis.sdk.entity.ApiResult;
import com.uas.eis.sdk.resp.ApiResponse;
import com.uas.eis.service.RequestSTKService;
import com.uas.eis.service.STKService;
import com.uas.eis.utils.*;
import com.uas.eis.vo.stkVo.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;

import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.util.*;

/**
 * @author zhuxl
 * @date 2024-10-12
 */
@Service
public class STKServiceImpl implements STKService {
    private final Logger logger = LoggerFactory.getLogger(this.getClass());
    @Autowired
    private BaseDao baseDao;

    @Autowired
    private RequestSTKService requestSTKService;

    @Override
    public ApiResult<String> getAssistBalanceCount(HttpServletRequest request, AssistBalanceDTO dto) {
        String yearmonth = dto.getYearMonth();
        boolean bool = baseDao.checkIf("PeriodsDetail", "pd_code='MONTH-A' and pd_status=99 and pd_detno='"+yearmonth+"'");
        if (bool) {
            int batch_no = baseDao.getSeqId("STK_ASSISTBALANCE2_SEQ");
            String res = baseDao.callProcedure("SP_INSER_ASSISTBALANCE",
                    new Object[] {batch_no,yearmonth});
            if (res != null && !res.trim().equals("")) {
                return ApiResponse.successRsp("1",res,request.getHeader("RequestId"),null);
            }else{
                int count = baseDao.getCount("select count(1)  from STK_ASSISTBALANCE where FPERIODNAME='" + yearmonth + "'");
                BalanceCountDTO balanceCountDTO = new BalanceCountDTO();
                balanceCountDTO.setYearMonth(yearmonth);
                balanceCountDTO.setBatch_no(batch_no);
                balanceCountDTO.setCount(count);
                String s = JSON.toJSONString(balanceCountDTO, SerializerFeature.WriteMapNullValue);
                return ApiResponse.successRsp("1",null,request.getHeader("RequestId"),s);
            }
        }else{
            return ApiResponse.successRsp("2001","当前期间未结账！",request.getHeader("RequestId"),null);
        }
    }

    @Override
    public ApiResult<String> getAssistBalance(HttpServletRequest request, AssistBalanceDTO dto) {
        String yearmonth = dto.getYearMonth();
        String batch_no = dto.getBatch_no();
        int pageNum = Integer.valueOf(dto.getPageNum());
        int pageSize = Integer.valueOf(dto.getPageSize());
        int start = ((pageNum - 1) * pageSize + 1);
        int end = pageNum * pageSize;
        boolean bool = baseDao.checkIf("PeriodsDetail", "pd_code='MONTH-A' and pd_status=99 and pd_detno='"+yearmonth+"'");
        if (bool) {
            List<BalanceDTO> balanceDTO = baseDao.query("SELECT fid,fssno,fsoid,forgunitno,forgunitname,fperiodname,fcurrencyname,forginalcname,faccountno,faccountname," +
                    "     fassistgrptype,fassistgrpno1,fassistgrpname1," +
                    "     fassistgrpno2,fassistgrpname2," +
                    "     fbeginbalancefor,fbeginbalancelocal," +
                    "     fcreditfor,fcreditlocal,fdebitfor,fdebitlocal," +
                    "     fendbalancefor,fendbalancelocal," +
                    "     fyearpnlfor,fyearpnllocal," +
                    "     fyeardebitfor,fyeardebitlocal,fyearcreditfor,fyearcreditlocal," +
                    "     faccoccurfor,faccoccurlocal," +
                    "     to_char(fmodifytime,'yyyy-mm-dd hh24:mi:ss') fmodifytime,to_char(flockintime,'yyyy-mm-dd hh24:mi:ss') flockintime," +
                    "     fdisablelabel,fdatamode,fbilltype,batch_no from stk_assistbalance " +
                    "WHERE batch_no ="+batch_no+" and FPERIODNAME = '"+yearmonth +"' and QUERYDETNO >= " +start+ " and QUERYDETNO <= " + end, BalanceDTO.class);

            //String s = JSON.toJSONString(rs.getResultList(), SerializerFeature.WriteMapNullValue);
            String s = JSON.toJSONString(balanceDTO, SerializerFeature.WriteMapNullValue);
            return ApiResponse.successRsp("1",null,request.getHeader("RequestId"),s);
        }else{
            return ApiResponse.successRsp("2001","当前期间未结账！",request.getHeader("RequestId"),null);
        }
    }

    @Override
    public ApiResult<String> getCashFlowCount(HttpServletRequest request, AssistBalanceDTO dto) {
        String yearmonth = dto.getYearMonth();
        boolean bool = baseDao.checkIf("PeriodsDetail", "pd_code='MONTH-A' and pd_status=99 and pd_detno='"+yearmonth+"'");
        if (bool) {
            int batch_no = baseDao.getSeqId("STK_CASHFLOW2_SEQ");
            String res = baseDao.callProcedure("SP_INSER_CASHFLOW",
                    new Object[] {batch_no,yearmonth});
            if (res != null && !res.trim().equals("")) {
                return ApiResponse.successRsp("2001",res,request.getHeader("RequestId"),null);
            }else{
                int count = baseDao.getCount("select count(1)  from STK_CASHFLOW where FPERIODNAME='" + yearmonth + "'");
                BalanceCountDTO balanceCountDTO = new BalanceCountDTO();
                balanceCountDTO.setYearMonth(yearmonth);
                balanceCountDTO.setBatch_no(batch_no);
                balanceCountDTO.setCount(count);
                String s = JSON.toJSONString(balanceCountDTO, SerializerFeature.WriteMapNullValue);
                return ApiResponse.successRsp("1",null,request.getHeader("RequestId"),s);
            }
        }else{
            return ApiResponse.successRsp("2001","当前期间未结账！",request.getHeader("RequestId"),null);
        }
    }

    @Override
    public ApiResult<String> getCashFlow(HttpServletRequest request, AssistBalanceDTO dto) {
        String yearmonth = dto.getYearMonth();
        String batch_no = dto.getBatch_no();
        int pageNum = Integer.valueOf(dto.getPageNum());
        int pageSize = Integer.valueOf(dto.getPageSize());
        int start = ((pageNum - 1) * pageSize + 1);
        int end = pageNum * pageSize;
        boolean bool = baseDao.checkIf("PeriodsDetail", "pd_code='MONTH-A' and pd_status=99 and pd_detno='"+yearmonth+"'");
        if (bool) {
            List<CashFlowDTO> cashFlowDTO = baseDao.query("SELECT fid,fssno,fsoid,forgunitno,forgunitname,fperiodname,fcurrencyname,forginalcname,faccountno,faccountname," +
                    "     fassistgrptype,fassistgrpno1,fassistgrpname1," +
                    "     fassistgrpno2,fassistgrpname2," +
                    "     fytdamt,fytdlocalamt," +
                    "     fmodifytime,flockintime,fdisablelabel,fdatamode,batch_no from STK_CASHFLOW " +
                    "WHERE batch_no ="+batch_no+" and FPERIODNAME = '"+yearmonth +"' and QUERYDETNO >= " +start+ " and QUERYDETNO <= " + end, CashFlowDTO.class);

            //String s = JSON.toJSONString(rs.getResultList(), SerializerFeature.WriteMapNullValue);
            String s = JSON.toJSONString(cashFlowDTO, SerializerFeature.WriteMapNullValue);
            return ApiResponse.successRsp("1",null,request.getHeader("RequestId"),s);
        }else{
            return ApiResponse.successRsp("2001","当前期间未结账！",request.getHeader("RequestId"),null);
        }
    }



    @Override
    public ApiResult<String> updateCustVend(UpdateCustVendDTO dto) {
        int vid = dto.getVid();
        String vtype = dto.getVtype();
        //查询出的新增，变更数据
        List<SaveOrChangeCustomerDetailDto> sourceDataList = new ArrayList<>();
        if ("客户".equals(vtype)) {
            SqlRowList cust = baseDao
                    .queryForRowSet("select CU_CODE,CU_NAME,UID_TYPE,CU_BUSINESSCODE,NVL(CUSTOMER_TYPE,'C0201') CUSTOMER_TYPE,IS_VALID,nvl(CREATED_ORG,CU_CODE) CREATED_ORG,CREATED_SYSTEM,ISTEMPORARY " +
                            "from Customer left join STK_CUSTVEND on cu_businesscode = uid2 where cu_id="
                            + vid + "");
            while (cust.next()) {
                SaveOrChangeCustomerDetailDto sourcedao = new SaveOrChangeCustomerDetailDto();
                sourcedao.setS_CODE(cust.getString("CU_CODE"));
                sourcedao.setNAME(cust.getString("CU_NAME"));
                sourcedao.setUID_TYPE(cust.getString("UID_TYPE"));
                sourcedao.setUID(cust.getString("CU_BUSINESSCODE"));
                sourcedao.setCUSTOMER_TYPE(cust.getString("CUSTOMER_TYPE"));
                sourcedao.setIS_VALID(cust.getString("IS_VALID"));
                sourcedao.setCREATED_ORG(cust.getString("CREATED_ORG"));
                sourcedao.setCREATED_SYSTEM(cust.getString("CREATED_SYSTEM"));
                sourcedao.setISTEMPORARY(cust.getString("ISTEMPORARY"));
                sourceDataList.add(sourcedao);
            }

        }else{
            SqlRowList vend = baseDao
                    .queryForRowSet("select VE_CODE,VE_NAME,UID_TYPE,VE_WEBSERVER,NVL(CUSTOMER_TYPE,'S0201') CUSTOMER_TYPE,IS_VALID,nvl(CREATED_ORG,VE_CODE) CREATED_ORG,CREATED_SYSTEM,ISTEMPORARY " +
                            "from Vendor left join STK_CUSTVEND on ve_webserver = uid2 where ve_id="
                            + vid + "");
            while (vend.next()) {
                SaveOrChangeCustomerDetailDto sourcedao = new SaveOrChangeCustomerDetailDto();
                sourcedao.setS_CODE(vend.getString("VE_CODE"));
                sourcedao.setNAME(vend.getString("VE_NAME"));
                sourcedao.setUID_TYPE(vend.getString("UID_TYPE"));
                sourcedao.setUID(vend.getString("VE_WEBSERVER"));
                sourcedao.setCUSTOMER_TYPE(vend.getString("CUSTOMER_TYPE"));
                sourcedao.setIS_VALID(vend.getString("IS_VALID"));
                sourcedao.setCREATED_ORG(vend.getString("CREATED_ORG"));
                sourcedao.setCREATED_SYSTEM(vend.getString("CREATED_SYSTEM"));
                sourcedao.setISTEMPORARY(vend.getString("ISTEMPORARY"));
                sourceDataList.add(sourcedao);
            }
        }
        List<SaveOrChangeCustomerDataVo> changeCustomerVos = new ArrayList<>();
        //调用深投控api接口
        for(SaveOrChangeCustomerDetailDto detailDto : sourceDataList){
            SaveOrChangeCustomerDataVo saveOrChangeCustomerVo = null;
            try {
                logger.info("开始调用客商api");
                saveOrChangeCustomerVo = requestSTKService.updateKSPostParam(detailDto);
            } catch (Exception e) {
                e.printStackTrace();
            }
            changeCustomerVos.add(saveOrChangeCustomerVo);
        }

        ApiResult result = new ApiResult();
        return result.setData(changeCustomerVos);
    }


    @Override
    public ApiResult<String> getAssistBalanceCountTest(HttpServletRequest request, AssistBalanceDTO dto) {
        //取yearMonth
        String yearMonth = dto.getYearMonth();
        System.out.println("body参数打印："+dto.getYearMonth());
        //获取header参数
        Map<String,String> headerMap = getHeaderParams(request);
        System.out.println("header参数：【AccessKey："+headerMap.get("AccessKey")+",Timestamp："+headerMap.get("Timestamp")
        +"，RequestId："+headerMap.get("RequestId")+"，Signature："+headerMap.get("Signature")+"】");
        return null;
    }



    //客商信息
    @Override
    public void getCustvend(TravellingMerchantVo travellingMerchantVo , Boolean isdelete) {
        if(null == travellingMerchantVo.getData() || CollectionUtils.isEmpty(travellingMerchantVo.getData().getList())){
            return ;
        }
        List<CustvendDTO> custvendDTOS = travellingMerchantVo.getData().getList();
        /*List<String> sqls = new ArrayList<>();
        if (isdelete) {
            sqls.add("delete from STK_CUSTVEND");
        }*/
        for (int i = 0; i < custvendDTOS.size(); i++) {
            List<String> sqls = new ArrayList<>();
            sqls.add("delete from STK_CUSTVEND where id = " + custvendDTOS.get(i).getId());
            /*String regBizsCope = "to_clob("+StringUtil.splitAndConcat(custvendDTOS.get(i).getReg_bizscope(), 1333, "'", "'", ")||to_clob(")+")";
            if (StringUtils.isEmpty(custvendDTOS.get(i).getReg_bizscope()) ||custvendDTOS.get(i).getReg_bizscope().length()==0) {
                regBizsCope = "''";
            }*/
            sqls.add("insert into STK_CUSTVEND(ID,S_ID,S_CODE,NAME,UID_TYPE,UID2,CUSTOMER_TYPE,IS_VALID,CREATED_ORG,CREATED_SYSTEM,ISTEMPORARY,MDM_CODE,REG_COUNTRY, " +
                    "REG_PLACE,REG_REP,REG_CAPTIAL,REG_PERIOD,REG_BIZSCOPE," +
                    "REG_FOUNDEDDATE," +
                    "REG_URL,REG_ADDRESS," +
                    "CREAT_TIME," +
                    "UPDATE_TIME,SERIAL) " +
                    "values ("+custvendDTOS.get(i).getId()+","+custvendDTOS.get(i).getS_id()+",'"+custvendDTOS.get(i).getS_code()+"','"+custvendDTOS.get(i).getName()+"'" +
                    ",'"+custvendDTOS.get(i).getUid_type()+"','"+custvendDTOS.get(i).getUid()+"','"+custvendDTOS.get(i).getCustomer_type()+"','"+custvendDTOS.get(i).getIs_valid()+"'" +
                    ",'"+custvendDTOS.get(i).getCreated_org()+"','"+custvendDTOS.get(i).getCreated_system()+"','"+custvendDTOS.get(i).getIstemporary()+"','"+custvendDTOS.get(i).getMdm_code()+"','"+custvendDTOS.get(i).getReg_country()+"'" +
                    ",'"+custvendDTOS.get(i).getReg_place()+"','"+custvendDTOS.get(i).getReg_rep()+"','"+custvendDTOS.get(i).getReg_captial()+"','"+custvendDTOS.get(i).getReg_period()+"',' '" +
                    ",case when '"+custvendDTOS.get(i).getReg_foundeddate()+"' = 'null' then null else to_date(to_char(to_timestamp('"+custvendDTOS.get(i).getReg_foundeddate()+"','yyyy-mm-dd hh24:mi:ssxff'),'yyyy-mm-dd hh24:mi:ss'),'yyyy-mm-dd hh24:mi:ss') end" +
                    ",'"+custvendDTOS.get(i).getReg_url()+"','"+custvendDTOS.get(i).getReg_address()+"'" +
                    ",case when '"+custvendDTOS.get(i).getCreat_time()+"' = 'null' then null else to_date(to_char(to_timestamp('"+custvendDTOS.get(i).getCreat_time()+"','yyyy-mm-dd hh24:mi:ssxff'),'yyyy-mm-dd hh24:mi:ss'),'yyyy-mm-dd hh24:mi:ss') end" +
                    ",case when '"+custvendDTOS.get(i).getUpdate_time()+"' = 'null' then null else to_date(to_char(to_timestamp('"+custvendDTOS.get(i).getUpdate_time()+"','yyyy-mm-dd hh24:mi:ssxff'),'yyyy-mm-dd hh24:mi:ss'),'yyyy-mm-dd hh24:mi:ss') end,'"+custvendDTOS.get(i).getSerial()+"')");
            sqls.add("update STK_CUSTVEND set UID_TYPENAME = case when UID_TYPE = '01' then '统一社会信用代码' when UID_TYPE = '02' then '邓氏编码' " +
                    "when UID_TYPE = '03' then '身份证号码（大陆）' when UID_TYPE = '04' then '护照号码（包括港澳身份证号码）'  when UID_TYPE = '06' then '身份证护照组合' " +
                    "when UID_TYPE = '99' then '其他编码' end where id = " + custvendDTOS.get(i).getId());
            sqls.add("update STK_CUSTVEND set CUSTOMER_TYPENAME = case when CUSTOMER_TYPE = 'C0201' then '单位客户' when CUSTOMER_TYPE = 'C0202' then '个人客户' " +
                    "when CUSTOMER_TYPE = 'S0201' then '单位供应商' when CUSTOMER_TYPE = 'S0202' then '个人供应商' end where id = " + custvendDTOS.get(i).getId());
            sqls.add("update STK_CUSTVEND set IS_VALIDNAME = case when IS_VALID = '1' then '有效' else '无效' end, " +
                    "ISTEMPORARYNAME = case when ISTEMPORARY = '1' then '是' else '否' end where id = " + custvendDTOS.get(i).getId());
            baseDao.execute(sqls);
        }
    }

    //客商信息(当天)
    @Override
    public void getCustvendDay(TravellingMerchantVo travellingMerchantVo , Boolean isdelete) {
        if(null == travellingMerchantVo.getData() || CollectionUtils.isEmpty(travellingMerchantVo.getData().getList())){
            return ;
        }
        List<CustvendDTO> custvendDTOS = travellingMerchantVo.getData().getList();
        List<String> sqls = new ArrayList<>();
        for (int i = 0; i < custvendDTOS.size(); i++) {
            sqls.add("delete from STK_CUSTVEND where id = " + custvendDTOS.get(i).getId());
            sqls.add("insert into STK_CUSTVEND(ID,S_ID,S_CODE,NAME,UID_TYPE,UID2,CUSTOMER_TYPE,IS_VALID,CREATED_ORG,CREATED_SYSTEM,ISTEMPORARY,MDM_CODE,REG_COUNTRY, " +
                    "REG_PLACE,REG_REP,REG_CAPTIAL,REG_PERIOD,REG_BIZSCOPE," +
                    "REG_FOUNDEDDATE," +
                    "REG_URL,REG_ADDRESS," +
                    "CREAT_TIME," +
                    "UPDATE_TIME,SERIAL) " +
                    "values ("+custvendDTOS.get(i).getId()+","+custvendDTOS.get(i).getS_id()+",'"+custvendDTOS.get(i).getS_code()+"','"+custvendDTOS.get(i).getName()+"'" +
                    ",'"+custvendDTOS.get(i).getUid_type()+"','"+custvendDTOS.get(i).getUid()+"','"+custvendDTOS.get(i).getCustomer_type()+"','"+custvendDTOS.get(i).getIs_valid()+"'" +
                    ",'"+custvendDTOS.get(i).getCreated_org()+"','"+custvendDTOS.get(i).getCreated_system()+"','"+custvendDTOS.get(i).getIstemporary()+"','"+custvendDTOS.get(i).getMdm_code()+"','"+custvendDTOS.get(i).getReg_country()+"'" +
                    ",'"+custvendDTOS.get(i).getReg_place()+"','"+custvendDTOS.get(i).getReg_rep()+"','"+custvendDTOS.get(i).getReg_captial()+"','"+custvendDTOS.get(i).getReg_period()+"',' '" +
                    ",case when '"+custvendDTOS.get(i).getReg_foundeddate()+"' = 'null' then null else to_date(to_char(to_timestamp('"+custvendDTOS.get(i).getReg_foundeddate()+"','yyyy-mm-dd hh24:mi:ssxff'),'yyyy-mm-dd hh24:mi:ss'),'yyyy-mm-dd hh24:mi:ss') end" +
                    ",'"+custvendDTOS.get(i).getReg_url()+"','"+custvendDTOS.get(i).getReg_address()+"'" +
                    ",case when '"+custvendDTOS.get(i).getCreat_time()+"' = 'null' then null else to_date(to_char(to_timestamp('"+custvendDTOS.get(i).getCreat_time()+"','yyyy-mm-dd hh24:mi:ssxff'),'yyyy-mm-dd hh24:mi:ss'),'yyyy-mm-dd hh24:mi:ss') end" +
                    ",case when '"+custvendDTOS.get(i).getUpdate_time()+"' = 'null' then null else to_date(to_char(to_timestamp('"+custvendDTOS.get(i).getUpdate_time()+"','yyyy-mm-dd hh24:mi:ssxff'),'yyyy-mm-dd hh24:mi:ss'),'yyyy-mm-dd hh24:mi:ss') end,'"+custvendDTOS.get(i).getSerial()+"')");
            sqls.add("update STK_CUSTVEND set UID_TYPENAME = case when UID_TYPE = '01' then '统一社会信用代码' when UID_TYPE = '02' then '邓氏编码' " +
                    "when UID_TYPE = '03' then '身份证号码（大陆）' when UID_TYPE = '04' then '护照号码（包括港澳身份证号码）'  when UID_TYPE = '06' then '身份证护照组合' " +
                    "when UID_TYPE = '99' then '其他编码' end where id = " + custvendDTOS.get(i).getId());
            sqls.add("update STK_CUSTVEND set CUSTOMER_TYPENAME = case when CUSTOMER_TYPE = 'C0201' then '单位客户' when CUSTOMER_TYPE = 'C0202' then '个人客户' " +
                    "when CUSTOMER_TYPE = 'S0201' then '单位供应商' when CUSTOMER_TYPE = 'S0202' then '个人供应商' end where id = " + custvendDTOS.get(i).getId());
            sqls.add("update STK_CUSTVEND set IS_VALIDNAME = case when IS_VALID = '1' then '有效' else '无效' end, " +
                    "ISTEMPORARYNAME = case when ISTEMPORARY = '1' then '是' else '否' end where id = " + custvendDTOS.get(i).getId());
        }
        baseDao.execute(sqls);
    }



    //获取现金流
    @Override
    public void getCashFlowItems(CashFlowItemsVo cashFlowItemsVo , Boolean isdelete) {
        if(null == cashFlowItemsVo.getData()){
            return ;
        }
        List<CashFlowItemsDataVo> cashFlowItemsDataVo = cashFlowItemsVo.getData().getList();
        List<String> sqls = new ArrayList<>();
        if (isdelete) {
            sqls.add("delete from STK_CASHFLOWDJ");
        }
        for (int i = 0; i < cashFlowItemsDataVo.size(); i++) {
            sqls.add("delete from STK_CASHFLOWDJ where id = " + cashFlowItemsDataVo.get(i).getID());
            sqls.add("insert into STK_CASHFLOWDJ(ID,NUMBER2,CODE,NAME,LONGNUMBER,LEVEL2,FULLNAME,ISLEAF,CTRLSTRATEGY,SOURCEDATA,BITINDEX,SRCINDEX," +
                    "TYPE,DIRECTION,ISDEALACTIVITY,ISEXCHANGERATE,ISPREFIT,NOTICE,CHECKITEMHELP,ISASSIST,ISSCHEDULEITEM,MODIFIER_NUMBER," +
                    "MODIFIER_NAME,CREATEORG_NUMBER,ORG_NUMBER,ORG_NAME,USEORG_NUMBER,USEORG_NAME,STATUS,ENABLE," +
                    "CREATE_TIME," +
                    "UPDATE_IME," +
                    "SOURCE,ASSISTENTRY) " +
                    "values ("+cashFlowItemsDataVo.get(i).getID()+",'"+cashFlowItemsDataVo.get(i).getNUMBER()+"','"+cashFlowItemsDataVo.get(i).getCODE()+"','"+cashFlowItemsDataVo.get(i).getNAME()+"'" +
                    ",'"+cashFlowItemsDataVo.get(i).getLONGNUMBER()+"','"+cashFlowItemsDataVo.get(i).getLEVEL()+"','"+cashFlowItemsDataVo.get(i).getFULLNAME()+"','"+cashFlowItemsDataVo.get(i).getISLEAF()+"'" +
                    ",'"+cashFlowItemsDataVo.get(i).getCTRLSTRATEGY()+"','"+cashFlowItemsDataVo.get(i).getSOURCEDATA()+"','"+cashFlowItemsDataVo.get(i).getBITINDEX()+"','"+cashFlowItemsDataVo.get(i).getSRCINDEX()+"'" +
                    ",'"+cashFlowItemsDataVo.get(i).getTYPE()+"','"+cashFlowItemsDataVo.get(i).getDIRECTION()+"','"+cashFlowItemsDataVo.get(i).getISDEALACTIVITY()+"','"+cashFlowItemsDataVo.get(i).getISEXCHANGERATE()+"','"+cashFlowItemsDataVo.get(i).getISPREFIT()+"','"+cashFlowItemsDataVo.get(i).getNOTICE()+"'" +
                    ",'"+cashFlowItemsDataVo.get(i).getCHECKITEMHELP()+"','"+cashFlowItemsDataVo.get(i).getISASSIST()+"','"+cashFlowItemsDataVo.get(i).getISSCHEDULEITEM()+"','"+cashFlowItemsDataVo.get(i).getMODIFIER_NUMBER()+"'" +
                    ",'"+cashFlowItemsDataVo.get(i).getMODIFIER_NAME()+"','"+cashFlowItemsDataVo.get(i).getCREATEORG_NUMBER()+"','"+cashFlowItemsDataVo.get(i).getORG_NUMBER()+"','"+cashFlowItemsDataVo.get(i).getORG_NAME()+"'" +
                    ",'"+cashFlowItemsDataVo.get(i).getUSEORG_NUMBER()+"','"+cashFlowItemsDataVo.get(i).getUSEORG_NAME()+"','"+cashFlowItemsDataVo.get(i).getSTATUS()+"','"+cashFlowItemsDataVo.get(i).getENABLE()+"'" +
                    ",case when '"+cashFlowItemsDataVo.get(i).getCREATE_TIME()+"' = 'null' then null else to_date(to_char(to_timestamp('"+cashFlowItemsDataVo.get(i).getCREATE_TIME()+"','yyyy-mm-dd hh24:mi:ssxff'),'yyyy-mm-dd hh24:mi:ss'),'yyyy-mm-dd hh24:mi:ss') end" +
                    ",case when '"+cashFlowItemsDataVo.get(i).getUPDATE_IME()+"' = 'null' then null else to_date(to_char(to_timestamp('"+cashFlowItemsDataVo.get(i).getUPDATE_IME()+"','yyyy-mm-dd hh24:mi:ssxff'),'yyyy-mm-dd hh24:mi:ss'),'yyyy-mm-dd hh24:mi:ss') end" +
                    //",'"+cashFlowItemsDataVo.get(i).getSOURCE()+"','"+cashFlowItemsDataVo.get(i).getASSISTENTRY()+"')");
                    ",'"+cashFlowItemsDataVo.get(i).getSOURCE()+"','')");
        }
        baseDao.execute(sqls);
    }


    //获取会计科目
    @Override
    public void getAccountantProject(AccountantProjectVo accountantProjectVo , Boolean isdelete) {
        if(null == accountantProjectVo.getData()){
            return ;
        }
        List<AccountantProjectDataVo> accountantProjectDataVo = accountantProjectVo.getData().getList();
        List<String> sqls = new ArrayList<>();
        if (isdelete) {
            sqls.add("delete from STK_CATEGORYDJ");
        }
        for (int i = 0; i < accountantProjectDataVo.size(); i++) {
            sqls.add("delete from STK_CATEGORYDJ where id = " + accountantProjectDataVo.get(i).getID());
            sqls.add("insert into STK_CATEGORYDJ(ID,S_ID,S_NUMBER,CODE,NAME,PARENTID,S_PARENTNUM,PARENTCODE,PARENTNAME,LONGNUMBER,LONGNAME,LEVEL2,ISLEAF,ACCOUNTTABLENUMBER,ACCOUNTTABLENAME,ACCOUNTTYPENUMBER,ACCOUNTTYPENAME," +
                    "PLTYPE,DC,ACCRUALDIRECTION,ISCASH,ISBANK,ISCASHEQUIVALENT,ACNOTICE,ISCHANGECURRENCY,BW,ISQTY,ISASSIST,NOCURRENCYRADIO,DESCURRENCYRADIO,ALLCURRENCYRADIO,ACCTCURRENCY,HELPCODE,ISALLOWCA,ORGCONTROLLEVEL,ISMANUAL,ACCHECK,ISJOURNAL," +
                    "STARTDATE," +
                    "ENDDATE," +
                    "MREUTYPENUMBER,MREUTYPENAME,MEASUREUNITCNUM,MEASUREUNITNAME,CREATEORGCODE,CREATEORGNAME,ORG_NUMBER,ORG_NAME,USEORG_NUMBER,USEORG_NAME,CTRLSTRATEGY,STATUS,ENABLE," +
                    "CREATE_TIME," +
                    "UPDATE_TIME," +
                    "DISABLEDATE," +
                    "SOURCE,ENTRYCHECKITEM,ENTRYCURRENCY) " +
                    "values ("+accountantProjectDataVo.get(i).getID()+",'"+accountantProjectDataVo.get(i).getS_ID()+"','"+accountantProjectDataVo.get(i).getS_NUMBER()+"','"+accountantProjectDataVo.get(i).getCODE()+"','"+accountantProjectDataVo.get(i).getNAME()+"'" +
                    ",'"+accountantProjectDataVo.get(i).getPARENTID()+"','"+accountantProjectDataVo.get(i).getS_PARENTNUM()+"','"+accountantProjectDataVo.get(i).getPARENTCODE()+"','"+accountantProjectDataVo.get(i).getPARENTNAME()+"'" +
                    ",'"+accountantProjectDataVo.get(i).getLONGNUMBER()+"','"+accountantProjectDataVo.get(i).getLONGNAME()+"','"+accountantProjectDataVo.get(i).getLEVEL()+"','"+accountantProjectDataVo.get(i).getISLEAF()+"'" +
                    ",'"+accountantProjectDataVo.get(i).getACCOUNTTABLENUMBER()+"','"+accountantProjectDataVo.get(i).getACCOUNTTABLENAME()+"','"+accountantProjectDataVo.get(i).getACCOUNTTYPENUMBER()+"','"+accountantProjectDataVo.get(i).getACCOUNTTYPENAME()+"'" +
                    ",'"+accountantProjectDataVo.get(i).getPLTYPE()+"','"+accountantProjectDataVo.get(i).getDC()+"','"+accountantProjectDataVo.get(i).getACCRUALDIRECTION()+"','"+accountantProjectDataVo.get(i).getISCASH()+"','"+accountantProjectDataVo.get(i).getISBANK()+"'" +
                    ",'"+accountantProjectDataVo.get(i).getISCASHEQUIVALENT()+"','"+accountantProjectDataVo.get(i).getACNOTICE()+"','"+accountantProjectDataVo.get(i).getISCHANGECURRENCY()+"','"+accountantProjectDataVo.get(i).getBW()+"','"+accountantProjectDataVo.get(i).getISQTY()+"'" +
                    ",'"+accountantProjectDataVo.get(i).getISASSIST()+"','"+accountantProjectDataVo.get(i).getNOCURRENCYRADIO()+"','"+accountantProjectDataVo.get(i).getDESCURRENCYRADIO()+"','"+accountantProjectDataVo.get(i).getALLCURRENCYRADIO()+"','"+accountantProjectDataVo.get(i).getACCTCURRENCY()+"','"+accountantProjectDataVo.get(i).getHELPCODE()+"'" +
                    ",'"+accountantProjectDataVo.get(i).getISALLOWCA()+"','"+accountantProjectDataVo.get(i).getORGCONTROLLEVEL()+"','"+accountantProjectDataVo.get(i).getISMANUAL()+"','"+accountantProjectDataVo.get(i).getACCHECK()+"','"+accountantProjectDataVo.get(i).getISJOURNAL()+"'" +
                    ",case when '"+accountantProjectDataVo.get(i).getSTARTDATE()+"' = 'null' then null else to_date(to_char(to_timestamp('"+accountantProjectDataVo.get(i).getSTARTDATE()+"','yyyy-mm-dd hh24:mi:ssxff'),'yyyy-mm-dd hh24:mi:ss'),'yyyy-mm-dd hh24:mi:ss') end" +
                    ",case when '"+accountantProjectDataVo.get(i).getENDDATE()+"' = 'null' then null else to_date(to_char(to_timestamp('"+accountantProjectDataVo.get(i).getENDDATE()+"','yyyy-mm-dd hh24:mi:ssxff'),'yyyy-mm-dd hh24:mi:ss'),'yyyy-mm-dd hh24:mi:ss') end" +
                    ",'"+accountantProjectDataVo.get(i).getMREUTYPENUMBER()+"','"+accountantProjectDataVo.get(i).getMREUTYPENAME()+"','"+accountantProjectDataVo.get(i).getMEASUREUNITCNUM()+"','"+accountantProjectDataVo.get(i).getMEASUREUNITNAME()+"','"+accountantProjectDataVo.get(i).getCREATEORGCODE()+"'" +
                    ",'"+accountantProjectDataVo.get(i).getCREATEORGNAME()+"','"+accountantProjectDataVo.get(i).getORG_NUMBER()+"','"+accountantProjectDataVo.get(i).getORG_NAME()+"','"+accountantProjectDataVo.get(i).getUSEORG_NUMBER()+"','"+accountantProjectDataVo.get(i).getUSEORG_NAME()+"'" +
                    ",'"+accountantProjectDataVo.get(i).getCTRLSTRATEGY()+"','"+accountantProjectDataVo.get(i).getSTATUS()+"','"+accountantProjectDataVo.get(i).getENABLE()+"'" +
                    ",case when '"+accountantProjectDataVo.get(i).getCREATE_TIME()+"' = 'null' then null else to_date(to_char(to_timestamp('"+accountantProjectDataVo.get(i).getCREATE_TIME()+"','yyyy-mm-dd hh24:mi:ssxff'),'yyyy-mm-dd hh24:mi:ss'),'yyyy-mm-dd hh24:mi:ss') end" +
                    ",case when '"+accountantProjectDataVo.get(i).getUPDATE_TIME()+"' = 'null' then null else to_date(to_char(to_timestamp('"+accountantProjectDataVo.get(i).getUPDATE_TIME()+"','yyyy-mm-dd hh24:mi:ssxff'),'yyyy-mm-dd hh24:mi:ss'),'yyyy-mm-dd hh24:mi:ss') end" +
                    ",case when '"+accountantProjectDataVo.get(i).getDISABLEDATE()+"' = 'null' then null else to_date(to_char(to_timestamp('"+accountantProjectDataVo.get(i).getDISABLEDATE()+"','yyyy-mm-dd hh24:mi:ssxff'),'yyyy-mm-dd hh24:mi:ss'),'yyyy-mm-dd hh24:mi:ss') end" +
                    //",'"+accountantProjectDataVo.get(i).getSOURCE()+"','"+accountantProjectDataVo.get(i).getENTRYCHECKITEM()+"','"+accountantProjectDataVo.get(i).getENTRYCURRENCY()+"')");
                    ",'"+accountantProjectDataVo.get(i).getSOURCE()+"','','"+accountantProjectDataVo.get(i).getENTRYCURRENCY()+"')");
        }
        baseDao.execute(sqls);
    }

    /**
     * 获取客商数据前，先删除客商信息（暂时）
     * */
    @Override
    public void delete(){
        baseDao.execute("delete from STK_CUSTVEND");
    }


    private Map<String, JSONArray> getData(HttpServletRequest request){
        Map<String, JSONArray> map = new HashMap<>();
        try {
            String data = PSHttpUtils.readRaw(request.getInputStream());
            JSONObject jsonObject = JSON.parseObject(data);
            Object data1 = jsonObject.get("Data");
            JSONObject jsonObject1 = JSON.parseObject(StringUtil.nvl(data1,""));
            Object page1 = jsonObject1.get("Page1");
            Object page2 = jsonObject1.get("Page2");
            JSONArray jsonArray = JSON.parseArray(StringUtil.nvl(page1, ""));
            map.put("main",jsonArray);
            JSONArray jsonArray1 = JSON.parseArray(StringUtil.nvl(page2, ""));
            map.put("detail",jsonArray1);
        } catch (IOException e) {
            logger.info("参数解析异常信息："+e.getMessage());
            e.printStackTrace();
        }
        return map;
    }


    /**
     * 获取header参数
     * */
    public Map<String,String> getHeaderParams(HttpServletRequest request){
        String accessKey = request.getHeader("AccessKey");
        String timestamp = request.getHeader("Timestamp");
        String requestId = request.getHeader("RequestId");
        String signature = request.getHeader("Signature");
        Map<String,String> headerMap = new HashMap<>();
        if(!StringUtils.isEmpty(accessKey)){
            headerMap.put("AccessKey",accessKey);
        }
        if(!StringUtils.isEmpty(timestamp)){
            headerMap.put("Timestamp",timestamp);
        }
        if(!StringUtils.isEmpty(requestId)){
            headerMap.put("RequestId",requestId);
        }
        if(!StringUtils.isEmpty(signature)){
            headerMap.put("Signature",signature);
        }
        return headerMap;
    }

    private JSONObject getJsonData(HttpServletRequest request){
        JSONObject jsonObject=null;
        try {
            String data = PSHttpUtils.readRaw(request.getInputStream());
            jsonObject = JSON.parseObject(data);
        } catch (IOException e) {
            logger.info("参数解析异常信息："+e.getMessage());
            e.printStackTrace();
        }
        return jsonObject;
    }

}