Authored by mali

上链迁移

1 -package com.yoho.ufo.service.impl;  
2 -  
3 -import org.springframework.stereotype.Service;  
4 -  
5 -/**  
6 - * Created by li.ma on 2020/3/31.  
7 - */  
8 -@Service  
9 -public class ProductChainService {  
10 -  
11 -}  
1 package com.yoho.ufo.controller.nfc; 1 package com.yoho.ufo.controller.nfc;
2 2
3 -import com.yoho.product.model.ProductInfo;  
4 -import com.yoho.ufo.exception.PlatformException;  
5 -import com.yoho.ufo.service.INFCService;  
6 -import com.yoho.ufo.service.impl.ProductChainService;  
7 import com.yoho.ufo.service.model.ApiResponse; 3 import com.yoho.ufo.service.model.ApiResponse;
8 import com.yohobuy.ufo.model.request.nfc.ProductInfoReq; 4 import com.yohobuy.ufo.model.request.nfc.ProductInfoReq;
9 -import com.yohobuy.ufo.model.request.nfc.UfoNFCRequestBo;  
10 import org.slf4j.Logger; 5 import org.slf4j.Logger;
11 import org.slf4j.LoggerFactory; 6 import org.slf4j.LoggerFactory;
12 import org.springframework.beans.factory.annotation.Autowired; 7 import org.springframework.beans.factory.annotation.Autowired;
@@ -161,9 +161,12 @@ public class ProductChainService { @@ -161,9 +161,12 @@ public class ProductChainService {
161 return productChainMapper.updateTransactionId(tagId, transaction_id); 161 return productChainMapper.updateTransactionId(tagId, transaction_id);
162 } 162 }
163 163
  164 +
164 // 同步上链的数据 165 // 同步上链的数据
165 public void addItem(ProductInfoReq bo) { 166 public void addItem(ProductInfoReq bo) {
  167 +
166 Long generateid = generateid(); 168 Long generateid = generateid();
  169 +
167 logger.info("generateid is : " , generateid); 170 logger.info("generateid is : " , generateid);
168 171
169 updatechainSql(bo.getTagid(), generateid, null, Integer.valueOf(bo.getTransaction_time())); 172 updatechainSql(bo.getTagid(), generateid, null, Integer.valueOf(bo.getTransaction_time()));
1 package com.yoho.ufo.service.scheduled; 1 package com.yoho.ufo.service.scheduled;
2 2
3 -import com.yoho.product.model.ProductChain;  
4 import com.yoho.product.model.ProductInfo; 3 import com.yoho.product.model.ProductInfo;
5 import com.yoho.quartz.annotation.JobType; 4 import com.yoho.quartz.annotation.JobType;
6 import com.yoho.quartz.annotation.MisfiredPolicy; 5 import com.yoho.quartz.annotation.MisfiredPolicy;
@@ -8,7 +7,6 @@ import com.yoho.quartz.annotation.YhJobDef; @@ -8,7 +7,6 @@ import com.yoho.quartz.annotation.YhJobDef;
8 import com.yoho.quartz.domain.JobProcessResult; 7 import com.yoho.quartz.domain.JobProcessResult;
9 import com.yoho.quartz.domain.JobResultCode; 8 import com.yoho.quartz.domain.JobResultCode;
10 import com.yoho.quartz.job.YhJob; 9 import com.yoho.quartz.job.YhJob;
11 -import com.yoho.ufo.service.impl.ProductChainService;  
12 import org.slf4j.Logger; 10 import org.slf4j.Logger;
13 import org.slf4j.LoggerFactory; 11 import org.slf4j.LoggerFactory;
14 import org.springframework.beans.factory.annotation.Autowired; 12 import org.springframework.beans.factory.annotation.Autowired;
@@ -7,7 +7,6 @@ import com.yoho.quartz.annotation.YhJobDef; @@ -7,7 +7,6 @@ import com.yoho.quartz.annotation.YhJobDef;
7 import com.yoho.quartz.domain.JobProcessResult; 7 import com.yoho.quartz.domain.JobProcessResult;
8 import com.yoho.quartz.domain.JobResultCode; 8 import com.yoho.quartz.domain.JobResultCode;
9 import com.yoho.quartz.job.YhJob; 9 import com.yoho.quartz.job.YhJob;
10 -import com.yoho.ufo.service.impl.ProductChainService;  
11 import org.slf4j.Logger; 10 import org.slf4j.Logger;
12 import org.slf4j.LoggerFactory; 11 import org.slf4j.LoggerFactory;
13 import org.springframework.beans.factory.annotation.Autowired; 12 import org.springframework.beans.factory.annotation.Autowired;
@@ -28,6 +28,7 @@ @@ -28,6 +28,7 @@
28 <value>queryBatchProductStorageCount</value> 28 <value>queryBatchProductStorageCount</value>
29 <value>getBaseSortsById</value> 29 <value>getBaseSortsById</value>
30 <value>getBrandSeriesByIds</value> 30 <value>getBrandSeriesByIds</value>
  31 + <value>addItem</value>
31 </list> 32 </list>
32 </property> 33 </property>
33 </bean> 34 </bean>