批量重新同步导购

gic-store-api/src/main/java/com/gic/store/service/ClerkApiService.java

@@ -185,4 +185,16 @@ public interface ClerkApiService {
     ServiceResponse<Void> syncClerkToWeimob(Integer wmMallStoreId, List<Integer> storeIdList, Integer enterpriseId);
 
     ServiceResponse<Void> syncClerkToWeimobTask(String param);
+
+    /**
+     * 同步失败的重新同步导购
+     * @Title: syncClerkToWeimobOfAdd

+     * @Description:
+    
* @author guojuxing
+     * @param wmMallStoreId
+     * @param clerkIds
+     * @param enterpriseId

+     * @return  com.gic.api.base.commons.ServiceResponse<java.lang.Void>

+    
*/
+    ServiceResponse<Void> syncClerkToWeimob(Integer wmMallStoreId, String clerkIds, Integer enterpriseId);
 }

gic-store-service/src/main/java/com/gic/store/service/outer/impl/ClerkApiServiceImpl.java

@@ -680,6 +680,42 @@ public class ClerkApiServiceImpl implements ClerkApiService {
         return ServiceResponse.success();
     }
 
+    @Override
+    public ServiceResponse<Void> syncClerkToWeimob(Integer wmMallStoreId, String clerkIds, Integer enterpriseId) {
+        if (StringUtils.isBlank(clerkIds)) {
+            return ServiceResponse.success();
+        }
+        List<TabClerk> clerkList = clerkService.listClerkByIds(enterpriseId, clerkIds);
+        if (CollectionUtils.isNotEmpty(clerkList)) {
+            List<Integer> storeInfoIdList = clerkList.stream().map(e -> e.getStoreInfoId()).collect(Collectors.toList());
+            Map<String, String> storeInfoIdMapStoreCode = new HashMap<>(16);
+            //查询门店，为了获取门店code
+            if (CollectionUtils.isNotEmpty(storeInfoIdList)) {
+                StoreSearchDBDTO storeSearchDBDTO = new StoreSearchDBDTO();
+                storeSearchDBDTO.setStoreInfoIdList(storeInfoIdList);
+                com.github.pagehelper.Page<StoreDTO> storePage = storeService.listStore(storeSearchDBDTO, 0, storeInfoIdList.size());
+                if (storePage != null) {
+                    List<StoreDTO> storeList = storePage.getResult();
+                    if (CollectionUtils.isNotEmpty(storeList)) {
+                        storeList.forEach( store -> storeInfoIdMapStoreCode.put(store.getStoreInfoId().toString(), store.getStoreName()));
+                    }
+                }
+            }
+            clerkList.forEach(clerkTemp -> {
+                WeimobGuiderSynDTO weimobGuiderSynDTO = new WeimobGuiderSynDTO();
+                weimobGuiderSynDTO.setStoreNumber(storeInfoIdMapStoreCode.get(clerkTemp.getStoreInfoId().toString()));
+                weimobGuiderSynDTO.setClerkId(clerkTemp.getClerkId());
+                weimobGuiderSynDTO.setGuiderName(clerkTemp.getClerkName());
+                weimobGuiderSynDTO.setGuiderPhone(clerkTemp.getPhoneNumber());
+                weimobGuiderSynDTO.setJobNumber(clerkTemp.getClerkCode());
+                weimobGuiderSynDTO.setStoreInfoId(clerkTemp.getStoreInfoId());
+                asynClerkInfoToWeimobMQ(wmMallStoreId, enterpriseId, weimobGuiderSynDTO);
+            });
+
+        }
+        return ServiceResponse.success();
+    }
+
     private void asynClerkInfoToWeimobMQ(Integer wmMallStoreId, Integer enterpriseId, WeimobGuiderSynDTO wmGuiderDTO) {
         GicMQClient client = GICMQClientUtil.getClientInstance();
         Map<String, Object> params = new HashMap<>(4);