修改机场执行

tuoheng-admin/src/main/java/com/tuoheng/admin/service/impl/ThInspectionServiceImpl.java

@@ -22,6 +22,8 @@ import com.tuoheng.admin.service.IThInspectionService;
 import com.tuoheng.common.common.BaseServiceImpl;
 import com.tuoheng.common.exception.ServiceException;
 import com.tuoheng.common.utils.*;
+import com.tuoheng.system.entity.User;
+import com.tuoheng.system.mapper.UserMapper;
 import com.tuoheng.system.utils.ShiroUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
@@ -54,6 +56,9 @@ public class ThInspectionServiceImpl extends BaseServiceImpl<ThInspectionMapper,
     @Autowired
     private TenantMapper tenantMapper;
 
+    @Autowired
+    private UserMapper userMapper;
+
     @Autowired
     private RedisUtils redisUtils;
 
@@ -129,8 +134,9 @@ public class ThInspectionServiceImpl extends BaseServiceImpl<ThInspectionMapper,
     @Override
     public JsonResult executeTask(String missionId,PushAndPullURLRequest pushAndPull) throws ServiceException{
         log.info("executeTask准备就绪");
-        Tenant tenant = tenantMapper.selectById(ShiroUtils.getTenantId());
         ThMission thMission = missionMapper.selectById(Integer.parseInt(missionId));
+        User user = userMapper.selectById(thMission.getCreateUser());
+        Tenant tenant = tenantMapper.selectById(user.getTenantId());
         Assert.notNull(thMission,"任务不能为空！");
 
         //这边需要配置到yml文件里面