md_YOS/src/custom/common/crm/bean/saleArea.java

package common.crm.bean;

import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import common.YosException;
import common.data.QuerySQL;
import common.data.Rows;
import common.data.SQLFactory;
import org.apache.logging.log4j.Logger;
import common.crm.bean.core.CrmBase;

import java.util.ArrayList;

public class saleArea extends CrmBase {
    public saleArea(Logger logger) {
        super(logger);
    }

    @Override
    public void autoAction() throws YosException {
        //同步E-订单营销区域至CRM
        ArrayList<crm_datasync> datasyncList = get("营销区域", "sa_salearea", 100);
        for (crm_datasync datasync : datasyncList) {
            JSONArray dataArray = new JSONArray();
            QuerySQL querySQL = SQLFactory.createQuerySQL(dbConnect, "sa_salearea", "sa_saleareaid", "areanum", "areaname").setTableAlias("t1");
            querySQL.addJoinTable(JOINTYPE.left, "sa_salearea", "t2", "t1.parentid = t2.sa_saleareaid", "areanum as upareanum");
            querySQL.setWhere("t1.sa_saleareaid", datasync.ownerid);
            Rows areaRows = querySQL.query();
            if (areaRows.isNotEmpty() && !areaRows.get(0).getString("areanum").isEmpty()) {
                JSONObject dataObject = new JSONObject();
                dataObject.put("fareaNum", areaRows.get(0).getString("areanum"));
                dataObject.put("fareaName", areaRows.get(0).getString("areaname"));
                dataObject.put("fuparea", areaRows.get(0).getString("upareanum"));

                QuerySQL salerQuery = SQLFactory.createQuerySQL(dbConnect, "sa_salearea_hr").setTableAlias("t1");
                salerQuery.addJoinTable(JOINTYPE.inner, "sys_hr", "t2", "t1.hrid=t2.hrid");
                salerQuery.addJoinTable(JOINTYPE.inner, "sys_users", "t3", "t2.userid=t3.userid", "accountno", "name", "status");
                salerQuery.setWhere("t1.siteid", "MD").setWhere("sa_saleareaid", areaRows.get(0).getString("sa_saleareaid"));
                Rows salerrows = salerQuery.query();
                if (salerrows.isNotEmpty()) {
                    dataObject.put("fsaler", salerrows.get(0).getString("accountno"));
                    dataObject.put("fsalerName", salerrows.get(0).getString("name"));
                    dataObject.put("status", salerrows.get(0).getString("status"));
                }
                dataObject.put("fbrandId", fbrandId);
                dataArray.add(dataObject);
                String result = postCRM(dataArray.toJSONString(), "/ext/brSaleArea/batchSaveBrSaleAreas/1");
                JSONObject jsonObject = JSONObject.parseObject(result);
                if (jsonObject.getBooleanValue("success")) {
                    datasync.suc();
                } else {
                    datasync.fail();
                }
            } else {
                datasync.del();
            }
        }
    }
}