上海市接口-提交指令解析2

CZT

2023-08-18 e97e5cc1d6b14914ed2aa5cb281bfaeef78c7757

上海市接口-提交指令解析2

 src/main/java/com/fzzy/api/view/repository/Api1101Rep.java

@@ -7,6 +7,7 @@
import org.springframework.data.repository.query.Param;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.List;


@@ -31,4 +32,12 @@
     */
    @Query("from Api1101 where kqdm=:kqdm ")
    List<Api1101> findPushData(@Param("kqdm") String kqdm);

    /**
     * å•ä½ä¿¡æ¯
     * @param kqdm
     * @return
     */
    @Query("from Api1101 where kqdm=:kqdm and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Api1101> getDataByTime(@Param("kqdm") String kqdm, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/order/OrderApiService.java

@@ -1,6 +1,9 @@
package com.fzzy.order;

import com.fzzy.api.entity.ApiConfs;
import com.fzzy.order.data.OrderData;

import java.text.ParseException;

/**
 * æ ¹æ®åè®®è§£æžæŒ‡ä»¤
@@ -23,5 +26,5 @@
     * @throws Exception
     */

    public void execute(OrderData req, String orderType);
    public void execute(OrderData req, String orderType, ApiConfs apiConfs) throws ParseException;
}

 src/main/java/com/fzzy/order/OrderManager.java

@@ -5,6 +5,7 @@
import com.fzzy.api.view.pr.ApiConfsPR;
import com.fzzy.order.data.OrderData;
import com.fzzy.order.data.OrderReq;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
@@ -21,6 +22,7 @@
 * @author czt
 * @date 2023/8/17
 */
@Slf4j
@Component(OrderManager.BEAN_ID)
public class OrderManager implements ApplicationContextAware {
    public static final String BEAN_ID = "order.orderManager";
@@ -47,23 +49,29 @@
    @Async
    public void execute(OrderReq<JSONObject> req){

        //获取配置信息
        List<ApiConfs> apiConfList = apiConfsPR.listAll();
        if(null == apiConfList || apiConfList.isEmpty()){
            return;
        }
        OrderData data = JSONObject.parseObject(req.getData().toString(), OrderData.class);

        //根据配置信息执行
        OrderApiService service;
        for (ApiConfs apiConfs : apiConfList) {

            service = serviceMap.get(apiConfs.getPushProtocol());
            if(null == service){
                continue;
        try{
            //获取配置信息
            List<ApiConfs> apiConfList = apiConfsPR.listAll();
            if(null == apiConfList || apiConfList.isEmpty()){
                return;
            }
            OrderData data = JSONObject.parseObject(req.getData().toString(), OrderData.class);

            service.execute(data, req.getType());
            //根据配置信息执行
            OrderApiService service;
            for (ApiConfs conf : apiConfList) {

                service = serviceMap.get(conf.getPushProtocol());
                if(null == service){
                    continue;
                }

                service.execute(data, req.getType(), conf);
            }
        } catch (Exception e) {
            log.error("-----指令解析异常-----指令={}", req);
            e.printStackTrace();
        }

    }
}

 src/main/java/com/fzzy/push/sh2023/SH2023OrderApiServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,177 @@
package com.fzzy.push.sh2023;

import com.alibaba.fastjson.JSON;
import com.fzzy.api.Constant;
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.entity.ApiConfs;
import com.fzzy.order.OrderApiService;
import com.fzzy.order.data.OrderConstant;
import com.fzzy.order.data.OrderData;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import java.text.ParseException;

/**
 * ä¸Šæµ·å¸‚平台2023版-指令解析
 *
 * @author czt
 * @date 2023/08/17
 */
@Slf4j
public class SH2023OrderApiServiceImpl implements OrderApiService {

    @Autowired
    private SH2023ApiRemoteService apiRemoteService;
    @Autowired
    private SH2023PushService11 sh2023PushService11;
    @Autowired
    private SH2023PushService12 sh2023PushService12;
    @Autowired
    private SH2023PushService13 sh2023PushService13;
    @Autowired
    private SH2023PushService14 sh2023PushService14;

    @Override
    public String getProtocol() {
        return PushProtocol.SB_SH_2023.getCode();
    }


    @Override
    public void execute(OrderData req, String orderType, ApiConfs conf) throws ParseException {

        // è‹¥æŒ‡ä»¤ç±»åž‹ä¸ä¸º1，则返回
        if(!OrderConstant.ORDER_TYPE_1.equals(orderType)){
            return;
        }
        String ids = req.getContent();
        if(StringUtils.isEmpty(ids)){
            return;
        }

        ApiParam param = new ApiParam();
        param.setPushProtocol(conf.getPushProtocol());
        param.setKqdm(conf.getKqdm());
        param.setStart(DateUtils.parseDate(req.getStarttime(), new String[]{"yyyy-MM-dd HH:mm:ss"}));
        param.setEnd(DateUtils.parseDate(req.getEndtime(), new String[]{"yyyy-MM-dd HH:mm:ss"}));
        param.setDeptId(conf.getDeptId());

        String[] interfaces = ids.split(",");
        for (String inteId : interfaces) {
            param.setInteId(inteId);
            getDataToPush(param, inteId);
        }

    }

    private void getDataToPush(ApiParam param, String inteId) {
        param.setInteCategory(Constant.API_CATEGORY_11);
        param.setInteId(inteId);

        switch (inteId) {
            case "1101":
                sh2023PushService11.pushData1101(apiRemoteService, param);
            case "1102":
                sh2023PushService11.pushData1102(apiRemoteService, param);
            case "1103":
                sh2023PushService11.pushData1103(apiRemoteService, param);
            case "1104":
                sh2023PushService11.pushData1104(apiRemoteService, param);
            case "1105":
                sh2023PushService11.pushData1105(apiRemoteService, param);
            case "1106":
                sh2023PushService11.pushData1106(apiRemoteService, param);
            case "1107":
                sh2023PushService11.pushData1107(apiRemoteService, param);
            case "1108":
                sh2023PushService11.pushData1108(apiRemoteService, param);
            case "1109":
                sh2023PushService11.pushData1109(apiRemoteService, param);
            case "1110":
                sh2023PushService11.pushData1110(apiRemoteService, param);
            case "1111":
                sh2023PushService11.pushData1111(apiRemoteService, param);
            case "1112":
                sh2023PushService11.pushData1112(apiRemoteService, param);
            case "1113":
                sh2023PushService11.pushData1113(apiRemoteService, param);
            case "1114":
                sh2023PushService11.pushData1114(apiRemoteService, param);
            case "1201":
                sh2023PushService12.pushData1201(apiRemoteService, param);
            case "1202":
                sh2023PushService12.pushData1202(apiRemoteService, param);
            case "1203":
                sh2023PushService12.pushData1203(apiRemoteService, param);
            case "1204":
                sh2023PushService12.pushData1204(apiRemoteService, param);
            case "1205":
                sh2023PushService12.pushData1205(apiRemoteService, param);
            case "1206":
                sh2023PushService12.pushData1206(apiRemoteService, param);
            case "1207":
                sh2023PushService12.pushData1207(apiRemoteService, param);
            case "1208":
                sh2023PushService12.pushData1209(apiRemoteService, param);
            case "1209":
                sh2023PushService12.pushData1209(apiRemoteService, param);
            case "1210":
                sh2023PushService12.pushData1210(apiRemoteService, param);
            case "1211":
                sh2023PushService12.pushData1211(apiRemoteService, param);
            case "1212":
                sh2023PushService12.pushData1212(apiRemoteService, param);
            case "2101":
                sh2023PushService12.pushData2101(apiRemoteService, param);
            case "2102":
                sh2023PushService12.pushData2102(apiRemoteService, param);
            case "2104":
                sh2023PushService12.pushData2104(apiRemoteService, param);
            case "1301":
                sh2023PushService13.pushData1301(apiRemoteService, param);
            case "1302":
                sh2023PushService13.pushData1302(apiRemoteService, param);
            case "1303":
                sh2023PushService13.pushData1303(apiRemoteService, param);
            case "1304":
                sh2023PushService13.pushData1304(apiRemoteService, param);
            case "1305":
                sh2023PushService13.pushData1305(apiRemoteService, param);
            case "1306":
                sh2023PushService13.pushData1306(apiRemoteService, param);
            case "1307":
                sh2023PushService13.pushData1307(apiRemoteService, param);
            case "1308":
                sh2023PushService13.pushData1308(apiRemoteService, param);
            case "1309":
                sh2023PushService13.pushData1309(apiRemoteService, param);
            case "1310":
                sh2023PushService13.pushData1310(apiRemoteService, param);
            case "1311":
                sh2023PushService13.pushData1311(apiRemoteService, param);
            case "2103":
                sh2023PushService13.pushData2103(apiRemoteService, param);
            case "1401":
                sh2023PushService14.pushData1401(apiRemoteService, param);
            case "1402":
                sh2023PushService14.pushData1402(apiRemoteService, param);
            case "1403":
                sh2023PushService14.pushData1403(apiRemoteService, param);
            case "1404":
                sh2023PushService14.pushData1404(apiRemoteService, param);
            case "1405":
                sh2023PushService14.pushData1405(apiRemoteService, param);
            case "2203":
                sh2023PushService14.pushData2203(apiRemoteService, param);
            case "2204":
                sh2023PushService14.pushData2204(apiRemoteService, param);
            default:
                log.error("-----上海市平台：未匹配到接口编码，不推送-----");
        }

    }

}

 src/main/java/com/fzzy/push/sh2023/SH2023PushService11.java

@@ -36,6 +36,7 @@

    @Override
    public void pushData(ApiParam param) {

        log.info("------->>>>基础信息 æŽ¥å£æ¨¡å—上报开始");

        //推送单位信息
@@ -49,12 +50,13 @@
    /**
     * 1101 å•ä½ä¿¡æ¯
     */
    private void pushData1101(ApiRemoteService apiRemoteService, ApiParam param) {
    public void pushData1101(ApiRemoteService apiRemoteService, ApiParam param) {

        //TODO èŽ·å–单位信息
        List<Api1101> list = null;
        //获取单位信息
        List<Api1101> list = api1101Rep.getDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到单位信息，不推送-----");
            return;
        }

@@ -68,9 +70,112 @@
                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1101Rep.save(data);

                }
            }
        }
    }

    /**
     * 1102 åº“区信息
     */
    public void pushData1102(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1103  ä»“房信息
     */
    public void pushData1103(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1104  å»’间信息
     */
    public void pushData1104(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1105 è´§ä½ä¿¡æ¯
     */
    public void pushData1105(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1106 æ²¹ç½ä¿¡æ¯
     */
    public void pushData1106(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1107  è®¾å¤‡ä¿¡æ¯
     */
    public void pushData1107(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1108  è¯å‰‚信息
     */
    public void pushData1108(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1109  æ–‡ä»¶ä¿¡æ¯
     */
    public void pushData1109(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1110 åº“区图仓房点位标注
     */
    public void pushData1110(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1111 åº“区图视频监控设备点位标注
     */
    public void pushData1111(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1112  äººå‘˜ä¿¡æ¯
     */
    public void pushData1112(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1113  ä¼ä¸šä¿¡ç”¨ä¿¡æ¯
     */
    public void pushData1113(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1114  è´¢åŠ¡æŠ¥è¡¨
     */
    public void pushData1114(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }
}

 src/main/java/com/fzzy/push/sh2023/SH2023PushService12.java

@@ -2,6 +2,7 @@

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.PushService11;
import com.fzzy.push.impl.ComPushService11;
import lombok.extern.slf4j.Slf4j;
@@ -20,7 +21,7 @@


    @Autowired
    private ComPushService11 pushService;
    private SH2023ApiRemoteService apiRemoteService;

    @Override
    public String getProtocol() {
@@ -36,4 +37,124 @@

        log.info("------->>>>基础信息 æŽ¥å£æ¨¡å—上报结束");
    }

    /**
     * 1201 åˆåŒä¿¡æ¯
     */
    public void pushData1201(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1202 ç²®é£Ÿå…¥åº“信息
     */
    public void pushData1202(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1203 ç²®é£Ÿå…¥åº“检验信息
     */
    public void pushData1203(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1204 ç²®é£Ÿå…¥åº“结算信息
     */
    public void pushData1204(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1205 ç²®é£Ÿå‡ºåº“信息
     */
    public void pushData1205(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1206 ç²®é£Ÿå‡ºåº“结算信息
     */
    public void pushData1206(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1207 å€’仓倒出
     */
    public void pushData1207(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1208 ç²®é£Ÿåº“å­˜
     */
    public void pushData1208(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1209 æŸæº¢å•
     */
    public void pushData1209(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1210 ç²®é£Ÿæ€§è´¨è½¬å˜å•
     */
    public void pushData1210(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1211 è´¦é¢åº“å­˜
     */
    public void pushData1211(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1212 å®¢æˆ·ä¿¡æ¯
     */
    public void pushData1212(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 2101 æ£€æ–¤å•
     */
    public void pushData2101(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 2102 å€’仓倒入
     */
    public void pushData2102(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 2104  å¸‚储驳运单
     */
    public void pushData2104(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }
}

 src/main/java/com/fzzy/push/sh2023/SH2023PushService13.java

@@ -2,6 +2,7 @@

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.PushService11;
import com.fzzy.push.impl.ComPushService11;
import lombok.extern.slf4j.Slf4j;
@@ -20,7 +21,7 @@


    @Autowired
    private ComPushService11 pushService;
    private SH2023ApiRemoteService apiRemoteService;

    @Override
    public String getProtocol() {
@@ -36,4 +37,100 @@

        log.info("------->>>>基础信息 æŽ¥å£æ¨¡å—上报结束");
    }

    /**
     * 1301 å®‰å…¨ç®¡ç†
     */
    public void pushData1301(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1302 æ¸©æ¹¿åº¦æ£€æµ‹
     */
    public void pushData1302(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1303 å®³è™«æ£€æµ‹
     */
    public void pushData1303(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1304 æ°”体检测
     */
    public void pushData1304(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1305 é€šé£Žä½œä¸š
     */
    public void pushData1305(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1306 ç†è’¸ä½œä¸š
     */
    public void pushData1306(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1307 ä»“内视频图像
     */
    public void pushData1307(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1308 è§†é¢‘监控异常事件告警
     */
    public void pushData1308(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1309 è¿è§„预警信息
     */
    public void pushData1309(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1310 è´¨æ£€æ•°æ®
     */
    public void pushData1310(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1311 è§†é¢‘监控接口
     */
    public void pushData1311(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 2103 ç²®æƒ…设备配置
     */
    public void pushData2103(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }
}

 src/main/java/com/fzzy/push/sh2023/SH2023PushService14.java

@@ -2,8 +2,8 @@

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.PushService11;
import com.fzzy.push.impl.ComPushService11;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -20,7 +20,7 @@


    @Autowired
    private ComPushService11 pushService;
    private SH2023ApiRemoteService apiRemoteService;

    @Override
    public String getProtocol() {
@@ -36,4 +36,59 @@

        log.info("------->>>>基础信息 æŽ¥å£æ¨¡å—上报结束");
    }

    /**
     * 1401 å‚¨å¤‡è§„模
     */
    public void pushData1401(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1402 å‚¨å¤‡è®¡åˆ’信息
     */
    public void pushData1402(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1403 è½®æ¢è®¡åˆ’信息
     */
    public void pushData1403(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 1404 è½®æ¢è®¡åˆ’明细信息
     */
    public void pushData1404(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }
    /**
     * 1405 é¡¹ç›®ä¿¡æ¯
     */
    public void pushData1405(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 2203 äº¤æ˜“中心合同
     */
    public void pushData2203(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }

    /**
     * 2204 å®šåŒ–水检验
     */
    public void pushData2204(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

    }
}

 src/main/java/com/fzzy/push/whhpjl/WhjlOrderApiServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,29 @@
package com.fzzy.push.whhpjl;

import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.entity.ApiConfs;
import com.fzzy.order.OrderApiService;
import com.fzzy.order.data.OrderData;

/**
 * ä¸Šæ­¦æ±‰å†›ç²®å¹³å°2023版-指令解析
 *
 * @author czt
 * @date 2023/08/17
 */
public class WhjlOrderApiServiceImpl implements OrderApiService {

    @Override
    public String getProtocol() {
        return PushProtocol.SB_WHJL_2023.getCode();
    }


    @Override
    public void execute(OrderData req, String orderType, ApiConfs apiConfs) {

        //TODO å¾…实现

    }

}