package com.fzzy.push.shjdjw2023; import com.fzzy.api.data.ApiParam; import com.fzzy.api.data.PushProtocol; import com.fzzy.api.entity.ApiConfs; import com.fzzy.order.common.OrderCommonService; import com.fzzy.order.common.data.OrderCommonConstant; import com.fzzy.order.common.data.OrderCommonData; import com.fzzy.push.impl.ComPushService11; import com.fzzy.push.impl.ComPushService12; import com.fzzy.push.impl.ComPushService13; import com.fzzy.push.impl.ComPushService14; 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 org.springframework.stereotype.Service; import java.text.ParseException; /** * 上海嘉定纪委接口指令上报-仅测试使用 * * @Description * @Author CZT * @Date 2024/9/25 9:36 */ @Slf4j @Service public class Shjdjw2023OrderServiceImpl implements OrderCommonService { @Autowired private ShjdjwApiRemoteService2023 apiRemoteService; @Autowired private ComPushService11 pushService11; @Autowired private ComPushService12 pushService12; @Autowired private ComPushService13 pushService13; @Autowired private ComPushService14 pushService14; @Override public String getProtocol() { return PushProtocol.SB_SHJdJW_2023.getCode(); } @Override public void execute(OrderCommonData req, String orderType, ApiConfs conf, String orderid) throws ParseException { // 若指令类型不为1,则返回 if(!OrderCommonConstant.ORDER_TYPE_1.equals(orderType)){ log.error("指令类型不为1,不进行数据上报={}", req); return; } String ids = req.getContent(); if(StringUtils.isEmpty(ids)){ log.error("指令接口为空,不进行数据上报={}", req); 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()); log.info("接收的指令中接口内容为={}", req.getContent()); String[] interfaces = ids.split(";"); for (String inteId : interfaces) { log.info("执行接口={}的数据上报", inteId); getDataToPush(param, inteId); } } private void getDataToPush(ApiParam param, String inteId) { switch (inteId) { case "1101": pushService11.pushData1101(apiRemoteService, param); break; case "1102": pushService11.pushData1102(apiRemoteService, param); break; case "1103": pushService11.pushData1103(apiRemoteService, param); break; case "1104": pushService11.pushData1104(apiRemoteService, param); break; case "1105": pushService11.pushData1105(apiRemoteService, param); break; case "1202": pushService12.pushData1202(apiRemoteService, param); break; case "1203": pushService12.pushData1203(apiRemoteService, param); break; case "1205": pushService12.pushData1205(apiRemoteService, param); break; case "1209": pushService12.pushData1209(apiRemoteService, param); break; case "1310": pushService13.pushData1310(apiRemoteService, param); break; case "1403": pushService14.pushData1403(apiRemoteService, param); break; case "1404": pushService14.pushData1404(apiRemoteService, param); break; default: log.error("-----嘉定纪委平台:未匹配到接口编码,不推送-----"); break; } } }