项目：pugtsdb
文件：RollUpAggregationSteps.java
private void insertPoint(Timestamp timestamp,Object value) throws Throwable {
String sql = sourceGranularity == null
? " INSERT INTO point (\"metric_id\",\"timestamp\",\"value\") VALUES (?,?,?) "
: " INSERT INTO point_" + sourceGranularity + " (\"metric_id\",\"value\",\"aggregation\") VALUES (?,?) ";
try (Connection connection = pugTSDB.getDataSource().getConnection();
PreparedStatement statement = connection.prepareStatement(sql)) {
statement.setInt(1,metric.getId());
statement.setTimestamp(2,timestamp);
statement.setBytes(3,metric.valuetoBytes(value));
if (sourceGranularity != null) {
statement.setString(4,aggregation.getName());
}
statement.execute();
}
}
项目：filter-sort-jooq-api
文件：TransferTimingPageRepositoryImplPureJooq.java
private static TransferTimingListingDTO recordToDto(Record16<Long,Integer,String,Byte,Timestamp,Long> r) {
// You can do your mapping manually or use jooq methods like "into" etc
return new TransferTimingListingDTO(
r.get(TRANSFER_TIMING_FILE_TRANSITION_HISTORY_ID,Long.class),r.get("fileId",r.get("atableId",r.get("atableName",String.class),r.get(USER.USERNAME,r.get(FILE.CODE,r.get("fileTypeName",r.get(TRANSFER_TIMING_VISUAL_COUNT,Integer.class),r.get(TRANSFER_TIMING_SOMETHING_COUNT,r.get(field("fromStatus"),r.get(field("toStatus"),r.get(FILE_TRANSITION_HISTORY.LOCATION_IPV4,r.get(TRANSFER_TIMING_TRANSFER_STATUS,Boolean.class),// Set zone to specific one if you are not using UTC (you should)
r.get(TRANSFER_TIMING_TRANSFER_STARTED_AT).toLocalDateTime().atZone(DATABASE_TIMEZONE),r.get(TRANSFER_TIMING_TRANSFER_ENDED_AT).toLocalDateTime().atZone(DATABASE_TIMEZONE),r.get(TRANSFER_TIMING_TRANSFER_TIME_SPENT_IN_SECONDS,Long.class)
);
}
@Test
public void testExecuteBatchFilter() throws Exception {
truncateTable("product");
Timestamp currentDatetime = Timestamp.valueOf("2005-12-12 10:10:10.000000000");
List<String> log = TestAppender.getLogbackLogs(() -> {
sqlContext ctx = agent.contextFrom("example/insert_product").setsqlId("333")
.param("product_id",new BigDecimal(1)).param("product_name","商品名1")
.param("product_kana_name","ショウヒンメイイチ").param("jan_code","1234567890123")
.param("product_description","1番目の商品").param("ins_datetime",currentDatetime)
.param("upd_datetime",currentDatetime).param("version_no",new BigDecimal(0)).addBatch()
.param("product_id",new BigDecimal(2)).param("product_name","商品名2")
.param("product_kana_name","ショウヒンメイニ").param("jan_code","1234567890124")
.param("product_description","2番目の商品").param("ins_datetime",new BigDecimal(0))
.param("_userName","testUserName").param("_funcId","testFunction").addBatch();
agent.batch(ctx);
});
assertthat(log,is(Files.readAllLines(
Paths.get("src/test/resources/data/expected/DebugsqlFilter","testExecuteBatchFilter.txt"),StandardCharsets.UTF_8)));
}
项目：jshERP
文件：AssetNameAction.java
/**
* 删除资产名称
* @return
*/
public String delete()
{
Log.infoFileSync("====================开始调用删除资产名称信息方法delete()================");
try
{
assetnameService.delete(model.getAssetNameID());
tipMsg = "成功";
tipType = 0;
}
catch (DataAccessException e)
{
Log.errorFileSync(">>>>>>>>>>>删除ID为 " + model.getAssetNameID() + " 的资产名称异常",e);
tipMsg = "失败";
tipType = 1;
}
model.getShowModel().setMsgTip(tipMsg);
logService.create(new Logdetails(getUser(),"删除资产名称",model.getClientIp(),new Timestamp(System.currentTimeMillis()),tipType,"删除资产名称ID为 "+ model.getAssetNameID() + " " + tipMsg + "！","删除资产名称" + tipMsg));
Log.infoFileSync("====================结束调用删除资产名称信息方法delete()================");
return SUCCESS;
}
/**
* Initializes the default set of extractors
* @return the defailt set of extractors
*/
private static Map<Class<?>,sqlExtractor> extractors() {
if (!initialized) {
extractorMap.put(boolean.class,new BooleanExtractor());
extractorMap.put(int.class,new IntegerExtractor());
extractorMap.put(long.class,new LongExtractor());
extractorMap.put(double.class,new DoubleExtractor());
extractorMap.put(Boolean.class,new BooleanExtractor());
extractorMap.put(Integer.class,new IntegerExtractor());
extractorMap.put(Long.class,new LongExtractor());
extractorMap.put(Double.class,new DoubleExtractor());
extractorMap.put(String.class,new StringExtractor());
extractorMap.put(java.util.Date.class,new DateExtractor());
extractorMap.put(java.sql.Date.class,new DateExtractor());
extractorMap.put(java.sql.Time.class,new TimeExtractor());
extractorMap.put(Timestamp.class,new TimestampExtractor());
extractorMap.put(LocalDate.class,new LocalDateExtractor());
extractorMap.put(LocalTime.class,new LocalTimeExtractor());
extractorMap.put(LocalDateTime.class,new LocalDateTimeExtractor());
initialized = true;
}
return extractorMap;
}
项目：jshERP
文件：DepotHeadAction.java
/**
* 删除单据
* @return
*/
public String delete() {
Log.infoFileSync("====================开始调用删除单据信息方法delete()================");
try {
depotHeadService.delete(model.getDepotHeadID());
tipMsg = "成功";
tipType = 0;
}
catch (DataAccessException e) {
Log.errorFileSync(">>>>>>>>>>>删除ID为 " + model.getDepotHeadID() + " 的单据异常",e);
tipMsg = "失败";
tipType = 1;
}
model.getShowModel().setMsgTip(tipMsg);
logService.create(new Logdetails(getUser(),"删除单据","删除单据ID为 "+ model.getDepotHeadID() + " " + tipMsg + "！","删除单据" + tipMsg));
Log.infoFileSync("====================结束调用删除单据信息方法delete()================");
return SUCCESS;
}
项目：JBA
文件：PingCommand.java
@Override
public void onCommand(User sender,MessageChannel channel,Message message,String[] args,Member member) {
// Get the time since the message sent by the user was created.
long pongTime = message.getCreationTime().until(zoneddatetime.Now(),ChronoUnit.MILLIS);
channel.sendMessage("Pong! `" + pongTime + "ms`").queue();
try {
sqlController.runsqlTask(conn -> {
PreparedStatement statement = conn.prepareStatement("INSERT INTO pings (time_pinged,response_time) VALUES (?,?)");
statement.setTimestamp(1,Timestamp.valueOf(LocalDateTime.Now()));
statement.setLong(2,pongTime);
statement.execute();
});
} catch (sqlException e) {
ExampleBot.LOGGER.error("There was an error inserting into the MysqL table.",e);
}
}
public void testAppendWithTimestamp() throws Exception {
// Create a table with data in it; import it.
// Then add more data,verify that only the incremental data is pulled.
final String TABLE_NAME = "appendTimestamp";
Timestamp thePast = new Timestamp(System.currentTimeMillis() - 100);
createTimestampTable(TABLE_NAME,10,thePast);
List<String> args = getArgListForTable(TABLE_NAME,false,false);
args.add("--append");
createJob(TABLE_NAME,args);
runJob(TABLE_NAME);
assertDirOfNumbers(TABLE_NAME,10);
// Add some more rows.
long importWasBefore = System.currentTimeMillis();
Thread.sleep(50);
long rowsAddedTime = System.currentTimeMillis() - 5;
assertTrue(rowsAddedTime > importWasBefore);
assertTrue(rowsAddedTime < System.currentTimeMillis());
insertIdTimestampRows(TABLE_NAME,20,new Timestamp(rowsAddedTime));
// Import only those rows.
runJob(TABLE_NAME);
assertDirOfNumbers(TABLE_NAME,20);
}
项目：BibliotecaPS
文件：StatementRegressionTest.java
/**
* Tests fix for BUG#54095 - Unnecessary call in newSetTimestampInternal.
*
* This bug was fixed as a consequence of the patch for Bug#71084.
*
* @throws Exception
* if the test fails.
*/
public void testBug54095() throws Exception {
Connection testConn = getConnectionWithProps("useLegacyDatetimeCode=false");
Calendar testCal = Calendar.getInstance();
java.util.Date origDate = testCal.getTime();
PreparedStatement testPstmt = testConn.prepareStatement("SELECT ?");
testPstmt.setTimestamp(1,new Timestamp(0),testCal);
assertEquals("Calendar object shouldn't have changed after PreparedStatement.setTimestamp().",origDate,testCal.getTime());
ResultSet testRs = testPstmt.executeQuery();
testRs.next();
assertEquals("Calendar object shouldn't have changed after PreparedStatement.executeQuery().",testCal.getTime());
testRs.getTimestamp(1,testCal);
assertEquals("Calendar object shouldn't have changed after ResultSet.getTimestamp().",testCal.getTime());
testRs.close();
testPstmt.close();
testConn.close();
}
项目：webpoll
文件：SurveyAnsweringModelBuilder.java
private static SurveyEntity buildSurvey(UserEntity owner,List<QuestionEntity> questionEntities) {
SurveyEntity survey = new SurveyEntity();
survey.setName("Testundersøkelse");
survey.setCode("testabc");
survey.setId(1);
survey.setDateCreated(new Timestamp(System.currentTimeMillis()));
survey.setDeadline(new Timestamp(System.currentTimeMillis() + 36000));
survey.setQuestions(questionEntities);
survey.setowner(owner);
for (QuestionEntity q : questionEntities) {
q.setSurvey(survey);
}
return survey;
}
@Override
public Userlogin insertLogin(Userinfo userinfo) throws Exception{
String user_email = userinfo.getUser_email();
String user_password = userinfo.getUser_password();
Map userinfoMap = new HashMap<>();
userinfoMap.put("user_email",user_email);
userinfoMap.put("user_password",user_password);
List<Userinfo> loginUserInfo = userinfoDaoImpl.loginUserInfo(userinfoMap);
//设置登陆的id
long token_id = sNowflakeIdUtil.nextId();
//放到数据库中
Userlogin userlogin = new Userlogin();
userlogin.setToken_id("#"+String.valueOf(token_id));
userlogin.setUser_id(loginUserInfo.get(0).getUser_id());
userlogin.setUser_login_time(String.valueOf( new Timestamp( (new Date()).getTime()) ));
userloginDaoImpl.insertUserlogin(userlogin);
userlogin.setToken_id(String.valueOf(token_id));
return userlogin;
}
项目：jshERP
文件：InOutItemAction.java
/**
* 删除收支项目
* @return
*/
public String delete()
{
Log.infoFileSync("====================开始调用删除收支项目信息方法delete()================");
try
{
inOutItemService.delete(model.getInOutItemID());
tipMsg = "成功";
tipType = 0;
}
catch (DataAccessException e)
{
Log.errorFileSync(">>>>>>>>>>>删除ID为 " + model.getInOutItemID() + " 的收支项目异常","删除收支项目","删除收支项目ID为 "+ model.getInOutItemID() + ",名称为 " + model.getName() + tipMsg + "！","删除收支项目" + tipMsg));
Log.infoFileSync("====================结束调用删除收支项目信息方法delete()================");
return SUCCESS;
}
项目：microservices-sample-project
文件：EmailVerification.java
public EmailVerification calculateExpiryDate() {
Calendar cal = Calendar.getInstance();
cal.setTime(new Timestamp(cal.getTime().getTime()));
cal.add(Calendar.MINUTE,EXPIRATION);
this.expiryDate = new Date(cal.getTime().getTime());
return this;
}
项目：Lucid2.0
文件：MapleClient.java
public final Timestamp getCreated() {
Connection con = DatabaseConnection.getConnection();
try {
PreparedStatement ps;
ps = con.prepareStatement("SELECT createdat FROM accounts WHERE id = ?");
ps.setInt(1,getAccID());
Timestamp ret;
try (ResultSet rs = ps.executeQuery()) {
if (!rs.next()) {
rs.close();
ps.close();
return null;
}
ret = rs.getTimestamp("createdat");
}
ps.close();
return ret;
} catch (sqlException e) {
throw new DatabaseException("error getting create",e);
}
}
项目：DBus
文件：MaDefaultHandler.java
private MetaWrapper buildMeta(MessageEntry msgEntry) {
MetaWrapper MetaWrapper = new MetaWrapper();
EntryHeader header = msgEntry.getEntryHeader();
RowData rowData = msgEntry.getMsgColumn().getRowDataLst().get(0);
List<Column> columns = Support.getFinalColumns(header.getoperType(),rowData);
for (Column column : columns) {
MetaWrapper.MetaCell cell = new MetaWrapper.MetaCell();
cell.setColumnName(column.getName());
cell.setDataType(Support.getColumnType(column));
int[] ret = Support.getColumnLengthAndPrecision(column);
cell.setDataLength(ret[0]);
cell.setDataPrecision(ret[1]);
cell.setDataScale(0);
cell.setIsPk(column.getIsKey() ? "Y" : "N");
cell.setNullAble("N");
cell.setDdlTime(new Timestamp(header.getExecuteTime()));
cell.setColumnId(column.getIndex());
cell.setInternalColumnId(column.getIndex());
cell.setHiddenColumn("NO");
cell.setVirtualColumn("NO");
MetaWrapper.addMetaCell(cell);
}
return MetaWrapper;
}
项目：ctsms
文件：JournalServiceImpl.java
@Override
protected JournalExcelVO handleExportEcrfJournal(AuthenticationVO auth,Long trialId) throws Exception {
JournalExcelWriter writer = new JournalExcelWriter(JournalModule.ECRF_JOURNAL,!CoreUtil.isPassDecryption());
Trial trial = CheckIDUtil.checkTrialId(trialId,this.getTrialDao());
writer.setTrial(this.getTrialDao().toTrialOutVO(trial));
Pattern ecrfJournalEntryTitleRegExp = Settings.getRegexp(SettingCodes.ECRF_JOURNAL_ENTRY_TITLE_REGEXP,Bundle.SETTINGS,DefaultSettings.ECRF_JOURNAL_ENTRY_TITLE_REGEXP);
JournalEntryDao journalEntryDao = this.getJournalEntryDao();
Collection<JournalEntry> journalEntries = journalEntryDao.findEcrfJournal(trialId);
ArrayList<JournalEntryOutVO> journalEntryVOs = new ArrayList<JournalEntryOutVO>(journalEntries.size());
Iterator<JournalEntry> journalEntriesIt = journalEntries.iterator();
while (journalEntriesIt.hasNext()) {
JournalEntryOutVO journalEntryVO = journalEntryDao.toJournalEntryOutVO(journalEntriesIt.next());
if (journalEntryVO.isDecrypted()
&& (journalEntryVO.getInputField() != null
|| (journalEntryVO.getTrial() != null && ecrfJournalEntryTitleRegExp != null && ecrfJournalEntryTitleRegExp.matcher(journalEntryVO.getTitle()).find()))) {
if (CommonUtil.HTML_SYstem_MESSAGES_COMMENTS) {
journalEntryVO.setComment(diff_match_patch.prettyHtmlToUnicode(journalEntryVO.getComment()));
}
journalEntryVOs.add(journalEntryVO);
}
}
writer.setVOs(journalEntryVOs);
User modified = CoreUtil.getUser();
writer.getExcelVO().setRequestingUser(this.getUserDao().toUserOutVO(modified));
(new ExcelExporter(writer,writer)).write();
JournalExcelVO result = writer.getExcelVO();
Timestamp Now = CommonUtil.datetoTimestamp(result.getContentTimestamp());
logSystemMessage(trial,writer.getTrial(),Now,modified,SystemMessageCodes.ECRF_JOURNAL_EXPORTED,result,null,journalEntryDao);
return result;
}
项目：openjdk-jdk10
文件：TimestampTests.java
@Test
public void test11() {
Timestamp ts1 = Timestamp.valueOf("1996-12-10 12:26:19.12");
Timestamp ts2 = Timestamp.valueOf("1996-12-10 12:26:19.12");
Timestamp ts3 = Timestamp.valueOf("1996-12-11 12:24:19.12");
assertTrue(ts1.equals(ts2) && ts2.equals(ts1),"Error ts1 != ts2");
assertFalse(ts1.equals(ts3) && ts3.equals(ts1),"Error ts1 == ts3");
}
项目：helper
文件：ProfilesPlugin.java
private void saveProfile(ImmutableProfile profile) {
try (Connection c = sql.getConnection()) {
try (PreparedStatement ps = c.prepareStatement(replaceTableName(INSERT))) {
ps.setString(1,UuidUtils.toString(profile.getUniqueId()));
ps.setString(2,profile.getName().get());
ps.setTimestamp(3,new Timestamp(profile.getTimestamp()));
ps.setString(4,profile.getName().get());
ps.setTimestamp(5,new Timestamp(profile.getTimestamp()));
ps.execute();
}
} catch (sqlException e) {
e.printstacktrace();
}
}
public Empenho(Fornecedor fornecedor,Timestamp emissao,String numero,String observacao,double valorTotal,ArrayList<EmpenhoItem> itens) {
this.fornecedor = fornecedor;
this.emissao = emissao;
this.numero = numero;
this.observacao = observacao;
this.valorTotal = valorTotal;
this.itens = itens;
}
项目：Pxls
文件：DBPixelPlacementUser.java
@Override
public DBPixelPlacementUser map(int index,ResultSet r,StatementContext ctx) throws sqlException {
Timestamp time = r.getTimestamp("time");
return new DBPixelPlacementUser(
r.getInt("id"),r.getInt("x"),r.getInt("y"),r.getInt("color"),time == null ? 0 : time.getTime(),r.getString("users.username"),r.getInt("pixel_count"),r.getInt("pixel_count_alltime")
);
}
项目：ctsms
文件：StaffServiceImpl.java
@Override
protected StaffStatusEntryOutVO handleAddStaffStatusEntry(
AuthenticationVO auth,StaffStatusEntryInVO newStaffStatusEntry) throws Exception {
checkStaffStatusEntryInput(newStaffStatusEntry);
StaffStatusEntryDao statusEntryDao = this.getStaffStatusEntryDao();
StaffStatusEntry statusEntry = statusEntryDao.staffStatusEntryInVOToEntity(newStaffStatusEntry);
Timestamp Now = new Timestamp(System.currentTimeMillis());
User user = CoreUtil.getUser();
CoreUtil.modifyVersion(statusEntry,user);
statusEntry = statusEntryDao.create(statusEntry);
notifyStaffInactive(statusEntry,Now);
StaffStatusEntryOutVO result = statusEntryDao.toStaffStatusEntryOutVO(statusEntry);
logSystemMessage(statusEntry.getStaff(),result.getStaff(),user,SystemMessageCodes.STAFF_STATUS_ENTRY_CREATED,this.getJournalEntryDao());
return result;
}
项目：coinapi-sdk
文件：java_rest_coin_api_test.java
private static void test_orderbooks_get_historical_data(String symbol_id,Timestamp time_start,Timestamp time_end,int limit) throws java_rest_coin_api.exception {
java_rest_coin_api c = new java_rest_coin_api(KEY);
System.out.println("Get historical orderbooks started");
java_rest_coin_api.orderbook[] result = c.orderbooks_get_historical_data(symbol_id,time_start,time_end,limit);
if (result!=null) {
for(java_rest_coin_api.orderbook o : result)
System.out.println(orderbook_to_string(o));
}
System.out.println("Get historical orderbooks finished");
System.out.println();
}
项目：ctsms
文件：InputFieldServiceImpl.java
private static JournalEntry logSystemMessage(User user,InputFieldOutVO inputFieldVO,Timestamp Now,User modified,String systemMessageCode,Object result,Object original,JournalEntryDao journalEntryDao) throws Exception {
if (user == null) {
return null;
}
return journalEntryDao.addSystemMessage(user,systemMessageCode,new Object[] { CommonUtil.inputFieldOutVOToString(inputFieldVO) },new Object[] { CoreUtil.getSystemMessageCommentContent(result,original,!CommonUtil.getUseJournalEncryption(JournalModule.USER_JOURNAL,null)) });
}
项目：ctsms
文件：DutyRosterTurnDaoImpl.java
/**
* @inheritDoc
*/
@Override
protected Collection<DutyRosterTurn> handleFindByDepartmentCategoryCalendarInterval(Long staffDepartmentId,Long staffCategoryId,Boolean allocatable,String calendar,Timestamp from,Timestamp to)
{
Criteria dutyRosterCriteria = createDutyRosterTurnCriteria("dutyRosterTurn");
CriteriaUtil.applyClosedIntervalCriterion(dutyRosterCriteria,from,to,null);
Criteria staffCriteria = null;
if (staffDepartmentId != null) {
staffCriteria = dutyRosterCriteria.createCriteria("staff",CriteriaSpecification.LEFT_JOIN);
} else if (staffCategoryId != null || allocatable != null) {
staffCriteria = dutyRosterCriteria.createCriteria("staff",CriteriaSpecification.INNER_JOIN);
}
if (staffDepartmentId != null || staffCategoryId != null || allocatable != null) {
if (staffDepartmentId != null) {
staffCriteria.add(Restrictions.or(Restrictions.isNull("dutyRosterTurn.staff"),Restrictions.eq("department.id",staffDepartmentId.longValue())));
}
if (staffCategoryId != null) {
staffCriteria.add(Restrictions.eq("category.id",staffCategoryId.longValue()));
}
if (allocatable != null) {
staffCriteria.add(Restrictions.eq("allocatable",allocatable.booleanValue()));
}
}
CategoryCriterion.apply(dutyRosterCriteria,new CategoryCriterion(calendar,"calendar",MatchMode.EXACT,EmptyPrefixModes.ALL_ROWS));
return dutyRosterCriteria.list();
}
项目：oneops
文件：DjRfcRelationAttributesRecord.java
/**
* {@inheritDoc}
*/
@Override
public DjRfcRelationAttributesRecord values(Long value1,Long value2,Integer value3,String value4,String value5,String value6,String value7,Timestamp value8) {
value1(value1);
value2(value2);
value3(value3);
value4(value4);
value5(value5);
value6(value6);
value7(value7);
value8(value8);
return this;
}
public static void insertEntidades(int numeroFila,int anio,int nivel,int entidad,String nombreEntidad,String abrevEntidad,String siglaEntidad,String base_legal,String mision,String politica,String objetivo,String diagnostico){
Connection conect=conectar();
String query = " insert into entidad (id,nombre,anho,nivel_id,abrev,sigla,fecha_creacion,base_legal,mision,politica,objetivo,diagnostico,version,numero_fila)"
+ " values (?,?)";
try {
Timestamp timestamp = new Timestamp(new Date().getTime());
PreparedStatement preparedStmt;
preparedStmt = conect.prepareStatement(query);
preparedStmt.setInt (1,entidad);
preparedStmt.setString (2,nombreEntidad);
preparedStmt.setInt (3,anio);
preparedStmt.setInt (4,nivel);
preparedStmt.setString(5,abrevEntidad);
preparedStmt.setString (6,siglaEntidad);
preparedStmt.setTimestamp (7,timestamp);
preparedStmt.setString (8,base_legal);
preparedStmt.setString (9,mision);
preparedStmt.setString (10,politica);
preparedStmt.setString (11,objetivo);
preparedStmt.setString (12,diagnostico);
preparedStmt.setInt (13,50);
preparedStmt.setInt (14,numeroFila);
preparedStmt.execute();
conect.close();
} catch (sqlException e) {e.printstacktrace();}
}
项目：BibliotecaPS
文件：BufferRow.java
@Override
public Timestamp getTimestampFast(int columnIndex,Calendar targetCalendar,TimeZone tz,boolean rollForward,MysqLConnection conn,ResultSetImpl rs)
throws sqlException {
if (isNull(columnIndex)) {
return null;
}
findAndSeekToOffset(columnIndex);
long length = this.rowFromServer.readFieldLength();
int offset = this.rowFromServer.getPosition();
return getTimestampFast(columnIndex,this.rowFromServer.getByteBuffer(),offset,(int) length,targetCalendar,tz,rollForward,conn,rs);
}
项目：Celebino
文件：GardenStatus.java
public GardenStatus(Long id,Garden garden,int sunLight,int soilHumidity,int airHumidity,int airTemperature,Timestamp time) {
super();
this.id = id;
this.garden = garden;
this.sunLight = sunLight;
this.soilHumidity = soilHumidity;
this.airHumidity = airHumidity;
this.airTemperature = airTemperature;
this.time = time;
}
项目：ctsms
文件：InventoryServiceImpl.java
@Override
protected InventoryStatusEntryOutVO handleAddInventoryStatusEntry(AuthenticationVO auth,InventoryStatusEntryInVO newInventoryStatusEntry) throws Exception {
checkInventoryStatusEntryInput(newInventoryStatusEntry);
InventoryStatusEntryDao statusEntryDao = this.getInventoryStatusEntryDao();
InventoryStatusEntry statusEntry = statusEntryDao.inventoryStatusEntryInVOToEntity(newInventoryStatusEntry);
Timestamp Now = new Timestamp(System.currentTimeMillis());
User user = CoreUtil.getUser();
CoreUtil.modifyVersion(statusEntry,user);
statusEntry = statusEntryDao.create(statusEntry);
notifyInventoryInactive(statusEntry,Now);
InventoryStatusEntryOutVO result = statusEntryDao.toInventoryStatusEntryOutVO(statusEntry);
logSystemMessage(statusEntry.getInventory(),result.getInventory(),SystemMessageCodes.INVENTORY_STATUS_ENTRY_CREATED,this.getJournalEntryDao());
return result;
}
项目：AssistantBySDK
文件：TimeUtils.java
/**
* 把一个时间转换成timestamp格式(yyyy-MM-dd)
*
* @param str
* @return
*/
public static Timestamp convertTimestamp(String str) {
if (str == null || str.length() == 0)
return null;
try {
return new Timestamp((new SimpleDateFormat("yyyy-MM-dd")).parse(str).getTime());
} catch (ParseException e) {
e.printstacktrace();
return null;
}
}
项目：oneops
文件：DjReleasesRecord.java
/**
* Setter for <code>kloopzcm.dj_releases.created</code>.
*/
public void setCreated(Timestamp value) {
set(10,value);
}
项目：Celebino
文件：Watering.java
public void setTime(Timestamp time) {
this.time = time;
}
项目：oneops
文件：MdRelationAttributesRecord.java
/**
* {@inheritDoc}
*/
@Override
public MdRelationAttributesRecord value10(Timestamp value) {
setCreated(value);
return this;
}
项目：coinapi-sdk
文件：java_rest_coin_api.java
public Timestamp get_time_coinapi() {
return time_coinapi;
}
项目：CrashCoin
文件：Transaction.java
public Transaction(final Address destAddress) {
this(destAddress,new Timestamp(System.currentTimeMillis()));
}
项目：school-express-delivery
文件：ReviewEntity.java
public void setTime(Timestamp time) {
this.time = time;
}
项目：sunbird-lms-mw
文件：BackgroundJobManager.java
private void enrollParticipants(Map<String,Object> batch) {
Util.DbInfo courseBatchDBInfo = Util.dbInfoMap.get(JsonKey.COURSE_BATCH_DB);
Util.DbInfo courseEnrollmentdbInfo = Util.dbInfoMap.get(JsonKey.LEARNER_COURSE_DB);
Map<String,String> additionalCourseInfo =
(Map<String,String>) batch.get(JsonKey.COURSE_ADDITIONAL_INFO);
Map<String,Boolean> participants = (Map<String,Boolean>) batch.get(JsonKey.PARTICIPANT);
for (Map.Entry<String,Boolean> entry : participants.entrySet()) {
if (!entry.getValue()) {
Timestamp ts = new Timestamp(new Date().getTime());
Map<String,Object> userCourses = new HashMap<>();
userCourses.put(JsonKey.USER_ID,entry.getKey());
userCourses.put(JsonKey.BATCH_ID,batch.get(JsonKey.ID));
userCourses.put(JsonKey.COURSE_ID,batch.get(JsonKey.COURSE_ID));
userCourses.put(JsonKey.ID,generatePrimaryKey(userCourses));
userCourses.put(JsonKey.CONTENT_ID,batch.get(JsonKey.COURSE_ID));
userCourses.put(JsonKey.COURSE_ENROLL_DATE,ProjectUtil.getFormattedDate());
userCourses.put(JsonKey.ACTIVE,ProjectUtil.ActiveStatus.ACTIVE.getValue());
userCourses.put(JsonKey.STATUS,(int) batch.get(JsonKey.STATUS));
userCourses.put(JsonKey.DATE_TIME,ts);
userCourses.put(JsonKey.COURSE_PROGRESS,0);
userCourses.put(JsonKey.COURSE_logo_URL,additionalCourseInfo.get(JsonKey.APP_ICON));
userCourses.put(JsonKey.COURSE_NAME,additionalCourseInfo.get(JsonKey.NAME));
userCourses.put(JsonKey.DESCRIPTION,additionalCourseInfo.get(JsonKey.DESCRIPTION));
if (ProjectUtil.isstringNullOREmpty(additionalCourseInfo.get(JsonKey.LEAF_NODE_COUNT))) {
userCourses.put(JsonKey.LEAF_NODE_COUNT,additionalCourseInfo.get(JsonKey.LEAF_NODE_COUNT));
}
try {
cassandraOperation.insertRecord(courseEnrollmentdbInfo.getKeySpace(),courseEnrollmentdbInfo.getTableName(),userCourses);
// Todo: for some reason,ES indexing is failing with Timestamp value. need to check and
// correct it.
userCourses.put(JsonKey.DATE_TIME,ProjectUtil.formatDate(ts));
insertDataToElastic(ProjectUtil.EsIndex.sunbird.getIndexName(),ProjectUtil.EsType.usercourses.getTypeName(),(String) batch.get(JsonKey.ID),userCourses);
// update participant map value as true
entry.setValue(true);
} catch (Exception ex) {
ProjectLogger.log("INSERT RECORD TO USER COURSES EXCEPTION ",ex);
}
}
}
ProjectLogger.log("Adding participants to user course table completed");
Map<String,Object> updatedBatch = new HashMap<>();
updatedBatch.put(JsonKey.ID,batch.get(JsonKey.ID));
updatedBatch.put(JsonKey.PARTICIPANT,participants);
ProjectLogger.log("Updating participants to batch course table started");
cassandraOperation.updateRecord(courseBatchDBInfo.getKeySpace(),courseBatchDBInfo.getTableName(),updatedBatch);
ProjectLogger.log("Updating participants to batch course table completed");
}
项目：amap
文件：MIP_CalendarUtils.java
public Timestamp getTimestamp()
{
return new Timestamp(cal.getTimeInMillis());
}
项目：userinterface
文件：PagesEntity.java
public void setFoundDateTime(Timestamp foundDateTime) {
this.foundDateTime = foundDateTime;
}
项目：dremio-oss
文件：DremioResultSetImpl.java
@Override
public Timestamp getTimestamp( int columnIndex ) throws sqlException {
throwIfClosed();
return super.getTimestamp( columnIndex );
}
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。