|
|
@@ -35,10 +35,7 @@ import io.renren.modules.qyh.model.bo.PayForBO;
|
|
|
import io.renren.modules.qyh.model.dto.AuditDTO;
|
|
|
import io.renren.modules.qyh.model.dto.EnterpriseDTO;
|
|
|
import io.renren.modules.qyh.model.vo.EnterpriseVO;
|
|
|
-import io.renren.modules.qyh.service.AuditService;
|
|
|
-import io.renren.modules.qyh.service.EnterpriseService;
|
|
|
-import io.renren.modules.qyh.service.LoginVerificationService;
|
|
|
-import io.renren.modules.qyh.service.OrderService;
|
|
|
+import io.renren.modules.qyh.service.*;
|
|
|
import org.jdom.JDOMException;
|
|
|
import org.springframework.amqp.core.MessageProperties;
|
|
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
|
|
@@ -80,6 +77,8 @@ public class EnterpriseServiceImpl extends ServiceImpl<EnterpriseMapper, Enterpr
|
|
|
private RabbitTemplate rabbitTemplate;
|
|
|
@Autowired
|
|
|
private RedisUtils redisUtils;
|
|
|
+ @Autowired
|
|
|
+ private MemberWalletService memberWalletService;
|
|
|
|
|
|
@Override
|
|
|
public PageUtils queryPage(Map<String, Object> params) {
|
|
|
@@ -360,6 +359,9 @@ public class EnterpriseServiceImpl extends ServiceImpl<EnterpriseMapper, Enterpr
|
|
|
wxConsumeInfoEntity.setBusinessId(enterpriseEntity.getId());
|
|
|
wxConsumeInfoService.save(wxConsumeInfoEntity);
|
|
|
|
|
|
+ // 处理会员充值返佣
|
|
|
+ memberWalletService.handleRechargeCommission(orderEntity.getMemberId(), orderEntity.getId(), orderEntity.getActuallyPaid());
|
|
|
+
|
|
|
returnData.put("return_code", "SUCCESS");
|
|
|
returnData.put("return_msg", "OK");
|
|
|
|
