|
|
@@ -1,589 +0,0 @@
|
|
|
-package me.zhengjie.dao.jdbc.impl;
|
|
|
-
|
|
|
-import java.sql.ResultSet;
|
|
|
-import java.sql.SQLException;
|
|
|
-import java.util.ArrayList;
|
|
|
-import java.util.HashMap;
|
|
|
-import java.util.List;
|
|
|
-import java.util.Map;
|
|
|
-
|
|
|
-import org.apache.commons.collections.CollectionUtils;
|
|
|
-import org.apache.commons.lang3.StringUtils;
|
|
|
-import org.springframework.beans.factory.annotation.Autowired;
|
|
|
-import org.springframework.jdbc.core.JdbcTemplate;
|
|
|
-import org.springframework.jdbc.core.RowCallbackHandler;
|
|
|
-import org.springframework.jdbc.core.RowMapper;
|
|
|
-import org.springframework.stereotype.Repository;
|
|
|
-import org.springframework.transaction.annotation.Transactional;
|
|
|
-
|
|
|
-import me.zhengjie.dao.jdbc.OrderDao;
|
|
|
-import me.zhengjie.application.bank.controller.vo.Order;
|
|
|
-import me.zhengjie.application.bank.controller.vo.Sms;
|
|
|
-import me.zhengjie.application.bank.controller.vo.SaOrderQueryPageReq;
|
|
|
-import me.zhengjie.application.bank.controller.vo.SaOrderQueryDetailRes;
|
|
|
-import me.zhengjie.application.bank.controller.vo.SaOrderQueryPageRes;
|
|
|
-import me.zhengjie.base.util.StatusEnum;
|
|
|
-
|
|
|
-@Repository
|
|
|
-@Transactional
|
|
|
-public class OrderDaoImpl implements OrderDao {
|
|
|
-
|
|
|
- @Autowired
|
|
|
- private JdbcTemplate jdbcTemplate;
|
|
|
-
|
|
|
- @Override
|
|
|
- @Transactional
|
|
|
- public void insertOrder(Order order) {
|
|
|
- String sql = "insert into `order` (businessNo,appId,orderNo,companyFullName,companyCertNo,companyProvince,companyCity,companyDistrict,companyAddress,companyFile,legalName,legalBirthday,legalCertCode,legalCertNo,legalPhone,contactAuthorize,contactCreditor,loanAmount,loanRate,loanTerm,loanPurpose,loanNo,loanFile,contactAuthorizationFile,createTime,pdfCode,ifPutDown,ifVideo,ifSign) "
|
|
|
- + "values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
|
|
- this.jdbcTemplate.update(sql, order.getBusinessNo(), order.getAppId(), order.getOrderNo(),
|
|
|
- order.getCompanyFullName(), order.getCompanyCertNo(), order.getCompanyProvince(),
|
|
|
- order.getCompanyCity(), order.getCompanyDistrict(), order.getCompanyAddress(), order.getCompanyFile(),
|
|
|
- order.getLegalName(), order.getLegalBirthday(), order.getLegalCertCode(), order.getLegalCertNo(),
|
|
|
- order.getLegalPhone(), order.getContactAuthorize(), order.getContactCreditor(), order.getLoanAmount(),
|
|
|
- order.getLoanRate(), order.getLoanTerm(), order.getLoanPurpose(), order.getLoanNo(),
|
|
|
- order.getLoanFile(), order.getContactAuthorizationFile(), order.getCreateTime(), order.getPdfCode(),
|
|
|
- order.getIfPutDown(), order.getIfVideo(), order.getIfSign());
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public HashMap<String, String> selectOrderByOrderNo(String orderNo) {
|
|
|
- String sql = "select `status`,`notarizeNo` as `no`, `notarizeStartDate` as `startDate`,"
|
|
|
- + "`notarizeEndDate` as `endDate` ,`notarizeFile` as `file`,`notarizeRemark` as `remark`,"
|
|
|
- + "`companyProvince` as `province`,`companyCity` as `city`,`companyDistrict` as `district` from `order` where orderNo = ?";
|
|
|
- final HashMap<String, String> hm = new HashMap<>();
|
|
|
- Object[] arr = new Object[] { orderNo };
|
|
|
- this.jdbcTemplate.query(sql, arr, new RowCallbackHandler() {
|
|
|
- @Override
|
|
|
- public void processRow(ResultSet rs) throws SQLException {
|
|
|
- hm.put("status", rs.getString("status"));
|
|
|
- if (rs.getString("status").equals("1")) {
|
|
|
- hm.put("no", rs.getString("no"));
|
|
|
- hm.put("startDate", rs.getString("startDate"));
|
|
|
- hm.put("file", rs.getString("file"));
|
|
|
- hm.put("remark", rs.getString("remark"));
|
|
|
- }
|
|
|
- }
|
|
|
- });
|
|
|
- return hm;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Order selectOrderById(Integer id) {
|
|
|
- Order order = new Order();
|
|
|
- String sql = "select * from `order` where id=?";
|
|
|
- Object[] arr = new Object[] { id };
|
|
|
- this.jdbcTemplate.query(sql, arr, new RowCallbackHandler() {
|
|
|
- @Override
|
|
|
- public void processRow(ResultSet rs) throws SQLException {
|
|
|
- order.setBusinessNo(rs.getString("businessNo"));
|
|
|
- order.setOrderNo(rs.getString("orderNo"));
|
|
|
- order.setCompanyFullName(rs.getString("companyFullName"));
|
|
|
-
|
|
|
- order.setPdfCode(rs.getString("pdfCode"));
|
|
|
- order.setIfVideo(rs.getInt("ifVideo"));
|
|
|
- order.setIfPutDown(rs.getInt("ifPutDown"));
|
|
|
- order.setIfSign(rs.getInt("ifSign"));
|
|
|
-// order.setNotarizeStartDate(rs.getDate(""));
|
|
|
-// order.setNotarizeEndDate(rs.getDate(""));
|
|
|
- }
|
|
|
- });
|
|
|
- return order;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Order selectOrderDetailById(Integer id) {
|
|
|
- Order order = new Order();
|
|
|
- String sql = "select p.title as companyProvinceTitle,c.title as companyCityTitle,d.title as companyDistrictTitle, tab.* from `order` tab "
|
|
|
- + "left join `area` p on tab.companyProvince=p.code " + "left join `area` c on tab.companyCity=c.code "
|
|
|
- + "left join `area` d on tab.companyDistrict=d.code " + "where tab.id=?";
|
|
|
-
|
|
|
- Object[] arr = new Object[] { id };
|
|
|
- this.jdbcTemplate.query(sql, arr, new RowCallbackHandler() {
|
|
|
- @Override
|
|
|
- public void processRow(ResultSet rs) throws SQLException {
|
|
|
- order.setBusinessNo(rs.getString("businessNo"));
|
|
|
- order.setOrderNo(rs.getString("orderNo"));
|
|
|
-
|
|
|
- order.setCompanyFullName(rs.getString("companyFullName"));
|
|
|
- order.setCompanyCertNo(rs.getString("companyCertNo"));
|
|
|
- order.setCompanyProvinceTitle(rs.getString("companyProvinceTitle"));
|
|
|
- order.setCompanyCityTitle(rs.getString("companyCityTitle"));
|
|
|
- order.setCompanyDistrictTitle(rs.getString("companyDistrictTitle"));
|
|
|
- order.setCompanyAddress(rs.getString("companyAddress"));
|
|
|
- order.setCompanyFile(rs.getString("companyFile"));
|
|
|
-
|
|
|
- order.setLegalName(rs.getString("legalName"));
|
|
|
- order.setLegalBirthday(rs.getString("legalBirthday"));
|
|
|
- order.setLegalCertCode(rs.getString("legalCertCode"));
|
|
|
- order.setLegalCertNo(rs.getString("legalCertNo"));
|
|
|
- order.setLegalPhone(rs.getString("legalPhone"));
|
|
|
-
|
|
|
- // 增加状态
|
|
|
- order.setStatus(rs.getInt("status"));
|
|
|
-
|
|
|
- order.setContactAuthorize(rs.getString("contactAuthorize"));
|
|
|
- order.setContactCreditor(rs.getString("contactCreditor"));
|
|
|
- order.setLoanAmount(rs.getInt("loanAmount"));
|
|
|
- order.setLoanRate(rs.getInt("loanRate"));
|
|
|
- order.setLoanTerm(rs.getInt("loanTerm"));
|
|
|
- order.setLoanPurpose(rs.getString("loanPurpose"));
|
|
|
- order.setLoanNo(rs.getString("loanNo"));
|
|
|
- order.setLoanFile(rs.getString("loanFile"));
|
|
|
- order.setContactAuthorizationFile(rs.getString("contactAuthorizationFile"));
|
|
|
- order.setNotarizeRemark(rs.getString("notarizeRemark"));
|
|
|
- }
|
|
|
- });
|
|
|
- return order;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public SaOrderQueryDetailRes selectSaOrderDetailById(Integer id) {
|
|
|
- SaOrderQueryDetailRes order = new SaOrderQueryDetailRes();
|
|
|
- String sql = "select p.title as companyProvinceTitle,c.title as companyCityTitle,d.title as companyDistrictTitle, tab.* from `order` tab "
|
|
|
- + "left join `area` p on tab.companyProvince=p.code " + "left join `area` c on tab.companyCity=c.code "
|
|
|
- + "left join `area` d on tab.companyDistrict=d.code " + "where tab.id=?";
|
|
|
-
|
|
|
- Object[] arr = new Object[] { id };
|
|
|
- this.jdbcTemplate.query(sql, arr, new RowCallbackHandler() {
|
|
|
- @Override
|
|
|
- public void processRow(ResultSet rs) throws SQLException {
|
|
|
- order.setOrderNo(rs.getString("orderNo"));
|
|
|
- order.setBusinessNo(rs.getString("businessNo"));
|
|
|
- order.setCompanyFullName(rs.getString("companyFullName"));
|
|
|
- order.setCompanyCertNo(rs.getString("companyCertNo"));
|
|
|
- String companyAddress = rs.getString("companyProvinceTitle") + rs.getString("companyCityTitle")
|
|
|
- + rs.getString("companyDistrictTitle") + rs.getString("companyAddress");
|
|
|
- order.setCompanyAddress(companyAddress);
|
|
|
- order.setLegalName(rs.getString("legalName"));
|
|
|
- order.setLegalBirthday(rs.getString("legalBirthday"));
|
|
|
- order.setLegalCertCode(rs.getString("legalCertCode"));
|
|
|
- order.setLegalCertNo(rs.getString("legalCertNo"));
|
|
|
- order.setLegalPhone(rs.getString("legalPhone"));
|
|
|
- order.setContactAuthorize(rs.getString("contactAuthorize"));
|
|
|
- order.setContactCreditor(rs.getString("contactCreditor"));
|
|
|
- order.setLoanAmount(rs.getInt("loanAmount"));
|
|
|
- order.setLoanRate(rs.getInt("loanRate"));
|
|
|
- order.setLoanTerm(rs.getInt("loanTerm"));
|
|
|
- order.setLoanPurpose(rs.getString("loanPurpose"));
|
|
|
- order.setLoanNo(rs.getString("loanNo"));
|
|
|
- order.setNotarizeRemark(rs.getString("notarizeRemark"));
|
|
|
- }
|
|
|
- });
|
|
|
- return order;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Integer selectOrderByLoginParameter(Sms sms) {
|
|
|
- String sql = "select count(id) as num from `order` where legalName=? and legalPhone=? and legalCertNo=?";
|
|
|
- Object[] arr = new Object[] { sms.getUserName(), sms.getPhone(), sms.getIdCode() };
|
|
|
- this.jdbcTemplate.query(sql, arr, new RowCallbackHandler() {
|
|
|
- @Override
|
|
|
- public void processRow(ResultSet rs) throws SQLException {
|
|
|
- sms.setCount(rs.getInt("num"));
|
|
|
- }
|
|
|
- });
|
|
|
- return sms.getCount();
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List<Order> selectOrderList(Order order) {
|
|
|
- Integer pageNum = order.getPageSize();
|
|
|
- Integer beginMum = (order.getPageIndex() - 1) * pageNum;
|
|
|
- String sqlAdd = " ";
|
|
|
- ArrayList<Object> list = new ArrayList<>();
|
|
|
- if (order.getAccountId() != null) {
|
|
|
- sqlAdd += " and tab.accountId =? ";
|
|
|
- list.add(order.getAccountId());
|
|
|
- }
|
|
|
- if (order.getLoanNo() != null) {
|
|
|
-
|
|
|
- sqlAdd += " and tab.loanNo =? ";
|
|
|
- list.add(order.getLoanNo());
|
|
|
- }
|
|
|
- if (order.getLegalName() != null) {
|
|
|
- sqlAdd += " and tab.legalName =? ";
|
|
|
- list.add(order.getLegalName());
|
|
|
- }
|
|
|
- if (order.getLegalPhone() != null) {
|
|
|
- sqlAdd += " and tab.legalPhone=? ";
|
|
|
- list.add( order.getLegalPhone());
|
|
|
- }
|
|
|
- if (order.getLegalCertNo() != null) {
|
|
|
- sqlAdd += " and tab.legalCertNo = ?";
|
|
|
- list.add( order.getLegalCertNo());
|
|
|
- }
|
|
|
- if (order.getStatus() != null) {
|
|
|
- sqlAdd += " and tab.status = ? ";
|
|
|
- list.add( order.getStatus());
|
|
|
- }
|
|
|
- if (order.getCompanyProvince() != null) {
|
|
|
- sqlAdd += " and tab.companyProvince = ?" ;
|
|
|
- list.add(order.getCompanyProvince());
|
|
|
- }
|
|
|
- if (order.getCompanyCity() != null) {
|
|
|
- sqlAdd += " and tab.companyCity = ? " ;
|
|
|
- list.add(order.getCompanyCity());
|
|
|
- }
|
|
|
- if (order.getCompanyDistrict() != null) {
|
|
|
- sqlAdd += " and tab.companyDistrict = ? " ;
|
|
|
- list.add(order.getCompanyDistrict());
|
|
|
- }
|
|
|
- if (StringUtils.isNotBlank(order.getAccountCompany())) {
|
|
|
- sqlAdd += " and a.company =? ";
|
|
|
- list.add(order.getAccountCompany());
|
|
|
- }
|
|
|
-
|
|
|
- // 获取页数
|
|
|
- String sqlCount = "select count(tab.id) as num from `order` tab"
|
|
|
- + " left join `account` a on tab.accountId = a.id where 1=1 " + sqlAdd;
|
|
|
- Integer count = selectListCount(sqlCount,list.toArray(), pageNum);
|
|
|
- list.add(beginMum);
|
|
|
- list.add(pageNum);
|
|
|
- String sql = "select a.userName as accountUserName , a.company as accountCompany, a.type as accountType, tab.*, "
|
|
|
- + "date_format(tab.notarizeStartDate,'%Y-%m-%d %H:%i:%s') as start_dt, "
|
|
|
- + "date_format(tab.notarizeEndDate,'%Y-%m-%d %H:%i:%s') as end_dt " + "from `order` tab "
|
|
|
- + "left join `account` a on tab.accountId = a.id where 1=1 " + sqlAdd + " order by tab.id desc "
|
|
|
- + " limit ?,?";
|
|
|
-
|
|
|
- return this.jdbcTemplate.query(sql, list.toArray(),new RowMapper<Order>() {
|
|
|
- @Override
|
|
|
- public Order mapRow(ResultSet rs, int rowNum) throws SQLException {
|
|
|
- Order order = new Order();
|
|
|
- order.setAccountId(rs.getInt("accountId"));
|
|
|
- order.setId(rs.getInt("id"));
|
|
|
- order.setOrderNo(rs.getString("orderNo"));
|
|
|
- order.setBusinessNo(rs.getString("businessNo"));
|
|
|
- order.setCompanyFullName(rs.getString("companyFullName"));
|
|
|
- order.setCompanyProvince(rs.getInt("companyProvince"));
|
|
|
- order.setCompanyCity(rs.getInt("companyCity"));
|
|
|
- order.setCompanyDistrict(rs.getInt("companyDistrict"));
|
|
|
- order.setLoanNo(rs.getString("loanNo"));
|
|
|
- order.setLegalName(rs.getString("legalName"));
|
|
|
- order.setLegalCertNo(rs.getString("legalCertNo"));
|
|
|
- order.setLoanAmount(rs.getInt("loanAmount"));
|
|
|
- order.setLegalPhone(rs.getString("legalPhone"));
|
|
|
- order.setNotarizeStartDate(rs.getString("notarizeStartDate"));
|
|
|
- order.setNotarizeEndDate(rs.getString("notarizeEndDate"));
|
|
|
- order.setNotarizeRemark(rs.getString("notarizeRemark"));
|
|
|
- order.setStatus(rs.getInt("status"));
|
|
|
- order.setCreateTime(rs.getDate("createTime"));
|
|
|
- order.setAccountUserName(rs.getString("accountUserName"));
|
|
|
- order.setAccountCompany(rs.getString("accountCompany"));
|
|
|
- order.setAccountType(rs.getInt("accountType"));
|
|
|
- order.setCount(count);
|
|
|
- return order;
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 根据订单ID查询所属客户经理账户ID
|
|
|
- *
|
|
|
- * @param id
|
|
|
- * @return
|
|
|
- */
|
|
|
- @Override
|
|
|
- public Integer selectOrderAccountIdById(Integer id) {
|
|
|
- String sql = "select accountId from `order` where id=?";
|
|
|
- Object[] arr = new Object[] { id };
|
|
|
- Order order = new Order();
|
|
|
- this.jdbcTemplate.query(sql, arr, new RowCallbackHandler() {
|
|
|
- public void processRow(ResultSet rs) throws SQLException {
|
|
|
- order.setAccountId(rs.getInt("accountId"));
|
|
|
- }
|
|
|
- });
|
|
|
- return order.getAccountId();
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 查询条数
|
|
|
- *
|
|
|
- * @param sql
|
|
|
- * @param pageNum
|
|
|
- * @return
|
|
|
- */
|
|
|
- public Integer selectListCount(String sql,Object obj[], Integer pageNum) {
|
|
|
- Integer count = 0;
|
|
|
- Order order = new Order();
|
|
|
- this.jdbcTemplate.query(sql,obj, new RowCallbackHandler() {
|
|
|
- @Override
|
|
|
- public void processRow(ResultSet rs) throws SQLException {
|
|
|
- order.setCount(rs.getInt("num"));
|
|
|
- }
|
|
|
- });
|
|
|
- return order.getCount();
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public void updateOrderStatusById(Order order) {
|
|
|
- String sqlAdd = " and id=" + order.getId();
|
|
|
- if (order.getAccountId() != null) {
|
|
|
- sqlAdd += " and accountId=" + order.getAccountId();
|
|
|
- }
|
|
|
- String sql = "update `order` set status=" + order.getStatus() + " where 1=1 " + sqlAdd;
|
|
|
- this.jdbcTemplate.update(sql);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Order selectOrder(Integer id) {
|
|
|
- Order order = new Order();
|
|
|
- String sql = "select * from `order` where id=?";
|
|
|
- Object[] arr = new Object[] { id };
|
|
|
- this.jdbcTemplate.query(sql, arr, new RowCallbackHandler() {
|
|
|
- @Override
|
|
|
- public void processRow(ResultSet rs) throws SQLException {
|
|
|
- order.setId(rs.getInt("id"));
|
|
|
- order.setBusinessNo(rs.getString("businessNo"));
|
|
|
- order.setAppId(rs.getString("appId"));
|
|
|
- order.setOrderNo(rs.getString("orderNo"));
|
|
|
- order.setCompanyFullName(rs.getString("companyFullName"));
|
|
|
- order.setCompanyCertNo(rs.getString("companyCertNo"));
|
|
|
- order.setCompanyProvince(rs.getInt("companyProvince"));
|
|
|
- order.setCompanyCity(rs.getInt("companyCity"));
|
|
|
- order.setCompanyDistrict(rs.getInt("companyDistrict"));
|
|
|
- order.setCompanyAddress(rs.getString("companyAddress"));
|
|
|
- order.setCompanyFile(rs.getString("companyFile"));
|
|
|
- order.setLegalName(rs.getString("legalName"));
|
|
|
- order.setLegalCertNo(rs.getString("legalCertNo"));
|
|
|
- order.setLegalBirthday(rs.getString("legalBirthday"));
|
|
|
- order.setLegalPhone(rs.getString("legalPhone"));
|
|
|
- order.setContactAuthorize(rs.getString("contactAuthorize"));
|
|
|
- order.setContactCreditor(rs.getString("contactCreditor"));
|
|
|
- order.setLoanAmount(rs.getInt("loanAmount"));
|
|
|
- order.setLoanRate(rs.getInt("loanRate"));
|
|
|
- order.setLoanTerm(rs.getInt("loanTerm"));
|
|
|
- order.setLoanPurpose(rs.getString("loanPurpose"));
|
|
|
- order.setLoanNo(rs.getString("loanNo"));
|
|
|
- order.setLoanFile(rs.getString("loanFile"));
|
|
|
- order.setContactAuthorizationFile(rs.getString("contactAuthorizationFile"));
|
|
|
- order.setStatus(rs.getInt("status"));
|
|
|
- order.setNotarizeNo(rs.getString("notarizeNo"));
|
|
|
- order.setNotarizeStartDate(rs.getString("notarizeStartDate"));
|
|
|
- order.setNotarizeEndDate(rs.getString("notarizeEndDate"));
|
|
|
- order.setNotarizeFile(rs.getString("notarizeFile"));
|
|
|
- order.setNotarizeRemark(rs.getString("notarizeRemark"));
|
|
|
- order.setPdfCode(rs.getString("pdfCode"));
|
|
|
- order.setLocalVideoFile(rs.getString("localVideoFile"));
|
|
|
- order.setAppVideFile(rs.getString("appVideFile"));
|
|
|
- order.setAppSignFile(rs.getString("appSignFile"));
|
|
|
- order.setIfPutDown(rs.getInt("ifPutDown"));
|
|
|
- order.setIfVideo(rs.getInt("ifVideo"));
|
|
|
- order.setIfSign(rs.getInt("ifSign"));
|
|
|
- order.setAccountId(rs.getInt("accountId"));
|
|
|
- }
|
|
|
- });
|
|
|
- return order;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public void updateOrderAccountId(Integer id, Integer accountId) {
|
|
|
- String sql = "update `order` set accountId= " + accountId + " where id=" + id;
|
|
|
- this.jdbcTemplate.update(sql);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public void setStatus(Integer id, Integer status, String reason) {
|
|
|
- String sql = "";
|
|
|
- if (StringUtils.isNotEmpty(reason)) {
|
|
|
- sql = "update `order` set status=" + status + " , notarizeRemark='" + reason + "' where id=" + id;
|
|
|
- } else {
|
|
|
- sql = "update `order` set status=" + status + " where id=" + id;
|
|
|
- }
|
|
|
- this.jdbcTemplate.update(sql);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public void setStartEndTime(Integer id, String start, String end) {
|
|
|
- String sql = "update `order` set notarizeStartDate=? ,notarizeEndDate=? where id=?";
|
|
|
- this.jdbcTemplate.update(sql, start, end, id);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List<SaOrderQueryPageRes> getSaOrderPage(SaOrderQueryPageReq req) {
|
|
|
- int offset = req.getPageSize();
|
|
|
- int index = (req.getPageNum() - 1) * offset;
|
|
|
- String sqlAdd = " ";
|
|
|
-
|
|
|
- if (CollectionUtils.isNotEmpty(req.getQueryAppIds())) {
|
|
|
- sqlAdd += " and a.appid in (" + StringUtils.join(req.getQueryAppIds(), ",") + ")";
|
|
|
- }
|
|
|
-
|
|
|
- if (StringUtils.isNotBlank(req.getLoanNo())) {
|
|
|
- sqlAdd += " and a.loanNo like concat ('%', " + req.getLoanNo() + ", '%'";
|
|
|
- }
|
|
|
-
|
|
|
- if (StringUtils.isNotBlank(req.getLegalName())) {
|
|
|
- sqlAdd += " and a.legalName like concat ('%', " + req.getLegalName() + ", '%'";
|
|
|
- }
|
|
|
-
|
|
|
- if (StringUtils.isNotBlank(req.getLegalCertNo())) {
|
|
|
- sqlAdd += " and a.legalCertNo like concat ('%', " + req.getLegalCertNo() + ", '%'";
|
|
|
- }
|
|
|
-
|
|
|
- if (StringUtils.isNotBlank(req.getLegalPhone())) {
|
|
|
- sqlAdd += " and a.legalPhone like concat ('%', " + req.getLegalPhone() + ", '%'";
|
|
|
- }
|
|
|
- if (req.getNotaryStatus() != null) {
|
|
|
- sqlAdd += " and a.status = " + req.getNotaryStatus();
|
|
|
- }
|
|
|
-
|
|
|
- String sql = "select a.id, a.businessNo, a.loanNo, a.legalName, a.legalCertNo,"
|
|
|
- + "a.legalPhone, a.loanAmount, DATE_FORMAT(a.createTime, '%Y-%m-%d %H:%i:%s') as createTime, a.status, "
|
|
|
- + "b.company as notaryOffice, b.userName as notary, a.type" + "from `order` a "
|
|
|
- + "left join `account` b on a.accountId = b.id " + "where 1=1 " + sqlAdd + " order by a.id " + "limit "
|
|
|
- + index + "," + offset;
|
|
|
-
|
|
|
- return this.jdbcTemplate.query(sql, new RowMapper<SaOrderQueryPageRes>() {
|
|
|
- @Override
|
|
|
- public SaOrderQueryPageRes mapRow(ResultSet rs, int rowNum) throws SQLException {
|
|
|
- SaOrderQueryPageRes order = new SaOrderQueryPageRes();
|
|
|
- order.setId(rs.getInt("id"));
|
|
|
- order.setBusinessNo(rs.getString("businessNo"));
|
|
|
- order.setLoanNo(rs.getString("loanNo"));
|
|
|
- order.setLegalName(rs.getString("legalName"));
|
|
|
- order.setLegalCertNo(rs.getString("legalCertNo"));
|
|
|
- order.setLegalPhone(rs.getString("legalPhone"));
|
|
|
- order.setLoanAmount(rs.getInt("loanAmount"));
|
|
|
- order.setCreateTime(rs.getString("createTime"));
|
|
|
- order.setStatus(rs.getInt("status"));
|
|
|
- int type = rs.getInt("type");
|
|
|
- order.setType(type);
|
|
|
- order.setNotaryOffice(rs.getString("notaryOffice"));
|
|
|
- order.setNotary(rs.getString("notary"));
|
|
|
- order.setNotaryStatusDesc(StatusEnum.NotaryStatusEnum.getExplain(rs.getInt("status")));
|
|
|
- return order;
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Integer countSaOrderPage(SaOrderQueryPageReq req) {
|
|
|
- String sqlAdd = " ";
|
|
|
-
|
|
|
- if (CollectionUtils.isNotEmpty(req.getQueryAppIds())) {
|
|
|
- sqlAdd += " and a.appid in (" + StringUtils.join(req.getQueryAppIds(), ",") + ")";
|
|
|
- }
|
|
|
-
|
|
|
- if (StringUtils.isNotBlank(req.getLoanNo())) {
|
|
|
- sqlAdd += " and a.loanNo like concat ('%', " + req.getLoanNo() + ", '%'";
|
|
|
- }
|
|
|
-
|
|
|
- if (StringUtils.isNotBlank(req.getLegalName())) {
|
|
|
- sqlAdd += " and a.legalName like concat ('%', " + req.getLegalName() + ", '%'";
|
|
|
- }
|
|
|
-
|
|
|
- if (StringUtils.isNotBlank(req.getLegalCertNo())) {
|
|
|
- sqlAdd += " and a.legalCertNo like concat ('%', " + req.getLegalCertNo() + ", '%'";
|
|
|
- }
|
|
|
-
|
|
|
- if (StringUtils.isNotBlank(req.getLegalPhone())) {
|
|
|
- sqlAdd += " and a.legalPhone like concat ('%', " + req.getLegalPhone() + ", '%'";
|
|
|
- }
|
|
|
- if (req.getNotaryStatus() != null) {
|
|
|
- sqlAdd += " and a.status = " + req.getNotaryStatus();
|
|
|
- }
|
|
|
-
|
|
|
- String sql = "select count(1) as `count` " + "from `order` a " + "left join `account` b on a.accountId = b.id "
|
|
|
- + "where 1=1 " + sqlAdd;
|
|
|
-
|
|
|
- return this.jdbcTemplate.queryForObject(sql, Integer.class);
|
|
|
- }
|
|
|
-
|
|
|
- // 查询所有图片
|
|
|
- public Map<String, Object> queryPicByOrderId(int id) {
|
|
|
-
|
|
|
- String sql = "select * from pic_path where order_id=" + id;
|
|
|
-
|
|
|
- return this.jdbcTemplate.queryForMap(sql);
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- public Integer selectOrderByPhone(String phone) {
|
|
|
- String sql = "select count(id) as num from `order` where legalPhone=? ";
|
|
|
- Object[] arr = new Object[] {phone};
|
|
|
- return this.jdbcTemplate.queryForObject(sql, arr,Integer.class);
|
|
|
-
|
|
|
-
|
|
|
- }
|
|
|
- @Override
|
|
|
- public List<Order> getOrderDetail(Order order) {
|
|
|
-
|
|
|
- String sqlAdd = "";
|
|
|
- ArrayList<Object> list = new ArrayList<>();
|
|
|
- if (order.getAccountId() != null) {
|
|
|
- sqlAdd += " and tab.accountId =? ";
|
|
|
- list.add(order.getAccountId());
|
|
|
- }
|
|
|
- if (order.getLoanNo() != null) {
|
|
|
-
|
|
|
- sqlAdd += " and tab.loanNo =? ";
|
|
|
- list.add(order.getLoanNo());
|
|
|
- }
|
|
|
- if (order.getLegalName() != null) {
|
|
|
- sqlAdd += " and tab.legalName =? ";
|
|
|
- list.add(order.getLegalName());
|
|
|
- }
|
|
|
- if (order.getLegalPhone() != null) {
|
|
|
- sqlAdd += " and tab.legalPhone=? ";
|
|
|
- list.add( order.getLegalPhone());
|
|
|
- }
|
|
|
- if (order.getLegalCertNo() != null) {
|
|
|
- sqlAdd += " and tab.legalCertNo = ?";
|
|
|
- list.add( order.getLegalCertNo());
|
|
|
- }
|
|
|
- if (order.getStatus() != null) {
|
|
|
- sqlAdd += " and tab.status = ? ";
|
|
|
- list.add( order.getStatus());
|
|
|
- }
|
|
|
- if (order.getCompanyProvince() != null) {
|
|
|
- sqlAdd += " and tab.companyProvince = ?" ;
|
|
|
- list.add(order.getCompanyProvince());
|
|
|
- }
|
|
|
- if (order.getCompanyCity() != null) {
|
|
|
- sqlAdd += " and tab.companyCity = ? " ;
|
|
|
- list.add(order.getCompanyCity());
|
|
|
- }
|
|
|
- if (order.getCompanyDistrict() != null) {
|
|
|
- sqlAdd += " and tab.companyDistrict = ? " ;
|
|
|
- list.add(order.getCompanyDistrict());
|
|
|
- }
|
|
|
- if (StringUtils.isNotBlank(order.getAccountCompany())) {
|
|
|
- sqlAdd += " and a.company =? ";
|
|
|
- list.add(order.getAccountCompany());
|
|
|
- }
|
|
|
- String sql=" select tab.* from `order` tab where 1=1 ";
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
- return this.jdbcTemplate.query(sql+sqlAdd.toString(), list.toArray(),new RowMapper<Order>() {
|
|
|
- @Override
|
|
|
- public Order mapRow(ResultSet rs, int rowNum) throws SQLException {
|
|
|
- Order order = new Order();
|
|
|
- order.setAccountId(rs.getInt("accountId"));
|
|
|
- order.setId(rs.getInt("id"));
|
|
|
- order.setOrderNo(rs.getString("orderNo"));
|
|
|
- order.setBusinessNo(rs.getString("businessNo"));
|
|
|
- order.setCompanyFullName(rs.getString("companyFullName"));
|
|
|
- order.setCompanyProvince(rs.getInt("companyProvince"));
|
|
|
- order.setCompanyCity(rs.getInt("companyCity"));
|
|
|
- order.setCompanyDistrict(rs.getInt("companyDistrict"));
|
|
|
- order.setLoanNo(rs.getString("loanNo"));
|
|
|
- order.setLegalName(rs.getString("legalName"));
|
|
|
- order.setLegalCertNo(rs.getString("legalCertNo"));
|
|
|
- order.setLoanAmount(rs.getInt("loanAmount"));
|
|
|
- order.setLegalPhone(rs.getString("legalPhone"));
|
|
|
- order.setNotarizeStartDate(rs.getString("notarizeStartDate"));
|
|
|
- order.setNotarizeEndDate(rs.getString("notarizeEndDate"));
|
|
|
- order.setNotarizeRemark(rs.getString("notarizeRemark"));
|
|
|
- order.setStatus(rs.getInt("status"));
|
|
|
- order.setCreateTime(rs.getDate("createTime"));
|
|
|
-// order.setAccountUserName(rs.getString("accountUserName"));
|
|
|
-// order.setAccountCompany(rs.getString("accountCompany"));
|
|
|
-// order.setAccountType(rs.getInt("accountType"));
|
|
|
-
|
|
|
- return order;
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
-}
|