暂时提交

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/partner/KylinCheckUserPartnerServiceImpl.java

@@ -10,14 +10,12 @@ import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.dao.ChildDetailsDao;
 import com.liquidnet.service.kylin.dao.ChildListDao;
-import com.liquidnet.service.kylin.dto.vo.CheckUserVo;
-import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketTimesPartnerVo;
+import com.liquidnet.service.kylin.dto.vo.KylinCheckUserVo;
 import com.liquidnet.service.kylin.entity.KylinCheckUser;
 import com.liquidnet.service.kylin.mapper.KylinCheckUserMapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.liquidnet.service.kylin.service.partner.IKylinCheckUserPartnerService;
 import com.mongodb.BasicDBObject;
-import org.apache.tomcat.jni.Local;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
@@ -79,7 +77,7 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
 //            mongoTemplate.getCollection(CheckUserVo.class.getSimpleName()).updateOne(
 //                    Query.query(Criteria.where("checkUserId").is(checkUserId)).getQueryObject(),
 //                    obj
-            mongoTemplate.remove(Query.query(Criteria.where("checkUserId").is(checkUserId)), CheckUserVo.class, CheckUserVo.class.getSimpleName());
+            mongoTemplate.remove(Query.query(Criteria.where("checkUserId").is(checkUserId)), KylinCheckUserVo.class, KylinCheckUserVo.class.getSimpleName());
             return ResponseDto.success("删除成功");
         } catch (Exception e) {
             return ResponseDto.failure(ErrorMapping.get(20102));
@@ -99,9 +97,9 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
             checkUser.setStatus(1);
             checkUserMapper.insert(checkUser);
 
-            CheckUserVo checkUserVo = new CheckUserVo();
-            BeanUtils.copyProperties(checkUser, checkUserVo);
-            mongoTemplate.insert(checkUserVo, CheckUserVo.class.getSimpleName());
+            KylinCheckUserVo kylinCheckUserVo = new KylinCheckUserVo();
+            BeanUtils.copyProperties(checkUser, kylinCheckUserVo);
+            mongoTemplate.insert(kylinCheckUserVo, KylinCheckUserVo.class.getSimpleName());
 
             return ResponseDto.success("添加成功");
         } catch (Exception e) {
@@ -121,7 +119,7 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
             checkUser.setUpdatedAt(LocalDateTime.now());
             checkUserMapper.update(checkUser, new UpdateWrapper<KylinCheckUser>().eq("check_user_id", checkUserId).eq("merchant_id", merchantId));
             BasicDBObject obj = new BasicDBObject("$set", mongoConverter.convertToMongoType(checkUser));
-            mongoTemplate.getCollection(CheckUserVo.class.getSimpleName()).updateOne(
+            mongoTemplate.getCollection(KylinCheckUserVo.class.getSimpleName()).updateOne(
                     Query.query(Criteria.where("checkUserId").is(checkUserId)).getQueryObject(),
                     obj
             );

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/partner/KylinCheckUserPerformancesPartnerServiceImpl.java

@@ -9,7 +9,8 @@ import com.liquidnet.service.base.ErrorMapping;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.dao.ChildPerformanceDao;
-import com.liquidnet.service.kylin.dto.vo.CheckUserPerformanceVo;
+import com.liquidnet.service.kylin.dto.param.CheckPerformanceRelationParam;
+import com.liquidnet.service.kylin.dto.vo.KylinCheckUserPerformanceVo;
 import com.liquidnet.service.kylin.entity.KylinCheckUserPerformances;
 import com.liquidnet.service.kylin.mapper.KylinCheckUserPerformancesMapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -73,25 +74,25 @@ public class KylinCheckUserPerformancesPartnerServiceImpl extends ServiceImpl<Ky
     }
 
     @Override
-    public ResponseDto<String> setPerformance(List<String> performanceIds, String checkUserId, String canDownTime) {
+    public ResponseDto<String> setPerformance(List<CheckPerformanceRelationParam> param, String checkUserId) {
         try {
             List<String> performanceList = new ArrayList<>();
-            for (String performanceId : performanceIds) {
+            for (CheckPerformanceRelationParam item : param) {
                 KylinCheckUserPerformances checkUserPerformances = new KylinCheckUserPerformances();
                 checkUserPerformances.setCheckUserId(checkUserId);
-                checkUserPerformances.setCanDownTime(LocalDateTime.parse(canDownTime, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
-                checkUserPerformances.setPerformanceId(performanceId);
+                checkUserPerformances.setCanDownTime(LocalDateTime.parse(item.getCanDownTime(), DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+                checkUserPerformances.setPerformanceId(item.getPerformanceId());
                 checkUserPerformances.setCheckUserPerformanceId(IDGenerator.nextSnowId().toString());
                 checkUserPerformances.setCreatedAt(LocalDateTime.now());
                 checkUserPerformances.setStatus(1);
                 checkUserPerformancesMapper.insert(checkUserPerformances);
-                performanceList.add(performanceId);
+                performanceList.add(item.getPerformanceId());
             }
-            CheckUserPerformanceVo userPerformanceVo = new CheckUserPerformanceVo();
+            KylinCheckUserPerformanceVo userPerformanceVo = new KylinCheckUserPerformanceVo();
             userPerformanceVo.setCheckUserId(checkUserId);
             userPerformanceVo.setPerformanceList(performanceList);
-            mongoTemplate.remove(Query.query(Criteria.where("checkUserId").is(checkUserId)),CheckUserPerformanceVo.class,CheckUserPerformanceVo.class.getSimpleName());
-            mongoTemplate.insert(userPerformanceVo,CheckUserPerformanceVo.class.getSimpleName());
+            mongoTemplate.remove(Query.query(Criteria.where("checkUserId").is(checkUserId)), KylinCheckUserPerformanceVo.class, KylinCheckUserPerformanceVo.class.getSimpleName());
+            mongoTemplate.insert(userPerformanceVo, KylinCheckUserPerformanceVo.class.getSimpleName());
 
             redisUtil.hdel(KylinRedisConst.CHECK_USER_RELATION,checkUserId);
             return ResponseDto.success("添加成功");
@@ -108,11 +109,11 @@ public class KylinCheckUserPerformancesPartnerServiceImpl extends ServiceImpl<Ky
                 performanceList.add(performanceId);
                 checkUserPerformancesMapper.delete(new UpdateWrapper<KylinCheckUserPerformances>().eq("check_user_id", checkUserId).eq("performance_id", performanceId));
             }
-            CheckUserPerformanceVo userPerformanceVo = new CheckUserPerformanceVo();
+            KylinCheckUserPerformanceVo userPerformanceVo = new KylinCheckUserPerformanceVo();
             userPerformanceVo.setCheckUserId(checkUserId);
             userPerformanceVo.setPerformanceList(performanceList);
-            mongoTemplate.remove(Query.query(Criteria.where("checkUserId").is(checkUserId)),CheckUserPerformanceVo.class,CheckUserPerformanceVo.class.getSimpleName());
-            mongoTemplate.insert(userPerformanceVo,CheckUserPerformanceVo.class.getSimpleName());
+            mongoTemplate.remove(Query.query(Criteria.where("checkUserId").is(checkUserId)), KylinCheckUserPerformanceVo.class, KylinCheckUserPerformanceVo.class.getSimpleName());
+            mongoTemplate.insert(userPerformanceVo, KylinCheckUserPerformanceVo.class.getSimpleName());
             redisUtil.hdel(KylinRedisConst.CHECK_USER_RELATION,checkUserId);
             return ResponseDto.success("删除成功");
         }catch (Exception e){