| | |
| | | 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 com.fzzy.push.impl.*; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang.StringUtils; |
| | | import org.apache.commons.lang.time.DateUtils; |
| | |
| | | private ComPushService13 pushService13; |
| | | @Autowired |
| | | private ComPushService14 pushService14; |
| | | @Autowired |
| | | private ComPushService15 pushService15; |
| | | |
| | | @Override |
| | | public String getProtocol() { |
| | |
| | | |
| | | //指令存入缓存,时效24小时 |
| | | String key = RedisConst.buildKey(RedisConst.KYE_ORDER, conf.getKqdm()); |
| | | redisUtil.set(key, req, 59 * 60 * 24); |
| | | redisUtil.set(key, req.getOrderid(), 59 * 60 * 24); |
| | | |
| | | ApiParam param = new ApiParam(); |
| | | param.setPushProtocol(conf.getPushProtocol()); |
| | |
| | | break; |
| | | case "1112": |
| | | pushService11.pushData1112(apiRemoteService, param); |
| | | break; |
| | | case "1114": |
| | | pushService11.pushData1114(apiRemoteService, param); |
| | | break; |
| | | case "1201": |
| | | pushService12.pushData1201(apiRemoteService, param); |
| | |
| | | case "1310": |
| | | pushService13.pushData1310(apiRemoteService, param); |
| | | break; |
| | | case "1403": |
| | | pushService14.pushData1403(apiRemoteService, param); |
| | | break; |
| | | case "1404": |
| | | pushService14.pushData1404(apiRemoteService, param); |
| | | break; |
| | | case "2442": |
| | | pushService12.pushData1213(apiRemoteService, param); |
| | | break; |
| | | case "2443": |
| | | pushService15.pushData1504(apiRemoteService, param); |
| | | break; |
| | | case "2444": |
| | | pushService15.pushData1505(apiRemoteService, param); |
| | | break; |
| | | case "2445": |
| | | pushService15.pushData1506(apiRemoteService, param); |
| | | break; |
| | | case "2446": |
| | | pushService15.pushData1507(apiRemoteService, param); |
| | | break; |
| | | case "2447": |
| | | pushService15.pushData1508(apiRemoteService, param); |
| | | break; |
| | | case "2448": |
| | | pushService15.pushData1509(apiRemoteService, param); |
| | | break; |
| | | case "2449": |
| | | pushService15.pushData1510(apiRemoteService, param); |
| | | break; |
| | | default: |
| | | log.error("-----宁夏省平台:未匹配到接口编码,不推送-----"); |
| | | break; |