推广码

src/main/java/com/kiisoo/ic/synchronous/entity/PromotionDO.java

@@ -0,0 +1,16 @@
+package com.kiisoo.ic.synchronous.entity;
+
+import lombok.Data;
+
+@Data
+public class PromotionDO {
+    /**店铺号ID*/
+    private String userId;
+    /**参数类型0为门店账号，1为内部员工导购，2为其他*/
+    private String type;
+    /**参数type为1时传员工工号id，type为2时传其他需要参数*/
+    private String state;
+    /**店铺号对应的门店编号*/
+    private String storeNo;
+
+}

src/main/java/com/kiisoo/ic/synchronous/service/PromotionCodeService.java

@@ -1,19 +1,31 @@
 package com.kiisoo.ic.synchronous.service;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.kiisoo.aegis.common.faces.util.HttpUtil;
+import com.kiisoo.ic.common.utils.MD5FileUtil;
+import com.kiisoo.ic.common.utils.httpClientUtil.HttpClientUtil;
+import com.kiisoo.ic.common.utils.httpClientUtil.HttpResult;
+import com.kiisoo.ic.employee.entity.PrivilageCpUserDO;
+import com.kiisoo.ic.employee.mapper.PrivilageCpUserDOMapper;
 import com.kiisoo.ic.store.constant.Constants;
 import com.kiisoo.ic.store.entity.PoiStore;
 import com.kiisoo.ic.store.entity.PoiStoreStaff;
+import com.kiisoo.ic.store.entity.PrivilageCpUserStoreDO;
 import com.kiisoo.ic.store.entity.StoreUserDTO;
 import com.kiisoo.ic.store.mapper.PoiStoreDOMapper;
 import com.kiisoo.ic.store.mapper.PoiStoreStaffDOMapper;
 import com.kiisoo.ic.store.mapper.PrivilageCpUserStoreDOMapper;
+import com.kiisoo.ic.synchronous.entity.PromotionDO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
 import java.util.List;
 
+import static com.kiisoo.ic.employee.constant.Constants.DATABASE_CP_USER_ID_KEY;
+
 @Service
 public class PromotionCodeService {
 
@@ -26,6 +38,19 @@ public class PromotionCodeService {
     @Autowired
     private PoiStoreStaffDOMapper poiStoreStaffDOMapper;
 
+    @Autowired
+    private PrivilageCpUserDOMapper privilageCpUserDOMapper;
+
+    public String getToken(){
+        String token = "BOSIDENG";
+        String date = "2018-10-31";
+        return MD5FileUtil.getMD5String(token+date);
+    }
+
+    /**
+     * 找店铺二维码
+     * @param i
+     */
     public void getPromotion(int i) {
         //找到所有店铺
       List<PoiStore> shops = poiStoreDOMapper.selectList(null);
@@ -36,9 +61,24 @@ public class PromotionCodeService {
             //找到是否有推广码
             List<StoreUserDTO> cpUserStoreDO = privilageCpUserStoreDOMapper.selectCpUserByShops(shopIds);
             if(cpUserStoreDO.size() == 0){
+                PromotionDO p = new PromotionDO();
+                p.setType("0");
+                p.setStoreNo(item.getCode());
                 //没有推广码则查询
-
+                HttpResult data = HttpClientUtil.httpPost("http://vtest.bsd.cn/BSD_WXAPP/qyWechat/getShareQRcode?token=TOKEN", JSON.toJSONString(p),getToken());
-                //增加推广码
+                //http返回参数
+                if((boolean) JSONObject.parseObject(data.getMessage()).get("success")){
+                    String url = JSONObject.parseObject(data.getMessage()).get("data").toString();
+
+                    //排重---根据企业微信账号查询是否存在用户
+                    PrivilageCpUserDO privilageCpUserDO = new PrivilageCpUserDO();
+                    privilageCpUserDO.setQrCode(url);
+                    int insert = privilageCpUserDOMapper.insert(privilageCpUserDO);
+                    PrivilageCpUserStoreDO cpUserStore = new PrivilageCpUserStoreDO();
+                    cpUserStore.setStoreId(item.getId());
+                    cpUserStore.setCpUserId(privilageCpUserDO.getId());
+                    privilageCpUserStoreDOMapper.insert(cpUserStore);
+                }
 
             }
 
@@ -48,19 +88,28 @@ public class PromotionCodeService {
     }
 
     /**
-     *
+     * 找用户二维码
      */
     public void getStaffPromotion() {
         List<PoiStoreStaff> sellers = poiStoreStaffDOMapper.selectList(null);
         sellers.forEach(item ->{
-            PoiStoreStaff poiStoreStaff = new PoiStoreStaff();
+            if(item.getEpWechatQrCode() == null){
-            poiStoreStaff.setUserId(item.getUserId());
+                PromotionDO p = new PromotionDO();
-            poiStoreStaff.setStatus(Constants.STATUS_USEFUL);
+                p.setUserId(item.getCustomerUserId()+"");
-            List<PoiStoreStaff> poiStoreStaffs = poiStoreStaffDOMapper.selectList(new QueryWrapper<>(poiStoreStaff));
+                p.setType("1");
-            if(poiStoreStaffs.size() == 0){
+                p.setState(item.getStaffCode());
+
                 //没有推广码则查询
+                HttpResult data = HttpClientUtil.httpPost("http://vtest.bsd.cn/BSD_WXAPP/qyWechat/getShareQRcode?token=TOKEN", JSON.toJSONString(p),getToken());
+                //http返回参数
+                if((boolean) JSONObject.parseObject(data.getMessage()).get("success")){
+                    String url = JSONObject.parseObject(data.getMessage()).get("data").toString();
+
+                    //没有推广码则查询
+                    item.setEpWechatQrCode(url);
+                    poiStoreStaffDOMapper.updateById(item);
+                }
 
-                //
             }
         });