|
|
@@ -9,7 +9,6 @@ import java.util.HashMap;
|
|
|
|
|
|
public class DRPWarrantycardCheck extends ServiceController {
|
|
|
private static HashMap<String, Long> agentsnumMapping = new HashMap<>();
|
|
|
- private static long mincustid = -12170623L;
|
|
|
|
|
|
static {
|
|
|
try {
|
|
|
@@ -28,6 +27,10 @@ public class DRPWarrantycardCheck extends ServiceController {
|
|
|
try {
|
|
|
SQLDump sqlDump = new SQLDump();
|
|
|
drpWarrantycardRows = dbConnect.runSqlQuery("select * from mddrp.twarrantycard where eordermatchflag=0 limit 10");
|
|
|
+
|
|
|
+ Rows rows = dbConnect.runSqlQuery("select min(sa_customersid) as sa_customersid from sa_customers");
|
|
|
+ long mincustid = rows.get(0).getLong("sa_customersid");
|
|
|
+
|
|
|
if (drpWarrantycardRows.isNotEmpty()) {
|
|
|
RowsMap warrantycardRowsMap = SQLFactory.createQuerySQL(dbConnect, "sa_warrantycard", "cardno", "sa_customersid").setWhere("cardno", drpWarrantycardRows.toArrayList("fbillnum")).query().toRowsMap("cardno");
|
|
|
RowsMap itemRowsMap = SQLFactory.createQuerySQL(dbConnect, "plm_item", "itemno", "itemid").setWhere("itemno", drpWarrantycardRows.toArrayList("fitemno")).query().toRowsMap("itemno");
|
|
|
@@ -124,7 +127,7 @@ public class DRPWarrantycardCheck extends ServiceController {
|
|
|
|
|
|
@Override
|
|
|
public ServiceParam paramSet() {
|
|
|
- return new ServiceParam("DRP保修卡归属经销商同步任务", 1, RunType.minute);
|
|
|
+ return new ServiceParam("DRP保修卡归属经销商同步任务", 5, RunType.minute);
|
|
|
}
|
|
|
|
|
|
}
|