dyDeliver/conf/script/1000/orderApi/BE_Order_CreateOrder_DYLK.groovy

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.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.BusinessOrderStatus
import com.dderp.common.datas.flycat.PlatformType
import com.dderp.common.entity.base.InvokeCallParams
import com.dderp.common.entity.base.InvokeCallResult
import com.dderp.common.entity.geo.GeoPoiLocation
import com.dderp.common.entity.order.*
import com.dderp.common.entity.site.ERPTokenUser
import com.dderp.common.entity.store.StoreInfo
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.common.xcontent.XContentType

import javax.annotation.Resource
import java.math.RoundingMode
import java.time.LocalDateTime
import java.time.ZoneOffset

@SuppressWarnings("unused")
class BE_Order_CreateOrder_DYLK implements BusinessExecutor<InvokeCallParams, InvokeCallResult> {

    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 TunaService tunaService

    private OrderDao orderDao

    @Override
    String scriptName() {
        return "[抖音来客]创建订单"
    }

    @Override
    ERPModule module() {
        return ERPModule.ORDER_API
    }


    RetResult<InvokeCallResult> 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
        JsonConvert orderConvertor = source.jsonConvertMap.get("orderConvertor")

        def jsonSlurper = new JsonSlurper()
        def invokeOrder = jsonSlurper.parseText(source.params)

        StorePlatform storePlatform = storeService.getStorePlatformByInvokeInfo(invokeOrder["poi"]["poi_id"] as String,
                "DYLK", PlatformType.order.value, supplierCode)
        if (storePlatform == null) return RetResult.<InvokeCallResult> errorT().retinfo("订单来源平台未知!")
        if (storePlatform.enableStatue == 0) {
            logger.info("[" + storePlatform.platformName + "]门店[" + storePlatform.platformStoreId + "]已被禁用,消息已忽略")
            return RetResult.<InvokeCallResult> errorT().retinfo("[" + storePlatform.platformName + "]门店[" + storePlatform.platformStoreId + "]已被禁用")
        }

        BusinessOrder businessOrder = new BusinessOrder()
        businessOrder.setId(tableIdService.getTableIdMulti("deBusinessOrder.id", 1, dataSourceId, String.valueOf(supplierCode)))
        businessOrder.setOrderName(invokeOrder["merchant"]["account_name"] as String)
        businessOrder.setOrderCode(tableIdService.getTableCodeMulti("deBusinessOrder.code", dataSourceId, String.valueOf(supplierCode)))
        businessOrder.setOrderStatus(BusinessOrderStatus.init.value)

        businessOrder.setIncomePlatformId(storePlatform.id)
        businessOrder.setIncomePlatformName(storePlatform.platformName)
        businessOrder.setIncomePlatformOrderCode(invokeOrder["order"]["order_id"] as String)
        businessOrder.setIncomePlatformOrderTimeLong(invokeOrder["order"]["pay_time"] as long * 1000)//抖音传过来的时间戳单位是秒
        businessOrder.setIncomePlatformOrderTime(new Date(businessOrder.incomePlatformOrderTimeLong))
        //抖音传过来的格式为起始时间戳（单位秒）- 截止时间戳（单位秒），示例：1669370006-1669371206,目前先取起始时间
        long suggestTimeLong = (invokeOrder["order"]["sys_expect_time"] as String).split("-")[0] as long
        businessOrder.setSuggestDeliverTimeLong(suggestTimeLong * 1000)
        businessOrder.setSuggestDeliverTime(new Date(businessOrder.suggestDeliverTimeLong))
        StoreInfo storeInfo = storeService.getStoreInfo(storePlatform.idStore, supplierCode, false, false, false);
        businessOrder.setIdStore(storeInfo.id)
        businessOrder.setStoreName(storeInfo.storeName)
        BigDecimal deliverFee = ERPUtils.money((invokeOrder["amount_info"]["freight_pay_amount"] as int))
        businessOrder.setDeliverFee(deliverFee)
        String address = "[" + invokeOrder["receiver_info"]["city"] + "]" + invokeOrder["receiver_info"]["province"] +
                invokeOrder["receiver_info"]["city"] +
                invokeOrder["receiver_info"]["district"] +
                invokeOrder["receiver_info"]["town"] +
                invokeOrder["receiver_info"]["location_address"] +
                invokeOrder["receiver_info"]["location_name"] + "-" +
                invokeOrder["receiver_info"]["receiver_name"]
        businessOrder.setDeliverAddressAll(address)
        //写入订单序号
        long sequence = orderService.getOrderSequence(storeInfo.id, storePlatform.idPlatformInfo, supplierCode)
        businessOrder.setOrderSequence(sequence)
        BusinessOrder.create(businessOrder, currentUser.id)

        //订单金额类信息
        OrderFinances orderFinances = new OrderFinances()
        orderFinances.setId(tableIdService.getTableIdMulti("deBusinessOrder.id", 1, dataSourceId, String.valueOf(supplierCode)))
        orderFinances.setIdOrder(businessOrder.id)
        orderFinances.setOrderMoney(ERPUtils.money(invokeOrder["amount_info"]["origin_amount"] as int))
        orderFinances.setDeliverFee(deliverFee)
        orderFinances.setCustomerPaid(ERPUtils.money(invokeOrder["amount_info"]["pay_amount"] as int))
        orderFinances.setStoreRealCollection(ERPUtils.money(invokeOrder["amount_info"]["estimated_order_income"] as int))
        orderFinances.setPlatformServiceFee(ERPUtils.money(invokeOrder["amount_info"]["commission_amount"] as int))
        OrderFinances.create(orderFinances, currentUser.id)

        businessOrder.setOrderFinances(orderFinances)

        //订单折扣信息,归属于金额信息系列
        //分别合计以下平台补贴和商户补贴
        def platDiscount = 0, merchantDiscount = 0
        List<OrderDiscount> discountList = new ArrayList<>()
        long idDiscount = tableIdService.getTableIdMulti("deOrderDiscount.id", (invokeOrder["amount_info"]["discounts"] as ArrayList).size(),
                dataSourceId, String.valueOf(supplierCode))
        (invokeOrder["amount_info"]["discounts"] as ArrayList).each { discount ->
            OrderDiscount orderDiscount = new OrderDiscount()
            orderDiscount.setId(idDiscount)
            orderDiscount.setIdOrder(businessOrder.id)
            orderDiscount.setDiscountName("")
            orderDiscount.setDiscountType(discount["discount_type"] as int)
            orderDiscount.setDiscountAmount(discount["discount_amount"] as int)
            orderDiscount.setMerchantDiscountAmount(discount["merchant_discount_amount"] as int)
            orderDiscount.setPlatformDiscountAmount(discount["platform_discount_amount"] as int)
            OrderDiscount.create(orderDiscount, currentUser.id)
            platDiscount += orderDiscount.platformDiscountAmount
            merchantDiscount += orderDiscount.merchantDiscountAmount

            discountList.add(orderDiscount)

            idDiscount++
        }
        businessOrder.setOrderDiscountList(discountList)
        orderFinances.setOrderPlatformSubsidy(ERPUtils.money(platDiscount))
        orderFinances.setStoreDiscount(ERPUtils.money(merchantDiscount))

        //订单配送类信息
        OrderDeliveryInfo orderDeliveryInfo = new OrderDeliveryInfo()
        orderDeliveryInfo.setId(tableIdService.getTableIdMulti("deOrderDeliveryInfo.id", 1, dataSourceId, String.valueOf(supplierCode)))
        orderDeliveryInfo.setIdOrder(businessOrder.id)
        orderDeliveryInfo.setDeliverProvince(invokeOrder["receiver_info"]["province"] as String)
        orderDeliveryInfo.setDeliverCity(invokeOrder["receiver_info"]["city"] as String)
        orderDeliveryInfo.setDeliverDistract(invokeOrder["receiver_info"]["district"] as String)
//        orderDeliveryInfo.setDeliverAddress(invokeOrder["receiver_info"]["location_address"] as String)
        orderDeliveryInfo.setDeliverAddress(invokeOrder["receiver_info"]["location_name"] as String + " " + invokeOrder["receiver_info"]["door_plate_num"] as String)
        orderDeliveryInfo.setGeoPoiLocation(new GeoPoiLocation(invokeOrder["receiver_info"]["lng"] as double, invokeOrder["receiver_info"]["lat"] as double))
        orderDeliveryInfo.setGeoLocationSerial(jsonConvert.convertTo(orderDeliveryInfo.geoPoiLocation))
        orderDeliveryInfo.setReceiveMan(invokeOrder["receiver_info"]["receiver_name"] as String)
        orderDeliveryInfo.setContractPhone(invokeOrder["receiver_info"]["secret_number"] as String + "(" + invokeOrder["receiver_info"]["receiver_phone"] as String + ")")
        orderDeliveryInfo.setDeliverTimeliness(invokeOrder["order"]["is_book"] as int - 1) //抖音1表示即时单,2表示预订单
        orderDeliveryInfo.setBookingDeliverTimeLong(suggestTimeLong * 1000)
        orderDeliveryInfo.setBookingDeliverTime(new Date(orderDeliveryInfo.bookingDeliverTimeLong))
        orderDeliveryInfo.setCustomerMemo(invokeOrder["order"]["remark"] as String)
        OrderDeliveryInfo.create(orderDeliveryInfo, currentUser.id)

        businessOrder.setOrderDeliveryInfo(orderDeliveryInfo)

        //订单明细详情
        List<OrderDetailItem> itemList = new ArrayList<>()
        long itemId = tableIdService.getTableIdMulti("deOrderDetailItem.id", (invokeOrder["products"] as ArrayList).size(),
                dataSourceId, String.valueOf(supplierCode))
        (invokeOrder["products"] as ArrayList).each {
            OrderDetailItem item = new OrderDetailItem()
            item.setId(itemId)
            item.setIdOrder(businessOrder.id)
            item.setItemName(it["product_name"] as String)
            item.setItemCount(it["num"] as int)
            item.setItemMoney(it["origin_amount"] as BigDecimal)
            item.setItemDetail(jsonConvert.convertTo(it["commodities"]))
            OrderDetailItem.create(item, currentUser.id)

            itemList.add(item)
        }

        businessOrder.setDetailItemList(itemList)

        OrderStep orderStep = orderStepService.parseOrderStep(businessOrder.id, "顾客完成付款下单", "[抖音来客]", currentUser)

        //持久化
        //订单主表
        BulkRequestBuilder bulkRequest = esClient.getClient().prepareBulk().setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE)
        IndexRequestBuilder orderRequest = esClient.getClient()
                .prepareIndex(supplierInitService.getDateYearESIndex(supplierCode, ESKeys.ES_DELIVER_BUSINESS_ORDER_INDEX, 0),
                        ESKeys.ES_DELIVER_BUSINESS_ORDER_TYPE)
                .setId(String.valueOf(businessOrder.id))
                .setSource(orderConvertor.convertTo(businessOrder), XContentType.JSON)
        bulkRequest.add(orderRequest)
        //订单金额信息
        IndexRequestBuilder financesRequest = esClient.getClient()
                .prepareIndex(supplierInitService.getDateYearESIndex(supplierCode, ESKeys.ES_DELIVER_BUSINESS_ORDER_INDEX, 0),
                        ESKeys.ES_DELIVER_ORDER_FINANCES_TYPE)
                .setId(String.valueOf(orderFinances.id))
                .setParent(String.valueOf(orderFinances.idOrder))
                .setSource(jsonConvert.convertTo(orderFinances), XContentType.JSON)
        bulkRequest.add(financesRequest)

        //订单折扣信息
        discountList.each {
            IndexRequestBuilder discountRequest = esClient.getClient()
                    .prepareIndex(supplierInitService.getDateYearESIndex(supplierCode, ESKeys.ES_DELIVER_BUSINESS_ORDER_INDEX, 0),
                            ESKeys.ES_DELIVER_ORDER_DISCOUNT_TYPE)
                    .setId(String.valueOf(it.id))
                    .setParent(String.valueOf(it.idOrder))
                    .setSource(jsonConvert.convertTo(it), XContentType.JSON)
            bulkRequest.add(discountRequest)
        }

        //订单配送信息
        IndexRequestBuilder deliveryRequest = esClient.getClient()
                .prepareIndex(supplierInitService.getDateYearESIndex(supplierCode, ESKeys.ES_DELIVER_BUSINESS_ORDER_INDEX, 0),
                        ESKeys.ES_DELIVER_ORDER_DELIVERY_INFO_TYPE)
                .setId(String.valueOf(orderDeliveryInfo.id))
                .setParent(String.valueOf(orderDeliveryInfo.idOrder))
                .setSource(jsonConvert.convertTo(orderDeliveryInfo), XContentType.JSON)
        bulkRequest.add(deliveryRequest)
        //订单明细详情
        itemList.each {
            IndexRequestBuilder itemRequest = esClient.getClient()
                    .prepareIndex(supplierInitService.getDateYearESIndex(supplierCode, ESKeys.ES_DELIVER_BUSINESS_ORDER_INDEX, 0),
                            ESKeys.ES_DELIVER_ORDER_DETAIL_ITEM_TYPE)
                    .setId(String.valueOf(it.id))
                    .setParent(String.valueOf(it.idOrder))
                    .setSource(jsonConvert.convertTo(it), XContentType.JSON)
            bulkRequest.add(itemRequest)
        }
        //订单脚印
        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.<InvokeCallResult> errorT().retinfo("新建订单出错[抖音来客]:" + businessOrder.orderName);
        } else {
            logger.info("新建订单成功[抖音来客]");
            //写数据库
            orderDao.addBusinessOrder(businessOrder,
                    businessOrder.orderFinances,
                    businessOrder.orderDiscountList,
                    businessOrder.orderDeliveryInfo,
                    businessOrder.detailItemList,
                    [orderStep],
                    dataSourceId,
                    String.valueOf(supplierCode))
            return RetResult.<InvokeCallResult> successT()
        }
    }
}