提交获取指令功能

zhywpt-service-inss/src/main/java/cn/com/taiji/inss/manager/inst/InstOnlineActiveMananger.java

@@ -11,6 +11,7 @@ import cn.com.taiji.core.entity.invw.InvwCardDetails;
 import cn.com.taiji.core.entity.invw.InvwObuDetails;
 import cn.com.taiji.core.entity.issue.IssueOrderinfo;
 import cn.com.taiji.core.entity.issue.IssueProduct;
+import cn.com.taiji.core.manager.tools.issue.QdCallUtil;
 import cn.com.taiji.core.model.comm.protocol.inss.inst.InstCallBackRequest;
 import cn.com.taiji.core.model.comm.protocol.valid.GlyServiceError;
 import cn.com.taiji.core.repo.jpa.basic.*;
@@ -33,6 +34,9 @@ import static cn.com.taiji.core.entity.dict.issue.TransactionBizType.*;
 
 @Service
 public class InstOnlineActiveMananger extends AbstractCallBackManager {
+
+    @Autowired
+    private QdCallUtil qdCallUtil;
     @Autowired
     private QtkCardInfoRepo cardInfoRepo;
     @Autowired
@@ -260,6 +264,7 @@ public class InstOnlineActiveMananger extends AbstractCallBackManager {
             orderInfo.setUpdateTime(LocalDateTime.now());
         }
         orderInfoRepo.save(orderInfo);
+        //同步老库
         persistTransaction(ISSUE_ORDER_SYNC, vo.getOrderId(), "order");
     }
 
@@ -309,6 +314,7 @@ public class InstOnlineActiveMananger extends AbstractCallBackManager {
         if ("52010102005".equals(orderInfo.getAccountId()))
             cardInfo.setAccountId("52010102007");
         cardInfoRepo.save(cardInfo);
+        //同步老库
         persistTransaction(ISSUE_CARD_SYNC, vo.getOrderId(), "card");
         persistTransaction(ISSUE_CARD_UPLOAD, vo.getOrderId(), Operation.ADD.name());
         return cardInfo;
@@ -371,7 +377,10 @@ public class InstOnlineActiveMananger extends AbstractCallBackManager {
             obuInfo.setObuExpireTime(vo.getObuExpireTime());
         }
         obuInfoRepo.save(obuInfo);
+        //同步老库
         persistTransaction(ISSUE_OBU_SYNC, vo.getOrderId(), "obu");
         persistTransaction(ISSUE_OBU_UPLOAD, vo.getOrderId(), Operation.ADD.name());
+        //通知渠道
+        qdCallUtil.callBackQd(orderInfo, "");
     }
 }