package service;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import common.ServiceController;
import common.YosException;
import common.data.Rows;
import restcontroller.webmanage.sale.bankstatement.CreateBankstatement;
import restcontroller.webmanage.sale.bankstatement.NHUtils.qyzl;

import java.util.ArrayList;
import java.util.Calendar;

public class AutoQueryBoclnfosForNH_NB extends ServiceController {


    @Override
    public void serviceRun() throws YosException {
        int HOUR_OF_DAY = Calendar.getInstance().get(Calendar.HOUR_OF_DAY);
        if (HOUR_OF_DAY <= 6) {
            return;
        }
        String StartDate;
        String siteid = "NB";
        Rows rows = dbConnect.runSqlQuery("select tranflow from sa_bankstatement where siteid='" + siteid + "' and banktype='农行' order by tranflow desc");
        if (rows.isEmpty()) {
            StartDate = "0";
        } else {
            String tranflow = rows.get(0).getString("tranflow");
            StartDate = tranflow.substring(0, 8);
        }
        JSONArray jsonArray = new qyzl().query(siteid, StartDate);
        if (!jsonArray.isEmpty()) {
            JSONObject jsonObject = CreateBankstatement.createBankstatement(this, jsonArray, siteid, "农行");
            dbConnect.runSqlUpdate((ArrayList<String>) jsonObject.get("sqlList"));
            ArrayList<Long> idList = (ArrayList<Long>) jsonObject.get("idList");
            for (Long id : idList) {
                Rows statusRows = dbConnect.runSqlQuery("select status from sa_bankstatement where siteid='" + siteid + "' and sa_bankstatementid=" + id);
                if (statusRows.isNotEmpty() && statusRows.get(0).getString("status").equals("未入账")) {
                    CreateBankstatement.autoRemind(this, "bankstatementerr", id, siteid);
                }
            }
        }
    }

}