| | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.alibaba.fastjson.TypeReference; |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.doumee.biz.system.SystemDictDataBiz; |
| | | import com.doumee.biz.zbom.ZbomCRMService; |
| | | import com.doumee.biz.zbom.model.crm.*; |
| | | import com.doumee.biz.zbom.model.crm.response.CRMBaseResponse; |
| | |
| | | import com.doumee.dao.business.CustomerLogMapper; |
| | | import com.doumee.dao.business.model.CrmInterfaceLog; |
| | | import com.doumee.dao.business.model.CustomerLog; |
| | | import com.doumee.dao.business.model.Member; |
| | | import com.doumee.dao.business.model.Users; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.codec.digest.DigestUtils; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.apache.logging.log4j.util.Base64Util; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.data.redis.core.RedisTemplate; |
| | | import org.springframework.scheduling.annotation.Async; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.util.Base64Utils; |
| | | |
| | | import javax.crypto.Cipher; |
| | | import javax.crypto.spec.IvParameterSpec; |
| | | import javax.crypto.spec.SecretKeySpec; |
| | | import java.io.UnsupportedEncodingException; |
| | | import java.net.URLEncoder; |
| | | import java.util.*; |
| | | |
| | |
| | | private CustomerLogMapper customerLogMapper; |
| | | @Autowired |
| | | private CrmInterfaceLogMapper crmInterfaceLogMapper; |
| | | |
| | | @Autowired |
| | | private RedisTemplate<String, Object> redisTemplate; |
| | | @Autowired |
| | | private SystemDictDataBiz systemDictDataBiz; |
| | | |
| | | |
| | | |
| | |
| | | */ |
| | | @Override |
| | | @Async |
| | | public int dealCustomerLogData(CustomerLog customerLog){ |
| | | public void dealCustomerLogData(CustomerLog customerLog){ |
| | | if(StringUtils.isBlank(customerLog.getPhone())){ |
| | | return; |
| | | } |
| | | CrmCustomerInfoRequest entity = new CrmCustomerInfoRequest(); |
| | | entity.setId(customerLog.getId()); |
| | | entity.setName(customerLog.getName()); |
| | |
| | | entity.setAreaname(customerLog.getAreaName()); |
| | | entity.setAreacode(customerLog.getAreaCode()); |
| | | entity.setOpenid(customerLog.getOpenid()); |
| | | entity.setUserData(new ArrayList<>()); |
| | | if(StringUtils.isNotBlank(customerLog.getUsernames())){ |
| | | String[] names = customerLog.getUsernames().split(","); |
| | | for(String str:names){ |
| | | CrmCustomerUsernameRequest usernameRequest = new CrmCustomerUsernameRequest(); |
| | | usernameRequest.setUserName(str); |
| | | entity.getUserData().add(usernameRequest);//导购登陆账号集合 |
| | | } |
| | | } |
| | | // 提交类型 0-测试装修风格;1-0元定制;2装修计算器 |
| | | if(Constants.equalsInteger(customerLog.getType(),Constants.ONE)){ |
| | | entity.setSource(CRMConstants.CRM_SOURCE.SOURCE_MP01); |
| | |
| | | entity.setSource(CRMConstants.CRM_SOURCE.SOURCE_MP02); |
| | | entity.setChannel(CRMConstants.CRM_SOURCE.SOURCE_MP02+"00"); |
| | | } |
| | | // entity.setOpenId(customerLog.getOpenid()); |
| | | entity.setOpenid(customerLog.getOpenid()); |
| | | entity.setDate(DateUtil.dateToString(customerLog.getCreateDate(),"yyyy/MM/dd HH:mm")); |
| | | CrmCustomerPostRequest obj = new CrmCustomerPostRequest(); |
| | |
| | | .set(CustomerLog::getCrmStatus,Constants.ONE ) |
| | | .set(CustomerLog::getCrmInfo,crmInfo ) |
| | | .set(CustomerLog::getCrmDate,new Date() ));// 更新状态 |
| | | return status;// 默认失败 |
| | | } |
| | | /** |
| | | * 获取导购绑定列表 |
| | |
| | | |
| | | public <T> CRMBaseResponse<T> sendCusHttpRequest(String interfaceUrl, String name, String param){ |
| | | log.info("【"+name+"】================开始===="+ JSONObject.toJSONString(param)); |
| | | String appKey = (String) redisTemplate.opsForValue().get(Constants.RedisKeys.ZBOM_CRM_API_KEY); |
| | | String appKey = (String) redisTemplate.opsForValue().get(Constants.RedisKeys.ZBOM_CRM_POSTCUS_API_KEY); |
| | | String url = redisTemplate.opsForValue().get(Constants.RedisKeys.ZBOM_CRM_API_URL) + interfaceUrl ; |
| | | long _t = System.currentTimeMillis(); |
| | | if (StringUtils.isNotBlank(appKey)||StringUtils.isNotBlank(url)) { |
| | |
| | | * @return |
| | | */ |
| | | @Override |
| | | public String getCrmGoUrl(String userName){ |
| | | StringBuffer sb = new StringBuffer(); |
| | | String result = null; |
| | | public String getCrmGoUrl(String userName,Integer type,String iamId){ |
| | | try { |
| | | // 创建StringBuffer对象用来操作字符串 |
| | | int _t = (int)(System.currentTimeMillis()); |
| | | String appkey = (String) redisTemplate.opsForValue().get(Constants.RedisKeys.ZBOM_CRM_AUTH_API_KEY); |
| | | String url = (String) redisTemplate.opsForValue().get(Constants.RedisKeys.ZBOM_CRM_API_URL) |
| | | +CRMConstants.IntegerUrl.GO_CRM_AUTH_URL |
| | | + "?timestamp="+_t |
| | | +"&agent_phone_number=" + URLEncoder.encode(userName, "UTF-8") |
| | | + "&bindKey=mp&sign="+ DigestUtils.md5Hex( _t + appkey);; |
| | | String pageKey ="mp";//客户列表页面码 |
| | | String fileUrl = systemDictDataBiz.queryByCode(Constants.ZBOM,Constants.ZBOM_CRM_API_URL_MP).getCode(); |
| | | if(Constants.equalsInteger(type,Constants.ONE)){ |
| | | pageKey = "mpAddIntention";//新增意向页面码 |
| | | fileUrl = systemDictDataBiz.queryByCode(Constants.ZBOM,Constants.ZBOM_CRM_API_URL_MP_ADDINTENTION).getCode(); |
| | | } |
| | | String url = redisTemplate.opsForValue().get(Constants.RedisKeys.ZBOM_CRM_API_URL) |
| | | + CRMConstants.IntegerUrl.GO_CRM_AUTH_URL |
| | | + "?bindKey="+pageKey |
| | | + "&tick=" + this.getTick(iamId, fileUrl); |
| | | return url; |
| | | }catch (Exception e){ |
| | | e.printStackTrace(); |
| | | } |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"获取跳转地址失败哦!"); |
| | | } |
| | | |
| | | public String getTick(String iamId, String fileUrL) throws UnsupportedEncodingException { |
| | | Map<String,Object> map = new HashMap<>(); |
| | | //用户IAM主键 |
| | | map.put("ssouserid",iamId); |
| | | //售前小程序appid |
| | | map.put("appid",systemDictDataBiz.queryByCode(Constants.ZBOM,Constants.ZBOM_IAM_BUSINESS_APPID).getCode()); |
| | | //跳转地址 |
| | | map.put("rediUrl",fileUrL); |
| | | //时间戳 |
| | | map.put("timestamp",System.currentTimeMillis()/1000+""); |
| | | //C端小程序appid |
| | | map.put("sourceappid",systemDictDataBiz.queryByCode(Constants.ZBOM,Constants.ZBOM_IAM_CUSTOMER_APPID).getCode()); |
| | | System.out.println(JSONObject.toJSONString(map)); |
| | | //获取tick |
| | | String tick = ZbomCRMServiceImpl.encrypt( |
| | | systemDictDataBiz.queryByCode(Constants.ZBOM,Constants.ZBOM_CRM_API_URL_PRIVATE_KEY).getCode() |
| | | ,JSONObject.toJSONString(map) |
| | | ,systemDictDataBiz.queryByCode(Constants.ZBOM,Constants.ZBOM_CRM_API_URL_INIT_VECTOR).getCode()); |
| | | |
| | | String tickEncoder = URLEncoder.encode(tick,"UTF-8"); |
| | | |
| | | return tickEncoder; |
| | | } |
| | | |
| | | |
| | | public static String encrypt(String key, String value,String initVector) { |
| | | try { |
| | | IvParameterSpec iv = new IvParameterSpec(initVector.getBytes("UTF-8")); |
| | | SecretKeySpec skeySpec = new SecretKeySpec(key.getBytes("UTF-8"), "AES"); |
| | | Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5PADDING"); |
| | | cipher.init(Cipher.ENCRYPT_MODE, skeySpec, iv); |
| | | byte[] encrypted = cipher.doFinal(value.getBytes()); |
| | | return Base64Utils.encodeToString(encrypted); |
| | | } |
| | | catch (Exception ex) { |
| | | ex.printStackTrace(); |
| | | } |
| | | return null; |
| | | } |
| | | |
| | | |
| | | } |