提交ec同步部分代码

coolstore-partner-model/src/main/java/com/cool/store/entity/HyPartnerLabelGroupDO.java

@@ -5,6 +5,7 @@ import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
+import lombok.experimental.Accessors;
 
 import java.util.Date;
 
@@ -16,6 +17,7 @@ import java.util.Date;
 @Builder
 @NoArgsConstructor
 @AllArgsConstructor
+@Accessors(chain = true)
 public class HyPartnerLabelGroupDO {
 
     @ApiModelProperty("id")

coolstore-partner-model/src/main/java/com/cool/store/request/GetTagRequest.java

@@ -0,0 +1,27 @@
+package com.cool.store.request;
+
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.util.List;
+
+/**
+ * @author hxd
+ */
+@Data
+@Accessors(chain = true)
+public class GetTagRequest {
+    private Long groupId;
+    private String groupName;
+    private Integer sort;
+    private Integer type;
+    private List<GetTagItem> list;
+
+    @Data
+    @Accessors(chain = true)
+    public static  class  GetTagItem{
+        private Long classId;
+        private String className;
+        private int sort;
+    }
+}

coolstore-partner-service/src/main/java/com/cool/store/service/EcSyncService.java

@@ -1,6 +1,7 @@
 package com.cool.store.service;
 
 import com.cool.store.request.CustomerInfoRequest;
+import com.cool.store.request.GetTagRequest;
 
 import java.util.List;
 
@@ -8,4 +9,7 @@ public interface EcSyncService {
     boolean ecToApplet(List<CustomerInfoRequest> queryListData);
 
     void getChannelSource();
+
+    Boolean labelInfo(List<GetTagRequest> getTagRequestList);
+
 }

coolstore-partner-service/src/main/java/com/cool/store/service/impl/EcSyncServiceImpl.java

@@ -15,8 +15,11 @@ import com.cool.store.enums.WorkflowStageEnum;
 import com.cool.store.enums.WorkflowStatusEnum;
 import com.cool.store.exception.ApiException;
 import com.cool.store.http.UserSourceResponse;
+import com.cool.store.mapper.HyPartnerLabelGroupMapper;
+import com.cool.store.mapper.HyPartnerLabelMapper;
 import com.cool.store.mapper.HyPartnerUserChannelMapper;
 import com.cool.store.request.CustomerInfoRequest;
+import com.cool.store.request.GetTagRequest;
 import com.cool.store.sdk.ec.EcClient;
 import com.cool.store.sdk.ec.bo.ChangeFollowUserBo;
 import com.cool.store.sdk.ec.bo.UpdateCustomerBo;
@@ -49,6 +52,10 @@ public class EcSyncServiceImpl implements EcSyncService {
     @Value("${ec.baseUrl:null}")
     private String baseUrl;
 
+
+    @Value("${ec.sync.createUserId}")
+    private String createUserId;
+
     @Resource
     private HyPartnerLineInfoDAO hyPartnerLineInfoDAO;
 
@@ -65,6 +72,12 @@ public class EcSyncServiceImpl implements EcSyncService {
     @Resource
     private HyPartnerUserChannelMapper hyPartnerUserChannelMapper;
 
+    @Resource
+    private HyPartnerLabelGroupMapper hyPartnerLabelGroupMapper;
+
+    @Resource
+    private HyPartnerLabelMapper hyPartnerLabelMapper;
+
 
     @Override
     public boolean ecToApplet(List<CustomerInfoRequest> queryListData) {
@@ -99,6 +112,16 @@ public class EcSyncServiceImpl implements EcSyncService {
         }
     }
 
+    @Override
+    public Boolean labelInfo(List<GetTagRequest> getTagRequestList) {
+        for (GetTagRequest getTagRequest : getTagRequestList) {
+            HyPartnerLabelGroupDO hyPartnerLabelGroupDO = new HyPartnerLabelGroupDO();
+            hyPartnerLabelGroupDO.setLabelGroupName(getTagRequest.getGroupName()).setId(getTagRequest.getGroupId());
+
+        }
+        return null;
+    }
+
     /**
      * 同步ec数据到表中 同时将部分数据同步到ec
      *

coolstore-partner-webb/src/main/java/com/cool/store/controller/EcSyncController.java

@@ -2,6 +2,7 @@ package com.cool.store.controller;
 
 
 import com.cool.store.request.CustomerInfoRequest;
+import com.cool.store.request.GetTagRequest;
 import com.cool.store.response.ResponseResult;
 import com.cool.store.service.EcSyncService;
 import com.cool.store.vo.InterviewScheduleInfoVO;
@@ -28,4 +29,10 @@ public class EcSyncController {
         return  ResponseResult.success(ecSyncService.ecToApplet(queryListData));
     }
 
+    @PostMapping(path = "/labelInfo")
+    @ApiOperation("ec同步标签数据到小程序")
+    public ResponseResult<Boolean> labelInfo(@RequestBody List<GetTagRequest> getTagRequestList){
+        return  ResponseResult.success(ecSyncService.labelInfo(getTagRequestList));
+    }
+
 }