修复 定时上下线bug

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/kylin/KylinPerformancesController.java

@@ -4,8 +4,10 @@ package com.liquidnet.service.platform.controller.kylin;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.kylin.dto.vo.KylinTimePerformanceVo;
 import com.liquidnet.service.kylin.dto.vo.PerformanceOrderStatisticalVo;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
 import com.liquidnet.service.kylin.service.partner.IKylinPerformancesPartnerService;
 import com.liquidnet.service.platform.utils.PerformanceVoTask;
+import com.mongodb.BasicDBObject;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiResponse;
@@ -14,6 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.web.bind.annotation.*;
 
 import javax.validation.constraints.NotNull;
@@ -70,6 +73,11 @@ public class KylinPerformancesController {
                         performancesPartnerService.outLinePerformance(item.getPerformanceId());
                         log.info("[FINISH OUT LINE TASK] performanceId = " + item.getPerformanceId() + " time = " + item.getTime());
                     }
+                    if (item.getTaskType() != 0) {
+                        mongoTemplate.getCollection(KylinTimePerformanceVo.class.getSimpleName()).updateMany(
+                                Query.query(Criteria.where("performanceId").is(item.getPerformanceId())).getQueryObject(),
+                                Update.update("taskType", 0).getUpdateObject());
+                    }
                 }
             }
             return ResponseDto.success(true);