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.ReadOrderOption import com.dderp.common.datas.flycat.BusinessOrderStatus 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.VoidFlagStatus 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.OrderFinances 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 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_RejectOrder_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 } 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 StorePlatform storePlatform = storeService.getStorePlatformByInvokeInfo(platformStoreId, "DYLK", PlatformType.order.value, supplierCode) if (storePlatform == null) return RetResult. errorT().retinfo("订单来源平台未知!") if (storePlatform.enableStatue == 0) { logger.info("[" + storePlatform.platformName + "]门店[" + storePlatform.platformStoreId + "]已被禁用,消息已忽略") return RetResult. errorT().retinfo("[" + storePlatform.platformName + "]门店[" + storePlatform.platformStoreId + "]已被禁用") } RMap searchParams = new RMap(); searchParams.set("incomePlatformId", storePlatform.id) searchParams.set("incomePlatformOrderCode", incomePlatformOrderCode) RetResult> orderResult = orderSearchService.searchBusinessOrderList(searchParams, currentUser, dataSourceId, supplierCode, ReadOrderOption.ORDER_PRODUCT, ReadOrderOption.ORDER_FINANCES) if (!orderResult.isSuccess()) return RetResult. errorT().retinfo(orderResult.retinfo) BusinessOrder esOrder = orderResult.result.get(0) //这么查只可能有一个 OrderFinances orderFinances = esOrder.orderFinances if (esOrder.orderStatus != BusinessOrderStatus.init.value) return RetResult. errorT().retinfo("订单状态[" + BusinessOrderStatus.getName(esOrder.orderStatus) + "],不允许拒单操作") //todo 目前不知道商户拒单是个什么逻辑,暂且认为等同于订单取消 // esOrder.setOrderStatus(BusinessOrderStatus.accept.value) esOrder.setVoidFlagIn(VoidFlagStatus.invalid.value) BusinessOrder.update(esOrder, currentUser.id) OrderStep orderStep = orderStepService.parseOrderStep(esOrder.id, "[" + storePlatform.platformName + "]商家拒绝接单: " + invokeOrder["description"], storePlatform.platformCode, currentUser) OrderAfterSaleBill afterSaleBill = new OrderAfterSaleBill() afterSaleBill.setId(tableIdService.getTableIdMulti("deOrderAfterSaleBill.id", 1, dataSourceId, String.valueOf(supplierCode))) afterSaleBill.setIdOrder(esOrder.id) afterSaleBill.setIdStorePlatform(storePlatform.id) afterSaleBill.setIdStore(storePlatform.idStore) afterSaleBill.setOutPlatformStoreId(storePlatform.platformStoreId) afterSaleBill.setPlatformCode(storePlatform.platformCode) afterSaleBill.setPlatformType(storePlatform.platformType) afterSaleBill.setPlatformName(storePlatform.platformName) afterSaleBill.setBillCode(tableIdService.getTableCodeMulti("deOrderAfterSaleBill.code", dataSourceId, String.valueOf(supplierCode))) afterSaleBill.setApplySource("MERCHANT")//拒单只能是商户发起 afterSaleBill.setFullRefunded(true) afterSaleBill.setUserRefundAmount((orderFinances.customerPaid * 100).intValue()) afterSaleBill.setTotalUserRefundAmount((orderFinances.customerPaid * 100).intValue()) afterSaleBill.setProdCountAfterRefund(0) afterSaleBill.setProductsRemainDetail("") afterSaleBill.setProductsRefundDetail(jsonConvert.convertTo(esOrder.detailItemList)) OrderAfterSaleBill.create(afterSaleBill, currentUser.id) //持久化 //订单主表 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("voidFlagIn", esOrder.voidFlagIn) .field("updateBy", esOrder.getUpdateBy()) .field("updateTimeLong", esOrder.getUpdateTimeLong()) .endObject()) bulkRequest.add(orderRequest) //订单售后单 IndexRequestBuilder orderAfterBillRequest = 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(orderAfterBillRequest) //订单脚印 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.voidBusinessOrderIn(esOrder, afterSaleBill, [orderStep], dataSourceId, String.valueOf(supplierCode)) return RetResult. successT().result(InvokeCallResult.success().data(jsonConvert.convertTo(esOrder))) } } }