第三方引流

src/main/java/com/huiju/estateagents/common/CommConstant.java

@@ -397,4 +397,5 @@ public class CommConstant {
 	
 	//分享活动
 	public static final Object GROUP_ACTIVITY = "groupActivity";
+	public static final String TARGET_TYPE_H5 = "H5";
 }

src/main/java/com/huiju/estateagents/drainage/controller/TaDrainageController.java

@@ -5,9 +5,12 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.huiju.estateagents.base.BaseController;
 import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.common.CommConstant;
 import com.huiju.estateagents.common.StringUtils;
 import com.huiju.estateagents.drainage.entity.TaDrainage;
 import com.huiju.estateagents.drainage.service.ITaDrainageService;
+import com.huiju.estateagents.third.entity.TaThirdPartyMiniappConfig;
+import com.huiju.estateagents.third.service.ITaThirdPartyMiniappConfigService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -21,6 +24,9 @@ import org.springframework.web.bind.annotation.RestController;
 
 import javax.servlet.http.HttpServletRequest;
 import java.time.LocalDateTime;
+import java.util.List;
+import java.util.UUID;
+
 
 /**
  * <p>
@@ -38,7 +44,9 @@ public class TaDrainageController extends BaseController {
 
     @Autowired
     public ITaDrainageService iTaDrainageService;
-
+    
+    @Autowired
+    public ITaThirdPartyMiniappConfigService iTaThirdPartyMiniappConfigService;
 
     /**
      * 分页查询列表
@@ -63,6 +71,19 @@ public class TaDrainageController extends BaseController {
             queryWrapper.orderByDesc("create_date");
 
             IPage<TaDrainage> result = iTaDrainageService.page(pg, queryWrapper);
+            List<TaDrainage> records = result.getRecords();
+            records.forEach(e -> {
+                QueryWrapper<TaThirdPartyMiniappConfig> taThirdPartyMiniappConfigQueryWrapper = new QueryWrapper<>();
+                taThirdPartyMiniappConfigQueryWrapper.eq("target_type",CommConstant.TARGET_TYPE_H5);
+                taThirdPartyMiniappConfigQueryWrapper.eq("target_id",e.getDrainageId());
+                taThirdPartyMiniappConfigQueryWrapper.eq("org_id",getOrgId(request));
+                TaThirdPartyMiniappConfig taThirdPartyMiniappConfig = iTaThirdPartyMiniappConfigService.getOne(taThirdPartyMiniappConfigQueryWrapper);
+                if (null != taThirdPartyMiniappConfig){
+                    e.setAppid(taThirdPartyMiniappConfig.getAppid());
+                    e.setAppSecret(taThirdPartyMiniappConfig.getAppSecret());
+                }
+            });
+            result.setRecords(records);
             responseBean.addSuccess(result);
         }catch (Exception e){
             e.printStackTrace();
@@ -84,6 +105,15 @@ public class TaDrainageController extends BaseController {
             taDrainage.setOrgId(getOrgId(request));
             taDrainage.setCreateDate(LocalDateTime.now());
             if (iTaDrainageService.save(taDrainage)){
+                //添加第三方appid和secret
+                TaThirdPartyMiniappConfig taThirdPartyMiniappConfig = new TaThirdPartyMiniappConfig();
+                taThirdPartyMiniappConfig.setOrgId(getOrgId(request));
+                taThirdPartyMiniappConfig.setAppid(getUUIDS());
+                taThirdPartyMiniappConfig.setAppSecret(getUUIDS());
+                taThirdPartyMiniappConfig.setExpirationDate(LocalDateTime.now().plusDays(7));
+                taThirdPartyMiniappConfig.setTargetType(CommConstant.TARGET_TYPE_H5);
+                taThirdPartyMiniappConfig.setTargetId(taDrainage.getDrainageId().toString());
+                iTaThirdPartyMiniappConfigService.save(taThirdPartyMiniappConfig);
                 responseBean.addSuccess(taDrainage);
             }else {
                 responseBean.addError("fail");
@@ -95,7 +125,16 @@ public class TaDrainageController extends BaseController {
         }
         return responseBean;
     }
-
+    
+    /**
+     * 获取uuid
+     * @return
+     */
+    private String getUUIDS() {
+        String uuid= UUID.randomUUID().toString().replace("-", "");
+        return uuid;
+    }
+    
     /**
      * 根据id删除对象
      * @param id  实体ID

src/main/java/com/huiju/estateagents/drainage/controller/TaDrainageRecordController.java

@@ -11,11 +11,14 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.google.gson.JsonObject;
 import com.huiju.estateagents.base.BaseController;
 import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.common.CommConstant;
 import com.huiju.estateagents.common.StringUtils;
 import com.huiju.estateagents.drainage.entity.TaDrainageRecord;
 import com.huiju.estateagents.drainage.service.ITaDrainageRecordService;
 import com.huiju.estateagents.excel.ReporRecommendCustomer;
 import com.huiju.estateagents.excel.handler.CustomCellWriteHandler;
+import com.huiju.estateagents.third.entity.TaThirdPartyMiniappConfig;
+import com.huiju.estateagents.third.service.ITaThirdPartyMiniappConfigService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -53,7 +56,9 @@ public class TaDrainageRecordController extends BaseController {
 
     @Autowired
     public ITaDrainageRecordService iTaDrainageRecordService;
-
+    
+    @Autowired
+    public ITaThirdPartyMiniappConfigService iTaThirdPartyMiniappConfigService;
 
     /**
      * 分页查询列表
@@ -235,4 +240,40 @@ public class TaDrainageRecordController extends BaseController {
         }
         return responseBean;
     }
+    
+    /**
+     * 保存对象
+     *
+     * @return
+     */
+    @RequestMapping(value="/third/taDrainageRecord",method= RequestMethod.POST)
+    public ResponseBean thirdDrainageRecordAdd(@RequestBody String jsonString,HttpServletRequest request){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            //获取H5项目相关信息
+            String appid = request.getHeader("x-appid");
+            QueryWrapper<TaThirdPartyMiniappConfig> taThirdPartyMiniappConfigQueryWrapper = new QueryWrapper<>();
+            taThirdPartyMiniappConfigQueryWrapper.eq("appid", appid);
+            TaThirdPartyMiniappConfig taThirdPartyMiniappConfig = iTaThirdPartyMiniappConfigService.getOne(taThirdPartyMiniappConfigQueryWrapper);
+            if (null == taThirdPartyMiniappConfig){
+                return ResponseBean.error("不存在的项目",ResponseBean.ERROR_UNAVAILABLE);
+            }
+            //保存信息
+            JSONObject jsonParse = JSONObject.parseObject(jsonString);
+            TaDrainageRecord taDrainageRecord = new TaDrainageRecord();
+            taDrainageRecord.setContent(jsonParse.getString("content"));
+            taDrainageRecord.setPhone(jsonParse.getString("phone"));
+            taDrainageRecord.setUserName(jsonParse.getString("userName"));
+            taDrainageRecord.setCreateDate(LocalDateTime.now());
+            taDrainageRecord.setDrainageId(taThirdPartyMiniappConfig.getTargetId());
+            if (iTaDrainageRecordService.save(taDrainageRecord)){
+                return ResponseBean.success(taDrainageRecord);
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taDrainageRecordAdd -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
 }

src/main/java/com/huiju/estateagents/drainage/entity/TaDrainage.java

@@ -1,6 +1,7 @@
 package com.huiju.estateagents.drainage.entity;
 
 import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
@@ -60,5 +61,9 @@ public class TaDrainage implements Serializable {
      */
     private Integer enlistNum;
 
-
+    @TableField(exist = false)
+    private String appid;
+    
+    @TableField(exist = false)
+    private String appSecret;
 }