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.BusinessOrderStatus import com.dderp.common.datas.ERPModule import com.dderp.common.datas.ESKeys 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.OrderStep import com.dderp.common.entity.site.ERPTokenUser import com.dderp.common.entity.store.StorePlatform 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 javax.annotation.Resource import java.time.LocalDateTime import java.time.ZoneOffset import static org.elasticsearch.common.xcontent.XContentFactory.jsonBuilder @SuppressWarnings("unused") class BE_Order_CancelOrder 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(name = "APP_HOME") private String appHome @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:{idOrder:xxx, refundReason:[501,502], description:"超出配送范围"} 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) long idOrder = invokeOrder["idOrder"] as Long RetResult orderResult = orderSearchService.getBusinessOrder(idOrder, currentUser, dataSourceId, supplierCode, null) if (!orderResult.isSuccess()) return RetResult. errorT().retinfo(orderResult.retinfo) def refundCodeJsonFile = new File(appHome + File.separator + "conf" + File.separator + "script" + File.separator + supplierCode + File.separator + "scriptFiles" + File.separator + "refundOrderReason.json") def refundCodeArray = jsonSlurper.parse(refundCodeJsonFile) BusinessOrder esOrder = orderResult.result def legalReasons = (refundCodeArray.find { it["orderStatus"] == esOrder.orderStatus })["refundReason"] as ArrayList for (Integer reason in invokeOrder["refundReason"] as ArrayList) { if (legalReasons.find { it["code"] as Integer == reason } == null) { return RetResult. errorT().retinfo("订单状态[" + BusinessOrderStatus.getName(esOrder.orderStatus) + "],不允许以[" + reason + "]取消订单") } } esOrder.setVoidFlag(1) BusinessOrder.update(esOrder, currentUser.id) StorePlatform storePlatform = storeService.getStorePlatformInfo(esOrder.incomePlatformId, supplierCode) if (storePlatform == null) return RetResult. errorT().retinfo("订单来源平台未知!") OrderStep orderStep = orderStepService.parseOrderStep(esOrder.id, 0, "[" + storePlatform.platformName + "]商家取消订单: " + invokeOrder["description"], storePlatform.platformCode, currentUser) //todo 判断订单目前状态,如果已生成配送单据,则要同步将配送单据取消 def callSuccess = [success: false, errorMsg: ""] //根据订单来源平台,回调平台的接单接口 switch (storePlatform.platformCode) { case "DYLK": { //抖音来客 def postBody = [ order_id : esOrder.incomePlatformOrderCode, refund_reason: [ reason_code: invokeOrder["refundReason"], desc : invokeOrder["description"] ] ] String responseStr = douyinService.postInvoker("/goodlife/v1/after_sale/order/apply_refund/", jsonConvert.convertTo(postBody)) def response = jsonSlurper.parseText(responseStr) if (response["extra"]["error_code"] as Integer == 0) { callSuccess["success"] = true } else { //todo 抖音侧调用失败,怎么处理? logger.error("[抖音来客]商户接单平台接口调用失败:" + response["extra"]["description"] as String) callSuccess["success"] = false callSuccess["errorMsg"] = "[抖音来客]商户接单平台接口调用失败:" + response["extra"]["description"] as String } break; } } if (callSuccess["success"]) { //持久化 //订单主表 BulkRequestBuilder bulkRequest = esClient.getClient().prepareBulk().setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE) UpdateRequestBuilder orderRequest = esClient.getClient().prepareUpdate( supplierInitService.getDateYearESIndex(supplierCode, ESKeys.ES_DELIVER_BUSINESS_ORDER_INDEX, 0), ESKeys.ES_DELIVER_BUSINESS_ORDER_TYPE, String.valueOf(esOrder.getId())) .setDoc(jsonBuilder() .startObject() .field("voidFlag", esOrder.voidFlag) .field("updateBy", esOrder.getUpdateBy()) .field("updateTimeLong", esOrder.getUpdateTimeLong()) .endObject()) bulkRequest.add(orderRequest) //订单脚印 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("商户取消订单出错:" + esOrder.orderName); } else { logger.info("商户取消订单成功"); //写数据库 orderDao.voidBusinessOrder(esOrder, [orderStep], dataSourceId, String.valueOf(supplierCode)) return RetResult. successT().result(InvokeCallResult.success().data(jsonConvert.convertTo(esOrder))) } } else { return RetResult. errorT().retinfo("商户取消订单出错:" + callSuccess["errorMsg"]); } } }