| | |
| | | try { |
| | | Thread.sleep(CORE_SCAN_FREQUENCY_MILLISECOND); |
| | | |
| | | List<String> actionGroupIds = actionService.selectPrepareGroup(); |
| | | List<String> actionGroupIds = actionService.selectGroupNo(ActionStsType.PREPARE); |
| | | for (String actionGroupId : actionGroupIds) { |
| | | mainService.publishAction(actionGroupId); |
| | | } |
| | |
| | | |
| | | List<Map<String, Object>> selectCountGroupByType(); |
| | | |
| | | List<String> selectGroupNo(@Param("actionSts") Long actionSts); |
| | | |
| | | List<String> selectPrepareGroup(); |
| | | |
| | | List<Long> selectTaskIdsByGroupId(@Param("groupId") String groupId); |
| | |
| | | |
| | | List<Map<String, Object>> selectCountGroupByType(); |
| | | |
| | | List<String> selectGroupNo(ActionStsType actionStsType); |
| | | |
| | | List<String> selectPrepareGroup(); |
| | | |
| | | List<Long> selectTaskIdsByGroupId(String groupId); |
| | |
| | | } |
| | | |
| | | @Override |
| | | public List<String> selectGroupNo(ActionStsType actionStsType) { |
| | | return this.baseMapper.selectGroupNo(actionStsType.val()); |
| | | } |
| | | |
| | | @Override |
| | | public List<String> selectPrepareGroup() { |
| | | return this.baseMapper.selectPrepareGroup(); |
| | | } |
| | |
| | | ORDER BY count DESC |
| | | </select> |
| | | |
| | | <select id="selectGroupNo" resultType="java.lang.String"> |
| | | SELECT group_id |
| | | FROM man_action |
| | | WHERE 1=1 |
| | | AND action_sts = #{actionSts} |
| | | AND group_id IS NOT NULL |
| | | GROUP BY group_id |
| | | </select> |
| | | |
| | | <select id="selectPrepareGroup" resultType="java.lang.String"> |
| | | SELECT ma.group_id |
| | | FROM man_action ma |