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 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(); } } } }