violet/ensign
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 同步所有客户到下单平台

Browse Source
This commit is contained in:
zzs 2025-04-09 16:05:52 +08:00
parent 7a5944c413
commit bc20e7940e
3 changed files with 134 additions and 128 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

99
src/main/java/com/yem/or/task/CustomerTask.java
View File

@ -5,6 +5,7 @@ import com.yem.wm.task.YunZhiJaGetOpenidTask;
import com.yem.wm.utils.YEM; import com.yem.wm.utils.YEM;
import kd.bos.context.RequestContext; import kd.bos.context.RequestContext;
import kd.bos.dataentity.entity.DynamicObject; import kd.bos.dataentity.entity.DynamicObject;
import kd.bos.exception.KDBizException;
import kd.bos.exception.KDException; import kd.bos.exception.KDException;
import kd.bos.logging.Log; import kd.bos.logging.Log;
import kd.bos.logging.LogFactory; import kd.bos.logging.LogFactory;
@ -14,65 +15,75 @@ import kd.bos.schedule.executor.AbstractTask;
import kd.bos.servicehelper.BusinessDataServiceHelper; import kd.bos.servicehelper.BusinessDataServiceHelper;
import kd.bos.servicehelper.operation.SaveServiceHelper; import kd.bos.servicehelper.operation.SaveServiceHelper;
import java.io.IOException;
import java.util.Map; import java.util.Map;
import static com.yem.or.utils.OrderApiUtils.getToken;
/** /**
* ljw * ljw
* 同步数据至下单平台 * 同步数据至下单平台
*/ */
public class CustomerTask extends AbstractTask { public class CustomerTask extends AbstractTask {
private static final Log log = LogFactory.getLog(CustomerTask.class);
@Override @Override
public void execute(RequestContext requestContext, Map<String, Object> map) throws KDException { public void execute(RequestContext requestContext, Map<String, Object> map) throws KDException {
Log log = LogFactory.getLog(YunZhiJaGetOpenidTask.class);
String accessToken = "";
try {
Map<String, String> token = getToken();
accessToken = token.get("token");
} catch (IOException e) {
throw new RuntimeException(e);
}
if (YEM.isEmpty(accessToken)) {
throw new KDBizException("获取AccessToken失败");
}
QFilter qFilter = new QFilter("status", QCP.equals, "C"); QFilter qFilter = new QFilter("status", QCP.equals, "C");
DynamicObject[] dynamicObjects = BusinessDataServiceHelper.load("bd_customer", "id,number,name,yem_checkboxfield,yem_torderid,group,yem_groupcustomers" DynamicObject[] dynamicObjects = BusinessDataServiceHelper.load("bd_customer", "id,number,name,yem_checkboxfield,yem_torderid,group,yem_groupcustomers"
, new QFilter[]{qFilter}); , new QFilter[]{qFilter});
for (DynamicObject dynamicObject : dynamicObjects) { for (DynamicObject dynamicObject : dynamicObjects) {
DynamicObject group = dynamicObject.getDynamicObject("group"); String number = dynamicObject.getString("number");
if (group != null) { String name = dynamicObject.getString("name");
long groupid = group.getLong("id"); DynamicObject groupcustomers = dynamicObject.getDynamicObject("yem_groupcustomers");
DynamicObject[] bd_customergroup = BusinessDataServiceHelper.load("bd_customergroup", "id,number,parent" if (YEM.isEmpty(groupcustomers)) {
, new QFilter[]{new QFilter("parent.number", QCP.equals, "11602"), new QFilter("id", QCP.equals, groupid)}); log.error(" [SKIP] 业务主体为空 ");
if (bd_customergroup.length > 0) { continue;
for (int i = 0; i < bd_customergroup.length; i++) { }
String number = dynamicObject.getString("number"); if (!groupcustomers.containsProperty("yem_torderid")) {
String name = dynamicObject.getString("name"); groupcustomers = BusinessDataServiceHelper.loadSingleFromCache(groupcustomers.getDataEntityType().getName(), new QFilter[]{new QFilter("id", "=", groupcustomers.getPkValue())});
DynamicObject groupcustomers = dynamicObject.getDynamicObject("yem_groupcustomers"); String group_torderid = groupcustomers.getString("yem_torderid");
if (YEM.isEmpty(groupcustomers)) { if (YEM.isEmpty(group_torderid)) {
continue; log.error(" [SKIP] 业务主体未同步 ");
} continue;
if (!groupcustomers.containsProperty("yem_torderid")) {
groupcustomers = BusinessDataServiceHelper.loadSingleFromCache(groupcustomers.getDataEntityType().getName(), new QFilter[]{new QFilter("id", "=", groupcustomers.getPkValue())});
String group_torderid = groupcustomers.getString("yem_torderid");
if (YEM.isEmpty(group_torderid)) {
continue;
}
}
Map<String, String> demands;
if (dynamicObject.getBoolean("yem_checkboxfield")) {
String torderid = dynamicObject.getString("yem_torderid");
if(YEM.isEmpty(torderid)) {
continue;
}
Long id = Long.valueOf(torderid);
demands = OrderApiUtils.demands(name, number, groupcustomers, false, id);
} else {
demands = OrderApiUtils.demands(name, number, groupcustomers, true, null);
}
String msg = demands.get("msg");
if (msg == null) {
String id = demands.get("id");
if (YEM.isNotEmpty(id)) {
dynamicObject.set("yem_torderid", id);
dynamicObject.set("yem_checkboxfield", true);
SaveServiceHelper.update(dynamicObject);
SaveServiceHelper.save(new DynamicObject[]{dynamicObject});
}
}
}
} }
} }
Map<String, String> demands;
if (dynamicObject.getBoolean("yem_checkboxfield")) {
String torderid = dynamicObject.getString("yem_torderid");
if (YEM.isEmpty(torderid)) {
log.error(" [SKIP] 已同步但ID为空 ");
continue;
}
Long id = Long.valueOf(torderid);
demands = OrderApiUtils.demands(accessToken, name, number, groupcustomers, false, id);
} else {
demands = OrderApiUtils.demands(accessToken, name, number, groupcustomers, true, null);
}
log.info(demands.toString());
if (demands.containsKey("id")) {
String id = demands.get("id");
dynamicObject.set("yem_torderid", id);
dynamicObject.set("yem_checkboxfield", true);
SaveServiceHelper.save(new DynamicObject[]{dynamicObject});
} else if (demands.containsKey("msg")) {
log.error(demands.get("msg"));
}
} }
} }
} }

119
src/main/java/com/yem/or/utils/OrderApiUtils.java
View File

@ -138,7 +138,7 @@ public class OrderApiUtils {
resStatus.put("msg", "未知客户"); resStatus.put("msg", "未知客户");
return resStatus; return resStatus;
} }
customer = BusinessDataServiceHelper.loadSingle(customer.getPkValue(),customer.getDynamicObjectType().getName()); customer = BusinessDataServiceHelper.loadSingle(customer.getPkValue(), customer.getDynamicObjectType().getName());
dynamicObject.set("yem_customer", customer);//客户\ dynamicObject.set("yem_customer", customer);//客户\
dynamicObject.set("yem_customername", customer.getString("name")); dynamicObject.set("yem_customername", customer.getString("name"));
@ -421,7 +421,7 @@ public class OrderApiUtils {
/** /**
* 新增用户 * 新增用户
*/ */
public static Map<String, String> demands(String username, String userNumber, DynamicObject groupcustomers, boolean isCreate, Long existId) { public static Map<String, String> demands(String accessToken, String username, String userNumber, DynamicObject groupcustomers, boolean isCreate, Long existId) {
String requestUrl; String requestUrl;
if (isCreate) { if (isCreate) {
requestUrl = ENDPOINTS + "/admin-api/system/user/create"; requestUrl = ENDPOINTS + "/admin-api/system/user/create";
@ -429,65 +429,57 @@ public class OrderApiUtils {
requestUrl = ENDPOINTS + "/admin-api/system/user/update"; requestUrl = ENDPOINTS + "/admin-api/system/user/update";
} }
Map<String, String> headers = null;
try {
headers = getToken();
} catch (IOException e) {
throw new RuntimeException(e);
}
Map<String, String> resStatus = new HashMap<>(); Map<String, String> resStatus = new HashMap<>();
// 租户ID Map<String, String> headers = new HashMap<>();
if ("success".equals(headers.get("status"))) { headers.put("Authorization", "Bearer " + (accessToken));
String accessToken = headers.get("token"); Map<String, Object> requestBody = new HashMap<>();
headers.put("Authorization", "Bearer " + (accessToken)); if (!groupcustomers.containsProperty("yem_torderid") || !groupcustomers.containsProperty("number") || !groupcustomers.containsProperty("name")) {
Map<String, Object> requestBody = new HashMap<>(); groupcustomers = BusinessDataServiceHelper.loadSingleFromCache(groupcustomers.getDataEntityType().getName(), new QFilter[]{new QFilter("id", "=", groupcustomers.getPkValue())});
if (!groupcustomers.containsProperty("yem_torderid") || !groupcustomers.containsProperty("number") || !groupcustomers.containsProperty("name")) { }
groupcustomers = BusinessDataServiceHelper.loadSingleFromCache(groupcustomers.getDataEntityType().getName(), new QFilter[]{new QFilter("id", "=", groupcustomers.getPkValue())}); String groupUserId = groupcustomers.getString("yem_torderid");
} String groupName = groupcustomers.getString("number");
String groupUserId = groupcustomers.getString("yem_torderid"); String name = groupcustomers.getString("name");
String groupName = groupcustomers.getString("number"); requestBody.put("nickname", username);
String name = groupcustomers.getString("name"); requestBody.put("password", "ensign@123");
requestBody.put("nickname", username); requestBody.put("username", userNumber);
requestBody.put("password", "ensign@123"); requestBody.put("deptId", "100");
requestBody.put("username", userNumber); requestBody.put("groupCustomerId", groupUserId);
requestBody.put("deptId", "100"); requestBody.put("groupCustomerNumber", groupName);
requestBody.put("groupCustomerId", groupUserId); requestBody.put("groupCustomerName", name);
requestBody.put("groupCustomerNumber", groupName); if (!isCreate) {
requestBody.put("groupCustomerName", name); requestBody.put("id", existId);
if (!isCreate) { }
requestBody.put("id", existId); String res = "";
}
String res = "";
try { try {
log.info("start request {}", requestUrl); log.info("start request {}", requestUrl);
res = HttpClientUtils.postAppJson(requestUrl, headers, requestBody, 3000, 3000); res = HttpClientUtils.postAppJson(requestUrl, headers, requestBody, 3000, 3000);
} catch (IOException e) { } catch (IOException e) {
log.error("request token error", e); log.error("request token error", e);
resStatus.put("status", "error"); resStatus.put("status", "error");
resStatus.put("msg", String.format("获取token请求异常:%s", e.getMessage())); resStatus.put("msg", String.format("获取token请求异常:%s", e.getMessage()));
// throw new RuntimeException(e); }
} log.info("request {}", requestBody);
JSONObject jsonObject = JSONObject.parseObject(res);
JSONObject jsonObject = JSONObject.parseObject(res); log.info("response {}", jsonObject);
int code = jsonObject.getIntValue("code"); int code = jsonObject.getIntValue("code");
if (code == 0) { if (code == 0) {
Integer data = jsonObject.getInteger("data"); Object data = jsonObject.get("data");
if (!(data instanceof Boolean)) {
resStatus.put("id", String.valueOf(data)); resStatus.put("id", String.valueOf(data));
} else {
throw new KDBizException("失败：" + res);
} }
return resStatus;
} else { } else {
log.error(headers.get("msg")); resStatus.put("msg", JSON.toJSONString(jsonObject));
} }
return resStatus; return resStatus;
} }
/** /**
* 修改用户 * 修改用户
*/ */
public static Map<String, String> Modifyuser(String big,String string) { public static Map<String, String> Modifyuser(String big, String string) {
final String requestUrl = ENDPOINTS + "/admin-api/system/user/update-status"; final String requestUrl = ENDPOINTS + "/admin-api/system/user/update-status";
@ -508,7 +500,7 @@ public class OrderApiUtils {
String res = ""; String res = "";
try { try {
log.info("start request {}", requestUrl); log.info("start request {}", requestUrl);
res = HttpUtils.doPut(requestUrl, JSON.toJSONString(requestBody),"json", headers); res = HttpUtils.doPut(requestUrl, JSON.toJSONString(requestBody), "json", headers);
// HttpUtils.doPut(requestUrl, JSON.toJSONString(objectArrayList), "json", headers); // HttpUtils.doPut(requestUrl, JSON.toJSONString(objectArrayList), "json", headers);
} catch (IOException e) { } catch (IOException e) {
log.error("request token error", e); log.error("request token error", e);
@ -518,6 +510,7 @@ public class OrderApiUtils {
} }
return null; return null;
} }
/** /**
* 同步订单 * 同步订单
* *
@ -552,9 +545,9 @@ public class OrderApiUtils {
requestBody.put("model", Bearer.get("model")); requestBody.put("model", Bearer.get("model"));
requestBody.put("salesman", Bearer.get("salesman")); requestBody.put("salesman", Bearer.get("salesman"));
requestBody.put("seller", Bearer.get("seller")); requestBody.put("seller", Bearer.get("seller"));
requestBody.put("productenname",Bearer.get("productenname")); requestBody.put("productenname", Bearer.get("productenname"));
requestBody.put("productname",Bearer.get("productname")); requestBody.put("productname", Bearer.get("productname"));
requestBody.put("product",Bearer.get("productnumber")); requestBody.put("product", Bearer.get("productnumber"));
Map<String, Object> objectMap = new HashMap<>(); Map<String, Object> objectMap = new HashMap<>();
objectMap.put("salesorderno", Bearer.get("salesordernos")); objectMap.put("salesorderno", Bearer.get("salesordernos"));
objectMap.put("framenumber", Bearer.get("framenumber")); objectMap.put("framenumber", Bearer.get("framenumber"));
@ -601,8 +594,8 @@ public class OrderApiUtils {
DynamicObject[] mechanical = BusinessDataServiceHelper.load("yem_em_devicefiles" DynamicObject[] mechanical = BusinessDataServiceHelper.load("yem_em_devicefiles"
, "id,number,yem_ordeid,yem_issynorde" , "id,number,yem_ordeid,yem_issynorde"
, new QFilter[]{new QFilter("yem_salesorderno", QCP.equals, salesorderno), , new QFilter[]{new QFilter("yem_salesorderno", QCP.equals, salesorderno),
new QFilter("number", QCP.in, compNo) new QFilter("number", QCP.in, compNo)
}); });
for (DynamicObject d : mechanical) { for (DynamicObject d : mechanical) {
d.set("yem_ordeid", objectsId); d.set("yem_ordeid", objectsId);
d.set("yem_issynorde", true); d.set("yem_issynorde", true);
@ -620,6 +613,7 @@ public class OrderApiUtils {
/** /**
* 同步产品机型到下单平台权限项 * 同步产品机型到下单平台权限项
*
* @param parentObject 父级 * @param parentObject 父级
*/ */
public static void syncProductModuleToPermissions(DynamicObject parentObject, ORM orm) throws IOException { public static void syncProductModuleToPermissions(DynamicObject parentObject, ORM orm) throws IOException {
@ -647,6 +641,7 @@ public class OrderApiUtils {
/** /**
* 查询子级所有的产品机型，为空则查询一级 * 查询子级所有的产品机型，为空则查询一级
*
* @param parent * @param parent
* @return * @return
*/ */
@ -684,7 +679,7 @@ public class OrderApiUtils {
Long itemId = requestAddPermissionItem(object, returnId, token, subIdx); Long itemId = requestAddPermissionItem(object, returnId, token, subIdx);
object.set("yem_orderperid", itemId); object.set("yem_orderperid", itemId);
log.info("AddPermissionItem__parent: " + dynamicObject.getString("number") + "_" + dynamicObject.getString("name") +"_item: " + object.getPkValue() + "_" + object.getString("number") + "_" + object.getString("name")); log.info("AddPermissionItem__parent: " + dynamicObject.getString("number") + "_" + dynamicObject.getString("name") + "_item: " + object.getPkValue() + "_" + object.getString("number") + "_" + object.getString("name"));
} }
SaveServiceHelper.update(collection.toArray(new DynamicObject[0])); SaveServiceHelper.update(collection.toArray(new DynamicObject[0]));
@ -696,7 +691,7 @@ public class OrderApiUtils {
if ("success".equals(resMap.get("status"))) { if ("success".equals(resMap.get("status"))) {
return "Bearer " + resMap.get("token"); return "Bearer " + resMap.get("token");
} else { } else {
throw new IOException("获取token失败"); throw new IOException("获取token失败");
} }
} }
@ -754,7 +749,7 @@ public class OrderApiUtils {
* *
* @param object 产品机型 * @param object 产品机型
* @param parentId 该机型对应类型ID * @param parentId 该机型对应类型ID
* @param subIdx 排序 * @param subIdx 排序
* @return * @return
*/ */
private static Long requestAddPermissionItem(DynamicObject object, Long parentId, String token, int subIdx) throws IOException { private static Long requestAddPermissionItem(DynamicObject object, Long parentId, String token, int subIdx) throws IOException {
@ -812,10 +807,10 @@ public class OrderApiUtils {
headers.put("Authorization", "Bearer " + (accessToken)); headers.put("Authorization", "Bearer " + (accessToken));
for (Map<String, Object> Bearer : list) { for (Map<String, Object> Bearer : list) {
Map<String, Object> requestBody = new HashMap<>(); Map<String, Object> requestBody = new HashMap<>();
requestBody.put("id",Bearer.get("id")); requestBody.put("id", Bearer.get("id"));
requestBody.put("status",Bearer.get("status")); requestBody.put("status", Bearer.get("status"));
requestBody.put("logisticsNo",Bearer.get("logisticsNo")); requestBody.put("logisticsNo", Bearer.get("logisticsNo"));
requestBody.put("ladingDate",Bearer.get("ladingDate")); requestBody.put("ladingDate", Bearer.get("ladingDate"));
objectArrayList.add(requestBody); objectArrayList.add(requestBody);
} }
try { try {

44
src/main/java/com/yem/wm/bd/customer/from/Validator/CustomerValidator.java
View File

@ -5,13 +5,16 @@ import com.yem.wm.utils.YEM;
import kd.bos.dataentity.entity.DynamicObject; import kd.bos.dataentity.entity.DynamicObject;
import kd.bos.entity.ExtendedDataEntity; import kd.bos.entity.ExtendedDataEntity;
import kd.bos.entity.validate.AbstractValidator; import kd.bos.entity.validate.AbstractValidator;
import kd.bos.orm.query.QCP; import kd.bos.exception.KDBizException;
import kd.bos.orm.query.QFilter; import kd.bos.orm.query.QFilter;
import kd.bos.servicehelper.BusinessDataServiceHelper; import kd.bos.servicehelper.BusinessDataServiceHelper;
import kd.bos.servicehelper.operation.SaveServiceHelper; import kd.bos.servicehelper.operation.SaveServiceHelper;
import java.io.IOException;
import java.util.Map; import java.util.Map;
import static com.yem.or.utils.OrderApiUtils.getToken;
/** /**
* ljw * ljw
* 同步数据至下单平台 * 同步数据至下单平台
@ -21,18 +24,23 @@ public class CustomerValidator extends AbstractValidator {
@Override @Override
public void validate() { public void validate() {
ExtendedDataEntity[] dataEntities = this.getDataEntities(); ExtendedDataEntity[] dataEntities = this.getDataEntities();
String accessToken = "";
try {
Map<String, String> token = getToken();
accessToken = token.get("token");
} catch (IOException e) {
throw new RuntimeException(e);
}
if (YEM.isEmpty(accessToken)) {
throw new KDBizException("获取AccessToken失败");
}
for (ExtendedDataEntity dataEntitie : dataEntities) { for (ExtendedDataEntity dataEntitie : dataEntities) {
DynamicObject mechanical = dataEntitie.getDataEntity(); DynamicObject mechanical = dataEntitie.getDataEntity();
boolean isSynced = mechanical.getBoolean("yem_checkboxfield"); boolean isSynced = mechanical.getBoolean("yem_checkboxfield");
// DynamicObject group = mechanical.getDynamicObject("group");
// if (group != null) {
// long groupid = group.getLong("id");
// QFilter qFilter = new QFilter("parent.number", QCP.equals, "11602");
// QFilter qFilter1 = new QFilter("id", QCP.equals, groupid);
// qFilter1.and(new QFilter("enable", QCP.equals, "1"));
// DynamicObject[] dynamicObjects = BusinessDataServiceHelper.load("bd_customergroup", "id,number,parent"
// , new QFilter[]{qFilter, qFilter1});
// if (dynamicObjects.length > 0) {
String number = mechanical.getString("number"); String number = mechanical.getString("number");
String name = mechanical.getString("name"); String name = mechanical.getString("name");
DynamicObject groupcustomers = mechanical.getDynamicObject("yem_groupcustomers"); DynamicObject groupcustomers = mechanical.getDynamicObject("yem_groupcustomers");
@ -53,26 +61,18 @@ public class CustomerValidator extends AbstractValidator {
if (isSynced) { if (isSynced) {
String torderid = mechanical.getString("yem_torderid"); String torderid = mechanical.getString("yem_torderid");
Long existId = Long.valueOf(torderid); Long existId = Long.valueOf(torderid);
demands = OrderApiUtils.demands(name, number, groupcustomers, false, existId); demands = OrderApiUtils.demands(accessToken, name, number, groupcustomers, false, existId);
} else { } else {
demands = OrderApiUtils.demands(name, number, groupcustomers, true, null); demands = OrderApiUtils.demands(accessToken, name, number, groupcustomers, true, null);
} }
String msg = demands.get("msg");
if (demands.containsKey("id")) { if (demands.containsKey("id")) {
String id = demands.get("id"); String id = demands.get("id");
mechanical.set("yem_torderid", id); mechanical.set("yem_torderid", id);
mechanical.set("yem_checkboxfield", true); mechanical.set("yem_checkboxfield", true);
SaveServiceHelper.update(mechanical);
SaveServiceHelper.save(new DynamicObject[]{mechanical}); SaveServiceHelper.save(new DynamicObject[]{mechanical});
} else { } else if (demands.containsKey("msg")) {
this.addErrorMessage(dataEntitie, msg); this.addErrorMessage(dataEntitie, demands.get("msg"));
} }
// } else {
// this.addErrorMessage(dataEntitie, "当前客户不满足同步条件，禁止同步至下单平台！！！");
// }
// } else {
// this.addErrorMessage(dataEntitie, "当前客户分组为空！！");
// }
} }
} }
} }