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

.

dev
lisai17@sina.com 2020-10-11 01:00:02 +08:00
parent 5f9b9b400b
commit 1bbb3301bc
3 changed files with 15 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ssjygl-xsx-local/src/main/java/com/cowr/local/ssjygl/synctask/SyncTaskService.java
View File

@ -226,7 +226,7 @@ public class SyncTaskService {
JSONObject data = increment_data.getJSONObject(tablename);
String pks = data.getString("pks");
JSONArray pkv = data.getJSONArray("pkv");
JSONObject increment_data = data.getJSONObject("increment_data");
JSONObject increment_data = data.getJSONObject("increment");
Record record = Db.findByIds(tablename, pks, pkv.toArray());
boolean change = false;
@ -281,6 +281,8 @@ public class SyncTaskService {
err[0] = String.format("重复数据 %s", recvdata.toJSONString());
} else {
log.error(e.getMessage(), e);
err[0] = String.format("其他异常 %s", e.getMessage());
}
return false;

20
ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/prepay/prepaydetail/PrepayDetailSyncService.java
View File

@ -129,7 +129,17 @@ public class PrepayDetailSyncService extends BaseSyncService {
// 只有在 state == 2 表示审核通过时，更新余额
if (state == 2) {
customer.setType(1); // 标记为预付费用户
if(customer.getType() != 1){
customer.setType(1); // 标记为预付费用户
ret = customer.update();
synctask.addUpdateData(customer);
if (!ret) {
return false;
}
}
PrepayCustomer prepayCustomer = PrepayCustomerService.me.getPrepayCustomer(customer.getId());
if (prepayCustomer == null) {
@ -156,14 +166,6 @@ public class PrepayDetailSyncService extends BaseSyncService {
new JSONObject().fluentPut("surplus", model.getAmount()) // 取消订单，在原余额上加上一个数
);
}
if (!ret) {
return false;
}
ret = customer.update();
synctask.addUpdateData(customer);
}
if (!ret) {

2
ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/synctask/SyncTaskService.java
View File

@ -307,7 +307,7 @@ public class SyncTaskService {
JSONObject data = increment_data.getJSONObject(tablename);
String pks = data.getString("pks");
JSONArray pkv = data.getJSONArray("pkv");
JSONObject increment_data = data.getJSONObject("increment_data");
JSONObject increment_data = data.getJSONObject("increment");
Record record = Db.findByIds(tablename, pks, pkv.toArray());
boolean change = false;