1

winsea-haixin-plugin-wangluohuoyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/service/impl/EvaluateInfoServiceImpl.java

@@ -7,11 +7,8 @@ import com.google.common.collect.Lists;
 import com.yh.saas.common.support.util.IdGenerator;
 import com.yh.saas.plugin.yiliangyiyun.entity.*;
 import com.yh.saas.plugin.yiliangyiyun.mapper.EvaluateInfoMapper;
-import com.yh.saas.plugin.yiliangyiyun.service.ICommonUserService;
-import com.yh.saas.plugin.yiliangyiyun.service.IEvaluateInfoService;
+import com.yh.saas.plugin.yiliangyiyun.service.*;
 import com.baomidou.mybatisplus.service.impl.ServiceImpl;
-import com.yh.saas.plugin.yiliangyiyun.service.IFreightInfoService;
-import com.yh.saas.plugin.yiliangyiyun.service.IOrderInfoService;
 import org.activiti.engine.impl.util.CollectionUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -38,6 +35,11 @@ public class EvaluateInfoServiceImpl extends ServiceImpl<EvaluateInfoMapper, Eva
 
     @Autowired
     private ICommonUserService commonUserService;
+    @Autowired
+    private IDriverInfoService driverInfoService;
+    @Autowired
+    private ICargoOwnerInfoService cargoOwnerInfoService;
+
     /**
      * 添加评价
      * @param evaluateInfo
@@ -57,6 +59,33 @@ public class EvaluateInfoServiceImpl extends ServiceImpl<EvaluateInfoMapper, Eva
                     +evaluateInfo.getTranSafety()+evaluateInfo.getServiceQuality()+evaluateInfo.getSatisfaction())/5)));
         }
         this.insert(evaluateInfo);
+        //查询此人好评数
+        Integer haoCount = this.selectCount(new EntityWrapper<EvaluateInfo>()
+                .ge("driver_score_obtained", "4")
+                .eq("evaluatored_id", evaluateInfo.getEvaluatoredId())
+                .eq("delete_flag","0"));
+        //查询此人被评价数
+        Integer count = this.selectCount(new EntityWrapper<EvaluateInfo>()
+                .eq("evaluatored_id", evaluateInfo.getEvaluatoredId())
+                .eq("delete_flag","0"));
+        //查询订单
+        OrderInfo orderInfo = orderInfoService.selectById(evaluateInfo.getOrderId());
+        //被评价人是司机
+        if (evaluateInfo.getEvaluatoredId().equals(orderInfo.getCommonId())){
+            //查询司机信息
+            HyDriverInfo hyDriverInfo = driverInfoService.selectOne(new EntityWrapper<HyDriverInfo>()
+            .eq("common_id",evaluateInfo.getEvaluatoredId()).eq("delete_flag","0"));
+            hyDriverInfo.setFavorableRate(haoCount / count * 100);
+            driverInfoService.updateById(hyDriverInfo);
+        }
+        //被评价人是货主
+        else{
+            //查询货主信息
+            HyCargoOwnerInfo hyCargoOwnerInfo = cargoOwnerInfoService.selectOne(new EntityWrapper<HyCargoOwnerInfo>()
+                    .eq("common_id",evaluateInfo.getEvaluatoredId()).eq("delete_flag","0"));
+            hyCargoOwnerInfo.setFavorableRate(haoCount / count * 100);
+            cargoOwnerInfoService.updateById(hyCargoOwnerInfo);
+        }
         return "OK";
     }
 

winsea-haixin-plugin-wangluohuoyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/service/impl/FeedbackReportServiceImpl.java

@@ -1,13 +1,17 @@
 package com.yh.saas.plugin.yiliangyiyun.service.impl;
 
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.baomidou.mybatisplus.plugins.Page;
 import com.google.common.collect.Lists;
 import com.yh.saas.common.support.util.IdGenerator;
 import com.yh.saas.plugin.yiliangyiyun.constant.StatusEnum;
 import com.yh.saas.plugin.yiliangyiyun.entity.FeedbackReport;
 import com.yh.saas.plugin.yiliangyiyun.entity.HyCargoOwnerCapitalInfo;
+import com.yh.saas.plugin.yiliangyiyun.entity.HyDriverInfo;
 import com.yh.saas.plugin.yiliangyiyun.entity.NewsInfo;
 import com.yh.saas.plugin.yiliangyiyun.mapper.FeedbackReportMapper;
+import com.yh.saas.plugin.yiliangyiyun.service.ICargoOwnerInfoService;
+import com.yh.saas.plugin.yiliangyiyun.service.IDriverInfoService;
 import com.yh.saas.plugin.yiliangyiyun.service.IFeedbackReportService;
 import com.baomidou.mybatisplus.service.impl.ServiceImpl;
 import com.yh.saas.plugin.yiliangyiyun.service.INewsInfoService;
@@ -33,7 +37,8 @@ public class FeedbackReportServiceImpl extends ServiceImpl<FeedbackReportMapper,
 
     @Autowired
     private INewsInfoService newsInfoService;
-
+    @Autowired
+    private IDriverInfoService driverInfoService;
 
     /**
      * 投诉举报编号列表集合
@@ -114,6 +119,23 @@ public class FeedbackReportServiceImpl extends ServiceImpl<FeedbackReportMapper,
             }
         }
         this.insert(feedbackReport);
+        //被投诉举报人是司机
+        if("1".equals(feedbackReport.getObjectFlag())){
+            //查询司机信息
+            HyDriverInfo hyDriverInfo = driverInfoService.selectOne(new EntityWrapper<HyDriverInfo>()
+                    .eq("common_id",feedbackReport.getPassiveCommonId()).eq("delete_flag","0"));
+            //投诉
+            if("1".equals(feedbackReport.getFlag())){
+                Long count = hyDriverInfo.getComplaintsNumber();
+                hyDriverInfo.setComplaintsNumber(count + 1);
+            }
+            //举报
+            else{
+                Long count = hyDriverInfo.getReportedNumber();
+                hyDriverInfo.setReportedNumber(count + 1);
+            }
+            driverInfoService.updateById(hyDriverInfo);
+        }
         return "OK";
     }