|
@@ -10,9 +10,9 @@ import com.huimv.eartag2.common.utils.DateUtil;
|
|
|
import com.huimv.eartag2.eartag.service.ICacheService;
|
|
|
import com.huimv.eartag2.eartag.service.IDeviceService;
|
|
|
import com.huimv.eartag2.eartag.service.IEartagService;
|
|
|
-import com.huimv.eartag2.manage2.mapper.EartagData2Mapper;
|
|
|
-import com.huimv.eartag2.manage2.pojo.EartagData2;
|
|
|
-import com.huimv.eartag2.manage2.service.IEartagData2Service;
|
|
|
+//import com.huimv.eartag2.manage2.mapper.EartagData2Mapper;
|
|
|
+//import com.huimv.eartag2.manage2.pojo.EartagData2;
|
|
|
+//import com.huimv.eartag2.manage2.service.IEartagData2Service;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.data.redis.core.RedisTemplate;
|
|
@@ -39,11 +39,10 @@ import java.util.Map;
|
|
|
@Service
|
|
|
@Slf4j
|
|
|
public class EartagServiceImpl implements IEartagService {
|
|
|
- @Resource
|
|
|
- private IEartagData2Service eartagData2Service;
|
|
|
-
|
|
|
- @Resource
|
|
|
- private EartagData2Mapper eartagData2Mapper;
|
|
|
+// @Resource
|
|
|
+// private IEartagData2Service eartagData2Service;
|
|
|
+// @Resource
|
|
|
+// private EartagData2Mapper eartagData2Mapper;
|
|
|
@Autowired
|
|
|
private RedisTemplate redisTemplate;
|
|
|
@Autowired
|
|
@@ -653,53 +652,53 @@ public class EartagServiceImpl implements IEartagService {
|
|
|
DateUtil dateUtil = new DateUtil();
|
|
|
//判断近五分钟内是否有耳标数据 先获取耳标号
|
|
|
String earmark = eartagJo.getString("earmark");
|
|
|
- List<EartagData2> eartagFlowByEarmark = eartagData2Service.getEartagData(earmark);
|
|
|
- if (null == eartagFlowByEarmark ||eartagFlowByEarmark.size() == 0 ){
|
|
|
- //插数据到数据库里
|
|
|
- EartagData2 dataEntity2 = new EartagData2();
|
|
|
- dataEntity2.setCmdHeader(eartagJo.getString("cmdHeader"));
|
|
|
- dataEntity2.setDevice(eartagJo.getString("device"));
|
|
|
- dataEntity2.setEarmark(eartagJo.getString("earmark"));
|
|
|
- dataEntity2.setBat(Integer.parseInt(eartagJo.getString("bat")));
|
|
|
- dataEntity2.setEarTemp(Integer.parseInt(eartagJo.getString("earTemp")));
|
|
|
- dataEntity2.setEarTemp1(eartagJo.getFloat("earTemp1"));
|
|
|
- dataEntity2.setEnvTemp(Integer.parseInt(eartagJo.getString("envTemp")));
|
|
|
- dataEntity2.setEnvTemp1(eartagJo.getFloat("envTemp1"));
|
|
|
- dataEntity2.setAct(Integer.parseInt(eartagJo.getString("act")));
|
|
|
- dataEntity2.setAct1(Integer.parseInt(eartagJo.getString("act1")));
|
|
|
- dataEntity2.setSignal1(Integer.parseInt(eartagJo.getString("signal")));
|
|
|
- Date date = Convert.toDate(getAskTime(eartagJo.getString("askTime")));
|
|
|
- Date date1 = new Date();
|
|
|
- Timestamp timestamp = new Timestamp(date1.getTime());
|
|
|
- dataEntity2.setAskTime(timestamp);
|
|
|
- dataEntity2.setOther(eartagJo.getString("other"));
|
|
|
- dataEntity2.setAddTime(nowTimestamp);
|
|
|
- dataEntity2.setCreateDate(todayDate);
|
|
|
- dataEntity2.setFarmId(farmId);
|
|
|
- dataEntity2.setAskDate(new java.sql.Date(dateUtil.parseDate(getAskDate(eartagJo.getString("askTime"))).getTime()));
|
|
|
- eartagData2Mapper.insert(dataEntity2);
|
|
|
- }else {
|
|
|
- EartagData2 eartagData2 = eartagFlowByEarmark.get(0);
|
|
|
- eartagData2.setCmdHeader(eartagJo.getString("cmdHeader"));
|
|
|
- eartagData2.setDevice(eartagJo.getString("device"));
|
|
|
- eartagData2.setEarmark(eartagJo.getString("earmark"));
|
|
|
- eartagData2.setBat(Integer.parseInt(eartagJo.getString("bat")));
|
|
|
- eartagData2.setEarTemp(Integer.parseInt(eartagJo.getString("earTemp")));
|
|
|
- eartagData2.setEarTemp1(eartagJo.getFloat("earTemp1"));
|
|
|
- eartagData2.setEnvTemp(Integer.parseInt(eartagJo.getString("envTemp")));
|
|
|
- eartagData2.setEnvTemp1(eartagJo.getFloat("envTemp1"));
|
|
|
- eartagData2.setAct(Integer.parseInt(eartagJo.getString("act")));
|
|
|
- eartagData2.setAct1(Integer.parseInt(eartagJo.getString("act1")));
|
|
|
- eartagData2.setSignal1(Integer.parseInt(eartagJo.getString("signal")));
|
|
|
- Date date = Convert.toDate(getAskTime(eartagJo.getString("askTime")));
|
|
|
- Timestamp timestamp = new Timestamp(date.getTime());
|
|
|
- eartagData2.setAskTime(timestamp);
|
|
|
- eartagData2.setOther(eartagJo.getString("other"));
|
|
|
- eartagData2.setCreateDate(todayDate);
|
|
|
- eartagData2.setFarmId(farmId);
|
|
|
- eartagData2.setAskDate(new java.sql.Date(dateUtil.parseDate(getAskDate(eartagJo.getString("askTime"))).getTime()));
|
|
|
- eartagData2Mapper.updateById(eartagData2);
|
|
|
- }
|
|
|
+// List<EartagData2> eartagFlowByEarmark = eartagData2Service.getEartagData(earmark);
|
|
|
+// if (null == eartagFlowByEarmark ||eartagFlowByEarmark.size() == 0 ){
|
|
|
+// //插数据到数据库里
|
|
|
+// EartagData2 dataEntity2 = new EartagData2();
|
|
|
+// dataEntity2.setCmdHeader(eartagJo.getString("cmdHeader"));
|
|
|
+// dataEntity2.setDevice(eartagJo.getString("device"));
|
|
|
+// dataEntity2.setEarmark(eartagJo.getString("earmark"));
|
|
|
+// dataEntity2.setBat(Integer.parseInt(eartagJo.getString("bat")));
|
|
|
+// dataEntity2.setEarTemp(Integer.parseInt(eartagJo.getString("earTemp")));
|
|
|
+// dataEntity2.setEarTemp1(eartagJo.getFloat("earTemp1"));
|
|
|
+// dataEntity2.setEnvTemp(Integer.parseInt(eartagJo.getString("envTemp")));
|
|
|
+// dataEntity2.setEnvTemp1(eartagJo.getFloat("envTemp1"));
|
|
|
+// dataEntity2.setAct(Integer.parseInt(eartagJo.getString("act")));
|
|
|
+// dataEntity2.setAct1(Integer.parseInt(eartagJo.getString("act1")));
|
|
|
+// dataEntity2.setSignal1(Integer.parseInt(eartagJo.getString("signal")));
|
|
|
+// Date date = Convert.toDate(getAskTime(eartagJo.getString("askTime")));
|
|
|
+// Date date1 = new Date();
|
|
|
+// Timestamp timestamp = new Timestamp(date1.getTime());
|
|
|
+// dataEntity2.setAskTime(timestamp);
|
|
|
+// dataEntity2.setOther(eartagJo.getString("other"));
|
|
|
+// dataEntity2.setAddTime(nowTimestamp);
|
|
|
+// dataEntity2.setCreateDate(todayDate);
|
|
|
+// dataEntity2.setFarmId(farmId);
|
|
|
+// dataEntity2.setAskDate(new java.sql.Date(dateUtil.parseDate(getAskDate(eartagJo.getString("askTime"))).getTime()));
|
|
|
+// eartagData2Mapper.insert(dataEntity2);
|
|
|
+// }else {
|
|
|
+// EartagData2 eartagData2 = eartagFlowByEarmark.get(0);
|
|
|
+// eartagData2.setCmdHeader(eartagJo.getString("cmdHeader"));
|
|
|
+// eartagData2.setDevice(eartagJo.getString("device"));
|
|
|
+// eartagData2.setEarmark(eartagJo.getString("earmark"));
|
|
|
+// eartagData2.setBat(Integer.parseInt(eartagJo.getString("bat")));
|
|
|
+// eartagData2.setEarTemp(Integer.parseInt(eartagJo.getString("earTemp")));
|
|
|
+// eartagData2.setEarTemp1(eartagJo.getFloat("earTemp1"));
|
|
|
+// eartagData2.setEnvTemp(Integer.parseInt(eartagJo.getString("envTemp")));
|
|
|
+// eartagData2.setEnvTemp1(eartagJo.getFloat("envTemp1"));
|
|
|
+// eartagData2.setAct(Integer.parseInt(eartagJo.getString("act")));
|
|
|
+// eartagData2.setAct1(Integer.parseInt(eartagJo.getString("act1")));
|
|
|
+// eartagData2.setSignal1(Integer.parseInt(eartagJo.getString("signal")));
|
|
|
+// Date date = Convert.toDate(getAskTime(eartagJo.getString("askTime")));
|
|
|
+// Timestamp timestamp = new Timestamp(date.getTime());
|
|
|
+// eartagData2.setAskTime(timestamp);
|
|
|
+// eartagData2.setOther(eartagJo.getString("other"));
|
|
|
+// eartagData2.setCreateDate(todayDate);
|
|
|
+// eartagData2.setFarmId(farmId);
|
|
|
+// eartagData2.setAskDate(new java.sql.Date(dateUtil.parseDate(getAskDate(eartagJo.getString("askTime"))).getTime()));
|
|
|
+// eartagData2Mapper.updateById(eartagData2);
|
|
|
+// }
|
|
|
}
|
|
|
|
|
|
//
|