方法的职责

@RestController
public class SmsReplyMsgNotify {
 
    @Autowired
    private CreateSmsModel createSmsModel;
    @Autowired
    private SmsDeliverManager smsDeliverManager;
    @Autowired
    private SmsDeliverBizService smsDeliverBizService;
 
    /**
     * 处理短信上行通知
     * @param request
     */
    @RequestMapping("/deliverMsg/{supplierFlag}")
    public String processRequest(@PathVariable("supplierFlag") String supplierFlag, HttpServletRequest request) {
        log.info("接收到短信上行的通知。 短信供应商={}", supplierFlag);
 
        SmsSupplierEnum supplierEnum = SmsSupplierEnum.getByReplyNotifyPath(supplierFlag);
        if(supplierEnum == null){
            log.error("短信上行通知，没有找到对应的供应商");
            throw new ResponseStatusException(HttpStatus.NOT_FOUND);
        }
 
        String supplierName = supplierEnum.getName();
        log.info("短信上行通知，找到对应的供应商：{}", supplierName);
        ISmsSDK supplierApi = createSmsModel.findSupplierApi(supplierName);
        Result<List<SmsDeliver>> notifyResult = supplierApi.handleReplyNotify(request);
        if(notifyResult.isSuccess()){
            List<SmsDeliver> smsDelivers = notifyResult.getResult();
            Integer count = smsDeliverManager.insertBatch(smsDelivers);
            log.info("{}短信上行通知，新增回调记录，准备新增数量：{}，实际新增数量：{}", supplierName, smsDelivers.size(), count);
 
            //通知业务系统
            for (SmsDeliver smsDeliver : smsDelivers) {
                String oneRecord;
                if(SmsSupplierEnum.MDSmsSDK == supplierEnum){
                    oneRecord = String.format("%s,%s,%s,%s,%s", smsDeliver.getExt(), smsDeliver.getSn(),
                            smsDeliver.getPhone(), smsDeliver.getContent(), DateUtil.formatDateTime(smsDeliver.getReceiveTime()));
                }else{
                    oneRecord = String.format("0,0,%s,%s,%s",
                            smsDeliver.getPhone(), smsDeliver.getContent(), DateUtil.formatDateTime(smsDeliver.getReceiveTime()));
                }
                smsDeliverBizService.notifyCaller(oneRecord, smsDeliver);
            }
        }
 
        log.info("{}短信上行通知处理完成", supplierName);
        return notifyResult.getMessage();
    }
 
}

@Component
public class SmsDeliverBizService {
 
    @Autowired
    private SmsReportManager smsReportManager;
    @Autowired
    private SmsSetingManager smsSetingManager;
 
 
    public void notifyCaller(String oneRecord, SmsDeliver deliverModel) {
        String content = deliverModel.getContent();
        if (StringUtils.isEmpty(content)) {
            return;
        }
 
        if (content.length() == 5) {
            String uri = notifyCallerNewMethod(deliverModel);
            log.info("短信上行通知-短信审批新通知地址：{}", uri);
            if (StringUtils.isEmpty(uri)) {
                return;
            }
            HttpUtil.get(uri, 100000);
        } else if (content.length() == 11) {
 
            ...
 
        } else {
            String uri = notifyCallerOldMethod(oneRecord);
            log.info("短信上行通知-短信审批旧通知地址：{}", uri);
            HttpUtil.get(uri, 100000);
        }
    }
 
    private String notifyCallerOldMethod(String oneRecord) {
        String url = smsSetingManager.findValue(SetingOptionConstant.SaasCallbackUrl);
        return url.replace("{0}", oneRecord);
    }
 
    // class中的其他方法（略）
}