吴家粮库协议解析-1

jiazx0107@163.com

2023-12-29 dfe62588ca792d4a5eb3e2722675e7263aa46a4e

 src/main/java/com/fzzy/api/service/ApiTriggerService.java

@@ -4,17 +4,15 @@
import com.bstek.dorado.annotation.DataProvider;
import com.bstek.dorado.annotation.Expose;
import com.fzzy.api.Constant;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.data.SyncProtocol;
import com.fzzy.api.data.*;
import com.fzzy.api.entity.ApiTrigger;
import com.fzzy.api.utils.RedisConst;
import com.fzzy.api.utils.RedisUtil;
import com.fzzy.api.view.repository.ApiTriggerRep;

import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
@@ -35,10 +33,10 @@

    private String DEFAULT_MAP_KEY = "DEFAULT";

    @Autowired
    @Resource
    private RedisUtil redisUtil;

    @Autowired
    @Resource
    private ApiTriggerRep apiTriggerRep;


@@ -61,6 +59,7 @@
        }

    }

    public ApiTrigger findNameByCode(String code, String parentCode) {

        List<ApiTrigger> listParent = apiTriggerRep.findNameByCode(code, parentCode);
@@ -119,16 +118,16 @@
        String result = null;
        Map<String, String> parentMap = contextMap.get(parentCode);
        if (null == parentMap || parentMap.isEmpty()) {
            if(StringUtils.isEmpty(bizCode)){
            if (StringUtils.isEmpty(bizCode)) {
                return bizCode;
            }
            if(Constant.TRIGGER_P_LSPZ.equals(parentCode)){
                result = Integer.valueOf(bizCode)*1000000 + "";
                result = result.substring(0,7);
            }else if(Constant.TRIGGER_P_LSXZ.equals(parentCode)){
                result = Integer.valueOf(bizCode)*100 + "";
                result = result.substring(0,3);
            }else {
            if (Constant.TRIGGER_P_LSPZ.equals(parentCode)) {
                result = Integer.valueOf(bizCode) * 1000000 + "";
                result = result.substring(0, 7);
            } else if (Constant.TRIGGER_P_LSXZ.equals(parentCode)) {
                result = Integer.valueOf(bizCode) * 100 + "";
                result = result.substring(0, 3);
            } else {
                result = bizCode;
            }
            return result;
@@ -140,22 +139,37 @@
        }

        if (null == result) {
            if(StringUtils.isEmpty(bizCode)){
            if (StringUtils.isEmpty(bizCode)) {
                return bizCode;
            }
            if(Constant.TRIGGER_P_LSPZ.equals(parentCode)){
                result = Integer.valueOf(bizCode)*1000000 + "";
                result = result.substring(0,7);
            }else if(Constant.TRIGGER_P_LSXZ.equals(parentCode)){
                result = Integer.valueOf(bizCode)*100 + "";
                result = result.substring(0,3);
            }else {
            if (Constant.TRIGGER_P_LSPZ.equals(parentCode)) {
                result = Integer.valueOf(bizCode) * 1000000 + "";
                result = result.substring(0, 7);
            } else if (Constant.TRIGGER_P_LSXZ.equals(parentCode)) {
                result = Integer.valueOf(bizCode) * 100 + "";
                result = result.substring(0, 3);
            } else {
                result = bizCode;
            }
        }
        return result;
    }


    /**
     * 在线或者不在线
     * <p>
     * ${dorado.getDataProvider("apiTriggerService#triggerOnline").getResult()}
     *
     * @return
     */
    @DataProvider
    public List<ApiTrigger> triggerOnline() {
        List<ApiTrigger> list = new ArrayList<>();
        list.add(new ApiTrigger(Constant.YN_N,"离线"));
        list.add(new ApiTrigger(Constant.YN_Y,"在线"));
        return list;
    }

    /**
     * 页面下拉框使用，根据父编码获取，父编码的定注意在 @See Constant
@@ -177,16 +191,7 @@
     */
    @DataProvider
    public List<ApiTrigger> triggerPushProtocol() {
        List<ApiTrigger> list = new ArrayList<>();
        list.add(new ApiTrigger(PushProtocol.GB_DEFAULT.getCode(), PushProtocol.GB_DEFAULT.getName()));
        list.add(new ApiTrigger(PushProtocol.GB_2022.getCode(), PushProtocol.GB_2022.getName()));
        list.add(new ApiTrigger(PushProtocol.SB_SH_2021.getCode(), PushProtocol.SB_SH_2021.getName()));
        list.add(new ApiTrigger(PushProtocol.SB_SC_2021.getCode(), PushProtocol.SB_SC_2021.getName()));
        list.add(new ApiTrigger(PushProtocol.SB_GD_2022.getCode(), PushProtocol.SB_GD_2022.getName()));
        list.add(new ApiTrigger(PushProtocol.SB_GD_2020.getCode(), PushProtocol.SB_GD_2020.getName()));
        list.add(new ApiTrigger(PushProtocol.HB_FZZY_JG_2022.getCode(), PushProtocol.HB_FZZY_JG_2022.getName()));
        list.add(new ApiTrigger(PushProtocol.SB_SHJdJW_2023.getCode(), PushProtocol.SB_SHJdJW_2023.getName()));
        return list;
        return PushProtocol.listTrigger();
    }

    /**
@@ -197,12 +202,41 @@
     */
    @DataProvider
    public List<ApiTrigger> triggerSyncProtocol() {
        List<ApiTrigger> list = new ArrayList<>();
        list.add(new ApiTrigger(SyncProtocol.GB_DEFAULT.getCode(), SyncProtocol.GB_DEFAULT.getName()));
        list.add(new ApiTrigger(SyncProtocol.FZZY_V30_GB.getCode(), SyncProtocol.FZZY_V30_GB.getName()));
        list.add(new ApiTrigger(SyncProtocol.FZZY_V35_GB.getCode(), SyncProtocol.FZZY_V35_GB.getName()));
        list.add(new ApiTrigger(SyncProtocol.FZZY_V35_SHYZ.getCode(), SyncProtocol.FZZY_V35_SHYZ.getName()));
        return list;
        return SyncProtocol.listTrigger();
    }

    /**
     * ${dorado.getDataProvider("apiTriggerService#triggerGatewayProtocol").getResult()}
     * 系统与网关直接的通讯协议
     *
     * @return
     */
    @DataProvider
    public List<ApiTrigger> triggerGatewayProtocol() {
        return GatewayProtocol.listTrigger();
    }

    /**
     * ${dorado.getDataProvider("apiTriggerService#triggerGatewayDeviceProtocol").getResult()}
     * 系统与网关直接的通讯协议
     *
     * @return
     */
    @DataProvider
    public List<ApiTrigger> triggerGatewayDeviceProtocol() {
        return GatewayDeviceProtocol.listTrigger();
    }

    /**
     * ${dorado.getDataProvider("apiTriggerService#triggerGatewayDeviceType").getResult()}
     * 系统与网关直接的通讯协议
     *
     * @return
     */
    @DataProvider
    public List<ApiTrigger> triggerGatewayDeviceType() {
        return GatewayDeviceType.listTrigger();
    }


}