批量重新同步导购

gic-platform-enterprise-web/pom.xml

@@ -204,6 +204,11 @@
             <artifactId>gic-weimob-api</artifactId>
             <version>${gic-weimob-api}</version>
         </dependency>
+        <dependency>
+            <groupId>com.gic</groupId>
+            <artifactId>gic-goods-api</artifactId>
+            <version>${gic-goods-api}</version>
+        </dependency>
     </dependencies>
 
     <build>

gic-platform-enterprise-web/src/main/java/com/gic/enterprise/web/controller/wm/WmMallStoreController.java

@@ -6,6 +6,7 @@ import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import com.gic.enterprise.error.ErrorCode;
+import com.gic.goods.pump.api.service.WeiMobGoodsService;
 import com.gic.weimob.api.service.WeimobBaseService;
 import com.gic.weimob.api.service.WeimobMemberService;
 import org.apache.commons.collections.CollectionUtils;
@@ -54,6 +55,8 @@ public class WmMallStoreController {
     private WeimobMemberService weimobMemberService;
     @Autowired
     private WeimobBaseService weimobBaseService;
+    @Autowired
+    private WeiMobGoodsService weiMobGoodsService;
 
     @RequestMapping("/save-wm-store")
     public RestResponse save(WmStoreDTO dto) {
@@ -272,6 +275,23 @@ public class WmMallStoreController {
     }
 
     /**
+     * 同步商品信息
+     * @param wmMallStoreId
+     * @return
+     */
+    @RequestMapping("/sync-goods")
+    public RestResponse syncGoods(Integer wmMallStoreId) {
+        ServiceResponse<WmStoreDTO> response = wmStoreApiService.getWmStoreByWmMallStoreId(wmMallStoreId);
+        if (response.isSuccess()) {
+            WmStoreDTO wmStoreDTO = response.getResult();
+            ServiceResponse<Void> goodsResponse = weiMobGoodsService
+                    .saveEnterpriseIdAndPid(UserDetailUtils.getUserDetail().getEnterpriseId(), Long.valueOf(wmStoreDTO.getWmPid()));
+            return ResultControllerUtils.commonResult(goodsResponse);
+        }
+        return RestResponse.failure(response.getCode(), response.getMessage());
+    }
+
+    /**
      * gic卡券列表
      * @param wmMallStoreId
      * @param cardName

gic-platform-enterprise-web/src/main/java/com/gic/enterprise/web/controller/wm/WmStoreSyncController.java

@@ -13,6 +13,7 @@ import javax.servlet.http.HttpServletResponse;
 
 import com.gic.commons.util.EntityUtil;
 import com.gic.enterprise.web.vo.wm.WmBranchVO;
+import com.gic.weimob.api.dto.WeimobGuiderSynDTO;
 import com.gic.weimob.api.dto.WeimobStoreGicInfoDTO;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.collections.MapUtils;
@@ -95,6 +96,7 @@ public class WmStoreSyncController {
     @RequestMapping("list-store")
     public RestResponse listStore(StoreSearchDTO storeSearchDTO) {
         //todo 过滤已同步过的门店
+        storeSearchDTO.setEnterpriseId(UserDetailUtils.getUserDetail().getEnterpriseId());
         return ResultControllerUtils.commonResult(storeApiService.listStore(storeSearchDTO, 0, 1000));
     }
 
@@ -275,17 +277,32 @@ public class WmStoreSyncController {
     }
 
     /**
+     * 导购重新同步
+     * @param clerkIds 英文逗号隔开
+     * @param wmMallStoreId
+     * @return
+     */
+    @RequestMapping("/sync-clerk-to-wm-again")
+    public RestResponse syncClerkToWmAgain(String clerkIds, Integer wmMallStoreId) {
+        return ResultControllerUtils.commonResult(clerkApiService
+                .syncClerkToWeimob(wmMallStoreId, clerkIds, UserDetailUtils.getUserDetail().getEnterpriseId()));
+    }
+
+    /**
      * 门店错误日志-不处理
      * @Title: deleteStoreClerkErrorLog

      * @Description:
     
* @author guojuxing
-     * @param id

+     * @param ids
      * @return  com.gic.commons.webapi.reponse.RestResponse

     
*/
     @RequestMapping("delete-store-clerk-error-log")
     @ResponseBody
-    public RestResponse deleteStoreClerkErrorLog(String id) {
-        return ResultControllerUtils.commonResult(weimobStoreSiteService.deleteStoreClerkErrorlog(Long.valueOf(id)));
+    public RestResponse deleteStoreClerkErrorLog(String ids) {
+        if (StringUtils.isNotBlank(ids)) {
+            Arrays.stream(ids.split(",")).forEach( e -> weimobStoreSiteService.deleteStoreClerkErrorlog(Long.valueOf(e)));
+        }
+        return RestResponse.success();
     }
 
     /**

gic-platform-enterprise-web/src/main/resources/dubbo-gic-platform-enterprise-web.xml

@@ -133,4 +133,6 @@
     <dubbo:reference interface="com.gic.marketing.api.service.coupon.MemberCouponApiService" id="memberCouponApiService" timeout="6000"/>
 
     <dubbo:reference interface="com.gic.store.service.ClerkApiService" id="clerkApiService" timeout="60000" />
+
+    <dubbo:reference interface="com.gic.goods.pump.api.service.WeiMobGoodsService" id="weiMobGoodsService" timeout="60000" />
 </beans>