Merge remote-tracking branch 'origin/v6.4_transportation_20231110' into…

performance-api/src/main/java/com/clx/performance/param/pay/NotifyString.java

 package com.clx.performance.param.pay;
 
-import com.msl.common.enums.ResultEnum;
 
 
 /**
@@ -9,7 +8,7 @@ import com.msl.common.enums.ResultEnum;
  * @date 2017年6月01日
  * @description
  */
-public class NotifyString extends PayResult<String> {
+public class NotifyString extends Result<String> {
 	/** 支付操作 参考<MessageTypeEnum> */
 	private Integer action;
 	/** 交易单号 */
@@ -22,7 +21,7 @@ public class NotifyString extends PayResult<String> {
 	public NotifyString(){
 		super();
 	}
-	public NotifyString(PayResult<String> ret){
+	public NotifyString(Result<String> ret){
 		this.setCode(ret.getCode());
 		this.setMsg(ret.getMsg());
 		this.setData(ret.getData());

performance-api/src/main/java/com/clx/performance/param/pay/Result.java

+package com.clx.performance.param.pay;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+
+/**
+ * 
+ * 类： Result
+ * 描述：接口返回结果类
+ * @author wangjf
+ * 时间：2017年3月23日下午3:46:50
+ * 版本：v1.0
+ * 修改人：wangjf
+ */
+public class Result<T> {
+	
+	private Integer code; // 返回结果代码，0为成功
+	/**
+	 * 返回结果代码
+	 * 0为成功 ，其他代码请参照代码文档
+	 * @return
+	 */
+	public Integer getCode() {
+		return code;
+	}
+
+	private Long total;//总共记录数
+
+	private Integer pageNum;//总共页数
+
+	/**
+	 * 0代表成功，其他代码请参考《返回值说明文档》 
+	 * 请务必按规定填写！
+	 * @param code 结果代码
+	 */
+	public void setCode(Integer code) {
+		this.code = code;
+	}
+
+	public String getMsg() {
+		return msg;
+	}
+
+	/**
+	 * 错误消息，接口中的错误处理，请务必填写错误消息<br/>
+	 * 当成功时消息应为“success”
+	 * @param msg 错误消息
+	 */
+	public void setMsg(String msg) {
+		this.msg = msg;
+	}
+
+	public T getData() {
+		return data;
+	}
+
+	public void setData(T data) {
+		this.data = data;
+	}
+
+	private String msg;
+	private T data;
+	/**
+	 * 默认code = 0,<br/>
+	 * msg = "success"
+	 */
+	public Result() {
+		this.code = 0;
+		this.msg = "success";
+	}
+	/**
+	 * 默认code = 0, 
+	 * msg = "success",<br/>
+	 * 当成功返回结果时，可使用此方法，直接将返回结果填写即可
+	 * @param data ，返回结果
+	 */
+	public Result(T data) {
+		this.code = 0;
+		this.msg = "success";
+		this.data = data;
+	}
+
+	/**
+	 * 查询列表返回成功
+	 * @param data
+	 * @param pageNum
+	 * @param total
+	 */
+	public Result(T data, Integer pageNum, Long total) {
+		this.code = 0;
+		this.msg = "success";
+		this.data = data;
+		this.pageNum = pageNum;
+		this.total = total;
+	}
+
+	/**
+	 * 产生错误时，需要在枚举中拼接自定义返回的内容
+	 * @param e
+	 * @param msg
+	 */
+	public Result(ResultEnum e, String msg) {
+		this.code = e.getCode();
+		this.msg = String.format(e.getMsg(), msg);
+	}
+
+	/**
+	 * 产生错误时，可以使用此构造方法，在new时直接填写错误代码及消息即可
+	 * @param code
+	 * @param msg
+	 */
+	public Result(Integer code,String msg) {
+		this.code = code;
+		this.msg = msg;
+	}
+	public Result(Integer code,String msg, T data) {
+		this.code = code;
+		this.msg = msg;
+		this.data = data;
+	}
+	@JsonIgnore
+	public void setResultEnum(ResultEnum e){
+		this.code = e.getCode();
+		this.msg = e.getMsg();
+	}
+	
+	public Result(ResultEnum e) {
+		this.code = e.getCode();
+		this.msg = e.getMsg();
+	}
+
+	public Result(T data, ResultEnum e) {
+		this.code = e.getCode();
+		this.msg = e.getMsg();
+		this.data = data;
+	}
+
+	public Long getTotal() {
+		return total;
+	}
+
+	public void setTotal(Long total) {
+		this.total = total;
+	}
+
+	public Integer getPageNum() {
+		return pageNum;
+	}
+
+	public void setPageNum(Integer pageNum) {
+		this.pageNum = pageNum;
+	}
+
+	@Override
+	public String toString() {
+		return "Result [code=" + code + ", msg=" + msg + ", data=" + data + "]";
+	}
+
+	/**
+	 * 是否成功
+	 * @return
+	 */
+	public boolean succeed() {
+		return code != null && code == ResultCodeEnum.SUCCESS.getCode();
+	}
+}

performance-api/src/main/java/com/clx/performance/param/pay/ResultCodeEnum.java

+package com.clx.performance.param.pay;
+
+public enum ResultCodeEnum implements ResultEnum {
+	SUCCESS(0, "success"),
+    FAIL(1, "服务繁忙"),
+    THIRDPARTY(2,"调用第三方接口参数错误"),
+    HTTPERROR(3,"HTTP请求异常"),
+    ILLEGAL_PARAMETER(4, "非法参数"),
+    SYSTEM_ERROR(5, "系统异常"),
+	REQUEST_TOO_OFTEN(6, "请勿频繁点击"),
+	MASSAGE_SERVICE_ERROR(7, "消息服务繁忙"),
+	ORDER_COMPLETE(8, "订单已经处理过了"),
+	DATA_SYNC_ERROR(9, "数据同步异常"),
+	MQ_ERROR(10, "消息队列异常"),
+	NO_LOGIN(100, "没有登录"),
+	NO_OPERATING_AUTHORIZATION(101, "没有权限"),
+	FEGIN_NULL(102, "FEGIN返回null"),
+	FEGIN_ERROR(103, "fegin调用繁忙"),
+	EVALUATION_INFORMATION_NULL(104, "评价信息不能为空"),
+	SUBJECT_TO_BE_EVALUATED_NULL(105, "被评价主体不能为空"),
+	EVALUATION_TYPE_ERROR(106, "评价类型错误"),
+	EVALUATION_SCORE_ERROR(107, "评价分值错误"),
+	LABEL_OR_CONTENT_NULL(108, "差评时必须有标签或者内容"),
+	CHILD_NO_NULL(109, "运单号不能为空"),
+	REDIS_LOCK_ERROR(110, "锁异常"),
+
+	VERIFICATION_CODE_ERROR(111, "验证码错误"),
+	VERIFICATION_CODE_COUNT_ERROR(112, "验证码输入错误次数过多，请重新获取"),
+
+	ACCOUNT_LOCKED_TTL_ERROR(113, "账号已锁定，请%s分钟之后再试"),
+	ACCOUNT_PWD_ERROR(114, "密码错误，还可尝试%s次，超过将锁定"),
+
+	PRODUCT_TYPE_ERROR(115, "产品线参数错误"),
+
+	;
+
+	// 成员变量
+	private String msg;
+	private int code;
+
+	// 构造方法
+	private ResultCodeEnum(int code, String msg) {
+		this.msg = msg;
+		this.code = code;
+	}
+
+	// 普通方法
+	public static String getMsg(int code) {
+		for (ResultCodeEnum c : ResultCodeEnum.values()) {
+			if (c.getCode() == code) {
+				return c.msg;
+			}
+		}
+		return null;
+	}
+	
+	public String getMsg() {
+		return msg;
+	}
+
+	public void setMsg(String msg) {
+		this.msg = msg;
+	}
+
+	public int getCode() {
+		return code;
+	}
+
+	public void setCode(int code) {
+		this.code = code;
+	}
+
+}

performance-api/src/main/java/com/clx/performance/param/pay/ResultEnum.java

+package com.clx.performance.param.pay;
+
+public interface ResultEnum {
+
+	String getMsg();
+
+	int getCode();
+}

performance-web/src/main/java/com/clx/performance/controller/feign/OrderChildFeignController.java

@@ -13,7 +13,6 @@ import lombok.AllArgsConstructor;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
-import javax.validation.constraints.NotBlank;
 import javax.validation.constraints.NotNull;
 import java.util.List;
 
@@ -61,14 +60,4 @@ public class OrderChildFeignController {
         return Result.ok(feignOrderChildService.getLineStatistics(sendSystemAddressId, receiveSystemAddressId));
 
     }
-
-    @ApiOperation(value = "运单取消/到达最晚拉运时间 同步最后一车", notes = "<br>By:刘海泉")
-    @RequestMapping(value = "/syncLastTruck", method = RequestMethod.GET)
-    Result<?> syncLastTruck(@RequestParam("orderNo") @NotBlank(message = "订单编号不能为空") String orderNo){
-        return lastTruckService.syncLastTruckChild4OrderTrigger(orderNo);
-    }
-
-
-
-
 }

performance-web/src/main/java/com/clx/performance/dao/OrderChildDao.java

@@ -153,5 +153,7 @@ public interface OrderChildDao extends BaseDao<OrderChildMapper, OrderChild, Int
 
     BigDecimal getLastDriverFreightByTransportLine(Integer sendSystemAddressId, Integer receiveSystemAddressId);
 
-    OrderChild findLastTruckChildByCreateTime(String orderNo);
+    OrderChild getOrderCompleteLastTruck(String orderNo);
+
+    Long haveArriveReceiveChild(String orderNo);
 }

performance-web/src/main/java/com/clx/performance/dao/impl/OrderChildDaoImpl.java

@@ -468,11 +468,21 @@ public class OrderChildDaoImpl extends BaseDaoImpl<OrderChildMapper, OrderChild,
     }
 
     @Override
-    public OrderChild findLastTruckChildByCreateTime(String orderNo) {
+    public OrderChild getOrderCompleteLastTruck(String orderNo) {
         LambdaQueryWrapper<OrderChild> query = new LambdaQueryWrapper<>();
-        query.eq(OrderChild :: getOrderNo,orderNo);
-        query.orderByDesc(OrderChild ::getCreateTime);
+        query.eq(OrderChild ::getOrderNo,orderNo);
+        query.ge(OrderChild :: getStatus,OrderChildEnum.Status.ARRIVE_SEND.getCode());
+        query.le(OrderChild :: getStatus,OrderChildEnum.Status.COMPLETE.getCode());
+        query.orderByDesc(OrderChild :: getArriveReceiveTime);
         query.last("limit 1");
         return baseMapper.selectOne(query);
     }
+
+    @Override
+    public Long haveArriveReceiveChild(String orderNo) {
+        LambdaQueryWrapper<OrderChild> query = new LambdaQueryWrapper<>();
+        query.eq(OrderChild ::getOrderNo,orderNo);
+        query.lt(OrderChild :: getStatus,OrderChildEnum.Status.ARRIVE_RECEIVE.getCode());
+        return baseMapper.selectCount(query);
+    }
 }

performance-web/src/main/java/com/clx/performance/listener/OrderChildDtsListener.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
 import com.clx.open.sdk.callback.OpenCallBackClient;
 import com.clx.open.sdk.callback.message.OrderChildMessage;
 import com.clx.open.sdk.enums.ResultStatusEnum;
+import com.clx.order.enums.OrderEnum;
 import com.clx.order.enums.SyncPlatformEnum;
 import com.clx.order.feign.OrderFeign;
 import com.clx.order.vo.feign.FeignOrderVO;
@@ -95,12 +96,27 @@ public class OrderChildDtsListener  {
             OpenCallBackClient client = new OpenCallBackClient(mslAppConfig.getUrl(),mslAppConfig.getAppId(),mslAppConfig.getSecret());
             Result<?> result = client.encryptPost(JSON.toJSONString(after),after.topic());
             log.info("运单信息同步，运单编号:{},响应结果:{}",after.getChildNo(),JSON.toJSONString(result));
-            //当运单状态为到达目的地之后的状态时候，需要判断最后一车的逻辑
-            if(after.getStatus() >= OrderChildEnum.Status.ARRIVE_RECEIVE.getCode()  && after.getStatus() <= OrderChildEnum.Status.COMPLETE.getCode()){
-                OrderChild child = lastTruckService.getLastTruckChild(after.getOrderNo());
-                if(Objects.nonNull(child)){
-                    lastTruckService.syncLastTruckChild(child);
-                }
+
+            syncLastTruck(orderInfoFeign,after);
+
+        }
+    }
+
+    public void syncLastTruck(FeignOrderVO orderInfoFeign,OrderChildMessage after){
+        //当运单状态为到达目的地之后的状态时候，需要判断最后一车的逻辑
+        if(after.getStatus() >= OrderChildEnum.Status.ARRIVE_RECEIVE.getCode()  && after.getStatus() <= OrderChildEnum.Status.COMPLETE.getCode()){
+            OrderChild child;
+            if(Objects.equals(orderInfoFeign.getOrderStatus(), OrderEnum.Status.COMPLETED.getCode()) ||
+                    Objects.equals(orderInfoFeign.getOrderStatus(), OrderEnum.Status.SUCCESS.getCode())) { //订单变成已完成 || 已完结  （不存在司机可以取消的运单）
+                OrderEnum.Status byCode = OrderEnum.Status.getByCode(orderInfoFeign.getOrderStatus());
+                log.info("订单号:{},运单号：{},订单状态：{},开始查询最后一车运单===========" ,orderInfoFeign.getOrderNo(),after.getChildNo(),
+                        Objects.nonNull(byCode)?byCode.getName():"未知状态");
+                child = lastTruckService.getOrderCompleteLastTruck(after.getOrderNo());
+            }else{  // 订单除  已完成 || 已完结  外的其他状态
+                child = lastTruckService.getLastTruckChild(after.getOrderNo());
+            }
+            if(Objects.nonNull(child)){
+                lastTruckService.syncLastTruckChild(child);
             }
         }
     }

performance-web/src/main/java/com/clx/performance/service/LastTruckService.java

 package com.clx.performance.service;
 
 import com.clx.performance.model.OrderChild;
-import com.msl.common.result.Result;
 
 public interface LastTruckService {
 
     OrderChild getLastTruckChild(String orderNo);
 
-    Result<?> syncLastTruckChild(OrderChild child);
+    void syncLastTruckChild(OrderChild child);
 
-    Result<?> syncLastTruckChild4OrderTrigger(String orderNo);
 
+    OrderChild getOrderCompleteLastTruck(String orderNo);
 }

performance-web/src/main/java/com/clx/performance/service/impl/LastTruckServiceImpl.java

@@ -67,29 +67,24 @@ public class LastTruckServiceImpl implements LastTruckService {
      * @return
      **/
     @Override
-    public Result<?> syncLastTruckChild(OrderChild child) {
+    public void syncLastTruckChild(OrderChild child) {
         OrderChildMessage message = orderChildStruct.convertMessage(child);
         message.setLastFlag(ResultStatusEnum.YES.getCode());
         log.info("开始同步最后一车的运单，运单编号:{},运单信息:{}",child.getChildNo(), JSON.toJSONString(message));
         OpenCallBackClient client2 = new OpenCallBackClient(mslAppConfig.getUrl(),mslAppConfig.getAppId(),mslAppConfig.getSecret());
         Result<?> result2 = client2.encryptPost(JSON.toJSONString(message),message.topic());
         log.info("结束同步最后一车的运单，运单编号:{}，响应结果:{}",child.getChildNo(),JSON.toJSONString(result2));
-        return result2;
     }
 
-    /**
-     * @Author kavin
-     * @Description 订单取消、到达最晚拉运时间 同步最后一车
-     * @Param [orderNo]
-     * @return
-     **/
-    public Result<?> syncLastTruckChild4OrderTrigger(String orderNo) {
-        OrderChild child = orderChildDao.findLastTruckChildByCreateTime(orderNo);
-        log.info("订单取消/到达最晚拉运时间获取最后一车运单，订单号：{} ,获取到的最后一车的运单信息：{}",orderNo,JSON.toJSONString(child));
-        if(Objects.nonNull(child)){
-            return syncLastTruckChild(child);
+    @Override
+    public OrderChild getOrderCompleteLastTruck(String orderNo) {
+        //判断当前订单下是否存在未到达目的地之前的运单 && 排除掉已取消的运单
+        Long count = orderChildDao.haveArriveReceiveChild(orderNo);
+        log.info("已完成/已完结的订单号:{},查询运单状态非取消并且在到达目的地之前的运单数量为:{}",orderNo,count);
+        if(count  == 0 ){
+            //说明排除已取消的运单后，剩下的所有运单都已经是到达目的地之后的状态，根据到达目的地的时间倒序取出第一条运单作为最后一车
+            return orderChildDao.getOrderCompleteLastTruck(orderNo);
         }
-        return Result.ok("承运系统提示:承运系统未查询到该订单下的运单信息");
+        return null;
     }
-
 }

performance-web/src/main/java/com/clx/performance/service/impl/breakcontract/BreakContractSettlementOwnerServiceImpl.java

@@ -426,8 +426,7 @@ public class BreakContractSettlementOwnerServiceImpl  implements BreakContractSe
         BreakContractOwnerRuleVO.AutoRule autoRule = JSONObject.parseObject(autoRuleJson, BreakContractOwnerRuleVO.AutoRule.class);
         BreakContractOwnerRuleVO.OrderCancelRule orderCancelRule = autoRule.getOrderCancelRule();//订单取消规则
 
-        //运单状态（包括货主取消）
-        //运单状态（包括货主取消）
+        //运单状态
         List<Integer> statusList = new ArrayList<>();
         statusList.add(OrderChildEnum.Status.CREATED.getCode());
         statusList.add(OrderChildEnum.Status.PAY.getCode());
@@ -489,8 +488,13 @@ public class BreakContractSettlementOwnerServiceImpl  implements BreakContractSe
                 BigDecimal noTransitWeight = transportWeight.subtract(deliveredWeight);//未拉运的重量
                 BigDecimal noTransitFreight = noTransitWeight.multiply(validFreightPrice);//未拉运的费用
                 BigDecimal totalFreight = deliveredFreight.add(noTransitFreight);//总运费
-                BigDecimal baseFigure = totalFreight.multiply(orderCancelRule.getAfterRatio()).multiply(cancelWeight)
-                        .divide(transportWeight,2, BigDecimal.ROUND_HALF_UP);//基础违约金
+                BigDecimal baseFigure;
+                if(cancelWeight.compareTo(BigDecimal.ZERO) == 0){//没有取消的吨数
+                    baseFigure = totalFreight.multiply(orderCancelRule.getAfterRatio());//基础违约金
+                }else{
+                    baseFigure = totalFreight.multiply(orderCancelRule.getAfterRatio()).multiply(cancelWeight)
+                            .divide(transportWeight,2, BigDecimal.ROUND_HALF_UP);//基础违约金
+                }
 
                 //挂单后，车辆违约金
                 BigDecimal truckFigure = BigDecimal.ZERO;

performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementOwnerDetailServiceImpl.java

@@ -85,9 +85,6 @@ public class SettlementOwnerDetailServiceImpl  implements SettlementOwnerDetailS
 
 
         settlementOwnerDetail.setFinalPaymentStatus(SettlementOwnerDetailEnum.FinalPaymentStatus.NO.getCode());
-        if(settlementOwnerDetail.getSettlementFreight().compareTo(BigDecimal.ZERO) == 0){
-            settlementOwnerDetail.setFinalPaymentStatus(SettlementOwnerDetailEnum.FinalPaymentStatus.NO_REQUIRE.getCode());
-        }
 
         settlementOwnerDetailDao.saveEntity(settlementOwnerDetail);
 

performance-web/src/main/java/com/clx/performance/sqlProvider/OrderChildSqlProvider.java

 package com.clx.performance.sqlProvider;
 
-
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.clx.performance.enums.OrderChildEnum;
 import com.clx.performance.param.app.PageOrderChildOfDriverParam;
@@ -16,7 +15,6 @@ import org.apache.commons.lang3.StringUtils;
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.jdbc.SQL;
 
-import java.time.LocalDateTime;
 import java.util.List;
 import java.util.Objects;