|
@@ -55,6 +55,7 @@ public class ALIPAY_GENERATED_ACCOUNT extends Ops implements Runnable {
|
|
try {
|
|
try {
|
|
originDoc = cursor.next();
|
|
originDoc = cursor.next();
|
|
DataMap newDoc = initWithOrigin(originDoc, output.getFileId());
|
|
DataMap newDoc = initWithOrigin(originDoc, output.getFileId());
|
|
|
|
+ deleteKey(newDoc, "FILEID");
|
|
String v1 = Ops.getString(originDoc, origin, "用户信息");
|
|
String v1 = Ops.getString(originDoc, origin, "用户信息");
|
|
List<String> v1List = Ops.extract_1(v1);
|
|
List<String> v1List = Ops.extract_1(v1);
|
|
Ops.setString(
|
|
Ops.setString(
|
|
@@ -76,6 +77,7 @@ public class ALIPAY_GENERATED_ACCOUNT extends Ops implements Runnable {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
replaceKey(newDoc, "金额", "交易金额");
|
|
replaceKey(newDoc, "金额", "交易金额");
|
|
|
|
+ deleteKey(newDoc, "FILEID");
|
|
needToSave.add(newDoc);
|
|
needToSave.add(newDoc);
|
|
if (needToSave.size() >= 1000) {
|
|
if (needToSave.size() >= 1000) {
|
|
saveLines(new ArrayList<>(needToSave), mongoTemplate);
|
|
saveLines(new ArrayList<>(needToSave), mongoTemplate);
|