xjm
/
ssjygl-xsct-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

.

dev
lisai17@sina.com 2020-10-11 00:46:46 +08:00
parent 13fcbcc212
commit 5f9b9b400b
2 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
ssjygl-xsx-common/src/main/java/com/cowr/model/SyncTask.java
View File

@ -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);

9
ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/refunddetail/RefundDetailSyncService.java
View File

@ -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)) // 结算完成，在原余额上加上一个负数
);
}
}