package com.malk.siku.service.impl; import com.alibaba.fastjson.JSONObject; import com.malk.server.aliwork.YDConf; import com.malk.server.aliwork.YDParam; import com.malk.server.common.McR; import com.malk.service.aliwork.YDClient; import com.malk.service.dingtalk.DDClient; import com.malk.service.dingtalk.DDClient_Contacts; import com.malk.service.dingtalk.DDClient_Personnel; import com.malk.siku.service.SikuService; import com.malk.siku.utils.MkBxUtil; import com.malk.siku.utils.MkYpUtil; import com.malk.siku.utils.QyddUtil; import com.malk.utils.UtilHttp; import com.malk.utils.UtilMap; import lombok.extern.slf4j.Slf4j; import org.apache.logging.log4j.util.Strings; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import java.io.FileOutputStream; import java.io.InputStream; import java.net.HttpURLConnection; import java.net.URL; import java.text.SimpleDateFormat; import java.util.*; import java.util.stream.Collectors; @Slf4j @Service public class SikuServiceImpl implements SikuService { @Autowired private YDClient ydClient; @Value(value = "${mk.downloadFilePath}") private String downloadFilePath; @Value(value = "${mk.downloadUrl}") private String downloadUrl; @Autowired private DDClient ddClient; //每刻报销 测试环境 /*private static String mkbx_empId = "18857526310";//默认 周漂 private static String mkbx_deptId = "DI205228744816739500";//默认 财务部*/ //每刻报销 正式环境 private static String mkbx_empId = "HZ769";//默认 周漂 private static String mkbx_deptId = "DI205228744816739500";//默认 财务部 //每刻云票 测试环境 // private static String mkyp_empId = "18857526310";//默认 周漂 //每刻云票 正式环境 private static String mkyp_empId = "HZ769";//默认 周漂 @Override public McR saveTradingPartner(Map map) { String formInstId = UtilMap.getString(map, "formInstId"); String type = UtilMap.getString(map, "type"); Map formData = ydClient.queryData(YDParam.builder() .formInstanceId(formInstId) .build(), YDConf.FORM_QUERY.retrieve_id).getFormData(); Map partner = new HashMap(); if ("客户".equals(type)){ //客户 // partner.put("parentName", "客户");//所属分类名称 partner.put("name", UtilMap.getString(formData,"textField_mkddjwy3"));//往来单位中文名 partner.put("partnerType", "客户");//往来关系，可选值为："供应商"、"客户"、"供应商，客户"（既是供应商又是客户的情况下以中文逗号分隔(供应商在前)） partner.put("partnerProperty", "公司");//往来性质，可选值为："公司"、"个体工商户" partner.put("businessCode", UtilMap.getString(formData,"serialNumberField_mkddjwy2"));//往来单位编码,不超过50个字符 partner.put("taxNumber", UtilMap.getString(formData,"textField_mkddjwys"));//税务登记号,不超过200个字符 partner.put("readOnly", false);//是否只读，默认false。如果为true，那么在每刻系统中往来单位的所有信息（如权限范围、收款账户等）均无法修改。（接口更新操作不受限制） partner.put("reMark", "");//往来单位备注 partner.put("enabled", true);//是否启用（true:启用；false:禁用）。若该参数为空，新增则默认为true，更新则保持系统内状态。 }else { //供应商 String hzlx = UtilMap.getString(formData, "radioField_mketkvw7"); String freeType = UtilMap.getString(formData, "radioField_mmyoc59n");//free类别 // partner.put("parentBizCode", "GYS");//所属分类业务编码 partner.put("name", "个人".equals(freeType) ? UtilMap.getString(formData,"textField_mkkixdd6") : UtilMap.getString(formData,"textField_mketkvv0"));//往来单位中文名 partner.put("partnerType", "供应商");//往来关系，可选值为："供应商"、"客户"、"供应商，客户"（既是供应商又是客户的情况下以中文逗号分隔(供应商在前)） partner.put("partnerProperty", "个人".equals(freeType) ? "个体工商户" : "公司");//往来性质，可选值为："公司"、"个体工商户" partner.put("businessCode", UtilMap.getString(formData,"serialNumberField_mketkvw4"));//往来单位编码,不超过50个字符 partner.put("taxNumber", "个人".equals(freeType) ? "" : UtilMap.getString(formData,"textField_mketkvxo"));//税务登记号,不超过200个字符 partner.put("readOnly", false);//是否只读，默认false。如果为true，那么在每刻系统中往来单位的所有信息（如权限范围、收款账户等）均无法修改。（接口更新操作不受限制） partner.put("reMark", "");//往来单位备注 partner.put("enabled", "启用".equals(UtilMap.getString(formData,"radioField_mketkvw8")));//是否启用（true:启用；false:禁用）。若该参数为空，新增则默认为true，更新则保持系统内状态。 } Map body = new HashMap(); body.put("partnerList", Arrays.asList(partner)); Map result = MkBxUtil.saveTradingPartner(body); List data = UtilMap.getList(result, "data"); String status = UtilMap.getString(data.get(0), "status"); if ("ALL_FAIL".equals(status)){ //保存往来单位失败回写错误信息 String message = UtilMap.getString(data.get(0), "message"); ydClient.operateData(YDParam.builder() .formInstanceId(formInstId) .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("selectField_mmx7nk6m, textareaField_mmx7nk6r","入库失败",message))) .build(), YDConf.FORM_OPERATION.update); } //保存往来单位账户 if ("SUCCESS".equals(status)){ Map account = new HashMap(); account.put("businessCode",UtilMap.getString(formData,"serialNumberField_mketkvw4")); Map accountItem = new HashMap(); accountItem.put("accountName",UtilMap.getString(formData,"textField_mketkvxa"));//账户名称 accountItem.put("accountNumber",UtilMap.getString(formData,"textField_mketkvxc"));//账号 accountItem.put("bankBranchName",UtilMap.getString(formData,"textField_mketkvx8"));//分支行 accountItem.put("accountType","BANK"); account.put("accounts",Arrays.asList(accountItem)); Map result2 = MkBxUtil.saveAccount(Arrays.asList(account)); List data2 = UtilMap.getList(result2, "data"); String status2 = UtilMap.getString(data2.get(0), "status"); if ("ALL_FAIL".equals(status2)){ String message = UtilMap.getString(data2.get(0), "message"); ydClient.operateData(YDParam.builder() .formInstanceId(formInstId) .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("selectField_mmx7nk6m, textareaField_mmx7nk6r","入库成功，账号保存失败",message))) .build(), YDConf.FORM_OPERATION.update); }else { ydClient.operateData(YDParam.builder() .formInstanceId(formInstId) .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("selectField_mmx7nk6m, textareaField_mmx7nk6r","入库成功",""))) .build(), YDConf.FORM_OPERATION.update); } } return McR.success(); } @Override public McR saveYpApplication(Map map) { String formInstId = UtilMap.getString(map, "formInstId"); Map formData = ydClient.queryData(YDParam.builder() .formInstanceId(formInstId) .build(), YDConf.FORM_QUERY.retrieve_id).getFormData(); Map application = new HashMap(); application.put("formSubTypeBizCode","KPSQD");//单据编码（云票系统内维护的） application.put("bizCode", UtilMap.getString(formData,"serialNumberField_mknspz75"));//外部系统中的开票申请单业务编码。必须系统内唯一，用于判断开票申请单是否已导入。 application.put("clientBizCode",UtilMap.getString(formData,"textField_mkxpe3fj"));//收票方bizCode（客户的业务编码（云票系统内维护的））与收票方开票信息字段二选一必填 application.put("clientLegalEntityBizCode",UtilMap.getString(formData,"textField_mkddjwys"));//收票方抬头code，如果不传默认第一个（云票系统内维护的） String jobNumber = UtilMap.getString(formData, "textField_mo0x02kw");//申请人工号 List allEmployee = MkYpUtil.getAllEmployee(); String employeeId = mkyp_empId; for (Map employee : allEmployee) { String employeeId2 = UtilMap.getString(employee, "employeeId"); if (jobNumber.equals(employeeId2)){ employeeId = employeeId2; break; } } application.put("submitterBizCode",employeeId);//提交人工号，单据状态为审批中时必填 application.put("applicantBizCode",employeeId);//开票申请人工号 /*Map clientLegalEntityOaDto = new HashMap();//收票方开票信息（不在云票系统内维护的）与收票方bizCode（客户的业务编码）二选一必填且优先级高于收票方bizCode（客户的业务编码）（也就是当两字段都有值时，忽略客户的业务编码） clientLegalEntityOaDto.put("invoiceTitle",UtilMap.getString(formData,"selectField_mkxmix7e"));//名称 clientLegalEntityOaDto.put("dutyParagraph",UtilMap.getString(formData,"textField_mm2wj87l"));//税号 clientLegalEntityOaDto.put("account",UtilMap.getString(formData,"textField_mm2wj87u"));//账号 clientLegalEntityOaDto.put("bankBranchName",UtilMap.getString(formData,"textField_mm2wj87t"));//银行 application.put("clientLegalEntityOaDto",clientLegalEntityOaDto);*/ application.put("legalEntityBizCode",UtilMap.getString(formData,"textField_mn4dhy5g"));//公司主体code(后续传税号) application.put("estimatedDate",System.currentTimeMillis());//预计开票时间 String fplx = UtilMap.getString(formData, "selectField_mkdnuvem");//发票类型 String estimatedInvoiceType = ""; if (!"红冲".equals(fplx)){ estimatedInvoiceType = getEstimatedInvoiceType(fplx, estimatedInvoiceType); application.put("hasRedInvoice",false);//是否负数发票 application.put("redInvoiceReason",UtilMap.getString(formData,"textareaField_mmelm9xt"));//红冲原因 }else { String lzfplx = UtilMap.getString(formData, "textField_mm2wj87n");//蓝字发票类型 estimatedInvoiceType = getEstimatedInvoiceType(lzfplx, estimatedInvoiceType); application.put("hasRedInvoice",true);//是否负数发票 } application.put("estimatedInvoiceType",estimatedInvoiceType);//发票类型 application.put("phoneNumber",UtilMap.getString(formData,"textField_mkdo0azf"));//收票人电话 application.put("email",UtilMap.getString(formData,"textField_mkdo0azn"));//收票邮箱 application.put("autoSendMail",true);//是否自动发送邮件/短信，若传true且填写正确的收票邮箱/手机号，则在开票申请单完全开票后自动发邮件/短信。不填写收票邮箱/短信或传false时，将不会自动交付电子发票。 application.put("applicationComment",UtilMap.getString(formData,"textareaField_mkdo0aze"));//开票备注 Map item = new HashMap(); item.put("productBizCode","1001");//产品bizcode item.put("invoiceName",UtilMap.getString(formData,"textField_mn4ajusx"));//开票名称 item.put("taxPercent",UtilMap.getDouble(formData,"numberField_mkgkboht")/100);//税率 item.put("forexName","CNY");//币种 item.put("exchangeRate",1);//外汇汇率 item.put("taxClassShortCode",UtilMap.getString(formData,"textField_mm49zsli"));//税收分类编码 if (!"红冲".equals(fplx)){ item.put("quantity",1);//数量 item.put("priceWithTax",UtilMap.getDouble(formData,"numberField_mkdo0azb"));//含税单价 }else { item.put("quantity",-1);//数量 item.put("priceWithTax",UtilMap.getDouble(formData,"numberField_mknspz7d"));//含税单价 Map originInvoice = new HashMap(); originInvoice.put("blueInvoiceNumber",UtilMap.getString(formData,"textField_mkxmix7d"));//原蓝字发票号 item.put("blueInvoiceDto",Arrays.asList(originInvoice)); } application.put("items",Arrays.asList(item)); //若为红冲发票，先作废原蓝字发票应收单 if ("红冲".equals(fplx)){ //原蓝字发票应收单查询 String lzlsh = UtilMap.getString(formData, "textField_mknspz7c");//原蓝字发票流水号 Map body1 = new HashMap(); body1.put("applicationInvoiceBizCodeList",Arrays.asList(lzlsh)); body1.put("pageSize",1); body1.put("pageNum",1); List receivableList = MkYpUtil.searchReceivable(body1); if (!receivableList.isEmpty()){ Map receivable = receivableList.get(0); String bizCode = UtilMap.getString(receivable, "bizCode"); //作废原蓝字发票应收单 Map body2 = new HashMap(); body2.put("employeeId",employeeId); body2.put("bizCodeList",Arrays.asList(bizCode)); MkYpUtil.receivableObsolete(body2); } } Map result = MkYpUtil.application(Arrays.asList(application)); if (!isTrue(result)){ ydClient.operateData(YDParam.builder() .formInstanceId(formInstId) .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("radioField_mkxripcc, textareaField_mmlzqvn0","开票失败",getErrorMsg(result)))) .useLatestVersion(true) .build(), YDConf.FORM_OPERATION.update); } return McR.success(); } private boolean isTrue(Map result){ String messageCode = UtilMap.getString(result, "messageCode"); if (Objects.nonNull(messageCode) && "SUCCESS".equals(messageCode)){ return true; }else { return false; } } //获取错误信息 private String getErrorMsg(Map result) { String errorMsg = UtilMap.getString(result, "message"); Map data = UtilMap.getMap(result, "data"); if (Objects.nonNull(data)){ List errorData = UtilMap.getList(data, "errorData"); if (Objects.nonNull(errorData) && !errorData.isEmpty()){ for (Map errorDatum : errorData) { errorMsg = errorMsg + ";" + UtilMap.getString(errorDatum, "errorMessage"); } } } return errorMsg; } private static String getEstimatedInvoiceType(String fplx, String estimatedInvoiceType) { switch (fplx){ case "应/免税普票": estimatedInvoiceType = "ELECTRONIC_VAT";break;//电子发票(普通发票)（税号开通全电） case "专票": estimatedInvoiceType = "ELECTRONIC_SPACIAL_VAT";break;//电子发票(增值税专票)（税号开通全电） case "红冲":break; case "形式发票":break; case "收据":break; default:break; } return estimatedInvoiceType; } @Async @Override public void invoiceWriteBack2(Map map) { //获取发票信息 Map calloutParams = UtilMap.getMap(map, "calloutParams"); String serviceType = UtilMap.getString(calloutParams, "serviceType"); Map bizData = UtilMap.getMap(calloutParams, "bizData"); if ("INVOICE_VAT_INVOICED_NOTIFY_AR".equals(serviceType)){//开票成功逻辑移到应收单完成回调中 /*//发票开具成功后回调 String bizCode = UtilMap.getString(bizData, "bizCode");//发票号码 String invoiceNumber = UtilMap.getString(bizData, "invoiceNumber");//发票号码 long issueDate = UtilMap.getLong(bizData, "issueDate");//开票日期 String pdfUrl = UtilMap.getString(bizData, "pdfUrl");//pdf文件下载地址 String downloadPageUrl = UtilMap.getString(bizData, "downloadPageUrl");//发票下载页面链接 List detailItems = (List) UtilMap.getList(bizData, "detailItems"); List documentCorrelates = UtilMap.getList(detailItems.get(0), "documentCorrelates"); String lsh = UtilMap.getString(documentCorrelates.get(0), "bizCode");//开票申请单编号 //回写宜搭 Map updateFormData = new HashMap(); updateFormData.put("radioField_mkxripcc","开票成功"); updateFormData.put("textField_mkxripc6",invoiceNumber); updateFormData.put("dateField_mnfpbwpd",issueDate); updateFormData.put("textField_mm3aixk0",downloadPageUrl); updateFormData.put("textareaField_mmlzqvn0",""); if (Strings.isNotBlank(pdfUrl)){ String fileName = invoiceNumber + ".pdf"; String downloadPath = downloadFilePath + fileName; downloadFile(pdfUrl,downloadPath);//下载pdf发票 String downloadUri = downloadUrl + "/files/" + fileName + "?option=download" + fileName; String previewUri = downloadUrl + "/files/"+fileName+"?option=preview" + fileName; Map attachmentField = new HashMap(); attachmentField.put("downloadUrl",downloadUri); attachmentField.put("name",fileName); attachmentField.put("previewUrl",previewUri); attachmentField.put("url",downloadUri); attachmentField.put("ext","pdf"); updateFormData.put("attachmentField_mkxripc5",Arrays.asList(attachmentField)); } Map data = ((List)ydClient.queryData(YDParam.builder() .formInstanceId(bizCode) .searchCondition(JSONObject.toJSONString(UtilMap.map("serialNumberField_mknspz75",lsh))) .formUuid("FORM-A9A47B0365DB437F8F4C8E01B4468220K7GU") .build(), YDConf.FORM_QUERY.retrieve_list).getData()).get(0); String formInstanceId = UtilMap.getString(data, "formInstanceId"); ydClient.operateData(YDParam.builder() .formInstanceId(formInstanceId) .updateFormDataJson(JSONObject.toJSONString(updateFormData)) .build(), YDConf.FORM_OPERATION.update);*/ }else if ("INVOICE_APPLICATION_VAT_FAIL_NOTIFY_AR".equals(serviceType)){ //开票失败后回调 String invoiceErrorMsg = UtilMap.getString(bizData, "invoiceErrorMsg"); String bizCode = UtilMap.getString(bizData, "bizCode"); Map data = ((List)ydClient.queryData(YDParam.builder() .formInstanceId(bizCode) .searchCondition(JSONObject.toJSONString(UtilMap.map("serialNumberField_mknspz75",bizCode))) .formUuid("FORM-A9A47B0365DB437F8F4C8E01B4468220K7GU") .build(), YDConf.FORM_QUERY.retrieve_list).getData()).get(0); String formInstanceId = UtilMap.getString(data, "formInstanceId"); ydClient.operateData(YDParam.builder() .formInstanceId(formInstanceId) .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("radioField_mkxripcc, textareaField_mmlzqvn0","开票失败",invoiceErrorMsg))) .build(), YDConf.FORM_OPERATION.update); } } @Override public McR saveBxReimbursement(Map map) { String formInstId = UtilMap.getString(map, "formInstId"); Map formData = ydClient.queryData(YDParam.builder() .formInstanceId(formInstId) .build(), YDConf.FORM_QUERY.retrieve_id).getFormData(); String type = UtilMap.getString(formData, "radioField_mkkmij3b");//需求单类型 String formSubTypeBizCode = "FT208629766551519240";//项目支付单 Double amt = UtilMap.getDouble(formData, "numberField_mkkmij6i"); String empId = ""; String deptBusinessCode = ""; String ydfqr = UtilMap.getString(formData, "textField_mmwvodde");//宜搭发起人工号 String ztcggh = UtilMap.getString(formData, "textField_mmwvfb97");//中台采购工号 String legalEntityBizCode = UtilMap.getString(formData, "textField_mmd6hio7");//公司抬头编码 String xqbh = UtilMap.getString(formData, "serialNumberField_mkkmij3o");//需求编号 long ldjssj = UtilMap.getLong(formData, "dateField_mkdf8q8q");//落地结束时间 String isFree = "FREE需求".equals(type) ? "是" : "否";//是否free String isDdf = "是".equals(UtilMap.getString(formData, "radioField_mkf2quln")) ? "1" : "2";//是否代垫付 String xmsssyb = UtilMap.getString(formData, "selectField_mkdedkv7");//项目所属事业部 String projectCode = UtilMap.getString(formData, "textField_mmoh6nvx");//项目编码 //针对多供应商分期付款拆分多条每刻项目支付单 if ("常规需求".equals(type)){ List detailList = UtilMap.getList(formData, "tableField_mkkmij56");//常规-采购明细 int index = 0; for (Map detail : detailList) { index++; String uuid = UtilMap.getString(detail, "textField_mmvhqm0q");//子表uuid Map body = new HashMap(); body.put("formCode",xqbh + "-" + index);//有值时会使用该值作为单据号 body.put("formSubTypeBizCode",formSubTypeBizCode);//表单类型的业务编号 String mktdr = UtilMap.getString(detail, "selectField_mo9z9dva");//每刻提单人 body.put("submittedUserEmployeeId",mktdr);//提单人工号 body.put("coverUserEmployeeId",mktdr);//承担人工号 // body.put("",ydfqr.equals(mktdr) ? ztcggh : mktdr);//todo 抄送人工号 若每刻提单人为宜搭发起人，抄送人则为中台采购 若每刻提单人为中台采购，抄送人则为宜搭发起人 //查询每刻提单人部门 Map employeeDetails = MkBxUtil.employeeDetails(UtilMap.map("employeeIds", Arrays.asList(mktdr))); String coverDepartmentBizCode = mkbx_deptId; if (Objects.nonNull(employeeDetails)){ List departments = UtilMap.getList(employeeDetails, "departments"); coverDepartmentBizCode = UtilMap.getString(departments.get(0), "businessCode"); } body.put("coverDepartmentBizCode",coverDepartmentBizCode);//承担部门编码 body.put("reimburseName",UtilMap.getString(detail,"textareaField_mkkmij5i"));//报销事由 body.put("legalEntityBizCode",legalEntityBizCode);//公司抬头编码 body.put("tradingPartnerBizCode",UtilMap.getString(detail,"textField_mmbmohrb"));//往来单位编码 Map customObject = new HashMap(); customObject.put("CF4",new HashMap(){{put("currentTime",ldjssj);}});//落地结束时间 customObject.put("CF3",new HashMap(){{put("currentTime",UtilMap.getLong(detail,"dateField_mmvhqm0u"));}});//期望支付日期 customObject.put("CF6",isFree);////free 是；否 customObject.put("CF5",isDdf);//代垫付 是：1 ； 否：2 customObject.put("CF2",xmsssyb);//项目所属事业部 customObject.put("CF1",projectCode);//项目 customObject.put("CF7",UtilMap.getString(detail,"numberField_mmwt2wcn"));//逾期天数 body.put("customObject",customObject); //报销单费用导入 Map expenseListItem = new HashMap(); Map consumeAmount = new HashMap(); consumeAmount.put("amount",String.format("%.2f", UtilMap.getDouble(detail,"numberField_mkkmij5e")));//结算金额 consumeAmount.put("currency","CNY"); expenseListItem.put("consumeAmount",consumeAmount); expenseListItem.put("corpExpense",true);//是否对公费用，需要填写true String gysej = UtilMap.getString(detail, "selectField_mkkkw28y");//供应商二级 expenseListItem.put("expenseTypeBizCode",MkBxUtil.expenseTypeSearch(UtilMap.map("keyword",gysej)));//费用类型业务编码 expenseListItem.put("corpType","NO_RECEIPT");//业务场景：ALL_RECEIPTS(全部到票) NO_RECEIPT(预付未到票) RECEIPT_DEDUCTION(到票核销) RECEIPT_PAY_SOME(到票部分支付或不支付) PAY_BEFORE_RECEIPT(支付前期已到的发票) expenseListItem.put("nonReceiptAmount",new HashMap<>(consumeAmount));//未到票金额（预付未到票场景必填） expenseListItem.put("forecastReceiptDate",System.currentTimeMillis());//预计到票时间（预付未到票场景必填） expenseListItem.put("tradingPartnerBizCode",UtilMap.getString(detail,"textField_mmbmohrb"));//往来单位业务编码 Map consumeLocation = new HashMap(); consumeLocation.put("cityPair",null); consumeLocation.put("location","110001");//todo 暂时写死 110001 北京 expenseListItem.put("consumeLocation",consumeLocation); expenseListItem.put("corpExpenseResponsibleEmpIds",Arrays.asList("002"));//责任人/业务经办人（预付未到票/到票部分支付或不支付 两种场景必填） todo 暂时写死 002 wzy Map body2 = new HashMap(); body2.put("employeeId","002");//需要导入的对应员工的工号 body2.put("expenseList",Arrays.asList(expenseListItem)); List expenseCodes = MkBxUtil.receiveExpense(body2); body.put("expenseCodes",expenseCodes);//费用类型业务编码 //收款账户 Map payeeAccount = new HashMap(); payeeAccount.put("bankAcctName",UtilMap.getString(detail,"textField_mkkmij6z"));//账户名 payeeAccount.put("bankAcctNumber",UtilMap.getString(detail,"textField_mkkmij6y"));//银行账户 payeeAccount.put("paymentType","BANK");//账户类型;ALIPAY-支付宝,BANK-银行账户,CASH-现金 payeeAccount.put("accountType","CORP");//收款账户类型：个人（员工）-PERSONAL,公司（往来单位）-CORP body.put("payeeAccount",payeeAccount); body.put("stagingFlag",true);//暂存标识，默认为false表示不暂存 Map result = MkBxUtil.receiveReimburse(body); } }else { List detailList = UtilMap.getList(formData, "tableField_mkkmij61");//free-采购明细 int index = 0; for (Map detail : detailList) { index ++; String uuid = UtilMap.getString(detail, "textField_mmvhqm0s");//子表uuid Map body = new HashMap(); body.put("formCode",xqbh + "-" +index);//有值时会使用该值作为单据号 body.put("formSubTypeBizCode",formSubTypeBizCode);//表单类型的业务编号 String mktdr = UtilMap.getString(detail, "selectField_mo9z9dvc");//每刻提单人 body.put("submittedUserEmployeeId",mktdr);//提单人工号 body.put("coverUserEmployeeId",mktdr);//承担人工号 // body.put("",ydfqr.equals(mktdr) ? ztcggh : mktdr);//todo 抄送人工号 若每刻提单人为宜搭发起人，抄送人则为中台采购 若每刻提单人为中台采购，抄送人则为宜搭发起人 //查询每刻提单人部门 Map employeeDetails = MkBxUtil.employeeDetails(UtilMap.map("employeeIds", Arrays.asList(mktdr))); String coverDepartmentBizCode = mkbx_deptId; if (Objects.nonNull(employeeDetails)){ List departments = UtilMap.getList(employeeDetails, "departments"); coverDepartmentBizCode = UtilMap.getString(departments.get(0), "businessCode"); } body.put("coverDepartmentBizCode",coverDepartmentBizCode);//承担部门编码 body.put("reimburseName","FREE-" + UtilMap.getString(detail,"selectField_mkkixdd7"));//报销事由 body.put("legalEntityBizCode",legalEntityBizCode);//公司抬头编码 body.put("tradingPartnerBizCode",UtilMap.getString(detail,"textField_mmekbfa2"));//往来单位编码 Map customObject = new HashMap(); customObject.put("CF4",new HashMap(){{put("currentTime",ldjssj);}});//落地结束时间 customObject.put("CF3",new HashMap(){{put("currentTime",UtilMap.getLong(detail,"dateField_mkkkw298"));}});//期望支付日期 customObject.put("CF6",isFree);//free 是；否 customObject.put("CF5",isDdf);//代垫付 是：1 ； 否：2 customObject.put("CF2",xmsssyb);//项目所属事业部 customObject.put("CF1",projectCode);//项目 customObject.put("CF7",UtilMap.getString(detail,"numberField_mmwswtkx"));//逾期天数 body.put("customObject",customObject); //报销单费用导入 Map expenseListItem = new HashMap(); Map consumeAmount = new HashMap(); consumeAmount.put("amount",String.format("%.2f", UtilMap.getDouble(detail,"numberField_mkkmij6p")));//结算金额 consumeAmount.put("currency","CNY"); expenseListItem.put("consumeAmount",consumeAmount); expenseListItem.put("corpExpense",true);//是否对公费用，需要填写true String gysej = UtilMap.getString(detail, "selectField_mmwuzaql");//供应商二级 expenseListItem.put("expenseTypeBizCode",MkBxUtil.expenseTypeSearch(UtilMap.map("keyword",gysej)));//费用类型业务编码 expenseListItem.put("corpType","NO_RECEIPT");//业务场景：ALL_RECEIPTS(全部到票) NO_RECEIPT(预付未到票) RECEIPT_DEDUCTION(到票核销) RECEIPT_PAY_SOME(到票部分支付或不支付) PAY_BEFORE_RECEIPT(支付前期已到的发票) expenseListItem.put("nonReceiptAmount",new HashMap<>(consumeAmount));//未到票金额（预付未到票场景必填） expenseListItem.put("forecastReceiptDate",System.currentTimeMillis());//预计到票时间（预付未到票场景必填） expenseListItem.put("tradingPartnerBizCode",UtilMap.getString(detail,"textField_mmekbfa2"));//往来单位业务编码 Map consumeLocation = new HashMap(); consumeLocation.put("cityPair",null); consumeLocation.put("location","110001");//todo 暂时写死 110001 北京 expenseListItem.put("consumeLocation",consumeLocation); expenseListItem.put("corpExpenseResponsibleEmpIds",Arrays.asList("002"));//责任人/业务经办人（预付未到票/到票部分支付或不支付 两种场景必填） todo 暂时写死 002 wzy Map body2 = new HashMap(); body2.put("employeeId","002");//需要导入的对应员工的工号 body2.put("expenseList",Arrays.asList(expenseListItem)); List expenseCodes = MkBxUtil.receiveExpense(body2); body.put("expenseCodes",expenseCodes);//费用类型业务编码 //收款账户 Map payeeAccount = new HashMap(); payeeAccount.put("bankAcctName",UtilMap.getString(detail,"textField_mketkvxa"));//账户名 payeeAccount.put("bankAcctNumber",UtilMap.getString(detail,"textField_mketkvxc"));//银行账户 payeeAccount.put("paymentType","BANK");//账户类型;ALIPAY-支付宝,BANK-银行账户,CASH-现金 payeeAccount.put("accountType","CORP");//收款账户类型：个人（员工）-PERSONAL,公司（往来单位）-CORP body.put("payeeAccount",payeeAccount); body.put("stagingFlag",true);//暂存标识，默认为false表示不暂存 Map result = MkBxUtil.receiveReimburse(body); } } /*Map body = new HashMap(); body.put("formCode",UtilMap.getString(formData,"serialNumberField_mkkmij3o"));//有值时会使用该值作为单据号 body.put("formSubTypeBizCode","FT208629766551519240");//表单类型的业务编号 todo 暂时写死 FT208629766551519240 宜搭支付单 body.put("submittedUserEmployeeId","002");//提单人工号 todo 暂时写死 002 wzy body.put("reimburseName",UtilMap.getString(formData,"textareaField_mmbmohr9"));//报销事由 body.put("legalEntityBizCode",UtilMap.getString(formData,"textField_mmd6hio7"));//公司抬头编码 body.put("coverUserEmployeeId","002");//承担人工号 todo 暂时写死 002 wzy body.put("coverDepartmentBizCode","DI203800035494740082");//承担部门编码 todo 暂时写死 DI203800035494740082 Map customObject = new HashMap(); customObject.put("CF4",new HashMap(){{put("currentTime",UtilMap.getLong(formData,"dateField_mkdf8q8q"));}});//落地结束时间 customObject.put("CF3",new HashMap(){{put("currentTime",UtilMap.getLong(formData,"dateField_mkkkw298"));}});//预计支付日期 customObject.put("CF6",UtilMap.getString(formData,"radioField_mkf2quln"));////free 是；否 customObject.put("CF5","是".equals(UtilMap.getString(formData,"radioField_mkf2quln")) ? "1" : "2");//代垫付 是：1 ； 否：2 customObject.put("CF2",UtilMap.getString(formData,"selectField_mkdedkv7"));//项目所属事业部 customObject.put("CF1",UtilMap.getString(formData,"textField_mmoh6nvx"));//项目 body.put("customObject",customObject); List expenseCodes = new ArrayList<>(); List collectionSchedule = new ArrayList<>(); List expenseList = new ArrayList<>(); if ("常规需求".equals(type)){ List detailList = UtilMap.getList(formData, "tableField_mkkmij56");//常规-采购明细 for (Map result : detailList) { Map item = new HashMap(); Map consumeAmount = new HashMap(); consumeAmount.put("amount",String.format("%.2f", UtilMap.getDouble(result,"numberField_mkkmij5e")));//结算金额 consumeAmount.put("currency","CNY"); item.put("consumeAmount",consumeAmount); item.put("corpExpense",true);//是否对公费用，需要填写true item.put("expenseTypeBizCode","200140");//费用类型业务编码 todo 暂时写死 200140 其他费用 item.put("corpType","NO_RECEIPT");//业务场景：ALL_RECEIPTS(全部到票) NO_RECEIPT(预付未到票) RECEIPT_DEDUCTION(到票核销) RECEIPT_PAY_SOME(到票部分支付或不支付) PAY_BEFORE_RECEIPT(支付前期已到的发票) item.put("nonReceiptAmount",new HashMap<>(consumeAmount));//未到票金额（预付未到票场景必填） item.put("forecastReceiptDate",System.currentTimeMillis());//预计到票时间（预付未到票场景必填） item.put("tradingPartnerBizCode",UtilMap.getString(result,"textField_mmbmohrb"));//往来单位业务编码 Map consumeLocation = new HashMap(); consumeLocation.put("cityPair",null); consumeLocation.put("location","110001"); item.put("consumeLocation",consumeLocation); item.put("corpExpenseResponsibleEmpIds",Arrays.asList("002"));//责任人/业务经办人（预付未到票/到票部分支付或不支付 两种场景必填） todo 暂时写死 002 wzy expenseList.add(item); Map collectionScheduleItem = new HashMap(); Map payeeAccount = new HashMap(); payeeAccount.put("bankAcctName",UtilMap.getString(result,"textField_mkkmij6z"));//账户名 payeeAccount.put("bankAcctNumber",UtilMap.getString(result,"textField_mkkmij6y"));//银行账户 payeeAccount.put("paymentType","BANK");//账户类型;ALIPAY-支付宝,BANK-银行账户,CASH-现金 payeeAccount.put("accountType","CORP");//收款账户类型：个人（员工）-PERSONAL,公司（往来单位）-CORP collectionScheduleItem.put("payeeAccount",payeeAccount); collectionScheduleItem.put("collectionTradingPartnerBizCode",UtilMap.getString(result,"textField_mmbmohrb"));//收款往来单位编码 collectionScheduleItem.put("amountRatio",0);//收款比例 collectionScheduleItem.put("amount",new HashMap<>(consumeAmount));//收款金额 collectionScheduleItem.put("collectionType","BANK");//支付类型 collectionSchedule.add(collectionScheduleItem); } }else { List detailList = UtilMap.getList(formData, "tableField_mkkmij61");//free-采购明细 for (Map result : detailList) { Map item = new HashMap(); Map consumeAmount = new HashMap(); consumeAmount.put("amount",String.format("%.2f", UtilMap.getDouble(result,"numberField_mkkmij6p")));//结算金额 consumeAmount.put("currency","CNY"); item.put("consumeAmount",consumeAmount); item.put("corpExpense",true);//是否对公费用，需要填写true item.put("expenseTypeBizCode","200140");//费用类型业务编码 todo 暂时写死 200140 其他费用 item.put("corpType","NO_RECEIPT");//业务场景：ALL_RECEIPTS(全部到票) NO_RECEIPT(预付未到票) RECEIPT_DEDUCTION(到票核销) RECEIPT_PAY_SOME(到票部分支付或不支付) PAY_BEFORE_RECEIPT(支付前期已到的发票) item.put("nonReceiptAmount",new HashMap<>(consumeAmount));//未到票金额（预付未到票场景必填） item.put("forecastReceiptDate",System.currentTimeMillis());//预计到票时间（预付未到票场景必填） item.put("tradingPartnerBizCode",UtilMap.getString(result,"textField_mmekbfa2"));//往来单位业务编码 Map consumeLocation = new HashMap(); consumeLocation.put("cityPair",null); consumeLocation.put("location","110001"); item.put("consumeLocation",consumeLocation); item.put("corpExpenseResponsibleEmpIds",Arrays.asList("002"));//责任人/业务经办人（预付未到票/到票部分支付或不支付 两种场景必填） todo 暂时写死 002 wzy expenseList.add(item); Map collectionScheduleItem = new HashMap(); Map payeeAccount = new HashMap(); payeeAccount.put("bankAcctName",UtilMap.getString(result,"textField_mketkvxa"));//账户名 payeeAccount.put("bankAcctNumber",UtilMap.getString(result,"textField_mketkvxc"));//银行账户 payeeAccount.put("paymentType","BANK");//账户类型;ALIPAY-支付宝,BANK-银行账户,CASH-现金 payeeAccount.put("accountType","CORP");//收款账户类型：个人（员工）-PERSONAL,公司（往来单位）-CORP collectionScheduleItem.put("payeeAccount",payeeAccount); collectionScheduleItem.put("collectionTradingPartnerBizCode",UtilMap.getString(result,"textField_mmekbfa2"));//收款往来单位编码 collectionScheduleItem.put("amountRatio",0);//收款比例 collectionScheduleItem.put("amount",new HashMap<>(consumeAmount));//收款金额 collectionScheduleItem.put("collectionType","BANK");//支付类型 collectionSchedule.add(collectionScheduleItem); } } //报销单费用导入 Map body2 = new HashMap(); body2.put("employeeId","002");//需要导入的对应员工的工号 body2.put("expenseList",expenseList); expenseCodes = MkBxUtil.receiveExpense(body2); body.put("expenseCodes",expenseCodes);//费用类型业务编码 body.put("collectionSchedule",collectionSchedule);//多人收款，如果已填充该字段，则无需填充上方的收款账户字段，若传多人收款，则paymentSceneBizCode参数必填 body.put("paymentSceneBizCode","DGYSSK");//多人收款场景（支付场景）表单业务编码，需要填写多人收款时必填 body.put("stagingFlag",false);////暂存标识，默认为false表示不暂存 Map result = MkBxUtil.receiveReimburse(body);*/ return McR.success(); } @Override public McR saveYpClient(Map map) { String formInstId = UtilMap.getString(map, "formInstId"); Map formData = ydClient.queryData(YDParam.builder() .formInstanceId(formInstId) .build(), YDConf.FORM_QUERY.retrieve_id).getFormData(); Map customerObj = new HashMap(); customerObj.put("bizCode",UtilMap.getString(formData,"serialNumberField_mkddjwy2"));//客户编码， 系统内唯一。 customerObj.put("name",UtilMap.getString(formData,"textField_mkddjwy3"));//客户名称，系统内唯一 customerObj.put("type","CORP");//客户类型: CORP (公司，默认), SELF_EMPLOYED(个体经营商) customerObj.put("nameAutoCode",false); customerObj.put("status","ENABLED");//客户状态：DISABLED("禁用" ，默认) ENABLED("启用") List contacts = new ArrayList<>(); List contactList = UtilMap.getList(formData, "tableField_mkddjwyv"); for (Map contact : contactList) { Map contactObj = new HashMap(); contactObj.put("name",UtilMap.getString(contact,"textField_mkddjwyw"));//联系人姓名 contactObj.put("phoneNumber",UtilMap.getString(contact,"textField_mkddjwyx"));//联系电话 contactObj.put("position",UtilMap.getString(contact,"textField_mkg8toy9"));//职位 contacts.add(contactObj); } customerObj.put("contacts",contacts);//联系人列表 List invoiceTitles = new ArrayList<>(); List accounts = new ArrayList<>(); List invoiceList = UtilMap.getList(formData, "tableField_mn496ozf"); for (Map invoice : invoiceList) { Map invoiceTitle = new HashMap(); invoiceTitle.put("invoiceTitle",UtilMap.getString(invoice,"textField_mkddjwyr"));//发票抬头 invoiceTitle.put("dutyParagraph",UtilMap.getString(invoice,"textField_mkddjwys"));//税号 invoiceTitle.put("bizCode",UtilMap.getString(invoice,"textField_mkddjwys"));//业务编码 invoiceTitle.put("bankBranchName",UtilMap.getString(invoice,"textField_mkddjwyt"));//开户行 invoiceTitle.put("account",UtilMap.getString(invoice,"textField_mkddjwyu"));//银行账户 invoiceTitles.add(invoiceTitle); Map account = new HashMap(); account.put("paymentType","BANK");//账户类型, account.put("bankAcctName",UtilMap.getString(invoice,"textField_mkddjwyr"));//账户名 account.put("bankAcctNumber",UtilMap.getString(invoice,"textField_mkddjwyu"));//银行对应银行卡号 account.put("bankName",UtilMap.getString(invoice,"textField_mkddjwyt"));//银行名称 accounts.add(account); } customerObj.put("invoiceTitles",invoiceTitles);//账户信息 customerObj.put("accounts",accounts);//账户信息 MkYpUtil.saveClient(Arrays.asList(customerObj)); return McR.success(); } @Async @Override public void invoiceWriteBack(Map map) { Map calloutParams = UtilMap.getMap(map, "calloutParams"); Map bizData = UtilMap.getMap(calloutParams, "bizData"); long verifyDate = UtilMap.getLong(bizData, "verifyDate");//核销日期 List upStreamItemList = UtilMap.getList(bizData, "upStreamItemList");//主核销方核销明细 Double totalVerifyAmount = UtilMap.getDouble(upStreamItemList.get(0), "totalVerifyAmount");//本次核销金额 List relatedDocuments = UtilMap.getList(bizData, "relatedDocuments"); for (Map relatedDocument : relatedDocuments) { String formType = UtilMap.getString(relatedDocument, "formType"); if ("RECEIVABLE_AR".equals(formType)){ String bizCode = UtilMap.getString(relatedDocument, "bizCode"); //应收单查询 Map body = new HashMap(); body.put("bizCodes",Arrays.asList(bizCode)); body.put("pageNum",1); body.put("pageSize",1); Map receivable = MkYpUtil.searchReceivable(body).get(0); Map invoice = ((List) UtilMap.getList(receivable, "invoiceList")).get(0); String invoiceNumber = UtilMap.getString(invoice, "invoiceNumber");//发票号码 Double receivedAmount = UtilMap.getDouble(receivable, "receivedAmount");//已收金额 List data = (List) ydClient.queryData(YDParam.builder() .formUuid("FORM-A9A47B0365DB437F8F4C8E01B4468220K7GU") .searchCondition(JSONObject.toJSONString(UtilMap.map("textField_mkxripc6",invoiceNumber))) .build(), YDConf.FORM_QUERY.retrieve_list).getData(); String formInstanceId = UtilMap.getString(data.get(0), "formInstanceId"); Map updateFormData = new HashMap(); updateFormData.put("numberField_ml8t9c4u",receivedAmount);//已收金额 updateFormData.put("dateField_mnfpbwpe",verifyDate);//核销日期 updateFormData.put("numberField_mngxcnih",totalVerifyAmount);//本次核销金额 ydClient.operateData(YDParam.builder() .formInstanceId(formInstanceId) .updateFormDataJson(JSONObject.toJSONString(updateFormData)) .build(), YDConf.FORM_OPERATION.update); return; } } } @Async @Override public void invoiceWriteBack3(Map map) { String formCode = UtilMap.getString(map, "formCode"); if (!formCode.contains("需求") && !formCode.contains("采购")){ //判断是否为核销报销单 Map formData = UtilMap.getMap(map, "formData"); Map expenseList = UtilMap.getMap(formData, "expenseList"); List expenseValueList = UtilMap.getList(expenseList, "value"); for (Map expenseValue : expenseValueList) { Map deductionList = UtilMap.getMap(expenseValue, "deductionList");//当前对公费用核销的数据（当前到票核销场景核销了哪些“预付未到票”记录） List deductionValueList = UtilMap.getList(deductionList, "value"); Map deductionValue = deductionValueList.get(0); Double deductionAmount = UtilMap.getDouble(deductionValue, "deductionAmount");//核销金额 String targetFormCode = UtilMap.getString(deductionValue, "targetFormCode");//核销报销单编号 if (targetFormCode.contains("需求") || targetFormCode.contains("采购")){ //更新宜搭核销金额 updateYdDeduction(targetFormCode,deductionAmount); } } return; } Map reimburseDetailInfo = MkBxUtil.reimburseDetailInfo(formCode); Boolean installment = UtilMap.getBoolean(reimburseDetailInfo, "installment");//是否使用分期付款 Boolean firstPeriodPayment = UtilMap.getBoolean(reimburseDetailInfo, "firstPeriodPayment");//分期情况下首期是否随本单支付 double amt = 0; if (installment){ if (firstPeriodPayment){ List collectionSchedule = UtilMap.getList(reimburseDetailInfo, "collectionSchedule"); Map collectionAmount = UtilMap.getMap(collectionSchedule.get(0), "collectionAmount"); amt = UtilMap.getDouble(collectionAmount,"amount"); }else { return; } }else { Map paymentAmount = UtilMap.getMap(reimburseDetailInfo, "paymentAmount"); amt = UtilMap.getDouble(paymentAmount, "amount");//应付金额 } long approvedAt = UtilMap.getLong(reimburseDetailInfo, "approvedAt");//审批通过时间 String[] split = formCode.split("-"); String bh = split[0];//采购需求编号/直接采购单编号 int index = Integer.parseInt(split[1]);//子表索引 Map updateFormData = new HashMap(); List updateDetailList = new ArrayList<>(); if (formCode.contains("需求")){ //采购需求&结算 List data = (List) ydClient.queryData(YDParam.builder() .formUuid("FORM-C8C1FBBA781C4C5EBAC487C07BC5A86AD2HO") .searchCondition(JSONObject.toJSONString(UtilMap.map("serialNumberField_mkkmij3o", bh))) .build(), YDConf.FORM_QUERY.retrieve_list_all).getData(); String formInstanceId = UtilMap.getString(data.get(0), "formInstanceId"); Map ydFormData = UtilMap.getMap(data.get(0), "formData"); String type = UtilMap.getString(ydFormData, "radioField_mkkmij3b"); if ("常规需求".equals(type)){ List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij56"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxx")){ Double jscb = UtilMap.getDouble(detail, "numberField_mkkmij5e");//结算成本 Double yfkje = UtilMap.getDouble(detail, "numberField_mmvqom6l");//已付款金额 String fkzt = UtilMap.getString(detail, "selectField_mmvhqm0p");//付款状态 if (yfkje + amt == jscb){ detailMap.put("selectField_mmvhqm0p","全部付款"); }else if (yfkje + amt < jscb && yfkje + amt > 0 && !"部分退款".equals(fkzt)){ detailMap.put("selectField_mmvhqm0p","部分付款"); } detailMap.put("numberField_mmvqom6l",yfkje + amt); detailMap.put("dateField_mnh6e4zy",approvedAt); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij56",updateDetailList); }else { List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij61"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxz")){ Double jscb = UtilMap.getDouble(detail, "numberField_mkkmij6p");//结算成本 Double yfkje = UtilMap.getDouble(detail, "numberField_mmvqs9h6");//已付款金额 String fkzt = UtilMap.getString(detail, "selectField_mkkmij6a");//付款状态 if (yfkje + amt == jscb){ detailMap.put("selectField_mkkmij6a","全部付款"); }else if (yfkje + amt < jscb && yfkje + amt > 0 && !"部分退款".equals(fkzt)){ detailMap.put("selectField_mkkmij6a","部分付款"); } detailMap.put("numberField_mmvqs9h6",yfkje + amt); detailMap.put("dateField_mnh6e4zw",approvedAt); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij61",updateDetailList); } Double yzf = UtilMap.getDouble(ydFormData, "numberField_mkf2qumf");//已支付 updateFormData.put("numberField_mkf2qumf",yzf + amt);//已支付 updateFormData.put("numberField_mnibjld0",amt);//最新支付金额 ydClient.operateData(YDParam.builder() .formInstanceId(formInstanceId) .updateFormDataJson(JSONObject.toJSONString(updateFormData)) .useLatestVersion(true) .build(), YDConf.FORM_OPERATION.update); }else { //直接采购结算单 List data = (List) ydClient.queryData(YDParam.builder() .formUuid("FORM-1AFEDDA034C74F0DB18FA60C941CB56EHUUG") .searchCondition(JSONObject.toJSONString(UtilMap.map("serialNumberField_mkkmij3o", bh))) .build(), YDConf.FORM_QUERY.retrieve_list_all).getData(); String formInstanceId = UtilMap.getString(data.get(0), "formInstanceId"); Map ydFormData = UtilMap.getMap(data.get(0), "formData"); String type = UtilMap.getString(ydFormData, "radioField_mkkmij3b"); if ("常规采购".equals(type)){ List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij56"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxx")){ Double jscb = UtilMap.getDouble(detail, "numberField_mkkmij5e");//结算成本 Double yfkje = UtilMap.getDouble(detail, "numberField_mmvqom6k");//已付款金额 String fkzt = UtilMap.getString(detail, "selectField_mmvhtdy0");//付款状态 if (yfkje + amt == jscb){ detailMap.put("selectField_mmvhtdy0","全部付款"); }else if (yfkje + amt < jscb && yfkje + amt > 0 && !"部分退款".equals(fkzt)){ detailMap.put("selectField_mmvhtdy0","部分付款"); } detailMap.put("numberField_mmvqom6k",yfkje + amt); detailMap.put("dateField_mnh6e4zy",approvedAt); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij56",updateDetailList); }else { List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij61"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxz")){ Double jscb = UtilMap.getDouble(detail, "numberField_mkkmij6p");//结算成本 Double yfkje = UtilMap.getDouble(detail, "numberField_mmvqom6l");//已付款金额 String fkzt = UtilMap.getString(detail, "selectField_mkkmij6a");//付款状态 if (yfkje + amt == jscb){ detailMap.put("selectField_mkkmij6a","全部付款"); }else if (yfkje + amt < jscb && yfkje + amt > 0 && !"部分退款".equals(fkzt)){ detailMap.put("selectField_mkkmij6a","部分付款"); } detailMap.put("numberField_mmvqom6l",yfkje + amt); detailMap.put("dateField_mnh6e4zw",approvedAt); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij61",updateDetailList); } Double yzf = UtilMap.getDouble(ydFormData, "numberField_mkf2qumf");//已支付 updateFormData.put("numberField_mkf2qumf",yzf + amt);//已支付 updateFormData.put("numberField_mnibjld0",amt);//最新支付金额 ydClient.operateData(YDParam.builder() .formInstanceId(formInstanceId) .updateFormDataJson(JSONObject.toJSONString(updateFormData)) .useLatestVersion(true) .build(), YDConf.FORM_OPERATION.update); } } //更新宜搭采购已核销金额 private void updateYdDeduction(String formCode, Double deductionAmount) { String[] split = formCode.split("-"); String bh = split[0]; int index = Integer.parseInt(split[1]); Map updateFormData = new HashMap(); List updateDetailList = new ArrayList<>(); if (formCode.contains("需求")){ //采购需求&结算 List data = (List) ydClient.queryData(YDParam.builder() .formUuid("FORM-C8C1FBBA781C4C5EBAC487C07BC5A86AD2HO") .searchCondition(JSONObject.toJSONString(UtilMap.map("serialNumberField_mkkmij3o", bh))) .build(), YDConf.FORM_QUERY.retrieve_list_all).getData(); String formInstanceId = UtilMap.getString(data.get(0), "formInstanceId"); Map ydFormData = UtilMap.getMap(data.get(0), "formData"); String type = UtilMap.getString(ydFormData, "radioField_mkkmij3b"); if ("常规需求".equals(type)){ List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij56"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxx")){ Double yhxje = UtilMap.getDouble(detail, "numberField_mniatky8");//已核销金额 detailMap.put("numberField_mniatky8",yhxje + deductionAmount); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij56",updateDetailList); }else { List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij61"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxz")){ Double yhxje = UtilMap.getDouble(detail, "numberField_mniatkya");//已核销金额 detailMap.put("numberField_mniatkya",yhxje + deductionAmount); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij61",updateDetailList); } ydClient.operateData(YDParam.builder() .formInstanceId(formInstanceId) .updateFormDataJson(JSONObject.toJSONString(updateFormData)) .useLatestVersion(true) .build(), YDConf.FORM_OPERATION.update); }else { //直接采购结算单 List data = (List) ydClient.queryData(YDParam.builder() .formUuid("FORM-1AFEDDA034C74F0DB18FA60C941CB56EHUUG") .searchCondition(JSONObject.toJSONString(UtilMap.map("serialNumberField_mkkmij3o", bh))) .build(), YDConf.FORM_QUERY.retrieve_list_all).getData(); String formInstanceId = UtilMap.getString(data.get(0), "formInstanceId"); Map ydFormData = UtilMap.getMap(data.get(0), "formData"); String type = UtilMap.getString(ydFormData, "radioField_mkkmij3b"); if ("常规采购".equals(type)){ List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij56"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxx")){ Double yhxje = UtilMap.getDouble(detail, "numberField_mniatky8");//已核销金额 detailMap.put("numberField_mniatky8",yhxje + deductionAmount); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij56",updateDetailList); }else { List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij61"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxz")){ Double yhxje = UtilMap.getDouble(detail, "numberField_mniatkya");//已核销金额 detailMap.put("numberField_mniatkya",yhxje + deductionAmount); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij61",updateDetailList); } ydClient.operateData(YDParam.builder() .formInstanceId(formInstanceId) .updateFormDataJson(JSONObject.toJSONString(updateFormData)) .useLatestVersion(true) .build(), YDConf.FORM_OPERATION.update); } } @Override public McR saveBxReimbursement2(Map map) { String formInstId = UtilMap.getString(map, "formInstId"); Map formData = ydClient.queryData(YDParam.builder() .formInstanceId(formInstId) .build(), YDConf.FORM_QUERY.retrieve_id).getFormData(); String type = UtilMap.getString(formData, "radioField_mkkmij3b");//需求单类型 String formSubTypeBizCode = "FT208629766551519240";//项目支付单 Double amt = UtilMap.getDouble(formData, "numberField_mkkmij6i"); String empId = ""; String deptBusinessCode = ""; String ydfqr = UtilMap.getString(formData, "textField_mmwvodde");//宜搭发起人工号 String ztcggh = UtilMap.getString(formData, "textField_mmwvfb97");//中台采购工号 String legalEntityBizCode = UtilMap.getString(formData, "textField_mmd6hio7");//公司抬头编码 String xqbh = UtilMap.getString(formData, "serialNumberField_mkkmij3o");//需求编号 long ldjssj = UtilMap.getLong(formData, "dateField_mkdf8q8q");//落地结束时间 String isFree = "FREE采购".equals(UtilMap.getString(formData, "radioField_mkf2quln")) ? "是" : "否";//是否free String isDdf = "是".equals(UtilMap.getString(formData, "radioField_mkf2qulo")) ? "1" : "2";//是否代垫付 String xmsssyb = UtilMap.getString(formData, "selectField_mkdedkv7");//项目所属事业部 String projectCode = UtilMap.getString(formData, "textField_mmoh6nvx");//项目编码 //针对多供应商分期付款拆分多条每刻项目支付单 if ("常规采购".equals(type)){ List detailList = UtilMap.getList(formData, "tableField_mkkmij56");//常规-采购明细 int index = 0; for (Map detail : detailList) { index++; String uuid = UtilMap.getString(detail, "textField_mmvhqm0q");//子表uuid Map body = new HashMap(); body.put("formCode",xqbh + "-" + index);//有值时会使用该值作为单据号 body.put("formSubTypeBizCode",formSubTypeBizCode);//表单类型的业务编号 String mktdr = UtilMap.getString(detail, "selectField_mo9z9dva");//每刻提单人 body.put("submittedUserEmployeeId",mktdr);//提单人工号 body.put("coverUserEmployeeId",mktdr);//承担人工号 // body.put("",ydfqr.equals(mktdr) ? ztcggh : mktdr);//todo 抄送人工号 若每刻提单人为宜搭发起人，抄送人则为中台采购 若每刻提单人为中台采购，抄送人则为宜搭发起人 //查询每刻提单人部门 Map employeeDetails = MkBxUtil.employeeDetails(UtilMap.map("employeeIds", Arrays.asList(mktdr))); String coverDepartmentBizCode = mkbx_deptId; if (Objects.nonNull(employeeDetails)){ List departments = UtilMap.getList(employeeDetails, "departments"); coverDepartmentBizCode = UtilMap.getString(departments.get(0), "businessCode"); } body.put("coverDepartmentBizCode",coverDepartmentBizCode);//承担部门编码 body.put("legalEntityBizCode",legalEntityBizCode);//公司抬头编码 body.put("reimburseName",UtilMap.getString(detail,"textareaField_mkkmij5i"));//报销事由 body.put("tradingPartnerBizCode",UtilMap.getString(detail,"textField_mmbmohrb"));//往来单位编码 Map customObject = new HashMap(); customObject.put("CF4",new HashMap(){{put("currentTime",ldjssj);}});//落地结束时间 customObject.put("CF3",new HashMap(){{put("currentTime",UtilMap.getLong(detail,"dateField_mkkkw298"));}});//期望支付日期 customObject.put("CF6",isFree);//free 是；否 customObject.put("CF5",isDdf);//代垫付 是：1 ； 否：2 customObject.put("CF2",xmsssyb);//项目所属事业部 customObject.put("CF1",projectCode);//项目 customObject.put("CF7",UtilMap.getString(detail,"numberField_mmwswtkv"));//逾期天数 body.put("customObject",customObject); //报销单费用导入 Map expenseListItem = new HashMap(); Map consumeAmount = new HashMap(); consumeAmount.put("amount",String.format("%.2f", UtilMap.getDouble(detail,"numberField_mkkmij5e")));//结算金额 consumeAmount.put("currency","CNY"); expenseListItem.put("consumeAmount",consumeAmount); expenseListItem.put("corpExpense",true);//是否对公费用，需要填写true String gysej = UtilMap.getString(detail, "selectField_mkkkw28y");//供应商二级 expenseListItem.put("expenseTypeBizCode",MkBxUtil.expenseTypeSearch(UtilMap.map("keyword",gysej)));//费用类型业务编码 expenseListItem.put("corpType","NO_RECEIPT");//业务场景：ALL_RECEIPTS(全部到票) NO_RECEIPT(预付未到票) RECEIPT_DEDUCTION(到票核销) RECEIPT_PAY_SOME(到票部分支付或不支付) PAY_BEFORE_RECEIPT(支付前期已到的发票) expenseListItem.put("nonReceiptAmount",new HashMap<>(consumeAmount));//未到票金额（预付未到票场景必填） expenseListItem.put("forecastReceiptDate",System.currentTimeMillis());//预计到票时间（预付未到票场景必填） expenseListItem.put("tradingPartnerBizCode",UtilMap.getString(detail,"textField_mmbmohrb"));//往来单位业务编码 Map consumeLocation = new HashMap(); consumeLocation.put("cityPair",null); consumeLocation.put("location","110001");//todo 暂时写死 110001 北京 expenseListItem.put("consumeLocation",consumeLocation); expenseListItem.put("corpExpenseResponsibleEmpIds",Arrays.asList("002"));//责任人/业务经办人（预付未到票/到票部分支付或不支付 两种场景必填） todo 暂时写死 002 wzy Map body2 = new HashMap(); body2.put("employeeId","002");//需要导入的对应员工的工号 body2.put("expenseList",Arrays.asList(expenseListItem)); List expenseCodes = MkBxUtil.receiveExpense(body2); body.put("expenseCodes",expenseCodes);//费用类型业务编码 //收款账户 Map payeeAccount = new HashMap(); payeeAccount.put("bankAcctName",UtilMap.getString(detail,"textField_mkkmij6z"));//账户名 payeeAccount.put("bankAcctNumber",UtilMap.getString(detail,"textField_mkkmij6y"));//银行账户 payeeAccount.put("paymentType","BANK");//账户类型;ALIPAY-支付宝,BANK-银行账户,CASH-现金 payeeAccount.put("accountType","CORP");//收款账户类型：个人（员工）-PERSONAL,公司（往来单位）-CORP body.put("payeeAccount",payeeAccount); body.put("stagingFlag",true);//暂存标识，默认为false表示不暂存 Map result = MkBxUtil.receiveReimburse(body); } }else { List detailList = UtilMap.getList(formData, "tableField_mkkmij61");//free-采购明细 int index = 0; for (Map detail : detailList) { index ++; String uuid = UtilMap.getString(detail, "textField_mmvhqm0s");//子表uuid Map body = new HashMap(); body.put("formCode",xqbh + "-" +index);//有值时会使用该值作为单据号 body.put("formSubTypeBizCode",formSubTypeBizCode);//表单类型的业务编号 String mktdr = UtilMap.getString(detail, "selectField_mo9z9dvc");//每刻提单人 body.put("submittedUserEmployeeId",mktdr);//提单人工号 body.put("coverUserEmployeeId",mktdr);//承担人工号 // body.put("",ydfqr.equals(mktdr) ? ztcggh : mktdr);//todo 抄送人工号 若每刻提单人为宜搭发起人，抄送人则为中台采购 若每刻提单人为中台采购，抄送人则为宜搭发起人 //查询每刻提单人部门 Map employeeDetails = MkBxUtil.employeeDetails(UtilMap.map("employeeIds", Arrays.asList(mktdr))); String coverDepartmentBizCode = mkbx_deptId; if (Objects.nonNull(employeeDetails)){ List departments = UtilMap.getList(employeeDetails, "departments"); coverDepartmentBizCode = UtilMap.getString(departments.get(0), "businessCode"); } body.put("coverDepartmentBizCode",coverDepartmentBizCode);//承担部门编码 body.put("reimburseName","FREE-" + UtilMap.getString(detail,"selectField_mkkixdd7"));//报销事由 body.put("legalEntityBizCode",legalEntityBizCode);//公司抬头编码 body.put("tradingPartnerBizCode",UtilMap.getString(detail,"textField_mmekbfa2"));//往来单位编码 Map customObject = new HashMap(); customObject.put("CF4",new HashMap(){{put("currentTime",ldjssj);}});//落地结束时间 customObject.put("CF3",new HashMap(){{put("currentTime",UtilMap.getLong(detail,"dateField_mmvhtdy4"));}});//期望支付日期 customObject.put("CF6",isFree);//free 是；否 customObject.put("CF5",isDdf);//代垫付 是：1 ； 否：2 customObject.put("CF2",xmsssyb);//项目所属事业部 customObject.put("CF1",projectCode);//项目 customObject.put("CF7",UtilMap.getString(detail,"numberField_mmwswtkx"));//逾期天数 body.put("customObject",customObject); //报销单费用导入 Map expenseListItem = new HashMap(); Map consumeAmount = new HashMap(); consumeAmount.put("amount",String.format("%.2f", UtilMap.getDouble(detail,"numberField_mkkmij6p")));//结算金额 consumeAmount.put("currency","CNY"); expenseListItem.put("consumeAmount",consumeAmount); expenseListItem.put("corpExpense",true);//是否对公费用，需要填写true String gysej = UtilMap.getString(detail, "selectField_mmwuzaql");//供应商二级 expenseListItem.put("expenseTypeBizCode",MkBxUtil.expenseTypeSearch(UtilMap.map("keyword",gysej)));//费用类型业务编码 expenseListItem.put("corpType","NO_RECEIPT");//业务场景：ALL_RECEIPTS(全部到票) NO_RECEIPT(预付未到票) RECEIPT_DEDUCTION(到票核销) RECEIPT_PAY_SOME(到票部分支付或不支付) PAY_BEFORE_RECEIPT(支付前期已到的发票) expenseListItem.put("nonReceiptAmount",new HashMap<>(consumeAmount));//未到票金额（预付未到票场景必填） expenseListItem.put("forecastReceiptDate",System.currentTimeMillis());//预计到票时间（预付未到票场景必填） expenseListItem.put("tradingPartnerBizCode",UtilMap.getString(detail,"textField_mmekbfa2"));//往来单位业务编码 Map consumeLocation = new HashMap(); consumeLocation.put("cityPair",null); consumeLocation.put("location","110001");//todo 暂时写死 110001 北京 expenseListItem.put("consumeLocation",consumeLocation); expenseListItem.put("corpExpenseResponsibleEmpIds",Arrays.asList("002"));//责任人/业务经办人（预付未到票/到票部分支付或不支付 两种场景必填） todo 暂时写死 002 wzy Map body2 = new HashMap(); body2.put("employeeId","002");//需要导入的对应员工的工号 body2.put("expenseList",Arrays.asList(expenseListItem)); List expenseCodes = MkBxUtil.receiveExpense(body2); body.put("expenseCodes",expenseCodes);//费用类型业务编码 //收款账户 Map payeeAccount = new HashMap(); payeeAccount.put("bankAcctName",UtilMap.getString(detail,"textField_mketkvxa"));//账户名 payeeAccount.put("bankAcctNumber",UtilMap.getString(detail,"textField_mketkvxc"));//银行账户 payeeAccount.put("paymentType","BANK");//账户类型;ALIPAY-支付宝,BANK-银行账户,CASH-现金 payeeAccount.put("accountType","CORP");//收款账户类型：个人（员工）-PERSONAL,公司（往来单位）-CORP body.put("payeeAccount",payeeAccount); body.put("stagingFlag",true);//暂存标识，默认为false表示不暂存 Map result = MkBxUtil.receiveReimburse(body); } } return McR.success(); } @Override public McR checkBudgetAmt(Map map) { String projectCode = UtilMap.getString(map, "projectCode"); long ldqssj = UtilMap.getLong(map, "ldqssj");//落地起始时间 //落地起始时间在几月份 Calendar calendar = Calendar.getInstance(); calendar.setTimeInMillis(ldqssj); int month = calendar.get(Calendar.MONTH) + 1; List list = UtilMap.getList(map, "list"); List subjectCodeList = new ArrayList<>(); Map cgmxMap = new HashMap(); for (Map map1 : list) { Double jscb = UtilMap.getDouble(map1, "numberField_mkkmij5e");//结算成本 String subjectCode = UtilMap.getString(map1, "textField_mn8nhpnz");//预算科目编号 subjectCodeList.add(subjectCode); if (cgmxMap.containsKey(subjectCode)){ cgmxMap.put(subjectCode,UtilMap.getDouble(cgmxMap,subjectCode) + jscb); }else { cgmxMap.put(subjectCode,jscb); } } Map body = new HashMap(); body.put("budgetPlanBizCode","全面预算");//预算方案编码 body.put("budgetOrgBizCodes",Arrays.asList(projectCode));//预算组织编码 body.put("budgetSubjectBizCodes",subjectCodeList);//预算科目编码 body.put("pageNum",1); body.put("pageSize",50); List budgetList = MkBxUtil.budgetInfo(body); boolean flag = true; StringBuilder errorMsg = new StringBuilder(); for (Map budget : budgetList) { String subjectCode = UtilMap.getString(budget, "subjectBizCode"); String subjectName = UtilMap.getString(budget, "subjectName"); List budgetUnits = UtilMap.getList(budget, "budgetUnits"); for (Map budgetUnit : budgetUnits) { int periodNum = UtilMap.getInt(budgetUnit, "periodNum"); if (periodNum == month) { Double usableAmount = UtilMap.getDouble(budgetUnit, "usableAmount"); Double jscb = cgmxMap.get(subjectCode); if (jscb > usableAmount) { flag = false; errorMsg.append("[").append(subjectName).append("]预算金额不足，剩余可用预算金额[").append(usableAmount).append("];"); } break; } } } Map result = new HashMap(); result.put("flag",flag); result.put("errorMsg", errorMsg.toString()); return McR.success(result); } @Override public void updateBudget(Map map) { String formInstId = UtilMap.getString(map, "formInstId"); String type = UtilMap.getString(map, "type"); Map formData = ydClient.queryData(YDParam.builder() .formInstanceId(formInstId).build(), YDConf.FORM_QUERY.retrieve_id).getFormData(); String projectCode = UtilMap.getString(formData, "textField_mmoh6nvx"); long ldqssj = UtilMap.getLong(formData, "dateField_mkdf8q8p"); //落地起始时间在几月份 Calendar calendar = Calendar.getInstance(); calendar.setTimeInMillis(ldqssj); int month = calendar.get(Calendar.MONTH) + 1; Map body = new HashMap(); body.put("budgetPlanBizCode","全面预算"); body.put("increment",false); body.put("onlyError",false); List budgets = new ArrayList<>(); if ("冻结".equals(type)){ Map budget = new HashMap(); budget.put("budgetOrgBizCode",projectCode); // budget.put("budgetSubjectBizCode",""); Map budgetUnit = new HashMap(); budgetUnit.put("periodNum",month); budgetUnit.put("budgetAmount",0);//置零 相当于冻结 budget.put("budgetUnits",Arrays.asList(budgetUnit)); budgets.add(budget); }else {//释放 Map budget = new HashMap(); budget.put("budgetOrgBizCode",projectCode); // budget.put("budgetSubjectBizCode",""); Double amt = UtilMap.getDouble(formData, "numberField_mkga10nj"); Map budgetUnit = new HashMap(); budgetUnit.put("periodNum",month); budgetUnit.put("budgetAmount",amt); budget.put("budgetUnits",Arrays.asList(budgetUnit)); budgets.add(budget); } body.put("budgets",budgets); MkBxUtil.batchBudget(body); } @Async @Override public void invoiceWriteBack4(Map map) { String formCode = UtilMap.getString(map, "formCode");//付款单编号 //查询付款单详情 Map paymentDetailInfo = MkBxUtil.paymentDetailInfo(formCode); String reimburseFormSubTypeBizCode = UtilMap.getString(paymentDetailInfo, "reimburseFormSubTypeBizCode");//关联的报销单的单据小类编码 //项目支付单（对公） if ("FT208629766551519240".equals(reimburseFormSubTypeBizCode)){ String reimburseCode = UtilMap.getString(paymentDetailInfo, "reimburseCode"); //宜搭推送的项目支付单编号 格式：流水号-index if (reimburseCode.contains("采购") || reimburseCode.contains("需求")){ String[] split = reimburseCode.split("-"); String ydFormCode = split[0]; int index = Integer.parseInt(split[1]); Map approvedAmount = UtilMap.getMap(paymentDetailInfo, "approvedAmount"); Double amt = UtilMap.getDouble(approvedAmount, "amount");//审批通过金额 long settledAt = UtilMap.getLong(paymentDetailInfo, "settledAt");//支付时间 Map updateFormData = new HashMap(); List updateDetailList = new ArrayList<>(); if (reimburseCode.contains("需求")){ //采购需求&结算 List data = (List) ydClient.queryData(YDParam.builder() .formUuid("FORM-C8C1FBBA781C4C5EBAC487C07BC5A86AD2HO") .searchCondition(JSONObject.toJSONString(UtilMap.map("serialNumberField_mkkmij3o", ydFormCode))) .build(), YDConf.FORM_QUERY.retrieve_list_all).getData(); String formInstanceId = UtilMap.getString(data.get(0), "formInstanceId"); Map ydFormData = UtilMap.getMap(data.get(0), "formData"); String type = UtilMap.getString(ydFormData, "radioField_mkkmij3b"); if ("常规需求".equals(type)){ List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij56"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxx")){ Double jscb = UtilMap.getDouble(detail, "numberField_mkkmij5e");//结算成本 Double yfkje = UtilMap.getDouble(detail, "numberField_mmvqom6l");//已付款金额 String fkzt = UtilMap.getString(detail, "selectField_mmvhqm0p");//付款状态 if (yfkje + amt == jscb){ detailMap.put("selectField_mmvhqm0p","全部付款"); }else if (yfkje + amt < jscb && yfkje + amt > 0 && !"部分退款".equals(fkzt)){ detailMap.put("selectField_mmvhqm0p","部分付款"); } detailMap.put("numberField_mmvqom6l",yfkje + amt); detailMap.put("dateField_mnh6e4zy",settledAt); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij56",updateDetailList); }else { List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij61"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxz")){ Double jscb = UtilMap.getDouble(detail, "numberField_mkkmij6p");//结算成本 Double yfkje = UtilMap.getDouble(detail, "numberField_mmvqs9h6");//已付款金额 String fkzt = UtilMap.getString(detail, "selectField_mkkmij6a");//付款状态 if (yfkje + amt == jscb){ detail.put("selectField_mkkmij6a","全部付款"); }else if (yfkje + amt < jscb && yfkje + amt > 0 && !"部分退款".equals(fkzt)){ detailMap.put("selectField_mkkmij6a","部分付款"); } detailMap.put("numberField_mmvqs9h6",yfkje + amt); detailMap.put("dateField_mnh6e4zy",settledAt); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij61",updateDetailList); } Double yzf = UtilMap.getDouble(ydFormData, "numberField_mkf2qumf");//已支付 updateFormData.put("numberField_mkf2qumf",yzf + amt);//已支付 updateFormData.put("numberField_mnibjld0",amt);//最新支付金额 ydClient.operateData(YDParam.builder() .formInstanceId(formInstanceId) .updateFormDataJson(JSONObject.toJSONString(updateFormData)) .build(), YDConf.FORM_OPERATION.update); }else { //直接采购结算单 List data = (List) ydClient.queryData(YDParam.builder() .formUuid("FORM-1AFEDDA034C74F0DB18FA60C941CB56EHUUG") .searchCondition(JSONObject.toJSONString(UtilMap.map("serialNumberField_mkkmij3o", ydFormCode))) .build(), YDConf.FORM_QUERY.retrieve_list_all).getData(); String formInstanceId = UtilMap.getString(data.get(0), "formInstanceId"); Map ydFormData = UtilMap.getMap(data.get(0), "formData"); String type = UtilMap.getString(ydFormData, "radioField_mkkmij3b"); if ("常规采购".equals(type)){ List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij56"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxx")){ Double jscb = UtilMap.getDouble(detail, "numberField_mkkmij5e");//结算成本 Double yfkje = UtilMap.getDouble(detail, "numberField_mmvqom6k");//已付款金额 String fkzt = UtilMap.getString(detail, "selectField_mmvhtdy0");//付款状态 if (yfkje + amt == jscb){ detailMap.put("selectField_mmvhtdy0","全部付款"); }else if (yfkje + amt < jscb && yfkje + amt > 0 && !"部分退款".equals(fkzt)){ detailMap.put("selectField_mmvhtdy0","部分付款"); } detailMap.put("numberField_mmvqom6k",yfkje + amt); detailMap.put("dateField_mnh6e4zy",settledAt); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij56",updateDetailList); }else { List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij61"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxz")){ Double jscb = UtilMap.getDouble(detail, "numberField_mkkmij6p");//结算成本 Double yfkje = UtilMap.getDouble(detail, "numberField_mmvqom6l");//已付款金额 String fkzt = UtilMap.getString(detail, "selectField_mkkmij6a");//付款状态 if (yfkje + amt == jscb){ detailMap.put("selectField_mkkmij6a","全部付款"); }else if (yfkje + amt < jscb && yfkje + amt > 0 && !"部分退款".equals(fkzt)){ detailMap.put("selectField_mkkmij6a","部分付款"); } detailMap.put("numberField_mmvqom6l",yfkje + amt); detailMap.put("dateField_mnh6e4zy",settledAt); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij61",updateDetailList); } Double yzf = UtilMap.getDouble(ydFormData, "numberField_mkf2qumf");//已支付 updateFormData.put("numberField_mkf2qumf",yzf + amt);//已支付 updateFormData.put("numberField_mnibjld0",amt);//最新支付金额 ydClient.operateData(YDParam.builder() .formInstanceId(formInstanceId) .updateFormDataJson(JSONObject.toJSONString(updateFormData)) .build(), YDConf.FORM_OPERATION.update); } } } } @Async @Override public void invoiceWriteBack5(Map map) { //防止查询不到单据详情 try { Thread.sleep(3000); } catch (InterruptedException e) { throw new RuntimeException(e); } String formCode = UtilMap.getString(map, "formCode"); Map repayDetailInfo = MkBxUtil.repayDetailInfo(formCode); Map repayAmount = UtilMap.getMap(repayDetailInfo, "repayAmount"); Double amount = UtilMap.getDouble(repayAmount, "amount");//还款金额 List returnDeductions = UtilMap.getList(repayDetailInfo, "returnDeductions"); for (Map returnDeduction : returnDeductions) { String recordFormCode = UtilMap.getString(returnDeduction, "recordFormCode"); if (recordFormCode.contains("采购") || recordFormCode.contains("需求")){ updateYdRepay(recordFormCode,amount); } } } @Override public void invoiceWriteBack6(Map map) { String formCode = UtilMap.getString(map, "formCode");//单据号 Map formData = UtilMap.getMap(map, "formData"); String formSubTypeBizCode = getMkStrValue(formData, "formSubTypeBizCode");//单据类型业务编码 Map ydFormData = new HashMap(); switch (formSubTypeBizCode){ case "FT210319434976347227"://押金/保证金支付单 String isProject = getMkStrValue(formData, "CF32");//是否项目相关 if (!"是".equals(isProject)) return; String loanName = getMkStrValue(formData, "loanName");//事由 double payableAmount = Double.parseDouble(getMkStrValue(formData, "payableAmount"));//借款金额 String legalEntity = getMkStrValue(formData, "legalEntity");//所属公司 Map loanUser = getMkListValue(formData, "loanUser").get(0);//借款人 String employeeName = UtilMap.getString(loanUser, "text");//借款人姓名 List loanDdUser = getDdUserId(employeeName); Map cf0 = getMkMapValue(formData, "CF0"); String projectCode = UtilMap.getString(cf0, "businessCode");//项目流水号 String projectName = UtilMap.getString(cf0, "text");//项目名称 Long expectRepayDate = getMkDateValue(formData, "expectRepayDate");//预计归还时间 String loanDepartment = getMkStrValue(formData, "loanDepartment");//借款部门 Map payeeAccount = getMkMapValue(formData, "payeeAccount"); String bankAcctNumber = UtilMap.getString(payeeAccount, "bankAcctNumber");//收款账户 ydFormData.put("textField_mnsm4ozj",legalEntity); ydFormData.put("textField_mnsm4p09",projectName); ydFormData.put("textField_mnsm4ozk",formCode); ydFormData.put("textareaField_mnsm4ozp",loanName); ydFormData.put("employeeField_mnsm4ozu",loanDdUser); ydFormData.put("textField_mnsm4ozv",loanDepartment); ydFormData.put("numberField_mnsm4p00",payableAmount); ydFormData.put("dateField_mnsm4p01",expectRepayDate); ydFormData.put("textField_mnsm4p07",bankAcctNumber); ydFormData.put("textField_mnwtck7h","押金/保证金支付单"); ydFormData.put("textField_mnwtwu9z",projectCode); break; case "FT203800208910336098"://借款单（项目） String loanName2 = getMkStrValue(formData, "loanName");//事由 double payableAmount2 = Double.parseDouble(getMkStrValue(formData, "payableAmount"));//借款金额 String legalEntity2 = getMkStrValue(formData, "legalEntity");//所属公司 Map loanUser2 = getMkListValue(formData, "loanUser").get(0);//借款人 String employeeName2 = UtilMap.getString(loanUser2, "text");//借款人姓名 List loanDdUser2 = getDdUserId(employeeName2); Map cf0_2 = getMkMapValue(formData, "CF0"); String projectCode2 = UtilMap.getString(cf0_2, "businessCode");//项目流水号 String projectName2 = UtilMap.getString(cf0_2, "text");//项目名称 Long expectRepayDate2 = getMkDateValue(formData, "expectRepayDate");//预计归还时间 String loanDepartment2 = getMkStrValue(formData, "loanDepartment");//借款部门 Map payeeAccount2 = getMkMapValue(formData, "payeeAccount"); String bankAcctNumber2 = UtilMap.getString(payeeAccount2, "bankAcctNumber");//收款账户 String comments = getMkStrValue(formData, "comments");//备用金用途 ydFormData.put("textField_mnsm4ozj",legalEntity2); ydFormData.put("textField_mnsm4p09",projectName2); ydFormData.put("textField_mnsm4ozk",formCode); ydFormData.put("textareaField_mnsm4ozp",loanName2); ydFormData.put("employeeField_mnsm4ozu",loanDdUser2); ydFormData.put("textField_mnsm4ozv",loanDepartment2); ydFormData.put("numberField_mnsm4p00",payableAmount2); ydFormData.put("dateField_mnsm4p01",expectRepayDate2); ydFormData.put("textField_mnsm4p07",bankAcctNumber2); ydFormData.put("textField_mnwtck7h","借款单（项目）"); ydFormData.put("textField_mnwtwu9z",projectCode2); ydFormData.put("textareaField_mnsm4p0c",comments); break; default: return; } ydClient.operateData(YDParam.builder() .formUuid("FORM-204D3E39C2EB49FEA4121D73E8A71F796A2U") .formDataJson(JSONObject.toJSONString(ydFormData)) .build(), YDConf.FORM_OPERATION.create); } @Override public void invoiceWriteBack7(Map map) { String formDataCode = UtilMap.getString(map, "formDataCode");//单据类型 String formCode = UtilMap.getString(map, "formCode");//单据号 Map formData = UtilMap.getMap(map, "formData"); String repaymentName = getMkStrValue(formData, "repaymentName");//事由 double repayAmount = Double.parseDouble(getMkStrValue(formData, "repayAmount"));//还款金额 String legalEntity = getMkStrValue(formData, "legalEntity");//所属公司 Map repayUser = getMkListValue(formData, "repayUser").get(0);//责任人 String employeeName = UtilMap.getString(repayUser, "text");//责任人姓名 List repayDdUser = getDdUserId(employeeName); // Long repaymentDate = getMkDateValue(formData, "repaymentDate");//还款日期 String repayDept = getMkStrValue(formData, "repayDept");//责任人部门 String comments = getMkStrValue(formData, "comments");//备注 List loanDeductionList = getMkListValue(formData, "loanDeductionList");//核销借款 List ydLoanDeductionList = new ArrayList<>(); for (Map loanDeduction : loanDeductionList) { Map ydLoanDeduction = new HashMap(); Double deductionAmount = UtilMap.getDouble(loanDeduction, "deductionAmount");//核销金额 String loanFormCode = UtilMap.getString(loanDeduction, "loanFormCode");//借款单单据号 //借款单详情 Map loanDetailInfo = MkBxUtil.loanDetailInfo(loanFormCode); Map customObject = UtilMap.getMap(loanDetailInfo, "customObject"); Map cf0 = UtilMap.getMap(customObject, "CF0"); String projectCode = UtilMap.getString(cf0, "detailBusinessCode");//项目流水号 String projectName = UtilMap.getString(cf0, "text");//项目名称 String loanName = UtilMap.getString(loanDetailInfo, "loanName");//事由 ydLoanDeduction.put("textField_mnsmfo6t",loanName); ydLoanDeduction.put("textField_mnxzo8la",loanFormCode); ydLoanDeduction.put("textField_mnwlnnmz",projectName); ydLoanDeduction.put("textField_mnwtwu9z",projectCode); ydLoanDeduction.put("numberField_mnxzo8l8",deductionAmount); ydLoanDeductionList.add(ydLoanDeduction); } Map ydFormData = new HashMap(); ydFormData.put("textField_mnsmfo6f",legalEntity); ydFormData.put("textField_mnxzo8l5",formCode); ydFormData.put("textareaField_mnsmfo6k",repaymentName); ydFormData.put("employeeField_mnsmfo6l",repayDdUser); ydFormData.put("textField_mnsmfo6m",repayDept); ydFormData.put("numberField_mnsmfo6s",repayAmount); ydFormData.put("textareaField_mnsmfo70",comments); ydFormData.put("textField_mnwtck7h","还款/退款单"); ydFormData.put("tableField_mnxzo8l6",ydLoanDeductionList); ydClient.operateData(YDParam.builder() .formUuid("FORM-D8589EE237894F4E9FF9B1A0D4BDCABFKNYM") .formDataJson(JSONObject.toJSONString(ydFormData)) .build(), YDConf.FORM_OPERATION.create); } @Override public void invoiceWriteBack8(Map map) { String formCode = UtilMap.getString(map, "formCode");//单据号 Map formData = UtilMap.getMap(map, "formData"); String formSubTypeBizCode = getMkStrValue(formData, "formSubTypeBizCode");//单据类型业务编码 Map ydFormData = new HashMap(); switch (formSubTypeBizCode){ case "FT204655110165381205"://项目报销单(个人) String reimburseName = getMkStrValue(formData, "reimburseName");//事由 String legalEntity = getMkStrValue(formData, "legalEntity");//公司抬头 Map coverUser = getMkListValue(formData, "coverUser").get(0);//承担人 String coverUserName = UtilMap.getString(coverUser, "text");//承担人姓名 List coverDdUser = getDdUserId(coverUserName);//承担人钉钉id String coverDepartment = getMkStrValue(formData, "coverDepartment");//承担部门 Map cf0 = getMkMapValue(formData, "CF0"); String projectCode = UtilMap.getString(cf0, "businessCode");//项目流水号 String projectName = UtilMap.getString(cf0, "text");//项目名称 String cf31 = getMkStrValue(formData, "CF31");//代垫付 Map payeeAccount = getMkMapValue(formData, "payeeAccount"); String bankAcctNumber = UtilMap.getString(payeeAccount, "bankAcctNumber");//收款账户 List expenseList = getMkListValue(formData, "expenseList"); List ydExpenseList = new ArrayList<>(); double totalAmt = 0d; for (Map expense : expenseList) { String expenseType = getMkStrValue(expense, "expenseTypeCode");//费用类型 double acceptAmount = Double.parseDouble(getMkStrValue(expense, "acceptAmount"));//收款金额 String comments = getMkStrValue(expense, "comments");//用途 long consumeTime = getMkDateValue(expense, "consumeTime");//消费日期 Map expenseMap = new HashMap(); expenseMap.put("textField_mnwlpiwc",expenseType); expenseMap.put("numberField_mnwlpiwd",acceptAmount); expenseMap.put("textareaField_mnwlpiwh",comments); expenseMap.put("dateField_mnwlpiwe",consumeTime); ydExpenseList.add(expenseMap); totalAmt += acceptAmount; } ydFormData.put("textField_mnwtck7h","项目报销单(个人)"); ydFormData.put("textField_mnwtwu9z",projectCode); ydFormData.put("textField_mnwlpivn",projectName); ydFormData.put("textareaField_mnwlpivb",reimburseName); ydFormData.put("textField_mnwlpivg",legalEntity); ydFormData.put("textField_mnwlpivi",coverDepartment); ydFormData.put("employeeField_mnwlpivh",coverDdUser); ydFormData.put("textField_mnwlpiw6",bankAcctNumber); ydFormData.put("textField_mnwlpivq",cf31); ydFormData.put("tableField_mnwlpiwb",ydExpenseList); ydFormData.put("numberField_mo007gcg",totalAmt); break; case "FT212801282906280987"://打车(企业支付) String cf36 = getMkStrValue(formData, "CF36");//是否有项目 if (!"是".equals(cf36)) return; String reimburseName2 = getMkStrValue(formData, "reimburseName");//事由 String legalEntity2 = getMkStrValue(formData, "legalEntity");//公司抬头 Map coverUser2 = getMkListValue(formData, "coverUser").get(0);//承担人 String coverUserName2 = UtilMap.getString(coverUser2, "text");//承担人姓名 List coverDdUser2 = getDdUserId(coverUserName2);//承担人钉钉id String coverDepartment2 = getMkStrValue(formData, "coverDepartment");//承担部门 Map cf0_2 = getMkMapValue(formData, "CF0"); String projectCode2 = UtilMap.getString(cf0_2, "businessCode");//项目流水号 String projectName2 = UtilMap.getString(cf0_2, "text");//项目名称 String cf31_2 = getMkStrValue(formData, "CF31");//代垫付 Map payeeAccount2 = getMkMapValue(formData, "payeeAccount"); String bankAcctNumber2 = UtilMap.getString(payeeAccount2, "bankAcctNumber");//收款账户 List expenseList2 = getMkListValue(formData, "expenseList"); List ydExpenseList2 = new ArrayList<>(); double totalAmt2 = 0d; for (Map expense : expenseList2) { String expenseType = getMkStrValue(expense, "expenseTypeCode");//费用类型 double acceptAmount = Double.parseDouble(getMkStrValue(expense, "acceptAmount"));//收款金额 String comments = getMkStrValue(expense, "comments");//用途 long consumeTime = getMkDateValue(expense, "consumeTime");//消费日期 Map expenseMap = new HashMap(); expenseMap.put("textField_mnwlpiwc",expenseType); expenseMap.put("numberField_mnwlpiwd",acceptAmount); expenseMap.put("textareaField_mnwlpiwh",comments); expenseMap.put("dateField_mnwlpiwe",consumeTime); ydExpenseList2.add(expenseMap); totalAmt2 += acceptAmount; } ydFormData.put("textField_mnwtck7h","打车(企业支付)"); ydFormData.put("textField_mnwtwu9z",projectCode2); ydFormData.put("textField_mnwlpivn",projectName2); ydFormData.put("textareaField_mnwlpivb",reimburseName2); ydFormData.put("textField_mnwlpivg",legalEntity2); ydFormData.put("textField_mnwlpivi",coverDepartment2); ydFormData.put("employeeField_mnwlpivh",coverDdUser2); ydFormData.put("textField_mnwlpiw6",bankAcctNumber2); ydFormData.put("textField_mnwlpivq",cf31_2); ydFormData.put("tableField_mnwlpiwb",ydExpenseList2); ydFormData.put("numberField_mo007gcg",totalAmt2); break; case "FT204524106635297811"://项目差旅报销单 String reimburseName3 = getMkStrValue(formData, "reimburseName");//事由 String legalEntity3 = getMkStrValue(formData, "legalEntity");//公司抬头 Map coverUser3 = getMkListValue(formData, "coverUser").get(0);//承担人 String coverUserName3 = UtilMap.getString(coverUser3, "text");//承担人姓名 List coverDdUser3 = getDdUserId(coverUserName3);//承担人钉钉id String coverDepartment3 = getMkStrValue(formData, "coverDepartment");//承担部门 Map cf0_3 = getMkMapValue(formData, "CF0"); String projectCode3 = UtilMap.getString(cf0_3, "businessCode");//项目流水号 String projectName3 = UtilMap.getString(cf0_3, "text");//项目名称 String cf31_3 = getMkStrValue(formData, "CF31");//代垫付 Map payeeAccount3 = getMkMapValue(formData, "payeeAccount"); String bankAcctNumber3 = UtilMap.getString(payeeAccount3, "bankAcctNumber");//收款账户 List expenseList3 = getMkListValue(formData, "expenseList"); List ydExpenseList3 = new ArrayList<>(); double totalAmt3 = 0d; for (Map expense : expenseList3) { String expenseType = getMkStrValue(expense, "expenseTypeCode");//费用类型 double acceptAmount = Double.parseDouble(getMkStrValue(expense, "acceptAmount"));//收款金额 String comments = getMkStrValue(expense, "comments");//用途 long consumeTime = getMkDateValue(expense, "consumeTime");//消费日期 Map expenseMap = new HashMap(); expenseMap.put("textField_mnwlpiwc",expenseType); expenseMap.put("numberField_mnwlpiwd",acceptAmount); expenseMap.put("textareaField_mnwlpiwh",comments); expenseMap.put("dateField_mnwlpiwe",consumeTime); ydExpenseList3.add(expenseMap); totalAmt3 += acceptAmount; } ydFormData.put("textField_mnwtck7h","项目差旅报销单"); ydFormData.put("textField_mnwtwu9z",projectCode3); ydFormData.put("textField_mnwlpivn",projectName3); ydFormData.put("textareaField_mnwlpivb",reimburseName3); ydFormData.put("textField_mnwlpivg",legalEntity3); ydFormData.put("textField_mnwlpivi",coverDepartment3); ydFormData.put("employeeField_mnwlpivh",coverDdUser3); ydFormData.put("textField_mnwlpiw6",bankAcctNumber3); ydFormData.put("textField_mnwlpivq",cf31_3); ydFormData.put("tableField_mnwlpiwb",ydExpenseList3); ydFormData.put("numberField_mo007gcg",totalAmt3); break; default: return; } ydClient.operateData(YDParam.builder() .formUuid("FORM-4F0DF576764A472AA6CF4AC0E26061559AR4") .formDataJson(JSONObject.toJSONString(ydFormData)) .build(), YDConf.FORM_OPERATION.create); } @Override public McR saveRepayment(Map map) { String formInstId = UtilMap.getString(map, "formInstId"); Map formData = ydClient.queryData(YDParam.builder() .formInstanceId(formInstId) .build(), YDConf.FORM_QUERY.retrieve_id).getFormData(); String thbh = UtilMap.getString(formData, "serialNumberField_mkkmij3o");//退回编号 String type = UtilMap.getString(formData, "radioField_mkkmij3b"); String ssgssh = UtilMap.getString(formData, "textField_mmd6hio7");//所属公司税号 String sqrgh = UtilMap.getString(formData, "textField_mmwvodde");//申请人工号 Map employeeDetails = MkBxUtil.employeeDetails(UtilMap.map("employeeIds", Arrays.asList(sqrgh))); String deptBusinessCode = ""; String empId = ""; if (Objects.nonNull(employeeDetails)){ List departments = UtilMap.getList(employeeDetails, "departments"); deptBusinessCode = UtilMap.getString(departments.get(0), "businessCode"); empId = sqrgh; }else { empId = mkbx_empId; deptBusinessCode = mkbx_deptId; } if ("直接采购".equals(type)){ String cgbh = UtilMap.getString(formData, "textField_mn4fwdj5");//采购编号 List cgmxList = UtilMap.getList(formData, "tableField_mkkmij56"); for (Map cgmx : cgmxList) { Double amt = UtilMap.getDouble(cgmx, "numberField_mn2wqvpp");//退回金额 if (amt == 0) continue; int index = UtilMap.getInt(cgmx, "numberField_mn36ykxx");//索引 String thsy = UtilMap.getString(cgmx, "textareaField_mo2k0ien");//退回事由 String gysbh = UtilMap.getString(cgmx, "textField_mmbmohrb");//供应商编号 Map reimburseDetailInfo = MkBxUtil.reimburseDetailInfo(cgbh + "-" + index); Map expense = ((List) UtilMap.getList(reimburseDetailInfo, "expenseList")).get(0); String expenseCode = UtilMap.getString(expense, "code");//费用编码 Map noReceiptReturn = new HashMap(); noReceiptReturn.put("recordExpenseCode",expenseCode); noReceiptReturn.put("recordDeductionAmount",new HashMap(){{put("currency","CNY");put("amount",amt);}}); Map body = new HashMap(); body.put("formCode",thbh + index); body.put("repaymentName",thsy); body.put("formSubTypeBizCode","FT212654855978767371"); body.put("submittedUserEmployeeId",empId); body.put("coverEmployeeId",empId); body.put("departmentBizCode",deptBusinessCode); body.put("legalEntityBizCode",ssgssh); body.put("repayAmount",new HashMap(){{put("currency","CNY");put("amount",amt);}}); body.put("repaymentDate",System.currentTimeMillis()); body.put("tradingPartnerBizCode",gysbh); body.put("paymentType","BANK"); body.put("noReceiptReturnList",Arrays.asList(noReceiptReturn)); body.put("stagingFlag",false); MkBxUtil.receiveRepayment(body); } }else {//需求采购 String xqbh = UtilMap.getString(formData, "textField_mn4fwdj4");//需求编号 List cgmxList = UtilMap.getList(formData, "tableField_mn2xmq2b"); for (Map cgmx : cgmxList) { Double amt = UtilMap.getDouble(cgmx, "numberField_mn2xmq1p");//退回金额 if (amt == 0) continue; int index = UtilMap.getInt(cgmx, "numberField_mn39fdfe");//索引 String thsy = UtilMap.getString(cgmx, "textareaField_mo2k0iep");//退回事由 String gysbh = UtilMap.getString(cgmx, "textField_mn2xmq27");//供应商编号 Map reimburseDetailInfo = MkBxUtil.reimburseDetailInfo(xqbh + "-" + index); Map expense = ((List) UtilMap.getList(reimburseDetailInfo, "expenseList")).get(0); String expenseCode = UtilMap.getString(expense, "code");//费用编码 Map noReceiptReturn = new HashMap(); noReceiptReturn.put("recordExpenseCode",expenseCode); noReceiptReturn.put("recordDeductionAmount",new HashMap(){{put("currency","CNY");put("amount",amt);}}); Map body = new HashMap(); body.put("formCode",thbh + index); body.put("repaymentName",thsy); body.put("formSubTypeBizCode","FT212654855978767371"); body.put("submittedUserEmployeeId",empId); body.put("coverEmployeeId",empId); body.put("departmentBizCode",deptBusinessCode); body.put("legalEntityBizCode",ssgssh); body.put("repayAmount",new HashMap(){{put("currency","CNY");put("amount",amt);}}); body.put("repaymentDate",System.currentTimeMillis()); body.put("tradingPartnerBizCode",gysbh); body.put("paymentType","BANK"); body.put("noReceiptReturnList",Arrays.asList(noReceiptReturn)); body.put("stagingFlag",false); MkBxUtil.receiveRepayment(body); } } return McR.success(); } @Async @Override public void invoiceWriteBack9(Map map) { Map calloutParams = UtilMap.getMap(map, "calloutParams"); String serviceType = UtilMap.getString(calloutParams, "serviceType"); Map bizData = UtilMap.getMap(calloutParams, "bizData"); if ("RECEIVABLE_AR_COMPLETED_NOTIFY_AR".equals(serviceType)){ List invoiceList = UtilMap.getList(bizData, "invoiceList"); Map invoiceMap = invoiceList.get(0); String invoiceNumber = UtilMap.getString(invoiceMap, "invoiceNumber");//发票号码 long formDate = UtilMap.getLong(invoiceMap, "formDate");//开票日期 String invoiceApplicationBizCode = ((List)UtilMap.getList(bizData, "invoiceApplicationBizCodes")).get(0);//开票申请单编号 Map updateFormData = new HashMap(); updateFormData.put("radioField_mkxripcc","开票成功"); updateFormData.put("textField_mkxripc6",invoiceNumber); updateFormData.put("dateField_mnfpbwpd",formDate); updateFormData.put("textareaField_mmlzqvn0",""); //发票下载信息查询 Map invoiceInfo = MkYpUtil.getInvoiceInfo(invoiceNumber); if (Objects.nonNull(invoiceInfo)){ String pdfUrl = UtilMap.getString(invoiceInfo, "pdfUrl");//发票下载地址 String downloadPageUrl = UtilMap.getString(invoiceInfo, "downloadPageUrl");//发票下载页面地址 if (Strings.isNotBlank(pdfUrl)){ String fileName = invoiceNumber + ".pdf"; String downloadPath = downloadFilePath + fileName; downloadFile(pdfUrl,downloadPath);//下载pdf发票 String downloadUri = downloadUrl + "files/" + fileName + "?option=download"; String previewUri = downloadUrl + "files/" + fileName + "?option=preview"; Map attachmentField = new HashMap(); attachmentField.put("downloadUrl",downloadUri); attachmentField.put("name",fileName); attachmentField.put("previewUrl",previewUri); attachmentField.put("url",downloadUri); attachmentField.put("ext","pdf"); updateFormData.put("attachmentField_mkxripc5",Arrays.asList(attachmentField)); } if (Strings.isNotBlank(downloadPageUrl)){ updateFormData.put("textField_mm3aixk0",downloadPageUrl); } } //回写宜搭 Map data = ((List)ydClient.queryData(YDParam.builder() .searchCondition(JSONObject.toJSONString(UtilMap.map("serialNumberField_mknspz75",invoiceApplicationBizCode))) .formUuid("FORM-A9A47B0365DB437F8F4C8E01B4468220K7GU") .build(), YDConf.FORM_QUERY.retrieve_list).getData()).get(0); String formInstanceId = UtilMap.getString(data, "formInstanceId"); ydClient.operateData(YDParam.builder() .formInstanceId(formInstanceId) .updateFormDataJson(JSONObject.toJSONString(updateFormData)) .build(), YDConf.FORM_OPERATION.update); } } @Override public McR ddProject(Map map) { String formInstId = UtilMap.getString(map, "formInstId"); String type = UtilMap.getString(map, "type"); Map formData = ydClient.queryData(YDParam.builder() .formInstanceId(formInstId) .build(), YDConf.FORM_QUERY.retrieve_id).getFormData(); String projectCode = UtilMap.getString(formData, "serialNumberField_mknemyna");//项目流水号 String projectName = UtilMap.getString(formData, "textField_mkdedkvu");//项目名称 String projectProgress = UtilMap.getString(formData, "selectField_mkdf8q80");//项目进度 String projectManager = UtilMap.getString(formData, "textField_mo8lkotd");//项目负责人工号 List projectMember = UtilMap.getList(formData, "multiSelectField_mo9iilfl");//项目成员工号 String ztcg = UtilMap.getString(formData, "textField_mo9iilfm");//中台采购工号 List leader_employee_id = new ArrayList<>(); leader_employee_id.add(projectManager);//第一个为主负责人，后续为其他负责人 leader_employee_id.addAll(projectMember); leader_employee_id.add(ztcg); //leader_employee_id去重 leader_employee_id = leader_employee_id.stream().distinct().collect(Collectors.toList()); String htqygssh = UtilMap.getString(formData, "textField_mo9nav1d");//合同签约公司税号 if ("add".equals(type)){//新增 String startDate = new SimpleDateFormat("yyyy-MM-dd").format(new Date());//项目开始时间 //当前时间+一年半 Calendar calendar = Calendar.getInstance(); calendar.setTime(new Date()); calendar.add(Calendar.YEAR, 1); calendar.add(Calendar.MONTH, 6); String endDate = new SimpleDateFormat("yyyy-MM-dd").format(calendar.getTime());//项目结束时间 Map body = new HashMap(); body.put("out_budget_id",projectCode); body.put("name",projectName); body.put("type",2); body.put("budget_cycle",0); body.put("total_quota",0); body.put("member_used",2);//0 ：全员可见 1：项目成员可见 2：公司主体可见 body.put("legal_entity_id",htqygssh);//项目所属公司主体ID body.put("start_date",startDate); body.put("expiry_date",endDate); body.put("leader_employee_id",JSONObject.toJSONString(leader_employee_id)); Map result = QyddUtil.BudgetCenterAdd(body); return McR.success(result); }else if ("update".equals(type)){//更新 Map body = new HashMap(); body.put("out_budget_id",projectCode); body.put("name",projectName); body.put("type",2); body.put("member_used",2);//0 ：全员可见 1：项目成员可见 2：公司主体可见 body.put("legal_entity_id",htqygssh);//项目所属公司主体ID body.put("leader_employee_id",JSONObject.toJSONString(leader_employee_id)); Map result = QyddUtil.BudgetCenterEdit(body); return McR.success(result); }else{//封账 Map body = new HashMap(); body.put("out_budget_id",projectCode); body.put("name",projectName); body.put("type",2); body.put("expiry_date",new SimpleDateFormat("yyyy-MM-dd").format(new Date()));//项目结束时间 封账时间 Map result = QyddUtil.BudgetCenterEdit(body); return McR.success(result); } } private static String getMkStrValue(Map formData, String entityName) { Map title = UtilMap.getMap(formData, entityName); Map value = UtilMap.getMap(title, "value"); String text = UtilMap.getString(value, "text"); return text; } private static Map getMkMapValue(Map formData, String entityName) { Map title = UtilMap.getMap(formData, entityName); Map value = UtilMap.getMap(title, "value"); return value; } private static List getMkListValue(Map formData, String entityName) { Map title = UtilMap.getMap(formData, entityName); List value = UtilMap.getList(title, "value"); return value; } private static Long getMkDateValue(Map formData, String entityName) { Map title = UtilMap.getMap(formData, entityName); Map value = UtilMap.getMap(title, "value"); long currentTime = UtilMap.getLong(value, "currentTime"); return currentTime; } //根据员工名字匹配员工id private List getDdUserId(String Name){ HashMap body = new HashMap(); body.put("queryWord", Name); body.put("offset",0); body.put("size",1); String s1 = UtilHttp.doPost("https://api.dingtalk.com/v1.0/contact/users/search", ddClient.initTokenHeader(), null, body); List list = JSONObject.parseObject(s1).getJSONArray("list").toJavaList(String.class); return list; } //更新宜搭采购已退回金额 private void updateYdRepay(String formCode, Double amount) { String[] split = formCode.split("-"); String bh = split[0]; int index = Integer.parseInt(split[1]); Map updateFormData = new HashMap(); List updateDetailList = new ArrayList<>(); if (formCode.contains("需求")){ //采购需求&结算 List data = (List) ydClient.queryData(YDParam.builder() .formUuid("FORM-C8C1FBBA781C4C5EBAC487C07BC5A86AD2HO") .searchCondition(JSONObject.toJSONString(UtilMap.map("serialNumberField_mkkmij3o", bh))) .build(), YDConf.FORM_QUERY.retrieve_list_all).getData(); String formInstanceId = UtilMap.getString(data.get(0), "formInstanceId"); Map ydFormData = UtilMap.getMap(data.get(0), "formData"); String type = UtilMap.getString(ydFormData, "radioField_mkkmij3b"); if ("常规需求".equals(type)){ List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij56"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxx")){ Double ythje = UtilMap.getDouble(detail, "numberField_mn4g182f");//已退回金额 detailMap.put("numberField_mn4g182f",ythje + amount); detailMap.put("selectField_mmvhqm0p","部分退款"); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij56",updateDetailList); }else { List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij61"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxz")){ Double ythje = UtilMap.getDouble(detail, "numberField_mn4g182g");//已退回金额 detailMap.put("numberField_mn4g182g",ythje + amount); detailMap.put("selectField_mkkmij6a","部分退款"); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij61",updateDetailList); } Double totalAmt = UtilMap.getDouble(ydFormData, "numberField_mn4g5e28");//已退回 updateFormData.put("numberField_mn4g5e28",totalAmt + amount); ydClient.operateData(YDParam.builder() .formInstanceId(formInstanceId) .updateFormDataJson(JSONObject.toJSONString(updateFormData)) .useLatestVersion(true) .build(), YDConf.FORM_OPERATION.update); }else { //直接采购结算单 List data = (List) ydClient.queryData(YDParam.builder() .formUuid("FORM-1AFEDDA034C74F0DB18FA60C941CB56EHUUG") .searchCondition(JSONObject.toJSONString(UtilMap.map("serialNumberField_mkkmij3o", bh))) .build(), YDConf.FORM_QUERY.retrieve_list_all).getData(); String formInstanceId = UtilMap.getString(data.get(0), "formInstanceId"); Map ydFormData = UtilMap.getMap(data.get(0), "formData"); String type = UtilMap.getString(ydFormData, "radioField_mkkmij3b"); if ("常规采购".equals(type)){ List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij56"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxx")){ Double ythje = UtilMap.getDouble(detail, "numberField_mn4g182f");//已退回金额 detailMap.put("numberField_mn4g182f",ythje + amount); detailMap.put("selectField_mmvhtdy0","部分退款"); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij56",updateDetailList); }else { List detailList = UtilMap.getList(ydFormData, "tableField_mkkmij61"); for (Map detail : detailList) { Map detailMap = new HashMap(); if (index == UtilMap.getInt(detail, "numberField_mn36ykxz")){ Double ythje = UtilMap.getDouble(detail, "numberField_mn4g182g");//已退回金额 detailMap.put("numberField_mn4g182g",ythje + amount); detailMap.put("selectField_mkkmij6a","部分退款"); } updateDetailList.add(detailMap); } updateFormData.put("tableField_mkkmij61",updateDetailList); } Double totalAmt = UtilMap.getDouble(ydFormData, "numberField_mn4g5e28");//已退回 updateFormData.put("numberField_mn4g5e28",totalAmt + amount); ydClient.operateData(YDParam.builder() .formInstanceId(formInstanceId) .updateFormDataJson(JSONObject.toJSONString(updateFormData)) .useLatestVersion(true) .build(), YDConf.FORM_OPERATION.update); } } //文件下载到本地 private void downloadFile(String downloadUri,String downloadPath){ try { URL url = new URL(downloadUri); HttpURLConnection httpConn = (HttpURLConnection) url.openConnection(); int responseCode = httpConn.getResponseCode(); // 检查HTTP响应代码是否为200 if (responseCode == HttpURLConnection.HTTP_OK) { InputStream inputStream = httpConn.getInputStream(); FileOutputStream outputStream = new FileOutputStream(downloadPath); byte[] buffer = new byte[4096]; int bytesRead = -1; while ((bytesRead = inputStream.read(buffer)) != -1) { outputStream.write(buffer, 0, bytesRead); } outputStream.close(); inputStream.close(); } else { System.out.println("无法下载文件。HTTP响应代码: " + responseCode); } httpConn.disconnect(); }catch (Exception e){ throw new RuntimeException(e); } } }