MerchantServiceImpl.java 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653
  1. package com.poteviohealth.ym.ipos.service.impl;
  2. import com.alibaba.fastjson.JSON;
  3. import com.alibaba.fastjson.JSONObject;
  4. import com.alibaba.fastjson.TypeReference;
  5. import com.poteviohealth.cgp.common.facade.cache.CacheService;
  6. import com.poteviohealth.cgp.common.filter.TokenContext;
  7. import com.poteviohealth.cgp.common.integrated.OperatorIdParams;
  8. import com.poteviohealth.cgp.common.integrated.customer.CustomerFeignClient;
  9. import com.poteviohealth.cgp.common.integrated.partner.PartnerFeignClient;
  10. import com.poteviohealth.cgp.common.model.VaultsResponse;
  11. import com.poteviohealth.ym.ipos.common.Basic;
  12. import com.poteviohealth.ym.ipos.model.BasicConfiguration;
  13. import com.poteviohealth.ym.ipos.model.back.BaseBack;
  14. import com.poteviohealth.ym.ipos.model.merchant.*;
  15. import com.poteviohealth.ym.ipos.model.merchant.back.ImageListBack;
  16. import com.poteviohealth.ym.ipos.model.merchant.back.PictureBack;
  17. import com.poteviohealth.ym.ipos.model.merchant.back.UserBack;
  18. import com.poteviohealth.ym.ipos.model.merchant.back.UserSearchBack;
  19. import com.poteviohealth.ym.ipos.model.merchant.detail.*;
  20. import com.poteviohealth.ym.ipos.model.merchant.dto.ImageDto;
  21. import com.poteviohealth.ym.ipos.model.merchant.dto.ImageListDto;
  22. import com.poteviohealth.ym.ipos.model.merchant.dto.UserDto;
  23. import com.poteviohealth.ym.ipos.model.payment.dto.BindDto;
  24. import com.poteviohealth.ym.ipos.service.IAreaService;
  25. import com.poteviohealth.ym.ipos.service.IMerchantService;
  26. import com.poteviohealth.ym.ipos.service.IPaymentService;
  27. import com.poteviohealth.ym.ipos.utils.YmUtil;
  28. import lombok.extern.log4j.Log4j2;
  29. import org.apache.commons.lang3.StringUtils;
  30. import org.springframework.stereotype.Service;
  31. import javax.annotation.Resource;
  32. import java.math.BigDecimal;
  33. import java.util.List;
  34. import java.util.stream.Collectors;
  35. /**
  36. * 商户入驻接口实现
  37. * @author Qin
  38. */
  39. @Service
  40. @Log4j2
  41. public class MerchantServiceImpl implements IMerchantService {
  42. @Resource
  43. private PartnerFeignClient partnerFeignClient;
  44. @Resource
  45. private CustomerFeignClient customerFeignClient;
  46. @Resource
  47. private IAreaService areaService;
  48. @Resource
  49. private IPaymentService paymentService;
  50. @Resource
  51. private CacheService cacheService;
  52. /**
  53. * 上传图片
  54. * @param dto
  55. * @return
  56. */
  57. @Override
  58. public VaultsResponse<String> merchantPicture(ImageDto dto){
  59. BasicConfiguration bc = Basic.getSystemParameter(TokenContext.cureOperatorId());
  60. Picture p = new Picture();
  61. p.setSystem_id(bc.getSystemId());
  62. p.setIsspid(bc.getPid());
  63. PictureDetail detail = new PictureDetail();
  64. detail.setType(dto.getType());
  65. detail.setImage_name(dto.getName());
  66. detail.setImage_content(dto.getBase64Str());
  67. p.setMerchant_picture_request(detail);
  68. PictureBack back = null;
  69. try {
  70. back = (PictureBack) YmUtil.resultBack(p,new PictureBack());
  71. } catch (IllegalAccessException e) {
  72. e.printStackTrace();
  73. return VaultsResponse.failed(e.getMessage());
  74. }
  75. if(YmUtil.SUCCESS.equals(back.getResult().getId())){
  76. return VaultsResponse.success(back.getId());
  77. }
  78. return VaultsResponse.failed(back.getResult().getComment());
  79. }
  80. /**
  81. * 商户新增/修改开户入驻
  82. * @param dto
  83. * @return
  84. */
  85. @Override
  86. public VaultsResponse merchantCreateOpen(UserDto dto) {
  87. BasicConfiguration basicConfig = Basic.getSystemParameter(TokenContext.cureOperatorId());
  88. dto.setRemained_amt(dto.getRemained_amt()*100);
  89. VaultsResponse<UserSearchBack> vaultsResponse = this.merchantQuery(dto.getPhone(),null);
  90. if(!vaultsResponse.validate()){
  91. log.info("UserSearchBack==="+vaultsResponse);
  92. return vaultsResponse;
  93. }
  94. UserSearchBack searchBack = vaultsResponse.getData();
  95. Integer status = 0;
  96. if(searchBack != null){
  97. status = Integer.parseInt(searchBack.getIncoming_status());
  98. }
  99. if(StringUtils.isEmpty(dto.getIncoming_status())){
  100. dto.setIncoming_status(status.toString());
  101. }
  102. if(StringUtils.isEmpty(dto.getMerchant_id())){
  103. if(searchBack != null){
  104. dto.setMerchant_id(searchBack.getMerchant_id());
  105. //return VaultsResponse.failed("手机号码已被注册");
  106. }
  107. //添加商户
  108. VaultsResponse<String> createVault = this.merchantCreate(dto);
  109. if(!createVault.validate()){
  110. log.info("createVault==="+createVault);
  111. return createVault;
  112. }
  113. dto.setMerchant_id(createVault.getData());
  114. }else{
  115. if(searchBack != null && !searchBack.getMerchant_id().equals(dto.getMerchant_id())){
  116. return VaultsResponse.failed("手机号码已被注册");
  117. }
  118. }
  119. if(dto.getIncoming_status().equals("2")){
  120. //修改开户/入驻信息
  121. VaultsResponse<String> indvmodifyVault = this.modifyVault(dto);
  122. if(!indvmodifyVault.validate()){
  123. log.info("indvmodifyVault==="+indvmodifyVault);
  124. return indvmodifyVault;
  125. }
  126. VaultsResponse<String> openModifyVault = this.merchantOpenModify(dto);
  127. VaultsResponse<String> stringVault = updateMerchantId(dto.getId(), dto.getSourceId(), dto.getMerchant_id(),2,dto.getRemained_amt(),basicConfig.getCode(),dto.getProportion());
  128. if(!stringVault.validate()){
  129. log.info("stringVault==="+stringVault);
  130. return stringVault;
  131. }
  132. if(dto.getSourceId().equals(1)){
  133. BindDto bd = new BindDto();
  134. bd.setAppId(stringVault.getData());
  135. bd.setPosId(basicConfig.getCode());
  136. bd.setStoreId(dto.getId().toString());
  137. bd.setName("("+basicConfig.getCode()+")"+dto.getMerchant_short_name());
  138. //修改门店信息
  139. if(!dto.getMerchant_short_name().equals(searchBack.getBase_merchant_short_name())){
  140. VaultsResponse changeVr = paymentService.changeBindPos(bd);
  141. if(!changeVr.validate()){
  142. return changeVr;
  143. }
  144. }
  145. //终端绑定交易
  146. return paymentService.bindPos(bd);
  147. }
  148. log.info("openModifyVault==="+openModifyVault);
  149. return openModifyVault;
  150. }else{
  151. if(dto.getIncoming_status().equals("0") || dto.getIncoming_status().equals("-1")){
  152. //未开户或开户失败时
  153. if(dto.getType().equals("3")){
  154. //个人
  155. VaultsResponse<String> indvregisterVault = this.merchantIndvregister(dto);
  156. if(!indvregisterVault.validate()){
  157. log.info("indvregisterVault==="+indvregisterVault);
  158. return indvregisterVault;
  159. }
  160. }else{
  161. //商户
  162. VaultsResponse<String> entregisterVault = this.merchantEntregister(dto);
  163. if(!entregisterVault.validate()){
  164. log.info("entregisterVault==="+entregisterVault);
  165. return entregisterVault;
  166. }
  167. }
  168. updateMerchantId(dto.getId(), dto.getSourceId(), dto.getMerchant_id(),3,dto.getRemained_amt(),basicConfig.getCode(),dto.getProportion());
  169. }else{
  170. VaultsResponse<String> indvmodifyVault = this.modifyVault(dto);
  171. if(!indvmodifyVault.validate()){
  172. log.info("indvmodifyVault==="+indvmodifyVault);
  173. return indvmodifyVault;
  174. }
  175. }
  176. //入驻
  177. VaultsResponse<String> openVault = this.merchantOpen(dto);
  178. if(!openVault.validate()){
  179. log.info("openVault==="+openVault);
  180. return openVault;
  181. }
  182. // if(status != 2){
  183. VaultsResponse<String> stringVault = updateMerchantId(dto.getId(), dto.getSourceId(), dto.getMerchant_id(),2,dto.getRemained_amt(),basicConfig.getCode(),dto.getProportion());
  184. if(!stringVault.validate()){
  185. log.info("stringVault==="+stringVault);
  186. return stringVault;
  187. }
  188. if(dto.getSourceId().equals(1)){
  189. //终端绑定交易
  190. BindDto bd = new BindDto();
  191. bd.setAppId(stringVault.getData());
  192. bd.setPosId(basicConfig.getCode());
  193. bd.setStoreId(dto.getId().toString());
  194. bd.setName("("+basicConfig.getCode()+")"+dto.getMerchant_short_name());
  195. return paymentService.bindPos(bd);
  196. }
  197. // }
  198. }
  199. return VaultsResponse.success();
  200. }
  201. private VaultsResponse<String> modifyVault(UserDto dto) {
  202. //修改开户信息
  203. if(dto.getType().equals("3")){
  204. //个人
  205. VaultsResponse<String> indvmodifyVault = this.merchantIndvmodify(dto);
  206. if(!indvmodifyVault.validate()){
  207. return indvmodifyVault;
  208. }
  209. }else{
  210. //商户
  211. VaultsResponse<String> entmodifyVault = this.merchantEntmodify(dto);
  212. if(!entmodifyVault.validate()){
  213. return entmodifyVault;
  214. }
  215. }
  216. return VaultsResponse.success();
  217. }
  218. /**
  219. * 添加分账商户
  220. * @param dto
  221. * @return
  222. */
  223. private VaultsResponse merchantCreate(UserDto dto) {
  224. User user = new User();
  225. BasicConfiguration bc = Basic.getSystemParameter(TokenContext.cureOperatorId());
  226. user.setSystem_id(bc.getSystemId());
  227. user.setIsspid(bc.getPid());
  228. UserDetail detail = new UserDetail();
  229. detail.setType(dto.getType());
  230. detail.setMerchant_short_name(dto.getMerchant_short_name());
  231. detail.setMerchant_name(dto.getMerchant_name());
  232. detail.setPhone(dto.getPhone());
  233. user.setMerchant_create_request(detail);
  234. UserBack back = null;
  235. try {
  236. back = (UserBack) YmUtil.resultBack(user,new UserBack());
  237. } catch (IllegalAccessException e) {
  238. e.printStackTrace();
  239. return VaultsResponse.failed(e.getMessage());
  240. }
  241. if(YmUtil.SUCCESS.equals(back.getResult().getId())){
  242. VaultsResponse vaultsResponse = updateMerchantId(dto.getId(), dto.getSourceId(), back.getMerchant_id(),0,dto.getRemained_amt(),bc.getCode(),dto.getProportion());
  243. if(!vaultsResponse.validate()){
  244. return vaultsResponse;
  245. }
  246. return VaultsResponse.success(back.getMerchant_id());
  247. }
  248. return VaultsResponse.failed(back.getResult().getComment());
  249. }
  250. private VaultsResponse updateMerchantId(Integer id, Integer source, String merchantId, Integer status, Long remainedAmt, String code, BigDecimal proportion) {
  251. VaultsResponse vaultsResponse;
  252. OperatorIdParams operatorIdParams = new OperatorIdParams();
  253. operatorIdParams.setOperatorId(TokenContext.cureOperatorId());
  254. operatorIdParams.setId(id.toString());
  255. operatorIdParams.setMerchantId(merchantId);
  256. operatorIdParams.setSource(source);
  257. operatorIdParams.setStatus(status);
  258. operatorIdParams.setCode(code);
  259. operatorIdParams.setRemainedAmt(remainedAmt);
  260. if(source.equals(3)){
  261. vaultsResponse = customerFeignClient.updateMerchantId(operatorIdParams);
  262. }else{
  263. operatorIdParams.setProportion(proportion.divide(new BigDecimal(100.0)));
  264. vaultsResponse = partnerFeignClient.updateMerchantId(operatorIdParams);
  265. }
  266. return vaultsResponse;
  267. }
  268. /**
  269. * 个人分账商户开户
  270. * @param dto
  271. * @return
  272. */
  273. private VaultsResponse merchantIndvregister(UserDto dto){
  274. IndvregisterAdd iAdd = new IndvregisterAdd();
  275. BasicConfiguration bc = Basic.getSystemParameter(TokenContext.cureOperatorId());
  276. iAdd.setSystem_id(bc.getSystemId());
  277. iAdd.setIsspid(bc.getPid());
  278. IndvregisterAddDetail detail = new IndvregisterAddDetail();
  279. detail.setMerchant_id(dto.getMerchant_id());
  280. detail.setIdentity_begin_date(dto.getIdentity_begin_date());
  281. if(StringUtils.isNotEmpty(dto.getIdentity_end_date())){
  282. detail.setIdentity_end_date(dto.getIdentity_end_date());
  283. }
  284. detail.setIdentity_validity_type(dto.getIdentity_validity_type());
  285. detail.setContact_phone(dto.getContact_phone());
  286. detail.setCert_photo_a(this.merchantPicture(dto.getCert_photo_a()).getData());
  287. detail.setCert_photo_b(this.merchantPicture(dto.getCert_photo_b()).getData());
  288. detail.setLegal_name(dto.getLegal_name());
  289. detail.setIdentity_no(dto.getIdentity_no());
  290. detail.setMerchant_name(dto.getMerchant_name());
  291. //detail.setIdentity_type(dto.getIdentity_type());
  292. iAdd.setMerchant_indvregister_request(detail);
  293. BaseBack back = null;
  294. try {
  295. back = (BaseBack) YmUtil.resultBack(iAdd,new BaseBack());
  296. } catch (IllegalAccessException e) {
  297. e.printStackTrace();
  298. return VaultsResponse.failed(e.getMessage());
  299. }
  300. if(YmUtil.SUCCESS.equals(back.getResult().getId())){
  301. return VaultsResponse.success();
  302. }
  303. return VaultsResponse.failed(back.getResult().getComment());
  304. }
  305. /**
  306. * 个人分账商户修改
  307. * @param dto
  308. * @return
  309. */
  310. private VaultsResponse merchantIndvmodify(UserDto dto){
  311. IndvregisterUpdate iUpdate = new IndvregisterUpdate();
  312. BasicConfiguration bc = Basic.getSystemParameter(TokenContext.cureOperatorId());
  313. iUpdate.setSystem_id(bc.getSystemId());
  314. iUpdate.setIsspid(bc.getPid());
  315. IndvregisterUpdateDetail iUpdateDetail = new IndvregisterUpdateDetail();
  316. iUpdateDetail.setMerchant_id(dto.getMerchant_id());
  317. iUpdateDetail.setIdentity_begin_date(dto.getIdentity_begin_date());
  318. if(StringUtils.isNotEmpty(dto.getIdentity_end_date())){
  319. iUpdateDetail.setIdentity_end_date(dto.getIdentity_end_date());
  320. }
  321. iUpdateDetail.setIdentity_validity_type(dto.getIdentity_validity_type());
  322. iUpdateDetail.setContact_phone(dto.getContact_phone());
  323. if(StringUtils.isEmpty(dto.getCert_photo_a().getBase64Str())){
  324. for (ImageListDto imageListDto : dto.getImage_list()) {
  325. if(imageListDto.getFile_type().equals("01")){
  326. iUpdateDetail.setCert_photo_a(imageListDto.getFile_id());
  327. break;
  328. }
  329. }
  330. }else{
  331. iUpdateDetail.setCert_photo_a(this.merchantPicture(dto.getCert_photo_a()).getData());
  332. }
  333. if(StringUtils.isEmpty(dto.getCert_photo_b().getBase64Str())){
  334. for (ImageListDto imageListDto : dto.getImage_list()) {
  335. if(imageListDto.getFile_type().equals("02")){
  336. iUpdateDetail.setCert_photo_b(imageListDto.getFile_id());
  337. break;
  338. }
  339. }
  340. }else{
  341. iUpdateDetail.setCert_photo_b(this.merchantPicture(dto.getCert_photo_b()).getData());
  342. }
  343. iUpdate.setMerchant_indvmodify_request(iUpdateDetail);
  344. BaseBack back = null;
  345. try {
  346. back = (BaseBack) YmUtil.resultBack(iUpdate,new BaseBack());
  347. } catch (IllegalAccessException e) {
  348. e.printStackTrace();
  349. return VaultsResponse.failed(e.getMessage());
  350. }
  351. if(YmUtil.SUCCESS.equals(back.getResult().getId())){
  352. return VaultsResponse.success();
  353. }
  354. return VaultsResponse.failed(back.getResult().getComment());
  355. }
  356. /**
  357. * 企业分账商户开户
  358. * @param dto
  359. * @return
  360. */
  361. private VaultsResponse merchantEntregister(UserDto dto){
  362. EntregisterAdd iAdd = new EntregisterAdd();
  363. BasicConfiguration bc = Basic.getSystemParameter(TokenContext.cureOperatorId());
  364. iAdd.setSystem_id(bc.getSystemId());
  365. iAdd.setIsspid(bc.getPid());
  366. EntregisterAddDetail detail = new EntregisterAddDetail();
  367. detail.setMerchant_id(dto.getMerchant_id());
  368. detail.setLicense_begin_date(dto.getLicense_begin_date());
  369. if(StringUtils.isNotEmpty(dto.getLicense_end_date())){
  370. detail.setLicense_end_date(dto.getLicense_end_date());
  371. }
  372. detail.setLicense_validity_type(dto.getLicense_validity_type());
  373. List<String> areaList = areaService.getAreaCode(dto.getLicense_area());
  374. detail.setLicense_province_code(areaList.get(0));
  375. detail.setLicense_city_code(areaList.get(1));
  376. detail.setLicense_area_code(areaList.get(2));
  377. detail.setLicense_address(dto.getLicense_address());
  378. detail.setLegal_name(dto.getLegal_name());
  379. detail.setIdentity_no(dto.getIdentity_no());
  380. detail.setIdentity_begin_date(dto.getIdentity_begin_date());
  381. if(StringUtils.isNotEmpty(dto.getIdentity_end_date())){
  382. detail.setIdentity_end_date(dto.getIdentity_end_date());
  383. }
  384. detail.setIdentity_validity_type(dto.getIdentity_validity_type());
  385. detail.setContact_name(dto.getContact_name());
  386. detail.setContact_phone(dto.getContact_phone());
  387. detail.setLicense_photo(this.merchantPicture(dto.getLicense_photo()).getData());
  388. detail.setCert_photo_a(this.merchantPicture(dto.getCert_photo_a()).getData());
  389. detail.setCert_photo_b(this.merchantPicture(dto.getCert_photo_b()).getData());
  390. detail.setMerchant_name(dto.getMerchant_name());
  391. detail.setLicense_code(dto.getLicense_code());
  392. //detail.setIdentity_type(dto.getIdentity_type());
  393. iAdd.setMerchant_entregister_request(detail);
  394. BaseBack back = null;
  395. try {
  396. back = (BaseBack) YmUtil.resultBack(iAdd,new BaseBack());
  397. } catch (IllegalAccessException e) {
  398. e.printStackTrace();
  399. return VaultsResponse.failed(e.getMessage());
  400. }
  401. if(YmUtil.SUCCESS.equals(back.getResult().getId())){
  402. return VaultsResponse.success();
  403. }
  404. return VaultsResponse.failed(back.getResult().getComment());
  405. }
  406. /**
  407. * 企业分账商户修改
  408. * @param dto
  409. * @return
  410. */
  411. private VaultsResponse merchantEntmodify(UserDto dto){
  412. EntregisterUpdate iUpdate = new EntregisterUpdate();
  413. BasicConfiguration bc = Basic.getSystemParameter(TokenContext.cureOperatorId());
  414. iUpdate.setSystem_id(bc.getSystemId());
  415. iUpdate.setIsspid(bc.getPid());
  416. EntregisterUpdateDetail iUpdateDetail = new EntregisterUpdateDetail();
  417. iUpdateDetail.setMerchant_id(dto.getMerchant_id());
  418. iUpdateDetail.setLicense_begin_date(dto.getLicense_begin_date());
  419. if(StringUtils.isNotEmpty(dto.getLicense_end_date())){
  420. iUpdateDetail.setLicense_end_date(dto.getLicense_end_date());
  421. }
  422. iUpdateDetail.setLicense_validity_type(dto.getLicense_validity_type());
  423. List<String> areaList = areaService.getAreaCode(dto.getLicense_area());
  424. iUpdateDetail.setLicense_province_code(areaList.get(0));
  425. iUpdateDetail.setLicense_city_code(areaList.get(1));
  426. iUpdateDetail.setLicense_area_code(areaList.get(2));
  427. iUpdateDetail.setLicense_address(dto.getLicense_address());
  428. iUpdateDetail.setLegal_name(dto.getLegal_name());
  429. iUpdateDetail.setIdentity_no(dto.getIdentity_no());
  430. iUpdateDetail.setIdentity_begin_date(dto.getIdentity_begin_date());
  431. if(StringUtils.isNotEmpty(dto.getIdentity_end_date())){
  432. iUpdateDetail.setIdentity_end_date(dto.getIdentity_end_date());
  433. }
  434. iUpdateDetail.setIdentity_validity_type(dto.getIdentity_validity_type());
  435. iUpdateDetail.setContact_name(dto.getContact_name());
  436. iUpdateDetail.setContact_phone(dto.getContact_phone());
  437. if(StringUtils.isEmpty(dto.getLicense_photo().getBase64Str())){
  438. for (ImageListDto imageListDto : dto.getImage_list()) {
  439. if(imageListDto.getFile_type().equals("03")){
  440. iUpdateDetail.setLicense_photo(imageListDto.getFile_id());
  441. break;
  442. }
  443. }
  444. }else{
  445. iUpdateDetail.setLicense_photo(this.merchantPicture(dto.getLicense_photo()).getData());
  446. }
  447. if(StringUtils.isEmpty(dto.getCert_photo_a().getBase64Str())){
  448. for (ImageListDto imageListDto : dto.getImage_list()) {
  449. if(imageListDto.getFile_type().equals("01")){
  450. iUpdateDetail.setCert_photo_a(imageListDto.getFile_id());
  451. break;
  452. }
  453. }
  454. }else{
  455. iUpdateDetail.setCert_photo_a(this.merchantPicture(dto.getCert_photo_a()).getData());
  456. }
  457. if(StringUtils.isEmpty(dto.getCert_photo_b().getBase64Str())){
  458. for (ImageListDto imageListDto : dto.getImage_list()) {
  459. if(imageListDto.getFile_type().equals("02")){
  460. iUpdateDetail.setCert_photo_b(imageListDto.getFile_id());
  461. break;
  462. }
  463. }
  464. }else{
  465. iUpdateDetail.setCert_photo_b(this.merchantPicture(dto.getCert_photo_b()).getData());
  466. }
  467. iUpdate.setMerchant_entmodify_request(iUpdateDetail);
  468. BaseBack back = null;
  469. try {
  470. back = (BaseBack) YmUtil.resultBack(iUpdate,new BaseBack());
  471. } catch (IllegalAccessException e) {
  472. e.printStackTrace();
  473. return VaultsResponse.failed(e.getMessage());
  474. }
  475. if(YmUtil.SUCCESS.equals(back.getResult().getId())){
  476. return VaultsResponse.success();
  477. }
  478. return VaultsResponse.failed(back.getResult().getComment());
  479. }
  480. /**
  481. * 分账商户业务入驻
  482. * @param dto
  483. * @return
  484. */
  485. private VaultsResponse merchantOpen(UserDto dto){
  486. OpenAdd openAdd = new OpenAdd();
  487. BasicConfiguration bc = Basic.getSystemParameter(TokenContext.cureOperatorId());
  488. openAdd.setSystem_id(bc.getSystemId());
  489. openAdd.setIsspid(bc.getPid());
  490. openAdd.setMerchant_open_request(this.fill(dto));
  491. BaseBack back = null;
  492. try {
  493. back = (BaseBack) YmUtil.resultBack(openAdd,new BaseBack());
  494. } catch (IllegalAccessException e) {
  495. e.printStackTrace();
  496. return VaultsResponse.failed(e.getMessage());
  497. }
  498. if(YmUtil.SUCCESS.equals(back.getResult().getId())){
  499. return VaultsResponse.success(back);
  500. }else if(YmUtil.ERROR.equals(back.getResult().getId())){
  501. return VaultsResponse.failed(back.getResult().getComment());
  502. }
  503. return VaultsResponse.failed();
  504. }
  505. /**
  506. * 入驻数据填充
  507. * @param dto
  508. * @return
  509. */
  510. private OpenDetail fill(UserDto dto){
  511. OpenDetail detail = new OpenDetail();
  512. detail.setMerchant_id(dto.getMerchant_id());
  513. detail.setSettle_type(dto.getSettle_type());
  514. /* detail.setSettlement_way(dto.getSettlement_way());
  515. detail.setWithdraw_way(dto.getWithdraw_way());*/
  516. detail.setCard_no(dto.getCard_no());
  517. detail.setParent_bank_name(dto.getParent_bank_name());
  518. detail.setParent_bank_code(dto.getParent_bank_code());
  519. List<String> areaList = areaService.getAreaCode(dto.getBank_area());
  520. detail.setProvince(areaList.get(0));
  521. detail.setCity(areaList.get(1));
  522. detail.setBranch_bank_code(dto.getBranch_bank_code());
  523. detail.setBranch_bank_name(dto.getBranch_bank_name());
  524. if(StringUtils.isEmpty(dto.getSettle_photo_a().getBase64Str())){
  525. for (ImageListDto imageListDto : dto.getImage_list()) {
  526. if(imageListDto.getFile_type().equals("13")){
  527. detail.setSettle_photo_a(imageListDto.getFile_id());
  528. break;
  529. }
  530. }
  531. }else{
  532. detail.setSettle_photo_a(this.merchantPicture(dto.getSettle_photo_a()).getData());
  533. }
  534. if(StringUtils.isEmpty(dto.getSettle_photo_b().getBase64Str())){
  535. for (ImageListDto imageListDto : dto.getImage_list()) {
  536. if(imageListDto.getFile_type().equals("14")){
  537. detail.setSettle_photo_b(imageListDto.getFile_id());
  538. break;
  539. }
  540. }
  541. }else{
  542. detail.setSettle_photo_b(this.merchantPicture(dto.getSettle_photo_b()).getData());
  543. }
  544. detail.setRemained_amt(dto.getRemained_amt());
  545. detail.setSettle_abstract(dto.getSettle_abstract());
  546. return detail;
  547. }
  548. /**
  549. * 分账商户业务入驻修改
  550. * @param dto
  551. * @return
  552. */
  553. private VaultsResponse merchantOpenModify(UserDto dto){
  554. OpenUpdate openUpdate = new OpenUpdate();
  555. BasicConfiguration bc = Basic.getSystemParameter(TokenContext.cureOperatorId());
  556. openUpdate.setSystem_id(bc.getSystemId());
  557. openUpdate.setIsspid(bc.getPid());
  558. openUpdate.setMerchant_openmodify_request(this.fill(dto));
  559. BaseBack back = null;
  560. try {
  561. back = (BaseBack) YmUtil.resultBack(openUpdate,new BaseBack());
  562. } catch (IllegalAccessException e) {
  563. e.printStackTrace();
  564. return VaultsResponse.failed(e.getMessage());
  565. }
  566. if(YmUtil.SUCCESS.equals(back.getResult().getId())){
  567. return VaultsResponse.success(back);
  568. }
  569. return VaultsResponse.failed();
  570. }
  571. /**
  572. * 分账商户查询
  573. * @param phone
  574. * @param merchantId
  575. * @return
  576. */
  577. @Override
  578. public VaultsResponse<UserSearchBack> merchantQuery(String phone, String merchantId){
  579. UserSearch userSearch = new UserSearch();
  580. BasicConfiguration bc = Basic.getSystemParameter(TokenContext.cureOperatorId());
  581. userSearch.setSystem_id(bc.getSystemId());
  582. userSearch.setIsspid(bc.getPid());
  583. UserSearchDetail detail = new UserSearchDetail();
  584. detail.setPhone(phone);
  585. detail.setMerchant_id(merchantId);
  586. userSearch.setMerchant_query_request(detail);
  587. UserSearchBack back = null;
  588. try {
  589. String val = (String) YmUtil.resultBack(userSearch,new UserSearchBack());
  590. JSONObject jsonObject = new JSONObject(JSON.parseObject(val));
  591. if(val.contains("image_list")){
  592. List<ImageListBack> list = jsonObject.getJSONArray("image_list").stream().map(item -> JSON.parseObject(item.toString(), new TypeReference<ImageListBack>() {})).collect(Collectors.toList());
  593. jsonObject.put("image_list",list);
  594. }
  595. back = JSONObject.toJavaObject(jsonObject, UserSearchBack.class);
  596. back.setProportion(new BigDecimal(cacheService.get("supplier_pro")).multiply(new BigDecimal(100)));
  597. } catch (IllegalAccessException e) {
  598. e.printStackTrace();
  599. return VaultsResponse.failed(e.getMessage());
  600. }
  601. if(YmUtil.SUCCESS.equals(back.getResult().getId())){
  602. return VaultsResponse.success(back);
  603. }else if("9990".equals(back.getResult().getId())){
  604. return VaultsResponse.success(null);
  605. }
  606. return VaultsResponse.failed();
  607. }
  608. }