| 
					
				 | 
			
			
				@@ -1,609 +0,0 @@ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-/* 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-package com.gree.mall.manager.controller.common; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.alibaba.fastjson.JSON; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.alibaba.fastjson.JSONObject; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.aliyuncs.utils.StringUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.fasterxml.jackson.core.JsonProcessingException; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.fasterxml.jackson.databind.DeserializationFeature; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.fasterxml.jackson.databind.JsonMappingException; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.fasterxml.jackson.databind.ObjectMapper; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.gree.mall.manager.bean.CommonParam; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.gree.mall.manager.bean.OutAppDefaultReq; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.gree.mall.manager.constant.Constant; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.gree.mall.manager.exception.RemoteServiceException; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.gree.mall.manager.helper.GreeResponseHelper; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.gree.mall.manager.logic.common.CommonLogic; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.gree.mall.manager.utils.RedisUtil; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.gree.mall.manager.utils.http.HttpUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import lombok.extern.slf4j.Slf4j; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.beans.BeanUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.beans.factory.annotation.Autowired; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.beans.factory.annotation.Value; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.http.HttpEntity; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.http.HttpHeaders; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.http.MediaType; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.stereotype.Service; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.util.LinkedMultiValueMap; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.util.MultiValueMap; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.web.client.HttpStatusCodeException; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.web.client.RestTemplate; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import java.io.IOException; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import java.text.SimpleDateFormat; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import java.util.*; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-*/ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-/** 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- * 格力总部接口*//* 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-@Slf4j 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-@Service 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-public class GreeLogic { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.V3.gettoken}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String tokenUrl; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.check.barcode}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String checkBarcodeUrl; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.repair.settle.get}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String getRepairSettleUrl; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.repair.settle.do}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String doRepairSettleUrl; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.client.id}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String clientId; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.V3.client.secert}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String clientSecert; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.api.url}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String apiUrl; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.gz.appid}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String gzAppId; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.gz.appkey}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String gzAppKey; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.fs.appid}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String fsAppId; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.fs.appkey}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String fsAppKey; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-//    @Value("${gree.cloud.api.url}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-//    private String cloudApiUrl; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.V3.api.url}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String v3ApiUrl; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.V3.gettoken}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String v3TokenUrl; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.V3.client.secert}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String v3ClientSecert; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Value("${gree.url}") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private String apiUrlFeedBack; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Autowired 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    RedisUtil redisUtil; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Autowired 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    CommonLogic commonLogic; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public String getAppId(Integer belongType){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if(belongType == 1){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return gzAppId; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        }else{ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return fsAppId; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public String getAppKey(Integer belongType){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if(belongType == 1){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return gzAppKey; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        }else{ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return fsAppKey; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-*/ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-/** 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * 获取总部接口的请求token 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @return 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @throws RemoteServiceException*//* 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public String getAccessToken() throws RemoteServiceException { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String redisKey = Constant.RedisPrefix.TOKEN_GREE; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String token = (String)redisUtil.get(redisKey); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if(token != null){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return token; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        MultiValueMap<String, String> forms= new LinkedMultiValueMap<String, String>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        forms.put("client_id", Collections.singletonList(clientId)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        forms.put("client_secret", Collections.singletonList(clientSecert)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        forms.put("grant_type", Collections.singletonList("client_credentials")); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String s = HttpUtils.requestXwww(tokenUrl, forms); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        //String s = HttpUtils.requestPostForm(tokenUrl, map, null); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【获取总部token】response:{}",s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        JSONObject jsonObject = JSONObject.parseObject(s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String accessToken = jsonObject.getString("access_token"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if(StringUtils.isNotEmpty(accessToken)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            redisUtil.set(Constant.RedisPrefix.TOKEN_GREE, accessToken, 2 * 60 * 60); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        return accessToken; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-*/ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-/** 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * 获取总部接口的请求token 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @return 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @throws RemoteServiceException*//* 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public String getAccessTokenV3() throws RemoteServiceException { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String redisKey = Constant.RedisPrefix.TOKEN_GREE_V3; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String token = (String)redisUtil.get(redisKey); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-//        if(token != null){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-//            return token; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-//        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        MultiValueMap<String, String> forms= new LinkedMultiValueMap<String, String>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        forms.put("client_id", Collections.singletonList(clientId)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        forms.put("client_secret", Collections.singletonList(v3ClientSecert)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        forms.put("grant_type", Collections.singletonList("client_credentials")); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String s = HttpUtils.requestXwww(v3TokenUrl, forms); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        //String s = HttpUtils.requestPostForm(tokenUrl, map, null); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【获取总部token】response:{}",s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        JSONObject jsonObject = JSONObject.parseObject(s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String accessToken = jsonObject.getString("access_token"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if(StringUtils.isNotEmpty(accessToken)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            redisUtil.set(Constant.RedisPrefix.TOKEN_GREE_V3, accessToken, 2 * 60 * 60); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        return accessToken; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-*/ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-/** 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     *   获取销司结算标准 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @param jxbh 机型编号,条码前五位 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @param wxxmh 维修项目号 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @param gmrg 购买日期(yyyy-MM-dd) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @param wxlx 维修类型 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @param spid 大类 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     *//* 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public String getRepairSettle(String jxbh,String wxxmh,String gmrg,String wxlx,String spid){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        try { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            Map<String, Object> map = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            map.put("jxbh", jxbh); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            map.put("wxxmh", wxxmh); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            map.put("gmrg", gmrg); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            map.put("wxlx", wxlx); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            map.put("spid", spid); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            map.put("clientid", clientId); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            JSONObject jsonObject = this.post(getRepairSettleUrl, map); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return JSONObject.toJSONString(jsonObject.get("data")); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        }catch(Exception e){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.error("获取销司结算标准失败",e); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return ""; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-*/ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-/** 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     *   批量转结算 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @param ids 多个逗号隔开 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     *//* 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public String doRepairSettle(String ids){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        try { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            Map<String,Object> map = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            map.put("wxjsguids",ids); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            map.put("clientid",clientId); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            JSONObject jsonObject = this.post(doRepairSettleUrl, map); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return JSONObject.toJSONString(jsonObject.get("data")); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        }catch(Exception e){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.error("【对接总部】批量转结算失败",e.getMessage()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        return null; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-*/ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-/** 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * 请求总部接口 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @return*//* 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  public String post(String apiPath,Map<String,Object> bizContent,Integer belongType) throws Exception { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        CommonParam commonParam = new CommonParam(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        commonParam.setAppId(this.getAppId(belongType)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        commonParam.setAppKey(this.getAppKey(belongType)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        commonParam.setAppPath(apiPath); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        commonParam.setJson(JSONObject.toJSONString(bizContent)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        OutAppDefaultReq outAppDefaultReq = commonLogic.supplyParam(commonParam); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        Map<String,String> header = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        header.put("authorization","Bearer "+this.getAccessToken()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        //log.info("accessToken:{}", "Bearer "+this.getAccessToken()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【请求总部接口】request:{}",JSONObject.toJSONString(outAppDefaultReq)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String s = HttpUtils.requestPostBody(apiUrl, JSONObject.toJSONString(outAppDefaultReq), header); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【请求总部接口】response:{}",s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        GreeResponseHelper greeResponseHelper = JSONObject.parseObject(s, GreeResponseHelper.class); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if(greeResponseHelper.getStatus() != 200){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            throw new RemoteServiceException("对接失败总部接口失败:"+greeResponseHelper.getMsg()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        return (String)greeResponseHelper.getData(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public JSONObject post(String url,List param){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    	Map<String, String> header = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        header.put("authorization", "Bearer " + this.getAccessToken()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】request:{}",  JSON.toJSONString(param)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String s = HttpUtils.requestPostBody(url, JSON.toJSONString(param), header); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】response:{}",s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        JSONObject jsonObject = JSONObject.parseObject(s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        Integer statusCode = jsonObject.getInteger("status"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if (statusCode != 200) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.error("接口地址:{},对接总部接口失败",url); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return null; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        return jsonObject; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-*/ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-/** 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * post请求,用3.0的token 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @param url 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @param param 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @return*//* 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public JSONObject postV3(String url,List param){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    	Map<String, String> header = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        header.put("authorization", "Bearer " + this.getAccessTokenV3()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】request:{}",  JSON.toJSONString(param)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String s = HttpUtils.requestPostBody(url, JSON.toJSONString(param), header); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】response:{}",s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        JSONObject jsonObject = JSONObject.parseObject(s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        Integer statusCode = jsonObject.getInteger("status"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if (statusCode != 200) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.error("接口地址:{},对接总部接口失败",url); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return null; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        return jsonObject; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private JSONObject post(String url,Map<String,Object> map){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        Map<String, String> header = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        header.put("authorization", "Bearer " + this.getAccessToken()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】request:{}",JSONObject.toJSONString(map)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String s = HttpUtils.requestPostBody(url, JSONObject.toJSONString(map), header); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】response:{}",s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        JSONObject jsonObject = JSONObject.parseObject(s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        Integer statusCode = jsonObject.getInteger("statusCode"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if (statusCode != 200) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.error("接口地址:{},对接总部接口失败",url); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return null; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        return jsonObject; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public JSONObject postPub(String url,Map<String,Object> map) throws IOException { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    	Map<String, String> header = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        header.put("authorization", "Bearer " + this.getAccessToken()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】request:{}",JSONObject.toJSONString(map)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        JSONObject jsonObject = new JSONObject(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    	String s = HttpUtils.requestPostBodyIO(url, JSONObject.toJSONString(map), header); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】response:{}",s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        jsonObject = JSONObject.parseObject(s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        Integer statusCode = (jsonObject.containsKey("status") && null != jsonObject.get("status") ) ? 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        		jsonObject.getInteger("status") : jsonObject.getInteger("statusCode"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        jsonObject.put("status", statusCode); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if (statusCode != 200) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.error("接口地址:{},对接总部接口失败",url); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        return jsonObject; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public JSONObject postPubV3(String url,Map<String,Object> map) throws IOException { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    	Map<String, String> header = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        header.put("authorization", "Bearer " + this.getAccessTokenV3()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】request:{}",JSONObject.toJSONString(map)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        JSONObject jsonObject = new JSONObject(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    	String s = HttpUtils.requestPostBodyIO(url, JSONObject.toJSONString(map), header); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】response:{}",s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        jsonObject = JSONObject.parseObject(s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        Integer statusCode = (jsonObject.containsKey("status") && null != jsonObject.get("status") ) ? 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        		jsonObject.getInteger("status") : jsonObject.getInteger("statusCode"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        jsonObject.put("status", statusCode); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if (statusCode != 200) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.error("接口地址:{},对接总部接口失败",url); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        return jsonObject; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public Object get(String url,Map<String,String> map) throws JsonMappingException, JsonProcessingException { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    	final String apiPath = v3ApiUrl; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    	Map<String, String> header = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        header.put("authorization", "Bearer " + this.getAccessTokenV3()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】request:{}",JSONObject.toJSONString(map)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-//        String s = HttpUtils.requestPostBody(url, JSONObject.toJSONString(map), header); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String s = HttpUtils.requestGet(apiPath+url, map, header); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】response:{}",s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        ObjectMapper mapper = new ObjectMapper(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-		mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        ResponseExHelper responseHelper = mapper.readValue(s, ResponseExHelper.class); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if(responseHelper.getStatusCode() != 200){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            throw new RemoteServiceException("对接失败总部接口失败:"+responseHelper.getMessage()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        return responseHelper.getData(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public JSONObject getPub(String url,Map<String,String> map) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    	Map<String, String> header = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        header.put("authorization", "Bearer " + this.getAccessToken()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】request:{}",JSONObject.toJSONString(map)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String s = com.gree.settlement.api.utils.HttpUtils.requestGet(url, map, header); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】response:{}",s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        JSONObject jsonObject = JSONObject.parseObject(s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        Integer statusCode = jsonObject.getInteger("status"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if (statusCode != 200) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.error("接口地址:{},对接总部接口失败",url); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return null; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        return jsonObject; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public JSONObject getPubV3(String url,Map<String,String> map) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    	Map<String, String> header = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        header.put("authorization", "Bearer " + this.getAccessTokenV3()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】request:{}",JSONObject.toJSONString(map)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        String s = com.gree.settlement.api.utils.HttpUtils.requestGet(url, map, header); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【总部接口对接】response:{}",s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        JSONObject jsonObject = JSONObject.parseObject(s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        Integer statusCode = jsonObject.getInteger("status"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if (statusCode != 200) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.error("接口地址:{},对接总部接口失败",url); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return null; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        return jsonObject; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-*/ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-/** 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * 同步总部机型名称和单价 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @param outCode 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @param mainNumber*//* 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public void syncProduct(String insideCode,String outCode,String mainNumber,Rule rule){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        try { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            CheckBarcodeBean checkBarcodeBean = null; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            if (StringUtils.isNotEmpty(insideCode)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                String insideShortCode = insideCode.substring(0, 5); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                Integer count = ruleService.lambdaQuery().eq(Rule::getInsideShortCode, insideShortCode).count(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                if(count > 0){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                    return; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                checkBarcodeBean = this.getProductName(insideCode, Integer.parseInt(mainNumber)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                this.saveProduct(mainNumber,insideShortCode,checkBarcodeBean); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            CheckBarcodeBean checkBarcodeBean2 = null; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            if (StringUtils.isNotEmpty(outCode)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                checkBarcodeBean2 = this.getProductName(outCode, Integer.parseInt(mainNumber)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.info("【同步总部机型】,code:{},mainNumber:{},返回结果:{}", insideCode, mainNumber, JSONObject.toJSONString(checkBarcodeBean)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            if ((checkBarcodeBean != null  && mainNumber.equals(Constant.MAIN_NUMBER_101)) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                    || !mainNumber.equals(Constant.MAIN_NUMBER_101)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                //生成新的结算规则 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                if(rule == null) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                   rule = new Rule(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                if (checkBarcodeBean != null) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                    rule.setPrice(checkBarcodeBean.getJsdj()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                    rule.setEnginPrice(checkBarcodeBean.getJsdj()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                    rule.setInsideShortCode(checkBarcodeBean.getJxbh()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                    rule.setInsideName(checkBarcodeBean.getJxmc()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                if (checkBarcodeBean2 != null) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                    if (rule.getPrice() == null || rule.getPrice().doubleValue() == 0) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                        rule.setPrice(checkBarcodeBean2.getJsdj()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                        rule.setEnginPrice(checkBarcodeBean2.getJsdj()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                    rule.setOutShortCode(checkBarcodeBean2.getJxbh()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                    rule.setOutName(checkBarcodeBean2.getJxmc()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                rule.setMainId(Integer.parseInt(mainNumber)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                rule.setMainNumber(mainNumber); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                rule.setInsideCode(insideCode); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                rule.setOutCode(outCode); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                rule.setCreateTime(new Date()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                if(rule.getStlRuleId() != null){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                    rule.updateById(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                }else { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                    rule.insert(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        }catch(Exception e){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.error("同步总部机型失败",e.getMessage()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public void saveProduct(String mainNumber,String insideShortCode,CheckBarcodeBean checkBarcodeBean){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if(StringUtils.isEmpty(mainNumber) || !mainNumber.equals(Constant.MAIN_NUMBER_101)){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        Integer count = productService.lambdaQuery().eq(Product::getProductCode, insideShortCode).count(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if(count > 0){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        Product product = new Product(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        product.setMainNumber(mainNumber); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        //product.setMainName(checkBarcodeBean.get); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        product.setMaterialCode(checkBarcodeBean.getZjdm()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        product.setMaterialName(checkBarcodeBean.getZjmc()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        product.setNwbs("内机"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        product.setPrice(checkBarcodeBean.getJsdj()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        product.setProductCode(insideShortCode); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        product.setCreateTime(new Date()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        product.insert(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public void initProduct(){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【初始化套机数据】开始:"+ new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        List<Rule> list = ruleService.lambdaQuery().ne(Rule::getInsideShortCode, "").eq(Rule::getMainNumber,Constant.MAIN_NUMBER_101).list(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        for(Rule rule : list){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            CheckBarcodeBean checkBarcodeBean = this.getProductName(rule.getInsideCode(), Integer.parseInt(rule.getMainNumber())); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            if(checkBarcodeBean == null){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                continue; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            this.saveProduct(Constant.MAIN_NUMBER_101,rule.getInsideShortCode(),checkBarcodeBean); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【初始化套机数据】结束:"+ new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-*/ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-/** 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * 初始化机型名称*//* 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public void init(){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        List<ProductNew> list = productNewService.list(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        for(ProductNew productNew : list){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            String mainNumber = productNew.getMainNumber(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            String insideCode = productNew.getInsideCode(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            CheckBarcodeBean checkBarcodeBean = this.getProductName(insideCode, Integer.parseInt(mainNumber)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            if(checkBarcodeBean == null){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                productNew.setRemark("调取总部接口获取机型失败"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                continue; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            BeanUtils.copyProperties(checkBarcodeBean,productNew); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            productNew.setProductName(checkBarcodeBean.getJxmc()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            productNew.setPrice(checkBarcodeBean.getJsdj()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        productNewService.updateBatchById(list); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-*/ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-/** 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * 请求总部接口 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @return*//* 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public GreeResponseHelper greePost(String apiPath,Map<String,Object> bizContent,Integer belongType) throws Exception { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        CommonParam commonParam = new CommonParam(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        commonParam.setAppId(this.getAppId(belongType)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        commonParam.setAppKey(this.getAppKey(belongType)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        commonParam.setAppPath(apiPath); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        commonParam.setJson(JSONObject.toJSONString(bizContent)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        OutAppDefaultReq outAppDefaultReq = commonLogic.supplyParam(commonParam); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        Map<String,String> header = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        header.put("authorization","Bearer "+this.getAccessToken()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【请求总部接口】request:{}",JSONObject.toJSONString(outAppDefaultReq)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-//        String s = HttpUtils.post(apiUrl, JSONObject.toJSONString(outAppDefaultReq), header); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        // 设置请求头 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        HttpHeaders headers = new HttpHeaders(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        headers.setContentType(MediaType.APPLICATION_JSON); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        for(String str : header.keySet()){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            headers.set(str,header.get(str)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        RestTemplate restTemplate = new RestTemplate(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        HttpEntity<String> httpEntity = new HttpEntity<>(JSONObject.toJSONString(outAppDefaultReq), headers); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        //获取返回数据 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        try { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            String body = restTemplate.postForObject(apiUrl, httpEntity, String.class); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.info("【请求总部接口】response:{}",body); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return JSONObject.parseObject(body, GreeResponseHelper.class); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        }catch(HttpStatusCodeException ex) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        	log.error("rawStatusCode = {}",ex.getRawStatusCode()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        	GreeResponseHelper greeResponseHelper = new GreeResponseHelper(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        	greeResponseHelper.setStatus(ex.getRawStatusCode()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-//        	greeResponseHelper.setMsg(GreeResponseCodeEnum.valueOf(ex.getRawStatusCode())); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        	greeResponseHelper.setMsg(ex.getMessage().substring(0,100)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        	ex.printStackTrace(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        	return greeResponseHelper; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        }catch(Exception e){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        	GreeResponseHelper greeResponseHelper = new GreeResponseHelper(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        	greeResponseHelper.setStatus(ResponseHelper.ResponseCode_COMMON); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        	greeResponseHelper.setMsg("非法请求"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        	e.printStackTrace(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        	return greeResponseHelper; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-*/ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-/** 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * 请求总部接口 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-     * @return*//* 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    public GreeResponseHelper greePostDecryptFeed(String apiPath, DecryptFeedbackBean bean) throws Exception { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        Map<String,String> header = new HashMap<>(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        header.put("authorization","Bearer "+this.getAccessToken()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        // 设置请求头 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        HttpHeaders headers = new HttpHeaders(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        headers.setContentType(MediaType.APPLICATION_JSON); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        for(String str : header.keySet()){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            headers.set(str,header.get(str)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        RestTemplate restTemplate = new RestTemplate(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        HttpEntity<String> httpEntity = new HttpEntity<>(JSONObject.toJSONString(bean), headers); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        log.info("【请求总部接口】request:{}",JSONObject.toJSONString(bean)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        //获取返回数据 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        try { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            String body = restTemplate.postForObject(apiUrlFeedBack+apiPath, httpEntity, String.class); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.info("【请求总部接口】response:{}",body); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return JSONObject.parseObject(body, GreeResponseHelper.class); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        }catch(HttpStatusCodeException ex) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            log.error("rawStatusCode = {}",ex.getRawStatusCode()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            GreeResponseHelper greeResponseHelper = new GreeResponseHelper(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            greeResponseHelper.setStatus(ex.getRawStatusCode()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            greeResponseHelper.setMsg(ex.getMessage().substring(0,100)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            ex.printStackTrace(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return greeResponseHelper; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        }catch(Exception e){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            GreeResponseHelper greeResponseHelper = new GreeResponseHelper(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            greeResponseHelper.setStatus(ResponseHelper.ResponseCode_COMMON); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            greeResponseHelper.setMsg("非法请求"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            e.printStackTrace(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            return greeResponseHelper; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-} 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-*/ 
			 |