Parcourir la source

泛化及算法删除

wangzhiqiang il y a 2 ans
Parent
commit
18ae0c2a15
15 fichiers modifiés avec 143 ajouts et 47 suppressions
  1. 1 0
      api-common/src/main/java/api/common/pojo/param/scene/SceneAccidentParam.java
  2. 2 0
      api-common/src/main/java/api/common/pojo/param/scene/SceneGeneralTemplateParam.java
  3. 5 2
      simulation-resource-server/src/main/java/com/css/simulation/resource/algorithm/serviceImpl/AlgorithmServiceImpl.java
  4. 15 8
      simulation-resource-server/src/main/java/com/css/simulation/resource/scene/ctrl/ScoringRulesController.java
  5. 1 1
      simulation-resource-server/src/main/java/com/css/simulation/resource/scene/mapper/ScenePackageMapper.java
  6. 1 1
      simulation-resource-server/src/main/java/com/css/simulation/resource/scene/mapper/ScoringRulesMapper.java
  7. 1 0
      simulation-resource-server/src/main/java/com/css/simulation/resource/scene/service/SceneAccidentService.java
  8. 12 6
      simulation-resource-server/src/main/java/com/css/simulation/resource/scene/service/SceneGeneralExampleService.java
  9. 61 11
      simulation-resource-server/src/main/java/com/css/simulation/resource/scene/service/ScenePackageService.java
  10. 19 3
      simulation-resource-server/src/main/java/com/css/simulation/resource/scene/service/ScoringRulesService.java
  11. 8 6
      simulation-resource-server/src/main/resources/mapper/algorithm/AlgorithmMapper.xml
  12. 2 2
      simulation-resource-server/src/main/resources/mapper/scene/SceneAccidentMapper.xml
  13. 14 0
      simulation-resource-server/src/main/resources/mapper/scene/SceneGeneralTemplateMapper.xml
  14. 0 3
      simulation-resource-server/src/main/resources/mapper/scene/ScenePackageMapper.xml
  15. 1 4
      simulation-resource-server/src/main/resources/mapper/scene/ScoringRulesMapper.xml

+ 1 - 0
api-common/src/main/java/api/common/pojo/param/scene/SceneAccidentParam.java

@@ -43,5 +43,6 @@ public class SceneAccidentParam extends PageVO implements Serializable {
 
     private String[] ids ; //回显数组
     private String[] allSceneNames ; //场景名集合
+    private String share;
 
 }

+ 2 - 0
api-common/src/main/java/api/common/pojo/param/scene/SceneGeneralTemplateParam.java

@@ -28,4 +28,6 @@ public class SceneGeneralTemplateParam extends PageVO implements Serializable {
     private String[] ids ; //回显数组
     private String[] allSceneNames ; //场景名集合
 
+    private List<String> scenarioRoadType;//道路类型
+
 }

+ 5 - 2
simulation-resource-server/src/main/java/com/css/simulation/resource/algorithm/serviceImpl/AlgorithmServiceImpl.java

@@ -306,6 +306,7 @@ public class AlgorithmServiceImpl implements AlgorithmService {
         if (isEmpty(param.getId())) {
             return new ResponseBodyVO(ResponseBodyVO.Response.CLIENT_FAILURE);
         } else {
+            Map map =new HashMap();
             String algorithmId = param.getId();
             List<RunningProjectVO> runningParentProjectVos = algorithmMapper.selectRunningProjectParent(algorithmId);
             if (runningParentProjectVos != null && runningParentProjectVos.size() > 0) {
@@ -315,9 +316,11 @@ public class AlgorithmServiceImpl implements AlgorithmService {
                 }
 
                 String substring = stringBuffer.substring(0, stringBuffer.lastIndexOf(","));
-                return new ResponseBodyVO(ResponseBodyVO.Response.SUCCESS, "该算法已绑定ID:" + substring + " 自动运行项目,删除后该项目将停止自动运行");
+                map.put("substring",substring);
+                return new ResponseBodyVO(ResponseBodyVO.Response.SUCCESS, "该算法已绑定ID:" + substring + " 自动运行项目,删除后该项目将停止自动运行",map);
             } else {
-                return new ResponseBodyVO(ResponseBodyVO.Response.SUCCESS,"该算法未绑定自动运行项目");
+                map.put("substring","");
+                return new ResponseBodyVO(ResponseBodyVO.Response.SUCCESS,"该算法未绑定自动运行项目",map);
             }
         }
     }

+ 15 - 8
simulation-resource-server/src/main/java/com/css/simulation/resource/scene/ctrl/ScoringRulesController.java

@@ -61,12 +61,12 @@ public class ScoringRulesController {
     //查唯一
     @PostMapping("/queryScoringRulesCount")
     @ResponseBody
-    public ResponseBodyVO<List<ScoringRulesPO>> queryScoringRulesCount(@RequestBody ScoringRulesParam parms) {
+    public ResponseBodyVO<ScoringRulesPO> queryScoringRulesCount(@RequestBody ScoringRulesParam parms) {
         if (ObjectUtil.isNull(parms.getRuleName())) {
             return new ResponseBodyVO<>(ResponseBodyVO.Response.CLIENT_FAILURE, "参数RulesName不能为空,请检查");
         }
-        List<ScoringRulesPO> list = scoringRulesService.queryScoringRulesByRuleName(parms);
-        return new ResponseBodyVO<>(ResponseBodyVO.Response.SUCCESS, list);
+        ScoringRulesPO po = scoringRulesService.queryScoringRulesByRuleName(parms);
+        return new ResponseBodyVO<>(ResponseBodyVO.Response.SUCCESS, po);
     }
 
 
@@ -80,8 +80,8 @@ public class ScoringRulesController {
         BeanUtils.copyProperties(scoringRulesPO, vo);
         vo.setShare("0");
         //1 检查是否存在同名平分规则
-        List<ScoringRulesPO> list = scoringRulesService.queryScoringRulesByRuleName(vo);
-        if (list != null && list.size() > 0) {
+        ScoringRulesPO tmPo = scoringRulesService.queryScoringRulesByRuleName(vo);
+        if (ObjectUtil.isNotNull(tmPo)) {
             return new ResponseBodyVO<>(ResponseBodyVO.Response.CLIENT_FAILURE, "规则名称 ruleName 已存在,请重新命名。");
         }
         //2 校验 python 语法错误
@@ -116,9 +116,16 @@ public class ScoringRulesController {
         ScoringRulesPO po = scoringRulesService.queryScoringRules(params);
         params.setShare("1");
         params.setRuleName(po.getRuleName());
-        List<ScoringRulesPO> list = scoringRulesService.queryScoringRulesByRuleName(params);
-        if (list != null && list.size() > 0) {
+        ScoringRulesPO tmPo = scoringRulesService.queryScoringRulesByRuleName(params);
+       /* if (list != null && list.size() > 0) {
             return new ResponseBodyVO<>(ResponseBodyVO.Response.CLIENT_FAILURE, "规则名称ruleName已存在,请重新命名", "");
+        }*/
+
+        if (ObjectUtil.isNotNull(tmPo)) {
+            po.setShare("1");
+            po.setRulesId(tmPo.getRulesId());
+            scoringRulesService.updateScoringRules(po);
+            return new ResponseBodyVO<>(ResponseBodyVO.Response.SUCCESS);
         }
         po.setShare("1");
         scoringRulesService.saveScoringRules(po);
@@ -139,7 +146,7 @@ public class ScoringRulesController {
     public ResponseBodyVO<List<ScoringRulesPO>> queryCsb() {
         ScoringRulesParam params = new ScoringRulesParam();
         params.setShare("0");
-        List<ScoringRulesPO> list = scoringRulesService.queryScoringRulesList(params);
+        List<ScoringRulesPO> list = scoringRulesService.queryScoringRulesListCSB(params);
         return new ResponseBodyVO<>(ResponseBodyVO.Response.SUCCESS, list);
     }
 

+ 1 - 1
simulation-resource-server/src/main/java/com/css/simulation/resource/scene/mapper/ScenePackageMapper.java

@@ -27,7 +27,7 @@ public interface ScenePackageMapper {
     ScenePackageNewVO queryScenePackageBySublist(String packageId);
 
     //测试包名查唯一
-    List<ScenePackageNewVO> queryByPackageName(ScenePackagePO params);
+    ScenePackageNewVO queryByPackageName(ScenePackagePO params);
     //测试包数量
     Integer queryPackageCount(ScenePackagePO params);
 

+ 1 - 1
simulation-resource-server/src/main/java/com/css/simulation/resource/scene/mapper/ScoringRulesMapper.java

@@ -13,7 +13,7 @@ public interface ScoringRulesMapper {
 
     void saveScoringRules(ScoringRulesPO params);
 
-    List<ScoringRulesPO> queryScoringRulesByRuleName(ScoringRulesParam params);
+    ScoringRulesPO queryScoringRulesByRuleName(ScoringRulesParam params);
 
     List<ScoringRulesPO> queryScoringRulesList(ScoringRulesParam params);
     Integer queryCsbById(ScoringRulesParam params);

+ 1 - 0
simulation-resource-server/src/main/java/com/css/simulation/resource/scene/service/SceneAccidentService.java

@@ -712,6 +712,7 @@ public class SceneAccidentService {
                                     sceneAccidentPO.setSceneWeather(root.path("天气").asText());
                                     sceneAccidentPO.setMaxTime(root.path("max_time").asText());
                                     sceneAccidentPO.setIsDeleted("0");
+                                    sceneAccidentPO.setShare("0");
                                     if (ObjectUtil.isNull(sceneAccidentPO.getOsgbAddress())) {
                                         sceneAccidentPO.setOsgbAddress(osgbAdress);
                                     }

+ 12 - 6
simulation-resource-server/src/main/java/com/css/simulation/resource/scene/service/SceneGeneralExampleService.java

@@ -159,25 +159,29 @@ public class SceneGeneralExampleService {
         //远程调用接口
         Map map=  beanToMap(po);
         RequestConfig requestConfig = RequestConfig.custom()
-                .setSocketTimeout(6*10*1000)
-                .setConnectTimeout(6*10*1000)
-                .setConnectionRequestTimeout(6*10*1000)
+                .setSocketTimeout(2*60*1000)
+                .setConnectTimeout(2*60*1000)
+                .setConnectionRequestTimeout(2*6*10*1000)
                 .setRedirectsEnabled(false)
                 .setExpectContinueEnabled(false)
                 .build();
-
+       // log.info("测试是否调用成功---入参--"+map);
         String post = HttpUtil.post(HttpUtil.getHttpClient(), requestConfig, "http://47.94.105.148:5000/test_1.0", null, map);
-       Boolean success= JsonUtil.readTree(post).get("success").asBoolean();
+       //log.info("测试是否调用成功-----"+post);
+
+        Boolean success= JsonUtil.readTree(post).get("success").asBoolean();
        if(!success){
            String message= JsonUtil.readTree(post).get("message").toString();
            return new ResponseBodyVO(ResponseBodyVO.Response.CLIENT_FAILURE, message);
        }
         JsonNode params = JsonUtil.readTree(post).get("params");
+
         // 实例化 ObjectMapper 对象
         ObjectMapper objectMapper = new ObjectMapper();
         String newjson = objectMapper.writeValueAsString(params);
-        List<SceneGeneralDataPO>  list=JsonUtil.jsonToList(newjson,SceneGeneralDataPO.class);
 
+        List<SceneGeneralDataPO>  list=JsonUtil.jsonToList(newjson,SceneGeneralDataPO.class);
+        log.info("测试是否调用成功---444--"+list.size());
         String sceneGeneralizationIds=null;
         //生成指标id
         String sublistId=StringUtil.getRandomUUID();
@@ -218,6 +222,8 @@ public class SceneGeneralExampleService {
         map1.put("templateId",po.getTemplateId()); //模板id
         map1.put("sceneGeneralizationIds",sceneGeneralizationIds);//泛化场景数组
         map1.put("sublistId",sublistId); //指标id
+
+        log.info("测试是否调用成功---555555--"+map1);
         return new ResponseBodyVO(ResponseBodyVO.Response.SUCCESS, map1);
 
     }

+ 61 - 11
simulation-resource-server/src/main/java/com/css/simulation/resource/scene/service/ScenePackageService.java

@@ -2,8 +2,10 @@ package com.css.simulation.resource.scene.service;
 
 import api.common.pojo.common.ResponseBodyVO;
 import api.common.pojo.param.scene.ScenePackageParam;
+import api.common.pojo.param.scene.ScoringRulesParam;
 import api.common.pojo.po.scene.ScenePackagePO;
 import api.common.pojo.po.scene.ScenePackageSublistPO;
+import api.common.pojo.po.scene.ScoringRulesPO;
 import api.common.pojo.vo.scene.ScenePackageNewVO;
 import api.common.pojo.vo.scene.ScenePackageSublistVO;
 import api.common.util.LogUtil;
@@ -13,6 +15,7 @@ import api.common.util.TimeUtil;
 import com.css.simulation.resource.common.utils.AuthUtil;
 import com.css.simulation.resource.scene.mapper.ScenePackageMapper;
 import com.css.simulation.resource.scene.mapper.ScenePackageSublistMapper;
+import com.css.simulation.resource.scene.mapper.ScoringRulesMapper;
 import com.css.simulation.resource.system.service.ParameterService;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
@@ -32,6 +35,9 @@ public class ScenePackageService {
     private ScenePackageSublistMapper scenePackageSublistMapper;
     @Resource
     private ParameterService parameterService;
+    @Resource
+    private ScoringRulesMapper scoringRulesMapper;
+
 
     /**
      * 测试包数据录入大保存:
@@ -44,8 +50,8 @@ public class ScenePackageService {
             po.setPackageName(vo.getSublistName());
             po.setCreateUserId(AuthUtil.getCurrentUserId());
             po.setShare("0");
-            List<ScenePackageNewVO> listName = scenePackageMapper.queryByPackageName(po);
-            if (listName != null && listName.size() > 0) {
+            ScenePackageNewVO scenePackageNewVO  = scenePackageMapper.queryByPackageName(po);
+            if (ObjectUtil.isNotNull(scenePackageNewVO)) {
                 return new ResponseBodyVO(ResponseBodyVO.Response.CLIENT_FAILURE, "测试包名称:" + po.getPackageName() + "已存在,请重新命名");
             }
             po.setWeight(vo.getWeight());
@@ -109,8 +115,8 @@ public class ScenePackageService {
             po.setCreateUserId(AuthUtil.getCurrentUserId());
             po.setShare("0");
             po.setPackageId(vo.getId());
-            List<ScenePackageNewVO> listName = scenePackageMapper.queryByPackageName(po);
-            if (listName != null && listName.size() > 0) {
+            ScenePackageNewVO scenePackageNewVO = scenePackageMapper.queryByPackageName(po);
+            if (ObjectUtil.isNotNull(scenePackageNewVO)) {
                 return new ResponseBodyVO(ResponseBodyVO.Response.CLIENT_FAILURE, "测试包名称:" + po.getPackageName() + "已存在,请重新命名");
             }
             po.setWeight(vo.getWeight());
@@ -257,16 +263,19 @@ public class ScenePackageService {
         ScenePackagePO po = new ScenePackagePO();
         po.setShare("1");
         po.setPackageName(scenePackagePO.getPackageName());
-        List<ScenePackageNewVO> listName = scenePackageMapper.queryByPackageName(po);
-        if (listName != null && listName.size() > 0) {
-            return new ResponseBodyVO<>(ResponseBodyVO.Response.CLIENT_FAILURE, "测试包名称:" + listName.get(0).getPackageName() + "的测试包已存在,请检查");
-        }
+        ScenePackageNewVO scenePackageNewVO = scenePackageMapper.queryByPackageName(po);
+
         BeanUtils.copyProperties(scenePackagePO, po);
         po.setCreateTime(TimeUtil.getNowForMysql());
         po.setModifyTime(TimeUtil.getNowForMysql());
         po.setCreateUserId(AuthUtil.getCurrentUserId());
         po.setPackageCode(StringUtil.getRandomCode());
-        String uuId = StringUtil.getRandomUUID();
+        String uuId ="";
+        if (ObjectUtil.isNotNull(scenePackageNewVO)) {
+           uuId =scenePackageNewVO.getPackageId();
+        }else{
+           uuId = StringUtil.getRandomUUID();
+        }
         po.setPackageId(uuId);
         po.setIsDeleted("0");
         po.setShare("1");
@@ -276,6 +285,9 @@ public class ScenePackageService {
         if (treeList != null && treeList.size() > 1) {
             Set set = new HashSet();
             Map map = new HashMap<>();
+            //打分规则
+            ScoringRulesParam scoringRulesParam=new ScoringRulesParam();
+            ScoringRulesParam gyParam=new ScoringRulesParam();
             for (ScenePackageSublistPO vo : treeList) {
                 Object sublistName = map.get(vo.getSublistName());
                 if (ObjectUtil.isNull(sublistName)) {
@@ -283,12 +295,50 @@ public class ScenePackageService {
                 } else {
                     set.add(vo.getSublistName());
                 }
+                //分享打分规则
+                scoringRulesParam.setRulesId(vo.getPackageAndRules());
+                ScoringRulesPO syPo= scoringRulesMapper.queryScoringRules( scoringRulesParam);//私有
+                gyParam.setShare("1");
+                gyParam.setRuleName(syPo.getRuleName());
+                ScoringRulesPO gyPo=scoringRulesMapper.queryScoringRulesByRuleName(gyParam);
+                if(ObjectUtil.isNotNull(gyPo)){
+                    syPo.setRulesId(gyPo.getRulesId());
+                    syPo.setShare("1");
+                    syPo.setModifyTime(TimeUtil.getNowForMysql());
+                    syPo.setModifyUserId(AuthUtil.getCurrentUserId());
+                    scoringRulesMapper.updateScoringRules(syPo);
+                }else{
+                    syPo.setCreateTime(TimeUtil.getNowForMysql());
+                    syPo.setModifyTime(TimeUtil.getNowForMysql());
+                    syPo.setRulesId(StringUtil.getRandomUUID());
+                    syPo.setRulesCode(StringUtil.getRandomCode());
+                    syPo.setCreateUserId(AuthUtil.getCurrentUserId());
+                    syPo.setIsDeleted("0");
+                    syPo.setShare("1");
+                    scoringRulesMapper.saveScoringRules(syPo);
+                    vo.setPackageAndRules(syPo.getRulesId());
+                }
+
             }
             if (ObjectUtil.isNotNull(set)) {
                 return new ResponseBodyVO<>(ResponseBodyVO.Response.CLIENT_FAILURE, "该条数据中指标名称:" + set + "重复,请检查");
             }
+
+
+
+        }
+        //判断是否存在,存在覆盖
+        if (ObjectUtil.isNotNull(scenePackageNewVO)) {
+            //return new ResponseBodyVO<>(ResponseBodyVO.Response.CLIENT_FAILURE, "测试包名称:" + listName.get(0).getPackageName() + "的测试包已存在,请检查");
+            scenePackagePO.setShare("1");
+            scenePackagePO.setModifyTime(TimeUtil.getNowForMysql());
+            scenePackagePO.setModifyUserId(AuthUtil.getCurrentUserId());
+            scenePackagePO.setPackageId(scenePackageNewVO.getPackageId());
+            scenePackageMapper.updateScenePackage(scenePackagePO);
+            scenePackageSublistMapper.deleteScenePackageSublist(scenePackageNewVO.getPackageId());
+        }else{
+            scenePackageMapper.saveScenePackage(po);
         }
-        scenePackageMapper.saveScenePackage(po);
         scenePackageSublistMapper.saveScenePackageSublistAll(treeList);
         LogUtil.insert();
         return new ResponseBodyVO<>(ResponseBodyVO.Response.SUCCESS);
@@ -342,7 +392,7 @@ public class ScenePackageService {
     }
 
     //测试包名查唯一
-    public List<ScenePackageNewVO> queryByPackageName(ScenePackagePO params) {
+    public ScenePackageNewVO queryByPackageName(ScenePackagePO params) {
         return scenePackageMapper.queryByPackageName(params);
     }
 

+ 19 - 3
simulation-resource-server/src/main/java/com/css/simulation/resource/scene/service/ScoringRulesService.java

@@ -35,6 +35,21 @@ public class ScoringRulesService {
         LogUtil.insert();
     }
 
+    @SneakyThrows
+    public List<ScoringRulesPO> queryScoringRulesListCSB(ScoringRulesParam params) {
+        if (params != null && params.getShare() != null && params.getShare().equals("0")) {
+            params.setCreateUserId(AuthUtil.getCurrentUserId());
+        }
+        List<ScoringRulesPO> list = scoringRulesMapper.queryScoringRulesList(params);
+
+        //查询共有
+        params.setCreateUserId("");
+        params.setShare("1");
+        List<ScoringRulesPO> list1 = scoringRulesMapper.queryScoringRulesList(params);
+        list.addAll(list1);
+        return list;
+    }
+
     @SneakyThrows
     public List<ScoringRulesPO> queryScoringRulesList(ScoringRulesParam params) {
         if (params != null && params.getShare() != null && params.getShare().equals("0")) {
@@ -44,6 +59,7 @@ public class ScoringRulesService {
         return list;
     }
 
+
     @SneakyThrows
     public ScoringRulesPO queryScoringRules(ScoringRulesParam params) {
         ScoringRulesPO Po = scoringRulesMapper.queryScoringRules(params);
@@ -51,10 +67,10 @@ public class ScoringRulesService {
     }
 
     @SneakyThrows
-    public List<ScoringRulesPO> queryScoringRulesByRuleName(ScoringRulesParam params) {
-        if (params.getShare().equals("0")) {
+    public ScoringRulesPO queryScoringRulesByRuleName(ScoringRulesParam params) {
+   /*     if (params.getShare().equals("0")) {
             params.setCreateUserId(AuthUtil.getCurrentUserId());
-        }
+        }*/
         return scoringRulesMapper.queryScoringRulesByRuleName(params);
     }
 

+ 8 - 6
simulation-resource-server/src/main/resources/mapper/algorithm/AlgorithmMapper.xml

@@ -83,19 +83,21 @@
 
     <!--查询绑定算法的正在运行的项目-->
     <select id="selectRunningProject"  parameterType="java.lang.String" resultType="api.common.pojo.vo.algorithm.RunningProjectVO">
-        select id,project_id  from simulation_automatic_subproject
-        where now_run_state = '20' and is_deleted = '0'
+        select a.id,a.project_id  from simulation_automatic_subproject a left join simulation_automatic_project b
+        on a.parent_id=b.id
+        where a.now_run_state = '20' and a.is_deleted = '0' and  b.is_deleted = '0'
         <if test="id != null and id != ''">
-            and  algorithm = #{id,jdbcType=VARCHAR}
+            and  b.algorithm = #{id,jdbcType=VARCHAR}
         </if>
     </select>
 
     <!--查询绑定算法的正在运行的项目的父项目-->
     <select id="selectRunningProjectParent"  parameterType="java.lang.String" resultType="api.common.pojo.vo.algorithm.RunningProjectVO">
-        select distinct parent_id as id,parent_project_id as projectId  from simulation_automatic_subproject
-        where now_run_state = '20' and is_deleted = '0'
+        select distinct a.parent_id as id,a.parent_project_id as projectId  from simulation_automatic_subproject a left join simulation_automatic_project b
+        on a.parent_id=b.id
+        where a.now_run_state = '20' and a.is_deleted = '0' and  b.is_deleted = '0'
         <if test="id != null and id != ''">
-            and  algorithm = #{id,jdbcType=VARCHAR}
+            and  b.algorithm = #{id,jdbcType=VARCHAR}
         </if>
     </select>
 

+ 2 - 2
simulation-resource-server/src/main/resources/mapper/scene/SceneAccidentMapper.xml

@@ -302,7 +302,7 @@
        scene_weather=#{sceneWeather},modify_time=#{modifyTime},
        modify_user_id=#{modifyUserId},video_address=#{videoAddress},
        osgb_address=#{osgbAddress},xml_address=#{xmlAddress},
-       xodr_address=#{xodrAddress},json_address=#{jsonAddress},max_time=#{maxTime}
+       xodr_address=#{xodrAddress},json_address=#{jsonAddress},max_time=#{maxTime},share=#{share}
         where accident_id = #{accidentId,jdbcType=VARCHAR}
     </update>
 
@@ -316,7 +316,7 @@
             scene_weather=#{item.sceneWeather},modify_time=#{item.modifyTime},
             modify_user_id=#{item.modifyUserId},video_address=#{item.videoAddress},
             osgb_address=#{item.osgbAddress},xml_address=#{item.xmlAddress},
-            xodr_address=#{item.xodrAddress},json_address=#{item.jsonAddress},max_time=#{item.maxTime}
+            xodr_address=#{item.xodrAddress},json_address=#{item.jsonAddress},max_time=#{item.maxTime},share=#{share}
             where accident_id = #{item.accidentId,jdbcType=VARCHAR}
         </foreach>
     </update>

+ 14 - 0
simulation-resource-server/src/main/resources/mapper/scene/SceneGeneralTemplateMapper.xml

@@ -80,6 +80,13 @@
                     #{item}
                 </foreach>
             </if>
+            <if test="scenarioRoadType != null and scenarioRoadType.size()>0 ">
+                and scenario_road_type in
+                <foreach collection="scenarioRoadType" item="item" index="index"
+                         separator="," open="(" close=")">
+                    #{item}
+                </foreach>
+            </if>
         order by modify_time desc
         </where>
     </select>
@@ -201,6 +208,13 @@
                     #{item}
                 </foreach>
             </if>
+            <if test="scenarioRoadType != null and scenarioRoadType.size()>0 ">
+                and scenario_road_type in
+                <foreach collection="scenarioRoadType" item="item" index="index"
+                         separator="," open="(" close=")">
+                    #{item}
+                </foreach>
+            </if>
             order by modify_time desc
         </where>
     </select>

+ 0 - 3
simulation-resource-server/src/main/resources/mapper/scene/ScenePackageMapper.xml

@@ -160,9 +160,6 @@
             <if test="packageName != null and packageName != ''">
                 and package_name =#{packageName,jdbcType=VARCHAR}
             </if>
-            <if test="createUserId != null and createUserId != ''">
-                and create_user_id=#{createUserId,jdbcType=VARCHAR}
-            </if>
             <if test="share != null and share != ''">
                 and share=#{share,jdbcType=VARCHAR}
             </if>

+ 1 - 4
simulation-resource-server/src/main/resources/mapper/scene/ScoringRulesMapper.xml

@@ -43,9 +43,9 @@
             <if test="createUserId != null and createUserId != ''">
                 and create_user_id=#{createUserId,jdbcType=VARCHAR}
             </if>
-
             order by modify_time desc
         </where>
+
     </select>
     <select id="queryScoringRules" parameterType="api.common.pojo.param.scene.ScoringRulesParam"
             resultType="api.common.pojo.po.scene.ScoringRulesPO">
@@ -77,9 +77,6 @@
             <if test="ruleName != null and ruleName != ''">
                 and rule_name =#{ruleName}
             </if>
-            <if test="createUserId != null and createUserId != ''">
-                and create_user_id=#{createUserId,jdbcType=VARCHAR}
-            </if>
             <if test="share != null and share != ''">
                 and share=#{share,jdbcType=VARCHAR}
             </if>