添加 默认验票员 bug修复

liquidnet-bus-api/liquidnet-service-slime-api/src/main/java/com/liquidnet/service/slime/dto/param/SlimeAuthorizationRecordParam.java

@@ -10,7 +10,7 @@ import java.util.List;
 
 @ApiModel(value = "SlimeAuthorizationRecordParam", description = "授权验票统计入参")
 @Data
-public class SlimeAuthorizationRecordParam implements java.io.Serializable{
+public class SlimeAuthorizationRecordParam implements java.io.Serializable,Cloneable{
     private static final long serialVersionUID = -673681507332688410L;
 
     @ApiModelProperty(position = 10, required = true, value = "演出ID")
@@ -33,4 +33,13 @@ public class SlimeAuthorizationRecordParam implements java.io.Serializable{
     @ApiModelProperty(position = 15, required = true, value = "授权权限")
     @NotEmpty
     private List<SlimeAuthorizationPermissionParam> permissions;
+
+    private static final SlimeAuthorizationRecordParam obj = new SlimeAuthorizationRecordParam();
+    public static SlimeAuthorizationRecordParam getNew() {
+        try {
+            return (SlimeAuthorizationRecordParam) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new SlimeAuthorizationRecordParam();
+        }
+    }
 }

liquidnet-bus-service/liquidnet-service-slime/liquidnet-service-slime-impl/src/main/java/com/liquidnet/service/slime/service/impl/SlimeFieldsServiceImpl.java

@@ -6,6 +6,11 @@ import com.liquidnet.service.base.ErrorMapping;
 import com.liquidnet.service.base.PagedResult;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
+import com.liquidnet.service.slime.constant.SlimeAuthorizationConst;
+import com.liquidnet.service.slime.dto.param.SlimeAuthorizationPermissionParam;
+import com.liquidnet.service.slime.dto.param.SlimeAuthorizationRecordParam;
+import com.liquidnet.service.slime.dto.vo.SlimeAuthorizationRecordsVo;
 import com.liquidnet.service.slime.dto.vo.SlimeFieldCheckersVo;
 import com.liquidnet.service.slime.dto.vo.SlimeFieldsDetailsVo;
 import com.liquidnet.service.slime.dto.vo.SlimeFieldsVo;
@@ -28,6 +33,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.time.LocalDateTime;
+import java.util.ArrayList;
 import java.util.LinkedList;
 import java.util.List;
 import java.util.regex.Pattern;
@@ -49,6 +55,9 @@ public class SlimeFieldsServiceImpl implements ISlimeFieldsService {
     @Autowired
     QueueUtil queueUtil;
 
+    @Autowired
+    SlimeAuthorizationRecordsServiceImpl authorizationRecordsService;
+
     @Override
     public PagedResult<SlimeFieldsVo> search(String name, int page, int size) {
         // 查询条件
@@ -214,6 +223,27 @@ public class SlimeFieldsServiceImpl implements ISlimeFieldsService {
         );
         log.debug("#MQ耗时:{}ms", System.currentTimeMillis() - s);
 
+
+        SlimeAuthorizationRecordParam param = SlimeAuthorizationRecordParam.getNew();
+        param.setMobile(mobile);
+        param.setName(name);
+        List<SlimeAuthorizationPermissionParam> list = new ArrayList<>();
+        SlimeAuthorizationPermissionParam permissionParam = SlimeAuthorizationPermissionParam.getNew();
+        permissionParam.setPermissionId(SlimeAuthorizationConst.PerformancePermission.CHECK.getId());
+        list.add(permissionParam);
+        param.setPermissions(list);
+        param.setUid(uid);
+        param.setUidRole("CHECKER");
+        List<KylinPerformanceVo> voList = mongoTemplate.find(Query.query(Criteria.where("fieldId").is("654336562571018243092042").and("appStatus").gte(3)), KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
+        for (KylinPerformanceVo item : voList) {
+            try {
+                param.setPerformanceId(item.getPerformancesId());
+                authorizationRecordsService.performanceRecordCheckerAdd(cuid, param);
+            } catch (Exception e) {
+                continue;
+            }
+        }
+
         return fieldCheckersVo.getFieldCheckerId();
     }
 
@@ -269,13 +299,19 @@ public class SlimeFieldsServiceImpl implements ISlimeFieldsService {
                 SqlMapping.gets(toMqSqls, fieldCheckerUpdateObjs)
         );
         log.debug("#MQ耗时:{}ms", System.currentTimeMillis() - s);
+
+        List<KylinPerformanceVo> voList = mongoTemplate.find(Query.query(Criteria.where("fieldId").is("654336562571018243092042").and("appStatus").gte(3)), KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
+        for (KylinPerformanceVo item : voList) {
+            SlimeAuthorizationRecordsVo vo = mongoTemplate.findOne(Query.query(Criteria.where("performanceId").is(item.getPerformancesId()).and("uidRole").is("CHECKER").and("uid").is(uid).and("cuid").is(cuid)), SlimeAuthorizationRecordsVo.class, SlimeAuthorizationRecordsVo.class.getSimpleName());
+            authorizationRecordsService.performanceRecordCheckerDel(cuid, vo.getAuthorizationRecordId());
+        }
     }
 
     @Override
     public SlimeFieldsDetailsVo fieldDetails(String fieldId) {
         SlimeFieldsVo vo = slimeRdmService.getFieldsVoByFieldId(fieldId);
         SlimeFieldsDetailsVo returnData = SlimeFieldsDetailsVo.getNew();
-        BeanUtils.copyProperties(vo,returnData);
+        BeanUtils.copyProperties(vo, returnData);
         return returnData;
     }