上片模块配置pp表多数据源（可供其他模块配置多数据源参考）

zhoushihao

2024-04-16 ffb758283ece163e04c629def3bd700d292d7f89

 UnLoadGlassModule/src/main/java/com/mes/mapper/DownWorkstationMapper.java

@@ -1,6 +1,5 @@
package com.mes.mapper;



import com.baomidou.dynamic.datasource.annotation.DS;

import com.baomidou.mybatisplus.annotation.InterceptorIgnore;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;

import com.mes.entity.DownGlassInfo;

@@ -10,12 +9,12 @@
import org.springframework.stereotype.Repository;



import java.util.List;

import java.util.Map;



@Mapper

@Component

@Repository

@InterceptorIgnore(tenantLine = "true")

@DS("hangzhoumes") // 指定使用 hangzhoumes 数据源

public interface DownWorkstationMapper extends BaseMapper<DownWorkstation> {

//根据工位ID和设备ID更新工位状态

    @Update("UPDATE down_workstation SET work_state = #{workState} " +

@@ -66,4 +65,30 @@


    @Update("UPDATE down_workstation_task SET state = 0 WHERE flow_card_id = #{flowCardId}")

    void update_task_state_to_zero(@Param("flowCardId") String flowCardId);





@Select(" SELECT * FROM down_workstation WHERE workstation_id >= 1 AND workstation_id <= 5")

    List<DownWorkstation> getoneDownWorkstations();





    @Select(" SELECT * FROM down_workstation WHERE workstation_id >= 6 AND workstation_id <= 10")

    List<DownWorkstation> gettwoDownWorkstations();







    @Select("SELECT DISTINCT  flowcard_id from glass_info")

    @ResultType(Map.class)

    List<Map<String, Object>> getflowCardId();



    @Update("UPDATE down_workstation SET flow_card_id = NULL, total_quantity = 0, racks_number = 0 WHERE workstation_id = #{workstationId}")

    void clearFlowCardInfoByWorkstationId(@Param("workstationId") int workstationId);



    // 获取总数量

    @Select("SELECT total_quantity FROM down_workstation WHERE workstation_id = #{workstationId}")

    int getTotalQuantity(@Param("workstationId") int workstationId);



    // 获取落架数量

    @Select("SELECT racks_number FROM down_workstation WHERE workstation_id = #{workstationId}")

    int getRacksNumber(@Param("workstationId") int workstationId);



}