bug修改

src/main/java/com/zzsn/event/service/impl/SubjectServiceImpl.java

@@ -187,7 +187,9 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl
 
     @Override
     public void updateStatus(Subject subject) {
-        baseMapper.updateById(subject);
+        LambdaUpdateWrapper<Subject> updateWrapper = Wrappers.lambdaUpdate();
+        updateWrapper.set(Subject::getStatus,subject.getStatus()).eq(Subject::getId,subject.getId());
+        this.update(updateWrapper);
         CompletableFuture.runAsync(()->{
             Integer status = subject.getStatus();
             if (status == 1) {

src/main/java/com/zzsn/event/util/EsOpUtil.java

@@ -506,6 +506,7 @@ public class EsOpUtil<T> {
             request.doc(JSON.toJSONString(information), XContentType.JSON);
             bulkRequest.add(request);
         }
+        bulkRequest.setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);
         // 执行更新请求
         client.bulkAsync(bulkRequest, RequestOptions.DEFAULT, new ActionListener<BulkResponse>() {
             @Override