协同人员信息查询

src/main/java/com/founder/config/DataSourceYthcjConfig.java

+package com.founder.config;
+
+import org.apache.ibatis.session.SqlSessionFactory;
+import org.mybatis.spring.SqlSessionFactoryBean;
+import org.mybatis.spring.SqlSessionTemplate;
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.boot.jdbc.DataSourceBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
+
+import javax.sql.DataSource;
+
+/**
+ * Created by summer on 2016/11/25.
+ */
+@Configuration
+@MapperScan(basePackages = "com.founder.ythcjdao", sqlSessionTemplateRef  = "ythcjSqlSessionTemplate")
+public class DataSourceYthcjConfig {
+
+    @Bean(name = "ythcjDataSource")
+    @ConfigurationProperties(prefix = "spring.datasource.ythcj")
+    public DataSource ythcjDataSource() {
+        return DataSourceBuilder.create().build();
+    }
+
+    @Bean(name = "ythcjSqlSessionFactory")
+    public SqlSessionFactory ythcjSqlSessionFactory(@Qualifier("ythcjDataSource") DataSource dataSource) throws Exception {
+        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
+        bean.setDataSource(dataSource);
+        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mybatis/ythcjMapper/*.xml"));
+        return bean.getObject();
+    }
+    @Bean(name = "ythcjSqlSessionTemplate")
+    public SqlSessionTemplate ythcjSqlSessionTemplate(@Qualifier("ythcjSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
+        return new SqlSessionTemplate(sqlSessionFactory);
+    }
+
+}

src/main/java/com/founder/controller/AjFwController.java

@@ -5,10 +5,7 @@ import com.founder.checkAuthorization.config.AuthorizationInterceptor;
 import com.founder.common.IpADressLock;
 import com.founder.common.LogsUtil;
 import com.founder.dao.AuthorizationMapper;
-import com.founder.model.AsjRyRelateVo;
-import com.founder.model.R;
-import com.founder.model.TbSpParam;
-import com.founder.model.XyrParam;
+import com.founder.model.*;
 import com.founder.service.AjFwService;
 import com.founder.service.SysGnsyrzOpenApiService;
 import lombok.extern.slf4j.Slf4j;
@@ -21,6 +18,8 @@ import org.springframework.web.bind.annotation.RestController;
 
 import javax.servlet.http.HttpServletRequest;
 import java.util.Map;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
 
 @RestController
 @RequestMapping(value="/aj/esQuery",produces = "application/json; charset=utf-8")
@@ -35,6 +34,8 @@ public class AjFwController {
     private AjFwService ajFwService;
     @Autowired
     private SysGnsyrzOpenApiService sysGnsyrzOpenApiService;
+    private static Lock lock = new ReentrantLock();
+    private static boolean iscall=false;
     /**
      * 案件信息查询
      * @param
@@ -143,9 +144,43 @@ public class AjFwController {
     }
 
 
+    @PostMapping("/jz/getXzxtZpByRybh")
+    public R getXzxtZpByRybh(HttpServletRequest request,@RequestBody TbStAsjXzVo asj) {
+        try {
+            if(StringUtils.isEmpty(asj.getRybh())){
+                return R.error("人员编号为空，不能查询");
+            }
+
+            if(!iscall){
+                lock.lock();
+                try {
+                    iscall=true;
+                    TbRxImgVo zp = ajFwService.getXzxtZpByRybh(asj.getRybh());
+                    Map<String, String> map = getFwidAndXtmc(request);
+                    sysGnsyrzOpenApiService.insertGNSYRZOPENAPI("01", map.get("FWMC"), LogsUtil.getNotEmptyFiled(asj).toString(),
+                            "", "", "430000000000", map.get("XTMC"), "", ipADressLock.getAddressIp(request), "0", map.get("FWID"));
+                    return R.ok().data("rows", zp);
+                }catch (Exception e){
+                    e.printStackTrace();
+                    throw new Exception("系统异常");
+                }finally {
+                    lock.unlock();
+                    iscall=false;
+                }
+            }else {
+                return R.error("上一编号还在查询，稍后再试");
+            }
+        } catch (Exception e) {
+            log.error("错误日志", e);
+            return R.error(e.getMessage());
+        }
+    }
+
     private Map<String, String> getFwidAndXtmc(HttpServletRequest request) {
         String appId = request.getHeader(AuthorizationInterceptor.appId);
         String appSecret = request.getHeader(AuthorizationInterceptor.appSecret);
         return authorizationMapper.getFwidAndXtmc(appId, appSecret);
     }
+
+
 }

src/main/java/com/founder/model/TbRxImgVo.java

+package com.founder.model;
+
+import lombok.Data;
+
+@Data
+public class TbRxImgVo {
+	private byte[] zmzp;
+	private byte[] zczp;
+	private byte[] yczp;
+}

src/main/java/com/founder/model/TbRycjZp.java

+package com.founder.model;
+
+
+import java.util.Date;
+import java.io.Serializable;
+
+/**
+ * 人员照片信息(TbRycjZp)表服务接口
+ *
+ * @author liulianglang
+ * @since 2021-08-25 16:12:02
+ */
+public class TbRycjZp implements Serializable {
+	private static final long serialVersionUID = 710236537689518217L;
+	/**
+	 * <!>信息主键编号
+	 */
+	private String xxzjbh;
+	/**
+	 * <!>相关人员编号#0#0#1##TEXTBOX#1#
+	 */
+	private String asjxgrybh;
+	/**
+	 * <!>人员照片_照片类型代码#0#1#1#BD_D_ZPLX#COBBOX#2#
+	 */
+	private String ryzpZplxdm;
+	/**
+	 * 人员照片标题CN#0#1#1##TEXTBOX#3#
+	 */
+	private String ryzpDzwjbt;
+	/**
+	 * 人员照片名称CN#0#1#1##TEXTBOX#4#
+	 */
+	private String ryzpDzwjmc;
+	/**
+	 * 人员照片格式#0#1#1##TEXTBOX#5#
+	 */
+	private String ryzpDzwjgs;
+	/**
+	 * 人员照片内容CN#0#1#1##TEXTBOX#6#
+	 */
+	private byte[] ryzpDzwjnr;
+	/**
+	 * 人员照片大小CN#0#1#1##TEXTBOX#7#
+	 */
+	private Double ryzpDzwjdx;
+	/**
+	 * 人员照片位置CN#0#1#1##TEXTBOX#8#
+	 */
+	private String ryzpDzwjwz;
+	/**
+	 * 人员照片建立时间#0#1#1##DATE#9#
+	 */
+	private Date ryzpJlsj;
+
+	public String getRyzpJlsjStr() {
+		return ryzpJlsjStr;
+	}
+
+	public void setRyzpJlsjStr(String ryzpJlsjStr) {
+		this.ryzpJlsjStr = ryzpJlsjStr;
+	}
+
+	private String ryzpJlsjStr;
+	/**
+	 * 信息删除_判断标识
+	 */
+	private String xxscPdbz;
+	/**
+	 * 信息登记单位_公安机关机构代码
+	 */
+	private String xxdjdwGajgjgdm;
+	/**
+	 * 信息登记单位_公安机关名称
+	 */
+	private String xxdjdwGajgmc;
+	/**
+	 * 信息登记人员_姓名
+	 */
+	private String xxdjryXm;
+	/**
+	 * 信息登记人员_公民身份号码
+	 */
+	private String xxdjryGmsfhm;
+	/**
+	 * 信息登记人员_联系电话
+	 */
+	private String xxdjryLxdh;
+	/**
+	 * 登记时间
+	 */
+	private Date djsj;
+	/**
+	 * 信息操作单位_公安机关机构代码
+	 */
+	private String xxczdwGajgjgdm;
+	/**
+	 * 信息操作单位_公安机关名称
+	 */
+	private String xxczdwGajgmc;
+	/**
+	 * 信息操作人员_姓名
+	 */
+	private String xxczryXm;
+	/**
+	 * 信息操作人员_公民身份号码
+	 */
+	private String xxczryGmsfhm;
+	/**
+	 * 更新时间
+	 */
+	private Date gxsj;
+	/**
+	 * 信息来源描述
+	 */
+	private String xxlyms;
+	/**
+	 * 信息入省库时间
+	 */
+	private Date xxrsksj;
+	/**
+	 * 信息入部库时间
+	 */
+	private Date xxrbksj;
+	/**
+	 * 信息入省库_判断标识
+	 */
+	private String xxrskPdbz;
+	/**
+	 * 信息入部库_判断标识
+	 */
+	private String xxrbkPdbz;
+	/**
+	 * 照片部位，1：二代证；2：正面照片；3：左侧面照片；4：右侧面照片
+	 */
+	private String zpbw;
+	/**
+	 * 部省业务联动服务公安部下发  0:否   1:是
+	 */
+	private String gabxf;
+
+	public String getBdzt() {
+		return bdzt;
+	}
+
+	public void setBdzt(String bdzt) {
+		this.bdzt = bdzt;
+	}
+
+	public String getBdrwbh() {
+		return bdrwbh;
+	}
+
+	public void setBdrwbh(String bdrwbh) {
+		this.bdrwbh = bdrwbh;
+	}
+
+	private String bdrwbh;
+	private String bdzt;
+
+	public String getXxzjbh() {
+		return xxzjbh;
+	}
+
+	public void setXxzjbh(String xxzjbh) {
+		this.xxzjbh = xxzjbh;
+	}
+
+	public String getAsjxgrybh() {
+		return asjxgrybh;
+	}
+
+	public void setAsjxgrybh(String asjxgrybh) {
+		this.asjxgrybh = asjxgrybh;
+	}
+
+	public String getRyzpZplxdm() {
+		return ryzpZplxdm;
+	}
+
+	public void setRyzpZplxdm(String ryzpZplxdm) {
+		this.ryzpZplxdm = ryzpZplxdm;
+	}
+
+	public String getRyzpDzwjbt() {
+		return ryzpDzwjbt;
+	}
+
+	public void setRyzpDzwjbt(String ryzpDzwjbt) {
+		this.ryzpDzwjbt = ryzpDzwjbt;
+	}
+
+	public String getRyzpDzwjmc() {
+		return ryzpDzwjmc;
+	}
+
+	public void setRyzpDzwjmc(String ryzpDzwjmc) {
+		this.ryzpDzwjmc = ryzpDzwjmc;
+	}
+
+	public String getRyzpDzwjgs() {
+		return ryzpDzwjgs;
+	}
+
+	public void setRyzpDzwjgs(String ryzpDzwjgs) {
+		this.ryzpDzwjgs = ryzpDzwjgs;
+	}
+
+	public byte[] getRyzpDzwjnr() {
+		return ryzpDzwjnr;
+	}
+
+	public void setRyzpDzwjnr(byte[] ryzpDzwjnr) {
+		this.ryzpDzwjnr = ryzpDzwjnr;
+	}
+
+	public Double getRyzpDzwjdx() {
+		return ryzpDzwjdx;
+	}
+
+	public void setRyzpDzwjdx(Double ryzpDzwjdx) {
+		this.ryzpDzwjdx = ryzpDzwjdx;
+	}
+
+	public String getRyzpDzwjwz() {
+		return ryzpDzwjwz;
+	}
+
+	public void setRyzpDzwjwz(String ryzpDzwjwz) {
+		this.ryzpDzwjwz = ryzpDzwjwz;
+	}
+
+	public Date getRyzpJlsj() {
+		return ryzpJlsj;
+	}
+
+	public void setRyzpJlsj(Date ryzpJlsj) {
+		this.ryzpJlsj = ryzpJlsj;
+	}
+
+	public String getXxscPdbz() {
+		return xxscPdbz;
+	}
+
+	public void setXxscPdbz(String xxscPdbz) {
+		this.xxscPdbz = xxscPdbz;
+	}
+
+	public String getXxdjdwGajgjgdm() {
+		return xxdjdwGajgjgdm;
+	}
+
+	public void setXxdjdwGajgjgdm(String xxdjdwGajgjgdm) {
+		this.xxdjdwGajgjgdm = xxdjdwGajgjgdm;
+	}
+
+	public String getXxdjdwGajgmc() {
+		return xxdjdwGajgmc;
+	}
+
+	public void setXxdjdwGajgmc(String xxdjdwGajgmc) {
+		this.xxdjdwGajgmc = xxdjdwGajgmc;
+	}
+
+	public String getXxdjryXm() {
+		return xxdjryXm;
+	}
+
+	public void setXxdjryXm(String xxdjryXm) {
+		this.xxdjryXm = xxdjryXm;
+	}
+
+	public String getXxdjryGmsfhm() {
+		return xxdjryGmsfhm;
+	}
+
+	public void setXxdjryGmsfhm(String xxdjryGmsfhm) {
+		this.xxdjryGmsfhm = xxdjryGmsfhm;
+	}
+
+	public String getXxdjryLxdh() {
+		return xxdjryLxdh;
+	}
+
+	public void setXxdjryLxdh(String xxdjryLxdh) {
+		this.xxdjryLxdh = xxdjryLxdh;
+	}
+
+	public Date getDjsj() {
+		return djsj;
+	}
+
+	public void setDjsj(Date djsj) {
+		this.djsj = djsj;
+	}
+
+	public String getXxczdwGajgjgdm() {
+		return xxczdwGajgjgdm;
+	}
+
+	public void setXxczdwGajgjgdm(String xxczdwGajgjgdm) {
+		this.xxczdwGajgjgdm = xxczdwGajgjgdm;
+	}
+
+	public String getXxczdwGajgmc() {
+		return xxczdwGajgmc;
+	}
+
+	public void setXxczdwGajgmc(String xxczdwGajgmc) {
+		this.xxczdwGajgmc = xxczdwGajgmc;
+	}
+
+	public String getXxczryXm() {
+		return xxczryXm;
+	}
+
+	public void setXxczryXm(String xxczryXm) {
+		this.xxczryXm = xxczryXm;
+	}
+
+	public String getXxczryGmsfhm() {
+		return xxczryGmsfhm;
+	}
+
+	public void setXxczryGmsfhm(String xxczryGmsfhm) {
+		this.xxczryGmsfhm = xxczryGmsfhm;
+	}
+
+	public Date getGxsj() {
+		return gxsj;
+	}
+
+	public void setGxsj(Date gxsj) {
+		this.gxsj = gxsj;
+	}
+
+	public String getXxlyms() {
+		return xxlyms;
+	}
+
+	public void setXxlyms(String xxlyms) {
+		this.xxlyms = xxlyms;
+	}
+
+	public Date getXxrsksj() {
+		return xxrsksj;
+	}
+
+	public void setXxrsksj(Date xxrsksj) {
+		this.xxrsksj = xxrsksj;
+	}
+
+	public Date getXxrbksj() {
+		return xxrbksj;
+	}
+
+	public void setXxrbksj(Date xxrbksj) {
+		this.xxrbksj = xxrbksj;
+	}
+
+	public String getXxrskPdbz() {
+		return xxrskPdbz;
+	}
+
+	public void setXxrskPdbz(String xxrskPdbz) {
+		this.xxrskPdbz = xxrskPdbz;
+	}
+
+	public String getXxrbkPdbz() {
+		return xxrbkPdbz;
+	}
+
+	public void setXxrbkPdbz(String xxrbkPdbz) {
+		this.xxrbkPdbz = xxrbkPdbz;
+	}
+
+	public String getZpbw() {
+		return zpbw;
+	}
+
+	public void setZpbw(String zpbw) {
+		this.zpbw = zpbw;
+	}
+
+	public String getGabxf() {
+		return gabxf;
+	}
+
+	public void setGabxf(String gabxf) {
+		this.gabxf = gabxf;
+	}
+
+}

src/main/java/com/founder/model/TbStAsjXzVo.java

+package com.founder.model;
+
+
+import lombok.Data;
+
+@Data
+public class TbStAsjXzVo {
+    /**
+     * 案事件编号
+     */
+    private String asjbh;
+    private String ajmc;
+    private String ajlbdm;
+    private String ajlbmc;
+    private String asjfsddXzqhdm;
+    private String asjfsddDzmc;
+    private String larq;
+    private String jyaq;
+
+    private String rybh;
+}

src/main/java/com/founder/service/AjFwService.java

 package com.founder.service;
 
 import com.founder.model.AsjRyRelateVo;
+import com.founder.model.TbRxImgVo;
 import com.founder.model.TbSpParam;
 import com.founder.model.XyrParam;
 
@@ -20,4 +21,5 @@ public interface AjFwService {
     Map<String, Object> xczp(HttpServletRequest request, TbSpParam tbSpParam)  throws Exception;
 
 
+    TbRxImgVo getXzxtZpByRybh(String rybh);
 }

src/main/java/com/founder/service/impl/AjFwServiceImpl.java

@@ -3,11 +3,10 @@ package com.founder.service.impl;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.founder.dao.AjFwMapper;
-import com.founder.model.AsjRyRelateVo;
-import com.founder.model.TbSpParam;
-import com.founder.model.TbSpVo;
+import com.founder.model.*;
 import com.founder.service.AjFwService;
 import com.founder.util.HttpClient;
+import com.founder.ythcjdao.YthcjZyfwMapper;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -22,7 +21,8 @@ import java.util.Map;
 public class AjFwServiceImpl implements AjFwService {
     @Autowired
     private AjFwMapper ajFwMapper;
-
+    @Autowired
+    private YthcjZyfwMapper ythcjZyfwMapper;
     @Override
     public Map<String, Object> esQuery(HttpServletRequest request, AsjRyRelateVo asjRyRelateVo) throws Exception {
         Map<String, Object> resultMap = new HashMap<>(); //返回值
@@ -143,6 +143,26 @@ public class AjFwServiceImpl implements AjFwService {
 
     }
 
+
+    @Override
+    public TbRxImgVo getXzxtZpByRybh(String rybh) {
+        Map<String,Object> map1 = new HashMap<>();
+        map1.put("rybh",rybh);
+        List<TbRycjZp> list=  ythcjZyfwMapper.getOrclRyRyzpInfo(map1);
+        TbRxImgVo imgVo=new TbRxImgVo();
+
+        for(TbRycjZp s:list){
+            if("2".equals(s.getZpbw())){
+                imgVo.setZmzp(s.getRyzpDzwjnr());
+            }else if("3".equals(s.getZpbw())){
+                imgVo.setZczp(s.getRyzpDzwjnr());
+            }else if("4".equals(s.getZpbw())){
+                imgVo.setYczp(s.getRyzpDzwjnr());
+            }
+        }
+        return imgVo;
+    }
+
     private HashMap<String, String> initHttpXmlHeads() {
         HashMap<String, String> headParams = new HashMap<String, String>();
         headParams.put("Content-Type", "application/json;charset=UTF-8");

src/main/java/com/founder/ythcjdao/YthcjZyfwMapper.java

+
+package com.founder.ythcjdao;
+
+
+import com.founder.model.TbRycjZp;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 厅级资源服务
+ *
+ * @author create by lystar
+ * @date 2022/8/16 14:46
+ */
+@Mapper
+@Repository
+public interface YthcjZyfwMapper {
+    int getYthcjRyCount(@Param("isZl") String isZl);
+
+    int getYthcjRyZpCount(@Param("isZl") String isZl);
+
+    int getYthcjZjCount(@Param("isZl") String isZl);
+
+    int getYthcjSjCount(@Param("isZl") String isZl);
+
+    long getYthcjSjTxlCount(@Param("isZl") String isZl);
+
+    long getYthcjSjThjlCount(@Param("isZl") String isZl);
+
+    long getYthcjSjDxjlCount(@Param("isZl") String isZl);
+
+    int getYthcjSjXnsfCount(@Param("isZl") String isZl);
+
+    int getYthcjYhkCount(@Param("isZl") String isZl);
+
+    int getYthcjSwCount(@Param("isZl") String isZl);
+
+    int getYthcjHmCount(@Param("isZl") String isZl);
+    int getYthcjSsxdwpCount(@Param("isZl") String isZl);
+
+
+    public List<TbRycjZp> getOrclRyRyzpInfo(Map<String, Object> map);
+}

src/main/resources/application-dev.yml

@@ -18,6 +18,17 @@ spring:
       password: manager
       jdbc-url: jdbc:oracle:thin:@47.92.129.99:1600:orcl
       type: com.alibaba.druid.pool.DruidDataSource
+    ythcj:
+      #      driver-class-name: oracle.jdbc.OracleDriver
+      #      username: YTHCJ
+      #      password: XtbaPwd#43
+      #      jdbc-url: jdbc:oracle:thin:@10.142.16.172:1621:STXZ
+      #      type: com.alibaba.druid.pool.DruidDataSource
+      driver-class-name: oracle.jdbc.driver.OracleDriver
+      username: XZXT
+      password: XzPwd#11022
+      jdbc-url: jdbc:oracle:thin:@47.92.129.99:1560:ORCL
+      type: com.alibaba.druid.pool.DruidDataSource
 
   #配置jpa 使其展示sql语句
   jpa:

src/main/resources/mybatis/ythcjMapper/YthcjZyfwMapper.xml

+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.founder.ythcjdao.YthcjZyfwMapper">
+
+
+    <resultMap type="com.founder.model.TbRycjZp" id="TbRycjZpMap">
+        <result property="xxzjbh" column="xxzjbh" jdbcType="VARCHAR"/>
+        <result property="asjxgrybh" column="asjxgrybh" jdbcType="VARCHAR"/>
+        <result property="ryzpZplxdm" column="ryzp_zplxdm" jdbcType="VARCHAR"/>
+        <result property="ryzpDzwjbt" column="ryzp_dzwjbt" jdbcType="VARCHAR"/>
+        <result property="ryzpDzwjmc" column="ryzp_dzwjmc" jdbcType="VARCHAR"/>
+        <result property="ryzpDzwjgs" column="ryzp_dzwjgs" jdbcType="VARCHAR"/>
+        <result property="ryzpDzwjnr" column="ryzp_dzwjnr" jdbcType="BLOB"/>
+        <result property="ryzpDzwjdx" column="ryzp_dzwjdx" jdbcType="NUMERIC"/>
+        <result property="ryzpDzwjwz" column="ryzp_dzwjwz" jdbcType="VARCHAR"/>
+        <result property="ryzpJlsj" column="ryzp_jlsj" jdbcType="TIMESTAMP"/>
+
+        <result property="ryzpJlsjStr" column="RYZP_JLSJStr" jdbcType="VARCHAR"/>
+        <result property="xxscPdbz" column="xxsc_pdbz" jdbcType="VARCHAR"/>
+        <result property="xxdjdwGajgjgdm" column="xxdjdw_gajgjgdm" jdbcType="VARCHAR"/>
+        <result property="xxdjdwGajgmc" column="xxdjdw_gajgmc" jdbcType="VARCHAR"/>
+        <result property="xxdjryXm" column="xxdjry_xm" jdbcType="VARCHAR"/>
+        <result property="xxdjryGmsfhm" column="xxdjry_gmsfhm" jdbcType="VARCHAR"/>
+        <result property="xxdjryLxdh" column="xxdjry_lxdh" jdbcType="VARCHAR"/>
+        <result property="djsj" column="djsj" jdbcType="TIMESTAMP"/>
+        <result property="xxczdwGajgjgdm" column="xxczdw_gajgjgdm" jdbcType="VARCHAR"/>
+        <result property="xxczdwGajgmc" column="xxczdw_gajgmc" jdbcType="VARCHAR"/>
+        <result property="xxczryXm" column="xxczry_xm" jdbcType="VARCHAR"/>
+        <result property="xxczryGmsfhm" column="xxczry_gmsfhm" jdbcType="VARCHAR"/>
+        <result property="gxsj" column="gxsj" jdbcType="TIMESTAMP"/>
+        <result property="xxlyms" column="xxlyms" jdbcType="VARCHAR"/>
+        <result property="xxrsksj" column="xxrsksj" jdbcType="TIMESTAMP"/>
+        <result property="xxrbksj" column="xxrbksj" jdbcType="TIMESTAMP"/>
+        <result property="xxrskPdbz" column="xxrsk_pdbz" jdbcType="VARCHAR"/>
+        <result property="xxrbkPdbz" column="xxrbk_pdbz" jdbcType="VARCHAR"/>
+        <result property="zpbw" column="zpbw" jdbcType="VARCHAR"/>
+        <result property="gabxf" column="gabxf" jdbcType="VARCHAR"/>
+    </resultMap>
+    <select id="getYthcjRyCount" resultType="java.lang.Integer">
+        select count(*) from tb_ry_rycj WHERE SCBZ = 0
+        <if test="isZl == '1'.toString()">
+            and LRSJ >= to_date(to_char(sysdate, 'yyyy-mm-dd'), 'yyyy-mm-dd')
+        </if>
+    </select>
+    <select id="getYthcjRyZpCount" resultType="java.lang.Integer">
+        select count(*) FROM tb_ry_ryzp where SCBZ = 0
+        <if test="isZl == '1'.toString()">
+            and LRSJ >= to_date(to_char(sysdate, 'yyyy-mm-dd'), 'yyyy-mm-dd')
+        </if>
+    </select>
+    <select id="getYthcjZjCount" resultType="java.lang.Integer">
+        select count(*) FROM tb_xw_ythcj_zj where XXSC_PDBZ = '0'
+        <if test="isZl == '1'.toString()">
+            and DJSJ >= to_date(to_char(sysdate, 'yyyy-mm-dd'), 'yyyy-mm-dd')
+        </if>
+    </select>
+    <select id="getYthcjSjCount" resultType="java.lang.Integer">
+        select count(*) FROM tb_ph_fzxyrsjgl where SCBZ = 0
+        <if test="isZl == '1'.toString()">
+            and LRSJ >= to_date(to_char(sysdate, 'yyyy-mm-dd'), 'yyyy-mm-dd')
+        </if>
+    </select>
+    <select id="getYthcjSjTxlCount" resultType="java.lang.Long">
+        <if test="isZl == '1'.toString()">
+            select count(*) FROM tb_ph_lxrxx where gxsj >= to_date(to_char(sysdate, 'yyyy-mm-dd'), 'yyyy-mm-dd')
+        </if>
+        <if test="isZl == '0'.toString()">
+            select num_rows from user_tables where table_name='TB_PH_LXRXX'
+        </if>
+    </select>
+    <select id="getYthcjSjThjlCount" resultType="java.lang.Long">
+        <if test="isZl == '1'.toString()">
+            select count(*) FROM tb_ph_thjl where gxsj >= to_date(to_char(sysdate, 'yyyy-mm-dd'), 'yyyy-mm-dd')
+        </if>
+        <if test="isZl == '0'.toString()">
+            select num_rows from user_tables where table_name='TB_PH_THJL'
+        </if>
+    </select>
+    <select id="getYthcjSjDxjlCount" resultType="java.lang.Long">
+        <if test="isZl == '1'.toString()">
+            select count(*) FROM tb_ph_dxjl where gxsj >= to_date(to_char(sysdate, 'yyyy-mm-dd'), 'yyyy-mm-dd')
+        </if>
+        <if test="isZl == '0'.toString()">
+            select num_rows from user_tables where table_name='TB_PH_DXJL'
+        </if>
+    </select>
+    <select id="getYthcjSjXnsfCount" resultType="java.lang.Integer">
+        select count(*) FROM tb_xnsf_zhxx where SCBZ = 0
+        <if test="isZl == '1'.toString()">
+            and LRSJ >= to_date(to_char(sysdate, 'yyyy-mm-dd'), 'yyyy-mm-dd')
+        </if>
+    </select>
+    <select id="getYthcjYhkCount" resultType="java.lang.Integer">
+        select count(*) FROM tb_xw_ythcj_yhkjbxx where XXSC_PDBZ = '0'
+        <if test="isZl == '1'.toString()">
+            and CJSJ >= to_date(to_char(sysdate, 'yyyy-mm-dd'), 'yyyy-mm-dd')
+        </if>
+    </select>
+    <select id="getYthcjSwCount" resultType="java.lang.Integer">
+        select count(*) FROM tb_xw_ythcj_sw where XXSC_PDBZ = '0'
+        <if test="isZl == '1'.toString()">
+            and CJSJ >= to_date(to_char(sysdate, 'yyyy-mm-dd'), 'yyyy-mm-dd')
+        </if>
+    </select>
+    <select id="getYthcjHmCount" resultType="java.lang.Integer">
+        select count(*) FROM tb_xw_ythcj_hm where XXSC_PDBZ = '0'
+        <if test="isZl == '1'.toString()">
+            and CJSJ >= to_date(to_char(sysdate, 'yyyy-mm-dd'), 'yyyy-mm-dd')
+        </if>
+    </select>
+    <select id="getYthcjSsxdwpCount" resultType="java.lang.Integer">
+        select count(*) FROM tb_xw_ythcj_ssxdwp where XXSC_PDBZ = '0'
+        <if test="isZl == '1'.toString()">
+            and CJSJ >= to_date(to_char(sysdate, 'yyyy-mm-dd'), 'yyyy-mm-dd')
+        </if>
+    </select>
+
+    <select id="getOrclRyRyzpInfo" parameterType="map" resultMap="TbRycjZpMap">
+       select
+    XXBH as XXZJBH ,
+    RYBH as ASJXGRYBH ,
+    DZWJMC as RYZP_DZWJMC ,
+    DZWJWZ as RYZP_DZWJWZ,
+    DZWJNR as RYZP_DZWJNR ,
+    DZWJDX as RYZP_DZWJDX ,
+    LRSJ as RYZP_JLSJ,
+    to_char(LRSJ,'yyyy-MM-dd hh24:mi:ss') as RYZP_JLSJStr,
+    ZPBW
+
+from TB_RY_RYZP where RYBH = (select RYBH from TB_RY_RYCJ where SCBZ='0' and (RYBH=#{rybh} or JZRYBH=#{rybh} )  and ROWNUM=1) and SCBZ ='0'
+
+    </select>
+</mapper>
\ No newline at end of file