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.ZHUtils.BOC;

import java.util.ArrayList;

public class AutoQueryBoclnfosForZH_TZ extends ServiceController {


    @Override
    public void serviceRun() throws YosException {
        String siteid = "TZ";
        Rows rows = dbConnect.runSqlQuery("select count(0) sum from sa_bankstatement where datediff(now(),createdate)=0 and siteid='" + siteid + "' and banktype ='中行'");
        long begnum = rows.get(0).getLong("sum") + 1;
        if (begnum == 0) {
            begnum = 1;
        }

        JSONArray jsonArray = new BOC().query(siteid, (int) begnum);
        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);
                }
            }
        }
    }
}