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("-----上海市平台:未匹配到接口编码,不推送-----"); } } }