pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mybatis/AutoGenerateIdInterceptor.java

@@ -1,8 +1,5 @@
package com.dy.common.mybatis;


import com.alibaba.fastjson2.JSONObject;
import com.alibaba.fastjson2.JSONWriter;
import com.dy.common.po.BaseEntity;
import com.dy.common.util.IDLongGenerator;
import org.apache.ibatis.executor.Executor;

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/config/MyBatisGlConfig.java

New file
@@ -0,0 +1,35 @@
package com.dy.pipIrrGlobal.config;

import jakarta.annotation.PostConstruct;
import org.apache.ibatis.session.SqlSessionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;

import java.util.List;

/**
 * @Author: liurunyu
 * @Date: 2025/4/27 9:31
 * @Description
 */
@Configuration
public class MyBatisGlConfig {

    @Autowired
    private List<SqlSessionFactory> sqlSessionFactoryList;

    @Value("${common.virtual_card_disable_set_inuse:false}")
    private Boolean disableSetInUse;
    /**
     * æ ¹æ®é…ç½®æ–‡ä»¶é…ç½®ï¼Œé…ç½®æ‹¦æˆªå™¨
     */
    @PostConstruct
    public void addMyInterceptor() {
        for (SqlSessionFactory sqlSessionFactory : sqlSessionFactoryList) {
            if (disableSetInUse != null && disableSetInUse.booleanValue()) {
                sqlSessionFactory.getConfiguration().addInterceptor(new VirtualCardInUseInterceptor());
            }
        }
    }
}

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/config/VirtualCardInUseInterceptor.java

New file
@@ -0,0 +1,61 @@
package com.dy.pipIrrGlobal.config;

/**
 * @Author: liurunyu
 * @Date: 2025/4/27 9:19
 * @Description
 */
import com.dy.pipIrrGlobal.pojoSe.SeVirtualCard;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.executor.Executor;
import org.apache.ibatis.mapping.MappedStatement;
import org.apache.ibatis.mapping.SqlCommandType;
import org.apache.ibatis.plugin.Interceptor;
import org.apache.ibatis.plugin.Intercepts;
import org.apache.ibatis.plugin.Invocation;
import org.apache.ibatis.plugin.Signature;
import java.lang.reflect.Method;

/**
 * æ‹¦æˆªè™šæ‹Ÿå¡è¡¨çš„更新操作，使不能设置占用状态操作。
 */
@Intercepts({
        @Signature(
                type = Executor.class,
                method = "update",
                args = {
                        MappedStatement.class,
                        Object.class
                }
        )
})
@Slf4j
public class VirtualCardInUseInterceptor  implements Interceptor {

    static int MAPPED_STATEMENT_INDEX = 0;
    static int PARAMETER_INDEX = 1;
    static String BASE_FIELD_SET_PRIMARY_KEY_FUNTION_SETINUSE = "setInUse";

    @Override
    public Object intercept(Invocation invocation) throws Throwable {
        Object entity = invocation.getArgs()[PARAMETER_INDEX];
        if (entity instanceof SeVirtualCard) {
            MappedStatement mappedStatement = (MappedStatement) invocation.getArgs()[MAPPED_STATEMENT_INDEX];
            SqlCommandType commandType = mappedStatement.getSqlCommandType();
            if (commandType.equals(SqlCommandType.INSERT)) {
                Class<?> entityClass = entity.getClass();
                Method setInUse = null;
                try {
                    setInUse = entityClass.getMethod(BASE_FIELD_SET_PRIMARY_KEY_FUNTION_SETINUSE, Long.class);
                } catch (Exception e) {
                    //当entityClass没有setInUse方法时，会抛出异常
                }
                if (setInUse != null) {
                    setInUse.invoke(entity, 0);
                }
                invocation.getArgs()[PARAMETER_INDEX] = entity;
            }
        }
        return invocation.proceed();
    }
}

 pipIrr-platform/pipIrr-global/src/main/resources/application-common-web(121·þÎñÆ÷).yml

@@ -2,3 +2,8 @@
  # 233服务器：ym,mj,sp,test
  # 121服务器：mq,yq,hlj,gz,lz,jc
  spring_main_datasource_names: mq,yq,hlj,gz,lz,jc

  # è™šæ‹Ÿå¡è¡¨å­—段in_use意为占用状态，当为true时统一设置值为0
  # 233服务器：false
  # 121服务器：true
  virtual_card_disable_set_inuse: true

 pipIrr-platform/pipIrr-global/src/main/resources/application-common-web(233·þÎñÆ÷).yml

@@ -2,3 +2,8 @@
  # 233服务器：ym,mj,sp,test
  # 121服务器：mq,yq,hlj,gz,lz,jc
  spring_main_datasource_names: ym,mj,sp,test

  # è™šæ‹Ÿå¡è¡¨å­—段in_use意为占用状态，当为true时统一设置值为0
  # 233服务器：false
  # 121服务器：true
  virtual_card_disable_set_inuse: false

 pipIrr-platform/pipIrr-global/src/main/resources/application-common-web.yml

@@ -2,3 +2,8 @@
  # 233服务器：ym,mj,sp,test
  # 121服务器：mq,yq,hlj,gz,lz,jc
  spring_main_datasource_names: ym,mj,sp,test

  # è™šæ‹Ÿå¡è¡¨å­—段in_use意为占用状态，当为true时统一设置值为0
  # 233服务器：false
  # 121服务器：true
  virtual_card_disable_set_inuse: false

 pipIrr-platform/pipIrr-global/src/main/resources/mapper/BaUserMapper.xml

@@ -373,8 +373,7 @@
        COUNT(*) AS recordCount
        FROM ba_user user
        <where>
            user.supperAdmin != 1
            AND user.deleted = 0
            user.deleted = 0
            <if test = "phone != null and phone !=''">
                AND user.phone= #{phone}
            </if>

 pipIrr-platform/pipIrr-web/pipIrr-web-sso/src/main/java/com/dy/sso/busi/SsoCtrl.java

@@ -113,25 +113,24 @@
        if(vo.orgTag == null || vo.orgTag.trim().length() == 0){
            return BaseResponseUtils.buildErrorMsg("未选择组织单位");
        }
        if(vo.token == null || vo.token.trim().length() == 0){
            return BaseResponseUtils.buildErrorMsg("无token");
        }
        if(vo.code == null || vo.code.trim().length() == 0){
            return BaseResponseUtils.buildErrorMsg("请输入验证码");
        }
        //把组织单位标签作为数据源名称
        DataSourceContext.set(vo.orgTag);

        // ä»Žæ•°æ®åº“获取验证码
        Map map = sv.getCodeByToken(vo.token);
        Long expiration = Long.parseLong(map.get("expiration").toString());
        Long currentTimestamp = System.currentTimeMillis();
        if(currentTimestamp > expiration) {
            return BaseResponseUtils.buildErrorMsg("验证码已超时");
        }
        String localCode = map.get("code").toString();
        if(!vo.code.equals(localCode)) {
            return BaseResponseUtils.buildErrorMsg("验证码错误");
        if(vo.token != null && vo.token.trim().length() > 0) {
            // ä»Žsession中获取验证码
            //HttpSession session = (HttpSession) request.getSession();
            //String localCode = session.getAttribute(token).toString();
            // ä»Žæ•°æ®åº“获取验证码
            Map map = sv.getCodeByToken(vo.token);
            Long expiration = Long.parseLong(map.get("expiration").toString());
            Long currentTimestamp = System.currentTimeMillis();
            if(currentTimestamp > expiration) {
                return BaseResponseUtils.buildErrorMsg("验证码已超时");
            }
            String localCode = map.get("code").toString();
            if(!vo.code.equals(localCode)) {
                return BaseResponseUtils.buildErrorMsg("验证码错误");
            }
        }

        if(!sv.existPhone(vo.phone)){