@@ -15,6 +15,7 @@ dependencies { | |||
implementation "${groupname}:comm-core:1.0.0-SNAPSHOT" | |||
implementation "${groupname}:sample-protocol:1.0.0-SNAPSHOT" | |||
implementation "${groupname}:ias-protocol:1.0.0-SNAPSHOT" | |||
implementation "${groupname}:ods-protocol:1.0.0-SNAPSHOT" | |||
implementation "${groupname}:smp-protocol:1.0.0-SNAPSHOT" | |||
implementation "com.alibaba.cloud:spring-cloud-starter-alibaba-nacos-discovery" | |||
implementation "com.alibaba.cloud:spring-cloud-starter-alibaba-nacos-config" |
@@ -7,8 +7,10 @@ import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse; | |||
import cn.com.taiji.core.model.comm.protocol.SignJsonRequest; | |||
import cn.com.taiji.core.model.comm.protocol.ias.IasServiceType; | |||
import cn.com.taiji.core.model.comm.protocol.ias.bill.*; | |||
import cn.com.taiji.core.model.comm.protocol.ias.order.OrderInitRequest; | |||
import cn.com.taiji.core.model.comm.protocol.ias.order.OrderServiceCmd; | |||
import cn.com.taiji.ias.manager.bill.BillBusinessManager; | |||
import cn.com.taiji.ias.manager.order.OrderInitManager; | |||
import com.zgglyun.common.model.AbstractHttpRequestInfo; | |||
import org.springframework.beans.factory.annotation.Autowired; | |||
import org.springframework.stereotype.Service; | |||
@@ -20,26 +22,14 @@ public class OrderServiceHandler extends AbstractIasServiceHandler<OrderServiceC | |||
} | |||
@Autowired | |||
private BillBusinessManager billBusinessManager; | |||
private OrderInitManager orderInitManager; | |||
@Override | |||
protected <T extends AbstractSignTypeRequest<?>> AbstractSignTypeResponse handleInternal(T request, SignJsonRequest jsonReq, AbstractHttpRequestInfo reqInfo) throws ServiceHandleException { | |||
BillServiceCmd cmd = BillServiceCmd.fromIfCode(jsonReq.getIfCode()); | |||
OrderServiceCmd cmd = OrderServiceCmd.fromIfCode(jsonReq.getIfCode()); | |||
switch (cmd) { | |||
case RAISEINSERT: | |||
return billBusinessManager.billRaiseInsert((BillRaiseInsertRequest) request,cmd.getTxCode()); | |||
case RAISEDELETE: | |||
return billBusinessManager.billRaiseDelete((BillRaiseDeleteRequest) request,cmd.getTxCode()); | |||
case RAISEUPDATE: | |||
return billBusinessManager.billRaiseUpdate((BillRaiseUpdateRequest) request,cmd.getTxCode()); | |||
case RECORD: | |||
return billBusinessManager.billRecord((BillRecordRequest) request,cmd.getTxCode()); | |||
case REVERSAL: | |||
return billBusinessManager.billReversal((BillReversalRequest) request,cmd.getTxCode()); | |||
case MERGEINVOICING: | |||
return billBusinessManager.billMergeInvoicing((BillMergeInvoicingRequest) request,cmd.getTxCode()); | |||
case ORDERPUSH: | |||
return billBusinessManager.billOrderPush((BillOrderPushLogRequest) request); | |||
case INIT: | |||
return orderInitManager.serviceHandle((OrderInitRequest)request, jsonReq.getIfCode(), jsonReq.getReqId(), reqInfo); | |||
default: | |||
throw FileProtocolSystemError.NOT_SUPPORT.toHandleException(jsonReq.getIfCode()); | |||
} |
@@ -0,0 +1,36 @@ | |||
package cn.com.taiji.ias.manager.handler; | |||
import cn.com.taiji.common.manager.net.http.ServiceHandleException; | |||
import cn.com.taiji.common.model.file.FileProtocolSystemError; | |||
import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeRequest; | |||
import cn.com.taiji.core.model.comm.protocol.AbstractSignTypeResponse; | |||
import cn.com.taiji.core.model.comm.protocol.SignJsonRequest; | |||
import cn.com.taiji.core.model.comm.protocol.ias.IasServiceType; | |||
import cn.com.taiji.core.model.comm.protocol.ias.vaild.ValidServiceCmd; | |||
import cn.com.taiji.core.model.comm.protocol.ias.vaild.VehiclePlateCheckRequest; | |||
import cn.com.taiji.ias.manager.valid.VehiclePlateCheckManager; | |||
import com.zgglyun.common.model.AbstractHttpRequestInfo; | |||
import org.springframework.beans.factory.annotation.Autowired; | |||
import org.springframework.stereotype.Service; | |||
@Service | |||
public class ValidServiceHandler extends AbstractIasServiceHandler<ValidServiceCmd> { | |||
@Autowired | |||
private VehiclePlateCheckManager manager; | |||
public ValidServiceHandler() { | |||
super(IasServiceType.PORTAL); | |||
} | |||
@Override | |||
protected <T extends AbstractSignTypeRequest<?>> AbstractSignTypeResponse handleInternal(T request, SignJsonRequest jsonReq, AbstractHttpRequestInfo reqInfo) throws ServiceHandleException { | |||
ValidServiceCmd cmd = ValidServiceCmd.fromIfCode(jsonReq.getIfCode()); | |||
switch (cmd) { | |||
case VEHICLEPLATECHECK: | |||
return manager.serviceHandle((VehiclePlateCheckRequest) request); | |||
default: | |||
throw FileProtocolSystemError.NOT_SUPPORT.toHandleException(jsonReq.getIfCode()); | |||
} | |||
} | |||
} |
@@ -68,7 +68,7 @@ public abstract class AbstractOrderManager<T extends AbstractSignTypeRequest<?>> | |||
public void syncOrder(IssueOrderinfo order) throws ServiceHandleException { | |||
TransactionStatus transStatus = transactionManager.findByBizTypeAndBizId(ISSUE_ORDER_SYNC, order.getOrderNo()); | |||
IssueOrderinfoExt ext = orderInfoExtRepo.findByOrderNum(order.getOrderNo()); | |||
IssueOrderinfoExt ext = orderInfoExtRepo.findByOrderNo(order.getOrderNo()); | |||
logger.info("开始上传订单数据,{}", order.getOrderNo()); | |||
saveOldOrder(order, ext); | |||
logger.info("上传订单数据成功"); |
@@ -0,0 +1,16 @@ | |||
package cn.com.taiji.ias.manager.valid; | |||
import cn.com.taiji.common.manager.net.http.ServiceHandleException; | |||
import cn.com.taiji.core.model.comm.protocol.ias.vaild.VehiclePlateCheckRequest; | |||
import cn.com.taiji.core.model.comm.protocol.ias.vaild.VehiclePlateCheckResponse; | |||
import cn.com.taiji.ias.manager.portal.AbstractLoginManager; | |||
import org.springframework.stereotype.Service; | |||
@Service | |||
public class VehiclePlateCheckManager extends AbstractLoginManager { | |||
public VehiclePlateCheckResponse serviceHandle(VehiclePlateCheckRequest request) throws ServiceHandleException { | |||
return null; | |||
} | |||
} |