更新来源，固定使用信息源的名称

src/main/java/com/zzsn/leaderbase/kafka/PersonOfJobChangeKafkaConsumer.java

@@ -63,7 +63,15 @@ public class PersonOfJobChangeKafkaConsumer {
             String id = String.valueOf(generatorIdService.getId());
             baseData.setId(id);
         }
-
+        //更新来源，固定使用信息源的名称
+        if(StringUtils.isNotEmpty(baseData.getSid())){
+            String origin = characterExtractInfoService.getOriginBySid(baseData.getSid());
+            if(StringUtils.isNotEmpty(origin)){
+                baseData.setOrigin(origin);
+                record.setOrigin(origin);
+                log.info("更新来源：{}",origin);
+            }
+        }
         List<CharacterExtractInfo> list = new ArrayList<>();
         Map<String, List<InfoExtractionParam>> map = new HashMap<>();
         map.put("data_list", Collections.singletonList(record));

src/main/java/com/zzsn/leaderbase/mapper/CharacterExtractInfoMapper.java

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.zzsn.leaderbase.entity.CharacterExtractInfo;
 import com.zzsn.leaderbase.vo.ExtractListVo;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Select;
 
 import java.util.List;
@@ -23,4 +24,6 @@ public interface CharacterExtractInfoMapper extends BaseMapper<CharacterExtractI
     List<CharacterExtractInfo> getList(ExtractListVo extractListVo);
 
     Integer getListCount(ExtractListVo extractListVo);
+
+    String getOriginBySid(@Param("sid") String sid);
 }

src/main/java/com/zzsn/leaderbase/service/CharacterExtractInfoService.java

@@ -33,4 +33,6 @@ public interface CharacterExtractInfoService extends IService<CharacterExtractIn
     Result<?> checkNewlyAdded(CheckVo checkVo);
 
     Result<?> checkMerge(CheckVo checkVo);
+
+    String getOriginBySid(String sid);
 }

src/main/java/com/zzsn/leaderbase/service/impl/CharacterExtractInfoServiceImpl.java

@@ -136,6 +136,11 @@ public class CharacterExtractInfoServiceImpl extends ServiceImpl<CharacterExtrac
         return Result.OK(character);
     }
 
+    @Override
+    public String getOriginBySid(String sid) {
+        return this.baseMapper.getOriginBySid(sid);
+    }
+
 
     private  CharacterBasicInfo convertCharacter( CharacterBasicInfo character ,CharacterExtractInfo extractInfo){
         String id = Long.toString(generatorIdService.getOrderId());

src/main/resources/mapper/CharacterExtractInfoMapper.xml

@@ -37,7 +37,11 @@
         </if>
     </sql>
 
-
+    <select id="getOriginBySid" resultType="java.lang.String">
+        select m.info_name from info_source s
+        LEFT JOIN info_source_main m on (s.info_source_id = m.id)
+        where s.id = #{sid} limit 1
+    </select>
 </mapper>