SupplierAddnewWebApiPlugin.java 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572
  1. package bamp.basedata.webapi;
  2. import kd.bos.dataentity.OperateOption;
  3. import kd.bos.dataentity.entity.DynamicObject;
  4. import kd.bos.dataentity.entity.DynamicObjectCollection;
  5. import kd.bos.entity.operate.result.OperateErrorInfo;
  6. import kd.bos.entity.operate.result.OperationResult;
  7. import kd.bos.entity.validate.ValidateResult;
  8. import kd.bos.entity.validate.ValidateResultCollection;
  9. import kd.bos.logging.Log;
  10. import kd.bos.logging.LogFactory;
  11. import kd.bos.openapi.common.custom.annotation.ApiController;
  12. import kd.bos.openapi.common.custom.annotation.ApiMapping;
  13. import kd.bos.openapi.common.custom.annotation.ApiParam;
  14. import kd.bos.openapi.common.custom.annotation.ApiPostMapping;
  15. import kd.bos.openapi.common.result.CustomApiResult;
  16. import kd.bos.orm.query.QCP;
  17. import kd.bos.orm.query.QFilter;
  18. import kd.bos.servicehelper.BusinessDataServiceHelper;
  19. import kd.bos.servicehelper.operation.OperationServiceHelper;
  20. import kd.bos.servicehelper.operation.SaveServiceHelper;
  21. import java.io.Serializable;
  22. import java.text.ParseException;
  23. import java.text.SimpleDateFormat;
  24. import java.util.*;
  25. /*
  26. * 供应商新增插件
  27. * wangj 2025-02-05
  28. * 主要功能:新增主数据供应商
  29. */
  30. @SuppressWarnings("all")
  31. @ApiController(value = "open", desc = "供应商新增接口插件")
  32. @ApiMapping(value = "/bd_supplier")
  33. public class SupplierAddnewWebApiPlugin implements Serializable {
  34. int successCount = 0;
  35. int failCount = 0;
  36. private static final Log log = LogFactory.getLog(SupplierAddnewWebApiPlugin.class);
  37. @ApiPostMapping(value = "supplier_addnew", desc = "同步接口")
  38. public CustomApiResult<Map<String, Object>> supplier_addnew(@ApiParam(value = "提交参数") List<Map<String, Object>> data ) {
  39. CustomApiResult customApiResult = new CustomApiResult();
  40. customApiResult.setStatus(true);
  41. customApiResult.setErrorCode("0");
  42. try {
  43. Map resultDatasMap = new HashMap();
  44. List<Map> resultDatas = new ArrayList<Map>();
  45. for(Map param : data){
  46. Map resultData = new HashMap();
  47. try {
  48. doUpdateSupplier(param,resultData);
  49. }catch (Exception e) {
  50. resultData.put("id","");
  51. resultData.put("errors",e.getMessage());
  52. resultData.put("billStatus",false);
  53. failCount ++;
  54. }
  55. resultDatas.add(resultData);
  56. }
  57. resultDatasMap.put("failCount",failCount);
  58. if(failCount>0){
  59. customApiResult.setStatus(false);
  60. customApiResult.setErrorCode("603");
  61. }
  62. resultDatasMap.put("successCount",successCount);
  63. resultDatasMap.put("result",resultDatas);
  64. customApiResult.setData(resultDatasMap);
  65. } catch (Exception e) {
  66. customApiResult.setStatus(false);
  67. customApiResult.setMessage(e.getMessage());
  68. customApiResult.setErrorCode("400");
  69. }
  70. return customApiResult;
  71. }
  72. private void doUpdateSupplier(Map param, Map resultData) throws ParseException {
  73. String errorMsg = "";
  74. //创建新用户
  75. DynamicObject supplierObj = null;
  76. if(param.get("number")!=null){
  77. QFilter qFilter_number = new QFilter("number", QCP.equals,param.get("number"));
  78. DynamicObject[] customer = BusinessDataServiceHelper.load("bd_supplier","id",new QFilter[]{qFilter_number});
  79. if(customer.length>0){//防止新增失败情况留存的历史数据
  80. supplierObj = BusinessDataServiceHelper.loadSingle(customer[0].getPkValue(),"bd_supplier");
  81. if(param.get("enable")!=null && !"".equals(param.get("enable")) && "0".equals(param.get("enable"))){//使用状态变为禁用
  82. //禁用人
  83. setDynamicField(true,"modifier_number","disabler","bos_user",param,resultData,supplierObj);
  84. //禁用时间
  85. setDateField(true,"modifytime","disabledate",param,resultData,supplierObj);
  86. //使用状态
  87. supplierObj.set("enable","0");
  88. }
  89. //更新供应商子码基础资料
  90. if(param.get("pznm_zmentry")!=null){
  91. List<Map> mapEntrys = (List<Map>) param.get("pznm_zmentry");
  92. doSetEntry(mapEntrys,resultData,supplierObj);
  93. }
  94. }else{
  95. supplierObj = BusinessDataServiceHelper.newDynamicObject("bd_supplier");
  96. //数据状态
  97. supplierObj.set("status","A");
  98. //使用状态
  99. supplierObj.set("enable","1");
  100. }
  101. resultData.put("number",param.get("number"));
  102. }
  103. //供应商编码
  104. setTextField(true,"number","number",param,resultData,supplierObj);
  105. //供应商名称
  106. setTextField(true,"name","name",param,resultData,supplierObj);
  107. //创建人
  108. setDynamicField(true,"creator_number","creator","bos_user",param,resultData,supplierObj);
  109. //创建时间
  110. setDateField(true,"createtime","createtime",param,resultData,supplierObj);
  111. //修改人
  112. setDynamicField(true,"modifier_number","pznm_modifier_xh","bos_user",param,resultData,supplierObj);
  113. //修改时间
  114. setDateField(true,"modifytime","modifytime",param,resultData,supplierObj);
  115. //审核人
  116. setDynamicField(true,"approverid_number","pznm_auditor_xh","bos_user",param,resultData,supplierObj);
  117. //审核日期
  118. setDateField(true,"approvedate","approvedate",param,resultData,supplierObj);
  119. //创建组织
  120. setDynamicField(true,"createorg_number","createorg","bos_org",param,resultData,supplierObj);
  121. //控制策略
  122. setTextField(true,"ctrlstrategy","ctrlstrategy",param,resultData,supplierObj);
  123. //详细地址
  124. setTextField(false,"bizpartner_address","bizpartner_address",param,resultData,supplierObj);
  125. //统一社会信用代码
  126. setTextField(false,"societycreditcode","societycreditcode",param,resultData,supplierObj);
  127. //是否关联单位
  128. setTextField(false,"pznm_isrelateunit","pznm_isrelateunit",param,resultData,supplierObj);
  129. //内部业务单元
  130. setDynamicField(false,"internal_company_number","internal_company","bos_org",param,resultData,supplierObj);
  131. //是否内部单位
  132. setTextField(false,"chkisinternalcompany","chkisinternalcompany",param,resultData,supplierObj);
  133. //供应商分类
  134. if(param.get("entry_groupstandard")!=null){
  135. List<Map> mapEntrys = (List<Map>) param.get("entry_groupstandard");
  136. doSetGroupEntry(mapEntrys,resultData,supplierObj);
  137. }
  138. //银行信息
  139. if(param.get("entry_bank")!=null){
  140. List<Map> mapEntrys = (List<Map>) param.get("entry_bank");
  141. doSetBankEntry(mapEntrys,resultData,supplierObj);
  142. }
  143. //委托人分录
  144. if(param.get("pznm_wtrentry")!=null){
  145. List<Map> mapEntrys = (List<Map>) param.get("pznm_wtrentry");
  146. doSetWtrEntry(mapEntrys,resultData,supplierObj);
  147. }
  148. //控制状态分录
  149. if(param.get("pznm_kzztentry")!=null){
  150. List<Map> mapEntrys = (List<Map>) param.get("pznm_kzztentry");
  151. doSetKzztentry(mapEntrys,resultData,supplierObj);
  152. }
  153. if(resultData.get("errors")!=null && !"".equals(resultData.get("errors"))){
  154. List errors = new ArrayList();
  155. errors.add(resultData.get("errors"));
  156. resultData.put("id","");
  157. resultData.put("errors",errors);
  158. resultData.put("billStatus",false);
  159. }else{
  160. //保存供应商对象
  161. String status = supplierObj.getString("status");
  162. if("A".equals(status)){//暂存,走正常逻辑
  163. doAddNew(resultData,supplierObj,param);
  164. }else if("B".equals(status)){//已提交,走update和审核
  165. doUpdateAndAudit(resultData,supplierObj);
  166. }else if("C".equals(status)){//已审核,走修改逻辑
  167. doUpdate(resultData,supplierObj);
  168. }
  169. }
  170. }
  171. private void doUpdate(Map resultData, DynamicObject supplierObj) {
  172. SaveServiceHelper.update(supplierObj);
  173. resultData.put("errors",new ArrayList());
  174. resultData.put("id",supplierObj.getPkValue());
  175. resultData.put("billStatus", true);
  176. successCount++;
  177. }
  178. private void doUpdateAndAudit(Map resultData, DynamicObject supplierObj) {
  179. SaveServiceHelper.update(supplierObj);
  180. OperationResult result_audit = OperationServiceHelper.executeOperate("audit", "bd_supplier",
  181. new DynamicObject[]{supplierObj}, OperateOption.create());
  182. //执行供应商对应组织分配
  183. if(result_audit.isSuccess()){//保存供应商成功
  184. resultData.put("errors",new ArrayList());
  185. resultData.put("id",result_audit.getSuccessPkIds().get(0));
  186. resultData.put("billStatus", true);
  187. successCount++;
  188. }else{//提交供应商失败
  189. List errors = new ArrayList();
  190. ValidateResultCollection validateResults = result_audit.getValidateResult();
  191. List<ValidateResult> validateResultList = validateResults.getValidateErrors();
  192. for(ValidateResult validateResult : validateResultList){
  193. List<OperateErrorInfo> allErrorInfos = validateResult.getAllErrorInfo();
  194. for(OperateErrorInfo allErrorInfo : allErrorInfos){
  195. errors.add(allErrorInfo.getMessage());
  196. }
  197. }
  198. resultData.put("errors",errors);
  199. resultData.put("id","");
  200. resultData.put("billStatus", false);
  201. failCount ++;
  202. }
  203. }
  204. private void doAddNew(Map resultData, DynamicObject supplierObj, Map param) {
  205. OperationResult result_submit = OperationServiceHelper.executeOperate("submit", "bd_supplier",
  206. new DynamicObject[]{supplierObj}, OperateOption.create());
  207. if(result_submit.isSuccess()){
  208. OperationResult result_audit = OperationServiceHelper.executeOperate("audit", "bd_supplier",
  209. new DynamicObject[]{supplierObj}, OperateOption.create());
  210. //执行供应商对应组织分配
  211. if(result_audit.isSuccess()){//保存供应商成功
  212. //更新供应商子码基础资料
  213. if(param.get("pznm_zmentry")!=null){
  214. List<Map> mapEntrys = (List<Map>) param.get("pznm_zmentry");
  215. doSetEntry(mapEntrys,resultData,supplierObj);
  216. }
  217. if(resultData.get("errors")!=null && !"".equals(resultData.get("errors"))){
  218. List errors = new ArrayList();
  219. errors.add(resultData.get("errors"));
  220. resultData.put("errors",errors);
  221. resultData.put("id","");
  222. resultData.put("billStatus", false);
  223. failCount ++;
  224. }else{
  225. resultData.put("errors",new ArrayList());
  226. resultData.put("id",result_audit.getSuccessPkIds().get(0));
  227. resultData.put("billStatus", true);
  228. successCount++;
  229. }
  230. }else{//提交供应商失败
  231. List errors = new ArrayList();
  232. ValidateResultCollection validateResults = result_audit.getValidateResult();
  233. List<ValidateResult> validateResultList = validateResults.getValidateErrors();
  234. for(ValidateResult validateResult : validateResultList){
  235. List<OperateErrorInfo> allErrorInfos = validateResult.getAllErrorInfo();
  236. for(OperateErrorInfo allErrorInfo : allErrorInfos){
  237. errors.add(allErrorInfo.getMessage());
  238. }
  239. }
  240. resultData.put("errors",errors);
  241. resultData.put("id","");
  242. resultData.put("billStatus", false);
  243. failCount ++;
  244. }
  245. }else{
  246. List errors = new ArrayList();
  247. ValidateResultCollection validateResults = result_submit.getValidateResult();
  248. List<ValidateResult> validateResultList = validateResults.getValidateErrors();
  249. for(ValidateResult validateResult : validateResultList){
  250. List<OperateErrorInfo> allErrorInfos = validateResult.getAllErrorInfo();
  251. for(OperateErrorInfo allErrorInfo : allErrorInfos){
  252. errors.add(allErrorInfo.getMessage());
  253. }
  254. }
  255. resultData.put("errors",errors);
  256. resultData.put("id","");
  257. resultData.put("billStatus", false);
  258. failCount ++;
  259. }
  260. }
  261. private void doSetGroupEntry(List<Map> mapEntrys, Map resultData, DynamicObject supplierObj) {
  262. DynamicObjectCollection entrys = supplierObj.getDynamicObjectCollection("entry_groupstandard");
  263. entrys.clear();
  264. for(Map mapEntry : mapEntrys) {
  265. DynamicObject newEntry = new DynamicObject(entrys.getDynamicObjectType());
  266. //分类标准.编码
  267. setDynamicField(true, "standardid_number", "standardid", "bd_suppliergroupstandard",
  268. mapEntry, resultData, newEntry);
  269. //分类.编码
  270. setDynamicField(false,"groupid_number","groupid","bd_suppliergroup",
  271. mapEntry,resultData,newEntry);
  272. entrys.add(newEntry);
  273. }
  274. }
  275. private void doSetBankEntry(List<Map> mapEntrys, Map resultData, DynamicObject supplierObj) {
  276. DynamicObjectCollection entrys = supplierObj.getDynamicObjectCollection("entry_bank");
  277. entrys.clear();
  278. for(Map mapEntry : mapEntrys) {
  279. DynamicObject newEntry = new DynamicObject(entrys.getDynamicObjectType());
  280. //所属组织
  281. setDynamicField(true, "pznm_bket_org_number", "pznm_bket_org", "bos_org",
  282. mapEntry, resultData, newEntry);
  283. //银行账号
  284. setTextField(true, "bankaccount", "bankaccount", mapEntry, resultData, newEntry);
  285. //账户名称
  286. setTextField(true, "accountname", "accountname", mapEntry, resultData, newEntry);
  287. //开户银行
  288. setDynamicField(true,"bank_number","bank","bd_bebank",
  289. mapEntry,resultData,newEntry);
  290. //币别
  291. setDynamicField(true,"currency_number","currency","bd_currency",
  292. mapEntry,resultData,newEntry);
  293. //默认
  294. setTextField(true, "isdefault_bank", "isdefault_bank", mapEntry, resultData, newEntry);
  295. //账户性质
  296. setTextField(false, "pznm_bket_account", "pznm_bket_account", mapEntry, resultData, newEntry);
  297. entrys.add(newEntry);
  298. }
  299. }
  300. private void doSetEntry(List<Map> mapEntrys, Map resultData, DynamicObject supplierObj) {
  301. //拼接组织+字码编码的过滤条件
  302. List<String> zmnumbers = new ArrayList<String>();
  303. List<String> orgnumbers = new ArrayList<String>();
  304. for(Map mapEntry : mapEntrys){
  305. zmnumbers.add(mapEntry.get("pznm_zmet_number").toString());
  306. orgnumbers.add(mapEntry.get("pznm_zmet_org_number").toString());
  307. }
  308. //查询过滤条件,缓存存在的字码Map记录
  309. Map isHaveOrgs_zmnumber = new HashMap();
  310. QFilter qFilter_customer = new QFilter("pznm_supplier",QCP.equals,supplierObj.getPkValue());
  311. QFilter qFilter_org = new QFilter("pznm_zmet_org.number",QCP.in,orgnumbers);
  312. QFilter qFilter_ztnumber = new QFilter("number",QCP.in,zmnumbers);
  313. DynamicObject[] isHaveObjs = BusinessDataServiceHelper.load("pznm_supplierzm",
  314. "id,pznm_zmet_org,pznm_zmet_org.number,pznm_zmet_number,pznm_zmet_name,pznm_zmet_oldnumber,pznm_zmet_wtr,pznm_zmet_wtrphone," +
  315. "pznm_zmet_lxr,pznm_zmet_lxrphone,pznm_zmet_cgper,pznm_zmet_setttype," +
  316. "pznm_zmet_zqnotes,pznm_zmet_settday,pznm_zmet_zqrtype,pznm_zmet_zqptype,pznm_zmet_paytype,pznm_zmet_invoicetype",
  317. new QFilter[]{qFilter_customer,qFilter_org,qFilter_ztnumber});
  318. for(DynamicObject obj : isHaveObjs){
  319. DynamicObject org = (DynamicObject) obj.getDynamicObject("pznm_zmet_org");
  320. String org_zmnumber = org.getString("number")+"_"+obj.getString("number");
  321. isHaveOrgs_zmnumber.put(org_zmnumber,obj);
  322. }
  323. //区分并拼接需更新和新增的记录
  324. DynamicObjectCollection add_entrys = new DynamicObjectCollection();
  325. DynamicObjectCollection update_entrys = new DynamicObjectCollection();
  326. for(Map mapEntry : mapEntrys){
  327. String org_zmnumber = mapEntry.get("pznm_zmet_org_number").toString()+"_"+mapEntry.get("pznm_zmet_number").toString();
  328. if(isHaveOrgs_zmnumber.get(org_zmnumber)!=null && !"".equals(isHaveOrgs_zmnumber.get(org_zmnumber))){
  329. //已存在,缓存修改对象
  330. DynamicObject update_entry = (DynamicObject) isHaveOrgs_zmnumber.get(org_zmnumber);
  331. setDynamicField(true,"pznm_zmet_org_number","pznm_zmet_org","bos_org",
  332. mapEntry,resultData,update_entry);
  333. //供应商子码.子码编码
  334. setTextField(true,"pznm_zmet_number","number",mapEntry,resultData,update_entry);
  335. //供应商子码.子码名称
  336. setTextField(true,"pznm_zmet_name","name",mapEntry,resultData,update_entry);
  337. //供应商子码.老系统编号
  338. setTextField(false,"pznm_zmet_oldnumber","pznm_zmet_oldnumber",mapEntry,resultData,update_entry);
  339. //委托人.编码
  340. setDynamicField(false,"pznm_zmet_wtr_number","pznm_zmet_wtr","pznm_outcontacts",
  341. mapEntry,resultData,update_entry);
  342. //委托人信息.委托人电话
  343. setTextField(false,"pznm_zmet_wtrphone","pznm_zmet_wtrphone",mapEntry,resultData,update_entry);
  344. //联系人.编码
  345. setDynamicField(false,"pznm_zmet_lxr_number","pznm_zmet_lxr","pznm_outcontacts",
  346. mapEntry,resultData,update_entry);
  347. //供应商子码.联系人电话
  348. setTextField(false,"pznm_zmet_lxrphone","pznm_zmet_lxrphone",mapEntry,resultData,update_entry);
  349. //供应商子码.采购负责人.工号
  350. setDynamicField(false,"pznm_zmet_cgper_number","pznm_zmet_cgper","bos_user",
  351. mapEntry,resultData,update_entry);
  352. //结算类型.编码
  353. setDynamicField(false,"pznm_zmet_setttype_number","pznm_zmet_setttype","pznm_settlementtype",
  354. mapEntry,resultData,update_entry);
  355. //供应商子码.账期摘要
  356. setTextField(false,"pznm_zmet_zqnotes","pznm_zmet_zqnotes",mapEntry,resultData,update_entry);
  357. //供应商子码.实销实结结算日
  358. setTextField(false,"pznm_zmet_settday","pznm_zmet_settday",mapEntry,resultData,update_entry);
  359. //账期类型(收款).编码
  360. setDynamicField(false,"pznm_zmet_zqrtype_number","pznm_zmet_zqrtype","bd_reccondition",
  361. mapEntry,resultData,update_entry);
  362. //账期类型(付款).编码
  363. setDynamicField(false,"pznm_zmet_zqptype_number","pznm_zmet_zqptype","bd_paycondition",
  364. mapEntry,resultData,update_entry);
  365. //支付方式.编码
  366. setDynamicField(false,"pznm_zmet_paytype_number","pznm_zmet_paytype","bd_settlementtype",
  367. mapEntry,resultData,update_entry);
  368. //发票类型.编码
  369. setDynamicField(false,"pznm_zmet_invoicetype_number","pznm_zmet_invoicetype","bd_invoicetype",
  370. mapEntry,resultData,update_entry);
  371. update_entrys.add(update_entry);
  372. }else{
  373. //不存在,缓存新增对象
  374. DynamicObject add_entry = BusinessDataServiceHelper.newDynamicObject("pznm_supplierzm");
  375. setDynamicField(true,"pznm_zmet_org_number","pznm_zmet_org","bos_org",
  376. mapEntry,resultData,add_entry);
  377. //供应商子码.子码编码
  378. setTextField(true,"pznm_zmet_number","number",mapEntry,resultData,add_entry);
  379. //供应商子码.子码名称
  380. setTextField(true,"pznm_zmet_name","name",mapEntry,resultData,add_entry);
  381. //供应商子码.老系统编号
  382. setTextField(false,"pznm_zmet_oldnumber","pznm_zmet_oldnumber",mapEntry,resultData,add_entry);
  383. //委托人.编码
  384. setDynamicField(false,"pznm_zmet_wtr_number","pznm_zmet_wtr","pznm_outcontacts",
  385. mapEntry,resultData,add_entry);
  386. //委托人信息.委托人电话
  387. setTextField(false,"pznm_zmet_wtrphone","pznm_zmet_wtrphone",mapEntry,resultData,add_entry);
  388. //联系人.编码
  389. setDynamicField(false,"pznm_zmet_lxr_number","pznm_zmet_lxr","pznm_outcontacts",
  390. mapEntry,resultData,add_entry);
  391. //供应商子码.联系人电话
  392. setTextField(false,"pznm_zmet_lxrphone","pznm_zmet_lxrphone",mapEntry,resultData,add_entry);
  393. //供应商子码.采购负责人.工号
  394. setDynamicField(false,"pznm_zmet_cgper_number","pznm_zmet_cgper","bos_user",
  395. mapEntry,resultData,add_entry);
  396. //结算类型.编码
  397. setDynamicField(false,"pznm_zmet_setttype_number","pznm_zmet_setttype","pznm_settlementtype",
  398. mapEntry,resultData,add_entry);
  399. //客户子码.账期摘要
  400. setTextField(false,"pznm_zmet_zqnotes","pznm_zmet_zqnotes",mapEntry,resultData,add_entry);
  401. //客户子码.实销实结结算日
  402. setTextField(false,"pznm_zmet_settday","pznm_zmet_settday",mapEntry,resultData,add_entry);
  403. //账期类型(收款).编码
  404. setDynamicField(false,"pznm_zmet_zqrtype_number","pznm_zmet_zqrtype","bd_reccondition",
  405. mapEntry,resultData,add_entry);
  406. //账期类型(付款).编码
  407. setDynamicField(false,"pznm_zmet_zqptype_number","pznm_zmet_zqptype","bd_paycondition",
  408. mapEntry,resultData,add_entry);
  409. //支付方式.编码
  410. setDynamicField(false,"pznm_zmet_paytype_number","pznm_zmet_paytype","bd_settlementtype",
  411. mapEntry,resultData,add_entry);
  412. //发票类型.编码
  413. setDynamicField(false,"pznm_zmet_invoicetype_number","pznm_zmet_invoicetype","bd_invoicetype",
  414. mapEntry,resultData,add_entry);
  415. //供应商
  416. add_entry.set("pznm_supplier",supplierObj);
  417. //数据状态
  418. add_entry.set("status","A");
  419. //使用状态
  420. add_entry.set("enable","1");
  421. add_entrys.add(add_entry);
  422. }
  423. }
  424. DynamicObject[] real_update_entrys = new DynamicObject[update_entrys.size()];
  425. for(int i=0;i< update_entrys.size();i++){
  426. real_update_entrys[i] = update_entrys.get(i);
  427. }
  428. DynamicObject[] real_add_entrys = new DynamicObject[add_entrys.size()];
  429. for(int i=0;i< add_entrys.size();i++){
  430. real_add_entrys[i] = add_entrys.get(i);
  431. }
  432. if(resultData.get("errors")==null || "".equals(resultData.get("errors"))) {
  433. //执行更新
  434. if (real_update_entrys.length > 0) {
  435. SaveServiceHelper.update(real_update_entrys);
  436. }
  437. //执行新增
  438. if (real_add_entrys.length > 0) {
  439. OperationResult result_submit = OperationServiceHelper.executeOperate("submit", "pznm_supplierzm",
  440. real_add_entrys, OperateOption.create());
  441. if (result_submit.isSuccess() == true) {
  442. OperationResult result_audit = OperationServiceHelper.executeOperate("audit", "pznm_supplierzm",
  443. real_add_entrys, OperateOption.create());
  444. if (result_audit.isSuccess() == false) {
  445. resultData.put("errors", "子码审核失败");
  446. }
  447. } else {
  448. resultData.put("errors", "子码创建失败");
  449. }
  450. }
  451. }
  452. }
  453. private void doSetWtrEntry(List<Map> mapEntrys, Map resultData, DynamicObject supplierObj) {
  454. DynamicObjectCollection entrys = supplierObj.getDynamicObjectCollection("pznm_wtrentry");
  455. entrys.clear();
  456. for(Map mapEntry : mapEntrys){
  457. DynamicObject newEntry = new DynamicObject(entrys.getDynamicObjectType());
  458. //所属组织
  459. setDynamicField(true,"pznm_wtret_org_number","pznm_wtret_org","bos_org",
  460. mapEntry,resultData,newEntry);
  461. //委托人信息.委托人电话
  462. setTextField(false,"pznm_wtret_userphone","pznm_wtret_userphone",mapEntry,resultData,newEntry);
  463. //委托人.编码
  464. setDynamicField(true,"pznm_wtret_user_number","pznm_wtret_user","pznm_outcontacts",
  465. mapEntry,resultData,newEntry);
  466. entrys.add(newEntry);
  467. }
  468. }
  469. private void doSetKzztentry(List<Map> mapEntrys, Map resultData, DynamicObject supplierObj) {
  470. DynamicObjectCollection entrys = supplierObj.getDynamicObjectCollection("pznm_kzztentry");
  471. entrys.clear();
  472. for(Map mapEntry : mapEntrys){
  473. DynamicObject newEntry = new DynamicObject(entrys.getDynamicObjectType());
  474. //所属组织
  475. setDynamicField(true,"pznm_kzztet_org_number","pznm_kzztet_org","bos_org",
  476. mapEntry,resultData,newEntry);
  477. //公司级状态
  478. setTextField(true,"pznm_companystatus","pznm_companystatus",mapEntry,resultData,newEntry);
  479. entrys.add(newEntry);
  480. }
  481. }
  482. /* 校验并设置F7字段
  483. * @key 入参校验字段
  484. * @fieldName 写入供应商对象的字段名
  485. * @entityNumber 字段对应基础资料实体名
  486. * @param 接口入参对象
  487. * @resultData 返回报文对象
  488. * @supplierObj 供应商对象
  489. */
  490. private void setDynamicField(Boolean isMust,String key,String fieldName, String entityNumber, Map param, Map resultData, DynamicObject supplierObj) {
  491. if(param.get(key)==null || "".equals(param.get(key))){
  492. if(isMust){
  493. String errors = resultData.get("errors")!=null?resultData.get("errors").toString()+";":"";
  494. resultData.put("errors",errors+"参数【" + key + "】必填");
  495. }
  496. }else{
  497. QFilter qFilter_number = new QFilter("number",QCP.equals,param.get(key));
  498. QFilter qFilter_enable = new QFilter("enable", QCP.equals,"1");
  499. QFilter qFilter_status = new QFilter("status", QCP.equals, "C");
  500. DynamicObject objCol = BusinessDataServiceHelper.loadSingleFromCache(entityNumber,"id,number,name",
  501. new QFilter[]{qFilter_number,qFilter_enable,qFilter_status});
  502. if(objCol!=null){
  503. supplierObj.set(fieldName,objCol);
  504. }else{
  505. String errors = resultData.get("errors")!=null?resultData.get("errors").toString()+";":"";
  506. resultData.put("errors",errors+"参数【" + key + "】值【"+param.get(key)+"】匹配不成功,可能的原因是:1、编码不正确 2、不符合基础资料字段查询条件");
  507. }
  508. }
  509. }
  510. /* 校验并设置文本字段
  511. * @key 入参校验字段
  512. * @fieldName 写入供应商对象的字段名
  513. * @param 接口入参对象
  514. * @resultData 返回报文对象
  515. * @supplierObj 供应商对象
  516. */
  517. private void setTextField(Boolean isMust,String key,String fieldName,Map param, Map resultData, DynamicObject supplierObj) {
  518. if(param.get(key)==null || "".equals(param.get(key))){
  519. if(isMust){
  520. String errors = resultData.get("errors")!=null?resultData.get("errors").toString()+";":"";
  521. resultData.put("errors",errors+"参数【" + key + "】必填");
  522. }
  523. }else{
  524. supplierObj.set(fieldName,param.get(key));
  525. }
  526. }
  527. /* 校验并设置日期字段
  528. * @key 入参校验字段
  529. * @fieldName 写入供应商对象的字段名
  530. * @param 接口入参对象
  531. * @resultData 返回报文对象
  532. * @supplierObj 供应商对象
  533. */
  534. private void setDateField(Boolean isMust,String key,String fieldName,Map param, Map resultData, DynamicObject supplierObj) throws ParseException {
  535. if(param.get(key)==null || "".equals(param.get(key))){
  536. if(isMust){
  537. String errors = resultData.get("errors")!=null?resultData.get("errors").toString()+";":"";
  538. resultData.put("errors",errors+"参数【" + key + "】必填");
  539. }
  540. }else{
  541. supplierObj.set(fieldName,new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(param.get(key).toString()));
  542. }
  543. }
  544. }