个微池调用typer接口 划入typer

src/main/java/com/mokamrp/privates/controller/pangu/FosterwxFlowListController.java

@@ -66,7 +66,7 @@ public class FosterwxFlowListController extends BaseController<FosterwxFlowList>
         Integer maxFans = Integer.valueOf(fosterwxMobilePool.getMaxFans());
 
         // 查看是否超过百分之五十 并且 所属组别不是游戏导粉类型
-        if (fosterwxFlowList.getBusFans() > maxFans * 7 / 10.0 && 2 != fosterwxMobilePool.getIncomeFansType()) {
+        if (fosterwxFlowList.getBusFans() > maxFans * 7 / 10.0 && 1 == fosterwxMobilePool.getIncomeFansType()) {
             // 超过
             // 更新
             // 设置流量位置

src/main/java/com/mokamrp/privates/controller/pangu/FosterwxMobilePoolController.java

@@ -1,10 +1,12 @@
 package com.mokamrp.privates.controller.pangu;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.mokamrp.privates.constant.HttpStatus;
 import com.mokamrp.privates.controller.BaseController;
 import com.mokamrp.privates.entity.EditHandle;
 import com.mokamrp.privates.entity.pangu.FosterwxMobilePoolHandle;
+import com.mokamrp.privates.entity.pangu.TyperBean;
 import com.mokamrp.privates.help.AjaxResult;
 import com.mokamrp.privates.interceptor.AuthUser;
 import com.mokamrp.privates.mapper.pangu.pojo.FosterwxFlowList;
@@ -13,8 +15,9 @@ import com.mokamrp.privates.mapper.pojo.User;
 import com.mokamrp.privates.service.pangu.FosterwxFlowListService;
 import com.mokamrp.privates.service.pangu.FosterwxMobilePoolService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
 import org.springframework.http.HttpMethod;
-import org.springframework.http.ResponseEntity;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.BindingResult;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -24,9 +27,7 @@ import org.springframework.web.bind.annotation.RestController;
 import org.springframework.web.client.RestTemplate;
 
 import javax.validation.Valid;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 
 /**
@@ -50,6 +51,9 @@ public class FosterwxMobilePoolController extends BaseController<FosterwxMobileP
     @Autowired
     private RestTemplate restTemplate;
 
+    @Value("${typer.url}")
+    private String domain;
+
     /*
      * @fast
      * 默认生成的控制器所继承的父类中有index/add/edit/del四个基础方法,均为post json请求
@@ -110,10 +114,37 @@ public class FosterwxMobilePoolController extends BaseController<FosterwxMobileP
     @PostMapping("/loadInTyper")
     public Object loadInTyper(@Valid @RequestBody EditHandle<FosterwxMobilePool> editHandle) {
         List<FosterwxMobilePool> fosterwxMobilePoolList = fosterwxMobilePoolService.list(new LambdaQueryWrapper<FosterwxMobilePool>().in(FosterwxMobilePool::getId, editHandle.getIds().split(",")));
+        List<TyperBean> typerBeans = new ArrayList<>();
+
+        fosterwxMobilePoolList.forEach(fosterwxMobilePool -> {
+            TyperBean typerBean = new TyperBean();
+            typerBean.setHera_id(fosterwxMobilePool.getId());
+            typerBean.setQrcode_id(fosterwxMobilePool.getPoolIndex());
+            typerBean.setSite_id(String.valueOf(fosterwxMobilePool.getStationId()));
+            typerBean.setQw_appid(fosterwxMobilePool.getWxAppid());
+            typerBean.setSite_tel(fosterwxMobilePool.getMobileNo());
+            typerBean.setCode_url(fosterwxMobilePool.getCodeUrl());
+            typerBean.setThreshold(Integer.valueOf(fosterwxMobilePool.getMaxFans()));
+            typerBean.setCustomer_tel(fosterwxMobilePool.getBusMobileNo());
+            typerBean.setStatus(0 == fosterwxMobilePool.getStatus() ? 2 : 1);
+
+            typerBeans.add(typerBean);
+        });
 
-        ResponseEntity<String> result = restTemplate.exchange("", HttpMethod.POST, null, String.class);
+        Map<String, Object> body = new HashMap<>(1);
+        body.put("data", typerBeans);
+        HttpEntity<Map<String, Object>> httpEntity = new HttpEntity<>(body, null);
+        JSONObject result = restTemplate.exchange(domain + "/poster/qrcode", HttpMethod.POST, httpEntity, JSONObject.class).getBody();
 
-        return AjaxResult.success(result.getBody());
+        if (null != result) {
+            if ("200".equals(result.get("code"))) {
+                return AjaxResult.success(result.get("data").toString());
+            } else {
+                return AjaxResult.error(result.get("data").toString());
+            }
+        } else {
+            return AjaxResult.error("划入失败!");
+        }
     }
 }
 

src/main/java/com/mokamrp/privates/entity/pangu/TyperBean.java

@@ -0,0 +1,43 @@
+package com.mokamrp.privates.entity.pangu;
+
+import lombok.Data;
+
+@Data
+public class TyperBean {
+    /**
+     * 池id
+     */
+    private Integer hera_id;
+    /**
+     * 码id
+     */
+    private String qrcode_id;
+    /**
+     * 站点
+     */
+    private String site_id;
+    /**
+     * 企业微信appid
+     */
+    private String qw_appid;
+    /**
+     * 站点手机号
+     */
+    private String site_tel;
+    /**
+     * 个微二维码链接
+     */
+    private String code_url;
+    /**
+     * 阈值
+     */
+    private Integer threshold;
+    /**
+     * 企微客服手机
+     */
+    private String customer_tel;
+    /**
+     * 状态 1正常 2停用
+     */
+    private Integer status;
+}

src/main/resources/application-local.properties

@@ -80,5 +80,8 @@ es.username=elastic
 es.password=moka6_3moka
 es.port=9200
 
+#typer接口
+typer.url=https://test.typer.mokamrp.com/api
+
 #定时任务全局开关，本地环境无需开启
 cronjob.power=true

src/main/resources/application-prod.properties

@@ -74,5 +74,8 @@ es.username=elastic
 es.password=moka6_3moka
 es.port=9200
 
+#typer接口
+typer.url=https://typer.mokamrp.com
+
 #定时任务全局开关，线上环境需要开启
 cronjob.power=true

src/main/resources/application-test.properties

@@ -75,6 +75,9 @@ es.username=elastic
 es.password=moka6_3moka
 es.port=9200
 
+#typer接口
+typer.url=https://test.typer.mokamrp.com/api
+
 #定时任务全局开关，线上环境需要开启
 cronjob.power=false