订单企微支付成功处理激活码

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/licence/LicenceOrderApiServiceImpl.java

@@ -9,6 +9,7 @@ import com.gic.api.base.commons.Page;
 import com.gic.api.base.commons.ServiceResponse;
 import com.gic.commons.util.DateUtil;
 import com.gic.commons.util.EntityUtil;
+import com.gic.commons.util.GICMQClientUtil;
 import com.gic.commons.util.UniqueIdUtils;
 import com.gic.enterprise.api.dto.EnterpriseDTO;
 import com.gic.enterprise.api.service.EnterpriseService;
@@ -31,6 +32,7 @@ import com.gic.haoban.manage.service.service.*;
 import com.gic.haoban.manage.service.service.licence.LicenceOrderProgressService;
 import com.gic.haoban.manage.service.service.licence.LicenceOrderService;
 import com.gic.haoban.manage.service.util.DingUtils;
+import com.gic.mq.sdk.GicMQClient;
 import com.gic.redis.data.util.RedisUtil;
 import com.gic.thirdparty.api.dto.RefundReqDataDTO;
 import com.gic.thirdparty.api.dto.RefundResDataDTO;
@@ -93,6 +95,7 @@ public class LicenceOrderApiServiceImpl implements LicenceOrderApiService {
     private StaffService staffService;
     @Autowired
     private TabHaobanRenewalUserService renewalUserService;
+    GicMQClient instance = GICMQClientUtil.getClientInstance();
 
     @Override
     public ServiceResponse<LicenceOrderDTO> getLicenceOrderDetail(Long orderId, Integer type) {
@@ -517,6 +520,13 @@ public class LicenceOrderApiServiceImpl implements LicenceOrderApiService {
                 activeDataDTO.setPurchased(purchased);
                 wxEnterpriseActiveDataService.updateByStaffActiveDataDTO(activeDataDTO);
             }
+
+            try {
+                logger.info("订单企微支付,处理激活码={}",order.getWxEnterpriseId());
+                instance.sendMessage("qywxAddFeeMq", order.getWxEnterpriseId());
+            } catch (Exception e) {
+                logger.info("发送消息处理异常：{}", e.getMessage(), e);
+            }
         }
         if ("license_refund".equals(infoType)) {
             if (order.getQywxRefundTime() != null) {