import com.dderp.business.dao.OrderDao import com.dderp.common.api.BusinessExecutor import com.dderp.common.api.StoreService import com.dderp.common.api.SupplierInitService import com.dderp.common.api.flycat.DouyinService import com.dderp.common.api.flycat.OrderSearchService import com.dderp.common.api.flycat.OrderService import com.dderp.common.api.flycat.OrderStepService import com.dderp.common.datas.ERPModule import com.dderp.common.datas.ESKeys import com.dderp.common.datas.flycat.PlatformType import com.dderp.common.datas.flycat.RefundRequestStatus import com.dderp.common.entity.base.InvokeCallParams import com.dderp.common.entity.base.InvokeCallResult import com.dderp.common.entity.order.BusinessOrder import com.dderp.common.entity.order.OrderAfterSaleBill import com.dderp.common.entity.order.OrderRefundRequest import com.dderp.common.entity.order.OrderStep import com.dderp.common.entity.site.ERPTokenUser import com.dderp.common.entity.store.StorePlatform import com.dderp.common.tool.ERPUtils import com.dySweetFishPlugin.elasticsearch.ESClient import com.dySweetFishPlugin.sql.TableIdService import com.dySweetFishPlugin.sql.dao.TunaService import com.sweetfish.convert.json.JsonConvert import com.sweetfish.service.RetResult import groovy.json.JsonSlurper import org.apache.logging.log4j.LogManager import org.apache.logging.log4j.Logger import org.elasticsearch.action.bulk.BulkRequestBuilder import org.elasticsearch.action.bulk.BulkResponse import org.elasticsearch.action.index.IndexRequestBuilder import org.elasticsearch.action.support.WriteRequest import org.elasticsearch.action.update.UpdateRequestBuilder import org.elasticsearch.common.xcontent.XContentType import org.rex.RMap import javax.annotation.Resource import java.time.LocalDateTime import java.time.ZoneOffset import static org.elasticsearch.common.xcontent.XContentFactory.jsonBuilder @SuppressWarnings("unused") class BE_Order_ProcessRefund_DYLK implements BusinessExecutor { private final Logger logger = LogManager.getLogger(this.getClass().getSimpleName()) @Resource private JsonConvert jsonConvert @Resource private TableIdService tableIdService @Resource private StoreService storeService @Resource private ESClient esClient @Resource private SupplierInitService supplierInitService @Resource private OrderStepService orderStepService @Resource private OrderService orderService @Resource private OrderSearchService orderSearchService @Resource private DouyinService douyinService @Resource private TunaService tunaService private OrderDao orderDao @Override String scriptName() { return "商户同意/拒绝退款请求" } @Override ERPModule module() { return ERPModule.ORDER_API } @Override RetResult beforeExecute(InvokeCallParams source) { return super.beforeExecute(source) } /* params : { "idRefundRequest" : 2 , 客户退款申请id "approve" : 0 , 拒绝0同意1 "rejectReasonCode" : "[101,102,103]" , 拒绝原因代码,注意这个括号不能少必须是数组形式 "rejectMemo" : "拒绝原因备注" 拒绝原因备注 } */ RetResult execute(InvokeCallParams source) { //秒级时间戳，groovy里面不让用system long currentTime = LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8)) String dataSourceId = source.dataSourceId long supplierCode = source.supplierCode ERPTokenUser currentUser = source.currentUser def jsonSlurper = new JsonSlurper() def invokeOrder = jsonSlurper.parseText(source.params) String incomePlatformOrderCode = invokeOrder["order_id"] as String String platformStoreId = invokeOrder["poi_id"] as String String outAfterSaleId = invokeOrder["after_sale_id"] as String boolean pass = invokeOrder["pass"] as boolean // StorePlatform storePlatform = storeService.getStorePlatformByInvokeInfo(platformStoreId, "DYLK", PlatformType.order.value, supplierCode) // if (storePlatform == null) return RetResult. errorT().retinfo("订单来源平台未知!") // // RMap searchParams = new RMap(); // searchParams.set("incomePlatformId", platformStoreId) // searchParams.set("incomePlatformOrderCode", incomePlatformOrderCode) // // RetResult> orderResult = orderSearchService.searchBusinessOrderList(searchParams, currentUser, dataSourceId, supplierCode, null) // if (!orderResult.isSuccess()) return RetResult. errorT().retinfo(orderResult.retinfo) // // BusinessOrder esOrder = orderResult.result.get(0) //这么查只可能有一个 RMap searchParams = new RMap() searchParams.set("outAfterSaleId", outAfterSaleId) RetResult> requestRetResult = orderSearchService.searchOrderRefundRequestList(searchParams, currentUser, dataSourceId, supplierCode, null) if (!requestRetResult.isSuccess()) return RetResult. errorT().retinfo(requestRetResult.retinfo) OrderRefundRequest refundRequest = requestRetResult.result.get(0) //这么查只可能有一个 OrderAfterSaleBill afterSaleBill if (!pass) { //拒绝退款 def codeList = (invokeOrder["refuse_audit_reasons"] as ArrayList).collect { it["code"] as int } def msgList = (invokeOrder["refuse_audit_reasons"] as ArrayList).collect { it["msg"] as String } refundRequest.setRequestStatus(RefundRequestStatus.refuse.value) refundRequest.setRefuseToRefundReasonCodes(jsonConvert.convertTo(codeList)) refundRequest.setRefuseToRefundMemo(jsonConvert.convertTo(msgList)) OrderRefundRequest.update(refundRequest, currentUser.id) } else { //同意退款 refundRequest.setRequestStatus(RefundRequestStatus.agree.value) OrderRefundRequest.update(refundRequest, currentUser.id) afterSaleBill = OrderAfterSaleBill.buildFromRefundRequest(refundRequest) afterSaleBill.setId(tableIdService.getTableIdMulti("deOrderAfterSaleBill.id", 1, dataSourceId, String.valueOf(supplierCode))) afterSaleBill.setBillCode(tableIdService.getTableCodeMulti("deOrderAfterSaleBill.code", dataSourceId, String.valueOf(supplierCode))) OrderAfterSaleBill.create(afterSaleBill, currentUser.id) } OrderStep orderStep = orderStepService.parseOrderStep(refundRequest.idOrder, "[" + refundRequest.platformName + "]商家已" + pass ? "同意" : "拒绝" + "退款", pass ? "" : refundRequest.refuseToRefundMemo, currentUser) //持久化 //订单退款申请 BulkRequestBuilder bulkRequest = esClient.getClient().prepareBulk().setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE) UpdateRequestBuilder refundQueryRequest = esClient.getClient().prepareUpdate( supplierInitService.getDateYearESIndex(supplierCode, ESKeys.ES_DELIVER_ORDER_REFUND_REQUEST_INDEX, 0), ESKeys.ES_DELIVER_ORDER_REFUND_REQUEST_TYPE, String.valueOf(refundRequest.getId())) .setDoc(jsonBuilder() .startObject() .field("requestStatus", refundRequest.requestStatus) .field("updateBy", refundRequest.getUpdateBy()) .field("updateTimeLong", refundRequest.getUpdateTimeLong()) .endObject()) bulkRequest.add(refundQueryRequest) //订单售后单,只有同意退款才写 if (afterSaleBill) { IndexRequestBuilder afterSaleRequest = esClient.getClient() .prepareIndex(supplierInitService.getDateYearESIndex(supplierCode, ESKeys.ES_DELIVER_BUSINESS_ORDER_INDEX, 0), ESKeys.ES_DELIVER_ORDER_AFTER_SALE_BILL_TYPE) .setId(String.valueOf(afterSaleBill.id)) .setParent(String.valueOf(afterSaleBill.idOrder)) .setSource(jsonConvert.convertTo(afterSaleBill), XContentType.JSON) bulkRequest.add(afterSaleRequest) } //订单脚印 IndexRequestBuilder orderStepRequest = esClient.getClient() .prepareIndex(supplierInitService.getDateYearESIndex(supplierCode, ESKeys.ES_DELIVER_ORDER_STEP_INDEX, 0), ESKeys.ES_DELIVER_ORDER_STEP_TYPE) .setId(String.valueOf(orderStep.id)) .setSource(jsonConvert.convertTo(orderStep), XContentType.JSON) bulkRequest.add(orderStepRequest) BulkResponse bulkResponse = bulkRequest.get(); orderDao = tunaService.generate(OrderDao.class) if (bulkResponse.hasFailures()) { logger.error("商户已同意/拒绝退款出错：" + bulkResponse.buildFailureMessage()); return RetResult. errorT().retinfo("商户已同意/拒绝退款出错:" + refundRequest.orderName); } else { logger.info("商户已同意/拒绝退款成功"); //写数据库 List afterSaleBillList = new ArrayList<>() if (afterSaleBill) afterSaleBillList.add(afterSaleBill) orderDao.processRefundOrder(refundRequest, afterSaleBillList, [orderStep], dataSourceId, String.valueOf(supplierCode)) return RetResult. successT() } } }