人工小微进件

ldt-core/src/main/java/org/springblade/ldt/shop/controller/ShopController.java

@@ -39,6 +39,7 @@ import org.springblade.ldt.shop.service.IShopService;
 import org.springblade.ldt.shop.vo.ShopVO;
 import org.springblade.ldt.shop.vo.WechatConfigQueryVO;
 import org.springblade.ldt.shop.wrapper.ShopWrapper;
+import org.springblade.yeePay.entity.saas.MicroInvitationDto;
 import org.springblade.yeePay.entity.saas.WechatApplyDto;
 import org.springblade.yeePay.entity.saas.WechatConfigAddDto;
 import org.springframework.web.bind.annotation.*;
@@ -187,4 +188,10 @@ public class ShopController extends BladeController {
 		return R.data(shopService.wechatApply(artificialWechatApplyDto));
 	}
 
+	@PostMapping("/inviteMicro")
+	@ApiOperation(value = "人工小微进件")
+	public R inviteMicro(@RequestBody MicroInvitationDto microInvitationDto) {
+		return R.data(shopService.inviteMicro(microInvitationDto));
+	}
+
 }

ldt-core/src/main/java/org/springblade/ldt/shop/service/IShopService.java

@@ -24,6 +24,7 @@ import org.springblade.ldt.shop.dto.ArtificialWechatApplyDto;
 import org.springblade.ldt.shop.entity.Shop;
 import org.springblade.ldt.shop.vo.ShopVO;
 import org.springblade.ldt.shop.vo.WechatConfigQueryVO;
+import org.springblade.yeePay.entity.saas.MicroInvitationDto;
 import org.springblade.yeePay.entity.saas.WechatApplyDto;
 import org.springblade.yeePay.entity.saas.WechatConfigAddDto;
 
@@ -101,4 +102,12 @@ public interface IShopService extends BaseService<Shop> {
 	 */
 	R wechatConfigAdd(WechatConfigAddDto wechatConfigAddDto);
 
+	/**
+	 * @param microInvitationDto: 小微进件信息
+	 * @Return R 易宝请求结果
+	 * @Author July
+	 * @Description 人工小微进件
+	 * @Date 2021/11/22 14:08
+	 */
+	R inviteMicro(MicroInvitationDto microInvitationDto);
 }

ldt-core/src/main/java/org/springblade/ldt/shop/service/impl/ShopServiceImpl.java

@@ -30,8 +30,10 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springblade.common.cache.FlowCache;
+import org.springblade.common.constant.CallbackServeUrl;
 import org.springblade.core.log.exception.ServiceException;
 import org.springblade.core.mp.base.BaseServiceImpl;
+import org.springblade.core.redis.cache.BladeRedis;
 import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.BeanUtil;
 import org.springblade.flow.shop.task.WechatApplyTask;
@@ -59,6 +61,9 @@ import java.util.List;
 import java.util.Objects;
 import java.util.Set;
 
+import static org.springblade.common.enums.AppConstant.InvitationType.SHOP_INVITATION;
+import static org.springblade.yeePay.common.YeepayApiConstant.businessRole.SETTLED_MERCHANT;
+
 /**
  * 服务实现类
  *
@@ -210,7 +215,7 @@ public class ShopServiceImpl extends BaseServiceImpl<ShopMapper, Shop> implement
 	@Override
 	public R wechatConfigAdd(WechatConfigAddDto wechatConfigAddDto) {
 		Shop shop = shopMapper.selectById(wechatConfigAddDto.getMerchantNo());
-		Assert.notNull(shop,"未找到该商户记录");
+		Assert.notNull(shop, "未找到该商户记录");
 		wechatConfigAddDto.setMerchantNo(shop.getMerchantNo());
 		wechatConfigAddDto.setParentMerchantNo(yeePayConst.getPlatformServiceNo());
 		YopResponse yopResponse = yeepaySaasService.wechatConfigAdd(wechatConfigAddDto);
@@ -221,6 +226,23 @@ public class ShopServiceImpl extends BaseServiceImpl<ShopMapper, Shop> implement
 		return R.success("配置成功！");
 	}
 
+	private BladeRedis bladeRedis;
+
+	@Override
+	public R inviteMicro(MicroInvitationDto microInvitationDto) {
+		microInvitationDto.setParentMerchantNo(yeePayConst.getPlatformServiceNo());
+		microInvitationDto.setBusinessRole(SETTLED_MERCHANT.name());
+		microInvitationDto.setRequestNo("ldt" + microInvitationDto.getMerchantCorporationInfo().getMobile() + "micro");
+		microInvitationDto.setNotifyUrl(CallbackServeUrl.CALL_BACK_SERVE_URL + "/invitation/callback/" + SHOP_INVITATION);
+		YopResponse yopResponse = yeepaySaasService.inviteMicro(microInvitationDto);
+		JSONObject res = JSON.parseObject(yopResponse.getStringResult());
+		if (!Objects.equals(res.getString("returnCode"), "NIG00000")) {
+			throw new ServiceException(res.getString("returnMsg"));
+		}
+		bladeRedis.set("manual-micro-invitation", res);
+		return R.data(res);
+	}
+
 	//@Scheduled(cron = "0 */1 * * * ?")
 	private void queryStatus() {
 		//查询当前微信认证队列各个状态

ldt-core/src/main/resources/application.yml

@@ -266,5 +266,6 @@ crypto:
     - /withdraw
     - /pressure_test/scanPay
     - /pressure_test/deCodeNotifyData
+    - /ocr/idcard