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

package common.crm.bean;

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 user extends CrmBase {
    public user(Logger logger) {
        super(logger);
    }

    @Override
    public void autoAction() throws YosException {
        //同步E-订单区域经理账号至CRM
        ArrayList<crm_datasync> datasyncList = get("区域经理账号", "sys_users", 100);
        for (crm_datasync datasync : datasyncList) {
            QuerySQL querySQL = SQLFactory.createQuerySQL(dbConnect, "sys_users", "name", "accountno").setTableAlias("t1");
            querySQL.addJoinTable(JOINTYPE.inner, "sys_usersite", "t2", "t1.userid = t2.userid");
            querySQL.setWhere("t1.userid", datasync.ownerid);
            querySQL.setWhere("t2.usertype", 2).setWhere("t2.siteid", "MD");
            Rows userRow = querySQL.query();
            if (userRow.isNotEmpty()) {
                JSONObject dataObject = new JSONObject();
                dataObject.put("username", userRow.get(0).getString("accountno"));
                dataObject.put("name", userRow.get(0).getString("name"));
                dataObject.put("password", "654321");
                dataObject.put("state", 1);//人员状态：-2:异常，-1:已删除，0:停用，1:正常
                dataObject.put("fagentNum", "meida");
                dataObject.put("fbrandId", fbrandId);
                dataObject.put("userType", 16);
                dataObject.put("fnotes", "根据E-订单账号表自动生成");
                String result = postCRM(dataObject.toJSONString(), "/ext/bragent/registerAgentHr/regionalManager");
                JSONObject jsonObject = JSONObject.parseObject(result);
                if (jsonObject.getBooleanValue("success")) {
                    datasync.suc();
                } else {
                    datasync.fail();
                }
            } else {
                datasync.del();
            }
        }
    }
}