zouxuan 5 years ago
parent
commit
e93413f886

+ 9 - 0
src/main/java/com/ym/mec/collectfee/controller/UserController.java

@@ -197,4 +197,13 @@ public class UserController extends BaseController {
         applyInfoService.pushRenew(renewBean);
         return succeed();
     }
+
+    /**
+     * 查询mec用户信息
+     * @return
+     */
+    @PostMapping("/findMecUser")
+    public Object findMecUser(Integer userId){
+        return succeed(applyInfoService.findMecUser(userId));
+    }
 }

+ 8 - 4
src/main/java/com/ym/mec/collectfee/service/ApplyInfoService.java

@@ -1,10 +1,7 @@
 package com.ym.mec.collectfee.service;
 
 import com.ym.mec.collectfee.common.service.BaseService;
-import com.ym.mec.collectfee.entity.ApplyInfo;
-import com.ym.mec.collectfee.entity.Branch;
-import com.ym.mec.collectfee.entity.RenewBean;
-import com.ym.mec.collectfee.entity.StudentsQueryInfo;
+import com.ym.mec.collectfee.entity.*;
 
 import java.util.List;
 
@@ -57,6 +54,13 @@ public interface ApplyInfoService extends BaseService<Integer, ApplyInfo> {
     Object queryUserCourse(Integer userId);
 
     /**
+     * 查询mec用户信息
+     * @param userId
+     * @return
+     */
+    MecUser findMecUser(Integer userId);
+
+    /**
      * 推送续费成功订单到mec
      * @param orderId 订单编号
      * @param chargeMode 收费方式

+ 23 - 11
src/main/java/com/ym/mec/collectfee/service/impl/ApplyInfoServiceImpl.java

@@ -218,17 +218,7 @@ public class ApplyInfoServiceImpl extends BaseServiceImpl<Integer, ApplyInfo> im
 	public Object queryUserCourse(Integer userId) {
 		try {
 			//获取学员信息
-			MecUser mecUser = mecUserDao.get(userId);
-			if(mecUser == null){
-				String body = "<body><userId>" + userId + "</userId></body>";
-				body = getBody(body, 121313);
-				if(!StringUtils.isEmpty(body)){
-					body = new String(Base64.getDecoder().decode(body));
-					mecUser = XStreamUtil.xmlToObject("student", MecUser.class, body);
-					//同步mec用户数据
-					mecUserDao.insert(mecUser);
-				}
-			}
+			findMecUser(userId);
 			//获取学员课程班数据
 			//1小课,2乐团
 			String body = "<body><userId>" + userId + "</userId><classType>1</classType></body>";
@@ -258,6 +248,28 @@ public class ApplyInfoServiceImpl extends BaseServiceImpl<Integer, ApplyInfo> im
 	}
 
 	@Override
+	public MecUser findMecUser(Integer userId) {
+		try {
+			//获取学员信息
+			MecUser mecUser = mecUserDao.get(userId);
+			if(mecUser == null){
+				String body = "<body><userId>" + userId + "</userId></body>";
+				body = getBody(body, 121313);
+				if(!StringUtils.isEmpty(body)){
+					body = new String(Base64.getDecoder().decode(body));
+					mecUser = XStreamUtil.xmlToObject("student", MecUser.class, body);
+					//同步mec用户数据
+					mecUserDao.insert(mecUser);
+				}
+			}
+			return mecUser;
+		}catch (Exception e){
+			e.printStackTrace();
+		}
+		return null;
+	}
+
+	@Override
 	public boolean pushRenew(RenewBean renewBean) {
 		try {
 			XStream xs = new XStream();