Kaynağa Gözat

修复crm同步错误

shenjingwei 5 ay önce
ebeveyn
işleme
969707b17c
1 değiştirilmiş dosya ile 20 ekleme ve 17 silme
  1. 20 17
      src/custom/common/crm/bean/customer.java

+ 20 - 17
src/custom/common/crm/bean/customer.java

@@ -1,5 +1,6 @@
 package common.crm.bean;
 
+import com.alibaba.fastjson2.JSONObject;
 import common.YosException;
 import common.crm.bean.core.CrmBase;
 import common.data.*;
@@ -28,23 +29,25 @@ public class customer extends CrmBase {
         RowsMap regionsMap = dbConnect.runSqlQuery("select code,name from t_regions where countryid=1").toRowsMap("code");
 
         for (Row row : rows) {
-            long syncid = row.getLong("syncid");
-            long cid = row.getLong("cid");
-            String createby = row.getString("createby");
-            String createtime = row.getString("createtime");
-            String changeby = row.getString("changeby");
-            String changetime = row.getString("changetime");
-            String customer_status = row.getString("customer_status");
-            String fchannel = row.getString("fchannel");
-            String fname = row.getString("fname");
-            String fphone = row.getString("fphone");
-            String fcommunity = row.getString("fcommunity");
-            String fcustom_num = row.getString("fcustom_num");
-            String fagent_num_created = row.getString("fagent_num_created");
-            String fagent_num = row.getString("fagent_num");
-            String fprovince = row.getString("fprovince");
-            String fcity = row.getString("fcity");
-            String fcounty = row.getString("fcounty");
+            JSONObject jsonObject = row.toJsonObject();
+
+            long syncid = jsonObject.getLong("syncid");
+            long cid = jsonObject.getLong("cid");
+            String createby = jsonObject.getString("createby");
+            String createtime = jsonObject.getString("createtime");
+            String changeby = jsonObject.getString("changeby");
+            String changetime = jsonObject.getString("changetime");
+            String customer_status = jsonObject.getString("customer_status");
+            String fchannel = jsonObject.getString("fchannel");
+            String fname = jsonObject.getString("fname");
+            String fphone = jsonObject.getString("fphone");
+            String fcommunity = jsonObject.getString("fcommunity");
+            String fcustom_num = jsonObject.getString("fcustom_num");
+            String fagent_num_created = jsonObject.getString("fagent_num_created");
+            String fagent_num = jsonObject.getString("fagent_num");
+            String fprovince = jsonObject.getString("fprovince");
+            String fcity = jsonObject.getString("fcity");
+            String fcounty = jsonObject.getString("fcounty");
 
             if (agentRowsMap.containsKey(fagent_num_created)) {
                 if (dbConnect.runSqlQuery("select * from sa_customers where sa_customersid=" + cid).isEmpty()) {