增加订单判断是否评论

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/UserCommentBiz.java

@@ -14,6 +14,8 @@ import com.github.wxiaoqi.security.common.biz.BaseBiz;
 import com.github.wxiaoqi.security.common.exception.BaseException;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
 import com.github.wxiaoqi.security.common.vo.PageDataVO;
+import com.xxfc.platform.order.entity.BaseOrder;
+import com.xxfc.platform.order.feign.OrderFeign;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -26,7 +28,7 @@ import java.util.List;
 @Service
 @Slf4j
 public class UserCommentBiz extends BaseBiz<UserCommentMapper, UserComment>{
-
+    private OrderFeign orderFeign;
 
 
 
@@ -142,11 +144,23 @@ public class UserCommentBiz extends BaseBiz<UserCommentMapper, UserComment>{
     }
 
     /**
+     * 订单评论
      * 处理维度
      * 总分
      * @param userComment
      */
     public void saveComment(UserComment userComment){
+        String no = userComment.getOrderNo();
+        if(no == null || ("").equals(no)){
+            throw  new BaseException("订单号不能为空", ResultCode.FAILED_CODE);
+        }
+        BaseOrder baseOrder = orderFeign.queryByNo(no);
+        if(baseOrder == null){
+            throw  new BaseException("订单错误", ResultCode.FAILED_CODE);
+        }
+        if(baseOrder.getIsAppraise() == 1){
+            throw  new BaseException("订单已评价，不能重复评论", ResultCode.FAILED_CODE);
+        }
         JSONArray jsonArray = JSONArray.parseArray(userComment.getAppraiseJson());
         if(jsonArray == null || jsonArray.size() == 0){
             throw  new BaseException("评论维度不能为空", ResultCode.FAILED_CODE);
@@ -191,6 +205,9 @@ public class UserCommentBiz extends BaseBiz<UserCommentMapper, UserComment>{
                 mapper.addreplyNum(rootParentId);
             }
         }
+
+        baseOrder.setIsAppraise(1);
+        orderFeign.updateBaseOrder(baseOrder);
     }
 
 

xx-order/xx-order-api/src/main/java/com/xxfc/platform/order/entity/BaseOrder.java

@@ -363,4 +363,7 @@ public class BaseOrder implements Serializable {
 
 	@Column(name = "order_sign")
 	private Integer orderSign;
+
+	@Column(name = "is_appraise")
+	private Integer isAppraise;
 }

xx-order/xx-order-api/src/main/java/com/xxfc/platform/order/feign/OrderFeign.java

@@ -52,4 +52,11 @@ public interface OrderFeign {
     @PostMapping(value = "chw/orderPulishReceive/add")
     ObjectRestResponse<BaseOrder> add(@RequestBody PulishReceiveBO bo);
 
+    @GetMapping(value = "/baseOrder/queryByNo")
+    BaseOrder queryByNo(@RequestParam("no")String no);
+
+    @PostMapping(value = "/baseOrder/updateBaseOrder")
+    BaseOrder updateBaseOrder(@RequestBody BaseOrder baseOrder);
+
+
 }

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/rest/BaseOrderController.java

@@ -523,4 +523,15 @@ public class BaseOrderController extends CommonBaseController implements UserRes
         return baseOrderBiz.updateBaseOrder(baseOrder);
     }
 
+    @RequestMapping(value = "/queryByNo", method = RequestMethod.GET)
+    public BaseOrder queryByNo(@RequestParam("no") String no) {
+        BaseOrder baseOrder = new BaseOrder();
+        baseOrder.setNo(no);
+        return baseOrderBiz.selectOne(baseOrder);
+    }
+
+    @RequestMapping(value = "/updateBaseOrder", method = RequestMethod.POST)
+    public void updateBaseOrder(@RequestBody BaseOrder baseOrder) {
+         baseOrderBiz.updateSelectiveById(baseOrder);
+    }
 }