pco/sp-server/src/main/java/com/pj/project/sync/SyncService.java

package com.pj.project.sync;

import cn.hutool.json.JSONUtil;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.pj.current.config.PushfeeConfig;
import com.pj.project.sync.bo.*;
import com.pj.project.sync.dto.IExpensePriceReq;
import com.pj.project.sync.dto.ItemTypeDTO;
import com.pj.project.sync.dto.PartnerDTO;
import com.pj.project.sync.dto.PartnerParam;
import com.pj.project.sync.dto.item.IFactorItem;
import com.pj.project.sync.request.IOrderPriceReq;
import com.pj.project.sync.request.item.IOrderItem;
import com.pj.project.sync.response.IExpensePriceRes;
import com.pj.project.sync.response.IOrderPriceRes;
import com.pj.project.sync.response.item.IExpenseItem;
import com.pj.utils.sg.AjaxError;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.Collections;
import java.util.List;

@Service
@Slf4j
public class SyncService {
    @Resource
    private PushfeeConfig pushfeeConfig;
    @Resource
    private HelpService helpService;
    private static final Gson gson = new GsonBuilder().disableHtmlEscaping().create();

    /**
     * 同步合作伙伴
     *
     * @param id
     * @param name
     * @param syncType
     */
    @Async
    public void syncPartnes(String id, String name, String syncType) {
        log.info("sync partner:{},{},{}",id,name,syncType);
        PartnerParam dto = new PartnerParam(id, name, syncType);
        List<PartnerParam> list = Collections.singletonList(dto);
        PartnerDTO partnerDTO = new PartnerDTO();
        partnerDTO.setPartnersList(list);
        helpService.req("/data/sync/partners", partnerDTO);
    }

    @Async
    public void syncPartnes(  PartnerDTO partnerDTO ) {
        log.info("sync partner:{}",JSONUtil.toJsonStr(partnerDTO));
        helpService.req("/data/sync/partners", partnerDTO);
    }

    public List<IExpenseItem> syncItemTypeList(String itemTypeName, String itemCode) {
        ItemTypeDTO dto = new ItemTypeDTO();
        dto.setSysId(pushfeeConfig.getSysId()).setBizTypeNo(itemCode).setExpenseName(itemTypeName);
        SyncResultBO resultBO = helpService.req("/price/external/expense/list", dto);
        IExpenseListQueryRes res = helpService.deCrypte(resultBO.getData(), IExpenseListQueryRes.class);
        return res.getList();

    }

    /**
     * 费项价格计算
     *
     * @param uniqExpenseId
     * @param num
     * @param factorItems
     * @return
     */
    public IExpensePriceRes calItemPrice(String uniqExpenseId, int num, List<IFactorItem> factorItems) {
        IExpensePriceReq iExpensePriceReq = new IExpensePriceReq();
        iExpensePriceReq.setUniqExpenseId(uniqExpenseId)
                .setExpenseNum(num)
                .setFactors(factorItems);
        SyncResultBO resultBO = helpService.req("/price/external/expense/price", iExpensePriceReq);
        if (resultBO.getCode() == 200) {
            IExpensePriceRes res = helpService.deCrypte(resultBO.getData(), IExpensePriceRes.class);
            return res;
        }
        throw new AjaxError("计算费用出错");
    }

    /**
     * 计费规则
     * let standard = 30;
     * let extraPrice=40;
     * let overStandard = floor(hour/24) * extraPrice;
     * let total = standard + overStandard;
     * return total;
     * 订单计算接口
     * @param expenses
     */
    public IOrderPriceRes orderPriceCal(  List<IOrderItem> expenses ){
        log.info("order price:{}",JSONUtil.toJsonStr(expenses));
        IOrderPriceReq iOrderPriceReq=new IOrderPriceReq();
        iOrderPriceReq.setSysId(pushfeeConfig.getSysId()).setExpenses(expenses).setOrderNum(1);
        SyncResultBO resultBO = helpService.req("/price/external/order/calc", iOrderPriceReq);
        if (resultBO.getCode() == 200) {
            return  helpService.deCrypte(resultBO.getData(), IOrderPriceRes.class);
        }
        throw new AjaxError(resultBO.getMsg());
    }

}