案件池查询修改 定时任务加环境判断

zhanghua

2023-12-15 1eb1ae6b785210727812ed5f6ce9ccaaf09cc458

案件池查询修改
定时任务加环境判断

 ycl-platform/src/main/java/com/ycl/controller/caseHandler/BaseCaseController.java

@@ -44,6 +44,7 @@
import javax.servlet.http.HttpServletResponse;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.List;


@@ -133,7 +134,7 @@
    @ApiOperation(value = "查询违规违建")
    @GetMapping("/query")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "state", value = "处理状态(0-待处理1-误报2-上报3-再学习/再训练4暂不处理5立案6调度7处置8核查9结案)", dataType = "Integer"),
            @ApiImplicitParam(name = "state", value = "处理状态(wait(0-待处理)  handle(5立案6调度7处置8核查)  finish(1-误报2-上报3-再学习/再训练4暂不处理 9结案)", dataType = "String"),
            @ApiImplicitParam(name = "type", value = "1 违规,2 违建", dataType = "Integer"),
            @ApiImplicitParam(name = "resource", value = "1 视频,2 手动", dataType = "Integer"),
            @ApiImplicitParam(name = "code", dataType = "String"),
@@ -147,7 +148,7 @@
    })
    public CommonResult searchViolation(@RequestParam Integer size,
                                        @RequestParam Integer current,
                                        @RequestParam(required = false) Integer state,
                                        @RequestParam(required = false) String state,
                                        @RequestParam Integer type,
                                        @RequestParam(required = false) Integer resource,
                                        @RequestParam(required = false) String code,
@@ -161,10 +162,30 @@
                                        @RequestParam(required = false) Integer videoId) {

        Page<Object> queryList;
       // 处理状态(wait(0-待处理)  handle(5立案6调度7处置8核查)  finish(1-误报2-上报3-再学习/再训练4暂不处理 9结案)
        List<Integer> stateList = new ArrayList<>();
        switch (state){
            case "wait":
                stateList.add(0);
                break;
            case  "handle":
                stateList.add(5);
                stateList.add(6);
                stateList.add(7);
                stateList.add(8);
                break;
            case "finish":
                stateList.add(1);
                stateList.add(2);
                stateList.add(3);
                stateList.add(4);
                stateList.add(9);
                break;
        }
        if (type == 1) {
            queryList = baseCaseService.listViolationsPage(current, size, state, resource, code, categoryBig, categorySmall, street, site, startTime, endTime, violationsTypeId, videoId);
            queryList = baseCaseService.listViolationsPage(current, size, stateList, resource, code, categoryBig, categorySmall, street, site, startTime, endTime, violationsTypeId, videoId);
        } else if (type == 2) {
            queryList = baseCaseService.listIllegalBuilding(current, size, state, resource);
            queryList = baseCaseService.listIllegalBuilding(current, size, stateList, resource);
        } else {
            return CommonResult.failed("bad request url");
        }

 ycl-platform/src/main/java/com/ycl/mapper/caseHandler/BaseCaseMapper.java

@@ -27,9 +27,9 @@
 * @since 2022-09-24
 */
public interface BaseCaseMapper extends BaseMapper<BaseCase> {
    Page<CasePoolViolationVO> listViolationsPage(Page page, Integer state, Integer type, Integer resource, String code, String categoryBig, String categorySmall, Integer street, String site, String startTime, String endTime, Integer violationsTypeId, Integer videoId);
    Page<CasePoolViolationVO> listViolationsPage(Page page, List<Integer> state, Integer type, Integer resource, String code, String categoryBig, String categorySmall, Integer street, String site, String startTime, String endTime, Integer violationsTypeId, Integer videoId);

    Page<CasePoolIllegalBuildingVO> listIllegalBuildingsPage(Page page, Integer state, Integer type, Integer resource);
    Page<CasePoolIllegalBuildingVO> listIllegalBuildingsPage(Page page, List<Integer> state, Integer type, Integer resource);

    BaseCase selectCondMap(Map map);


 ycl-platform/src/main/java/com/ycl/service/caseHandler/IBaseCaseService.java

@@ -39,9 +39,9 @@
     */
    String uploadEvent(Long caseId);

    Page listViolationsPage(Integer size, Integer current, Integer state, Integer resource, String code, String categoryBig, String categorySmall, Integer street, String site, String startTime, String endTime, Integer violationsTypeId, Integer videoId);
    Page listViolationsPage(Integer size, Integer current, List<Integer> state, Integer resource, String code, String categoryBig, String categorySmall, Integer street, String site, String startTime, String endTime, Integer violationsTypeId, Integer videoId);

    Page listIllegalBuilding(Integer current, Integer size, Integer state, Integer resource);
    Page listIllegalBuilding(Integer current, Integer size, List<Integer> state, Integer resource);

    Boolean saveViolationCase(ViolationParam violationParam, Long id);


 ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java

@@ -173,7 +173,7 @@
    }

    @Override
    public Page listViolationsPage(Integer current, Integer size, Integer state, Integer resource, String code, String categoryBig, String categorySmall, Integer street, String site, String startTime, String endTime, Integer violationsTypeId, Integer videoId) {
    public Page listViolationsPage(Integer current, Integer size,  List<Integer>  state, Integer resource, String code, String categoryBig, String categorySmall, Integer street, String site, String startTime, String endTime, Integer violationsTypeId, Integer videoId) {
        Integer type = 01;
        Integer hours = 60;
        Integer day = 24;
@@ -198,7 +198,7 @@
    }

    @Override
    public Page listIllegalBuilding(Integer current, Integer size, Integer state, Integer resource) {
    public Page listIllegalBuilding(Integer current, Integer size, List<Integer> state, Integer resource) {
        Integer type = 02;
        Page page = new Page<>().setCurrent(current).setSize(size);
        return baseCaseMapper.listIllegalBuildingsPage(page, state, type, resource);

 ycl-platform/src/main/java/com/ycl/timer/GetDingToken.java

@@ -8,6 +8,7 @@
import com.ycl.config.DingConfig;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.data.redis.core.StringRedisTemplate;
@@ -91,8 +92,15 @@
//            runAction();
        }
    }
//    @Scheduled(cron ="0 0/2 * * * ? ")

    @Value("${spring.profiles.active}")
    private String env;

        @Scheduled(cron ="0 0/2 * * * ? ")
//    @Scheduled(cron = "0/1 * * * * ?")   // 每秒执行
    public void runAction() {
//        System.out.println("环境：" + env);
        if ("online".equals(env)) {
         //gettoken
         String getToken = getToken();
         //jsApi
@@ -104,3 +112,4 @@
         redisTemplate.opsForValue().set("ding", dingObj.toJSONString(), 2L, TimeUnit.HOURS);
    }
}
}

 ycl-platform/src/main/java/com/ycl/vo/casePool/CasePoolIllegalBuildingVO.java

@@ -70,4 +70,9 @@
     */
    @ApiModelProperty(value = "违建材料", dataType = "String")
    private String materials;
    /**
     * 状态
     */
    @ApiModelProperty(value = "状态")
    private Integer state;
}

 ycl-platform/src/main/java/com/ycl/vo/casePool/CasePoolViolationVO.java

@@ -78,4 +78,9 @@
    @ApiModelProperty(value = "关闭时间")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private LocalDateTime closeTime;
    /**
     * 状态
     */
    @ApiModelProperty(value = "状态")
    private Integer state;
}

 ycl-platform/src/main/resources/application-online.yml

@@ -1,5 +1,5 @@
server:
  port: 8084
  port: 8082
  tomcat:
    uri-encoding: UTF-8
  servlet:

 ycl-platform/src/main/resources/application-prod.yml

@@ -24,7 +24,7 @@
spring:
  redis:
    database: 0
    host: 127.0.0.1
    host: 10.110.247.1
    port: 6380
    password: Q(yNR2x^%v@HV
    jedis:

 ycl-platform/src/main/resources/mapper/caseHandler/BaseCaseMapper.xml

@@ -55,7 +55,8 @@
        t5.region_name as street,
        ubc.site,
        ubc.alarm_time,
        ubc.close_time
        ubc.close_time,
        ubc.state
        FROM
        `ums_base_case` AS ubc
        JOIN ums_violations AS uv ON ubc.id = uv.id
@@ -63,11 +64,11 @@
        LEFT JOIN ums_data_dictionary AS t4 ON uv.type_id = t4.id
        LEFT JOIN ums_sccg_region t5 ON ubc.street_id = t5.id
        <where>
            <if test="state!=null and state!=6">
                ubc.state=#{state}
            </if>
            <if test="state!=null and state==6">
                ubc.state &gt;=#{state}
            <if test=" state != null and state.size() > 0">
                AND ubc.state in
                <foreach collection="state" index="index" item="item" open="(" separator="," close=")">
                    #{item}
                </foreach>
            </if>
            <if test="resource!=null">
                and ubc.event_source=#{resource}
@@ -115,18 +116,19 @@
        uib.building_width,
        uib.building_length,
        uib.building_area,
        uib.materials
        uib.materials,
        ubc.state
        FROM
        `ums_base_case` AS ubc
        left JOIN ums_illegal_building AS uib ON ubc.id = uib.base_case_id
        left JOIN ums_data_dictionary AS t1 ON uib.category_id = t1.id
        left JOIN ums_sccg_region t2 ON ubc.community_id = t2.id
        <where>
            <if test="state!=null and state!=6">
                ubc.state=#{state}
            </if>
            <if test="state!=null and state==6">
                ubc.state &gt;=#{state}
            <if test=" state != null and state.size() > 0">
                AND ubc.state in
                <foreach collection="state" index="index" item="item" open="(" separator="," close=")">
                    #{item}
                </foreach>
            </if>
            <if test="resource!=null">
                and ubc.event_source=#{resource}