同步流量bug

src/main/java/track/task/TrackingFlowTask.java

@@ -350,7 +350,7 @@ public class TrackingFlowTask {
             }else{
                 //查看历史总消耗流量是否超出
                 BigDecimal totalFlow = tkioFlowRepository.sumFlowByEmailAndContractCode(contract.getEmail(),contract.getContractCode());
-                if(totalFlow!=null){
+                totalFlow=totalFlow==null?new BigDecimal(0):totalFlow;
                     Double contractTrackFlow = contract.getTrackFlow() * 10000;
                     if(contractTrackFlow.longValue()-totalFlow.longValue()-clickNum.longValue()>=0){
                         tkioFlow.setFlow(clickNum.longValue());
@@ -358,9 +358,6 @@ public class TrackingFlowTask {
                         tkioFlow.setFlow(contractTrackFlow.longValue() - totalFlow.longValue());
                         tkioFlow.setCostFlow(clickNum.longValue()-tkioFlow.getFlow());
                     }
-                }else{
-                    tkioFlow.setFlow(clickNum.longValue());
-                }
 
             }
             return tkioFlow;