石广澎
2023-12-12 45bfb77d4b4d1b1d3204475caba9b9c0e3e04ef9
consum-base/src/main/java/com/consum/base/service/impl/FinSysTenantUserServiceImpl.java
File was renamed from consum-base/src/main/java/com/consum/base/service/FinSysTenantUserServiceImpl.java
@@ -1,4 +1,12 @@
package com.consum.base.service;
package com.consum.base.service.impl;
import com.consum.base.service.FinSysTenantUserService;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Service;
import com.consum.base.pojo.FinSysTenantUserSearchParam;
import com.consum.model.po.FinSysTenantUser;
@@ -9,15 +17,9 @@
import com.walker.db.page.GenericPager;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.jdbc.service.BaseServiceImpl;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Service
public class FinSysTenantUserServiceImpl extends BaseServiceImpl {
public class FinSysTenantUserServiceImpl extends BaseServiceImpl implements FinSysTenantUserService {
    private static final String SQL_GET_USER =
        "SELECT * FROM fin_sys_tenant_user WHERE IS_DELETE = 0 AND `STATUS` = 1 AND TENANT_ID = ?";
@@ -50,6 +52,7 @@
     * @Author wh
     * @Date 2023/7/17 14:26
     */
    @Override
    public GenericPager<FinSysTenantUser> queryAllPageUser(FinSysTenantUserSearchParam param) {
        Map<String, Object> parameter = new HashMap<>(5);
        StringBuilder sql = new StringBuilder(SQL_QH_PAGE_USER_PREFIX);
@@ -118,6 +121,7 @@
        return this.selectSplit(sql.toString(), parameter, new FinSysTenantUser());
    }
    @Override
    public FinSysTenantUser queryOneById(String id) {
        FinSysTenantUser finSysTenantUser = new FinSysTenantUser();
        finSysTenantUser.setId(Long.valueOf(id));
@@ -127,7 +131,9 @@
        }
        return null;
    }
    public  FinSysTenantUser queryOneBySysId(String sysUserId) {
    @Override
    public FinSysTenantUser queryOneBySysId(String sysUserId) {
        FinSysTenantUser finSysTenantUser = new FinSysTenantUser();
        finSysTenantUser.setSysUserId(Long.valueOf(sysUserId));
        List<FinSysTenantUser> finSysTenantUserList = this.select(finSysTenantUser);
@@ -137,14 +143,10 @@
        return null;
    }
    @Override
    public FinSysTenantUser queryOneByUserId(String userId) {
        List<FinSysTenantUser> finSysTenantUserList =
            this.select(SQL_TENANT_USER, new Object[] {userId}, new FinSysTenantUser());
        if (finSysTenantUserList.size() > 0) {
            return finSysTenantUserList.get(0);
        } else {
            return null;
        }
        FinSysTenantUser finSysTenantUser = this.get(SQL_TENANT_USER, new Object[] {userId}, new FinSysTenantUser());
        return finSysTenantUser;
    }
    /**
@@ -153,6 +155,7 @@
     * @param roleIdList
     * @param userId
     */
    @Override
    public void execInsertRoleUserList(List<Long> roleIdList, Long userId) {
        List<Object[]> parameters = new ArrayList<>();
        Object[] one = null;
@@ -168,6 +171,7 @@
    /**
     * 批量添加角色对应的用户。支持同时多个用户
     */
    @Override
    public void execInsertRoleUserList(List<FinSysTenantUser> finSysTenantUsers) {
        List<Object[]> parameters = new ArrayList<>();
        for (FinSysTenantUser finSysTenantUser : finSysTenantUsers) {
@@ -188,6 +192,7 @@
     *
     * @param userId
     */
    @Override
    public void execDelRoleUserList(Long userId) {
        List<Object[]> parameters = new ArrayList<>();
        Object[] one = new Object[1];
@@ -196,19 +201,7 @@
        this.execBatchUpdate(SQL_DELETE_ROLE_USER, parameters);
    }
    /**
     * 根据用户id和角色id删除用户角色
     *
     * @param userId
     */
    public void execDeleteRoleByUserIdAndRoleId(Long userId, Long roleId) {
        List<Object[]> parameters = new ArrayList<>();
        Object[] one = new Object[2];
        one[0] = userId;
        one[1] = roleId;
        parameters.add(one);
        this.execBatchUpdate(SQL_DELETE_ROLE_BY_USER_ID_AND_ROLE_ID, parameters);
    }
    /**
     * 根据userCode查询重复。
@@ -216,18 +209,14 @@
     * @param userCode 用户登录标识
     * @return
     */
    public Integer getByUserCode(String userCode) {
    @Override
    public FinSysTenantUser getByUserCode(String userCode) {
        Map<String, Object> parameter = new HashMap<>();
        StringBuilder sql = new StringBuilder(SQL_SELECT_USER_CODE);
        sql.append("and  USER_CODE= :userCode");
        sql.append("and USER_CODE= :userCode");
        parameter.put("userCode", userCode);
        sql.append(" limit 1");
        List<FinSysTenantUser> select = this.select(sql.toString(), parameter, new FinSysTenantUser());
        Integer flag = 0;
        if (select != null && select.size() > 0) {
            flag = select.size();
        }
        return flag;
        FinSysTenantUser finSysTenantUser = this.get(sql.toString(), parameter, new FinSysTenantUser());
        return finSysTenantUser;
    }
    /**
@@ -236,6 +225,7 @@
     * @param userId
     * @return
     */
    @Override
    public List<S_role> getByUserId(Long userId) {
        Map<String, Object> parameter = new HashMap<>();
        StringBuilder sql = new StringBuilder(SQL_SELECT_USER_ID);
@@ -250,6 +240,7 @@
     *
     * @return
     */
    @Override
    public List<S_role> getRoleAll() {
        Map<String, Object> parameter = new HashMap<>();
        StringBuilder sql = new StringBuilder(SQL_SELECT_USER_ID);
@@ -257,6 +248,7 @@
        return select;
    }
    @Override
    public List<S_dept> selectDept(String deptName) {
        StringBuilder sqlStr = new StringBuilder(SQL_DEPT_ROLES);
        Map<String, Object> paramts = new HashMap<>();
@@ -271,6 +263,7 @@
     * @Author wh
     * @Date 2023/10/4 15:49
     */
    @Override
    public List<FinSysTenantUser> getByOrgId(Long orgId) {
        return this.select(SQL_GET_USER, new Object[] {orgId}, new FinSysTenantUser());
    }