1.已存在的数据不在生成
This commit is contained in:
ljw 2024-12-07 17:52:21 +08:00
parent 35d101386a
commit 37857e0346

View File

@ -5,7 +5,6 @@ import com.yem.wm.utils.YEM;
import kd.bos.dataentity.OperateOption;
import kd.bos.dataentity.entity.DynamicObject;
import kd.bos.dataentity.entity.DynamicObjectCollection;
import kd.bos.entity.operate.OperationException;
import kd.bos.entity.operate.result.IOperateInfo;
import kd.bos.entity.operate.result.OperationResult;
import kd.bos.exception.KDBizException;
@ -978,61 +977,76 @@ public class AtlasUtils {
//
// }
// } else {
DynamicObject cmmptable = BusinessDataServiceHelper.newDynamicObject("yem_em_bomchange");
cmmptable.set("yem_producttype", yem_producttype);
cmmptable.set("enable", "1");
cmmptable.set("status", "A");
cmmptable.set("name", changebill_code);
cmmptable.set("number", changebill_code);
cmmptable.set("createorg", bos_org);
cmmptable.set("useorg", bos_org);
cmmptable.set("creator", YEM.getCurrentUserId());
cmmptable.set("yem_date", new Date());
DynamicObjectCollection yem_entryentity = cmmptable.getDynamicObjectCollection("yem_entryentity");
DynamicObject dynamicObject = yem_entryentity.addNew();
dynamicObject.set("yem_changeno", changebill_code);//更改单号
dynamicObject.set("yem_parentno", map.get("pcode"));//父件编码
dynamicObject.set("yem_parentname", map.get("mater_name"));//父件名称
dynamicObject.set("yem_enableparno", map.get("pcode"));//替换父件名称
dynamicObject.set("yem_enableparname", map.get("mater_name"));//替换父件名称
dynamicObject.set("yem_subno", map.get("ccode"));//父件编码
dynamicObject.set("yem_subname", map.get("cmater_name"));//子件名称
dynamicObject.set("yem_qty", map.get("qty"));//数量
if (map.get("break_flag").toString().equals("启用")) {
dynamicObject.set("yem_enablesta", "A");//启用停用状态
String selectfields = DynamicObjectUtil.getSelectfields("yem_em_bomchange", false);
DynamicObject[] loaded = BusinessDataServiceHelper.load("yem_em_bomchange", selectfields, null);
List<String> list = new ArrayList<>();
if (loaded.length > 0) {
for (DynamicObject dynamicObject : loaded) {
String number = dynamicObject.getString("number");
list.add(number);
}
}
if (map.get("break_flag").toString().equals("停用")) {
dynamicObject.set("yem_enablesta", "B");//启用停用状态
}
dynamicObject.set("yem_enableddate", map.get("enable_time"));//启用时间
dynamicObject.set("yem_downdate", map.get("disable_time"));//停用时间
dynamicObject.set("yem_exestate", map.get("state"));//执行状态
DynamicObject assatlasdet = seelctDyn("yem_em_assatlasdet", "number", map.get("pcode").toString());
if (assatlasdet != null) {
//是否总成 yem_isass
dynamicObject.set("yem_isass", true);
}
DynamicObject basemodelib = seelctDyn("yem_bd_basemodelib", "number", map.get("pcode").toString());
if (basemodelib != null) {
//是否资源 yem_isass
dynamicObject.set("yem_isresource", true);
}
dynamicObject.set("yem_completetime", map.get("complete_time"));
OperationResult save = OperationServiceHelper.executeOperate("save",
cmmptable.getDynamicObjectType().getName(), new DynamicObject[]{cmmptable}, OperateOption.create());
if (!save.isSuccess()) {
throw new KDBizException("保存失败!" + changebill_code + "_" + save.getMessage());
}
OperationResult submit = OperationServiceHelper.executeOperate("submit",
cmmptable.getDynamicObjectType().getName(), new DynamicObject[]{cmmptable}, OperateOption.create());
if (!submit.isSuccess()) {
throw new KDBizException("提交失败!" + changebill_code + "_" + save.getMessage());
}
OperationResult audit = OperationServiceHelper.executeOperate("audit",
cmmptable.getDynamicObjectType().getName(), new DynamicObject[]{cmmptable}, OperateOption.create());
if (!audit.isSuccess()) {
throw new KDBizException("审核失败!" + changebill_code + "_" + save.getMessage());
for (int i1 = 0; i1 < list.size(); i1++) {
if (list.contains(changebill_code)) {
continue;
}
DynamicObject cmmptable = BusinessDataServiceHelper.newDynamicObject("yem_em_bomchange");
cmmptable.set("yem_producttype", yem_producttype);
cmmptable.set("enable", "1");
cmmptable.set("status", "A");
cmmptable.set("name", changebill_code);
cmmptable.set("number", changebill_code);
cmmptable.set("createorg", bos_org);
cmmptable.set("useorg", bos_org);
cmmptable.set("creator", YEM.getCurrentUserId());
cmmptable.set("yem_date", new Date());
DynamicObjectCollection yem_entryentity = cmmptable.getDynamicObjectCollection("yem_entryentity");
DynamicObject dynamicObject = yem_entryentity.addNew();
dynamicObject.set("yem_changeno", changebill_code);//更改单号
dynamicObject.set("yem_parentno", map.get("pcode"));//父件编码
dynamicObject.set("yem_parentname", map.get("mater_name"));//父件名称
dynamicObject.set("yem_enableparno", map.get("pcode"));//替换父件名称
dynamicObject.set("yem_enableparname", map.get("mater_name"));//替换父件名称
dynamicObject.set("yem_subno", map.get("ccode"));//父件编码
dynamicObject.set("yem_subname", map.get("cmater_name"));//子件名称
dynamicObject.set("yem_qty", map.get("qty"));//数量
if (map.get("break_flag").toString().equals("启用")) {
dynamicObject.set("yem_enablesta", "A");//启用停用状态
}
if (map.get("break_flag").toString().equals("停用")) {
dynamicObject.set("yem_enablesta", "B");//启用停用状态
}
dynamicObject.set("yem_enableddate", map.get("enable_time"));//启用时间
dynamicObject.set("yem_downdate", map.get("disable_time"));//停用时间
dynamicObject.set("yem_exestate", map.get("state"));//执行状态
DynamicObject assatlasdet = seelctDyn("yem_em_assatlasdet", "number", map.get("pcode").toString());
if (assatlasdet != null) {
//是否总成 yem_isass
dynamicObject.set("yem_isass", true);
}
DynamicObject basemodelib = seelctDyn("yem_bd_basemodelib", "number", map.get("pcode").toString());
if (basemodelib != null) {
//是否资源 yem_isass
dynamicObject.set("yem_isresource", true);
}
dynamicObject.set("yem_completetime", map.get("complete_time"));
OperationResult save = OperationServiceHelper.executeOperate("save",
cmmptable.getDynamicObjectType().getName(), new DynamicObject[]{cmmptable}, OperateOption.create());
if (!save.isSuccess()) {
throw new KDBizException("保存失败!" + changebill_code + "_" + save.getMessage());
}
OperationResult submit = OperationServiceHelper.executeOperate("submit",
cmmptable.getDynamicObjectType().getName(), new DynamicObject[]{cmmptable}, OperateOption.create());
if (!submit.isSuccess()) {
throw new KDBizException("提交失败!" + changebill_code + "_" + save.getMessage());
}
OperationResult audit = OperationServiceHelper.executeOperate("audit",
cmmptable.getDynamicObjectType().getName(), new DynamicObject[]{cmmptable}, OperateOption.create());
if (!audit.isSuccess()) {
throw new KDBizException("审核失败!" + changebill_code + "_" + save.getMessage());
}
}
}
}
// }