njs před 1 rokem
rodič
revize
37f8e3f22b

+ 12 - 0
suishenbang-sync/suishenbang-sync-common/src/main/java/com/dgtly/sync/service/impl/AnalysisSysUserService.java

@@ -349,6 +349,8 @@ public class AnalysisSysUserService implements IAnalysisSysUserService {
      */
     @Override
     public SyncLog analysisSysDivisionUser() {
+        Long l = new Date().getTime();
+        String packageId = l.toString();
         //解析零售下事业部人员直接sql查
         List<MetaEmployeeDiy> metaEmployeeDiys = metaEmployeeDiyMapper.selectMetaEmployeeDiyListByDivision();
         SyncLog syncLog = new SyncLog();
@@ -403,6 +405,7 @@ public class AnalysisSysUserService implements IAnalysisSysUserService {
                     if (StringUtils.isEmpty(userExt.getOrgCode())){
                         log.error("DIY-事业部用户对应的销售部未找到!当前用户信息: " + m.getLoginName() + " , 销售部名称: " + userExt.getOrgName());
                         SyncFailDetail syncFailDetail = new SyncFailDetail();
+                        syncFailDetail.setPackageId(packageId);
                         syncFailDetail.setFailReason("DIY-事业部用户对应的销售部未找到!当前用户信息: " + m.getLoginName() + " , 销售部名称: " + userExt.getOrgName());
                         syncFailDetail.setDataJson(JSONObject.toJSONString(m));
                         syncFailDetail.setFailLevel("1");
@@ -455,6 +458,7 @@ public class AnalysisSysUserService implements IAnalysisSysUserService {
                      * 警告类异常
                      */
                     SyncFailDetail syncFailDetail = new SyncFailDetail();
+                    syncFailDetail.setPackageId(packageId);
                     syncFailDetail.setFailReason(e.getMessage());
                     syncFailDetail.setDataJson(JSONObject.toJSONString(m));
                     syncFailDetail.setFailLevel("0");
@@ -466,6 +470,7 @@ public class AnalysisSysUserService implements IAnalysisSysUserService {
                      * 错误异常
                      */
                     SyncFailDetail syncFailDetail = new SyncFailDetail();
+                    syncFailDetail.setPackageId(packageId);
                     syncFailDetail.setFailReason(e.getMessage());
                     syncFailDetail.setDataJson(JSONObject.toJSONString(m));
                     syncFailDetail.setFailLevel("1");
@@ -934,6 +939,8 @@ public class AnalysisSysUserService implements IAnalysisSysUserService {
 
     @Override
     public SyncLog analysisSysClueReporting() {
+        Long l = new Date().getTime();
+        String packageId = l.toString();
         List<MetaEmployeeDiy> metaEmployeeDiys = metaEmployeeDiyMapper.selectMetaEmployeetClueReporting();
         SyncLog syncLog = new SyncLog();
         syncLog.setSyncType("sysuserClueReporting");
@@ -952,6 +959,9 @@ public class AnalysisSysUserService implements IAnalysisSysUserService {
             for (MetaEmployeeDiy m : metaEmployeeDiys) {
                 try {
                     /** =============用户基本信息构建 start===============*/
+                    if(m.getName().equals("朱 玉洁")){
+                        int i =1;
+                    }
                     SysUser user = new SysUser();
                     user.setCompanyId(1L);
                     user.setLoginName(m.getLoginName());
@@ -1082,6 +1092,7 @@ public class AnalysisSysUserService implements IAnalysisSysUserService {
                      * 警告类异常
                      */
                     SyncFailDetail syncFailDetail = new SyncFailDetail();
+                    syncFailDetail.setPackageId(packageId);
                     syncFailDetail.setFailReason(e.getMessage());
                     syncFailDetail.setDataJson(JSONObject.toJSONString(m));
                     syncFailDetail.setFailLevel("0");
@@ -1093,6 +1104,7 @@ public class AnalysisSysUserService implements IAnalysisSysUserService {
                      * 错误异常
                      */
                     SyncFailDetail syncFailDetail = new SyncFailDetail();
+                    syncFailDetail.setPackageId(packageId);
                     syncFailDetail.setFailReason(e.getMessage());
                     syncFailDetail.setDataJson(JSONObject.toJSONString(m));
                     syncFailDetail.setFailLevel("1");