From 5f9b9b400bba38f6738afb345e7ffabd43f349d7 Mon Sep 17 00:00:00 2001
From: "lisai17@sina.com" <lisai17@sina.com>
Date: Sun, 11 Oct 2020 00:46:46 +0800
Subject: [PATCH] .

---
 .../src/main/java/com/cowr/model/SyncTask.java         | 10 ++--------
 .../prepay/refunddetail/RefundDetailSyncService.java   |  9 ++++++++-
 2 files changed, 10 insertions(+), 9 deletions(-)

diff --git a/ssjygl-xsx-common/src/main/java/com/cowr/model/SyncTask.java b/ssjygl-xsx-common/src/main/java/com/cowr/model/SyncTask.java
index 7a2b6c6..2fb5eac 100644
--- a/ssjygl-xsx-common/src/main/java/com/cowr/model/SyncTask.java
+++ b/ssjygl-xsx-common/src/main/java/com/cowr/model/SyncTask.java
@@ -51,16 +51,10 @@ public class SyncTask extends BaseSyncTask<SyncTask> {
     }
 
     public SyncTask addIncrementData(String tablename, String pks, Object pkv, JSONObject obj){
-        JSONObject data = new JSONObject();
-        data.put("pks", pks);
-        data.put("pkv", new JSONArray().add(pkv));
-        data.put("increment", obj);
-        _increment_data.put(tablename, data);
-
-        return this;
+        return addIncrementData(tablename, pks, new JSONArray().fluentAdd(pkv), obj);
     }
 
-    public SyncTask addIncrementData(String tablename, String pks, JSONObject pkv, JSONObject obj){
+    public SyncTask addIncrementData(String tablename, String pks, JSONArray pkv, JSONObject obj){
         JSONObject data = new JSONObject();
         data.put("pks", pks);
         data.put("pkv", pkv);
diff --git a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/refunddetail/RefundDetailSyncService.java b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/refunddetail/RefundDetailSyncService.java
index e46d5e9..095e4f0 100644
--- a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/refunddetail/RefundDetailSyncService.java
+++ b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/refunddetail/RefundDetailSyncService.java
@@ -1,5 +1,6 @@
 package com.cowr.service.ssjygl.prepay.refunddetail;
 
+import com.alibaba.fastjson.JSONObject;
 import com.cowr.common.enums.Enums;
 import com.cowr.common.view.Result;
 import com.cowr.model.*;
@@ -247,7 +248,13 @@ public class RefundDetailSyncService extends BaseSyncService {
 
                                 ret = prepayCustomer.update();
 
-                                synctask.addUpdateData(prepayCustomer);
+                                // 余额变化需要广播
+                                synctask.addIncrementData(
+                                        prepayCustomer.getTablename(),
+                                        "id",
+                                        prepayCustomer.getId(),
+                                        new JSONObject().fluentPut("surplus", new BigDecimal(0).subtract(amount)) // 结算完成，在原余额上加上一个负数
+                                );
                             }
                         }