为什么80%的码农都做不了架构师？>>>   

Files.readLines(file, Charset.forName("utf-8"), new LineProcessor() {@Overridepublic boolean processLine(String line) throws IOException {String[] messages = StringUtils.splitByWholeSeparatorPreserveAllTokens(line, ",");String[] socketLogicIds = StringUtils.splitByWholeSeparatorPreserveAllTokens(finalLogicId, ",");StringBuffer socketLogicIdValue = new StringBuffer();for(int i=0;i<socketLogicIds.length;i++){int index = Integer.parseInt(socketLogicIds[i]);socketLogicIdValue.append(messages[index].equalsIgnoreCase("null")?"":messages[index]);}StringBuffer socketLacCiIdKey = new StringBuffer();int socketLacCiIdIndex = Integer.parseInt(finalLacCiId);socketLacCiIdKey.append(messages[socketLacCiIdIndex]);laciCacheDara.put(socketLacCiIdKey.toString(), socketLogicIdValue.toString());return true;}

　　　　　Date date = new Date();String aString = DateFormatUtils.format(date, "yyyy-MM-dd ");Date  ddDate =DateUtils.addDays(date, -10);

　　　　String execDate ="20141210";Date date = DateUtils.parseDate(execDate, new String[]{"yyyyMMdd"});System.out.println(date);String startDateStr = DateFormatUtils.format(date, "yyyy-MM-01 00:00:00");System.out.println(startDateStr);   DateUtils.addDays(date, 2);

private static final void out(String string, HttpServletResponse response) {PrintWriter writer = null;try {response.setContentType("application/json; charset=UTF-8");response.setCharacterEncoding("UTF-8");response.setHeader("progma", "no-cache");response.setHeader("Access-Control-Allow-Origin", "*");response.setHeader("Cache-Control", "no-cache");writer = response.getWriter();writer.write(string);} catch (IOException e) {LOG.error("",e);dataJson.put("status", "201");out.print(dataJson);} finally {if (null != writer) {writer.flush();writer.close();}}}

public static Map<String, Object> jsonToMap(String paramJson ){Map<String, Object> paramsMap = new HashMap<String, Object>();paramsMap = (Map<String, Object>) JSONObject.fromObject(paramJson);return paramsMap;}

/*** 判断obj是否为空或者0 是返True* @param obj* @return*/private static Boolean isNullOrZero(Object obj) {Boolean flag = false;if(null !=obj){String str = String.valueOf(obj);if (("0").equals(str) || "".equals(str)) {flag = true;}}else{flag = true;    }return flag;}

public List getMtlCtrlProductNo(String campsegId,String channelId,Date beginDate,String count){StringBuffer sql = new StringBuffer("SELECT PRODUCT_NO, COUNT(1)  FROM MTL_CONTACT_ACTIVITY_RCT_LOG  ");sql.append(" where CAMPSEG_ID = ?  AND CHANNEL_ID = ?  ");sql.append("  AND LOG_TIME >=  ?  ");sql.append(" GROUP BY PRODUCT_NO HAVING   COUNT(1) >= ?  ");List list = this.getJdbcTemplate().queryForList(sql.toString(),new Object[]{campsegId,channelId,beginDate,Integer.valueOf(count)});return list;}

/*** 处理成千分位* @param number* @param pattern   ",###,###"||",###,###.00"* @return*/public static String parseMoney(String number,String pattern){if(StringUtils.isEmpty(pattern)){pattern = ",###,###";}BigDecimal bd=new BigDecimal(number);DecimalFormat df=new DecimalFormat(pattern);return df.format(bd);}/*** 处理成百分数* @param number* @return*/public static String parsePercent(String number){double result=Double.valueOf(number);DecimalFormat df = new DecimalFormat("0.00%");return df.format(result);}

public List<MtlBotherContactConfig> getMtlBotherContactConfigList() {StringBuffer sql = new StringBuffer("select * from MTL_BOTHER_CONTACT_CONFIG where CONTACT_CONTROL_FLAG <> 0 ");List<MtlBotherContactConfig> list = getJdbcTemplate().query(sql.toString(),new RowMapper(){@Overridepublic Object mapRow(ResultSet rs, int arg1) throws SQLException {MtlBotherContactConfig obj = new MtlBotherContactConfig();obj.setAvoidBotherFlag(rs.getLong("AVOID_BOTHER_FLAG"));obj.setCampsegCityType(rs.getLong("CAMPSEG_CITY_TYPE"));obj.setCampsegTypeId(rs.getLong("CAMPSEG_TYPE_ID"));obj.setChannelId(rs.getString("CHANNEL_ID"));obj.setContactControlFlag(rs.getLong("CONTACT_CONTROL_FLAG"));obj.setParamDays(rs.getLong("PARAM_DAYS"));obj.setParamNum(rs.getLong("PARAM_NUM"));return obj;}});return list;}

/*** 加载接触频次控制渠道配置规则* @param sql* @param map*/private void loadChannelContactRuleConfig(String sql, final Map<String, Map<String,Object>> map) {JdbcTemplate jt = SpringContext.getBean("jdbcTemplate", JdbcTemplate.class);jt.query(sql, new RowMapper() {public Object mapRow(ResultSet rs, int rowNum) throws SQLException {String channelId = rs.getString("CHANNEL_ID");String channelName = rs.getString("CHANNEL_NAME");Integer userLevelControlFlag = rs.getInt("USER_LEVEL_CONTROL_FLAG");//此渠道是否接受用户级的接触频次控制:0:不受控制，1：受控制Integer channelDayCount = rs.getInt("CHANNEL_DAY_COUNT");//每个用户在这个渠道每天最多可以接受多少次Integer channelMonthCount = rs.getInt("CHANNEL_MONTH_COUNT");//每个用户在这个渠道每个月最多可以接受多少次if (StringUtil.isNotEmpty(channelId)) {Map<String, Object> channelConfig = new HashMap<String,Object>();channelConfig.put("channelId", channelId);channelConfig.put("channelName", channelName);channelConfig.put("userLevelControlFlag", userLevelControlFlag);channelConfig.put("channelDayCount", channelDayCount);channelConfig.put("channelMonthCount", channelMonthCount);map.put(channelId, channelConfig);}return null;}});}

  sql.append("SELECT * FROM USER");        return this.getJdbcTemplate().query(sql.toString(),            ParameterizedBeanPropertyRowMapper.newInstance(user.class));

///INSERT_MESSAGE_SQL = INSERT INTO BS_SMS_PUSH_R(ID,TASK_ID,CHANNEL_ID,MSISDN,SUBJECT,STATUS,SEND_COUNT,CREATE_TIME,UPDATE_TIME) VALUES (:id,:taskId,:channelId,:productNo,:msg,:status,:sendCount,:createTime,:updateTime)            String sql = MpmConfigure.getInstance().getProperty("INSERT_MESSAGE_SQL");            SqlParameterSource[] params = SqlParameterSourceUtils.createBatch(msgList.toArray());            SimpleJdbcTemplate messageSimpleJdbcTemplate = SpringContext.getBean("messageSimpleJdbcTemplate", SimpleJdbcTemplate.class);            messageSimpleJdbcTemplate.batchUpdate(sql, params);