司机修改企业评分传参司机手机号

sckw-modules-api/sckw-system-api/src/main/java/com/sckw/system/api/RemoteSystemService.java

@@ -188,6 +188,7 @@ public interface RemoteSystemService {
      */
     UserCacheResDto queryUserCacheById(Long userId);
     UserResDto queryUserById(Long userId);
+    UserResDto queryUserByPhone(String phone);
 
     /**
      * @desc: 从缓存查用户信息

sckw-modules/sckw-contract/src/main/java/com/sckw/contract/service/impl/KwcContractLogisticsScoreServiceImpl.java

@@ -40,6 +40,7 @@ import com.sckw.redis.utils.RedissonUtils;
 import com.sckw.system.api.RemoteSystemService;
 import com.sckw.system.api.model.dto.res.EntCacheResDto;
 import com.sckw.system.api.model.dto.res.UserCacheResDto;
+import com.sckw.system.api.model.dto.res.UserResDto;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.dubbo.config.annotation.DubboReference;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -412,7 +413,11 @@ public class KwcContractLogisticsScoreServiceImpl implements IKwcContractLogisti
             //2.插入评分明细记录
             LogisticsScoreDetailAddDto detailAddDto = new LogisticsScoreDetailAddDto();
             detailAddDto.setScoreId(logisticsScore.getId());
-            detailAddDto.setInfluenceBy(detailDto.getInfluenceBy());
+            //根据影响人手机号查询影响人userId
+            UserResDto userResDto = remoteSystemService.queryUserByPhone(detailDto.getPhone());
+            if(userResDto != null){
+                detailAddDto.setInfluenceBy(userResDto.getId());
+            }
             detailAddDto.setAction(detailDto.getAction());
             detailAddDto.setScoreChange(entScoreChange);
             detailAddDto.setScore(resultScore);

sckw-modules/sckw-system/src/main/java/com/sckw/system/dao/KwsUserDao.java

@@ -40,6 +40,13 @@ public interface KwsUserDao extends BaseMapper<KwsUser> {
      */
     KwsUser selectByKey(Long id);
 
+    /**
+     * 详情查询
+     * @param phone
+     * @return
+     */
+    KwsUser selectByPhone(String phone);
+
     /**
      * 详情查询
      * @param list

sckw-modules/sckw-system/src/main/java/com/sckw/system/dubbo/RemoteSystemServiceImpl.java

@@ -627,6 +627,16 @@ public class RemoteSystemServiceImpl implements RemoteSystemService {
         return null;
     }
 
+    @Override
+    public UserResDto queryUserByPhone(String phone) {
+        KwsUser kwsUser = kwsUserService.selectByPhone(phone);
+        if (Objects.nonNull(kwsUser)) {
+            UserResDto bean = BeanUtil.toBean(kwsUser, UserResDto.class);
+            return bean;
+        }
+        return null;
+    }
+
     @Override
     public List<UserCacheResDto> queryUserCacheByIds(List<Long> userIds) {
         if (CollectionUtils.isEmpty(userIds)) {

sckw-modules/sckw-system/src/main/java/com/sckw/system/service/KwsUserService.java

@@ -406,6 +406,13 @@ public class KwsUserService {
         return kwsUserDao.selectByKey(key);
     }
 
+    /**
+     * 根据主键查询
+     */
+    public KwsUser selectByPhone(String phone) {
+        return kwsUserDao.selectByPhone(phone);
+    }
+
     /**
      * 根据主键查询
      */

sckw-modules/sckw-system/src/main/resources/mapper/KwsUserDao.xml

@@ -70,6 +70,13 @@
         where id = #{id,jdbcType=BIGINT}
     </select>
 
+    <select id="selectByPhone" parameterType="java.lang.String" resultMap="BaseResultMap">
+        select
+        <include refid="Base_Column_List"/>
+        from kws_user
+        where phone = #{phone, jdbcType=VARCHAR}
+    </select>
+
     <select id="selectByKeys" resultMap="BaseResultMap">
         select
         <include refid="Base_Column_List"/>